[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_166":167,"_168":169},"routes/_app.x.$handle.$name",{"_94":93,"_32":45,"_102":84,"_27":103,"_13":14,"_104":-5,"_11":105,"_106":107,"_108":109,"_110":111,"_112":113,"_20":-5,"_114":-5,"_115":-5,"_116":25,"_117":118,"_119":120,"_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",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":77,"_78":79,"_80":81,"_82":25},"version",19,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_34":35,"_36":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":33,"_34":35,"_36":37},"deleted",false,"deletedHere","path","Talentflow.ts","latestPath","fileId","275d2d3e-2fa2-11f1-b6ff-42dde27851f2","name","new-file-3620.ts","fileType","http","content","import { blob } from \"https://esm.town/v/std/blob\";\n\n// ─── Types ───────────────────────────────────────────────────────────────────\n\ninterface Candidate {\n candidate_id: string;\n name: string;\n email: string;\n phone: string;\n match_score: number;\n cv_summary: string;\n status:\n | \"shortlisted\"\n | \"invited\"\n | \"booking_confirmed\"\n | \"interviewing\"\n | \"interviewed\"\n | \"excluded\";\n overall_score: number | null;\n verdict: string | null;\n excluded_at: string | null;\n updated_at: string;\n}\n\ninterface Session {\n id: string; // = temporal run_id\n job_id: string;\n job_title: string;\n company_name: string;\n top_n: number;\n hiring_manager_email: string;\n session_deadline: string;\n status: \"in_progress\" | \"completed\";\n candidates: Candidate[];\n final_report: Record | null;\n created_at: string;\n completed_at: string | null;\n}\n\ninterface InterviewResult {\n candidate_id: string;\n candidate_name: string;\n candidate_email: string;\n job_title: string;\n cv_match_score: number;\n overall_score: number;\n verdict: string;\n interview_analysis: Record;\n interviewed_at: string;\n}\n\n// ─── Blob key helpers ────────────────────────────────────────────────────────\n\nconst sessionKey = (id: string) => `talentflow_session_${id}`;\nconst resultsKey = (id: string) => `talentflow_results_${id}`;\n\nasync function getSession(id: string): Promise {\n try {\n return await blob.getJSON(sessionKey(id));\n } catch {\n return null;\n }\n}\n\nasync function saveSession(session: Session): Promise {\n await blob.setJSON(sessionKey(session.id), session);\n}\n\nasync function getResults(id: string): Promise {\n try {\n return (await blob.getJSON(resultsKey(id))) ?? [];\n } catch {\n return [];\n }\n}\n\nasync function saveResults(\n id: string,\n results: InterviewResult[],\n): Promise {\n await blob.setJSON(resultsKey(id), results);\n}\n\n// ─── Response helpers ────────────────────────────────────────────────────────\n\nconst CORS = {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, PATCH, DELETE, 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(req: Request): Promise> {\n try {\n const text = await req.text();\n return text ? JSON.parse(text) : {};\n } catch {\n return {};\n }\n}\n\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\n// ─── Route handlers ───────────────────────────────────────────────────────────\n\n// POST /sessions\n// Called by the Init Session code node in the Hiring Session Workflow.\n// Body: { id (= temporal_execution_id), job_id, job_title, company_name,\n// top_n, candidates[], hiring_manager_email, session_deadline }\nasync function handleCreateSession(req: Request): Promise {\n const body = await parseBody(req);\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 fail(\"id (= temporal_execution_id) is required\");\n\n const now = new Date().toISOString();\n\n const session: Session = {\n id: id as string,\n job_id: (job_id ?? \"\") as string,\n job_title: (job_title ?? \"\") as string,\n company_name: (company_name ?? \"\") as string,\n top_n: Number(top_n),\n hiring_manager_email: (hiring_manager_email ?? \"\") as string,\n session_deadline: (session_deadline ?? \"\") as string,\n status: \"in_progress\",\n candidates: (candidates as Record[]).map((c) => ({\n candidate_id: c.candidate_id as string,\n name: (c.name ?? \"\") as string,\n email: (c.email ?? \"\") as string,\n phone: (c.phone ?? \"\") as string,\n match_score: Number(c.match_score ?? 0),\n cv_summary: (c.cv_summary ?? \"\") as string,\n status: \"shortlisted\",\n overall_score: null,\n verdict: null,\n excluded_at: null,\n updated_at: now,\n })),\n final_report: null,\n created_at: now,\n completed_at: null,\n };\n\n await saveSession(session);\n\n return ok(\n { session_id: id, candidates_count: session.candidates.length },\n 201,\n );\n}\n\n// GET /sessions/:id\n// Polled by the UI to show live pipeline status.\nasync function handleGetSession(id: string): Promise {\n const session = await getSession(id);\n if (!session) return fail(\"Session not found\", 404);\n return ok({ session });\n}\n\n// PATCH /sessions/:id\n// Used by Finalize Session node to mark session complete and store final report.\n// Body: { status?, completed_at?, final_report? }\nasync function handleUpdateSession(\n id: string,\n req: Request,\n): Promise {\n const session = await getSession(id);\n if (!session) return fail(\"Session not found\", 404);\n\n const body = await parseBody(req);\n if (\"status\" in body) session.status = body.status as Session[\"status\"];\n if (\"completed_at\" in body) {\n session.completed_at = body.completed_at as string;\n }\n if (\"final_report\" in body) {\n session.final_report = body.final_report as Record;\n }\n\n await saveSession(session);\n return ok({ session_id: id, updated: true });\n}\n\n// POST /sessions/:id/results\n// Called by the Store Results code node after each interview is analysed.\n// Body: { candidate_id, candidate_name, candidate_email, job_title,\n// cv_match_score, overall_score, verdict, interview_analysis }\nasync function handleAddResult(id: string, req: Request): Promise {\n const session = await getSession(id);\n if (!session) return fail(\"Session not found\", 404);\n\n const body = await parseBody(req);\n if (!body.candidate_id) return fail(\"candidate_id is required\");\n\n const results = await getResults(id);\n\n // Upsert — replace if already exists (e.g. retry scenario)\n const idx = results.findIndex((r) => r.candidate_id === body.candidate_id);\n const result: InterviewResult = {\n candidate_id: body.candidate_id as string,\n candidate_name: (body.candidate_name ?? \"\") as string,\n candidate_email: (body.candidate_email ?? \"\") as string,\n job_title: (body.job_title ?? session.job_title) as string,\n cv_match_score: Number(body.cv_match_score ?? 0),\n overall_score: Number(body.overall_score ?? 0),\n verdict: (body.verdict ?? \"\") as string,\n interview_analysis: (body.interview_analysis ?? {}) as Record<\n string,\n unknown\n >,\n interviewed_at: new Date().toISOString(),\n };\n\n if (idx >= 0) results[idx] = result;\n else results.push(result);\n\n // Sort by overall_score descending so ranked list is always ready\n results.sort((a, b) => b.overall_score - a.overall_score);\n\n await saveResults(id, results);\n\n // Check if all done — no counter needed, just compare result count to top_n\n const deadline_passed = session.session_deadline\n ? new Date().toISOString() >= session.session_deadline\n : false;\n const all_done = results.length >= session.top_n || deadline_passed;\n\n return ok({\n session_id: id,\n candidate_id: body.candidate_id,\n stored: true,\n results_count: results.length,\n top_n: session.top_n,\n all_done,\n }, 201);\n}\n\n// GET /sessions/:id/results\n// Called by the Fetch All Results node in the Hiring Session Workflow\n// after aggregation_ready is received.\nasync function handleGetResults(id: string): Promise {\n const session = await getSession(id);\n if (!session) return fail(\"Session not found\", 404);\n\n const results = await getResults(id);\n return ok({ session_id: id, results, count: results.length });\n}\n\n// PATCH /sessions/:id/candidates/:candidate_id\n// Called to update a candidate's pipeline status at each stage transition.\n// Body: { status?, overall_score?, verdict?, excluded_at? }\nasync function handleUpdateCandidate(\n sessionId: string,\n candidateId: string,\n req: Request,\n): Promise {\n const session = await getSession(sessionId);\n if (!session) return fail(\"Session not found\", 404);\n\n const cand = session.candidates.find((c) => c.candidate_id === candidateId);\n if (!cand) return fail(\"Candidate not found in session\", 404);\n\n const body = await parseBody(req);\n if (\"status\" in body) cand.status = body.status as Candidate[\"status\"];\n if (\"overall_score\" in body) {\n cand.overall_score = body.overall_score as number;\n }\n if (\"verdict\" in body) cand.verdict = body.verdict as string;\n if (\"excluded_at\" in body) cand.excluded_at = body.excluded_at as string;\n cand.updated_at = new Date().toISOString();\n\n await saveSession(session);\n return ok({\n session_id: sessionId,\n candidate_id: candidateId,\n updated: true,\n });\n}\n\n// DELETE /sessions/:id\n// Removes session blob + results blob entirely. Use for cleanup / failed run restarts.\nasync function handleDeleteSession(id: string): Promise {\n const session = await getSession(id);\n if (!session) return fail(\"Session not found\", 404);\n\n await blob.delete(sessionKey(id));\n await blob.delete(resultsKey(id));\n\n return ok({ session_id: id, deleted: true });\n}\n\n// DELETE /sessions/:id/results\n// Clears only the results blob, keeps the session intact.\n// Use when retrying interviews without resetting the whole session.\nasync function handleDeleteResults(id: string): Promise {\n const session = await getSession(id);\n if (!session) return fail(\"Session not found\", 404);\n\n await blob.delete(resultsKey(id));\n\n return ok({ session_id: id, results_cleared: true });\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 if (pathname === \"/\" || pathname === \"\") {\n return ok({ service: \"TalentFlow\", status: \"ok\" });\n }\n\n if (m === \"POST\" && pathname === \"/sessions\") {\n return handleCreateSession(req);\n }\n\n if (m === \"GET\" && (p = matchPath(pathname, \"/sessions/:id\"))) {\n return handleGetSession(p.id);\n }\n\n if (m === \"PATCH\" && (p = matchPath(pathname, \"/sessions/:id\"))) {\n return handleUpdateSession(p.id, req);\n }\n\n if (m === \"POST\" && (p = matchPath(pathname, \"/sessions/:id/results\"))) {\n return handleAddResult(p.id, req);\n }\n\n if (m === \"GET\" && (p = matchPath(pathname, \"/sessions/:id/results\"))) {\n return handleGetResults(p.id);\n }\n\n if (\n m === \"PATCH\" &&\n (p = matchPath(pathname, \"/sessions/:id/candidates/:candidate_id\"))\n ) {\n return handleUpdateCandidate(p.id, p.candidate_id, req);\n }\n\n if (m === \"DELETE\" && (p = matchPath(pathname, \"/sessions/:id/results\"))) {\n return handleDeleteResults(p.id);\n }\n\n if (m === \"DELETE\" && (p = matchPath(pathname, \"/sessions/:id\"))) {\n return handleDeleteSession(p.id);\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",1775251803577],"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",{"_94":93,"_101":97},"org",{"_94":93,"_95":-5,"_96":97,"_18":54,"_98":99,"_100":25},"branch",{"_13":83,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"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",{"_43":44,"_32":45,"_38":162,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":163,"_78":164,"_80":165,"_82":25},"tree",[153,154],"files",[153,154],"counts",{"_142":60,"_143":144,"_145":60,"_146":147,"_148":149},"contents",[125,126],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":138,"_32":28,"_30":31,"_130":-5,"_41":42,"_40":14,"_132":25,"_38":139,"_13":140,"_34":35,"_36":37,"_24":25,"_136":-5,"_27":141},{"_43":127,"_32":128,"_30":129,"_130":-5,"_41":42,"_40":131,"_132":120,"_38":133,"_13":134,"_34":35,"_36":135,"_24":25,"_136":-5,"_27":137},"ae001fe8-2e87-11f1-a882-42dde27851f2","whproxy.ts","2133faf4-2e86-11f1-994a-42dde27851f2","parentId",7,"latest",["D",1775129569979],6,"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],"46e78436-2fa4-11f1-8cdc-42dde27851f2",["D",1775251803577],5,[28],"pulls","branches",1,"forks","envVars",{"_150":144,"_152":60},"connections",{"_150":60,"_151":60},"count","unfilledCount","emptyCount",{"_43":138,"_32":28,"_30":31,"_130":-5,"_41":42,"_40":14,"_132":25,"_38":159,"_13":140,"_34":35,"_36":37,"_24":25,"_136":-5,"_156":160,"_27":161},{"_43":127,"_32":128,"_30":129,"_130":-5,"_41":42,"_40":131,"_132":120,"_38":155,"_13":134,"_34":35,"_36":135,"_24":25,"_136":-5,"_156":157,"_27":158},["D",1775129569979],"children",[],[128],["D",1775251803577],[],[28],["D",1775128904245],{"_94":93,"_101":97},{"_94":93,"_95":-5,"_96":97,"_18":54,"_98":99,"_100":25},{"_13":83,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"ctx",{"_76":-5,"_122":199,"_200":201,"_202":203,"_204":25,"_205":25,"_206":25,"_207":120,"_208":-5,"_209":-7,"_210":-7,"_211":60,"_212":25,"_213":25,"_214":-5,"_215":25,"_216":25,"_217":25,"_218":-5},"ENV",{"_170":171,"_172":173,"_174":84,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","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 · v19