[{"_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","context.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},"89c4c3e6-2198-11f1-9238-42dde27851f2","fileId","debad81a-1ad9-11f1-b21b-42dde27851f2","parentId","branchId","branchVersion",634,"latest",true,["D",1773707445460],2,"fileType","script","content","/**\n * context.ts — v9 Projection layer.\n *\n * Takes the full wrapped context from buildContext (engine layer) and shapes\n * it for the requesting agent based on salience thresholds.\n *\n * Three tiers:\n * Focus (score >= focus_threshold): full value + full _meta\n * Peripheral (score >= elide_threshold): full value + minimal _meta\n * Elided (score < elide_threshold): value: null + minimal _meta + expand hint\n *\n * Override params:\n * expand — force specific keys to Focus (e.g. [\"_shared.some_key\"])\n * elision — \"none\" to disable elision entirely\n * meta_threshold — override where full _meta kicks in (default: 0.5)\n * focus_threshold — override focus threshold (default: 0.5)\n * elide_threshold — override elide threshold (default: 0.1)\n *\n * Replaces: _salience synthetic view, _contested synthetic view, _context envelope.\n * All metadata now lives in _meta on the relevant entries.\n */\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { json, rows2objects } from \"./utils.ts\";\nimport {\n buildContext,\n celEval,\n evalCel,\n type BuildContextOptions,\n type WrappedEntry,\n type EntryMeta,\n} from \"./cel.ts\";\nimport { isTimerLive } from \"./timers.ts\";\nimport { hasFullReadAccess, touchAgent, type AuthResult } from \"./auth.ts\";\nimport { BUILTIN_ACTIONS, OVERRIDABLE_BUILTINS } from \"./invoke.ts\";\nimport { minimalMeta } from \"./meta.ts\";\n\n// ── ContextRequest ──────────────────────────────────────────────────────\n\nexport interface ContextRequest {\n /** Action detail level */\n depth?: \"lean\" | \"full\" | \"usage\";\n /** Return only these top-level sections */\n only?: string[];\n /** Include actions section (default true) */\n actions?: boolean;\n /** Include messages section (default true) */\n messages?: boolean;\n /** Message seq cursor — only return messages after this seq */\n messagesAfter?: number;\n /** Max messages to return (default 100, max 500) */\n messagesLimit?: number;\n /** Extra state scopes to include (e.g. \"_audit\") */\n include?: string[];\n\n // ── v9 shaping params ──\n\n /** Force specific keys to Focus tier: [\"_shared.key1\", \"_agents.explorer\"] */\n expand?: string[];\n /** Disable elision entirely: \"none\" */\n elision?: \"none\" | \"auto\";\n /** Threshold for full _meta (default 0.5) */\n focusThreshold?: number;\n /** Threshold below which values are elided (default 0.1) */\n elideThreshold?: number;\n}\n\n/** Parse a ContextRequest from URL search params or MCP tool params */\nexport function parseContextRequest(url: URL): ContextRequest {\n const req: ContextRequest = {};\n const depth = url.searchParams.get(\"depth\");\n if (depth === \"lean\" || depth === \"full\" || depth === \"usage\") req.depth = depth;\n const only = url.searchParams.get(\"only\");\n if (only) req.only = only.split(\",\").map((s) => s.trim()).filter(Boolean);\n const actions = url.searchParams.get(\"actions\");\n if (actions === \"false\") req.actions = false;\n const messages = url.searchParams.get(\"messages\");\n if (messages === \"false\") req.messages = false;\n const after = url.searchParams.get(\"messages_after\");\n if (after) req.messagesAfter = parseInt(after);\n const limit = url.searchParams.get(\"messages_limit\");\n if (limit) req.messagesLimit = parseInt(limit);\n const include = url.searchParams.get(\"include\");\n if (include) req.include = include.split(\",\").map((s) => s.trim()).filter(Boolean);\n\n // v9 shaping\n const expand = url.searchParams.get(\"expand\");\n if (expand) req.expand = expand.split(\",\").map((s) => s.trim()).filter(Boolean);\n const elision = url.searchParams.get(\"elision\");\n if (elision === \"none\") req.elision = \"none\";\n const focusThreshold = url.searchParams.get(\"focus_threshold\");\n if (focusThreshold) req.focusThreshold = parseFloat(focusThreshold);\n const elideThreshold = url.searchParams.get(\"elide_threshold\");\n if (elideThreshold) req.elideThreshold = parseFloat(elideThreshold);\n\n return req;\n}\n\n// ── Shaping ─────────────────────────────────────────────────────────────\n\nconst DEFAULT_FOCUS_THRESHOLD = 0.5;\nconst DEFAULT_ELIDE_THRESHOLD = 0.1;\n\n/** Minimal _meta for peripheral/elided tier — strip trajectory/provenance */\nfunction trimMeta(meta: any, elided: boolean, expandHint?: string): any {\n const trimmed: any = {\n score: meta.score,\n revision: meta.revision,\n updated_at: meta.updated_at,\n elided,\n };\n if (elided && expandHint) {\n trimmed.expand = expandHint;\n }\n return trimmed;\n}\n\n/** Check if a scope.key is in the expand list */\nfunction isExpanded(scope: string, key: string, expandSet: Set): boolean {\n return (\n expandSet.has(`${scope}.${key}`) ||\n expandSet.has(`${scope}.*`) ||\n expandSet.has(\"*\")\n );\n}\n\n/**\n * Shape a scope's entries by salience threshold.\n *\n * Focus: full value + full _meta\n * Peripheral: full value + trimmed _meta (score, revision, updated_at)\n * Elided: value: null + trimmed _meta + expand hint\n */\nfunction shapeScope(\n scope: string,\n entries: Record,\n focusThreshold: number,\n elideThreshold: number,\n expandSet: Set,\n noElision: boolean,\n): Record {\n const shaped: Record = {};\n\n for (const [key, entry] of Object.entries(entries)) {\n const score = entry._meta?.score ?? 0;\n const forceExpand = isExpanded(scope, key, expandSet);\n\n if (forceExpand || noElision || score >= focusThreshold) {\n // Focus tier: full value + full _meta\n shaped[key] = entry;\n } else if (score >= elideThreshold) {\n // Peripheral tier: full value + trimmed _meta\n shaped[key] = {\n value: entry.value,\n _meta: trimMeta(entry._meta, false),\n };\n } else {\n // Elided tier: null value + minimal _meta + expand hint\n shaped[key] = {\n value: null,\n _meta: trimMeta(\n entry._meta,\n true,\n `?expand=${scope}.${key}`,\n ),\n };\n }\n }\n\n return shaped;\n}\n\n// ── buildExpandedContext ─────────────────────────────────────────────────\n\n/**\n * Build the agent-facing context response.\n *\n * v9: Returns wrapped { value, _meta } entries shaped by salience threshold.\n * All metadata (salience, provenance, trajectory, contested) lives in _meta.\n * No synthetic views, no _context envelope.\n */\nexport async function buildExpandedContext(\n roomId: string,\n auth: AuthResult,\n req: ContextRequest = {},\n): Promise> {\n const depth = req.depth ?? \"lean\";\n const includeActions = req.actions !== false;\n const includeMessages = req.messages !== false;\n const includedScopes = req.include ?? [];\n\n // Shaping params\n const focusThreshold = req.focusThreshold ?? DEFAULT_FOCUS_THRESHOLD;\n const elideThreshold = req.elideThreshold ?? DEFAULT_ELIDE_THRESHOLD;\n const noElision = req.elision === \"none\";\n const expandSet = new Set(req.expand ?? []);\n\n // ── Engine layer: full wrapped context ──\n const ctx = await buildContext(roomId, {\n selfAgent: auth.agentId ?? undefined,\n allScopes: hasFullReadAccess(auth),\n });\n\n // ── Shape state scopes ──\n const stateOut: Record = {};\n for (const [scope, entries] of Object.entries(ctx.state as Record>)) {\n // Strip _audit and _messages unless opted in\n if (scope === \"_audit\" && !includedScopes.includes(\"_audit\")) continue;\n if (scope === \"_messages\" && !includedScopes.includes(\"_messages\")) continue;\n // Skip system internals\n if (scope === \"_actions\" || scope === \"_views\" || scope === \"_agents\" || scope === \"_config\" || scope === \"_help\") continue;\n\n stateOut[scope] = shapeScope(\n scope, entries, focusThreshold, elideThreshold, expandSet, noElision,\n );\n }\n\n // ── Shape agents ──\n const agentsOut: Record = {};\n for (const [id, entry] of Object.entries(ctx.agents as Record)) {\n // Agents are always focus tier (important for coordination)\n agentsOut[id] = entry;\n }\n\n // ── Shape views ──\n const viewsOut: Record = {};\n for (const [id, entry] of Object.entries(ctx.views as Record)) {\n const score = entry._meta?.score ?? 0;\n if (noElision || score >= elideThreshold || isExpanded(\"_views\", id, expandSet)) {\n viewsOut[id] = score >= focusThreshold || noElision\n ? entry\n : { value: entry.value, _meta: trimMeta(entry._meta, false) };\n } else {\n viewsOut[id] = {\n value: null,\n _meta: trimMeta(entry._meta, true, `?expand=_views.${id}`),\n };\n }\n }\n\n // ── Actions ──\n let actionsOut: Record | undefined;\n\n if (includeActions) {\n actionsOut = {};\n\n // Custom actions from engine context (already wrapped with action _meta)\n for (const [id, entry] of Object.entries(ctx.actions as Record)) {\n const actionValue = entry.value;\n const actionMeta = entry._meta as any;\n\n const shaped: any = {\n value: {\n available: actionValue.available ?? true,\n description: null as string | null,\n },\n _meta: actionMeta,\n };\n\n // Load full definition for description and depth-dependent fields\n try {\n const defResult = await sqlite.execute({\n sql: `SELECT value FROM state WHERE room_id = ? AND scope = '_actions' AND key = ?`,\n args: [roomId, id],\n });\n if (defResult.rows.length > 0) {\n const def = JSON.parse(defResult.rows[0][0] as string);\n shaped.value.description = def.description ?? null;\n\n if (depth === \"full\" || depth === \"usage\") {\n shaped.value.enabled = true;\n if (def.params) shaped.value.params = def.params;\n if (def.writes?.length > 0) shaped.value.writes = def.writes;\n if (def.if) shaped.value.if = def.if;\n if (def.scope && def.scope !== \"_shared\") shaped.value.scope = def.scope;\n }\n }\n } catch {}\n\n actionsOut[id] = shaped;\n }\n\n // Built-in actions (not in _actions scope — synthesize wrapped entries)\n for (const [id, def] of Object.entries(BUILTIN_ACTIONS)) {\n if (OVERRIDABLE_BUILTINS.has(id) && actionsOut[id]) continue;\n\n const builtinValue: any = {\n available: true,\n builtin: true,\n description: def.description,\n };\n if (depth === \"full\" || depth === \"usage\") {\n builtinValue.enabled = true;\n builtinValue.params = def.params ?? null;\n }\n\n actionsOut[id] = {\n value: builtinValue,\n _meta: {\n ...minimalMeta(0, \"\", 0),\n // Builtins have no audit trail — minimal meta\n invocations: 0,\n last_invoked_at: null,\n last_invoked_by: null,\n contested: [],\n },\n };\n }\n }\n\n // ── Messages ──\n let messagesOut: any;\n let sectionElided: string[] = [];\n\n if (includeMessages) {\n const messagesLimit = Math.min(req.messagesLimit ?? 100, 500);\n let msgSql = `SELECT scope, key, sort_key, value, revision, updated_at,\n timer_json, timer_expires_at, timer_ticks_left, timer_tick_on,\n timer_effect, timer_started_at, enabled_expr\n FROM state WHERE room_id = ? AND scope = '_messages'`;\n const msgArgs: any[] = [roomId];\n if (req.messagesAfter) {\n msgSql += ` AND sort_key > ?`;\n msgArgs.push(req.messagesAfter);\n }\n msgSql += ` ORDER BY sort_key DESC LIMIT ?`;\n msgArgs.push(messagesLimit);\n const msgResult = await sqlite.execute({ sql: msgSql, args: msgArgs });\n let msgRows = rows2objects(msgResult).filter((r: any) => isTimerLive(r));\n msgRows.reverse();\n\n const recentMessages = msgRows.map((r: any) => {\n let parsed: any = {};\n try {\n parsed = JSON.parse(r.value);\n } catch {\n parsed = { body: r.value };\n }\n return { seq: r.sort_key, ...parsed };\n });\n\n // Update last_seen_seq\n if (auth.agentId && recentMessages.length > 0) {\n const maxSeq = Math.max(...recentMessages.map((m: any) => m.seq ?? 0));\n if (maxSeq > 0) {\n sqlite.execute({\n sql: `UPDATE state SET\n value = json_set(value, '$.last_seen_seq', ?),\n revision = revision + 1, updated_at = datetime('now')\n WHERE room_id = ? AND scope = '_agents' AND key = ?`,\n args: [maxSeq, roomId, auth.agentId],\n }).catch(() => {});\n }\n }\n\n // Count total for elision detection\n const totalMsgResult = await sqlite.execute({\n sql: `SELECT COUNT(*) as cnt FROM state WHERE room_id = ? AND scope = '_messages'`,\n args: [roomId],\n });\n const totalMessages = Number(rows2objects(totalMsgResult)[0]?.cnt ?? 0);\n const oldestSeq = recentMessages.length > 0 ? (recentMessages[0].seq ?? 0) : 0;\n\n messagesOut = {\n count: ctx.messages.count,\n unread: ctx.messages.unread,\n directed_unread: ctx.messages.directed_unread,\n recent: recentMessages,\n };\n\n if (totalMessages > messagesLimit) {\n messagesOut._meta = {\n total: totalMessages,\n returned: recentMessages.length,\n elided: true,\n expand: `?messages_after=0&messages_limit=${Math.min(totalMessages, 500)}`,\n };\n }\n } else {\n sectionElided.push(\"messages\");\n }\n\n if (!includeActions) {\n sectionElided.push(\"actions\");\n }\n\n // ── Assemble response ──\n let result: Record = {\n state: stateOut,\n views: viewsOut,\n agents: agentsOut,\n ...(actionsOut !== undefined ? { actions: actionsOut } : {}),\n ...(messagesOut !== undefined ? { messages: messagesOut } : {}),\n self: ctx.self,\n };\n\n // ── Apply `only` filter ──\n if (req.only && req.only.length > 0) {\n const filtered: Record = {};\n for (const s of req.only) {\n if (s in result) filtered[s] = result[s];\n if (s.startsWith(\"state.\")) {\n const scope = s.slice(6);\n if (!filtered.state) filtered.state = {};\n if (ctx.state[scope]) {\n filtered.state[scope] = shapeScope(\n scope, ctx.state[scope], focusThreshold, elideThreshold, expandSet, noElision,\n );\n }\n }\n }\n if (result.self) filtered.self = result.self;\n for (const key of Object.keys(result)) {\n if (!(key in filtered) && key !== \"self\") sectionElided.push(key);\n }\n result = filtered;\n }\n\n // ── Shaping summary ──\n // Minimal envelope — just enough for the agent to understand what it got\n const shapingSummary: any = {\n focus_threshold: focusThreshold,\n elide_threshold: elideThreshold,\n elision: noElision ? \"none\" : \"auto\",\n };\n\n // Count shaped entries\n let focusCount = 0;\n let peripheralCount = 0;\n let elidedCount = 0;\n for (const scope of Object.values(stateOut)) {\n for (const entry of Object.values(scope as Record)) {\n const e = entry as any;\n if (e?._meta?.elided) elidedCount++;\n else if (e?._meta?.score !== undefined && !e?._meta?.writers) peripheralCount++;\n else focusCount++;\n }\n }\n shapingSummary.state_entries = {\n focus: focusCount,\n peripheral: peripheralCount,\n elided: elidedCount,\n total: focusCount + peripheralCount + elidedCount,\n };\n\n if (sectionElided.length > 0) {\n shapingSummary.sections_elided = sectionElided;\n }\n\n result._shaping = shapingSummary;\n\n return result;\n}\n\n// ── CEL eval endpoint ───────────────────────────────────────────────────\n\nexport async function evalExpression(\n roomId: string,\n body: any,\n auth: AuthResult,\n) {\n const expr = body.expr;\n if (!expr || typeof expr !== \"string\") {\n return json({ error: \"expr string is required\" }, 400);\n }\n touchAgent(roomId, auth.agentId);\n const ctx = await buildContext(roomId, {\n selfAgent: auth.agentId ?? undefined,\n });\n const result = await evalCel(roomId, expr, ctx);\n if (!result.ok) {\n return json(\n { error: \"cel_error\", expression: expr, detail: result.error },\n 400,\n );\n }\n return json({ expression: expr, value: result.value });\n}\n","deleted","label",[100],"permalink","https://www.val.town/x/c15r/sync/code/context.ts","extension","actionData","errors"]