X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=servicehandler%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Ftransportpce%2Fservicehandler%2Fimpl%2FServicehandlerImpl.java;h=2c0ea7d0a8fe9460925cb76bae04e9fc89b8ec41;hb=b1b3bafd549bb501937cea5c976d5344608b6ed3;hp=48583b38f131bc0f033cc234ddf7fd9643bcbd10;hpb=e14bba1b91c605df2106d3068f92168a2abd5d87;p=transportpce.git diff --git a/servicehandler/src/main/java/org/opendaylight/transportpce/servicehandler/impl/ServicehandlerImpl.java b/servicehandler/src/main/java/org/opendaylight/transportpce/servicehandler/impl/ServicehandlerImpl.java index 48583b38f..2c0ea7d0a 100644 --- a/servicehandler/src/main/java/org/opendaylight/transportpce/servicehandler/impl/ServicehandlerImpl.java +++ b/servicehandler/src/main/java/org/opendaylight/transportpce/servicehandler/impl/ServicehandlerImpl.java @@ -7,68 +7,34 @@ */ package org.opendaylight.transportpce.servicehandler.impl; -import com.google.common.util.concurrent.ListenableFuture; -import java.time.OffsetDateTime; -import java.time.ZoneOffset; -import java.time.format.DateTimeFormatter; -import java.util.Optional; -import java.util.concurrent.ExecutionException; -import org.opendaylight.controller.md.sal.binding.api.DataBroker; -import org.opendaylight.transportpce.common.OperationResult; -import org.opendaylight.transportpce.common.ResponseCodes; +import com.google.common.collect.ImmutableClassToInstanceMap; +import org.opendaylight.mdsal.binding.api.NotificationPublishService; +import org.opendaylight.mdsal.binding.api.RpcProviderService; import org.opendaylight.transportpce.pce.service.PathComputationService; import org.opendaylight.transportpce.renderer.provisiondevice.RendererServiceOperations; -import org.opendaylight.transportpce.servicehandler.ModelMappingUtils; +import org.opendaylight.transportpce.servicehandler.catalog.CatalogDataStoreOperations; +import org.opendaylight.transportpce.servicehandler.listeners.NetworkListener; +import org.opendaylight.transportpce.servicehandler.listeners.PceListener; +import org.opendaylight.transportpce.servicehandler.listeners.RendererListener; import org.opendaylight.transportpce.servicehandler.service.PCEServiceWrapper; +import org.opendaylight.transportpce.servicehandler.service.RendererServiceWrapper; import org.opendaylight.transportpce.servicehandler.service.ServiceDataStoreOperations; -import org.opendaylight.transportpce.servicehandler.service.ServiceDataStoreOperationsImpl; -import org.opendaylight.transportpce.servicehandler.validation.ServiceCreateValidation; -import org.opendaylight.transportpce.servicehandler.validation.checks.ComplianceCheckResult; -import org.opendaylight.transportpce.servicehandler.validation.checks.ServicehandlerCompliancyCheck; -import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev170426.PathComputationRequestOutput; -import org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev161014.RpcActions; -import org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev161014.sdnc.request.header.SdncRequestHeaderBuilder; -import org.opendaylight.yang.gen.v1.http.org.openroadm.common.types.rev161014.RpcStatus; -import org.opendaylight.yang.gen.v1.http.org.openroadm.common.types.rev161014.State; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.EquipmentNotificationInput; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.EquipmentNotificationOutput; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.NetworkReOptimizationInput; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.NetworkReOptimizationOutput; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.OrgOpenroadmServiceService; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.ServiceCreateInput; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.ServiceCreateInputBuilder; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.ServiceCreateOutput; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.ServiceDeleteInput; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.ServiceDeleteInputBuilder; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.ServiceDeleteOutput; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.ServiceFeasibilityCheckInput; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.ServiceFeasibilityCheckOutput; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.ServiceReconfigureInput; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.ServiceReconfigureOutput; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.ServiceRerouteConfirmInput; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.ServiceRerouteConfirmOutput; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.ServiceRerouteInput; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.ServiceRerouteOutput; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.ServiceRerouteOutputBuilder; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.ServiceRestorationInput; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.ServiceRestorationOutput; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.ServiceReversionInput; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.ServiceReversionOutput; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.ServiceRollInput; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.ServiceRollOutput; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.TempServiceCreateInput; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.TempServiceCreateOutput; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.TempServiceDeleteInput; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.TempServiceDeleteOutput; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.service.create.input.ServiceAEndBuilder; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.service.create.input.ServiceZEndBuilder; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.service.delete.input.ServiceDeleteReqInfo.TailRetention; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.service.delete.input.ServiceDeleteReqInfoBuilder; -import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev161014.service.list.Services; -import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.servicepath.rev170426.ServiceImplementationRequestInput; -import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.DateAndTime; -import org.opendaylight.yangtools.yang.common.RpcResult; -import org.opendaylight.yangtools.yang.common.RpcResultBuilder; +import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev230526.AddOpenroadmOperationalModesToCatalog; +import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev230526.AddSpecificOperationalModesToCatalog; +import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev230526.ServiceCreate; +import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev230526.ServiceDelete; +import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev230526.ServiceFeasibilityCheck; +import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev230526.ServiceReconfigure; +import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev230526.ServiceReroute; +import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev230526.ServiceRestoration; +import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev230526.TempServiceCreate; +import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev230526.TempServiceDelete; +import org.opendaylight.yangtools.concepts.Registration; +import org.opendaylight.yangtools.yang.binding.Rpc; +import org.osgi.service.component.annotations.Activate; +import org.osgi.service.component.annotations.Component; +import org.osgi.service.component.annotations.Deactivate; +import org.osgi.service.component.annotations.Reference; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -76,302 +42,120 @@ import org.slf4j.LoggerFactory; /** * Top level service interface providing main OpenROADM controller services. */ -public class ServicehandlerImpl implements OrgOpenroadmServiceService { - +@Component +public class ServicehandlerImpl { private static final Logger LOG = LoggerFactory.getLogger(ServicehandlerImpl.class); - private DataBroker db; private ServiceDataStoreOperations serviceDataStoreOperations; - private RendererServiceOperations rendererServiceOperations; + private PceListener pceListenerImpl; + private RendererListener rendererListenerImpl; + private NetworkListener networkModelListenerImpl; + private CatalogDataStoreOperations catalogDataStoreOperations; + private NotificationPublishService notificationPublishService; private PCEServiceWrapper pceServiceWrapper; - - //TODO: remove private request fields as they are in global scope - - public ServicehandlerImpl(DataBroker databroker, PathComputationService pathComputationService, - RendererServiceOperations rendererServiceOperations) { - this.db = databroker; - this.rendererServiceOperations = rendererServiceOperations; - this.serviceDataStoreOperations = new ServiceDataStoreOperationsImpl(this.db); - this.serviceDataStoreOperations.initialize(); - this.pceServiceWrapper = new PCEServiceWrapper(pathComputationService); + private RendererServiceWrapper rendererServiceWrapper; + private Registration reg; + + @Activate + public ServicehandlerImpl(@Reference RpcProviderService rpcProviderService, + @Reference ServiceDataStoreOperations serviceDataStoreOperations, + @Reference PceListener pceListenerImpl, + @Reference RendererListener rendererListenerImpl, + @Reference NetworkListener networkModelListenerImpl, + @Reference CatalogDataStoreOperations catalogDataStoreOperations, + @Reference PathComputationService pathComputationService, + @Reference RendererServiceOperations rendererServiceOperations, + @Reference NotificationPublishService notificationPublishService) { + this.serviceDataStoreOperations = serviceDataStoreOperations; + this.pceListenerImpl = pceListenerImpl; + this.rendererListenerImpl = rendererListenerImpl; + this.networkModelListenerImpl = networkModelListenerImpl; + this.catalogDataStoreOperations = catalogDataStoreOperations; + this.notificationPublishService = notificationPublishService; + this.pceServiceWrapper = new PCEServiceWrapper(pathComputationService, notificationPublishService); + this.rendererServiceWrapper = new RendererServiceWrapper(rendererServiceOperations, notificationPublishService); + this.reg = rpcProviderService.registerRpcImplementations(registerRPCs()); + LOG.info("ServicehandlerImpl Initiated"); } - @Override - public ListenableFuture> serviceCreate(ServiceCreateInput input) { - LOG.info("RPC service creation received"); - // Validation - OperationResult validationResult = ServiceCreateValidation.validateServiceCreateRequest(input); - if (! validationResult.isSuccess()) { - LOG.warn("Aborting service create because validation of service create request failed: {}", - validationResult.getResultMessage()); - return ModelMappingUtils.createCreateServiceReply(input, ResponseCodes.FINAL_ACK_YES, - validationResult.getResultMessage(), ResponseCodes.RESPONSE_FAILED); - } - - // Starting service create operation - LOG.info("Commencing PCE"); - //TODO: createService service status into datastore - PathComputationRequestOutput pceResponse = this.pceServiceWrapper.performPCE(input, true); - String pceResponseCode = pceResponse.getConfigurationResponseCommon().getResponseCode(); - if (!ResponseCodes.RESPONSE_OK.equals(pceResponseCode)) { - LOG.info("PCE calculation failed {}", pceResponseCode); - return ModelMappingUtils.createCreateServiceReply(input, ResponseCodes.FINAL_ACK_YES, - pceResponse.getConfigurationResponseCommon().getResponseMessage(), ResponseCodes.RESPONSE_FAILED); - } - - LOG.info("PCE calculation done OK {}", pceResponseCode); - - OperationResult operationResult = this.serviceDataStoreOperations.createService(input, pceResponse); - if (!operationResult.isSuccess()) { - String message = "Service status not updated in datastore !"; - LOG.info(message); - return ModelMappingUtils.createCreateServiceReply(input, ResponseCodes.FINAL_ACK_YES, message, - ResponseCodes.RESPONSE_FAILED); - } - - OperationResult operationServicePathSaveResult = this.serviceDataStoreOperations.createServicePath(input, - pceResponse); - if (!operationServicePathSaveResult.isSuccess()) { - String message = "Service Path not updated in datastore !"; - LOG.info(message); - return ModelMappingUtils.createCreateServiceReply(input, ResponseCodes.FINAL_ACK_YES, message, - ResponseCodes.RESPONSE_FAILED); - } - - ServiceImplementationRequestInput serviceImplementationRequest = - ModelMappingUtils.createServiceImplementationRequest(input, pceResponse); - org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.servicepath.rev170426 - .ServiceImplementationRequestOutput serviceImplementationRequestOutput = this.rendererServiceOperations - .serviceImplementation(serviceImplementationRequest); - if (ResponseCodes.RESPONSE_OK - .equals(serviceImplementationRequestOutput.getConfigurationResponseCommon().getResponseCode())) { - String message = "Service rendered successfully !"; - LOG.info(message); - operationResult = this.serviceDataStoreOperations.modifyService(input.getServiceName(), State.InService, - State.InService); - if (!operationResult.isSuccess()) { - LOG.warn("Service status not updated in datastore !"); - } - return ModelMappingUtils.createCreateServiceReply(input, ResponseCodes.FINAL_ACK_YES, message, - ResponseCodes.RESPONSE_OK); - } else { - String message = "Service rendering has failed !"; - LOG.warn(message); - - OperationResult deleteServicePathOperationResult = - this.serviceDataStoreOperations.deleteServicePath(input.getServiceName()); - if (!deleteServicePathOperationResult.isSuccess()) { - LOG.warn("Service path was not removed from datastore!"); - } - - OperationResult deleteServiceOperationResult = - this.serviceDataStoreOperations.deleteService(input.getServiceName()); - if (!deleteServiceOperationResult.isSuccess()) { - LOG.warn("Service was not removed from datastore!"); - } + @Deactivate + public void close() { + this.reg.close(); + LOG.info("ServicehandlerImpl Closed"); + } - return ModelMappingUtils.createCreateServiceReply(input, ResponseCodes.FINAL_ACK_YES, message, - ResponseCodes.RESPONSE_FAILED); - } + public Registration getRegisteredRpc() { + return reg; } - @Override - public ListenableFuture> serviceDelete(ServiceDeleteInput input) { - LOG.info("RPC serviceDelete request received for {}", input.getServiceDeleteReqInfo().getServiceName()); - String message = ""; + private ImmutableClassToInstanceMap> registerRPCs() { + return ImmutableClassToInstanceMap.>builder() + .put(ServiceCreate.class, new ServiceCreateImpl(serviceDataStoreOperations, pceListenerImpl, + rendererListenerImpl, networkModelListenerImpl, pceServiceWrapper, notificationPublishService)) + .put(ServiceDelete.class, new ServiceDeleteImpl(serviceDataStoreOperations, pceListenerImpl, + rendererListenerImpl, networkModelListenerImpl, rendererServiceWrapper, notificationPublishService)) + .put(ServiceFeasibilityCheck.class, new ServiceFeasibilityCheckImpl(serviceDataStoreOperations, + pceListenerImpl, rendererListenerImpl, networkModelListenerImpl, pceServiceWrapper)) + .put(ServiceReconfigure.class, new ServiceReconfigureImpl(serviceDataStoreOperations, pceListenerImpl, + rendererListenerImpl, networkModelListenerImpl, rendererServiceWrapper)) + .put(ServiceRestoration.class, new ServiceRestorationImpl(serviceDataStoreOperations, pceListenerImpl, + rendererListenerImpl, networkModelListenerImpl, rendererServiceWrapper)) + .put(ServiceReroute.class, new ServiceRerouteImpl(serviceDataStoreOperations, pceServiceWrapper)) + .put(TempServiceCreate.class, new TempServiceCreateImpl(serviceDataStoreOperations, pceListenerImpl, + rendererListenerImpl, networkModelListenerImpl, pceServiceWrapper)) + .put(TempServiceDelete.class, new TempServiceDeleteImpl(serviceDataStoreOperations, pceListenerImpl, + rendererListenerImpl, rendererServiceWrapper)) + .put(AddOpenroadmOperationalModesToCatalog.class, + new AddOpenroadmOperationalModesToCatalogImpl(catalogDataStoreOperations)) + .put(AddSpecificOperationalModesToCatalog.class, + new AddSpecificOperationalModesToCatalogImpl(catalogDataStoreOperations)) + .build(); + } - /* - * Upon receipt of service-deleteService RPC, service header and sdnc-request - * header compliancy are verified. - */ - LOG.info("checking Service Compliancy ..."); - ComplianceCheckResult serviceHandlerCheckResult = ServicehandlerCompliancyCheck.check( - input.getServiceDeleteReqInfo().getServiceName(), - input.getSdncRequestHeader(), null, RpcActions.ServiceDelete, false, true); - if (serviceHandlerCheckResult.hasPassed()) { - LOG.info("Service compliant !"); - } else { - LOG.info("Service is not compliant !"); - return ModelMappingUtils - .createDeleteServiceReply(input, ResponseCodes.FINAL_ACK_YES, - "Service not compliant !", ResponseCodes.RESPONSE_FAILED); + // This is class is public so that these messages can be accessed from Junit (avoid duplications). + public static final class LogMessages { + + public static final String PCE_CALLING; + public static final String ABORT_PCE_FAILED; + public static final String PCE_FAILED; + public static final String ABORT_SERVICE_NON_COMPLIANT; + public static final String SERVICE_NON_COMPLIANT; + public static final String RENDERER_DELETE_FAILED; + public static final String ABORT_VALID_FAILED; + public static final String ABORT_OR_TO_CATALOG_FAILED; + public static final String ABORT_SPECIFIC_TO_CATALOG_FAILED; + + // Static blocks are generated once and spare memory. + static { + PCE_CALLING = "Calling PCE"; + ABORT_PCE_FAILED = "Aborting: PCE calculation failed "; + PCE_FAILED = "PCE calculation failed"; + ABORT_SERVICE_NON_COMPLIANT = "Aborting: non-compliant service "; + SERVICE_NON_COMPLIANT = "non-compliant service"; + RENDERER_DELETE_FAILED = "Renderer service delete failed"; + ABORT_VALID_FAILED = "Aborting: validation of service create request failed"; + ABORT_OR_TO_CATALOG_FAILED = "Aborting: validation of add OR to catalog request failed"; + ABORT_SPECIFIC_TO_CATALOG_FAILED = "Aborting: validation of add Specific to catalog request failed"; } - //Check presence of service to be deleted - String serviceName = input.getServiceDeleteReqInfo().getServiceName(); - LOG.info("serviceName : {}", serviceName); - try { - Optional service = this.serviceDataStoreOperations.getService(serviceName); - if (!service.isPresent()) { - message = "Service '" + serviceName + "' does not exist in datastore"; - LOG.error(message); - return ModelMappingUtils.createDeleteServiceReply(input, ResponseCodes.FINAL_ACK_YES, - message, ResponseCodes.RESPONSE_FAILED); - } - } catch (NullPointerException e) { - LOG.info("failed to get service '{}' from datastore : ", serviceName, e); + public static String serviceInDS(String serviceName) { + return "Service '" + serviceName + "' already exists in datastore"; } - LOG.debug("Service '{}' present in datastore !", serviceName); - org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.servicepath.rev170426.ServiceDeleteInput - serviceDeleteInput = ModelMappingUtils.createServiceDeleteInput(input); - org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.servicepath.rev170426 - .ServiceDeleteOutput output = this.rendererServiceOperations.serviceDelete(serviceDeleteInput); - - if (!ResponseCodes.RESPONSE_OK - .equals(output.getConfigurationResponseCommon().getResponseCode())) { - message = "Service delete failed!"; - return ModelMappingUtils.createDeleteServiceReply(input, ResponseCodes.FINAL_ACK_YES, message, - ResponseCodes.RESPONSE_FAILED); + public static String serviceNotInDS(String serviceName) { + return "Service '" + serviceName + "' does not exist in datastore"; } - OperationResult deleteServicePathOperationResult = - this.serviceDataStoreOperations.deleteServicePath(input.getServiceDeleteReqInfo().getServiceName()); - if (!deleteServicePathOperationResult.isSuccess()) { - LOG.warn("Service path was not removed from datastore!"); + public static String servicePathNotInDS(String serviceName) { + return "Service Path from '" + serviceName + "' does not exist in datastore"; } - OperationResult deleteServiceOperationResult = - this.serviceDataStoreOperations.deleteService(input.getServiceDeleteReqInfo().getServiceName()); - if (!deleteServiceOperationResult.isSuccess()) { - LOG.warn("Service was not removed from datastore!"); + public static String serviceInService(String serviceName) { + return "Service '" + serviceName + "' is in 'inService' state"; } - return ModelMappingUtils.createDeleteServiceReply(input, ResponseCodes.FINAL_ACK_YES, - "Service delete was successful!", ResponseCodes.RESPONSE_OK); - } - - @Override - public ListenableFuture> serviceFeasibilityCheck( - ServiceFeasibilityCheckInput input) { - throw new UnsupportedOperationException("Not implemented yet"); - } - - @Override - public ListenableFuture> serviceReconfigure(ServiceReconfigureInput input) { - throw new UnsupportedOperationException("Not implemented yet"); - } - - @Override - public ListenableFuture> serviceRestoration(ServiceRestorationInput input) { - throw new UnsupportedOperationException("Not implemented yet"); - } - - @Override - public ListenableFuture> - equipmentNotification(EquipmentNotificationInput input) { - // TODO Auto-generated method stub - return null; - } - - @Override - public ListenableFuture> - serviceRerouteConfirm(ServiceRerouteConfirmInput input) { - // TODO Auto-generated method stub - return null; - } - - @Override - public ListenableFuture> serviceReroute(ServiceRerouteInput input) { - LOG.info("RPC service reroute received"); - String message = ""; - try { - Optional servicesObject = this.serviceDataStoreOperations.getService(input.getServiceName()); - if (servicesObject.isPresent()) { - ServiceDeleteInputBuilder deleteInputBldr = new ServiceDeleteInputBuilder(); - DateTimeFormatter dtf = DateTimeFormatter.ofPattern("yyyy-MM-dd'T'HH:mm:ssxxx"); - OffsetDateTime offsetDateTime = OffsetDateTime.now(ZoneOffset.UTC); - DateAndTime datetime = new DateAndTime(dtf.format(offsetDateTime)); - deleteInputBldr.setServiceDeleteReqInfo(new ServiceDeleteReqInfoBuilder() - .setServiceName(input.getServiceName()).setDueDate(datetime) - .setTailRetention(TailRetention.No).build()); - SdncRequestHeaderBuilder sdncBuilder = new SdncRequestHeaderBuilder(); - sdncBuilder.setNotificationUrl(servicesObject.get().getSdncRequestHeader().getNotificationUrl()); - sdncBuilder.setRequestId(servicesObject.get().getSdncRequestHeader().getRequestId()); - sdncBuilder.setRequestSystemId(servicesObject.get().getSdncRequestHeader().getRequestSystemId()); - sdncBuilder.setRpcAction(RpcActions.ServiceDelete); - deleteInputBldr.setSdncRequestHeader(sdncBuilder.build()); - // Calling delete service - ServiceDeleteOutput serviceDeleteOutput = serviceDelete(deleteInputBldr.build()).get().getResult(); - // Calling create request now - if (!ResponseCodes.RESPONSE_OK - .equals(serviceDeleteOutput.getConfigurationResponseCommon().getResponseCode())) { - message = "Service delete failed!"; - return ModelMappingUtils.createRerouteServiceReply(input, ResponseCodes.FINAL_ACK_YES, - message, RpcStatus.Failed); - } - ServiceCreateInputBuilder serviceCreateBldr = new ServiceCreateInputBuilder(); - serviceCreateBldr.setServiceName(input.getServiceName() + 2); - serviceCreateBldr.setCommonId(servicesObject.get().getCommonId()); - serviceCreateBldr.setConnectionType(servicesObject.get().getConnectionType()); - serviceCreateBldr.setCustomer(servicesObject.get().getCustomer()); - serviceCreateBldr.setCustomerContact(servicesObject.get().getCustomerContact()); - serviceCreateBldr.setDueDate(servicesObject.get().getDueDate()); - serviceCreateBldr.setEndDate(servicesObject.get().getEndDate()); - serviceCreateBldr.setHardConstraints(servicesObject.get().getHardConstraints()); - serviceCreateBldr.setNcCode(servicesObject.get().getNcCode()); - serviceCreateBldr.setNciCode(servicesObject.get().getNciCode()); - serviceCreateBldr.setOperatorContact(servicesObject.get().getOperatorContact()); - serviceCreateBldr.setSdncRequestHeader(servicesObject.get().getSdncRequestHeader()); - serviceCreateBldr.setSecondaryNciCode(servicesObject.get().getSecondaryNciCode()); - ServiceAEndBuilder serviceAendBuilder = new ServiceAEndBuilder(servicesObject.get().getServiceAEnd()); - serviceCreateBldr.setServiceAEnd(serviceAendBuilder.build()); - ServiceZEndBuilder serviceZendBuilder = new ServiceZEndBuilder(servicesObject.get().getServiceZEnd()); - serviceCreateBldr.setServiceZEnd(serviceZendBuilder.build()); - serviceCreateBldr.setSoftConstraints(servicesObject.get().getSoftConstraints()); - ServiceCreateOutput serviceCreateOutput = serviceCreate(serviceCreateBldr.build()).get().getResult(); - if (!ResponseCodes.RESPONSE_OK - .equals(serviceCreateOutput.getConfigurationResponseCommon().getResponseCode())) { - message = "Service create failed!"; - return ModelMappingUtils.createRerouteServiceReply(input, ResponseCodes.FINAL_ACK_YES, - message, RpcStatus.Failed); - } - ServiceRerouteOutputBuilder output = new ServiceRerouteOutputBuilder() - .setHardConstraints(null).setSoftConstraints(null).setStatus( - org.opendaylight.yang.gen.v1.http.org.openroadm.common.types.rev161014.RpcStatus.Successful) - .setStatusMessage("Service reroute successfully !"); - return RpcResultBuilder.success(output).buildFuture(); - } else { - LOG.error("Service '{}' is not present", input.getServiceName()); - message = "Service '" + input.getServiceName() + "' is not present"; - } - } catch (InterruptedException | ExecutionException e) { - LOG.info("Exception caught" , e); + private LogMessages() { } - ServiceRerouteOutputBuilder output = new ServiceRerouteOutputBuilder() - .setHardConstraints(null).setSoftConstraints(null).setStatus(RpcStatus.Failed).setStatusMessage(message); - return RpcResultBuilder.success(output).buildFuture(); - } - - @Override - public ListenableFuture> serviceReversion(ServiceReversionInput input) { - // TODO Auto-generated method stub - return null; } - - @Override - public ListenableFuture> serviceRoll(ServiceRollInput input) { - // TODO Auto-generated method stub - return null; - } - - @Override - public ListenableFuture> - networkReOptimization(NetworkReOptimizationInput input) { - // TODO Auto-generated method stub - return null; - } - - @Override - public ListenableFuture> tempServiceDelete(TempServiceDeleteInput input) { - // TODO Auto-generated method stub - return null; - } - - @Override - public ListenableFuture> tempServiceCreate(TempServiceCreateInput input) { - // TODO Auto-generated method stub - return null; - } - } +