fix last message

src/app/module/chat/data/repository/message/message-live-signalr-data-source.service.ts

@@ -7,11 +7,11 @@ import { SignalRService } from 'src/app/infra/socket/signalR/signal-r.service';
 import { filter, map } from 'rxjs/operators';
 import { SocketMessage } from 'src/app/infra/socket/signalR/signalR';
 import { IMessageSocketRepository } from 'src/app/core/chat/repository/message/message-socket-repository';
-import { MessageCreateOutPutDataDTO } from '../../../domain/use-case/message/message-create-use-case.service';
-import { MessageInputDTO } from 'src/app/core/chat/repository/dto/messageInputDtO'
+import { MessageCreateOutPutDataDTO, MessageInputDTO } from '../../../domain/use-case/message/message-create-use-case.service';
 import { MessageMarkAsReadInput } from '../../../domain/use-case/message/message-mark-as-read-use-case.service';
 import { MessageOutPutDataDTO } from 'src/app/core/chat/repository/dto/messageOutputDTO';
 import { MessageDeleteInputDTO } from '../../../domain/use-case/message/message-delete-by-id-live-use-case.service';
+import { BehaviorSubject, Observable } from 'rxjs';
 
 interface sendDeliverAt {
   memberId: number,
@@ -25,6 +25,8 @@ interface sendDeliverAt {
 })
 export class MessageSocketRepositoryService implements IMessageSocketRepository {
 
+  private sendDataSubject: BehaviorSubject<{method: string, data: any}> = new BehaviorSubject<{method: string, data: any}>(null);
+
   constructor(
     private socket: SignalRService
   ) {}
@@ -49,9 +51,10 @@ export class MessageSocketRepositoryService implements IMessageSocketRepository
       data: data,
     })
 
-    if(result.isOk()) {
-      console.log('recieve', result.value)
-    }
+    this.sendDataSubject.next({
+      method: 'sendMessage',
+      data: data,
+    })
 
     return result;
   }
@@ -66,6 +69,10 @@ export class MessageSocketRepositoryService implements IMessageSocketRepository
       data: data as any,
     })
 
+    this.sendDataSubject.next({
+      method: 'SendDirectMessage',
+      data: data,
+    })
     return result;
   }
 
@@ -121,6 +128,18 @@ export class MessageSocketRepositoryService implements IMessageSocketRepository
     )
   }
 
+  listenToSendMessage() {
+    return this.sendDataSubject.pipe(
+      filter((e) : e is SocketMessage<MessageInputDTO>=> {
+        console.log(e, e?.method == 'sendMessage' || e?.method == 'SendDirectMessage')
+
+        return e?.method == 'sendMessage' || e?.method == 'SendDirectMessage'
+      }
+    ))
+
+
+  }
+
 
   reactToMessageSocket(data: MessageReactionInput) {
     this.socket.sendData({