pcep/topology/topology-provider/src/main/java/org/opendaylight/bgpcep/pcep/topology/provider/PCEPTopologyConfiguration.java

   1 /*
   2  * Copyright (c) 2017 AT&T Intellectual Property. 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.bgpcep.pcep.topology.provider;
   9
  10 import static java.util.Objects.requireNonNull;
  11
  12 import com.google.common.net.InetAddresses;
  13 import java.net.InetAddress;
  14 import java.net.InetSocketAddress;
  15 import java.util.HashMap;
  16 import java.util.Map;
  17 import org.eclipse.jdt.annotation.NonNull;
  18 import org.eclipse.jdt.annotation.Nullable;
  19 import org.opendaylight.protocol.concepts.KeyMapping;
  20 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IetfInetUtil;
  21 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddressNoZone;
  22 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.PortNumber;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.graph.rev220720.graph.topology.GraphKey;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.topology.pcep.rev220730.Node1;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.topology.pcep.rev220730.TopologyTypes1;
  26 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.Topology;
  27 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
  28 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.NodeKey;
  29 import org.opendaylight.yangtools.concepts.Immutable;
  30
  31 final class PCEPTopologyConfiguration implements Immutable {
  32     private final @NonNull InetSocketAddress address;
  33     private final @NonNull KeyMapping keys;
  34     private final short rpcTimeout;
  35     private final GraphKey graphKey;
  36
  37     PCEPTopologyConfiguration(final @NonNull InetSocketAddress address, final short rpcTimeout,
  38             final @NonNull KeyMapping keys, final @NonNull GraphKey graphKey) {
  39         this.address = requireNonNull(address);
  40         this.keys = requireNonNull(keys);
  41         this.rpcTimeout = rpcTimeout;
  42         this.graphKey = requireNonNull(graphKey);
  43     }
  44
  45     static @Nullable PCEPTopologyConfiguration of(final @NonNull Topology topology) {
  46         final var types = topology.getTopologyTypes();
  47         if (types == null) {
  48             return null;
  49         }
  50         final var typesAug = types.augmentation(TopologyTypes1.class);
  51         if (typesAug == null) {
  52             return null;
  53         }
  54         final var topologyPcep = typesAug.getTopologyPcep();
  55         if (topologyPcep == null) {
  56             return null;
  57         }
  58         final var sessionConfig = topologyPcep.getSessionConfig();
  59         if (sessionConfig == null) {
  60             return null;
  61         }
  62
  63         return new PCEPTopologyConfiguration(
  64             getInetSocketAddress(sessionConfig.getListenAddress(), sessionConfig.getListenPort()),
  65             sessionConfig.getRpcTimeout(), constructKeys(topology.getNode()),
  66             constructGraphKey(sessionConfig.getTedName()));
  67     }
  68
  69     short getRpcTimeout() {
  70         return rpcTimeout;
  71     }
  72
  73     @NonNull InetSocketAddress getAddress() {
  74         return address;
  75     }
  76
  77     @NonNull KeyMapping getKeys() {
  78         return keys;
  79     }
  80
  81     @NonNull GraphKey getGraphKey() {
  82         return graphKey;
  83     }
  84
  85     private static @NonNull KeyMapping constructKeys(final @Nullable Map<NodeKey, Node> nodes) {
  86         if (nodes == null) {
  87             return KeyMapping.of();
  88         }
  89
  90         final var passwords = new HashMap<InetAddress, String>();
  91         for (var node : nodes.values()) {
  92             if (node != null) {
  93                 final var nodeConfig = node.augmentation(Node1.class);
  94                 if (nodeConfig != null) {
  95                     final var sessionConfig = nodeConfig.getSessionConfig();
  96                     if (sessionConfig != null) {
  97                         final var rfc2385KeyPassword = sessionConfig.getPassword();
  98                         if (rfc2385KeyPassword != null) {
  99                             final String password = rfc2385KeyPassword.getValue();
 100                             if (!password.isEmpty()) {
 101                                 passwords.put(nodeAddress(node), password);
 102                             }
 103                         }
 104                     }
 105                 }
 106             }
 107         }
 108
 109         return KeyMapping.of(passwords);
 110     }
 111
 112     private static @NonNull GraphKey constructGraphKey(final String name) {
 113         return new GraphKey(name.startsWith("ted://") ? name : "ted://" + name);
 114     }
 115
 116     private static InetAddress nodeAddress(final Node node) {
 117         return InetAddresses.forString(node.getNodeId().getValue());
 118     }
 119
 120     private static @NonNull InetSocketAddress getInetSocketAddress(final IpAddressNoZone address,
 121             final PortNumber port) {
 122         return new InetSocketAddress(IetfInetUtil.INSTANCE.inetAddressForNoZone(requireNonNull(address)),
 123             port.getValue().toJava());
 124     }
 125 }