NestJS 如何使用异步中间件？

Question

我使用 NestJS 框架，并且想要将多个中间件应用于我的应用程序中的路由。每个中间件都是一个实现NestMiddleware接口的类。这些中间件之一是异步的，在调用路由处理程序之前不会被消耗。有没有办法在处理路由之前解决这个中间件的承诺？

我的代码

异步中间件（page-loader.middleware）

import { Injectable, NestMiddleware } from '@nestjs/common';

@Injectable()

export class PageLoader implements NestMiddleware {

  async use(req: any, res: any, next: () => void) {
    try {
      req.body.html = await req.body.fetcher.fetch();
    } catch (error) {
      throw new Error(error);
    } finally {
      next();
    }
  }

}

控制器（创建文章.控制器）

import { Controller, Post, Body } from '@nestjs/common';
import { SaveArticleService } from './save-article.service';
import { CreateArticleDto } from './create-article.dto';

@Controller()

export class CreateArticleController {

  constructor(private readonly saveArticleService: SaveArticleService) {}

  @Post('/create')
  async create(@Body() createArticleDto: CreateArticleDto) {
    return this.saveArticleService.save(createArticleDto);
  }

}

模块（创建文章.模块）

import { Module, NestModule, MiddlewareConsumer, RequestMethod } from '@nestjs/common';
import { CreateArticleController } from './create-article.controller';
import { SaveArticleService } from './save-article.service';

// Another (sync) middleware
import { ExtensionExtractor } from './extension-extractor.middleware'; 

// The async middleware
import { PageLoader } from './page-loader.middleware';

@Module({
  controllers: [CreateArticleController],
  providers: [SaveArticleService],
})

export class CreateArticleModule implements NestModule {
  configure(consumer: MiddlewareConsumer) {
    consumer
    .apply(ExtensionExtractor, PageLoader)
    .forRoutes({ path: 'create', method: RequestMethod.POST});
  }
}

我没有包含控制器中使用的服务的片段，因为它与我的问题无关。

我尝试过的

这个问题并没有帮助我解决问题，因为中间件结构不同。我正在等待中间件方法来解决其承诺，而不是等待在中间件内部重用的输入。

这些github 问题答案并不相关，因为 NestJS API 发生了巨大的变化。

在此先感谢您的帮助！

Answer 1

您绝对可以将异步中间件与 Nest 结合使用；然而，使用该策略存在一个问题.forRoutes({path: 'path', method: method});。

我设置了一个快速中间件消费者来展示它如何在不使用RequestMethod.GET.

UserModule（包含中间件）

import { MiddlewareConsumer, Module, NestModule, RequestMethod } from '@nestjs/common';
import { UserController } from './user.controller';
import { UserService } from './user.service';

function asyncTimeout(milliseconds: number): Promise<string> {
  return new Promise((resolve, reject) => {
    setTimeout(() => resolve('DONE'), milliseconds);
  });
}

@Module({
  controllers: [UserController],
  providers: [UserService],
  exports: [UserService]
})
export class UserModule implements NestModule {
  configure(consumer: MiddlewareConsumer) {
    consumer
      .apply((req, res, next) => {
        console.log('Using forRoutes(path)');
        console.log('syncronous middleware');
        next();
      },
        (async (req, res, next) => {
          console.log('Using forRoutes(path)');
          const start = Date.now();
          const done = await asyncTimeout(5000);
          console.log(done);
          console.log('Time taken:' + (Date.now() - start));
          next();
        })
      )
      .forRoutes('/')
      .apply((req, res, next) => {
        console.log('Using forRoutes({path, method})');
        console.log('syncronous middleware');
        next();
      },
        (async (req, res, next) => {
          console.log('Using forRoutes({path, method})');
          const start = Date.now();
          const done = await asyncTimeout(5000);
          console.log(done);
          console.log('Time taken:' + (Date.now() - start));
          next();
        })
      )
      .forRoutes({path: '/', method: RequestMethod.GET});
  }
}

用户控制器（片段）

import { Controller, Get } from '@nestjs/common';
import { UserSerivce } from './user.service';

@Controller('user')
export class UserController {
  constructor(private readonly userService: UserService) {}

  @Get('/')
  testFunction() {
    return {greeting: 'hello'};
  }
}

输出

[2019-06-20 22:40:48.191] [INFO] | Listening at http://localhost:3333/api
Using forRoutes(path)
syncronous middleware
Using forRoutes(path)
DONE
Time taken:5002
[2019-06-20 22:40:57.346] [INFO] | [Nest] 30511 [Morgan] GET /api/user 200 5014.234 ms - 20

我在两种设置中使用了相同的中间件功能，但是您可以看到异步中间件在使用时按预期响应.forRoutes(path)，而在使用时则不然.forRoutes({path, method})（请原谅我的自定义记录器）。

这应该作为 GitHub 上的问题向 Kamil 提出来解决，但您的设置可以正常工作。如果您选择打开一个示例存储库，请随意使用我在此处的任何代码来设置该问题的示例存储库。