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.rsvp.rev130820.AttributeFilter;
  64 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.Ipv4ExtendedTunnelId;
  65 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.LspId;
  66 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.TunnelId;
  67
  68 public class PCEPObjectParserTest {
  69
  70     private TlvRegistry tlvRegistry;
  71
  72     private VendorInformationTlvRegistry viTlvRegistry;
  73
  74     @Before
  75     public void setUp() throws Exception {
  76         this.tlvRegistry = ServiceLoaderPCEPExtensionProviderContext.create().getTlvHandlerRegistry();
  77         this.viTlvRegistry = ServiceLoaderPCEPExtensionProviderContext.getSingletonInstance().getVendorInformationTlvRegistry();
  78     }
  79
  80     @Test
  81     public void testOpenObjectWithTLV() throws PCEPDeserializerException, IOException {
  82         final Stateful07OpenObjectParser parser = new Stateful07OpenObjectParser(this.tlvRegistry, this.viTlvRegistry);
  83         final ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCEPOpenObject1.bin"));
  84
  85         final OpenBuilder builder = new OpenBuilder();
  86         builder.setProcessingRule(false);
  87         builder.setIgnore(false);
  88         builder.setVersion(new ProtocolVersion((short) 1));
  89         builder.setKeepalive((short) 30);
  90         builder.setDeadTimer((short) 120);
  91         builder.setSessionId((short) 1);
  92
  93         final Stateful tlv1 = new StatefulBuilder().setLspUpdateCapability(Boolean.TRUE).build();
  94
  95         final Tlvs1Builder statBuilder = new Tlvs1Builder();
  96         statBuilder.setStateful(tlv1);
  97
  98         builder.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.open.TlvsBuilder().addAugmentation(
  99                 Tlvs1.class, statBuilder.build()).build());
 100
 101         assertEquals(builder.build(), parser.parseObject(new ObjectHeaderImpl(false, false), result.slice(4, result.readableBytes() - 4)));
 102         ByteBuf buf = Unpooled.buffer();
 103         parser.serializeObject(builder.build(), buf);
 104         assertArrayEquals(result.array(),ByteArray.getAllBytes(buf));
 105     }
 106
 107     @Test
 108     public void testLspObjectWithTLV() throws IOException, PCEPDeserializerException {
 109         final CInitiated00LspObjectParser parser = new CInitiated00LspObjectParser(this.tlvRegistry, this.viTlvRegistry);
 110         final ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCEPLspObject1WithTLV.bin"));
 111
 112         final LspBuilder builder = new LspBuilder();
 113         builder.setProcessingRule(true);
 114         builder.setIgnore(true);
 115         builder.setAdministrative(true);
 116         builder.setDelegate(false);
 117         builder.setRemove(true);
 118         builder.setSync(false);
 119         builder.addAugmentation(Lsp1.class, new Lsp1Builder().setCreate(false).build());
 120         builder.setOperational(OperationalStatus.GoingDown);
 121         builder.setPlspId(new PlspId(0x12345L));
 122
 123         final LspErrorCode tlv1 = new LspErrorCodeBuilder().setErrorCode(627610883L).build();
 124         final SymbolicPathName tlv2 = new SymbolicPathNameBuilder().setPathName(
 125                 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.SymbolicPathName("Med".getBytes())).build();
 126         builder.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.lsp.object.lsp.TlvsBuilder().setLspErrorCode(
 127                 tlv1).setSymbolicPathName(tlv2).build());
 128         assertEquals(builder.build(), parser.parseObject(new ObjectHeaderImpl(true, true), result.slice(4, result.readableBytes() - 4)));
 129         final ByteBuf buf = Unpooled.buffer();
 130         parser.serializeObject(builder.build(), buf);
 131         assertArrayEquals(result.array(),ByteArray.getAllBytes(buf));
 132     }
 133
 134     @Test
 135     public void testStateful07LspObjectWithTlv() throws IOException, PCEPDeserializerException {
 136         final Stateful07LspObjectParser parser = new Stateful07LspObjectParser(this.tlvRegistry, this.viTlvRegistry);
 137         final ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCEPLspObject2WithTLV.bin"));
 138
 139         final LspBuilder builder = new LspBuilder();
 140         builder.setProcessingRule(true);
 141         builder.setIgnore(true);
 142         builder.setAdministrative(true);
 143         builder.setDelegate(false);
 144         builder.setRemove(true);
 145         builder.setSync(false);
 146         builder.setOperational(OperationalStatus.GoingDown);
 147         builder.setPlspId(new PlspId(0x12345L));
 148
 149         final LspErrorCode tlv1 = new LspErrorCodeBuilder().setErrorCode(627610883L).build();
 150         final SymbolicPathName tlv2 = new SymbolicPathNameBuilder().setPathName(
 151                 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.SymbolicPathName("Med".getBytes())).build();
 152         final Ipv4Builder afi = new Ipv4Builder();
 153         afi.setIpv4TunnelSenderAddress(Ipv4Util.addressForBytes(new byte[] { (byte) 0x12, (byte) 0x34, (byte) 0x56, (byte) 0x78 }));
 154         afi.setIpv4ExtendedTunnelId(new Ipv4ExtendedTunnelId(Ipv4Util.addressForBytes(new byte[] { (byte) 0x12, (byte) 0x34, (byte) 0x56,
 155             (byte) 0x78 })));
 156         afi.setIpv4TunnelEndpointAddress(Ipv4Util.addressForBytes(new byte[] { (byte) 0x12, (byte) 0x34, (byte) 0x56, (byte) 0x78 }));
 157         final LspIdentifiers tlv3 = new LspIdentifiersBuilder().setAddressFamily(new Ipv4CaseBuilder().setIpv4(afi.build()).build()).setLspId(
 158             new LspId(65535L)).setTunnelId(new TunnelId(4660)).build();
 159         final RsvpErrorBuilder rsvpBuilder = new RsvpErrorBuilder();
 160         rsvpBuilder.setNode(new IpAddress(Ipv4Util.addressForBytes(new byte[] { (byte) 0x12, (byte) 0x34, (byte) 0x56, (byte) 0x78 })));
 161         rsvpBuilder.setFlags(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.ErrorSpec.Flags(false, true));
 162         rsvpBuilder.setCode((short) 146);
 163         rsvpBuilder.setValue(5634);
 164         final RsvpErrorSpec tlv4 = new RsvpErrorSpecBuilder().setErrorType(new RsvpCaseBuilder().setRsvpError(rsvpBuilder.build()).build()).build();
 165         builder.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.lsp.object.lsp.TlvsBuilder().setLspErrorCode(
 166                 tlv1).setSymbolicPathName(tlv2).setLspIdentifiers(tlv3).setRsvpErrorSpec(tlv4).build());
 167         assertEquals(builder.build(), parser.parseObject(new ObjectHeaderImpl(true, true), result.slice(4, result.readableBytes() - 4)));
 168         final ByteBuf buf = Unpooled.buffer();
 169         parser.serializeObject(builder.build(), buf);
 170         assertArrayEquals(result.array(),ByteArray.getAllBytes(buf));
 171     }
 172
 173     @Test
 174     public void testLspaObject() throws IOException, PCEPDeserializerException {
 175         final Stateful07LspaObjectParser parser = new Stateful07LspaObjectParser(this.tlvRegistry, this.viTlvRegistry);
 176         final LspaBuilder builder = new LspaBuilder();
 177         final ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCEPLspaObject3RandVals.bin"));
 178
 179         final SymbolicPathName tlv = new SymbolicPathNameBuilder().setPathName(
 180                 new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.SymbolicPathName(new byte[] {
 181                     (byte) 0x4d, (byte) 0x65, (byte) 0x64, (byte) 0x20, (byte) 0x74, (byte) 0x65, (byte) 0x73, (byte) 0x74, (byte) 0x20,
 182                     (byte) 0x6f, (byte) 0x66, (byte) 0x20, (byte) 0x73, (byte) 0x79, (byte) 0x6d, (byte) 0x62, (byte) 0x6f, (byte) 0x6c,
 183                     (byte) 0x69, (byte) 0x63, (byte) 0x20, (byte) 0x6e, (byte) 0x61, (byte) 0x6d, (byte) 0x65 })).build();
 184
 185         builder.setIgnore(false);
 186         builder.setProcessingRule(false);
 187         builder.setExcludeAny(new AttributeFilter(0x20A1FEE3L));
 188         builder.setIncludeAny(new AttributeFilter(0x1A025CC7L));
 189         builder.setIncludeAll(new AttributeFilter(0x2BB66532L));
 190         builder.setHoldPriority((short) 0x02);
 191         builder.setSetupPriority((short) 0x03);
 192         builder.setLocalProtectionDesired(true);
 193         builder.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lspa.object.lspa.TlvsBuilder().addAugmentation(
 194                 Tlvs2.class, new Tlvs2Builder().setSymbolicPathName(tlv).build()).build());
 195
 196         // Tlvs container does not contain toString
 197         final Object o = parser.parseObject(new ObjectHeaderImpl(true, true), result.slice(4, result.readableBytes() - 4));
 198         assertEquals(tlv, ((Lspa) o).getTlvs().getAugmentation(Tlvs2.class).getSymbolicPathName());
 199         // assertEquals(builder.build(), parser.parseObject(new ObjectHeaderImpl(true, true), ByteArray.cutBytes(result,
 200         // 4)));
 201         ByteBuf buf = Unpooled.buffer();
 202         parser.serializeObject(builder.build(), buf);
 203         assertArrayEquals(result.array(),ByteArray.getAllBytes(buf));
 204     }
 205
 206     @Test
 207     public void testSrpObject() throws IOException, PCEPDeserializerException {
 208         final CInitiated00SrpObjectParser parser = new CInitiated00SrpObjectParser(this.tlvRegistry, this.viTlvRegistry);
 209         final ByteBuf result = Unpooled.wrappedBuffer(new byte[] { (byte) 0x21, (byte) 0x10, (byte) 0x00, (byte) 0x0c, 0, 0, 0,
 210             (byte) 0x01, 0, 0, 0, (byte) 0x01 });
 211
 212         final SrpBuilder builder = new SrpBuilder();
 213         builder.setProcessingRule(false);
 214         builder.setIgnore(false);
 215         builder.setOperationId(new SrpIdNumber(1L));
 216         builder.addAugmentation(Srp1.class, new Srp1Builder().setRemove(true).build());
 217         builder.setTlvs(new TlvsBuilder().build());
 218
 219         assertEquals(builder.build(), parser.parseObject(new ObjectHeaderImpl(false, false), result.slice(4, result.readableBytes() - 4)));
 220         ByteBuf buf = Unpooled.buffer();
 221         parser.serializeObject(builder.build(), buf);
 222         assertArrayEquals(result.array(),ByteArray.getAllBytes(buf));
 223     }
 224 }