chore(@nestjs) publish v8.0.4 release

fix(deps): update dependency bull to v3.25.0

.circleci/config.yml

@@ -74,6 +74,11 @@ jobs:
     <<: *unit-tests-template
     docker:
       - image: circleci/node:14
+    
+  test_node_16:
+    <<: *unit-tests-template
+    docker:
+      - image: circleci/node:16
 
   lint:
     working_directory: ~/nest
@@ -160,6 +165,9 @@ workflows:
   build-and-test:
     jobs:
       - build
+      - test_node_16:
+          requires:
+            - build
       - test_node_14:
           requires:
             - build

.eslintrc.js

@@ -9,7 +9,6 @@ module.exports = {
     'plugin:@typescript-eslint/eslint-recommended',
     'plugin:@typescript-eslint/recommended',
     'prettier',
-    'prettier/@typescript-eslint',
   ],
   root: true,
   env: {

.github/PULL_REQUEST_TEMPLATE.md

@@ -10,15 +10,13 @@ Please check if your PR fulfills the following requirements:
 What kind of change does this PR introduce?
 
 <!-- Please check the one that applies to this PR using "x". -->
-```
-[ ] Bugfix
-[ ] Feature
-[ ] Code style update (formatting, local variables)
-[ ] Refactoring (no functional changes, no api changes)
-[ ] Build related changes
-[ ] CI related changes
-[ ] Other... Please describe:
-```
+- [ ] Bugfix
+- [ ] Feature
+- [ ] Code style update (formatting, local variables)
+- [ ] Refactoring (no functional changes, no api changes)
+- [ ] Build related changes
+- [ ] CI related changes
+- [ ] Other... Please describe:
 
 ## What is the current behavior?
 <!-- Please describe the current behavior that you are modifying, or link to a relevant issue. -->
@@ -30,10 +28,8 @@ Issue Number: N/A
 
 
 ## Does this PR introduce a breaking change?
-```
-[ ] Yes
-[ ] No
-```
+- [ ] Yes
+- [ ] No
 
 <!-- If this PR contains a breaking change, please describe the impact and migration path for existing applications below. -->
 

.mocharc.js

@@ -0,0 +1,7 @@
+module.exports = {
+  mochaHooks: {
+    beforeAll: function() {
+      require('reflect-metadata');
+    }
+  }
+};

Readme.md

@@ -37,6 +37,8 @@ Nest is a framework for building efficient, scalable <a href="http://nodejs.org"
 
 * To check out the [guide](https://docs.nestjs.com), visit [docs.nestjs.com](https://docs.nestjs.com). :books:
 * 要查看中文 [指南](readme_zh.md), 请访问 [docs.nestjs.cn](https://docs.nestjs.cn). :books:
+* [가이드](readme_kr.md)를 확인하려면, [docs.nestjs.com](https://docs.nestjs.com)를 방문하세요.:books: 
+* チェックするには [ガイド](readme_jp.md), 詳しくは [docs.nestjs.com](https://docs.nestjs.com). :books: 
 
 ## Questions
 
@@ -64,6 +66,8 @@ Nest is an MIT-licensed open source project. It can grow thanks to the sponsors
 #### Gold Sponsors
 
 <table style="text-align:center;"><tr><td>
+  <a href="https://careers.labster.com/departments/platform" target="_blank"><img src="https://nestjs.com/img/labster-logo.png" width="170" valign="middle" /></a></td><td>
+<a href="https://weld.so/" target="_blank"><img src="https://nestjs.com/img/weld-logo.svg" width="150" valign="middle" /></a></td><td>
 <a href="https://valor-software.com/" target="_blank"><img src="https://docs.nestjs.com/assets/sponsors/valor-software.png" width="170" valign="middle" /></a></td></tr></table>
 
 #### Silver Sponsors
@@ -72,7 +76,8 @@ Nest is an MIT-licensed open source project. It can grow thanks to the sponsors
 <a href="https://neoteric.eu/" target="_blank"><img src="https://nestjs.com/img/neoteric-cut.png" width="120" valign="middle" /></a> </td><td>
   <a href="http://gojob.com" target="_blank"><img src="http://nestjs.com/img/gojob-logo.png" valign="middle" width="100" /></a> </td><td>
 <a href="http://www.leogistics.com" target="_blank"><img src="https://nestjs.com/img/leogistics-logo.jpeg" width="150" valign="middle" /></td><td>
-<a href="http://www.meetdandy.com" target="_blank"><img src="https://nestjs.com/img/dandy-wide-logo.png" width="150" valign="middle" /></td></tr></table>
+<a href="http://www.meetdandy.com" target="_blank"><img src="https://nestjs.com/img/dandy-wide-logo.png" width="150" valign="middle" /></td><td>
+<a href="https://www.castlecraft.in" target="_blank"><img src="https://nestjs.com/img/castlecraft-logo.png" width="150" valign="middle" /></td></tr></table>
 
 #### Sponsors
 
@@ -95,11 +100,14 @@ Nest is an MIT-licensed open source project. It can grow thanks to the sponsors
   <td align="center" valign="middle">
   <a href="https://genuinebee.com/" target="_blank"><img src="https://nestjs.com/img/genuinebee.svg" width="97" valign="middle" /></a> </td>
 <td align="center" valign="middle"><a href="https://sanyodigital.com/" target="_blank"><img src="https://nestjs.com/img/sanyo-digital.png" width="130" valign="middle" /></a></td></tr><tr><td align="center" valign="middle"><a href="https://vpn-review.com/vpn-for-torrenting" target="_blank"><img src="https://nestjs.com/img/vpn-review-logo.png" width="85" valign="middle" /></a></td><td align="center" valign="middle"><a href="https://lambda-it.ch/" target="_blank"><img src="https://nestjs.com/img/lambda-it-logo.svg" width="115" valign="middle" /></a></td><td align="center" valign="middle"><a href="https://pickwriters.com/top-10-translation-services" target="_blank"><img src="https://nestjs.com/img/pickwriters-logo.png" width="40" valign="middle" /></a></td><td align="center" valign="middle"><a href="https://thewordpoint.com/services/localization" target="_blank"><img src="https://nestjs.com/img/thewordpoint-logo.png" width="40" valign="middle" /></a></td>
-<td align="center" valign="middle"><a href="https://streamat.se/" target="_blank"><img src="https://nestjs.com/img/streamat-logo.png" width="120" valign="middle" /></a></td>
-<td align="center" valign="middle"><a href="https://filmen.nu/" target="_blank"><img src="https://nestjs.com/img/filmen-logo.png" width="120" valign="middle" /></a></td></tr><tr>
 <td align="center" valign="middle"><a href="https://meercode.io/" target="_blank"><img src="https://nestjs.com/img/meercode-logo.png" width="60" valign="middle" /></a></td>
-  <td align="center" valign="middle"><a href="https://www.najlepszeplatformyforex.pl/blog/broker-xtb/" target="_blank"><img src="https://nestjs.com/img/npf-logo.jpg" width="200" valign="middle" /></a></td>
-    <td align="center" valign="middle"><a href="https://thestandarddaily.com/" target="_blank"><img src="https://nestjs.com/img/the-standard-daily-logo.png" width="180" valign="middle" /></a></td>
+  <td align="center" valign="middle"><a href="https://www.najlepszeplatformyforex.pl/blog/broker-xtb/" target="_blank"><img src="https://nestjs.com/img/npf-logo.jpg" width="200" valign="middle" /></a></td></tr><tr>
+<td align="center" valign="middle"><a href="https://thestandarddaily.com/" target="_blank"><img src="https://nestjs.com/img/the-standard-daily-logo.png" width="180" valign="middle" /></a></td>
+<td align="center" valign="middle"><a href="https://houseofangular.io/" target="_blank"><img src="https://nestjs.com/img/house-of-angular.png" width="100" valign="middle" /></a></td>
+<td align="center" valign="middle"><a href="https://rocketech.it/cases/?utm_source=google&utm_medium=badge&utm_campaign=nestjs" target="_blank"><img src="https://nestjs.com/img/rocketech-logo.svg" width="110" valign="middle" /></a></td>
+  <td align="center" valign="middle"><a href="https://www.bystored.com/" target="_blank"><img src="https://nestjs.com/img/stored-logo.svg" width="110" valign="middle" /></a></td>
+  <td align="center" valign="middle"><a href="https://studyclerk.com/pay-for-research-paper" target="_blank"><img src="https://nestjs.com/img/studyclerk-logo.png" width="125" valign="middle" /></a></td><td align="center" valign="middle"><a href="https://xyndata.com" target="_blank"><img src="https://nestjs.com/img/xyndata-logo.png" width="125" valign="middle" /></a></td></tr><tr>
+  <td align="center" valign="middle"><a href="https://www.anonymistic.com/" target="_blank"><img src="https://nestjs.com/img/anonymistic-logo.png" width="125" valign="middle" /></a></td>
   </tr></table>
 
 ## Backers

benchmarks/all_output.txt

@@ -2,47 +2,87 @@
 express
 -----------------------
 Running 10s test @ http://localhost:3000
-  8 threads and 1024 connections
-  Thread Stats   Avg      Stdev     Max   +/- Stdev
-    Latency    47.78ms   19.09ms 212.47ms   66.94%
-    Req/Sec     1.31k   268.90     2.07k    72.38%
-  104687 requests in 10.02s, 21.47MB read
-  Socket errors: connect 0, read 877, write 0, timeout 0
-Requests/sec:  10444.24
-Transfer/sec:      2.14MB
+1024 connections
+
+┌─────────┬───────┬───────┬───────┬────────┬──────────┬──────────┬────────┐
+│ Stat    │ 2.5%  │ 50%   │ 97.5% │ 99%    │ Avg      │ Stdev    │ Max    │
+├─────────┼───────┼───────┼───────┼────────┼──────────┼──────────┼────────┤
+│ Latency │ 55 ms │ 58 ms │ 91 ms │ 138 ms │ 61.88 ms │ 23.95 ms │ 747 ms │
+└─────────┴───────┴───────┴───────┴────────┴──────────┴──────────┴────────┘
+┌───────────┬─────────┬─────────┬─────────┬─────────┬──────────┬─────────┬─────────┐
+│ Stat      │ 1%      │ 2.5%    │ 50%     │ 97.5%   │ Avg      │ Stdev   │ Min     │
+├───────────┼─────────┼─────────┼─────────┼─────────┼──────────┼─────────┼─────────┤
+│ Req/Sec   │ 8407    │ 8407    │ 17407   │ 17743   │ 16454.41 │ 2716.94 │ 8402    │
+├───────────┼─────────┼─────────┼─────────┼─────────┼──────────┼─────────┼─────────┤
+│ Bytes/Sec │ 1.81 MB │ 1.81 MB │ 3.74 MB │ 3.81 MB │ 3.54 MB  │ 584 kB  │ 1.81 MB │
+└───────────┴─────────┴─────────┴─────────┴─────────┴──────────┴─────────┴─────────┘
+
+Req/Bytes counts sampled once per second.
+
+165k requests in 10.17s, 35.4 MB read
+-----------------------
+nest (with "@nestjs/platform-express")
+-----------------------
+Running 10s test @ http://localhost:3000
+1024 connections
+
+┌─────────┬───────┬───────┬───────┬───────┬──────────┬──────────┬────────┐
+│ Stat    │ 2.5%  │ 50%   │ 97.5% │ 99%   │ Avg      │ Stdev    │ Max    │
+├─────────┼───────┼───────┼───────┼───────┼──────────┼──────────┼────────┤
+│ Latency │ 61 ms │ 64 ms │ 71 ms │ 94 ms │ 65.44 ms │ 17.35 ms │ 325 ms │
+└─────────┴───────┴───────┴───────┴───────┴──────────┴──────────┴────────┘
+┌───────────┬─────────┬─────────┬─────────┬─────────┬─────────┬────────┬─────────┐
+│ Stat      │ 1%      │ 2.5%    │ 50%     │ 97.5%   │ Avg     │ Stdev  │ Min     │
+├───────────┼─────────┼─────────┼─────────┼─────────┼─────────┼────────┼─────────┤
+│ Req/Sec   │ 14183   │ 14183   │ 15767   │ 15991   │ 15640   │ 501.13 │ 14182   │
+├───────────┼─────────┼─────────┼─────────┼─────────┼─────────┼────────┼─────────┤
+│ Bytes/Sec │ 3.06 MB │ 3.06 MB │ 3.41 MB │ 3.45 MB │ 3.38 MB │ 108 kB │ 3.06 MB │
+└───────────┴─────────┴─────────┴─────────┴─────────┴─────────┴────────┴─────────┘
+
+Req/Bytes counts sampled once per second.
+
+156k requests in 10.24s, 33.8 MB read
 -----------------------
 fastify
 -----------------------
 Running 10s test @ http://localhost:3000
-  8 threads and 1024 connections
-  Thread Stats   Avg      Stdev     Max   +/- Stdev
-    Latency    21.80ms    8.73ms  78.12ms   55.78%
-    Req/Sec     2.99k     0.92k    5.67k    68.88%
-  238550 requests in 10.02s, 31.17MB read
-  Socket errors: connect 0, read 862, write 0, timeout 0
-Requests/sec:  23795.79
-Transfer/sec:      3.11MB
+1024 connections
+
+┌─────────┬───────┬───────┬───────┬───────┬──────────┬──────────┬─────────┐
+│ Stat    │ 2.5%  │ 50%   │ 97.5% │ 99%   │ Avg      │ Stdev    │ Max     │
+├─────────┼───────┼───────┼───────┼───────┼──────────┼──────────┼─────────┤
+│ Latency │ 27 ms │ 30 ms │ 39 ms │ 78 ms │ 31.62 ms │ 26.59 ms │ 1232 ms │
+└─────────┴───────┴───────┴───────┴───────┴──────────┴──────────┴─────────┘
+┌───────────┬─────────┬─────────┬─────────┬─────────┬─────────┬─────────┬─────────┐
+│ Stat      │ 1%      │ 2.5%    │ 50%     │ 97.5%   │ Avg     │ Stdev   │ Min     │
+├───────────┼─────────┼─────────┼─────────┼─────────┼─────────┼─────────┼─────────┤
+│ Req/Sec   │ 19935   │ 19935   │ 33247   │ 34111   │ 32030.4 │ 4103.84 │ 19931   │
+├───────────┼─────────┼─────────┼─────────┼─────────┼─────────┼─────────┼─────────┤
+│ Bytes/Sec │ 3.03 MB │ 3.03 MB │ 5.05 MB │ 5.19 MB │ 4.87 MB │ 624 kB  │ 3.03 MB │
+└───────────┴─────────┴─────────┴─────────┴─────────┴─────────┴─────────┴─────────┘
+
+Req/Bytes counts sampled once per second.
+
+320k requests in 10.18s, 48.7 MB read
 -----------------------
-nest
+nest (with "@nestjs/platform-fastify")
 -----------------------
 Running 10s test @ http://localhost:3000
-  8 threads and 1024 connections
-  Thread Stats   Avg      Stdev     Max   +/- Stdev
-    Latency    54.00ms   22.33ms 200.25ms   62.23%
-    Req/Sec     1.15k   338.60     1.88k    66.12%
-  91348 requests in 10.05s, 18.82MB read
-  Socket errors: connect 0, read 983, write 0, timeout 0
-Requests/sec:   9093.64
-Transfer/sec:      1.87MB
------------------------
-nest-fastify
------------------------
-Running 10s test @ http://localhost:3000
-  8 threads and 1024 connections
-  Thread Stats   Avg      Stdev     Max   +/- Stdev
-    Latency    29.31ms   11.71ms 101.96ms   70.03%
-    Req/Sec     2.17k     0.93k    4.12k    63.13%
-  173241 requests in 10.05s, 22.80MB read
-  Socket errors: connect 0, read 934, write 0, timeout 0
-Requests/sec:  17233.87
-Transfer/sec:      2.27MB
+1024 connections
+
+┌─────────┬───────┬───────┬───────┬───────┬──────────┬──────────┬────────┐
+│ Stat    │ 2.5%  │ 50%   │ 97.5% │ 99%   │ Avg      │ Stdev    │ Max    │
+├─────────┼───────┼───────┼───────┼───────┼──────────┼──────────┼────────┤
+│ Latency │ 31 ms │ 33 ms │ 38 ms │ 52 ms │ 34.41 ms │ 11.73 ms │ 245 ms │
+└─────────┴───────┴───────┴───────┴───────┴──────────┴──────────┴────────┘
+┌───────────┬─────────┬─────────┬────────┬─────────┬─────────┬─────────┬─────────┐
+│ Stat      │ 1%      │ 2.5%    │ 50%    │ 97.5%   │ Avg     │ Stdev   │ Min     │
+├───────────┼─────────┼─────────┼────────┼─────────┼─────────┼─────────┼─────────┤
+│ Req/Sec   │ 24911   │ 24911   │ 30031  │ 30335   │ 29470.4 │ 1564.48 │ 24907   │
+├───────────┼─────────┼─────────┼────────┼─────────┼─────────┼─────────┼─────────┤
+│ Bytes/Sec │ 3.81 MB │ 3.81 MB │ 4.6 MB │ 4.64 MB │ 4.51 MB │ 239 kB  │ 3.81 MB │
+└───────────┴─────────┴─────────┴────────┴─────────┴─────────┴─────────┴─────────┘
+
+Req/Bytes counts sampled once per second.
+
+295k requests in 10.17s, 45.1 MB read

integration/cache/e2e/multi-store.spec.ts

@@ -0,0 +1,31 @@
+import { INestApplication } from '@nestjs/common';
+import { Test } from '@nestjs/testing';
+import * as request from 'supertest';
+import { MultiStoreModule } from '../src/multi-store/multi-store.module';
+
+describe('Caching Multi Store', () => {
+  let server;
+  let app: INestApplication;
+
+  before(async () => {
+    const module = await Test.createTestingModule({
+      imports: [MultiStoreModule],
+    }).compile();
+
+    app = module.createNestApplication();
+    server = app.getHttpServer();
+    await app.init();
+  });
+
+  it(`should return empty`, async () => {
+    return request(server).get('/').expect(200, '');
+  });
+
+  it(`should return data`, async () => {
+    return request(server).get('/').expect(200, 'multi-store-value');
+  });
+
+  after(async () => {
+    await app.close();
+  });
+});

integration/cache/src/multi-store/multi-store.controller.ts

@@ -0,0 +1,16 @@
+import { Controller, Get, Inject, CACHE_MANAGER } from '@nestjs/common';
+import { Cache } from 'cache-manager';
+
+@Controller()
+export class MultiStoreController {
+  constructor(@Inject(CACHE_MANAGER) private cacheManager: Cache) {}
+
+  @Get()
+  async getFromMultiStore(): Promise<unknown> {
+    const value = await this.cacheManager.get('multi-store-key');
+    if (!value) {
+      await this.cacheManager.set('multi-store-key', 'multi-store-value');
+    }
+    return value;
+  }
+}

integration/cache/src/multi-store/multi-store.module.ts

@@ -0,0 +1,23 @@
+import { CacheModule, Module } from '@nestjs/common';
+import * as redisStore from 'cache-manager-redis-store';
+import { MultiStoreController } from './multi-store.controller';
+
+@Module({
+  imports: [CacheModule.register([
+      {
+        store: 'memory',
+        max: 100,
+        ttl: 10,
+      },
+      {
+        store: redisStore,
+        host: 'localhost',
+        port: 6379,
+        db: 0,
+        ttl: 600
+      }
+    ],
+  )],
+  controllers: [MultiStoreController],
+})
+export class MultiStoreModule {}

integration/cache/src/multi-store/tsconfig.json

@@ -0,0 +1,22 @@
+{
+  "compilerOptions": {
+    "module": "commonjs",
+    "declaration": false,
+    "noImplicitAny": false,
+    "removeComments": true,
+    "noLib": false,
+    "emitDecoratorMetadata": true,
+    "experimentalDecorators": true,
+    "target": "es6",
+    "sourceMap": true,
+    "allowJs": true,
+    "outDir": "./dist"
+  },
+  "include": [
+    "src/**/*",
+    "e2e/**/*"
+  ],
+  "exclude": [
+    "node_modules",
+  ]
+}

integration/docker-compose.yml

@@ -23,7 +23,7 @@ services:
       - "9001:9001"
     restart: always
   mysql:
-    image: mysql:5.7.33
+    image: mysql:5.7.34
     environment:
       MYSQL_ROOT_PASSWORD: root
       MYSQL_DATABASE: test
@@ -48,7 +48,7 @@ services:
   zookeeper:
     container_name: test-zookeeper
     hostname: zookeeper
-    image: confluentinc/cp-zookeeper:5.5.3
+    image: confluentinc/cp-zookeeper:6.2.0
     ports:
       - "2181:2181"
     environment:
@@ -57,7 +57,7 @@ services:
   kafka:
     container_name: test-kafka
     hostname: kafka
-    image: confluentinc/cp-kafka:5.5.3
+    image: confluentinc/cp-kafka:6.2.0
     depends_on:
       - zookeeper
     ports:

integration/graphql-code-first/e2e/pipes.spec.ts

@@ -33,6 +33,7 @@ describe('GraphQL Pipes', () => {
               code: 'INTERNAL_SERVER_ERROR',
               exception: {
                 message: 'Bad Request Exception',
+                name: 'BadRequestException',
                 response: {
                   message: [
                     'description must be longer than or equal to 30 characters',

integration/hello-world/e2e/router-module-middleware.spec.ts

@@ -0,0 +1,77 @@
+import {
+  Controller,
+  Get,
+  INestApplication,
+  MiddlewareConsumer,
+  Module,
+} from '@nestjs/common';
+import { RouterModule } from '@nestjs/core';
+import { Test } from '@nestjs/testing';
+import * as request from 'supertest';
+import { ApplicationModule } from '../src/app.module';
+
+const RETURN_VALUE = 'test';
+const SCOPED_VALUE = 'test_scoped';
+
+@Controller()
+class TestController {
+  @Get('test')
+  test() {
+    return RETURN_VALUE;
+  }
+
+  @Get('test2')
+  test2() {
+    return RETURN_VALUE;
+  }
+}
+
+@Module({
+  imports: [ApplicationModule],
+  controllers: [TestController],
+})
+class TestModule {
+  configure(consumer: MiddlewareConsumer) {
+    consumer
+      .apply((req, res, next) => res.send(SCOPED_VALUE))
+      .forRoutes(TestController);
+  }
+}
+
+describe('RouterModule with Middleware functions', () => {
+  let app: INestApplication;
+
+  beforeEach(async () => {
+    app = (
+      await Test.createTestingModule({
+        imports: [
+          TestModule,
+          RouterModule.register([
+            {
+              path: '/module-path/',
+              module: TestModule,
+            },
+          ]),
+        ],
+      }).compile()
+    ).createNestApplication();
+
+    await app.init();
+  });
+
+  it(`forRoutes(TestController) - /test`, () => {
+    return request(app.getHttpServer())
+      .get('/module-path/test')
+      .expect(200, SCOPED_VALUE);
+  });
+
+  it(`forRoutes(TestController) - /test2`, () => {
+    return request(app.getHttpServer())
+      .get('/module-path/test2')
+      .expect(200, SCOPED_VALUE);
+  });
+
+  afterEach(async () => {
+    await app.close();
+  });
+});

integration/hello-world/e2e/router-module.spec.ts

@@ -0,0 +1,99 @@
+import { Controller, Get, INestApplication, Module } from '@nestjs/common';
+import { RouterModule, Routes } from '@nestjs/core';
+import { Test } from '@nestjs/testing';
+import * as request from 'supertest';
+
+describe('RouterModule', () => {
+  let app: INestApplication;
+
+  abstract class BaseController {
+    @Get()
+    getName() {
+      return this.constructor.name;
+    }
+  }
+
+  @Controller('/parent-controller')
+  class ParentController extends BaseController {}
+  @Controller('/child-controller')
+  class ChildController extends BaseController {}
+  @Controller('no-slash-controller')
+  class NoSlashController extends BaseController {}
+
+  class UnknownController {}
+  @Module({ controllers: [ParentController] })
+  class ParentModule {}
+
+  @Module({ controllers: [ChildController] })
+  class ChildModule {}
+
+  @Module({})
+  class AuthModule {}
+  @Module({})
+  class PaymentsModule {}
+
+  @Module({ controllers: [NoSlashController] })
+  class NoSlashModule {}
+
+  const routes1: Routes = [
+    {
+      path: 'parent',
+      module: ParentModule,
+      children: [
+        {
+          path: 'child',
+          module: ChildModule,
+        },
+      ],
+    },
+  ];
+  const routes2: Routes = [
+    { path: 'v1', children: [AuthModule, PaymentsModule, NoSlashModule] },
+  ];
+
+  @Module({
+    imports: [ParentModule, ChildModule, RouterModule.register(routes1)],
+  })
+  class MainModule {}
+
+  @Module({
+    imports: [
+      AuthModule,
+      PaymentsModule,
+      NoSlashModule,
+      RouterModule.register(routes2),
+    ],
+  })
+  class AppModule {}
+
+  before(async () => {
+    const moduleRef = await Test.createTestingModule({
+      imports: [MainModule, AppModule],
+    }).compile();
+
+    app = moduleRef.createNestApplication();
+    await app.init();
+  });
+
+  it('should hit the "ParentController"', async () => {
+    return request(app.getHttpServer())
+      .get('/parent/parent-controller')
+      .expect(200, 'ParentController');
+  });
+
+  it('should hit the "ChildController"', async () => {
+    return request(app.getHttpServer())
+      .get('/parent/child/child-controller')
+      .expect(200, 'ChildController');
+  });
+
+  it('should hit the "NoSlashController"', async () => {
+    return request(app.getHttpServer())
+      .get('/v1/no-slash-controller')
+      .expect(200, 'NoSlashController');
+  });
+
+  afterEach(async () => {
+    await app.close();
+  });
+});

integration/hooks/e2e/before-app-shutdown.spec.ts

@@ -1,4 +1,4 @@
-import { BeforeApplicationShutdown, Injectable } from '@nestjs/common';
+import { BeforeApplicationShutdown, Injectable, Module } from '@nestjs/common';
 import { Test } from '@nestjs/testing';
 import { expect } from 'chai';
 import * as Sinon from 'sinon';
@@ -19,35 +19,46 @@ describe('BeforeApplicationShutdown', () => {
     const instance = module.get(TestInjectable);
     expect(instance.beforeApplicationShutdown.called).to.be.true;
   });
-  /*
-  it('should not stop the server once beforeApplicationShutdown has been called', async () => {
-    let resolve;
-    const promise = new Promise(r => (resolve = r));
+
+  it('should sort modules by distance (topological sort) - DESC order', async () => {
+    @Injectable()
+    class BB implements BeforeApplicationShutdown {
+      public field: string;
+      async beforeApplicationShutdown() {
+        this.field = 'b-field';
+      }
+    }
+
+    @Module({
+      providers: [BB],
+      exports: [BB],
+    })
+    class B {}
+
+    @Injectable()
+    class AA implements BeforeApplicationShutdown {
+      public field: string;
+      constructor(private bb: BB) {}
+
+      async beforeApplicationShutdown() {
+        this.field = this.bb.field + '_a-field';
+      }
+    }
+    @Module({
+      imports: [B],
+      providers: [AA],
+    })
+    class A {}
+
     const module = await Test.createTestingModule({
-      providers: [
-        {
-          provide: 'Test',
-          useValue: {
-            beforeApplicationShutdown: () => promise,
-          },
-        },
-      ],
+      imports: [A],
     }).compile();
-    Sinon.stub(module, 'dispose' as any);
+
     const app = module.createNestApplication();
+    await app.init();
+    await app.close();
 
-    app.close();
-
-    expect(((module as any).dispose as Sinon.SinonSpy).called, 'dispose').to.be
-      .false;
-
-    resolve();
-
-    setTimeout(
-      () =>
-        expect(((module as any).dispose as Sinon.SinonSpy).called, 'dispose').to
-          .be.true,
-      0,
-    );
-  });*/
+    const instance = module.get(AA);
+    expect(instance.field).to.equal('b-field_a-field');
+  });
 });

integration/hooks/e2e/enable-shutdown-hook.spec.ts

@@ -15,7 +15,7 @@ describe('enableShutdownHooks', () => {
     expect(calls[0]).to.equal('beforeApplicationShutdown SIGHUP');
     expect(calls[1]).to.equal('onApplicationShutdown SIGHUP');
     done();
-  }).timeout(5000);
+  }).timeout(10000);
 
   it('should call the correct hooks if a specific shutdown signal gets invoked', done => {
     const result = spawnSync('ts-node', [
@@ -30,7 +30,7 @@ describe('enableShutdownHooks', () => {
     expect(calls[0]).to.equal('beforeApplicationShutdown SIGINT');
     expect(calls[1]).to.equal('onApplicationShutdown SIGINT');
     done();
-  }).timeout(5000);
+  }).timeout(10000);
 
   it('should ignore system signals which are not specified', done => {
     const result = spawnSync('ts-node', [
@@ -40,7 +40,7 @@ describe('enableShutdownHooks', () => {
     ]);
     expect(result.stdout.toString().trim()).to.be.eq('');
     done();
-  }).timeout(5000);
+  }).timeout(10000);
 
   it('should ignore system signals if "enableShutdownHooks" was not called', done => {
     const result = spawnSync('ts-node', [
@@ -50,5 +50,5 @@ describe('enableShutdownHooks', () => {
     ]);
     expect(result.stdout.toString().trim()).to.be.eq('');
     done();
-  }).timeout(5000);
+  }).timeout(10000);
 });

integration/hooks/e2e/on-app-boostrap.spec.ts

@@ -1,7 +1,7 @@
+import { Injectable, Module, OnApplicationBootstrap } from '@nestjs/common';
 import { Test } from '@nestjs/testing';
 import { expect } from 'chai';
 import * as Sinon from 'sinon';
-import { Injectable, OnApplicationBootstrap } from '@nestjs/common';
 
 @Injectable()
 class TestInjectable implements OnApplicationBootstrap {
@@ -41,4 +41,45 @@ describe('OnApplicationBootstrap', () => {
     const app = module.createNestApplication();
     await app.init().then(obj => expect(obj).to.not.be.undefined);
   });
+
+  it('should sort modules by distance (topological sort) - DESC order', async () => {
+    @Injectable()
+    class BB implements OnApplicationBootstrap {
+      public field: string;
+      async onApplicationBootstrap() {
+        this.field = 'b-field';
+      }
+    }
+
+    @Module({
+      providers: [BB],
+      exports: [BB],
+    })
+    class B {}
+
+    @Injectable()
+    class AA implements OnApplicationBootstrap {
+      public field: string;
+      constructor(private bb: BB) {}
+
+      async onApplicationBootstrap() {
+        this.field = this.bb.field + '_a-field';
+      }
+    }
+    @Module({
+      imports: [B],
+      providers: [AA],
+    })
+    class A {}
+
+    const module = await Test.createTestingModule({
+      imports: [A],
+    }).compile();
+
+    const app = module.createNestApplication();
+    await app.init();
+
+    const instance = module.get(AA);
+    expect(instance.field).to.equal('b-field_a-field');
+  });
 });

integration/hooks/e2e/on-app-shutdown.spec.ts

@@ -1,4 +1,4 @@
-import { Injectable, OnApplicationShutdown } from '@nestjs/common';
+import { Injectable, Module, OnApplicationShutdown } from '@nestjs/common';
 import { Test } from '@nestjs/testing';
 import { expect } from 'chai';
 import * as Sinon from 'sinon';
@@ -19,4 +19,46 @@ describe('OnApplicationShutdown', () => {
     const instance = module.get(TestInjectable);
     expect(instance.onApplicationShutdown.called).to.be.true;
   });
+
+  it('should sort modules by distance (topological sort) - DESC order', async () => {
+    @Injectable()
+    class BB implements OnApplicationShutdown {
+      public field: string;
+      async onApplicationShutdown() {
+        this.field = 'b-field';
+      }
+    }
+
+    @Module({
+      providers: [BB],
+      exports: [BB],
+    })
+    class B {}
+
+    @Injectable()
+    class AA implements OnApplicationShutdown {
+      public field: string;
+      constructor(private bb: BB) {}
+
+      async onApplicationShutdown() {
+        this.field = this.bb.field + '_a-field';
+      }
+    }
+    @Module({
+      imports: [B],
+      providers: [AA],
+    })
+    class A {}
+
+    const module = await Test.createTestingModule({
+      imports: [A],
+    }).compile();
+
+    const app = module.createNestApplication();
+    await app.init();
+    await app.close();
+
+    const instance = module.get(AA);
+    expect(instance.field).to.equal('b-field_a-field');
+  });
 });

integration/hooks/e2e/on-module-destroy.spec.ts

@@ -1,4 +1,4 @@
-import { Injectable, OnModuleDestroy } from '@nestjs/common';
+import { Injectable, Module, OnModuleDestroy } from '@nestjs/common';
 import { Test } from '@nestjs/testing';
 import { expect } from 'chai';
 import * as Sinon from 'sinon';
@@ -39,4 +39,46 @@ describe('OnModuleDestroy', () => {
     const app = module.createNestApplication();
     await app.init().then(obj => expect(obj).to.not.be.undefined);
   });
+
+  it('should sort modules by distance (topological sort) - DESC order', async () => {
+    @Injectable()
+    class BB implements OnModuleDestroy {
+      public field: string;
+      async onModuleDestroy() {
+        this.field = 'b-field';
+      }
+    }
+
+    @Module({
+      providers: [BB],
+      exports: [BB],
+    })
+    class B {}
+
+    @Injectable()
+    class AA implements OnModuleDestroy {
+      public field: string;
+      constructor(private bb: BB) {}
+
+      async onModuleDestroy() {
+        this.field = this.bb.field + '_a-field';
+      }
+    }
+    @Module({
+      imports: [B],
+      providers: [AA],
+    })
+    class A {}
+
+    const module = await Test.createTestingModule({
+      imports: [A],
+    }).compile();
+
+    const app = module.createNestApplication();
+    await app.init();
+    await app.close();
+
+    const instance = module.get(AA);
+    expect(instance.field).to.equal('b-field_a-field');
+  });
 });

