* ============LICENSE_START=======================================================
* ONAP : APPC
* ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
+ * Copyright (C) 2017-2018 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* Copyright (C) 2017 Amdocs
* =============================================================================
static final String DEVICE_PROTOCOL_PREFIX = "tmp.deviceinterfaceprotocol";
static final String CONF_ACTION_PREFIX = "tmp.configureactiondg";
+ static final String CONFIG_FILES_PREFIX = "tmp.configFiles";
+ static final String MAX_CONF_FILE_PREFIX = "tmp.configfilesmax";
+ static final String UPLOAD_CONFIG_PREFIX = "tmp.uploadConfig";
+ static final String UPLOAD_CONFIG_INFO_PREFIX = "tmp.uploadConfigInfo";
+
+ static final String PREPARE_RELATIONSHIP_PARAM = "tmp.preparerel";
+ static final String CONFIG_FILE_ID_PARAM = "tmp.configfilesmax.configfileid";
+ static final String FILE_CATEGORY_PARAM = "file-category";
+ static final String UPLOAD_CONFIG_ID_PARAM = "tmp.uploadConfigInfo.UPLOAD-CONFIG-ID";
+
+ static final String SDC_IND = "N";
+ static final String TMP_CONVERTCONFIG_ESC_DATA = "tmp.convertconfig.escapeData";
+ static final String CONFIG_PARAMS = "configuration-params";
+ static final String TMP_MERGE_MERGED_DATA = "tmp.merge.mergedData";
+ static final String DATA_SOURCE = "data-source";
+ static final String FILE_CONTENT = "file-content";
+ static final String CAPABILITIES = "capabilities";
+ static final String NOT_SUPPORTED = "Not-Supported";
+ static final String UNABLE_TO_READ_STR = "Unable to Read ";
+ static final String UNABLE_TO_SAVE_RELATIONSHIP_STR = "Unable to save prepare_relationship";
+
+
+ static final String SITE_LOCATION_PARAM = "site-location";
+
private static final EELFLogger log = EELFManager.getInstance().getLogger(ConfigResourceNode.class);
private final DGGeneralDBService db;
* Constructor which provide default DB service
*/
public ConfigResourceNode() {
- db = DGGeneralDBService.initialise();
+ db = DGGeneralDBService.initialise();
}
/**
try {
responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix + ".") : "";
- QueryStatus status = db.getConfigFileReferenceByFileTypeNVnfType(ctx, DEVICE_CONF_PREFIX, DEVICE_CONF_FILE_TYPE);
+ QueryStatus status = db
+ .getConfigFileReferenceByFileTypeNVnfType(ctx, DEVICE_CONF_PREFIX, DEVICE_CONF_FILE_TYPE);
- if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE)
- throw new Exception("Unable to Read ConfigFileReference:device-configuration");
+ if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE) {
+ throw new QueryException("Unable to Read ConfigFileReference:device-configuration");
+ }
status = db.getConfigFileReferenceByFileTypeNVnfType(ctx, SUCCESS_PREFIX, SUCCESS_FILE_TYPE);
- if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE)
- throw new Exception("Unable to Read ConfigFileReference:configuration_success");
+ if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE) {
+ throw new QueryException("Unable to Read ConfigFileReference:configuration_success");
+ }
status = db.getConfigFileReferenceByFileTypeNVnfType(ctx, FAILURE_PREFIX, FAILURE_FILE_TYPE);
- if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE)
- throw new Exception("Unable to Read ConfigFileReference:configuration_error");
+ if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE) {
+ throw new QueryException("Unable to Read ConfigFileReference:configuration_error");
+ }
status = db.getConfigFileReferenceByFileTypeNVnfType(ctx, LOG_PREFIX, LOG_FILE_TYPE);
- if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE)
- throw new Exception("Unable to Read ConfigFileReference:configuration_log");
+ if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE) {
+ throw new QueryException("Unable to Read ConfigFileReference:configuration_log");
+ }
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
- AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
+ AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
log.info("GetConfigFileReference Successful ");
} catch (Exception e) {
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
- AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
+ AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
- log.error("Failed in GetConfigFileReference " + e.getMessage());
-
+ log.error("Failed in GetConfigFileReference", e);
throw new SvcLogicException(e.getMessage());
}
}
responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix + ".") : "";
QueryStatus status = db.getDeviceProtocolByVnfType(ctx, DEVICE_PROTOCOL_PREFIX);
- if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE)
- throw new Exception("Unable to Read device_interface_protocol");
+ if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE) {
+ throw new QueryException("Unable to Read device_interface_protocol");
+ }
status = db.getConfigureActionDGByVnfTypeNAction(ctx, CONF_ACTION_PREFIX);
- if (status == QueryStatus.FAILURE)
- throw new Exception("Unable to Read configure_action_dg");
+ if (status == QueryStatus.FAILURE) {
+ throw new QueryException("Unable to Read configure_action_dg");
+ }
if (status == QueryStatus.NOT_FOUND) {
status = db.getConfigureActionDGByVnfType(ctx, CONF_ACTION_PREFIX);
- if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE)
- throw new Exception("Unable to Read configure_action_dg");
+ if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE) {
+ throw new QueryException("Unable to Read configure_action_dg");
+ }
}
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
- AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
+ AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
log.info("getCommonConfigInfo Successful ");
} catch (Exception e) {
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
- AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
+ AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
- log.error("Failed in getCommonConfigInfo " + e.getMessage());
-
+ log.error("Failed in getCommonConfigInfo", e);
throw new SvcLogicException(e.getMessage());
}
}
String responsePrefix = inParams.get(AppcDataServiceConstant.INPUT_PARAM_RESPONSE_PREFIX);
String fileCategory = inParams.get(AppcDataServiceConstant.INPUT_PARAM_FILE_CATEGORY);
String templateName = ctx.getAttribute("template-name");
- QueryStatus status = null;
+ String templateModelId = ctx.getAttribute("template-model-id");
+ QueryStatus status;
String responsePrefix1 = "";
try {
log.info("RESPONSEPREFIX1 : " + responsePrefix1);
if (StringUtils.isBlank(templateName)) {
-
- // if ( !StringUtils.isBlank(ctx.getAttribute("vnfc-type"))) {
-
+ if (StringUtils.isNotBlank(templateModelId)) {
+ status = db.getTemplateWithTemplateModelId(ctx, responsePrefix, fileCategory,templateModelId);
+ if (status == QueryStatus.FAILURE) {
+ throw new QueryException(UNABLE_TO_READ_STR + fileCategory);
+ }
+ if (!(status == QueryStatus.NOT_FOUND) ) {
+ ctx.setAttribute(responsePrefix1 + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
+ AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
+ log.info("GetTemplate Successful ");
+ return;
+ }
+ }
status = db.getTemplate(ctx, responsePrefix, fileCategory);
- if (status == QueryStatus.FAILURE)
- throw new Exception("Unable to Read " + fileCategory);
- // }
+ if (status == QueryStatus.FAILURE) {
+ throw new QueryException(UNABLE_TO_READ_STR + fileCategory);
+ }
if (status == QueryStatus.NOT_FOUND) {
+ if (StringUtils.isNotBlank(templateModelId)) {
+ status = db.getTemplateByVnfTypeNActionWithTemplateModelId(ctx, responsePrefix, fileCategory,templateModelId);
+ if (status == QueryStatus.FAILURE) {
+ throw new QueryException(UNABLE_TO_READ_STR + fileCategory);
+ }
+ if (!(status == QueryStatus.NOT_FOUND) ) {
+ ctx.setAttribute(responsePrefix1 + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
+ AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
+ log.info("GetTemplate Successful ");
+ return;
+ }
+ }
+ if (status == QueryStatus.NOT_FOUND) {
- status = db.getTemplateByVnfTypeNAction(ctx, responsePrefix, fileCategory);
+ status = db.getTemplateByVnfTypeNAction(ctx, responsePrefix, fileCategory);
- if (status == QueryStatus.FAILURE)
- throw new Exception("Unable to Read " + fileCategory);
+ if (status == QueryStatus.FAILURE) {
+ throw new QueryException(UNABLE_TO_READ_STR + fileCategory);
+ }
- if (status == QueryStatus.NOT_FOUND) {
+ if (status == QueryStatus.NOT_FOUND) {
+ throw new QueryException(UNABLE_TO_READ_STR + fileCategory);
+ }
+ }
- // status = db.getTemplateByVnfType(ctx, responsePrefix, fileCategory);
- // if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE)
- throw new Exception("Unable to Read " + fileCategory);
- }
}
} else {
status = db.getTemplateByTemplateName(ctx, responsePrefix, templateName);
- if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE)
- throw new Exception("Unable to Read " + fileCategory + " template");
+ if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE) {
+ throw new QueryException(UNABLE_TO_READ_STR + fileCategory + " template");
+ }
}
ctx.setAttribute(responsePrefix1 + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
- AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
+ AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
log.info("GetTemplate Successful ");
} catch (Exception e) {
ctx.setAttribute(responsePrefix1 + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
- AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
+ AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
ctx.setAttribute(responsePrefix1 + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
- log.error("Failed in getTemplate " + e.getMessage());
+ log.error("Failed in getTemplate", e);
throw new SvcLogicException(e.getMessage());
}
}
- public void saveConfigFiles(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
+ void saveConfigFiles(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
log.info("Received saveConfigFiles call with params : " + inParams);
try {
responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix + ".") : "";
- QueryStatus status = db.saveConfigFiles(ctx, "tmp.configFiles");
+ QueryStatus status = db.saveConfigFiles(ctx, CONFIG_FILES_PREFIX);
- if (status == QueryStatus.FAILURE)
- throw new Exception("Unable to Save " + ctx.getAttribute("file-category") + " in configfiles");
+ if (status == QueryStatus.FAILURE) {
+ throw new QueryException("Unable to Save " + ctx.getAttribute(FILE_CATEGORY_PARAM) + " in configfiles");
+ }
- status = db.getMaxConfigFileId(ctx, "tmp.configfilesmax", ctx.getAttribute("file-category"));
+ status = db.getMaxConfigFileId(ctx, MAX_CONF_FILE_PREFIX, ctx.getAttribute(FILE_CATEGORY_PARAM));
- if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE)
- throw new Exception("Unable to get " + ctx.getAttribute("file-category") + " from configfiles");
+ if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE) {
+ throw new QueryException(
+ "Unable to get " + ctx.getAttribute(FILE_CATEGORY_PARAM) + " from configfiles");
+ }
- status = db.savePrepareRelationship(ctx, "tmp.preparerel",
- ctx.getAttribute("tmp.configfilesmax.configfileid"), "N");
- if (status == QueryStatus.FAILURE)
- throw new Exception("Unable to save prepare_relationship");
+ status = db.savePrepareRelationship(ctx, PREPARE_RELATIONSHIP_PARAM,
+ ctx.getAttribute(CONFIG_FILE_ID_PARAM), SDC_IND);
+ if (status == QueryStatus.FAILURE) {
+ throw new QueryException(UNABLE_TO_SAVE_RELATIONSHIP_STR);
+ }
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
- AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
+ AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
log.info("saveConfigFiles Successful ");
} catch (Exception e) {
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
- AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
+ AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
- log.error("Failed in saveConfigFiles " + e.getMessage());
+ log.error("Failed in saveConfigFiles", e);
throw new SvcLogicException(e.getMessage());
}
responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix + ".") : "";
ctx.setAttribute("tmp.escaped.devicerunningconfig",
- EscapeUtils.escapeSql(ctx.getAttribute("device-running-config")));
+ EscapeUtils.escapeSql(ctx.getAttribute("device-running-config")));
- QueryStatus status = db.saveUploadConfig(ctx, "tmp.uploadConfig");
+ QueryStatus status = db.saveUploadConfig(ctx, UPLOAD_CONFIG_PREFIX);
- if (status == QueryStatus.FAILURE)
- throw new Exception("Unable to Save configuration in upload_config");
+ if (status == QueryStatus.FAILURE) {
+ throw new QueryException("Unable to Save configuration in upload_config");
+ }
- status = db.getUploadConfigInfo(ctx, "tmp.uploadConfigInfo");
+ status = db.getUploadConfigInfo(ctx, UPLOAD_CONFIG_INFO_PREFIX);
- if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE)
- throw new Exception("Unable to get record from upload_config");
+ if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE) {
+ throw new QueryException("Unable to get record from upload_config");
+ }
- status = db.updateUploadConfig(ctx, "tmp.uploadConfig",
- Integer.parseInt(ctx.getAttribute("tmp.uploadConfigInfo.UPLOAD-CONFIG-ID")));
+ status = db.updateUploadConfig(ctx, UPLOAD_CONFIG_PREFIX,
+ Integer.parseInt(ctx.getAttribute(UPLOAD_CONFIG_ID_PARAM)));
if (status == QueryStatus.FAILURE)
- throw new Exception("Unable to upload upload_config");
+ throw new QueryException("Unable to upload upload_config");
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
- AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
+ AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
log.info("updateUploadConfig Successful ");
} catch (Exception e) {
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
- AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
+ AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
- log.error("Failed in updateUploadConfig " + e.getMessage());
+ log.error("Failed in updateUploadConfig", e);
throw new SvcLogicException(e.getMessage());
}
responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix + ".") : "";
- QueryStatus status = db.savePrepareRelationship(ctx, "tmp.preparerel", fileId, sdcArtifactInd);
- if (status == QueryStatus.FAILURE)
- throw new Exception("Unable to save prepare_relationship");
+ QueryStatus status = db.savePrepareRelationship(ctx, PREPARE_RELATIONSHIP_PARAM, fileId, sdcArtifactInd);
+ if (status == QueryStatus.FAILURE) {
+ throw new QueryException(UNABLE_TO_SAVE_RELATIONSHIP_STR);
+ }
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
- AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
+ AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
log.info("savePrepareRelationship Successful ");
} catch (Exception e) {
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
- AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
+ AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
- log.error("Failed in saveConfigFiles " + e.getMessage());
+ log.error("Failed in saveConfigFiles", e);
throw new SvcLogicException(e.getMessage());
}
try {
responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix + ".") : "";
- ctx.setAttribute("tmp.convertconfig.escapeData", EscapeUtils.escapeSql(ctx.getAttribute("configuration")));
+ ctx.setAttribute(TMP_CONVERTCONFIG_ESC_DATA, EscapeUtils.escapeSql(ctx.getAttribute("configuration")));
- if (StringUtils.isBlank(ctx.getAttribute("configuration-params"))) {
- saveDeviceConfiguration(inParams, ctx, "Request", ctx.getAttribute("tmp.convertconfig.escapeData"),
- ctx.getAttribute("configuration"));
+ if (StringUtils.isBlank(ctx.getAttribute(CONFIG_PARAMS))) {
+ saveDeviceConfiguration(inParams, ctx, "Request", ctx.getAttribute(TMP_CONVERTCONFIG_ESC_DATA),
+ ctx.getAttribute("configuration"));
} else {
saveConfigurationBlock(inParams, ctx);
- ctx.setAttribute("tmp.convertconfig.escapeData",
- EscapeUtils.escapeSql(ctx.getAttribute("tmp.merge.mergedData")));
- saveDeviceConfiguration(inParams, ctx, "Configurator", ctx.getAttribute("tmp.convertconfig.escapeData"),
- ctx.getAttribute("tmp.merge.mergedData"));
+ ctx.setAttribute(TMP_CONVERTCONFIG_ESC_DATA,
+ EscapeUtils.escapeSql(ctx.getAttribute(TMP_MERGE_MERGED_DATA)));
+ saveDeviceConfiguration(inParams, ctx, "Configurator", ctx.getAttribute(TMP_CONVERTCONFIG_ESC_DATA),
+ ctx.getAttribute(TMP_MERGE_MERGED_DATA));
saveConfigurationData(inParams, ctx);
}
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
- AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
+ AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
log.info("saveConfigBlock Successful ");
} catch (Exception e) {
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
- AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
+ AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
- log.error("Failed in saveConfigBlock " + e.getMessage());
+ log.error("Failed in saveConfigBlock", e);
throw new SvcLogicException(e.getMessage());
}
try {
responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix + ".") : "";
- if (StringUtils.isBlank(ctx.getAttribute("configuration-params"))) {
+ if (StringUtils.isBlank(ctx.getAttribute(CONFIG_PARAMS))) {
- ctx.setAttribute("tmp.convertconfig.escapeData",
- EscapeUtils.escapeSql(ctx.getAttribute("config-template.file-content")));
- saveDeviceConfiguration(inParams, ctx, "Template", ctx.getAttribute("tmp.convertconfig.escapeData"),
- ctx.getAttribute("config-template.file-content"));
+ ctx.setAttribute(TMP_CONVERTCONFIG_ESC_DATA,
+ EscapeUtils.escapeSql(ctx.getAttribute("config-template.file-content")));
+ saveDeviceConfiguration(inParams, ctx, "Template", ctx.getAttribute(TMP_CONVERTCONFIG_ESC_DATA),
+ ctx.getAttribute("config-template.file-content"));
} else {
saveConfigurationData(inParams, ctx);
- ctx.setAttribute("tmp.convertconfig.escapeData",
- EscapeUtils.escapeSql(ctx.getAttribute("tmp.merge.mergedData")));
- saveDeviceConfiguration(inParams, ctx, "Configurator", ctx.getAttribute("tmp.convertconfig.escapeData"),
- ctx.getAttribute("tmp.merge.mergedData"));
+ ctx.setAttribute(TMP_CONVERTCONFIG_ESC_DATA,
+ EscapeUtils.escapeSql(ctx.getAttribute(TMP_MERGE_MERGED_DATA)));
+ saveDeviceConfiguration(inParams, ctx, "Configurator", ctx.getAttribute(TMP_CONVERTCONFIG_ESC_DATA),
+ ctx.getAttribute(TMP_MERGE_MERGED_DATA));
}
- QueryStatus status = db.savePrepareRelationship(ctx, "tmp.preparerel",
- ctx.getAttribute("config-template.config-file-id"), "Y");
- if (status == QueryStatus.FAILURE)
- throw new Exception("Unable to save prepare_relationship");
+ QueryStatus status = db.savePrepareRelationship(ctx, PREPARE_RELATIONSHIP_PARAM,
+ ctx.getAttribute("config-template.config-file-id"), "Y");
+ if (status == QueryStatus.FAILURE) {
+ throw new QueryException(UNABLE_TO_SAVE_RELATIONSHIP_STR);
+ }
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
- AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
+ AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
log.info("saveTemplateConfig Successful ");
} catch (Exception e) {
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
- AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
+ AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
- log.error("Failed in saveTemplateConfig " + e.getMessage());
+ log.error("Failed in saveTemplateConfig", e);
throw new SvcLogicException(e.getMessage());
}
try {
responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix + ".") : "";
- ctx.setAttribute("tmp.convertconfig.escapeData",
- EscapeUtils.escapeSql(ctx.getAttribute("tmp.merge.mergedData")));
- saveDeviceConfiguration(inParams, ctx, "StyleSheet", ctx.getAttribute("tmp.convertconfig.escapeData"),
- ctx.getAttribute("tmp.merge.mergedData"));
+ ctx.setAttribute(TMP_CONVERTCONFIG_ESC_DATA,
+ EscapeUtils.escapeSql(ctx.getAttribute(TMP_MERGE_MERGED_DATA)));
+ saveDeviceConfiguration(inParams, ctx, "StyleSheet", ctx.getAttribute(TMP_CONVERTCONFIG_ESC_DATA),
+ ctx.getAttribute(TMP_MERGE_MERGED_DATA));
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
- AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
+ AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
log.info("saveStyleSheet Successful ");
} catch (Exception e) {
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
- AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
+ AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
- log.error("Failed in saveStyleSheet " + e.getMessage());
+ log.error("Failed in saveStyleSheet", e);
throw new SvcLogicException(e.getMessage());
}
log.info("Received saveStyleSheet call with params : " + inParams);
String responsePrefix = inParams.get(AppcDataServiceConstant.INPUT_PARAM_RESPONSE_PREFIX);
- String siteLocation = ctx.getAttribute("site-location");
+ String siteLocation = ctx.getAttribute(SITE_LOCATION_PARAM);
- QueryStatus status = null;
+ QueryStatus status;
try {
status = db.getTemplateByArtifactType(ctx, "smm", "smm", siteLocation);
- if (status == QueryStatus.FAILURE)
- throw new Exception("Unable to Read smm file");
+ if (status == QueryStatus.FAILURE) {
+ throw new QueryException("Unable to Read smm file");
+ }
status = db.getTemplateByArtifactType(ctx, "intermediate-ca-chain", "intermediate_ca_chain", siteLocation);
- if (status == QueryStatus.FAILURE)
- throw new Exception("Unable to Read intermediate_ca_chain file");
+ if (status == QueryStatus.FAILURE) {
+ throw new QueryException("Unable to Read intermediate_ca_chain file");
+ }
status = db.getTemplateByArtifactType(ctx, "server-certificate-and-key", "server_certificate_and_key",
- siteLocation);
+ siteLocation);
- if (status == QueryStatus.FAILURE)
- throw new Exception("Unable to Read server_certificate_and_key file");
+ if (status == QueryStatus.FAILURE) {
+ throw new QueryException("Unable to Read server_certificate_and_key file");
+ }
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
- AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
+ AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
log.info("saveStyleSheet Successful ");
} catch (Exception e) {
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
- AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
+ AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
- log.error("Failed in saveStyleSheet " + e.getMessage());
+ log.error("Failed in saveStyleSheet", e);
throw new SvcLogicException(e.getMessage());
}
}
public void saveDeviceConfiguration(Map<String, String> inParams, SvcLogicContext ctx, String dataSource,
- String fileContent, String deviceConfig) throws SvcLogicException {
- ctx.setAttribute("data-source", dataSource);
- ctx.setAttribute("file-content", fileContent);
- ctx.setAttribute("file-category", "device_configuration");
+ String fileContent, String deviceConfig) throws SvcLogicException {
+ ctx.setAttribute(DATA_SOURCE, dataSource);
+ ctx.setAttribute(FILE_CONTENT, fileContent);
+ ctx.setAttribute(FILE_CATEGORY_PARAM, "device_configuration");
ctx.setAttribute("deviceconfig-file-content", deviceConfig);
saveConfigFiles(inParams, ctx);
}
- public void saveConfigurationBlock(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
- ctx.setAttribute("data-source", "Request");
- ctx.setAttribute("file-content", ctx.getAttribute("tmp.convertconfig.escapeData"));
- ctx.setAttribute("file-category", "configuration_block");
+ private void saveConfigurationBlock(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
+ ctx.setAttribute(DATA_SOURCE, "Request");
+ ctx.setAttribute(FILE_CONTENT, ctx.getAttribute(TMP_CONVERTCONFIG_ESC_DATA));
+ ctx.setAttribute(FILE_CATEGORY_PARAM, "configuration_block");
saveConfigFiles(inParams, ctx);
}
- public void saveConfigurationData(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
- ctx.setAttribute("data-source", ctx.getAttribute("originator-id"));
- ctx.setAttribute("file-content", ctx.getAttribute("configuration-params"));
- ctx.setAttribute("file-category", "config_data");
+ private void saveConfigurationData(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
+ ctx.setAttribute(DATA_SOURCE, ctx.getAttribute("originator-id"));
+ ctx.setAttribute(FILE_CONTENT, ctx.getAttribute(CONFIG_PARAMS));
+ ctx.setAttribute(FILE_CATEGORY_PARAM, "config_data");
saveConfigFiles(inParams, ctx);
}
public void getConfigFilesByVnfVmNCategory(Map<String, String> inParams, SvcLogicContext ctx)
- throws SvcLogicException {
+ throws SvcLogicException {
log.info("Received getConfigFilesByVnfVmNCategory call with params : " + inParams);
try {
QueryStatus status = db.getConfigFilesByVnfVmNCategory(ctx, responsePrefix, fileCategory, vnfId, vmName);
- if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE)
- throw new Exception("Unable to get " + ctx.getAttribute("fileCategory") + " from configfiles");
+ if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE) {
+ throw new QueryException("Unable to get " + ctx.getAttribute("fileCategory") + " from configfiles");
+ }
responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix + ".") : "";
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
- AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
+ AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
log.info("getConfigFilesByVnfVmNCategory Successful "
- + ctx.getAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS));
+ + ctx.getAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS));
} catch (Exception e) {
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
- AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
+ AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
- log.error("Failed in getConfigFilesByVnfVmNCategory " + e.getMessage());
+ log.error("Failed in getConfigFilesByVnfVmNCategory", e);
throw new SvcLogicException(e.getMessage());
}
}
public void getDownloadConfigTemplateByVnf(Map<String, String> inParams, SvcLogicContext ctx)
- throws SvcLogicException {
+ throws SvcLogicException {
log.info("Received getDownloadConfigTemplateByVnfNProtocol call with params : " + inParams);
try {
QueryStatus status = db.getDownloadConfigTemplateByVnf(ctx, responsePrefix);
- if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE)
- throw new Exception("Unable to get download config template.");
+ if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE) {
+ throw new QueryException("Unable to get download config template.");
+ }
responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix + ".") : "";
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
- AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
+ AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
log.info("getDownloadConfigTemplateByVnf Successful "
- + ctx.getAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS));
+ + ctx.getAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS));
} catch (Exception e) {
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
- AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
+ AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
- log.error("Failed in getDownloadConfigTemplateByVnf " + e.getMessage());
+ log.error("Failed in getDownloadConfigTemplateByVnf", e);
throw new SvcLogicException(e.getMessage());
}
logctx.setAttribute("log-message", null);
- if (status == QueryStatus.FAILURE)
- throw new Exception("Unable to insert into config_transaction_log");
+ if (status == QueryStatus.FAILURE) {
+ throw new QueryException("Unable to insert into config_transaction_log");
+ }
} catch (Exception e) {
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
- AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
+ AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
-
+ log.error("Failed in saveConfigTransactionLog", e);
throw new SvcLogicException(e.getMessage());
}
}
log.info("Received getVnfcReference call with params : " + inParams);
String responsePrefix = inParams.get(AppcDataServiceConstant.INPUT_PARAM_RESPONSE_PREFIX);
+ String templateModelId = ctx.getAttribute("template-model-id");
+ log.info("getVnfcReference():::"+templateModelId);
QueryStatus status = null;
try {
if (!StringUtils.isBlank(ctx.getAttribute("vnfc-type"))) {
+
+
status = db.getVnfcReferenceByVnfcTypeNAction(ctx, responsePrefix);
- if (status == QueryStatus.FAILURE)
- throw new Exception("Unable to Read vnfc-reference");
- }
- // else if (status == QueryStatus.NOT_FOUND ) {
- status = db.getVnfcReferenceByVnfTypeNAction(ctx, responsePrefix);
+ if (status == QueryStatus.FAILURE) {
+ throw new QueryException("Unable to Read vnfc-reference");
+ }
- if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE)
- throw new Exception("Unable to Read vnfc reference");
+ }
+ if (StringUtils.isNotBlank(templateModelId)) {
+ status = db.getVnfcReferenceByVnfTypeNActionWithTemplateModelId(ctx, responsePrefix,templateModelId);
+ if (status == QueryStatus.FAILURE) {
+ throw new QueryException("Unable to Read vnfc-reference with template-model-id");
+ }
+ }
+ if (StringUtils.isBlank(templateModelId) || (StringUtils.isNotBlank(templateModelId) && (status == QueryStatus.NOT_FOUND))) {
+ status = db.getVnfcReferenceByVnfTypeNAction(ctx, responsePrefix);
- // }
+ if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE) {
+ throw new QueryException("Unable to Read vnfc reference");
+ }
+ }
responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix + ".") : "";
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
- AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
+ AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
log.info("getVnfcReference Successful ");
} catch (Exception e) {
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
- AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
+ AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
- log.error("Failed in getVnfcReference " + e.getMessage());
+ log.error("Failed in getVnfcReference", e);
throw new SvcLogicException(e.getMessage());
}
String vServerId = inParams.get("vServerId");
if (!checkIfCapabilityCheckNeeded(caplevel, findCapability)) {
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
- AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
+ AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
log.info("getCapability Successful - No need for capability check for this action");
return;
}
log.info("getCapability::returned from DB::+cap");
if (StringUtils.isBlank(cap)) {
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
- AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
+ AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
log.info("getCapability Successful - No capability blocks found");
return;
}
ObjectMapper mapper = new ObjectMapper();
JsonNode caps = mapper.readTree(cap);
log.info("From DB = " + caps);
- JsonNode capabilities = caps.get("capabilities");
+ JsonNode capabilities = caps.get(CAPABILITIES);
log.info("capabilities = " + capabilities);
if (caplevel != null && !caplevel.isEmpty()) {
JsonNode subCapabilities = capabilities.get(caplevel);
log.info("subCapabilities = " + caplevel + " : " + subCapabilities);
if (caplevel.equalsIgnoreCase(AppcDataServiceConstant.CAPABILITY_VM_LEVEL)
- && (null == subCapabilities || subCapabilities.isNull() || subCapabilities.size() == 0)) {
- ctx.setAttribute("capabilities", "None");
+ && (null == subCapabilities || subCapabilities.isNull() || subCapabilities.size() == 0)) {
+ ctx.setAttribute(CAPABILITIES, "None");
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
- AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
+ AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
log.info("getCapability Successful ");
return;
}
if (findCapability != null && !findCapability.isEmpty()) {
if (subCapabilities != null && subCapabilities.toString().contains(findCapability)) {
- if (caplevel.equalsIgnoreCase(AppcDataServiceConstant.CAPABILITY_VM_LEVEL))
+ if (caplevel.equalsIgnoreCase(AppcDataServiceConstant.CAPABILITY_VM_LEVEL)) {
processCapabilitiesForVMLevel(vServerId, ctx, findCapability, subCapabilities);
- else
- ctx.setAttribute("capabilities", "Supported");
+ } else {
+ ctx.setAttribute(CAPABILITIES, "Supported");
+ }
} else {
- ctx.setAttribute("capabilities", "Not-Supported");
+ ctx.setAttribute(CAPABILITIES, NOT_SUPPORTED);
}
} else {
ctx.setAttribute(responsePrefix + "capabilities." + caplevel, subCapabilities.toString());
}
- } else
- ctx.setAttribute(responsePrefix + "capabilities", capabilities.toString());
+ } else {
+ ctx.setAttribute(responsePrefix + CAPABILITIES, capabilities.toString());
+ }
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
- AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
+ AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
log.info("getCapability Successful ");
} catch (Exception e) {
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
- AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
+ AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
- log.error("Failed in getCapability " + e.getMessage());
+ log.error("Failed in getCapability", e);
throw new SvcLogicException(e.getMessage());
}
}
public void processCapabilitiesForVMLevel(String vServerId, SvcLogicContext ctx, String findCapability,
- JsonNode subCapabilities) throws Exception {
+ JsonNode subCapabilities) {
log.info("processCapabilitiesForVMLevel():::subCapabilities::" + subCapabilities.toString() + ",vServerId::"
- + vServerId);
+ + vServerId);
if (subCapabilities.size() == 0) {
- ctx.setAttribute("capabilities", "None");
+ ctx.setAttribute(CAPABILITIES, "None");
log.info("processCapabilitiesForVMLevel :: No VM block found!!");
return;
}
JsonNode vmCaps = null;
for (JsonNode cap : subCapabilities) {
if (null != cap && null != cap.get(findCapability)
- && StringUtils.isNotBlank(cap.get(findCapability).toString())) {
+ && StringUtils.isNotBlank(cap.get(findCapability).toString())) {
vmCaps = cap.get(findCapability);
log.info("processCapabilitiesForVMLevel()::vmCaps found" + vmCaps.toString());
break;
}
if (null == vmCaps || vmCaps.isNull() || vmCaps.size() == 0) {
- ctx.setAttribute("capabilities", "Not-Supported");
+ ctx.setAttribute(CAPABILITIES, NOT_SUPPORTED);
log.info("processCapabilitiesForVMLevel :: Found non-empty VM block but Not desired capability!!");
return;
}
String vnfcFunctionCode = getVnfcFunctionCodeForVserver(ctx, vServerId);
if (StringUtils.isBlank(vnfcFunctionCode)) {
log.info("processCapabilitiesForVMLevel() :: vnfcFunctionCode is not present in context!!!");
- ctx.setAttribute("capabilities", "Not-Supported");
+ ctx.setAttribute(CAPABILITIES, NOT_SUPPORTED);
return;
}
- if (vmCaps.toString().contains(vnfcFunctionCode))
- ctx.setAttribute("capabilities", "Supported");
- else
- ctx.setAttribute("capabilities", "Not-Supported");
- log.info("End processCapabilitiesForVMLevel():capabilities is ::" + ctx.getAttribute("capabilities"));
+ if (vmCaps.toString().contains(vnfcFunctionCode)) {
+ ctx.setAttribute(CAPABILITIES, "Supported");
+ } else {
+ ctx.setAttribute(CAPABILITIES, NOT_SUPPORTED);
+ }
+ log.info("End processCapabilitiesForVMLevel():capabilities is ::" + ctx.getAttribute(CAPABILITIES));
}
- private String getVnfcFunctionCodeForVserver(SvcLogicContext ctx, String vServerId) throws Exception {
+ private String getVnfcFunctionCodeForVserver(SvcLogicContext ctx, String vServerId) {
log.info("getVnfcFunctionCodeForVserver()::vServerId=" + vServerId);
for (Object key : ctx.getAttributeKeySet()) {
String parmName = (String) key;
String parmValue = ctx.getAttribute(parmName);
- log.info(parmName + "=" + parmValue);
+ log.info(parmName + "=" + parmValue);
}
String vnfcFunctionCode = ctx.getAttribute("tmp.vnfInfo.vm.vnfc.vnfc-function-code");
public boolean checkIfCapabilityCheckNeeded(String caplevel, String findCapability) {
boolean capabilityCheckNeeded = true;
if (!StringUtils.equalsIgnoreCase(caplevel, AppcDataServiceConstant.CAPABILITY_VM_LEVEL)) {
- List<AppcDataServiceConstant.ACTIONS> actionList = new ArrayList<AppcDataServiceConstant.ACTIONS>(
- Arrays.asList(AppcDataServiceConstant.ACTIONS.values()));
+ List<AppcDataServiceConstant.ACTIONS> actionList = new ArrayList<>(
+ Arrays.asList(AppcDataServiceConstant.ACTIONS.values()));
for (AppcDataServiceConstant.ACTIONS action : actionList) {
if (StringUtils.equalsIgnoreCase(action.toString(), findCapability)) {
capabilityCheckNeeded = false;
}
return capabilityCheckNeeded;
}
-}
\ No newline at end of file
+
+}
Code Review / appc.git / blobdiff