2 * Copyright © 2018 Orange Systems, 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
9 package org.opendaylight.transportpce.renderer.provisiondevice;
11 import static org.junit.jupiter.api.Assertions.assertEquals;
12 import static org.junit.jupiter.api.Assertions.assertFalse;
13 import static org.junit.jupiter.api.Assertions.assertTrue;
14 import static org.mockito.ArgumentMatchers.anyString;
15 import static org.mockito.Mockito.doReturn;
16 import static org.mockito.Mockito.mock;
17 import static org.mockito.Mockito.spy;
18 import static org.mockito.Mockito.when;
20 import java.util.ArrayList;
21 import java.util.concurrent.ExecutionException;
22 import org.junit.jupiter.api.Test;
23 import org.opendaylight.mdsal.binding.api.MountPoint;
24 import org.opendaylight.mdsal.binding.api.MountPointService;
25 import org.opendaylight.mdsal.binding.api.WriteTransaction;
26 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
27 import org.opendaylight.transportpce.common.StringConstants;
28 import org.opendaylight.transportpce.common.crossconnect.CrossConnect;
29 import org.opendaylight.transportpce.common.crossconnect.CrossConnectImpl;
30 import org.opendaylight.transportpce.common.crossconnect.CrossConnectImpl121;
31 import org.opendaylight.transportpce.common.crossconnect.CrossConnectImpl221;
32 import org.opendaylight.transportpce.common.crossconnect.CrossConnectImpl710;
33 import org.opendaylight.transportpce.common.device.DeviceTransactionManager;
34 import org.opendaylight.transportpce.common.device.DeviceTransactionManagerImpl;
35 import org.opendaylight.transportpce.common.mapping.MappingUtils;
36 import org.opendaylight.transportpce.common.mapping.MappingUtilsImpl;
37 import org.opendaylight.transportpce.common.mapping.PortMapping;
38 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfaceException;
39 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfaces;
40 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfacesImpl;
41 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfacesImpl121;
42 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfacesImpl221;
43 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfacesImpl710;
44 import org.opendaylight.transportpce.renderer.openroadminterface.OpenRoadmInterfaceFactory;
45 import org.opendaylight.transportpce.renderer.utils.CreateOtsOmsDataUtils;
46 import org.opendaylight.transportpce.renderer.utils.MountPointUtils;
47 import org.opendaylight.transportpce.test.AbstractTest;
48 import org.opendaylight.transportpce.test.stub.MountPointServiceStub;
49 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.device.renderer.rev211004.CreateOtsOmsInput;
50 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.device.renderer.rev211004.CreateOtsOmsOutput;
51 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev231221.Network;
52 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev231221.OpenroadmNodeVersion;
53 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev231221.mapping.Mapping;
54 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev231221.network.Nodes;
55 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev231221.network.NodesBuilder;
56 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev231221.network.NodesKey;
57 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev231221.network.nodes.NodeInfo;
58 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev231221.network.nodes.NodeInfoBuilder;
59 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
61 public class DeviceRendererServiceImplCreateOtsOmsTest extends AbstractTest {
63 private DeviceRendererService deviceRendererService;
64 private CrossConnect crossConnect;
65 private OpenRoadmInterfaces openRoadmInterfaces;
66 private OpenRoadmInterfaceFactory openRoadmInterfaceFactory;
67 private DeviceTransactionManager deviceTransactionManager;
68 private MappingUtils mappingUtils;
69 private OpenRoadmInterfacesImpl121 openRoadmInterfacesImpl121;
70 private OpenRoadmInterfacesImpl221 openRoadmInterfacesImpl221;
71 private OpenRoadmInterfacesImpl710 openRoadmInterfacesImpl710;
72 private CrossConnectImpl121 crossConnectImpl121;
73 private CrossConnectImpl221 crossConnectImpl221;
74 private CrossConnectImpl710 crossConnectImpl710;
75 private final PortMapping portMapping = mock(PortMapping.class);
77 private void setMountPoint(MountPoint mountPoint) {
78 MountPointService mountPointService = new MountPointServiceStub(mountPoint);
79 this.deviceTransactionManager = new DeviceTransactionManagerImpl(mountPointService, 3000);
80 this.mappingUtils = new MappingUtilsImpl(getDataBroker());
81 this.mappingUtils = spy(MappingUtils.class);
83 doReturn(StringConstants.OPENROADM_DEVICE_VERSION_1_2_1).when(mappingUtils).getOpenRoadmVersion(anyString());
84 this.openRoadmInterfaces = new OpenRoadmInterfacesImpl(deviceTransactionManager, mappingUtils,
85 openRoadmInterfacesImpl121, openRoadmInterfacesImpl221, openRoadmInterfacesImpl710);
86 this.openRoadmInterfaces = spy(this.openRoadmInterfaces);
87 this.openRoadmInterfaceFactory = new OpenRoadmInterfaceFactory(this.mappingUtils, portMapping,
90 this.crossConnectImpl121 = new CrossConnectImpl121(this.deviceTransactionManager);
91 this.crossConnectImpl221 = new CrossConnectImpl221(this.deviceTransactionManager);
92 this.crossConnect = new CrossConnectImpl(this.deviceTransactionManager, this.mappingUtils,
93 this.crossConnectImpl121, this.crossConnectImpl221, this.crossConnectImpl710);
94 this.crossConnect = spy(this.crossConnect);
95 this.deviceRendererService = new DeviceRendererServiceImpl(getDataBroker(), this.deviceTransactionManager,
96 this.openRoadmInterfaces, this.crossConnect, mappingUtils, portMapping);
100 void testCreateOtsOmsWhenDeviceIsNotMounted() throws OpenRoadmInterfaceException {
102 CreateOtsOmsInput input = CreateOtsOmsDataUtils.buildCreateOtsOms();
103 CreateOtsOmsOutput result = this.deviceRendererService.createOtsOms(input);
104 assertFalse(result.getSuccess());
105 assertEquals("node 1 is not mounted on the controller", result.getResult());
109 void testCreateOtsOmsWhenDeviceIsMountedWithNoMapping() throws OpenRoadmInterfaceException {
110 setMountPoint(MountPointUtils.getMountPoint(new ArrayList<>(), getDataBroker()));
111 CreateOtsOmsInput input = CreateOtsOmsDataUtils.buildCreateOtsOms();
112 CreateOtsOmsOutput result = this.deviceRendererService.createOtsOms(input);
113 assertFalse(result.getSuccess());
117 void testCreateOtsOmsWhenDeviceIsMountedWithMapping()
118 throws OpenRoadmInterfaceException, InterruptedException, ExecutionException {
119 InstanceIdentifier<NodeInfo> nodeInfoIID = InstanceIdentifier.builder(Network.class).child(Nodes.class,
120 new NodesKey("node 1")).child(NodeInfo.class).build();
121 InstanceIdentifier<Nodes> nodeIID = InstanceIdentifier.builder(Network.class).child(Nodes.class,
122 new NodesKey("node 1")).build();
123 final NodeInfo nodeInfo = new NodeInfoBuilder().setOpenroadmVersion(OpenroadmNodeVersion._221).build();
124 Nodes nodes = new NodesBuilder().setNodeId("node 1").setNodeInfo(nodeInfo).build();
125 WriteTransaction wr = getDataBroker().newWriteOnlyTransaction();
126 wr.merge(LogicalDatastoreType.CONFIGURATION, nodeIID, nodes);
127 wr.merge(LogicalDatastoreType.CONFIGURATION, nodeInfoIID, nodeInfo);
129 setMountPoint(MountPointUtils.getMountPoint(new ArrayList<>(), getDataBroker()));
130 CreateOtsOmsInput input = CreateOtsOmsDataUtils.buildCreateOtsOms();
131 Mapping mapping = MountPointUtils.createMapping(input.getNodeId(), input.getLogicalConnectionPoint());
132 when(portMapping.getMapping(anyString(), anyString())).thenReturn(mapping);
133 CreateOtsOmsOutput result = this.deviceRendererService.createOtsOms(input);
134 assertTrue(result.getSuccess());