Merge pull request #1511 from IABTechLab/ans-UID2-4956-add-site-id-extraction-logic

changes to record old sdk versions being used with site id

Author: ashleysmithTTD

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

@@ -870,6 +870,7 @@ private void handleTokenRefreshV1(RoutingContext rc) {
         try {
             final RefreshResponse r = this.refreshIdentity(rc, refreshToken);
             siteId = rc.get(Const.RoutingContextData.SiteId);
+            recordOperatorServedSdkUsage(siteId, rc, rc.request().headers().get(Const.Http.ClientVersionHeader));
             if (!r.isRefreshed()) {
                 if (r.isOptOut() || r.isDeprecated()) {
                     ResponseUtil.SuccessNoBody(ResponseStatus.OptOut, rc);
@@ -894,6 +895,14 @@ private void handleTokenRefreshV1(RoutingContext rc) {
         }
     }
 
+    public void recordOperatorServedSdkUsage(Integer siteId, RoutingContext rc, String clientVersion) {
+        _clientVersionCounters.computeIfAbsent(new Tuple.Tuple2<>(Integer.toString(siteId), clientVersion), tuple -> Counter
+                    .builder("uid2.client_sdk_versions")
+                    .description("counter for how many http requests are processed per each operator-served sdk version")
+                    .tags("site_id", tuple.getItem1(), "client_version", tuple.getItem2())
+                    .register(Metrics.globalRegistry)).increment();;
+    }
+
     private void handleTokenRefreshV2(RoutingContext rc) {
         Integer siteId = null;
         TokenResponseStatsCollector.PlatformType platformType = TokenResponseStatsCollector.PlatformType.Other;
@@ -905,6 +914,7 @@ private void handleTokenRefreshV2(RoutingContext rc) {
             String tokenStr = (String) rc.data().get("request");
             final RefreshResponse r = this.refreshIdentity(rc, tokenStr);
             siteId = rc.get(Const.RoutingContextData.SiteId);
+            recordOperatorServedSdkUsage(siteId, rc, rc.request().headers().get(Const.Http.ClientVersionHeader));
             if (!r.isRefreshed()) {
                 if (r.isOptOut() || r.isDeprecated()) {
                     ResponseUtil.SuccessNoBodyV2(ResponseStatus.OptOut, rc);
@@ -1169,6 +1179,7 @@ private void handleTokenRefresh(RoutingContext rc) {
             sendJsonResponse(rc, toJson(r.getTokens()));
 
             siteId = rc.get(Const.RoutingContextData.SiteId);
+            recordOperatorServedSdkUsage(siteId, rc, rc.request().headers().get(Const.Http.ClientVersionHeader));
             if (r.isRefreshed()) {
                 this.recordRefreshDurationStats(siteId, getApiContact(rc), r.getDurationSinceLastRefresh(), rc.request().headers().contains(ORIGIN_HEADER), identityExpiresAfter);
             }