fix(rabbitmq): using __routeArguments__ to allow pipe injection

Author: sezanzeb

packages/rabbitmq/src/rabbitmq.constants.ts

@@ -1,6 +1,5 @@
 export const RABBIT_HANDLER = Symbol('RABBIT_HANDLER');
 export const RABBIT_CONFIG_TOKEN = Symbol('RABBIT_CONFIG');
-export const RABBIT_ARGS_METADATA = 'RABBIT_ARGS_METADATA';
 export const RABBIT_PARAM_TYPE = 3;
 export const RABBIT_HEADER_TYPE = 4;
 export const RABBIT_REQUEST_TYPE = 5;

packages/rabbitmq/src/rabbitmq.decorators.ts

@@ -7,9 +7,9 @@ import {
   Type,
   assignMetadata,
 } from '@nestjs/common';
+import { ROUTE_ARGS_METADATA } from '@nestjs/common/constants';
 import { isString } from 'lodash';
 import {
-  RABBIT_ARGS_METADATA,
   RABBIT_CONFIG_TOKEN,
   RABBIT_HANDLER,
   RABBIT_HEADER_TYPE,
@@ -47,14 +47,14 @@ export const createPipesRpcParamDecorator =
   ): ParameterDecorator =>
   (target, key, index) => {
     const args =
-      Reflect.getMetadata(RABBIT_ARGS_METADATA, target.constructor, key) || {};
+      Reflect.getMetadata(ROUTE_ARGS_METADATA, target.constructor, key) || {};
 
     const hasParamData = isString(data);
     const paramData = hasParamData ? data : undefined;
     const paramPipes = hasParamData ? pipes : [data, ...pipes];
 
     Reflect.defineMetadata(
-      RABBIT_ARGS_METADATA,
+      ROUTE_ARGS_METADATA,
       assignMetadata(args, type, index, paramData, ...paramPipes),
       target.constructor,
       key

packages/rabbitmq/src/rabbitmq.module.ts

@@ -10,15 +10,12 @@ import {
   OnApplicationBootstrap,
   OnApplicationShutdown,
 } from '@nestjs/common';
+import { ROUTE_ARGS_METADATA } from '@nestjs/common/constants';
 import { ExternalContextCreator } from '@nestjs/core/helpers/external-context-creator';
 import { groupBy } from 'lodash';
 import { AmqpConnection } from './amqp/connection';
 import { AmqpConnectionManager } from './amqp/connectionManager';
-import {
-  RABBIT_ARGS_METADATA,
-  RABBIT_CONFIG_TOKEN,
-  RABBIT_HANDLER,
-} from './rabbitmq.constants';
+import { RABBIT_CONFIG_TOKEN, RABBIT_HANDLER } from './rabbitmq.constants';
 import { RabbitRpcParamsFactory } from './rabbitmq.factory';
 import { RabbitHandlerConfig, RabbitMQConfig } from './rabbitmq.interfaces';
 
@@ -190,7 +187,7 @@ export class RabbitMQModule
               discoveredMethod.parentClass.instance,
               discoveredMethod.handler,
               discoveredMethod.methodName,
-              RABBIT_ARGS_METADATA,
+              ROUTE_ARGS_METADATA,
               this.rpcParamsFactory,
               undefined, // contextId
               undefined, // inquirerId