resubcribe on reconnect

src/app/models/rochet-chat-cliente-service.ts

@@ -1,5 +1,5 @@
 export interface wsCallbacksParams {
-    type: 'Offline' | 'Online' | 'Open' | 'Onmessage',
+    type: 'Offline' | 'Online' | 'Open' | 'Onmessage' | 'reConnect',
     funx: Function
     runOnces?: boolean
     requestId?: string

src/app/services/chat/ws-chat-methods.service.ts

@@ -54,6 +54,18 @@ export class WsChatMethodsService {
 
     })()
 
+
+    /**
+     * @description when the phone is in the background for a long time it could disconnects from the socket then the socket reconnects automatically,
+     *  when the connection is lost the subscribe is also lost, so we have to subscribe again when reconnection is establish.
+     */
+    this.WsChatService.registerCallback({
+      type: 'reConnect',
+      funx: ()=>{
+        this.subscribeToRoom()
+      }
+    })
+
   }
 
   openRoom(roomId) {
@@ -116,11 +128,17 @@ export class WsChatMethodsService {
     this.loadingWholeList = false
   }
 
+  /**
+   * @description sort room list by last message date
+   */
   sortRoomList() {
     this._dm = this.sortService.sortDate(this._dm,'_updatedAt').reverse()
     this._group = this.sortService.sortDate(this._group,'_updatedAt').reverse()
   }
 
+  /**
+   * @description subscribe all room
+   */
   subscribeToRoom() {
 
     for (const id in this.dm) {

src/app/services/chat/ws-chat.service.ts

@@ -572,6 +572,7 @@ updateRoomEventss(roomId, collection:string, funx: Function, ) {
   private socket!: WebSocket;
   private wsMsgQueue : {[key: string]:  msgQueue} = {}
   private wsCallbacks: {[key: string]:  wsCallbacksParams} = {}
+  private wsReconnect = 0
 
   private ws = {
     connected: false,
@@ -592,9 +593,26 @@ updateRoomEventss(roomId, collection:string, funx: Function, ) {
     },
     onopen:()=> {
       this.ws.connected = true
+      
       console.log('================== welcome to socket server =====================')
 
       this.ws.wsMsgQueue()
+
+      if(this.wsReconnect >= 1) {
+        for (const [key, value] of Object.entries(this.wsCallbacks)) {
+          if(value.type== 'reConnect') {
+            const dontRepeat = value.funx()
+  
+            if(dontRepeat) {
+              delete this.wsCallbacks[key]
+            }
+  
+          }
+  
+        }
+      }
+
+      this.wsReconnect++;
     },
     wsMsgQueue:()=> {