Added rollout testing code

Author: gmsdelmundo

src/main/java/com/uid2/admin/vertx/service/SaltService.java

@@ -140,6 +140,12 @@ public void setupRoutes(Router router) {
             }
         }, new AuditParams(List.of(), Collections.emptyList()), Role.MAINTAINER, Role.SECRET_ROTATION));
 
+        router.post("/api/salt/rollout").blockingHandler(auth.handle(ctx -> {
+            synchronized (writeLock) {
+                this.handleSaltRollout(ctx);
+            }
+        }, new AuditParams(List.of(), Collections.emptyList()), Role.MAINTAINER, Role.SECRET_ROTATION));
+
         router.post("/api/salt/simulateToken").blockingHandler(auth.handle(ctx -> {
             synchronized (writeLock) {
                 this.handleSaltSimulateToken(ctx);
@@ -474,6 +480,35 @@ private void handleSaltOptout(RoutingContext rc) {
         }
     }
 
+    private void handleSaltRollout(RoutingContext rc) {
+        try {
+            final String candidateOperatorUrl = RequestUtil.getString(rc, "candidate_operator_url").orElse("");
+            final String candidateApiKey = RequestUtil.getString(rc, "candidate_api_key").orElse("");
+            final String candidateApiSecret = RequestUtil.getString(rc, "candidate_api_secret").orElse("");
+
+            RotatingSaltProvider.SaltSnapshot snapshot = saltProvider.getSnapshots().getLast();
+
+            List<String> emails = new ArrayList<>();
+            while (emails.size() < 10_000) {
+                String email = randomEmail();
+                SaltEntry salt = getSalt(email, snapshot);
+
+                if (salt.currentSalt() == null) {
+                    emails.add(email);
+                }
+            }
+
+            JsonNode response = v3IdentityMap(emails, candidateOperatorUrl, candidateApiKey, candidateApiSecret);
+
+            rc.response()
+                    .putHeader(HttpHeaders.CONTENT_TYPE, "application/json")
+                    .end();
+        } catch (Exception e) {
+            LOGGER.error(e.getMessage(), e);
+            rc.fail(500, e);
+        }
+    }
+
     private void handleSaltSimulateToken(RoutingContext rc) {
         try {
             final double fraction = RequestUtil.getDouble(rc, "fraction").orElse(0.002740);

webroot/adm/salt.html

@@ -260,6 +260,25 @@ <h1>UID2 Env - Salt Management</h1>
           }
         },
       },
+      {
+        id: 'rollout',
+        title: 'Rollout',
+        role: 'maintainer',
+        inputs: [
+          candidateOperatorUrlInput,
+          candidateApiKeyInput,
+          candidateApiSecretInput
+        ],
+        apiCall: {
+          method: 'POST',
+          getUrl: (inputs) => {
+            const candidateOperatorUrl = encodeURIComponent(inputs.candidateOperatorUrl);
+            const candidateApiKey = encodeURIComponent(inputs.candidateApiKey);
+            const candidateApiSecret = encodeURIComponent(inputs.candidateApiSecret);
+            return `/api/salt/rollout?candidate_operator_url=${candidateOperatorUrl}&candidate_api_key=${candidateApiKey}&candidate_api_secret=${candidateApiSecret}`;
+          }
+        },
+      },
       {
         id: 'simulateToken',
         title: 'Simulate Token',