117 lines
3.1 KiB
TypeScript
117 lines
3.1 KiB
TypeScript
import { eq, desc, and } from "drizzle-orm";
|
|
import { database } from "~/database/context";
|
|
import * as schema from "~/database/schema";
|
|
|
|
export type League = typeof schema.leagues.$inferSelect;
|
|
export type NewLeague = typeof schema.leagues.$inferInsert;
|
|
|
|
export async function createLeague(data: NewLeague): Promise<League> {
|
|
const db = database();
|
|
const [league] = await db
|
|
.insert(schema.leagues)
|
|
.values(data)
|
|
.returning();
|
|
return league;
|
|
}
|
|
|
|
export async function findLeagueById(id: string): Promise<League | undefined> {
|
|
const db = database();
|
|
return await db.query.leagues.findFirst({
|
|
where: eq(schema.leagues.id, id),
|
|
});
|
|
}
|
|
|
|
export async function findLeaguesByCreator(userId: string): Promise<League[]> {
|
|
const db = database();
|
|
return await db.query.leagues.findMany({
|
|
where: eq(schema.leagues.createdBy, userId),
|
|
orderBy: (leagues, { desc }) => [desc(leagues.createdAt)],
|
|
});
|
|
}
|
|
|
|
export async function updateLeague(
|
|
id: string,
|
|
data: Partial<NewLeague>
|
|
): Promise<League> {
|
|
const db = database();
|
|
const [league] = await db
|
|
.update(schema.leagues)
|
|
.set({ ...data, updatedAt: new Date() })
|
|
.where(eq(schema.leagues.id, id))
|
|
.returning();
|
|
return league;
|
|
}
|
|
|
|
export async function deleteLeague(id: string): Promise<void> {
|
|
const db = database();
|
|
await db.delete(schema.leagues).where(eq(schema.leagues.id, id));
|
|
}
|
|
|
|
export async function setCurrentSeason(
|
|
leagueId: string,
|
|
seasonId: string | null
|
|
): Promise<League> {
|
|
return await updateLeague(leagueId, { currentSeasonId: seasonId });
|
|
}
|
|
|
|
export async function listLeagues(options?: {
|
|
limit?: number;
|
|
offset?: number;
|
|
}): Promise<League[]> {
|
|
const db = database();
|
|
return await db.query.leagues.findMany({
|
|
limit: options?.limit,
|
|
offset: options?.offset,
|
|
orderBy: (leagues, { desc }) => [desc(leagues.createdAt)],
|
|
});
|
|
}
|
|
|
|
export async function findLeaguesWithActiveSeasonsByUserId(
|
|
userId: string
|
|
): Promise<League[]> {
|
|
const db = database();
|
|
|
|
// Query to find all leagues where user has a team in the current season
|
|
const leagues = await db
|
|
.selectDistinct({
|
|
id: schema.leagues.id,
|
|
name: schema.leagues.name,
|
|
createdBy: schema.leagues.createdBy,
|
|
currentSeasonId: schema.leagues.currentSeasonId,
|
|
createdAt: schema.leagues.createdAt,
|
|
updatedAt: schema.leagues.updatedAt,
|
|
})
|
|
.from(schema.leagues)
|
|
.innerJoin(schema.teams, eq(schema.teams.seasonId, schema.leagues.currentSeasonId))
|
|
.where(eq(schema.teams.ownerId, userId))
|
|
.orderBy(desc(schema.leagues.createdAt));
|
|
|
|
return leagues;
|
|
}
|
|
|
|
/**
|
|
* Check if a user is a member of a league (has a team in current season)
|
|
*/
|
|
export async function isUserLeagueMember(
|
|
leagueId: string,
|
|
userId: string
|
|
): Promise<boolean> {
|
|
const db = database();
|
|
|
|
const league = await db.query.leagues.findFirst({
|
|
where: eq(schema.leagues.id, leagueId),
|
|
});
|
|
|
|
if (!league || !league.currentSeasonId) {
|
|
return false;
|
|
}
|
|
|
|
const team = await db.query.teams.findFirst({
|
|
where: and(
|
|
eq(schema.teams.seasonId, league.currentSeasonId),
|
|
eq(schema.teams.ownerId, userId)
|
|
),
|
|
});
|
|
|
|
return !!team;
|
|
}
|