style(): auto-organise import statements

feat: timestemp inside LoggerSerivce can be overridden

.circleci/config.yml

@@ -70,10 +70,10 @@ jobs:
     docker:
       - image: circleci/node:10
 
-  test_node_8:
+  test_node_14:
     <<: *unit-tests-template
     docker:
-      - image: circleci/node:8
+      - image: circleci/node:14
 
   lint:
     working_directory: ~/nest
@@ -160,15 +160,15 @@ workflows:
   build-and-test:
     jobs:
       - build
+      - test_node_14:
+          requires:
+            - build
       - test_node_12:
           requires:
             - build
       - test_node_10:
           requires:
             - build
-      - test_node_8:
-          requires:
-            - build
       - lint:
           requires:
             - build

.eslintrc.js

@@ -19,6 +19,8 @@ module.exports = {
     '@typescript-eslint/interface-name-prefix': 'off',
     '@typescript-eslint/explicit-function-return-type': 'off',
     '@typescript-eslint/no-explicit-any': 'off',
+    '@typescript-eslint/explicit-module-boundary-types': 'off',
     '@typescript-eslint/no-unused-vars': 'off',
+    '@typescript-eslint/ban-types': 'off',
   },
 };

.github/dependabot.yml

@@ -0,0 +1,7 @@
+version: 2
+updates:
+- package-ecosystem: npm
+  directory: "/"
+  schedule:
+    interval: daily
+  open-pull-requests-limit: 10

.github/workflows/codeql-analysis.yml

@@ -0,0 +1,54 @@
+name: "CodeQL"
+
+on:
+  push:
+    branches: [master, ]
+  pull_request:
+    # The branches below must be a subset of the branches above
+    branches: [master]
+  schedule:
+    - cron: '0 17 * * 4'
+
+jobs:
+  analyse:
+    name: Analyse
+    runs-on: ubuntu-latest
+
+    steps:
+    - name: Checkout repository
+      uses: actions/checkout@v2
+      with:
+        # We must fetch at least the immediate parents so that if this is
+        # a pull request then we can checkout the head.
+        fetch-depth: 2
+
+    # If this run was triggered by a pull request event, then checkout
+    # the head of the pull request instead of the merge commit.
+    - run: git checkout HEAD^2
+      if: ${{ github.event_name == 'pull_request' }}
+
+    # Initializes the CodeQL tools for scanning.
+    - name: Initialize CodeQL
+      uses: github/codeql-action/init@v1
+      # Override language selection by uncommenting this and choosing your languages
+      # with:
+      #   languages: go, javascript, csharp, python, cpp, java
+
+    # Autobuild attempts to build any compiled languages  (C/C++, C#, or Java).
+    # If this step fails, then you should remove it and run the build manually (see below)
+    - name: Autobuild
+      uses: github/codeql-action/autobuild@v1
+
+    # ℹ️ Command-line programs to run using the OS shell.
+    # 📚 https://git.io/JvXDl
+
+    # ✏️ If the Autobuild fails above, remove it and uncomment the following three lines
+    #    and modify them (or add more) to build your code if your project
+    #    uses a compiled language
+
+    #- run: |
+    #   make bootstrap
+    #   make release
+
+    - name: Perform CodeQL Analysis
+      uses: github/codeql-action/analyze@v1

CONTRIBUTING.md

