Spaces:
Running
Running
| import assert from "node:assert/strict"; | |
| import { createServer } from "node:http"; | |
| import type { AddressInfo } from "node:net"; | |
| import { test } from "node:test"; | |
| import express from "express"; | |
| import type { SupabaseClient } from "@supabase/supabase-js"; | |
| test("an administrator can start analysis for another user's player", async () => { | |
| Object.assign(process.env, { | |
| NODE_ENV: "test", | |
| FRONTEND_URL: "http://127.0.0.1:3000", | |
| BACKEND_URL: "http://127.0.0.1:4000", | |
| ANALYSIS_PROXY_SECRET: "test-analysis-proxy-secret-32-chars", | |
| SUPABASE_URL: "http://127.0.0.1:54321", | |
| SUPABASE_ANON_KEY: "test-anon-key", | |
| SUPABASE_SERVICE_ROLE_KEY: "test-service-role-key", | |
| }); | |
| const { analysisRouter } = await import("../src/analysis.js"); | |
| const adminId = "11111111-1111-4111-8111-111111111111"; | |
| const ownerId = "22222222-2222-4222-8222-222222222222"; | |
| const playerId = "33333333-3333-4333-8333-333333333333"; | |
| const clientId = "44444444-4444-4444-8444-444444444444"; | |
| const filters: [string, string][] = []; | |
| const rpcCalls: { name: string; args: Record<string, unknown> }[] = []; | |
| const db = { | |
| from(table: string) { | |
| assert.equal(table, "players"); | |
| const query = { | |
| select() { return query; }, | |
| eq(column: string, value: string) { filters.push([column, value]); return query; }, | |
| async maybeSingle() { return { data: { player_id: playerId, user_id: ownerId }, error: null }; }, | |
| }; | |
| return query; | |
| }, | |
| async rpc(name: string, args: Record<string, unknown>) { | |
| rpcCalls.push({ name, args }); | |
| return { error: null }; | |
| }, | |
| } as unknown as SupabaseClient; | |
| const secret = "test-analysis-proxy-secret-32-chars"; | |
| const app = express(); | |
| app.use("/internal/analysis", analysisRouter(db, secret)); | |
| const server = createServer(app); | |
| await new Promise<void>((resolve) => server.listen(0, "127.0.0.1", resolve)); | |
| try { | |
| const port = (server.address() as AddressInfo).port; | |
| const response = await fetch(`http://127.0.0.1:${port}/internal/analysis`, { | |
| method: "POST", | |
| headers: { | |
| "content-type": "application/json", | |
| "x-sporalize-proxy-secret": secret, | |
| "x-sporalize-user-id": adminId, | |
| "x-sporalize-admin": "true", | |
| }, | |
| body: JSON.stringify({ clientId, playerId, name: "Admin analysis" }), | |
| }); | |
| assert.equal(response.status, 200); | |
| assert.deepEqual(await response.json(), { | |
| session_id: clientId, player_id: playerId, user_id: ownerId, | |
| by_admin: true, actor_is_admin: true, | |
| }); | |
| assert.deepEqual(filters, [["player_id", playerId]]); | |
| assert.deepEqual(rpcCalls, [{ name: "admin_create_analysis_session", args: { | |
| p_session_id: clientId, p_user_id: ownerId, p_player_id: playerId, | |
| p_name: "Admin analysis", p_path: `sessions/${clientId}`, p_by_admin: true, | |
| } }]); | |
| } finally { | |
| await new Promise<void>((resolve, reject) => server.close((error) => error ? reject(error) : resolve())); | |
| } | |
| }); | |