chore: add stats for shopify anonId resolution based on shopifyTopic …

…and method

src/util/prometheus.js

@@ -487,6 +487,12 @@ class Prometheus {
         type: 'counter',
         labelNames: ['type', 'writeKey', 'source'],
       },
+      {
+        name: 'shopify_anon_id_resolve',
+        help: 'shopify_anon_id_resolve',
+        type: 'counter',
+        labelNames: ['method', 'writeKey', 'shopifyTopic'],
+      },
       {
         name: 'shopify_redis_calls',
         help: 'shopify_redis_calls',

src/v0/sources/shopify/transform.js

@@ -175,7 +175,7 @@ const processEvent = async (inputEvent, metricMetadata) => {
   if (message.type !== EventType.IDENTIFY) {
     const { anonymousId, sessionId } = await getAnonymousIdAndSessionId(
       message,
-      metricMetadata,
+      { shopifyTopic, ...metricMetadata },
       redisData,
     );
     if (isDefinedAndNotNull(anonymousId)) {

src/v0/sources/shopify/util.js

@@ -164,6 +164,10 @@ const getAnonymousIdAndSessionId = async (message, metricMetadata, redisData = n
   }
   // falling back to cartToken mapping or its hash in case no rudderAnonymousId or rudderSessionId is found
   if (isDefinedAndNotNull(anonymousId) && isDefinedAndNotNull(sessionId)) {
+    stats.increment('shopify_anon_id_resolve', {
+      method: 'note_attributes',
+      ...metricMetadata,
+    });
     return { anonymousId, sessionId };
   }
   const cartToken = getCartToken(message);
@@ -189,6 +193,13 @@ const getAnonymousIdAndSessionId = async (message, metricMetadata, redisData = n
     Hash the id and use it as anonymousId (limiting 256 -> 36 chars) and sessionId is not sent as its not required field
     */
     anonymousId = v5(cartToken, v5.URL);
+  } else {
+    // This metric let us know how many events based on event name used redis for anonId resolution
+    // and for how many
+    stats.increment('shopify_anon_id_resolve', {
+      method: 'database',
+      ...metricMetadata,
+    });
   }
   return { anonymousId, sessionId };
 };