command-bus.ts

class CommandBus {
  constructor(private readonly handlers: CommandHandler<any>[]) {}

  public async execute(command: Command<unknown>) {
    const handler = this.handlers.find(
      (existingHandler) => existingHandler.type === command.type
    );

    if (!handler) {
      throw new Error(`Handler for command: ${command.type} does not exist.`);
    }

    return handler.execute(command);
  }
}