aboutsummaryrefslogtreecommitdiff
path: root/src/routes/+page.server.ts
blob: 0a8a3f4742fb0975f4e2f9bf56bd7e3b45225f70 (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127

import { fail, redirect } from '@sveltejs/kit';
import { db } from '$lib/server/db';
import { groceries, categories, references } from '$lib/server/db/schema';
import { eq, desc } from 'drizzle-orm';
import type { Actions, PageServerLoad } from './$types';

export const load: PageServerLoad = async () => {
	const [items, cats, refs] = await Promise.all([
		db
			.select()
			.from(groceries)
			.where(eq(groceries.checked, false))
			.orderBy(desc(groceries.createdAt)),
		db.select().from(categories).orderBy(desc(categories.name)),
		db.select().from(references).orderBy(desc(references.qualityScore)),
	]);

	const catMap = new Map(cats.map((c) => [c.id, c.name]));
	const bestRef = new Map<number, (typeof refs)[number]>();
	for (const ref of refs) {
		if (!bestRef.has(ref.groceryId)) {
			bestRef.set(ref.groceryId, ref);
		}
	}

	return {
		items: items.map((i) => ({
			...i,
			categoryName: i.categoryId ? (catMap.get(i.categoryId) ?? null) : null,
			bestRef: bestRef.get(i.id) ?? null,
		})),
		categories: cats,
	};
};

export const actions: Actions = {
	add: async ({ request }) => {
		const data = await request.formData();
		const name = data.get('name')?.toString().trim();
		const categoryId = data.get('category_id')?.toString() || null;

		if (!name) {
			return fail(400, { error: 'Le nom est requis' });
		}

		const [existing] = await db
			.select()
			.from(groceries)
			.where(eq(groceries.name, name))
			.limit(1);

		if (existing) {
			await db
				.update(groceries)
				.set({
					checked: false,
					categoryId: categoryId ? Number(categoryId) : existing.categoryId,
				})
				.where(eq(groceries.id, existing.id));
		} else {
			await db.insert(groceries).values({
				name,
				categoryId: categoryId ? Number(categoryId) : null,
				createdAt: new Date().toISOString(),
			});
		}

		return { success: true };
	},

	toggle: async ({ request }) => {
		const data = await request.formData();
		const id = Number(data.get('id'));

		const [item] = await db
			.select()
			.from(groceries)
			.where(eq(groceries.id, id));
		if (!item) {
			return fail(404, { error: 'Article introuvable' });
		}

		await db
			.update(groceries)
			.set({ checked: !item.checked })
			.where(eq(groceries.id, id));

		return { success: true };
	},

	addAndEdit: async ({ request }) => {
		const data = await request.formData();
		const name = data.get('name')?.toString().trim();
		const categoryId = data.get('category_id')?.toString() || null;

		if (!name) {
			return fail(400, { error: 'Le nom est requis' });
		}

		const [existing] = await db
			.select()
			.from(groceries)
			.where(eq(groceries.name, name))
			.limit(1);

		if (existing) {
			await db
				.update(groceries)
				.set({
					checked: false,
					categoryId: categoryId ? Number(categoryId) : existing.categoryId,
				})
				.where(eq(groceries.id, existing.id));
			throw redirect(303, `/grocery/${existing.id}`);
		} else {
			const [inserted] = await db
				.insert(groceries)
				.values({
					name,
					categoryId: categoryId ? Number(categoryId) : null,
					createdAt: new Date().toISOString(),
				})
				.returning();
			throw redirect(303, `/grocery/${inserted.id}`);
		}
	},
};