refactored to use statsd instead of dd-tracer (#743)

* refactored to use statsd instead of dd-tracer

* using correct vaults-claimer.heartbeat

Author: julien51

claimer/main.ts

@@ -1,4 +1,3 @@
-import { heartbeat } from './src/tracer'
 import { start, stop } from './src/runner'
 import { proveTransactions } from './src/prove-transactions'
 import { claimTransactions } from './src/claim-withdrawals'
@@ -11,7 +10,6 @@ import { logger } from './src/logger'
 
 const run = async () => {
   const { vaultService } = await start()
-  await heartbeat()
 
   // process transactions
   await proveTransactions({ vaultService })

claimer/package.json

@@ -20,6 +20,7 @@
   },
   "dependencies": {
     "ethers": "6.15.0",
+    "hot-shots": "11.2.0",
     "tsx": "4.20.4",
     "winston": "3.17.0"
   }

claimer/src/datadog.ts

@@ -0,0 +1,35 @@
+import { StatsD } from 'hot-shots'
+import { logger } from './logger'
+
+let statsd: StatsD | null = null
+const service = process.env.SERVICE_NAME || 'vaults-backend-claimer'
+const environment =
+  process.env.ENVIRONMENT || process.env.NODE_ENV || 'development'
+const version = process.env.IMAGE_TAG || 'unknown'
+const url = new URL(process.env.DATADOG_AGENT_URL || 'http://localhost:8125')
+
+export const start = () => {
+  logger.info('Starting monitoring', { environment, service, url, version })
+  // init if datadog is set
+  if (process.env.DATADOG_AGENT_URL) {
+    statsd = new StatsD({
+      globalTags: {
+        environment,
+        service,
+        version,
+      },
+      host: url.hostname,
+      port: parseInt(url.port || '8125', 10),
+    })
+
+    statsd.increment('vaults-claimer.heartbeat', 1)
+    logger.info('Heartbeat sent to datadog')
+  }
+}
+
+export const stop = async () => {
+  logger.info('Stopped monitoring')
+  if (statsd) {
+    statsd.close()
+  }
+}

claimer/src/runner.ts

@@ -3,11 +3,15 @@ import { RelayVaultService } from '@relay-vaults/client'
 const vaultService = new RelayVaultService(
   process.env.BACKEND_URL ?? 'https://vaults-api.relay.link/'
 )
+import * as monitoring from './datadog.js'
 
 export const start = async () => {
+  monitoring.start()
   return {
     vaultService,
   }
 }
 
-export const stop = async () => {}
+export const stop = async () => {
+  monitoring.stop()
+}

claimer/src/tracer.ts

@@ -4887,6 +4887,7 @@ __metadata:
     "@types/node": "npm:24.3.0"
     eslint: "npm:9.33.0"
     ethers: "npm:6.15.0"
+    hot-shots: "npm:11.2.0"
     tsx: "npm:4.20.4"
     typescript: "npm:5.9.2"
     winston: "npm:3.17.0"
@@ -7811,6 +7812,15 @@ __metadata:
   languageName: node
   linkType: hard
 
+"bindings@npm:^1.5.0":
+  version: 1.5.0
+  resolution: "bindings@npm:1.5.0"
+  dependencies:
+    file-uri-to-path: "npm:1.0.0"
+  checksum: 10/593d5ae975ffba15fbbb4788fe5abd1e125afbab849ab967ab43691d27d6483751805d98cb92f7ac24a2439a8a8678cd0131c535d5d63de84e383b0ce2786133
+  languageName: node
+  linkType: hard
+
 "bintrees@npm:1.0.2":
   version: 1.0.2
   resolution: "bintrees@npm:1.0.2"
@@ -10571,6 +10581,13 @@ __metadata:
   languageName: node
   linkType: hard
 
+"file-uri-to-path@npm:1.0.0":
+  version: 1.0.0
+  resolution: "file-uri-to-path@npm:1.0.0"
+  checksum: 10/b648580bdd893a008c92c7ecc96c3ee57a5e7b6c4c18a9a09b44fb5d36d79146f8e442578bc0e173dc027adf3987e254ba1dfd6e3ec998b7c282873010502144
+  languageName: node
+  linkType: hard
+
 "fill-keys@npm:^1.0.2":
   version: 1.0.2
   resolution: "fill-keys@npm:1.0.2"
@@ -11555,6 +11572,18 @@ __metadata:
   languageName: node
   linkType: hard
 
+"hot-shots@npm:11.2.0":
+  version: 11.2.0
+  resolution: "hot-shots@npm:11.2.0"
+  dependencies:
+    unix-dgram: "npm:2.x"
+  dependenciesMeta:
+    unix-dgram:
+      optional: true
+  checksum: 10/7fcd3c160e2ba012c4dd6c36c603ad3f419e572707ff5324be955ddccf436537a79244a5f45b3d5a49f91f93e88db729561521365aceb5c0a0f8cfc59c50a675
+  languageName: node
+  linkType: hard
+
 "http-cache-semantics@npm:^4.1.1":
   version: 4.1.1
   resolution: "http-cache-semantics@npm:4.1.1"
@@ -17298,6 +17327,17 @@ __metadata:
   languageName: node
   linkType: hard
 
+"unix-dgram@npm:2.x":
+  version: 2.0.7
+  resolution: "unix-dgram@npm:2.0.7"
+  dependencies:
+    bindings: "npm:^1.5.0"
+    nan: "npm:^2.20.0"
+    node-gyp: "npm:latest"
+  checksum: 10/a171f3079d27f244dfb7ff3feef2717c3f44756640532d92015e0fc2918153994070e02d652af402b269c95aae59eeb82c1792d614df00493724addbce468327
+  languageName: node
+  linkType: hard
+
 "unixify@npm:^1.0.0":
   version: 1.0.0
   resolution: "unixify@npm:1.0.0"