feat: add timestamps to client events

Author: aleortega

package.json

@@ -20,7 +20,7 @@
     "@dcl/catalyst-contracts": "^4.4.2",
     "@dcl/crypto": "^3.4.5",
     "@dcl/platform-server-commons": "^0.0.4",
-    "@dcl/schemas": "^14.0.0",
+    "@dcl/schemas": "https://sdk-team-cdn.decentraland.org/@dcl/schemas/branch/feat/multiple-timestamps-on-client-events/dcl-schemas-16.0.1-13812753145.commit-5cf4966.tgz",
     "@well-known-components/env-config-provider": "^1.2.0",
     "@well-known-components/http-server": "^2.1.0",
     "@well-known-components/interfaces": "^1.4.3",

src/adapters/event-parser.ts

@@ -50,6 +50,10 @@ export function createEventParserComponent({ logs }: Pick<AppComponents, 'logs'>
             userAddress: event.context.dcl_eth_address,
             sessionId: event.context.session_id,
             timestamp: event.sentAt,
+            timestamps: {
+              receivedAt: new Date(event.receivedAt).getTime(),
+              reportedAt: new Date(event.timestamp).getTime()
+            },
             realm: event.context.realm,
             parcel: {
               isEmptyParcel: event.properties.is_empty_parcel,
@@ -72,6 +76,10 @@ export function createEventParserComponent({ logs }: Pick<AppComponents, 'logs'>
             userAddress: event.context.dcl_eth_address,
             sessionId: event.context.session_id,
             timestamp: event.sentAt,
+            timestamps: {
+              receivedAt: new Date(event.receivedAt).getTime(),
+              reportedAt: new Date(event.timestamp).getTime()
+            },
             realm: event.context.realm,
             emote: {
               emoteIndex: event.properties.emote_index,
@@ -94,6 +102,10 @@ export function createEventParserComponent({ logs }: Pick<AppComponents, 'logs'>
             userAddress: event.context.dcl_eth_address,
             sessionId: event.context.session_id,
             timestamp: event.sentAt,
+            timestamps: {
+              receivedAt: new Date(event.receivedAt).getTime(),
+              reportedAt: new Date(event.timestamp).getTime()
+            },
             realm: event.context.realm,
             passport: {
               receiver: event.properties.receiver_id
@@ -113,6 +125,10 @@ export function createEventParserComponent({ logs }: Pick<AppComponents, 'logs'>
             userAddress: event.context.dcl_eth_address,
             sessionId: event.context.session_id,
             timestamp: event.sentAt,
+            timestamps: {
+              receivedAt: new Date(event.receivedAt).getTime(),
+              reportedAt: new Date(event.timestamp).getTime()
+            },
             realm: event.context.realm,
             distance: event.properties.distance,
             stepCount: event.properties.step_count
@@ -131,6 +147,10 @@ export function createEventParserComponent({ logs }: Pick<AppComponents, 'logs'>
             userAddress: event.context.dcl_eth_address,
             sessionId: event.context.session_id,
             timestamp: event.sentAt,
+            timestamps: {
+              receivedAt: new Date(event.receivedAt).getTime(),
+              reportedAt: new Date(event.timestamp).getTime()
+            },
             realm: event.context.realm,
             height: event.properties.height
           }

src/metrics.ts

@@ -3,12 +3,28 @@ import { validateMetricsDeclaration } from '@well-known-components/metrics'
 import { metricDeclarations as pgMetricDeclarations } from '@well-known-components/pg-component'
 import { metricDeclarations as theGraphMetricDeclarations } from '@well-known-components/thegraph-component'
 import { getDefaultHttpMetrics } from '@well-known-components/http-server'
+import { IMetricsComponent } from '@well-known-components/interfaces'
 
 export const metricDeclarations = {
   ...getDefaultHttpMetrics(),
   ...logMetricDeclarations,
   ...pgMetricDeclarations,
-  ...theGraphMetricDeclarations
+  ...theGraphMetricDeclarations,
+  explorer_segment_event_delay_in_seconds: {
+    type: IMetricsComponent.GaugeType,
+    help: 'Delay between segment event and explorer event',
+    labelNames: ['event_type']
+  },
+  segment_webhook_event_delay_in_seconds: {
+    type: IMetricsComponent.GaugeType,
+    help: 'Delay between segment webhook event and explorer event',
+    labelNames: ['event_type']
+  },
+  handled_explorer_events_count: {
+    type: IMetricsComponent.CounterType,
+    help: 'Number of explorer events',
+    labelNames: ['event_type']
+  }
 }
 
 // type assertions

yarn.lock

@@ -802,6 +802,15 @@
     ajv-errors "^3.0.0"
     ajv-keywords "^5.1.0"
 
+"@dcl/schemas@https://sdk-team-cdn.decentraland.org/@dcl/schemas/branch/feat/multiple-timestamps-on-client-events/dcl-schemas-16.0.1-13812753145.commit-5cf4966.tgz":
+  version "16.0.1-13812753145.commit-5cf4966"
+  resolved "https://sdk-team-cdn.decentraland.org/@dcl/schemas/branch/feat/multiple-timestamps-on-client-events/dcl-schemas-16.0.1-13812753145.commit-5cf4966.tgz#1b8b50f9d741f921294370342ce25809e5ef202a"
+  dependencies:
+    ajv "^8.11.0"
+    ajv-errors "^3.0.0"
+    ajv-keywords "^5.1.0"
+    mitt "^3.0.1"
+
 "@eslint-community/eslint-utils@^4.2.0", "@eslint-community/eslint-utils@^4.4.0":
   version "4.4.0"
   resolved "https://registry.yarnpkg.com/@eslint-community/eslint-utils/-/eslint-utils-4.4.0.tgz#a23514e8fb9af1269d5f7788aa556798d61c6b59"