[{"_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","cdbc11de55e47953b237ebd2bc3607fb50931703","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,"_157":158,"_177":178,"_179":-5},"handle","c15r","name","sync-mcp","path","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":33,"_14":120,"_121":122,"_123":124,"_125":-5,"_126":127,"_128":127,"_129":130,"_131":130,"_132":130,"_133":127,"_134":127,"_23":135,"_138":139,"_143":144,"_156":20},"id","d65eeaac-17ce-11f1-a9e3-42dde27851f2","createdAt",["D",1772631255241],"deletedAt","legacyEnvVars","privacy","unlisted","description","MCP server for agent-sync coordination","imageUrl","21f2e37e-8066-4730-9dc7-d27cf8d3c9f3","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","0630d977-f678-453e-926c-52043293f59f","tursoName","d65eeaac17ce11f1a9e342dde27851f2","tursoHostname","d65eeaac17ce11f1a9e342dde27851f2-val-town.aws-us-east-2.turso.io","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_95":96,"_136":137},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yb2RJNlc1czZ1NlpZRmoxdGJ2eFVNNVhmeTYifQ","org",{"_95":96,"_140":137,"_12":114,"_141":142},"avatar","tier","pro","branch",{"_145":146,"_97":45,"_103":147,"_148":104,"_149":-5,"_150":-5,"_151":-5,"_152":-5,"_153":-5,"_154":98,"_155":96},"version",16,"d65f55b4-17ce-11f1-a9e3-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_103":159,"_97":100,"_160":161,"_162":-5,"_163":147,"_164":165,"_166":167,"_105":168,"_145":169,"_170":171,"_172":173,"_174":20,"_175":-5,"_99":176},"22e49e6e-189f-11f1-8077-42dde27851f2","fileId","6c779f82-1876-11f1-a7bf-42dde27851f2","parentId","branchId","branchVersion",15,"latest",true,["D",1772720718926],2,"fileType","script","content","/**\n * tools.ts — MCP tool definitions for sync-mcp\n *\n * Updated from v1: room and token are now optional when OAuth-authenticated.\n * If omitted, the tool resolves credentials from the user's token vault.\n */\n\n// ─── Configuration ───────────────────────────────────────────────\nconst SYNC_URL = Deno.env.get(\"SYNC_URL\") ?? \"https://sync.parc.land\";\n\n// ─── HTTP helpers ────────────────────────────────────────────────\n\nfunction headers(token?: string): Record {\n const h: Record = { \"Content-Type\": \"application/json\" };\n if (token) h[\"Authorization\"] = `Bearer ${token}`;\n return h;\n}\n\nasync function syncFetch(\n path: string,\n opts: { method?: string; body?: unknown; token?: string } = {},\n): Promise<{ status: number; data: unknown }> {\n const url = `${SYNC_URL}${path}`;\n const init: RequestInit = {\n method: opts.method ?? \"GET\",\n headers: headers(opts.token),\n };\n if (opts.body !== undefined) {\n init.body = JSON.stringify(opts.body);\n }\n const res = await fetch(url, init);\n const text = await res.text();\n let data: unknown;\n try {\n data = JSON.parse(text);\n } catch {\n data = text;\n }\n return { status: res.status, data };\n}\n\n// ─── Tool context (injected by MCP handler) ─────────────────────\n\nexport interface ToolContext {\n userId: string | null; // null if unauthenticated\n resolveToken: (\n room?: string,\n token?: string,\n ) => Promise<{ room: string; token: string } | null>;\n resolveAdminToken: (room: string) => Promise;\n}\n\n// ─── Helpers ─────────────────────────────────────────────────────\n\nasync function requireAuth(\n ctx: ToolContext,\n params: Record,\n opts?: { needsRoom?: boolean },\n): Promise<{ room: string; token: string }> {\n const room = params.room as string | undefined;\n const token = params.token as string | undefined;\n\n const resolved = await ctx.resolveToken(room, token);\n console.log(`requireAuth, post ctx.resolveToken`, {\n room,\n token,\n userId: ctx.userId,\n resolved,\n });\n if (!resolved) {\n if (!ctx.userId) {\n throw new Error(\n \"Authentication required. Connect with OAuth or provide room + token parameters.\",\n );\n }\n if (opts?.needsRoom !== false) {\n throw new Error(\n \"No room specified and no default room in vault. Provide 'room' parameter or set a default room via sync_vault_store.\",\n );\n }\n throw new Error(\n \"No token found for this room. Provide 'token' parameter or add one via sync_vault_store.\",\n );\n }\n return resolved;\n}\n\n/** Retry a sync API call with admin token if the agent token gets scope_denied.\n * Used for shared-scope operations (register action/view) where agent tokens\n * lack authority but the user holds an admin token in the vault. */\nasync function withAdminEscalation(\n ctx: ToolContext,\n room: string,\n agentToken: string,\n fn: (token: string) => Promise<{ status: number; data: unknown }>,\n): Promise {\n const result = await fn(agentToken);\n\n // If agent token worked, return directly\n if (result.status < 400) return result.data;\n\n // Check if this is a scope/authority error worth escalating\n const data = result.data as Record | undefined;\n const error = data?.error as string | undefined;\n const isScopeDenied = error === \"scope_denied\" ||\n error === \"room_token_required\" ||\n error === \"authentication_required\";\n\n if (!isScopeDenied) return result.data; // Not an auth error — return as-is\n\n // Try escalation with room admin token\n const adminToken = await ctx.resolveAdminToken(room);\n if (!adminToken) return result.data; // No admin token available — return original error\n\n const escalated = await fn(adminToken);\n return escalated.data;\n}\n\n// ─── Tool Definitions ────────────────────────────────────────────\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: (\n params: Record,\n ctx: ToolContext,\n ) => Promise;\n}\n\nexport const TOOLS: ToolDef[] = [\n // ── Room lifecycle ──────────────────────────────────────────\n {\n name: \"sync_create_room\",\n title: \"Create Room\",\n description:\n `Create a new sync collaboration room. Returns the room ID, admin token, and view token.\n\nIf authenticated via OAuth, the room token is automatically saved to your vault.\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): Vault 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: {\n type: \"string\",\n description: \"Custom room ID (auto-generated if omitted)\",\n },\n meta: { type: \"object\", description: \"Room metadata (any JSON)\" },\n label: { type: \"string\", description: \"Vault label for this room\" },\n set_default: {\n type: \"boolean\",\n description: \"Make this the default room\",\n },\n },\n },\n annotations: {\n readOnlyHint: false,\n destructiveHint: false,\n idempotentHint: false,\n openWorldHint: false,\n },\n async handler(params, ctx) {\n const body: Record = {};\n if (params.id) body.id = params.id;\n if (params.meta) body.meta = params.meta;\n const result = (await syncFetch(\"/rooms\", { method: \"POST\", body }))\n .data as Record;\n\n // Auto-vault if authenticated\n if (ctx.userId && result.token && result.id) {\n const { vaultStore } = await import(\"./db.ts\");\n // Store room token\n await vaultStore({\n userId: ctx.userId,\n roomId: result.id as string,\n token: result.token as string,\n tokenType: \"room\",\n label: (params.label as string) ?? `Room ${result.id}`,\n isDefault: params.set_default as boolean ?? false,\n });\n // Also store view token\n if (result.view_token) {\n await vaultStore({\n userId: ctx.userId,\n roomId: result.id as string,\n token: result.view_token as string,\n tokenType: \"view\",\n label: `View: ${result.id}`,\n });\n }\n (result as Record)._vaulted = true;\n }\n\n return result;\n },\n },\n\n {\n name: \"sync_list_rooms\",\n title: \"List Rooms\",\n description:\n `List rooms accessible with the given token. If authenticated, uses vault token.\n\nArgs:\n - room (string, optional): Room ID (uses default if omitted).\n - token (string, optional): Auth token (resolved from vault if omitted).\n\nReturns: Array of room objects.`,\n inputSchema: {\n type: \"object\",\n properties: {\n token: {\n type: \"string\",\n description:\n \"Auth token (room_xxx, view_xxx, or as_xxx). Optional if authenticated.\",\n },\n },\n },\n annotations: {\n readOnlyHint: true,\n destructiveHint: false,\n idempotentHint: true,\n openWorldHint: false,\n },\n async handler(params, ctx) {\n const token = params.token as string | undefined;\n if (token) {\n return (await syncFetch(\"/rooms\", { token })).data;\n }\n // If authenticated, try to list rooms from vault\n if (ctx.userId) {\n const { vaultList } = await import(\"./db.ts\");\n const entries = await vaultList(ctx.userId);\n if (entries.length > 0) {\n // Use first available token to list rooms\n return (await syncFetch(\"/rooms\", { token: entries[0].token })).data;\n }\n }\n throw new Error(\n \"No token available. Provide 'token' parameter or authenticate via OAuth.\",\n );\n },\n },\n\n {\n name: \"sync_join_room\",\n title: \"Join Room\",\n description: `Join a sync room as an agent. Returns an agent token (as_xxx).\n\nIf authenticated, the agent token is automatically saved to your vault.\n\nArgs:\n - room (string, optional): Room ID (uses default if omitted).\n - token (string, optional): Room admin token (resolved from vault if omitted).\n - id (string, optional): Agent ID (auto-generated if omitted).\n - name (string, optional): Display name.\n - role (string, optional): Agent role.\n - state (object, optional): Initial private state.\n - public_keys (string[], optional): State keys to auto-expose as views.\n - views (array, optional): Pre-register views.\n\nReturns: Agent object with { id, token, room_id, ... }`,\n inputSchema: {\n type: \"object\",\n properties: {\n room: { type: \"string\", description: \"Room ID\" },\n token: {\n type: \"string\",\n description:\n \"Room admin token (room_xxx). Optional if authenticated.\",\n },\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: {\n type: \"array\",\n items: { type: \"string\" },\n description: \"State keys to auto-expose\",\n },\n views: {\n type: \"array\",\n items: { type: \"object\" },\n description: \"Views to pre-register\",\n },\n },\n },\n annotations: {\n readOnlyHint: false,\n destructiveHint: false,\n idempotentHint: false,\n openWorldHint: false,\n },\n async handler(params, ctx) {\n const resolved = await requireAuth(ctx, params);\n const body: Record = {};\n for (\n const key of [\"id\", \"name\", \"role\", \"state\", \"public_keys\", \"views\"]\n ) {\n if (params[key] !== undefined) body[key] = params[key];\n }\n const result = await withAdminEscalation(\n ctx,\n resolved.room,\n resolved.token,\n (token) =>\n syncFetch(`/rooms/${resolved.room}/agents`, {\n method: \"POST\",\n body,\n token,\n }),\n ) as Record;\n\n // Auto-vault agent token\n if (ctx.userId && result.token) {\n const { vaultStore } = await import(\"./db.ts\");\n await vaultStore({\n userId: ctx.userId,\n roomId: resolved.room,\n token: result.token as string,\n tokenType: \"agent\",\n label: `Agent: ${result.id ?? \"unknown\"}`,\n });\n (result as Record)._vaulted = true;\n }\n\n return result;\n },\n },\n\n // ── Core rhythm: read → act ─────────────────────────────────\n\n {\n name: \"sync_read_context\",\n title: \"Read Context\",\n description: `THE primary read operation. Returns the full room context.\n\nThis is the \"read\" in the read → evaluate → act rhythm.\n\nArgs:\n - room (string, optional): Room ID (uses default if omitted).\n - token (string, optional): Auth token (resolved from vault if omitted).\n - depth (string, optional): \"lean\" | \"full\" | \"usage\"\n - only (string, optional): Section filter, e.g. \"state,actions\"\n - actions (boolean, optional): Include actions (default true)\n - messages (boolean, optional): Include messages (default true)\n - messages_after (number, optional): Seq cursor\n - messages_limit (number, optional): Max messages\n - include (string, optional): Extra scopes, e.g. \"_audit\"\n - compact (boolean, optional): Strip nulls\n\nReturns: { state, views, agents, actions, messages, self, _context }`,\n inputSchema: {\n type: \"object\",\n properties: {\n room: { type: \"string\", description: \"Room ID\" },\n token: { type: \"string\", description: \"Auth token\" },\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 compact: { type: \"boolean\" },\n },\n },\n annotations: {\n readOnlyHint: true,\n destructiveHint: false,\n idempotentHint: true,\n openWorldHint: false,\n },\n async handler(params, ctx) {\n const resolved = await requireAuth(ctx, params);\n const qp = new URLSearchParams();\n if (params.depth) qp.set(\"depth\", params.depth as string);\n if (params.only) qp.set(\"only\", params.only as string);\n if (params.actions === false) qp.set(\"actions\", \"false\");\n if (params.messages === false) qp.set(\"messages\", \"false\");\n if (params.messages_after !== undefined) {\n qp.set(\"messages_after\", String(params.messages_after));\n }\n if (params.messages_limit !== undefined) {\n qp.set(\"messages_limit\", String(params.messages_limit));\n }\n if (params.include) qp.set(\"include\", params.include as string);\n if (params.compact) qp.set(\"compact\", \"true\");\n const qs = qp.toString();\n return (await syncFetch(\n `/rooms/${resolved.room}/context${qs ? \"?\" + qs : \"\"}`,\n {\n token: resolved.token,\n },\n )).data;\n },\n },\n\n {\n name: \"sync_invoke_action\",\n title: \"Invoke Action\",\n description:\n `THE primary write operation. Invoke any action (built-in or custom) in a room.\n\nThis is the \"act\" in the read → evaluate → act rhythm.\n\nArgs:\n - room (string, optional): Room ID (uses default if omitted).\n - token (string, optional): Auth token (resolved from vault if omitted).\n - action (string, required): Action ID to invoke.\n - params (object, optional): Parameters for the action.\n - agent (string, optional): Agent identity override.\n\nReturns: { invoked, action, agent, params, writes, 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 agent: { type: \"string\", description: \"Agent identity override\" },\n },\n required: [\"action\"],\n },\n annotations: {\n readOnlyHint: false,\n destructiveHint: false,\n idempotentHint: false,\n openWorldHint: true,\n },\n async handler(params, ctx) {\n const resolved = await requireAuth(ctx, params);\n const body: Record = {};\n if (params.params) body.params = params.params;\n if (params.agent) body.agent = params.agent;\n return (await syncFetch(\n `/rooms/${resolved.room}/actions/${params.action}/invoke`,\n {\n method: \"POST\",\n body,\n token: resolved.token,\n },\n )).data;\n },\n },\n\n {\n name: \"sync_wait\",\n title: \"Wait for Condition\",\n description:\n `Block until a CEL condition becomes true, then return room context.\n\nArgs:\n - room (string, optional): Room ID.\n - token (string, optional): Auth token.\n - condition (string, required): CEL expression.\n - timeout (number, optional): Max wait ms (default: 25000).\n\nReturns: { triggered: true/false, condition, context }`,\n inputSchema: {\n type: \"object\",\n properties: {\n room: { type: \"string\" },\n token: { type: \"string\" },\n condition: {\n type: \"string\",\n description: \"CEL expression to wait for\",\n },\n timeout: { type: \"number\" },\n depth: { type: \"string\", enum: [\"lean\", \"full\", \"usage\"] },\n only: { type: \"string\" },\n },\n required: [\"condition\"],\n },\n annotations: {\n readOnlyHint: true,\n destructiveHint: false,\n idempotentHint: true,\n openWorldHint: true,\n },\n async handler(params, ctx) {\n const resolved = await requireAuth(ctx, params);\n const qp = new URLSearchParams();\n qp.set(\"condition\", params.condition as string);\n if (params.timeout) qp.set(\"timeout\", String(params.timeout));\n if (params.depth) qp.set(\"depth\", params.depth as string);\n if (params.only) qp.set(\"only\", params.only as string);\n return (await syncFetch(`/rooms/${resolved.room}/wait?${qp.toString()}`, {\n token: resolved.token,\n })).data;\n },\n },\n\n // ── Sugar for common built-in actions ───────────────────────\n\n {\n name: \"sync_register_action\",\n title: \"Register Action\",\n description: `Register a new action in a room.\n\nArgs: room, token (optional if authed), 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: {\n type: \"array\",\n items: { type: \"object\" },\n description: \"Write templates\",\n },\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: [\"id\"],\n },\n annotations: {\n readOnlyHint: false,\n destructiveHint: false,\n idempotentHint: true,\n openWorldHint: false,\n },\n async handler(params, ctx) {\n const resolved = await requireAuth(ctx, params);\n const actionParams: Record = {};\n for (\n const key of [\n \"id\",\n \"description\",\n \"writes\",\n \"params\",\n \"scope\",\n \"if\",\n \"enabled\",\n \"result\",\n \"on_invoke\",\n ]\n ) {\n if (params[key] !== undefined) actionParams[key] = params[key];\n }\n return withAdminEscalation(\n ctx,\n resolved.room,\n resolved.token,\n (token) =>\n syncFetch(`/rooms/${resolved.room}/actions/_register_action/invoke`, {\n method: \"POST\",\n body: { params: actionParams },\n token,\n }),\n );\n },\n },\n\n {\n name: \"sync_register_view\",\n title: \"Register View\",\n description: `Register a computed view — a named CEL expression.\n\nArgs: room, token (optional if authed), 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: [\"id\", \"expr\"],\n },\n annotations: {\n readOnlyHint: false,\n destructiveHint: false,\n idempotentHint: true,\n openWorldHint: false,\n },\n async handler(params, ctx) {\n const resolved = await requireAuth(ctx, params);\n const viewParams: Record = {};\n for (\n const key of [\"id\", \"expr\", \"description\", \"scope\", \"enabled\", \"render\"]\n ) {\n if (params[key] !== undefined) viewParams[key] = params[key];\n }\n return withAdminEscalation(\n ctx,\n resolved.room,\n resolved.token,\n (token) =>\n syncFetch(`/rooms/${resolved.room}/actions/_register_view/invoke`, {\n method: \"POST\",\n body: { params: viewParams },\n token,\n }),\n );\n },\n },\n\n {\n name: \"sync_send_message\",\n title: \"Send Message\",\n description: `Send a message to a sync room.\n\nArgs: room, token (optional if authed), 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: [\"body\"],\n },\n annotations: {\n readOnlyHint: false,\n destructiveHint: false,\n idempotentHint: false,\n openWorldHint: false,\n },\n async handler(params, ctx) {\n const resolved = await requireAuth(ctx, params);\n const msgParams: Record = { body: params.body };\n if (params.kind) msgParams.kind = params.kind;\n if (params.to) msgParams.to = params.to;\n return (await syncFetch(\n `/rooms/${resolved.room}/actions/_send_message/invoke`,\n {\n method: \"POST\",\n body: { params: msgParams },\n token: resolved.token,\n },\n )).data;\n },\n },\n\n {\n name: \"sync_help\",\n title: \"Get Help\",\n description: `Access the sync help system.\n\nArgs: room, token (optional if authed), 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 },\n annotations: {\n readOnlyHint: true,\n destructiveHint: false,\n idempotentHint: true,\n openWorldHint: false,\n },\n async handler(params, ctx) {\n const resolved = await requireAuth(ctx, params);\n const helpParams: Record = {};\n if (params.key) helpParams.key = params.key;\n return (await syncFetch(`/rooms/${resolved.room}/actions/help/invoke`, {\n method: \"POST\",\n body: { params: helpParams },\n token: resolved.token,\n })).data;\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, token (optional if authed), 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: [\"expr\"],\n },\n annotations: {\n readOnlyHint: true,\n destructiveHint: false,\n idempotentHint: true,\n openWorldHint: false,\n },\n async handler(params, ctx) {\n const resolved = await requireAuth(ctx, params);\n return (await syncFetch(`/rooms/${resolved.room}/eval`, {\n method: \"POST\",\n body: { expr: params.expr },\n token: resolved.token,\n })).data;\n },\n },\n\n {\n name: \"sync_delete_action\",\n title: \"Delete Action\",\n description: `Remove an action from a room.\n\nArgs: room, token (optional if authed), 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: [\"id\"],\n },\n annotations: {\n readOnlyHint: false,\n destructiveHint: true,\n idempotentHint: true,\n openWorldHint: false,\n },\n async handler(params, ctx) {\n const resolved = await requireAuth(ctx, params);\n return (await syncFetch(\n `/rooms/${resolved.room}/actions/_delete_action/invoke`,\n {\n method: \"POST\",\n body: { params: { id: params.id } },\n token: resolved.token,\n },\n )).data;\n },\n },\n\n {\n name: \"sync_delete_view\",\n title: \"Delete View\",\n description: `Remove a view from a room.\n\nArgs: room, token (optional if authed), 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: [\"id\"],\n },\n annotations: {\n readOnlyHint: false,\n destructiveHint: true,\n idempotentHint: true,\n openWorldHint: false,\n },\n async handler(params, ctx) {\n const resolved = await requireAuth(ctx, params);\n return (await syncFetch(\n `/rooms/${resolved.room}/actions/_delete_view/invoke`,\n {\n method: \"POST\",\n body: { params: { id: params.id } },\n token: resolved.token,\n },\n )).data;\n },\n },\n\n // ── Vault management (auth-only) ───────────────────────────\n\n {\n name: \"sync_vault_list\",\n title: \"List Vault\",\n description:\n `List all sync tokens stored in your vault. Requires OAuth authentication.\n\nReturns: Array of vault entries with room_id, token_type, label, is_default.`,\n inputSchema: { type: \"object\", properties: {} },\n annotations: {\n readOnlyHint: true,\n destructiveHint: false,\n idempotentHint: true,\n openWorldHint: false,\n },\n async handler(_params, ctx) {\n if (!ctx.userId) {\n throw new Error(\"OAuth authentication required for vault access.\");\n }\n const { vaultList } = await import(\"./db.ts\");\n const entries = await vaultList(ctx.userId);\n return entries.map((e) => ({\n id: e.id,\n room_id: e.roomId,\n token_type: e.tokenType,\n label: e.label,\n is_default: e.isDefault,\n token_preview: e.token.substring(0, 12) + \"...\",\n }));\n },\n },\n\n {\n name: \"sync_vault_store\",\n title: \"Store Token in Vault\",\n description: `Add a sync token to your vault. Requires OAuth authentication.\n\nArgs:\n - room_id (string, required): Room ID this token belongs to.\n - token (string, required): The sync token (room_xxx, as_xxx, or view_xxx).\n - token_type (string, required): \"room\", \"agent\", or \"view\".\n - label (string, optional): Human-readable label.\n - set_default (boolean, optional): Make this the default room.\n\nReturns: { id, room_id, token_type }`,\n inputSchema: {\n type: \"object\",\n properties: {\n room_id: { type: \"string\" },\n token: { type: \"string\" },\n token_type: { type: \"string\", enum: [\"room\", \"agent\", \"view\"] },\n label: { type: \"string\" },\n set_default: { type: \"boolean\" },\n },\n required: [\"room_id\", \"token\", \"token_type\"],\n },\n annotations: {\n readOnlyHint: false,\n destructiveHint: false,\n idempotentHint: false,\n openWorldHint: false,\n },\n async handler(params, ctx) {\n if (!ctx.userId) {\n throw new Error(\"OAuth authentication required for vault access.\");\n }\n const { vaultStore } = await import(\"./db.ts\");\n const id = await vaultStore({\n userId: ctx.userId,\n roomId: params.room_id as string,\n token: params.token as string,\n tokenType: params.token_type as string,\n label: params.label as string | undefined,\n isDefault: params.set_default as boolean | undefined,\n });\n return { id, room_id: params.room_id, token_type: params.token_type };\n },\n },\n\n {\n name: \"sync_vault_remove\",\n title: \"Remove from Vault\",\n description: `Remove a token from your vault. Requires OAuth authentication.\n\nArgs:\n - id (string, required): Vault entry ID (from sync_vault_list).\n\nReturns: { deleted: true }`,\n inputSchema: {\n type: \"object\",\n properties: {\n id: { type: \"string\", description: \"Vault entry ID\" },\n },\n required: [\"id\"],\n },\n annotations: {\n readOnlyHint: false,\n destructiveHint: true,\n idempotentHint: true,\n openWorldHint: false,\n },\n async handler(params, ctx) {\n if (!ctx.userId) {\n throw new Error(\"OAuth authentication required for vault access.\");\n }\n const { vaultDelete } = await import(\"./db.ts\");\n await vaultDelete(ctx.userId, params.id as string);\n return { deleted: true, id: params.id };\n },\n },\n];","deleted","label",[100],"permalink","https://www.val.town/x/c15r/sync-mcp/code/tools.ts","extension","actionData","errors"]