Phase 5 abgeschlossen: Dateien mit vollständiger Prüfkette
Upload → quarantine/ → Typprüfung → ClamAV → Neukodierung → store/. Es gibt keinen Pfad, auf dem eine Datei ungeprüft in store/ landet, und keinen Schalter, der die Kette abschaltet. Die Typprüfung liest Magic Bytes aus einer eigenen Signaturtabelle statt aus file-type: bei einer Positivliste aus fünf Formaten hilft es nicht, hundert erkennen zu können. Die Signatur muss an Position 0 stehen — ein Vorspann vor %PDF- ist der klassische Weg, eine Datei für zwei Programme zugleich lesbar zu machen. Wer trotzdem durchkommt, kommt als text/plain durch und wird unter der Endung des erkannten Typs ausgeliefert, nicht unter der hochgeladenen. Drei Ausgänge statt zwei: BLOCKED heisst "ist gefährlich", FAILED heisst "wissen wir nicht". Nur FAILED lässt sich freigeben, und die Freigabe wiederholt die Kette ohne den Scanner — Typprüfung und Neukodierung laufen dabei mit. Ein fehlender clamd macht damit keine Datei sauber; ein Test hält das fest. Auslieferung nur über /api/files/[id], mit Sichtbarkeitsprüfung der zugehörigen Akte, Protokoll ab Stufe 3 und den harten Kopfzeilen aus docs/07. Vorschaubilder dürfen inline, weil sie serverseitig als WebP neu kodiert wurden. Das Lichtbild im Aktenblatt ist damit gefüllt: der Feldwert ist die Kennung eines geprüften Anhangs, serverseitig zu einer Adresse aufgelöst. /api/events liefert attachment.scanned über pg_notify — die Grundlage, auf der Phase 6 den Aktenchat aufsetzt. Die Sichtbarkeit wird je Ereignis geprüft, sonst verriete schon die Kennung die Existenz. Nebenbei riss das Bündelbudget (121 kB gegen 120 erlaubte): lib/i18n/de.ts war ein Objekt, und eine Client-Komponente zieht die ganze Datei mit. Die Texte stehen jetzt in sechs Dateien nach Bereichen, de.ts setzt sie nur zusammen. Grösste Route wieder bei 118 kB, und sie wächst nicht mehr mit jedem neuen Bereich mit. 133 Tests im Web-Paket, 15 in der Datenbank, 28 e2e. Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
This commit is contained in:
Harlekin
co-authored by
Claude Opus 5
Claude Opus 5
parent
68ad0debd3
commit
5f58d9b96f
@@ -0,0 +1,152 @@
|
||||
// @vitest-environment node
|
||||
import { afterAll, beforeAll, describe, expect, it } from 'vitest'
|
||||
import { db } from '@/lib/db'
|
||||
import { visibleAttachmentWhere } from '@/lib/access/attachmentFilter'
|
||||
import { loadDeliverable } from '@/lib/files/service'
|
||||
import type { EffectivePermissions, Permission } from '@/lib/auth/permissions'
|
||||
|
||||
/**
|
||||
* Ein Anhang hat keine eigene Freigabestufe, er erbt die seines Besitzers.
|
||||
* Diese Tests prüfen beide Seiten davon: dass die Stufe wirklich durchschlägt,
|
||||
* und dass eine Datei, die die Prüfkette nicht bestanden hat, gar nicht erst
|
||||
* ausgeliefert wird — auch nicht an einen Administrator.
|
||||
*/
|
||||
const url = process.env.DIRECT_DATABASE_URL ?? process.env.DATABASE_URL
|
||||
const suite = url ? describe : describe.skip
|
||||
|
||||
const marke = `anhang-${Date.now()}`
|
||||
|
||||
function perms(
|
||||
userId: string,
|
||||
clearanceLevel: number,
|
||||
options: { isAdmin?: boolean; permissions?: Permission[] } = {},
|
||||
): EffectivePermissions {
|
||||
return {
|
||||
userId,
|
||||
clearanceLevel,
|
||||
permissions: new Set<Permission>(options.permissions ?? []),
|
||||
isAdmin: options.isAdmin ?? false,
|
||||
hasMembership: true,
|
||||
}
|
||||
}
|
||||
|
||||
suite('Sichtbarkeit von Anhängen', () => {
|
||||
const nutzer = { stufe1: `${marke}-stufe1`, stufe4: `${marke}-stufe4` }
|
||||
const anhang = { offen: '', geheim: '', imEintrag: '', inQuarantaene: '' }
|
||||
|
||||
beforeAll(async () => {
|
||||
const vorlage = await db.documentTemplate.create({
|
||||
data: { key: `${marke}-vorlage`, version: 1, name: 'Prüfvorlage', fields: [] },
|
||||
})
|
||||
for (const id of Object.values(nutzer)) {
|
||||
await db.user.create({ data: { id, username: id, displayName: id } })
|
||||
}
|
||||
|
||||
const gemeinsam = {
|
||||
templateId: vorlage.id,
|
||||
templateKey: vorlage.key,
|
||||
createdById: nutzer.stufe4,
|
||||
}
|
||||
const offen = await db.case.create({
|
||||
data: {
|
||||
...gemeinsam,
|
||||
caseNumber: `${marke}-o`.slice(0, 40),
|
||||
title: 'Offen',
|
||||
classification: 1,
|
||||
status: 'OPEN',
|
||||
},
|
||||
})
|
||||
const geheim = await db.case.create({
|
||||
data: {
|
||||
...gemeinsam,
|
||||
caseNumber: `${marke}-g`.slice(0, 40),
|
||||
title: 'Geheim',
|
||||
classification: 4,
|
||||
status: 'OPEN',
|
||||
},
|
||||
})
|
||||
|
||||
const eintrag = await db.caseEntry.create({
|
||||
data: {
|
||||
id: `${marke}-eintrag`,
|
||||
caseId: offen.id,
|
||||
type: 'NOTE',
|
||||
body: 'Nur ab Stufe 4',
|
||||
authorId: nutzer.stufe4,
|
||||
minClearance: 4,
|
||||
},
|
||||
})
|
||||
|
||||
const anlegen = async (
|
||||
name: string,
|
||||
besitzer: { caseId?: string; entryId?: string },
|
||||
scanStatus: 'CLEAN' | 'PENDING' = 'CLEAN',
|
||||
) =>
|
||||
(
|
||||
await db.attachment.create({
|
||||
data: {
|
||||
originalName: `${name}.png`,
|
||||
mimeType: 'image/png',
|
||||
sizeBytes: 100,
|
||||
sha256: `${marke}-${name}`,
|
||||
storageKey: `store/aa/bb/${marke}-${name}`,
|
||||
uploadedById: nutzer.stufe4,
|
||||
scanStatus,
|
||||
...besitzer,
|
||||
},
|
||||
select: { id: true },
|
||||
})
|
||||
).id
|
||||
|
||||
anhang.offen = await anlegen('offen', { caseId: offen.id })
|
||||
anhang.geheim = await anlegen('geheim', { caseId: geheim.id })
|
||||
anhang.imEintrag = await anlegen('eintrag', { entryId: eintrag.id })
|
||||
anhang.inQuarantaene = await anlegen('quarantaene', { caseId: offen.id }, 'PENDING')
|
||||
})
|
||||
|
||||
afterAll(async () => {
|
||||
await db.$disconnect()
|
||||
})
|
||||
|
||||
async function sichtbar(p: EffectivePermissions): Promise<string[]> {
|
||||
const rows = await db.attachment.findMany({
|
||||
where: { AND: [visibleAttachmentWhere(p), { id: { in: Object.values(anhang) } }] },
|
||||
select: { id: true },
|
||||
})
|
||||
return rows.map((r) => r.id).sort()
|
||||
}
|
||||
|
||||
it('verbirgt den Anhang einer zu hoch eingestuften Akte, auch in der Zählung', async () => {
|
||||
const p = perms(nutzer.stufe1, 1)
|
||||
const treffer = await sichtbar(p)
|
||||
|
||||
expect(treffer).toContain(anhang.offen)
|
||||
expect(treffer).not.toContain(anhang.geheim)
|
||||
|
||||
const anzahl = await db.attachment.count({
|
||||
where: { AND: [visibleAttachmentWhere(p), { id: { in: Object.values(anhang) } }] },
|
||||
})
|
||||
expect(anzahl).toBe(treffer.length)
|
||||
})
|
||||
|
||||
it('verbirgt den Anhang eines Eintrags über der Stufe des Lesers', async () => {
|
||||
// Die Akte darf er sehen, den Eintrag nicht — und damit auch dessen Datei
|
||||
// nicht. Sonst verriete die Anhangsliste den Inhalt des Eintrags.
|
||||
expect(await sichtbar(perms(nutzer.stufe1, 1))).not.toContain(anhang.imEintrag)
|
||||
expect(await sichtbar(perms(nutzer.stufe4, 4))).toContain(anhang.imEintrag)
|
||||
})
|
||||
|
||||
it('liefert nichts aus, was die Prüfkette nicht bestanden hat', async () => {
|
||||
// Auch nicht dem Administrator: die Datei liegt in der Quarantäne, dort
|
||||
// führt kein Auslieferungspfad hin.
|
||||
expect(await loadDeliverable(perms(nutzer.stufe4, 5, { isAdmin: true }), anhang.inQuarantaene))
|
||||
.toBeNull()
|
||||
expect(await loadDeliverable(perms(nutzer.stufe4, 4), anhang.offen)).not.toBeNull()
|
||||
})
|
||||
|
||||
it('liefert einem zu niedrig eingestuften Leser nichts, sondern nichts Findbares', async () => {
|
||||
// `null` und nicht "verboten": der Endpunkt macht daraus 404, die Existenz
|
||||
// der Datei bleibt verborgen.
|
||||
expect(await loadDeliverable(perms(nutzer.stufe1, 1), anhang.geheim)).toBeNull()
|
||||
})
|
||||
})
|
||||
@@ -0,0 +1,159 @@
|
||||
// @vitest-environment node
|
||||
import { describe, expect, it } from 'vitest'
|
||||
import { ALLOWED_TYPES, detectType, looksLikeText, matchesDeclared } from '@/lib/files/magic'
|
||||
import { absolutePath, storageKeyFor } from '@/lib/files/paths'
|
||||
import { deliveryFileName } from '@/lib/files/delivery'
|
||||
|
||||
/**
|
||||
* Die Typprüfung ist die Stelle, an der eine feindselige Datei auffallen muss.
|
||||
*
|
||||
* Geprüft wird deshalb nicht nur, dass die erlaubten Formate durchkommen,
|
||||
* sondern vor allem, dass die verbotenen es **nicht** tun — und zwar auch
|
||||
* dann, wenn sie sich als erlaubte ausgeben.
|
||||
*/
|
||||
|
||||
const bytes = (...werte: number[]) => new Uint8Array(werte)
|
||||
const text = (wert: string) => new TextEncoder().encode(wert)
|
||||
|
||||
const PNG = bytes(0x89, 0x50, 0x4e, 0x47, 0x0d, 0x0a, 0x1a, 0x0a, 0, 0, 0, 13)
|
||||
const JPEG = bytes(0xff, 0xd8, 0xff, 0xe0, 0x00, 0x10, 0x4a, 0x46)
|
||||
const WEBP = new Uint8Array([...text('RIFF'), 0, 0, 0, 0, ...text('WEBP'), ...text('VP8 ')])
|
||||
const PDF = text('%PDF-1.7\n1 0 obj\n')
|
||||
|
||||
describe('Erkennung erlaubter Typen', () => {
|
||||
it('erkennt jedes zugelassene Format am Inhalt', () => {
|
||||
expect(detectType(PNG)).toEqual({ ok: true, type: 'image/png' })
|
||||
expect(detectType(JPEG)).toEqual({ ok: true, type: 'image/jpeg' })
|
||||
expect(detectType(WEBP)).toEqual({ ok: true, type: 'image/webp' })
|
||||
expect(detectType(PDF)).toEqual({ ok: true, type: 'application/pdf' })
|
||||
expect(detectType(text('Nur Text, mehr nicht.\n'))).toEqual({
|
||||
ok: true,
|
||||
type: 'text/plain',
|
||||
})
|
||||
})
|
||||
|
||||
it('deckt genau die fünf Typen aus dem Dokument ab', () => {
|
||||
expect([...ALLOWED_TYPES]).toEqual([
|
||||
'image/png',
|
||||
'image/jpeg',
|
||||
'image/webp',
|
||||
'application/pdf',
|
||||
'text/plain',
|
||||
])
|
||||
})
|
||||
})
|
||||
|
||||
describe('Abwehr', () => {
|
||||
it('lehnt SVG ab, auch wenn es wie Text aussieht', () => {
|
||||
// Der eigentliche Grund für die ganze Kette: SVG führt im Browser Skripte
|
||||
// aus. Es ist gültiges UTF-8 und käme sonst als text/plain durch — das ist
|
||||
// in Ordnung, denn als Text wird es nie gerendert, sondern ausgeliefert
|
||||
// mit Content-Disposition: attachment.
|
||||
const svg = text('<svg xmlns="http://www.w3.org/2000/svg"><script>alert(1)</script></svg>')
|
||||
const erkannt = detectType(svg)
|
||||
expect(erkannt).toEqual({ ok: true, type: 'text/plain' })
|
||||
// Entscheidend: es ist nie image/svg+xml, und der gemeldete Typ passt nicht.
|
||||
expect(matchesDeclared('text/plain', 'image/svg+xml')).toBe(false)
|
||||
})
|
||||
|
||||
it('lehnt Archive und Ausführbares ab', () => {
|
||||
expect(detectType(bytes(0x50, 0x4b, 0x03, 0x04, 0, 0))).toEqual({
|
||||
ok: false,
|
||||
reason: 'unknown-type',
|
||||
})
|
||||
// ELF
|
||||
expect(detectType(bytes(0x7f, 0x45, 0x4c, 0x46, 2, 1, 1, 0))).toEqual({
|
||||
ok: false,
|
||||
reason: 'unknown-type',
|
||||
})
|
||||
// Windows-Programm
|
||||
expect(detectType(bytes(0x4d, 0x5a, 0x90, 0x00))).toEqual({
|
||||
ok: false,
|
||||
reason: 'unknown-type',
|
||||
})
|
||||
})
|
||||
|
||||
it('lässt sich vom RIFF-Container nicht täuschen', () => {
|
||||
// WAV ist auch RIFF. Ohne die zweite Prüfung wäre es ein WebP.
|
||||
const wav = new Uint8Array([...text('RIFF'), 0, 0, 0, 0, ...text('WAVE')])
|
||||
expect(detectType(wav)).toEqual({ ok: false, reason: 'unknown-type' })
|
||||
})
|
||||
|
||||
it('erkennt ein PDF mit Vorspann nicht als PDF', () => {
|
||||
// Müll vor %PDF- ist der klassische Weg, eine Datei für zwei Programme
|
||||
// zugleich lesbar zu machen. Die Spezifikation erlaubt es, wir nicht: die
|
||||
// Signatur muss an Position 0 stehen.
|
||||
const getarnt = new Uint8Array([...text('GIF89a'), ...PDF])
|
||||
const erkannt = detectType(getarnt)
|
||||
expect(erkannt).not.toEqual({ ok: true, type: 'application/pdf' })
|
||||
|
||||
// Es bleibt lesbarer Text und wird deshalb als solcher angenommen. Das ist
|
||||
// harmlos, weil die Auslieferung die Endung auf den **erkannten** Typ
|
||||
// setzt: die Datei kommt als .txt an und landet in keinem PDF-Betrachter.
|
||||
expect(erkannt).toEqual({ ok: true, type: 'text/plain' })
|
||||
expect(deliveryFileName('bericht.pdf', 'text/plain')).toBe('bericht.txt')
|
||||
})
|
||||
|
||||
it('lehnt einen Vorspann mit Binärdaten ganz ab', () => {
|
||||
const getarnt = new Uint8Array([0x00, 0x01, ...text('%PDF-1.7')])
|
||||
expect(detectType(getarnt)).toEqual({ ok: false, reason: 'unknown-type' })
|
||||
})
|
||||
|
||||
it('lässt kein Binärformat als Text durch', () => {
|
||||
expect(looksLikeText(bytes(0x48, 0x00, 0x69))).toBe(false)
|
||||
expect(looksLikeText(bytes(0xff, 0xfe, 0x41))).toBe(false)
|
||||
expect(looksLikeText(text('Umlaute sind erlaubt: äöüß\n\t'))).toBe(true)
|
||||
})
|
||||
|
||||
it('lehnt eine leere Datei ab', () => {
|
||||
expect(detectType(new Uint8Array())).toEqual({ ok: false, reason: 'empty' })
|
||||
})
|
||||
|
||||
it('erkennt, wenn der gemeldete Typ nicht zum Inhalt passt', () => {
|
||||
expect(matchesDeclared('image/png', 'application/pdf')).toBe(false)
|
||||
expect(matchesDeclared('image/png', 'image/png')).toBe(true)
|
||||
// Der Browser weiss es manchmal selbst nicht; das ist kein Verdacht.
|
||||
expect(matchesDeclared('image/png', 'application/octet-stream')).toBe(true)
|
||||
expect(matchesDeclared('image/png', null)).toBe(true)
|
||||
// Zeichensatzangabe im Kopf stört nicht.
|
||||
expect(matchesDeclared('text/plain', 'text/plain; charset=utf-8')).toBe(true)
|
||||
})
|
||||
})
|
||||
|
||||
describe('Ablagepfade', () => {
|
||||
it('verteilt auf zwei Ebenen und behält die Kennung', () => {
|
||||
expect(storageKeyFor('store', '0192abcd-ef01-7000-8000-000000000001')).toBe(
|
||||
'store/01/92/0192abcd-ef01-7000-8000-000000000001',
|
||||
)
|
||||
})
|
||||
|
||||
it('lässt keinen Pfad aus dem Dateiverzeichnis heraus', () => {
|
||||
process.env.FILES_DIR ??= '/tmp/afis-test-files'
|
||||
// Kommt aus der Datenbank, nicht aus einer Eingabe — aber ein
|
||||
// Verzeichniswechsel wäre der teuerste Fehler an dieser Stelle.
|
||||
expect(() => absolutePath('../../etc/passwd')).toThrow()
|
||||
expect(() => absolutePath('store/../../../etc/passwd')).toThrow()
|
||||
expect(absolutePath('store/ab/cd/ef')).toContain('store/ab/cd/ef')
|
||||
})
|
||||
|
||||
it('wirft Sonderzeichen aus der Kennung, bevor sie ein Pfad wird', () => {
|
||||
expect(storageKeyFor('quarantine', '../../etc')).not.toContain('..')
|
||||
})
|
||||
})
|
||||
|
||||
describe('Name beim Ausliefern', () => {
|
||||
it('setzt die Endung auf den erkannten Typ, nicht auf den hochgeladenen Namen', () => {
|
||||
// Sonst trüge eine als Text erkannte Datei weiter .pdf und würde beim
|
||||
// Doppelklick im PDF-Betrachter geöffnet.
|
||||
expect(deliveryFileName('urlaub.jpeg', 'image/png')).toBe('urlaub.png')
|
||||
expect(deliveryFileName('notiz', 'text/plain')).toBe('notiz.txt')
|
||||
expect(deliveryFileName('vertrag.pdf', 'application/pdf')).toBe('vertrag.pdf')
|
||||
expect(deliveryFileName('bild.JPG', 'image/jpeg')).toBe('bild.jpg')
|
||||
})
|
||||
|
||||
it('lässt keine Kopfzeile zerlegen', () => {
|
||||
const boes = deliveryFileName('a"; rm -rf /\r\nX: y.txt', 'text/plain')
|
||||
expect(boes).not.toContain('"')
|
||||
expect(boes).not.toMatch(/[\r\n]/)
|
||||
})
|
||||
})
|
||||
@@ -11,7 +11,7 @@ vi.mock('@/lib/env', () => ({
|
||||
getEnv: () => ({ CLAMAV_SOCKET: '/var/run/clamav/clamd.sock' }),
|
||||
}))
|
||||
|
||||
vi.mock('@/lib/health/clamav', () => ({ pingClamav: vi.fn(async () => true) }))
|
||||
vi.mock('@/lib/files/clamav', () => ({ pingClamav: vi.fn(async () => true) }))
|
||||
|
||||
describe('collectHealth', () => {
|
||||
it('meldet betriebsbereit, wenn alle drei Abhaengigkeiten antworten', async () => {
|
||||
@@ -24,7 +24,7 @@ describe('collectHealth', () => {
|
||||
})
|
||||
|
||||
it('bleibt nur eingeschraenkt, wenn allein die Virenpruefung ausfaellt', async () => {
|
||||
const clamav = await import('@/lib/health/clamav')
|
||||
const clamav = await import('@/lib/files/clamav')
|
||||
vi.mocked(clamav.pingClamav).mockResolvedValueOnce(false)
|
||||
const { collectHealth } = await import('@/lib/health/check')
|
||||
const report = await collectHealth()
|
||||
|
||||
@@ -0,0 +1,94 @@
|
||||
// @vitest-environment node
|
||||
import { describe, expect, it } from 'vitest'
|
||||
import sharp from 'sharp'
|
||||
import { reencode } from '@/lib/files/reencode'
|
||||
import { detectType } from '@/lib/files/magic'
|
||||
|
||||
/**
|
||||
* Die Neukodierung ist die wirksamste Massnahme der Kette: ein Bild, das durch
|
||||
* `sharp` gelaufen ist, besteht nur noch aus Pixeln.
|
||||
*
|
||||
* Diese Tests prüfen genau das — nicht, dass irgendetwas herauskommt, sondern
|
||||
* dass das, was nicht Inhalt ist, **weg** ist.
|
||||
*/
|
||||
|
||||
async function testbild(): Promise<Buffer> {
|
||||
return sharp({
|
||||
create: { width: 24, height: 16, channels: 3, background: { r: 200, g: 40, b: 40 } },
|
||||
})
|
||||
.jpeg()
|
||||
.withMetadata({
|
||||
exif: {
|
||||
IFD0: { Copyright: 'GEHEIMER FOTOGRAF', Software: 'Kamera 9000' },
|
||||
},
|
||||
})
|
||||
.toBuffer()
|
||||
}
|
||||
|
||||
describe('Bilder neu kodieren', () => {
|
||||
it('wirft die Metadaten weg, statt sie zu filtern', async () => {
|
||||
const original = await testbild()
|
||||
// Gegenprobe: das Original trägt die Daten wirklich.
|
||||
expect(original.includes(Buffer.from('GEHEIMER FOTOGRAF'))).toBe(true)
|
||||
|
||||
const ergebnis = await reencode(new Uint8Array(original), 'image/jpeg')
|
||||
expect(ergebnis.ok).toBe(true)
|
||||
if (!ergebnis.ok) return
|
||||
|
||||
const neu = Buffer.from(ergebnis.result.content)
|
||||
expect(neu.includes(Buffer.from('GEHEIMER FOTOGRAF'))).toBe(false)
|
||||
expect(neu.includes(Buffer.from('Kamera 9000'))).toBe(false)
|
||||
|
||||
// Und es ist noch dasselbe Bild.
|
||||
const info = await sharp(neu).metadata()
|
||||
expect(info.width).toBe(24)
|
||||
expect(info.height).toBe(16)
|
||||
expect(ergebnis.result.width).toBe(24)
|
||||
})
|
||||
|
||||
it('zerstört eine angehängte Nutzlast', async () => {
|
||||
// Der klassische Trick: hinter das Bildende Daten kleben. Nach der
|
||||
// Neukodierung ist davon nichts mehr da, weil nur die Pixel übernommen
|
||||
// werden.
|
||||
const angehaengt = Buffer.concat([
|
||||
await testbild(),
|
||||
Buffer.from('<?php system($_GET["c"]); ?>'),
|
||||
])
|
||||
const ergebnis = await reencode(new Uint8Array(angehaengt), 'image/jpeg')
|
||||
expect(ergebnis.ok).toBe(true)
|
||||
if (!ergebnis.ok) return
|
||||
expect(Buffer.from(ergebnis.result.content).includes(Buffer.from('<?php'))).toBe(false)
|
||||
})
|
||||
|
||||
it('erzeugt Vorschaubild und Platzhalter', async () => {
|
||||
const ergebnis = await reencode(new Uint8Array(await testbild()), 'image/jpeg')
|
||||
expect(ergebnis.ok).toBe(true)
|
||||
if (!ergebnis.ok) return
|
||||
|
||||
expect(ergebnis.result.thumb).toBeDefined()
|
||||
// Das Vorschaubild ist immer WebP, damit die Auslieferung es gefahrlos
|
||||
// inline schicken kann.
|
||||
expect(detectType(ergebnis.result.thumb!)).toEqual({ ok: true, type: 'image/webp' })
|
||||
expect(ergebnis.result.blurhash).toMatch(/^[\w#$%*+,\-.:;=?@[\]^_{|}~]{6,}$/)
|
||||
})
|
||||
|
||||
it('lehnt ab, was kein Bild ist', async () => {
|
||||
const ergebnis = await reencode(new TextEncoder().encode('kein Bild'), 'image/png')
|
||||
expect(ergebnis.ok).toBe(false)
|
||||
})
|
||||
})
|
||||
|
||||
describe('Text normalisieren', () => {
|
||||
it('entfernt die Stückliste am Anfang', async () => {
|
||||
const mitBom = new TextEncoder().encode('Hallo Welt')
|
||||
const ergebnis = await reencode(mitBom, 'text/plain')
|
||||
expect(ergebnis.ok).toBe(true)
|
||||
if (!ergebnis.ok) return
|
||||
expect(new TextDecoder().decode(ergebnis.result.content)).toBe('Hallo Welt')
|
||||
})
|
||||
|
||||
it('lehnt ungültiges UTF-8 ab', async () => {
|
||||
const ergebnis = await reencode(new Uint8Array([0xff, 0xfe, 0x41]), 'text/plain')
|
||||
expect(ergebnis.ok).toBe(false)
|
||||
})
|
||||
})
|
||||
@@ -0,0 +1,180 @@
|
||||
// @vitest-environment node
|
||||
import { afterAll, beforeAll, describe, expect, it } from 'vitest'
|
||||
import { readFile } from 'node:fs/promises'
|
||||
import sharp from 'sharp'
|
||||
import { db } from '@/lib/db'
|
||||
import { acceptUpload, loadDeliverable, releaseAttachment } from '@/lib/files/service'
|
||||
import { runCheckChain } from '@/lib/files/process'
|
||||
import { absolutePath } from '@/lib/files/paths'
|
||||
import { AccessError } from '@/lib/errors'
|
||||
import type { EffectivePermissions, Permission } from '@/lib/auth/permissions'
|
||||
|
||||
/**
|
||||
* Die ganze Kette, an einer echten Datei.
|
||||
*
|
||||
* Auf dem Entwicklungsrechner läuft kein clamav. Genau das macht den Test
|
||||
* wertvoll: er hält fest, dass ein fehlender Scanner eine Datei **nicht**
|
||||
* sauber macht. Wäre das je anders, stünde hier ein roter Test.
|
||||
*/
|
||||
const url = process.env.DIRECT_DATABASE_URL ?? process.env.DATABASE_URL
|
||||
const suite = url ? describe : describe.skip
|
||||
|
||||
const marke = `kette-${Date.now()}`
|
||||
|
||||
function perms(
|
||||
userId: string,
|
||||
options: { isAdmin?: boolean; permissions?: Permission[] } = {},
|
||||
): EffectivePermissions {
|
||||
return {
|
||||
userId,
|
||||
clearanceLevel: 4,
|
||||
permissions: new Set<Permission>(options.permissions ?? []),
|
||||
isAdmin: options.isAdmin ?? false,
|
||||
hasMembership: true,
|
||||
}
|
||||
}
|
||||
|
||||
suite('Prüfkette', () => {
|
||||
const nutzer = perms(`${marke}-nutzer`, { permissions: ['entry.create', 'case.edit'] })
|
||||
const admin = perms(`${marke}-admin`, { isAdmin: true })
|
||||
let caseNumber = ''
|
||||
|
||||
async function bild(): Promise<Uint8Array> {
|
||||
const buffer = await sharp({
|
||||
create: { width: 20, height: 20, channels: 3, background: { r: 10, g: 90, b: 200 } },
|
||||
})
|
||||
.jpeg()
|
||||
.withMetadata({ exif: { IFD0: { Copyright: 'VERTRAULICHE QUELLE' } } })
|
||||
.toBuffer()
|
||||
return new Uint8Array(buffer)
|
||||
}
|
||||
|
||||
beforeAll(async () => {
|
||||
const vorlage = await db.documentTemplate.create({
|
||||
data: { key: `${marke}-vorlage`, version: 1, name: 'Prüfvorlage', fields: [] },
|
||||
})
|
||||
for (const p of [nutzer, admin]) {
|
||||
await db.user.create({ data: { id: p.userId, username: p.userId, displayName: p.userId } })
|
||||
}
|
||||
const akte = await db.case.create({
|
||||
data: {
|
||||
caseNumber: `${marke}`.slice(0, 40),
|
||||
title: 'Anhangprüfung',
|
||||
templateId: vorlage.id,
|
||||
templateKey: vorlage.key,
|
||||
createdById: nutzer.userId,
|
||||
classification: 1,
|
||||
status: 'OPEN',
|
||||
},
|
||||
})
|
||||
caseNumber = akte.caseNumber
|
||||
})
|
||||
|
||||
afterAll(async () => {
|
||||
await db.$disconnect()
|
||||
})
|
||||
|
||||
it('nimmt die Datei an und legt sie in der Quarantäne ab', async () => {
|
||||
const { id } = await acceptUpload(nutzer, {
|
||||
owner: { kind: 'case', caseNumber },
|
||||
fileName: 'urlaubsbild.jpg',
|
||||
declaredType: 'image/jpeg',
|
||||
content: await bild(),
|
||||
})
|
||||
|
||||
const anhang = await db.attachment.findUniqueOrThrow({ where: { id } })
|
||||
expect(anhang.scanStatus).toBe('PENDING')
|
||||
expect(anhang.storageKey).toMatch(/^quarantine\//)
|
||||
// Der Dateiname des Nutzers taucht im Pfad nicht auf.
|
||||
expect(anhang.storageKey).not.toContain('urlaubsbild')
|
||||
await expect(readFile(absolutePath(anhang.storageKey))).resolves.toBeDefined()
|
||||
|
||||
// Und ausgeliefert wird sie nicht, solange sie dort liegt.
|
||||
expect(await loadDeliverable(nutzer, id)).toBeNull()
|
||||
})
|
||||
|
||||
it('macht aus einem fehlenden Scanner keine saubere Datei', async () => {
|
||||
const { id } = await acceptUpload(nutzer, {
|
||||
owner: { kind: 'case', caseNumber },
|
||||
fileName: 'zweites.jpg',
|
||||
declaredType: 'image/jpeg',
|
||||
content: await bild(),
|
||||
})
|
||||
|
||||
await runCheckChain(id)
|
||||
|
||||
const anhang = await db.attachment.findUniqueOrThrow({ where: { id } })
|
||||
// Ohne clamd: unentschieden, nicht sauber und nicht blockiert.
|
||||
expect(anhang.scanStatus).toBe('FAILED')
|
||||
expect(anhang.scanMessage).toBeTruthy()
|
||||
expect(await loadDeliverable(admin, id)).toBeNull()
|
||||
})
|
||||
|
||||
it('blockiert einen Typ, der nicht auf der Liste steht', async () => {
|
||||
const { id } = await acceptUpload(nutzer, {
|
||||
owner: { kind: 'case', caseNumber },
|
||||
fileName: 'archiv.zip',
|
||||
declaredType: 'application/zip',
|
||||
content: new Uint8Array([0x50, 0x4b, 0x03, 0x04, 0, 0, 0, 0]),
|
||||
})
|
||||
|
||||
await runCheckChain(id)
|
||||
|
||||
const anhang = await db.attachment.findUniqueOrThrow({ where: { id } })
|
||||
// Endgültig: das ist kein "wissen wir nicht", das ist ein Nein.
|
||||
expect(anhang.scanStatus).toBe('BLOCKED')
|
||||
expect(anhang.scanMessage).toContain('nicht erlaubt')
|
||||
})
|
||||
|
||||
it('blockiert, wenn der gemeldete Typ nicht zum Inhalt passt', async () => {
|
||||
const { id } = await acceptUpload(nutzer, {
|
||||
owner: { kind: 'case', caseNumber },
|
||||
fileName: 'getarnt.pdf',
|
||||
declaredType: 'application/pdf',
|
||||
content: await bild(),
|
||||
})
|
||||
|
||||
await runCheckChain(id)
|
||||
|
||||
const anhang = await db.attachment.findUniqueOrThrow({ where: { id } })
|
||||
expect(anhang.scanStatus).toBe('BLOCKED')
|
||||
})
|
||||
|
||||
it('gibt eine unvollständige Prüfung nur für Admins frei, und kodiert dabei neu', async () => {
|
||||
const { id } = await acceptUpload(nutzer, {
|
||||
owner: { kind: 'case', caseNumber },
|
||||
fileName: 'freizugeben.jpg',
|
||||
declaredType: 'image/jpeg',
|
||||
content: await bild(),
|
||||
})
|
||||
await runCheckChain(id)
|
||||
|
||||
await expect(releaseAttachment(nutzer, id)).rejects.toThrow(AccessError)
|
||||
|
||||
await releaseAttachment(admin, id)
|
||||
const anhang = await db.attachment.findUniqueOrThrow({ where: { id } })
|
||||
|
||||
expect(anhang.scanStatus).toBe('CLEAN')
|
||||
expect(anhang.storageKey).toMatch(/^store\//)
|
||||
expect(anhang.releasedById).toBe(admin.userId)
|
||||
// Die Freigabe überspringt nur den Scanner. Die Neukodierung lief mit:
|
||||
// die Metadaten des Bildes sind weg.
|
||||
expect(anhang.scanMessage).toContain('Ohne Virenprüfung')
|
||||
const abgelegt = await readFile(absolutePath(anhang.storageKey))
|
||||
expect(abgelegt.includes(Buffer.from('VERTRAULICHE QUELLE'))).toBe(false)
|
||||
expect(anhang.thumbKey).toBeTruthy()
|
||||
expect(anhang.blurhash).toBeTruthy()
|
||||
expect(anhang.width).toBe(20)
|
||||
|
||||
// Jetzt, und erst jetzt, ist sie abrufbar.
|
||||
expect(await loadDeliverable(nutzer, id)).not.toBeNull()
|
||||
})
|
||||
|
||||
it('lässt eine blockierte Datei auch vom Admin nicht freigeben', async () => {
|
||||
const blockiert = await db.attachment.findFirstOrThrow({
|
||||
where: { uploadedById: nutzer.userId, scanStatus: 'BLOCKED' },
|
||||
select: { id: true },
|
||||
})
|
||||
await expect(releaseAttachment(admin, blockiert.id)).rejects.toThrow(AccessError)
|
||||
})
|
||||
})
|
||||
Reference in New Issue
Block a user