演示

中间件

在控制器上使用认证、权限与审计中间件;通过 @Module 的 globalFilter / globalExceptionsFilter 注册插件级全局过滤器;或用 @Middleware 编写自定义中间件。

用法

可装饰整个控制器类(全部路由)或单个方法。管理端 API 通常先认证再做权限校验。若需要对应用内每个请求生效,请在根 @Module 上使用 globalFilter。

TSXusage
1import { 2 AuditLogMiddleware, 3 AuthenticatedUserOnly, 4 CheckAPIPermission, 5 Controller, 6 Get, 7 ResponseDto, 8} from "@quan-erp/shared-backend-core"; 9 10@Controller("/admin-dashboard") 11export class AdminDashboardController { 12 @Get("/stats") 13 @AuthenticatedUserOnly() 14 @CheckAPIPermission() 15 @AuditLogMiddleware((req) => `View stats`) 16 async getStats() { 17 return ResponseDto.ok(data); 18 } 19}

内置中间件

  • @AuthenticatedUserOnly() — 未认证返回 401;用于需要登录的接口
  • @CheckAPIPermission() — 按 method + URL 校验角色允许的 API;管理端需搭配 @AuthenticatedUserOnly
  • @AuditLogMiddleware(action) — 静态字符串或 (req) => string,写入审计日志
TSXaudit
1import { 2 AuditLogMiddleware, 3 Controller, 4 Get, 5 Put, 6} from "@quan-erp/shared-backend-core"; 7 8@Controller("/branch") 9export class BranchController { 10 @AuditLogMiddleware("View all branches") 11 @Get("/") 12 async getAll() { /* … */ } 13 14 @AuditLogMiddleware((req) => `Update branch ${req.params.id}`) 15 @Put("/:id") 16 async update() { /* … */ } 17}

全局中间件(模块)

在根 @Module 上注册过滤器,使其对每个请求生效(而不仅是某个控制器)。请求用 globalFilter,异常用 globalExceptionsFilter。卸载插件时核心会自动注销。

  • globalFilter: { position, handler }[] — 应用级请求中间件
  • globalExceptionsFilter: handler[] — 应用级异常中间件(IExceptionMiddleware)
  • MiddlewarePosition.BEFORE_ROOT_ROUTE — 在插件根路由之前(认证 / 解析用户 / 日志)
  • MiddlewarePosition.AFTER_ROOT_ROUTE — 在根栈之后
  • Handler — Express RequestHandler,或实现 IExpressMiddleware / IExceptionMiddleware 的类
  • 每个类中间件必须:@MiddlewareMetadata({ plugin: metadata.name })
TSXglobalFilter on @Module
1import { 2 MiddlewareMetadata, 3 MiddlewarePosition, 4 Module, 5} from "@quan-erp/shared-backend-core"; 6import type { 7 IExceptionMiddleware, 8 IExpressMiddleware, 9} from "@quan-erp/shared-backend-core"; 10import type { NextFunction, Request, Response } from "express"; 11import metadata from "../../module.metadata.json" with { type: "json" }; 12import { MyController } from "./my.controller.js"; 13import { MyService } from "./my.service.js"; 14 15@MiddlewareMetadata({ plugin: metadata.name }) 16export class RequestIdMiddleware implements IExpressMiddleware { 17 handler(req: Request, res: Response, next: NextFunction) { 18 res.setHeader("x-request-plugin", metadata.name); 19 return next(); 20 } 21} 22 23@MiddlewareMetadata({ plugin: metadata.name }) 24export class PluginErrorFilter implements IExceptionMiddleware { 25 handler(error: Error, req: Request, res: Response, next: NextFunction) { 26 if (res.headersSent) return next(error); 27 res.status(500).json({ message: error.message }); 28 } 29} 30 31@Module({ 32 name: metadata.name, 33 providers: [MyService], 34 controllers: [MyController], 35 entities: [], 36 globalFilter: [ 37 { 38 position: MiddlewarePosition.BEFORE_ROOT_ROUTE, 39 handler: RequestIdMiddleware, 40 }, 41 ], 42 globalExceptionsFilter: [PluginErrorFilter], 43}) 44export class MyPluginModule {}

创建自定义中间件

用 Middleware(...) 封装为控制器/方法装饰器,或实现 IExpressMiddleware / IExceptionMiddleware(也可用于 globalFilter)。每个类中间件必须声明 @MiddlewareMetadata({ plugin: metadata.name }),以便核心在正确的插件 DI 作用域中解析。路由上通过 @MyDecorator() 或 @Middleware(MyClass) 应用。

  • 必须:每个实现 IExpressMiddleware / IExceptionMiddleware 的类加 @MiddlewareMetadata({ plugin: metadata.name })
  • 装饰器方式 — 工厂返回 Middleware(async (req, res, next) => { … })(函数处理器无需 MiddlewareMetadata)
  • 类方式(IExpressMiddleware)— handler(req, res, next);@Inject 无需 @Service()
  • 异常中间件(IExceptionMiddleware)— handler(error, req, res, next)
  • 中间件保持精简;业务规则尽量放在 service
TSXdecorator middleware
1import { 2 HttpStatus, 3 Middleware, 4 ResponseDto, 5} from "@quan-erp/shared-backend-core"; 6 7export function MyCustomAuth(): MethodDecorator & ClassDecorator { 8 return Middleware(async (req, res, next) => { 9 if (req.headers["x-custom-header"] === "secret-value") return next(); 10 return res 11 .status(HttpStatus.UNAUTHORIZED) 12 .json(ResponseDto.error("Unauthorized", HttpStatus.UNAUTHORIZED)); 13 }); 14}
TSXclass middleware
1import type { NextFunction, Request, Response } from "express"; 2import { 3 Controller, 4 Inject, 5 Middleware, 6 MiddlewareMetadata, 7} from "@quan-erp/shared-backend-core"; 8import type { IExpressMiddleware } from "@quan-erp/shared-backend-core"; 9import metadata from "../../module.metadata.json" with { type: "json" }; 10import { MyService } from "./my.service.js"; 11 12@MiddlewareMetadata({ plugin: metadata.name }) 13export class MyComplexMiddleware implements IExpressMiddleware { 14 @Inject(MyService) 15 private myService: MyService; 16 17 async handler(req: Request, res: Response, next: NextFunction) { 18 if (await this.myService.validate(req.body)) return next(); 19 res.status(400).send("Invalid request"); 20 } 21} 22 23@Middleware(MyComplexMiddleware) 24@Controller("/complex") 25export class ComplexController {}