69 lines
2.4 KiB
TypeScript
69 lines
2.4 KiB
TypeScript
import { Result } from '@core/shared/domain/Result';
|
|
import type { ApplicationErrorCode } from '@core/shared/errors/ApplicationErrorCode';
|
|
import { randomUUID } from 'crypto';
|
|
import { LeagueMembership } from '../../domain/entities/LeagueMembership';
|
|
import type { LeagueMembershipRepository } from '../../domain/repositories/LeagueMembershipRepository';
|
|
import type { LeagueRepository } from '../../domain/repositories/LeagueRepository';
|
|
|
|
export interface ApproveLeagueJoinRequestInput {
|
|
leagueId: string;
|
|
joinRequestId: string;
|
|
}
|
|
|
|
export interface ApproveLeagueJoinRequestResult {
|
|
success: boolean;
|
|
message: string;
|
|
}
|
|
|
|
export class ApproveLeagueJoinRequestUseCase {
|
|
constructor(
|
|
private readonly leagueMembershipRepository: LeagueMembershipRepository,
|
|
private readonly leagueRepository: LeagueRepository,
|
|
) {}
|
|
|
|
async execute(
|
|
input: ApproveLeagueJoinRequestInput,
|
|
): Promise<
|
|
Result<
|
|
ApproveLeagueJoinRequestResult,
|
|
ApplicationErrorCode<
|
|
'JOIN_REQUEST_NOT_FOUND' | 'LEAGUE_NOT_FOUND' | 'LEAGUE_AT_CAPACITY',
|
|
{ message: string }
|
|
>
|
|
>
|
|
> {
|
|
const requests = await this.leagueMembershipRepository.getJoinRequests(input.leagueId);
|
|
const request = requests.find(r => r.id === input.joinRequestId);
|
|
if (!request) {
|
|
return Result.err({ code: 'JOIN_REQUEST_NOT_FOUND', details: { message: 'Join request not found' } });
|
|
}
|
|
|
|
const league = await this.leagueRepository.findById(input.leagueId);
|
|
if (!league) {
|
|
return Result.err({ code: 'LEAGUE_NOT_FOUND', details: { message: 'League not found' } });
|
|
}
|
|
|
|
const members = await this.leagueMembershipRepository.getLeagueMembers(input.leagueId);
|
|
const maxDrivers = league.settings.maxDrivers ?? 32;
|
|
|
|
if (members.length >= maxDrivers) {
|
|
return Result.err({ code: 'LEAGUE_AT_CAPACITY', details: { message: 'League is at capacity' } });
|
|
}
|
|
|
|
await this.leagueMembershipRepository.removeJoinRequest(input.joinRequestId);
|
|
await this.leagueMembershipRepository.saveMembership(
|
|
LeagueMembership.create({
|
|
id: randomUUID(),
|
|
leagueId: input.leagueId,
|
|
driverId: request.driverId.toString(),
|
|
role: 'member',
|
|
status: 'active',
|
|
joinedAt: new Date(),
|
|
})
|
|
);
|
|
|
|
const result: ApproveLeagueJoinRequestResult = { success: true, message: 'Join request approved.' };
|
|
|
|
return Result.ok(result);
|
|
}
|
|
} |