From 021e0ac60bc520241d647beea17ffdc364888f97 Mon Sep 17 00:00:00 2001 From: Sai Ranjit Tummalapalli Date: Mon, 15 Jul 2024 15:57:05 +0530 Subject: [PATCH] refactor: added logs Signed-off-by: Sai Ranjit Tummalapalli --- src/storage/StorageMessageQueue.ts | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/storage/StorageMessageQueue.ts b/src/storage/StorageMessageQueue.ts index 7d0e6e1..ab45f56 100644 --- a/src/storage/StorageMessageQueue.ts +++ b/src/storage/StorageMessageQueue.ts @@ -42,6 +42,8 @@ export class StorageServiceMessageQueue implements MessagePickupRepository { const messageRecords = await this.messageRepository.findByConnectionId(this.agentContext, connectionId) + this.agentContext.config.logger.debug(`Found ${messageRecords.length} messages for connection ${connectionId}`) + return messageRecords.length } @@ -101,6 +103,8 @@ export class StorageServiceMessageQueue implements MessagePickupRepository { public async removeMessages(options: RemoveMessagesOptions) { const { messageIds } = options + this.agentContext.config.logger.debug(`Removing message ids ${messageIds}`) + const deletePromises = messageIds.map((messageId) => this.messageRepository.deleteById(this.agentContext, messageId) )