pcep/pcc-mock/src/main/java/org/opendaylight/protocol/pcep/pcc/mock/spi/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.spi;
  10
  11 import com.google.common.base.Optional;
  12 import com.google.common.collect.Lists;
  13 import java.math.BigInteger;
  14 import java.nio.charset.StandardCharsets;
  15 import java.util.Collections;
  16 import java.util.List;
  17 import javax.annotation.Nonnull;
  18 import org.opendaylight.protocol.pcep.spi.PCEPErrors;
  19 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Address;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep.sync.optimizations.rev150714.Tlvs1;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep.sync.optimizations.rev150714.Tlvs1Builder;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.pcep.sync.optimizations.rev150714.lsp.db.version.tlv.LspDbVersionBuilder;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.crabbe.initiated.rev131126.pcinitiate.message.pcinitiate.message.Requests;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.OperationalStatus;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.Pcrpt;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.PcrptBuilder;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.PlspId;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.SrpIdNumber;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.SymbolicPathName;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.lsp.identifiers.tlv.LspIdentifiersBuilder;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.lsp.identifiers.tlv.lsp.identifiers.address.family.Ipv4CaseBuilder;
  32 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;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.lsp.object.Lsp;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.lsp.object.LspBuilder;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.lsp.object.lsp.Tlvs;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.lsp.object.lsp.TlvsBuilder;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcerr.pcerr.message.error.type.StatefulCaseBuilder;
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcerr.pcerr.message.error.type.stateful._case.StatefulBuilder;
  39 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;
  40 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcrpt.message.PcrptMessageBuilder;
  41 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcrpt.message.pcrpt.message.ReportsBuilder;
  42 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcrpt.message.pcrpt.message.reports.Path;
  43 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcrpt.message.pcrpt.message.reports.PathBuilder;
  44 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.srp.object.Srp;
  45 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.srp.object.SrpBuilder;
  46 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.symbolic.path.name.tlv.SymbolicPathNameBuilder;
  47 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.Pcerr;
  48 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.message.rev131007.PcerrBuilder;
  49 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.EroBuilder;
  50 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.explicit.route.object.ero.Subobject;
  51 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcep.error.object.ErrorObjectBuilder;
  52 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.PcerrMessageBuilder;
  53 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.pcerr.message.pcerr.message.ErrorsBuilder;
  54 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev150820.Ipv4ExtendedTunnelId;
  55 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev150820.LspId;
  56 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.rsvp.rev150820.TunnelId;
  57
  58 public final class MsgBuilderUtil {
  59
  60     private MsgBuilderUtil() {
  61         throw new UnsupportedOperationException();
  62     }
  63
  64     public static Pcrpt createPcRtpMessage(final Lsp lsp, final Optional<Srp> srp, final Path path) {
  65         final PcrptBuilder rptBuilder = new PcrptBuilder();
  66         final PcrptMessageBuilder msgBuilder = new PcrptMessageBuilder();
  67         final ReportsBuilder reportBuilder = new ReportsBuilder();
  68         reportBuilder.setLsp(lsp);
  69         reportBuilder.setSrp(srp.orNull());
  70         reportBuilder.setPath(path);
  71         msgBuilder.setReports(Lists.newArrayList(reportBuilder.build()));
  72         rptBuilder.setPcrptMessage(msgBuilder.build());
  73         return rptBuilder.build();
  74     }
  75
  76     public static Lsp createLsp(final long plspId, final boolean sync, final Optional<Tlvs> tlvs, final boolean isDelegatedLsp, final boolean remove) {
  77         final LspBuilder lspBuilder = new LspBuilder();
  78         lspBuilder.setAdministrative(true);
  79         lspBuilder.setDelegate(isDelegatedLsp);
  80         lspBuilder.setIgnore(false);
  81         lspBuilder.setOperational(OperationalStatus.Up);
  82         lspBuilder.setPlspId(new PlspId(plspId));
  83         lspBuilder.setProcessingRule(false);
  84         lspBuilder.setRemove(remove);
  85         lspBuilder.setSync(sync);
  86         lspBuilder.setTlvs(tlvs.orNull());
  87         return lspBuilder.build();
  88     }
  89
  90     public static Lsp createLsp(final long plspId, final boolean sync, final Optional<Tlvs> tlvs, final boolean isDelegatedLspe) {
  91         return createLsp(plspId, sync, tlvs, isDelegatedLspe, false);
  92     }
  93
  94     public static Path createPath(final List<Subobject> subobjects) {
  95         final PathBuilder pathBuilder = new PathBuilder();
  96         pathBuilder.setEro(new EroBuilder().setSubobject(subobjects).build());
  97         return pathBuilder.build();
  98     }
  99
 100     public static Srp createSrp(final long srpId) {
 101         final SrpBuilder srpBuilder = new SrpBuilder();
 102         srpBuilder.setProcessingRule(false);
 103         srpBuilder.setIgnore(false);
 104         srpBuilder.setOperationId(new SrpIdNumber(srpId));
 105         return srpBuilder.build();
 106     }
 107
 108     public static Path updToRptPath(
 109             final org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.ietf.stateful.rev131222.pcupd.message.pcupd.message.updates.Path path) {
 110         final PathBuilder pathBuilder = new PathBuilder();
 111         if (path != null) {
 112             pathBuilder.fieldsFrom(path);
 113         }
 114         return pathBuilder.build();
 115     }
 116
 117     public static Path reqToRptPath(final Requests request) {
 118         final PathBuilder pathBuilder = new PathBuilder();
 119         if (request != null) {
 120             pathBuilder.fieldsFrom(request);
 121         }
 122         return pathBuilder.build();
 123     }
 124
 125     public static Tlvs createLspTlvs(final long lspId, final boolean symbolicPathName, final String tunnelEndpoint,
 126                                      final String tunnelSender, final String extendedTunnelAddress, final Optional<byte[]> symbolicName) {
 127         return createLspTlvs(lspId, symbolicPathName, tunnelEndpoint, tunnelSender, extendedTunnelAddress, symbolicName, Optional.absent());
 128     }
 129
 130     public static Tlvs createLspTlvs(final long lspId, final boolean symbolicPathName, final String tunnelEndpoint,
 131                                      final String tunnelSender, final String extendedTunnelAddress, final Optional<byte[]> symbolicName, final Optional<BigInteger> lspDBVersion) {
 132         final TlvsBuilder tlvs = new TlvsBuilder().setLspIdentifiers(new LspIdentifiersBuilder()
 133                 .setLspId(new LspId(lspId))
 134                 .setAddressFamily(
 135                         new Ipv4CaseBuilder().setIpv4(
 136                                 new Ipv4Builder()
 137                                         .setIpv4TunnelEndpointAddress(new Ipv4Address(tunnelEndpoint))
 138                                         .setIpv4TunnelSenderAddress(new Ipv4Address(tunnelSender))
 139                                         .setIpv4ExtendedTunnelId(
 140                                                 new Ipv4ExtendedTunnelId(extendedTunnelAddress))
 141                                         .build()).build()).setTunnelId(new TunnelId((int) lspId)).build());
 142         if (symbolicPathName) {
 143             if (symbolicName.isPresent()) {
 144                 tlvs.setSymbolicPathName(new SymbolicPathNameBuilder().setPathName(
 145                         new SymbolicPathName(symbolicName.get())).build());
 146             } else {
 147                 tlvs.setSymbolicPathName(new SymbolicPathNameBuilder().setPathName(
 148                         new SymbolicPathName(getDefaultPathName(tunnelSender, lspId))).build());
 149             }
 150         }
 151
 152         if (lspDBVersion.isPresent()) {
 153             tlvs.addAugmentation(Tlvs1.class, new Tlvs1Builder().setLspDbVersion(new LspDbVersionBuilder().
 154                 setLspDbVersionValue(lspDBVersion.get()).build()).build());
 155         }
 156         return tlvs.build();
 157     }
 158
 159     public static Optional<Tlvs> createLspTlvsEndofSync(@Nonnull final BigInteger bigInteger) {
 160         final Tlvs tlvs = new TlvsBuilder().addAugmentation(Tlvs1.class, new Tlvs1Builder().setLspDbVersion(
 161             new LspDbVersionBuilder().setLspDbVersionValue(bigInteger).build()).build()).build();
 162         return Optional.of(tlvs);
 163     }
 164
 165     public static Pcerr createErrorMsg(@Nonnull final PCEPErrors e, @Nonnull final long srpId) {
 166         final PcerrMessageBuilder msgBuilder = new PcerrMessageBuilder();
 167         return new PcerrBuilder().setPcerrMessage(
 168             msgBuilder
 169                 .setErrorType(
 170                     new StatefulCaseBuilder().setStateful(
 171                         new StatefulBuilder().setSrps(
 172                             Lists.newArrayList(new SrpsBuilder().setSrp(
 173                                 new SrpBuilder().setProcessingRule(false).setIgnore(false)
 174                                     .setOperationId(new SrpIdNumber(srpId)).build())
 175                                 .build())).build()).build())
 176                 .setErrors(
 177                     Collections.singletonList(new ErrorsBuilder().setErrorObject(
 178                         new ErrorObjectBuilder().setType(e.getErrorType()).setValue(e.getErrorValue())
 179                             .build()).build())).build()).build();
 180     }
 181
 182     public static byte[] getDefaultPathName(final String address, final long lspId) {
 183         return ("pcc_" + address + "_tunnel_" + lspId).getBytes(StandardCharsets.UTF_8);
 184     }
 185
 186 }