@foblex/nestjs-mediator

An advanced mediator library for NestJS, leveraging the Command Query Responsibility Segregation (CQRS) pattern to facilitate low coupling and high cohesion within applications. Designed to streamline the execution of commands and queries, @foblex/mediator supports a clean architecture by separating the responsibility of command execution and query handling.

Features

• Implements CQRS pattern for clear separation of command and query operations.
• Facilitates low coupling and high cohesion for scalable application architecture.
• Easy integration with NestJS projects.

Installation

Install the @foblex/nestjs-mediator library via npm:

1npm install @foblex/nestjs-mediator

Usage

FMediator simplifies the handling of commands and queries within your Angular applications, ensuring a clean and maintainable architecture. Below are the steps on how to utilize FMediator in your project:

Setting up Validators and Handlers

Create your request class implementing IRequest interface.

1export class CreateProductRequest implements IRequest<void> {
2
3  constructor(
4      public name: string,
5      public description: string,
6      public price: number,
7  ) {
8  }
9}

Create a validator implementing IRequestValidator<TRequest, TResponse> interface.

1@Validator(CreateProductRequest)
2export class CreateProductValidator
3    implements IRequestValidator<CreateProductRequest, void> {
4
5  constructor(
6      @InjectModel(Product.name) private dataContext: Model<Product>
7  ) {
8  }
9
10  public async handle(payload: CreateProductRequest): Promise<void> {
11    const errors: string[] = [];
12
13    if (!payload.name) {
14      errors.push("Name is required");
15    }
16
17    if (!payload.price) {
18      errors.push("Price is required");
19    }
20
21    const product = await this.dataContext.findOne({ name: payload.name });
22    if (product) {
23      errors.push("Product already exists");
24    }
25
26    if (errors.length > 0) {
27      throw new HttpException({ errors }, 400);
28    }
29  }
30}

Create handlers extending CommandExecutable class.

1@Executable(CreateProductRequest)
2export class CreateProductHandler
3    extends CommandExecutable<CreateProductRequest, void> {
4
5  constructor(
6      @InjectModel(Product.name) private dataContext: Model<Product>
7  ) {
8    super();
9  }
10
11  public async executeAsync(payload: CreateProductRequest): Promise<void> {
12    await this.dataContext.create({ ...payload, productId: uuid() });
13  }
14}

Add your validators and handlers to the module providers.

1@Module({
2  providers: [ CreateProductValidator, CreateProductHandler ]
3})
4export class DomainModule {
5}

Configuring FMediatorModule

In your app module, import FMediatorModule and configure it using forRoot method.

1@Module({
2  imports: [
3    FMediatorModule.forRoot(),
4  ]
5})
6export class AppModule {
7}

Using FMediator Service

Inject FMediator service and use send method to send your requests.

1@Controller("account")
2export class AccountController {
3
4  constructor(
5      private mediator: FMediator
6  ) {
7  }
8
9  @Post()
10  public async create(@Body() payload: CreateAccountRequest) {
11    return this.mediator.send(CreateAccountRequest, payload);
12  }
13}

License

The code in this project is licensed under the MIT License. See the LICENSE file for details.