feat(central): add debug info for remote proxy calls and log them. This is useful for debugging

7 files changed, 16 insertions, 0 deletions

diff --git a/central/src/main/java/moe/yuuta/dn42peering/asn/ASNHttpVerticle.java b/central/src/main/java/moe/yuuta/dn42peering/asn/ASNHttpVerticle.java
index 32f1a24..84ee461 100644
--- a/central/src/main/java/moe/yuuta/dn42peering/asn/ASNHttpVerticle.java
+++ b/central/src/main/java/moe/yuuta/dn42peering/asn/ASNHttpVerticle.java
@@ -18,6 +18,7 @@ public class ASNHttpVerticle extends AbstractVerticle {
     public void start(Promise<Void> startPromise) throws Exception {
         consumer = new ServiceBinder(vertx)
                 .setAddress(IASNHttpService.ADDRESS)
+                .setIncludeDebugInfo(true)
                 .register(IASNHttpService.class, new IASNHttpServiceImpl(vertx));
         consumer.completionHandler(ar -> {
             if (ar.succeeded()) {
diff --git a/central/src/main/java/moe/yuuta/dn42peering/asn/ASNVerticle.java b/central/src/main/java/moe/yuuta/dn42peering/asn/ASNVerticle.java
index 032dc2f..aef9e1c 100644
--- a/central/src/main/java/moe/yuuta/dn42peering/asn/ASNVerticle.java
+++ b/central/src/main/java/moe/yuuta/dn42peering/asn/ASNVerticle.java
@@ -27,6 +27,7 @@ public class ASNVerticle extends AbstractVerticle {
 
         consumer = new ServiceBinder(vertx)
                 .setAddress(IASNService.ADDRESS)
+                .setIncludeDebugInfo(true)
                 .register(IASNService.class, new ASNServiceImpl(vertx, pool));
         consumer.completionHandler(ar -> {
             if(ar.succeeded()) {
diff --git a/central/src/main/java/moe/yuuta/dn42peering/node/NodeVerticle.java b/central/src/main/java/moe/yuuta/dn42peering/node/NodeVerticle.java
index 3607e08..d23d6d5 100644
--- a/central/src/main/java/moe/yuuta/dn42peering/node/NodeVerticle.java
+++ b/central/src/main/java/moe/yuuta/dn42peering/node/NodeVerticle.java
@@ -27,6 +27,7 @@ public class NodeVerticle extends AbstractVerticle {
 
         consumer = new ServiceBinder(vertx)
                 .setAddress(INodeService.ADDRESS)
+                .setIncludeDebugInfo(true)
                 .register(INodeService.class, new NodeServiceImpl(vertx, pool));
         consumer.completionHandler(ar -> {
             if(ar.succeeded()) {
diff --git a/central/src/main/java/moe/yuuta/dn42peering/peer/PeerVerticle.java b/central/src/main/java/moe/yuuta/dn42peering/peer/PeerVerticle.java
index d13dfec..666ced8 100644
--- a/central/src/main/java/moe/yuuta/dn42peering/peer/PeerVerticle.java
+++ b/central/src/main/java/moe/yuuta/dn42peering/peer/PeerVerticle.java
@@ -27,6 +27,7 @@ public class PeerVerticle extends AbstractVerticle {
 
         consumer = new ServiceBinder(vertx)
                 .setAddress(IPeerService.ADDRESS)
+                .setIncludeDebugInfo(true)
                 .register(IPeerService.class, new PeerServiceImpl(vertx, pool));
         consumer.completionHandler(ar -> {
             if(ar.succeeded()) {
diff --git a/central/src/main/java/moe/yuuta/dn42peering/portal/HTTPPortalVerticle.java b/central/src/main/java/moe/yuuta/dn42peering/portal/HTTPPortalVerticle.java
index d7c6d9f..a3e2f30 100644
--- a/central/src/main/java/moe/yuuta/dn42peering/portal/HTTPPortalVerticle.java
+++ b/central/src/main/java/moe/yuuta/dn42peering/portal/HTTPPortalVerticle.java
@@ -9,6 +9,7 @@ import io.vertx.core.json.JsonObject;
 import io.vertx.ext.web.Router;
 import io.vertx.ext.web.common.template.TemplateEngine;
 import io.vertx.ext.web.templ.freemarker.FreeMarkerTemplateEngine;
+import io.vertx.serviceproxy.ServiceException;
 import moe.yuuta.dn42peering.admin.AdminHandler;
 import moe.yuuta.dn42peering.asn.ASNHandler;
 import moe.yuuta.dn42peering.manage.ManageHandler;
@@ -44,6 +45,15 @@ public class HTTPPortalVerticle extends AbstractVerticle {
                 ctx.response().setStatusCode(((HTTPException) ctx.failure()).code).end();
                 return;
             }
+            if(ctx.failure() instanceof ServiceException) {
+                final JsonObject debugInfo = ((ServiceException) ctx.failure()).getDebugInfo();
+                if(debugInfo != null) {
+                    logger.error("Generic Error: " + debugInfo.encodePrettily(), ctx.failure());
+                } else {
+                    logger.error("Generic Error: No debug info available.", ctx.failure());
+                }
+                return;
+            }
             logger.error("Generic Error", ctx.failure());
         });
         vertx.createHttpServer()
diff --git a/central/src/main/java/moe/yuuta/dn42peering/provision/ProvisionVerticle.java b/central/src/main/java/moe/yuuta/dn42peering/provision/ProvisionVerticle.java
index 7d2772f..1a6e6a7 100644
--- a/central/src/main/java/moe/yuuta/dn42peering/provision/ProvisionVerticle.java
+++ b/central/src/main/java/moe/yuuta/dn42peering/provision/ProvisionVerticle.java
@@ -18,6 +18,7 @@ public class ProvisionVerticle extends AbstractVerticle {
     public void start(Promise<Void> startPromise) throws Exception {
         consumer = new ServiceBinder(vertx)
                 .setAddress(IProvisionRemoteService.ADDRESS)
+                .setIncludeDebugInfo(true)
                 .register(IProvisionRemoteService.class, new ProvisionRemoteServiceImpl(vertx));
         consumer.completionHandler(ar -> {
             if(ar.succeeded()) {
diff --git a/central/src/main/java/moe/yuuta/dn42peering/whois/WhoisVerticle.java b/central/src/main/java/moe/yuuta/dn42peering/whois/WhoisVerticle.java
index d4cc83a..9c68e7d 100644
--- a/central/src/main/java/moe/yuuta/dn42peering/whois/WhoisVerticle.java
+++ b/central/src/main/java/moe/yuuta/dn42peering/whois/WhoisVerticle.java
@@ -17,6 +17,7 @@ public class WhoisVerticle extends AbstractVerticle {
     public void start(Promise<Void> startPromise) throws Exception {
         consumer = new ServiceBinder(vertx)
                 .setAddress(IWhoisService.ADDRESS)
+                .setIncludeDebugInfo(true)
                 .register(IWhoisService.class, IWhoisService.create(vertx));
         consumer.completionHandler(ar -> {
             if(ar.succeeded()) {