X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=tapi%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Ftransportpce%2Ftapi%2Fconnectivity%2FTapiConnectivityImpl.java;h=c62645344fa24bc294d9d33607f23921a1328c61;hb=b4e55db9320fecf507cb9193037ce231d92b896a;hp=cd5d1da72a2609f76cdf9bf07f60f8bd76dfb56f;hpb=af4ed1fe1d489698d70d874471968972507f7c6b;p=transportpce.git diff --git a/tapi/src/main/java/org/opendaylight/transportpce/tapi/connectivity/TapiConnectivityImpl.java b/tapi/src/main/java/org/opendaylight/transportpce/tapi/connectivity/TapiConnectivityImpl.java index cd5d1da72..c62645344 100644 --- a/tapi/src/main/java/org/opendaylight/transportpce/tapi/connectivity/TapiConnectivityImpl.java +++ b/tapi/src/main/java/org/opendaylight/transportpce/tapi/connectivity/TapiConnectivityImpl.java @@ -8,7 +8,7 @@ package org.opendaylight.transportpce.tapi.connectivity; import com.google.common.util.concurrent.ListenableFuture; -import java.nio.charset.Charset; +import java.nio.charset.StandardCharsets; import java.util.HashMap; import java.util.Map; import java.util.UUID; @@ -230,7 +230,7 @@ public class TapiConnectivityImpl implements TapiConnectivityService { public ListenableFuture> getConnectivityServiceDetails( GetConnectivityServiceDetailsInput input) { // TODO Auto-generated method stub - Uuid serviceUuid = new Uuid(input.getServiceIdOrName()); + Uuid serviceUuid = getUuidFromIput(input.getServiceIdOrName()); ConnectivityService service = this.tapiContext.getConnectivityService(serviceUuid); if (service == null) { LOG.error("Service {} doesnt exist in tapi context", input.getServiceIdOrName()); @@ -254,8 +254,7 @@ public class TapiConnectivityImpl implements TapiConnectivityService { public ListenableFuture> getConnectionDetails( GetConnectionDetailsInput input) { // TODO Auto-generated method stub - Uuid connectionUuid = new Uuid(UUID.nameUUIDFromBytes(input.getConnectionIdOrName() - .getBytes(Charset.forName("UTF-8"))).toString()); + Uuid connectionUuid = getUuidFromIput(input.getConnectionIdOrName()); Connection connection = this.tapiContext.getConnection(connectionUuid); if (connection == null) { LOG.error("Connection {} doesnt exist in tapi context", input.getConnectionIdOrName()); @@ -273,7 +272,7 @@ public class TapiConnectivityImpl implements TapiConnectivityService { // TODO add try if (input.getServiceIdOrName() != null) { try { - Uuid serviceUuid = new Uuid(input.getServiceIdOrName()); + Uuid serviceUuid = getUuidFromIput(input.getServiceIdOrName()); this.tapiContext.deleteConnectivityService(serviceUuid); ListenableFuture> output = this.serviceHandler.serviceDelete(new ServiceDeleteInputBuilder() @@ -329,14 +328,10 @@ public class TapiConnectivityImpl implements TapiConnectivityService { public ListenableFuture> getConnectionEndPointDetails( GetConnectionEndPointDetailsInput input) { // TODO Auto-generated method stub - Uuid topoUuid = new Uuid(UUID.nameUUIDFromBytes(input.getTopologyIdOrName() - .getBytes(Charset.forName("UTF-8"))).toString()); - Uuid nodeUuid = new Uuid(UUID.nameUUIDFromBytes(input.getNodeIdOrName() - .getBytes(Charset.forName("UTF-8"))).toString()); - Uuid nepUuid = new Uuid(UUID.nameUUIDFromBytes(input.getNepIdOrName() - .getBytes(Charset.forName("UTF-8"))).toString()); - Uuid cepUuid = new Uuid(UUID.nameUUIDFromBytes(input.getCepIdOrName() - .getBytes(Charset.forName("UTF-8"))).toString()); + Uuid topoUuid = getUuidFromIput(input.getTopologyIdOrName()); + Uuid nodeUuid = getUuidFromIput(input.getNodeIdOrName()); + Uuid nepUuid = getUuidFromIput(input.getNepIdOrName()); + Uuid cepUuid = getUuidFromIput(input.getCepIdOrName()); ConnectionEndPoint cep = this.tapiContext.getTapiCEP(topoUuid, nodeUuid, nepUuid, cepUuid); if (cep == null) { LOG.error("Cep doesnt exist in tapi context"); @@ -346,4 +341,15 @@ public class TapiConnectivityImpl implements TapiConnectivityService { return RpcResultBuilder.success(new GetConnectionEndPointDetailsOutputBuilder().setConnectionEndPoint( new ConnectionEndPointBuilder(cep).build()).build()).buildFuture(); } + + private Uuid getUuidFromIput(String serviceIdOrName) { + try { + UUID.fromString(serviceIdOrName); + LOG.info("Given attribute {} is a UUID", serviceIdOrName); + return new Uuid(serviceIdOrName); + } catch (IllegalArgumentException e) { + LOG.info("Given attribute {} is not a UUID", serviceIdOrName); + return new Uuid(UUID.nameUUIDFromBytes(serviceIdOrName.getBytes(StandardCharsets.UTF_8)).toString()); + } + } }