Merge pull request #234 from autonomys/add-interaction-metric

feat: send interaction to vmetrics

Author: clostao

backend/src/drivers/vmetrics.ts

@@ -8,29 +8,35 @@ export interface Metric {
 }
 
 export const sendMetricToVictoria = async (metric: Metric): Promise<void> => {
-  const values = Object.entries(metric.fields).map(
-    ([key, value]) => `${key}=${value}`,
-  )
-  const data = `${metric.measurement},${metric.tag} ${values.join(',')}`
+  try {
+    const values = Object.entries(metric.fields).map(
+      ([key, value]) => `${key}=${value}`,
+    )
+    const data = `${metric.measurement},${metric.tag} ${values.join(',')}`
 
-  const basicAuthToken = Buffer.from(
-    `${config.monitoring.auth.username}:${config.monitoring.auth.password}`,
-  ).toString('base64')
+    const basicAuthToken = Buffer.from(
+      `${config.monitoring.auth.username}:${config.monitoring.auth.password}`,
+    ).toString('base64')
 
-  if (!config.monitoring.victoriaEndpoint) {
-    console.log(JSON.stringify(config.monitoring, null, 2))
-    console.error('Victoria endpoint is not set')
-    return
-  }
+    if (!config.monitoring.victoriaEndpoint) {
+      console.log(JSON.stringify(config.monitoring, null, 2))
+      console.error('Victoria endpoint is not set')
+      return
+    }
 
-  const response = await fetch(config.monitoring.victoriaEndpoint, {
-    method: 'POST',
-    body: data,
-    headers: {
-      Authorization: `Basic ${basicAuthToken}`,
-    },
-  })
-  if (!response.ok) {
-    throw new Error(`Failed to send metric to Victoria: ${response.statusText}`)
+    const response = await fetch(config.monitoring.victoriaEndpoint, {
+      method: 'POST',
+      body: data,
+      headers: {
+        Authorization: `Basic ${basicAuthToken}`,
+      },
+    })
+    if (!response.ok) {
+      throw new Error(
+        `Failed to send metric to Victoria: ${response.statusText}`,
+      )
+    }
+  } catch (error) {
+    console.error('Failed to send metric to Victoria', error)
   }
 }

backend/src/http/middlewares/requestTrace.ts

@@ -33,5 +33,5 @@ export const requestTrace: RequestHandler = (req, res) => {
     },
   }
 
-  sendMetricToVictoria(metric).catch(console.error)
+  sendMetricToVictoria(metric)
 }

backend/src/useCases/objects/interactions.ts

@@ -1,12 +1,34 @@
 import { v4 } from 'uuid'
 import { InteractionType } from '@auto-drive/models'
 import { interactionsRepository } from '../../repositories/objects/interactions.js'
+import { Metric, sendMetricToVictoria } from '../../drivers/vmetrics.js'
+import { config } from '../../config.js'
+
+const createMetric = (type: InteractionType, size: bigint): Metric => {
+  const tags = {
+    chain: config.monitoring.metricEnvironmentTag,
+    type,
+  }
+
+  const tag = Object.entries(tags)
+    .map(([key, value]) => `${key}=${value}`)
+    .join(',')
+
+  return {
+    measurement: 'auto_drive_interactions',
+    tag,
+    fields: {
+      size,
+    },
+  }
+}
 
 const createInteraction = async (
   subscriptionId: string,
   type: InteractionType,
   size: bigint,
 ): Promise<void> => {
+  sendMetricToVictoria(createMetric(type, size))
   await interactionsRepository.createInteraction(
     v4(),
     subscriptionId,