[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_165":166,"_167":168},"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",20,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","Talentflow.ts","latestPath","fileId","275d2d3e-2fa2-11f1-b6ff-42dde27851f2","name","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}","/**\n * RecruitFlow — Val.town HTTP Handler\n *\n * Deploy this as a val on val.town. It stores recruitment job data\n * with candidate tracking, stage progression, and interview results.\n *\n * Endpoints:\n * GET / → List all jobs\n * GET /:jobId → Get single job with full candidate/stage data\n * POST / → Create a new job record\n * PATCH /:jobId → Update job (stages, candidates, status, results)\n * DELETE /:jobId → Delete a single job\n * DELETE / → Delete all jobs\n *\n * GET /candidates → Get the pre-loaded candidate pool\n */\n\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst JOBS_KEY = \"recruitflow_jobs\";\nconst CANDIDATES_KEY = \"recruitflow_candidates\";\n\n// Pre-loaded candidate pool (from PDF resume extracts)\nconst DEFAULT_CANDIDATES = [\n {\n candidate_id: \"CAND-001\",\n name: \"Alexandra Rodriguez\",\n email: \"alexandra.rodriguez@email.com\",\n phone: \"+1-404-555-0189\",\n current_title: \"Senior SDET\",\n current_company: \"QualityFirst Tech\",\n years_of_experience: 6,\n education: [{\n degree: \"B.S. Quality Assurance Engineering\",\n institution: \"Georgia Institute of Technology\",\n year: 2017,\n }],\n skills: [\n \"Python\",\n \"Java\",\n \"JavaScript\",\n \"SQL\",\n \"Selenium WebDriver\",\n \"Appium\",\n \"Cucumber\",\n \"TestNG\",\n \"JUnit\",\n \"REST Assured\",\n \"Postman\",\n \"JMeter\",\n \"Jenkins\",\n \"GitHub Actions\",\n \"Docker\",\n \"MySQL\",\n \"PostgreSQL\",\n \"MongoDB\",\n \"BDD\",\n \"TDD\",\n ],\n experience_summary:\n \"Specialized SDET with 6 years building test automation frameworks and quality infrastructure. Progressed from QA Automation Engineer to Senior SDET, with expertise in end-to-end testing, CI/CD pipeline testing, and performance testing across 50+ microservices.\",\n notable_projects: [\n \"Built test automation infrastructure handling 5000+ automated tests with <5% flakiness\",\n \"Designed parallel test execution framework reducing CI/CD time from 2hrs to 20min\",\n ],\n resume_file: \"Alexandra_Rodriguez_Resume.pdf\",\n },\n {\n candidate_id: \"CAND-002\",\n name: \"Christopher Anderson\",\n email: \"christopher.anderson@email.com\",\n phone: \"+1-617-555-0167\",\n current_title: \"Engineering Manager\",\n current_company: \"FinTechInnovate\",\n years_of_experience: 9,\n education: [{\n degree: \"B.S. Computer Science\",\n institution: \"Massachusetts Institute of Technology (MIT)\",\n year: 2017,\n }],\n skills: [\n \"Python\",\n \"Java\",\n \"TypeScript\",\n \"C#\",\n \"SQL\",\n \"Go\",\n \"Django\",\n \"Spring Boot\",\n \"FastAPI\",\n \"Node.js\",\n \".NET Core\",\n \"PostgreSQL\",\n \"MySQL\",\n \"MongoDB\",\n \"Redis\",\n \"Kafka\",\n \"RabbitMQ\",\n \"Elasticsearch\",\n \"AWS\",\n \"Azure\",\n \"Docker\",\n \"Kubernetes\",\n \"Terraform\",\n ],\n experience_summary:\n \"Engineering Manager with 9 years of full-stack software engineering experience and 3.5 years leading technical teams. Deep expertise in payment processing, trading platforms, and mission-critical financial systems.\",\n notable_projects: [\n \"Led team developing payment processing systems handling $2B+ annually\",\n \"Improved system reliability from 99.9% to 99.99%\",\n ],\n resume_file: \"Christopher_Anderson_Resume.pdf\",\n },\n {\n candidate_id: \"CAND-003\",\n name: \"David Martinez\",\n email: \"david.martinez@email.com\",\n phone: \"+1-303-555-0198\",\n current_title: \"Engineering Manager\",\n current_company: \"InnovateTech Solutions\",\n years_of_experience: 7,\n education: [{\n degree: \"B.S. Computer Engineering\",\n institution: \"University of Colorado Boulder\",\n year: 2017,\n }],\n skills: [\n \"Python\",\n \"Go\",\n \"Java\",\n \"JavaScript\",\n \"C++\",\n \"SQL\",\n \"Django\",\n \"Spring Boot\",\n \"Node.js\",\n \"React\",\n \"FastAPI\",\n \"Kafka\",\n \"RabbitMQ\",\n \"Elasticsearch\",\n \"Redis\",\n \"PostgreSQL\",\n \"MongoDB\",\n \"Kubernetes\",\n \"Docker\",\n \"AWS\",\n \"Terraform\",\n ],\n experience_summary:\n \"Engineering Manager with 7 years of software engineering experience and 3 years leading high-performance teams. Manages a team of 8 engineers delivering a microservices platform serving 5M+ users.\",\n notable_projects: [\n \"Led team of 8 engineers delivering platform serving 5M+ users\",\n \"Architected event-driven system handling 100K+ events/sec using Go and Kafka\",\n ],\n resume_file: \"David_Martinez_Resume.pdf\",\n },\n {\n candidate_id: \"CAND-004\",\n name: \"James Williams\",\n email: \"james.williams@email.com\",\n phone: \"+1-213-555-0156\",\n current_title: \"Lead UX/UI Designer\",\n current_company: \"CreativeStudio Design\",\n years_of_experience: 6,\n education: [{\n degree: \"B.F.A. Graphic Design\",\n institution: \"California Institute of the Arts\",\n year: 2017,\n }],\n skills: [\n \"Figma\",\n \"Adobe XD\",\n \"Sketch\",\n \"Adobe Photoshop\",\n \"Adobe Illustrator\",\n \"User Research\",\n \"Wireframing\",\n \"Prototyping\",\n \"Usability Testing\",\n \"Design Systems\",\n \"A/B Testing\",\n ],\n experience_summary:\n \"Creative UI/UX Designer with 6 years designing digital interfaces. Expertise in user research, design systems, and data-driven design decisions across fintech, healthcare, and e-commerce.\",\n notable_projects: [\n \"Led design for 8+ mobile and web applications\",\n \"Built comprehensive design system used by 25+ designers\",\n ],\n resume_file: \"James_Williams_Resume.pdf\",\n },\n {\n candidate_id: \"CAND-005\",\n name: \"Jennifer Liu\",\n email: \"jennifer.liu@email.com\",\n phone: \"+1-206-555-0142\",\n current_title: \"Engineering Manager\",\n current_company: \"PlatformCore Inc\",\n years_of_experience: 8,\n education: [\n {\n degree: \"M.S. Computer Science\",\n institution: \"University of Washington\",\n year: 2015,\n },\n {\n degree: \"B.S. Mathematics & Computer Science\",\n institution: \"University of British Columbia\",\n year: 2013,\n },\n ],\n skills: [\n \"Python\",\n \"Java\",\n \"JavaScript\",\n \"TypeScript\",\n \"Go\",\n \"SQL\",\n \"Django\",\n \"Spring Boot\",\n \"Node.js\",\n \"React\",\n \"FastAPI\",\n \"Apache Kafka\",\n \"Apache Spark\",\n \"Elasticsearch\",\n \"AWS\",\n \"GCP\",\n \"Kubernetes\",\n \"Docker\",\n \"Terraform\",\n ],\n experience_summary:\n \"Engineering Manager with 8 years of hands-on development and 4 years leading cross-functional teams. Scaled teams from 4 to 12 engineers. Deep expertise in distributed systems, real-time analytics, and big data processing.\",\n notable_projects: [\n \"Led monolith-to-microservices migration (9-month project)\",\n \"Grew team from 4 to 12 engineers with 3 promotions to senior\",\n ],\n resume_file: \"Jennifer_Liu_Resume.pdf\",\n },\n {\n candidate_id: \"CAND-006\",\n name: \"Michael Chen\",\n email: \"michael.chen@email.com\",\n phone: \"+1-415-555-0142\",\n current_title: \"Senior Software Engineer\",\n current_company: \"TechVision Inc.\",\n years_of_experience: 4,\n education: [{\n degree: \"B.S. Computer Science\",\n institution: \"University of California, Berkeley\",\n year: 2019,\n }],\n skills: [\n \"Python\",\n \"JavaScript\",\n \"TypeScript\",\n \"SQL\",\n \"Django\",\n \"Flask\",\n \"Node.js\",\n \"Express\",\n \"React\",\n \"PostgreSQL\",\n \"MongoDB\",\n \"Redis\",\n \"AWS\",\n \"Docker\",\n \"Kubernetes\",\n \"GitHub Actions\",\n ],\n experience_summary:\n \"Software Engineer with 4 years in full-stack web development and backend systems. Expertise in microservices architecture, API development, and performance optimization serving 500K+ daily active users.\",\n notable_projects: [\n \"Developed 5+ microservices serving 500K+ daily active users\",\n \"Implemented Redis caching reducing API response time by 40%\",\n ],\n resume_file: \"Michael_Chen_Resume.pdf\",\n },\n {\n candidate_id: \"CAND-007\",\n name: \"Sarah Johnson\",\n email: \"sarah.johnson@email.com\",\n phone: \"+1-512-555-0187\",\n current_title: \"Staff Software Engineer\",\n current_company: \"FinanceAI Corp\",\n years_of_experience: 5,\n education: [\n {\n degree: \"M.S. Computer Science\",\n institution: \"Stanford University\",\n year: 2017,\n },\n {\n degree: \"B.S. Mathematics\",\n institution: \"University of Washington\",\n year: 2015,\n },\n ],\n skills: [\n \"Python\",\n \"Java\",\n \"JavaScript\",\n \"TypeScript\",\n \"Go\",\n \"SQL\",\n \"Django\",\n \"Spring Boot\",\n \"Node.js\",\n \"React\",\n \"Vue.js\",\n \"PostgreSQL\",\n \"MySQL\",\n \"MongoDB\",\n \"Elasticsearch\",\n \"Apache Kafka\",\n \"Spark\",\n \"AWS\",\n \"GCP\",\n \"Docker\",\n \"Kubernetes\",\n \"Terraform\",\n ],\n experience_summary:\n \"Staff Software Engineer with 5 years of expertise in full-stack development and system architecture. Led migration from monolithic to microservices architecture serving 2M+ daily transactions.\",\n notable_projects: [\n \"Architected microservices platform serving 2M+ transactions daily\",\n \"Reduced system latency by 50% through optimization\",\n \"Improved reliability from 99.5% to 99.99% uptime\",\n ],\n resume_file: \"Sarah_Johnson_Resume.pdf\",\n },\n];\n\nasync function getJobs(): Promise> {\n try {\n const data = await blob.getJSON(JOBS_KEY);\n return (data as Record) || {};\n } catch {\n return {};\n }\n}\n\nasync function saveJobs(jobs: Record) {\n await blob.setJSON(JOBS_KEY, jobs);\n}\n\nfunction corsHeaders() {\n return {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, PATCH, DELETE, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, Authorization\",\n \"Content-Type\": \"application/json\",\n };\n}\n\nfunction jsonResponse(data: any, status = 200) {\n return new Response(JSON.stringify(data), { status, headers: corsHeaders() });\n}\n\nexport default async function (req: Request): Promise {\n // Handle CORS preflight\n if (req.method === \"OPTIONS\") {\n return new Response(null, { status: 204, headers: corsHeaders() });\n }\n\n const url = new URL(req.url);\n const path = url.pathname;\n\n try {\n // ──────────────────────────────────────────\n // GET /candidates — Return the candidate pool\n // ──────────────────────────────────────────\n if (req.method === \"GET\" && path === \"/candidates\") {\n return jsonResponse(DEFAULT_CANDIDATES);\n }\n\n // ──────────────────────────────────────────\n // GET / — List all jobs\n // ──────────────────────────────────────────\n if (req.method === \"GET\" && (path === \"/\" || path === \"\")) {\n const jobs = await getJobs();\n const jobList = Object.values(jobs);\n return jsonResponse({ count: jobList.length, jobs: jobList });\n }\n\n // ──────────────────────────────────────────\n // GET /:jobId — Get single job\n // ──────────────────────────────────────────\n if (\n req.method === \"GET\" && path.length > 1 && !path.includes(\"/candidates\")\n ) {\n const jobId = decodeURIComponent(path.slice(1));\n const jobs = await getJobs();\n const job = jobs[jobId];\n if (!job) {\n return jsonResponse({ error: `Job ${jobId} not found` }, 404);\n }\n return jsonResponse(job);\n }\n\n // ──────────────────────────────────────────\n // POST / — Create a new job\n // ──────────────────────────────────────────\n if (req.method === \"POST\" && (path === \"/\" || path === \"\")) {\n const body = await req.json();\n const jobId = body.id || body.job_id;\n if (!jobId) {\n return jsonResponse({ error: \"Missing id or job_id in body\" }, 400);\n }\n const jobs = await getJobs();\n jobs[jobId] = {\n ...body,\n created_at: body.created_at || new Date().toISOString(),\n updated_at: new Date().toISOString(),\n };\n await saveJobs(jobs);\n return jsonResponse({ id: jobId, status: \"created\" }, 201);\n }\n\n // ──────────────────────────────────────────\n // PATCH /:jobId — Update job fields\n // ──────────────────────────────────────────\n if (req.method === \"PATCH\" && path.length > 1) {\n const jobId = decodeURIComponent(path.slice(1));\n const body = await req.json();\n const jobs = await getJobs();\n\n if (!jobs[jobId]) {\n return jsonResponse({ error: `Job ${jobId} not found` }, 404);\n }\n\n // Deep merge stages array if provided\n const existing = jobs[jobId];\n if (body.stages && Array.isArray(body.stages)) {\n const existingStages = existing.stages || [];\n for (const newStage of body.stages) {\n const idx = existingStages.findIndex((s: any) =>\n s.stage_number === newStage.stage_number\n );\n if (idx >= 0) {\n existingStages[idx] = { ...existingStages[idx], ...newStage };\n } else {\n existingStages.push(newStage);\n }\n }\n body.stages = existingStages.sort((a: any, b: any) =>\n a.stage_number - b.stage_number\n );\n }\n\n // Merge candidates array if provided (by candidate_id)\n if (body.candidates && Array.isArray(body.candidates)) {\n const existingCandidates = existing.candidates || [];\n for (const newCandidate of body.candidates) {\n const idx = existingCandidates.findIndex((c: any) =>\n c.candidate_id === newCandidate.candidate_id\n );\n if (idx >= 0) {\n existingCandidates[idx] = {\n ...existingCandidates[idx],\n ...newCandidate,\n };\n } else {\n existingCandidates.push(newCandidate);\n }\n }\n body.candidates = existingCandidates;\n }\n\n // Merge scorecards array if provided\n if (body.scorecards && Array.isArray(body.scorecards)) {\n const existingScorecards = existing.scorecards || [];\n body.scorecards = [...existingScorecards, ...body.scorecards];\n }\n\n jobs[jobId] = {\n ...existing,\n ...body,\n updated_at: new Date().toISOString(),\n };\n await saveJobs(jobs);\n return jsonResponse(jobs[jobId]);\n }\n\n // ──────────────────────────────────────────\n // DELETE /:jobId — Delete single job\n // ──────────────────────────────────────────\n if (req.method === \"DELETE\" && path.length > 1) {\n const jobId = decodeURIComponent(path.slice(1));\n const jobs = await getJobs();\n if (jobs[jobId]) {\n delete jobs[jobId];\n await saveJobs(jobs);\n return jsonResponse({ deleted: jobId });\n }\n return jsonResponse({ error: `Job ${jobId} not found` }, 404);\n }\n\n // ──────────────────────────────────────────\n // DELETE / — Delete all jobs\n // ──────────────────────────────────────────\n if (req.method === \"DELETE\" && (path === \"/\" || path === \"\")) {\n await saveJobs({});\n return jsonResponse({ deleted: \"all\" });\n }\n\n return jsonResponse({ error: \"Not found\" }, 404);\n } catch (err) {\n return jsonResponse({ error: String(err) }, 500);\n }\n}","createdAt",["D",1775482974612],"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":161,"_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":162,"_78":163,"_80":164,"_82":25},"tree",[152,153],"files",[152,153],"counts",{"_141":60,"_142":143,"_144":60,"_145":146,"_147":148},"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":134,"_33":34,"_35":37,"_24":25,"_136":-5,"_27":140},{"_43":127,"_32":128,"_30":129,"_130":-5,"_41":42,"_40":131,"_132":120,"_38":133,"_13":134,"_33":34,"_35":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],"8393fda8-31be-11f1-b6da-42dde27851f2",["D",1775482974612],[28],"pulls","branches",1,"forks","envVars",{"_149":143,"_151":60},"connections",{"_149":60,"_150":60},"count","unfilledCount","emptyCount",{"_43":138,"_32":28,"_30":31,"_130":-5,"_41":42,"_40":14,"_132":25,"_38":158,"_13":134,"_33":34,"_35":37,"_24":25,"_136":-5,"_155":159,"_27":160},{"_43":127,"_32":128,"_30":129,"_130":-5,"_41":42,"_40":131,"_132":120,"_38":154,"_13":134,"_33":34,"_35":135,"_24":25,"_136":-5,"_155":156,"_27":157},["D",1775129569979],"children",[],[128],["D",1775482974612],[],[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":198,"_199":200,"_201":202,"_203":25,"_204":25,"_205":25,"_206":120,"_207":-5,"_208":-7,"_209":-7,"_210":60,"_211":25,"_212":25,"_213":-5,"_214":25,"_215":25,"_216":25,"_217":-5},"ENV",{"_169":170,"_171":172,"_173":84,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197},"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 · v20