Require method and minutes for a typed-in recipe; pause refresh on every save

The manual recipe form now enables Save only once method and minutes are
set, as POST /api/v1/dinners/{id}/ground requires, and always sends both.

useRegulars watches the Regulars changes in flight with useIsMutating, so
the grounding refresh pauses while an edit or a recipe fix is being saved,
not only while an add or favorite changes the list, and resumes after.

Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>

docs/ARCHITECTURE.md

@@ -96,7 +96,7 @@ Columns ending in `_ct` hold AES-256-GCM ciphertext (via `secretbox`).
 | `recipe_ingredients` | recipe_id, position, raw_text, name, qty, unit, note. |
 | `recipe_steps` | recipe_id, position, text. |
 | `photos` | source_url, local_path, width, height, sha256, fetched_at. |
-| `dinners` | The meal record and its lifecycle: name, normalized_name, status (`suggested` / `quest_log` / `tried` / `regular` / `archived`), origin, method, minutes_total, difficulty, cuisine, is_favorite, recipe_id, recipe_url (a pasted recipe link awaiting grounding), photo_id, grounding_status (`pending` / `grounded` / `failed` / `manual`), grounding_error (why grounding failed), grounding_revision (raised when a pending dinner is renamed, so only the latest `ground_dinner` job may write it), updated_by. |
+| `dinners` | The meal record and its lifecycle: name, normalized_name, status (`suggested` / `quest_log` / `tried` / `regular` / `archived`), origin, method, minutes_total, difficulty, cuisine, is_favorite, recipe_id, recipe_url (a pasted recipe link awaiting grounding), photo_id, grounding_status (`pending` / `grounded` / `failed` / `manual`), grounding_error (why grounding failed), updated_by. |
 | `suggestion_batches` | trigger, status, ai_run_id. |
 | `suggestions` | dinner_id, batch_id, reason, cited_regular_ids (JSON), status, decided_at. |
 | `week_plans` | week_start (unique), status (`draft` / `synced` / `changed`), ai_note, ai_run_id, calendar_synced_at. |
@@ -187,10 +187,8 @@ automatic** (D-021).
   "Beef stew"); a link that names nothing is 400 — add it by name. A name
   is trimmed, at most 120 characters and must keep a word after
   `harness.Normalize`, which sets `normalized_name`. A name
-  `harness.Similar` to an unarchived dinner's, or a link one already has
-  (the source_url of the recipe it is grounded in, else its pasted
-  `recipe_url`), is 409 `duplicate_dinner`; archived names may be added
-  again.
+  `harness.Similar` to an unarchived dinner's, or a link one already has,
+  is 409 `duplicate_dinner`; archived names may be added again.
   `GET /api/v1/dinners?status=regular|quest_log` returns
   `{dinners: [...]}` ordered by normalized name, each with `photo_url`
   (`/media/photos/{photo_id}-400.jpg`, or null) and `grounding_status`;
@@ -213,22 +211,11 @@ automatic** (D-021).
   `failed` with `grounding_error` — also the job's failure code — one of
   `no_recipe_found`, `recipe_unusable` (the pasted link), `search_not_configured`,
   `search_failed`, `ai_failed`, `interrupted` (the server stopped) or
-  `grounding_error`. Each job carries the dinner's `grounding_revision`
-  from when it was enqueued; renaming a `pending` dinner clears its
-  `recipe_url`, raises the revision and enqueues a job for the new name.
-  A job for a dinner archived, no longer `pending` or at another revision
-  does no work, and a job only writes a dinner still unarchived, `pending`
-  and at its revision, so a fix-up made meanwhile wins and an earlier job
-  for an old name — queued or running — never decides the outcome.
-  Archiving or renaming a dinner also stops its running job where it is,
-  so no further search, page fetch, photo download or model call is made
-  for it. A
-  method, minutes_total or difficulty a member saved while the dinner was
-  `pending` is kept; grounding fills only those left empty. At boot, after
-  the job runner fails the jobs a previous process left running, every
-  unarchived dinner still `pending` with no `ground_dinner` job for its revision
-  queued or running is set `failed` with `interrupted`, so no dinner stays
-  pending with nothing left to ground it.
+  `grounding_error`. It only writes a dinner still `pending`, so a fix-up
+  made meanwhile wins. At boot, after the job runner fails the jobs a
+  previous process left running, every dinner still `pending` with no
+  `ground_dinner` job queued or running is set `failed` with `interrupted`,
+  so no dinner stays pending with nothing left to ground it.
   `GET /api/v1/dinners/{id}/recipe-candidates`
   searches for the dinner's name and returns `{candidates: [{candidate_id,
   title, site_name, photo_url, minutes}]}`, at most 3, ranked as `Ground`
@@ -242,24 +229,14 @@ automatic** (D-021).
   — no model runs — as a `recipes` row whose source_url is
   `mealquest:manual:{recipe_id}` and whose raw_jsonld is a schema.org
   Recipe built from it, and sets `manual` with its method and minutes, no
-  photo and the dinner's difficulty unchanged. Either clears the dinner's
-  pasted `recipe_url`: the recipe chosen replaces it. It answers 200 with
-  the dinner; an invalid body is 400, an unknown dinner 404, a page that cannot
+  photo and the dinner's difficulty unchanged. It answers 200 with the
+  dinner; an invalid body is 400, an unknown dinner 404, a page that cannot
   ground it 422 `ungroundable` (the dinner is unchanged), recipe search not
   set up 409 `not_configured`, a search or model failure 502
   `search_failed` / `ai_failed` (only the reason code is logged, never the
   provider's text), and grounding a candidate or link that runs past 90
   seconds (fetch, photo and `normalize_recipe`, all in the request) 504
-  `ground_timeout`, leaving the dinner unchanged. An archived dinner is 409
-  `dinner_archived`. A candidate or link is written only if the dinner is
-  still as it was before grounding began: one renamed or grounded some
-  other way meanwhile is 409 `ground_conflict`, and one archived meanwhile
-  409 `dinner_archived`, either leaving the dinner unchanged. A method,
-  minutes or difficulty a member edits meanwhile is kept over the recipe's.
-  Any other failure grounding a candidate or link, or recording it on the
-  dinner, is 500, logged with a fixed reason and the dinner id only —
-  never the link, which can carry a personal token, or dependency error
-  text.
+  `ground_timeout`, leaving the dinner unchanged.
 - `/health` — liveness.
 - Everything else serves the embedded PWA with SPA fallback.
 
@@ -511,24 +488,13 @@ First run: while `household_settings.onboarding_completed_at` (read from
 `GET /api/v1/settings/household`) is null, every route redirects to
 `/onboarding`. Onboarding is a full screen outside the app shell, in three
 steps: the welcome (`/onboarding`), the Regulars (`/onboarding/regulars`,
-mock 1h, adding and archiving through the dinners API optimistically; Next
-waits for three saved Regulars, and a common pick is not offered once a
-Regular has a name `harness.Similar` to it — the PWA's copy of the name
-rules in `web/src/dinners/names.ts` folds letters with
-`web/src/dinners/letterFolds.json`, which `gen_folds.py` writes from the
-same table as the server's, and runs the same cases,
-`internal/ai/harness/testdata/dedupe_cases.json`, as the server's) and
+mock 1h, adding and archiving through the dinners API optimistically) and
 notifications (`/onboarding/notifications`: what MealQuest notifies about,
 the iOS install hint, "Turn on notifications" and "Maybe later"). Either
 button sends `PATCH /api/v1/settings/household` with
 `{"onboarding_completed": true}`; the server sets `onboarding_completed_at`
 to the time of that update (keeping the first time if it is already set;
 the field itself is read-only and `false` is refused) and the app goes Home.
-Completing needs at least three Regulars (`household.MinRegulars`); with
-fewer the server answers 400 `invalid_settings` naming
-`onboarding_completed` and changes nothing. Step 3 can be reached with
-fewer — by its URL, or after another member removes a Regular — so it then
-shows the server's reason with an "Add Regulars" button back to step 2.
 Notification permission is never asked for on page load; until Feature 19
 wires Web Push, "Turn on notifications" asks for nothing. Offline on the saved pages the
 settings cannot be read (the service worker never caches `/api/v1/settings`),

internal/ai/harness/dedupe_test.go

@@ -1,70 +1,10 @@
 package harness
 
 import (
-	"encoding/json"
-	"os"
 	"testing"
 	"unicode"
-	"unicode/utf8"
 )
 
-// TestSharedDedupeCases runs testdata/dedupe_cases.json, which the PWA's
-// copy of Normalize and Similar (web/src/dinners/names.ts) runs too, so the
-// two cannot drift apart on these names.
-func TestSharedDedupeCases(t *testing.T) {
-	raw, err := os.ReadFile("testdata/dedupe_cases.json")
-	if err != nil {
-		t.Fatal(err)
-	}
-	var cases struct {
-		Normalize []struct{ Name, Want string }
-		Similar   []struct {
-			A, B string
-			Want bool
-		}
-	}
-	if err := json.Unmarshal(raw, &cases); err != nil {
-		t.Fatal(err)
-	}
-	if len(cases.Normalize) == 0 || len(cases.Similar) == 0 {
-		t.Fatal("dedupe_cases.json has no cases")
-	}
-	for _, c := range cases.Normalize {
-		if got := Normalize(c.Name); got != c.Want {
-			t.Errorf("Normalize(%q) = %q, want %q", c.Name, got, c.Want)
-		}
-	}
-	for _, c := range cases.Similar {
-		if got := Similar(c.A, c.B); got != c.Want {
-			t.Errorf("Similar(%q, %q) = %v, want %v", c.A, c.B, got, c.Want)
-		}
-	}
-}
-
-// TestLetterFoldsMatchPWA checks that the PWA's letter-fold table, which
-// gen_folds.py writes beside folds_table.go, is letterFolds exactly; run
-// go generate when it fails.
-func TestLetterFoldsMatchPWA(t *testing.T) {
-	raw, err := os.ReadFile("../../../web/src/dinners/letterFolds.json")
-	if err != nil {
-		t.Fatal(err)
-	}
-	var pwa map[string]string
-	if err := json.Unmarshal(raw, &pwa); err != nil {
-		t.Fatal(err)
-	}
-	for r, want := range letterFolds {
-		if got, ok := pwa[string(r)]; !ok || got != want {
-			t.Errorf("PWA folds %U to %q (present %v), want %q", r, got, ok, want)
-		}
-	}
-	for k := range pwa {
-		if utf8.RuneCountInString(k) != 1 || letterFolds[[]rune(k)[0]] == "" {
-			t.Errorf("PWA folds %q, which letterFolds does not", k)
-		}
-	}
-}
-
 func TestNormalize(t *testing.T) {
 	tests := []struct {
 		name, want string

internal/ai/harness/gen_folds.py

@@ -1,8 +1,5 @@
 #!/usr/bin/env python3
-"""Generate folds_table.go, the letter-fold table used by harness.Normalize,
-and its copy web/src/dinners/letterFolds.json, used by the PWA's
-normalizeName (web/src/dinners/names.ts). TestLetterFoldsMatchPWA fails when
-the two differ.
+"""Generate folds_table.go, the letter-fold table used by harness.Normalize.
 
 Run from this directory with `go generate ./internal/ai/harness` (or
 `python3 gen_folds.py`; gofmt must be on PATH). It uses only the Python
@@ -31,14 +28,11 @@ Hangul syllables are left out: their decomposition is into conjoining jamo,
 not combining marks.
 """
 
-import json
 import re
 import subprocess
 import sys
 import unicodedata
 
-PWA_TABLE = "../../../web/src/dinners/letterFolds.json"
-
 EXTRA = {
     "ß": "ss", "ẞ": "ss", "æ": "ae", "Æ": "ae", "œ": "oe", "Œ": "oe",
     "þ": "th", "Þ": "th", "ð": "d", "Ð": "d", "ı": "i", "ʼn": "n",
@@ -116,9 +110,6 @@ def main():
     with open("folds_table.go", "w", encoding="utf-8") as f:
         f.write("\n".join(out) + "\n")
     subprocess.run(["gofmt", "-w", "folds_table.go"], check=True)
-    with open(PWA_TABLE, "w", encoding="ascii") as f:
-        json.dump({chr(cp): folded for cp, folded in entries}, f, indent=2)
-        f.write("\n")
 
 
 if __name__ == "__main__":

internal/ai/harness/testdata/dedupe_cases.json

@@ -1,136 +0,0 @@
-{
-  "normalize": [
-    {
-      "name": "Easy Chicken Tikka-Masala!",
-      "want": "chicken tikka masala"
-    },
-    {
-      "name": "  Homemade   Chili ",
-      "want": "chili"
-    },
-    {
-      "name": "Grandma's Stew",
-      "want": "grandmas stew"
-    },
-    {
-      "name": "Grandma’s Stew",
-      "want": "grandmas stew"
-    },
-    {
-      "name": "İskender Kebab",
-      "want": "iskender kebab"
-    },
-    {
-      "name": "Paella à la Valenciana",
-      "want": "paella la valenciana"
-    },
-    {
-      "name": "Crème Brûlée",
-      "want": "creme brulee"
-    },
-    {
-      "name": "Crème Brûlée",
-      "want": "creme brulee"
-    },
-    {
-      "name": "Smørrebrød",
-      "want": "smorrebrod"
-    },
-    {
-      "name": "Pierogi z Łososiem",
-      "want": "pierogi z lososiem"
-    },
-    {
-      "name": "Straße Würstchen",
-      "want": "strasse wurstchen"
-    },
-    {
-      "name": "Œufs en Cocotte",
-      "want": "oeufs en cocotte"
-    },
-    {
-      "name": "Æbleskiver",
-      "want": "aebleskiver"
-    },
-    {
-      "name": "Phở Bò",
-      "want": "pho bo"
-    },
-    {
-      "name": "The Best Quick Recipe",
-      "want": ""
-    },
-    {
-      "name": "Chicken stir-fry",
-      "want": "chicken stir fry"
-    },
-    {
-      "name": "7-layer dip",
-      "want": "7 layer dip"
-    },
-    {
-      "name": "Ƈhili",
-      "want": "chili"
-    },
-    {
-      "name": "Ꞔarbanzo Stew",
-      "want": "carbanzo stew"
-    },
-    {
-      "name": "ΜΟΥΣΑΚΑΣ",
-      "want": "μουσακασ"
-    }
-  ],
-  "similar": [
-    {
-      "a": "Homemade chili",
-      "b": "Chili",
-      "want": true
-    },
-    {
-      "a": "Easy Spaghetti Bolognese",
-      "b": "spaghetti bolognese",
-      "want": true
-    },
-    {
-      "a": "Chicken stir fry",
-      "b": "Chicken stir-fry",
-      "want": true
-    },
-    {
-      "a": "Crème brûlée",
-      "b": "Creme brulee",
-      "want": true
-    },
-    {
-      "a": "Smørrebrød",
-      "b": "smorrebrod",
-      "want": true
-    },
-    {
-      "a": "Beef tacos",
-      "b": "Fish tacos",
-      "want": false
-    },
-    {
-      "a": "Chili",
-      "b": "White chicken chili",
-      "want": false
-    },
-    {
-      "a": "Pot roast",
-      "b": "Roast",
-      "want": false
-    },
-    {
-      "a": "The best",
-      "b": "Easy recipe",
-      "want": false
-    },
-    {
-      "a": "Ƈhili",
-      "b": "Chili",
-      "want": true
-    }
-  ]
-}

internal/db/db_test.go

@@ -190,7 +190,6 @@ func TestDinners(t *testing.T) {
 		Difficulty:      str("medium"),
 		Cuisine:         sql.NullString{},
 		RecipeID:        sql.NullString{},
-		RecipeUrl:       str("https://example.com/tacos"),
 		PhotoID:         str(photo.ID),
 		GroundingStatus: "failed",
 		UpdatedBy:       str("sam@example.com"),
@@ -268,7 +267,7 @@ func TestDinners(t *testing.T) {
 	}
 	var unarchivedIDs []string
 	for _, d := range unarchived {
-		unarchivedIDs = append(unarchivedIDs, d.Dinner.ID)
+		unarchivedIDs = append(unarchivedIDs, d.ID)
 	}
 	assertIDs(t, "unarchived", unarchivedIDs, other.ID, third.ID)
 	_, err = q.ArchiveDinner(ctx, db.ArchiveDinnerParams{ID: "missing", UpdatedAt: archivedAt})

internal/db/dinners.sql.go

@@ -16,7 +16,7 @@ SET status = 'archived',
 	updated_by = ?,
 	updated_at = ?
 WHERE id = ?
-RETURNING id, name, normalized_name, status, origin, method, minutes_total, difficulty, cuisine, is_favorite, recipe_id, photo_id, grounding_status, updated_by, created_at, updated_at, recipe_url, grounding_error, grounding_revision
+RETURNING id, name, normalized_name, status, origin, method, minutes_total, difficulty, cuisine, is_favorite, recipe_id, photo_id, grounding_status, updated_by, created_at, updated_at, recipe_url, grounding_error
 `
 
 type ArchiveDinnerParams struct {
@@ -48,24 +48,10 @@ func (q *Queries) ArchiveDinner(ctx context.Context, arg ArchiveDinnerParams) (D
 		&i.UpdatedAt,
 		&i.RecipeUrl,
 		&i.GroundingError,
-		&i.GroundingRevision,
 	)
 	return i, err
 }
 
-const countRegularDinners = `-- name: CountRegularDinners :one
-SELECT COUNT(*) FROM dinners
-WHERE status = 'regular'
-`
-
-// How many Regulars the household has; archived dinners are not counted.
-func (q *Queries) CountRegularDinners(ctx context.Context) (int64, error) {
-	row := q.db.QueryRowContext(ctx, countRegularDinners)
-	var count int64
-	err := row.Scan(&count)
-	return count, err
-}
-
 const createDinner = `-- name: CreateDinner :one
 INSERT INTO dinners (
 	id, name, normalized_name, status, origin, method, minutes_total,
@@ -76,7 +62,7 @@ INSERT INTO dinners (
 	?, ?, ?, ?, ?, ?,
 	?, ?, ?, ?
 )
-RETURNING id, name, normalized_name, status, origin, method, minutes_total, difficulty, cuisine, is_favorite, recipe_id, photo_id, grounding_status, updated_by, created_at, updated_at, recipe_url, grounding_error, grounding_revision
+RETURNING id, name, normalized_name, status, origin, method, minutes_total, difficulty, cuisine, is_favorite, recipe_id, photo_id, grounding_status, updated_by, created_at, updated_at, recipe_url, grounding_error
 `
 
 type CreateDinnerParams struct {
@@ -139,7 +125,6 @@ func (q *Queries) CreateDinner(ctx context.Context, arg CreateDinnerParams) (Din
 		&i.UpdatedAt,
 		&i.RecipeUrl,
 		&i.GroundingError,
-		&i.GroundingRevision,
 	)
 	return i, err
 }
@@ -150,13 +135,11 @@ SET grounding_status = 'failed',
 	grounding_error = ?1,
 	updated_at = ?2
 WHERE grounding_status = 'pending'
