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

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