[{"_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","cel.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},"89c44ba0-2198-11f1-9238-42dde27851f2","fileId","85ccce52-1048-11f1-ab7f-42dde27851f2","parentId","branchId","branchVersion",634,"latest",true,["D",1773707445460],7,"fileType","script","content","/**\n * cel.ts — CEL (Common Expression Language) evaluator for sync v9.\n *\n * v9: Wrapped state model + Environment API.\n *\n * Every entry in the CEL context is { value, _meta: { ... } }.\n * The Environment registers domain helpers and receiver methods\n * so expressions can query the wrapped shape ergonomically:\n *\n * state._shared.phase.value == \"executing\" // value access\n * state._shared.phase._meta.writer == \"explorer\" // meta access\n * salient(state._shared, 0.5) // domain helper\n * state._shared.keys().filter(k, ...) // receiver method\n * written_by(state._shared, self) // provenance query\n *\n * Three layers:\n * Storage: raw values in SQLite\n * Engine: buildContext wraps every entry with full _meta (this module)\n * Projection: buildExpandedContext shapes _meta by salience threshold (context.ts)\n *\n * Validation pipeline (validateExpression):\n * 1. Parse — syntax check with source-pointed error\n * 2. Check — type-level validation via Environment.check()\n * 3. Lint — static detection of old-style (v8) expressions\n * 4. Eval — trial evaluation against room state (optional)\n */\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport {\n Environment,\n evaluate as bareEvaluate,\n parse,\n ParseError,\n EvaluationError,\n} from \"npm:@marcbachmann/cel-js\";\nimport { isTimerLive } from \"./timers.ts\";\nimport {\n computeRoomMeta,\n computeScore,\n loadAgentContext,\n wrapEntry,\n minimalMeta,\n type AgentContext,\n type RoomMeta,\n type WrappedEntry,\n type EntryMeta,\n} from \"./meta.ts\";\n\n// Re-export for consumers\nexport type { WrappedEntry, EntryMeta };\n\n// ── Singleton Environment ──────────────────────────────────────────────\n//\n// Created once per process. Registers all domain helpers and receiver\n// methods. Used for all CEL evaluation and validation.\n\nlet _env: Environment | null = null;\n\nexport function getCelEnvironment(): Environment {\n if (_env) return _env;\n\n const env = new Environment({\n unlistedVariablesAreDyn: true,\n homogeneousAggregateLiterals: false,\n enableOptionalTypes: true,\n });\n\n // ── Receiver methods (map → list conversions) ──────────────────────\n // The built-in map.keys() and map.entries() don't resolve through dyn\n // at eval time, so we register explicit receiver methods that work\n // regardless of how the map is accessed in the expression.\n\n env.registerFunction({\n name: \"keys\",\n receiverType: \"map\",\n returnType: \"list\",\n handler: (m: any) => Object.keys(m),\n params: [],\n description: \"Get all keys from a map as a list\",\n });\n\n env.registerFunction({\n name: \"entries\",\n receiverType: \"map\",\n returnType: \"list\",\n handler: (m: any) =>\n Object.entries(m).map(([k, v]) => ({ key: k, entry: v })),\n params: [],\n description: \"Get all entries from a map as a list of { key, entry }\",\n });\n\n env.registerFunction({\n name: \"values\",\n receiverType: \"map\",\n returnType: \"list\",\n handler: (m: any) => Object.values(m),\n params: [],\n description: \"Get all values from a map as a list\",\n });\n\n // ── Domain helpers: scope queries ──────────────────────────────────\n\n env.registerFunction({\n signature: \"salient(map, double): list\",\n handler: (scope: any, threshold: number) =>\n Object.keys(scope).filter(\n (k) => (scope[k]?._meta?.score ?? 0) > threshold,\n ),\n description:\n \"Keys in scope with salience score above threshold\",\n });\n\n env.registerFunction({\n signature: \"elided(map): list\",\n handler: (scope: any) =>\n Object.keys(scope).filter((k) => scope[k]?._meta?.elided === true),\n description: \"Keys in scope that are elided (value is null)\",\n });\n\n env.registerFunction({\n signature: \"active(map): list\",\n handler: (scope: any) =>\n Object.keys(scope).filter((k) => !scope[k]?._meta?.elided),\n description: \"Keys in scope that are not elided\",\n });\n\n env.registerFunction({\n signature: \"written_by(map, string): list\",\n handler: (scope: any, agent: string) =>\n Object.keys(scope).filter((k) => scope[k]?._meta?.writer === agent),\n description: \"Keys in scope last written by a specific agent\",\n });\n\n env.registerFunction({\n signature: \"velocity_above(map, double): list\",\n handler: (scope: any, threshold: number) =>\n Object.keys(scope).filter(\n (k) => (scope[k]?._meta?.velocity ?? 0) > threshold,\n ),\n description: \"Keys in scope with write velocity above threshold\",\n });\n\n env.registerFunction({\n signature: \"top_n(map, int): list\",\n handler: (scope: any, n: bigint) =>\n Object.entries(scope)\n .map(([k, v]: [string, any]) => ({\n key: k,\n score: v?._meta?.score ?? 0,\n }))\n .sort((a, b) => b.score - a.score)\n .slice(0, Number(n))\n .map((e) => e.key),\n description:\n \"Top N keys in scope by salience score\",\n });\n\n env.registerFunction({\n signature: \"focus(map): list\",\n handler: (scope: any) =>\n Object.entries(scope)\n .filter(\n ([_, v]: [string, any]) =>\n !v?._meta?.elided && (v?._meta?.score ?? 0) > 0.5,\n )\n .map(([k]) => k),\n description: \"Keys in focus tier (high score, not elided)\",\n });\n\n env.registerFunction({\n signature: \"peripheral(map): list\",\n handler: (scope: any) =>\n Object.entries(scope)\n .filter(([_, v]: [string, any]) => {\n const s = v?._meta?.score ?? 0;\n return !v?._meta?.elided && s > 0.1 && s <= 0.5;\n })\n .map(([k]) => k),\n description:\n \"Keys in peripheral tier (medium score, not elided)\",\n });\n\n // ── Domain helpers: action queries ─────────────────────────────────\n\n env.registerFunction({\n signature: \"contested(map): list\",\n handler: (actions: any) =>\n Object.keys(actions).filter((k) => {\n const c = actions[k]?._meta?.contested;\n return Array.isArray(c) && c.length > 0;\n }),\n description: \"Action IDs that have contested write targets\",\n });\n\n env.registerFunction({\n signature: \"stale(map, int): list\",\n handler: (actions: any, threshold: bigint) =>\n Object.keys(actions).filter(\n (k) => (actions[k]?._meta?.invocations ?? 0) < Number(threshold),\n ),\n description: \"Action IDs with fewer than N invocations\",\n });\n\n // ── Convenience shorthands ─────────────────────────────────────────\n\n env.registerFunction({\n signature: \"val(dyn): dyn\",\n handler: (entry: any) => {\n if (entry && typeof entry === \"object\" && \"value\" in entry) {\n return entry.value;\n }\n return entry;\n },\n description: \"Shorthand: extract .value from a wrapped entry\",\n });\n\n env.registerFunction({\n signature: \"meta(dyn, string): dyn\",\n handler: (entry: any, field: string) => {\n if (entry && typeof entry === \"object\" && \"_meta\" in entry) {\n return entry._meta[field] ?? null;\n }\n return null;\n },\n description: \"Shorthand: extract a _meta field from a wrapped entry\",\n });\n\n _env = env;\n return env;\n}\n\n// ── CEL evaluation (replaces bare evaluate()) ──────────────────────────\n\n/**\n * Evaluate a CEL expression using the sync Environment.\n * All domain helpers and receiver methods are available.\n */\nexport function celEval(expr: string, ctx: Record): any {\n const env = getCelEnvironment();\n return env.evaluate(expr, ctx);\n}\n\n// ── Validation ─────────────────────────────────────────────────────────\n\nexport interface ValidationResult {\n valid: boolean;\n stage: \"parse\" | \"check\" | \"lint\" | \"eval\" | \"ok\";\n error?: string;\n /** Source pointer for parse/eval errors (if available) */\n source?: string;\n /** Actionable hint for fixing the issue */\n hint?: string;\n /** Help key — invoke help({ key }) for detailed guidance */\n help?: string;\n /** Inferred return type (if validation succeeded) */\n type?: string;\n /** Lint warnings (expressions that parse but may be incorrect) */\n warnings?: string[];\n}\n\n/**\n * Detect old-style (v8) CEL patterns that silently produce wrong results\n * under the v9 wrapped shape.\n *\n * These expressions parse and evaluate without error, but compare\n * { value, _meta } objects to primitives (always false) or access\n * fields directly on the wrapped entry instead of on .value.\n */\nfunction lintExpression(expr: string): string[] {\n const warnings: string[] = [];\n\n // Pattern: state.scope.key == \"literal\" (without .value)\n // Compares { value, _meta } to a primitive → always false\n const bareCompare =\n /state\\.(\\w+)\\.(\\w+)\\s*(==|!=|>=|<=|>|<)\\s*(\".*?\"|'.*?'|\\d+(?:\\.\\d+)?|true|false|null)/g;\n let m;\n while ((m = bareCompare.exec(expr))) {\n const fullPath = `state.${m[1]}.${m[2]}`;\n if (\n !fullPath.endsWith(\".value\") && !fullPath.includes(\"._meta\")\n ) {\n const parts = fullPath.split(\".\");\n if (parts.length === 3) {\n warnings.push(\n `\"${fullPath}\" compares a wrapped entry to a primitive. ` +\n `Use \"${fullPath}.value\" instead. See help({ key: \"wrapped_entries\" }).`,\n );\n }\n }\n }\n\n // Pattern: state.scope[\"key\"].field where field isn't value or _meta\n const bracketField =\n /state\\.\\w+\\[\"[^\"]+\"\\]\\.([a-z]\\w+)/g;\n while ((m = bracketField.exec(expr))) {\n const field = m[1];\n if (field !== \"value\" && field !== \"_meta\" && !field.startsWith(\"_\")) {\n warnings.push(\n `\".${field}\" accesses the wrapped entry directly. ` +\n `Use \".value.${field}\" instead. See help({ key: \"wrapped_entries\" }).`,\n );\n }\n }\n\n // Pattern: state.scope.key.field where field isn't value/_meta\n // but only at the 4th dot level (state.scope.key.field)\n const dotField =\n /state\\.(\\w+)\\.(\\w+)\\.([a-z]\\w+)/g;\n while ((m = dotField.exec(expr))) {\n const field = m[3];\n if (\n field !== \"value\" && field !== \"_meta\" && !field.startsWith(\"_\")\n ) {\n // Avoid false positives: state._shared.phase.value.something is fine\n // We only flag state._shared.key.field (not state._shared.key.value.field)\n const preceding = `state.${m[1]}.${m[2]}`;\n // Check that the preceding token isn't \".value\"\n const fullMatch = m[0];\n if (!fullMatch.includes(\".value.\")) {\n warnings.push(\n `\".${field}\" on \"${preceding}\" accesses the wrapped entry directly. ` +\n `Use \"${preceding}.value.${field}\" instead.`,\n );\n }\n }\n }\n\n // Deduplicate\n return [...new Set(warnings)];\n}\n\n/**\n * Validate a CEL expression through a multi-stage pipeline.\n *\n * Stages:\n * 1. parse — syntax check (catches missing operators, bad tokens, etc.)\n * 2. check — type-level validation via Environment.check()\n * 3. lint — static detection of v8-style patterns (silent wrong results)\n * 4. eval — trial evaluation against provided context (optional)\n *\n * Returns structured feedback with error location, hint, and warnings.\n */\nexport function validateExpression(\n expr: string,\n trialCtx?: Record,\n): ValidationResult {\n if (!expr || typeof expr !== \"string\" || expr.trim() === \"\") {\n return {\n valid: false,\n stage: \"parse\",\n error: \"Expression is empty\",\n hint: \"Provide a CEL expression.\",\n };\n }\n\n // ── Stage 1: Parse ──\n try {\n parse(expr);\n } catch (e: any) {\n const msg = e.message || String(e);\n // Extract source pointer if present (lines after the first)\n const lines = msg.split(\"\\n\");\n const source = lines.length > 1 ? lines.slice(1).join(\"\\n\") : undefined;\n\n return {\n valid: false,\n stage: \"parse\",\n error: lines[0],\n source,\n hint: e instanceof ParseError\n ? \"Syntax error. Check: balanced parentheses, valid operators (== not ===), proper string quotes.\"\n : \"Expression could not be parsed.\",\n help: \"expressions\",\n };\n }\n\n // ── Stage 2: Check ──\n // With unlistedVariablesAreDyn, all state access resolves to `dyn` which\n // means the checker can't validate receiver methods (.keys(), .entries())\n // or deep property access. We treat check failures as soft warnings\n // rather than hard errors — the real validation happens at eval time.\n try {\n const env = getCelEnvironment();\n const checkResult = env.check(expr);\n if (!checkResult.valid) {\n const msg = checkResult.error?.message ?? \"Type check failed\";\n // dyn-related failures are soft (receiver methods, overloads on dyn)\n const isDynIssue = msg.includes(\"dyn\") || msg.includes(\"no matching overload\");\n if (!isDynIssue) {\n const lines = msg.split(\"\\n\");\n return {\n valid: false,\n stage: \"check\",\n error: lines[0],\n source: lines.length > 1 ? lines.slice(1).join(\"\\n\") : undefined,\n hint:\n \"Type error. Check that variable types match operators. Use .value for entry values and ._meta for metadata.\",\n help: \"expressions\",\n };\n }\n // dyn type limitation — soft pass, not a real error\n }\n } catch {\n // check() can throw for complex dyn expressions — soft pass\n }\n\n // ── Stage 3: Lint ──\n const warnings = lintExpression(expr);\n\n // ── Stage 4: Trial eval (optional) ──\n if (trialCtx) {\n try {\n const env = getCelEnvironment();\n const result = env.evaluate(expr, trialCtx);\n const type = result === null\n ? \"null\"\n : typeof result === \"bigint\"\n ? \"int\"\n : Array.isArray(result)\n ? \"list\"\n : typeof result === \"object\"\n ? \"map\"\n : typeof result;\n\n return {\n valid: true,\n stage: \"ok\",\n type,\n ...(warnings.length > 0 ? { warnings } : {}),\n };\n } catch (e: any) {\n const msg = e.message || String(e);\n const lines = msg.split(\"\\n\");\n\n let hint: string;\n let help = \"expressions\";\n if (msg.includes(\"No such key\")) {\n const keyMatch = msg.match(/No such key: (\\S+)/);\n const missingKey = keyMatch?.[1] ?? \"\";\n if (missingKey === \"value\" || missingKey === \"_meta\") {\n hint =\n `Key \"${missingKey}\" not found. Only the top-level entry has .value and ._meta — ` +\n `you may be inside .value already.`;\n help = \"wrapped_entries\";\n } else if (missingKey === \"meta\") {\n hint = `Did you mean \"._meta\"? Meta fields use an underscore prefix.`;\n help = \"wrapped_entries\";\n } else {\n hint =\n `Key \"${missingKey}\" not found. Check the key exists, or guard with has().`;\n }\n } else if (msg.includes(\"no such overload\")) {\n hint =\n \"Type mismatch. Wrapped entries are maps — use .value for comparisons.\";\n help = \"wrapped_entries\";\n } else if (msg.includes(\"no matching overload\")) {\n hint =\n \"Function or method not available for this type. See help({ key: \\\"functions\\\" }) for available helpers.\";\n help = \"functions\";\n } else {\n hint =\n \"Expression failed at runtime. Check that referenced keys exist.\";\n }\n\n return {\n valid: false,\n stage: \"eval\",\n error: lines[0],\n source: lines.length > 1 ? lines.slice(1).join(\"\\n\") : undefined,\n hint,\n help,\n ...(warnings.length > 0 ? { warnings } : {}),\n };\n }\n }\n\n // No trial context — return parse+check+lint result\n return {\n valid: true,\n stage: \"ok\",\n ...(warnings.length > 0 ? { warnings } : {}),\n };\n}\n\n/**\n * Legacy-compatible validateCel — wraps validateExpression.\n * Used by actions.ts, views.ts for backward-compatible validation.\n */\nexport function validateCel(\n expr: string,\n): { valid: true; warnings?: string[] } | { valid: false; error: string; hint?: string; warnings?: string[] } {\n const result = validateExpression(expr);\n if (result.valid) {\n return { valid: true, ...(result.warnings?.length ? { warnings: result.warnings } : {}) };\n }\n // \"No such key\" at eval stage is acceptable — the key may not exist yet\n if (result.stage === \"eval\" && result.error?.includes(\"No such key\")) {\n return { valid: true, ...(result.warnings?.length ? { warnings: result.warnings } : {}) };\n }\n return {\n valid: false,\n error: result.error ?? \"validation failed\",\n hint: result.hint,\n ...(result.warnings?.length ? { warnings: result.warnings } : {}),\n };\n}\n\n// ── Internal helpers ───────────────────────────────────────────────────\n\nfunction rows2objects(result: { columns: string[]; rows: any[][] }) {\n return result.rows.map((row) =>\n Object.fromEntries(result.columns.map((col, i) => [col, row[i]]))\n );\n}\n\nfunction parseValue(raw: string): any {\n try {\n return JSON.parse(raw);\n } catch {\n return raw;\n }\n}\n\n// ── buildContext ────────────────────────────────────────────────────────\n\nexport interface BuildContextOptions {\n /** The requesting agent's ID. Used for `self`, scope privacy, and salience scoring. */\n selfAgent?: string;\n /** Additional scopes to include (for view/action evaluation with registrar authority). */\n includeScopes?: string[];\n /** If true, include ALL scopes (for internal/admin use). */\n allScopes?: boolean;\n}\n\n/**\n * Build the CEL evaluation context from room data.\n *\n * v9: Every entry is wrapped as { value, _meta: { ... } }.\n * All evaluation uses the Environment (celEval) for domain helpers.\n */\nexport async function buildContext(\n roomId: string,\n opts: BuildContextOptions = {},\n): Promise> {\n const { selfAgent, includeScopes = [], allScopes = false } = opts;\n\n const stateResult = await sqlite.execute({\n sql: `SELECT scope, key, sort_key, value, revision, updated_at,\n timer_effect, timer_expires_at, timer_ticks_left, enabled_expr\n FROM state WHERE room_id = ?`,\n args: [roomId],\n });\n const stateRows = rows2objects(stateResult) as any[];\n\n const roomMeta = await computeRoomMeta(roomId);\n\n let agentCtx: AgentContext | null = null;\n if (selfAgent) {\n agentCtx = await loadAgentContext(roomId, selfAgent, stateRows);\n }\n\n // ── Build wrapped state tree ──\n const state: Record> = {};\n const deferredEnabled: {\n scope: string;\n key: string;\n value: any;\n revision: number;\n updatedAt: string;\n enabled_expr: string;\n }[] = [];\n\n for (const row of stateRows) {\n if (!isTimerLive(row)) continue;\n\n const scope = row.scope as string;\n const isShared = scope === \"_shared\";\n const isSelf = selfAgent && scope === selfAgent;\n const isExplicitlyIncluded = includeScopes.includes(scope);\n const isSystemScope = scope.startsWith(\"_\");\n\n if (\n !allScopes && !isShared && !isSelf && !isExplicitlyIncluded &&\n !isSystemScope\n ) {\n continue;\n }\n\n if (row.enabled_expr) {\n deferredEnabled.push({\n scope,\n key: row.key,\n value: parseValue(row.value),\n revision: row.revision ?? 0,\n updatedAt: row.updated_at ?? \"\",\n enabled_expr: row.enabled_expr,\n });\n continue;\n }\n\n const contextScope = (isSelf && !allScopes) ? \"self\" : scope;\n if (!state[contextScope]) state[contextScope] = {};\n\n const value = parseValue(row.value);\n const score = computeScore(\n scope, row.key, row.updated_at, value, agentCtx, roomMeta,\n );\n\n state[contextScope][row.key] = wrapEntry(\n value, scope, row.key, row.revision ?? 0, row.updated_at ?? \"\",\n roomMeta, score,\n );\n }\n\n // ── Agents (wrapped) ──\n const agents: Record = {};\n for (const row of stateRows) {\n if (row.scope !== \"_agents\") continue;\n if (!isTimerLive(row)) continue;\n const val = parseValue(row.value);\n const agentData = {\n name: val.name ?? row.key,\n role: val.role ?? \"agent\",\n status: val.status ?? \"active\",\n waiting_on: val.waiting_on ?? null,\n last_heartbeat: val.last_heartbeat ?? null,\n };\n const score = computeScore(\n \"_agents\", row.key, row.updated_at, val, agentCtx, roomMeta,\n );\n agents[row.key] = wrapEntry(\n agentData, \"_agents\", row.key, row.revision ?? 0,\n row.updated_at ?? \"\", roomMeta, score,\n );\n }\n\n // ── Message counts ──\n const countResult = await sqlite.execute({\n sql: `SELECT COUNT(*) as total FROM state WHERE room_id = ? AND scope = '_messages'\n AND (timer_effect IS NULL\n OR (timer_effect = 'delete' AND (timer_expires_at IS NULL OR timer_expires_at > datetime('now'))\n AND (timer_ticks_left IS NULL OR timer_ticks_left > 0))\n OR (timer_effect = 'enable' AND ((timer_expires_at IS NOT NULL AND timer_expires_at <= datetime('now'))\n OR (timer_ticks_left IS NOT NULL AND timer_ticks_left <= 0))))`,\n args: [roomId],\n });\n const totalCount = Number(\n (rows2objects(countResult)[0] as any)?.total || 0,\n );\n\n let unreadCount = 0;\n let directedUnread = 0;\n if (selfAgent) {\n let lastSeen = 0;\n try {\n const agentEntry = stateRows.find(\n (r: any) => r.scope === \"_agents\" && r.key === selfAgent,\n );\n if (agentEntry) {\n const val = parseValue(agentEntry.value);\n lastSeen = val.last_seen_seq ?? 0;\n }\n } catch {}\n const unreadResult = await sqlite.execute({\n sql: `SELECT COUNT(*) as c FROM state WHERE room_id = ? AND scope = '_messages' AND sort_key > ?\n AND (timer_effect IS NULL\n OR (timer_effect = 'delete' AND (timer_expires_at IS NULL OR timer_expires_at > datetime('now'))\n AND (timer_ticks_left IS NULL OR timer_ticks_left > 0))\n OR (timer_effect = 'enable' AND ((timer_expires_at IS NOT NULL AND timer_expires_at <= datetime('now'))\n OR (timer_ticks_left IS NOT NULL AND timer_ticks_left <= 0))))`,\n args: [roomId, lastSeen],\n });\n unreadCount = Number((rows2objects(unreadResult)[0] as any)?.c || 0);\n\n const directedResult = await sqlite.execute({\n sql: `SELECT value FROM state WHERE room_id = ? AND scope = '_messages' AND sort_key > ?`,\n args: [roomId, lastSeen],\n });\n for (const row of rows2objects(directedResult)) {\n try {\n const msg = JSON.parse((row as any).value);\n if (Array.isArray(msg.to) && msg.to.includes(selfAgent)) {\n directedUnread++;\n }\n } catch {}\n }\n }\n\n // ── Actions (wrapped with action meta) ──\n const actionsCtx: Record = {};\n for (const row of stateRows) {\n if (row.scope !== \"_actions\") continue;\n if (!isTimerLive(row)) continue;\n const val = parseValue(row.value);\n\n if (val.enabled) {\n try {\n const checkCtx = {\n state, views: {}, agents,\n messages: { count: 0, unread: 0, directed_unread: 0 },\n actions: {}, self: selfAgent ?? \"\", params: {},\n };\n if (!celEval(val.enabled, checkCtx)) continue;\n } catch { continue; }\n }\n\n const actionData = { enabled: true, if_expr: val.if ?? null };\n const score = computeScore(\n \"_actions\", row.key, row.updated_at, val, agentCtx, roomMeta,\n );\n actionsCtx[row.key] = wrapEntry(\n actionData, \"_actions\", row.key, row.revision ?? 0,\n row.updated_at ?? \"\", roomMeta, score,\n );\n }\n\n // ── Assemble context ──\n const ctx: Record = {\n state,\n views: {} as Record,\n agents,\n messages: {\n count: totalCount,\n unread: unreadCount,\n directed_unread: directedUnread,\n },\n actions: actionsCtx,\n self: selfAgent ?? \"\",\n params: {},\n };\n\n // ── Deferred enabled entries ──\n for (const d of deferredEnabled) {\n try {\n if (celEval(d.enabled_expr, ctx)) {\n const contextScope =\n selfAgent && d.scope === selfAgent && !allScopes\n ? \"self\"\n : d.scope;\n if (!state[contextScope]) state[contextScope] = {};\n const score = computeScore(\n d.scope, d.key, d.updatedAt, d.value, agentCtx, roomMeta,\n );\n state[contextScope][d.key] = wrapEntry(\n d.value, d.scope, d.key, d.revision, d.updatedAt, roomMeta, score,\n );\n }\n } catch {}\n }\n\n // ── Views (wrapped) ──\n const viewEntries = stateRows.filter(\n (r: any) => r.scope === \"_views\" && isTimerLive(r),\n );\n const views = ctx.views as Record;\n\n for (const row of viewEntries) {\n const val = parseValue(row.value);\n if (!val.expr) continue;\n\n if (val.enabled) {\n try {\n if (!celEval(val.enabled, ctx)) continue;\n } catch { continue; }\n }\n\n const viewCtx = await buildViewContext(\n roomId, val.scope ?? \"_shared\", ctx, roomMeta, agentCtx,\n );\n\n try {\n const result = celEval(val.expr, viewCtx);\n const viewValue = typeof result === \"bigint\" ? Number(result) : result;\n\n const score = computeScore(\n \"_views\", row.key, row.updated_at, viewValue, agentCtx, roomMeta,\n );\n views[row.key] = {\n value: viewValue,\n _meta: {\n ...minimalMeta(row.revision ?? 0, row.updated_at ?? \"\", score),\n writer: val.registered_by ?? null,\n via: null,\n seq: null,\n },\n };\n } catch (e: any) {\n views[row.key] = {\n value: { _error: e.message },\n _meta: minimalMeta(row.revision ?? 0, row.updated_at ?? \"\", 0),\n };\n }\n }\n\n // ── Action availability (post-view resolution) ──\n for (const [_id, entry] of Object.entries(actionsCtx)) {\n const ifExpr = entry.value.if_expr;\n if (ifExpr) {\n try {\n entry.value.available = !!celEval(ifExpr, ctx);\n } catch {\n entry.value.available = false;\n }\n } else {\n entry.value.available = true;\n }\n delete entry.value.if_expr;\n }\n\n return ctx;\n}\n\n/**\n * Build a context for view evaluation that includes the registrar's private scope.\n */\nexport async function buildViewContext(\n roomId: string,\n registrarScope: string,\n baseCtx: Record,\n roomMeta?: RoomMeta,\n agentCtx?: AgentContext | null,\n): Promise> {\n if (registrarScope === \"_shared\" || baseCtx.state[registrarScope]) {\n return baseCtx;\n }\n\n const scopeResult = await sqlite.execute({\n sql: `SELECT key, value, revision, updated_at,\n timer_effect, timer_expires_at, timer_ticks_left, enabled_expr\n FROM state WHERE room_id = ? AND scope = ?`,\n args: [roomId, registrarScope],\n });\n const rows = rows2objects(scopeResult) as any[];\n\n const scopeData: Record = {};\n for (const row of rows) {\n if (!isTimerLive(row)) continue;\n if (row.enabled_expr) {\n try {\n if (!celEval(row.enabled_expr, baseCtx)) continue;\n } catch { continue; }\n }\n const value = parseValue(row.value);\n const score = roomMeta\n ? computeScore(\n registrarScope, row.key, row.updated_at, value,\n agentCtx ?? null, roomMeta,\n )\n : 0;\n scopeData[row.key] = roomMeta\n ? wrapEntry(\n value, registrarScope, row.key, row.revision ?? 0,\n row.updated_at ?? \"\", roomMeta, score,\n )\n : { value, _meta: minimalMeta(row.revision ?? 0, row.updated_at ?? \"\") };\n }\n\n return {\n ...baseCtx,\n state: { ...baseCtx.state, [registrarScope]: scopeData },\n };\n}\n\n// ── Public evaluation API ──────────────────────────────────────────────\n\n/**\n * Evaluate a CEL expression against room state.\n */\nexport async function evalCel(\n roomId: string,\n expr: string,\n ctx?: Record,\n): Promise<{ ok: true; value: any } | { ok: false; error: string }> {\n try {\n const context = ctx ?? (await buildContext(roomId));\n const result = celEval(expr, context);\n const value = typeof result === \"bigint\" ? Number(result) : result;\n return { ok: true, value };\n } catch (e: any) {\n return { ok: false, error: e.message || String(e) };\n }\n}\n\n/**\n * Evaluate a CEL expression with additional params context.\n */\nexport function evalCelWithParams(\n expr: string,\n ctx: Record,\n params: Record,\n): { ok: true; value: any } | { ok: false; error: string } {\n try {\n const extendedCtx = { ...ctx, params };\n const result = celEval(expr, extendedCtx);\n const value = typeof result === \"bigint\" ? Number(result) : result;\n return { ok: true, value };\n } catch (e: any) {\n return { ok: false, error: e.message || String(e) };\n }\n}\n","deleted","label",[100],"permalink","https://www.val.town/x/c15r/sync/code/cel.ts","extension","actionData","errors"]