vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-06-03 20:44:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor: share qqbot typing notify retry

Browse Source
This commit is contained in:
Vincent Koc
2026-05-29 11:58:12 +02:00
parent 9f28e8c5f4
commit bba28df9f7
1 changed files with 5 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
extensions/qqbot/src/engine/gateway/gateway.ts
View File

@@ -221,7 +221,7 @@ async function startTypingForEvent(
try {
const creds = accountToCreds(account);
const rawNotifyFn = createRawInputNotifyFn(account.appId);
try {
const sendNotifyAndStartKeepAlive = async () => {
const resp = await senderSendInputNotify({
openid: event.senderId,
creds,
@@ -238,26 +238,14 @@ async function startTypingForEvent(
);
keepAlive.start();
return { refIdx: resp.refIdx, keepAlive };
};
try {
return await sendNotifyAndStartKeepAlive();
} catch (notifyErr) {
const errMsg = String(notifyErr);
if (errMsg.includes("token") || errMsg.includes("401") || errMsg.includes("11244")) {
clearTokenCache(account.appId);
const resp = await senderSendInputNotify({
openid: event.senderId,
creds,
msgId: event.messageId,
inputSecond: TYPING_INPUT_SECOND,
});
const keepAlive = new TypingKeepAlive(
() => getAccessToken(account.appId, account.clientSecret),
() => clearTokenCache(account.appId),
rawNotifyFn,
event.senderId,
event.messageId,
log,
);
keepAlive.start();
return { refIdx: resp.refIdx, keepAlive };
return await sendNotifyAndStartKeepAlive();
}
throw notifyErr;
}