bgp/topology-provider/src/main/java/org/opendaylight/bgpcep/bgp/topology/provider/NetworkTopologyConfigFileProcessor.java

   1 /*
   2  * Copyright (c) 2016 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.bgpcep.bgp.topology.provider;
  10
  11 import static java.util.Objects.requireNonNull;
  12
  13 import java.util.Collection;
  14 import java.util.Map;
  15 import javax.annotation.Nonnull;
  16 import org.opendaylight.bgpcep.bgp.topology.provider.spi.BgpTopologyDeployer;
  17 import org.opendaylight.mdsal.binding.dom.codec.api.BindingNormalizedNodeSerializer;
  18 import org.opendaylight.protocol.bgp.config.loader.spi.ConfigFileProcessor;
  19 import org.opendaylight.protocol.bgp.config.loader.spi.ConfigLoader;
  20 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NetworkTopology;
  21 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.Topology;
  22 import org.opendaylight.yangtools.concepts.AbstractRegistration;
  23 import org.opendaylight.yangtools.yang.binding.DataObject;
  24 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  25 import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
  26 import org.opendaylight.yangtools.yang.data.api.schema.ContainerNode;
  27 import org.opendaylight.yangtools.yang.data.api.schema.MapEntryNode;
  28 import org.opendaylight.yangtools.yang.data.api.schema.MapNode;
  29 import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
  30 import org.opendaylight.yangtools.yang.model.api.SchemaPath;
  31
  32 public final class NetworkTopologyConfigFileProcessor implements ConfigFileProcessor, AutoCloseable {
  33     private static final SchemaPath TOPOLOGY_SCHEMA_PATH = SchemaPath.create(true, NetworkTopology.QNAME);
  34     private final BindingNormalizedNodeSerializer bindingSerializer;
  35     private final BgpTopologyDeployer deployer;
  36     private final AbstractRegistration registration;
  37     private final YangInstanceIdentifier topologyYii;
  38
  39     public NetworkTopologyConfigFileProcessor(final ConfigLoader configLoader, final BgpTopologyDeployer deployer) {
  40         requireNonNull(configLoader);
  41         this.deployer = requireNonNull(deployer);
  42         this.bindingSerializer = configLoader.getBindingNormalizedNodeSerializer();
  43         this.topologyYii = this.bindingSerializer.toYangInstanceIdentifier(deployer.getInstanceIdentifier());
  44         this.registration = configLoader.registerConfigFile(this);
  45     }
  46
  47     @Override
  48     public void close() throws Exception {
  49         this.registration.close();
  50     }
  51
  52     @Nonnull
  53     @Override
  54     public SchemaPath getSchemaPath() {
  55         return TOPOLOGY_SCHEMA_PATH;
  56     }
  57
  58     @Override
  59     public void loadConfiguration(@Nonnull final NormalizedNode<?, ?> dto) {
  60         final ContainerNode networkTopologyContainer = (ContainerNode) dto;
  61         final MapNode topologyList = (MapNode) networkTopologyContainer.getChild(
  62                 topologyYii.getLastPathArgument()).get();
  63         final Collection<MapEntryNode> networkTopology = topologyList.getValue();
  64         for (final MapEntryNode topology : networkTopology) {
  65             final Map.Entry<InstanceIdentifier<?>, DataObject> bi = this.bindingSerializer.fromNormalizedNode(this.topologyYii , topology);
  66             if (bi != null) {
  67                 this.deployer.createInstance((Topology) bi.getValue());
  68             }
  69         }
  70     }
  71 }