pcep/impl/src/test/java/org/opendaylight/protocol/pcep/impl/PCEPValidatorTest.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.impl;
   9
  10 import static org.junit.Assert.assertArrayEquals;
  11 import static org.junit.Assert.assertEquals;
  12 import static org.junit.Assert.fail;
  13
  14 import com.google.common.collect.Lists;
  15 import io.netty.buffer.ByteBuf;
  16 import io.netty.buffer.Unpooled;
  17 import java.io.IOException;
  18 import java.util.ArrayList;
  19 import java.util.Collections;
  20 import java.util.List;
  21 import org.junit.Before;
  22 import org.junit.Test;
  23 import org.opendaylight.protocol.pcep.impl.TestVendorInformationTlvParser.TestEnterpriseSpecificInformation;
  24 import org.opendaylight.protocol.pcep.impl.message.PCEPCloseMessageParser;
  25 import org.opendaylight.protocol.pcep.impl.message.PCEPErrorMessageParser;
  26 import org.opendaylight.protocol.pcep.impl.message.PCEPKeepAliveMessageParser;
  27 import org.opendaylight.protocol.pcep.impl.message.PCEPNotificationMessageParser;
  28 import org.opendaylight.protocol.pcep.impl.message.PCEPOpenMessageParser;
  29 import org.opendaylight.protocol.pcep.impl.message.PCEPReplyMessageParser;
  30 import org.opendaylight.protocol.pcep.impl.message.PCEPRequestMessageParser;
  31 import org.opendaylight.protocol.pcep.spi.ObjectRegistry;
  32 import org.opendaylight.protocol.pcep.spi.PCEPDeserializerException;
  33 import org.opendaylight.protocol.pcep.spi.VendorInformationObjectRegistry;
  34 import org.opendaylight.protocol.pcep.spi.pojo.SimplePCEPExtensionProviderContext;
  35 import org.opendaylight.protocol.util.ByteArray;
  36 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.Ipv4Address;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.iana.rev130816.EnterpriseNumber;
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ieee754.rev130819.Float32;
  39 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.CloseBuilder;
  40 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.KeepaliveBuilder;
  41 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.OpenBuilder;
  42 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcerrBuilder;
  43 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcntfBuilder;
  44 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcrepBuilder;
  45 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcreqBuilder;
  46 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.Message;
  47 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.OfId;
  48 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.ProtocolVersion;
  49 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.RequestId;
  50 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.close.message.CCloseMessageBuilder;
  51 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.close.object.CCloseBuilder;
  52 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.close.object.c.close.TlvsBuilder;
  53 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.endpoints.address.family.Ipv4CaseBuilder;
  54 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.endpoints.address.family.ipv4._case.Ipv4Builder;
  55 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.endpoints.object.EndpointsObj;
  56 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.endpoints.object.EndpointsObjBuilder;
  57 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.Ero;
  58 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.EroBuilder;
  59 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.include.route.object.Iro;
  60 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.include.route.object.IroBuilder;
  61 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.include.route.object.iro.Subobject;
  62 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.include.route.object.iro.SubobjectBuilder;
  63 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.keepalive.message.KeepaliveMessageBuilder;
  64 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lsp.attributes.Metrics;
  65 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lsp.attributes.MetricsBuilder;
  66 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lspa.object.Lspa;
  67 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lspa.object.LspaBuilder;
  68 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.metric.object.MetricBuilder;
  69 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.notification.object.CNotification;
  70 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.notification.object.CNotificationBuilder;
  71 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.of.object.Of;
  72 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.of.object.OfBuilder;
  73 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.message.OpenMessageBuilder;
  74 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.Open;
  75 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcep.error.object.ErrorObject;
  76 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcep.error.object.ErrorObjectBuilder;
  77 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.PcerrMessageBuilder;
  78 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.Errors;
  79 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.ErrorsBuilder;
  80 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.RequestCaseBuilder;
  81 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.SessionCaseBuilder;
  82 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.request._case.RequestBuilder;
  83 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.session._case.SessionBuilder;
  84 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.PcntfMessageBuilder;
  85 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.Notifications;
  86 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.NotificationsBuilder;
  87 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.Rps;
  88 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.RpsBuilder;
  89 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.PcrepMessageBuilder;
  90 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.Replies;
  91 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.RepliesBuilder;
  92 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.FailureCaseBuilder;
  93 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.SuccessCaseBuilder;
  94 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.failure._case.NoPath;
  95 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.failure._case.NoPathBuilder;
  96 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.success._case.SuccessBuilder;
  97 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.success._case.success.Paths;
  98 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.success._case.success.PathsBuilder;
  99 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.PcreqMessageBuilder;
 100 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.Requests;
 101 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.requests.SegmentComputationBuilder;
 102 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.requests.segment.computation.P2pBuilder;
 103 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.rp.object.Rp;
 104 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.rp.object.RpBuilder;
 105 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.svec.object.Svec;
 106 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.svec.object.SvecBuilder;
 107 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.vendor.information.objects.VendorInformationObject;
 108 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.vendor.information.objects.VendorInformationObjectBuilder;
 109 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.AttributeFilter;
 110 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.basic.explicit.route.subobjects.subobject.type.AsNumberCase;
 111 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.basic.explicit.route.subobjects.subobject.type.AsNumberCaseBuilder;
 112 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.basic.explicit.route.subobjects.subobject.type.as.number._case.AsNumberBuilder;
 113
 114 public class PCEPValidatorTest {
 115
 116     private ObjectRegistry objectRegistry;
 117     private VendorInformationObjectRegistry viObjRegistry;
 118
 119     private Open open;
 120     private Rp rpTrue;
 121     private Rp rpFalse;
 122     private NoPath noPath;
 123     private Lspa lspa;
 124     private Metrics metrics;
 125     private Iro iro;
 126     private Ero ero;
 127     private Of of;
 128     private EndpointsObj endpoints;
 129     private Svec svec;
 130     private List<VendorInformationObject> viObjects;
 131
 132     private AsNumberCase eroASSubobject;
 133
 134     private SimplePCEPExtensionProviderContext ctx;
 135     private Activator act;
 136     private TestVendorInformationActivator viObjAct;
 137
 138     @Before
 139     public void setUp() throws Exception {
 140         this.ctx = new SimplePCEPExtensionProviderContext();
 141         this.act = new Activator();
 142         this.viObjAct = new TestVendorInformationActivator();
 143         this.act.start(this.ctx);
 144         this.viObjAct.start(this.ctx);
 145         this.objectRegistry = this.ctx.getObjectHandlerRegistry();
 146         this.viObjRegistry = this.ctx.getVendorInformationObjectRegistry();
 147         final RpBuilder rpBuilder = new RpBuilder();
 148         rpBuilder.setProcessingRule(true);
 149         rpBuilder.setIgnore(false);
 150         rpBuilder.setReoptimization(false);
 151         rpBuilder.setBiDirectional(false);
 152         rpBuilder.setLoose(true);
 153         rpBuilder.setMakeBeforeBreak(false);
 154         rpBuilder.setOrder(false);
 155         rpBuilder.setPathKey(false);
 156         rpBuilder.setSupplyOf(false);
 157         rpBuilder.setFragmentation(false);
 158         rpBuilder.setP2mp(false);
 159         rpBuilder.setEroCompression(false);
 160         rpBuilder.setPriority((short) 1);
 161         rpBuilder.setRequestId(new RequestId(10L));
 162         rpBuilder.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.rp.object.rp.TlvsBuilder().build());
 163         this.rpTrue = rpBuilder.build();
 164         rpBuilder.setProcessingRule(false);
 165         this.rpFalse = rpBuilder.build();
 166
 167         final org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.OpenBuilder openBuilder = new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.OpenBuilder();
 168         openBuilder.setProcessingRule(false);
 169         openBuilder.setIgnore(false);
 170         openBuilder.setDeadTimer((short) 1);
 171         openBuilder.setKeepalive((short) 1);
 172         openBuilder.setSessionId((short) 0);
 173         openBuilder.setVersion(new ProtocolVersion((short) 1));
 174         openBuilder.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.open.TlvsBuilder().build());
 175         this.open = openBuilder.build();
 176
 177         final NoPathBuilder npbuilder = new NoPathBuilder();
 178         npbuilder.setProcessingRule(false);
 179         npbuilder.setIgnore(false);
 180         npbuilder.setNatureOfIssue((short) 0);
 181         npbuilder.setUnsatisfiedConstraints(false);
 182         npbuilder.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcrep.message.pcrep.message.replies.result.failure._case.no.path.TlvsBuilder().build());
 183         this.noPath = npbuilder.build();
 184
 185         final LspaBuilder lspaBuilder = new LspaBuilder();
 186         lspaBuilder.setProcessingRule(false);
 187         lspaBuilder.setIgnore(false);
 188         lspaBuilder.setLocalProtectionDesired(false);
 189         lspaBuilder.setHoldPriority((short) 0);
 190         lspaBuilder.setSetupPriority((short) 0);
 191         lspaBuilder.setExcludeAny(new AttributeFilter(0L));
 192         lspaBuilder.setIncludeAll(new AttributeFilter(0L));
 193         lspaBuilder.setIncludeAny(new AttributeFilter(0L));
 194         lspaBuilder.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.lspa.object.lspa.TlvsBuilder().build());
 195         this.lspa = lspaBuilder.build();
 196
 197         final MetricBuilder mBuilder = new MetricBuilder();
 198         mBuilder.setIgnore(false);
 199         mBuilder.setProcessingRule(false);
 200         mBuilder.setComputed(false);
 201         mBuilder.setBound(false);
 202         mBuilder.setMetricType((short) 1);
 203         mBuilder.setValue(new Float32(new byte[4]));
 204         this.metrics = new MetricsBuilder().setMetric(mBuilder.build()).build();
 205
 206         this.eroASSubobject = new AsNumberCaseBuilder().setAsNumber(
 207             new AsNumberBuilder().setAsNumber(
 208                 new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.AsNumber(0xFFFFL)).build()).build();
 209
 210         final IroBuilder iroBuilder = new IroBuilder();
 211         iroBuilder.setIgnore(false);
 212         iroBuilder.setProcessingRule(false);
 213         final List<Subobject> iroSubs = Lists.newArrayList();
 214         iroSubs.add(new SubobjectBuilder().setSubobjectType(this.eroASSubobject).build());
 215         iroBuilder.setSubobject(iroSubs);
 216         this.iro = iroBuilder.build();
 217
 218         final EroBuilder eroBuilder = new EroBuilder();
 219         eroBuilder.setIgnore(false);
 220         eroBuilder.setProcessingRule(false);
 221         final List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.ero.Subobject> eroSubs = Lists.newArrayList();
 222         eroSubs.add(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.ero.SubobjectBuilder().setSubobjectType(
 223             this.eroASSubobject).setLoose(false).build());
 224         eroBuilder.setSubobject(eroSubs);
 225         this.ero = eroBuilder.build();
 226
 227         final OfBuilder ofBuilder = new OfBuilder();
 228         ofBuilder.setIgnore(false);
 229         ofBuilder.setProcessingRule(false);
 230         ofBuilder.setCode(new OfId(0));
 231         ofBuilder.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.of.object.of.TlvsBuilder().build());
 232         this.of = ofBuilder.build();
 233
 234         final Ipv4Builder afi = new Ipv4Builder();
 235         afi.setSourceIpv4Address(new Ipv4Address("255.255.255.255"));
 236         afi.setDestinationIpv4Address(new Ipv4Address("255.255.255.255"));
 237
 238         final EndpointsObjBuilder epBuilder = new EndpointsObjBuilder();
 239         epBuilder.setIgnore(false);
 240         epBuilder.setProcessingRule(true);
 241         epBuilder.setAddressFamily(new Ipv4CaseBuilder().setIpv4(afi.build()).build());
 242         this.endpoints = epBuilder.build();
 243
 244         final SvecBuilder sBuilder = new SvecBuilder();
 245         sBuilder.setIgnore(false);
 246         sBuilder.setProcessingRule(false);
 247         sBuilder.setLinkDiverse(false);
 248         sBuilder.setNodeDiverse(false);
 249         sBuilder.setSrlgDiverse(false);
 250         sBuilder.setRequestsIds(Lists.newArrayList(new RequestId(1L)));
 251         this.svec = sBuilder.build();
 252
 253         this.viObjects = Lists.newArrayList();
 254         final TestEnterpriseSpecificInformation esInfo = new TestEnterpriseSpecificInformation(5);
 255         final VendorInformationObject viObj = new VendorInformationObjectBuilder().setEnterpriseNumber(new EnterpriseNumber(0L))
 256                 .setEnterpriseSpecificInformation(esInfo).build();
 257         this.viObjects.add(viObj);
 258     }
 259
 260     @Test
 261     public void testOpenMsg() throws IOException, PCEPDeserializerException {
 262         final ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCEPOpenMessage1.bin"));
 263         final PCEPOpenMessageParser parser = new PCEPOpenMessageParser(this.ctx.getObjectHandlerRegistry());
 264         final OpenMessageBuilder builder = new OpenMessageBuilder();
 265
 266         final org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.OpenBuilder b = new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.OpenBuilder();
 267         b.setProcessingRule(false);
 268         b.setIgnore(false);
 269         b.setVersion(new ProtocolVersion((short) 1));
 270         b.setKeepalive((short) 30);
 271         b.setDeadTimer((short) 120);
 272         b.setSessionId((short) 1);
 273         b.setTlvs(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.open.object.open.TlvsBuilder().build());
 274         builder.setOpen(b.build());
 275
 276         assertEquals(new OpenBuilder().setOpenMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 277             result.readableBytes() - 4), Collections.<Message> emptyList()));
 278         final ByteBuf buf = Unpooled.buffer(result.readableBytes());
 279         parser.serializeMessage(new OpenBuilder().setOpenMessage(builder.build()).build(), buf);
 280         assertArrayEquals(result.array(), buf.array());
 281
 282         try {
 283             parser.serializeMessage(new OpenBuilder().setOpenMessage(new OpenMessageBuilder().build()).build(), null);
 284             fail();
 285         } catch (final IllegalArgumentException e) {
 286             assertEquals("Open Object must be present in Open Message.", e.getMessage());
 287         }
 288     }
 289
 290     @Test
 291     public void testKeepAliveMsg() throws IOException, PCEPDeserializerException {
 292         final ByteBuf result = Unpooled.wrappedBuffer(new byte[] { 32, 2, 0, 4 });
 293         final PCEPKeepAliveMessageParser parser = new PCEPKeepAliveMessageParser(this.objectRegistry);
 294         final KeepaliveBuilder builder = new KeepaliveBuilder().setKeepaliveMessage(new KeepaliveMessageBuilder().build());
 295
 296         assertEquals(builder.build(), parser.parseMessage(result.slice(4, result.readableBytes() - 4), Collections.<Message> emptyList()));
 297         final ByteBuf buf = Unpooled.buffer(result.readableBytes());
 298         parser.serializeMessage(builder.build(), buf);
 299         assertArrayEquals(result.array(), buf.array());
 300     }
 301
 302     @Test
 303     public void testCloseMsg() throws IOException, PCEPDeserializerException {
 304         final ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCEPCloseMessage1.bin"));
 305
 306         final PCEPCloseMessageParser parser = new PCEPCloseMessageParser(this.objectRegistry);
 307         final CloseBuilder builder = new CloseBuilder().setCCloseMessage(new CCloseMessageBuilder().setCClose(
 308             new CCloseBuilder().setIgnore(false).setProcessingRule(false).setReason((short) 5).setTlvs(new TlvsBuilder().build()).build()).build());
 309
 310         assertEquals(builder.build(), parser.parseMessage(result.slice(4, result.readableBytes() - 4), Collections.<Message> emptyList()));
 311         final ByteBuf buf = Unpooled.buffer(result.readableBytes());
 312         parser.serializeMessage(builder.build(), buf);
 313         assertArrayEquals(result.array(), buf.array());
 314
 315         try {
 316             parser.serializeMessage(new CloseBuilder().setCCloseMessage(new CCloseMessageBuilder().build()).build(), null);
 317             fail();
 318         } catch (final IllegalArgumentException e) {
 319             assertEquals("Close Object must be present in Close Message.", e.getMessage());
 320         }
 321     }
 322
 323     @Test
 324     public void testRequestMsg() throws IOException, PCEPDeserializerException {
 325         ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCEPRequestMessage1.bin"));
 326
 327         final PCEPRequestMessageParser parser = new PCEPRequestMessageParser(this.objectRegistry, this.viObjRegistry);
 328
 329         final PcreqMessageBuilder builder = new PcreqMessageBuilder();
 330         final List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.Requests> reqs1 = Lists.newArrayList();
 331         final org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.RequestsBuilder rBuilder = new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.RequestsBuilder();
 332         rBuilder.setRp(this.rpTrue);
 333         rBuilder.setSegmentComputation(new SegmentComputationBuilder().setP2p(new P2pBuilder().setEndpointsObj(this.endpoints).build()).build());
 334         reqs1.add(rBuilder.build());
 335         builder.setRequests(reqs1);
 336
 337         assertEquals(new PcreqBuilder().setPcreqMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 338             result.readableBytes() - 4), Collections.<Message> emptyList()));
 339         ByteBuf buf = Unpooled.buffer(result.readableBytes());
 340         parser.serializeMessage(new PcreqBuilder().setPcreqMessage(builder.build()).build(), buf);
 341
 342         assertArrayEquals(result.array(), buf.array());
 343
 344         result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCReq.3.bin"));
 345
 346         final List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.Requests> reqs2 = Lists.newArrayList();
 347         final org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.RequestsBuilder rBuilder1 = new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.RequestsBuilder();
 348         rBuilder1.setRp(this.rpTrue);
 349         final P2pBuilder p2pBuilder = new P2pBuilder();
 350         p2pBuilder.setEndpointsObj(this.endpoints);
 351         p2pBuilder.setMetrics(Lists.newArrayList(this.metrics));
 352         p2pBuilder.setIro(this.iro);
 353         rBuilder1.setSegmentComputation(new SegmentComputationBuilder().setP2p(p2pBuilder.build()).build());
 354         reqs2.add(rBuilder1.build());
 355         builder.setRequests(reqs2);
 356         builder.setSvec(Lists.newArrayList(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.SvecBuilder().setSvec(
 357             this.svec).build()));
 358
 359         assertEquals(new PcreqBuilder().setPcreqMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 360             result.readableBytes() - 4), Collections.<Message> emptyList()));
 361         buf = Unpooled.buffer(result.readableBytes());
 362         parser.serializeMessage(new PcreqBuilder().setPcreqMessage(builder.build()).build(), buf);
 363         assertArrayEquals(result.array(), buf.array());
 364
 365         try {
 366             parser.serializeMessage(new PcreqBuilder().setPcreqMessage(new PcreqMessageBuilder().build()).build(), null);
 367             fail();
 368         } catch (final IllegalArgumentException e) {
 369             assertEquals("Requests cannot be null or empty.", e.getMessage());
 370         }
 371         try {
 372             parser.serializeMessage(new PcreqBuilder().setPcreqMessage(new PcreqMessageBuilder().setRequests(Collections.<Requests> emptyList()).build()).build(), null);
 373             fail();
 374         } catch (final IllegalArgumentException e) {
 375             assertEquals("Requests cannot be null or empty.", e.getMessage());
 376         }
 377     }
 378
 379     @Test
 380     public void testReplyMsg() throws IOException, PCEPDeserializerException {
 381         // only RP
 382         ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCRep.1.bin"));
 383
 384         final PCEPReplyMessageParser parser = new PCEPReplyMessageParser(this.objectRegistry, this.viObjRegistry);
 385
 386         final PcrepMessageBuilder builder = new PcrepMessageBuilder();
 387         RepliesBuilder rBuilder = new RepliesBuilder();
 388
 389         final List<Replies> replies1 = Lists.newArrayList();
 390         rBuilder.setRp(this.rpTrue);
 391         replies1.add(rBuilder.build());
 392         builder.setReplies(replies1);
 393
 394         assertEquals(new PcrepBuilder().setPcrepMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 395             result.readableBytes() - 4), Collections.<Message> emptyList()));
 396         ByteBuf buf = Unpooled.buffer(result.readableBytes());
 397         parser.serializeMessage(new PcrepBuilder().setPcrepMessage(builder.build()).build(), buf);
 398         assertArrayEquals(result.array(), buf.array());
 399
 400         // simple Failure
 401         result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCRep.2.bin"));
 402         final List<Replies> replies2 = Lists.newArrayList();
 403         rBuilder = new RepliesBuilder();
 404         rBuilder.setRp(this.rpTrue);
 405         replies2.add(rBuilder.build());
 406         final RepliesBuilder rBuilder2 = new RepliesBuilder();
 407         rBuilder2.setRp(this.rpTrue);
 408         rBuilder2.setResult(new FailureCaseBuilder().setNoPath(this.noPath).build());
 409         replies2.add(rBuilder2.build());
 410         builder.setReplies(replies2);
 411
 412         assertEquals(new PcrepBuilder().setPcrepMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 413             result.readableBytes() - 4), Collections.<Message> emptyList()));
 414         buf = Unpooled.buffer(result.readableBytes());
 415         parser.serializeMessage(new PcrepBuilder().setPcrepMessage(builder.build()).build(), buf);
 416         assertArrayEquals(result.array(), buf.array());
 417
 418         // Failure with attributes
 419         result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCRep.3.bin"));
 420         final List<Replies> replies3 = Lists.newArrayList();
 421         rBuilder = new RepliesBuilder();
 422         rBuilder.setRp(this.rpTrue);
 423         rBuilder.setResult(new FailureCaseBuilder().setNoPath(this.noPath).setLspa(this.lspa).setMetrics(Lists.newArrayList(this.metrics)).setIro(
 424             this.iro).build());
 425         replies3.add(rBuilder.build());
 426         builder.setReplies(replies3);
 427
 428         assertEquals(new PcrepBuilder().setPcrepMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 429             result.readableBytes() - 4), Collections.<Message> emptyList()));
 430         buf = Unpooled.buffer(result.readableBytes());
 431         parser.serializeMessage(new PcrepBuilder().setPcrepMessage(builder.build()).build(), buf);
 432         assertArrayEquals(result.array(), buf.array());
 433
 434         // Success
 435         result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCRep.5.bin"));
 436         final List<Replies> replies4 = Lists.newArrayList();
 437         rBuilder = new RepliesBuilder();
 438         rBuilder.setRp(this.rpTrue);
 439         final List<Paths> paths = Lists.newArrayList();
 440         final PathsBuilder paBuilder = new PathsBuilder();
 441         paBuilder.setEro(this.ero);
 442         paBuilder.setLspa(this.lspa);
 443         paBuilder.setMetrics(Lists.newArrayList(this.metrics));
 444         paBuilder.setIro(this.iro);
 445         paBuilder.setOf(this.of);
 446         paths.add(paBuilder.build());
 447         rBuilder.setResult(new SuccessCaseBuilder().setSuccess(new SuccessBuilder().setPaths(paths).build()).build()).build();
 448         replies4.add(rBuilder.build());
 449         builder.setReplies(replies4);
 450
 451         assertEquals(new PcrepBuilder().setPcrepMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 452             result.readableBytes() - 4), Collections.<Message> emptyList()));
 453         buf = Unpooled.buffer(result.readableBytes());
 454         parser.serializeMessage(new PcrepBuilder().setPcrepMessage(builder.build()).build(), buf);
 455         assertArrayEquals(result.array(), buf.array());
 456
 457         try {
 458             parser.serializeMessage(new PcrepBuilder().setPcrepMessage(new PcrepMessageBuilder().build()).build(), null);
 459             fail();
 460         } catch (final IllegalArgumentException e) {
 461             assertEquals("Replies cannot be null or empty.", e.getMessage());
 462         }
 463         try {
 464             parser.serializeMessage(new PcrepBuilder().setPcrepMessage(new PcrepMessageBuilder().setReplies(Collections.<Replies> emptyList()).build()).build(), null);
 465             fail();
 466         } catch (final IllegalArgumentException e) {
 467             assertEquals("Replies cannot be null or empty.", e.getMessage());
 468         }
 469     }
 470
 471     @Test
 472     public void testNotificationMsg() throws IOException, PCEPDeserializerException {
 473         final CNotification cn1 = new CNotificationBuilder().setIgnore(false).setProcessingRule(false).setType((short) 1).setValue(
 474             (short) 1).build();
 475
 476         final List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.Notifications> innerNot = Lists.newArrayList();
 477         innerNot.add(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.NotificationsBuilder().setCNotification(
 478             cn1).build());
 479         final List<Rps> rps = Lists.newArrayList();
 480         rps.add(new RpsBuilder().setRp(this.rpFalse).build());
 481
 482         final ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCNtf.5.bin"));
 483
 484         final PCEPNotificationMessageParser parser = new PCEPNotificationMessageParser(this.objectRegistry);
 485         final PcntfMessageBuilder builder = new PcntfMessageBuilder();
 486
 487         final List<Notifications> nots = Lists.newArrayList();
 488         final NotificationsBuilder b = new NotificationsBuilder();
 489         b.setNotifications(innerNot);
 490         b.setRps(rps);
 491         nots.add(b.build());
 492
 493         final List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.Notifications> innerNot1 = Lists.newArrayList();
 494         innerNot1.add(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.NotificationsBuilder().setCNotification(
 495             cn1).build());
 496         innerNot1.add(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcntf.message.pcntf.message.notifications.NotificationsBuilder().setCNotification(
 497             cn1).build());
 498         final List<Rps> rps1 = Lists.newArrayList();
 499         rps1.add(new RpsBuilder().setRp(this.rpFalse).build());
 500         rps1.add(new RpsBuilder().setRp(this.rpFalse).build());
 501
 502         b.setNotifications(innerNot1);
 503         b.setRps(rps1);
 504         nots.add(b.build());
 505         builder.setNotifications(nots);
 506
 507         assertEquals(new PcntfBuilder().setPcntfMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 508             result.readableBytes() - 4), Collections.<Message> emptyList()));
 509         final ByteBuf buf = Unpooled.buffer(result.readableBytes());
 510         parser.serializeMessage(new PcntfBuilder().setPcntfMessage(builder.build()).build(), buf);
 511         assertArrayEquals(result.array(), buf.array());
 512     }
 513
 514     @Test
 515     public void testErrorMsg() throws IOException, PCEPDeserializerException {
 516         ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCErr.5.bin"));
 517
 518         ErrorObject error1 = new ErrorObjectBuilder().setIgnore(false).setProcessingRule(false).setType((short) 3).setValue((short) 1).build();
 519
 520         final PCEPErrorMessageParser parser = new PCEPErrorMessageParser(this.ctx.getObjectHandlerRegistry());
 521
 522         List<Errors> innerErr = new ArrayList<>();
 523
 524         final PcerrMessageBuilder builder = new PcerrMessageBuilder();
 525
 526         final List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.request._case.request.Rps> rps = Lists.newArrayList();
 527         rps.add(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.error.type.request._case.request.RpsBuilder().setRp(
 528             this.rpFalse).build());
 529
 530         innerErr.add(new ErrorsBuilder().setErrorObject(error1).build());
 531
 532         builder.setErrors(innerErr);
 533         builder.setErrorType(new RequestCaseBuilder().setRequest(new RequestBuilder().setRps(rps).build()).build());
 534
 535         assertEquals(new PcerrBuilder().setPcerrMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 536             result.readableBytes() - 4), Collections.<Message> emptyList()));
 537         ByteBuf buf = Unpooled.buffer(result.readableBytes());
 538         parser.serializeMessage(new PcerrBuilder().setPcerrMessage(builder.build()).build(), buf);
 539         assertArrayEquals(result.array(), buf.array());
 540
 541         result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCErr.3.bin"));
 542
 543         error1 = new ErrorObjectBuilder().setIgnore(false).setProcessingRule(false).setType((short) 3).setValue((short) 1).build();
 544
 545         innerErr = new ArrayList<>();
 546         innerErr.add(new ErrorsBuilder().setErrorObject(error1).build());
 547
 548         builder.setErrors(innerErr);
 549         builder.setErrorType(new SessionCaseBuilder().setSession(new SessionBuilder().setOpen(this.open).build()).build());
 550
 551         assertEquals(new PcerrBuilder().setPcerrMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 552             result.readableBytes() - 4), Collections.<Message> emptyList()));
 553         buf = Unpooled.buffer(result.readableBytes());
 554         parser.serializeMessage(new PcerrBuilder().setPcerrMessage(builder.build()).build(), buf);
 555         assertArrayEquals(result.array(), buf.array());
 556
 557         try {
 558             parser.serializeMessage(new PcerrBuilder().setPcerrMessage(new PcerrMessageBuilder().build()).build(), null);
 559             fail();
 560         } catch (final IllegalArgumentException e) {
 561             assertEquals("Errors should not be empty.", e.getMessage());
 562         }
 563         try {
 564             parser.serializeMessage(new PcerrBuilder().setPcerrMessage(new PcerrMessageBuilder().setErrors(Collections.<Errors> emptyList()).build()).build(), null);
 565             fail();
 566         } catch (final IllegalArgumentException e) {
 567             assertEquals("Errors should not be empty.", e.getMessage());
 568         }
 569     }
 570
 571     @Test
 572     public void testReqMsgWithVendorInfoObjects() throws IOException, PCEPDeserializerException {
 573         final ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCReq.7.bin"));
 574         final PCEPRequestMessageParser parser = new PCEPRequestMessageParser(this.objectRegistry, this.viObjRegistry);
 575
 576         final PcreqMessageBuilder builder = new PcreqMessageBuilder();
 577         final List<org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.Requests> reqs1 = Lists.newArrayList();
 578         final org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.RequestsBuilder rBuilder = new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.RequestsBuilder();
 579         rBuilder.setRp(this.rpTrue);
 580         rBuilder.setVendorInformationObject(this.viObjects);
 581         final SegmentComputationBuilder sBuilder = new SegmentComputationBuilder();
 582         sBuilder.setP2p(new P2pBuilder().setEndpointsObj(this.endpoints).setVendorInformationObject(this.viObjects).build());
 583         rBuilder.setSegmentComputation(sBuilder.build());
 584         reqs1.add(rBuilder.build());
 585         builder.setSvec(Lists.newArrayList(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcreq.message.pcreq.message.SvecBuilder().setSvec(
 586                 this.svec).setVendorInformationObject(this.viObjects).build()));
 587         builder.setRequests(reqs1);
 588
 589         assertEquals(new PcreqBuilder().setPcreqMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 590             result.readableBytes() - 4), Collections.<Message> emptyList()));
 591         final ByteBuf buf = Unpooled.buffer(result.readableBytes());
 592         parser.serializeMessage(new PcreqBuilder().setPcreqMessage(builder.build()).build(), buf);
 593
 594         assertArrayEquals(result.array(), buf.array());
 595     }
 596
 597     @Test
 598     public void testRepMsgWithVendorInforObjects() throws IOException, PCEPDeserializerException {
 599         final PCEPReplyMessageParser parser = new PCEPReplyMessageParser(this.objectRegistry, this.viObjRegistry);
 600
 601         final PcrepMessageBuilder builder = new PcrepMessageBuilder();
 602         RepliesBuilder rBuilder = new RepliesBuilder();
 603         final ByteBuf result = Unpooled.wrappedBuffer(ByteArray.fileToBytes("src/test/resources/PCRep.6.bin"));
 604         final List<Replies> replies = Lists.newArrayList();
 605         rBuilder = new RepliesBuilder();
 606         rBuilder.setRp(this.rpTrue);
 607         rBuilder.setVendorInformationObject(this.viObjects);
 608         final List<Paths> paths = Lists.newArrayList();
 609         final PathsBuilder paBuilder = new PathsBuilder();
 610         paBuilder.setEro(this.ero);
 611         paths.add(paBuilder.build());
 612         rBuilder.setResult(new SuccessCaseBuilder().setSuccess(new SuccessBuilder().setPaths(paths).setVendorInformationObject(this.viObjects).build()).build()).build();
 613         replies.add(rBuilder.build());
 614         builder.setReplies(replies);
 615
 616         assertEquals(new PcrepBuilder().setPcrepMessage(builder.build()).build(), parser.parseMessage(result.slice(4,
 617             result.readableBytes() - 4), Collections.<Message> emptyList()));
 618         final ByteBuf buf = Unpooled.buffer(result.readableBytes());
 619         parser.serializeMessage(new PcrepBuilder().setPcrepMessage(builder.build()).build(), buf);
 620         assertArrayEquals(result.array(), buf.array());
 621     }
 622 }