[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_167":168,"_169":170},"routes/_app.x.$handle.$name",{"_95":94,"_33":46,"_103":85,"_28":104,"_13":14,"_105":-5,"_11":106,"_107":108,"_109":110,"_111":112,"_113":114,"_20":-5,"_115":-5,"_116":-5,"_117":27,"_118":119,"_120":25,"_121":-5,"_122":-5,"_123":124},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_44":45,"_33":46,"_39":47,"_48":-5,"_49":27,"_50":51,"_52":51,"_53":-5,"_54":-5,"_18":55,"_56":-5,"_57":27,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":27},"version",11,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":27,"_28":29,"_30":29},"file",{"_31":32,"_33":29,"_34":35,"_36":38,"_39":40,"_41":14,"_42":43,"_24":27},"previous",{"_31":32,"_33":29,"_34":35,"_36":37},"deleted",true,"deletedHere",false,"path","TalentFlow.ts","latestPath","fileId","96e8b9ec-2f9e-11f1-8fe7-42dde27851f2","name","fileType","script","content","import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n\n// ─── Schema bootstrap ────────────────────────────────────────────────────────\n\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS sessions (\n id TEXT PRIMARY KEY,\n job_id TEXT,\n job_title TEXT,\n company_name TEXT,\n top_n INTEGER NOT NULL DEFAULT 5,\n hiring_manager_email TEXT,\n session_deadline TEXT,\n completed_count INTEGER NOT NULL DEFAULT 0,\n status TEXT NOT NULL DEFAULT 'in_progress',\n final_report TEXT,\n created_at TEXT NOT NULL,\n completed_at TEXT\n )\n`);\n\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS candidates (\n session_id TEXT NOT NULL,\n candidate_id TEXT NOT NULL,\n name TEXT,\n email TEXT,\n phone TEXT,\n match_score REAL,\n cv_summary TEXT,\n status TEXT NOT NULL DEFAULT 'shortlisted',\n overall_score REAL,\n verdict TEXT,\n excluded_at TEXT,\n updated_at TEXT,\n PRIMARY KEY (session_id, candidate_id)\n )\n`);\n\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS interview_results (\n session_id TEXT NOT NULL,\n candidate_id TEXT NOT NULL,\n candidate_name TEXT,\n candidate_email TEXT,\n job_title TEXT,\n cv_match_score REAL,\n overall_score REAL,\n verdict TEXT,\n interview_analysis TEXT,\n interviewed_at TEXT NOT NULL,\n PRIMARY KEY (session_id, candidate_id)\n )\n`);\n\n// ─── Helpers ─────────────────────────────────────────────────────────────────\n\nfunction json(data: unknown, status = 200): Response {\n return new Response(JSON.stringify(data), {\n status,\n headers: { \"Content-Type\": \"application/json\" },\n });\n}\n\nfunction err(msg: string, status = 400): Response {\n return json({ error: msg }, status);\n}\n\n// Parse :param from a URL pattern like /sessions/:id/results\nfunction match(\n pathname: string,\n pattern: string,\n): Record | null {\n const patParts = pattern.split(\"/\");\n const urlParts = pathname.split(\"/\");\n if (patParts.length !== urlParts.length) return null;\n const params: Record = {};\n for (let i = 0; i < patParts.length; i++) {\n if (patParts[i].startsWith(\":\")) {\n params[patParts[i].slice(1)] = decodeURIComponent(urlParts[i]);\n } else if (patParts[i] !== urlParts[i]) {\n return null;\n }\n }\n return params;\n}\n\n// ─── Route handlers ───────────────────────────────────────────────────────────\n\n// POST /sessions\n// Body: { id (= temporal run_id), job_id, job_title, company_name, top_n,\n// candidates[], hiring_manager_email, session_deadline }\nasync function createSession(req: Request): Promise {\n const body = await req.json();\n const {\n id,\n job_id,\n job_title,\n company_name,\n top_n = 5,\n candidates = [],\n hiring_manager_email,\n session_deadline,\n } = body;\n\n if (!id) return err(\"id (temporal run_id) is required\");\n\n const now = new Date().toISOString();\n\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO sessions\n (id, job_id, job_title, company_name, top_n, hiring_manager_email,\n session_deadline, completed_count, status, created_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, 0, 'in_progress', ?)`,\n args: [\n id,\n job_id,\n job_title,\n company_name,\n top_n,\n hiring_manager_email,\n session_deadline,\n now,\n ],\n });\n\n // Insert shortlisted candidates\n for (const c of candidates) {\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO candidates\n (session_id, candidate_id, name, email, phone,\n match_score, cv_summary, status, updated_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, 'shortlisted', ?)`,\n args: [\n id,\n c.candidate_id,\n c.name,\n c.email,\n c.phone,\n c.match_score,\n c.cv_summary ?? null,\n now,\n ],\n });\n }\n\n return json({\n session_id: id,\n status: \"created\",\n candidates_count: candidates.length,\n }, 201);\n}\n\n// GET /sessions/:id\nasync function getSession(id: string): Promise {\n const sessionRows = await sqlite.execute({\n sql: \"SELECT * FROM sessions WHERE id = ?\",\n args: [id],\n });\n if (!sessionRows.rows.length) return err(\"Session not found\", 404);\n\n const cols = sessionRows.columns;\n const row = sessionRows.rows[0];\n const session: Record = {};\n cols.forEach((c, i) => {\n session[c] = row[i];\n });\n\n // Parse final_report if present\n if (session.final_report) {\n try {\n session.final_report = JSON.parse(session.final_report as string);\n } catch { /* leave as string */ }\n }\n\n // Attach candidates\n const candRows = await sqlite.execute({\n sql:\n \"SELECT * FROM candidates WHERE session_id = ? ORDER BY match_score DESC\",\n args: [id],\n });\n const candCols = candRows.columns;\n session.candidates = candRows.rows.map((r) => {\n const c: Record = {};\n candCols.forEach((col, i) => {\n c[col] = r[i];\n });\n return c;\n });\n\n return json(session);\n}\n\n// PATCH /sessions/:id\n// Body: { status?, completed_at?, final_report? }\nasync function updateSession(id: string, req: Request): Promise {\n const body = await req.json();\n const fields: string[] = [];\n const args: unknown[] = [];\n\n if (body.status !== undefined) {\n fields.push(\"status = ?\");\n args.push(body.status);\n }\n if (body.completed_at !== undefined) {\n fields.push(\"completed_at = ?\");\n args.push(body.completed_at);\n }\n if (body.final_report !== undefined) {\n fields.push(\"final_report = ?\");\n args.push(\n typeof body.final_report === \"string\"\n ? body.final_report\n : JSON.stringify(body.final_report),\n );\n }\n\n if (!fields.length) return err(\"No updatable fields provided\");\n\n args.push(id);\n await sqlite.execute({\n sql: `UPDATE sessions SET ${fields.join(\", \")} WHERE id = ?`,\n args,\n });\n\n return json({ session_id: id, updated: true });\n}\n\n// POST /sessions/:id/results\n// Body: { candidate_id, candidate_name, candidate_email, job_title,\n// cv_match_score, overall_score, verdict, interview_analysis }\nasync function addResult(id: string, req: Request): Promise {\n const body = await req.json();\n const {\n candidate_id,\n candidate_name,\n candidate_email,\n job_title,\n cv_match_score,\n overall_score,\n verdict,\n interview_analysis,\n } = body;\n\n if (!candidate_id) return err(\"candidate_id is required\");\n\n const now = new Date().toISOString();\n\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO interview_results\n (session_id, candidate_id, candidate_name, candidate_email, job_title,\n cv_match_score, overall_score, verdict, interview_analysis, interviewed_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n id,\n candidate_id,\n candidate_name,\n candidate_email,\n job_title,\n cv_match_score,\n overall_score,\n verdict,\n typeof interview_analysis === \"string\"\n ? interview_analysis\n : JSON.stringify(interview_analysis),\n now,\n ],\n });\n\n return json({ session_id: id, candidate_id, stored: true }, 201);\n}\n\n// GET /sessions/:id/results\nasync function getResults(id: string): Promise {\n const rows = await sqlite.execute({\n sql: `SELECT * FROM interview_results\n WHERE session_id = ?\n ORDER BY overall_score DESC NULLS LAST`,\n args: [id],\n });\n\n const cols = rows.columns;\n const results = rows.rows.map((r) => {\n const res: Record = {};\n cols.forEach((c, i) => {\n res[c] = r[i];\n });\n // Parse interview_analysis JSON\n if (res.interview_analysis && typeof res.interview_analysis === \"string\") {\n try {\n res.interview_analysis = JSON.parse(res.interview_analysis as string);\n } catch { /* leave as string */ }\n }\n return res;\n });\n\n return json({ session_id: id, results, count: results.length });\n}\n\n// PATCH /sessions/:id/candidates/:candidate_id\n// Body: { status?, overall_score?, verdict?, excluded_at? }\nasync function updateCandidate(\n sessionId: string,\n candidateId: string,\n req: Request,\n): Promise {\n const body = await req.json();\n const fields: string[] = [];\n const args: unknown[] = [];\n const now = new Date().toISOString();\n\n if (body.status !== undefined) {\n fields.push(\"status = ?\");\n args.push(body.status);\n }\n if (body.overall_score !== undefined) {\n fields.push(\"overall_score = ?\");\n args.push(body.overall_score);\n }\n if (body.verdict !== undefined) {\n fields.push(\"verdict = ?\");\n args.push(body.verdict);\n }\n if (body.excluded_at !== undefined) {\n fields.push(\"excluded_at = ?\");\n args.push(body.excluded_at);\n }\n\n fields.push(\"updated_at = ?\");\n args.push(now);\n args.push(sessionId);\n args.push(candidateId);\n\n await sqlite.execute({\n sql: `UPDATE candidates SET ${fields.join(\", \")}\n WHERE session_id = ? AND candidate_id = ?`,\n args,\n });\n\n return json({\n session_id: sessionId,\n candidate_id: candidateId,\n updated: true,\n });\n}\n\n// POST /sessions/:id/complete\n// Body: { candidate_id }\n// Atomically increments completed_count.\n// Returns { completed_count, top_n, all_done } so the caller knows\n// whether to fire the aggregation_ready signal.\nasync function markComplete(id: string, req: Request): Promise {\n const body = await req.json();\n const { candidate_id } = body;\n\n // SQLite UPDATE with RETURNING gives us the new value atomically\n const result = await sqlite.execute({\n sql: `UPDATE sessions\n SET completed_count = completed_count + 1\n WHERE id = ?\n RETURNING completed_count, top_n`,\n args: [id],\n });\n\n if (!result.rows.length) return err(\"Session not found\", 404);\n\n const completed_count = result.rows[0][0] as number;\n const top_n = result.rows[0][1] as number;\n const all_done = completed_count >= top_n;\n\n return json({\n session_id: id,\n candidate_id,\n completed_count,\n top_n,\n all_done,\n });\n}\n\n// ─── Router ───────────────────────────────────────────────────────────────────\n\nexport default async function handler(req: Request): Promise {\n const url = new URL(req.url);\n const p = url.pathname; // e.g. \"/sessions/abc123/results\"\n const m = req.method;\n\n // CORS headers for UI polling\n if (m === \"OPTIONS\") {\n return new Response(null, {\n headers: {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, PATCH, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type\",\n },\n });\n }\n\n let params: Record | null;\n\n // POST /sessions\n if (m === \"POST\" && p === \"/sessions\") {\n return createSession(req);\n }\n\n // GET /sessions/:id\n if (m === \"GET\" && (params = match(p, \"/sessions/:id\"))) {\n return getSession(params.id);\n }\n\n // PATCH /sessions/:id\n if (m === \"PATCH\" && (params = match(p, \"/sessions/:id\"))) {\n return updateSession(params.id, req);\n }\n\n // POST /sessions/:id/results\n if (m === \"POST\" && (params = match(p, \"/sessions/:id/results\"))) {\n return addResult(params.id, req);\n }\n\n // GET /sessions/:id/results\n if (m === \"GET\" && (params = match(p, \"/sessions/:id/results\"))) {\n return getResults(params.id);\n }\n\n // PATCH /sessions/:id/candidates/:candidate_id\n if (\n m === \"PATCH\" &&\n (params = match(p, \"/sessions/:id/candidates/:candidate_id\"))\n ) {\n return updateCandidate(params.id, params.candidate_id, req);\n }\n\n // POST /sessions/:id/complete\n if (m === \"POST\" && (params = match(p, \"/sessions/:id/complete\"))) {\n return markComplete(params.id, req);\n }\n\n return err(\"Not found\", 404);\n}","import { sqlite } from \"https://esm.town/v/std/sqlite\";\n\n// ─── Schema bootstrap ────────────────────────────────────────────────────────\n\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS sessions (\n id TEXT PRIMARY KEY,\n job_id TEXT,\n job_title TEXT,\n company_name TEXT,\n top_n INTEGER NOT NULL DEFAULT 5,\n hiring_manager_email TEXT,\n session_deadline TEXT,\n completed_count INTEGER NOT NULL DEFAULT 0,\n status TEXT NOT NULL DEFAULT 'in_progress',\n final_report TEXT,\n created_at TEXT NOT NULL,\n completed_at TEXT\n )\n`);\n\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS candidates (\n session_id TEXT NOT NULL,\n candidate_id TEXT NOT NULL,\n name TEXT,\n email TEXT,\n phone TEXT,\n match_score REAL,\n cv_summary TEXT,\n status TEXT NOT NULL DEFAULT 'shortlisted',\n overall_score REAL,\n verdict TEXT,\n excluded_at TEXT,\n updated_at TEXT,\n PRIMARY KEY (session_id, candidate_id)\n )\n`);\n\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS interview_results (\n session_id TEXT NOT NULL,\n candidate_id TEXT NOT NULL,\n candidate_name TEXT,\n candidate_email TEXT,\n job_title TEXT,\n cv_match_score REAL,\n overall_score REAL,\n verdict TEXT,\n interview_analysis TEXT,\n interviewed_at TEXT NOT NULL,\n PRIMARY KEY (session_id, candidate_id)\n )\n`);\n\n// ─── Helpers ─────────────────────────────────────────────────────────────────\n\nconst CORS = {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, PATCH, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type\",\n};\n\nfunction ok(data: Record, status = 200): Response {\n return new Response(JSON.stringify({ ok: true, ...data }), {\n status,\n headers: { \"Content-Type\": \"application/json\", ...CORS },\n });\n}\n\nfunction fail(error: string, status = 400): Response {\n return new Response(JSON.stringify({ ok: false, error }), {\n status,\n headers: { \"Content-Type\": \"application/json\", ...CORS },\n });\n}\n\nasync function parseBody(\n req: Request,\n): Promise | null> {\n try {\n const text = await req.text();\n if (!text) return {};\n return JSON.parse(text);\n } catch {\n return null;\n }\n}\n\n// Parse URL params — e.g. match(\"/sessions/abc/results\", \"/sessions/:id/results\")\nfunction matchPath(\n pathname: string,\n pattern: string,\n): Record | null {\n const pp = pattern.split(\"/\");\n const up = pathname.replace(/\\/$/, \"\").split(\"/\");\n if (pp.length !== up.length) return null;\n const params: Record = {};\n for (let i = 0; i < pp.length; i++) {\n if (pp[i].startsWith(\":\")) {\n params[pp[i].slice(1)] = decodeURIComponent(up[i]);\n } else if (pp[i] !== up[i]) return null;\n }\n return params;\n}\n\nfunction rowsToObjects(\n columns: string[],\n rows: unknown[][],\n): Record[] {\n return rows.map((r) => {\n const obj: Record = {};\n columns.forEach((c, i) => {\n obj[c] = r[i];\n });\n return obj;\n });\n}\n\n// ─── Handlers ────────────────────────────────────────────────────────────────\n\n// POST /sessions\n// id = temporal run_id (set by the workflow via {{temporal_execution_id}})\nasync function createSession(req: Request): Promise {\n const body = await parseBody(req);\n if (!body) return fail(\"Invalid JSON body\");\n\n const {\n id,\n job_id,\n job_title,\n company_name,\n top_n = 5,\n candidates = [],\n hiring_manager_email,\n session_deadline,\n } = body as Record;\n\n if (!id) return fail(\"id (= temporal_execution_id) is required\");\n\n const now = new Date().toISOString();\n\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO sessions\n (id, job_id, job_title, company_name, top_n, hiring_manager_email,\n session_deadline, completed_count, status, created_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, 0, 'in_progress', ?)`,\n args: [\n id as string,\n (job_id ?? null) as string,\n (job_title ?? null) as string,\n (company_name ?? null) as string,\n top_n as number,\n (hiring_manager_email ?? null) as string,\n (session_deadline ?? null) as string,\n now,\n ],\n });\n\n for (const c of (candidates as Record[])) {\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO candidates\n (session_id, candidate_id, name, email, phone,\n match_score, cv_summary, status, updated_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, 'shortlisted', ?)`,\n args: [\n id as string,\n c.candidate_id as string,\n (c.name ?? null) as string,\n (c.email ?? null) as string,\n (c.phone ?? null) as string,\n (c.match_score ?? null) as number,\n (c.cv_summary ?? null) as string,\n now,\n ],\n });\n }\n\n return ok({\n session_id: id,\n candidates_count: (candidates as unknown[]).length,\n }, 201);\n}\n\n// GET /sessions/:id\nasync function getSession(id: string): Promise {\n const sr = await sqlite.execute({\n sql: \"SELECT * FROM sessions WHERE id = ?\",\n args: [id],\n });\n if (!sr.rows.length) return fail(\"Session not found\", 404);\n\n const session = rowsToObjects(sr.columns, sr.rows as unknown[][])[0];\n if (session.final_report && typeof session.final_report === \"string\") {\n try {\n session.final_report = JSON.parse(session.final_report);\n } catch { /* ok */ }\n }\n\n const cr = await sqlite.execute({\n sql:\n \"SELECT * FROM candidates WHERE session_id = ? ORDER BY match_score DESC\",\n args: [id],\n });\n session.candidates = rowsToObjects(cr.columns, cr.rows as unknown[][]);\n\n return ok({ session });\n}\n\n// PATCH /sessions/:id\nasync function updateSession(id: string, req: Request): Promise {\n const body = await parseBody(req);\n if (!body) return fail(\"Invalid JSON body\");\n\n const fields: string[] = [];\n const args: unknown[] = [];\n\n if (\"status\" in body) {\n fields.push(\"status = ?\");\n args.push(body.status);\n }\n if (\"completed_at\" in body) {\n fields.push(\"completed_at = ?\");\n args.push(body.completed_at);\n }\n if (\"final_report\" in body) {\n fields.push(\"final_report = ?\");\n args.push(\n typeof body.final_report === \"string\"\n ? body.final_report\n : JSON.stringify(body.final_report),\n );\n }\n\n if (!fields.length) return fail(\"No updatable fields provided\");\n\n args.push(id);\n await sqlite.execute({\n sql: `UPDATE sessions SET ${fields.join(\", \")} WHERE id = ?`,\n args,\n });\n\n return ok({ session_id: id, updated: true });\n}\n\n// POST /sessions/:id/results\nasync function addResult(id: string, req: Request): Promise {\n const body = await parseBody(req);\n if (!body) return fail(\"Invalid JSON body\");\n\n const {\n candidate_id,\n candidate_name,\n candidate_email,\n job_title,\n cv_match_score,\n overall_score,\n verdict,\n interview_analysis,\n } = body as Record;\n\n if (!candidate_id) return fail(\"candidate_id is required\");\n\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO interview_results\n (session_id, candidate_id, candidate_name, candidate_email,\n job_title, cv_match_score, overall_score, verdict,\n interview_analysis, interviewed_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n id,\n candidate_id as string,\n (candidate_name ?? null) as string,\n (candidate_email ?? null) as string,\n (job_title ?? null) as string,\n (cv_match_score ?? null) as number,\n (overall_score ?? null) as number,\n (verdict ?? null) as string,\n typeof interview_analysis === \"string\"\n ? interview_analysis\n : JSON.stringify(interview_analysis ?? null),\n new Date().toISOString(),\n ],\n });\n\n return ok({ session_id: id, candidate_id, stored: true }, 201);\n}\n\n// GET /sessions/:id/results\nasync function getResults(id: string): Promise {\n const r = await sqlite.execute({\n sql: `SELECT * FROM interview_results\n WHERE session_id = ?\n ORDER BY overall_score DESC`,\n args: [id],\n });\n\n const results = rowsToObjects(r.columns, r.rows as unknown[][]).map((res) => {\n if (res.interview_analysis && typeof res.interview_analysis === \"string\") {\n try {\n res.interview_analysis = JSON.parse(res.interview_analysis);\n } catch { /* ok */ }\n }\n return res;\n });\n\n return ok({ session_id: id, results, count: results.length });\n}\n\n// PATCH /sessions/:id/candidates/:candidate_id\nasync function updateCandidate(\n sessionId: string,\n candidateId: string,\n req: Request,\n): Promise {\n const body = await parseBody(req);\n if (!body) return fail(\"Invalid JSON body\");\n\n const fields: string[] = [];\n const args: unknown[] = [];\n\n if (\"status\" in body) {\n fields.push(\"status = ?\");\n args.push(body.status);\n }\n if (\"overall_score\" in body) {\n fields.push(\"overall_score = ?\");\n args.push(body.overall_score);\n }\n if (\"verdict\" in body) {\n fields.push(\"verdict = ?\");\n args.push(body.verdict);\n }\n if (\"excluded_at\" in body) {\n fields.push(\"excluded_at = ?\");\n args.push(body.excluded_at);\n }\n\n fields.push(\"updated_at = ?\");\n args.push(new Date().toISOString(), sessionId, candidateId);\n\n await sqlite.execute({\n sql: `UPDATE candidates SET ${fields.join(\", \")}\n WHERE session_id = ? AND candidate_id = ?`,\n args,\n });\n\n return ok({\n session_id: sessionId,\n candidate_id: candidateId,\n updated: true,\n });\n}\n\n// POST /sessions/:id/complete\n// Atomically increments completed_count.\n// Returns { completed_count, top_n, all_done } so the candidate workflow\n// knows whether to fire the aggregation_ready signal to the parent.\nasync function markComplete(id: string, req: Request): Promise {\n const body = await parseBody(req);\n if (!body) return fail(\"Invalid JSON body\");\n\n const result = await sqlite.execute({\n sql: `UPDATE sessions\n SET completed_count = completed_count + 1\n WHERE id = ?\n RETURNING completed_count, top_n`,\n args: [id],\n });\n\n if (!result.rows.length) return fail(\"Session not found\", 404);\n\n const completed_count = result.rows[0][0] as number;\n const top_n = result.rows[0][1] as number;\n const all_done = completed_count >= top_n;\n\n return ok({\n session_id: id,\n candidate_id: (body as Record).candidate_id,\n completed_count,\n top_n,\n all_done,\n });\n}\n\n// ─── Router ───────────────────────────────────────────────────────────────────\n\nexport default async function handler(req: Request): Promise {\n if (req.method === \"OPTIONS\") {\n return new Response(null, { status: 204, headers: CORS });\n }\n\n const { pathname } = new URL(req.url);\n const m = req.method;\n let p: Record | null;\n\n try {\n // Health check\n if (pathname === \"/\" || pathname === \"\") {\n return ok({ service: \"TalentFlow val.town\", status: \"ok\" });\n }\n\n if (m === \"POST\" && pathname === \"/sessions\") {\n return createSession(req);\n }\n\n if (m === \"GET\" && (p = matchPath(pathname, \"/sessions/:id\"))) {\n return getSession(p.id);\n }\n\n if (m === \"PATCH\" && (p = matchPath(pathname, \"/sessions/:id\"))) {\n return updateSession(p.id, req);\n }\n\n if (m === \"POST\" && (p = matchPath(pathname, \"/sessions/:id/results\"))) {\n return addResult(p.id, req);\n }\n\n if (m === \"GET\" && (p = matchPath(pathname, \"/sessions/:id/results\"))) {\n return getResults(p.id);\n }\n\n if (\n m === \"PATCH\" &&\n (p = matchPath(pathname, \"/sessions/:id/candidates/:candidate_id\"))\n ) {\n return updateCandidate(p.id, p.candidate_id, req);\n }\n\n if (m === \"POST\" && (p = matchPath(pathname, \"/sessions/:id/complete\"))) {\n return markComplete(p.id, req);\n }\n\n return fail(\"Not found\", 404);\n } catch (e) {\n console.error(e);\n return fail(e instanceof Error ? e.message : \"Internal server error\", 500);\n }\n}","createdAt",["D",1775249901028],"branchVersion","branchId","21307032-2e86-11f1-994a-42dde27851f2","id","212fabd4-2e86-11f1-994a-42dde27851f2","untitled-1279",["D",1775128904245],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","019be3ee-b210-72df-b0b7-1c63b5f83da1","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019be3ee-b210-72df-b0b7-20f942b1694c","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_95":94,"_102":98},"org",{"_95":94,"_96":-5,"_97":98,"_18":55,"_99":100,"_101":27},"branch",{"_13":84,"_33":85,"_44":43,"_86":45,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":46,"_93":94},"isOwned",21,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","gflow","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzM4YjVwUVVEZWJ2b0RPYVpYSHBhNXRUQmEwdSJ9","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_44":45,"_33":46,"_39":163,"_48":-5,"_49":27,"_50":51,"_52":51,"_53":-5,"_54":-5,"_18":55,"_56":-5,"_57":27,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":164,"_79":165,"_81":166,"_83":27},"tree",[154,155],"files",[154,155],"counts",{"_143":61,"_144":145,"_146":61,"_147":148,"_149":150},"contents",[125,126],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_44":139,"_33":29,"_31":32,"_130":-5,"_42":43,"_41":14,"_132":27,"_39":140,"_13":141,"_34":35,"_36":38,"_24":27,"_137":-5,"_28":142},{"_44":127,"_33":128,"_31":129,"_130":-5,"_42":43,"_41":131,"_132":25,"_39":133,"_13":134,"_34":135,"_36":136,"_24":27,"_137":-5,"_28":138},"ae001fe8-2e87-11f1-a882-42dde27851f2","whproxy.ts","2133faf4-2e86-11f1-994a-42dde27851f2","parentId",7,"latest",["D",1775129569979],6,"http","export default async function handler(req: Request): Promise {\n const GENIE_TOKEN = Deno.env.get(\"GENIE_TOKEN\") ?? \"\";\n const GENIE_URL =\n \"https://aubergenie-api.prod.deep.atlas-platform.io/api/webhook/5250dec3-e490-4225-b77e-cf856cfece48\";\n\n // Guard: empty body (e.g. Val.town test runner GET)\n const rawBody = await req.text();\n if (!rawBody || rawBody.trim() === \"\") {\n return new Response(JSON.stringify({ ok: false, error: \"Empty body\" }), {\n status: 400,\n });\n }\n\n let parsed: any;\n try {\n parsed = JSON.parse(rawBody);\n } catch (e) {\n return new Response(JSON.stringify({ ok: false, error: \"Invalid JSON\" }), {\n status: 400,\n });\n }\n\n // Swallow PING so cal.com marks webhook healthy\n if (parsed.triggerEvent === \"PING\") {\n return new Response(JSON.stringify({ ok: true }), { status: 200 });\n }\n\n await fetch(GENIE_URL, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"Authorization\": `Bearer ${GENIE_TOKEN}`,\n },\n body: rawBody, // forward original body as-is\n });\n\n return new Response(\"ok\", { status: 200 });\n}","label",[128],"d8e5f214-2f9f-11f1-acb5-42dde27851f2",["D",1775249901028],3,[29],"pulls","branches",1,"forks","envVars",{"_151":145,"_153":61},"connections",{"_151":61,"_152":61},"count","unfilledCount","emptyCount",{"_44":139,"_33":29,"_31":32,"_130":-5,"_42":43,"_41":14,"_132":27,"_39":160,"_13":141,"_34":35,"_36":38,"_24":27,"_137":-5,"_157":161,"_28":162},{"_44":127,"_33":128,"_31":129,"_130":-5,"_42":43,"_41":131,"_132":25,"_39":156,"_13":134,"_34":135,"_36":136,"_24":27,"_137":-5,"_157":158,"_28":159},["D",1775129569979],"children",[],[128],["D",1775249901028],[],[29],["D",1775128904245],{"_95":94,"_102":98},{"_95":94,"_96":-5,"_97":98,"_18":55,"_99":100,"_101":27},{"_13":84,"_33":85,"_44":43,"_86":45,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":46,"_93":94},"ctx",{"_77":-5,"_122":200,"_201":202,"_203":204,"_205":27,"_206":27,"_207":27,"_208":25,"_209":-5,"_210":-7,"_211":-7,"_212":61,"_213":27,"_214":27,"_215":-5,"_216":27,"_217":27,"_218":27,"_219":-5},"ENV",{"_171":172,"_173":174,"_175":85,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197,"_198":199},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v11