chore(@nestjs) publish v10.4.18 release

chore(deps): update dependency prettier to v3.4.2

.circleci/config.yml

@@ -121,7 +121,7 @@ jobs:
   lint:
     working_directory: ~/nest
     docker:
-      - image: cimg/node:<< pipeline.parameters.maintenance-node-version >>
+      - image: cimg/node:<< pipeline.parameters.current-node-version >>
     steps:
       - checkout
       - *restore-cache

.eslintrc.js

@@ -17,13 +17,13 @@ module.exports = {
         sourceType: 'module',
       },
       rules: {
-        '@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',
-        '@typescript-eslint/no-array-constructor': 'off',
+        '@typescript-eslint/no-unsafe-function-type': 'off',
+        '@typescript-eslint/no-unused-expressions': 'off',
+        '@typescript-eslint/no-require-imports': 'off',
+        '@typescript-eslint/no-empty-object-type': 'off',
+        '@typescript-eslint/no-wrapper-object-types': 'off',
       },
     },
     {
@@ -34,13 +34,13 @@ module.exports = {
         sourceType: 'module',
       },
       rules: {
-        '@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',
-        '@typescript-eslint/no-empty-function': 'off',
+        '@typescript-eslint/no-unsafe-function-type': 'off',
+        '@typescript-eslint/no-unused-expressions': 'off',
+        '@typescript-eslint/no-require-imports': 'off',
+        '@typescript-eslint/no-empty-object-type': 'off',
+        '@typescript-eslint/no-wrapper-object-types': 'off',
       },
     }
   ]

.gitignore

@@ -1,4 +1,5 @@
 packages/*/package-lock.json
+sample/*/package-lock.json
 
 # dependencies
 node_modules/
@@ -10,7 +11,7 @@ node_modules/
 /.devcontainer
 /.classpath
 /.project
-/.settings 
+/.settings
 *.code-workspace
 
 # Vim
@@ -50,3 +51,4 @@ build/config\.gypi
 
 .npmrc
 pnpm-lock.yaml
+/.history

integration/docker-compose.yml

@@ -25,7 +25,7 @@ services:
       - "9001:9001"
     restart: always
   mysql:
-    image: mysql:8.3.0
+    image: mysql:9.1.0
     environment:
       MYSQL_ROOT_PASSWORD: root
       MYSQL_DATABASE: test
@@ -50,7 +50,7 @@ services:
   zookeeper:
     container_name: test-zookeeper
     hostname: zookeeper
-    image: confluentinc/cp-zookeeper:7.5.3
+    image: confluentinc/cp-zookeeper:7.8.0
     ports:
       - "2181:2181"
     environment:
@@ -59,7 +59,7 @@ services:
   kafka:
     container_name: test-kafka
     hostname: kafka
-    image: confluentinc/cp-kafka:7.5.3
+    image: confluentinc/cp-kafka:7.8.0
     depends_on:
       - zookeeper
     ports:

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

