[{"_1":2,"_184":-5,"_185":-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,"_181":182,"_183":-5},"handle","c15r","name","sync","path","mcp/tools.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":161,"_162":163,"_164":165,"_166":148,"_167":168,"_169":170,"_105":171,"_146":172,"_173":174,"_175":176,"_177":20,"_178":-5,"_99":179},"b1649e7e-21e0-11f1-97dd-42dde27851f2","tools.ts","fileId","9f51a29a-18a3-11f1-b05e-42dde27851f2","parentId","019cbe80-ea89-7462-9a69-79fbc30a3494","branchId","branchVersion",638,"latest",true,["D",1773738435759],11,"fileType","script","content","/**\n * tools.ts — MCP tool definitions for sync-mcp\n *\n * v3: Agency & Identity model.\n * - New ToolContext with resolveForRoom (session-aware, embodiment-aware)\n * - Observe/embody split: read_context is view-level by default, mutations require embodiment\n * - New tools: sync_lobby, sync_embody, sync_disembody, sync_restrict_scope, sync_revoke_access\n * - Context decoration: _session block + _current/_switchable agent annotations\n */\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { rows2objects } from \"../utils.ts\";\nimport {\n buildExpandedContext,\n createRoom,\n joinRoom,\n invokeAction,\n invokeBuiltinAction,\n registerAction,\n registerView,\n deleteAction,\n deleteView,\n evalExpression,\n listRooms,\n insertAgentDirect,\n waitForCondition,\n type ContextRequest,\n} from \"../main.ts\";\n\nimport {\n resolveAuthFromToken,\n resolveAgentAuth,\n generateToken,\n hashToken,\n type AuthResult,\n} from \"../auth.ts\";\n\nimport { releaseAgent, fetchRoomRoles } from \"../agents.ts\";\nimport { migrate } from \"../schema.ts\";\n\nimport * as db from \"./db.ts\";\nimport {\n type ParsedScope,\n parseScope,\n serializeScope,\n checkRoomInScope,\n} from \"./scope.ts\";\n\nimport {\n type ToolContext,\n type ToolDef,\n tokenToAuth,\n resolveForTool,\n unwrap,\n withResponseEscalation,\n decorateContextWithSession,\n} from \"./tool-context.ts\";\n\n// Re-export for mcp.ts\nexport type { ToolContext, ToolDef };\n\n// ─── Ensure schema on first tool call ────────────────────────────\n\nlet migrated = false;\nasync function ensureMigrated() {\n if (!migrated) { await migrate(); migrated = true; }\n}\n\n// ─── Tool Definitions ────────────────────────────────────────────\n\nexport const TOOLS: ToolDef[] = [\n // ═══════════════════════════════════════════════════════════════\n // NEW: Agency & Identity tools\n // ═══════════════════════════════════════════════════════════════\n\n {\n name: \"sync_lobby\",\n title: \"Lobby\",\n description: `Overview of your rooms, agents, and roles. The starting point.\n\nReturns rooms you have access to, with agents, roles, access levels,\nand current embodiments. Agents are annotated with _current and _switchable.\n\nThis is observation — no agent presence is created.`,\n inputSchema: { type: \"object\", properties: {} },\n annotations: { readOnlyHint: true, destructiveHint: false, idempotentHint: true, openWorldHint: false },\n async handler(_params, ctx) {\n if (!ctx.userId) throw new Error(\"OAuth required\");\n await ensureMigrated();\n\n const userRooms = await db.listUserRooms(ctx.userId);\n const embodiments = ctx.sessionHash\n ? await db.listEmbodiments(ctx.sessionHash) : [];\n\n const rooms = [];\n for (const ur of userRooms) {\n // Check scope allows this room — wildcard grants access to all\n if (ctx.scope && ctx.scope.rooms.size > 0 && !ctx.scope.wildcardRooms) {\n if (!ctx.scope.rooms.has(ur.roomId)) continue;\n }\n\n // Fetch room agents\n const agentsResult = await sqlite.execute({\n sql: `SELECT id, name, role, status, last_heartbeat, waiting_on\n FROM agents WHERE room_id = ? ORDER BY joined_at`,\n args: [ur.roomId],\n });\n const agents = rows2objects(agentsResult);\n\n // Fetch role definitions\n const roles = await fetchRoomRoles(ur.roomId);\n\n const currentEmbodiment = embodiments.find(e => e.roomId === ur.roomId);\n const canEmbody = ur.access !== \"observer\";\n\n const switchableAgents = canEmbody ? agents.filter((a: any) => {\n if (a.id === currentEmbodiment?.agentId) return false;\n return a.status === \"idle\" || a.status === \"done\";\n }).map((a: any) => a.id as string) : [];\n\n const unfilledRoles = Object.entries(roles)\n .filter(([_, def]) => !def.filled_by)\n .map(([id]) => id)\n .filter(id => !switchableAgents.includes(id));\n\n const scopeLevel = ctx.scope?.rooms.get(ur.roomId);\n\n rooms.push({\n id: ur.roomId,\n access: ur.access,\n label: ur.label,\n scope_level: scopeLevel\n ? (scopeLevel.level === \"role\" ? `role:${scopeLevel.role}` : scopeLevel.level)\n : \"full\",\n roles,\n agents: agents.map((a: any) => ({\n id: a.id, name: a.name, role: a.role, status: a.status,\n last_heartbeat: a.last_heartbeat, waiting_on: a.waiting_on,\n _current: currentEmbodiment?.agentId === a.id,\n _switchable: canEmbody && (a.status === \"idle\" || a.status === \"done\") && a.id !== currentEmbodiment?.agentId,\n })),\n unfilled_roles: unfilledRoles,\n embodied_as: currentEmbodiment?.agentId ?? null,\n });\n }\n\n return {\n user: (await db.getUserById(ctx.userId))?.username ?? ctx.userId,\n client: ctx.clientId,\n rooms,\n can_create_rooms: ctx.scope?.createRooms ?? true,\n active_embodiments: embodiments,\n };\n },\n },\n\n {\n name: \"sync_embody\",\n title: \"Embody Agent\",\n description: `Commit to an agent in a room. Creates, takes over, or switches agents.\n\nSwitching: if already embodied in this room, the old agent is cleanly\nreleased (set idle, filled_by cleared) before the new one activates.\nAlways returns fresh context as the new agent.\n\nOne session can embody agents in multiple rooms simultaneously.\nOne agent per room per session — call sync_embody again to switch.\n\nArgs:\n - room (string, required): Room ID.\n - agent (string, optional): Existing agent ID to take over.\n - role (string, optional): Role to fill (creates/takes agent with role ID).\n - name (string, optional): Display name for new agent.\n - state (object, optional): Initial state for new agent.\n\nReturns: Full context with self set to embodied agent, plus _session metadata.`,\n inputSchema: {\n type: \"object\",\n properties: {\n room: { type: \"string\", description: \"Room ID\" },\n agent: { type: \"string\", description: \"Existing agent ID to take over\" },\n role: { type: \"string\", description: \"Role to fill\" },\n name: { type: \"string\", description: \"Display name for new agent\" },\n state: { type: \"object\", description: \"Initial state for new agent\" },\n },\n required: [\"room\"],\n },\n annotations: { readOnlyHint: false, destructiveHint: false, idempotentHint: false, openWorldHint: false },\n async handler(params, ctx) {\n if (!ctx.userId || !ctx.sessionHash) throw new Error(\"OAuth required\");\n await ensureMigrated();\n\n const roomId = params.room as string;\n\n // 1. Scope check\n const requiredLevel = params.role ? \"embody_role\" as const : \"embody\" as const;\n const scopeCheck = checkRoomInScope(ctx.scope!, roomId, requiredLevel, params.role as string);\n if (!scopeCheck.allowed) throw new Error(`Scope denied: ${scopeCheck.reason}`);\n\n // 2. User-room access check\n const userRoom = await db.getUserRoom(ctx.userId, roomId);\n if (!userRoom) throw new Error(`No access to room ${roomId}. Use sync_lobby to see your rooms.`);\n if (userRoom.access === \"observer\") throw new Error(\"Observer access cannot embody agents\");\n\n // 3. Grants from access level\n const grants = (userRoom.access === \"owner\" || userRoom.access === \"collaborator\")\n ? [\"_shared\"] : [];\n\n // 4. Clean transition: release old agent if switching within this room\n const previousAgentId = await db.getEmbodiment(ctx.sessionHash, roomId);\n if (previousAgentId) {\n await releaseAgent(roomId, previousAgentId);\n }\n\n // 5. Determine agent ID\n let agentId: string;\n let isNewAgent = false;\n\n if (params.role) {\n agentId = params.role as string;\n // Verify role exists\n const roleState = await sqlite.execute({\n sql: `SELECT value FROM state WHERE room_id = ? AND scope = '_shared' AND key = ?`,\n args: [roomId, `roles.${agentId}`],\n });\n if (roleState.rows.length === 0) throw new Error(`Role \"${agentId}\" not defined in this room`);\n } else if (params.agent) {\n agentId = params.agent as string;\n const existing = await sqlite.execute({\n sql: `SELECT id FROM agents WHERE id = ? AND room_id = ?`,\n args: [agentId, roomId],\n });\n if (existing.rows.length === 0) throw new Error(`Agent \"${agentId}\" not found in room ${roomId}`);\n } else {\n // New agent — derive ID from user + client\n const user = await db.getUserById(ctx.userId);\n const username = user?.username ?? ctx.userId;\n const client = await db.getOAuthClient(ctx.clientId!);\n const clientSlug = (client?.clientName ?? \"mcp\")\n .toLowerCase().replace(/[^a-z0-9]/g, \"-\").replace(/-+/g, \"-\");\n agentId = `${username}:${clientSlug}`;\n isNewAgent = true;\n }\n\n // 6. Create or re-activate agent\n const existingAgent = await sqlite.execute({\n sql: `SELECT id FROM agents WHERE id = ? AND room_id = ?`,\n args: [agentId, roomId],\n });\n\n if (existingAgent.rows.length === 0 || isNewAgent) {\n const user = await db.getUserById(ctx.userId);\n await insertAgentDirect(roomId, {\n id: agentId,\n name: (params.name as string) ?? user?.username ?? \"agent\",\n role: params.role ? \"role\" : \"mcp-client\",\n grants,\n state: params.state as Record | undefined,\n });\n } else {\n // Re-activate: rotate token, reset status, reset grants\n const newToken = generateToken(\"as\");\n const newHash = await hashToken(newToken);\n await sqlite.execute({\n sql: `UPDATE agents SET token_hash = ?, status = 'active',\n last_heartbeat = datetime('now'), waiting_on = NULL, grants = ?\n WHERE id = ? AND room_id = ?`,\n args: [newHash, JSON.stringify(grants), agentId, roomId],\n });\n }\n\n // 7. Record embodiment\n await db.setEmbodiment(ctx.sessionHash, roomId, agentId);\n\n // 8. Update role filled_by if applicable\n if (params.role) {\n await sqlite.execute({\n sql: `UPDATE state SET\n value = json_set(value, '$.filled_by', json(?)),\n revision = revision + 1, updated_at = datetime('now')\n WHERE room_id = ? AND scope = '_shared' AND key = ?`,\n args: [JSON.stringify(agentId), roomId, `roles.${params.role}`],\n });\n }\n\n // 9. Return fresh context as the new agent\n const auth = await resolveAgentAuth(roomId, agentId);\n if (!auth) throw new Error(\"Failed to resolve agent auth after creation\");\n const context = await buildExpandedContext(roomId, auth, { depth: \"lean\" });\n\n // 10. Decorate with _session\n return decorateContextWithSession(context, ctx, roomId, agentId);\n },\n },\n\n {\n name: \"sync_disembody\",\n title: \"Disembody\",\n description: `Release an agent in a room. Agent persists as idle; you stop driving it.\n\nArgs:\n - room (string, required): Room to disembody from.\n\nReturns: Confirmation with disembodied agent ID.`,\n inputSchema: {\n type: \"object\",\n properties: {\n room: { type: \"string\", description: \"Room to disembody from\" },\n },\n required: [\"room\"],\n },\n annotations: { readOnlyHint: false, destructiveHint: false, idempotentHint: true, openWorldHint: false },\n async handler(params, ctx) {\n if (!ctx.sessionHash) throw new Error(\"OAuth required\");\n await ensureMigrated();\n const roomId = params.room as string;\n\n const agentId = await db.getEmbodiment(ctx.sessionHash, roomId);\n if (!agentId) throw new Error(`Not embodied in room ${roomId}`);\n\n // Clean transition\n await releaseAgent(roomId, agentId);\n\n await db.removeEmbodiment(ctx.sessionHash, roomId);\n return { ok: true, disembodied: agentId, room: roomId };\n },\n },\n\n {\n name: \"sync_restrict_scope\",\n title: \"Restrict Scope\",\n description: `Narrow your session's effective scope for a room.\n\nArgs:\n - room (string, required): Room ID.\n - level (string, required): \"observe\" or \"role\".\n - role (string, optional): Required when level is \"role\".`,\n inputSchema: {\n type: \"object\",\n properties: {\n room: { type: \"string\" },\n level: { type: \"string\", enum: [\"observe\", \"role\"] },\n role: { type: \"string\" },\n },\n required: [\"room\", \"level\"],\n },\n annotations: { readOnlyHint: false, destructiveHint: false, idempotentHint: true, openWorldHint: false },\n async handler(params, ctx) {\n if (!ctx.sessionHash || !ctx.scope) throw new Error(\"OAuth required\");\n const roomId = params.room as string;\n const level = params.level as string;\n const role = params.role as string | undefined;\n\n const newScope: ParsedScope = { rooms: new Map(ctx.scope.rooms), createRooms: ctx.scope.createRooms };\n if (level === \"observe\") {\n newScope.rooms.set(roomId, { level: \"observe\" });\n // Disembody if currently embodied\n const agentId = await db.getEmbodiment(ctx.sessionHash, roomId);\n if (agentId) {\n await releaseAgent(roomId, agentId);\n await db.removeEmbodiment(ctx.sessionHash, roomId);\n }\n } else if (level === \"role\") {\n if (!role) throw new Error(\"role parameter required when level is 'role'\");\n newScope.rooms.set(roomId, { level: \"role\", role });\n }\n await db.updateSessionScope(ctx.sessionHash, serializeScope(newScope));\n return { ok: true, room: roomId, level, role };\n },\n },\n\n {\n name: \"sync_revoke_access\",\n title: \"Revoke Room Access\",\n description: `Remove a room from your session's effective scope.\n\nArgs:\n - room (string, required): Room to remove.`,\n inputSchema: {\n type: \"object\",\n properties: { room: { type: \"string\" } },\n required: [\"room\"],\n },\n annotations: { readOnlyHint: false, destructiveHint: true, idempotentHint: true, openWorldHint: false },\n async handler(params, ctx) {\n if (!ctx.sessionHash || !ctx.scope) throw new Error(\"OAuth required\");\n const roomId = params.room as string;\n const agentId = await db.getEmbodiment(ctx.sessionHash, roomId);\n if (agentId) {\n await releaseAgent(roomId, agentId);\n await db.removeEmbodiment(ctx.sessionHash, roomId);\n }\n const newScope: ParsedScope = { rooms: new Map(ctx.scope.rooms), createRooms: ctx.scope.createRooms };\n newScope.rooms.delete(roomId);\n await db.updateSessionScope(ctx.sessionHash, serializeScope(newScope));\n return { ok: true, revoked: roomId };\n },\n },\n\n // ═══════════════════════════════════════════════════════════════\n // Room lifecycle\n // ═══════════════════════════════════════════════════════════════\n\n {\n name: \"sync_create_room\",\n title: \"Create Room\",\n description: `Create a new sync collaboration room. Returns the room ID, admin token, and view token.\n\nIf authenticated via OAuth, the room is registered in your user-rooms as owner\nand added to your session scope.\n\nArgs:\n - id (string, optional): Custom room ID. Auto-generated if omitted.\n - meta (object, optional): Arbitrary metadata for the room.\n - label (string, optional): Label for this room.\n - set_default (boolean, optional): Make this the default room.\n\nReturns: { id, token, view_token, created_at }`,\n inputSchema: {\n type: \"object\",\n properties: {\n id: { type: \"string\", description: \"Custom room ID (auto-generated if omitted)\" },\n meta: { type: \"object\", description: \"Room metadata (any JSON)\" },\n label: { type: \"string\", description: \"Label for this room\" },\n set_default: { type: \"boolean\", description: \"Make this the default room\" },\n },\n },\n annotations: { readOnlyHint: false, destructiveHint: false, idempotentHint: false, openWorldHint: false },\n async handler(params, ctx) {\n await ensureMigrated();\n const body: Record = {};\n if (params.id) body.id = params.id;\n if (params.meta) body.meta = params.meta;\n const result = await unwrap(await createRoom(body)) as Record;\n\n // v7: rooms.ts handles user_rooms linkage when auth has userId.\n // No vault auto-store needed.\n if (ctx.userId && result.id) {\n await db.upsertUserRoom(\n ctx.userId, result.id as string, \"owner\",\n (params.label as string) ?? `Room ${result.id}`,\n params.set_default as boolean ?? false,\n );\n // Widen session scope\n if (ctx.sessionHash && ctx.scope) {\n const newScope: ParsedScope = { rooms: new Map(ctx.scope.rooms), createRooms: ctx.scope.createRooms, wildcardRooms: ctx.scope.wildcardRooms };\n newScope.rooms.set(result.id as string, { level: \"full\" });\n await db.updateSessionScope(ctx.sessionHash, serializeScope(newScope));\n }\n }\n return result;\n },\n },\n\n {\n name: \"sync_list_rooms\",\n title: \"List Rooms\",\n description: `List rooms accessible with the given token. If authenticated, uses vault token.\nPrefer sync_lobby for a richer overview with agents and roles.\n\nArgs:\n - token (string, optional): Auth token. Optional if authenticated.\n\nReturns: Array of room objects.`,\n inputSchema: {\n type: \"object\",\n properties: {\n token: { type: \"string\", description: \"Auth token (room_xxx, view_xxx, or as_xxx). Optional if authenticated.\" },\n },\n },\n annotations: { readOnlyHint: true, destructiveHint: false, idempotentHint: true, openWorldHint: false },\n async handler(params, ctx) {\n await ensureMigrated();\n if (!ctx.userId) throw new Error(\"Authentication required. Use sync_lobby for a richer view.\");\n // v7: Use user_rooms as source of truth\n const userRooms = await db.listUserRooms(ctx.userId);\n if (userRooms.length === 0) return [];\n const roomIds = userRooms.map(ur => ur.roomId);\n const placeholders = roomIds.map(() => \"?\").join(\",\");\n const result = await sqlite.execute({\n sql: `SELECT id, created_at, meta FROM rooms WHERE id IN (${placeholders}) ORDER BY created_at DESC`,\n args: roomIds,\n });\n return rows2objects(result);\n },\n },\n\n {\n name: \"sync_join_room\",\n title: \"Join Room\",\n description: `Join a sync room as an agent (low-level). Returns an agent token (as_xxx).\nPrefer sync_embody for the agency-identity flow.\n\nArgs: room, token (optional), id, name, role, state, public_keys, views.\n\nReturns: Agent object with { id, token, room_id, ... }`,\n inputSchema: {\n type: \"object\",\n properties: {\n room: { type: \"string\" },\n token: { type: \"string\" },\n id: { type: \"string\", description: \"Agent ID\" },\n name: { type: \"string\", description: \"Display name\" },\n role: { type: \"string\", description: \"Agent role\" },\n state: { type: \"object\", description: \"Initial private state\" },\n public_keys: { type: \"array\", items: { type: \"string\" }, description: \"State keys to auto-expose\" },\n views: { type: \"array\", items: { type: \"object\" }, description: \"Views to pre-register\" },\n },\n },\n annotations: { readOnlyHint: false, destructiveHint: false, idempotentHint: false, openWorldHint: false },\n async handler(params, ctx) {\n await ensureMigrated();\n const resolved = await resolveForTool(ctx, params);\n const body: Record = {};\n for (const key of [\"id\", \"name\", \"role\", \"state\", \"public_keys\", \"views\"]) {\n if (params[key] !== undefined) body[key] = params[key];\n }\n const result = await withResponseEscalation(ctx, resolved.room, resolved.auth, async (auth) => {\n const req = new Request(\"http://internal/rooms/\" + resolved.room + \"/agents\", {\n headers: auth.kind === \"room\"\n ? { Authorization: `Bearer room_placeholder` }\n : { Authorization: `Bearer ${resolved.token}` },\n });\n return joinRoom(resolved.room, body, req);\n }) as Record;\n\n // v7: no vault auto-store. Agent tokens are returned to caller.\n return result;\n },\n },\n\n // ═══════════════════════════════════════════════════════════════\n // Core rhythm: read → act\n // ═══════════════════════════════════════════════════════════════\n\n {\n name: \"sync_read_context\",\n title: \"Read Context\",\n description: `THE primary read operation. Returns the room context with wrapped entries.\n\nEvery entry is { value, _meta: { score, revision, writer, via, velocity, ... } }.\nEntries are shaped by salience: high-score entries get full value + full _meta,\nlow-score entries are elided (value: null, _meta.elided: true, _meta.expand: \"...\").\n\nUse .value to access stored data, ._meta for provenance/trajectory/salience.\nDomain helpers: salient(), elided(), written_by(), focus(), keys(), entries().\n\nIf embodied: reads as agent (full scope, heartbeat). If not: observer (view-level).\n\nArgs:\n - room (string, required): Room ID.\n - token (string, optional): Auth token (legacy — prefer OAuth + embodiment).\n - depth: \"lean\" | \"full\" | \"usage\" — action detail level.\n - expand: comma-separated keys to force into Focus tier (e.g. \"_shared.key1\").\n - elision: \"none\" to disable elision entirely (return everything).\n - focus_threshold: score above which entries get full _meta (default: 0.5).\n - elide_threshold: score below which values are null (default: 0.1).\n - only, actions, messages, messages_after, messages_limit, include.\n\nReturns: { state, views, agents, actions, messages, self, _shaping }`,\n inputSchema: {\n type: \"object\",\n properties: {\n room: { type: \"string\", description: \"Room ID\" },\n token: { type: \"string\", description: \"Auth token (legacy)\" },\n depth: { type: \"string\", enum: [\"lean\", \"full\", \"usage\"] },\n only: { type: \"string\" },\n actions: { type: \"boolean\" },\n messages: { type: \"boolean\" },\n messages_after: { type: \"number\" },\n messages_limit: { type: \"number\" },\n include: { type: \"string\" },\n expand: { type: \"string\", description: \"Comma-separated keys to force into Focus tier\" },\n elision: { type: \"string\", enum: [\"none\", \"auto\"], description: \"Set to 'none' to disable elision\" },\n focus_threshold: { type: \"number\", description: \"Score threshold for full _meta (default: 0.5)\" },\n elide_threshold: { type: \"number\", description: \"Score threshold below which values are elided (default: 0.1)\" },\n },\n required: [\"room\"],\n },\n annotations: { readOnlyHint: true, destructiveHint: false, idempotentHint: true, openWorldHint: false },\n async handler(params, ctx) {\n await ensureMigrated();\n const roomId = params.room as string;\n\n // Build ContextRequest with v9 shaping params\n const ctxReq: ContextRequest = {};\n if (params.depth) ctxReq.depth = params.depth as \"lean\" | \"full\" | \"usage\";\n if (params.only) ctxReq.only = (params.only as string).split(\",\").map(s => s.trim());\n if (params.actions === false) ctxReq.actions = false;\n if (params.messages === false) ctxReq.messages = false;\n if (params.messages_after !== undefined) ctxReq.messagesAfter = params.messages_after as number;\n if (params.messages_limit !== undefined) ctxReq.messagesLimit = params.messages_limit as number;\n if (params.include) ctxReq.include = (params.include as string).split(\",\").map(s => s.trim());\n // v9 shaping\n if (params.expand) ctxReq.expand = (params.expand as string).split(\",\").map(s => s.trim());\n if (params.elision) ctxReq.elision = params.elision as \"none\" | \"auto\";\n if (params.focus_threshold !== undefined) ctxReq.focusThreshold = params.focus_threshold as number;\n if (params.elide_threshold !== undefined) ctxReq.elideThreshold = params.elide_threshold as number;\n\n // New path: session-aware resolution\n if (ctx.resolveForRoom) {\n const resolved = await ctx.resolveForRoom(roomId);\n if (!resolved) throw new Error(`No access to room ${roomId}. Use sync_lobby to see your rooms.`);\n\n const context = await buildExpandedContext(roomId, resolved.auth, ctxReq);\n return decorateContextWithSession(context, ctx, roomId, resolved.agentId);\n }\n\n // Legacy fallback: explicit token\n const resolved = await resolveForTool(ctx, params);\n return buildExpandedContext(resolved.room, resolved.auth, ctxReq);\n },\n },\n\n {\n name: \"sync_invoke_action\",\n title: \"Invoke Action\",\n description: `THE primary write operation. Invoke any action (built-in or custom) in a room.\n\nRequires embodiment — call sync_embody first if not yet embodied.\nReturns wrapped entries for written keys with _meta (score, writer, velocity,\ncontested) so the agent sees the structural consequences of its action.\n\nArgs:\n - room (string, required): Room ID.\n - token (string, optional): Auth token (legacy).\n - action (string, required): Action ID to invoke.\n - params (object, optional): Parameters for the action.\n\nReturns: { invoked, action, agent, params, writes: [{ scope, key, value, _meta }], result? }`,\n inputSchema: {\n type: \"object\",\n properties: {\n room: { type: \"string\" },\n token: { type: \"string\" },\n action: { type: \"string\", description: \"Action ID to invoke\" },\n params: { type: \"object\", description: \"Action parameters\" },\n },\n required: [\"room\", \"action\"],\n },\n annotations: { readOnlyHint: false, destructiveHint: false, idempotentHint: false, openWorldHint: true },\n async handler(params, ctx) {\n await ensureMigrated();\n const roomId = params.room as string;\n\n // New path: session-aware\n if (ctx.resolveForRoom) {\n const resolved = await ctx.resolveForRoom(roomId);\n if (!resolved) throw new Error(`No access to room ${roomId}`);\n if (!resolved.agentId) {\n throw new Error(`Not embodied in room ${roomId}. Call sync_embody first.`);\n }\n const body: Record = {};\n if (params.params) body.params = params.params;\n return unwrap(await invokeAction(roomId, params.action as string, body, resolved.auth));\n }\n\n // Legacy fallback\n const resolved = await resolveForTool(ctx, params);\n const body: Record = {};\n if (params.params) body.params = params.params;\n return unwrap(await invokeAction(resolved.room, params.action as string, body, resolved.auth));\n },\n },\n\n {\n name: \"sync_wait\",\n title: \"Wait for Condition\",\n description: `Block until a CEL condition becomes true, then return room context.\n\nArgs:\n - room (string, required): Room ID.\n - token (string, optional): Auth token (legacy).\n - condition (string, required): CEL expression.\n - timeout (number, optional): Max wait ms (default: 25000).\n - depth, only: Context shaping params.\n\nReturns: { triggered: true/false, condition, context }`,\n inputSchema: {\n type: \"object\",\n properties: {\n room: { type: \"string\" },\n token: { type: \"string\" },\n condition: { type: \"string\", description: \"CEL expression to wait for\" },\n timeout: { type: \"number\" },\n depth: { type: \"string\", enum: [\"lean\", \"full\", \"usage\"] },\n only: { type: \"string\" },\n },\n required: [\"room\", \"condition\"],\n },\n annotations: { readOnlyHint: true, destructiveHint: false, idempotentHint: true, openWorldHint: true },\n async handler(params, ctx) {\n await ensureMigrated();\n const roomId = params.room as string;\n\n // Resolve auth (embodied or view-level)\n let auth: AuthResult;\n if (ctx.resolveForRoom) {\n const resolved = await ctx.resolveForRoom(roomId);\n if (!resolved) throw new Error(`No access to room ${roomId}`);\n auth = resolved.auth;\n } else {\n const resolved = await resolveForTool(ctx, params);\n auth = resolved.auth;\n }\n\n // Build URL for waitForCondition\n const url = new URL(`http://internal/rooms/${roomId}/wait`);\n url.searchParams.set(\"condition\", params.condition as string);\n if (params.timeout) url.searchParams.set(\"timeout\", String(params.timeout));\n if (params.depth) url.searchParams.set(\"depth\", params.depth as string);\n if (params.only) url.searchParams.set(\"only\", params.only as string);\n\n return unwrap(await waitForCondition(roomId, url, auth));\n },\n },\n\n // ═══════════════════════════════════════════════════════════════\n // Sugar for common built-in actions\n // ═══════════════════════════════════════════════════════════════\n\n {\n name: \"sync_register_action\",\n title: \"Register Action\",\n description: `Register a new action in a room. Requires embodiment.\n\nArgs: room (required), id (required), description, writes, params, scope, if, enabled, result, on_invoke.\n\nReturns: Saved action definition.`,\n inputSchema: {\n type: \"object\",\n properties: {\n room: { type: \"string\" },\n token: { type: \"string\" },\n id: { type: \"string\", description: \"Action ID\" },\n description: { type: \"string\" },\n writes: { type: \"array\", items: { type: \"object\" }, description: \"Write templates\" },\n params: { type: \"object\", description: \"Parameter schema\" },\n scope: { type: \"string\" },\n \"if\": { type: \"string\", description: \"CEL precondition\" },\n enabled: { type: \"string\", description: \"CEL visibility gate\" },\n result: { type: \"string\", description: \"CEL result expression\" },\n on_invoke: { type: \"object\", description: \"Cooldown timer\" },\n },\n required: [\"room\", \"id\"],\n },\n annotations: { readOnlyHint: false, destructiveHint: false, idempotentHint: true, openWorldHint: false },\n async handler(params, ctx) {\n await ensureMigrated();\n const roomId = params.room as string;\n const actionBody: Record = {};\n for (const key of [\"id\", \"description\", \"writes\", \"params\", \"scope\", \"if\", \"enabled\", \"result\", \"on_invoke\"]) {\n if (params[key] !== undefined) actionBody[key] = params[key];\n }\n\n if (ctx.resolveForRoom) {\n const resolved = await ctx.resolveForRoom(roomId);\n if (!resolved) throw new Error(`No access to room ${roomId}`);\n if (!resolved.agentId) throw new Error(`Not embodied in room ${roomId}. Call sync_embody first.`);\n return withResponseEscalation(ctx, roomId, resolved.auth, (auth) =>\n registerAction(roomId, actionBody, auth)\n );\n }\n\n const resolved = await resolveForTool(ctx, params);\n return withResponseEscalation(ctx, resolved.room, resolved.auth, (auth) =>\n registerAction(resolved.room, actionBody, auth)\n );\n },\n },\n\n {\n name: \"sync_register_view\",\n title: \"Register View\",\n description: `Register a computed view. Requires embodiment.\n\nArgs: room (required), id (required), expr (required), description, scope, enabled, render.\n\nReturns: View with current resolved value.`,\n inputSchema: {\n type: \"object\",\n properties: {\n room: { type: \"string\" },\n token: { type: \"string\" },\n id: { type: \"string\" },\n expr: { type: \"string\" },\n description: { type: \"string\" },\n scope: { type: \"string\" },\n enabled: { type: \"string\" },\n render: { type: \"object\" },\n },\n required: [\"room\", \"id\", \"expr\"],\n },\n annotations: { readOnlyHint: false, destructiveHint: false, idempotentHint: true, openWorldHint: false },\n async handler(params, ctx) {\n await ensureMigrated();\n const roomId = params.room as string;\n const viewBody: Record = {};\n for (const key of [\"id\", \"expr\", \"description\", \"scope\", \"enabled\", \"render\"]) {\n if (params[key] !== undefined) viewBody[key] = params[key];\n }\n\n if (ctx.resolveForRoom) {\n const resolved = await ctx.resolveForRoom(roomId);\n if (!resolved) throw new Error(`No access to room ${roomId}`);\n if (!resolved.agentId) throw new Error(`Not embodied in room ${roomId}. Call sync_embody first.`);\n return withResponseEscalation(ctx, roomId, resolved.auth, (auth) =>\n registerView(roomId, viewBody, auth)\n );\n }\n\n const resolved = await resolveForTool(ctx, params);\n return withResponseEscalation(ctx, resolved.room, resolved.auth, (auth) =>\n registerView(resolved.room, viewBody, auth)\n );\n },\n },\n\n {\n name: \"sync_send_message\",\n title: \"Send Message\",\n description: `Send a message to a sync room. Requires embodiment.\n\nArgs: room (required), body (required), kind, to.\n\nReturns: { ok, seq, from, kind }`,\n inputSchema: {\n type: \"object\",\n properties: {\n room: { type: \"string\" },\n token: { type: \"string\" },\n body: { type: \"string\", description: \"Message content\" },\n kind: { type: \"string\" },\n to: { type: \"string\", description: \"Direct to agent(s)\" },\n },\n required: [\"room\", \"body\"],\n },\n annotations: { readOnlyHint: false, destructiveHint: false, idempotentHint: false, openWorldHint: false },\n async handler(params, ctx) {\n await ensureMigrated();\n const roomId = params.room as string;\n const msgParams: Record = { body: params.body };\n if (params.kind) msgParams.kind = params.kind;\n if (params.to) msgParams.to = params.to;\n\n if (ctx.resolveForRoom) {\n const resolved = await ctx.resolveForRoom(roomId);\n if (!resolved) throw new Error(`No access to room ${roomId}`);\n if (!resolved.agentId) throw new Error(`Not embodied in room ${roomId}. Call sync_embody first.`);\n return unwrap(await invokeBuiltinAction(roomId, \"_send_message\", { params: msgParams }, resolved.auth));\n }\n\n const resolved = await resolveForTool(ctx, params);\n return unwrap(await invokeBuiltinAction(resolved.room, \"_send_message\", { params: msgParams }, resolved.auth));\n },\n },\n\n {\n name: \"sync_help\",\n title: \"Get Help\",\n description: `Access the sync help system.\n\nArgs: room (required), key (optional).\n\nReturns: { content, version, source }`,\n inputSchema: {\n type: \"object\",\n properties: {\n room: { type: \"string\" },\n token: { type: \"string\" },\n key: { type: \"string\", description: \"Help key\" },\n },\n required: [\"room\"],\n },\n annotations: { readOnlyHint: true, destructiveHint: false, idempotentHint: true, openWorldHint: false },\n async handler(params, ctx) {\n await ensureMigrated();\n const roomId = params.room as string;\n const helpParams: Record = {};\n if (params.key) helpParams.key = params.key;\n\n // Help works in observe mode — no embodiment required\n if (ctx.resolveForRoom) {\n const resolved = await ctx.resolveForRoom(roomId);\n if (!resolved) throw new Error(`No access to room ${roomId}`);\n return unwrap(await invokeBuiltinAction(roomId, \"help\", { params: helpParams }, resolved.auth));\n }\n\n const resolved = await resolveForTool(ctx, params);\n return unwrap(await invokeBuiltinAction(resolved.room, \"help\", { params: helpParams }, resolved.auth));\n },\n },\n\n {\n name: \"sync_eval_cel\",\n title: \"Evaluate CEL\",\n description: `Evaluate a CEL expression against the current room state.\n\nArgs: room (required), expr (required).\n\nReturns: { expression, value }`,\n inputSchema: {\n type: \"object\",\n properties: {\n room: { type: \"string\" },\n token: { type: \"string\" },\n expr: { type: \"string\", description: \"CEL expression\" },\n },\n required: [\"room\", \"expr\"],\n },\n annotations: { readOnlyHint: true, destructiveHint: false, idempotentHint: true, openWorldHint: false },\n async handler(params, ctx) {\n await ensureMigrated();\n const roomId = params.room as string;\n\n if (ctx.resolveForRoom) {\n const resolved = await ctx.resolveForRoom(roomId);\n if (!resolved) throw new Error(`No access to room ${roomId}`);\n return unwrap(await evalExpression(roomId, { expr: params.expr }, resolved.auth));\n }\n\n const resolved = await resolveForTool(ctx, params);\n return unwrap(await evalExpression(resolved.room, { expr: params.expr }, resolved.auth));\n },\n },\n\n {\n name: \"sync_delete_action\",\n title: \"Delete Action\",\n description: `Remove an action from a room. Requires embodiment.\n\nArgs: room (required), id (required).`,\n inputSchema: {\n type: \"object\",\n properties: {\n room: { type: \"string\" },\n token: { type: \"string\" },\n id: { type: \"string\", description: \"Action ID to delete\" },\n },\n required: [\"room\", \"id\"],\n },\n annotations: { readOnlyHint: false, destructiveHint: true, idempotentHint: true, openWorldHint: false },\n async handler(params, ctx) {\n await ensureMigrated();\n const roomId = params.room as string;\n\n if (ctx.resolveForRoom) {\n const resolved = await ctx.resolveForRoom(roomId);\n if (!resolved) throw new Error(`No access to room ${roomId}`);\n if (!resolved.agentId) throw new Error(`Not embodied in room ${roomId}. Call sync_embody first.`);\n return unwrap(await deleteAction(roomId, params.id as string, resolved.auth));\n }\n\n const resolved = await resolveForTool(ctx, params);\n return unwrap(await deleteAction(resolved.room, params.id as string, resolved.auth));\n },\n },\n\n {\n name: \"sync_delete_view\",\n title: \"Delete View\",\n description: `Remove a view from a room. Requires embodiment.\n\nArgs: room (required), id (required).`,\n inputSchema: {\n type: \"object\",\n properties: {\n room: { type: \"string\" },\n token: { type: \"string\" },\n id: { type: \"string\", description: \"View ID to delete\" },\n },\n required: [\"room\", \"id\"],\n },\n annotations: { readOnlyHint: false, destructiveHint: true, idempotentHint: true, openWorldHint: false },\n async handler(params, ctx) {\n await ensureMigrated();\n const roomId = params.room as string;\n\n if (ctx.resolveForRoom) {\n const resolved = await ctx.resolveForRoom(roomId);\n if (!resolved) throw new Error(`No access to room ${roomId}`);\n if (!resolved.agentId) throw new Error(`Not embodied in room ${roomId}. Call sync_embody first.`);\n return unwrap(await deleteView(roomId, params.id as string, resolved.auth));\n }\n\n const resolved = await resolveForTool(ctx, params);\n return unwrap(await deleteView(resolved.room, params.id as string, resolved.auth));\n },\n },\n\n // ═══════════════════════════════════════════════════════════════\n // Vault management — REMOVED in v7 (unified tokens replace vault)\n // Legacy vault tools have been removed. Use /tokens endpoints instead.\n // ═══════════════════════════════════════════════════════════════\n];\n","deleted","label",[180,161],"mcp","permalink","https://www.val.town/x/c15r/sync/code/mcp/tools.ts","extension","actionData","errors"]