gerrit.onap Code Review - vfc/nfvo/driver/vnfm/gvnfm.git/blob

   1 /*
   2  * Copyright 2016 Huawei Technologies Co., Ltd.
   3  *
   4  * Licensed under the Apache License, Version 2.0 (the "License");
   5  * you may not use this file except in compliance with the License.
   6  * You may obtain a copy of the License at
   7  *
   8  *     http://www.apache.org/licenses/LICENSE-2.0
   9  *
  10  * Unless required by applicable law or agreed to in writing, software
  11  * distributed under the License is distributed on an "AS IS" BASIS,
  12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13  * See the License for the specific language governing permissions and
  14  * limitations under the License.
  15  */
  16
  17 package org.onap.vfc.nfvo.vnfm.gvnfm.jujuvnfmadapter.service.api.internalsvc.impl;
  18
  19 import java.io.BufferedInputStream;
  20 import java.io.FileInputStream;
  21 import java.io.FileNotFoundException;
  22 import java.io.IOException;
  23 import java.io.InputStream;
  24 import java.util.HashMap;
  25 import java.util.Map;
  26 import java.util.concurrent.Executors;
  27
  28 import org.onap.vfc.nfvo.vnfm.gvnfm.jujuvnfmadapter.service.adapter.impl.JujuAdapter2MSBManager;
  29 import org.onap.vfc.nfvo.vnfm.gvnfm.jujuvnfmadapter.service.adapter.inf.IJujuAdapter2MSBManager;
  30 import org.onap.vfc.nfvo.vnfm.gvnfm.jujuvnfmadapter.service.api.internalsvc.inf.IJujuAdapterMgrService;
  31 import org.onap.vfc.nfvo.vnfm.gvnfm.jujuvnfmadapter.service.constant.Constant;
  32 import org.onap.vfc.nfvo.vnfm.gvnfm.jujuvnfmadapter.service.constant.UrlConstant;
  33 import org.onap.vfc.nfvo.vnfm.gvnfm.jujuvnfmadapter.common.restclient.SystemEnvVariablesFactory;
  34 import org.slf4j.Logger;
  35 import org.slf4j.LoggerFactory;
  36
  37 import net.sf.json.JSONObject;
  38
  39 /**
  40  * Juju adapter manager service class.<br>
  41  * <p>
  42  * </p>
  43  *
  44  * @author
  45  * @version NFVO 0.5 Sep 12, 2016
  46  */
  47 public class JujuAdapterMgrService implements IJujuAdapterMgrService {
  48
  49     private static final Logger LOG = LoggerFactory.getLogger(JujuAdapterMgrService.class);
  50
  51     @Override
  52     public void register() {
  53         // set BUS URL and mothedtype
  54         Map<String, String> paramsMap = new HashMap<>();
  55         paramsMap.put("url", UrlConstant.REST_MSB_REGISTER);
  56         paramsMap.put("methodType", Constant.POST);
  57
  58         // get juju adapter info and raise registration
  59         try {
  60             String adapterInfo = readJujuAdapterInfoFromJson();
  61             if(!"".equals(adapterInfo)) {
  62                 JSONObject adapterObject = JSONObject.fromObject(adapterInfo);
  63                 RegisterJujuAdapterThread jujuAdapterThread = new RegisterJujuAdapterThread(paramsMap, adapterObject);
  64                 Executors.newSingleThreadExecutor().submit(jujuAdapterThread);
  65             } else {
  66                 LOG.error("JujuVnfmAdapter info is null,please check!", JujuAdapterMgrService.class);
  67             }
  68
  69         } catch(IOException e) {
  70             LOG.error("Failed to read JujuVnfmAdapter info!" + e, JujuAdapterMgrService.class);
  71         }
  72
  73     }
  74
  75     /**
  76      * Read juju adapter information from Json.<br>
  77      *
  78      * @return
  79      * @throws IOException
  80      * @since NFVO 0.5
  81      */
  82     public static String readJujuAdapterInfoFromJson() throws IOException {
  83         String fileContent = "";
  84
  85         String fileName = SystemEnvVariablesFactory.getInstance().getAppRoot()
  86                 + System.getProperty(Constant.FILE_SEPARATOR) + "etc" + System.getProperty(Constant.FILE_SEPARATOR)
  87                 + "adapterInfo" + System.getProperty(Constant.FILE_SEPARATOR) + Constant.JUJUADAPTERINFO;
  88
  89         try(
  90             InputStream ins = new FileInputStream(fileName);
  91             BufferedInputStream bins = new BufferedInputStream(ins)){
  92
  93             byte[] contentByte = new byte[ins.available()];
  94             int num = bins.read(contentByte);
  95
  96             if(num > 0) {
  97                 fileContent = new String(contentByte);
  98             }
  99         } catch(FileNotFoundException e) {
 100             LOG.error(fileName + "is not found!", e, JujuAdapterMgrService.class);
 101         }
 102
 103         return fileContent;
 104     }
 105
 106     private static class RegisterJujuAdapterThread implements Runnable {
 107
 108         // Thread lock Object
 109         private final Object lockObject = new Object();
 110
 111         private IJujuAdapter2MSBManager adapter2MSBMgr = new JujuAdapter2MSBManager();
 112
 113         // url and mothedtype
 114         private Map<String, String> paramsMap;
 115
 116         // driver body
 117         private JSONObject adapterInfo;
 118
 119         public RegisterJujuAdapterThread(Map<String, String> paramsMap, JSONObject adapterInfo) {
 120             this.paramsMap = paramsMap;
 121             this.adapterInfo = adapterInfo;
 122         }
 123
 124         @Override
 125         public void run() {
 126             LOG.info("start register jujuvnfmadapter", RegisterJujuAdapterThread.class);
 127
 128             if(paramsMap == null || adapterInfo == null) {
 129                 LOG.error("parameter is null,please check!", RegisterJujuAdapterThread.class);
 130                 return;
 131             }
 132
 133             // catch Runtime Exception
 134             try {
 135                 sendRequest(paramsMap, adapterInfo);
 136             } catch(RuntimeException e) {
 137                 LOG.error(e.getMessage(), e);
 138             }
 139
 140         }
 141
 142         private void sendRequest(Map<String, String> paramsMap, JSONObject driverInfo) {
 143             JSONObject resultObj = adapter2MSBMgr.registerJujuAdapter(paramsMap, driverInfo);
 144
 145             if(Integer.valueOf(resultObj.get("retCode").toString()) == Constant.HTTP_CREATED) {
 146                 LOG.info("JujuVnfmAdapter has now Successfully Registered to the Microservice BUS!",
 147                         JujuAdapterMgrService.class);
 148             } else {
 149                 LOG.error("JujuVnfmAdapter failed to  Register to the Microservice BUS! Reason:"
 150                         + resultObj.get("reason").toString() + " retCode:" + resultObj.get("retCode").toString());
 151
 152                 // if registration fails,wait one minute and try again
 153                 try {
 154                     synchronized(lockObject) {
 155                         lockObject.wait(Constant.REPEAT_REG_TIME);
 156                     }
 157                 } catch(InterruptedException e) {
 158                     LOG.error("sendRequest error", e);
 159                 }
 160
 161                 sendRequest(this.paramsMap, this.adapterInfo);
 162             }
 163
 164         }
 165
 166     }
 167
 168     @Override
 169     public void unregister() {
 170         // Not implemented
 171
 172     }
 173
 174     /**
 175      * Main method.<br>
 176      *
 177      * @param args
 178      * @since NFVO 0.5
 179      */
 180     public static void main(String[] args) {
 181         LOG.info(SystemEnvVariablesFactory.getInstance().getAppRoot() + System.getProperty(Constant.FILE_SEPARATOR)
 182                 + "etc" + System.getProperty(Constant.FILE_SEPARATOR) + "adapterInfo"
 183                 + System.getProperty(Constant.FILE_SEPARATOR) + Constant.JUJUADAPTERINFO);
 184     }
 185
 186 }