action.ts

import { Request, Response } from "express";
import { celebrate, Joi } from "celebrate";
import { CommandBus } from "@tshio/command-bus";
import { CreateUserCommand } from "../commands/create-user.command";
import { Action } from "../../../../shared/http/types";

export interface CreateUserActionDependencies {
  commandBus: CommandBus;
}

export const createUserActionValidation = celebrate(
  {
    body: Joi.object().keys({
      name: Joi.string().required(),
    }),
  },
  { abortEarly: false }
);

class CreateUserAction implements Action {
  constructor(private dependencies: CreateUserActionDependencies) {}

  async invoke({ body }: Request, res: Response) {
    const result = await this.dependencies.commandBus.execute(
      new CreateUserCommand({
        name: body.name,
      })
    );

    res.json(result);
  }
}

export default CreateUserAction;