如何从 Nest fastify 服务器中创建的中间件发送响应？

Question

我用 Fastify 创建了一个 NestJs 项目，并为它创建了一个中间件，但我不知道如何向客户端发送响应，类似于我们在 express 中可以做的，任何帮助将不胜感激，谢谢！，这是我的中间件代码：

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

@Injectable()
export class LoggerMiddleware implements NestMiddleware {
  use(req: any, res: any, next: Function) {
    console.log('Request...', res);
    // throw new HttpException('Forbidden', HttpStatus.FORBIDDEN);
    next();
  }
}

Answer 1

看起来 Fastify 抽象使用 NodeJS vanila http 对象（这里注入的 res 是 http,ServerResponse ）

// app.middleware.ts

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

@Injectable()
export class AppMiddleware implements NestMiddleware {
  use(req: IncomingMessage, res: ServerResponse, next: Function) {
    res.writeHead(200, { 'content-type': 'application/json' })
    res.write(JSON.stringify({ test: "test" }))
    res.end()
  }
}

// app.module.ts

import { Module, MiddlewareConsumer, RequestMethod } from '@nestjs/common';
import { AppController } from './app.controller';
import { AppMiddleware } from './app.middleware';

@Module({
  imports: [],
  controllers: [AppController],
  providers: [],
})
export class AppModule {
  configure(consumer: MiddlewareConsumer) {
    consumer
      .apply(AppMiddleware)
      .forRoutes({ path: '*', method: RequestMethod.ALL }); // apply on all routes
  }
}

Answer 2

使用 express

改编 Daniel 代码以在中间件验证（缓存）后终止执行的示例

import { BadRequestException, Injectable, NestMiddleware } from '@nestjs/common';
import { Request, Response, NextFunction } from 'express';

@Injectable()
export class CacheMiddleware implements NestMiddleware {

  constructor(
     private cacheService: CacheService
  ){}

  async use(req: Request, res: Response, next: NextFunction) {

    const cache = await this.cacheService.getCache(req.url)
    if(cache){
      res.writeHead(200, { 'content-type': 'application/json' })
      res.write(cache)
      res.end()
      return
    }

    next();
  }
}

如何从 Nest fastify 服务器中创建的中间件发送响应？

How to send response from middleware created in a Nest fastify server?

nestjs

fastify

nestjs-fastify