refactor: refactor mediatr-js in building-blocks

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

@@ -6,5 +6,5 @@ import {
 import { mediatrJs } from 'building-blocks/mediatr-js/mediatr-js';
 
 export const registerMediatrHandlers = () => {
-  mediatrJs.registerRequestHandler(CreateBooking, container.resolve(CreateBookingHandler));
+  mediatrJs.registerRequestHandler(new CreateBooking(), container.resolve(CreateBookingHandler));
 };

src/building-blocks/.eslintrc

@@ -10,6 +10,7 @@
   },
   "rules": {
     "@typescript-eslint/no-explicit-any": "off",
-    "@typescript-eslint/no-var-requires": "off"
+    "@typescript-eslint/no-var-requires": "off",
+    "@typescript-eslint/no-empty-interface": "off"
   }
 }

src/building-blocks/mediatr-js/mediatr-js.d.ts

@@ -5,7 +5,7 @@ export interface IRequest<TResponse> {
 }
 declare class MediatrJs {
     private requestHandlersRegistrations;
-    registerRequestHandler<TRequest, TResponse>(request: new () => TRequest, handler: any): void;
+    registerRequestHandler<TRequest, TResponse>(request: TRequest, handler: any): void;
     send<TResponse>(request: IRequest<TResponse>): Promise<TResponse>;
     private GetTypeName;
 }

src/building-blocks/mediatr-js/mediatr-js.ts

@@ -1,14 +1,12 @@
 export interface IRequestHandler<TRequest, TResponse> {
   handle(request: TRequest): Promise<TResponse>;
 }
