gerrit.onap Code Review - integration.git/blob

   1 package org.onap.pnfsimulator.netconfmonitor;
   2
   3 import com.tailf.jnc.JNCException;
   4 import com.tailf.jnc.NetconfSession;
   5 import com.tailf.jnc.SSHConnection;
   6 import com.tailf.jnc.SSHSession;
   7 import java.io.IOException;
   8 import java.util.Map;
   9 import java.util.Timer;
  10 import org.onap.pnfsimulator.netconfmonitor.netconf.NetconfConfigurationCache;
  11 import org.onap.pnfsimulator.netconfmonitor.netconf.NetconfConfigurationReader;
  12 import org.onap.pnfsimulator.netconfmonitor.netconf.NetconfConfigurationWriter;
  13 import org.onap.pnfsimulator.netconfmonitor.netconf.NetconfConnectionParams;
  14 import org.slf4j.Logger;
  15 import org.slf4j.LoggerFactory;
  16 import org.springframework.context.annotation.Bean;
  17 import org.springframework.context.annotation.Configuration;
  18
  19 @Configuration
  20 public class NetconfMonitorServiceConfiguration {
  21
  22     private static final Logger LOGGER = LoggerFactory.getLogger(NetconfMonitorServiceConfiguration.class);
  23     private static final Map<String, String> enviroment = System.getenv();
  24
  25     private static final String LOG_PATH = "/var/log";
  26
  27     private static final String NETCONF_ADDRESS = "NETCONF_ADDRESS";
  28     private static final String NETCONF_PORT = "NETCONF_PORT";
  29     private static final String NETCONF_MODEL = "NETCONF_MODEL";
  30     private static final String NETCONF_MAIN_CONTAINER = "NETCONF_MAIN_CONTAINER";
  31
  32     private static final String DEFAULT_NETCONF_ADDRESS = "localhost";
  33     private static final int DEFAULT_NETCONF_PORT = 830;
  34     private static final String DEFAULT_NETCONF_MODEL = "pnf-simulator";
  35     private static final String DEFAULT_NETCONF_MAIN_CONTAINER = "config";
  36
  37     private static final String DEFAULT_NETCONF_USER = "netconf";
  38     private static final String DEFAULT_NETCONF_PASSWORD = "netconf";
  39
  40     @Bean
  41     public Timer timer() {
  42         return new Timer("NetconfMonitorServiceTimer");
  43     }
  44
  45     @Bean
  46     public NetconfConfigurationCache configurationCache() {
  47         return new NetconfConfigurationCache();
  48     }
  49
  50     @Bean
  51     public NetconfConfigurationReader configurationReader() throws IOException, JNCException {
  52         NetconfConnectionParams params = resolveConnectionParams();
  53         LOGGER.info("Configuration params are : {}", params);
  54         NetconfSession session = createNetconfSession(params);
  55         return new NetconfConfigurationReader(session, buildModelPath());
  56     }
  57
  58     NetconfSession createNetconfSession(NetconfConnectionParams params) throws IOException, JNCException {
  59         SSHConnection sshConnection = new SSHConnection(params.address, params.port);
  60         sshConnection.authenticateWithPassword(params.user, params.password);
  61         return new NetconfSession( new SSHSession(sshConnection));
  62     }
  63
  64     @Bean
  65     public NetconfConfigurationWriter netconfConfigurationWriter() {
  66         return new NetconfConfigurationWriter(LOG_PATH);
  67     }
  68
  69     private String buildModelPath() {
  70         return String.format("/%s:%s",
  71             enviroment.getOrDefault(NETCONF_MODEL, DEFAULT_NETCONF_MODEL),
  72             enviroment.getOrDefault(NETCONF_MAIN_CONTAINER, DEFAULT_NETCONF_MAIN_CONTAINER));
  73     }
  74
  75     NetconfConnectionParams resolveConnectionParams() {
  76         return new NetconfConnectionParams(
  77             enviroment.getOrDefault(NETCONF_ADDRESS, DEFAULT_NETCONF_ADDRESS),
  78             resolveNetconfPort(),
  79             DEFAULT_NETCONF_USER,
  80             DEFAULT_NETCONF_PASSWORD);
  81     }
  82
  83     private int resolveNetconfPort() {
  84         try {
  85             return Integer.parseInt(enviroment.get(NETCONF_PORT));
  86         } catch (NumberFormatException e) {
  87             LOGGER.warn("Invalid netconf port: {}. Default netconf port {} is set.", e.getMessage(),
  88                 DEFAULT_NETCONF_PORT);
  89             return DEFAULT_NETCONF_PORT;
  90         }
  91     }
  92 }