Benachrichtigungen: ntfy ersetzt durch Discord-Webhooks
User-Wunsch: Discord statt ntfy. notify.ts sendet jetzt einen JSON-Webhook-POST
({username, content} mit fettem Titel + Nachricht, auf Discords 2000-Zeichen-
Limit gekappt) statt ntfy-Headern. Emoji-Status im Titel (OK/Fehler/Ziel-
flagge) ersetzt Priority/Tags. Settings-UI: Label/Placeholder/Hinweis auf
Discord-Webhook umgestellt (Servereinstellungen -> Integrationen -> Webhooks).
Hooks, Dedup und Guards unveraendert. Tests auf das JSON-Format angepasst
(inkl. Discord-204-Antwort und 2000-Zeichen-Cap).
This commit is contained in:
parent
4684144093
commit
41cf36890b
@ -10496,10 +10496,8 @@ export class DownloadManager extends EventEmitter {
|
|||||||
}
|
}
|
||||||
this.notifiedPackages.add(pkg.id);
|
this.notifiedPackages.add(pkg.id);
|
||||||
void sendNotification(url, {
|
void sendNotification(url, {
|
||||||
title: kind === "completed" ? "Paket fertig" : "Paket fehlgeschlagen",
|
title: kind === "completed" ? "✅ Paket fertig" : "❌ Paket fehlgeschlagen",
|
||||||
message: `${pkg.name}\n${detail}`,
|
message: `${pkg.name}\n${detail}`
|
||||||
priority: kind === "failed" ? "high" : "default",
|
|
||||||
tags: kind === "completed" ? "white_check_mark" : "x"
|
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -12122,10 +12120,8 @@ export class DownloadManager extends EventEmitter {
|
|||||||
this.session.summaryText = `Summary: Dauer ${duration}s, Ø Speed ${humanSize(avgSpeed)}/s, Erfolg ${success}/${total}`;
|
this.session.summaryText = `Summary: Dauer ${duration}s, Ø Speed ${humanSize(avgSpeed)}/s, Erfolg ${success}/${total}`;
|
||||||
if (this.settings.notifyOnRunFinished && total > 0) {
|
if (this.settings.notifyOnRunFinished && total > 0) {
|
||||||
void sendNotification(this.settings.notifyUrl, {
|
void sendNotification(this.settings.notifyUrl, {
|
||||||
title: "Durchlauf beendet",
|
title: failed > 0 ? "⚠️ Durchlauf beendet" : "🏁 Durchlauf beendet",
|
||||||
message: `${success}/${total} erfolgreich, ${failed} fehlgeschlagen, ${cancelled} abgebrochen\nDauer ${duration}s, Durchschnitt ${humanSize(avgSpeed)}/s`,
|
message: `${success}/${total} erfolgreich, ${failed} fehlgeschlagen, ${cancelled} abgebrochen\nDauer ${duration}s, Durchschnitt ${humanSize(avgSpeed)}/s`
|
||||||
priority: failed > 0 ? "high" : "default",
|
|
||||||
tags: failed > 0 ? "warning" : "checkered_flag"
|
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
this.runItemIds.clear();
|
this.runItemIds.clear();
|
||||||
|
|||||||
@ -3,30 +3,24 @@ import { logger } from "./logger";
|
|||||||
export interface NotifyPayload {
|
export interface NotifyPayload {
|
||||||
title: string;
|
title: string;
|
||||||
message: string;
|
message: string;
|
||||||
priority?: "default" | "high";
|
|
||||||
tags?: string;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
const NOTIFY_TIMEOUT_MS = 5000;
|
const NOTIFY_TIMEOUT_MS = 5000;
|
||||||
|
const WEBHOOK_USERNAME = "Real-Debrid Downloader";
|
||||||
|
|
||||||
export function isNotifyUrlValid(url: string): boolean {
|
export function isNotifyUrlValid(url: string): boolean {
|
||||||
return /^https?:\/\/\S+$/i.test(String(url || "").trim());
|
return /^https?:\/\/\S+$/i.test(String(url || "").trim());
|
||||||
}
|
}
|
||||||
|
|
||||||
export function buildNotifyRequest(url: string, payload: NotifyPayload): { url: string; init: RequestInit } {
|
export function buildNotifyRequest(url: string, payload: NotifyPayload): { url: string; init: RequestInit } {
|
||||||
const headers: Record<string, string> = {
|
const content = `**${payload.title}**\n${payload.message}`.slice(0, 2000);
|
||||||
"Title": payload.title,
|
|
||||||
"Content-Type": "text/plain; charset=utf-8"
|
|
||||||
};
|
|
||||||
if (payload.priority && payload.priority !== "default") {
|
|
||||||
headers["Priority"] = payload.priority;
|
|
||||||
}
|
|
||||||
if (payload.tags) {
|
|
||||||
headers["Tags"] = payload.tags;
|
|
||||||
}
|
|
||||||
return {
|
return {
|
||||||
url: String(url || "").trim(),
|
url: String(url || "").trim(),
|
||||||
init: { method: "POST", headers, body: payload.message }
|
init: {
|
||||||
|
method: "POST",
|
||||||
|
headers: { "Content-Type": "application/json" },
|
||||||
|
body: JSON.stringify({ username: WEBHOOK_USERNAME, content })
|
||||||
|
}
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -4957,9 +4957,9 @@ export function App(): ReactElement {
|
|||||||
<label className="toggle-line"><input type="checkbox" checked={settingsDraft.minimizeToTray} onChange={(e) => setBool("minimizeToTray", e.target.checked)} /> In System Tray minimieren</label>
|
<label className="toggle-line"><input type="checkbox" checked={settingsDraft.minimizeToTray} onChange={(e) => setBool("minimizeToTray", e.target.checked)} /> In System Tray minimieren</label>
|
||||||
<label className="toggle-line"><input type="checkbox" checked={settingsDraft.confirmDeleteSelection} onChange={(e) => setBool("confirmDeleteSelection", e.target.checked)} /> Vor dem Löschen bestätigen</label>
|
<label className="toggle-line"><input type="checkbox" checked={settingsDraft.confirmDeleteSelection} onChange={(e) => setBool("confirmDeleteSelection", e.target.checked)} /> Vor dem Löschen bestätigen</label>
|
||||||
<label className="toggle-line"><input type="checkbox" checked={settingsDraft.backupIncludeDownloads} onChange={(e) => setBool("backupIncludeDownloads", e.target.checked)} /> Download-Liste in Sicherung mitsichern (Standard: nur Einstellungen)</label>
|
<label className="toggle-line"><input type="checkbox" checked={settingsDraft.backupIncludeDownloads} onChange={(e) => setBool("backupIncludeDownloads", e.target.checked)} /> Download-Liste in Sicherung mitsichern (Standard: nur Einstellungen)</label>
|
||||||
<label>Benachrichtigungs-URL (ntfy/Webhook)</label>
|
<label>Webhook-URL (Discord)</label>
|
||||||
<input value={settingsDraft.notifyUrl} placeholder="https://ntfy.sh/mein-topic" onChange={(e) => setText("notifyUrl", e.target.value)} />
|
<input value={settingsDraft.notifyUrl} placeholder="https://discord.com/api/webhooks/..." onChange={(e) => setText("notifyUrl", e.target.value)} />
|
||||||
<div className="hint">POST an diese URL bei den unten gewählten Ereignissen. Mit der ntfy-App aufs Handy: Topic-URL eintragen, Topic in der App abonnieren — kein Account nötig.</div>
|
<div className="hint">In Discord: Servereinstellungen → Integrationen → Webhooks → Neuer Webhook → URL kopieren und hier eintragen. Die gewählten Ereignisse landen als Nachricht im Kanal.</div>
|
||||||
<label className="toggle-line"><input type="checkbox" checked={settingsDraft.notifyOnPackageCompleted} onChange={(e) => setBool("notifyOnPackageCompleted", e.target.checked)} /> Benachrichtigen wenn ein Paket fertig ist</label>
|
<label className="toggle-line"><input type="checkbox" checked={settingsDraft.notifyOnPackageCompleted} onChange={(e) => setBool("notifyOnPackageCompleted", e.target.checked)} /> Benachrichtigen wenn ein Paket fertig ist</label>
|
||||||
<label className="toggle-line"><input type="checkbox" checked={settingsDraft.notifyOnPackageFailed} onChange={(e) => setBool("notifyOnPackageFailed", e.target.checked)} /> Benachrichtigen wenn ein Paket fehlschlägt</label>
|
<label className="toggle-line"><input type="checkbox" checked={settingsDraft.notifyOnPackageFailed} onChange={(e) => setBool("notifyOnPackageFailed", e.target.checked)} /> Benachrichtigen wenn ein Paket fehlschlägt</label>
|
||||||
<label className="toggle-line"><input type="checkbox" checked={settingsDraft.notifyOnRunFinished} onChange={(e) => setBool("notifyOnRunFinished", e.target.checked)} /> Benachrichtigen wenn der Durchlauf beendet ist</label>
|
<label className="toggle-line"><input type="checkbox" checked={settingsDraft.notifyOnRunFinished} onChange={(e) => setBool("notifyOnRunFinished", e.target.checked)} /> Benachrichtigen wenn der Durchlauf beendet ist</label>
|
||||||
|
|||||||
@ -3,46 +3,48 @@ import { buildNotifyRequest, isNotifyUrlValid, sendNotification } from "../src/m
|
|||||||
|
|
||||||
describe("isNotifyUrlValid", () => {
|
describe("isNotifyUrlValid", () => {
|
||||||
it("accepts http/https URLs", () => {
|
it("accepts http/https URLs", () => {
|
||||||
expect(isNotifyUrlValid("https://ntfy.sh/mein-topic")).toBe(true);
|
expect(isNotifyUrlValid("https://discord.com/api/webhooks/123/abc")).toBe(true);
|
||||||
expect(isNotifyUrlValid("http://192.168.1.10:8080/hook")).toBe(true);
|
expect(isNotifyUrlValid("http://192.168.1.10:8080/hook")).toBe(true);
|
||||||
expect(isNotifyUrlValid(" https://ntfy.sh/topic ")).toBe(true);
|
expect(isNotifyUrlValid(" https://discord.com/api/webhooks/123/abc ")).toBe(true);
|
||||||
});
|
});
|
||||||
it("rejects empty and non-http values", () => {
|
it("rejects empty and non-http values", () => {
|
||||||
expect(isNotifyUrlValid("")).toBe(false);
|
expect(isNotifyUrlValid("")).toBe(false);
|
||||||
expect(isNotifyUrlValid("ntfy.sh/topic")).toBe(false);
|
expect(isNotifyUrlValid("discord.com/api/webhooks/123/abc")).toBe(false);
|
||||||
expect(isNotifyUrlValid("ftp://x")).toBe(false);
|
expect(isNotifyUrlValid("ftp://x")).toBe(false);
|
||||||
expect(isNotifyUrlValid("https:// mit leerzeichen")).toBe(false);
|
expect(isNotifyUrlValid("https:// mit leerzeichen")).toBe(false);
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
describe("buildNotifyRequest", () => {
|
describe("buildNotifyRequest", () => {
|
||||||
it("builds an ntfy-style POST with title/priority/tags headers and message body", () => {
|
it("builds a Discord-compatible JSON webhook POST (bold title + message as content)", () => {
|
||||||
const req = buildNotifyRequest(" https://ntfy.sh/topic ", { title: "Paket fertig", message: "Show.S01\n5 Datei(en)", priority: "high", tags: "x" });
|
const req = buildNotifyRequest(" https://discord.com/api/webhooks/123/abc ", { title: "✅ Paket fertig", message: "Show.S01\n5 Datei(en)" });
|
||||||
expect(req.url).toBe("https://ntfy.sh/topic");
|
expect(req.url).toBe("https://discord.com/api/webhooks/123/abc");
|
||||||
expect(req.init.method).toBe("POST");
|
expect(req.init.method).toBe("POST");
|
||||||
expect(req.init.body).toBe("Show.S01\n5 Datei(en)");
|
expect(req.init.headers).toMatchObject({ "Content-Type": "application/json" });
|
||||||
expect(req.init.headers).toMatchObject({ Title: "Paket fertig", Priority: "high", Tags: "x" });
|
const body = JSON.parse(String(req.init.body));
|
||||||
|
expect(body.content).toBe("**✅ Paket fertig**\nShow.S01\n5 Datei(en)");
|
||||||
|
expect(body.username).toBe("Real-Debrid Downloader");
|
||||||
});
|
});
|
||||||
it("omits default priority and empty tags", () => {
|
it("caps the content at Discord's 2000-char limit", () => {
|
||||||
const req = buildNotifyRequest("https://ntfy.sh/topic", { title: "T", message: "M", priority: "default" });
|
const req = buildNotifyRequest("https://discord.com/api/webhooks/123/abc", { title: "T", message: "x".repeat(3000) });
|
||||||
expect(req.init.headers).not.toHaveProperty("Priority");
|
const body = JSON.parse(String(req.init.body));
|
||||||
expect(req.init.headers).not.toHaveProperty("Tags");
|
expect(body.content.length).toBe(2000);
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
describe("sendNotification", () => {
|
describe("sendNotification", () => {
|
||||||
it("returns true on HTTP ok", async () => {
|
it("returns true on HTTP ok (Discord answers 204 No Content)", async () => {
|
||||||
const fetchFn = vi.fn().mockResolvedValue(new Response("", { status: 200 }));
|
const fetchFn = vi.fn().mockResolvedValue(new Response(null, { status: 204 }));
|
||||||
await expect(sendNotification("https://ntfy.sh/topic", { title: "T", message: "M" }, fetchFn)).resolves.toBe(true);
|
await expect(sendNotification("https://discord.com/api/webhooks/123/abc", { title: "T", message: "M" }, fetchFn)).resolves.toBe(true);
|
||||||
expect(fetchFn).toHaveBeenCalledTimes(1);
|
expect(fetchFn).toHaveBeenCalledTimes(1);
|
||||||
});
|
});
|
||||||
it("returns false on HTTP error without throwing", async () => {
|
it("returns false on HTTP error without throwing", async () => {
|
||||||
const fetchFn = vi.fn().mockResolvedValue(new Response("", { status: 500 }));
|
const fetchFn = vi.fn().mockResolvedValue(new Response("", { status: 500 }));
|
||||||
await expect(sendNotification("https://ntfy.sh/topic", { title: "T", message: "M" }, fetchFn)).resolves.toBe(false);
|
await expect(sendNotification("https://discord.com/api/webhooks/123/abc", { title: "T", message: "M" }, fetchFn)).resolves.toBe(false);
|
||||||
});
|
});
|
||||||
it("returns false on network error without throwing", async () => {
|
it("returns false on network error without throwing", async () => {
|
||||||
const fetchFn = vi.fn().mockRejectedValue(new Error("offline"));
|
const fetchFn = vi.fn().mockRejectedValue(new Error("offline"));
|
||||||
await expect(sendNotification("https://ntfy.sh/topic", { title: "T", message: "M" }, fetchFn)).resolves.toBe(false);
|
await expect(sendNotification("https://discord.com/api/webhooks/123/abc", { title: "T", message: "M" }, fetchFn)).resolves.toBe(false);
|
||||||
});
|
});
|
||||||
it("does not call fetch for an invalid URL", async () => {
|
it("does not call fetch for an invalid URL", async () => {
|
||||||
const fetchFn = vi.fn();
|
const fetchFn = vi.fn();
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user