-
-// eslint-disable-next-line @typescript-eslint/no-empty-interface
 export interface IRequest<TResponse> {}
 
 class MediatrJs {
   private requestHandlersRegistrations: Record<string, any> = {};
 
-  registerRequestHandler<TRequest, TResponse>(request: new () => TRequest, handler: any) {
+  registerRequestHandler<TRequest, TResponse>(request: TRequest, handler: any) {
     const requestTypeName = this.GetTypeName(request);
 
     this.requestHandlersRegistrations[requestTypeName] = handler;
@@ -28,7 +26,7 @@ class MediatrJs {
   }
 
   private GetTypeName(request: any): string {
-    return request?.name ?? request.constructor.name;
+    return request.constructor.name;
   }
 }
 

src/flight/src/extensions/mediatr.extensions.ts

@@ -24,11 +24,14 @@ import {
 import { mediatrJs } from 'building-blocks/mediatr-js/mediatr-js';
 
 export const registerMediatrHandlers = () => {
-  mediatrJs.registerRequestHandler(CreateAircraft, container.resolve(CreateAircraftHandler));
-  mediatrJs.registerRequestHandler(CreateAirport, container.resolve(CreateAirportHandler));
-  mediatrJs.registerRequestHandler(CreateFlight, container.resolve(CreateFlightHandler));
-  mediatrJs.registerRequestHandler(GetFlightById, container.resolve(GetFlightByIdHandler));
-  mediatrJs.registerRequestHandler(CreateSeat, container.resolve(CreateSeatHandler));
-  mediatrJs.registerRequestHandler(ReserveSeat, container.resolve(ReserveSeatHandler));
-  mediatrJs.registerRequestHandler(GetAvailableSeats, container.resolve(GetAvailableSeatsHandler));
+  mediatrJs.registerRequestHandler(new CreateAircraft(), container.resolve(CreateAircraftHandler));
+  mediatrJs.registerRequestHandler(new CreateAirport(), container.resolve(CreateAirportHandler));
+  mediatrJs.registerRequestHandler(new CreateFlight(), container.resolve(CreateFlightHandler));
+  mediatrJs.registerRequestHandler(new GetFlightById(), container.resolve(GetFlightByIdHandler));
+  mediatrJs.registerRequestHandler(new CreateSeat(), container.resolve(CreateSeatHandler));
+  mediatrJs.registerRequestHandler(new ReserveSeat(), container.resolve(ReserveSeatHandler));
+  mediatrJs.registerRequestHandler(
+    new GetAvailableSeats(),
+    container.resolve(GetAvailableSeatsHandler)
+  );
 };

src/identity/src/extensions/mediatr.extensions.ts

@@ -18,17 +18,17 @@ import {
   ValidateTokenHandler
 } from '../auth/features/v1/validate-token/validate-token';
 import { RefreshToken, RefreshTokenHandler } from '../auth/features/v1/refresh-token/refresh-token';
-import {mediatrJs} from "building-blocks/mediatr-js/mediatr-js";
+import { mediatrJs } from 'building-blocks/mediatr-js/mediatr-js';
 
 export const registerMediatrHandlers = () => {
-  mediatrJs.registerRequestHandler(CreateUser, container.resolve(CreateUserHandler));
-  mediatrJs.registerRequestHandler(DeleteUserById, container.resolve(DeleteUserByIdHandler));
-  mediatrJs.registerRequestHandler(GetUserById, container.resolve(GetUserByIdHandler));
-  mediatrJs.registerRequestHandler(GetUsers, container.resolve(GetUsersHandler));
-  mediatrJs.registerRequestHandler(UpdateUser, container.resolve(UpdateUserHandler));
-  mediatrJs.registerRequestHandler(GenerateToken, container.resolve(GenerateTokenHandler));
-  mediatrJs.registerRequestHandler(ValidateToken, container.resolve(ValidateTokenHandler));
-  mediatrJs.registerRequestHandler(Login, container.resolve(LoginHandler));
-  mediatrJs.registerRequestHandler(Logout, container.resolve(LogoutHandler));
-  mediatrJs.registerRequestHandler(RefreshToken, container.resolve(RefreshTokenHandler));
+  mediatrJs.registerRequestHandler(new CreateUser(), container.resolve(CreateUserHandler));
+  mediatrJs.registerRequestHandler(new DeleteUserById(), container.resolve(DeleteUserByIdHandler));
+  mediatrJs.registerRequestHandler(new GetUserById(), container.resolve(GetUserByIdHandler));
+  mediatrJs.registerRequestHandler(new GetUsers(), container.resolve(GetUsersHandler));
+  mediatrJs.registerRequestHandler(new UpdateUser(), container.resolve(UpdateUserHandler));
+  mediatrJs.registerRequestHandler(new GenerateToken(), container.resolve(GenerateTokenHandler));
+  mediatrJs.registerRequestHandler(new ValidateToken(), container.resolve(ValidateTokenHandler));
+  mediatrJs.registerRequestHandler(new Login(), container.resolve(LoginHandler));
+  mediatrJs.registerRequestHandler(new Logout(), container.resolve(LogoutHandler));
+  mediatrJs.registerRequestHandler(new RefreshToken(), container.resolve(RefreshTokenHandler));
 };

src/identity/test/integration-test/user/features/create-user.test.ts

@@ -1,9 +1,9 @@
 import 'reflect-metadata';
 import { UserCreated } from 'building-blocks/contracts/identity.contract';
-import {Fixture, IntegrationTestFixture} from "../../../shared/fixtures/integration-test.fixture";
-import {UserDto} from "../../../../src/user/dtos/user.dto";
-import {FakeCreateUser} from "../../../shared/fakes/user/fake-create-user";
-import {mediatrJs} from "building-blocks/mediatr-js/mediatr-js";
+import { Fixture, IntegrationTestFixture } from '../../../shared/fixtures/integration-test.fixture';
+import { UserDto } from '../../../../src/user/dtos/user.dto';
+import { FakeCreateUser } from '../../../shared/fakes/user/fake-create-user';
+import { mediatrJs } from 'building-blocks/mediatr-js/mediatr-js';
 
 describe('integration test for create user', () => {
   const integrationTestFixture = new IntegrationTestFixture();

src/passenger/src/extensions/mediatr.extensions.ts

@@ -1,13 +1,18 @@
-import {container} from "tsyringe";
+import { container } from 'tsyringe';
 import {
   GetPassengerById,
   GetPassengerByIdHandler
-} from "../passenger/features/v1/get-passenger-by-id/get-passenger-by-id";
-import {GetPassengers, GetPassengersHandler} from "../passenger/features/v1/get-passengers/get-passengers";
-import {mediatrJs} from "building-blocks/mediatr-js/mediatr-js";
-
+} from '../passenger/features/v1/get-passenger-by-id/get-passenger-by-id';
+import {
+  GetPassengers,
+  GetPassengersHandler
+} from '../passenger/features/v1/get-passengers/get-passengers';
+import { mediatrJs } from 'building-blocks/mediatr-js/mediatr-js';
 
 export const registerMediatrHandlers = () => {
-    mediatrJs.registerRequestHandler(GetPassengerById, container.resolve(GetPassengerByIdHandler));
-    mediatrJs.registerRequestHandler(GetPassengers, container.resolve(GetPassengersHandler));
+  mediatrJs.registerRequestHandler(
+    new GetPassengerById(),
+    container.resolve(GetPassengerByIdHandler)
+  );
+  mediatrJs.registerRequestHandler(new GetPassengers(), container.resolve(GetPassengersHandler));
 };