feat: add Better Stack webhook receiver for Telegram alerts

server/server.js

@@ -901,6 +901,63 @@ app.post('/api/streams/sync-vod-direct', authenticateWorker, async (req, res) =>
   }
 });
 
+// Outgoing Webhook receiver from Better Stack to forward alerts to Telegram bot
+app.post('/api/betterstack-webhook', async (req, res) => {
+  console.log('[Better Stack Webhook] Received webhook payload:', req.body);
+  
+  const botToken = process.env.TELEGRAM_BOT_TOKEN;
+  const chatId = process.env.TELEGRAM_CHAT_ID;
+
+  if (!botToken || !chatId) {
+    console.warn('[Better Stack Webhook] Missing TELEGRAM_BOT_TOKEN or TELEGRAM_CHAT_ID in environment');
+    return res.status(200).json({ success: false, error: 'Telegram credentials missing' });
+  }
+
+  try {
+    const event = req.body.event || 'incident.updated';
+    const data = req.body.data || {};
+    const attributes = data.attributes || {};
+    
+    const monitorName = attributes.name || 'Unknown Monitor';
+    const url = attributes.url || '';
+    const cause = attributes.cause || 'No cause provided';
+    const status = attributes.status || '';
+
+    let statusEmoji = '⚠️';
+    let statusText = 'UPDATED';
+
+    if (status === 'ongoing') {
+      statusEmoji = '🔴';
+      statusText = 'DOWN (CRITICAL)';
+    } else if (status === 'resolved') {
+      statusEmoji = '🟢';
+      statusText = 'RESOLVED (UP)';
+    }
+
+    const message = 
+      `🚨 *[Better Stack Alert]*\n\n` +
+      `🖥️ *Monitor:* ${monitorName}\n` +
+      `📈 *Status:* ${statusEmoji} ${statusText}\n` +
+      `❓ *Cause:* ${cause}\n` +
+      `🔗 *URL:* ${url || 'N/A'}\n` +
+      `🔔 *Event:* \`${event}\``;
+
+    // Send to Telegram Bot API
+    await axios.post(`https://api.telegram.org/bot${botToken}/sendMessage`, {
+      chat_id: chatId,
+      text: message,
+      parse_mode: 'Markdown'
+    });
+
+    console.log('[Better Stack Webhook] Successfully forwarded alert to Telegram');
+    return res.json({ success: true });
+  } catch (err) {
+    console.error('[Better Stack Webhook] Error sending message to Telegram:', err.message);
+    // Return 200 to Better Stack so it doesn't retry infinitely on transport failures, but log the error
+    return res.status(200).json({ success: false, error: err.message });
+  }
+});
+
 // Periodic Twitch Stream Status Polling
 async function pollTwitchStreamStatus() {
   const clientId = process.env.TWITCH_CLIENT_ID;