2 * Copyright © 2024 Orange, Inc. and others. All rights reserved.
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
8 package org.opendaylight.transportpce.servicehandler.impl;
10 import com.google.common.util.concurrent.ListenableFuture;
11 import org.opendaylight.mdsal.binding.api.NotificationPublishService;
12 import org.opendaylight.transportpce.common.OperationResult;
13 import org.opendaylight.transportpce.common.ResponseCodes;
14 import org.opendaylight.transportpce.servicehandler.ModelMappingUtils;
15 import org.opendaylight.transportpce.servicehandler.ServiceInput;
16 import org.opendaylight.transportpce.servicehandler.impl.ServicehandlerImpl.LogMessages;
17 import org.opendaylight.transportpce.servicehandler.listeners.NetworkListener;
18 import org.opendaylight.transportpce.servicehandler.listeners.PceListener;
19 import org.opendaylight.transportpce.servicehandler.listeners.RendererListener;
20 import org.opendaylight.transportpce.servicehandler.service.PCEServiceWrapper;
21 import org.opendaylight.transportpce.servicehandler.service.ServiceDataStoreOperations;
22 import org.opendaylight.transportpce.servicehandler.validation.ServiceCreateValidation;
23 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev240205.PathComputationRequestOutput;
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.configuration.response.common.ConfigurationResponseCommon;
26 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.state.types.rev191129.State;
27 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev230526.ServiceCreate;
28 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev230526.ServiceCreateInput;
29 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev230526.ServiceCreateOutput;
30 import org.opendaylight.yang.gen.v1.nbi.notifications.rev230728.PublishNotificationProcessService;
31 import org.opendaylight.yang.gen.v1.nbi.notifications.rev230728.PublishNotificationProcessServiceBuilder;
32 import org.opendaylight.yang.gen.v1.nbi.notifications.rev230728.notification.process.service.ServiceAEndBuilder;
33 import org.opendaylight.yang.gen.v1.nbi.notifications.rev230728.notification.process.service.ServiceZEndBuilder;
34 import org.opendaylight.yangtools.yang.common.RpcResult;
35 import org.slf4j.Logger;
36 import org.slf4j.LoggerFactory;
39 public class ServiceCreateImpl implements ServiceCreate {
40 private static final Logger LOG = LoggerFactory.getLogger(ServiceCreateImpl.class);
41 private static final String SERVICE_CREATE_MSG = "serviceCreate: {}";
42 private static final String PUBLISHER = "ServiceHandler";
44 private ServiceDataStoreOperations serviceDataStoreOperations;
45 private PceListener pceListener;
46 private RendererListener rendererListener;
47 private NetworkListener networkListener;
48 private PCEServiceWrapper pceServiceWrapper;
49 private NotificationPublishService notificationPublishService;
51 public ServiceCreateImpl(final ServiceDataStoreOperations serviceDataStoreOperations,
52 final PceListener pceListener, RendererListener rendererListener, NetworkListener networkListener,
53 PCEServiceWrapper pceServiceWrapper, NotificationPublishService notificationPublishService) {
54 this.serviceDataStoreOperations = serviceDataStoreOperations;
55 this.pceListener = pceListener;
56 this.rendererListener = rendererListener;
57 this.networkListener = networkListener;
58 this.pceServiceWrapper = pceServiceWrapper;
59 this.notificationPublishService = notificationPublishService;
63 public ListenableFuture<RpcResult<ServiceCreateOutput>> invoke(ServiceCreateInput input) {
64 LOG.info("RPC serviceCreate received");
66 OperationResult validationResult = ServiceCreateValidation.validateServiceCreateRequest(
67 new ServiceInput(input), RpcActions.ServiceCreate);
68 if (!validationResult.isSuccess()) {
69 LOG.warn(SERVICE_CREATE_MSG, LogMessages.ABORT_VALID_FAILED);
70 return ModelMappingUtils.createCreateServiceReply(
71 input, ResponseCodes.FINAL_ACK_YES,
72 validationResult.getResultMessage(), ResponseCodes.RESPONSE_FAILED);
74 //Check any presence of services with the same nameequipmentNotification
75 String serviceName = input.getServiceName();
76 if (this.serviceDataStoreOperations.getService(serviceName).isPresent()) {
77 LOG.warn(SERVICE_CREATE_MSG, LogMessages.serviceInDS(serviceName));
78 return ModelMappingUtils.createCreateServiceReply(input, ResponseCodes.FINAL_ACK_YES,
79 LogMessages.serviceInDS(serviceName), ResponseCodes.RESPONSE_FAILED);
81 // TODO: Here we also have to check if there is an associated temp-service.
82 // TODO: If there is one, delete it from the temp-service-list??
83 this.pceListener.setInput(new ServiceInput(input));
84 this.pceListener.setServiceReconfigure(false);
85 this.pceListener.setTempService(false);
86 this.pceListener.setserviceDataStoreOperations(this.serviceDataStoreOperations);
87 this.rendererListener.setserviceDataStoreOperations(serviceDataStoreOperations);
88 this.rendererListener.setServiceInput(new ServiceInput(input));
89 // This ensures that the temp-service boolean is false, especially, when
90 // service-create is initiated after the temp-service-create
91 this.rendererListener.setTempService(false);
92 this.networkListener.setserviceDataStoreOperations(serviceDataStoreOperations);
93 LOG.debug(SERVICE_CREATE_MSG, LogMessages.PCE_CALLING);
94 PathComputationRequestOutput output = this.pceServiceWrapper.performPCE(input, true);
96 LOG.warn(SERVICE_CREATE_MSG, LogMessages.ABORT_PCE_FAILED);
97 sendNbiNotification(new PublishNotificationProcessServiceBuilder()
98 .setServiceName(serviceName)
99 .setServiceAEnd(new ServiceAEndBuilder(input.getServiceAEnd()).build())
100 .setServiceZEnd(new ServiceZEndBuilder(input.getServiceZEnd()).build())
101 .setCommonId(input.getCommonId())
102 .setConnectionType(input.getConnectionType())
103 .setResponseFailed(LogMessages.ABORT_PCE_FAILED)
104 .setMessage("ServiceCreate request failed ...")
105 .setOperationalState(State.Degraded)
106 .setPublisherName(PUBLISHER)
108 return ModelMappingUtils.createCreateServiceReply(input, ResponseCodes.FINAL_ACK_YES,
109 LogMessages.PCE_FAILED, ResponseCodes.RESPONSE_FAILED);
111 LOG.info("RPC serviceCreate in progress...");
112 ConfigurationResponseCommon common = output.getConfigurationResponseCommon();
113 return ModelMappingUtils.createCreateServiceReply(
114 input, common.getAckFinalIndicator(),
115 common.getResponseMessage(), common.getResponseCode());
119 * Send notification to NBI notification in order to publish message.
120 * @param service PublishNotificationService
122 private void sendNbiNotification(PublishNotificationProcessService service) {
124 notificationPublishService.putNotification(service);
125 } catch (InterruptedException e) {
126 LOG.warn("Cannot send notification to nbi", e);
127 Thread.currentThread().interrupt();