undefined onErr bug fix

This commit is contained in:
Adhiraj Singh
2021-09-09 20:54:33 +05:30
parent c195e999f1
commit 9cba28e891

View File

@@ -213,10 +213,6 @@ export const makeSocket = ({
let onRecv: (json) => void
let onErr: (err) => void
let cancelPhoneChecker: () => void
if(requiresPhoneConnection) {
startPhoneCheckInterval()
cancelPhoneChecker = exitQueryIfResponseNotExpected(tag, onErr)
}
try {
const result = await promiseTimeout(timeoutMs,
(resolve, reject) => {
@@ -224,6 +220,11 @@ export const makeSocket = ({
onErr = err => {
reject(err || new Boom('Connection Closed', { statusCode: DisconnectReason.connectionClosed }))
}
if(requiresPhoneConnection) {
startPhoneCheckInterval()
cancelPhoneChecker = exitQueryIfResponseNotExpected(tag, onErr)
}
ws.on(`TAG:${tag}`, onRecv)
ws.on('ws-close', onErr) // if the socket closes, you'll never receive the message