[{"_1":2,"_245":-5,"_246":-5},"loaderData",{"_3":4,"_95":96,"_218":219},"root",{"_5":6,"_36":37,"_68":69},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":22,"_29":22,"_30":22,"_31":-5,"_32":33,"_34":22,"_35":22},"auth",{"_9":10,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":-5,"_20":-5,"_21":22},"tokenType","session_token","sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"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":22,"_79":76,"_80":76,"_81":76,"_82":76,"_83":84,"_93":22,"_94":22},"__clerk_ssr_state",{"_9":10,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":-5,"_20":-5,"_21":22},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_85":22,"_21":22,"_86":76,"_87":88,"_89":76,"_90":47,"_91":22,"_92":76},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/_app.x.$handle.$name",{"_97":98,"_99":100,"_101":45,"_102":103,"_104":105,"_106":107,"_159":160,"_191":192,"_193":194,"_206":207,"_208":209,"_212":-5,"_213":-5,"_214":22,"_215":22,"_216":217},"handle","gflow","name","untitled-1279","branchName","path","new-file-3620.ts","version",17,"project",{"_108":109,"_99":100,"_110":111,"_112":-5,"_113":22,"_114":115,"_116":-5,"_117":-5,"_14":118,"_119":-5,"_120":22,"_121":-5,"_122":-5,"_123":33,"_16":124,"_125":-5,"_126":-5,"_127":-5,"_128":-5,"_129":130,"_131":130,"_132":133,"_134":133,"_135":133,"_136":130,"_137":130,"_23":138,"_141":142,"_146":147,"_158":22},"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,"_139":140},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzM4YjVwUVVEZWJ2b0RPYVpYSHBhNXRUQmEwdSJ9","org",{"_97":98,"_143":140,"_14":118,"_144":145},"avatar","tier","free","branch",{"_104":148,"_99":45,"_108":149,"_150":109,"_151":-5,"_152":-5,"_153":-5,"_154":-5,"_155":-5,"_156":100,"_157":98},19,"21307032-2e86-11f1-994a-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","tree",[161,180],{"_108":162,"_99":103,"_163":164,"_165":-5,"_166":149,"_167":105,"_168":22,"_110":169,"_104":170,"_171":172,"_173":174,"_175":22,"_176":-5,"_177":178,"_102":179},"2ea3c184-2fa2-11f1-9224-42dde27851f2","fileId","275d2d3e-2fa2-11f1-b6ff-42dde27851f2","parentId","branchId","branchVersion","latest",["D",1775250903877],3,"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, 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// ─── 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 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","children",[],[103],{"_108":181,"_99":182,"_163":183,"_165":-5,"_166":149,"_167":184,"_168":185,"_110":186,"_104":187,"_171":172,"_173":188,"_175":22,"_176":-5,"_177":189,"_102":190},"ae001fe8-2e87-11f1-a882-42dde27851f2","whproxy.ts","2133faf4-2e86-11f1-994a-42dde27851f2",7,true,["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}",[],[182],"files",[161,180],"counts",{"_195":33,"_196":197,"_198":33,"_199":200,"_203":204},"pulls","branches",1,"forks","envVars",{"_201":197,"_202":33},"count","emptyCount","connections",{"_201":33,"_205":33},"unfilledCount","contents",[],"file",{"_108":162,"_99":103,"_163":164,"_165":-5,"_166":149,"_167":105,"_168":22,"_110":210,"_104":170,"_171":172,"_173":174,"_175":22,"_176":-5,"_102":211},["D",1775250903877],[103],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.version.$version.code.$",{"_97":98,"_99":100,"_101":45,"_104":105,"_102":103,"_106":220,"_159":225,"_191":234,"_208":235,"_206":238,"_239":-5,"_240":-5,"_241":-5,"_242":-5,"_243":244,"_199":-5},{"_108":109,"_99":100,"_110":221,"_112":-5,"_113":22,"_114":115,"_116":-5,"_117":-5,"_14":118,"_119":-5,"_120":22,"_121":-5,"_122":-5,"_123":33,"_16":124,"_125":-5,"_126":-5,"_127":-5,"_128":-5,"_129":130,"_131":130,"_132":133,"_134":133,"_135":133,"_136":130,"_137":130,"_23":222,"_141":223,"_146":224,"_158":22},["D",1775128904245],{"_97":98,"_139":140},{"_97":98,"_143":140,"_14":118,"_144":145},{"_104":148,"_99":45,"_108":149,"_150":109,"_151":-5,"_152":-5,"_153":-5,"_154":-5,"_155":-5,"_156":100,"_157":98},[226,230],{"_108":162,"_99":103,"_163":164,"_165":-5,"_166":149,"_167":105,"_168":22,"_110":227,"_104":170,"_171":172,"_173":174,"_175":22,"_176":-5,"_177":228,"_102":229},["D",1775250903877],[],[103],{"_108":181,"_99":182,"_163":183,"_165":-5,"_166":149,"_167":184,"_168":185,"_110":231,"_104":187,"_171":172,"_173":188,"_175":22,"_176":-5,"_177":232,"_102":233},["D",1775129569979],[],[182],[226,230],{"_108":162,"_99":103,"_163":164,"_165":-5,"_166":149,"_167":105,"_168":22,"_110":236,"_104":170,"_171":172,"_173":174,"_175":22,"_176":-5,"_102":237},["D",1775250903877],[103],[],"upstream","pull","ahead","behind","templates",[],"actionData","errors"]