diff --git a/src/Connection/socket.ts b/src/Connection/socket.ts index 0c65f2d..a192638 100644 --- a/src/Connection/socket.ts +++ b/src/Connection/socket.ts @@ -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