integration/hooks/e2e/on-module-init.spec.ts

@@ -1,7 +1,7 @@
+import { Injectable, Module, OnModuleInit } from '@nestjs/common';
 import { Test } from '@nestjs/testing';
 import { expect } from 'chai';
 import * as Sinon from 'sinon';
-import { Injectable, OnModuleInit } from '@nestjs/common';
 
 @Injectable()
 class TestInjectable implements OnModuleInit {
@@ -37,4 +37,45 @@ describe('OnModuleInit', () => {
     const app = module.createNestApplication();
     await app.init().then(obj => expect(obj).to.not.be.undefined);
   });
+
+  it('should sort modules by distance (topological sort) - DESC order', async () => {
+    @Injectable()
+    class BB implements OnModuleInit {
+      public field: string;
+      async onModuleInit() {
+        this.field = 'b-field';
+      }
+    }
+
+    @Module({
+      providers: [BB],
+      exports: [BB],
+    })
+    class B {}
+
+    @Injectable()
+    class AA implements OnModuleInit {
+      public field: string;
+      constructor(private bb: BB) {}
+
+      async onModuleInit() {
+        this.field = this.bb.field + '_a-field';
+      }
+    }
+    @Module({
+      imports: [B],
+      providers: [AA],
+    })
+    class A {}
+
+    const module = await Test.createTestingModule({
+      imports: [A],
+    }).compile();
+
+    const app = module.createNestApplication();
+    await app.init();
+
+    const instance = module.get(AA);
+    expect(instance.field).to.equal('b-field_a-field');
+  });
 });

