opendaylight/netconf/config-netconf-connector/src/main/java/org/opendaylight/controller/netconf/confignetconfconnector/osgi/NetconfOperationServiceImpl.java

   1 /*
   2  * Copyright (c) 2013 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.controller.netconf.confignetconfconnector.osgi;
  10
  11 import com.google.common.base.Optional;
  12 import com.google.common.collect.Sets;
  13 import org.opendaylight.controller.config.util.ConfigRegistryJMXClient;
  14 import org.opendaylight.controller.config.yang.store.api.YangStoreException;
  15 import org.opendaylight.controller.config.yang.store.api.YangStoreService;
  16 import org.opendaylight.controller.config.yang.store.api.YangStoreSnapshot;
  17 import org.opendaylight.controller.netconf.confignetconfconnector.transactions.TransactionProvider;
  18 import org.opendaylight.controller.netconf.confignetconfconnector.util.Util;
  19 import org.opendaylight.controller.netconf.mapping.api.Capability;
  20 import org.opendaylight.controller.netconf.mapping.api.NetconfOperation;
  21 import org.opendaylight.controller.netconf.mapping.api.NetconfOperationFilter;
  22 import org.opendaylight.controller.netconf.mapping.api.NetconfOperationService;
  23 import org.opendaylight.yangtools.yang.model.api.Module;
  24
  25 import java.util.Collection;
  26 import java.util.Collections;
  27 import java.util.Map;
  28 import java.util.Set;
  29
  30 /**
  31  * Manages life cycle of {@link YangStoreSnapshot}.
  32  */
  33 public class NetconfOperationServiceImpl implements NetconfOperationService {
  34
  35     private final YangStoreSnapshot yangStoreSnapshot;
  36     private final NetconfOperationProvider operationProvider;
  37     private final Set<Capability> capabilities;
  38     private final TransactionProvider transactionProvider;
  39
  40     public NetconfOperationServiceImpl(YangStoreService yangStoreService, ConfigRegistryJMXClient jmxClient,
  41             String netconfSessionIdForReporting) throws YangStoreException {
  42
  43         yangStoreSnapshot = yangStoreService.getYangStoreSnapshot();
  44         transactionProvider = new TransactionProvider(jmxClient, netconfSessionIdForReporting);
  45         operationProvider = new NetconfOperationProvider(yangStoreSnapshot, jmxClient, transactionProvider,
  46                 netconfSessionIdForReporting);
  47         capabilities = setupCapabilities(yangStoreSnapshot);
  48     }
  49
  50     @Override
  51     public void close() {
  52         yangStoreSnapshot.close();
  53         transactionProvider.close();
  54     }
  55
  56     @Override
  57     public Set<Capability> getCapabilities() {
  58         return capabilities;
  59     }
  60
  61     @Override
  62     public Set<NetconfOperation> getNetconfOperations() {
  63         return operationProvider.getOperations();
  64     }
  65
  66     @Override
  67     public Set<NetconfOperationFilter> getFilters() {
  68         return Collections.emptySet();
  69     }
  70
  71     private static Set<Capability> setupCapabilities(YangStoreSnapshot yangStoreSnapshot) {
  72         Set<Capability> capabilities = Sets.newHashSet();
  73
  74         capabilities.add(new BasicCapability("urn:ietf:params:netconf:capability:candidate:1.0"));
  75         capabilities.add(new BasicCapability("urn:ietf:params:netconf:capability:rollback-on-error:1.0"));
  76         capabilities.add(new BasicCapability("urn:ietf:params:netconf:capability:operations:1.0"));
  77         capabilities.add(new BasicCapability("urn:ietf:params:netconf:capability:operations:1.1"));
  78         capabilities
  79                 .add(new BasicCapability(
  80                         "urn:ietf:params:xml:ns:yang:ietf-netconf-monitoring?module=ietf-netconf-monitoring&amp;revision=2010-10-04"));
  81
  82         final Collection<Map.Entry<Module, String>> modulesAndContents = yangStoreSnapshot.getModuleMap().values();
  83         for (Map.Entry<Module, String> moduleAndContent : modulesAndContents) {
  84             capabilities.add(new YangStoreCapability(moduleAndContent));
  85         }
  86
  87         return capabilities;
  88     }
  89
  90     private static class BasicCapability implements Capability {
  91
  92         private final String capability;
  93
  94         private BasicCapability(String capability) {
  95             this.capability = capability;
  96         }
  97
  98         @Override
  99         public String getCapabilityUri() {
 100             return capability;
 101         }
 102
 103         @Override
 104         public Optional<String> getModuleName() {
 105             return Optional.absent();
 106         }
 107
 108         @Override
 109         public Optional<String> getRevision() {
 110             return Optional.absent();
 111         }
 112
 113         @Override
 114         public Optional<String> getCapabilitySchema() {
 115             return Optional.absent();
 116         }
 117     }
 118
 119     private static class YangStoreCapability extends BasicCapability {
 120
 121         private final String content;
 122         private final String revision;
 123         private final String moduleName;
 124
 125         public YangStoreCapability(Map.Entry<Module, String> moduleAndContent) {
 126             super(getAsString(moduleAndContent.getKey()));
 127             this.content = moduleAndContent.getValue();
 128             Module module = moduleAndContent.getKey();
 129             this.moduleName = module.getName();
 130             this.revision = Util.writeDate(module.getRevision());
 131         }
 132
 133         @Override
 134         public Optional<String> getCapabilitySchema() {
 135             return Optional.of(content);
 136         }
 137
 138         private static String getAsString(Module module) {
 139             final StringBuffer capabilityContent = new StringBuffer();
 140             capabilityContent.append(module.getNamespace());
 141             capabilityContent.append("?module=");
 142             capabilityContent.append(module.getName());
 143             capabilityContent.append("&revision=");
 144             capabilityContent.append(Util.writeDate(module.getRevision()));
 145             return capabilityContent.toString();
 146         }
 147
 148         @Override
 149         public Optional<String> getModuleName() {
 150             return Optional.of(moduleName);
 151         }
 152
 153         @Override
 154         public Optional<String> getRevision() {
 155             return Optional.of(revision);
 156         }
 157     }
 158 }