X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=common%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Ftransportpce%2Fcommon%2Fmapping%2FPortMappingImplTest.java;h=bed32688ddfdf4d5472998026ceb3f0348f71509;hb=67763b4d82e44c68fdbc765cdeec5496ff65b01e;hp=c8dd03dcc6748cbbe2e1609208813ba32f1cd29a;hpb=34ba84c1db1c64400ffc6b750c3bc2052b451ede;p=transportpce.git diff --git a/common/src/test/java/org/opendaylight/transportpce/common/mapping/PortMappingImplTest.java b/common/src/test/java/org/opendaylight/transportpce/common/mapping/PortMappingImplTest.java index c8dd03dcc..bed32688d 100644 --- a/common/src/test/java/org/opendaylight/transportpce/common/mapping/PortMappingImplTest.java +++ b/common/src/test/java/org/opendaylight/transportpce/common/mapping/PortMappingImplTest.java @@ -24,22 +24,24 @@ import org.junit.Test; import org.opendaylight.mdsal.binding.api.DataBroker; import org.opendaylight.mdsal.binding.api.WriteTransaction; import org.opendaylight.mdsal.common.api.LogicalDatastoreType; -import org.opendaylight.transportpce.common.DataStoreContext; -import org.opendaylight.transportpce.common.DataStoreContextImpl; -import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev200429.Network; -import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev200429.network.Nodes; -import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev200429.network.NodesKey; -import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev200429.network.nodes.Mapping; -import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev200429.network.nodes.MappingBuilder; -import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev200429.network.nodes.MappingKey; -import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev200429.network.nodes.NodeInfo; -import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev200429.network.nodes.NodeInfoBuilder; +import org.opendaylight.transportpce.test.DataStoreContext; +import org.opendaylight.transportpce.test.DataStoreContextImpl; +import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev210315.Network; +import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev210315.OpenroadmNodeVersion; +import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev210315.mapping.Mapping; +import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev210315.mapping.MappingBuilder; +import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev210315.mapping.MappingKey; +import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev210315.network.Nodes; +import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev210315.network.NodesBuilder; +import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev210315.network.NodesKey; +import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev210315.network.nodes.NodeInfo; +import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev210315.network.nodes.NodeInfoBuilder; import org.opendaylight.yangtools.yang.binding.InstanceIdentifier; - public class PortMappingImplTest { DataBroker dataBroker = null; + private PortMappingVersion710 portMappingVersion710; private PortMappingVersion221 portMappingVersion221; private PortMappingVersion121 portMappingVersion121; private PortMapping portMapping; @@ -48,9 +50,11 @@ public class PortMappingImplTest { public void setUp() throws Exception { DataStoreContext dataStoreContext = new DataStoreContextImpl(); dataBroker = dataStoreContext.getDataBroker(); + portMappingVersion710 = mock(PortMappingVersion710.class); portMappingVersion221 = mock(PortMappingVersion221.class); portMappingVersion121 = mock(PortMappingVersion121.class); - portMapping = new PortMappingImpl(dataBroker, portMappingVersion221, portMappingVersion121); + portMapping = new PortMappingImpl(dataBroker, portMappingVersion710, + portMappingVersion221, portMappingVersion121); } @Test @@ -80,21 +84,24 @@ public class PortMappingImplTest { .build(); InstanceIdentifier nodeInfoIID = InstanceIdentifier.builder(Network.class).child(Nodes.class, new NodesKey("node")).child(NodeInfo.class).build(); - final NodeInfo nodeInfo = new NodeInfoBuilder().setOpenroadmVersion(NodeInfo.OpenroadmVersion._221).build(); - final NodeInfo nodeInfo2 = new NodeInfoBuilder().setOpenroadmVersion(NodeInfo.OpenroadmVersion._121).build(); - + final NodeInfo nodeInfo = new NodeInfoBuilder().setOpenroadmVersion(OpenroadmNodeVersion._221).build(); + final NodeInfo nodeInfo2 = new NodeInfoBuilder().setOpenroadmVersion(OpenroadmNodeVersion._121).build(); + Nodes nodes = new NodesBuilder().setNodeId("node").setNodeInfo(nodeInfo).build(); + InstanceIdentifier nodeIID = InstanceIdentifier.builder(Network.class).child(Nodes.class, + new NodesKey("node")).build(); //create node with portmapping and nodeifno version 2 WriteTransaction wr = dataBroker.newWriteOnlyTransaction(); - wr.merge(LogicalDatastoreType.CONFIGURATION, portMappingIID, mapping, true); - wr.merge(LogicalDatastoreType.CONFIGURATION, nodeInfoIID, nodeInfo, true); + wr.merge(LogicalDatastoreType.CONFIGURATION, nodeIID, nodes); + wr.merge(LogicalDatastoreType.CONFIGURATION, portMappingIID, mapping); + wr.merge(LogicalDatastoreType.CONFIGURATION, nodeInfoIID, nodeInfo); wr.commit().get(); //test update port mapping version 2 when(portMappingVersion221.updateMapping("node", mapping)).thenReturn(true); - assertEquals(portMapping.updateMapping("node", mapping), true); + assertTrue("Update sould be ok", portMapping.updateMapping("node", mapping)); //replace node nodefino version 1 instead of version 2 WriteTransaction wr2 = dataBroker.newWriteOnlyTransaction(); - wr2.put(LogicalDatastoreType.CONFIGURATION, nodeInfoIID, nodeInfo2, true); + wr2.merge(LogicalDatastoreType.CONFIGURATION, nodeInfoIID, nodeInfo2); wr2.commit().get(); //test update portmapping version 1