format(@nestjs) run prettier, format existing codebase

Author: kamilmysliwiec

…microservices/e2e/multicast-mqtt.spec.ts …microservices/e2e/broadcast-mqtt.spec.tsintegration/microservices/e2e/multicast-mqtt.spec.ts renamed to integration/microservices/e2e/broadcast-mqtt.spec.ts integration/microservices/e2e/multicast-mqtt.spec.ts renamed to integration/microservices/e2e/broadcast-mqtt.spec.ts

@@ -3,15 +3,15 @@ import * as request from 'supertest';
 import { Test } from '@nestjs/testing';
 import { INestApplication } from '@nestjs/common';
 import { Transport } from '@nestjs/microservices';
-import { MqttMulticastController } from '../src/mqtt/mqtt-multicast.controller';
+import { MqttBroadcastController } from '../src/mqtt/mqtt-broadcast.controller';
 
 describe('MQTT transport', () => {
   let server;
   let app: INestApplication;
 
   beforeEach(async () => {
     const module = await Test.createTestingModule({
-      controllers: [MqttMulticastController],
+      controllers: [MqttBroadcastController],
     }).compile();
 
     server = express();
@@ -26,9 +26,9 @@ describe('MQTT transport', () => {
     await app.init();
   });
 
-  it(`Multicast (2 subscribers)`, () => {
+  it(`Broadcast (2 subscribers)`, () => {
     return request(server)
-      .get('/multicast')
+      .get('/broadcast')
       .expect(200, '2');
   });
 

…microservices/e2e/multicast-nats.spec.ts …microservices/e2e/broadcast-nats.spec.tsintegration/microservices/e2e/multicast-nats.spec.ts renamed to integration/microservices/e2e/broadcast-nats.spec.ts integration/microservices/e2e/multicast-nats.spec.ts renamed to integration/microservices/e2e/broadcast-nats.spec.ts

@@ -3,15 +3,15 @@ import * as request from 'supertest';
 import { Test } from '@nestjs/testing';
 import { INestApplication } from '@nestjs/common';
 import { Transport } from '@nestjs/microservices';
-import { NatsMulticastController } from '../src/nats/nats-multicast.controller';
+import { NatsBroadcastController } from '../src/nats/nats-broadcast.controller';
 
 describe('NATS transport', () => {
   let server;
   let app: INestApplication;
 
   beforeEach(async () => {
     const module = await Test.createTestingModule({
-      controllers: [NatsMulticastController],
+      controllers: [NatsBroadcastController],
     }).compile();
 
     server = express();
@@ -27,9 +27,9 @@ describe('NATS transport', () => {
     await app.init();
   });
 
-  it(`Multicast (2 subscribers)`, () => {
+  it(`Broadcast (2 subscribers)`, () => {
     return request(server)
-      .get('/multicast')
+      .get('/broadcast')
       .expect(200, '2');
   });
 

…icroservices/e2e/multicast-redis.spec.ts …icroservices/e2e/broadcast-redis.spec.tsintegration/microservices/e2e/multicast-redis.spec.ts renamed to integration/microservices/e2e/broadcast-redis.spec.ts integration/microservices/e2e/multicast-redis.spec.ts renamed to integration/microservices/e2e/broadcast-redis.spec.ts

@@ -4,15 +4,15 @@ import { Test } from '@nestjs/testing';
 import { INestApplication } from '@nestjs/common';
 import { Transport } from '@nestjs/microservices';
 import { RedisController } from '../src/redis/redis.controller';
-import { RedisMulticastController } from '../src/redis/redis-multicast.controller';
+import { RedisBroadcastController } from '../src/redis/redis-broadcast.controller';
 
 describe('REDIS transport', () => {
   let server;
   let app: INestApplication;
 
   beforeEach(async () => {
     const module = await Test.createTestingModule({
-      controllers: [RedisMulticastController],
+      controllers: [RedisBroadcastController],
     }).compile();
 
     server = express();
@@ -27,9 +27,9 @@ describe('REDIS transport', () => {
     await app.init();
   });
 
-  it(`Multicast (2 subscribers)`, () => {
+  it(`Broadcast (2 subscribers)`, () => {
     return request(server)
-      .get('/multicast')
+      .get('/broadcast')
       .expect(200, '2');
   });
 

…es/src/mqtt/mqtt-multicast.controller.ts …es/src/mqtt/mqtt-broadcast.controller.tsintegration/microservices/src/mqtt/mqtt-multicast.controller.ts renamed to integration/microservices/src/mqtt/mqtt-broadcast.controller.ts integration/microservices/src/mqtt/mqtt-multicast.controller.ts renamed to integration/microservices/src/mqtt/mqtt-broadcast.controller.ts

@@ -9,19 +9,19 @@ import { Observable } from 'rxjs/Observable';
 import { scan, take } from 'rxjs/operators';
 
 @Controller()
-export class MqttMulticastController {
+export class MqttBroadcastController {
   @Client({ transport: Transport.MQTT })
   client: ClientProxy;
 
-  @Get('multicast')
+  @Get('broadcast')
   multicats() {
     return this.client
-      .send<number>({ cmd: 'multicast' }, {})
+      .send<number>({ cmd: 'broadcast' }, {})
       .pipe(scan((a, b) => a + b), take(2));
   }
 
-  @MessagePattern({ cmd: 'multicast' })
-  replyMulticast(): Observable<number> {
+  @MessagePattern({ cmd: 'broadcast' })
+  replyBroadcast(): Observable<number> {
     return new Observable(observer => observer.next(1));
   }
 }

…es/src/nats/nats-multicast.controller.ts …es/src/nats/nats-broadcast.controller.tsintegration/microservices/src/nats/nats-multicast.controller.ts renamed to integration/microservices/src/nats/nats-broadcast.controller.ts integration/microservices/src/nats/nats-multicast.controller.ts renamed to integration/microservices/src/nats/nats-broadcast.controller.ts

@@ -9,19 +9,19 @@ import { Observable } from 'rxjs/Observable';
 import { scan, take } from 'rxjs/operators';
 
 @Controller()
-export class NatsMulticastController {
+export class NatsBroadcastController {
   @Client({ transport: Transport.NATS })
   client: ClientProxy;
 
-  @Get('multicast')
+  @Get('broadcast')
   multicats() {
     return this.client
-      .send<number>({ cmd: 'multicast' }, {})
+      .send<number>({ cmd: 'broadcast' }, {})
       .pipe(scan((a, b) => a + b), take(2));
   }
 
-  @MessagePattern({ cmd: 'multicast' })
-  replyMulticast(): Observable<number> {
+  @MessagePattern({ cmd: 'broadcast' })
+  replyBroadcast(): Observable<number> {
     return new Observable(observer => observer.next(1));
   }
 }

…/src/redis/redis-multicast.controller.ts …/src/redis/redis-broadcast.controller.tsintegration/microservices/src/redis/redis-multicast.controller.ts renamed to integration/microservices/src/redis/redis-broadcast.controller.ts integration/microservices/src/redis/redis-multicast.controller.ts renamed to integration/microservices/src/redis/redis-broadcast.controller.ts

@@ -9,21 +9,21 @@ import { Observable } from 'rxjs/Observable';
 import { scan, take } from 'rxjs/operators';
 
 @Controller()
-export class RedisMulticastController {
+export class RedisBroadcastController {
   @Client({ transport: Transport.REDIS })
   client: ClientProxy;
 
-  @Get('multicast')
+  @Get('broadcast')
   multicats() {
-    return this.client.send<number>({ cmd: 'multicast' }, {})
+    return this.client.send<number>({ cmd: 'broadcast' }, {})
       .pipe(
         scan((a, b) => a + b),
         take(2),
       );
   }
 
-  @MessagePattern({ cmd: 'multicast' })
-  replyMulticast(): Observable<number> {
+  @MessagePattern({ cmd: 'broadcast' })
+  replyBroadcast(): Observable<number> {
     return new Observable((observer) => observer.next(1));
   }
 }

src/core/scanner.ts

@@ -66,7 +66,11 @@ export class DependenciesScanner {
     });
   }
 
-  public reflectRelatedModules(module: Type<any>, token: string, context: string) {
+  public reflectRelatedModules(
+    module: Type<any>,
+    token: string,
+    context: string,
+  ) {
     const modules = [
       ...this.reflectMetadata(module, metadata.MODULES),
       ...this.container.getDynamicMetadataByToken(

src/websockets/web-sockets-controller.ts

@@ -9,10 +9,7 @@ import {
 } from './gateway-metadata-explorer';
 import { Subject } from 'rxjs/Subject';
 import { SocketServerProvider } from './socket-server-provider';
-import {
-  PORT_METADATA,
-  GATEWAY_OPTIONS,
-} from './constants';
+import { PORT_METADATA, GATEWAY_OPTIONS } from './constants';
 import { Type } from '@nestjs/common/interfaces/type.interface';
 import { MetadataScanner } from '@nestjs/core/metadata-scanner';
 import { NestContainer } from '@nestjs/core/injector/container';
@@ -47,7 +44,7 @@ export class WebSocketsController {
   ) {
     const options = Reflect.getMetadata(GATEWAY_OPTIONS, metatype) || {};
     const port = Reflect.getMetadata(PORT_METADATA, metatype) || 0;
-    
+
     if (!Number.isInteger(port)) {
       throw new InvalidSocketPortException(port, metatype);
     }