2 * Copyright © 2018 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.tapi.connectivity;
10 import com.google.common.collect.ImmutableClassToInstanceMap;
11 import com.google.common.util.concurrent.ListenableFuture;
12 import java.util.ArrayList;
13 import java.util.HashMap;
14 import java.util.List;
16 import java.util.NoSuchElementException;
17 import java.util.Optional;
18 import java.util.UUID;
19 import java.util.concurrent.ExecutionException;
20 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
21 import org.opendaylight.transportpce.common.OperationResult;
22 import org.opendaylight.transportpce.common.ResponseCodes;
23 import org.opendaylight.transportpce.common.network.NetworkTransactionService;
24 import org.opendaylight.transportpce.tapi.listeners.TapiPceNotificationHandler;
25 import org.opendaylight.transportpce.tapi.listeners.TapiRendererNotificationHandler;
26 import org.opendaylight.transportpce.tapi.utils.TapiContext;
27 import org.opendaylight.transportpce.tapi.validation.CreateConnectivityServiceValidation;
28 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev230526.RpcActions;
29 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.service.types.rev230526.sdnc.request.header.SdncRequestHeaderBuilder;
30 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev230526.OrgOpenroadmServiceService;
31 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev230526.ServiceCreateInput;
32 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev230526.ServiceCreateOutput;
33 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev230526.ServiceDeleteInputBuilder;
34 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev230526.ServiceDeleteOutput;
35 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev230526.service.delete.input.ServiceDeleteReqInfo;
36 import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev230526.service.delete.input.ServiceDeleteReqInfoBuilder;
37 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev221121.AdministrativeState;
38 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev221121.Context;
39 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev221121.ForwardingDirection;
40 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev221121.LifecycleState;
41 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev221121.OperationalState;
42 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev221121.Uuid;
43 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev221121.capacity.TotalSizeBuilder;
44 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev221121.global._class.Name;
45 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev221121.global._class.NameBuilder;
46 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev221121.global._class.NameKey;
47 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev221121.tapi.context.ServiceInterfacePoint;
48 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev221121.tapi.context.ServiceInterfacePointKey;
49 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.CreateConnectivityService;
50 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.CreateConnectivityServiceInput;
51 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.CreateConnectivityServiceOutput;
52 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.CreateConnectivityServiceOutputBuilder;
53 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.DeleteConnectivityService;
54 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.DeleteConnectivityServiceInput;
55 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.DeleteConnectivityServiceOutput;
56 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.DeleteConnectivityServiceOutputBuilder;
57 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.GetConnectionDetails;
58 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.GetConnectionDetailsInput;
59 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.GetConnectionDetailsOutput;
60 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.GetConnectionDetailsOutputBuilder;
61 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.GetConnectionEndPointDetails;
62 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.GetConnectionEndPointDetailsInput;
63 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.GetConnectionEndPointDetailsOutput;
64 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.GetConnectivityServiceDetails;
65 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.GetConnectivityServiceDetailsInput;
66 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.GetConnectivityServiceDetailsOutput;
67 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.GetConnectivityServiceDetailsOutputBuilder;
68 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.GetConnectivityServiceList;
69 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.GetConnectivityServiceListInput;
70 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.GetConnectivityServiceListOutput;
71 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.GetConnectivityServiceListOutputBuilder;
72 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.ServiceType;
73 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.TapiConnectivityService;
74 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.UpdateConnectivityService;
75 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.UpdateConnectivityServiceInput;
76 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.UpdateConnectivityServiceOutput;
77 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.connectivity.context.Connection;
78 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.connectivity.context.ConnectivityService;
79 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.connectivity.context.ConnectivityServiceBuilder;
80 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.connectivity.context.ConnectivityServiceKey;
81 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.connectivity.service.ConnectivityConstraint;
82 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.connectivity.service.ConnectivityConstraintBuilder;
83 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.connectivity.service.EndPoint;
84 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.connectivity.service.EndPointBuilder;
85 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.connectivity.service.EndPointKey;
86 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.connectivity.service.end.point.CapacityBuilder;
87 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.connectivity.service.end.point.ServiceInterfacePointBuilder;
88 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.context.ConnectivityContext;
89 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.create.connectivity.service.output.ServiceBuilder;
90 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.get.connection.details.output.ConnectionBuilder;
91 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.get.connectivity.service.list.output.Service;
92 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.get.connectivity.service.list.output.ServiceKey;
93 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
94 import org.opendaylight.yangtools.yang.binding.Rpc;
95 import org.opendaylight.yangtools.yang.common.ErrorTag;
96 import org.opendaylight.yangtools.yang.common.ErrorType;
97 import org.opendaylight.yangtools.yang.common.RpcResult;
98 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
99 import org.slf4j.Logger;
100 import org.slf4j.LoggerFactory;
103 * Top level service interface providing main TAPI Connectivity services.
105 public class TapiConnectivityImpl implements TapiConnectivityService {
106 private final NetworkTransactionService networkTransactionService;
107 private static final Logger LOG = LoggerFactory.getLogger(TapiConnectivityImpl.class);
109 private OrgOpenroadmServiceService serviceHandler;
110 private final TapiContext tapiContext;
111 private final ConnectivityUtils connectivityUtils;
112 private TapiPceNotificationHandler pceListenerImpl;
113 private TapiRendererNotificationHandler rendererListenerImpl;
115 public TapiConnectivityImpl(OrgOpenroadmServiceService serviceHandler, TapiContext tapiContext,
116 ConnectivityUtils connectivityUtils, TapiPceNotificationHandler pceListenerImpl,
117 TapiRendererNotificationHandler rendererListenerImpl,
118 NetworkTransactionService nts) {
119 LOG.info("inside TapiImpl constructor");
120 this.serviceHandler = serviceHandler;
121 this.tapiContext = tapiContext;
122 this.connectivityUtils = connectivityUtils;
123 this.pceListenerImpl = pceListenerImpl;
124 this.rendererListenerImpl = rendererListenerImpl;
125 this.networkTransactionService = nts;
129 public ListenableFuture<RpcResult<CreateConnectivityServiceOutput>> createConnectivityService(
130 CreateConnectivityServiceInput input) {
131 // TODO: later version of TAPI models include Name as an input parameter in connectivity.yang
132 LOG.info("RPC create-connectivity received: {}", input.getEndPoint());
133 Uuid serviceUuid = new Uuid(UUID.randomUUID().toString());
134 this.pceListenerImpl.setInput(input);
135 this.pceListenerImpl.setServiceUuid(serviceUuid);
136 this.rendererListenerImpl.setServiceUuid(serviceUuid);
137 ListenableFuture<RpcResult<ServiceCreateOutput>> output = null;
138 OperationResult validationResult = CreateConnectivityServiceValidation.validateCreateConnectivityServiceRequest(
140 if (validationResult.isSuccess()) {
141 LOG.info("input parameter of RPC create-connectivity are being handled");
142 // check uuid of SIP in tapi context
143 Map<ServiceInterfacePointKey, ServiceInterfacePoint> sipMap = this.tapiContext.getTapiContext()
144 .getServiceInterfacePoint();
145 if (sipMap == null) {
146 return RpcResultBuilder.<CreateConnectivityServiceOutput>failed()
147 .withError(ErrorType.RPC, "SIP list is empty")
150 if (sipMap.containsKey(new ServiceInterfacePointKey(input.getEndPoint().values().stream().findFirst()
151 .orElseThrow().getServiceInterfacePoint().getServiceInterfacePointUuid()))
152 && sipMap.containsKey(new ServiceInterfacePointKey(input.getEndPoint().values().stream().skip(1)
153 .findFirst().orElseThrow().getServiceInterfacePoint().getServiceInterfacePointUuid()))) {
154 LOG.info("SIPs found in sipMap");
155 // TODO: differentiate between OTN service and GbE service in TAPI
156 ServiceCreateInput sci = this.connectivityUtils.createORServiceInput(input, serviceUuid);
158 return RpcResultBuilder.<CreateConnectivityServiceOutput>failed()
159 .withError(ErrorType.RPC, "Couldnt map Service create input")
162 LOG.info("Service Create input = {}", sci);
163 output = this.serviceHandler.serviceCreate(sci);
164 if (!output.isDone()) {
165 return RpcResultBuilder.<CreateConnectivityServiceOutput>failed()
166 .withError(ErrorType.RPC, "Service create RPC failed")
170 LOG.error("Unknown UUID");
171 return RpcResultBuilder.<CreateConnectivityServiceOutput>failed()
172 .withError(ErrorType.RPC, "SIPs do not exist in tapi context")
177 if (output == null) {
178 return RpcResultBuilder.<CreateConnectivityServiceOutput>failed()
179 .withError(ErrorType.RPC, "Failed to create service")
182 LOG.info("Service create request was successful");
183 if (output.get().getResult().getConfigurationResponseCommon().getResponseCode()
184 .equals(ResponseCodes.RESPONSE_FAILED)) {
185 return RpcResultBuilder.<CreateConnectivityServiceOutput>failed()
186 .withError(ErrorType.RPC, "Failed to create service")
189 LOG.info("Output of service request = {}", output.get().getResult());
190 } catch (InterruptedException | ExecutionException e) {
191 LOG.error("Error checking response code of service create", e);
193 // Connections and states should be created/updated when the pce and renderer are done :)
194 Map<EndPointKey, EndPoint> endPointList = createEndPoints(input.getEndPoint());
195 Name name = new NameBuilder()
196 .setValueName("Connectivity Service Name")
197 .setValue(serviceUuid.getValue())
199 ConnectivityConstraint conConstr = new ConnectivityConstraintBuilder()
200 .setServiceType(ServiceType.POINTTOPOINTCONNECTIVITY)
201 .setServiceLevel(input.getConnectivityConstraint().getServiceLevel()).build();
203 ConnectivityService service = new ConnectivityServiceBuilder()
204 .setUuid(serviceUuid)
205 .setAdministrativeState(AdministrativeState.LOCKED)
206 .setOperationalState(OperationalState.DISABLED)
207 .setLifecycleState(LifecycleState.PLANNED)
208 .setLayerProtocolName(input.getLayerProtocolName())
209 .setConnectivityConstraint(conConstr)
210 .setDirection(ForwardingDirection.BIDIRECTIONAL)
211 .setName(Map.of(name.key(), name))
212 .setConnection(new HashMap<>())
213 .setEndPoint(endPointList)
215 // add to tapi context
216 this.tapiContext.updateConnectivityContext(Map.of(service.key(), service), new HashMap<>());
217 LOG.info("Created locked service in Datastore. Waiting for PCE and Renderer to complete tasks...");
218 // return ConnectivityServiceCreateOutput
219 return RpcResultBuilder.success(new CreateConnectivityServiceOutputBuilder()
220 .setService(new ServiceBuilder(service).build()).build()).buildFuture();
224 public ListenableFuture<RpcResult<GetConnectivityServiceDetailsOutput>> getConnectivityServiceDetails(
225 GetConnectivityServiceDetailsInput input) {
226 // TODO Auto-generated method stub
227 Uuid serviceUuid = input.getUuid();
228 ConnectivityService service = this.tapiContext.getConnectivityService(serviceUuid);
229 if (service == null) {
230 LOG.error("Service {} doesnt exist in tapi context", input.getUuid());
231 return RpcResultBuilder.<GetConnectivityServiceDetailsOutput>failed()
232 .withError(ErrorType.RPC, "Service doesnt exist in datastore")
235 return RpcResultBuilder.success(new GetConnectivityServiceDetailsOutputBuilder().setService(
236 new org.opendaylight.yang.gen.v1.urn
237 .onf.otcc.yang.tapi.connectivity.rev221121.get.connectivity.service.details.output.ServiceBuilder(
238 service).build()).build()).buildFuture();
242 public ListenableFuture<RpcResult<UpdateConnectivityServiceOutput>> updateConnectivityService(
243 UpdateConnectivityServiceInput input) {
244 // TODO Auto-generated method stub. More complicated as it depends on what needs to be updated... left aside
245 return RpcResultBuilder.<UpdateConnectivityServiceOutput>failed()
246 .withError(ErrorType.RPC, ErrorTag.OPERATION_NOT_SUPPORTED, "RPC not implemented yet")
251 public ListenableFuture<RpcResult<GetConnectionDetailsOutput>> getConnectionDetails(
252 GetConnectionDetailsInput input) {
253 // TODO Auto-generated method stub
254 Uuid connectionUuid = input.getUuid();
255 Connection connection = this.tapiContext.getConnection(connectionUuid);
256 if (connection == null) {
257 LOG.error("Connection {} doesnt exist in tapi context", input.getUuid());
258 return RpcResultBuilder.<GetConnectionDetailsOutput>failed()
259 .withError(ErrorType.RPC, "Connection doesnt exist in datastore")
262 return RpcResultBuilder.success(new GetConnectionDetailsOutputBuilder().setConnection(
263 new ConnectionBuilder(connection).build()).build()).buildFuture();
267 public ListenableFuture<RpcResult<DeleteConnectivityServiceOutput>> deleteConnectivityService(
268 DeleteConnectivityServiceInput input) {
269 // TODO Auto-generated method stub
271 String serviceName = null;
273 serviceName = getNameFromUuid(input.getUuid(), "Service").iterator().next();
274 } catch (ExecutionException e) {
275 LOG.error("Service {} to be deleted not found in the DataStore", e.getMessage());
276 return RpcResultBuilder.<DeleteConnectivityServiceOutput>failed()
277 .withError(ErrorType.RPC, "Failed to delete Service")
280 if (input.getUuid() != null) {
282 Uuid serviceUuid = input.getUuid();
283 this.tapiContext.deleteConnectivityService(serviceUuid);
284 ListenableFuture<RpcResult<ServiceDeleteOutput>> output =
285 this.serviceHandler.serviceDelete(new ServiceDeleteInputBuilder()
286 .setServiceDeleteReqInfo(new ServiceDeleteReqInfoBuilder()
287 .setServiceName(serviceName)
288 .setTailRetention(ServiceDeleteReqInfo.TailRetention.No)
290 .setSdncRequestHeader(new SdncRequestHeaderBuilder()
291 .setRequestId("request-1")
292 .setNotificationUrl("notification url")
293 .setRequestSystemId("appname")
294 .setRpcAction(RpcActions.ServiceDelete)
297 RpcResult<ServiceDeleteOutput> rpcResult = output.get();
298 if (!rpcResult.getResult().getConfigurationResponseCommon().getResponseCode()
299 .equals(ResponseCodes.RESPONSE_FAILED)) {
300 LOG.info("Service is being deleted and devices are being rolled back");
301 return RpcResultBuilder.success(new DeleteConnectivityServiceOutputBuilder().build()).buildFuture();
303 LOG.error("Failed to delete service. Deletion process failed");
304 } catch (InterruptedException | ExecutionException e) {
305 LOG.error("Failed to delete service.", e);
308 return RpcResultBuilder.<DeleteConnectivityServiceOutput>failed()
309 .withError(ErrorType.RPC, "Failed to delete Service")
314 public ListenableFuture<RpcResult<GetConnectivityServiceListOutput>> getConnectivityServiceList(
315 GetConnectivityServiceListInput input) {
316 // TODO Auto-generated method stub
317 Map<ConnectivityServiceKey, ConnectivityService> connMap = this.tapiContext.getConnectivityServices();
318 if (connMap == null) {
319 LOG.error("No services in tapi context");
320 return RpcResultBuilder.<GetConnectivityServiceListOutput>failed()
321 .withError(ErrorType.RPC, "No services exist in datastore")
325 Map<ServiceKey, Service> serviceMap = new HashMap<>();
326 for (ConnectivityService connectivityService: connMap.values()) {
327 Service service = new org.opendaylight.yang.gen.v1.urn
328 .onf.otcc.yang.tapi.connectivity.rev221121.get.connectivity.service.list.output.ServiceBuilder(
329 connectivityService).build();
330 serviceMap.put(service.key(), service);
332 return RpcResultBuilder.success(new GetConnectivityServiceListOutputBuilder().setService(serviceMap)
333 .build()).buildFuture();
337 public ListenableFuture<RpcResult<GetConnectionEndPointDetailsOutput>> getConnectionEndPointDetails(
338 GetConnectionEndPointDetailsInput input) {
339 // TODO: Leveraging previous code, provide TAPI2.4 compliant implementation for this function
340 LOG.error("Method getConnectionEndPointDetails not currently implemented");
344 public ImmutableClassToInstanceMap<Rpc<?, ?>> registerRPCs() {
345 return ImmutableClassToInstanceMap.<Rpc<?, ?>>builder()
346 .put(CreateConnectivityService.class, this::createConnectivityService)
347 .put(GetConnectivityServiceDetails.class, this::getConnectivityServiceDetails)
348 .put(UpdateConnectivityService.class, this::updateConnectivityService)
349 .put(GetConnectionDetails.class, this::getConnectionDetails)
350 .put(DeleteConnectivityService.class, this::deleteConnectivityService)
351 .put(GetConnectivityServiceList.class, this::getConnectivityServiceList)
352 .put(GetConnectionEndPointDetails.class, this::getConnectionEndPointDetails)
356 private Map<EndPointKey, EndPoint> createEndPoints(
357 Map<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121
358 .create.connectivity.service.input.EndPointKey,
359 org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121
360 .create.connectivity.service.input.EndPoint> endPoints) {
361 Map<EndPointKey, EndPoint> endPointMap = new HashMap<>();
362 for (org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121
363 .create.connectivity.service.input.EndPoint ep: endPoints.values()) {
364 EndPoint endpoint = new EndPointBuilder()
365 .setServiceInterfacePoint(new ServiceInterfacePointBuilder()
366 .setServiceInterfacePointUuid(ep.getServiceInterfacePoint().getServiceInterfacePointUuid())
368 .setName(ep.getName())
369 .setAdministrativeState(ep.getAdministrativeState())
370 .setDirection(ep.getDirection())
371 .setLifecycleState(ep.getLifecycleState())
372 .setOperationalState(ep.getOperationalState())
373 .setLayerProtocolName(ep.getLayerProtocolName())
374 // TODO: implement bandwidth profile
375 .setCapacity(new CapacityBuilder()
376 .setTotalSize(new TotalSizeBuilder().build())
377 // .setBandwidthProfile(new BandwidthProfileBuilder().build())
379 .setProtectionRole(ep.getProtectionRole())
380 .setRole(ep.getRole())
381 .setLocalId(ep.getLocalId())
383 endPointMap.put(endpoint.key(), endpoint);
388 public List<String> getNameFromUuid(Uuid uuid, String typeOfNode) throws ExecutionException {
389 Map<NameKey, Name> nameMap = new HashMap<>();
390 if ("service".equals(typeOfNode)) {
391 ConnectivityService conServ = null;
392 InstanceIdentifier<ConnectivityService> nodeIID = InstanceIdentifier.builder(Context.class)
394 org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.connectivity.rev221121.Context1.class)
395 .child(ConnectivityContext.class)
396 .child(ConnectivityService.class, new ConnectivityServiceKey(uuid))
398 ListenableFuture<Optional<ConnectivityService>> conServFuture =
399 this.networkTransactionService.read(LogicalDatastoreType.OPERATIONAL, nodeIID);
401 conServ = conServFuture.get().orElseThrow();
402 } catch (InterruptedException e) {
403 Thread.currentThread().interrupt();
404 //TODO: investigate on how to throw Interrupted exception (generate a check violation error)
405 } catch (ExecutionException e) {
406 throw new ExecutionException("Unable to get from mdsal service: " + nodeIID
407 .firstKeyOf(ConnectivityService.class).getUuid().getValue(), e);
408 } catch (NoSuchElementException e) {
411 nameMap = conServ.getName();
414 List<String> nameList = new ArrayList<>();
415 for (Map.Entry<NameKey, Name> entry : nameMap.entrySet()) {
416 nameList.add(entry.getValue().getValueName());