SDNC-13 minor refactoring 05/4505/1
authorKevin Smokowski <ks6305@att.com>
Fri, 26 May 2017 18:09:22 +0000 (18:09 +0000)
committerKevin Smokowski <ks6305@att.com>
Fri, 26 May 2017 18:13:47 +0000 (18:13 +0000)
Change-Id: I12a76262fc28b2354c3c8e87267c537000124ece
Signed-off-by: Kevin Smokowski <ks6305@att.com>
restapi-call-node/provider/src/main/java/org/openecomp/sdnc/restapicall/Format.java [new file with mode: 0644]
restapi-call-node/provider/src/main/java/org/openecomp/sdnc/restapicall/HttpMethod.java [new file with mode: 0644]
restapi-call-node/provider/src/main/java/org/openecomp/sdnc/restapicall/HttpResponse.java [new file with mode: 0644]
restapi-call-node/provider/src/main/java/org/openecomp/sdnc/restapicall/Parameters.java [new file with mode: 0644]
restapi-call-node/provider/src/main/java/org/openecomp/sdnc/restapicall/RestapiCallNode.java

diff --git a/restapi-call-node/provider/src/main/java/org/openecomp/sdnc/restapicall/Format.java b/restapi-call-node/provider/src/main/java/org/openecomp/sdnc/restapicall/Format.java
new file mode 100644 (file)
index 0000000..26cbdb5
--- /dev/null
@@ -0,0 +1,15 @@
+package org.openecomp.sdnc.restapicall;
+
+public enum Format {
+    JSON, XML;
+
+    public static Format fromString(String s) {
+        if (s == null)
+            return null;
+        if (s.equalsIgnoreCase("json"))
+            return JSON;
+        if (s.equalsIgnoreCase("xml"))
+            return XML;
+        throw new IllegalArgumentException("Invalid value for format: " + s);
+    }
+}
diff --git a/restapi-call-node/provider/src/main/java/org/openecomp/sdnc/restapicall/HttpMethod.java b/restapi-call-node/provider/src/main/java/org/openecomp/sdnc/restapicall/HttpMethod.java
new file mode 100644 (file)
index 0000000..cad15d5
--- /dev/null
@@ -0,0 +1,21 @@
+package org.openecomp.sdnc.restapicall;
+
+public enum HttpMethod {
+    GET, POST, PUT, DELETE, PATCH;
+
+    public static HttpMethod fromString(String s) {
+        if (s == null)
+            return null;
+        if (s.equalsIgnoreCase("get"))
+            return GET;
+        if (s.equalsIgnoreCase("post"))
+            return POST;
+        if (s.equalsIgnoreCase("put"))
+            return PUT;
+        if (s.equalsIgnoreCase("delete"))
+            return DELETE;
+        if (s.equalsIgnoreCase("patch"))
+            return PATCH;
+        throw new IllegalArgumentException("Invalid value for HTTP Method: " + s);
+    }
+}
diff --git a/restapi-call-node/provider/src/main/java/org/openecomp/sdnc/restapicall/HttpResponse.java b/restapi-call-node/provider/src/main/java/org/openecomp/sdnc/restapicall/HttpResponse.java
new file mode 100644 (file)
index 0000000..f0815a5
--- /dev/null
@@ -0,0 +1,10 @@
+package org.openecomp.sdnc.restapicall;
+
+import javax.ws.rs.core.MultivaluedMap;
+
+public class HttpResponse {
+    public int code;
+    public String message;
+    public String body;
+    public MultivaluedMap<String, String> headers;
+}
diff --git a/restapi-call-node/provider/src/main/java/org/openecomp/sdnc/restapicall/Parameters.java b/restapi-call-node/provider/src/main/java/org/openecomp/sdnc/restapicall/Parameters.java
new file mode 100644 (file)
index 0000000..8208857
--- /dev/null
@@ -0,0 +1,25 @@
+package org.openecomp.sdnc.restapicall;
+
+import java.util.Set;
+
+public class Parameters {
+    public String templateFileName;
+    public String restapiUrl;
+    public String restapiUser;
+    public String restapiPassword;
+    public Format format;
+    public String contentType;
+    public HttpMethod httpMethod;
+    public String responsePrefix;
+    public Set<String> listNameList;
+    public boolean skipSending;
+    public boolean convertResponse;
+    public String keyStoreFileName;
+    public String keyStorePassword;
+    public String trustStoreFileName;
+    public String trustStorePassword;
+    public boolean ssl;
+    public String customHttpHeaders;
+    public String partner;
+    public Boolean dumpHeaders;
+}
index 210dee8..fb51ab0 100644 (file)
@@ -65,13 +65,13 @@ public class RestapiCallNode implements SvcLogicJavaPlugin {
 
        private String uebServers;
        private String defaultUebTemplateFileName = "/opt/bvc/restapi/templates/default-ueb-message.json";
-       public RetryPolicyStore retryPolicyStore;
+       protected RetryPolicyStore retryPolicyStore;
 
-       public RetryPolicyStore getRetryPolicyStore() {
+       protected RetryPolicyStore getRetryPolicyStore() {
                return retryPolicyStore;
        }
 
-       public void setRetryPolicyStore(RetryPolicyStore retryPolicyStore) {
+       protected void setRetryPolicyStore(RetryPolicyStore retryPolicyStore) {
                this.retryPolicyStore = retryPolicyStore;
        }
 
@@ -116,7 +116,7 @@ public class RestapiCallNode implements SvcLogicJavaPlugin {
                RetryPolicy retryPolicy = null;
                HttpResponse r = null;
                try {
-                       Param p = getParameters(paramMap);
+                       Parameters p = getParameters(paramMap);
                        if (p.partner != null) {
                                retryPolicy = retryPolicyStore.getRetryPolicy(p.partner);
                        }
@@ -200,8 +200,8 @@ public class RestapiCallNode implements SvcLogicJavaPlugin {
                        throw new SvcLogicException(String.valueOf(r.code) + ": " + r.message);
        }
 
-       private Param getParameters(Map<String, String> paramMap) throws SvcLogicException {
-               Param p = new Param();
+       protected Parameters getParameters(Map<String, String> paramMap) throws SvcLogicException {
+               Parameters p = new Parameters();
                p.templateFileName = parseParam(paramMap, "templateFileName", false, null);
                p.restapiUrl = parseParam(paramMap, "restapiUrl", true, null);
                p.restapiUser = parseParam(paramMap, "restapiUser", false, null);
@@ -226,7 +226,7 @@ public class RestapiCallNode implements SvcLogicJavaPlugin {
                return p;
        }
 
-       private Set<String> getListNameList(Map<String, String> paramMap) {
+       protected Set<String> getListNameList(Map<String, String> paramMap) {
                Set<String> ll = new HashSet<String>();
                for (String key : paramMap.keySet())
                        if (key.startsWith("listName"))
@@ -234,7 +234,7 @@ public class RestapiCallNode implements SvcLogicJavaPlugin {
                return ll;
        }
 
-       private String parseParam(Map<String, String> paramMap, String name, boolean required, String def)
+       protected String parseParam(Map<String, String> paramMap, String name, boolean required, String def)
                throws SvcLogicException {
                String s = paramMap.get(name);
 
@@ -270,63 +270,6 @@ public class RestapiCallNode implements SvcLogicJavaPlugin {
                return value;
        }
 
-       private static class Param {
-
-               public String templateFileName;
-               public String restapiUrl;
-               public String restapiUser;
-               public String restapiPassword;
-               public Format format;
-               public String contentType;
-               public HttpMethod httpMethod;
-               public String responsePrefix;
-               public Set<String> listNameList;
-               public boolean skipSending;
-               public boolean convertResponse;
-               public String keyStoreFileName;
-               public String keyStorePassword;
-               public String trustStoreFileName;
-               public String trustStorePassword;
-               public boolean ssl;
-               public String customHttpHeaders;
-               public String partner;
-           public Boolean dumpHeaders;
-       }
-
-       protected static enum Format {
-               JSON, XML;
-
-               public static Format fromString(String s) {
-                       if (s == null)
-                               return null;
-                       if (s.equalsIgnoreCase("json"))
-                               return JSON;
-                       if (s.equalsIgnoreCase("xml"))
-                               return XML;
-                       throw new IllegalArgumentException("Invalid value for format: " + s);
-               }
-       }
-
-       private static enum HttpMethod {
-               GET, POST, PUT, DELETE, PATCH;
-
-               public static HttpMethod fromString(String s) {
-                       if (s == null)
-                               return null;
-                       if (s.equalsIgnoreCase("get"))
-                               return GET;
-                       if (s.equalsIgnoreCase("post"))
-                               return POST;
-                       if (s.equalsIgnoreCase("put"))
-                               return PUT;
-                       if (s.equalsIgnoreCase("delete"))
-                               return DELETE;
-                       if (s.equalsIgnoreCase("patch"))
-                               return PATCH;
-                       throw new IllegalArgumentException("Invalid value for HTTP Method: " + s);
-               }
-       }
-
        protected String buildXmlJsonRequest(SvcLogicContext ctx, String template, Format format) {
                log.info("Building " + format + " started");
                long t1 = System.currentTimeMillis();
@@ -383,7 +326,7 @@ public class RestapiCallNode implements SvcLogicJavaPlugin {
                return req;
        }
 
-       private String expandRepeats(SvcLogicContext ctx, String template, int level) {
+       protected String expandRepeats(SvcLogicContext ctx, String template, int level) {
                StringBuilder newTemplate = new StringBuilder();
                int k = 0;
                while (k < template.length()) {
@@ -454,7 +397,7 @@ public class RestapiCallNode implements SvcLogicJavaPlugin {
                return new String(encoded, "UTF-8");
        }
 
-       private HttpResponse sendHttpRequest(String request, Param p) throws Exception {
+       protected HttpResponse sendHttpRequest(String request, Parameters p) throws Exception {
                ClientConfig config = new DefaultClientConfig();
                SSLContext ssl = null;
                if (p.ssl && p.restapiUrl.startsWith("https"))
@@ -528,7 +471,7 @@ public class RestapiCallNode implements SvcLogicJavaPlugin {
                return r;
        }
 
-       private SSLContext createSSLContext(Param p) {
+       protected SSLContext createSSLContext(Parameters p) {
                try {
                        System.setProperty("jsse.enableSNIExtension", "false");
                        System.setProperty("javax.net.ssl.trustStore", p.trustStoreFileName);
@@ -558,15 +501,7 @@ public class RestapiCallNode implements SvcLogicJavaPlugin {
                return null;
        }
 
-       private static class HttpResponse {
-
-               public int code;
-               public String message;
-               public String body;
-               public MultivaluedMap<String, String> headers;
-       }
-
-       private void setFailureResponseStatus(SvcLogicContext ctx, String prefix, String errorMessage, HttpResponse r) {
+       protected void setFailureResponseStatus(SvcLogicContext ctx, String prefix, String errorMessage, HttpResponse r) {
                r = new HttpResponse();
                r.code = 500;
                r.message = errorMessage;
@@ -575,7 +510,7 @@ public class RestapiCallNode implements SvcLogicJavaPlugin {
                ctx.setAttribute(pp + "response-message", r.message);
        }
 
-       private void setResponseStatus(SvcLogicContext ctx, String prefix, HttpResponse r) {
+       protected void setResponseStatus(SvcLogicContext ctx, String prefix, HttpResponse r) {
                String pp = prefix != null ? prefix + '.' : "";
                ctx.setAttribute(pp + "response-code", String.valueOf(r.code));
                ctx.setAttribute(pp + "response-message", r.message);
@@ -628,7 +563,7 @@ public class RestapiCallNode implements SvcLogicJavaPlugin {
                return p;
        }
 
-       private HttpResponse sendHttpData(byte[] data, FileParam p) {
+       protected HttpResponse sendHttpData(byte[] data, FileParam p) {
                Client client = Client.create();
                client.setConnectTimeout(5000);
                client.setFollowRedirects(true);
@@ -747,7 +682,7 @@ public class RestapiCallNode implements SvcLogicJavaPlugin {
                return p;
        }
 
-       private HttpResponse postOnUeb(String request, UebParam p) throws Exception {
+       protected HttpResponse postOnUeb(String request, UebParam p) throws Exception {
                String[] urls = uebServers.split(" ");
                for (int i = 0; i < urls.length; i++) {
                        if (!urls[i].endsWith("/"))
@@ -788,7 +723,7 @@ public class RestapiCallNode implements SvcLogicJavaPlugin {
                return r;
        }
 
-       private void logProperties(Map<String, Object> mm) {
+       protected void logProperties(Map<String, Object> mm) {
                List<String> ll = new ArrayList<>();
                for (Object o : mm.keySet())
                        ll.add((String) o);
@@ -799,7 +734,7 @@ public class RestapiCallNode implements SvcLogicJavaPlugin {
                        log.info("--- " + name + ": " + String.valueOf(mm.get(name)));
        }
 
-       private void logHeaders(MultivaluedMap<String, String> mm) {
+       protected void logHeaders(MultivaluedMap<String, String> mm) {
                log.info("HTTP response headers:");
 
                if (mm == null)