Compare commits
30
Commits
a6482ddb0e
...
0.8.0
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
de46f150f8 | ||
|
|
77aac1e6ba | ||
|
|
950add40a3 | ||
|
|
e77c546cb2 | ||
|
|
67e8520b08 | ||
|
|
842c4c9b0c | ||
|
|
58200b2bf9 | ||
|
|
35de0e1990 | ||
|
|
975cf38170 | ||
|
|
ab46e63bf0 | ||
|
|
3f7414707a | ||
|
|
cd99cd20df | ||
|
|
8bb0471a71 | ||
|
|
f24d8aa062 | ||
|
|
5233b1e6fd | ||
|
|
ff9f679fcb | ||
|
|
a13bc17629 | ||
|
|
f480407927 | ||
|
|
9267786371 | ||
|
|
e24f4ff7e2 | ||
|
|
56cd6e32e9 | ||
|
|
689bd95ff0 | ||
|
|
240d993d57 | ||
|
|
c2f6b07742 | ||
|
|
863d43ef8c | ||
|
|
dcd1203d31 | ||
|
|
5638fc4979 | ||
|
|
3695fc68d6 | ||
|
|
cf6853d71e | ||
|
|
fdbf40adac |
@@ -1,17 +0,0 @@
|
||||
when:
|
||||
event: [push, pull_request]
|
||||
|
||||
steps:
|
||||
e2e-build:
|
||||
image: rust:1
|
||||
commands:
|
||||
- cargo build
|
||||
|
||||
e2e-test:
|
||||
image: node:24
|
||||
directory: e2e
|
||||
commands:
|
||||
- apt-get update
|
||||
- apt-get install -y --no-install-recommends ca-certificates fonts-liberation libasound2 libatk-bridge2.0-0 libatk1.0-0 libcups2 libdbus-1-3 libdrm2 libgbm1 libglib2.0-0 libgtk-3-0 libnspr4 libnss3 libpango-1.0-0 libx11-6 libxcb1 libxcomposite1 libxdamage1 libxext6 libxfixes3 libxkbcommon0 libxrandr2 xdg-utils
|
||||
- npm install && npx playwright install chromium
|
||||
- npx playwright test
|
||||
@@ -6,3 +6,13 @@ steps:
|
||||
image: rust:1
|
||||
commands:
|
||||
- cargo test --all
|
||||
- cargo build --all
|
||||
|
||||
e2e-test:
|
||||
image: node:24
|
||||
directory: e2e
|
||||
commands:
|
||||
- apt-get update
|
||||
- apt-get install -y --no-install-recommends ca-certificates fonts-liberation libasound2 libatk-bridge2.0-0 libatk1.0-0 libcups2 libdbus-1-3 libdrm2 libgbm1 libglib2.0-0 libgtk-3-0 libnspr4 libnss3 libpango-1.0-0 libx11-6 libxcb1 libxcomposite1 libxdamage1 libxext6 libxfixes3 libxkbcommon0 libxrandr2 xdg-utils
|
||||
- npm install && npx playwright install chromium
|
||||
- npx playwright test
|
||||
|
||||
Generated
+8
-1
@@ -116,6 +116,12 @@ dependencies = [
|
||||
"tracing",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "barcoders"
|
||||
version = "2.0.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "a3826fb6e98ec72c0c0db8c9a40af4932d16793021027469857e84c1b50a1e8f"
|
||||
|
||||
[[package]]
|
||||
name = "base64"
|
||||
version = "0.13.1"
|
||||
@@ -1772,11 +1778,12 @@ checksum = "13c2bddecc57b384dee18652358fb23172facb8a2c51ccc10d74c157bdea3292"
|
||||
|
||||
[[package]]
|
||||
name = "sustenance"
|
||||
version = "0.2.0"
|
||||
version = "0.8.0"
|
||||
dependencies = [
|
||||
"argon2",
|
||||
"async-trait",
|
||||
"axum",
|
||||
"barcoders",
|
||||
"base64 0.22.1",
|
||||
"futures-util",
|
||||
"hex",
|
||||
|
||||
+2
-1
@@ -1,12 +1,13 @@
|
||||
[package]
|
||||
name = "sustenance"
|
||||
version = "0.2.0"
|
||||
version = "0.8.0"
|
||||
edition = "2024"
|
||||
|
||||
[dependencies]
|
||||
argon2 = "0.5"
|
||||
async-trait = "0.1"
|
||||
axum = { version = "0.8", features = ["ws"] }
|
||||
barcoders = { version = "2.0.0", features = ["svg"] }
|
||||
base64 = "0.22"
|
||||
futures-util = "0.3"
|
||||
hex = "0.4"
|
||||
|
||||
@@ -57,6 +57,8 @@ The file is optional — if it is missing or invalid, seeding is silently skippe
|
||||
- Global categories with common defaults seeded at startup and custom category creation
|
||||
- Items grouped by category and assigned from the add/edit forms
|
||||
- Meals with ingredients, markdown descriptions, and one-click "add meal to list"
|
||||
- Rewards cards with store name and number, rendered as scannable Code 128 / Code 39 barcodes
|
||||
- Single-card scan view that shows one barcode at a time and keeps the screen awake for scanning
|
||||
- Server-authoritative last-write-wins updates
|
||||
- Per-list WebSocket updates with server-rendered htmx fragments
|
||||
- In-memory presence for members currently viewing a list
|
||||
|
||||
+5
-19
@@ -1,13 +1,12 @@
|
||||
import { test as base, expect, Page } from "@playwright/test";
|
||||
import { spawn, ChildProcess } from "child_process";
|
||||
import * as fs from "fs";
|
||||
import * as os from "os";
|
||||
import * as path from "path";
|
||||
|
||||
/**
|
||||
* Starts a fresh Sustenance server against a unique, throwaway database on a
|
||||
* unique port for each test, and tears it down afterwards. This gives every
|
||||
* test a clean DB with no shared state between tests.
|
||||
* Starts a fresh Sustenance server against an in-memory SQLite database on a
|
||||
* unique port for each test, and tears it down afterwards. Every test gets a
|
||||
* clean DB with no shared state between tests, and nothing is written to disk.
|
||||
*/
|
||||
export const test = base.extend<{ server: { baseURL: string }; page: Page }>({
|
||||
server: [
|
||||
@@ -15,10 +14,6 @@ export const test = base.extend<{ server: { baseURL: string }; page: Page }>({
|
||||
const server = await startServer();
|
||||
await use({ baseURL: server.baseURL });
|
||||
await killTree(server.child);
|
||||
// Clean up the DB files (including -wal / -shm).
|
||||
for (const suffix of ["", "-wal", "-shm"]) {
|
||||
fs.rmSync(server.dbPath + suffix, { force: true });
|
||||
}
|
||||
},
|
||||
{ scope: "test", auto: true },
|
||||
],
|
||||
@@ -35,12 +30,6 @@ export const test = base.extend<{ server: { baseURL: string }; page: Page }>({
|
||||
/** Starts a server, retrying on a fresh port if the first attempt fails to bind. */
|
||||
async function startServer() {
|
||||
for (let attempt = 0; attempt < 5; attempt++) {
|
||||
const dbPath = path.join(
|
||||
os.tmpdir(),
|
||||
`sustenance-e2e-${process.pid}-${Date.now()}-${Math.random()
|
||||
.toString(36)
|
||||
.slice(2)}.db`,
|
||||
);
|
||||
const port = 20000 + Math.floor(Math.random() * 30000);
|
||||
const baseURL = `http://localhost:${port}`;
|
||||
|
||||
@@ -50,7 +39,7 @@ async function startServer() {
|
||||
{
|
||||
env: {
|
||||
...process.env,
|
||||
DATABASE_PATH: dbPath,
|
||||
DATABASE_IN_MEMORY: "1",
|
||||
REGISTRATION_MODE: "open",
|
||||
BIND_ADDRESS: `127.0.0.1:${port}`,
|
||||
PUBLIC_BASE_URL: baseURL,
|
||||
@@ -72,13 +61,10 @@ async function startServer() {
|
||||
|
||||
try {
|
||||
await waitForServer(baseURL, child);
|
||||
return { baseURL, child, dbPath };
|
||||
return { baseURL, child };
|
||||
} catch (error) {
|
||||
// The server may have failed to bind (port collision). Clean up and retry.
|
||||
await killTree(child);
|
||||
for (const suffix of ["", "-wal", "-shm"]) {
|
||||
fs.rmSync(dbPath + suffix, { force: true });
|
||||
}
|
||||
if (attempt === 4) {
|
||||
throw new Error(
|
||||
`server failed to start after retries; last stderr:\n${stderr}\n${error}`,
|
||||
|
||||
+21
-2
@@ -11,9 +11,17 @@ export async function registerAndLogin(page: Page, email: string) {
|
||||
}
|
||||
|
||||
/** Creates a meal with the given name and markdown description. */
|
||||
export async function createMeal(page: Page, name: string, description: string) {
|
||||
export async function createMeal(
|
||||
page: Page,
|
||||
name: string,
|
||||
description: string,
|
||||
category?: string,
|
||||
) {
|
||||
await page.goto("/meals/new");
|
||||
await page.fill("#meal-name", name);
|
||||
if (category) {
|
||||
await page.selectOption("#meal-category", { label: category });
|
||||
}
|
||||
await page.fill("#meal-description", description);
|
||||
await page.click('button:has-text("Save meal")');
|
||||
await expect(page).toHaveURL(/\/meals\/\d+/);
|
||||
@@ -38,12 +46,23 @@ export async function addItem(page: Page, name: string, quantity = "") {
|
||||
}
|
||||
|
||||
/** Adds an ingredient to the current meal page. */
|
||||
export async function addIngredient(page: Page, name: string, quantity = "") {
|
||||
export async function addIngredient(
|
||||
page: Page,
|
||||
name: string,
|
||||
quantity = "",
|
||||
category?: string,
|
||||
) {
|
||||
await page.fill("#ingredient-name", name);
|
||||
if (category) {
|
||||
await page.selectOption("#ingredient-category", { label: category });
|
||||
}
|
||||
if (quantity) {
|
||||
await page.fill("#ingredient-quantity", quantity);
|
||||
}
|
||||
await page.click("#add-ingredient-button");
|
||||
// The form submit is hx-boosted (full body swap to the same URL), so wait for
|
||||
// the new row to appear. This also acts as a settle point so the next action
|
||||
// doesn't race the async body replacement and target a stale form.
|
||||
await expect(page.locator(".ingredient-list").filter({ hasText: name })).toBeVisible();
|
||||
}
|
||||
|
||||
|
||||
@@ -52,3 +52,47 @@ test("the add-meal picker closes when clicking outside", async ({ page }) => {
|
||||
await page.mouse.click(10, 10);
|
||||
await expect(picker).toHaveCount(0);
|
||||
});
|
||||
|
||||
test("a meal added to a list is shown in the meals panel", async ({ page }) => {
|
||||
await registerAndLogin(page, "alice@example.com");
|
||||
await createMealWithIngredients(page, "Spaghetti Bolognese", [
|
||||
{ name: "Penne", quantity: "500g" },
|
||||
{ name: "Tomato", quantity: "2" },
|
||||
]);
|
||||
await createList(page, "Weekly shop");
|
||||
|
||||
await page.click(".add-meal-button");
|
||||
const picker = page.locator(".meal-picker-backdrop");
|
||||
await picker.locator(".meal-picker-button").filter({ hasText: "Spaghetti Bolognese" }).click();
|
||||
|
||||
// The meal appears in the "Meals on this list" panel.
|
||||
const panel = page.locator("#list-meals-panel");
|
||||
await expect(panel).toBeVisible();
|
||||
await expect(panel.locator(".list-meal-row").filter({ hasText: "Spaghetti Bolognese" })).toBeVisible();
|
||||
});
|
||||
|
||||
test("removing a meal from a list removes its ingredients", async ({ page }) => {
|
||||
await registerAndLogin(page, "alice@example.com");
|
||||
await createMealWithIngredients(page, "Spaghetti Bolognese", [
|
||||
{ name: "Penne", quantity: "500g" },
|
||||
{ name: "Tomato", quantity: "2" },
|
||||
]);
|
||||
await createList(page, "Weekly shop");
|
||||
|
||||
await page.click(".add-meal-button");
|
||||
const picker = page.locator(".meal-picker-backdrop");
|
||||
await picker.locator(".meal-picker-button").filter({ hasText: "Spaghetti Bolognese" }).click();
|
||||
|
||||
await expect(page.locator(".item-row").filter({ hasText: "Penne" })).toBeVisible();
|
||||
await expect(page.locator(".item-row").filter({ hasText: "Tomato" })).toBeVisible();
|
||||
|
||||
// Remove the meal from the list.
|
||||
const panel = page.locator("#list-meals-panel");
|
||||
const row = panel.locator(".list-meal-row").filter({ hasText: "Spaghetti Bolognese" });
|
||||
await row.locator(".list-meal-remove-button").click();
|
||||
|
||||
// The meal's ingredients are removed from the list.
|
||||
await expect(page.locator(".item-row").filter({ hasText: "Penne" })).toHaveCount(0);
|
||||
await expect(page.locator(".item-row").filter({ hasText: "Tomato" })).toHaveCount(0);
|
||||
await expect(row).toHaveCount(0);
|
||||
});
|
||||
|
||||
@@ -0,0 +1,83 @@
|
||||
import { expect } from "@playwright/test";
|
||||
import { test } from "../fixtures";
|
||||
import { registerAndLogin, createList, addItem } from "../helpers";
|
||||
|
||||
test("a user can archive a list and it moves to the archive page", async ({ page }) => {
|
||||
await registerAndLogin(page, "alice@example.com");
|
||||
await createList(page, "Weekly shop");
|
||||
|
||||
// Archive from the list page.
|
||||
await page.click('button:has-text("Archive")');
|
||||
|
||||
// Lands back on the lists page; the list is no longer shown.
|
||||
await expect(page).toHaveURL(/\/lists/);
|
||||
await expect(page.locator(".list-card").filter({ hasText: "Weekly shop" })).toHaveCount(0);
|
||||
|
||||
// The archived list is reachable from the archive page.
|
||||
await page.goto("/archive");
|
||||
await expect(page.locator(".list-card").filter({ hasText: "Weekly shop" })).toBeVisible();
|
||||
});
|
||||
|
||||
test("the lists frame links to the archive page", async ({ page }) => {
|
||||
await registerAndLogin(page, "alice@example.com");
|
||||
await createList(page, "Weekly shop");
|
||||
await page.goto("/lists");
|
||||
|
||||
await page.click('a.archive-link');
|
||||
await expect(page).toHaveURL(/\/archive/);
|
||||
});
|
||||
|
||||
test("an archived list is read-only", async ({ page }) => {
|
||||
await registerAndLogin(page, "alice@example.com");
|
||||
await createList(page, "Weekly shop");
|
||||
await addItem(page, "Apple");
|
||||
await page.click('button:has-text("Archive")');
|
||||
|
||||
// Open the archived list directly.
|
||||
await page.goto("/archive");
|
||||
await page.locator(".list-card").filter({ hasText: "Weekly shop" }).click();
|
||||
await expect(page).toHaveURL(/\/lists\/\d+/);
|
||||
|
||||
// The item is still visible.
|
||||
await expect(page.locator(".item-row").filter({ hasText: "Apple" })).toBeVisible();
|
||||
|
||||
// No mutation UI is present.
|
||||
await expect(page.locator("#add-item-form")).toHaveCount(0);
|
||||
await expect(page.locator(".item-actions-button")).toHaveCount(0);
|
||||
await expect(page.locator(".check-form")).toHaveCount(0);
|
||||
await expect(page.locator('button:has-text("+ Add meal")')).toHaveCount(0);
|
||||
});
|
||||
|
||||
test("a user can restore an archived list and edit it again", async ({ page }) => {
|
||||
await registerAndLogin(page, "alice@example.com");
|
||||
await createList(page, "Weekly shop");
|
||||
await addItem(page, "Apple");
|
||||
await page.click('button:has-text("Archive")');
|
||||
|
||||
// Open the archived list and restore it.
|
||||
await page.goto("/archive");
|
||||
await page.locator(".list-card").filter({ hasText: "Weekly shop" }).click();
|
||||
await page.click('button:has-text("Restore")');
|
||||
|
||||
// Back on the lists page, the list is active again.
|
||||
await expect(page).toHaveURL(/\/lists/);
|
||||
await expect(page.locator(".list-card").filter({ hasText: "Weekly shop" })).toBeVisible();
|
||||
|
||||
// The list is editable again.
|
||||
await page.locator(".list-card").filter({ hasText: "Weekly shop" }).click();
|
||||
await expect(page.locator("#add-item-form")).toBeVisible();
|
||||
await addItem(page, "Banana");
|
||||
await expect(page.locator(".item-row").filter({ hasText: "Banana" })).toBeVisible();
|
||||
});
|
||||
|
||||
test("the archive page shows the list name and created date", async ({ page }) => {
|
||||
await registerAndLogin(page, "alice@example.com");
|
||||
await createList(page, "Weekly shop");
|
||||
await page.click('button:has-text("Archive")');
|
||||
|
||||
await page.goto("/archive");
|
||||
const card = page.locator(".list-card").filter({ hasText: "Weekly shop" });
|
||||
await expect(card).toBeVisible();
|
||||
// The card shows a created date (e.g. "Created 7 Aug 2026").
|
||||
await expect(card.locator("small")).toContainText("Created");
|
||||
});
|
||||
@@ -0,0 +1,134 @@
|
||||
import { expect } from "@playwright/test";
|
||||
import { test } from "../fixtures";
|
||||
import { registerAndLogin, createList, createMealWithIngredients } from "../helpers";
|
||||
|
||||
/**
|
||||
* Opens the carry-over modal and waits for htmx to finish swapping it in, so
|
||||
* the source `<select>`'s `change` trigger is bound before interacting with it.
|
||||
*/
|
||||
async function openCarryModal(page: import("@playwright/test").Page) {
|
||||
await page.click(".carry-over-button");
|
||||
const carry = page.locator(".meal-picker-backdrop");
|
||||
await expect(carry).toBeVisible();
|
||||
// Let htmx finish processing the freshly-swapped modal before selecting a
|
||||
// source; otherwise the change event can be missed and no hx-get fires.
|
||||
await page.waitForTimeout(300);
|
||||
return carry;
|
||||
}
|
||||
|
||||
test("a user can carry meals over from a previous list without re-adding ingredients", async ({
|
||||
page,
|
||||
}) => {
|
||||
await registerAndLogin(page, "alice@example.com");
|
||||
await createMealWithIngredients(page, "Spaghetti Bolognese", [
|
||||
{ name: "Penne", quantity: "500g" },
|
||||
{ name: "Tomato", quantity: "2" },
|
||||
]);
|
||||
|
||||
// Last week's list has the meal added (with its ingredients as items).
|
||||
await createList(page, "Last week");
|
||||
await page.click(".add-meal-button");
|
||||
const picker = page.locator(".meal-picker-backdrop");
|
||||
await picker
|
||||
.locator(".meal-picker-button")
|
||||
.filter({ hasText: "Spaghetti Bolognese" })
|
||||
.click();
|
||||
await expect(page.locator(".item-row").filter({ hasText: "Penne" })).toBeVisible();
|
||||
|
||||
// Create this week's (new) list.
|
||||
await createList(page, "This week");
|
||||
await expect(page.locator(".item-row")).toHaveCount(0);
|
||||
|
||||
// Open the carry-over modal and pick the source list.
|
||||
const carry = await openCarryModal(page);
|
||||
await expect(carry.locator(".carry-intro")).toContainText("already purchased");
|
||||
await carry.locator("#carry-source").selectOption({ label: "Last week" });
|
||||
|
||||
// The source list's meals appear as selectable rows.
|
||||
const row = carry.locator(".carry-row").filter({ hasText: "Spaghetti Bolognese" });
|
||||
await expect(row).toBeVisible();
|
||||
|
||||
// Select the meal and finish.
|
||||
await row.locator('input[type="checkbox"]').check();
|
||||
await carry.locator(".carry-submit").click();
|
||||
|
||||
// The modal closes, the meal appears in the meals panel, but no items are added.
|
||||
await expect(carry).toHaveCount(0);
|
||||
const panel = page.locator("#list-meals-panel");
|
||||
await expect(panel.locator(".list-meal-row").filter({ hasText: "Spaghetti Bolognese" })).toBeVisible();
|
||||
await expect(page.locator(".item-row")).toHaveCount(0);
|
||||
});
|
||||
|
||||
test("the carry-over modal lists active lists newest first and excludes the current list", async ({
|
||||
page,
|
||||
}) => {
|
||||
await registerAndLogin(page, "alice@example.com");
|
||||
await createList(page, "First list");
|
||||
await createList(page, "Second list");
|
||||
|
||||
// Open carry-over on the second (current) list.
|
||||
await page.click(".carry-over-button");
|
||||
const carry = page.locator(".meal-picker-backdrop");
|
||||
await expect(carry).toBeVisible();
|
||||
|
||||
const options = carry.locator("#carry-source option");
|
||||
// The current list is excluded; only the other list remains.
|
||||
await expect(options).toHaveCount(2); // placeholder + one source
|
||||
await expect(carry.locator("#carry-source")).toContainText("First list");
|
||||
await expect(carry.locator("#carry-source")).not.toContainText("Second list");
|
||||
});
|
||||
|
||||
test("carrying a meal does not remove it from the source list", async ({ page }) => {
|
||||
await registerAndLogin(page, "alice@example.com");
|
||||
await createMealWithIngredients(page, "Pasta", [{ name: "Penne" }]);
|
||||
await createList(page, "Last week");
|
||||
await page.click(".add-meal-button");
|
||||
await page
|
||||
.locator(".meal-picker-backdrop .meal-picker-button")
|
||||
.filter({ hasText: "Pasta" })
|
||||
.click();
|
||||
await expect(page.locator(".item-row").filter({ hasText: "Penne" })).toBeVisible();
|
||||
|
||||
await createList(page, "This week");
|
||||
const carry = await openCarryModal(page);
|
||||
|
||||
// Select the source list; the meal rows load via hx-get.
|
||||
await carry.locator("#carry-source").selectOption({ label: "Last week" });
|
||||
const row = carry.locator(".carry-row").filter({ hasText: "Pasta" });
|
||||
await expect(row).toBeVisible({ timeout: 10_000 });
|
||||
await row.locator('input[type="checkbox"]').check();
|
||||
await carry.locator(".carry-submit").click();
|
||||
await expect(carry).toHaveCount(0);
|
||||
|
||||
// The source list still has its meal and items.
|
||||
await page.goto("/lists");
|
||||
await page.locator(".list-card").filter({ hasText: "Last week" }).click();
|
||||
await expect(page.locator("#list-meals-panel .list-meal-row").filter({ hasText: "Pasta" })).toBeVisible();
|
||||
await expect(page.locator(".item-row").filter({ hasText: "Penne" })).toBeVisible();
|
||||
});
|
||||
|
||||
test("submitting carry-over with no selection does not add a meal", async ({ page }) => {
|
||||
await registerAndLogin(page, "alice@example.com");
|
||||
await createMealWithIngredients(page, "Pasta", [{ name: "Penne" }]);
|
||||
await createList(page, "Last week");
|
||||
await page.click(".add-meal-button");
|
||||
await page
|
||||
.locator(".meal-picker-backdrop .meal-picker-button")
|
||||
.filter({ hasText: "Pasta" })
|
||||
.click();
|
||||
await expect(page.locator(".item-row").filter({ hasText: "Penne" })).toBeVisible();
|
||||
|
||||
await createList(page, "This week");
|
||||
const carry = await openCarryModal(page);
|
||||
|
||||
// Select the source list; the meal rows load via hx-get.
|
||||
await carry.locator("#carry-source").selectOption({ label: "Last week" });
|
||||
await expect(carry.locator(".carry-row").filter({ hasText: "Pasta" })).toBeVisible({
|
||||
timeout: 10_000,
|
||||
});
|
||||
|
||||
// Submit with nothing selected; the modal stays open and no meal is carried.
|
||||
await carry.locator(".carry-submit").click();
|
||||
await expect(carry).toBeVisible();
|
||||
await expect(page.locator("#list-meals-panel .list-meal-row")).toHaveCount(0);
|
||||
});
|
||||
@@ -84,6 +84,8 @@ test("a user can add a category", async ({ page }) => {
|
||||
await registerAndLogin(page, "alice@example.com");
|
||||
await createList(page, "Weekly shop");
|
||||
|
||||
// Categories are managed from the main lists page.
|
||||
await page.goto("/lists");
|
||||
await page.fill("#category-name", "Bakery");
|
||||
await page.click("#add-category-button");
|
||||
|
||||
|
||||
@@ -0,0 +1,111 @@
|
||||
import { expect } from "@playwright/test";
|
||||
import { test } from "../fixtures";
|
||||
import { registerAndLogin, createMeal } from "../helpers";
|
||||
|
||||
test("meals are grouped under their category on the meals page", async ({ page }) => {
|
||||
await registerAndLogin(page, "alice@example.com");
|
||||
|
||||
await createMeal(page, "Beef Stew", "", "Beef");
|
||||
await createMeal(page, "Chicken Curry", "", "Chicken");
|
||||
await createMeal(page, "Plain Rice", "");
|
||||
|
||||
await page.goto("/meals");
|
||||
|
||||
// Each category appears as a heading with its meals beneath it.
|
||||
const beef = page.locator(".category-group").filter({ hasText: "Beef" });
|
||||
await expect(beef.locator(".category-heading")).toContainText("Beef");
|
||||
await expect(beef.locator(".list-card").filter({ hasText: "Beef Stew" })).toBeVisible();
|
||||
|
||||
const chicken = page.locator(".category-group").filter({ hasText: "Chicken" });
|
||||
await expect(chicken.locator(".list-card").filter({ hasText: "Chicken Curry" })).toBeVisible();
|
||||
|
||||
// Uncategorized meals land in their own group.
|
||||
const uncategorized = page.locator(".category-group").filter({ hasText: "Uncategorized" });
|
||||
await expect(uncategorized.locator(".list-card").filter({ hasText: "Plain Rice" })).toBeVisible();
|
||||
});
|
||||
|
||||
test("a user can create a meal category", async ({ page }) => {
|
||||
await registerAndLogin(page, "alice@example.com");
|
||||
|
||||
await page.goto("/meals");
|
||||
await page.fill('form[action="/meals/categories"] input[name="name"]', "Breakfast");
|
||||
await page.click('form[action="/meals/categories"] button[type="submit"]');
|
||||
|
||||
await expect(page).toHaveURL(/\/meals$/);
|
||||
await expect(page.locator(".meal-category-name").filter({ hasText: "Breakfast" })).toBeVisible();
|
||||
});
|
||||
|
||||
test("a user can delete a meal category and its meals become uncategorized", async ({ page }) => {
|
||||
await registerAndLogin(page, "alice@example.com");
|
||||
|
||||
// Create a custom category and a meal in it.
|
||||
await page.goto("/meals");
|
||||
await page.fill('form[action="/meals/categories"] input[name="name"]', "Breakfast");
|
||||
await page.click('form[action="/meals/categories"] button[type="submit"]');
|
||||
await expect(page).toHaveURL(/\/meals$/);
|
||||
|
||||
await createMeal(page, "Pancakes", "", "Breakfast");
|
||||
|
||||
// Delete the category.
|
||||
await page.goto("/meals");
|
||||
const row = page.locator(".meal-category-row").filter({ hasText: "Breakfast" });
|
||||
await row.locator(".meal-category-delete").click();
|
||||
await expect(page).toHaveURL(/\/meals$/);
|
||||
|
||||
// The category is gone and the meal is now uncategorized.
|
||||
await expect(page.locator(".meal-category-name").filter({ hasText: "Breakfast" })).toHaveCount(0);
|
||||
const uncategorized = page.locator(".category-group").filter({ hasText: "Uncategorized" });
|
||||
await expect(uncategorized.locator(".list-card").filter({ hasText: "Pancakes" })).toBeVisible();
|
||||
});
|
||||
|
||||
test("a user can change a meal's category via the edit modal", async ({ page }) => {
|
||||
await registerAndLogin(page, "alice@example.com");
|
||||
await createMeal(page, "Beef Stew", "", "Beef");
|
||||
|
||||
await page.click('button:has-text("Edit")');
|
||||
const dialog = page.locator("dialog#meal-edit-modal");
|
||||
await expect(dialog).toBeVisible();
|
||||
await dialog.locator("#meal-edit-category").selectOption({ label: "Chicken" });
|
||||
await dialog.locator("#meal-edit-save").click();
|
||||
|
||||
await expect(page).toHaveURL(/\/meals\/\d+/);
|
||||
await page.goto("/meals");
|
||||
|
||||
const chicken = page.locator(".category-group").filter({
|
||||
has: page.locator(".category-heading", { hasText: "Chicken" }),
|
||||
});
|
||||
await expect(chicken.locator(".list-card").filter({ hasText: "Beef Stew" })).toBeVisible();
|
||||
const beef = page.locator(".category-group").filter({
|
||||
has: page.locator(".category-heading", { hasText: "Beef" }),
|
||||
});
|
||||
await expect(beef.locator(".list-card").filter({ hasText: "Beef Stew" })).toHaveCount(0);
|
||||
});
|
||||
|
||||
test("a meal's category is shown on its page", async ({ page }) => {
|
||||
await registerAndLogin(page, "alice@example.com");
|
||||
await createMeal(page, "Beef Stew", "", "Beef");
|
||||
|
||||
await expect(page.locator(".meal-category-label")).toHaveText("(Beef)");
|
||||
});
|
||||
|
||||
test("the add-meal picker groups meals by category", async ({ page }) => {
|
||||
await registerAndLogin(page, "alice@example.com");
|
||||
await createMeal(page, "Beef Stew", "", "Beef");
|
||||
await createMeal(page, "Chicken Curry", "", "Chicken");
|
||||
|
||||
// Go to a list to open the picker.
|
||||
await page.goto("/lists");
|
||||
await page.fill("#list-name", "Weekly shop");
|
||||
await page.click('button:has-text("Create list")');
|
||||
await expect(page).toHaveURL(/\/lists\/\d+/);
|
||||
|
||||
await page.click(".add-meal-button");
|
||||
const picker = page.locator(".meal-picker-backdrop");
|
||||
await expect(picker).toBeVisible();
|
||||
|
||||
const beef = picker.locator(".category-group").filter({ hasText: "Beef" });
|
||||
await expect(beef.locator(".meal-picker-button").filter({ hasText: "Beef Stew" })).toBeVisible();
|
||||
|
||||
const chicken = picker.locator(".category-group").filter({ hasText: "Chicken" });
|
||||
await expect(chicken.locator(".meal-picker-button").filter({ hasText: "Chicken Curry" })).toBeVisible();
|
||||
});
|
||||
@@ -0,0 +1,57 @@
|
||||
import { expect } from "@playwright/test";
|
||||
import { test } from "../fixtures";
|
||||
import { registerAndLogin, createList, createMeal } from "../helpers";
|
||||
|
||||
test("the meals page filters by name as you type", async ({ page }) => {
|
||||
await registerAndLogin(page, "alice@example.com");
|
||||
await createMeal(page, "Spaghetti Bolognese", "");
|
||||
await createMeal(page, "Chicken Curry", "");
|
||||
await createMeal(page, "Pancakes", "");
|
||||
|
||||
await page.goto("/meals");
|
||||
await expect(page.locator(".list-card").filter({ hasText: "Spaghetti Bolognese" })).toBeVisible();
|
||||
await expect(page.locator(".list-card").filter({ hasText: "Chicken Curry" })).toBeVisible();
|
||||
await expect(page.locator(".list-card").filter({ hasText: "Pancakes" })).toBeVisible();
|
||||
|
||||
// Type a query; only matching meals remain.
|
||||
await page.fill("#meal-search", "chicken");
|
||||
await expect(page.locator(".list-card").filter({ hasText: "Chicken Curry" })).toBeVisible();
|
||||
await expect(page.locator(".list-card").filter({ hasText: "Spaghetti Bolognese" })).toHaveCount(0);
|
||||
await expect(page.locator(".list-card").filter({ hasText: "Pancakes" })).toHaveCount(0);
|
||||
|
||||
// Clearing the search restores all meals.
|
||||
await page.fill("#meal-search", "");
|
||||
await expect(page.locator(".list-card").filter({ hasText: "Spaghetti Bolognese" })).toBeVisible();
|
||||
await expect(page.locator(".list-card").filter({ hasText: "Pancakes" })).toBeVisible();
|
||||
});
|
||||
|
||||
test("the meals page shows an empty state when nothing matches", async ({ page }) => {
|
||||
await registerAndLogin(page, "alice@example.com");
|
||||
await createMeal(page, "Spaghetti Bolognese", "");
|
||||
|
||||
await page.goto("/meals");
|
||||
await page.fill("#meal-search", "zzzz");
|
||||
await expect(page.locator(".meal-filter-empty")).toBeVisible();
|
||||
await expect(page.locator(".list-card")).toHaveCount(0);
|
||||
});
|
||||
|
||||
test("the add-meal picker filters meals as you type", async ({ page }) => {
|
||||
await registerAndLogin(page, "alice@example.com");
|
||||
await createMeal(page, "Spaghetti Bolognese", "");
|
||||
await createMeal(page, "Chicken Curry", "");
|
||||
await createList(page, "Weekly shop");
|
||||
|
||||
await page.click(".add-meal-button");
|
||||
const picker = page.locator(".meal-picker-backdrop");
|
||||
await expect(picker).toBeVisible();
|
||||
await expect(picker.locator(".meal-picker-button").filter({ hasText: "Spaghetti Bolognese" })).toBeVisible();
|
||||
await expect(picker.locator(".meal-picker-button").filter({ hasText: "Chicken Curry" })).toBeVisible();
|
||||
|
||||
await picker.locator(".meal-filter").fill("curry");
|
||||
await expect(picker.locator(".meal-picker-button").filter({ hasText: "Chicken Curry" })).toBeVisible();
|
||||
await expect(picker.locator(".meal-picker-button").filter({ hasText: "Spaghetti Bolognese" })).toHaveCount(0);
|
||||
|
||||
// The search box keeps focus and the modal stays open.
|
||||
await expect(picker.locator(".meal-filter")).toBeFocused();
|
||||
await expect(picker).toBeVisible();
|
||||
});
|
||||
@@ -32,6 +32,7 @@ test("a user can delete a meal", async ({ page }) => {
|
||||
await registerAndLogin(page, "alice@example.com");
|
||||
await createMeal(page, "Spaghetti Bolognese", "");
|
||||
|
||||
page.on("dialog", (dialog) => dialog.accept());
|
||||
await page.click('button:has-text("Delete")');
|
||||
await expect(page).toHaveURL(/\/meals$/);
|
||||
await expect(page.locator(".list-card").filter({ hasText: "Spaghetti Bolognese" })).toHaveCount(0);
|
||||
@@ -76,9 +77,7 @@ test("ingredients are grouped under their categories", async ({ page }) => {
|
||||
await createMeal(page, "Spaghetti Bolognese", "");
|
||||
|
||||
// Add an ingredient in the default "Produce" category.
|
||||
await page.fill("#ingredient-name", "Tomato");
|
||||
await page.selectOption("#ingredient-category", { label: "Produce" });
|
||||
await page.click("#add-ingredient-button");
|
||||
await addIngredient(page, "Tomato", "", "Produce");
|
||||
|
||||
// Add one without a category.
|
||||
await addIngredient(page, "Penne");
|
||||
|
||||
@@ -0,0 +1,169 @@
|
||||
import { expect } from "@playwright/test";
|
||||
import { test } from "../fixtures";
|
||||
import { registerAndLogin } from "../helpers";
|
||||
|
||||
/** Navigates to the rewards cards page. */
|
||||
async function gotoRewards(page: import("@playwright/test").Page) {
|
||||
await page.goto("/rewards");
|
||||
await expect(page.locator("h1")).toContainText("Rewards cards");
|
||||
}
|
||||
|
||||
/**
|
||||
* Adds a rewards card and lands back on the /rewards page with it rendered.
|
||||
*/
|
||||
async function addCard(
|
||||
page: import("@playwright/test").Page,
|
||||
storeName: string,
|
||||
number: string,
|
||||
symbology?: string,
|
||||
) {
|
||||
await page.fill("#store-name", storeName);
|
||||
await page.fill("#card-number", number);
|
||||
if (symbology) {
|
||||
await page.selectOption("#symbology", symbology);
|
||||
}
|
||||
await page.click('button:has-text("Add card")');
|
||||
await expect(page).toHaveURL(/\/rewards$/);
|
||||
const card = page.locator(".rewards-card").filter({ hasText: storeName });
|
||||
await expect(card).toBeVisible();
|
||||
return card;
|
||||
}
|
||||
|
||||
test("the rewards page shows an empty state before any cards are added", async ({
|
||||
page,
|
||||
}) => {
|
||||
await registerAndLogin(page, "alice@example.com");
|
||||
await gotoRewards(page);
|
||||
await expect(page.locator(".empty-state")).toContainText("No rewards cards yet");
|
||||
await expect(page.locator(".rewards-card")).toHaveCount(0);
|
||||
});
|
||||
|
||||
test("the Rewards link is available in the site navigation", async ({ page }) => {
|
||||
await registerAndLogin(page, "alice@example.com");
|
||||
const nav = page.locator(".site-nav");
|
||||
await expect(nav.locator('a[href="/rewards"]')).toHaveText("Rewards");
|
||||
});
|
||||
|
||||
test("a user can add a rewards card and see its barcode", async ({ page }) => {
|
||||
await registerAndLogin(page, "alice@example.com");
|
||||
await gotoRewards(page);
|
||||
|
||||
const card = await addCard(page, "Kroger", "606171584511340224537");
|
||||
|
||||
// The card renders an inline SVG barcode and the store's card number.
|
||||
await expect(card.locator(".rewards-barcode svg")).toBeVisible();
|
||||
await expect(card.locator(".rewards-number")).toHaveText("606171584511340224537");
|
||||
|
||||
// The barcode should be included via the embedded SVG (Code 128 set B→C mix),
|
||||
// not rendered client-side from scratch by an image.
|
||||
const svg = card.locator(".rewards-barcode svg");
|
||||
await expect(svg).toHaveAttribute("viewBox", /\d+ \d+/);
|
||||
});
|
||||
|
||||
test("a user can add a card as Code 39 and see its barcode", async ({ page }) => {
|
||||
await registerAndLogin(page, "alice@example.com");
|
||||
await gotoRewards(page);
|
||||
|
||||
const card = await addCard(page, "Safeway", "ABC123", "code39");
|
||||
await expect(card.locator(".rewards-barcode svg")).toBeVisible();
|
||||
});
|
||||
|
||||
test("multiple rewards cards are each rendered with their own barcode", async ({
|
||||
page,
|
||||
}) => {
|
||||
await registerAndLogin(page, "alice@example.com");
|
||||
await gotoRewards(page);
|
||||
|
||||
await addCard(page, "Kroger", "606171584511340224537");
|
||||
await addCard(page, "Safeway", "012345678901");
|
||||
|
||||
await expect(page.locator(".rewards-card")).toHaveCount(2);
|
||||
await expect(page.locator(".rewards-card").filter({ hasText: "Kroger" })).toBeVisible();
|
||||
await expect(page.locator(".rewards-card").filter({ hasText: "Safeway" })).toBeVisible();
|
||||
});
|
||||
|
||||
test("removing a rewards card prompts for confirmation and deletes on accept", async ({
|
||||
page,
|
||||
}) => {
|
||||
await registerAndLogin(page, "alice@example.com");
|
||||
await gotoRewards(page);
|
||||
await addCard(page, "Kroger", "606171584511340224537");
|
||||
|
||||
await expect(page).toHaveURL(/\/rewards$/);
|
||||
await expect(page.locator(".rewards-card")).toHaveCount(1);
|
||||
|
||||
page.on("dialog", (dialog) => dialog.accept());
|
||||
await page.click('button:has-text("Remove")');
|
||||
|
||||
// The card is deleted and the empty state returns.
|
||||
await expect(page.locator(".rewards-card")).toHaveCount(0);
|
||||
await expect(page.locator(".empty-state")).toContainText("No rewards cards yet");
|
||||
});
|
||||
|
||||
test("cancelling the remove confirmation keeps the rewards card", async ({
|
||||
page,
|
||||
}) => {
|
||||
await registerAndLogin(page, "alice@example.com");
|
||||
await gotoRewards(page);
|
||||
await addCard(page, "Kroger", "606171584511340224537");
|
||||
|
||||
await expect(page.locator(".rewards-card")).toHaveCount(1);
|
||||
|
||||
page.on("dialog", (dialog) => dialog.dismiss());
|
||||
await page.click('button:has-text("Remove")');
|
||||
|
||||
// The card must remain after cancelling.
|
||||
await expect(page.locator(".rewards-card")).toHaveCount(1);
|
||||
await expect(page.locator(".rewards-card").filter({ hasText: "Kroger" })).toBeVisible();
|
||||
});
|
||||
|
||||
test("a user can open a single-card scan view with only one barcode", async ({
|
||||
page,
|
||||
}) => {
|
||||
await registerAndLogin(page, "alice@example.com");
|
||||
await gotoRewards(page);
|
||||
await addCard(page, "Kroger", "606171584511340224537");
|
||||
await addCard(page, "Safeway", "012345678901");
|
||||
|
||||
// Click the Kroger card's barcode to open its focused scan view.
|
||||
await page
|
||||
.locator(".rewards-card")
|
||||
.filter({ hasText: "Kroger" })
|
||||
.locator(".rewards-card-link")
|
||||
.click();
|
||||
|
||||
await expect(page).toHaveURL(/\/rewards\/\d+/);
|
||||
// Only one barcode is rendered on the scan page.
|
||||
await expect(page.locator(".scan-barcode svg")).toHaveCount(1);
|
||||
await expect(page.locator(".scan-store")).toHaveText("Kroger");
|
||||
await expect(page.locator(".scan-card .rewards-number")).toHaveText(
|
||||
"606171584511340224537",
|
||||
);
|
||||
// The wake-lock script is loaded on the scan page.
|
||||
await expect(page.locator('script[src*="rewards.js"]')).toHaveCount(1);
|
||||
|
||||
// Back link returns to the list.
|
||||
await page.click('.scan-back');
|
||||
await expect(page).toHaveURL(/\/rewards$/);
|
||||
});
|
||||
|
||||
test("a scan view for another user's card is not accessible", async ({ page }) => {
|
||||
await registerAndLogin(page, "alice@example.com");
|
||||
await gotoRewards(page);
|
||||
await addCard(page, "Kroger", "606171584511340224537");
|
||||
|
||||
// Grab the card id from the URL of the scan view.
|
||||
await page
|
||||
.locator(".rewards-card-link")
|
||||
.click();
|
||||
const url = page.url();
|
||||
const cardId = url.split("/").pop();
|
||||
|
||||
// Sign out and sign in as a different user.
|
||||
await page.click('button:has-text("Sign out")');
|
||||
await registerAndLogin(page, "bob@example.com");
|
||||
|
||||
// Bob cannot view Alice's card.
|
||||
await page.goto(`/rewards/${cardId}`);
|
||||
await expect(page.locator(".scan-barcode svg")).toHaveCount(0);
|
||||
});
|
||||
@@ -20,12 +20,25 @@ test("a list updates live for another user via websocket", async ({ page, browse
|
||||
// Give the websocket connections a moment to establish.
|
||||
await page.waitForTimeout(500);
|
||||
|
||||
// Both start with an empty list.
|
||||
await expect(pageB.locator("#list-meta")).toHaveText("0 items left out of 0");
|
||||
|
||||
// User A adds an item.
|
||||
await addItem(page, "Apple", "2");
|
||||
|
||||
// It should appear on User B's page without any reload.
|
||||
await expect(pageB.locator(".item-row").filter({ hasText: "Apple" })).toBeVisible();
|
||||
await expect(pageB.locator(".item-row").filter({ hasText: "Apple" }).locator(".item-qty")).toHaveText("(2)");
|
||||
// The left/total count should also update live for User B.
|
||||
await expect(pageB.locator("#list-meta")).toHaveText("1 items left out of 1");
|
||||
|
||||
// User A removes the item.
|
||||
await page.locator(".item-actions-button").first().click();
|
||||
await page.locator("[id^='item-edit-delete']").click();
|
||||
|
||||
// The item and the count should update live on User B's page.
|
||||
await expect(pageB.locator(".item-row").filter({ hasText: "Apple" })).toHaveCount(0);
|
||||
await expect(pageB.locator("#list-meta")).toHaveText("0 items left out of 0");
|
||||
|
||||
await contextB.close();
|
||||
});
|
||||
|
||||
@@ -0,0 +1,39 @@
|
||||
# Set the Cargo.toml version, commit it, and tag the commit with that version.
|
||||
# Usage: just tag 1.2.3
|
||||
tag ver:
|
||||
#!/usr/bin/env bash
|
||||
set -euo pipefail
|
||||
|
||||
# Validate the version argument.
|
||||
if [[ ! "{{ver}}" =~ ^[0-9]+\.[0-9]+\.[0-9]+$ ]]; then
|
||||
echo "error: version must be in the form X.Y.Z (got '{{ver}}')" >&2
|
||||
exit 1
|
||||
fi
|
||||
|
||||
# Bump the version in Cargo.toml.
|
||||
sed -i -E "s/^version = \".*\"/version = \"{{ver}}\"/" Cargo.toml
|
||||
|
||||
# Regenerate Cargo.lock so it reflects the new version.
|
||||
cargo build
|
||||
|
||||
# Stage, commit, and tag.
|
||||
git add Cargo.toml Cargo.lock
|
||||
git commit -m "version {{ver}} [skip ci]"
|
||||
git tag "{{ver}}"
|
||||
git push
|
||||
git push --tags
|
||||
|
||||
# Run the Rust unit tests.
|
||||
# Usage: just test
|
||||
test:
|
||||
cargo test --all
|
||||
|
||||
# Format the Rust code.
|
||||
# Usage: just fmt
|
||||
fmt:
|
||||
cargo fmt --all
|
||||
|
||||
# Run the end-to-end Playwright tests.
|
||||
# Usage: just e2e
|
||||
e2e:
|
||||
cd e2e && npm test
|
||||
@@ -0,0 +1,10 @@
|
||||
CREATE TABLE meal_categories (
|
||||
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
||||
name TEXT NOT NULL UNIQUE COLLATE NOCASE,
|
||||
position INTEGER NOT NULL DEFAULT 0,
|
||||
created_at INTEGER NOT NULL
|
||||
);
|
||||
|
||||
ALTER TABLE meals ADD COLUMN category_id INTEGER REFERENCES meal_categories(id) ON DELETE SET NULL;
|
||||
|
||||
CREATE INDEX meals_category_idx ON meals(category_id);
|
||||
@@ -0,0 +1,12 @@
|
||||
CREATE TABLE list_meals (
|
||||
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
||||
list_id INTEGER NOT NULL REFERENCES lists(id) ON DELETE CASCADE,
|
||||
meal_id INTEGER REFERENCES meals(id) ON DELETE SET NULL,
|
||||
name TEXT NOT NULL,
|
||||
created_at INTEGER NOT NULL
|
||||
);
|
||||
|
||||
ALTER TABLE items ADD COLUMN list_meal_id INTEGER REFERENCES list_meals(id) ON DELETE CASCADE;
|
||||
|
||||
CREATE INDEX list_meals_list_idx ON list_meals(list_id);
|
||||
CREATE INDEX items_list_meal_idx ON items(list_meal_id);
|
||||
@@ -0,0 +1 @@
|
||||
ALTER TABLE lists ADD COLUMN archived_at INTEGER;
|
||||
@@ -0,0 +1,10 @@
|
||||
CREATE TABLE rewards_cards (
|
||||
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
||||
user_id INTEGER NOT NULL REFERENCES users(id) ON DELETE CASCADE,
|
||||
store_name TEXT NOT NULL,
|
||||
number TEXT NOT NULL,
|
||||
symbology TEXT NOT NULL DEFAULT 'code128',
|
||||
created_at INTEGER NOT NULL
|
||||
);
|
||||
|
||||
CREATE INDEX rewards_cards_user_idx ON rewards_cards(user_id);
|
||||
@@ -0,0 +1,85 @@
|
||||
use std::collections::HashMap;
|
||||
use std::sync::LazyLock;
|
||||
|
||||
use sha2::{Digest, Sha256};
|
||||
|
||||
/// A single static asset: its embedded bytes and a content hash used to
|
||||
/// version its URL.
|
||||
pub struct StaticAsset {
|
||||
pub data: &'static [u8],
|
||||
pub hash: String,
|
||||
}
|
||||
|
||||
/// A registry of the app's static assets, keyed by filename. Each asset's
|
||||
/// content hash is computed once on first use and cached, so the versioned URL
|
||||
/// changes automatically whenever the underlying file changes.
|
||||
pub struct StaticAssetStore {
|
||||
assets: HashMap<&'static str, StaticAsset>,
|
||||
}
|
||||
|
||||
impl StaticAssetStore {
|
||||
fn new(entries: &[(&'static str, &'static [u8])]) -> Self {
|
||||
let assets = entries
|
||||
.iter()
|
||||
.map(|(name, data)| {
|
||||
let hash = content_hash(data);
|
||||
(*name, StaticAsset { data, hash })
|
||||
})
|
||||
.collect();
|
||||
Self { assets }
|
||||
}
|
||||
|
||||
/// Looks up an asset by its filename (e.g. `"style.css"`).
|
||||
pub fn get(&self, name: &str) -> Option<&StaticAsset> {
|
||||
self.assets.get(name)
|
||||
}
|
||||
|
||||
/// Returns the versioned URL for an asset, e.g. `/static/style.css?v=<hash>`.
|
||||
pub fn url(&self, name: &str) -> Option<String> {
|
||||
self.assets
|
||||
.get(name)
|
||||
.map(|asset| format!("/static/{name}?v={}", asset.hash))
|
||||
}
|
||||
}
|
||||
|
||||
fn content_hash(data: &[u8]) -> String {
|
||||
let mut hasher = Sha256::new();
|
||||
hasher.update(data);
|
||||
hex::encode(hasher.finalize())
|
||||
}
|
||||
|
||||
/// Constructs a `StaticAssetStore` from `name => path` pairs, embedding each
|
||||
/// file's bytes at compile time via `include_bytes!`.
|
||||
macro_rules! static_assets {
|
||||
($($name:literal => $path:literal),* $(,)?) => {
|
||||
StaticAssetStore::new(&[
|
||||
$(($name, include_bytes!($path))),*
|
||||
])
|
||||
};
|
||||
}
|
||||
|
||||
/// The app's static assets, loaded once on first use.
|
||||
pub static STORE: LazyLock<StaticAssetStore> = LazyLock::new(|| {
|
||||
static_assets! {
|
||||
"style.css" => "../static/style.css",
|
||||
"passkey-login.js" => "../static/passkey-login.js",
|
||||
"passkey-register.js" => "../static/passkey-register.js",
|
||||
"password-toggle.js" => "../static/password-toggle.js",
|
||||
"rewards.js" => "../static/rewards.js",
|
||||
"htmx.min.js" => "../static/htmx.min.js",
|
||||
"idiomorph-ext.min.js" => "../static/idiomorph-ext.min.js",
|
||||
"htmx-ws.min.js" => "../static/htmx-ws.min.js",
|
||||
"favicon.ico" => "../static/favicon.ico",
|
||||
"favicon-32x32.png" => "../static/favicon-32x32.png",
|
||||
"apple-touch-icon.png" => "../static/apple-touch-icon.png",
|
||||
"logo.svg" => "../static/logo.svg",
|
||||
}
|
||||
});
|
||||
|
||||
/// Returns the versioned URL for a known asset, panicking if the name isn't
|
||||
/// registered (a programmer error, since these are compile-time constants).
|
||||
pub fn url(name: &str) -> String {
|
||||
STORE
|
||||
.url(name)
|
||||
.unwrap_or_else(|| panic!("unknown static asset: {name}"))
|
||||
}
|
||||
@@ -31,6 +31,9 @@ pub struct Passkey {
|
||||
pub user_id: i64,
|
||||
pub credential_id: String,
|
||||
pub credential: String,
|
||||
/// WebAuthn sign counter, persisted for future cloned-authenticator
|
||||
/// detection. Not currently read by application logic.
|
||||
#[allow(dead_code)]
|
||||
pub counter: i64,
|
||||
}
|
||||
|
||||
@@ -45,6 +48,10 @@ pub struct GroceryList {
|
||||
pub id: i64,
|
||||
pub name: String,
|
||||
pub revision: i64,
|
||||
/// Unix timestamp of when the list was created.
|
||||
pub created_at: i64,
|
||||
/// Unix timestamp of when the list was archived; `None` when active.
|
||||
pub archived_at: Option<i64>,
|
||||
}
|
||||
|
||||
#[derive(Clone, Debug)]
|
||||
@@ -65,11 +72,18 @@ pub struct Category {
|
||||
pub name: String,
|
||||
}
|
||||
|
||||
#[derive(Clone, Debug)]
|
||||
pub struct MealCategory {
|
||||
pub id: i64,
|
||||
pub name: String,
|
||||
}
|
||||
|
||||
#[derive(Clone, Debug)]
|
||||
pub struct Meal {
|
||||
pub id: i64,
|
||||
pub name: String,
|
||||
pub description: String,
|
||||
pub category_id: Option<i64>,
|
||||
pub ingredients: Vec<MealIngredient>,
|
||||
}
|
||||
|
||||
@@ -82,8 +96,36 @@ pub struct MealIngredient {
|
||||
pub category_id: Option<i64>,
|
||||
}
|
||||
|
||||
#[derive(Clone, Debug)]
|
||||
pub struct ListMeal {
|
||||
pub id: i64,
|
||||
/// The catalog meal this instance came from; `None` once the meal is deleted.
|
||||
#[allow(dead_code)]
|
||||
pub meal_id: Option<i64>,
|
||||
pub name: String,
|
||||
/// When the meal was added to the list.
|
||||
#[allow(dead_code)]
|
||||
pub created_at: i64,
|
||||
}
|
||||
|
||||
#[derive(Clone, Debug)]
|
||||
pub struct PresenceUser {
|
||||
pub user_id: i64,
|
||||
pub display_name: String,
|
||||
}
|
||||
|
||||
/// A stored rewards-card number that can be shown as a scannable barcode.
|
||||
#[derive(Clone, Debug)]
|
||||
pub struct RewardsCard {
|
||||
pub id: i64,
|
||||
/// The owner of this card.
|
||||
#[allow(dead_code)]
|
||||
pub user_id: i64,
|
||||
pub store_name: String,
|
||||
pub number: String,
|
||||
/// Symbology used to render the barcode (e.g. "code128", "code39").
|
||||
pub symbology: String,
|
||||
/// When the card was added.
|
||||
#[allow(dead_code)]
|
||||
pub created_at: i64,
|
||||
}
|
||||
|
||||
+442
-38
@@ -14,29 +14,28 @@ use axum::{
|
||||
routing::{get, post},
|
||||
};
|
||||
use futures_util::{SinkExt, StreamExt};
|
||||
use maud::PreEscaped;
|
||||
use serde::{Deserialize, de::DeserializeOwned};
|
||||
use thiserror::Error;
|
||||
use tower_http::trace::{DefaultMakeSpan, DefaultOnResponse, TraceLayer};
|
||||
use tracing::{Level, error, warn};
|
||||
|
||||
use crate::assets;
|
||||
use crate::domain::{DomainError, SessionUser};
|
||||
use crate::ports::{HubEvent, RealtimeNotifier};
|
||||
use crate::services::{AuthService, InvitationService, ListService, MealService};
|
||||
use crate::services::{
|
||||
AuthService, InvitationService, ListService, MealService, RewardsCardService,
|
||||
};
|
||||
use crate::views;
|
||||
use crate::webauthn::WebAuthnService;
|
||||
|
||||
/// The contents of `static/`, embedded into the binary at compile time so the
|
||||
/// app can be shipped as a single executable without a separate static directory.
|
||||
const STYLE_CSS: &[u8] = include_bytes!("../static/style.css");
|
||||
const PASSKEY_LOGIN_JS: &[u8] = include_bytes!("../static/passkey-login.js");
|
||||
const PASSKEY_REGISTER_JS: &[u8] = include_bytes!("../static/passkey-register.js");
|
||||
|
||||
#[derive(Clone)]
|
||||
pub struct AppState {
|
||||
pub auth: Arc<AuthService>,
|
||||
pub lists: Arc<ListService>,
|
||||
pub meals: Arc<MealService>,
|
||||
pub invitations: Arc<InvitationService>,
|
||||
pub rewards_cards: Arc<RewardsCardService>,
|
||||
pub webauthn: Arc<WebAuthnService>,
|
||||
pub realtime: Arc<dyn RealtimeNotifier>,
|
||||
pub cookie_secure: bool,
|
||||
@@ -51,6 +50,8 @@ pub enum AppError {
|
||||
BadRequest(String),
|
||||
#[error("not found")]
|
||||
NotFound,
|
||||
#[error("list is archived")]
|
||||
Archived,
|
||||
}
|
||||
|
||||
impl IntoResponse for AppError {
|
||||
@@ -70,6 +71,10 @@ impl IntoResponse for AppError {
|
||||
StatusCode::NOT_FOUND,
|
||||
views::error_page("404", "That page could not be found."),
|
||||
),
|
||||
AppError::Archived => status_html_response(
|
||||
StatusCode::CONFLICT,
|
||||
views::error_page("409", "This list is archived and cannot be modified."),
|
||||
),
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -94,7 +99,10 @@ pub fn build_router(state: AppState) -> Router {
|
||||
)
|
||||
.route("/account/password", post(change_password))
|
||||
.route("/lists", get(lists_page).post(create_list))
|
||||
.route("/archive", get(archive_page))
|
||||
.route("/lists/{list_id}", get(list_page))
|
||||
.route("/lists/{list_id}/archive", post(archive_list))
|
||||
.route("/lists/{list_id}/unarchive", post(unarchive_list))
|
||||
.route("/lists/{list_id}/items", post(add_item))
|
||||
.route("/lists/{list_id}/items/{item_id}/check", post(check_item))
|
||||
.route("/lists/{list_id}/items/{item_id}/edit", post(edit_item))
|
||||
@@ -103,6 +111,11 @@ pub fn build_router(state: AppState) -> Router {
|
||||
.route("/invitations", post(create_invitation))
|
||||
.route("/meals", get(meals_page).post(create_meal))
|
||||
.route("/meals/new", get(new_meal_page))
|
||||
.route("/meals/categories", post(create_meal_category))
|
||||
.route(
|
||||
"/meals/categories/{category_id}/delete",
|
||||
post(delete_meal_category),
|
||||
)
|
||||
.route("/meals/{meal_id}", get(meal_page))
|
||||
.route("/meals/{meal_id}/edit", post(edit_meal))
|
||||
.route("/meals/{meal_id}/delete", post(delete_meal))
|
||||
@@ -116,6 +129,18 @@ pub fn build_router(state: AppState) -> Router {
|
||||
post(delete_ingredient),
|
||||
)
|
||||
.route("/lists/{list_id}/add-meal", post(add_meal_to_list))
|
||||
.route(
|
||||
"/lists/{list_id}/meals/{list_meal_id}/remove",
|
||||
post(remove_meal_from_list),
|
||||
)
|
||||
.route(
|
||||
"/lists/{list_id}/carry",
|
||||
get(carry_over_modal).post(carry_meals),
|
||||
)
|
||||
.route("/lists/{list_id}/carry/meals", get(carry_source_meals))
|
||||
.route("/rewards", get(rewards_page).post(create_rewards_card))
|
||||
.route("/rewards/{card_id}", get(rewards_scan_page))
|
||||
.route("/rewards/{card_id}/delete", post(delete_rewards_card))
|
||||
.route("/lists/{list_id}/stream", get(list_stream))
|
||||
.route("/invite/{token}", get(invitation_page))
|
||||
.route("/invite/{token}/accept", post(accept_invitation))
|
||||
@@ -247,6 +272,14 @@ struct CategoryForm {
|
||||
csrf: String,
|
||||
}
|
||||
|
||||
#[derive(Debug, Deserialize)]
|
||||
struct RewardsCardForm {
|
||||
store_name: String,
|
||||
number: String,
|
||||
symbology: String,
|
||||
csrf: String,
|
||||
}
|
||||
|
||||
#[derive(Debug, Deserialize)]
|
||||
struct PasskeyRegisterStartForm {
|
||||
csrf: String,
|
||||
@@ -287,6 +320,8 @@ struct MealForm {
|
||||
name: String,
|
||||
#[serde(default)]
|
||||
description: String,
|
||||
#[serde(default)]
|
||||
category_id: Option<String>,
|
||||
csrf: String,
|
||||
}
|
||||
|
||||
@@ -308,9 +343,25 @@ struct AddMealForm {
|
||||
csrf: String,
|
||||
}
|
||||
|
||||
#[derive(Debug, Deserialize)]
|
||||
struct CarrySourceQuery {
|
||||
source: i64,
|
||||
}
|
||||
|
||||
#[derive(Debug, Deserialize)]
|
||||
struct CarryMealsForm {
|
||||
source_list_id: i64,
|
||||
/// Selected list_meal ids as a comma-separated string, since the form
|
||||
/// extractor does not coalesce repeated keys into a Vec.
|
||||
#[serde(default)]
|
||||
list_meal_ids: String,
|
||||
csrf: String,
|
||||
}
|
||||
|
||||
#[derive(Debug, Deserialize)]
|
||||
struct MealPickerQuery {
|
||||
picker: Option<i64>,
|
||||
q: Option<String>,
|
||||
}
|
||||
|
||||
async fn home() -> Redirect {
|
||||
@@ -318,14 +369,27 @@ async fn home() -> Redirect {
|
||||
}
|
||||
|
||||
/// Serves a file embedded in the binary from the `static/` folder.
|
||||
///
|
||||
/// Every asset is served with an immutable, long-lived cache header. Because
|
||||
/// the HTML references each asset under a URL that is versioned by its content
|
||||
/// hash, a changed file gets a new URL and the cache is never stale.
|
||||
async fn static_asset(Path(path): Path<String>) -> Response {
|
||||
let (mime, data) = match path.as_str() {
|
||||
"style.css" => ("text/css", STYLE_CSS),
|
||||
"passkey-login.js" => ("application/javascript", PASSKEY_LOGIN_JS),
|
||||
"passkey-register.js" => ("application/javascript", PASSKEY_REGISTER_JS),
|
||||
_ => return StatusCode::NOT_FOUND.into_response(),
|
||||
let Some(asset) = assets::STORE.get(&path) else {
|
||||
return StatusCode::NOT_FOUND.into_response();
|
||||
};
|
||||
([(header::CONTENT_TYPE, mime)], data).into_response()
|
||||
let mime = match path.rsplit('.').next() {
|
||||
Some("css") => "text/css",
|
||||
Some("ico") => "image/x-icon",
|
||||
Some("png") => "image/png",
|
||||
Some("svg") => "image/svg+xml",
|
||||
_ => "application/javascript",
|
||||
};
|
||||
let mut response = ([(header::CONTENT_TYPE, mime)], asset.data).into_response();
|
||||
response.headers_mut().insert(
|
||||
header::CACHE_CONTROL,
|
||||
HeaderValue::from_static("public, max-age=31536000, immutable"),
|
||||
);
|
||||
response
|
||||
}
|
||||
|
||||
async fn log_response_status(request: Request, next: Next) -> Response {
|
||||
@@ -479,7 +543,10 @@ async fn change_password(
|
||||
};
|
||||
|
||||
if form.new_password != form.confirm_password {
|
||||
return Ok(render(Some("New password and confirmation do not match."), false));
|
||||
return Ok(render(
|
||||
Some("New password and confirmation do not match."),
|
||||
false,
|
||||
));
|
||||
}
|
||||
|
||||
state
|
||||
@@ -577,13 +644,28 @@ async fn lists_page(
|
||||
user: CurrentUser,
|
||||
) -> Result<Response, AppError> {
|
||||
let lists = state.lists.list_summaries().await?;
|
||||
let archived = state.lists.list_archived_summaries().await?;
|
||||
let categories = state.lists.categories().await?;
|
||||
Ok(html_response(views::lists_page(
|
||||
&user.session.user,
|
||||
&lists,
|
||||
archived.len(),
|
||||
&categories,
|
||||
&user.session.csrf_token,
|
||||
)))
|
||||
}
|
||||
|
||||
async fn archive_page(
|
||||
State(state): State<AppState>,
|
||||
user: CurrentUser,
|
||||
) -> Result<Response, AppError> {
|
||||
let archived_lists = state.lists.list_archived_summaries().await?;
|
||||
Ok(html_response(views::archive_page(
|
||||
&user.session.user,
|
||||
&archived_lists,
|
||||
)))
|
||||
}
|
||||
|
||||
async fn create_list(
|
||||
State(state): State<AppState>,
|
||||
user: CurrentUser,
|
||||
@@ -608,17 +690,43 @@ async fn list_page(
|
||||
let access = require_list(&state, list_id).await?;
|
||||
let items = state.lists.items(list_id).await?;
|
||||
let categories = state.lists.categories().await?;
|
||||
let list_meals = state.meals.list_meals_on_list(list_id).await?;
|
||||
let presence = state.realtime.presence(list_id).await;
|
||||
Ok(html_response(views::list_page(
|
||||
&user.session.user,
|
||||
&access,
|
||||
&items,
|
||||
&categories,
|
||||
&list_meals,
|
||||
&presence,
|
||||
&user.session.csrf_token,
|
||||
)))
|
||||
}
|
||||
|
||||
async fn archive_list(
|
||||
State(state): State<AppState>,
|
||||
user: CurrentUser,
|
||||
Path(list_id): Path<i64>,
|
||||
LoggedForm(form): LoggedForm<CsrfForm>,
|
||||
) -> Result<Response, AppError> {
|
||||
verify_csrf(&user, &form.csrf)?;
|
||||
require_list(&state, list_id).await?;
|
||||
state.lists.archive_list(list_id).await?;
|
||||
Ok(Redirect::to("/lists").into_response())
|
||||
}
|
||||
|
||||
async fn unarchive_list(
|
||||
State(state): State<AppState>,
|
||||
user: CurrentUser,
|
||||
Path(list_id): Path<i64>,
|
||||
LoggedForm(form): LoggedForm<CsrfForm>,
|
||||
) -> Result<Response, AppError> {
|
||||
verify_csrf(&user, &form.csrf)?;
|
||||
require_list(&state, list_id).await?;
|
||||
state.lists.unarchive_list(list_id).await?;
|
||||
Ok(Redirect::to("/lists").into_response())
|
||||
}
|
||||
|
||||
async fn add_item(
|
||||
State(state): State<AppState>,
|
||||
user: CurrentUser,
|
||||
@@ -626,7 +734,7 @@ async fn add_item(
|
||||
LoggedForm(form): LoggedForm<ItemForm>,
|
||||
) -> Result<Response, AppError> {
|
||||
verify_csrf(&user, &form.csrf)?;
|
||||
require_list(&state, list_id).await?;
|
||||
require_mutable_list(&state, list_id).await?;
|
||||
let name = form.name.trim().to_owned();
|
||||
let quantity = form.quantity.trim().to_owned();
|
||||
let note = form.note.trim().to_owned();
|
||||
@@ -650,7 +758,7 @@ async fn check_item(
|
||||
LoggedForm(form): LoggedForm<CheckForm>,
|
||||
) -> Result<Response, AppError> {
|
||||
verify_csrf(&user, &form.csrf)?;
|
||||
require_list(&state, list_id).await?;
|
||||
require_mutable_list(&state, list_id).await?;
|
||||
let checked = match form.checked.as_str() {
|
||||
"1" | "true" => true,
|
||||
"0" | "false" => false,
|
||||
@@ -670,7 +778,7 @@ async fn edit_item(
|
||||
LoggedForm(form): LoggedForm<ItemForm>,
|
||||
) -> Result<Response, AppError> {
|
||||
verify_csrf(&user, &form.csrf)?;
|
||||
require_list(&state, list_id).await?;
|
||||
require_mutable_list(&state, list_id).await?;
|
||||
let name = form.name.trim().to_owned();
|
||||
if name.is_empty() || name.chars().count() > 120 {
|
||||
return Err(AppError::BadRequest(
|
||||
@@ -698,7 +806,7 @@ async fn delete_item(
|
||||
LoggedForm(form): LoggedForm<CsrfForm>,
|
||||
) -> Result<Response, AppError> {
|
||||
verify_csrf(&user, &form.csrf)?;
|
||||
require_list(&state, list_id).await?;
|
||||
require_mutable_list(&state, list_id).await?;
|
||||
state.lists.delete_item(list_id, item_id).await?;
|
||||
list_fragment_response(&state, &user, list_id).await
|
||||
}
|
||||
@@ -719,26 +827,178 @@ async fn create_category(
|
||||
Ok(Redirect::to("/lists").into_response())
|
||||
}
|
||||
|
||||
async fn create_meal_category(
|
||||
State(state): State<AppState>,
|
||||
user: CurrentUser,
|
||||
LoggedForm(form): LoggedForm<CategoryForm>,
|
||||
) -> Result<Response, AppError> {
|
||||
verify_csrf(&user, &form.csrf)?;
|
||||
let name = form.name.trim().to_owned();
|
||||
if name.is_empty() || name.chars().count() > 60 {
|
||||
return Err(AppError::BadRequest(
|
||||
"Category names must be between 1 and 60 characters.".into(),
|
||||
));
|
||||
}
|
||||
state.meals.create_meal_category(name).await?;
|
||||
Ok(Redirect::to("/meals").into_response())
|
||||
}
|
||||
|
||||
async fn delete_meal_category(
|
||||
State(state): State<AppState>,
|
||||
user: CurrentUser,
|
||||
Path(category_id): Path<i64>,
|
||||
LoggedForm(form): LoggedForm<CsrfForm>,
|
||||
) -> Result<Response, AppError> {
|
||||
verify_csrf(&user, &form.csrf)?;
|
||||
state.meals.delete_meal_category(category_id).await?;
|
||||
Ok(Redirect::to("/meals").into_response())
|
||||
}
|
||||
|
||||
async fn rewards_page(
|
||||
State(state): State<AppState>,
|
||||
user: CurrentUser,
|
||||
) -> Result<Response, AppError> {
|
||||
let cards = state.rewards_cards.list_cards(user.session.user.id).await?;
|
||||
Ok(html_response(views::rewards_page(
|
||||
&user.session.user,
|
||||
&cards,
|
||||
&user.session.csrf_token,
|
||||
)))
|
||||
}
|
||||
|
||||
async fn rewards_scan_page(
|
||||
State(state): State<AppState>,
|
||||
user: CurrentUser,
|
||||
Path(card_id): Path<i64>,
|
||||
) -> Result<Response, AppError> {
|
||||
let card = state
|
||||
.rewards_cards
|
||||
.get_card(user.session.user.id, card_id)
|
||||
.await?
|
||||
.ok_or(AppError::NotFound)?;
|
||||
Ok(html_response(views::rewards_scan_page(
|
||||
&user.session.user,
|
||||
&card,
|
||||
)))
|
||||
}
|
||||
|
||||
async fn create_rewards_card(
|
||||
State(state): State<AppState>,
|
||||
user: CurrentUser,
|
||||
LoggedForm(form): LoggedForm<RewardsCardForm>,
|
||||
) -> Result<Response, AppError> {
|
||||
verify_csrf(&user, &form.csrf)?;
|
||||
let store_name = form.store_name.trim().to_owned();
|
||||
let number = form.number.trim().to_owned();
|
||||
let symbology = normalize_symbology(&form.symbology);
|
||||
if store_name.is_empty() || store_name.chars().count() > 60 {
|
||||
return Err(AppError::BadRequest(
|
||||
"Store names must be between 1 and 60 characters.".into(),
|
||||
));
|
||||
}
|
||||
if number.is_empty() || number.chars().count() > 80 {
|
||||
return Err(AppError::BadRequest(
|
||||
"Card numbers must be between 1 and 80 characters.".into(),
|
||||
));
|
||||
}
|
||||
state
|
||||
.rewards_cards
|
||||
.create_card(user.session.user.id, store_name, number, symbology)
|
||||
.await?;
|
||||
Ok(Redirect::to("/rewards").into_response())
|
||||
}
|
||||
|
||||
async fn delete_rewards_card(
|
||||
State(state): State<AppState>,
|
||||
user: CurrentUser,
|
||||
Path(card_id): Path<i64>,
|
||||
LoggedForm(form): LoggedForm<CsrfForm>,
|
||||
) -> Result<Response, AppError> {
|
||||
verify_csrf(&user, &form.csrf)?;
|
||||
state
|
||||
.rewards_cards
|
||||
.delete_card(user.session.user.id, card_id)
|
||||
.await?;
|
||||
Ok(Redirect::to("/rewards").into_response())
|
||||
}
|
||||
|
||||
/// Normalizes a submitted symbology value to a known barcode type, falling
|
||||
/// back to Code 128 for unknown or empty values.
|
||||
fn normalize_symbology(value: &str) -> String {
|
||||
match value.trim().to_ascii_lowercase().as_str() {
|
||||
"code39" => "code39".to_owned(),
|
||||
_ => "code128".to_owned(),
|
||||
}
|
||||
}
|
||||
|
||||
async fn meals_page(
|
||||
State(state): State<AppState>,
|
||||
user: CurrentUser,
|
||||
Query(query): Query<MealPickerQuery>,
|
||||
headers: HeaderMap,
|
||||
) -> Result<Response, AppError> {
|
||||
let meals = state.meals.list_meals().await?;
|
||||
let q = query.q.clone().unwrap_or_default();
|
||||
let meals = state.meals.list_meals(&q).await?;
|
||||
let meal_categories = state.meals.list_meal_categories().await?;
|
||||
let is_htmx = headers
|
||||
.get("hx-request")
|
||||
.and_then(|value| value.to_str().ok())
|
||||
.is_some_and(|value| value == "true");
|
||||
// A boosted navigation (e.g. the category form's POST redirect) also sends
|
||||
// `HX-Request: true`, but must render the full page, not just the results
|
||||
// fragment. Only a live search (an `hx-get` on the filter box) swaps the
|
||||
// fragment. htmx marks boosted requests with `HX-Boosted: true`.
|
||||
let is_boosted = headers
|
||||
.get("hx-boosted")
|
||||
.and_then(|value| value.to_str().ok())
|
||||
.is_some_and(|value| value == "true");
|
||||
if let Some(list_id) = query.picker {
|
||||
return Ok(html_response(views::meal_picker(
|
||||
if query.q.is_some() {
|
||||
// Live search inside the picker: swap only the grouped rows, keeping
|
||||
// the modal and search box focused. The initial picker load has no
|
||||
// `q`, so it falls through to the full modal below.
|
||||
return Ok(html_response(views::meal_picker_results(
|
||||
&meals,
|
||||
&meal_categories,
|
||||
list_id,
|
||||
&user.session.csrf_token,
|
||||
)));
|
||||
}
|
||||
let picker = views::meal_picker(
|
||||
&meals,
|
||||
&meal_categories,
|
||||
list_id,
|
||||
&user.session.csrf_token,
|
||||
&q,
|
||||
);
|
||||
return Ok(html_response(picker));
|
||||
}
|
||||
if is_htmx && !is_boosted {
|
||||
// Live search on the meals page: swap only the grouped results.
|
||||
return Ok(html_response(views::meal_results(
|
||||
&meals,
|
||||
&meal_categories,
|
||||
&q,
|
||||
)));
|
||||
}
|
||||
Ok(html_response(views::meals_page(&user.session.user, &meals)))
|
||||
Ok(html_response(views::meals_page(
|
||||
&user.session.user,
|
||||
&meals,
|
||||
&meal_categories,
|
||||
&user.session.csrf_token,
|
||||
&q,
|
||||
)))
|
||||
}
|
||||
|
||||
async fn new_meal_page(user: CurrentUser) -> Result<Response, AppError> {
|
||||
async fn new_meal_page(
|
||||
State(state): State<AppState>,
|
||||
user: CurrentUser,
|
||||
) -> Result<Response, AppError> {
|
||||
let meal_categories = state.meals.list_meal_categories().await?;
|
||||
Ok(html_response(views::meal_form_page(
|
||||
&user.session.user,
|
||||
None,
|
||||
&meal_categories,
|
||||
&user.session.csrf_token,
|
||||
)))
|
||||
}
|
||||
@@ -757,7 +1017,11 @@ async fn create_meal(
|
||||
}
|
||||
let meal = state
|
||||
.meals
|
||||
.create_meal(name, form.description.trim().to_owned())
|
||||
.create_meal(
|
||||
name,
|
||||
form.description.trim().to_owned(),
|
||||
parse_category_id(form.category_id),
|
||||
)
|
||||
.await?;
|
||||
Ok(Redirect::to(&format!("/meals/{}", meal.id)).into_response())
|
||||
}
|
||||
@@ -773,10 +1037,12 @@ async fn meal_page(
|
||||
.await?
|
||||
.ok_or(AppError::NotFound)?;
|
||||
let categories = state.lists.categories().await?;
|
||||
let meal_categories = state.meals.list_meal_categories().await?;
|
||||
Ok(html_response(views::meal_page(
|
||||
&user.session.user,
|
||||
&meal,
|
||||
&categories,
|
||||
&meal_categories,
|
||||
&user.session.csrf_token,
|
||||
)))
|
||||
}
|
||||
@@ -796,7 +1062,12 @@ async fn edit_meal(
|
||||
}
|
||||
state
|
||||
.meals
|
||||
.update_meal(meal_id, name, form.description.trim().to_owned())
|
||||
.update_meal(
|
||||
meal_id,
|
||||
name,
|
||||
form.description.trim().to_owned(),
|
||||
parse_category_id(form.category_id),
|
||||
)
|
||||
.await?;
|
||||
Ok(Redirect::to(&format!("/meals/{meal_id}")).into_response())
|
||||
}
|
||||
@@ -886,11 +1157,107 @@ async fn add_meal_to_list(
|
||||
LoggedForm(form): LoggedForm<AddMealForm>,
|
||||
) -> Result<Response, AppError> {
|
||||
verify_csrf(&user, &form.csrf)?;
|
||||
require_list(&state, list_id).await?;
|
||||
require_mutable_list(&state, list_id).await?;
|
||||
state.meals.add_meal_to_list(form.meal_id, list_id).await?;
|
||||
list_fragment_response(&state, &user, list_id).await
|
||||
}
|
||||
|
||||
async fn remove_meal_from_list(
|
||||
State(state): State<AppState>,
|
||||
user: CurrentUser,
|
||||
Path((list_id, list_meal_id)): Path<(i64, i64)>,
|
||||
LoggedForm(form): LoggedForm<CsrfForm>,
|
||||
) -> Result<Response, AppError> {
|
||||
verify_csrf(&user, &form.csrf)?;
|
||||
require_mutable_list(&state, list_id).await?;
|
||||
state
|
||||
.meals
|
||||
.remove_meal_from_list(list_id, list_meal_id)
|
||||
.await?;
|
||||
list_fragment_response(&state, &user, list_id).await
|
||||
}
|
||||
|
||||
/// Renders the carry-over modal: a picker of active source lists (newest first,
|
||||
/// excluding the current list) that the user can import meals from.
|
||||
async fn carry_over_modal(
|
||||
State(state): State<AppState>,
|
||||
_user: CurrentUser,
|
||||
Path(dest_list_id): Path<i64>,
|
||||
) -> Result<Response, AppError> {
|
||||
require_mutable_list(&state, dest_list_id).await?;
|
||||
let lists = state.lists.list_summaries().await?;
|
||||
let sources: Vec<_> = lists
|
||||
.into_iter()
|
||||
.filter(|list| list.id != dest_list_id)
|
||||
.collect();
|
||||
Ok(html_response(views::carry_over_modal(
|
||||
&sources,
|
||||
dest_list_id,
|
||||
)))
|
||||
}
|
||||
|
||||
/// Renders the selectable meal rows for a chosen source list inside the carry
|
||||
/// modal.
|
||||
async fn carry_source_meals(
|
||||
State(state): State<AppState>,
|
||||
user: CurrentUser,
|
||||
Path(dest_list_id): Path<i64>,
|
||||
Query(query): Query<CarrySourceQuery>,
|
||||
) -> Result<Response, AppError> {
|
||||
require_mutable_list(&state, dest_list_id).await?;
|
||||
let source = require_list(&state, query.source).await?;
|
||||
if source.id == dest_list_id {
|
||||
return Err(AppError::BadRequest(
|
||||
"Cannot carry meals from a list into itself.".into(),
|
||||
));
|
||||
}
|
||||
let list_meals = state.meals.list_meals_on_list(source.id).await?;
|
||||
Ok(html_response(views::carry_source_meals(
|
||||
&list_meals,
|
||||
source.id,
|
||||
dest_list_id,
|
||||
&user.session.csrf_token,
|
||||
)))
|
||||
}
|
||||
|
||||
/// Copies the selected meals from a source list into the current list without
|
||||
/// re-adding their ingredients.
|
||||
async fn carry_meals(
|
||||
State(state): State<AppState>,
|
||||
user: CurrentUser,
|
||||
Path(dest_list_id): Path<i64>,
|
||||
LoggedForm(form): LoggedForm<CarryMealsForm>,
|
||||
) -> Result<Response, AppError> {
|
||||
verify_csrf(&user, &form.csrf)?;
|
||||
require_mutable_list(&state, dest_list_id).await?;
|
||||
let source = require_list(&state, form.source_list_id).await?;
|
||||
if source.id == dest_list_id {
|
||||
return Err(AppError::BadRequest(
|
||||
"Cannot carry meals from a list into itself.".into(),
|
||||
));
|
||||
}
|
||||
if form.list_meal_ids.is_empty() {
|
||||
return Err(AppError::BadRequest(
|
||||
"Select at least one meal to carry over.".into(),
|
||||
));
|
||||
}
|
||||
let list_meal_ids: Vec<i64> = form
|
||||
.list_meal_ids
|
||||
.split(',')
|
||||
.filter_map(|id| id.trim().parse().ok())
|
||||
.collect();
|
||||
if list_meal_ids.is_empty() {
|
||||
return Err(AppError::BadRequest(
|
||||
"Select at least one meal to carry over.".into(),
|
||||
));
|
||||
}
|
||||
state
|
||||
.meals
|
||||
.carry_meals_to_list(source.id, dest_list_id, &list_meal_ids)
|
||||
.await?;
|
||||
list_fragment_response(&state, &user, dest_list_id).await
|
||||
}
|
||||
|
||||
async fn create_invitation(
|
||||
State(state): State<AppState>,
|
||||
user: CurrentUser,
|
||||
@@ -1055,11 +1422,16 @@ async fn websocket_snapshot(
|
||||
let access = require_list(state, list_id).await?;
|
||||
let items = state.lists.items(list_id).await?;
|
||||
let categories = state.lists.categories().await?;
|
||||
Ok(
|
||||
views::live_list_fragments(&access, &items, &categories, &user.session.csrf_token)
|
||||
.into_string()
|
||||
+ &views::presence_panel(presence, true).into_string(),
|
||||
let list_meals = state.meals.list_meals_on_list(list_id).await?;
|
||||
Ok(views::live_list_fragments(
|
||||
&access,
|
||||
&items,
|
||||
&categories,
|
||||
&list_meals,
|
||||
&user.session.csrf_token,
|
||||
)
|
||||
.into_string()
|
||||
+ &views::presence_panel(presence, true).into_string())
|
||||
}
|
||||
|
||||
async fn websocket_list_update(
|
||||
@@ -1070,10 +1442,15 @@ async fn websocket_list_update(
|
||||
let access = require_list(state, list_id).await?;
|
||||
let items = state.lists.items(list_id).await?;
|
||||
let categories = state.lists.categories().await?;
|
||||
Ok(
|
||||
views::live_list_fragments(&access, &items, &categories, &user.session.csrf_token)
|
||||
.into_string(),
|
||||
let list_meals = state.meals.list_meals_on_list(list_id).await?;
|
||||
Ok(views::live_list_fragments(
|
||||
&access,
|
||||
&items,
|
||||
&categories,
|
||||
&list_meals,
|
||||
&user.session.csrf_token,
|
||||
)
|
||||
.into_string())
|
||||
}
|
||||
|
||||
async fn list_fragment_response(
|
||||
@@ -1084,12 +1461,26 @@ async fn list_fragment_response(
|
||||
let access = require_list(state, list_id).await?;
|
||||
let items = state.lists.items(list_id).await?;
|
||||
let categories = state.lists.categories().await?;
|
||||
Ok(html_response(views::list_items_fragment(
|
||||
&access,
|
||||
&items,
|
||||
&categories,
|
||||
&user.session.csrf_token,
|
||||
false,
|
||||
let list_meals = state.meals.list_meals_on_list(list_id).await?;
|
||||
let editable = access.archived_at.is_none();
|
||||
Ok(html_response(PreEscaped(
|
||||
views::list_items_fragment(
|
||||
&access,
|
||||
&items,
|
||||
&categories,
|
||||
&user.session.csrf_token,
|
||||
false,
|
||||
editable,
|
||||
)
|
||||
.into_string()
|
||||
+ &views::list_meals_panel(
|
||||
&list_meals,
|
||||
list_id,
|
||||
&user.session.csrf_token,
|
||||
true,
|
||||
editable,
|
||||
)
|
||||
.into_string(),
|
||||
)))
|
||||
}
|
||||
|
||||
@@ -1104,6 +1495,19 @@ async fn require_list(
|
||||
.ok_or(AppError::NotFound)
|
||||
}
|
||||
|
||||
/// Like [`require_list`], but also rejects archived lists so they stay
|
||||
/// immutable until restored.
|
||||
async fn require_mutable_list(
|
||||
state: &AppState,
|
||||
list_id: i64,
|
||||
) -> Result<crate::domain::GroceryList, AppError> {
|
||||
let list = require_list(state, list_id).await?;
|
||||
if list.archived_at.is_some() {
|
||||
return Err(AppError::Archived);
|
||||
}
|
||||
Ok(list)
|
||||
}
|
||||
|
||||
async fn optional_user(
|
||||
state: &AppState,
|
||||
headers: &HeaderMap,
|
||||
|
||||
+33
-7
@@ -1,3 +1,4 @@
|
||||
mod assets;
|
||||
mod domain;
|
||||
mod http;
|
||||
mod hub;
|
||||
@@ -19,16 +20,20 @@ use tracing::{info, warn};
|
||||
use crate::http::{AppState, build_router};
|
||||
use crate::hub::InMemoryHub;
|
||||
use crate::ports::{
|
||||
CategoryRepository, InvitationRepository, ItemRepository, ListRepository,
|
||||
MealIngredientRepository, MealRepository, PasskeyRepository, PasswordHasher, RealtimeNotifier,
|
||||
SessionRepository, TokenGenerator, UserRepository,
|
||||
CategoryRepository, InvitationRepository, ItemRepository, ListMealRepository, ListRepository,
|
||||
MealCategoryRepository, MealIngredientRepository, MealRepository, PasskeyRepository,
|
||||
PasswordHasher, RealtimeNotifier, RewardsCardRepository, SessionRepository, TokenGenerator,
|
||||
UserRepository,
|
||||
};
|
||||
use crate::security::{Argon2PasswordHasher, RandomTokenGenerator};
|
||||
use crate::services::{AuthService, InvitationService, ListService, MealService, RegistrationMode};
|
||||
use crate::services::{
|
||||
AuthService, InvitationService, ListService, MealService, RegistrationMode, RewardsCardService,
|
||||
};
|
||||
use crate::sqlite::{
|
||||
SqliteCategoryRepository, SqliteDatabase, SqliteInvitationRepository, SqliteItemRepository,
|
||||
SqliteListRepository, SqliteMealIngredientRepository, SqliteMealRepository,
|
||||
SqlitePasskeyRepository, SqliteSessionRepository, SqliteUserRepository,
|
||||
SqliteListMealRepository, SqliteListRepository, SqliteMealCategoryRepository,
|
||||
SqliteMealIngredientRepository, SqliteMealRepository, SqlitePasskeyRepository,
|
||||
SqliteRewardsCardRepository, SqliteSessionRepository, SqliteUserRepository,
|
||||
};
|
||||
use crate::webauthn::{AppWebauthnConfig, WebAuthnService};
|
||||
|
||||
@@ -41,6 +46,9 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
|
||||
.init();
|
||||
|
||||
let database_path = env::var("DATABASE_PATH").unwrap_or_else(|_| "sustenance.db".into());
|
||||
let database_in_memory = env::var("DATABASE_IN_MEMORY")
|
||||
.map(|value| value == "1" || value.eq_ignore_ascii_case("true"))
|
||||
.unwrap_or(false);
|
||||
let bind_address = env::var("BIND_ADDRESS").unwrap_or_else(|_| "127.0.0.1:3000".into());
|
||||
// For loopback hosts, advertise `localhost` so WebAuthn works locally (browsers
|
||||
// reject IP addresses as RP IDs). Access the app via http://localhost:PORT.
|
||||
@@ -68,17 +76,24 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
|
||||
};
|
||||
|
||||
// Build the adapters (ports) and wire them into application services.
|
||||
let db = SqliteDatabase::open(&database_path).await?;
|
||||
let db = if database_in_memory {
|
||||
SqliteDatabase::open_in_memory().await?
|
||||
} else {
|
||||
SqliteDatabase::open(&database_path).await?
|
||||
};
|
||||
let users: Arc<dyn UserRepository> = Arc::new(SqliteUserRepository);
|
||||
let sessions: Arc<dyn SessionRepository> = Arc::new(SqliteSessionRepository);
|
||||
let lists: Arc<dyn ListRepository> = Arc::new(SqliteListRepository);
|
||||
let categories: Arc<dyn CategoryRepository> = Arc::new(SqliteCategoryRepository);
|
||||
let items: Arc<dyn ItemRepository> = Arc::new(SqliteItemRepository);
|
||||
let list_meals: Arc<dyn ListMealRepository> = Arc::new(SqliteListMealRepository);
|
||||
let meals: Arc<dyn MealRepository> = Arc::new(SqliteMealRepository);
|
||||
let meal_ingredients: Arc<dyn MealIngredientRepository> =
|
||||
Arc::new(SqliteMealIngredientRepository);
|
||||
let meal_categories: Arc<dyn MealCategoryRepository> = Arc::new(SqliteMealCategoryRepository);
|
||||
let invitations: Arc<dyn InvitationRepository> = Arc::new(SqliteInvitationRepository);
|
||||
let passkeys: Arc<dyn PasskeyRepository> = Arc::new(SqlitePasskeyRepository);
|
||||
let rewards_cards: Arc<dyn RewardsCardRepository> = Arc::new(SqliteRewardsCardRepository);
|
||||
let hasher: Arc<dyn PasswordHasher> = Arc::new(Argon2PasswordHasher);
|
||||
let tokens: Arc<dyn TokenGenerator> = Arc::new(RandomTokenGenerator);
|
||||
let realtime: Arc<dyn RealtimeNotifier> = Arc::new(InMemoryHub::default());
|
||||
@@ -103,12 +118,18 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
|
||||
Arc::clone(&invitations),
|
||||
Arc::clone(&tokens),
|
||||
));
|
||||
let rewards_cards_service = Arc::new(RewardsCardService::new(
|
||||
db.clone(),
|
||||
Arc::clone(&rewards_cards),
|
||||
));
|
||||
let meals_service = Arc::new(MealService::new(
|
||||
db.clone(),
|
||||
Arc::clone(&meals),
|
||||
Arc::clone(&meal_ingredients),
|
||||
Arc::clone(&meal_categories),
|
||||
Arc::clone(&lists),
|
||||
Arc::clone(&items),
|
||||
Arc::clone(&list_meals),
|
||||
Arc::clone(&realtime),
|
||||
));
|
||||
|
||||
@@ -144,6 +165,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
|
||||
lists: lists_service,
|
||||
meals: meals_service,
|
||||
invitations: invitations_service,
|
||||
rewards_cards: rewards_cards_service,
|
||||
webauthn: webauthn_service,
|
||||
realtime,
|
||||
cookie_secure,
|
||||
@@ -158,6 +180,10 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
|
||||
.with_graceful_shutdown(shutdown_signal())
|
||||
.await?;
|
||||
info!("shutdown complete; closing database");
|
||||
// Explicitly close the pool so SQLite can checkpoint and remove the
|
||||
// WAL/SHM sidecar files. Without this, the pool's background close task
|
||||
// races with process exit and the sidecars can be left behind.
|
||||
db.close().await;
|
||||
Ok(())
|
||||
}
|
||||
|
||||
|
||||
+95
-3
@@ -2,8 +2,8 @@ use async_trait::async_trait;
|
||||
use sqlx::SqliteConnection;
|
||||
|
||||
use crate::domain::{
|
||||
Category, DomainResult, GroceryList, Item, Meal, MealIngredient, Passkey, PresenceUser,
|
||||
SessionUser, User,
|
||||
Category, DomainResult, GroceryList, Item, ListMeal, Meal, MealCategory, MealIngredient,
|
||||
Passkey, PresenceUser, RewardsCard, SessionUser, User,
|
||||
};
|
||||
|
||||
/// Repositories take `&mut SqliteConnection` (which a `Transaction` derefs to),
|
||||
@@ -88,6 +88,10 @@ pub trait SessionRepository: Send + Sync {
|
||||
#[async_trait]
|
||||
pub trait ListRepository: Send + Sync {
|
||||
async fn list_summaries(&self, txn: &mut SqliteConnection) -> DomainResult<Vec<GroceryList>>;
|
||||
async fn list_archived_summaries(
|
||||
&self,
|
||||
txn: &mut SqliteConnection,
|
||||
) -> DomainResult<Vec<GroceryList>>;
|
||||
async fn create_list(
|
||||
&self,
|
||||
txn: &mut SqliteConnection,
|
||||
@@ -98,6 +102,12 @@ pub trait ListRepository: Send + Sync {
|
||||
txn: &mut SqliteConnection,
|
||||
list_id: i64,
|
||||
) -> DomainResult<Option<GroceryList>>;
|
||||
async fn set_archived(
|
||||
&self,
|
||||
txn: &mut SqliteConnection,
|
||||
list_id: i64,
|
||||
archived: bool,
|
||||
) -> DomainResult<()>;
|
||||
}
|
||||
|
||||
#[async_trait]
|
||||
@@ -113,6 +123,9 @@ pub struct NewItem {
|
||||
pub quantity: String,
|
||||
pub note: String,
|
||||
pub category_id: Option<i64>,
|
||||
/// When set, links this item to the `list_meals` row it came from, so the
|
||||
/// item is removed together with that meal instance.
|
||||
pub list_meal_id: Option<i64>,
|
||||
}
|
||||
|
||||
#[async_trait]
|
||||
@@ -158,6 +171,38 @@ pub trait ItemRepository: Send + Sync {
|
||||
) -> DomainResult<i64>;
|
||||
}
|
||||
|
||||
#[async_trait]
|
||||
pub trait ListMealRepository: Send + Sync {
|
||||
async fn list_meals(
|
||||
&self,
|
||||
txn: &mut SqliteConnection,
|
||||
list_id: i64,
|
||||
) -> DomainResult<Vec<ListMeal>>;
|
||||
async fn add_meal(
|
||||
&self,
|
||||
txn: &mut SqliteConnection,
|
||||
list_id: i64,
|
||||
meal_id: Option<i64>,
|
||||
name: String,
|
||||
) -> DomainResult<i64>;
|
||||
async fn remove_meal(
|
||||
&self,
|
||||
txn: &mut SqliteConnection,
|
||||
list_id: i64,
|
||||
list_meal_id: i64,
|
||||
) -> DomainResult<i64>;
|
||||
/// Copies the given meal instances from one list to another without
|
||||
/// expanding their ingredients into items (they were already purchased).
|
||||
/// Returns the new rows and the destination list's bumped revision.
|
||||
async fn copy_meals_to_list(
|
||||
&self,
|
||||
txn: &mut SqliteConnection,
|
||||
source_list_id: i64,
|
||||
dest_list_id: i64,
|
||||
list_meal_ids: &[i64],
|
||||
) -> DomainResult<(Vec<ListMeal>, i64)>;
|
||||
}
|
||||
|
||||
#[async_trait]
|
||||
pub trait InvitationRepository: Send + Sync {
|
||||
async fn create_invitation(
|
||||
@@ -174,6 +219,21 @@ pub trait InvitationRepository: Send + Sync {
|
||||
) -> DomainResult<()>;
|
||||
}
|
||||
|
||||
#[async_trait]
|
||||
pub trait MealCategoryRepository: Send + Sync {
|
||||
async fn meal_categories(&self, txn: &mut SqliteConnection) -> DomainResult<Vec<MealCategory>>;
|
||||
async fn create_meal_category(
|
||||
&self,
|
||||
txn: &mut SqliteConnection,
|
||||
name: String,
|
||||
) -> DomainResult<i64>;
|
||||
async fn delete_meal_category(
|
||||
&self,
|
||||
txn: &mut SqliteConnection,
|
||||
category_id: i64,
|
||||
) -> DomainResult<()>;
|
||||
}
|
||||
|
||||
#[async_trait]
|
||||
pub trait MealRepository: Send + Sync {
|
||||
async fn create_meal(
|
||||
@@ -181,19 +241,21 @@ pub trait MealRepository: Send + Sync {
|
||||
txn: &mut SqliteConnection,
|
||||
name: String,
|
||||
description: String,
|
||||
category_id: Option<i64>,
|
||||
) -> DomainResult<Meal>;
|
||||
async fn get_meal(
|
||||
&self,
|
||||
txn: &mut SqliteConnection,
|
||||
meal_id: i64,
|
||||
) -> DomainResult<Option<Meal>>;
|
||||
async fn list_meals(&self, txn: &mut SqliteConnection) -> DomainResult<Vec<Meal>>;
|
||||
async fn list_meals(&self, txn: &mut SqliteConnection, query: &str) -> DomainResult<Vec<Meal>>;
|
||||
async fn update_meal(
|
||||
&self,
|
||||
txn: &mut SqliteConnection,
|
||||
meal_id: i64,
|
||||
name: String,
|
||||
description: String,
|
||||
category_id: Option<i64>,
|
||||
) -> DomainResult<()>;
|
||||
async fn delete_meal(&self, txn: &mut SqliteConnection, meal_id: i64) -> DomainResult<()>;
|
||||
}
|
||||
@@ -262,3 +324,33 @@ pub enum HubEvent {
|
||||
ListChanged { list_id: i64, revision: i64 },
|
||||
PresenceChanged { list_id: i64 },
|
||||
}
|
||||
|
||||
/// Stores and retrieves a user's rewards cards.
|
||||
#[async_trait]
|
||||
pub trait RewardsCardRepository: Send + Sync {
|
||||
async fn list_cards(
|
||||
&self,
|
||||
txn: &mut SqliteConnection,
|
||||
user_id: i64,
|
||||
) -> DomainResult<Vec<RewardsCard>>;
|
||||
async fn get_card(
|
||||
&self,
|
||||
txn: &mut SqliteConnection,
|
||||
user_id: i64,
|
||||
card_id: i64,
|
||||
) -> DomainResult<Option<RewardsCard>>;
|
||||
async fn create_card(
|
||||
&self,
|
||||
txn: &mut SqliteConnection,
|
||||
user_id: i64,
|
||||
store_name: String,
|
||||
number: String,
|
||||
symbology: String,
|
||||
) -> DomainResult<RewardsCard>;
|
||||
async fn delete_card(
|
||||
&self,
|
||||
txn: &mut SqliteConnection,
|
||||
user_id: i64,
|
||||
card_id: i64,
|
||||
) -> DomainResult<()>;
|
||||
}
|
||||
|
||||
+190
-10
@@ -1,10 +1,13 @@
|
||||
use std::sync::Arc;
|
||||
|
||||
use crate::domain::{DomainError, DomainResult, GroceryList, Item, Meal, SessionUser, User};
|
||||
use crate::domain::{
|
||||
DomainError, DomainResult, GroceryList, Item, ListMeal, Meal, MealCategory, RewardsCard,
|
||||
SessionUser, User,
|
||||
};
|
||||
use crate::ports::{
|
||||
CategoryRepository, InvitationRepository, ItemRepository, ListRepository,
|
||||
MealIngredientRepository, MealRepository, NewItem, PasswordHasher, RealtimeNotifier,
|
||||
SessionRepository, TokenGenerator, UserRepository,
|
||||
CategoryRepository, InvitationRepository, ItemRepository, ListMealRepository, ListRepository,
|
||||
MealCategoryRepository, MealIngredientRepository, MealRepository, NewItem, PasswordHasher,
|
||||
RealtimeNotifier, RewardsCardRepository, SessionRepository, TokenGenerator, UserRepository,
|
||||
};
|
||||
use crate::sqlite::SqliteDatabase;
|
||||
|
||||
@@ -197,6 +200,13 @@ impl ListService {
|
||||
.await
|
||||
}
|
||||
|
||||
pub async fn list_archived_summaries(&self) -> DomainResult<Vec<GroceryList>> {
|
||||
let lists = Arc::clone(&self.lists);
|
||||
self.db
|
||||
.run(move |txn| Box::pin(async move { lists.list_archived_summaries(txn).await }))
|
||||
.await
|
||||
}
|
||||
|
||||
pub async fn create_list(&self, name: String) -> DomainResult<GroceryList> {
|
||||
let lists = Arc::clone(&self.lists);
|
||||
self.db
|
||||
@@ -211,6 +221,20 @@ impl ListService {
|
||||
.await
|
||||
}
|
||||
|
||||
pub async fn archive_list(&self, list_id: i64) -> DomainResult<()> {
|
||||
let lists = Arc::clone(&self.lists);
|
||||
self.db
|
||||
.run(move |txn| Box::pin(async move { lists.set_archived(txn, list_id, true).await }))
|
||||
.await
|
||||
}
|
||||
|
||||
pub async fn unarchive_list(&self, list_id: i64) -> DomainResult<()> {
|
||||
let lists = Arc::clone(&self.lists);
|
||||
self.db
|
||||
.run(move |txn| Box::pin(async move { lists.set_archived(txn, list_id, false).await }))
|
||||
.await
|
||||
}
|
||||
|
||||
pub async fn items(&self, list_id: i64) -> DomainResult<Vec<Item>> {
|
||||
let items = Arc::clone(&self.items);
|
||||
self.db
|
||||
@@ -313,8 +337,10 @@ pub struct MealService {
|
||||
db: SqliteDatabase,
|
||||
meals: Arc<dyn MealRepository>,
|
||||
ingredients: Arc<dyn MealIngredientRepository>,
|
||||
meal_categories: Arc<dyn MealCategoryRepository>,
|
||||
lists: Arc<dyn ListRepository>,
|
||||
items: Arc<dyn ItemRepository>,
|
||||
list_meals: Arc<dyn ListMealRepository>,
|
||||
realtime: Arc<dyn RealtimeNotifier>,
|
||||
}
|
||||
|
||||
@@ -323,25 +349,36 @@ impl MealService {
|
||||
db: SqliteDatabase,
|
||||
meals: Arc<dyn MealRepository>,
|
||||
ingredients: Arc<dyn MealIngredientRepository>,
|
||||
meal_categories: Arc<dyn MealCategoryRepository>,
|
||||
lists: Arc<dyn ListRepository>,
|
||||
items: Arc<dyn ItemRepository>,
|
||||
list_meals: Arc<dyn ListMealRepository>,
|
||||
realtime: Arc<dyn RealtimeNotifier>,
|
||||
) -> Self {
|
||||
Self {
|
||||
db,
|
||||
meals,
|
||||
ingredients,
|
||||
meal_categories,
|
||||
lists,
|
||||
items,
|
||||
list_meals,
|
||||
realtime,
|
||||
}
|
||||
}
|
||||
|
||||
pub async fn create_meal(&self, name: String, description: String) -> DomainResult<Meal> {
|
||||
pub async fn create_meal(
|
||||
&self,
|
||||
name: String,
|
||||
description: String,
|
||||
category_id: Option<i64>,
|
||||
) -> DomainResult<Meal> {
|
||||
let meals = Arc::clone(&self.meals);
|
||||
self.db
|
||||
.run(move |txn| {
|
||||
Box::pin(async move { meals.create_meal(txn, name, description).await })
|
||||
Box::pin(
|
||||
async move { meals.create_meal(txn, name, description, category_id).await },
|
||||
)
|
||||
})
|
||||
.await
|
||||
}
|
||||
@@ -353,10 +390,11 @@ impl MealService {
|
||||
.await
|
||||
}
|
||||
|
||||
pub async fn list_meals(&self) -> DomainResult<Vec<Meal>> {
|
||||
pub async fn list_meals(&self, query: &str) -> DomainResult<Vec<Meal>> {
|
||||
let meals = Arc::clone(&self.meals);
|
||||
let query = query.to_owned();
|
||||
self.db
|
||||
.run(move |txn| Box::pin(async move { meals.list_meals(txn).await }))
|
||||
.run(move |txn| Box::pin(async move { meals.list_meals(txn, &query).await }))
|
||||
.await
|
||||
}
|
||||
|
||||
@@ -365,11 +403,43 @@ impl MealService {
|
||||
meal_id: i64,
|
||||
name: String,
|
||||
description: String,
|
||||
category_id: Option<i64>,
|
||||
) -> DomainResult<()> {
|
||||
let meals = Arc::clone(&self.meals);
|
||||
self.db
|
||||
.run(move |txn| {
|
||||
Box::pin(async move { meals.update_meal(txn, meal_id, name, description).await })
|
||||
Box::pin(async move {
|
||||
meals
|
||||
.update_meal(txn, meal_id, name, description, category_id)
|
||||
.await
|
||||
})
|
||||
})
|
||||
.await
|
||||
}
|
||||
|
||||
pub async fn list_meal_categories(&self) -> DomainResult<Vec<MealCategory>> {
|
||||
let meal_categories = Arc::clone(&self.meal_categories);
|
||||
self.db
|
||||
.run(move |txn| Box::pin(async move { meal_categories.meal_categories(txn).await }))
|
||||
.await
|
||||
}
|
||||
|
||||
pub async fn create_meal_category(&self, name: String) -> DomainResult<i64> {
|
||||
let meal_categories = Arc::clone(&self.meal_categories);
|
||||
self.db
|
||||
.run(move |txn| {
|
||||
Box::pin(async move { meal_categories.create_meal_category(txn, name).await })
|
||||
})
|
||||
.await
|
||||
}
|
||||
|
||||
pub async fn delete_meal_category(&self, category_id: i64) -> DomainResult<()> {
|
||||
let meal_categories = Arc::clone(&self.meal_categories);
|
||||
self.db
|
||||
.run(move |txn| {
|
||||
Box::pin(
|
||||
async move { meal_categories.delete_meal_category(txn, category_id).await },
|
||||
)
|
||||
})
|
||||
.await
|
||||
}
|
||||
@@ -444,11 +514,12 @@ impl MealService {
|
||||
}
|
||||
|
||||
/// Expands a meal's ingredients into items on a list in one unit of work,
|
||||
/// bumping the list revision exactly once.
|
||||
/// recording the meal on the list and bumping the list revision exactly once.
|
||||
pub async fn add_meal_to_list(&self, meal_id: i64, list_id: i64) -> DomainResult<i64> {
|
||||
let meals = Arc::clone(&self.meals);
|
||||
let lists = Arc::clone(&self.lists);
|
||||
let items = Arc::clone(&self.items);
|
||||
let list_meals = Arc::clone(&self.list_meals);
|
||||
let revision = self
|
||||
.db
|
||||
.run(move |txn| {
|
||||
@@ -460,6 +531,9 @@ impl MealService {
|
||||
if lists.get_list(txn, list_id).await?.is_none() {
|
||||
return Err(DomainError::NotFound);
|
||||
}
|
||||
let list_meal_id = list_meals
|
||||
.add_meal(txn, list_id, Some(meal.id), meal.name.clone())
|
||||
.await?;
|
||||
let new_items = meal
|
||||
.ingredients
|
||||
.into_iter()
|
||||
@@ -468,6 +542,7 @@ impl MealService {
|
||||
quantity: ingredient.quantity,
|
||||
note: ingredient.note,
|
||||
category_id: ingredient.category_id,
|
||||
list_meal_id: Some(list_meal_id),
|
||||
})
|
||||
.collect();
|
||||
items.add_items_bulk(txn, list_id, new_items).await
|
||||
@@ -477,6 +552,60 @@ impl MealService {
|
||||
self.realtime.publish_list_changed(list_id, revision).await;
|
||||
Ok(revision)
|
||||
}
|
||||
|
||||
/// Lists the meals that have been added to a list, most recent first.
|
||||
pub async fn list_meals_on_list(&self, list_id: i64) -> DomainResult<Vec<ListMeal>> {
|
||||
let list_meals = Arc::clone(&self.list_meals);
|
||||
self.db
|
||||
.run(move |txn| Box::pin(async move { list_meals.list_meals(txn, list_id).await }))
|
||||
.await
|
||||
}
|
||||
|
||||
/// Removes a meal instance from a list, deleting the items that came from it
|
||||
/// and bumping the list revision exactly once.
|
||||
pub async fn remove_meal_from_list(
|
||||
&self,
|
||||
list_id: i64,
|
||||
list_meal_id: i64,
|
||||
) -> DomainResult<i64> {
|
||||
let list_meals = Arc::clone(&self.list_meals);
|
||||
let revision = self
|
||||
.db
|
||||
.run(move |txn| {
|
||||
Box::pin(async move { list_meals.remove_meal(txn, list_id, list_meal_id).await })
|
||||
})
|
||||
.await?;
|
||||
self.realtime.publish_list_changed(list_id, revision).await;
|
||||
Ok(revision)
|
||||
}
|
||||
|
||||
/// Copies the given meal instances from a source list into the destination
|
||||
/// list without re-expanding their ingredients into items (they were already
|
||||
/// purchased). The source list is left untouched. Publishes a realtime update
|
||||
/// for the destination only.
|
||||
pub async fn carry_meals_to_list(
|
||||
&self,
|
||||
source_list_id: i64,
|
||||
dest_list_id: i64,
|
||||
list_meal_ids: &[i64],
|
||||
) -> DomainResult<Vec<ListMeal>> {
|
||||
let list_meals = Arc::clone(&self.list_meals);
|
||||
let ids = list_meal_ids.to_vec();
|
||||
let (copied, revision) = self
|
||||
.db
|
||||
.run(move |txn| {
|
||||
Box::pin(async move {
|
||||
list_meals
|
||||
.copy_meals_to_list(txn, source_list_id, dest_list_id, &ids)
|
||||
.await
|
||||
})
|
||||
})
|
||||
.await?;
|
||||
self.realtime
|
||||
.publish_list_changed(dest_list_id, revision)
|
||||
.await;
|
||||
Ok(copied)
|
||||
}
|
||||
}
|
||||
|
||||
pub struct InvitationService {
|
||||
@@ -529,3 +658,54 @@ impl InvitationService {
|
||||
.await
|
||||
}
|
||||
}
|
||||
|
||||
pub struct RewardsCardService {
|
||||
db: SqliteDatabase,
|
||||
cards: Arc<dyn RewardsCardRepository>,
|
||||
}
|
||||
|
||||
impl RewardsCardService {
|
||||
pub fn new(db: SqliteDatabase, cards: Arc<dyn RewardsCardRepository>) -> Self {
|
||||
Self { db, cards }
|
||||
}
|
||||
|
||||
pub async fn list_cards(&self, user_id: i64) -> DomainResult<Vec<RewardsCard>> {
|
||||
let cards = Arc::clone(&self.cards);
|
||||
self.db
|
||||
.run(move |txn| Box::pin(async move { cards.list_cards(txn, user_id).await }))
|
||||
.await
|
||||
}
|
||||
|
||||
pub async fn get_card(&self, user_id: i64, card_id: i64) -> DomainResult<Option<RewardsCard>> {
|
||||
let cards = Arc::clone(&self.cards);
|
||||
self.db
|
||||
.run(move |txn| Box::pin(async move { cards.get_card(txn, user_id, card_id).await }))
|
||||
.await
|
||||
}
|
||||
|
||||
pub async fn create_card(
|
||||
&self,
|
||||
user_id: i64,
|
||||
store_name: String,
|
||||
number: String,
|
||||
symbology: String,
|
||||
) -> DomainResult<RewardsCard> {
|
||||
let cards = Arc::clone(&self.cards);
|
||||
self.db
|
||||
.run(move |txn| {
|
||||
Box::pin(async move {
|
||||
cards
|
||||
.create_card(txn, user_id, store_name, number, symbology)
|
||||
.await
|
||||
})
|
||||
})
|
||||
.await
|
||||
}
|
||||
|
||||
pub async fn delete_card(&self, user_id: i64, card_id: i64) -> DomainResult<()> {
|
||||
let cards = Arc::clone(&self.cards);
|
||||
self.db
|
||||
.run(move |txn| Box::pin(async move { cards.delete_card(txn, user_id, card_id).await }))
|
||||
.await
|
||||
}
|
||||
}
|
||||
|
||||
+1071
-34
File diff suppressed because it is too large
Load Diff
+866
-145
File diff suppressed because it is too large
Load Diff
Binary file not shown.
|
After Width: | Height: | Size: 18 KiB |
Binary file not shown.
|
After Width: | Height: | Size: 2.2 KiB |
Binary file not shown.
|
After Width: | Height: | Size: 832 B |
Vendored
+1
File diff suppressed because one or more lines are too long
Vendored
+1
File diff suppressed because one or more lines are too long
Vendored
+1
File diff suppressed because one or more lines are too long
+143
@@ -0,0 +1,143 @@
|
||||
<svg
|
||||
xmlns="http://www.w3.org/2000/svg"
|
||||
viewBox="0 0 64 64"
|
||||
role="img"
|
||||
aria-labelledby="title"
|
||||
>
|
||||
<title id="title">Sustenance grocery bag with produce</title>
|
||||
|
||||
<!-- Background -->
|
||||
<rect width="64" height="64" rx="12" fill="#286247"/>
|
||||
|
||||
<!-- Back of the paper bag -->
|
||||
<path
|
||||
d="
|
||||
M7 27
|
||||
L16 22
|
||||
L24 26
|
||||
L32 22
|
||||
L40 25
|
||||
L49 21
|
||||
L57 25
|
||||
L47 31
|
||||
L39 28
|
||||
L31 32
|
||||
L23 27
|
||||
L16 31
|
||||
Z
|
||||
"
|
||||
fill="#F2D39B"
|
||||
/>
|
||||
|
||||
<!-- Back rim -->
|
||||
<path
|
||||
d="M7 27 16 22 24 26 32 22 40 25 49 21 57 25"
|
||||
fill="none"
|
||||
stroke="#1F4938"
|
||||
stroke-width="2.75"
|
||||
stroke-linecap="round"
|
||||
stroke-linejoin="round"
|
||||
/>
|
||||
|
||||
<!-- Leafy greens -->
|
||||
<path
|
||||
d="M42 28C39 21 42 12 49 7c2 3 2 6 1 9 3-2 6-2 8 0-1 5-5 9-12 13Z"
|
||||
fill="#8EC866"
|
||||
stroke="#1F4938"
|
||||
stroke-width="2.5"
|
||||
stroke-linejoin="round"
|
||||
/>
|
||||
<path
|
||||
d="M45 27 53 15M47 22l7-1M49 18l-1-5"
|
||||
fill="none"
|
||||
stroke="#1F4938"
|
||||
stroke-width="2"
|
||||
stroke-linecap="round"
|
||||
/>
|
||||
|
||||
<!-- Carrot leaves -->
|
||||
<path
|
||||
d="
|
||||
M17 14c-2-4-1-7 0-10 3 3 4 6 3 10
|
||||
m0 0c0-5 2-8 5-10 1 5-1 8-5 11
|
||||
"
|
||||
fill="#8EC866"
|
||||
stroke="#1F4938"
|
||||
stroke-width="2.5"
|
||||
stroke-linecap="round"
|
||||
stroke-linejoin="round"
|
||||
/>
|
||||
|
||||
<!-- Carrot -->
|
||||
<path
|
||||
d="M13 18c3-4 9-5 13-2l-3 20-5 2Z"
|
||||
fill="#F29A3F"
|
||||
stroke="#1F4938"
|
||||
stroke-width="2.5"
|
||||
stroke-linejoin="round"
|
||||
/>
|
||||
<path
|
||||
d="m16 24 7-2m-6 7 5-2"
|
||||
fill="none"
|
||||
stroke="#1F4938"
|
||||
stroke-width="2"
|
||||
stroke-linecap="round"
|
||||
/>
|
||||
|
||||
<!-- Tomato -->
|
||||
<path
|
||||
d="M27 25c0-6 4-10 10-10s10 4 10 10c0 7-4 12-10 12S27 32 27 25Z"
|
||||
fill="#E65A46"
|
||||
stroke="#1F4938"
|
||||
stroke-width="2.5"
|
||||
/>
|
||||
<path
|
||||
d="m37 15-4 5 4-1 4 2-1-5"
|
||||
fill="#78B75B"
|
||||
stroke="#1F4938"
|
||||
stroke-width="2"
|
||||
stroke-linecap="round"
|
||||
stroke-linejoin="round"
|
||||
/>
|
||||
|
||||
<!-- Front and sides of the paper bag -->
|
||||
<path
|
||||
d="
|
||||
M7 27
|
||||
L16 31
|
||||
L23 27
|
||||
L31 32
|
||||
L39 28
|
||||
L47 31
|
||||
L57 25
|
||||
L55 51
|
||||
L45 59
|
||||
L11 51
|
||||
Z
|
||||
"
|
||||
fill="#F2D39B"
|
||||
stroke="#1F4938"
|
||||
stroke-width="2.75"
|
||||
stroke-linejoin="round"
|
||||
/>
|
||||
|
||||
<!-- Front opening edge -->
|
||||
<path
|
||||
d="M7 27 16 31 23 27 31 32 39 28 47 31 57 25"
|
||||
fill="none"
|
||||
stroke="#1F4938"
|
||||
stroke-width="2.75"
|
||||
stroke-linecap="round"
|
||||
stroke-linejoin="round"
|
||||
/>
|
||||
|
||||
<!-- Side-panel seam and paper creases -->
|
||||
<path
|
||||
d="M47 31 45 59M45 59l10-8M15 36l1 9"
|
||||
fill="none"
|
||||
stroke="#1F4938"
|
||||
stroke-width="2.25"
|
||||
stroke-linecap="round"
|
||||
stroke-linejoin="round"
|
||||
/>
|
||||
</svg>
|
||||
|
After Width: | Height: | Size: 2.6 KiB |
@@ -0,0 +1,16 @@
|
||||
// Toggle password visibility so users can check for typos, especially on mobile.
|
||||
document.querySelectorAll(".password-toggle").forEach(function (button) {
|
||||
button.addEventListener("pointerdown", function (event) {
|
||||
// Toggle on press (not click) for an instant response. preventScroll avoids
|
||||
// a scroll-to-input animation that makes rapid toggling feel laggy, and
|
||||
// keeping focus on the input keeps the mobile keyboard open.
|
||||
event.preventDefault();
|
||||
var input = document.getElementById(button.getAttribute("data-toggle-for"));
|
||||
if (!input) return;
|
||||
var showing = input.type === "text";
|
||||
input.type = showing ? "password" : "text";
|
||||
button.textContent = showing ? "Show" : "Hide";
|
||||
button.setAttribute("aria-label", showing ? "Show password" : "Hide password");
|
||||
input.focus({ preventScroll: true });
|
||||
});
|
||||
});
|
||||
@@ -0,0 +1,30 @@
|
||||
// Keep the screen awake while a rewards barcode is on screen so the cashier
|
||||
// can scan it without the display dimming or locking. This mirrors how wallet
|
||||
// apps behave when showing a barcode. The Screen Wake Lock API is best-effort:
|
||||
// it may be rejected (e.g. low battery) or auto-released when the tab is hidden,
|
||||
// so we re-acquire whenever the page becomes visible again.
|
||||
(function () {
|
||||
var wakeLock = null;
|
||||
|
||||
function requestWakeLock() {
|
||||
if (!("wakeLock" in navigator)) return;
|
||||
navigator.wakeLock
|
||||
.request("screen")
|
||||
.then(function (sentinel) {
|
||||
wakeLock = sentinel;
|
||||
})
|
||||
.catch(function () {
|
||||
// Best-effort only; ignore failures (unsupported, low battery, etc.).
|
||||
});
|
||||
}
|
||||
|
||||
// Re-acquire if the lock was released (e.g. the tab was hidden) and the user
|
||||
// returns to the page.
|
||||
document.addEventListener("visibilitychange", function () {
|
||||
if (document.visibilityState === "visible" && wakeLock === null) {
|
||||
requestWakeLock();
|
||||
}
|
||||
});
|
||||
|
||||
requestWakeLock();
|
||||
})();
|
||||
+162
-2
@@ -38,7 +38,7 @@ a { color: inherit; }
|
||||
}
|
||||
|
||||
.brand { display: inline-flex; align-items: center; gap: 10px; text-decoration: none; font-weight: 800; letter-spacing: -.03em; }
|
||||
.brand-mark { display: grid; place-items: center; width: 32px; height: 32px; border-radius: 11px 11px 11px 3px; background: var(--deep-sage); color: white; transform: rotate(-6deg); }
|
||||
.brand-mark { display: block; width: 34px; height: 34px; border-radius: 9px; object-fit: cover; }
|
||||
.site-nav { display: flex; align-items: center; gap: 6px; }
|
||||
.site-nav a {
|
||||
padding: 8px 14px;
|
||||
@@ -67,14 +67,25 @@ h3 { margin-bottom: 6px; font-size: 1rem; }
|
||||
.muted { color: var(--muted); }
|
||||
|
||||
.page-heading { display: flex; justify-content: space-between; align-items: end; margin-bottom: 34px; }
|
||||
.page-heading h1.page-title { font-size: clamp(1.6rem, 3.2vw, 2.3rem); }
|
||||
.dashboard-grid { display: grid; grid-template-columns: minmax(0, 1.5fr) minmax(260px, .8fr); gap: 22px; align-items: start; }
|
||||
.panel { padding: 26px; border: 1px solid rgba(221, 225, 210, .9); border-radius: 24px; background: rgba(255, 253, 248, .88); box-shadow: var(--shadow); }
|
||||
.panel-heading { display: flex; justify-content: space-between; align-items: center; gap: 12px; margin-bottom: 22px; }
|
||||
.archive-link { margin-left: auto; color: var(--muted); font-size: .78rem; font-weight: 700; text-decoration: none; }
|
||||
.archive-link:hover { color: var(--deep-sage); }
|
||||
.count-badge { display: inline-grid; place-items: center; min-width: 27px; height: 27px; padding: 0 8px; border-radius: 99px; color: var(--deep-sage); background: #e8f0e1; font-size: .78rem; font-weight: 800; }
|
||||
.stack { display: grid; gap: 9px; }
|
||||
.stack label { color: var(--muted); font-size: .82rem; font-weight: 700; }
|
||||
input { width: 100%; min-height: 46px; padding: 10px 13px; border: 1px solid var(--line); border-radius: 12px; outline: none; color: var(--ink); background: #fff; }
|
||||
input:focus { border-color: var(--deep-sage); box-shadow: 0 0 0 4px rgba(85, 113, 93, .12); }
|
||||
.password-field { position: relative; }
|
||||
.password-field input { padding-right: 64px; }
|
||||
.password-toggle { position: absolute; top: 50%; right: 8px; transform: translateY(-50%); min-height: 32px; padding: 5px 10px; border: 0; border-radius: 9px; cursor: pointer; color: var(--deep-sage); background: #e7f0e1; font-weight: 800; font-size: .78rem; }
|
||||
.password-toggle:hover { background: #dbe9d2; }
|
||||
select { width: 100%; min-height: 46px; padding: 10px 34px 10px 13px; border: 1px solid var(--line); border-radius: 12px; outline: none; color: var(--ink); background: #fff; font: inherit; appearance: none; -webkit-appearance: none; background-image: url("data:image/svg+xml;utf8,<svg xmlns='http://www.w3.org/2000/svg' width='16' height='16' viewBox='0 0 16 16'><path d='M4 6l4 4 4-4' fill='none' stroke='%2355715d' stroke-width='2' stroke-linecap='round' stroke-linejoin='round'/></svg>"); background-repeat: no-repeat; background-position: right 12px center; }
|
||||
select:focus { border-color: var(--deep-sage); box-shadow: 0 0 0 4px rgba(85, 113, 93, .12); }
|
||||
select option { color: var(--ink); background: #fff; }
|
||||
select option:checked { color: var(--deep-sage); font-weight: 700; }
|
||||
textarea { width: 100%; padding: 10px 13px; border: 1px solid var(--line); border-radius: 12px; outline: none; color: var(--ink); background: #fff; font: inherit; resize: vertical; }
|
||||
textarea:focus { border-color: var(--deep-sage); box-shadow: 0 0 0 4px rgba(85, 113, 93, .12); }
|
||||
.button { display: inline-flex; align-items: center; justify-content: center; min-height: 44px; padding: 10px 17px; border: 0; border-radius: 12px; cursor: pointer; text-decoration: none; font-weight: 800; transition: transform .16s ease, box-shadow .16s ease, background .16s ease; }
|
||||
@@ -91,12 +102,18 @@ textarea:focus { border-color: var(--deep-sage); box-shadow: 0 0 0 4px rgba(85,
|
||||
.list-card-copy { display: grid; flex: 1; gap: 2px; }
|
||||
.list-card-copy small { color: var(--muted); font-size: .75rem; }
|
||||
.list-card-arrow { color: var(--muted); font-size: 1.25rem; }
|
||||
.archived-list-card { opacity: .72; }
|
||||
.archived-list-card .list-card-icon { color: var(--muted); background: #eef0ea; }
|
||||
.archived-list-card .list-card-copy { align-items: flex-start; }
|
||||
.archived-list-card form { margin-left: auto; }
|
||||
.archived-banner { margin-bottom: 18px; padding: 11px 14px; border: 1px solid var(--line); border-radius: 12px; color: var(--muted); background: #f1f3ec; font-size: .82rem; font-weight: 700; }
|
||||
.empty-state { padding: 35px 18px 24px; text-align: center; color: var(--muted); }
|
||||
.empty-mark { display: grid; place-items: center; width: 50px; height: 50px; margin: 0 auto 15px; border-radius: 18px; color: var(--deep-sage); background: #edf3e8; font-size: 1.8rem; }
|
||||
.empty-state h3 { color: var(--ink); }
|
||||
|
||||
.auth-card { width: min(100%, 480px); margin: 7vh auto 0; padding: clamp(27px, 6vw, 54px); border: 1px solid var(--line); border-radius: 28px; background: rgba(255, 253, 248, .9); box-shadow: var(--shadow); }
|
||||
.auth-card .button { margin-top: 11px; }
|
||||
#passkey-login { width: 100%; }
|
||||
.auth-divider { display: flex; align-items: center; gap: 12px; margin: 20px 0 4px; color: var(--muted); font-size: .8rem; }
|
||||
.auth-divider::before, .auth-divider::after { content: ""; flex: 1; height: 1px; background: var(--line); }
|
||||
.passkey-list { display: grid; gap: 8px; margin-bottom: 16px; }
|
||||
@@ -127,7 +144,8 @@ textarea:focus { border-color: var(--deep-sage); box-shadow: 0 0 0 4px rgba(85,
|
||||
.list-heading { display: flex; justify-content: space-between; margin-bottom: 25px; }
|
||||
.list-heading h1 { max-width: 100%; margin-bottom: 5px; overflow-wrap: anywhere; font-size: clamp(1.45rem, 2.8vw, 2.05rem); }
|
||||
.list-meta { margin: 0; color: var(--muted); font-size: .85rem; }
|
||||
.add-item-form { display: grid; grid-template-columns: minmax(0, 1fr) 90px 145px auto; gap: 8px; margin-bottom: 19px; }
|
||||
.meal-category-label { margin-left: 10px; color: var(--muted); font-size: .8em; font-weight: 500; white-space: nowrap; }
|
||||
.add-item-form { display: grid; grid-template-columns: minmax(0, 1fr) 145px 90px auto; gap: 8px; margin-bottom: 19px; }
|
||||
.add-item-form input { min-height: 50px; }
|
||||
.add-item-form select { min-height: 50px; }
|
||||
.add-button { min-height: 50px; }
|
||||
@@ -135,11 +153,14 @@ textarea:focus { border-color: var(--deep-sage); box-shadow: 0 0 0 4px rgba(85,
|
||||
.item-list { display: grid; gap: 6px; }
|
||||
.category-group + .category-group { margin-top: 18px; }
|
||||
.category-heading { margin: 0 7px 4px; color: var(--deep-sage); font-size: .72rem; letter-spacing: .12em; text-transform: uppercase; }
|
||||
.ingredients-divider { margin: 26px 0 18px; border: 0; border-top: 1px solid var(--line); }
|
||||
.item-row { display: flex; align-items: center; gap: 12px; min-height: 66px; padding: 9px 7px 9px 10px; border-bottom: 1px solid #edf0e6; }
|
||||
.item-row:last-child { border-bottom: 0; }
|
||||
.check-form { flex: 0 0 auto; }
|
||||
.check-button { display: grid; place-items: center; width: 28px; height: 28px; padding: 0; border: 2px solid #c8d6c1; border-radius: 9px; color: #fff; background: transparent; cursor: pointer; font-size: .88rem; font-weight: 900; }
|
||||
.is-checked .check-button { border-color: var(--deep-sage); background: var(--deep-sage); }
|
||||
.check-button-static { cursor: default; }
|
||||
.is-checked .check-button-static { border-color: var(--deep-sage); background: var(--deep-sage); }
|
||||
.item-copy { display: grid; grid-template-columns: auto 1fr; flex: 1; min-width: 0; gap: 2px 7px; align-items: baseline; }
|
||||
.item-copy strong { grid-column: 2; overflow: hidden; text-overflow: ellipsis; white-space: nowrap; }
|
||||
.item-qty { grid-column: 1; grid-row: 1; color: var(--muted); font-weight: 700; white-space: nowrap; }
|
||||
@@ -208,6 +229,10 @@ textarea:focus { border-color: var(--deep-sage); box-shadow: 0 0 0 4px rgba(85,
|
||||
.edit-form { margin-bottom: 12px; }
|
||||
.edit-form input { min-height: 38px; padding: 7px 10px; font-size: .85rem; }
|
||||
.danger-link { padding: 0; border: 0; color: var(--coral); background: none; cursor: pointer; font-size: .8rem; font-weight: 800; }
|
||||
.bordered-delete { padding: 7px 14px; border: 1px solid var(--coral); border-radius: 10px; background: none; }
|
||||
.bordered-delete:hover { background: #fbeae4; }
|
||||
.button-danger { width: 100%; color: var(--coral); background: #fbeae4; }
|
||||
.button-danger:hover { background: #f7ddd4; }
|
||||
.empty-items { padding: 34px 10px 18px; color: var(--muted); text-align: center; }
|
||||
.empty-items-icon { display: block; margin-bottom: 7px; color: var(--yellow); font-size: 1.7rem; }
|
||||
.empty-items p { margin-bottom: 2px; color: var(--ink); font-weight: 800; }
|
||||
@@ -218,12 +243,45 @@ textarea:focus { border-color: var(--deep-sage); box-shadow: 0 0 0 4px rgba(85,
|
||||
.category-form input { min-height: 38px; padding: 7px 10px; font-size: .84rem; }
|
||||
.category-list { display: flex; flex-wrap: wrap; gap: 6px; margin-top: 14px; }
|
||||
.category-chip { padding: 5px 9px; border-radius: 99px; color: var(--deep-sage); background: #edf3e8; font-size: .72rem; font-weight: 800; }
|
||||
/* Meal categories side panel */
|
||||
.meal-category-list { display: grid; gap: 2px; margin-top: 14px; }
|
||||
.meal-category-row { display: flex; align-items: center; justify-content: space-between; gap: 8px; padding: 7px 4px; border-bottom: 1px solid #edf0e6; }
|
||||
.meal-category-row:last-child { border-bottom: 0; }
|
||||
.meal-category-name { font-size: .9rem; font-weight: 700; }
|
||||
.meal-category-delete { padding: 2px 6px; border: 0; border-radius: 7px; color: var(--muted); background: transparent; cursor: pointer; font-size: .8rem; line-height: 1; }
|
||||
.meal-category-delete:hover { color: var(--coral); background: #fbeae4; }
|
||||
.category-empty { margin: 13px 0 0; font-size: .8rem; }
|
||||
.category-result { margin-top: 10px; }
|
||||
.category-success { margin: 0; color: var(--deep-sage); font-size: .76rem; font-weight: 800; }
|
||||
.presence-list { display: grid; gap: 12px; }
|
||||
.presence-person { display: flex; align-items: center; gap: 10px; font-size: .9rem; font-weight: 700; }
|
||||
.avatar { display: grid; place-items: center; width: 32px; height: 32px; border-radius: 11px; color: var(--deep-sage); background: #e6f0df; font-size: .7rem; font-weight: 900; }
|
||||
.list-meals { display: grid; gap: 8px; }
|
||||
.list-meal-row { display: flex; align-items: center; gap: 10px; padding: 6px 4px; border-bottom: 1px solid #edf0e6; }
|
||||
.list-meal-row:last-child { border-bottom: 0; }
|
||||
.list-meal-icon { display: grid; place-items: center; flex: 0 0 auto; width: 30px; height: 30px; border-radius: 10px; color: var(--deep-sage); background: #eef4e9; font-size: .95rem; }
|
||||
.list-meal-name { flex: 1; min-width: 0; overflow: hidden; text-overflow: ellipsis; white-space: nowrap; font-size: .9rem; font-weight: 700; }
|
||||
.list-meal-remove { margin: 0; flex: 0 0 auto; }
|
||||
.list-meal-remove-button { padding: 2px 7px; border: 0; border-radius: 7px; color: var(--muted); background: transparent; cursor: pointer; font-size: .8rem; line-height: 1; }
|
||||
.list-meal-remove-button:hover { color: var(--coral); background: #fbeae4; }
|
||||
.list-meals-panel .add-meal-button { margin-top: 12px; width: 100%; }
|
||||
.list-meals-actions { display: grid; grid-template-columns: 1fr 1fr; gap: 8px; margin-top: 12px; }
|
||||
.list-meals-actions .button { width: 100%; margin: 0; }
|
||||
.carry-over-button { color: var(--deep-sage); background: #eef4e9; }
|
||||
.carry-over-button:hover { background: #e3eddc; }
|
||||
.carry-intro { margin: 14px 24px 4px; font-size: .85rem; }
|
||||
.carry-source-picker { padding: 14px 24px 4px; }
|
||||
.carry-source-picker label { display: block; margin-bottom: 6px; font-size: .78rem; font-weight: 800; color: var(--muted); text-transform: uppercase; letter-spacing: .04em; }
|
||||
.carry-source-picker select { width: 100%; min-height: 42px; padding: 8px 12px; border: 1px solid var(--line); border-radius: 12px; color: var(--ink); background: #fff; font-size: .9rem; }
|
||||
.carry-results { padding: 14px 24px 22px; overflow-y: auto; }
|
||||
.carry-form { margin: 0; }
|
||||
.carry-list { display: grid; gap: 8px; }
|
||||
.carry-row { display: flex; align-items: center; gap: 12px; padding: 10px 12px; border: 1px solid var(--line); border-radius: 14px; background: #fff; cursor: pointer; }
|
||||
.carry-row:hover { border-color: var(--sage); }
|
||||
.carry-row input { accent-color: var(--deep-sage); width: 17px; height: 17px; }
|
||||
.carry-row-icon { display: grid; place-items: center; flex: 0 0 auto; width: 34px; height: 34px; border-radius: 11px; color: var(--deep-sage); background: #eef4e9; font-size: .95rem; }
|
||||
.carry-row-name { flex: 1; min-width: 0; overflow: hidden; text-overflow: ellipsis; white-space: nowrap; font-size: .9rem; font-weight: 700; }
|
||||
.carry-submit { margin-top: 14px; width: 100%; }
|
||||
.sharing-panel p, .tip-panel p { color: var(--muted); font-size: .86rem; }
|
||||
.invite-result { margin-top: 15px; }
|
||||
.invite-link-result { padding: 11px; border-radius: 12px; background: #f1f5ec; }
|
||||
@@ -337,6 +395,11 @@ textarea:focus { border-color: var(--deep-sage); box-shadow: 0 0 0 4px rgba(85,
|
||||
.meal-picker-empty { padding: 34px 22px 30px; text-align: center; color: var(--muted); }
|
||||
.meal-picker-empty h3 { color: var(--ink); }
|
||||
.meal-picker-empty p { margin-bottom: 18px; }
|
||||
.meal-filter-bar { margin: -6px 0 18px; }
|
||||
.meal-filter-bar input { min-height: 40px; padding: 8px 12px; font-size: .9rem; }
|
||||
.meal-filter-bar-picker { margin: 14px 24px 4px; }
|
||||
.meal-filter-empty { padding: 28px 18px; text-align: center; color: var(--muted); }
|
||||
.meal-filter-empty p { margin: 0; }
|
||||
|
||||
@media (max-width: 780px) {
|
||||
.site-header, .site-main, .site-footer { width: min(100% - 28px, 600px); }
|
||||
@@ -362,3 +425,100 @@ textarea:focus { border-color: var(--deep-sage); box-shadow: 0 0 0 4px rgba(85,
|
||||
.side-column { grid-template-columns: 1fr; }
|
||||
.site-footer { margin-bottom: 20px; }
|
||||
}
|
||||
|
||||
/* Rewards cards */
|
||||
.rewards-grid { display: grid; gap: 16px; }
|
||||
.rewards-card {
|
||||
position: relative;
|
||||
padding: 18px;
|
||||
border: 1px solid var(--line);
|
||||
border-radius: 18px;
|
||||
background: #fff;
|
||||
transition: border-color .16s ease, transform .16s ease;
|
||||
}
|
||||
.rewards-card:hover { border-color: var(--sage); transform: translateY(-1px); }
|
||||
/* Stretched link: makes the whole card clickable to open the scan view. */
|
||||
.rewards-card-link {
|
||||
position: absolute;
|
||||
inset: 0;
|
||||
border-radius: inherit;
|
||||
z-index: 1;
|
||||
}
|
||||
.rewards-card-heading {
|
||||
display: flex;
|
||||
justify-content: space-between;
|
||||
align-items: center;
|
||||
gap: 12px;
|
||||
margin-bottom: 14px;
|
||||
}
|
||||
.rewards-card-heading strong { font-size: 1.05rem; }
|
||||
.rewards-barcode {
|
||||
display: flex;
|
||||
justify-content: center;
|
||||
padding: 14px;
|
||||
border-radius: 12px;
|
||||
background: #fff;
|
||||
}
|
||||
.rewards-barcode svg { width: 100%; height: auto; max-width: 340px; }
|
||||
.rewards-number {
|
||||
margin: 12px 0 0;
|
||||
text-align: center;
|
||||
color: var(--muted);
|
||||
font-size: .85rem;
|
||||
letter-spacing: .08em;
|
||||
}
|
||||
.rewards-unencodable {
|
||||
display: block;
|
||||
color: var(--coral);
|
||||
font-weight: 700;
|
||||
}
|
||||
/* Keep the Remove button above the stretched link so it stays clickable. */
|
||||
.rewards-card-heading form { position: relative; z-index: 2; }
|
||||
|
||||
/* Single-card scan view */
|
||||
.scan-page {
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
align-items: center;
|
||||
gap: 22px;
|
||||
padding: 12px 0 40px;
|
||||
}
|
||||
.scan-back { align-self: flex-start; }
|
||||
.scan-card {
|
||||
width: min(100%, 460px);
|
||||
padding: clamp(24px, 6vw, 42px);
|
||||
border: 1px solid var(--line);
|
||||
border-radius: 28px;
|
||||
background: #fff;
|
||||
box-shadow: var(--shadow);
|
||||
text-align: center;
|
||||
}
|
||||
.scan-store { margin: 4px 0 26px; font-size: clamp(1.3rem, 4vw, 1.7rem); }
|
||||
.scan-barcode {
|
||||
display: flex;
|
||||
justify-content: center;
|
||||
padding: 22px;
|
||||
border-radius: 14px;
|
||||
background: #fff;
|
||||
}
|
||||
.scan-barcode svg {
|
||||
width: 100%;
|
||||
height: auto;
|
||||
max-width: 420px;
|
||||
}
|
||||
.scan-card .rewards-number {
|
||||
margin-top: 18px;
|
||||
font-size: 1rem;
|
||||
}
|
||||
select {
|
||||
width: 100%;
|
||||
min-height: 46px;
|
||||
padding: 10px 13px;
|
||||
border: 1px solid var(--line);
|
||||
border-radius: 12px;
|
||||
outline: none;
|
||||
color: var(--ink);
|
||||
background: #fff;
|
||||
font: inherit;
|
||||
}
|
||||
select:focus { border-color: var(--deep-sage); box-shadow: 0 0 0 4px rgba(85, 113, 93, .12); }
|
||||
|
||||
Reference in New Issue
Block a user