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

chore: update legacy connection close msgs

Browse Source
This commit is contained in:
Adhiraj Singh
2021-12-20 12:37:18 +05:30
parent dbed7fef74
commit 258b2f2747
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/LegacySocket/auth.ts
View File

@@ -34,11 +34,11 @@ const makeAuthSocket = (config: LegacySocketConfig) => {
}) })
// add close listener // add close listener
ws.on('ws-close', (error: Boom | Error) => { ws.on('ws-close', (error: Boom | Error) => {
logger.info({ error }, 'Closed connection to WhatsApp') logger.info({ error }, 'closed connection to WhatsApp')
initTimeout && clearTimeout(initTimeout) initTimeout && clearTimeout(initTimeout)
// if no reconnects occur // if no reconnects occur
// send close event // send close event
updateState({ updateState({
connection: 'close', connection: 'close',
qr: undefined, qr: undefined,
lastDisconnect: { lastDisconnect: {

8
src/LegacySocket/socket.ts
View File

@@ -96,7 +96,7 @@ export const makeSocket = ({
return tag return tag
} }
const end = (error: Error | undefined) => { const end = (error: Error | undefined) => {
logger.debug({ error }, 'connection closed') logger.info({ error }, 'connection closed')
ws.removeAllListeners('close') ws.removeAllListeners('close')
ws.removeAllListeners('error') ws.removeAllListeners('error')
@@ -213,7 +213,7 @@ export const makeSocket = ({
*/ */
const waitForMessage = (tag: string, requiresPhoneConnection: boolean, timeoutMs?: number) => { const waitForMessage = (tag: string, requiresPhoneConnection: boolean, timeoutMs?: number) => {
if(ws.readyState !== ws.OPEN) { if(ws.readyState !== ws.OPEN) {
throw new Boom('Connection Closed', { statusCode: DisconnectReason.connectionClosed }) throw new Boom('Connection not open', { statusCode: DisconnectReason.connectionClosed })
} }
let cancelToken = () => { } let cancelToken = () => { }
@@ -228,7 +228,7 @@ export const makeSocket = ({
(resolve, reject) => { (resolve, reject) => {
onRecv = resolve onRecv = resolve
onErr = err => { onErr = err => {
reject(err || new Boom('Connection Closed', { statusCode: DisconnectReason.connectionClosed })) reject(err || new Boom('Intentional Close', { statusCode: DisconnectReason.connectionClosed }))
} }
cancelToken = () => onErr(new Boom('Cancelled', { statusCode: 500 })) cancelToken = () => onErr(new Boom('Cancelled', { statusCode: 500 }))
@@ -311,7 +311,7 @@ export const makeSocket = ({
const waitForSocketOpen = async() => { const waitForSocketOpen = async() => {
if(ws.readyState === ws.OPEN) return if(ws.readyState === ws.OPEN) return
if(ws.readyState === ws.CLOSED || ws.readyState === ws.CLOSING) { if(ws.readyState === ws.CLOSED || ws.readyState === ws.CLOSING) {
throw new Boom('Connection Closed', { statusCode: DisconnectReason.connectionClosed }) throw new Boom('Connection Already Closed', { statusCode: DisconnectReason.connectionClosed })
} }
let onOpen: () => void let onOpen: () => void
let onClose: (err: Error) => void let onClose: (err: Error) => void