aai-service/provider/src/main/java/org/onap/ccsdk/sli/adaptors/aai/AAIServiceActivator.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * openECOMP : SDN-C
   4  * ================================================================================
   5  * Copyright (C) 2017 AT&T Intellectual Property. All rights
   6  *             reserved.
   7  * ================================================================================
   8  * Licensed under the Apache License, Version 2.0 (the "License");
   9  * you may not use this file except in compliance with the License.
  10  * You may obtain a copy of the License at
  11  *
  12  *      http://www.apache.org/licenses/LICENSE-2.0
  13  *
  14  * Unless required by applicable law or agreed to in writing, software
  15  * distributed under the License is distributed on an "AS IS" BASIS,
  16  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  17  * See the License for the specific language governing permissions and
  18  * limitations under the License.
  19  * ============LICENSE_END=========================================================
  20  */
  21
  22 package org.onap.ccsdk.sli.adaptors.aai;
  23
  24 import java.io.File;
  25 import java.io.FileInputStream;
  26 import java.io.FilenameFilter;
  27 import java.io.IOException;
  28 import java.io.InputStream;
  29 import java.util.HashSet;
  30 import java.util.Properties;
  31 import java.util.Set;
  32
  33 import org.onap.ccsdk.sli.core.sli.ConfigurationException;
  34 import org.osgi.framework.BundleActivator;
  35 import org.osgi.framework.BundleContext;
  36 import org.osgi.framework.ServiceRegistration;
  37 import org.slf4j.Logger;
  38 import org.slf4j.LoggerFactory;
  39
  40 public class AAIServiceActivator implements BundleActivator {
  41
  42     private static final String DEFAULT_CONFIG_FILE_NAME = "aaiclient.config";
  43     private static final String DEFAULT_PROPERTY_FILE_NAME = "aaiclient.properties";
  44     private static final String DEFAULT_KEYWORD = "default";
  45
  46     private static final String SDNC_CONFIG_DIR = "SDNC_CONFIG_DIR";
  47
  48     private static final String BVC_PROPERTY_FILE = "/opt/bvc/controller/configuration/aaiclient.properties";
  49     private static final String DEFAULT_SDNC_PROPERTY_FILE = "/opt/sdnc/data/properties/aaiclient.properties";
  50
  51     private Set<ServiceRegistration> registrationSet = new HashSet<ServiceRegistration>();
  52
  53     private static final Logger LOG = LoggerFactory.getLogger(AAIServiceActivator.class);
  54
  55     @Override
  56     public void start(BundleContext ctx) throws Exception {
  57
  58         System.setProperty("aaiclient.runtime", "OSGI");
  59
  60         String sdnConfigDirectory = System.getenv(SDNC_CONFIG_DIR);
  61
  62         // check SDNC CONFIG DIR system property
  63         if(sdnConfigDirectory == null ) {
  64             LOG.error("System property SDNC_CONFIG_DIR is not defined.");
  65             LOG.info("Defaulting SDNC_CONFIG_DIR to '/opt/sdnc/data/properties/'");
  66             sdnConfigDirectory = "/opt/sdnc/data/properties/";
  67         }
  68
  69         LOG.debug("Configuration directory used : " + sdnConfigDirectory);
  70
  71         // check existance of properties directory
  72         File configDirectory = new File(sdnConfigDirectory);
  73         if(!configDirectory.exists() || !configDirectory.isDirectory()){
  74             LOG.error("System property SDNC_CONFIG_DIR = '" + sdnConfigDirectory + "' does not point to a valid directory. AAIService will not be initialized.");
  75             return;
  76         }
  77
  78         Properties properties = new Properties();
  79         InputStream input = null;
  80
  81         // find aaiclient config file
  82         File[] files = findFiles(configDirectory, DEFAULT_CONFIG_FILE_NAME);
  83
  84         // read the aai config data
  85         if(files != null && files.length > 0) {
  86             LOG.debug("AAIService config file exists and it is named :" + files[0].getAbsolutePath() );
  87             try {
  88                 input = new FileInputStream(files[0]);
  89                 properties.load(input);
  90                 LOG.debug("Loaded AAI Client properties from " + files[0].getAbsolutePath());
  91             } catch (IOException exc) {
  92                 LOG.warn("Problem loading AAI Client properties from " + files[0].getAbsolutePath(), exc);
  93             } finally {
  94                 if(input != null ) {
  95                     try {
  96                         input.close();
  97                     } catch(Exception exc) {
  98                         LOG.error("Failed to close InputStream", exc);
  99                     }
 100                 }
 101                 int size = properties.keySet().size() ;
 102                 if(size == 0) {
 103                     LOG.debug(files[0].getAbsolutePath() + " contained no entries. Adding the default entry");
 104                     properties.put(DEFAULT_KEYWORD, DEFAULT_PROPERTY_FILE_NAME);
 105                 }
 106             }
 107         } else {
 108             LOG.debug("No configuration entries were found. Adding the default entry");
 109             properties.put(DEFAULT_KEYWORD, DEFAULT_PROPERTY_FILE_NAME);
 110         }
 111
 112         Set<String> entrySet = properties. stringPropertyNames();
 113         String value = null;
 114
 115         // initialize AAI Service for each aai client property files
 116         for(String entry : entrySet) {
 117             value = properties.getProperty(entry);
 118             if(value != null && !value.isEmpty()) {
 119
 120                 final String fileName = value;
 121
 122                 File[] propertyFileList = findFiles(configDirectory, fileName);
 123
 124                 for(File propertiesFile : propertyFileList) {
 125                     LOG.info(propertiesFile.getName());
 126                     // Advertise AAI resource adaptor
 127                     AAIClient impl = null;
 128                     switch(entry) {
 129                     case DEFAULT_KEYWORD:
 130                         impl = new AAIService(propertiesFile.toURI().toURL());
 131                         break;
 132                     case "trinity":
 133                         impl = new AAITrinityService(propertiesFile.toURI().toURL());
 134                         break;
 135                     default:
 136                         LOG.error("Invalid configuration keyword '"+entry+"' detected in aaiclient.config. Aborting initialization");
 137                         continue;
 138                     }
 139                     String regName = impl.getClass().getName();
 140
 141                     LOG.debug("Registering AAIService service "+regName);
 142                     ServiceRegistration registration = ctx.registerService(regName, impl, null);
 143                     registrationSet.add(registration);
 144
 145                 }
 146             }
 147         }
 148     }
 149
 150 //    @Override
 151     @Deprecated
 152     public void start1(BundleContext ctx) throws Exception {
 153
 154         String sdnConfigDirectory = System.getenv(SDNC_CONFIG_DIR);
 155         String propertiesPath = null;
 156
 157         if (sdnConfigDirectory == null || sdnConfigDirectory.isEmpty()) {
 158             String filename = DEFAULT_SDNC_PROPERTY_FILE;
 159             File file = new File(filename);
 160             if(file.exists()) {
 161                 propertiesPath = filename;
 162                 LOG.info("Using property file (1): " + propertiesPath);
 163             } else {
 164                 filename = BVC_PROPERTY_FILE;
 165                 file = new File(filename);
 166                 if(file.exists()) {
 167                     propertiesPath = filename;
 168                     LOG.info("Using property file (1): " + propertiesPath);
 169                 } else {
 170                     throw new ConfigurationException("Cannot find config file - "+filename+" and "+SDNC_CONFIG_DIR+" is unset");
 171                 }
 172             }
 173         } else {
 174             propertiesPath = sdnConfigDirectory + "/aaiclient.properties";
 175             LOG.info("Environment variable " + SDNC_CONFIG_DIR + " set, - calculated path " + propertiesPath);
 176         }
 177
 178         File propFile = new File(propertiesPath);
 179         if(!propFile.exists()) {
 180             String filename = DEFAULT_SDNC_PROPERTY_FILE;
 181             File file = new File(filename);
 182             if(file.exists()) {
 183                 propertiesPath = filename;
 184                 LOG.info("Using property file (1): " + propertiesPath);
 185             } else {
 186                 filename = BVC_PROPERTY_FILE;
 187                 file = new File(filename);
 188                 if(file.exists()) {
 189                     propertiesPath = filename;
 190                     LOG.info("Using property file (1): " + propertiesPath);
 191                 } else {
 192                     LOG.error("AnAI Service Property file " + propertiesPath + "does not exist.");
 193                     throw new ConfigurationException("Cannot find config file - "+propertiesPath+" and " + SDNC_CONFIG_DIR + " is unset.");
 194                 }
 195             }
 196         }
 197
 198         // Advertise AAI resource adaptor
 199         AAIClient impl = new AAIService(propFile.toURI().toURL());
 200         String regName = impl.getClass().getName();
 201
 202         LOG.debug("Registering AAIService service "+regName);
 203         ServiceRegistration registration = ctx.registerService(regName, impl, null);
 204         registrationSet.add(registration);
 205     }
 206
 207     @Override
 208     public void stop(BundleContext ctx) throws Exception {
 209
 210         Set<ServiceRegistration> localRegistrationSet = new HashSet<ServiceRegistration>();
 211         localRegistrationSet.addAll(registrationSet);
 212
 213         for(ServiceRegistration registration : localRegistrationSet) {
 214             if (registration != null) {
 215                 try {
 216                     AAIService aaiService = (AAIService)ctx.getService(registration.getReference());
 217                 registration.unregister();
 218                 registrationSet.remove(registration);
 219                     if(aaiService != null) {
 220                         aaiService.cleanUp();
 221                     }
 222                 } catch(Exception exc) {
 223                     if(LOG.isDebugEnabled())
 224                         LOG.debug(exc.getMessage());
 225                 }
 226             }
 227         }
 228     }
 229
 230     private File[] findFiles(File configDirectory, final String filter) {
 231         File[] files = configDirectory.listFiles(new FilenameFilter() {
 232             public boolean accept(File dir, String name) {
 233                 return name.equalsIgnoreCase(filter);
 234             }
 235         });
 236
 237         return files;
 238     }
 239 }