add deplay on the first event

This commit is contained in:
Peter Maquiran
2024-09-02 16:35:28 +01:00
parent 0dbe0a4bbc
commit 878008b4ba
@@ -80,14 +80,15 @@ export class RoomBoldSyncUseCaseService {
@XTracerAsync({name:'RoomBoldSyncUseCaseService/onInsertToDB', module:'chat', bugPrint: true})
private onInsertToDB(tracing?: TracingType) {
let delay = 2000
this.messageLocalRepository.onCreateObservable().pipe(
filter(e => e?.origin == 'history'),
filter(e => e.sender.wxUserId != SessionStore.user.UserId)
filter(e => e.sender.wxUserId != SessionStore.user.UserId),
).subscribe(async (newMessage)=> {
const haveSeen = MessageEntity.haveSeen(newMessage.info)
if(!haveSeen) {
setTimeout(async ()=> {
setTimeout(async ()=> {
const haveSeen = MessageEntity.haveSeen(newMessage.info)
if(!haveSeen) {
await this.boldLocalRepository.open()
const result = await this.boldLocalRepository.findOne({roomId: newMessage.roomId})
@@ -98,8 +99,10 @@ export class RoomBoldSyncUseCaseService {
} else {
tracing.hasError("failed to set bold",{})
}
}, 2000)
}
}
}, delay);
delay = 0
})
}
}