feat(relayer): adds possibility to filter messages based on msg.sender

packages/relayer/.env.example

@@ -4,4 +4,5 @@ RPC=
 PK=
 WATCH_INTERVAL_TIME_MS=
 MONGO_DB_URI=
-MIN_BATCH_SIZE=
+MIN_BATCH_SIZE=
+WHITELISTED_SENDER_ADDRESSES=

packages/relayer/README.md

@@ -9,6 +9,7 @@ The Relayer is a service used to relay batches of dispatched messages through Ya
  
 
 ## Installation
+
 To install the Relayer, follow these steps:
 
 ```bash
@@ -45,4 +46,3 @@ cd packages/relayer
 ```bash
 yarn start dotenv_config_path="your env file"
 ```
-

packages/relayer/src/index.ts

@@ -1,4 +1,4 @@
-import 'dotenv/config'
+import "dotenv/config"
 import { createWalletClient, http, Chain, publicActions, Log } from "viem"
 import { privateKeyToAccount } from "viem/accounts"
 import * as chains from "viem/chains"
@@ -18,6 +18,10 @@ const mongoClient = new MongoClient(process.env.MONGO_DB_URI as string)
 await mongoClient.connect()
 const db = mongoClient.db("hashi")
 
+const whitelistedSenderAddresses = process.env.WHITELISTED_SENDER_ADDRESSES?.split(",").map((_address: string) =>
+  _address.toLowerCase(),
+) as string[]
+
 const watcher = new Watcher({
   service: "RelayerWatcher",
   logger,
@@ -27,13 +31,11 @@ const watcher = new Watcher({
   eventName: "MessageDispatched",
   watchIntervalTimeMs: Number(process.env.WATCH_INTERVAL_TIME_MS as string),
   onLogs: async (_logs: Log[]) => {
-    // TODO: filter messages that you don't want to relay. For example it could be possible
-    // to relayMessagesToAdapters only those coming from specific message.sender
-
-    /*const blocks = (await Promise.all(
-      _logs.map((_log: Log) => client.getBlock({ blockHash: _log.blockHash as `0x${string}` })),
-    )) as Block[]*/
-    const messages = _logs.map((_log: Log) => Message.fromLog(_log))
+    let messages = _logs.map((_log: Log) => Message.fromLog(_log))
+    if (whitelistedSenderAddresses.length) {
+      logger.child({ service: "Relayer" }).info(`Filtering messages ...`)
+      messages = messages.filter((_message) => whitelistedSenderAddresses.includes(_message.sender.toLowerCase()))
+    }
 
     await Promise.all(
       messages.map((_message: Message, _index: number) =>