push.rocks/smartsocket
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(core): update

Browse Source
This commit is contained in:
Philipp Kunz 2022-01-20 17:14:11 +01:00
parent b34d7faec2
commit 01b5b3dc1a
1 changed files with 13 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
ts/smartsocket.classes.smartsocketclient.ts
View File

@ -184,28 +184,37 @@ export class SmartsocketClient {
return done.promise;
}
private disconnectRunning = false;
/**
* disconnect from the server
*/
public async disconnect(useAutoconnectSetting = false) {
if (this.eventStatus === 'disconnecting') {
if (this.disconnectRunning) {
return;
}
this.disconnectRunning = true;
this.updateStatus('disconnecting');
this.tagStoreSubscription?.unsubscribe();
if (this.socketConnection) {
await this.socketConnection.disconnect();
this.socketConnection = undefined;
logger.log('ok', 'disconnected socket!');
} else {
this.disconnectRunning = false;
logger.log('warn', 'tried to disconnect, without a SocketConnection');
return;
}
logger.log('warn', `disconnected from server ${this.remoteShortId}`);
this.remoteShortId = null;
if (this.autoReconnect && useAutoconnectSetting && this.eventStatus !== 'connecting') {
this.updateStatus('connecting');
this.tryDebouncedReconnect();
} else if (this.eventStatus === 'connected') {
this.updateStatus('disconnected');
await this.tryDebouncedReconnect();
this.disconnectRunning = false;
} else {
this.disconnectRunning = false;
}
}