@@ -237,7 +237,7 @@ Samples: (even more [samples](https://github.com/nestjs/nest/commits/master))
 
 ```
 docs(changelog): update change log to beta.5
-bugfix(core): need to depend on latest rxjs and zone.js
+fix(core): need to depend on latest rxjs and zone.js
 ```
 
 ### Revert
@@ -249,14 +249,16 @@ If the commit reverts a previous commit, it should begin with `revert:`, followe
 Must be one of the following:
 
 - **build**: Changes that affect the build system or external dependencies (example scopes: gulp, broccoli, npm)
+- **chore**: Updating tasks etc; no production code change
 - **ci**: Changes to our CI configuration files and scripts (example scopes: Travis, Circle, BrowserStack, SauceLabs)
 - **docs**: Documentation only changes
-- **feature**: A new feature
+- **feat**: A new feature
 - **fix**: A bug fix
 - **perf**: A code change that improves performance
 - **refactor**: A code change that neither fixes a bug nor adds a feature
 - **style**: Changes that do not affect the meaning of the code (white-space, formatting, missing semi-colons, etc)
 - **test**: Adding missing tests or correcting existing tests
+- **sample**: A change to the samples
 
 ### Scope
 

LICENSE

@@ -1,6 +1,6 @@
 (The MIT License)
 
-Copyright (c) 2017-2019 Kamil Myśliwiec <http://kamilmysliwiec.com>
+Copyright (c) 2017-2020 Kamil Mysliwiec <https://kamilmysliwiec.com>
 
 Permission is hereby granted, free of charge, to any person obtaining
 a copy of this software and associated documentation files (the

Readme.md

@@ -38,6 +38,14 @@ 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:
 
+## Questions
+
+For questions and support please use the official [Discord channel](https://discord.gg/G7Qnnhy). The issue list of this repo is **exclusively** for bug reports and feature requests.
+
+## Issues
+
+Please make sure to read the [Issue Reporting Checklist](https://github.com/nestjs/nest/blob/master/CONTRIBUTING.md#-submitting-an-issue) before opening an issue. Issues not conforming to the guidelines may be closed immediately.
+
 ## Consulting
 
 With official support, you can get expert help straight from Nest core team. We provide dedicated technical support, migration strategies, advice on best practices (and design decisions), PR reviews, and team augmentation. Read more about [support here](https://enterprise.nestjs.com).
@@ -46,32 +54,43 @@ With official support, you can get expert help straight from Nest core team. We
 
 Nest is an MIT-licensed open source project. It can grow thanks to the sponsors and support by the amazing backers. If you'd like to join them, please [read more here](https://docs.nestjs.com/support).
 
-#### Principal Sponsor
-
-<a href="https://valor-software.com/" target="_blank"><img src="https://docs.nestjs.com/assets/sponsors/valor-software.png" width="320" /></a>
+#### Principal Sponsors
+<table style="text-align:center;"><tr><td>
+<a href="https://github.com/Sanofi-IADC" target="_blank"><img src="https://docs.nestjs.com/assets/sponsors/sanofi.png" width="180" 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="180" valign="middle" /></a></td>
+</tr></table>
 
 #### Silver Sponsors
-<a href="https://neoteric.eu/" target="_blank"><img src="https://nestjs.com/img/neoteric-cut.png" width="120" valign="middle" /></a> &nbsp;
-  <a href="http://gojob.com" target="_blank"><img src="http://nestjs.com/img/gojob-logo.png" valign="middle" height="95" /></a> &nbsp; 
-    <a href="https://trilon.io" target="_blank"><img src="https://nestjs.com/img/trilon.svg" width="150" valign="middle" /></a> &nbsp;
-<a href="http://www.leogistics.com" target="_blank"><img src="https://nestjs.com/img/leogistics-logo.jpeg" width="150" valign="middle" /></a>
+
+<table style="text-align:center;"><tr><td>
+<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="https://trilon.io" target="_blank"><img src="https://nestjs.com/img/trilon.svg" width="170" valign="middle" /></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>
 
 #### Sponsors
 
-<a href="https://www.swingdev.io" target="_blank"><img src="https://nestjs.com/img/swingdev-logo.svg#1" width="110" valign="middle" /> </a> &nbsp; <a href="https://blueanchor.io/" target="_blank"><img src="https://nestjs.com/img/blueanchor.png" width="150" valign="middle" /></a> &nbsp;
-<a href="https://www.novologic.com/" target="_blank"><img src="https://nestjs.com/img/novologic.png" width="110" valign="middle" /></a> &nbsp; <a href="https://hostpresto.com" target="_blank"><img src="https://nestjs.com/img/hostpresto.png" height="24" valign="middle" /></a>
-<a href="https://ever.co/" target="_blank"><img src="https://nestjs.com/img/ever-logo.png" height="14" valign="middle" /></a>  &nbsp; 
-<a href="https://buddy.works/" target="_blank"><img src="https://nestjs.com/img/buddy-logo.svg" height="25" valign="middle" /></a> &nbsp;
-<a href="https://blokt.com" target="_blank"><img src="https://nestjs.com/img/blokt-logo.png" height="25" valign="middle" /></a>  &nbsp;  <a href="https://genuinebee.com/" target="_blank"><img src="https://nestjs.com/img/genuinebee.svg" height="27" valign="middle" /></a> &nbsp; <a href="http://architectnow.net/" target="_blank"><img src="https://nestjs.com/img/architectnow.png" height="20" valign="middle" /></a> &nbsp; <a href="https://quander.io/" target="_blank"><img src="https://nestjs.com/img/quander.png" height="22" valign="middle" /></a> &nbsp; <a href="https://mantro.net/" target="_blank"><img src="https://nestjs.com/img/mantro-logo.svg" height="19" valign="middle" /></a> &nbsp; <a href="https://triplebyte.com/" target="_blank"><img src="https://nestjs.com/img/triplebyte.png" height="20" valign="middle" /></a> &nbsp; 
-<a href="https://reposit.co.uk/" target="_blank"><img src="https://nestjs.com/img/reposit-logo.png" height="18" valign="middle" /></a> &nbsp; &nbsp;
-<a href="https://nearpod.com/" target="_blank"><img src="https://nestjs.com/img/nearpod-logo.svg" width="100" valign="middle" /></a> &nbsp;
-<a href="https://clay.global/" target="_blank"><img src="https://nestjs.com/img/clay-logo.svg" width="75" valign="middle" /></a> &nbsp;
-<a href="https://firesticktricks.com" target="_blank"><img src="https://nestjs.com/img/firesticktricks-logo.png" width="120" valign="middle" /></a> &nbsp;
-<a href="https://www.codeguesser.co.uk" target="_blank"><img src="https://nestjs.com/img/codeguesser-logo.svg" width="120" valign="middle" /></a> &nbsp;
-<a href="https://tekhattan.com" target="_blank"><img src="https://nestjs.com/img/tekhattan-logo.png" width="110" valign="middle" /></a> &nbsp;
-<a href="https://f-a.nz/" target="_blank"><img src="https://nestjs.com/img/franz.svg" width="80" valign="middle" /></a> &nbsp;
-<a href="https://sparkfabrik.com/" target="_blank"><img src="https://nestjs.com/img/sparkfabrik-logo.png" width="120" valign="middle" /></a>
-
+<table><tr><td align="center" valign="middle">
+<a href="https://www.swingdev.io" target="_blank"><img src="https://nestjs.com/img/swingdev-logo.svg#1" width="110" valign="middle" /> </a></td><td align="center" valign="middle">
+<a href="https://www.novologic.com/" target="_blank"><img src="https://nestjs.com/img/novologic.png" width="110" valign="middle" /></a> </td><td align="center" valign="middle">
+<a href="https://ever.co/" target="_blank"><img src="https://nestjs.com/img/ever-logo.png" width="72" valign="middle" /></a>  </td><td align="center" valign="middle">
+<a href="https://blokt.com" target="_blank"><img src="https://nestjs.com/img/blokt-logo.png" width="120" valign="middle" /></a>  </td><td align="center" valign="middle"> 
+  <a href="http://architectnow.net/" target="_blank"><img src="https://nestjs.com/img/architectnow.png" width="125" valign="middle" /></a> </td><td align="center" valign="middle">
+  <a href="https://quander.io/" target="_blank"><img src="https://nestjs.com/img/quander.png" width="100" valign="middle" /></a> </td></tr><tr><td align="center" valign="middle">
+  <a href="https://mantro.net/" target="_blank"><img src="https://nestjs.com/img/mantro-logo.svg" width="95" valign="middle" /></a> </td><td align="center" valign="middle">
+  <a href="https://triplebyte.com/" target="_blank"><img src="https://nestjs.com/img/triplebyte.png" width="107" valign="middle" /></a> </td><td align="center" valign="middle">
+<a href="https://reposit.co.uk/" target="_blank"><img src="https://nestjs.com/img/reposit-logo.png" width="71" valign="middle" /></a></td><td align="center" valign="middle">
+<a href="https://nearpod.com/" target="_blank"><img src="https://nestjs.com/img/nearpod-logo.svg" width="100" valign="middle" /></a> </td><td align="center" valign="middle">
+<a href="https://clay.global/" target="_blank"><img src="https://nestjs.com/img/clay-logo.svg" width="75" valign="middle" /></a> </td><td align="center" valign="middle">
+<a href="https://firesticktricks.com" target="_blank"><img src="https://nestjs.com/img/firesticktricks-logo.png" width="120" valign="middle" /></a></td></tr><tr><td align="center" valign="middle">
+<a href="https://www.codeguesser.co.uk" target="_blank"><img src="https://nestjs.com/img/codeguesser-logo.svg" width="120" valign="middle" /></a> </td><td align="center" valign="middle">
+<a href="https://f-a.nz/" target="_blank"><img src="https://nestjs.com/img/franz.svg" width="80" valign="middle" /></a> </td><td align="center" valign="middle">
+<a href="https://sparkfabrik.com/" target="_blank"><img src="https://nestjs.com/img/sparkfabrik-logo.png" width="120" valign="middle" /></a></td><td align="center" valign="middle"><a href="https://www.thebigphonestore.co.uk/" target="_blank"><img src="https://nestjs.com/img/the-big-phone-store-logo.png" width="65" valign="middle" /></a></td>
+  <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>
+  </tr></table>
 
 ## Backers
 

integration/docker-compose.yml

@@ -23,7 +23,7 @@ services:
       - "9001:9001"
     restart: always
   mysql:
-    image: mysql:5.7.29
+    image: mysql:5.7.32
     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.3.2
+    image: confluentinc/cp-zookeeper:5.5.2
     ports:
       - "2181:2181"
     environment:
@@ -57,7 +57,7 @@ services:
   kafka:
     container_name: test-kafka
     hostname: kafka
-    image: confluentinc/cp-kafka:5.3.2
+    image: confluentinc/cp-kafka:5.5.2
     depends_on:
       - zookeeper
     ports:

integration/graphql-code-first/schema.gql

@@ -2,9 +2,22 @@
 # THIS FILE WAS AUTOMATICALLY GENERATED (DO NOT MODIFY)
 # ------------------------------------------------------
 
+type Recipe {
+  id: ID!
+  title: String!
+  description: String
+  creationDate: Date!
+  ingredients: [String!]!
+}
+
 """Date custom scalar type"""
 scalar Date
 
+type Query {
+  recipe(id: String!): Recipe!
+  recipes(skip: Int = 0, take: Int = 25): [Recipe!]!
+}
+
 type Mutation {
   addRecipe(newRecipeData: NewRecipeInput!): Recipe!
   removeRecipe(id: String!): Boolean!
@@ -16,19 +29,6 @@ input NewRecipeInput {
   ingredients: [String!]!
 }
 
-type Query {
-  recipe(id: String!): Recipe!
-  recipes(skip: Int = 0, take: Int = 25): [Recipe!]!
-}
-
-type Recipe {
-  id: ID!
-  title: String!
-  description: String
-  creationDate: Date!
-  ingredients: [String!]!
-}
-
 type Subscription {
   recipeAdded: Recipe!
 }

integration/hello-world/e2e/fastify-adapter.spec.ts

@@ -3,7 +3,6 @@ import {
   NestFastifyApplication,
 } from '@nestjs/platform-fastify';
 import { Test } from '@nestjs/testing';
-import { fail } from 'assert';
 import { expect } from 'chai';
 import { ApplicationModule } from '../src/app.module';
 
@@ -54,19 +53,22 @@ describe('Hello world (fastify adapter)', () => {
         method: 'GET',
         url: '/host',
       })
-      .then(
-        ({ payload }) => {
-          fail(`Unexpected success: ${payload}`);
-        },
-        err => {
-          expect(err.getResponse()).to.be.eql({
-            error: 'Internal Server Error',
-            message:
-              'HTTP adapter does not support filtering on host: ":tenant.example.com"',
-            statusCode: 500,
-          });
-        },
-      );
+      .then(({ payload }) => {
+        expect(JSON.parse(payload)).to.be.eql({
+          error: 'Internal Server Error',
+          message:
+            'HTTP adapter does not support filtering on host: ":tenant.example.com"',
+          statusCode: 500,
+        });
+      });
+  });
+
+  it(`/GET inject with LightMyRequest chaining API`, () => {
+    return app
+      .inject()
+      .get('/hello')
+      .end()
+      .then(({ payload }) => expect(payload).to.be.eql('Hello world!'));
   });
 
   afterEach(async () => {

integration/hello-world/e2e/middleware-fastify.spec.ts

@@ -19,7 +19,6 @@ class TestController {
   }
 
   @Get('tests/wildcard_nested')
-  // eslint-disable-next-line @typescript-eslint/camelcase
   wildcard_nested() {
     return RETURN_VALUE;
   }

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

@@ -21,7 +21,6 @@ class TestController {
   }
 
   @Get('tests/wildcard_nested')
-  // eslint-disable-next-line @typescript-eslint/camelcase
   wildcard_nested() {
     return RETURN_VALUE;
   }

integration/injector/e2e/introspection.spec.ts

@@ -0,0 +1,34 @@
+import { Scope } from '@nestjs/common';
+import { ModuleRef } from '@nestjs/core';
+import { Test, TestingModule } from '@nestjs/testing';
+import { expect } from 'chai';
+import { ScopedModule, STATIC_FACTORY } from '../src/scoped/scoped.module';
+import { ScopedService } from '../src/scoped/scoped.service';
+import { TransientService } from '../src/scoped/transient.service';
+
+describe('Providers introspection', () => {
+  let testingModule: TestingModule;
+  let moduleRef: ModuleRef;
+
+  beforeEach(async () => {
+    testingModule = await Test.createTestingModule({
+      imports: [ScopedModule],
+    }).compile();
+    moduleRef = testingModule.get(ModuleRef);
+  });
+
+  it('should properly introspect a transient provider', async () => {
+    const introspectionResult = moduleRef.introspect(TransientService);
+    expect(introspectionResult.scope).to.be.equal(Scope.TRANSIENT);
+  });
+
+  it('should properly introspect a singleton provider', async () => {
+    const introspectionResult = moduleRef.introspect(STATIC_FACTORY);
+    expect(introspectionResult.scope).to.be.equal(Scope.DEFAULT);
+  });
+
+  it('should properly introspect a request-scoped provider', async () => {
+    const introspectionResult = moduleRef.introspect(ScopedService);
+    expect(introspectionResult.scope).to.be.equal(Scope.REQUEST);
+  });
+});

integration/injector/e2e/scoped-instances.spec.ts

@@ -3,9 +3,15 @@ import { InvalidClassScopeException } from '@nestjs/core/errors/exceptions/inval
 import { Test, TestingModule } from '@nestjs/testing';
 import { expect } from 'chai';
 import { ScopedController } from '../src/scoped/scoped.controller';
-import { ScopedModule } from '../src/scoped/scoped.module';
+import {
+  REQUEST_SCOPED_FACTORY,
+  ScopedModule,
+  STATIC_FACTORY,
+  TRANSIENT_SCOPED_FACTORY,
+} from '../src/scoped/scoped.module';
 import { ScopedService } from '../src/scoped/scoped.service';
 import { TransientService } from '../src/scoped/transient.service';
+import { Transient3Service } from '../src/scoped/transient3.service';
 
 describe('Scoped Instances', () => {
   let testingModule: TestingModule;
@@ -20,20 +26,47 @@ describe('Scoped Instances', () => {
     const contextId = createContextId();
     const transient1 = await testingModule.resolve(TransientService, contextId);
     const transient2 = await testingModule.resolve(TransientService, contextId);
+    const transientFactory = await testingModule.resolve(
+      TRANSIENT_SCOPED_FACTORY,
+    );
 
     expect(transient1).to.be.instanceOf(TransientService);
     expect(transient2).to.be.instanceOf(TransientService);
     expect(transient1).to.be.equal(transient2);
+    expect(transientFactory).to.be.true;
+  });
+
+  it('should dynamically resolve nested transient provider', async () => {
+    const contextId = createContextId();
+    const transientTwoDepthLevel = await testingModule.resolve(
+      TransientService,
+      contextId,
+    );
+    const transientThreeDepthLevel = await testingModule.resolve(
+      Transient3Service,
+      contextId,
+    );
+
+    expect(transientTwoDepthLevel.svc.logger).to.not.be.undefined;
+    expect(transientThreeDepthLevel.svc.svc.logger).to.not.be.undefined;
   });
 
   it('should dynamically resolve request-scoped provider', async () => {
     const request1 = await testingModule.resolve(ScopedService);
     const request2 = await testingModule.resolve(ScopedService);
-    const request3 = await testingModule.resolve(ScopedService, { id: 1 });
+
+    const ctxId = { id: 1 };
+    const requestProvider = { host: 'localhost' };
+    testingModule.registerRequestByContextId(requestProvider, ctxId);
+
+    const request3 = await testingModule.resolve(ScopedService, ctxId);
+    const requestFactory = await testingModule.resolve(REQUEST_SCOPED_FACTORY);
 
     expect(request1).to.be.instanceOf(ScopedService);
     expect(request2).to.be.instanceOf(ScopedService);
     expect(request3).to.not.be.equal(request2);
+    expect(requestFactory).to.be.true;
+    expect(request3.request).to.be.equal(requestProvider);
   });
 
   it('should dynamically resolve request-scoped controller', async () => {
@@ -46,11 +79,19 @@ describe('Scoped Instances', () => {
     expect(request3).to.not.be.equal(request2);
   });
 
-  it('should throw an exception when "get()" method is used', async () => {
+  it('should throw an exception when "get()" method is used for scoped providers', () => {
     try {
       testingModule.get(ScopedController);
     } catch (err) {
       expect(err).to.be.instanceOf(InvalidClassScopeException);
     }
   });
+
+  it('should throw an exception when "resolve()" method is used for static providers', async () => {
+    try {
+      await testingModule.resolve(STATIC_FACTORY);
+    } catch (err) {
+      expect(err).to.be.instanceOf(InvalidClassScopeException);
+    }
+  });
 });

integration/injector/src/scoped/scoped.module.ts

@@ -1,11 +1,35 @@
-import { Module } from '@nestjs/common';
+import { Module, Scope } from '@nestjs/common';
 import { ScopedController } from './scoped.controller';
 import { ScopedService } from './scoped.service';
 import { TransientService } from './transient.service';
 import { Transient2Service } from './transient2.service';
+import { Transient3Service } from './transient3.service';
+
+export const STATIC_FACTORY = 'STATIC_FACTORY';
+export const REQUEST_SCOPED_FACTORY = 'REQUEST_SCOPED_FACTORY';
+export const TRANSIENT_SCOPED_FACTORY = 'TRANSIENT_SCOPED_FACTORY';
 
 @Module({
   controllers: [ScopedController],
-  providers: [ScopedService, TransientService, Transient2Service],
+  providers: [
+    ScopedService,
+    TransientService,
+    Transient2Service,
+    Transient3Service,
+    {
+      provide: STATIC_FACTORY,
+      useFactory: () => true,
+    },
+    {
+      provide: REQUEST_SCOPED_FACTORY,
+      useFactory: () => true,
+      scope: Scope.REQUEST,
+    },
+    {
+      provide: TRANSIENT_SCOPED_FACTORY,
+      useFactory: () => true,
+      scope: Scope.TRANSIENT,
+    },
+  ],
 })
 export class ScopedModule {}

integration/injector/src/scoped/scoped.service.ts

@@ -1,4 +1,7 @@
-import { Injectable, Scope } from '@nestjs/common';
+import { Inject, Injectable, Scope } from '@nestjs/common';
+import { REQUEST } from '@nestjs/core';
 
 @Injectable({ scope: Scope.REQUEST })
-export class ScopedService {}
+export class ScopedService {
+  constructor(@Inject(REQUEST) public readonly request) {}
+}

integration/injector/src/scoped/transient.service.ts

@@ -3,5 +3,5 @@ import { Transient2Service } from './transient2.service';
 
 @Injectable({ scope: Scope.TRANSIENT })
 export class TransientService {
-  constructor(private readonly svc: Transient2Service) {}
+  constructor(public readonly svc: Transient2Service) {}
 }

integration/injector/src/scoped/transient2.service.ts

@@ -1,4 +1,6 @@
-import { Injectable, Scope } from '@nestjs/common';
+import { Injectable, Logger, Scope } from '@nestjs/common';
 
 @Injectable({ scope: Scope.TRANSIENT })
-export class Transient2Service {}
+export class Transient2Service {
+  logger = new Logger();
+}

integration/injector/src/scoped/transient3.service.ts

@@ -0,0 +1,7 @@
+import { Injectable, Scope } from '@nestjs/common';
+import { TransientService } from './transient.service';
+
+@Injectable({ scope: Scope.TRANSIENT })
+export class Transient3Service {
+  constructor(public readonly svc: TransientService) {}
+}

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

@@ -113,6 +113,11 @@ describe('Advanced GRPC transport', () => {
   it('GRPC Sending and receiving Stream from RX handler', async () => {
     const callHandler = client.sync();
 
+    // Get Set-Cookie from Metadata
+    callHandler.on('metadata', (metadata: GRPC.Metadata) => {
+      expect(metadata.get('Set-Cookie')[0]).to.eq('test_cookie=abcd');
+    });
+
     callHandler.on('data', (msg: number) => {
       // Do deep comparison (to.eql)
       expect(msg).to.eql({

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

@@ -50,6 +50,20 @@ describe('RPC transport', () => {
       .expect(200, '15');
   });
 
+  it(`/POST (useFactory client)`, () => {
+    return request(server)
+      .post('/useFactory?command=sum')
+      .send([1, 2, 3, 4, 5])
+      .expect(200, '15');
+  });
+
+  it(`/POST (useClass client)`, () => {
+    return request(server)
+      .post('/useClass?command=sum')
+      .send([1, 2, 3, 4, 5])
+      .expect(200, '15');
+  });
+
   it(`/POST (concurrent)`, () => {
     return request(server)
       .post('/concurrent')

integration/microservices/src/app.controller.ts

@@ -1,4 +1,11 @@
-import { Body, Controller, HttpCode, Post, Query } from '@nestjs/common';
+import {
+  Body,
+  Controller,
+  HttpCode,
+  Inject,
+  Post,
+  Query,
+} from '@nestjs/common';
 import {
   Client,
   ClientProxy,
@@ -11,6 +18,10 @@ import { scan } from 'rxjs/operators';
 
 @Controller()
 export class AppController {
+  constructor(
+    @Inject('USE_CLASS_CLIENT') private useClassClient: ClientProxy,
+    @Inject('USE_FACTORY_CLIENT') private useFactoryClient: ClientProxy,
+  ) {}
   static IS_NOTIFIED = false;
 
   @Client({ transport: Transport.TCP })
@@ -22,6 +33,24 @@ export class AppController {
     return this.client.send<number>({ cmd }, data);
   }
 
+  @Post('useFactory')
+  @HttpCode(200)
+  callWithClientUseFactory(
+    @Query('command') cmd,
+    @Body() data: number[],
+  ): Observable<number> {
+    return this.useFactoryClient.send<number>({ cmd }, data);
+  }
+
+  @Post('useClass')
+  @HttpCode(200)
+  callWithClientUseClass(
+    @Query('command') cmd,
+    @Body() data: number[],
+  ): Observable<number> {
+    return this.useClassClient.send<number>({ cmd }, data);
+  }
+
   @Post('stream')
   @HttpCode(200)
   stream(@Body() data: number[]): Observable<number> {

integration/microservices/src/app.module.ts

@@ -1,7 +1,59 @@
-import { Module } from '@nestjs/common';
+import { Module, Injectable } from '@nestjs/common';
 import { AppController } from './app.controller';
+import {
+  ClientsModule,
+  Transport,
+  ClientsModuleOptionsFactory,
+  ClientOptions,
+} from '@nestjs/microservices';
+
+@Injectable()
+class ConfigService {
+  private readonly config = {
+    transport: Transport.TCP,
+  };
+  get(key: string) {
+    return this.config[key];
+  }
+}
 
 @Module({
+  providers: [ConfigService],
+  exports: [ConfigService],
+})
+class ConfigModule {}
+
+@Injectable()
+class ClientOptionService implements ClientsModuleOptionsFactory {
+  constructor(private readonly configService: ConfigService) {}
+  createClientOptions(): Promise<ClientOptions> | ClientOptions {
+    return {
+      transport: this.configService.get('transport'),
+      options: {},
+    };
+  }
+}
+
+@Module({
+  imports: [
+    ClientsModule.registerAsync([
+      {
+        imports: [ConfigModule],
+        name: 'USE_FACTORY_CLIENT',
+        useFactory: (configService: ConfigService) => ({
+          transport: configService.get('transport'),
+          options: {},
+        }),
+        inject: [ConfigService],
+      },
+      {
+        imports: [ConfigModule],
+        name: 'USE_CLASS_CLIENT',
+        useClass: ClientOptionService,
+        inject: [ConfigService],
+      },
+    ]),
+  ],
   controllers: [AppController],
 })
 export class ApplicationModule {}

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

@@ -9,6 +9,7 @@ import {
 } from '@nestjs/microservices';
 import { join } from 'path';
 import { Observable, of, ReplaySubject, Subject } from 'rxjs';
+import { Metadata } from 'grpc';
 
 @Controller()
 export class AdvancedGrpcController {
@@ -84,7 +85,16 @@ export class AdvancedGrpcController {
    * @param messages
    */
   @GrpcStreamMethod('orders.OrderService')
-  async sync(messages: Observable<any>): Promise<any> {
+  async sync(
+    messages: Observable<any>,
+    metadata: Metadata,
+    call: any,
+  ): Promise<any> {
+    // Set Set-Cookie from Metadata
+    const srvMetadata = new Metadata();
+    srvMetadata.add('Set-Cookie', 'test_cookie=abcd');
+    call.sendMetadata(srvMetadata);
+
     const s = new Subject();
     const o = s.asObservable();
     messages.subscribe(msg => {

integration/nest-application/app-locals/e2e/express.spec.ts

@@ -0,0 +1,38 @@
+import { NestExpressApplication } from '@nestjs/platform-express';
+import { Test, TestingModule } from '@nestjs/testing';
+import { expect } from 'chai';
+import * as request from 'supertest';
+import { AppModule } from '../src/app.module';
+
+describe('App-level globals (Express Application)', () => {
+  let moduleFixture: TestingModule;
+  let app: NestExpressApplication;
+
+  beforeEach(async () => {
+    moduleFixture = await Test.createTestingModule({
+      imports: [AppModule],
+    }).compile();
+  });
+
+  beforeEach(() => {
+    app = moduleFixture.createNestApplication<NestExpressApplication>();
+  });
+
+  it('should get "title" from "app.locals"', async () => {
+    app.setLocal('title', 'My Website');
+    await app.init();
+    const response = await request(app.getHttpServer()).get('/').expect(200);
+    expect(response.body.title).to.equal('My Website');
+  });
+
+  it('should get "email" from "app.locals"', async () => {
+    app.setLocal('email', 'admin@example.com');
+    await app.listen(4444);
+    const response = await request(app.getHttpServer()).get('/').expect(200);
+    expect(response.body.email).to.equal('admin@example.com');
+  });
+
+  afterEach(async () => {
+    await app.close();
+  });
+});

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

@@ -0,0 +1,10 @@
+import { Controller, Get, Req } from '@nestjs/common';
+import { Request } from 'express';
+
+@Controller()
+export class AppController {
+  @Get()
+  getGlobals(@Req() req: Request) {
+    return req.app.locals;
+  }
+}

integration/nest-application/app-locals/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/app-locals/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/get-url/e2e/express.spec.ts

@@ -37,6 +37,13 @@ describe('Get URL (Express Application)', () => {
     expect(await app.getUrl()).to.be.eql(`http://127.0.0.1:${port}`);
     await app.close();
   });
+  it('should return 127.0.0.1 even in a callback', () => {
+    const app = testModule.createNestApplication(new ExpressAdapter(express()));
+    return app.listen(port, async () => {
+      expect(await app.getUrl()).to.be.eql(`http://127.0.0.1:${port}`);
+      await app.close();
+    });
+  });
   it('should throw an error for calling getUrl before listen', async () => {
     const app = testModule.createNestApplication(new ExpressAdapter(express()));
     try {

integration/nest-application/get-url/e2e/fastify.spec.ts

@@ -30,6 +30,13 @@ describe('Get URL (Fastify Application)', () => {
     expect(await app.getUrl()).to.be.eql(`http://127.0.0.1:${port}`);
     await app.close();
   });
+  it('should return 127.0.0.1 even in a callback', () => {
+    const app = testModule.createNestApplication(new FastifyAdapter());
+    return app.listen(port, async () => {
+      expect(await app.getUrl()).to.be.eql(`http://127.0.0.1:${port}`);
+      await app.close();
+    });
+  });
   it('should throw an error for calling getUrl before listen', async () => {
     const app = testModule.createNestApplication(new FastifyAdapter());
     try {

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

@@ -28,5 +28,18 @@ describe('WebSocketGateway (ack)', () => {
     );
   });
 
+  it(`should handle message with ack & without data (http)`, async () => {
+    app = await createNestApp(AckGateway);
+    await app.listenAsync(3000);
+
+    ws = io.connect('http://localhost:8080');
+    await new Promise(resolve =>
+      ws.emit('push', data => {
+        expect(data).to.be.eql('pong');
+        resolve();
+      }),
+    );
+  });
+
   afterEach(() => app.close());
 });

lerna.json

@@ -3,5 +3,5 @@
   "packages": [
     "packages/*"
   ],
-  "version": "7.0.7"
+  "version": "7.5.5"
 }

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nestjs/core",
-  "version": "7.0.5",
+  "version": "7.5.3",
   "description": "Modern, fast, powerful node.js web framework",
   "homepage": "https://nestjs.com",
   "repository": {
@@ -27,7 +27,7 @@
     "test": "nyc --require ts-node/register mocha packages/**/*.spec.ts --reporter spec --retries 3 --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 -d",
+    "test:docker:down": "docker-compose -f integration/docker-compose.yml down",
     "lint": "concurrently 'npm run lint:packages' 'npm run lint:integration' 'npm run lint:spec'",
     "lint:integration": "eslint 'integration/*/{,!(node_modules)/**/}/*.ts' -c '.eslintrc.spec.js' --fix",
     "lint:packages": "eslint 'packages/**/**.ts' --fix --ignore-pattern 'packages/**/*.spec.ts'",
@@ -51,118 +51,120 @@
     ]
   },
   "dependencies": {
-    "@nuxtjs/opencollective": "0.2.2",
-    "axios": "0.19.2",
-    "class-transformer": "0.2.3",
-    "class-validator": "0.11.1",
+    "@nuxtjs/opencollective": "0.3.2",
+    "axios": "0.21.0",
+    "class-transformer": "0.3.1",
+    "class-validator": "0.12.2",
     "cli-color": "2.0.0",
     "cors": "2.8.5",
     "express": "4.17.1",
-    "fast-json-stringify": "1.18.0",
+    "fast-json-stringify": "2.2.10",
     "fast-safe-stringify": "2.0.7",
-    "iterare": "1.2.0",
+    "iterare": "1.2.1",
     "object-hash": "2.0.3",
     "path-to-regexp": "3.2.0",
     "reflect-metadata": "0.1.13",
-    "rxjs": "6.5.4",
+    "rxjs": "6.6.3",
     "socket.io": "2.3.0",
-    "uuid": "7.0.2",
-    "tslib": "1.11.1"
+    "uuid": "8.3.1",
+    "tslib": "2.0.3"
   },
   "devDependencies": {
     "@codechecks/client": "0.1.10",
-    "@commitlint/cli": "8.3.5",
-    "@commitlint/config-angular": "8.3.4",
-    "@grpc/proto-loader": "0.5.3",
-    "@nestjs/graphql": "7.1.3",
-    "@nestjs/mongoose": "6.4.0",
-    "@nestjs/typeorm": "7.0.0",
-    "@types/amqplib": "0.5.13",
+    "@commitlint/cli": "11.0.0",
+    "@commitlint/config-angular": "11.0.0",
+    "@grpc/proto-loader": "0.5.5",
+    "@nestjs/graphql": "7.9.1",
+    "@nestjs/mongoose": "7.1.2",
+    "@nestjs/typeorm": "7.1.5",
+    "@types/amqplib": "0.5.16",
     "@types/bytes": "3.1.0",
-    "@types/cache-manager": "2.10.2",
-    "@types/chai": "4.2.10",
-    "@types/chai-as-promised": "7.1.2",
-    "@types/cors": "2.8.6",
-    "@types/express": "4.17.3",
-    "@types/fastify-cors": "2.1.0",
-    "@types/gulp": "4.0.6",
-    "@types/kafka-node": "2.0.9",
-    "@types/mocha": "7.0.2",
-    "@types/mongoose": "5.7.8",
-    "@types/node": "10.17.3",
-    "@types/redis": "2.8.17",
-    "@types/reflect-metadata": "0.0.5",
-    "@types/sinon": "7.5.2",
-    "@types/socket.io": "2.1.4",
-    "@types/ws": "7.2.3",
-    "@typescript-eslint/eslint-plugin": "2.25.0",
-    "@typescript-eslint/parser": "2.25.0",
-    "amqp-connection-manager": "3.2.0",
-    "amqplib": "0.5.5",
-    "apollo-server-express": "2.11.0",
-    "artillery": "1.6.0",
+    "@types/cache-manager": "2.10.3",
+    "@types/chai": "4.2.14",
+    "@types/chai-as-promised": "7.1.3",
+    "@types/cors": "2.8.8",
+    "@types/express": "4.17.9",
+    "@types/gulp": "4.0.7",
+    "@types/mocha": "8.0.4",
+    "@types/mongoose": "5.10.2",
+    "@types/node": "14.14.10",
+    "@types/redis": "2.8.28",
+    "@types/reflect-metadata": "0.1.0",
+    "@types/sinon": "9.0.9",
+    "@types/socket.io": "2.1.12",
+    "@types/ws": "7.4.0",
+    "@typescript-eslint/eslint-plugin": "4.9.1",
+    "@typescript-eslint/parser": "4.9.0",
+    "amqp-connection-manager": "3.2.1",
+    "amqplib": "0.6.0",
+    "apollo-server-express": "2.19.0",
+    "artillery": "1.6.1",
     "awesome-typescript-loader": "5.2.1",
     "body-parser": "1.19.0",
     "bytes": "3.1.0",
-    "cache-manager": "3.2.1",
+    "cache-manager": "3.4.0",
     "chai": "4.2.0",
     "chai-as-promised": "7.1.1",
     "clang-format": "1.4.0",
     "commitlint-circle": "1.0.0",
-    "concurrently": "5.1.0",
-    "conventional-changelog": "3.1.18",
-    "core-js": "3.6.4",
-    "coveralls": "3.0.11",
+    "concurrently": "5.3.0",
+    "conventional-changelog": "3.1.24",
+    "core-js": "3.8.1",
+    "coveralls": "3.1.0",
     "delete-empty": "3.0.0",
-    "engine.io-client": "3.4.0",
-    "eslint": "6.8.0",
-    "eslint-config-prettier": "6.10.1",
-    "eslint-plugin-import": "2.20.2",
+    "engine.io-client": "4.0.4",
+    "eslint": "7.15.0",
+    "eslint-config-prettier": "7.0.0",
+    "eslint-plugin-import": "2.22.1",
+    "eventsource": "1.0.7",
     "fancy-log": "1.3.3",
-    "fastify": "2.13.0",
-    "fastify-cors": "3.0.3",
-    "fastify-formbody": "3.1.0",
-    "fastify-multipart": "1.0.5",
-    "fastify-static": "2.6.0",
-    "graphql": "14.6.0",
-    "graphql-tools": "4.0.7",
-    "grpc": "1.24.2",
+    "fastify": "3.9.1",
+    "fastify-cors": "5.0.0",
+    "fastify-formbody": "5.0.0",
+    "fastify-multipart": "3.3.1",
+    "fastify-static": "3.3.0",
+    "graphql": "15.4.0",
+    "graphql-tools": "7.0.2",
+    "grpc": "1.24.4",
     "gulp": "4.0.2",
     "gulp-clang-format": "1.0.27",
     "gulp-clean": "0.4.0",
-    "gulp-sourcemaps": "2.6.5",
+    "gulp-sourcemaps": "3.0.0",
     "gulp-typescript": "5.0.1",
     "gulp-watch": "5.0.1",
-    "husky": "4.2.3",
-    "imports-loader": "0.8.0",
+    "husky": "4.3.5",
+    "imports-loader": "1.2.0",
     "json-loader": "0.5.7",
     "kafkajs": "1.12.0",
     "lerna": "2.11.0",
-    "lint-staged": "10.0.10",
+    "light-my-request": "4.3.0",
+    "lint-staged": "10.5.3",
     "markdown-table": "2.0.0",
-    "merge-graphql-schemas": "1.7.6",
-    "mocha": "7.1.1",
-    "mongoose": "5.9.6",
-    "mqtt": "3.0.0",
+    "merge-graphql-schemas": "1.7.8",
+    "middie": "5.2.0",
+    "mocha": "8.2.1",
+    "mongoose": "5.11.5",
+    "mqtt": "4.2.6",
     "multer": "1.4.2",
     "mysql": "2.18.1",
-    "nats": "1.4.8",
-    "nodemon": "2.0.2",
-    "nyc": "15.0.0",
-    "prettier": "2.0.2",
+    "nats": "1.4.12",
+    "nodemon": "2.0.6",
+    "nyc": "15.1.0",
+    "point-of-view": "4.7.0",
+    "prettier": "2.2.1",
     "redis": "3.0.2",
-    "rxjs-compat": "6.5.4",
-    "sinon": "9.0.1",
+    "rxjs-compat": "6.6.3",
+    "sinon": "9.2.1",
     "sinon-chai": "3.5.0",
-    "socket.io-client": "2.3.0",
-    "subscriptions-transport-ws": "0.9.16",
-    "supertest": "4.0.2",
-    "ts-morph": "7.0.1",
-    "ts-node": "8.8.1",
-    "typeorm": "0.2.24",
-    "typescript": "3.7.2",
-    "wrk": "1.2.0",
-    "ws": "7.2.3"
+    "socket.io-client": "2.3.1",
+    "subscriptions-transport-ws": "0.9.18",
+    "supertest": "6.0.1",
+    "ts-morph": "9.1.0",
+    "ts-node": "9.1.1",
+    "typeorm": "0.2.29",
+    "typescript": "4.0.3",
+    "wrk": "1.2.1",
+    "ws": "7.4.1"
   },
   "engines": {
     "node": ">= 10.13.0"
@@ -193,7 +195,7 @@
       "packages/microservices/microservices-module.ts",
       "packages/core/middleware/middleware-module.ts",
       "packages/core/injector/module-ref.ts",
-      "packages/core/injector/container-scanner.ts",
+      "packages/core/injector/instance-links-host.ts",
       "packages/common/cache/**/*",
       "packages/common/serializer/**/*",
       "packages/common/services/logger.service.ts"

packages/common/Readme.md

@@ -38,6 +38,14 @@ 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:
 
+## Questions
+
+For questions and support please use the official [Discord channel](https://discord.gg/G7Qnnhy). The issue list of this repo is **exclusively** for bug reports and feature requests.
+
+## Issues
+
+Please make sure to read the [Issue Reporting Checklist](https://github.com/nestjs/nest/blob/master/CONTRIBUTING.md#-submitting-an-issue) before opening an issue. Issues not conforming to the guidelines may be closed immediately.
+
 ## Consulting
 
 With official support, you can get expert help straight from Nest core team. We provide dedicated technical support, migration strategies, advice on best practices (and design decisions), PR reviews, and team augmentation. Read more about [support here](https://enterprise.nestjs.com).
@@ -46,32 +54,43 @@ With official support, you can get expert help straight from Nest core team. We
 
 Nest is an MIT-licensed open source project. It can grow thanks to the sponsors and support by the amazing backers. If you'd like to join them, please [read more here](https://docs.nestjs.com/support).
 
-#### Principal Sponsor
-
-<a href="https://valor-software.com/" target="_blank"><img src="https://docs.nestjs.com/assets/sponsors/valor-software.png" width="320" /></a>
+#### Principal Sponsors
+<table style="text-align:center;"><tr><td>
+<a href="https://github.com/Sanofi-IADC" target="_blank"><img src="https://docs.nestjs.com/assets/sponsors/sanofi.png" width="180" 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="180" valign="middle" /></a></td>
+</tr></table>
 
 #### Silver Sponsors
-<a href="https://neoteric.eu/" target="_blank"><img src="https://nestjs.com/img/neoteric-cut.png" width="120" valign="middle" /></a> &nbsp;
-  <a href="http://gojob.com" target="_blank"><img src="http://nestjs.com/img/gojob-logo.png" valign="middle" height="95" /></a> &nbsp; 
-    <a href="https://trilon.io" target="_blank"><img src="https://nestjs.com/img/trilon.svg" width="150" valign="middle" /></a> &nbsp;
-<a href="http://www.leogistics.com" target="_blank"><img src="https://nestjs.com/img/leogistics-logo.jpeg" width="150" valign="middle" /></a>
+
+<table style="text-align:center;"><tr><td>
+<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="https://trilon.io" target="_blank"><img src="https://nestjs.com/img/trilon.svg" width="170" valign="middle" /></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>
 
 #### Sponsors
 
-<a href="https://www.swingdev.io" target="_blank"><img src="https://nestjs.com/img/swingdev-logo.svg#1" width="110" valign="middle" /> </a> &nbsp; <a href="https://blueanchor.io/" target="_blank"><img src="https://nestjs.com/img/blueanchor.png" width="150" valign="middle" /></a> &nbsp;
-<a href="https://www.novologic.com/" target="_blank"><img src="https://nestjs.com/img/novologic.png" width="110" valign="middle" /></a> &nbsp; <a href="https://hostpresto.com" target="_blank"><img src="https://nestjs.com/img/hostpresto.png" height="24" valign="middle" /></a>
-<a href="https://ever.co/" target="_blank"><img src="https://nestjs.com/img/ever-logo.png" height="14" valign="middle" /></a>  &nbsp; 
-<a href="https://buddy.works/" target="_blank"><img src="https://nestjs.com/img/buddy-logo.svg" height="25" valign="middle" /></a> &nbsp;
-<a href="https://blokt.com" target="_blank"><img src="https://nestjs.com/img/blokt-logo.png" height="25" valign="middle" /></a>  &nbsp;  <a href="https://genuinebee.com/" target="_blank"><img src="https://nestjs.com/img/genuinebee.svg" height="27" valign="middle" /></a> &nbsp; <a href="http://architectnow.net/" target="_blank"><img src="https://nestjs.com/img/architectnow.png" height="20" valign="middle" /></a> &nbsp; <a href="https://quander.io/" target="_blank"><img src="https://nestjs.com/img/quander.png" height="22" valign="middle" /></a> &nbsp; <a href="https://mantro.net/" target="_blank"><img src="https://nestjs.com/img/mantro-logo.svg" height="19" valign="middle" /></a> &nbsp; <a href="https://triplebyte.com/" target="_blank"><img src="https://nestjs.com/img/triplebyte.png" height="20" valign="middle" /></a> &nbsp; 
-<a href="https://reposit.co.uk/" target="_blank"><img src="https://nestjs.com/img/reposit-logo.png" height="18" valign="middle" /></a> &nbsp; &nbsp;
-<a href="https://nearpod.com/" target="_blank"><img src="https://nestjs.com/img/nearpod-logo.svg" width="100" valign="middle" /></a> &nbsp;
-<a href="https://clay.global/" target="_blank"><img src="https://nestjs.com/img/clay-logo.svg" width="75" valign="middle" /></a> &nbsp;
-<a href="https://firesticktricks.com" target="_blank"><img src="https://nestjs.com/img/firesticktricks-logo.png" width="120" valign="middle" /></a> &nbsp;
-<a href="https://www.codeguesser.co.uk" target="_blank"><img src="https://nestjs.com/img/codeguesser-logo.svg" width="120" valign="middle" /></a> &nbsp;
-<a href="https://tekhattan.com" target="_blank"><img src="https://nestjs.com/img/tekhattan-logo.png" width="110" valign="middle" /></a> &nbsp;
-<a href="https://f-a.nz/" target="_blank"><img src="https://nestjs.com/img/franz.svg" width="80" valign="middle" /></a> &nbsp;
-<a href="https://sparkfabrik.com/" target="_blank"><img src="https://nestjs.com/img/sparkfabrik-logo.png" width="120" valign="middle" /></a>
-
+<table><tr><td align="center" valign="middle">
+<a href="https://www.swingdev.io" target="_blank"><img src="https://nestjs.com/img/swingdev-logo.svg#1" width="110" valign="middle" /> </a></td><td align="center" valign="middle">
+<a href="https://www.novologic.com/" target="_blank"><img src="https://nestjs.com/img/novologic.png" width="110" valign="middle" /></a> </td><td align="center" valign="middle">
+<a href="https://ever.co/" target="_blank"><img src="https://nestjs.com/img/ever-logo.png" width="72" valign="middle" /></a>  </td><td align="center" valign="middle">
+<a href="https://blokt.com" target="_blank"><img src="https://nestjs.com/img/blokt-logo.png" width="120" valign="middle" /></a>  </td><td align="center" valign="middle"> 
+  <a href="http://architectnow.net/" target="_blank"><img src="https://nestjs.com/img/architectnow.png" width="125" valign="middle" /></a> </td><td align="center" valign="middle">
+  <a href="https://quander.io/" target="_blank"><img src="https://nestjs.com/img/quander.png" width="100" valign="middle" /></a> </td></tr><tr><td align="center" valign="middle">
+  <a href="https://mantro.net/" target="_blank"><img src="https://nestjs.com/img/mantro-logo.svg" width="95" valign="middle" /></a> </td><td align="center" valign="middle">
+  <a href="https://triplebyte.com/" target="_blank"><img src="https://nestjs.com/img/triplebyte.png" width="107" valign="middle" /></a> </td><td align="center" valign="middle">
+<a href="https://reposit.co.uk/" target="_blank"><img src="https://nestjs.com/img/reposit-logo.png" width="71" valign="middle" /></a></td><td align="center" valign="middle">
+<a href="https://nearpod.com/" target="_blank"><img src="https://nestjs.com/img/nearpod-logo.svg" width="100" valign="middle" /></a> </td><td align="center" valign="middle">
+<a href="https://clay.global/" target="_blank"><img src="https://nestjs.com/img/clay-logo.svg" width="75" valign="middle" /></a> </td><td align="center" valign="middle">
+<a href="https://firesticktricks.com" target="_blank"><img src="https://nestjs.com/img/firesticktricks-logo.png" width="120" valign="middle" /></a></td></tr><tr><td align="center" valign="middle">
+<a href="https://www.codeguesser.co.uk" target="_blank"><img src="https://nestjs.com/img/codeguesser-logo.svg" width="120" valign="middle" /></a> </td><td align="center" valign="middle">
+<a href="https://f-a.nz/" target="_blank"><img src="https://nestjs.com/img/franz.svg" width="80" valign="middle" /></a> </td><td align="center" valign="middle">
+<a href="https://sparkfabrik.com/" target="_blank"><img src="https://nestjs.com/img/sparkfabrik-logo.png" width="120" valign="middle" /></a></td><td align="center" valign="middle"><a href="https://www.thebigphonestore.co.uk/" target="_blank"><img src="https://nestjs.com/img/the-big-phone-store-logo.png" width="65" valign="middle" /></a></td>
+  <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>
+  </tr></table>
 
 ## Backers
 

packages/common/cache/decorators/cache-ttl.decorator.ts

@@ -1,4 +1,5 @@
 import { SetMetadata } from '../../decorators';
+import { ExecutionContext } from '../../interfaces/features/execution-context.interface';
 import { CACHE_TTL_METADATA } from '../cache.constants';
 
 /**
@@ -12,4 +13,6 @@ import { CACHE_TTL_METADATA } from '../cache.constants';
  *
  * @publicApi
  */
-export const CacheTTL = (ttl: number) => SetMetadata(CACHE_TTL_METADATA, ttl);
+type CacheTTLFactory = (ctx: ExecutionContext) => Promise<number> | number;
+export const CacheTTL = (ttl: number | CacheTTLFactory) =>
+  SetMetadata(CACHE_TTL_METADATA, ttl);

packages/common/cache/index.ts

@@ -1,4 +1,4 @@
-export { CACHE_MANAGER } from './cache.constants';
+export * from './cache.constants';
 export * from './cache.module';
 export * from './decorators';
 export * from './interceptors';

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

@@ -7,6 +7,7 @@ import {
   HttpServer,
   NestInterceptor,
 } from '../../interfaces';
+import { isFunction, isNil } from '../../utils/shared.utils';
 import {
   CACHE_KEY_METADATA,
   CACHE_MANAGER,
@@ -36,7 +37,7 @@ export class CacheInterceptor implements NestInterceptor {
     next: CallHandler,
   ): Promise<Observable<any>> {
     const key = this.trackBy(context);
-    const ttl =
+    const ttlValueOrFactory =
       this.reflector.get(CACHE_TTL_METADATA, context.getHandler()) || null;
 
     if (!key) {
@@ -44,13 +45,15 @@ export class CacheInterceptor implements NestInterceptor {
     }
     try {
       const value = await this.cacheManager.get(key);
-      if (value) {
+      if (!isNil(value)) {
         return of(value);
       }
-
+      const ttl = isFunction(ttlValueOrFactory)
+        ? await ttlValueOrFactory(context)
+        : ttlValueOrFactory;
       return next.handle().pipe(
         tap(response => {
-          const args = ttl ? [key, response, { ttl }] : [key, response];
+          const args = isNil(ttl) ? [key, response] : [key, response, { ttl }];
           this.cacheManager.set(...args);
         }),
       );

packages/common/constants.ts

@@ -26,3 +26,5 @@ export const HTTP_CODE_METADATA = '__httpCode__';
 export const MODULE_PATH = '__module_path__';
 export const HEADERS_METADATA = '__headers__';
 export const REDIRECT_METADATA = '__redirect__';
+export const RESPONSE_PASSTHROUGH_METADATA = '__responsePassthrough__';
+export const SSE_METADATA = '__sse__';

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

@@ -3,8 +3,8 @@ import {
   PATH_METADATA,
   SCOPE_OPTIONS_METADATA,
 } from '../../constants';
-import { isString, isUndefined } from '../../utils/shared.utils';
 import { ScopeOptions } from '../../interfaces/scope-options.interface';
+import { isString, isUndefined } from '../../utils/shared.utils';
 
 /**
  * Interface defining options that can be passed to `@Controller()` decorator
@@ -18,7 +18,7 @@ export interface ControllerOptions extends ScopeOptions {
    *
    * @see [Routing](https://docs.nestjs.com/controllers#routing)
    */
-  path?: string;
+  path?: string | string[];
 
   /**
    * Specifies an optional HTTP Request host filter.  When configured, methods
@@ -65,7 +65,7 @@ export function Controller(): ClassDecorator;
  * It defines a class that provides a context for one or more message or event
  * handlers.
  *
- * @param {string} prefix string that defines a `route path prefix`.  The prefix
+ * @param {string, Array} prefix string that defines a `route path prefix`.  The prefix
  * is pre-pended to the path specified in any request decorator in the class.
  *
  * @see [Routing](https://docs.nestjs.com/controllers#routing)
@@ -74,7 +74,7 @@ export function Controller(): ClassDecorator;
  *
  * @publicApi
  */
-export function Controller(prefix: string): ClassDecorator;
+export function Controller(prefix: string | string[]): ClassDecorator;
 
 /**
  * Decorator that marks a class as a Nest controller that can receive inbound
@@ -137,12 +137,13 @@ export function Controller(options: ControllerOptions): ClassDecorator;
  * @publicApi
  */
 export function Controller(
-  prefixOrOptions?: string | ControllerOptions,
+  prefixOrOptions?: string | string[] | ControllerOptions,
 ): ClassDecorator {
   const defaultPath = '/';
+
   const [path, host, scopeOptions] = isUndefined(prefixOrOptions)
     ? [defaultPath, undefined, undefined]
-    : isString(prefixOrOptions)
+    : isString(prefixOrOptions) || Array.isArray(prefixOrOptions)
     ? [prefixOrOptions, undefined, undefined]
     : [
         prefixOrOptions.path || defaultPath,

packages/common/decorators/core/set-metadata.decorator.ts

@@ -9,7 +9,7 @@ export type CustomDecorator<TKey = string> = MethodDecorator &
  *
  * Requires two parameters:
  * - `key` - a value defining the key under which the metadata is stored
- * - `value[]` - array of metadata values to be associated with `key`
+ * - `value` - metadata to be associated with `key`
  *
  * This metadata can be reflected using the `Reflector` class.
  *

packages/common/decorators/http/index.ts

@@ -5,3 +5,4 @@ export * from './create-route-param-metadata.decorator';
 export * from './render.decorator';
 export * from './header.decorator';
 export * from './redirect.decorator';
+export * from './sse.decorator';

packages/common/decorators/http/redirect.decorator.ts

@@ -5,7 +5,7 @@ import { REDIRECT_METADATA } from '../../constants';
  *
  * @publicApi
  */
-export function Redirect(url: string, statusCode?: number): MethodDecorator {
+export function Redirect(url = '', statusCode?: number): MethodDecorator {
   return (
     target: object,
     key: string | symbol,

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

@@ -1,9 +1,26 @@
-import { ROUTE_ARGS_METADATA } from '../../constants';
+import {
+  RESPONSE_PASSTHROUGH_METADATA,
+  ROUTE_ARGS_METADATA,
+} from '../../constants';
 import { RouteParamtypes } from '../../enums/route-paramtypes.enum';
 import { PipeTransform } from '../../index';
 import { Type } from '../../interfaces';
 import { isNil, isString } from '../../utils/shared.utils';
 
+/**
+ * The `@Response()`/`@Res` parameter decorator options.
+ */
+export interface ResponseDecoratorOptions {
+  /**
+   * Determines whether the response will be sent manually within the route handler,
+   * with the use of native response handling methods exposed by the platform-specific response object,
+   * or if it should passthrough Nest response processing pipeline.
+   *
+   * @default false
+   */
+  passthrough: boolean;
+}
+
 export type ParamData = object | string | number;
 export interface RouteParamMetadata {
   index: number;
@@ -85,21 +102,35 @@ export const Request: () => ParameterDecorator = createRouteParamDecorator(
  *
  * Example: `logout(@Response() res)`
  *
- * @see [Request object](https://docs.nestjs.com/controllers#request-object)
- *
  * @publicApi
  */
-export const Response: () => ParameterDecorator = createRouteParamDecorator(
-  RouteParamtypes.RESPONSE,
-);
+export const Response: (
+  options?: ResponseDecoratorOptions,
+) => ParameterDecorator = (options?: ResponseDecoratorOptions) => (
+  target,
+  key,
+  index,
+) => {
+  if (options?.passthrough) {
+    Reflect.defineMetadata(
+      RESPONSE_PASSTHROUGH_METADATA,
+      options?.passthrough,
+      target.constructor,
+      key,
+    );
+  }
+  return createRouteParamDecorator(RouteParamtypes.RESPONSE)()(
+    target,
+    key,
+    index,
+  );
+};
 
 /**
  * Route handler parameter decorator. Extracts reference to the `Next` function
  * from the underlying platform and populates the decorated
  * parameter with the value of `Next`.
  *
- * @see [Request object](https://docs.nestjs.com/controllers#request-object)
- *
  * @publicApi
  */
 export const Next: () => ParameterDecorator = createRouteParamDecorator(

packages/common/decorators/http/sse.decorator.ts

@@ -0,0 +1,26 @@
+import { METHOD_METADATA, PATH_METADATA, SSE_METADATA } from '../../constants';
+import { RequestMethod } from '../../enums/request-method.enum';
+
+/**
+ * Declares this route as a Server-Sent-Events endpoint
+ *
+ * @publicApi
+ */
+export function Sse(path?: string): MethodDecorator {
+  return (
+    target: object,
+    key: string | symbol,
+    descriptor: TypedPropertyDescriptor<any>,
+  ) => {
+    path = path && path.length ? path : '/';
+
+    Reflect.defineMetadata(PATH_METADATA, path, descriptor.value);
+    Reflect.defineMetadata(
+      METHOD_METADATA,
+      RequestMethod.GET,
+      descriptor.value,
+    );
+    Reflect.defineMetadata(SSE_METADATA, true, descriptor.value);
+    return descriptor;
+  };
+}

packages/common/enums/http-status.enum.ts

@@ -2,6 +2,7 @@ export enum HttpStatus {
   CONTINUE = 100,
   SWITCHING_PROTOCOLS = 101,
   PROCESSING = 102,
+  EARLYHINTS = 103,
   OK = 200,
   CREATED = 201,
   ACCEPTED = 202,
@@ -35,6 +36,7 @@ export enum HttpStatus {
   REQUESTED_RANGE_NOT_SATISFIABLE = 416,
   EXPECTATION_FAILED = 417,
   I_AM_A_TEAPOT = 418,
+  MISDIRECTED = 421,
   UNPROCESSABLE_ENTITY = 422,
   FAILED_DEPENDENCY = 424,
   TOO_MANY_REQUESTS = 429,

packages/common/exceptions/gateway-timeout.exception.ts

@@ -2,7 +2,7 @@ import { HttpStatus } from '../enums/http-status.enum';
 import { HttpException } from './http.exception';
 
 /**
- * Defines an HTTP exception for *Gatway Timeout* type errors.
+ * Defines an HTTP exception for *Gateway Timeout* type errors.
  *
  * @see [Base Exceptions](https://docs.nestjs.com/exception-filters#base-exceptions)
  *

packages/common/exceptions/http.exception.ts

@@ -67,14 +67,15 @@ export class HttpException extends Error {
 
   public static createBody(
     objectOrError: object | string,
-    message?: string,
+    description?: string,
     statusCode?: number,
   ) {
     if (!objectOrError) {
-      return { statusCode, message };
+      return { statusCode, message: description };
     }
     return isObject(objectOrError) && !Array.isArray(objectOrError)
       ? objectOrError
-      : { statusCode, message: objectOrError, error: message };
+      : { statusCode, message: objectOrError, error: description };
   }
 }
+

packages/common/exceptions/index.ts

@@ -13,7 +13,10 @@ export * from './unsupported-media-type.exception';
 export * from './unprocessable-entity.exception';
 export * from './internal-server-error.exception';
 export * from './not-implemented.exception';
+export * from './http-version-not-supported.exception';
 export * from './bad-gateway.exception';
 export * from './service-unavailable.exception';
 export * from './gateway-timeout.exception';
 export * from './im-a-teapot.exception';
+export * from './precondition-failed.exception';
+export * from './misdirected.exception';

packages/common/exceptions/misdirected.exception.ts

@@ -0,0 +1,49 @@
+import { HttpStatus } from '../enums/http-status.enum';
+import { HttpException } from './http.exception';
+
+/**
+ * Defines an HTTP exception for *Misdirected* type errors.
+ *
+ * @see [Base Exceptions](https://docs.nestjs.com/exception-filters#base-exceptions)
+ *
+ * @publicApi
+ */
+export class MisdirectedException extends HttpException {
+  /**
+   * Instantiate a `MisdirectedException` Exception.
+   *
+   * @example
+   * `throw new MisdirectedException()`
+   *
+   * @usageNotes
+   * The HTTP response status code will be 421.
+   * - The `objectOrError` argument defines the JSON response body or the message string.
+   * - The `description` argument contains a short description of the HTTP error.
+   *
+   * By default, the JSON response body contains two properties:
+   * - `statusCode`: this will be the value 421.
+   * - `message`: the string `'Bad Gateway'` by default; override this by supplying
+   * a string in the `objectOrError` parameter.
+   *
+   * If the parameter `objectOrError` is a string, the response body will contain an
+   * additional property, `error`, with a short description of the HTTP error. To override the
+   * entire JSON response body, pass an object instead. Nest will serialize the object
+   * and return it as the JSON response body.
+   *
+   * @param objectOrError string or object describing the error condition.
+   * @param description a short description of the HTTP error.
+   */
+  constructor(
+    objectOrError?: string | object | any,
+    description = 'Misdirected',
+  ) {
+    super(
+      HttpException.createBody(
+        objectOrError,
+        description,
+        HttpStatus.MISDIRECTED,
+      ),
+      HttpStatus.MISDIRECTED,
+    );
+  }
+}

packages/common/exceptions/precondition-failed.exception.ts

@@ -0,0 +1,49 @@
+import { HttpStatus } from '../enums/http-status.enum';
+import { HttpException } from './http.exception';
+
+/**
+ * Defines an HTTP exception for *Precondition Failed* type errors.
+ *
+ * @see [Base Exceptions](https://docs.nestjs.com/exception-filters#base-exceptions)
+ *
+ * @publicApi
+ */
+export class PreconditionFailedException extends HttpException {
+  /**
+   * Instantiate a `PreconditionFailedException` Exception.
+   *
+   * @example
+   * `throw new PreconditionFailedException()`
+   *
+   * @usageNotes
+   * The HTTP response status code will be 412.
+   * - The `objectOrError` argument defines the JSON response body or the message string.
+   * - The `description` argument contains a short description of the HTTP error.
+   *
+   * By default, the JSON response body contains two properties:
+   * - `statusCode`: this will be the value 412.
+   * - `message`: the string `'Precondition Failed'` by default; override this by supplying
+   * a string in the `objectOrError` parameter.
+   *
+   * If the parameter `objectOrError` is a string, the response body will contain an
+   * additional property, `error`, with a short description of the HTTP error. To override the
+   * entire JSON response body, pass an object instead. Nest will serialize the object
+   * and return it as the JSON response body.
+   *
+   * @param objectOrError string or object describing the error condition.
+   * @param description a short description of the HTTP error.
+   */
+  constructor(
+    objectOrError?: string | object | any,
+    description = 'Precondition Failed',
+  ) {
+    super(
+      HttpException.createBody(
+        objectOrError,
+        description,
+        HttpStatus.PRECONDITION_FAILED,
+      ),
+      HttpStatus.PRECONDITION_FAILED,
+    );
+  }
+}

packages/common/http/http.service.ts

@@ -1,8 +1,9 @@
 import Axios, {
   AxiosInstance,
+  AxiosPromise,
   AxiosRequestConfig,
   AxiosResponse,
-  AxiosPromise,
+  CancelTokenSource,
 } from 'axios';
 import { Observable } from 'rxjs';
 import { Inject } from '../decorators';
@@ -72,13 +73,14 @@ export class HttpService {
     ...args: any[]
   ) {
     return new Observable<AxiosResponse<T>>(subscriber => {
-      let config = args[args.length - 1];
-      if (!config) {
-        config = {};
-        args[args.length - 1] = config;
+      const config: AxiosRequestConfig = { ...(args[args.length - 1] || {}) };
+
+      let cancelSource: CancelTokenSource;
+      if (!config.cancelToken) {
+        cancelSource = Axios.CancelToken.source();
+        config.cancelToken = cancelSource.token;
       }
-      const cancelSource = Axios.CancelToken.source();
-      config.cancelToken = cancelSource.token;
+
       axios(...args)
         .then(res => {
           subscriber.next(res);
@@ -88,7 +90,11 @@ export class HttpService {
           subscriber.error(err);
         });
       return () => {
-        if (config.responseType !== 'stream') {
+        if (config.responseType === 'stream') {
+          return;
+        }
+
+        if (cancelSource) {
           cancelSource.cancel();
         }
       };

packages/common/index.ts

@@ -30,8 +30,12 @@ export {
   INestApplication,
   INestApplicationContext,
   INestMicroservice,
+  IntrospectionResult,
+  MessageEvent,
   MiddlewareConsumer,
+  ModuleMetadata,
   NestApplicationOptions,
+  NestHybridApplicationOptions,
   NestInterceptor,
   NestMiddleware,
   NestModule,

packages/common/interfaces/features/nest-interceptor.interface.ts

@@ -10,7 +10,7 @@ import { ExecutionContext } from './execution-context.interface';
  */
 export interface CallHandler<T = any> {
   /**
-   * Returns an `Observable` reprsenting the response stream from the route
+   * Returns an `Observable` representing the response stream from the route
    * handler.
    */
   handle(): Observable<T>;

packages/common/interfaces/http/http-server.interface.ts

@@ -54,7 +54,9 @@ export interface HttpServer<TRequest = any, TResponse = any> {
   setViewEngine?(engineOrOptions: any): this;
   createMiddlewareFactory(
     method: RequestMethod,
-  ): (path: string, callback: Function) => any;
+  ):
+    | ((path: string, callback: Function) => any)
+    | Promise<(path: string, callback: Function) => any>;
   getRequestHostname?(request: TRequest): string;
   getRequestMethod?(request: TRequest): string;
   getRequestUrl?(request: TResponse): string;
@@ -65,4 +67,5 @@ export interface HttpServer<TRequest = any, TResponse = any> {
   initHttpServer(options: NestApplicationOptions): void;
   close(): any;
   getType(): string;
+  init?(): Promise<void>;
 }

packages/common/interfaces/http/index.ts

@@ -0,0 +1,2 @@
+export * from './http-server.interface';
+export * from './message-event.interface';

packages/common/interfaces/http/message-event.interface.ts

@@ -0,0 +1,6 @@
+export interface MessageEvent {
+  data: string | object;
+  id?: string;
+  type?: string;
+  retry?: number;
+}

packages/common/interfaces/index.ts

@@ -13,14 +13,11 @@ export * from './features/nest-interceptor.interface';
 export * from './features/paramtype.interface';
 export * from './features/pipe-transform.interface';
 export * from './hooks';
-export * from './http/http-server.interface';
+export * from './http';
 export * from './injectable.interface';
+export * from './microservices/nest-hybrid-application-options.interface';
 export * from './middleware';
-export * from './modules/dynamic-module.interface';
-export * from './modules/forward-reference.interface';
-export * from './modules/module-metadata.interface';
-export * from './modules/nest-module.interface';
-export * from './modules/provider.interface';
+export * from './modules';
 export * from './nest-application-context.interface';
 export * from './nest-application-options.interface';
 export * from './nest-application.interface';

packages/common/interfaces/microservices/nest-hybrid-application-options.interface.ts

@@ -0,0 +1,3 @@
+export interface NestHybridApplicationOptions {
+  inheritAppConfig?: boolean;
+}

packages/common/interfaces/middleware/middleware-config-proxy.interface.ts

@@ -6,7 +6,7 @@ export interface MiddlewareConfigProxy {
   /**
    * Excludes routes from the currently processed middleware.
    *
-   * @param  {} ...routes
+   * @param {(string | RouteInfo)[]} routes
    * @returns {MiddlewareConfigProxy}
    */
   exclude(...routes: (string | RouteInfo)[]): MiddlewareConfigProxy;
@@ -15,7 +15,7 @@ export interface MiddlewareConfigProxy {
    * Attaches passed either routes or controllers to the currently configured middleware.
    * If you pass a class, Nest would attach middleware to every path defined within this controller.
    *
-   * @param  {} ...routes
+   * @param {(string | Type | RouteInfo)[]} routes
    * @returns {MiddlewareConsumer}
    */
   forRoutes(...routes: (string | Type<any> | RouteInfo)[]): MiddlewareConsumer;

packages/common/interfaces/middleware/middleware-consumer.interface.ts

@@ -10,7 +10,7 @@ import { MiddlewareConfigProxy } from './middleware-config-proxy.interface';
  */
 export interface MiddlewareConsumer {
   /**
-   * @param  middleware middleware class/function or array of classes/functions
+   * @param {...(Type | Function)} middleware middleware class/function or array of classes/functions
    * to be attached to the passed routes.
    *
    * @returns {MiddlewareConfigProxy}

packages/common/interfaces/modules/dynamic-module.interface.ts

@@ -21,7 +21,7 @@ export interface DynamicModule extends ModuleMetadata {
    * in all modules. Thereafter, modules that wish to inject a service exported
    * from a global module do not need to import the provider module.
    *
-   * Default: false
+   * @default false
    */
   global?: boolean;
 }

packages/common/interfaces/modules/index.ts

@@ -1,5 +1,6 @@
 export * from './dynamic-module.interface';
 export * from './forward-reference.interface';
+export * from './introspection-result.interface';
 export * from './module-metadata.interface';
 export * from './nest-module.interface';
 export * from './provider.interface';

packages/common/interfaces/modules/introspection-result.interface.ts

@@ -0,0 +1,11 @@
+import { Scope } from '../scope-options.interface';
+
+/**
+ * @publicApi
+ */
+export interface IntrospectionResult {
+  /**
+   * Enum defining lifetime of host class or factory.
+   */
+  scope: Scope;
+}

packages/common/interfaces/nest-application-context-options.interface.ts

@@ -8,4 +8,11 @@ export class NestApplicationContextOptions {
    * Specifies the logger to use.  Pass `false` to turn off logging.
    */
   logger?: LoggerService | LogLevel[] | boolean;
+
+  /**
+   * Whether to abort the process on Error. By default, the process is exited.
+   * Pass `false` to override the default behavior. If `false` is passed, Nest will not exit
+   * the application and instead will rethrow the exception.
+   */
+  abortOnError?: boolean | undefined;
 }

packages/common/interfaces/nest-application-context.interface.ts

@@ -1,5 +1,5 @@
 import { ShutdownSignal } from '../enums/shutdown-signal.enum';
-import { LoggerService } from '../services/logger.service';
+import { LoggerService, LogLevel } from '../services/logger.service';
 import { Abstract } from './abstract.interface';
 import { Type } from './type.interface';
 
@@ -34,6 +34,15 @@ export interface INestApplicationContext {
     options?: { strict: boolean },
   ): Promise<TResult>;
 
+  /**
+   * Registers the request/context object for a given context ID (DI container sub-tree).
+   * @returns {void}
+   */
+  registerRequestByContextId<T = any>(
+    request: T,
+    contextId: { id: number },
+  ): void;
+
   /**
    * Terminates the application
    * @returns {Promise<void>}
@@ -44,7 +53,7 @@ export interface INestApplicationContext {
    * Sets custom logger service
    * @returns {void}
    */
-  useLogger(logger: LoggerService): void;
+  useLogger(logger: LoggerService | LogLevel[] | false): void;
 
   /**
    * Enables the usage of shutdown hooks. Will call the

packages/common/interfaces/nest-application.interface.ts

@@ -2,7 +2,12 @@ import { CorsOptions } from './external/cors-options.interface';
 import { CanActivate } from './features/can-activate.interface';
 import { NestInterceptor } from './features/nest-interceptor.interface';
 import { HttpServer } from './http/http-server.interface';
-import { ExceptionFilter, INestMicroservice, PipeTransform } from './index';
+import {
+  ExceptionFilter,
+  INestMicroservice,
+  NestHybridApplicationOptions,
+  PipeTransform,
+} from './index';
 import { INestApplicationContext } from './nest-application-context.interface';
 import { WebSocketAdapter } from './websockets/web-socket-adapter.interface';
 
@@ -16,7 +21,7 @@ export interface INestApplication extends INestApplicationContext {
    * A wrapper function around HTTP adapter method: `adapter.use()`.
    * Example `app.use(cors())`
    *
-   * @returns {void}
+   * @returns {this}
    */
   use(...args: any[]): this;
 
@@ -30,10 +35,10 @@ export interface INestApplication extends INestApplicationContext {
   /**
    * Starts the application.
    *
-   * @param  {number} port
-   * @param  {string} hostname
-   * @param  {Function} callback Optional callback
-   * @returns A Promise that, when resolved, is a reference to the underlying HttpServer.
+   * @param {number|string} port
+   * @param {string} [hostname]
+   * @param {Function} [callback] Optional callback
+   * @returns {Promise} A Promise that, when resolved, is a reference to the underlying HttpServer.
    */
   listen(port: number | string, callback?: () => void): Promise<any>;
   listen(
@@ -45,15 +50,15 @@ export interface INestApplication extends INestApplicationContext {
   /**
    * Returns the url the application is listening at, based on OS and IP version. Returns as an IP value either in IPv6 or IPv4
    *
-   * @returns The IP where the server is listening
+   * @returns {Promise<string>} The IP where the server is listening
    */
   getUrl(): Promise<string>;
 
   /**
    * Starts the application (can be awaited).
    *
-   * @param  {number} port
-   * @param  {string} hostname (optional)
+   * @param {number|string} port
+   * @param {string} [hostname]
    * @returns {Promise}
    */
   listenAsync(port: number | string, hostname?: string): Promise<any>;
@@ -61,17 +66,17 @@ export interface INestApplication extends INestApplicationContext {
   /**
    * Registers a prefix for every HTTP route path.
    *
-   * @param  {string} prefix The prefix for every HTTP route path (for example `/v1/api`)
-   * @returns {void}
+   * @param {string} prefix The prefix for every HTTP route path (for example `/v1/api`)
+   * @returns {this}
    */
   setGlobalPrefix(prefix: string): this;
 
   /**
-   * Setup Ws Adapter which will be used inside Gateways.
+   * Register Ws Adapter which will be used inside Gateways.
    * Use when you want to override default `socket.io` library.
    *
-   * @param  {WebSocketAdapter} adapter
-   * @returns {void}
+   * @param {WebSocketAdapter} adapter
+   * @returns {this}
    */
   useWebSocketAdapter(adapter: WebSocketAdapter): this;
 
@@ -79,10 +84,15 @@ export interface INestApplication extends INestApplicationContext {
    * Connects microservice to the NestApplication instance. Transforms application
    * to a hybrid instance.
    *
-   * @param  {T} options Microservice options object
+   * @template {object} T
+   * @param {T} options Microservice options object
+   * @param {NestHybridApplicationOptions} hybridOptions Hybrid options object
    * @returns {INestMicroservice}
    */
-  connectMicroservice<T extends object = any>(options: T): INestMicroservice;
+  connectMicroservice<T extends object = any>(
+    options: T,
+    hybridOptions?: NestHybridApplicationOptions,
+  ): INestMicroservice;
 
   /**
    * Returns array of the microservices connected to the NestApplication.
@@ -94,7 +104,7 @@ export interface INestApplication extends INestApplicationContext {
   /**
    * Returns the underlying native HTTP server.
    *
-   * @returns {any}
+   * @returns {*}
    */
   getHttpServer(): any;
 
@@ -108,8 +118,8 @@ export interface INestApplication extends INestApplicationContext {
   /**
    * Starts all connected microservices asynchronously.
    *
-   * @param  {Function} callback Optional callback function
-   * @returns {void}
+   * @param {Function} [callback] Optional callback function
+   * @returns {this}
    */
   startAllMicroservices(callback?: () => void): this;
 
@@ -124,14 +134,14 @@ export interface INestApplication extends INestApplicationContext {
    * Registers exception filters as global filters (will be used within
    * every HTTP route handler)
    *
-   * @param  {ExceptionFilter[]} ...filters
+   * @param {...ExceptionFilter} filters
    */
   useGlobalFilters(...filters: ExceptionFilter[]): this;
 
   /**
    * Registers pipes as global pipes (will be used within every HTTP route handler)
    *
-   * @param  {PipeTransform[]} ...pipes
+   * @param {...PipeTransform} pipes
    */
   useGlobalPipes(...pipes: PipeTransform<any>[]): this;
 
@@ -139,14 +149,14 @@ export interface INestApplication extends INestApplicationContext {
    * Registers interceptors as global interceptors (will be used within
    * every HTTP route handler)
    *
-   * @param  {NestInterceptor[]} ...interceptors
+   * @param {...NestInterceptor} interceptors
    */
   useGlobalInterceptors(...interceptors: NestInterceptor[]): this;
 
   /**
    * Registers guards as global guards (will be used within every HTTP route handler)
    *
-   * @param  {CanActivate[]} ...guards
+   * @param {...CanActivate} guards
    */
   useGlobalGuards(...guards: CanActivate[]): this;
 

packages/common/interfaces/nest-microservice.interface.ts

@@ -14,11 +14,10 @@ export interface INestMicroservice extends INestApplicationContext {
   /**
    * Starts the microservice.
    *
-   * @param  {Function} callback
-   * @returns {Promise}
-   *
+   * @param {Function} callback
+   * @returns {void}
    */
-  listen(callback: () => void): any;
+  listen(callback: () => void): void;
 
   /**
    * Starts the microservice (can be awaited).
@@ -29,38 +28,38 @@ export interface INestMicroservice extends INestApplicationContext {
 
   /**
    * Register Ws Adapter which will be used inside Gateways.
-   * Use, when you want to override default `socket.io` library.
+   * Use when you want to override default `socket.io` library.
    *
-   * @param  {WebSocketAdapter} adapter
-   * @returns {void}
+   * @param {WebSocketAdapter} adapter
+   * @returns {this}
    */
   useWebSocketAdapter(adapter: WebSocketAdapter): this;
 
   /**
-   * Registers exception filters as a global filters (will be used within every message pattern handler)
+   * Registers exception filters as global filters (will be used within every message pattern handler)
    *
-   * @param  {ExceptionFilter[]} ...filters
+   * @param {...ExceptionFilter} filters
    */
   useGlobalFilters(...filters: ExceptionFilter[]): this;
 
   /**
-   * Registers pipes as a global pipes (will be used within every message pattern handler)
+   * Registers pipes as global pipes (will be used within every message pattern handler)
    *
-   * @param  {PipeTransform[]} ...pipes
+   * @param {...PipeTransform} pipes
    */
   useGlobalPipes(...pipes: PipeTransform<any>[]): this;
 
   /**
-   * Registers interceptors as a global interceptors (will be used within every message pattern handler)
+   * Registers interceptors as global interceptors (will be used within every message pattern handler)
    *
-   * @param  {NestInterceptor[]} ...interceptors
+   * @param {...NestInterceptor} interceptors
    */
   useGlobalInterceptors(...interceptors: NestInterceptor[]): this;
 
   /**
-   * Registers guards as a global guards (will be used within every message pattern handler)
+   * Registers guards as global guards (will be used within every message pattern handler)
    *
-   * @param  {CanActivate[]} ...guards
+   * @param {...CanActivate} guards
    */
   useGlobalGuards(...guards: CanActivate[]): this;
 

packages/common/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nestjs/common",
-  "version": "7.0.7",
+  "version": "7.5.5",
   "description": "Nest - modern, fast, powerful node.js web framework (@common)",
   "author": "Kamil Mysliwiec",
   "homepage": "https://nestjs.com",
@@ -17,11 +17,10 @@
   },
   "license": "MIT",
   "dependencies": {
-    "axios": "0.19.2",
-    "cli-color": "2.0.0",
-    "iterare": "1.2.0",
-    "tslib": "1.11.1",
-    "uuid": "7.0.2"
+    "axios": "0.21.0",
+    "iterare": "1.2.1",
+    "tslib": "2.0.3",
+    "uuid": "8.3.1"
   },
   "peerDependencies": {
     "reflect-metadata": "^0.1.12",

packages/common/pipes/default-value.pipe.ts

@@ -0,0 +1,25 @@
+import { ArgumentMetadata, Injectable, PipeTransform } from '../index';
+import { isNil } from '../utils/shared.utils';
+
+/**
+ * Defines the built-in DefaultValue Pipe
+ *
+ * @see [Built-in Pipes](https://docs.nestjs.com/pipes#built-in-pipes)
+ *
+ * @publicApi
+ */
+@Injectable()
+export class DefaultValuePipe<T = any, R = any>
+  implements PipeTransform<T, T | R> {
+  constructor(private readonly defaultValue: R) {}
+
+  transform(value?: T, _metadata?: ArgumentMetadata): T | R {
+    if (
+      isNil(value) ||
+      (typeof value === 'number' && isNaN((value as unknown) as number))
+    ) {
+      return this.defaultValue;
+    }
+    return value;
+  }
+}

packages/common/pipes/index.ts

@@ -1,3 +1,4 @@
+export * from './default-value.pipe';
 export * from './parse-array.pipe';
 export * from './parse-bool.pipe';
 export * from './parse-int.pipe';

packages/common/pipes/validation.pipe.ts

@@ -6,6 +6,7 @@ import { ArgumentMetadata, ValidationError } from '../index';
 import { ClassTransformOptions } from '../interfaces/external/class-transform-options.interface';
 import { ValidatorOptions } from '../interfaces/external/validator-options.interface';
 import { PipeTransform } from '../interfaces/features/pipe-transform.interface';
+import { Type } from '../interfaces/type.interface';
 import {
   ErrorHttpStatusCode,
   HttpErrorByCode,
@@ -20,6 +21,7 @@ export interface ValidationPipeOptions extends ValidatorOptions {
   errorHttpStatusCode?: ErrorHttpStatusCode;
   exceptionFactory?: (errors: ValidationError[]) => any;
   validateCustomDecorators?: boolean;
+  expectedType?: Type<any>;
 }
 
 let classValidator: any = {};
@@ -32,6 +34,7 @@ export class ValidationPipe implements PipeTransform<any> {
   protected validatorOptions: ValidatorOptions;
   protected transformOptions: ClassTransformOptions;
   protected errorHttpStatusCode: ErrorHttpStatusCode;
+  protected expectedType: Type<any>;
   protected exceptionFactory: (errors: ValidationError[]) => any;
   protected validateCustomDecorators: boolean;
 
@@ -41,6 +44,7 @@ export class ValidationPipe implements PipeTransform<any> {
       transform,
       disableErrorMessages,
       errorHttpStatusCode,
+      expectedType,
       transformOptions,
       validateCustomDecorators,
       ...validatorOptions
@@ -52,19 +56,32 @@ export class ValidationPipe implements PipeTransform<any> {
     this.isDetailedOutputDisabled = disableErrorMessages;
     this.validateCustomDecorators = validateCustomDecorators || false;
     this.errorHttpStatusCode = errorHttpStatusCode || HttpStatus.BAD_REQUEST;
+    this.expectedType = expectedType;
     this.exceptionFactory =
       options.exceptionFactory || this.createExceptionFactory();
 
-    classValidator = loadPackage('class-validator', 'ValidationPipe', () =>
+    classValidator = this.loadValidator();
+    classTransformer = this.loadTransformer();
+  }
+
+  protected loadValidator() {
+    return loadPackage('class-validator', 'ValidationPipe', () =>
       require('class-validator'),
     );
-    classTransformer = loadPackage('class-transformer', 'ValidationPipe', () =>
+  }
+
+  protected loadTransformer() {
+    return loadPackage('class-transformer', 'ValidationPipe', () =>
       require('class-transformer'),
     );
   }
 
   public async transform(value: any, metadata: ArgumentMetadata) {
-    const { metatype } = metadata;
+    if (this.expectedType) {
+      metadata = { ...metadata, metatype: this.expectedType };
+    }
+
+    const metatype = metadata.metatype;
     if (!metatype || !this.toValidate(metadata)) {
       return this.isTransformEnabled
         ? this.transformPrimitive(value, metadata)
@@ -96,7 +113,7 @@ export class ValidationPipe implements PipeTransform<any> {
 
     const errors = await classValidator.validate(entity, this.validatorOptions);
     if (errors.length > 0) {
-      throw this.exceptionFactory(errors);
+      throw await this.exceptionFactory(errors);
     }
     if (isPrimitive) {
       // if the value is a primitive value and the validation process has been successfully completed
@@ -125,16 +142,16 @@ export class ValidationPipe implements PipeTransform<any> {
     };
   }
 
-  private toValidate(metadata: ArgumentMetadata): boolean {
+  protected toValidate(metadata: ArgumentMetadata): boolean {
     const { metatype, type } = metadata;
     if (type === 'custom' && !this.validateCustomDecorators) {
       return false;
     }
-    const types = [String, Boolean, Number, Array, Object];
+    const types = [String, Boolean, Number, Array, Object, Buffer];
     return !types.some(t => metatype === t) && !isNil(metatype);
   }
 
-  private transformPrimitive(value: any, metadata: ArgumentMetadata) {
+  protected transformPrimitive(value: any, metadata: ArgumentMetadata) {
     if (!metadata.data) {
       // leave top-level query/param objects unmodified
       return value;
@@ -152,11 +169,11 @@ export class ValidationPipe implements PipeTransform<any> {
     return value;
   }
 
-  private toEmptyIfNil<T = any, R = any>(value: T): R | {} {
+  protected toEmptyIfNil<T = any, R = any>(value: T): R | {} {
     return isNil(value) ? {} : value;
   }
 
-  private stripProtoKeys(value: Record<string, any>) {
+  protected stripProtoKeys(value: Record<string, any>) {
     delete value.__proto__;
     const keys = Object.keys(value);
     iterate(keys)
@@ -164,11 +181,11 @@ export class ValidationPipe implements PipeTransform<any> {
       .forEach(key => this.stripProtoKeys(value[key]));
   }
 
-  private isPrimitive(value: unknown): boolean {
+  protected isPrimitive(value: unknown): boolean {
     return ['number', 'boolean', 'string'].includes(typeof value);
   }
 
-  private flattenValidationErrors(
+  protected flattenValidationErrors(
     validationErrors: ValidationError[],
   ): string[] {
     return iterate(validationErrors)
@@ -180,7 +197,7 @@ export class ValidationPipe implements PipeTransform<any> {
       .toArray();
   }
 
-  private mapChildrenToValidationErrors(
+  protected mapChildrenToValidationErrors(
     error: ValidationError,
   ): ValidationError[] {
     if (!(error.children && error.children.length)) {
@@ -196,7 +213,7 @@ export class ValidationPipe implements PipeTransform<any> {
     return validationErrors;
   }
 
-  private prependConstraintsWithParentProp(
+  protected prependConstraintsWithParentProp(
     parentError: ValidationError,
     error: ValidationError,
   ): ValidationError {

packages/common/serializer/class-serializer.interceptor.ts

@@ -1,10 +1,10 @@
 import { Observable } from 'rxjs';
 import { map } from 'rxjs/operators';
-import { Inject, Injectable } from '../decorators/core';
+import { Inject, Injectable, Optional } from '../decorators/core';
+import { CallHandler, ExecutionContext, NestInterceptor } from '../interfaces';
 import { ClassTransformOptions } from '../interfaces/external/class-transform-options.interface';
 import { loadPackage } from '../utils/load-package.util';
 import { isObject } from '../utils/shared.utils';
-import { CallHandler, ExecutionContext, NestInterceptor } from '../interfaces';
 import { CLASS_SERIALIZER_OPTIONS } from './class-serializer.constants';
 
 let classTransformer: any = {};
@@ -20,7 +20,10 @@ const REFLECTOR = 'Reflector';
 
 @Injectable()
 export class ClassSerializerInterceptor implements NestInterceptor {
-  constructor(@Inject(REFLECTOR) protected readonly reflector: any) {
+  constructor(
+    @Inject(REFLECTOR) protected readonly reflector: any,
+    @Optional() protected readonly defaultOptions: ClassTransformOptions = {},
+  ) {
     classTransformer = loadPackage(
       'class-transformer',
       'ClassSerializerInterceptor',
@@ -30,7 +33,11 @@ export class ClassSerializerInterceptor implements NestInterceptor {
   }
 
   intercept(context: ExecutionContext, next: CallHandler): Observable<any> {
-    const options = this.getContextOptions(context);
+    const contextOptions = this.getContextOptions(context);
+    const options = {
+      ...this.defaultOptions,
+      ...contextOptions,
+    };
     return next
       .handle()
       .pipe(

packages/common/services/logger.service.ts

@@ -1,10 +1,9 @@
-import * as clc from 'cli-color';
 import { Injectable } from '../decorators/core/injectable.decorator';
 import { Optional } from '../decorators/core/optional.decorator';
+import { clc, yellow } from '../utils/cli-colors.util';
 import { isObject } from '../utils/shared.utils';
 
 declare const process: any;
-const yellow = clc.xterm(3);
 
 export type LogLevel = 'log' | 'error' | 'warn' | 'debug' | 'verbose';
 
@@ -26,7 +25,7 @@ export class Logger implements LoggerService {
     'verbose',
   ];
   private static lastTimestamp?: number;
-  private static instance?: typeof Logger | LoggerService = Logger;
+  protected static instance?: typeof Logger | LoggerService = Logger;
 
   constructor(
     @Optional() protected context?: string,
@@ -62,6 +61,10 @@ export class Logger implements LoggerService {
     this.context = context;
   }
 
+  getTimestamp() {
+    return Logger.getTimestamp();
+  }
+
   static overrideLogger(logger: LoggerService | LogLevel[] | boolean) {
     if (Array.isArray(logger)) {
       this.logLevels = logger;
@@ -96,6 +99,18 @@ export class Logger implements LoggerService {
     this.printMessage(message, clc.cyanBright, context, isTimeDiffEnabled);
   }
 
+  static getTimestamp() {
+    const localeStringOptions = {
+      year: 'numeric',
+      hour: 'numeric',
+      minute: 'numeric',
+      second: 'numeric',
+      day: '2-digit',
+      month: '2-digit',
+    };
+    return new Date(Date.now()).toLocaleString(undefined, localeStringOptions);
+  }
+
   private callFunction(
     name: 'log' | 'warn' | 'debug' | 'verbose',
     message: any,
@@ -115,7 +130,7 @@ export class Logger implements LoggerService {
       );
   }
 
-  private getInstance(): typeof Logger | LoggerService {
+  protected getInstance(): typeof Logger | LoggerService {
     const { instance } = Logger;
     return instance === this ? Logger : instance;
   }
@@ -134,25 +149,12 @@ export class Logger implements LoggerService {
       ? `${color('Object:')}\n${JSON.stringify(message, null, 2)}\n`
       : color(message);
 
-    const localeStringOptions = {
-      year: 'numeric',
-      hour: 'numeric',
-      minute: 'numeric',
-      second: 'numeric',
-      day: '2-digit',
-      month: '2-digit',
-    };
-    const timestamp = new Date(Date.now()).toLocaleString(
-      undefined,
-      localeStringOptions,
-    );
-
     const pidMessage = color(`[Nest] ${process.pid}   - `);
     const contextMessage = context ? yellow(`[${context}] `) : '';
     const timestampDiff = this.updateAndGetTimestampDiff(isTimeDiffEnabled);
-
+    const instance = this.instance as typeof Logger;
     process.stdout.write(
-      `${pidMessage}${timestamp}   ${contextMessage}${output}${timestampDiff}\n`,
+      `${pidMessage}${instance.getTimestamp()}   ${contextMessage}${output}${timestampDiff}\n`,
     );
   }
 

packages/common/test/decorators/bind.decorator.spec.ts

@@ -1,6 +1,6 @@
 import { expect } from 'chai';
+import { ROUTE_ARGS_METADATA } from '../../constants';
 import { Bind } from '../../decorators/core/bind.decorator';
-import { ROUTE_ARGS_METADATA } from '@nestjs/common/constants';
 import { Req } from '../../decorators/http/route-params.decorator';
 
 describe('@Bind', () => {

packages/common/test/decorators/create-param-decorator.spec.ts

@@ -1,7 +1,7 @@
-import { ParseIntPipe } from '@nestjs/common';
-import { ROUTE_ARGS_METADATA } from '@nestjs/common/constants';
 import { expect } from 'chai';
+import { ROUTE_ARGS_METADATA } from '../../constants';
 import { createParamDecorator } from '../../decorators/http/create-route-param-metadata.decorator';
+import { ParseIntPipe } from '../../index';
 
 describe('createParamDecorator', () => {
   let result;

packages/common/test/decorators/redirect.decorator.spec.ts

@@ -1,7 +1,7 @@
 import { expect } from 'chai';
-import { Redirect } from '../../decorators/http/redirect.decorator';
 import { REDIRECT_METADATA } from '../../constants';
-import { HttpStatus } from '@nestjs/common';
+import { Redirect } from '../../decorators/http/redirect.decorator';
+import { HttpStatus } from '../../index';
 
 describe('@Redirect', () => {
   const url = 'http://test.com';

packages/common/test/decorators/sse.decorator.spec.ts

@@ -0,0 +1,23 @@
+import { expect } from 'chai';
+import { METHOD_METADATA, PATH_METADATA, SSE_METADATA } from '../../constants';
+import { Sse } from '../../decorators/http/sse.decorator';
+import { RequestMethod } from '../../enums/request-method.enum';
+
+describe('@Sse', () => {
+  const prefix = '/prefix';
+  class Test {
+    @Sse(prefix)
+    public static test() {}
+  }
+
+  it('should enhance method with expected http status code', () => {
+    const path = Reflect.getMetadata(PATH_METADATA, Test.test);
+    expect(path).to.be.eql('/prefix');
+
+    const method = Reflect.getMetadata(METHOD_METADATA, Test.test);
+    expect(method).to.be.eql(RequestMethod.GET);
+
+    const metadata = Reflect.getMetadata(SSE_METADATA, Test.test);
+    expect(metadata).to.be.eql(true);
+  });
+});

packages/common/test/decorators/use-guards.decorator.spec.ts

@@ -8,17 +8,17 @@ class Guard {}
 describe('@UseGuards', () => {
   const guards = [Guard, Guard];
 
-  @UseGuards(...(guards as any))
+  @UseGuards(...guards)
   class Test {}
 
   class TestWithMethod {
-    @UseGuards(...(guards as any))
+    @UseGuards(...guards)
     public static test() {}
   }
 
   class Test2 {
-    @UseGuards(...(guards as any))
-    @UseGuards(...(guards as any))
+    @UseGuards(...guards)
+    @UseGuards(...guards)
     public static test() {}
   }
 
@@ -32,12 +32,12 @@ describe('@UseGuards', () => {
     expect(metadata).to.be.eql(guards);
   });
 
-  it('should enhance class with multiple guards array', () => {
+  it('should enhance method with multiple guards array', () => {
     const metadata = Reflect.getMetadata(GUARDS_METADATA, Test2.test);
     expect(metadata).to.be.eql(guards.concat(guards));
   });
 
-  it('when object is invalid should throw exception', () => {
+  it('should throw exception when object is invalid', () => {
     try {
       UseGuards('test' as any)(() => {});
     } catch (e) {

packages/common/test/decorators/use-interceptors.decorator.spec.ts

@@ -8,11 +8,11 @@ class Interceptor {}
 describe('@UseInterceptors', () => {
   const interceptors = [Interceptor, Interceptor];
 
-  @UseInterceptors(...(interceptors as any))
+  @UseInterceptors(...interceptors)
   class Test {}
 
   class TestWithMethod {
-    @UseInterceptors(...(interceptors as any))
+    @UseInterceptors(...interceptors)
     public static test() {}
   }
 

packages/common/test/decorators/use-pipes.decorator.spec.ts

@@ -10,11 +10,11 @@ class Pipe {
 describe('@UsePipes', () => {
   const pipes = [new Pipe(), new Pipe()];
 
-  @UsePipes(...(pipes as any))
+  @UsePipes(...pipes)
   class Test {}
 
   class TestWithMethod {
-    @UsePipes(...(pipes as any))
+    @UsePipes(...pipes)
     public static test() {}
   }
 

packages/common/test/http/http.service.spec.ts

@@ -0,0 +1,18 @@
+import { expect } from 'chai';
+import { HttpService } from '../../http/http.service';
+import { AxiosRequestConfig, AxiosInstance } from 'axios';
+
+describe('HttpService', () => {
+  it('should not mutate user-given axios options object', done => {
+    const http = new HttpService({ get: () => Promise.resolve() } as any);
+    const options: AxiosRequestConfig = {};
+
+    http
+      .get('/', options)
+      .toPromise()
+      .then(() => {
+        expect(options.cancelToken).to.be.undefined;
+        done();
+      });
+  });
+});

packages/common/test/pipes/default-value.pipe.spec.ts

@@ -0,0 +1,20 @@
+import { expect } from 'chai';
+import { DefaultValuePipe } from '../../pipes/default-value.pipe';
+
+describe('DefaultValuePipe', () => {
+  const defaultValue = 'default';
+  const target = new DefaultValuePipe(defaultValue);
+
+  describe('transform', () => {
+    it('should return original value if one was provided', () => {
+      const value = 'value';
+      const result = target.transform(value);
+      expect(result).to.equal(value);
+    });
+
+    it('should return default value if no value was provided', () => {
+      const result = target.transform(undefined);
+      expect(result).to.equal(defaultValue);
+    });
+  });
+});

packages/common/test/pipes/validation.pipe.spec.ts

@@ -396,4 +396,44 @@ describe('ValidationPipe', () => {
       });
     });
   });
+
+  describe('option: "expectedType"', () => {
+    class TestModel2 {
+      @IsString()
+      public prop1: string;
+
+      @IsBoolean()
+      public prop2: boolean;
+
+      @IsOptional()
+      @IsString()
+      public optionalProp: string;
+    }
+
+    it('should validate against the expected type if presented', async () => {
+      const m: ArgumentMetadata = {
+        type: 'body',
+        metatype: TestModel2,
+        data: '',
+      };
+
+      target = new ValidationPipe({ expectedType: TestModel });
+      const testObj = { prop1: 'value1', prop2: 'value2' };
+
+      expect(await target.transform(testObj, m)).to.equal(testObj);
+    });
+
+    it('should validate against the expected type if presented and metatype is primitive type', async () => {
+      const m: ArgumentMetadata = {
+        type: 'body',
+        metatype: String,
+        data: '',
+      };
+
+      target = new ValidationPipe({ expectedType: TestModel });
+      const testObj = { prop1: 'value1', prop2: 'value2' };
+
+      expect(await target.transform(testObj, m)).to.equal(testObj);
+    });
+  });
 });

packages/common/test/utils/shared.utils.spec.ts

@@ -1,14 +1,14 @@
 import { expect } from 'chai';
 import {
-  isUndefined,
-  isFunction,
-  isObject,
-  isString,
+  addLeadingSlash,
   isConstructor,
-  validatePath,
-  isNil,
   isEmpty,
+  isFunction,
+  isNil,
+  isObject,
   isPlainObject,
+  isString,
+  isUndefined,
 } from '../../utils/shared.utils';
 
 function Foo(a) {
@@ -81,17 +81,17 @@ describe('Shared utils', () => {
       expect(isConstructor('nope')).to.be.false;
     });
   });
-  describe('validatePath', () => {
+  describe('addLeadingSlash', () => {
     it('should returns validated path ("add / if not exists")', () => {
-      expect(validatePath('nope')).to.be.eql('/nope');
+      expect(addLeadingSlash('nope')).to.be.eql('/nope');
     });
     it('should returns same path', () => {
-      expect(validatePath('/nope')).to.be.eql('/nope');
+      expect(addLeadingSlash('/nope')).to.be.eql('/nope');
     });
     it('should returns empty path', () => {
-      expect(validatePath('')).to.be.eql('');
-      expect(validatePath(null)).to.be.eql('');
-      expect(validatePath(undefined)).to.be.eql('');
+      expect(addLeadingSlash('')).to.be.eql('');
+      expect(addLeadingSlash(null)).to.be.eql('');
+      expect(addLeadingSlash(undefined)).to.be.eql('');
     });
   });
   describe('isNil', () => {

packages/common/utils/cli-colors.util.ts

@@ -0,0 +1,16 @@
+type ColorTextFn = (text: string) => string;
+
+const isColorAllowed = () => !process.env.NO_COLOR;
+const colorIfAllowed = (colorFn: ColorTextFn) => (text: string) =>
+  isColorAllowed() ? colorFn(text) : text;
+
+export const clc = {
+  green: colorIfAllowed((text: string) => `\x1B[32m${text}\x1B[39m`),
+  yellow: colorIfAllowed((text: string) => `\x1B[33m${text}\x1B[39m`),
+  red: colorIfAllowed((text: string) => `\x1B[31m${text}\x1B[39m`),
+  magentaBright: colorIfAllowed((text: string) => `\x1B[95m${text}\x1B[39m`),
+  cyanBright: colorIfAllowed((text: string) => `\x1B[96m${text}\x1B[39m`),
+};
+export const yellow = colorIfAllowed(
+  (text: string) => `\x1B[38;5;3m${text}\x1B[39m`,
+);

packages/common/utils/http-error-by-code.util.ts

@@ -13,6 +13,7 @@ import {
   NotFoundException,
   NotImplementedException,
   PayloadTooLargeException,
+  PreconditionFailedException,
   RequestTimeoutException,
   ServiceUnavailableException,
   UnauthorizedException,
@@ -35,6 +36,7 @@ export type ErrorHttpStatusCode =
   | HttpStatus.NOT_FOUND
   | HttpStatus.NOT_IMPLEMENTED
   | HttpStatus.PAYLOAD_TOO_LARGE
+  | HttpStatus.PRECONDITION_FAILED
   | HttpStatus.REQUEST_TIMEOUT
   | HttpStatus.SERVICE_UNAVAILABLE
   | HttpStatus.UNAUTHORIZED
@@ -55,6 +57,7 @@ export const HttpErrorByCode: Record<ErrorHttpStatusCode, Type<unknown>> = {
   [HttpStatus.NOT_FOUND]: NotFoundException,
   [HttpStatus.NOT_IMPLEMENTED]: NotImplementedException,
   [HttpStatus.PAYLOAD_TOO_LARGE]: PayloadTooLargeException,
+  [HttpStatus.PRECONDITION_FAILED]: PreconditionFailedException,
   [HttpStatus.REQUEST_TIMEOUT]: RequestTimeoutException,
   [HttpStatus.SERVICE_UNAVAILABLE]: ServiceUnavailableException,
   [HttpStatus.UNAUTHORIZED]: UnauthorizedException,

packages/common/utils/shared.utils.ts

@@ -24,7 +24,7 @@ export const isPlainObject = (fn: any): fn is object => {
   );
 };
 
-export const validatePath = (path?: string): string =>
+export const addLeadingSlash = (path?: string): string =>
   path ? (path.charAt(0) !== '/' ? '/' + path : path) : '';
 
 export const isFunction = (fn: any): boolean => typeof fn === 'function';

packages/core/Readme.md

@@ -38,6 +38,14 @@ 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:
 
+## Questions
+
+For questions and support please use the official [Discord channel](https://discord.gg/G7Qnnhy). The issue list of this repo is **exclusively** for bug reports and feature requests.
+
+## Issues
+
+Please make sure to read the [Issue Reporting Checklist](https://github.com/nestjs/nest/blob/master/CONTRIBUTING.md#-submitting-an-issue) before opening an issue. Issues not conforming to the guidelines may be closed immediately.
+
 ## Consulting
 
 With official support, you can get expert help straight from Nest core team. We provide dedicated technical support, migration strategies, advice on best practices (and design decisions), PR reviews, and team augmentation. Read more about [support here](https://enterprise.nestjs.com).
@@ -46,32 +54,43 @@ With official support, you can get expert help straight from Nest core team. We
 
 Nest is an MIT-licensed open source project. It can grow thanks to the sponsors and support by the amazing backers. If you'd like to join them, please [read more here](https://docs.nestjs.com/support).
 
-#### Principal Sponsor
-
-<a href="https://valor-software.com/" target="_blank"><img src="https://docs.nestjs.com/assets/sponsors/valor-software.png" width="320" /></a>
+#### Principal Sponsors
+<table style="text-align:center;"><tr><td>
+<a href="https://github.com/Sanofi-IADC" target="_blank"><img src="https://docs.nestjs.com/assets/sponsors/sanofi.png" width="180" 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="180" valign="middle" /></a></td>
+</tr></table>
 
 #### Silver Sponsors
-<a href="https://neoteric.eu/" target="_blank"><img src="https://nestjs.com/img/neoteric-cut.png" width="120" valign="middle" /></a> &nbsp;
-  <a href="http://gojob.com" target="_blank"><img src="http://nestjs.com/img/gojob-logo.png" valign="middle" height="95" /></a> &nbsp; 
-    <a href="https://trilon.io" target="_blank"><img src="https://nestjs.com/img/trilon.svg" width="150" valign="middle" /></a> &nbsp;
-<a href="http://www.leogistics.com" target="_blank"><img src="https://nestjs.com/img/leogistics-logo.jpeg" width="150" valign="middle" /></a>
+
+<table style="text-align:center;"><tr><td>
+<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="https://trilon.io" target="_blank"><img src="https://nestjs.com/img/trilon.svg" width="170" valign="middle" /></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>
 
 #### Sponsors
 
-<a href="https://www.swingdev.io" target="_blank"><img src="https://nestjs.com/img/swingdev-logo.svg#1" width="110" valign="middle" /> </a> &nbsp; <a href="https://blueanchor.io/" target="_blank"><img src="https://nestjs.com/img/blueanchor.png" width="150" valign="middle" /></a> &nbsp;
-<a href="https://www.novologic.com/" target="_blank"><img src="https://nestjs.com/img/novologic.png" width="110" valign="middle" /></a> &nbsp; <a href="https://hostpresto.com" target="_blank"><img src="https://nestjs.com/img/hostpresto.png" height="24" valign="middle" /></a>
-<a href="https://ever.co/" target="_blank"><img src="https://nestjs.com/img/ever-logo.png" height="14" valign="middle" /></a>  &nbsp; 
-<a href="https://buddy.works/" target="_blank"><img src="https://nestjs.com/img/buddy-logo.svg" height="25" valign="middle" /></a> &nbsp;
-<a href="https://blokt.com" target="_blank"><img src="https://nestjs.com/img/blokt-logo.png" height="25" valign="middle" /></a>  &nbsp;  <a href="https://genuinebee.com/" target="_blank"><img src="https://nestjs.com/img/genuinebee.svg" height="27" valign="middle" /></a> &nbsp; <a href="http://architectnow.net/" target="_blank"><img src="https://nestjs.com/img/architectnow.png" height="20" valign="middle" /></a> &nbsp; <a href="https://quander.io/" target="_blank"><img src="https://nestjs.com/img/quander.png" height="22" valign="middle" /></a> &nbsp; <a href="https://mantro.net/" target="_blank"><img src="https://nestjs.com/img/mantro-logo.svg" height="19" valign="middle" /></a> &nbsp; <a href="https://triplebyte.com/" target="_blank"><img src="https://nestjs.com/img/triplebyte.png" height="20" valign="middle" /></a> &nbsp; 
-<a href="https://reposit.co.uk/" target="_blank"><img src="https://nestjs.com/img/reposit-logo.png" height="18" valign="middle" /></a> &nbsp; &nbsp;
-<a href="https://nearpod.com/" target="_blank"><img src="https://nestjs.com/img/nearpod-logo.svg" width="100" valign="middle" /></a> &nbsp;
-<a href="https://clay.global/" target="_blank"><img src="https://nestjs.com/img/clay-logo.svg" width="75" valign="middle" /></a> &nbsp;
-<a href="https://firesticktricks.com" target="_blank"><img src="https://nestjs.com/img/firesticktricks-logo.png" width="120" valign="middle" /></a> &nbsp;
-<a href="https://www.codeguesser.co.uk" target="_blank"><img src="https://nestjs.com/img/codeguesser-logo.svg" width="120" valign="middle" /></a> &nbsp;
-<a href="https://tekhattan.com" target="_blank"><img src="https://nestjs.com/img/tekhattan-logo.png" width="110" valign="middle" /></a> &nbsp;
-<a href="https://f-a.nz/" target="_blank"><img src="https://nestjs.com/img/franz.svg" width="80" valign="middle" /></a> &nbsp;
-<a href="https://sparkfabrik.com/" target="_blank"><img src="https://nestjs.com/img/sparkfabrik-logo.png" width="120" valign="middle" /></a>
-
+<table><tr><td align="center" valign="middle">
+<a href="https://www.swingdev.io" target="_blank"><img src="https://nestjs.com/img/swingdev-logo.svg#1" width="110" valign="middle" /> </a></td><td align="center" valign="middle">
+<a href="https://www.novologic.com/" target="_blank"><img src="https://nestjs.com/img/novologic.png" width="110" valign="middle" /></a> </td><td align="center" valign="middle">
+<a href="https://ever.co/" target="_blank"><img src="https://nestjs.com/img/ever-logo.png" width="72" valign="middle" /></a>  </td><td align="center" valign="middle">
+<a href="https://blokt.com" target="_blank"><img src="https://nestjs.com/img/blokt-logo.png" width="120" valign="middle" /></a>  </td><td align="center" valign="middle"> 
+  <a href="http://architectnow.net/" target="_blank"><img src="https://nestjs.com/img/architectnow.png" width="125" valign="middle" /></a> </td><td align="center" valign="middle">
+  <a href="https://quander.io/" target="_blank"><img src="https://nestjs.com/img/quander.png" width="100" valign="middle" /></a> </td></tr><tr><td align="center" valign="middle">
+  <a href="https://mantro.net/" target="_blank"><img src="https://nestjs.com/img/mantro-logo.svg" width="95" valign="middle" /></a> </td><td align="center" valign="middle">
+  <a href="https://triplebyte.com/" target="_blank"><img src="https://nestjs.com/img/triplebyte.png" width="107" valign="middle" /></a> </td><td align="center" valign="middle">
+<a href="https://reposit.co.uk/" target="_blank"><img src="https://nestjs.com/img/reposit-logo.png" width="71" valign="middle" /></a></td><td align="center" valign="middle">
+<a href="https://nearpod.com/" target="_blank"><img src="https://nestjs.com/img/nearpod-logo.svg" width="100" valign="middle" /></a> </td><td align="center" valign="middle">
+<a href="https://clay.global/" target="_blank"><img src="https://nestjs.com/img/clay-logo.svg" width="75" valign="middle" /></a> </td><td align="center" valign="middle">
+<a href="https://firesticktricks.com" target="_blank"><img src="https://nestjs.com/img/firesticktricks-logo.png" width="120" valign="middle" /></a></td></tr><tr><td align="center" valign="middle">
+<a href="https://www.codeguesser.co.uk" target="_blank"><img src="https://nestjs.com/img/codeguesser-logo.svg" width="120" valign="middle" /></a> </td><td align="center" valign="middle">
+<a href="https://f-a.nz/" target="_blank"><img src="https://nestjs.com/img/franz.svg" width="80" valign="middle" /></a> </td><td align="center" valign="middle">
+<a href="https://sparkfabrik.com/" target="_blank"><img src="https://nestjs.com/img/sparkfabrik-logo.png" width="120" valign="middle" /></a></td><td align="center" valign="middle"><a href="https://www.thebigphonestore.co.uk/" target="_blank"><img src="https://nestjs.com/img/the-big-phone-store-logo.png" width="65" valign="middle" /></a></td>
+  <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>
+  </tr></table>
 
 ## Backers
 

packages/core/adapters/http-adapter.ts

@@ -15,6 +15,9 @@ export abstract class AbstractHttpAdapter<
 
   constructor(protected readonly instance: any) {}
 
+  // eslint-disable-next-line @typescript-eslint/no-empty-function
+  public async init() {}
+
   public use(...args: any[]) {
     return this.instance.use(...args);
   }
@@ -97,6 +100,8 @@ export abstract class AbstractHttpAdapter<
   abstract enableCors(options: CorsOptions, prefix?: string);
   abstract createMiddlewareFactory(
     requestMethod: RequestMethod,
-  ): (path: string, callback: Function) => any;
+  ):
+    | ((path: string, callback: Function) => any)
+    | Promise<(path: string, callback: Function) => any>;
   abstract getType(): string;
 }

packages/core/errors/exceptions/invalid-module.exception.ts

@@ -2,8 +2,7 @@ import { INVALID_MODULE_MESSAGE } from '../messages';
 import { RuntimeException } from './runtime.exception';
 
 export class InvalidModuleException extends RuntimeException {
-  constructor(trace: any[]) {
-    const scope = (trace || []).map(module => module.name).join(' -> ');
-    super(INVALID_MODULE_MESSAGE`${scope}`);
+  constructor(parentModule: any, index: number, scope: any[]) {
+    super(INVALID_MODULE_MESSAGE(parentModule, index, scope));
   }
 }

packages/core/errors/exceptions/undefined-forwardref.exception.ts

@@ -0,0 +1,9 @@
+import { UNDEFINED_FORWARDREF_MESSAGE } from '../messages';
+import { RuntimeException } from './runtime.exception';
+import { Type } from '@nestjs/common';
+
+export class UndefinedForwardRefException extends RuntimeException {
+  constructor(scope: Type<any>[]) {
+    super(UNDEFINED_FORWARDREF_MESSAGE(scope));
+  }
+}

packages/core/errors/exceptions/undefined-module.exception.ts

@@ -0,0 +1,8 @@
+import { RuntimeException } from './runtime.exception';
+import { UNDEFINED_MODULE_MESSAGE } from '../messages';
+
+export class UndefinedModuleException extends RuntimeException {
+  constructor(parentModule: any, index: number, scope: any[]) {
+    super(UNDEFINED_MODULE_MESSAGE(parentModule, index, scope));
+  }
+}

packages/core/errors/exceptions/unknown-element.exception.ts

@@ -1,7 +1,8 @@
 import { RuntimeException } from './runtime.exception';
 
 export class UnknownElementException extends RuntimeException {
-  constructor(name?: string) {
+  constructor(name?: string | symbol) {
+    name = name && name.toString();
     super(
       `Nest could not find ${
         name || 'given'

packages/core/errors/exceptions/unknown-export.exception.ts

@@ -2,7 +2,7 @@ import { UNKNOWN_EXPORT_MESSAGE } from '../messages';
 import { RuntimeException } from './runtime.exception';
 
 export class UnknownExportException extends RuntimeException {
-  constructor(token: string, module: string) {
-    super(UNKNOWN_EXPORT_MESSAGE(token, module));
+  constructor(token: string | symbol, moduleName: string) {
+    super(UNKNOWN_EXPORT_MESSAGE(token, moduleName));
   }
 }

packages/core/errors/messages.ts

@@ -37,6 +37,9 @@ const getDependencyName = (dependency: InjectorDependency): string =>
 const getModuleName = (module: Module) =>
   (module && getInstanceName(module.metatype)) || 'current';
 
+const stringifyScope = (scope: any[]): string =>
+  (scope || []).map(getInstanceName).join(' -> ');
+
 export const UNKNOWN_DEPENDENCIES_MESSAGE = (
   type: string | symbol,
   unknownDependencyContext: InjectorDependencyContext,
@@ -84,17 +87,50 @@ export const INVALID_MIDDLEWARE_MESSAGE = (
   name: string,
 ) => `The middleware doesn't provide the 'use' method (${name})`;
 
-export const INVALID_MODULE_MESSAGE = (
-  text: TemplateStringsArray,
-  scope: string,
-) =>
-  `Nest cannot create the module instance. Often, this is because of a circular dependency between modules. Use forwardRef() to avoid it.
+export const UNDEFINED_FORWARDREF_MESSAGE = (
+  scope: Type<any>[],
+) => `Nest cannot create the module instance. Often, this is because of a circular dependency between modules. Use forwardRef() to avoid it.
 
 (Read more: https://docs.nestjs.com/fundamentals/circular-dependency)
-Scope [${scope}]
-`;
+Scope [${stringifyScope(scope)}]
+  `;
+
+export const INVALID_MODULE_MESSAGE = (
+  parentModule: any,
+  index: number,
+  scope: any[],
+) => {
+  const parentModuleName = parentModule?.name || 'module';
+
+  return `Nest cannot create the ${parentModuleName} instance.
+Received an unexpected value at index [${index}] of the ${parentModuleName} "imports" array. 
+
+Scope [${stringifyScope(scope)}]`;
+};
+
+export const UNDEFINED_MODULE_MESSAGE = (
+  parentModule: any,
+  index: number,
+  scope: any[],
+) => {
+  const parentModuleName = parentModule?.name || 'module';
+
+  return `Nest cannot create the ${parentModuleName} instance.
+The module at index [${index}] of the ${parentModuleName} "imports" array is undefined.
+
+Potential causes:
+- A circular dependency between modules. Use forwardRef() to avoid it. Read more: https://docs.nestjs.com/fundamentals/circular-dependency
+- The module at index [${index}] is of type "undefined". Check your import statements and the type of the module.
+
+Scope [${stringifyScope(scope)}]`;
+};
+
+export const UNKNOWN_EXPORT_MESSAGE = (
+  token: string | symbol = 'item',
+  module: string,
+) => {
+  token = isSymbol(token) ? token.toString() : token;
 
-export const UNKNOWN_EXPORT_MESSAGE = (token = 'item', module: string) => {
   return `Nest cannot export a provider/module that is not a part of the currently processed module (${module}). Please verify whether the exported ${token} is available in this particular context.
 
 Possible Solutions:

packages/core/exceptions/exceptions-handler.ts

@@ -1,4 +1,4 @@
-import { HttpException } from '@nestjs/common';
+import { HttpException, Type } from '@nestjs/common';
 import { ExceptionFilterMetadata } from '@nestjs/common/interfaces/exceptions/exception-filter-metadata.interface';
 import { ArgumentsHost } from '@nestjs/common/interfaces/features/arguments-host.interface';
 import { isEmpty } from '@nestjs/common/utils/shared.utils';
@@ -26,14 +26,15 @@ export class ExceptionsHandler extends BaseExceptionFilter {
     exception: T,
     ctx: ArgumentsHost,
   ): boolean {
-    if (isEmpty(this.filters)) return false;
+    if (isEmpty(this.filters)) {
+      return false;
+    }
+    const isInstanceOf = (metatype: Type<unknown>) =>
+      exception instanceof metatype;
 
     const filter = this.filters.find(({ exceptionMetatypes }) => {
       const typeExists =
-        !exceptionMetatypes.length ||
-        exceptionMetatypes.some(
-          ExceptionMetatype => exception instanceof ExceptionMetatype,
-        );
+        !exceptionMetatypes.length || exceptionMetatypes.some(isInstanceOf);
       return typeExists;
     });
     filter && filter.func(exception, ctx);

packages/core/exceptions/external-exceptions-handler.ts

@@ -1,3 +1,4 @@
+import { Type } from '@nestjs/common';
 import { ExceptionFilterMetadata } from '@nestjs/common/interfaces/exceptions';
 import { ArgumentsHost } from '@nestjs/common/interfaces/features/arguments-host.interface';
 import { isEmpty } from '@nestjs/common/utils/shared.utils';
@@ -29,11 +30,13 @@ export class ExternalExceptionsHandler extends ExternalExceptionFilter {
     if (isEmpty(this.filters)) {
       return null;
     }
-    const isInstanceOf = metatype => exception instanceof metatype;
-    const filter = this.filters.find(({ exceptionMetatypes, func }) => {
-      const hasMetatype =
+    const isInstanceOf = (metatype: Type<unknown>) =>
+      exception instanceof metatype;
+
+    const filter = this.filters.find(({ exceptionMetatypes }) => {
+      const typeExists =
         !exceptionMetatypes.length || exceptionMetatypes.some(isInstanceOf);
-      return hasMetatype;
+      return typeExists;
     });
     return filter ? filter.func(exception, host) : null;
   }

packages/core/helpers/context-utils.ts

@@ -1,5 +1,8 @@
 import { ParamData } from '@nestjs/common';
-import { PARAMTYPES_METADATA } from '@nestjs/common/constants';
+import {
+  PARAMTYPES_METADATA,
+  RESPONSE_PASSTHROUGH_METADATA,
+} from '@nestjs/common/constants';
 import {
   ContextType,
   Controller,
@@ -38,6 +41,14 @@ export class ContextUtils {
     return Reflect.getMetadata(metadataKey, instance.constructor, methodName);
   }
 
+  public reflectPassthrough(instance: Controller, methodName: string): boolean {
+    return Reflect.getMetadata(
+      RESPONSE_PASSTHROUGH_METADATA,
+      instance.constructor,
+      methodName,
+    );
+  }
+
   public getArgumentsLength<T>(keys: string[], metadata: T): number {
     return Math.max(...keys.map(key => metadata[key].index)) + 1;
   }

packages/core/helpers/handler-metadata-storage.ts

@@ -1,11 +1,32 @@
 import { Type } from '@nestjs/common';
 import { Controller } from '@nestjs/common/interfaces';
+import { IncomingMessage } from 'http';
+import { Observable } from 'rxjs';
 import { CONTROLLER_ID_KEY } from '../injector/constants';
 import { ContextId } from '../injector/instance-wrapper';
+import { HeaderStream } from '../router/sse-stream';
 import { ParamProperties } from './context-utils';
 
 export const HANDLER_METADATA_SYMBOL = Symbol.for('handler_metadata:cache');
 
+export type HandleResponseFn = HandlerResponseBasicFn | HandleSseResponseFn;
+
+export type HandlerResponseBasicFn = <TResult, TResponse>(
+  result: TResult,
+  res: TResponse,
+  req?: any,
+) => any;
+
+export type HandleSseResponseFn = <
+  TResult extends Observable<unknown> = any,
+  TResponse extends HeaderStream = any,
+  TRequest extends IncomingMessage = any
+>(
+  result: TResult,
+  res: TResponse,
+  req: TRequest,
+) => any;
+
 export interface HandlerMetadata {
   argsLength: number;
   paramtypes: any[];
@@ -17,10 +38,7 @@ export interface HandlerMetadata {
     contextId?: ContextId,
     inquirerId?: string,
   ) => (ParamProperties & { metatype?: any })[];
-  fnHandleResponse: <TResult, TResponse>(
-    result: TResult,
-    res: TResponse,
-  ) => any;
+  fnHandleResponse: HandleResponseFn;
 }
 
 export class HandlerMetadataStorage<