Spaces:
Running
Running
| import assert from "node:assert/strict"; | |
| import { spawn } from "node:child_process"; | |
| import { once } from "node:events"; | |
| import { createServer } from "node:http"; | |
| import type { AddressInfo } from "node:net"; | |
| import { test } from "node:test"; | |
| test("admin action edits attribute changed feedback to the editor", { timeout: 30_000 }, async () => { | |
| const adminId = "11111111-1111-4111-8111-111111111111"; | |
| const ownerId = "22222222-2222-4222-8222-222222222222"; | |
| const sessionId = "33333333-3333-4333-8333-333333333333"; | |
| const actionId = "44444444-4444-4444-8444-444444444444"; | |
| const user = { id: adminId, email: "admin@example.com", email_confirmed_at: new Date().toISOString(), user_metadata: {} }; | |
| const savedReviews: Array<Record<string, unknown>> = []; | |
| let oldNotes = ["Original feedback"]; | |
| const upstream = createServer(async (req, res) => { | |
| const url = new URL(req.url!, "http://stub"); | |
| res.setHeader("Content-Type", "application/json"); | |
| if (url.pathname === "/auth/v1/user") return res.end(JSON.stringify(user)); | |
| if (url.pathname === "/rest/v1/users") return res.end(JSON.stringify({ user_id: adminId, account_role: "admin" })); | |
| if (url.pathname === "/rest/v1/sessions") return res.end(JSON.stringify({ status: "completed" })); | |
| if (url.pathname === "/rest/v1/annotations" && req.method === "GET") { | |
| return res.end(JSON.stringify({ user_id: ownerId, score: 5, annotations_notes: oldNotes.map((note) => ({ note })) })); | |
| } | |
| if (url.pathname === "/rest/v1/rpc/save_action_review") { | |
| const chunks: Buffer[] = []; | |
| for await (const chunk of req) chunks.push(Buffer.from(chunk)); | |
| const body = JSON.parse(Buffer.concat(chunks).toString()) as Record<string, unknown>; | |
| savedReviews.push(body); | |
| oldNotes = body.p_notes as string[]; | |
| return res.end("null"); | |
| } | |
| if (url.pathname === `/api/sessions/${sessionId}/actions/${actionId}` && req.method === "PATCH") return res.end("{}"); | |
| res.statusCode = 404; | |
| return res.end(JSON.stringify({ error: "Unexpected mock request", path: url.pathname })); | |
| }); | |
| upstream.listen(0, "127.0.0.1"); | |
| await once(upstream, "listening"); | |
| const portProbe = createServer(); | |
| portProbe.listen(0, "127.0.0.1"); | |
| await once(portProbe, "listening"); | |
| const port = (portProbe.address() as AddressInfo).port; | |
| await new Promise<void>((resolve) => portProbe.close(() => resolve())); | |
| const origin = `http://127.0.0.1:${port}`; | |
| const upstreamOrigin = `http://127.0.0.1:${(upstream.address() as AddressInfo).port}`; | |
| const child = spawn(process.execPath, ["--import", "tsx", "src/server.ts"], { | |
| env: { ...process.env, NODE_ENV: "test", PORT: String(port), FRONTEND_URL: origin, BACKEND_URL: origin, | |
| ANALYSIS_API_URL: upstreamOrigin, SUPABASE_URL: upstreamOrigin, | |
| SUPABASE_ANON_KEY: "test-anon", SUPABASE_SERVICE_ROLE_KEY: "test-service", ANALYSIS_PROXY_SECRET: "x".repeat(32) }, | |
| stdio: ["ignore", "pipe", "pipe"], | |
| }); | |
| try { | |
| await new Promise<void>((resolve, reject) => { | |
| child.stdout.on("data", (data) => { if (String(data).includes("API listening")) resolve(); }); | |
| child.once("exit", (code) => reject(new Error(`API exited: ${code}`))); | |
| child.once("error", reject); | |
| }); | |
| const save = (notes: string[]) => fetch(`${origin}/api/admin/sessions/${sessionId}/actions/${actionId}`, { | |
| method: "PATCH", signal: AbortSignal.timeout(10000), | |
| headers: { Cookie: "sp_access=access", Origin: origin, "Content-Type": "application/json" }, | |
| body: JSON.stringify({ startFrame: 0, endFrame: 10, type: "Shoot", score: 5, notes }), | |
| }); | |
| assert.equal((await save(["Original feedback"])).status, 200); | |
| assert.equal(savedReviews.length, 0, "an action-only edit must preserve the previous feedback author"); | |
| assert.equal((await save(["Updated feedback"])).status, 200); | |
| assert.equal(savedReviews.length, 1); | |
| assert.equal(savedReviews[0].p_user_id, adminId); | |
| assert.deepEqual(savedReviews[0].p_notes, ["Updated feedback"]); | |
| assert.equal(savedReviews[0].p_session_id, sessionId); | |
| assert.equal(savedReviews[0].p_action_id, actionId); | |
| } finally { | |
| if (child.exitCode === null && child.signalCode === null) { | |
| const exited = once(child, "exit"); | |
| child.kill(); | |
| await exited; | |
| } | |
| upstream.closeAllConnections(); | |
| await new Promise<void>((resolve) => upstream.close(() => resolve())); | |
| } | |
| }); | |