servicehandler/src/main/java/org/opendaylight/transportpce/servicehandler/impl/ServiceRestorationImpl.java

   1 /*
   2  * Copyright © 2024 Orange, Inc. and others.  All rights reserved.
   3  *
   4  * This program and the accompanying materials are made available under the
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html
   7  */
   8 package org.opendaylight.transportpce.servicehandler.impl;
   9
  10 import com.google.common.util.concurrent.ListenableFuture;
  11 import java.time.OffsetDateTime;
  12 import java.time.ZoneOffset;
  13 import java.time.format.DateTimeFormatter;
  14 import java.util.Optional;
  15 import org.opendaylight.transportpce.servicehandler.DowngradeConstraints;
  16 import org.opendaylight.transportpce.servicehandler.ModelMappingUtils;
  17 import org.opendaylight.transportpce.servicehandler.ServiceInput;
  18 import org.opendaylight.transportpce.servicehandler.impl.ServicehandlerImpl.LogMessages;
  19 import org.opendaylight.transportpce.servicehandler.listeners.NetworkListener;
  20 import org.opendaylight.transportpce.servicehandler.listeners.PceListener;
  21 import org.opendaylight.transportpce.servicehandler.listeners.RendererListener;
  22 import org.opendaylight.transportpce.servicehandler.service.RendererServiceWrapper;
  23 import org.opendaylight.transportpce.servicehandler.service.ServiceDataStoreOperations;
  24 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev230526.RpcActions;
  25 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev230526.ServiceNotificationTypes;
  26 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev230526.configuration.response.common.ConfigurationResponseCommon;
  27 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev230526.sdnc.request.header.SdncRequestHeaderBuilder;
  28 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.state.types.rev191129.State;
  29 import org.opendaylight.yang.gen.v1.http.org.openroadm.routing.constraints.rev221209.routing.constraints.HardConstraints;
  30 import org.opendaylight.yang.gen.v1.http.org.openroadm.routing.constraints.rev221209.routing.constraints.SoftConstraints;
  31 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev230526.ServiceDeleteInputBuilder;
  32 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev230526.ServiceRestoration;
  33 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev230526.ServiceRestorationInput;
  34 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev230526.ServiceRestorationOutput;
  35 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev230526.service.delete.input.ServiceDeleteReqInfo.TailRetention;
  36 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev230526.service.delete.input.ServiceDeleteReqInfoBuilder;
  37 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev230526.service.list.Services;
  38 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.DateAndTime;
  39 import org.opendaylight.yangtools.yang.common.RpcResult;
  40 import org.slf4j.Logger;
  41 import org.slf4j.LoggerFactory;
  42
  43
  44 public class ServiceRestorationImpl implements ServiceRestoration {
  45     private static final Logger LOG = LoggerFactory.getLogger(ServiceRestorationImpl.class);
  46     private static final String SERVICE_RESTORATION_MSG = "serviceRestoration: {}";
  47
  48     private ServiceDataStoreOperations serviceDataStoreOperations;
  49     private PceListener pceListener;
  50     private RendererListener rendererListener;
  51     private NetworkListener networkListener;
  52     private RendererServiceWrapper rendererServiceWrapper;
  53
  54     public ServiceRestorationImpl(final ServiceDataStoreOperations serviceDataStoreOperations,
  55             final PceListener pceListener, RendererListener rendererListener, NetworkListener networkListener,
  56             RendererServiceWrapper rendererServiceWrapper) {
  57         this.serviceDataStoreOperations = serviceDataStoreOperations;
  58         this.pceListener = pceListener;
  59         this.rendererListener = rendererListener;
  60         this.networkListener = networkListener;
  61         this.rendererServiceWrapper = rendererServiceWrapper;
  62     }
  63
  64     @Override
  65     public ListenableFuture<RpcResult<ServiceRestorationOutput>> invoke(ServiceRestorationInput input) {
  66         String serviceName = input.getServiceName();
  67         LOG.info("RPC serviceRestoration received for {}", serviceName);
  68         Optional<Services> servicesObject = this.serviceDataStoreOperations.getService(serviceName);
  69
  70         if (!servicesObject.isPresent()) {
  71             LOG.warn(SERVICE_RESTORATION_MSG, LogMessages.serviceNotInDS(serviceName));
  72             return ModelMappingUtils.createRestoreServiceReply(
  73                     LogMessages.serviceNotInDS(serviceName));
  74         }
  75
  76         Services service = servicesObject.orElseThrow();
  77         State state = service.getOperationalState();
  78
  79         if (state == State.InService) {
  80             LOG.error(SERVICE_RESTORATION_MSG, LogMessages.serviceInService(serviceName));
  81             return ModelMappingUtils.createRestoreServiceReply(
  82                     LogMessages.serviceInService(serviceName));
  83         }
  84
  85         DateTimeFormatter dtf = DateTimeFormatter.ofPattern("yyyy-MM-dd'T'HH:mm:ssxxx");
  86         OffsetDateTime offsetDateTime = OffsetDateTime.now(ZoneOffset.UTC);
  87         DateAndTime datetime = new DateAndTime(dtf.format(offsetDateTime));
  88         SdncRequestHeaderBuilder sdncBuilder = new SdncRequestHeaderBuilder()
  89                 .setNotificationUrl(service.getSdncRequestHeader().getNotificationUrl())
  90                 .setRequestId(service.getSdncRequestHeader().getRequestId())
  91                 .setRequestSystemId(service.getSdncRequestHeader().getRequestSystemId())
  92                 .setRpcAction(RpcActions.ServiceDelete);
  93         ServiceDeleteInputBuilder deleteInputBldr = new ServiceDeleteInputBuilder()
  94                 .setServiceDeleteReqInfo(new ServiceDeleteReqInfoBuilder()
  95                     .setServiceName(serviceName)
  96                     .setDueDate(datetime)
  97                     .setTailRetention(TailRetention.No).build())
  98                 .setSdncRequestHeader(sdncBuilder.build());
  99         ServiceInput serviceInput = new ServiceInput(deleteInputBldr.build());
 100         serviceInput.setServiceAEnd(service.getServiceAEnd());
 101         serviceInput.setServiceZEnd(service.getServiceZEnd());
 102         serviceInput.setConnectionType(service.getConnectionType());
 103         HardConstraints hardConstraints = service.getHardConstraints();
 104         if (hardConstraints == null) {
 105             LOG.warn("service '{}' HardConstraints is not set !", serviceName);
 106         } else {
 107             SoftConstraints softConstraints = service.getSoftConstraints();
 108             if (softConstraints == null) {
 109                 LOG.warn("service '{}' SoftConstraints is not set !", serviceName);
 110                 serviceInput.setSoftConstraints(DowngradeConstraints.convertToSoftConstraints(hardConstraints));
 111             } else {
 112                 LOG.info("converting hard constraints to soft constraints ...");
 113                 serviceInput.setSoftConstraints(
 114                         DowngradeConstraints.updateSoftConstraints(hardConstraints, softConstraints));
 115             }
 116             serviceInput.setHardConstraints(DowngradeConstraints.downgradeHardConstraints(hardConstraints));
 117         }
 118         this.pceListener.setInput(serviceInput);
 119         this.pceListener.setServiceReconfigure(true);
 120         this.pceListener.setserviceDataStoreOperations(this.serviceDataStoreOperations);
 121         this.rendererListener.setServiceInput(serviceInput);
 122         this.rendererListener.setserviceDataStoreOperations(this.serviceDataStoreOperations);
 123         this.networkListener.setserviceDataStoreOperations(serviceDataStoreOperations);
 124         org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev210915
 125             .ServiceDeleteInput serviceDeleteInput = ModelMappingUtils.createServiceDeleteInput(
 126                     new ServiceInput(deleteInputBldr.build()));
 127         org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev210915
 128             .ServiceDeleteOutput output = this.rendererServiceWrapper.performRenderer(serviceDeleteInput,
 129                 ServiceNotificationTypes.ServiceDeleteResult, null);
 130         if (output == null) {
 131             LOG.error(SERVICE_RESTORATION_MSG, LogMessages.RENDERER_DELETE_FAILED);
 132             return ModelMappingUtils.createRestoreServiceReply(LogMessages.RENDERER_DELETE_FAILED);
 133         }
 134         LOG.info("RPC serviceRestore in progress...");
 135         ConfigurationResponseCommon common = output.getConfigurationResponseCommon();
 136         return ModelMappingUtils.createRestoreServiceReply(common.getResponseMessage());
 137     }
 138
 139 }