feat: Webhook notifications via ntfy.sh

Author: Lissy93

src/server/routes/domain-updater/lib/notify.ts

@@ -1,9 +1,5 @@
-// server/api/trigger-updates/lib/notifyIfEnabled.ts
-
 import { callPgExecutor } from './pgExecutor';
-// import { Logger } from './logger';
-
-// const log = new Logger('notify');
+import { sendWebhookNotification } from './sendWebhookNotification';
 
 /**
  * Check if a notification should be sent for a changeType, and insert it if so.
@@ -31,6 +27,7 @@ export async function notifyUser(
     );
 
     if (!isEnabled) {
+      console.info(`Skipping notification for ${changeType}, because not enabled for this domain`);
       return;
     }
 
@@ -44,13 +41,14 @@ export async function notifyUser(
       [userId, domainId, changeType, message || null]
     );
 
-    // Placeholder: Webhook / external dispatch
-    // log.info(`📤 Notification queued: domain=${domainId}, type=${changeType}`);
-
-    console.log(`Notification queued: domain=${domainId}, type=${changeType}`);
+    // Send webhook notification
+    await sendWebhookNotification(
+      message || `Change detected: ${changeType}`,
+      'Domain Locker Update',
+      [changeType]
+    );
 
-    // TODO: Dispatch webhook or send notification to user
   } catch (err: any) {
-    // log.error(`Failed to insert notification for ${changeType}: ${err.message}`);
+    console.error(`Failed to insert notification for ${changeType}: ${err.message}`);
   }
 }

src/server/routes/domain-updater/lib/sendWebhookNotification.ts

@@ -0,0 +1,35 @@
+import { getEnvVar } from './utils';
+
+export async function sendWebhookNotification(
+  message: string,
+  title = 'Domain Locker',
+  tags?: string[]
+): Promise<void> {
+  const base = getEnvVar('NOTIFY_WEBHOOK_BASE');
+  const topic = getEnvVar('NOTIFY_WEBHOOK_TOPIC');
+  const token = getEnvVar('NOTIFY_WEBHOOK_TOKEN', '');
+
+  if (!base || !topic) {
+    console.log('Webhook notification skipped (missing config)');
+    return;
+  }
+
+  try {
+    const res = await fetch(`${base.replace(/\/$/, '')}/${topic}`, {
+      method: 'POST',
+      headers: {
+        'Content-Type': 'text/plain',
+        ...(token ? { Authorization: `Bearer ${token}` } : {})
+      },
+      body: message
+    });
+
+    if (!res.ok) {
+      throw new Error(`Failed with status ${res.status}`);
+    }
+
+    console.info(`📨 Webhook sent: ${title} - ${message}`);
+  } catch (err: any) {
+    console.error(`❌ Webhook failed: ${err.message}`);
+  }
+}