From 34a8b96dd3f8b9818058ff7ac5de40955e33c96a Mon Sep 17 00:00:00 2001 From: Harlekin Date: Wed, 2 Sep 2026 21:06:03 +0200 Subject: [PATCH] =?UTF-8?q?Phase=206=20abgeschlossen:=20Aktenchat,=20Kan?= =?UTF-8?q?=C3=A4le,=20Echtzeit,=20Benachrichtigungen?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Ein Ereignisstrom mit Themen (/api/stream), in dem der Dateistrom aus Phase 5 aufgegangen ist. Zwei Prüfungen: beim Verbinden, welche Themen der Nutzer abonnieren darf, und je Ereignis wird der Inhalt mit seinen Rechten geladen. Das zweite ist nicht nur Vorsicht — eine Umklassifizierung wirkt dadurch in einer offenen Verbindung sofort. In der pg_notify-Nutzlast steht nie ein Inhalt, nur Thema, Art und Kennung. Der Aktenchat sendet optimistisch mit clientseitiger UUIDv7, die zugleich Idempotenzschlüssel ist. Antworten, vier feste Reaktionen, Bearbeiten mit sichtbarem editedAt, Zurückziehen mit Platzhalter — Löschen gibt es nicht, und eine Regel in der Datenbank hält das fest. Eine zurückgezogene Nachricht kommt ohne Text an, nicht ausgeblendet. Aktenzeichen im Text werden zu Vorschaukarten, serverseitig aufgelöst. Eine Akte, die der Leser nicht sehen darf, sieht darin genauso aus wie eine, die es gar nicht gibt. "Als Vermerk übernehmen" steht sichtbar an jeder Nachricht. Der Vermerk gehört dem Verfasser, nicht dem Übernehmenden; ein Systemeintrag nennt den Ursprung, damit der Wortlaut später nicht für die Akte geschrieben wirkt. Bei den Discord-Benachrichtigungen entscheidet die Web-App, wer was erfährt, und der Worker liefert nur aus. Die Alternative hätte geheissen, die Sichtbarkeitsprüfung im Worker ein zweites Mal zu bauen. In meta steht ein Titel nur, wenn er hinaus darf — ab Stufe 3 keiner. Postausgang als Tabelle, angestossen über LISTEN, mit Takt als Sicherheitsnetz. Nebenbei riss das Budget der Fallakte erneut (122 kB). Drei Schritte zurück auf 119,6: Chattexte in eine eigene i18n-Datei, ein gemeinsames AddPanel statt viermal derselbe Aufklapp-Code, und eine eigene UUIDv7 statt des Pakets — die Sortierbarkeit, auf der die Nachlieferung beruht, steht damit im eigenen Code und hat Tests. Unterwegs habe ich NotifyMode und User.notifyMode ein zweites Mal angelegt, obwohl es beides seit dem Grundgerüst gibt. Die Migration schlug fehl und die Datenbank musste von Hand aufgeräumt werden; die Lehre steht in docs/13. 155 Tests im Web-Paket, 15 in der Datenbank, 7 im Worker, 32 e2e. Co-Authored-By: Claude Opus 5 --- .env.example | 2 + TASKS.md | 17 +- docs/13-entscheidungen.md | 98 ++++ .../migration.sql | 81 +++ packages/db/prisma/schema.prisma | 41 ++ pnpm-lock.yaml | 9 - web/app/(app)/chat/actions.ts | 128 +++++ .../(app)/dokumente/[documentNumber]/page.tsx | 6 + web/app/(app)/einstellungen/NotifyForm.tsx | 46 ++ web/app/(app)/einstellungen/actions.ts | 28 + web/app/(app)/einstellungen/page.tsx | 24 + .../(app)/faelle/[caseNumber]/CaseLinks.tsx | 102 ++-- .../faelle/[caseNumber]/EntryComposer.tsx | 2 +- .../faelle/[caseNumber]/Participants.tsx | 137 ++--- web/app/(app)/faelle/[caseNumber]/page.tsx | 47 ++ web/app/(app)/kanaele/NewChannelForm.tsx | 116 +++++ web/app/(app)/kanaele/[key]/page.tsx | 70 +++ web/app/(app)/kanaele/actions.ts | 40 ++ web/app/(app)/kanaele/page.tsx | 71 +++ web/app/(app)/layout.tsx | 2 + .../(app)/personalakten/[id]/Assignments.tsx | 107 ++-- web/app/(app)/personalakten/[id]/LinkCase.tsx | 101 +--- web/app/api/events/route.ts | 111 ---- web/app/api/stream/route.ts | 311 +++++++++++ web/components/AddPanel.tsx | 106 ++++ web/components/chat/Chat.tsx | 391 ++++++++++++++ web/components/chat/ChatLazy.tsx | 73 +++ web/components/chat/MessageBody.tsx | 74 +++ web/components/files/Attachments.tsx | 7 +- web/components/files/PhotoField.tsx | 7 +- web/components/files/useScanEvents.ts | 43 -- web/components/realtime/useStream.ts | 64 +++ web/components/sections/Sections.tsx | 4 + web/e2e/smoke.spec.ts | 2 + web/lib/access/chatFilter.ts | 29 ++ web/lib/audit.ts | 2 + web/lib/cases/service.ts | 23 +- web/lib/chat/load.ts | 69 +++ web/lib/chat/mentions.ts | 65 +++ web/lib/chat/preview.ts | 49 ++ web/lib/chat/service.ts | 487 ++++++++++++++++++ web/lib/chat/terms.ts | 13 + web/lib/chat/view.ts | 28 + web/lib/files/process.ts | 69 ++- web/lib/i18n/chat.ts | 64 +++ web/lib/i18n/common.ts | 6 + web/lib/i18n/de.ts | 21 +- web/lib/i18n/shell.ts | 15 + web/lib/notify/enqueue.ts | 124 +++++ web/lib/realtime/listener.ts | 31 +- web/lib/realtime/publish.ts | 56 +- web/lib/uuidv7.ts | 71 +++ web/package.json | 1 - web/tests/benachrichtigungen.test.ts | 175 +++++++ web/tests/chat.test.ts | 225 ++++++++ web/tests/erwaehnungen.test.ts | 44 ++ web/tests/uuidv7.test.ts | 47 ++ worker/src/env.ts | 6 + worker/src/index.ts | 43 ++ worker/src/notify.ts | 128 +++++ worker/tests/nachricht.test.ts | 42 ++ 61 files changed, 3883 insertions(+), 518 deletions(-) create mode 100644 packages/db/prisma/migrations/20260903090000_chat_und_echtzeit/migration.sql create mode 100644 web/app/(app)/chat/actions.ts create mode 100644 web/app/(app)/einstellungen/NotifyForm.tsx create mode 100644 web/app/(app)/einstellungen/actions.ts create mode 100644 web/app/(app)/einstellungen/page.tsx create mode 100644 web/app/(app)/kanaele/NewChannelForm.tsx create mode 100644 web/app/(app)/kanaele/[key]/page.tsx create mode 100644 web/app/(app)/kanaele/actions.ts create mode 100644 web/app/(app)/kanaele/page.tsx delete mode 100644 web/app/api/events/route.ts create mode 100644 web/app/api/stream/route.ts create mode 100644 web/components/AddPanel.tsx create mode 100644 web/components/chat/Chat.tsx create mode 100644 web/components/chat/ChatLazy.tsx create mode 100644 web/components/chat/MessageBody.tsx delete mode 100644 web/components/files/useScanEvents.ts create mode 100644 web/components/realtime/useStream.ts create mode 100644 web/lib/access/chatFilter.ts create mode 100644 web/lib/chat/load.ts create mode 100644 web/lib/chat/mentions.ts create mode 100644 web/lib/chat/preview.ts create mode 100644 web/lib/chat/service.ts create mode 100644 web/lib/chat/terms.ts create mode 100644 web/lib/chat/view.ts create mode 100644 web/lib/i18n/chat.ts create mode 100644 web/lib/notify/enqueue.ts create mode 100644 web/lib/uuidv7.ts create mode 100644 web/tests/benachrichtigungen.test.ts create mode 100644 web/tests/chat.test.ts create mode 100644 web/tests/erwaehnungen.test.ts create mode 100644 web/tests/uuidv7.test.ts create mode 100644 worker/src/notify.ts create mode 100644 worker/tests/nachricht.test.ts diff --git a/.env.example b/.env.example index 9c4ca07..6879553 100644 --- a/.env.example +++ b/.env.example @@ -37,6 +37,8 @@ DISCORD_GUILD_ID= # Kanal, in den der Worker Start, Verbindungsabbruch und fehlgeschlagenen # Voll-Abgleich meldet. Das ist die eigentliche Alarmierung. DISCORD_ADMIN_CHANNEL_ID= +# Takt des Postausgangs als Sicherheitsnetz; angestossen wird er ueber LISTEN. +WORKER_OUTBOX_MS=30000 # --- Notfallzugang ------------------------------------------------------------ # Eine oder zwei Discord-IDs, kommagetrennt. Diese Nutzer haben immer Stufe 5 diff --git a/TASKS.md b/TASKS.md index a9d75da..b15aa9e 100644 --- a/TASKS.md +++ b/TASKS.md @@ -104,14 +104,15 @@ Das ist der schwierigste Teil. Wenn er steht, ist der Rest Formularbau. ## Phase 6 — Chat und Echtzeit -- [ ] SSE-Endpunkt mit `LISTEN/NOTIFY`, Heartbeat, Reconnect mit `Last-Event-ID` -- [ ] Aktenchat mit Antworten, Reaktionen, Bearbeiten, Zurückziehen -- [ ] Optimistisches Senden mit Dedupe über Client-ID -- [ ] Aktenzeichen-Erkennung mit serverseitig aufgelöster Vorschaukarte -- [ ] Ungelesen-Markierung und Trennlinie -- [ ] Freie Kanäle mit eigener Mindeststufe -- [ ] „Als Vermerk übernehmen" -- [ ] Discord-Benachrichtigungen über den Worker, ohne Inhalte +- [x] SSE-Endpunkt mit `LISTEN/NOTIFY`, Heartbeat, Reconnect mit `Last-Event-ID` +- [x] Aktenchat mit Antworten, Reaktionen, Bearbeiten, Zurückziehen +- [x] Optimistisches Senden mit Dedupe über Client-ID +- [x] Aktenzeichen-Erkennung mit serverseitig aufgelöster Vorschaukarte +- [x] Ungelesen-Markierung und Trennlinie +- [x] Freie Kanäle mit eigener Mindeststufe +- [x] „Als Vermerk übernehmen" +- [x] Discord-Benachrichtigungen über den Worker, ohne Inhalte +- [x] Benachrichtigungseinstellung je Nutzer: alles / meine Fälle / Erwähnungen / aus ## Phase 7 — Suche diff --git a/docs/13-entscheidungen.md b/docs/13-entscheidungen.md index c34c81f..8502dcb 100644 --- a/docs/13-entscheidungen.md +++ b/docs/13-entscheidungen.md @@ -550,3 +550,101 @@ importieren den Bereich, den sie brauchen. Das brachte die grösste Route von 121 auf 118 kB und wächst nicht mehr mit jedem neuen Bereich mit. Der Zuschnitt der sechs Gruppen folgt der gemeinsamen Verwendung, nicht der Grösse: was zusammen gebraucht wird, liegt zusammen. + +## Chat und Echtzeit + +### Ein Strom, Themen darin + +`docs/06` nennt `GET /api/stream?topics=case:,notifications`. Gebaut wie beschrieben, mit +den Themen `case:`, `channel:` und `user:`. Der Ereignisstrom aus Phase 5 +(`/api/events`, nur Dateiprüfungen) ist darin aufgegangen. + +**Zwei Prüfungen, beide nötig.** Beim Verbinden wird gefiltert, welche der angefragten Themen +der Nutzer überhaupt abonnieren darf — wer ein fremdes nennt, bekommt es nicht und erfährt +auch nicht, ob es existiert. Und je Ereignis wird der Inhalt **mit den Rechten des Empfängers** +geladen. Das zweite ist nicht nur Vorsicht: eine Umklassifizierung mitten in einer offenen +Verbindung wirkt dadurch sofort, ohne dass jemand neu laden muss. + +In der `pg_notify`-Nutzlast steht deshalb nie ein Inhalt, nur Thema, Art und Kennung. Ein Text +darin wäre an jedem Filter vorbei. + +### Die Vorschaukarte ist der heikelste Ort im Chat + +Ein Aktenzeichen im Fliesstext wird zur Karte. Sie wird **serverseitig** aufgelöst, und eine +Akte, die der Leser nicht sehen darf, sieht darin genauso aus wie eine, die es gar nicht gibt. +Nie den Titel mitschicken und im Client ausblenden — das ist der Fehler, den ein Aktensystem +genau einmal macht. + +Dasselbe gilt für nachkommende Nachrichten: der Strom-Endpunkt löst die Karten je Empfänger +auf, nicht der Absender. + +### Nachrichten werden zurückgezogen, nicht gelöscht + +Der Chat ist ausdrücklich kein Aktenbestandteil, deshalb darf hier bearbeitet werden, ohne dass +eine Version entsteht. Eine Nachricht, auf die jemand geantwortet hat, darf trotzdem nicht +spurlos verschwinden: `withdrawnAt` setzt einen Platzhalter, und eine Regel in der Datenbank +verbietet `DELETE`. Autor, Zeitpunkt und Ort sind per Trigger unveränderlich. + +Eine zurückgezogene Nachricht kommt **ohne Text** in der Oberfläche an. Nicht ausgeblendet — +gar nicht erst geschickt. + +### Die Web-App entscheidet, der Worker liefert + +Bei den Discord-Benachrichtigungen war die naheliegende Bauart, dem Worker die Kennungen zu +geben und ihn nachschlagen zu lassen. Das hiesse, die Sichtbarkeitsprüfung ein zweites Mal zu +bauen — und sie zweimal richtig zu haben, dauerhaft. + +Stattdessen entscheidet die Web-App beim Einstellen in den Postausgang, wer die Meldung bekommt +(eine Zeile je Empfänger) und was darin stehen darf. In `meta` liegt ein Titel nur, wenn er +auch nach Discord darf; ab Stufe 3 liegt dort keiner. Der Worker setzt aus festen Bruchstücken +einen Satz zusammen und hat keine Entscheidung mehr zu treffen. + +Der Postausgang ist eine Tabelle, kein Aufruf: der Worker ist ein eigener Prozess und darf +gerade neu starten. Eine Zeile, die nicht rausging, bleibt liegen. Angestossen wird er über +`notification_queued`, der 30-Sekunden-Takt ist das Sicherheitsnetz — kein Einmal-Container, +siehe harte Regel 8. + +Die Empfängerprüfung ruft `visibleCaseWhere` je Kandidat auf, also eine Abfrage pro Person. +Bei zehn bis fünfzig Leuten ist das billiger als der Fehler, die Regel ein zweites Mal zu +schreiben und eine der beiden Fassungen später zu vergessen. + +### Eigene UUIDv7 statt Paket + +Das Paket `uuidv7` wog 2,6 kB im Bündel der Fallakte. Ersetzt durch `web/lib/uuidv7.ts`, rund +sechzig Zeilen, mit dem Zähler in `rand_a` für die Reihenfolge innerhalb einer Millisekunde. + +Der Grund ist nicht nur die Grösse: auf der **lexikografischen Sortierbarkeit** dieser +Kennungen beruhen zwei Dinge — die Nachlieferung verpasster Nachrichten (`id > seit`) und die +Reihenfolge im Chat ohne Sortierspalte. Diese Zusicherung steht jetzt ausdrücklich im eigenen +Code und hat Tests, statt in einer Abhängigkeit vorausgesetzt zu werden. + +## Das Bündelbudget der Fallakte + +Die Fallakte ist die dichteste Seite der Anwendung: Abschnitte, Verlauf, Beteiligte, +Verknüpfungen, Dokumente, Anhänge, Chat. Mit Phase 6 riss sie das Budget aus `docs/09` +(122 kB gegen 120 kB erlaubte) und wurde in drei Schritten darunter gebracht: + +| Schritt | Ersparnis | +|---|---| +| Chattexte aus `lib/i18n/cases.ts` in eine eigene Datei | ~0,5 kB | +| Gemeinsames `AddPanel` statt viermal derselbe Aufklapp-Code | ~1 kB | +| Eigene UUIDv7 statt Paket | ~2,6 kB | + +Sie liegt jetzt bei **119,6 kB**. Das ist knapp, und die Richtung stimmt nicht: jede weitere +Insel auf dieser Seite kostet wieder. Der nächste Schritt, wenn es eng wird, ist kein weiteres +Kürzen, sondern die Seite zu teilen — die Beteiligten, Verknüpfungen und Anhänge gehören +fachlich zusammen und könnten hinter einen Reiter. + +Der Chat wird bereits erst geladen, wenn er in Sichtweite kommt. Das zählt Next zwar weiter +zur ersten Ladung, spart aber wirklich etwas: wer nur die Akte liest, baut keine offene +Verbindung zum Ereignisstrom auf. + +## Beim Erweitern des Schemas zuerst nachsehen + +In dieser Phase wurden `NotifyMode` und `User.notifyMode` ein zweites Mal angelegt — es gab +beides schon seit dem Grundgerüst. Die Migration scheiterte, und die Datenbank stand halb +geändert da; das Aufräumen war von Hand nötig. + +Die Lehre steht hier, weil sie sich wiederholen wird: **vor jedem neuen Modell, Enum oder Feld +im Schema nachsehen, ob es das schon gibt.** Das Schema ist über achthundert Zeilen lang, und +der Teil, den man gerade nicht bearbeitet, ist der, den man vergisst. diff --git a/packages/db/prisma/migrations/20260903090000_chat_und_echtzeit/migration.sql b/packages/db/prisma/migrations/20260903090000_chat_und_echtzeit/migration.sql new file mode 100644 index 0000000..5bfe7d2 --- /dev/null +++ b/packages/db/prisma/migrations/20260903090000_chat_und_echtzeit/migration.sql @@ -0,0 +1,81 @@ +-- Phase 6: Chat und Echtzeit. + +-- =========================================================================== +-- 1. Erwähnungen an der Nachricht +-- +-- Beim Senden aufgelöst und gespeichert, nicht beim Lesen aus dem Text +-- geparst: der Worker braucht sie für die Benachrichtigungen, und er soll +-- den Text gar nicht erst sehen. +-- =========================================================================== + +ALTER TABLE "ChatMessage" + ADD COLUMN "mentions" TEXT[] NOT NULL DEFAULT ARRAY[]::TEXT[]; + +CREATE INDEX "ChatMessage_mentions_idx" ON "ChatMessage" USING GIN ("mentions"); + +-- =========================================================================== +-- 2. Chatnachrichten sind zurückziehbar, nicht löschbar +-- +-- Dieselbe Zusicherung wie beim Verlaufseintrag, eine Stufe schwächer: der +-- Chat ist ausdrücklich kein Aktenbestandteil, aber eine Nachricht, auf die +-- jemand geantwortet hat, darf nicht spurlos verschwinden. +-- =========================================================================== + +CREATE RULE chat_no_delete AS ON DELETE TO "ChatMessage" DO INSTEAD NOTHING; + +-- Autor, Zeitpunkt und Ort einer Nachricht sind unveränderlich. Wer etwas +-- anderes sagen will, zieht zurück und schreibt neu. +CREATE OR REPLACE FUNCTION chat_immutable_guard() RETURNS trigger AS $$ +BEGIN + IF NEW."authorId" IS DISTINCT FROM OLD."authorId" + OR NEW."createdAt" IS DISTINCT FROM OLD."createdAt" + OR NEW."caseId" IS DISTINCT FROM OLD."caseId" + OR NEW."channelId" IS DISTINCT FROM OLD."channelId" THEN + RAISE EXCEPTION 'authorId, createdAt und der Ort einer ChatMessage sind unveränderlich'; + END IF; + RETURN NEW; +END; +$$ LANGUAGE plpgsql; + +CREATE TRIGGER chat_immutable_guard_trg + BEFORE UPDATE ON "ChatMessage" + FOR EACH ROW EXECUTE FUNCTION chat_immutable_guard(); + +-- =========================================================================== +-- 3. Benachrichtigungen +-- =========================================================================== + +-- NotifyMode und User.notifyMode gibt es seit dem Grundgeruest, sie werden hier +-- nur benutzt. Siehe docs/06-chat-und-realtime.md. + +CREATE TABLE "NotificationOutbox" ( + "id" BIGSERIAL NOT NULL, + "kind" TEXT NOT NULL, + "caseId" TEXT, + "channelId" TEXT, + "recipientId" TEXT, + "actorId" TEXT NOT NULL, + "meta" JSONB, + "createdAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP, + "sentAt" TIMESTAMP(3), + "attempts" INTEGER NOT NULL DEFAULT 0, + "lastError" TEXT, + + CONSTRAINT "NotificationOutbox_pkey" PRIMARY KEY ("id") +); + +CREATE INDEX "NotificationOutbox_sentAt_createdAt_idx" + ON "NotificationOutbox"("sentAt", "createdAt"); +CREATE INDEX "NotificationOutbox_caseId_idx" ON "NotificationOutbox"("caseId"); + +-- Der Worker wartet nicht auf seinen Takt, wenn etwas anliegt. +CREATE OR REPLACE FUNCTION notify_outbox() RETURNS trigger AS $$ +BEGIN + PERFORM pg_notify('notification_queued', NEW."id"::text); + RETURN NULL; +END; +$$ LANGUAGE plpgsql; + +CREATE TRIGGER notification_outbox_notify + AFTER INSERT ON "NotificationOutbox" + FOR EACH ROW EXECUTE FUNCTION notify_outbox(); diff --git a/packages/db/prisma/schema.prisma b/packages/db/prisma/schema.prisma index 10960af..a611af7 100644 --- a/packages/db/prisma/schema.prisma +++ b/packages/db/prisma/schema.prisma @@ -41,10 +41,13 @@ model User { firstSeenAt DateTime @default(now()) lastSeenAt DateTime @default(now()) + /// Wie viel dieser Nutzer per Discord erfahren will. + /// Siehe docs/06-chat-und-realtime.md. notifyMode NotifyMode @default(OWN_CASES) roles UserRole[] sessions Session[] + personnelFiles PersonnelFile[] participations CaseParticipant[] assignments PersonnelAssignment[] @@ -55,9 +58,13 @@ model User { @@index([isActive, displayName]) } +/// Was ein Nutzer per Discord erfahren will. enum NotifyMode { + /// jede Aenderung in jeder Akte, die er sehen darf ALL + /// nur Akten, an denen er beteiligt ist oder die er beobachtet OWN_CASES + /// nur direkte Erwaehnungen MENTIONS OFF } @@ -720,6 +727,10 @@ model ChatMessage { withdrawnAt DateTime? /// Gesetzt, sobald die Nachricht als Vermerk uebernommen wurde. adoptedEntryId String? + /// Erwaehnte Nutzer, beim Senden aufgeloest. Steht hier und wird nicht beim + /// Lesen aus dem Text geparst, weil der Worker sie fuer die + /// Benachrichtigungen braucht, ohne den Text zu kennen. + mentions String[] @default([]) createdAt DateTime @default(now()) case Case? @relation(fields: [caseId], references: [id], onDelete: Cascade) @@ -732,6 +743,7 @@ model ChatMessage { @@index([channelId, createdAt(sort: Desc)]) @@index([authorId]) @@index([replyToId]) + @@index([mentions], type: Gin) } /// Kleiner fester Satz an Reaktionen, keine freie Emoji-Auswahl. @@ -766,6 +778,35 @@ model Watch { } +/// Was die Web-App dem Worker zum Verschicken uebergibt. +/// +/// Eine Tabelle statt eines direkten Aufrufs, weil der Worker ein eigener +/// Prozess ist und laufen oder auch gerade neu starten kann. Ein Eintrag, der +/// nicht rausging, bleibt liegen und wird beim naechsten Durchlauf abgeholt. +/// Kein Einmal-Container, siehe CLAUDE.md, harte Regel 8. +/// +/// **Hier steht nie ein Inhalt.** Nur Kennungen und die Art des Ereignisses; +/// den Text baut der Worker daraus, und Discord kennt unsere Klassifizierung +/// nicht. Siehe docs/06-chat-und-realtime.md. +model NotificationOutbox { + id BigInt @id @default(autoincrement()) + kind String // "entry.new", "chat.new", "chat.mention", "case.status" + caseId String? + channelId String? + /// Leer heisst: in den allgemeinen Kanal. Sonst als Direktnachricht. + recipientId String? + actorId String + /// Nur Kennungen und Zahlen, nie Text aus einer Akte. + meta Json? + createdAt DateTime @default(now()) + sentAt DateTime? + attempts Int @default(0) + lastError String? + + @@index([sentAt, createdAt]) + @@index([caseId]) +} + /// Lebenszeichen der Dienste, die nicht im Web-Container laufen. Der Worker /// schreibt hier seinen Gateway-Zustand hinein, damit /api/health ihn pruefen /// kann, ohne Discord zu befragen. Siehe docs/11-betrieb.md. diff --git a/pnpm-lock.yaml b/pnpm-lock.yaml index 5bab958..4d77974 100644 --- a/pnpm-lock.yaml +++ b/pnpm-lock.yaml @@ -106,9 +106,6 @@ importers: sharp: specifier: 0.34.4 version: 0.34.4 - uuidv7: - specifier: 1.0.2 - version: 1.0.2 zod: specifier: ^4.0.0 version: 4.5.4 @@ -3477,10 +3474,6 @@ packages: uri-js@4.4.1: resolution: {integrity: sha512-7rKUyy33Q1yc98pQ1DAmLtwX109F7TIfWlW1Ydo8Wl1ii1SeHieeh0HHfPeL2fMXK6z0s8ecKs9frCuLJvndBg==} - uuidv7@1.0.2: - resolution: {integrity: sha512-8JQkH4ooXnm1JCIhqTMbtmdnYEn6oKukBxHn1Ic9878jMkL7daTI7anTExfY18VRCX7tcdn5quzvCb6EWrR8PA==} - hasBin: true - valibot@1.4.2: resolution: {integrity: sha512-gjdCvJ6d3RyHAneqxMYMW9QMCwYMb3jpOO0IyHZV1bnRHFBHrX3VkIILt5XYR0WhwHiH7Mty8ovuPZ/O3gamrg==} peerDependencies: @@ -7090,8 +7083,6 @@ snapshots: dependencies: punycode: 2.3.1 - uuidv7@1.0.2: {} - valibot@1.4.2(typescript@5.9.3): optionalDependencies: typescript: 5.9.3 diff --git a/web/app/(app)/chat/actions.ts b/web/app/(app)/chat/actions.ts new file mode 100644 index 0000000..7fa3ec2 --- /dev/null +++ b/web/app/(app)/chat/actions.ts @@ -0,0 +1,128 @@ +'use server' + +import { revalidatePath } from 'next/cache' +import { z } from 'zod' +import { requireUser } from '@/lib/auth/current' +import { AccessError } from '@/lib/errors' +import { + adoptAsEntry, + editMessage, + markRead, + sendMessage, + toggleReaction, + withdrawMessage, +} from '@/lib/chat/service' +import { REACTIONS } from '@/lib/chat/terms' +import { de } from '@/lib/i18n/de' + +export type ActionResult = { ok: true } | { ok: false; error: string } + +function toMessage(error: unknown): string { + if (error instanceof AccessError) { + return de.actionErrors[error.code] ?? de.actionErrors.default! + } + console.error('[chat] unerwartet', error) + return de.actionErrors.default! +} + +const scope = z.union([ + z.object({ kind: z.literal('case'), caseNumber: z.string().min(1) }), + z.object({ kind: z.literal('channel'), key: z.string().min(1) }), +]) + +const sendSchema = z.object({ + id: z.string().min(1).max(64), + scope, + body: z.string().min(1).max(4000), + replyToId: z.string().max(64).nullish(), +}) + +export async function sendMessageAction(input: unknown): Promise { + const user = await requireUser() + const parsed = sendSchema.safeParse(input) + if (!parsed.success) return { ok: false, error: de.actionErrors['message-empty']! } + + try { + await sendMessage(user.permissions, parsed.data) + return { ok: true } + } catch (error) { + return { ok: false, error: toMessage(error) } + } +} + +const editSchema = z.object({ id: z.string().min(1), body: z.string().min(1).max(4000) }) + +export async function editMessageAction(input: unknown): Promise { + const user = await requireUser() + const parsed = editSchema.safeParse(input) + if (!parsed.success) return { ok: false, error: de.actionErrors['message-empty']! } + + try { + await editMessage(user.permissions, parsed.data) + return { ok: true } + } catch (error) { + return { ok: false, error: toMessage(error) } + } +} + +const idSchema = z.object({ id: z.string().min(1) }) + +export async function withdrawMessageAction(input: unknown): Promise { + const user = await requireUser() + const parsed = idSchema.safeParse(input) + if (!parsed.success) return { ok: false, error: de.actionErrors.default! } + + try { + await withdrawMessage(user.permissions, parsed.data.id) + return { ok: true } + } catch (error) { + return { ok: false, error: toMessage(error) } + } +} + +const reactionSchema = z.object({ id: z.string().min(1), key: z.enum(REACTIONS) }) + +export async function toggleReactionAction(input: unknown): Promise { + const user = await requireUser() + const parsed = reactionSchema.safeParse(input) + if (!parsed.success) return { ok: false, error: de.actionErrors.default! } + + try { + await toggleReaction(user.permissions, parsed.data) + return { ok: true } + } catch (error) { + return { ok: false, error: toMessage(error) } + } +} + +/** + * „Als Vermerk übernehmen". Danach wird die Akte neu geladen: der Vermerk + * gehört in den Verlauf, und der steht auf derselben Seite. + */ +export async function adoptAsEntryAction(input: unknown): Promise { + const user = await requireUser() + const parsed = idSchema.safeParse(input) + if (!parsed.success) return { ok: false, error: de.actionErrors.default! } + + try { + await adoptAsEntry(user.permissions, parsed.data.id) + revalidatePath('/faelle', 'layout') + return { ok: true } + } catch (error) { + return { ok: false, error: toMessage(error) } + } +} + +const readSchema = z.object({ + scopeType: z.enum(['case', 'channel']), + scopeId: z.string().min(1), +}) + +export async function markReadAction(input: unknown): Promise { + const user = await requireUser() + const parsed = readSchema.safeParse(input) + if (!parsed.success) return { ok: false, error: de.actionErrors.default! } + + await markRead(user.permissions, parsed.data.scopeType, parsed.data.scopeId) + return { ok: true } +} diff --git a/web/app/(app)/dokumente/[documentNumber]/page.tsx b/web/app/(app)/dokumente/[documentNumber]/page.tsx index 3f4a802..8fceb71 100644 --- a/web/app/(app)/dokumente/[documentNumber]/page.tsx +++ b/web/app/(app)/dokumente/[documentNumber]/page.tsx @@ -47,6 +47,7 @@ async function Body({ title: string layout: string createdAt: Date + caseId: string | null } permissions: EffectivePermissions canEdit: boolean @@ -69,6 +70,7 @@ async function Body({ sections={sections} canEdit={canEdit} documentNumber={document.documentNumber} + topic={document.caseId ? `case:${document.caseId}` : `user:${permissions.userId}`} photoUrls={photoUrls} /> ) @@ -108,11 +110,13 @@ async function Body({ async function AttachmentBlock({ documentId, documentNumber, + topic, permissions, canUpload, }: { documentId: string documentNumber: string + topic: string permissions: EffectivePermissions canUpload: boolean }) { @@ -120,6 +124,7 @@ async function AttachmentBlock({ return ( diff --git a/web/app/(app)/einstellungen/NotifyForm.tsx b/web/app/(app)/einstellungen/NotifyForm.tsx new file mode 100644 index 0000000..521dcb7 --- /dev/null +++ b/web/app/(app)/einstellungen/NotifyForm.tsx @@ -0,0 +1,46 @@ +'use client' + +import { useActionState } from 'react' +import { notifyText } from '@/lib/i18n/shell' +import { saveNotifyModeAction, type ActionResult } from './actions' + +const MODES = ['ALL', 'OWN_CASES', 'MENTIONS', 'OFF'] as const + +export function NotifyForm({ current }: { current: string }) { + const [state, action, pending] = useActionState( + saveNotifyModeAction, + null, + ) + + return ( +
+
+ {notifyText.mode} +
+ {MODES.map((mode) => ( + + ))} +
+
+ +
+ + {state?.ok ? ( + {notifyText.saved} + ) : null} + {state && !state.ok ? ( + {state.error} + ) : null} +
+
+ ) +} diff --git a/web/app/(app)/einstellungen/actions.ts b/web/app/(app)/einstellungen/actions.ts new file mode 100644 index 0000000..4bac63a --- /dev/null +++ b/web/app/(app)/einstellungen/actions.ts @@ -0,0 +1,28 @@ +'use server' + +import { revalidatePath } from 'next/cache' +import { z } from 'zod' +import { db } from '@/lib/db' +import { requireUser } from '@/lib/auth/current' +import { de } from '@/lib/i18n/de' + +export type ActionResult = { ok: true } | { ok: false; error: string } + +const schema = z.object({ notifyMode: z.enum(['ALL', 'OWN_CASES', 'MENTIONS', 'OFF']) }) + +/** Jeder stellt nur für sich selbst ein — die Kennung kommt aus der Sitzung. */ +export async function saveNotifyModeAction( + _prev: ActionResult | null, + formData: FormData, +): Promise { + const user = await requireUser() + const parsed = schema.safeParse(Object.fromEntries(formData)) + if (!parsed.success) return { ok: false, error: de.actionErrors.default! } + + await db.user.update({ + where: { id: user.id }, + data: { notifyMode: parsed.data.notifyMode }, + }) + revalidatePath('/einstellungen') + return { ok: true } +} diff --git a/web/app/(app)/einstellungen/page.tsx b/web/app/(app)/einstellungen/page.tsx new file mode 100644 index 0000000..e2e3b00 --- /dev/null +++ b/web/app/(app)/einstellungen/page.tsx @@ -0,0 +1,24 @@ +import type { Metadata } from 'next' +import { db } from '@/lib/db' +import { requireUser } from '@/lib/auth/current' +import { de } from '@/lib/i18n/de' +import { NotifyForm } from './NotifyForm' + +export const metadata: Metadata = { title: de.notify.heading } +export const dynamic = 'force-dynamic' + +export default async function SettingsPage() { + const user = await requireUser() + const eigen = await db.user.findUniqueOrThrow({ + where: { id: user.id }, + select: { notifyMode: true }, + }) + + return ( +
+

{de.notify.heading}

+

{de.notify.intro}

+ +
+ ) +} diff --git a/web/app/(app)/faelle/[caseNumber]/CaseLinks.tsx b/web/app/(app)/faelle/[caseNumber]/CaseLinks.tsx index 41846e7..6df303b 100644 --- a/web/app/(app)/faelle/[caseNumber]/CaseLinks.tsx +++ b/web/app/(app)/faelle/[caseNumber]/CaseLinks.tsx @@ -3,10 +3,10 @@ import { useState, useTransition } from 'react' import Link from 'next/link' import { linkText } from '@/lib/i18n/cases' -import { commonText } from '@/lib/i18n/common' import { LINK_KINDS } from '@/lib/cases/terms' -import { linkCasesAction, unlinkCasesAction } from '../actions' +import { AddPanel, PanelSelect } from '@/components/AddPanel' import { classificationEdgeStyle } from '@/components/StampMark' +import { linkCasesAction, unlinkCasesAction } from '../actions' type Verknuepfung = { kind: string @@ -29,10 +29,9 @@ export function CaseLinks({ links: Verknuepfung[] canEdit: boolean }) { - const [open, setOpen] = useState(false) const [target, setTarget] = useState('') const [kind, setKind] = useState('RELATED') - const [error, setError] = useState(null) + const [fehler, setFehler] = useState(null) const [pending, startTransition] = useTransition() return ( @@ -65,12 +64,12 @@ export function CaseLinks({ disabled={pending} onClick={() => startTransition(async () => { - const result = await unlinkCasesAction({ + const ergebnis = await unlinkCasesAction({ fromCaseNumber: caseNumber, toCaseNumber: link.other.caseNumber, kind: link.kind, }) - if (!result.ok) setError(result.error) + if (!ergebnis.ok) setFehler(ergebnis.error) }) } className="font-condensed text-2xs text-text-dim" @@ -83,70 +82,37 @@ export function CaseLinks({ )} - {error ?

{error}

: null} + {fehler ?

{fehler}

: null} {canEdit ? ( - open ? ( -
- - setTarget(event.target.value)} - placeholder={linkText.target} - aria-label={linkText.target} - className="border border-line bg-raised px-2 py-1 font-mono text-2xs" - /> - - -
- ) : ( - - ) + { + const ergebnis = await linkCasesAction({ + fromCaseNumber: caseNumber, + toCaseNumber: target.trim(), + kind, + }) + if (ergebnis.ok) setTarget('') + return ergebnis + }} + > + + {LINK_KINDS.map((value) => ( + + ))} + + setTarget(event.target.value)} + placeholder={linkText.target} + aria-label={linkText.target} + className="border border-line bg-raised px-2 py-1 font-mono text-2xs" + /> + ) : null} ) diff --git a/web/app/(app)/faelle/[caseNumber]/EntryComposer.tsx b/web/app/(app)/faelle/[caseNumber]/EntryComposer.tsx index e2c8ff4..eb7158d 100644 --- a/web/app/(app)/faelle/[caseNumber]/EntryComposer.tsx +++ b/web/app/(app)/faelle/[caseNumber]/EntryComposer.tsx @@ -1,7 +1,7 @@ 'use client' import { useOptimistic, useRef, useState, useTransition } from 'react' -import { uuidv7 } from 'uuidv7' +import { uuidv7 } from '@/lib/uuidv7' import { caseText, entryText } from '@/lib/i18n/cases' import { addEntryAction } from '../actions' diff --git a/web/app/(app)/faelle/[caseNumber]/Participants.tsx b/web/app/(app)/faelle/[caseNumber]/Participants.tsx index c1a6e17..4ee4a6f 100644 --- a/web/app/(app)/faelle/[caseNumber]/Participants.tsx +++ b/web/app/(app)/faelle/[caseNumber]/Participants.tsx @@ -2,9 +2,10 @@ import { useState, useTransition } from 'react' import Link from 'next/link' -import { participantText } from '@/lib/i18n/cases' import { commonText } from '@/lib/i18n/common' +import { participantText } from '@/lib/i18n/cases' import { PARTICIPANT_ROLES } from '@/lib/cases/terms' +import { AddPanel, PanelSelect } from '@/components/AddPanel' import { addParticipantAction, removeParticipantAction } from '../actions' type Beteiligter = { @@ -35,31 +36,11 @@ export function Participants({ members: { id: string; displayName: string }[] files: { id: string; displayName: string }[] }) { - const [open, setOpen] = useState(false) const [role, setRole] = useState('INVESTIGATOR') const [target, setTarget] = useState('') - const [error, setError] = useState(null) + const [fehler, setFehler] = useState(null) const [pending, startTransition] = useTransition() - function add() { - if (!target) return - setError(null) - const [art, id] = target.split(':') - startTransition(async () => { - const result = await addParticipantAction({ - caseNumber, - role, - ...(art === 'user' ? { userId: id } : { personnelFileId: id }), - }) - if (result.ok) { - setTarget('') - setOpen(false) - } else { - setError(result.error) - } - }) - } - return (
{participants.length === 0 ? ( @@ -89,11 +70,11 @@ export function Participants({ disabled={pending} onClick={() => startTransition(async () => { - const result = await removeParticipantAction({ + const ergebnis = await removeParticipantAction({ caseNumber, participantId: person.id, }) - if (!result.ok) setError(result.error) + if (!ergebnis.ok) setFehler(ergebnis.error) }) } className="font-condensed text-2xs text-text-dim" @@ -106,75 +87,49 @@ export function Participants({ )} - {error ?

{error}

: null} + {fehler ?

{fehler}

: null} {canEdit ? ( - open ? ( -
-

- {participantText.hint} -

-
- - - - -
-
- ) : ( - - ) + { + const [art, id] = target.split(':') + const ergebnis = await addParticipantAction({ + caseNumber, + role, + ...(art === 'user' ? { userId: id } : { personnelFileId: id }), + }) + if (ergebnis.ok) setTarget('') + return ergebnis + }} + > + + {PARTICIPANT_ROLES.map((value) => ( + + ))} + + + + + {members.map((member) => ( + + ))} + + + {files.map((file) => ( + + ))} + + + ) : null}
) diff --git a/web/app/(app)/faelle/[caseNumber]/page.tsx b/web/app/(app)/faelle/[caseNumber]/page.tsx index f2e582f..378f54b 100644 --- a/web/app/(app)/faelle/[caseNumber]/page.tsx +++ b/web/app/(app)/faelle/[caseNumber]/page.tsx @@ -25,6 +25,8 @@ import { visiblePersonnelWhere } from '@/lib/access/personnelFilter' import { DocumentList } from '@/components/documents/DocumentList' import { NewDocument } from '@/components/documents/NewDocument' import { Attachments } from '@/components/files/Attachments' +import { ChatLazy } from '@/components/chat/ChatLazy' +import { loadChatView } from '@/lib/chat/load' import { listAttachments } from '@/lib/files/service' import { toAttachmentViews } from '@/lib/files/view' import { allowedTargets, type CaseStatusName } from '@/lib/cases/lifecycle' @@ -214,6 +216,7 @@ async function Relations({
+ ) +} + async function SectionBlock({ caseId, caseNumber, @@ -373,6 +406,20 @@ export default async function CasePage({
+
+ + + + + + } + > + + +
+