pcep/pcc-mock/src/main/java/org/opendaylight/protocol/pcep/pcc/mock/MsgBuilderUtil.java

   1 /*
   2  * Copyright (c) 2014 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
   9 package org.opendaylight.protocol.pcep.pcc.mock;
  10
  11 import com.google.common.base.Charsets;
  12 import com.google.common.base.Optional;
  13 import com.google.common.collect.Lists;
  14 import java.net.InetAddress;
  15 import java.util.Arrays;
  16 import java.util.List;
  17 import org.opendaylight.protocol.pcep.spi.PCEPErrors;
  18 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.Ipv4Address;
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.OperationalStatus;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.Pcrpt;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.PcrptBuilder;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.PlspId;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.SrpIdNumber;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.SymbolicPathName;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.lsp.identifiers.tlv.LspIdentifiersBuilder;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.lsp.identifiers.tlv.lsp.identifiers.address.family.Ipv4CaseBuilder;
  27 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;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.lsp.object.Lsp;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.lsp.object.LspBuilder;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.lsp.object.lsp.Tlvs;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.lsp.object.lsp.TlvsBuilder;
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcerr.pcerr.message.error.type.StatefulCaseBuilder;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcerr.pcerr.message.error.type.stateful._case.StatefulBuilder;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcerr.pcerr.message.error.type.stateful._case.stateful.SrpsBuilder;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcrpt.message.PcrptMessageBuilder;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcrpt.message.pcrpt.message.ReportsBuilder;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcrpt.message.pcrpt.message.reports.Path;
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcrpt.message.pcrpt.message.reports.PathBuilder;
  39 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.srp.object.Srp;
  40 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.srp.object.SrpBuilder;
  41 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.symbolic.path.name.tlv.SymbolicPathNameBuilder;
  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.types.rev131005.Message;
  44 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.EroBuilder;
  45 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.ero.Subobject;
  46 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcep.error.object.ErrorObjectBuilder;
  47 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.PcerrMessageBuilder;
  48 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.ErrorsBuilder;
  49 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.Ipv4ExtendedTunnelId;
  50 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.LspId;
  51 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev130820.TunnelId;
  52
  53 public final class MsgBuilderUtil {
  54
  55     private MsgBuilderUtil() {
  56         throw new UnsupportedOperationException();
  57     }
  58
  59     public static Pcrpt createPcRtpMessage(final Lsp lsp, final Optional<Srp> srp, final Path path) {
  60         final PcrptBuilder rptBuilder = new PcrptBuilder();
  61         final PcrptMessageBuilder msgBuilder = new PcrptMessageBuilder();
  62         final ReportsBuilder reportBuilder = new ReportsBuilder();
  63         reportBuilder.setLsp(lsp);
  64         reportBuilder.setSrp(srp.orNull());
  65         reportBuilder.setPath(path);
  66         msgBuilder.setReports(Lists.newArrayList(reportBuilder.build()));
  67         rptBuilder.setPcrptMessage(msgBuilder.build());
  68         return rptBuilder.build();
  69     }
  70
  71     public static Lsp createLsp(final long plspId, final boolean sync, final Optional<Tlvs> tlvs) {
  72         final LspBuilder lspBuilder = new LspBuilder();
  73         lspBuilder.setAdministrative(true);
  74         lspBuilder.setDelegate(true);
  75         lspBuilder.setIgnore(false);
  76         lspBuilder.setOperational(OperationalStatus.Up);
  77         lspBuilder.setPlspId(new PlspId(plspId));
  78         lspBuilder.setProcessingRule(false);
  79         lspBuilder.setRemove(false);
  80         lspBuilder.setSync(sync);
  81         lspBuilder.setTlvs(tlvs.orNull());
  82         return lspBuilder.build();
  83     }
  84
  85     public static Path createPath(final List<Subobject> subobjects) {
  86         final PathBuilder pathBuilder = new PathBuilder();
  87         pathBuilder.setEro(new EroBuilder().setSubobject(subobjects).build());
  88         return pathBuilder.build();
  89     }
  90
  91     public static Srp createSrp(final long srpId) {
  92         final SrpBuilder srpBuilder = new SrpBuilder();
  93         srpBuilder.setProcessingRule(false);
  94         srpBuilder.setIgnore(false);
  95         srpBuilder.setOperationId(new SrpIdNumber(srpId));
  96         return srpBuilder.build();
  97     }
  98
  99     public static Path updToRptPath(
 100             org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcupd.message.pcupd.message.updates.Path path) {
 101         final PathBuilder pathBuilder = new PathBuilder();
 102         pathBuilder.setBandwidth(path.getBandwidth());
 103         pathBuilder.setClassType(path.getClassType());
 104         pathBuilder.setEro(path.getEro());
 105         pathBuilder.setIro(path.getIro());
 106         pathBuilder.setLspa(path.getLspa());
 107         pathBuilder.setMetrics(path.getMetrics());
 108         pathBuilder.setOf(path.getOf());
 109         pathBuilder.setRro(path.getRro());
 110         pathBuilder.setXro(path.getXro());
 111         return pathBuilder.build();
 112     }
 113
 114     public static Tlvs createLspTlvs(final long lspId, final boolean symbolicPathName, InetAddress tunnelEndpoint,
 115             InetAddress tunnelSender, InetAddress extendedTunnelAddress) {
 116         final TlvsBuilder tlvs = new TlvsBuilder().setLspIdentifiers(new LspIdentifiersBuilder()
 117                 .setLspId(new LspId(lspId))
 118                 .setAddressFamily(
 119                         new Ipv4CaseBuilder().setIpv4(
 120                                 new Ipv4Builder()
 121                                         .setIpv4TunnelEndpointAddress(new Ipv4Address(tunnelEndpoint.getHostAddress()))
 122                                         .setIpv4TunnelSenderAddress(new Ipv4Address(tunnelSender.getHostAddress()))
 123                                         .setIpv4ExtendedTunnelId(
 124                                                 new Ipv4ExtendedTunnelId(extendedTunnelAddress.getHostAddress()))
 125                                         .build()).build()).setTunnelId(new TunnelId((int) lspId)).build());
 126         if (symbolicPathName) {
 127             final String pathName = "pcc_" + tunnelSender.getHostAddress() + "_tunnel_" + lspId;
 128             tlvs.setSymbolicPathName(new SymbolicPathNameBuilder().setPathName(
 129                     new SymbolicPathName(pathName.getBytes(Charsets.UTF_8))).build());
 130         }
 131         return tlvs.build();
 132     }
 133
 134     public static Message createErrorMsg(final PCEPErrors e, final long srpId) {
 135         final PcerrMessageBuilder msgBuilder = new PcerrMessageBuilder();
 136         return new PcerrBuilder().setPcerrMessage(
 137                 msgBuilder
 138                         .setErrorType(
 139                                 new StatefulCaseBuilder().setStateful(
 140                                         new StatefulBuilder().setSrps(
 141                                                 Lists.newArrayList(new SrpsBuilder().setSrp(
 142                                                         new SrpBuilder().setProcessingRule(false).setIgnore(false)
 143                                                                 .setOperationId(new SrpIdNumber(srpId)).build())
 144                                                         .build())).build()).build())
 145                         .setErrors(
 146                                 Arrays.asList(new ErrorsBuilder().setErrorObject(
 147                                         new ErrorObjectBuilder().setType(e.getErrorType()).setValue(e.getErrorValue())
 148                                                 .build()).build())).build()).build();
 149     }
 150
 151 }