franpcode/Baileys
1
0
Fork 0
mirror of https://github.com/FranP-code/Baileys.git synced 2025-10-13 00:32:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #1368 from WhiskeySockets/fix-catch-unhandled-timeout-error

Browse Source
This commit is contained in:
Cassio Santos
2025-05-01 11:55:56 -03:00
committed by GitHub
parent a4338fac12 6d4ce2cb18
commit 5ee939418c
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/Socket/socket.ts
View File

@@ -187,7 +187,7 @@ export const makeSocket = (config: SocketConfig) => {
let onRecv: (json) => void
let onErr: (err) => void
try {
return await promiseTimeout<T>(timeoutMs,
const result = await promiseTimeout<T>(timeoutMs,
(resolve, reject) => {
onRecv = resolve
onErr = err => {
@@ -199,6 +199,8 @@ export const makeSocket = (config: SocketConfig) => {
ws.off('error', onErr)
},
)
return result as any
} finally {
ws.off(`TAG:${msgId}`, onRecv!)
ws.off('close', onErr!) // if the socket closes, you'll never receive the message
@@ -213,11 +215,12 @@ export const makeSocket = (config: SocketConfig) => {
}
const msgId = node.attrs.id
const wait = waitForMessage(msgId, timeoutMs)
await sendNode(node)
const [result] = await Promise.all([
waitForMessage(msgId, timeoutMs),
sendNode(node)
])
const result = await (wait as Promise<BinaryNode>)
if('tag' in result) {
assertNodeErrorFree(result)
}