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: remove "connection.update" listener from ev instead of ws

Browse Source
This commit is contained in:
Adhiraj Singh
2021-11-19 21:47:51 +05:30
parent 3adeb2ed6b
commit 49da0e4e71
1 changed files with 3 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/Socket/socket.ts
View File

@@ -252,6 +252,7 @@ export const makeSocket = ({
logger.info({ error }, 'connection closed') logger.info({ error }, 'connection closed')
clearInterval(keepAliveReq) clearInterval(keepAliveReq)
clearInterval(qrTimer)
ws.removeAllListeners('close') ws.removeAllListeners('close')
ws.removeAllListeners('error') ws.removeAllListeners('error')
@@ -269,7 +270,7 @@ export const makeSocket = ({
date: new Date() date: new Date()
} }
}) })
ws.removeAllListeners('connection.update') ev.removeAllListeners('connection.update')
} }
const waitForSocketOpen = async() => { const waitForSocketOpen = async() => {
@@ -444,15 +445,6 @@ export const makeSocket = ({
} }
genPairQR() genPairQR()
const checkConnection = ({ connection }: ConnectionState) => {
if(connection === 'open' || connection === 'close') {
clearTimeout(qrTimer)
ev.off('connection.update', checkConnection)
}
}
ev.on('connection.update', checkConnection)
}) })
// device paired for the first time // device paired for the first time
// if device pairs successfully, the server asks to restart the connection // if device pairs successfully, the server asks to restart the connection
@@ -492,6 +484,7 @@ export const makeSocket = ({
await sendPassiveIq('active') await sendPassiveIq('active')
logger.info('opened connection to WA') logger.info('opened connection to WA')
clearTimeout(qrTimer) // will never happen in all likelyhood -- but just in case WA sends success on first try
ev.emit('connection.update', { connection: 'open' }) ev.emit('connection.update', { connection: 'open' })
}) })