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
 105                         Long jobId = saveCreateVnfJob(vnfInstanceId);
 106                         driverResponse = responseConverter.createRspConvert(cbamResponse, jobId);
 107
 108                         vnfContinueProcessorInf.continueInstantiateVnf(driverRequest, vnfInstanceId, jobId.toString(), nslcmMgmr, catalogMgmr, cbamMgmr, requestConverter, jobDbManager);
 109
 110                 } catch (Exception e) {
 111                         logger.error("error VnfmDriverMgmrImpl --> instantiateVnf. ", e);
 112                         throw new VnfmDriverException(HttpStatus.SC_INTERNAL_SERVER_ERROR, CommonConstants.HTTP_ERROR_DESC_500);
 113                 }
 114
 115         return driverResponse;
 116         }
 117
 118         private Long saveCreateVnfJob(String vnfInstanceId) {
 119                 VnfmJobExecutionInfo jobInfo = new VnfmJobExecutionInfo();
 120                 jobInfo.setVnfInstanceId(vnfInstanceId);
 121                 jobInfo.setVnfmInterfceName(CommonConstants.NSLCM_OPERATION_INSTANTIATE);
 122                 jobInfo.setStatus(CommonConstants.CBAM_OPERATION_STATUS_START);
 123
 124                 VnfmJobExecutionInfo jobInfo1 = (VnfmJobExecutionInfo) jobDbManager.save(jobInfo);
 125                 Long jobId = jobInfo1.getJobId();
 126                 return jobId;
 127         }
 128
 129         public TerminateVnfResponse terminateVnf(TerminateVnfRequest driverRequest, String vnfmId, String vnfInstanceId) {
 130                 TerminateVnfResponse driverResponse;
 131                 try {
 132                         buildVnfmHttpPathById(vnfmId);
 133                         driverResponse = generateTerminateVnfResponse(vnfInstanceId);
 134                         String jobId = driverResponse.getJobId();
 135                         vnfContinueProcessorInf.continueTerminateVnf(driverRequest, vnfInstanceId, jobId, nslcmMgmr, cbamMgmr, requestConverter, jobDbManager);
 136
 137                 } catch (Exception e) {
 138                         logger.error("error VnfmDriverMgmrImpl --> terminateVnf. ", e);
 139                         throw new VnfmDriverException(HttpStatus.SC_INTERNAL_SERVER_ERROR, CommonConstants.HTTP_ERROR_DESC_500);
 140                 }
 141
 142         return driverResponse;
 143         }
 144
 145         private TerminateVnfResponse generateTerminateVnfResponse(String vnfInstanceId) {
 146                 VnfmJobExecutionInfo jobInfo = new VnfmJobExecutionInfo();
 147                 jobInfo.setVnfInstanceId(vnfInstanceId);
 148                 jobInfo.setVnfmInterfceName(CommonConstants.NSLCM_OPERATION_TERMINATE);
 149                 jobInfo.setStatus(CommonConstants.CBAM_OPERATION_STATUS_START);
 150
 151                 VnfmJobExecutionInfo jobInfo1=  jobDbManager.save(jobInfo);
 152                 Long jobId = jobInfo1.getJobId();
 153
 154                 TerminateVnfResponse response = new TerminateVnfResponse();
 155                 response.setJobId("" + jobId);
 156                 return response;
 157         }
 158
 159         public QueryVnfResponse queryVnf(String vnfmId, String vnfInstanceId) {
 160                 QueryVnfResponse driverResponse;
 161                 try {
 162                         buildVnfmHttpPathById(vnfmId);
 163                         CBAMQueryVnfResponse cbamResponse = cbamMgmr.queryVnf(vnfInstanceId);
 164                         driverResponse = responseConverter.queryRspConvert(cbamResponse);
 165                 } catch (Exception e) {
 166                         logger.error("error VnfmDriverMgmrImpl --> queryVnf. ", e);
 167                         throw new VnfmDriverException(HttpStatus.SC_INTERNAL_SERVER_ERROR, CommonConstants.HTTP_ERROR_DESC_500);
 168                 }
 169
 170         return driverResponse;
 171         }
 172
 173         public OperStatusVnfResponse getOperStatus(String vnfmId, String jobId)  throws VnfmDriverException {
 174
 175                 CBAMQueryOperExecutionResponse cbamResponse;
 176
 177                 try {
 178                         buildVnfmHttpPathById(vnfmId);
 179
 180                         VnfmJobExecutionInfo jobInfo = jobDbManager.findOne(Long.getLong(jobId));
 181                         String execId = jobInfo.getVnfmExecutionId();
 182                         cbamResponse = cbamMgmr.queryOperExecution(execId);
 183                 } catch (Exception e) {
 184                         logger.error("error VnfmDriverMgmrImpl --> getOperStatus. ", e);
 185                         throw new VnfmDriverException(HttpStatus.SC_INTERNAL_SERVER_ERROR, CommonConstants.HTTP_ERROR_DESC_500);
 186                 }
 187
 188                 OperStatusVnfResponse response = responseConverter.operRspConvert(cbamResponse);
 189
 190                 return response;
 191         }
 192
 193         public ScaleVnfResponse scaleVnf(ScaleVnfRequest driverRequest, String vnfmId, String vnfInstanceId) throws VnfmDriverException {
 194                 ScaleVnfResponse driverResponse;
 195                 try {
 196                         buildVnfmHttpPathById(vnfmId);
 197                         CBAMScaleVnfRequest cbamRequest = requestConverter.scaleReqconvert(driverRequest);
 198                         CBAMScaleVnfResponse cbamResponse = cbamMgmr.scaleVnf(cbamRequest, vnfInstanceId);
 199                         driverResponse = responseConverter.scaleRspConvert(cbamResponse);
 200                 } catch (Exception e) {
 201                         logger.error("error VnfmDriverMgmrImpl --> scaleVnf. ", e);
 202                         throw new VnfmDriverException(HttpStatus.SC_INTERNAL_SERVER_ERROR, CommonConstants.HTTP_ERROR_DESC_500);
 203                 }
 204
 205         return driverResponse;
 206         }
 207
 208         public HealVnfResponse healVnf(HealVnfRequest driverRequest, String vnfmId, String vnfInstanceId) throws VnfmDriverException {
 209                 HealVnfResponse driverResponse;
 210                 try {
 211                         buildVnfmHttpPathById(vnfmId);
 212                         CBAMHealVnfRequest cbamRequest = requestConverter.healReqConvert(driverRequest);
 213                         CBAMHealVnfResponse cbamResponse = cbamMgmr.healVnf(cbamRequest, vnfInstanceId);
 214                         driverResponse = responseConverter.healRspConvert(cbamResponse);
 215                 } catch (Exception e) {
 216                         logger.error("error VnfmDriverMgmrImpl --> healVnf. ", e);
 217                         throw new VnfmDriverException(HttpStatus.SC_INTERNAL_SERVER_ERROR, CommonConstants.HTTP_ERROR_DESC_500);
 218                 }
 219
 220         return driverResponse;
 221         }
 222
 223         public String buildVnfmHttpPathById(String vnfmId) throws ClientProtocolException, IOException, VnfmDriverException {
 224
 225                 return null;
 226         }
 227
 228         public String buildVnfmHttpPathByRealId(String vnfmId) throws ClientProtocolException, IOException, VnfmDriverException {
 229                 AaiVnfmInfo vnfmInfo = aaiMgmr.queryVnfm(vnfmId);
 230                 logger.info("vnfmInfo in AAI is {}", gson.toJson(vnfmInfo));
 231                 if(isVnfmInfoValid(vnfmId, vnfmInfo))
 232                 {
 233                         throw new VnfmDriverException(HttpStatus.SC_INTERNAL_SERVER_ERROR, CommonConstants.HTTP_ERROR_DESC_500);
 234                 }
 235
 236                 EsrSystemInfo systemInfo = vnfmInfo.getEsrSystemInfoList().get(0);
 237
 238                 String urlHead = systemInfo.getServiceUrl();
 239                 adaptorEnv.setCbamApiUriFront(urlHead);
 240                 adaptorEnv.setCbamUserName(systemInfo.getUserName());
 241                 adaptorEnv.setCbamPassword(systemInfo.getPassword());
 242
 243                 return urlHead;
 244         }
 245
 246         private boolean isVnfmInfoValid(String vnfmId, AaiVnfmInfo vnfmInfo) {
 247                 return vnfmInfo == null || vnfmInfo.getEsrSystemInfoList() == null || vnfmInfo.getEsrSystemInfoList().isEmpty();
 248         }
 249
 250         public void setRequestConverter(Driver2CbamRequestConverter requestConverter) {
 251                 this.requestConverter = requestConverter;
 252         }
 253
 254         public void setResponseConverter(Cbam2DriverResponseConverter responseConverter) {
 255                 this.responseConverter = responseConverter;
 256         }
 257
 258 }