Spaces:
Running
Running
File size: 2,987 Bytes
dffa291 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 | 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()));
}
});
|