feat: ability to register per request middlewares

packages/@wroud/flow-middleware/src/FlowMiddleware.ts

@@ -30,8 +30,8 @@ export class FlowMiddleware<Data = Record<string, any>>
     initialData: Data = {} as Data,
   ): IMiddlewareRequest<Data> {
     return new MiddlewareRequest<Data>(
-      this.middlewares,
-      this.errorMiddlewares,
+      [...this.middlewares],
+      [...this.errorMiddlewares],
       initialData,
       this.logger,
     );

packages/@wroud/flow-middleware/src/MiddlewareRequest.ts

@@ -36,6 +36,16 @@ export class MiddlewareRequest<Data = Record<string, any>>
     this.isDisposed = false;
   }
 
+  public use(...middleware: IMiddleware<Data>[]): this {
+    this.middlewares.push(...middleware);
+    return this;
+  }
+
+  public error(...errorMiddleware: IErrorMiddleware<Data>[]): this {
+    this.errorMiddlewares.push(...errorMiddleware);
+    return this;
+  }
+
   public async execute(): Promise<void> {
     if (this.isDisposed) {
       throw new Error("Cannot execute a disposed request.");

packages/@wroud/flow-middleware/src/interfaces/IFlowMiddleware.ts

@@ -1,10 +1,7 @@
-import type { IErrorMiddleware } from "./IErrorMiddleware.js";
-import type { IMiddleware } from "./IMiddleware.js";
+import type { IMiddlewareContainer } from "./IMiddlewareContainer.js";
 import type { IMiddlewareRequest } from "./IMiddlewareRequest.js";
 
-export interface IFlowMiddleware<Data = Record<string, any>> {
-  use(...middleware: IMiddleware<Data>[]): this;
-  error(...errorMiddleware: IErrorMiddleware<Data>[]): this;
-
+export interface IFlowMiddleware<Data = Record<string, any>>
+  extends IMiddlewareContainer<Data> {
   createRequest(initialData?: Data): IMiddlewareRequest<Data>;
 }

packages/@wroud/flow-middleware/src/interfaces/IMiddlewareContainer.ts

@@ -0,0 +1,7 @@
+import type { IErrorMiddleware } from "./IErrorMiddleware.js";
+import type { IMiddleware } from "./IMiddleware.js";
+
+export interface IMiddlewareContainer<Data = Record<string, any>> {
+  use(...middleware: IMiddleware<Data>[]): this;
+  error(...errorMiddleware: IErrorMiddleware<Data>[]): this;
+}

packages/@wroud/flow-middleware/src/interfaces/IMiddlewareRequest.ts

@@ -1,4 +1,7 @@
-export interface IMiddlewareRequest<Data = Record<string, any>> {
+import type { IMiddlewareContainer } from "./IMiddlewareContainer.js";
+
+export interface IMiddlewareRequest<Data = Record<string, any>>
+  extends IMiddlewareContainer<Data> {
   execute(): Promise<void>;
   dispose(): void;
 }