68 lines
2.0 KiB
JavaScript
68 lines
2.0 KiB
JavaScript
/**
|
|
* AIBOT 长连接传输壳（无业务）。
|
|
*
|
|
* 本文件职责：
|
|
* - 当 WECOM_AIBOT_ENABLED=true 时启动「帧循环」占位（默认只心跳日志，不连真 Bot SDK）
|
|
* - 收到已规范化的入站帧时转发到同进程 forwardToAgent（由 server.cjs 注入）
|
|
*
|
|
* 禁止：写工单/六态/Graph；并存期勿与现网 8813 双连同一 Bot。
|
|
* 正式 SDK 接入：替换 startLongConnectionLoop 内的 connect 段，保持只做传输。
|
|
*/
|
|
|
|
"use strict";
|
|
|
|
/**
|
|
* @param {object} opts
|
|
* @param {boolean} opts.enabled
|
|
* @param {(payloadText: string) => Promise<object>} opts.forwardToAgent
|
|
* @param {() => boolean} [opts.shouldStop]
|
|
*/
|
|
function startLongConnectionLoop(opts) {
|
|
const enabled = !!opts.enabled;
|
|
const forwardToAgent = opts.forwardToAgent;
|
|
const shouldStop = opts.shouldStop || (() => false);
|
|
|
|
if (!enabled) {
|
|
// eslint-disable-next-line no-console
|
|
console.log("[aibot-long-connection] 未启用（WECOM_AIBOT_ENABLED=false），跳过帧循环壳");
|
|
return { stop: () => {} };
|
|
}
|
|
|
|
// eslint-disable-next-line no-console
|
|
console.warn(
|
|
"[aibot-long-connection] 帧循环壳已启动：当前不连企微 Bot SDK，仅心跳；" +
|
|
"请确认现网桥已停，避免双连"
|
|
);
|
|
|
|
let timer = null;
|
|
const tick = () => {
|
|
if (shouldStop()) {
|
|
return;
|
|
}
|
|
// 心跳：证明传输壳在跑；无帧可转发
|
|
// eslint-disable-next-line no-console
|
|
console.log("[aibot-long-connection] heartbeat shell (no SDK frame)");
|
|
};
|
|
timer = setInterval(tick, 60000);
|
|
tick();
|
|
|
|
return {
|
|
stop: () => {
|
|
if (timer) {
|
|
clearInterval(timer);
|
|
timer = null;
|
|
}
|
|
},
|
|
/**
|
|
* 测试注入：模拟 SDK 收到一帧已解析 JSON，只做转发。
|
|
* @param {object|string} frame
|
|
*/
|
|
injectFrameForTest: async (frame) => {
|
|
const text = typeof frame === "string" ? frame : JSON.stringify(frame);
|
|
return forwardToAgent(text);
|
|
},
|
|
};
|
|
}
|
|
|
|
module.exports = { startLongConnectionLoop };
|