Edeny 中继

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_226":227,"_228":229},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":-7,"_18":19,"_17":-7,"_170":-5,"_20":171,"_22":172,"_173":174,"_175":176,"_26":177,"_24":178,"_179":-5,"_180":-5,"_181":55,"_182":183,"_184":46,"_185":-5,"_186":-5,"_187":188},"routes/_app.x.$handle.$name.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":25,"_26":27,"_28":-5,"_29":-5,"_30":-5,"_31":-5,"_32":-5},"handle","ximu8108","name","relay","branchName","main","version","path","untitled-folder-8015","project",{"_34":112,"_13":14,"_47":113,"_114":-5,"_115":55,"_116":117,"_118":117,"_119":120,"_121":-5,"_122":123,"_124":-5,"_125":55,"_126":-5,"_127":-5,"_128":60,"_129":130,"_131":132,"_133":134,"_135":136,"_137":-5,"_138":139,"_140":139,"_141":142,"_143":142,"_144":142,"_145":139,"_146":139,"_147":148,"_149":150,"_151":152,"_153":55},"tree",[64,65,66,67,68],"file",{"_34":58,"_41":42,"_37":40,"_13":19,"_52":-5,"_50":59,"_17":60,"_39":-5,"_47":61,"_43":62,"_56":-5,"_18":63},"contents",[33],"upstream","pull","ahead","behind","envVars",{"_34":35,"_13":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":46,"_47":48,"_17":49,"_50":51,"_52":53,"_54":55,"_56":-5,"_18":57},"id","e85c9d06-3975-46d1-a10c-2f0ce33a23d5","memo.ts","fileId","63336c72-75ea-11f1-a325-1607ee4eb77e","parentId","57bcb60a-75ea-11f1-b37a-1607ee4eb77e","branchId","3222847d-e2f3-46c2-acd6-4d743732a292","branchVersion",30,"latest",true,"createdAt",["D",1782978521816],2,"fileType","script","content","export default async function(req: Request): Promise {\n const upstream = Deno.env.get(\"MEMORY_UPSTREAM_BASE_URL\");\n if (!upstream) return new Response(\"Missing upstream\", { status: 500 });\n\n const incoming = new URL(req.url);\n const target = new URL(incoming.pathname + incoming.search, upstream);\n\n const headers = new Headers(req.headers);\n headers.set(\"x-forwarded-host\", incoming.host);\n headers.set(\"x-forwarded-proto\", \"https\");\n headers.delete(\"host\");\n\n const res = await fetch(target, {\n method: req.method,\n headers,\n body: req.method === \"GET\" || req.method === \"HEAD\" ? undefined : req.body,\n redirect: \"manual\",\n });\n\n const outHeaders = new Headers(res.headers);\n outHeaders.set(\"cache-control\", \"no-store\");\n\n return new Response(res.body, {\n status: res.status,\n statusText: res.statusText,\n headers: outHeaders,\n });\n}","deleted",false,"label",[19,36],"dba925ae-9b68-49b4-9ef3-ea27c95f9ce7","directory",0,["D",1782978477991],27,[19],{"_34":58,"_13":19,"_37":40,"_39":-5,"_41":42,"_43":62,"_45":46,"_47":105,"_17":60,"_50":59,"_52":-5,"_54":55,"_56":-5,"_77":106,"_18":107},{"_34":98,"_13":99,"_37":100,"_39":-5,"_41":42,"_43":101,"_45":46,"_47":102,"_17":60,"_50":59,"_52":-5,"_54":55,"_56":-5,"_77":103,"_18":104},{"_34":89,"_13":90,"_37":91,"_39":-5,"_41":42,"_43":92,"_45":46,"_47":93,"_17":94,"_50":75,"_52":95,"_54":55,"_56":-5,"_77":96,"_18":97},{"_34":80,"_13":81,"_37":82,"_39":-5,"_41":42,"_43":83,"_45":46,"_47":84,"_17":85,"_50":75,"_52":86,"_54":55,"_56":-5,"_77":87,"_18":88},{"_34":69,"_13":70,"_37":71,"_39":-5,"_41":42,"_43":72,"_45":46,"_47":73,"_17":74,"_50":75,"_52":76,"_54":55,"_56":-5,"_77":78,"_18":79},"ec5d10ea-2b9d-49d1-802d-0cada2891cbd","new-file-3900.ts","5b952ee0-753d-11f1-b3f4-1607ee4eb77e",26,["D",1782905114400],3,"http","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\ntype JsonRpcRequest = {\n jsonrpc?: string;\n id?: string | number | null;\n method?: string;\n params?: Record;\n};\n\nconst SERVER_NAME = \"stackchan-valtown-mcp\";\nconst PROTOCOL_VERSION = \"2025-06-18\";\n\nconst ROBOT_TOOL_MAP: Record = {\n get_status: \"get_status\",\n set_avatar: \"set_avatar\",\n move_head: \"move_head\",\n};\n\nfunction json(\n data: unknown,\n status = 200,\n headers: Record = {},\n): Response {\n return new Response(JSON.stringify(data), {\n status,\n headers: {\n \"content-type\": \"application/json; charset=utf-8\",\n ...headers,\n },\n });\n}\n\nfunction bearerToken(req: Request): string | null {\n const value = req.headers.get(\"authorization\") ?? \"\";\n const match = value.match(/^Bearer\\s+(.+)$/i);\n return match?.[1] ?? null;\n}\n\nasync function ensureSchema(): Promise {\n await sqlite.batch([\n `CREATE TABLE IF NOT EXISTS memories (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n text TEXT NOT NULL,\n tags TEXT NOT NULL DEFAULT '',\n created_at INTEGER NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS commands (\n id TEXT PRIMARY KEY,\n tool TEXT NOT NULL,\n arguments_json TEXT NOT NULL,\n status TEXT NOT NULL,\n result_json TEXT,\n error TEXT,\n created_at INTEGER NOT NULL,\n updated_at INTEGER NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS oauth_clients (\n client_id TEXT PRIMARY KEY,\n client_secret TEXT,\n redirect_uris_json TEXT,\n created_at INTEGER NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS oauth_codes (\n code TEXT PRIMARY KEY,\n client_id TEXT NOT NULL,\n redirect_uri TEXT NOT NULL,\n code_challenge TEXT,\n code_challenge_method TEXT,\n created_at INTEGER NOT NULL\n )`,\n `CREATE TABLE IF NOT EXISTS oauth_tokens (\n access_token TEXT PRIMARY KEY,\n refresh_token TEXT,\n client_id TEXT,\n created_at INTEGER NOT NULL\n )`,\n ]);\n}\n\nasync function isValidOAuthToken(token: string): Promise {\n await ensureSchema();\n const rows = await sqlite.execute({\n sql: \"SELECT access_token FROM oauth_tokens WHERE access_token = ? LIMIT 1\",\n args: [token],\n });\n return rows.rows.length > 0;\n}\n\nasync function requireMcpAuth(req: Request): Promise {\n const token = bearerToken(req);\n const staticToken = Deno.env.get(\"MCP_BEARER_TOKEN\");\n\n if (staticToken && token === staticToken) return null;\n if (token && await isValidOAuthToken(token)) return null;\n\n return json(\n { error: \"unauthorized\" },\n 401,\n { \"WWW-Authenticate\": 'Bearer realm=\"stackchan-valtown-mcp\"' },\n );\n}\n\nfunction requireStaticBearer(req: Request, envName: string): Response | null {\n const expected = Deno.env.get(envName);\n if (!expected) return null;\n if (bearerToken(req) !== expected) {\n return json({ error: \"unauthorized\" }, 401);\n }\n return null;\n}\n\nfunction issuer(req: Request): string {\n const url = new URL(req.url);\n return `${url.protocol}//${url.host}`;\n}\n\nfunction oauthMetadata(req: Request) {\n const base = issuer(req);\n return {\n issuer: base,\n authorization_endpoint: `${base}/authorize`,\n token_endpoint: `${base}/token`,\n registration_endpoint: `${base}/register`,\n response_types_supported: [\"code\"],\n grant_types_supported: [\"authorization_code\", \"refresh_token\"],\n token_endpoint_auth_methods_supported: [\n \"none\",\n \"client_secret_post\",\n \"client_secret_basic\",\n ],\n code_challenge_methods_supported: [\"plain\", \"S256\"],\n scopes_supported: [\"mcp\"],\n service_documentation: `${base}/`,\n };\n}\n\nasync function parseBody(req: Request): Promise> {\n const contentType = req.headers.get(\"content-type\") ?? \"\";\n if (contentType.includes(\"application/json\")) {\n const body = await req.json() as Record;\n return Object.fromEntries(\n Object.entries(body).map(([key, value]) => [key, String(value ?? \"\")]),\n );\n }\n const form = await req.formData();\n return Object.fromEntries(\n [...form.entries()].map(([key, value]) => [key, String(value)]),\n );\n}\n\nasync function handleRegister(req: Request): Promise {\n await ensureSchema();\n const body = await req.json().catch(() => ({})) as Record;\n const clientId = crypto.randomUUID();\n const clientSecret = crypto.randomUUID();\n const redirectUris = JSON.stringify(body.redirect_uris ?? []);\n\n await sqlite.execute({\n sql:\n \"INSERT INTO oauth_clients (client_id, client_secret, redirect_uris_json, created_at) VALUES (?, ?, ?, ?)\",\n args: [clientId, clientSecret, redirectUris, Date.now()],\n });\n\n return json({\n client_id: clientId,\n client_secret: clientSecret,\n client_id_issued_at: Math.floor(Date.now() / 1000),\n token_endpoint_auth_method: \"client_secret_post\",\n grant_types: [\"authorization_code\", \"refresh_token\"],\n response_types: [\"code\"],\n redirect_uris: body.redirect_uris ?? [],\n }, 201);\n}\n\nasync function handleAuthorize(req: Request): Promise {\n await ensureSchema();\n const url = new URL(req.url);\n const redirectUri = url.searchParams.get(\"redirect_uri\");\n const clientId = url.searchParams.get(\"client_id\") ?? \"\";\n const state = url.searchParams.get(\"state\") ?? \"\";\n const codeChallenge = url.searchParams.get(\"code_challenge\") ?? \"\";\n const codeChallengeMethod = url.searchParams.get(\"code_challenge_method\") ??\n \"plain\";\n\n if (!redirectUri) return json({ error: \"redirect_uri is required\" }, 400);\n\n const code = crypto.randomUUID();\n await sqlite.execute({\n sql:\n \"INSERT INTO oauth_codes (code, client_id, redirect_uri, code_challenge, code_challenge_method, created_at) VALUES (?, ?, ?, ?, ?, ?)\",\n args: [\n code,\n clientId,\n redirectUri,\n codeChallenge,\n codeChallengeMethod,\n Date.now(),\n ],\n });\n\n const redirect = new URL(redirectUri);\n redirect.searchParams.set(\"code\", code);\n if (state) redirect.searchParams.set(\"state\", state);\n return Response.redirect(redirect.toString(), 302);\n}\n\nasync function handleToken(req: Request): Promise {\n await ensureSchema();\n const body = await parseBody(req);\n const grantType = body.grant_type;\n\n if (grantType === \"authorization_code\") {\n const code = body.code ?? \"\";\n const rows = await sqlite.execute({\n sql: \"SELECT client_id FROM oauth_codes WHERE code = ? LIMIT 1\",\n args: [code],\n });\n if (!rows.rows.length) return json({ error: \"invalid_grant\" }, 400);\n\n const clientId = String(\n (rows.rows[0] as Record).client_id ?? body.client_id ??\n \"\",\n );\n await sqlite.execute({\n sql: \"DELETE FROM oauth_codes WHERE code = ?\",\n args: [code],\n });\n\n const accessToken = crypto.randomUUID();\n const refreshToken = crypto.randomUUID();\n await sqlite.execute({\n sql:\n \"INSERT INTO oauth_tokens (access_token, refresh_token, client_id, created_at) VALUES (?, ?, ?, ?)\",\n args: [accessToken, refreshToken, clientId, Date.now()],\n });\n\n return json({\n access_token: accessToken,\n token_type: \"Bearer\",\n expires_in: 31536000,\n refresh_token: refreshToken,\n scope: \"mcp\",\n });\n }\n\n if (grantType === \"refresh_token\") {\n const refreshToken = body.refresh_token ?? \"\";\n const rows = await sqlite.execute({\n sql: \"SELECT client_id FROM oauth_tokens WHERE refresh_token = ? LIMIT 1\",\n args: [refreshToken],\n });\n if (!rows.rows.length) return json({ error: \"invalid_grant\" }, 400);\n\n const clientId = String(\n (rows.rows[0] as Record).client_id ?? \"\",\n );\n const accessToken = crypto.randomUUID();\n await sqlite.execute({\n sql:\n \"INSERT INTO oauth_tokens (access_token, refresh_token, client_id, created_at) VALUES (?, ?, ?, ?)\",\n args: [accessToken, refreshToken, clientId, Date.now()],\n });\n return json({\n access_token: accessToken,\n token_type: \"Bearer\",\n expires_in: 31536000,\n refresh_token: refreshToken,\n scope: \"mcp\",\n });\n }\n\n return json({ error: \"unsupported_grant_type\" }, 400);\n}\n\nfunction rpcResult(id: JsonRpcRequest[\"id\"], result: unknown): Response {\n return json({ jsonrpc: \"2.0\", id, result });\n}\n\nfunction rpcError(\n id: JsonRpcRequest[\"id\"],\n code: number,\n message: string,\n): Response {\n return json({ jsonrpc: \"2.0\", id, error: { code, message } });\n}\n\nfunction textContent(text: string) {\n return { content: [{ type: \"text\", text }] };\n}\n\nfunction toolDefinitions() {\n return [\n {\n name: \"memory_append\",\n description: \"Append a memory note for future Claude sessions.\",\n inputSchema: {\n type: \"object\",\n properties: { text: { type: \"string\" }, tags: { type: \"string\" } },\n required: [\"text\"],\n },\n },\n {\n name: \"memory_recent\",\n description: \"Return recent memory notes.\",\n inputSchema: {\n type: \"object\",\n properties: { limit: { type: \"number\", minimum: 1, maximum: 20 } },\n },\n },\n {\n name: \"memory_search\",\n description: \"Search memory notes by substring.\",\n inputSchema: {\n type: \"object\",\n properties: {\n query: { type: \"string\" },\n limit: { type: \"number\", minimum: 1, maximum: 20 },\n },\n required: [\"query\"],\n },\n },\n {\n name: \"get_status\",\n description:\n \"Queue a StackChan gateway status request through the local bridge.\",\n inputSchema: { type: \"object\", properties: {} },\n },\n {\n name: \"set_avatar\",\n description: \"Queue a StackChan avatar expression change.\",\n inputSchema: {\n type: \"object\",\n properties: {\n face: {\n type: \"string\",\n enum: [\n \"idle\",\n \"happy\",\n \"thinking\",\n \"sad\",\n \"surprised\",\n \"embarrassed\",\n \"off\",\n ],\n },\n },\n required: [\"face\"],\n },\n },\n {\n name: \"move_head\",\n description: \"Queue a StackChan head movement command.\",\n inputSchema: {\n type: \"object\",\n properties: {\n yaw: { type: \"number\", minimum: -90, maximum: 90 },\n pitch: { type: \"number\", minimum: 5, maximum: 85 },\n speed: { type: \"string\", enum: [\"low\", \"mid\", \"high\"] },\n },\n required: [\"yaw\", \"pitch\"],\n },\n },\n {\n name: \"get_command_result\",\n description: \"Fetch a queued robot command result by id.\",\n inputSchema: {\n type: \"object\",\n properties: { id: { type: \"string\" } },\n required: [\"id\"],\n },\n },\n ];\n}\n\nasync function callTool(name: string, args: Record = {}) {\n await ensureSchema();\n\n if (name === \"memory_append\") {\n const text = String(args.text ?? \"\").trim();\n if (!text) return textContent(\"text is required\");\n const tags = String(args.tags ?? \"\").trim();\n await sqlite.execute({\n sql: \"INSERT INTO memories (text, tags, created_at) VALUES (?, ?, ?)\",\n args: [text, tags, Date.now()],\n });\n return textContent(\"memory appended\");\n }\n\n if (name === \"memory_recent\") {\n const limit = Math.min(Math.max(Number(args.limit ?? 5), 1), 20);\n const rows = await sqlite.execute({\n sql:\n \"SELECT id, text, tags, created_at FROM memories ORDER BY id DESC LIMIT ?\",\n args: [limit],\n });\n return textContent(JSON.stringify(rows.rows, null, 2));\n }\n\n if (name === \"memory_search\") {\n const query = String(args.query ?? \"\").trim();\n const limit = Math.min(Math.max(Number(args.limit ?? 5), 1), 20);\n if (!query) return textContent(\"query is required\");\n const rows = await sqlite.execute({\n sql:\n \"SELECT id, text, tags, created_at FROM memories WHERE text LIKE ? OR tags LIKE ? ORDER BY id DESC LIMIT ?\",\n args: [`%${query}%`, `%${query}%`, limit],\n });\n return textContent(JSON.stringify(rows.rows, null, 2));\n }\n\n if (name === \"get_command_result\") {\n const id = String(args.id ?? \"\").trim();\n const rows = await sqlite.execute({\n sql:\n \"SELECT id, tool, status, result_json, error, updated_at FROM commands WHERE id = ?\",\n args: [id],\n });\n if (!rows.rows.length) return textContent(`command not found: ${id}`);\n return textContent(JSON.stringify(rows.rows[0], null, 2));\n }\n\n const mapped = ROBOT_TOOL_MAP[name];\n if (mapped) {\n const id = crypto.randomUUID();\n const now = Date.now();\n await sqlite.execute({\n sql:\n \"INSERT INTO commands (id, tool, arguments_json, status, created_at, updated_at) VALUES (?, ?, ?, 'pending', ?, ?)\",\n args: [id, mapped, JSON.stringify(args), now, now],\n });\n\n const deadline = Date.now() + 22000;\n while (Date.now() < deadline) {\n const rows = await sqlite.execute({\n sql: \"SELECT status, result_json, error FROM commands WHERE id = ?\",\n args: [id],\n });\n const row = rows.rows[0] as Record | undefined;\n if (row?.status === \"done\") {\n return textContent(String(row.result_json ?? \"{}\"));\n }\n if (row?.status === \"error\") {\n return textContent(`bridge error: ${String(row.error ?? \"unknown\")}`);\n }\n await new Promise((resolve) => setTimeout(resolve, 700));\n }\n return textContent(`queued: ${id}. Call get_command_result with this id.`);\n }\n\n return textContent(`unknown tool: ${name}`);\n}\n\nasync function handleMcp(req: Request): Promise {\n const authError = await requireMcpAuth(req);\n if (authError) return authError;\n\n const body = await req.json() as JsonRpcRequest;\n const method = body.method ?? \"\";\n\n if (method === \"initialize\") {\n return rpcResult(body.id, {\n protocolVersion: PROTOCOL_VERSION,\n capabilities: { tools: {} },\n serverInfo: { name: SERVER_NAME, version: \"0.2.0\" },\n });\n }\n if (method === \"notifications/initialized\") {\n return new Response(null, { status: 202 });\n }\n if (method === \"tools/list\") {\n return rpcResult(body.id, { tools: toolDefinitions() });\n }\n if (method === \"tools/call\") {\n const params = body.params ?? {};\n const name = String(params.name ?? \"\");\n const args = (params.arguments ?? {}) as Record;\n return rpcResult(body.id, await callTool(name, args));\n }\n return rpcError(body.id, -32601, `method not found: ${method}`);\n}\n\nasync function handleBridgePoll(req: Request): Promise {\n const authError = requireStaticBearer(req, \"BRIDGE_TOKEN\");\n if (authError) return authError;\n await ensureSchema();\n\n const rows = await sqlite.execute(\n \"SELECT id, tool, arguments_json FROM commands WHERE status = 'pending' ORDER BY created_at ASC LIMIT 1\",\n );\n const row = rows.rows[0] as Record | undefined;\n if (!row) return json({ command: null });\n\n await sqlite.execute({\n sql: \"UPDATE commands SET status = 'running', updated_at = ? WHERE id = ?\",\n args: [Date.now(), row.id],\n });\n return json({\n command: {\n id: row.id,\n tool: row.tool,\n arguments: JSON.parse(String(row.arguments_json ?? \"{}\")),\n },\n });\n}\n\nasync function handleBridgeResult(req: Request): Promise {\n const authError = requireStaticBearer(req, \"BRIDGE_TOKEN\");\n if (authError) return authError;\n await ensureSchema();\n\n const body = await req.json() as {\n id?: string;\n ok?: boolean;\n result?: unknown;\n error?: string;\n };\n if (!body.id) return json({ error: \"id is required\" }, 400);\n\n if (body.ok) {\n await sqlite.execute({\n sql:\n \"UPDATE commands SET status = 'done', result_json = ?, error = NULL, updated_at = ? WHERE id = ?\",\n args: [JSON.stringify(body.result ?? null), Date.now(), body.id],\n });\n } else {\n await sqlite.execute({\n sql:\n \"UPDATE commands SET status = 'error', error = ?, updated_at = ? WHERE id = ?\",\n args: [body.error ?? \"unknown bridge error\", Date.now(), body.id],\n });\n }\n return json({ ok: true });\n}\n\nexport default async function handler(req: Request): Promise {\n const url = new URL(req.url);\n\n if (req.method === \"GET\" && url.pathname === \"/\") {\n return json({\n ok: true,\n service: SERVER_NAME,\n endpoints: [\n \"/mcp\",\n \"/bridge/poll\",\n \"/bridge/result\",\n \"/.well-known/oauth-authorization-server\",\n \"/register\",\n \"/authorize\",\n \"/token\",\n ],\n });\n }\n\n if (\n req.method === \"GET\" &&\n (url.pathname === \"/.well-known/oauth-authorization-server\" ||\n url.pathname === \"/.well-known/openid-configuration\")\n ) return json(oauthMetadata(req));\n if (req.method === \"POST\" && url.pathname === \"/register\") {\n return await handleRegister(req);\n }\n if (req.method === \"GET\" && url.pathname === \"/authorize\") {\n return await handleAuthorize(req);\n }\n if (req.method === \"POST\" && url.pathname === \"/token\") {\n return await handleToken(req);\n }\n\n if (req.method === \"POST\" && url.pathname === \"/mcp\") {\n return await handleMcp(req);\n }\n if (req.method === \"GET\" && url.pathname === \"/bridge/poll\") {\n return await handleBridgePoll(req);\n }\n if (req.method === \"POST\" && url.pathname === \"/bridge/result\") {\n return await handleBridgeResult(req);\n }\n\n return json({ error: \"not found\" }, 404);\n}","children",[],[70],"29ed8bf3-6bb2-4946-a197-656afe2cc16d","mcp.ts","66f21ad0-71fc-11f1-807a-1607ee4eb77e",18,["D",1782548868794],10,"// Edeny MCP Server + 状态端点（合并版）\n// MCP协议 (POST) + 状态管理 (GET) 二合一\n// 中继页面的 SU 地址改成这个 val 的 URL\n\n// ── Blob 存储 ──────────────────────────────────────────────\n\nconst BLOB_KEY = \"edeny_state\";\n\nasync function getState(): Promise> {\n try {\n const { blob } = await import(\"https://esm.town/v/std/blob\");\n const state = await blob.getJSON(BLOB_KEY);\n return (state as Record) || { cmd: \"idle\", t: 0 };\n } catch {\n return { cmd: \"idle\", t: 0 };\n }\n}\n\nasync function setState(state: Record): Promise {\n const { blob } = await import(\"https://esm.town/v/std/blob\");\n await blob.setJSON(BLOB_KEY, { ...state, t: Date.now() });\n}\n\n// ── Tool 定义 ──────────────────────────────────────────────\n\nconst TOOLS = [\n {\n name: \"toy_set\",\n description:\n \"控制设备的振动模式和强度。mode: 振动模式(0-3)，strength: 强度(1-20)，on/off: 脉冲时长(ms)，可选。\",\n inputSchema: {\n type: \"object\",\n properties: {\n mode: { type: \"number\", description: \"振动模式 0-3\" },\n strength: { type: \"number\", description: \"振动强度 1-20\" },\n on: { type: \"number\", description: \"开启时长 ms（可选）\" },\n off: { type: \"number\", description: \"关闭时长 ms（可选）\" },\n },\n required: [\"mode\", \"strength\"],\n },\n },\n {\n name: \"toy_stop\",\n description: \"立即停止设备\",\n inputSchema: { type: \"object\", properties: {} },\n },\n];\n\n// ── JSON-RPC 工具函数 ─────────────────────────────────────\n\nfunction jsonRpc(id: string | number, result: unknown) {\n return Response.json({ jsonrpc: \"2.0\", id, result }, { headers: corsHeaders() });\n}\n\nfunction jsonRpcError(id: string | number | null, code: number, message: string) {\n return Response.json(\n { jsonrpc: \"2.0\", id, error: { code, message } },\n { headers: corsHeaders() },\n );\n}\n\nfunction corsHeaders(): Record {\n return {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, mcp-session-id\",\n };\n}\n\n// ── Tool 执行 ──────────────────────────────────────────────\n\nasync function executeTool(name: string, args: Record) {\n if (name === \"toy_set\") {\n const state: Record = {\n cmd: \"set\",\n mode: Number(args.mode ?? 0),\n strength: Number(args.strength ?? 1),\n on_ms: Number(args.on ?? 200),\n off_ms: Number(args.off ?? 100),\n };\n await setState(state);\n return {\n content: [{\n type: \"text\",\n text: `已设置: mode=${state.mode}, strength=${state.strength}, on=${state.on_ms}ms, off=${state.off_ms}ms`,\n }],\n };\n }\n\n if (name === \"toy_stop\") {\n await setState({ cmd: \"stop\" });\n return { content: [{ type: \"text\", text: \"已停止\" }] };\n }\n\n throw new Error(`未知工具: ${name}`);\n}\n\n// ── 请求处理 ───────────────────────────────────────────────\n\nexport default async function(req: Request): Promise {\n const url = new URL(req.url);\n\n // CORS 预检\n if (req.method === \"OPTIONS\") {\n return new Response(null, { status: 204, headers: corsHeaders() });\n }\n\n // ── GET 请求：状态端点（供中继页面轮询）──\n if (req.method === \"GET\") {\n // GET /stop → 停止指令\n if (url.pathname === \"/stop\") {\n await setState({ cmd: \"stop\" });\n return Response.json({ cmd: \"stop\", t: Date.now() }, { headers: corsHeaders() });\n }\n\n // GET 带参数 → 设置状态\n if (url.searchParams.has(\"mode\") || url.searchParams.has(\"strength\")) {\n const state: Record = {\n cmd: \"set\",\n mode: Number(url.searchParams.get(\"mode\") ?? 0),\n strength: Number(url.searchParams.get(\"strength\") ?? 1),\n on_ms: Number(url.searchParams.get(\"on\") ?? 200),\n off_ms: Number(url.searchParams.get(\"off\") ?? 100),\n };\n await setState(state);\n return Response.json({ ...state, t: Date.now() }, { headers: corsHeaders() });\n }\n\n // GET 无参数 → 返回当前状态（中继页面轮询）\n const state = await getState();\n return Response.json(state, { headers: corsHeaders() });\n }\n\n // ── POST 请求：MCP JSON-RPC 协议 ──\n if (req.method === \"POST\") {\n let body: any;\n try {\n body = await req.json();\n } catch {\n return jsonRpcError(null, -32700, \"JSON 解析失败\");\n }\n\n const { method, id, params } = body;\n\n if (method === \"initialize\") {\n return jsonRpc(id, {\n protocolVersion: \"2025-03-26\",\n capabilities: { tools: {} },\n serverInfo: { name: \"edeny-controller\", version: \"2.0.0\" },\n });\n }\n\n if (method === \"notifications/initialized\") {\n return new Response(null, { status: 204, headers: corsHeaders() });\n }\n\n if (method === \"tools/list\") {\n return jsonRpc(id, { tools: TOOLS });\n }\n\n if (method === \"tools/call\") {\n try {\n const result = await executeTool(params.name, params.arguments || {});\n return jsonRpc(id, result);\n } catch (e: any) {\n return jsonRpc(id, {\n content: [{ type: \"text\", text: `错误: ${e.message}` }],\n isError: true,\n });\n }\n }\n\n return jsonRpcError(id, -32601, `未知方法: ${method}`);\n }\n\n return new Response(\"Method not allowed\", { status: 405, headers: corsHeaders() });\n}",[],[81],"8f8dcb01-e365-4965-a75c-4301adc1e4bd","main.ts","a9d33b5e-67ed-11f1-8261-1607ee4eb77e",16,["D",1782548686721],6,"export default async function (req) {\n return new Response(\n `\n\n\n\n\nEdeny 中继\n\n\n\n

Edeny 中继 · 保持页面打开

蓝牙未连接

\n\n

中继未启动

\n\n

等待指令...

\n\n

\n\n\n`,\n { headers: { \"Content-Type\": \"text/html; charset=utf-8\" } },\n );\n}",[],[90],"84832852-79ae-4a8a-9b8d-ea74a03ff588","untitled-folder-9630","5ad6f1aa-753d-11f1-a03a-1607ee4eb77e",22,["D",1782904180255],[],[99],["D",1782978477991],[108],[19],{"_34":35,"_13":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":46,"_47":109,"_17":49,"_50":51,"_52":53,"_54":55,"_56":-5,"_77":110,"_18":111},["D",1782978521816],[],[19,36],"1a819507-bd16-4611-bd75-7173742b806a",["D",1781440587910],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","userId","28fb5761-f602-4908-9a5d-490a4ca6905d","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","019ec5fe-a9df-7398-9784-02c59fcd1c5d","tursoName","1a819507bd164611bd757173742b806a","tursoHostname","1a819507bd164611bd757173742b806a-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789522836959],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_169":165},"org",{"_11":12,"_162":163,"_164":165,"_122":123,"_166":167,"_168":55},"branch",{"_17":44,"_13":16,"_34":42,"_154":112,"_155":-5,"_156":-5,"_157":-5,"_158":-5,"_159":-5,"_160":14,"_161":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","西木雪","avatar","https://lh3.googleusercontent.com/a/ACg8ocLKwAeaecvMbI1NhLzuaYnJMJOnKu37RS0Vh8VlwTQTsqw-J5M=s96-c","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_34":112,"_13":14,"_47":221,"_114":-5,"_115":55,"_116":117,"_118":117,"_119":120,"_121":-5,"_122":123,"_124":-5,"_125":55,"_126":-5,"_127":-5,"_128":60,"_129":130,"_131":132,"_133":134,"_135":222,"_137":-5,"_138":139,"_140":139,"_141":142,"_143":142,"_144":142,"_145":139,"_146":139,"_147":223,"_149":224,"_151":225,"_153":55},[203,205,206,207,208],"files",[203,204,205,206,207,208],"counts",{"_193":60,"_194":195,"_196":60,"_32":197,"_198":199},[191],{"_34":58,"_13":19,"_37":40,"_39":-5,"_41":42,"_43":62,"_45":46,"_47":189,"_17":60,"_50":59,"_52":-5,"_54":55,"_56":-5,"_18":190},"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1782978477991],[19],{"_34":35,"_13":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":46,"_47":48,"_17":49,"_50":51,"_52":53,"_54":55,"_56":-5,"_18":192},[19,36],"pulls","branches",1,"forks",{"_200":49,"_202":60},"connections",{"_200":60,"_201":60},"count","unfilledCount","emptyCount",{"_34":58,"_13":19,"_37":40,"_39":-5,"_41":42,"_43":62,"_45":46,"_47":105,"_17":60,"_50":59,"_52":-5,"_54":55,"_56":-5,"_77":219,"_18":220},{"_34":35,"_13":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":46,"_47":109,"_17":49,"_50":51,"_52":53,"_54":55,"_56":-5,"_77":217,"_18":218},{"_34":98,"_13":99,"_37":100,"_39":-5,"_41":42,"_43":101,"_45":46,"_47":102,"_17":60,"_50":59,"_52":-5,"_54":55,"_56":-5,"_77":215,"_18":216},{"_34":89,"_13":90,"_37":91,"_39":-5,"_41":42,"_43":92,"_45":46,"_47":93,"_17":94,"_50":75,"_52":95,"_54":55,"_56":-5,"_77":213,"_18":214},{"_34":80,"_13":81,"_37":82,"_39":-5,"_41":42,"_43":83,"_45":46,"_47":84,"_17":85,"_50":75,"_52":86,"_54":55,"_56":-5,"_77":211,"_18":212},{"_34":69,"_13":70,"_37":71,"_39":-5,"_41":42,"_43":72,"_45":46,"_47":73,"_17":74,"_50":75,"_52":76,"_54":55,"_56":-5,"_77":209,"_18":210},[],[70],[],[81],[],[90],[],[99],[],[19,36],[204],[19],["D",1781440587910],["D",1789522836959],{"_11":12,"_169":165},{"_11":12,"_162":163,"_164":165,"_122":123,"_166":167,"_168":55},{"_17":44,"_13":16,"_34":42,"_154":112,"_155":-5,"_156":-5,"_157":-5,"_158":-5,"_159":-5,"_160":14,"_161":12},"ctx",{"_147":-5,"_186":259,"_260":261,"_262":263,"_264":55,"_265":55,"_266":55,"_267":46,"_268":-5,"_269":-7,"_270":-7,"_271":60,"_272":55,"_273":55,"_274":-5,"_275":55,"_276":55,"_277":55,"_278":-5},"ENV",{"_230":231,"_232":233,"_234":16,"_235":236,"_237":238,"_239":240,"_241":242,"_243":244,"_245":246,"_247":248,"_249":250,"_251":252,"_253":254,"_255":256,"_257":258},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","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","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]