import { db as defaultDb } from '$lib/server/db';
import { references } from '$lib/server/db/schema';
import { eq, desc, asc } from 'drizzle-orm';
import type { AppDatabase } from './groceries';
import type { Reference } from './types';

export async function loadForGrocery(
	groceryId: number,
	db = defaultDb,
): Promise<Reference[]> {
	return db
		.select()
		.from(references)
		.where(eq(references.groceryId, groceryId))
		.orderBy(desc(references.qualityScore), asc(references.id));
}

export async function add(
	groceryId: number,
	reference: string,
	price: number | null,
	unit: string | null,
	qualityScore: number | null,
	db = defaultDb,
): Promise<Reference> {
	const [inserted] = await db
		.insert(references)
		.values({ groceryId, reference, price, unit, qualityScore })
		.returning();
	return inserted;
}

export async function deleteReference(
	id: number,
	db = defaultDb,
): Promise<void> {
	await db.delete(references).where(eq(references.id, id));
}