Added stopwatch filter

Issue-ID: DMAAP-1109

Change-Id: I1738444ec9ce18768efdc9693c9669990660698f
Signed-off-by: Pawel <pawel.kasperkiewicz@nokia.com>

3 files changed, 59 insertions, 67 deletions

diff --git a/src/main/java/org/onap/dmaap/dbcapi/resources/RequestTimeLogFilter.java b/src/main/java/org/onap/dmaap/dbcapi/resources/RequestTimeLogFilter.java
new file mode 100644
index 0000000..b2b98b6
--- /dev/null
+++ b/src/main/java/org/onap/dmaap/dbcapi/resources/RequestTimeLogFilter.java
@@ -0,0 +1,55 @@
+/*-

+ * ============LICENSE_START=======================================================

+ * org.onap.dmaap

+ * ================================================================================

+ * Copyright (C) 2019 Nokia Intellectual Property. All rights reserved.

+ * ================================================================================

+ * 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.

+ * See the License for the specific language governing permissions and

+ * limitations under the License.

+ * ============LICENSE_END=========================================================

+ */

+package org.onap.dmaap.dbcapi.resources;

+

+import com.att.eelf.configuration.EELFLogger;

+import java.time.Clock;

+import javax.ws.rs.container.ContainerRequestContext;

+import javax.ws.rs.container.ContainerRequestFilter;

+import javax.ws.rs.container.ContainerResponseContext;

+import javax.ws.rs.container.ContainerResponseFilter;

+import org.onap.dmaap.dbcapi.logging.BaseLoggingClass;

+

+public class RequestTimeLogFilter extends BaseLoggingClass implements ContainerRequestFilter, ContainerResponseFilter {

+

+    private final EELFLogger log;

+    private Clock clock;

+

+    public RequestTimeLogFilter() {

+        this(auditLogger, Clock.systemDefaultZone());

+    }

+

+    RequestTimeLogFilter(EELFLogger logger, Clock clock) {

+        this.log = logger;

+        this.clock = clock;

+    }

+

+    @Override

+    public void filter(ContainerRequestContext requestContext) {

+        requestContext.setProperty("start", clock.millis());

+    }

+

+    @Override

+    public void filter(ContainerRequestContext requestContext, ContainerResponseContext containerResponseContext) {

+        long startTime = (long) requestContext.getProperty("start");

+        long elapsedTime = clock.millis() - startTime;

+        log.info("Request took {} ms", elapsedTime);

+    }

+}

diff --git a/src/main/java/org/onap/dmaap/dbcapi/server/ApplicationConfig.java b/src/main/java/org/onap/dmaap/dbcapi/server/ApplicationConfig.java
index 2283ea2..2244b73 100644
--- a/src/main/java/org/onap/dmaap/dbcapi/server/ApplicationConfig.java
+++ b/src/main/java/org/onap/dmaap/dbcapi/server/ApplicationConfig.java
@@ -20,8 +20,8 @@
 package org.onap.dmaap.dbcapi.server;
 
 import org.glassfish.jersey.server.ResourceConfig;
-
-
+import org.onap.dmaap.dbcapi.resources.RequestTimeLogFilter;
+import org.onap.dmaap.dbcapi.resources.AuthorizationFilter;
 
 public class ApplicationConfig extends ResourceConfig {
 	
@@ -30,7 +30,8 @@ public class ApplicationConfig extends ResourceConfig {
 	 */
 	public ApplicationConfig() {
 		
-        register(org.onap.dmaap.dbcapi.resources.AuthorizationFilter.class);
+        register(AuthorizationFilter.class).
+					register(RequestTimeLogFilter.class);
   
     }
 }
diff --git a/src/main/java/org/onap/dmaap/dbcapi/service/StopWatch.java b/src/main/java/org/onap/dmaap/dbcapi/service/StopWatch.java
deleted file mode 100644
index 6dc8fe9..0000000
--- a/src/main/java/org/onap/dmaap/dbcapi/service/StopWatch.java
+++ /dev/null
@@ -1,64 +0,0 @@
-/*-

- * ============LICENSE_START=======================================================

- * org.onap.dmaap

- * ================================================================================

- * Copyright (C) 2019 AT&T Intellectual Property. All rights reserved.

- * ================================================================================

- * 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.

- * See the License for the specific language governing permissions and

- * limitations under the License.

- * ============LICENSE_END=========================================================

- */

-package org.onap.dmaap.dbcapi.service;

-

-import static com.att.eelf.configuration.Configuration.MDC_BEGIN_TIMESTAMP;

-import static com.att.eelf.configuration.Configuration.MDC_ELAPSED_TIME;

-import static com.att.eelf.configuration.Configuration.MDC_END_TIMESTAMP;

-

-import java.text.SimpleDateFormat;

-import java.util.Date;

-import java.util.TimeZone;

-import org.slf4j.MDC;

-

-

-public class StopWatch {

-

-    private static final String ISO_FORMAT = "yyyy-MM-dd'T'HH:mm:ss.SSSZ";

-    private final static SimpleDateFormat isoFormatter = new SimpleDateFormat(ISO_FORMAT);

-    private final static TimeZone utc = TimeZone.getTimeZone("UTC");

-

-    private long startTimestamp;

-    private long elapsedTime;

-

-    static {

-        isoFormatter.setTimeZone(utc);

-    }

-

-    public void start() {

-        startTimestamp = System.currentTimeMillis();

-        MDC.put(MDC_BEGIN_TIMESTAMP, isoFormatter.format(new Date(startTimestamp)));

-    }

-

-    public void stop() {

-        long endTimestamp = System.currentTimeMillis();

-        elapsedTime = endTimestamp - startTimestamp;

-        MDC.put(MDC_END_TIMESTAMP, isoFormatter.format(new Date(endTimestamp)));

-        MDC.put(MDC_ELAPSED_TIME, String.valueOf(elapsedTime));

-    }

-

-    public void resetElapsedTime() {

-        elapsedTime = 0;

-    }

-

-    public long getElapsedTime() {

-        return elapsedTime;

-    }

-}