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.CBAMQueryOperExecutionResponse;
  32 import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.CBAMQueryVnfResponse;
  33 import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.CBAMScaleVnfRequest;
  34 import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.CBAMScaleVnfResponse;
  35 import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.inf.CbamMgmrInf;
  36 import org.onap.vfc.nfvo.driver.vnfm.svnfm.common.bo.AdaptorEnv;
  37 import org.onap.vfc.nfvo.driver.vnfm.svnfm.constant.CommonConstants;
  38 import org.onap.vfc.nfvo.driver.vnfm.svnfm.db.bean.VnfmJobExecutionInfo;
  39 import org.onap.vfc.nfvo.driver.vnfm.svnfm.db.repository.VnfmJobExecutionRepository;
  40 import org.onap.vfc.nfvo.driver.vnfm.svnfm.exception.VnfmDriverException;
  41 import org.onap.vfc.nfvo.driver.vnfm.svnfm.nslcm.inf.NslcmMgmrInf;
  42 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.HealVnfRequest;
  43 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.HealVnfResponse;
  44 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.InstantiateVnfRequest;
  45 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.InstantiateVnfResponse;
  46 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.OperStatusVnfResponse;
  47 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.QueryVnfResponse;
  48 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.ScaleVnfRequest;
  49 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.ScaleVnfResponse;
  50 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.TerminateVnfRequest;
  51 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.TerminateVnfResponse;
  52 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.inf.VnfContinueProcessorInf;
  53 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.inf.VnfmDriverMgmrInf;
  54 import org.slf4j.Logger;
  55 import org.slf4j.LoggerFactory;
  56 import org.springframework.beans.factory.annotation.Autowired;
  57 import org.springframework.stereotype.Component;
  58
  59 import com.google.gson.Gson;
  60
  61
  62 @Component
  63 public class VnfmDriverMgmrImpl implements VnfmDriverMgmrInf{
  64         private static final Logger logger = LoggerFactory.getLogger(VnfmDriverMgmrImpl.class);
  65
  66         @Autowired
  67         Driver2CbamRequestConverter requestConverter;
  68
  69         @Autowired
  70         Cbam2DriverResponseConverter responseConverter;
  71
  72         @Autowired
  73         private CbamMgmrInf cbamMgmr;
  74
  75         @Autowired
  76         private CatalogMgmrInf catalogMgmr;
  77
  78         @Autowired
  79         private NslcmMgmrInf nslcmMgmr;
  80
  81         @Autowired
  82         private AaiMgmrInf aaiMgmr;
  83
  84         @Autowired
  85         private VnfmJobExecutionRepository jobDbManager;
  86
  87         @Autowired
  88         AdaptorEnv adaptorEnv;
  89
  90         @Autowired
  91         private VnfContinueProcessorInf vnfContinueProcessorInf;
  92
  93         private Gson gson = new Gson();
  94
  95         public InstantiateVnfResponse instantiateVnf(InstantiateVnfRequest driverRequest, String vnfmId) throws VnfmDriverException {
  96                 InstantiateVnfResponse driverResponse;
  97                 try {
  98                         buildVnfmHttpPathById(vnfmId);
  99
 100                         //step 3: create vnf
 101                         CBAMCreateVnfRequest cbamRequest = requestConverter.createReqConvert(driverRequest);
 102                         CBAMCreateVnfResponse cbamResponse = cbamMgmr.createVnf(cbamRequest);
 103                         String vnfInstanceId = cbamResponse.getId();
 104                         Long jobId = saveCreateVnfJob(vnfInstanceId);
 105                         driverResponse = responseConverter.createRspConvert(cbamResponse, jobId);
 106
 107                         vnfContinueProcessorInf.continueInstantiateVnf(driverRequest, vnfInstanceId, jobId.toString(), nslcmMgmr, catalogMgmr, cbamMgmr, requestConverter, jobDbManager);
 108
 109                 } catch (Exception e) {
 110                         logger.error("error VnfmDriverMgmrImpl --> instantiateVnf. ", e);
 111                         throw new VnfmDriverException(HttpStatus.SC_INTERNAL_SERVER_ERROR, CommonConstants.HTTP_ERROR_DESC_500);
 112                 }
 113
 114         return driverResponse;
 115         }
 116
 117         private Long saveCreateVnfJob(String vnfInstanceId) {
 118                 VnfmJobExecutionInfo jobInfo = new VnfmJobExecutionInfo();
 119                 jobInfo.setVnfInstanceId(vnfInstanceId);
 120                 jobInfo.setVnfmInterfceName(CommonConstants.NSLCM_OPERATION_INSTANTIATE);
 121                 jobInfo.setStatus(CommonConstants.CBAM_OPERATION_STATUS_START);
 122
 123                 VnfmJobExecutionInfo jobInfo1 = (VnfmJobExecutionInfo) jobDbManager.save(jobInfo);
 124                 Long jobId = jobInfo1.getJobId();
 125                 return jobId;
 126         }
 127
 128         public TerminateVnfResponse terminateVnf(TerminateVnfRequest driverRequest, String vnfmId, String vnfInstanceId) {
 129                 TerminateVnfResponse driverResponse;
 130                 try {
 131                         buildVnfmHttpPathById(vnfmId);
 132                         driverResponse = generateTerminateVnfResponse(vnfInstanceId);
 133                         String jobId = driverResponse.getJobId();
 134                         vnfContinueProcessorInf.continueTerminateVnf(driverRequest, vnfInstanceId, jobId, nslcmMgmr, cbamMgmr, requestConverter, jobDbManager);
 135
 136                 } catch (Exception e) {
 137                         logger.error("error VnfmDriverMgmrImpl --> terminateVnf. ", e);
 138                         throw new VnfmDriverException(HttpStatus.SC_INTERNAL_SERVER_ERROR, CommonConstants.HTTP_ERROR_DESC_500);
 139                 }
 140
 141         return driverResponse;
 142         }
 143
 144         private TerminateVnfResponse generateTerminateVnfResponse(String vnfInstanceId) {
 145                 VnfmJobExecutionInfo jobInfo = new VnfmJobExecutionInfo();
 146                 jobInfo.setVnfInstanceId(vnfInstanceId);
 147                 jobInfo.setVnfmInterfceName(CommonConstants.NSLCM_OPERATION_TERMINATE);
 148                 jobInfo.setStatus(CommonConstants.CBAM_OPERATION_STATUS_START);
 149
 150                 VnfmJobExecutionInfo jobInfo1=  jobDbManager.save(jobInfo);
 151                 Long jobId = jobInfo1.getJobId();
 152
 153                 TerminateVnfResponse response = new TerminateVnfResponse();
 154                 response.setJobId("" + jobId);
 155                 return response;
 156         }
 157
 158         public QueryVnfResponse queryVnf(String vnfmId, String vnfInstanceId) {
 159                 QueryVnfResponse driverResponse;
 160                 try {
 161                         buildVnfmHttpPathById(vnfmId);
 162                         CBAMQueryVnfResponse cbamResponse = cbamMgmr.queryVnf(vnfInstanceId);
 163                         driverResponse = responseConverter.queryRspConvert(cbamResponse);
 164                 } catch (Exception e) {
 165                         logger.error("error VnfmDriverMgmrImpl --> queryVnf. ", e);
 166                         throw new VnfmDriverException(HttpStatus.SC_INTERNAL_SERVER_ERROR, CommonConstants.HTTP_ERROR_DESC_500);
 167                 }
 168
 169         return driverResponse;
 170         }
 171
 172         public OperStatusVnfResponse getOperStatus(String vnfmId, String jobId)  throws VnfmDriverException {
 173
 174                 CBAMQueryOperExecutionResponse cbamResponse;
 175
 176                 try {
 177                         buildVnfmHttpPathById(vnfmId);
 178
 179                         VnfmJobExecutionInfo jobInfo = jobDbManager.findOne(Long.getLong(jobId));
 180                         String execId = jobInfo.getVnfmExecutionId();
 181                         cbamResponse = cbamMgmr.queryOperExecution(execId);
 182                 } catch (Exception e) {
 183                         logger.error("error VnfmDriverMgmrImpl --> getOperStatus. ", e);
 184                         throw new VnfmDriverException(HttpStatus.SC_INTERNAL_SERVER_ERROR, CommonConstants.HTTP_ERROR_DESC_500);
 185                 }
 186
 187                 OperStatusVnfResponse response = responseConverter.operRspConvert(cbamResponse);
 188
 189                 return response;
 190         }
 191
 192         public ScaleVnfResponse scaleVnf(ScaleVnfRequest driverRequest, String vnfmId, String vnfInstanceId) throws VnfmDriverException {
 193                 ScaleVnfResponse driverResponse;
 194                 try {
 195                         buildVnfmHttpPathById(vnfmId);
 196                         CBAMScaleVnfRequest cbamRequest = requestConverter.scaleReqconvert(driverRequest);
 197                         CBAMScaleVnfResponse cbamResponse = cbamMgmr.scaleVnf(cbamRequest, vnfInstanceId);
 198                         driverResponse = responseConverter.scaleRspConvert(cbamResponse);
 199                 } catch (Exception e) {
 200                         logger.error("error VnfmDriverMgmrImpl --> scaleVnf. ", e);
 201                         throw new VnfmDriverException(HttpStatus.SC_INTERNAL_SERVER_ERROR, CommonConstants.HTTP_ERROR_DESC_500);
 202                 }
 203
 204         return driverResponse;
 205         }
 206
 207         public HealVnfResponse healVnf(HealVnfRequest driverRequest, String vnfmId, String vnfInstanceId) throws VnfmDriverException {
 208                 HealVnfResponse driverResponse;
 209                 try {
 210                         buildVnfmHttpPathById(vnfmId);
 211                         CBAMHealVnfRequest cbamRequest = requestConverter.healReqConvert(driverRequest);
 212                         CBAMHealVnfResponse cbamResponse = cbamMgmr.healVnf(cbamRequest, vnfInstanceId);
 213                         driverResponse = responseConverter.healRspConvert(cbamResponse);
 214                 } catch (Exception e) {
 215                         logger.error("error VnfmDriverMgmrImpl --> healVnf. ", e);
 216                         throw new VnfmDriverException(HttpStatus.SC_INTERNAL_SERVER_ERROR, CommonConstants.HTTP_ERROR_DESC_500);
 217                 }
 218
 219         return driverResponse;
 220         }
 221
 222         public String buildVnfmHttpPathById(String vnfmId) throws ClientProtocolException, IOException, VnfmDriverException {
 223                 AaiVnfmInfo vnfmInfo = aaiMgmr.queryVnfm(vnfmId);
 224                 logger.info("vnfmInfo in AAI is {}", gson.toJson(vnfmInfo));
 225                 if(isVnfmInfoValid(vnfmId, vnfmInfo))
 226                 {
 227                         throw new VnfmDriverException(HttpStatus.SC_INTERNAL_SERVER_ERROR, CommonConstants.HTTP_ERROR_DESC_500);
 228                 }
 229
 230                 EsrSystemInfo systemInfo = vnfmInfo.getEsrSystemInfoList().get(0);
 231
 232                 String urlHead = systemInfo.getServiceUrl();
 233                 adaptorEnv.setCbamApiUriFront(urlHead);
 234                 return urlHead;
 235         }
 236
 237         private boolean isVnfmInfoValid(String vnfmId, AaiVnfmInfo vnfmInfo) {
 238                 return vnfmInfo == null || !vnfmId.equalsIgnoreCase(vnfmInfo.getVnfmId()) || vnfmInfo.getEsrSystemInfoList() == null || vnfmInfo.getEsrSystemInfoList().isEmpty();
 239         }
 240
 241         public void setRequestConverter(Driver2CbamRequestConverter requestConverter) {
 242                 this.requestConverter = requestConverter;
 243         }
 244
 245         public void setResponseConverter(Cbam2DriverResponseConverter responseConverter) {
 246                 this.responseConverter = responseConverter;
 247         }
 248
 249 }