import { Mapper } from '@automapper/core';
import { InjectMapper } from '@automapper/nestjs';
import { CommandHandler } from '@nestjs/cqrs';
import { UserMessager } from '../../adapters/secondaries/user.messager';
import { UsersRepository } from '../../adapters/secondaries/users.repository';
import { UpdateUserCommand } from '../../commands/update-user.command';
import { UpdateUserRequest } from '../dtos/update-user.request';
import { User } from '../entities/user';

@CommandHandler(UpdateUserCommand)
export class UpdateUserUseCase {
  constructor(
    private readonly _repository: UsersRepository,
    private readonly _messager: UserMessager,
    @InjectMapper() private readonly _mapper: Mapper,
  ) {}

  async execute(command: UpdateUserCommand): Promise<User> {
    const entity = this._mapper.map(
      command.updateUserRequest,
      UpdateUserRequest,
      User,
    );

    const user = await this._repository.update(
      command.updateUserRequest.uuid,
      entity,
    );

    if (user) {
      this._messager.publish(
        'user.update',
        JSON.stringify(command.updateUserRequest),
      );
    }
    return user;
  }
}