Phase 7: Benachrichtigungen und Termine

Terminkalender mit Serienterminen, Selbstanmeldung, Warteliste und
Anwesenheitsliste. Vier Zustellwege hinter Schnittstellen: echtes SMTP,
ntfy (selbst gehostet), Telegram und Web-Push. Kalenderabonnement als
ICS-Feed, digitaler Dienstausweis mit signiertem QR und Pruefseite.

Niemand wird ungefragt benachrichtigt: ein neuer Zustellweg hat eine leere
Ereignisliste, und der Seed legt bewusst keine an. Was das Netz der Wehr
verlaesst, bekommt nur die Kurzfassung ohne Namen und Details.

Kein CalDAV (Lesen genuegt, ICS kann jeder Kalender) und kein WhatsApp
(Verarbeitung ueber Meta, Kosten je Konversation, Telefonbuchabgleich) --
beides im README begruendet.

56 neue Unit-Tests, 17 neue E2E-Tests, Version 0.8.0.

Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com>

src/worker/index.ts

@@ -16,6 +16,11 @@ import { protokollErzeugen } from "@/lib/wartung/protokoll-erzeugen";
 import { einsatzberichtErzeugen } from "@/lib/einsatz/bericht-erzeugen";
 import { atemschutzprotokollErzeugen } from "@/lib/atemschutz/protokoll-erzeugen";
 import { erinnerungenSenden, mangelBenachrichtigung, terminePlanen } from "@/worker/wartung";
+import {
+  benachrichtigungenAufraeumen,
+  morgenlauf,
+  zustellen,
+} from "@/worker/benachrichtigung";
 
 /**
  * Hintergrundprozess.
@@ -133,11 +138,44 @@ async function atemschutzprotokollErzeugenAuftrag(auftrag: Job<AuftragsDaten>) {
   return { erzeugt: ergebnis.neu, dateiId: ergebnis.dateiId };
 }
 
+/**
+ * Der Zustelllauf.
+ *
+ * Läuft jede Minute und ist deshalb bewusst wortkarg: er meldet sich nur,
+ * wenn er etwas getan hat. Ein Worker, der 1440-mal am Tag „nichts zu tun"
+ * ins Protokoll schreibt, macht das Protokoll unlesbar.
+ */
+async function benachrichtigungZustellen(auftrag: Job<AuftragsDaten>) {
+  const ergebnis = await zustellen(auftrag.data.organisationId);
+  if (ergebnis.gesendet + ergebnis.aufgegeben > 0) {
+    protokoll(
+      `Benachrichtigungen: ${ergebnis.gesendet} zugestellt, ${ergebnis.aufgegeben} aufgegeben`,
+    );
+  }
+  return ergebnis;
+}
+
+/** Der Morgenlauf: Terminerinnerungen, ablaufende Qualifikationen, Zustellung. */
+async function benachrichtigungErinnern(auftrag: Job<AuftragsDaten>) {
+  const ergebnis = await morgenlauf(auftrag.data.organisationId);
+  protokoll(
+    `Morgenlauf: ${ergebnis.termine.termine} Termine, ` +
+      `${ergebnis.qualifikationen.qualifikationen} Qualifikationen, ` +
+      `${ergebnis.zugestellt.gesendet} Nachrichten zugestellt`,
+  );
+  return ergebnis;
+}
+
 async function aufbewahrungPruefen(auftrag: Job<AuftragsDaten>): Promise<{ entfernt: number }> {
   protokoll(`Aufbewahrungsfristen prüfen für Organisation ${auftrag.data.organisationId}`);
+
+  // Seit Phase 7: zugestellte Benachrichtigungen nach ihrer Frist abräumen.
+  // Fehlgeschlagene bleiben — sie zeigen einen kaputten Kanal an.
+  const benachrichtigungen = await benachrichtigungenAufraeumen(auftrag.data.organisationId);
+
   // Ab Phase 8: Audit-Log exportieren und danach abräumen,
   // ausgetretene Mitglieder nach PERSON_ANONYMISIERUNG_TAGE anonymisieren.
-  return { entfernt: 0 };
+  return { entfernt: benachrichtigungen.entfernt };
 }
 
 const bearbeiter: Record<string, (auftrag: Job<AuftragsDaten>) => Promise<unknown>> = {
@@ -146,6 +184,8 @@ const bearbeiter: Record<string, (auftrag: Job<AuftragsDaten>) => Promise<unknow
   [AUFTRAG.PDF_ERZEUGEN]: pdfErzeugen,
   [AUFTRAG.EINSATZBERICHT_ERZEUGEN]: einsatzberichtErzeugenAuftrag,
   [AUFTRAG.ATEMSCHUTZPROTOKOLL_ERZEUGEN]: atemschutzprotokollErzeugenAuftrag,
+  [AUFTRAG.BENACHRICHTIGUNG_ZUSTELLEN]: benachrichtigungZustellen,
+  [AUFTRAG.BENACHRICHTIGUNG_ERINNERN]: benachrichtigungErinnern,
   [AUFTRAG.AUFBEWAHRUNG_PRUEFEN]: aufbewahrungPruefen,
 };
 
@@ -174,6 +214,18 @@ async function zeitplaeneEinrichten(): Promise<number> {
       { organisationId: organisation.id },
       env.WARTUNG_ERINNERUNG_LAUF,
     );
+    // Jede Minute. Eine Absage am Dienstagabend muss ankommen, solange sie
+    // noch etwas nützt — nicht am nächsten Morgen.
+    await beauftrageWiederkehrend(
+      AUFTRAG.BENACHRICHTIGUNG_ZUSTELLEN,
+      { organisationId: organisation.id },
+      "* * * * *",
+    );
+    await beauftrageWiederkehrend(
+      AUFTRAG.BENACHRICHTIGUNG_ERINNERN,
+      { organisationId: organisation.id },
+      env.BENACHRICHTIGUNG_LAUF,
+    );
   }
 
   return organisationen.length;