import type { ILeagueMembershipRepository } from '../../domain/repositories/ILeagueMembershipRepository';
import type { IDriverRepository } from '../../domain/repositories/IDriverRepository';
import type { AsyncUseCase } from '@core/shared/application';
import { Result } from '@core/shared/result/Result';
import type { GetLeagueJoinRequestsUseCaseParams } from '../dto/GetLeagueJoinRequestsUseCaseParams';
import type { GetLeagueJoinRequestsResultDTO } from '../dto/GetLeagueJoinRequestsResultDTO';

export class GetLeagueJoinRequestsUseCase implements AsyncUseCase<GetLeagueJoinRequestsUseCaseParams, Result<GetLeagueJoinRequestsResultDTO, never>> {
  constructor(
    private readonly leagueMembershipRepository: ILeagueMembershipRepository,
    private readonly driverRepository: IDriverRepository,
  ) {}

  async execute(params: GetLeagueJoinRequestsUseCaseParams): Promise<Result<GetLeagueJoinRequestsResultDTO, never>> {
    const joinRequests = await this.leagueMembershipRepository.getJoinRequests(params.leagueId);
    const driverIds = [...new Set(joinRequests.map(r => r.driverId))];
    const drivers = await Promise.all(driverIds.map(id => this.driverRepository.findById(id)));
    const driverMap = new Map(drivers.filter(d => d !== null).map(d => [d!.id, { id: d!.id, name: d!.name }]));
    const enrichedJoinRequests = joinRequests.map(request => ({
      ...request,
      driver: driverMap.get(request.driverId)!,
    }));
    return Result.ok({
      joinRequests: enrichedJoinRequests,
    });
  }
}