refactor(microservices): simplify clients module

Author: kamilmysliwiec

packages/microservices/module/clients.constants.ts

@@ -1,14 +1,13 @@
 import { DynamicModule, Module } from '@nestjs/common';
 import { ClientProxyFactory } from './../client';
-import { getClientToken } from './clients.utils';
 import { ClientsModuleOptions } from './interfaces/clients-module.interface';
 
 @Module({})
 export class ClientsModule {
   static register(options: ClientsModuleOptions): DynamicModule {
     const clients = (options || []).map(item => ({
-      provide: getClientToken(item.name),
-      useValue: ClientProxyFactory.create(item.options),
+      provide: item.name,
+      useValue: ClientProxyFactory.create(item),
     }));
     return {
       module: ClientsModule,

packages/microservices/module/clients.decorators.ts

@@ -1,3 +1 @@
-export * from './clients.decorators';
 export * from './clients.module';
-export * from './clients.utils';

packages/microservices/module/clients.module.ts

@@ -1,8 +1,7 @@
 import { ClientOptions } from '../../interfaces';
 
-export interface ClientProviderOptions {
+export type ClientProviderOptions = ClientOptions & {
   name: string;
-  options: ClientOptions;
-}
+};
 
 export interface ClientsModuleOptions extends Array<ClientProviderOptions> {}

packages/microservices/module/clients.utils.ts

@@ -0,0 +1 @@
+export const MATH_SERVICE = 'MATH_SERVICE';

packages/microservices/module/index.ts

@@ -1,16 +1,11 @@
-import { Controller, Get } from '@nestjs/common';
-import {
-  Client,
-  ClientProxy,
-  MessagePattern,
-  Transport,
-} from '@nestjs/microservices';
+import { Controller, Get, Inject } from '@nestjs/common';
+import { ClientProxy, MessagePattern } from '@nestjs/microservices';
 import { Observable } from 'rxjs';
+import { MATH_SERVICE } from './math.constants';
 
 @Controller()
 export class MathController {
-  @Client({ transport: Transport.TCP })
-  client: ClientProxy;
+  constructor(@Inject(MATH_SERVICE) private readonly client: ClientProxy) {}
 
   @Get()
   execute(): Observable<number> {