From 38b984f2ecb89e962b687627ea356ed54866dafd Mon Sep 17 00:00:00 2001 From: Peter Maquiran Date: Thu, 10 Feb 2022 14:56:06 +0100 Subject: [PATCH] improve --- src/app/services/chat/message.service.ts | 26 +++--- src/app/services/chat/room.service.ts | 88 +++++++++++++------ .../services/chat/ws-chat-methods.service.ts | 55 +++++++++--- 3 files changed, 119 insertions(+), 50 deletions(-) diff --git a/src/app/services/chat/message.service.ts b/src/app/services/chat/message.service.ts index 34e4d4d54..9d6cc59ab 100644 --- a/src/app/services/chat/message.service.ts +++ b/src/app/services/chat/message.service.ts @@ -95,18 +95,22 @@ export class MessageService { } } - async send() { + async send(): Promise { this.sendAttempt++; if(!this.hasFile) { this.WsChatService.send({roomId:this.rid, msg:this.msg}).then((data: any) => { - if (environment.chatOffline) { - let ChatMessage = data.result + let ChatMessage = data.result + + if (environment.chatOffline) { this.redefinedMessage(this, ChatMessage) this.offline = false } + return new Promise((resolve, reject)=>{ + resolve(ChatMessage) + }) }) } else { @@ -125,21 +129,23 @@ export class MessageService { this.temporaryData = {} this.WsChatService.send({roomId:this.rid, msg: this.msg, attachments: this.attachments, file: this.file}).then((data: any) => { - if (environment.chatOffline) { - // console.log('send sucees', data.result) - let ChatMessage = data.result + let ChatMessage = data.result + + if (environment.chatOffline) { this.redefinedMessage(this, ChatMessage) this.offline = false } + + return new Promise((resolve, reject)=>{ + resolve(ChatMessage) + }) }) } else if(this.WsChatService.isLogin == false) { - this.WsChatService.registerCallback({ type: 'reConnect', - funx:()=> { - this.send() - return true + funx: async ()=> { + return await this.send() } }) diff --git a/src/app/services/chat/room.service.ts b/src/app/services/chat/room.service.ts index b19247335..35a24cb5a 100644 --- a/src/app/services/chat/room.service.ts +++ b/src/app/services/chat/room.service.ts @@ -14,7 +14,8 @@ import { SortService } from '../functions/sort.service'; import { chatUser } from 'src/app/models/chatMethod'; import { environment } from 'src/environments/environment'; import { ChatService } from 'src/app/services/chat.service'; -import { NfService } from 'src/app/services/chat/nf.service' +import { NfService } from 'src/app/services/chat/nf.service'; +import { v4 as uuidv4 } from 'uuid' @Injectable({ providedIn: 'root' @@ -164,6 +165,57 @@ export class RoomService { } + async updateMessageDB(ChatMessage, localReference) { + if (environment.chatOffline) { + this.storage.get('chatmsg' + this.id).then((messages: any = []) => { + if(!Array.isArray(messages)) { + messages = [] + } + + let index; + const find = messages.find((message, _index)=> { + if(message.localReference == ChatMessage.localReference) { + index = _index + return true + } + + return false + }) + + if(!find) { + messages[index] = ChatMessage + this.storage.set('chatmsg' + this.id, messages) + } + + }) + } + + } + + /** + * @description delete message in the DB. get all messages, delete then corresponding message and update the store + * @param id message ID + */ + private deleteMessageFromDb(id) { + this.storage.get('chatmsg' + this.id).then((messages: any = []) => { + if(!Array.isArray(messages)) { + messages = [] + } + + messages.forEach((message, index) => { + + if(message._id == id) { + messages.splice(index, 1) + } + + }) + + this.storage.set('chatmsg' + this.id, messages).then((value) => { + console.log('MSG SAVED ON STORAGE', value) + }); + }) + } + async receiveMessageDelete() { this.WsChatService.updateRoomEventss( @@ -201,46 +253,26 @@ export class RoomService { } - /** - * @description delete message in the DB. get all messages, delete then corresponding message and update the store - * @param id message ID - */ - private deleteMessageFromDb(id) { - this.storage.get('chatmsg' + this.id).then((messages: any = []) => { - if(!Array.isArray(messages)) { - messages = [] - } - - messages.forEach((message, index) => { - - if(message._id == id) { - messages.splice(index, 1) - } - - }) - - this.storage.set('chatmsg' + this.id, messages).then((value) => { - console.log('MSG SAVED ON STORAGE', value) - }); - }) - } - /** * @description sen text message */ async send({file = null, attachments = null, temporaryData = {}}) { + const localReference = uuidv4() let offlineChatMessage = { rid: this.id, msg: this.message, attachments, file, - temporaryData + temporaryData, + localReference } const message: MessageService = this.prepareMessage(offlineChatMessage, environment.chatOffline) - message.send() + message.send().then((ChatMessage) => { + this.updateMessageDB(ChatMessage, localReference) + }) if (environment.chatOffline) { this.addMessageDB(offlineChatMessage) @@ -349,6 +381,8 @@ export class RoomService { if(wewMessage.offline == false) { this.prepareMessage(ChatMessage) + } else { + } }); diff --git a/src/app/services/chat/ws-chat-methods.service.ts b/src/app/services/chat/ws-chat-methods.service.ts index caecf5ccc..f31adf4d3 100644 --- a/src/app/services/chat/ws-chat-methods.service.ts +++ b/src/app/services/chat/ws-chat-methods.service.ts @@ -13,7 +13,7 @@ import { NativeNotificationService } from 'src/app/services/native-notification. import { SortService } from '../functions/sort.service'; import { chatUser } from 'src/app/models/chatMethod'; import { NfService } from 'src/app/services/chat/nf.service' - +import { ChangeProfileService } from '../change-profile.service'; @Injectable({ providedIn: 'root' }) @@ -42,18 +42,10 @@ export class WsChatMethodsService { private sortService: SortService, private ChatService: ChatService, private NfService: NfService, + private changeProfileService: ChangeProfileService, ) { - (async()=>{ - await this.restoreRooms() - await this.getAllRooms(); - this.subscribeToRoom() - - - // - await this.getUser() - this.getUserStatus() - - })() + + this.loadChat() this.WsChatService.registerCallback({ type: 'reConnect', @@ -64,7 +56,9 @@ export class WsChatMethodsService { */ this.subscribeToRoom() - this.currentRoom.loadHistory({forceUpdate: true}) + if(this.currentRoom) { + this.currentRoom.loadHistory({forceUpdate: true}) + } for (const id in this.dm) { this.dm[id].hasLoadHistory = false @@ -77,6 +71,11 @@ export class WsChatMethodsService { } }) + this.changeProfileService.registerCallback(()=>{ + this.clearChat() + this.ReLoadChat() + }) + // this.WsChatService.registerCallback({ // type:'Onmessage', @@ -112,6 +111,36 @@ export class WsChatMethodsService { } + private loadChat() { + this.ReLoadChat() + } + + async ReLoadChat() { + await this.restoreRooms() + await this.getAllRooms(); + this.subscribeToRoom() + + + // + await this.getUser() + this.getUserStatus() + } + + clearChat() { + this.dm = {} + this.group = {} + this._dm = [] + this._group = [] + + this.loadingWholeList = false + + this.dmCount = 0; + this.groupCount = 0; + + this.currentRoom = null + this.users = [] + } + getRoomFromDb() { this.storage.get('Rooms').then((rooms) => { rooms.result.update.forEach((roomData: room) => {