feat(indexer): trigger address activity job

apps/indexer/package.json

@@ -17,10 +17,12 @@
     "dependencies": {
         "@dfuse/client": "^0.3.21",
         "@repo/supabase": "workspace:*",
+        "@repo/trigger": "workspace:*",
         "@sentry/integrations": "^7.114.0",
         "@sentry/node": "^8.19.0",
         "@sentry/profiling-node": "^8.26.0",
         "@supabase/supabase-js": "^2.44.4",
+        "@trigger.dev/sdk": "^2.3.19",
         "@types/pino-http": "^5.8.4",
         "app-contracts": "workspace:*",
         "app-env": "workspace:*",

apps/indexer/src/routes/alchemy.ts

@@ -2,19 +2,26 @@ import { Request, Response } from 'express'
 import crypto from 'crypto'
 import { appConfig } from '../config'
 import { logger } from '~/lib/logger'
+import {addressActivityTask} from '@repo/trigger';
 
-function validateAlchemySignature(req: Request): boolean {
-  const alchemySignature = req.headers['x-alchemy-signature'] as string
-  const payload = JSON.stringify(req.body)
-  const hmac = crypto.createHmac('sha256', appConfig.evm.alchemySecretKey)
-  hmac.update(payload)
-  return alchemySignature === hmac.digest('hex')
-}
 
 export function alchemyWebhook(req: Request, res: Response) {
   if (!validateAlchemySignature(req)) return res.status(401).send('Unauthorized')
 
    logger.info(req.body)   
 
+    // TODO: validate user is whitelisted
+
+   addressActivityTask.trigger(req.body)
+
   res.status(200).send('Webhook processed')
-}
+}
+
+
+function validateAlchemySignature(req: Request): boolean {
+    const alchemySignature = req.headers['x-alchemy-signature'] as string
+    const payload = JSON.stringify(req.body)
+    const hmac = crypto.createHmac('sha256', appConfig.evm.alchemySecretKey)
+    hmac.update(payload)
+    return alchemySignature === hmac.digest('hex')
+  }

apps/trigger/package.json

@@ -1,17 +1,18 @@
 {
-  "name": "smartsale-jobs",
+  "name": "@repo/trigger",
   "version": "0.0.1",
   "private": true,
+  "main": "src/index.ts",
   "scripts": {
     "dev": "bunx trigger.dev@beta dev",
     "deploy:test": "bunx trigger.dev@beta deploy --env test",
     "deploy:prod": "bunx trigger.dev@beta deploy --env prod"
   },
   "dependencies": {
-    "@trigger.dev/sdk": "3.0.0-beta.54",
-    "viem": "latest",
+    "@trigger.dev/sdk": "^2.3.19",
     "app-contracts": "workspace:*",
     "app-env": "workspace:*",
-    "app-lib": "workspace:*"
+    "app-lib": "workspace:*",
+    "viem": "latest"
   }
 }

apps/trigger/src/index.ts

@@ -0,0 +1 @@
+export * from './trigger/activity'

apps/trigger/src/trigger/transfers.ts → apps/trigger/src/trigger/activity.ts

@@ -1,4 +1,5 @@
 import { logger, task } from "@trigger.dev/sdk/v3";
+import { getErrorMessage } from "app-lib";
 
 export const addressActivityTask = task({
   id: "address-activity",
@@ -9,7 +10,7 @@ export const addressActivityTask = task({
 
 
     } catch (error) {
-      logger.error("Error processing address activity", { error: (error as Error).message });
+      logger.error("Error processing address activity", { error: getErrorMessage(error) });
       throw error;
     }
   },