aboutsummaryrefslogtreecommitdiffstats
path: root/appc-inbound/appc-design-services
diff options
context:
space:
mode:
Diffstat (limited to 'appc-inbound/appc-design-services')
-rw-r--r--appc-inbound/appc-design-services/provider/src/main/java/org/onap/appc/design/dbervices/RequestValidationException.java8
-rw-r--r--appc-inbound/appc-design-services/provider/src/main/java/org/onap/appc/design/dbervices/RequestValidator.java214
2 files changed, 142 insertions, 80 deletions
diff --git a/appc-inbound/appc-design-services/provider/src/main/java/org/onap/appc/design/dbervices/RequestValidationException.java b/appc-inbound/appc-design-services/provider/src/main/java/org/onap/appc/design/dbervices/RequestValidationException.java
new file mode 100644
index 000000000..f957ee930
--- /dev/null
+++ b/appc-inbound/appc-design-services/provider/src/main/java/org/onap/appc/design/dbervices/RequestValidationException.java
@@ -0,0 +1,8 @@
+package org.onap.appc.design.dbervices;
+
+public class RequestValidationException extends Exception{
+
+ public RequestValidationException(String message) {
+ super(message);
+ }
+}
diff --git a/appc-inbound/appc-design-services/provider/src/main/java/org/onap/appc/design/dbervices/RequestValidator.java b/appc-inbound/appc-design-services/provider/src/main/java/org/onap/appc/design/dbervices/RequestValidator.java
index 1ef3f26cc..64a776f61 100644
--- a/appc-inbound/appc-design-services/provider/src/main/java/org/onap/appc/design/dbervices/RequestValidator.java
+++ b/appc-inbound/appc-design-services/provider/src/main/java/org/onap/appc/design/dbervices/RequestValidator.java
@@ -24,100 +24,154 @@
package org.onap.appc.design.dbervices;
-import org.onap.appc.design.services.util.DesignServiceConstants;
+import static org.onap.appc.design.services.util.DesignServiceConstants.ACTION;
+import static org.onap.appc.design.services.util.DesignServiceConstants.ACTION_LEVEL;
+import static org.onap.appc.design.services.util.DesignServiceConstants.ARTIFACT_CONTENTS;
+import static org.onap.appc.design.services.util.DesignServiceConstants.ARTIFACT_NAME;
+import static org.onap.appc.design.services.util.DesignServiceConstants.ARTIFACT_TYPE;
+import static org.onap.appc.design.services.util.DesignServiceConstants.ARTIFACT_VERSOIN;
+import static org.onap.appc.design.services.util.DesignServiceConstants.GETARTIFACT;
+import static org.onap.appc.design.services.util.DesignServiceConstants.GETDESIGNS;
+import static org.onap.appc.design.services.util.DesignServiceConstants.GETSTATUS;
+import static org.onap.appc.design.services.util.DesignServiceConstants.PROTOCOL;
+import static org.onap.appc.design.services.util.DesignServiceConstants.SETINCART;
+import static org.onap.appc.design.services.util.DesignServiceConstants.SETPROTOCOLREFERENCE;
+import static org.onap.appc.design.services.util.DesignServiceConstants.SETSTATUS;
+import static org.onap.appc.design.services.util.DesignServiceConstants.STATUS;
+import static org.onap.appc.design.services.util.DesignServiceConstants.UPLOADARTIFACT;
+import static org.onap.appc.design.services.util.DesignServiceConstants.USER_ID;
+import static org.onap.appc.design.services.util.DesignServiceConstants.VNF_TYPE;
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 java.io.IOException;
public class RequestValidator {
-
+
private static final EELFLogger log = EELFManager.getInstance().getLogger(RequestValidator.class);
- public static void validate(String action, String payload) throws Exception {
- log.info("payload" + payload);
+
+ private RequestValidator() {
+ }
+
+ public static void validate(String action, String payload) throws RequestValidationException, IOException {
+ log.info("payload" + payload);
ObjectMapper objectMapper = new ObjectMapper();
JsonNode payloadObject = objectMapper.readTree(payload);
- log.info("payloadObject" + payloadObject.get(DesignServiceConstants.ARTIFACT_CONTENTS));
-
- String errorString = null;
+ log.info("payloadObject" + payloadObject.get(ARTIFACT_CONTENTS));
+
+ String errorString;
switch (action) {
- case DesignServiceConstants.GETDESIGNS:
- if(payloadObject.get(DesignServiceConstants.USER_ID) == null || payloadObject.get(DesignServiceConstants.USER_ID).textValue().isEmpty())
- errorString = DesignServiceConstants.USER_ID;
- break;
- case DesignServiceConstants.GETARTIFACT:
- if(payloadObject.get(DesignServiceConstants.VNF_TYPE) == null || payloadObject.get(DesignServiceConstants.VNF_TYPE).textValue().isEmpty())
- errorString = DesignServiceConstants.VNF_TYPE;
- else if(payloadObject.get(DesignServiceConstants.ARTIFACT_TYPE) == null || payloadObject.get(DesignServiceConstants.ARTIFACT_TYPE).textValue().isEmpty())
- errorString = DesignServiceConstants.ARTIFACT_TYPE;
- else if(payloadObject.get(DesignServiceConstants.ARTIFACT_NAME) == null || payloadObject.get(DesignServiceConstants.ARTIFACT_NAME).textValue().isEmpty())
- errorString = DesignServiceConstants.ARTIFACT_NAME;
- break;
- case DesignServiceConstants.GETSTATUS:
- if(payloadObject.get(DesignServiceConstants.USER_ID) == null || payloadObject.get(DesignServiceConstants.USER_ID).textValue().isEmpty())
- errorString = DesignServiceConstants.USER_ID;
- else if(payloadObject.get(DesignServiceConstants.VNF_TYPE) == null || payloadObject.get(DesignServiceConstants.VNF_TYPE).textValue().isEmpty())
- errorString = DesignServiceConstants.VNF_TYPE;
- break;
- case DesignServiceConstants.SETSTATUS:
- if(payloadObject.get(DesignServiceConstants.USER_ID) == null || payloadObject.get(DesignServiceConstants.USER_ID).textValue().isEmpty())
- errorString = DesignServiceConstants.USER_ID;
- else if(payloadObject.get(DesignServiceConstants.VNF_TYPE) == null || payloadObject.get(DesignServiceConstants.VNF_TYPE).textValue().isEmpty())
- errorString = DesignServiceConstants.VNF_TYPE;
- else if(payloadObject.get(DesignServiceConstants.ACTION) == null || payloadObject.get(DesignServiceConstants.ACTION).textValue().isEmpty())
- errorString = DesignServiceConstants.ACTION;
- else if(payloadObject.get(DesignServiceConstants.ARTIFACT_TYPE) == null || payloadObject.get(DesignServiceConstants.ARTIFACT_TYPE).textValue().isEmpty())
- errorString = DesignServiceConstants.ARTIFACT_TYPE;
- else if(payloadObject.get(DesignServiceConstants.STATUS) == null || payloadObject.get(DesignServiceConstants.STATUS).textValue().isEmpty())
- errorString = DesignServiceConstants.STATUS;
- break;
- case DesignServiceConstants.UPLOADARTIFACT:
- if(payloadObject.get(DesignServiceConstants.ARTIFACT_NAME) == null || payloadObject.get(DesignServiceConstants.ARTIFACT_NAME).textValue().isEmpty())
- errorString = DesignServiceConstants.ARTIFACT_NAME;
- else if(! payloadObject.get(DesignServiceConstants.ARTIFACT_NAME).textValue().contains("reference")){
- if(payloadObject.get(DesignServiceConstants.ACTION) == null || payloadObject.get(DesignServiceConstants.ACTION).textValue().isEmpty())
- errorString = DesignServiceConstants.ACTION;
- }
- else if(payloadObject.get(DesignServiceConstants.ARTIFACT_VERSOIN) == null || payloadObject.get(DesignServiceConstants.ARTIFACT_VERSOIN).textValue().isEmpty())
- errorString = DesignServiceConstants.ARTIFACT_VERSOIN;
- else if(payloadObject.get(DesignServiceConstants.ARTIFACT_CONTENTS) == null)
- errorString = DesignServiceConstants.ARTIFACT_CONTENTS;
- else if(payloadObject.get(DesignServiceConstants.ARTIFACT_TYPE) == null || payloadObject.get(DesignServiceConstants.ARTIFACT_TYPE).textValue().isEmpty())
- errorString = DesignServiceConstants.ARTIFACT_TYPE;
-
- else if(payloadObject.get(DesignServiceConstants.VNF_TYPE) == null || payloadObject.get(DesignServiceConstants.VNF_TYPE).textValue().isEmpty())
- errorString = DesignServiceConstants.VNF_TYPE;
-
-
- break;
- case DesignServiceConstants.SETPROTOCOLREFERENCE:
- if(payloadObject.get(DesignServiceConstants.ACTION) == null || payloadObject.get(DesignServiceConstants.ACTION).textValue().isEmpty())
- errorString = DesignServiceConstants.ACTION;
- else if(payloadObject.get(DesignServiceConstants.ACTION_LEVEL) == null || payloadObject.get(DesignServiceConstants.ACTION_LEVEL).textValue().isEmpty())
- errorString = DesignServiceConstants.ACTION_LEVEL;
- else if(payloadObject.get(DesignServiceConstants.VNF_TYPE) == null || payloadObject.get(DesignServiceConstants.VNF_TYPE).textValue().isEmpty())
- errorString = DesignServiceConstants.VNF_TYPE;
- else if(payloadObject.get(DesignServiceConstants.PROTOCOL) == null || payloadObject.get(DesignServiceConstants.PROTOCOL).textValue().isEmpty())
- errorString = DesignServiceConstants.PROTOCOL;
-
- case DesignServiceConstants.SETINCART:
- if(payloadObject.get(DesignServiceConstants.ACTION) == null || payloadObject.get(DesignServiceConstants.ACTION).textValue().isEmpty())
- errorString = DesignServiceConstants.ACTION;
- else if(payloadObject.get(DesignServiceConstants.ACTION_LEVEL) == null || payloadObject.get(DesignServiceConstants.ACTION_LEVEL).textValue().isEmpty())
- errorString = DesignServiceConstants.ACTION_LEVEL;
- else if(payloadObject.get(DesignServiceConstants.VNF_TYPE) == null || payloadObject.get(DesignServiceConstants.VNF_TYPE).textValue().isEmpty())
- errorString = DesignServiceConstants.VNF_TYPE;
- else if(payloadObject.get(DesignServiceConstants.PROTOCOL) == null || payloadObject.get(DesignServiceConstants.PROTOCOL).textValue().isEmpty())
- errorString = DesignServiceConstants.PROTOCOL;
- break;
- default:
- throw new Exception(" Action " + action + " not found while processing request ");
+ case GETDESIGNS:
+ errorString = resolveGetDesignsErrorString(payloadObject);
+ break;
+ case GETARTIFACT:
+ errorString = resolveGetArtifactErrorString(payloadObject);
+ break;
+ case GETSTATUS:
+ errorString = resolveGetStatusErrorString(payloadObject);
+ break;
+ case SETSTATUS:
+ errorString = resolveSetStatusErrorString(payloadObject);
+ break;
+ case UPLOADARTIFACT:
+ errorString = resolveUploadArtifactErrorString(payloadObject);
+ break;
+ case SETPROTOCOLREFERENCE:
+ case SETINCART:
+ errorString = resolveErrorString(payloadObject);
+ break;
+ default:
+ throw new RequestValidationException(" Action " + action + " not found while processing request ");
+ }
+ checkForErrorString(errorString);
+ }
+ private static void checkForErrorString(String errorString) throws RequestValidationException {
+ if (errorString != null) {
+ throw new RequestValidationException(" Missing input parameter :-" + errorString + " -:");
}
- if(errorString != null)
- throw new Exception(" Missing input parameter :-" + errorString + " -:");
+ }
+
+ private static String resolveGetDesignsErrorString(JsonNode payloadObject) {
+ return nullOrEmpty(payloadObject, USER_ID) ? USER_ID : null;
+ }
+
+ private static String resolveErrorString(JsonNode payloadObject) {
+ if (nullOrEmpty(payloadObject, ACTION)) {
+ return ACTION;
+ } else if (nullOrEmpty(payloadObject, ACTION_LEVEL)) {
+ return ACTION_LEVEL;
+ } else if (nullOrEmpty(payloadObject, VNF_TYPE)) {
+ return VNF_TYPE;
+ } else if (nullOrEmpty(payloadObject, PROTOCOL)) {
+ return PROTOCOL;
+ }
+ return null;
+ }
+
+ private static String resolveUploadArtifactErrorString(JsonNode payloadObject) {
+ if (nullOrEmpty(payloadObject, ARTIFACT_NAME)) {
+ return ARTIFACT_NAME;
+ } else if (doesNotContainReference(payloadObject)) {
+ return ACTION;
+ } else if (nullOrEmpty(payloadObject, ARTIFACT_VERSOIN)) {
+ return ARTIFACT_VERSOIN;
+ } else if (payloadObject.get(ARTIFACT_CONTENTS) == null) {
+ return ARTIFACT_CONTENTS;
+ } else if (nullOrEmpty(payloadObject, ARTIFACT_TYPE)) {
+ return ARTIFACT_TYPE;
+ } else if (nullOrEmpty(payloadObject, VNF_TYPE)) {
+ return VNF_TYPE;
+ }
+ return null;
+ }
+
+ private static boolean doesNotContainReference(JsonNode payloadObject) {
+ return
+ !payloadObject.get(ARTIFACT_NAME).textValue().contains("reference")
+ && nullOrEmpty(payloadObject, ARTIFACT_NAME);
+ }
+
+ private static String resolveSetStatusErrorString(JsonNode payloadObject) {
+ if (nullOrEmpty(payloadObject, USER_ID)) {
+ return USER_ID;
+ } else if (nullOrEmpty(payloadObject, VNF_TYPE)) {
+ return VNF_TYPE;
+ } else if (nullOrEmpty(payloadObject, ACTION)) {
+ return ACTION;
+ } else if (nullOrEmpty(payloadObject, ARTIFACT_TYPE)) {
+ return ARTIFACT_TYPE;
+ } else if (nullOrEmpty(payloadObject, STATUS)) {
+ return STATUS;
+ }
+ return null;
+ }
+
+ private static String resolveGetStatusErrorString(JsonNode payloadObject) {
+ if (nullOrEmpty(payloadObject, USER_ID)) {
+ return USER_ID;
+ } else if (nullOrEmpty(payloadObject, VNF_TYPE)) {
+ return VNF_TYPE;
+ }
+ return null;
+ }
+
+ private static String resolveGetArtifactErrorString(JsonNode payloadObject) {
+ if (nullOrEmpty(payloadObject, VNF_TYPE)) {
+ return VNF_TYPE;
+ } else if (nullOrEmpty(payloadObject, ARTIFACT_TYPE)) {
+ return ARTIFACT_TYPE;
+ } else if (nullOrEmpty(payloadObject, ARTIFACT_NAME)) {
+ return ARTIFACT_NAME;
+ }
+ return null;
+ }
+ private static boolean nullOrEmpty(JsonNode payloadObject, String param) {
+ return payloadObject.get(param) == null || payloadObject
+ .get(param).textValue().isEmpty();
}
}