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.CBAMCreateSubscriptionResponse;
  28 import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.CBAMCreateVnfRequest;
  29 import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.CBAMCreateVnfResponse;
  30 import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.CBAMQueryVnfResponse;
  31 import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.entity.OperationExecution;
  32 import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.entity.OperationExecution.OperationType;
  33 import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.inf.CbamMgmrInf;
  34 import org.onap.vfc.nfvo.driver.vnfm.svnfm.common.bo.AdaptorEnv;
  35 import org.onap.vfc.nfvo.driver.vnfm.svnfm.constant.CommonConstants;
  36 import org.onap.vfc.nfvo.driver.vnfm.svnfm.constant.CommonEnum;
  37 import org.onap.vfc.nfvo.driver.vnfm.svnfm.constant.ScaleType;
  38 import org.onap.vfc.nfvo.driver.vnfm.svnfm.db.bean.VnfmJobExecutionInfo;
  39 import org.onap.vfc.nfvo.driver.vnfm.svnfm.db.mapper.VnfcResourceInfoMapper;
  40 import org.onap.vfc.nfvo.driver.vnfm.svnfm.db.mapper.VnfmJobExecutionMapper;
  41 import org.onap.vfc.nfvo.driver.vnfm.svnfm.db.mapper.VnfmSubscriptionsMapper;
  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.CreateSubscriptionRequest;
  45 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.CreateSubscriptionResponse;
  46 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.HealVnfRequest;
  47 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.HealVnfResponse;
  48 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.InstantiateVnfRequest;
  49 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.InstantiateVnfResponse;
  50 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.OperStatusVnfResponse;
  51 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.QueryVnfResponse;
  52 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.ScaleVnfRequest;
  53 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.ScaleVnfResponse;
  54 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.TerminateVnfRequest;
  55 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.TerminateVnfResponse;
  56 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.inf.VnfContinueProcessorInf;
  57 import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.inf.VnfmDriverMgmrInf;
  58 import org.slf4j.Logger;
  59 import org.slf4j.LoggerFactory;
  60 import org.springframework.beans.factory.annotation.Autowired;
  61 import org.springframework.stereotype.Component;
  62
  63 import com.google.gson.Gson;
  64
  65 @Component
  66 public class VnfmDriverMgmrImpl implements VnfmDriverMgmrInf {
  67         private static final Logger logger = LoggerFactory.getLogger(VnfmDriverMgmrImpl.class);
  68
  69         @Autowired
  70         Driver2CbamRequestConverter requestConverter;
  71
  72         @Autowired
  73         Cbam2DriverResponseConverter responseConverter;
  74
  75         @Autowired
  76         private CbamMgmrInf cbamMgmr;
  77
  78         @Autowired
  79         private CatalogMgmrInf catalogMgmr;
  80
  81         @Autowired
  82         private NslcmMgmrInf nslcmMgmr;
  83
  84         @Autowired
  85         private AaiMgmrInf aaiMgmr;
  86
  87         @Autowired
  88         private VnfmJobExecutionMapper jobDbManager;
  89
  90         @Autowired
  91         private VnfcResourceInfoMapper vnfcDbMgmr;
  92
  93         @Autowired
  94         private VnfmSubscriptionsMapper subscriptionsMapper;
  95
  96         @Autowired
  97         AdaptorEnv adaptorEnv;
  98
  99         @Autowired
 100         private VnfContinueProcessorInf vnfContinueProcessorInf;
 101
 102         private Gson gson = new Gson();
 103
 104         public InstantiateVnfResponse instantiateVnf(InstantiateVnfRequest driverRequest, String vnfmId)
 105                         throws VnfmDriverException {
 106                 InstantiateVnfResponse driverResponse;
 107                 try {
 108                         driverRequest.setVnfdId(adaptorEnv.getVnfdId());
 109                         buildVnfmHttpPathById(vnfmId);
 110
 111                         // String dirPath = "/etc/vnfmpkg";
 112                         // String cbamDirName = CommonUtil.getAppRoot() + dirPath;
 113                         // File cbamDirFile = new File(cbamDirName);
 114                         // String cbamPackageName = cbamDirFile.listFiles()[0].getAbsolutePath();
 115                         // cbamMgmr.uploadVnfPackage(cbamPackageName);
 116
 117                         // step 3: create vnf
 118                         CBAMCreateVnfRequest cbamRequest = requestConverter.createReqConvert(driverRequest);
 119                         logger.info("VnfmDriverMgmrImpl --> instantiateVnf, ready to create vnf on CBAM. ");
 120                         CBAMCreateVnfResponse cbamResponse = cbamMgmr.createVnf(cbamRequest);
 121                         String vnfInstanceId = cbamResponse.getId();
 122                         logger.info("VnfmDriverMgmrImpl --> instantiateVnf, vnfInstanceId is " + vnfInstanceId);
 123                         Long jobId = saveCreateVnfJob(vnfInstanceId);
 124                         driverResponse = responseConverter.createRspConvert(cbamResponse, jobId);
 125
 126                         vnfContinueProcessorInf.continueInstantiateVnf(vnfmId, driverRequest, vnfInstanceId, jobId.toString(),
 127                                         nslcmMgmr, catalogMgmr, cbamMgmr, requestConverter, jobDbManager, vnfcDbMgmr);
 128
 129                 } catch (Exception e) {
 130                         logger.error("error VnfmDriverMgmrImpl --> instantiateVnf. ", e);
 131                         throw new VnfmDriverException(HttpStatus.SC_INTERNAL_SERVER_ERROR, CommonConstants.HTTP_ERROR_DESC_500);
 132                 }
 133
 134                 return driverResponse;
 135         }
 136
 137         private Long saveCreateVnfJob(String vnfInstanceId) {
 138                 VnfmJobExecutionInfo jobInfo = new VnfmJobExecutionInfo();
 139                 long nowTime = System.currentTimeMillis();
 140                 jobInfo.setVnfInstanceId(vnfInstanceId);
 141                 jobInfo.setVnfmInterfceName(CommonConstants.NSLCM_OPERATION_INSTANTIATE);
 142                 jobInfo.setStatus(CommonConstants.CBAM_OPERATION_STATUS_START);
 143                 jobInfo.setOperateStartTime(nowTime);
 144
 145                 jobDbManager.insert(jobInfo);
 146                 VnfmJobExecutionInfo jobInfo1 = (VnfmJobExecutionInfo) jobDbManager.findNewestJobInfo();
 147                 Long jobId = jobInfo1.getJobId();
 148                 return jobId;
 149         }
 150
 151         public TerminateVnfResponse terminateVnf(TerminateVnfRequest driverRequest, String vnfmId, String vnfInstanceId) {
 152                 TerminateVnfResponse driverResponse;
 153                 try {
 154                         buildVnfmHttpPathById(vnfmId);
 155                         driverResponse = generateTerminateVnfResponse(vnfInstanceId);
 156                         String jobId = driverResponse.getJobId();
 157
 158                         vnfContinueProcessorInf.continueTerminateVnf(vnfmId, driverRequest, vnfInstanceId, jobId, nslcmMgmr,
 159                                         cbamMgmr, requestConverter, jobDbManager, vnfcDbMgmr);
 160
 161                 } catch (Exception e) {
 162                         logger.error("error VnfmDriverMgmrImpl --> terminateVnf. ", e);
 163                         throw new VnfmDriverException(HttpStatus.SC_INTERNAL_SERVER_ERROR, CommonConstants.HTTP_ERROR_DESC_500);
 164                 }
 165
 166                 return driverResponse;
 167         }
 168
 169         private TerminateVnfResponse generateTerminateVnfResponse(String vnfInstanceId) {
 170                 VnfmJobExecutionInfo jobInfo = new VnfmJobExecutionInfo();
 171                 long nowTime = System.currentTimeMillis();
 172                 jobInfo.setVnfInstanceId(vnfInstanceId);
 173                 jobInfo.setVnfmInterfceName(CommonConstants.NSLCM_OPERATION_TERMINATE);
 174                 jobInfo.setStatus(CommonConstants.CBAM_OPERATION_STATUS_START);
 175                 jobInfo.setOperateStartTime(nowTime);
 176                 jobDbManager.insert(jobInfo);
 177                 VnfmJobExecutionInfo jobInfo1 = jobDbManager.findNewestJobInfo();
 178                 Long jobId = jobInfo1.getJobId();
 179
 180                 TerminateVnfResponse response = new TerminateVnfResponse();
 181                 response.setJobId("" + jobId);
 182                 return response;
 183         }
 184
 185         public QueryVnfResponse queryVnf(String vnfmId, String vnfInstanceId) {
 186                 QueryVnfResponse driverResponse;
 187                 try {
 188                         buildVnfmHttpPathById(vnfmId);
 189                         CBAMQueryVnfResponse cbamResponse = cbamMgmr.queryVnf(vnfInstanceId);
 190                         driverResponse = responseConverter.queryRspConvert(cbamResponse);
 191                 } catch (Exception e) {
 192                         logger.error("error VnfmDriverMgmrImpl --> queryVnf. ", e);
 193                         throw new VnfmDriverException(HttpStatus.SC_INTERNAL_SERVER_ERROR, CommonConstants.HTTP_ERROR_DESC_500);
 194                 }
 195
 196                 return driverResponse;
 197         }
 198
 199         public OperStatusVnfResponse getOperStatus(String vnfmId, String jobId) throws VnfmDriverException {
 200
 201                 OperationExecution cbamResponse = null;
 202
 203                 try {
 204                         buildVnfmHttpPathById(vnfmId);
 205
 206                         VnfmJobExecutionInfo jobInfo = jobDbManager.findOne(Long.parseLong(jobId));
 207                         cbamResponse = new OperationExecution();
 208
 209                         if ("Instantiate".equalsIgnoreCase(jobInfo.getVnfmInterfceName())) {
 210                                 cbamResponse.setOperationType(OperationType.INSTANTIATE);
 211                         } else if ("Terminal".equalsIgnoreCase(jobInfo.getVnfmInterfceName())) {
 212                                 cbamResponse.setOperationType(OperationType.TERMINATE);
 213                         } else if ("Scalein".equalsIgnoreCase(jobInfo.getVnfmInterfceName())
 214                                         || "Scaleout".equalsIgnoreCase(jobInfo.getVnfmInterfceName())) {
 215                                 cbamResponse.setOperationType(OperationType.SCALE);
 216                         } else {
 217                                 cbamResponse.setOperationType(OperationType.HEAL);
 218                         }
 219
 220                         if (jobInfo.getStatus().equalsIgnoreCase(CommonConstants.CBAM_OPERATION_STATUS_FINISH)) {
 221                                 cbamResponse.setStatus(CommonEnum.OperationStatus.FINISHED);
 222                         } else if (jobInfo.getStatus().equalsIgnoreCase(CommonConstants.CBAM_OPERATION_STATUS_ERROR)) {
 223                                 cbamResponse.setStatus(CommonEnum.OperationStatus.FINISHED);
 224                         } else {
 225                                 cbamResponse.setStatus(CommonEnum.OperationStatus.OTHER);
 226                                 // String execId = jobInfo.getVnfmExecutionId();
 227                                 // logger.info(" VnfmDriverMgmrImpl --> getOperStatus execId is " + execId);
 228                                 // cbamResponse = cbamMgmr.queryOperExecution(execId);
 229                         }
 230
 231                 } catch (Exception e) {
 232                         logger.error("error VnfmDriverMgmrImpl --> getOperStatus. ", e);
 233                         throw new VnfmDriverException(HttpStatus.SC_INTERNAL_SERVER_ERROR, CommonConstants.HTTP_ERROR_DESC_500);
 234                 }
 235
 236                 OperStatusVnfResponse response = responseConverter.operRspConvert(cbamResponse, jobId);
 237                 response.setJobId(jobId);
 238
 239                 return response;
 240         }
 241
 242         public ScaleVnfResponse scaleVnf(ScaleVnfRequest driverRequest, String vnfmId, String vnfInstanceId)
 243                         throws VnfmDriverException {
 244                 ScaleVnfResponse driverResponse;
 245                 try {
 246                         buildVnfmHttpPathById(vnfmId);
 247                         driverResponse = generateScaleVnfResponse(vnfInstanceId, driverRequest.getType());
 248                         String jobId = driverResponse.getJobId();
 249
 250                         vnfContinueProcessorInf.continueScaleVnf(vnfmId, driverRequest, vnfInstanceId, jobId, nslcmMgmr, cbamMgmr,
 251                                         requestConverter, jobDbManager);
 252                 } catch (Exception e) {
 253                         logger.error("error VnfmDriverMgmrImpl --> scaleVnf. ", e);
 254                         throw new VnfmDriverException(HttpStatus.SC_INTERNAL_SERVER_ERROR, CommonConstants.HTTP_ERROR_DESC_500);
 255                 }
 256
 257                 return driverResponse;
 258         }
 259
 260         private ScaleVnfResponse generateScaleVnfResponse(String vnfInstanceId, ScaleType type) {
 261                 VnfmJobExecutionInfo jobInfo = new VnfmJobExecutionInfo();
 262                 long nowTime = System.currentTimeMillis();
 263                 jobInfo.setVnfInstanceId(vnfInstanceId);
 264                 if (type.equals(ScaleType.SCALE_OUT)) {
 265                         jobInfo.setVnfmInterfceName(CommonConstants.NSLCM_OPERATION_SCALE_OUT);
 266                 } else {
 267                         jobInfo.setVnfmInterfceName(CommonConstants.NSLCM_OPERATION_SCALE_IN);
 268                 }
 269                 jobInfo.setStatus(CommonConstants.CBAM_OPERATION_STATUS_START);
 270                 jobInfo.setOperateStartTime(nowTime);
 271                 jobDbManager.insert(jobInfo);
 272                 VnfmJobExecutionInfo jobInfo1 = jobDbManager.findNewestJobInfo();
 273                 Long jobId = jobInfo1.getJobId();
 274
 275                 ScaleVnfResponse response = new ScaleVnfResponse();
 276                 response.setJobId("" + jobId);
 277                 return response;
 278
 279         }
 280
 281         public HealVnfResponse healVnf(HealVnfRequest driverRequest, String vnfmId, String vnfInstanceId)
 282                         throws VnfmDriverException {
 283                 HealVnfResponse driverResponse;
 284                 try {
 285                         buildVnfmHttpPathById(vnfmId);
 286                         driverResponse = generateHealVnfResponse(vnfInstanceId);
 287                         String jobId = driverResponse.getJobId();
 288
 289                         vnfContinueProcessorInf.continueHealVnf(vnfmId, driverRequest, vnfInstanceId, jobId, nslcmMgmr, cbamMgmr,
 290                                         requestConverter, jobDbManager);
 291                 } catch (Exception e) {
 292                         logger.error("error VnfmDriverMgmrImpl --> healVnf. ", e);
 293                         throw new VnfmDriverException(HttpStatus.SC_INTERNAL_SERVER_ERROR, CommonConstants.HTTP_ERROR_DESC_500);
 294                 }
 295
 296                 return driverResponse;
 297         }
 298
 299         private HealVnfResponse generateHealVnfResponse(String vnfInstanceId) {
 300                 VnfmJobExecutionInfo jobInfo = new VnfmJobExecutionInfo();
 301                 long nowTime = System.currentTimeMillis();
 302                 jobInfo.setVnfInstanceId(vnfInstanceId);
 303                 jobInfo.setVnfmInterfceName(CommonConstants.NSLCM_OPERATION_HEAL);
 304                 jobInfo.setStatus(CommonConstants.CBAM_OPERATION_STATUS_START);
 305                 jobInfo.setOperateStartTime(nowTime);
 306                 jobDbManager.insert(jobInfo);
 307                 VnfmJobExecutionInfo jobInfo1 = jobDbManager.findNewestJobInfo();
 308                 Long jobId = jobInfo1.getJobId();
 309
 310                 HealVnfResponse response = new HealVnfResponse();
 311                 response.setJobId("" + jobId);
 312                 return response;
 313         }
 314
 315         public String buildVnfmHttpPathById(String vnfmId) {
 316                 String result = "";
 317                 try {
 318                         result = buildVnfmHttpPathByRealId(vnfmId);
 319                 } catch (Exception e) {
 320                         logger.error("buildVnfmHttpPathById Error.", e);
 321                 }
 322                 return result;
 323         }
 324
 325         public String buildVnfmHttpPathByRealId(String vnfmId)
 326                         throws ClientProtocolException, IOException, VnfmDriverException {
 327                 AaiVnfmInfo vnfmInfo = aaiMgmr.queryVnfm(vnfmId);
 328                 logger.info("vnfmInfo in AAI is " + gson.toJson(vnfmInfo));
 329                 if (isVnfmInfoValid(vnfmId, vnfmInfo)) {
 330                         throw new VnfmDriverException(HttpStatus.SC_INTERNAL_SERVER_ERROR, CommonConstants.HTTP_ERROR_DESC_500);
 331                 }
 332
 333                 EsrSystemInfo systemInfo = vnfmInfo.getEsrSystemInfoList().get(0);
 334
 335                 String urlHead = systemInfo.getServiceUrl();
 336                 // adaptorEnv.setCbamApiUriFront(urlHead);
 337                 // adaptorEnv.setCbamUserName(systemInfo.getUserName());
 338                 // adaptorEnv.setCbamPassword(systemInfo.getPassword());
 339
 340                 return urlHead;
 341         }
 342
 343         private boolean isVnfmInfoValid(String vnfmId, AaiVnfmInfo vnfmInfo) {
 344                 return vnfmInfo == null || vnfmInfo.getEsrSystemInfoList() == null || vnfmInfo.getEsrSystemInfoList().isEmpty();
 345         }
 346
 347         public void setRequestConverter(Driver2CbamRequestConverter requestConverter) {
 348                 this.requestConverter = requestConverter;
 349         }
 350
 351         public void setResponseConverter(Cbam2DriverResponseConverter responseConverter) {
 352                 this.responseConverter = responseConverter;
 353         }
 354
 355         @Override
 356         public CreateSubscriptionResponse createSubscription(CreateSubscriptionRequest request) throws VnfmDriverException {
 357                 CreateSubscriptionResponse driverResponse;
 358                 try {
 359                         CBAMCreateSubscriptionResponse cbamResponse = cbamMgmr.createSubscription(request);
 360                         driverResponse = responseConverter.queryRspConvert(cbamResponse);
 361                         subscriptionsMapper.insert(cbamResponse.getId());
 362                 } catch (Exception e) {
 363                         logger.error("error VnfmDriverMgmrImpl --> createSubscripiton. ", e);
 364                         throw new VnfmDriverException(HttpStatus.SC_INTERNAL_SERVER_ERROR, CommonConstants.HTTP_ERROR_DESC_500);
 365                 }
 366
 367                 return driverResponse;
 368         }
 369
 370 }