edit message

src/app/module/chat/data/repository/message-respository.service.ts

@@ -9,6 +9,7 @@ import { v4 as uuidv4 } from 'uuid'
 import { filter } from 'rxjs/operators';
 import { err, ok } from 'neverthrow';
 import { MessageDeleteInputDTO } from '../../domain/use-case/message-delete-live-use-case.service';
+import { MessageUpdateInput } from '../../domain/use-case/message-update-use-case.service';
 
 export const InstanceId = uuidv4();
 
@@ -111,6 +112,13 @@ export class MessageRepositoryService {
     })
   }
 
+  updateMessage(input: MessageUpdateInput) {
+    this.messageLiveSignalRDataSourceService.sendData({
+      method: 'EditMessage',
+      data: input,
+    })
+  }
+
   async listAllMessagesByRoomId(id: string) {
     const result = await this.messageRemoteDataSourceService.getMessagesFromRoom(id)
 

src/app/module/chat/domain/chat-service.service.ts

@@ -2,6 +2,8 @@ import { Injectable } from '@angular/core';
 import { MessageDeleteLiveUseCaseService, MessageDeleteInputDTO } from 'src/app/module/chat/domain/use-case/message-delete-live-use-case.service'
 import { SessionStore } from 'src/app/store/session.service';
 import { MessageReactionInput, MessageReactionUseCaseService } from 'src/app/module/chat/domain/use-case/message-reaction-use-case.service';
+import { MessageUpdateInput, MessageUpdateUseCaseService } from 'src/app/module/chat/domain/use-case/message-update-use-case.service';
+
 
 @Injectable({
   providedIn: 'root'
@@ -10,7 +12,8 @@ export class ChatServiceService {
 
   constructor(
     private MessageDeleteLiveUseCaseService: MessageDeleteLiveUseCaseService,
-    private MessageReactionUseCaseService: MessageReactionUseCaseService
+    private MessageReactionUseCaseService: MessageReactionUseCaseService,
+    private MessageUpdateUseCaseService: MessageUpdateUseCaseService
   ) { }
 
   messageDelete(data: {roomId, messageId}) {
@@ -26,5 +29,9 @@ export class ChatServiceService {
   reactToMessage(input: MessageReactionInput) {
     return this.MessageReactionUseCaseService.execute(input);
   }
+
+  updateMessage(input: MessageUpdateInput) {
+    return this.MessageUpdateUseCaseService.execute(input);
+  }
 }