mirror of
https://code.equilibrium.co.ao/ITO/doneit-web.git
synced 2026-04-18 20:47:54 +00:00
improve chat
This commit is contained in:
@@ -1,5 +1,6 @@
|
||||
import { Injectable } from '@angular/core';
|
||||
import * as FIFOProcessQueue from 'fifo-process-queue';
|
||||
import { async } from 'rxjs';
|
||||
import { RoomService } from './room.service';
|
||||
|
||||
@Injectable({
|
||||
@@ -21,11 +22,15 @@ export class ViewedMessageService {
|
||||
room.deleteMessageToReceive(userId)
|
||||
}
|
||||
|
||||
let n = 0
|
||||
for (const message of room.messages) {
|
||||
if(message.online) {
|
||||
for(let id of membersIds) {
|
||||
if(message.addReceived(id)) {
|
||||
await message.saveChanges()
|
||||
n++
|
||||
setTimeout(async() => {
|
||||
await message.saveChanges()
|
||||
}, 100 * n)
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -44,13 +49,18 @@ export class ViewedMessageService {
|
||||
|
||||
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)
|
||||
await message.saveChanges()
|
||||
n++
|
||||
setTimeout(async() => {
|
||||
await message.saveChanges()
|
||||
}, 100 * n)
|
||||
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user