@@ -43,7 +43,10 @@ describe('OnModuleDestroy', () => {
   it('should sort modules by distance (topological sort) - DESC order', async () => {
     @Injectable()
     class BB implements OnModuleDestroy {
-      onModuleDestroy = Sinon.spy();
+      public field: string;
+      async onModuleDestroy() {
+        this.field = 'b-field';
+      }
     }
 
     @Module({
@@ -54,10 +57,13 @@ describe('OnModuleDestroy', () => {
 
     @Injectable()
     class AA implements OnModuleDestroy {
+      public field: string;
       constructor(private bb: BB) {}
-      onModuleDestroy = Sinon.spy();
-    }
 
+      async onModuleDestroy() {
+        this.field = this.bb.field + '_a-field';
+      }
+    }
     @Module({
       imports: [B],
       providers: [AA],
@@ -72,8 +78,7 @@ describe('OnModuleDestroy', () => {
     await app.init();
     await app.close();
 
-    const aa = module.get(AA);
-    const bb = module.get(BB);
-    Sinon.assert.callOrder(aa.onModuleDestroy, bb.onModuleDestroy);
+    const instance = module.get(AA);
+    expect(instance.field).to.equal('b-field_a-field');
   });
 });

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

@@ -39,39 +39,11 @@ describe('OnModuleInit', () => {
   });
 
   it('should sort modules by distance (topological sort) - DESC order', async () => {
-    @Injectable()
-    class CC implements OnModuleInit {
-      public field: string;
-
-      async onModuleInit() {
-        this.field = 'c-field';
-      }
-    }
-
-    @Module({})
-    class C {
-      static forRoot() {
-        return {
-          module: C,
-          global: true,
-          providers: [
-            {
-              provide: CC,
-              useValue: new CC(),
-            },
-          ],
-          exports: [CC],
-        };
-      }
-    }
-
     @Injectable()
     class BB implements OnModuleInit {
       public field: string;
-      constructor(private cc: CC) {}
-
       async onModuleInit() {
-        this.field = this.cc.field + '_b-field';
+        this.field = 'b-field';
       }
     }
 
@@ -96,19 +68,14 @@ describe('OnModuleInit', () => {
     })
     class A {}
 
-    @Module({
-      imports: [A, C.forRoot()],
-    })
-    class AppModule {}
-
     const module = await Test.createTestingModule({
-      imports: [AppModule],
+      imports: [A],
     }).compile();
 
     const app = module.createNestApplication();
     await app.init();
 
     const instance = module.get(AA);
-    expect(instance.field).to.equal('c-field_b-field_a-field');
+    expect(instance.field).to.equal('b-field_a-field');
   });
 });

integration/inspector/src/external-svc/external-svc.controller.ts

@@ -1,8 +1,8 @@
 import { Controller } from '@nestjs/common';
 import { MessagePattern, Payload } from '@nestjs/microservices';
-import { ExternalSvcService } from './external-svc.service';
 import { CreateExternalSvcDto } from './dto/create-external-svc.dto';
 import { UpdateExternalSvcDto } from './dto/update-external-svc.dto';
+import { ExternalSvcService } from './external-svc.service';
 
 @Controller()
 export class ExternalSvcController {

integration/lazy-modules/e2e/lazy-import-transient-providers.spec.ts

@@ -0,0 +1,32 @@
+import { INestApplication } from '@nestjs/common';
+import { Test } from '@nestjs/testing';
+import { TransientLazyModule } from '../src/transient.module';
+import { LazyController } from '../src/lazy.controller';
+import * as chai from 'chai';
+import { expect } from 'chai';
+import * as request from 'supertest';
+
+describe('Lazy Transient providers', () => {
+  let app: INestApplication;
+
+  beforeEach(async () => {
+    const module = await Test.createTestingModule({
+      controllers: [LazyController],
+    }).compile();
+
+    app = module.createNestApplication();
+    await app.init();
+  });
+
+  it('should not recreate dependencies for default scope', async () => {
+    const resultOne = await request(app.getHttpServer()).get('/lazy/transient');
+
+    const resultTwo = await request(app.getHttpServer()).get('/lazy/transient');
+
+    expect(resultOne.text).to.be.equal('Hi! Counter is 1');
+    expect(resultOne.statusCode).to.be.equal(200);
+
+    expect(resultTwo.text).to.be.equal('Hi! Counter is 2');
+    expect(resultTwo.statusCode).to.be.equal(200);
+  });
+});

integration/lazy-modules/src/eager.module.ts

@@ -3,7 +3,13 @@ import { GlobalService } from './global.module';
 
 @Injectable()
 export class EagerService {
+  private counter = 0;
   constructor(public globalService: GlobalService) {}
+
+  sayHello() {
+    this.counter++;
+    return 'Hi! Counter is ' + this.counter;
+  }
 }
 
 @Module({

integration/lazy-modules/src/lazy.controller.ts

@@ -0,0 +1,18 @@
+import { Controller, Get } from '@nestjs/common';
+import { LazyModuleLoader } from '@nestjs/core';
+
+@Controller('lazy')
+export class LazyController {
+  constructor(private lazyLoadModule: LazyModuleLoader) {}
+
+  @Get('transient')
+  async exec() {
+    const { TransientLazyModule } = await import('./transient.module');
+    const moduleRef = await this.lazyLoadModule.load(() => TransientLazyModule);
+
+    const { TransientService } = await import('./transient.service');
+    const _service = await moduleRef.resolve(TransientService);
+
+    return _service.eager();
+  }
+}

integration/lazy-modules/src/transient.module.ts

@@ -0,0 +1,11 @@
+import { Module } from '@nestjs/common';
+import { GlobalService } from './global.module';
+import { EagerService } from './eager.module';
+import { TransientService } from './transient.service';
+
+@Module({
+  imports: [],
+  providers: [TransientService, GlobalService, EagerService],
+  exports: [TransientService],
+})
+export class TransientLazyModule {}

integration/lazy-modules/src/transient.service.ts

@@ -0,0 +1,11 @@
+import { Injectable, Scope } from '@nestjs/common';
+import { EagerService } from './eager.module';
+
+@Injectable({ scope: Scope.TRANSIENT })
+export class TransientService {
+  constructor(private eagerService: EagerService) {}
+
+  eager() {
+    return this.eagerService.sayHello();
+  }
+}

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

@@ -1,98 +0,0 @@
-import {
-  Controller,
-  INestMicroservice,
-  Injectable,
-  Module,
-} from '@nestjs/common';
-import { NestFactory } from '@nestjs/core';
-import {
-  AsyncOptions,
-  ClientTCP,
-  ClientsModule,
-  MessagePattern,
-  MicroserviceOptions,
-  Payload,
-  TcpOptions,
-  Transport,
-} from '@nestjs/microservices';
-import { expect } from 'chai';
-
-let port: number;
-
-do {
-  port = Math.round(Math.random() * 10000);
-} while (port < 1000);
-
-@Injectable()
-class RpcOptionsProvider {
-  getOptions(): TcpOptions {
-    return {
-      transport: Transport.TCP,
-      options: {
-        port,
-        host: '0.0.0.0',
-      },
-    };
-  }
-}
-
-@Controller()
-class RpcController {
-  @MessagePattern({ cmd: 'sum' })
-  sumPayload(@Payload() payload: number[]) {
-    return payload.reduce((a, b) => a + b, 0);
-  }
-}
-
-@Module({
-  imports: [
-    ClientsModule.register([
-      {
-        name: 'RPC_CLIENT',
-        transport: Transport.TCP,
-        options: {
-          port,
-          host: '0.0.0.0',
-        },
-      },
-    ]),
-  ],
-  controllers: [RpcController],
-  providers: [RpcOptionsProvider],
-})
-class RpcModule {}
-
-describe('RPC Async transport', () => {
-  let app: INestMicroservice;
-  let client: ClientTCP;
-
-  beforeEach(async () => {
-    app = await NestFactory.createMicroservice<
-      AsyncOptions<MicroserviceOptions>
-    >(RpcModule, {
-      logger: false,
-      inject: [RpcOptionsProvider],
-      useFactory: (optionsProvider: RpcOptionsProvider) =>
-        optionsProvider.getOptions(),
-    });
-
-    await app.listen();
-    client = app.get('RPC_CLIENT', { strict: false });
-  });
-
-  it(`/POST`, done => {
-    let retData = 0;
-    client.send({ cmd: 'sum' }, [1, 2, 3, 4, 5]).subscribe({
-      next: val => (retData += val),
-      error: done,
-      complete: () => {
-        expect(retData).to.eq(15);
-        done();
-      },
-    });
-  });
-
-  afterEach(async () => {
-    await app.close();
-  });
-});

integration/microservices/src/disconnected.controller.ts

@@ -24,8 +24,9 @@ export class DisconnectedClientController {
         return throwError(() =>
           code === 'ECONNREFUSED' ||
           code === 'CONN_ERR' ||
+          code === 'ENOTFOUND' ||
           code === 'CONNECTION_REFUSED' ||
-          error.message === 'Connection is closed.'
+          error.message.includes('Connection is closed.')
             ? new RequestTimeoutException('ECONNREFUSED')
             : new InternalServerErrorException(),
         );

integration/microservices/src/tcp-tls/app.module.ts

@@ -1,13 +1,13 @@
-import { Injectable, Module } from '@nestjs/common';
+import { Module, Injectable } from '@nestjs/common';
+import { AppController } from './app.controller';
 import {
-  ClientOptions,
   ClientsModule,
+  Transport,
   ClientsModuleOptionsFactory,
+  ClientOptions,
   ClientTCP,
   RpcException,
-  Transport,
 } from '@nestjs/microservices';
-import { AppController } from './app.controller';
 
 import * as fs from 'fs';
 import * as path from 'path';

integration/scopes/e2e/durable-providers.spec.ts

@@ -27,10 +27,14 @@ describe('Durable providers', () => {
       tenantId: number,
       end: (err?: any) => void,
       endpoint = '/durable',
+      opts: {
+        forceError: boolean;
+      } = { forceError: false },
     ) =>
       request(server)
         .get(endpoint)
-        .set({ ['x-tenant-id']: tenantId })
+        .set({ ['x-tenant-id']: String(tenantId) })
+        .set({ ['x-force-error']: opts.forceError ? 'true' : 'false' })
         .end((err, res) => {
           if (err) return end(err);
           end(res);
@@ -84,6 +88,42 @@ describe('Durable providers', () => {
       );
       expect(result.body).deep.equal({ tenantId: '3' });
     });
+
+    it(`should return the same tenantId both from durable request scoped service and non-durable request scoped service`, async () => {
+      let result: request.Response;
+      result = await new Promise<request.Response>(resolve =>
+        performHttpCall(1, resolve, '/durable/request-context'),
+      );
+      expect(result.body).deep.equal({
+        durableService: '1',
+        nonDurableService: '1',
+      });
+
+      result = await new Promise<request.Response>(resolve =>
+        performHttpCall(2, resolve, '/durable/request-context'),
+      );
+      expect(result.body).deep.equal({
+        durableService: '2',
+        nonDurableService: '2',
+      });
+    });
+    
+    it(`should not cache durable providers that throw errors`, async () => {
+      let result: request.Response;
+
+      result = await new Promise<request.Response>(resolve =>
+        performHttpCall(10, resolve, '/durable/echo', { forceError: true }),
+      );
+
+      expect(result.statusCode).equal(412);
+
+      // The second request should be successful
+      result = await new Promise<request.Response>(resolve =>
+        performHttpCall(10, resolve, '/durable/echo'),
+      );
+
+      expect(result.body).deep.equal({ tenantId: '10' });
+    });
   });
 
   after(async () => {

integration/scopes/src/durable/durable-context-id.strategy.ts

@@ -1,11 +1,18 @@
 import { ContextId, ContextIdStrategy, HostComponentInfo } from '@nestjs/core';
 import { Request } from 'express';
 
+export type TenantContext = {
+  tenantId: string;
+  forceError?: boolean;
+};
+
 const tenants = new Map<string, ContextId>();
 
 export class DurableContextIdStrategy implements ContextIdStrategy {
   attach(contextId: ContextId, request: Request) {
     const tenantId = request.headers['x-tenant-id'] as string;
+    const forceError = request.headers['x-force-error'] === 'true';
+
     let tenantSubTreeId: ContextId;
 
     if (tenants.has(tenantId)) {
@@ -14,10 +21,15 @@ export class DurableContextIdStrategy implements ContextIdStrategy {
       tenantSubTreeId = { id: +tenantId } as ContextId;
       tenants.set(tenantId, tenantSubTreeId);
     }
+
+    const payload: TenantContext = { tenantId };
+    if (forceError) {
+      payload.forceError = true;
+    }
     return {
       resolve: (info: HostComponentInfo) =>
         info.isTreeDurable ? tenantSubTreeId : contextId,
-      payload: { tenantId },
+      payload,
     };
   }
 }

integration/scopes/src/durable/durable.controller.ts

@@ -1,9 +1,13 @@
 import { Controller, Get } from '@nestjs/common';
 import { DurableService } from './durable.service';
+import { NonDurableService } from './non-durable.service';
 
 @Controller('durable')
 export class DurableController {
-  constructor(private readonly durableService: DurableService) {}
+  constructor(
+    private readonly durableService: DurableService,
+    private readonly nonDurableService: NonDurableService,
+  ) {}
 
   @Get()
   greeting(): string {
@@ -12,6 +16,16 @@ export class DurableController {
 
   @Get('echo')
   echo() {
-    return this.durableService.requestPayload;
+    return {
+      tenantId: this.durableService.getTenantId(),
+    };
+  }
+
+  @Get('request-context')
+  getRequestContext() {
+    return {
+      durableService: this.durableService.getTenantId(),
+      nonDurableService: this.nonDurableService.getTenantId(),
+    };
   }
 }

integration/scopes/src/durable/durable.module.ts

@@ -3,11 +3,13 @@ import { APP_GUARD } from '@nestjs/core';
 import { DurableController } from './durable.controller';
 import { DurableGuard } from './durable.guard';
 import { DurableService } from './durable.service';
+import { NonDurableService } from './non-durable.service';
 
 @Module({
   controllers: [DurableController],
   providers: [
     DurableService,
+    NonDurableService,
     {
       provide: APP_GUARD,
       useClass: DurableGuard,

integration/scopes/src/durable/durable.service.ts

@@ -1,14 +1,30 @@
-import { Inject, Injectable, Scope } from '@nestjs/common';
+import {
+  Inject,
+  Injectable,
+  PreconditionFailedException,
+  Scope,
+} from '@nestjs/common';
 import { REQUEST } from '@nestjs/core';
+import { TenantContext } from './durable-context-id.strategy';
 
 @Injectable({ scope: Scope.REQUEST, durable: true })
 export class DurableService {
   public instanceCounter = 0;
 
-  constructor(@Inject(REQUEST) public readonly requestPayload: unknown) {}
+  constructor(
+    @Inject(REQUEST) private readonly requestPayload: TenantContext,
+  ) {
+    if (requestPayload.forceError) {
+      throw new PreconditionFailedException('Forced error');
+    }
+  }
 
   greeting() {
     ++this.instanceCounter;
     return `Hello world! Counter: ${this.instanceCounter}`;
   }
+
+  getTenantId() {
+    return this.requestPayload.tenantId;
+  }
 }

integration/scopes/src/durable/non-durable.service.ts

@@ -0,0 +1,14 @@
+import { Inject, Injectable, Scope } from '@nestjs/common';
+import { REQUEST } from '@nestjs/core';
+import { TenantContext } from './durable-context-id.strategy';
+
+@Injectable()
+export class NonDurableService {
+  constructor(
+    @Inject(REQUEST) private readonly requestPayload: TenantContext,
+  ) {}
+
+  getTenantId() {
+    return this.requestPayload.tenantId;
+  }
+}

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

@@ -11,27 +11,20 @@ describe('ErrorGateway', () => {
     const testingModule = await Test.createTestingModule({
       providers: [ErrorGateway],
     }).compile();
-
-    app = testingModule.createNestApplication();
+    app = await testingModule.createNestApplication();
     await app.listen(3000);
   });
 
   it(`should handle error`, async () => {
     const ws = io('http://localhost:8080');
-    const pattern = 'push';
-    const data = { test: 'test' };
-
-    ws.emit(pattern, data);
-
+    ws.emit('push', {
+      test: 'test',
+    });
     await new Promise<void>(resolve =>
-      ws.on('exception', error => {
-        expect(error).to.be.eql({
+      ws.on('exception', data => {
+        expect(data).to.be.eql({
           status: 'error',
           message: 'test',
-          cause: {
-            pattern,
-            data,
-          },
         });
         resolve();
       }),

integration/websockets/e2e/gateway.spec.ts

@@ -1,7 +1,9 @@
 import { INestApplication } from '@nestjs/common';
 import { Test } from '@nestjs/testing';
 import { expect } from 'chai';
+import * as EventSource from 'eventsource';
 import { io } from 'socket.io-client';
+import { AppController as LongConnectionController } from '../../nest-application/sse/src/app.controller';
 import { ApplicationGateway } from '../src/app.gateway';
 import { NamespaceGateway } from '../src/namespace.gateway';
 import { ServerGateway } from '../src/server.gateway';
@@ -15,7 +17,7 @@ async function createNestApp(...gateways): Promise<INestApplication> {
 }
 
 describe('WebSocketGateway', () => {
-  let ws, app;
+  let ws: ReturnType<typeof io>, app: INestApplication;
 
   it(`should handle message (2nd port)`, async () => {
     app = await createNestApp(ApplicationGateway);
@@ -98,5 +100,78 @@ describe('WebSocketGateway', () => {
     );
   });
 
+  describe('shared server for WS and Long-Running connections', () => {
+    afterEach(() => {});
+    it('should block application shutdown', function (done) {
+      let eventSource;
+
+      (async () => {
+        this.timeout(30000);
+
+        setTimeout(() => {
+          const instance = testingModule.get(ServerGateway);
+          expect(instance.onApplicationShutdown.called).to.be.false;
+          eventSource.close();
+          done();
+        }, 25000);
+
+        const testingModule = await Test.createTestingModule({
+          providers: [ServerGateway],
+          controllers: [LongConnectionController],
+        }).compile();
+        app = testingModule.createNestApplication();
+
+        await app.listen(3000);
+
+        ws = io(`http://localhost:3000`);
+        eventSource = new EventSource(`http://localhost:3000/sse`);
+
+        await new Promise<void>((resolve, reject) => {
+          ws.on('connect', resolve);
+          ws.on('error', reject);
+        });
+
+        await new Promise((resolve, reject) => {
+          eventSource.onmessage = resolve;
+          eventSource.onerror = reject;
+        });
+
+        app.close();
+      })();
+    });
+
+    it('should shutdown application immediately when forceCloseConnections is true', async () => {
+      const testingModule = await Test.createTestingModule({
+        providers: [ServerGateway],
+        controllers: [LongConnectionController],
+      }).compile();
+
+      app = testingModule.createNestApplication({
+        forceCloseConnections: true,
+      });
+
+      await app.listen(3000);
+
+      ws = io(`http://localhost:3000`);
+      const eventSource = new EventSource(`http://localhost:3000/sse`);
+
+      await new Promise<void>((resolve, reject) => {
+        ws.on('connect', resolve);
+        ws.on('error', reject);
+      });
+
+      await new Promise((resolve, reject) => {
+        eventSource.onmessage = resolve;
+        eventSource.onerror = reject;
+      });
+
+      await app.close();
+
+      const instance = testingModule.get(ServerGateway);
+      expect(instance.onApplicationShutdown.called).to.be.true;
+      eventSource.close();
+    });
+  });
+
   afterEach(() => app.close());
 });

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

@@ -218,61 +218,6 @@ describe('WebSocketGateway (WsAdapter)', () => {
     );
   });
 
-  it('should set messageParser by using setMessageParser method', async () => {
-    const testingModule = await Test.createTestingModule({
-      providers: [ApplicationGateway],
-    }).compile();
-    app = testingModule.createNestApplication();
-
-    const wsAdapter = new WsAdapter(app);
-    wsAdapter.setMessageParser(data => {
-      const [event, payload] = JSON.parse(data.toString());
-      return { event, data: payload };
-    });
-    app.useWebSocketAdapter(wsAdapter);
-    await app.listen(3000);
-
-    ws = new WebSocket('ws://localhost:8080');
-    await new Promise(resolve => ws.on('open', resolve));
-
-    ws.send(JSON.stringify(['push', { test: 'test' }]));
-    await new Promise<void>(resolve =>
-      ws.on('message', data => {
-        expect(JSON.parse(data).data.test).to.be.eql('test');
-        ws.close();
-        resolve();
-      }),
-    );
-  });
-
-  it('should set messageParser by using constructor options', async () => {
-    const testingModule = await Test.createTestingModule({
-      providers: [ApplicationGateway],
-    }).compile();
-    app = testingModule.createNestApplication();
-
-    const wsAdapter = new WsAdapter(app, {
-      messageParser: data => {
-        const [event, payload] = JSON.parse(data.toString());
-        return { event, data: payload };
-      },
-    });
-    app.useWebSocketAdapter(wsAdapter);
-    await app.listen(3000);
-
-    ws = new WebSocket('ws://localhost:8080');
-    await new Promise(resolve => ws.on('open', resolve));
-
-    ws.send(JSON.stringify(['push', { test: 'test' }]));
-    await new Promise<void>(resolve =>
-      ws.on('message', data => {
-        expect(JSON.parse(data).data.test).to.be.eql('test');
-        ws.close();
-        resolve();
-      }),
-    );
-  });
-
   afterEach(async function () {
     await app.close();
   });

integration/websockets/src/server.gateway.ts

@@ -1,9 +1,10 @@
-import { UseInterceptors } from '@nestjs/common';
+import { OnApplicationShutdown, UseInterceptors } from '@nestjs/common';
 import { SubscribeMessage, WebSocketGateway } from '@nestjs/websockets';
+import * as Sinon from 'sinon';
 import { RequestInterceptor } from './request.interceptor';
 
 @WebSocketGateway()
-export class ServerGateway {
+export class ServerGateway implements OnApplicationShutdown {
   @SubscribeMessage('push')
   onPush(client, data) {
     return {
@@ -20,4 +21,6 @@ export class ServerGateway {
       data: { ...data, path: client.pattern },
     };
   }
+
+  onApplicationShutdown = Sinon.spy();
 }

lerna.json

@@ -3,5 +3,5 @@
   "packages": [
     "packages/*"
   ],
-  "version": "10.4.7"
+  "version": "10.4.18"
 }

package.json

@@ -59,59 +59,59 @@
   },
   "dependencies": {
     "@nuxtjs/opencollective": "0.3.2",
+    "ansis": "3.3.2",
     "class-transformer": "0.5.1",
     "class-validator": "0.14.1",
-    "cli-color": "2.0.4",
     "cors": "2.8.5",
-    "express": "4.21.1",
+    "express": "4.21.2",
     "fast-json-stringify": "6.0.0",
     "fast-safe-stringify": "2.1.1",
-    "graphql-subscriptions": "2.0.0",
+    "file-type": "20.4.1",
     "iterare": "1.2.1",
     "object-hash": "3.0.0",
-    "path-to-regexp": "3.2.0",
+    "path-to-regexp": "3.3.0",
     "reflect-metadata": "0.2.2",
     "rxjs": "7.8.1",
-    "socket.io": "4.8.0",
-    "tslib": "2.7.0",
+    "socket.io": "4.8.1",
+    "tslib": "2.8.1",
     "uid": "2.0.2",
-    "uuid": "10.0.0"
+    "uuid": "11.1.0"
   },
   "devDependencies": {
-    "@apollo/server": "4.11.0",
+    "@apollo/server": "4.11.2",
     "@codechecks/client": "0.1.12",
-    "@commitlint/cli": "19.5.0",
-    "@commitlint/config-angular": "19.5.0",
+    "@commitlint/cli": "19.6.0",
+    "@commitlint/config-angular": "19.6.0",
     "@fastify/cors": "9.0.1",
     "@fastify/formbody": "7.4.0",
-    "@fastify/middie": "8.3.1",
+    "@fastify/middie": "8.3.3",
     "@fastify/multipart": "8.3.0",
     "@fastify/static": "7.0.4",
     "@fastify/view": "9.1.0",
-    "@grpc/grpc-js": "1.11.1",
+    "@grpc/grpc-js": "1.12.4",
     "@grpc/proto-loader": "0.7.13",
-    "@nestjs/apollo": "12.2.0",
-    "@nestjs/graphql": "12.2.0",
-    "@nestjs/mongoose": "10.0.10",
+    "@nestjs/apollo": "12.2.2",
+    "@nestjs/graphql": "12.2.2",
+    "@nestjs/mongoose": "10.1.0",
     "@nestjs/typeorm": "10.0.2",
-    "@types/amqplib": "0.10.5",
-    "@types/bytes": "3.1.4",
-    "@types/chai": "4.3.16",
+    "@types/amqplib": "0.10.6",
+    "@types/bytes": "3.1.5",
+    "@types/chai": "4.3.20",
     "@types/chai-as-promised": "7.1.8",
     "@types/cors": "2.8.17",
     "@types/express": "4.17.21",
     "@types/gulp": "4.0.17",
     "@types/http-errors": "2.0.4",
-    "@types/mocha": "10.0.8",
-    "@types/node": "22.5.5",
+    "@types/mocha": "10.0.10",
+    "@types/node": "22.10.0",
     "@types/sinon": "17.0.3",
-    "@types/supertest": "2.0.16",
-    "@types/ws": "8.5.12",
-    "@typescript-eslint/eslint-plugin": "7.18.0",
-    "@typescript-eslint/parser": "7.18.0",
+    "@types/supertest": "6.0.2",
+    "@types/ws": "8.5.13",
+    "@typescript-eslint/eslint-plugin": "8.17.0",
+    "@typescript-eslint/parser": "8.17.0",
     "amqp-connection-manager": "4.1.14",
-    "amqplib": "0.10.4",
-    "artillery": "2.0.20",
+    "amqplib": "0.10.5",
+    "artillery": "2.0.21",
     "body-parser": "1.20.3",
     "bytes": "3.1.2",
     "cache-manager": "5.7.6",
@@ -119,57 +119,58 @@
     "chai": "4.5.0",
     "chai-as-promised": "7.1.2",
     "clang-format": "1.8.0",
-    "concurrently": "9.0.1",
+    "concurrently": "9.1.0",
     "conventional-changelog": "6.0.0",
-    "core-js": "3.38.1",
+    "core-js": "3.39.0",
     "coveralls": "3.1.1",
     "delete-empty": "3.0.0",
-    "engine.io-client": "6.6.1",
+    "engine.io-client": "6.6.2",
     "eslint": "8.57.1",
     "eslint-config-prettier": "9.1.0",
-    "eslint-plugin-import": "2.29.1",
+    "eslint-plugin-import": "2.31.0",
     "eventsource": "2.0.2",
     "fancy-log": "2.0.0",
     "fastify": "4.28.1",
     "graphql": "16.9.0",
-    "graphql-tools": "9.0.1",
-    "gulp": "4.0.2",
+    "graphql-tools": "9.0.5",
+    "graphql-subscriptions": "2.0.0",
+    "gulp": "5.0.0",
     "gulp-clang-format": "1.0.27",
     "gulp-clean": "0.4.0",
     "gulp-sourcemaps": "3.0.0",
     "gulp-typescript": "5.0.1",
     "gulp-watch": "5.0.1",
     "http-errors": "2.0.0",
-    "husky": "9.1.5",
+    "husky": "9.1.7",
     "imports-loader": "5.0.0",
     "ioredis": "5.4.1",
     "json-loader": "0.5.7",
     "kafkajs": "2.2.4",
     "lerna": "2.11.0",
     "lerna-changelog": "2.2.0",
-    "light-my-request": "6.1.0",
+    "light-my-request": "6.3.0",
     "lint-staged": "15.2.10",
     "markdown-table": "2.0.0",
-    "mocha": "10.7.3",
-    "mongoose": "8.6.2",
-    "mqtt": "5.6.0",
+    "mocha": "10.8.2",
+    "mongoose": "8.8.4",
+    "mqtt": "5.10.3",
     "multer": "1.4.4",
-    "mysql2": "3.11.3",
+    "mysql2": "3.11.4",
     "nats": "2.28.2",
-    "nodemon": "3.1.5",
-    "nyc": "14.1.1",
-    "prettier": "3.3.3",
+    "nodemon": "3.1.7",
+    "nyc": "17.1.0",
+    "prettier": "3.4.2",
     "redis": "4.7.0",
     "rxjs-compat": "6.6.7",
     "sinon": "19.0.2",
-    "sinon-chai": "3.7.0",
-    "socket.io-client": "4.8.0",
+    "sinon-chai": "4.0.0",
+    "socket.io-client": "4.8.1",
     "subscriptions-transport-ws": "0.11.0",
     "supertest": "7.0.0",
-    "ts-morph": "23.0.0",
+    "ts-morph": "24.0.0",
     "ts-node": "10.9.2",
     "typeorm": "0.3.20",
-    "typescript": "5.6.2",
+    "typescript": "5.6.3",
     "wrk": "1.2.1",
     "ws": "8.18.0"
   },

packages/common/Readme.md

@@ -94,7 +94,7 @@ Nest is an MIT-licensed open source project. It can grow thanks to the sponsors
 <td><a href="https://www.mercedes-benz.com/" target="_blank"><img src="https://nestjs.com/img/logos/mercedes-logo.png" width="100" valign="middle" /></a></td>
 <td><a href="https://www.dinii.jp/" target="_blank"><img src="https://nestjs.com/img/logos/dinii-logo.png" width="65" valign="middle" /></a></td>
 <td><a href="https://bloodycase.com/?promocode=NEST" target="_blank"><img src="https://nestjs.com/img/logos/bloodycase-logo.png" width="65" valign="middle" /></a></td>
-<td><a href="https://handsontable.com/docs/react-data-grid/?utm_source=NestJS_GH&utm_medium=sponsorship&utm_campaign=library_sponsorship_2024" target="_blank"><img src="https://nestjs.com/img/logos/handsontable-logo.svg" width="150" valign="middle" /></a></td>
+<td><a href="https://handsontable.com/docs/react-data-grid/?utm_source=NestJS_GH&utm_medium=sponsorship&utm_campaign=library_sponsorship_2024" target="_blank"><img src="https://nestjs.com/img/logos/handsontable-dark-logo.svg#2" width="150" valign="middle" /></a></td>
 <td align="center" valign="middle"><a href="https://www.itflashcards.com/" target="_blank"><img src="https://nestjs.com/img/logos/it_flashcards-logo.png" width="170" valign="middle" /></a></td>
 <td align="center" valign="middle"><a href="https://arcjet.com/?ref=nestjs" target="_blank"><img src="https://nestjs.com/img/logos/arcjet-logo.svg" width="170" valign="middle" /></a></td>
 </tr>

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

@@ -3,7 +3,6 @@ import {
   PROPERTY_DEPS_METADATA,
   SELF_DECLARED_DEPS_METADATA,
 } from '../../constants';
-import { ForwardReference, InjectionToken } from '../../interfaces';
 import { isUndefined } from '../../utils/shared.utils';
 
 /**
@@ -35,8 +34,8 @@ import { isUndefined } from '../../utils/shared.utils';
  *
  * @publicApi
  */
-export function Inject(
-  token?: InjectionToken | ForwardReference,
+export function Inject<T = any>(
+  token?: T,
 ): PropertyDecorator & ParameterDecorator {
   const injectCallHasArguments = arguments.length > 0;
 

packages/common/decorators/http/create-route-param-metadata.decorator.ts

@@ -16,8 +16,12 @@ export type ParamDecoratorEnhancer = ParameterDecorator;
  *
  * @publicApi
  */
-export function createParamDecorator<FactoryData = any, FactoryOutput = any>(
-  factory: CustomParamFactory<FactoryData, FactoryOutput>,
+export function createParamDecorator<
+  FactoryData = any,
+  FactoryInput = any,
+  FactoryOutput = any,
+>(
+  factory: CustomParamFactory<FactoryData, FactoryInput, FactoryOutput>,
   enhancers: ParamDecoratorEnhancer[] = [],
 ): (
   ...dataOrPipes: (Type<PipeTransform> | PipeTransform | FactoryData)[]

packages/common/decorators/http/request-mapping.decorator.ts

@@ -118,66 +118,3 @@ export const All = createMappingDecorator(RequestMethod.ALL);
  * @publicApi
  */
 export const Search = createMappingDecorator(RequestMethod.SEARCH);
-
-/**
- * Route handler (method) Decorator. Routes Webdav PROPFIND requests to the specified path.
- *
- * @see [Routing](https://docs.nestjs.com/controllers#routing)
- *
- * @publicApi
- */
-export const Propfind = createMappingDecorator(RequestMethod.PROPFIND);
-
-/**
- * Route handler (method) Decorator. Routes Webdav PROPPATCH requests to the specified path.
- *
- * @see [Routing](https://docs.nestjs.com/controllers#routing)
- *
- * @publicApi
- */
-export const Proppatch = createMappingDecorator(RequestMethod.PROPPATCH);
-
-/**
- * Route handler (method) Decorator. Routes Webdav MKCOL requests to the specified path.
- *
- * @see [Routing](https://docs.nestjs.com/controllers#routing)
- *
- * @publicApi
- */
-export const Mkcol = createMappingDecorator(RequestMethod.MKCOL);
-
-/**
- * Route handler (method) Decorator. Routes Webdav COPY requests to the specified path.
- *
- * @see [Routing](https://docs.nestjs.com/controllers#routing)
- *
- * @publicApi
- */
-export const Copy = createMappingDecorator(RequestMethod.COPY);
-
-/**
- * Route handler (method) Decorator. Routes Webdav MOVE requests to the specified path.
- *
- * @see [Routing](https://docs.nestjs.com/controllers#routing)
- *
- * @publicApi
- */
-export const Move = createMappingDecorator(RequestMethod.MOVE);
-
-/**
- * Route handler (method) Decorator. Routes Webdav LOCK requests to the specified path.
- *
- * @see [Routing](https://docs.nestjs.com/controllers#routing)
- *
- * @publicApi
- */
-export const Lock = createMappingDecorator(RequestMethod.LOCK);
-
-/**
- * Route handler (method) Decorator. Routes Webdav UNLOCK requests to the specified path.
- *
- * @see [Routing](https://docs.nestjs.com/controllers#routing)
- *
- * @publicApi
- */
-export const Unlock = createMappingDecorator(RequestMethod.UNLOCK);

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

@@ -524,6 +524,32 @@ export function Body(
  */
 export function RawBody(): ParameterDecorator;
 
+/**
+ * Route handler parameter decorator. Extracts the `rawBody` Buffer
+ * property from the `req` object and populates the decorated parameter with that value.
+ * Also applies pipes to the bound rawBody parameter.
+ *
+ * For example:
+ * ```typescript
+ * async create(@RawBody(new ValidationPipe()) rawBody: Buffer)
+ * ```
+ *
+ * @param pipes one or more pipes - either instances or classes - to apply to
+ * the bound body parameter.
+ *
+ * @see [Request object](https://docs.nestjs.com/controllers#request-object)
+ * @see [Raw body](https://docs.nestjs.com/faq/raw-body)
+ * @see [Working with pipes](https://docs.nestjs.com/custom-decorators#working-with-pipes)
+ *
+ * @publicApi
+ */
+export function RawBody(
+  ...pipes: (
+    | Type<PipeTransform<Buffer | undefined>>
+    | PipeTransform<Buffer | undefined>
+  )[]
+): ParameterDecorator;
+
 /**
  * Route handler parameter decorator. Extracts the `rawBody` Buffer
  * property from the `req` object and populates the decorated parameter with that value.

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

@@ -13,9 +13,6 @@ export enum HttpStatus {
   NO_CONTENT = 204,
   RESET_CONTENT = 205,
   PARTIAL_CONTENT = 206,
-  MULTI_STATUS = 207,
-  ALREADY_REPORTED = 208,
-  CONTENT_DIFFERENT = 210,
   AMBIGUOUS = 300,
   MOVED_PERMANENTLY = 301,
   FOUND = 302,
@@ -44,17 +41,13 @@ export enum HttpStatus {
   I_AM_A_TEAPOT = 418,
   MISDIRECTED = 421,
   UNPROCESSABLE_ENTITY = 422,
-  LOCKED = 423,
   FAILED_DEPENDENCY = 424,
   PRECONDITION_REQUIRED = 428,
   TOO_MANY_REQUESTS = 429,
-  UNRECOVERABLE_ERROR = 456,
   INTERNAL_SERVER_ERROR = 500,
   NOT_IMPLEMENTED = 501,
   BAD_GATEWAY = 502,
   SERVICE_UNAVAILABLE = 503,
   GATEWAY_TIMEOUT = 504,
   HTTP_VERSION_NOT_SUPPORTED = 505,
-  INSUFFICIENT_STORAGE = 507,
-  LOOP_DETECTED = 508,
 }

packages/common/enums/request-method.enum.ts

@@ -8,11 +8,4 @@ export enum RequestMethod {
   OPTIONS,
   HEAD,
   SEARCH,
-  PROPFIND,
-  PROPPATCH,
-  MKCOL,
-  COPY,
-  MOVE,
-  LOCK,
-  UNLOCK,
 }

packages/common/exceptions/http.exception.ts

@@ -2,8 +2,7 @@ import {
   HttpExceptionBody,
   HttpExceptionBodyMessage,
 } from '../interfaces/http/http-exception-body.interface';
-import { isNumber, isObject, isString } from '../utils/shared.utils';
-import { IntrinsicException } from './intrinsic.exception';
+import { isObject, isString } from '../utils/shared.utils';
 
 export interface HttpExceptionOptions {
   /** original cause of the error */
@@ -24,13 +23,7 @@ export interface DescriptionAndOptions {
  *
  * @publicApi
  */
-export class HttpException extends IntrinsicException {
-  /**
-   * Exception cause. Indicates the specific original cause of the error.
-   * It is used when catching and re-throwing an error with a more-specific or useful error message in order to still have access to the original error.
-   */
-  public cause: unknown;
-
+export class HttpException extends Error {
   /**
    * Instantiate a plain HTTP Exception.
    *
@@ -75,6 +68,8 @@ export class HttpException extends IntrinsicException {
     this.initCause();
   }
 
+  public cause: unknown;
+
   /**
    * Configures error chaining support
    *
@@ -120,14 +115,17 @@ export class HttpException extends IntrinsicException {
     message: HttpExceptionBodyMessage,
     statusCode: number,
   ): HttpExceptionBody;
+
   public static createBody(
     message: HttpExceptionBodyMessage,
     error: string,
     statusCode: number,
   ): HttpExceptionBody;
+
   public static createBody<Body extends Record<string, unknown>>(
     custom: Body,
   ): Body;
+
   public static createBody<Body extends Record<string, unknown>>(
     arg0: null | HttpExceptionBodyMessage | Body,
     arg1?: HttpExceptionBodyMessage | string,
@@ -140,7 +138,7 @@ export class HttpException extends IntrinsicException {
       };
     }
 
-    if (isString(arg0) || Array.isArray(arg0) || isNumber(arg0)) {
+    if (isString(arg0) || Array.isArray(arg0)) {
       return {
         message: arg0,
         error: arg1 as string,

packages/common/exceptions/index.ts

@@ -1,23 +1,22 @@
-export * from './bad-gateway.exception';
 export * from './bad-request.exception';
-export * from './conflict.exception';
-export * from './forbidden.exception';
-export * from './gateway-timeout.exception';
-export * from './gone.exception';
-export * from './http-version-not-supported.exception';
 export * from './http.exception';
-export * from './im-a-teapot.exception';
-export * from './internal-server-error.exception';
-export * from './intrinsic.exception';
-export * from './method-not-allowed.exception';
-export * from './misdirected.exception';
-export * from './not-acceptable.exception';
-export * from './not-found.exception';
-export * from './not-implemented.exception';
-export * from './payload-too-large.exception';
-export * from './precondition-failed.exception';
-export * from './request-timeout.exception';
-export * from './service-unavailable.exception';
 export * from './unauthorized.exception';
-export * from './unprocessable-entity.exception';
+export * from './method-not-allowed.exception';
+export * from './not-found.exception';
+export * from './forbidden.exception';
+export * from './not-acceptable.exception';
+export * from './request-timeout.exception';
+export * from './conflict.exception';
+export * from './gone.exception';
+export * from './payload-too-large.exception';
 export * from './unsupported-media-type.exception';
+export * from './unprocessable-entity.exception';
+export * from './internal-server-error.exception';
+export * from './not-implemented.exception';
+export * from './http-version-not-supported.exception';
+export * from './bad-gateway.exception';
+export * from './service-unavailable.exception';
+export * from './gateway-timeout.exception';
+export * from './im-a-teapot.exception';
+export * from './precondition-failed.exception';
+export * from './misdirected.exception';

packages/common/exceptions/intrinsic.exception.ts

@@ -1,7 +0,0 @@
-/**
- * Exception that represents an intrinsic error in the application.
- * When thrown, the default exception filter will not log the error message.
- *
- * @publicApi
- */
-export class IntrinsicException extends Error {}

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

@@ -1,9 +1,9 @@
 import { Readable } from 'stream';
 import { types } from 'util';
 import { HttpStatus } from '../enums';
-import { Logger } from '../services';
 import { isFunction } from '../utils/shared.utils';
 import { StreamableFileOptions, StreamableHandlerResponse } from './interfaces';
+import { Logger } from '../services';
 
 /**
  * @see [Streaming files](https://docs.nestjs.com/techniques/streaming-files)
@@ -31,7 +31,7 @@ export class StreamableFile {
   };
 
   protected logError: (err: Error) => void = (err: Error) => {
-    this.logger.error(err);
+    this.logger.error(err.message, err.stack);
   };
 
   constructor(buffer: Uint8Array, options?: StreamableFileOptions);

packages/common/interfaces/external/transformer-package.interface.ts

@@ -2,7 +2,7 @@ import { Type } from '../type.interface';
 import { ClassTransformOptions } from './class-transform-options.interface';
 
 export interface TransformerPackage {
-  plainToInstance<T>(
+  plainToClass<T>(
     cls: Type<T>,
     plain: unknown,
     options?: ClassTransformOptions,

packages/common/interfaces/features/custom-route-param-factory.interface.ts

@@ -1,9 +1,7 @@
-import { ExecutionContext } from './execution-context.interface';
-
 /**
  * @publicApi
  */
-export type CustomParamFactory<TData = any, TOutput = any> = (
+export type CustomParamFactory<TData = any, TInput = any, TOutput = any> = (
   data: TData,
-  context: ExecutionContext,
+  input: TInput,
 ) => TOutput;

packages/common/interfaces/http/http-exception-body.interface.ts

@@ -1,4 +1,4 @@
-export type HttpExceptionBodyMessage = string | string[] | number;
+export type HttpExceptionBodyMessage = string | string[];
 
 export interface HttpExceptionBody {
   message: HttpExceptionBodyMessage;

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

@@ -47,20 +47,6 @@ export interface HttpServer<
   put(path: string, handler: RequestHandler<TRequest, TResponse>): any;
   patch(handler: RequestHandler<TRequest, TResponse>): any;
   patch(path: string, handler: RequestHandler<TRequest, TResponse>): any;
-  propfind?(handler: RequestHandler<TRequest, TResponse>): any;
-  propfind?(path: string, handler: RequestHandler<TRequest, TResponse>): any;
-  proppatch?(handler: RequestHandler<TRequest, TResponse>): any;
-  proppatch?(path: string, handler: RequestHandler<TRequest, TResponse>): any;
-  mkcol?(handler: RequestHandler<TRequest, TResponse>): any;
-  mkcol?(path: string, handler: RequestHandler<TRequest, TResponse>): any;
-  copy?(handler: RequestHandler<TRequest, TResponse>): any;
-  copy?(path: string, handler: RequestHandler<TRequest, TResponse>): any;
-  move?(handler: RequestHandler<TRequest, TResponse>): any;
-  move?(path: string, handler: RequestHandler<TRequest, TResponse>): any;
-  lock?(handler: RequestHandler<TRequest, TResponse>): any;
-  lock?(path: string, handler: RequestHandler<TRequest, TResponse>): any;
-  unlock?(handler: RequestHandler<TRequest, TResponse>): any;
-  unlock?(path: string, handler: RequestHandler<TRequest, TResponse>): any;
   all(path: string, handler: RequestHandler<TRequest, TResponse>): any;
   all(handler: RequestHandler<TRequest, TResponse>): any;
   options(handler: RequestHandler<TRequest, TResponse>): any;

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

@@ -35,6 +35,7 @@ export interface ModuleMetadata {
    */
   exports?: Array<
     | DynamicModule
+    | Promise<DynamicModule>
     | string
     | symbol
     | Provider

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

@@ -44,13 +44,4 @@ export class NestApplicationContextOptions {
    * @default false
    */
   snapshot?: boolean;
-
-  /**
-   * Determines what algorithm use to generate module ids.
-   * When set to `deep-hash`, the module id is generated based on the serialized module definition.
-   * When set to `reference`, each module obtains a unique id based on its reference.
-   *
-   * @default 'reference'
-   */
-  moduleIdGeneratorAlgorithm?: 'deep-hash' | 'reference';
 }

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

@@ -1,11 +1,8 @@
 import { ShutdownSignal } from '../enums/shutdown-signal.enum';
 import { LoggerService, LogLevel } from '../services/logger.service';
 import { DynamicModule } from './modules';
-import { NestApplicationContextOptions } from './nest-application-context-options.interface';
 import { Type } from './type.interface';
 
-export type SelectOptions = Pick<NestApplicationContextOptions, 'abortOnError'>;
-
 export interface GetOrResolveOptions {
   /**
    * If enabled, lookup will only be performed in the host module.
@@ -30,10 +27,7 @@ export interface INestApplicationContext {
    * Allows navigating through the modules tree, for example, to pull out a specific instance from the selected module.
    * @returns {INestApplicationContext}
    */
-  select<T>(
-    module: Type<T> | DynamicModule,
-    options?: SelectOptions,
-  ): INestApplicationContext;
+  select<T>(module: Type<T> | DynamicModule): INestApplicationContext;
 
   /**
    * Retrieves an instance of either injectable or controller, otherwise, throws exception.

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

@@ -1,4 +1,3 @@
-import { Observable } from 'rxjs';
 import { ExceptionFilter } from './exceptions/exception-filter.interface';
 import { CanActivate } from './features/can-activate.interface';
 import { NestInterceptor } from './features/nest-interceptor.interface';
@@ -20,8 +19,8 @@ export interface INestMicroservice extends INestApplicationContext {
   listen(): Promise<any>;
 
   /**
-   * Registers a web socket adapter that will be used for Gateways.
-   * Use to override the default `socket.io` library.
+   * Register Ws Adapter which will be used inside Gateways.
+   * Use when you want to override default `socket.io` library.
    *
    * @param {WebSocketAdapter} adapter
    * @returns {this}
@@ -29,64 +28,37 @@ export interface INestMicroservice extends INestApplicationContext {
   useWebSocketAdapter(adapter: WebSocketAdapter): this;
 
   /**
-   * Registers global exception filters (will be used for every pattern handler).
+   * Registers exception filters as global filters (will be used within every message pattern handler)
    *
    * @param {...ExceptionFilter} filters
    */
   useGlobalFilters(...filters: ExceptionFilter[]): this;
 
   /**
-   * Registers global pipes (will be used for every pattern handler).
+   * Registers pipes as global pipes (will be used within every message pattern handler)
    *
    * @param {...PipeTransform} pipes
    */
   useGlobalPipes(...pipes: PipeTransform<any>[]): this;
 
   /**
-   * Registers global interceptors (will be used for every pattern handler).
+   * Registers interceptors as global interceptors (will be used within every message pattern handler)
    *
    * @param {...NestInterceptor} interceptors
    */
   useGlobalInterceptors(...interceptors: NestInterceptor[]): this;
 
   /**
-   * Registers global guards (will be used for every pattern handler).
+   * Registers guards as global guards (will be used within every message pattern handler)
    *
    * @param {...CanActivate} guards
    */
   useGlobalGuards(...guards: CanActivate[]): this;
 
   /**
-   * Terminates the application.
+   * Terminates the application
    *
    * @returns {Promise<void>}
    */
   close(): Promise<void>;
-
-  /**
-   * Returns an observable that emits status changes.
-   *
-   * @returns {Observable<string>}
-   */
-  status: Observable<string>;
-
-  /**
-   * Registers an event listener for the given event.
-   * @param event Event name
-   * @param callback Callback to be executed when the event is emitted
-   */
-  on<
-    EventsMap extends Record<string, Function> = Record<string, Function>,
-    EventKey extends keyof EventsMap = keyof EventsMap,
-    EventCallback extends EventsMap[EventKey] = EventsMap[EventKey],
-  >(
-    event: EventKey,
-    callback: EventCallback,
-  ): void;
-
-  /**
-   * Returns an instance of the underlying server/broker instance,
-   * or a group of servers if there are more than one.
-   */
-  unwrap<T>(): T;
 }

packages/common/module-utils/utils/get-injection-providers.util.ts

@@ -1,3 +1,4 @@
+import { isUndefined } from '../../utils/shared.utils';
 import {
   InjectionToken,
   Provider,
@@ -6,15 +7,17 @@ import {
 } from '../../interfaces';
 
 /**
- * check if x is OptionalFactoryDependency, based on prototype presence
- * (to avoid classes with a static 'token' field)
- * @param x
- * @returns x is OptionalFactoryDependency
+ * @param value
+ * @returns `true` if value is `OptionalFactoryDependency`
  */
 function isOptionalFactoryDependency(
-  x: InjectionToken | OptionalFactoryDependency,
-): x is OptionalFactoryDependency {
-  return !!((x as any)?.token && !(x as any)?.prototype);
+  value: InjectionToken | OptionalFactoryDependency,
+): value is OptionalFactoryDependency {
+  return (
+    !isUndefined((value as OptionalFactoryDependency).token) &&
+    !isUndefined((value as OptionalFactoryDependency).optional) &&
+    !(value as any).prototype
+  );
 }
 
 const mapInjectToTokens = (t: InjectionToken | OptionalFactoryDependency) =>

packages/common/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nestjs/common",
-  "version": "10.4.7",
+  "version": "10.4.18",
   "description": "Nest - modern, fast, powerful node.js web framework (@common)",
   "author": "Kamil Mysliwiec",
   "homepage": "https://nestjs.com",
@@ -18,8 +18,9 @@
   },
   "license": "MIT",
   "dependencies": {
+    "file-type": "20.4.1",
     "iterare": "1.2.1",
-    "tslib": "2.7.0",
+    "tslib": "2.8.1",
     "uid": "2.0.2"
   },
   "peerDependencies": {

packages/common/pipes/file/file-type.validator.ts

@@ -3,14 +3,19 @@ import { IFile } from './interfaces';
 
 export type FileTypeValidatorOptions = {
   fileType: string | RegExp;
+
+  /**
+   * If `true`, the validator will skip the magic numbers validation.
+   * This can be useful when you can't identify some files as there are no common magic numbers available for some file types.
+   * @default false
+   */
+  skipMagicNumbersValidation?: boolean;
 };
 
 /**
- * Defines the built-in FileType File Validator. It validates incoming files mime-type
- * matching a string or a regular expression. Note that this validator uses a naive strategy
- * to check the mime-type and could be fooled if the client provided a file with renamed extension.
- * (for instance, renaming a 'malicious.bat' to 'malicious.jpeg'). To handle such security issues
- * with more reliability, consider checking against the file's [magic-numbers](https://en.wikipedia.org/wiki/Magic_number_%28programming%29)
+ * Defines the built-in FileTypeValidator. It validates incoming files by examining
+ * their magic numbers using the file-type package, providing more reliable file type validation
+ * than just checking the mimetype string.
  *
  * @see [File Validators](https://docs.nestjs.com/techniques/file-upload#validators)
  *
@@ -20,19 +25,42 @@ export class FileTypeValidator extends FileValidator<
   FileTypeValidatorOptions,
   IFile
 > {
-  buildErrorMessage(): string {
+  buildErrorMessage(file?: IFile): string {
+    if (file?.mimetype) {
+      return `Validation failed (current file type is ${file.mimetype}, expected type is ${this.validationOptions.fileType})`;
+    }
     return `Validation failed (expected type is ${this.validationOptions.fileType})`;
   }
 
-  isValid(file?: IFile): boolean {
+  async isValid(file?: IFile): Promise<boolean> {
     if (!this.validationOptions) {
       return true;
     }
 
-    return (
-      !!file &&
-      'mimetype' in file &&
-      !!file.mimetype.match(this.validationOptions.fileType)
-    );
+    const isFileValid = !!file && 'mimetype' in file;
+
+    if (this.validationOptions.skipMagicNumbersValidation) {
+      return (
+        isFileValid && !!file.mimetype.match(this.validationOptions.fileType)
+      );
+    }
+
+    if (!isFileValid || !file.buffer) {
+      return false;
+    }
+
+    try {
+      const { fileTypeFromBuffer } = (await eval(
+        'import ("file-type")',
+      )) as typeof import('file-type');
+
+      const fileType = await fileTypeFromBuffer(file.buffer);
+
+      return (
+        !!fileType && !!fileType.mime.match(this.validationOptions.fileType)
+      );
+    } catch {
+      return false;
+    }
   }
 }

packages/common/pipes/file/interfaces/file.interface.ts

@@ -1,4 +1,5 @@
 export interface IFile {
   mimetype: string;
   size: number;
+  buffer?: Buffer;
 }

packages/common/pipes/index.ts

@@ -1,10 +1,9 @@
 export * from './default-value.pipe';
-export * from './file';
 export * from './parse-array.pipe';
 export * from './parse-bool.pipe';
-export * from './parse-date.pipe';
-export * from './parse-enum.pipe';
-export * from './parse-float.pipe';
 export * from './parse-int.pipe';
+export * from './parse-float.pipe';
+export * from './parse-enum.pipe';
 export * from './parse-uuid.pipe';
 export * from './validation.pipe';
+export * from './file';

packages/common/pipes/parse-array.pipe.ts

@@ -7,7 +7,7 @@ import {
   PipeTransform,
 } from '../interfaces/features/pipe-transform.interface';
 import { HttpErrorByCode } from '../utils/http-error-by-code.util';
-import { isNil, isString, isUndefined } from '../utils/shared.utils';
+import { isNil, isUndefined, isString } from '../utils/shared.utils';
 import { ValidationPipe, ValidationPipeOptions } from './validation.pipe';
 
 const VALIDATION_ERROR_MESSAGE = 'Validation failed (parsable array expected)';
@@ -21,26 +21,9 @@ export interface ParseArrayOptions
     ValidationPipeOptions,
     'transform' | 'validateCustomDecorators' | 'exceptionFactory'
   > {
-  /**
-   * Type for items to be converted into
-   */
   items?: Type<unknown>;
-  /**
-   * Items separator to split string by
-   * @default ','
-   */
   separator?: string;
-  /**
-   * If true, the pipe will return null or undefined if the value is not provided
-   * @default false
-   */
   optional?: boolean;
-  /**
-   * A factory function that returns an exception object to be thrown
-   * if validation fails.
-   * @param error Error message or object
-   * @returns The exception object
-   */
   exceptionFactory?: (error: any) => any;
 }
 

packages/common/pipes/parse-bool.pipe.ts

@@ -15,21 +15,8 @@ import { isNil } from '../utils/shared.utils';
  * @publicApi
  */
 export interface ParseBoolPipeOptions {
-  /**
-   * The HTTP status code to be used in the response when the validation fails.
-   */
   errorHttpStatusCode?: ErrorHttpStatusCode;
-  /**
-   * A factory function that returns an exception object to be thrown
-   * if validation fails.
-   * @param error Error message
-   * @returns The exception object
-   */
   exceptionFactory?: (error: string) => any;
-  /**
-   * If true, the pipe will return null or undefined if the value is not provided
-   * @default false
-   */
   optional?: boolean;
 }
 

packages/common/pipes/parse-date.pipe.ts

@@ -1,74 +0,0 @@
-import { Injectable } from '../decorators/core/injectable.decorator';
-import { HttpStatus } from '../enums/http-status.enum';
-import { PipeTransform } from '../interfaces/features/pipe-transform.interface';
-import {
-  ErrorHttpStatusCode,
-  HttpErrorByCode,
-} from '../utils/http-error-by-code.util';
-import { isNil } from '../utils/shared.utils';
-
-export interface ParseDatePipeOptions {
-  /**
-   * If true, the pipe will return null or undefined if the value is not provided
-   * @default false
-   */
-  optional?: boolean;
-  /**
-   * Default value for the date
-   */
-  default?: () => Date;
-  /**
-   * The HTTP status code to be used in the response when the validation fails.
-   */
-  errorHttpStatusCode?: ErrorHttpStatusCode;
-  /**
-   * A factory function that returns an exception object to be thrown
-   * if validation fails.
-   * @param error Error message
-   * @returns The exception object
-   */
-  exceptionFactory?: (error: string) => any;
-}
-
-@Injectable()
-export class ParseDatePipe
-  implements PipeTransform<string | number | undefined | null>
-{
-  protected exceptionFactory: (error: string) => any;
-
-  constructor(private readonly options: ParseDatePipeOptions = {}) {
-    const { exceptionFactory, errorHttpStatusCode = HttpStatus.BAD_REQUEST } =
-      options;
-
-    this.exceptionFactory =
-      exceptionFactory ||
-      (error => new HttpErrorByCode[errorHttpStatusCode](error));
-  }
-
-  /**
-   * Method that accesses and performs optional transformation on argument for
-   * in-flight requests.
-   *
-   * @param value currently processed route argument
-   * @param metadata contains metadata about the currently processed route argument
-   */
-  transform(value: string | number | undefined | null): Date {
-    if (this.options.optional && isNil(value)) {
-      return this.options.default
-        ? this.options.default()
-        : (value as undefined | null);
-    }
-
-    if (!value) {
-      throw this.exceptionFactory('Validation failed (no Date provided)');
-    }
-
-    const transformedValue = new Date(value);
-
-    if (isNaN(transformedValue.getTime())) {
-      throw this.exceptionFactory('Validation failed (invalid date format)');
-    }
-
-    return transformedValue;
-  }
-}

packages/common/pipes/parse-enum.pipe.ts

@@ -11,21 +11,8 @@ import { isNil } from '../utils/shared.utils';
  * @publicApi
  */
 export interface ParseEnumPipeOptions {
-  /**
-   * If true, the pipe will return null or undefined if the value is not provided
-   * @default false
-   */
   optional?: boolean;
-  /**
-   * The HTTP status code to be used in the response when the validation fails.
-   */
   errorHttpStatusCode?: ErrorHttpStatusCode;
-  /**
-   * A factory function that returns an exception object to be thrown
-   * if validation fails.
-   * @param error Error message
-   * @returns The exception object
-   */
   exceptionFactory?: (error: string) => any;
 }
 

packages/common/pipes/parse-float.pipe.ts

@@ -11,21 +11,8 @@ import { isNil } from '../utils/shared.utils';
  * @publicApi
  */
 export interface ParseFloatPipeOptions {
-  /**
-   * The HTTP status code to be used in the response when the validation fails.
-   */
   errorHttpStatusCode?: ErrorHttpStatusCode;
-  /**
-   * A factory function that returns an exception object to be thrown
-   * if validation fails.
-   * @param error Error message
-   * @returns The exception object
-   */
   exceptionFactory?: (error: string) => any;
-  /**
-   * If true, the pipe will return null or undefined if the value is not provided
-   * @default false
-   */
   optional?: boolean;
 }
 

packages/common/pipes/parse-int.pipe.ts

@@ -15,21 +15,8 @@ import { isNil } from '../utils/shared.utils';
  * @publicApi
  */
 export interface ParseIntPipeOptions {
-  /**
-   * The HTTP status code to be used in the response when the validation fails.
-   */
   errorHttpStatusCode?: ErrorHttpStatusCode;
-  /**
-   * A factory function that returns an exception object to be thrown
-   * if validation fails.
-   * @param error Error message
-   * @returns The exception object
-   */
   exceptionFactory?: (error: string) => any;
-  /**
-   * If true, the pipe will return null or undefined if the value is not provided
-   * @default false
-   */
   optional?: boolean;
 }
 

packages/common/pipes/parse-uuid.pipe.ts

@@ -15,25 +15,9 @@ import { isNil, isString } from '../utils/shared.utils';
  * @publicApi
  */
 export interface ParseUUIDPipeOptions {
-  /**
-   * UUID version to validate
-   */
   version?: '3' | '4' | '5' | '7';
-  /**
-   * The HTTP status code to be used in the response when the validation fails.
-   */
   errorHttpStatusCode?: ErrorHttpStatusCode;
-  /**
-   * A factory function that returns an exception object to be thrown
-   * if validation fails.
-   * @param error Error message
-   * @returns The exception object
-   */
   exceptionFactory?: (errors: string) => any;
-  /**
-   * If true, the pipe will return null or undefined if the value is not provided
-   * @default false
-   */
   optional?: boolean;
 }
 

packages/common/pipes/validation.pipe.ts

@@ -116,12 +116,13 @@ export class ValidationPipe implements PipeTransform<any> {
         : value;
     }
     const originalValue = value;
-    value = this.toEmptyIfNil(value);
+    value = this.toEmptyIfNil(value, metatype);
 
     const isNil = value !== originalValue;
     const isPrimitive = this.isPrimitive(value);
     this.stripProtoKeys(value);
-    let entity = classTransformer.plainToInstance(
+
+    let entity = classTransformer.plainToClass(
       metatype,
       value,
       this.transformOptions,
@@ -203,19 +204,32 @@ export class ValidationPipe implements PipeTransform<any> {
       return value === true || value === 'true';
     }
     if (metatype === Number) {
-      if (isUndefined(value)) {
-        // This is a workaround to deal with optional numeric values since
-        // optional numerics shouldn't be parsed to a valid number when
-        // they were not defined
-        return undefined;
-      }
       return +value;
     }
+    if (metatype === String && !isUndefined(value)) {
+      return String(value);
+    }
     return value;
   }
 
-  protected toEmptyIfNil<T = any, R = any>(value: T): R | {} {
-    return isNil(value) ? {} : value;
+  protected toEmptyIfNil<T = any, R = any>(
+    value: T,
+    metatype: Type<unknown> | object,
+  ): R | {} {
+    if (!isNil(value)) {
+      return value;
+    }
+    if (
+      typeof metatype === 'function' ||
+      (metatype && 'prototype' in metatype && metatype.prototype?.constructor)
+    ) {
+      return {};
+    }
+    // Builder like SWC require empty string to be returned instead of an empty object
+    // when the value is nil and the metatype is not a class instance, but a plain object (enum, for example).
+    // Otherwise, the error will be thrown.
+    // @see https://github.com/nestjs/nest/issues/12680
+    return '';
   }
 
   protected stripProtoKeys(value: any) {

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

@@ -94,11 +94,7 @@ export class ClassSerializerInterceptor implements NestInterceptor {
     if (plainOrClass instanceof options.type) {
       return classTransformer.classToPlain(plainOrClass, options);
     }
-    const instance = classTransformer.plainToInstance(
-      options.type,
-      plainOrClass,
-      options,
-    );
+    const instance = classTransformer.plainToClass(options.type, plainOrClass);
     return classTransformer.classToPlain(instance, options);
   }
 

packages/common/services/console-logger.service.ts

@@ -1,4 +1,3 @@
-import { inspect, InspectOptions } from 'util';
 import { Injectable, Optional } from '../decorators/core';
 import { clc, yellow } from '../utils/cli-colors.util';
 import {
@@ -10,8 +9,6 @@ import {
 import { LoggerService, LogLevel } from './logger.service';
 import { isLogLevelEnabled } from './utils';
 
-const DEFAULT_DEPTH = 5;
-
 export interface ConsoleLoggerOptions {
   /**
    * Enabled log levels.
@@ -19,73 +16,8 @@ export interface ConsoleLoggerOptions {
   logLevels?: LogLevel[];
   /**
    * If enabled, will print timestamp (time difference) between current and previous log message.
-   * Note: This option is not used when `json` is enabled.
    */
   timestamp?: boolean;
-  /**
-   * A prefix to be used for each log message.
-   * Note: This option is not used when `json` is enabled.
-   */
-  prefix?: string;
-  /**
-   * If enabled, will print the log message in JSON format.
-   */
-  json?: boolean;
-  /**
-   * If enabled, will print the log message in color.
-   * Default true if json is disabled, false otherwise
-   */
-  colors?: boolean;
-  /**
-   * The context of the logger.
-   */
-  context?: string;
-  /**
-   * If enabled, will print the log message in a single line, even if it is an object with multiple properties.
-   * If set to a number, the most n inner elements are united on a single line as long as all properties fit into breakLength. Short array elements are also grouped together.
-   * Default true when `json` is enabled, false otherwise.
-   */
-  compact?: boolean | number;
-  /**
-   * Specifies the maximum number of Array, TypedArray, Map, Set, WeakMap, and WeakSet elements to include when formatting.
-   * Set to null or Infinity to show all elements. Set to 0 or negative to show no elements.
-   * Ignored when `json` is enabled, colors are disabled, and `compact` is set to true as it produces a parseable JSON output.
-   * @default 100
-   */
-  maxArrayLength?: number;
-  /**
-   * Specifies the maximum number of characters to include when formatting.
-   * Set to null or Infinity to show all elements. Set to 0 or negative to show no characters.
-   * Ignored when `json` is enabled, colors are disabled, and `compact` is set to true as it produces a parseable JSON output.
-   * @default 10000.
-   */
-  maxStringLength?: number;
-  /**
-   * If enabled, will sort keys while formatting objects.
-   * Can also be a custom sorting function.
-   * Ignored when `json` is enabled, colors are disabled, and `compact` is set to true as it produces a parseable JSON output.
-   * @default false
-   */
-  sorted?: boolean | ((a: string, b: string) => number);
-  /**
-   * Specifies the number of times to recurse while formatting object. T
-   * This is useful for inspecting large objects. To recurse up to the maximum call stack size pass Infinity or null.
-   * Ignored when `json` is enabled, colors are disabled, and `compact` is set to true as it produces a parseable JSON output.
-   * @default 5
-   */
-  depth?: number;
-  /**
-   * If true, object's non-enumerable symbols and properties are included in the formatted result.
-   * WeakMap and WeakSet entries are also included as well as user defined prototype properties
-   * @default false
-   */
-  showHidden?: boolean;
-  /**
-   * The length at which input values are split across multiple lines. Set to Infinity to format the input as a single line (in combination with "compact" set to true).
-   * Default Infinity when "compact" is true, 80 otherwise.
-   * Ignored when `json` is enabled, colors are disabled, and `compact` is set to true as it produces a parseable JSON output.
-   */
-  breakLength?: number;
 }
 
 const DEFAULT_LOG_LEVELS: LogLevel[] = [
@@ -108,54 +40,22 @@ const dateTimeFormatter = new Intl.DateTimeFormat(undefined, {
 
 @Injectable()
 export class ConsoleLogger implements LoggerService {
-  /**
-   * The options of the logger.
-   */
-  protected options: ConsoleLoggerOptions;
-  /**
-   * The context of the logger (can be set manually or automatically inferred).
-   */
-  protected context?: string;
-  /**
-   * The original context of the logger (set in the constructor).
-   */
-  protected originalContext?: string;
-  /**
-   * The options used for the "inspect" method.
-   */
-  protected inspectOptions: InspectOptions;
-  /**
-   * The last timestamp at which the log message was printed.
-   */
-  protected static lastTimestampAt?: number;
+  private static lastTimestampAt?: number;
+  private originalContext?: string;
 
   constructor();
   constructor(context: string);
-  constructor(options: ConsoleLoggerOptions);
   constructor(context: string, options: ConsoleLoggerOptions);
   constructor(
     @Optional()
-    contextOrOptions?: string | ConsoleLoggerOptions,
+    protected context?: string,
     @Optional()
-    options?: ConsoleLoggerOptions,
+    protected options: ConsoleLoggerOptions = {},
   ) {
-    // eslint-disable-next-line prefer-const
-    let [context, opts] = isString(contextOrOptions)
-      ? [contextOrOptions, options]
-      : !!options
-        ? [undefined, options]
-        : [contextOrOptions?.context, contextOrOptions];
-
-    opts = opts ?? {};
-    opts.logLevels ??= DEFAULT_LOG_LEVELS;
-    opts.colors ??= opts.colors ?? (opts.json ? false : true);
-    opts.prefix ??= 'Nest';
-
-    this.options = opts;
-    this.inspectOptions = this.getInspectOptions();
-
+    if (!options.logLevels) {
+      options.logLevels = DEFAULT_LOG_LEVELS;
+    }
     if (context) {
-      this.context = context;
       this.originalContext = context;
     }
   }
@@ -191,7 +91,7 @@ export class ConsoleLogger implements LoggerService {
     const { messages, context, stack } =
       this.getContextAndStackAndMessagesToPrint([message, ...optionalParams]);
 
-    this.printMessages(messages, context, 'error', 'stderr', stack);
+    this.printMessages(messages, context, 'error', 'stderr');
     this.printStackTrace(stack);
   }
 
@@ -303,18 +203,8 @@ export class ConsoleLogger implements LoggerService {
     context = '',
     logLevel: LogLevel = 'log',
     writeStreamType?: 'stdout' | 'stderr',
-    errorStack?: unknown,
   ) {
     messages.forEach(message => {
-      if (this.options.json) {
-        this.printAsJson(message, {
-          context,
-          logLevel,
-          writeStreamType,
-          errorStack,
-        });
-        return;
-      }
       const pidMessage = this.formatPid(process.pid);
       const contextMessage = this.formatContext(context);
       const timestampDiff = this.updateAndGetTimestampDiff();
@@ -332,57 +222,12 @@ export class ConsoleLogger implements LoggerService {
     });
   }
 
-  protected printAsJson(
-    message: unknown,
-    options: {
-      context: string;
-      logLevel: LogLevel;
-      writeStreamType?: 'stdout' | 'stderr';
-      errorStack?: unknown;
-    },
-  ) {
-    type JsonLogObject = {
-      level: LogLevel;
-      pid: number;
-      timestamp: number;
-      message: unknown;
-      context?: string;
-      stack?: unknown;
-    };
-
-    const logObject: JsonLogObject = {
-      level: options.logLevel,
-      pid: process.pid,
-      timestamp: Date.now(),
-      message,
-    };
-
-    if (options.context) {
-      logObject.context = options.context;
-    }
-
-    if (options.errorStack) {
-      logObject.stack = options.errorStack;
-    }
-
-    const formattedMessage =
-      !this.options.colors && this.inspectOptions.compact === true
-        ? JSON.stringify(logObject, this.stringifyReplacer)
-        : inspect(logObject, this.inspectOptions);
-    process[options.writeStreamType ?? 'stdout'].write(`${formattedMessage}\n`);
-  }
-
   protected formatPid(pid: number) {
-    return `[${this.options.prefix}] ${pid}  - `;
+    return `[Nest] ${pid}  - `;
   }
 
   protected formatContext(context: string): string {
-    if (!context) {
-      return '';
-    }
-
-    context = `[${context}] `;
-    return this.options.colors ? yellow(context) : context;
+    return context ? yellow(`[${context}] `) : '';
   }
 
   protected formatMessage(
@@ -411,30 +256,23 @@ export class ConsoleLogger implements LoggerService {
       return this.stringifyMessage(message(), logLevel);
     }
 
-    if (typeof message === 'string') {
-      return this.colorize(message, logLevel);
-    }
-
-    const outputText = inspect(message, this.inspectOptions);
-    if (isPlainObject(message)) {
-      return `Object(${Object.keys(message).length}) ${outputText}`;
-    }
-    if (Array.isArray(message)) {
-      return `Array(${message.length}) ${outputText}`;
-    }
-    return outputText;
+    return isPlainObject(message) || Array.isArray(message)
+      ? `${this.colorize('Object:', logLevel)}\n${JSON.stringify(
+          message,
+          (key, value) =>
+            typeof value === 'bigint' ? value.toString() : value,
+          2,
+        )}\n`
+      : this.colorize(message as string, logLevel);
   }
 
   protected colorize(message: string, logLevel: LogLevel) {
-    if (!this.options.colors || this.options.json) {
-      return message;
-    }
     const color = this.getColorByLogLevel(logLevel);
     return color(message);
   }
 
   protected printStackTrace(stack: string) {
-    if (!stack || this.options.json) {
+    if (!stack) {
       return;
     }
     process.stderr.write(`${stack}\n`);
@@ -451,58 +289,7 @@ export class ConsoleLogger implements LoggerService {
   }
 
   protected formatTimestampDiff(timestampDiff: number) {
-    const formattedDiff = ` +${timestampDiff}ms`;
-    return this.options.colors ? yellow(formattedDiff) : formattedDiff;
-  }
-
-  protected getInspectOptions() {
-    let breakLength = this.options.breakLength;
-    if (typeof breakLength === 'undefined') {
-      breakLength = this.options.colors
-        ? this.options.compact
-          ? Infinity
-          : undefined
-        : this.options.compact === false
-          ? undefined
-          : Infinity; // default breakLength to Infinity if inline is not set and colors is false
-    }
-
-    const inspectOptions: InspectOptions = {
-      depth: this.options.depth ?? DEFAULT_DEPTH,
-      sorted: this.options.sorted,
-      showHidden: this.options.showHidden,
-      compact: this.options.compact ?? (this.options.json ? true : false),
-      colors: this.options.colors,
-      breakLength,
-    };
-
-    if (this.options.maxArrayLength) {
-      inspectOptions.maxArrayLength = this.options.maxArrayLength;
-    }
-    if (this.options.maxStringLength) {
-      inspectOptions.maxStringLength = this.options.maxStringLength;
-    }
-
-    return inspectOptions;
-  }
-
-  protected stringifyReplacer(key: string, value: unknown) {
-    // Mimic util.inspect behavior for JSON logger with compact on and colors off
-    if (typeof value === 'bigint') {
-      return value.toString();
-    }
-    if (typeof value === 'symbol') {
-      return value.toString();
-    }
-
-    if (
-      value instanceof Map ||
-      value instanceof Set ||
-      value instanceof Error
-    ) {
-      return `${inspect(value, this.inspectOptions)}`;
-    }
-    return value;
+    return yellow(` +${timestampDiff}ms`);
   }
 
   private getContextAndMessagesToPrint(args: unknown[]) {

packages/common/test/decorators/apply-decorators.spec.ts

@@ -1,6 +1,6 @@
 import { expect } from 'chai';
-import { GUARDS_METADATA } from '../../constants';
 import { applyDecorators, UseGuards } from '../../decorators';
+import { GUARDS_METADATA } from '../../constants';
 import { CanActivate } from '../../interfaces';
 
 describe('applyDecorators', () => {

packages/common/test/decorators/route-params.decorator.spec.ts

@@ -1,22 +1,7 @@
 import { expect } from 'chai';
 import { Body, HostParam, Param, Query, Search } from '../../decorators';
 import { RequestMethod } from '../../enums/request-method.enum';
-import {
-  All,
-  Delete,
-  Get,
-  ParseIntPipe,
-  Patch,
-  Post,
-  Put,
-  Propfind,
-  Proppatch,
-  Mkcol,
-  Move,
-  Copy,
-  Lock,
-  Unlock,
-} from '../../index';
+import { All, Delete, Get, ParseIntPipe, Patch, Post, Put } from '../../index';
 import { ROUTE_ARGS_METADATA } from '../../constants';
 import { RouteParamtypes } from '../../enums/route-paramtypes.enum';
 
@@ -430,409 +415,3 @@ describe('Inheritance', () => {
     expect(methodUsingArray).to.be.eql(requestPropsUsingArray.method);
   });
 });
-
-describe('@PropFind', () => {
-  const requestPath = 'test';
-  const requestProps = {
-    path: requestPath,
-    method: RequestMethod.PROPFIND,
-  };
-
-  const requestPathUsingArray = ['foo', 'bar'];
-  const requestPropsUsingArray = {
-    path: requestPathUsingArray,
-    method: RequestMethod.PROPFIND,
-  };
-
-  it('should enhance class with expected request metadata', () => {
-    class Test {
-      @Propfind(requestPath)
-      public static test() {}
-
-      @Propfind(requestPathUsingArray)
-      public static testUsingArray() {}
-    }
-
-    const path = Reflect.getMetadata('path', Test.test);
-    const method = Reflect.getMetadata('method', Test.test);
-    const pathUsingArray = Reflect.getMetadata('path', Test.testUsingArray);
-    const methodUsingArray = Reflect.getMetadata('method', Test.testUsingArray);
-
-    expect(path).to.be.eql(requestPath);
-    expect(method).to.be.eql(requestProps.method);
-    expect(pathUsingArray).to.be.eql(requestPathUsingArray);
-    expect(methodUsingArray).to.be.eql(requestPropsUsingArray.method);
-  });
-
-  it('should set path on "/" by default', () => {
-    class Test {
-      @Propfind()
-      public static test(
-        @Query() query,
-        @Param() params,
-        @HostParam() hostParams,
-      ) {}
-
-      @Propfind([])
-      public static testUsingArray(
-        @Query() query,
-        @Param() params,
-        @HostParam() hostParams,
-      ) {}
-    }
-
-    const path = Reflect.getMetadata('path', Test.test);
-    const pathUsingArray = Reflect.getMetadata('path', Test.testUsingArray);
-
-    expect(path).to.be.eql('/');
-    expect(pathUsingArray).to.be.eql('/');
-  });
-});
-
-describe('@PropPatch', () => {
-  const requestPath = 'test';
-  const requestProps = {
-    path: requestPath,
-    method: RequestMethod.PROPPATCH,
-  };
-
-  const requestPathUsingArray = ['foo', 'bar'];
-  const requestPropsUsingArray = {
-    path: requestPathUsingArray,
-    method: RequestMethod.PROPPATCH,
-  };
-
-  it('should enhance class with expected request metadata', () => {
-    class Test {
-      @Proppatch(requestPath)
-      public static test() {}
-
-      @Proppatch(requestPathUsingArray)
-      public static testUsingArray() {}
-    }
-
-    const path = Reflect.getMetadata('path', Test.test);
-    const method = Reflect.getMetadata('method', Test.test);
-    const pathUsingArray = Reflect.getMetadata('path', Test.testUsingArray);
-    const methodUsingArray = Reflect.getMetadata('method', Test.testUsingArray);
-
-    expect(path).to.be.eql(requestPath);
-    expect(method).to.be.eql(requestProps.method);
-    expect(pathUsingArray).to.be.eql(requestPathUsingArray);
-    expect(methodUsingArray).to.be.eql(requestPropsUsingArray.method);
-  });
-
-  it('should set path on "/" by default', () => {
-    class Test {
-      @Proppatch()
-      public static test(
-        @Query() query,
-        @Param() params,
-        @HostParam() hostParams,
-      ) {}
-
-      @Proppatch([])
-      public static testUsingArray(
-        @Query() query,
-        @Param() params,
-        @HostParam() hostParams,
-      ) {}
-    }
-
-    const path = Reflect.getMetadata('path', Test.test);
-    const pathUsingArray = Reflect.getMetadata('path', Test.testUsingArray);
-
-    expect(path).to.be.eql('/');
-    expect(pathUsingArray).to.be.eql('/');
-  });
-});
-
-describe('@MkCol', () => {
-  const requestPath = 'test';
-  const requestProps = {
-    path: requestPath,
-    method: RequestMethod.MKCOL,
-  };
-
-  const requestPathUsingArray = ['foo', 'bar'];
-  const requestPropsUsingArray = {
-    path: requestPathUsingArray,
-    method: RequestMethod.MKCOL,
-  };
-
-  it('should enhance class with expected request metadata', () => {
-    class Test {
-      @Mkcol(requestPath)
-      public static test() {}
-
-      @Mkcol(requestPathUsingArray)
-      public static testUsingArray() {}
-    }
-
-    const path = Reflect.getMetadata('path', Test.test);
-    const method = Reflect.getMetadata('method', Test.test);
-    const pathUsingArray = Reflect.getMetadata('path', Test.testUsingArray);
-    const methodUsingArray = Reflect.getMetadata('method', Test.testUsingArray);
-
-    expect(path).to.be.eql(requestPath);
-    expect(method).to.be.eql(requestProps.method);
-    expect(pathUsingArray).to.be.eql(requestPathUsingArray);
-    expect(methodUsingArray).to.be.eql(requestPropsUsingArray.method);
-  });
-
-  it('should set path on "/" by default', () => {
-    class Test {
-      @Mkcol()
-      public static test(
-        @Query() query,
-        @Param() params,
-        @HostParam() hostParams,
-      ) {}
-
-      @Mkcol([])
-      public static testUsingArray(
-        @Query() query,
-        @Param() params,
-        @HostParam() hostParams,
-      ) {}
-    }
-
-    const path = Reflect.getMetadata('path', Test.test);
-    const pathUsingArray = Reflect.getMetadata('path', Test.testUsingArray);
-
-    expect(path).to.be.eql('/');
-    expect(pathUsingArray).to.be.eql('/');
-  });
-});
-
-describe('@Copy', () => {
-  const requestPath = 'test';
-  const requestProps = {
-    path: requestPath,
-    method: RequestMethod.COPY,
-  };
-
-  const requestPathUsingArray = ['foo', 'bar'];
-  const requestPropsUsingArray = {
-    path: requestPathUsingArray,
-    method: RequestMethod.COPY,
-  };
-
-  it('should enhance class with expected request metadata', () => {
-    class Test {
-      @Copy(requestPath)
-      public static test() {}
-
-      @Copy(requestPathUsingArray)
-      public static testUsingArray() {}
-    }
-
-    const path = Reflect.getMetadata('path', Test.test);
-    const method = Reflect.getMetadata('method', Test.test);
-    const pathUsingArray = Reflect.getMetadata('path', Test.testUsingArray);
-    const methodUsingArray = Reflect.getMetadata('method', Test.testUsingArray);
-
-    expect(path).to.be.eql(requestPath);
-    expect(method).to.be.eql(requestProps.method);
-    expect(pathUsingArray).to.be.eql(requestPathUsingArray);
-    expect(methodUsingArray).to.be.eql(requestPropsUsingArray.method);
-  });
-
-  it('should set path on "/" by default', () => {
-    class Test {
-      @Copy()
-      public static test(
-        @Query() query,
-        @Param() params,
-        @HostParam() hostParams,
-      ) {}
-
-      @Copy([])
-      public static testUsingArray(
-        @Query() query,
-        @Param() params,
-        @HostParam() hostParams,
-      ) {}
-    }
-
-    const path = Reflect.getMetadata('path', Test.test);
-    const pathUsingArray = Reflect.getMetadata('path', Test.testUsingArray);
-
-    expect(path).to.be.eql('/');
-    expect(pathUsingArray).to.be.eql('/');
-  });
-});
-
-describe('@Move', () => {
-  const requestPath = 'test';
-  const requestProps = {
-    path: requestPath,
-    method: RequestMethod.MOVE,
-  };
-
-  const requestPathUsingArray = ['foo', 'bar'];
-  const requestPropsUsingArray = {
-    path: requestPathUsingArray,
-    method: RequestMethod.MOVE,
-  };
-
-  it('should enhance class with expected request metadata', () => {
-    class Test {
-      @Move(requestPath)
-      public static test() {}
-
-      @Move(requestPathUsingArray)
-      public static testUsingArray() {}
-    }
-
-    const path = Reflect.getMetadata('path', Test.test);
-    const method = Reflect.getMetadata('method', Test.test);
-    const pathUsingArray = Reflect.getMetadata('path', Test.testUsingArray);
-    const methodUsingArray = Reflect.getMetadata('method', Test.testUsingArray);
-
-    expect(path).to.be.eql(requestPath);
-    expect(method).to.be.eql(requestProps.method);
-    expect(pathUsingArray).to.be.eql(requestPathUsingArray);
-    expect(methodUsingArray).to.be.eql(requestPropsUsingArray.method);
-  });
-
-  it('should set path on "/" by default', () => {
-    class Test {
-      @Move()
-      public static test(
-        @Query() query,
-        @Param() params,
-        @HostParam() hostParams,
-      ) {}
-
-      @Move([])
-      public static testUsingArray(
-        @Query() query,
-        @Param() params,
-        @HostParam() hostParams,
-      ) {}
-    }
-
-    const path = Reflect.getMetadata('path', Test.test);
-    const pathUsingArray = Reflect.getMetadata('path', Test.testUsingArray);
-
-    expect(path).to.be.eql('/');
-    expect(pathUsingArray).to.be.eql('/');
-  });
-});
-
-describe('@Lock', () => {
-  const requestPath = 'test';
-  const requestProps = {
-    path: requestPath,
-    method: RequestMethod.LOCK,
-  };
-
-  const requestPathUsingArray = ['foo', 'bar'];
-  const requestPropsUsingArray = {
-    path: requestPathUsingArray,
-    method: RequestMethod.LOCK,
-  };
-
-  it('should enhance class with expected request metadata', () => {
-    class Test {
-      @Lock(requestPath)
-      public static test() {}
-
-      @Lock(requestPathUsingArray)
-      public static testUsingArray() {}
-    }
-
-    const path = Reflect.getMetadata('path', Test.test);
-    const method = Reflect.getMetadata('method', Test.test);
-    const pathUsingArray = Reflect.getMetadata('path', Test.testUsingArray);
-    const methodUsingArray = Reflect.getMetadata('method', Test.testUsingArray);
-
-    expect(path).to.be.eql(requestPath);
-    expect(method).to.be.eql(requestProps.method);
-    expect(pathUsingArray).to.be.eql(requestPathUsingArray);
-    expect(methodUsingArray).to.be.eql(requestPropsUsingArray.method);
-  });
-
-  it('should set path on "/" by default', () => {
-    class Test {
-      @Lock()
-      public static test(
-        @Query() query,
-        @Param() params,
-        @HostParam() hostParams,
-      ) {}
-
-      @Lock([])
-      public static testUsingArray(
-        @Query() query,
-        @Param() params,
-        @HostParam() hostParams,
-      ) {}
-    }
-
-    const path = Reflect.getMetadata('path', Test.test);
-    const pathUsingArray = Reflect.getMetadata('path', Test.testUsingArray);
-
-    expect(path).to.be.eql('/');
-    expect(pathUsingArray).to.be.eql('/');
-  });
-});
-
-describe('@Unlock', () => {
-  const requestPath = 'test';
-  const requestProps = {
-    path: requestPath,
-    method: RequestMethod.UNLOCK,
-  };
-
-  const requestPathUsingArray = ['foo', 'bar'];
-  const requestPropsUsingArray = {
-    path: requestPathUsingArray,
-    method: RequestMethod.UNLOCK,
-  };
-
-  it('should enhance class with expected request metadata', () => {
-    class Test {
-      @Unlock(requestPath)
-      public static test() {}
-
-      @Unlock(requestPathUsingArray)
-      public static testUsingArray() {}
-    }
-
-    const path = Reflect.getMetadata('path', Test.test);
-    const method = Reflect.getMetadata('method', Test.test);
-    const pathUsingArray = Reflect.getMetadata('path', Test.testUsingArray);
-    const methodUsingArray = Reflect.getMetadata('method', Test.testUsingArray);
-
-    expect(path).to.be.eql(requestPath);
-    expect(method).to.be.eql(requestProps.method);
-    expect(pathUsingArray).to.be.eql(requestPathUsingArray);
-    expect(methodUsingArray).to.be.eql(requestPropsUsingArray.method);
-  });
-
-  it('should set path on "/" by default', () => {
-    class Test {
-      @Unlock()
-      public static test(
-        @Query() query,
-        @Param() params,
-        @HostParam() hostParams,
-      ) {}
-
-      @Unlock([])
-      public static testUsingArray(
-        @Query() query,
-        @Param() params,
-        @HostParam() hostParams,
-      ) {}
-    }
-
-    const path = Reflect.getMetadata('path', Test.test);
-    const pathUsingArray = Reflect.getMetadata('path', Test.testUsingArray);
-
-    expect(path).to.be.eql('/');
-    expect(pathUsingArray).to.be.eql('/');
-  });
-});

packages/common/test/module-utils/utils/get-injection-providers.util.spec.ts

@@ -5,19 +5,30 @@ import { getInjectionProviders } from '../../../module-utils/utils/get-injection
 describe('getInjectionProviders', () => {
   it('should take only required providers', () => {
     class C {
-      static token = 'a';
+      static token = 'anything';
     }
-    const p: Provider[] = [
+    class G {
+      static token = 'anything';
+      static optional = true;
+    }
+    class H {
+      static token = 'anything';
+      static optional = false;
+    }
+    const providers: Provider[] = [
       {
+        //0
         provide: 'a',
         useValue: 'a',
       },
       {
+        //1
         provide: 'b',
         useValue: 'b',
       },
-      C,
+      C, //2
       {
+        //3
         provide: 'd',
         useFactory: (c, b) => [c, b],
         inject: [
@@ -27,23 +38,36 @@ describe('getInjectionProviders', () => {
             optional: true,
           },
           'x',
+          G,
+          H,
         ],
       },
       {
+        //4
         provide: 'e',
         useFactory: (d, b) => [d, b],
         inject: ['d', 'b'],
       },
       {
+        //5
         provide: 'f',
         useValue: 'f',
       },
+      G, //6
+      H, //7
     ];
-    // should not include 'a' and 'f'
-    const expected = p.slice(1, -1);
-    const result = getInjectionProviders(p, ['e']);
-    expect(result).to.have.length(expected.length);
+
+    const expected = [
+      providers[1],
+      providers[2],
+      providers[3],
+      providers[4],
+      providers[6],
+      providers[7],
+    ];
+
+    const result = getInjectionProviders(providers, ['e']);
+
     expect(result).to.have.members(expected);
-    expect(result).not.to.have.members([p[0], p[5]]);
   });
 });

packages/common/test/pipes/file/file-type.validator.spec.ts

@@ -1,89 +1,195 @@
 import { expect } from 'chai';
+import { IFile } from '../../../../common/pipes/file/interfaces';
 import { FileTypeValidator } from '../../../pipes';
 
 describe('FileTypeValidator', () => {
   describe('isValid', () => {
-    it('should return true when the file mimetype is the same as the specified', () => {
+    it('should return true when the file buffer matches the specified type', async () => {
       const fileTypeValidator = new FileTypeValidator({
         fileType: 'image/jpeg',
       });
 
+      const jpegBuffer = Buffer.from([
+        0xff, 0xd8, 0xff, 0xe0, 0x00, 0x10, 0x4a, 0x46, 0x49, 0x46,
+      ]);
       const requestFile = {
         mimetype: 'image/jpeg',
-      } as any;
+        buffer: jpegBuffer,
+      } as IFile;
 
-      expect(fileTypeValidator.isValid(requestFile)).to.equal(true);
+      expect(await fileTypeValidator.isValid(requestFile)).to.equal(true);
     });
 
-    it('should return true when the file mimetype ends with the specified option type', () => {
+    it('should return true when the file buffer matches the specified file extension', async () => {
       const fileTypeValidator = new FileTypeValidator({
         fileType: 'jpeg',
       });
 
+      const jpegBuffer = Buffer.from([
+        0xff, 0xd8, 0xff, 0xe0, 0x00, 0x10, 0x4a, 0x46, 0x49, 0x46,
+      ]);
       const requestFile = {
         mimetype: 'image/jpeg',
-      } as any;
-
-      expect(fileTypeValidator.isValid(requestFile)).to.equal(true);
+        buffer: jpegBuffer,
+      } as IFile;
+      expect(await fileTypeValidator.isValid(requestFile)).to.equal(true);
     });
 
-    it('should return true when the file mimetype matches the specified regexp', () => {
+    it('should return true when the file buffer matches the specified regexp', async () => {
       const fileTypeValidator = new FileTypeValidator({
-        fileType: /word/,
+        fileType: /^image\//,
       });
 
+      const jpegBuffer = Buffer.from([
+        0xff, 0xd8, 0xff, 0xe0, 0x00, 0x10, 0x4a, 0x46, 0x49, 0x46,
+      ]);
       const requestFile = {
-        mimetype: 'application/msword',
-      } as any;
+        mimetype: 'image/jpeg',
+        buffer: jpegBuffer,
+      } as IFile;
 
-      expect(fileTypeValidator.isValid(requestFile)).to.equal(true);
+      expect(await fileTypeValidator.isValid(requestFile)).to.equal(true);
     });
 
-    it('should return false when the file mimetype is different from the specified', () => {
+    it('should return false when the file buffer does not match the specified type', async () => {
       const fileTypeValidator = new FileTypeValidator({
         fileType: 'image/jpeg',
       });
 
+      const pngBuffer = Buffer.from([
+        0x89, 0x50, 0x4e, 0x47, 0x0d, 0x0a, 0x1a, 0x0a,
+      ]);
+      const requestFile = {
+        mimetype: 'image/jpeg', // Spoofed mimetype
+        buffer: pngBuffer,
+      } as IFile;
+
+      expect(await fileTypeValidator.isValid(requestFile)).to.equal(false);
+    });
+
+    it('should return false when the file buffer does not match the specified file extension', async () => {
+      const fileTypeValidator = new FileTypeValidator({
+        fileType: 'jpeg',
+      });
+
+      const pngBuffer = Buffer.from([
+        0x89, 0x50, 0x4e, 0x47, 0x0d, 0x0a, 0x1a, 0x0a,
+      ]);
       const requestFile = {
         mimetype: 'image/png',
-      } as any;
+        buffer: pngBuffer,
+      } as IFile;
 
-      expect(fileTypeValidator.isValid(requestFile)).to.equal(false);
+      expect(await fileTypeValidator.isValid(requestFile)).to.equal(false);
     });
 
-    it('should return false when the file mimetype does not match the provided regexp', () => {
+    it('should return false when no buffer is provided', async () => {
       const fileTypeValidator = new FileTypeValidator({
-        fileType: /mp4/,
+        fileType: 'image/jpeg',
       });
 
       const requestFile = {
-        mimetype: 'image/png',
-      } as any;
+        mimetype: 'image/jpeg',
+      } as IFile;
 
-      expect(fileTypeValidator.isValid(requestFile)).to.equal(false);
+      expect(await fileTypeValidator.isValid(requestFile)).to.equal(false);
     });
 
-    it('should return false when the file mimetype was not provided', () => {
+    it('should return false when no file is provided', async () => {
       const fileTypeValidator = new FileTypeValidator({
         fileType: 'image/jpeg',
       });
 
-      const requestFile = {} as any;
-
-      expect(fileTypeValidator.isValid(requestFile)).to.equal(false);
+      expect(await fileTypeValidator.isValid()).to.equal(false);
     });
 
-    it('should return false when no file provided', () => {
+    it('should return false when no buffer is provided', async () => {
       const fileTypeValidator = new FileTypeValidator({
         fileType: 'image/jpeg',
       });
 
-      expect(fileTypeValidator.isValid()).to.equal(false);
+      const requestFile = {
+        mimetype: 'image/jpeg',
+      } as IFile;
+
+      expect(await fileTypeValidator.isValid(requestFile)).to.equal(false);
+    });
+
+    it('should return true when the file buffer matches the specified regexp', async () => {
+      const fileTypeValidator = new FileTypeValidator({
+        fileType: /^image\//,
+      });
+
+      const jpegBuffer = Buffer.from([
+        0xff, 0xd8, 0xff, 0xe0, 0x00, 0x10, 0x4a, 0x46, 0x49, 0x46,
+      ]);
+      const requestFile = {
+        mimetype: 'image/jpeg',
+        buffer: jpegBuffer,
+      } as IFile;
+
+      expect(await fileTypeValidator.isValid(requestFile)).to.equal(true);
+    });
+
+    it('should return true when no validation options are provided', async () => {
+      const fileTypeValidator = new FileTypeValidator({} as any);
+      const jpegBuffer = Buffer.from([
+        0xff, 0xd8, 0xff, 0xe0, 0x00, 0x10, 0x4a, 0x46, 0x49, 0x46,
+      ]);
+      const requestFile = {
+        mimetype: 'image/jpeg',
+        buffer: jpegBuffer,
+      } as IFile;
+
+      expect(await fileTypeValidator.isValid(requestFile)).to.equal(true);
+    });
+
+    it('should skip magic numbers validation when the skipMagicNumbersValidation is true', async () => {
+      const fileTypeValidator = new FileTypeValidator({
+        fileType: 'image/jpeg',
+        skipMagicNumbersValidation: true,
+      });
+
+      const requestFile = {
+        mimetype: 'image/jpeg',
+      } as IFile;
+
+      expect(await fileTypeValidator.isValid(requestFile)).to.equal(true);
+    });
+
+    it('should return false when the file buffer does not match any known type', async () => {
+      const fileTypeValidator = new FileTypeValidator({
+        fileType: 'unknown/type',
+      });
+
+      const unknownBuffer = Buffer.from([
+        0x00, 0x11, 0x22, 0x33, 0x44, 0x55, 0x66, 0x77,
+      ]);
+      const requestFile = {
+        mimetype: 'unknown/type',
+        buffer: unknownBuffer,
+      } as IFile;
+
+      expect(await fileTypeValidator.isValid(requestFile)).to.equal(false);
+    });
+
+    it('should return false when the buffer is empty', async () => {
+      const fileTypeValidator = new FileTypeValidator({
+        fileType: 'image/jpeg',
+      });
+
+      const emptyBuffer = Buffer.from([]);
+      const requestFile = {
+        mimetype: 'image/jpeg',
+        buffer: emptyBuffer,
+      } as IFile;
+
+      expect(await fileTypeValidator.isValid(requestFile)).to.equal(false);
     });
   });
 
   describe('buildErrorMessage', () => {
-    it('should return a string with the format "Validation failed (expected type is #fileType)"', () => {
+    it('should return a string with the format "Validation failed (expected type is #fileType)"', async () => {
       const fileType = 'image/jpeg';
       const fileTypeValidator = new FileTypeValidator({
         fileType,
@@ -93,5 +199,85 @@ describe('FileTypeValidator', () => {
         `Validation failed (expected type is ${fileType})`,
       );
     });
+
+    it('should include the file type in the error message when a file is provided', async () => {
+      const currentFileType = 'image/png';
+      const fileType = 'image/jpeg';
+      const fileTypeValidator = new FileTypeValidator({
+        fileType,
+      });
+
+      const file = { mimetype: currentFileType } as IFile;
+
+      expect(fileTypeValidator.buildErrorMessage(file)).to.equal(
+        `Validation failed (current file type is ${currentFileType}, expected type is ${fileType})`,
+      );
+    });
+
+    it('should handle regexp file type in error message', async () => {
+      const fileTypeValidator = new FileTypeValidator({
+        fileType: /^image\//,
+      });
+      const file = { mimetype: 'application/pdf' } as IFile;
+
+      expect(fileTypeValidator.buildErrorMessage(file)).to.equal(
+        `Validation failed (current file type is application/pdf, expected type is /^image\\//)`,
+      );
+    });
+
+    it('should handle file extension in error message', async () => {
+      const fileTypeValidator = new FileTypeValidator({
+        fileType: 'jpeg',
+      });
+      const file = { mimetype: 'image/png' } as IFile;
+
+      expect(fileTypeValidator.buildErrorMessage(file)).to.equal(
+        'Validation failed (current file type is image/png, expected type is jpeg)',
+      );
+    });
+
+    it('should handle regexp file type in error message', async () => {
+      const fileTypeValidator = new FileTypeValidator({
+        fileType: /^image\//,
+      });
+      const file = { mimetype: 'application/pdf' } as IFile;
+
+      expect(fileTypeValidator.buildErrorMessage(file)).to.equal(
+        `Validation failed (current file type is application/pdf, expected type is /^image\\//)`,
+      );
+    });
+
+    it('should handle file extension in error message', async () => {
+      const fileTypeValidator = new FileTypeValidator({
+        fileType: 'jpeg',
+      });
+      const file = { mimetype: 'image/png' } as IFile;
+
+      expect(fileTypeValidator.buildErrorMessage(file)).to.equal(
+        'Validation failed (current file type is image/png, expected type is jpeg)',
+      );
+    });
+
+    it('should handle regexp file type in error message', async () => {
+      const fileTypeValidator = new FileTypeValidator({
+        fileType: /^image\//,
+      });
+      const file = { mimetype: 'application/pdf' } as IFile;
+
+      expect(fileTypeValidator.buildErrorMessage(file)).to.equal(
+        `Validation failed (current file type is application/pdf, expected type is /^image\\//)`,
+      );
+    });
+
+    it('should handle file extension in error message', async () => {
+      const fileTypeValidator = new FileTypeValidator({
+        fileType: 'jpeg',
+      });
+      const file = { mimetype: 'image/png' } as IFile;
+
+      expect(fileTypeValidator.buildErrorMessage(file)).to.equal(
+        'Validation failed (current file type is image/png, expected type is jpeg)',
+      );
+    });
   });
 });

packages/common/test/pipes/file/parse-file-pipe.builder.spec.ts

@@ -1,9 +1,9 @@
 import { expect } from 'chai';
 import {
-  FileTypeValidator,
   FileValidator,
   MaxFileSizeValidator,
   ParseFilePipeBuilder,
+  FileTypeValidator,
 } from '../../../pipes';
 
 describe('ParseFilePipeBuilder', () => {

packages/common/test/pipes/parse-date.pipe.spec.ts

@@ -1,71 +0,0 @@
-import { expect } from 'chai';
-import { BadRequestException } from '../../exceptions';
-import { ParseDatePipe } from '../../pipes/parse-date.pipe';
-
-describe('ParseDatePipe', () => {
-  let target: ParseDatePipe;
-
-  beforeEach(() => {
-    target = new ParseDatePipe();
-  });
-
-  describe('transform', () => {
-    describe('when validation passes', () => {
-      it('should return a valid date object', () => {
-        const date = new Date().toISOString();
-
-        const transformedDate = target.transform(date);
-        expect(transformedDate).to.be.instanceOf(Date);
-        expect(transformedDate.toISOString()).to.equal(date);
-
-        const asNumber = transformedDate.getTime();
-        const transformedNumber = target.transform(asNumber);
-        expect(transformedNumber).to.be.instanceOf(Date);
-        expect(transformedNumber.getTime()).to.equal(asNumber);
-      });
-
-      it('should not throw an error if the value is undefined/null and optional is true', () => {
-        const target = new ParseDatePipe({ optional: true });
-        const value = target.transform(undefined);
-        expect(value).to.equal(undefined);
-      });
-    });
-    describe('when default value is provided', () => {
-      it('should return the default value if the value is undefined/null', () => {
-        const defaultValue = new Date();
-        const target = new ParseDatePipe({
-          optional: true,
-          default: () => defaultValue,
-        });
-        const value = target.transform(undefined);
-        expect(value).to.equal(defaultValue);
-      });
-    });
-    describe('when validation fails', () => {
-      it('should throw an error', () => {
-        try {
-          target.transform('123abc');
-          expect.fail();
-        } catch (error) {
-          expect(error).to.be.instanceOf(BadRequestException);
-          expect(error.message).to.equal(
-            'Validation failed (invalid date format)',
-          );
-        }
-      });
-    });
-    describe('when empty value', () => {
-      it('should throw an error', () => {
-        try {
-          target.transform('');
-          expect.fail();
-        } catch (error) {
-          expect(error).to.be.instanceOf(BadRequestException);
-          expect(error.message).to.equal(
-            'Validation failed (no Date provided)',
-          );
-        }
-      });
-    });
-  });
-});

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

@@ -205,18 +205,6 @@ describe('ValidationPipe', () => {
             }),
           ).to.be.equal(+value);
         });
-        it('should parse undefined to undefined', async () => {
-          target = new ValidationPipe({ transform: true });
-          const value = undefined;
-
-          expect(
-            await target.transform(value, {
-              metatype: Number,
-              data: 'test',
-              type: 'query',
-            }),
-          ).to.be.undefined;
-        });
       });
       describe('when input is a path parameter (number)', () => {
         it('should parse to number', async () => {
@@ -231,18 +219,6 @@ describe('ValidationPipe', () => {
             }),
           ).to.be.equal(+value);
         });
-        it('should parse undefined to undefined', async () => {
-          target = new ValidationPipe({ transform: true });
-          const value = undefined;
-
-          expect(
-            await target.transform(value, {
-              metatype: Number,
-              data: 'test',
-              type: 'param',
-            }),
-          ).to.be.undefined;
-        });
       });
       describe('when input is a query parameter (boolean)', () => {
         it('should parse the string "true" to the boolean true', async () => {

packages/common/test/services/logger.service.spec.ts

@@ -125,12 +125,9 @@ describe('Logger', () => {
         Logger.error(error);
 
         expect(processStderrWriteSpy.calledOnce).to.be.true;
-
+        expect(processStderrWriteSpy.firstCall.firstArg).to.include(`Object:`);
         expect(processStderrWriteSpy.firstCall.firstArg).to.include(
-          `Object(${Object.keys(error).length})`,
-        );
-        expect(processStderrWriteSpy.firstCall.firstArg).to.include(
-          `randomError: \x1b[33mtrue`,
+          `{\n  "randomError": true\n}`,
         );
       });
 
@@ -184,153 +181,6 @@ describe('Logger', () => {
         expect(processStderrWriteSpy.thirdCall.firstArg).to.equal(stack + '\n');
       });
     });
-
-    describe('when the default logger is used and json mode is enabled', () => {
-      const logger = new ConsoleLogger({ json: true });
-
-      let processStdoutWriteSpy: sinon.SinonSpy;
-      let processStderrWriteSpy: sinon.SinonSpy;
-
-      beforeEach(() => {
-        processStdoutWriteSpy = sinon.spy(process.stdout, 'write');
-        processStderrWriteSpy = sinon.spy(process.stderr, 'write');
-      });
-
-      afterEach(() => {
-        processStdoutWriteSpy.restore();
-        processStderrWriteSpy.restore();
-      });
-
-      it('should print error with stack as JSON to the console', () => {
-        const errorMessage = 'error message';
-        const error = new Error(errorMessage);
-
-        logger.error(error.message, error.stack);
-
-        const json = JSON.parse(processStderrWriteSpy.firstCall?.firstArg);
-
-        expect(json.pid).to.equal(process.pid);
-        expect(json.level).to.equal('error');
-        expect(json.message).to.equal(errorMessage);
-      });
-      it('should log out to stdout as JSON', () => {
-        const message = 'message 1';
-
-        logger.log(message);
-
-        const json = JSON.parse(processStdoutWriteSpy.firstCall?.firstArg);
-
-        expect(json.pid).to.equal(process.pid);
-        expect(json.level).to.equal('log');
-        expect(json.message).to.equal(message);
-      });
-      it('should log out an error to stderr as JSON', () => {
-        const message = 'message 1';
-
-        logger.error(message);
-
-        const json = JSON.parse(processStderrWriteSpy.firstCall?.firstArg);
-
-        expect(json.pid).to.equal(process.pid);
-        expect(json.level).to.equal('error');
-        expect(json.message).to.equal(message);
-      });
-      it('should log Map object', () => {
-        const map = new Map([
-          ['key1', 'value1'],
-          ['key2', 'value2'],
-        ]);
-
-        logger.log(map);
-
-        const json = JSON.parse(processStdoutWriteSpy.firstCall?.firstArg);
-
-        expect(json.pid).to.equal(process.pid);
-        expect(json.level).to.equal('log');
-        expect(json.message).to.equal(
-          `Map(2) { 'key1' => 'value1', 'key2' => 'value2' }`,
-        );
-      });
-      it('should log Set object', () => {
-        const set = new Set(['value1', 'value2']);
-
-        logger.log(set);
-
-        const json = JSON.parse(processStdoutWriteSpy.firstCall?.firstArg);
-
-        expect(json.pid).to.equal(process.pid);
-        expect(json.level).to.equal('log');
-        expect(json.message).to.equal(`Set(2) { 'value1', 'value2' }`);
-      });
-      it('should log bigint', () => {
-        const bigInt = BigInt(9007199254740991);
-
-        logger.log(bigInt);
-
-        const json = JSON.parse(processStdoutWriteSpy.firstCall?.firstArg);
-
-        expect(json.pid).to.equal(process.pid);
-        expect(json.level).to.equal('log');
-        expect(json.message).to.equal('9007199254740991');
-      });
-      it('should log symbol', () => {
-        const symbol = Symbol('test');
-
-        logger.log(symbol);
-
-        const json = JSON.parse(processStdoutWriteSpy.firstCall?.firstArg);
-
-        expect(json.pid).to.equal(process.pid);
-        expect(json.level).to.equal('log');
-        expect(json.message).to.equal('Symbol(test)');
-      });
-    });
-
-    describe('when the default logger is used, json mode is enabled and compact is false (utils.inspect)', () => {
-      const logger = new ConsoleLogger({ json: true, compact: false });
-
-      let processStdoutWriteSpy: sinon.SinonSpy;
-      let processStderrWriteSpy: sinon.SinonSpy;
-
-      beforeEach(() => {
-        processStdoutWriteSpy = sinon.spy(process.stdout, 'write');
-        processStderrWriteSpy = sinon.spy(process.stderr, 'write');
-      });
-
-      afterEach(() => {
-        processStdoutWriteSpy.restore();
-        processStderrWriteSpy.restore();
-      });
-
-      it('should log out to stdout as JSON (utils.inspect)', () => {
-        const message = 'message 1';
-
-        logger.log(message);
-
-        const json = convertInspectToJSON(
-          processStdoutWriteSpy.firstCall?.firstArg,
-        );
-
-        expect(json.pid).to.equal(process.pid);
-        expect(json.level).to.equal('log');
-        expect(json.message).to.equal(message);
-      });
-
-      it('should log out an error to stderr as JSON (utils.inspect)', () => {
-        const message = 'message 1';
-
-        logger.error(message);
-
-        const json = convertInspectToJSON(
-          processStderrWriteSpy.firstCall?.firstArg,
-        );
-
-        expect(json.pid).to.equal(process.pid);
-        expect(json.level).to.equal('error');
-        expect(json.message).to.equal(message);
-      });
-    });
-
     describe('when logging is disabled', () => {
       let processStdoutWriteSpy: sinon.SinonSpy;
       let previousLoggerRef: LoggerService;
@@ -718,7 +568,6 @@ describe('Logger', () => {
         expect(processStdoutWriteSpy.called).to.be.false;
       });
     });
-
     describe('when custom logger is being used', () => {
       class CustomLogger implements LoggerService {
         log(message: any, context?: string) {}
@@ -874,7 +723,7 @@ describe('Logger', () => {
         }
       }
 
-      const consoleLogger = new CustomConsoleLogger({ colors: false });
+      const consoleLogger = new CustomConsoleLogger();
       const consoleLoggerSpy = sinon.spy(
         consoleLogger,
         'stringifyMessage' as keyof ConsoleLogger,
@@ -890,40 +739,30 @@ describe('Logger', () => {
 
       expect(consoleLoggerSpy.getCall(0).returnValue).to.equal('str1');
       expect(consoleLoggerSpy.getCall(1).returnValue).to.equal(
-        `Object(1) {
-  key: 'str2'
-}`,
+        `Object:
+{
+  "key": "str2"
+}
+`,
       );
       expect(consoleLoggerSpy.getCall(2).returnValue).to.equal(
-        `Array(1) [
-  'str3'
-]`,
+        `Object:
+[
+  "str3"
+]
+`,
       );
       expect(consoleLoggerSpy.getCall(3).returnValue).to.equal(
-        `Array(1) [
+        `Object:
+[
   {
-    key: 'str4'
+    "key": "str4"
   }
-]`,
+]
+`,
       );
-      expect(consoleLoggerSpy.getCall(4).returnValue).to.equal('null');
-      expect(consoleLoggerSpy.getCall(5).returnValue).to.equal('1');
+      expect(consoleLoggerSpy.getCall(4).returnValue).to.equal(null);
+      expect(consoleLoggerSpy.getCall(5).returnValue).to.equal(1);
     });
   });
 });
-
-function convertInspectToJSON(inspectOutput: string) {
-  const jsonLikeString = inspectOutput
-    .replace(/'([^']+)'/g, '"$1"') // single-quoted strings
-    .replace(/([a-zA-Z0-9_]+):/g, '"$1":') // unquoted object keys
-    .replace(/\bundefined\b/g, 'null')
-    .replace(/\[Function(: [^\]]+)?\]/g, '"[Function]"')
-    .replace(/\[Circular\]/g, '"[Circular]"');
-
-  try {
-    return JSON.parse(jsonLikeString);
-  } catch (error) {
-    console.error('Error parsing the modified inspect output:', error);
-    throw error;
-  }
-}

packages/core/Readme.md

@@ -94,7 +94,7 @@ Nest is an MIT-licensed open source project. It can grow thanks to the sponsors
 <td><a href="https://www.mercedes-benz.com/" target="_blank"><img src="https://nestjs.com/img/logos/mercedes-logo.png" width="100" valign="middle" /></a></td>
 <td><a href="https://www.dinii.jp/" target="_blank"><img src="https://nestjs.com/img/logos/dinii-logo.png" width="65" valign="middle" /></a></td>
 <td><a href="https://bloodycase.com/?promocode=NEST" target="_blank"><img src="https://nestjs.com/img/logos/bloodycase-logo.png" width="65" valign="middle" /></a></td>
-<td><a href="https://handsontable.com/docs/react-data-grid/?utm_source=NestJS_GH&utm_medium=sponsorship&utm_campaign=library_sponsorship_2024" target="_blank"><img src="https://nestjs.com/img/logos/handsontable-logo.svg" width="150" valign="middle" /></a></td>
+<td><a href="https://handsontable.com/docs/react-data-grid/?utm_source=NestJS_GH&utm_medium=sponsorship&utm_campaign=library_sponsorship_2024" target="_blank"><img src="https://nestjs.com/img/logos/handsontable-dark-logo.svg#2" width="150" valign="middle" /></a></td>
 <td align="center" valign="middle"><a href="https://www.itflashcards.com/" target="_blank"><img src="https://nestjs.com/img/logos/it_flashcards-logo.png" width="170" valign="middle" /></a></td>
 <td align="center" valign="middle"><a href="https://arcjet.com/?ref=nestjs" target="_blank"><img src="https://nestjs.com/img/logos/arcjet-logo.svg" width="170" valign="middle" /></a></td>
 </tr>

packages/core/adapters/http-adapter.ts

@@ -62,48 +62,6 @@ export abstract class AbstractHttpAdapter<
     return this.instance.patch(...args);
   }
 
-  public propfind(handler: RequestHandler);
-  public propfind(path: any, handler: RequestHandler);
-  public propfind(...args: any[]) {
-    return this.instance.propfind(...args);
-  }
-
-  public proppatch(handler: RequestHandler);
-  public proppatch(path: any, handler: RequestHandler);
-  public proppatch(...args: any[]) {
-    return this.instance.proppatch(...args);
-  }
-
-  public mkcol(handler: RequestHandler);
-  public mkcol(path: any, handler: RequestHandler);
-  public mkcol(...args: any[]) {
-    return this.instance.mkcol(...args);
-  }
-
-  public copy(handler: RequestHandler);
-  public copy(path: any, handler: RequestHandler);
-  public copy(...args: any[]) {
-    return this.instance.copy(...args);
-  }
-
-  public move(handler: RequestHandler);
-  public move(path: any, handler: RequestHandler);
-  public move(...args: any[]) {
-    return this.instance.move(...args);
-  }
-
-  public lock(handler: RequestHandler);
-  public lock(path: any, handler: RequestHandler);
-  public lock(...args: any[]) {
-    return this.instance.lock(...args);
-  }
-
-  public unlock(handler: RequestHandler);
-  public unlock(path: any, handler: RequestHandler);
-  public unlock(...args: any[]) {
-    return this.instance.unlock(...args);
-  }
-
   public all(handler: RequestHandler);
   public all(path: any, handler: RequestHandler);
   public all(...args: any[]) {

packages/core/errors/exception-handler.ts

@@ -1,9 +1,14 @@
+import { RuntimeException } from './exceptions/runtime.exception';
 import { Logger } from '@nestjs/common/services/logger.service';
 
 export class ExceptionHandler {
   private static readonly logger = new Logger(ExceptionHandler.name);
 
-  public handle(exception: Error) {
-    ExceptionHandler.logger.error(exception);
+  public handle(exception: RuntimeException | Error) {
+    if (!(exception instanceof RuntimeException)) {
+      ExceptionHandler.logger.error(exception.message, exception.stack);
+      return;
+    }
+    ExceptionHandler.logger.error(exception.what(), exception.stack);
   }
 }

packages/core/exceptions/base-exception-filter.ts

@@ -5,7 +5,6 @@ import {
   HttpServer,
   HttpStatus,
   Inject,
-  IntrinsicException,
   Logger,
   Optional,
 } from '@nestjs/common';
@@ -69,9 +68,13 @@ export class BaseExceptionFilter<T = any> implements ExceptionFilter<T> {
       applicationRef.end(response);
     }
 
-    if (!(exception instanceof IntrinsicException)) {
-      BaseExceptionFilter.logger.error(exception);
+    if (this.isExceptionObject(exception)) {
+      return BaseExceptionFilter.logger.error(
+        exception.message,
+        exception.stack,
+      );
     }
+    return BaseExceptionFilter.logger.error(exception);
   }
 
   public isExceptionObject(err: any): err is Error {

packages/core/exceptions/external-exception-filter.ts

@@ -1,14 +1,11 @@
-import { ArgumentsHost, IntrinsicException, Logger } from '@nestjs/common';
+import { ArgumentsHost, HttpException, Logger } from '@nestjs/common';
 
 export class ExternalExceptionFilter<T = any, R = any> {
   private static readonly logger = new Logger('ExceptionsHandler');
 
   catch(exception: T, host: ArgumentsHost): R | Promise<R> {
-    if (
-      exception instanceof Error &&
-      !(exception instanceof IntrinsicException)
-    ) {
-      ExternalExceptionFilter.logger.error(exception);
+    if (exception instanceof Error && !(exception instanceof HttpException)) {
+      ExternalExceptionFilter.logger.error(exception.message, exception.stack);
     }
     throw exception;
   }

packages/core/helpers/http-adapter-host.ts

@@ -1,3 +1,4 @@
+import { Observable, Subject } from 'rxjs';
 import { AbstractHttpAdapter } from '../adapters/http-adapter';
 
 /**
@@ -16,6 +17,8 @@ export class HttpAdapterHost<
   T extends AbstractHttpAdapter = AbstractHttpAdapter,
 > {
   private _httpAdapter?: T;
+  private _listen$ = new Subject<void>();
+  private isListening = false;
 
   /**
    * Accessor for the underlying `HttpAdapter`
@@ -35,4 +38,31 @@ export class HttpAdapterHost<
   get httpAdapter(): T {
     return this._httpAdapter;
   }
+
+  /**
+   * Observable that allows to subscribe to the `listen` event.
+   * This event is emitted when the HTTP application is listening for incoming requests.
+   */
+  get listen$(): Observable<void> {
+    return this._listen$.asObservable();
+  }
+
+  /**
+   * Sets the listening state of the application.
+   */
+  set listening(listening: boolean) {
+    this.isListening = listening;
+
+    if (listening) {
+      this._listen$.next();
+      this._listen$.complete();
+    }
+  }
+
+  /**
+   * Returns a boolean indicating whether the application is listening for incoming requests.
+   */
+  get listening(): boolean {
+    return this.isListening;
+  }
 }

packages/core/helpers/router-method-factory.ts

@@ -11,13 +11,6 @@ const REQUEST_METHOD_MAP = {
   [RequestMethod.OPTIONS]: 'options',
   [RequestMethod.HEAD]: 'head',
   [RequestMethod.SEARCH]: 'search',
-  [RequestMethod.PROPFIND]: 'propfind',
-  [RequestMethod.PROPPATCH]: 'proppatch',
-  [RequestMethod.MKCOL]: 'mkcol',
-  [RequestMethod.COPY]: 'copy',
-  [RequestMethod.MOVE]: 'move',
-  [RequestMethod.LOCK]: 'lock',
-  [RequestMethod.UNLOCK]: 'unlock',
 } as const satisfies Record<RequestMethod, keyof HttpServer>;
 
 export class RouterMethodFactory {

packages/core/injector/compiler.ts

@@ -3,7 +3,7 @@ import {
   ForwardReference,
   Type,
 } from '@nestjs/common/interfaces';
-import { ModuleOpaqueKeyFactory } from './opaque-key-factory/interfaces/module-opaque-key-factory.interface';
+import { ModuleTokenFactory } from './module-token-factory';
 
 export interface ModuleFactory {
   type: Type<any>;
@@ -12,59 +12,36 @@ export interface ModuleFactory {
 }
 
 export class ModuleCompiler {
-  constructor(
-    private readonly _moduleOpaqueKeyFactory: ModuleOpaqueKeyFactory,
-  ) {}
-
-  get moduleOpaqueKeyFactory(): ModuleOpaqueKeyFactory {
-    return this._moduleOpaqueKeyFactory;
-  }
+  constructor(private readonly moduleTokenFactory = new ModuleTokenFactory()) {}
 
   public async compile(
-    moduleClsOrDynamic:
-      | Type
-      | DynamicModule
-      | ForwardReference
-      | Promise<DynamicModule>,
+    metatype: Type<any> | DynamicModule | Promise<DynamicModule>,
   ): Promise<ModuleFactory> {
-    moduleClsOrDynamic = await moduleClsOrDynamic;
-
-    const { type, dynamicMetadata } = this.extractMetadata(moduleClsOrDynamic);
-    const token = dynamicMetadata
-      ? this._moduleOpaqueKeyFactory.createForDynamic(
-          type,
-          dynamicMetadata,
-          moduleClsOrDynamic as DynamicModule | ForwardReference,
-        )
-      : this._moduleOpaqueKeyFactory.createForStatic(
-          type,
-          moduleClsOrDynamic as Type,
-        );
-
+    const { type, dynamicMetadata } = this.extractMetadata(await metatype);
+    const token = this.moduleTokenFactory.create(type, dynamicMetadata);
     return { type, dynamicMetadata, token };
   }
 
   public extractMetadata(
-    moduleClsOrDynamic: Type | ForwardReference | DynamicModule,
+    metatype: Type<any> | ForwardReference | DynamicModule,
   ): {
-    type: Type;
-    dynamicMetadata: Omit<DynamicModule, 'module'> | undefined;
+    type: Type<any>;
+    dynamicMetadata?: Partial<DynamicModule> | undefined;
   } {
-    if (!this.isDynamicModule(moduleClsOrDynamic)) {
+    if (!this.isDynamicModule(metatype)) {
       return {
-        type: (moduleClsOrDynamic as ForwardReference)?.forwardRef
-          ? (moduleClsOrDynamic as ForwardReference).forwardRef()
-          : moduleClsOrDynamic,
-        dynamicMetadata: undefined,
+        type: (metatype as ForwardReference)?.forwardRef
+          ? (metatype as ForwardReference).forwardRef()
+          : metatype,
       };
     }
-    const { module: type, ...dynamicMetadata } = moduleClsOrDynamic;
+    const { module: type, ...dynamicMetadata } = metatype;
     return { type, dynamicMetadata };
   }
 
   public isDynamicModule(
-    moduleClsOrDynamic: Type | DynamicModule | ForwardReference,
-  ): moduleClsOrDynamic is DynamicModule {
-    return !!(moduleClsOrDynamic as DynamicModule).module;
+    module: Type<any> | DynamicModule | ForwardReference,
+  ): module is DynamicModule {
+    return !!(module as DynamicModule).module;
   }
 }

packages/core/injector/container.ts

@@ -4,7 +4,6 @@ import {
   GLOBAL_MODULE_METADATA,
 } from '@nestjs/common/constants';
 import { Injectable, Type } from '@nestjs/common/interfaces';
-import { NestApplicationContextOptions } from '@nestjs/common/interfaces/nest-application-context-options.interface';
 import { ApplicationConfig } from '../application-config';
 import { DiscoverableMetaHostCollection } from '../discovery/discoverable-meta-host-collection';
 import {
@@ -20,16 +19,16 @@ import { ContextId } from './instance-wrapper';
 import { InternalCoreModule } from './internal-core-module/internal-core-module';
 import { InternalProvidersStorage } from './internal-providers-storage';
 import { Module } from './module';
+import { ModuleTokenFactory } from './module-token-factory';
 import { ModulesContainer } from './modules-container';
-import { ByReferenceModuleOpaqueKeyFactory } from './opaque-key-factory/by-reference-module-opaque-key-factory';
-import { DeepHashedModuleOpaqueKeyFactory } from './opaque-key-factory/deep-hashed-module-opaque-key-factory';
-import { ModuleOpaqueKeyFactory } from './opaque-key-factory/interfaces/module-opaque-key-factory.interface';
 
 type ModuleMetatype = Type<any> | DynamicModule | Promise<DynamicModule>;
 type ModuleScope = Type<any>[];
 
 export class NestContainer {
   private readonly globalModules = new Set<Module>();
+  private readonly moduleTokenFactory = new ModuleTokenFactory();
+  private readonly moduleCompiler = new ModuleCompiler(this.moduleTokenFactory);
   private readonly modules = new ModulesContainer();
   private readonly dynamicModulesMetadata = new Map<
     string,
@@ -37,27 +36,11 @@ export class NestContainer {
   >();
   private readonly internalProvidersStorage = new InternalProvidersStorage();
   private readonly _serializedGraph = new SerializedGraph();
-  private moduleCompiler: ModuleCompiler;
   private internalCoreModule: Module;
 
   constructor(
-    private readonly _applicationConfig:
-      | ApplicationConfig
-      | undefined = undefined,
-    private readonly _contextOptions:
-      | NestApplicationContextOptions
-      | undefined = undefined,
-  ) {
-    const moduleOpaqueKeyFactory =
-      this._contextOptions?.moduleIdGeneratorAlgorithm === 'deep-hash'
-        ? new DeepHashedModuleOpaqueKeyFactory()
-        : new ByReferenceModuleOpaqueKeyFactory({
-            keyGenerationStrategy: this._contextOptions?.snapshot
-              ? 'shallow'
-              : 'random',
-          });
-    this.moduleCompiler = new ModuleCompiler(moduleOpaqueKeyFactory);
-  }
+    private readonly _applicationConfig: ApplicationConfig = undefined,
+  ) {}
 
   get serializedGraph(): SerializedGraph {
     return this._serializedGraph;
@@ -338,8 +321,8 @@ export class NestContainer {
     this.modules[InternalCoreModule.name] = moduleRef;
   }
 
-  public getModuleTokenFactory(): ModuleOpaqueKeyFactory {
-    return this.moduleCompiler.moduleOpaqueKeyFactory;
+  public getModuleTokenFactory(): ModuleTokenFactory {
+    return this.moduleTokenFactory;
   }
 
   public registerRequestProvider<T = any>(request: T, contextId: ContextId) {

packages/core/injector/injector.ts

@@ -170,6 +170,11 @@ export class Injector {
         inquirer,
       );
     } catch (err) {
+      wrapper.removeInstanceByContextId(
+        this.getContextId(contextId, wrapper),
+        inquirerId,
+      );
+
       settlementSignal.error(err);
       throw err;
     }
@@ -338,11 +343,20 @@ export class Injector {
     wrapper: InstanceWrapper<T>,
   ): [InjectorDependency[], number[]] {
     const optionalDependenciesIds = [];
-    const isOptionalFactoryDep = (
-      item: InjectionToken | OptionalFactoryDependency,
-    ): item is OptionalFactoryDependency =>
-      !isUndefined((item as OptionalFactoryDependency).token) &&
-      !isUndefined((item as OptionalFactoryDependency).optional);
+
+    /**
+     * Same as the internal utility function `isOptionalFactoryDependency` from `@nestjs/common`.
+     * We are duplicating it here because that one is not supposed to be exported.
+     */
+    function isOptionalFactoryDependency(
+      value: InjectionToken | OptionalFactoryDependency,
+    ): value is OptionalFactoryDependency {
+      return (
+        !isUndefined((value as OptionalFactoryDependency).token) &&
+        !isUndefined((value as OptionalFactoryDependency).optional) &&
+        !(value as any).prototype
+      );
+    }
 
     const mapFactoryProviderInjectArray = (
       item: InjectionToken | OptionalFactoryDependency,
@@ -351,7 +365,7 @@ export class Injector {
       if (typeof item !== 'object') {
         return item;
       }
-      if (isOptionalFactoryDep(item)) {
+      if (isOptionalFactoryDependency(item)) {
         if (item.optional) {
           optionalDependenciesIds.push(index);
         }

packages/core/injector/instance-wrapper.ts

@@ -168,6 +168,21 @@ export class InstanceWrapper<T = any> {
     collection.set(contextId, value);
   }
 
+  public removeInstanceByContextId(contextId: ContextId, inquirerId?: string) {
+    if (this.scope === Scope.TRANSIENT && inquirerId) {
+      return this.removeInstanceByInquirerId(contextId, inquirerId);
+    }
+    this.values.delete(contextId);
+  }
+
+  public removeInstanceByInquirerId(contextId: ContextId, inquirerId: string) {
+    const collection = this.transientMap.get(inquirerId);
+    if (!collection) {
+      return;
+    }
+    collection.delete(contextId);
+  }
+
   public addCtorMetadata(index: number, wrapper: InstanceWrapper) {
     if (!this[INSTANCE_METADATA_SYMBOL].dependencies) {
       this[INSTANCE_METADATA_SYMBOL].dependencies = [];

packages/core/injector/module-token-factory.ts

@@ -1,48 +1,34 @@
-import { DynamicModule } from '@nestjs/common/interfaces/modules/dynamic-module.interface';
+import { DynamicModule, Logger } from '@nestjs/common';
 import { Type } from '@nestjs/common/interfaces/type.interface';
-import { Logger } from '@nestjs/common/services/logger.service';
 import { randomStringGenerator } from '@nestjs/common/utils/random-string-generator.util';
 import { isFunction, isSymbol } from '@nestjs/common/utils/shared.utils';
 import { createHash } from 'crypto';
 import stringify from 'fast-safe-stringify';
-import { ModuleOpaqueKeyFactory } from './interfaces/module-opaque-key-factory.interface';
+import { performance } from 'perf_hooks';
 
 const CLASS_STR = 'class ';
 const CLASS_STR_LEN = CLASS_STR.length;
 
-export class DeepHashedModuleOpaqueKeyFactory
-  implements ModuleOpaqueKeyFactory
-{
-  private readonly moduleIdsCache = new WeakMap<Type<unknown>, string>();
+export class ModuleTokenFactory {
   private readonly moduleTokenCache = new Map<string, string>();
-  private readonly logger = new Logger(DeepHashedModuleOpaqueKeyFactory.name, {
+  private readonly moduleIdsCache = new WeakMap<Type<unknown>, string>();
+  private readonly logger = new Logger(ModuleTokenFactory.name, {
     timestamp: true,
   });
 
-  public createForStatic(moduleCls: Type): string {
-    const moduleId = this.getModuleId(moduleCls);
-    const moduleName = this.getModuleName(moduleCls);
-
-    const key = `${moduleId}_${moduleName}`;
-    if (this.moduleTokenCache.has(key)) {
-      return this.moduleTokenCache.get(key);
-    }
-
-    const hash = this.hashString(key);
-    this.moduleTokenCache.set(key, hash);
-    return hash;
-  }
-
-  public createForDynamic(
-    moduleCls: Type<unknown>,
-    dynamicMetadata: Omit<DynamicModule, 'module'>,
+  public create(
+    metatype: Type<unknown>,
+    dynamicModuleMetadata?: Partial<DynamicModule> | undefined,
   ): string {
-    const moduleId = this.getModuleId(moduleCls);
-    const moduleName = this.getModuleName(moduleCls);
+    const moduleId = this.getModuleId(metatype);
+
+    if (!dynamicModuleMetadata) {
+      return this.getStaticModuleToken(moduleId, this.getModuleName(metatype));
+    }
     const opaqueToken = {
       id: moduleId,
-      module: moduleName,
-      dynamic: dynamicMetadata,
+      module: this.getModuleName(metatype),
+      dynamic: dynamicModuleMetadata,
     };
     const start = performance.now();
     const opaqueTokenString = this.getStringifiedOpaqueToken(opaqueToken);
@@ -51,13 +37,24 @@ export class DeepHashedModuleOpaqueKeyFactory
     if (timeSpentInMs > 10) {
       const formattedTimeSpent = timeSpentInMs.toFixed(2);
       this.logger.warn(
-        `The module "${opaqueToken.module}" is taking ${formattedTimeSpent}ms to serialize, this may be caused by larger objects statically assigned to the module. Consider changing the "moduleIdGeneratorAlgorithm" option to "reference" to improve the performance.`,
+        `The module "${opaqueToken.module}" is taking ${formattedTimeSpent}ms to serialize, this may be caused by larger objects statically assigned to the module. More details: https://github.com/nestjs/nest/issues/12738`,
       );
     }
 
     return this.hashString(opaqueTokenString);
   }
 
+  public getStaticModuleToken(moduleId: string, moduleName: string): string {
+    const key = `${moduleId}_${moduleName}`;
+    if (this.moduleTokenCache.has(key)) {
+      return this.moduleTokenCache.get(key);
+    }
+
+    const hash = this.hashString(key);
+    this.moduleTokenCache.set(key, hash);
+    return hash;
+  }
+
   public getStringifiedOpaqueToken(opaqueToken: object | undefined): string {
     // Uses safeStringify instead of JSON.stringify to support circular dynamic modules
     // The replacer function is also required in order to obtain real class names

packages/core/injector/module.ts

@@ -12,6 +12,7 @@ import {
   InjectionToken,
   NestModule,
   Provider,
+  Scope,
   Type,
   ValueProvider,
 } from '@nestjs/common/interfaces';
@@ -253,6 +254,11 @@ export class Module {
       return this.addCustomProvider(provider, this._providers, enhancerSubtype);
     }
 
+    const isAlreadyDeclared = this._providers.has(provider);
+    if (this.isTransientProvider(provider) && isAlreadyDeclared) {
+      return provider;
+    }
+
     this._providers.set(
       provider,
       new InstanceWrapper({
@@ -653,12 +659,11 @@ export class Module {
 
   private generateUuid(): string {
     const prefix = 'M_';
-    const key = this.token
-      ? this.token.includes(':')
-        ? this.token.split(':')[1]
-        : this.token
-      : this.name;
-
+    const key = this.name?.toString() ?? this.token?.toString();
     return key ? UuidFactory.get(`${prefix}_${key}`) : randomStringGenerator();
   }
+
+  private isTransientProvider(provider: Type<any>): boolean {
+    return getClassScope(provider) === Scope.TRANSIENT;
+  }
 }

packages/core/injector/opaque-key-factory/by-reference-module-opaque-key-factory.ts

@@ -1,63 +0,0 @@
-import { DynamicModule } from '@nestjs/common/interfaces/modules/dynamic-module.interface';
-import { ForwardReference } from '@nestjs/common/interfaces/modules/forward-reference.interface';
-import { Type } from '@nestjs/common/interfaces/type.interface';
-import { randomStringGenerator } from '@nestjs/common/utils/random-string-generator.util';
-import { createHash } from 'crypto';
-import { ModuleOpaqueKeyFactory } from './interfaces/module-opaque-key-factory.interface';
-
-const K_MODULE_ID = Symbol('K_MODULE_ID');
-
-export class ByReferenceModuleOpaqueKeyFactory
-  implements ModuleOpaqueKeyFactory
-{
-  private readonly keyGenerationStrategy: 'random' | 'shallow';
-
-  constructor(options?: { keyGenerationStrategy: 'random' | 'shallow' }) {
-    this.keyGenerationStrategy = options?.keyGenerationStrategy ?? 'random';
-  }
-
-  public createForStatic(
-    moduleCls: Type,
-    originalRef: Type | ForwardReference = moduleCls,
-  ): string {
-    return this.getOrCreateModuleId(moduleCls, undefined, originalRef);
-  }
-
-  public createForDynamic(
-    moduleCls: Type<unknown>,
-    dynamicMetadata: Omit<DynamicModule, 'module'>,
-    originalRef: DynamicModule | ForwardReference,
-  ): string {
-    return this.getOrCreateModuleId(moduleCls, dynamicMetadata, originalRef);
-  }
-
-  private getOrCreateModuleId(
-    moduleCls: Type<unknown>,
-    dynamicMetadata: Partial<DynamicModule> | undefined,
-    originalRef: Type | DynamicModule | ForwardReference,
-  ): string {
-    if (originalRef[K_MODULE_ID]) {
-      return originalRef[K_MODULE_ID];
-    }
-
-    let moduleId: string;
-    if (this.keyGenerationStrategy === 'random') {
-      moduleId = this.generateRandomString();
-    } else {
-      moduleId = dynamicMetadata
-        ? `${this.generateRandomString()}:${this.hashString(moduleCls.name + JSON.stringify(dynamicMetadata))}`
-        : `${this.generateRandomString()}:${this.hashString(moduleCls.toString())}`;
-    }
-
-    originalRef[K_MODULE_ID] = moduleId;
-    return moduleId;
-  }
-
-  private hashString(value: string): string {
-    return createHash('sha256').update(value).digest('hex');
-  }
-
-  private generateRandomString(): string {
-    return randomStringGenerator();
-  }
-}

packages/core/injector/opaque-key-factory/interfaces/module-opaque-key-factory.interface.ts

@@ -1,26 +0,0 @@
-import { DynamicModule } from '@nestjs/common/interfaces/modules/dynamic-module.interface';
-import { ForwardReference } from '@nestjs/common/interfaces/modules/forward-reference.interface';
-import { Type } from '@nestjs/common/interfaces/type.interface';
-
-export interface ModuleOpaqueKeyFactory {
-  /**
-   * Creates a unique opaque key for the given static module.
-   * @param moduleCls A static module class.
-   * @param originalRef Original object reference. In most cases, it's the same as `moduleCls`.
-   */
-  createForStatic(
-    moduleCls: Type,
-    originalRef: Type | ForwardReference,
-  ): string;
-  /**
-   * Creates a unique opaque key for the given dynamic module.
-   * @param moduleCls  A dynamic module class reference.
-   * @param dynamicMetadata Dynamic module metadata.
-   * @param originalRef Original object reference.
-   */
-  createForDynamic(
-    moduleCls: Type<unknown>,
-    dynamicMetadata: Omit<DynamicModule, 'module'>,
-    originalRef: DynamicModule | ForwardReference,
-  ): string;
-}

packages/core/middleware/middleware-module.ts

@@ -346,7 +346,9 @@ export class MiddlewareModule<
         configurable: false,
       });
 
-      const requestProviderValue = isTreeDurable ? contextId.payload : request;
+      const requestProviderValue = isTreeDurable
+        ? contextId.payload
+        : Object.assign(request, contextId.payload);
       this.container.registerRequestProvider(requestProviderValue, contextId);
     }
     return contextId;

packages/core/nest-application-context.ts

@@ -9,7 +9,6 @@ import {
   Abstract,
   DynamicModule,
   GetOrResolveOptions,
-  SelectOptions,
   Type,
 } from '@nestjs/common/interfaces';
 import { NestApplicationContextOptions } from '@nestjs/common/interfaces/nest-application-context-options.interface';
@@ -51,10 +50,11 @@ export class NestApplicationContext<
 
   private shouldFlushLogsOnOverride = false;
   private readonly activeShutdownSignals = new Array<string>();
-  private readonly moduleCompiler: ModuleCompiler;
+  private readonly moduleCompiler = new ModuleCompiler();
   private shutdownCleanupRef?: (...args: unknown[]) => unknown;
   private _instanceLinksHost: InstanceLinksHost;
   private _moduleRefsForHooksByDistance?: Array<Module>;
+  private initializationPromise?: Promise<void>;
 
   protected get instanceLinksHost() {
     if (!this._instanceLinksHost) {
@@ -71,7 +71,6 @@ export class NestApplicationContext<
   ) {
     super();
     this.injector = new Injector();
-    this.moduleCompiler = container.getModuleCompiler();
 
     if (this.appOptions.preview) {
       this.printInPreviewModeWarning();
@@ -89,7 +88,6 @@ export class NestApplicationContext<
    */
   public select<T>(
     moduleType: Type<T> | DynamicModule,
-    selectOptions?: SelectOptions,
   ): INestApplicationContext {
     const modulesContainer = this.container.getModules();
     const contextModuleCtor = this.contextModule.metatype;
@@ -98,30 +96,15 @@ export class NestApplicationContext<
     const moduleTokenFactory = this.container.getModuleTokenFactory();
     const { type, dynamicMetadata } =
       this.moduleCompiler.extractMetadata(moduleType);
-    const token = dynamicMetadata
-      ? moduleTokenFactory.createForDynamic(
-          type,
-          dynamicMetadata,
-          moduleType as DynamicModule,
-        )
-      : moduleTokenFactory.createForStatic(type, moduleType as Type);
+    const token = moduleTokenFactory.create(type, dynamicMetadata);
 
     const selectedModule = modulesContainer.get(token);
     if (!selectedModule) {
       throw new UnknownModuleException(type.name);
     }
-
-    const options =
-      typeof selectOptions?.abortOnError !== 'undefined'
-        ? {
-            ...this.appOptions,
-            ...selectOptions,
-          }
-        : this.appOptions;
-
     return new NestApplicationContext(
       this.container,
-      options,
+      this.appOptions,
       selectedModule,
       scope,
     );
@@ -252,8 +235,16 @@ export class NestApplicationContext<
     if (this.isInitialized) {
       return this;
     }
-    await this.callInitHook();
-    await this.callBootstrapHook();
+    this.initializationPromise = new Promise(async (resolve, reject) => {
+      try {
+        await this.callInitHook();
+        await this.callBootstrapHook();
+        resolve();
+      } catch (err) {
+        reject(err);
+      }
+    });
+    await this.initializationPromise;
 
     this.isInitialized = true;
     return this;
@@ -264,6 +255,7 @@ export class NestApplicationContext<
    * @returns {Promise<void>}
    */
   public async close(signal?: string): Promise<void> {
+    await this.initializationPromise;
     await this.callDestroyHook();
     await this.callBeforeShutdownHook(signal);
     await this.dispose();
@@ -351,6 +343,7 @@ export class NestApplicationContext<
           return;
         }
         receivedSignal = true;
+        await this.initializationPromise;
         await this.callDestroyHook();
         await this.callBeforeShutdownHook(signal);
         await this.dispose();
@@ -402,10 +395,7 @@ export class NestApplicationContext<
    * modules and its children.
    */
   protected async callDestroyHook(): Promise<void> {
-    const modulesSortedByDistance = [
-      ...this.getModulesToTriggerHooksOn(),
-    ].reverse();
-
+    const modulesSortedByDistance = this.getModulesToTriggerHooksOn();
     for (const module of modulesSortedByDistance) {
       await callModuleDestroyHook(module);
     }

packages/core/nest-application.ts

@@ -294,8 +294,12 @@ export class NestApplication
   public async listen(port: number | string, hostname: string): Promise<any>;
   public async listen(port: number | string, ...args: any[]): Promise<any> {
     this.assertNotInPreviewMode('listen');
-    !this.isInitialized && (await this.init());
 
+    if (!this.isInitialized) {
+      await this.init();
+    }
+
+    const httpAdapterHost = this.container.getHttpAdapterHostRef();
     return new Promise((resolve, reject) => {
       const errorHandler = (e: any) => {
         this.logger.error(e?.toString?.());
@@ -323,6 +327,8 @@ export class NestApplication
           if (address) {
             this.httpServer.removeListener('error', errorHandler);
             this.isListening = true;
+
+            httpAdapterHost.listening = true;
             resolve(this.httpServer);
           }
           if (isCallbackInOriginalArgs) {

packages/core/nest-factory.ts

@@ -3,9 +3,6 @@ import {
   INestApplication,
   INestApplicationContext,
   INestMicroservice,
-  DynamicModule,
-  ForwardReference,
-  Type,
 } from '@nestjs/common';
 import { NestMicroserviceOptions } from '@nestjs/common/interfaces/microservices/nest-microservice-options.interface';
 import { NestApplicationContextOptions } from '@nestjs/common/interfaces/nest-application-context-options.interface';
@@ -30,12 +27,6 @@ import { NestApplication } from './nest-application';
 import { NestApplicationContext } from './nest-application-context';
 import { DependenciesScanner } from './scanner';
 
-type IEntryNestModule =
-  | Type<any>
-  | DynamicModule
-  | ForwardReference
-  | Promise<IEntryNestModule>;
-
 /**
  * @publicApi
  */
@@ -56,7 +47,7 @@ export class NestFactoryStatic {
    * contains a reference to the NestApplication instance.
    */
   public async create<T extends INestApplication = INestApplication>(
-    module: IEntryNestModule,
+    module: any,
     options?: NestApplicationOptions,
   ): Promise<T>;
   /**
@@ -71,12 +62,12 @@ export class NestFactoryStatic {
    * contains a reference to the NestApplication instance.
    */
   public async create<T extends INestApplication = INestApplication>(
-    module: IEntryNestModule,
+    module: any,
     httpAdapter: AbstractHttpAdapter,
     options?: NestApplicationOptions,
   ): Promise<T>;
   public async create<T extends INestApplication = INestApplication>(
-    moduleCls: IEntryNestModule,
+    moduleCls: any,
     serverOrOptions?: AbstractHttpAdapter | NestApplicationOptions,
     options?: NestApplicationOptions,
   ): Promise<T> {
@@ -121,7 +112,7 @@ export class NestFactoryStatic {
    * contains a reference to the NestMicroservice instance.
    */
   public async createMicroservice<T extends object>(
-    moduleCls: IEntryNestModule,
+    moduleCls: any,
     options?: NestMicroserviceOptions & T,
   ): Promise<INestMicroservice> {
     const { NestMicroservice } = loadPackage(
@@ -163,7 +154,7 @@ export class NestFactoryStatic {
    * contains a reference to the NestApplicationContext instance.
    */
   public async createApplicationContext(
-    moduleCls: IEntryNestModule,
+    moduleCls: any,
     options?: NestApplicationContextOptions,
   ): Promise<INestApplicationContext> {
     const applicationConfig = new ApplicationConfig();

packages/core/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nestjs/core",
-  "version": "10.4.7",
+  "version": "10.4.18",
   "description": "Nest - modern, fast, powerful node.js web framework (@core)",
   "author": "Kamil Mysliwiec",
   "license": "MIT",
@@ -32,11 +32,11 @@
     "fast-safe-stringify": "2.1.1",
     "iterare": "1.2.1",
     "path-to-regexp": "3.3.0",
-    "tslib": "2.7.0",
+    "tslib": "2.8.1",
     "uid": "2.0.2"
   },
   "devDependencies": {
-    "@nestjs/common": "10.4.7"
+    "@nestjs/common": "10.4.18"
   },
   "peerDependencies": {
     "@nestjs/common": "^10.0.0",

packages/core/router/router-explorer.ts

@@ -418,7 +418,9 @@ export class RouterExplorer {
         configurable: false,
       });
 
-      const requestProviderValue = isTreeDurable ? contextId.payload : request;
+      const requestProviderValue = isTreeDurable
+        ? contextId.payload
+        : Object.assign(request, contextId.payload);
       this.container.registerRequestProvider(requestProviderValue, contextId);
     }
     return contextId;

packages/core/scanner.ts

@@ -92,10 +92,10 @@ export class DependenciesScanner {
       overrides: options?.overrides,
     });
     await this.scanModulesForDependencies();
+    this.calculateModulesDistance();
+
     this.addScopedEnhancersMetadata();
     this.container.bindGlobalScope();
-
-    this.calculateModulesDistance();
   }
 
   public async scanForModules({
@@ -389,16 +389,12 @@ export class DependenciesScanner {
     // Skip "InternalCoreModule" from calculating distance
     modulesGenerator.next();
 
-    const calculateDistance = (
-      moduleRef: Module,
-      distance = 1,
-      modulesStack = [],
-    ) => {
-      const localModulesStack = [...modulesStack];
-      if (!moduleRef || localModulesStack.includes(moduleRef)) {
+    const modulesStack = [];
+    const calculateDistance = (moduleRef: Module, distance = 1) => {
+      if (!moduleRef || modulesStack.includes(moduleRef)) {
         return;
       }
-      localModulesStack.push(moduleRef);
+      modulesStack.push(moduleRef);
 
       const moduleImports = moduleRef.imports;
       moduleImports.forEach(importedModuleRef => {
@@ -406,7 +402,7 @@ export class DependenciesScanner {
           if (distance > importedModuleRef.distance) {
             importedModuleRef.distance = distance;
           }
-          calculateDistance(importedModuleRef, distance + 1, localModulesStack);
+          calculateDistance(importedModuleRef, distance + 1);
         }
       });
     };

packages/core/services/reflector.service.ts

@@ -127,10 +127,14 @@ export class Reflector {
    * @param targets context (decorated objects) to retrieve metadata from
    *
    */
-  public getAll<TParam = any, TTransformed = TParam>(
-    decorator: ReflectableDecorator<TParam, TTransformed>,
+  public getAll<T extends ReflectableDecorator<any>>(
+    decorator: T,
     targets: (Type<any> | Function)[],
-  ): TTransformed extends Array<any> ? TTransformed : TTransformed[];
+  ): T extends ReflectableDecorator<infer R>
+    ? R extends Array<any>
+      ? R
+      : R[]
+    : unknown;
   /**
    * Retrieve metadata for a specified key for a specified set of targets.
    *
@@ -165,14 +169,10 @@ export class Reflector {
    * @param targets context (decorated objects) to retrieve metadata from
    *
    */
-  public getAllAndMerge<TParam = any, TTransformed = TParam>(
-    decorator: ReflectableDecorator<TParam, TTransformed>,
+  public getAllAndMerge<T extends ReflectableDecorator<any>>(
+    decorator: T,
     targets: (Type<any> | Function)[],
-  ): TTransformed extends Array<any>
-    ? TTransformed
-    : TTransformed extends object
-      ? TTransformed
-      : TTransformed[];
+  ): T extends ReflectableDecorator<infer R> ? R : unknown;
   /**
    * Retrieve metadata for a specified key for a specified set of targets and merge results.
    *
@@ -203,13 +203,6 @@ export class Reflector {
     if (isEmpty(metadataCollection)) {
       return metadataCollection as TResult;
     }
-    if (metadataCollection.length === 1) {
-      const value = metadataCollection[0];
-      if (isObject(value)) {
-        return value as TResult;
-      }
-      return metadataCollection as TResult;
-    }
     return metadataCollection.reduce((a, b) => {
       if (Array.isArray(a)) {
         return a.concat(b);
@@ -231,10 +224,10 @@ export class Reflector {
    * @param targets context (decorated objects) to retrieve metadata from
    *
    */
-  public getAllAndOverride<TParam = any, TTransformed = TParam>(
-    decorator: ReflectableDecorator<TParam, TTransformed>,
+  public getAllAndOverride<T extends ReflectableDecorator<any>>(
+    decorator: T,
     targets: (Type<any> | Function)[],
-  ): TTransformed;
+  ): T extends ReflectableDecorator<infer R> ? R : unknown;
   /**
    * Retrieve metadata for a specified key for a specified set of targets and return a first not undefined value.
    *

packages/core/test/errors/test/exception-handler.spec.ts

@@ -1,7 +1,8 @@
-import { expect } from 'chai';
 import * as sinon from 'sinon';
+import { expect } from 'chai';
 import { ExceptionHandler } from '../../../errors/exception-handler';
 import { RuntimeException } from '../../../errors/exceptions/runtime.exception';
+import { InvalidMiddlewareException } from '../../../errors/exceptions/invalid-middleware.exception';
 
 describe('ExceptionHandler', () => {
   let instance: ExceptionHandler;
@@ -9,7 +10,7 @@ describe('ExceptionHandler', () => {
     instance = new ExceptionHandler();
   });
   describe('handle', () => {
-    let logger: { error: Function };
+    let logger;
     let errorSpy: sinon.SinonSpy;
     beforeEach(() => {
       logger = {
@@ -18,10 +19,16 @@ describe('ExceptionHandler', () => {
       (ExceptionHandler as any).logger = logger;
       errorSpy = sinon.spy(logger, 'error');
     });
-    it('should call the logger.error method with the thrown exception passed as an argument', () => {
+    it('when exception is instanceof RuntimeException', () => {
       const exception = new RuntimeException('msg');
       instance.handle(exception);
-      expect(errorSpy.calledWith(exception)).to.be.true;
+      expect(errorSpy.calledWith(exception.message, exception.stack)).to.be
+        .true;
+    });
+    it('when exception is not instanceof RuntimeException', () => {
+      const exception = new InvalidMiddlewareException('msg');
+      instance.handle(exception);
+      expect(errorSpy.calledWith(exception.what(), exception.stack)).to.be.true;
     });
   });
 });

packages/core/test/helpers/application-ref-host.spec.ts

@@ -2,11 +2,27 @@ import { expect } from 'chai';
 import { HttpAdapterHost } from '../../helpers/http-adapter-host';
 
 describe('HttpAdapterHost', () => {
-  const applicationRefHost = new HttpAdapterHost();
+  let applicationRefHost: HttpAdapterHost;
+  beforeEach(() => {
+    applicationRefHost = new HttpAdapterHost();
+  });
+
   it('should wrap application reference', () => {
     const ref = {};
     applicationRefHost.httpAdapter = ref as any;
 
     expect(applicationRefHost.httpAdapter).to.be.eql(ref);
   });
+
+  it('should emit listen event when listening is set to true', done => {
+    applicationRefHost.listen$.subscribe(() => {
+      expect(applicationRefHost.listening).to.be.true;
+      done();
+    });
+    applicationRefHost.listening = true;
+  });
+
+  it('listening should return false if the application isnt listening yet', () => {
+    expect(applicationRefHost.listening).to.be.false;
+  });
 });

packages/core/test/helpers/router-method-factory.spec.ts

@@ -14,13 +14,6 @@ describe('RouterMethodFactory', () => {
     patch: () => {},
     options: () => {},
     head: () => {},
-    propfind: () => {},
-    proppatch: () => {},
-    mkcol: () => {},
-    copy: () => {},
-    move: () => {},
-    lock: () => {},
-    unlock: () => {},
     all: () => {},
   };
   beforeEach(() => {
@@ -36,17 +29,6 @@ describe('RouterMethodFactory', () => {
     expect(factory.get(target, RequestMethod.PATCH)).to.equal(target.patch);
     expect(factory.get(target, RequestMethod.OPTIONS)).to.equal(target.options);
     expect(factory.get(target, RequestMethod.HEAD)).to.equal(target.head);
-    expect(factory.get(target, RequestMethod.PROPFIND)).to.equal(
-      target.propfind,
-    );
-    expect(factory.get(target, RequestMethod.PROPPATCH)).to.equal(
-      target.proppatch,
-    );
-    expect(factory.get(target, RequestMethod.MKCOL)).to.equal(target.mkcol);
-    expect(factory.get(target, RequestMethod.COPY)).to.equal(target.copy);
-    expect(factory.get(target, RequestMethod.MOVE)).to.equal(target.move);
-    expect(factory.get(target, RequestMethod.LOCK)).to.equal(target.lock);
-    expect(factory.get(target, RequestMethod.UNLOCK)).to.equal(target.unlock);
     expect(factory.get(target, -1 as any)).to.equal(target.use);
   });
 });

packages/core/test/injector/compiler.spec.ts

@@ -1,30 +1,28 @@
 import { expect } from 'chai';
 import { ModuleCompiler } from '../../injector/compiler';
-import { ByReferenceModuleOpaqueKeyFactory } from '../../injector/opaque-key-factory/by-reference-module-opaque-key-factory';
 
 describe('ModuleCompiler', () => {
   let compiler: ModuleCompiler;
   beforeEach(() => {
-    compiler = new ModuleCompiler(new ByReferenceModuleOpaqueKeyFactory());
+    compiler = new ModuleCompiler();
   });
 
   describe('extractMetadata', () => {
     describe('when module is a dynamic module', () => {
-      it('should return object with "type" and "dynamicMetadata" property', () => {
+      it('should return object with "type" and "dynamicMetadata" property', async () => {
         const obj = { module: 'test', providers: [] };
         const { module, ...dynamicMetadata } = obj;
-        expect(compiler.extractMetadata(obj as any)).to.be.deep.equal({
+        expect(await compiler.extractMetadata(obj as any)).to.be.deep.equal({
           type: module,
           dynamicMetadata,
         });
       });
     });
     describe('when module is a not dynamic module', () => {
-      it('should return object with "type" property', () => {
+      it('should return object with "type" property', async () => {
         const type = 'test';
-        expect(compiler.extractMetadata(type as any)).to.be.deep.equal({
+        expect(await compiler.extractMetadata(type as any)).to.be.deep.equal({
           type,
-          dynamicMetadata: undefined,
         });
       });
     });

packages/core/test/injector/container.spec.ts

@@ -9,7 +9,6 @@ import { NoopHttpAdapter } from '../utils/noop-adapter.spec';
 
 describe('NestContainer', () => {
   let container: NestContainer;
-  let untypedContainer: any;
 
   @Module({})
   class TestModule {}
@@ -20,7 +19,6 @@ describe('NestContainer', () => {
 
   beforeEach(() => {
     container = new NestContainer();
-    untypedContainer = container as any;
   });
 
   it('should "addProvider" throw "UnknownModuleException" when module is not stored in collection', () => {
@@ -55,7 +53,7 @@ describe('NestContainer', () => {
 
   describe('clear', () => {
     it('should call `clear` on modules collection', () => {
-      const clearSpy = sinon.spy(untypedContainer.modules, 'clear');
+      const clearSpy = sinon.spy((container as any).modules, 'clear');
       container.clear();
       expect(clearSpy.called).to.be.true;
     });
@@ -65,7 +63,7 @@ describe('NestContainer', () => {
     it('should not add module if already exists in collection', async () => {
       const modules = new Map();
       const setSpy = sinon.spy(modules, 'set');
-      untypedContainer.modules = modules;
+      (container as any).modules = modules;
 
       await container.addModule(TestModule as any, []);
       await container.addModule(TestModule as any, []);
@@ -91,7 +89,7 @@ describe('NestContainer', () => {
 
       const modules = new Map();
       const setSpy = sinon.spy(modules, 'set');
-      untypedContainer.modules = modules;
+      (container as any).modules = modules;
 
       await container.addModule(TestModule as any, []);
       await container.replaceModule(
@@ -176,7 +174,7 @@ describe('NestContainer', () => {
     beforeEach(() => {
       token = 'token';
       collection = new Map();
-      untypedContainer.dynamicModulesMetadata = collection;
+      (container as any).dynamicModulesMetadata = collection;
     });
     describe('when dynamic metadata exists', () => {
       it('should add to the dynamic metadata collection', () => {
@@ -217,7 +215,7 @@ describe('NestContainer', () => {
   describe('get applicationConfig', () => {
     it('should return ApplicationConfig instance', () => {
       expect(container.applicationConfig).to.be.eql(
-        untypedContainer._applicationConfig,
+        (container as any)._applicationConfig,
       );
     });
   });
@@ -227,7 +225,7 @@ describe('NestContainer', () => {
       const httpAdapter = new NoopHttpAdapter({});
       container.setHttpAdapter(httpAdapter);
 
-      const internalStorage = untypedContainer.internalProvidersStorage;
+      const internalStorage = (container as any).internalProvidersStorage;
       expect(internalStorage.httpAdapter).to.be.eql(httpAdapter);
     });
   });
@@ -246,7 +244,7 @@ describe('NestContainer', () => {
     it('should register core module ref', () => {
       const ref = {} as any;
       container.registerCoreModuleRef(ref);
-      expect(untypedContainer.internalCoreModule).to.be.eql(ref);
+      expect((container as any).internalCoreModule).to.be.eql(ref);
     });
   });
 });

packages/core/test/injector/instance-wrapper.spec.ts

@@ -1,6 +1,7 @@
 import { Scope } from '@nestjs/common';
 import { expect } from 'chai';
 import * as sinon from 'sinon';
+import { createContextId } from '../../helpers';
 import { STATIC_CONTEXT } from '../../injector/constants';
 import { InstanceWrapper } from '../../injector/instance-wrapper';
 
@@ -737,6 +738,53 @@ describe('InstanceWrapper', () => {
     });
   });
 
+  describe('removeInstanceByContextId', () => {
+    describe('without inquirer', () => {
+      it('should remove instance for given context', () => {
+        const wrapper = new InstanceWrapper({
+          scope: Scope.TRANSIENT,
+        });
+
+        const contextId = createContextId();
+        wrapper.setInstanceByContextId(contextId, { instance: {} });
+
+        const existingContext = wrapper.getInstanceByContextId(contextId);
+        expect(existingContext.instance).to.be.not.undefined;
+        wrapper.removeInstanceByContextId(contextId);
+
+        const removedContext = wrapper.getInstanceByContextId(contextId);
+        expect(removedContext.instance).to.be.undefined;
+      });
+    });
+
+    describe('when transient and inquirer has been passed', () => {
+      it('should remove instance for given context', () => {
+        const wrapper = new InstanceWrapper({
+          scope: Scope.TRANSIENT,
+        });
+
+        wrapper.setInstanceByContextId(
+          STATIC_CONTEXT,
+          { instance: {} },
+          'inquirerId',
+        );
+
+        const existingContext = wrapper.getInstanceByContextId(
+          STATIC_CONTEXT,
+          'inquirerId',
+        );
+        expect(existingContext.instance).to.be.not.undefined;
+        wrapper.removeInstanceByContextId(STATIC_CONTEXT, 'inquirerId');
+
+        const removedContext = wrapper.getInstanceByContextId(
+          STATIC_CONTEXT,
+          'inquirerId',
+        );
+        expect(removedContext.instance).to.be.undefined;
+      });
+    });
+  });
+
   describe('isInRequestScope', () => {
     describe('when tree and context are not static and is not transient', () => {
       it('should return true', () => {

packages/core/test/injector/module-token-factory.spec.ts

@@ -1,48 +1,41 @@
 import { expect } from 'chai';
 import * as sinon from 'sinon';
-import { DeepHashedModuleOpaqueKeyFactory } from '../../../injector/opaque-key-factory/deep-hashed-module-opaque-key-factory';
+import { ModuleTokenFactory } from '../../injector/module-token-factory';
 
-describe('DeepHashedModuleOpaqueKeyFactory', () => {
+describe('ModuleTokenFactory', () => {
   const moduleId = 'constId';
-  let factory: DeepHashedModuleOpaqueKeyFactory;
+  let factory: ModuleTokenFactory;
 
   beforeEach(() => {
-    factory = new DeepHashedModuleOpaqueKeyFactory();
+    factory = new ModuleTokenFactory();
     sinon.stub(factory, 'getModuleId').returns(moduleId);
   });
-  describe('createForStatic', () => {
+  describe('create', () => {
     class Module {}
-
     it('should return expected token', () => {
       const type = Module;
-      const token1 = factory.createForStatic(type);
-      const token2 = factory.createForStatic(type);
+      const token1 = factory.create(type, undefined);
+      const token2 = factory.create(type, undefined);
       expect(token1).to.be.deep.eq(token2);
     });
-  });
-  describe('createForDynamic', () => {
-    class Module {}
-
     it('should include dynamic metadata', () => {
       const type = Module;
-      const token1 = factory.createForDynamic(type, {
+      const token1 = factory.create(type, {
         providers: [{}],
       } as any);
-      const token2 = factory.createForDynamic(type, {
+      const token2 = factory.create(type, {
         providers: [{}],
       } as any);
 
       expect(token1).to.be.deep.eq(token2);
     });
   });
-
   describe('getModuleName', () => {
     it('should map module metatype to name', () => {
       const metatype = () => {};
       expect(factory.getModuleName(metatype as any)).to.be.eql(metatype.name);
     });
   });
-
   describe('getStringifiedOpaqueToken', () => {
     describe('when metadata exists', () => {
       it('should return hash', () => {
@@ -87,7 +80,6 @@ describe('DeepHashedModuleOpaqueKeyFactory', () => {
         );
       });
     });
-
     describe('when metadata does not exist', () => {
       it('should return empty string', () => {
         expect(factory.getStringifiedOpaqueToken(undefined)).to.be.eql('');