let5see/clawdbot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: clean up web inbox listeners on close

Browse Source
This commit is contained in:
Peter Steinberger
2025-12-26 09:27:01 +00:00
parent f5d8876384
commit ffe9a2435b
1 changed files with 22 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
src/web/inbound.ts
View File

@@ -115,9 +115,12 @@ export async function monitorWebInbox(options: {
} }
}; };
sock.ev.on("messages.upsert", async (upsert) => { const handleMessagesUpsert = async (upsert: {
type?: string;
messages?: Array<import("@whiskeysockets/baileys").WAMessage>;
}) => {
if (upsert.type !== "notify") return; if (upsert.type !== "notify") return;
for (const msg of upsert.messages) { for (const msg of upsert.messages ?? []) {
const id = msg.key?.id ?? undefined; const id = msg.key?.id ?? undefined;
// De-dupe on message id; Baileys can emit retries. // De-dupe on message id; Baileys can emit retries.
if (id && seen.has(id)) continue; if (id && seen.has(id)) continue;
@@ -295,11 +298,12 @@ export async function monitorWebInbox(options: {
); );
} }
} }
}); };
sock.ev.on("messages.upsert", handleMessagesUpsert);
sock.ev.on( const handleConnectionUpdate = (
"connection.update", update: Partial<import("@whiskeysockets/baileys").ConnectionState>,
(update: Partial<import("@whiskeysockets/baileys").ConnectionState>) => { ) => {
try { try {
if (update.connection === "close") { if (update.connection === "close") {
const status = getStatusCode(update.lastDisconnect?.error); const status = getStatusCode(update.lastDisconnect?.error);
@@ -320,12 +324,22 @@ export async function monitorWebInbox(options: {
error: err, error: err,
}); });
} }
}, };
); sock.ev.on("connection.update", handleConnectionUpdate);
return { return {
close: async () => { close: async () => {
try { try {
if (typeof sock.ev.off === "function") {
sock.ev.off("messages.upsert", handleMessagesUpsert);
sock.ev.off("connection.update", handleConnectionUpdate);
} else {
sock.ev.removeListener?.("messages.upsert", handleMessagesUpsert);
sock.ev.removeListener?.(
"connection.update",
handleConnectionUpdate,
);
}
sock.ws?.close(); sock.ws?.close();
} catch (err) { } catch (err) {
logVerbose(`Socket close failed: ${String(err)}`); logVerbose(`Socket close failed: ${String(err)}`);