-	AND status <> 'archived'
 	AND NOT EXISTS (
 		SELECT 1 FROM jobs
 		WHERE jobs.kind = ?3
 			AND jobs.status IN ('queued', 'running')
 			AND json_extract(jobs.payload, '$.dinner_id') = dinners.id
-			AND json_extract(jobs.payload, '$.revision') = dinners.grounding_revision
 	)
 `
 
@@ -166,11 +149,10 @@ type FailOrphanedPendingDinnerGroundingsParams struct {
 	Kind           string
 }
 
-// Fails every unarchived dinner still pending whose grounding job for its
-// current grounding_revision is no longer queued or running: the process
-// stopped before the job, or before its handler recorded a result. An
-// archived dinner is left as it is; archiving stopped its grounding. Run at
-// boot, after the job runner fails the jobs a previous process left running.
+// Fails every dinner still pending whose grounding job is no longer queued
+// or running: the process stopped before the job, or before its handler
+// recorded a result. Run at boot, after the job runner fails the jobs a
+// previous process left running.
 func (q *Queries) FailOrphanedPendingDinnerGroundings(ctx context.Context, arg FailOrphanedPendingDinnerGroundingsParams) (int64, error) {
 	result, err := q.db.ExecContext(ctx, failOrphanedPendingDinnerGroundings, arg.GroundingError, arg.UpdatedAt, arg.Kind)
 	if err != nil {
@@ -184,30 +166,19 @@ UPDATE dinners
 SET grounding_status = 'failed',
 	grounding_error = ?,
 	updated_at = ?
-WHERE id = ?
-	AND status <> 'archived'
-	AND grounding_status = 'pending'
-	AND grounding_revision = ?
+WHERE id = ? AND grounding_status = 'pending'
 `
 
 type FailPendingDinnerGroundingParams struct {
-	GroundingError    sql.NullString
-	UpdatedAt         string
-	ID                string
-	GroundingRevision int64
+	GroundingError sql.NullString
+	UpdatedAt      string
+	ID             string
 }
 
-// Records why the background grounding of an unarchived dinner still
-// pending at the grounding_revision it was grounded for failed; a dinner
-// grounded some other way, renamed or archived meanwhile is left as it is
-// (0 rows).
+// Records why the background grounding of a dinner still pending failed; a
+// dinner grounded some other way meanwhile is left as it is (0 rows).
 func (q *Queries) FailPendingDinnerGrounding(ctx context.Context, arg FailPendingDinnerGroundingParams) (int64, error) {
-	result, err := q.db.ExecContext(ctx, failPendingDinnerGrounding,
-		arg.GroundingError,
-		arg.UpdatedAt,
-		arg.ID,
-		arg.GroundingRevision,
-	)
+	result, err := q.db.ExecContext(ctx, failPendingDinnerGrounding, arg.GroundingError, arg.UpdatedAt, arg.ID)
 	if err != nil {
 		return 0, err
 	}
@@ -215,7 +186,7 @@ func (q *Queries) FailPendingDinnerGrounding(ctx context.Context, arg FailPendin
 }
 
 const getDinner = `-- name: GetDinner :one
-SELECT id, name, normalized_name, status, origin, method, minutes_total, difficulty, cuisine, is_favorite, recipe_id, photo_id, grounding_status, updated_by, created_at, updated_at, recipe_url, grounding_error, grounding_revision FROM dinners
+SELECT id, name, normalized_name, status, origin, method, minutes_total, difficulty, cuisine, is_favorite, recipe_id, photo_id, grounding_status, updated_by, created_at, updated_at, recipe_url, grounding_error FROM dinners
 WHERE id = ?
 `
 
@@ -241,83 +212,50 @@ func (q *Queries) GetDinner(ctx context.Context, id string) (Dinner, error) {
 		&i.UpdatedAt,
 		&i.RecipeUrl,
 		&i.GroundingError,
-		&i.GroundingRevision,
 	)
 	return i, err
 }
 
 const groundDinner = `-- name: GroundDinner :one
 UPDATE dinners
-SET recipe_id = ?1,
-	recipe_url = NULL,
-	photo_id = ?2,
-	method = CASE WHEN method IS ?3
-		THEN ?4 ELSE method END,
-	minutes_total = CASE WHEN minutes_total IS ?5
-		THEN ?6 ELSE minutes_total END,
-	difficulty = CASE WHEN difficulty IS ?7
-		THEN ?8 ELSE difficulty END,
-	grounding_status = ?9,
+SET recipe_id = ?,
+	photo_id = ?,
+	method = ?,
+	minutes_total = ?,
+	difficulty = ?,
+	grounding_status = ?,
 	grounding_error = NULL,
-	updated_by = ?10,
-	updated_at = ?11
-WHERE id = ?12
-	AND status <> 'archived'
-	AND name = ?13
-	AND normalized_name = ?14
-	AND grounding_status = ?15
-	AND grounding_revision = ?16
-	AND recipe_id IS ?17
-RETURNING id, name, normalized_name, status, origin, method, minutes_total, difficulty, cuisine, is_favorite, recipe_id, photo_id, grounding_status, updated_by, created_at, updated_at, recipe_url, grounding_error, grounding_revision
+	updated_by = ?,
+	updated_at = ?
+WHERE id = ?
+RETURNING id, name, normalized_name, status, origin, method, minutes_total, difficulty, cuisine, is_favorite, recipe_id, photo_id, grounding_status, updated_by, created_at, updated_at, recipe_url, grounding_error
 `
 
 type GroundDinnerParams struct {
-	RecipeID                  sql.NullString
-	PhotoID                   sql.NullString
-	ObservedMethod            sql.NullString
-	Method                    sql.NullString
-	ObservedMinutesTotal      sql.NullInt64
-	MinutesTotal              sql.NullInt64
-	ObservedDifficulty        sql.NullString
-	Difficulty                sql.NullString
-	GroundingStatus           string
-	UpdatedBy                 sql.NullString
-	UpdatedAt                 string
-	ID                        string
-	ObservedName              string
-	ObservedNormalizedName    string
-	ObservedGroundingStatus   string
-	ObservedGroundingRevision int64
-	ObservedRecipeID          sql.NullString
+	RecipeID        sql.NullString
+	PhotoID         sql.NullString
+	Method          sql.NullString
+	MinutesTotal    sql.NullInt64
+	Difficulty      sql.NullString
+	GroundingStatus string
+	UpdatedBy       sql.NullString
+	UpdatedAt       string
+	ID              string
 }
 
