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

Update 3.Connect.ts

Browse Source
This commit is contained in:
Adhiraj
2020-08-25 22:21:49 +05:30
parent 07076fd227
commit 11b6e3b1a3
1 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/WAConnection/3.Connect.ts
View File

@@ -16,7 +16,7 @@ export class WAConnection extends Base {
this.emit ('connecting') this.emit ('connecting')
const { ws, cancel } = Utils.openWebSocketConnection (5000, typeof options?.retryOnNetworkErrors === 'undefined' ? true : options?.retryOnNetworkErrors) const { ws, cancel } = Utils.openWebSocketConnection (5000, typeof options?.retryOnNetworkErrors === 'undefined' ? true : options?.retryOnNetworkErrors)
const promise: Promise<void> = Utils.promiseTimeout(options?.timeoutMs, (resolve, reject) => { const promise = Utils.promiseTimeout(options?.timeoutMs, (resolve, reject) => {
ws ws
.then (conn => this.conn = conn) .then (conn => this.conn = conn)
.then (() => this.conn.on('message', data => this.onMessageRecieved(data as any))) .then (() => this.conn.on('message', data => this.onMessageRecieved(data as any)))
@@ -29,11 +29,12 @@ export class WAConnection extends Base {
this.conn.on ('close', () => this.unexpectedDisconnect ('close')) this.conn.on ('close', () => this.unexpectedDisconnect ('close'))
}) })
.then (resolve) .then (resolve)
.catch (err => { .catch (reject)
cancel ()
reject (err)
})
}) })
.catch (err => {
cancel ()
throw err
}) as Promise<void>
try { try {
const tasks = [promise] const tasks = [promise]