brackt/app/models/season-sport.ts

129 lines
3 KiB
TypeScript

import { eq, and } from "drizzle-orm";
import { database } from "~/database/context";
import * as schema from "~/database/schema";
export type SeasonSport = typeof schema.seasonSports.$inferSelect;
export type NewSeasonSport = typeof schema.seasonSports.$inferInsert;
export async function linkSportToSeason(
seasonId: string,
sportsSeasonId: string,
isRequired: boolean = true
): Promise<SeasonSport> {
const db = database();
const [link] = await db
.insert(schema.seasonSports)
.values({
seasonId,
sportsSeasonId,
isRequired,
})
.returning();
return link;
}
export async function linkMultipleSportsToSeason(
data: NewSeasonSport[]
): Promise<SeasonSport[]> {
const db = database();
return await db
.insert(schema.seasonSports)
.values(data)
.returning();
}
export async function unlinkSportFromSeason(
seasonId: string,
sportsSeasonId: string
): Promise<void> {
const db = database();
await db
.delete(schema.seasonSports)
.where(
and(
eq(schema.seasonSports.seasonId, seasonId),
eq(schema.seasonSports.sportsSeasonId, sportsSeasonId)
)
);
}
export async function findSeasonSportsBySeasonId(
seasonId: string
): Promise<SeasonSport[]> {
const db = database();
return await db.query.seasonSports.findMany({
where: eq(schema.seasonSports.seasonId, seasonId),
with: {
sportsSeason: {
with: {
sport: true,
},
},
},
});
}
export async function findSeasonSportsBySportsSeasonId(
sportsSeasonId: string
): Promise<SeasonSport[]> {
const db = database();
return await db.query.seasonSports.findMany({
where: eq(schema.seasonSports.sportsSeasonId, sportsSeasonId),
with: {
season: {
with: {
league: true,
},
},
},
});
}
export async function updateSeasonSport(
seasonId: string,
sportsSeasonId: string,
isRequired: boolean
): Promise<SeasonSport> {
const db = database();
const [link] = await db
.update(schema.seasonSports)
.set({ isRequired })
.where(
and(
eq(schema.seasonSports.seasonId, seasonId),
eq(schema.seasonSports.sportsSeasonId, sportsSeasonId)
)
)
.returning();
return link;
}
export async function deleteSeasonSport(id: string): Promise<void> {
const db = database();
await db.delete(schema.seasonSports).where(eq(schema.seasonSports.id, id));
}
export async function applySportsFromTemplate(
seasonId: string,
templateId: string
): Promise<SeasonSport[]> {
const db = database();
// Get all sports from the template
const templateSports = await db.query.seasonTemplateSports.findMany({
where: eq(schema.seasonTemplateSports.templateId, templateId),
});
if (templateSports.length === 0) {
return [];
}
// Link them to the season
return await linkMultipleSportsToSeason(
templateSports.map((ts) => ({
seasonId,
sportsSeasonId: ts.sportsSeasonId,
isRequired: ts.isRequired,
}))
);
}