重构: 将 TypeScript 转为 JavaScript 并优化项目文件结构
- 将 src/IpcManager.ts 和 src/IpcUi.ts 手动转写为干净的 JavaScript,消除编译产物中的 polyfill 代码 - 移动 main.js、scene-script.js、mcp-proxy.js 至 src/ 目录,统一源码管理 - 移动 DEVELOPMENT.md、IPC_MESSAGES.md、UPDATE_LOG.md、注意事项.md 至 docs/ 目录 - 删除 dist/ 编译产物目录和 tsconfig.json - 更新 package.json 入口路径、所有模块引用路径 - 更新 README.md 和 DEVELOPMENT.md 中的架构说明、文件路径引用和项目规范 - 更新 .gitignore 启用 dist 忽略规则
This commit is contained in:
150
src/mcp-proxy.js
Normal file
150
src/mcp-proxy.js
Normal file
@@ -0,0 +1,150 @@
|
||||
/**
|
||||
* MCP 桥接代理脚本
|
||||
* 负责在标准 MCP 客户端 (stdin/stdout) 与 Cocos Creator 插件 (HTTP) 之间转发请求。
|
||||
*/
|
||||
|
||||
const http = require("http");
|
||||
|
||||
/**
|
||||
* 当前 Cocos Creator 插件监听的端口
|
||||
* 支持通过环境变量 MCP_BRIDGE_PORT 或命令行参数指定端口
|
||||
* @type {number}
|
||||
*/
|
||||
const COCOS_PORT = parseInt(process.env.MCP_BRIDGE_PORT || process.argv[2] || "3456", 10);
|
||||
|
||||
/**
|
||||
* 发送调试日志到标准的错误输出流水
|
||||
* @param {string} msg 日志消息
|
||||
*/
|
||||
function debugLog(msg) {
|
||||
process.stderr.write(`[代理调试] ${msg}\n`);
|
||||
}
|
||||
|
||||
// 监听标准输入以获取 MCP 请求
|
||||
process.stdin.on("data", (data) => {
|
||||
const lines = data.toString().split("\n");
|
||||
lines.forEach((line) => {
|
||||
if (!line.trim()) return;
|
||||
try {
|
||||
const request = JSON.parse(line);
|
||||
handleRequest(request);
|
||||
} catch (e) {
|
||||
// 忽略非 JSON 输入
|
||||
}
|
||||
});
|
||||
});
|
||||
|
||||
/**
|
||||
* 处理 JSON-RPC 请求
|
||||
* @param {Object} req RPC 请求对象
|
||||
*/
|
||||
function handleRequest(req) {
|
||||
const { method, id, params } = req;
|
||||
|
||||
// 处理握手初始化
|
||||
if (method === "initialize") {
|
||||
sendToAI({
|
||||
jsonrpc: "2.0",
|
||||
id: id,
|
||||
result: {
|
||||
protocolVersion: "2024-11-05",
|
||||
capabilities: { tools: {} },
|
||||
serverInfo: { name: "cocos-bridge", version: "1.0.0" },
|
||||
},
|
||||
});
|
||||
return;
|
||||
}
|
||||
|
||||
// 获取工具列表
|
||||
if (method === "tools/list") {
|
||||
forwardToCocos("/list-tools", null, id, "GET");
|
||||
return;
|
||||
}
|
||||
|
||||
// 执行具体工具
|
||||
if (method === "tools/call") {
|
||||
forwardToCocos(
|
||||
"/call-tool",
|
||||
{
|
||||
name: params.name,
|
||||
arguments: params.arguments,
|
||||
},
|
||||
id,
|
||||
"POST",
|
||||
);
|
||||
return;
|
||||
}
|
||||
|
||||
// 默认空响应
|
||||
if (id !== undefined) sendToAI({ jsonrpc: "2.0", id: id, result: {} });
|
||||
}
|
||||
|
||||
/**
|
||||
* 将请求通过 HTTP 转发给 Cocos Creator 插件
|
||||
* @param {string} path API 路径
|
||||
* @param {Object|null} payload 发送的数据体
|
||||
* @param {string|number} id RPC 请求标识符
|
||||
* @param {string} method HTTP 方法 (默认 POST)
|
||||
*/
|
||||
function forwardToCocos(path, payload, id, method = "POST") {
|
||||
const postData = payload ? JSON.stringify(payload) : "";
|
||||
|
||||
const options = {
|
||||
hostname: "127.0.0.1",
|
||||
port: COCOS_PORT,
|
||||
path: path,
|
||||
method: method,
|
||||
headers: { "Content-Type": "application/json" },
|
||||
};
|
||||
|
||||
if (postData) {
|
||||
options.headers["Content-Length"] = Buffer.byteLength(postData);
|
||||
}
|
||||
|
||||
const request = http.request(options, (res) => {
|
||||
let resData = "";
|
||||
res.on("data", (d) => (resData += d));
|
||||
res.on("end", () => {
|
||||
try {
|
||||
const cocosRes = JSON.parse(resData);
|
||||
|
||||
// 检查关键字段,确保 Cocos 插件返回了期望的数据格式
|
||||
if (path === "/list-tools" && !cocosRes.tools) {
|
||||
debugLog(`致命错误: Cocos 未返回工具列表。接收内容: ${resData}`);
|
||||
sendError(id, -32603, "Cocos 响应无效:缺少 tools 数组");
|
||||
} else {
|
||||
sendToAI({ jsonrpc: "2.0", id: id, result: cocosRes });
|
||||
}
|
||||
} catch (e) {
|
||||
debugLog(`JSON 解析错误。Cocos 发送内容: ${resData}`);
|
||||
sendError(id, -32603, "Cocos 返回了非 JSON 数据");
|
||||
}
|
||||
});
|
||||
});
|
||||
|
||||
request.on("error", (e) => {
|
||||
debugLog(`Cocos 插件已离线: ${e.message}`);
|
||||
sendError(id, -32000, "Cocos 插件离线");
|
||||
});
|
||||
|
||||
if (postData) request.write(postData);
|
||||
request.end();
|
||||
}
|
||||
|
||||
/**
|
||||
* 将结果发送给 AI (通过标准输出)
|
||||
* @param {Object} obj 结果对象
|
||||
*/
|
||||
function sendToAI(obj) {
|
||||
process.stdout.write(JSON.stringify(obj) + "\n");
|
||||
}
|
||||
|
||||
/**
|
||||
* 发送 RPC 错误响应
|
||||
* @param {string|number} id RPC 请求标识符
|
||||
* @param {number} code 错误码
|
||||
* @param {string} message 错误消息
|
||||
*/
|
||||
function sendError(id, code, message) {
|
||||
sendToAI({ jsonrpc: "2.0", id: id, error: { code, message } });
|
||||
}
|
||||
Reference in New Issue
Block a user