33 lines
1.3 KiB
JavaScript
33 lines
1.3 KiB
JavaScript
// dsh-plugin-mcn HTTP 路由工具(拆分自 index.js)
|
||||
|
|
|
|||
|
|
function parseQuery(url) {
|
|||
|
|
const u = new URL(url, "http://localhost");
|
|||
|
|
const out = {};
|
|||
|
|
for (const [k, v] of u.searchParams) out[k] = v;
|
|||
|
|
return out;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
function json(res, status, body) {
|
|||
|
|
res.writeHead(status, { "Content-Type": "application/json; charset=utf-8" });
|
|||
|
|
res.end(JSON.stringify(body));
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
function readBody(req) {
|
|||
|
|
return new Promise((resolvePromise, reject) => {
|
|||
|
|
// 收集 Buffer 后一次性按 UTF-8 解码:逐 chunk 直接拼字符串会独立解码各 chunk,
|
|||
|
|
// 多字节字符横跨 chunk 边界时被损坏为 U+FFFD(大体积 data 导入必现)
|
|||
|
|
const chunks = [];
|
|||
|
|
req.on("data", (c) => { chunks.push(c); });
|
|||
|
|
req.on("end", () => {
|
|||
|
|
try {
|
|||
|
|
const data = Buffer.concat(chunks).toString("utf8");
|
|||
|
|
resolvePromise(data ? JSON.parse(data) : {});
|
|||
|
|
} catch (e) {
|
|||
|
|
reject(new Error("请求体 JSON 解析失败:请以 UTF-8 发送 JSON。若用 PowerShell 调用,勿用 Invoke-RestMethod 直接传含中文的 -Body 字符串(Windows PowerShell 5.1 会按 GBK 编码导致此错误),请改用 curl.exe --data-binary @文件 或 [System.Text.Encoding]::UTF8.GetBytes() 字节体"));
|
|||
|
|
}
|
|||
|
|
});
|
|||
|
|
req.on("error", reject);
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
export { parseQuery, json, readBody };
|