Added more logging

Author: pokki-deploy

src/main/java/in/erail/route/OpenAPI3RouteBuilder.java

@@ -4,6 +4,8 @@
 import com.codahale.metrics.Metered;
 import com.codahale.metrics.MetricRegistry;
 import com.codahale.metrics.Timer;
+import com.google.common.base.Joiner;
+import com.google.common.base.MoreObjects;
 import com.google.common.base.Strings;
 import com.google.common.net.HttpHeaders;
 import com.google.common.net.MediaType;
@@ -29,9 +31,11 @@
 import io.netty.handler.codec.http.HttpResponseStatus;
 import io.reactivex.Observable;
 import io.vertx.reactivex.core.buffer.Buffer;
+import io.vertx.reactivex.core.http.HttpServerRequest;
 import io.vertx.reactivex.ext.web.Cookie;
 import java.util.Arrays;
 import java.util.HashMap;
+import java.util.Objects;
 import java.util.Optional;
 import java.util.UUID;
 import org.apache.commons.lang3.exception.ExceptionUtils;
@@ -251,6 +255,8 @@ public Router getRouter(Router pRouter) {
                           if (isSecurityEnable() && service.isSecure()) {
 
                             if (routingContext.user() == null) {
+                              getLog().error(() -> "Security on this operation is enabled. But, no user found. Please check, if you are passing correct auth credentials:" + service.getOperationId());
+                              getLog().trace(() -> dumpRequest(routingContext.request()));
                               routingContext.fail(401);
                               return;
                             }
@@ -265,12 +271,13 @@ public Router getRouter(Router pRouter) {
                                       .firstElement()
                                       .subscribe((success) -> {
                                         getLog().trace(() -> "Request is authorized. Processing Message:" + service.getOperationId());
+                                        getLog().trace(() -> dumpRequest(routingContext.request()));
                                         process(routingContext, service.getServiceUniqueId());
                                       }, (err) -> {
                                         getLog().error(() -> "Error processing serive message", err);
                                         routingContext.fail(err);
                                       }, () -> {
-                                        getLog().warn(() -> "You are not authorized to access service:" + service.getOperationId() + ":" + routingContext.toString());
+                                        getLog().warn(() -> "You are not authorized to access service:" + service.getOperationId());
                                         routingContext.fail(401);
                                       });
                             } else {
@@ -280,6 +287,7 @@ public Router getRouter(Router pRouter) {
 
                           } else {
                             getLog().warn("Security disabled for " + service.getServiceUniqueId());
+                            getLog().trace(() -> dumpRequest(routingContext.request()));
                             process(routingContext, service.getServiceUniqueId());
                           }
                         });
@@ -291,6 +299,7 @@ public Router getRouter(Router pRouter) {
                           }
 
                           getLog().debug(() -> "API Failure Handle called:" + service.getOperationId() + ":" + generateErrorResponse(routingContext));
+                          getLog().trace(() -> dumpRequest(routingContext.request()));
 
                           routingContext
                                   .response()
@@ -304,6 +313,7 @@ public Router getRouter(Router pRouter) {
                           }
 
                           getLog().debug(() -> "API Validation Failer Handle called:" + service.getOperationId() + ":" + generateErrorResponse(routingContext));
+                          getLog().trace(() -> dumpRequest(routingContext.request()));
 
                           routingContext
                                   .response()
@@ -313,6 +323,7 @@ public Router getRouter(Router pRouter) {
                         apiFactory.setNotImplementedFailureHandler((routingContext) -> {
 
                           getLog().debug(() -> "API not implemented:" + service.getOperationId() + ":" + generateErrorResponse(routingContext));
+                          getLog().trace(() -> dumpRequest(routingContext.request()));
 
                           routingContext
                                   .response()
@@ -325,6 +336,15 @@ public Router getRouter(Router pRouter) {
     return apiFactory.getRouter();
   }
 
+  protected String dumpRequest(HttpServerRequest pRequest) {
+    return MoreObjects
+            .toStringHelper(pRequest)
+            .add("RequestPath", pRequest.absoluteURI())
+            .add("Headers", Joiner.on(",").join(pRequest.headers().entries().stream().map((e) -> e.getKey() + ":" + e.getValue()).collect(Collectors.toList())))
+            .add("QueryParam", pRequest.query())
+            .toString();
+  }
+
   protected String generateErrorResponse(RoutingContext pContext) {
     return Optional
             .ofNullable(pContext.failure())