fix search page

src/app/module/chat/domain/use-case/message/messages-send-offline-use-case.service.ts

@@ -40,73 +40,77 @@ export class SendLocalMessagesUseCaseService {
         for(const message of messages) {
           const room = allRooms.value.find(e => e.id == message.roomId)
 
-          const attachments =  await this.AttachmentRepositoryService.find({$messageId: message.$id})
+          if(room) {
 
-          if(attachments.isOk()) {
+            const attachments =  await this.AttachmentRepositoryService.find({$messageId: message.$id})
 
-          message.attachments = attachments.value.map(e => ({
-            fileType: e.fileType,
-            source: e.source,
-            fileName: e.fileName,
-            applicationId: e.applicationId,
-            docId: e.docId,
-            id: e.id,
-            mimeType: e.mimeType,
-            description: e.description,
-            file: e.base64.split(',')[1]
-          }))
-          console.log('to upload', messages)
-          const requestId = InstanceId +'@'+ uuidv4();
+            if(attachments.isOk()) {
 
-          await this.messageLocalDataSourceService.update(message.$id, { sending: true })
+              message.attachments = attachments.value.map(e => ({
+                fileType: e.fileType,
+                source: e.source,
+                fileName: e.fileName,
+                applicationId: e.applicationId,
+                docId: e.docId,
+                id: e.id,
+                mimeType: e.mimeType,
+                description: e.description,
+                file: e.base64.split(',')[1]
+              }))
+              console.log('to upload', messages)
+              const requestId = InstanceId +'@'+ uuidv4();
 
-          let sendMessageResult: Result<MessageOutPutDataDTO, any>
-          if(room.roomType == RoomType.Group) {
-            const DTO = MessageMapper.fromDomain(message, message.requestId)
-            sendMessageResult = await this.MessageSocketRepositoryService.sendGroupMessage(DTO)
-          } else {
+              await this.messageLocalDataSourceService.update(message.$id, { sending: true })
 
-            if(message.receiverId) {
-              const DTO = MessageMapper.fromDomain(message, message.requestId)
-              sendMessageResult = await this.messageSocketRepositoryService.sendDirectMessage(DTO)
-            } else {
-              const getRoomMembers = await this.MemberListLocalRepository.directMember({
-                roomId:message.roomId,
-                currentUserId: SessionStore.user.UserId
-              })
-              if(getRoomMembers.isOk()) {
-                message.receiverId = getRoomMembers.value.wxUserId
+              let sendMessageResult: Result<MessageOutPutDataDTO, any>
+              if(room.roomType == RoomType.Group) {
                 const DTO = MessageMapper.fromDomain(message, message.requestId)
-                sendMessageResult = await this.messageSocketRepositoryService.sendGroupMessage(DTO)
+                sendMessageResult = await this.MessageSocketRepositoryService.sendGroupMessage(DTO)
               } else {
-                console.log('not found direct users', getRoomMembers.error)
+
+                if(message.receiverId) {
+                  const DTO = MessageMapper.fromDomain(message, message.requestId)
+                  sendMessageResult = await this.messageSocketRepositoryService.sendDirectMessage(DTO)
+                } else {
+                  const getRoomMembers = await this.MemberListLocalRepository.directMember({
+                    roomId:message.roomId,
+                    currentUserId: SessionStore.user.UserId
+                  })
+                  if(getRoomMembers.isOk()) {
+                    message.receiverId = getRoomMembers.value.wxUserId
+                    const DTO = MessageMapper.fromDomain(message, message.requestId)
+                    sendMessageResult = await this.messageSocketRepositoryService.sendGroupMessage(DTO)
+                  } else {
+                    console.log('not found direct users', getRoomMembers.error)
+                  }
+                }
+
+              }
+
+              if(sendMessageResult.isOk()) {
+
+                if(sendMessageResult.value.sender == undefined || sendMessageResult.value.sender == null) {
+
+                  delete sendMessageResult.value.sender
+                }
+
+                let clone: MessageTable = {
+                  ...sendMessageResult.value,
+                  id: sendMessageResult.value.id,
+                  $id : message.$id
+                }
+
+                clone.sending = false
+                console.log({clone})
+                console.log('send message local '+ messages.length)
+
+                this.messageLocalDataSourceService.update(message.$id, {id: sendMessageResult.value.id, sending: false})
+              } else {
+                this.messageLocalDataSourceService.update(message.$id, {sending: false})
               }
             }
-
           }
 
-          if(sendMessageResult.isOk()) {
-
-            if(sendMessageResult.value.sender == undefined || sendMessageResult.value.sender == null) {
-
-              delete sendMessageResult.value.sender
-            }
-
-            let clone: MessageTable = {
-              ...sendMessageResult.value,
-              id: sendMessageResult.value.id,
-              $id : message.$id
-            }
-
-            clone.sending = false
-            console.log({clone})
-            console.log('send message local '+ messages.length)
-
-            this.messageLocalDataSourceService.update(message.$id, {id: sendMessageResult.value.id, sending: false})
-          } else {
-            this.messageLocalDataSourceService.update(message.$id, {sending: false})
-          }
-          }
         }
       }