huawei/vnfmadapter/VnfmadapterService/service/src/main/java/org/onap/vfc/nfvo/vnfm/svnfm/vnfmadapter/service/api/internalsvc/impl/VnfmAdapterMgrService.java

   1 /*
   2  * Copyright 2016-2017 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.svnfm.vnfmadapter.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.svnfm.vnfmadapter.common.restclient.SystemEnvVariablesFactory;
  29 import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.service.adapter.impl.Driver2MSBManager;
  30 import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.service.adapter.inf.IDriver2MSBManager;
  31 import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.service.api.internalsvc.inf.IVnfmAdapterMgrService;
  32 import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.service.constant.Constant;
  33 import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.service.constant.UrlConstant;
  34 import org.slf4j.Logger;
  35 import org.slf4j.LoggerFactory;
  36
  37 import net.sf.json.JSONObject;
  38
  39 /**
  40  * <br/>
  41  * <p>
  42  * </p>
  43  *
  44  * @author
  45  * @version VFC 1.0 Aug 31, 2016
  46  */
  47 public class VnfmAdapterMgrService implements IVnfmAdapterMgrService {
  48
  49     private static final Logger LOG = LoggerFactory.getLogger(VnfmAdapterMgrService.class);
  50
  51     public static final String VNFMADAPTERINFO = "vnfmadapterinfo.json";
  52
  53     @Override
  54     public void register() {
  55         // set BUS URL and mothedtype
  56         Map<String, String> paramsMap = new HashMap<>();
  57         paramsMap.put("url", UrlConstant.REST_MSB_REGISTER);
  58         paramsMap.put("methodType", Constant.POST);
  59
  60         // get vim adapter info and raise registration
  61         try {
  62             String adapterInfo = readVnfmAdapterInfoFromJson();
  63             if(!"".equals(adapterInfo)) {
  64                 JSONObject adapterObject = JSONObject.fromObject(adapterInfo);
  65                 RegisterVnfmAdapterThread vnfmAdapterThread = new RegisterVnfmAdapterThread(paramsMap, adapterObject);
  66                 Executors.newSingleThreadExecutor().submit(vnfmAdapterThread);
  67             } else {
  68                 LOG.error("VnfmAdapter info is null,please check!");
  69             }
  70
  71         } catch(IOException e) {
  72             LOG.error("Failed to read VnfmAdapter info! " + e.getMessage(), e);
  73         }
  74
  75     }
  76
  77     /**
  78      * Retrieve VIM driver information.
  79      *
  80      * @return
  81      * @throws IOException
  82      */
  83     public String readVnfmAdapterInfoFromJson() throws IOException {
  84         String fileContent = "";
  85
  86         String fileName = SystemEnvVariablesFactory.getInstance().getAppRoot()
  87                 + System.getProperty(Constant.FILE_SEPARATOR) + "etc" + System.getProperty(Constant.FILE_SEPARATOR)
  88                 + "adapterInfo" + System.getProperty(Constant.FILE_SEPARATOR) + VNFMADAPTERINFO;
  89
  90         try (InputStream ins = new FileInputStream(fileName)) {
  91             try (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             }
 100         } catch(FileNotFoundException e) {
 101             LOG.error(fileName + "is not found!", e);
 102         }
 103
 104         return fileContent;
 105     }
 106
 107     private static class RegisterVnfmAdapterThread implements Runnable {
 108
 109         private IDriver2MSBManager adapter2MSBMgr = new Driver2MSBManager();
 110
 111         // url and mothedtype
 112         private Map<String, String> paramsMap;
 113
 114         // driver body
 115         private JSONObject adapterInfo;
 116
 117         public RegisterVnfmAdapterThread(Map<String, String> paramsMap, JSONObject adapterInfo) {
 118             this.paramsMap = paramsMap;
 119             this.adapterInfo = adapterInfo;
 120         }
 121
 122         @Override
 123         public void run() {
 124             LOG.info("start register vnfmadapter", RegisterVnfmAdapterThread.class);
 125
 126             if(paramsMap == null || adapterInfo == null) {
 127                 LOG.error("parameter is null,please check!", RegisterVnfmAdapterThread.class);
 128                 return;
 129             }
 130
 131             // catch Runtime Exception
 132             try {
 133                 sendRequest(paramsMap, adapterInfo);
 134             } catch(RuntimeException e) {
 135                 LOG.error(e.getMessage(), e);
 136             }
 137
 138         }
 139
 140         private void sendRequest(Map<String, String> paramsMap, JSONObject driverInfo) {
 141             JSONObject resultObj = adapter2MSBMgr.registerDriver(paramsMap, driverInfo);
 142
 143             if(Integer.valueOf(resultObj.get(Constant.RETCODE).toString()) == Constant.HTTP_CREATED) {
 144                 LOG.info("Vnfmadapter has now Successfully Registered to the Microservice BUS!");
 145             } else {
 146                 LOG.error("Vnfmadapter failed to  Register to the Microservice BUS! Reason:"
 147                         + resultObj.get(Constant.REASON).toString() + " retCode:"
 148                         + resultObj.get(Constant.RETCODE).toString());
 149
 150                 // if registration fails,wait one minute and try again
 151                 try {
 152                     Thread.sleep(Constant.REPEAT_REG_TIME);
 153                 } catch(InterruptedException e) {
 154                     LOG.error(e.getMessage(), e);
 155                     // Restore interrupted state...
 156                     Thread.currentThread().interrupt();
 157                 }
 158
 159                 sendRequest(this.paramsMap, this.adapterInfo);
 160             }
 161
 162         }
 163
 164     }
 165
 166     @Override
 167     public void unregister() {
 168         // unregister
 169     }
 170
 171 }