summaryrefslogtreecommitdiffstats
path: root/appc-config/appc-data-services/provider/src/main/java
diff options
context:
space:
mode:
authorSkip Wonnell <skip@att.com>2018-01-10 19:22:56 -0600
committerPatrick Brady <pb071s@att.com>2018-01-11 22:23:27 +0000
commit45a2f9496998236dc9b3c6ebcb6008ef11f80fc5 (patch)
tree679a661a3ad59336508b2df5b69d2e390f5865dc /appc-config/appc-data-services/provider/src/main/java
parentc670d4dd2e503b8a9d1e313ed068c10f6e6b0861 (diff)
Sonar blocker issue resolution
Resolve this Sonar blocker issue: https://sonar.onap.org/issues/search#issues=AWDAtKDw-08if2a6wtv- Change-Id: I723651c5f2ab64d79dce4e9a609d4d59e245515d Issue-ID: APPC-388 Signed-off-by: Skip Wonnell <skip@att.com>
Diffstat (limited to 'appc-config/appc-data-services/provider/src/main/java')
-rw-r--r--appc-config/appc-data-services/provider/src/main/java/org/onap/appc/data/services/node/ConfigResourceNode.java237
1 files changed, 89 insertions, 148 deletions
diff --git a/appc-config/appc-data-services/provider/src/main/java/org/onap/appc/data/services/node/ConfigResourceNode.java b/appc-config/appc-data-services/provider/src/main/java/org/onap/appc/data/services/node/ConfigResourceNode.java
index 856e93e18..a9d3dbb8f 100644
--- a/appc-config/appc-data-services/provider/src/main/java/org/onap/appc/data/services/node/ConfigResourceNode.java
+++ b/appc-config/appc-data-services/provider/src/main/java/org/onap/appc/data/services/node/ConfigResourceNode.java
@@ -7,9 +7,9 @@
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@@ -20,27 +20,22 @@
package org.onap.appc.data.services.node;
-import java.util.Map;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
-
+import java.util.Map;
import org.apache.commons.lang3.StringUtils;
-import com.att.eelf.configuration.EELFLogger;
-import com.att.eelf.configuration.EELFManager;
-import com.fasterxml.jackson.databind.JsonNode;
-import com.fasterxml.jackson.databind.ObjectMapper;
-
-import org.onap.ccsdk.sli.core.sli.SvcLogicContext;
-import org.onap.ccsdk.sli.core.sli.SvcLogicException;
-import org.onap.ccsdk.sli.core.sli.SvcLogicJavaPlugin;
-
import org.onap.appc.data.services.AppcDataServiceConstant;
-import org.onap.appc.data.services.AppcDataServiceConstant.ACTIONS;
import org.onap.appc.data.services.db.DGGeneralDBService;
import org.onap.appc.data.services.utils.EscapeUtils;
-
+import org.onap.ccsdk.sli.core.sli.SvcLogicContext;
+import org.onap.ccsdk.sli.core.sli.SvcLogicException;
+import org.onap.ccsdk.sli.core.sli.SvcLogicJavaPlugin;
import org.onap.ccsdk.sli.core.sli.SvcLogicResource.QueryStatus;
+import com.att.eelf.configuration.EELFLogger;
+import com.att.eelf.configuration.EELFManager;
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.ObjectMapper;
public class ConfigResourceNode implements SvcLogicJavaPlugin {
@@ -54,7 +49,7 @@ public class ConfigResourceNode implements SvcLogicJavaPlugin {
try {
- responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix+".") : "";
+ responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix + ".") : "";
DGGeneralDBService db = DGGeneralDBService.initialise();
QueryStatus status = db.getConfigFileReferenceByFileTypeNVnfType(ctx, "configfilereference-deviceconfig",
"device_configuration");
@@ -101,7 +96,7 @@ public class ConfigResourceNode implements SvcLogicJavaPlugin {
try {
- responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix+".") : "";
+ responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix + ".") : "";
DGGeneralDBService db = DGGeneralDBService.initialise();
QueryStatus status = db.getDeviceProtocolByVnfType(ctx, "tmp.deviceinterfaceprotocol");
@@ -122,8 +117,6 @@ public class ConfigResourceNode implements SvcLogicJavaPlugin {
-
-
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
log.info("getCommonConfigInfo Successful ");
@@ -138,7 +131,7 @@ public class ConfigResourceNode implements SvcLogicJavaPlugin {
}
- // fileCategory Can be config_template, parameter_definitions, parameter_yang
+ // fileCategory Can be config_template, parameter_definitions, parameter_yang
public void getTemplate(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
log.info("Received getTemplate call with params : " + inParams);
@@ -152,7 +145,7 @@ public class ConfigResourceNode implements SvcLogicJavaPlugin {
try {
- responsePrefix1 = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix+".") : "";
+ responsePrefix1 = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix + ".") : "";
log.info("RESPONSEPREFIX : " + responsePrefix);
log.info("RESPONSEPREFIX1 : " + responsePrefix1);
@@ -160,13 +153,13 @@ public class ConfigResourceNode implements SvcLogicJavaPlugin {
if (StringUtils.isBlank(templateName)) {
- //if ( !StringUtils.isBlank(ctx.getAttribute("vnfc-type"))) {
+ // if ( !StringUtils.isBlank(ctx.getAttribute("vnfc-type"))) {
status = db.getTemplate(ctx, responsePrefix, fileCategory);
if (status == QueryStatus.FAILURE)
- throw new Exception("Unable to Read " + fileCategory );
- //}
+ throw new Exception("Unable to Read " + fileCategory);
+ // }
if (status == QueryStatus.NOT_FOUND) {
@@ -174,14 +167,14 @@ public class ConfigResourceNode implements SvcLogicJavaPlugin {
status = db.getTemplateByVnfTypeNAction(ctx, responsePrefix, fileCategory);
if (status == QueryStatus.FAILURE)
- throw new Exception("Unable to Read " + fileCategory );
+ throw new Exception("Unable to Read " + fileCategory);
if (status == QueryStatus.NOT_FOUND) {
- //status = db.getTemplateByVnfType(ctx, responsePrefix, fileCategory);
+ // status = db.getTemplateByVnfType(ctx, responsePrefix, fileCategory);
- //if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE)
- throw new Exception("Unable to Read " + fileCategory );
+ // if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE)
+ throw new Exception("Unable to Read " + fileCategory);
}
}
} else {
@@ -214,7 +207,7 @@ public class ConfigResourceNode implements SvcLogicJavaPlugin {
try {
- responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix+".") : "";
+ responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix + ".") : "";
DGGeneralDBService db = DGGeneralDBService.initialise();
QueryStatus status = db.saveConfigFiles(ctx, "tmp.configFiles");
@@ -252,7 +245,7 @@ public class ConfigResourceNode implements SvcLogicJavaPlugin {
try {
- responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix+".") : "";
+ responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix + ".") : "";
DGGeneralDBService db = DGGeneralDBService.initialise();
ctx.setAttribute("tmp.escaped.devicerunningconfig",
@@ -263,16 +256,6 @@ public class ConfigResourceNode implements SvcLogicJavaPlugin {
if (status == QueryStatus.FAILURE)
throw new Exception("Unable to Save configuration in upload_config");
- /*status = db.getMaxUploadConfigFileId(ctx, "tmp.uploadconfigmax");
-
- if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE)
- throw new Exception("Unable to get record from upload_config");
-
- status = db.updateUploadConfig(ctx, "tmp.uploadConfig",
- Integer.parseInt(ctx.getAttribute("tmp.uploadconfigmax.uploadconfigid")));
- if (status == QueryStatus.FAILURE)
- throw new Exception("Unable to upload upload_config");*/
-
status = db.getUploadConfigInfo(ctx, "tmp.uploadConfigInfo");
if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE)
@@ -305,7 +288,7 @@ public class ConfigResourceNode implements SvcLogicJavaPlugin {
String fileId = inParams.get(AppcDataServiceConstant.INPUT_PARAM_FILE_ID);
try {
- responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix+".") : "";
+ responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix + ".") : "";
DGGeneralDBService db = DGGeneralDBService.initialise();
QueryStatus status = db.savePrepareRelationship(ctx, "tmp.preparerel", fileId, sdcArtifactInd);
@@ -333,9 +316,8 @@ public class ConfigResourceNode implements SvcLogicJavaPlugin {
try {
- responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix+".") : "";
- ctx.setAttribute("tmp.convertconfig.escapeData",
- EscapeUtils.escapeSql(ctx.getAttribute("configuration")));
+ responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix + ".") : "";
+ ctx.setAttribute("tmp.convertconfig.escapeData", EscapeUtils.escapeSql(ctx.getAttribute("configuration")));
DGGeneralDBService db = DGGeneralDBService.initialise();
if (StringUtils.isBlank(ctx.getAttribute("configuration-params"))) {
@@ -374,7 +356,7 @@ public class ConfigResourceNode implements SvcLogicJavaPlugin {
try {
- responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix+".") : "";
+ responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix + ".") : "";
DGGeneralDBService db = DGGeneralDBService.initialise();
if (StringUtils.isBlank(ctx.getAttribute("configuration-params"))) {
@@ -414,7 +396,6 @@ public class ConfigResourceNode implements SvcLogicJavaPlugin {
-
public void saveStyleSheetConfig(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
@@ -424,18 +405,20 @@ public class ConfigResourceNode implements SvcLogicJavaPlugin {
try {
- responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix+".") : "";
+ 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(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS, AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
+ ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
+ AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
log.info("saveStyleSheet Successful ");
} catch (Exception e) {
- ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS, AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
- ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE,e.getMessage());
+ ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
+ AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
+ ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
log.error("Failed in saveStyleSheet " + e.getMessage());
throw new SvcLogicException(e.getMessage());
@@ -453,39 +436,41 @@ public class ConfigResourceNode implements SvcLogicJavaPlugin {
QueryStatus status = null;
- try{
+ try {
- responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix+".") : "";
+ responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix + ".") : "";
DGGeneralDBService db = DGGeneralDBService.initialise();
- status = db.getTemplateByArtifactType(ctx, "smm", "smm", siteLocation);
+ status = db.getTemplateByArtifactType(ctx, "smm", "smm", siteLocation);
- if ( status == QueryStatus.FAILURE )
+ if (status == QueryStatus.FAILURE)
throw new Exception("Unable to Read smm file");
- status = db.getTemplateByArtifactType(ctx, "intermediate-ca-chain", "intermediate_ca_chain", siteLocation);
+ status = db.getTemplateByArtifactType(ctx, "intermediate-ca-chain", "intermediate_ca_chain", siteLocation);
- if ( status == QueryStatus.FAILURE )
+ if (status == QueryStatus.FAILURE)
throw new Exception("Unable to Read intermediate_ca_chain file");
+ status = db.getTemplateByArtifactType(ctx, "server-certificate-and-key", "server_certificate_and_key",
+ siteLocation);
- status = db.getTemplateByArtifactType(ctx, "server-certificate-and-key", "server_certificate_and_key", siteLocation);
-
- if ( status == QueryStatus.FAILURE )
+ if (status == QueryStatus.FAILURE)
throw new Exception("Unable to Read server_certificate_and_key file");
- ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS, AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
+ ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
+ AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
log.info("saveStyleSheet Successful ");
} catch (Exception e) {
- ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS, AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
- ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE,e.getMessage());
+ ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
+ AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
+ ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
log.error("Failed in saveStyleSheet " + e.getMessage());
throw new SvcLogicException(e.getMessage());
@@ -518,7 +503,8 @@ public class ConfigResourceNode implements SvcLogicJavaPlugin {
}
- public void getConfigFilesByVnfVmNCategory(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
+ public void getConfigFilesByVnfVmNCategory(Map<String, String> inParams, SvcLogicContext ctx)
+ throws SvcLogicException {
log.info("Received getConfigFilesByVnfVmNCategory call with params : " + inParams);
@@ -537,10 +523,11 @@ public class ConfigResourceNode implements SvcLogicJavaPlugin {
throw new Exception("Unable to get " + ctx.getAttribute("fileCategory") + " from configfiles");
- responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix+".") : "";
+ responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix + ".") : "";
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
- log.info("getConfigFilesByVnfVmNCategory Successful " + ctx.getAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS));
+ log.info("getConfigFilesByVnfVmNCategory Successful "
+ + ctx.getAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS));
} catch (Exception e) {
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
@@ -552,7 +539,8 @@ public class ConfigResourceNode implements SvcLogicJavaPlugin {
}
- public void getDownloadConfigTemplateByVnf(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
+ public void getDownloadConfigTemplateByVnf(Map<String, String> inParams, SvcLogicContext ctx)
+ throws SvcLogicException {
log.info("Received getDownloadConfigTemplateByVnfNProtocol call with params : " + inParams);
@@ -566,9 +554,11 @@ public class ConfigResourceNode implements SvcLogicJavaPlugin {
throw new Exception("Unable to get download config template.");
- responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix+".") : "";
- ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS, AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
- log.info("getDownloadConfigTemplateByVnf Successful " + ctx.getAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS));
+ responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix + ".") : "";
+ ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
+ AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
+ log.info("getDownloadConfigTemplateByVnf Successful "
+ + ctx.getAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS));
} catch (Exception e) {
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
@@ -601,9 +591,9 @@ public class ConfigResourceNode implements SvcLogicJavaPlugin {
logctx.setAttribute("log-message", escapedMessage);
- responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix+".") : "";
+ responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix + ".") : "";
DGGeneralDBService db = DGGeneralDBService.initialise();
- QueryStatus status = db.saveConfigTransactionLog( logctx, responsePrefix);
+ QueryStatus status = db.saveConfigTransactionLog(logctx, responsePrefix);
logctx.setAttribute("log-message", null);
@@ -637,21 +627,21 @@ public class ConfigResourceNode implements SvcLogicJavaPlugin {
DGGeneralDBService db = DGGeneralDBService.initialise();
- if ( !StringUtils.isBlank(ctx.getAttribute("vnfc-type"))) {
+ if (!StringUtils.isBlank(ctx.getAttribute("vnfc-type"))) {
status = db.getVnfcReferenceByVnfcTypeNAction(ctx, responsePrefix);
- if ( status == QueryStatus.FAILURE)
+ if (status == QueryStatus.FAILURE)
throw new Exception("Unable to Read vnfc-reference");
}
- //else if (status == QueryStatus.NOT_FOUND ) {
+ // else if (status == QueryStatus.NOT_FOUND ) {
status = db.getVnfcReferenceByVnfTypeNAction(ctx, responsePrefix);
if (status == QueryStatus.NOT_FOUND || status == QueryStatus.FAILURE)
throw new Exception("Unable to Read vnfc reference");
- //}
+ // }
- responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix+".") : "";
+ responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix + ".") : "";
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
log.info("getVnfcReference Successful ");
@@ -668,19 +658,18 @@ public class ConfigResourceNode implements SvcLogicJavaPlugin {
public void getCapability(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
log.info("Received getCapability call with params : " + inParams);
String responsePrefix = inParams.get(AppcDataServiceConstant.INPUT_PARAM_RESPONSE_PREFIX);
- responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix+".") : "";
+ responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix + ".") : "";
String caplevel = inParams.get("caplevel");
String findCapability = inParams.get("checkCapability");
- String vServerId=inParams.get("vServerId");
- if (!checkIfCapabilityCheckNeeded(caplevel, findCapability))
- {
+ String vServerId = inParams.get("vServerId");
+ if (!checkIfCapabilityCheckNeeded(caplevel, findCapability)) {
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
log.info("getCapability Successful - No need for capability check for this action");
return;
}
- try {
- DGGeneralDBService db = DGGeneralDBService.initialise();
+ try {
+ DGGeneralDBService db = DGGeneralDBService.initialise();
String cap = db.getCapability(ctx, inParams.get("vnf-type"));
log.info("getCapability::returned from DB::+cap");
if (StringUtils.isBlank(cap)) {
@@ -694,38 +683,32 @@ public class ConfigResourceNode implements SvcLogicJavaPlugin {
log.info("From DB = " + caps);
JsonNode capabilities = caps.get("capabilities");
log.info("capabilities = " + capabilities);
- if(caplevel !=null && !caplevel.isEmpty()){
+ if (caplevel != null && !caplevel.isEmpty()) {
JsonNode subCapabilities = capabilities.get(caplevel);
- log.info("subCapabilities = " + caplevel + " : " + subCapabilities);
+ log.info("subCapabilities = " + caplevel + " : " + subCapabilities);
if (caplevel.equalsIgnoreCase(AppcDataServiceConstant.CAPABILITY_VM_LEVEL)
- && (null == subCapabilities || subCapabilities.isNull() || subCapabilities.size()==0)) {
+ && (null == subCapabilities || subCapabilities.isNull() || subCapabilities.size() == 0)) {
ctx.setAttribute("capabilities", "None");
ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
log.info("getCapability Successful ");
return;
}
- if(findCapability !=null && !findCapability.isEmpty()){
- if(subCapabilities != null && subCapabilities.toString().contains(findCapability)){
+ if (findCapability != null && !findCapability.isEmpty()) {
+ if (subCapabilities != null && subCapabilities.toString().contains(findCapability)) {
if (caplevel.equalsIgnoreCase(AppcDataServiceConstant.CAPABILITY_VM_LEVEL))
processCapabilitiesForVMLevel(vServerId, ctx, findCapability, subCapabilities);
else
- ctx.setAttribute("capabilities" , "Supported");
- }
- else {
- ctx.setAttribute("capabilities" , "Not-Supported");
+ ctx.setAttribute("capabilities", "Supported");
+ } else {
+ ctx.setAttribute("capabilities", "Not-Supported");
}
+ } else {
+ ctx.setAttribute(responsePrefix + "capabilities." + caplevel, subCapabilities.toString());
}
- 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);
log.info("getCapability Successful ");
@@ -743,7 +726,7 @@ public class ConfigResourceNode implements SvcLogicJavaPlugin {
JsonNode subCapabilities) throws Exception {
log.info("processCapabilitiesForVMLevel():::subCapabilities::" + subCapabilities.toString() + ",vServerId::"
+ vServerId);
- if (subCapabilities.size()==0) {
+ if (subCapabilities.size() == 0) {
ctx.setAttribute("capabilities", "None");
log.info("processCapabilitiesForVMLevel :: No VM block found!!");
return;
@@ -757,19 +740,19 @@ public class ConfigResourceNode implements SvcLogicJavaPlugin {
break;
}
}
-
+
if (null == vmCaps || vmCaps.isNull() || vmCaps.size() == 0) {
ctx.setAttribute("capabilities", "Not-Supported");
log.info("processCapabilitiesForVMLevel :: Found non-empty VM block but Not desired capability!!");
return;
}
-
+
String vnfcFunctionCode = getVnfcFunctionCodeForVserver(ctx, vServerId);
- if (vmCaps != null && vmCaps.toString().contains(vnfcFunctionCode))
+ if (vmCaps.toString().contains(vnfcFunctionCode))
ctx.setAttribute("capabilities", "Supported");
else
ctx.setAttribute("capabilities", "Not-Supported");
- log.info("End processCapabilitiesForVMLevel():capabilities is ::"+ctx.getAttribute("capabilities"));
+ log.info("End processCapabilitiesForVMLevel():capabilities is ::" + ctx.getAttribute("capabilities"));
}
private String getVnfcFunctionCodeForVserver(SvcLogicContext ctx, String vServerId) throws Exception {
@@ -793,46 +776,4 @@ public class ConfigResourceNode implements SvcLogicJavaPlugin {
}
return capabilityCheckNeeded;
}
-
-
-
- /*public void getUploadConfigInfo(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
-
- log.info("Received getUploadConfigInfo call with params : " + inParams);
-
- String responsePrefix = inParams.get(AppcDataServiceConstant.INPUT_PARAM_RESPONSE_PREFIX);
-
- String uploadConfigId = inParams.get(AppcDataServiceConstant.INPUT_PARAM_UPLOAD_CONFIG_ID);
- QueryStatus status = null;
-
- int id = 0;
- try {
-
-
- DGGeneralDBService db = DGGeneralDBService.initialise();
-
- if ( uploadConfigId != null )
- id = Integer.parseInt(uploadConfigId);
-
- status = db.getUploadConfigInfo(ctx, responsePrefix,id);
-
- if ( status == QueryStatus.FAILURE || status == QueryStatus.NOT_FOUND)
- throw new Exception("Unable to Read upload-config");
-
-
- responsePrefix = StringUtils.isNotBlank(responsePrefix) ? (responsePrefix+".") : "";
- ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
- AppcDataServiceConstant.OUTPUT_STATUS_SUCCESS);
- log.info("getUploadConfigInfo Successful ");
- } catch (Exception e) {
- ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_STATUS,
- AppcDataServiceConstant.OUTPUT_STATUS_FAILURE);
- ctx.setAttribute(responsePrefix + AppcDataServiceConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
- log.error("Failed in getUploadConfigInfo " + e.getMessage());
-
- throw new SvcLogicException(e.getMessage());
- }
- }
- */
-
}