-// Records a dinner's grounding by hand (grounded or manual) and clears any
-// grounding_error and pasted recipe_url: the recipe chosen replaces the
-// link. It writes only an unarchived dinner still as it was observed
-// before grounding (same name, normalized_name, grounding_status,
-// grounding_revision and recipe_id), so a dinner renamed, archived or
-// grounded some other way meanwhile is left as it is. That dinner, or an
-// unknown id, returns sql.ErrNoRows. A method, minutes_total or difficulty
-// no longer as observed is kept: a member edited it while it was grounding.
+// Records a dinner's grounding (grounded or manual) and clears any
+// grounding_error. An unknown id returns sql.ErrNoRows.
 func (q *Queries) GroundDinner(ctx context.Context, arg GroundDinnerParams) (Dinner, error) {
 	row := q.db.QueryRowContext(ctx, groundDinner,
 		arg.RecipeID,
 		arg.PhotoID,
-		arg.ObservedMethod,
 		arg.Method,
-		arg.ObservedMinutesTotal,
 		arg.MinutesTotal,
-		arg.ObservedDifficulty,
 		arg.Difficulty,
 		arg.GroundingStatus,
 		arg.UpdatedBy,
 		arg.UpdatedAt,
 		arg.ID,
-		arg.ObservedName,
-		arg.ObservedNormalizedName,
-		arg.ObservedGroundingStatus,
-		arg.ObservedGroundingRevision,
-		arg.ObservedRecipeID,
 	)
 	var i Dinner
 	err := row.Scan(
@@ -339,43 +277,35 @@ func (q *Queries) GroundDinner(ctx context.Context, arg GroundDinnerParams) (Din
 		&i.UpdatedAt,
 		&i.RecipeUrl,
 		&i.GroundingError,
-		&i.GroundingRevision,
 	)
 	return i, err
 }
 
 const groundPendingDinner = `-- name: GroundPendingDinner :execrows
 UPDATE dinners
-SET recipe_id = ?1,
-	photo_id = ?2,
-	method = COALESCE(method, ?3),
-	minutes_total = COALESCE(minutes_total, ?4),
-	difficulty = COALESCE(difficulty, ?5),
+SET recipe_id = ?,
+	photo_id = ?,
+	method = ?,
+	minutes_total = ?,
+	difficulty = ?,
 	grounding_status = 'grounded',
 	grounding_error = NULL,
-	updated_at = ?6
-WHERE id = ?7
-	AND status <> 'archived'
-	AND grounding_status = 'pending'
-	AND grounding_revision = ?8
+	updated_at = ?
+WHERE id = ? AND grounding_status = 'pending'
 `
 
 type GroundPendingDinnerParams struct {
-	RecipeID          sql.NullString
-	PhotoID           sql.NullString
-	Method            sql.NullString
-	MinutesTotal      sql.NullInt64
-	Difficulty        sql.NullString
-	UpdatedAt         string
-	ID                string
-	GroundingRevision int64
+	RecipeID     sql.NullString
+	PhotoID      sql.NullString
+	Method       sql.NullString
+	MinutesTotal sql.NullInt64
+	Difficulty   sql.NullString
+	UpdatedAt    string
+	ID           string
 }
 
-// Records the background grounding of an unarchived dinner still pending at
-// the grounding_revision it was grounded for; a dinner grounded some other
-// way, renamed or archived meanwhile is left as it is (0 rows). A method,
-// minutes_total or difficulty already set is kept: a pending dinner has
-// them only when a member edited them while it was grounding.
+// Records the background grounding of a dinner still pending; a dinner
+// grounded some other way meanwhile is left as it is (0 rows).
 func (q *Queries) GroundPendingDinner(ctx context.Context, arg GroundPendingDinnerParams) (int64, error) {
 	result, err := q.db.ExecContext(ctx, groundPendingDinner,
 		arg.RecipeID,
@@ -385,7 +315,6 @@ func (q *Queries) GroundPendingDinner(ctx context.Context, arg GroundPendingDinn
 		arg.Difficulty,
 		arg.UpdatedAt,
 		arg.ID,
-		arg.GroundingRevision,
 	)
 	if err != nil {
 		return 0, err
@@ -394,7 +323,7 @@ func (q *Queries) GroundPendingDinner(ctx context.Context, arg GroundPendingDinn
 }
 
 const listDinnersByStatus = `-- name: ListDinnersByStatus :many
-SELECT id, name, normalized_name, status, origin, method, minutes_total, difficulty, cuisine, is_favorite, recipe_id, photo_id, grounding_status, updated_by, created_at, updated_at, recipe_url, grounding_error, grounding_revision FROM dinners
+SELECT id, name, normalized_name, status, origin, method, minutes_total, difficulty, cuisine, is_favorite, recipe_id, photo_id, grounding_status, updated_by, created_at, updated_at, recipe_url, grounding_error FROM dinners
 WHERE status = ?
 ORDER BY normalized_name, id
 `
@@ -427,7 +356,6 @@ func (q *Queries) ListDinnersByStatus(ctx context.Context, status string) ([]Din
 			&i.UpdatedAt,
 			&i.RecipeUrl,
 			&i.GroundingError,
-			&i.GroundingRevision,
 		); err != nil {
 			return nil, err
 		}
@@ -443,50 +371,40 @@ func (q *Queries) ListDinnersByStatus(ctx context.Context, status string) ([]Din
 }
 
 const listUnarchivedDinners = `-- name: ListUnarchivedDinners :many
-SELECT dinners.id, dinners.name, dinners.normalized_name, dinners.status, dinners.origin, dinners.method, dinners.minutes_total, dinners.difficulty, dinners.cuisine, dinners.is_favorite, dinners.recipe_id, dinners.photo_id, dinners.grounding_status, dinners.updated_by, dinners.created_at, dinners.updated_at, dinners.recipe_url, dinners.grounding_error, dinners.grounding_revision, recipes.source_url AS recipe_source_url
-FROM dinners
-LEFT JOIN recipes ON recipes.id = dinners.recipe_id
-WHERE dinners.status <> 'archived'
-ORDER BY dinners.id
+SELECT id, name, normalized_name, status, origin, method, minutes_total, difficulty, cuisine, is_favorite, recipe_id, photo_id, grounding_status, updated_by, created_at, updated_at, recipe_url, grounding_error FROM dinners
+WHERE status <> 'archived'
+ORDER BY id
 `
 
-type ListUnarchivedDinnersRow struct {
-	Dinner          Dinner
-	RecipeSourceUrl sql.NullString
-}
-
-// Every dinner a new or renamed dinner must not repeat, with the
-// source_url of the recipe it is grounded in (NULL while it has none).
-func (q *Queries) ListUnarchivedDinners(ctx context.Context) ([]ListUnarchivedDinnersRow, error) {
+// Every dinner a new or renamed dinner must not repeat.
+func (q *Queries) ListUnarchivedDinners(ctx context.Context) ([]Dinner, error) {
 	rows, err := q.db.QueryContext(ctx, listUnarchivedDinners)
 	if err != nil {
 		return nil, err
 	}
 	defer rows.Close()
-	var items []ListUnarchivedDinnersRow
+	var items []Dinner
 	for rows.Next() {
-		var i ListUnarchivedDinnersRow
+		var i Dinner
 		if err := rows.Scan(
-			&i.Dinner.ID,
-			&i.Dinner.Name,
-			&i.Dinner.NormalizedName,
-			&i.Dinner.Status,
-			&i.Dinner.Origin,
-			&i.Dinner.Method,
-			&i.Dinner.MinutesTotal,
-			&i.Dinner.Difficulty,
-			&i.Dinner.Cuisine,
-			&i.Dinner.IsFavorite,
-			&i.Dinner.RecipeID,
-			&i.Dinner.PhotoID,
-			&i.Dinner.GroundingStatus,
-			&i.Dinner.UpdatedBy,
-			&i.Dinner.CreatedAt,
-			&i.Dinner.UpdatedAt,
-			&i.Dinner.RecipeUrl,
-			&i.Dinner.GroundingError,
-			&i.Dinner.GroundingRevision,
-			&i.RecipeSourceUrl,
+			&i.ID,
+			&i.Name,
+			&i.NormalizedName,
+			&i.Status,
+			&i.Origin,
+			&i.Method,
+			&i.MinutesTotal,
+			&i.Difficulty,
+			&i.Cuisine,
+			&i.IsFavorite,
+			&i.RecipeID,
+			&i.PhotoID,
+			&i.GroundingStatus,
+			&i.UpdatedBy,
+			&i.CreatedAt,
+			&i.UpdatedAt,
+			&i.RecipeUrl,
+			&i.GroundingError,
 		); err != nil {
 			return nil, err
 		}
@@ -507,7 +425,7 @@ SET is_favorite = ?,
 	updated_by = ?,
 	updated_at = ?
 WHERE id = ?
-RETURNING id, name, normalized_name, status, origin, method, minutes_total, difficulty, cuisine, is_favorite, recipe_id, photo_id, grounding_status, updated_by, created_at, updated_at, recipe_url, grounding_error, grounding_revision
+RETURNING id, name, normalized_name, status, origin, method, minutes_total, difficulty, cuisine, is_favorite, recipe_id, photo_id, grounding_status, updated_by, created_at, updated_at, recipe_url, grounding_error
 `
 
 type SetDinnerFavoriteParams struct {
@@ -545,7 +463,6 @@ func (q *Queries) SetDinnerFavorite(ctx context.Context, arg SetDinnerFavoritePa
 		&i.UpdatedAt,
 		&i.RecipeUrl,
 		&i.GroundingError,
-		&i.GroundingRevision,
 	)
 	return i, err
 }
@@ -556,7 +473,7 @@ SET is_favorite = 1 - is_favorite,
 	updated_by = ?,
 	updated_at = ?
 WHERE id = ?
-RETURNING id, name, normalized_name, status, origin, method, minutes_total, difficulty, cuisine, is_favorite, recipe_id, photo_id, grounding_status, updated_by, created_at, updated_at, recipe_url, grounding_error, grounding_revision
+RETURNING id, name, normalized_name, status, origin, method, minutes_total, difficulty, cuisine, is_favorite, recipe_id, photo_id, grounding_status, updated_by, created_at, updated_at, recipe_url, grounding_error
 `
 
 type ToggleDinnerFavoriteParams struct {
@@ -588,7 +505,6 @@ func (q *Queries) ToggleDinnerFavorite(ctx context.Context, arg ToggleDinnerFavo
 		&i.UpdatedAt,
 		&i.RecipeUrl,
 		&i.GroundingError,
-		&i.GroundingRevision,
 	)
 	return i, err
 }
@@ -604,33 +520,29 @@ SET name = ?,
 	difficulty = ?,
 	cuisine = ?,
 	recipe_id = ?,
-	recipe_url = ?,
 	photo_id = ?,
 	grounding_status = ?,
-	grounding_revision = ?,
 	updated_by = ?,
 	updated_at = ?
 WHERE id = ?
-RETURNING id, name, normalized_name, status, origin, method, minutes_total, difficulty, cuisine, is_favorite, recipe_id, photo_id, grounding_status, updated_by, created_at, updated_at, recipe_url, grounding_error, grounding_revision
+RETURNING id, name, normalized_name, status, origin, method, minutes_total, difficulty, cuisine, is_favorite, recipe_id, photo_id, grounding_status, updated_by, created_at, updated_at, recipe_url, grounding_error
 `
 
 type UpdateDinnerParams struct {
-	Name              string
-	NormalizedName    string
-	Status            string
-	Origin            string
-	Method            sql.NullString
-	MinutesTotal      sql.NullInt64
-	Difficulty        sql.NullString
-	Cuisine           sql.NullString
-	RecipeID          sql.NullString
-	RecipeUrl         sql.NullString
-	PhotoID           sql.NullString
-	GroundingStatus   string
-	GroundingRevision int64
-	UpdatedBy         sql.NullString
-	UpdatedAt         string
-	ID                string
+	Name            string
+	NormalizedName  string
+	Status          string
+	Origin          string
+	Method          sql.NullString
+	MinutesTotal    sql.NullInt64
+	Difficulty      sql.NullString
+	Cuisine         sql.NullString
+	RecipeID        sql.NullString
+	PhotoID         sql.NullString
+	GroundingStatus string
+	UpdatedBy       sql.NullString
+	UpdatedAt       string
+	ID              string
 }
 
 // An unknown id returns sql.ErrNoRows.
@@ -645,10 +557,8 @@ func (q *Queries) UpdateDinner(ctx context.Context, arg UpdateDinnerParams) (Din
 		arg.Difficulty,
 		arg.Cuisine,
 		arg.RecipeID,
-		arg.RecipeUrl,
 		arg.PhotoID,
 		arg.GroundingStatus,
-		arg.GroundingRevision,
 		arg.UpdatedBy,
 		arg.UpdatedAt,
 		arg.ID,
@@ -673,7 +583,6 @@ func (q *Queries) UpdateDinner(ctx context.Context, arg UpdateDinnerParams) (Din
 		&i.UpdatedAt,
 		&i.RecipeUrl,
 		&i.GroundingError,
-		&i.GroundingRevision,
 	)
 	return i, err
 }

internal/db/models.go

@@ -51,25 +51,24 @@ type ChatSetting struct {
 }
 
 type Dinner struct {
-	ID                string
-	Name              string
-	NormalizedName    string
-	Status            string
-	Origin            string
-	Method            sql.NullString
-	MinutesTotal      sql.NullInt64
-	Difficulty        sql.NullString
-	Cuisine           sql.NullString
-	IsFavorite        int64
-	RecipeID          sql.NullString
-	PhotoID           sql.NullString
-	GroundingStatus   string
-	UpdatedBy         sql.NullString
-	CreatedAt         string
-	UpdatedAt         string
-	RecipeUrl         sql.NullString
-	GroundingError    sql.NullString
-	GroundingRevision int64
+	ID              string
+	Name            string
+	NormalizedName  string
+	Status          string
+	Origin          string
+	Method          sql.NullString
+	MinutesTotal    sql.NullInt64
+	Difficulty      sql.NullString
+	Cuisine         sql.NullString
+	IsFavorite      int64
+	RecipeID        sql.NullString
+	PhotoID         sql.NullString
+	GroundingStatus string
+	UpdatedBy       sql.NullString
+	CreatedAt       string
+	UpdatedAt       string
+	RecipeUrl       sql.NullString
+	GroundingError  sql.NullString
 }
 
 type HouseholdSetting struct {

internal/db/querier.go

@@ -21,8 +21,6 @@ type Querier interface {
 	// Drops references to the runs created before the cutoff, so the purge
 	// can delete them.
 	ClearWeekPlanAIRunsBefore(ctx context.Context, cutoff string) (int64, error)
-	// How many Regulars the household has; archived dinners are not counted.
-	CountRegularDinners(ctx context.Context) (int64, error)
 	CreateAIRun(ctx context.Context, arg CreateAIRunParams) error
 	CreateDinner(ctx context.Context, arg CreateDinnerParams) (Dinner, error)
 	CreateJob(ctx context.Context, arg CreateJobParams) error
@@ -36,16 +34,13 @@ type Querier interface {
 	DeleteRecipeIngredients(ctx context.Context, recipeID string) error
 	DeleteRecipeSteps(ctx context.Context, recipeID string) error
 	FailJob(ctx context.Context, arg FailJobParams) (int64, error)
-	// Fails every unarchived dinner still pending whose grounding job for its
-	// current grounding_revision is no longer queued or running: the process
-	// stopped before the job, or before its handler recorded a result. An
-	// archived dinner is left as it is; archiving stopped its grounding. Run at
-	// boot, after the job runner fails the jobs a previous process left running.
+	// Fails every dinner still pending whose grounding job is no longer queued
+	// or running: the process stopped before the job, or before its handler
+	// recorded a result. Run at boot, after the job runner fails the jobs a
+	// previous process left running.
 	FailOrphanedPendingDinnerGroundings(ctx context.Context, arg FailOrphanedPendingDinnerGroundingsParams) (int64, error)
-	// Records why the background grounding of an unarchived dinner still
-	// pending at the grounding_revision it was grounded for failed; a dinner
-	// grounded some other way, renamed or archived meanwhile is left as it is
-	// (0 rows).
+	// Records why the background grounding of a dinner still pending failed; a
+	// dinner grounded some other way meanwhile is left as it is (0 rows).
 	FailPendingDinnerGrounding(ctx context.Context, arg FailPendingDinnerGroundingParams) (int64, error)
 	// Fails every job left running, at boot before any worker starts.
 	FailRunningJobs(ctx context.Context, arg FailRunningJobsParams) (int64, error)
@@ -67,20 +62,11 @@ type Querier interface {
 	GetRecipeBySourceURL(ctx context.Context, sourceUrl string) (Recipe, error)
 	// Returns sql.ErrNoRows until the row exists.
 	GetRecipeSearchSettings(ctx context.Context) (RecipeSearchSetting, error)
-	// Records a dinner's grounding by hand (grounded or manual) and clears any
-	// grounding_error and pasted recipe_url: the recipe chosen replaces the
-	// link. It writes only an unarchived dinner still as it was observed
-	// before grounding (same name, normalized_name, grounding_status,
-	// grounding_revision and recipe_id), so a dinner renamed, archived or
-	// grounded some other way meanwhile is left as it is. That dinner, or an
-	// unknown id, returns sql.ErrNoRows. A method, minutes_total or difficulty
-	// no longer as observed is kept: a member edited it while it was grounding.
+	// Records a dinner's grounding (grounded or manual) and clears any
+	// grounding_error. An unknown id returns sql.ErrNoRows.
 	GroundDinner(ctx context.Context, arg GroundDinnerParams) (Dinner, error)
-	// Records the background grounding of an unarchived dinner still pending at
-	// the grounding_revision it was grounded for; a dinner grounded some other
-	// way, renamed or archived meanwhile is left as it is (0 rows). A method,
-	// minutes_total or difficulty already set is kept: a pending dinner has
-	// them only when a member edited them while it was grounding.
+	// Records the background grounding of a dinner still pending; a dinner
+	// grounded some other way meanwhile is left as it is (0 rows).
 	GroundPendingDinner(ctx context.Context, arg GroundPendingDinnerParams) (int64, error)
 	ListDinnersByStatus(ctx context.Context, status string) ([]Dinner, error)
 	// The planned dinners dated from from_date up to but not including
@@ -91,9 +77,8 @@ type Querier interface {
 	ListRecentDeclinedNames(ctx context.Context, limit int64) ([]string, error)
 	ListRecipeIngredients(ctx context.Context, recipeID string) ([]RecipeIngredient, error)
 	ListRecipeSteps(ctx context.Context, recipeID string) ([]RecipeStep, error)
-	// Every dinner a new or renamed dinner must not repeat, with the
-	// source_url of the recipe it is grounded in (NULL while it has none).
-	ListUnarchivedDinners(ctx context.Context) ([]ListUnarchivedDinnersRow, error)
+	// Every dinner a new or renamed dinner must not repeat.
+	ListUnarchivedDinners(ctx context.Context) ([]Dinner, error)
 	// Stores a partial result of a running job.
 	PublishJobResult(ctx context.Context, arg PublishJobResultParams) (int64, error)
 	// An unknown id returns sql.ErrNoRows.

internal/dinners/dinners.go

@@ -11,11 +11,9 @@ import (
 	"errors"
 	"fmt"
 	"log/slog"
-	"math"
 	"net/url"
 	"slices"
 	"strings"
-	"sync"
 	"unicode"
 	"unicode/utf8"
 
@@ -132,11 +130,6 @@ type Service struct {
 	grounder  *recipes.Grounder
 	logger    *slog.Logger
 	groundJob *jobs.Kind[GroundJob]
-
-	// groundingsMu guards groundings: the KindGroundDinner jobs running,
-	// by dinner id, so archiving or renaming a dinner can stop them.
-	groundingsMu sync.Mutex
-	groundings   map[string]map[*runningGrounding]struct{}
 }
 
 // NewService returns a service over st that grounds dinners with grounder
@@ -153,7 +146,7 @@ func NewService(st *store.Store, grounder *recipes.Grounder, runner *jobs.Runner
 	case logger == nil:
 		return nil, errors.New("dinners: nil logger")
 	}
-	s := &Service{st: st, grounder: grounder, logger: logger, groundings: make(map[string]map[*runningGrounding]struct{})}
+	s := &Service{st: st, grounder: grounder, logger: logger}
 	kind, err := jobs.Register(runner, KindGroundDinner, s.runGroundJob, Reasons...)
 	if err != nil {
 		return nil, err
@@ -183,70 +176,57 @@ func (s *Service) CreateRegular(ctx context.Context, r NewRegular, updatedBy str
 	if err != nil {
 		return Created{}, err
 	}
-	jobID, err := s.enqueueGrounding(ctx, d.ID, d.GroundingRevision)
-	if err != nil {
-		return Created{}, err
-	}
-	if jobID == nil {
-		row, err := db.New(s.st.Reader).GetDinner(context.WithoutCancel(ctx), d.ID)
-		if err != nil {
-			return Created{}, fmt.Errorf("dinners: read %s: %w", d.ID, err)
-		}
-		return Created{Dinner: fromRow(row)}, nil
-	}
-	return Created{Dinner: fromRow(d), GroundingJobID: jobID}, nil
-}
-
-// enqueueGrounding enqueues the KindGroundDinner job for pending dinner id
-// at grounding_revision revision and returns its id. When the job cannot be
-// enqueued, the dinner's grounding is failed with ReasonGroundingError, so
-// it is not left pending with no job, and the id is nil.
-func (s *Service) enqueueGrounding(ctx context.Context, id string, revision int64) (*string, error) {
-	jobID, err := s.groundJob.Enqueue(ctx, GroundJob{DinnerID: id, Revision: revision})
+	jobID, err := s.groundJob.Enqueue(ctx, GroundJob{DinnerID: d.ID})
 	if err == nil {
-		return &jobID, nil
+		return Created{Dinner: d, GroundingJobID: &jobID}, nil
 	}
-	// The error is a database error, never a dependency's text.
-	s.logger.ErrorContext(ctx, "dinner grounding not enqueued", "dinner_id", id, "error", err)
-	if _, err := db.New(s.st.Writer).FailPendingDinnerGrounding(context.WithoutCancel(ctx), db.FailPendingDinnerGroundingParams{
-		GroundingError:    sql.NullString{String: ReasonGroundingError, Valid: true},
-		UpdatedAt:         store.Now().String(),
-		ID:                id,
-		GroundingRevision: revision,
+	// The dinner is stored; record that it will not be grounded so it is
+	// not left pending with no job. The error is a database error, never a
+	// dependency's text.
+	s.logger.ErrorContext(ctx, "dinner grounding not enqueued", "dinner_id", d.ID, "error", err)
+	write := context.WithoutCancel(ctx)
+	if _, err := db.New(s.st.Writer).FailPendingDinnerGrounding(write, db.FailPendingDinnerGroundingParams{
+		GroundingError: sql.NullString{String: ReasonGroundingError, Valid: true},
+		UpdatedAt:      store.Now().String(),
+		ID:             d.ID,
 	}); err != nil {
-		return nil, fmt.Errorf("dinners: record failed grounding of %s: %w", id, err)
+		return Created{}, fmt.Errorf("dinners: record failed grounding of %s: %w", d.ID, err)
 	}
-	return nil, nil
+	row, err := db.New(s.st.Reader).GetDinner(write, d.ID)
+	if err != nil {
+		return Created{}, fmt.Errorf("dinners: read %s: %w", d.ID, err)
+	}
+	return Created{Dinner: fromRow(row)}, nil
 }
 
-func (s *Service) createRegular(ctx context.Context, r NewRegular, updatedBy string) (db.Dinner, error) {
+func (s *Service) createRegular(ctx context.Context, r NewRegular, updatedBy string) (Dinner, error) {
 	if updatedBy == "" {
-		return db.Dinner{}, errors.New("dinners: create: no member to record as updated_by")
+		return Dinner{}, errors.New("dinners: create: no member to record as updated_by")
 	}
 	var name string
 	var recipeURL sql.NullString
 	switch {
 	case r.Name != nil && r.RecipeURL != nil:
-		return db.Dinner{}, invalid("name", "give a name or a recipe_url, not both")
+		return Dinner{}, invalid("name", "give a name or a recipe_url, not both")
 	case r.Name != nil:
 		n, err := checkName(*r.Name)
 		if err != nil {
-			return db.Dinner{}, err
+			return Dinner{}, err
 		}
 		name = n
 	case r.RecipeURL != nil:
 		u, err := checkRecipeURL(*r.RecipeURL)
 		if err != nil {
-			return db.Dinner{}, err
+			return Dinner{}, err
 		}
 		n, ok := nameFromURL(u)
 		if !ok {
-			return db.Dinner{}, invalid("recipe_url", "the link does not name a dinner; add it by name instead")
+			return Dinner{}, invalid("recipe_url", "the link does not name a dinner; add it by name instead")
 		}
 		name = n
 		recipeURL = sql.NullString{String: u.String(), Valid: true}
 	default:
-		return db.Dinner{}, invalid("name", "give a name or a recipe_url")
+		return Dinner{}, invalid("name", "give a name or a recipe_url")
 	}
 
 	var row db.Dinner
@@ -275,9 +255,9 @@ func (s *Service) createRegular(ctx context.Context, r NewRegular, updatedBy str
 		return nil
 	})
 	if err != nil {
-		return db.Dinner{}, err
+		return Dinner{}, err
 	}
-	return row, nil
+	return fromRow(row), nil
 }
 
 // List returns the dinners with status, which must be regular or
@@ -299,11 +279,7 @@ func (s *Service) List(ctx context.Context, status string) ([]Dinner, error) {
 
 // Update applies p to dinner id, recording updatedBy. An invalid patch is a
 // *ValidationError and a new name repeating another unarchived dinner a
-// *DuplicateError; either changes nothing. Renaming a dinner still pending
-// clears its recipe_url, raises its grounding_revision and enqueues a fresh
-// KindGroundDinner job that grounds the new name: a job queued or running
-// for the old name or link carries the old revision, so it can no longer
-// write the dinner, and one running is stopped.
+// *DuplicateError; either changes nothing.
 func (s *Service) Update(ctx context.Context, id string, p Patch, updatedBy string) (Dinner, error) {
 	if updatedBy == "" {
 		return Dinner{}, errors.New("dinners: update: no member to record as updated_by")
@@ -314,7 +290,6 @@ func (s *Service) Update(ctx context.Context, id string, p Patch, updatedBy stri
 	}
 
 	var row db.Dinner
-	var regrounding bool
 	err = s.st.WithTx(ctx, func(tx *sql.Tx) error {
 		q := db.New(tx)
 		cur, err := q.GetDinner(ctx, id)
@@ -325,22 +300,20 @@ func (s *Service) Update(ctx context.Context, id string, p Patch, updatedBy stri
 			return fmt.Errorf("dinners: read %s: %w", id, err)
 		}
 		params := db.UpdateDinnerParams{
-			ID:                cur.ID,
-			Name:              cur.Name,
-			NormalizedName:    cur.NormalizedName,
-			Status:            cur.Status,
-			Origin:            cur.Origin,
-			Method:            cur.Method,
-			MinutesTotal:      cur.MinutesTotal,
-			Difficulty:        cur.Difficulty,
-			Cuisine:           cur.Cuisine,
-			RecipeID:          cur.RecipeID,
-			RecipeUrl:         cur.RecipeUrl,
-			PhotoID:           cur.PhotoID,
-			GroundingStatus:   cur.GroundingStatus,
-			GroundingRevision: cur.GroundingRevision,
-			UpdatedBy:         sql.NullString{String: updatedBy, Valid: true},
-			UpdatedAt:         store.Now().String(),
+			ID:              cur.ID,
+			Name:            cur.Name,
+			NormalizedName:  cur.NormalizedName,
+			Status:          cur.Status,
+			Origin:          cur.Origin,
+			Method:          cur.Method,
+			MinutesTotal:    cur.MinutesTotal,
+			Difficulty:      cur.Difficulty,
+			Cuisine:         cur.Cuisine,
+			RecipeID:        cur.RecipeID,
+			PhotoID:         cur.PhotoID,
+			GroundingStatus: cur.GroundingStatus,
+			UpdatedBy:       sql.NullString{String: updatedBy, Valid: true},
+			UpdatedAt:       store.Now().String(),
 		}
 		if p.Name != nil {
 			if err := checkUnique(ctx, q, cur.ID, name, sql.NullString{}); err != nil {
@@ -348,12 +321,6 @@ func (s *Service) Update(ctx context.Context, id string, p Patch, updatedBy stri
 			}
 			params.Name = name
 			params.NormalizedName = harness.Normalize(name)
-			if cur.GroundingStatus == GroundingPending && params.NormalizedName != cur.NormalizedName {
-				// The link was the old dinner's recipe; the new name is
-				// grounded by name, and a link can be given by hand.
-				params.RecipeUrl = sql.NullString{}
-				params.GroundingRevision++
-			}
 		}
 		if p.Method != nil {
 			params.Method = sql.NullString{String: *p.Method, Valid: true}
@@ -368,31 +335,16 @@ func (s *Service) Update(ctx context.Context, id string, p Patch, updatedBy stri
 		if err != nil {
 			return fmt.Errorf("dinners: update %s: %w", id, err)
 		}
-		regrounding = row.GroundingRevision != cur.GroundingRevision
 		return nil
 	})
 	if err != nil {
 		return Dinner{}, err
 	}
-	if regrounding {
-		s.stopGroundings(row.ID, row.GroundingRevision)
-		jobID, err := s.enqueueGrounding(ctx, row.ID, row.GroundingRevision)
-		if err != nil {
-			return Dinner{}, err
-		}
-		if jobID == nil {
-			row, err = db.New(s.st.Reader).GetDinner(context.WithoutCancel(ctx), row.ID)
-			if err != nil {
-				return Dinner{}, fmt.Errorf("dinners: read %s: %w", id, err)
-			}
-		}
-	}
 	return fromRow(row), nil
 }
 
 // Archive sets dinner id's status to archived, recording updatedBy. The row
-// is kept, so its name still counts for Side quest dedupe. A
-// KindGroundDinner job running for it is stopped.
+// is kept, so its name still counts for Side quest dedupe.
 func (s *Service) Archive(ctx context.Context, id, updatedBy string) (Dinner, error) {
 	if updatedBy == "" {
 		return Dinner{}, errors.New("dinners: archive: no member to record as updated_by")
@@ -408,7 +360,6 @@ func (s *Service) Archive(ctx context.Context, id, updatedBy string) (Dinner, er
 	if err != nil {
 		return Dinner{}, fmt.Errorf("dinners: archive %s: %w", id, err)
 	}
-	s.stopGroundings(row.ID, math.MaxInt64)
 	return fromRow(row), nil
 }
 
@@ -526,24 +477,18 @@ func nameFromURL(u *url.URL) (name string, ok bool) {
 }
 
 // checkUnique returns a *DuplicateError when name is harness.Similar to an
-// unarchived dinner other than self, or recipeURL is one's recipe link: the
-// source_url of the recipe it is grounded in, else the recipe_url still
-// awaiting grounding.
+// unarchived dinner other than self, or recipeURL is one's recipe link.
 func checkUnique(ctx context.Context, q *db.Queries, self, name string, recipeURL sql.NullString) error {
 	rows, err := q.ListUnarchivedDinners(ctx)
 	if err != nil {
 		return fmt.Errorf("dinners: list for dedupe: %w", err)
 	}
 	for _, row := range rows {
-		if row.Dinner.ID == self {
+		if row.ID == self {
 			continue
 		}
-		link := row.Dinner.RecipeUrl
-		if row.RecipeSourceUrl.Valid {
-			link = row.RecipeSourceUrl
-		}
-		if harness.Similar(name, row.Dinner.Name) || (recipeURL.Valid && link == recipeURL) {
-			return &DuplicateError{Existing: fromRow(row.Dinner)}
+		if harness.Similar(name, row.Name) || (recipeURL.Valid && row.RecipeUrl == recipeURL) {
+			return &DuplicateError{Existing: fromRow(row)}
 		}
 	}
 	return nil

internal/dinners/export_test.go

@@ -1,7 +1,6 @@
 package dinners
 
 import (
-	"context"
 	"testing"
 	"time"
 )
@@ -13,11 +12,3 @@ func SetGroundTimeout(t *testing.T, d time.Duration) {
 	groundTimeout = d
 	t.Cleanup(func() { groundTimeout = old })
 }
-
-// RunGroundJob runs the KindGroundDinner handler for p in the caller's
-// goroutine, as the job runner would, and returns the grounding status it
-// reports.
-func (s *Service) RunGroundJob(ctx context.Context, p GroundJob) (string, error) {
-	r, err := s.runGroundJob(ctx, p, nil)
-	return r.GroundingStatus, err
-}

internal/dinners/grounding.go

@@ -76,29 +76,14 @@ var groundTimeout = GroundTimeout
 // runs past GroundTimeout; the dinner is left as it was.
 var ErrGroundTimeout = errors.New("dinners: grounding the recipe took too long")
 
-// ErrGroundFailed wraps any unexpected failure grounding a dinner by hand.
-// Its text may quote the link and dependency errors, so it is never
-// logged.
-var ErrGroundFailed = errors.New("dinners: grounding the recipe failed")
-
-// ErrArchived is grounding an archived dinner by hand.
-var ErrArchived = errors.New("dinner archived")
-
-// ErrGroundConflict is a candidate or link grounded for a dinner that was
-// renamed or grounded some other way while it was grounding.
-var ErrGroundConflict = errors.New("dinner changed while its recipe was grounding")
-
-// GroundJob is the KindGroundDinner payload: the dinner to ground and its
-// grounding_revision when the job was enqueued.
+// GroundJob is the KindGroundDinner payload.
 type GroundJob struct {
 	DinnerID string `json:"dinner_id"`
-	Revision int64  `json:"revision"`
 }
 
 // groundResult is the KindGroundDinner result: the dinner's grounding
-// status once the job ends. It is not grounded by this job when the dinner
-// was grounded by hand before the job finished, renamed (a later job
-// grounds it) or archived; the job then reports the status it found.
+// status once the job ends. It is not grounded when the dinner was
+// grounded by hand before the job finished.
 type groundResult struct {
 	DinnerID        string `json:"dinner_id"`
 	GroundingStatus string `json:"grounding_status"`
@@ -108,38 +93,24 @@ func (r groundResult) PublicJSON() ([]byte, error) { return json.Marshal(r) }
 
 // runGroundJob grounds a pending dinner as its creation asked: its
 // recipe_url with GroundURL, else its name with Ground. Success records
-// the recipe and photo with grounding_status grounded, and the recipe's
-// method, minutes and difficulty where a member has not set them; failure
-// records grounding_status failed with its Reason, which is also the job's
-// failure code. A dinner archived, no longer pending, or at a
-// grounding_revision other than p.Revision is not grounded at all, and
-// either result is recorded only while the dinner is still unarchived,
-// pending and at p.Revision: a dinner grounded by hand meanwhile is left as
-// it is, and one renamed or archived meanwhile is left pending — for the
-// job its rename enqueued, or for none. Archiving or renaming the dinner
-// stops the grounding where it is, so no further search, fetch, photo
-// download or model call is made for it.
+// the recipe, photo, method, minutes and difficulty with grounding_status
+// grounded; failure records grounding_status failed with its Reason, which
+// is also the job's failure code. A dinner no longer pending (grounded by
+// hand meanwhile) is left as it is.
 func (s *Service) runGroundJob(ctx context.Context, p GroundJob, _ func(groundResult) error) (groundResult, error) {
-	// Tracked before the dinner is read: an archive or rename committed
-	// after the read finds this job to stop.
-	groundCtx, done := s.trackGrounding(ctx, p.DinnerID, p.Revision)
-	defer done()
 	row, err := db.New(s.st.Reader).GetDinner(ctx, p.DinnerID)
 	if err != nil {
 		return groundResult{}, fmt.Errorf("dinners: ground: read %s: %w", p.DinnerID, err)
 	}
-	if row.Status == StatusArchived || row.GroundingStatus != GroundingPending || row.GroundingRevision != p.Revision {
+	if row.GroundingStatus != GroundingPending {
 		return groundResult{DinnerID: row.ID, GroundingStatus: row.GroundingStatus}, nil
 	}
 
 	var gr recipes.Grounded
 	if row.RecipeUrl.Valid {
-		gr, err = s.grounder.GroundURL(groundCtx, row.RecipeUrl.String)
+		gr, err = s.grounder.GroundURL(ctx, row.RecipeUrl.String)
 	} else {
-		gr, err = s.grounder.Ground(groundCtx, row.Name, row.Name)
-	}
-	if err != nil && ctx.Err() == nil && errors.Is(context.Cause(groundCtx), errGroundingStopped) {
-		return s.currentGrounding(ctx, row.ID)
+		gr, err = s.grounder.Ground(ctx, row.Name, row.Name)
 	}
 	if err != nil {
 		reason := reasonFor(err, row.RecipeUrl.Valid)
@@ -151,10 +122,9 @@ func (s *Service) runGroundJob(ctx context.Context, p GroundJob, _ func(groundRe
 		s.logger.InfoContext(ctx, "dinner grounding failed", "dinner_id", row.ID, "reason", reason)
 		write := context.WithoutCancel(ctx)
 		if _, failErr := db.New(s.st.Writer).FailPendingDinnerGrounding(write, db.FailPendingDinnerGroundingParams{
-			GroundingError:    sql.NullString{String: reason, Valid: true},
-			UpdatedAt:         store.Now().String(),
-			ID:                row.ID,
-			GroundingRevision: p.Revision,
+			GroundingError: sql.NullString{String: reason, Valid: true},
+			UpdatedAt:      store.Now().String(),
+			ID:             row.ID,
 		}); failErr != nil {
 			return groundResult{}, fmt.Errorf("dinners: ground: record failure of %s: %w", row.ID, failErr)
 		}
@@ -165,85 +135,31 @@ func (s *Service) runGroundJob(ctx context.Context, p GroundJob, _ func(groundRe
 	}
 
 	n, err := db.New(s.st.Writer).GroundPendingDinner(ctx, db.GroundPendingDinnerParams{
-		RecipeID:          sql.NullString{String: gr.RecipeID, Valid: true},
-		PhotoID:           sql.NullString{String: gr.PhotoID, Valid: true},
-		Method:            sql.NullString{String: gr.Method, Valid: true},
-		MinutesTotal:      nullInt(gr.MinutesTotal),
-		Difficulty:        sql.NullString{String: gr.Difficulty, Valid: true},
-		UpdatedAt:         store.Now().String(),
-		ID:                row.ID,
-		GroundingRevision: p.Revision,
+		RecipeID:     sql.NullString{String: gr.RecipeID, Valid: true},
+		PhotoID:      sql.NullString{String: gr.PhotoID, Valid: true},
+		Method:       sql.NullString{String: gr.Method, Valid: true},
+		MinutesTotal: nullInt(gr.MinutesTotal),
+		Difficulty:   sql.NullString{String: gr.Difficulty, Valid: true},
+		UpdatedAt:    store.Now().String(),
+		ID:           row.ID,
 	})
 	if err != nil {
 		return groundResult{}, fmt.Errorf("dinners: ground: record %s: %w", row.ID, err)
 	}
 	if n == 0 {
-		return s.currentGrounding(ctx, row.ID)
+		cur, err := db.New(s.st.Reader).GetDinner(ctx, row.ID)
+		if err != nil {
+			return groundResult{}, fmt.Errorf("dinners: ground: read %s: %w", row.ID, err)
+		}
+		return groundResult{DinnerID: cur.ID, GroundingStatus: cur.GroundingStatus}, nil
 	}
 	return groundResult{DinnerID: row.ID, GroundingStatus: GroundingGrounded}, nil
 }
 
-// currentGrounding is the KindGroundDinner result of a job that did not
-// ground dinner id: the grounding status the dinner has now.
-func (s *Service) currentGrounding(ctx context.Context, id string) (groundResult, error) {
-	cur, err := db.New(s.st.Reader).GetDinner(ctx, id)
-	if err != nil {
-		return groundResult{}, fmt.Errorf("dinners: ground: read %s: %w", id, err)
-	}
-	return groundResult{DinnerID: cur.ID, GroundingStatus: cur.GroundingStatus}, nil
-}
-
-// errGroundingStopped is the cause a running KindGroundDinner job's
-// grounding is cancelled with when its dinner is archived or renamed.
-var errGroundingStopped = errors.New("dinners: grounding stopped: dinner archived or renamed")
-
-// runningGrounding is a KindGroundDinner job running for a dinner at
-// revision, with the cancel of its grounding.
-type runningGrounding struct {
-	revision int64
-	cancel   context.CancelCauseFunc
-}
-
-// trackGrounding returns a context for grounding dinnerID at revision that
-// stopGroundings cancels, and the func to call when the job ends.
-func (s *Service) trackGrounding(ctx context.Context, dinnerID string, revision int64) (context.Context, func()) {
-	groundCtx, cancel := context.WithCancelCause(ctx)
-	r := &runningGrounding{revision: revision, cancel: cancel}
-	s.groundingsMu.Lock()
-	if s.groundings[dinnerID] == nil {
-		s.groundings[dinnerID] = make(map[*runningGrounding]struct{})
-	}
-	s.groundings[dinnerID][r] = struct{}{}
-	s.groundingsMu.Unlock()
-	return groundCtx, func() {
-		s.groundingsMu.Lock()
-		delete(s.groundings[dinnerID], r)
-		if len(s.groundings[dinnerID]) == 0 {
-			delete(s.groundings, dinnerID)
-		}
-		s.groundingsMu.Unlock()
-		cancel(nil)
-	}
-}
-
-// stopGroundings cancels, with errGroundingStopped, the grounding of every
-// KindGroundDinner job running for dinnerID at a revision below below. Call
-// it once the change that makes those jobs stale is committed.
-func (s *Service) stopGroundings(dinnerID string, below int64) {
-	s.groundingsMu.Lock()
-	defer s.groundingsMu.Unlock()
-	for r := range s.groundings[dinnerID] {
-		if r.revision < below {
-			r.cancel(errGroundingStopped)
-		}
-	}
-}
-
-// FailInterruptedGroundings fails, with ReasonInterrupted, every unarchived
-// dinner still pending whose KindGroundDinner job is no longer queued or
-// running: a previous process stopped before enqueuing the job or before
-// its handler recorded a result. An archived dinner is left pending, since
-// archiving, not a restart, stopped its grounding. Call it once at boot, after the job runner's
+// FailInterruptedGroundings fails, with ReasonInterrupted, every dinner
+// still pending whose KindGroundDinner job is no longer queued or running:
+// a previous process stopped before enqueuing the job or before its
+// handler recorded a result. Call it once at boot, after the job runner's
 // Start has failed the jobs that process left running, so no dinner stays
 // pending with nothing left to ground it. It returns how many it failed.
 func (s *Service) FailInterruptedGroundings(ctx context.Context) (int64, error) {
@@ -335,17 +251,11 @@ type ManualRecipe struct {
 // Ground grounds dinner id as f says, recording updatedBy. A candidate or
 // link is grounded with recipes.Grounder.GroundURL and sets
 // grounding_status grounded, with the recipe's photo, method, minutes and
-// difficulty; one a member changed while it was grounding is kept. A
-// manual recipe is stored as typed — no model runs — and sets
-// grounding_status manual with its method and minutes; it has no photo,
-// and the dinner keeps its difficulty. An invalid f is a *ValidationError
-// and an archived dinner ErrArchived. A failure grounding a candidate or
-// link, or recording it on the dinner, wraps ErrGroundFailed; a page that
-// cannot ground the dinner is also a *recipes.ErrUngroundable. A dinner
-// renamed, archived or grounded some other way while a candidate or link
-// was grounding is ErrGroundConflict or ErrArchived. A missing dinner is
-// ErrNotFound; any other failure, by candidate, link or manual recipe,
-// wraps ErrGroundFailed. None of these changes the dinner.
+// difficulty. A manual recipe is stored as typed — no model runs — and
+// sets grounding_status manual with its method and minutes; it has no
+// photo, and the dinner keeps its difficulty. An invalid f is a
+// *ValidationError; a page that cannot ground the dinner is a
+// *recipes.ErrUngroundable and changes nothing.
 func (s *Service) Ground(ctx context.Context, id string, f Fix, updatedBy string) (Dinner, error) {
 	if updatedBy == "" {
 		return Dinner{}, errors.New("dinners: ground: no member to record as updated_by")
@@ -357,16 +267,9 @@ func (s *Service) Ground(ctx context.Context, id string, f Fix, updatedBy string
 	if manual != nil {
 		return s.groundManual(ctx, id, *manual, updatedBy)
 	}
-	cur, err := s.get(ctx, id)
-	if errors.Is(err, ErrNotFound) {
+	if _, err := s.get(ctx, id); err != nil {
 		return Dinner{}, err
 	}
-	if err != nil {
-		return Dinner{}, fmt.Errorf("%w: dinner %s: %w", ErrGroundFailed, id, err)
-	}
-	if cur.Status == StatusArchived {
-		return Dinner{}, ErrArchived
-	}
 	groundCtx, cancel := context.WithTimeout(ctx, groundTimeout)
 	defer cancel()
 	gr, err := s.grounder.GroundURL(groundCtx, link)
@@ -374,57 +277,30 @@ func (s *Service) Ground(ctx context.Context, id string, f Fix, updatedBy string
 		if ctx.Err() == nil && errors.Is(groundCtx.Err(), context.DeadlineExceeded) {
 			return Dinner{}, ErrGroundTimeout
 		}
-		return Dinner{}, fmt.Errorf("%w: dinner %s: %w", ErrGroundFailed, id, err)
+		return Dinner{}, fmt.Errorf("dinners: ground %s: %w", id, err)
 	}
 	row, err := db.New(s.st.Writer).GroundDinner(ctx, db.GroundDinnerParams{
-		RecipeID:                  sql.NullString{String: gr.RecipeID, Valid: true},
-		PhotoID:                   sql.NullString{String: gr.PhotoID, Valid: true},
-		Method:                    sql.NullString{String: gr.Method, Valid: true},
-		MinutesTotal:              nullInt(gr.MinutesTotal),
-		Difficulty:                sql.NullString{String: gr.Difficulty, Valid: true},
-		GroundingStatus:           GroundingGrounded,
-		UpdatedBy:                 sql.NullString{String: updatedBy, Valid: true},
-		UpdatedAt:                 store.Now().String(),
-		ID:                        cur.ID,
-		ObservedName:              cur.Name,
-		ObservedNormalizedName:    cur.NormalizedName,
-		ObservedGroundingStatus:   cur.GroundingStatus,
-		ObservedGroundingRevision: cur.GroundingRevision,
-		ObservedRecipeID:          cur.RecipeID,
-		ObservedMethod:            cur.Method,
-		ObservedMinutesTotal:      cur.MinutesTotal,
-		ObservedDifficulty:        cur.Difficulty,
+		RecipeID:        sql.NullString{String: gr.RecipeID, Valid: true},
+		PhotoID:         sql.NullString{String: gr.PhotoID, Valid: true},
+		Method:          sql.NullString{String: gr.Method, Valid: true},
+		MinutesTotal:    nullInt(gr.MinutesTotal),
+		Difficulty:      sql.NullString{String: gr.Difficulty, Valid: true},
+		GroundingStatus: GroundingGrounded,
+		UpdatedBy:       sql.NullString{String: updatedBy, Valid: true},
+		UpdatedAt:       store.Now().String(),
+		ID:              id,
 	})
 	if errors.Is(err, sql.ErrNoRows) {
-		return Dinner{}, s.groundRejected(ctx, id)
+		return Dinner{}, ErrNotFound
 	}
 	if err != nil {
-		return Dinner{}, fmt.Errorf("%w: dinner %s: record: %w", ErrGroundFailed, id, err)
+		return Dinner{}, fmt.Errorf("dinners: ground %s: %w", id, err)
 	}
 	return fromRow(row), nil
 }
 
-// groundRejected is the error for dinner id when it was not as observed
-// before grounding: ErrNotFound, ErrArchived or ErrGroundConflict. Failing
-// to read it wraps ErrGroundFailed.
-func (s *Service) groundRejected(ctx context.Context, id string) error {
-	cur, err := s.get(ctx, id)
-	if errors.Is(err, ErrNotFound) {
-		return err
-	}
-	if err != nil {
-		return fmt.Errorf("%w: dinner %s: %w", ErrGroundFailed, id, err)
-	}
-	if cur.Status == StatusArchived {
-		return ErrArchived
-	}
-	return ErrGroundConflict
-}
-
 // groundManual stores m as dinner id's recipe, with its ingredients and
-// steps, and records it on the dinner, all in one transaction. A missing
-// or archived dinner is ErrNotFound or ErrArchived; any other failure
-// wraps ErrGroundFailed.
+// steps, and records it on the dinner, all in one transaction.
 func (s *Service) groundManual(ctx context.Context, id string, m ManualRecipe, updatedBy string) (Dinner, error) {
 	var row db.Dinner
 	err := s.st.WithTx(ctx, func(tx *sql.Tx) error {
@@ -436,9 +312,6 @@ func (s *Service) groundManual(ctx context.Context, id string, m ManualRecipe, u
 		if err != nil {
 			return fmt.Errorf("dinners: read %s: %w", id, err)
 		}
-		if cur.Status == StatusArchived {
-			return ErrArchived
-		}
 		ld, err := json.Marshal(manualJSONLD{
 			Context:      "https://schema.org",
 			Type:         "Recipe",
@@ -494,33 +367,22 @@ func (s *Service) groundManual(ctx context.Context, id string, m ManualRecipe, u
 			}
 		}
 		row, err = q.GroundDinner(ctx, db.GroundDinnerParams{
-			RecipeID:                  sql.NullString{String: rec.ID, Valid: true},
-			Method:                    method,
-			MinutesTotal:              minutes,
-			Difficulty:                cur.Difficulty,
-			GroundingStatus:           GroundingManual,
-			UpdatedBy:                 sql.NullString{String: updatedBy, Valid: true},
-			UpdatedAt:                 now,
-			ID:                        cur.ID,
-			ObservedName:              cur.Name,
-			ObservedNormalizedName:    cur.NormalizedName,
-			ObservedGroundingStatus:   cur.GroundingStatus,
-			ObservedGroundingRevision: cur.GroundingRevision,
-			ObservedRecipeID:          cur.RecipeID,
-			ObservedMethod:            cur.Method,
-			ObservedMinutesTotal:      cur.MinutesTotal,
-			ObservedDifficulty:        cur.Difficulty,
+			RecipeID:        sql.NullString{String: rec.ID, Valid: true},
+			Method:          method,
+			MinutesTotal:    minutes,
+			Difficulty:      cur.Difficulty,
+			GroundingStatus: GroundingManual,
+			UpdatedBy:       sql.NullString{String: updatedBy, Valid: true},
+			UpdatedAt:       now,
+			ID:              cur.ID,
 		})
 		if err != nil {
 			return fmt.Errorf("dinners: ground %s: %w", id, err)
 		}
 		return nil
 	})
-	if errors.Is(err, ErrNotFound) || errors.Is(err, ErrArchived) {
-		return Dinner{}, err
-	}
 	if err != nil {
-		return Dinner{}, fmt.Errorf("%w: dinner %s: %w", ErrGroundFailed, id, err)
+		return Dinner{}, err
 	}
 	return fromRow(row), nil
 }

internal/dinners/grounding_test.go

@@ -2,15 +2,11 @@ package dinners_test
 
 import (
 	"context"
-	"database/sql"
-	"encoding/json"
 	"errors"
 	"io"
-	"io/fs"
 	"log/slog"
 	"slices"
 	"testing"
-	"testing/fstest"
 	"time"
 
 	"code.cubecraftlabs.com/Maniacs_Mansion/Meal-Quest/internal/ai/llm"
@@ -56,13 +52,6 @@ func newEnv(t *testing.T) *env {
 func newUnstartedEnv(t *testing.T) *env {
 	t.Helper()
 	dataDir := t.TempDir()
-	return newUnstartedEnvOn(t, openStore(t, dataDir), dataDir)
-}
-
-// openStore opens the store in dataDir, closing it when the test ends. It
-// is not migrated.
-func openStore(t *testing.T, dataDir string) *store.Store {
-	t.Helper()
 	st, err := store.Open(t.Context(), dataDir)
 	if err != nil {
 		t.Fatal(err)
@@ -72,13 +61,6 @@ func openStore(t *testing.T, dataDir string) *store.Store {
 			t.Error(err)
 		}
 	})
-	return st
-}
-
-// newUnstartedEnvOn is newUnstartedEnv over st, the store in dataDir,
-// which it migrates to the latest version.
-func newUnstartedEnvOn(t *testing.T, st *store.Store, dataDir string) *env {
-	t.Helper()
 	if err := store.Migrate(t.Context(), st.Writer, migrations.FS); err != nil {
 		t.Fatal(err)
 	}
@@ -304,328 +286,6 @@ func TestManualFixWhilePendingIsKept(t *testing.T) {
 	}
 }
 
-// TestRenameWhilePendingGroundsNewName: a Regular renamed while its job is
-// still grounding the old name never gets the old name's result, whether
-// the old name would be found or not: the rename stops that job where it
-// is, and the job the rename enqueues grounds the new name.
-func TestRenameWhilePendingGroundsNewName(t *testing.T) {
-	t.Parallel()
-	tests := []struct {
-		name    string
-		oldName string
-	}{
-		{"old name found", "Chicken curry"},
-		{"old name not found", "Unknown dish"},
-	}
-	for _, tt := range tests {
-		t.Run(tt.name, func(t *testing.T) {
-			t.Parallel()
-			e := newEnv(t)
-			e.search.Results["Beef stew"] = []recipes.Candidate{{URL: stew}}
-			e.search.Gate = make(chan struct{})
-			e.model.QueueGenerate(recipestest.NormalizedReply("oven", 150))
-
-			c, err := e.svc.CreateRegular(t.Context(), dinners.NewRegular{Name: ptr(tt.oldName)}, member)
-			if err != nil {
-				t.Fatal(err)
-			}
-			// Rename only once the job has read the old name and is searching it.
-			e.waitQuery(t, tt.oldName)
-			d, err := e.svc.Update(t.Context(), c.ID, dinners.Patch{Name: ptr("Beef stew")}, member)
-			if err != nil {
-				t.Fatal(err)
-			}
-			if d.GroundingStatus != dinners.GroundingPending {
-				t.Fatalf("renamed = %+v, want still pending", d)
-			}
-			// The old name's job ends while its search is still held.
-			first := e.waitJob(t, *c.GroundingJobID)
-			if first.Status != jobs.StatusSucceeded || string(first.Result) != `{"dinner_id":"`+c.ID+`","grounding_status":"pending"}` {
-				t.Fatalf("old name's job = %+v (result %s), want succeeded leaving the dinner pending", first, first.Result)
-			}
-			close(e.search.Gate)
-
-			row := e.waitGrounding(t, c.ID)
-			if row.GroundingStatus != dinners.GroundingGrounded {
-				t.Fatalf("dinner = %+v, want grounded for the new name", row)
-			}
-			rec, err := db.New(e.st.Reader).GetRecipe(t.Context(), row.RecipeID.String)
-			if err != nil {
-				t.Fatal(err)
-			}
-			if rec.SourceUrl != stew || rec.PhotoID != row.PhotoID || row.Method.String != "oven" || row.MinutesTotal.Int64 != 150 {
-				t.Errorf("dinner = %+v recipe %s, want grounded in %s", row, rec.SourceUrl, stew)
-			}
-			if got := e.search.Queries(); !slices.Equal(got, []string{tt.oldName, "Beef stew"}) {
-				t.Errorf("searched %q, want the old name then the new", got)
-			}
-			if got := len(e.model.Requests()); got != 1 {
-				t.Errorf("model called %d times, want once, for the new name only", got)
-			}
-		})
-	}
-}
-
-// TestRenameLinkWhilePendingGroundsNewName: a Regular added from a link and
-// renamed while still pending drops the link and grounds its new name, not
-// the old link's recipe and photo.
-func TestRenameLinkWhilePendingGroundsNewName(t *testing.T) {
-	t.Parallel()
-	e := newUnstartedEnv(t)
-	e.search.Results["Beef stew"] = []recipes.Candidate{{URL: stew}}
-	e.model.QueueGenerate(recipestest.NormalizedReply("oven", 150))
-
-	c, err := e.svc.CreateRegular(t.Context(), dinners.NewRegular{RecipeURL: ptr(curryA)}, member)
-	if err != nil {
-		t.Fatal(err)
-	}
-	d, err := e.svc.Update(t.Context(), c.ID, dinners.Patch{Name: ptr("Beef stew")}, member)
-	if err != nil {
-		t.Fatal(err)
-	}
-	if d.GroundingStatus != dinners.GroundingPending || d.RecipeURL != nil {
-		t.Fatalf("renamed = %+v, want still pending with no recipe_url", d)
-	}
-	e.start(t)
-
-	row := e.waitGrounding(t, c.ID)
-	if row.GroundingStatus != dinners.GroundingGrounded {
-		t.Fatalf("dinner = %+v, want grounded for the new name", row)
-	}
-	rec, err := db.New(e.st.Reader).GetRecipe(t.Context(), row.RecipeID.String)
-	if err != nil {
-		t.Fatal(err)
-	}
-	if rec.SourceUrl != stew || rec.PhotoID != row.PhotoID || row.Method.String != "oven" || row.MinutesTotal.Int64 != 150 {
-		t.Errorf("dinner = %+v recipe %s, want grounded in %s, not the old link %s", row, rec.SourceUrl, stew, curryA)
-	}
-	if got := e.search.Queries(); !slices.Equal(got, []string{"Beef stew"}) {
-		t.Errorf("searched %q, want only the new name", got)
-	}
-	if row.RecipeUrl.Valid {
-		t.Errorf("recipe_url = %q, want the old link dropped", row.RecipeUrl.String)
-	}
-	if _, err := db.New(e.st.Reader).GetRecipeBySourceURL(t.Context(), curryA); !errors.Is(err, sql.ErrNoRows) {
-		t.Errorf("old link's recipe lookup err = %v, want it never grounded (sql.ErrNoRows)", err)
-	}
-}
-
-// queuedJob reads the payload of queued KindGroundDinner job id.
-func (e *env) queuedJob(t *testing.T, id string) dinners.GroundJob {
-	t.Helper()
-	var payload string
-	if err := e.st.Reader.QueryRowContext(t.Context(), `SELECT payload FROM jobs WHERE id = ?`, id).Scan(&payload); err != nil {
-		t.Fatal(err)
-	}
-	var p dinners.GroundJob
-	if err := json.Unmarshal([]byte(payload), &p); err != nil {
-		t.Fatal(err)
-	}
-	return p
-}
-
-// TestRenameBeforeJobStartsSkipsStaleJob: a Regular renamed before its
-// first job starts is grounded only by the job its rename enqueued. The
-// first job, though it would read the new name, does no work and writes
-// nothing, so its failure cannot leave the dinner "Needs a recipe" while
-// the rename's job finds a recipe.
-func TestRenameBeforeJobStartsSkipsStaleJob(t *testing.T) {
-	t.Parallel()
-	e := newUnstartedEnv(t)
-	e.search.Results["Beef stew"] = []recipes.Candidate{{URL: stew}}
-
-	c, err := e.svc.CreateRegular(t.Context(), dinners.NewRegular{Name: ptr("Chicken curry")}, member)
-	if err != nil {
-		t.Fatal(err)
-	}
-	first := e.queuedJob(t, *c.GroundingJobID)
-	if first.DinnerID != c.ID || first.Revision != e.dinner(t, c.ID).GroundingRevision {
-		t.Fatalf("first job = %+v, want dinner %s at its revision", first, c.ID)
-	}
-	if _, err := e.svc.Update(t.Context(), c.ID, dinners.Patch{Name: ptr("Beef stew")}, member); err != nil {
-		t.Fatal(err)
-	}
-	renamed := e.dinner(t, c.ID)
-	if renamed.GroundingRevision != first.Revision+1 {
-		t.Fatalf("revision after rename = %d, want %d", renamed.GroundingRevision, first.Revision+1)
-	}
-
-	// The first job would fail if it searched.
-	e.search.Err = recipes.ErrSearchRateLimited
-	status, err := e.svc.RunGroundJob(t.Context(), first)
-	if err != nil || status != dinners.GroundingPending {
-		t.Fatalf("first job = %q, %v; want pending, no error", status, err)
-	}
-	if q := e.search.Queries(); len(q) != 0 {
-		t.Errorf("first job searched %q, want no work for a stale revision", q)
-	}
-	if row := e.dinner(t, c.ID); row != renamed {
-		t.Fatalf("first job wrote the dinner: %+v, was %+v", row, renamed)
-	}
-
-	e.search.Err = nil
-	e.model.QueueGenerate(recipestest.NormalizedReply("oven", 150))
-	status, err = e.svc.RunGroundJob(t.Context(), dinners.GroundJob{DinnerID: c.ID, Revision: renamed.GroundingRevision})
-	if err != nil || status != dinners.GroundingGrounded {
-		t.Fatalf("rename's job = %q, %v; want grounded", status, err)
-	}
-	row := e.dinner(t, c.ID)
-	rec, err := db.New(e.st.Reader).GetRecipe(t.Context(), row.RecipeID.String)
-	if err != nil {
-		t.Fatal(err)
-	}
-	if row.GroundingStatus != dinners.GroundingGrounded || rec.SourceUrl != stew {
-		t.Errorf("dinner = %+v recipe %s, want grounded in %s", row, rec.SourceUrl, stew)
-	}
-
-	// A stale job finishing last changes nothing either.
-	if status, err := e.svc.RunGroundJob(t.Context(), first); err != nil || status != dinners.GroundingGrounded {
-		t.Errorf("first job run last = %q, %v; want grounded reported, no error", status, err)
-	}
-	if after := e.dinner(t, c.ID); after != row {
-		t.Errorf("stale job changed the grounded dinner: %+v, was %+v", after, row)
-	}
-}
-
-// TestEditWhilePendingIsKept: a method or minutes a member saves while a
-// Regular is grounding is kept when grounding succeeds; what the member
-// did not set comes from the recipe.
-func TestEditWhilePendingIsKept(t *testing.T) {
-	t.Parallel()
-	e := newEnv(t)
-	e.search.Gate = make(chan struct{})
-	e.model.QueueGenerate(recipestest.NormalizedReply("stovetop", 40))
-
-	c, err := e.svc.CreateRegular(t.Context(), dinners.NewRegular{Name: ptr("Chicken curry")}, member)
-	if err != nil {
-		t.Fatal(err)
-	}
-	e.waitQuery(t, "Chicken curry")
-	if _, err := e.svc.Update(t.Context(), c.ID, dinners.Patch{Method: ptr("grill"), MinutesTotal: ptr(15)}, member); err != nil {
-		t.Fatal(err)
-	}
-	close(e.search.Gate)
-
-	row := e.waitGrounding(t, c.ID)
-	if row.GroundingStatus != dinners.GroundingGrounded || !row.RecipeID.Valid || !row.PhotoID.Valid {
-		t.Fatalf("dinner = %+v, want grounded", row)
-	}
-	if row.Method.String != "grill" || row.MinutesTotal.Int64 != 15 || row.Difficulty.String != "easy" {
-		t.Errorf("dinner = %s, %d minutes, %s; want the member's grill and 15 minutes, the recipe's easy",
-			row.Method.String, row.MinutesTotal.Int64, row.Difficulty.String)
-	}
-}
-
-// TestArchiveWhilePendingStopsGrounding: a pending Regular archived before
-// its job starts is not searched for, and one archived while its job runs
-// is stopped there, with no page fetched or model called; neither ends up
-// grounded.
-func TestArchiveWhilePendingStopsGrounding(t *testing.T) {
-	t.Parallel()
-	t.Run("before the job starts", func(t *testing.T) {
-		t.Parallel()
-		e := newUnstartedEnv(t)
-		e.model.QueueGenerate(recipestest.NormalizedReply("stovetop", 40))
-		c, err := e.svc.CreateRegular(t.Context(), dinners.NewRegular{Name: ptr("Chicken curry")}, member)
-		if err != nil {
-			t.Fatal(err)
-		}
-		if _, err := e.svc.Archive(t.Context(), c.ID, member); err != nil {
-			t.Fatal(err)
-		}
-		e.start(t)
-		if job := e.waitJob(t, *c.GroundingJobID); job.Status != jobs.StatusSucceeded {
-			t.Fatalf("job = %+v, want succeeded with nothing to do", job)
-		}
-		if q := e.search.Queries(); len(q) != 0 {
-			t.Errorf("searched %q for an archived dinner", q)
-		}
-		if row := e.dinner(t, c.ID); row.Status != dinners.StatusArchived || row.GroundingStatus == dinners.GroundingGrounded || row.RecipeID.Valid {
-			t.Errorf("dinner = %+v, want archived and not grounded", row)
-		}
-	})
-	t.Run("while the job runs", func(t *testing.T) {
-		t.Parallel()
-		e := newEnv(t)
-		e.search.Gate = make(chan struct{})
-		e.model.QueueGenerate(recipestest.NormalizedReply("stovetop", 40))
-		c, err := e.svc.CreateRegular(t.Context(), dinners.NewRegular{Name: ptr("Chicken curry")}, member)
-		if err != nil {
-			t.Fatal(err)
-		}
-		e.waitQuery(t, "Chicken curry")
-		if _, err := e.svc.Archive(t.Context(), c.ID, member); err != nil {
-			t.Fatal(err)
-		}
-		// The job ends while its search is still held: archiving stopped it.
-		job := e.waitJob(t, *c.GroundingJobID)
-		close(e.search.Gate)
-		if job.Status != jobs.StatusSucceeded || string(job.Result) != `{"dinner_id":"`+c.ID+`","grounding_status":"pending"}` {
-			t.Fatalf("job = %+v (result %s), want succeeded leaving the dinner pending", job, job.Result)
-		}
-		if got := e.pages.Fetched(); len(got) != 0 {
-			t.Errorf("fetched %q for an archived dinner", got)
-		}
-		if got := len(e.model.Requests()); got != 0 {
-			t.Errorf("model called %d times for an archived dinner", got)
-		}
-		if row := e.dinner(t, c.ID); row.Status != dinners.StatusArchived || row.GroundingStatus == dinners.GroundingGrounded || row.RecipeID.Valid {
-			t.Errorf("dinner = %+v, want archived and not grounded", row)
-		}
-	})
-}
-
-// TestRenameWhilePendingEnqueueFailure: a pending Regular renamed when the
-// job for its new name cannot be enqueued is failed, not left pending.
-func TestRenameWhilePendingEnqueueFailure(t *testing.T) {
-	t.Parallel()
-	e := newUnstartedEnv(t)
-	c, err := e.svc.CreateRegular(t.Context(), dinners.NewRegular{Name: ptr("Chicken curry")}, member)
-	if err != nil {
-		t.Fatal(err)
-	}
-	if _, err := e.st.Writer.ExecContext(t.Context(),
-		`CREATE TRIGGER refuse_jobs BEFORE INSERT ON jobs BEGIN SELECT RAISE(ABORT, 'no jobs'); END`); err != nil {
-		t.Fatal(err)
-	}
-	d, err := e.svc.Update(t.Context(), c.ID, dinners.Patch{Name: ptr("Beef stew")}, member)
-	if err != nil {
-		t.Fatal(err)
-	}
-	if d.Name != "Beef stew" || d.GroundingStatus != dinners.GroundingFailed ||
-		d.GroundingError == nil || *d.GroundingError != dinners.ReasonGroundingError {
-		t.Fatalf("renamed = %+v, want Beef stew failed (grounding_error)", d)
-	}
-}
-
-// waitQuery waits until the fake search has been asked query.
-func (e *env) waitQuery(t *testing.T, query string) {
-	t.Helper()
-	deadline := time.Now().Add(10 * time.Second)
-	for !slices.Contains(e.search.Queries(), query) {
-		if time.Now().After(deadline) {
-			t.Fatalf("search never asked %q; asked %q", query, e.search.Queries())
-		}
-		time.Sleep(5 * time.Millisecond)
-	}
-}
-
-// waitGrounding waits for dinner id to be no longer pending and returns it.
-func (e *env) waitGrounding(t *testing.T, id string) db.Dinner {
-	t.Helper()
-	deadline := time.Now().Add(10 * time.Second)
-	for {
-		row := e.dinner(t, id)
-		if row.GroundingStatus != dinners.GroundingPending {
-			return row
-		}
-		if time.Now().After(deadline) {
-			t.Fatalf("dinner %s still pending", id)
-		}
-		time.Sleep(5 * time.Millisecond)
-	}
-}
-
 // failedDinner creates a Regular whose background grounding fails.
 func failedDinner(t *testing.T, e *env, name string) string {
 	t.Helper()
@@ -718,59 +378,6 @@ func TestFixViaCandidate(t *testing.T) {
 	}
 }
 
-// TestFixReplacesPendingLink: fixing a Regular added from a link that held
-// no recipe drops that link, so it no longer blocks adding the link again,
-// while the link of the recipe chosen does.
-func TestFixReplacesPendingLink(t *testing.T) {
-	t.Parallel()
-	const lost = "https://gone.example/recipes/lamb-tagine"
-	tests := []struct {
-		name string
-		fix  dinners.Fix
-		// linkTaken is the recipe link the fixed dinner now has, if any.
-		linkTaken string
-	}{
-		{"candidate", dinners.Fix{CandidateID: ptr(curryB)}, curryB},
-		{"manual", dinners.Fix{Manual: &dinners.ManualRecipe{Ingredients: []string{"1 lamb"}, Minutes: ptr(90), Method: ptr("oven")}}, ""},
-	}
-	for _, tt := range tests {
-		t.Run(tt.name, func(t *testing.T) {
-			t.Parallel()
-			e := newEnv(t)
-			c, err := e.svc.CreateRegular(t.Context(), dinners.NewRegular{RecipeURL: ptr(lost)}, member)
-			if err != nil {
-				t.Fatal(err)
-			}
-			if job := e.waitJob(t, *c.GroundingJobID); job.Status != jobs.StatusFailed {
-				t.Fatalf("job = %+v, want failed", job)
-			}
-			// Renamed, so only the link could repeat it.
-			if _, err := e.svc.Update(t.Context(), c.ID, dinners.Patch{Name: ptr("Weeknight dinner")}, member); err != nil {
-				t.Fatal(err)
-			}
-			e.model.QueueGenerate(recipestest.NormalizedReply("stovetop", 25))
-			d, err := e.svc.Ground(t.Context(), c.ID, tt.fix, member)
-			if err != nil {
-				t.Fatal(err)
-			}
-			if d.RecipeURL != nil {
-				t.Errorf("recipe_url = %q after the fix, want the unusable link dropped", *d.RecipeURL)
-			}
-
-			if _, err := e.svc.CreateRegular(t.Context(), dinners.NewRegular{RecipeURL: ptr(lost)}, member); err != nil {
-				t.Errorf("adding the dropped link again: %v, want added", err)
-			}
-			if tt.linkTaken != "" {
-				_, err := e.svc.CreateRegular(t.Context(), dinners.NewRegular{RecipeURL: ptr(tt.linkTaken)}, member)
-				var dup *dinners.DuplicateError
-				if !errors.As(err, &dup) || dup.Existing.ID != c.ID {
-					t.Errorf("adding the fixed dinner's recipe link: err = %v, want a duplicate of %s", err, c.ID)
-				}
-			}
-		})
-	}
-}
-
 func TestFixViaRecipeURL(t *testing.T) {
 	t.Parallel()
 	e := newEnv(t)
@@ -946,126 +553,6 @@ func TestRestartFailsInterruptedGrounding(t *testing.T) {
 	}
 }
 
-// TestRestartKeepsArchivedPendingDinner: a pending Regular archived while
-// its job runs stays pending, its job succeeded; the boot cleanup leaves it
-// as it is rather than failing it as interrupted.
-func TestRestartKeepsArchivedPendingDinner(t *testing.T) {
-	t.Parallel()
-	e := newEnv(t)
-	e.search.Gate = make(chan struct{})
-	c, err := e.svc.CreateRegular(t.Context(), dinners.NewRegular{Name: ptr("Chicken curry")}, member)
-	if err != nil {
-		t.Fatal(err)
-	}
-	e.waitQuery(t, "Chicken curry")
-	if _, err := e.svc.Archive(t.Context(), c.ID, member); err != nil {
-		t.Fatal(err)
-	}
-	job := e.waitJob(t, *c.GroundingJobID)
-	close(e.search.Gate)
-	if job.Status != jobs.StatusSucceeded {
-		t.Fatalf("job = %+v, want succeeded", job)
-	}
-
-	// The database is now as the next boot finds it.
-	n, err := e.svc.FailInterruptedGroundings(t.Context())
-	if err != nil {
-		t.Fatal(err)
-	}
-	if n != 0 {
-		t.Errorf("failed %d dinners, want 0", n)
-	}
-	if row := e.dinner(t, c.ID); row.Status != dinners.StatusArchived ||
-		row.GroundingStatus != dinners.GroundingPending || row.GroundingError.Valid {
-		t.Errorf("dinner = %s, %s (%s), want archived and pending with no error",
-			row.Status, row.GroundingStatus, row.GroundingError.String)
-	}
-}
-
-// TestUpgradeKeepsLegacyQueuedGrounding: a pending Regular whose
-// ground_dinner job was queued before migration 0010, so its payload has
-// no revision, is not failed as interrupted at the first boot after the
-// upgrade; its job still grounds it. The upgrade starts either from 0009
-// or from a database that has already applied 0010.
-func TestUpgradeKeepsLegacyQueuedGrounding(t *testing.T) {
-	t.Parallel()
-	for name, below := range map[string]string{
-		"from 0009": "0010",
-		"from 0010": "0011",
-	} {
-		t.Run(name, func(t *testing.T) {
-			t.Parallel()
-			upgradeWithLegacyQueuedGrounding(t, below)
-		})
-	}
-}
-
-// upgradeWithLegacyQueuedGrounding migrates a database to every migration
-// named before below, adds a pending Regular with a queued ground_dinner
-// job whose payload has no revision, then boots on the latest migrations.
-func upgradeWithLegacyQueuedGrounding(t *testing.T, below string) {
-	ctx := t.Context()
-	dataDir := t.TempDir()
-	st := openStore(t, dataDir)
-	before := fstest.MapFS{}
-	files, err := fs.Glob(migrations.FS, "*.sql")
-	if err != nil {
-		t.Fatal(err)
-	}
-	for _, name := range files {
-		if name >= below {
-			continue
-		}
-		body, err := fs.ReadFile(migrations.FS, name)
-		if err != nil {
-			t.Fatal(err)
-		}
-		before[name] = &fstest.MapFile{Data: body}
-	}
-	if err := store.Migrate(ctx, st.Writer, before); err != nil {
-		t.Fatal(err)
-	}
-	now := store.Now().String()
-	if _, err := st.Writer.ExecContext(ctx, `INSERT INTO dinners
-		(id, name, normalized_name, status, origin, is_favorite, grounding_status, updated_by, created_at, updated_at)
-		VALUES ('dinner-1', 'Chicken curry', 'chicken curry', 'regular', 'regular', 0, 'pending', ?, ?, ?)`,
-		member, now, now); err != nil {
-		t.Fatal(err)
-	}
-	if _, err := st.Writer.ExecContext(ctx, `INSERT INTO jobs (id, kind, status, payload, created_at, updated_at)
-		VALUES ('job-1', ?, 'queued', '{"dinner_id":"dinner-1"}', ?, ?)`,
-		dinners.KindGroundDinner, now, now); err != nil {
-		t.Fatal(err)
-	}
-
-	// Boot: migrate, start the runner, then fail interrupted groundings. The
-	// search is held, so the job cannot finish before the cleanup runs.
-	e := newUnstartedEnvOn(t, st, dataDir)
-	e.search.Gate = make(chan struct{})
-	e.model.QueueGenerate(recipestest.NormalizedReply("stovetop", 40))
-	if p := e.queuedJob(t, "job-1"); p != (dinners.GroundJob{DinnerID: "dinner-1", Revision: 0}) {
-		t.Errorf("migrated payload = %+v, want dinner-1 at revision 0", p)
-	}
-	e.start(t)
-	n, err := e.svc.FailInterruptedGroundings(ctx)
-	if err != nil {
-		t.Fatal(err)
-	}
-	if n != 0 {
-		t.Errorf("failed %d dinners, want 0", n)
-	}
-	if row := e.dinner(t, "dinner-1"); row.GroundingStatus != dinners.GroundingPending {
-		t.Fatalf("dinner = %s (%s), want still pending", row.GroundingStatus, row.GroundingError.String)
-	}
-	close(e.search.Gate)
-	if job := e.waitJob(t, "job-1"); job.Status != jobs.StatusSucceeded {
-		t.Fatalf("job = %+v", job)
-	}
-	if row := e.dinner(t, "dinner-1"); row.GroundingStatus != dinners.GroundingGrounded {
-		t.Errorf("dinner = %s, want grounded", row.GroundingStatus)
-	}
-}
-
 // TestCreateEnqueueFailureReturnsFailedDinner: a dinner saved when its job
 // cannot be enqueued is returned, with its id, failed and no job id.
 func TestCreateEnqueueFailureReturnsFailedDinner(t *testing.T) {
@@ -1106,204 +593,3 @@ func TestGroundTimesOut(t *testing.T) {
 		t.Errorf("grounding_status = %s, want failed as before", row.GroundingStatus)
 	}
 }
-
-// TestFixInFlightWhenDinnerChanges: a link still grounding when its dinner
-// is renamed, archived or grounded some other way writes nothing; the
-// change made meanwhile is kept.
-func TestFixInFlightWhenDinnerChanges(t *testing.T) {
-	t.Parallel()
-	tests := []struct {
-		name   string
-		change func(t *testing.T, e *env, id string)
-		want   error
-		// kept checks the dinner shows the change, not the link's recipe.
-		kept func(row db.Dinner) bool
-	}{
-		{"renamed", func(t *testing.T, e *env, id string) {
-			if _, err := e.svc.Update(t.Context(), id, dinners.Patch{Name: ptr("Chicken curry")}, member); err != nil {
-				t.Fatal(err)
-			}
-		}, dinners.ErrGroundConflict, func(row db.Dinner) bool {
-			return row.Name == "Chicken curry" && row.GroundingStatus == dinners.GroundingFailed && !row.RecipeID.Valid
-		}},
-		{"renamed to the same normalized name", func(t *testing.T, e *env, id string) {
-			if _, err := e.svc.Update(t.Context(), id, dinners.Patch{Name: ptr("Easy Grandma's stew")}, member); err != nil {
-				t.Fatal(err)
-			}
-		}, dinners.ErrGroundConflict, func(row db.Dinner) bool {
-			return row.Name == "Easy Grandma's stew" && row.GroundingStatus == dinners.GroundingFailed && !row.RecipeID.Valid
-		}},
-		{"archived", func(t *testing.T, e *env, id string) {
-			if _, err := e.svc.Archive(t.Context(), id, member); err != nil {
-				t.Fatal(err)
-			}
-		}, dinners.ErrArchived, func(row db.Dinner) bool {
-			return row.Status == dinners.StatusArchived && row.GroundingStatus == dinners.GroundingFailed && !row.RecipeID.Valid
-		}},
-		{"grounded by hand", func(t *testing.T, e *env, id string) {
-			if _, err := e.svc.Ground(t.Context(), id, dinners.Fix{Manual: &dinners.ManualRecipe{
-				Ingredients: []string{"1 lb beef"}, Minutes: ptr(240), Method: ptr("crockpot"),
-			}}, member); err != nil {
-				t.Fatal(err)
-			}
-		}, dinners.ErrGroundConflict, func(row db.Dinner) bool {
-			return row.GroundingStatus == dinners.GroundingManual && row.Method.String == "crockpot"
-		}},
-	}
-	for _, tt := range tests {
-		t.Run(tt.name, func(t *testing.T) {
-			t.Parallel()
-			e := newEnv(t)
-			id := failedDinner(t, e, "Grandma's stew")
-			e.model.QueueGenerate(recipestest.NormalizedReply("oven", 150))
-			e.pages.Gate = make(chan struct{})
-
-			done := make(chan error, 1)
-			go func() {
-				_, err := e.svc.Ground(context.Background(), id, dinners.Fix{RecipeURL: ptr(stew)}, member)
-				done <- err
-			}()
-			e.waitFetched(t, stew)
-			tt.change(t, e, id)
-			close(e.pages.Gate)
-
-			if err := <-done; !errors.Is(err, tt.want) {
-				t.Fatalf("err = %v, want %v", err, tt.want)
-			}
-			if row := e.dinner(t, id); !tt.kept(row) {
-				t.Errorf("dinner = %+v, want the %s change kept and the link's recipe not written", row, tt.name)
-			}
-		})
-	}
-}
-
-// TestFixInFlightKeepsMemberEdits: a method, minutes or difficulty a
-// member sets while a link is grounding is kept; a field they left alone
-// takes the link's recipe, even one already set before grounding began.
-func TestFixInFlightKeepsMemberEdits(t *testing.T) {
-	t.Parallel()
-	// Every field is set before grounding, then one is changed in flight.
-	before := dinners.Patch{Method: ptr("stovetop"), MinutesTotal: ptr(45), Difficulty: ptr("easy")}
-	tests := []struct {
-		name  string
-		edit  dinners.Patch
-		field string
-	}{
-		{"method", dinners.Patch{Method: ptr("grill")}, "method"},
-		{"minutes", dinners.Patch{MinutesTotal: ptr(20)}, "minutes_total"},
-		{"difficulty", dinners.Patch{Difficulty: ptr("medium")}, "difficulty"},
-	}
-	for _, tt := range tests {
-		t.Run(tt.name, func(t *testing.T) {
-			t.Parallel()
-			e := newEnv(t)
-			id := failedDinner(t, e, "Grandma's stew")
-			if _, err := e.svc.Update(t.Context(), id, before, member); err != nil {
-				t.Fatal(err)
-			}
-			e.model.QueueGenerate(recipestest.NormalizedReply("oven", 150))
-			e.pages.Gate = make(chan struct{})
-
-			done := make(chan error, 1)
-			go func() {
-				_, err := e.svc.Ground(context.Background(), id, dinners.Fix{RecipeURL: ptr(stew)}, member)
-				done <- err
-			}()
-			e.waitFetched(t, stew)
-			if _, err := e.svc.Update(t.Context(), id, tt.edit, member); err != nil {
-				t.Fatal(err)
-			}
-			close(e.pages.Gate)
-
-			if err := <-done; err != nil {
-				t.Fatal(err)
-			}
-			row := e.dinner(t, id)
-			if row.GroundingStatus != dinners.GroundingGrounded || !row.RecipeID.Valid {
-				t.Fatalf("dinner = %+v, want grounded in the link's recipe", row)
-			}
-			var recipe fields
-			if err := e.st.Reader.QueryRowContext(t.Context(),
-				`SELECT method, minutes_total, difficulty FROM recipes WHERE id = ?`, row.RecipeID.String,
-			).Scan(&recipe.method, &recipe.minutes, &recipe.difficulty); err != nil {
-				t.Fatal(err)
-			}
-			old, edited := patchFields(before), patchFields(tt.edit)
-			want := recipe
-			switch tt.field {
-			case "method":
-				want.method = edited.method
-			case "minutes_total":
-				want.minutes = edited.minutes
-			case "difficulty":
-				want.difficulty = edited.difficulty
-			}
-			if recipe.method == old.method || recipe.minutes == old.minutes || recipe.difficulty == old.difficulty {
-				t.Fatalf("recipe %+v shares a value with the dinner before grounding %+v", recipe, old)
-			}
-			got := fields{row.Method.String, row.MinutesTotal.Int64, row.Difficulty.String}
-			if got != want {
-				t.Errorf("method, minutes, difficulty = %+v, want %+v: the %s edit kept, the rest from the recipe", got, want, tt.field)
-			}
-		})
-	}
-}
-
-// fields are a dinner's or recipe's method, minutes_total and difficulty.
-type fields struct {
-	method     string
-	minutes    int64
-	difficulty string
-}
-
-// patchFields returns the fields p sets, zero where it sets none.
-func patchFields(p dinners.Patch) fields {
-	var f fields
-	if p.Method != nil {
-		f.method = *p.Method
-	}
-	if p.MinutesTotal != nil {
-		f.minutes = int64(*p.MinutesTotal)
-	}
-	if p.Difficulty != nil {
-		f.difficulty = *p.Difficulty
-	}
-	return f
-}
-
-// TestFixArchivedDinner: an archived dinner cannot be grounded by hand.
-func TestFixArchivedDinner(t *testing.T) {
-	t.Parallel()
-	e := newEnv(t)
-	id := failedDinner(t, e, "Grandma's stew")
-	if _, err := e.svc.Archive(t.Context(), id, member); err != nil {
-		t.Fatal(err)
-	}
-	before := e.dinner(t, id)
-	for _, f := range []dinners.Fix{
-		{RecipeURL: ptr(stew)},
-		{Manual: &dinners.ManualRecipe{Ingredients: []string{"1 lb beef"}, Minutes: ptr(240), Method: ptr("crockpot")}},
-	} {
-		if _, err := e.svc.Ground(t.Context(), id, f, member); !errors.Is(err, dinners.ErrArchived) {
-			t.Errorf("fix %+v: err = %v, want ErrArchived", f, err)
-		}
-	}
-	if got := e.pages.Fetched(); len(got) != 0 {
-		t.Errorf("fetched %q for an archived dinner", got)
-	}
-	if after := e.dinner(t, id); after != before {
-		t.Errorf("archived dinner changed: %+v, was %+v", after, before)
-	}
-}
-
-// waitFetched waits until rawURL has been fetched.
-func (e *env) waitFetched(t *testing.T, rawURL string) {
-	t.Helper()
-	deadline := time.Now().Add(10 * time.Second)
-	for !slices.Contains(e.pages.Fetched(), rawURL) {
-		if time.Now().After(deadline) {
-			t.Fatalf("%s never fetched", rawURL)
-		}
-		time.Sleep(5 * time.Millisecond)
-	}
-}

internal/household/settings.go

@@ -71,15 +71,10 @@ type SettingsPatch struct {
 	// OnboardingCompleted, when true, records that the household finished
 	// onboarding: onboarding_completed_at becomes the time of the update,
 	// unless it is already set, when the first time is kept. Onboarding is
-	// never undone, so false is invalid, and it cannot first be completed
-	// with fewer than MinRegulars Regulars.
+	// never undone, so false is invalid.
 	OnboardingCompleted *bool
 }
 
-// MinRegulars is how many Regulars the household must have to complete
-// onboarding.
-const MinRegulars = 3
-
 // Problem is one invalid field of a SettingsPatch, named by its JSON key.
 type Problem struct {
 	Field  string
@@ -172,8 +167,7 @@ func (s *SettingsService) Get(ctx context.Context) (Settings, error) {
 // Update validates patch, applies it, records updatedBy (the signed-in
 // member's subject, which must not be empty) and publishes the new settings
 // to every subscriber. An invalid patch is a *ValidationError and changes
-// nothing, as does completing onboarding with fewer than MinRegulars
-// Regulars.
+// nothing.
 func (s *SettingsService) Update(ctx context.Context, patch SettingsPatch, updatedBy string) (Settings, error) {
 	if updatedBy == "" {
 		return Settings{}, errors.New("household: update settings: no member to record as updated_by")
@@ -220,16 +214,6 @@ func (s *SettingsService) Update(ctx context.Context, patch SettingsPatch, updat
 		setDow(&p.ChatAutosendDow, patch.ChatAutosendDow)
 		setString(&p.ChatAutosendTime, patch.ChatAutosendTime)
 		if patch.OnboardingCompleted != nil && !p.OnboardingCompletedAt.Valid {
-			n, err := q.CountRegularDinners(ctx)
-			if err != nil {
-				return fmt.Errorf("household: count Regulars: %w", err)
-			}
-			if n < MinRegulars {
-				return &ValidationError{Problems: []Problem{{
-					Field:  "onboarding_completed",
-					Reason: fmt.Sprintf("add at least %d Regulars first (have %d)", MinRegulars, n),
-				}}}
-			}
 			p.OnboardingCompletedAt = sql.NullString{String: p.UpdatedAt, Valid: true}
 		}
 		row, err = q.UpsertHouseholdSettings(ctx, p)

internal/household/settings_test.go

@@ -3,13 +3,10 @@ package household
 import (
 	"context"
 	"errors"
-	"fmt"
 	"slices"
-	"strings"
 	"sync"
 	"testing"
 
-	"code.cubecraftlabs.com/Maniacs_Mansion/Meal-Quest/internal/db"
 	"code.cubecraftlabs.com/Maniacs_Mansion/Meal-Quest/internal/store"
 	"code.cubecraftlabs.com/Maniacs_Mansion/Meal-Quest/migrations"
 )
@@ -37,34 +34,12 @@ func migratedStore(t *testing.T, dir string) *store.Store {
 // seededService returns a settings service over a migrated temp database
 // seeded with zone America/New_York.
 func seededService(t *testing.T) *SettingsService {
-	t.Helper()
-	svc, _ := seededServiceStore(t)
-	return svc
-}
-
-// seededServiceStore is seededService with its store.
-func seededServiceStore(t *testing.T) (*SettingsService, *store.Store) {
 	t.Helper()
 	st := migratedStore(t, t.TempDir())
 	if err := SeedSettings(context.Background(), st, "America/New_York"); err != nil {
 		t.Fatal(err)
 	}
-	return NewSettingsService(st), st
-}
-
-// addDinners stores n dinners with status.
-func addDinners(t *testing.T, st *store.Store, status string, n int) {
-	t.Helper()
-	for range n {
-		id := store.NewID()
-		now := store.Now().String()
-		if _, err := db.New(st.Writer).CreateDinner(context.Background(), db.CreateDinnerParams{
-			ID: id, Name: "Dinner " + id, NormalizedName: "dinner " + strings.ToLower(id),
-			Status: status, Origin: "regular", GroundingStatus: "pending", CreatedAt: now, UpdatedAt: now,
-		}); err != nil {
-			t.Fatal(err)
-		}
-	}
+	return NewSettingsService(st)
 }
 
 func ptr[T any](v T) *T { return &v }
@@ -245,8 +220,7 @@ func TestUpdateAppliesPatchAndRecordsUpdatedBy(t *testing.T) {
 func TestUpdateCompletesOnboardingOnce(t *testing.T) {
 	t.Parallel()
 	ctx := context.Background()
-	svc, st := seededServiceStore(t)
-	addDinners(t, st, "regular", MinRegulars)
+	svc := seededService(t)
 
 	got, err := svc.Update(ctx, SettingsPatch{OnboardingCompleted: ptr(true)}, "sam")
 	if err != nil {
@@ -276,36 +250,6 @@ func TestUpdateCompletesOnboardingOnce(t *testing.T) {
 	}
 }
 
-// TestUpdateOnboardingNeedsMinRegulars: onboarding cannot be completed
-// with fewer than MinRegulars Regulars; archived and Quest log dinners do
-// not count.
-func TestUpdateOnboardingNeedsMinRegulars(t *testing.T) {
-	t.Parallel()
-	for regulars := range MinRegulars {
-		t.Run(fmt.Sprintf("%d Regulars", regulars), func(t *testing.T) {
-			t.Parallel()
-			ctx := context.Background()
-			svc, st := seededServiceStore(t)
-			addDinners(t, st, "regular", regulars)
-			addDinners(t, st, "archived", MinRegulars)
-			addDinners(t, st, "quest_log", MinRegulars)
-
-			_, err := svc.Update(ctx, SettingsPatch{OnboardingCompleted: ptr(true)}, "sam")
-			var verr *ValidationError
-			if !errors.As(err, &verr) || len(verr.Problems) != 1 || verr.Problems[0].Field != "onboarding_completed" {
-				t.Fatalf("Update = %v, want a ValidationError on onboarding_completed", err)
-			}
-			got, err := svc.Get(ctx)
-			if err != nil {
-				t.Fatal(err)
-			}
-			if got.OnboardingCompletedAt != nil {
-				t.Errorf("onboarding_completed_at = %s after a refused completion, want null", *got.OnboardingCompletedAt)
-			}
-		})
-	}
-}
-
 func TestUpdateRequiresMember(t *testing.T) {
 	t.Parallel()
 	ctx := context.Background()

internal/recipes/ground.go

@@ -266,7 +266,7 @@ func (g *Grounder) GroundURL(ctx context.Context, rawURL string) (Grounded, erro
 	}
 	gr, reason, err := g.ground(ctx, rawURL, r)
 	if err != nil {
-		return Grounded{}, fmt.Errorf("recipes: ground pasted link: %w", err)
+		return Grounded{}, fmt.Errorf("recipes: ground %s: %w", rawURL, err)
 	}
 	if reason != nil {
 		return ungroundable(reason)

internal/recipes/recipestest/recipestest.go

@@ -66,15 +66,9 @@ func (s *Search) Queries() []string {
 type Pages struct {
 	Bodies map[string][]byte
 	Gate   chan struct{}
-
-	mu      sync.Mutex
-	fetched []string
 }
 
 func (p *Pages) Fetch(ctx context.Context, rawURL string) (recipes.Page, error) {
-	p.mu.Lock()
-	p.fetched = append(p.fetched, rawURL)
-	p.mu.Unlock()
 	if p.Gate != nil {
 		select {
 		case <-p.Gate:
@@ -89,13 +83,6 @@ func (p *Pages) Fetch(ctx context.Context, rawURL string) (recipes.Page, error)
 	return recipes.Page{URL: rawURL, ContentType: "text/html", Body: body}, nil
 }
 
-// Fetched returns every URL fetched, in order.
-func (p *Pages) Fetched() []string {
-	p.mu.Lock()
-	defer p.mu.Unlock()
-	return append([]string(nil), p.fetched...)
-}
-
 // Images is a recipes.ImageFetcher serving JPEGs by URL; any other URL is
 // a 404.
 type Images struct {

internal/server/dinners.go

@@ -200,11 +200,7 @@ func actorOrFail(w http.ResponseWriter, r *http.Request, logger *slog.Logger) (a
 // writeDinnerError maps a dinners.Service error to its API error. A page
 // that cannot ground the dinner is 422 ungroundable; recipe search not set
 // up is 409 not_configured; a search or model failure is 502; grounding by
-// hand that runs past dinners.GroundTimeout is 504 ground_timeout; grounding
-// an archived dinner is 409 dinner_archived and one changed while grounding
-// 409 ground_conflict. Any other grounding failure, by candidate, link or
-// manual recipe, wraps dinners.ErrGroundFailed and is 500, logged by reason
-// and dinner id only.
+// hand that runs past dinners.GroundTimeout is 504 ground_timeout.
 func writeDinnerError(w http.ResponseWriter, r *http.Request, logger *slog.Logger, action string, err error) {
 	var invalid *dinners.ValidationError
 	var dup *dinners.DuplicateError
@@ -224,16 +220,6 @@ func writeDinnerError(w http.ResponseWriter, r *http.Request, logger *slog.Logge
 	case errors.Is(err, recipes.ErrNormalizeFailed):
 		logger.WarnContext(r.Context(), action, "reason", "normalize_recipe failed")
 		writeError(w, r, logger, http.StatusBadGateway, "ai_failed", "the AI provider failed to read the recipe")
-	case errors.Is(err, dinners.ErrGroundFailed):
-		// The error may quote the pasted link, which can carry a personal
-		// token, and dependency errors, so only the reason and dinner are
-		// logged.
-		logger.ErrorContext(r.Context(), action, "reason", "ground_failed", "dinner_id", chi.URLParam(r, "id"))
-		writeError(w, r, logger, http.StatusInternalServerError, "internal", "internal error")
-	case errors.Is(err, dinners.ErrArchived):
-		writeError(w, r, logger, http.StatusConflict, "dinner_archived", "the dinner is archived")
-	case errors.Is(err, dinners.ErrGroundConflict):
-		writeError(w, r, logger, http.StatusConflict, "ground_conflict", "the dinner changed while its recipe was grounding; reload and try again")
 	case errors.Is(err, dinners.ErrGroundTimeout):
 		logger.WarnContext(r.Context(), action, "reason", "ground_timeout")
 		writeError(w, r, logger, http.StatusGatewayTimeout, "ground_timeout", "grounding the recipe took too long; try again")

internal/server/grounding_test.go

@@ -224,115 +224,6 @@ func TestPostGroundViaRecipeURL(t *testing.T) {
 	}
 }
 
-// TestPostGroundViaRecipeURLStorageFailure: a pasted link that fails for a
-// reason other than its recipe is a 500 logged by reason and dinner id,
-// never with the link, which can carry a personal token, or the dependency
-// error.
-func TestPostGroundViaRecipeURLStorageFailure(t *testing.T) {
-	t.Parallel()
-	e := newDinnersEnv(t).withRecipes(t)
-	const token = "personal-token-abc123"
-	link := stewPage + "?access_token=" + token
-	e.pages.Bodies[link] = e.pages.Bodies[stewPage]
-	id := createDinner(t, e.h, `{"name":"Sunday stew"}`)
-	e.model.QueueGenerate(recipestest.NormalizedReply("oven", 150))
-	if _, err := e.st.Writer.ExecContext(t.Context(),
-		`CREATE TRIGGER refuse_recipes BEFORE INSERT ON recipes BEGIN SELECT RAISE(ABORT, 'disk full'); END`); err != nil {
-		t.Fatal(err)
-	}
-
-	rec, body := callDinners(t, e.h, http.MethodPost, dinnersPath+"/"+id+"/ground", `{"recipe_url":"`+link+`"}`)
-	if rec.Code != http.StatusInternalServerError || errorCode(body) != "internal" || strings.Contains(rec.Body.String(), token) {
-		t.Errorf("POST = %d %s, want 500 internal without the link", rec.Code, rec.Body)
-	}
-	logs := e.logs.String()
-	if strings.Contains(logs, token) || strings.Contains(logs, "c.example") || strings.Contains(logs, "disk full") ||
-		!strings.Contains(logs, "reason=ground_failed") || !strings.Contains(logs, "dinner_id="+id) {
-		t.Errorf("logs = %q, want reason=ground_failed and the dinner id, without the link or dependency error", logs)
-	}
-}
-
-// TestPostGroundViaRecipeURLDinnerWriteFailure: a pasted link whose recipe
-// is stored but whose dinner cannot be written is a 500 logged by reason
-// and dinner id, never with the dependency error.
-func TestPostGroundViaRecipeURLDinnerWriteFailure(t *testing.T) {
-	t.Parallel()
-	e := newDinnersEnv(t).withRecipes(t)
-	id := createDinner(t, e.h, `{"name":"Sunday stew"}`)
-	e.model.QueueGenerate(recipestest.NormalizedReply("oven", 150))
-	if _, err := e.st.Writer.ExecContext(t.Context(),
-		`CREATE TRIGGER refuse_grounding BEFORE UPDATE OF recipe_id ON dinners WHEN NEW.recipe_id IS NOT NULL BEGIN SELECT RAISE(ABORT, 'disk full'); END`); err != nil {
-		t.Fatal(err)
-	}
-
-	rec, body := callDinners(t, e.h, http.MethodPost, dinnersPath+"/"+id+"/ground", `{"recipe_url":"`+stewPage+`"}`)
-	if rec.Code != http.StatusInternalServerError || errorCode(body) != "internal" {
-		t.Errorf("POST = %d %s, want 500 internal", rec.Code, rec.Body)
-	}
-	var stored int
-	if err := e.st.Reader.QueryRowContext(t.Context(), `SELECT COUNT(*) FROM recipes WHERE source_url = ?`, stewPage).Scan(&stored); err != nil || stored != 1 {
-		t.Fatalf("recipes stored for the link = %d (%v), want 1: the failure must be the dinner write", stored, err)
-	}
-	logs := e.logs.String()
-	if strings.Contains(logs, "disk full") || !strings.Contains(logs, "reason=ground_failed") || !strings.Contains(logs, "dinner_id="+id) {
-		t.Errorf("logs = %q, want reason=ground_failed and the dinner id, without the dependency error", logs)
-	}
-}
-
-// TestPostGroundUnexpectedFailures: grounding by hand that fails reading
-// the dinner, or storing a manual recipe, is a 500 logged by reason and
-// dinner id, never with the database error.
-func TestPostGroundUnexpectedFailures(t *testing.T) {
-	t.Parallel()
-	const (
-		// Renaming a column every dinner read selects fails the read.
-		breakRead = `ALTER TABLE dinners RENAME COLUMN cuisine TO cuisine_gone`
-		// The trigger's message stands in for the database error.
-		breakStore = `CREATE TRIGGER refuse_recipes BEFORE INSERT ON recipes BEGIN SELECT RAISE(ABORT, 'disk full'); END`
-		manual     = `{"manual":{"ingredients":["1 lb beef"],"steps":["Brown."],"minutes":240,"method":"crockpot"}}`
-	)
-	for _, tc := range []struct {
-		name, sabotage, fix, leak string
-	}{
-		{"link read", breakRead, `{"recipe_url":"` + stewPage + `"}`, "cuisine"},
-		{"manual read", breakRead, manual, "cuisine"},
-		{"manual store", breakStore, manual, "disk full"},
-	} {
-		t.Run(tc.name, func(t *testing.T) {
-			t.Parallel()
-			e := newDinnersEnv(t).withRecipes(t)
-			id := createDinner(t, e.h, `{"name":"Sunday stew"}`)
-			if _, err := e.st.Writer.ExecContext(t.Context(), tc.sabotage); err != nil {
-				t.Fatal(err)
-			}
-
-			rec, body := callDinners(t, e.h, http.MethodPost, dinnersPath+"/"+id+"/ground", tc.fix)
-			if rec.Code != http.StatusInternalServerError || errorCode(body) != "internal" {
-				t.Errorf("POST = %d %s, want 500 internal", rec.Code, rec.Body)
-			}
-			logs := e.logs.String()
-			if strings.Contains(logs, tc.leak) || !strings.Contains(logs, "reason=ground_failed") || !strings.Contains(logs, "dinner_id="+id) {
-				t.Errorf("logs = %q, want reason=ground_failed and the dinner id, without the database error", logs)
-			}
-		})
-	}
-}
-
-// TestPostGroundArchived: grounding an archived dinner by hand is a 409.
-func TestPostGroundArchived(t *testing.T) {
-	t.Parallel()
-	e := newDinnersEnv(t)
-	id := createDinner(t, e.h, `{"name":"Family chili"}`)
-	if rec, _ := callDinners(t, e.h, http.MethodDelete, dinnersPath+"/"+id, ""); rec.Code != http.StatusOK {
-		t.Fatalf("DELETE = %d: %s", rec.Code, rec.Body)
-	}
-	rec, body := callDinners(t, e.h, http.MethodPost, dinnersPath+"/"+id+"/ground",
-		`{"manual":{"ingredients":["1 lb beef"],"minutes":240,"method":"crockpot"}}`)
-	if rec.Code != http.StatusConflict || errorCode(body) != "dinner_archived" {
-		t.Errorf("POST = %d %v, want 409 dinner_archived", rec.Code, body)
-	}
-}
-
 func TestPostGroundViaManual(t *testing.T) {
 	t.Parallel()
 	e := newDinnersEnv(t)

internal/server/settings_test.go

@@ -3,7 +3,6 @@ package server
 import (
 	"context"
 	"encoding/json"
-	"fmt"
 	"io"
 	"log/slog"
 	"net/http"
@@ -14,7 +13,6 @@ import (
 	"time"
 
 	"code.cubecraftlabs.com/Maniacs_Mansion/Meal-Quest/internal/auth"
-	"code.cubecraftlabs.com/Maniacs_Mansion/Meal-Quest/internal/db"
 	"code.cubecraftlabs.com/Maniacs_Mansion/Meal-Quest/internal/household"
 	"code.cubecraftlabs.com/Maniacs_Mansion/Meal-Quest/internal/store"
 	"code.cubecraftlabs.com/Maniacs_Mansion/Meal-Quest/migrations"
@@ -117,30 +115,10 @@ func TestPatchHouseholdSettings(t *testing.T) {
 	}
 }
 
-// newOnboardingRouter returns a router whose settings store holds regulars
-// Regulars.
-func newOnboardingRouter(t *testing.T, regulars int) http.Handler {
-	t.Helper()
-	st := newTestStore(t)
-	if err := household.SeedSettings(context.Background(), st, "America/New_York"); err != nil {
-		t.Fatal(err)
-	}
-	for i := range regulars {
-		now := store.Now().String()
-		if _, err := db.New(st.Writer).CreateDinner(context.Background(), db.CreateDinnerParams{
-			ID: store.NewID(), Name: fmt.Sprintf("Dinner %d", i), NormalizedName: fmt.Sprintf("dinner %d", i),
-			Status: "regular", Origin: "regular", GroundingStatus: "pending", CreatedAt: now, UpdatedAt: now,
-		}); err != nil {
-			t.Fatal(err)
-		}
-	}
-	return newTestRouterWith(t, "dev", household.NewSettingsService(st), newTestRunner(t))
-}
-
 func TestPatchHouseholdSettingsCompletesOnboarding(t *testing.T) {
 	t.Parallel()
 
-	rec, body := serve(t, newOnboardingRouter(t, household.MinRegulars), signedIn(http.MethodPatch, settingsPath,
+	rec, body := serve(t, newTestRouter(t, "dev"), signedIn(http.MethodPatch, settingsPath,
 		strings.NewReader(`{"onboarding_completed":true}`)))
 	if rec.Code != http.StatusOK {
 		t.Fatalf("status = %d, want 200: %s", rec.Code, rec.Body)
@@ -150,30 +128,6 @@ func TestPatchHouseholdSettingsCompletesOnboarding(t *testing.T) {
 	}
 }
 
-// TestPatchHouseholdSettingsOnboardingNeedsRegulars: completing onboarding
-// with fewer than three Regulars is refused and leaves it incomplete.
-func TestPatchHouseholdSettingsOnboardingNeedsRegulars(t *testing.T) {
-	t.Parallel()
-
-	for regulars := range household.MinRegulars {
-		t.Run(fmt.Sprintf("%d Regulars", regulars), func(t *testing.T) {
-			t.Parallel()
-			router := newOnboardingRouter(t, regulars)
-			rec, _ := serve(t, router, signedIn(http.MethodPatch, settingsPath,
-				strings.NewReader(`{"onboarding_completed":true}`)))
-			if rec.Code != http.StatusBadRequest ||
-				!strings.Contains(rec.Body.String(), `"code":"invalid_settings"`) ||
-				!strings.Contains(rec.Body.String(), "onboarding_completed: add at least 3 Regulars first") {
-				t.Fatalf("PATCH = %d %s, want 400 invalid_settings on onboarding_completed", rec.Code, rec.Body)
-			}
-			_, body := serve(t, router, signedIn(http.MethodGet, settingsPath, nil))
-			if body["onboarding_completed_at"] != nil {
-				t.Errorf("onboarding_completed_at = %#v after a refused completion, want null", body["onboarding_completed_at"])
-			}
-		})
-	}
-}
-
 func TestPatchHouseholdSettingsRejected(t *testing.T) {
 	t.Parallel()
 

internal/store/migrate_test.go

@@ -175,8 +175,8 @@ func TestMigrateEmbeddedMigrations(t *testing.T) {
 	if err := Migrate(context.Background(), s.Writer, migrations.FS); err != nil {
 		t.Fatal(err)
 	}
-	if got := versions(migrationRows(t, s)); got != "0000_bootstrap,0001_init,0002_household_settings_updated_by,0003_jobs_status,0004_ai_provider_presets,0005_ai_provider_xai,0006_ai_runs_status,0007_recipe_grounding,0008_dinner_recipe_url,0009_dinner_grounding_error,0010_dinner_grounding_revision,0011_ground_dinner_job_revision" {
-		t.Errorf("versions = %q, want 0000_bootstrap,0001_init,0002_household_settings_updated_by,0003_jobs_status,0004_ai_provider_presets,0005_ai_provider_xai,0006_ai_runs_status,0007_recipe_grounding,0008_dinner_recipe_url,0009_dinner_grounding_error,0010_dinner_grounding_revision,0011_ground_dinner_job_revision", got)
+	if got := versions(migrationRows(t, s)); got != "0000_bootstrap,0001_init,0002_household_settings_updated_by,0003_jobs_status,0004_ai_provider_presets,0005_ai_provider_xai,0006_ai_runs_status,0007_recipe_grounding,0008_dinner_recipe_url,0009_dinner_grounding_error" {
+		t.Errorf("versions = %q, want 0000_bootstrap,0001_init,0002_household_settings_updated_by,0003_jobs_status,0004_ai_provider_presets,0005_ai_provider_xai,0006_ai_runs_status,0007_recipe_grounding,0008_dinner_recipe_url,0009_dinner_grounding_error", got)
 	}
 }
 
@@ -196,8 +196,8 @@ func TestMigrateBootstrapThenEmbeddedInitApplies(t *testing.T) {
 	if err := Migrate(ctx, s.Writer, migrations.FS); err != nil {
 		t.Fatal(err)
 	}
-	if got := versions(migrationRows(t, s)); got != "0000_bootstrap,0001_init,0002_household_settings_updated_by,0003_jobs_status,0004_ai_provider_presets,0005_ai_provider_xai,0006_ai_runs_status,0007_recipe_grounding,0008_dinner_recipe_url,0009_dinner_grounding_error,0010_dinner_grounding_revision,0011_ground_dinner_job_revision" {
-		t.Errorf("versions = %q, want 0000_bootstrap,0001_init,0002_household_settings_updated_by,0003_jobs_status,0004_ai_provider_presets,0005_ai_provider_xai,0006_ai_runs_status,0007_recipe_grounding,0008_dinner_recipe_url,0009_dinner_grounding_error,0010_dinner_grounding_revision,0011_ground_dinner_job_revision", got)
+	if got := versions(migrationRows(t, s)); got != "0000_bootstrap,0001_init,0002_household_settings_updated_by,0003_jobs_status,0004_ai_provider_presets,0005_ai_provider_xai,0006_ai_runs_status,0007_recipe_grounding,0008_dinner_recipe_url,0009_dinner_grounding_error" {
+		t.Errorf("versions = %q, want 0000_bootstrap,0001_init,0002_household_settings_updated_by,0003_jobs_status,0004_ai_provider_presets,0005_ai_provider_xai,0006_ai_runs_status,0007_recipe_grounding,0008_dinner_recipe_url,0009_dinner_grounding_error", got)
 	}
 	if !tableExists(t, s, "dinners") {
 		t.Error("table from 0001_init was not created")

migrations/0010_dinner_grounding_revision.sql

@@ -1,7 +0,0 @@
--- 0010_dinner_grounding_revision: each ground_dinner job carries the
--- dinner's grounding_revision when it was enqueued, and records its result
--- only while the dinner still has that revision. Renaming a pending dinner
--- raises the revision before enqueuing the job for the new name, so an
--- earlier job — queued or running — can no longer write the dinner.
-
-ALTER TABLE dinners ADD COLUMN grounding_revision INTEGER NOT NULL DEFAULT 0;

migrations/0011_ground_dinner_job_revision.sql

@@ -1,11 +0,0 @@
--- 0011_ground_dinner_job_revision: every dinner starts at grounding
--- revision 0 (0010), so a ground_dinner job enqueued before 0010, whose
--- payload has only dinner_id, is for revision 0. Recording it lets the boot
--- cleanup, which matches a pending dinner to its job by revision, see a job
--- still queued for its dinner. This is a migration of its own, not part of
--- 0010, so it also runs on a database that has already applied 0010.
-
-UPDATE jobs
-SET payload = json_set(payload, '$.revision', 0)
-WHERE kind = 'ground_dinner'
-	AND json_type(payload, '$.revision') IS NULL;

migrations/queries/dinners.sql

@@ -19,19 +19,11 @@ SELECT * FROM dinners
 WHERE status = ?
 ORDER BY normalized_name, id;
 
--- name: CountRegularDinners :one
--- How many Regulars the household has; archived dinners are not counted.
-SELECT COUNT(*) FROM dinners
-WHERE status = 'regular';
-
 -- name: ListUnarchivedDinners :many
--- Every dinner a new or renamed dinner must not repeat, with the
--- source_url of the recipe it is grounded in (NULL while it has none).
-SELECT sqlc.embed(dinners), recipes.source_url AS recipe_source_url
-FROM dinners
-LEFT JOIN recipes ON recipes.id = dinners.recipe_id
-WHERE dinners.status <> 'archived'
-ORDER BY dinners.id;
+-- Every dinner a new or renamed dinner must not repeat.
+SELECT * FROM dinners
+WHERE status <> 'archived'
+ORDER BY id;
 
 -- name: UpdateDinner :one
 -- An unknown id returns sql.ErrNoRows.
@@ -45,10 +37,8 @@ SET name = ?,
 	difficulty = ?,
 	cuisine = ?,
 	recipe_id = ?,
-	recipe_url = ?,
 	photo_id = ?,
 	grounding_status = ?,
-	grounding_revision = ?,
 	updated_by = ?,
 	updated_at = ?
 WHERE id = ?
@@ -82,87 +72,57 @@ WHERE id = ?
 RETURNING *;
 
 -- name: GroundDinner :one
--- Records a dinner's grounding by hand (grounded or manual) and clears any
--- grounding_error and pasted recipe_url: the recipe chosen replaces the
--- link. It writes only an unarchived dinner still as it was observed
--- before grounding (same name, normalized_name, grounding_status,
--- grounding_revision and recipe_id), so a dinner renamed, archived or
--- grounded some other way meanwhile is left as it is. That dinner, or an
--- unknown id, returns sql.ErrNoRows. A method, minutes_total or difficulty
--- no longer as observed is kept: a member edited it while it was grounding.
+-- Records a dinner's grounding (grounded or manual) and clears any
+-- grounding_error. An unknown id returns sql.ErrNoRows.
 UPDATE dinners
-SET recipe_id = sqlc.arg(recipe_id),
-	recipe_url = NULL,
-	photo_id = sqlc.arg(photo_id),
-	method = CASE WHEN method IS sqlc.narg(observed_method)
-		THEN sqlc.arg(method) ELSE method END,
-	minutes_total = CASE WHEN minutes_total IS sqlc.narg(observed_minutes_total)
-		THEN sqlc.arg(minutes_total) ELSE minutes_total END,
-	difficulty = CASE WHEN difficulty IS sqlc.narg(observed_difficulty)
-		THEN sqlc.arg(difficulty) ELSE difficulty END,
-	grounding_status = sqlc.arg(grounding_status),
+SET recipe_id = ?,
+	photo_id = ?,
+	method = ?,
+	minutes_total = ?,
+	difficulty = ?,
+	grounding_status = ?,
 	grounding_error = NULL,
-	updated_by = sqlc.arg(updated_by),
-	updated_at = sqlc.arg(updated_at)
-WHERE id = sqlc.arg(id)
-	AND status <> 'archived'
-	AND name = sqlc.arg(observed_name)
-	AND normalized_name = sqlc.arg(observed_normalized_name)
-	AND grounding_status = sqlc.arg(observed_grounding_status)
-	AND grounding_revision = sqlc.arg(observed_grounding_revision)
-	AND recipe_id IS sqlc.narg(observed_recipe_id)
+	updated_by = ?,
+	updated_at = ?
+WHERE id = ?
 RETURNING *;
 
 -- name: GroundPendingDinner :execrows
--- Records the background grounding of an unarchived dinner still pending at
--- the grounding_revision it was grounded for; a dinner grounded some other
--- way, renamed or archived meanwhile is left as it is (0 rows). A method,
--- minutes_total or difficulty already set is kept: a pending dinner has
--- them only when a member edited them while it was grounding.
+-- Records the background grounding of a dinner still pending; a dinner
+-- grounded some other way meanwhile is left as it is (0 rows).
 UPDATE dinners
-SET recipe_id = sqlc.arg(recipe_id),
-	photo_id = sqlc.arg(photo_id),
-	method = COALESCE(method, sqlc.arg(method)),
-	minutes_total = COALESCE(minutes_total, sqlc.arg(minutes_total)),
-	difficulty = COALESCE(difficulty, sqlc.arg(difficulty)),
+SET recipe_id = ?,
+	photo_id = ?,
+	method = ?,
+	minutes_total = ?,
+	difficulty = ?,
 	grounding_status = 'grounded',
 	grounding_error = NULL,
-	updated_at = sqlc.arg(updated_at)
-WHERE id = sqlc.arg(id)
-	AND status <> 'archived'
-	AND grounding_status = 'pending'
-	AND grounding_revision = sqlc.arg(grounding_revision);
+	updated_at = ?
+WHERE id = ? AND grounding_status = 'pending';
 
 -- name: FailPendingDinnerGrounding :execrows
--- Records why the background grounding of an unarchived dinner still
--- pending at the grounding_revision it was grounded for failed; a dinner
--- grounded some other way, renamed or archived meanwhile is left as it is
--- (0 rows).
+-- Records why the background grounding of a dinner still pending failed; a
+-- dinner grounded some other way meanwhile is left as it is (0 rows).
 UPDATE dinners
 SET grounding_status = 'failed',
 	grounding_error = ?,
 	updated_at = ?
-WHERE id = ?
-	AND status <> 'archived'
-	AND grounding_status = 'pending'
-	AND grounding_revision = ?;
+WHERE id = ? AND grounding_status = 'pending';
 
 -- name: FailOrphanedPendingDinnerGroundings :execrows
--- Fails every unarchived dinner still pending whose grounding job for its
--- current grounding_revision is no longer queued or running: the process
--- stopped before the job, or before its handler recorded a result. An
--- archived dinner is left as it is; archiving stopped its grounding. Run at
--- boot, after the job runner fails the jobs a previous process left running.
+-- Fails every dinner still pending whose grounding job is no longer queued
+-- or running: the process stopped before the job, or before its handler
+-- recorded a result. Run at boot, after the job runner fails the jobs a
+-- previous process left running.
 UPDATE dinners
 SET grounding_status = 'failed',
 	grounding_error = sqlc.arg(grounding_error),
 	updated_at = sqlc.arg(updated_at)
 WHERE grounding_status = 'pending'
-	AND status <> 'archived'
 	AND NOT EXISTS (
 		SELECT 1 FROM jobs
 		WHERE jobs.kind = sqlc.arg(kind)
 			AND jobs.status IN ('queued', 'running')
 			AND json_extract(jobs.payload, '$.dinner_id') = dinners.id
-			AND json_extract(jobs.payload, '$.revision') = dinners.grounding_revision
 	);

web/src/dinners/names.test.ts

@@ -1,20 +0,0 @@
-import { describe, expect, it } from 'vitest'
-import cases from '../../../internal/ai/harness/testdata/dedupe_cases.json'
-import { normalizeName, similarNames } from './names.ts'
-
-// The cases internal/ai/harness's tests run against Normalize and Similar.
-describe('dinner names, as the server compares them', () => {
-  it('has cases to run', () => {
-    expect(cases.normalize.length).toBeGreaterThan(0)
-    expect(cases.similar.length).toBeGreaterThan(0)
-  })
-
-  it.each(cases.normalize)('normalizes "$name" to "$want"', ({ name, want }) => {
-    expect(normalizeName(name)).toBe(want)
-  })
-
-  it.each(cases.similar)('"$a" and "$b" similar: $want', ({ a, b, want }) => {
-    expect(similarNames(a, b)).toBe(want)
-    expect(similarNames(b, a)).toBe(want)
-  })
-})

web/src/dinners/names.ts

@@ -1,58 +0,0 @@
-// The PWA's copy of the server's dinner-name rules (internal/ai/harness
-// Normalize and Similar), so a screen can tell beforehand that the dinners
-// API would refuse a name as a duplicate. The server still decides.
-// internal/ai/harness/testdata/dedupe_cases.json is run against both.
-
-import folds from './letterFolds.json'
-
-// SIMILAR_THRESHOLD is harness.SimilarThreshold.
-const SIMILAR_THRESHOLD = 0.85
-
-// fillerWords is harness's fillerWords.
-const fillerWords = new Set(['easy', 'best', 'homemade', 'quick', 'simple', 'the', 'a', 'recipe', 'classic'])
-
-// letterFolds is harness's letterFolds: gen_folds.py writes both tables,
-// and harness's TestLetterFoldsMatchPWA fails when they differ.
-const letterFolds: Record<string, string> = folds
-
-const combiningMark = /\p{Mn}/u
-const wordChar = /[\p{L}\p{Nd}]/u
-
-// normalizeName is harness.Normalize: lowercased, accents dropped, letters
-// folded, apostrophes removed, other punctuation turned into spaces and
-// filler words dropped. "Easy Chicken Tikka-Masala!" is
-// "chicken tikka masala".
-export function normalizeName(name: string): string {
-  let out = ''
-  // Lowercased letter by letter, as Go's strings.ToLower does, so no
-  // letter is lowered by its context (a final Σ is σ, not ς).
-  for (const letter of name) {
-    for (const ch of letter.toLowerCase()) {
-      if (combiningMark.test(ch) || ch === "'" || ch === '’') continue
-      const fold = letterFolds[ch]
-      if (fold !== undefined) out += fold
-      else if (wordChar.test(ch)) out += ch
-      else out += ' '
-    }
-  }
-  return out
-    .split(' ')
-    .filter((word) => word !== '' && !fillerWords.has(word))
-    .join(' ')
-}
-
-function words(name: string): Set<string> {
-  const normalized = normalizeName(name)
-  return new Set(normalized === '' ? [] : normalized.split(' '))
-}
-
-// similarNames is harness.Similar: whether a and b name the same dinner, by
-// the share of the words of their normalized forms they have in common.
-export function similarNames(a: string, b: string): boolean {
-  const left = words(a)
-  const right = words(b)
-  if (left.size === 0 || right.size === 0) return false
-  let shared = 0
-  for (const word of left) if (right.has(word)) shared++
-  return shared / (left.size + right.size - shared) >= SIMILAR_THRESHOLD
-}

web/src/onboarding/NotificationsStep.test.tsx

@@ -100,7 +100,6 @@ async function renderStep(enableNotifications?: EnableNotifications) {
               element={<NotificationsStep enableNotifications={enableNotifications} />}
             />
             <Route path="/" element={<h1>Home</h1>} />
-            <Route path="/onboarding/regulars" element={<h1>Regulars step</h1>} />
           </Routes>
         </AuthBootstrap>
       </ApiProviders>
@@ -258,41 +257,6 @@ describe('onboarding step 3', () => {
   })
 })
 
-describe('onboarding step 3 with too few Regulars', () => {
-  it('says why and offers a way back to add Regulars', async () => {
-    const server = await renderStep()
-    fireEvent.click(later())
-    await vi.waitFor(() => expect(server.held).toHaveLength(1))
-    server.held[0]!.answer(
-      jsonResponse(400, {
-        error: {
-          code: 'invalid_settings',
-          message: 'invalid household settings: onboarding_completed: add at least 3 Regulars first (have 2)',
-          retryable: false,
-        },
-      }),
-    )
-
-    expect(await screen.findByRole('alert')).toHaveTextContent(
-      'Could not finish setting up: invalid household settings: onboarding_completed: add at least 3 Regulars first (have 2)',
-    )
-    const addRegulars = screen.getByRole('button', { name: 'Add Regulars' })
-    expectMinHitArea(addRegulars)
-    fireEvent.click(addRegulars)
-    expect(await screen.findByRole('heading', { level: 1, name: 'Regulars step' })).toBeInTheDocument()
-  })
-
-  it('offers no way back for any other refusal', async () => {
-    const server = await renderStep()
-    fireEvent.click(later())
-    await vi.waitFor(() => expect(server.held).toHaveLength(1))
-    server.held[0]!.answer(errorResponse(500, 'internal'))
-
-    expect(await screen.findByRole('alert')).toHaveTextContent('Could not finish setting up: internal message')
-    expect(screen.queryByRole('button', { name: 'Add Regulars' })).not.toBeInTheDocument()
-  })
-})
-
 describe('notificationsUnavailable', () => {
   it('answers "unavailable" without asking for permission', async () => {
     await expect(notificationsUnavailable()).resolves.toBe('unavailable')

web/src/onboarding/NotificationsStep.tsx

@@ -2,7 +2,7 @@ import { useState } from 'react'
 import { CalendarDays, ShoppingBasket, Sparkles, UtensilsCrossed, type LucideIcon } from 'lucide-react'
 import { useNavigate } from 'react-router'
 import { InstallHint } from '../pwa/InstallHint.tsx'
-import { needsMoreRegulars, useCompleteOnboarding } from '../settings/api.ts'
+import { useCompleteOnboarding } from '../settings/api.ts'
 import { Button } from '../ui/Button.tsx'
 import { Icon } from '../ui/Icon.tsx'
 import { OnboardingStep } from './OnboardingStep.tsx'
@@ -50,15 +50,12 @@ export type NotificationsStepProps = {
 
 // NotificationsStep is onboarding step 3: what MealQuest notifies about, the
 // iOS install hint, and finishing onboarding. Either button records that
-// onboarding is finished and goes Home. When the server refuses because the
-// household has fewer than three Regulars, the reason shows with a way back
-// to step 2 to add them.
+// onboarding is finished and goes Home.
 export function NotificationsStep({ enableNotifications = notificationsUnavailable }: NotificationsStepProps) {
   const navigate = useNavigate()
   const complete = useCompleteOnboarding()
   const [enabling, setEnabling] = useState(false)
   const [problem, setProblem] = useState<string | null>(null)
-  const [fewRegulars, setFewRegulars] = useState(false)
   const busy = enabling || complete.isPending
 
   async function finish() {
@@ -66,19 +63,13 @@ export function NotificationsStep({ enableNotifications = notificationsUnavailab
       await complete.mutateAsync()
     } catch (error) {
       setProblem(`Could not finish setting up: ${(error as Error).message}`)
-      setFewRegulars(needsMoreRegulars(error as Error))
       return
     }
     void navigate('/', { replace: true })
   }
 
-  function clearProblem() {
-    setProblem(null)
-    setFewRegulars(false)
-  }
-
   async function turnOn() {
-    clearProblem()
+    setProblem(null)
     setEnabling(true)
     try {
       await enableNotifications()
@@ -92,7 +83,7 @@ export function NotificationsStep({ enableNotifications = notificationsUnavailab
   }
 
   function later() {
-    clearProblem()
+    setProblem(null)
     void finish()
   }
 
@@ -133,11 +124,6 @@ export function NotificationsStep({ enableNotifications = notificationsUnavailab
           {problem}
         </p>
       )}
-      {fewRegulars && (
-        <Button variant="outline" className={styles.recover} onClick={() => void navigate('/onboarding/regulars')}>
-          Add Regulars
-        </Button>
-      )}
     </OnboardingStep>
   )
 }

web/src/onboarding/Onboarding.module.css

@@ -229,11 +229,6 @@
   color: var(--color-accent-700);
 }
 
-/* Step 3: back to step 2 when the server wants more Regulars. */
-.recover {
-  margin-top: var(--space-3);
-}
-
 .status {
   margin-top: 10px;
 }

web/src/onboarding/OnboardingPage.test.tsx

@@ -146,14 +146,6 @@ describe('onboarding step 2 (mock 1h)', () => {
     expect(declaredStyle(pills[0]!).height).toBe('6px')
   })
 
-  it('does not offer a common pick the server would refuse as a duplicate of a Regular', async () => {
-    await regularsStep([dinnerBody('d1', 'Homemade chili'), dinnerBody('d2', 'Easy Chicken Stir Fry')])
-
-    expect(screen.queryByRole('button', { name: 'Add Chili' })).not.toBeInTheDocument()
-    expect(screen.queryByRole('button', { name: 'Add Chicken stir-fry' })).not.toBeInTheDocument()
-    expect(screen.getByRole('button', { name: 'Add Beef tacos' })).toBeInTheDocument()
-  })
-
   it('sizes the input pill, "+" button, picks and Next as the mock does', async () => {
     await regularsStep()
     expect(hitArea(input()).height).toBe(48)

web/src/onboarding/RegularsStep.tsx

@@ -2,7 +2,6 @@ import { useState, type FormEvent } from 'react'
 import { Plus } from 'lucide-react'
 import { useNavigate } from 'react-router'
 import { useAddRegular, useRegulars, useRemoveRegular, type Regular } from '../dinners/api.ts'
-import { similarNames } from '../dinners/names.ts'
 import { useRefusals } from '../dinners/useRefusals.ts'
 import { Button } from '../ui/Button.tsx'
 import { Chip } from '../ui/Chip.tsx'
@@ -17,8 +16,7 @@ import styles from './Onboarding.module.css'
 // household moves on.
 export const MIN_REGULARS = 3
 
-// commonPicks are offered as one-tap Regulars until the household has them,
-// or a Regular the server would count as the same dinner.
+// commonPicks are offered as one-tap Regulars until the household has them.
 export const commonPicks = [
   'Beef tacos',
   'Spaghetti bolognese',
@@ -30,6 +28,10 @@ export const commonPicks = [
   'Fried rice',
 ]
 
+function sameName(a: string, b: string): boolean {
+  return a.trim().toLowerCase() === b.trim().toLowerCase()
+}
+
 // RegularsStep is onboarding step 2, handoff mock 1h: the household adds
 // the dinners it makes on repeat. Each add and remove shows at once and is
 // undone if the server refuses it.
@@ -41,7 +43,7 @@ export function RegularsStep() {
   const [draft, setDraft] = useState('')
   const { refusals, track } = useRefusals()
   const list = regulars.data ?? []
-  const picks = commonPicks.filter((pick) => !list.some((regular) => similarNames(regular.name, pick)))
+  const picks = commonPicks.filter((pick) => !list.some((regular) => sameName(regular.name, pick)))
   // Next waits for every add to be answered, so a refused add's error shows
   // here and an add the server takes back never counts towards the three.
   const adding = list.some((regular) => regular.pending)

web/src/settings/api.ts

@@ -441,18 +441,6 @@ export function householdSettingsProblems(error: Error): HouseholdSettingsProble
   return problems
 }
 
-// needsMoreRegulars reports whether error is the server refusing to finish
-// onboarding because the household has fewer than three Regulars
-// (internal/household MinRegulars) — the only refusal of
-// {"onboarding_completed": true}.
-export function needsMoreRegulars(error: Error): boolean {
-  return (
-    error instanceof ApiError &&
-    error.code === 'invalid_settings' &&
-    error.message.startsWith(`${invalidHouseholdPrefix}onboarding_completed: `)
-  )
-}
-
 // aiStatus is the AI assistant row's status line: the provider and the
 // model's display name, or that no model is chosen yet (the seed).
 export function aiStatus(settings: Pick<AISettings, 'provider' | 'model'>): string {