[{"_1":2,"_181":-5,"_182":-5},"loaderData",{"_3":4,"_93":94},"root",{"_5":6,"_36":37,"_66":67},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":-5,"_32":33,"_34":20,"_35":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesChatPanelState","notificationCount",0,"flagDenols","isTeamOrgMember","ENV",{"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63,"_64":65},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","1ed3b00b191d67ef967325d666dac7a18ce9a124","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","API_URL","https://api.val.town","clerkState",{"_68":69},"__internal_clerk_state",{"_70":71,"_72":47,"_73":74,"_75":74,"_76":20,"_77":74,"_78":74,"_79":74,"_80":74,"_81":82,"_91":20,"_92":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_83":20,"_19":20,"_84":74,"_85":86,"_87":74,"_88":47,"_89":20,"_90":74},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_95":96,"_97":98,"_99":100,"_101":102,"_158":159,"_178":179,"_180":-5},"handle","c15r","name","sync","path","replay.ts","project",{"_103":104,"_97":98,"_105":106,"_107":-5,"_108":20,"_109":110,"_111":112,"_113":-5,"_12":114,"_115":-5,"_116":20,"_117":-5,"_118":-5,"_119":120,"_14":121,"_122":123,"_124":125,"_126":-5,"_127":128,"_129":128,"_130":131,"_132":131,"_133":131,"_134":128,"_135":128,"_23":136,"_139":140,"_144":145,"_157":20},"id","93e19588-0ebb-11f1-a6cd-42dde27851f2","createdAt",["D",1771633422787],"deletedAt","legacyEnvVars","privacy","public","description","Agent collaboration layer https://sync.parc.land","imageUrl","21f2e37e-8066-4730-9dc7-d27cf8d3c9f3","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",1,"0630d977-f678-453e-926c-52043293f59f","tursoName","93e195880ebb11f1a6cd42dde27851f2","tursoHostname","93e195880ebb11f1a6cd42dde27851f2-val-town.aws-us-east-2.turso.io","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_95":96,"_137":138},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yb2RJNlc1czZ1NlpZRmoxdGJ2eFVNNVhmeTYifQ","org",{"_95":96,"_141":138,"_12":114,"_142":143},"avatar","tier","pro","branch",{"_146":147,"_97":45,"_103":148,"_149":104,"_150":-5,"_151":-5,"_152":-5,"_153":-5,"_154":-5,"_155":98,"_156":96},"version",639,"93e21602-0ebb-11f1-a6cd-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_103":160,"_97":100,"_161":162,"_163":-5,"_164":148,"_165":166,"_167":168,"_105":169,"_146":170,"_171":172,"_173":174,"_175":20,"_176":-5,"_99":177},"89c8d3d2-2198-11f1-9238-42dde27851f2","fileId","debc6afe-1ad9-11f1-b21b-42dde27851f2","parentId","branchId","branchVersion",634,"latest",true,["D",1773707445460],2,"fileType","script","content","/**\n * replay.ts — Time-travel replay for sync rooms.\n *\n * v9: Reconstructs wrapped { value, _meta } state from audit entries.\n * Uses celEval (Environment) so v9 expressions with domain helpers work.\n * Accumulates per-key _meta (writer, via, revision) from audit walk.\n */\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { celEval } from \"./cel.ts\";\nimport { rows2objects } from \"./utils.ts\";\nimport { isTimerLive } from \"./timers.ts\";\nimport type { EntryMeta } from \"./meta.ts\";\n\n/** Minimal _meta accumulated from audit walk */\nfunction replayMeta(revision: number, writer: string | null, via: string | null, seq: number | null, ts: string): EntryMeta {\n return {\n revision,\n updated_at: ts,\n writer,\n via,\n seq,\n score: 0,\n velocity: 0,\n writers: writer ? [writer] : [],\n first_at: ts,\n elided: false,\n };\n}\n\n/**\n * Reconstruct room state by replaying audit entries up to seq N.\n * Returns wrapped { value, _meta } entries — same shape as live context.\n */\nexport async function replayRoom(roomId: string, upToSeq: number): Promise<{\n agents: any[];\n state: any[];\n messages: any[];\n actions: any[];\n views: any[];\n audit: any[];\n _replay: { seq: number; total: number; ts: string | null };\n}> {\n const auditRes = await sqlite.execute({\n sql: `SELECT sort_key, value FROM state WHERE room_id = ? AND scope = '_audit' AND sort_key <= ? ORDER BY sort_key ASC`,\n args: [roomId, upToSeq],\n });\n const auditRows = rows2objects(auditRes);\n\n const totalRes = await sqlite.execute({\n sql: `SELECT COALESCE(MAX(sort_key), 0) as total FROM state WHERE room_id = ? AND scope = '_audit'`,\n args: [roomId],\n });\n const total = Number(rows2objects(totalRes)[0]?.total ?? 0);\n\n // ── Reconstruction state ──\n const agentsMap: Record = {};\n const actionsMap: Record = {};\n const viewsMap: Record = {};\n // state: scope → key → { value, revision, writer, via, seq, writers, first_at }\n const stateMap: Record; first_at: string }>> = {};\n const messagesArr: any[] = [];\n const auditOut: any[] = [];\n\n let lastTs: string | null = null;\n\n function writeState(scope: string, key: string, value: any, agent: string | null, action: string | null, seq: number, ts: string) {\n if (!stateMap[scope]) stateMap[scope] = {};\n const existing = stateMap[scope][key];\n if (existing) {\n existing.value = value;\n existing.revision++;\n existing.writer = agent;\n existing.via = action;\n existing.seq = seq;\n if (agent) existing.writers.add(agent);\n } else {\n stateMap[scope][key] = {\n value, revision: 1, writer: agent, via: action, seq,\n writers: new Set(agent ? [agent] : []),\n first_at: ts,\n };\n }\n }\n\n for (const row of auditRows) {\n let entry: any;\n try { entry = JSON.parse(row.value); } catch { continue; }\n const kind = entry.kind ?? \"invoke\";\n lastTs = entry.ts ?? lastTs;\n const seq = Number(row.sort_key);\n\n auditOut.push({ sort_key: row.sort_key, value: entry, updated_at: entry.ts ?? \"\" });\n\n switch (kind) {\n case \"agent_join\": {\n const s = entry.schema ?? {};\n agentsMap[s.id] = {\n id: s.id, name: s.name ?? s.id, role: s.role ?? \"agent\",\n status: \"active\", grants: JSON.stringify(s.grants ?? []),\n joined_at: entry.ts ?? \"\", last_heartbeat: entry.ts ?? \"\", waiting_on: null,\n };\n if (s.state && typeof s.state === \"object\") {\n for (const [key, value] of Object.entries(s.state)) {\n writeState(s.id, key, value, s.id, null, seq, entry.ts ?? \"\");\n }\n }\n break;\n }\n case \"agent_update\": {\n const s = entry.schema ?? {};\n if (agentsMap[s.id]) {\n const changes = s.changes ?? {};\n if (changes.name !== undefined) agentsMap[s.id].name = changes.name;\n if (changes.role !== undefined) agentsMap[s.id].role = changes.role;\n if (changes.grants !== undefined) agentsMap[s.id].grants = JSON.stringify(changes.grants);\n }\n break;\n }\n case \"register_action\": {\n const s = entry.schema ?? {};\n if (s.id) {\n actionsMap[s.id] = {\n id: s.id, room_id: roomId, scope: s.scope ?? \"_shared\",\n description: s.description ?? null, if: s.if_expr ?? null,\n enabled: s.enabled_expr ?? null, writes: s.writes ?? [],\n params: s.params ?? null, available: true, version: 1,\n registered_by: entry.agent ?? null,\n };\n }\n break;\n }\n case \"delete_action\": {\n const s = entry.schema ?? {};\n if (s.id) delete actionsMap[s.id];\n break;\n }\n case \"register_view\": {\n const s = entry.schema ?? {};\n if (s.id) {\n viewsMap[s.id] = {\n id: s.id, room_id: roomId, scope: s.scope ?? \"_shared\",\n description: s.description ?? null, expr: s.expr,\n enabled: s.enabled_expr ?? null, render: s.render ?? null,\n registered_by: entry.agent ?? null, version: 1,\n };\n }\n break;\n }\n case \"delete_view\": {\n const s = entry.schema ?? {};\n if (s.id) delete viewsMap[s.id];\n break;\n }\n case \"invoke\":\n default: {\n const writes: Array<{ scope: string; key: string; value?: any }> = entry.effect?.writes ?? [];\n for (const w of writes) {\n if (!w.scope || !w.key) continue;\n if (w.scope === \"_messages\") {\n messagesArr.push({ sort_key: w.key, value: w.value, updated_at: entry.ts ?? \"\" });\n continue;\n }\n if (w.scope === \"_audit\") continue;\n writeState(w.scope, w.key, w.value, entry.agent ?? null, entry.action ?? null, seq, entry.ts ?? \"\");\n }\n const invokeAgent = entry.agent;\n if (invokeAgent && agentsMap[invokeAgent]) {\n agentsMap[invokeAgent].status = \"active\";\n agentsMap[invokeAgent].last_heartbeat = entry.ts ?? agentsMap[invokeAgent].last_heartbeat;\n }\n break;\n }\n }\n }\n\n // ── Build wrapped state (v9 shape: { value, _meta }) ──\n const stateRows: any[] = [];\n const celState: Record> = {};\n\n for (const [scope, keys] of Object.entries(stateMap)) {\n celState[scope] = {};\n for (const [key, entry] of Object.entries(keys)) {\n const wrapped = {\n value: entry.value,\n _meta: {\n ...replayMeta(entry.revision, entry.writer, entry.via, entry.seq, entry.first_at),\n updated_at: lastTs ?? entry.first_at,\n writers: [...entry.writers],\n },\n };\n celState[scope][key] = wrapped;\n stateRows.push({ room_id: roomId, scope, key, value: entry.value, version: \"\", revision: entry.revision, sort_key: null, updated_at: lastTs ?? \"\" });\n }\n }\n\n // ── Wrapped agents for CEL context ──\n const celAgents: Record = {};\n for (const [id, a] of Object.entries(agentsMap)) {\n celAgents[id] = {\n value: { name: a.name, role: a.role, status: a.status },\n _meta: replayMeta(1, null, null, null, a.joined_at ?? \"\"),\n };\n }\n\n // ── Wrapped actions for CEL context ──\n const celActions: Record = {};\n for (const [id, a] of Object.entries(actionsMap)) {\n celActions[id] = {\n value: { enabled: true, available: true, description: a.description },\n _meta: { ...replayMeta(1, a.registered_by, null, null, \"\"), invocations: 0, last_invoked_at: null, last_invoked_by: null, contested: [] },\n };\n }\n\n // ── Evaluate views against wrapped reconstructed state ──\n const views: any[] = [];\n for (const viewDef of Object.values(viewsMap)) {\n let value: any = null;\n try {\n const celCtx = {\n state: celState,\n views: {},\n agents: celAgents,\n actions: celActions,\n messages: { count: messagesArr.length, unread: 0, directed_unread: 0 },\n self: \"\",\n params: {},\n };\n const evalResult = celEval(viewDef.expr, celCtx);\n value = typeof evalResult === \"bigint\" ? Number(evalResult) : evalResult;\n } catch (e: any) {\n value = { _error: e.message };\n }\n views.push({ ...viewDef, value });\n }\n\n // ── Messages from DB (more reliable than audit writes) ──\n if (lastTs) {\n const sqliteTs = lastTs.replace(\"T\", \" \").replace(/\\.\\d+Z?$/, \"\");\n const dbMsgsRes = await sqlite.execute({\n sql: `SELECT sort_key, value, updated_at FROM state\n WHERE room_id = ? AND scope = '_messages' AND updated_at <= ?\n ORDER BY sort_key ASC`,\n args: [roomId, sqliteTs],\n });\n messagesArr.length = 0;\n for (const row of rows2objects(dbMsgsRes)) {\n let msgValue: any = row.value;\n try { msgValue = JSON.parse(row.value); } catch {}\n messagesArr.push({ sort_key: row.sort_key, value: msgValue, updated_at: row.updated_at });\n }\n } else {\n messagesArr.length = 0;\n }\n\n return {\n agents: Object.values(agentsMap),\n state: stateRows,\n messages: messagesArr,\n actions: Object.values(actionsMap),\n views,\n audit: auditOut,\n _replay: { seq: upToSeq, total, ts: lastTs },\n };\n}\n","deleted","label",[100],"permalink","https://www.val.town/x/c15r/sync/code/replay.ts","extension","actionData","errors"]