InstarClientNode sonar fixes 67/32567/2
authorJakub Dudycz <jakub.dudycz@nokia.com>
Thu, 22 Feb 2018 15:05:19 +0000 (16:05 +0100)
committerPatrick Brady <pb071s@att.com>
Thu, 22 Feb 2018 17:34:03 +0000 (17:34 +0000)
Change-Id: I3c61219c989fc2fdb17719babd06487da0f7032b
Issue-ID: APPC-663
Signed-off-by: Jakub Dudycz <jakub.dudycz@nokia.com>
appc-outbound/appc-network-inventory-client/provider/src/main/java/org/onap/appc/instar/node/InstarClientNode.java

index f9aa42d..87bcb6c 100644 (file)
@@ -28,7 +28,6 @@ import com.att.eelf.configuration.EELFLogger;
 import com.att.eelf.configuration.EELFManager;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.fasterxml.jackson.dataformat.yaml.YAMLFactory;
-
 import java.util.HashMap;
 import java.util.Map;
 import org.apache.commons.lang3.StringUtils;
@@ -39,101 +38,97 @@ import org.onap.appc.instar.interfaceImpl.InterfaceIpAddressImpl;
 import org.onap.appc.instar.interfaces.RestClientInterface;
 import org.onap.appc.instar.interfaces.RuleHandlerInterface;
 import org.onap.appc.instar.utils.InstarClientConstant;
-import org.onap.sdnc.config.params.data.Parameter;
 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.sdnc.config.params.data.Parameter;
