Fixing uncontrolled log size (#262)

* Fixing uncontrolled log size

* Test fix

* Another test fix

Author: CarlosGamero

packages/amqp/test/consumers/AmqpPermissionConsumer.spec.ts

@@ -15,7 +15,6 @@ import type { AmqpPermissionPublisher } from '../publishers/AmqpPermissionPublis
 import { TEST_AMQP_CONFIG } from '../utils/testAmqpConfig.ts'
 import type { Dependencies } from '../utils/testContext.ts'
 import { SINGLETON_CONFIG, registerDependencies } from '../utils/testContext.ts'
-
 import { AmqpPermissionConsumer } from './AmqpPermissionConsumer.ts'
 import type {
   PERMISSIONS_ADD_MESSAGE_TYPE,
@@ -111,8 +110,7 @@ describe('AmqpPermissionConsumer', () => {
           timestamp: expect.any(String),
         },
         {
-          messageId: '1',
-          processingResult: { status: 'consumed' },
+          processedMessageMetadata: expect.any(String),
         },
       ])
     })

packages/core/lib/queues/AbstractQueueService.ts

@@ -1,6 +1,12 @@
 import { types } from 'node:util'
 
-import type { CommonLogger, Either, ErrorReporter, ErrorResolver } from '@lokalise/node-core'
+import {
+  type CommonLogger,
+  type Either,
+  type ErrorReporter,
+  type ErrorResolver,
+  stringValueSerializer,
+} from '@lokalise/node-core'
 import { resolveGlobalErrorLogObject } from '@lokalise/node-core'
 import type { CommonEventDefinition } from '@message-queue-toolkit/schemas'
 import type { ZodSchema, ZodType } from 'zod'
@@ -245,7 +251,7 @@ export abstract class AbstractQueueService<
     )
     if (debugLoggingEnabled) {
       this.logger.debug(
-        processedMessageMetadata,
+        { processedMessageMetadata: stringValueSerializer(processedMessageMetadata) },
         `Finished processing message ${processedMessageMetadata.messageId}`,
       )
     }

packages/core/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@message-queue-toolkit/core",
-    "version": "21.0.0",
+    "version": "21.0.1",
     "private": false,
     "license": "MIT",
     "description": "Useful utilities, interfaces and base classes for message queue handling. Supports AMQP and SQS with a common abstraction on top currently",
@@ -29,7 +29,7 @@
         "prepublishOnly": "npm run lint && npm run build"
     },
     "dependencies": {
-        "@lokalise/node-core": "^13.3.0",
+        "@lokalise/node-core": "^13.6.0",
         "@message-queue-toolkit/schemas": "^6.0.0",
         "fast-equals": "^5.0.1",
         "json-stream-stringify": "^3.1.6",

packages/sqs/test/consumers/SqsPermissionConsumer.spec.ts

@@ -318,8 +318,7 @@ describe('SqsPermissionConsumer', () => {
           timestamp: expect.any(String),
         },
         {
-          messageId: '1',
-          processingResult: { status: 'consumed' },
+          processedMessageMetadata: expect.any(String),
         },
       ])
       await newConsumer.close()