Add merchant research Discord channel for registration notifications

Sends new origin registrations to a dedicated merchant research channel
with the origin URL displayed between the title and description. The
existing notification channel continues to receive the same format as
before.

Author: onchainlu

apps/scan/.env.example

@@ -21,3 +21,4 @@ NEXT_PUBLIC_PROXY_URL=https://proxy.x402scan.com
 SIGNOZ_INGESTION_KEY=
 OTEL_SERVICE_NAME=
 DISCORD_NOTIFICATIONS_WEBHOOK_URL=
+DISCORD_MERCHANT_RESEARCH_WEBHOOK_URL=

apps/scan/src/env.ts

@@ -41,6 +41,7 @@ export const env = createEnv({
     RESOURCE_SEARCH_API_KEY: z.string().optional(),
     STRIPE_SECRET_KEY: z.string(),
     DISCORD_NOTIFICATIONS_WEBHOOK_URL: z.url().optional(),
+    DISCORD_MERCHANT_RESEARCH_WEBHOOK_URL: z.url().optional(),
     DISCORD_TELEMETRY_WEBHOOK_URL: z.string().optional(),
     X402_PAYEE_ADDRESS: z.string().optional(),
     AGENTCASH_URL: z.string().optional(),

apps/scan/src/lib/discord-notifications.ts

@@ -20,17 +20,25 @@ interface DiscordConfig {
 
 export function notifyNewServer(notification: NewServerNotification) {
   scheduleDiscordNotification({
+    webhookUrl: env.DISCORD_NOTIFICATIONS_WEBHOOK_URL,
     username: NEW_SERVER_USERNAME,
     embed: config => buildNewServerEmbed(notification, config),
   });
+
+  scheduleDiscordNotification({
+    webhookUrl: env.DISCORD_MERCHANT_RESEARCH_WEBHOOK_URL,
+    username: NEW_SERVER_USERNAME,
+    embed: config => buildMerchantResearchEmbed(notification, config),
+  });
 }
 
 function scheduleDiscordNotification(options: {
+  webhookUrl: string | undefined;
   username: string;
   embed: (config: DiscordConfig) => DiscordEmbed;
 }) {
   try {
-    const config = getDiscordConfig();
+    const config = getDiscordConfig(options.webhookUrl);
     if (!config) return;
 
     const sendNotification = async () => {
@@ -55,9 +63,9 @@ function scheduleDiscordNotification(options: {
   }
 }
 
-function getDiscordConfig(): DiscordConfig | null {
-  const webhookUrl = env.DISCORD_NOTIFICATIONS_WEBHOOK_URL;
-
+function getDiscordConfig(
+  webhookUrl: string | undefined
+): DiscordConfig | null {
   if (process.env.VERCEL_ENV !== 'production' || !webhookUrl) return null;
 
   return {
@@ -115,6 +123,28 @@ function buildNewServerEmbed(
   };
 }
 
+function buildMerchantResearchEmbed(
+  notification: NewServerNotification,
+  config: DiscordConfig
+) {
+  const domain = domainFromOrigin(notification.origin);
+  const title = notification.title?.trim();
+  const name = title && title.length > 0 ? title : domain;
+  const description = truncateDescription(notification.description);
+  const lines = [
+    `[**${escapeMarkdown(name)}**](${serverUrl(config.appUrl, notification.originId)})`,
+    `\`${notification.origin}\``,
+  ];
+
+  if (description) {
+    lines.push(escapeMarkdown(description));
+  }
+
+  return {
+    description: lines.join('\n'),
+  };
+}
+
 function serverUrl(appUrl: string, originId: string) {
   return `${appUrl}/server/${encodeURIComponent(originId)}`;
 }

turbo.json

@@ -125,6 +125,7 @@
     "OPENROUTER_API_KEY",
     "FREEPIK_API_KEY",
     "DISCORD_TELEMETRY_WEBHOOK_URL",
+    "DISCORD_MERCHANT_RESEARCH_WEBHOOK_URL",
     "X402_PAYEE_ADDRESS",
     "SOLANA_RPC_*",
     "BASE_RPC_*"