BUG-45 : migrated Origin path attribute to generated source code.

[bgpcep.git] / bgp / parser-impl / src / test / java / org / opendaylight / protocol / bgp / parser / impl / BGPParserTest.java

diff --git a/bgp/parser-impl/src/test/java/org/opendaylight/protocol/bgp/parser/impl/BGPParserTest.java b/bgp/parser-impl/src/test/java/org/opendaylight/protocol/bgp/parser/impl/BGPParserTest.java
index 297f0922fd5e81892ed0430f62109790904549cb..09ceef540190702b7e6401448f2b7ba1c0c557ab 100644 (file)
--- a/bgp/parser-impl/src/test/java/org/opendaylight/protocol/bgp/parser/impl/BGPParserTest.java
+++ b/bgp/parser-impl/src/test/java/org/opendaylight/protocol/bgp/parser/impl/BGPParserTest.java
@@ -26,7 +26,6 @@ import org.opendaylight.protocol.bgp.concepts.ASPath;
 import org.opendaylight.protocol.bgp.concepts.BGPAddressFamily;
 import org.opendaylight.protocol.bgp.concepts.BGPAggregator;
 import org.opendaylight.protocol.bgp.concepts.BGPObject;
-import org.opendaylight.protocol.bgp.concepts.BGPOrigin;
 import org.opendaylight.protocol.bgp.concepts.BGPSubsequentAddressFamily;
 import org.opendaylight.protocol.bgp.concepts.BGPTableType;
 import org.opendaylight.protocol.bgp.concepts.BaseBGPObjectState;
@@ -79,6 +78,7 @@ import org.opendaylight.protocol.concepts.Identifier;
 import org.opendaylight.protocol.concepts.Metric;
 import org.opendaylight.protocol.util.ByteArray;
 import org.opendaylight.protocol.util.DefaultingTypesafeContainer;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev130919.BgpOrigin;
 
 import com.google.common.collect.Lists;
 import com.google.common.collect.Sets;
