fix(account-state): Only swiths to disconnected if the account was pr…

…eviously connected
postalsys · Oct 25, 2024 · 4f56fe3 · 4f56fe3
1 parent c25413f
commit 4f56fe3
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/lib/email-client/gmail-client.js b/lib/email-client/gmail-client.js
@@ -315,7 +315,7 @@ class GmailClient extends BaseClient {
         clearTimeout(this.renewWatchTimer);
         this.closed = true;
 
-        if (this.state !== 'disconnected') {
+        if (['init', 'connecting', 'syncing', 'connected'].includes(this.state)) {
             this.state = 'disconnected';
             await this.setStateVal();
             await emitChangeEvent(this.logger, this.account, 'state', this.state);
@@ -328,7 +328,7 @@ class GmailClient extends BaseClient {
         clearTimeout(this.renewWatchTimer);
         this.closed = true;
 
-        if (this.state !== 'disconnected') {
+        if (['init', 'connecting', 'syncing', 'connected'].includes(this.state)) {
             this.state = 'disconnected';
             await this.setStateVal();
             await emitChangeEvent(this.logger, this.account, 'state', this.state);

diff --git a/lib/email-client/imap-client.js b/lib/email-client/imap-client.js
@@ -1086,7 +1086,7 @@ class IMAPClient extends BaseClient {
                 await this.redis.hSetExists(this.getAccountKey(), 'connections', this.connections.size.toString());
                 imapClient?.log.info({ msg: 'Connection closed', type: 'imapClient', account: this.account, disabled: imapClient.disabled });
 
-                if (this.state !== 'disconnected') {
+                if (['init', 'connecting', 'syncing', 'connected'].includes(this.state)) {
                     this.state = 'disconnected';
                     await this.setStateVal();
                     await emitChangeEvent(this.logger, this.account, 'state', this.state);

diff --git a/lib/email-client/outlook-client.js b/lib/email-client/outlook-client.js
@@ -216,7 +216,7 @@ class OutlookClient extends BaseClient {
         clearTimeout(this.renewWatchTimer);
         this.closed = true;
 
-        if (this.state !== 'disconnected') {
+        if (['init', 'connecting', 'syncing', 'connected'].includes(this.state)) {
             this.state = 'disconnected';
             await this.setStateVal();
             await emitChangeEvent(this.logger, this.account, 'state', this.state);
@@ -229,7 +229,7 @@ class OutlookClient extends BaseClient {
         clearTimeout(this.renewWatchTimer);
         this.closed = true;
 
-        if (this.state !== 'disconnected') {
+        if (['init', 'connecting', 'syncing', 'connected'].includes(this.state)) {
             this.state = 'disconnected';
             await this.setStateVal();
             await emitChangeEvent(this.logger, this.account, 'state', this.state);