[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_213":214,"_215":216},"routes/_app.x.$handle.$name",{"_99":98,"_32":44,"_108":89,"_27":103,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":48,"_122":123,"_124":25,"_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",{"_42":43,"_32":44,"_37":45,"_46":-5,"_47":48,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":25,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":48},"version",65,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",true,"deletedHere","path","backfill-arrivals.tsx","latestPath","fileId","b2fd5da4-7e13-11f1-9be1-1607ee4eb77e","name","fileType","http","content","// One-off: backfill the Arrivals DB so every SF student has an Arrivals row.\n// Source of truth = SF Student List. For each student with no Arrivals row,\n// create one linking \"Student Relation\" -> the student page. Everything else\n// (Date/Time, Method, Airport, etc.) left blank. Rollups (Room, Age, Email,\n// Gender, names, parent info, phones) auto-populate from the linked student.\n// Gated behind ARR_KEY. Dry run by default; ?apply=true to write.\n// Delete this file when done.\n\nconst NOTION_TOKEN = Deno.env.get(\"NOTION_TOKEN\");\nconst KEY = Deno.env.get(\"ARR_KEY\");\nconst NOTION_VERSION = \"2025-09-03\";\n\nconst STUDENT_DS = \"3b9cd139-473f-4100-b5e2-e9aa69486832\"; // SF Student List\nconst ARRIVALS_DS = \"0c73e5f4-9e2f-4e52-90ce-c5a86ab57c64\"; // Arrivals\nconst REL_PROP = \"Student Relation\"; // relation on Arrivals -> Student List\n\nfunction notion(path: string, method: string, body?: unknown) {\n return fetch(`https://api.notion.com/v1/${path}`, {\n method,\n headers: {\n Authorization: `Bearer ${NOTION_TOKEN}`,\n \"Notion-Version\": NOTION_VERSION,\n \"Content-Type\": \"application/json\",\n },\n body: body ? JSON.stringify(body) : undefined,\n });\n}\n\nfunction plain(prop: any): string {\n const items = prop?.title ?? prop?.rich_text ?? [];\n return items.map((p: any) => p?.plain_text ?? \"\").join(\"\").trim();\n}\n\nasync function fetchAll(ds: string): Promise {\n const rows: any[] = [];\n let cursor: string | undefined;\n do {\n const body: any = { page_size: 100 };\n if (cursor) body.start_cursor = cursor;\n const r = await notion(`data_sources/${ds}/query`, \"POST\", body);\n const j = await r.json();\n if (!r.ok) throw new Error(\"query failed: \" + JSON.stringify(j));\n rows.push(...(j.results ?? []));\n cursor = j.has_more ? j.next_cursor : undefined;\n } while (cursor);\n return rows;\n}\n\n// Collect { propName: [linkedPageId,...] } for every relation-type property on a page.\nfunction relationLinks(page: any): Record {\n const out: Record = {};\n for (const [name, val] of Object.entries(page.properties ?? {})) {\n if (val?.type === \"relation\" && Array.isArray(val.relation)) {\n out[name] = val.relation.map((r: any) => r.id);\n }\n }\n return out;\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const key = req.headers.get(\"x-arr-key\") ?? url.searchParams.get(\"key\");\n if (!KEY || key !== KEY) return new Response(\"unauthorized\", { status: 401 });\n if (!NOTION_TOKEN) {\n return new Response(JSON.stringify({ ok: false, error: \"missing NOTION_TOKEN\" }, null, 2),\n { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n }\n const apply = req.headers.get(\"x-apply\") === \"true\" || url.searchParams.get(\"apply\") === \"true\";\n\n // --- Read the Arrivals data source schema (authoritative relation ids). ---\n const dsResp = await notion(`data_sources/${ARRIVALS_DS}`, \"GET\");\n const dsJson = await dsResp.json();\n const relSchema: any[] = [];\n for (const [name, def] of Object.entries(dsJson?.properties ?? {})) {\n if (def?.type === \"relation\") {\n relSchema.push({\n name,\n id: def.id,\n data_source_id: def.relation?.data_source_id,\n type: def.relation?.type,\n synced_property_name: def.relation?.dual_property?.synced_property_name,\n synced_property_id: def.relation?.dual_property?.synced_property_id,\n });\n }\n }\n const relProp = dsJson?.properties?.[REL_PROP];\n const relPropExists = relProp?.type === \"relation\";\n\n // --- Read both databases. ---\n let studentRows: any[], arrivalRows: any[];\n try {\n [studentRows, arrivalRows] = await Promise.all([fetchAll(STUDENT_DS), fetchAll(ARRIVALS_DS)]);\n } catch (e) {\n return new Response(JSON.stringify({ ok: false, error: String(e) }, null, 2),\n { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n }\n\n const students = studentRows.map((p) => ({\n id: p.id,\n name: plain(p.properties?.[\"Notion Page\"]),\n first: plain(p.properties?.[\"First Name\"]),\n last: plain(p.properties?.[\"Last Name\"]),\n email: p.properties?.[\"Email\"]?.email ?? null,\n }));\n const studentIds = new Set(students.map((s) => s.id));\n\n // Which students are already linked from an Arrivals row (via REL_PROP)?\n const linkedViaRel = new Set();\n const linkedViaAnyRel = new Set();\n const arrivalsNoLink: any[] = [];\n const danglingLinks: any[] = [];\n const linkCount: Record = {};\n for (const a of arrivalRows) {\n const links = relationLinks(a);\n const relIds = links[REL_PROP] ?? [];\n const allIds = Object.values(links).flat();\n for (const id of relIds) {\n linkedViaRel.add(id);\n linkCount[id] = (linkCount[id] ?? 0) + 1;\n }\n for (const id of allIds) {\n linkedViaAnyRel.add(id);\n if (!studentIds.has(id)) danglingLinks.push({ arrival: plain(a.properties?.[\"Notion Page\"]), id });\n }\n if (allIds.length === 0) arrivalsNoLink.push({ id: a.id, title: plain(a.properties?.[\"Notion Page\"]) });\n }\n\n const missing = students.filter((s) => !linkedViaRel.has(s.id));\n const dupLinked = Object.entries(linkCount).filter(([, n]) => n > 1)\n .map(([id, n]) => ({ id, count: n, name: students.find((s) => s.id === id)?.name }));\n\n // Sample a populated arrival row to confirm which relation drives rollups.\n const sampleSrc = arrivalRows.find((a) => (relationLinks(a)[REL_PROP] ?? []).length > 0) ?? arrivalRows[0];\n let sampleRow: any = null;\n if (sampleSrc) {\n const props = sampleSrc.properties ?? {};\n const rollups: Record = {};\n for (const [name, val] of Object.entries(props)) {\n if (val?.type === \"rollup\") {\n const rr = val.rollup;\n rollups[name] = rr?.type === \"array\"\n ? (rr.array ?? []).map((x: any) => x?.[x?.type])\n : rr?.[rr?.type] ?? rr;\n }\n }\n sampleRow = {\n title: plain(props[\"Notion Page\"]),\n relationLinks: relationLinks(sampleSrc),\n rollupValues: rollups,\n };\n }\n\n // --- Apply: create an Arrivals row per missing student. ---\n let applyResult: any = \"skipped (dry run)\";\n if (apply) {\n if (!relPropExists) {\n return new Response(JSON.stringify({ ok: false, error: `relation property '${REL_PROP}' not found on Arrivals` }, null, 2),\n { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n }\n applyResult = { created: [] as string[], errors: [] as any[] };\n for (const s of missing) {\n const title = s.name || [s.first, s.last].filter(Boolean).join(\" \").trim() || \"(unnamed)\";\n const props: any = {\n \"Notion Page\": { title: [{ type: \"text\", text: { content: title } }] },\n [REL_PROP]: { relation: [{ id: s.id }] },\n };\n const res = await notion(\"pages\", \"POST\", {\n parent: { type: \"data_source_id\", data_source_id: ARRIVALS_DS },\n properties: props,\n });\n const j = await res.json();\n if (res.ok) applyResult.created.push(title);\n else applyResult.errors.push({ student: title, status: res.status, error: j });\n await new Promise((r) => setTimeout(r, 160));\n }\n }\n\n const payload = {\n mode: apply ? \"APPLIED\" : \"DRY RUN\",\n arrivalsRelationSchema: relSchema,\n relPropUsed: REL_PROP,\n relPropExists,\n counts: {\n students: students.length,\n arrivalRows: arrivalRows.length,\n alreadyLinked: linkedViaRel.size,\n missing: missing.length,\n arrivalsWithNoLink: arrivalsNoLink.length,\n },\n sampleRow,\n missingStudents: missing.map((s) => ({ id: s.id, name: s.name, email: s.email })),\n arrivalsWithNoLink: arrivalsNoLink,\n duplicateLinks: dupLinked,\n danglingLinks,\n applyResult,\n };\n return new Response(JSON.stringify(payload, null, 2), { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n}\n","createdAt",["D",1783875921752],"branchVersion","branchId","6ea9e81e-5f84-11f1-8ea9-1607ee4eb77e","id","6ea94daa-5f84-11f1-8ea9-1607ee4eb77e","logistics-sync",["D",1780515782210],"deletedAt","legacyEnvVars",false,"privacy","public","httpPrivacy","description","Form to Notion sync","imageUrl","57b8f323-328a-47b3-86c3-c762ebff5f42","pinnedFileId","10db2ebc-692c-11f1-8ac0-1607ee4eb77e","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019e8ef8-82d4-720f-b07f-808c7f165c8a","tursoName","6ea94daa5f8411f18ea91607ee4eb77e","tursoHostname","6ea94daa5f8411f18ea91607ee4eb77e-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789512647429],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_99":98,"_107":103},"org",{"_99":98,"_100":101,"_102":103,"_18":55,"_104":105,"_106":48},"branch",{"_13":88,"_32":89,"_42":41,"_90":43,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":44,"_97":98},"isOwned",67,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","sadok","handle","displayName","Sadok Cervantes","avatar","","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_42":43,"_32":44,"_37":208,"_46":-5,"_47":48,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":25,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":209,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":210,"_83":211,"_85":212,"_87":48},"tree",[187,188,189,190,191],"files",[187,188,189,190,191],"counts",{"_175":62,"_176":177,"_178":62,"_179":180,"_181":182},"contents",[129,130,131,132,133],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":167,"_32":168,"_30":169,"_137":-5,"_40":41,"_39":170,"_139":25,"_37":171,"_13":172,"_33":34,"_35":173,"_24":48,"_143":-5,"_27":174},{"_42":160,"_32":161,"_30":162,"_137":-5,"_40":41,"_39":163,"_139":25,"_37":164,"_13":150,"_33":34,"_35":165,"_24":48,"_143":-5,"_27":166},{"_42":153,"_32":154,"_30":57,"_137":-5,"_40":41,"_39":155,"_139":25,"_37":156,"_13":157,"_33":34,"_35":158,"_24":48,"_143":-5,"_27":159},{"_42":145,"_32":146,"_30":147,"_137":-5,"_40":41,"_39":148,"_139":25,"_37":149,"_13":150,"_33":34,"_35":151,"_24":48,"_143":-5,"_27":152},{"_42":134,"_32":135,"_30":136,"_137":-5,"_40":41,"_39":138,"_139":25,"_37":140,"_13":141,"_33":34,"_35":142,"_24":48,"_143":-5,"_27":144},"1b114403-2d22-45b2-8b25-8925c972a1f6","main.tsx","6eac93de-5f84-11f1-8ea9-1607ee4eb77e","parentId",36,"latest",["D",1781898307578],20,"// Webhook: form POST -> match a person by email in the roster data source\n// -> pull the source-of-truth name -> create one arrival row and one\n// departure row with the relation set. No match -> rows are still created\n// without the relation so nothing is lost, and a Slack alert is sent so the\n// email can be fixed or the record linked manually.\n//\n// Notion API 2025-09-03 (data sources).\n//\n// Env vars (Val Town -> Settings -> Environment Variables):\n// NOTION_TOKEN Notion integration secret (required)\n// SLACK_DM_CHANNEL Slack member ID for the no-match alert (required)\n//\n// SLACK_TOKEN is injected by Val Town's Slack connection.\n\nimport { WebClient } from \"npm:@slack/web-api\";\n\nconst NOTION_TOKEN = Deno.env.get(\"NOTION_TOKEN\");\nconst SLACK_DM_CHANNEL = Deno.env.get(\"SLACK_DM_CHANNEL\");\nconst SLACK_TOKEN = Deno.env.get(\"SLACK_TOKEN\");\n\nconst NOTION_VERSION = \"2025-09-03\";\n\n// Data source IDs — required by Notion API 2025-09-03\nconst STUDENT_DS = \"3b9cd139-473f-4100-b5e2-e9aa69486832\";\nconst ARRIVALS_DS = \"0c73e5f4-9e2f-4e52-90ce-c5a86ab57c64\";\nconst DEPARTURES_DS = \"268eee30-2306-4f40-a54a-c2aeaad623ab\";\n\nfunction notion(path: string, method: string, body?: unknown) {\n return fetch(`https://api.notion.com/v1/${path}`, {\n method,\n headers: {\n Authorization: `Bearer ${NOTION_TOKEN}`,\n \"Notion-Version\": NOTION_VERSION,\n \"Content-Type\": \"application/json\",\n },\n body: body ? JSON.stringify(body) : undefined,\n });\n}\n\nasync function slackNotify(text: string) {\n if (!SLACK_TOKEN || !SLACK_DM_CHANNEL) {\n console.warn(\"Slack not configured; skipping alert:\", text);\n return;\n }\n try {\n const slack = new WebClient(SLACK_TOKEN);\n await slack.chat.postMessage({ channel: SLACK_DM_CHANNEL, text });\n } catch (e) {\n console.error(\"Slack notify failed\", e);\n }\n}\n\nfunction norm(s: string): string {\n return (s || \"\").replace(/&/g, \"&\").replace(/\\s+/g, \" \").trim().toLowerCase();\n}\n\nfunction buildFieldMap(fields: any[]): Record {\n const map: Record = {};\n for (const f of fields || []) {\n let value = f.value;\n if (Array.isArray(value) && Array.isArray(f.options)) {\n value = value\n .map((id: string) => f.options.find((o: any) => o.id === id)?.text ?? id)\n .join(\", \");\n } else if (Array.isArray(value)) {\n value = value.join(\", \");\n }\n map[norm(f.label)] = value == null ? \"\" : String(value);\n }\n return map;\n}\n\nconst title = (v: string) => ({ title: [{ text: { content: v || \"\" } }] });\nconst rich = (v: string) => (v ? { rich_text: [{ text: { content: v } }] } : { rich_text: [] });\nconst sel = (v: string) => (v ? { select: { name: v } } : { select: null });\nconst mail = (v: string) => (v ? { email: v } : { email: null });\n\nasync function upsert(\n dsId: string,\n props: Record,\n studentId: string | null,\n fullName: string,\n): Promise<{ ok: boolean; action: string; id?: string; detail?: unknown }> {\n // Find an existing row: by linked student when matched, else by name.\n const filter = studentId\n ? { property: \"Student Relation\", relation: { contains: studentId } }\n : { property: \"Notion Page\", title: { equals: fullName } };\n const q = await notion(`data_sources/${dsId}/query`, \"POST\", { filter, page_size: 1 });\n const qj = await q.json();\n const existing = q.ok ? qj.results?.[0] : null;\n if (existing) {\n const r = await notion(`pages/${existing.id}`, \"PATCH\", { properties: props });\n return { ok: r.ok, action: \"updated\", id: existing.id, detail: r.ok ? undefined : await r.json() };\n }\n const c = await notion(\"pages\", \"POST\", {\n parent: { type: \"data_source_id\", data_source_id: dsId },\n properties: props,\n });\n return { ok: c.ok, action: \"created\", detail: c.ok ? undefined : await c.json() };\n}\n\nexport default async function (req: Request): Promise {\n if (req.method !== \"POST\") {\n return new Response(\"listener live\", { status: 200 });\n }\n if (!NOTION_TOKEN) {\n console.error(\"Missing NOTION_TOKEN env var\");\n return new Response(\"server not configured\", { status: 500 });\n }\n\n let payload: any;\n try {\n payload = await req.json();\n } catch {\n return new Response(\"bad json\", { status: 400 });\n }\n\n const data = payload?.data ?? {};\n const m = buildFieldMap(data.fields);\n\n const email = (m[\"student email\"] || \"\").trim();\n const tallyFirst = (m[\"student first name\"] || \"\").trim();\n const tallyLast = (m[\"student last name\"] || \"\").trim();\n\n const arriveMethod = m[\"how will the student arrive?\"] || \"\";\n const arriveAirport = m[\"arrival airport\"] || \"\";\n const arriveFlight = m[\"arrival airline & flight number\"] || \"\";\n const arriveTime = m[\"arrival time (24-hour format)\"] || \"\";\n\n const departMethod = m[\"how will the student depart?\"] || \"\";\n const departAirport = m[\"departure airport\"] || \"\";\n const departFlight = m[\"departure airline & flight number\"] || \"\";\n const departTime = m[\"departure time (24-hour format)\"] || \"\";\n\n if (!email) {\n console.warn(\"Submission has no email; skipping\", data?.submissionId);\n return new Response(JSON.stringify({ ok: false, reason: \"no email\" }), {\n status: 200,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n\n // 1) Match student by email\n const q = await notion(`data_sources/${STUDENT_DS}/query`, \"POST\", {\n filter: { property: \"Email\", email: { equals: email } },\n page_size: 1,\n });\n const qj = await q.json();\n if (!q.ok) {\n console.error(\"Notion student query failed\", qj);\n return new Response(\"notion query error\", { status: 502 });\n }\n\n const student = qj.results?.[0];\n const tallyFull = `${tallyFirst} ${tallyLast}`.trim();\n let fullName = tallyFull;\n let studentRelation: { id: string }[] = [];\n\n if (student) {\n studentRelation = [{ id: student.id }];\n const p = student.properties || {};\n fullName = p[\"Notion Page\"]?.title?.[0]?.plain_text || tallyFull;\n } else {\n await slackNotify(\n `:warning: *Logistics sync - no match found*\\n` +\n `Student: *${tallyFirst} ${tallyLast}*\\n` +\n `Email submitted: \\`${email}\\`\\n` +\n `Unlinked Arrival + Departure rows were created. Fix the email on the student record or link them manually in Notion.`,\n );\n }\n\n // 2) Create Arrivals row\n const arrivalProps: Record = {\n \"Notion Page\": title(fullName),\n \"Method\": sel(arriveMethod),\n \"Airport\": sel(arriveAirport),\n \"Airline/Flight\": rich(arriveFlight),\n \"Date/Time\": rich(arriveTime),\n };\n if (studentRelation.length) arrivalProps[\"Student Relation\"] = { relation: studentRelation };\n\n const aRes = await upsert(ARRIVALS_DS, arrivalProps, student ? student.id : null, fullName);\n if (!aRes.ok) console.error(\"Arrival upsert failed\", aRes.detail);\n\n // 3) Create Departures row\n const departureProps: Record = {\n \"Notion Page\": title(fullName),\n \"Method\": sel(departMethod),\n \"Airport\": sel(departAirport),\n \"Airline/Flight\": rich(departFlight),\n \"Date/Time\": rich(departTime),\n };\n if (studentRelation.length) departureProps[\"Student Relation\"] = { relation: studentRelation };\n\n const dRes = await upsert(DEPARTURES_DS, departureProps, student ? student.id : null, fullName);\n if (!dRes.ok) console.error(\"Departure upsert failed\", dRes.detail);\n\n return new Response(\n JSON.stringify({\n ok: true,\n matched: !!student,\n email,\n arrival: aRes.ok ? aRes.action : \"failed\",\n departure: dRes.ok ? dRes.action : \"failed\",\n }),\n { status: 200, headers: { \"Content-Type\": \"application/json\" } },\n );\n}\n","label",[135],"21a2651d-46f9-481e-9f6f-edf9043c6530","insurance-sync.tsx","546abdca-774e-11f1-bcbd-1607ee4eb77e",61,["D",1783134053552],5,"// One-off insurance sync endpoint. Gated by INS_KEY.\n// POST JSON: { apply?: boolean, records: [{ name, policy, under, envelopeId? }] }\n// Reads SF Student List, matches by \"First Last\" (with reversed fallback),\n// updates \"Insurance Policy\" and \"Insurance Under\" idempotently.\n// No student data is hardcoded here; records arrive at runtime.\n\nconst DATA_SOURCE_ID = \"3b9cd139-473f-4100-b5e2-e9aa69486832\";\nconst NOTION_VERSION = \"2025-09-03\";\n\nconst norm = (s: string) =>\n (s ?? \"\").toString().trim().toLowerCase().replace(/\\s+/g, \" \");\nconst reversed = (s: string) => {\n const t = norm(s).split(\" \");\n return t.length >= 2 ? [t[t.length - 1], ...t.slice(0, -1)].join(\" \") : norm(s);\n};\nconst rt = (v: string) => (v ? [{ type: \"text\", text: { content: v } }] : []);\nconst plain = (prop: any): string => {\n if (!prop) return \"\";\n const arr = prop.rich_text || prop.title || [];\n return arr.map((x: any) => x.plain_text ?? x.text?.content ?? \"\").join(\"\").trim();\n};\n\nexport default async function (req: Request): Promise {\n const j = (obj: any) =>\n new Response(JSON.stringify(obj, null, 2), {\n status: 200,\n headers: { \"content-type\": \"application/json\" },\n });\n try {\n const url = new URL(req.url);\n if (url.searchParams.get(\"key\") !== Deno.env.get(\"INS_KEY\"))\n return j({ ok: false, error: \"bad key\" });\n const token = Deno.env.get(\"NOTION_TOKEN\");\n const H = {\n Authorization: `Bearer ${token}`,\n \"Notion-Version\": NOTION_VERSION,\n \"content-type\": \"application/json\",\n };\n\n const readRoster = async () => {\n const rows: any[] = [];\n let cursor: string | undefined = undefined;\n do {\n const r = await fetch(`https://api.notion.com/v1/data_sources/${DATA_SOURCE_ID}/query`, {\n method: \"POST\", headers: H, body: JSON.stringify({ page_size: 100, start_cursor: cursor }),\n });\n const d = await r.json();\n if (!r.ok) throw new Error(`query ${r.status}: ${JSON.stringify(d)}`);\n rows.push(...(d.results || []));\n cursor = d.has_more ? d.next_cursor : undefined;\n } while (cursor);\n return rows;\n };\n\n if (req.method === \"GET\") {\n const rows = await readRoster();\n const names = rows\n .map((p) => norm(`${plain(p.properties?.[\"First Name\"])} ${plain(p.properties?.[\"Last Name\"])}`))\n .sort();\n return j({ ok: true, rosterCount: rows.length, names });\n }\n if (req.method !== \"POST\")\n return j({ ok: false, error: \"POST required\" });\n\n const body = await req.json();\n const apply = body.apply === true;\n const records: Array<{ name: string; policy: string; under: string; envelopeId?: string }> =\n body.records || [];\n\n // Optional: pull straight from DocuSign for the given envelope IDs.\n const envelopeIds: string[] = body.envelopeIds || [];\n const pullErrors: any[] = [];\n if (envelopeIds.length) {\n const dsToken = Deno.env.get(\"DS_ACCESS_TOKEN\");\n if (!dsToken) return j({ ok: false, error: \"DS_ACCESS_TOKEN not set on the val\" });\n const DS_BASE = \"https://na3.docusign.net\";\n const DS_ACCT = \"b83e64f1-b726-44fb-b692-5c1152c2d45f\";\n const TAB_INSURER = \"Text a7057c73-6775-497a-bb88-d9f599377390\";\n const TAB_POLICY = \"Text b4278c2a-6255-459f-a5b6-0ed0d4b0e977\";\n const TAB_UNDER = \"Text 8b58da95-f263-4643-ae76-f3121bae772d\";\n for (const eid of envelopeIds) {\n try {\n const rr = await fetch(\n `${DS_BASE}/restapi/v2.1/accounts/${DS_ACCT}/envelopes/${eid}/recipients?include_tabs=true`,\n { headers: { Authorization: `Bearer ${dsToken}` } },\n );\n const rd = await rr.json();\n if (!rr.ok) { pullErrors.push({ eid, status: rr.status, detail: rd }); continue; }\n const signers = rd.signers || [];\n const student =\n (signers.find((s: any) => (s.roleName || \"\").toLowerCase() === \"student\")?.name || \"\").trim();\n let insurer = \"\", policyNum = \"\", under = \"\";\n for (const s of signers) {\n for (const t of (s.tabs?.textTabs || [])) {\n if (t.tabLabel === TAB_INSURER) insurer = (t.value || \"\").trim();\n else if (t.tabLabel === TAB_POLICY) policyNum = (t.value || \"\").trim();\n else if (t.tabLabel === TAB_UNDER) under = (t.value || \"\").trim();\n }\n }\n const policy = [insurer, policyNum].filter(Boolean).join(\" \");\n if (!student) pullErrors.push({ eid, warn: \"no student-role recipient\", insurer, policyNum, under });\n records.push({ name: student, policy, under, envelopeId: eid });\n } catch (e) {\n pullErrors.push({ eid, error: String(e) });\n }\n }\n }\n\n // 1) Read full roster\n const rows = await readRoster();\n\n // 2) Build name index\n const index = new Map();\n for (const p of rows) {\n const first = plain(p.properties?.[\"First Name\"]);\n const last = plain(p.properties?.[\"Last Name\"]);\n const full = norm(`${first} ${last}`);\n const rec = {\n id: p.id,\n full,\n policy: plain(p.properties?.[\"Insurance Policy\"]),\n under: plain(p.properties?.[\"Insurance Under\"]),\n };\n if (!index.has(full)) index.set(full, []);\n index.get(full)!.push(rec);\n }\n\n const report: any = {\n ok: true,\n apply,\n rosterCount: rows.length,\n recordCount: records.length,\n pullErrors,\n updated: [],\n alreadyCorrect: [],\n unmatched: [],\n ambiguous: [],\n };\n\n for (const rec of records) {\n const wantPolicy = (rec.policy ?? \"\").trim();\n const wantUnder = (rec.under ?? \"\").trim();\n let cands = index.get(norm(rec.name)) || [];\n if (cands.length === 0) cands = index.get(reversed(rec.name)) || [];\n if (cands.length === 0) {\n report.unmatched.push(rec.name);\n continue;\n }\n if (cands.length > 1) {\n report.ambiguous.push(rec.name);\n continue;\n }\n const page = cands[0];\n const same = page.policy === wantPolicy && page.under === wantUnder;\n if (same) {\n report.alreadyCorrect.push(rec.name);\n continue;\n }\n if (!apply) {\n report.updated.push({ name: rec.name, wouldSet: { policy: wantPolicy, under: wantUnder }, from: { policy: page.policy, under: page.under } });\n continue;\n }\n const pr = await fetch(`https://api.notion.com/v1/pages/${page.id}`, {\n method: \"PATCH\",\n headers: H,\n body: JSON.stringify({\n properties: {\n \"Insurance Policy\": { rich_text: rt(wantPolicy) },\n \"Insurance Under\": { rich_text: rt(wantUnder) },\n },\n }),\n });\n if (!pr.ok) {\n const detail = await pr.json().catch(() => ({}));\n report.updated.push({ name: rec.name, error: true, status: pr.status, detail });\n } else {\n report.updated.push({ name: rec.name, set: { policy: wantPolicy, under: wantUnder } });\n }\n }\n return j(report);\n } catch (e) {\n return j({ ok: false, error: String(e), stack: (e as any)?.stack });\n }\n}\n",[146],"ac67e68e-0a48-4d8a-a886-8c59aca67e22","fix-online-names.tsx",26,["D",1781592560697],8,"// One-off: fix titles in a roster data source.\n//\n// Current state per row: title (\"Notion Page\") holds the FIRST name,\n// \"First Name\" column is empty, \"Last Name\" is populated.\n// This sets the title to \"First Last\" and copies the first name into \"First Name\".\n//\n// Safe to re-run: only rows whose \"First Name\" is still empty are touched.\n// Output lists names, so the endpoint is gated behind FIX_KEY.\n//\n// GET ...?key=FIX_KEY -> dry run, returns the planned changes\n// GET ...?key=FIX_KEY&apply=true -> writes the changes\n//\n// Delete this file once the migration is done.\n\nconst NOTION_TOKEN = Deno.env.get(\"NOTION_TOKEN\");\nconst FIX_KEY = Deno.env.get(\"FIX_KEY\");\nconst NOTION_VERSION = \"2025-09-03\";\n// redeploy nonce 1\nconst ONLINE_DS = \"9f3e6237-4908-4bf9-b64f-6f7e13cce320\"; // roster data source\n\nfunction notion(path: string, method: string, body?: unknown) {\n return fetch(`https://api.notion.com/v1/${path}`, {\n method,\n headers: {\n Authorization: `Bearer ${NOTION_TOKEN}`,\n \"Notion-Version\": NOTION_VERSION,\n \"Content-Type\": \"application/json\",\n },\n body: body ? JSON.stringify(body) : undefined,\n });\n}\n\nfunction plain(prop: any): string {\n const items = prop?.title ?? prop?.rich_text ?? [];\n return items.map((p: any) => p?.plain_text ?? \"\").join(\"\").trim();\n}\n\nfunction titleCase(s: string): string {\n return (s || \"\")\n .trim()\n .split(/\\s+/)\n .map((w) => (w ? w[0].toLocaleUpperCase() + w.slice(1).toLocaleLowerCase() : w))\n .join(\" \");\n}\n\nasync function fetchAll(): Promise {\n const rows: any[] = [];\n let cursor: string | undefined;\n do {\n const body: any = { page_size: 100 };\n if (cursor) body.start_cursor = cursor;\n const r = await notion(`data_sources/${ONLINE_DS}/query`, \"POST\", body);\n const j = await r.json();\n if (!r.ok) throw new Error(\"query failed: \" + JSON.stringify(j));\n rows.push(...(j.results ?? []));\n cursor = j.has_more ? j.next_cursor : undefined;\n } while (cursor);\n return rows;\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const providedKey = req.headers.get(\"x-fix-key\") ?? url.searchParams.get(\"key\");\n if (!FIX_KEY || providedKey !== FIX_KEY) {\n return new Response(\"unauthorized\", { status: 401 });\n }\n if (!NOTION_TOKEN) return new Response(\"missing NOTION_TOKEN\", { status: 500 });\n\n const apply = req.headers.get(\"x-apply\") === \"true\" || url.searchParams.get(\"apply\") === \"true\";\n\n let rows: any[];\n try {\n rows = await fetchAll();\n } catch (e) {\n return new Response(JSON.stringify({ ok: false, error: String(e) }, null, 2), {\n status: 200,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n\n const planned: any[] = [];\n const flagged: any[] = [];\n let skipped = 0;\n\n for (const page of rows) {\n const p = page.properties || {};\n const currentTitle = plain(p[\"Notion Page\"]); // = first name today\n const existingFirst = plain(p[\"First Name\"]);\n const last = plain(p[\"Last Name\"]);\n\n if (existingFirst) { skipped++; continue; } // already fixed\n if (!currentTitle) { skipped++; continue; } // nothing to derive from\n\n const first = titleCase(currentTitle);\n const tcLast = titleCase(last);\n const newTitle = `${first} ${tcLast}`.trim();\n const change = { id: page.id, first, last: tcLast, newTitle };\n if (!tcLast) flagged.push(change);\n planned.push(change);\n }\n\n let applied = 0;\n const errors: any[] = [];\n if (apply) {\n for (const c of planned) {\n const res = await notion(`pages/${c.id}`, \"PATCH\", {\n properties: {\n \"Notion Page\": { title: [{ text: { content: c.newTitle } }] },\n \"First Name\": { rich_text: [{ text: { content: c.first } }] },\n },\n });\n if (res.ok) applied++;\n else errors.push({ id: c.id, error: await res.json() });\n await new Promise((r) => setTimeout(r, 350)); // stay under ~3 req/s\n }\n }\n\n return new Response(\n JSON.stringify({\n mode: apply ? \"APPLIED\" : \"DRY RUN\",\n totalRows: rows.length,\n toProcess: planned.length,\n skippedAlreadyDoneOrEmpty: skipped,\n flaggedMissingLastName: flagged,\n applied,\n errors,\n planned,\n }, null, 2),\n { status: 200, headers: { \"Content-Type\": \"application/json\" } },\n );\n}\n",[154],"4b507d03-25c3-41e0-aab5-430a25105ef2","assign-teams.tsx","21597b3e-6ac3-11f1-8cd3-1607ee4eb77e",32,["D",1781765097904],"// One-off: add a \"Team\" select property to the roster and assign each row.\n// Gated behind FIX_KEY. Dry run by default; send header x-apply: true to write.\n// Delete this file when done.\n\nconst NOTION_TOKEN = Deno.env.get(\"NOTION_TOKEN\");\nconst FIX_KEY = Deno.env.get(\"FIX_KEY\");\nconst NOTION_VERSION = \"2025-09-03\";\nconst ONLINE_DS = \"9f3e6237-4908-4bf9-b64f-6f7e13cce320\"; // roster data source\n\nconst TEAMS = [\"Team 1\", \"Team 2\", \"Team 3\", \"Team 4\", \"Team 5\", \"Team 6\"];\nconst TEAM_COLORS: Record = {\n \"Team 1\": \"blue\",\n \"Team 2\": \"green\",\n \"Team 3\": \"orange\",\n \"Team 4\": \"pink\",\n \"Team 5\": \"purple\",\n \"Team 6\": \"yellow\",\n};\n\n// Read from the attached team sheet, matched to the full names in the roster.\nconst MAPPING: Record = {\n \"Team 1\": [],\n \"Team 2\": [],\n \"Team 3\": [],\n \"Team 4\": [],\n \"Team 5\": [],\n \"Team 6\": [],\n};\n\nconst norm = (s: string) => (s || \"\").trim().toLocaleLowerCase().replace(/\\s+/g, \" \");\n\nconst NAME_TO_TEAM: Record = {};\nfor (const [team, names] of Object.entries(MAPPING)) {\n for (const n of names) NAME_TO_TEAM[norm(n)] = team;\n}\n\nfunction notion(path: string, method: string, body?: unknown) {\n return fetch(`https://api.notion.com/v1/${path}`, {\n method,\n headers: {\n Authorization: `Bearer ${NOTION_TOKEN}`,\n \"Notion-Version\": NOTION_VERSION,\n \"Content-Type\": \"application/json\",\n },\n body: body ? JSON.stringify(body) : undefined,\n });\n}\n\nfunction plain(prop: any): string {\n const items = prop?.title ?? prop?.rich_text ?? [];\n return items.map((p: any) => p?.plain_text ?? \"\").join(\"\").trim();\n}\n\nasync function fetchAll(): Promise {\n const rows: any[] = [];\n let cursor: string | undefined;\n do {\n const body: any = { page_size: 100 };\n if (cursor) body.start_cursor = cursor;\n const r = await notion(`data_sources/${ONLINE_DS}/query`, \"POST\", body);\n const j = await r.json();\n if (!r.ok) throw new Error(\"query failed: \" + JSON.stringify(j));\n rows.push(...(j.results ?? []));\n cursor = j.has_more ? j.next_cursor : undefined;\n } while (cursor);\n return rows;\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const key = req.headers.get(\"x-fix-key\") ?? url.searchParams.get(\"key\");\n if (!FIX_KEY || key !== FIX_KEY) return new Response(\"unauthorized\", { status: 401 });\n if (!NOTION_TOKEN) {\n return new Response(JSON.stringify({ ok: false, error: \"missing NOTION_TOKEN\" }, null, 2),\n { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n }\n const apply = req.headers.get(\"x-apply\") === \"true\" || url.searchParams.get(\"apply\") === \"true\";\n\n let rows: any[];\n try {\n rows = await fetchAll();\n } catch (e) {\n return new Response(JSON.stringify({ ok: false, error: String(e) }, null, 2),\n { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n }\n\n const planned: any[] = [];\n const unassigned: any[] = [];\n const seen = new Set();\n for (const page of rows) {\n const title = plain(page.properties?.[\"Notion Page\"]);\n const dob = page.properties?.[\"Date of Birth\"]?.date?.start ?? null;\n const currentTeam = page.properties?.[\"Team\"]?.select?.name ?? null;\n const team = NAME_TO_TEAM[norm(title)];\n if (team) { planned.push({ id: page.id, name: title, team, currentTeam, dob }); seen.add(norm(title)); }\n else unassigned.push({ id: page.id, name: title, currentTeam, dob });\n }\n const alreadyCorrect = planned.filter((c) => c.currentTeam === c.team).length;\n const missingFromDB = Object.keys(NAME_TO_TEAM)\n .filter((n) => !seen.has(n))\n .map((n) => ({ name: n, team: NAME_TO_TEAM[n] }));\n\n const perTeam: Record = {};\n for (const c of planned) perTeam[c.team] = (perTeam[c.team] || 0) + 1;\n\n let propertyResult: any = \"skipped (dry run)\";\n let assigned = 0;\n const errors: any[] = [];\n\n if (apply) {\n const pr = await notion(`data_sources/${ONLINE_DS}`, \"PATCH\", {\n properties: { Team: { select: { options: TEAMS.map((t) => ({ name: t, color: TEAM_COLORS[t] })) } } },\n });\n propertyResult = pr.ok ? \"ok\" : await pr.json();\n if (pr.ok) {\n for (const c of planned) {\n const res = await notion(`pages/${c.id}`, \"PATCH\", {\n properties: { Team: { select: { name: c.team } } },\n });\n if (res.ok) assigned++;\n else errors.push({ id: c.id, name: c.name, error: await res.json() });\n await new Promise((r) => setTimeout(r, 150));\n }\n }\n }\n\n return new Response(JSON.stringify({\n mode: apply ? \"APPLIED\" : \"DRY RUN\",\n totalRows: rows.length,\n toAssign: planned.length,\n alreadyCorrect,\n perTeam,\n unassigned,\n missingFromDB,\n propertyResult,\n assigned,\n errors,\n planned,\n }, null, 2), { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n}\n",[161],"097d0b66-23a3-4705-b08d-30ca9c222056","assign-rooms.tsx","9b2da19c-751d-11f1-bdc4-1607ee4eb77e",55,["D",1782977991442],18,"// One-off: assign SF students to I-House 4th-floor rooms.\n// Gated behind FIX_KEY. Dry run by default; ?apply=true to write.\n// Read/propose has NO side effects. Apply: adds a two-way relation, then\n// writes Occupant 1/2 (text), Occupant Type=Student, and the relation.\n// Never touches rooms marked Staff or rooms that already have an occupant.\n// Never touches the Email column. Delete this file when done.\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst NOTION_TOKEN = Deno.env.get(\"NOTION_TOKEN\");\nconst FIX_KEY = Deno.env.get(\"ROOM_KEY\") ?? Deno.env.get(\"FIX_KEY\");\nconst NOTION_VERSION = \"2025-09-03\";\n\nconst ROOM_DS = \"a3966545-958f-4920-b3e4-ecb6648c677b\"; // Room Assignments data source\nconst STUDENT_DS = \"3b9cd139-473f-4100-b5e2-e9aa69486832\"; // SF Student List data source\n\nconst RELATION_PROP = \"Students\"; // new relation on the Room DB (holds up to 2 student pages)\nconst SYNCED_NAME = \"Room\"; // synced back-reference column added on the Student DB\n\nconst PROGRAM_START = new Date(\"2026-07-12\");\n\n// Students who explicitly requested to room together (matched by full name = Notion page title).\n// Both must be the same supported gender, else the pair is reported and skipped.\nconst FORCED_PAIRS: [string, string][] = [];\nconst normName = (s: string) => (s ?? \"\").trim().toLowerCase();\n\nfunction notion(path: string, method: string, body?: unknown) {\n return fetch(`https://api.notion.com/v1/${path}`, {\n method,\n headers: {\n Authorization: `Bearer ${NOTION_TOKEN}`,\n \"Notion-Version\": NOTION_VERSION,\n \"Content-Type\": \"application/json\",\n },\n body: body ? JSON.stringify(body) : undefined,\n });\n}\n\nfunction plain(prop: any): string {\n const items = prop?.title ?? prop?.rich_text ?? [];\n return items.map((p: any) => p?.plain_text ?? \"\").join(\"\").trim();\n}\n\nasync function fetchAll(ds: string): Promise {\n const rows: any[] = [];\n let cursor: string | undefined;\n do {\n const body: any = { page_size: 100 };\n if (cursor) body.start_cursor = cursor;\n const r = await notion(`data_sources/${ds}/query`, \"POST\", body);\n const j = await r.json();\n if (!r.ok) throw new Error(\"query failed: \" + JSON.stringify(j));\n rows.push(...(j.results ?? []));\n cursor = j.has_more ? j.next_cursor : undefined;\n } while (cursor);\n return rows;\n}\n\nfunction ageFromDob(dob: string): number {\n const d = new Date(dob);\n let a = PROGRAM_START.getFullYear() - d.getFullYear();\n const m = PROGRAM_START.getMonth() - d.getMonth();\n if (m < 0 || (m === 0 && PROGRAM_START.getDate() < d.getDate())) a--;\n return a;\n}\n\n// Youngest first; adjacent entries are closest in age.\nfunction sortDays(s: any): number {\n if (s.dob) return (PROGRAM_START.getTime() - new Date(s.dob).getTime()) / 86400000;\n if (s.age != null) return s.age * 365;\n return Number.POSITIVE_INFINITY;\n}\n\ntype Assn = { room: any; occupants: any[] };\n\nfunction assignGender(students: any[], doubles: any[], singles: any[], forced: any[][] = []) {\n const assignments: Assn[] = [];\n let di = 0, si = 0;\n const usedIds = new Set();\n // Honor requested pairs first: each goes into its own double.\n for (const pair of forced) {\n if (di >= doubles.length) break; // no double left; members fall through to overflow\n assignments.push({ room: doubles[di], occupants: [pair[0], pair[1]] });\n di += 1;\n usedIds.add(pair[0].id);\n usedIds.add(pair[1].id);\n }\n const sorted = students.filter((s) => !usedIds.has(s.id)).sort((a, b) => sortDays(a) - sortDays(b));\n let i = 0;\n // Pair adjacent-age students into doubles.\n while (i + 1 < sorted.length && di < doubles.length) {\n assignments.push({ room: doubles[di], occupants: [sorted[i], sorted[i + 1]] });\n i += 2; di += 1;\n }\n // Remaining students -> singles first.\n while (i < sorted.length && si < singles.length) {\n assignments.push({ room: singles[si], occupants: [sorted[i]] });\n i += 1; si += 1;\n }\n // Then any leftover double (solo occupant).\n while (i < sorted.length && di < doubles.length) {\n assignments.push({ room: doubles[di], occupants: [sorted[i]] });\n i += 1; di += 1;\n }\n const overflow = sorted.slice(i); // no capacity left\n const emptyRooms = [...doubles.slice(di), ...singles.slice(si)];\n return { assignments, overflow, emptyRooms };\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const key = req.headers.get(\"x-fix-key\") ?? url.searchParams.get(\"key\");\n if (!FIX_KEY || key !== FIX_KEY) return new Response(\"unauthorized\", { status: 401 });\n if (!NOTION_TOKEN) {\n return new Response(JSON.stringify({ ok: false, error: \"missing NOTION_TOKEN\" }, null, 2),\n { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n }\n const apply = req.headers.get(\"x-apply\") === \"true\" || url.searchParams.get(\"apply\") === \"true\";\n\n let roomRows: any[], studentRows: any[];\n try {\n [roomRows, studentRows] = await Promise.all([fetchAll(ROOM_DS), fetchAll(STUDENT_DS)]);\n } catch (e) {\n try {\n await sqlite.execute(\"CREATE TABLE IF NOT EXISTS run_log (id INTEGER PRIMARY KEY AUTOINCREMENT, ts TEXT, payload TEXT)\");\n await sqlite.execute({ sql: \"INSERT INTO run_log (ts, payload) VALUES (?, ?)\", args: [new Date().toISOString(), JSON.stringify({ readError: String(e) })] });\n } catch (_se) { /* ignore */ }\n return new Response(JSON.stringify({ ok: false, error: String(e) }, null, 2),\n { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n }\n\n // Parse rooms.\n const rooms = roomRows.map((p) => ({\n id: p.id,\n room: plain(p.properties?.[\"Room\"]),\n gender: p.properties?.[\"Gender\"]?.select?.name ?? null,\n type: p.properties?.[\"Room Type\"]?.select?.name ?? null,\n occ1: plain(p.properties?.[\"Occupant 1\"]),\n occ2: plain(p.properties?.[\"Occupant 2\"]),\n occType: p.properties?.[\"Occupant Type\"]?.select?.name ?? null,\n floor: p.properties?.[\"Floor plan location\"]?.number ?? null,\n }));\n\n // Parse students.\n const students = studentRows.map((p) => {\n const dob = p.properties?.[\"Date of Birth\"]?.date?.start ?? null;\n const age = p.properties?.[\"Age\"]?.number ?? null;\n return {\n id: p.id,\n name: plain(p.properties?.[\"Notion Page\"]),\n first: plain(p.properties?.[\"First Name\"]),\n last: plain(p.properties?.[\"Last Name\"]),\n gender: p.properties?.[\"Gender\"]?.select?.name ?? null,\n age, dob,\n effAge: dob ? ageFromDob(dob) : age,\n };\n });\n\n // Partition rooms.\n const staffRooms = rooms.filter((r) => r.occType === \"Staff\");\n const occupied = rooms.filter((r) => r.occType !== \"Staff\" && (r.occ1 || r.occ2));\n const available = rooms.filter((r) => r.occType !== \"Staff\" && !r.occ1 && !r.occ2);\n const noGender = available.filter((r) => r.gender !== \"Male\" && r.gender !== \"Female\");\n\n const byGenderRooms = (g: string) => {\n const set = available.filter((r) => r.gender === g && (r.type === \"Single\" || r.type === \"Double\"));\n return {\n doubles: set.filter((r) => r.type === \"Double\").sort((a, b) => (a.floor ?? 0) - (b.floor ?? 0)),\n singles: set.filter((r) => r.type === \"Single\").sort((a, b) => (a.floor ?? 0) - (b.floor ?? 0)),\n };\n };\n\n const otherGender = students.filter((s) => s.gender !== \"Male\" && s.gender !== \"Female\");\n const genders = [\"Female\", \"Male\"];\n const result: Record = {};\n const allAssignments: Assn[] = [];\n\n // Resolve requested room-together pairs to student objects and validate.\n const byName = new Map(students.map((s) => [normName(s.name), s]));\n const pairIssues: any[] = [];\n const forcedByGender: Record = { Female: [], Male: [] };\n for (const [n1, n2] of FORCED_PAIRS) {\n const s1 = byName.get(normName(n1));\n const s2 = byName.get(normName(n2));\n if (!s1 || !s2) {\n pairIssues.push({ pair: [n1, n2], issue: \"not found: \" + [!s1 ? n1 : null, !s2 ? n2 : null].filter(Boolean).join(\", \") });\n continue;\n }\n if (s1.gender !== s2.gender || (s1.gender !== \"Male\" && s1.gender !== \"Female\")) {\n pairIssues.push({ pair: [n1, n2], issue: `cannot share a gendered room: ${s1.name}=${s1.gender}, ${s2.name}=${s2.gender}` });\n continue;\n }\n forcedByGender[s1.gender].push([s1, s2]);\n }\n\n for (const g of genders) {\n const st = students.filter((s) => s.gender === g);\n const { doubles, singles } = byGenderRooms(g);\n const { assignments, overflow, emptyRooms } = assignGender(st, doubles, singles, forcedByGender[g] ?? []);\n allAssignments.push(...assignments);\n result[g] = {\n students: st.length,\n doubleRooms: doubles.length,\n singleRooms: singles.length,\n capacity: doubles.length * 2 + singles.length,\n overflow: overflow.map((s) => `${s.name} (${s.effAge})`),\n emptyRooms: emptyRooms.map((r) => `${r.room} [${r.type}]`),\n plan: assignments.map((a) => ({\n room: a.room.room,\n type: a.room.type,\n floor: a.room.floor,\n occupants: a.occupants.map((s) => `${s.name} (age ${s.effAge})`),\n })),\n };\n }\n\n const missingData = students\n .filter((s) => s.effAge == null || !s.name)\n .map((s) => ({ id: s.id, name: s.name, gender: s.gender, age: s.age, dob: s.dob }));\n\n const summary = {\n totalRooms: rooms.length,\n availableRooms: available.length,\n staffRooms: staffRooms.length,\n alreadyOccupiedNonStaff: occupied.map((r) => `${r.room}: ${r.occ1}${r.occ2 ? \" / \" + r.occ2 : \"\"}`),\n roomsWithNoGender: noGender.map((r) => r.room),\n totalStudents: students.length,\n studentsOtherGender: otherGender.map((s) => s.name),\n studentsMissingAgeOrName: missingData,\n requestedPairs: FORCED_PAIRS,\n requestedPairIssues: pairIssues,\n };\n\n let applyResult: any = \"skipped (dry run)\";\n if (apply) {\n applyResult = { relation: null, writes: [], errors: [] as any[] };\n\n // 1) Ensure the two-way relation property exists on the Room DB.\n const dsResp = await notion(`data_sources/${ROOM_DS}`, \"GET\");\n const dsJson = await dsResp.json();\n const hasRel = dsResp.ok && dsJson?.properties?.[RELATION_PROP]?.type === \"relation\";\n let relationOk = hasRel;\n if (!hasRel) {\n const pr = await notion(`data_sources/${ROOM_DS}`, \"PATCH\", {\n properties: {\n [RELATION_PROP]: {\n relation: {\n data_source_id: STUDENT_DS,\n type: \"dual_property\",\n dual_property: { synced_property_name: SYNCED_NAME },\n },\n },\n },\n });\n relationOk = pr.ok;\n applyResult.relation = pr.ok ? \"created\" : { status: pr.status, body: await pr.json() };\n } else {\n applyResult.relation = \"already exists\";\n }\n\n // 2) Write each assignment only if the relation is in place. Email untouched.\n if (relationOk) {\n for (const a of allAssignments) {\n const props: any = {\n \"Occupant 1\": { rich_text: [{ type: \"text\", text: { content: a.occupants[0].name } }] },\n \"Occupant Type\": { select: { name: \"Student\" } },\n [RELATION_PROP]: { relation: a.occupants.map((s) => ({ id: s.id })) },\n };\n if (a.occupants[1]) {\n props[\"Occupant 2\"] = { rich_text: [{ type: \"text\", text: { content: a.occupants[1].name } }] };\n }\n const res = await notion(`pages/${a.room.id}`, \"PATCH\", { properties: props });\n if (res.ok) applyResult.writes.push(a.room.room);\n else applyResult.errors.push({ room: a.room.room, error: await res.json() });\n await new Promise((r) => setTimeout(r, 160));\n }\n } else {\n applyResult.aborted = \"relation not created; no rooms written\";\n }\n }\n\n const payload = {\n mode: apply ? \"APPLIED\" : \"DRY RUN\",\n summary,\n byGender: result,\n applyResult,\n };\n try {\n await sqlite.execute(\"CREATE TABLE IF NOT EXISTS run_log (id INTEGER PRIMARY KEY AUTOINCREMENT, ts TEXT, payload TEXT)\");\n await sqlite.execute({ sql: \"INSERT INTO run_log (ts, payload) VALUES (?, ?)\", args: [new Date().toISOString(), JSON.stringify(payload)] });\n } catch (_) { /* best effort, non-fatal */ }\n return new Response(JSON.stringify(payload, null, 2), { status: 200, headers: { \"Content-Type\": \"application/json\" } });\n}\n",[168],"pulls","branches",1,"forks","envVars",{"_183":185,"_186":62},"connections",{"_183":177,"_184":62},"count","unfilledCount",7,"emptyCount",{"_42":167,"_32":168,"_30":169,"_137":-5,"_40":41,"_39":170,"_139":25,"_37":205,"_13":172,"_33":34,"_35":173,"_24":48,"_143":-5,"_193":206,"_27":207},{"_42":160,"_32":161,"_30":162,"_137":-5,"_40":41,"_39":163,"_139":25,"_37":202,"_13":150,"_33":34,"_35":165,"_24":48,"_143":-5,"_193":203,"_27":204},{"_42":153,"_32":154,"_30":57,"_137":-5,"_40":41,"_39":155,"_139":25,"_37":199,"_13":157,"_33":34,"_35":158,"_24":48,"_143":-5,"_193":200,"_27":201},{"_42":145,"_32":146,"_30":147,"_137":-5,"_40":41,"_39":148,"_139":25,"_37":196,"_13":150,"_33":34,"_35":151,"_24":48,"_143":-5,"_193":197,"_27":198},{"_42":134,"_32":135,"_30":136,"_137":-5,"_40":41,"_39":138,"_139":25,"_37":192,"_13":141,"_33":34,"_35":142,"_24":48,"_143":-5,"_193":194,"_27":195},["D",1781898307578],"children",[],[135],["D",1783134053552],[],[146],["D",1781592560697],[],[154],["D",1781765097904],[],[161],["D",1782977991442],[],[168],["D",1780515782210],["D",1789512647429],{"_99":98,"_107":103},{"_99":98,"_100":101,"_102":103,"_18":55,"_104":105,"_106":48},{"_13":88,"_32":89,"_42":41,"_90":43,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":44,"_97":98},"ctx",{"_81":-5,"_126":246,"_247":248,"_249":250,"_251":48,"_252":48,"_253":48,"_254":25,"_255":-5,"_256":-7,"_257":-7,"_258":62,"_259":48,"_260":48,"_261":-5,"_262":48,"_263":48,"_264":48,"_265":-5},"ENV",{"_217":218,"_219":220,"_221":89,"_222":223,"_224":225,"_226":227,"_228":229,"_230":231,"_232":233,"_234":235,"_236":237,"_238":239,"_240":241,"_242":243,"_244":245},"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 · v65