[{"_1":2,"_179":-5,"_180":-5},"loaderData",{"_3":4,"_95":96},"root",{"_5":6,"_36":37,"_68":69},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":-5,"_32":33,"_34":20,"_35":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesChatPanelState","notificationCount",0,"flagDenols","isBusinessOrgMember","ENV",{"_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},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","e57df1da97789090df5b7715fd77dd1717576393","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","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","API_URL","https://api.val.town","clerkState",{"_70":71},"__internal_clerk_state",{"_72":73,"_74":47,"_75":76,"_77":76,"_78":20,"_79":76,"_80":76,"_81":76,"_82":76,"_83":84,"_93":20,"_94":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_85":20,"_19":20,"_86":76,"_87":88,"_89":76,"_90":47,"_91":20,"_92":76},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_97":98,"_99":100,"_101":102,"_103":104,"_157":158,"_176":177,"_178":-5},"handle","gflow","name","untitled-1279","path","Talentflow.ts","project",{"_105":106,"_99":100,"_107":108,"_109":-5,"_110":20,"_111":112,"_113":-5,"_114":-5,"_12":115,"_116":-5,"_117":20,"_118":-5,"_119":-5,"_120":33,"_14":121,"_122":-5,"_123":-5,"_124":-5,"_125":-5,"_126":127,"_128":127,"_129":130,"_131":130,"_132":130,"_133":127,"_134":127,"_23":135,"_138":139,"_143":144,"_156":20},"id","212fabd4-2e86-11f1-994a-42dde27851f2","createdAt",["D",1775128904245],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","019be3ee-b210-72df-b0b7-1c63b5f83da1","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","019be3ee-b210-72df-b0b7-20f942b1694c","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_97":98,"_136":137},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzM4YjVwUVVEZWJ2b0RPYVpYSHBhNXRUQmEwdSJ9","org",{"_97":98,"_140":137,"_12":115,"_141":142},"avatar","tier","free","branch",{"_145":146,"_99":45,"_105":147,"_148":106,"_149":-5,"_150":-5,"_151":-5,"_152":-5,"_153":-5,"_154":100,"_155":98},"version",19,"21307032-2e86-11f1-994a-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_105":159,"_99":102,"_160":161,"_162":-5,"_163":147,"_164":146,"_165":166,"_107":167,"_145":168,"_169":170,"_171":172,"_173":20,"_174":-5,"_101":175},"46e78436-2fa4-11f1-8cdc-42dde27851f2","fileId","275d2d3e-2fa2-11f1-b6ff-42dde27851f2","parentId","branchId","branchVersion","latest",true,["D",1775251803577],5,"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}","deleted","label",[102],"permalink","https://www.val.town/x/gflow/untitled-1279/code/Talentflow.ts","extension","actionData","errors"]