fairnesscoop / permacoop

@CommandHandler(IncreaseUserSavingsRecordCommand)

export class IncreaseUserSavingsRecordCommandHandler {

  constructor(

    @Inject('IUserRepository')

    private readonly userRepository: IUserRepository,

    @Inject('IUserSavingsRecordRepository')

    private readonly userSavingsRecordRepository: IUserSavingsRecordRepository,

  ) {}

  public async execute(command: IncreaseUserSavingsRecordCommand): Promise<string> {

    const { userId, amount } = command;

    const user = await this.userRepository.findOneById(userId);

    if (!user) {

      throw new UserNotFoundException();

    }

    const userSavingsRecord = await this.userSavingsRecordRepository.save(

      new UserSavingsRecord(

        Math.round(amount * 100),

        SavingsRecordType.INPUT,

        user,

      )

    );

    return userSavingsRecord.getId();