Update snapshot consuming after migrating to maven central portal (#1801)

Author: caroline-ttd

src/main/java/com/uid2/operator/service/ResponseUtil.java

@@ -61,6 +61,7 @@ public static JsonObject SuccessV2(Object body) {
     public static void SuccessV2(RoutingContext rc, Object body) {
         final JsonObject json = SuccessV2(body);
         rc.data().put("response", json);
+        rc.next();
     }
 
     public static void LogInfoAndSend400Response(RoutingContext rc, String message) {

src/main/java/com/uid2/operator/vertx/UIDOperatorVerticle.java

@@ -1677,8 +1677,22 @@ private void handleIdentityMapV2(RoutingContext rc) {
 
             if (!validateServiceLink(rc)) { return; }
 
-            final JsonObject resp = handleIdentityMapCommon(rc, inputList);
-            ResponseUtil.SuccessV2(rc, resp);
+            vertx.executeBlocking(
+                    promise -> {
+                        try {
+                            final JsonObject resp = handleIdentityMapCommon(rc, inputList);
+                            promise.complete(resp);
+                        } catch (Exception e) {
+                            promise.fail(e);
+                        }},
+                    false,
+                    resp -> {
+                        if (resp.succeeded()) {
+                            ResponseUtil.SuccessV2(rc, resp.result());
+                        } else {
+                            ResponseUtil.LogErrorAndSendResponse(ResponseStatus.UnknownError, 500, rc, "Unknown error while mapping identity v2", (Exception) resp.cause());
+                        }
+                });
         } catch (Exception e) {
             ResponseUtil.LogErrorAndSendResponse(ResponseStatus.UnknownError, 500, rc, "Unknown error while mapping identity v2", e);
         }

src/test/java/com/uid2/operator/UIDOperatorVerticleTest.java

@@ -33,10 +33,7 @@
 import com.uid2.shared.store.salt.ISaltProvider;
 import io.micrometer.core.instrument.Metrics;
 import io.micrometer.core.instrument.simple.SimpleMeterRegistry;
-import io.vertx.core.AsyncResult;
-import io.vertx.core.Future;
-import io.vertx.core.Handler;
-import io.vertx.core.Vertx;
+import io.vertx.core.*;
 import io.vertx.core.buffer.Buffer;
 import io.vertx.core.json.JsonArray;
 import io.vertx.core.json.JsonObject;
@@ -2346,8 +2343,12 @@ void identityMapBatchBothEmailAndHashEmpty(String apiVersion, Vertx vertx, Vertx
         req.put("email_hash", emailHashes);
 
         send(apiVersion, vertx, apiVersion + "/identity/map", false, null, req, 200, respJson -> {
-            checkIdentityMapResponse(respJson);
-            testContext.completeNow();
+            try {
+                checkIdentityMapResponse(respJson);
+                testContext.completeNow();
+            } catch (Throwable ex) {
+                testContext.failNow(ex);
+            }
         });
     }