fairnesscoop / permacoop

@QueryHandler(GetUsersSavingsRecordsBalanceQuery)

export class GetUsersSavingsRecordsBalanceQueryHandler {

  constructor(

    @Inject('IUserSavingsRecordRepository')

    private readonly userSavingsRecordRepository: IUserSavingsRecordRepository,

    private readonly getUserSavingsRecordBalance: GetUserSavingsRecordBalance,

  ) {}

  public async execute(

    query: GetUsersSavingsRecordsBalanceQuery

  ): Promise<UserSavingsRecordsBalanceView[]> {

    const userSavingsRecords = await this.userSavingsRecordRepository.findUsersSavingsRecords();

    const userSavingsRecordsBalances: UserSavingsRecordsBalanceView[] = [];

    const usersBalances = this.getUserSavingsRecordBalance.get(userSavingsRecords);

    for (const [userId, {firstName, lastName, balance}] of Object.entries(usersBalances)) {

      userSavingsRecordsBalances.push(

        new UserSavingsRecordsBalanceView(

          userId,

          firstName,

          lastName,

          balance / 100,

        )

      );

    };

    return userSavingsRecordsBalances;