--- /dev/null
+/*
+ * Copyright © 2022 Orange, Inc. and others. All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0 which accompanies this distribution,
+ * and is available at http://www.eclipse.org/legal/epl-v10.html
+ */
+
+package org.opendaylight.transportpce.servicehandler.listeners;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertTrue;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.ArgumentMatchers.anyString;
+import static org.mockito.Mockito.doCallRealMethod;
+import static org.mockito.Mockito.eq;
+import static org.mockito.Mockito.never;
+import static org.mockito.Mockito.times;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Optional;
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.mockito.Mock;
+import org.mockito.Mockito;
+import org.mockito.junit.MockitoJUnitRunner;
+import org.opendaylight.mdsal.binding.api.NotificationPublishService;
+import org.opendaylight.transportpce.common.OperationResult;
+import org.opendaylight.transportpce.servicehandler.service.ServiceDataStoreOperations;
+import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.networkmodel.rev201116.TopologyUpdateResult;
+import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.networkmodel.rev201116.TopologyUpdateResultBuilder;
+import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.networkmodel.rev201116.topology.update.result.TopologyChanges;
+import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.networkmodel.rev201116.topology.update.result.TopologyChangesBuilder;
+import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.networkmodel.rev201116.topology.update.result.TopologyChangesKey;
+import org.opendaylight.yang.gen.v1.http.org.openroadm.common.state.types.rev191129.State;
+import org.opendaylight.yang.gen.v1.http.org.openroadm.equipment.states.types.rev191129.AdminStates;
+import org.opendaylight.yang.gen.v1.http.org.openroadm.service.rev211210.service.list.ServicesBuilder;
+import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev210705.path.description.AToZDirectionBuilder;
+import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev210705.path.description.ZToADirectionBuilder;
+import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev210705.path.description.atoz.direction.AToZ;
+import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev210705.path.description.atoz.direction.AToZBuilder;
+import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev210705.path.description.atoz.direction.AToZKey;
+import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev210705.path.description.ztoa.direction.ZToA;
+import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev210705.path.description.ztoa.direction.ZToABuilder;
+import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev210705.path.description.ztoa.direction.ZToAKey;
+import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev210705.pce.resource.ResourceBuilder;
+import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev210705.pce.resource.resource.resource.LinkBuilder;
+import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev210705.pce.resource.resource.resource.NodeBuilder;
+import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev210705.pce.resource.resource.resource.TerminationPointBuilder;
+import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev220118.service.path.PathDescription;
+import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev220118.service.path.PathDescriptionBuilder;
+import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.servicepath.rev171017.ServicePathListBuilder;
+import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.servicepath.rev171017.service.path.list.ServicePaths;
+import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.servicepath.rev171017.service.path.list.ServicePathsBuilder;
+import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.servicepath.rev171017.service.path.list.ServicePathsKey;
+
+@RunWith(MockitoJUnitRunner.class)
+public class NetworkModelListenerImplTest {
+
+ @Mock
+ private NotificationPublishService notificationPublishService;
+ @Mock
+ private ServiceDataStoreOperations serviceDataStoreOperations;
+ private static PathDescription pathDescription;
+ private NetworkModelListenerImpl networkModelListener;
+
+ @Before
+ public void setUp() {
+ pathDescription = new PathDescriptionBuilder()
+ .setAToZDirection(new AToZDirectionBuilder().setAToZ(new HashMap<>(createMapAtoZ())).build())
+ .setZToADirection(new ZToADirectionBuilder().setZToA(new HashMap<>(createMapZtoA())).build())
+ .build();
+ networkModelListener = new NetworkModelListenerImpl(notificationPublishService,
+ serviceDataStoreOperations);
+ }
+
+ @Test
+ public void testChangePathElementStateZAShouldNotModifyPathDescriptionsElementStates() {
+ Map<TopologyChangesKey, TopologyChanges> topologyChanges = Map.of(
+ new TopologyChangesKey("tpNodeIdA", "TpIdA1"),
+ new TopologyChangesBuilder()
+ .setNodeId("tpNodeIdA")
+ .setTpId("TpIdA1")
+ .setState(State.InService)
+ .build(),
+ new TopologyChangesKey("tpNodeIdA", "TpIdA2"),
+ new TopologyChangesBuilder()
+ .setNodeId("tpNodeIdA")
+ .setTpId("TpIdA2")
+ .setState(State.InService)
+ .build()
+ );
+
+ assertEquals(pathDescription.getZToADirection().getZToA(),
+ networkModelListener.changePathElementStateZA(topologyChanges, pathDescription));
+ }
+
+ @Test
+ public void testChangePathElementStateZAShouldModifyPathDescriptionsElementStates() {
+ Map<TopologyChangesKey, TopologyChanges> topologyChanges = Map.of(
+ new TopologyChangesKey("tpNodeIdA", "TpIdA1"),
+ new TopologyChangesBuilder()
+ .setNodeId("tpNodeIdA")
+ .setTpId("TpIdA1")
+ .setState(State.OutOfService)
+ .build(),
+ new TopologyChangesKey("tpNodeIdA", "TpIdA2"),
+ new TopologyChangesBuilder()
+ .setNodeId("tpNodeIdA")
+ .setTpId("TpIdA2")
+ .setState(State.OutOfService)
+ .build());
+
+ Map<ZToAKey, ZToA> ztoamapExpected = pathDescription.getZToADirection().getZToA();
+ ztoamapExpected.computeIfPresent(
+ new ZToAKey("6"),
+ (zToAKey, zToA) -> new ZToABuilder(zToA)
+ .setResource(new ResourceBuilder(zToA.getResource())
+ .setState(State.OutOfService)
+ .build())
+ .build());
+ ztoamapExpected.computeIfPresent(
+ new ZToAKey("4"),
+ (zToAKey, zToA) -> new ZToABuilder(zToA)
+ .setResource(new ResourceBuilder(zToA.getResource())
+ .setState(State.OutOfService)
+ .build())
+ .build());
+ assertEquals(ztoamapExpected, networkModelListener.changePathElementStateZA(topologyChanges, pathDescription));
+ }
+
+ @Test
+ public void testChangePathElementStateAZShouldNotModifyPathDescriptionsElementStates() {
+ Map<TopologyChangesKey, TopologyChanges> topologyChanges = Map.of(
+ new TopologyChangesKey("tpNodeIdA", "TpIdA1"),
+ new TopologyChangesBuilder()
+ .setNodeId("tpNodeIdA")
+ .setTpId("TpIdA1")
+ .setState(State.InService)
+ .build(),
+ new TopologyChangesKey("tpNodeIdA", "TpIdA2"),
+ new TopologyChangesBuilder()
+ .setNodeId("tpNodeIdA")
+ .setTpId("TpIdA2")
+ .setState(State.InService)
+ .build());
+
+ assertEquals(pathDescription.getAToZDirection().getAToZ(),
+ networkModelListener.changePathElementStateAZ(topologyChanges, pathDescription));
+ }
+
+ @Test
+ public void testChangePathElementStateAZShouldModifyPathDescriptionsElementStates() {
+ Map<TopologyChangesKey, TopologyChanges> topologyChanges = Map.of(
+ new TopologyChangesKey("tpNodeIdA", "TpIdA1"),
+ new TopologyChangesBuilder()
+ .setNodeId("tpNodeIdA")
+ .setTpId("TpIdA1")
+ .setState(State.OutOfService)
+ .build(),
+ new TopologyChangesKey("tpNodeIdA", "TpIdA2"),
+ new TopologyChangesBuilder()
+ .setNodeId("tpNodeIdA")
+ .setTpId("TpIdA2")
+ .setState(State.OutOfService)
+ .build());
+
+ Map<AToZKey, AToZ> atozmapExpected = pathDescription.getAToZDirection().getAToZ();
+ atozmapExpected.computeIfPresent(
+ new AToZKey("0"),
+ (aToZKey, aToZ) -> new AToZBuilder(aToZ)
+ .setResource(new ResourceBuilder(aToZ.getResource())
+ .setState(State.OutOfService)
+ .build())
+ .build());
+ atozmapExpected.computeIfPresent(
+ new AToZKey("2"),
+ (aToZKey, aToZ) -> new AToZBuilder(aToZ)
+ .setResource(new ResourceBuilder(aToZ.getResource())
+ .setState(State.OutOfService)
+ .build())
+ .build());
+ assertEquals(atozmapExpected, networkModelListener.changePathElementStateAZ(topologyChanges, pathDescription));
+ }
+
+ @Test
+ public void testAllElementsinPathinServiceShouldReturnFalse() {
+ Map<AToZKey, AToZ> atozmap = pathDescription.getAToZDirection().getAToZ();
+ atozmap.computeIfPresent(
+ new AToZKey("0"),
+ (aToZKey, aToZ) -> new AToZBuilder(aToZ)
+ .setResource(new ResourceBuilder(aToZ.getResource())
+ .setState(State.OutOfService)
+ .build())
+ .build());
+ Map<ZToAKey, ZToA> ztoamap = pathDescription.getZToADirection().getZToA();
+ ztoamap.computeIfPresent(
+ new ZToAKey("6"),
+ (zToAKey, zToA) -> new ZToABuilder(zToA)
+ .setResource(new ResourceBuilder(zToA.getResource())
+ .setState(State.OutOfService)
+ .build())
+ .build());
+ assertFalse(networkModelListener.allElementsinPathinService(atozmap, ztoamap));
+ }
+
+ @Test
+ public void testAllElementsinPathinServiceShouldReturnTrue() {
+ assertTrue(networkModelListener.allElementsinPathinService(pathDescription.getAToZDirection().getAToZ(),
+ pathDescription.getZToADirection().getZToA()));
+ }
+
+ @Test
+ public void testUpdateServicePathsShouldNotModifyServiceState() {
+ Map<ServicePathsKey, ServicePaths> servicePathMap = Map.of(new ServicePathsKey("service-path 1"),
+ new ServicePathsBuilder()
+ .setServicePathName("service-path 1")
+ .setPathDescription(pathDescription)
+ .build());
+
+ when(serviceDataStoreOperations.getServicePaths()).thenReturn(Optional.of(new ServicePathListBuilder()
+ .setServicePaths(servicePathMap).build()));
+ when(serviceDataStoreOperations.modifyServicePath(any(PathDescription.class), anyString()))
+ .thenReturn(OperationResult.ok(""));
+ when(serviceDataStoreOperations.getService(anyString())).thenReturn(Optional.of(
+ new ServicesBuilder().setServiceName("serviceTest")
+ .setOperationalState(State.InService)
+ .setAdministrativeState(AdminStates.InService)
+ .build()));
+
+ Map<TopologyChangesKey, TopologyChanges> topologyChanges = Map.of(
+ new TopologyChangesKey("tpNodeIdC", "TpIdC1"),
+ new TopologyChangesBuilder()
+ .setNodeId("tpNodeIdC")
+ .setTpId("TpIdC1")
+ .setState(State.OutOfService)
+ .build(),
+ new TopologyChangesKey("tpNodeIdA", "TpIdA1"),
+ new TopologyChangesBuilder()
+ .setNodeId("tpNodeIdA")
+ .setTpId("TpIdA1")
+ .setState(State.InService)
+ .build());
+
+ networkModelListener.updateServicePaths(new TopologyUpdateResultBuilder()
+ .setTopologyChanges(topologyChanges).build());
+ verify(serviceDataStoreOperations,
+ never()).modifyService(anyString(), any(State.class), any(AdminStates.class));
+ }
+
+ @Test
+ public void testUpdateServicePathsShouldModifyServiceState() {
+ Map<ServicePathsKey, ServicePaths> servicePathMap = Map.of(
+ new ServicePathsKey("service-path 1"),
+ new ServicePathsBuilder()
+ .setServicePathName("service-path 1")
+ .setPathDescription(pathDescription)
+ .build());
+
+ when(serviceDataStoreOperations.getServicePaths()).thenReturn(Optional.of(new ServicePathListBuilder()
+ .setServicePaths(servicePathMap).build()));
+ when(serviceDataStoreOperations.modifyServicePath(any(PathDescription.class), anyString()))
+ .thenReturn(OperationResult.ok(""));
+ when(serviceDataStoreOperations.getService(anyString())).thenReturn(Optional.of(
+ new ServicesBuilder().setServiceName("serviceTest")
+ .setOperationalState(State.InService)
+ .setAdministrativeState(AdminStates.InService)
+ .build()));
+ when(serviceDataStoreOperations.modifyService(anyString(), any(State.class), any(AdminStates.class)))
+ .thenReturn(OperationResult.ok(""));
+
+ Map<TopologyChangesKey, TopologyChanges> topologyChanges = Map.of(
+ new TopologyChangesKey("tpNodeIdA", "TpIdA1"),
+ new TopologyChangesBuilder()
+ .setNodeId("tpNodeIdA")
+ .setTpId("TpIdA1")
+ .setState(State.OutOfService)
+ .build());
+
+ networkModelListener.updateServicePaths(new TopologyUpdateResultBuilder()
+ .setTopologyChanges(topologyChanges).build());
+ verify(serviceDataStoreOperations, times(1)).modifyService(anyString(),
+ eq(State.OutOfService), any(AdminStates.class));
+ }
+
+ @Test
+ public void testOnTopologyUpdateResultWhenNeverWired() {
+ NetworkModelListenerImpl networkModelListenerMocked = Mockito.mock(NetworkModelListenerImpl.class);
+ doCallRealMethod().when(networkModelListenerMocked).onTopologyUpdateResult(any(TopologyUpdateResult.class));
+
+ Map<TopologyChangesKey, TopologyChanges> topologyChanges1 = Map.of(
+ new TopologyChangesKey("tpNodeIdA", "TpIdA1"),
+ new TopologyChangesBuilder()
+ .setNodeId("tpNodeIdA")
+ .setTpId("TpIdA1")
+ .setState(State.OutOfService)
+ .build());
+ Map<TopologyChangesKey, TopologyChanges> topologyChanges2 = Map.of(
+ new TopologyChangesKey("tpNodeIdC", "TpIdC1"),
+ new TopologyChangesBuilder()
+ .setNodeId("tpNodeIdC")
+ .setTpId("TpIdC1")
+ .setState(State.OutOfService)
+ .build());
+
+ networkModelListenerMocked.onTopologyUpdateResult(new TopologyUpdateResultBuilder()
+ .setTopologyChanges(topologyChanges1).build());
+ networkModelListenerMocked.onTopologyUpdateResult(new TopologyUpdateResultBuilder()
+ .setTopologyChanges(topologyChanges2).build());
+ verify(networkModelListenerMocked, times(2)).updateServicePaths(
+ any(TopologyUpdateResult.class));
+ }
+
+ @Test
+ public void testOnTopologyUpdateResultWhenAlreadyWired() {
+ NetworkModelListenerImpl networkModelListenerMocked = Mockito.mock(NetworkModelListenerImpl.class);
+ doCallRealMethod().when(networkModelListenerMocked).onTopologyUpdateResult(any(TopologyUpdateResult.class));
+
+ Map<TopologyChangesKey, TopologyChanges> topologyChanges = Map.of(
+ new TopologyChangesKey("tpNodeIdA", "TpIdA1"),
+ new TopologyChangesBuilder()
+ .setNodeId("tpNodeIdA")
+ .setTpId("TpIdA1")
+ .setState(State.OutOfService)
+ .build());
+ TopologyUpdateResult topologyUpdateResult = new TopologyUpdateResultBuilder()
+ .setTopologyChanges(topologyChanges).build();
+
+ networkModelListenerMocked.onTopologyUpdateResult(topologyUpdateResult);
+ networkModelListenerMocked.onTopologyUpdateResult(topologyUpdateResult);
+ verify(networkModelListenerMocked, times(1)).updateServicePaths(
+ any(TopologyUpdateResult.class));
+ }
+
+ private Map<AToZKey, AToZ> createMapAtoZ() {
+ Map<AToZKey, AToZ> atozmap = new HashMap<>();
+ atozmap.put(
+ new AToZKey("0"),
+ new AToZBuilder()
+ .setId("0")
+ .setResource(new ResourceBuilder()
+ .setResource(new TerminationPointBuilder()
+ .setTpNodeId("tpNodeIdA")
+ .setTpId("TpIdA1")
+ .build())
+ .setState(State.InService)
+ .build())
+ .build());
+ atozmap.put(
+ new AToZKey("1"),
+ new AToZBuilder()
+ .setId("1")
+ .setResource(new ResourceBuilder()
+ .setResource(new NodeBuilder()
+ .setNodeId("NodeIdA")
+ .build())
+ .setState(State.InService)
+ .build())
+ .build());
+ atozmap.put(
+ new AToZKey("2"),
+ new AToZBuilder()
+ .setId("2")
+ .setResource(new ResourceBuilder()
+ .setResource(new TerminationPointBuilder()
+ .setTpNodeId("tpNodeIdA")
+ .setTpId("TpIdA2")
+ .build())
+ .setState(State.InService)
+ .build())
+ .build());
+ atozmap.put(
+ new AToZKey("3"),
+ new AToZBuilder()
+ .setId("3")
+ .setResource(new ResourceBuilder()
+ .setResource(new LinkBuilder()
+ .setLinkId("LinkIdAZ")
+ .build())
+ .setState(State.InService)
+ .build())
+ .build());
+ atozmap.put(
+ new AToZKey("4"),
+ new AToZBuilder()
+ .setId("4")
+ .setResource(new ResourceBuilder()
+ .setResource(new TerminationPointBuilder()
+ .setTpNodeId("tpNodeIdZ")
+ .setTpId("TpIdZ2")
+ .build())
+ .setState(State.InService)
+ .build())
+ .build());
+ atozmap.put(
+ new AToZKey("5"),
+ new AToZBuilder()
+ .setId("5")
+ .setResource(new ResourceBuilder()
+ .setResource(new NodeBuilder()
+ .setNodeId("NodeIdZ")
+ .build())
+ .setState(State.InService)
+ .build())
+ .build());
+ atozmap.put(
+ new AToZKey("6"),
+ new AToZBuilder()
+ .setId("6")
+ .setResource(new ResourceBuilder()
+ .setResource(new TerminationPointBuilder()
+ .setTpNodeId("tpNodeIdZ")
+ .setTpId("TpIdZ1")
+ .build())
+ .setState(State.InService)
+ .build())
+ .build());
+ return atozmap;
+ }
+
+ private Map<ZToAKey, ZToA> createMapZtoA() {
+ Map<ZToAKey, ZToA> ztoamap = new HashMap<>();
+ ztoamap.put(
+ new ZToAKey("0"),
+ new ZToABuilder()
+ .setId("0")
+ .setResource(new ResourceBuilder()
+ .setResource(new TerminationPointBuilder()
+ .setTpNodeId("tpNodeIdZ")
+ .setTpId("TpIdZ1")
+ .build())
+ .setState(State.InService)
+ .build())
+ .build());
+ ztoamap.put(
+ new ZToAKey("1"),
+ new ZToABuilder()
+ .setId("1")
+ .setResource(new ResourceBuilder()
+ .setResource(new NodeBuilder()
+ .setNodeId("NodeIdZ")
+ .build())
+ .setState(State.InService)
+ .build())
+ .build());
+ ztoamap.put(
+ new ZToAKey("2"),
+ new ZToABuilder()
+ .setId("2")
+ .setResource(new ResourceBuilder()
+ .setResource(new TerminationPointBuilder()
+ .setTpNodeId("tpNodeIdZ")
+ .setTpId("TpIdZ2")
+ .build())
+ .setState(State.InService)
+ .build())
+ .build());
+ ztoamap.put(
+ new ZToAKey("3"),
+ new ZToABuilder()
+ .setId("3")
+ .setResource(new ResourceBuilder()
+ .setResource(new LinkBuilder()
+ .setLinkId("LinkIdAZ")
+ .build())
+ .setState(State.InService)
+ .build())
+ .build());
+ ztoamap.put(
+ new ZToAKey("4"),
+ new ZToABuilder()
+ .setId("4")
+ .setResource(new ResourceBuilder()
+ .setResource(new TerminationPointBuilder()
+ .setTpNodeId("tpNodeIdA")
+ .setTpId("TpIdA2")
+ .build())
+ .setState(State.InService)
+ .build())
+ .build());
+ ztoamap.put(
+ new ZToAKey("5"),
+ new ZToABuilder()
+ .setId("5")
+ .setResource(new ResourceBuilder()
+ .setResource(new NodeBuilder()
+ .setNodeId("NodeIdA")
+ .build())
+ .setState(State.InService)
+ .build())
+ .build());
+ ztoamap.put(
+ new ZToAKey("6"),
+ new ZToABuilder()
+ .setId("6")
+ .setResource(new ResourceBuilder()
+ .setResource(new TerminationPointBuilder()
+ .setTpNodeId("tpNodeIdA")
+ .setTpId("TpIdA1")
+ .build())
+ .setState(State.InService)
+ .build())
+ .build());
+ return ztoamap;
+ }
+}
Code Review / transportpce.git / blobdiff