[{"_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/tool-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":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},"89de0034-21e0-11f1-9b94-42dde27851f2","tool-context.ts","fileId","debc196e-1ad9-11f1-b21b-42dde27851f2","parentId","019cbe80-ea89-7462-9a69-79fbc30a3494","branchId","branchVersion",637,"latest",true,["D",1773738369451],2,"fileType","script","content","/**\n * tool-context.ts — MCP tool infrastructure.\n *\n * Contains ToolContext and ToolDef interfaces, auth helpers for tool handlers,\n * and context decoration with session metadata. Separated from tools.ts\n * so tool implementations can import a focused set of infrastructure.\n */\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { rows2objects } from \"../utils.ts\";\nimport {\n resolveAuthFromToken,\n type AuthResult,\n} from \"../auth.ts\";\nimport * as db from \"./db.ts\";\nimport { type ParsedScope } from \"./scope.ts\";\n\n// ─── Tool context (injected by MCP handler) ─────────────────────\n\nexport interface ToolContext {\n userId: string | null;\n clientId: string | null;\n sessionHash: string | null;\n scope: ParsedScope | null;\n\n /** Resolve auth for a room, accounting for embodiment state.\n * Returns embodied agent's AuthResult (if embodied), or view-level\n * AuthResult (if observing), or null (no access). */\n resolveForRoom: (\n roomId: string,\n ) => Promise<{ auth: AuthResult; agentId: string | null } | null>;\n\n /** Legacy: explicit token override (backward compat for non-OAuth callers) */\n resolveToken: (\n room?: string, token?: string,\n ) => Promise<{ room: string; token: string } | null>;\n\n /** Admin-level auth for privilege escalation */\n resolveAdminAuth: (\n roomId: string,\n ) => Promise;\n}\n\n// ─── Tool definition ─────────────────────────────────────────────\n\nexport interface ToolDef {\n name: string;\n title: string;\n description: string;\n inputSchema: Record;\n annotations: {\n readOnlyHint: boolean;\n destructiveHint: boolean;\n idempotentHint: boolean;\n openWorldHint: boolean;\n };\n handler: (params: Record, ctx: ToolContext) => Promise;\n}\n\n// ─── Auth helpers ────────────────────────────────────────────────\n\n/** Convert a vault token string into an AuthResult for direct function calls. */\nexport async function tokenToAuth(token: string, roomId: string): Promise {\n const result = await resolveAuthFromToken(token, roomId);\n if (result instanceof Response) {\n const data = await result.json();\n throw new Error(data.error ?? data.message ?? \"Invalid token\");\n }\n return result;\n}\n\n/** Resolve vault → room + AuthResult for a tool call (legacy path). */\nexport async function resolveForTool(\n ctx: ToolContext,\n params: Record,\n): Promise<{ room: string; token: string; auth: AuthResult }> {\n const resolved = await ctx.resolveToken(\n params.room as string | undefined,\n params.token as string | undefined,\n );\n if (!resolved) {\n if (!ctx.userId) {\n throw new Error(\"Authentication required. Connect with OAuth or provide room + token parameters.\");\n }\n throw new Error(\"No room specified and no default room in vault. Provide 'room' parameter or set a default room via sync_vault_store.\");\n }\n const auth = await tokenToAuth(resolved.token, resolved.room);\n return { room: resolved.room, token: resolved.token, auth };\n}\n\n/** Unwrap a Response into data. Throws on error status with full structured detail. */\nexport async function unwrap(response: Response): Promise {\n const data = await response.json();\n if (response.status >= 400) {\n // Preserve full error body for MCP consumers — agents need hint, help, stage, source\n if (typeof data === \"object\" && data !== null) {\n const parts: string[] = [];\n if (data.error) parts.push(String(data.error));\n if (data.detail) parts.push(String(data.detail));\n if (data.hint) parts.push(`Hint: ${data.hint}`);\n if (data.help) parts.push(`Help: invoke help({ key: \"${data.help}\" })`);\n if (data.source) parts.push(`Source: ${data.source}`);\n if (data.stage) parts.push(`Stage: ${data.stage}`);\n if (data.field) parts.push(`Field: ${data.field}`);\n // Elevation URL for scope_denied\n if (data.elevate) parts.push(`Elevate: ${data.elevate}`);\n throw new Error(parts.join(\"\\n\"));\n }\n throw new Error(String(data));\n }\n return data;\n}\n\n/** Escalation wrapper for functions returning Response. */\nexport async function withResponseEscalation(\n ctx: ToolContext,\n room: string,\n agentAuth: AuthResult,\n fn: (auth: AuthResult) => Promise,\n): Promise {\n const response = await fn(agentAuth);\n if (response.status < 400) return response.json();\n\n const data = await response.json();\n const error = data?.error;\n const isScopeDenied = error === \"scope_denied\" || error === \"room_token_required\";\n\n if (!isScopeDenied) {\n // Preserve structured error for MCP consumers\n const parts: string[] = [];\n if (typeof error === \"string\") parts.push(error);\n if (data.detail) parts.push(String(data.detail));\n if (data.hint) parts.push(`Hint: ${data.hint}`);\n if (data.help) parts.push(`Help: invoke help({ key: \"${data.help}\" })`);\n if (data.stage) parts.push(`Stage: ${data.stage}`);\n throw new Error(parts.length > 0 ? parts.join(\"\\n\") : JSON.stringify(data));\n }\n\n const adminAuth = await ctx.resolveAdminAuth(room);\n if (!adminAuth) throw new Error(typeof error === \"string\" ? error : JSON.stringify(data));\n\n return unwrap(await fn(adminAuth));\n}\n\n// ─── Context decoration ─────────────────────────────────────────\n\n/** Decorate a context response with MCP session metadata.\n * Adds _session block + _current/_switchable annotations on agents.\n * This is MCP-layer only — buildExpandedContext stays session-unaware. */\nexport async function decorateContextWithSession(\n context: Record,\n ctx: ToolContext,\n roomId: string,\n currentAgentId: string | null,\n): Promise> {\n if (!ctx.sessionHash || !ctx.userId) return context;\n\n const userRoom = await db.getUserRoom(ctx.userId, roomId);\n const canEmbody = userRoom && userRoom.access !== \"observer\";\n\n const switchable: string[] = [];\n\n // Annotate agents in the agents section\n if (canEmbody && context.agents) {\n const agentsObj = context.agents;\n if (typeof agentsObj === \"object\" && !Array.isArray(agentsObj)) {\n for (const [agentId, agentData] of Object.entries(agentsObj as Record)) {\n const isCurrent = agentId === currentAgentId;\n const isIdle = agentData.status === \"idle\"\n || agentData.status === \"done\"\n || agentData.status === \"suspended\";\n agentData._current = isCurrent;\n agentData._switchable = !isCurrent && isIdle;\n if (agentData._switchable) switchable.push(agentId);\n }\n }\n }\n\n // Check for unfilled roles\n try {\n const rolesResult = await sqlite.execute({\n sql: `SELECT key, value FROM state\n WHERE room_id = ? AND scope = '_shared' AND key LIKE 'roles.%'`,\n args: [roomId],\n });\n for (const r of rolesResult.rows) {\n const roleId = (r[0] as string).replace(\"roles.\", \"\");\n try {\n const def = JSON.parse(r[1] as string);\n if (!def.filled_by && !switchable.includes(roleId)\n && roleId !== currentAgentId) {\n switchable.push(roleId);\n }\n } catch {}\n }\n } catch {}\n\n const scopeLevel = ctx.scope?.rooms.get(roomId);\n\n context._session = {\n agent: currentAgentId,\n room: roomId,\n switchable,\n scope_level: scopeLevel\n ? (scopeLevel.level === \"role\"\n ? `role:${scopeLevel.role}` : scopeLevel.level)\n : \"full\",\n };\n\n return context;\n}\n","deleted","label",[180,161],"mcp","permalink","https://www.val.town/x/c15r/sync/code/mcp/tool-context.ts","extension","actionData","errors"]