add uid2_operator_raw_email_dot_total and record in all paths with raw emails

Author: swibi-ttd

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

@@ -910,6 +910,7 @@ private void handleTokenValidateV2(RoutingContext rc) {
                 recordTokenValidateStats(participantSiteId, "invalid_input");
                 return;
             }
+            recordRawEmailDotMetric(input, rc.request().path());
 
             final Instant now = Instant.now();
             final String token = req.getString("token");
@@ -952,6 +953,7 @@ private void handleTokenGenerateV2(RoutingContext rc) {
 
             final InputUtil.InputVal input = this.getTokenInputV2(req);
             if (isTokenInputValid(input, rc)) {
+                recordRawEmailDotMetric(input, rc.request().path());
                 final String apiContact = getApiContact(rc);
 
                 switch (validateUserConsent(req, apiContact)) {
@@ -1008,6 +1010,7 @@ private Future handleLogoutAsyncV2(RoutingContext rc) {
         final InputUtil.InputVal input = getTokenInputV2(req);
         final String uidTraceId = rc.request().getHeader(Audit.UID_TRACE_ID_HEADER);
         if (input != null && input.isValid()) {
+            recordRawEmailDotMetric(input, rc.request().path());
             final Instant now = Instant.now();
 
             Promise promise = Promise.promise();
@@ -1232,6 +1235,12 @@ private void handleIdentityMapV2(RoutingContext rc) {
 
             if (!validateServiceLink(rc)) { return; }
 
+            if (v2Input.diiType().equals("email")) {
+                for (InputUtil.InputVal input : v2Input.inputList()) {
+                    recordRawEmailDotMetric(input, rc.request().path());
+                }
+            }
+
             final JsonObject resp = processIdentityMapV2Response(rc, v2Input);
             ResponseUtil.SuccessV2(rc, resp);
         } catch (Exception e) {
@@ -1295,6 +1304,13 @@ private void handleIdentityMapV3(RoutingContext rc) {
 
             if (!validateServiceLink(rc)) { return; }
 
+            InputUtil.InputVal[] emailInputs = normalizedInput.get("email");
+            if (emailInputs != null) {
+                for (InputUtil.InputVal emailInput : emailInputs) {
+                    recordRawEmailDotMetric(emailInput, rc.request().path());
+                }
+            }
+
             final JsonObject response = processIdentityMapV3Response(rc, normalizedInput);
             ResponseUtil.SuccessV2(rc, response);
         } catch (ClassCastException | JsonProcessingException processingException) {
@@ -1507,6 +1523,24 @@ public TokenVersion getRefreshTokenVersion(String s) {
         return null;
     }
 
+    private void recordRawEmailDotMetric(InputUtil.InputVal input, String path) {
+        if (!input.isValid() || input.getInputType() != InputUtil.IdentityInputType.Raw
+                || input.getIdentityType() != IdentityType.Email) {
+            return;
+        }
+        String provided = input.getProvided();
+        int atIndex = provided.indexOf('@');
+        boolean hasDot = atIndex > 0 && provided.lastIndexOf('.', atIndex) >= 0;
+        boolean isGmail = input.getNormalized().endsWith("@gmail.com");
+        Counter.builder("uid2_operator_raw_email_dot_total")
+                .description("Count of valid raw emails processed, by presence of dot before @ and gmail domain")
+                .tag("path", path)
+                .tag("has_dot", String.valueOf(hasDot))
+                .tag("is_gmail", String.valueOf(isGmail))
+                .register(Metrics.globalRegistry)
+                .increment();
+    }
+
     private void recordRefreshTokenVersionCount(String siteId, TokenVersion tokenVersion) {
         Counter.builder("uid2_refresh_token_received_count_total")
                 .description(String.format("Counter for the amount of refresh token %s received", tokenVersion.toString().toLowerCase()))