message

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

@@ -47,13 +47,8 @@ export class ChatMethodsService {
     return this.chatService.sendMessage(body)
   }
 
-
   deleteMessage(body) {
     return this.chatService.deleteMessage(body)
   }
-
-
-
-
   
 }

src/app/services/chat/message.service.ts

@@ -12,6 +12,7 @@ import { MessageModel, DeleteMessageModel } from '../../models/beast-orm'
 import { AESEncrypt } from '../aesencrypt.service'
 import { HttpClient, HttpEventType } from '@angular/common/http';
 import { AttachmentsService } from 'src/app/services/attachments.service';
+import { NetworkServiceService , ConnectionStatus} from 'src/app/services/network-service.service';
 
 @Injectable({
   providedIn: 'root'
@@ -62,7 +63,8 @@ export class MessageService {
     private ChatStorageService: ChatStorageService,
     private ChatMethodsService: ChatMethodsService,
     private AESEncrypt: AESEncrypt,
-    private AttachmentsService: AttachmentsService,) {
+    private AttachmentsService: AttachmentsService,
+    private NetworkServiceService: NetworkServiceService) {
   }
 
   setData({customFields = {}, channels, mentions, msg ,rid ,ts, u, t, _id, id, _updatedAt, file, attachments, temporaryData, localReference , viewed = [], received = [], delate = false, delateRequest =false, }:Message) {
@@ -184,24 +186,29 @@ export class MessageService {
       delete params?.attachments?.image_url
     }
 
-    this.ChatMethodsService.send(params).subscribe(
-      (response: any) => {
-        const ChatMessage = response.message
-        this.messageSend = true
-        this.redefinedMessage(ChatMessage)
 
-      },
-      (error) => {
-        this.WsChatService.registerCallback({
-          type: 'reConnect',
-          funx: async ()=> {
-            
-            this.send()
-            return true
-          }
-        })
-      }
-    )
+    if(this.NetworkServiceService.getCurrentNetworkStatus() == ConnectionStatus.Online) {
+      
+      this.WsChatService.send(params).then(
+        (ChatMessage: any) => {
+          ChatMessage = ChatMessage.message.result
+
+          this.messageSend = true
+          this.redefinedMessage(ChatMessage)
+        }
+      )
+
+    } else {
+      this.WsChatService.registerCallback({
+        type: 'reConnect',
+        funx: async ()=> {
+          
+          this.send()
+          return true
+        }
+      })
+    }
+
   }
 
   async redefinedMessage(ChatMessage , update = true) {

src/app/services/chat/room.service.ts

@@ -22,6 +22,7 @@ import { DeleteMessageModel, MessageModel } from '../../models/beast-orm'
 import { AESEncrypt } from '../aesencrypt.service'
 import { IncomingChatMessage, ChatMessageInterface, falseTypingMethod } from 'src/app/models/message.model';
 import { AttachmentsService } from 'src/app/services/attachments.service';
+import { ConnectionStatus, NetworkServiceService} from 'src/app/services/network-service.service';
 
 @Injectable({
   providedIn: 'root'
@@ -77,18 +78,16 @@ export class RoomService {
     private ChatStorageService: ChatStorageService,
     private ChatMethodsService: ChatMethodsService,
     private AESEncrypt: AESEncrypt,
-    private AttachmentsService: AttachmentsService
+    private AttachmentsService: AttachmentsService,
+    private NetworkServiceService: NetworkServiceService
   ) {
     this.NativeNotificationService.askForPermission()
 
-    // this.restoreMessageFromDB()
-
     this.WsChatService.getUserStatus((d) => {
 
       const userId = d.fields.args[0][0]
       const statusNum = d.fields.args[0][2]
       const statusText = this.statusNumberToText(statusNum)
-      // 
 
       if(this.members?.map) {
         const membersIds = this.members.map((user)=> user._id)
@@ -145,7 +144,7 @@ export class RoomService {
     }
   }
 
-  setData({members, u, customFields = {}, id, name, t, lastMessage = new MessageService(this.storage, this.NfService, this.WsChatService, this.ChatStorageService, this.ChatMethodsService, this.AESEncrypt, this.AttachmentsService), _updatedAt }) {
+  setData({members, u, customFields = {}, id, name, t, lastMessage = new MessageService(this.storage, this.NfService, this.WsChatService, this.ChatStorageService, this.ChatMethodsService, this.AESEncrypt, this.AttachmentsService, this.NetworkServiceService), _updatedAt }) {
     this.customFields = customFields
     this.id = id
     this.name = name
@@ -343,7 +342,6 @@ export class RoomService {
 
   } 
 
-
   async receiveMessageDelete() {
 
     this.WsChatService.updateRoomEventss(
@@ -372,14 +370,6 @@ export class RoomService {
       if(this.messages[i]?._id == id ) {
 
         
-
-        //Get previous last message from room
-        const previousLastMessage = this.messages.slice(-1)[0];
-        this.lastMessage = previousLastMessage;
-        
-        this.calDateDuration(previousLastMessage._updatedAt)
-        this.sortRoomList()
-        
         if (SessionStore.user.RochetChatUser == this.messages[i]?.u?.username) {
           const allMemberThatIsOffline = this.getAllMemberThatIsOffline()
           
@@ -393,10 +383,14 @@ export class RoomService {
         }
         
         this.messages[i]?.delateDB()
-
-        // console.log(_id,'==',this.messages[i]?._id, true)
         this.messages.splice(i, 1)
 
+        //Get previous last message from room
+        const previousLastMessage = this.messages.slice(-1)[0];
+        this.lastMessage = previousLastMessage;
+        this.calDateDuration(previousLastMessage._updatedAt)
+        this.sortRoomList()
+
         return true
 
       } else {
@@ -429,40 +423,28 @@ export class RoomService {
     const message = this.messages.find((e)=>e._id == msgId)
     await message.delateStatusFalse()
 
-    this.ChatMethodsService.deleteMessage({_id:msgId, msgId:msgId, roomId:message.rid}).subscribe(
-      async (response: any) => {
-
+    if(this.NetworkServiceService.getCurrentNetworkStatus() == ConnectionStatus.Online) {
+      
+      this.WsChatService.deleteMessage(msgId).then(async() => {
         message.delateRequest = true
         await message.save()
         this.deleteMessage(msgId)
+      })
 
-      },
-      async (response) => {
-
-        if (response?.error?.error.startsWith('No message found with the id of')) {
+    } else {
+      this.WsChatService.registerCallback({
+        type: 'reConnect',
+        funx: async ()=> {
           
-          this.deleteMessage(msgId)
-          message.delateRequest = true
-          await message.save()
-
-        } else {
-          this.WsChatService.registerCallback({
-            type: 'reConnect',
-            funx: async ()=> {
-              
-              this.sendDeleteRequest(msgId)
-              return true
-            }
-          })
+          this.sendDeleteRequest(msgId)
+          return true
         }
-
-      }
-    )
+      })
+    }
 
   }
 
 
-
   /**
    *  @description sen text message
    */
@@ -629,7 +611,7 @@ export class RoomService {
 
     await this.WsChatService.loadHistory(this.id, limit).then( async (chatHistory:chatHistory) => {
 
-      console.log('load chatHistory', JSON.stringify(chatHistory))
+      // console.log('load chatHistory', JSON.stringify(chatHistory))
 
       const messagesId =  this.messages.map((message)=> message._id)
 
@@ -685,7 +667,7 @@ export class RoomService {
     message = this.fix_updatedAt(message)
 
    
-    const wewMessage = new MessageService(this.storage, this.NfService, this.WsChatService, this.ChatStorageService, this.ChatMethodsService, this.AESEncrypt, this.AttachmentsService)
+    const wewMessage = new MessageService(this.storage, this.NfService, this.WsChatService, this.ChatStorageService, this.ChatMethodsService, this.AESEncrypt, this.AttachmentsService, this.NetworkServiceService)
     wewMessage.setData(message)
     wewMessage.loadHistory = this.hasLoadHistory
 
@@ -742,7 +724,7 @@ export class RoomService {
    async prepareCreate({message, save = true}): Promise<MessageService> {
     message = this.fix_updatedAt(message)
 
-    const wewMessage = new MessageService(this.storage, this.NfService, this.WsChatService, this.ChatStorageService, this.ChatMethodsService, this.AESEncrypt, this.AttachmentsService)
+    const wewMessage = new MessageService(this.storage, this.NfService, this.WsChatService, this.ChatStorageService, this.ChatMethodsService, this.AESEncrypt, this.AttachmentsService, this.NetworkServiceService)
     wewMessage.setData(message)
     wewMessage.loadHistory = this.hasLoadHistory
 
@@ -754,7 +736,7 @@ export class RoomService {
 
   simplePrepareMessage(message) {
     message = this.fix_updatedAt(message)
-    const wewMessage = new MessageService(this.storage, this.NfService, this.WsChatService, this.ChatStorageService, this.ChatMethodsService, this.AESEncrypt, this.AttachmentsService)
+    const wewMessage = new MessageService(this.storage, this.NfService, this.WsChatService, this.ChatStorageService, this.ChatMethodsService, this.AESEncrypt, this.AttachmentsService, this.NetworkServiceService)
     wewMessage.setData(message)
     wewMessage.loadHistory = this.hasLoadHistory
 

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

@@ -20,6 +20,7 @@ import { ChatStorageService } from './chat-storage.service'
 import { ChatMethodsService } from './chat-methods.service'
 import { AESEncrypt } from '../aesencrypt.service'
 import { AttachmentsService } from 'src/app/services/attachments.service';
+import { NetworkServiceService} from 'src/app/services/network-service.service';
 
 @Injectable({
   providedIn: 'root'
@@ -57,7 +58,8 @@ export class WsChatMethodsService {
     private ChatStorageService: ChatStorageService,
     private ChatMethodsService:ChatMethodsService,
     private AESEncrypt: AESEncrypt,
-    private AttachmentsService:AttachmentsService
+    private AttachmentsService:AttachmentsService,
+    private NetworkServiceService: NetworkServiceService
   ) {
 
     this.loggedUser = authService.ValidatedUserChat['data'];
@@ -314,7 +316,7 @@ export class WsChatMethodsService {
 
     // create room
     if(!this.roomExist(roomId)) {
-      let room:RoomService = new RoomService(this.WsChatService, new MessageService(this.storage, this.NfService, this.WsChatService, this.ChatStorageService, this.ChatMethodsService, this.AESEncrypt, this.AttachmentsService), this.storage, this.platform, this.sqlservice, this.NativeNotificationService, this.sortService, this.ChatService, this.NfService , this.ChatStorageService, this.ChatMethodsService, this.AESEncrypt, this.AttachmentsService)
+      let room:RoomService = new RoomService(this.WsChatService, new MessageService(this.storage, this.NfService, this.WsChatService, this.ChatStorageService, this.ChatMethodsService, this.AESEncrypt, this.AttachmentsService, this.NetworkServiceService), this.storage, this.platform, this.sqlservice, this.NativeNotificationService, this.sortService, this.ChatService, this.NfService , this.ChatStorageService, this.ChatMethodsService, this.AESEncrypt, this.AttachmentsService, this.NetworkServiceService)
       room.setData(setData)
       room.receiveMessage()
       room.getAllUsers = this.getUsers

src/app/services/network-service.service.spec.ts

@@ -0,0 +1,16 @@
+import { TestBed } from '@angular/core/testing';
+
+import { NetworkServiceService } from './network-service.service';
+
+describe('NetworkServiceService', () => {
+  let service: NetworkServiceService;
+
+  beforeEach(() => {
+    TestBed.configureTestingModule({});
+    service = TestBed.inject(NetworkServiceService);
+  });
+
+  it('should be created', () => {
+    expect(service).toBeTruthy();
+  });
+});

src/app/services/network-service.service.ts

@@ -0,0 +1,62 @@
+import { Injectable } from '@angular/core';
+import { ToastController, Platform } from '@ionic/angular';
+import { BehaviorSubject, Observable } from 'rxjs';
+import { Network } from '@ionic-native/network/ngx'
+
+
+export enum ConnectionStatus {
+  Online,
+  Offline
+}
+
+
+@Injectable({
+  providedIn: 'root'
+})
+export class NetworkServiceService {
+  private status: BehaviorSubject<ConnectionStatus> = new BehaviorSubject(ConnectionStatus.Offline);
+ 
+  constructor(private network: Network, private toastController: ToastController, private plt: Platform) {
+    this.plt.ready().then(() => {
+      this.initializeNetworkEvents();
+      let status =  this.network.type !== 'none' ? ConnectionStatus.Online : ConnectionStatus.Offline;
+      this.status.next(status);
+    });    
+
+  }
+ 
+  public initializeNetworkEvents() {
+ 
+    this.network.onDisconnect().subscribe(() => {
+      if (this.status.getValue() === ConnectionStatus.Online) {
+        this.updateNetworkStatus(ConnectionStatus.Offline);
+      }
+    });
+ 
+    this.network.onConnect().subscribe(() => {
+      if (this.status.getValue() === ConnectionStatus.Offline) {
+        this.updateNetworkStatus(ConnectionStatus.Online);
+      }
+    });
+  }
+ 
+  private async updateNetworkStatus(status: ConnectionStatus) {
+    this.status.next(status);
+ 
+    let connection = status == ConnectionStatus.Offline ? 'Offline' : 'Online';
+    let toast = this.toastController.create({
+      message: `You are now ${connection}`,
+      duration: 3000,
+      position: 'bottom'
+    });
+    toast.then(toast => toast.present());
+  }
+ 
+  public onNetworkChange(): Observable<ConnectionStatus> {
+    return this.status.asObservable();
+  }
+ 
+  public getCurrentNetworkStatus(): ConnectionStatus {
+    return this.status.getValue();
+  }
+}

src/app/services/permission.service.ts

@@ -26,8 +26,8 @@ export class PermissionService {
     }
 
 
-    for(let permission of (this.SessionStore.user.UserPermissions || [])){
-      if (args.includes(permission)){
+    for(let permission of (this.SessionStore.user.UserPermissions || [])) {
+      if (args.includes(permission)) {
         return true;
       }
     }
@@ -46,7 +46,7 @@ export class PermissionService {
           role = [role]
         }
 
-        if(!UserRoleIsValid) {return false }
+        if(!UserRoleIsValid) { return false }
 
         return true