add: new notifiers and ui fixes

src/features/notifications/dispatch.ts

@@ -7,7 +7,6 @@ import {db} from "@/db";
 import {notificationLog} from "@/db/schema/11_notification-log";
 import {NotificationChannel} from "@/db/schema/09_notification-channel";
 import {Json} from "drizzle-zod";
-import {AlertPolicy} from "@/db/schema/10_alert-policy";
 
 export async function dispatchNotification(
     payload: EventPayload,

src/features/notifications/providers/discord.ts

@@ -0,0 +1,48 @@
+import type {EventPayload, DispatchResult} from '../types';
+
+export async function sendDiscord(
+    config: { discordWebhook: string },
+    payload: EventPayload
+): Promise<DispatchResult> {
+    const {discordWebhook: webhookUrl} = config;
+
+    const embeds = [
+        {
+            title: `[${payload.level.toUpperCase()}] ${payload.title}`,
+            description: payload.message,
+            color: payload.level === 'critical' ? 15158332 : payload.level === 'warning' ? 16776960 : 3447003,
+            fields: payload.data ? [
+                {
+                    name: 'Data',
+                    value: `
+                    ${JSON.stringify(payload.data, null, 2).substring(0, 1000)}
+                    `,
+                    inline: false
+                }
+            ] : [],
+            timestamp: new Date().toISOString(),
+        }
+    ];
+
+    const body = {
+        embeds,
+    };
+
+    const res = await fetch(webhookUrl, {
+        method: 'POST',
+        body: JSON.stringify(body),
+        headers: {'Content-Type': 'application/json'},
+    });
+
+    if (!res.ok) {
+        const err = await res.text();
+        throw new Error(`Discord error: ${res.status} ${err}`);
+    }
+
+    return {
+        success: true,
+        provider: 'discord',
+        message: 'Sent to Discord',
+        response: res.statusText,
+    };
+}

src/features/notifications/providers/gotify.ts

@@ -0,0 +1,34 @@
+import type {EventPayload, DispatchResult} from '../types';
+
+export async function sendGotify(
+    config: { gotifyServerUrl: string; gotifyAppToken: string },
+    payload: EventPayload
+): Promise<DispatchResult> {
+    const {gotifyServerUrl, gotifyAppToken} = config;
+
+    const baseUrl = gotifyServerUrl.replace(/\/$/, "");
+
+    const body = {
+        title: `[${payload.level.toUpperCase()}] ${payload.title}`,
+        message: `${payload.message}\n\n${payload.data ? `Data:\n${JSON.stringify(payload.data, null, 2)}` : ''}`,
+        priority: payload.level === 'critical' ? 8 : payload.level === 'warning' ? 5 : 2,
+    };
+
+    const res = await fetch(`${baseUrl}/message?token=${gotifyAppToken}`, {
+        method: 'POST',
+        body: JSON.stringify(body),
+        headers: {'Content-Type': 'application/json'},
+    });
+
+    if (!res.ok) {
+        const err = await res.text();
+        throw new Error(`Gotify error: ${res.status} ${err}`);
+    }
+
+    return {
+        success: true,
+        provider: 'gotify',
+        message: 'Sent to Gotify',
+        response: await res.json(),
+    };
+}

src/features/notifications/providers/index.ts

@@ -2,6 +2,11 @@
 import type {ProviderKind, EventPayload, DispatchResult} from '../types';
 import {sendSlack} from './slack';
 import {sendSmtp} from './smtp';
+import {sendDiscord} from "@/features/notifications/providers/discord";
+import {sendTelegram} from "@/features/notifications/providers/telegram";
+import {sendGotify} from "@/features/notifications/providers/gotify";
+import {sendNtfy} from "@/features/notifications/providers/ntfy";
+import {sendWebhook} from "@/features/notifications/providers/webhook";
 
 const handlers: Record<
     ProviderKind,
@@ -9,6 +14,11 @@ const handlers: Record<
 > = {
     slack: sendSlack,
     smtp: sendSmtp,
+    discord: sendDiscord,
+    telegram: sendTelegram,
+    gotify: sendGotify,
+    ntfy: sendNtfy,
+    webhook: sendWebhook
 };
 
 export async function dispatchViaProvider(

src/features/notifications/providers/ntfy.ts

@@ -0,0 +1,44 @@
+import type {EventPayload, DispatchResult} from '../types';
+
+export async function sendNtfy(
+    config: { ntfyServerUrl?: string; ntfyTopic: string; ntfyToken?: string },
+    payload: EventPayload
+): Promise<DispatchResult> {
+    const {ntfyServerUrl, ntfyTopic, ntfyToken} = config;
+
+    const baseUrl = (ntfyServerUrl || "https://ntfy.sh").replace(/\/$/, "");
+
+    const body = {
+        topic: ntfyTopic,
+        title: payload.title,
+        message: payload.message + (payload.data ? `\n\nData:\n${JSON.stringify(payload.data, null, 2)}` : ''),
+        priority: 1,
+        tags: [payload.level === 'critical' ? 'rotating_light' : payload.level === 'warning' ? 'warning' : 'information_source'],
+    };
+
+    const headers: Record<string, string> = {
+        'Content-Type': 'application/json',
+    };
+
+    if (ntfyToken) {
+        headers['Authorization'] = `Bearer ${ntfyToken}`;
+    }
+
+    const res = await fetch(`${baseUrl}`, {
+        method: 'POST',
+        body: JSON.stringify(body),
+        headers: headers,
+    });
+
+    if (!res.ok) {
+        const err = await res.text();
+        throw new Error(`ntfy error: ${res.status} ${err}`);
+    }
+
+    return {
+        success: true,
+        provider: 'ntfy',
+        message: 'Sent to ntfy',
+        response: await res.json(),
+    };
+}

src/features/notifications/providers/telegram.ts

@@ -0,0 +1,49 @@
+import type {EventPayload, DispatchResult} from '../types';
+
+export async function sendTelegram(
+    config: { telegramBotToken: string; telegramChatId: string },
+    payload: EventPayload
+): Promise<DispatchResult> {
+    const {telegramBotToken, telegramChatId} = config;
+
+    // Helper to escape HTML characters
+    const escapeHtml = (unsafe: string) => {
+        return unsafe
+            .replace(/&/g, "&amp;")
+            .replace(/</g, "&lt;")
+            .replace(/>/g, "&gt;")
+            .replace(/"/g, "&quot;")
+            .replace(/'/g, "&#039;");
+    };
+
+    const title = escapeHtml(payload.title);
+    const message = escapeHtml(payload.message);
+    const level = escapeHtml(payload.level.toUpperCase());
+    const dataString = payload.data ? escapeHtml(JSON.stringify(payload.data, null, 2).substring(0, 1000)) : '';
+
+    const text = `<b>${title}</b>\n\n${message}\n\nLevel: <code>${level}</code>${payload.data ? `\n\nData:\n<pre>${dataString}</pre>` : ''}`;
+
+    const body = {
+        chat_id: telegramChatId,
+        text,
+        parse_mode: 'HTML',
+    };
+
+    const res = await fetch(`https://api.telegram.org/bot${telegramBotToken}/sendMessage`, {
+        method: 'POST',
+        body: JSON.stringify(body),
+        headers: {'Content-Type': 'application/json'},
+    });
+
+    if (!res.ok) {
+        const err = await res.text();
+        throw new Error(`Telegram error: ${res.status} ${err}`);
+    }
+
+    return {
+        success: true,
+        provider: 'telegram',
+        message: 'Sent to Telegram',
+        response: await res.text(),
+    };
+}

src/features/notifications/providers/webhook.ts

@@ -0,0 +1,35 @@
+import type {EventPayload, DispatchResult} from '../types';
+
+export async function sendWebhook(
+    config: { webhookUrl: string; webhookSecret?: string; webhookSecretHeader?: string },
+    payload: EventPayload
+): Promise<DispatchResult> {
+    const {webhookUrl, webhookSecret, webhookSecretHeader} = config;
+
+    const headers: Record<string, string> = {
+        'Content-Type': 'application/json',
+        'User-Agent': 'Portabase-Notifier/1.0'
+    };
+
+    if (webhookSecret) {
+        headers[webhookSecretHeader || 'X-Webhook-Secret'] = webhookSecret;
+    }
+
+    const res = await fetch(webhookUrl, {
+        method: 'POST',
+        body: JSON.stringify(payload),
+        headers: headers,
+    });
+
+    if (!res.ok) {
+        const err = await res.text();
+        throw new Error(`Webhook error: ${res.status} ${err}`);
+    }
+
+    return {
+        success: true,
+        provider: 'webhook',
+        message: 'Sent to Webhook',
+        response: await res.text(),
+    };
+}

src/features/notifications/types.ts

@@ -1,4 +1,4 @@
-export type ProviderKind = 'slack' | 'smtp';
+export type ProviderKind = 'slack' | 'smtp' | 'discord' | 'telegram' | 'gotify' | 'ntfy' | 'webhook';
 
 export interface DispatchResult {
     success: boolean;