diff --git a/internal/webhook/webhook_test.go b/internal/webhook/webhook_test.go index 5273127..2f78674 100644 --- a/internal/webhook/webhook_test.go +++ b/internal/webhook/webhook_test.go @@ -27,7 +27,6 @@ func setupTest(t *testing.T) (*Store, *pgxpool.Pool, func()) { t.Fatalf("pool: %v", err) } if _, err := pool.Exec(ctx, ` - CREATE EXTENSION IF NOT EXISTS pgcrypto; CREATE TABLE IF NOT EXISTS webhook_subscriptions ( id UUID PRIMARY KEY DEFAULT gen_random_uuid(), event_type TEXT NOT NULL, target_url TEXT NOT NULL, secret TEXT NOT NULL, created_at TIMESTAMPTZ NOT NULL DEFAULT now() @@ -99,13 +98,21 @@ func TestEnqueueAndProcessDue_DeliversSuccessfully(t *testing.T) { t.Fatalf("status = %q, want %q", status, StatusDelivered) } - expectedPayload, _ := json.Marshal(map[string]string{"file_id": "42"}) - expectedSig := Sign("geheimes-secret", expectedPayload) - if receivedSignature != expectedSig { - t.Fatalf("empfangene signatur = %q, want %q", receivedSignature, expectedSig) + // Postgres' JSONB-Spalte kann die Byte-Repraesentation des Payloads + // gegenueber dem urspruenglichen json.Marshal kanonisieren (z.B. + // Leerzeichen) — das ist unschaedlich, denn der Dispatcher signiert + // IMMER exakt die Bytes, die er auch sendet. Die Pruefung vergleicht + // deshalb Signatur gegen tatsaechlich empfangene Bytes (Selbstkonsistenz), + // nicht gegen eine unabhaengig neu marshalte Referenz. + if !VerifySignature("geheimes-secret", receivedBody, receivedSignature) { + t.Fatalf("empfangene signatur %q passt nicht zum empfangenen payload %q", receivedSignature, receivedBody) } - if string(receivedBody) != string(expectedPayload) { - t.Fatalf("empfangener payload = %q, want %q", receivedBody, expectedPayload) + var decoded map[string]string + if err := json.Unmarshal(receivedBody, &decoded); err != nil { + t.Fatalf("empfangener payload nicht als json lesbar: %v", err) + } + if decoded["file_id"] != "42" { + t.Fatalf("empfangener payload = %v, want file_id=42", decoded) } }