nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/adaptor/VnfmDriverMgmrImpl.java

   1 /*
   2  * Copyright 2016-2017, Nokia Corporation
   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.driver.vnfm.svnfm.adaptor;
  18
  19 import java.io.IOException;
  20
  21 import org.apache.http.HttpStatus;
  22 import org.apache.http.client.ClientProtocolException;
  23 import org.onap.vfc.nfvo.driver.vnfm.svnfm.aai.bo.AaiVnfmInfo;
  24 import org.onap.vfc.nfvo.driver.vnfm.svnfm.aai.bo.entity.EsrSystemInfo;
  25 import org.onap.vfc.nfvo.driver.vnfm.svnfm.aai.inf.AaiMgmrInf;
  26 import org.onap.vfc.nfvo.driver.vnfm.svnfm.catalog.inf.CatalogMgmrInf;
  27 import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.CBAMCreateVnfRequest;
  28 import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.CBAMCreateVnfResponse;
  29 import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.CBAMHealVnfRequest;
  30 import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.CBAMHealVnfResponse;
  31 import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.CBAMQueryVnfResponse;
  32 import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.CBAMScaleVnfRequest;
  33 import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.CBAMScaleVnfResponse;
  34 import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.entity.OperationExecution;
  35 import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.entity.OperationExecution.OperationType;
  36 import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.inf.CbamMgmrInf;
  37 import org.onap.vfc.nfvo.driver.vnfm.svnfm.common.bo.AdaptorEnv;
  38 import org.onap.vfc.nfvo.driver.vnfm.svnfm.constant.CommonConstants;
  39 import org.onap.vfc.nfvo.driver.vnfm.svnfm.constant.CommonEnum;
  40 import org.onap.vfc.nfvo.driver.vnfm.svnfm.db.bean.VnfmJobExecutionInfo;
  41 import org.onap.vfc.nfvo.driver.vnfm.svnfm.db.repository.VnfmJobExecutionRepository;
  42 import org.onap.vfc.nfvo.driver.vnfm.svnfm.exception.VnfmDriverException;
  43 import org.onap.vfc.nfvo.driver.vnfm.svnfm.nslcm.inf.NslcmMgmrInf;
  44 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.HealVnfRequest;
  45 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.HealVnfResponse;
  46 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.InstantiateVnfRequest;
  47 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.InstantiateVnfResponse;
  48 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.OperStatusVnfResponse;
  49 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.QueryVnfResponse;
  50 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.ScaleVnfRequest;
  51 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.ScaleVnfResponse;
  52 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.TerminateVnfRequest;
  53 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.TerminateVnfResponse;
  54 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.inf.VnfContinueProcessorInf;
  55 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.inf.VnfmDriverMgmrInf;
  56 import org.slf4j.Logger;
  57 import org.slf4j.LoggerFactory;
  58 import org.springframework.beans.factory.annotation.Autowired;
  59 import org.springframework.stereotype.Component;
  60
  61 import com.google.gson.Gson;
  62
  63
  64 @Component
  65 public class VnfmDriverMgmrImpl implements VnfmDriverMgmrInf{
  66         private static final Logger logger = LoggerFactory.getLogger(VnfmDriverMgmrImpl.class);
  67
  68         @Autowired
  69         Driver2CbamRequestConverter requestConverter;
  70
  71         @Autowired
  72         Cbam2DriverResponseConverter responseConverter;
  73
  74         @Autowired
  75         private CbamMgmrInf cbamMgmr;
  76
  77         @Autowired
  78         private CatalogMgmrInf catalogMgmr;
  79
  80         @Autowired
  81         private NslcmMgmrInf nslcmMgmr;
  82
  83         @Autowired
  84         private AaiMgmrInf aaiMgmr;
  85
  86         @Autowired
  87         private VnfmJobExecutionRepository jobDbManager;
  88
  89         @Autowired
  90         AdaptorEnv adaptorEnv;
  91
  92         @Autowired
  93         private VnfContinueProcessorInf vnfContinueProcessorInf;
  94
  95         private Gson gson = new Gson();
  96
  97         public InstantiateVnfResponse instantiateVnf(InstantiateVnfRequest driverRequest, String vnfmId) throws VnfmDriverException {
  98                 InstantiateVnfResponse driverResponse;
  99                 try {
 100                         driverRequest.setVnfdId(adaptorEnv.getVnfdId());
 101                         buildVnfmHttpPathById(vnfmId);
 102
 103 //                      String dirPath = "/etc/vnfmpkg";
 104 //                      String cbamDirName = CommonUtil.getAppRoot() + dirPath;
 105 //                      File cbamDirFile = new File(cbamDirName);
 106 //                      String cbamPackageName = cbamDirFile.listFiles()[0].getAbsolutePath();
 107 //                      cbamMgmr.uploadVnfPackage(cbamPackageName);
 108
 109                         //step 3: create vnf
 110                         CBAMCreateVnfRequest cbamRequest = requestConverter.createReqConvert(driverRequest);
 111                         CBAMCreateVnfResponse cbamResponse = cbamMgmr.createVnf(cbamRequest);
 112                         String vnfInstanceId = cbamResponse.getId();
 113
 114                         Long jobId = saveCreateVnfJob(vnfInstanceId);
 115                         driverResponse = responseConverter.createRspConvert(cbamResponse, jobId);
 116
 117                         //start the timer
 118                         OperateTaskProgress.startInstantiateTimerTask();
 119
 120                         vnfContinueProcessorInf.continueInstantiateVnf(vnfmId, driverRequest, vnfInstanceId, jobId.toString(), nslcmMgmr, catalogMgmr, cbamMgmr, requestConverter, jobDbManager);
 121
 122                 } catch (Exception e) {
 123                         logger.error("error VnfmDriverMgmrImpl --> instantiateVnf. ", e);
 124                         throw new VnfmDriverException(HttpStatus.SC_INTERNAL_SERVER_ERROR, CommonConstants.HTTP_ERROR_DESC_500);
 125                 }
 126
 127         return driverResponse;
 128         }
 129
 130         private Long saveCreateVnfJob(String vnfInstanceId) {
 131                 VnfmJobExecutionInfo jobInfo = new VnfmJobExecutionInfo();
 132                 jobInfo.setVnfInstanceId(vnfInstanceId);
 133                 jobInfo.setVnfmInterfceName(CommonConstants.NSLCM_OPERATION_INSTANTIATE);
 134                 jobInfo.setStatus(CommonConstants.CBAM_OPERATION_STATUS_START);
 135
 136                 VnfmJobExecutionInfo jobInfo1 = (VnfmJobExecutionInfo) jobDbManager.save(jobInfo);
 137                 Long jobId = jobInfo1.getJobId();
 138                 return jobId;
 139         }
 140
 141         public TerminateVnfResponse terminateVnf(TerminateVnfRequest driverRequest, String vnfmId, String vnfInstanceId) {
 142                 TerminateVnfResponse driverResponse;
 143                 try {
 144                         buildVnfmHttpPathById(vnfmId);
 145                         driverResponse = generateTerminateVnfResponse(vnfInstanceId);
 146                         String jobId = driverResponse.getJobId();
 147
 148                         //start the timer
 149                         OperateTaskProgress.startTerminateTimerTask();
 150                         vnfContinueProcessorInf.continueTerminateVnf(vnfmId, driverRequest, vnfInstanceId, jobId, nslcmMgmr, cbamMgmr, requestConverter, jobDbManager);
 151
 152                 } catch (Exception e) {
 153                         logger.error("error VnfmDriverMgmrImpl --> terminateVnf. ", e);
 154                         throw new VnfmDriverException(HttpStatus.SC_INTERNAL_SERVER_ERROR, CommonConstants.HTTP_ERROR_DESC_500);
 155                 }
 156
 157         return driverResponse;
 158         }
 159
 160         private TerminateVnfResponse generateTerminateVnfResponse(String vnfInstanceId) {
 161                 VnfmJobExecutionInfo jobInfo = new VnfmJobExecutionInfo();
 162                 jobInfo.setVnfInstanceId(vnfInstanceId);
 163                 jobInfo.setVnfmInterfceName(CommonConstants.NSLCM_OPERATION_TERMINATE);
 164                 jobInfo.setStatus(CommonConstants.CBAM_OPERATION_STATUS_START);
 165
 166                 VnfmJobExecutionInfo jobInfo1=  jobDbManager.save(jobInfo);
 167                 Long jobId = jobInfo1.getJobId();
 168
 169                 TerminateVnfResponse response = new TerminateVnfResponse();
 170                 response.setJobId("" + jobId);
 171                 return response;
 172         }
 173
 174         public QueryVnfResponse queryVnf(String vnfmId, String vnfInstanceId) {
 175                 QueryVnfResponse driverResponse;
 176                 try {
 177                         buildVnfmHttpPathById(vnfmId);
 178                         CBAMQueryVnfResponse cbamResponse = cbamMgmr.queryVnf(vnfInstanceId);
 179                         driverResponse = responseConverter.queryRspConvert(cbamResponse);
 180                 } catch (Exception e) {
 181                         logger.error("error VnfmDriverMgmrImpl --> queryVnf. ", e);
 182                         throw new VnfmDriverException(HttpStatus.SC_INTERNAL_SERVER_ERROR, CommonConstants.HTTP_ERROR_DESC_500);
 183                 }
 184
 185         return driverResponse;
 186         }
 187
 188         public OperStatusVnfResponse getOperStatus(String vnfmId, String jobId)  throws VnfmDriverException {
 189
 190                 OperationExecution cbamResponse = null;
 191
 192                 try {
 193                         buildVnfmHttpPathById(vnfmId);
 194
 195                         VnfmJobExecutionInfo jobInfo = jobDbManager.findOne(Long.parseLong(jobId));
 196                         cbamResponse = new OperationExecution();
 197
 198                         if("Instantiate".equalsIgnoreCase(jobInfo.getVnfmInterfceName())) {
 199                                 cbamResponse.setOperationType(OperationType.INSTANTIATE);
 200                         }
 201                         else
 202                         {
 203                                 cbamResponse.setOperationType(OperationType.TERMINATE);
 204                         }
 205
 206                         if(jobInfo.getStatus().equalsIgnoreCase(CommonConstants.CBAM_OPERATION_STATUS_FINISH))
 207                         {
 208                                 cbamResponse.setStatus(CommonEnum.OperationStatus.FINISHED);
 209                         } else if(jobInfo.getStatus().equalsIgnoreCase(CommonConstants.CBAM_OPERATION_STATUS_ERROR))
 210                         {
 211                                 cbamResponse.setStatus(CommonEnum.OperationStatus.FINISHED);
 212                         }
 213                         else
 214                         {
 215                                 cbamResponse.setStatus(CommonEnum.OperationStatus.OTHER);
 216 //                              String execId = jobInfo.getVnfmExecutionId();
 217 //                              logger.info(" VnfmDriverMgmrImpl --> getOperStatus execId is " + execId);
 218 //                              cbamResponse = cbamMgmr.queryOperExecution(execId);
 219                         }
 220
 221                 } catch (Exception e) {
 222                         logger.error("error VnfmDriverMgmrImpl --> getOperStatus. ", e);
 223                         throw new VnfmDriverException(HttpStatus.SC_INTERNAL_SERVER_ERROR, CommonConstants.HTTP_ERROR_DESC_500);
 224                 }
 225
 226                 OperStatusVnfResponse response = responseConverter.operRspConvert(cbamResponse);
 227                 response.setJobId(jobId);
 228
 229                 return response;
 230         }
 231
 232         public ScaleVnfResponse scaleVnf(ScaleVnfRequest driverRequest, String vnfmId, String vnfInstanceId) throws VnfmDriverException {
 233                 ScaleVnfResponse driverResponse;
 234                 try {
 235                         buildVnfmHttpPathById(vnfmId);
 236                         CBAMScaleVnfRequest cbamRequest = requestConverter.scaleReqconvert(driverRequest);
 237                         CBAMScaleVnfResponse cbamResponse = cbamMgmr.scaleVnf(cbamRequest, vnfInstanceId);
 238                         driverResponse = responseConverter.scaleRspConvert(cbamResponse);
 239                 } catch (Exception e) {
 240                         logger.error("error VnfmDriverMgmrImpl --> scaleVnf. ", e);
 241                         throw new VnfmDriverException(HttpStatus.SC_INTERNAL_SERVER_ERROR, CommonConstants.HTTP_ERROR_DESC_500);
 242                 }
 243
 244         return driverResponse;
 245         }
 246
 247         public HealVnfResponse healVnf(HealVnfRequest driverRequest, String vnfmId, String vnfInstanceId) throws VnfmDriverException {
 248                 HealVnfResponse driverResponse;
 249                 try {
 250                         buildVnfmHttpPathById(vnfmId);
 251                         CBAMHealVnfRequest cbamRequest = requestConverter.healReqConvert(driverRequest);
 252                         CBAMHealVnfResponse cbamResponse = cbamMgmr.healVnf(cbamRequest, vnfInstanceId);
 253                         driverResponse = responseConverter.healRspConvert(cbamResponse);
 254                 } catch (Exception e) {
 255                         logger.error("error VnfmDriverMgmrImpl --> healVnf. ", e);
 256                         throw new VnfmDriverException(HttpStatus.SC_INTERNAL_SERVER_ERROR, CommonConstants.HTTP_ERROR_DESC_500);
 257                 }
 258
 259         return driverResponse;
 260         }
 261
 262         public String buildVnfmHttpPathById(String vnfmId) {
 263                 String result = "";
 264                 try {
 265                         result = buildVnfmHttpPathByRealId(vnfmId);
 266                 } catch (Exception e) {
 267                         logger.error("buildVnfmHttpPathById Error.", e);
 268                 }
 269                 return result;
 270         }
 271
 272         public String buildVnfmHttpPathByRealId(String vnfmId) throws ClientProtocolException, IOException, VnfmDriverException {
 273                 AaiVnfmInfo vnfmInfo = aaiMgmr.queryVnfm(vnfmId);
 274                 logger.info("vnfmInfo in AAI is " + gson.toJson(vnfmInfo));
 275                 if(isVnfmInfoValid(vnfmId, vnfmInfo))
 276                 {
 277                         throw new VnfmDriverException(HttpStatus.SC_INTERNAL_SERVER_ERROR, CommonConstants.HTTP_ERROR_DESC_500);
 278                 }
 279
 280                 EsrSystemInfo systemInfo = vnfmInfo.getEsrSystemInfoList().get(0);
 281
 282                 String urlHead = systemInfo.getServiceUrl();
 283 //              adaptorEnv.setCbamApiUriFront(urlHead);
 284 //              adaptorEnv.setCbamUserName(systemInfo.getUserName());
 285 //              adaptorEnv.setCbamPassword(systemInfo.getPassword());
 286
 287                 return urlHead;
 288         }
 289
 290         private boolean isVnfmInfoValid(String vnfmId, AaiVnfmInfo vnfmInfo) {
 291                 return vnfmInfo == null || vnfmInfo.getEsrSystemInfoList() == null || vnfmInfo.getEsrSystemInfoList().isEmpty();
 292         }
 293
 294         public void setRequestConverter(Driver2CbamRequestConverter requestConverter) {
 295                 this.requestConverter = requestConverter;
 296         }
 297
 298         public void setResponseConverter(Cbam2DriverResponseConverter responseConverter) {
 299                 this.responseConverter = responseConverter;
 300         }
 301
 302 }