fix(microservices): add missing get pattern to rmq and tcp

Author: kamilmysliwiec

packages/microservices/ctx-host/rmq.context.ts

@@ -1,6 +1,6 @@
 import { BaseRpcContext } from './base-rpc.context';
 
-type RmqContextArgs = [Record<string, any>, any];
+type RmqContextArgs = [Record<string, any>, any, string];
 
 export class RmqContext extends BaseRpcContext<RmqContextArgs> {
   constructor(args: RmqContextArgs) {
@@ -20,4 +20,11 @@ export class RmqContext extends BaseRpcContext<RmqContextArgs> {
   getChannelRef() {
     return this.args[1];
   }
+
+  /**
+   * Returns the name of the pattern.
+   */
+  getPattern() {
+    return this.args[2];
+  }
 }

packages/microservices/ctx-host/tcp.context.ts

@@ -1,7 +1,7 @@
 import { JsonSocket } from '../helpers';
 import { BaseRpcContext } from './base-rpc.context';
 
-type TcpContextArgs = [JsonSocket];
+type TcpContextArgs = [JsonSocket, string];
 
 export class TcpContext extends BaseRpcContext<TcpContextArgs> {
   constructor(args: TcpContextArgs) {
@@ -14,4 +14,11 @@ export class TcpContext extends BaseRpcContext<TcpContextArgs> {
   getSocketRef() {
     return this.args[0];
   }
+
+  /**
+   * Returns the name of the pattern.
+   */
+  getPattern() {
+    return this.args[1];
+  }
 }

packages/microservices/server/server-rmq.ts

@@ -110,7 +110,7 @@ export class ServerRMQ extends Server implements CustomTransportStrategy {
       ? packet.pattern
       : JSON.stringify(packet.pattern);
 
-    const rmqContext = new RmqContext([message, channel]);
+    const rmqContext = new RmqContext([message, channel, pattern]);
     if (isUndefined((packet as IncomingRequest).id)) {
       return this.handleEvent(pattern, packet, rmqContext);
     }

packages/microservices/server/server-tcp.ts

@@ -63,7 +63,7 @@ export class ServerTCP extends Server implements CustomTransportStrategy {
       ? JSON.stringify(packet.pattern)
       : packet.pattern;
 
-    const tcpContext = new TcpContext([socket]);
+    const tcpContext = new TcpContext([socket, pattern]);
     if (isUndefined((packet as IncomingRequest).id)) {
       return this.handleEvent(pattern, packet, tcpContext);
     }

packages/microservices/test/ctx-host/rmq.context.spec.ts

@@ -2,11 +2,11 @@ import { expect } from 'chai';
 import { RmqContext } from '../../ctx-host';
 
 describe('RmqContext', () => {
-  const args = [{ test: true }, 'test'];
+  const args = [{ test: true }, 'test', 'pattern'];
   let context: RmqContext;
 
   beforeEach(() => {
-    context = new RmqContext(args as [Record<string, any>, any]);
+    context = new RmqContext(args as [Record<string, any>, any, string]);
   });
   describe('getMessage', () => {
     it('should return original message', () => {
@@ -18,4 +18,9 @@ describe('RmqContext', () => {
       expect(context.getChannelRef()).to.be.eql(args[1]);
     });
   });
+  describe('getPattern', () => {
+    it('should return pattern', () => {
+      expect(context.getPattern()).to.be.eql(args[2]);
+    });
+  });
 });

packages/microservices/test/ctx-host/tcp.context.spec.ts

@@ -2,7 +2,7 @@ import { expect } from 'chai';
 import { TcpContext } from '../../ctx-host';
 
 describe('TcpContext', () => {
-  const args = [{}];
+  const args = [{}, 'pattern'];
   let context: TcpContext;
 
   beforeEach(() => {
@@ -13,4 +13,9 @@ describe('TcpContext', () => {
       expect(context.getSocketRef()).to.be.eql(args[0]);
     });
   });
+  describe('getPattern', () => {
+    it('should return pattern', () => {
+      expect(context.getPattern()).to.be.eql(args[1]);
+    });
+  });
 });