refactor: refactor mediatr-js in building-blocks

src/booking/src/app.ts

@@ -9,7 +9,6 @@ import { RegisterRoutes } from './routes/routes';
 import config from 'building-blocks/config/config';
 import { collectDefaultMetrics } from 'prom-client';
 import { initialSwagger } from 'building-blocks/swagger/swagger';
-import { erroHandler } from 'building-blocks/error-handler/erro-handler';
 import { initialDbContext } from './data/db.context';
 import { initialLogger } from './extensions/logger.extensions';
 import { initialOpenTelemetry } from './extensions/otel.extensions';
@@ -19,6 +18,7 @@ import { registerMediatrHandlers } from './extensions/mediatr.extensions';
 import { httpContextMiddleware } from 'building-blocks/context/context';
 import { postgresOptions } from './data/data-source';
 import { Logger } from 'building-blocks/logging/logger';
+import {errorHandler} from "building-blocks/error-handler/error-handler";
 
 const startupApp = async () => {
   collectDefaultMetrics();
@@ -54,7 +54,7 @@ const startupApp = async () => {
 
   RegisterRoutes(app);
 
-  app.use(erroHandler);
+  app.use(errorHandler);
 
   const server = app.listen(config.port, () => {
     logger.info(`Listening to http://localhost:${config.port}`);

src/booking/src/booking/features/v1/create-booking/create-booking.ts

@@ -1,4 +1,3 @@
-import { IHandler, IRequest, mediatrJs } from 'building-blocks/mediatr-js/mediatr.js';
 import { Body, Controller, Post, Route, Security, SuccessResponse } from 'tsoa';
 import httpStatus from 'http-status';
 import Joi from 'joi';
@@ -12,6 +11,7 @@ import { IFlightClient } from '../../../http-client/services/flight/flight.clien
 import { IPassengerClient } from '../../../http-client/services/passenger/passenger.client';
 import { IPublisher } from 'building-blocks/rabbitmq/rabbitmq-publisher';
 import mapper from '../../../mappings';
+import { IRequest, IRequestHandler, mediatrJs } from 'building-blocks/mediatr-js/mediatr-js';
 
 export class CreateBooking implements IRequest<BookingDto> {
   passengerId: number;
@@ -59,7 +59,7 @@ export class CreateBookingController extends Controller {
 }
 
 @injectable()
-export class CreateBookingHandler implements IHandler<CreateBooking, BookingDto> {
+export class CreateBookingHandler implements IRequestHandler<CreateBooking, BookingDto> {
   constructor(
     @inject('IBookingRepository') private bookingRepository: IBookingRepository,
     @inject('IFlightClient') private flightClientService: IFlightClient,

src/booking/src/extensions/mediatr.extensions.ts

@@ -1,8 +1,10 @@
 import { container } from 'tsyringe';
-import { mediatrJs } from 'building-blocks/mediatr-js/mediatr.js';
-import {CreateBooking, CreateBookingHandler} from "../booking/features/v1/create-booking/create-booking";
-
+import {
+  CreateBooking,
+  CreateBookingHandler
+} from '../booking/features/v1/create-booking/create-booking';
+import { mediatrJs } from 'building-blocks/mediatr-js/mediatr-js';
 
 export const registerMediatrHandlers = () => {
-  mediatrJs.registerHandler(CreateBooking, container.resolve(CreateBookingHandler));
+  mediatrJs.registerRequestHandler(CreateBooking, container.resolve(CreateBookingHandler));
 };

src/building-blocks/context/context.d.ts

@@ -1,5 +1,5 @@
 /// <reference types="node" />
-import { IncomingHttpHeaders } from "http";
+import { IncomingHttpHeaders } from 'http';
 export declare class HttpContext {
     static request: Request;
     static response: Response;

src/building-blocks/context/context.ts

@@ -1,4 +1,4 @@
-import {IncomingHttpHeaders} from "http";
+import { IncomingHttpHeaders } from 'http';
 
 export class HttpContext {
   static request: Request;

src/building-blocks/error-handler/error-handler.d.ts

@@ -0,0 +1,2 @@
+import { ErrorRequestHandler } from 'express';
+export declare const errorHandler: ErrorRequestHandler;

src/building-blocks/error-handler/erro-handler.ts → src/building-blocks/error-handler/error-handler.ts

@@ -8,11 +8,10 @@ import UnauthorizedException from '../types/exception/unauthorized.exception';
 import ForbiddenException from '../types/exception/forbidden.exception';
 import NotFoundException from '../types/exception/not-found.exception';
 import ConflictException from '../types/exception/conflict.exception';
-import { container } from 'tsyringe';
 import { Logger } from '../logging/logger';
 import HttpClientException from '../types/exception/http-client.exception';
 
-export const erroHandler: ErrorRequestHandler = (err, req, res, next) => {
+export const errorHandler: ErrorRequestHandler = (err, req, res, next) => {
   if (err instanceof ApplicationException) {
     res.status(httpStatus.BAD_REQUEST).json(
       new ProblemDocument({

src/building-blocks/jwt/jwt.d.ts

@@ -1,2 +1,6 @@
 import * as express from 'express';
-export declare function expressAuthentication(request: express.Request, securityName: string, scopes?: string[]): Promise<any>;
+export declare function expressAuthentication(
+  request: express.Request,
+  securityName: string,
+  scopes?: string[]
+): Promise<any>;

src/building-blocks/logging/logger.d.ts

@@ -1,15 +1,15 @@
 export interface ILogger {
-    debug(message: string): void;
-    error(message: string | Error): void;
-    info(message: string): void;
+  debug(message: string): void;
+  error(message: string | Error): void;
+  info(message: string): void;
 }
 export declare class Logger implements ILogger {
-    private static logger;
-    constructor();
-    debug(message: string): void;
-    static debug(message: string): void;
-    info(message: string): void;
-    static info(message: string): void;
-    error(message: string | Error): void;
-    static error(message: string | Error): void;
+  private static logger;
+  constructor();
+  debug(message: string): void;
+  static debug(message: string): void;
+  info(message: string): void;
+  static info(message: string): void;
+  error(message: string | Error): void;
+  static error(message: string | Error): void;
 }