@@ -100,8 +100,9 @@ public class BGPParserTest {
                for (int i = 1; i <= COUNTER; i++) {
                        final String name = "/up" + i + ".bin";
                        final InputStream is = BGPParserTest.class.getResourceAsStream(name);
-                       if (is == null)
+                       if (is == null) {
                                throw new IOException("Failed to get resource " + name);
+                       }
 
                        final ByteArrayOutputStream bis = new ByteArrayOutputStream();
                        final byte[] data = new byte[MAX_SIZE];
@@ -165,9 +166,9 @@ public class BGPParserTest {
        @Test
        public void testGetUpdateMessage1() throws Exception {
 
-               final byte[] body = ByteArray.cutBytes(inputBytes.get(0), BGPMessageFactory.COMMON_HEADER_LENGTH);
-               final int messageLength = ByteArray.bytesToInt(ByteArray.subByte(inputBytes.get(0), BGPMessageFactory.MARKER_LENGTH,
-                               BGPMessageFactory.LENGTH_FIELD_LENGTH));
+               final byte[] body = ByteArray.cutBytes(inputBytes.get(0), BGPMessageFactoryImpl.COMMON_HEADER_LENGTH);
+               final int messageLength = ByteArray.bytesToInt(ByteArray.subByte(inputBytes.get(0), BGPMessageFactoryImpl.MARKER_LENGTH,
+                               BGPMessageFactoryImpl.LENGTH_FIELD_LENGTH));
                final BGPUpdateEvent ret = BGPUpdateMessageParser.parse(body, messageLength);
 
                assertTrue(ret instanceof BGPUpdateMessage);
@@ -217,7 +218,7 @@ public class BGPParserTest {
                // final Set<IPv4Prefix> nlri = Sets.newHashSet(pref1, pref2, pref3);
                // assertEquals(nlri, ret.getBgpUpdateMessageBuilder().getNlri());
 
-               final BaseBGPObjectState state = new BaseBGPObjectState(BGPOrigin.IGP, null);
+               final BaseBGPObjectState state = new BaseBGPObjectState(BgpOrigin.Igp, null);
                final NetworkRouteState<IPv4Address> routeState = new NetworkRouteState<>(new NetworkObjectState(asPath, comms, Collections.<ExtendedCommunity> emptySet()), nextHop);
 
                // check API message
@@ -291,9 +292,9 @@ public class BGPParserTest {
         */
        @Test
        public void testGetUpdateMessage2() throws Exception {
-               final byte[] body = ByteArray.cutBytes(inputBytes.get(1), BGPMessageFactory.COMMON_HEADER_LENGTH);
-               final int messageLength = ByteArray.bytesToInt(ByteArray.subByte(inputBytes.get(1), BGPMessageFactory.MARKER_LENGTH,
-                               BGPMessageFactory.LENGTH_FIELD_LENGTH));
+               final byte[] body = ByteArray.cutBytes(inputBytes.get(1), BGPMessageFactoryImpl.COMMON_HEADER_LENGTH);
+               final int messageLength = ByteArray.bytesToInt(ByteArray.subByte(inputBytes.get(1), BGPMessageFactoryImpl.MARKER_LENGTH,
+                               BGPMessageFactoryImpl.LENGTH_FIELD_LENGTH));
                final BGPUpdateEvent ret = BGPUpdateMessageParser.parse(body, messageLength);
 
                assertTrue(ret instanceof BGPUpdateMessage);
@@ -335,7 +336,7 @@ public class BGPParserTest {
                // TypeCode.CLUSTER_LIST, true, false, false, false, clusters);
                // assertEquals(clusterAttr, attrs.get(4));
 
-               final BaseBGPObjectState state = new BaseBGPObjectState(BGPOrigin.IGP, null);
+               final BaseBGPObjectState state = new BaseBGPObjectState(BgpOrigin.Igp, null);
                final NetworkRouteState<IPv6Address> routeState = new NetworkRouteState<>(new NetworkObjectState(asPath, Collections.<Community> emptySet(), Collections.<ExtendedCommunity> emptySet()), nextHop);
 
                // check API message
@@ -400,9 +401,9 @@ public class BGPParserTest {
         */
        @Test
        public void testGetUpdateMessage3() throws Exception {
-               final byte[] body = ByteArray.cutBytes(inputBytes.get(2), BGPMessageFactory.COMMON_HEADER_LENGTH);
-               final int messageLength = ByteArray.bytesToInt(ByteArray.subByte(inputBytes.get(2), BGPMessageFactory.MARKER_LENGTH,
-                               BGPMessageFactory.LENGTH_FIELD_LENGTH));
+               final byte[] body = ByteArray.cutBytes(inputBytes.get(2), BGPMessageFactoryImpl.COMMON_HEADER_LENGTH);
+               final int messageLength = ByteArray.bytesToInt(ByteArray.subByte(inputBytes.get(2), BGPMessageFactoryImpl.MARKER_LENGTH,
+                               BGPMessageFactoryImpl.LENGTH_FIELD_LENGTH));
                final BGPUpdateEvent ret = BGPUpdateMessageParser.parse(body, messageLength);
                assertTrue(ret instanceof BGPUpdateMessage);
                final BGPUpdateMessage message = (BGPUpdateMessage) ret;
@@ -446,7 +447,7 @@ public class BGPParserTest {
                // final Set<IPv4Prefix> nlri = Sets.newHashSet(pref1);
                // assertEquals(nlri, ret.getBgpUpdateMessageBuilder().getNlri());
 
-               final BaseBGPObjectState state = new BaseBGPObjectState(BGPOrigin.INCOMPLETE, aggregator);
+               final BaseBGPObjectState state = new BaseBGPObjectState(BgpOrigin.Incomplete, aggregator);
                final NetworkRouteState<IPv4Address> routeState = new NetworkRouteState<>(new NetworkObjectState(asPath, Collections.<Community> emptySet(), Collections.<ExtendedCommunity> emptySet()), nextHop);
 
                // check API message
@@ -504,9 +505,9 @@ public class BGPParserTest {
         */
        @Test
        public void testGetUpdateMessage4() throws Exception {
-               final byte[] body = ByteArray.cutBytes(inputBytes.get(3), BGPMessageFactory.COMMON_HEADER_LENGTH);
-               final int messageLength = ByteArray.bytesToInt(ByteArray.subByte(inputBytes.get(3), BGPMessageFactory.MARKER_LENGTH,
-                               BGPMessageFactory.LENGTH_FIELD_LENGTH));
+               final byte[] body = ByteArray.cutBytes(inputBytes.get(3), BGPMessageFactoryImpl.COMMON_HEADER_LENGTH);
+               final int messageLength = ByteArray.bytesToInt(ByteArray.subByte(inputBytes.get(3), BGPMessageFactoryImpl.MARKER_LENGTH,
+                               BGPMessageFactoryImpl.LENGTH_FIELD_LENGTH));
                final BGPUpdateEvent ret = BGPUpdateMessageParser.parse(body, messageLength);
 
                assertTrue(ret instanceof BGPUpdateMessage);
@@ -550,7 +551,7 @@ public class BGPParserTest {
                // final Set<IPv4Prefix> nlri = Sets.newHashSet(pref1, pref2, pref3);
                // assertEquals(nlri, ret.getBgpUpdateMessageBuilder().getNlri());
 
-               final BaseBGPObjectState state = new BaseBGPObjectState(BGPOrigin.EGP, null);
+               final BaseBGPObjectState state = new BaseBGPObjectState(BgpOrigin.Egp, null);
                final NetworkRouteState<IPv4Address> routeState = new NetworkRouteState<>(new NetworkObjectState(ASPath.EMPTY, Collections.<Community> emptySet(), comms), nextHop);
 
                // check API message
@@ -586,9 +587,9 @@ public class BGPParserTest {
         */
        @Test
        public void testGetUpdateMessage5() throws Exception {
-               final byte[] body = ByteArray.cutBytes(inputBytes.get(4), BGPMessageFactory.COMMON_HEADER_LENGTH);
-               final int messageLength = ByteArray.bytesToInt(ByteArray.subByte(inputBytes.get(4), BGPMessageFactory.MARKER_LENGTH,
-                               BGPMessageFactory.LENGTH_FIELD_LENGTH));
+               final byte[] body = ByteArray.cutBytes(inputBytes.get(4), BGPMessageFactoryImpl.COMMON_HEADER_LENGTH);
+               final int messageLength = ByteArray.bytesToInt(ByteArray.subByte(inputBytes.get(4), BGPMessageFactoryImpl.MARKER_LENGTH,
+                               BGPMessageFactoryImpl.LENGTH_FIELD_LENGTH));
                final BGPUpdateEvent ret = BGPUpdateMessageParser.parse(body, messageLength);
 
                assertTrue(ret instanceof BGPUpdateMessage);
@@ -616,9 +617,9 @@ public class BGPParserTest {
         */
        @Test
        public void testEORIpv4() throws Exception {
-               final byte[] body = ByteArray.cutBytes(inputBytes.get(5), BGPMessageFactory.COMMON_HEADER_LENGTH);
-               final int messageLength = ByteArray.bytesToInt(ByteArray.subByte(inputBytes.get(5), BGPMessageFactory.MARKER_LENGTH,
-                               BGPMessageFactory.LENGTH_FIELD_LENGTH));
+               final byte[] body = ByteArray.cutBytes(inputBytes.get(5), BGPMessageFactoryImpl.COMMON_HEADER_LENGTH);
+               final int messageLength = ByteArray.bytesToInt(ByteArray.subByte(inputBytes.get(5), BGPMessageFactoryImpl.MARKER_LENGTH,
+                               BGPMessageFactoryImpl.LENGTH_FIELD_LENGTH));
                final BGPUpdateEvent ret = BGPUpdateMessageParser.parse(body, messageLength);
 
                assertTrue(ret instanceof BGPUpdateSynchronized);
@@ -652,9 +653,9 @@ public class BGPParserTest {
         */
        @Test
        public void testEORIpv6() throws Exception {
-               final byte[] body = ByteArray.cutBytes(inputBytes.get(6), BGPMessageFactory.COMMON_HEADER_LENGTH);
-               final int messageLength = ByteArray.bytesToInt(ByteArray.subByte(inputBytes.get(6), BGPMessageFactory.MARKER_LENGTH,
-                               BGPMessageFactory.LENGTH_FIELD_LENGTH));
+               final byte[] body = ByteArray.cutBytes(inputBytes.get(6), BGPMessageFactoryImpl.COMMON_HEADER_LENGTH);
+               final int messageLength = ByteArray.bytesToInt(ByteArray.subByte(inputBytes.get(6), BGPMessageFactoryImpl.MARKER_LENGTH,
+                               BGPMessageFactoryImpl.LENGTH_FIELD_LENGTH));
                final BGPUpdateEvent ret = BGPUpdateMessageParser.parse(body, messageLength);
 
                assertTrue(ret instanceof BGPUpdateSynchronized);
@@ -690,9 +691,9 @@ public class BGPParserTest {
         */
        @Test
        public void testEORLS() throws Exception {
-               final byte[] body = ByteArray.cutBytes(inputBytes.get(7), BGPMessageFactory.COMMON_HEADER_LENGTH);
-               final int messageLength = ByteArray.bytesToInt(ByteArray.subByte(inputBytes.get(7), BGPMessageFactory.MARKER_LENGTH,
-                               BGPMessageFactory.LENGTH_FIELD_LENGTH));
+               final byte[] body = ByteArray.cutBytes(inputBytes.get(7), BGPMessageFactoryImpl.COMMON_HEADER_LENGTH);
+               final int messageLength = ByteArray.bytesToInt(ByteArray.subByte(inputBytes.get(7), BGPMessageFactoryImpl.MARKER_LENGTH,
+                               BGPMessageFactoryImpl.LENGTH_FIELD_LENGTH));
                final BGPUpdateEvent ret = BGPUpdateMessageParser.parse(body, messageLength);
 
                assertTrue(ret instanceof BGPUpdateSynchronized);
@@ -864,9 +865,9 @@ public class BGPParserTest {
         */
        @Test
        public void testBGPLink() throws Exception {
-               final byte[] body = ByteArray.cutBytes(inputBytes.get(8), BGPMessageFactory.COMMON_HEADER_LENGTH);
-               final int messageLength = ByteArray.bytesToInt(ByteArray.subByte(inputBytes.get(8), BGPMessageFactory.MARKER_LENGTH,
-                               BGPMessageFactory.LENGTH_FIELD_LENGTH));
+               final byte[] body = ByteArray.cutBytes(inputBytes.get(8), BGPMessageFactoryImpl.COMMON_HEADER_LENGTH);
+               final int messageLength = ByteArray.bytesToInt(ByteArray.subByte(inputBytes.get(8), BGPMessageFactoryImpl.MARKER_LENGTH,
+                               BGPMessageFactoryImpl.LENGTH_FIELD_LENGTH));
                final BGPUpdateEvent ret = BGPUpdateMessageParser.parse(body, messageLength);
 
                assertTrue(ret instanceof BGPUpdateMessage);
@@ -878,7 +879,7 @@ public class BGPParserTest {
 
                // network object state
                final NetworkObjectState objState = new NetworkObjectState(ASPath.EMPTY, Collections.<Community> emptySet(), Collections.<ExtendedCommunity> emptySet());
-               final BaseBGPObjectState state = new BaseBGPObjectState(BGPOrigin.IGP, null);
+               final BaseBGPObjectState state = new BaseBGPObjectState(BgpOrigin.Igp, null);
 
                // network link state
                final DefaultingTypesafeContainer<Metric<?>> container = new DefaultingTypesafeContainer<Metric<?>>();
@@ -927,7 +928,7 @@ public class BGPParserTest {
                00 31 <- NLRI length (49)
                03 <- ProtocolID - OSPF
                00 00 00 00 00 00 00 01 <- identifier
-       
+
                01 00 <- local node descriptor type (256)
                00 24 <- length (36)
                02 00 <- node descriptor type (member AS - 512)
@@ -942,12 +943,12 @@ public class BGPParserTest {
                02 03 <- node descriptor type (routeId - 515)
                00 08 <- length
                03 03 03 04 0b 0b 0b 03 <- OSPF Router Id
-       
+
                00 01 <- NLRI type (1 - nodeNLRI)
                00 2d <- NLRI length (45)
                03 <- ProtocolID - OSPF
                00 00 00 00 00 00 00 01 <- identifier
-       
+
                01 00 <- local node descriptor type (256)
                00 20 <- length (32)
                02 00 <- node descriptor type (member AS - 512)
@@ -962,7 +963,7 @@ public class BGPParserTest {
                02 03 <- node descriptor type (routeId - 515)
                00 04 <- length
                03 03 03 04 <- OSPF Router Id
-       
+
                00 01 <- NLRI type (1 - nodeNLRI)
                00 2d <- NLRI length (45)
                03 <- ProtocolID - OSPF
@@ -981,7 +982,7 @@ public class BGPParserTest {
                02 03 <- node descriptor type (routeId - 515)
                00 04 <- length
                01 01 01 02  <- OSPF Router Id
-       
+
                40 <- attribute flags
                01 <- attribute type (Origin)
                01 <- attribute length
@@ -996,9 +997,9 @@ public class BGPParserTest {
         */
        @Test
        public void testBGPNode() throws Exception {
-               final byte[] body = ByteArray.cutBytes(inputBytes.get(9), BGPMessageFactory.COMMON_HEADER_LENGTH);
-               final int messageLength = ByteArray.bytesToInt(ByteArray.subByte(inputBytes.get(9), BGPMessageFactory.MARKER_LENGTH,
-                               BGPMessageFactory.LENGTH_FIELD_LENGTH));
+               final byte[] body = ByteArray.cutBytes(inputBytes.get(9), BGPMessageFactoryImpl.COMMON_HEADER_LENGTH);
+               final int messageLength = ByteArray.bytesToInt(ByteArray.subByte(inputBytes.get(9), BGPMessageFactoryImpl.MARKER_LENGTH,
+                               BGPMessageFactoryImpl.LENGTH_FIELD_LENGTH));
                final BGPUpdateEvent ret = BGPUpdateMessageParser.parse(body, messageLength);
 
                assertTrue(ret instanceof BGPUpdateMessage);
@@ -1010,7 +1011,7 @@ public class BGPParserTest {
 
                // network object state
                final NetworkObjectState objState = new NetworkObjectState(ASPath.EMPTY, Collections.<Community> emptySet(), Collections.<ExtendedCommunity> emptySet());
-               final BaseBGPObjectState state = new BaseBGPObjectState(BGPOrigin.IGP, null);
+               final BaseBGPObjectState state = new BaseBGPObjectState(BgpOrigin.Igp, null);
                final NetworkNodeState nstate = new NetworkNodeState(objState, Collections.<TopologyIdentifier> emptySet(), Collections.<ISISAreaIdentifier> emptySet(), false, false, false, false, Collections.<RouterIdentifier> emptySet(), null);
 
                // network link state
@@ -1076,9 +1077,8 @@ public class BGPParserTest {
         */
        @Test
        public void testOpenMessage() throws Exception {
-               final BGPMessageFactory msgFactory = new BGPMessageFactory();
-               final BGPOpenMessage open = (BGPOpenMessage) msgFactory.parse(ByteArray.cutBytes(inputBytes.get(13),
-                               BGPMessageFactory.MARKER_LENGTH));
+               final BGPMessageFactoryImpl msgFactory = new BGPMessageFactoryImpl();
+               final BGPOpenMessage open = (BGPOpenMessage) msgFactory.parse(inputBytes.get(13)).get(0);
                final Set<BGPTableType> types = Sets.newHashSet();
                for (final BGPParameter param : open.getOptParams()) {
                        if (param instanceof MultiprotocolCapability) {