5a47300110
Adds CRUD modules for the canonical tables created in commit 775b905.
Each module mirrors existing app/models conventions (database() from
~/database/context, schema from ~/database/schema, mock-based tests).
Key implementation notes:
- participant.ts exports use "Canonical" prefix (CanonicalParticipant,
createCanonicalParticipant, etc.) to avoid collision with existing
season-participant.ts exports
- All four models include comprehensive unit tests following the
audit-log.test.ts pattern
- Tests use mocked db responses (no real database access)
- Upsert functions use onConflictDoUpdate for appropriate unique constraints
Part of Phase 1b of canonical tournament layer migration.
Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>
76 lines
1.9 KiB
TypeScript
76 lines
1.9 KiB
TypeScript
import { eq, and, asc } from "drizzle-orm";
|
|
import { database } from "~/database/context";
|
|
import * as schema from "~/database/schema";
|
|
|
|
export type CanonicalParticipant = typeof schema.participants.$inferSelect;
|
|
export type NewCanonicalParticipant = typeof schema.participants.$inferInsert;
|
|
|
|
export async function createCanonicalParticipant(
|
|
data: NewCanonicalParticipant
|
|
): Promise<CanonicalParticipant> {
|
|
const db = database();
|
|
const [participant] = await db
|
|
.insert(schema.participants)
|
|
.values(data)
|
|
.returning();
|
|
return participant;
|
|
}
|
|
|
|
export async function getCanonicalParticipantById(
|
|
id: string
|
|
): Promise<CanonicalParticipant | null> {
|
|
const db = database();
|
|
const results = await db
|
|
.select()
|
|
.from(schema.participants)
|
|
.where(eq(schema.participants.id, id))
|
|
.limit(1);
|
|
return results[0] ?? null;
|
|
}
|
|
|
|
export async function findCanonicalParticipantsBySport(
|
|
sportId: string
|
|
): Promise<CanonicalParticipant[]> {
|
|
const db = database();
|
|
return await db
|
|
.select()
|
|
.from(schema.participants)
|
|
.where(eq(schema.participants.sportId, sportId))
|
|
.orderBy(asc(schema.participants.name));
|
|
}
|
|
|
|
export async function findCanonicalParticipantBySportName(
|
|
sportId: string,
|
|
name: string
|
|
): Promise<CanonicalParticipant | null> {
|
|
const db = database();
|
|
const results = await db
|
|
.select()
|
|
.from(schema.participants)
|
|
.where(
|
|
and(
|
|
eq(schema.participants.sportId, sportId),
|
|
eq(schema.participants.name, name)
|
|
)
|
|
)
|
|
.limit(1);
|
|
return results[0] ?? null;
|
|
}
|
|
|
|
export async function upsertCanonicalParticipantBySportName(
|
|
sportId: string,
|
|
name: string,
|
|
extra?: Partial<NewCanonicalParticipant>
|
|
): Promise<CanonicalParticipant> {
|
|
const existing = await findCanonicalParticipantBySportName(sportId, name);
|
|
|
|
if (existing) {
|
|
return existing;
|
|
}
|
|
|
|
return await createCanonicalParticipant({
|
|
sportId,
|
|
name,
|
|
...extra,
|
|
});
|
|
}
|