/*
- * Copyright 2016 Huawei Technologies Co., Ltd.
+ * Copyright 2016-2017 Huawei Technologies Co., Ltd.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
import java.util.Map;
import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.common.VnfmException;
-import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.service.constant.Constant;
-import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.common.restclient.ServiceException;
import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.common.restclient.Restful;
import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.common.restclient.RestfulAsyncCallback;
import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.common.restclient.RestfulFactory;
import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.common.restclient.RestfulOptions;
import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.common.restclient.RestfulParametes;
import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.common.restclient.RestfulResponse;
+import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.common.restclient.ServiceException;
+import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.service.constant.Constant;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
* Utility class.</br>
*
* @author
- * @version VFC 1.0 Sep 10, 2016
+ * @version VFC 1.0 Sep 10, 2016
*/
public final class VNFRestfulUtil {
return getRestRes(methodNames, path, restParametes);
}
-
/**
* encapsulate the java reflect exception
*
* @param methodName
* @param objects
* @return
- * @since VFC 1.0
+ * @since VFC 1.0
*/
public static RestfulResponse getRestRes(String methodName, Object... objects) {
Restful rest = RestfulFactory.getRestInstance(RestfulFactory.PROTO_HTTP);
response.setResponseJson(e.getCause().getMessage());
return response;
- } catch(Throwable e) { //NOSONAR
+ } catch(Throwable e) { // NOSONAR
try {
throw (VnfmException)new VnfmException().initCause(e.getCause());
} catch(VnfmException e1) {
/**
* Send request to manager.
+ *
* @param path
* @param methodName
* @param paraJson
*/
public static JSONObject sendReqToApp(String path, String methodName, JSONObject paraJson) {
JSONObject retJson = new JSONObject();
- retJson.put("retCode", Constant.REST_FAIL);
+ retJson.put(Constant.RETCODE, Constant.REST_FAIL);
String abPath = null;
String vnfmId = null;
if(paraJson != null && paraJson.containsKey("vnfmInfo")) {
if(!abPath.contains("vnfdmgr/v1")) {
LOG.warn("function=sendReqToApp, msg=result from app is: " + object.toString());
}
- if(object.getInt("retCode") == Constant.REST_SUCCESS) {
- retJson.put("retCode", Constant.REST_SUCCESS);
+ if(object.getInt(Constant.RETCODE) == Constant.REST_SUCCESS) {
+ retJson.put(Constant.RETCODE, Constant.REST_SUCCESS);
retJson.put("data", withVnfmIdSuffix(vnfmId, object.get("data")));
return retJson;
} else {
- retJson.put("retCode", Constant.REST_FAIL);
+ retJson.put(Constant.RETCODE, Constant.REST_FAIL);
if(object.containsKey("msg")) {
retJson.put("data", object.getString("msg"));
return retJson;
* @param domainTokens String
* @param isNfvoApp Boolean
* @return
- * @since VFC 1.0
+ * @since VFC 1.0
*/
public static RestfulResponse getRemoteResponse(Map<String, String> paramsMap, String params, String domainTokens,
boolean isNfvoApp) {
* @param paramsMap
* @param params
* @return
- * @since VFC 1.0
+ * @since VFC 1.0
*/
public static RestfulResponse getRemoteResponse(Map<String, String> paramsMap, String params) {
- if(null == paramsMap){
+ if(null == paramsMap) {
return null;
}
String url = paramsMap.get("url");
restfulParametes.setHeaderMap(headerMap);
restfulParametes.setRawData(params);
- if (rest != null) {
- if (TYPE_GET.equalsIgnoreCase(methodType)) {
+ if(rest != null) {
+ if(TYPE_GET.equalsIgnoreCase(methodType)) {
rsp = rest.get(url, restfulParametes);
- } else if (TYPE_POST.equalsIgnoreCase(methodType)) {
+ } else if(TYPE_POST.equalsIgnoreCase(methodType)) {
rsp = rest.post(url, restfulParametes);
- } else if (TYPE_PUT.equalsIgnoreCase(methodType)) {
+ } else if(TYPE_PUT.equalsIgnoreCase(methodType)) {
rsp = rest.put(url, restfulParametes);
- } else if (TYPE_DEL.equalsIgnoreCase(methodType)) {
+ } else if(TYPE_DEL.equalsIgnoreCase(methodType)) {
rsp = rest.delete(url, restfulParametes);
}
}
- } catch (ServiceException e) {
+ } catch(ServiceException e) {
LOG.error("function=getRemoteResponse, get restful response catch exception {}", e);
}
return rsp;
}
-
/**
* Helps to make the parameter map.
* <br>
* @param path
* @param authMode
* @return
- * @since VFC 1.0
+ * @since VFC 1.0
*/
public static Map<String, String> generateParamsMap(String url, String methodType, String path, String authMode) {
Map<String, String> utilParamsMap = new HashMap<>(6);
* @param methodType
* @param path
* @return
- * @since VFC 1.0
+ * @since VFC 1.0
*/
public static Map<String, String> generateParamsMap(String url, String methodType, String path) {
Map<String, String> paramsMap = new HashMap<>(6);
* @param vnfmInfo
* @param vnfmId
* @return
- * @since VFC 1.0
+ * @since VFC 1.0
*/
public static JSONObject getResultToVnfm(JSONObject vnfmInfo, String vnfmId) {
JSONObject retJson = new JSONObject();
- retJson.put("retCode", Constant.REST_FAIL);
+ retJson.put(Constant.RETCODE, Constant.REST_FAIL);
if(vnfmInfo == null) {
LOG.error("function=getResultToVnfm, msg=data from vnfm is null");
retJson.put("data", "get null result");
return retJson;
}
- if(vnfmInfo.getInt("retCode") == Constant.REST_SUCCESS) {
- retJson.put("retCode", Constant.REST_SUCCESS);
+ if(vnfmInfo.getInt(Constant.RETCODE) == Constant.REST_SUCCESS) {
+ retJson.put(Constant.RETCODE, Constant.REST_SUCCESS);
retJson.put("data", withVnfmIdSuffix(vnfmId, vnfmInfo.get("data")));
return retJson;
} else {
- retJson.put("retCode", Constant.REST_FAIL);
+ retJson.put(Constant.RETCODE, Constant.REST_FAIL);
if(vnfmInfo.containsKey("msg")) {
retJson.put("data", vnfmInfo.getString("msg"));
return retJson;
/*
- * Copyright 2016 Huawei Technologies Co., Ltd.
+ * Copyright 2016-2017 Huawei Technologies Co., Ltd.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
import java.util.Map;
import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.common.VnfmException;
-import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.service.constant.Constant;
-import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.common.restclient.ServiceException;
import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.common.restclient.Restful;
import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.common.restclient.RestfulAsyncCallback;
import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.common.restclient.RestfulFactory;
import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.common.restclient.RestfulOptions;
import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.common.restclient.RestfulParametes;
import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.common.restclient.RestfulResponse;
+import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.common.restclient.ServiceException;
+import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.service.constant.Constant;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
* .</br>
*
* @author
- * @version VFC 1.0 Sep 10, 2016
+ * @version VFC 1.0 Sep 10, 2016
*/
public final class VnfmRestfulUtil {
* @param methodName String
* @param objects String
* @return
- * @since VFC 1.0
+ * @since VFC 1.0
*/
public static RestfulResponse getRestRes(String methodName, Object... objects) {
Restful rest = RestfulFactory.getRestInstance(RestfulFactory.PROTO_HTTP);
response.setResponseJson(e.getCause().getMessage());
return response;
- } catch(Throwable e) { //NOSONAR
+ } catch(Throwable e) { // NOSONAR
try {
throw (VnfmException)new VnfmException().initCause(e.getCause());
} catch(VnfmException e1) {
* @param methodName String
* @param paraJson JSONObject
* @return
- * @since VFC 1.0
+ * @since VFC 1.0
*/
public static JSONObject sendReqToApp(String path, String methodName, JSONObject paraJson) {
JSONObject retJson = new JSONObject();
- retJson.put("retCode", Constant.REST_FAIL);
+ retJson.put(Constant.RETCODE, Constant.REST_FAIL);
String abPath = null;
String vnfmId = null;
if(paraJson != null && paraJson.containsKey("vnfmInfo")) {
if(!abPath.contains("vnfdmgr/v1")) {
LOG.warn("function=sendReqToApp, msg=result from app is: " + object.toString());
}
- if(object.getInt("retCode") == Constant.REST_SUCCESS) {
- retJson.put("retCode", Constant.REST_SUCCESS);
+ if(object.getInt(Constant.RETCODE) == Constant.REST_SUCCESS) {
+ retJson.put(Constant.RETCODE, Constant.REST_SUCCESS);
retJson.put("data", withVnfmIdSuffix(vnfmId, object.get("data")));
return retJson;
} else {
- retJson.put("retCode", Constant.REST_FAIL);
+ retJson.put(Constant.RETCODE, Constant.REST_FAIL);
if(object.containsKey("msg")) {
retJson.put("data", object.getString("msg"));
return retJson;
* @param domainTokens String
* @param isNfvoApp boolean
* @return
- * @since VFC 1.0
+ * @since VFC 1.0
*/
public static RestfulResponse getRemoteResponse(Map<String, String> paramsMap, String params, String domainTokens,
boolean isNfvoApp) {
* @param methodType String
* @param params String
* @return
- * @since VFC 1.0
+ * @since VFC 1.0
*/
public static RestfulResponse getRemoteResponse(String url, String methodType, String params) {
RestfulResponse rsp = null;
* @param path String
* @param authMode String
* @return
- * @since VFC 1.0
+ * @since VFC 1.0
*/
public static Map<String, String> generateParamsMap(String url, String methodType, String path, String authMode) {
Map<String, String> utilParamsMap = new HashMap<>(6);
// check if parameters are null.
if(paramsMap == null || paramsMap.isEmpty()) {
- resultObj.put("reason", "csarid and vnfmid are null.");
- resultObj.put("retCode", Constant.REST_FAIL);
+ resultObj.put(Constant.REASON, "csarid and vnfmid are null.");
+ resultObj.put(Constant.RETCODE, Constant.REST_FAIL);
return resultObj;
}
String vnfdid = "";
if(null == csarid || "".equals(csarid)) {
- resultObj.put("reason", "csarid is null.");
- resultObj.put("retCode", Constant.REST_FAIL);
+ resultObj.put(Constant.REASON, "csarid is null.");
+ resultObj.put(Constant.RETCODE, Constant.REST_FAIL);
return resultObj;
}
if(null == vnfmid || "".equals(vnfmid)) {
- resultObj.put("reason", "vnfmid is null.");
- resultObj.put("retCode", Constant.REST_FAIL);
+ resultObj.put(Constant.REASON, "vnfmid is null.");
+ resultObj.put(Constant.RETCODE, Constant.REST_FAIL);
return resultObj;
}
// obtain CSAR package info
JSONObject csarobj = getVnfmCsarInfo(csarid);
String downloadUri = "";
- if(Integer.valueOf(csarobj.get("retCode").toString()) == Constant.HTTP_OK) {
- LOG.info("get CSAR info successful.", csarobj.get("retCode"));
+ if(Integer.valueOf(csarobj.get(Constant.RETCODE).toString()) == Constant.HTTP_OK) {
+ LOG.info("get CSAR info successful.", csarobj.get(Constant.RETCODE));
downloadUri = csarobj.getString("downloadUri");
} else {
- LOG.error("get CSAR info fail.", csarobj.get("retCode"));
- resultObj.put("reason", csarobj.get("reason").toString());
- resultObj.put("retCode", Constant.REST_FAIL);
+ LOG.error("get CSAR info fail.", csarobj.get(Constant.RETCODE));
+ resultObj.put(Constant.REASON, csarobj.get(Constant.REASON).toString());
+ resultObj.put(Constant.RETCODE, Constant.REST_FAIL);
return resultObj;
}
JSONObject csarTempObj = new JSONObject();
JSONObject downloadObject =
downloadCsar(downloadUri, csarfilepath + System.getProperty(Constant.FILE_SEPARATOR) + csarfilename);
- if(Integer.valueOf(downloadObject.get("retCode").toString()) != Constant.REST_SUCCESS) {
- LOG.error("download CSAR fail.", downloadObject.get("retCode"));
- resultObj.put("reason", downloadObject.get("reason").toString());
- resultObj.put("retCode", downloadObject.get("retCode").toString());
+ if(Integer.valueOf(downloadObject.get(Constant.RETCODE).toString()) != Constant.REST_SUCCESS) {
+ LOG.error("download CSAR fail.", downloadObject.get(Constant.RETCODE));
+ resultObj.put(Constant.REASON, downloadObject.get(Constant.REASON).toString());
+ resultObj.put(Constant.RETCODE, downloadObject.get(Constant.RETCODE).toString());
return resultObj;
}
- LOG.info("download CSAR successful.", downloadObject.get("retCode"));
+ LOG.info("download CSAR successful.", downloadObject.get(Constant.RETCODE));
// unzip csar package to location.
JSONObject unzipObject =
unzipCSAR(csarfilepath + System.getProperty(Constant.FILE_SEPARATOR) + csarfilename, csarfilepath);
- if(Integer.valueOf(unzipObject.get("retCode").toString()) != Constant.REST_SUCCESS) {
- LOG.error("unzip CSAR fail.", unzipObject.get("retCode"));
- resultObj.put("reason", unzipObject.get("reason").toString());
- resultObj.put("retCode", unzipObject.get("retCode").toString());
+ if(Integer.valueOf(unzipObject.get(Constant.RETCODE).toString()) != Constant.REST_SUCCESS) {
+ LOG.error("unzip CSAR fail.", unzipObject.get(Constant.RETCODE));
+ resultObj.put(Constant.REASON, unzipObject.get(Constant.REASON).toString());
+ resultObj.put(Constant.RETCODE, unzipObject.get(Constant.RETCODE).toString());
return resultObj;
}
- LOG.info("unzip CSAR successful.", unzipObject.get("retCode"));
+ LOG.info("unzip CSAR successful.", unzipObject.get(Constant.RETCODE));
Map<String, String> vnfmMap = new HashMap<>();
vnfmMap.put("url", String.format(UrlConstant.REST_VNFMINFO_GET, vnfmid));
// get VNFM connection info
JSONObject vnfmObject = getVnfmConnInfo(vnfmMap);
- if(Integer.valueOf(vnfmObject.get("retCode").toString()) != Constant.HTTP_OK) {
- LOG.error("get Vnfm Connection Info fail.", vnfmObject.get("retCode"));
- resultObj.put("reason", vnfmObject.get("reason").toString());
- resultObj.put("retCode", vnfmObject.get("retCode").toString());
+ if(Integer.valueOf(vnfmObject.get(Constant.RETCODE).toString()) != Constant.HTTP_OK) {
+ LOG.error("get Vnfm Connection Info fail.", vnfmObject.get(Constant.RETCODE));
+ resultObj.put(Constant.REASON, vnfmObject.get(Constant.REASON).toString());
+ resultObj.put(Constant.RETCODE, vnfmObject.get(Constant.RETCODE).toString());
return resultObj;
}
- LOG.info("get Vnfm Connection Info successful.", vnfmObject.get("retCode"));
+ LOG.info("get Vnfm Connection Info successful.", vnfmObject.get(Constant.RETCODE));
String vnfmUrl = vnfmObject.getString("url");
String userName = vnfmObject.getString("userName");
if(Constant.HTTP_OK != mgrVcmm.connect(vnfmObject, Constant.CERTIFICATE)) {
LOG.error("get Access Session fail.");
resultObj.put(Constant.RETCODE, Constant.HTTP_INNERERROR);
- resultObj.put("reason", "connect fail.");
+ resultObj.put(Constant.REASON, "connect fail.");
return resultObj;
}
LOG.info("get Access Session successful.");
}
// return values
- resultObj.put("retCode", Constant.HTTP_OK);
+ resultObj.put(Constant.RETCODE, Constant.HTTP_OK);
resultObj.put("vnfdId", vnfdid);
resultObj.put("vnfdVersion", vnfdVersion);
resultObj.put("planName", planName);
RestfulResponse rsp = VNFRestfulUtil.getRemoteResponse(paramsMap, "");
if(null == rsp) {
LOG.error("function=sendRequest, RestfulResponse is null");
- resultObj.put("reason", "RestfulResponse is null.");
- resultObj.put("retCode", Constant.REST_FAIL);
+ resultObj.put(Constant.REASON, "RestfulResponse is null.");
+ resultObj.put(Constant.RETCODE, Constant.REST_FAIL);
return resultObj;
}
String resultCreate = rsp.getResponseContent();
if(rsp.getStatus() == Constant.HTTP_OK) {
LOG.warn("function=sendRequest, msg= status={}, result={}.", rsp.getStatus(), resultCreate);
resultObj = JSONObject.fromObject(resultCreate);
- resultObj.put("retCode", Constant.HTTP_OK);
+ resultObj.put(Constant.RETCODE, Constant.HTTP_OK);
return resultObj;
} else {
LOG.error("function=sendRequest, msg=ESR return fail,status={}, result={}.", rsp.getStatus(), resultCreate);
- resultObj.put("reason", "ESR return fail.");
+ resultObj.put(Constant.REASON, "ESR return fail.");
}
- resultObj.put("retCode", Constant.REST_FAIL);
+ resultObj.put(Constant.RETCODE, Constant.REST_FAIL);
return resultObj;
}
JSONObject resultObj = new JSONObject();
if(null == csarid || "".equals(csarid)) {
- resultObj.put("reason", "csarid is null.");
- resultObj.put("retCode", Constant.REST_FAIL);
+ resultObj.put(Constant.REASON, "csarid is null.");
+ resultObj.put(Constant.RETCODE, Constant.REST_FAIL);
return resultObj;
}
JSONObject resultObj = new JSONObject();
if(url == null || "".equals(url)) {
- resultObj.put("reason", "url is null.");
- resultObj.put("retCode", Constant.REST_FAIL);
+ resultObj.put(Constant.REASON, "url is null.");
+ resultObj.put(Constant.RETCODE, Constant.REST_FAIL);
return resultObj;
}
if(filePath == null || "".equals(filePath)) {
- resultObj.put("reason", "downloadUrl filePath is null.");
- resultObj.put("retCode", Constant.REST_FAIL);
+ resultObj.put(Constant.REASON, "downloadUrl filePath is null.");
+ resultObj.put(Constant.RETCODE, Constant.REST_FAIL);
return resultObj;
}
String status = DownloadCsarManager.download(url, filePath);
if(Constant.DOWNLOADCSAR_SUCCESS.equals(status)) {
- resultObj.put("reason", "download csar file successfully.");
- resultObj.put("retCode", Constant.REST_SUCCESS);
+ resultObj.put(Constant.REASON, "download csar file successfully.");
+ resultObj.put(Constant.RETCODE, Constant.REST_SUCCESS);
} else {
- resultObj.put("reason", "download csar file failed.");
- resultObj.put("retCode", Constant.REST_FAIL);
+ resultObj.put(Constant.REASON, "download csar file failed.");
+ resultObj.put(Constant.RETCODE, Constant.REST_FAIL);
}
return resultObj;
}
} else {
LOG.error("uploadVNFPackage get allcloud failed, code:" + statusCode + " re:" + result);
resultObj.put(Constant.RETCODE, statusCode);
- resultObj.put("reason", "get allcloud failed. code:" + statusCode + " re:" + result);
+ resultObj.put(Constant.REASON, "get allcloud failed. code:" + statusCode + " re:" + result);
return resultObj;
}
} catch(JSONException e) {
LOG.error("function=uploadVNFPackage, msg=uploadVNFPackage get allcloud JSONException e={}.", e);
resultObj.put(Constant.RETCODE, Constant.HTTP_INNERERROR);
- resultObj.put("reason", "get allcloud failed and JSONException." + e.getMessage());
+ resultObj.put(Constant.REASON, "get allcloud failed and JSONException." + e.getMessage());
return resultObj;
} catch(VnfmException e) {
LOG.error("function=uploadVNFPackage, msg=uploadVNFPackage get allcloud VnfmException e={}.", e);
resultObj.put(Constant.RETCODE, Constant.HTTP_INNERERROR);
- resultObj.put("reason", "get allcloud failed and VnfmException." + e.getMessage());
+ resultObj.put(Constant.REASON, "get allcloud failed and VnfmException." + e.getMessage());
return resultObj;
} catch(IOException e) {
LOG.error("function=uploadVNFPackage, msg=uploadVNFPackage get allcloud IOException e={}.", e);
resultObj.put(Constant.RETCODE, Constant.HTTP_INNERERROR);
- resultObj.put("reason", "get allcloud failed and IOException." + e.getMessage());
+ resultObj.put(Constant.REASON, "get allcloud failed and IOException." + e.getMessage());
return resultObj;
}
return resultObj;
} catch(JSONException e) {
LOG.error("function=uploadVNFPackage, msg=uploadVNFPackage upload VNF package JSONException e={}.", e);
resultObj.put(Constant.RETCODE, Constant.HTTP_INNERERROR);
- resultObj.put("reason", "upload VNF package failed and JSONException." + e.getMessage());
+ resultObj.put(Constant.REASON, "upload VNF package failed and JSONException." + e.getMessage());
return resultObj;
} catch(VnfmException e) {
LOG.error("function=uploadVNFPackage, msg=uploadVNFPackage upload VNF package VnfmException e={}.", e);
resultObj.put(Constant.RETCODE, Constant.HTTP_INNERERROR);
- resultObj.put("reason", "upload VNF package failed and VnfmException." + e.getMessage());
+ resultObj.put(Constant.REASON, "upload VNF package failed and VnfmException." + e.getMessage());
return resultObj;
} catch(IOException e) {
LOG.error("function=uploadVNFPackage, msg=uploadVNFPackage upload VNF package IOException e={}.", e);
resultObj.put(Constant.RETCODE, Constant.HTTP_INNERERROR);
- resultObj.put("reason", "upload VNF package failed and IOException." + e.getMessage());
+ resultObj.put(Constant.REASON, "upload VNF package failed and IOException." + e.getMessage());
return resultObj;
}
return resultObj;
} catch(JSONException e) {
LOG.error("function=uploadVNFPackage, msg=uploadVNFPackage get vnfd version JSONException e={}.", e);
resultObj.put(Constant.RETCODE, Constant.HTTP_INNERERROR);
- resultObj.put("reason", "get vnfd version failed and JSONException." + e.getMessage());
+ resultObj.put(Constant.REASON, "get vnfd version failed and JSONException." + e.getMessage());
return resultObj;
} catch(VnfmException e) {
LOG.error("function=uploadVNFPackage, msg=uploadVNFPackage get vnfd version VnfmException e={}.", e);
resultObj.put(Constant.RETCODE, Constant.HTTP_INNERERROR);
- resultObj.put("reason", "get vnfd version failed and VnfmException." + e.getMessage());
+ resultObj.put(Constant.REASON, "get vnfd version failed and VnfmException." + e.getMessage());
return resultObj;
} catch(IOException e) {
LOG.error("function=uploadVNFPackage, msg=uploadVNFPackage get vnfd version IOException e={}.", e);
resultObj.put(Constant.RETCODE, Constant.HTTP_INNERERROR);
- resultObj.put("reason", "get vnfd version failed and IOException." + e.getMessage());
+ resultObj.put(Constant.REASON, "get vnfd version failed and IOException." + e.getMessage());
return resultObj;
}
return resultObj;
} else {
LOG.error("uploadVNFPackage get VNFDPlanInfo failed, code:" + statusCode + " re:" + result);
resultObj.put(Constant.RETCODE, statusCode);
- resultObj.put("reason", "get VNFDPlanInfo failed. code:" + statusCode + " re:" + result);
+ resultObj.put(Constant.REASON, "get VNFDPlanInfo failed. code:" + statusCode + " re:" + result);
return resultObj;
}
} catch(JSONException e) {
LOG.error("function=uploadVNFPackage, msg=uploadVNFPackage get VNFDPlanInfo JSONException e={}.", e);
resultObj.put(Constant.RETCODE, Constant.HTTP_INNERERROR);
- resultObj.put("reason", "get VNFDPlanInfo failed and JSONException." + e.getMessage());
+ resultObj.put(Constant.REASON, "get VNFDPlanInfo failed and JSONException." + e.getMessage());
return resultObj;
} catch(VnfmException e) {
LOG.error("function=uploadVNFPackage, msg=uploadVNFPackage get VNFDPlanInfo VnfmException e={}.", e);
resultObj.put(Constant.RETCODE, Constant.HTTP_INNERERROR);
- resultObj.put("reason", "get VNFDPlanInfo failed and VnfmException." + e.getMessage());
+ resultObj.put(Constant.REASON, "get VNFDPlanInfo failed and VnfmException." + e.getMessage());
return resultObj;
} catch(IOException e) {
LOG.error("function=uploadVNFPackage, msg=uploadVNFPackage get VNFDPlanInfo IOException e={}.", e);
resultObj.put(Constant.RETCODE, Constant.HTTP_INNERERROR);
- resultObj.put("reason", "get VNFDPlanInfo failed and IOException." + e.getMessage());
+ resultObj.put(Constant.REASON, "get VNFDPlanInfo failed and IOException." + e.getMessage());
return resultObj;
}
return resultObj;
JSONObject resultObj = new JSONObject();
if(fileName == null || "".equals(fileName)) {
- resultObj.put("reason", "fileName is null.");
- resultObj.put("retCode", Constant.REST_FAIL);
+ resultObj.put(Constant.REASON, "fileName is null.");
+ resultObj.put(Constant.RETCODE, Constant.REST_FAIL);
return resultObj;
}
if(filePath == null || "".equals(filePath)) {
- resultObj.put("reason", "unzipCSAR filePath is null.");
- resultObj.put("retCode", Constant.REST_FAIL);
+ resultObj.put(Constant.REASON, "unzipCSAR filePath is null.");
+ resultObj.put(Constant.RETCODE, Constant.REST_FAIL);
return resultObj;
}
int status = DownloadCsarManager.unzipCSAR(fileName, filePath);
if(Constant.UNZIP_SUCCESS == status) {
- resultObj.put("reason", "unzip csar file successfully.");
- resultObj.put("retCode", Constant.REST_SUCCESS);
+ resultObj.put(Constant.REASON, "unzip csar file successfully.");
+ resultObj.put(Constant.RETCODE, Constant.REST_SUCCESS);
} else {
- resultObj.put("reason", "unzip csar file failed.");
- resultObj.put("retCode", Constant.REST_FAIL);
+ resultObj.put(Constant.REASON, "unzip csar file failed.");
+ resultObj.put(Constant.RETCODE, Constant.REST_FAIL);
}
return resultObj;
}
/*
- * Copyright 2016 Huawei Technologies Co., Ltd.
+ * Copyright 2016-2017 Huawei Technologies Co., Ltd.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
import java.util.Map;
+import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.common.restclient.RestfulResponse;
import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.common.servicetoken.VNFRestfulUtil;
import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.service.adapter.inf.IDriver2MSBManager;
import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.service.constant.Constant;
-import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.common.restclient.RestfulResponse;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import net.sf.json.JSONObject;
/**
- *
* Driver to MSB Manager Class.<br/>
* <p>
* </p>
*
* @author
- * @version VFC 1.0 Aug 29, 2016
+ * @version VFC 1.0 Aug 29, 2016
*/
public class Driver2MSBManager implements IDriver2MSBManager {
RestfulResponse rsp = VNFRestfulUtil.getRemoteResponse(paramsMap, driverInfo.toString());
if(null == rsp) {
LOG.error("function=registerDriver, RestfulResponse is null");
- resultObj.put("reason", "RestfulResponse is null.");
- resultObj.put("retCode", Constant.REST_FAIL);
+ resultObj.put(Constant.REASON, "RestfulResponse is null.");
+ resultObj.put(Constant.RETCODE, Constant.REST_FAIL);
return resultObj;
}
String resultCreate = rsp.getResponseContent();
if(rsp.getStatus() == Constant.HTTP_CREATED) {
LOG.warn("function=registerDriver, msg= status={}, result={}.", rsp.getStatus(), resultCreate);
resultObj = JSONObject.fromObject(resultCreate);
- resultObj.put("retCode", Constant.HTTP_CREATED);
+ resultObj.put(Constant.RETCODE, Constant.HTTP_CREATED);
return resultObj;
} else if(rsp.getStatus() == Constant.HTTP_INVALID_PARAMETERS) {
LOG.error("function=registerDriver, msg=MSB return fail,invalid parameters,status={}, result={}.",
rsp.getStatus(), resultCreate);
- resultObj.put("reason", "MSB return fail,invalid parameters.");
+ resultObj.put(Constant.REASON, "MSB return fail,invalid parameters.");
} else if(rsp.getStatus() == Constant.HTTP_INNERERROR) {
LOG.error("function=registerDriver, msg=MSB return fail,internal system error,status={}, result={}.",
rsp.getStatus(), resultCreate);
- resultObj.put("reason", "MSB return fail,internal system error.");
+ resultObj.put(Constant.REASON, "MSB return fail,internal system error.");
}
- resultObj.put("retCode", Constant.REST_FAIL);
+ resultObj.put(Constant.RETCODE, Constant.REST_FAIL);
return resultObj;
}
RestfulResponse rsp = VNFRestfulUtil.getRemoteResponse(paramsMap, "");
if(null == rsp) {
LOG.error("function=unregisterDriver, RestfulResponse is null");
- resultObj.put("reason", "RestfulResponse is null.");
- resultObj.put("retCode", Constant.REST_FAIL);
+ resultObj.put(Constant.REASON, "RestfulResponse is null.");
+ resultObj.put(Constant.RETCODE, Constant.REST_FAIL);
return resultObj;
}
String resultCreate = rsp.getResponseContent();
if(rsp.getStatus() == Constant.HTTP_NOCONTENT) {
LOG.warn("function=unregisterDriver, msg= status={}, result={}.", rsp.getStatus(), resultCreate);
resultObj = JSONObject.fromObject(resultCreate);
- resultObj.put("retCode", Constant.HTTP_NOCONTENT);
+ resultObj.put(Constant.RETCODE, Constant.HTTP_NOCONTENT);
return resultObj;
} else if(rsp.getStatus() == Constant.HTTP_NOTFOUND) {
LOG.error(
"function=unregisterDriver, msg=MSB return fail,can't find the service instance.status={}, result={}.",
rsp.getStatus(), resultCreate);
- resultObj.put("reason", "MSB return fail,can't find the service instance.");
+ resultObj.put(Constant.REASON, "MSB return fail,can't find the service instance.");
} else if(rsp.getStatus() == Constant.HTTP_INVALID_PARAMETERS) {
LOG.error("function=unregisterDriver, msg=MSB return fail,invalid parameters,status={}, result={}.",
rsp.getStatus(), resultCreate);
- resultObj.put("reason", "MSB return fail,invalid parameters.");
+ resultObj.put(Constant.REASON, "MSB return fail,invalid parameters.");
} else if(rsp.getStatus() == Constant.HTTP_INNERERROR) {
LOG.error("function=unregisterDriver, msg=MSB return fail,internal system error,status={}, result={}.",
rsp.getStatus(), resultCreate);
- resultObj.put("reason", "MSB return fail,internal system error.");
+ resultObj.put(Constant.REASON, "MSB return fail,internal system error.");
}
- resultObj.put("retCode", Constant.REST_FAIL);
+ resultObj.put(Constant.RETCODE, Constant.REST_FAIL);
return resultObj;
}
import java.util.Map;
+import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.common.restclient.RestfulResponse;
import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.common.servicetoken.VNFRestfulUtil;
import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.service.adapter.inf.IVnfmAdapter2DriverManager;
import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.service.constant.Constant;
-import org.onap.vfc.nfvo.vnfm.svnfm.vnfmadapter.common.restclient.RestfulResponse;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
RestfulResponse rsp = VNFRestfulUtil.getRemoteResponse(paramsMap, driverInfo.toString());
if(null == rsp) {
LOG.error("function=registerDriver, RestfulResponse is null");
- resultObj.put("reason", "RestfulResponse is null.");
- resultObj.put("retCode", Constant.REST_FAIL);
+ resultObj.put(Constant.REASON, "RestfulResponse is null.");
+ resultObj.put(Constant.RETCODE, Constant.REST_FAIL);
return resultObj;
}
String resultCreate = rsp.getResponseContent();
if(rsp.getStatus() == Constant.HTTP_CREATED) {
LOG.warn("function=registerDriver, msg= status={}, result={}.", rsp.getStatus(), resultCreate);
- resultObj.put("retCode", Constant.HTTP_CREATED);
+ resultObj.put(Constant.RETCODE, Constant.HTTP_CREATED);
return resultObj;
} else if(rsp.getStatus() == Constant.HTTP_INVALID_PARAMETERS) {
LOG.error("function=registerDriver, msg=DriverManager return fail,invalid parameters,status={}, result={}.",
rsp.getStatus(), resultCreate);
- resultObj.put("reason", "DriverManager return fail,invalid parameters.");
+ resultObj.put(Constant.REASON, "DriverManager return fail,invalid parameters.");
} else if(rsp.getStatus() == Constant.HTTP_INNERERROR) {
LOG.error(
"function=registerDriver, msg=DriverManager return fail,internal system error,status={}, result={}.",
rsp.getStatus(), resultCreate);
- resultObj.put("reason", "DriverManager return fail,internal system error.");
+ resultObj.put(Constant.REASON, "DriverManager return fail,internal system error.");
}
- resultObj.put("retCode", Constant.REST_FAIL);
+ resultObj.put(Constant.RETCODE, Constant.REST_FAIL);
return resultObj;
}
RestfulResponse rsp = VNFRestfulUtil.getRemoteResponse(paramsMap, "");
if(null == rsp) {
LOG.error("function=unregisterDriver, RestfulResponse is null");
- resultObj.put("reason", "RestfulResponse is null.");
- resultObj.put("retCode", Constant.REST_FAIL);
+ resultObj.put(Constant.REASON, "RestfulResponse is null.");
+ resultObj.put(Constant.RETCODE, Constant.REST_FAIL);
return resultObj;
}
String resultCreate = rsp.getResponseContent();
if(rsp.getStatus() == Constant.HTTP_NOCONTENT) {
LOG.warn("function=unregisterDriver, msg= status={}, result={}.", rsp.getStatus(), resultCreate);
resultObj = JSONObject.fromObject(resultCreate);
- resultObj.put("retCode", Constant.HTTP_NOCONTENT);
+ resultObj.put(Constant.RETCODE, Constant.HTTP_NOCONTENT);
return resultObj;
} else if(rsp.getStatus() == Constant.HTTP_NOTFOUND) {
LOG.error(
"function=unregisterDriver, msg=DriverManager return fail,can't find the service instance.status={}, result={}.",
rsp.getStatus(), resultCreate);
- resultObj.put("reason", "DriverManager return fail,can't find the service instance.");
+ resultObj.put(Constant.REASON, "DriverManager return fail,can't find the service instance.");
} else if(rsp.getStatus() == Constant.HTTP_INVALID_PARAMETERS) {
LOG.error(
"function=unregisterDriver, msg=DriverManager return fail,invalid parameters,status={}, result={}.",
rsp.getStatus(), resultCreate);
- resultObj.put("reason", "DriverManager return fail,invalid parameters.");
+ resultObj.put(Constant.REASON, "DriverManager return fail,invalid parameters.");
} else if(rsp.getStatus() == Constant.HTTP_INNERERROR) {
LOG.error(
"function=unregisterDriver, msg=DriverManager return fail,internal system error,status={}, result={}.",
rsp.getStatus(), resultCreate);
- resultObj.put("reason", "DriverManager return fail,internal system error.");
+ resultObj.put(Constant.REASON, "DriverManager return fail,internal system error.");
}
- resultObj.put("retCode", Constant.REST_FAIL);
+ resultObj.put(Constant.RETCODE, Constant.REST_FAIL);
return resultObj;
}
private void sendRequest(Map<String, String> paramsMap, JSONObject driverInfo) {
JSONObject resultObj = adapter2DriverMgr.registerDriver(paramsMap, driverInfo);
- if(Integer.valueOf(resultObj.get("retCode").toString()) == Constant.HTTP_CREATED) {
+ if(Integer.valueOf(resultObj.get(Constant.RETCODE).toString()) == Constant.HTTP_CREATED) {
LOG.info("Vnfmadapter has now Successfully Registered to the Driver Manager!");
} else {
LOG.error("Vnfmadapter failed to Register to the Driver Manager! Reason:"
- + resultObj.get("reason").toString() + " retCode:" + resultObj.get("retCode").toString());
+ + resultObj.get(Constant.REASON).toString() + " retCode:"
+ + resultObj.get(Constant.RETCODE).toString());
// if registration fails,wait one minute and try again
try {
private void sendRequest(Map<String, String> paramsMap, JSONObject driverInfo) {
JSONObject resultObj = adapter2MSBMgr.registerDriver(paramsMap, driverInfo);
- if(Integer.valueOf(resultObj.get("retCode").toString()) == Constant.HTTP_CREATED) {
+ if(Integer.valueOf(resultObj.get(Constant.RETCODE).toString()) == Constant.HTTP_CREATED) {
LOG.info("Vnfmadapter has now Successfully Registered to the Microservice BUS!");
} else {
LOG.error("Vnfmadapter failed to Register to the Microservice BUS! Reason:"
- + resultObj.get("reason").toString() + " retCode:" + resultObj.get("retCode").toString());
+ + resultObj.get(Constant.REASON).toString() + " retCode:"
+ + resultObj.get(Constant.RETCODE).toString());
// if registration fails,wait one minute and try again
try {
/*
- * Copyright 2016 Huawei Technologies Co., Ltd.
+ * Copyright 2016-2017 Huawei Technologies Co., Ltd.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
addInfo.put("expires", 10);
addInfo.put("passwdStatus", "expiring");
authResult.put("additionalInfo", addInfo);
- restJson.put("retCode", Constant.REST_SUCCESS);
+ restJson.put(Constant.RETCODE, Constant.REST_SUCCESS);
restJson.put("data", authResult);
return restJson;
}
-}
\ No newline at end of file
+}
/*
- * Copyright 2016 Huawei Technologies Co., Ltd.
+ * Copyright 2016-2017 Huawei Technologies Co., Ltd.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
JSONObject authResult = authMgr.authToken(subJsonObject);
LOG.warn("authResult: {}", authResult);
- if(authResult.getInt("retCode") == Constant.REST_SUCCESS) {
+ if(authResult.getInt(Constant.RETCODE) == Constant.REST_SUCCESS) {
JSONObject data = authResult.getJSONObject("data");
resp.setStatus(Constant.HTTP_OK);
return data.toString();// String.format(ParamConstants.GET_TOKEN_SUC_RESP,
// data.getString("userName"),
// data.getString("userName"), data.getString("roaRand"));
- } else if(authResult.getInt("retCode") == Constant.HTTP_INNERERROR) {
+ } else if(authResult.getInt(Constant.RETCODE) == Constant.HTTP_INNERERROR) {
Response.status(Response.Status.INTERNAL_SERVER_ERROR).entity(authResult.getString("data")).build();
return String.format(ParamConstants.GET_TOKEN_FAIL_RESP, authResult.getString("data"));
@DELETE
@Path("/auth/tokens/{userName}/{roarand}")
public String delAuthToken(@Context HttpServletRequest context, @PathParam("userName") String userName,
- @PathParam("roarand") String roarand, @Context HttpServletResponse resp) {
+ @PathParam("roarand") String roarand, @Context HttpServletResponse resp) {
LOG.warn("function=logout, msg=enter to logout");
JSONObject resultJson = new JSONObject();
@GET
@Path("/nfvo/shakehand")
public String shakehand(@Context HttpServletRequest context, @QueryParam("roattr") String roattr,
- @Context HttpServletResponse resp) {
+ @Context HttpServletResponse resp) {
JSONObject resultJson = new JSONObject();
resultJson.put("status", "running");
resultJson.put("description", "Operation success");