[{"_1":2,"_180":-5,"_181":-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,"_177":178,"_179":-5},"handle","c15r","name","sync","path","meta.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":33,"_170":171,"_172":173,"_174":20,"_175":-5,"_99":176},"89c1805a-2198-11f1-9238-42dde27851f2","fileId","89c18104-2198-11f1-9238-42dde27851f2","parentId","branchId","branchVersion",634,"latest",true,["D",1773707445460],"fileType","script","content","/**\n * meta.ts — Entry metadata computation for wrapped state.\n *\n * v9: Every state entry carries { value, _meta: { ... } }.\n * This module computes _meta from:\n * - The state row itself (revision, updated_at)\n * - A single bulk audit scan (writer, via, seq, velocity, writers, first_at)\n * - Action invocation stats (invocations, last_invoked_at, last_invoked_by)\n * - Contested targets (contested)\n * - Agent-specific salience score\n *\n * Design principle: one SQL query for audit entries, one pass to accumulate\n * per-key stats. Room-level meta is agent-independent. Score is added per-agent.\n *\n * Replaces salience.ts — score becomes one field in _meta, not a separate module.\n */\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport type { DependencySet } from \"./deps.ts\";\nimport { isRelevant } from \"./deps.ts\";\n\n// ── Types ──────────────────────────────────────────────────────────────\n\nexport interface EntryMeta {\n revision: number;\n updated_at: string;\n writer: string | null;\n via: string | null;\n seq: number | null;\n score: number;\n velocity: number;\n writers: string[];\n first_at: string | null;\n elided: boolean;\n}\n\nexport interface ActionMeta extends EntryMeta {\n invocations: number;\n last_invoked_at: string | null;\n last_invoked_by: string | null;\n contested: string[];\n}\n\nexport interface WrappedEntry {\n value: T;\n _meta: EntryMeta | ActionMeta;\n}\n\n// ── Internal accumulators ──────────────────────────────────────────────\n\ninterface WriteEvent {\n agent: string;\n action: string;\n seq: number;\n ts: string;\n}\n\ninterface KeyAccum {\n writes: WriteEvent[];\n earliest_ts: string | null;\n}\n\ninterface ActionInvokeAccum {\n invocations: number;\n last_invoked_at: string | null;\n last_invoked_by: string | null;\n}\n\n// ── Velocity ───────────────────────────────────────────────────────────\n\nconst VELOCITY_HALF_LIFE_MS = 300_000; // 5 minutes\n\n/**\n * Exponential-decay weighted write count.\n * A write just now contributes 1.0, a write 5 min ago contributes 0.5.\n * Dimensionless — higher = more recent write activity.\n */\nfunction computeVelocity(writes: WriteEvent[], now: number): number {\n let sum = 0;\n for (const w of writes) {\n const ts = new Date(w.ts).getTime();\n if (isNaN(ts)) continue;\n const age = now - ts;\n if (age < 0) continue;\n sum += Math.pow(0.5, age / VELOCITY_HALF_LIFE_MS);\n }\n return Math.round(sum * 100) / 100;\n}\n\n// ── Room-level meta (agent-independent) ────────────────────────────────\n\nexport interface RoomMeta {\n keys: Map;\n actions: Map;\n /** Contested write targets: \"scope:key\" → list of competing action IDs */\n contested: Map;\n}\n\n/**\n * Compute room-level metadata from a single bulk audit scan.\n * One query, one pass. Agent-independent — score is added later.\n */\nexport async function computeRoomMeta(roomId: string): Promise {\n const now = Date.now();\n\n // ── Single audit scan ──\n const auditResult = await sqlite.execute({\n sql: `SELECT sort_key, value FROM state\n WHERE room_id = ? AND scope = '_audit'\n ORDER BY sort_key DESC LIMIT 1000`,\n args: [roomId],\n });\n\n const keyAccums = new Map();\n const actionAccums = new Map();\n\n for (const row of auditResult.rows) {\n const seq = Number(row[0]);\n let entry: any;\n try { entry = JSON.parse(row[1] as string); } catch { continue; }\n\n const agent = entry.agent ?? \"\";\n const action = entry.action ?? \"\";\n const ts = entry.ts ?? \"\";\n\n // Track action invocations (only non-builtin successful invokes)\n if ((entry.kind === \"invoke\" || (!entry.kind && entry.action)) && entry.ok !== false) {\n if (action && !entry.builtin) {\n let accum = actionAccums.get(action);\n if (!accum) {\n accum = { invocations: 0, last_invoked_at: null, last_invoked_by: null };\n actionAccums.set(action, accum);\n }\n accum.invocations++;\n // First encountered in DESC order = most recent\n if (!accum.last_invoked_at) {\n accum.last_invoked_at = ts;\n accum.last_invoked_by = agent;\n }\n }\n }\n\n // Track per-key writes\n const writes: Array<{ scope: string; key: string }> = entry.effect?.writes ?? [];\n for (const w of writes) {\n if (!w.scope || !w.key) continue;\n const mk = `${w.scope}:${w.key}`;\n let accum = keyAccums.get(mk);\n if (!accum) {\n accum = { writes: [], earliest_ts: null };\n keyAccums.set(mk, accum);\n }\n accum.writes.push({ agent, action, seq, ts });\n // Last seen in DESC order = earliest known\n accum.earliest_ts = ts;\n }\n }\n\n // ── Compute per-key derived fields ──\n const keys = new Map();\n\n for (const [mk, accum] of keyAccums) {\n const mostRecent = accum.writes[0]; // first in DESC = most recent\n const writerSet = [...new Set(accum.writes.map(w => w.agent))];\n keys.set(mk, {\n writer: mostRecent?.agent ?? null,\n via: mostRecent?.action ?? null,\n seq: mostRecent?.seq ?? null,\n velocity: computeVelocity(accum.writes, now),\n writers: writerSet,\n first_at: accum.earliest_ts,\n });\n }\n\n // ── Contested targets from action definitions ──\n const contested = new Map();\n try {\n const actionsResult = await sqlite.execute({\n sql: `SELECT key, value FROM state WHERE room_id = ? AND scope = '_actions'`,\n args: [roomId],\n });\n const writeTargets = new Map();\n for (const row of actionsResult.rows) {\n const actionId = row[0] as string;\n try {\n const def = JSON.parse(row[1] as string);\n if (!Array.isArray(def.writes)) continue;\n for (const w of def.writes) {\n const scope = w.scope ?? \"_shared\";\n const key = w.key;\n if (!key || key.includes(\"${\")) continue; // skip templated keys\n const target = `${scope}:${key}`;\n if (!writeTargets.has(target)) writeTargets.set(target, []);\n writeTargets.get(target)!.push(actionId);\n }\n } catch {}\n }\n for (const [target, actions] of writeTargets) {\n if (actions.length >= 2) contested.set(target, actions);\n }\n } catch {}\n\n return { keys, actions: actionAccums, contested };\n}\n\n// ── Score computation (agent-specific) ─────────────────────────────────\n\nexport interface ScoreWeights {\n recency: number;\n dependency: number;\n authorship: number;\n directed: number;\n contest: number;\n delta: number;\n}\n\nexport const DEFAULT_WEIGHTS: ScoreWeights = {\n recency: 0.10,\n dependency: 0.30,\n authorship: 0.10,\n directed: 0.20,\n contest: 0.10,\n delta: 0.20,\n};\n\n/** Agent-specific context needed for score computation */\nexport interface AgentContext {\n agentId: string;\n deps: DependencySet;\n lastSeen: string | null;\n registeredActions: Set;\n weights: ScoreWeights;\n}\n\n/**\n * Load the agent context needed for score computation.\n * One function, two queries.\n */\nexport async function loadAgentContext(\n roomId: string,\n agentId: string,\n stateRows: any[],\n): Promise {\n // Agent last_heartbeat from _agents scope (already in stateRows)\n let lastSeen: string | null = null;\n const agentRow = stateRows.find(\n (r: any) => r.scope === \"_agents\" && r.key === agentId,\n );\n if (agentRow) {\n try {\n const val = JSON.parse(agentRow.value);\n lastSeen = val.last_heartbeat ?? null;\n } catch {}\n }\n\n // Agent's registered actions (from stateRows)\n const registeredActions = new Set();\n for (const row of stateRows) {\n if (row.scope !== \"_actions\") continue;\n try {\n const def = JSON.parse(row.value);\n if (def.registered_by === agentId) registeredActions.add(row.key);\n } catch {}\n }\n\n // Agent's view dependencies (from stateRows)\n const deps: DependencySet = [];\n for (const row of stateRows) {\n if (row.scope !== \"_views\") continue;\n try {\n const viewDef = JSON.parse(row.value);\n if (\n viewDef.registered_by === agentId || viewDef.scope === agentId\n ) {\n if (Array.isArray(viewDef.deps)) {\n deps.push(...viewDef.deps);\n }\n }\n } catch {}\n }\n\n // Room-level weight overrides\n let weights = { ...DEFAULT_WEIGHTS };\n const configRow = stateRows.find(\n (r: any) => r.scope === \"_config\" && r.key === \"salience_weights\",\n );\n if (configRow) {\n try {\n const overrides = JSON.parse(configRow.value);\n weights = { ...weights, ...overrides };\n } catch {}\n }\n\n return { agentId, deps, lastSeen, registeredActions, weights };\n}\n\n/**\n * Compute salience score for a single entry.\n * All signals normalized to [0, 1], weighted sum.\n */\nexport function computeScore(\n scope: string,\n key: string,\n updatedAt: string | null,\n value: any,\n agentCtx: AgentContext | null,\n roomMeta: RoomMeta,\n): number {\n if (!agentCtx) return 0.5; // no agent context → neutral score\n\n const w = agentCtx.weights;\n const now = Date.now();\n const mk = `${scope}:${key}`;\n\n // Recency: exponential decay from last update\n let recency = 0;\n if (updatedAt) {\n const age = now - new Date(updatedAt).getTime();\n if (age >= 0) recency = Math.pow(0.5, age / 300_000);\n }\n\n // Dependency: is this key in the agent's view dependency set?\n const dependency = isRelevant(agentCtx.deps, scope, key) ? 1.0 : 0;\n\n // Authorship: did this agent last write this key?\n const km = roomMeta.keys.get(mk);\n const authorship = km?.writer === agentCtx.agentId ? 1.0 : 0;\n\n // Directed: for messages, is this directed at the agent?\n let directed = 0;\n if (scope === \"_messages\" && typeof value === \"object\" && value !== null) {\n if (Array.isArray(value.to)) {\n directed = value.to.includes(agentCtx.agentId) ? 1.0 : 0.1;\n } else {\n directed = 0.3; // broadcast\n }\n }\n\n // Contest: is this key a write target of 2+ actions?\n let contest = 0;\n const contestants = roomMeta.contested.get(mk);\n if (contestants && contestants.length >= 2) {\n contest = contestants.some((id) => agentCtx.registeredActions.has(id))\n ? 1.0\n : 0.5;\n }\n\n // Delta: has this key been updated since the agent's last heartbeat?\n let delta = 0;\n if (updatedAt && agentCtx.lastSeen) {\n const updated = new Date(updatedAt).getTime();\n const last = new Date(agentCtx.lastSeen).getTime();\n if (!isNaN(updated) && !isNaN(last) && updated > last) delta = 1.0;\n }\n\n const score = recency * w.recency +\n dependency * w.dependency +\n authorship * w.authorship +\n directed * w.directed +\n contest * w.contest +\n delta * w.delta;\n\n return Math.round(score * 100) / 100;\n}\n\n// ── Entry wrapping ─────────────────────────────────────────────────────\n\n/**\n * Wrap a state entry with full _meta.\n * Called once per entry during buildContext.\n */\nexport function wrapEntry(\n value: any,\n scope: string,\n key: string,\n revision: number,\n updatedAt: string,\n roomMeta: RoomMeta,\n score: number,\n): WrappedEntry {\n const mk = `${scope}:${key}`;\n const km = roomMeta.keys.get(mk);\n\n const meta: EntryMeta = {\n revision,\n updated_at: updatedAt,\n writer: km?.writer ?? null,\n via: km?.via ?? null,\n seq: km?.seq ?? null,\n score,\n velocity: km?.velocity ?? 0,\n writers: km?.writers ?? [],\n first_at: km?.first_at ?? null,\n elided: false,\n };\n\n // Action-specific meta\n if (scope === \"_actions\") {\n const am = roomMeta.actions.get(key);\n // Contested: other actions that share write targets with this action\n const myContested: string[] = [];\n for (const [_target, actions] of roomMeta.contested) {\n if (actions.includes(key)) {\n for (const a of actions) {\n if (a !== key && !myContested.includes(a)) myContested.push(a);\n }\n }\n }\n\n const actionMeta = meta as ActionMeta;\n actionMeta.invocations = am?.invocations ?? 0;\n actionMeta.last_invoked_at = am?.last_invoked_at ?? null;\n actionMeta.last_invoked_by = am?.last_invoked_by ?? null;\n actionMeta.contested = myContested;\n }\n\n return { value, _meta: meta };\n}\n\n/**\n * Create a minimal _meta for entries with no audit history.\n * Used for newly created entries or entries predating the audit window.\n */\nexport function minimalMeta(\n revision: number,\n updatedAt: string,\n score: number = 0,\n): EntryMeta {\n return {\n revision,\n updated_at: updatedAt,\n writer: null,\n via: null,\n seq: null,\n score,\n velocity: 0,\n writers: [],\n first_at: null,\n elided: false,\n };\n}\n","deleted","label",[100],"permalink","https://www.val.town/x/c15r/sync/code/meta.ts","extension","actionData","errors"]