String operationType = request.getParameter("operationType");
JobStatus jobStatus = packageDistributionService.getNsLcmJobStatus(serviceInstanceId,jobId, responseId,operationType);
if(UuiCommonUtil.isNotNullOrEmpty(jobStatus)&&UuiCommonUtil.isNotNullOrEmpty(jobStatus.getResponseDescriptor())&&UuiCommonUtil.isNotNullOrEmpty(jobStatus.getResponseDescriptor().getProgress())){
- String processNum = jobStatus.getResponseDescriptor().getProgress();
- String operationResult = Constant.IN_PROGRESS_CODE;
- if(Integer.parseInt(processNum)==100){
- operationResult = Constant.SUCCESS_CODE;
- }else if(Integer.parseInt(processNum)>100){
- operationResult=Constant.FAIL_CODE;
- }
- serviceLcmService.updateServiceInstanceOperation(serviceInstanceId,operationType,processNum,operationResult);
+ String processNum = jobStatus.getResponseDescriptor().getProgress();
+ String operationResult = Constant.IN_PROGRESS_CODE;
+ if(Integer.parseInt(processNum)==100){
+ operationResult = Constant.SUCCESS_CODE;
+ }else if(Integer.parseInt(processNum)>100){
+ operationResult=Constant.FAIL_CODE;
+ }
+ serviceLcmService.updateServiceInstanceOperation(serviceInstanceId,operationType,processNum,operationResult);
}
return jobStatus;
return packageDistributionService.fetchNsTemplateData(request);
}
- @RequestMapping(value={"/uui-lcm/fetchTemplateInfo"},method = RequestMethod.POST,produces="application/json")
- public JSONObject fetchTemplateInfo(HttpServletRequest request){
- String model = packageDistributionService.fetchTemplateInfo(request).getString("model");
- JSONObject modelJson = JSONObject.parseObject(model);
- return modelJson;
+ @RequestMapping(value={"/uui-lcm/fetchCCVPNTemplateData/{csarId}"},method = RequestMethod.POST,produces="application/json")
+ public JSONObject fetchCCVPNTemplateData(HttpServletRequest request, @PathVariable String csarId){
+ JSONObject model = (JSONObject) packageDistributionService.fetchCCVPNTemplateData(request, csarId).get("result");
+ return model;
}
@RequestMapping(value = {"/uui-lcm/listNsTemplates"}, method = RequestMethod.GET , produces = "application/json")
public String listNsTemplates(){
@RequestMapping(value = {"/uui-lcm/instantiateNetworkServiceInstance"}, method = RequestMethod.POST , produces = "application/json")
public String instantiateNetworkServiceInstance(HttpServletRequest request) throws ParseException{
- String customerId = request.getParameter("customerId");
- String serviceType = request.getParameter("serviceType");
- String serviceDomain = request.getParameter("serviceDomain");
- String ns_instance_id = request.getParameter("ns_instance_id");
- String object = packageDistributionService.instantiateNetworkServiceInstance(request,ns_instance_id);
- JSONObject jobObject = JSONObject.parseObject(object);
- String jobId = jobObject.getString("jobId");
- ServiceBean serviceBean = new ServiceBean(UuiCommonUtil.getUUID(),ns_instance_id,customerId,serviceType,serviceDomain,null,null);
- ServiceInstanceOperations serviceOpera = new ServiceInstanceOperations(ns_instance_id,jobId,Constant.CREATING_CODE,"0",Constant.IN_PROGRESS_CODE,DateUtils.dateToString(DateUtils.now()),null);
- serviceLcmService.saveOrUpdateServiceInstanceOperation(serviceOpera);
- serviceLcmService.saveOrUpdateServiceBean(serviceBean);
+ String customerId = request.getParameter("customerId");
+ String serviceType = request.getParameter("serviceType");
+ String serviceDomain = request.getParameter("serviceDomain");
+ String ns_instance_id = request.getParameter("ns_instance_id");
+ String object = packageDistributionService.instantiateNetworkServiceInstance(request,ns_instance_id);
+ JSONObject jobObject = JSONObject.parseObject(object);
+ String jobId = jobObject.getString("jobId");
+ ServiceBean serviceBean = new ServiceBean(UuiCommonUtil.getUUID(),ns_instance_id,customerId,serviceType,serviceDomain,null,null);
+ ServiceInstanceOperations serviceOpera = new ServiceInstanceOperations(ns_instance_id,jobId,Constant.CREATING_CODE,"0",Constant.IN_PROGRESS_CODE,DateUtils.dateToString(DateUtils.now()),null);
+ serviceLcmService.saveOrUpdateServiceInstanceOperation(serviceOpera);
+ serviceLcmService.saveOrUpdateServiceBean(serviceBean);
return object;
}
@RequestMapping(value = {"/uui-lcm/terminateNetworkServiceInstance"}, method = RequestMethod.POST , produces = "application/json")
public String terminateNetworkServiceInstance(HttpServletRequest request,@RequestParam String ns_instance_id) throws ParseException{
- String result = packageDistributionService.terminateNetworkServiceInstance(request,ns_instance_id);
- String jobId = "";
- if(UuiCommonUtil.isNotNullOrEmpty(result)){
- JSONObject jobIdObject = JSONObject.parseObject(result);
- jobId = jobIdObject.getString("jobId");
- }
- ServiceInstanceOperations serviceOpera = new ServiceInstanceOperations(ns_instance_id,jobId,Constant.DELETING_CODE,"0",Constant.IN_PROGRESS_CODE,DateUtils.dateToString(DateUtils.now()),null);
- serviceLcmService.saveOrUpdateServiceInstanceOperation(serviceOpera);
- return result;
+ String result = packageDistributionService.terminateNetworkServiceInstance(request,ns_instance_id);
+ String jobId = "";
+ if(UuiCommonUtil.isNotNullOrEmpty(result)){
+ JSONObject jobIdObject = JSONObject.parseObject(result);
+ jobId = jobIdObject.getString("jobId");
+ }
+ ServiceInstanceOperations serviceOpera = new ServiceInstanceOperations(ns_instance_id,jobId,Constant.DELETING_CODE,"0",Constant.IN_PROGRESS_CODE,DateUtils.dateToString(DateUtils.now()),null);
+ serviceLcmService.saveOrUpdateServiceInstanceOperation(serviceOpera);
+ return result;
}
@RequestMapping(value = {"/uui-lcm/healNetworkServiceInstance"}, method = RequestMethod.POST , produces = "application/json")
public String healNetworkServiceInstance(HttpServletRequest request,@RequestParam String ns_instance_id) throws ParseException{
- String result= packageDistributionService.healNetworkServiceInstance(request,ns_instance_id);
- String jobId = "";
- if(UuiCommonUtil.isNotNullOrEmpty(result)){
- JSONObject jobIdObject = JSONObject.parseObject(result);
- jobId = jobIdObject.getString("jobId");
- }
- ServiceInstanceOperations serviceOpera = new ServiceInstanceOperations(ns_instance_id,jobId,Constant.HEALING_CODE,"0",Constant.IN_PROGRESS_CODE,DateUtils.dateToString(DateUtils.now()),null);
- serviceLcmService.saveOrUpdateServiceInstanceOperation(serviceOpera);
- return result;
+ String result= packageDistributionService.healNetworkServiceInstance(request,ns_instance_id);
+ String jobId = "";
+ if(UuiCommonUtil.isNotNullOrEmpty(result)){
+ JSONObject jobIdObject = JSONObject.parseObject(result);
+ jobId = jobIdObject.getString("jobId");
+ }
+ ServiceInstanceOperations serviceOpera = new ServiceInstanceOperations(ns_instance_id,jobId,Constant.HEALING_CODE,"0",Constant.IN_PROGRESS_CODE,DateUtils.dateToString(DateUtils.now()),null);
+ serviceLcmService.saveOrUpdateServiceInstanceOperation(serviceOpera);
+ return result;
}
@RequestMapping(value = {"/uui-lcm/scaleNetworkServiceInstance"}, method = RequestMethod.POST , produces = "application/json")
import static org.onap.usecaseui.server.service.lcm.domain.sdc.consts.SDCConsts.CATEGORY_NS;
import static org.onap.usecaseui.server.service.lcm.domain.sdc.consts.SDCConsts.DISTRIBUTION_STATUS_DISTRIBUTED;
import static org.onap.usecaseui.server.service.lcm.domain.sdc.consts.SDCConsts.RESOURCETYPE_VF;
+
import static org.onap.usecaseui.server.util.RestfulServices.create;
import static org.onap.usecaseui.server.util.RestfulServices.extractBody;
+import java.io.BufferedReader;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
+import java.util.Map;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import org.onap.usecaseui.server.service.lcm.domain.vfc.beans.Job;
import org.onap.usecaseui.server.service.lcm.domain.vfc.beans.JobStatus;
import org.onap.usecaseui.server.service.lcm.domain.vfc.exceptions.VfcException;
+import org.onap.usecaseui.server.util.RestfulServices;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.annotation.EnableAspectJAutoProxy;
this.vfcService = vfcService;
}
- public void setServiceLcmService(ServiceLcmService serviceLcmService) {
- this.serviceLcmService = serviceLcmService;
- }
-
+ public void setServiceLcmService(ServiceLcmService serviceLcmService) {
+ this.serviceLcmService = serviceLcmService;
+ }
+
@Override
public VfNsPackageInfo retrievePackageInfo() {
List<SDCServiceTemplate> nsTemplate = sdcNsPackageInfo();
@Override
public List<Vnf> sdcVfPackageInfo() {
- try {
- Response<List<Vnf>> response = sdcCatalogService.listResources(RESOURCETYPE_VF).execute();
- if (response.isSuccessful()) {
- return response.body();
- } else {
- logger.info(String.format("Can not get VF resources[code=%s, message=%s]", response.code(), response.message()));
- return Collections.emptyList();
- }
- } catch (IOException e) {
- logger.error("sdcVfPackageInfo occur exception.Details:"+e.getMessage());
- }
- return null;
+ try {
+ Response<List<Vnf>> response = sdcCatalogService.listResources(RESOURCETYPE_VF).execute();
+ if (response.isSuccessful()) {
+ return response.body();
+ } else {
+ logger.info(String.format("Can not get VF resources[code=%s, message=%s]", response.code(), response.message()));
+ return Collections.emptyList();
+ }
+ } catch (IOException e) {
+ logger.error("sdcVfPackageInfo occur exception.Details:"+e.getMessage());
+ }
+ return null;
}
@Override
public List<SDCServiceTemplate> sdcNsPackageInfo() {
- try {
- Response<List<SDCServiceTemplate>> response = sdcCatalogService.listServices(CATEGORY_NS, DISTRIBUTION_STATUS_DISTRIBUTED).execute();
- if (response.isSuccessful()) {
- return response.body();
- } else {
- logger.info(String.format("Can not get NS services[code=%s, message=%s]", response.code(), response.message()));
- return Collections.emptyList();
- }
- } catch (IOException e) {
- logger.error("sdcNsPackageInfo occur exception.Details:"+e.getMessage());
- }
- return null;
- }
-
+ try {
+ Response<List<SDCServiceTemplate>> response = sdcCatalogService.listServices(CATEGORY_NS, DISTRIBUTION_STATUS_DISTRIBUTED).execute();
+ if (response.isSuccessful()) {
+ return response.body();
+ } else {
+ logger.info(String.format("Can not get NS services[code=%s, message=%s]", response.code(), response.message()));
+ return Collections.emptyList();
+ }
+ } catch (IOException e) {
+ logger.error("sdcNsPackageInfo occur exception.Details:"+e.getMessage());
+ }
+ return null;
+ }
+
@Override
public DistributionResult postNsPackage(Csar csar) {
try {
}
}
- @Override
- public String getVnfPackages() {
- String result="";
+ @Override
+ public String getVnfPackages() {
+ String result="";
try {
- logger.info("vfc getVnfPackages is starting!");
+ logger.info("vfc getVnfPackages is starting!");
Response<ResponseBody> response = this.vfcService.getVnfPackages().execute();
logger.info("vfc getVnfPackages has finished!");
if (response.isSuccessful()) {
- result=new String(response.body().bytes());
+ result=new String(response.body().bytes());
} else {
logger.info(String.format("Can not get getVnfPackages[code=%s, message=%s]", response.code(), response.message()));
result=Constant.CONSTANT_FAILED;;
result=Constant.CONSTANT_FAILED;;
}
return result;
- }
+ }
- @Override
- public String getNetworkServicePackages() {
+ @Override
+ public String getNetworkServicePackages() {
- String result="";
+ String result="";
try {
- logger.info("vfc getNetworkServicePackages is starting!");
+ logger.info("vfc getNetworkServicePackages is starting!");
Response<ResponseBody> response = this.vfcService.getNetworkServicePackages().execute();
logger.info("vfc getNetworkServicePackages has finished!");
if (response.isSuccessful()) {
- result=new String(response.body().bytes());
+ result=new String(response.body().bytes());
} else {
logger.info(String.format("Can not get getNetworkServicePackages[code=%s, message=%s]", response.code(), response.message()));
result=Constant.CONSTANT_FAILED;;
result=Constant.CONSTANT_FAILED;;
}
return result;
-
- }
+
+ }
- @Override
- public String getPnfPackages() {
+ @Override
+ public String getPnfPackages() {
- String result="";
+ String result="";
try {
- logger.info("vfc getPnfPackages is starting!");
+ logger.info("vfc getPnfPackages is starting!");
Response<ResponseBody> response = this.vfcService.getPnfPackages().execute();
logger.info("vfc getPnfPackages has finished!");
if (response.isSuccessful()) {
- result=new String(response.body().bytes());
+ result=new String(response.body().bytes());
} else {
logger.info(String.format("Can not get getPnfPackages[code=%s, message=%s]", response.code(), response.message()));
result=Constant.CONSTANT_FAILED;;
result=Constant.CONSTANT_FAILED;;
}
return result;
-
- }
+
+ }
- @Override
- public String downLoadNsPackage(String nsdInfoId) {
+ @Override
+ public String downLoadNsPackage(String nsdInfoId) {
- String result="";
+ String result="";
try {
- logger.info("vfc downLoadNsPackage is starting!");
+ logger.info("vfc downLoadNsPackage is starting!");
Response<ResponseBody> response = this.vfcService.downLoadNsPackage(nsdInfoId).execute();
logger.info("vfc downLoadNsPackage has finished!");
if (response.isSuccessful()) {
- result=Constant.CONSTANT_SUCCESS;
+ result=Constant.CONSTANT_SUCCESS;
} else {
logger.info(String.format("Can not get downLoadNsPackage[code=%s, message=%s]", response.code(), response.message()));
result=Constant.CONSTANT_FAILED;;
result=Constant.CONSTANT_FAILED;;
}
return result;
-
- }
+
+ }
- @Override
- public String downLoadPnfPackage(String pnfdInfoId) {
+ @Override
+ public String downLoadPnfPackage(String pnfdInfoId) {
- String result="";
+ String result="";
try {
- logger.info("vfc downLoadPnfPackage is starting!");
+ logger.info("vfc downLoadPnfPackage is starting!");
Response<ResponseBody> response = this.vfcService.downLoadNsPackage(pnfdInfoId).execute();
logger.info("vfc downLoadPnfPackage has finished!");
if (response.isSuccessful()) {
- result=Constant.CONSTANT_SUCCESS;
+ result=Constant.CONSTANT_SUCCESS;
} else {
logger.info(String.format("Can not get downLoadPnfPackage[code=%s, message=%s]", response.code(), response.message()));
result=Constant.CONSTANT_FAILED;;
result=Constant.CONSTANT_FAILED;;
}
return result;
-
- }
+
+ }
- @Override
- public String downLoadVnfPackage(String vnfPkgId) {
+ @Override
+ public String downLoadVnfPackage(String vnfPkgId) {
- String result="";
+ String result="";
try {
- logger.info("vfc downLoadVnfPackage is starting!");
+ logger.info("vfc downLoadVnfPackage is starting!");
Response<ResponseBody> response = this.vfcService.downLoadNsPackage(vnfPkgId).execute();
logger.info("vfc downLoadVnfPackage has finished!");
if (response.isSuccessful()) {
- result=Constant.CONSTANT_SUCCESS;
+ result=Constant.CONSTANT_SUCCESS;
} else {
logger.info(String.format("Can not get downLoadVnfPackage[code=%s, message=%s]", response.code(), response.message()));
result=Constant.CONSTANT_FAILED;;
result=Constant.CONSTANT_FAILED;;
}
return result;
-
- }
+
+ }
- @Override
- public String deleteNsdPackage(String nsdInfoId) {
- Response<ResponseBody> response=null;
- String result="";
+ @Override
+ public String deleteNsdPackage(String nsdInfoId) {
+ Response<ResponseBody> response=null;
+ String result="";
try {
- logger.info("vfc deleteNsdPackage is starting!");
+ logger.info("vfc deleteNsdPackage is starting!");
response = this.vfcService.deleteNsdPackage(nsdInfoId).execute();
logger.info("vfc deleteNsdPackage has finished!");
if (response.isSuccessful()) {
- result=Constant.CONSTANT_SUCCESS;
+ result=Constant.CONSTANT_SUCCESS;
} else {
logger.info(String.format("Can not get deleteNsdPackage[code=%s, message=%s]", response.code(), response.message()));
result=Constant.CONSTANT_FAILED;;
}
} catch (IOException e) {
- if(e.getMessage().contains("204")){
- return Constant.CONSTANT_SUCCESS;
- }
+ if(e.getMessage().contains("204")){
+ return Constant.CONSTANT_SUCCESS;
+ }
logger.error("deleteNsdPackage occur exception:"+e);
result=Constant.CONSTANT_FAILED;;
}
return result;
-
- }
+
+ }
- @Override
- public String deleteVnfPackage(String vnfPkgId) {
- Response<ResponseBody> response=null;
- String result="";
+ @Override
+ public String deleteVnfPackage(String vnfPkgId) {
+ Response<ResponseBody> response=null;
+ String result="";
try {
- logger.info("vfc deleteVnfPackage is starting!");
+ logger.info("vfc deleteVnfPackage is starting!");
response = this.vfcService.deleteVnfdPackage(vnfPkgId).execute();
logger.info("vfc deleteVnfPackage has finished!");
if (response.isSuccessful()) {
- result=Constant.CONSTANT_SUCCESS;
+ result=Constant.CONSTANT_SUCCESS;
} else {
logger.info(String.format("Can not get deleteNsdPackage[code=%s, message=%s]", response.code(), response.message()));
result=Constant.CONSTANT_FAILED;;
}
} catch (IOException e) {
- if(e.getMessage().contains("204")){
- return Constant.CONSTANT_SUCCESS;
- }
+ if(e.getMessage().contains("204")){
+ return Constant.CONSTANT_SUCCESS;
+ }
logger.error("deleteVnfPackage occur exception:"+e);
result=Constant.CONSTANT_FAILED;;
}
return result;
-
- }
+
+ }
- @Override
- public String deletePnfPackage(String pnfdInfoId) {
- Response<ResponseBody> response=null;
- String result="";
+ @Override
+ public String deletePnfPackage(String pnfdInfoId) {
+ Response<ResponseBody> response=null;
+ String result="";
try {
- logger.info("vfc deletePnfPackage is starting!");
- response = this.vfcService.deletePnfdPackage(pnfdInfoId).execute();
+ logger.info("vfc deletePnfPackage is starting!");
+ response = this.vfcService.deletePnfdPackage(pnfdInfoId).execute();
logger.info("vfc deletePnfPackage has finished!");
if (response.isSuccessful()) {
- result=Constant.CONSTANT_SUCCESS;
+ result=Constant.CONSTANT_SUCCESS;
} else {
logger.info(String.format("Can not get deletePnfPackage[code=%s, message=%s]", response.code(), response.message()));
result=Constant.CONSTANT_FAILED;;
}
} catch (IOException e) {
- if(e.getMessage().contains("204")){
- return Constant.CONSTANT_SUCCESS;
- }
+ if(e.getMessage().contains("204")){
+ return Constant.CONSTANT_SUCCESS;
+ }
logger.error("deletePnfPackage occur exception:"+e);
result=Constant.CONSTANT_FAILED;;
}
return result;
-
- }
+
+ }
- @Override
- public List<String> getNetworkServiceInfo() {
- List<String> result = new ArrayList<>();
+ @Override
+ public List<String> getNetworkServiceInfo() {
+ List<String> result = new ArrayList<>();
try {
- logger.info("vfc getNetworkServiceInfo is starting!");
+ logger.info("vfc getNetworkServiceInfo is starting!");
Response<nsServiceRsp> response = this.vfcService.getNetworkServiceInfo().execute();
logger.info("vfc getNetworkServiceInfo has finished!");
if (response.isSuccessful()) {
- List<String> nsServices = response.body().nsServices;
- if(nsServices.size()>0){
- for(String nsService:nsServices){
- JSONObject object = JSON.parseObject(nsService);
- String serviceInstanceId=object.get("nsInstanceId").toString();
- ServiceBean serviceBean = serviceLcmService.getServiceBeanByServiceInStanceId(serviceInstanceId);
- object.put("serviceDomain",serviceBean.getServiceDomain());
- object.put("childServiceInstances","[]");
- result.add(object.toString());
- }
- }
- return result;
+ List<String> nsServices = response.body().nsServices;
+ if(nsServices.size()>0){
+ for(String nsService:nsServices){
+ JSONObject object = JSON.parseObject(nsService);
+ String serviceInstanceId=object.get("nsInstanceId").toString();
+ ServiceBean serviceBean = serviceLcmService.getServiceBeanByServiceInStanceId(serviceInstanceId);
+ object.put("serviceDomain",serviceBean.getServiceDomain());
+ object.put("childServiceInstances","[]");
+ result.add(object.toString());
+ }
+ }
+ return result;
} else {
logger.info(String.format("Can not get getNetworkServiceInfo[code=%s, message=%s]", response.code(), response.message()));
return Collections.emptyList();
logger.error("getNetworkServiceInfo occur exception:"+e);
return Collections.emptyList();
}
-
- }
+
+ }
- @Override
- public String createNetworkServiceInstance(HttpServletRequest request) {
- String result = "";
+ @Override
+ public String createNetworkServiceInstance(HttpServletRequest request) {
+ String result = "";
try {
- logger.info("aai createNetworkServiceInstance is starting");
- RequestBody requestBody = extractBody(request);
+ logger.info("aai createNetworkServiceInstance is starting");
+ RequestBody requestBody = extractBody(request);
Response<ResponseBody> response = vfcService.createNetworkServiceInstance(requestBody).execute();
- logger.info("aai createNetworkServiceInstance has finished");
+ logger.info("aai createNetworkServiceInstance has finished");
if (response.isSuccessful()) {
- result=new String(response.body().bytes());
+ result=new String(response.body().bytes());
} else {
- result=Constant.CONSTANT_FAILED;
+ result=Constant.CONSTANT_FAILED;
logger.error(String.format("Can not createNetworkServiceInstance[code=%s, message=%s]", response.code(), response.message()));
}
} catch (Exception e) {
- result=Constant.CONSTANT_FAILED;
- logger.error("createNetworkServiceInstance occur exception:"+e);
+ result=Constant.CONSTANT_FAILED;
+ logger.error("createNetworkServiceInstance occur exception:"+e);
}
return result;
- }
+ }
- @Override
- public String deleteNetworkServiceInstance(String nsInstanceId) {
- Response response = null;
- String result="";
+ @Override
+ public String deleteNetworkServiceInstance(String nsInstanceId) {
+ Response response = null;
+ String result="";
try {
- logger.info("vfc deleteNetworkServiceInstance is starting!");
+ logger.info("vfc deleteNetworkServiceInstance is starting!");
response = this.vfcService.deleteNetworkServiceInstance(nsInstanceId).execute();
logger.info("vfc deleteNetworkServiceInstance has finished!");
if (response.isSuccessful()) {
- result=Constant.CONSTANT_SUCCESS;
+ result=Constant.CONSTANT_SUCCESS;
} else {
logger.info(String.format("Can not get deleteNetworkServiceInstance[code=%s, message=%s]", response.code(), response.message()));
result=Constant.CONSTANT_FAILED;;
}
} catch (IOException e) {
- if(e.getMessage().contains("204")){
- return Constant.CONSTANT_SUCCESS;
- }
+ if(e.getMessage().contains("204")){
+ return Constant.CONSTANT_SUCCESS;
+ }
logger.error("deleteNetworkServiceInstance occur exception:"+e);
result=Constant.CONSTANT_FAILED;
}
return result;
-
- }
+
+ }
- @Override
- public String terminateNetworkServiceInstance(HttpServletRequest request,String networkServiceInstanceId) {
- String result = "";
+ @Override
+ public String terminateNetworkServiceInstance(HttpServletRequest request,String networkServiceInstanceId) {
+ String result = "";
try {
- logger.info("aai terminateNetworkServiceInstance is starting");
- RequestBody requestBody = extractBody(request);
+ logger.info("aai terminateNetworkServiceInstance is starting");
+ RequestBody requestBody = extractBody(request);
Response<ResponseBody> response = vfcService.terminateNetworkServiceInstance(networkServiceInstanceId,requestBody).execute();
- logger.info("aai terminateNetworkServiceInstance has finished");
+ logger.info("aai terminateNetworkServiceInstance has finished");
if (response.isSuccessful()) {
- result=new String(response.body().bytes());
+ result=new String(response.body().bytes());
} else {
- result=Constant.CONSTANT_FAILED;
+ result=Constant.CONSTANT_FAILED;
logger.error(String.format("Can not terminateNetworkServiceInstance[code=%s, message=%s]", response.code(), response.message()));
}
} catch (Exception e) {
- result=Constant.CONSTANT_FAILED;
- logger.error("terminateNetworkServiceInstance occur exception:"+e);
+ result=Constant.CONSTANT_FAILED;
+ logger.error("terminateNetworkServiceInstance occur exception:"+e);
}
return result;
- }
+ }
- @Override
- public String healNetworkServiceInstance(HttpServletRequest request,String networkServiceInstanceId) {
- String result = "";
+ @Override
+ public String healNetworkServiceInstance(HttpServletRequest request,String networkServiceInstanceId) {
+ String result = "";
try {
- logger.info("aai healNetworkServiceInstance is starting");
- RequestBody requestBody = extractBody(request);
+ logger.info("aai healNetworkServiceInstance is starting");
+ RequestBody requestBody = extractBody(request);
Response<ResponseBody> response = vfcService.healNetworkServiceInstance(networkServiceInstanceId,requestBody).execute();
- logger.info("aai healNetworkServiceInstance has finished");
+ logger.info("aai healNetworkServiceInstance has finished");
if (response.isSuccessful()) {
- result=new String(response.body().bytes());
+ result=new String(response.body().bytes());
} else {
- result=Constant.CONSTANT_FAILED;
+ result=Constant.CONSTANT_FAILED;
logger.error(String.format("Can not healNetworkServiceInstance[code=%s, message=%s]", response.code(), response.message()));
}
} catch (Exception e) {
- result=Constant.CONSTANT_FAILED;
- logger.error("healNetworkServiceInstance occur exception:"+e);
+ result=Constant.CONSTANT_FAILED;
+ logger.error("healNetworkServiceInstance occur exception:"+e);
}
return result;
- }
+ }
- @Override
- public String scaleNetworkServiceInstance(HttpServletRequest request,String networkServiceInstanceId) {
- String result = "";
+ @Override
+ public String scaleNetworkServiceInstance(HttpServletRequest request,String networkServiceInstanceId) {
+ String result = "";
try {
- logger.info("aai scaleNetworkServiceInstance is starting");
- RequestBody requestBody = extractBody(request);
+ logger.info("aai scaleNetworkServiceInstance is starting");
+ RequestBody requestBody = extractBody(request);
Response<ResponseBody> response = vfcService.scaleNetworkServiceInstance(networkServiceInstanceId,requestBody).execute();
- logger.info("aai scaleNetworkServiceInstance has finished");
+ logger.info("aai scaleNetworkServiceInstance has finished");
if (response.isSuccessful()) {
- result=new String(response.body().bytes());
+ result=new String(response.body().bytes());
} else {
- result=Constant.CONSTANT_FAILED;
+ result=Constant.CONSTANT_FAILED;
logger.error(String.format("Can not scaleNetworkServiceInstance[code=%s, message=%s]", response.code(), response.message()));
}
} catch (Exception e) {
- result=Constant.CONSTANT_FAILED;
- logger.error("scaleNetworkServiceInstance occur exception:"+e);
+ result=Constant.CONSTANT_FAILED;
+ logger.error("scaleNetworkServiceInstance occur exception:"+e);
}
return result;
- }
+ }
- @Override
- public String createNetworkServiceData(HttpServletRequest request) {
- String result = "";
+ @Override
+ public String createNetworkServiceData(HttpServletRequest request) {
+ String result = "";
try {
- logger.info("aai createNetworkServiceData is starting");
- RequestBody requestBody = extractBody(request);
+ logger.info("aai createNetworkServiceData is starting");
+ RequestBody requestBody = extractBody(request);
Response<ResponseBody> response = vfcService.createNetworkServiceData(requestBody).execute();
- logger.info("aai createNetworkServiceData has finished");
+ logger.info("aai createNetworkServiceData has finished");
if (response.isSuccessful()) {
- result=new String(response.body().bytes());
+ result=new String(response.body().bytes());
} else {
- result=Constant.CONSTANT_FAILED;
+ result=Constant.CONSTANT_FAILED;
logger.error(String.format("Can not createNetworkServiceData[code=%s, message=%s]", response.code(), response.message()));
}
} catch (Exception e) {
- result=Constant.CONSTANT_FAILED;
- logger.error("createNetworkServiceData occur exception:"+e);
+ result=Constant.CONSTANT_FAILED;
+ logger.error("createNetworkServiceData occur exception:"+e);
}
return result;
- }
+ }
- @Override
- public String createVnfData(HttpServletRequest request) {
- String result = "";
+ @Override
+ public String createVnfData(HttpServletRequest request) {
+ String result = "";
try {
- logger.info("aai createVnfData is starting");
- RequestBody requestBody = extractBody(request);
+ logger.info("aai createVnfData is starting");
+ RequestBody requestBody = extractBody(request);
Response<ResponseBody> response = vfcService.createVnfData(requestBody).execute();
- logger.info("aai createVnfData has finished");
+ logger.info("aai createVnfData has finished");
if (response.isSuccessful()) {
- result=new String(response.body().bytes());
+ result=new String(response.body().bytes());
} else {
- result=Constant.CONSTANT_FAILED;
+ result=Constant.CONSTANT_FAILED;
logger.error(String.format("Can not createVnfData[code=%s, message=%s]", response.code(), response.message()));
}
} catch (Exception e) {
- result=Constant.CONSTANT_FAILED;
- logger.error("createVnfData occur exception:"+e);
+ result=Constant.CONSTANT_FAILED;
+ logger.error("createVnfData occur exception:"+e);
}
return result;
- }
+ }
- @Override
- public String createPnfData(HttpServletRequest request) {
- String result = "";
+ @Override
+ public String createPnfData(HttpServletRequest request) {
+ String result = "";
try {
- logger.info("aai createPnfData is starting");
- RequestBody requestBody = extractBody(request);
+ logger.info("aai createPnfData is starting");
+ RequestBody requestBody = extractBody(request);
Response<ResponseBody> response = vfcService.createPnfData(requestBody).execute();
- logger.info("aai createPnfData has finished");
+ logger.info("aai createPnfData has finished");
if (response.isSuccessful()) {
- result=new String(response.body().bytes());
+ result=new String(response.body().bytes());
} else {
- result=Constant.CONSTANT_FAILED;
+ result=Constant.CONSTANT_FAILED;
logger.error(String.format("Can not createPnfData[code=%s, message=%s]", response.code(), response.message()));
}
} catch (Exception e) {
- result=Constant.CONSTANT_FAILED;
- logger.error("createPnfData occur exception:"+e);
+ result=Constant.CONSTANT_FAILED;
+ logger.error("createPnfData occur exception:"+e);
}
return result;
- }
+ }
- @Override
- public String getNsdInfo(String nsdInfoId) {
+ @Override
+ public String getNsdInfo(String nsdInfoId) {
- String result="";
+ String result="";
try {
- logger.info("vfc getNsdInfo is starting!");
+ logger.info("vfc getNsdInfo is starting!");
Response<ResponseBody> response = this.vfcService.getNsdInfo(nsdInfoId).execute();
logger.info("vfc getNsdInfo has finished!");
if (response.isSuccessful()) {
- result=Constant.CONSTANT_SUCCESS;
+ result=Constant.CONSTANT_SUCCESS;
} else {
logger.info(String.format("Can not get getNsdInfo[code=%s, message=%s]", response.code(), response.message()));
result=Constant.CONSTANT_FAILED;;
result=Constant.CONSTANT_FAILED;;
}
return result;
-
- }
+
+ }
- @Override
- public String getVnfInfo(String vnfPkgId) {
+ @Override
+ public String getVnfInfo(String vnfPkgId) {
- String result="";
+ String result="";
try {
- logger.info("vfc getVnfInfo is starting!");
+ logger.info("vfc getVnfInfo is starting!");
Response<ResponseBody> response = this.vfcService.getVnfInfo(vnfPkgId).execute();
logger.info("vfc getVnfInfo has finished!");
if (response.isSuccessful()) {
- result=Constant.CONSTANT_SUCCESS;
+ result=Constant.CONSTANT_SUCCESS;
} else {
logger.info(String.format("Can not get getVnfInfo[code=%s, message=%s]", response.code(), response.message()));
result=Constant.CONSTANT_FAILED;;
result=Constant.CONSTANT_FAILED;;
}
return result;
-
- }
+
+ }
- @Override
- public String getPnfInfo(String pnfdInfoId) {
+ @Override
+ public String getPnfInfo(String pnfdInfoId) {
- String result="";
+ String result="";
try {
- logger.info("vfc getPnfInfo is starting!");
+ logger.info("vfc getPnfInfo is starting!");
Response<ResponseBody> response = this.vfcService.getPnfInfo(pnfdInfoId).execute();
logger.info("vfc getPnfInfo has finished!");
if (response.isSuccessful()) {
- result=Constant.CONSTANT_SUCCESS;
+ result=Constant.CONSTANT_SUCCESS;
} else {
logger.info(String.format("Can not get getPnfInfo[code=%s, message=%s]", response.code(), response.message()));
result=Constant.CONSTANT_FAILED;;
result=Constant.CONSTANT_FAILED;;
}
return result;
-
- }
+
+ }
- @Override
- public String listNsTemplates() {
+ @Override
+ public String listNsTemplates() {
- String result="";
+ String result="";
try {
- logger.info("vfc listNsTemplates is starting!");
+ logger.info("vfc listNsTemplates is starting!");
Response<ResponseBody> response = this.vfcService.listNsTemplates().execute();
logger.info("vfc listNsTemplates has finished!");
if (response.isSuccessful()) {
- result=new String(response.body().bytes());
+ result=new String(response.body().bytes());
} else {
logger.info(String.format("Can not get listNsTemplates[code=%s, message=%s]", response.code(), response.message()));
result=Constant.CONSTANT_FAILED;;
result=Constant.CONSTANT_FAILED;;
}
return result;
-
- }
+
+ }
- @Override
- public String fetchNsTemplateData(HttpServletRequest request) {
- String result = "";
+ @Override
+ public String fetchNsTemplateData(HttpServletRequest request) {
+ String result = "";
try {
- logger.info("aai fetchNsTemplateData is starting");
- RequestBody requestBody = extractBody(request);
+ logger.info("aai fetchNsTemplateData is starting");
+ RequestBody requestBody = extractBody(request);
Response<ResponseBody> response = vfcService.fetchNsTemplateData(requestBody).execute();
- logger.info("aai fetchNsTemplateData has finished");
+ logger.info("aai fetchNsTemplateData has finished");
if (response.isSuccessful()) {
- result=new String(response.body().bytes());
+ result=new String(response.body().bytes());
} else {
- result=Constant.CONSTANT_FAILED;
+ result=Constant.CONSTANT_FAILED;
logger.error(String.format("Can not fetchNsTemplateData[code=%s, message=%s]", response.code(), response.message()));
}
} catch (Exception e) {
- result=Constant.CONSTANT_FAILED;
- logger.error("fetchNsTemplateData occur exception:"+e);
+ result=Constant.CONSTANT_FAILED;
+ logger.error("fetchNsTemplateData occur exception:"+e);
}
return result;
- }
-
- @Override
- public JSONObject fetchTemplateInfo(HttpServletRequest request) {
- JSONObject result = new JSONObject();;
+ }
+
+ @Override
+ public JSONObject fetchCCVPNTemplateData(HttpServletRequest request, String csarId) {
+ JSONObject result = new JSONObject();
try {
- logger.info("aai fetchTemplateInfo is starting");
- RequestBody requestBody = extractBody(request);
- Response<ResponseBody> response = vfcService.fetchTemplateInfo(requestBody).execute();
- logger.info("aai fetchTemplateInfo has finished");
- if (response.isSuccessful()) {
- result.put("status", Constant.CONSTANT_SUCCESS);
- result.put("result",JSONObject.parseObject(new String(response.body().bytes())));
+ RequestBody requestBody = extractBody(request);
+ // search template from vfc catalog
+ Response<ResponseBody> getResponse = this.vfcService.servicePackages(csarId).execute();
+
+ if (getResponse.isSuccessful()) {
+ // call vfc template parser
+ logger.info("calling ccvpn template file parser is starting");
+ Response<ResponseBody> response = vfcService.fetchTemplateInfo(requestBody).execute();
+ logger.info("calling ccvpn template file parser has finished");
+ if (response.isSuccessful()) {
+ result.put("status", Constant.CONSTANT_SUCCESS);
+ result.put("result", JSONObject.parseObject(new String(response.body().bytes())));
+ } else {
+ result.put("status", Constant.CONSTANT_FAILED);
+ result.put("error", String.format("Can not parse ccvpn template file. Detail Info [code=%s, message=%s]", response.code(), response.message()));
+ logger.error(String.format("Can not parse ccvpn template file. Detail Info [code=%s, message=%s]", response.code(), response.message()));
+ }
} else {
- result.put("status", Constant.CONSTANT_FAILED);
- result.put("error",String.format("Can not fetchTemplateInfo[code=%s, message=%s]", response.code(), response.message()));
- logger.error(String.format("Can not fetchTemplateInfo[code=%s, message=%s]", response.code(), response.message()));
+ // distribute template files to vfc catalog
+ Response<ResponseBody> postResponse = this.vfcService.servicePackages(requestBody).execute();
+ if (postResponse.isSuccessful()) {
+ // call vfc template parser
+ logger.info("calling ccvpn template file parser is starting");
+ Response<ResponseBody> response = vfcService.fetchTemplateInfo(requestBody).execute();
+ logger.info("calling ccvpn template file parser has finished");
+ if (response.isSuccessful()) {
+ result.put("status", Constant.CONSTANT_SUCCESS);
+ result.put("result",JSONObject.parseObject(new String(response.body().bytes())));
+ } else {
+ result.put("status", Constant.CONSTANT_FAILED);
+ result.put("error",String.format("Can not parse ccvpn template file. Detail Info [code=%s, message=%s]", response.code(), response.message()));
+ logger.error(String.format("Can not parse ccvpn template file. Detail Info [code=%s, message=%s]", response.code(), response.message()));
+ }
+ } else {
+ result.put("status", Constant.CONSTANT_FAILED);
+ result.put("error",String.format("Can not distribute ccvpn template file. Detail Info [code=%s, message=%s]", postResponse.code(), postResponse.message()));
+ logger.error(String.format("Can not distribute ccvpn template file. Detail Info [code=%s, message=%s]", postResponse.code(), postResponse.message()));
+ }
}
} catch (Exception e) {
- result.put("status", Constant.CONSTANT_FAILED);
- result.put("errorMessage","fetchTemplateInfo occur exception:"+e);
+ result.put("status", Constant.CONSTANT_FAILED);
+ result.put("errorMessage", "calling ccvpn template parser happened exception:"+e);
}
return result;
- }
-
- @Override
- public String instantiateNetworkServiceInstance(HttpServletRequest request, String serviceInstanceId) {
- String result = "";
- try {
- logger.info("aai instantiateNetworkServiceInstance is starting");
- RequestBody requestBody = extractBody(request);
+ }
+
+ @Override
+ public String instantiateNetworkServiceInstance(HttpServletRequest request, String serviceInstanceId) {
+ String result = "";
+ try {
+ logger.info("aai instantiateNetworkServiceInstance is starting");
+ RequestBody requestBody = extractBody(request);
Response<ResponseBody> response = vfcService.instantiateNetworkServiceInstance(requestBody,serviceInstanceId).execute();
- logger.info("aai instantiateNetworkServiceInstance has finished");
+ logger.info("aai instantiateNetworkServiceInstance has finished");
if (response.isSuccessful()) {
- result=new String(response.body().bytes());
+ result=new String(response.body().bytes());
} else {
- result=Constant.CONSTANT_FAILED;
+ result=Constant.CONSTANT_FAILED;
logger.error(String.format("Can not instantiateNetworkServiceInstance[code=%s, message=%s]", response.code(), response.message()));
}
} catch (Exception e) {
- result=Constant.CONSTANT_FAILED;
- logger.error("instantiateNetworkServiceInstance occur exception:"+e);
+ result=Constant.CONSTANT_FAILED;
+ logger.error("instantiateNetworkServiceInstance occur exception:"+e);
}
return result;
- }
+ }
- @Override
- public String getVnfInfoById(String vnfinstid) {
+ @Override
+ public String getVnfInfoById(String vnfinstid) {
- String result="";
+ String result="";
try {
- logger.info("vfc getVnfInfoById is starting!");
+ logger.info("vfc getVnfInfoById is starting!");
Response<ResponseBody> response = this.vfcService.getVnfInfoById(vnfinstid).execute();
logger.info("vfc getVnfInfoById has finished!");
if (response.isSuccessful()) {
- result=new String(response.body().bytes());
+ result=new String(response.body().bytes());
} else {
logger.info(String.format("Can not get getVnfInfoById[code=%s, message=%s]", response.code(), response.message()));
result=Constant.CONSTANT_FAILED;;
result=Constant.CONSTANT_FAILED;;
}
return result;
-
- }
+
+ }
}