integration/microservices/e2e/broadcast-mqtt.spec.ts

@@ -28,7 +28,7 @@ describe('MQTT transport', () => {
         host: '0.0.0.0',
       },
     });
-    await app.startAllMicroservicesAsync();
+    await app.startAllMicroservices();
     await app.init();
   });
 

integration/microservices/e2e/broadcast-nats.spec.ts

@@ -19,16 +19,16 @@ describe('NATS transport', () => {
     app.connectMicroservice({
       transport: Transport.NATS,
       options: {
-        url: 'nats://0.0.0.0:4222',
+        servers: 'nats://0.0.0.0:4222',
       },
     });
     app.connectMicroservice({
       transport: Transport.NATS,
       options: {
-        url: 'nats://0.0.0.0:4222',
+        servers: 'servers://0.0.0.0:4222',
       },
     });
-    await app.startAllMicroservicesAsync();
+    await app.startAllMicroservices();
     await app.init();
   });
 

integration/microservices/e2e/broadcast-redis.spec.ts

@@ -28,7 +28,7 @@ describe('REDIS transport', () => {
         url: 'redis://0.0.0.0:6379',
       },
     });
-    await app.startAllMicroservicesAsync();
+    await app.startAllMicroservices();
     await app.init();
   });
 

integration/microservices/e2e/concurrent-kafka.spec.ts

@@ -7,7 +7,7 @@ import * as util from 'util';
 import { KafkaConcurrentController } from '../src/kafka-concurrent/kafka-concurrent.controller';
 import { KafkaConcurrentMessagesController } from '../src/kafka-concurrent/kafka-concurrent.messages.controller';
 
