send attachment to mobile and take picture

This commit is contained in:
Peter Maquiran
2024-08-16 11:26:31 +01:00
parent d1918d6695
commit 5f4d5ab1a8
12 changed files with 139 additions and 135 deletions
@@ -227,11 +227,11 @@ export class RoomRepositoryService {
@captureAndReraiseAsync('RoomRepositoryService/addMemberToRoom')
async addMemberToRoom(data: AddMemberToRoomInputDTO) {
return this.roomLiveSignalRDataSourceService.addMemberToRoom(data)
// return this.roomLiveSignalRDataSourceService.addMemberToRoom(data)
// const result = await this.roomRemoteDataSourceService.addMemberToRoom(data)
const result = await this.roomRemoteDataSourceService.addMemberToRoom(data)
// return result
return result
}
async updateMemberStatus(data: MemberListUPdateStatusInputDTO) {
@@ -14,8 +14,6 @@ export class ListenMessageDeleteByRoomIdService {
execute({roomId}) {
return this.messageLiveSignalRDataSourceService.getMessageDelete().pipe(
filter((message) => {
console.log({message}, 'delete')
return roomId == message?.roomId
} )
)
@@ -30,7 +30,6 @@ export class MessageAttachmentByMessageIdUseCase {
if(getLocalAttachment.isOk() && getLocalAttachment.value) {
if(getLocalAttachment.value) {
console.log('found local', getLocalAttachment.value)
return getLocalAttachment.map(e => e.file)
}
} else {
@@ -19,7 +19,9 @@ export class SyncAllRoomMessagesService {
const allRooms: RoomTable[] = await this.RoomRepositoryService.getRoomList()
if(allRooms) {
console.log('allRooms', allRooms)
if(allRooms.length == 0) {
console.log('no room to sync')
}
for(const room of allRooms) {
this.MessageRepositoryService.listAllMessagesByRoomId(room.id)
}
@@ -6,7 +6,7 @@ import { Plugins } from '@capacitor/core';
import { UserTypingDTO } from '../../data/dto/typing/typingInputDTO';
import { MessageOutPutDataDTO } from '../../data/dto/message/messageOutputDTO';
import { MessageDeleteInputDTO } from '../../data/dto/message/messageDeleteInputDTO';
import { object, z } from 'zod';
import { z } from 'zod';
import { switchMap } from 'rxjs/operators';
import { Result } from 'neverthrow';
@@ -84,7 +84,6 @@ export class SignalRService {
})
this.connection.getMessages().subscribe((data) => {
console.log("receive message 55")
this.messageSubject.next(data)
})
this.connection.getTyping().subscribe((data) => {
@@ -92,7 +91,6 @@ export class SignalRService {
})
this.connection.getMessageDelete().subscribe((data) => {
console.log('delete middleware', data)
this.messageDelete.next(data)
})