From 2298a4397584c2c3fff8a5efe34a1ecbd3c91c62 Mon Sep 17 00:00:00 2001 From: yufei_zhou Date: Tue, 10 Oct 2017 15:06:41 +0800 Subject: Modify POM parent oparent version as 0.1.1 Change-Id: I1320e0ecea14536e4524e9dff0d41fbbf4411d3c Issue-ID: VFC-53 Signed-off-by: yufei_zhou --- .../driver/vnfm/svnfm/VfcadaptorApplication.java | 5 +- .../adaptor/Cbam2DriverResponseConverter.java | 22 +-- .../svnfm/adaptor/Driver2CbamRequestConverter.java | 9 +- .../adaptor/InstantiateVnfContinueRunnable.java | 3 + .../adaptor/TerminateVnfContinueRunnable.java | 8 +- .../svnfm/catalog/bo/CatalogQueryVnfRequest.java | 21 --- .../svnfm/catalog/bo/CatalogQueryVnfResponse.java | 9 -- .../svnfm/catalog/bo/entity/VnfInstanceInfo.java | 6 - .../svnfm/cbam/bo/CBAMTerminateVnfRequest.java | 60 -------- .../svnfm/cbam/bo/entity/OPENSTACK_V2_INFO.java | 58 -------- .../svnfm/cbam/bo/entity/OPENSTACK_V3_INFO.java | 57 -------- .../vnfm/svnfm/cbam/bo/entity/OTHER_VIM_INFO.java | 45 ------ .../vnfm/svnfm/cbam/bo/entity/OpenstackV2Info.java | 58 ++++++++ .../vnfm/svnfm/cbam/bo/entity/OpenstackV3Info.java | 57 ++++++++ .../vnfm/svnfm/cbam/bo/entity/OtherVimInfo.java | 45 ++++++ .../svnfm/cbam/bo/entity/VMWARE_VCLOUD_INFO.java | 58 -------- .../vnfm/svnfm/cbam/bo/entity/VimInfoType.java | 45 ++---- .../svnfm/cbam/bo/entity/VmwareVcloudInfo.java | 58 ++++++++ .../driver/vnfm/svnfm/cbam/impl/CbamMgmrImpl.java | 88 +++++++++--- .../vnfm/svnfm/constant/CommonConstants.java | 1 + .../vnfm/svnfm/exception/VnfmDriverException.java | 2 +- .../nfvo/driver/vnfm/svnfm/nslcm/bo/VnfmInfo.java | 153 --------------------- .../vnfm/svnfm/nslcm/impl/NslcmMgmrImpl.java | 7 +- .../driver/vnfm/svnfm/nslcm/inf/NslcmMgmrInf.java | 1 - .../vnfmdriver/bo/entity/ResponseHistoryList.java | 14 -- .../controller/VnfmDriverController.java | 42 ++---- 26 files changed, 342 insertions(+), 590 deletions(-) delete mode 100644 nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/catalog/bo/CatalogQueryVnfRequest.java delete mode 100644 nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/OPENSTACK_V2_INFO.java delete mode 100644 nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/OPENSTACK_V3_INFO.java delete mode 100644 nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/OTHER_VIM_INFO.java create mode 100644 nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/OpenstackV2Info.java create mode 100644 nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/OpenstackV3Info.java create mode 100644 nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/OtherVimInfo.java delete mode 100644 nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/VMWARE_VCLOUD_INFO.java create mode 100644 nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/VmwareVcloudInfo.java delete mode 100644 nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nslcm/bo/VnfmInfo.java (limited to 'nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main') diff --git a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/VfcadaptorApplication.java b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/VfcadaptorApplication.java index eeac57bd..dc2b8c0c 100644 --- a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/VfcadaptorApplication.java +++ b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/VfcadaptorApplication.java @@ -25,10 +25,13 @@ import org.springframework.context.support.PropertySourcesPlaceholderConfigurer; @Configuration @SpringBootApplication -//@ComponentScan(basePackages= {"org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.controller"}) @ComponentScan public class VfcadaptorApplication { + private VfcadaptorApplication() { + + } + public final static void main(String[] args) { SpringApplication.run(VfcadaptorApplication.class, args); } diff --git a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/adaptor/Cbam2DriverResponseConverter.java b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/adaptor/Cbam2DriverResponseConverter.java index e741b78e..3358ce59 100644 --- a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/adaptor/Cbam2DriverResponseConverter.java +++ b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/adaptor/Cbam2DriverResponseConverter.java @@ -20,12 +20,12 @@ import java.util.List; import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.CBAMCreateVnfResponse; import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.CBAMHealVnfResponse; -import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.CBAMInstantiateVnfResponse; import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.CBAMQueryVnfResponse; import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.CBAMScaleVnfResponse; import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.CBAMTerminateVnfResponse; import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.entity.OperationExecution; import org.onap.vfc.nfvo.driver.vnfm.svnfm.constant.CommonConstants; +import org.onap.vfc.nfvo.driver.vnfm.svnfm.constant.CommonEnum; import org.onap.vfc.nfvo.driver.vnfm.svnfm.db.bean.VnfmJobExecutionInfo; import org.onap.vfc.nfvo.driver.vnfm.svnfm.db.repository.VnfmJobExecutionRepository; import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.HealVnfResponse; @@ -36,7 +36,6 @@ import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.ScaleVnfResponse; import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.TerminateVnfResponse; import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.entity.ResponseDescriptor; import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.entity.ResponseHistoryList; -import org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.entity.VnfInfo; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; @@ -55,17 +54,6 @@ public class Cbam2DriverResponseConverter { return response; } - public InstantiateVnfResponse instantiateRspConvert(CBAMInstantiateVnfResponse cbamResponse) { - InstantiateVnfResponse response = new InstantiateVnfResponse(); - - VnfmJobExecutionInfo jobInfo = jobDbManager.findOne(Long.getLong(cbamResponse.getId())); - - response.setJobId("1"); - - response.setVnfInstanceId(""); - return response; - } - public TerminateVnfResponse terminateRspConvert(CBAMTerminateVnfResponse cbamResponse) { VnfmJobExecutionInfo jobInfo = new VnfmJobExecutionInfo(); jobInfo.setVnfInstanceId(cbamResponse.getId()); @@ -100,13 +88,13 @@ public class Cbam2DriverResponseConverter { response.setJobId(oper.getId()); ResponseDescriptor er = new ResponseDescriptor(); // TODO er.setProgress(i); - if (oper.getStatus().equals("STARTED")) { + if (oper.getStatus() == CommonEnum.OperationStatus.STARTED ) { er.setStatus("started"); - } else if (oper.getStatus().equals("FINISHED")) { + } else if (oper.getStatus() == CommonEnum.OperationStatus.FINISHED) { er.setStatus("finished"); - } else if (oper.getStatus().equals("FAILED")) { + } else if (oper.getStatus() == CommonEnum.OperationStatus.FAILED) { er.setStatus("error"); - } else if (oper.getStatus().equals("OTHER")) { + } else if (oper.getStatus() == CommonEnum.OperationStatus.OTHER) { er.setStatus("processing"); } else { er.setStatus("error"); diff --git a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/adaptor/Driver2CbamRequestConverter.java b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/adaptor/Driver2CbamRequestConverter.java index 5b9f95fe..42c91058 100644 --- a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/adaptor/Driver2CbamRequestConverter.java +++ b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/adaptor/Driver2CbamRequestConverter.java @@ -26,10 +26,9 @@ import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.CBAMScaleVnfRequest; import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.CBAMTerminateVnfRequest; import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.entity.EndpointInfo; import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.entity.ExtVirtualLinkData; -import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.entity.OPENSTACK_V3_INFO; import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.entity.OpenStackAccessInfoV3; +import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.entity.OpenstackV3Info; import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.entity.VimInfo; -import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.entity.VimInfoType; import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.entity.VnfExtCpData; import org.onap.vfc.nfvo.driver.vnfm.svnfm.constant.CommonEnum; import org.onap.vfc.nfvo.driver.vnfm.svnfm.nslcm.bo.NslcmGrantVnfResponse; @@ -58,21 +57,17 @@ public class Driver2CbamRequestConverter { CBAMInstantiateVnfRequest request = new CBAMInstantiateVnfRequest(); List vims = new ArrayList(); VimInfo vim = new VimInfo(); - VimInfoType type = new VimInfoType(); EndpointInfo inter = new EndpointInfo(); - OPENSTACK_V3_INFO openstackV3 = new OPENSTACK_V3_INFO(); + OpenstackV3Info openstackV3 = new OpenstackV3Info(); vim.setId(nslc.getVim().getVimId()); openstackV3.setId(nslc.getVim().getVimId()); inter.setEndpoint(nslc.getVim().getInterfaceEndpoint()); openstackV3.setInterfaceInfo(inter); - openstackV3.setVimInfoType(type); OpenStackAccessInfoV3 v3 = new OpenStackAccessInfoV3(); v3.setUsername(nslc.getVim().getAccessInfo().getUsername()); v3.setPassword(nslc.getVim().getAccessInfo().getPassword()); openstackV3.setAccessInfo(v3); - type.setOPENSTACK_V3_INFO(openstackV3); - vim.setVimInfoType(type); vims.add(vim); List list = new ArrayList(); ExtVirtualLinkData ext = new ExtVirtualLinkData(); diff --git a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/adaptor/InstantiateVnfContinueRunnable.java b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/adaptor/InstantiateVnfContinueRunnable.java index 09cfee86..85077dd1 100644 --- a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/adaptor/InstantiateVnfContinueRunnable.java +++ b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/adaptor/InstantiateVnfContinueRunnable.java @@ -139,6 +139,9 @@ public class InstantiateVnfContinueRunnable implements Runnable { VnfmJobExecutionInfo jobInfo = jobDbMgmr.findOne(Long.getLong(jobId)); jobInfo.setVnfmExecutionId(cbamInstantiateResponse.getId()); + if(CommonEnum.OperationStatus.FAILED == cbamInstantiateResponse.getStatus()){ + jobInfo.setStatus(CommonConstants.CBAM_OPERATION_STATUS_ERROR); + } jobDbMgmr.save(jobInfo); } diff --git a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/adaptor/TerminateVnfContinueRunnable.java b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/adaptor/TerminateVnfContinueRunnable.java index 37348420..2995c140 100644 --- a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/adaptor/TerminateVnfContinueRunnable.java +++ b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/adaptor/TerminateVnfContinueRunnable.java @@ -73,11 +73,12 @@ public class TerminateVnfContinueRunnable implements Runnable { CBAMTerminateVnfRequest cbamRequest = requestConverter.terminateReqConvert(driverRequest); CBAMTerminateVnfResponse cbamResponse = cbamMgmr.terminateVnf(cbamRequest, vnfInstanceId); - handleCbamInstantiateResponse(cbamResponse, jobId); + handleCbamTerminateResponse(cbamResponse, jobId); cbamMgmr.deleteVnf(vnfInstanceId); NslcmNotifyLCMEventsRequest nslcmNotifyReq = buildNslcmNotifyLCMEventsRequest(cbamResponse); + nslcmMgmr.notifyVnf(nslcmNotifyReq, vnfInstanceId); } catch (ClientProtocolException e) { @@ -88,10 +89,13 @@ public class TerminateVnfContinueRunnable implements Runnable { } - private void handleCbamInstantiateResponse(CBAMTerminateVnfResponse cbamResponse, String jobId) { + private void handleCbamTerminateResponse(CBAMTerminateVnfResponse cbamResponse, String jobId) { VnfmJobExecutionInfo jobInfo = jobDbMgmr.findOne(Long.getLong(jobId)); jobInfo.setVnfmExecutionId(cbamResponse.getId()); + if(CommonEnum.OperationStatus.FAILED ==cbamResponse.getStatus()) { + jobInfo.setStatus(CommonConstants.CBAM_OPERATION_STATUS_ERROR); + } jobDbMgmr.save(jobInfo); } diff --git a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/catalog/bo/CatalogQueryVnfRequest.java b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/catalog/bo/CatalogQueryVnfRequest.java deleted file mode 100644 index 82946b11..00000000 --- a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/catalog/bo/CatalogQueryVnfRequest.java +++ /dev/null @@ -1,21 +0,0 @@ -/* - * Copyright 2016-2017, Nokia Corporation - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.onap.vfc.nfvo.driver.vnfm.svnfm.catalog.bo; - -public class CatalogQueryVnfRequest { - - -} diff --git a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/catalog/bo/CatalogQueryVnfResponse.java b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/catalog/bo/CatalogQueryVnfResponse.java index f5d44ca7..e050a34f 100644 --- a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/catalog/bo/CatalogQueryVnfResponse.java +++ b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/catalog/bo/CatalogQueryVnfResponse.java @@ -44,8 +44,6 @@ public class CatalogQueryVnfResponse { this.csarId = csarId; } - - public VnfPackageInfo getPackageInfo() { return packageInfo; } @@ -69,11 +67,4 @@ public class CatalogQueryVnfResponse { public void setVnfInstanceInfo(List vnfInstanceInfo) { this.vnfInstanceInfo = vnfInstanceInfo; } - - - - - - - } diff --git a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/catalog/bo/entity/VnfInstanceInfo.java b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/catalog/bo/entity/VnfInstanceInfo.java index 6ce4b07b..e458cc7b 100644 --- a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/catalog/bo/entity/VnfInstanceInfo.java +++ b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/catalog/bo/entity/VnfInstanceInfo.java @@ -40,10 +40,4 @@ public class VnfInstanceInfo { public void setVnfInstanceName(String vnfInstanceName) { this.vnfInstanceName = vnfInstanceName; } - - - - - - } diff --git a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/CBAMTerminateVnfRequest.java b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/CBAMTerminateVnfRequest.java index 8552a160..acaa16fc 100644 --- a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/CBAMTerminateVnfRequest.java +++ b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/CBAMTerminateVnfRequest.java @@ -37,109 +37,49 @@ public class CBAMTerminateVnfRequest { @JsonProperty("additionalParams") private Object additionalParams; - - public String getName() { return name; } - - - - - - public void setName(String name) { this.name = name; } - - - - - - public String getDescription() { return description; } - - - - - - public void setDescription(String description) { this.description = description; } - - - public CommonEnum.TerminationType getTerminationType() { return terminationType; } - - - - - - public void setTerminationType(CommonEnum.TerminationType terminationType) { this.terminationType = terminationType; } - - - - - - public Integer getGracefulTerminationTimeout() { return gracefulTerminationTimeout; } - - - - - - public void setGracefulTerminationTimeout(Integer gracefulTerminationTimeout) { this.gracefulTerminationTimeout = gracefulTerminationTimeout; } - - - - - - public Object getAdditionalParams() { return additionalParams; } - - - - - - public void setAdditionalParams(Object additionalParams) { this.additionalParams = additionalParams; } - - - - - - public enum TerminationType{ GRACEFUL, FORCEFUL - } } diff --git a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/OPENSTACK_V2_INFO.java b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/OPENSTACK_V2_INFO.java deleted file mode 100644 index 9fad8cb3..00000000 --- a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/OPENSTACK_V2_INFO.java +++ /dev/null @@ -1,58 +0,0 @@ -/* -* Copyright 2016-2017 Nokia Corporation -* -* Licensed under the Apache License, Version 2.0 (the "License"); -* you may not use this file except in compliance with the License. -* You may obtain a copy of the License at -* -* http://www.apache.org/licenses/LICENSE-2.0 -* -* Unless required by applicable law or agreed to in writing, software -* distributed under the License is distributed on an "AS IS" BASIS, -* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -* See the License for the specific language governing permissions and -* limitations under the License. -*/ -package org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.entity; - -import com.fasterxml.jackson.annotation.JsonProperty; - -public class OPENSTACK_V2_INFO { - - @JsonProperty("vimInfoType") - private VimInfoType vimInfoType; - @JsonProperty("interfaceInfo") - private EndpointInfo interfaceInfo; - @JsonProperty("id") - private String id; - @JsonProperty("accessInfo") - private OpenStackAccessInfoV2 accessInfo; - public VimInfoType getVimInfoType() { - return vimInfoType; - } - public void setVimInfoType(VimInfoType vimInfoType) { - this.vimInfoType = vimInfoType; - } - public EndpointInfo getInterfaceInfo() { - return interfaceInfo; - } - public void setInterfaceInfo(EndpointInfo interfaceInfo) { - this.interfaceInfo = interfaceInfo; - } - public String getId() { - return id; - } - public void setId(String id) { - this.id = id; - } - public OpenStackAccessInfoV2 getAccessInfo() { - return accessInfo; - } - public void setAccessInfo(OpenStackAccessInfoV2 accessInfo) { - this.accessInfo = accessInfo; - } - - - - -} diff --git a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/OPENSTACK_V3_INFO.java b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/OPENSTACK_V3_INFO.java deleted file mode 100644 index d5cc23a8..00000000 --- a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/OPENSTACK_V3_INFO.java +++ /dev/null @@ -1,57 +0,0 @@ -/* -* Copyright 2016-2017 Nokia Corporation -* -* Licensed under the Apache License, Version 2.0 (the "License"); -* you may not use this file except in compliance with the License. -* You may obtain a copy of the License at -* -* http://www.apache.org/licenses/LICENSE-2.0 -* -* Unless required by applicable law or agreed to in writing, software -* distributed under the License is distributed on an "AS IS" BASIS, -* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -* See the License for the specific language governing permissions and -* limitations under the License. -*/ -package org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.entity; - -import com.fasterxml.jackson.annotation.JsonProperty; - -public class OPENSTACK_V3_INFO { - - @JsonProperty("vimInfoType") - private VimInfoType vimInfoType; - @JsonProperty("interfaceInfo") - private EndpointInfo interfaceInfo; - @JsonProperty("id") - private String id; - @JsonProperty("accessInfo") - private OpenStackAccessInfoV3 accessInfo; - public VimInfoType getVimInfoType() { - return vimInfoType; - } - public void setVimInfoType(VimInfoType vimInfoType) { - this.vimInfoType = vimInfoType; - } - public EndpointInfo getInterfaceInfo() { - return interfaceInfo; - } - public void setInterfaceInfo(EndpointInfo interfaceInfo) { - this.interfaceInfo = interfaceInfo; - } - public String getId() { - return id; - } - public void setId(String id) { - this.id = id; - } - public OpenStackAccessInfoV3 getAccessInfo() { - return accessInfo; - } - public void setAccessInfo(OpenStackAccessInfoV3 accessInfo) { - this.accessInfo = accessInfo; - } - - - -} diff --git a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/OTHER_VIM_INFO.java b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/OTHER_VIM_INFO.java deleted file mode 100644 index 76651247..00000000 --- a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/OTHER_VIM_INFO.java +++ /dev/null @@ -1,45 +0,0 @@ -/* -* Copyright 2016-2017 Nokia Corporation -* -* Licensed under the Apache License, Version 2.0 (the "License"); -* you may not use this file except in compliance with the License. -* You may obtain a copy of the License at -* -* http://www.apache.org/licenses/LICENSE-2.0 -* -* Unless required by applicable law or agreed to in writing, software -* distributed under the License is distributed on an "AS IS" BASIS, -* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -* See the License for the specific language governing permissions and -* limitations under the License. -*/ -package org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.entity; - -import com.fasterxml.jackson.annotation.JsonProperty; - -public class OTHER_VIM_INFO { - @JsonProperty("vimInfoType") - private VimInfoType vimInfoType; - - @JsonProperty("id") - private String id; - - public VimInfoType getVimInfoType() { - return vimInfoType; - } - - public void setVimInfoType(VimInfoType vimInfoType) { - this.vimInfoType = vimInfoType; - } - - public String getId() { - return id; - } - - public void setId(String id) { - this.id = id; - } - - - -} diff --git a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/OpenstackV2Info.java b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/OpenstackV2Info.java new file mode 100644 index 00000000..3ffa0fb0 --- /dev/null +++ b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/OpenstackV2Info.java @@ -0,0 +1,58 @@ +/* +* Copyright 2016-2017 Nokia Corporation +* +* Licensed under the Apache License, Version 2.0 (the "License"); +* you may not use this file except in compliance with the License. +* You may obtain a copy of the License at +* +* http://www.apache.org/licenses/LICENSE-2.0 +* +* Unless required by applicable law or agreed to in writing, software +* distributed under the License is distributed on an "AS IS" BASIS, +* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +* See the License for the specific language governing permissions and +* limitations under the License. +*/ +package org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.entity; + +import com.fasterxml.jackson.annotation.JsonProperty; + +public class OpenstackV2Info { + + @JsonProperty("vimInfoType") + private VimInfoType vimInfoType; + @JsonProperty("interfaceInfo") + private EndpointInfo interfaceInfo; + @JsonProperty("id") + private String id; + @JsonProperty("accessInfo") + private OpenStackAccessInfoV2 accessInfo; + public VimInfoType getVimInfoType() { + return vimInfoType; + } + public void setVimInfoType(VimInfoType vimInfoType) { + this.vimInfoType = vimInfoType; + } + public EndpointInfo getInterfaceInfo() { + return interfaceInfo; + } + public void setInterfaceInfo(EndpointInfo interfaceInfo) { + this.interfaceInfo = interfaceInfo; + } + public String getId() { + return id; + } + public void setId(String id) { + this.id = id; + } + public OpenStackAccessInfoV2 getAccessInfo() { + return accessInfo; + } + public void setAccessInfo(OpenStackAccessInfoV2 accessInfo) { + this.accessInfo = accessInfo; + } + + + + +} diff --git a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/OpenstackV3Info.java b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/OpenstackV3Info.java new file mode 100644 index 00000000..22de770e --- /dev/null +++ b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/OpenstackV3Info.java @@ -0,0 +1,57 @@ +/* +* Copyright 2016-2017 Nokia Corporation +* +* Licensed under the Apache License, Version 2.0 (the "License"); +* you may not use this file except in compliance with the License. +* You may obtain a copy of the License at +* +* http://www.apache.org/licenses/LICENSE-2.0 +* +* Unless required by applicable law or agreed to in writing, software +* distributed under the License is distributed on an "AS IS" BASIS, +* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +* See the License for the specific language governing permissions and +* limitations under the License. +*/ +package org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.entity; + +import com.fasterxml.jackson.annotation.JsonProperty; + +public class OpenstackV3Info { + + @JsonProperty("vimInfoType") + private VimInfoType vimInfoType; + @JsonProperty("interfaceInfo") + private EndpointInfo interfaceInfo; + @JsonProperty("id") + private String id; + @JsonProperty("accessInfo") + private OpenStackAccessInfoV3 accessInfo; + public VimInfoType getVimInfoType() { + return vimInfoType; + } + public void setVimInfoType(VimInfoType vimInfoType) { + this.vimInfoType = vimInfoType; + } + public EndpointInfo getInterfaceInfo() { + return interfaceInfo; + } + public void setInterfaceInfo(EndpointInfo interfaceInfo) { + this.interfaceInfo = interfaceInfo; + } + public String getId() { + return id; + } + public void setId(String id) { + this.id = id; + } + public OpenStackAccessInfoV3 getAccessInfo() { + return accessInfo; + } + public void setAccessInfo(OpenStackAccessInfoV3 accessInfo) { + this.accessInfo = accessInfo; + } + + + +} diff --git a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/OtherVimInfo.java b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/OtherVimInfo.java new file mode 100644 index 00000000..4b7fb072 --- /dev/null +++ b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/OtherVimInfo.java @@ -0,0 +1,45 @@ +/* +* Copyright 2016-2017 Nokia Corporation +* +* Licensed under the Apache License, Version 2.0 (the "License"); +* you may not use this file except in compliance with the License. +* You may obtain a copy of the License at +* +* http://www.apache.org/licenses/LICENSE-2.0 +* +* Unless required by applicable law or agreed to in writing, software +* distributed under the License is distributed on an "AS IS" BASIS, +* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +* See the License for the specific language governing permissions and +* limitations under the License. +*/ +package org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.entity; + +import com.fasterxml.jackson.annotation.JsonProperty; + +public class OtherVimInfo { + @JsonProperty("vimInfoType") + private VimInfoType vimInfoType; + + @JsonProperty("id") + private String id; + + public VimInfoType getVimInfoType() { + return vimInfoType; + } + + public void setVimInfoType(VimInfoType vimInfoType) { + this.vimInfoType = vimInfoType; + } + + public String getId() { + return id; + } + + public void setId(String id) { + this.id = id; + } + + + +} diff --git a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/VMWARE_VCLOUD_INFO.java b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/VMWARE_VCLOUD_INFO.java deleted file mode 100644 index 2e417fec..00000000 --- a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/VMWARE_VCLOUD_INFO.java +++ /dev/null @@ -1,58 +0,0 @@ -/* -* Copyright 2016-2017 Nokia Corporation -* -* Licensed under the Apache License, Version 2.0 (the "License"); -* you may not use this file except in compliance with the License. -* You may obtain a copy of the License at -* -* http://www.apache.org/licenses/LICENSE-2.0 -* -* Unless required by applicable law or agreed to in writing, software -* distributed under the License is distributed on an "AS IS" BASIS, -* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -* See the License for the specific language governing permissions and -* limitations under the License. -*/ -package org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.entity; - -import com.fasterxml.jackson.annotation.JsonProperty; - -public class VMWARE_VCLOUD_INFO { - - @JsonProperty("vimInfoType") - private VimInfoType vimInfoType; - @JsonProperty("interfaceInfo") - private EndpointInfo interfaceInfo; - @JsonProperty("id") - private String id; - @JsonProperty("accessInfo") - private VCloudAccessInfo accessInfo; - public VimInfoType getVimInfoType() { - return vimInfoType; - } - public void setVimInfoType(VimInfoType vimInfoType) { - this.vimInfoType = vimInfoType; - } - public EndpointInfo getInterfaceInfo() { - return interfaceInfo; - } - public void setInterfaceInfo(EndpointInfo interfaceInfo) { - this.interfaceInfo = interfaceInfo; - } - public String getId() { - return id; - } - public void setId(String id) { - this.id = id; - } - public VCloudAccessInfo getAccessInfo() { - return accessInfo; - } - public void setAccessInfo(VCloudAccessInfo accessInfo) { - this.accessInfo = accessInfo; - } - - - - -} diff --git a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/VimInfoType.java b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/VimInfoType.java index 67e6ed76..779e2659 100644 --- a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/VimInfoType.java +++ b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/VimInfoType.java @@ -15,37 +15,22 @@ */ package org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.entity; -public class VimInfoType { +public enum VimInfoType { + + OPENSTACK_V2_INFO { + private OpenstackV2Info openstackv2; + + }, + OPENSTACK_V3_INFO{ + private OpenstackV3Info openstackv3; + }, + VMWARE_VCLOUD_INFO{ + private VmwareVcloudInfo vmwareInfo; + }, + OTHER_VIM_INFO{ + private OtherVimInfo other; + } - public OPENSTACK_V2_INFO OPENSTACK_V2_INFO; - public OPENSTACK_V3_INFO OPENSTACK_V3_INFO; - public VMWARE_VCLOUD_INFO VMWARE_VCLOUD_INFO; - public OTHER_VIM_INFO OTHER_VIM_INFO; - public OPENSTACK_V2_INFO getOPENSTACK_V2_INFO() { - return OPENSTACK_V2_INFO; - } - public void setOPENSTACK_V2_INFO(OPENSTACK_V2_INFO oPENSTACK_V2_INFO) { - OPENSTACK_V2_INFO = oPENSTACK_V2_INFO; - } - public OPENSTACK_V3_INFO getOPENSTACK_V3_INFO() { - return OPENSTACK_V3_INFO; - } - public void setOPENSTACK_V3_INFO(OPENSTACK_V3_INFO oPENSTACK_V3_INFO) { - OPENSTACK_V3_INFO = oPENSTACK_V3_INFO; - } - public VMWARE_VCLOUD_INFO getVMWARE_VCLOUD_INFO() { - return VMWARE_VCLOUD_INFO; - } - public void setVMWARE_VCLOUD_INFO(VMWARE_VCLOUD_INFO vMWARE_VCLOUD_INFO) { - VMWARE_VCLOUD_INFO = vMWARE_VCLOUD_INFO; - } - public OTHER_VIM_INFO getOTHER_VIM_INFO() { - return OTHER_VIM_INFO; - } - public void setOTHER_VIM_INFO(OTHER_VIM_INFO oTHER_VIM_INFO) { - OTHER_VIM_INFO = oTHER_VIM_INFO; - } - diff --git a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/VmwareVcloudInfo.java b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/VmwareVcloudInfo.java new file mode 100644 index 00000000..746cb007 --- /dev/null +++ b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/bo/entity/VmwareVcloudInfo.java @@ -0,0 +1,58 @@ +/* +* Copyright 2016-2017 Nokia Corporation +* +* Licensed under the Apache License, Version 2.0 (the "License"); +* you may not use this file except in compliance with the License. +* You may obtain a copy of the License at +* +* http://www.apache.org/licenses/LICENSE-2.0 +* +* Unless required by applicable law or agreed to in writing, software +* distributed under the License is distributed on an "AS IS" BASIS, +* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +* See the License for the specific language governing permissions and +* limitations under the License. +*/ +package org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.bo.entity; + +import com.fasterxml.jackson.annotation.JsonProperty; + +public class VmwareVcloudInfo { + + @JsonProperty("vimInfoType") + private VimInfoType vimInfoType; + @JsonProperty("interfaceInfo") + private EndpointInfo interfaceInfo; + @JsonProperty("id") + private String id; + @JsonProperty("accessInfo") + private VCloudAccessInfo accessInfo; + public VimInfoType getVimInfoType() { + return vimInfoType; + } + public void setVimInfoType(VimInfoType vimInfoType) { + this.vimInfoType = vimInfoType; + } + public EndpointInfo getInterfaceInfo() { + return interfaceInfo; + } + public void setInterfaceInfo(EndpointInfo interfaceInfo) { + this.interfaceInfo = interfaceInfo; + } + public String getId() { + return id; + } + public void setId(String id) { + this.id = id; + } + public VCloudAccessInfo getAccessInfo() { + return accessInfo; + } + public void setAccessInfo(VCloudAccessInfo accessInfo) { + this.accessInfo = accessInfo; + } + + + + +} diff --git a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/impl/CbamMgmrImpl.java b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/impl/CbamMgmrImpl.java index 79966f63..bb226db9 100644 --- a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/impl/CbamMgmrImpl.java +++ b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/cbam/impl/CbamMgmrImpl.java @@ -39,6 +39,7 @@ import org.onap.vfc.nfvo.driver.vnfm.svnfm.cbam.inf.CbamMgmrInf; import org.onap.vfc.nfvo.driver.vnfm.svnfm.common.bo.AdaptorEnv; import org.onap.vfc.nfvo.driver.vnfm.svnfm.constant.CommonConstants; import org.onap.vfc.nfvo.driver.vnfm.svnfm.http.client.HttpClientProcessorInf; +import org.onap.vfc.nfvo.driver.vnfm.svnfm.http.client.HttpResult; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.MediaType; import org.springframework.stereotype.Component; @@ -81,10 +82,16 @@ public class CbamMgmrImpl implements CbamMgmrInf { String httpPath = CommonConstants.CbamCreateVnfPath; RequestMethod method = RequestMethod.POST; - String responseStr = operateCbamHttpTask(cbamRequest, httpPath, method); + HttpResult httpResult = operateCbamHttpTask(cbamRequest, httpPath, method); + String responseStr = httpResult.getContent(); logger.info("CbamMgmrImpl -> createVnf, responseStr is " + responseStr); - + int code = httpResult.getStatusCode(); + if(code == 201) { + logger.info("CbamMgmrImpl -> createVnf success"); + }else { + logger.error("CbamMgmrImpl -> createVnf error "); + } CBAMCreateVnfResponse response = gson.fromJson(responseStr, CBAMCreateVnfResponse.class); return response; @@ -97,10 +104,16 @@ public class CbamMgmrImpl implements CbamMgmrInf { String httpPath = String.format(CommonConstants.CbamInstantiateVnfPath, vnfInstanceId); RequestMethod method = RequestMethod.POST; - String responseStr = operateCbamHttpTask(cbamRequest, httpPath, method); + HttpResult httpResult = operateCbamHttpTask(cbamRequest, httpPath, method); + String responseStr = httpResult.getContent(); logger.info("CbamMgmrImpl -> instantiateVnf, responseStr is " + responseStr); - + int code = httpResult.getStatusCode(); + if(code == 202) { + logger.info("CbamMgmrImpl -> instantiateVnf success " ); + }else { + logger.error("CbamMgmrImpl -> instantiateVnf error " ); + } CBAMInstantiateVnfResponse response = gson.fromJson(responseStr, CBAMInstantiateVnfResponse.class); return response; @@ -110,10 +123,16 @@ public class CbamMgmrImpl implements CbamMgmrInf { String httpPath = String.format(CommonConstants.CbamTerminateVnfPath, vnfInstanceId); RequestMethod method = RequestMethod.POST; - String responseStr = operateCbamHttpTask(cbamRequest, httpPath, method); + HttpResult httpResult = operateCbamHttpTask(cbamRequest, httpPath, method); + String responseStr = httpResult.getContent(); logger.info("CbamMgmrImpl -> terminateVnf, responseStr is " + responseStr); - + int code = httpResult.getStatusCode(); + if(code == 202) { + logger.info("CbamMgmrImpl -> terminateVnf sucess " ); + }else { + logger.error("CbamMgmrImpl -> terminateVnf error " ); + } CBAMTerminateVnfResponse response = gson.fromJson(responseStr, CBAMTerminateVnfResponse.class); return response; @@ -122,18 +141,29 @@ public class CbamMgmrImpl implements CbamMgmrInf { public void deleteVnf(String vnfInstanceId) throws ClientProtocolException, IOException { String httpPath = String.format(CommonConstants.CbamDeleteVnfPath, vnfInstanceId); RequestMethod method = RequestMethod.DELETE; + HttpResult httpResult = operateCbamHttpTask(null, httpPath, method); - operateCbamHttpTask(null, httpPath, method); + int code = httpResult.getStatusCode(); + if(code == 204) { + logger.info("CbamMgmrImpl -> deleteVnf success."); + }else { + logger.error("CbamMgmrImpl -> deleteVnf error. detail info is " + httpResult.getContent()); + } - logger.info("CbamMgmrImpl -> deleteVnf."); } public CBAMScaleVnfResponse scaleVnf(CBAMScaleVnfRequest cbamRequest, String vnfInstanceId) throws ClientProtocolException, IOException { String httpPath = String.format(CommonConstants.CbamScaleVnfPath, vnfInstanceId); RequestMethod method = RequestMethod.POST; - String responseStr = operateCbamHttpTask(cbamRequest, httpPath, method); - + HttpResult httpResult = operateCbamHttpTask(cbamRequest, httpPath, method); + String responseStr = httpResult.getContent(); + int code = httpResult.getStatusCode(); + if(code == 202) { + logger.info("CbamMgmrImpl -> scaleVnf success."); + }else { + logger.error("CbamMgmrImpl -> scaleVnf error. " ); + } CBAMScaleVnfResponse response = gson.fromJson(responseStr, CBAMScaleVnfResponse.class); return response; @@ -143,10 +173,16 @@ public class CbamMgmrImpl implements CbamMgmrInf { String httpPath = String.format(CommonConstants.CbamHealVnfPath, vnfInstanceId); RequestMethod method = RequestMethod.POST; - String responseStr = operateCbamHttpTask(cbamRequest, httpPath, method); + HttpResult httpResult = operateCbamHttpTask(cbamRequest, httpPath, method); + String responseStr = httpResult.getContent(); logger.info("CbamMgmrImpl -> healVnf, responseStr is " + responseStr); - + int code = httpResult.getStatusCode(); + if(code == 202) { + logger.info("CbamMgmrImpl -> healVnf success."); + }else { + logger.error("CbamMgmrImpl -> healVnf error. " ); + } CBAMHealVnfResponse response = gson.fromJson(responseStr, CBAMHealVnfResponse.class); return response; @@ -156,16 +192,23 @@ public class CbamMgmrImpl implements CbamMgmrInf { String httpPath = String.format(CommonConstants.CbamQueryVnfPath, vnfInstanceId); RequestMethod method = RequestMethod.GET; - String responseStr = operateCbamHttpTask(null, httpPath, method); + HttpResult httpResult = operateCbamHttpTask(null, httpPath, method); + String responseStr = httpResult.getContent(); logger.info("CbamMgmrImpl -> queryVnf, responseStr is " + responseStr); + int code = httpResult.getStatusCode(); + if(code == 200) { + logger.info("CbamMgmrImpl -> queryVnf success."); + }else { + logger.error("CbamMgmrImpl -> queryVnf error. " ); + } CBAMQueryVnfResponse response = gson.fromJson(responseStr, CBAMQueryVnfResponse.class); return response; } - public String operateCbamHttpTask(Object httpBodyObj, String httpPath, RequestMethod method) throws ClientProtocolException, IOException { + public HttpResult operateCbamHttpTask(Object httpBodyObj, String httpPath, RequestMethod method) throws ClientProtocolException, IOException { String token = null; try { token = retrieveToken(); @@ -179,19 +222,28 @@ public class CbamMgmrImpl implements CbamMgmrInf { map.put(CommonConstants.AUTHORIZATION, "bearer " + token); map.put(CommonConstants.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE); - String responseStr = httpClientProcessor.process(url, method, map, gson.toJson(httpBodyObj)).getContent(); - - return responseStr; + return httpClientProcessor.process(url, method, map, gson.toJson(httpBodyObj)); } public CBAMQueryOperExecutionResponse queryOperExecution(String execId) throws ClientProtocolException, IOException{ String httpPath = String.format(CommonConstants.CbamGetOperStatusPath, execId); RequestMethod method = RequestMethod.GET; - String responseStr = operateCbamHttpTask(null, httpPath, method); + HttpResult httpResult = operateCbamHttpTask(null, httpPath, method); + String responseStr = httpResult.getContent(); logger.info("CbamMgmrImpl -> CBAMQueryOperExecutionResponse, responseStr is " + responseStr); + int code = httpResult.getStatusCode(); + if(code == 200) { + logger.info("CbamMgmrImpl -> CBAMQueryOperExecutionResponse, success" ); + }else if(code == 202) { + logger.info("CbamMgmrImpl -> CBAMQueryOperExecutionResponse, ongoing" ); + }else { + logger.error("CbamMgmrImpl -> CBAMQueryOperExecutionResponse, error" ); + } + + CBAMQueryOperExecutionResponse response = gson.fromJson(responseStr, CBAMQueryOperExecutionResponse.class); return response; diff --git a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/constant/CommonConstants.java b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/constant/CommonConstants.java index 368e8a4e..aefd996a 100644 --- a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/constant/CommonConstants.java +++ b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/constant/CommonConstants.java @@ -62,6 +62,7 @@ public class CommonConstants { public static final String CBAM_OPERATION_STATUS_START = "start"; public static final String CBAM_OPERATION_STATUS_FINISH = "finished"; + public static final String CBAM_OPERATION_STATUS_ERROR = "error"; //MSB public static final String MSB_REGISTER_SERVICE_PATH = "/api/microservices/v1/services"; diff --git a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/exception/VnfmDriverException.java b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/exception/VnfmDriverException.java index 8a465435..78111a17 100644 --- a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/exception/VnfmDriverException.java +++ b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/exception/VnfmDriverException.java @@ -24,7 +24,7 @@ public class VnfmDriverException extends RuntimeException{ public VnfmDriverException(int httpStatus, String message) { super(message); - this.httpStatus = httpStatus; + setHttpStatus(httpStatus); } public int getHttpStatus() { diff --git a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nslcm/bo/VnfmInfo.java b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nslcm/bo/VnfmInfo.java deleted file mode 100644 index bf6608df..00000000 --- a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nslcm/bo/VnfmInfo.java +++ /dev/null @@ -1,153 +0,0 @@ -/* - * Copyright 2016-2017, Nokia Corporation - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.onap.vfc.nfvo.driver.vnfm.svnfm.nslcm.bo; - -import com.fasterxml.jackson.annotation.JsonProperty; - -public class VnfmInfo { - @JsonProperty("vnfmId") - private String vnfmId; - - @JsonProperty("name") - private String name; - - @JsonProperty("type") - private String type; - - @JsonProperty("url") - private String url; - - @JsonProperty("userName") - private String userName; - - @JsonProperty("password") - private String password; - - @JsonProperty("vimId") - private String vimId; - - @JsonProperty("vendor") - private String vendor; - - @JsonProperty("version") - private String version; - - @JsonProperty("description") - private String description; - - @JsonProperty("certificateUrl") - private String certificateUrl; - - @JsonProperty("createTime") - private String createTime; - - public String getVnfmId() { - return vnfmId; - } - - public void setVnfmId(String vnfmId) { - this.vnfmId = vnfmId; - } - - public String getName() { - return name; - } - - public void setName(String name) { - this.name = name; - } - - public String getType() { - return type; - } - - public void setType(String type) { - this.type = type; - } - - public String getUrl() { - return url; - } - - public void setUrl(String url) { - this.url = url; - } - - public String getUserName() { - return userName; - } - - public void setUserName(String userName) { - this.userName = userName; - } - - public String getPassword() { - return password; - } - - public void setPassword(String password) { - this.password = password; - } - - public String getVimId() { - return vimId; - } - - public void setVimId(String vimId) { - this.vimId = vimId; - } - - public String getVendor() { - return vendor; - } - - public void setVendor(String vendor) { - this.vendor = vendor; - } - - public String getVersion() { - return version; - } - - public void setVersion(String version) { - this.version = version; - } - - public String getDescription() { - return description; - } - - public void setDescription(String description) { - this.description = description; - } - - public String getCertificateUrl() { - return certificateUrl; - } - - public void setCertificateUrl(String certificateUrl) { - this.certificateUrl = certificateUrl; - } - - public String getCreateTime() { - return createTime; - } - - public void setCreateTime(String createTime) { - this.createTime = createTime; - } -} diff --git a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nslcm/impl/NslcmMgmrImpl.java b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nslcm/impl/NslcmMgmrImpl.java index 57e8fbac..fc0ff31c 100644 --- a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nslcm/impl/NslcmMgmrImpl.java +++ b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nslcm/impl/NslcmMgmrImpl.java @@ -20,18 +20,15 @@ import java.io.IOException; import java.util.HashMap; import org.apache.http.client.ClientProtocolException; -import org.apache.http.impl.client.HttpClientBuilder; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; import org.onap.vfc.nfvo.driver.vnfm.svnfm.common.bo.AdaptorEnv; import org.onap.vfc.nfvo.driver.vnfm.svnfm.constant.CommonConstants; import org.onap.vfc.nfvo.driver.vnfm.svnfm.http.client.HttpClientProcessorInf; -import org.onap.vfc.nfvo.driver.vnfm.svnfm.http.client.HttpRequestProcessor; import org.onap.vfc.nfvo.driver.vnfm.svnfm.nslcm.bo.NslcmGrantVnfRequest; import org.onap.vfc.nfvo.driver.vnfm.svnfm.nslcm.bo.NslcmGrantVnfResponse; import org.onap.vfc.nfvo.driver.vnfm.svnfm.nslcm.bo.NslcmNotifyLCMEventsRequest; -import org.onap.vfc.nfvo.driver.vnfm.svnfm.nslcm.bo.VnfmInfo; import org.onap.vfc.nfvo.driver.vnfm.svnfm.nslcm.inf.NslcmMgmrInf; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.MediaType; import org.springframework.stereotype.Component; diff --git a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nslcm/inf/NslcmMgmrInf.java b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nslcm/inf/NslcmMgmrInf.java index d9c39dff..537290c9 100644 --- a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nslcm/inf/NslcmMgmrInf.java +++ b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/nslcm/inf/NslcmMgmrInf.java @@ -22,7 +22,6 @@ import org.apache.http.client.ClientProtocolException; import org.onap.vfc.nfvo.driver.vnfm.svnfm.nslcm.bo.NslcmGrantVnfRequest; import org.onap.vfc.nfvo.driver.vnfm.svnfm.nslcm.bo.NslcmGrantVnfResponse; import org.onap.vfc.nfvo.driver.vnfm.svnfm.nslcm.bo.NslcmNotifyLCMEventsRequest; -import org.onap.vfc.nfvo.driver.vnfm.svnfm.nslcm.bo.VnfmInfo; public interface NslcmMgmrInf { // public VnfmInfo queryVnfm(String vnfmId) throws ClientProtocolException, IOException; diff --git a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/vnfmdriver/bo/entity/ResponseHistoryList.java b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/vnfmdriver/bo/entity/ResponseHistoryList.java index b9bbd6c4..895fa0f9 100644 --- a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/vnfmdriver/bo/entity/ResponseHistoryList.java +++ b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/vnfmdriver/bo/entity/ResponseHistoryList.java @@ -16,12 +16,9 @@ package org.onap.vfc.nfvo.driver.vnfm.svnfm.vnfmdriver.bo.entity; - - import com.fasterxml.jackson.annotation.JsonProperty; public class ResponseHistoryList { - @JsonProperty("status") private String status;//started;processing;finished;error @@ -38,8 +35,6 @@ public class ResponseHistoryList { @JsonProperty("responseId") private Integer responseId; - - public String getStatus() { return status; } @@ -48,7 +43,6 @@ public class ResponseHistoryList { this.status = status; } - public Integer getProgress() { return progress; } @@ -80,12 +74,4 @@ public class ResponseHistoryList { public void setResponseId(Integer responseId) { this.responseId = responseId; } - - - - - - - - } diff --git a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/vnfmdriver/controller/VnfmDriverController.java b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/vnfmdriver/controller/VnfmDriverController.java index 2336c941..25fef06d 100644 --- a/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/vnfmdriver/controller/VnfmDriverController.java +++ b/nokia/vnfmdriver/vfcadaptorservice/vfcadaptor/src/main/java/org/onap/vfc/nfvo/driver/vnfm/svnfm/vnfmdriver/controller/VnfmDriverController.java @@ -84,12 +84,7 @@ public class VnfmDriverController { } catch(VnfmDriverException e) { - try { - httpResponse.setStatus(HttpStatus.SC_BAD_REQUEST); - httpResponse.sendError(e.getHttpStatus(), e.getMessage()); - } catch (IOException e1) { - - } + processControllerException(httpResponse, e); } return null; @@ -109,12 +104,7 @@ public class VnfmDriverController { } catch(VnfmDriverException e) { - try { - httpResponse.setStatus(HttpStatus.SC_BAD_REQUEST); - httpResponse.sendError(e.getHttpStatus(), e.getMessage()); - } catch (IOException e1) { - - } + processControllerException(httpResponse, e); } return null; @@ -132,11 +122,7 @@ public class VnfmDriverController { } catch(VnfmDriverException e) { - try { - httpResponse.sendError(e.getHttpStatus(), e.getMessage()); - } catch (IOException e1) { - - } + processControllerException(httpResponse, e); } return null; @@ -157,11 +143,7 @@ public class VnfmDriverController { } catch(VnfmDriverException e) { - try { - httpResponse.sendError(e.getHttpStatus(), e.getMessage()); - } catch (IOException e1) { - - } + processControllerException(httpResponse, e); } return null; @@ -182,15 +164,21 @@ public class VnfmDriverController { } catch(VnfmDriverException e) { - try { - httpResponse.sendError(e.getHttpStatus(), e.getMessage()); - } catch (IOException e1) { - - } + processControllerException(httpResponse, e); } return null; } + private void processControllerException(HttpServletResponse httpResponse, VnfmDriverException e) { + try { + logger.error(" VnfmDriverController --> processControllerException", e); + httpResponse.setStatus(HttpStatus.SC_BAD_REQUEST); + httpResponse.sendError(e.getHttpStatus(), e.getMessage()); + } catch (IOException e1) { + logger.error("VnfmDriverController --> processControllerException error to sendError ", e1); + } + } + } -- cgit 1.2.3-korg