+
+public class InstarClientNode implements SvcLogicJavaPlugin {
 
-public class InstarClientNode implements SvcLogicJavaPlugin
-{
     private static final EELFLogger log = EELFManager.getInstance().getLogger(InstarClientNode.class);
 
     public void getInstarInfo(Map<String, String> inParams, SvcLogicContext ctx)
-    throws SvcLogicException{
+        throws SvcLogicException {
         log.info("Received getInstarInfo call with params : " + inParams);
-        String responsePrefix = (String)inParams.get(InstarClientConstant.INPUT_PARAM_RESPONSE_PRIFIX);
-        try
-        {
+        String responsePrefix = inParams.get(InstarClientConstant.INPUT_PARAM_RESPONSE_PRIFIX);
+        try {
             responsePrefix = StringUtils.isNotBlank(responsePrefix) ? responsePrefix + "." : "";
-            String [] instarKeys = getKeys(inParams.get(InstarClientConstant.INSTAR_KEYS));
-            for (String instarKey : instarKeys){
+            String[] instarKeys = getKeys(inParams.get(InstarClientConstant.INSTAR_KEYS));
+            for (String instarKey : instarKeys) {
                 log.info("Processing Key : " + instarKey);
                 log.info("Searching key for  : " + "INSTAR." + instarKey);
                 ObjectMapper mapper = new ObjectMapper(new YAMLFactory());
-                RuleHandlerInterface handler = null;
+                RuleHandlerInterface handler;
                 log.info("Received Context : " + ctx.getAttribute("INSTAR." + instarKey));
-                Parameter params = mapper.readValue(ctx.getAttribute(InstarClientConstant.SOURCE_SYSTEM_INSTAR + "." +  instarKey), Parameter.class);
+                Parameter params = mapper
+                    .readValue(ctx.getAttribute(InstarClientConstant.SOURCE_SYSTEM_INSTAR + "." + instarKey),
+                        Parameter.class);
 
-                log.info("Processing rule Type : "  + params.getRuleType());
-                switch(params.getRuleType()){
-                    case InstarClientConstant.INTERFACE_IP_ADDRESS:
-                        handler = new InterfaceIpAddressImpl(params, ctx);
-                        break;
-                    default:
-                        throw new Exception("No Rule Defined to process :" + params.getRuleType());
+                log.info("Processing rule Type : " + params.getRuleType());
+                if (params.getRuleType().equals(InstarClientConstant.INTERFACE_IP_ADDRESS)) {
+                    handler = new InterfaceIpAddressImpl(params, ctx);
+                } else {
+                    throw new SvcLogicException("No Rule Defined to process :" + params.getRuleType());
                 }
                 handler.processRule();
-
             }
             log.info("responsePrefix =" + responsePrefix);
-            ctx.setAttribute(responsePrefix + InstarClientConstant.INSTAR_KEY_VALUES, ctx.getAttribute(InstarClientConstant.INSTAR_KEY_VALUES));
-            ctx.setAttribute(responsePrefix + InstarClientConstant.OUTPUT_PARAM_STATUS, InstarClientConstant.OUTPUT_STATUS_SUCCESS);
+            ctx.setAttribute(responsePrefix + InstarClientConstant.INSTAR_KEY_VALUES,
+                ctx.getAttribute(InstarClientConstant.INSTAR_KEY_VALUES));
+            ctx.setAttribute(responsePrefix + InstarClientConstant.OUTPUT_PARAM_STATUS,
+                InstarClientConstant.OUTPUT_STATUS_SUCCESS);
             ctx.setAttribute(InstarClientConstant.INSTAR_KEY_VALUES, null);
-        }
-        catch (Exception e)
-        {
-            ctx.setAttribute(responsePrefix + InstarClientConstant.OUTPUT_PARAM_STATUS, InstarClientConstant.OUTPUT_STATUS_FAILURE);
+        } catch (Exception e) {
+            ctx.setAttribute(responsePrefix + InstarClientConstant.OUTPUT_PARAM_STATUS,
+                InstarClientConstant.OUTPUT_STATUS_FAILURE);
             ctx.setAttribute(responsePrefix + InstarClientConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
-            log.error("Failed processing Instar request" + e.getMessage());
-            e.printStackTrace();
+            log.error("Failed processing Instar request", e);
             throw new SvcLogicException(e.getMessage());
         }
     }
-     private static String[] getKeys(String keyString) {
-        String fn = "InstarClientNode.getKeys";
-        System.out.println("Received Key String as :" + keyString);
 
-         keyString = keyString.replace("[","");
-         keyString = keyString.replace("]", "");
-        keyString = keyString.replace("\"", "");
-         if(keyString.contains(","))
-         {
-                 String[] keys  = keyString.split(",");
-                 return keys;
-         }
-         else{
-                 String[] keys = {keyString};
-                 return keys;
-         }
+    private static String[] getKeys(String keyString) {
+        log.error("Received Key String as :" + keyString);
+
+        String key = keyString
+            .replace("[", "")
+            .replace("]", "")
+            .replace("\"", "");
+
+        if (key.contains(",")) {
+            return key.split(",");
+        } else {
+            return new String[]{key};
+        }
     }
+
     public void getInstarData(Map<String, String> inParams, SvcLogicContext ctx)
-            throws SvcLogicException{
-                log.info("Received getInstarData call with params : " + inParams);
-                String responsePrefix = (String)inParams.get(InstarClientConstant.INPUT_PARAM_RESPONSE_PRIFIX);
-                try
-                {
-                    HashMap<String, String> input  = new HashMap<String, String>();
-                    input.putAll(inParams);
-                    RestClientInterface rcINterface = new InstarRestClientImpl(input);
-                    String response = rcINterface.sendRequest(inParams.get("operationName"));
+        throws SvcLogicException {
+        log.info("Received getInstarData call with params : " + inParams);
+        String responsePrefix = inParams.get(InstarClientConstant.INPUT_PARAM_RESPONSE_PRIFIX);
+        try {
+            HashMap<String, String> input = new HashMap<>();
+            input.putAll(inParams);
+            RestClientInterface rcINterface = new InstarRestClientImpl(input);
+            String response = rcINterface.sendRequest(inParams.get("operationName"));
 
-                    responsePrefix = StringUtils.isNotBlank(responsePrefix) ? responsePrefix + "." : "";
-                    ctx.setAttribute(responsePrefix + InstarClientConstant.OUTPUT_PARAM_STATUS, InstarClientConstant.OUTPUT_STATUS_SUCCESS);
-                    ctx.setAttribute(responsePrefix + InstarClientConstant.INSTAR_KEY_VALUES, response);
+            responsePrefix = StringUtils.isNotBlank(responsePrefix) ? responsePrefix + "." : "";
+            ctx.setAttribute(responsePrefix + InstarClientConstant.OUTPUT_PARAM_STATUS,
+                InstarClientConstant.OUTPUT_STATUS_SUCCESS);
+            ctx.setAttribute(responsePrefix + InstarClientConstant.INSTAR_KEY_VALUES, response);
 
-                }
-                catch (Exception e)
-                {
-                    ctx.setAttribute(responsePrefix + InstarClientConstant.OUTPUT_PARAM_STATUS, InstarClientConstant.OUTPUT_STATUS_FAILURE);
-                    ctx.setAttribute(responsePrefix + InstarClientConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
-                    log.error("Failed processing Instar request" + e.getMessage());
-                    e.printStackTrace();
-                    throw new SvcLogicException(e.getMessage());
-                }
-            }
-public void getAaiInfo(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
+        } catch (Exception e) {
+            ctx.setAttribute(responsePrefix + InstarClientConstant.OUTPUT_PARAM_STATUS,
+                InstarClientConstant.OUTPUT_STATUS_FAILURE);
+            ctx.setAttribute(responsePrefix + InstarClientConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
+            log.error("Failed processing Instar request", e);
+            throw new SvcLogicException(e.getMessage());
+        }
+    }
+
+    public void getAaiInfo(Map<String, String> inParams, SvcLogicContext ctx) throws SvcLogicException {
         log.info("Received getAaiInfo call with params : " + inParams);
-        String responsePrefix = (String) inParams.get(AaiClientConstant.INPUT_PARAM_RESPONSE_PRIFIX);
+        String responsePrefix = inParams.get(AaiClientConstant.INPUT_PARAM_RESPONSE_PRIFIX);
         try {
             responsePrefix = StringUtils.isNotBlank(responsePrefix) ? responsePrefix + "." : "";
             String[] aaiKeys = getKeys(inParams.get(AaiClientConstant.AAI_KEYS));
@@ -141,28 +136,25 @@ public void getAaiInfo(Map<String, String> inParams, SvcLogicContext ctx) throws
                 log.info("Processing Key : " + aaiKey);
                 log.info("Searching key for  : " + "AAI." + aaiKey);
                 ObjectMapper mapper = new ObjectMapper(new YAMLFactory());
-                RuleHandlerInterface handler = null;
+                RuleHandlerInterface handler;
                 log.info("Received Context : " + ctx.getAttribute("AAI." + aaiKey));
                 Parameter params = mapper.readValue(
-                        ctx.getAttribute(AaiClientConstant.SOURCE_SYSTEM_AAI + "." + aaiKey), Parameter.class);
+                    ctx.getAttribute(AaiClientConstant.SOURCE_SYSTEM_AAI + "." + aaiKey), Parameter.class);
                 log.info("Processing rule Type : " + params.getRuleType());
                 handler = new AaiInterfaceRulesHandler(params, ctx);
                 handler.processRule();
-
             }
-
             log.info("responsePrefix =" + responsePrefix);
             ctx.setAttribute(responsePrefix + AaiClientConstant.AAI_KEY_VALUES,
-                    ctx.getAttribute(AaiClientConstant.AAI_KEY_VALUES));
+                ctx.getAttribute(AaiClientConstant.AAI_KEY_VALUES));
             ctx.setAttribute(responsePrefix + AaiClientConstant.OUTPUT_PARAM_STATUS,
-                    AaiClientConstant.OUTPUT_STATUS_SUCCESS);
+                AaiClientConstant.OUTPUT_STATUS_SUCCESS);
             ctx.setAttribute(AaiClientConstant.AAI_KEY_VALUES, null);
         } catch (Exception e) {
             ctx.setAttribute(responsePrefix + AaiClientConstant.OUTPUT_PARAM_STATUS,
-                    InstarClientConstant.OUTPUT_STATUS_FAILURE);
+                InstarClientConstant.OUTPUT_STATUS_FAILURE);
             ctx.setAttribute(responsePrefix + AaiClientConstant.OUTPUT_PARAM_ERROR_MESSAGE, e.getMessage());
-            log.error("Failed processing AAI data" + e.getMessage());
-            e.printStackTrace();
+            log.error("Failed processing AAI data", e);
             throw new SvcLogicException(e.getMessage());
         }
     }