chore(@nestjs) publish v8.2.5 release

chore(deps-dev): bump http-errors from 1.8.1 to 2.0.0

.circleci/config.yml

@@ -70,10 +70,15 @@ jobs:
     docker:
       - image: circleci/node:10
 
-  test_node_8:
+  test_node_14:
     <<: *unit-tests-template
     docker:
-      - image: circleci/node:8
+      - image: circleci/node:14
+    
+  test_node_16:
+    <<: *unit-tests-template
+    docker:
+      - image: circleci/node:16
 
   lint:
     working_directory: ~/nest
@@ -160,15 +165,18 @@ workflows:
   build-and-test:
     jobs:
       - build
+      - test_node_16:
+          requires:
+            - 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

@@ -9,7 +9,6 @@ module.exports = {
     'plugin:@typescript-eslint/eslint-recommended',
     'plugin:@typescript-eslint/recommended',
     'prettier',
-    'prettier/@typescript-eslint',
   ],
   root: true,
   env: {
@@ -19,6 +18,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/ISSUE_TEMPLATE/Bug_report.md

@@ -1,41 +0,0 @@
----
-name: "\U0001F41B Bug Report"
-about: "If something isn't working as expected \U0001F914."
-title: ''
-labels: 'type: potential issue :broken_heart:,needs triage'
-assignees: ''
-
----
-
-## Bug Report
-
-## Current behavior
-<!-- Describe how the issue manifests. -->
-
-## Input Code
-<!-- REPL or Repo link if applicable: -->
-
-```ts
-const your = (code) => here;
-```
-
-## Expected behavior
-<!-- A clear and concise description of what you expected to happen (or code). -->
-
-## Possible Solution
-<!--- Only if you have suggestions on a fix for the bug -->
-
-## Environment
-
-<pre><code>
-Nest version: X.Y.Z
-<!-- Check whether this is still an issue in the most recent Nest version -->
- 
-For Tooling issues:
-- Node version: XX  <!-- run `node --version` -->
-- Platform:  <!-- Mac, Linux, Windows -->
-
-Others:
-<!-- Anything else relevant?  Operating system version, IDE, package manager, ... -->
-</code></pre>
-

.github/ISSUE_TEMPLATE/Bug_report.yml

@@ -0,0 +1,142 @@
+name: "\U0001F41B Bug Report"
+description: "If something isn't working as expected \U0001F914"
+labels: ["needs triage"]
+body:
+  - type: markdown
+    attributes:
+      value: |
+        ## :warning: We use GitHub Issues to track bug reports, feature requests and regressions
+ 
+        If you are not sure that your issue is a bug, you could:
+
+        - read the [FAQ's common errors](https://docs.nestjs.com/faq/common-errors) page
+        - use our [Discord community](https://discord.gg/NestJS)
+        - use [StackOverflow using the tag `nestjs`](https://stackoverflow.com/questions/tagged/nestjs)
+        - If it's just a quick question you can ping [our Twitter](https://twitter.com/nestframework)
+
+        **NOTE:** You don't need to answer questions that you know that aren't relevant.
+
+        ---
+
+  - type: checkboxes
+    attributes:
+      label: "Is there an existing issue for this?"
+      description: "Please search [here](../issues?q=is%3Aissue) to see if an issue already exists for the bug you encountered"
+      options:
+      - label: "I have searched the existing issues"
+        required: true
+
+  - type: textarea
+    validations:
+      required: true
+    attributes:
+      label: "Current behavior"
+      description: "How the issue manifests?"
+
+  - type: input
+    validations:
+      required: true
+    attributes:
+      label: "Minimum reproduction code"
+      description: "An URL to some Git repository/[StackBlitz](https://stackblitz.com/fork/github/nestjs/typescript-starter)/[CodeSandbox](https://codesandbox.io/s/github/nestjs/typescript-starter/tree/master) project that reproduces your issue. [Wtf is a minimum reproduction?](https://jmcdo29.github.io/wtf-is-a-minimum-reproduction)"
+      placeholder: "https://github.com/..."
+
+  - type: textarea
+    attributes:
+      label: "Steps to reproduce"
+      description: |
+        How the issue manifests?
+        You could leave this blank if you alread write this in your reproduction code
+      placeholder: |
+        1. `npm ci`
+        2. `npm start:dev`
+        3. See error...
+
+  - type: textarea
+    validations:
+      required: true
+    attributes:
+      label: "Expected behavior"
+      description: "A clear and concise description of what you expected to happend (or code)"
+
+  - type: markdown
+    attributes:
+      value: |
+        ---
+
+  - type: checkboxes
+    validations:
+      required: true
+    attributes:
+      label: "Package"
+      description: |
+        Which package (or packages) do you think your issue is related to?
+        **Tip**: The first line of the stack trace can help you to figure out this
+
+        The package isn't listed below? Try to find its repository [here](https://github.com/orgs/nestjs/repositories) and open the issue there instead
+      options:
+        - label: "I don't know. Or some 3rd-party package"
+        - label: "<code>@nestjs/common</code>"
+        - label: "<code>@nestjs/core</code>"
+        - label: "<code>@nestjs/microservices</code>"
+        - label: "<code>@nestjs/platform-express</code>"
+        - label: "<code>@nestjs/platform-fastify</code>"
+        - label: "<code>@nestjs/platform-socket.io</code>"
+        - label: "<code>@nestjs/platform-ws</code>"
+        - label: "<code>@nestjs/testing</code>"
+        - label: "<code>@nestjs/websockets</code>"
+        - label: "Other (see below)"
+
+  - type: input
+    attributes:
+      label: "Other package"
+      description: "If your issue is related to some package that is not listed above nor under @nestjs org, write its name here"
+
+  - type: input
+    attributes:
+      label: "NestJS version"
+      description: |
+        Which version of `@nestjs/core` are you using?
+        **Tip**: Make sure that all of yours `@nestjs/*` dependencies are in sync!
+      placeholder: "8.1.3"
+
+  - type: textarea
+    validations:
+      required: true
+    attributes:
+      label: "Packages versions"
+      description: |
+        You could leave your whole `package.json` dependencies list here, or just indicate which version of `@nestjs/*` you are using
+        **Tip**: run _npx nest info_
+      value: |
+        ```json
+
+        ```
+
+  - type: input
+    attributes:
+      label: "Node.js version"
+      description: "Which version of Node.js are you using?"
+      placeholder: "14.17.6"
+
+  - type: checkboxes
+    validations:
+      required: true
+    attributes:
+      label: "In which operating systems have you tested?"
+      options:
+        - label: macOS
+        - label: Windows
+        - label: Linux
+
+  - type: markdown
+    attributes:
+      value: |
+        ---
+
+  - type: textarea
+    attributes:
+      label: "Other"
+      description: |
+        Anything else relevant? eg: Logs, OS version, IDE, package manager, etc.
+        **Tip:** You can attach images, recordings or log files by clicking this area to highlight it and then dragging files in

.github/ISSUE_TEMPLATE/Feature_request.md

@@ -1,22 +0,0 @@
----
-name: "\U0001F680 Feature Request"
-about: "I have a suggestion \U0001F63B!"
-title: ''
-labels: 'type: enhancement :wolf:,needs triage'
-assignees: ''
-
----
-
-## Feature Request
-
-## Is your feature request related to a problem? Please describe.
-<!-- A clear and concise description of what the problem is. Ex. I have an issue when [...] -->
-
-## Describe the solution you'd like
-<!-- A clear and concise description of what you want to happen. Add any considered drawbacks. -->
-
-## Teachability, Documentation, Adoption, Migration Strategy
-<!-- If you can, explain how users will be able to use this and possibly write out a version the docs. Maybe a screenshot or design? -->
-
-## What is the motivation / use case for changing the behavior?
-<!-- Describe the motivation or the concrete use case. -->

.github/ISSUE_TEMPLATE/Feature_request.yml

@@ -0,0 +1,55 @@
+name: "\U0001F680 Feature Request"
+description: "I have a suggestion \U0001F63B!"
+labels: ["type: enhancement :wolf:", "needs triage"]
+body:
+  - type: markdown
+    attributes:
+      value: |
+        ## :warning: We use GitHub Issues to track bug reports, feature requests and regressions
+ 
+        If you are not sure that your issue is a bug, you could:
+
+        - read the [FAQ's common errors](https://docs.nestjs.com/faq/common-errors) page
+        - use our [Discord community](https://discord.gg/NestJS)
+        - use [StackOverflow using the tag `nestjs`](https://stackoverflow.com/questions/tagged/nestjs)
+        - If it's just a quick question you can ping [our Twitter](https://twitter.com/nestframework)
+
+        ---
+
+  - type: checkboxes
+    attributes:
+      label: "Is there an existing issue that is already proposing this?"
+      description: "Please search [here](../issues?q=is%3Aissue) to see if an issue already exists for the feature you are requesting"
+      options:
+      - label: "I have searched the existing issues"
+        required: true
+
+  - type: textarea
+    validations:
+      required: true
+    attributes:
+      label: "Is your feature request related to a problem? Please describe it"
+      description: "A clear and concise description of what the problem is"
+      placeholder: |
+        I have an issue when ...
+
+  - type: textarea
+    validations:
+      required: true
+    attributes:
+      label: "Describe the solution you'd like"
+      description: "A clear and concise description of what you want to happen. Add any considered drawbacks"
+
+  - type: textarea
+    validations:
+      required: true
+    attributes:
+      label: "Teachability, documentation, adoption, migration strategy"
+      description: "If you can, explain how users will be able to use this and possibly write out a version the docs. Maybe a screenshot or design?"
+
+  - type: textarea
+    validations:
+      required: true
+    attributes:
+      label: "What is the motivation / use case for changing the behavior?"
+      description: "Describe the motivation or the concrete use case"

.github/ISSUE_TEMPLATE/Regression.md

@@ -1,40 +0,0 @@
----
-name: "\U0001F4A5 Regression"
-about: Report an unexpected while upgrading your Nest application!
-title: ''
-labels: 'type: bug :sob:,needs triage'
-assignees: ''
-
----
-
-## Regression
-
-<!-- First check out: https://docs.nestjs.com/migration-guide -->
-
-## Potential Commit/PR that introduced the regression**
-<!-- If you have time to investigate, what PR/date introduced this issue. -->
-
-## Describe the regression
-<!-- A clear and concise description of what the regression is. -->
-
-## Input Code
-<!--- If you have link to our REPL or a standalone repo please link that! -->
-
-```ts
-const your = (code) => here;
-```
-
-## Expected behavior/code
-<!-- A clear and concise description of what you expected to happen (or code). -->
-
-## Environment
-<pre><code>
-Nest version: A.B.C -> X.Y.Z
-
-For Tooling issues:
-- Node version: XX  <!-- run `node --version` -->
-- Platform:  <!-- Mac, Linux, Windows -->
-
-Others:
-<!-- Anything else relevant?  Operating system version, IDE, package manager, ... -->
-</code></pre>

.github/ISSUE_TEMPLATE/Regression.yml

@@ -0,0 +1,84 @@
+name: "\U0001F4A5 Regression"
+description: "Report an unexpected while upgrading your Nest application!"
+labels: ["type: bug :sob:", "needs triage"]
+body:
+  - type: markdown
+    attributes:
+      value: |
+        ## :warning: We use GitHub Issues to track bug reports, feature requests and regressions
+ 
+        If you are not sure that your issue is a bug, you could:
+
+        - read the [FAQ's common errors](https://docs.nestjs.com/faq/common-errors) page
+        - use our [Discord community](https://discord.gg/NestJS)
+        - use [StackOverflow using the tag `nestjs`](https://stackoverflow.com/questions/tagged/nestjs)
+        - If it's just a quick question you can ping [our Twitter](https://twitter.com/nestframework)
+
+        **NOTE:** You don't need to answer questions that you know that aren't relevant.
+
+        ---
+
+  - type: checkboxes
+    attributes:
+      label: "Did you read the migration guide?"
+      description: "Check out the [migration guide here](https://docs.nestjs.com/migration-guide)!"
+      options:
+      - label: "I have read the whole migration guide"
+        required: false
+
+  - type: checkboxes
+    attributes:
+      label: "Is there an existing issue that is already proposing this?"
+      description: "Please search [here](../issues?q=is%3Aissue) to see if an issue already exists for the feature you are requesting"
+      options:
+      - label: "I have searched the existing issues"
+        required: true
+
+  - type: input
+    attributes:
+      label: "Potential Commit/PR that introduced the regression"
+      description: "If you have time to investigate, what PR/date/version introduced this issue"
+      placeholder: "PR #123 or commit 5b3c4a4"
+
+  - type: input
+    validations:
+      required: true
+    attributes:
+      label: "NestJS version"
+      placeholder: "8.1.0 -> 8.1.3"
+
+  - type: textarea
+    validations:
+      required: true
+    attributes:
+      label: "Describe the regression"
+      description: "A clear and concise description of what the regression is"
+
+  - type: input
+    attributes:
+      label: "Minimum reproduction code"
+      description: "An URL to some git repository that reproduces this issue. [Wtf is a minimum reproduction?](https://jmcdo29.github.io/wtf-is-a-minimum-reproduction)"
+      placeholder: "https://github.com/..."
+
+  - type: textarea
+    attributes:
+      label: "Input code"
+      description: "Write some code snippets if you think it is worth it"
+      value: |
+        ```ts
+
+        ```
+
+  - type: textarea
+    validations:
+      required: true
+    attributes:
+      label: "Expected behavior"
+      description: "A clear and concise description of what you expected to happend (or code)"
+
+  - type: textarea
+    attributes:
+      label: "Other"
+      description: |
+        Anything else relevant? eg: Logs, OS version, IDE, package manager, etc.
+        **Tip:** You can attach images, recordings or log files by clicking this area to highlight it and then dragging files in

.github/ISSUE_TEMPLATE/Suggestion_improve_performance.yml

@@ -0,0 +1,48 @@
+title: "perf: "
+name: "\U0001F525 Suggestion for Improving Performance"
+description: "I have a suggestion that might improve the performance of Nest \U00002728"
+labels: ["type: enhancement :wolf:", "needs triage"]
+body:
+  - type: checkboxes
+    attributes:
+      label: "Is there an existing issue that is already proposing this?"
+      description: "Please search [here](../issues?q=is%3Aissue) to see if an issue already exists for this"
+      options:
+      - label: "I have searched the existing issues"
+        required: true
+
+  - type: input
+    validations:
+      required: true
+    attributes:
+      label: "NestJS version"
+      description: "Which version do you intend to improve?"
+      placeholder: "8.1.3"
+
+  - type: textarea
+    attributes:
+      label: "Is your performance suggestion related to a problem? Please describe it"
+      description: "A clear and concise description of what the problem is"
+
+  - type: textarea
+    validations:
+      required: true
+    attributes:
+      label: "Describe the performance enhancement you are proposing and how we can try it out"
+      placeholder: |
+        Cache `array.length` on the following lines ...
+
+  - type: textarea
+    validations:
+     required: true
+    attributes:
+      label: "Benchmarks result or another proof (eg: POC)"
+      description: |
+        If you've already prototyped a solution, share your results here
+        If not, what makes you believe there will be a performance improvement?
+      placeholder: |
+        ```
+        ```
+
+        MacBook Pro Mid 2014, 2.5 GHz Quad-Core Intel Core i7, 16 GB 1600 MHz DDR3, SSD
+

.github/ISSUE_TEMPLATE/Support_question.md

@@ -1,14 +0,0 @@
----
-name: "\U0001F917 Support Question"
-about: "If you have a question \U0001F4AC, please check out our Discord or StackOverflow!"
-title: ''
-labels: 'type: question 🙌,needs triage'
-assignees: ''
-
----
-
-<!-- We primarily use GitHub as an issue tracker; for usage and support questions, please check out these resources below. Thanks! 😁. -->
-
-* Discord Community Chat: https://discord.gg/G7Qnnhy
-* StackOverflow: https://stackoverflow.com/questions/tagged/nestjs using the tag `nestjs`
-* Twitter: If it's just a quick question you can ping our Twitter: https://twitter.com/nestframework

.github/ISSUE_TEMPLATE/config.yml

@@ -0,0 +1,10 @@
+## To encourage contributors to use issue templates, we don't allow blank issues
+blank_issues_enabled: false
+
+contact_links:
+  - name: "\u2049 FAQ"
+    url: "https://docs.nestjs.com/faq"
+    about: "Make sure you have read the Frequently Asked Questions page."
+  - name: "\u2753 Discord Community of NestJS"
+    url: "https://discord.gg/NestJS"
+    about: "Please ask support questions or discuss suggestions/enhancements here."

.github/PULL_REQUEST_TEMPLATE.md

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

.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

.husky/commit-msg

@@ -0,0 +1,4 @@
+#!/bin/sh
+. "$(dirname "$0")/_/husky.sh"
+
+npx --no-install commitlint --edit $1

.husky/pre-commit

@@ -0,0 +1,4 @@
+#!/bin/sh
+. "$(dirname "$0")/_/husky.sh"
+
+npx lint-staged

.mocharc.js

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

CONTRIBUTING.md

@@ -69,7 +69,7 @@ A minimal reproduce scenario using a repository or Gist allows us to quickly con
 
 <!-- We will be insisting on a minimal reproduce scenario in order to save maintainers time and ultimately be able to fix more bugs. Interestingly, from our experience users often find coding problems themselves while preparing a minimal plunk. We understand that sometimes it might be hard to extract essentials bits of code from a larger code-base but we really need to isolate the problem before we can fix it. -->
 
-Unfortunately, we are not able to investigate / fix bugs without a minimal reproduction, so if we don't hear back from you we are going to close an issue that don't have enough info to be reproduced.
+Unfortunately, we are not able to investigate / fix bugs without a minimal reproduction, so if we don't hear back from you we are going to close an issue that doesn't have enough info to be reproduced.
 
 You can file new issues by filling out our [new issue form](https://github.com/nestjs/nest/issues/new).
 
@@ -173,7 +173,7 @@ $ npm i # (or yarn install)
 $ sh scripts/prepare.sh
 ```
 
-That will compile fresh packages and afterward, move them to all `sample` directories as well as integration tests.
+That will compile fresh packages and afterward, move them all to `sample` directories.
 
 ### <a name="common-scripts"></a>Commonly used NPM scripts
 
@@ -228,7 +228,7 @@ format that includes a **type**, a **scope** and a **subject**:
 
 The **header** is mandatory and the **scope** of the header is optional.
 
-Any line of the commit message cannot be longer 100 characters! This allows the message to be easier
+Any line of the commit message cannot be longer than 100 characters! This allows the message to be easier
 to read on GitHub as well as in various git tools.
 
 Footer should contain a [closing reference to an issue](https://help.github.com/articles/closing-issues-via-commit-messages/) if any.
@@ -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-2022 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

@@ -37,6 +37,16 @@ Nest is a framework for building efficient, scalable <a href="http://nodejs.org"
 
 * To check out the [guide](https://docs.nestjs.com), visit [docs.nestjs.com](https://docs.nestjs.com). :books:
 * 要查看中文 [指南](readme_zh.md), 请访问 [docs.nestjs.cn](https://docs.nestjs.cn). :books:
+* [가이드](readme_kr.md)를 확인하려면, [docs.nestjs.com](https://docs.nestjs.com)를 방문하세요.:books: 
+* チェックするには [ガイド](readme_jp.md), 詳しくは [docs.nestjs.com](https://docs.nestjs.com). :books: 
+
+## Questions
+
+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
 
@@ -46,32 +56,69 @@ 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
+#### Principal Sponsors
+<table style="text-align:center;"><tr>
+  <td><a href="https://trilon.io" target="_blank"><img src="https://nestjs.com/img/trilon.svg" width="200" valign="middle" /></a></td>
+  <td><a href="https://www.redhat.com" target="_blank"><img src="https://nestjs.com/img/red-hat-logo.svg" width="200" valign="middle" /></a></td>
+<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://nx.dev" target="_blank"><img src="https://nestjs.com/img/nx-logo.png" height="45" valign="middle" /></a></td>
+</tr></table>
 
-<a href="https://valor-software.com/" target="_blank"><img src="https://docs.nestjs.com/assets/sponsors/valor-software.png" width="320" /></a>
+#### Gold Sponsors
+
+<table style="text-align:center;"><tr><td>
+  <a href="https://careers.labster.com/departments/platform" target="_blank"><img src="https://nestjs.com/img/labster-logo.png" width="170" valign="middle" /></a></td><td>
+<a href="https://weld.app/" target="_blank"><img src="https://nestjs.com/img/weld-logo.svg" width="150" valign="middle" /></a></td>
+  <td>
+<a href="https://valor-software.com/" target="_blank"><img src="https://docs.nestjs.com/assets/sponsors/valor-software.png" width="170" valign="middle" /></a></td>
+<td>
+<a href="https://intrinsic.ventures/" target="_blank"><img src="https://nestjs.com/img/intrinisic-logo.png" width="210" 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://www.myleodsc.com/" target="_blank"><img src="https://nestjs.com/img/myleo-logo.png" width="180" valign="middle" /></td><td>
+<a href="https://careers.meetdandy.com/?gh_src=063ba61e3us" target="_blank"><img src="https://nestjs.com/img/dandy-roles-logo.svg" width="150" valign="middle" /></td><td>
+<a href="https://www.castlecraft.in" target="_blank"><img src="https://nestjs.com/img/castlecraft-logo.png" width="150" valign="middle" /></td>
+<td><a href="https://www.tinystacks.com" target="_blank"><img src="https://nestjs.com/img/tinystacks-logo.png#1" width="140" 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>
+<td align="center" valign="middle"><a href="https://meercode.io/" target="_blank"><img src="https://nestjs.com/img/meercode-logo.png" width="60" valign="middle" /></a></td>
+  <td align="center" valign="middle"><a href="https://www.najlepszeplatformyforex.pl/blog/broker-xtb/" target="_blank"><img src="https://nestjs.com/img/npf-logo.jpg" width="200" valign="middle" /></a></td></tr><tr>
+<td align="center" valign="middle"><a href="https://thestandarddaily.com/" target="_blank"><img src="https://nestjs.com/img/the-standard-daily-logo.png" width="180" valign="middle" /></a></td>
+<td align="center" valign="middle"><a href="https://houseofangular.io/" target="_blank"><img src="https://nestjs.com/img/house-of-angular.png" width="100" valign="middle" /></a></td>
+<td align="center" valign="middle"><a href="https://rocketech.it/cases/?utm_source=google&utm_medium=badge&utm_campaign=nestjs" target="_blank"><img src="https://nestjs.com/img/rocketech-logo.svg" width="110" valign="middle" /></a></td>
+  <td align="center" valign="middle"><a href="https://www.bystored.com/" target="_blank"><img src="https://nestjs.com/img/stored-logo.svg" width="110" valign="middle" /></a></td>
+  <td align="center" valign="middle"><a href="https://studyclerk.com/pay-for-research-paper" target="_blank"><img src="https://nestjs.com/img/studyclerk-logo.png" width="125" valign="middle" /></a></td><td align="center" valign="middle"><a href="https://xyndata.com" target="_blank"><img src="https://nestjs.com/img/xyndata-logo.png" width="125" valign="middle" /></a></td></tr><tr>
+  <td align="center" valign="middle"><a href="https://www.anonymistic.com/" target="_blank"><img src="https://nestjs.com/img/anonymistic-logo.png" width="125" valign="middle" /></a></td>
+<td align="center" valign="middle"><a href="https://www.naologic.com/" target="_blank"><img src="https://nestjs.com/img/naologic-logo.svg" width="125" valign="middle" /></a></td>
+  <td align="center" valign="middle"><a href="https://messaged.com/" target="_blank"><img src="https://nestjs.com/img/messaged-logo.png" width="50" valign="middle" /></a></td>
+  <td align="center" valign="middle"><a href="https://triplecore.io" target="_blank"><img src="https://nestjs.com/img/triplecore-logo.svg" width="50" valign="middle" /></a></td>
+  </tr></table>
 
 ## Backers
 

SECURITY.md

@@ -0,0 +1,5 @@
+# Security Policy
+
+## Reporting a Vulnerability
+
+Please report security issues to `support@nestjs.com`.

benchmarks/all_output.txt

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

integration/auto-mock/src/bar.service.ts

@@ -0,0 +1,12 @@
+import { Injectable } from '@nestjs/common';
+import { FooService } from './foo.service';
+
+@Injectable()
+export class BarService {
+
+  constructor(private readonly foo: FooService) {}
+
+  bar() {
+    this.foo.foo();
+  }
+}

integration/auto-mock/src/foo.service.ts

@@ -0,0 +1,8 @@
+import { Injectable } from '@nestjs/common';
+
+@Injectable()
+export class FooService {
+  foo() {
+    console.log('foo called');
+  }
+}

integration/auto-mock/test/bar.service.spec.ts

@@ -0,0 +1,63 @@
+import { Test } from '@nestjs/testing';
+import * as chai from 'chai';
+import * as chaiAsPromised from 'chai-as-promised';
+import * as sinon from 'sinon';
+import { BarService } from '../src/bar.service';
+import { FooService } from '../src/foo.service';
+chai.use(chaiAsPromised);
+const { expect } = chai;
+
+describe('Auto-Mocking Bar Deps', () => {
+  let service: BarService;
+  let fooService: FooService;
+  const stub = sinon.stub();
+  beforeEach(async () => {
+    const moduleRef = await Test.createTestingModule({
+      providers: [BarService],
+    })
+      .useMocker(() => ({ foo: stub }))
+      .compile();
+    service = moduleRef.get(BarService);
+    fooService = moduleRef.get(FooService);
+  });
+
+  it('should be defined', () => {
+    expect(service).not.to.be.undefined;
+    expect(fooService).not.to.be.undefined;
+  });
+  it('should call bar.bar', () => {
+    service.bar();
+    expect(stub.called);
+  });
+});
+
+describe('Auto-Mocking with token in factory', () => {
+  it('can mock the dependencies', async () => {
+    const moduleRef = await Test.createTestingModule({
+      providers: [BarService],
+    })
+      .useMocker((token) => {
+        if (token === FooService) {
+          return { foo: sinon.stub };
+        }
+      })
+      .compile();
+    const service = moduleRef.get(BarService);
+    const fooServ = moduleRef.get<{ foo: sinon.SinonStub }>(FooService as any);
+    service.bar();
+    expect(fooServ.foo.called);
+  });
+  it('cannot mock the dependencies', async () => {
+
+    const moduleRef = Test.createTestingModule({
+      providers: [BarService],
+    })
+      .useMocker((token) => {
+        if (token === FooService.name + 'something that fails the token') {
+          return { foo: sinon.stub };
+        }
+      })
+      .compile;
+    expect(moduleRef()).to.eventually.throw()
+  });
+});

integration/auto-mock/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/cache/e2e/multi-store.spec.ts

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

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

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

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

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

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

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

integration/cors/e2e/express.spec.ts

@@ -0,0 +1,177 @@
+import { NestFastifyApplication } from '@nestjs/platform-fastify';
+import { Test } from '@nestjs/testing';
+import * as request from 'supertest';
+import { AppModule } from '../src/app.module';
+
+describe('Express Cors', () => {
+  let app: NestFastifyApplication;
+  const configs = [
+    {
+      origin: 'example.com',
+      methods: 'GET',
+      credentials: true,
+      exposedHeaders: ['foo', 'bar'],
+      allowedHeaders: ['baz', 'woo'],
+      maxAge: 123,
+    },
+    {
+      origin: 'sample.com',
+      methods: 'GET',
+      credentials: true,
+      exposedHeaders: ['zoo', 'bar'],
+      allowedHeaders: ['baz', 'foo'],
+      maxAge: 321,
+    },
+  ];
+  describe('Dynamic config', () => {
+    describe('enableCors', () => {
+      before(async () => {
+        const module = await Test.createTestingModule({
+          imports: [AppModule],
+        }).compile();
+
+        app = module.createNestApplication<NestFastifyApplication>();
+
+        let requestId = 0;
+        const configDelegation = function (req, cb) {
+          const config = configs[requestId];
+          requestId++;
+          cb(null, config);
+        };
+        app.enableCors(configDelegation);
+
+        await app.init();
+      });
+
+      it(`should add cors headers based on the first config`, async () => {
+        return request(app.getHttpServer())
+          .get('/')
+          .expect('access-control-allow-origin', 'example.com')
+          .expect('vary', 'Origin')
+          .expect('access-control-allow-credentials', 'true')
+          .expect('access-control-expose-headers', 'foo,bar')
+          .expect('content-length', '0');
+      });
+
+      it(`should add cors headers based on the second config`, async () => {
+        return request(app.getHttpServer())
+          .options('/')
+          .expect('access-control-allow-origin', 'sample.com')
+          .expect('vary', 'Origin')
+          .expect('access-control-allow-credentials', 'true')
+          .expect('access-control-expose-headers', 'zoo,bar')
+          .expect('access-control-allow-methods', 'GET')
+          .expect('access-control-allow-headers', 'baz,foo')
+          .expect('access-control-max-age', '321')
+          .expect('content-length', '0');
+      });
+
+      after(async () => {
+        await app.close();
+      });
+    });
+
+    describe('Application Options', () => {
+      before(async () => {
+        const module = await Test.createTestingModule({
+          imports: [AppModule],
+        }).compile();
+
+        let requestId = 0;
+        const configDelegation = function (req, cb) {
+          const config = configs[requestId];
+          requestId++;
+          cb(null, config);
+        };
+
+        app = module.createNestApplication<NestFastifyApplication>(null, {
+          cors: configDelegation,
+        });
+
+        await app.init();
+      });
+
+      it(`should add cors headers based on the first config`, async () => {
+        return request(app.getHttpServer())
+          .get('/')
+          .expect('access-control-allow-origin', 'example.com')
+          .expect('vary', 'Origin')
+          .expect('access-control-allow-credentials', 'true')
+          .expect('access-control-expose-headers', 'foo,bar')
+          .expect('content-length', '0');
+      });
+
+      it(`should add cors headers based on the second config`, async () => {
+        return request(app.getHttpServer())
+          .options('/')
+          .expect('access-control-allow-origin', 'sample.com')
+          .expect('vary', 'Origin')
+          .expect('access-control-allow-credentials', 'true')
+          .expect('access-control-expose-headers', 'zoo,bar')
+          .expect('access-control-allow-methods', 'GET')
+          .expect('access-control-allow-headers', 'baz,foo')
+          .expect('access-control-max-age', '321')
+          .expect('content-length', '0');
+      });
+
+      after(async () => {
+        await app.close();
+      });
+    });
+  });
+  describe('Static config', () => {
+    describe('enableCors', () => {
+      before(async () => {
+        const module = await Test.createTestingModule({
+          imports: [AppModule],
+        }).compile();
+
+        app = module.createNestApplication<NestFastifyApplication>();
+        app.enableCors(configs[0]);
+
+        await app.init();
+      });
+
+      it(`CORS headers`, async () => {
+        return request(app.getHttpServer())
+          .get('/')
+          .expect('access-control-allow-origin', 'example.com')
+          .expect('vary', 'Origin')
+          .expect('access-control-allow-credentials', 'true')
+          .expect('access-control-expose-headers', 'foo,bar')
+          .expect('content-length', '0');
+      });
+    });
+
+    after(async () => {
+      await app.close();
+    });
+
+    describe('Application Options', () => {
+      before(async () => {
+        const module = await Test.createTestingModule({
+          imports: [AppModule],
+        }).compile();
+
+        app = module.createNestApplication<NestFastifyApplication>(null, {
+          cors: configs[0],
+        });
+        await app.init();
+      });
+
+      it(`CORS headers`, async () => {
+        return request(app.getHttpServer())
+          .get('/')
+          .expect('access-control-allow-origin', 'example.com')
+          .expect('vary', 'Origin')
+          .expect('access-control-allow-credentials', 'true')
+          .expect('access-control-expose-headers', 'foo,bar')
+          .expect('content-length', '0');
+      });
+
+      after(async () => {
+        await app.close();
+      });
+    });
+  });
+});

integration/cors/e2e/fastify.spec.ts

@@ -0,0 +1,178 @@
+import { NestFastifyApplication } from '@nestjs/platform-fastify';
+import { Test } from '@nestjs/testing';
+import * as request from 'supertest';
+import { AppModule } from '../src/app.module';
+
+describe('Fastify Cors', () => {
+  let app: NestFastifyApplication;
+  const configs = [
+    {
+      origin: 'example.com',
+      methods: 'GET',
+      credentials: true,
+      exposedHeaders: ['foo', 'bar'],
+      allowedHeaders: ['baz', 'woo'],
+      maxAge: 123,
+    },
+    {
+      origin: 'sample.com',
+      methods: 'GET',
+      credentials: true,
+      exposedHeaders: ['zoo', 'bar'],
+      allowedHeaders: ['baz', 'foo'],
+      maxAge: 321,
+    },
+  ];
+  describe('Dynamic config', () => {
+    describe('enableCors', () => {
+      before(async () => {
+        const module = await Test.createTestingModule({
+          imports: [AppModule],
+        }).compile();
+
+        app = module.createNestApplication<NestFastifyApplication>();
+
+        let requestId = 0;
+        const configDelegation = function (req, cb) {
+          const config = configs[requestId];
+          requestId++;
+          cb(null, config);
+        };
+        app.enableCors(configDelegation);
+
+        await app.init();
+      });
+
+      it(`should add cors headers based on the first config`, async () => {
+        return request(app.getHttpServer())
+          .get('/')
+          .expect('access-control-allow-origin', 'example.com')
+          .expect('vary', 'Origin')
+          .expect('access-control-allow-credentials', 'true')
+          .expect('access-control-expose-headers', 'foo,bar')
+          .expect('content-length', '0');
+      });
+
+      it(`should add cors headers based on the second config`, async () => {
+        return request(app.getHttpServer())
+          .options('/')
+          .expect('access-control-allow-origin', 'sample.com')
+          .expect('vary', 'Origin')
+          .expect('access-control-allow-credentials', 'true')
+          .expect('access-control-expose-headers', 'zoo,bar')
+          .expect('access-control-allow-methods', 'GET')
+          .expect('access-control-allow-headers', 'baz,foo')
+          .expect('access-control-max-age', '321')
+          .expect('content-length', '0');
+      });
+
+      after(async () => {
+        await app.close();
+      });
+    });
+
+    describe('Application Options', () => {
+      before(async () => {
+        const module = await Test.createTestingModule({
+          imports: [AppModule],
+        }).compile();
+
+        let requestId = 0;
+        const configDelegation = function (req, cb) {
+          const config = configs[requestId];
+          requestId++;
+          cb(null, config);
+        };
+
+        app = module.createNestApplication<NestFastifyApplication>(null, {
+          cors: configDelegation,
+        });
+
+        await app.init();
+      });
+
+      it(`should add cors headers based on the first config`, async () => {
+        return request(app.getHttpServer())
+          .get('/')
+          .expect('access-control-allow-origin', 'example.com')
+          .expect('vary', 'Origin')
+          .expect('access-control-allow-credentials', 'true')
+          .expect('access-control-expose-headers', 'foo,bar')
+          .expect('content-length', '0');
+      });
+
+      it(`should add cors headers based on the second config`, async () => {
+        return request(app.getHttpServer())
+          .options('/')
+          .expect('access-control-allow-origin', 'sample.com')
+          .expect('vary', 'Origin')
+          .expect('access-control-allow-credentials', 'true')
+          .expect('access-control-expose-headers', 'zoo,bar')
+          .expect('access-control-allow-methods', 'GET')
+          .expect('access-control-allow-headers', 'baz,foo')
+          .expect('access-control-max-age', '321')
+          .expect('content-length', '0');
+      });
+
+      after(async () => {
+        await app.close();
+      });
+    });
+  });
+
+  describe('Static config', () => {
+    describe('enableCors', () => {
+      before(async () => {
+        const module = await Test.createTestingModule({
+          imports: [AppModule],
+        }).compile();
+
+        app = module.createNestApplication<NestFastifyApplication>();
+        app.enableCors(configs[0]);
+
+        await app.init();
+      });
+
+      it(`CORS headers`, async () => {
+        return request(app.getHttpServer())
+          .get('/')
+          .expect('access-control-allow-origin', 'example.com')
+          .expect('vary', 'Origin')
+          .expect('access-control-allow-credentials', 'true')
+          .expect('access-control-expose-headers', 'foo,bar')
+          .expect('content-length', '0');
+      });
+    });
+
+    after(async () => {
+      await app.close();
+    });
+    
+    describe('Application Options', () => {
+      before(async () => {
+        const module = await Test.createTestingModule({
+          imports: [AppModule],
+        }).compile();
+
+        app = module.createNestApplication<NestFastifyApplication>(null, {
+          cors: configs[0],
+        });
+        await app.init();
+      });
+
+      it(`CORS headers`, async () => {
+        return request(app.getHttpServer())
+          .get('/')
+          .expect('access-control-allow-origin', 'example.com')
+          .expect('vary', 'Origin')
+          .expect('access-control-allow-credentials', 'true')
+          .expect('access-control-expose-headers', 'foo,bar')
+          .expect('content-length', '0');
+      });
+    });
+
+    after(async () => {
+      await app.close();
+    });
+  });
+});

integration/cors/src/app.controller.ts

@@ -0,0 +1,9 @@
+import { Controller, Get } from '@nestjs/common';
+
+@Controller()
+export class AppController {
+  @Get()
+  getGlobals() {
+    return '';
+  }
+}

integration/cors/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/cors/tsconfig.json

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

integration/docker-compose.yml

@@ -23,7 +23,7 @@ services:
       - "9001:9001"
     restart: always
   mysql:
-    image: mysql:5.7.29
+    image: mysql:8.0.27
     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:7.0.1
     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:7.0.1
     depends_on:
       - zookeeper
     ports:
@@ -70,3 +70,4 @@ services:
       KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:29092,PLAINTEXT_HOST://localhost:9092
       KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
       KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS: 0
+      KAFKA_DELETE_TOPIC_ENABLE: 'true'

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

@@ -30,27 +30,16 @@ describe('GraphQL Pipes', () => {
         errors: [
           {
             extensions: {
-              code: 'INTERNAL_SERVER_ERROR',
-              exception: {
-                message: 'Bad Request Exception',
-                response: {
-                  message: [
-                    'description must be longer than or equal to 30 characters',
-                  ],
-                  error: 'Bad Request',
-                  statusCode: 400,
-                },
-                status: 400,
+              code: 'BAD_USER_INPUT',
+              response: {
+                error: 'Bad Request',
+                message: [
+                  'description must be longer than or equal to 30 characters',
+                ],
+                statusCode: 400,
               },
             },
-            locations: [
-              {
-                column: 3,
-                line: 2,
-              },
-            ],
             message: 'Bad Request Exception',
-            path: ['addRecipe'],
           },
         ],
       });

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/graphql-code-first/src/recipes/recipes.resolver.ts

@@ -1,6 +1,6 @@
 import { NotFoundException, UseGuards, UseInterceptors } from '@nestjs/common';
 import { Args, Mutation, Query, Resolver, Subscription } from '@nestjs/graphql';
-import { PubSub } from 'apollo-server-express';
+import { PubSub } from 'graphql-subscriptions';
 import { AuthGuard } from '../common/guards/auth.guard';
 import { DataInterceptor } from '../common/interceptors/data.interceptor';
 import { NewRecipeInput } from './dto/new-recipe.input';

integration/graphql-schema-first/src/common/scalars/date.scalar.ts

@@ -1,4 +1,4 @@
-import { Scalar } from '@nestjs/graphql/dist/decorators/resolvers.decorators';
+import { Scalar } from '@nestjs/graphql';
 import { Kind } from 'graphql';
 
 @Scalar('Date')

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

@@ -25,6 +25,11 @@ class TestController {
     return RETURN_VALUE;
   }
 
+  @Get('test/test')
+  testTest() {
+    return RETURN_VALUE;
+  }
+
   @Get('test2')
   test2() {
     return RETURN_VALUE;
@@ -85,6 +90,12 @@ describe('Exclude middleware (fastify)', () => {
     return request(app.getHttpServer()).get('/test').expect(200, RETURN_VALUE);
   });
 
+  it(`should not exclude "/test/test" endpoint`, () => {
+    return request(app.getHttpServer())
+      .get('/test/test')
+      .expect(200, MIDDLEWARE_VALUE);
+  });
+
   it(`should not exclude "/test2" endpoint`, () => {
     return request(app.getHttpServer())
       .get('/test2')

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,38 @@ 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 { host: [":tenant.example1.com", ":tenant.example2.com"] } not matched`, () => {
+    return app
+      .inject({
+        method: 'GET',
+        url: '/host-array',
+      })
+      .then(({ payload }) => {
+        expect(JSON.parse(payload)).to.be.eql({
+          error: 'Internal Server Error',
+          message:
+            'HTTP adapter does not support filtering on hosts: [":tenant.example1.com", ":tenant.example2.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/hello-world.spec.ts

@@ -28,6 +28,16 @@ describe('Hello world (default adapter)', () => {
       path: '/host',
       greeting: 'Host Greeting! tenant=acme',
     },
+    {
+      host: 'acme.example1.com',
+      path: '/host-array',
+      greeting: 'Host Greeting! tenant=acme',
+    },
+    {
+      host: 'acme.example2.com',
+      path: '/host-array',
+      greeting: 'Host Greeting! tenant=acme',
+    },
   ].forEach(({ host, path, greeting }) => {
     describe(`host=${host}`, () => {
       describe('/GET', () => {

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

@@ -5,17 +5,21 @@ import {
   Injectable,
   MiddlewareConsumer,
   Module,
+  RequestMethod,
 } from '@nestjs/common';
 import { Test } from '@nestjs/testing';
 import * as request from 'supertest';
 import { ApplicationModule } from '../src/app.module';
+import { Response } from 'express';
 
+const INCLUDED_VALUE = 'test_included';
 const RETURN_VALUE = 'test';
+const WILDCARD_VALUE = 'test_wildcard';
 
 @Injectable()
 class Middleware {
   use(req, res, next) {
-    res.send(RETURN_VALUE);
+    res.send(WILDCARD_VALUE);
   }
 }
 
@@ -23,7 +27,7 @@ class Middleware {
 class TestController {
   @Get('test')
   test() {
-    return 'test';
+    return RETURN_VALUE;
   }
 }
 
@@ -33,7 +37,11 @@ class TestController {
 })
 class TestModule {
   configure(consumer: MiddlewareConsumer) {
-    consumer.apply(Middleware).forRoutes('*');
+    consumer
+      .apply((req, res: Response, next) => res.status(201).end(INCLUDED_VALUE))
+      .forRoutes({ path: 'tests/included', method: RequestMethod.POST })
+      .apply(Middleware)
+      .forRoutes('*');
   }
 }
 
@@ -51,7 +59,27 @@ describe('Middleware (class)', () => {
   });
 
   it(`forRoutes(*)`, () => {
-    return request(app.getHttpServer()).get('/hello').expect(200, RETURN_VALUE);
+    return request(app.getHttpServer())
+      .get('/hello')
+      .expect(200, WILDCARD_VALUE);
+  });
+
+  it(`/test forRoutes(*)`, () => {
+    return request(app.getHttpServer())
+      .get('/test')
+      .expect(200, WILDCARD_VALUE);
+  });
+
+  it(`GET forRoutes(POST tests/included)`, () => {
+    return request(app.getHttpServer())
+      .get('/tests/included')
+      .expect(200, WILDCARD_VALUE);
+  });
+
+  it(`POST forRoutes(POST tests/included)`, () => {
+    return request(app.getHttpServer())
+      .post('/tests/included')
+      .expect(201, INCLUDED_VALUE);
   });
 
   afterEach(async () => {

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

@@ -1,4 +1,11 @@
-import { Controller, Get, MiddlewareConsumer, Module } from '@nestjs/common';
+import {
+  Controller,
+  Get,
+  MiddlewareConsumer,
+  Module,
+  Query,
+  RequestMethod,
+} from '@nestjs/common';
 import {
   FastifyAdapter,
   NestFastifyApplication,
@@ -7,36 +14,70 @@ import { Test } from '@nestjs/testing';
 import { expect } from 'chai';
 import { ApplicationModule } from '../src/app.module';
 
+const INCLUDED_VALUE = 'test_included';
+const QUERY_VALUE = 'test_query';
+const REQ_URL_VALUE = 'test_req_url';
 const RETURN_VALUE = 'test';
 const SCOPED_VALUE = 'test_scoped';
 const WILDCARD_VALUE = 'test_wildcard';
 
 @Controller()
 class TestController {
+  @Get('express_style_wildcard/wildcard_nested')
+  express_style_wildcard() {
+    return RETURN_VALUE;
+  }
+
   @Get('test')
   test() {
     return RETURN_VALUE;
   }
 
+  @Get('query')
+  query() {
+    return RETURN_VALUE;
+  }
+
   @Get('tests/wildcard_nested')
-  // eslint-disable-next-line @typescript-eslint/camelcase
   wildcard_nested() {
     return RETURN_VALUE;
   }
+
+  @Get('tests/included')
+  included() {
+    return RETURN_VALUE;
+  }
+}
+
+@Controller(QUERY_VALUE)
+class TestQueryController {
+  @Get()
+  [QUERY_VALUE](@Query('test') test: string) {
+    return test;
+  }
 }
 
 @Module({
   imports: [ApplicationModule],
-  controllers: [TestController],
+  controllers: [TestController, TestQueryController],
 })
 class TestModule {
   configure(consumer: MiddlewareConsumer) {
     consumer
+      .apply((req, res, next) => res.end(INCLUDED_VALUE))
+      .forRoutes({ path: 'tests/included', method: RequestMethod.POST })
+      .apply((req, res, next) => res.end(`${REQ_URL_VALUE}${req.url}`))
+      .forRoutes('req/url/')
       .apply((req, res, next) => res.end(WILDCARD_VALUE))
-      .forRoutes('tests/(.*)')
+      .forRoutes('express_style_wildcard/*', 'tests/(.*)')
+      .apply((req, res, next) => res.end(QUERY_VALUE))
+      .forRoutes('query')
+      .apply((req, res, next) => next())
+      .forRoutes(TestQueryController)
       .apply((req, res, next) => res.end(SCOPED_VALUE))
       .forRoutes(TestController)
       .apply((req, res, next) => res.end(RETURN_VALUE))
+      .exclude({ path: QUERY_VALUE, method: -1 })
       .forRoutes('(.*)');
   }
 }
@@ -54,7 +95,7 @@ describe('Middleware (FastifyAdapter)', () => {
     await app.init();
   });
 
-  it(`forRoutes(*)`, () => {
+  it(`forRoutes((.*))`, () => {
     return app
       .inject({
         method: 'GET',
@@ -72,15 +113,78 @@ describe('Middleware (FastifyAdapter)', () => {
       .then(({ payload }) => expect(payload).to.be.eql(SCOPED_VALUE));
   });
 
-  it(`forRoutes(tests/*)`, () => {
+  it(`query?test=${QUERY_VALUE} forRoutes(query)`, () => {
     return app
       .inject({
         method: 'GET',
-        url: '/tests/wildcard',
+        url: '/query',
+        query: {
+          test: QUERY_VALUE,
+        },
+      })
+      .then(({ payload }) => expect(payload).to.be.eql(QUERY_VALUE));
+  });
+
+  it(`${QUERY_VALUE}?test=${QUERY_VALUE} forRoutes(${QUERY_VALUE})`, () => {
+    return app
+      .inject({
+        method: 'GET',
+        url: QUERY_VALUE,
+        query: {
+          test: QUERY_VALUE,
+        },
+      })
+      .then(({ payload }) => expect(payload).to.be.eql(QUERY_VALUE));
+  });
+
+  it(`forRoutes(tests/(.*))`, () => {
+    return app
+      .inject({
+        method: 'GET',
+        url: '/tests/wildcard_nested',
       })
       .then(({ payload }) => expect(payload).to.be.eql(WILDCARD_VALUE));
   });
 
+  it(`forRoutes(express_style_wildcard/*)`, () => {
+    return app
+      .inject({
+        method: 'GET',
+        url: '/express_style_wildcard/wildcard_nested',
+      })
+      .then(({ payload }) => expect(payload).to.be.eql(WILDCARD_VALUE));
+  });
+
+  it(`forRoutes(req/url/)`, () => {
+    const reqUrl = '/test';
+    return app
+      .inject({
+        method: 'GET',
+        url: `/req/url${reqUrl}`,
+      })
+      .then(({ payload }) =>
+        expect(payload).to.be.eql(`${REQ_URL_VALUE}${reqUrl}`),
+      );
+  });
+
+  it(`GET forRoutes(POST tests/included)`, () => {
+    return app
+      .inject({
+        method: 'GET',
+        url: '/tests/included',
+      })
+      .then(({ payload }) => expect(payload).to.be.eql(WILDCARD_VALUE));
+  });
+
+  it(`POST forRoutes(POST tests/included)`, () => {
+    return app
+      .inject({
+        method: 'POST',
+        url: '/tests/included',
+      })
+      .then(({ payload }) => expect(payload).to.be.eql(INCLUDED_VALUE));
+  });
+
   afterEach(async () => {
     await app.close();
   });

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/hello-world/e2e/router-module-middleware.spec.ts

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

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

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

integration/hello-world/src/app.module.ts

@@ -1,8 +1,9 @@
 import { Module } from '@nestjs/common';
 import { HelloModule } from './hello/hello.module';
+import { HostArrayModule } from './host-array/host-array.module';
 import { HostModule } from './host/host.module';
 
 @Module({
-  imports: [HelloModule, HostModule],
+  imports: [HelloModule, HostModule, HostArrayModule],
 })
 export class ApplicationModule {}

integration/hello-world/src/host-array/dto/test.dto.ts

@@ -0,0 +1,10 @@
+import { IsString, IsNotEmpty, IsNumber } from 'class-validator';
+
+export class TestDto {
+  @IsString()
+  @IsNotEmpty()
+  string: string;
+
+  @IsNumber()
+  number: number;
+}

integration/hello-world/src/host-array/host-array.controller.ts

@@ -0,0 +1,37 @@
+import { Controller, Get, Header, HostParam, Param } from '@nestjs/common';
+import { Observable, of } from 'rxjs';
+import { HostArrayService } from './host-array.service';
+import { UserByIdPipe } from './users/user-by-id.pipe';
+
+@Controller({
+  path: 'host-array',
+  host: [':tenant.example1.com', ':tenant.example2.com'],
+})
+export class HostArrayController {
+  constructor(private readonly hostService: HostArrayService) {}
+
+  @Get()
+  @Header('Authorization', 'Bearer')
+  greeting(@HostParam('tenant') tenant: string): string {
+    return `${this.hostService.greeting()} tenant=${tenant}`;
+  }
+
+  @Get('async')
+  async asyncGreeting(@HostParam('tenant') tenant: string): Promise<string> {
+    return `${await this.hostService.greeting()} tenant=${tenant}`;
+  }
+
+  @Get('stream')
+  streamGreeting(@HostParam('tenant') tenant: string): Observable<string> {
+    return of(`${this.hostService.greeting()} tenant=${tenant}`);
+  }
+
+  @Get('local-pipe/:id')
+  localPipe(
+    @Param('id', UserByIdPipe)
+    user: any,
+    @HostParam('tenant') tenant: string,
+  ): any {
+    return { ...user, tenant };
+  }
+}

integration/hello-world/src/host-array/host-array.module.ts

@@ -0,0 +1,10 @@
+import { Module } from '@nestjs/common';
+import { HostArrayController } from './host-array.controller';
+import { HostArrayService } from './host-array.service';
+import { UsersService } from './users/users.service';
+
+@Module({
+  controllers: [HostArrayController],
+  providers: [HostArrayService, UsersService],
+})
+export class HostArrayModule {}

integration/hello-world/src/host-array/host-array.service.ts

@@ -0,0 +1,8 @@
+import { Injectable } from '@nestjs/common';
+
+@Injectable()
+export class HostArrayService {
+  greeting(): string {
+    return 'Host Greeting!';
+  }
+}

integration/hello-world/src/host-array/users/user-by-id.pipe.ts

@@ -0,0 +1,11 @@
+import { PipeTransform, Injectable, ArgumentMetadata } from '@nestjs/common';
+import { UsersService } from './users.service';
+
+@Injectable()
+export class UserByIdPipe implements PipeTransform<string> {
+  constructor(private readonly usersService: UsersService) {}
+
+  transform(value: string, metadata: ArgumentMetadata) {
+    return this.usersService.findById(value);
+  }
+}

integration/hello-world/src/host-array/users/users.service.ts

@@ -0,0 +1,8 @@
+import { Injectable } from '@nestjs/common';
+
+@Injectable()
+export class UsersService {
+  findById(id: string) {
+    return { id, host: true };
+  }
+}

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

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

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

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

integration/hooks/e2e/lifecycle-hook-order.spec.ts

@@ -16,7 +16,8 @@ class TestInjectable
     OnModuleInit,
     OnModuleDestroy,
     OnApplicationShutdown,
-    BeforeApplicationShutdown {
+    BeforeApplicationShutdown
+{
   onApplicationBootstrap = Sinon.spy();
   beforeApplicationShutdown = Sinon.spy();
   onApplicationShutdown = Sinon.spy();

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

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

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

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

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

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

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

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

integration/hooks/src/enable-shutdown-hooks-main.ts

@@ -10,7 +10,8 @@ const SIGNAL_TO_LISTEN = process.argv[3];
 
 @Injectable()
 class TestInjectable
-  implements OnApplicationShutdown, BeforeApplicationShutdown {
+  implements OnApplicationShutdown, BeforeApplicationShutdown
+{
   beforeApplicationShutdown(signal: string) {
     console.log('beforeApplicationShutdown ' + signal);
   }
@@ -26,7 +27,7 @@ class TestInjectable
 class AppModule {}
 
 async function bootstrap() {
-  const app = await NestFactory.create(AppModule, { logger: true });
+  const app = await NestFactory.create(AppModule, { logger: false });
 
   if (SIGNAL_TO_LISTEN && SIGNAL_TO_LISTEN !== 'NONE') {
     app.enableShutdownHooks([SIGNAL_TO_LISTEN]);

integration/injector/e2e/core-injectables.spec.ts

@@ -14,9 +14,8 @@ describe('Core Injectables', () => {
   });
 
   it('should provide ApplicationConfig as core injectable', () => {
-    const applicationConfig = testingModule.get<ApplicationConfig>(
-      ApplicationConfig,
-    );
+    const applicationConfig =
+      testingModule.get<ApplicationConfig>(ApplicationConfig);
 
     applicationConfig.setGlobalPrefix('/api');
 

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/broadcast-mqtt.spec.ts

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

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

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

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

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

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

@@ -0,0 +1,291 @@
+import { INestApplication, Logger } from '@nestjs/common';
+import { Transport } from '@nestjs/microservices';
+import { Test } from '@nestjs/testing';
+import { Admin, ITopicMetadata, Kafka } from 'kafkajs';
+import * as request from 'supertest';
+import * as util from 'util';
+import { KafkaConcurrentController } from '../src/kafka-concurrent/kafka-concurrent.controller';
+import { KafkaConcurrentMessagesController } from '../src/kafka-concurrent/kafka-concurrent.messages.controller';
+
+describe.skip('Kafka concurrent', function () {
+  const numbersOfServers = 3;
+
+  const requestTopic = 'math.sum.sync.number.wait';
+  const responseTopic = 'math.sum.sync.number.wait.reply';
+
+  let admin: Admin;
+  const servers: any[] = [];
+  const apps: INestApplication[] = [];
+
+  const logger = new Logger('concurrent-kafka.spec.ts');
+
+  // set timeout to be longer (especially for the after hook)
+  this.timeout(30000);
+
+  const startServer = async () => {
+    const module = await Test.createTestingModule({
+      controllers: [
+        KafkaConcurrentController,
+        KafkaConcurrentMessagesController,
+      ],
+    }).compile();
+
+    // use our own logger for a little
+    // Logger.overrideLogger(new Logger());
+
+    const app = module.createNestApplication();
+
+    const server = app.getHttpAdapter().getInstance();
+
+    app.connectMicroservice({
+      transport: Transport.KAFKA,
+      options: {
+        client: {
+          brokers: ['localhost:9092'],
+        },
+        run: {
+          partitionsConsumedConcurrently: numbersOfServers,
+        },
+      },
+    });
+
+    // enable these for clean shutdown
+    app.enableShutdownHooks();
+
+    // push to the collection
+    servers.push(server);
+    apps.push(app);
+
+    // await the start
+    await app.startAllMicroservices();
+    await app.init();
+  };
+
+  it(`Create kafka topics/partitions`, async () => {
+    const kafka = new Kafka({
+      clientId: 'concurrent-test-admin',
+      brokers: ['localhost:9092'],
+    });
+
+    admin = kafka.admin();
+    await admin.connect();
+
+    let topicMetadata: {
+      topics: ITopicMetadata[];
+    };
+
+    try {
+      topicMetadata = await admin.fetchTopicMetadata({
+        topics: [requestTopic, responseTopic],
+      });
+    } catch (e) {
+      // create with number of servers
+      try {
+        await admin.createTopics({
+          topics: [
+            {
+              topic: requestTopic,
+              numPartitions: numbersOfServers,
+              replicationFactor: 1,
+            },
+            {
+              topic: responseTopic,
+              numPartitions: numbersOfServers,
+              replicationFactor: 1,
+            },
+          ],
+        });
+      } catch (e) {
+        logger.error(util.format('Create topics error: %o', e));
+      }
+    }
+
+    if (topicMetadata && topicMetadata.topics.length > 0) {
+      // we have topics, how many partitions do they have?
+      for (const topic of topicMetadata.topics) {
+        if (topic.partitions.length < numbersOfServers) {
+          try {
+            await admin.createPartitions({
+              topicPartitions: [
+                {
+                  topic: topic.name,
+                  count: numbersOfServers,
+                },
+              ],
+            });
+          } catch (e) {
+            logger.error(util.format('Create partitions error: %o', e));
+          }
+        }
+      }
+    }
+
+    // create with number of servers
+    try {
+      await admin.createTopics({
+        topics: [
+          {
+            topic: requestTopic,
+            numPartitions: numbersOfServers,
+            replicationFactor: 1,
+          },
+          {
+            topic: responseTopic,
+            numPartitions: numbersOfServers,
+            replicationFactor: 1,
+          },
+        ],
+      });
+    } catch (e) {
+      logger.error(util.format('Create topics error: %o', e));
+    }
+
+    // disconnect
+    await admin.disconnect();
+  });
+
+  it(`Start Kafka apps`, async () => {
+    // start all at once
+    await Promise.all(
+      Array(numbersOfServers)
+        .fill(1)
+        .map(async (v, i) => {
+          // return startServer();
+
+          // wait in intervals so the consumers start in order
+          return new Promise<void>(resolve => {
+            setTimeout(async () => {
+              await startServer();
+
+              return resolve();
+            }, 1000 * i);
+          });
+        }),
+    );
+  }).timeout(30000);
+
+  it(`Concurrent messages without forcing a rebalance.`, async () => {
+    // wait a second before notifying the servers to respond
+    setTimeout(async () => {
+      // notify the other servers that it is time to respond
+      await Promise.all(
+        servers.map(async server => {
+          // send to all servers since indexes don't necessarily align with server consumers
+          return request(server).post('/go').send();
+        }),
+      );
+    }, 1000);
+
+    await Promise.all(
+      servers.map(async (server, index) => {
+        // send requests
+        const payload = {
+          key: index,
+          numbers: [1, index],
+        };
+        const result = (1 + index).toString();
+
+        return request(server)
+          .post('/mathSumSyncNumberWait')
+          .send(payload)
+          .expect(200)
+          .expect(200, result);
+      }),
+    );
+  });
+
+  it(`Close kafka client consumer while waiting for message pattern response.`, async () => {
+    await Promise.all(
+      servers.map(async (server, index) => {
+        // shut off and delete the leader
+        if (index === 0) {
+          return new Promise<void>(resolve => {
+            // wait a second before closing so the producers can send the message to the server consumers
+            setTimeout(async () => {
+              // get the controller
+              const controller = apps[index].get(KafkaConcurrentController);
+
+              // close the controller clients
+              await controller.client.close();
+
+              // notify the other servers that we have stopped
+              await Promise.all(
+                servers.map(async server => {
+                  // send to all servers since indexes don't necessarily align with server consumers
+                  return request(server).post('/go').send();
+                }),
+              );
+
+              return resolve();
+            }, 1000);
+          });
+        }
+
+        // send requests
+        const payload = {
+          key: index,
+          numbers: [1, index],
+        };
+        const result = (1 + index).toString();
+
+        return request(server)
+          .post('/mathSumSyncNumberWait')
+          .send(payload)
+          .expect(200)
+          .expect(200, result);
+      }),
+    );
+  });
+
+  it(`Start kafka client consumer while waiting for message pattern response.`, async () => {
+    await Promise.all(
+      servers.map(async (server, index) => {
+        // shut off and delete the leader
+        if (index === 0) {
+          return new Promise<void>(resolve => {
+            // wait a second before closing so the producers can send the message to the server consumers
+            setTimeout(async () => {
+              // get the controller
+              const controller = apps[index].get(KafkaConcurrentController);
+
+              // connect the controller client
+              await controller.client.connect();
+
+              // notify the servers that we have started
+              await Promise.all(
+                servers.map(async server => {
+                  // send to all servers since indexes don't necessarily align with server consumers
+                  return request(server).post('/go').send();
+                }),
+              );
+
+              return resolve();
+            }, 1000);
+          });
+        }
+
+        // send requests
+        const payload = {
+          key: index,
+          numbers: [1, index],
+        };
+        const result = (1 + index).toString();
+
+        return request(server)
+          .post('/mathSumSyncNumberWait')
+          .send(payload)
+          .expect(200)
+          .expect(200, result);
+      }),
+    );
+  });
+
+  after(`Stopping Kafka app`, async () => {
+    // close all concurrently
+    return Promise.all(
+      apps.map(async app => {
+        return app.close();
+      }),
+    );
+  });
+});

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

@@ -46,7 +46,7 @@ describe('Disconnected client', () => {
       .send({
         transport: Transport.NATS,
         options: {
-          url: 'nats://localhost:4224',
+          servers: 'nats://localhost:4224',
         },
       })
       .expect(408);
@@ -65,6 +65,19 @@ describe('Disconnected client', () => {
       .expect(408);
   });
 
+  it(`RMQ`, () => {
+    return request(server)
+      .post('/')
+      .send({
+        transport: Transport.RMQ,
+        options: {
+          urls: [`amqp://0.0.0.0:3333`],
+          queue: 'test',
+        },
+      })
+      .expect(408);
+  });
+
   afterEach(async () => {
     await app.close();
   });

integration/microservices/e2e/mqtt-record-builder.spec.ts

@@ -0,0 +1,46 @@
+import { INestApplication } from '@nestjs/common';
+import { Transport } from '@nestjs/microservices';
+import { Test } from '@nestjs/testing';
+import * as request from 'supertest';
+import { MqttController } from '../src/mqtt/mqtt.controller';
+
+describe('MQTT transport', () => {
+  let server;
+  let app: INestApplication;
+
+  beforeEach(async () => {
+    const module = await Test.createTestingModule({
+      controllers: [MqttController],
+    }).compile();
+
+    app = module.createNestApplication();
+    server = app.getHttpAdapter().getInstance();
+
+    app.connectMicroservice({
+      transport: Transport.MQTT,
+      options: {
+        url: 'mqtt://0.0.0.0:1883',
+        subscribeOptions: {
+          qos: 1,
+        },
+      },
+    });
+    await app.startAllMicroservices();
+    await app.init();
+  });
+
+  it(`/POST (setting packet options with "RecordBuilder")`, () => {
+    const payload = { items: [1, 2, 3] };
+    return request(server)
+      .post('/record-builder-duplex')
+      .send(payload)
+      .expect(200, {
+        data: payload,
+        qos: 1,
+      });
+  });
+
+  afterEach(async () => {
+    await app.close();
+  });
+});

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

@@ -1,3 +1,4 @@
+import * as GRPC from '@grpc/grpc-js';
 import * as ProtoLoader from '@grpc/proto-loader';
 import { INestApplication } from '@nestjs/common';
 import { Transport } from '@nestjs/microservices';
@@ -6,7 +7,6 @@ import { Test } from '@nestjs/testing';
 import { fail } from 'assert';
 import { expect } from 'chai';
 import * as express from 'express';
-import * as GRPC from 'grpc';
 import { join } from 'path';
 import * as request from 'supertest';
 import { AdvancedGrpcController } from '../src/grpc-advanced/advanced.grpc.controller';
@@ -39,7 +39,7 @@ describe('Advanced GRPC transport', () => {
       },
     });
     // Start gRPC microservice
-    await app.startAllMicroservicesAsync();
+    await app.startAllMicroservices();
     await app.init();
     // Load proto-buffers for test gRPC dispatch
     const proto = ProtoLoader.loadSync('root.proto', {
@@ -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({
@@ -129,7 +134,7 @@ describe('Advanced GRPC transport', () => {
     callHandler.on('error', (err: any) => {
       // We want to fail only on real errors while Cancellation error
       // is expected
-      if (String(err).toLowerCase().indexOf('cancelled') === -1) {
+      if (!String(err).toLowerCase().includes('cancelled')) {
         fail('gRPC Stream error happened, error: ' + err);
       }
     });
@@ -161,7 +166,7 @@ describe('Advanced GRPC transport', () => {
     callHandler.on('error', (err: any) => {
       // We want to fail only on real errors while Cancellation error
       // is expected
-      if (String(err).toLowerCase().indexOf('cancelled') === -1) {
+      if (!String(err).toLowerCase().includes('cancelled')) {
         fail('gRPC Stream error happened, error: ' + err);
       }
     });

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

@@ -1,10 +1,10 @@
+import * as GRPC from '@grpc/grpc-js';
 import * as ProtoLoader from '@grpc/proto-loader';
 import { INestApplication } from '@nestjs/common';
 import { Transport } from '@nestjs/microservices';
 import { Test } from '@nestjs/testing';
 import { fail } from 'assert';
 import { expect } from 'chai';
-import * as GRPC from 'grpc';
 import { join } from 'path';
 import * as request from 'supertest';
 import { GrpcController } from '../src/grpc/grpc.controller';
@@ -25,12 +25,15 @@ describe('GRPC transport', () => {
     app.connectMicroservice({
       transport: Transport.GRPC,
       options: {
-        package: 'math',
-        protoPath: join(__dirname, '../src/grpc/math.proto'),
+        package: ['math', 'math2'],
+        protoPath: [
+          join(__dirname, '../src/grpc/math.proto'),
+          join(__dirname, '../src/grpc/math2.proto'),
+        ],
       },
     });
     // Start gRPC microservice
-    await app.startAllMicroservicesAsync();
+    await app.startAllMicroservices();
     await app.init();
     // Load proto-buffers for test gRPC dispatch
     const proto = ProtoLoader.loadSync(
@@ -47,7 +50,19 @@ describe('GRPC transport', () => {
 
   it(`GRPC Sending and Receiving HTTP POST`, () => {
     return request(server)
-      .post('/')
+      .post('/sum')
+      .send([1, 2, 3, 4, 5])
+      .expect(200, { result: 15 });
+  });
+
+  it(`GRPC Sending and Receiving HTTP POST (multiple proto)`, async () => {
+    await request(server)
+      .post('/multi/sum')
+      .send([1, 2, 3, 4, 5])
+      .expect(200, { result: 15 });
+
+    await request(server)
+      .post('/multi/sum2')
       .send([1, 2, 3, 4, 5])
       .expect(200, { result: 15 });
   });
@@ -63,7 +78,7 @@ describe('GRPC transport', () => {
     callHandler.on('error', (err: any) => {
       // We want to fail only on real errors while Cancellation error
       // is expected
-      if (String(err).toLowerCase().indexOf('cancelled') === -1) {
+      if (!String(err).toLowerCase().includes('cancelled')) {
         fail('gRPC Stream error happened, error: ' + err);
       }
     });
@@ -85,7 +100,7 @@ describe('GRPC transport', () => {
     callHandler.on('error', (err: any) => {
       // We want to fail only on real errors while Cancellation error
       // is expected
-      if (String(err).toLowerCase().indexOf('cancelled') === -1) {
+      if (!String(err).toLowerCase().includes('cancelled')) {
         fail('gRPC Stream error happened, error: ' + err);
       }
     });
@@ -98,6 +113,5 @@ describe('GRPC transport', () => {
 
   after(async () => {
     await app.close();
-    client.close();
   });
 });

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

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

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

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

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

@@ -4,6 +4,7 @@ import { Test } from '@nestjs/testing';
 import { expect } from 'chai';
 import * as request from 'supertest';
 import { NatsController } from '../src/nats/nats.controller';
+import { NatsService } from '../src/nats/nats.service';
 
 describe('NATS transport', () => {
   let server;
@@ -12,6 +13,7 @@ describe('NATS transport', () => {
   beforeEach(async () => {
     const module = await Test.createTestingModule({
       controllers: [NatsController],
+      providers: [NatsService],
     }).compile();
 
     app = module.createNestApplication();
@@ -20,10 +22,10 @@ describe('NATS transport', () => {
     app.connectMicroservice({
       transport: Transport.NATS,
       options: {
-        url: 'nats://0.0.0.0:4222',
+        servers: 'nats://0.0.0.0:4222',
       },
     });
-    await app.startAllMicroservicesAsync();
+    await app.startAllMicroservices();
     await app.init();
   });
 
@@ -88,11 +90,25 @@ describe('NATS transport', () => {
       .end(() => {
         setTimeout(() => {
           expect(NatsController.IS_NOTIFIED).to.be.true;
+          expect(NatsController.IS_NOTIFIED2).to.be.true;
           done();
         }, 1000);
       });
   });
 
+  it(`/POST (sending headers with "RecordBuilder")`, () => {
+    const payload = { items: [1, 2, 3] };
+    return request(server)
+      .post('/record-builder-duplex')
+      .send(payload)
+      .expect(200, {
+        data: payload,
+        headers: {
+          ['x-version']: '1.0.0',
+        },
+      });
+  });
+
   afterEach(async () => {
     await app.close();
   });

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

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

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

@@ -26,7 +26,7 @@ describe('RabbitMQ transport', () => {
         socketOptions: { noDelay: true },
       },
     });
-    await app.startAllMicroservicesAsync();
+    await app.startAllMicroservices();
     await app.init();
   });
 
@@ -89,6 +89,20 @@ describe('RabbitMQ transport', () => {
       });
   });
 
+  it(`/POST (sending options with "RecordBuilder")`, () => {
+    const payload = { items: [1, 2, 3] };
+    return request(server)
+      .post('/record-builder-duplex')
+      .send(payload)
+      .expect(200, {
+        data: payload,
+        headers: {
+          ['x-version']: '1.0.0',
+        },
+        priority: 3,
+      });
+  });
+
   afterEach(async () => {
     await app.close();
   });

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

@@ -24,7 +24,7 @@ describe('RPC transport', () => {
         host: '0.0.0.0',
       },
     });
-    await app.startAllMicroservicesAsync();
+    await app.startAllMicroservices();
     await app.init();
   });
 
@@ -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')
@@ -91,6 +105,22 @@ describe('RPC transport', () => {
       });
   });
 
+  it('/POST (custom client)', () => {
+    return request(server)
+      .post('/error?client=custom')
+      .send({})
+      .expect(200)
+      .expect('true');
+  });
+
+  it('/POST (standard client)', () => {
+    return request(server)
+      .post('/error?client=standard')
+      .send({})
+      .expect(200)
+      .expect('false');
+  });
+
   afterEach(async () => {
     await app.close();
   });

integration/microservices/src/app.controller.ts

@@ -1,16 +1,29 @@
-import { Body, Controller, HttpCode, Post, Query } from '@nestjs/common';
+import {
+  Body,
+  Controller,
+  HttpCode,
+  Inject,
+  Post,
+  Query,
+} from '@nestjs/common';
 import {
   Client,
   ClientProxy,
   EventPattern,
   MessagePattern,
+  RpcException,
   Transport,
 } from '@nestjs/microservices';
-import { from, Observable, of } from 'rxjs';
-import { scan } from 'rxjs/operators';
+import { from, lastValueFrom, Observable, of, throwError } from 'rxjs';
+import { catchError, scan } from 'rxjs/operators';
 
 @Controller()
 export class AppController {
+  constructor(
+    @Inject('USE_CLASS_CLIENT') private useClassClient: ClientProxy,
+    @Inject('USE_FACTORY_CLIENT') private useFactoryClient: ClientProxy,
+    @Inject('CUSTOM_PROXY_CLIENT') private customClient: ClientProxy,
+  ) {}
   static IS_NOTIFIED = false;
 
   @Client({ transport: Transport.TCP })
@@ -22,6 +35,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> {
@@ -35,9 +66,9 @@ export class AppController {
   concurrent(@Body() data: number[][]): Promise<boolean> {
     const send = async (tab: number[]) => {
       const expected = tab.reduce((a, b) => a + b);
-      const result = await this.client
-        .send<number>({ cmd: 'sum' }, tab)
-        .toPromise();
+      const result = await lastValueFrom(
+        this.client.send<number>({ cmd: 'sum' }, tab),
+      );
 
       return result === expected;
     };
@@ -46,6 +77,20 @@ export class AppController {
       .reduce(async (a, b) => (await a) && b);
   }
 
+  @Post('error')
+  @HttpCode(200)
+  serializeError(
+    @Query('client') query: 'custom' | 'standard' = 'standard',
+    @Body() body: Record<string, any>,
+  ): Observable<boolean> {
+    const client = query === 'custom' ? this.customClient : this.client;
+    return client.send({ cmd: 'err' }, {}).pipe(
+      catchError(err => {
+        return of(err instanceof RpcException);
+      }),
+    );
+  }
+
   @MessagePattern({ cmd: 'sum' })
   sum(data: number[]): number {
     return (data || []).reduce((a, b) => a + b);
@@ -66,6 +111,11 @@ export class AppController {
     return from(data);
   }
 
+  @MessagePattern({ cmd: 'err' })
+  throwAnError() {
+    return throwError(() => new Error('err'));
+  }
+
   @Post('notify')
   async sendNotification(): Promise<any> {
     return this.client.emit<number>('notification', true);

integration/microservices/src/app.module.ts

@@ -1,7 +1,75 @@
-import { Module } from '@nestjs/common';
+import { Module, Injectable } from '@nestjs/common';
 import { AppController } from './app.controller';
+import {
+  ClientsModule,
+  Transport,
+  ClientsModuleOptionsFactory,
+  ClientOptions,
+  ClientTCP,
+  RpcException,
+} from '@nestjs/microservices';
+
+class ErrorHandlingProxy extends ClientTCP {
+  serializeError(err) {
+    return new RpcException(err);
+  }
+}
+
+@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],
+      },
+      {
+        imports: [ConfigModule],
+        inject: [ConfigService],
+        name: 'CUSTOM_PROXY_CLIENT',
+        useFactory: (config: ConfigService) => ({
+          customClass: ErrorHandlingProxy,
+        }),
+      },
+    ]),
+  ],
   controllers: [AppController],
 })
 export class ApplicationModule {}

integration/microservices/src/disconnected.controller.ts

@@ -14,21 +14,21 @@ export class DisconnectedClientController {
   @Post()
   call(@Body() options): Observable<number> {
     const client = ClientProxyFactory.create(options);
-    return client
-      .send<number, number[]>({ cmd: 'none' }, [1, 2, 3])
-      .pipe(
-        /*tap(
-        console.log.bind(console, 'data'),
-        console.error.bind(console, 'error'),
-      ),*/
-        catchError(error => {
-          const { code } = error || { code: 'CONN_ERR' };
-          return throwError(
-            code === 'ECONNREFUSED' || code === 'CONN_ERR'
-              ? new RequestTimeoutException('ECONNREFUSED')
-              : new InternalServerErrorException(),
-          );
-        }),
-      );
+    return client.send<number, number[]>({ cmd: 'none' }, [1, 2, 3]).pipe(
+      // tap(
+      //   console.log.bind(console, 'data'),
+      //   console.error.bind(console, 'error'),
+      // ),
+      catchError(error => {
+        const { code } = error?.err ?? error ?? { code: 'CONN_ERR' };
+        return throwError(() =>
+          code === 'ECONNREFUSED' ||
+          code === 'CONN_ERR' ||
+          code === 'CONNECTION_REFUSED'
+            ? new RequestTimeoutException('ECONNREFUSED')
+            : new InternalServerErrorException(),
+        );
+      }),
+    );
   }
 }

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

@@ -1,3 +1,4 @@
+import { Metadata } from '@grpc/grpc-js';
 import { Body, Controller, HttpCode, Post } from '@nestjs/common';
 import {
   Client,
@@ -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 => {
@@ -124,8 +134,8 @@ export class AdvancedGrpcController {
   async streamReq(messages: Observable<any>): Promise<any> {
     const s = new Subject();
     const o = s.asObservable();
-    messages.subscribe(
-      msg => {
+    messages.subscribe({
+      next: () => {
         s.next({
           id: 1,
           itemTypes: [1],
@@ -136,9 +146,8 @@ export class AdvancedGrpcController {
           },
         });
       },
-      null,
-      () => s.complete(),
-    );
+      complete: () => s.complete(),
+    });
     return o;
   }
 

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

@@ -31,9 +31,9 @@ export class GrpcController {
       ],
     },
   })
-  client2: ClientGrpc;
+  clientMulti: ClientGrpc;
 
-  @Post()
+  @Post('sum')
   @HttpCode(200)
   call(@Body() data: number[]): Observable<number> {
     const svc = this.client.getService<any>('Math');
@@ -50,16 +50,16 @@ export class GrpcController {
   @GrpcStreamMethod('Math')
   async sumStream(messages: Observable<any>): Promise<any> {
     return new Promise<any>((resolve, reject) => {
-      messages.subscribe(
-        msg => {
+      messages.subscribe({
+        next: msg => {
           resolve({
             result: msg.data.reduce((a, b) => a + b),
           });
         },
-        err => {
+        error: err => {
           reject(err);
         },
-      );
+      });
     });
   }
 
@@ -77,10 +77,17 @@ export class GrpcController {
     });
   }
 
-  @Post()
+  @Post('multi/sum')
   @HttpCode(200)
-  call2(@Body() data: number[]): Observable<number> {
-    const svc = this.client2.getService<any>('Math2');
+  callMultiSum(@Body() data: number[]): Observable<number> {
+    const svc = this.clientMulti.getService<any>('Math');
     return svc.sum({ data });
   }
+
+  @Post('multi/sum2')
+  @HttpCode(200)
+  callMultiSum2(@Body() data: number[]): Observable<number> {
+    const svc = this.clientMulti.getService<any>('Math2');
+    return svc.sum2({ data });
+  }
 }

integration/microservices/src/kafka-concurrent/dto/sum.dto.ts

@@ -0,0 +1,4 @@
+export class SumDto {
+  key: string;
+  numbers: number[];
+}

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

@@ -0,0 +1,71 @@
+import {
+  Body,
+  Controller,
+  HttpCode,
+  Logger,
+  OnModuleDestroy,
+  OnModuleInit,
+  Post,
+} from '@nestjs/common';
+import { Client, ClientKafka, Transport } from '@nestjs/microservices';
+import { PartitionerArgs } from 'kafkajs';
+import { Observable } from 'rxjs';
+import { SumDto } from './dto/sum.dto';
+
+/**
+ * The following function explicity sends messages to the key representing the partition.
+ */
+const explicitPartitioner = () => {
+  return ({ message }: PartitionerArgs) => {
+    return parseFloat(message.headers.toPartition.toString());
+  };
+};
+
+@Controller()
+export class KafkaConcurrentController
+  implements OnModuleInit, OnModuleDestroy
+{
+  protected readonly logger = new Logger(KafkaConcurrentController.name);
+
+  @Client({
+    transport: Transport.KAFKA,
+    options: {
+      client: {
+        brokers: ['localhost:9092'],
+      },
+      run: {
+        partitionsConsumedConcurrently: 3,
+      },
+      producer: {
+        createPartitioner: explicitPartitioner,
+      },
+    },
+  })
+  public readonly client: ClientKafka;
+
+  async onModuleInit() {
+    const requestPatterns = ['math.sum.sync.number.wait'];
+
+    requestPatterns.forEach(pattern => {
+      this.client.subscribeToResponseOf(pattern);
+    });
+
+    await this.client.connect();
+  }
+
+  async onModuleDestroy() {
+    await this.client.close();
+  }
+
+  @Post('mathSumSyncNumberWait')
+  @HttpCode(200)
+  public mathSumSyncNumberWait(@Body() data: SumDto): Observable<string> {
+    return this.client.send('math.sum.sync.number.wait', {
+      headers: {
+        toPartition: data.key.toString(),
+      },
+      key: data.key.toString(),
+      value: data.numbers,
+    });
+  }
+}

integration/microservices/src/kafka-concurrent/kafka-concurrent.messages.controller.ts

@@ -0,0 +1,37 @@
+import { Controller, HttpCode, Post } from '@nestjs/common';
+import { MessagePattern } from '@nestjs/microservices';
+import { BehaviorSubject, Observable } from 'rxjs';
+import { first, map, skipWhile } from 'rxjs/operators';
+
+@Controller()
+export class KafkaConcurrentMessagesController {
+  public waiting = new BehaviorSubject<boolean>(false);
+
+  @Post('go')
+  @HttpCode(200)
+  async go() {
+    // no longer waiting
+    this.waiting.next(false);
+
+    return;
+  }
+
+  @MessagePattern('math.sum.sync.number.wait')
+  public mathSumSyncNumberWait(data: any): Observable<number> {
+    // start waiting
+    this.waiting.next(true);
+
+    // find sum
+    const sum = data.value[0] + data.value[1];
+
+    return this.waiting.asObservable().pipe(
+      skipWhile(isWaiting => {
+        return isWaiting;
+      }),
+      map(() => {
+        return sum;
+      }),
+      first(),
+    );
+  }
+}

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

@@ -1,12 +1,19 @@
-import { Body, Controller, HttpCode, OnModuleInit, Post } from '@nestjs/common';
-import { Logger } from '@nestjs/common/services/logger.service';
+import {
+  Body,
+  Controller,
+  HttpCode,
+  Logger,
+  OnModuleDestroy,
+  OnModuleInit,
+  Post,
+} from '@nestjs/common';
 import { Client, ClientKafka, Transport } from '@nestjs/microservices';
-import { Observable } from 'rxjs';
+import { lastValueFrom, Observable } from 'rxjs';
 import { BusinessDto } from './dtos/business.dto';
 import { UserDto } from './dtos/user.dto';
 
 @Controller()
-export class KafkaController implements OnModuleInit {
+export class KafkaController implements OnModuleInit, OnModuleDestroy {
   protected readonly logger = new Logger(KafkaController.name);
   static IS_NOTIFIED = false;
   static MATH_SUM = 0;
@@ -21,7 +28,7 @@ export class KafkaController implements OnModuleInit {
   })
   private readonly client: ClientKafka;
 
-  onModuleInit() {
+  async onModuleInit() {
     const requestPatterns = [
       'math.sum.sync.kafka.message',
       'math.sum.sync.without.key',
@@ -36,6 +43,12 @@ export class KafkaController implements OnModuleInit {
     requestPatterns.forEach(pattern => {
       this.client.subscribeToResponseOf(pattern);
     });
+
+    await this.client.connect();
+  }
+
+  async onModuleDestroy() {
+    await this.client.close();
   }
 
   // sync send kafka message
@@ -44,14 +57,14 @@ export class KafkaController implements OnModuleInit {
   async mathSumSyncKafkaMessage(
     @Body() data: number[],
   ): Promise<Observable<any>> {
-    const result = await this.client
-      .send('math.sum.sync.kafka.message', {
+    const result = await lastValueFrom(
+      this.client.send('math.sum.sync.kafka.message', {
         key: '1',
         value: {
           numbers: data,
         },
-      })
-      .toPromise();
+      }),
+    );
     return result;
   }
 
@@ -61,13 +74,13 @@ export class KafkaController implements OnModuleInit {
   async mathSumSyncWithoutKey(
     @Body() data: number[],
   ): Promise<Observable<any>> {
-    const result = await this.client
-      .send('math.sum.sync.without.key', {
+    const result = await lastValueFrom(
+      this.client.send('math.sum.sync.without.key', {
         value: {
           numbers: data,
         },
-      })
-      .toPromise();
+      }),
+    );
     return result;
   }
 
@@ -77,11 +90,11 @@ export class KafkaController implements OnModuleInit {
   async mathSumSyncPlainObject(
     @Body() data: number[],
   ): Promise<Observable<any>> {
-    const result = await this.client
-      .send('math.sum.sync.plain.object', {
+    const result = await lastValueFrom(
+      this.client.send('math.sum.sync.plain.object', {
         numbers: data,
-      })
-      .toPromise();
+      }),
+    );
     return result;
   }
 
@@ -89,9 +102,9 @@ export class KafkaController implements OnModuleInit {
   @Post('mathSumSyncArray')
   @HttpCode(200)
   async mathSumSyncArray(@Body() data: number[]): Promise<Observable<any>> {
-    const result = await this.client
-      .send('math.sum.sync.array', data)
-      .toPromise();
+    const result = await lastValueFrom(
+      this.client.send('math.sum.sync.array', data),
+    );
     return result;
   }
 
@@ -99,18 +112,18 @@ export class KafkaController implements OnModuleInit {
   @HttpCode(200)
   async mathSumSyncString(@Body() data: number[]): Promise<Observable<any>> {
     // this.logger.error(util.format('mathSumSyncString() data: %o', data));
-    const result = await this.client
-      .send('math.sum.sync.string', data.toString())
-      .toPromise();
+    const result = await lastValueFrom(
+      this.client.send('math.sum.sync.string', data.toString()),
+    );
     return result;
   }
 
   @Post('mathSumSyncNumber')
   @HttpCode(200)
   async mathSumSyncNumber(@Body() data: number[]): Promise<Observable<any>> {
-    const result = await this.client
-      .send('math.sum.sync.number', data[0])
-      .toPromise();
+    const result = await lastValueFrom(
+      this.client.send('math.sum.sync.number', data[0]),
+    );
     return result;
   }
 
@@ -124,14 +137,14 @@ export class KafkaController implements OnModuleInit {
   @Post('/user')
   @HttpCode(200)
   async createUser(@Body() user: UserDto): Promise<Observable<any>> {
-    const result = await this.client
-      .send('user.create', {
+    const result = await lastValueFrom(
+      this.client.send('user.create', {
         key: '1',
         value: {
           user,
         },
-      })
-      .toPromise();
+      }),
+    );
     return result;
   }
 
@@ -139,14 +152,14 @@ export class KafkaController implements OnModuleInit {
   @Post('/business')
   @HttpCode(200)
   async createBusiness(@Body() business: BusinessDto) {
-    const result = await this.client
-      .send('business.create', {
+    const result = await lastValueFrom(
+      this.client.send('business.create', {
         key: '1',
         value: {
           business,
         },
-      })
-      .toPromise();
+      }),
+    );
     return result;
   }
 }

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

@@ -1,5 +1,4 @@
-import { Controller } from '@nestjs/common';
-import { Logger } from '@nestjs/common/services/logger.service';
+import { Controller, Logger } from '@nestjs/common';
 import { EventPattern, MessagePattern } from '@nestjs/microservices';
 import { BusinessDto } from './dtos/business.dto';
 import { UserDto } from './dtos/user.dto';

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

@@ -2,11 +2,15 @@ import { Body, Controller, HttpCode, Post, Query } from '@nestjs/common';
 import {
   Client,
   ClientProxy,
+  Ctx,
   EventPattern,
   MessagePattern,
+  MqttContext,
+  MqttRecordBuilder,
+  Payload,
   Transport,
 } from '@nestjs/microservices';
-import { from, Observable, of } from 'rxjs';
+import { from, lastValueFrom, Observable, of } from 'rxjs';
 import { scan } from 'rxjs/operators';
 
 @Controller()
@@ -30,10 +34,13 @@ export class MqttController {
 
   @Post('stream')
   @HttpCode(200)
-  stream(@Body() data: number[]): Observable<number> {
-    return this.client
-      .send<number>({ cmd: 'streaming' }, data)
-      .pipe(scan((a, b) => a + b));
+  async stream(@Body() data: number[]) {
+    const result = lastValueFrom(
+      this.client
+        .send<number>({ cmd: 'streaming' }, data)
+        .pipe(scan((a, b) => a + b, 0)),
+    );
+    return result;
   }
 
   @Post('concurrent')
@@ -41,9 +48,9 @@ export class MqttController {
   async concurrent(@Body() data: number[][]): Promise<boolean> {
     const send = async (tab: number[]) => {
       const expected = tab.reduce((a, b) => a + b);
-      const result = await this.client
-        .send<number>({ cmd: 'sum' }, tab)
-        .toPromise();
+      const result = await lastValueFrom(
+        this.client.send<number>({ cmd: 'sum' }, tab),
+      );
 
       return result === expected;
     };
@@ -83,6 +90,25 @@ export class MqttController {
     return this.client.send<number>('wildcard-message2/test/test', data);
   }
 
+  @Post('record-builder-duplex')
+  @HttpCode(200)
+  useRecordBuilderDuplex(@Body() data: Record<string, any>) {
+    const record = new MqttRecordBuilder(data).setQoS(2).build();
+    return this.client.send('record-builder-duplex', record);
+  }
+
+  @MessagePattern('record-builder-duplex')
+  handleRecordBuilderDuplex(
+    @Payload() data: Record<string, any>,
+    @Ctx() context: MqttContext,
+  ) {
+    const { qos } = context.getPacket();
+    return {
+      data,
+      qos,
+    };
+  }
+
   @MessagePattern('wildcard-message/#')
   wildcardMessageHandler(data: number[]): number {
     if ((data as any).response) {

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

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

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

@@ -1,29 +1,34 @@
 import { Body, Controller, Get, HttpCode, Post, Query } from '@nestjs/common';
 import {
-  Client,
   ClientProxy,
+  ClientProxyFactory,
   Ctx,
   EventPattern,
   MessagePattern,
   NatsContext,
+  NatsRecordBuilder,
   Payload,
   RpcException,
   Transport,
 } from '@nestjs/microservices';
-import { from, Observable, of, throwError } from 'rxjs';
+import * as nats from 'nats';
+import { from, lastValueFrom, Observable, of, throwError } from 'rxjs';
 import { catchError, scan } from 'rxjs/operators';
+import { NatsService } from './nats.service';
 
 @Controller()
 export class NatsController {
   static IS_NOTIFIED = false;
+  static IS_NOTIFIED2 = false;
 
-  @Client({
+  constructor(private readonly natsService: NatsService) {}
+
+  client: ClientProxy = ClientProxyFactory.create({
     transport: Transport.NATS,
     options: {
-      url: 'nats://localhost:4222',
+      servers: 'nats://localhost:4222',
     },
-  })
-  client: ClientProxy;
+  });
 
   @Post()
   @HttpCode(200)
@@ -48,9 +53,9 @@ export class NatsController {
   concurrent(@Body() data: number[][]): Promise<boolean> {
     const send = async (tab: number[]) => {
       const expected = tab.reduce((a, b) => a + b);
-      const result = await this.client
-        .send<number>('math.sum', tab)
-        .toPromise();
+      const result = await lastValueFrom(
+        this.client.send<number>('math.sum', tab),
+      );
 
       return result === expected;
     };
@@ -59,6 +64,28 @@ export class NatsController {
       .reduce(async (a, b) => (await a) && b);
   }
 
+  @Post('record-builder-duplex')
+  @HttpCode(200)
+  useRecordBuilderDuplex(@Body() data: Record<string, any>) {
+    const headers = nats.headers();
+    headers.set('x-version', '1.0.0');
+    const record = new NatsRecordBuilder(data).setHeaders(headers).build();
+    return this.client.send('record-builder-duplex', record);
+  }
+
+  @MessagePattern('record-builder-duplex')
+  handleRecordBuilderDuplex(
+    @Payload() data: Record<string, any>,
+    @Ctx() context: NatsContext,
+  ) {
+    return {
+      data,
+      headers: {
+        ['x-version']: context.getHeaders().get('x-version'),
+      },
+    };
+  }
+
   @MessagePattern('math.*')
   sum(@Payload() data: number[], @Ctx() context: NatsContext): number {
     return (data || []).reduce((a, b) => a + b);
@@ -88,7 +115,7 @@ export class NatsController {
 
   @MessagePattern('exception')
   throwError(): Observable<number> {
-    return throwError(new RpcException('test'));
+    return throwError(() => new RpcException('test'));
   }
 
   @Post('notify')
@@ -100,4 +127,9 @@ export class NatsController {
   eventHandler(@Payload() data: boolean) {
     NatsController.IS_NOTIFIED = data;
   }
+
+  @EventPattern('notification')
+  eventHandler2(@Payload() data: boolean) {
+    NatsController.IS_NOTIFIED2 = data;
+  }
 }

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

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

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

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