Code Review / dmaap / datarouter.git / blobdiff
? search:
summary | shortlog | log | commit | commitdiff | review | tree
raw | inline | side by side
Removing code smells
[dmaap/datarouter.git] / datarouter-prov / src / main / java / org / onap / dmaap / datarouter / provisioning / LogServlet.java
diff --git a/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/LogServlet.java b/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/LogServlet.java
index 762ab4e..e3b9c57 100644 (file)
--- a/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/LogServlet.java
+++ b/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/LogServlet.java
@@ -164,8 +164,8 @@ public class LogServlet extends BaseServlet {
             eventlogger.error(elr.toString());\r
             sendResponseError(resp, HttpServletResponse.SC_METHOD_NOT_ALLOWED, message, eventlogger);\r
         } finally {\r
-        eelfLogger.info(EelfMsgs.EXIT);\r
-    }\r
+            eelfLogger.info(EelfMsgs.EXIT);\r
+        }\r
     }\r
     /**\r
      * GET a logging URL -- retrieve logging data for a feed or subscription.\r
@@ -246,13 +246,13 @@ public class LogServlet extends BaseServlet {
         setIpFqdnRequestIDandInvocationIDForEelf("doPut", req);\r
         eelfLogger.info(EelfMsgs.ENTRY);\r
         try {\r
-        eelfLogger.info(EelfMsgs.MESSAGE_WITH_BEHALF_AND_FEEDID, req.getHeader(BEHALF_HEADER),getIdFromPath(req)+"");\r
-        String message = "PUT not allowed for the logURL.";\r
-        EventLogRecord elr = new EventLogRecord(req);\r
-        elr.setMessage(message);\r
-        elr.setResult(HttpServletResponse.SC_METHOD_NOT_ALLOWED);\r
-        eventlogger.error(elr.toString());\r
-        sendResponseError(resp, HttpServletResponse.SC_METHOD_NOT_ALLOWED, message, eventlogger);\r
+            eelfLogger.info(EelfMsgs.MESSAGE_WITH_BEHALF_AND_FEEDID, req.getHeader(BEHALF_HEADER),getIdFromPath(req)+"");\r
+            String message = "PUT not allowed for the logURL.";\r
+            EventLogRecord elr = new EventLogRecord(req);\r
+            elr.setMessage(message);\r
+            elr.setResult(HttpServletResponse.SC_METHOD_NOT_ALLOWED);\r
+            eventlogger.error(elr.toString());\r
+            sendResponseError(resp, HttpServletResponse.SC_METHOD_NOT_ALLOWED, message, eventlogger);\r
         } finally {\r
             eelfLogger.info(EelfMsgs.EXIT);\r
         }\r
@@ -265,13 +265,13 @@ public class LogServlet extends BaseServlet {
         setIpFqdnRequestIDandInvocationIDForEelf("doPost", req);\r
         eelfLogger.info(EelfMsgs.ENTRY);\r
         try {\r
-        eelfLogger.info(EelfMsgs.MESSAGE_WITH_BEHALF, req.getHeader(BEHALF_HEADER));\r
-        String message = "POST not allowed for the logURL.";\r
-        EventLogRecord elr = new EventLogRecord(req);\r
-        elr.setMessage(message);\r
-        elr.setResult(HttpServletResponse.SC_METHOD_NOT_ALLOWED);\r
-        eventlogger.error(elr.toString());\r
-        sendResponseError(resp, HttpServletResponse.SC_METHOD_NOT_ALLOWED, message, eventlogger);\r
+            eelfLogger.info(EelfMsgs.MESSAGE_WITH_BEHALF, req.getHeader(BEHALF_HEADER));\r
+            String message = "POST not allowed for the logURL.";\r
+            EventLogRecord elr = new EventLogRecord(req);\r
+            elr.setMessage(message);\r
+            elr.setResult(HttpServletResponse.SC_METHOD_NOT_ALLOWED);\r
+            eventlogger.error(elr.toString());\r
+            sendResponseError(resp, HttpServletResponse.SC_METHOD_NOT_ALLOWED, message, eventlogger);\r
         } finally {\r
             eelfLogger.info(EelfMsgs.EXIT);\r
         }\r
@@ -307,25 +307,32 @@ public class LogServlet extends BaseServlet {
 \r
         s = req.getParameter("filename");\r
         if (s != null) {\r
-            map.put(FILENAMESQL, " AND FILENAME = '"+s+"'");\r
+            map.put(FILENAMESQL, " AND FILENAME = '" + s + "'");\r
         }\r
 \r
         s = req.getParameter("statusCode");\r
         if (s != null) {\r
             String sql = null;\r
-            if ("success".equals(s)) {\r
-                sql = " AND STATUS >= 200 AND STATUS < 300";\r
-            } else if ("redirect".equals(s)) {\r
-                sql = " AND STATUS >= 300 AND STATUS < 400";\r
-            } else if ("failure".equals(s)) {\r
-                sql = " AND STATUS >= 400";\r
-            } else {\r
-                try {\r
-                    Integer n = Integer.parseInt(s);\r
-                    if ((n >= 100 && n < 600) || (n == -1))\r
-                        sql = " AND STATUS = " + n;\r
-                } catch (NumberFormatException e) {\r
-                }\r
+            switch (s) {\r
+                case "success":\r
+                    sql = " AND STATUS >= 200 AND STATUS < 300";\r
+                    break;\r
+                case "redirect":\r
+                    sql = " AND STATUS >= 300 AND STATUS < 400";\r
+                    break;\r
+                case "failure":\r
+                    sql = " AND STATUS >= 400";\r
+                    break;\r
+                default:\r
+                    try {\r
+                        int n = Integer.parseInt(s);\r
+                        if ((n >= 100 && n < 600) || (n == -1)) {\r
+                            sql = " AND STATUS = " + n;\r
+                        }\r
+                    } catch (NumberFormatException e) {\r
+                        intlogger.error("Failed to parse input", e);\r
+                    }\r
+                    break;\r
             }\r
             if (sql == null) {\r
                 map.put("err", "bad statusCode");\r
@@ -383,22 +390,22 @@ public class LogServlet extends BaseServlet {
             Date d = sdf.parse(s);\r
             return d.getTime();\r
         } catch (ParseException parseException) {\r
-            intlogger.error("Exception in getting Time :- "+parseException.getMessage(),parseException);\r
+            intlogger.error("Exception in getting Time :- " + parseException.getMessage(),parseException);\r
         }\r
         try {\r
             // Also allow a long (in ms); useful for testing\r
             return Long.parseLong(s);\r
         } catch (NumberFormatException numberFormatException) {\r
-            intlogger.error("Exception in getting Time :- "+numberFormatException.getMessage(),numberFormatException);\r
+            intlogger.error("Exception in getting Time :- " + numberFormatException.getMessage(),numberFormatException);\r
         }\r
-        intlogger.info("Error parsing time="+s);\r
+        intlogger.info("Error parsing time=" + s);\r
         return -1;\r
     }\r
 \r
     private void getPublishRecordsForFeed(int feedid, RowHandler rh, Map<String, String> map) {\r
         String type = map.get("type");\r
         if ("all".equals(type) || "pub".equals(type)) {\r
-            String sql = LOG_RECORDSSQL+feedid\r
+            String sql = LOG_RECORDSSQL + feedid\r
                 + " AND TYPE = 'pub'"\r
                 + map.get(TIMESQL) + map.get(PUBLISHSQL) + map.get(STATUSSQL) + map.get(FILENAMESQL);\r
             getRecordsForSQL(sql, rh);\r
@@ -407,7 +414,7 @@ public class LogServlet extends BaseServlet {
     private void getDeliveryRecordsForFeed(int feedid, RowHandler rh, Map<String, String> map) {\r
         String type = map.get("type");\r
         if ("all".equals(type) || "del".equals(type)) {\r
-            String sql = LOG_RECORDSSQL+feedid\r
+            String sql = LOG_RECORDSSQL + feedid\r
                 + " AND TYPE = 'del'"\r
                 + map.get(TIMESQL) + map.get(PUBLISHSQL) + map.get(RESULTSQL);\r
             getRecordsForSQL(sql, rh);\r
@@ -416,7 +423,7 @@ public class LogServlet extends BaseServlet {
     private void getDeliveryRecordsForSubscription(int subid, RowHandler rh, Map<String, String> map) {\r
         String type = map.get("type");\r
         if ("all".equals(type) || "del".equals(type)) {\r
-            String sql = "select * from LOG_RECORDS where DELIVERY_SUBID = "+subid\r
+            String sql = "select * from LOG_RECORDS where DELIVERY_SUBID = " + subid\r
                 + " AND TYPE = 'del'"\r
                 + map.get(TIMESQL) + map.get(PUBLISHSQL) + map.get(RESULTSQL);\r
             getRecordsForSQL(sql, rh);\r
@@ -427,7 +434,7 @@ public class LogServlet extends BaseServlet {
         if ("all".equals(type) || "exp".equals(type)) {\r
             String st = map.get(STATUSSQL);\r
             if (st == null || st.length() == 0) {\r
-                String sql = LOG_RECORDSSQL+feedid\r
+                String sql = LOG_RECORDSSQL + feedid\r
                     + " AND TYPE = 'exp'"\r
                     + map.get(TIMESQL) + map.get(PUBLISHSQL) + map.get(REASON_SQL);\r
                 getRecordsForSQL(sql, rh);\r
@@ -439,13 +446,14 @@ public class LogServlet extends BaseServlet {
         if ("all".equals(type) || "exp".equals(type)) {\r
             String st = map.get(STATUSSQL);\r
             if (st == null || st.length() == 0) {\r
-                String sql = "select * from LOG_RECORDS where DELIVERY_SUBID = "+subid\r
+                String sql = "select * from LOG_RECORDS where DELIVERY_SUBID = " + subid\r
                     + " AND TYPE = 'exp'"\r
                     + map.get(TIMESQL) + map.get(PUBLISHSQL) + map.get(REASON_SQL);\r
                 getRecordsForSQL(sql, rh);\r
             }\r
         }\r
     }\r
+\r
     private void getRecordsForSQL(String sql, RowHandler rh) {\r
         intlogger.debug(sql);\r
         long start = System.currentTimeMillis();\r
@@ -453,19 +461,19 @@ public class LogServlet extends BaseServlet {
         Connection conn = null;\r
         try {\r
             conn = db.getConnection();\r
-           try( Statement  stmt = conn.createStatement()){\r
-             try(ResultSet rs = stmt.executeQuery(sql)){\r
-                 while (rs.next()) {\r
-                     rh.handleRow(rs);\r
-                 }\r
-             }\r
-           }\r
+            try (Statement  stmt = conn.createStatement()) {\r
+                try (ResultSet rs = stmt.executeQuery(sql)) {\r
+                    while (rs.next()) {\r
+                        rh.handleRow(rs);\r
+                    }\r
+                }\r
+            }\r
         } catch (SQLException sqlException) {\r
-            intlogger.info("Failed to get Records. Exception = " +sqlException.getMessage(),sqlException);\r
+            intlogger.info("Failed to get Records. Exception = " + sqlException.getMessage(),sqlException);\r
         } finally {\r
             if (conn != null)\r
                 db.release(conn);\r
         }\r
-        intlogger.debug("Time: " + (System.currentTimeMillis()-start) + " ms");\r
+        intlogger.debug("Time: " + (System.currentTimeMillis() - start) + " ms");\r
     }\r
 }\r
The Data Routing System project is intended to provide a common framework by which data producers can make data available to data consumers and a way for potential consumers to find feeds with the data they require. The interface to DR is exposed as a RESTful web service known as the DR Publishing and Delivery API