[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_167":168,"_169":170},"routes/_app.x.$handle.$name",{"_93":92,"_31":43,"_102":83,"_26":103,"_13":14,"_104":-5,"_11":105,"_106":107,"_108":109,"_110":111,"_112":113,"_20":-5,"_114":-5,"_115":-5,"_116":24,"_117":118,"_119":24,"_120":-5,"_121":-5,"_122":123},"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":-5,"_55":24,"_56":-5,"_57":-5,"_58":59,"_60":61,"_62":-5,"_63":-5,"_64":-5,"_65":-5,"_66":67,"_68":67,"_69":70,"_71":70,"_72":70,"_73":67,"_74":67,"_75":76,"_77":78,"_79":80,"_81":24},"version",28,"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","http.ts","latestPath","fileId","ed271920-5a00-11f1-a26b-ee650bb23af1","name","fileType","script","content","// =============================================================================\n// HTTP entrypoint — lets users trigger a sync manually from a Notion button.\n// =============================================================================\n//\n// The val.town platform exposes this file's default export as a public URL.\n// Users click a Notion button → browser opens this URL → sync runs → user\n// sees a simple HTML page confirming the result.\n//\n// SECURITY: A shared secret is required. Set the env var SYNC_TRIGGER_SECRET\n// to a long random string, and include it as ?key=... in the button URL.\n// Without the secret, anyone with the URL could trigger runs.\n//\n// SETUP:\n// 1. Set env var SYNC_TRIGGER_SECRET in val.town (Settings → Env Variables).\n// Use a long random value, e.g. from a password generator.\n// 2. After deploying this val, copy the val's HTTP URL from val.town.\n// The full button URL is:\n// https://your-val-url.web.val.run/?key=YOUR_SECRET\n// 3. In each Notion DB (DB-A and DB-B), add a Button property:\n// - Edit the DB → \"+ New property\" → Button\n// - Action: \"Open page or URL\"\n// - URL: paste the full button URL with the secret\n// - Label the button \"Run sync now\" or similar\n//\n// USAGE:\n// - Users click the button → opens a new browser tab\n// - The tab shows a \"Sync triggered...\" page that polls for completion\n// - When complete, shows summary (creates/updates/deletes/errors)\n//\n// =============================================================================\n\nimport { runSync } from \"./main.ts\";\n\nconst SYNC_TRIGGER_SECRET = Deno.env.get(\"SYNC_TRIGGER_SECRET\") ?? \"\";\n\nfunction html(body: string, status = 200): Response {\n return new Response(\n `\n\n\n \n Notion Sync\n \n \n\n${body}\n`,\n { status, headers: { \"Content-Type\": \"text/html; charset=utf-8\" } }\n );\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const providedKey = url.searchParams.get(\"key\") ?? \"\";\n\n // ── Authentication ──\n // Constant-time comparison would be ideal, but for a low-stakes manual\n // trigger button, a simple equality check is fine.\n if (!SYNC_TRIGGER_SECRET) {\n return html(`\n

Sync not configured

The SYNC_TRIGGER_SECRET environment variable is not set on the val. Set it in val.town Settings before using this endpoint.

\n `, 500);\n }\n if (providedKey !== SYNC_TRIGGER_SECRET) {\n return html(`\n

Not authorized

This URL requires a valid ?key=... parameter.

\n `, 401);\n }\n\n // ── Run the sync ──\n // We await the full run before returning so the user sees the result\n // immediately. On the free tier, the sync runs up to ~50s, and val.town\n // HTTP handlers have a 60s timeout — so this fits.\n let result: any;\n let runError: Error | null = null;\n try {\n result = await runSync({ triggeredBy: \"manual-button\" });\n } catch (err) {\n runError = err instanceof Error ? err : new Error(String(err));\n }\n\n if (runError) {\n return html(`\n

Sync failed

The sync crashed before completing:

${escapeHtml(runError.message)}

Check the val.town logs for the full stack trace, or check the error databases in Notion.

\n `, 500);\n }\n\n if (result?.ok === false) {\n return html(`\n

Sync aborted

Reason: ${escapeHtml(result.reason)}

Errors logged: ${result.errors ?? 0}

Check the error databases in Notion for details.

\n `, 500);\n }\n\n const r = result ?? {};\n const hasWork = (r.creates || r.updates || r.deletes) > 0;\n const headline = hasWork\n ? `Sync complete`\n : `Everything already in sync`;\n\n return html(`\n

${headline}

\n \n \n \n \n \n \n \n

Created	${r.creates ?? 0}
Updated	${r.updates ?? 0}
Deleted	${r.deletes ?? 0}
Deferred	${r.deferred ?? 0}
Errors	${(r.errors ?? 0) > 0 ? `${r.errors}` : \"0\"}
Took	${r.elapsed ?? \"?\"}s

\n ${r.deferred > 0 ? `

Some records didn't fit in this run's time budget. They'll be picked up by the next sync (scheduled or manual).

` : \"\"}\n ${r.errors > 0 ? `

Errors were logged. Open the error databases in Notion to investigate.

` : \"\"}\n

You can close this tab.

\n `);\n}\n\nfunction escapeHtml(s: string): string {\n return s\n .replaceAll(\"&\", \"&\")\n .replaceAll(\"<\", \"<\")\n .replaceAll(\">\", \">\")\n .replaceAll('\"', \""\")\n .replaceAll(\"'\", \"'\");\n}\n","createdAt",["D",1779909545039],"branchVersion","branchId","52cc26be-59a0-11f1-9c88-ee650bb23af1","id","52cb35f6-59a0-11f1-9c88-ee650bb23af1","notion-bidirectional-sync",["D",1779868054388],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Daily bidirectional sync between two Notion databases via ledger","imageUrl","4d6a2ce9-7b0b-41ae-acae-02936cc37376","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019e6588-8f32-7029-9083-725ae084ef6f","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_93":92,"_101":97},"org",{"_93":92,"_94":95,"_96":97,"_18":53,"_98":99,"_100":24},"branch",{"_13":82,"_31":83,"_41":40,"_84":42,"_85":-5,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":43,"_91":92},"isOwned",29,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","valentinmoebs","handle","displayName","Valentin Moebs","avatar","https://lh3.googleusercontent.com/a/ACg8ocKHKyhQu2hb7BbRWE8BJhDtC42HdaVpFZJ8vPB8I94_RiniZKUc=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_41":42,"_31":43,"_36":163,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":-5,"_55":24,"_56":-5,"_57":-5,"_58":59,"_60":61,"_62":-5,"_63":-5,"_64":-5,"_65":-5,"_66":67,"_68":67,"_69":70,"_71":70,"_72":70,"_73":67,"_74":67,"_75":164,"_77":165,"_79":166,"_81":24},"tree",[154,155],"files",[154,155],"counts",{"_142":59,"_143":144,"_145":59,"_146":147,"_148":149},"contents",[124,125],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_41":139,"_31":27,"_29":30,"_129":-5,"_39":40,"_38":14,"_131":24,"_36":140,"_13":59,"_32":33,"_34":35,"_23":24,"_137":-5,"_26":141},{"_41":126,"_31":127,"_29":128,"_129":-5,"_39":40,"_38":130,"_131":132,"_36":133,"_13":134,"_32":135,"_34":136,"_23":24,"_137":-5,"_26":138},"da08e81e-5a00-11f1-94f0-ee650bb23af1","main.ts","52d100ee-59a0-11f1-9c88-ee650bb23af1","parentId",27,"latest",true,["D",1779909512945],26,"interval","// =============================================================================\n// Notion bidirectional sync — Val.town\n// =============================================================================\n//\n// Runs daily. Keeps two Notion databases (DB-A and DB-B) in sync via a third\n// \"ledger\" database that records sync state.\n//\n// CHANGE DETECTION: We hash each side's writable property payload and store\n// the hash in the ledger. On each run we recompute and compare. This is\n// independent of timestamps, immune to minute-rounding, and tells us exactly\n// which side changed (and therefore which direction to sync).\n//\n// IMPORTANT: DB-A and DB-B live in DIFFERENT Notion workspaces, so the script\n// uses two separate integration tokens. The ledger lives in the same workspace\n// as DB-A.\n//\n// Sync rules:\n// ROWS:\n// - New on one side → create on the other\n// - Edited on one side → propagate to the other\n// - Edited on both → newer last_edited_time wins\n// - Deleted/archived on one side → delete the other (DELETE WINS)\n// - Duplicate names within a single DB → keep newest, archive the rest\n// - Names with leading/trailing spaces → trimmed before matching\n// SCHEMA:\n// - Missing on one side → add it (additive only)\n// - Same name + same type → already in sync\n// - Same name + different type → CONFLICT: copy other side's\n// version with \" (from X)\" suffix\n// - Select/multi-select/status options → union both sides' options\n// - Title property → left alone (Notion-managed)\n// ERRORS:\n// - Any caught error during a run gets written to BOTH error DBs\n// - Errors are visible to humans in either workspace\n// - Failed records will retry naturally on next run (no special logic)\n//\n// SETUP:\n// Env vars:\n// NOTION_TOKEN_A, NOTION_TOKEN_B, DB_A_ID, DB_B_ID, LEDGER_ID,\n// ERROR_DB_A_ID, ERROR_DB_B_ID\n// Optional: DRY_RUN=true\n//\n// The ledger DB must have these properties:\n// Name (title)\n// DB-A Page ID (text)\n// DB-B Page ID (text)\n// Last Synced (date)\n// A Content Hash (text)\n// B Content Hash (text)\n//\n// Each error DB (one in each workspace) must have these properties:\n// Name (title)\n// Run Started At (date)\n// Record Name (text)\n// Operation (select)\n// Side (select)\n// Error Message (text)\n// Resolved (checkbox)\n//\n// =============================================================================\n\nconst NOTION_TOKEN_A = Deno.env.get(\"NOTION_TOKEN_A\")!;\nconst NOTION_TOKEN_B = Deno.env.get(\"NOTION_TOKEN_B\")!;\nconst DB_A_ID = Deno.env.get(\"DB_A_ID\")!;\nconst DB_B_ID = Deno.env.get(\"DB_B_ID\")!;\nconst LEDGER_ID = Deno.env.get(\"LEDGER_ID\")!;\nconst ERROR_DB_A_ID = Deno.env.get(\"ERROR_DB_A_ID\")!;\nconst ERROR_DB_B_ID = Deno.env.get(\"ERROR_DB_B_ID\")!;\nconst DRY_RUN = Deno.env.get(\"DRY_RUN\") === \"true\";\n\nconst NOTION_VERSION = \"2022-06-28\";\nconst API = \"https://api.notion.com/v1\";\n\ntype Side = \"A\" | \"B\" | \"ledger\";\n\n// =============================================================================\n// LOW-LEVEL HELPERS\n// =============================================================================\n\nconst tokenFor = (side: Side): string =>\n side === \"B\" ? NOTION_TOKEN_B : NOTION_TOKEN_A;\n\nconst sleep = (ms: number) => new Promise(r => setTimeout(r, ms));\n\nasync function notion(\n side: Side, method: string, path: string, body?: unknown,\n): Promise {\n for (let attempt = 0; attempt < 5; attempt++) {\n const res = await fetch(`${API}${path}`, {\n method,\n headers: {\n \"Authorization\": `Bearer ${tokenFor(side)}`,\n \"Notion-Version\": NOTION_VERSION,\n \"Content-Type\": \"application/json\",\n },\n body: body ? JSON.stringify(body) : undefined,\n });\n\n if (res.status === 429) {\n const retryAfter = Number(res.headers.get(\"Retry-After\") ?? \"1\");\n console.log(`Rate limited (${side}), waiting ${retryAfter}s`);\n await sleep(retryAfter * 1000);\n continue;\n }\n if (!res.ok) {\n const text = await res.text();\n throw new Error(`Notion ${method} ${path} [${side}] → ${res.status}: ${text}`);\n }\n return res.json();\n }\n throw new Error(`Notion ${method} ${path} [${side}] failed after 5 retries`);\n}\n\nfunction sideForDb(dbId: string): Side {\n if (dbId === DB_A_ID) return \"A\";\n if (dbId === DB_B_ID) return \"B\";\n if (dbId === LEDGER_ID) return \"ledger\";\n throw new Error(`Unknown database ID: ${dbId}`);\n}\n\n// =============================================================================\n// ERROR REPORTING\n// =============================================================================\n// All errors get written to both error DBs. If a write to one fails, the\n// other still happens. If both fail, console-log is the final fallback.\n//\n// The \"healthy\" flags are set during startup validation. If validation says\n// an error DB is broken, we don't try to write to it (so we don't generate\n// confusing nested errors).\n\nlet RUN_STARTED_AT = new Date().toISOString();\nlet ERROR_DB_A_HEALTHY = false;\nlet ERROR_DB_B_HEALTHY = false;\nlet ERROR_COUNT = 0;\n\ninterface ErrorReport {\n recordName: string; // \"(no record)\" for non-record-specific errors\n operation: string; // e.g. \"update-A-to-B\", \"schema-sync\", \"ledger-validation\"\n side: \"A\" | \"B\" | \"ledger\" | \"n/a\";\n error: unknown;\n}\n\nfunction errorProperties(r: ErrorReport): Record {\n const message = (r.error instanceof Error) ? r.error.message : String(r.error);\n const truncated = message.length > 2000 ? message.slice(0, 1997) + \"...\" : message;\n const title = r.recordName === \"(no record)\"\n ? `${r.operation} failed`\n : `Failed: ${r.recordName}`;\n return {\n \"Name\": { title: [{ text: { content: title } }] },\n \"Run Started At\": { date: { start: RUN_STARTED_AT } },\n \"Record Name\": { rich_text: [{ text: { content: r.recordName } }] },\n \"Operation\": { select: { name: r.operation } },\n \"Side\": { select: { name: r.side } },\n \"Error Message\": { rich_text: [{ text: { content: truncated } }] },\n \"Resolved\": { checkbox: false },\n };\n}\n\nasync function reportError(r: ErrorReport): Promise {\n ERROR_COUNT++;\n const message = (r.error instanceof Error) ? r.error.message : String(r.error);\n console.error(`Error [${r.operation}] \"${r.recordName}\":`, message);\n\n if (DRY_RUN) {\n console.log(`[DRY] would log error to both error DBs`);\n return;\n }\n\n const props = errorProperties(r);\n\n // Write to both, independently. Don't let one failure block the other.\n if (ERROR_DB_A_HEALTHY) {\n try {\n await notion(\"A\", \"POST\", \"/pages\", {\n parent: { database_id: ERROR_DB_A_ID },\n properties: props,\n });\n } catch (writeErr) {\n console.error(`Could not write to Errors A:`, writeErr);\n }\n }\n if (ERROR_DB_B_HEALTHY) {\n try {\n await notion(\"B\", \"POST\", \"/pages\", {\n parent: { database_id: ERROR_DB_B_ID },\n properties: props,\n });\n } catch (writeErr) {\n console.error(`Could not write to Errors B:`, writeErr);\n }\n }\n}\n\n// =============================================================================\n// STARTUP VALIDATION\n// =============================================================================\n// Verify that ledger and error DBs have the expected schema. If the ledger\n// is broken, we abort the run. If error DBs are broken, we log to console\n// and continue (broken observability shouldn't block correctness).\n\ninterface ExpectedProp { name: string; type: string; }\n\nfunction validateSchema(\n dbName: string,\n schema: any,\n expected: ExpectedProp[],\n): { ok: boolean; problems: string[] } {\n const problems: string[] = [];\n for (const { name, type } of expected) {\n const prop = schema?.properties?.[name];\n if (!prop) {\n problems.push(`missing property \"${name}\"`);\n continue;\n }\n if (prop.type !== type) {\n problems.push(`property \"${name}\" has type \"${prop.type}\", expected \"${type}\"`);\n }\n }\n return { ok: problems.length === 0, problems };\n}\n\nconst LEDGER_SCHEMA: ExpectedProp[] = [\n { name: \"Name\", type: \"title\" },\n { name: \"DB-A Page ID\", type: \"rich_text\" },\n { name: \"DB-B Page ID\", type: \"rich_text\" },\n { name: \"A Content Hash\", type: \"rich_text\" },\n { name: \"B Content Hash\", type: \"rich_text\" },\n];\n\nconst ERROR_DB_SCHEMA: ExpectedProp[] = [\n { name: \"Name\", type: \"title\" },\n { name: \"Run Started At\", type: \"date\" },\n { name: \"Record Name\", type: \"rich_text\" },\n { name: \"Operation\", type: \"select\" },\n { name: \"Side\", type: \"select\" },\n { name: \"Error Message\", type: \"rich_text\" },\n { name: \"Resolved\", type: \"checkbox\" },\n];\n\nasync function validateErrorDbs(): Promise {\n try {\n const a = await notion(\"A\", \"GET\", `/databases/${ERROR_DB_A_ID}`);\n const r = validateSchema(\"Errors A\", a, ERROR_DB_SCHEMA);\n if (r.ok) {\n ERROR_DB_A_HEALTHY = true;\n } else {\n console.error(`Errors A schema problems: ${r.problems.join(\"; \")}`);\n }\n } catch (err) {\n console.error(`Could not fetch Errors A:`, err);\n }\n try {\n const b = await notion(\"B\", \"GET\", `/databases/${ERROR_DB_B_ID}`);\n const r = validateSchema(\"Errors B\", b, ERROR_DB_SCHEMA);\n if (r.ok) {\n ERROR_DB_B_HEALTHY = true;\n } else {\n console.error(`Errors B schema problems: ${r.problems.join(\"; \")}`);\n }\n } catch (err) {\n console.error(`Could not fetch Errors B:`, err);\n }\n console.log(\n `Error DBs: A=${ERROR_DB_A_HEALTHY ? \"ok\" : \"BROKEN\"}, ` +\n `B=${ERROR_DB_B_HEALTHY ? \"ok\" : \"BROKEN\"}`\n );\n}\n\nasync function validateLedger(): Promise {\n try {\n const ledger = await notion(\"ledger\", \"GET\", `/databases/${LEDGER_ID}`);\n const r = validateSchema(\"Ledger\", ledger, LEDGER_SCHEMA);\n if (!r.ok) {\n await reportError({\n recordName: \"(no record)\",\n operation: \"ledger-validation\",\n side: \"ledger\",\n error: new Error(`Ledger DB schema problems: ${r.problems.join(\"; \")}`),\n });\n return false;\n }\n return true;\n } catch (err) {\n await reportError({\n recordName: \"(no record)\",\n operation: \"ledger-validation\",\n side: \"ledger\",\n error: err,\n });\n return false;\n }\n}\n\n// =============================================================================\n// QUERY\n// =============================================================================\n\nasync function queryAllPages(dbId: string): Promise {\n const side = sideForDb(dbId);\n const pages: any[] = [];\n let cursor: string | undefined = undefined;\n do {\n const res: any = await notion(side, \"POST\", `/databases/${dbId}/query`, {\n start_cursor: cursor,\n page_size: 100,\n // Notion's API includes archived pages by default; we want them so we\n // can detect manual archives as a delete signal. Partition happens\n // later in the classification phase.\n archived: undefined,\n });\n pages.push(...res.results);\n cursor = res.has_more ? res.next_cursor : undefined;\n } while (cursor);\n return pages;\n}\n\n// =============================================================================\n// NAME / TITLE UTILITIES\n// =============================================================================\n\nfunction getRawPageName(page: any): string {\n for (const prop of Object.values(page.properties)) {\n if (prop.type === \"title\") {\n return prop.title.map((t: any) => t.plain_text).join(\"\");\n }\n }\n return \"\";\n}\n\nfunction getPageName(page: any): string {\n return getRawPageName(page).trim();\n}\n\nfunction getTitlePropertyName(page: any): string | null {\n for (const [propName, prop] of Object.entries(page.properties)) {\n if (prop.type === \"title\") return propName;\n }\n return null;\n}\n\nfunction nameFromProps(props: Record): string {\n for (const val of Object.values(props)) {\n if (val?.title) return val.title.map((t: any) => t.text?.content ?? \"\").join(\"\");\n }\n return \"(unnamed)\";\n}\n\n// =============================================================================\n// PROPERTY HANDLING — extraction and hashing\n// =============================================================================\n\nconst WRITABLE_TYPES = new Set([\n \"title\", \"rich_text\", \"number\", \"select\", \"multi_select\", \"date\",\n \"checkbox\", \"url\", \"email\", \"phone_number\", \"people\", \"files\", \"status\",\n]);\n\nconst RICH_TEXT_MAX = 2000;\n\nfunction cleanPropertyValue(value: any): any {\n const t = value.type;\n if (t === \"select\" && value.select) {\n return { type: \"select\", select: value.select.name ? { name: value.select.name } : null };\n }\n if (t === \"multi_select\" && value.multi_select) {\n return {\n type: \"multi_select\",\n multi_select: value.multi_select.map((o: any) => ({ name: o.name })),\n };\n }\n if (t === \"status\" && value.status) {\n return { type: \"status\", status: value.status.name ? { name: value.status.name } : null };\n }\n if (t === \"people\") {\n return { type: \"people\", people: [] };\n }\n if (t === \"rich_text\" && Array.isArray(value.rich_text)) {\n const truncated = value.rich_text.map((seg: any) => {\n if (seg.text?.content && seg.text.content.length > RICH_TEXT_MAX) {\n return {\n ...seg,\n text: { ...seg.text, content: seg.text.content.slice(0, RICH_TEXT_MAX - 3) + \"...\" },\n plain_text: seg.plain_text?.slice(0, RICH_TEXT_MAX - 3) + \"...\",\n };\n }\n return seg;\n });\n return { type: \"rich_text\", rich_text: truncated };\n }\n if (t === \"title\" && Array.isArray(value.title)) {\n const truncated = value.title.map((seg: any) => {\n if (seg.text?.content && seg.text.content.length > RICH_TEXT_MAX) {\n return {\n ...seg,\n text: { ...seg.text, content: seg.text.content.slice(0, RICH_TEXT_MAX - 3) + \"...\" },\n };\n }\n return seg;\n });\n return { type: \"title\", title: truncated };\n }\n return value;\n}\n\nfunction extractWritableProps(page: any, destSchema: any): Record {\n const out: Record = {};\n for (const [name, value] of Object.entries(page.properties)) {\n if (!WRITABLE_TYPES.has(value.type)) continue;\n if (!destSchema[name]) continue;\n if (destSchema[name].type !== value.type) continue;\n const cleaned = cleanPropertyValue(value);\n const { id, ...rest } = cleaned;\n out[name] = rest;\n }\n return out;\n}\n\nasync function sha256Hex(input: string): Promise {\n const bytes = new TextEncoder().encode(input);\n const digest = await crypto.subtle.digest(\"SHA-256\", bytes);\n return Array.from(new Uint8Array(digest))\n .map(b => b.toString(16).padStart(2, \"0\"))\n .join(\"\");\n}\n\nfunction stableStringify(obj: any): string {\n if (obj === null || typeof obj !== \"object\") return JSON.stringify(obj);\n if (Array.isArray(obj)) return \"[\" + obj.map(stableStringify).join(\",\") + \"]\";\n const keys = Object.keys(obj).sort();\n return \"{\" + keys.map(k => JSON.stringify(k) + \":\" + stableStringify(obj[k])).join(\",\") + \"}\";\n}\n\nasync function hashPageContent(page: any, schema: any): Promise {\n const props = extractWritableProps(page, schema);\n return await sha256Hex(stableStringify(props));\n}\n\n// =============================================================================\n// LEDGER\n// =============================================================================\n\ninterface LedgerEntry {\n ledgerPageId: string;\n name: string;\n dbAPageId: string;\n dbBPageId: string;\n aContentHash: string | null;\n bContentHash: string | null;\n}\n\nfunction parseLedgerPage(page: any): LedgerEntry {\n const props = page.properties;\n const readText = (p: any) =>\n p?.rich_text?.map((t: any) => t.plain_text).join(\"\") ?? \"\";\n return {\n ledgerPageId: page.id,\n name: getPageName(page),\n dbAPageId: readText(props[\"DB-A Page ID\"]),\n dbBPageId: readText(props[\"DB-B Page ID\"]),\n aContentHash: readText(props[\"A Content Hash\"]) || null,\n bContentHash: readText(props[\"B Content Hash\"]) || null,\n };\n}\n\nfunction ledgerProperties(\n name: string | null, aId: string, bId: string,\n aHash: string, bHash: string,\n): Record {\n const out: Record = {\n \"DB-A Page ID\": { rich_text: [{ text: { content: aId } }] },\n \"DB-B Page ID\": { rich_text: [{ text: { content: bId } }] },\n \"Last Synced\": { date: { start: new Date().toISOString() } },\n \"A Content Hash\": { rich_text: [{ text: { content: aHash } }] },\n \"B Content Hash\": { rich_text: [{ text: { content: bHash } }] },\n };\n if (name !== null) {\n out[\"Name\"] = { title: [{ text: { content: name } }] };\n }\n return out;\n}\n\nasync function createLedgerEntry(\n name: string, aId: string, bId: string,\n aHash: string, bHash: string,\n) {\n if (DRY_RUN) { console.log(`[DRY] ledger create: ${name}`); return; }\n await notion(\"ledger\", \"POST\", \"/pages\", {\n parent: { database_id: LEDGER_ID },\n properties: ledgerProperties(name, aId, bId, aHash, bHash),\n });\n}\n\nasync function updateLedgerEntry(\n ledgerPageId: string, aId: string, bId: string,\n aHash: string, bHash: string,\n) {\n if (DRY_RUN) { console.log(`[DRY] ledger update: ${ledgerPageId}`); return; }\n await notion(\"ledger\", \"PATCH\", `/pages/${ledgerPageId}`, {\n properties: ledgerProperties(null, aId, bId, aHash, bHash),\n });\n}\n\n// =============================================================================\n// PAGE OPERATIONS\n// =============================================================================\n\nasync function archivePage(side: Side, pageId: string, label: string): Promise {\n if (DRY_RUN) { console.log(`[DRY] archive [${side}] (${label}): ${pageId}`); return; }\n await notion(side, \"PATCH\", `/pages/${pageId}`, { archived: true });\n}\n\nasync function createPageIn(dbId: string, props: Record): Promise {\n const side = sideForDb(dbId);\n if (DRY_RUN) {\n console.log(`[DRY] create in [${side}] ${dbId.slice(0,8)}…: ${nameFromProps(props)}`);\n return { id: \"dry-run-id\" };\n }\n return await notion(side, \"POST\", \"/pages\", {\n parent: { database_id: dbId },\n properties: props,\n });\n}\n\nasync function updatePage(side: Side, pageId: string, props: Record): Promise {\n if (DRY_RUN) {\n console.log(`[DRY] update [${side}] ${pageId.slice(0,8)}…: ${nameFromProps(props)}`);\n return;\n }\n await notion(side, \"PATCH\", `/pages/${pageId}`, { properties: props });\n}\n\n// =============================================================================\n// SCHEMA SYNC\n// =============================================================================\n\nconst SYNCABLE_SCHEMA_TYPES = new Set([\n \"rich_text\", \"number\", \"select\", \"multi_select\", \"date\", \"checkbox\",\n \"url\", \"email\", \"phone_number\", \"people\", \"files\", \"status\",\n]);\n\nfunction buildPropertyConfig(prop: any): any {\n const type = prop.type;\n switch (type) {\n case \"select\":\n return { select: { options: (prop.select?.options ?? []).map((o: any) =>\n ({ name: o.name, color: o.color })) } };\n case \"multi_select\":\n return { multi_select: { options: (prop.multi_select?.options ?? []).map((o: any) =>\n ({ name: o.name, color: o.color })) } };\n case \"status\":\n return { status: { options: (prop.status?.options ?? []).map((o: any) =>\n ({ name: o.name, color: o.color })) } };\n case \"number\":\n return { number: { format: prop.number?.format ?? \"number\" } };\n default:\n return { [type]: {} };\n }\n}\n\nfunction unionOptions(existing: any[] | undefined, incoming: any[] | undefined): any[] {\n const byName = new Map();\n for (const o of existing ?? []) byName.set(o.name, { name: o.name, color: o.color });\n for (const o of incoming ?? []) {\n if (!byName.has(o.name)) byName.set(o.name, { name: o.name, color: o.color });\n }\n return [...byName.values()];\n}\n\nasync function syncSchemas(): Promise<{ aProps: any; bProps: any } | null> {\n console.log(\"--- Schema sync ---\");\n let dbA: any, dbB: any;\n try {\n [dbA, dbB] = await Promise.all([\n notion(\"A\", \"GET\", `/databases/${DB_A_ID}`),\n notion(\"B\", \"GET\", `/databases/${DB_B_ID}`),\n ]);\n } catch (err) {\n await reportError({\n recordName: \"(no record)\",\n operation: \"schema-sync\",\n side: \"n/a\",\n error: err,\n });\n return null;\n }\n\n const patchToA: Record = {};\n const patchToB: Record = {};\n const additions: string[] = [];\n const conflicts: string[] = [];\n const optionUnions: string[] = [];\n\n const allNames = new Set([\n ...Object.keys(dbA.properties), ...Object.keys(dbB.properties),\n ]);\n\n for (const name of allNames) {\n const a = dbA.properties[name];\n const b = dbB.properties[name];\n if (a?.type === \"title\" || b?.type === \"title\") continue;\n\n if (a && !b) {\n if (!SYNCABLE_SCHEMA_TYPES.has(a.type)) {\n console.log(` skipping \"${name}\" (type ${a.type} not auto-synced)`);\n continue;\n }\n patchToB[name] = buildPropertyConfig(a);\n additions.push(`+ B: \"${name}\" (${a.type})`);\n continue;\n }\n if (b && !a) {\n if (!SYNCABLE_SCHEMA_TYPES.has(b.type)) {\n console.log(` skipping \"${name}\" (type ${b.type} not auto-synced)`);\n continue;\n }\n patchToA[name] = buildPropertyConfig(b);\n additions.push(`+ A: \"${name}\" (${b.type})`);\n continue;\n }\n if (a.type === b.type) {\n if (a.type === \"select\" || a.type === \"multi_select\" || a.type === \"status\") {\n const optKey = a.type as \"select\" | \"multi_select\" | \"status\";\n const aOpts = a[optKey]?.options ?? [];\n const bOpts = b[optKey]?.options ?? [];\n const merged = unionOptions(aOpts, bOpts);\n const aOptNames = new Set(aOpts.map((o: any) => o.name));\n const bOptNames = new Set(bOpts.map((o: any) => o.name));\n const mergedNames = new Set(merged.map((o: any) => o.name));\n if (mergedNames.size > aOptNames.size) {\n patchToA[name] = { [optKey]: { options: merged } };\n optionUnions.push(`~ A: \"${name}\" options ${aOptNames.size} → ${mergedNames.size}`);\n }\n if (mergedNames.size > bOptNames.size) {\n patchToB[name] = { [optKey]: { options: merged } };\n optionUnions.push(`~ B: \"${name}\" options ${bOptNames.size} → ${mergedNames.size}`);\n }\n }\n continue;\n }\n // Type conflict\n if (SYNCABLE_SCHEMA_TYPES.has(a.type)) {\n const newName = `${name} (from A)`;\n if (!dbB.properties[newName]) {\n patchToB[newName] = buildPropertyConfig(a);\n conflicts.push(`! B: conflict on \"${name}\" → added \"${newName}\" (${a.type})`);\n }\n }\n if (SYNCABLE_SCHEMA_TYPES.has(b.type)) {\n const newName = `${name} (from B)`;\n if (!dbA.properties[newName]) {\n patchToA[newName] = buildPropertyConfig(b);\n conflicts.push(`! A: conflict on \"${name}\" → added \"${newName}\" (${b.type})`);\n }\n }\n }\n\n try {\n if (Object.keys(patchToA).length > 0) {\n if (DRY_RUN) console.log(`[DRY] would patch A schema: ${Object.keys(patchToA).join(\", \")}`);\n else await notion(\"A\", \"PATCH\", `/databases/${DB_A_ID}`, { properties: patchToA });\n }\n if (Object.keys(patchToB).length > 0) {\n if (DRY_RUN) console.log(`[DRY] would patch B schema: ${Object.keys(patchToB).join(\", \")}`);\n else await notion(\"B\", \"PATCH\", `/databases/${DB_B_ID}`, { properties: patchToB });\n }\n } catch (err) {\n await reportError({\n recordName: \"(no record)\",\n operation: \"schema-sync\",\n side: \"n/a\",\n error: err,\n });\n // Keep going with the schemas we have — partial schema may still let some\n // row writes succeed.\n }\n\n for (const line of additions) console.log(` ${line}`);\n for (const line of optionUnions) console.log(` ${line}`);\n for (const line of conflicts) console.log(` ${line}`);\n if (additions.length + optionUnions.length + conflicts.length === 0) {\n console.log(\" schemas already in sync\");\n }\n\n if (DRY_RUN || (Object.keys(patchToA).length + Object.keys(patchToB).length === 0)) {\n return { aProps: dbA.properties, bProps: dbB.properties };\n }\n try {\n const dbA2 = await notion(\"A\", \"GET\", `/databases/${DB_A_ID}`);\n const dbB2 = await notion(\"B\", \"GET\", `/databases/${DB_B_ID}`);\n return { aProps: dbA2.properties, bProps: dbB2.properties };\n } catch (err) {\n await reportError({\n recordName: \"(no record)\",\n operation: \"schema-sync\",\n side: \"n/a\",\n error: err,\n });\n // Fall back to pre-patch schemas; better than nothing.\n return { aProps: dbA.properties, bProps: dbB.properties };\n }\n}\n\n// =============================================================================\n// PRE-SYNC PASSES: trim names, dedupe within DB\n// =============================================================================\n\nasync function trimPageNames(pages: any[], side: Side): Promise {\n let trimmed = 0;\n for (const page of pages) {\n const raw = getRawPageName(page);\n const clean = raw.trim();\n if (raw === clean || clean === \"\") continue;\n\n const titleProp = getTitlePropertyName(page);\n if (!titleProp) continue;\n\n try {\n if (DRY_RUN) {\n console.log(`[DRY] trim [${side}] \"${raw}\" → \"${clean}\"`);\n } else {\n await notion(side, \"PATCH\", `/pages/${page.id}`, {\n properties: { [titleProp]: { title: [{ text: { content: clean } }] } },\n });\n }\n page.properties[titleProp].title = [{\n type: \"text\", text: { content: clean, link: null },\n plain_text: clean, annotations: {}, href: null,\n }];\n trimmed++;\n } catch (err) {\n await reportError({\n recordName: clean,\n operation: \"trim-name\",\n side: side === \"ledger\" ? \"ledger\" : side,\n error: err,\n });\n }\n }\n if (trimmed > 0) console.log(` [${side}] trimmed ${trimmed} page name(s)`);\n}\n\nasync function dedupeWithinDb(pages: any[], label: Side): Promise> {\n const byName = new Map();\n for (const p of pages) {\n const name = getPageName(p);\n if (!name) continue;\n if (!byName.has(name)) byName.set(name, []);\n byName.get(name)!.push(p);\n }\n const survivors = new Map();\n for (const [name, group] of byName) {\n if (group.length === 1) {\n survivors.set(name, group[0]);\n continue;\n }\n group.sort((x, y) =>\n new Date(y.last_edited_time).getTime() - new Date(x.last_edited_time).getTime()\n );\n survivors.set(name, group[0]);\n for (const dup of group.slice(1)) {\n console.log(`[${label}] duplicate \"${name}\", archiving ${dup.id}`);\n try {\n await archivePage(label, dup.id, `${label} dupe of \"${name}\"`);\n } catch (err) {\n await reportError({\n recordName: name,\n operation: \"dedupe\",\n side: label === \"ledger\" ? \"ledger\" : label,\n error: err,\n });\n }\n }\n }\n return survivors;\n}\n\n// =============================================================================\n// MAIN\n// =============================================================================\nconst TIME_BUDGET_MS = 50_000;\n\ntype Op = \"create-on-B\" | \"create-on-A\"\n | \"update-A-to-B\" | \"update-B-to-A\"\n | \"delete-B\" | \"delete-A\"\n | \"ledger-cleanup\";\n\ninterface Work {\n op: Op;\n name: string;\n a?: any;\n b?: any;\n ledger?: LedgerEntry;\n aHashNow?: string;\n bHashNow?: string;\n}\n\nexport default async function main() {\n return await runSync();\n}\n\nexport async function runSync(opts: { triggeredBy?: string } = {}) {\n const startedAt = Date.now();\n RUN_STARTED_AT = new Date(startedAt).toISOString();\n ERROR_DB_A_HEALTHY = false;\n ERROR_DB_B_HEALTHY = false;\n ERROR_COUNT = 0;\n const overBudget = () => Date.now() - startedAt > TIME_BUDGET_MS;\n\n const triggerLabel = opts.triggeredBy ?? \"schedule\";\n console.log(`=== Notion sync starting ${RUN_STARTED_AT} (triggered by: ${triggerLabel}) ===`);\n if (DRY_RUN) console.log(\"DRY RUN — no writes will happen\");\n\n // ──────────────────────────────────────────────────────────────────────\n // PHASE 0: Validate error DBs (so reportError() knows where it can write)\n // ──────────────────────────────────────────────────────────────────────\n await validateErrorDbs();\n\n // ──────────────────────────────────────────────────────────────────────\n // PHASE 1: Validate ledger DB. Abort the run if it's broken.\n // ──────────────────────────────────────────────────────────────────────\n if (!await validateLedger()) {\n console.error(\"Ledger DB validation failed. Aborting run.\");\n const elapsed = Math.round((Date.now() - startedAt) / 1000);\n console.log(`Done. errors=${ERROR_COUNT} elapsed=${elapsed}s`);\n return { ok: false, reason: \"ledger-validation-failed\", errors: ERROR_COUNT, elapsed };\n }\n\n // ──────────────────────────────────────────────────────────────────────\n // PHASE 2: Schema sync\n // ──────────────────────────────────────────────────────────────────────\n const schemas = await syncSchemas();\n if (!schemas) {\n console.error(\"Schema sync failed catastrophically. Aborting run.\");\n const elapsed = Math.round((Date.now() - startedAt) / 1000);\n console.log(`Done. errors=${ERROR_COUNT} elapsed=${elapsed}s`);\n return { ok: false, reason: \"schema-sync-failed\", errors: ERROR_COUNT, elapsed };\n }\n const { aProps, bProps } = schemas;\n\n // ──────────────────────────────────────────────────────────────────────\n // PHASE 3: Fetch all rows (including archived)\n // ──────────────────────────────────────────────────────────────────────\n console.log(\"--- Row sync ---\");\n let aPagesRaw: any[], bPagesRaw: any[], ledgerPagesRaw: any[];\n try {\n [aPagesRaw, bPagesRaw, ledgerPagesRaw] = await Promise.all([\n queryAllPages(DB_A_ID),\n queryAllPages(DB_B_ID),\n queryAllPages(LEDGER_ID),\n ]);\n } catch (err) {\n await reportError({\n recordName: \"(no record)\",\n operation: \"fetch\",\n side: \"n/a\",\n error: err,\n });\n const elapsed = Math.round((Date.now() - startedAt) / 1000);\n console.log(`Done. errors=${ERROR_COUNT} elapsed=${elapsed}s`);\n return { ok: false, reason: \"fetch-failed\", errors: ERROR_COUNT, elapsed };\n }\n\n // Partition each side into active vs archived. An archived page is treated\n // as \"the user deleted this\" — same semantics as the page being missing.\n const aActive: any[] = [], aArchived: any[] = [];\n for (const p of aPagesRaw) (p.archived ? aArchived : aActive).push(p);\n const bActive: any[] = [], bArchived: any[] = [];\n for (const p of bPagesRaw) (p.archived ? bArchived : bActive).push(p);\n // Ledger entries that are archived shouldn't influence sync state.\n const ledgerActive = ledgerPagesRaw.filter(p => !p.archived);\n\n console.log(\n `Fetched: A=${aActive.length} (+${aArchived.length} archived), ` +\n `B=${bActive.length} (+${bArchived.length} archived), ` +\n `ledger=${ledgerActive.length}`\n );\n\n // ──────────────────────────────────────────────────────────────────────\n // PHASE 4: Trim whitespace in page names\n // ──────────────────────────────────────────────────────────────────────\n await trimPageNames(aActive, \"A\");\n await trimPageNames(bActive, \"B\");\n await trimPageNames(ledgerActive, \"ledger\");\n\n // ──────────────────────────────────────────────────────────────────────\n // PHASE 5: Within-DB dedupe (only among active pages)\n // ──────────────────────────────────────────────────────────────────────\n const aByName = await dedupeWithinDb(aActive, \"A\");\n const bByName = await dedupeWithinDb(bActive, \"B\");\n\n // Also build sets of archived names per side, so the classifier can\n // recognize \"this was archived on side X\" as a delete signal.\n const aArchivedNames = new Set();\n for (const p of aArchived) {\n const n = getPageName(p);\n if (n) aArchivedNames.add(n);\n }\n const bArchivedNames = new Set();\n for (const p of bArchived) {\n const n = getPageName(p);\n if (n) bArchivedNames.add(n);\n }\n\n // ──────────────────────────────────────────────────────────────────────\n // PHASE 6: Index the ledger\n // ──────────────────────────────────────────────────────────────────────\n const ledgerByName = new Map();\n for (const lp of ledgerActive) {\n const entry = parseLedgerPage(lp);\n if (entry.name) ledgerByName.set(entry.name, entry);\n }\n\n // ──────────────────────────────────────────────────────────────────────\n // PHASE 7: Classify\n //\n // For each name across A ∪ B ∪ ledger, decide what (if anything) to do.\n // \"Archived\" on one side is treated equivalently to \"missing\".\n // ──────────────────────────────────────────────────────────────────────\n const allNames = new Set([\n ...aByName.keys(), ...bByName.keys(), ...ledgerByName.keys(),\n ]);\n\n const work: Work[] = [];\n let skippedUnchanged = 0;\n\n for (const name of allNames) {\n if (!name) continue;\n const a = aByName.get(name);\n const b = bByName.get(name);\n const ledger = ledgerByName.get(name);\n const aWasArchived = aArchivedNames.has(name);\n const bWasArchived = bArchivedNames.has(name);\n\n // ── Case A: A is gone or archived, B is active, ledger present\n // → user deleted on A → archive B too, clean up ledger\n if (!a && b && ledger) {\n work.push({ op: \"delete-B\", name, b, ledger });\n continue;\n }\n // ── Case B: B is gone or archived, A is active, ledger present\n // → user deleted on B → archive A too, clean up ledger\n if (a && !b && ledger) {\n work.push({ op: \"delete-A\", name, a, ledger });\n continue;\n }\n // ── Case C: Both sides gone/archived, ledger orphan → clean up ledger\n if (!a && !b && ledger) {\n work.push({ op: \"ledger-cleanup\", name, ledger });\n continue;\n }\n // ── Case D: No ledger, A archived, B active → A was archived without\n // a ledger entry. Treat B as canonical (no signal from ledger\n // that B should be deleted). Fall through to create-on-A? No:\n // A had this once and the user archived it. Best behavior is\n // to also archive B, matching the \"delete wins\" rule.\n if (!a && b && !ledger && aWasArchived) {\n work.push({ op: \"delete-B\", name, b });\n continue;\n }\n if (a && !b && !ledger && bWasArchived) {\n work.push({ op: \"delete-A\", name, a });\n continue;\n }\n // ── Case E: Only A has it (no ledger, B never had it) → create on B\n if (a && !b && !ledger && !bWasArchived) {\n work.push({ op: \"create-on-B\", name, a });\n continue;\n }\n // ── Case F: Only B has it → create on A\n if (!a && b && !ledger && !aWasArchived) {\n work.push({ op: \"create-on-A\", name, b });\n continue;\n }\n // ── Case G: Both sides active → did either change?\n if (a && b) {\n const aHashNow = await hashPageContent(a, bProps);\n const bHashNow = await hashPageContent(b, bProps);\n\n if (ledger?.aContentHash && ledger?.bContentHash) {\n const aChanged = aHashNow !== ledger.aContentHash;\n const bChanged = bHashNow !== ledger.bContentHash;\n\n if (!aChanged && !bChanged) {\n skippedUnchanged++;\n continue;\n }\n if (aChanged && !bChanged) {\n work.push({ op: \"update-A-to-B\", name, a, b, ledger, aHashNow, bHashNow });\n continue;\n }\n if (!aChanged && bChanged) {\n work.push({ op: \"update-B-to-A\", name, a, b, ledger, aHashNow, bHashNow });\n continue;\n }\n // Both changed → conflict. Tiebreak by newer last_edited_time.\n const aTime = new Date(a.last_edited_time).getTime();\n const bTime = new Date(b.last_edited_time).getTime();\n work.push({\n op: aTime >= bTime ? \"update-A-to-B\" : \"update-B-to-A\",\n name, a, b, ledger, aHashNow, bHashNow,\n });\n continue;\n }\n\n // No ledger snapshot. If content already matches, just record ledger.\n if (aHashNow === bHashNow) {\n work.push({ op: \"update-A-to-B\", name, a, b, ledger, aHashNow, bHashNow });\n continue;\n }\n // Different content + no ledger → use timestamp tiebreaker.\n const aTime = new Date(a.last_edited_time).getTime();\n const bTime = new Date(b.last_edited_time).getTime();\n work.push({\n op: aTime >= bTime ? \"update-A-to-B\" : \"update-B-to-A\",\n name, a, b, ledger, aHashNow, bHashNow,\n });\n }\n }\n\n if (skippedUnchanged > 0) {\n console.log(`Skipped ${skippedUnchanged} unchanged record(s).`);\n }\n\n // Order: structural changes first, then updates, then cleanup.\n const order: Record = {\n \"delete-A\": 0, \"delete-B\": 0,\n \"create-on-A\": 1, \"create-on-B\": 1,\n \"update-A-to-B\": 2, \"update-B-to-A\": 2,\n \"ledger-cleanup\": 3,\n };\n work.sort((x, y) => order[x.op] - order[y.op]);\n\n // ──────────────────────────────────────────────────────────────────────\n // PHASE 8: Apply\n // ──────────────────────────────────────────────────────────────────────\n let creates = 0, updates = 0, deletes = 0, noops = 0, deferred = 0;\n\n for (const w of work) {\n if (overBudget()) { deferred++; continue; }\n\n try {\n switch (w.op) {\n case \"create-on-B\": {\n const props = extractWritableProps(w.a, bProps);\n const newB = await createPageIn(DB_B_ID, props);\n const hash = await sha256Hex(stableStringify(props));\n await createLedgerEntry(w.name, w.a.id, newB.id, hash, hash);\n creates++;\n break;\n }\n case \"create-on-A\": {\n const props = extractWritableProps(w.b, aProps);\n const newA = await createPageIn(DB_A_ID, props);\n const hashProps = extractWritableProps(w.b, bProps);\n const hash = await sha256Hex(stableStringify(hashProps));\n await createLedgerEntry(w.name, newA.id, w.b.id, hash, hash);\n creates++;\n break;\n }\n case \"update-A-to-B\": {\n if (w.aHashNow !== w.bHashNow) {\n await updatePage(\"B\", w.b.id, extractWritableProps(w.a, bProps));\n }\n await updateLedgerOrCreate(w, w.aHashNow!, w.aHashNow!);\n updates++;\n break;\n }\n case \"update-B-to-A\": {\n if (w.aHashNow !== w.bHashNow) {\n await updatePage(\"A\", w.a.id, extractWritableProps(w.b, aProps));\n }\n await updateLedgerOrCreate(w, w.bHashNow!, w.bHashNow!);\n updates++;\n break;\n }\n case \"delete-B\": {\n await archivePage(\"B\", w.b.id, `B (deleted on A): ${w.name}`);\n if (w.ledger) {\n await archivePage(\"ledger\", w.ledger.ledgerPageId, `ledger: ${w.name}`);\n }\n deletes++;\n break;\n }\n case \"delete-A\": {\n await archivePage(\"A\", w.a.id, `A (deleted on B): ${w.name}`);\n if (w.ledger) {\n await archivePage(\"ledger\", w.ledger.ledgerPageId, `ledger: ${w.name}`);\n }\n deletes++;\n break;\n }\n case \"ledger-cleanup\": {\n await archivePage(\"ledger\", w.ledger!.ledgerPageId, `ledger orphan: ${w.name}`);\n noops++;\n break;\n }\n }\n } catch (err) {\n // The operation name is the Op enum value — already a useful label.\n // The side is inferred from the op for the error report.\n const side: \"A\" | \"B\" | \"ledger\" | \"n/a\" =\n w.op === \"ledger-cleanup\" ? \"ledger\" :\n w.op.endsWith(\"-B\") || w.op.includes(\"-to-B\") ? \"B\" :\n w.op.endsWith(\"-A\") || w.op.includes(\"-to-A\") ? \"A\" :\n \"n/a\";\n await reportError({\n recordName: w.name,\n operation: w.op,\n side,\n error: err,\n });\n }\n }\n\n const elapsed = Math.round((Date.now() - startedAt) / 1000);\n console.log(\n `Done. creates=${creates} updates=${updates} ` +\n `deletes=${deletes} noops=${noops} deferred=${deferred} ` +\n `errors=${ERROR_COUNT} ` +\n `elapsed=${elapsed}s`\n );\n if (deferred > 0) {\n console.log(`Time budget reached — ${deferred} records deferred to next run.`);\n }\n if (ERROR_COUNT > 0) {\n console.log(`${ERROR_COUNT} error(s) reported — see error DBs in Notion.`);\n }\n\n return {\n ok: true,\n creates, updates, deletes, noops, deferred,\n errors: ERROR_COUNT,\n elapsed,\n };\n}\n\nasync function updateLedgerOrCreate(w: Work, aHash: string, bHash: string) {\n if (w.ledger) {\n await updateLedgerEntry(w.ledger.ledgerPageId, w.a.id, w.b.id, aHash, bHash);\n } else {\n await createLedgerEntry(w.name, w.a.id, w.b.id, aHash, bHash);\n }\n}\n","label",[127],"ed271858-5a00-11f1-a26b-ee650bb23af1",["D",1779909545039],[27],"pulls","branches",1,"forks","envVars",{"_150":152,"_153":59},"connections",{"_150":59,"_151":59},"count","unfilledCount",9,"emptyCount",{"_41":139,"_31":27,"_29":30,"_129":-5,"_39":40,"_38":14,"_131":24,"_36":160,"_13":59,"_32":33,"_34":35,"_23":24,"_137":-5,"_157":161,"_26":162},{"_41":126,"_31":127,"_29":128,"_129":-5,"_39":40,"_38":130,"_131":132,"_36":156,"_13":134,"_32":135,"_34":136,"_23":24,"_137":-5,"_157":158,"_26":159},["D",1779909512945],"children",[],[127],["D",1779909545039],[],[27],["D",1779868054388],{"_93":92,"_101":97},{"_93":92,"_94":95,"_96":97,"_18":53,"_98":99,"_100":24},{"_13":82,"_31":83,"_41":40,"_84":42,"_85":-5,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":43,"_91":92},"ctx",{"_75":-5,"_121":200,"_201":202,"_203":204,"_205":24,"_206":24,"_207":24,"_208":132,"_209":-5,"_210":-7,"_211":-7,"_212":59,"_213":24,"_214":24,"_215":-5,"_216":24,"_217":24,"_218":24,"_219":-5},"ENV",{"_171":172,"_173":174,"_175":83,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197,"_198":199},"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 · v28