改为长链接
This commit is contained in:
+8
-3
@@ -2,6 +2,8 @@ const app = require('./server');
|
||||
const config = require('./config');
|
||||
const logger = require('./utils/logger');
|
||||
const synology = require('./services/synology');
|
||||
const { startWsClient, setEventHandler } = require('./services/feishu-ws');
|
||||
const { processEvent } = require('./routes/feishu-event');
|
||||
|
||||
async function start() {
|
||||
logger.info('=== 文件传输自动化系统启动 ===');
|
||||
@@ -15,12 +17,15 @@ async function start() {
|
||||
logger.warn(`群晖 NAS 连接失败(将在首次使用时重试): ${e.message}`);
|
||||
}
|
||||
|
||||
// 启动 HTTP 服务
|
||||
// 启动飞书 WebSocket 长连接(无需公网IP,主动连出去接收事件)
|
||||
setEventHandler(processEvent);
|
||||
startWsClient();
|
||||
|
||||
// HTTP 服务(管理后台 + 健康检查)
|
||||
app.listen(config.port, () => {
|
||||
logger.info(`服务已启动: http://0.0.0.0:${config.port}`);
|
||||
logger.info(`管理后台: http://0.0.0.0:${config.port}/admin`);
|
||||
logger.info(`飞书事件回调: http://0.0.0.0:${config.port}/api/feishu/event`);
|
||||
logger.info(`健康检查: http://0.0.0.0:${config.port}/health`);
|
||||
logger.info('飞书事件: WebSocket 长连接模式(无需配置回调URL)');
|
||||
});
|
||||
}
|
||||
|
||||
|
||||
@@ -208,3 +208,4 @@ async function processGroupPermission(approvalCode, instanceId) {
|
||||
}
|
||||
|
||||
module.exports = router;
|
||||
module.exports.processEvent = processEvent;
|
||||
|
||||
@@ -0,0 +1,43 @@
|
||||
const lark = require('@larksuiteoapi/node-sdk');
|
||||
const config = require('../config');
|
||||
const logger = require('../utils/logger');
|
||||
|
||||
let eventHandler = null;
|
||||
|
||||
function setEventHandler(handler) {
|
||||
eventHandler = handler;
|
||||
}
|
||||
|
||||
/**
|
||||
* 启动飞书 WebSocket 长连接
|
||||
* 无需公网IP,主动连接飞书服务器接收事件
|
||||
*/
|
||||
function startWsClient() {
|
||||
const wsClient = new lark.WSClient({
|
||||
appId: config.feishu.appId,
|
||||
appSecret: config.feishu.appSecret,
|
||||
loggerLevel: lark.LoggerLevel.info,
|
||||
});
|
||||
|
||||
wsClient.start({
|
||||
eventDispatcher: new lark.EventDispatcher({}).register({
|
||||
'approval_instance': async (data) => {
|
||||
logger.info('[飞书WS] 收到审批事件:', JSON.stringify(data).substring(0, 200));
|
||||
if (eventHandler) {
|
||||
try {
|
||||
await eventHandler({
|
||||
header: { event_type: 'approval_instance' },
|
||||
event: data,
|
||||
});
|
||||
} catch (err) {
|
||||
logger.error(`[飞书WS] 事件处理失败: ${err.message}`);
|
||||
}
|
||||
}
|
||||
},
|
||||
}),
|
||||
});
|
||||
|
||||
logger.info('[飞书WS] 长连接已启动,等待审批事件...');
|
||||
}
|
||||
|
||||
module.exports = { startWsClient, setEventHandler };
|
||||
Reference in New Issue
Block a user