[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_316":317,"_318":319},"routes/_app.x.$handle.$name",{"_98":97,"_31":43,"_107":88,"_26":108,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":24,"_122":123,"_124":57,"_125":-5,"_126":-5,"_127":128},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_41":42,"_31":43,"_36":44,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":24},"version",16,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":27,"_32":33,"_34":35,"_36":37,"_38":14,"_39":40,"_23":24},"previous","deleted",false,"deletedHere","path","process-recordings.ts","latestPath","fileId","b29a51a2-81c2-11f1-8776-1607ee4eb77e","name","fileType","interval","content","// Interval val — processes queued recordings. Schedule: every minute (* * * * *).\n// Pulls pending rows, runs the pipeline (participants → metrics → Claude →\n// grounding validation → French Markdown → Notion), checkpoints on success.\nimport { ensureTables, claimPending, markDone, recordFailure, checkpointRecording } from \"./glue/db.ts\";\nimport { processMeeting } from \"./glue/process.ts\";\nimport { isDryRun } from \"./glue/env.ts\";\n\nconst BATCH_SIZE = 2; // keep each run well under the execution time limit\n\ntype Interval = { lastRunAt?: Date };\n\nexport default async function (_interval: Interval) {\n await ensureTables();\n const dryRun = isDryRun();\n const rows = await claimPending(BATCH_SIZE);\n if (!rows.length) return;\n\n for (const row of rows) {\n try {\n const meeting = JSON.parse(row.payload);\n const result = await processMeeting(meeting, dryRun);\n await markDone(row.id);\n if (result.checkpoint) await checkpointRecording(row.recording_id);\n console.log(\n `Recording ${row.recording_id}: ${result.status}` +\n (result.reason ? ` (${result.reason})` : \"\") +\n (result.notionPageId ? ` → Notion ${result.notionPageId}` : \"\") +\n (dryRun ? \" [dry run]\" : \"\"),\n );\n } catch (error) {\n const outcome = await recordFailure(row.id, row.retries);\n console.error(`Recording ${row.recording_id} failed (${outcome}): ${(error as Error).message}`);\n }\n }\n}\n","createdAt",["D",1784280864523],"branchVersion","branchId","86c684dc-fb6b-40db-85f4-e12036ab3e09","id","f0ac4d89-2364-4c3c-a35d-9e744274b9f6","interview-coach",["D",1784280622128],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Fathom interview → Claude coaching (interviewer) → Notion DB","imageUrl","4704801c-db4b-4f2a-8ad7-932a7d734595","pinnedFileId","af5858b8-81c2-11f1-bffa-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019f6f4e-7661-7305-979e-3c621fe95d18","tursoName","f0ac4d8923644c3ca35d9e744274b9f6","tursoHostname","f0ac4d8923644c3ca35d9e744274b9f6-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789527031073],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_106":102},"org",{"_98":97,"_99":100,"_101":102,"_18":53,"_103":104,"_105":24},"branch",{"_13":87,"_31":88,"_41":40,"_89":42,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":43,"_96":97},"isOwned",18,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","lcibot","handle","displayName","Louis Cibot","avatar","https://lh3.googleusercontent.com/a/ACg8ocIJUslEt6CPs22Hts-0n6afiQpKVLbtvn-iRhJvA1gVqdthrY0=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_41":42,"_31":43,"_36":311,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":312,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":313,"_82":314,"_84":315,"_86":24},"tree",[169,179,185,186],"files",[169,170,171,172,173,174,175,176,177,178,179,180,181,182,183,184,185,186],"counts",{"_159":61,"_160":156,"_161":61,"_162":163,"_164":165},"contents",[129,130,131,132],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_41":153,"_31":154,"_29":155,"_134":-5,"_39":40,"_38":156,"_135":57,"_36":157,"_13":61,"_32":151,"_34":-5,"_23":24,"_137":-5,"_26":158},{"_41":146,"_31":147,"_29":148,"_134":-5,"_39":40,"_38":149,"_135":57,"_36":150,"_13":61,"_32":151,"_34":-5,"_23":24,"_137":-5,"_26":152},{"_41":139,"_31":140,"_29":55,"_134":-5,"_39":40,"_38":141,"_135":57,"_36":142,"_13":61,"_32":143,"_34":144,"_23":24,"_137":-5,"_26":145},{"_41":133,"_31":27,"_29":30,"_134":-5,"_39":40,"_38":14,"_135":57,"_36":136,"_13":61,"_32":33,"_34":35,"_23":24,"_137":-5,"_26":138},"4c580dd1-2dba-4270-a958-47f71fe73a75","parentId","latest",["D",1784280864523],"label",[27],"f892e9bc-da90-49f5-9ee1-eb955722c6a2","fathom-webhook.ts",15,["D",1784280859052],"http","// HTTP val — Fathom webhook receiver.\n// Verifies the Svix signature over the RAW body, dedups, queues into SQLite,\n// answers 200 fast. All heavy work happens in process-recordings.ts (interval).\nimport { verifySvixSignature } from \"./core/svix.ts\";\nimport { env } from \"./glue/env.ts\";\nimport { ensureTables, seenWebhook, pruneWebhooks, isRecordingProcessed, enqueue } from \"./glue/db.ts\";\n\nexport default async function (req: Request): Promise {\n if (req.method !== \"POST\") {\n return new Response(\"method not allowed\", { status: 405 });\n }\n\n const secret = env(\"FATHOM_WEBHOOK_SECRET\");\n if (!secret) {\n console.error(\"FATHOM_WEBHOOK_SECRET is not set\");\n return new Response(\"not configured\", { status: 500 });\n }\n\n const rawBody = await req.text();\n const verdict = await verifySvixSignature(secret, rawBody, {\n id: req.headers.get(\"webhook-id\"),\n timestamp: req.headers.get(\"webhook-timestamp\"),\n signature: req.headers.get(\"webhook-signature\"),\n });\n if (!verdict.ok) {\n console.log(`Rejected delivery: ${verdict.reason}`);\n return new Response(\"invalid signature\", { status: 401 });\n }\n\n let meeting: any;\n try {\n meeting = JSON.parse(rawBody);\n } catch {\n return new Response(\"invalid json\", { status: 400 });\n }\n\n await ensureTables();\n\n const webhookId = req.headers.get(\"webhook-id\")!;\n if (await seenWebhook(webhookId)) {\n console.log(`Duplicate Svix delivery ${webhookId} — skipping.`);\n return new Response(\"duplicate delivery\", { status: 200 });\n }\n await pruneWebhooks();\n\n const recordingId = meeting?.recording_id != null ? String(meeting.recording_id) : \"\";\n if (!recordingId) {\n console.log(`Payload without recording_id — ignoring. Top-level keys: ${Object.keys(meeting ?? {}).join(\",\")}`);\n return new Response(\"ignored\", { status: 200 });\n }\n\n if (await isRecordingProcessed(recordingId)) {\n console.log(`Recording ${recordingId} already processed — skipping.`);\n return new Response(\"already processed\", { status: 200 });\n }\n\n await enqueue(recordingId, rawBody);\n console.log(`Queued recording ${recordingId} (${(meeting.transcript ?? []).length} transcript entries).`);\n return new Response(\"queued\", { status: 200 });\n}\n",[140],"d9587335-a3d2-4004-967b-cc7b073acb08","glue","54c03fa6-81ac-448f-a060-75ffa88db4d9",9,["D",1784280744388],"directory",[147],"87b75345-444c-40b8-b4a0-eeea89d08d77","core","01fedcb8-c298-46eb-adb9-de5f71997ea1",1,["D",1784280644634],[154],"pulls","branches","forks","envVars",{"_166":156,"_168":61},"connections",{"_166":61,"_167":61},"count","unfilledCount","emptyCount",{"_41":153,"_31":154,"_29":155,"_134":-5,"_39":40,"_38":156,"_135":57,"_36":308,"_13":61,"_32":151,"_34":-5,"_23":24,"_137":-5,"_188":309,"_26":310},{"_41":300,"_31":301,"_29":302,"_134":155,"_39":40,"_38":303,"_135":57,"_36":304,"_13":61,"_32":199,"_34":305,"_23":24,"_137":-5,"_188":306,"_26":307},{"_41":292,"_31":293,"_29":294,"_134":155,"_39":40,"_38":295,"_135":57,"_36":296,"_13":61,"_32":199,"_34":297,"_23":24,"_137":-5,"_188":298,"_26":299},{"_41":284,"_31":285,"_29":286,"_134":155,"_39":40,"_38":287,"_135":57,"_36":288,"_13":61,"_32":199,"_34":289,"_23":24,"_137":-5,"_188":290,"_26":291},{"_41":276,"_31":277,"_29":278,"_134":155,"_39":40,"_38":279,"_135":57,"_36":280,"_13":61,"_32":199,"_34":281,"_23":24,"_137":-5,"_188":282,"_26":283},{"_41":268,"_31":269,"_29":270,"_134":155,"_39":40,"_38":271,"_135":24,"_36":272,"_13":61,"_32":199,"_34":273,"_23":24,"_137":-5,"_188":274,"_26":275},{"_41":260,"_31":261,"_29":262,"_134":155,"_39":40,"_38":263,"_135":57,"_36":264,"_13":61,"_32":199,"_34":265,"_23":24,"_137":-5,"_188":266,"_26":267},{"_41":252,"_31":253,"_29":254,"_134":155,"_39":40,"_38":255,"_135":57,"_36":256,"_13":61,"_32":199,"_34":257,"_23":24,"_137":-5,"_188":258,"_26":259},{"_41":245,"_31":246,"_29":247,"_134":155,"_39":40,"_38":156,"_135":57,"_36":248,"_13":61,"_32":199,"_34":249,"_23":24,"_137":-5,"_188":250,"_26":251},{"_41":237,"_31":238,"_29":239,"_134":155,"_39":40,"_38":240,"_135":57,"_36":241,"_13":61,"_32":199,"_34":242,"_23":24,"_137":-5,"_188":243,"_26":244},{"_41":146,"_31":147,"_29":148,"_134":-5,"_39":40,"_38":149,"_135":57,"_36":234,"_13":61,"_32":151,"_34":-5,"_23":24,"_137":-5,"_188":235,"_26":236},{"_41":226,"_31":227,"_29":228,"_134":148,"_39":40,"_38":229,"_135":57,"_36":230,"_13":61,"_32":199,"_34":231,"_23":24,"_137":-5,"_188":232,"_26":233},{"_41":218,"_31":219,"_29":220,"_134":148,"_39":40,"_38":221,"_135":57,"_36":222,"_13":61,"_32":199,"_34":223,"_23":24,"_137":-5,"_188":224,"_26":225},{"_41":211,"_31":212,"_29":213,"_134":148,"_39":40,"_38":149,"_135":57,"_36":214,"_13":61,"_32":199,"_34":215,"_23":24,"_137":-5,"_188":216,"_26":217},{"_41":203,"_31":204,"_29":205,"_134":148,"_39":40,"_38":206,"_135":57,"_36":207,"_13":61,"_32":199,"_34":208,"_23":24,"_137":-5,"_188":209,"_26":210},{"_41":194,"_31":195,"_29":196,"_134":148,"_39":40,"_38":197,"_135":57,"_36":198,"_13":61,"_32":199,"_34":200,"_23":24,"_137":-5,"_188":201,"_26":202},{"_41":139,"_31":140,"_29":55,"_134":-5,"_39":40,"_38":141,"_135":57,"_36":191,"_13":61,"_32":143,"_34":144,"_23":24,"_137":-5,"_188":192,"_26":193},{"_41":133,"_31":27,"_29":30,"_134":-5,"_39":40,"_38":14,"_135":57,"_36":187,"_13":61,"_32":33,"_34":35,"_23":24,"_137":-5,"_188":189,"_26":190},["D",1784280864523],"children",[],[27],["D",1784280859052],[],[140],"9db00579-ec94-4ed7-a5ff-c016a63b60f7","process.ts","a4d7971e-81c2-11f1-a6d1-1607ee4eb77e",14,["D",1784280841426],"script","import { identifyParticipants } from \"../core/participants.ts\";\nimport { labelTranscript, computeMetrics } from \"../core/metrics.ts\";\nimport { validateCoaching } from \"../core/validate.ts\";\nimport { renderFeedback } from \"../core/render.ts\";\nimport { buildUserMessage } from \"../core/prompt.ts\";\nimport type { Meeting } from \"../core/types.ts\";\nimport { coachInterview } from \"./claude.ts\";\nimport { createFeedbackPage } from \"./notion.ts\";\n\nexport interface ProcessResult {\n status: \"skipped\" | \"no_grounded_items\" | \"posted\";\n reason?: string;\n notionPageId?: string;\n /** Whether the recording should be checkpointed as processed. */\n checkpoint: boolean;\n}\n\nexport async function processMeeting(meeting: Meeting, dryRun: boolean): Promise {\n const identified = identifyParticipants(meeting);\n if (!identified.ok) {\n return { status: \"skipped\", reason: identified.reason, checkpoint: false };\n }\n const { interviewer, candidate } = identified;\n const transcript = meeting.transcript ?? [];\n\n const labelled = labelTranscript(transcript, interviewer.email, candidate.email);\n const metrics = computeMetrics(transcript, interviewer.email, candidate.email);\n const transcriptText = labelled.map((l) => l.line).join(\"\\n\");\n\n const rawText = await coachInterview(buildUserMessage(metrics, interviewer.name, transcriptText));\n const coaching = validateCoaching(rawText, labelled);\n\n if (coaching.dropped.length) {\n console.log(\n `Dropped ${coaching.dropped.length} ungrounded item(s): ` +\n JSON.stringify(coaching.dropped.map((d) => `${d.bucket}:${d.reason}`)),\n );\n }\n\n const total = coaching.strengths.length + coaching.improvements.length + coaching.risk_flags.length;\n if (total === 0) {\n // Nothing grounded to say. Checkpoint (outside dry run) so we don't retry forever.\n return { status: \"no_grounded_items\", checkpoint: !dryRun };\n }\n\n const fathomUrl = meeting.url || meeting.share_url || \"\";\n const callDate = String(meeting.recording_start_time || meeting.created_at || \"\").split(\"T\")[0];\n const markdown = renderFeedback(coaching, { interviewerName: interviewer.name, metrics, fathomUrl });\n\n const notionPageId = await createFeedbackPage({\n interviewer,\n candidate,\n callDate,\n recordingId: String(meeting.recording_id),\n fathomUrl,\n coaching,\n markdown,\n dryRun,\n });\n\n // Dry run: the page is written (with the \"Dry run\" checkbox) so output quality\n // can be reviewed in Notion, but the recording stays replayable.\n return { status: \"posted\", notionPageId, checkpoint: !dryRun };\n}\n",[],[147,195],"5bccf14e-0375-4d42-94d1-bc86b7f9394b","notion.ts","9f79648c-81c2-11f1-96a9-1607ee4eb77e",13,["D",1784280832427],"import { markdownToNotionBlocks } from \"../core/notion-blocks.ts\";\nimport type { Coaching, Participant } from \"../core/types.ts\";\nimport { requireEnv } from \"./env.ts\";\n\nconst NOTION_VERSION = \"2022-06-28\";\nconst MAX_BLOCKS_PER_REQUEST = 100;\n\nexport interface FeedbackPageInput {\n interviewer: Participant;\n candidate: Participant;\n callDate: string; // YYYY-MM-DD\n recordingId: string;\n fathomUrl: string;\n coaching: Coaching;\n markdown: string;\n dryRun: boolean;\n}\n\nconst PRINCIPLE_PROPERTIES: Record = {\n \"HIGH STANDARDS\": \"High Standards\",\n \"NO BLIND SPOTS\": \"No Blind Spots\",\n \"CONTAGIOUS ENTHUSIASM\": \"Contagious Enthusiasm\",\n \"NEED FOR SPEED\": \"Need for Speed\",\n};\n\nasync function notionFetch(path: string, method: string, body: unknown): Promise {\n const response = await fetch(`https://api.notion.com/v1${path}`, {\n method,\n headers: {\n Authorization: `Bearer ${requireEnv(\"NOTION_API_KEY\")}`,\n \"Notion-Version\": NOTION_VERSION,\n \"content-type\": \"application/json\",\n },\n body: JSON.stringify(body),\n });\n if (!response.ok) {\n const text = await response.text();\n throw new Error(`Notion API ${response.status} on ${method} ${path}: ${text.slice(0, 300)}`);\n }\n return response.json();\n}\n\nfunction worstFlagSeverity(coaching: Coaching): \"High\" | \"Medium\" | \"None\" {\n const severities = coaching.risk_flags.map((f) => String(f.severity).toLowerCase());\n if (severities.includes(\"high\")) return \"High\";\n if (severities.includes(\"medium\")) return \"Medium\";\n return \"None\";\n}\n\nexport async function createFeedbackPage(input: FeedbackPageInput): Promise {\n const { interviewer, candidate, callDate, recordingId, fathomUrl, coaching, markdown, dryRun } = input;\n\n const properties: Record = {\n Name: { title: [{ text: { content: `${candidate.name} × ${interviewer.name} — ${callDate}` } }] },\n Interviewer: { rich_text: [{ text: { content: interviewer.name } }] },\n \"Interviewer email\": { email: interviewer.email },\n Candidate: { rich_text: [{ text: { content: candidate.name } }] },\n \"Candidate email\": { email: candidate.email },\n \"Recording ID\": { rich_text: [{ text: { content: recordingId } }] },\n Flags: { select: { name: worstFlagSeverity(coaching) } },\n \"Dry run\": { checkbox: dryRun },\n };\n if (callDate) properties[\"Date\"] = { date: { start: callDate } };\n if (coaching.score != null) properties[\"Score\"] = { number: coaching.score };\n if (fathomUrl) properties[\"Fathom URL\"] = { url: fathomUrl };\n for (const p of coaching.principles) {\n const property = PRINCIPLE_PROPERTIES[p.principle.toUpperCase()];\n if (property) properties[property] = { select: { name: p.verdict } };\n }\n\n const blocks = markdownToNotionBlocks(markdown);\n const page = await notionFetch(\"/pages\", \"POST\", {\n parent: { database_id: requireEnv(\"NOTION_DATABASE_ID\") },\n properties,\n children: blocks.slice(0, MAX_BLOCKS_PER_REQUEST),\n });\n\n for (let i = MAX_BLOCKS_PER_REQUEST; i < blocks.length; i += MAX_BLOCKS_PER_REQUEST) {\n await notionFetch(`/blocks/${page.id}/children`, \"PATCH\", {\n children: blocks.slice(i, i + MAX_BLOCKS_PER_REQUEST),\n });\n }\n\n return page.id;\n}\n",[],[147,204],"1eaa13c5-8474-496d-889c-2989a7c34ada","env.ts","6b002ccc-81c2-11f1-acbc-1607ee4eb77e",["D",1784280744388],"export function env(key: string): string | undefined {\n const deno = (globalThis as any).Deno;\n if (deno?.env?.get) return deno.env.get(key);\n return (globalThis as any).process?.env?.[key];\n}\n\nexport function requireEnv(key: string): string {\n const value = env(key);\n if (!value) throw new Error(`Missing required environment variable: ${key}`);\n return value;\n}\n\nexport function isDryRun(): boolean {\n return (env(\"DRY_RUN\") ?? \"true\").toLowerCase() !== \"false\";\n}\n",[],[147,212],"a3545bcf-6cfd-48b1-a7c4-e315e174f901","db.ts","8fd7b3da-81c2-11f1-8f63-1607ee4eb77e",11,["D",1784280806203],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst SEVEN_DAYS_MS = 7 * 24 * 60 * 60 * 1000;\nconst MAX_RETRIES = 3;\n\nexport interface PendingRow {\n id: number;\n recording_id: string;\n payload: string;\n retries: number;\n}\n\nexport async function ensureTables(): Promise {\n await sqlite.batch([\n `CREATE TABLE IF NOT EXISTS processed_webhook_ids (\n webhook_id TEXT PRIMARY KEY,\n ts INTEGER NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS processed_recording_ids (\n recording_id TEXT PRIMARY KEY,\n ts INTEGER NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS pending_recordings (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n recording_id TEXT NOT NULL,\n payload TEXT NOT NULL,\n retries INTEGER NOT NULL DEFAULT 0,\n status TEXT NOT NULL DEFAULT 'pending',\n created_at INTEGER NOT NULL\n )`,\n ]);\n}\n\n/** Records the Svix delivery id. Returns true if it was already seen (duplicate). */\nexport async function seenWebhook(webhookId: string): Promise {\n const result = await sqlite.execute({\n sql: \"INSERT OR IGNORE INTO processed_webhook_ids (webhook_id, ts) VALUES (?, ?)\",\n args: [webhookId, Date.now()],\n });\n return result.rowsAffected === 0;\n}\n\nexport async function pruneWebhooks(): Promise {\n await sqlite.execute({\n sql: \"DELETE FROM processed_webhook_ids WHERE ts < ?\",\n args: [Date.now() - SEVEN_DAYS_MS],\n });\n}\n\nexport async function isRecordingProcessed(recordingId: string): Promise {\n const result = await sqlite.execute({\n sql: \"SELECT 1 FROM processed_recording_ids WHERE recording_id = ?\",\n args: [recordingId],\n });\n return result.rows.length > 0;\n}\n\nexport async function checkpointRecording(recordingId: string): Promise {\n await sqlite.execute({\n sql: \"INSERT OR IGNORE INTO processed_recording_ids (recording_id, ts) VALUES (?, ?)\",\n args: [recordingId, Date.now()],\n });\n}\n\nexport async function enqueue(recordingId: string, payload: string): Promise {\n const existing = await sqlite.execute({\n sql: \"SELECT 1 FROM pending_recordings WHERE recording_id = ? AND status = 'pending'\",\n args: [recordingId],\n });\n if (existing.rows.length > 0) return;\n await sqlite.execute({\n sql: \"INSERT INTO pending_recordings (recording_id, payload, created_at) VALUES (?, ?, ?)\",\n args: [recordingId, payload, Date.now()],\n });\n}\n\nexport async function claimPending(limit: number): Promise {\n const result = await sqlite.execute({\n sql: \"SELECT id, recording_id, payload, retries FROM pending_recordings WHERE status = 'pending' ORDER BY id LIMIT ?\",\n args: [limit],\n });\n return result.rows as unknown as PendingRow[];\n}\n\nexport async function markDone(id: number): Promise {\n await sqlite.execute({\n sql: \"UPDATE pending_recordings SET status = 'done' WHERE id = ?\",\n args: [id],\n });\n}\n\n/** Bumps the retry counter; marks the row failed once MAX_RETRIES is reached. */\nexport async function recordFailure(id: number, retries: number): Promise<\"retrying\" | \"failed\"> {\n if (retries + 1 >= MAX_RETRIES) {\n await sqlite.execute({\n sql: \"UPDATE pending_recordings SET status = 'failed', retries = retries + 1 WHERE id = ?\",\n args: [id],\n });\n return \"failed\";\n }\n await sqlite.execute({\n sql: \"UPDATE pending_recordings SET retries = retries + 1 WHERE id = ?\",\n args: [id],\n });\n return \"retrying\";\n}\n",[],[147,219],"f81c5607-d8f4-4c9d-b895-6859c9025033","claude.ts","94781420-81c2-11f1-9d92-1607ee4eb77e",12,["D",1784280813948],"import { SYSTEM_PROMPT } from \"../core/prompt.ts\";\nimport { requireEnv } from \"./env.ts\";\n\nconst MODEL = \"claude-sonnet-5\";\n\nexport async function coachInterview(userMessage: string): Promise {\n const response = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: {\n \"x-api-key\": requireEnv(\"ANTHROPIC_API_KEY\"),\n \"anthropic-version\": \"2023-06-01\",\n \"content-type\": \"application/json\",\n },\n body: JSON.stringify({\n model: MODEL,\n max_tokens: 4096,\n temperature: 0.2,\n system: SYSTEM_PROMPT,\n messages: [{ role: \"user\", content: userMessage }],\n }),\n });\n\n if (!response.ok) {\n const body = await response.text();\n throw new Error(`Anthropic API ${response.status}: ${body.slice(0, 300)}`);\n }\n\n const data = await response.json();\n const text = (data.content ?? []).find((block: any) => block.type === \"text\")?.text;\n if (!text) throw new Error(`Claude returned no text. Content types: ${(data.content ?? []).map((b: any) => b.type).join(\",\")}`);\n return text;\n}\n",[],[147,227],["D",1784280744388],[180,181,182,183,184],[147],"0d278a26-f187-448b-8b73-7ab04be04858","validate.ts","4f082a2e-81c2-11f1-83e5-1607ee4eb77e",5,["D",1784280697463],"import type { Citation, Coaching, DroppedItem, LabelledLine, Principle } from \"./types.ts\";\n\nconst QUOTE_TOKEN_OVERLAP_THRESHOLD = 0.6;\nconst MIN_TOKENS_FOR_OVERLAP_CHECK = 4;\nconst PRINCIPLE_VERDICTS = new Set([\"✅\", \"🟡\", \"❌\"]);\n\nexport function stripFences(raw: unknown): string {\n return String(raw ?? \"\")\n .trim()\n .replace(/^```(?:json)?\\s*/i, \"\")\n .replace(/```\\s*$/, \"\")\n .trim();\n}\n\nfunction normalizeQuote(text: unknown): string {\n return String(text ?? \"\")\n .normalize(\"NFKD\") // decompose accents; the ASCII filter below drops the marks\n .toLowerCase()\n .replace(/[^a-z0-9@.]+/g, \" \")\n .replace(/\\s+/g, \" \")\n .trim();\n}\n\nfunction significantTokens(text: unknown): string[] {\n return normalizeQuote(text).split(\" \").filter((token) => token.length > 2);\n}\n\nexport function quoteLooksRelated(quote: unknown, sourceText: unknown): boolean {\n const q = normalizeQuote(quote);\n const s = normalizeQuote(sourceText);\n if (!q || !s) return false;\n if (s.includes(q) || q.includes(s)) return true;\n\n const quoteTokens = significantTokens(quote);\n if (quoteTokens.length < MIN_TOKENS_FOR_OVERLAP_CHECK) return false;\n const sourceTokens = new Set(significantTokens(sourceText));\n const hits = quoteTokens.filter((token) => sourceTokens.has(token)).length;\n return hits / quoteTokens.length >= QUOTE_TOKEN_OVERLAP_THRESHOLD;\n}\n\nfunction normalizeLineId(lineId: unknown): string {\n return String(lineId ?? \"\").trim().replace(/^\\[|\\]$/g, \"\").toUpperCase();\n}\n\nexport function validateCoaching(rawText: string, labelled: LabelledLine[]): Coaching {\n let parsed: any;\n try {\n parsed = JSON.parse(stripFences(rawText));\n } catch (error) {\n throw new Error(\n `Claude did not return valid JSON: ${(error as Error).message}\\n---\\n${String(rawText).slice(0, 500)}`\n );\n }\n\n const byId = new Map(labelled.map((line) => [line.id.toUpperCase(), line]));\n const dropped: DroppedItem[] = [];\n\n const keep = (items: unknown, bucket: string): T[] =>\n (Array.isArray(items) ? items : []).filter((item: any) => {\n const id = normalizeLineId(item.source_line_id);\n const line = byId.get(id);\n if (!line) {\n dropped.push({ bucket, item, reason: \"unknown_line_id\" });\n return false;\n }\n if (line.role !== \"INTERVIEWER\") {\n dropped.push({ bucket, item, reason: \"not_an_interviewer_line\" });\n return false;\n }\n if (!quoteLooksRelated(item.verbatim_quote, line.text)) {\n dropped.push({ bucket, item, reason: \"quote_not_in_line\" });\n return false;\n }\n item.source_line_id = id;\n return true;\n });\n\n const principles: Principle[] = (Array.isArray(parsed.principles) ? parsed.principles : [])\n .map((p: any) => ({\n principle: String(p.principle ?? \"\").trim(),\n verdict: PRINCIPLE_VERDICTS.has(p.verdict) ? p.verdict : \"🟡\",\n evidence: keep(p.evidence, \"principles\"),\n }))\n .filter((p: Principle) => p.principle);\n\n const score = Number.isFinite(parsed.score)\n ? Math.min(10, Math.max(0, Math.round(parsed.score)))\n : null;\n\n return {\n summary: String(parsed.summary ?? \"\").trim(),\n score,\n principles,\n strengths: keep(parsed.strengths, \"strengths\"),\n improvements: keep(parsed.improvements, \"improvements\"),\n risk_flags: keep(parsed.risk_flags, \"risk_flags\"),\n priority_action: String(parsed.priority_action ?? \"\").trim(),\n dropped,\n };\n}\n",[],[154,238],"14d0463c-bfb3-40ff-9846-dc002b60cc8b","types.ts","2f8aff1e-81c2-11f1-9145-1607ee4eb77e",["D",1784280644634],"export interface Speaker {\n display_name?: string;\n email?: string;\n matched_calendar_invitee_email?: string;\n matched_calendar_invitee?: { email?: string };\n}\n\nexport interface TranscriptEntry {\n speaker?: Speaker;\n text?: string;\n timestamp?: string;\n}\n\nexport interface Meeting {\n recording_id?: string | number;\n recording_start_time?: string;\n created_at?: string;\n url?: string;\n share_url?: string;\n transcript?: TranscriptEntry[];\n}\n\nexport interface Participant {\n email: string;\n name: string;\n words: number;\n}\n\nexport type IdentifyResult =\n | { ok: false; reason: \"transcript_too_short\" | \"no_internal_speaker\" | \"no_external_speaker\" }\n | { ok: true; interviewer: Participant; candidate: Participant; otherInternal: Participant[] };\n\nexport type Role = \"INTERVIEWER\" | \"CANDIDATE\" | \"OTHER_INTERNAL\" | \"OTHER_EXTERNAL\";\n\nexport interface LabelledLine {\n id: string;\n role: Role;\n email: string;\n name: string;\n text: string;\n line: string;\n}\n\nexport interface Metrics {\n interviewer_talk_ratio: number;\n candidate_talk_ratio: number;\n interviewer_turns: number;\n interviewer_questions: number;\n avg_words_per_interviewer_turn: number;\n longest_interviewer_monologue_words: number;\n interview_span_minutes: number | null;\n}\n\nexport interface Citation {\n source_line_id: string;\n verbatim_quote: string;\n}\n\nexport interface Strength extends Citation {\n point: string;\n}\n\nexport interface Improvement extends Citation {\n point: string;\n why_it_matters?: string;\n suggested_alternative?: string;\n}\n\nexport interface RiskFlag extends Citation {\n severity: string;\n issue: string;\n}\n\nexport interface Principle {\n principle: string;\n verdict: string;\n evidence: Citation[];\n}\n\nexport interface DroppedItem {\n bucket: string;\n item: unknown;\n reason: \"unknown_line_id\" | \"not_an_interviewer_line\" | \"quote_not_in_line\";\n}\n\nexport interface Coaching {\n summary: string;\n score: number | null;\n principles: Principle[];\n strengths: Strength[];\n improvements: Improvement[];\n risk_flags: RiskFlag[];\n priority_action: string;\n dropped: DroppedItem[];\n}\n\nexport interface RenderContext {\n interviewerName: string;\n metrics: Metrics;\n fathomUrl: string;\n}\n",[],[154,246],"c012561e-229b-4daa-9415-54270e3f97a4","svix.ts","5f532e10-81c2-11f1-b54e-1607ee4eb77e",7,["D",1784280724802],"const TOLERANCE_SECONDS = 300;\n\nexport interface SvixHeaders {\n id: string | null;\n timestamp: string | null;\n signature: string | null;\n}\n\nexport type SvixResult =\n | { ok: true }\n | { ok: false; reason: \"missing_headers\" | \"bad_timestamp\" | \"timestamp_out_of_tolerance\" | \"bad_signature\" };\n\nfunction base64ToBytes(b64: string): Uint8Array {\n const bin = atob(b64);\n const bytes = new Uint8Array(bin.length);\n for (let i = 0; i < bin.length; i++) bytes[i] = bin.charCodeAt(i);\n return bytes;\n}\n\nfunction bytesToBase64(bytes: Uint8Array): string {\n let bin = \"\";\n for (const b of bytes) bin += String.fromCharCode(b);\n return btoa(bin);\n}\n\n// Constant-time comparison. The length guard is deliberate: comparing lengths\n// leaks nothing useful, while looping over mismatched lengths would.\nfunction timingSafeEqual(a: Uint8Array, b: Uint8Array): boolean {\n if (a.length !== b.length) return false;\n let diff = 0;\n for (let i = 0; i < a.length; i++) diff |= a[i] ^ b[i];\n return diff === 0;\n}\n\nexport async function verifySvixSignature(\n secret: string,\n rawBody: string,\n headers: SvixHeaders,\n nowSeconds: number = Math.floor(Date.now() / 1000),\n): Promise {\n const { id, timestamp, signature } = headers;\n if (!id || !timestamp || !signature) return { ok: false, reason: \"missing_headers\" };\n\n if (!/^\\d+$/.test(timestamp.trim())) return { ok: false, reason: \"bad_timestamp\" };\n const ts = Number(timestamp.trim());\n if (Math.abs(nowSeconds - ts) > TOLERANCE_SECONDS) {\n return { ok: false, reason: \"timestamp_out_of_tolerance\" };\n }\n\n const key = base64ToBytes(secret.replace(/^whsec_/, \"\"));\n const cryptoKey = await crypto.subtle.importKey(\n \"raw\",\n key,\n { name: \"HMAC\", hash: \"SHA-256\" },\n false,\n [\"sign\"],\n );\n const signedContent = `${id}.${ts}.${rawBody}`;\n const mac = await crypto.subtle.sign(\"HMAC\", cryptoKey, new TextEncoder().encode(signedContent));\n const expected = new TextEncoder().encode(bytesToBase64(new Uint8Array(mac)));\n\n // webhook-signature may carry several space-separated entries like \"v1,\"\n for (const entry of signature.split(\" \")) {\n const candidate = entry.includes(\",\") ? entry.slice(entry.indexOf(\",\") + 1) : entry;\n if (timingSafeEqual(new TextEncoder().encode(candidate), expected)) return { ok: true };\n }\n return { ok: false, reason: \"bad_signature\" };\n}\n",[],[154,253],"a5db2322-903b-4efb-9006-de04d3c86b24","render.ts","59f9eecc-81c2-11f1-9c86-1607ee4eb77e",6,["D",1784280715813],"import type { Coaching, RenderContext } from \"./types.ts\";\n\nexport function renderFeedback(coaching: Coaching, context: RenderContext): string {\n const parts: string[] = [];\n parts.push(\"**🤖 Coaching IA de l'interviewer**\");\n parts.push(\n `_Feedback sur la conduite de cet entretien par **${context.interviewerName}**. ` +\n `Ce n'est pas une évaluation du candidat et ne comporte aucune recommandation d'embauche._`\n );\n parts.push(\"\");\n parts.push(coaching.summary);\n if (coaching.score != null) {\n parts.push(\"\");\n parts.push(`**Note globale : ${coaching.score}/10**`);\n }\n\n if (coaching.risk_flags.length) {\n parts.push(\"\");\n parts.push(\"### ⚠️ Signalements\");\n for (const flag of coaching.risk_flags) {\n parts.push(`- **${flag.severity.toUpperCase()}** — ${flag.issue}`);\n parts.push(` > \"${flag.verbatim_quote}\" _(${flag.source_line_id})_`);\n }\n }\n\n const principles = coaching.principles || [];\n if (principles.length) {\n parts.push(\"\");\n parts.push(\"### Évaluation des 4 principes\");\n for (const p of principles) {\n parts.push(`- ${p.verdict} **${p.principle}**`);\n for (const ev of p.evidence || []) {\n parts.push(` > \"${ev.verbatim_quote}\" _(${ev.source_line_id})_`);\n }\n }\n }\n\n if (coaching.strengths.length) {\n parts.push(\"\");\n parts.push(\"### Points forts\");\n for (const item of coaching.strengths) {\n parts.push(`- ${item.point}`);\n parts.push(` > \"${item.verbatim_quote}\" _(${item.source_line_id})_`);\n }\n }\n\n if (coaching.improvements.length) {\n parts.push(\"\");\n parts.push(\"### Axes d'amélioration\");\n for (const item of coaching.improvements) {\n parts.push(`- **${item.point}** — ${item.why_it_matters || \"\"}`.trimEnd());\n parts.push(` > \"${item.verbatim_quote}\" _(${item.source_line_id})_`);\n if (item.suggested_alternative) parts.push(` Essaie plutôt : _\"${item.suggested_alternative}\"_`);\n }\n }\n\n if (coaching.priority_action) {\n parts.push(\"\");\n parts.push(`**🎯 Action prioritaire pour le prochain entretien :** ${coaching.priority_action}`);\n }\n\n parts.push(\"\");\n parts.push(\n `_Mesuré : l'interviewer a prononcé ${Math.round(context.metrics.interviewer_talk_ratio * 100)} % des mots ` +\n `et posé ${context.metrics.interviewer_questions} questions._`\n );\n if (context.fathomUrl) parts.push(`_Enregistrement : ${context.fathomUrl}_`);\n\n return parts.join(\"\\n\");\n}\n",[],[154,261],"a1e04e6f-31f3-4471-b1e9-bfe6ab76f6f4","prompt.ts","807ab770-81c2-11f1-ba7e-1607ee4eb77e",10,["D",1784280780409],"import type { Metrics } from \"./types.ts\";\n\nexport const SYSTEM_PROMPT = `Tu es un coach en recrutement. Tu analyses un entretien de recrutement mené par un employé de Riot et tu donnes à l'INTERVIEWER un feedback factuel et actionnable sur sa technique d'entretien. Ton seul sujet est l'interviewer : tu n'évalues JAMAIS le candidat et tu ne dois jamais exprimer ou laisser entendre s'il faut l'embaucher.\n\nSTYLE\nRéponds en français (conserve les anglicismes d'usage). Sois direct et bienveillant. Base-toi uniquement sur le transcript : n'invente rien. Ne signale que ce qui mérite de l'être — jamais de contrôles négatifs (\"aucune question discriminatoire\", \"rien à signaler\", \"pas de problème détecté\").\n\nMÉTRIQUES MESURÉES\nLes métriques fournies dans le message utilisateur ont été calculées à partir du transcript et sont exactes. Cite-les quand c'est pertinent. Tu ne dois JAMAIS calculer, estimer, approximer ou inventer un chiffre — ni pourcentage, ni compte, ni durée. Si tu veux exprimer quelque chose de chiffré qui n'est pas dans les métriques fournies, dis-le qualitativement.\n\nFORMAT DU TRANSCRIPT\nChaque ligne est préfixée par un ID stable et un rôle, par exemple :\n [L13] [INTERVIEWER Louis Cibot]: So you'd agree that's the right call, wouldn't you?\nLes rôles sont INTERVIEWER, CANDIDATE, OTHER_INTERNAL, OTHER_EXTERNAL.\n\nRÈGLES D'ANCRAGE\n- Chaque élément que tu émets DOIT citer \"source_line_id\" — l'ID exact d'une ligne [INTERVIEWER].\n- Ne cite jamais une ligne CANDIDATE, OTHER_INTERNAL ou OTHER_EXTERNAL. Ces éléments seront supprimés.\n- \"verbatim_quote\" doit être un extrait exact de cette même ligne, idéalement 5 à 40 mots. Ne recolle jamais plusieurs lignes. Ne paraphrase jamais à l'intérieur de la citation.\n- Tu peux raccourcir une citation avec [...], mais la majorité des mots doivent rester ceux, exacts, de la ligne citée.\n\nCONFIDENTIALITÉ\nCe feedback peut être lu par d'autres personnes que l'interviewer. Avant de citer le transcript :\n- Ne retranscris JAMAIS : les circonstances de départ d'un salarié (rupture conventionnelle, licenciement, difficultés de performance), les rémunérations ou évaluations de salariés Riot, des informations personnelles sur des tiers nommés.\n- Si l'interviewer a divulgué une info de ce type pendant l'entretien, signale-le — c'est important — dans \"improvements\" ou \"risk_flags\" (severity \"medium\"), mais sans répéter le contenu : décris seulement la catégorie (ex : \"détails confidentiels sur le départ d'un salarié\") et remplace le passage sensible dans la citation par [confidentiel], en gardant les mots neutres autour pour que la citation reste reconnaissable.\n- Dans toutes les citations, garde uniquement ce qui illustre le comportement de l'interviewer ; coupe le reste avec [...].\n\nLES 4 PRINCIPES D'UN BON INTERVIEWER CHEZ RIOT\nÉvalue l'entretien sur ces 4 principes, dans cet ordre :\n1. HIGH STANDARDS — L'entretien est exigeant et rigoureux. Cadre l'entretien (agenda, durée annoncés). Pose des questions précises. Creuse les réponses vagues jusqu'à obtenir des exemples et des chiffres (\"What\", \"How\", \"Tell me more\").\n2. NO BLIND SPOTS — L'évaluation est complète et sans biais. Écoute plus qu'il ne parle (cible : ratio de parole de l'interviewer ≤ 0.30 — appuie-toi sur la métrique fournie, ne recalcule rien). Ne souffle pas les réponses (pas de questions orientées ou fermées). N'exprime pas de jugement pendant l'entretien. Explore les zones de doute au lieu de les éviter. Aucune question discriminatoire (âge, famille, grossesse, origine, nationalité, religion, santé, handicap, situation maritale...) — toute ligne touchant une caractéristique protégée va aussi dans \"risk_flags\", même posée gentiment ou en passant.\n3. CONTAGIOUS ENTHUSIASM — L'entretien donne envie de rejoindre Riot. Énergie et conviction. Vend Riot et le rôle, pas seulement de l'évaluation. Laisse de la place aux questions du candidat et y répond avec clarté.\n4. NEED FOR SPEED — L'entretien est efficace. Va droit au but, gère son temps. Annonce des next steps clairs et rapides en fin d'entretien.\n\nSORTIE\nRetourne UNIQUEMENT du JSON valide. Pas de fences markdown, pas de prose avant ou après. Ce schéma exact :\n\n{\n \"summary\": \"3 phrases max sur la conduite de l'entretien. Aucun signal d'embauche.\",\n \"score\": 7,\n \"principles\": [\n { \"principle\": \"HIGH STANDARDS\", \"verdict\": \"✅\", \"evidence\": [ { \"source_line_id\": \"L11\", \"verbatim_quote\": \"...\" } ] },\n { \"principle\": \"NO BLIND SPOTS\", \"verdict\": \"🟡\", \"evidence\": [ { \"source_line_id\": \"L13\", \"verbatim_quote\": \"...\" } ] },\n { \"principle\": \"CONTAGIOUS ENTHUSIASM\", \"verdict\": \"✅\", \"evidence\": [] },\n { \"principle\": \"NEED FOR SPEED\", \"verdict\": \"❌\", \"evidence\": [ { \"source_line_id\": \"L40\", \"verbatim_quote\": \"...\" } ] }\n ],\n \"strengths\": [\n { \"point\": \"Ce qu'il a bien fait\", \"source_line_id\": \"L11\", \"verbatim_quote\": \"...\" }\n ],\n \"improvements\": [\n { \"point\": \"Ce qu'il faut changer\",\n \"why_it_matters\": \"Le coût concret de faire comme ça\",\n \"source_line_id\": \"L13\",\n \"verbatim_quote\": \"...\",\n \"suggested_alternative\": \"Au lieu de X, essaie Y — une meilleure formulation de cette question précise\" }\n ],\n \"risk_flags\": [\n { \"severity\": \"high\", \"issue\": \"Question sur les projets de famille\", \"source_line_id\": \"L27\", \"verbatim_quote\": \"...\" }\n ],\n \"priority_action\": \"L'action numéro 1, concrète, pour le prochain entretien.\"\n}\n\n- \"score\" : note globale sur 10 de la conduite de l'entretien (jamais du candidat).\n- \"principles\" : exactement les 4 principes, dans l'ordre, verdict \"✅\" (solide), \"🟡\" (perfectible) ou \"❌\" (problème net), avec 1 à 2 citations d'appui chacun quand une ligne pertinente existe (tableau \"evidence\" vide sinon).\n- Émets au plus 2 \"strengths\" et au plus 2 \"improvements\" — les plus importants seulement.\n- \"risk_flags\" UNIQUEMENT quand une ligne touche clairement une caractéristique protégée ou une divulgation confidentielle — un tableau vide est la réponse correcte et fréquente. \"severity\" vaut \"high\" ou \"medium\".\n- Si l'entretien est bien mené, dis-le dans \"summary\" et garde des \"improvements\" mineurs ; ne fabrique pas de critique.`;\n\nexport function buildUserMessage(metrics: Metrics, interviewerName: string, transcriptText: string): string {\n const lines = [\n \"## Measured metrics (these are facts — do not recompute or estimate any number)\",\n `Interviewer talk ratio: ${metrics.interviewer_talk_ratio}`,\n `Candidate talk ratio: ${metrics.candidate_talk_ratio}`,\n `Interviewer turns: ${metrics.interviewer_turns}`,\n `Interviewer questions asked: ${metrics.interviewer_questions}`,\n `Average words per interviewer turn: ${metrics.avg_words_per_interviewer_turn}`,\n `Longest interviewer monologue (words): ${metrics.longest_interviewer_monologue_words}`,\n ];\n if (metrics.interview_span_minutes !== null) {\n lines.push(`Interview length (minutes): ${metrics.interview_span_minutes}`);\n }\n lines.push(\"\", \"## Interviewer\", interviewerName, \"\", \"## Transcript\", transcriptText);\n return lines.join(\"\\n\");\n}\n",[],[154,269],"89e8e41d-5c79-4691-8aa7-08816d3ab1f0","participants.ts","35d7d716-81c2-11f1-896f-1607ee4eb77e",3,["D",1784280655207],"import { isInternal, speakerEmail, countWords } from \"./lib.ts\";\nimport type { IdentifyResult, Meeting, Participant } from \"./types.ts\";\n\nexport const MIN_TRANSCRIPT_ENTRIES = 10;\n\nexport function identifyParticipants(meeting: Meeting | null | undefined): IdentifyResult {\n const transcript = Array.isArray(meeting && meeting.transcript) ? meeting!.transcript! : [];\n if (transcript.length < MIN_TRANSCRIPT_ENTRIES) {\n return { ok: false, reason: \"transcript_too_short\" };\n }\n\n const byEmail = new Map();\n for (const entry of transcript) {\n const email = speakerEmail(entry);\n if (!email) continue;\n const existing = byEmail.get(email) || {\n email,\n name: (entry.speaker && entry.speaker.display_name) || \"Unknown\",\n words: 0,\n };\n existing.words += countWords(entry.text);\n byEmail.set(email, existing);\n }\n\n const speakers = [...byEmail.values()];\n const byWordsDesc = (a: Participant, b: Participant) => b.words - a.words;\n const internal = speakers.filter((s) => isInternal(s.email)).sort(byWordsDesc);\n const external = speakers.filter((s) => !isInternal(s.email)).sort(byWordsDesc);\n\n if (internal.length === 0) return { ok: false, reason: \"no_internal_speaker\" };\n if (external.length === 0) return { ok: false, reason: \"no_external_speaker\" };\n\n return {\n ok: true,\n interviewer: internal[0],\n candidate: external[0],\n otherInternal: internal.slice(1),\n };\n}\n",[],[154,277],"414d9a48-4f3e-4f03-89f6-c38d5f2590a4","notion-blocks.ts","69ae91ec-81c2-11f1-9851-1607ee4eb77e",8,["D",1784280742135],"// Converts the rendered French Markdown into Notion blocks.\n// Supported subset (all that render.ts emits): ### headings, \"- \" bullets,\n// \"> \" quotes (possibly indented), plain paragraphs, and inline **bold** / _italic_.\n\nconst MAX_TEXT_LENGTH = 2000; // Notion limit per rich_text element\n\nexport interface RichText {\n type: \"text\";\n text: { content: string };\n annotations?: { bold?: boolean; italic?: boolean };\n}\n\nexport interface NotionBlock {\n object: \"block\";\n type: string;\n [key: string]: unknown;\n}\n\nfunction chunk(content: string): string[] {\n const chunks: string[] = [];\n for (let i = 0; i < content.length; i += MAX_TEXT_LENGTH) {\n chunks.push(content.slice(i, i + MAX_TEXT_LENGTH));\n }\n return chunks.length ? chunks : [\"\"];\n}\n\nexport function parseInline(text: string): RichText[] {\n const parts: RichText[] = [];\n // Tokenize on **bold** and _italic_ spans; everything else is plain.\n const pattern = /(\\*\\*[^*]+\\*\\*|_[^_]+_)/g;\n let lastIndex = 0;\n for (const match of text.matchAll(pattern)) {\n const index = match.index ?? 0;\n if (index > lastIndex) {\n for (const c of chunk(text.slice(lastIndex, index))) {\n parts.push({ type: \"text\", text: { content: c } });\n }\n }\n const token = match[0];\n if (token.startsWith(\"**\")) {\n for (const c of chunk(token.slice(2, -2))) {\n parts.push({ type: \"text\", text: { content: c }, annotations: { bold: true } });\n }\n } else {\n for (const c of chunk(token.slice(1, -1))) {\n parts.push({ type: \"text\", text: { content: c }, annotations: { italic: true } });\n }\n }\n lastIndex = index + token.length;\n }\n if (lastIndex < text.length) {\n for (const c of chunk(text.slice(lastIndex))) {\n parts.push({ type: \"text\", text: { content: c } });\n }\n }\n return parts.length ? parts : [{ type: \"text\", text: { content: \"\" } }];\n}\n\nfunction block(type: string, text: string): NotionBlock {\n return { object: \"block\", type, [type]: { rich_text: parseInline(text) } };\n}\n\nexport function markdownToNotionBlocks(markdown: string): NotionBlock[] {\n const blocks: NotionBlock[] = [];\n for (const rawLine of markdown.split(\"\\n\")) {\n const line = rawLine.trim();\n if (!line) continue;\n if (line.startsWith(\"### \")) {\n blocks.push(block(\"heading_3\", line.slice(4)));\n } else if (line.startsWith(\"> \")) {\n blocks.push(block(\"quote\", line.slice(2)));\n } else if (line.startsWith(\"- \")) {\n blocks.push(block(\"bulleted_list_item\", line.slice(2)));\n } else {\n blocks.push(block(\"paragraph\", line));\n }\n }\n return blocks;\n}\n",[],[154,285],"e3ff3f8f-9ee2-42a0-896a-7b0f11aff754","metrics.ts","41c79fac-81c2-11f1-8bfd-1607ee4eb77e",4,["D",1784280675234],"import { speakerEmail, countWords, timestampToSeconds, round, isInternal } from \"./lib.ts\";\nimport type { LabelledLine, Metrics, Role, TranscriptEntry } from \"./types.ts\";\n\ninterface Turn {\n email: string;\n words: number;\n entries: TranscriptEntry[];\n}\n\nexport function toTurns(transcript: TranscriptEntry[]): Turn[] {\n const turns: Turn[] = [];\n for (const entry of transcript) {\n const email = speakerEmail(entry);\n const words = countWords(entry.text);\n const last = turns[turns.length - 1];\n if (last && last.email === email) {\n last.words += words;\n last.entries.push(entry);\n } else {\n turns.push({ email, words, entries: [entry] });\n }\n }\n return turns;\n}\n\nexport function labelTranscript(\n transcript: TranscriptEntry[],\n interviewerEmail: string,\n candidateEmail: string,\n): LabelledLine[] {\n return transcript.map((entry, index) => {\n const email = speakerEmail(entry);\n let role: Role;\n if (email === interviewerEmail) role = \"INTERVIEWER\";\n else if (email === candidateEmail) role = \"CANDIDATE\";\n else if (isInternal(email)) role = \"OTHER_INTERNAL\";\n else role = \"OTHER_EXTERNAL\";\n\n const id = `L${index + 1}`;\n const name = (entry.speaker && entry.speaker.display_name) || \"Unknown\";\n const text = String(entry.text ?? \"\");\n return { id, role, email, name, text, line: `[${id}] [${role} ${name}]: ${text}` };\n });\n}\n\nexport function computeMetrics(\n transcript: TranscriptEntry[],\n interviewerEmail: string,\n candidateEmail: string,\n): Metrics {\n const entries = Array.isArray(transcript) ? transcript : [];\n\n let interviewerWords = 0;\n let candidateWords = 0;\n let totalWords = 0;\n let interviewerQuestions = 0;\n\n for (const entry of entries) {\n const email = speakerEmail(entry);\n const words = countWords(entry.text);\n totalWords += words;\n if (email === interviewerEmail) {\n interviewerWords += words;\n if (String(entry.text ?? \"\").includes(\"?\")) interviewerQuestions += 1;\n } else if (email === candidateEmail) {\n candidateWords += words;\n }\n }\n\n const interviewerTurns = toTurns(entries).filter((t) => t.email === interviewerEmail);\n const longestMonologue = interviewerTurns.reduce((max, t) => Math.max(max, t.words), 0);\n\n const first = entries.length ? timestampToSeconds(entries[0].timestamp) : null;\n const last = entries.length ? timestampToSeconds(entries[entries.length - 1].timestamp) : null;\n const span = first !== null && last !== null ? Math.round((last - first) / 60) : null;\n\n return {\n interviewer_talk_ratio: totalWords ? round(interviewerWords / totalWords, 2) : 0,\n candidate_talk_ratio: totalWords ? round(candidateWords / totalWords, 2) : 0,\n interviewer_turns: interviewerTurns.length,\n interviewer_questions: interviewerQuestions,\n avg_words_per_interviewer_turn: interviewerTurns.length\n ? round(interviewerWords / interviewerTurns.length, 1)\n : 0,\n longest_interviewer_monologue_words: longestMonologue,\n interview_span_minutes: span,\n };\n}\n",[],[154,293],"9e574286-21e0-4ed3-9d03-3816c875a57d","lib.ts","3304c904-81c2-11f1-9c86-1607ee4eb77e",2,["D",1784280650418],"import type { TranscriptEntry } from \"./types.ts\";\n\nexport const RIOT_EMAIL_DOMAIN = \"tryriot.com\";\n\nexport function normalizeEmail(email: unknown): string {\n return String(email ?? \"\").trim().toLowerCase();\n}\n\nexport function isInternal(email: unknown): boolean {\n const normalized = normalizeEmail(email);\n const atCount = (normalized.match(/@/g) || []).length;\n if (atCount !== 1) return false;\n return normalized.split(\"@\").pop() === RIOT_EMAIL_DOMAIN;\n}\n\nexport function speakerEmail(entry: TranscriptEntry | null | undefined): string {\n const speaker = (entry && entry.speaker) || {};\n return normalizeEmail(\n speaker.matched_calendar_invitee_email ||\n speaker.email ||\n (speaker.matched_calendar_invitee && speaker.matched_calendar_invitee.email)\n );\n}\n\nexport function countWords(text: unknown): number {\n return String(text ?? \"\").trim().split(/\\s+/).filter(Boolean).length;\n}\n\nexport function timestampToSeconds(ts: unknown): number | null {\n const raw = String(ts ?? \"\").trim();\n if (!raw) return null;\n const segments = raw.split(\":\");\n if (segments.some((seg) => !/^\\d+$/.test(seg))) return null;\n const parts = segments.map(Number);\n if (parts.length === 3) return parts[0] * 3600 + parts[1] * 60 + parts[2];\n if (parts.length === 2) return parts[0] * 60 + parts[1];\n return null;\n}\n\nexport function round(n: number, dp: number): number {\n const factor = 10 ** dp;\n return Math.round(n * factor) / factor;\n}\n",[],[154,301],["D",1784280644634],[170,171,172,173,174,175,176,177,178],[154],["D",1784280622128],["D",1789527031073],{"_98":97,"_106":102},{"_98":97,"_99":100,"_101":102,"_18":53,"_103":104,"_105":24},{"_13":87,"_31":88,"_41":40,"_89":42,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":43,"_96":97},"ctx",{"_80":-5,"_126":349,"_350":351,"_352":353,"_354":24,"_355":24,"_356":24,"_357":57,"_358":-5,"_359":-7,"_360":-7,"_361":61,"_362":24,"_363":24,"_364":-5,"_365":24,"_366":24,"_367":24,"_368":-5},"ENV",{"_320":321,"_322":323,"_324":88,"_325":326,"_327":328,"_329":330,"_331":332,"_333":334,"_335":336,"_337":338,"_339":340,"_341":342,"_343":344,"_345":346,"_347":348},"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 · v16