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

fix: prevent duplicate frame emit

Browse Source
This commit is contained in:
Adhiraj Singh
2022-04-23 12:20:18 +05:30
parent b3937b8852
commit 21f163d6cf
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/Socket/socket.ts
View File

@@ -254,7 +254,9 @@ export const makeSocket = ({
// reset ping timeout // reset ping timeout
lastDateRecv = new Date() lastDateRecv = new Date()
ws.emit('frame', frame) let anyTriggered = false
anyTriggered = ws.emit('frame', frame)
// if it's a binary node // if it's a binary node
if(!(frame instanceof Uint8Array)) { if(!(frame instanceof Uint8Array)) {
const msgId = frame.attrs.id const msgId = frame.attrs.id
@@ -263,9 +265,8 @@ export const makeSocket = ({
logger.trace({ msgId, fromMe: false, frame }, 'communication') logger.trace({ msgId, fromMe: false, frame }, 'communication')
} }
let anyTriggered = false
/* Check if this is a response to a message we sent */ /* Check if this is a response to a message we sent */
anyTriggered = ws.emit(`${DEF_TAG_PREFIX}${msgId}`, frame) anyTriggered = ws.emit(`${DEF_TAG_PREFIX}${msgId}`, frame) || anyTriggered
/* Check if this is a response to a message we are expecting */ /* Check if this is a response to a message we are expecting */
const l0 = frame.tag const l0 = frame.tag
const l1 = frame.attrs || { } const l1 = frame.attrs || { }
@@ -278,7 +279,6 @@ export const makeSocket = ({
}) })
anyTriggered = ws.emit(`${DEF_CALLBACK_PREFIX}${l0},,${l2}`, frame) || anyTriggered anyTriggered = ws.emit(`${DEF_CALLBACK_PREFIX}${l0},,${l2}`, frame) || anyTriggered
anyTriggered = ws.emit(`${DEF_CALLBACK_PREFIX}${l0}`, frame) || anyTriggered anyTriggered = ws.emit(`${DEF_CALLBACK_PREFIX}${l0}`, frame) || anyTriggered
anyTriggered = ws.emit('frame', frame) || anyTriggered
if(!anyTriggered && logger.level === 'debug') { if(!anyTriggered && logger.level === 'debug') {
logger.debug({ unhandled: true, msgId, fromMe: false, frame }, 'communication recv') logger.debug({ unhandled: true, msgId, fromMe: false, frame }, 'communication recv')