refactor: added logs

Signed-off-by: Sai Ranjit Tummalapalli <[email protected]>
credebl · Jul 15, 2024 · 021e0ac · 021e0ac
1 parent 5980086
commit 021e0ac
Showing 1 changed file with 4 additions and 0 deletions.
diff --git 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)
     )