save all

src/app/services/chat/change-message-queue.service.spec.ts

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

src/app/services/chat/change-message-queue.service.ts

@@ -0,0 +1,8 @@
+import { Injectable } from '@angular/core';
+
+@Injectable({
+  providedIn: 'root'
+})
+export class ChangeMessageQueueService {
+  constructor() {}
+}

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

@@ -504,20 +504,25 @@ export class MessageService {
       const message = this.getChatObj()
       let a
 
+      if(!message.id) {
+        delete message.id
+      }
+      
       if (this.localReference) {
         a = await MessageModel.get({localReference: this.localReference})
       } else if (this._id) {
-        a = await MessageModel.get({id: this.id})
-      } else if(this.id) {
         a = await MessageModel.get({_id: this._id})
+      } else if(this.id) {
+        a = await MessageModel.get({id: this.id})
       }
 
-      for( const [name, value] of Object.entries(message)) {
-        a[name] = value
+      if(a) {
+        for( const [name, value] of Object.entries(message)) {
+          a[name] = value
+        }
+        await a.save()
       }
       
-      await a.save()
-
     } else {
       this.earlySave = true
       console.log('save change to early')

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

@@ -763,8 +763,6 @@ export class RoomService {
 
   }
 
-
-
   async readAllMessage() {
 
     this.ViewedMessageService.requestReadAll(this)

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

@@ -1,6 +1,5 @@
 import { Injectable } from '@angular/core';
 import * as FIFOProcessQueue from 'fifo-process-queue';
-import { async } from 'rxjs';
 import { RoomService } from './room.service';
 
 @Injectable({