sync lost connecting

Author: clairton

src/services/auto_connect.ts

@@ -16,6 +16,7 @@ export const autoConnect = async (
   onNewLogin: OnNewLogin,
 ) => {
   try {
+    await sessionStore.syncConnecting()
     const phones = await sessionStore.getPhones()
     logger.info(`${phones.length} phones to verify if is auto connect`)
     for (let i = 0, j = phones.length; i < j; i++) {

src/services/redis.ts

@@ -135,7 +135,7 @@ const authKey = (phone: string) => {
   return `${BASE_KEY}auth:${phone}`
 }
 
-const sessionStatusKey = (phone: string) => {
+export const sessionStatusKey = (phone: string) => {
   return `${BASE_KEY}status:${phone}`
 }
 

src/services/session_store.ts

@@ -32,4 +32,6 @@ export abstract class SessionStore {
   async isStatusIsDisconnect(phone: string) {
     return await this.getStatus(phone) == 'disconnected'
   }
+
+  async syncConnecting() {}
 }

src/services/session_store_redis.ts

@@ -1,15 +1,16 @@
 import { SessionStore, sessionStatus } from './session_store'
-import { configKey, redisKeys, getSessionStatus, setSessionStatus } from './redis'
+import { configKey, redisKeys, getSessionStatus, setSessionStatus, sessionStatusKey, redisGet, getConfig } from './redis'
 import logger from './logger'
 
-const toReplace = configKey('')
+const toReplaceConfig = configKey('')
+const toReplaceStatus = sessionStatusKey('')
 
 export class SessionStoreRedis extends SessionStore {
   async getPhones(): Promise<string[]> {
     try {
       const pattern = configKey('*')
       const keys = await redisKeys(pattern)
-      return keys.map((key: string) => key.replace(toReplace, ''))
+      return keys.map((key: string) => key.replace(toReplaceConfig, ''))
     } catch (error) {
       logger.error(error, 'Erro on get configs')
       throw error
@@ -24,4 +25,23 @@ export class SessionStoreRedis extends SessionStore {
     logger.info(`Session status ${phone} change from ${await this.getStatus(phone)} to ${status}`)
     return setSessionStatus(phone, status)
   }
+
+  async syncConnecting() {
+    logger.info(`Sync lost connecting!`)
+    try {
+      const pattern = sessionStatusKey('*')
+      const keys = await redisKeys(pattern)
+      for (let i = 0; i < keys.length; i++) {
+        const key = keys[i];
+        const phone = key.replace(toReplaceStatus, '')
+        if ((await redisGet(key)) == 'connecting' || !getConfig(phone) ) {
+          logger.info(`Sync ${phone} lost connecting!`)
+          await this.setStatus(phone, 'disconnected')
+        }
+      }
+    } catch (error) {
+      logger.error(error, 'Error on sync lost connecting')
+      throw error
+    }
+  }
 }