✨ Support for using a custom replacer for JSON.stringify

mkfyi · Feb 19, 2024 · 108cc12 · 108cc12
1 parent 0a4366e
commit 108cc12
Show file tree

Hide file tree

Showing 4 changed files with 16 additions and 2 deletions.
diff --git a/lib/common/constants.ts b/lib/common/constants.ts
@@ -1,5 +1,6 @@
 export const DEFAULT_CONNECTION_NAME = 'default';
 export const JSON_SERVICE_PARSER = 'rmq.json_service.parser';
+export const JSON_SERVICE_REPLACER = 'rmq.json_service.replacer';
 export const LISTENER_HANDLER_METADATA = 'rmq.meta.handler.listener';
 export const PUB_SUB_ANDLER_METADATA = 'rmq.meta.handler.pub_sub';
 export const ROUTING_HANDLER_METADATA = 'rmq.meta.handler.routing';

diff --git a/lib/common/interfaces/rabbitmq.module-options.ts b/lib/common/interfaces/rabbitmq.module-options.ts
@@ -62,6 +62,7 @@ export interface BaseModuleOptions<T> {
     | TopicQueueAdapterOptions
   )[];
   parser?: ActionCallback;
+  replacer?: ActionCallback;
 }
 
 export interface RabbitMQModuleOptionsFactory

diff --git a/lib/core/json.service.ts b/lib/core/json.service.ts
@@ -1,15 +1,19 @@
 import { Inject, Injectable } from '@nestjs/common';
 import { ActionCallback, Json } from '../common/interfaces/json.interface';
-import { JSON_SERVICE_PARSER } from '../common/constants';
+import {
+  JSON_SERVICE_PARSER,
+  JSON_SERVICE_REPLACER,
+} from '../common/constants';
 
 @Injectable()
 export class JsonService implements Json {
   public constructor(
     @Inject(JSON_SERVICE_PARSER) private readonly parser?: ActionCallback,
+    @Inject(JSON_SERVICE_REPLACER) private readonly replacer?: ActionCallback,
   ) {}
 
   public stringify<T>(data: T, space?: number | string): string {
-    return JSON.stringify(data, undefined, space);
+    return JSON.stringify(data, this.replacer, space);
   }
 
   public parse<T = unknown>(data: string): T {

diff --git a/lib/rabbitmq.module.ts b/lib/rabbitmq.module.ts
@@ -20,6 +20,7 @@ import {
   DEFAULT_CONNECTION_NAME,
   EXCEPTION_HANDLER_INJECTION_TOKEN,
   JSON_SERVICE_PARSER,
+  JSON_SERVICE_REPLACER,
 } from './common/constants';
 import { buildConnectionToken } from './core/utils/build-connection-token';
 import { ConnectionWrapper } from './core/wrappers/connection.wrapper';
@@ -108,6 +109,7 @@ export class RabbitMQModule implements OnApplicationBootstrap {
     return this.assemble(
       options.exceptionHandler,
       options.parser,
+      options.replacer,
       (Array.isArray(options.connection)
         ? options.connection
         : [{ name: DEFAULT_CONNECTION_NAME, ...options.connection }]
@@ -133,6 +135,7 @@ export class RabbitMQModule implements OnApplicationBootstrap {
     return this.assemble(
       options.exceptionHandler,
       options.parser,
+      options.replacer,
       (Array.isArray(options.connection)
         ? options.connection
         : [{ name: DEFAULT_CONNECTION_NAME, ...options.connection }]
@@ -163,6 +166,7 @@ export class RabbitMQModule implements OnApplicationBootstrap {
   private static assemble(
     exceptionHandler: Type | undefined,
     parser: ActionCallback | undefined,
+    replacer: ActionCallback | undefined,
     connections: (FactoryProvider | ValueProvider)[],
     adapters?: RabbitMQModuleOptions['adapters'],
     imports?: DynamicModule['imports'],
@@ -178,6 +182,10 @@ export class RabbitMQModule implements OnApplicationBootstrap {
           provide: JSON_SERVICE_PARSER,
           useValue: parser,
         },
+        {
+          provide: JSON_SERVICE_REPLACER,
+          useValue: null,
+        },
         JsonService,
         exceptionHandler
           ? {