netconf/mdsal-netconf-monitoring/src/main/java/org/opendaylight/controller/config/yang/netconf/mdsal/monitoring/MdsalMonitoringMapperFactory.java

   1 /*
   2  * Copyright (c) 2015 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 package org.opendaylight.controller.config.yang.netconf.mdsal.monitoring;
   9
  10 import static java.util.Objects.requireNonNull;
  11
  12 import java.util.Set;
  13 import org.opendaylight.netconf.api.capability.Capability;
  14 import org.opendaylight.netconf.server.api.monitoring.CapabilityListener;
  15 import org.opendaylight.netconf.server.api.monitoring.NetconfMonitoringService;
  16 import org.opendaylight.netconf.server.api.operations.NetconfOperation;
  17 import org.opendaylight.netconf.server.api.operations.NetconfOperationService;
  18 import org.opendaylight.netconf.server.api.operations.NetconfOperationServiceFactory;
  19 import org.opendaylight.netconf.server.api.operations.NetconfOperationServiceFactoryListener;
  20 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.netconf.base._1._0.rev110601.SessionIdType;
  21 import org.opendaylight.yangtools.concepts.Registration;
  22 import org.osgi.service.component.annotations.Activate;
  23 import org.osgi.service.component.annotations.Component;
  24 import org.osgi.service.component.annotations.Deactivate;
  25 import org.osgi.service.component.annotations.Reference;
  26
  27 @Component(service = { })
  28 public final class MdsalMonitoringMapperFactory implements NetconfOperationServiceFactory, AutoCloseable {
  29     private final NetconfOperationServiceFactoryListener netconfOperationServiceFactoryListener;
  30     private final NetconfMonitoringService netconfMonitoringService;
  31
  32     @Activate
  33     public MdsalMonitoringMapperFactory(
  34             @Reference(target = "(type=mapper-aggregator-registry)")
  35             final NetconfOperationServiceFactoryListener netconfOperationServiceFactoryListener,
  36             @Reference(target = "(type=netconf-server-monitoring)")
  37             final NetconfMonitoringService netconfMonitoringService) {
  38         this.netconfOperationServiceFactoryListener = requireNonNull(netconfOperationServiceFactoryListener);
  39         this.netconfMonitoringService = requireNonNull(netconfMonitoringService);
  40         this.netconfOperationServiceFactoryListener.onAddNetconfOperationServiceFactory(this);
  41     }
  42
  43     @Deactivate
  44     @Override
  45     public void close() {
  46         netconfOperationServiceFactoryListener.onRemoveNetconfOperationServiceFactory(this);
  47     }
  48
  49     @Override
  50     public NetconfOperationService createService(final SessionIdType sessionId) {
  51         return new NetconfOperationService() {
  52             @Override
  53             public Set<NetconfOperation> getNetconfOperations() {
  54                 return Set.of(new GetSchema(sessionId, netconfMonitoringService));
  55             }
  56
  57             @Override
  58             public void close() {
  59                 // NOOP
  60             }
  61         };
  62     }
  63
  64     @Override
  65     public Set<Capability> getCapabilities() {
  66         // TODO No capabilities exposed to prevent clashes with schemas from mdsal-netconf-connector (it exposes all the
  67         // schemas). If the schemas exposed by mdsal-netconf-connector are filtered, this class would expose monitoring
  68         // related models.
  69         return Set.of();
  70     }
  71
  72     @Override
  73     public Registration registerCapabilityListener(final CapabilityListener listener) {
  74         return () -> { };
  75     }
  76 }