website refactor
This commit is contained in:
@@ -1,3 +1,4 @@
|
||||
import { injectable } from 'inversify';
|
||||
import { AdminApiClient } from '@/lib/api/admin/AdminApiClient';
|
||||
import type { UserDto, DashboardStats, UserListResponse } from '@/lib/types/admin';
|
||||
import { Result } from '@/lib/contracts/Result';
|
||||
@@ -14,6 +15,7 @@ import { getWebsiteServerEnv } from '@/lib/config/env';
|
||||
* All client-side presentation logic must be handled by presenters/templates.
|
||||
* @server-safe
|
||||
*/
|
||||
@injectable()
|
||||
export class AdminService implements Service {
|
||||
private apiClient: AdminApiClient;
|
||||
|
||||
|
||||
@@ -1,3 +1,4 @@
|
||||
import { injectable } from 'inversify';
|
||||
import { DashboardApiClient } from '@/lib/api/dashboard/DashboardApiClient';
|
||||
import { DashboardOverviewDTO } from '@/lib/types/generated/DashboardOverviewDTO';
|
||||
import { Result } from '@/lib/contracts/Result';
|
||||
@@ -13,6 +14,7 @@ import { getWebsiteApiBaseUrl } from '@/lib/config/apiBaseUrl';
|
||||
* Pure service that creates its own API client and returns Result types.
|
||||
* No business logic, only data fetching and error mapping.
|
||||
*/
|
||||
@injectable()
|
||||
export class DashboardService implements Service {
|
||||
private apiClient: DashboardApiClient;
|
||||
|
||||
|
||||
@@ -1,3 +1,4 @@
|
||||
import { injectable, unmanaged } from 'inversify';
|
||||
import { AuthApiClient } from '@/lib/api/auth/AuthApiClient';
|
||||
import { Result } from '@/lib/contracts/Result';
|
||||
import { DomainError, Service } from '@/lib/contracts/services/Service';
|
||||
@@ -18,10 +19,11 @@ import { SessionViewModel } from '@/lib/view-models/SessionViewModel';
|
||||
* Orchestrates authentication operations.
|
||||
* Returns raw API DTOs. No ViewModels or UX logic.
|
||||
*/
|
||||
@injectable()
|
||||
export class AuthService implements Service {
|
||||
private apiClient: AuthApiClient;
|
||||
|
||||
constructor(apiClient?: AuthApiClient) {
|
||||
constructor(@unmanaged() apiClient?: AuthApiClient) {
|
||||
if (apiClient) {
|
||||
this.apiClient = apiClient;
|
||||
} else {
|
||||
@@ -36,30 +38,30 @@ export class AuthService implements Service {
|
||||
}
|
||||
}
|
||||
|
||||
async login(params: LoginParamsDTO): Promise<any> {
|
||||
async login(params: LoginParamsDTO): Promise<Result<SessionViewModel, DomainError>> {
|
||||
try {
|
||||
const dto = await this.apiClient.login(params);
|
||||
return new SessionViewModel(dto.user);
|
||||
return Result.ok(new SessionViewModel(dto.user));
|
||||
} catch (error: unknown) {
|
||||
throw error;
|
||||
return Result.err({ type: 'unauthorized', message: (error as Error).message || 'Login failed' });
|
||||
}
|
||||
}
|
||||
|
||||
async signup(params: SignupParamsDTO): Promise<any> {
|
||||
async signup(params: SignupParamsDTO): Promise<Result<SessionViewModel, DomainError>> {
|
||||
try {
|
||||
const dto = await this.apiClient.signup(params);
|
||||
return new SessionViewModel(dto.user);
|
||||
return Result.ok(new SessionViewModel(dto.user));
|
||||
} catch (error: unknown) {
|
||||
throw error;
|
||||
return Result.err({ type: 'validation', message: (error as Error).message || 'Signup failed' });
|
||||
}
|
||||
}
|
||||
|
||||
async logout(): Promise<any> {
|
||||
async logout(): Promise<Result<void, DomainError>> {
|
||||
try {
|
||||
await this.apiClient.logout();
|
||||
return Result.ok(undefined);
|
||||
} catch (error: unknown) {
|
||||
throw error;
|
||||
return Result.err({ type: 'serverError', message: (error as Error).message || 'Logout failed' });
|
||||
}
|
||||
}
|
||||
|
||||
@@ -81,12 +83,12 @@ export class AuthService implements Service {
|
||||
}
|
||||
}
|
||||
|
||||
async getSession(): Promise<any> {
|
||||
async getSession(): Promise<Result<any, DomainError>> {
|
||||
try {
|
||||
const dto = await this.apiClient.getSession();
|
||||
return dto;
|
||||
return Result.ok(dto);
|
||||
} catch (error: unknown) {
|
||||
throw error;
|
||||
return Result.err({ type: 'serverError', message: (error as Error).message || 'Failed to get session' });
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -1,3 +1,4 @@
|
||||
import { injectable, unmanaged } from 'inversify';
|
||||
import { Result } from '@/lib/contracts/Result';
|
||||
import { DomainError, Service } from '@/lib/contracts/services/Service';
|
||||
import { AuthService } from './AuthService';
|
||||
@@ -10,25 +11,26 @@ import { SessionViewModel } from '@/lib/view-models/SessionViewModel';
|
||||
* Orchestrates session-related operations.
|
||||
* Returns raw API DTOs. No ViewModels or UX logic.
|
||||
*/
|
||||
@injectable()
|
||||
export class SessionService implements Service {
|
||||
private authService: AuthService;
|
||||
|
||||
constructor(apiClient?: any) {
|
||||
constructor(@unmanaged() apiClient?: any) {
|
||||
this.authService = new AuthService(apiClient);
|
||||
}
|
||||
|
||||
/**
|
||||
* Get current user session
|
||||
*/
|
||||
async getSession(): Promise<any> {
|
||||
async getSession(): Promise<Result<SessionViewModel | null, DomainError>> {
|
||||
try {
|
||||
const res = await this.authService.getSession();
|
||||
if (!res) return null;
|
||||
if (!res) return Result.ok(null);
|
||||
const data = (res as any).value || res;
|
||||
if (!data || !data.user) return null;
|
||||
return new SessionViewModel(data.user);
|
||||
if (!data || !data.user) return Result.ok(null);
|
||||
return Result.ok(new SessionViewModel(data.user));
|
||||
} catch (error: unknown) {
|
||||
throw error;
|
||||
return Result.err({ type: 'serverError', message: (error as Error).message || 'Failed to get session' });
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1,3 +1,4 @@
|
||||
import { injectable, unmanaged } from 'inversify';
|
||||
import { DriversApiClient } from '@/lib/api/drivers/DriversApiClient';
|
||||
import type { CompleteOnboardingInputDTO } from '@/lib/types/generated/CompleteOnboardingInputDTO';
|
||||
import type { GetDriverOutputDTO } from '@/lib/types/generated/GetDriverOutputDTO';
|
||||
@@ -19,10 +20,11 @@ import { CompleteOnboardingViewModel } from '@/lib/view-models/CompleteOnboardin
|
||||
* Returns raw API DTOs. No ViewModels or UX logic.
|
||||
* All client-side presentation logic must be handled by hooks/components.
|
||||
*/
|
||||
@injectable()
|
||||
export class DriverService implements Service {
|
||||
private readonly apiClient: DriversApiClient;
|
||||
|
||||
constructor(apiClient?: DriversApiClient) {
|
||||
constructor(@unmanaged() apiClient?: DriversApiClient) {
|
||||
if (apiClient) {
|
||||
this.apiClient = apiClient;
|
||||
} else {
|
||||
|
||||
@@ -1,3 +1,4 @@
|
||||
import { injectable, unmanaged } from 'inversify';
|
||||
import { Result } from '@/lib/contracts/Result';
|
||||
import { DomainError, Service } from '@/lib/contracts/services/Service';
|
||||
import { RacesApiClient } from '@/lib/api/races/RacesApiClient';
|
||||
@@ -16,13 +17,18 @@ import { HomeDiscoveryViewModel } from '@/lib/view-models/HomeDiscoveryViewModel
|
||||
* Returns raw API DTOs. No ViewModels or UX logic.
|
||||
* All client-side presentation logic must be handled by hooks/components.
|
||||
*/
|
||||
@injectable()
|
||||
export class LandingService implements Service {
|
||||
private racesApi: RacesApiClient;
|
||||
private leaguesApi: LeaguesApiClient;
|
||||
private teamsApi: TeamsApiClient;
|
||||
private authApi: AuthApiClient;
|
||||
|
||||
constructor(racesApi?: RacesApiClient, leaguesApi?: LeaguesApiClient, teamsApi?: TeamsApiClient) {
|
||||
constructor(
|
||||
@unmanaged() racesApi?: RacesApiClient,
|
||||
@unmanaged() leaguesApi?: LeaguesApiClient,
|
||||
@unmanaged() teamsApi?: TeamsApiClient
|
||||
) {
|
||||
const baseUrl = getWebsiteApiBaseUrl();
|
||||
const logger = new ConsoleLogger();
|
||||
const errorReporter = new EnhancedErrorReporter(logger, {
|
||||
|
||||
@@ -1,3 +1,4 @@
|
||||
import { injectable, unmanaged } from 'inversify';
|
||||
import { LeaguesApiClient } from '@/lib/api/leagues/LeaguesApiClient';
|
||||
import { getWebsiteApiBaseUrl } from '@/lib/config/apiBaseUrl';
|
||||
import { Result } from '@/lib/contracts/Result';
|
||||
@@ -15,12 +16,13 @@ export interface LeagueRosterAdminData {
|
||||
joinRequests: LeagueRosterJoinRequestDTO[];
|
||||
}
|
||||
|
||||
@injectable()
|
||||
export class LeagueMembershipService implements Service {
|
||||
private apiClient: LeaguesApiClient;
|
||||
// eslint-disable-next-line @typescript-eslint/no-explicit-any
|
||||
private static cachedMemberships = new Map<string, any[]>();
|
||||
|
||||
constructor(apiClient?: LeaguesApiClient) {
|
||||
constructor(@unmanaged() apiClient?: LeaguesApiClient) {
|
||||
if (apiClient) {
|
||||
this.apiClient = apiClient;
|
||||
} else {
|
||||
|
||||
@@ -1,3 +1,4 @@
|
||||
import { injectable, unmanaged } from 'inversify';
|
||||
import { LeaguesApiClient } from "@/lib/api/leagues/LeaguesApiClient";
|
||||
import { DriversApiClient } from "@/lib/api/drivers/DriversApiClient";
|
||||
import { SponsorsApiClient } from "@/lib/api/sponsors/SponsorsApiClient";
|
||||
@@ -16,6 +17,10 @@ import type { LeagueScheduleRaceMutationSuccessDTO } from '@/lib/types/generated
|
||||
import type { LeagueSeasonSchedulePublishOutputDTO } from '@/lib/types/generated/LeagueSeasonSchedulePublishOutputDTO';
|
||||
import type { LeagueRosterMemberDTO } from '@/lib/types/generated/LeagueRosterMemberDTO';
|
||||
import type { LeagueMembershipsDTO } from '@/lib/types/generated/LeagueMembershipsDTO';
|
||||
import type { GetTeamDetailsOutputDTO } from '@/lib/types/generated/GetTeamDetailsOutputDTO';
|
||||
import { TeamMemberViewModel } from '@/lib/view-models/TeamMemberViewModel';
|
||||
import { TeamSummaryViewModel } from '@/lib/view-models/TeamSummaryViewModel';
|
||||
import { TeamDetailsViewModel } from '@/lib/view-models/TeamDetailsViewModel';
|
||||
import { Result } from '@/lib/contracts/Result';
|
||||
import { DomainError, Service } from '@/lib/contracts/services/Service';
|
||||
import { ConsoleLogger } from '@/lib/infrastructure/logging/ConsoleLogger';
|
||||
@@ -50,13 +55,14 @@ export interface LeagueDetailData {
|
||||
* All client-side presentation logic must be handled by hooks/components.
|
||||
* @server-safe
|
||||
*/
|
||||
@injectable()
|
||||
export class LeagueService implements Service {
|
||||
private apiClient: LeaguesApiClient;
|
||||
private driversApiClient?: DriversApiClient;
|
||||
private sponsorsApiClient?: SponsorsApiClient;
|
||||
private racesApiClient?: RacesApiClient;
|
||||
|
||||
constructor(apiClient?: LeaguesApiClient) {
|
||||
constructor(@unmanaged() apiClient?: LeaguesApiClient) {
|
||||
if (apiClient) {
|
||||
this.apiClient = apiClient;
|
||||
} else {
|
||||
|
||||
@@ -1,3 +1,4 @@
|
||||
import { injectable, unmanaged } from 'inversify';
|
||||
import { Result } from '@/lib/contracts/Result';
|
||||
import { Service, type DomainError } from '@/lib/contracts/services/Service';
|
||||
import { type LeagueSettingsApiDto } from '@/lib/types/tbd/LeagueSettingsApiDto';
|
||||
@@ -5,12 +6,13 @@ import { LeaguesApiClient } from '@/lib/api/leagues/LeaguesApiClient';
|
||||
import { DriversApiClient } from '@/lib/api/drivers/DriversApiClient';
|
||||
import { LeagueSettingsViewModel } from '@/lib/view-models/LeagueSettingsViewModel';
|
||||
|
||||
@injectable()
|
||||
export class LeagueSettingsService implements Service {
|
||||
private static cachedMemberships = new Map<string, unknown[]>();
|
||||
|
||||
constructor(
|
||||
private readonly leaguesApiClient?: LeaguesApiClient,
|
||||
private readonly driversApiClient?: DriversApiClient,
|
||||
@unmanaged() private readonly leaguesApiClient?: LeaguesApiClient,
|
||||
@unmanaged() private readonly driversApiClient?: DriversApiClient,
|
||||
) {}
|
||||
|
||||
async getLeagueSettings(leagueId: string): Promise<LeagueSettingsViewModel | null> {
|
||||
|
||||
@@ -1,3 +1,4 @@
|
||||
import { injectable, unmanaged } from 'inversify';
|
||||
import { Result } from '@/lib/contracts/Result';
|
||||
import { Service, type DomainError } from '@/lib/contracts/services/Service';
|
||||
import { type StewardingApiDto } from '@/lib/types/tbd/StewardingApiDto';
|
||||
@@ -8,13 +9,14 @@ import { DriverService } from '../drivers/DriverService';
|
||||
import { LeagueMembershipService } from './LeagueMembershipService';
|
||||
import { LeagueStewardingViewModel } from '@/lib/view-models/LeagueStewardingViewModel';
|
||||
|
||||
@injectable()
|
||||
export class LeagueStewardingService implements Service {
|
||||
constructor(
|
||||
private readonly raceService?: RaceService,
|
||||
private readonly protestService?: ProtestService,
|
||||
private readonly penaltyService?: PenaltyService,
|
||||
private readonly driverService?: DriverService,
|
||||
private readonly leagueMembershipService?: LeagueMembershipService,
|
||||
@unmanaged() private readonly raceService?: RaceService,
|
||||
@unmanaged() private readonly protestService?: ProtestService,
|
||||
@unmanaged() private readonly penaltyService?: PenaltyService,
|
||||
@unmanaged() private readonly driverService?: DriverService,
|
||||
@unmanaged() private readonly leagueMembershipService?: LeagueMembershipService,
|
||||
) {}
|
||||
|
||||
async getLeagueStewardingData(leagueId: string): Promise<LeagueStewardingViewModel> {
|
||||
|
||||
@@ -1,10 +1,12 @@
|
||||
import { injectable, unmanaged } from 'inversify';
|
||||
import { Result } from '@/lib/contracts/Result';
|
||||
import { Service, DomainError } from '@/lib/contracts/services/Service';
|
||||
import { LeagueWalletApiDto } from '@/lib/types/tbd/LeagueWalletApiDto';
|
||||
import { WalletsApiClient } from '@/lib/api/wallets/WalletsApiClient';
|
||||
|
||||
@injectable()
|
||||
export class LeagueWalletService implements Service {
|
||||
constructor(private readonly apiClient?: WalletsApiClient) {}
|
||||
constructor(@unmanaged() private readonly apiClient?: WalletsApiClient) {}
|
||||
|
||||
async getWalletForLeague(leagueId: string): Promise<LeagueWalletApiDto> {
|
||||
if (this.apiClient) {
|
||||
|
||||
@@ -1,3 +1,4 @@
|
||||
import { injectable, unmanaged } from 'inversify';
|
||||
import { PenaltiesApiClient } from '@/lib/api/penalties/PenaltiesApiClient';
|
||||
import type { PenaltyTypesReferenceDTO } from '@/lib/types/PenaltyTypesReferenceDTO';
|
||||
import { Result } from '@/lib/contracts/Result';
|
||||
@@ -12,10 +13,11 @@ import { EnhancedErrorReporter } from '@/lib/infrastructure/EnhancedErrorReporte
|
||||
* Orchestrates penalty operations by coordinating API calls and view model creation.
|
||||
* All dependencies are injected via constructor.
|
||||
*/
|
||||
@injectable()
|
||||
export class PenaltyService implements Service {
|
||||
private readonly apiClient: PenaltiesApiClient;
|
||||
|
||||
constructor(apiClient?: PenaltiesApiClient) {
|
||||
constructor(@unmanaged() apiClient?: PenaltiesApiClient) {
|
||||
if (apiClient) {
|
||||
this.apiClient = apiClient;
|
||||
} else {
|
||||
|
||||
@@ -1,3 +1,4 @@
|
||||
import { injectable } from 'inversify';
|
||||
import { PolicyApiClient, type FeatureState, type PolicySnapshotDto } from '@/lib/api/policy/PolicyApiClient';
|
||||
import { Result } from '@/lib/contracts/Result';
|
||||
import { DomainError, Service } from '@/lib/contracts/services/Service';
|
||||
@@ -13,6 +14,7 @@ export interface CapabilityEvaluationResult {
|
||||
shouldShowComingSoon: boolean;
|
||||
}
|
||||
|
||||
@injectable()
|
||||
export class PolicyService implements Service {
|
||||
private readonly apiClient: PolicyApiClient;
|
||||
|
||||
|
||||
@@ -1,3 +1,4 @@
|
||||
import { injectable, unmanaged } from 'inversify';
|
||||
import { ProtestsApiClient } from '@/lib/api/protests/ProtestsApiClient';
|
||||
import type { ApplyPenaltyCommandDTO } from '@/lib/types/generated/ApplyPenaltyCommandDTO';
|
||||
import type { RequestProtestDefenseCommandDTO } from '@/lib/types/generated/RequestProtestDefenseCommandDTO';
|
||||
@@ -18,10 +19,11 @@ import { ProtestDriverViewModel } from '@/lib/view-models/ProtestDriverViewModel
|
||||
* All client-side presentation logic must be handled by hooks/components.
|
||||
* @server-safe
|
||||
*/
|
||||
@injectable()
|
||||
export class ProtestService implements Service {
|
||||
private readonly apiClient: ProtestsApiClient;
|
||||
|
||||
constructor(apiClient?: ProtestsApiClient) {
|
||||
constructor(@unmanaged() apiClient?: ProtestsApiClient) {
|
||||
if (apiClient) {
|
||||
this.apiClient = apiClient;
|
||||
} else {
|
||||
|
||||
@@ -1,3 +1,4 @@
|
||||
import { injectable, unmanaged } from 'inversify';
|
||||
import { RacesApiClient } from '@/lib/api/races/RacesApiClient';
|
||||
import { Result } from '@/lib/contracts/Result';
|
||||
import { DomainError, Service } from '@/lib/contracts/services/Service';
|
||||
@@ -15,10 +16,11 @@ import { ImportRaceResultsSummaryViewModel } from '@/lib/view-models/ImportRaceR
|
||||
* Orchestration service for race results operations.
|
||||
* Returns raw API DTOs. No ViewModels or UX logic.
|
||||
*/
|
||||
@injectable()
|
||||
export class RaceResultsService implements Service {
|
||||
private apiClient: RacesApiClient;
|
||||
|
||||
constructor(apiClient?: RacesApiClient) {
|
||||
constructor(@unmanaged() apiClient?: RacesApiClient) {
|
||||
if (apiClient) {
|
||||
this.apiClient = apiClient;
|
||||
} else {
|
||||
|
||||
@@ -1,3 +1,4 @@
|
||||
import { injectable } from 'inversify';
|
||||
import { RacesApiClient } from '@/lib/api/races/RacesApiClient';
|
||||
import { Result } from '@/lib/contracts/Result';
|
||||
import { DomainError, Service } from '@/lib/contracts/services/Service';
|
||||
@@ -12,6 +13,7 @@ import { ApiError } from '@/lib/api/base/ApiError';
|
||||
* Returns raw API DTOs. No ViewModels or UX logic.
|
||||
* All client-side presentation logic must be handled by hooks/components.
|
||||
*/
|
||||
@injectable()
|
||||
export class RaceService implements Service {
|
||||
private apiClient: RacesApiClient;
|
||||
|
||||
|
||||
@@ -1,3 +1,4 @@
|
||||
import { injectable, unmanaged } from 'inversify';
|
||||
import { RacesApiClient } from '@/lib/api/races/RacesApiClient';
|
||||
import { ProtestsApiClient } from '@/lib/api/protests/ProtestsApiClient';
|
||||
import { PenaltiesApiClient } from '@/lib/api/penalties/PenaltiesApiClient';
|
||||
@@ -15,12 +16,17 @@ import { RaceStewardingViewModel } from '@/lib/view-models/RaceStewardingViewMod
|
||||
* Orchestration service for race stewarding operations.
|
||||
* Returns raw API DTOs. No ViewModels or UX logic.
|
||||
*/
|
||||
@injectable()
|
||||
export class RaceStewardingService implements Service {
|
||||
private racesApiClient: RacesApiClient;
|
||||
private protestsApiClient: ProtestsApiClient;
|
||||
private penaltiesApiClient: PenaltiesApiClient;
|
||||
|
||||
constructor(racesApiClient?: RacesApiClient, protestsApiClient?: ProtestsApiClient, penaltiesApiClient?: PenaltiesApiClient) {
|
||||
constructor(
|
||||
@unmanaged() racesApiClient?: RacesApiClient,
|
||||
@unmanaged() protestsApiClient?: ProtestsApiClient,
|
||||
@unmanaged() penaltiesApiClient?: PenaltiesApiClient
|
||||
) {
|
||||
if (racesApiClient && protestsApiClient && penaltiesApiClient) {
|
||||
this.racesApiClient = racesApiClient;
|
||||
this.protestsApiClient = protestsApiClient;
|
||||
|
||||
@@ -1,3 +1,4 @@
|
||||
import { injectable, unmanaged } from 'inversify';
|
||||
import { TeamsApiClient } from '@/lib/api/teams/TeamsApiClient';
|
||||
import { TeamJoinRequestViewModel } from '@/lib/view-models/TeamJoinRequestViewModel';
|
||||
import { Result } from '@/lib/contracts/Result';
|
||||
@@ -13,10 +14,11 @@ import { isProductionEnvironment } from '@/lib/config/env';
|
||||
* Returns ViewModels for team join requests.
|
||||
* Handles presentation logic for join request management.
|
||||
*/
|
||||
@injectable()
|
||||
export class TeamJoinService implements Service {
|
||||
private apiClient: TeamsApiClient;
|
||||
|
||||
constructor(apiClient?: TeamsApiClient) {
|
||||
constructor(@unmanaged() apiClient?: TeamsApiClient) {
|
||||
if (apiClient) {
|
||||
this.apiClient = apiClient;
|
||||
} else {
|
||||
@@ -31,23 +33,24 @@ export class TeamJoinService implements Service {
|
||||
}
|
||||
}
|
||||
|
||||
async getJoinRequests(teamId: string, currentDriverId: string, isOwner: boolean): Promise<any[]> {
|
||||
async getJoinRequests(teamId: string, currentDriverId: string, isOwner: boolean): Promise<Result<TeamJoinRequestViewModel[], DomainError>> {
|
||||
try {
|
||||
const result = await this.apiClient.getJoinRequests(teamId);
|
||||
const requests = (result as any).requests || result;
|
||||
return requests.map((request: any) =>
|
||||
const viewModels = requests.map((request: any) =>
|
||||
new TeamJoinRequestViewModel(request, currentDriverId, isOwner)
|
||||
);
|
||||
return Result.ok(viewModels);
|
||||
} catch (error: any) {
|
||||
throw error;
|
||||
return Result.err({ type: 'serverError', message: error.message || 'Failed to fetch join requests' });
|
||||
}
|
||||
}
|
||||
|
||||
async approveJoinRequest(): Promise<void> {
|
||||
throw new Error('Not implemented: API endpoint for approving join requests');
|
||||
async approveJoinRequest(): Promise<Result<void, DomainError>> {
|
||||
return Result.err({ type: 'notImplemented', message: 'Not implemented: API endpoint for approving join requests' });
|
||||
}
|
||||
|
||||
async rejectJoinRequest(): Promise<void> {
|
||||
throw new Error('Not implemented: API endpoint for rejecting join requests');
|
||||
async rejectJoinRequest(): Promise<Result<void, DomainError>> {
|
||||
return Result.err({ type: 'notImplemented', message: 'Not implemented: API endpoint for rejecting join requests' });
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1,3 +1,4 @@
|
||||
import { injectable, unmanaged } from 'inversify';
|
||||
import { TeamsApiClient } from '@/lib/api/teams/TeamsApiClient';
|
||||
import type { TeamListItemDTO } from '@/lib/types/generated/TeamListItemDTO';
|
||||
import type { CreateTeamInputDTO } from '@/lib/types/generated/CreateTeamInputDTO';
|
||||
@@ -7,6 +8,7 @@ import type { UpdateTeamOutputDTO } from '@/lib/types/generated/UpdateTeamOutput
|
||||
import type { GetDriverTeamOutputDTO } from '@/lib/types/generated/GetDriverTeamOutputDTO';
|
||||
import type { GetTeamMembershipOutputDTO } from '@/lib/types/generated/GetTeamMembershipOutputDTO';
|
||||
import type { GetTeamJoinRequestsOutputDTO } from '@/lib/types/generated/GetTeamJoinRequestsOutputDTO';
|
||||
import type { GetTeamDetailsOutputDTO } from '@/lib/types/generated/GetTeamDetailsOutputDTO';
|
||||
import { TeamMemberViewModel } from '@/lib/view-models/TeamMemberViewModel';
|
||||
import { TeamSummaryViewModel } from '@/lib/view-models/TeamSummaryViewModel';
|
||||
import { TeamDetailsViewModel } from '@/lib/view-models/TeamDetailsViewModel';
|
||||
@@ -23,10 +25,11 @@ import { isProductionEnvironment } from '@/lib/config/env';
|
||||
* Returns raw API DTOs. No ViewModels or UX logic.
|
||||
* All client-side presentation logic must be handled by hooks/components.
|
||||
*/
|
||||
@injectable()
|
||||
export class TeamService implements Service {
|
||||
private apiClient: TeamsApiClient;
|
||||
|
||||
constructor(apiClient?: TeamsApiClient) {
|
||||
constructor(@unmanaged() apiClient?: TeamsApiClient) {
|
||||
if (apiClient) {
|
||||
this.apiClient = apiClient;
|
||||
} else {
|
||||
@@ -51,86 +54,86 @@ export class TeamService implements Service {
|
||||
}
|
||||
|
||||
async update(teamId: string, input: UpdateTeamInputDTO): Promise<Result<UpdateTeamOutputDTO, DomainError>> {
|
||||
return this.updateTeam(teamId, input);
|
||||
try {
|
||||
const result = await this.apiClient.update(teamId, input);
|
||||
return Result.ok((result as any).value || result);
|
||||
} catch (error: unknown) {
|
||||
return Result.err({ type: 'unknown', message: (error as Error).message || 'Failed to update team' });
|
||||
}
|
||||
}
|
||||
|
||||
async create(input: CreateTeamInputDTO): Promise<Result<CreateTeamOutputDTO, DomainError>> {
|
||||
return this.createTeam(input);
|
||||
try {
|
||||
const result = await this.apiClient.create(input);
|
||||
return Result.ok((result as any).value || result);
|
||||
} catch (error: unknown) {
|
||||
return Result.err({ type: 'unknown', message: (error as Error).message || 'Failed to create team' });
|
||||
}
|
||||
}
|
||||
|
||||
async getTeamDetails(teamId: string, _: string): Promise<any> {
|
||||
async getTeamDetails(teamId: string, _: string): Promise<Result<GetTeamDetailsOutputDTO, DomainError>> {
|
||||
try {
|
||||
const result = await this.apiClient.getDetails(teamId);
|
||||
if (!result) {
|
||||
return null;
|
||||
return Result.err({ type: 'notFound', message: 'Team not found' });
|
||||
}
|
||||
const data = (result as any).value || result;
|
||||
return new TeamDetailsViewModel(data, {} as any);
|
||||
return Result.ok((result as any).value || result);
|
||||
} catch (error: unknown) {
|
||||
throw error;
|
||||
return Result.err({ type: 'unknown', message: (error as Error).message || 'Failed to fetch team details' });
|
||||
}
|
||||
}
|
||||
|
||||
async getTeamMembers(teamId: string, currentDriverId: string, ownerId: string): Promise<any> {
|
||||
async getTeamMembers(teamId: string, currentDriverId: string, ownerId: string): Promise<Result<TeamMemberViewModel[], DomainError>> {
|
||||
try {
|
||||
const result = await this.apiClient.getMembers(teamId);
|
||||
const members = (result as any).members || result;
|
||||
return members.map((member: any) => new TeamMemberViewModel(member, currentDriverId, ownerId));
|
||||
const viewModels = members.map((member: any) => new TeamMemberViewModel(member, currentDriverId, ownerId));
|
||||
return Result.ok(viewModels);
|
||||
} catch (error: unknown) {
|
||||
throw error;
|
||||
return Result.err({ type: 'unknown', message: (error as Error).message || 'Failed to fetch team members' });
|
||||
}
|
||||
}
|
||||
|
||||
async getTeamJoinRequests(teamId: string): Promise<any> {
|
||||
async getTeamJoinRequests(teamId: string): Promise<Result<any, DomainError>> {
|
||||
try {
|
||||
const result = await this.apiClient.getJoinRequests(teamId);
|
||||
return (result as any).value || result;
|
||||
return Result.ok((result as any).value || result);
|
||||
} catch (error: unknown) {
|
||||
throw error;
|
||||
return Result.err({ type: 'unknown', message: (error as Error).message || 'Failed to fetch join requests' });
|
||||
}
|
||||
}
|
||||
|
||||
async createTeam(input: CreateTeamInputDTO): Promise<any> {
|
||||
try {
|
||||
const result = await this.apiClient.create(input);
|
||||
return (result as any).value || result;
|
||||
} catch (error: unknown) {
|
||||
throw error;
|
||||
}
|
||||
async createTeam(input: CreateTeamInputDTO): Promise<Result<any, DomainError>> {
|
||||
return this.create(input);
|
||||
}
|
||||
|
||||
async updateTeam(teamId: string, input: UpdateTeamInputDTO): Promise<any> {
|
||||
try {
|
||||
const result = await this.apiClient.update(teamId, input);
|
||||
return (result as any).value || result;
|
||||
} catch (error: unknown) {
|
||||
throw error;
|
||||
}
|
||||
async updateTeam(teamId: string, input: UpdateTeamInputDTO): Promise<Result<any, DomainError>> {
|
||||
return this.update(teamId, input);
|
||||
}
|
||||
|
||||
async getDriverTeam(driverId: string): Promise<any> {
|
||||
async getDriverTeam(driverId: string): Promise<Result<any, DomainError>> {
|
||||
try {
|
||||
const result = await this.apiClient.getDriverTeam(driverId);
|
||||
if (!result) return null;
|
||||
if (!result) return Result.ok(null);
|
||||
const data = (result as any).value || result;
|
||||
if (!data.team) return null;
|
||||
return {
|
||||
if (!data.team) return Result.ok(null);
|
||||
return Result.ok({
|
||||
teamId: data.team.id,
|
||||
teamName: data.team.name,
|
||||
role: data.membership?.role,
|
||||
};
|
||||
});
|
||||
} catch (error: unknown) {
|
||||
throw error;
|
||||
return Result.err({ type: 'unknown', message: (error as Error).message || 'Failed to fetch driver team' });
|
||||
}
|
||||
}
|
||||
|
||||
async getAllTeams(): Promise<any> {
|
||||
async getAllTeams(): Promise<Result<TeamListItemDTO[], DomainError>> {
|
||||
try {
|
||||
const result = await this.apiClient.getAll();
|
||||
const teams = (result as any).teams || result;
|
||||
return teams.map((t: any) => new TeamSummaryViewModel(t));
|
||||
return Result.ok(teams);
|
||||
} catch (error: unknown) {
|
||||
throw error;
|
||||
return Result.err({ type: 'unknown', message: (error as Error).message || 'Failed to fetch all teams' });
|
||||
}
|
||||
}
|
||||
|
||||
@@ -142,4 +145,4 @@ export class TeamService implements Service {
|
||||
return Result.err({ type: 'unknown', message: (error as Error).message || 'Failed to fetch team membership' });
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user