feat(fastify): added middlewares option to forRoot of the module

Author: Stradivario

packages/fastify/src/fastify.module.ts

@@ -2,7 +2,7 @@ import { Module, ModuleWithProviders } from '@rhtml/di';
 import fastify, { FastifyInstance } from 'fastify';
 
 import { Fastify, FastifyListen, FastifyModuleOptions } from './fastify.tokens';
-import { addSchema, globalErrorHandler, pipe } from './helpers';
+import { addMiddlewares, addSchema, globalErrorHandler, pipe } from './helpers';
 
 @Module()
 export class FastifyModule {
@@ -26,7 +26,8 @@ export class FastifyModule {
 
             return pipe(
               addSchema(schemas),
-              globalErrorHandler(options.globalErrorHandler)
+              globalErrorHandler(options.globalErrorHandler),
+              addMiddlewares(options.middlewares)
             )(instance);
           },
         },

packages/fastify/src/fastify.tokens.ts

@@ -11,6 +11,8 @@ import {
   FastifySchema,
 } from 'fastify';
 
+import { Middleware } from './helpers';
+
 export const Fastify = new InjectionToken<FastifyInstance>();
 export const FastifyListen = new InjectionToken<string>();
 
@@ -33,4 +35,5 @@ export interface FastifyModuleOptions extends FastifyHttpOptions<never> {
   schemas: FastifySchema[];
   globalErrorHandler: GlobalErrorHandler;
   server: FastifyListenOptions;
+  middlewares: Middleware[];
 }

packages/fastify/src/helpers/hooks/add-middlewares.ts

@@ -0,0 +1,15 @@
+import { Reader } from '@rhtml/di';
+import { FastifyInstance } from 'fastify';
+
+export type Middleware = (instance: FastifyInstance) => FastifyInstance;
+
+export function addMiddlewares(
+  middlewares: Middleware[]
+): Reader<FastifyInstance, FastifyInstance> {
+  return (instance) => {
+    for (const middleware of middlewares) {
+      instance = middleware(instance);
+    }
+    return instance;
+  };
+}

packages/fastify/src/helpers/hooks/index.ts

@@ -1,2 +1,3 @@
 export * from './add-schema.hook';
 export * from './global-error.hook';
+export * from './add-middlewares';