add contact page

src/app/module/chat/data/data-source/attachment/attachment-remote-data-source.service.ts

@@ -14,8 +14,8 @@ export class AttachmentRemoteDataSourceService {
     private httpService: HttpService
   ) { }
 
-  async getAttachment(Input: MessageAttachmentByMessageIdInput): DataSourceReturn<Blob>  {
-    return await this.httpService.get(`${this.baseUrl}/attachment/${Input.id}`, { responseType: 'blob' });
+  async getAttachment(id: string | number): DataSourceReturn<Blob>  {
+    return await this.httpService.get(`${this.baseUrl}/attachment/${id}`, { responseType: 'blob' });
   }
 
 }

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

@@ -9,6 +9,7 @@ import { SignalRService } from '../infra/socket/signal-r.service';
 import { SocketMessageDeleteUseCaseService } from 'src/app/module/chat/domain/use-case/socket/socket-message-delete-use-case.service';
 import { SocketMessageUpdateUseCaseService } from 'src/app/module/chat/domain/use-case/socket/socket-message-update-use-case.service';
 import { SocketMessageCreateUseCaseService } from 'src/app/module/chat/domain/use-case/socket/socket-message-create-use-case.service';
+import { DownloadMessageAttachmentUserCaseService } from 'src/app/module/chat/domain/use-case/download-message-attachment-user-case.service';
 import { ListenMessageByRoomIdNewUseCase } from 'src/app/module/chat/domain/use-case/listen-message-by-roomId.service';
 import { MemberListUpdateStatusUseCaseService } from 'src/app/module/chat/domain/use-case/socket/member-list-update-status-use-case.service';
 import { ListenMessageDeleteByRoomIdService } from './use-case/listene-message-delete-by-roomId.service';
@@ -44,7 +45,8 @@ export class ChatServiceService {
     private ListenMessageUpdateByRoomIdUseCase: ListenMessageUpdateByRoomIdUseCase,
     private ListenSendMessageUseCase: ListenSendMessageUseCase,
     private MessageAttachmentByMessageIdService: MessageAttachmentByMessageIdUseCase,
-    private SyncAllRoomMessagesService: SyncAllRoomMessagesService
+    private SyncAllRoomMessagesService: SyncAllRoomMessagesService,
+    private DownloadMessageAttachmentUserCaseService: DownloadMessageAttachmentUserCaseService
   ) {
     this.messageLiveSignalRDataSourceService.getMessageDelete()
     .pipe()
@@ -129,6 +131,11 @@ export class ChatServiceService {
     return this.MessageAttachmentByMessageIdService.execute(input)
   }
 
+  downloadMessageAttachmentByMessageId(input: MessageAttachmentByMessageIdInput) {
+    return this.DownloadMessageAttachmentUserCaseService.execute(input)
+  }
+
+
   listenToIncomingMessage(roomId:string) {
     return this.ListenMessageByRoomIdNewUseCase.execute({roomId})
   }

src/app/module/chat/domain/use-case/download-message-attachment-user-case.service.ts

@@ -0,0 +1,38 @@
+import { Injectable } from '@angular/core';
+import { AttachmentRemoteDataSourceService } from 'src/app/module/chat/data/data-source/attachment/attachment-remote-data-source.service'
+import { Logger } from 'src/app/services/logger/main/service';
+import { convertBlobToDataURL } from 'src/app/utils/ToBase64';
+import { AttachmentLocalDataSource } from 'src/app/module/chat/data/data-source/attachment/attachment-local-data-source.service'
+import { MessageAttachmentByMessageIdInput } from './message-attachment-by-message-id.service';
+
+
+@Injectable({
+  providedIn: 'root'
+})
+export class DownloadMessageAttachmentUserCaseService {
+
+  constructor(
+    private AttachmentRemoteDataSourceService: AttachmentRemoteDataSourceService,
+    private AttachmentLocalDataSource: AttachmentLocalDataSource
+  ) { }
+
+  async execute(input: MessageAttachmentByMessageIdInput) {
+    const result = await this.AttachmentRemoteDataSourceService.getAttachment(input.$messageId)
+    return result.asyncMap(async (e) => {
+
+      const dataUrl = await convertBlobToDataURL(e)
+      Logger.info('downloaded file #1', {
+        data: dataUrl.slice(0, 100)+'...',
+        context: 'DownloadMessageAttachmentUserCaseService'
+      })
+
+      this.AttachmentLocalDataSource.insert({
+        $messageId: input.$messageId,
+        id: input.id,
+        file: dataUrl
+      })
+
+      return dataUrl
+    })
+  }
+}

src/app/module/chat/domain/use-case/message-attachment-by-message-id.service.ts

@@ -4,6 +4,7 @@ import { AttachmentRemoteDataSourceService } from 'src/app/module/chat/data/data
 import { AttachmentLocalDataSource } from 'src/app/module/chat/data/data-source/attachment/attachment-local-data-source.service'
 import { convertBlobToDataURL } from 'src/app/utils/ToBase64';
 import { Result } from 'neverthrow';
+import { Logger } from 'src/app/services/logger/main/service';
 
 const MessageAttachmentByMessageIdSchema = z.object({
   $messageId: z.number(),
@@ -33,10 +34,13 @@ export class MessageAttachmentByMessageIdUseCase {
         return getLocalAttachment.map(e => e.file)
       }
     } else {
-      const result = await this.AttachmentRemoteDataSourceService.getAttachment(input)
+      const result = await this.AttachmentRemoteDataSourceService.getAttachment(input.id)
       return result.asyncMap(async (e) => {
 
         const dataUrl = await convertBlobToDataURL(e)
+        Logger.info('downloaded file', {
+          data: dataUrl.slice(0, 100)+'...'
+        })
 
         this.AttachmentLocalDataSource.insert({
           $messageId: input.$messageId,