enable discord notifications into test channel

Author: apexearth

CLAUDE.md

@@ -126,7 +126,7 @@ Use the admin UI (`../alert-config-admin`) or insert directly into the `alert_ru
 - `addresses` — contract addresses to watch (NULL = any)
 - `topic0s` — event signatures to match (NULL = any)
 - `sighashes` — function selectors for traces (NULL = any)
-- `data_filters` — optional JSONB filter on decoded data
+- `data_filters` — optional JSONB filter on decoded data (notification-only — all data is always persisted regardless of filters)
 - `topic` — Discord channel (OETH, OUSD, ARM, etc.)
 - `severity` — low, medium, high, critical, broken, highlight
 

squid.yaml

@@ -22,6 +22,7 @@ deploy:
     - RPC_SONIC_ENV
     - ALERT_CONFIG_DB_URL
     - RAILWAY_DATABASE_URL
+    - DISCORD_WEBHOOK_URL_TEST
     - DISCORD_WEBHOOK_URL_OGN
     - DISCORD_WEBHOOK_URL_OGN_ALERTS
     - DISCORD_WEBHOOK_URL_OGN_BUYBACKS

src/alert-config/migration.sql

@@ -159,7 +159,8 @@ CREATE TABLE alert_rule (
   suicide_refund_address TEXT[] CHECK (array_all_match(suicide_refund_address, 'address')),
   trace_error     BOOLEAN,               -- true = only failed traces, NULL = any
 
-  -- Conditions on decoded data — evaluated after matching.
+  -- Conditions on decoded data — controls NOTIFICATIONS ONLY.
+  -- All on-chain data is always persisted regardless of these filters.
   -- Supports AND/OR trees with comparison operators.
   data_filters    JSONB CHECK (is_valid_filter(data_filters)),
 

src/main-base.ts

@@ -32,11 +32,11 @@ const start = async () => {
     chainId: base.id,
     processors: [configAlert, persistenceProcessor],
     stateSchema: 'base',
-    // postValidation: async (ctx) => {
-    //   await processDiscordQueue()
-    //   await processOncallQueue()
-    //   await processLokiQueue()
-    // },
+    postValidation: async (ctx) => {
+      await processDiscordQueue()
+      // await processOncallQueue()
+      // await processLokiQueue()
+    },
     fields: DEFAULT_FIELDS,
   }).catch((err) => {
     throw err

src/main-sonic.ts

@@ -32,11 +32,11 @@ const start = async () => {
     chainId: sonic.id,
     processors: [configAlert, persistenceProcessor],
     stateSchema: 'sonic',
-    // postValidation: async (ctx) => {
-    //   await processDiscordQueue()
-    //   await processOncallQueue()
-    //   await processLokiQueue()
-    // },
+    postValidation: async (ctx) => {
+      await processDiscordQueue()
+      // await processOncallQueue()
+      // await processLokiQueue()
+    },
     fields: DEFAULT_FIELDS,
   }).catch((err) => {
     throw err

src/main.ts

@@ -39,11 +39,11 @@ const start = async () => {
     chainId: mainnet.id,
     processors: [...customProcessors, configAlert, persistenceProcessor],
     stateSchema: 'mainnet',
-    // postValidation: async (ctx) => {
-    //   await processDiscordQueue()
-    //   await processOncallQueue()
-    //   await processLokiQueue()
-    // },
+    postValidation: async (ctx) => {
+      await processDiscordQueue()
+      // await processOncallQueue()
+      // await processLokiQueue()
+    },
     fields: DEFAULT_FIELDS,
   }).catch((err) => {
     throw err

src/notify/discord.ts

@@ -3,18 +3,19 @@ import { sortBy } from 'lodash'
 
 import { Severity, Topic, severityEmojis, topicThumbnails } from './const'
 
+const testUrl = process.env['DISCORD_WEBHOOK_URL_TEST']
 const webhookUrls: Record<Topic, string> = {
-  Governance: process.env['DISCORD_WEBHOOK_URL_GOVERNANCE'] ?? '',
-  OGN: process.env['DISCORD_WEBHOOK_URL_OGN'] ?? '',
-  'OGN Alerts': process.env['DISCORD_WEBHOOK_URL_OGN_ALERTS'] ?? '',
-  'OGN Buybacks': process.env['DISCORD_WEBHOOK_URL_OGN_BUYBACKS'] ?? '',
-  OETH: process.env['DISCORD_WEBHOOK_URL_OETH'] ?? '',
-  superOETHb: process.env['DISCORD_WEBHOOK_URL_SUPER_OETH_B'] ?? '',
-  OUSD: process.env['DISCORD_WEBHOOK_URL_OUSD'] ?? '',
-  xOGN: process.env['DISCORD_WEBHOOK_URL_XOGN'] ?? '',
-  primeETH: process.env['DISCORD_WEBHOOK_URL_PRIME_ETH'] ?? '',
-  ARM: process.env['DISCORD_WEBHOOK_URL_ARM'] ?? '',
-  OS: process.env['DISCORD_WEBHOOK_URL_OS'] ?? '',
+  Governance: testUrl ?? process.env['DISCORD_WEBHOOK_URL_GOVERNANCE'] ?? '',
+  OGN: testUrl ?? process.env['DISCORD_WEBHOOK_URL_OGN'] ?? '',
+  'OGN Alerts': testUrl ?? process.env['DISCORD_WEBHOOK_URL_OGN_ALERTS'] ?? '',
+  'OGN Buybacks': testUrl ?? process.env['DISCORD_WEBHOOK_URL_OGN_BUYBACKS'] ?? '',
+  OETH: testUrl ?? process.env['DISCORD_WEBHOOK_URL_OETH'] ?? '',
+  superOETHb: testUrl ?? process.env['DISCORD_WEBHOOK_URL_SUPER_OETH_B'] ?? '',
+  OUSD: testUrl ?? process.env['DISCORD_WEBHOOK_URL_OUSD'] ?? '',
+  xOGN: testUrl ?? process.env['DISCORD_WEBHOOK_URL_XOGN'] ?? '',
+  primeETH: testUrl ?? process.env['DISCORD_WEBHOOK_URL_PRIME_ETH'] ?? '',
+  ARM: testUrl ?? process.env['DISCORD_WEBHOOK_URL_ARM'] ?? '',
+  OS: testUrl ?? process.env['DISCORD_WEBHOOK_URL_OS'] ?? '',
 }
 
 const clients: Record<Topic, WebhookClient | undefined> = {