import { eq } 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 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)],
  });
}