Skip to content

feat: 处理任务时给排队消息一个反馈 #39

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
1359484419 wants to merge 1 commit into
base: main
Choose a base branch
from
Open

feat: 处理任务时给排队消息一个反馈 #39

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
13 changes: 13 additions & 0 deletions src/main.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -270,6 +270,8 @@ async function runDaemon(): Promise<void> {
// -- Message queue for serial processing --
const messageQueue: WeixinMessage[] = [];
let processingQueue = false;
// 一波忙碌期内只发一次排队提示，避免用户连发消息时被刷屏
let queueNoticeSent = false;

async function drainQueue(): Promise<void> {
if (processingQueue) return;
Expand All @@ -279,6 +281,7 @@ async function runDaemon(): Promise<void> {
await handleMessage(msg, account!, session, sessionStore, sender, config, sharedCtx, activeControllers, messageQueue);
}
processingQueue = false;
queueNoticeSent = false; // 队列已清空，下一波忙碌可再次提示
}

// -- Wire the monitor callbacks --
Expand All @@ -305,6 +308,16 @@ async function runDaemon(): Promise<void> {
const callbacks: MonitorCallbacks = {
onMessage: async (msg: WeixinMessage) => {
if (handlePriorityCommand(msg)) return;
// 已有任务在处理时，新消息会进队列等待——立刻给一个排队反馈，
// 避免用户对着空白聊天框干等、误以为消息丢了。一波忙碌期只提示一次。
if (processingQueue && !queueNoticeSent && msg.message_type === MessageType.USER && msg.from_user_id) {
queueNoticeSent = true;
sender.sendText(
msg.from_user_id,
msg.context_token ?? '',
'⏳ 正在处理上一条消息，你后面发的我都收到了，会处理完依次回复。',
).catch(() => {});
}
messageQueue.push(msg);
drainQueue();
},
Expand Down