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.
173 lines
5.3 KiB
TypeScript
173 lines
5.3 KiB
TypeScript
'use client'
|
|
|
|
import { useCallback, useRef, useState } from 'react'
|
|
import { attachmentText, documentText } from '@/lib/i18n/documents'
|
|
import { MAX_FILE_BYTES } from '@/lib/files/limits'
|
|
import { useStream, type ScanEvent } from '@/components/realtime/useStream'
|
|
import type { SaveSection } from '@/components/sections/types'
|
|
|
|
/**
|
|
* Das Lichtbild im Aktenblatt.
|
|
*
|
|
* Der Wert des Feldes ist die **Kennung eines geprüften Anhangs**, nie das
|
|
* Bild selbst. Ein Bild als Data-URL im Abschnittswert liefe an der ganzen
|
|
* Prüfkette vorbei und wäre nachträglich kaum wieder herauszubekommen.
|
|
* Siehe docs/07-dateien-und-sicherheit.md.
|
|
*
|
|
* Deshalb zwei Schritte hintereinander: hochladen, dann die Kennung in den
|
|
* Abschnitt schreiben. Angezeigt wird erst, wenn die Prüfung durch ist.
|
|
*/
|
|
export function PhotoField({
|
|
save,
|
|
fieldKey,
|
|
label,
|
|
documentNumber,
|
|
topic,
|
|
initialAttachmentId,
|
|
initialUrl,
|
|
initialVersion,
|
|
readOnly,
|
|
}: {
|
|
save: SaveSection
|
|
fieldKey: string
|
|
label: string
|
|
documentNumber: string
|
|
/** Thema des Besitzers, damit das Prüfergebnis ankommt. */
|
|
topic: string
|
|
initialAttachmentId: string | null
|
|
initialUrl: string | null
|
|
initialVersion: number
|
|
readOnly: boolean
|
|
}) {
|
|
const [url, setUrl] = useState(initialUrl)
|
|
const [version, setVersion] = useState(initialVersion)
|
|
const [wartetAuf, setWartetAuf] = useState<string | null>(
|
|
initialAttachmentId && !initialUrl ? initialAttachmentId : null,
|
|
)
|
|
const [fortschritt, setFortschritt] = useState<number | null>(null)
|
|
const [fehler, setFehler] = useState<string | null>(null)
|
|
const eingabe = useRef<HTMLInputElement>(null)
|
|
|
|
const geprueft = useCallback(
|
|
(event: ScanEvent) => {
|
|
if (event.id !== wartetAuf) return
|
|
if (event.scanStatus === 'CLEAN') {
|
|
setUrl(`/api/files/${event.id}?variant=thumb`)
|
|
setWartetAuf(null)
|
|
return
|
|
}
|
|
if (event.scanStatus !== 'PENDING') {
|
|
setFehler(event.scanMessage ?? attachmentText.statusNames[event.scanStatus]!)
|
|
setWartetAuf(null)
|
|
}
|
|
},
|
|
[wartetAuf],
|
|
)
|
|
|
|
useStream([topic], { 'attachment.scanned': (data) => geprueft(data as ScanEvent) })
|
|
|
|
function waehlen(datei: File) {
|
|
setFehler(null)
|
|
if (datei.size > MAX_FILE_BYTES) {
|
|
setFehler(attachmentText.errors['file-too-large']!)
|
|
return
|
|
}
|
|
|
|
const form = new FormData()
|
|
form.set('file', datei)
|
|
form.set('documentNumber', documentNumber)
|
|
|
|
const anfrage = new XMLHttpRequest()
|
|
anfrage.open('POST', '/api/files')
|
|
setFortschritt(0)
|
|
|
|
anfrage.upload.addEventListener('progress', (event) => {
|
|
if (event.lengthComputable) {
|
|
setFortschritt(Math.round((event.loaded / event.total) * 100))
|
|
}
|
|
})
|
|
|
|
anfrage.addEventListener('load', async () => {
|
|
setFortschritt(null)
|
|
if (anfrage.status !== 201) {
|
|
try {
|
|
setFehler(
|
|
(JSON.parse(anfrage.responseText) as { error?: string }).error ??
|
|
attachmentText.errors.transfer!,
|
|
)
|
|
} catch {
|
|
setFehler(attachmentText.errors.transfer!)
|
|
}
|
|
return
|
|
}
|
|
|
|
const { id } = JSON.parse(anfrage.responseText) as { id: string }
|
|
// Die Kennung sofort in den Abschnitt schreiben, auch wenn die Prüfung
|
|
// noch läuft: sonst ginge die Zuordnung verloren, wenn der Nutzer die
|
|
// Seite verlässt.
|
|
const ergebnis = await save({ fieldKey, value: id, baseVersion: version })
|
|
if (ergebnis.ok) {
|
|
setVersion(ergebnis.version)
|
|
setWartetAuf(id)
|
|
setUrl(null)
|
|
} else if (!ergebnis.conflict) {
|
|
setFehler(ergebnis.error)
|
|
}
|
|
})
|
|
|
|
anfrage.addEventListener('error', () => {
|
|
setFortschritt(null)
|
|
setFehler(attachmentText.errors.transfer!)
|
|
})
|
|
|
|
anfrage.send(form)
|
|
}
|
|
|
|
return (
|
|
<div>
|
|
<p className="font-condensed text-xs text-text-dim">{label}</p>
|
|
<div className="mt-1.5 flex items-start gap-4">
|
|
<div className="flex h-40 w-30 items-center justify-center border border-line bg-raised text-center text-2xs text-text-dim">
|
|
{url ? (
|
|
// eslint-disable-next-line @next/next/no-img-element
|
|
<img src={url} alt={label} className="h-full w-full object-cover" />
|
|
) : wartetAuf ? (
|
|
attachmentText.checking
|
|
) : (
|
|
documentText.photoEmpty
|
|
)}
|
|
</div>
|
|
|
|
{!readOnly ? (
|
|
<div>
|
|
<input
|
|
ref={eingabe}
|
|
type="file"
|
|
accept="image/png,image/jpeg,image/webp"
|
|
onChange={(event) => {
|
|
const datei = event.target.files?.[0]
|
|
if (datei) waehlen(datei)
|
|
event.target.value = ''
|
|
}}
|
|
className="hidden"
|
|
/>
|
|
<button
|
|
type="button"
|
|
disabled={fortschritt !== null}
|
|
onClick={() => eingabe.current?.click()}
|
|
className="border border-line bg-raised px-3 py-1 font-condensed text-2xs text-accent disabled:text-text-dim"
|
|
>
|
|
{fortschritt === null
|
|
? attachmentText.choose
|
|
: `${attachmentText.uploading} ${fortschritt} %`}
|
|
</button>
|
|
{fehler ? (
|
|
<p className="mt-2 max-w-60 font-condensed text-2xs text-stamp-4">{fehler}</p>
|
|
) : null}
|
|
</div>
|
|
) : null}
|
|
</div>
|
|
</div>
|
|
)
|
|
}
|