florian.wildeandClaude Opus 5
9e770a99b1
SMTP mit STARTTLS fuer Microsoft 365, Webhook mit HMAC-Signatur, taegliche oder woechentliche Zusammenfassung, Versandprotokoll und Testversand. Keine Doppelmeldungen dank Pruefung gegen das Protokoll. 134 Tests. Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com>
87 lines
3.1 KiB
TypeScript
87 lines
3.1 KiB
TypeScript
import { Cron } from "croner";
|
|
import "dotenv/config";
|
|
import { prisma } from "@/lib/db";
|
|
import { alertsAbgleichen, warnregelnSicherstellen } from "@/server/alerts/abgleich";
|
|
import { neueAlertsMelden, zusammenfassungSenden } from "@/server/notifications/versand";
|
|
|
|
/**
|
|
* Hintergrundprozess: wertet die Warnregeln regelmäßig aus, verschickt Benachrichtigungen für
|
|
* neue Warnungen und schickt die Zusammenfassung. Läuft als eigener Dienst neben der Web-Anwendung (#014).
|
|
*
|
|
* npm run worker
|
|
*/
|
|
|
|
const ZEITZONE = "Europe/Berlin";
|
|
const ZEITPLAN = process.env.WORKER_CRON ?? "0 * * * *"; // stündlich zur vollen Stunde
|
|
const ZUSAMMENFASSUNG_ZEITPLAN = process.env.ZUSAMMENFASSUNG_CRON ?? "0 7 * * *"; // täglich 07:00 Uhr
|
|
|
|
function protokoll(nachricht: string) {
|
|
console.log(`[${new Date().toISOString()}] ${nachricht}`);
|
|
}
|
|
|
|
async function durchlauf() {
|
|
try {
|
|
const ergebnis = await alertsAbgleichen();
|
|
protokoll(
|
|
`Warnregeln geprüft: ${ergebnis.geoeffnet.length} neu, ${ergebnis.erledigt.length} erledigt, ${ergebnis.unveraendert} unverändert.`,
|
|
);
|
|
|
|
if (ergebnis.geoeffnet.length > 0) {
|
|
const versand = await neueAlertsMelden(ergebnis.geoeffnet.map((alert) => alert.fingerprint));
|
|
protokoll(
|
|
`Benachrichtigungen: ${versand.gesendet} gesendet, ${versand.uebersprungen} übersprungen, ${versand.fehlgeschlagen} fehlgeschlagen.`,
|
|
);
|
|
}
|
|
} catch (fehler) {
|
|
console.error("Auswertung fehlgeschlagen:", fehler);
|
|
}
|
|
}
|
|
|
|
/** Zeitraum der Zusammenfassung aus den Einstellungen (täglich, wöchentlich oder aus). */
|
|
async function zusammenfassungEinstellung(): Promise<"taeglich" | "woechentlich" | "aus"> {
|
|
const eintrag = await prisma.einstellung.findUnique({ where: { schluessel: "zusammenfassung" } });
|
|
const wert = (eintrag?.wert as { zeitraum?: string } | null)?.zeitraum;
|
|
return wert === "taeglich" || wert === "woechentlich" ? wert : "aus";
|
|
}
|
|
|
|
async function zusammenfassung() {
|
|
try {
|
|
const zeitraum = await zusammenfassungEinstellung();
|
|
if (zeitraum === "aus") return;
|
|
// Wöchentlich nur montags verschicken.
|
|
if (zeitraum === "woechentlich" && new Date().getDay() !== 1) return;
|
|
|
|
const ergebnis = await zusammenfassungSenden(zeitraum);
|
|
protokoll(
|
|
`Zusammenfassung (${zeitraum}): ${ergebnis.gesendet} gesendet, ${ergebnis.fehlgeschlagen} fehlgeschlagen.`,
|
|
);
|
|
} catch (fehler) {
|
|
console.error("Zusammenfassung fehlgeschlagen:", fehler);
|
|
}
|
|
}
|
|
|
|
async function start() {
|
|
await warnregelnSicherstellen();
|
|
protokoll(
|
|
`Worker gestartet. Auswertung "${ZEITPLAN}", Zusammenfassung "${ZUSAMMENFASSUNG_ZEITPLAN}" (${ZEITZONE}).`,
|
|
);
|
|
|
|
// Einmal sofort, damit nach einem Neustart nicht bis zur nächsten vollen Stunde gewartet wird.
|
|
await durchlauf();
|
|
|
|
const aufgaben = [
|
|
new Cron(ZEITPLAN, { timezone: ZEITZONE }, durchlauf),
|
|
new Cron(ZUSAMMENFASSUNG_ZEITPLAN, { timezone: ZEITZONE }, zusammenfassung),
|
|
];
|
|
|
|
for (const signal of ["SIGINT", "SIGTERM"] as const) {
|
|
process.on(signal, () => {
|
|
protokoll("Worker wird beendet.");
|
|
for (const aufgabe of aufgaben) aufgabe.stop();
|
|
process.exit(0);
|
|
});
|
|
}
|
|
}
|
|
|
|
void start();
|