Edeny 中继

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_172":173,"_174":175},"routes/_app.x.$handle.$name",{"_98":97,"_32":45,"_107":88,"_27":53,"_13":14,"_108":-5,"_11":109,"_110":111,"_112":113,"_114":115,"_116":117,"_20":-5,"_118":-5,"_119":-5,"_120":25,"_121":122,"_123":124,"_125":-5,"_126":-5,"_127":128},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":25},"version",18,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","mcp.ts","latestPath","fileId","66f21ad0-71fc-11f1-807a-1607ee4eb77e","name","fileType","http","content","// 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} headers: corsHeaders(),\n });\n}\n\nfunction jsonRpcError(\n id: string | number | null,\n code: number,\n message: string,\n) {\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 params = new URLSearchParams();\n if (args.mode !== undefined) params.set(\"mode\", String(args.mode));\n if (args.strength !== undefined) {\n params.set(\"strength\", String(args.strength));\n }\n if (args.on !== undefined) params.set(\"on\", String(args.on));\n if (args.off !== undefined) params.set(\"off\", String(args.off));\n\n const res = await fetch(`${STATE_URL}?${params.toString()}`);\n const text = await res.text();\n return {\n content: [{\n type: \"text\",\n text: `已设置: mode=${args.mode}, strength=${args.strength}${\n args.on ? `, on=${args.on}ms` : \"\"\n }${args.off ? `, off=${args.off}ms` : \"\"}\\n响应: ${text}`,\n }],\n };\n }\n\n if (name === \"toy_stop\") {\n const res = await fetch(`${STATE_URL}/stop`);\n const text = await res.text();\n return { content: [{ type: \"text\", text: `已停止\\n响应: ${text}` }] };\n }\n\n throw new Error(`未知工具: ${name}`);\n}\n\n// ── 请求处理 ───────────────────────────────────────────────\n\nexport default async function (req: Request): Promise {\n // CORS 预检\n if (req.method === \"OPTIONS\") {\n return new Response(null, { status: 204, headers: corsHeaders() });\n }\n\n // 健康检查\n if (req.method === \"GET\") {\n return new Response(\"Edeny MCP Server 运行中 🧡\", {\n headers: { \"Content-Type\": \"text/plain\", ...corsHeaders() },\n });\n }\n\n // 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 // ── 初始化 ──\n if (method === \"initialize\") {\n return jsonRpc(id, {\n protocolVersion: \"2025-03-26\",\n capabilities: { tools: {} },\n serverInfo: { name: \"edeny-controller\", version: \"1.0.0\" },\n });\n }\n\n // ── 通知（无需响应）──\n if (method === \"notifications/initialized\") {\n return new Response(null, { status: 204, headers: corsHeaders() });\n }\n\n // ── 工具列表 ──\n if (method === \"tools/list\") {\n return jsonRpc(id, { tools: TOOLS });\n }\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\", {\n status: 405,\n headers: corsHeaders(),\n });\n}","// 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}","createdAt",["D",1782548868794],"branchVersion","branchId","3222847d-e2f3-46c2-acd6-4d743732a292","id","1a819507-bd16-4611-bd75-7173742b806a","relay",["D",1781440587910],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","28fb5761-f602-4908-9a5d-490a4ca6905d","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"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",{"_98":97,"_106":102},"org",{"_98":97,"_99":100,"_101":102,"_18":55,"_103":104,"_105":25},"branch",{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"isOwned",30,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","ximu8108","handle","displayName","西木雪","avatar","https://lh3.googleusercontent.com/a/ACg8ocLKwAeaecvMbI1NhLzuaYnJMJOnKu37RS0Vh8VlwTQTsqw-J5M=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":167,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":168,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":169,"_82":170,"_84":171,"_86":25},"tree",[158,159],"files",[158,159],"counts",{"_146":61,"_147":148,"_149":61,"_150":151,"_152":153},"contents",[129,130],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":138,"_32":139,"_30":140,"_132":-5,"_41":42,"_40":141,"_133":124,"_38":142,"_13":143,"_33":34,"_35":144,"_24":25,"_136":-5,"_27":145},{"_43":131,"_32":28,"_30":31,"_132":-5,"_41":42,"_40":14,"_133":124,"_38":134,"_13":135,"_33":34,"_35":37,"_24":25,"_136":-5,"_27":137},"29ed8bf3-6bb2-4946-a197-656afe2cc16d","parentId","latest",["D",1782548868794],10,"label",[28],"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}",[139],"pulls","branches",1,"forks","envVars",{"_154":156,"_157":61},"connections",{"_154":61,"_155":61},"count","unfilledCount",2,"emptyCount",{"_43":138,"_32":139,"_30":140,"_132":-5,"_41":42,"_40":141,"_133":124,"_38":164,"_13":143,"_33":34,"_35":144,"_24":25,"_136":-5,"_161":165,"_27":166},{"_43":131,"_32":28,"_30":31,"_132":-5,"_41":42,"_40":14,"_133":124,"_38":160,"_13":135,"_33":34,"_35":37,"_24":25,"_136":-5,"_161":162,"_27":163},["D",1782548868794],"children",[],[28],["D",1782548686721],[],[139],["D",1781440587910],["D",1789522836959],{"_98":97,"_106":102},{"_98":97,"_99":100,"_101":102,"_18":55,"_103":104,"_105":25},{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"ctx",{"_80":-5,"_126":205,"_206":207,"_208":209,"_210":25,"_211":25,"_212":25,"_213":124,"_214":-5,"_215":-7,"_216":-7,"_217":61,"_218":25,"_219":25,"_220":-5,"_221":25,"_222":25,"_223":25,"_224":-5},"ENV",{"_176":177,"_178":179,"_180":88,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198,"_199":200,"_201":202,"_203":204},"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"]

Diff · v18