gerrit.onap Code Review - sdc.git/blob

   1 package org.openecomp.core.zusammen.impl;
   2
   3
   4 import org.apache.commons.lang3.StringUtils;
   5 import org.openecomp.core.nosqldb.util.CassandraUtils;
   6
   7 import javax.servlet.ServletContextEvent;
   8 import javax.servlet.ServletContextListener;
   9 import java.util.Objects;
  10
  11 /**
  12  * @author Avrahamg
  13  * @since April 25, 2017
  14  */
  15
  16 public class CassandraConnectionInitializer implements ServletContextListener {
  17
  18   private static String DATA_CENTER_PROPERTY_NAME = "cassandra.datacenter";
  19   private static String CONSISTENCY_LEVEL_PROPERTY_NAME = "cassandra.consistency.level";
  20   private static String NODES_PROPERTY_NAME = "cassandra.nodes";
  21   private static String AUTHENTICATE_PROPERTY_NAME = "cassandra.authenticate";
  22   private static String TRUE = "true";
  23   private static String FALSE = "false";
  24   private static String SSL_PROPERTY_NAME = "cassandra.ssl";
  25   private static String TRUSTSTORE_PROPERTY_NAME = "cassandra.truststore";
  26   private static String TRUSTSTORE_PASSWORD_PROPERTY_NAME = "cassandra.truststore.password";
  27   private static String USER_PROPERTY_NAME = "cassandra.user";
  28   private static String PASSWORD_PROPERTY_NAME = "cassandra.password";
  29   private static String KEYSPACE_PROPERTY_NAME = "cassandra.keyspace";
  30   private static String ZUSAMMEN = "zusammen";
  31
  32   @Override
  33   public void contextInitialized(ServletContextEvent servletContextEvent) {
  34     setCassandraConnectionPropertiesToSystem();
  35   }
  36
  37   public static void setCassandraConnectionPropertiesToSystem() {
  38
  39     if (!System.getProperties().containsKey(NODES_PROPERTY_NAME)) {
  40       System.setProperty(NODES_PROPERTY_NAME, StringUtils.join(CassandraUtils.getAddresses(), ','));
  41     }
  42
  43     if (!System.getProperties().containsKey(AUTHENTICATE_PROPERTY_NAME)) {
  44       System.setProperty(AUTHENTICATE_PROPERTY_NAME,
  45           CassandraUtils.isAuthenticate() ? TRUE : FALSE);
  46     }
  47     if (!System.getProperties().containsKey(SSL_PROPERTY_NAME)) {
  48       System.setProperty(SSL_PROPERTY_NAME,
  49           CassandraUtils.isSsl() ? TRUE : FALSE);
  50     }
  51
  52     if (!System.getProperties().containsKey(TRUSTSTORE_PROPERTY_NAME)) {
  53       System.setProperty(TRUSTSTORE_PROPERTY_NAME, CassandraUtils.getTruststore());
  54     }
  55
  56     if (!System.getProperties().containsKey(TRUSTSTORE_PASSWORD_PROPERTY_NAME)) {
  57       System.setProperty(TRUSTSTORE_PASSWORD_PROPERTY_NAME, CassandraUtils.getTruststorePassword());
  58     }
  59
  60     if (!System.getProperties().containsKey(USER_PROPERTY_NAME)) {
  61       System.setProperty(USER_PROPERTY_NAME, CassandraUtils.getUser());
  62     }
  63
  64     if (!System.getProperties().containsKey(PASSWORD_PROPERTY_NAME)) {
  65       System.setProperty(PASSWORD_PROPERTY_NAME, CassandraUtils.getPassword());
  66     }
  67
  68     if (!System.getProperties().containsKey(KEYSPACE_PROPERTY_NAME)) {
  69       System.setProperty(KEYSPACE_PROPERTY_NAME, ZUSAMMEN);
  70     }
  71
  72
  73     if (!System.getProperties().containsKey(DATA_CENTER_PROPERTY_NAME)) {
  74       String dataCenter = CassandraUtils.getLocalDataCenter();
  75       if (Objects.nonNull(dataCenter)) {
  76         System.setProperty(DATA_CENTER_PROPERTY_NAME, dataCenter);
  77       }
  78     }
  79
  80     if (!System.getProperties().containsKey(CONSISTENCY_LEVEL_PROPERTY_NAME)) {
  81       String consistencyLevel = CassandraUtils.getConsistencyLevel();
  82       if (Objects.nonNull(consistencyLevel)) {
  83         System.setProperty(CONSISTENCY_LEVEL_PROPERTY_NAME, consistencyLevel);
  84       }
  85     }
  86
  87
  88   }
  89
  90   //       -Dcassandra.nodes=10.147.97.145  -Dcassandra.keyspace=zusammen -Dcassandra.authenticate=true -Dcassandra.ssl=true
  91   // -Dcassandra.truststore=/apps/jetty/base/be/config/.truststore -Dcassandra.truststore.password=Aa123456
  92   // -Dcassandra.user=asdc_user -Dcassandra.password=Aa1234%^!
  93
  94   @Override
  95   public void contextDestroyed(ServletContextEvent servletContextEvent) {
  96
  97   }
  98 }