improve

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

@@ -172,14 +172,13 @@ export class RoomService {
       this.id,
       "stream-room-messages",
       async (IncomingChatMessage:IncomingChatMessage) => {
-        // console.log('recivemessage========', JSON.stringify(IncomingChatMessage))
 
         let IncomingChatMessageArgs = IncomingChatMessage.fields.args[0]
         let ChatMessage : ChatMessageInterface = this.fix_updatedAt(IncomingChatMessageArgs)
         
         if(!this.messagesLocalReference.includes(ChatMessage.localReference)) {
 
-          const message = await this.prepareMessage({message: ChatMessage, save: true})
+          const message = await this.prepareCreate({message: ChatMessage, save: true})
           message.messageSend = true
 
           this.lastMessage = message
@@ -659,11 +658,6 @@ export class RoomService {
     wewMessage.setData(message)
     wewMessage.loadHistory = this.hasLoadHistory
 
-    if(!message?._id && environment.chatOffline && save) {
-      this.messages.push(wewMessage)
-      return wewMessage
-    }
-
     let foundIndex;
 
     const found = this.messages.find((MessageService, index) => {
@@ -723,17 +717,8 @@ export class RoomService {
     wewMessage.setData(message)
     wewMessage.loadHistory = this.hasLoadHistory
 
-    console.log(message?._id, environment.chatOffline, save)
-
-    if(!message?._id && environment.chatOffline && save) {
-      
-      this.messages.push(wewMessage)
-      // console.log('add to view')
-      return wewMessage
-    }
-
-    
-
+    this.messages.push(wewMessage)
+    return wewMessage
 
   }