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