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

import { Injectable } from '@angular/core';
import * as FIFOProcessQueue from 'fifo-process-queue';
import { RoomService } from './room.service';

@Injectable({
  providedIn: 'root'
})
export class ViewedMessageService {

  constructor() { 
  }

  viewQueue = FIFOProcessQueue(async ({room, userId, statusNum, statusText}, callback) => {

    if(room.membersExcludeMe?.map) {
      const membersIds = room.membersExcludeMe.map((user)=> user._id)

      if(membersIds.includes(userId)) {

        if(statusText != 'offline') {
          room.deleteMessageToReceive(userId)
        }

        let n = 0
        for (const message of room.messages) {
          if(message.online) {
            for(let id of membersIds) {
              if(message.addReceived(id)) {
                n++
                setTimeout(async() => {
                  await message.saveChanges()
                }, 100 * n)
              }
            }
          }
        }

        setTimeout(function () {
          callback();
        }, 100);
      }
    }

  })


  viewReadQueue = FIFOProcessQueue(async ({room}, callback) => {

    const membersIds: string[] = room.membersExcludeMe.map((user)=> user._id)

    let n = 0
    for (const message of room.messages) {
      if(message.online) {
        for(let id of membersIds) {

          if(message.addViewed(id)) {
            message.addReceived(id)
            n++
            setTimeout(async() => {
              await message.saveChanges()
            }, 100 * n)
            
          }
        }
      }
    }

    setTimeout(() => {
      callback()
    },100)

  })
  
  request(room:RoomService, userId, statusNum, statusText) {
    this.viewQueue.push({room, userId, statusNum, statusText})
  }

  requestReadAll(room:RoomService) {
    this.viewReadQueue.push({room})
  }
}