pcep/ietf-stateful07/src/test/java/org/opendaylight/protocol/pcep/ietf/PCEPObjectParserTest.java

   1 /*
   2  * Copyright (c) 2013 Cisco Systems, Inc. and others.  All rights reserved.
   3  *
   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
   7  */
   8 package org.opendaylight.protocol.pcep.ietf;
   9
  10 import static org.junit.Assert.assertArrayEquals;
  11 import static org.junit.Assert.assertEquals;
  12
  13 import io.netty.buffer.ByteBuf;
  14 import io.netty.buffer.Unpooled;
  15 import java.io.IOException;
  16 import org.junit.Before;
  17 import org.junit.Test;
  18 import org.opendaylight.protocol.pcep.ietf.initiated00.CInitiated00LspObjectParser;
  19 import org.opendaylight.protocol.pcep.ietf.initiated00.CInitiated00SrpObjectParser;
  20 import org.opendaylight.protocol.pcep.ietf.stateful07.Stateful07LspObjectParser;
  21 import org.opendaylight.protocol.pcep.ietf.stateful07.Stateful07LspaObjectParser;
  22 import org.opendaylight.protocol.pcep.ietf.stateful07.Stateful07OpenObjectParser;
  23 import org.opendaylight.protocol.pcep.spi.ObjectHeaderImpl;
  24 import org.opendaylight.protocol.pcep.spi.PCEPDeserializerException;
  25 import org.opendaylight.protocol.pcep.spi.TlvRegistry;
  26 import org.opendaylight.protocol.pcep.spi.VendorInformationTlvRegistry;
  27 import org.opendaylight.protocol.pcep.spi.pojo.ServiceLoaderPCEPExtensionProviderContext;
  28 import org.opendaylight.protocol.util.ByteArray;
  29 import org.opendaylight.protocol.util.Ipv4Util;
  30 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.IpAddress;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.initiated.rev131126.Lsp1;
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.initiated.rev131126.Lsp1Builder;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.initiated.rev131126.Srp1;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.initiated.rev131126.Srp1Builder;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.OperationalStatus;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.PlspId;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.SrpIdNumber;
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.Tlvs1;
  39 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.Tlvs1Builder;
  40 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.Tlvs2;
  41 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.Tlvs2Builder;
  42 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.lsp.error.code.tlv.LspErrorCode;
  43 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.lsp.error.code.tlv.LspErrorCodeBuilder;
  44 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.lsp.identifiers.tlv.LspIdentifiers;
  45 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.lsp.identifiers.tlv.LspIdentifiersBuilder;
  46 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.lsp.identifiers.tlv.lsp.identifiers.address.family.Ipv4CaseBuilder;
  47 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.lsp.identifiers.tlv.lsp.identifiers.address.family.ipv4._case.Ipv4Builder;
  48 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.lsp.object.LspBuilder;
  49 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.rsvp.error.spec.tlv.RsvpErrorSpec;
  50 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.rsvp.error.spec.tlv.RsvpErrorSpecBuilder;
  51 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.rsvp.error.spec.tlv.rsvp.error.spec.error.type.RsvpCaseBuilder;
  52 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.rsvp.error.spec.tlv.rsvp.error.spec.error.type.rsvp._case.RsvpErrorBuilder;
  53 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.srp.object.SrpBuilder;
  54 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.srp.object.srp.TlvsBuilder;
  55 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.stateful.capability.tlv.Stateful;
  56 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.stateful.capability.tlv.StatefulBuilder;
  57 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.symbolic.path.name.tlv.SymbolicPathName;
  58 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.symbolic.path.name.tlv.SymbolicPathNameBuilder;
  59 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.ProtocolVersion;
  60 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lspa.object.Lspa;
  61 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lspa.object.LspaBuilder;
  62 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.OpenBuilder;
  63 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.path.setup.type.tlv.PathSetupTypeBuilder;
  64 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.AttributeFilter;
  65 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.Ipv4ExtendedTunnelId;
  66 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.LspId;
  67 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.TunnelId;
  68
  69 public class PCEPObjectParserTest {
  70
  71     private TlvRegistry tlvRegistry;
  72
  73     private VendorInformationTlvRegistry viTlvRegistry;
  74
  75     @Before
  76     public void setUp() throws Exception {
  77         this.tlvRegistry = ServiceLoaderPCEPExtensionProviderContext.create().getTlvHandlerRegistry();
  78         this.viTlvRegistry = ServiceLoaderPCEPExtensionProviderContext.getSingletonInstance().getVendorInformationTlvRegistry();
  79     }
  80
  81     @Test
  82     public void testOpenObjectWithTLV() throws PCEPDeserializerException, IOException {
  83         final Stateful07OpenObjectParser parser = new Stateful07OpenObjectParser(this.tlvRegistry, this.viTlvRegistry);
  84         final ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCEPOpenObject1.bin"));
  85
  86         final OpenBuilder builder = new OpenBuilder();
  87         builder.setProcessingRule(false);
  88         builder.setIgnore(false);
  89         builder.setVersion(new ProtocolVersion((short) 1));
  90         builder.setKeepalive((short) 30);
  91         builder.setDeadTimer((short) 120);
  92         builder.setSessionId((short) 1);
  93
  94         final Stateful tlv1 = new StatefulBuilder().setLspUpdateCapability(Boolean.TRUE).build();
  95
  96         final Tlvs1Builder statBuilder = new Tlvs1Builder();
  97         statBuilder.setStateful(tlv1);
  98
  99         builder.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.open.TlvsBuilder().addAugmentation(
 100                 Tlvs1.class, statBuilder.build()).build());
 101
 102         assertEquals(builder.build(), parser.parseObject(new ObjectHeaderImpl(false, false), result.slice(4, result.readableBytes() - 4)));
 103         final ByteBuf buf = Unpooled.buffer();
 104         parser.serializeObject(builder.build(), buf);
 105         assertArrayEquals(result.array(),ByteArray.getAllBytes(buf));
 106     }
 107
 108     @Test
 109     public void testLspObjectWithTLV() throws IOException, PCEPDeserializerException {
 110         final CInitiated00LspObjectParser parser = new CInitiated00LspObjectParser(this.tlvRegistry, this.viTlvRegistry);
 111         final ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCEPLspObject1WithTLV.bin"));
 112
 113         final LspBuilder builder = new LspBuilder();
 114         builder.setProcessingRule(true);
 115         builder.setIgnore(true);
 116         builder.setAdministrative(true);
 117         builder.setDelegate(false);
 118         builder.setRemove(true);
 119         builder.setSync(false);
 120         builder.addAugmentation(Lsp1.class, new Lsp1Builder().setCreate(false).build());
 121         builder.setOperational(OperationalStatus.GoingDown);
 122         builder.setPlspId(new PlspId(0x12345L));
 123
 124         final LspErrorCode tlv1 = new LspErrorCodeBuilder().setErrorCode(627610883L).build();
 125         final SymbolicPathName tlv2 = new SymbolicPathNameBuilder().setPathName(
 126                 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.SymbolicPathName("Med".getBytes())).build();
 127         builder.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.lsp.object.lsp.TlvsBuilder().setLspErrorCode(
 128                 tlv1).setSymbolicPathName(tlv2).build());
 129         assertEquals(builder.build(), parser.parseObject(new ObjectHeaderImpl(true, true), result.slice(4, result.readableBytes() - 4)));
 130         final ByteBuf buf = Unpooled.buffer();
 131         parser.serializeObject(builder.build(), buf);
 132         assertArrayEquals(result.array(),ByteArray.getAllBytes(buf));
 133     }
 134
 135     @Test
 136     public void testStateful07LspObjectWithTlv() throws IOException, PCEPDeserializerException {
 137         final Stateful07LspObjectParser parser = new Stateful07LspObjectParser(this.tlvRegistry, this.viTlvRegistry);
 138         final ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCEPLspObject2WithTLV.bin"));
 139
 140         final LspBuilder builder = new LspBuilder();
 141         builder.setProcessingRule(true);
 142         builder.setIgnore(true);
 143         builder.setAdministrative(true);
 144         builder.setDelegate(false);
 145         builder.setRemove(true);
 146         builder.setSync(false);
 147         builder.setOperational(OperationalStatus.GoingDown);
 148         builder.setPlspId(new PlspId(0x12345L));
 149
 150         final LspErrorCode tlv1 = new LspErrorCodeBuilder().setErrorCode(627610883L).build();
 151         final SymbolicPathName tlv2 = new SymbolicPathNameBuilder().setPathName(
 152                 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.SymbolicPathName("Med".getBytes())).build();
 153         final Ipv4Builder afi = new Ipv4Builder();
 154         afi.setIpv4TunnelSenderAddress(Ipv4Util.addressForByteBuf(Unpooled.wrappedBuffer(new byte[] { (byte) 0x12, (byte) 0x34, (byte) 0x56, (byte) 0x78 })));
 155         afi.setIpv4ExtendedTunnelId(new Ipv4ExtendedTunnelId(Ipv4Util.addressForByteBuf(Unpooled.wrappedBuffer(new byte[] { (byte) 0x12, (byte) 0x34, (byte) 0x56,
 156             (byte) 0x78 }))));
 157         afi.setIpv4TunnelEndpointAddress(Ipv4Util.addressForByteBuf(Unpooled.wrappedBuffer(new byte[] { (byte) 0x12, (byte) 0x34, (byte) 0x56, (byte) 0x78 })));
 158         final LspIdentifiers tlv3 = new LspIdentifiersBuilder().setAddressFamily(new Ipv4CaseBuilder().setIpv4(afi.build()).build()).setLspId(
 159             new LspId(65535L)).setTunnelId(new TunnelId(4660)).build();
 160         final RsvpErrorBuilder rsvpBuilder = new RsvpErrorBuilder();
 161         rsvpBuilder.setNode(new IpAddress(Ipv4Util.addressForByteBuf(Unpooled.wrappedBuffer(new byte[] { (byte) 0x12, (byte) 0x34, (byte) 0x56, (byte) 0x78 }))));
 162         rsvpBuilder.setFlags(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.ErrorSpec.Flags(false, true));
 163         rsvpBuilder.setCode((short) 146);
 164         rsvpBuilder.setValue(5634);
 165         final RsvpErrorSpec tlv4 = new RsvpErrorSpecBuilder().setErrorType(new RsvpCaseBuilder().setRsvpError(rsvpBuilder.build()).build()).build();
 166         builder.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.lsp.object.lsp.TlvsBuilder().setLspErrorCode(
 167                 tlv1).setSymbolicPathName(tlv2).setLspIdentifiers(tlv3).setRsvpErrorSpec(tlv4).build());
 168         assertEquals(builder.build(), parser.parseObject(new ObjectHeaderImpl(true, true), result.slice(4, result.readableBytes() - 4)));
 169         final ByteBuf buf = Unpooled.buffer();
 170         parser.serializeObject(builder.build(), buf);
 171         assertArrayEquals(result.array(),ByteArray.getAllBytes(buf));
 172     }
 173
 174     @Test
 175     public void testLspaObject() throws IOException, PCEPDeserializerException {
 176         final Stateful07LspaObjectParser parser = new Stateful07LspaObjectParser(this.tlvRegistry, this.viTlvRegistry);
 177         final LspaBuilder builder = new LspaBuilder();
 178         final ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCEPLspaObject3RandVals.bin"));
 179
 180         final SymbolicPathName tlv = new SymbolicPathNameBuilder().setPathName(
 181                 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.SymbolicPathName(new byte[] {
 182                     (byte) 0x4d, (byte) 0x65, (byte) 0x64, (byte) 0x20, (byte) 0x74, (byte) 0x65, (byte) 0x73, (byte) 0x74, (byte) 0x20,
 183                     (byte) 0x6f, (byte) 0x66, (byte) 0x20, (byte) 0x73, (byte) 0x79, (byte) 0x6d, (byte) 0x62, (byte) 0x6f, (byte) 0x6c,
 184                     (byte) 0x69, (byte) 0x63, (byte) 0x20, (byte) 0x6e, (byte) 0x61, (byte) 0x6d, (byte) 0x65 })).build();
 185
 186         builder.setIgnore(false);
 187         builder.setProcessingRule(false);
 188         builder.setExcludeAny(new AttributeFilter(0x20A1FEE3L));
 189         builder.setIncludeAny(new AttributeFilter(0x1A025CC7L));
 190         builder.setIncludeAll(new AttributeFilter(0x2BB66532L));
 191         builder.setHoldPriority((short) 0x02);
 192         builder.setSetupPriority((short) 0x03);
 193         builder.setLocalProtectionDesired(true);
 194         builder.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lspa.object.lspa.TlvsBuilder().addAugmentation(
 195                 Tlvs2.class, new Tlvs2Builder().setSymbolicPathName(tlv).build()).build());
 196
 197         // Tlvs container does not contain toString
 198         final Object o = parser.parseObject(new ObjectHeaderImpl(true, true), result.slice(4, result.readableBytes() - 4));
 199         assertEquals(tlv, ((Lspa) o).getTlvs().getAugmentation(Tlvs2.class).getSymbolicPathName());
 200         // assertEquals(builder.build(), parser.parseObject(new ObjectHeaderImpl(true, true), ByteArray.cutBytes(result,
 201         // 4)));
 202         final ByteBuf buf = Unpooled.buffer();
 203         parser.serializeObject(builder.build(), buf);
 204         assertArrayEquals(result.array(),ByteArray.getAllBytes(buf));
 205     }
 206
 207     @Test
 208     public void testSrpObject() throws IOException, PCEPDeserializerException {
 209         final CInitiated00SrpObjectParser parser = new CInitiated00SrpObjectParser(this.tlvRegistry, this.viTlvRegistry);
 210         final ByteBuf result = Unpooled.wrappedBuffer(new byte[] { (byte) 0x21, (byte) 0x10, (byte) 0x00, (byte) 0x0c, 0, 0, 0,
 211             (byte) 0x01, 0, 0, 0, (byte) 0x01 });
 212
 213         final SrpBuilder builder = new SrpBuilder();
 214         builder.setProcessingRule(false);
 215         builder.setIgnore(false);
 216         builder.setOperationId(new SrpIdNumber(1L));
 217         builder.addAugmentation(Srp1.class, new Srp1Builder().setRemove(true).build());
 218         builder.setTlvs(new TlvsBuilder().build());
 219
 220         assertEquals(builder.build(), parser.parseObject(new ObjectHeaderImpl(false, false), result.slice(4, result.readableBytes() - 4)));
 221         final ByteBuf buf = Unpooled.buffer();
 222         parser.serializeObject(builder.build(), buf);
 223         assertArrayEquals(result.array(),ByteArray.getAllBytes(buf));
 224     }
 225
 226     @Test
 227     public void testSRPObjectWithPSTTlv() throws PCEPDeserializerException {
 228         final byte[] srpObjectWithPstTlvBytes = { 0x21, 0x10, 0x00, 0x14, 0x0, 0x0, 0x0, 0x01, 0x0, 0x0,
 229             0x0, 0x01,
 230             /* pst-tlv */
 231             0x0, 0x1b, 0x0, 0x4, 0x0, 0x0, 0x0, 0x0 };
 232         final CInitiated00SrpObjectParser parser = new CInitiated00SrpObjectParser(this.tlvRegistry, this.viTlvRegistry);
 233         SrpBuilder builder = new SrpBuilder();
 234         builder.setProcessingRule(false);
 235         builder.setIgnore(false);
 236         builder.setOperationId(new SrpIdNumber(1L));
 237         builder.addAugmentation(Srp1.class, new Srp1Builder().setRemove(true).build());
 238         builder.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.srp.object.srp.TlvsBuilder().setPathSetupType(new PathSetupTypeBuilder().setPst((short) 0).build()).build());
 239
 240         final ByteBuf result = Unpooled.wrappedBuffer(srpObjectWithPstTlvBytes);
 241         assertEquals(builder.build(),
 242                 parser.parseObject(new ObjectHeaderImpl(false, false), result.slice(4, result.readableBytes() - 4)));
 243         final ByteBuf buf = Unpooled.buffer();
 244         parser.serializeObject(builder.build(), buf);
 245         assertArrayEquals(srpObjectWithPstTlvBytes, ByteArray.getAllBytes(buf));
 246     }
 247 }