fix message statud bag

This commit is contained in:
Peter Maquiran
2024-08-26 09:59:30 +01:00
parent c9b50620fe
commit 0f94af5f4e
18 changed files with 285 additions and 107 deletions
@@ -7,9 +7,7 @@ export class RoomService {
constructor(
private RoomSocketRepositoryService: RoomSocketRepositoryService
) {
}
) {}
init() {
this.OnReceiveCreateRoom()
@@ -0,0 +1,9 @@
import { Injectable } from '@angular/core';
@Injectable({
providedIn: 'root'
})
export class MessageToAsyncUIService {
constructor() { }
}
@@ -9,6 +9,7 @@ import { RoomLocalRepository } from '../../data/repository/room/room-local-repos
import { SessionStore } from 'src/app/store/session.service';
import { Logger } from 'src/app/services/logger/main/service';
import { XTracerAsync, TracingType } from 'src/app/services/monitoring/opentelemetry/tracer';
import { v4 as uuidv4 } from 'uuid'
@Injectable({
providedIn: 'root'
@@ -54,15 +55,17 @@ export class SyncAllRoomMessagesService {
this.messageLocalDataSourceService.findOrUpdate(clone)
const me = message.info.find(e => e.memberId == SessionStore.user.UserId)
const me = message.info.find(e => e.memberId == SessionStore.user.UserId && typeof e.deliverAt == 'string' )
if(!me) {
this.MessageSocketRepositoryService.sendDeliverAt({
memberId: SessionStore.user.UserId,
messageId: message.id,
roomId: message.roomId,
requestId: "string"
requestId: uuidv4()
})
tracing.addEvent('send delever roomId'+ room.id)
}
}
@@ -70,14 +73,17 @@ export class SyncAllRoomMessagesService {
let clone: MessageTable = message
clone.roomId = room.id
const me = message.info.find(e => e.memberId == SessionStore.user.UserId)
const me = message.info.find(e => e.memberId == SessionStore.user.UserId && typeof e.deliverAt == 'string' )
if(!me) {
this.MessageSocketRepositoryService.sendDeliverAt({
memberId: SessionStore.user.UserId,
messageId: message.id,
roomId: message.roomId,
requestId: "string"
requestId: uuidv4()
})
tracing.addEvent('send delever roomId'+ room.id)
}
}
@@ -159,7 +159,6 @@ export class SignalRConnection {
for(const method of methods) {
this.hubConnection.on(method, (message: any) => {
console.log({message})
this.messageSubject.next(message);
this.sendDataSubject.next({
method: method,