-describe('Kafka concurrent', function () {
+describe.skip('Kafka concurrent', function () {
   const numbersOfServers = 3;
 
   const requestTopic = 'math.sum.sync.number.wait';
@@ -57,7 +57,7 @@ describe('Kafka concurrent', function () {
     apps.push(app);
 
     // await the start
-    await app.startAllMicroservicesAsync();
+    await app.startAllMicroservices();
     await app.init();
   };
 

integration/microservices/e2e/disconnected-client.spec.ts

@@ -46,7 +46,7 @@ describe('Disconnected client', () => {
       .send({
         transport: Transport.NATS,
         options: {
-          url: 'nats://localhost:4224',
+          servers: 'nats://localhost:4224',
         },
       })
       .expect(408);

integration/microservices/e2e/orders-grpc.spec.ts

@@ -1,3 +1,4 @@
+import * as GRPC from '@grpc/grpc-js';
 import * as ProtoLoader from '@grpc/proto-loader';
 import { INestApplication } from '@nestjs/common';
 import { Transport } from '@nestjs/microservices';
@@ -6,7 +7,6 @@ import { Test } from '@nestjs/testing';
 import { fail } from 'assert';
 import { expect } from 'chai';
 import * as express from 'express';
-import * as GRPC from 'grpc';
 import { join } from 'path';
 import * as request from 'supertest';
 import { AdvancedGrpcController } from '../src/grpc-advanced/advanced.grpc.controller';
@@ -39,7 +39,7 @@ describe('Advanced GRPC transport', () => {
       },
     });
     // Start gRPC microservice
-    await app.startAllMicroservicesAsync();
+    await app.startAllMicroservices();
     await app.init();
     // Load proto-buffers for test gRPC dispatch
     const proto = ProtoLoader.loadSync('root.proto', {

integration/microservices/e2e/sum-grpc.spec.ts

@@ -1,10 +1,10 @@
+import * as GRPC from '@grpc/grpc-js';
 import * as ProtoLoader from '@grpc/proto-loader';
 import { INestApplication } from '@nestjs/common';
 import { Transport } from '@nestjs/microservices';
 import { Test } from '@nestjs/testing';
 import { fail } from 'assert';
 import { expect } from 'chai';
-import * as GRPC from 'grpc';
 import { join } from 'path';
 import * as request from 'supertest';
 import { GrpcController } from '../src/grpc/grpc.controller';
@@ -33,7 +33,7 @@ describe('GRPC transport', () => {
       },
     });
     // Start gRPC microservice
-    await app.startAllMicroservicesAsync();
+    await app.startAllMicroservices();
     await app.init();
     // Load proto-buffers for test gRPC dispatch
     const proto = ProtoLoader.loadSync(
@@ -113,6 +113,5 @@ describe('GRPC transport', () => {
 
   after(async () => {
     await app.close();
-    client.close();
   });
 });

integration/microservices/e2e/sum-kafka.spec.ts

@@ -9,14 +9,19 @@ import { UserEntity } from '../src/kafka/entities/user.entity';
 import { KafkaController } from '../src/kafka/kafka.controller';
 import { KafkaMessagesController } from '../src/kafka/kafka.messages.controller';
 
-describe('Kafka transport', function () {
-  let server;
+/**
+ * Skip this flaky test in CI/CD pipeline as it frequently
+ * fails to connect to Kafka container in the cloud.
+ */
+describe.skip('Kafka transport', function () {
+  let server: any;
   let app: INestApplication;
 
   // set timeout to be longer (especially for the after hook)
-  this.timeout(30000);
+  this.timeout(50000);
+  this.retries(10);
 
-  it(`Start Kafka app`, async () => {
+  before(`Start Kafka app`, async function () {
     const module = await Test.createTestingModule({
       controllers: [KafkaController, KafkaMessagesController],
     }).compile();
@@ -33,11 +38,11 @@ describe('Kafka transport', function () {
       },
     });
     app.enableShutdownHooks();
-    await app.startAllMicroservicesAsync();
+    await app.startAllMicroservices();
     await app.init();
-  }).timeout(30000);
+  });
 
-  it(`/POST (sync sum kafka message)`, () => {
+  it(`/POST (sync sum kafka message)`, function () {
     return request(server)
       .post('/mathSumSyncKafkaMessage')
       .send([1, 2, 3, 4, 5])
@@ -130,4 +135,4 @@ describe('Kafka transport', function () {
   after(`Stopping Kafka app`, async () => {
     await app.close();
   });
-}).timeout(30000);
+});

integration/microservices/e2e/sum-mqtt.spec.ts

@@ -23,7 +23,7 @@ describe('MQTT transport', () => {
         url: 'mqtt://0.0.0.0:1883',
       },
     });
-    await app.startAllMicroservicesAsync();
+    await app.startAllMicroservices();
     await app.init();
   });
 

integration/microservices/e2e/sum-nats.spec.ts

@@ -4,6 +4,7 @@ import { Test } from '@nestjs/testing';
 import { expect } from 'chai';
 import * as request from 'supertest';
 import { NatsController } from '../src/nats/nats.controller';
+import { NatsService } from '../src/nats/nats.service';
 
 describe('NATS transport', () => {
   let server;
@@ -12,6 +13,7 @@ describe('NATS transport', () => {
   beforeEach(async () => {
     const module = await Test.createTestingModule({
       controllers: [NatsController],
+      providers: [NatsService],
     }).compile();
 
     app = module.createNestApplication();
@@ -20,10 +22,10 @@ describe('NATS transport', () => {
     app.connectMicroservice({
       transport: Transport.NATS,
       options: {
-        url: 'nats://0.0.0.0:4222',
+        servers: 'nats://0.0.0.0:4222',
       },
     });
-    await app.startAllMicroservicesAsync();
+    await app.startAllMicroservices();
     await app.init();
   });
 
@@ -88,6 +90,7 @@ describe('NATS transport', () => {
       .end(() => {
         setTimeout(() => {
           expect(NatsController.IS_NOTIFIED).to.be.true;
+          expect(NatsController.IS_NOTIFIED2).to.be.true;
           done();
         }, 1000);
       });

integration/microservices/e2e/sum-redis.spec.ts

@@ -23,7 +23,7 @@ describe('REDIS transport', () => {
         url: 'redis://0.0.0.0:6379',
       },
     });
-    await app.startAllMicroservicesAsync();
+    await app.startAllMicroservices();
     await app.init();
   });
 

integration/microservices/e2e/sum-rmq.spec.ts

@@ -26,7 +26,7 @@ describe('RabbitMQ transport', () => {
         socketOptions: { noDelay: true },
       },
     });
-    await app.startAllMicroservicesAsync();
+    await app.startAllMicroservices();
     await app.init();
   });
 

integration/microservices/e2e/sum-rpc.spec.ts

@@ -24,7 +24,7 @@ describe('RPC transport', () => {
         host: '0.0.0.0',
       },
     });
-    await app.startAllMicroservicesAsync();
+    await app.startAllMicroservices();
     await app.init();
   });
 

integration/microservices/src/app.controller.ts

@@ -11,10 +11,10 @@ import {
   ClientProxy,
   EventPattern,
   MessagePattern,
-  Transport,
   RpcException,
+  Transport,
 } from '@nestjs/microservices';
-import { from, Observable, of, throwError } from 'rxjs';
+import { from, lastValueFrom, Observable, of, throwError } from 'rxjs';
 import { catchError, scan } from 'rxjs/operators';
 
 @Controller()
@@ -66,9 +66,9 @@ export class AppController {
   concurrent(@Body() data: number[][]): Promise<boolean> {
     const send = async (tab: number[]) => {
       const expected = tab.reduce((a, b) => a + b);
-      const result = await this.client
-        .send<number>({ cmd: 'sum' }, tab)
-        .toPromise();
+      const result = await lastValueFrom(
+        this.client.send<number>({ cmd: 'sum' }, tab),
+      );
 
       return result === expected;
     };
@@ -79,13 +79,16 @@ export class AppController {
 
   @Post('error')
   @HttpCode(200)
-  serializeError(@Query('client') query: 'custom' | 'standard' = 'standard', @Body() body: Record<string, any>): Observable<boolean> {
+  serializeError(
+    @Query('client') query: 'custom' | 'standard' = 'standard',
+    @Body() body: Record<string, any>,
+  ): Observable<boolean> {
     const client = query === 'custom' ? this.customClient : this.client;
     return client.send({ cmd: 'err' }, {}).pipe(
-      catchError((err) => {
+      catchError(err => {
         return of(err instanceof RpcException);
-      })
-    )
+      }),
+    );
   }
 
   @MessagePattern({ cmd: 'sum' })
@@ -110,7 +113,7 @@ export class AppController {
 
   @MessagePattern({ cmd: 'err' })
   throwAnError() {
-    return throwError(new Error('err'));
+    return throwError(() => new Error('err'));
   }
 
   @Post('notify')

integration/microservices/src/disconnected.controller.ts

@@ -18,13 +18,15 @@ export class DisconnectedClientController {
       .send<number, number[]>({ cmd: 'none' }, [1, 2, 3])
       .pipe(
         /*tap(
-        console.log.bind(console, 'data'),
-        console.error.bind(console, 'error'),
-      ),*/
+          console.log.bind(console, 'data'),
+          console.error.bind(console, 'error'),
+        ),*/
         catchError(error => {
           const { code } = error || { code: 'CONN_ERR' };
-          return throwError(
-            code === 'ECONNREFUSED' || code === 'CONN_ERR'
+          return throwError(() =>
+            code === 'ECONNREFUSED' ||
+            code === 'CONN_ERR' ||
+            code === 'CONNECTION_REFUSED'
               ? new RequestTimeoutException('ECONNREFUSED')
               : new InternalServerErrorException(),
           );

integration/microservices/src/grpc-advanced/advanced.grpc.controller.ts

@@ -1,3 +1,4 @@
+import { Metadata } from '@grpc/grpc-js';
 import { Body, Controller, HttpCode, Post } from '@nestjs/common';
 import {
   Client,
@@ -9,7 +10,6 @@ import {
 } from '@nestjs/microservices';
 import { join } from 'path';
 import { Observable, of, ReplaySubject, Subject } from 'rxjs';
-import { Metadata } from 'grpc';
 
 @Controller()
 export class AdvancedGrpcController {

integration/microservices/src/kafka/kafka.controller.ts

@@ -2,13 +2,13 @@ import {
   Body,
   Controller,
   HttpCode,
+  OnModuleDestroy,
   OnModuleInit,
   Post,
-  OnModuleDestroy,
 } from '@nestjs/common';
 import { Logger } from '@nestjs/common/services/logger.service';
 import { Client, ClientKafka, Transport } from '@nestjs/microservices';
-import { Observable } from 'rxjs';
+import { lastValueFrom, Observable } from 'rxjs';
 import { BusinessDto } from './dtos/business.dto';
 import { UserDto } from './dtos/user.dto';
 
@@ -57,14 +57,14 @@ export class KafkaController implements OnModuleInit, OnModuleDestroy {
   async mathSumSyncKafkaMessage(
     @Body() data: number[],
   ): Promise<Observable<any>> {
-    const result = await this.client
-      .send('math.sum.sync.kafka.message', {
+    const result = await lastValueFrom(
+      this.client.send('math.sum.sync.kafka.message', {
         key: '1',
         value: {
           numbers: data,
         },
-      })
-      .toPromise();
+      }),
+    );
     return result;
   }
 
@@ -74,13 +74,13 @@ export class KafkaController implements OnModuleInit, OnModuleDestroy {
   async mathSumSyncWithoutKey(
     @Body() data: number[],
   ): Promise<Observable<any>> {
-    const result = await this.client
-      .send('math.sum.sync.without.key', {
+    const result = await lastValueFrom(
+      this.client.send('math.sum.sync.without.key', {
         value: {
           numbers: data,
         },
-      })
-      .toPromise();
+      }),
+    );
     return result;
   }
 
@@ -90,11 +90,11 @@ export class KafkaController implements OnModuleInit, OnModuleDestroy {
   async mathSumSyncPlainObject(
     @Body() data: number[],
   ): Promise<Observable<any>> {
-    const result = await this.client
-      .send('math.sum.sync.plain.object', {
+    const result = await lastValueFrom(
+      this.client.send('math.sum.sync.plain.object', {
         numbers: data,
-      })
-      .toPromise();
+      }),
+    );
     return result;
   }
 
@@ -102,9 +102,9 @@ export class KafkaController implements OnModuleInit, OnModuleDestroy {
   @Post('mathSumSyncArray')
   @HttpCode(200)
   async mathSumSyncArray(@Body() data: number[]): Promise<Observable<any>> {
-    const result = await this.client
-      .send('math.sum.sync.array', data)
-      .toPromise();
+    const result = await lastValueFrom(
+      this.client.send('math.sum.sync.array', data),
+    );
     return result;
   }
 
@@ -112,18 +112,18 @@ export class KafkaController implements OnModuleInit, OnModuleDestroy {
   @HttpCode(200)
   async mathSumSyncString(@Body() data: number[]): Promise<Observable<any>> {
     // this.logger.error(util.format('mathSumSyncString() data: %o', data));
-    const result = await this.client
-      .send('math.sum.sync.string', data.toString())
-      .toPromise();
+    const result = await lastValueFrom(
+      this.client.send('math.sum.sync.string', data.toString()),
+    );
     return result;
   }
 
   @Post('mathSumSyncNumber')
   @HttpCode(200)
   async mathSumSyncNumber(@Body() data: number[]): Promise<Observable<any>> {
-    const result = await this.client
-      .send('math.sum.sync.number', data[0])
-      .toPromise();
+    const result = await lastValueFrom(
+      this.client.send('math.sum.sync.number', data[0]),
+    );
     return result;
   }
 
@@ -137,14 +137,14 @@ export class KafkaController implements OnModuleInit, OnModuleDestroy {
   @Post('/user')
   @HttpCode(200)
   async createUser(@Body() user: UserDto): Promise<Observable<any>> {
-    const result = await this.client
-      .send('user.create', {
+    const result = await lastValueFrom(
+      this.client.send('user.create', {
         key: '1',
         value: {
           user,
         },
-      })
-      .toPromise();
+      }),
+    );
     return result;
   }
 
@@ -152,14 +152,14 @@ export class KafkaController implements OnModuleInit, OnModuleDestroy {
   @Post('/business')
   @HttpCode(200)
   async createBusiness(@Body() business: BusinessDto) {
-    const result = await this.client
-      .send('business.create', {
+    const result = await lastValueFrom(
+      this.client.send('business.create', {
         key: '1',
         value: {
           business,
         },
-      })
-      .toPromise();
+      }),
+    );
     return result;
   }
 }

integration/microservices/src/mqtt/mqtt.controller.ts

@@ -6,7 +6,7 @@ import {
   MessagePattern,
   Transport,
 } from '@nestjs/microservices';
-import { from, Observable, of } from 'rxjs';
+import { from, lastValueFrom, Observable, of } from 'rxjs';
 import { scan } from 'rxjs/operators';
 
 @Controller()
@@ -30,10 +30,13 @@ export class MqttController {
 
   @Post('stream')
   @HttpCode(200)
-  stream(@Body() data: number[]): Observable<number> {
-    return this.client
-      .send<number>({ cmd: 'streaming' }, data)
-      .pipe(scan((a, b) => a + b));
+  async stream(@Body() data: number[]) {
+    const result = lastValueFrom(
+      await this.client
+        .send<number>({ cmd: 'streaming' }, data)
+        .pipe(scan((a, b) => a + b, 0)),
+    );
+    return result;
   }
 
   @Post('concurrent')
@@ -41,9 +44,9 @@ export class MqttController {
   async concurrent(@Body() data: number[][]): Promise<boolean> {
     const send = async (tab: number[]) => {
       const expected = tab.reduce((a, b) => a + b);
-      const result = await this.client
-        .send<number>({ cmd: 'sum' }, tab)
-        .toPromise();
+      const result = await lastValueFrom(
+        this.client.send<number>({ cmd: 'sum' }, tab),
+      );
 
       return result === expected;
     };

integration/microservices/src/nats/nats-broadcast.controller.ts

@@ -10,7 +10,12 @@ import { scan, take } from 'rxjs/operators';
 
 @Controller()
 export class NatsBroadcastController {
-  @Client({ transport: Transport.NATS })
+  @Client({
+    transport: Transport.NATS,
+    options: {
+      servers: 'nats://localhost:4222',
+    },
+  })
   client: ClientProxy;
 
   @Get('broadcast')

integration/microservices/src/nats/nats.controller.ts

@@ -1,7 +1,7 @@
 import { Body, Controller, Get, HttpCode, Post, Query } from '@nestjs/common';
 import {
-  Client,
   ClientProxy,
+  ClientProxyFactory,
   Ctx,
   EventPattern,
   MessagePattern,
@@ -10,20 +10,23 @@ import {
   RpcException,
   Transport,
 } from '@nestjs/microservices';
-import { from, Observable, of, throwError } from 'rxjs';
+import { from, lastValueFrom, Observable, of, throwError } from 'rxjs';
 import { catchError, scan } from 'rxjs/operators';
+import { NatsService } from './nats.service';
 
 @Controller()
 export class NatsController {
   static IS_NOTIFIED = false;
+  static IS_NOTIFIED2 = false;
 
-  @Client({
+  constructor(private readonly natsService: NatsService) {}
+
+  client: ClientProxy = ClientProxyFactory.create({
     transport: Transport.NATS,
     options: {
-      url: 'nats://localhost:4222',
+      servers: 'nats://localhost:4222',
     },
-  })
-  client: ClientProxy;
+  });
 
   @Post()
   @HttpCode(200)
@@ -48,9 +51,9 @@ export class NatsController {
   concurrent(@Body() data: number[][]): Promise<boolean> {
     const send = async (tab: number[]) => {
       const expected = tab.reduce((a, b) => a + b);
-      const result = await this.client
-        .send<number>('math.sum', tab)
-        .toPromise();
+      const result = await lastValueFrom(
+        this.client.send<number>('math.sum', tab),
+      );
 
       return result === expected;
     };
@@ -88,7 +91,7 @@ export class NatsController {
 
   @MessagePattern('exception')
   throwError(): Observable<number> {
-    return throwError(new RpcException('test'));
+    return throwError(() => new RpcException('test'));
   }
 
   @Post('notify')
@@ -100,4 +103,9 @@ export class NatsController {
   eventHandler(@Payload() data: boolean) {
     NatsController.IS_NOTIFIED = data;
   }
+
+  @EventPattern('notification')
+  eventHandler2(@Payload() data: boolean) {
+    NatsController.IS_NOTIFIED2 = data;
+  }
 }

integration/microservices/src/nats/nats.service.ts

@@ -0,0 +1,7 @@
+import { Inject, Injectable } from '@nestjs/common';
+import { CONTEXT } from '@nestjs/microservices';
+
+@Injectable()
+export class NatsService {
+  constructor(@Inject(CONTEXT) public ctx) {}
+}

integration/microservices/src/redis/redis.controller.ts

@@ -6,7 +6,7 @@ import {
   MessagePattern,
   Transport,
 } from '@nestjs/microservices';
-import { from, Observable, of } from 'rxjs';
+import { from, lastValueFrom, Observable, of } from 'rxjs';
 import { scan } from 'rxjs/operators';
 
 @Controller()
@@ -35,9 +35,9 @@ export class RedisController {
   concurrent(@Body() data: number[][]): Promise<boolean> {
     const send = async (tab: number[]) => {
       const expected = tab.reduce((a, b) => a + b);
-      const result = await this.client
-        .send<number>({ cmd: 'sum' }, tab)
-        .toPromise();
+      const result = await lastValueFrom(
+        this.client.send<number>({ cmd: 'sum' }, tab),
+      );
 
       return result === expected;
     };

integration/microservices/src/rmq/rmq.controller.ts

@@ -6,7 +6,7 @@ import {
   MessagePattern,
   Transport,
 } from '@nestjs/microservices';
-import { from, Observable, of } from 'rxjs';
+import { from, lastValueFrom, Observable, of } from 'rxjs';
 import { scan } from 'rxjs/operators';
 
 @Controller()
@@ -46,9 +46,9 @@ export class RMQController {
   concurrent(@Body() data: number[][]): Promise<boolean> {
     const send = async (tab: number[]) => {
       const expected = tab.reduce((a, b) => a + b);
-      const result = await this.client
-        .send<number>({ cmd: 'sum' }, tab)
-        .toPromise();
+      const result = await lastValueFrom(
+        this.client.send<number>({ cmd: 'sum' }, tab),
+      );
 
       return result === expected;
     };

integration/nest-application/global-prefix/e2e/global-prefix.spec.ts

@@ -0,0 +1,96 @@
+import { INestApplication } from '@nestjs/common';
+import { RequestMethod } from '@nestjs/common/enums/request-method.enum';
+import { Test } from '@nestjs/testing';
+import * as request from 'supertest';
+import { AppModule } from '../src/app.module';
+
+describe('Global prefix', () => {
+  let server;
+  let app: INestApplication;
+
+  beforeEach(async () => {
+    const module = await Test.createTestingModule({
+      imports: [AppModule],
+    }).compile();
+
+    app = module.createNestApplication();
+  });
+
+  it(`should use the global prefix`, async () => {
+    app.setGlobalPrefix('/api/v1');
+
+    server = app.getHttpServer();
+    await app.init();
+
+    await request(server).get('/health').expect(404);
+
+    await request(server).get('/api/v1/health').expect(200);
+  });
+
+  it(`should exclude the path as string`, async () => {
+    app.setGlobalPrefix('/api/v1', { exclude: ['/test'] });
+
+    server = app.getHttpServer();
+    await app.init();
+
+    await request(server).get('/test').expect(200);
+    await request(server).post('/test').expect(201);
+
+    await request(server).get('/api/v1/test').expect(404);
+    await request(server).post('/api/v1/test').expect(404);
+  });
+
+  it(`should exclude the path as RouteInfo`, async () => {
+    app.setGlobalPrefix('/api/v1', {
+      exclude: [{ path: '/health', method: RequestMethod.GET }],
+    });
+
+    server = app.getHttpServer();
+    await app.init();
+
+    await request(server).get('/health').expect(200);
+
+    await request(server).get('/api/v1/health').expect(404);
+  });
+
+  it(`should only exclude the GET RequestMethod`, async () => {
+    app.setGlobalPrefix('/api/v1', {
+      exclude: [{ path: '/test', method: RequestMethod.GET }],
+    });
+
+    server = app.getHttpServer();
+    await app.init();
+
+    await request(server).get('/test').expect(200);
+
+    await request(server).post('/test').expect(404);
+
+    await request(server).post('/api/v1/test').expect(201);
+  });
+
+  it(`should exclude the path as a mix of string and RouteInfo`, async () => {
+    app.setGlobalPrefix('/api/v1', {
+      exclude: ['test', { path: '/health', method: RequestMethod.GET }],
+    });
+
+    server = app.getHttpServer();
+    await app.init();
+
+    await request(server).get('/health').expect(200);
+
+    await request(server).get('/test').expect(200);
+  });
+
+  it(`should exclude the path with route param`, async () => {
+    app.setGlobalPrefix('/api/v1', { exclude: ['/hello/:name'] });
+
+    server = app.getHttpServer();
+    await app.init();
+
+    await request(server).get('/hello/foo').expect(200);
+  });
+
+  afterEach(async () => {
+    await app.close();
+  });
+});

integration/nest-application/global-prefix/src/app.controller.ts

@@ -0,0 +1,24 @@
+import { Controller, Get, Post } from '@nestjs/common';
+
+@Controller()
+export class AppController {
+  @Get('hello/:name')
+  getHello(): string {
+    return 'hello';
+  }
+
+  @Get('health')
+  getHealth(): string {
+    return 'up';
+  }
+
+  @Get('test')
+  getTest(): string {
+    return 'test';
+  }
+
+  @Post('test')
+  postTest(): string {
+    return 'test';
+  }
+}

integration/nest-application/global-prefix/src/app.module.ts

@@ -0,0 +1,7 @@
+import { Module } from '@nestjs/common';
+import { AppController } from './app.controller';
+
+@Module({
+  controllers: [AppController],
+})
+export class AppModule {}

integration/nest-application/global-prefix/tsconfig.json

@@ -0,0 +1,22 @@
+{
+  "compilerOptions": {
+    "module": "commonjs",
+    "declaration": false,
+    "noImplicitAny": false,
+    "removeComments": true,
+    "noLib": false,
+    "emitDecoratorMetadata": true,
+    "experimentalDecorators": true,
+    "target": "es6",
+    "sourceMap": true,
+    "allowJs": true,
+    "outDir": "./dist"
+  },
+  "include": [
+    "src/**/*",
+    "e2e/**/*"
+  ],
+  "exclude": [
+    "node_modules"
+  ]
+}

integration/nest-application/listen/e2e/express.spec.ts

@@ -0,0 +1,47 @@
+import { ExpressAdapter } from '@nestjs/platform-express';
+import { Test, TestingModule } from '@nestjs/testing';
+import { expect } from 'chai';
+import * as express from 'express';
+import { AppModule } from '../src/app.module';
+import { INestApplication } from '@nestjs/common';
+
+describe('Listen (Express Application)', () => {
+  let testModule: TestingModule;
+  let app: INestApplication;
+
+  beforeEach(async () => {
+    testModule = await Test.createTestingModule({
+      imports: [AppModule],
+    }).compile();
+    app = testModule.createNestApplication(new ExpressAdapter(express()));
+  });
+
+  afterEach(async () => {
+    app.close();
+  });
+
+  it('should resolve with httpServer on success', async () => {
+    const response = await app.listen(3000);
+    expect(response).to.eql(app.getHttpServer());
+  });
+
+  it('should reject if the port is not available', async () => {
+    await app.listen(3000);
+    const secondApp = testModule.createNestApplication(
+      new ExpressAdapter(express()),
+    );
+    try {
+      await secondApp.listen(3000);
+    } catch (error) {
+      expect(error.code).to.equal('EADDRINUSE');
+    }
+  });
+
+  it('should reject if there is an invalid host', async () => {
+    try {
+      await app.listen(3000, '1');
+    } catch (error) {
+      expect(error.code).to.equal('EADDRNOTAVAIL');
+    }
+  });
+});

integration/nest-application/listen/e2e/fastify.spec.ts

@@ -0,0 +1,46 @@
+import { INestApplication } from '@nestjs/common';
+import { FastifyAdapter } from '@nestjs/platform-fastify';
+import { Test, TestingModule } from '@nestjs/testing';
+import { expect } from 'chai';
+import { AppModule } from '../src/app.module';
+
+describe('Listen (Fastify Application)', () => {
+  let testModule: TestingModule;
+  let app: INestApplication;
+
+  beforeEach(async () => {
+    testModule = await Test.createTestingModule({
+      imports: [AppModule],
+    }).compile();
+    app = testModule.createNestApplication(new FastifyAdapter());
+  });
+
+  afterEach(async () => {
+    app.close();
+  });
+
+  it('should resolve with httpServer on success', async () => {
+    const response = await app.listen(3000);
+    expect(response).to.eql(app.getHttpServer());
+  });
+
+  it('should reject if the port is not available', async () => {
+    await app.listen(3000);
+    const secondApp = testModule.createNestApplication(new FastifyAdapter());
+    try {
+      await secondApp.listen(3000);
+    } catch (error) {
+      expect(error.code).to.equal('EADDRINUSE');
+    }
+
+    await secondApp.close();
+  });
+
+  it('should reject if there is an invalid host', async () => {
+    try {
+      await app.listen(3000, '1');
+    } catch (error) {
+      expect(error.code).to.equal('EADDRNOTAVAIL');
+    }
+  });
+});

integration/nest-application/listen/src/app.controller.ts

@@ -0,0 +1,12 @@
+import { Controller, Get } from '@nestjs/common';
+import { AppService } from './app.service';
+
+@Controller()
+export class AppController {
+  constructor(private readonly appService: AppService) {}
+
+  @Get()
+  getHello(): string {
+    return this.appService.sayHello();
+  }
+}

integration/nest-application/listen/src/app.module.ts

@@ -0,0 +1,9 @@
+import { Module } from '@nestjs/common';
+import { AppController } from './app.controller';
+import { AppService } from './app.service';
+
+@Module({
+  controllers: [AppController],
+  providers: [AppService],
+})
+export class AppModule {}

integration/nest-application/listen/src/app.service.ts

@@ -0,0 +1,8 @@
+import { Injectable } from '@nestjs/common';
+
+@Injectable()
+export class AppService {
+  sayHello(): string {
+    return 'Hello World!';
+  }
+}

integration/scopes/e2e/msvc-request-scope.spec.ts

@@ -35,7 +35,7 @@ describe('Request scope (microservices)', () => {
 
     server = app.getHttpServer();
     await app.init();
-    await app.startAllMicroservicesAsync();
+    await app.startAllMicroservices();
   });
 
   describe('when one service is request scoped', () => {

integration/send-files/e2e/express.spec.ts

@@ -0,0 +1,53 @@
+import { ExpressAdapter, NestExpressApplication } from '@nestjs/platform-express';
+import { Test } from '@nestjs/testing';
+import { expect } from 'chai';
+import { readFileSync } from 'fs';
+import { join } from 'path';
+import * as request from 'supertest';
+import { AppModule } from '../src/app.module';
+
+const readmeString = readFileSync(join(process.cwd(), 'Readme.md')).toString();
+
+describe('Express FileSend', () => {
+  let app: NestExpressApplication;
+
+  beforeEach(async () => {
+    const modRef = await Test.createTestingModule({
+      imports: [AppModule],
+    }).compile();
+
+    app = modRef.createNestApplication(new ExpressAdapter());
+    await app.init();
+  });
+
+  it('should return a file from a stream', async () => {
+    return request(app.getHttpServer())
+      .get('/file/stream/')
+      .expect(200)
+      .expect((res) => {
+        expect(res.body.toString()).to.be.eq(readmeString);
+      });
+  });
+  it('should return a file from a buffer', async () => {
+    return request(app.getHttpServer())
+      .get('/file/buffer')
+      .expect(200)
+      .expect((res) => {
+        expect(res.body.toString()).to.be.eq(readmeString);
+      });
+  });
+  it('should not stream a non-file', async () => {
+    return request(app.getHttpServer())
+      .get('/non-file/pipe-method')
+      .expect(200)
+      .expect({ value: 'Hello world' });
+  });
+  it('should return a file from an RxJS stream', async () => {
+    return request(app.getHttpServer())
+      .get('/file/rxjs/stream/')
+      .expect(200)
+      .expect((res) => {
+        expect(res.body.toString()).to.be.eq(readmeString);
+      });
+  });
+});

integration/send-files/e2e/fastify.spec.ts

@@ -0,0 +1,59 @@
+import { FastifyAdapter, NestFastifyApplication } from '@nestjs/platform-fastify';
+import { Test } from '@nestjs/testing';
+import { expect } from 'chai';
+import { readFileSync } from 'fs';
+import { join } from 'path';
+import { AppModule } from '../src/app.module';
+
+const readmeString = readFileSync(join(process.cwd(), 'Readme.md')).toString();
+
+describe('Fastify FileSend', () => {
+  let app: NestFastifyApplication;
+
+  beforeEach(async () => {
+    const modRef = await Test.createTestingModule({
+      imports: [AppModule],
+    }).compile();
+
+    app = modRef.createNestApplication(new FastifyAdapter());
+    await app.init();
+  });
+
+  it('should return a file from a stream', async () => {
+    return app.inject({
+      method: 'GET',
+      url: '/file/stream'
+    }).then(({ payload }) => {
+      expect(payload.toString()).to.be.eq(readmeString);
+    });
+  });
+  it('should return a file from a buffer', async () => {
+    return app.inject({
+      method: 'GET',
+      url: '/file/buffer',
+    }).then(({ payload }) => {
+      expect(payload.toString()).to.be.eq(readmeString);
+    });
+  });
+  /**
+   * It seems that Fastify has a similar issue as Kamil initially pointed out
+   * If a class has a `pipe` method, it will be treated as a stream. This means
+   * that the `NonFile` test is a failed case for fastify, hence the skip.
+   */
+  it.skip('should not stream a non-file', async () => {
+    return app.inject({
+      url: '/non-file/pipe-method',
+      method: 'get'
+    }).then(({ payload }) => {
+      expect(payload).to.be.eq({ value: 'Hello world' });
+    });
+  });
+  it('should return a file from an RxJS stream', async () => {
+    return app.inject({
+      method: 'GET',
+      url: '/file/rxjs/stream'
+    }).then(({ payload }) => {
+      expect(payload.toString()).to.be.eq(readmeString);
+    });
+  });
+});

integration/send-files/src/app.controller.ts

@@ -0,0 +1,29 @@
+import { Controller, Get, StreamableFile } from '@nestjs/common';
+import { Observable } from 'rxjs';
+import { AppService } from './app.service';
+import { NonFile } from './non-file';
+
+@Controller()
+export class AppController {
+  constructor(private readonly appService: AppService) {}
+
+  @Get('file/stream')
+  getFile(): StreamableFile {
+    return this.appService.getReadStream();
+  }
+
+  @Get('file/buffer')
+  getBuffer(): StreamableFile {
+    return this.appService.getBuffer();
+  }
+
+  @Get('non-file/pipe-method')
+  getNonFile(): NonFile {
+    return this.appService.getNonFile();
+  }
+
+  @Get('file/rxjs/stream')
+  getRxJSFile(): Observable<StreamableFile> {
+    return this.appService.getRxJSFile();
+  }
+}

integration/send-files/src/app.module.ts

@@ -0,0 +1,9 @@
+import { Module } from '@nestjs/common';
+import { AppController } from './app.controller';
+import { AppService } from './app.service';
+
+@Module({
+  controllers: [AppController],
+  providers: [AppService],
+})
+export class AppModule {}

integration/send-files/src/app.service.ts

@@ -0,0 +1,26 @@
+import { Injectable, StreamableFile } from '@nestjs/common';
+import { createReadStream, readFileSync } from 'fs';
+import { join } from 'path';
+import { Observable, of } from 'rxjs';
+import { NonFile } from './non-file';
+
+@Injectable()
+export class AppService {
+  getReadStream(): StreamableFile {
+    return new StreamableFile(
+      createReadStream(join(process.cwd(), 'Readme.md')),
+    );
+  }
+
+  getBuffer(): StreamableFile {
+    return new StreamableFile(readFileSync(join(process.cwd(), 'Readme.md')));
+  }
+
+  getNonFile(): NonFile {
+    return new NonFile('Hello world');
+  }
+
+  getRxJSFile(): Observable<StreamableFile> {
+    return of(this.getReadStream());
+  }
+}

integration/send-files/src/non-file.ts

@@ -0,0 +1,7 @@
+export class NonFile {
+  constructor(private readonly value: string) {}
+
+  pipe() {
+    return this.value;
+  }
+}

integration/send-files/tsconfig.json

@@ -0,0 +1,22 @@
+{
+  "compilerOptions": {
+    "module": "commonjs",
+    "declaration": false,
+    "noImplicitAny": false,
+    "removeComments": true,
+    "noLib": false,
+    "emitDecoratorMetadata": true,
+    "experimentalDecorators": true,
+    "target": "es6",
+    "sourceMap": true,
+    "allowJs": true,
+    "outDir": "./dist"
+  },
+  "include": [
+    "src/**/*",
+    "e2e/**/*"
+  ],
+  "exclude": [
+    "node_modules",
+  ]
+}

integration/versioning/e2e/header-versioning.spec.ts

@@ -0,0 +1,284 @@
+import { INestApplication, VersioningType } from '@nestjs/common';
+import { Test } from '@nestjs/testing';
+import * as request from 'supertest';
+import { AppModule } from '../src/app.module';
+
+describe('Versioning', () => {
+  let app: INestApplication;
+
+  before(async () => {
+    const moduleRef = await Test.createTestingModule({
+      imports: [AppModule],
+    }).compile();
+
+    app = moduleRef.createNestApplication();
+    app.enableVersioning({
+      type: VersioningType.HEADER,
+      header: 'X-API-Version',
+    });
+    await app.init();
+  });
+
+  describe('GET /', () => {
+    it('V1', () => {
+      return request(app.getHttpServer())
+        .get('/')
+        .set({
+          'X-API-Version': '1',
+        })
+        .expect(200)
+        .expect('Hello World V1!');
+    });
+
+    it('V2', () => {
+      return request(app.getHttpServer())
+        .get('/')
+        .set({
+          'X-API-Version': '2',
+        })
+        .expect(200)
+        .expect('Hello World V2!');
+    });
+
+    it('V3', () => {
+      return request(app.getHttpServer())
+        .get('/')
+        .set({
+          'X-API-Version': '3',
+        })
+        .expect(404);
+    });
+
+    it('No Version', () => {
+      return request(app.getHttpServer())
+        .get('/')
+        .set({
+          'X-API-Version': '',
+        })
+        .expect(404);
+    });
+
+    it('No Header', () => {
+      return request(app.getHttpServer()).get('/').expect(404);
+    });
+  });
+
+  describe('GET /:param', () => {
+    it('V1', () => {
+      return request(app.getHttpServer())
+        .get('/param/hello')
+        .set({
+          'X-API-Version': '1',
+        })
+        .expect(200)
+        .expect('Parameter V1!');
+    });
+
+    it('V2', () => {
+      return request(app.getHttpServer())
+        .get('/param/hello')
+        .set({
+          'X-API-Version': '2',
+        })
+        .expect(200)
+        .expect('Parameter V2!');
+    });
+
+    it('V3', () => {
+      return request(app.getHttpServer())
+        .get('/param/hello')
+        .set({
+          'X-API-Version': '3',
+        })
+        .expect(404);
+    });
+
+    it('No Version', () => {
+      return request(app.getHttpServer())
+        .get('/param/hello')
+        .set({
+          'X-API-Version': '',
+        })
+        .expect(404);
+    });
+
+    it('No Header', () => {
+      return request(app.getHttpServer()).get('/').expect(404);
+    });
+  });
+
+  describe('GET /multiple', () => {
+    it('V1', () => {
+      return request(app.getHttpServer())
+        .get('/multiple')
+        .set({
+          'X-API-Version': '1',
+        })
+        .expect(200)
+        .expect('Multiple Versions 1 or 2');
+    });
+
+    it('V2', () => {
+      return request(app.getHttpServer())
+        .get('/multiple')
+        .set({
+          'X-API-Version': '2',
+        })
+        .expect(200)
+        .expect('Multiple Versions 1 or 2');
+    });
+
+    it('V3', () => {
+      return request(app.getHttpServer())
+        .get('/multiple')
+        .set({
+          'X-API-Version': '3',
+        })
+        .expect(404);
+    });
+
+    it('No Version', () => {
+      return request(app.getHttpServer())
+        .get('/multiple')
+        .set({
+          'X-API-Version': '',
+        })
+        .expect(404);
+    });
+
+    it('No Header', () => {
+      return request(app.getHttpServer()).get('/multiple').expect(404);
+    });
+  });
+
+  describe('GET /neutral', () => {
+    it('V1', () => {
+      return request(app.getHttpServer())
+        .get('/neutral')
+        .set({
+          'X-API-Version': '1',
+        })
+        .expect(200)
+        .expect('Neutral');
+    });
+
+    it('V2', () => {
+      return request(app.getHttpServer())
+        .get('/neutral')
+        .set({
+          'X-API-Version': '2',
+        })
+        .expect(200)
+        .expect('Neutral');
+    });
+
+    it('No Version', () => {
+      return request(app.getHttpServer())
+        .get('/neutral')
+        .set({
+          'X-API-Version': '',
+        })
+        .expect(200)
+        .expect('Neutral');
+    });
+
+    it('No Header', () => {
+      return request(app.getHttpServer())
+        .get('/neutral')
+        .expect(200)
+        .expect('Neutral');
+    });
+  });
+
+  describe('GET /override', () => {
+    it('V1', () => {
+      return request(app.getHttpServer())
+        .get('/override')
+        .set({
+          'X-API-Version': '1',
+        })
+        .expect(200)
+        .expect('Override Version 1');
+    });
+
+    it('V2', () => {
+      return request(app.getHttpServer())
+        .get('/override')
+        .set({
+          'X-API-Version': '2',
+        })
+        .expect(200)
+        .expect('Override Version 2');
+    });
+
+    it('V3', () => {
+      return request(app.getHttpServer())
+        .get('/override')
+        .set({
+          'X-API-Version': '3',
+        })
+        .expect(404);
+    });
+
+    it('No Version', () => {
+      return request(app.getHttpServer())
+        .get('/override')
+        .set({
+          'X-API-Version': '',
+        })
+        .expect(404);
+    });
+
+    it('No Header', () => {
+      return request(app.getHttpServer()).get('/override').expect(404);
+    });
+  });
+
+  describe('GET /override-partial', () => {
+    it('V1', () => {
+      return request(app.getHttpServer())
+        .get('/override-partial')
+        .set({
+          'X-API-Version': '1',
+        })
+        .expect(200)
+        .expect('Override Partial Version 1');
+    });
+
+    it('V2', () => {
+      return request(app.getHttpServer())
+        .get('/override-partial')
+        .set({
+          'X-API-Version': '2',
+        })
+        .expect(200)
+        .expect('Override Partial Version 2');
+    });
+
+    it('V3', () => {
+      return request(app.getHttpServer())
+        .get('/override-partial')
+        .set({
+          'X-API-Version': '3',
+        })
+        .expect(404);
+    });
+
+    it('No Version', () => {
+      return request(app.getHttpServer())
+        .get('/override-partial')
+        .set({
+          'X-API-Version': '',
+        })
+        .expect(404);
+    });
+
+    it('No Header', () => {
+      return request(app.getHttpServer()).get('/override-partial').expect(404);
+    });
+  });
+
+  after(async () => {
+    await app.close();
+  });
+});

integration/versioning/e2e/media-type-versioning.spec.ts

@@ -0,0 +1,284 @@
+import { INestApplication, VersioningType } from '@nestjs/common';
+import { Test } from '@nestjs/testing';
+import * as request from 'supertest';
+import { AppModule } from '../src/app.module';
+
+describe('Versioning', () => {
+  let app: INestApplication;
+
+  before(async () => {
+    const moduleRef = await Test.createTestingModule({
+      imports: [AppModule],
+    }).compile();
+
+    app = moduleRef.createNestApplication();
+    app.enableVersioning({
+      type: VersioningType.MEDIA_TYPE,
+      key: 'v=',
+    });
+    await app.init();
+  });
+
+  describe('GET /', () => {
+    it('V1', () => {
+      return request(app.getHttpServer())
+        .get('/')
+        .set({
+          Accept: 'application/json;v=1',
+        })
+        .expect(200)
+        .expect('Hello World V1!');
+    });
+
+    it('V2', () => {
+      return request(app.getHttpServer())
+        .get('/')
+        .set({
+          Accept: 'application/json;v=2',
+        })
+        .expect(200)
+        .expect('Hello World V2!');
+    });
+
+    it('V3', () => {
+      return request(app.getHttpServer())
+        .get('/')
+        .set({
+          Accept: 'application/json;v=3',
+        })
+        .expect(404);
+    });
+
+    it('No Version', () => {
+      return request(app.getHttpServer())
+        .get('/')
+        .set({
+          Accept: 'application/json',
+        })
+        .expect(404);
+    });
+
+    it('No Header', () => {
+      return request(app.getHttpServer()).get('/').expect(404);
+    });
+  });
+
+  describe('GET /:param', () => {
+    it('V1', () => {
+      return request(app.getHttpServer())
+        .get('/param/hello')
+        .set({
+          Accept: 'application/json;v=1',
+        })
+        .expect(200)
+        .expect('Parameter V1!');
+    });
+
+    it('V2', () => {
+      return request(app.getHttpServer())
+        .get('/param/hello')
+        .set({
+          Accept: 'application/json;v=2',
+        })
+        .expect(200)
+        .expect('Parameter V2!');
+    });
+
+    it('V3', () => {
+      return request(app.getHttpServer())
+        .get('/param/hello')
+        .set({
+          Accept: 'application/json;v=3',
+        })
+        .expect(404);
+    });
+
+    it('No Version', () => {
+      return request(app.getHttpServer())
+        .get('/param/hello')
+        .set({
+          Accept: '',
+        })
+        .expect(404);
+    });
+
+    it('No Header', () => {
+      return request(app.getHttpServer()).get('/').expect(404);
+    });
+  });
+
+  describe('GET /multiple', () => {
+    it('V1', () => {
+      return request(app.getHttpServer())
+        .get('/multiple')
+        .set({
+          Accept: 'application/json;v=1',
+        })
+        .expect(200)
+        .expect('Multiple Versions 1 or 2');
+    });
+
+    it('V2', () => {
+      return request(app.getHttpServer())
+        .get('/multiple')
+        .set({
+          Accept: 'application/json;v=2',
+        })
+        .expect(200)
+        .expect('Multiple Versions 1 or 2');
+    });
+
+    it('V3', () => {
+      return request(app.getHttpServer())
+        .get('/multiple')
+        .set({
+          Accept: 'application/json;v=3',
+        })
+        .expect(404);
+    });
+
+    it('No Version', () => {
+      return request(app.getHttpServer())
+        .get('/multiple')
+        .set({
+          Accept: 'application/json',
+        })
+        .expect(404);
+    });
+
+    it('No Header', () => {
+      return request(app.getHttpServer()).get('/multiple').expect(404);
+    });
+  });
+
+  describe('GET /neutral', () => {
+    it('V1', () => {
+      return request(app.getHttpServer())
+        .get('/neutral')
+        .set({
+          Accept: 'application/json;v=1',
+        })
+        .expect(200)
+        .expect('Neutral');
+    });
+
+    it('V2', () => {
+      return request(app.getHttpServer())
+        .get('/neutral')
+        .set({
+          Accept: 'application/json;v=2',
+        })
+        .expect(200)
+        .expect('Neutral');
+    });
+
+    it('No Version', () => {
+      return request(app.getHttpServer())
+        .get('/neutral')
+        .set({
+          Accept: 'application/json',
+        })
+        .expect(200)
+        .expect('Neutral');
+    });
+
+    it('No Header', () => {
+      return request(app.getHttpServer())
+        .get('/neutral')
+        .expect(200)
+        .expect('Neutral');
+    });
+  });
+
+  describe('GET /override', () => {
+    it('V1', () => {
+      return request(app.getHttpServer())
+        .get('/override')
+        .set({
+          Accept: 'application/json;v=1',
+        })
+        .expect(200)
+        .expect('Override Version 1');
+    });
+
+    it('V2', () => {
+      return request(app.getHttpServer())
+        .get('/override')
+        .set({
+          Accept: 'application/json;v=2',
+        })
+        .expect(200)
+        .expect('Override Version 2');
+    });
+
+    it('V3', () => {
+      return request(app.getHttpServer())
+        .get('/override')
+        .set({
+          Accept: 'application/json;v=3',
+        })
+        .expect(404);
+    });
+
+    it('No Version', () => {
+      return request(app.getHttpServer())
+        .get('/override')
+        .set({
+          Accept: 'application/json',
+        })
+        .expect(404);
+    });
+
+    it('No Header', () => {
+      return request(app.getHttpServer()).get('/override').expect(404);
+    });
+  });
+
+  describe('GET /override-partial', () => {
+    it('V1', () => {
+      return request(app.getHttpServer())
+        .get('/override-partial')
+        .set({
+          Accept: 'application/json;v=1',
+        })
+        .expect(200)
+        .expect('Override Partial Version 1');
+    });
+
+    it('V2', () => {
+      return request(app.getHttpServer())
+        .get('/override-partial')
+        .set({
+          Accept: 'application/json;v=2',
+        })
+        .expect(200)
+        .expect('Override Partial Version 2');
+    });
+
+    it('V3', () => {
+      return request(app.getHttpServer())
+        .get('/override-partial')
+        .set({
+          Accept: 'application/json;v=3',
+        })
+        .expect(404);
+    });
+
+    it('No Version', () => {
+      return request(app.getHttpServer())
+        .get('/override-partial')
+        .set({
+          Accept: 'application/json',
+        })
+        .expect(404);
+    });
+
+    it('No Header', () => {
+      return request(app.getHttpServer()).get('/override-partial').expect(404);
+    });
+  });
+
+  after(async () => {
+    await app.close();
+  });
+});

integration/versioning/e2e/uri-versioning.spec.ts

@@ -0,0 +1,155 @@
+import { INestApplication, VersioningType } from '@nestjs/common';
+import { Test } from '@nestjs/testing';
+import * as request from 'supertest';
+import { AppModule } from '../src/app.module';
+
+describe('Versioning', () => {
+  let app: INestApplication;
+
+  before(async () => {
+    const moduleRef = await Test.createTestingModule({
+      imports: [AppModule],
+    }).compile();
+
+    app = moduleRef.createNestApplication();
+    app.enableVersioning({
+      type: VersioningType.URI,
+    });
+    await app.init();
+  });
+
+  describe('GET /', () => {
+    it('V1', () => {
+      return request(app.getHttpServer())
+        .get('/v1/')
+        .expect(200)
+        .expect('Hello World V1!');
+    });
+
+    it('V2', () => {
+      return request(app.getHttpServer())
+        .get('/v2/')
+        .expect(200)
+        .expect('Hello World V2!');
+    });
+
+    it('V3', () => {
+      return request(app.getHttpServer()).get('/v3/').expect(404);
+    });
+
+    it('No Version', () => {
+      return request(app.getHttpServer()).get('/').expect(404);
+    });
+  });
+
+  describe('GET /:param', () => {
+    it('V1', () => {
+      return request(app.getHttpServer())
+        .get('/v1/param/hello')
+        .expect(200)
+        .expect('Parameter V1!');
+    });
+
+    it('V2', () => {
+      return request(app.getHttpServer())
+        .get('/v2/param/hello')
+        .expect(200)
+        .expect('Parameter V2!');
+    });
+
+    it('V3', () => {
+      return request(app.getHttpServer()).get('/v3/param/hello').expect(404);
+    });
+
+    it('No Version', () => {
+      return request(app.getHttpServer()).get('/param/hello').expect(404);
+    });
+  });
+
+  describe('GET /multiple', () => {
+    it('V1', () => {
+      return request(app.getHttpServer())
+        .get('/v1/multiple')
+        .expect(200)
+        .expect('Multiple Versions 1 or 2');
+    });
+
+    it('V2', () => {
+      return request(app.getHttpServer())
+        .get('/v2/multiple')
+        .expect(200)
+        .expect('Multiple Versions 1 or 2');
+    });
+
+    it('V3', () => {
+      return request(app.getHttpServer()).get('/v3/multiple').expect(404);
+    });
+
+    it('No Version', () => {
+      return request(app.getHttpServer()).get('/multiple').expect(404);
+    });
+  });
+
+  describe('GET /neutral', () => {
+    it('No Version', () => {
+      return request(app.getHttpServer())
+        .get('/neutral')
+        .expect(200)
+        .expect('Neutral');
+    });
+  });
+
+  describe('GET /override', () => {
+    it('V1', () => {
+      return request(app.getHttpServer())
+        .get('/v1/override')
+        .expect(200)
+        .expect('Override Version 1');
+    });
+
+    it('V2', () => {
+      return request(app.getHttpServer())
+        .get('/v2/override')
+        .expect(200)
+        .expect('Override Version 2');
+    });
+
+    it('V3', () => {
+      return request(app.getHttpServer()).get('/v3/override').expect(404);
+    });
+
+    it('No Version', () => {
+      return request(app.getHttpServer()).get('/override').expect(404);
+    });
+  });
+
+  describe('GET /override-partial', () => {
+    it('V1', () => {
+      return request(app.getHttpServer())
+        .get('/v1/override-partial')
+        .expect(200)
+        .expect('Override Partial Version 1');
+    });
+
+    it('V2', () => {
+      return request(app.getHttpServer())
+        .get('/v2/override-partial')
+        .expect(200)
+        .expect('Override Partial Version 2');
+    });
+
+    it('V3', () => {
+      return request(app.getHttpServer())
+        .get('/v3/override-partial')
+        .expect(404);
+    });
+
+    it('No Version', () => {
+      return request(app.getHttpServer()).get('/override-partial').expect(404);
+    });
+  });
+
+  after(async () => {
+    await app.close();
+  });
+});

integration/versioning/src/app-v1.controller.ts

@@ -0,0 +1,16 @@
+import { Controller, Get } from '@nestjs/common';
+
+@Controller({
+  version: '1',
+})
+export class AppV1Controller {
+  @Get('/')
+  helloWorldV1() {
+    return 'Hello World V1!';
+  }
+
+  @Get('/:param/hello')
+  paramV1() {
+    return 'Parameter V1!';
+  }
+}

integration/versioning/src/app-v2.controller.ts

@@ -0,0 +1,16 @@
+import { Controller, Get } from '@nestjs/common';
+
+@Controller({
+  version: '2',
+})
+export class AppV2Controller {
+  @Get('/')
+  helloWorldV2() {
+    return 'Hello World V2!';
+  }
+
+  @Get('/:param/hello')
+  paramV1() {
+    return 'Parameter V2!';
+  }
+}

integration/versioning/src/app.module.ts

@@ -0,0 +1,20 @@
+import { Module } from '@nestjs/common';
+import { AppV1Controller } from './app-v1.controller';
+import { AppV2Controller } from './app-v2.controller';
+import { MultipleVersionController } from './multiple.controller';
+import { VersionNeutralController } from './neutral.controller';
+import { OverrideController } from './override.controller';
+import { OverridePartialController } from './override-partial.controller';
+
+@Module({
+  imports: [],
+  controllers: [
+    AppV1Controller,
+    AppV2Controller,
+    MultipleVersionController,
+    VersionNeutralController,
+    OverrideController,
+    OverridePartialController,
+  ],
+})
+export class AppModule {}

integration/versioning/src/main.ts

@@ -0,0 +1,15 @@
+import { VersioningType } from '@nestjs/common';
+import { NestFactory } from '@nestjs/core';
+import { AppModule } from './app.module';
+
+async function bootstrap() {
+  const app = await NestFactory.create(AppModule);
+  app.enableVersioning({
+    type: VersioningType.MEDIA_TYPE,
+    key: 'v=',
+  });
+
+  await app.listen(3000);
+  console.log(`Application is running on: ${await app.getUrl()}`);
+}
+bootstrap();

integration/versioning/src/multiple.controller.ts

@@ -0,0 +1,11 @@
+import { Controller, Get } from '@nestjs/common';
+
+@Controller({
+  version: ['1', '2'],
+})
+export class MultipleVersionController {
+  @Get('/multiple')
+  multiple() {
+    return 'Multiple Versions 1 or 2';
+  }
+}

integration/versioning/src/neutral.controller.ts

@@ -0,0 +1,11 @@
+import { Controller, Get, VERSION_NEUTRAL } from '@nestjs/common';
+
+@Controller({
+  version: VERSION_NEUTRAL,
+})
+export class VersionNeutralController {
+  @Get('/neutral')
+  neutral() {
+    return 'Neutral';
+  }
+}

integration/versioning/src/override-partial.controller.ts

@@ -0,0 +1,17 @@
+import { Controller, Get, Version } from '@nestjs/common';
+
+@Controller({
+  version: '1'
+})
+export class OverridePartialController {
+  @Get('/override-partial')
+  overridePartialV1() {
+    return 'Override Partial Version 1';
+  }
+
+  @Version('2')
+  @Get('/override-partial')
+  overridePartialV2() {
+    return 'Override Partial Version 2';
+  }
+}

integration/versioning/src/override.controller.ts

@@ -0,0 +1,16 @@
+import { Controller, Get, Version } from '@nestjs/common';
+
+@Controller()
+export class OverrideController {
+  @Version('1')
+  @Get('/override')
+  overrideV1() {
+    return 'Override Version 1';
+  }
+
+  @Version('2')
+  @Get('/override')
+  overrideV2() {
+    return 'Override Version 2';
+  }
+}

integration/versioning/tsconfig.json

@@ -0,0 +1,22 @@
+{
+  "compilerOptions": {
+    "module": "commonjs",
+    "declaration": false,
+    "noImplicitAny": false,
+    "removeComments": true,
+    "noLib": false,
+    "emitDecoratorMetadata": true,
+    "experimentalDecorators": true,
+    "target": "es6",
+    "sourceMap": true,
+    "allowJs": true,
+    "outDir": "./dist"
+  },
+  "include": [
+    "src/**/*",
+    "e2e/**/*"
+  ],
+  "exclude": [
+    "node_modules",
+  ]
+}

integration/websockets/e2e/error-gateway.spec.ts

@@ -1,7 +1,7 @@
 import { INestApplication } from '@nestjs/common';
 import { Test } from '@nestjs/testing';
 import { expect } from 'chai';
-import * as io from 'socket.io-client';
+import { io } from 'socket.io-client';
 import { ErrorGateway } from '../src/error.gateway';
 
 describe('ErrorGateway', () => {
@@ -12,11 +12,11 @@ describe('ErrorGateway', () => {
       providers: [ErrorGateway],
     }).compile();
     app = await testingModule.createNestApplication();
-    await app.listenAsync(3000);
+    await app.listen(3000);
   });
 
   it(`should handle error`, async () => {
-    const ws = io.connect('http://localhost:8080');
+    const ws = io('http://localhost:8080');
     ws.emit('push', {
       test: 'test',
     });

integration/websockets/e2e/gateway-ack.spec.ts

@@ -1,14 +1,14 @@
 import { INestApplication } from '@nestjs/common';
 import { Test } from '@nestjs/testing';
 import { expect } from 'chai';
-import * as io from 'socket.io-client';
+import { io } from 'socket.io-client';
 import { AckGateway } from '../src/ack.gateway';
 
 async function createNestApp(...gateways): Promise<INestApplication> {
   const testingModule = await Test.createTestingModule({
     providers: gateways,
   }).compile();
-  const app = await testingModule.createNestApplication();
+  const app = testingModule.createNestApplication();
   return app;
 }
 
@@ -17,9 +17,9 @@ describe('WebSocketGateway (ack)', () => {
 
   it(`should handle message with ack (http)`, async () => {
     app = await createNestApp(AckGateway);
-    await app.listenAsync(3000);
+    await app.listen(3000);
 
-    ws = io.connect('http://localhost:8080');
+    ws = io('http://localhost:8080');
     await new Promise<void>(resolve =>
       ws.emit('push', { test: 'test' }, data => {
         expect(data).to.be.eql('pong');
@@ -30,9 +30,9 @@ describe('WebSocketGateway (ack)', () => {
 
   it(`should handle message with ack & without data (http)`, async () => {
     app = await createNestApp(AckGateway);
-    await app.listenAsync(3000);
+    await app.listen(3000);
 
-    ws = io.connect('http://localhost:8080');
+    ws = io('http://localhost:8080');
     await new Promise<void>(resolve =>
       ws.emit('push', data => {
         expect(data).to.be.eql('pong');

integration/websockets/e2e/gateway.spec.ts

@@ -1,7 +1,7 @@
 import { INestApplication } from '@nestjs/common';
 import { Test } from '@nestjs/testing';
 import { expect } from 'chai';
-import * as io from 'socket.io-client';
+import { io } from 'socket.io-client';
 import { ApplicationGateway } from '../src/app.gateway';
 import { NamespaceGateway } from '../src/namespace.gateway';
 import { ServerGateway } from '../src/server.gateway';
@@ -10,7 +10,7 @@ async function createNestApp(...gateways): Promise<INestApplication> {
   const testingModule = await Test.createTestingModule({
     providers: gateways,
   }).compile();
-  const app = await testingModule.createNestApplication();
+  const app = testingModule.createNestApplication();
   return app;
 }
 
@@ -19,9 +19,9 @@ describe('WebSocketGateway', () => {
 
   it(`should handle message (2nd port)`, async () => {
     app = await createNestApp(ApplicationGateway);
-    await app.listenAsync(3000);
+    await app.listen(3000);
 
-    ws = io.connect('http://localhost:8080');
+    ws = io('http://localhost:8080');
     ws.emit('push', {
       test: 'test',
     });
@@ -35,9 +35,9 @@ describe('WebSocketGateway', () => {
 
   it(`should handle message (http)`, async () => {
     app = await createNestApp(ServerGateway);
-    await app.listenAsync(3000);
+    await app.listen(3000);
 
-    ws = io.connect('http://localhost:3000');
+    ws = io('http://localhost:3000');
     ws.emit('push', {
       test: 'test',
     });
@@ -51,10 +51,10 @@ describe('WebSocketGateway', () => {
 
   it(`should handle message (2 gateways)`, async () => {
     app = await createNestApp(ApplicationGateway, NamespaceGateway);
-    await app.listenAsync(3000);
+    await app.listen(3000);
 
-    ws = io.connect('http://localhost:8080');
-    io.connect('http://localhost:8080/test').emit('push', {});
+    ws = io('http://localhost:8080');
+    io('http://localhost:8080/test').emit('push', {});
     ws.emit('push', {
       test: 'test',
     });

integration/websockets/e2e/ws-gateway.spec.ts

@@ -5,7 +5,10 @@ import { expect } from 'chai';
 import * as WebSocket from 'ws';
 import { ApplicationGateway } from '../src/app.gateway';
 import { CoreGateway } from '../src/core.gateway';
+import { ExamplePathGateway } from '../src/example-path.gateway';
 import { ServerGateway } from '../src/server.gateway';
+import { WsPathGateway } from '../src/ws-path.gateway';
+import { WsPathGateway2 } from '../src/ws-path2.gateway';
 
 async function createNestApp(...gateways): Promise<INestApplication> {
   const testingModule = await Test.createTestingModule({
@@ -21,7 +24,7 @@ describe('WebSocketGateway (WsAdapter)', () => {
 
   it(`should handle message (2nd port)`, async () => {
     app = await createNestApp(ApplicationGateway);
-    await app.listenAsync(3000);
+    await app.listen(3000);
 
     ws = new WebSocket('ws://localhost:8080');
     await new Promise(resolve => ws.on('open', resolve));
@@ -44,7 +47,7 @@ describe('WebSocketGateway (WsAdapter)', () => {
 
   it(`should handle message (http)`, async () => {
     app = await createNestApp(ServerGateway);
-    await app.listenAsync(3000);
+    await app.listen(3000);
 
     ws = new WebSocket('ws://localhost:3000');
     await new Promise(resolve => ws.on('open', resolve));
@@ -65,11 +68,85 @@ describe('WebSocketGateway (WsAdapter)', () => {
     );
   });
 
-  it(`should support 2 different gateways`, async function () {
+  it(`should handle message on a different path`, async () => {
+    app = await createNestApp(WsPathGateway);
+    await app.listenAsync(3000);
+    try {
+      ws = new WebSocket('ws://localhost:3000/ws-path');
+      await new Promise((resolve, reject) => {
+        ws.on('open', resolve);
+        ws.on('error', reject);
+      });
+
+      ws.send(
+        JSON.stringify({
+          event: 'push',
+          data: {
+            test: 'test',
+          },
+        }),
+      );
+      await new Promise<void>(resolve =>
+        ws.on('message', data => {
+          expect(JSON.parse(data).data.test).to.be.eql('test');
+          resolve();
+        }),
+      );
+    } catch (err) {
+      console.log(err);
+    }
+  });
+
+  it(`should support 2 different gateways running on different paths`, async function () {
+    this.retries(10);
+
+    app = await createNestApp(ExamplePathGateway, WsPathGateway2);
+    await app.listenAsync(3000);
+
+    // open websockets delay
+    await new Promise(resolve => setTimeout(resolve, 1000));
+
+    ws = new WebSocket('ws://localhost:3000/example');
+    ws2 = new WebSocket('ws://localhost:3000/ws-path');
+
+    await new Promise<void>(resolve =>
+      ws.on('open', () => {
+        ws.on('message', data => {
+          expect(JSON.parse(data).data.test).to.be.eql('test');
+          resolve();
+        });
+        ws.send(
+          JSON.stringify({
+            event: 'push',
+            data: {
+              test: 'test',
+            },
+          }),
+        );
+      }),
+    );
+
+    await new Promise<void>(resolve => {
+      ws2.on('message', data => {
+        expect(JSON.parse(data).data.test).to.be.eql('test');
+        resolve();
+      });
+      ws2.send(
+        JSON.stringify({
+          event: 'push',
+          data: {
+            test: 'test',
+          },
+        }),
+      );
+    });
+  });
+
+  it(`should support 2 different gateways running on the same path (but different ports)`, async function () {
     this.retries(10);
 
     app = await createNestApp(ApplicationGateway, CoreGateway);
-    await app.listenAsync(3000);
+    await app.listen(3000);
 
     // open websockets delay
     await new Promise(resolve => setTimeout(resolve, 1000));

integration/websockets/src/error.gateway.ts

@@ -9,6 +9,6 @@ import { throwError } from 'rxjs';
 export class ErrorGateway {
   @SubscribeMessage('push')
   onPush(client, data) {
-    return throwError(new WsException('test'));
+    return throwError(() => new WsException('test'));
   }
 }

integration/websockets/src/example-path.gateway.ts

@@ -0,0 +1,14 @@
+import { SubscribeMessage, WebSocketGateway } from '@nestjs/websockets';
+
+@WebSocketGateway({
+  path: '/example',
+})
+export class ExamplePathGateway {
+  @SubscribeMessage('push')
+  onPush(client, data) {
+    return {
+      event: 'pop',
+      data,
+    };
+  }
+}

integration/websockets/src/ws-path.gateway.ts

@@ -0,0 +1,14 @@
+import { SubscribeMessage, WebSocketGateway } from '@nestjs/websockets';
+
+@WebSocketGateway({
+  path: '/ws-path',
+})
+export class WsPathGateway {
+  @SubscribeMessage('push')
+  onPush(client, data) {
+    return {
+      event: 'pop',
+      data,
+    };
+  }
+}

integration/websockets/src/ws-path2.gateway.ts

@@ -0,0 +1,14 @@
+import { SubscribeMessage, WebSocketGateway } from '@nestjs/websockets';
+
+@WebSocketGateway({
+  path: '/ws-path',
+})
+export class WsPathGateway2 {
+  @SubscribeMessage('push')
+  onPush(client, data) {
+    return {
+      event: 'pop',
+      data,
+    };
+  }
+}

lerna.json

@@ -3,5 +3,5 @@
   "packages": [
     "packages/*"
   ],
-  "version": "7.6.8"
+  "version": "8.0.4"
 }

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nestjs/core",
-  "version": "7.6.8",
+  "version": "8.0.0-alpha.1",
   "description": "Modern, fast, powerful node.js web framework",
   "homepage": "https://nestjs.com",
   "repository": {
@@ -24,7 +24,7 @@
     "coverage": "nyc report --reporter=text-lcov | coveralls",
     "format": "prettier \"**/*.ts\" --ignore-path ./.prettierignore --write && git status",
     "postinstall": "opencollective",
-    "test": "nyc --require ts-node/register mocha packages/**/*.spec.ts --reporter spec --retries 3 --require 'node_modules/reflect-metadata/Reflect.js' --exit",
+    "test": "nyc --require ts-node/register mocha packages/**/*.spec.ts --reporter spec --require 'node_modules/reflect-metadata/Reflect.js' --exit",
     "test:integration": "mocha \"integration/*/{,!(node_modules)/**/}/*.spec.ts\" --reporter spec --require ts-node/register --require 'node_modules/reflect-metadata/Reflect.js' --exit",
     "test:docker:up": "docker-compose -f integration/docker-compose.yml up -d",
     "test:docker:down": "docker-compose -f integration/docker-compose.yml down",
@@ -54,118 +54,121 @@
   "dependencies": {
     "@nuxtjs/opencollective": "0.3.2",
     "axios": "0.21.1",
-    "class-transformer": "0.3.2",
+    "class-transformer": "0.4.0",
     "class-validator": "0.13.1",
     "cli-color": "2.0.0",
     "cors": "2.8.5",
     "express": "4.17.1",
-    "fast-json-stringify": "2.4.1",
-    "fast-safe-stringify": "2.0.7",
+    "fast-json-stringify": "2.7.7",
+    "fast-safe-stringify": "2.0.8",
     "iterare": "1.2.1",
-    "object-hash": "2.1.1",
+    "object-hash": "2.2.0",
     "path-to-regexp": "3.2.0",
     "reflect-metadata": "0.1.13",
-    "rxjs": "6.6.3",
-    "socket.io": "2.4.1",
-    "tslib": "2.1.0",
+    "rxjs": "7.2.0",
+    "socket.io": "4.1.3",
+    "tslib": "2.3.0",
     "uuid": "8.3.2"
   },
   "devDependencies": {
-    "@codechecks/client": "0.1.10",
-    "@commitlint/cli": "11.0.0",
-    "@commitlint/config-angular": "11.0.0",
-    "@grpc/proto-loader": "0.5.6",
-    "@nestjs/graphql": "7.9.8",
-    "@nestjs/mongoose": "7.2.2",
-    "@nestjs/typeorm": "7.1.5",
-    "@types/amqplib": "0.5.17",
-    "@types/bytes": "3.1.0",
-    "@types/cache-manager": "3.4.0",
-    "@types/chai": "4.2.14",
-    "@types/chai-as-promised": "7.1.3",
-    "@types/cors": "2.8.9",
-    "@types/express": "4.17.11",
-    "@types/gulp": "4.0.8",
-    "@types/mocha": "8.2.0",
-    "@types/mongoose": "5.10.3",
-    "@types/node": "14.14.22",
-    "@types/redis": "2.8.28",
+    "@codechecks/client": "0.1.11",
+    "@commitlint/cli": "12.1.4",
+    "@commitlint/config-angular": "12.1.4",
+    "@grpc/grpc-js": "1.3.5",
+    "@grpc/proto-loader": "0.6.4",
+    "@nestjs/graphql": "7.11.0",
+    "@nestjs/mongoose": "8.0.0",
+    "@nestjs/typeorm": "8.0.1",
+    "@types/amqplib": "0.8.1",
+    "@types/bytes": "3.1.1",
+    "@types/cache-manager": "3.4.2",
+    "@types/chai": "4.2.21",
+    "@types/chai-as-promised": "7.1.4",
+    "@types/cors": "2.8.12",
+    "@types/express": "4.17.13",
+    "@types/gulp": "4.0.9",
+    "@types/http-errors": "1.8.1",
+    "@types/mocha": "8.2.3",
+    "@types/mongoose": "5.11.97",
+    "@types/node": "15.14.0",
+    "@types/redis": "2.8.31",
     "@types/reflect-metadata": "0.1.0",
-    "@types/sinon": "9.0.10",
-    "@types/socket.io": "2.1.13",
-    "@types/ws": "7.4.0",
-    "@typescript-eslint/eslint-plugin": "4.14.2",
-    "@typescript-eslint/parser": "4.14.2",
-    "amqp-connection-manager": "3.2.1",
-    "amqplib": "0.6.0",
-    "apollo-server-express": "2.19.2",
-    "artillery": "1.6.1",
+    "@types/sinon": "10.0.2",
+    "@types/socket.io": "3.0.2",
+    "@types/ws": "7.4.6",
+    "@typescript-eslint/eslint-plugin": "4.28.3",
+    "@typescript-eslint/parser": "4.28.3",
+    "amqp-connection-manager": "3.2.2",
+    "amqplib": "0.8.0",
+    "apollo-server-express": "2.25.2",
+    "artillery": "1.7.6",
     "awesome-typescript-loader": "5.2.1",
     "body-parser": "1.19.0",
     "bytes": "3.1.0",
-    "cache-manager": "3.4.0",
-    "chai": "4.2.0",
+    "cache-manager": "3.4.4",
+    "cache-manager-redis-store": "2.0.0",
+    "chai": "4.3.4",
     "chai-as-promised": "7.1.1",
     "clang-format": "1.5.0",
     "commitlint-circle": "1.0.0",
-    "concurrently": "5.3.0",
+    "concurrently": "6.2.0",
     "conventional-changelog": "3.1.24",
-    "core-js": "3.8.3",
-    "coveralls": "3.1.0",
+    "core-js": "3.15.2",
+    "coveralls": "3.1.1",
     "delete-empty": "3.0.0",
-    "engine.io-client": "4.1.0",
-    "eslint": "7.19.0",
-    "eslint-config-prettier": "7.2.0",
-    "eslint-plugin-import": "2.22.1",
-    "eventsource": "1.0.7",
+    "engine.io-client": "5.1.2",
+    "eslint": "7.30.0",
+    "eslint-config-prettier": "8.3.0",
+    "eslint-plugin-import": "2.23.4",
+    "eventsource": "1.1.0",
     "fancy-log": "1.3.3",
-    "fastify": "3.11.0",
-    "fastify-cors": "5.2.0",
+    "fastify": "3.19.1",
+    "fastify-cors": "6.0.2",
     "fastify-formbody": "5.0.0",
-    "fastify-multipart": "3.3.1",
-    "fastify-static": "3.4.0",
-    "graphql": "15.5.0",
-    "graphql-tools": "7.0.2",
-    "grpc": "1.24.4",
+    "fastify-multipart": "4.0.7",
+    "fastify-static": "4.2.2",
+    "graphql": "15.5.1",
+    "graphql-tools": "7.0.5",
     "gulp": "4.0.2",
     "gulp-clang-format": "1.0.27",
     "gulp-clean": "0.4.0",
     "gulp-sourcemaps": "3.0.0",
     "gulp-typescript": "5.0.1",
     "gulp-watch": "5.0.1",
-    "husky": "4.3.8",
-    "imports-loader": "2.0.0",
+    "http-errors": "1.8.0",
+    "husky": "7.0.1",
+    "imports-loader": "3.0.0",
     "json-loader": "0.5.7",
     "kafkajs": "1.15.0",
     "lerna": "2.11.0",
     "light-my-request": "4.4.1",
-    "lint-staged": "10.5.3",
+    "lint-staged": "11.0.1",
     "markdown-table": "2.0.0",
     "merge-graphql-schemas": "1.7.8",
-    "middie": "5.2.0",
-    "mocha": "8.2.1",
-    "mongoose": "5.11.14",
-    "mqtt": "4.2.6",
+    "middie": "5.3.0",
+    "mocha": "9.0.2",
+    "mongoose": "5.13.2",
+    "mqtt": "4.2.8",
     "multer": "1.4.2",
     "mysql": "2.18.1",
-    "nats": "1.4.12",
-    "nodemon": "2.0.7",
+    "nats": "2.1.0",
+    "nodemon": "2.0.12",
     "nyc": "15.1.0",
-    "point-of-view": "4.11.0",
-    "prettier": "2.2.1",
-    "redis": "3.0.2",
-    "rxjs-compat": "6.6.3",
-    "sinon": "9.2.4",
-    "sinon-chai": "3.5.0",
-    "socket.io-client": "2.4.0",
-    "subscriptions-transport-ws": "0.9.18",
+    "point-of-view": "4.15.1",
+    "prettier": "2.3.2",
+    "redis": "3.1.2",
+    "rxjs-compat": "6.6.7",
+    "sinon": "11.1.1",
+    "sinon-chai": "3.7.0",
+    "socket.io-client": "4.1.3",
+    "subscriptions-transport-ws": "0.9.19",
     "supertest": "6.1.3",
-    "ts-morph": "9.1.0",
-    "ts-node": "9.1.1",
-    "typeorm": "0.2.30",
-    "typescript": "4.1.3",
+    "ts-morph": "11.0.3",
+    "ts-node": "10.1.0",
+    "typeorm": "0.2.34",
+    "typescript": "4.3.5",
     "wrk": "1.2.1",
-    "ws": "7.4.2"
+    "ws": "7.5.3"
   },
   "engines": {
     "node": ">= 10.13.0"
@@ -182,8 +185,6 @@
       "packages/**/*.ts"
     ],
     "exclude": [
-      "node_modules/",
-      "packages/**/test/**",
       "packages/**/*.spec.ts",
       "packages/**/adapters/*.ts",
       "packages/**/nest-*.ts",
@@ -197,9 +198,10 @@
       "packages/core/middleware/middleware-module.ts",
       "packages/core/injector/module-ref.ts",
       "packages/core/injector/instance-links-host.ts",
+      "packages/core/helpers/context-id-factory.ts",
       "packages/common/cache/**/*",
       "packages/common/serializer/**/*",
-      "packages/common/services/logger.service.ts"
+      "packages/common/services/*.ts"
     ],
     "extension": [
       ".ts"

packages/common/Readme.md

@@ -37,6 +37,8 @@ Nest is a framework for building efficient, scalable <a href="http://nodejs.org"
 
 * To check out the [guide](https://docs.nestjs.com), visit [docs.nestjs.com](https://docs.nestjs.com). :books:
 * 要查看中文 [指南](readme_zh.md), 请访问 [docs.nestjs.cn](https://docs.nestjs.cn). :books:
+* [가이드](readme_kr.md)를 확인하려면, [docs.nestjs.com](https://docs.nestjs.com)를 방문하세요.:books: 
+* チェックするには [ガイド](readme_jp.md), 詳しくは [docs.nestjs.com](https://docs.nestjs.com). :books: 
 
 ## Questions
 
@@ -64,6 +66,8 @@ Nest is an MIT-licensed open source project. It can grow thanks to the sponsors
 #### Gold Sponsors
 
 <table style="text-align:center;"><tr><td>
+  <a href="https://careers.labster.com/departments/platform" target="_blank"><img src="https://nestjs.com/img/labster-logo.png" width="170" valign="middle" /></a></td><td>
+<a href="https://weld.so/" target="_blank"><img src="https://nestjs.com/img/weld-logo.svg" width="150" valign="middle" /></a></td><td>
 <a href="https://valor-software.com/" target="_blank"><img src="https://docs.nestjs.com/assets/sponsors/valor-software.png" width="170" valign="middle" /></a></td></tr></table>
 
 #### Silver Sponsors
@@ -72,7 +76,8 @@ Nest is an MIT-licensed open source project. It can grow thanks to the sponsors
 <a href="https://neoteric.eu/" target="_blank"><img src="https://nestjs.com/img/neoteric-cut.png" width="120" valign="middle" /></a> </td><td>
   <a href="http://gojob.com" target="_blank"><img src="http://nestjs.com/img/gojob-logo.png" valign="middle" width="100" /></a> </td><td>
 <a href="http://www.leogistics.com" target="_blank"><img src="https://nestjs.com/img/leogistics-logo.jpeg" width="150" valign="middle" /></td><td>
-<a href="http://www.meetdandy.com" target="_blank"><img src="https://nestjs.com/img/dandy-wide-logo.png" width="150" valign="middle" /></td></tr></table>
+<a href="http://www.meetdandy.com" target="_blank"><img src="https://nestjs.com/img/dandy-wide-logo.png" width="150" valign="middle" /></td><td>
+<a href="https://www.castlecraft.in" target="_blank"><img src="https://nestjs.com/img/castlecraft-logo.png" width="150" valign="middle" /></td></tr></table>
 
 #### Sponsors
 
@@ -95,11 +100,14 @@ Nest is an MIT-licensed open source project. It can grow thanks to the sponsors
   <td align="center" valign="middle">
   <a href="https://genuinebee.com/" target="_blank"><img src="https://nestjs.com/img/genuinebee.svg" width="97" valign="middle" /></a> </td>
 <td align="center" valign="middle"><a href="https://sanyodigital.com/" target="_blank"><img src="https://nestjs.com/img/sanyo-digital.png" width="130" valign="middle" /></a></td></tr><tr><td align="center" valign="middle"><a href="https://vpn-review.com/vpn-for-torrenting" target="_blank"><img src="https://nestjs.com/img/vpn-review-logo.png" width="85" valign="middle" /></a></td><td align="center" valign="middle"><a href="https://lambda-it.ch/" target="_blank"><img src="https://nestjs.com/img/lambda-it-logo.svg" width="115" valign="middle" /></a></td><td align="center" valign="middle"><a href="https://pickwriters.com/top-10-translation-services" target="_blank"><img src="https://nestjs.com/img/pickwriters-logo.png" width="40" valign="middle" /></a></td><td align="center" valign="middle"><a href="https://thewordpoint.com/services/localization" target="_blank"><img src="https://nestjs.com/img/thewordpoint-logo.png" width="40" valign="middle" /></a></td>
-<td align="center" valign="middle"><a href="https://streamat.se/" target="_blank"><img src="https://nestjs.com/img/streamat-logo.png" width="120" valign="middle" /></a></td>
-<td align="center" valign="middle"><a href="https://filmen.nu/" target="_blank"><img src="https://nestjs.com/img/filmen-logo.png" width="120" valign="middle" /></a></td></tr><tr>
 <td align="center" valign="middle"><a href="https://meercode.io/" target="_blank"><img src="https://nestjs.com/img/meercode-logo.png" width="60" valign="middle" /></a></td>
-  <td align="center" valign="middle"><a href="https://www.najlepszeplatformyforex.pl/blog/broker-xtb/" target="_blank"><img src="https://nestjs.com/img/npf-logo.jpg" width="200" valign="middle" /></a></td>
-    <td align="center" valign="middle"><a href="https://thestandarddaily.com/" target="_blank"><img src="https://nestjs.com/img/the-standard-daily-logo.png" width="180" valign="middle" /></a></td>
+  <td align="center" valign="middle"><a href="https://www.najlepszeplatformyforex.pl/blog/broker-xtb/" target="_blank"><img src="https://nestjs.com/img/npf-logo.jpg" width="200" valign="middle" /></a></td></tr><tr>
+<td align="center" valign="middle"><a href="https://thestandarddaily.com/" target="_blank"><img src="https://nestjs.com/img/the-standard-daily-logo.png" width="180" valign="middle" /></a></td>
+<td align="center" valign="middle"><a href="https://houseofangular.io/" target="_blank"><img src="https://nestjs.com/img/house-of-angular.png" width="100" valign="middle" /></a></td>
+<td align="center" valign="middle"><a href="https://rocketech.it/cases/?utm_source=google&utm_medium=badge&utm_campaign=nestjs" target="_blank"><img src="https://nestjs.com/img/rocketech-logo.svg" width="110" valign="middle" /></a></td>
+  <td align="center" valign="middle"><a href="https://www.bystored.com/" target="_blank"><img src="https://nestjs.com/img/stored-logo.svg" width="110" valign="middle" /></a></td>
+  <td align="center" valign="middle"><a href="https://studyclerk.com/pay-for-research-paper" target="_blank"><img src="https://nestjs.com/img/studyclerk-logo.png" width="125" valign="middle" /></a></td><td align="center" valign="middle"><a href="https://xyndata.com" target="_blank"><img src="https://nestjs.com/img/xyndata-logo.png" width="125" valign="middle" /></a></td></tr><tr>
+  <td align="center" valign="middle"><a href="https://www.anonymistic.com/" target="_blank"><img src="https://nestjs.com/img/anonymistic-logo.png" width="125" valign="middle" /></a></td>
   </tr></table>
 
 ## Backers

packages/common/cache/cache.providers.ts

@@ -16,11 +16,20 @@ export function createCacheManager(): Provider {
       const cacheManager = loadPackage('cache-manager', 'CacheModule', () =>
         require('cache-manager'),
       );
-      const memoryCache = cacheManager.caching({
-        ...defaultCacheOptions,
-        ...(options || {}),
-      });
-      return memoryCache;
+
+      return Array.isArray(options)
+        ? cacheManager.multiCaching(
+            options.map(store =>
+              cacheManager.caching({
+                ...defaultCacheOptions,
+                ...(store || {}),
+              }),
+            ),
+          )
+        : cacheManager.caching({
+            ...defaultCacheOptions,
+            ...(options || {}),
+          });
     },
     inject: [CACHE_MODULE_OPTIONS],
   };

packages/common/cache/interceptors/cache.interceptor.ts

@@ -27,6 +27,7 @@ export class CacheInterceptor implements NestInterceptor {
   @Inject(HTTP_ADAPTER_HOST)
   protected readonly httpAdapterHost: HttpAdapterHost;
 
+  protected allowedMethods = ['GET'];
   constructor(
     @Inject(CACHE_MANAGER) protected readonly cacheManager: any,
     @Inject(REFLECTOR) protected readonly reflector: any,
@@ -37,8 +38,7 @@ export class CacheInterceptor implements NestInterceptor {
     next: CallHandler,
   ): Promise<Observable<any>> {
     const key = this.trackBy(context);
-    const ttlValueOrFactory =
-      this.reflector.get(CACHE_TTL_METADATA, context.getHandler()) || null;
+    const ttlValueOrFactory = this.reflector.get(CACHE_TTL_METADATA, context.getHandler()) ?? null;
 
     if (!key) {
       return next.handle();
@@ -62,7 +62,7 @@ export class CacheInterceptor implements NestInterceptor {
     }
   }
 
-  trackBy(context: ExecutionContext): string | undefined {
+  protected trackBy(context: ExecutionContext): string | undefined {
     const httpAdapter = this.httpAdapterHost.httpAdapter;
     const isHttpApp = httpAdapter && !!httpAdapter.getRequestMethod;
     const cacheMetadata = this.reflector.get(
@@ -75,9 +75,14 @@ export class CacheInterceptor implements NestInterceptor {
     }
 
     const request = context.getArgByIndex(0);
-    if (httpAdapter.getRequestMethod(request) !== 'GET') {
+    if (!this.isRequestCacheable(context)) {
       return undefined;
     }
     return httpAdapter.getRequestUrl(request);
   }
+
+  protected isRequestCacheable(context: ExecutionContext): boolean {
+    const req = context.switchToHttp().getRequest();
+    return this.allowedMethods.includes(req.method);
+  }
 }

packages/common/constants.ts

@@ -28,3 +28,4 @@ export const HEADERS_METADATA = '__headers__';
 export const REDIRECT_METADATA = '__redirect__';
 export const RESPONSE_PASSTHROUGH_METADATA = '__responsePassthrough__';
 export const SSE_METADATA = '__sse__';
+export const VERSION_METADATA = '__version__';

packages/common/decorators/core/controller.decorator.ts

@@ -2,8 +2,10 @@ import {
   HOST_METADATA,
   PATH_METADATA,
   SCOPE_OPTIONS_METADATA,
+  VERSION_METADATA,
 } from '../../constants';
 import { ScopeOptions } from '../../interfaces/scope-options.interface';
+import { VersionOptions } from '../../interfaces/version-options.interface';
 import { isString, isUndefined } from '../../utils/shared.utils';
 
 /**
@@ -11,11 +13,13 @@ import { isString, isUndefined } from '../../utils/shared.utils';
  *
  * @publicApi
  */
-export interface ControllerOptions extends ScopeOptions {
+export interface ControllerOptions extends ScopeOptions, VersionOptions {
   /**
    * Specifies an optional `route path prefix`.  The prefix is pre-pended to the
    * path specified in any request decorator in the class.
    *
+   * Supported only by HTTP-based applications (does not apply to non-HTTP microservices).
+   *
    * @see [Routing](https://docs.nestjs.com/controllers#routing)
    */
   path?: string | string[];
@@ -27,7 +31,7 @@ export interface ControllerOptions extends ScopeOptions {
    *
    * @see [Routing](https://docs.nestjs.com/controllers#routing)
    */
-  host?: string | string[];
+  host?: string | RegExp | Array<string | RegExp>;
 }
 
 /**
@@ -37,7 +41,7 @@ export interface ControllerOptions extends ScopeOptions {
  * An HTTP Controller responds to inbound HTTP Requests and produces HTTP Responses.
  * It defines a class that provides the context for one or more related route
  * handlers that correspond to HTTP request methods and associated routes
- * for example `GET /api/profile`, `POST /user/resume`.
+ * for example `GET /api/profile`, `POST /users/resume`.
  *
  * A Microservice Controller responds to requests as well as events, running over
  * a variety of transports [(read more here)](https://docs.nestjs.com/microservices/basics).
@@ -58,7 +62,7 @@ export function Controller(): ClassDecorator;
  * An HTTP Controller responds to inbound HTTP Requests and produces HTTP Responses.
  * It defines a class that provides the context for one or more related route
  * handlers that correspond to HTTP request methods and associated routes
- * for example `GET /api/profile`, `POST /user/resume`.
+ * for example `GET /api/profile`, `POST /users/resume`.
  *
  * A Microservice Controller responds to requests as well as events, running over
  * a variety of transports [(read more here)](https://docs.nestjs.com/microservices/basics).
@@ -83,7 +87,7 @@ export function Controller(prefix: string | string[]): ClassDecorator;
  * An HTTP Controller responds to inbound HTTP Requests and produces HTTP Responses.
  * It defines a class that provides the context for one or more related route
  * handlers that correspond to HTTP request methods and associated routes
- * for example `GET /api/profile`, `POST /user/resume`.
+ * for example `GET /api/profile`, `POST /users/resume`.
  *
  * A Microservice Controller responds to requests as well as events, running over
  * a variety of transports [(read more here)](https://docs.nestjs.com/microservices/basics).
@@ -97,10 +101,14 @@ export function Controller(prefix: string | string[]): ClassDecorator;
  * more details.
  * - `prefix` - string that defines a `route path prefix`.  The prefix
  * is pre-pended to the path specified in any request decorator in the class.
+ * - `version` - string, array of strings, or Symbol that defines the version
+ * of all routes in the class. [See Versioning](https://docs.nestjs.com/techniques/versioning)
+ * for more details.
  *
  * @see [Routing](https://docs.nestjs.com/controllers#routing)
  * @see [Controllers](https://docs.nestjs.com/controllers)
  * @see [Microservices](https://docs.nestjs.com/microservices/basics#request-response)
+ * @see [Versioning](https://docs.nestjs.com/techniques/versioning)
  *
  * @publicApi
  */
@@ -113,7 +121,7 @@ export function Controller(options: ControllerOptions): ClassDecorator;
  * An HTTP Controller responds to inbound HTTP Requests and produces HTTP Responses.
  * It defines a class that provides the context for one or more related route
  * handlers that correspond to HTTP request methods and associated routes
- * for example `GET /api/profile`, `POST /user/resume`
+ * for example `GET /api/profile`, `POST /users/resume`
  *
  * A Microservice Controller responds to requests as well as events, running over
  * a variety of transports [(read more here)](https://docs.nestjs.com/microservices/basics).
@@ -128,11 +136,15 @@ export function Controller(options: ControllerOptions): ClassDecorator;
  * more details.
  * - `prefix` - string that defines a `route path prefix`.  The prefix
  * is pre-pended to the path specified in any request decorator in the class.
+ * - `version` - string, array of strings, or Symbol that defines the version
+ * of all routes in the class. [See Versioning](https://docs.nestjs.com/techniques/versioning)
+ * for more details.
  *
  * @see [Routing](https://docs.nestjs.com/controllers#routing)
  * @see [Controllers](https://docs.nestjs.com/controllers)
  * @see [Microservices](https://docs.nestjs.com/microservices/basics#request-response)
  * @see [Scope](https://docs.nestjs.com/fundamentals/injection-scopes#usage)
+ * @see [Versioning](https://docs.nestjs.com/techniques/versioning)
  *
  * @publicApi
  */
@@ -141,19 +153,23 @@ export function Controller(
 ): ClassDecorator {
   const defaultPath = '/';
 
-  const [path, host, scopeOptions] = isUndefined(prefixOrOptions)
-    ? [defaultPath, undefined, undefined]
+  const [path, host, scopeOptions, versionOptions] = isUndefined(
+    prefixOrOptions,
+  )
+    ? [defaultPath, undefined, undefined, undefined]
     : isString(prefixOrOptions) || Array.isArray(prefixOrOptions)
-    ? [prefixOrOptions, undefined, undefined]
+    ? [prefixOrOptions, undefined, undefined, undefined]
     : [
         prefixOrOptions.path || defaultPath,
         prefixOrOptions.host,
         { scope: prefixOrOptions.scope },
+        prefixOrOptions.version,
       ];
 
   return (target: object) => {
     Reflect.defineMetadata(PATH_METADATA, path, target);
     Reflect.defineMetadata(HOST_METADATA, host, target);
     Reflect.defineMetadata(SCOPE_OPTIONS_METADATA, scopeOptions, target);
+    Reflect.defineMetadata(VERSION_METADATA, versionOptions, target);
   };
 }

packages/common/decorators/core/index.ts

@@ -11,3 +11,4 @@ export * from './use-guards.decorator';
 export * from './use-interceptors.decorator';
 export * from './use-pipes.decorator';
 export * from './apply-decorators';
+export * from './version.decorator';

packages/common/decorators/core/inject.decorator.ts

@@ -2,7 +2,7 @@ import {
   PROPERTY_DEPS_METADATA,
   SELF_DECLARED_DEPS_METADATA,
 } from '../../constants';
-import { isFunction, isUndefined } from '../../utils/shared.utils';
+import { isUndefined } from '../../utils/shared.utils';
 
 /**
  * Decorator that marks a constructor parameter as a target for
@@ -35,9 +35,7 @@ import { isFunction, isUndefined } from '../../utils/shared.utils';
  */
 export function Inject<T = any>(token?: T) {
   return (target: object, key: string | symbol, index?: number) => {
-    token = token || Reflect.getMetadata('design:type', target, key);
-    const type =
-      token && isFunction(token) ? ((token as any) as Function).name : token;
+    const type = token || Reflect.getMetadata('design:type', target, key);
 
     if (!isUndefined(index)) {
       let dependencies =

packages/common/decorators/core/injectable.decorator.ts

@@ -46,7 +46,7 @@ export function Injectable(options?: InjectableOptions): ClassDecorator {
   };
 }
 
-export function mixin(mixinClass: Type<any>) {
+export function mixin<T>(mixinClass: Type<T>) {
   Object.defineProperty(mixinClass, 'name', {
     value: uuid(),
   });

packages/common/decorators/core/version.decorator.ts

@@ -0,0 +1,18 @@
+import { VERSION_METADATA } from '../../constants';
+import { VersionValue } from '../../interfaces/version-options.interface';
+
+/**
+ * Sets the version of the endpoint to the passed version
+ *
+ * @publicApi
+ */
+export function Version(version: VersionValue): MethodDecorator {
+  return (
+    target: any,
+    key: string | symbol,
+    descriptor: TypedPropertyDescriptor<any>,
+  ) => {
+    Reflect.defineMetadata(VERSION_METADATA, version, descriptor.value);
+    return descriptor;
+  };
+}

packages/common/decorators/http/route-params.decorator.ts

@@ -167,7 +167,7 @@ export const Session: () => ParameterDecorator = createRouteParamDecorator(
  * Route handler parameter decorator. Extracts the `file` object
  * and populates the decorated parameter with the value of `file`.
  * Used in conjunction with
- * [multer middleware](https://github.com/expressjs/multer).
+ * [multer middleware](https://github.com/expressjs/multer) for Express-based applications.
  *
  * For example:
  * ```typescript
@@ -179,15 +179,78 @@ export const Session: () => ParameterDecorator = createRouteParamDecorator(
  *
  * @publicApi
  */
-export const UploadedFile: (
+export function UploadedFile(): ParameterDecorator;
+/**
+ * Route handler parameter decorator. Extracts the `file` object
+ * and populates the decorated parameter with the value of `file`.
+ * Used in conjunction with
+ * [multer middleware](https://github.com/expressjs/multer) for Express-based applications.
+ *
+ * For example:
+ * ```typescript
+ * uploadFile(@UploadedFile() file) {
+ *   console.log(file);
+ * }
+ * ```
+ * @see [Request object](https://docs.nestjs.com/techniques/file-upload)
+ *
+ * @publicApi
+ */
+export function UploadedFile(
+  ...pipes: (Type<PipeTransform> | PipeTransform)[]
+): ParameterDecorator;
+
+/**
+ * Route handler parameter decorator. Extracts the `file` object
+ * and populates the decorated parameter with the value of `file`.
+ * Used in conjunction with
+ * [multer middleware](https://github.com/expressjs/multer) for Express-based applications.
+ *
+ * For example:
+ * ```typescript
+ * uploadFile(@UploadedFile() file) {
+ *   console.log(file);
+ * }
+ * ```
+ * @see [Request object](https://docs.nestjs.com/techniques/file-upload)
+ *
+ * @publicApi
+ */
+export function UploadedFile(
   fileKey?: string,
-) => ParameterDecorator = createRouteParamDecorator(RouteParamtypes.FILE);
+  ...pipes: (Type<PipeTransform> | PipeTransform)[]
+): ParameterDecorator;
+/**
+ * Route handler parameter decorator. Extracts the `file` object
+ * and populates the decorated parameter with the value of `file`.
+ * Used in conjunction with
+ * [multer middleware](https://github.com/expressjs/multer) for Express-based applications.
+ *
+ * For example:
+ * ```typescript
+ * uploadFile(@UploadedFile() file) {
+ *   console.log(file);
+ * }
+ * ```
+ * @see [Request object](https://docs.nestjs.com/techniques/file-upload)
+ *
+ * @publicApi
+ */
+export function UploadedFile(
+  fileKey?: string | (Type<PipeTransform> | PipeTransform),
+  ...pipes: (Type<PipeTransform> | PipeTransform)[]
+): ParameterDecorator {
+  return createPipesRouteParamDecorator(RouteParamtypes.FILE)(
+    fileKey,
+    ...pipes,
+  );
+}
 
 /**
  * Route handler parameter decorator. Extracts the `files` object
  * and populates the decorated parameter with the value of `files`.
  * Used in conjunction with
- * [multer middleware](https://github.com/expressjs/multer).
+ * [multer middleware](https://github.com/expressjs/multer) for Express-based applications.
  *
  * For example:
  * ```typescript
@@ -199,9 +262,51 @@ export const UploadedFile: (
  *
  * @publicApi
  */
-export const UploadedFiles: () => ParameterDecorator = createRouteParamDecorator(
-  RouteParamtypes.FILES,
-);
+export function UploadedFiles(): ParameterDecorator;
+/**
+ * Route handler parameter decorator. Extracts the `files` object
+ * and populates the decorated parameter with the value of `files`.
+ * Used in conjunction with
+ * [multer middleware](https://github.com/expressjs/multer) for Express-based applications.
+ *
+ * For example:
+ * ```typescript
+ * uploadFile(@UploadedFiles() files) {
+ *   console.log(files);
+ * }
+ * ```
+ * @see [Request object](https://docs.nestjs.com/techniques/file-upload)
+ *
+ * @publicApi
+ */
+export function UploadedFiles(
+  ...pipes: (Type<PipeTransform> | PipeTransform)[]
+): ParameterDecorator;
+/**
+ * Route handler parameter decorator. Extracts the `files` object
+ * and populates the decorated parameter with the value of `files`.
+ * Used in conjunction with
+ * [multer middleware](https://github.com/expressjs/multer) for Express-based applications.
+ *
+ * For example:
+ * ```typescript
+ * uploadFile(@UploadedFiles() files) {
+ *   console.log(files);
+ * }
+ * ```
+ * @see [Request object](https://docs.nestjs.com/techniques/file-upload)
+ *
+ * @publicApi
+ */
+export function UploadedFiles(
+  ...pipes: (Type<PipeTransform> | PipeTransform)[]
+): ParameterDecorator {
+  return createPipesRouteParamDecorator(RouteParamtypes.FILES)(
+    undefined,
+    ...pipes,
+  );
+}
+
 /**
  * Route handler parameter decorator. Extracts the `headers`
  * property from the `req` object and populates the decorated
@@ -316,7 +421,7 @@ export function Query(
  *
  * For example:
  * ```typescript
- * async create(@Body() cat: CreateCatDto)
+ * async create(@Body() createDto: CreateCatDto)
  * ```
  *
  * @see [Request object](https://docs.nestjs.com/controllers#request-object)
@@ -333,7 +438,7 @@ export function Body(): ParameterDecorator;
  *
  * For example:
  * ```typescript
- * async create(@Body(new ValidationPipe()) cat: CreateCatDto)
+ * async create(@Body(new ValidationPipe()) createDto: CreateCatDto)
  * ```
  *
  * @param pipes one or more pipes - either instances or classes - to apply to

packages/common/enums/index.ts

@@ -1,3 +1,4 @@
 export * from './request-method.enum';
 export * from './http-status.enum';
 export * from './shutdown-signal.enum';
+export * from './version-type.enum';

packages/common/enums/version-type.enum.ts

@@ -0,0 +1,8 @@
+/**
+ * @publicApi
+ */
+export enum VersioningType {
+  URI,
+  HEADER,
+  MEDIA_TYPE,
+}

packages/common/exceptions/http.exception.ts

@@ -40,6 +40,7 @@ export class HttpException extends Error {
   ) {
     super();
     this.initMessage();
+    this.initName();
   }
 
   public initMessage() {
@@ -57,6 +58,10 @@ export class HttpException extends Error {
     }
   }
 
+  public initName(): void {
+    this.name = this.constructor.name;
+  }
+
   public getResponse(): string | object {
     return this.response;
   }

packages/common/file-stream/index.ts

@@ -0,0 +1 @@
+export * from './streamable-file';

packages/common/file-stream/streamable-file.ts

@@ -0,0 +1,24 @@
+import { Readable } from 'stream';
+
+export class StreamableFile {
+  private readonly stream: Readable;
+
+  constructor(buffer: Buffer);
+  constructor(readable: Readable);
+  constructor(bufferOrReadStream: Buffer | Readable) {
+    if (Buffer.isBuffer(bufferOrReadStream)) {
+      this.stream = new Readable();
+      this.stream.push(bufferOrReadStream);
+      this.stream.push(null);
+    } else if (
+      bufferOrReadStream.pipe &&
+      typeof bufferOrReadStream.pipe === 'function'
+    ) {
+      this.stream = bufferOrReadStream;
+    }
+  }
+
+  getStream(): Readable {
+    return this.stream;
+  }
+}

packages/common/http/http.module.ts

@@ -14,6 +14,9 @@ import {
   HttpModuleOptionsFactory,
 } from './interfaces';
 
+/**
+ * @deprecated "HttpModule" (from the "@nestjs/common" package) is deprecated and will be removed in the next major release. Please, use the "@nestjs/axios" package instead.
+ */
 @Module({
   providers: [
     HttpService,

packages/common/http/http.service.ts

@@ -7,13 +7,23 @@ import Axios, {
 } from 'axios';
 import { Observable } from 'rxjs';
 import { Inject } from '../decorators';
+import { Logger } from '../services';
 import { AXIOS_INSTANCE_TOKEN } from './http.constants';
 
+/**
+ * @deprecated "HttpModule" (from the "@nestjs/common" package) is deprecated and will be removed in the next major release. Please, use the "@nestjs/axios" package instead.
+ */
 export class HttpService {
+  private readonly logger = new Logger(HttpService.name);
+
   constructor(
     @Inject(AXIOS_INSTANCE_TOKEN)
     private readonly instance: AxiosInstance = Axios,
-  ) {}
+  ) {
+    this.logger.warn(
+      'DEPRECATED! "HttpModule" (from the "@nestjs/common" package) is deprecated and will be removed in the next major release. Please, use the "@nestjs/axios" package instead.',
+    );
+  }
 
   request<T = any>(config: AxiosRequestConfig): Observable<AxiosResponse<T>> {
     return this.makeObservable<T>(this.instance.request, config);