Fix facet pills replacing body instead of self on HTMX update

Add hx_target="this" to the dsl_facet_pills container to prevent HTMX
from inheriting hx_target="body" from the parent wrapper. Without this,
clicking a facet pill would cause the facet refresh to replace the entire
body with just the pills HTML, breaking forms on pages like /actions/outcome.

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

flake.nix

@@ -61,6 +61,8 @@
         # Dev-only (not needed in Docker, but fine to include)
         pytest
         pytest-xdist
+        pytest-playwright
+        requests
         ruff
         filelock
       ]);
@@ -84,8 +86,13 @@
           pkgs.sqlite
           pkgs.skopeo  # For pushing Docker images
           pkgs.lefthook  # Git hooks manager
+          pkgs.playwright-driver  # Browser binaries for e2e tests
         ];
 
+        # Playwright browser configuration for NixOS
+        PLAYWRIGHT_BROWSERS_PATH = "${pkgs.playwright-driver.browsers}";
+        PLAYWRIGHT_SKIP_BROWSER_DOWNLOAD = "1";
+
         shellHook = ''
           export PYTHONPATH="$PWD/src:$PYTHONPATH"
           export PATH="$PWD/bin:$PATH"

lefthook.yml

@@ -12,4 +12,4 @@ pre-commit:
       run: ruff format --check src/ tests/
     pytest:
       glob: "**/*.py"
-      run: pytest tests/ -q --tb=short
+      run: pytest tests/ --ignore=tests/e2e -q --tb=short

pyproject.toml

@@ -28,6 +28,8 @@ dependencies = [
 dev = [
     "pytest>=7.4.0",
     "pytest-xdist>=3.5.0",
+    "pytest-playwright>=0.4.0",
+    "requests>=2.31.0",
     "ruff>=0.1.0",
     "filelock>=3.13.0",
 ]
@@ -56,3 +58,6 @@ python_files = "test_*.py"
 python_classes = "Test*"
 python_functions = "test_*"
 addopts = "--durations=20 -n auto"
+markers = [
+    "e2e: end-to-end browser tests (run with -n 0 to disable parallel execution)",
+]

src/animaltrack/web/app.py

@@ -204,11 +204,13 @@ def create_app(
     # Create FastHTML app with HTMX extensions, MonsterUI theme, and static path
     # Note: CsrfCookieMiddleware must come before StaticCacheMiddleware in the list
     # because Starlette applies middleware in reverse order (last in list wraps first)
+    # bodykw sets color-scheme: dark on body for native form controls (select dropdowns)
     app, rt = fast_app(
         before=beforeware,
         hdrs=(*Theme.slate.headers(daisy=True), htmx_config),  # Dark theme + daisyUI
         exts=["head-support", "preload"],
         static_path=static_path_for_fasthtml,
+        bodykw={"style": "color-scheme: dark"},
         middleware=[
             Middleware(CsrfCookieMiddleware, settings=settings),
             Middleware(StaticCacheMiddleware),

src/animaltrack/web/routes/actions.py

@@ -538,6 +538,9 @@ def tag_add_index(request: Request):
     roster_hash = ""
     animals = []
 
+    # Get animal repo for both resolution and facet counts
+    animal_repo = AnimalRepository(db)
+
     if filter_str:
         filter_ast = parse_filter(filter_str)
         resolution = resolve_filter(db, filter_ast, ts_utc)
@@ -546,9 +549,16 @@ def tag_add_index(request: Request):
         if resolved_ids:
             roster_hash = compute_roster_hash(resolved_ids, None)
             # Fetch animal details for checkbox display
-            animal_repo = AnimalRepository(db)
             animals = animal_repo.get_by_ids(resolved_ids)
 
+    # Get facet counts for alive animals
+    facet_filter = f"status:alive {filter_str}".strip() if filter_str else "status:alive"
+    facets = animal_repo.get_facet_counts(facet_filter)
+
+    # Get locations and species for facet name lookup
+    locations = LocationRepository(db).list_active()
+    species_list = SpeciesRepository(db).list_all()
+
     return render_page(
         request,
         tag_add_form(
@@ -558,6 +568,9 @@ def tag_add_index(request: Request):
             ts_utc=ts_utc,
             resolved_count=len(resolved_ids),
             animals=animals,
+            facets=facets,
+            locations=locations,
+            species_list=species_list,
         ),
         title="Add Tag - AnimalTrack",
         active_nav=None,
@@ -787,6 +800,9 @@ def tag_end_index(request: Request):
     active_tags: list[str] = []
     animals = []
 
+    # Get animal repo for both resolution and facet counts
+    animal_repo = AnimalRepository(db)
+
     if filter_str:
         filter_ast = parse_filter(filter_str)
         resolution = resolve_filter(db, filter_ast, ts_utc)
@@ -796,9 +812,16 @@ def tag_end_index(request: Request):
             roster_hash = compute_roster_hash(resolved_ids, None)
             active_tags = _get_active_tags_for_animals(db, resolved_ids)
             # Fetch animal details for checkbox display
-            animal_repo = AnimalRepository(db)
             animals = animal_repo.get_by_ids(resolved_ids)
 
+    # Get facet counts for alive animals
+    facet_filter = f"status:alive {filter_str}".strip() if filter_str else "status:alive"
+    facets = animal_repo.get_facet_counts(facet_filter)
+
+    # Get locations and species for facet name lookup
+    locations = LocationRepository(db).list_active()
+    species_list = SpeciesRepository(db).list_all()
+
     return render_page(
         request,
         tag_end_form(
@@ -809,6 +832,9 @@ def tag_end_index(request: Request):
             resolved_count=len(resolved_ids),
             active_tags=active_tags,
             animals=animals,
+            facets=facets,
+            locations=locations,
+            species_list=species_list,
         ),
         title="End Tag - AnimalTrack",
         active_nav=None,
@@ -1012,6 +1038,9 @@ def attrs_index(request: Request):
     roster_hash = ""
     animals = []
 
+    # Get animal repo for both resolution and facet counts
+    animal_repo = AnimalRepository(db)
+
     if filter_str:
         filter_ast = parse_filter(filter_str)
         resolution = resolve_filter(db, filter_ast, ts_utc)
@@ -1020,9 +1049,16 @@ def attrs_index(request: Request):
         if resolved_ids:
             roster_hash = compute_roster_hash(resolved_ids, None)
             # Fetch animal details for checkbox display
-            animal_repo = AnimalRepository(db)
             animals = animal_repo.get_by_ids(resolved_ids)
 
+    # Get facet counts for alive animals
+    facet_filter = f"status:alive {filter_str}".strip() if filter_str else "status:alive"
+    facets = animal_repo.get_facet_counts(facet_filter)
+
+    # Get locations and species for facet name lookup
+    locations = LocationRepository(db).list_active()
+    species_list = SpeciesRepository(db).list_all()
+
     return render_page(
         request,
         attrs_form(
@@ -1032,6 +1068,9 @@ def attrs_index(request: Request):
             ts_utc=ts_utc,
             resolved_count=len(resolved_ids),
             animals=animals,
+            facets=facets,
+            locations=locations,
+            species_list=species_list,
         ),
         title="Update Attributes - AnimalTrack",
         active_nav=None,
@@ -1247,6 +1286,9 @@ def outcome_index(request: Request):
     roster_hash = ""
     animals = []
 
+    # Get animal repo for both resolution and facet counts
+    animal_repo = AnimalRepository(db)
+
     if filter_str:
         filter_ast = parse_filter(filter_str)
         resolution = resolve_filter(db, filter_ast, ts_utc)
@@ -1255,13 +1297,20 @@ def outcome_index(request: Request):
         if resolved_ids:
             roster_hash = compute_roster_hash(resolved_ids, None)
             # Fetch animal details for checkbox display
-            animal_repo = AnimalRepository(db)
             animals = animal_repo.get_by_ids(resolved_ids)
 
     # Get active products for yield items dropdown
     product_repo = ProductRepository(db)
     products = [(p.code, p.name) for p in product_repo.list_all() if p.active]
 
+    # Get facet counts for alive animals
+    facet_filter = f"status:alive {filter_str}".strip() if filter_str else "status:alive"
+    facets = animal_repo.get_facet_counts(facet_filter)
+
+    # Get locations and species for facet name lookup
+    locations = LocationRepository(db).list_active()
+    species_list = SpeciesRepository(db).list_all()
+
     return render_page(
         request,
         outcome_form(
@@ -1272,6 +1321,9 @@ def outcome_index(request: Request):
             resolved_count=len(resolved_ids),
             products=products,
             animals=animals,
+            facets=facets,
+            locations=locations,
+            species_list=species_list,
         ),
         title="Record Outcome - AnimalTrack",
         active_nav=None,
@@ -1544,6 +1596,9 @@ async def status_correct_index(req: Request):
     resolved_ids: list[str] = []
     roster_hash = ""
 
+    # Get animal repo for facet counts
+    animal_repo = AnimalRepository(db)
+
     if filter_str:
         filter_ast = parse_filter(filter_str)
         resolution = resolve_filter(db, filter_ast, ts_utc)
@@ -1552,6 +1607,13 @@ async def status_correct_index(req: Request):
         if resolved_ids:
             roster_hash = compute_roster_hash(resolved_ids, None)
 
+    # Get facet counts (show all statuses for admin correction form)
+    facets = animal_repo.get_facet_counts(filter_str)
+
+    # Get locations and species for facet name lookup
+    locations = LocationRepository(db).list_active()
+    species_list = SpeciesRepository(db).list_all()
+
     return render_page(
         req,
         status_correct_form(
@@ -1560,6 +1622,9 @@ async def status_correct_index(req: Request):
             roster_hash=roster_hash,
             ts_utc=ts_utc,
             resolved_count=len(resolved_ids),
+            facets=facets,
+            locations=locations,
+            species_list=species_list,
         ),
         title="Correct Status - AnimalTrack",
         active_nav=None,

src/animaltrack/web/routes/api.py

@@ -1,17 +1,20 @@
 # ABOUTME: API routes for HTMX partial updates.
-# ABOUTME: Provides endpoints for selection preview and hash computation.
+# ABOUTME: Provides endpoints for selection preview, hash computation, and dynamic facets.
 
 from __future__ import annotations
 
 import time
 
-from fasthtml.common import APIRouter
+from fasthtml.common import APIRouter, to_xml
 from starlette.requests import Request
 from starlette.responses import HTMLResponse, JSONResponse
 
 from animaltrack.repositories.animals import AnimalRepository
+from animaltrack.repositories.locations import LocationRepository
+from animaltrack.repositories.species import SpeciesRepository
 from animaltrack.selection import compute_roster_hash, parse_filter, resolve_filter
 from animaltrack.web.templates.animal_select import animal_checkbox_list
+from animaltrack.web.templates.dsl_facets import dsl_facet_pills
 
 # APIRouter for multi-file route organization
 ar = APIRouter()
@@ -97,3 +100,49 @@ def selection_preview(request: Request):
 
     # Render checkbox list for multiple animals
     return HTMLResponse(content=to_xml(animal_checkbox_list(animals, selected_ids)))
+
+
+@ar("/api/facets")
+def facets(request: Request):
+    """GET /api/facets - Get facet pills HTML for current filter.
+
+    Query params:
+        - filter: DSL filter string (optional)
+        - include_status: "true" to include status facet (for registry)
+
+    Returns HTML partial with facet pills for HTMX outerHTML swap.
+    The returned HTML has id="dsl-facet-pills" for proper swap targeting.
+    """
+    db = request.app.state.db
+    filter_str = request.query_params.get("filter", "")
+    include_status = request.query_params.get("include_status", "").lower() == "true"
+
+    # Get facet counts based on current filter
+    animal_repo = AnimalRepository(db)
+
+    if include_status:
+        # Registry mode: show all statuses, no implicit alive filter
+        facet_filter = filter_str
+    else:
+        # Action form mode: filter to alive animals
+        if filter_str:
+            # If filter already includes status, use it as-is
+            # Otherwise, implicitly filter to alive animals
+            if "status:" in filter_str:
+                facet_filter = filter_str
+            else:
+                facet_filter = f"status:alive {filter_str}".strip()
+        else:
+            facet_filter = "status:alive"
+
+    facets = animal_repo.get_facet_counts(facet_filter)
+
+    # Get locations and species for name mapping
+    location_repo = LocationRepository(db)
+    species_repo = SpeciesRepository(db)
+    locations = location_repo.list_all()
+    species_list = species_repo.list_all()
+
+    # Render facet pills - filter input ID is "filter" by convention
+    result = dsl_facet_pills(facets, "filter", locations, species_list, include_status)
+    return HTMLResponse(content=to_xml(result))

src/animaltrack/web/routes/eggs.py

@@ -547,7 +547,7 @@ async def product_sold(request: Request, session):
     # Extract form data
     product_code = form.get("product_code", "")
     quantity_str = form.get("quantity", "0")
-    total_price_str = form.get("total_price_cents", "0")
+    total_price_str = form.get("total_price_euros", "0")
     buyer = form.get("buyer") or None
     notes = form.get("notes") or None
     nonce = form.get("nonce")
@@ -566,7 +566,7 @@ async def product_sold(request: Request, session):
             None,
             "Please select a product",
             quantity=quantity_str,
-            total_price_cents=total_price_str,
+            total_price_euros=total_price_str,
             buyer=buyer,
             notes=notes,
         )
@@ -583,7 +583,7 @@ async def product_sold(request: Request, session):
             product_code,
             "Quantity must be a number",
             quantity=quantity_str,
-            total_price_cents=total_price_str,
+            total_price_euros=total_price_str,
             buyer=buyer,
             notes=notes,
         )
@@ -597,14 +597,15 @@ async def product_sold(request: Request, session):
             product_code,
             "Quantity must be at least 1",
             quantity=quantity_str,
-            total_price_cents=total_price_str,
+            total_price_euros=total_price_str,
             buyer=buyer,
             notes=notes,
         )
 
-    # Validate total_price_cents
+    # Validate total_price_euros and convert to cents
     try:
-        total_price_cents = int(total_price_str)
+        total_price_euros = float(total_price_str)
+        total_price_cents = int(round(total_price_euros * 100))
     except ValueError:
         return _render_sell_error(
             request,
@@ -614,7 +615,7 @@ async def product_sold(request: Request, session):
             product_code,
             "Total price must be a number",
             quantity=quantity_str,
-            total_price_cents=total_price_str,
+            total_price_euros=total_price_str,
             buyer=buyer,
             notes=notes,
         )
@@ -628,7 +629,7 @@ async def product_sold(request: Request, session):
             product_code,
             "Total price cannot be negative",
             quantity=quantity_str,
-            total_price_cents=total_price_str,
+            total_price_euros=total_price_str,
             buyer=buyer,
             notes=notes,
         )
@@ -671,7 +672,7 @@ async def product_sold(request: Request, session):
             product_code,
             str(e),
             quantity=quantity_str,
-            total_price_cents=total_price_str,
+            total_price_euros=total_price_str,
             buyer=buyer,
             notes=notes,
         )
@@ -763,7 +764,7 @@ def _render_sell_error(
     selected_product_code,
     error_message,
     quantity: str | None = None,
-    total_price_cents: str | None = None,
+    total_price_euros: str | None = None,
     buyer: str | None = None,
     notes: str | None = None,
 ):
@@ -777,7 +778,7 @@ def _render_sell_error(
         selected_product_code: Currently selected product code.
         error_message: Error message to display.
         quantity: Quantity value to preserve.
-        total_price_cents: Total price value to preserve.
+        total_price_euros: Total price value to preserve.
         buyer: Buyer value to preserve.
         notes: Notes value to preserve.
 
@@ -798,7 +799,7 @@ def _render_sell_error(
                     harvest_action=product_collected,
                     sell_action=product_sold,
                     sell_quantity=quantity,
-                    sell_total_price_cents=total_price_cents,
+                    sell_total_price_euros=total_price_euros,
                     sell_buyer=buyer,
                     sell_notes=notes,
                     **display_data,

src/animaltrack/web/routes/move.py

@@ -20,6 +20,7 @@ from animaltrack.projections.event_animals import EventAnimalsProjection
 from animaltrack.projections.intervals import IntervalProjection
 from animaltrack.repositories.animals import AnimalRepository
 from animaltrack.repositories.locations import LocationRepository
+from animaltrack.repositories.species import SpeciesRepository
 from animaltrack.selection import compute_roster_hash, parse_filter, resolve_filter
 from animaltrack.selection.validation import SelectionContext, validate_selection
 from animaltrack.services.animal import AnimalService, ValidationError
@@ -192,6 +193,9 @@ def move_index(request: Request):
     from_location_name = None
     animals = []
 
+    # Get animal repo for both filter resolution and facet counts
+    animal_repo = AnimalRepository(db)
+
     if filter_str or not request.query_params:
         # If no filter, default to empty (show all alive animals)
         filter_ast = parse_filter(filter_str)
@@ -202,9 +206,15 @@ def move_index(request: Request):
             from_location_id, from_location_name = _get_from_location(db, resolved_ids, ts_utc)
             roster_hash = compute_roster_hash(resolved_ids, from_location_id)
             # Fetch animal details for checkbox display
-            animal_repo = AnimalRepository(db)
             animals = animal_repo.get_by_ids(resolved_ids)
 
+    # Get facet counts for alive animals (action forms filter to alive by default)
+    facet_filter = f"status:alive {filter_str}".strip() if filter_str else "status:alive"
+    facets = animal_repo.get_facet_counts(facet_filter)
+
+    # Get species list for facet name lookup
+    species_list = SpeciesRepository(db).list_all()
+
     # Get recent events and stats
     display_data = _get_move_display_data(db, locations)
 
@@ -221,6 +231,8 @@ def move_index(request: Request):
             from_location_name=from_location_name,
             action=animal_move,
             animals=animals,
+            facets=facets,
+            species_list=species_list,
             **display_data,
         ),
         title="Move - AnimalTrack",

src/animaltrack/web/routes/products.py

@@ -1,47 +1,19 @@
 # ABOUTME: Routes for Product Sold functionality.
-# ABOUTME: Handles GET /sell form and POST /actions/product-sold.
+# ABOUTME: Redirects GET /sell to Eggs page Sell tab. POST handled by eggs.py.
 
 from __future__ import annotations
 
-import json
-import time
-
-from fasthtml.common import APIRouter, to_xml
+from fasthtml.common import APIRouter
 from starlette.requests import Request
-from starlette.responses import HTMLResponse
-
-from animaltrack.events.payloads import ProductSoldPayload
-from animaltrack.events.store import EventStore
-from animaltrack.projections import EventLogProjection, ProjectionRegistry
-from animaltrack.projections.products import ProductsProjection
-from animaltrack.repositories.products import ProductRepository
-from animaltrack.services.products import ProductService, ValidationError
-from animaltrack.web.templates import render_page
-from animaltrack.web.templates.products import product_sold_form
+from starlette.responses import RedirectResponse
 
 # APIRouter for multi-file route organization
 ar = APIRouter()
 
 
-def _get_sellable_products(db):
-    """Get list of active, sellable products.
-
-    Args:
-        db: Database connection.
-
-    Returns:
-        List of sellable Product objects.
-    """
-    repo = ProductRepository(db)
-    all_products = repo.list_all()
-    return [p for p in all_products if p.active and p.sellable]
-
-
 @ar("/sell")
 def sell_index(request: Request):
     """GET /sell - Redirect to Eggs page Sell tab."""
-    from starlette.responses import RedirectResponse
-
     # Preserve product_code if provided
     product_code = request.query_params.get("product_code")
     redirect_url = "/?tab=sell"
@@ -49,130 +21,3 @@ def sell_index(request: Request):
         redirect_url = f"/?tab=sell&product_code={product_code}"
 
     return RedirectResponse(url=redirect_url, status_code=302)
-
-
-@ar("/actions/product-sold", methods=["POST"])
-async def product_sold(request: Request):
-    """POST /actions/product-sold - Record product sale."""
-    db = request.app.state.db
-    form = await request.form()
-
-    # Extract form data
-    product_code = form.get("product_code", "")
-    quantity_str = form.get("quantity", "0")
-    total_price_str = form.get("total_price_cents", "0")
-    buyer = form.get("buyer") or None
-    notes = form.get("notes") or None
-    nonce = form.get("nonce")
-
-    # Get products for potential re-render
-    products = _get_sellable_products(db)
-
-    # Validate product_code
-    if not product_code:
-        return _render_error_form(request, products, None, "Please select a product")
-
-    # Validate quantity
-    try:
-        quantity = int(quantity_str)
-    except ValueError:
-        return _render_error_form(request, products, product_code, "Quantity must be a number")
-
-    if quantity < 1:
-        return _render_error_form(request, products, product_code, "Quantity must be at least 1")
-
-    # Validate total_price_cents
-    try:
-        total_price_cents = int(total_price_str)
-    except ValueError:
-        return _render_error_form(request, products, product_code, "Total price must be a number")
-
-    if total_price_cents < 0:
-        return _render_error_form(request, products, product_code, "Total price cannot be negative")
-
-    # Get current timestamp
-    ts_utc = int(time.time() * 1000)
-
-    # Create product service
-    event_store = EventStore(db)
-    registry = ProjectionRegistry()
-    registry.register(ProductsProjection(db))
-    registry.register(EventLogProjection(db))
-
-    product_service = ProductService(db, event_store, registry)
-
-    # Create payload
-    payload = ProductSoldPayload(
-        product_code=product_code,
-        quantity=quantity,
-        total_price_cents=total_price_cents,
-        buyer=buyer,
-        notes=notes,
-    )
-
-    # Get actor from auth
-    auth = request.scope.get("auth")
-    actor = auth.username if auth else "unknown"
-
-    # Sell product
-    try:
-        product_service.sell_product(
-            payload=payload,
-            ts_utc=ts_utc,
-            actor=actor,
-            nonce=nonce,
-            route="/actions/product-sold",
-        )
-    except ValidationError as e:
-        return _render_error_form(request, products, product_code, str(e))
-
-    # Success: re-render form with product sticking, other fields cleared
-    response = HTMLResponse(
-        content=to_xml(
-            render_page(
-                request,
-                product_sold_form(
-                    products, selected_product_code=product_code, action=product_sold
-                ),
-                title="Sell - AnimalTrack",
-                active_nav=None,
-            )
-        ),
-    )
-
-    # Add toast trigger header
-    response.headers["HX-Trigger"] = json.dumps(
-        {"showToast": {"message": f"Recorded sale of {quantity} {product_code}", "type": "success"}}
-    )
-
-    return response
-
-
-def _render_error_form(request, products, selected_product_code, error_message):
-    """Render form with error message.
-
-    Args:
-        request: The Starlette request object.
-        products: List of sellable products.
-        selected_product_code: Currently selected product code.
-        error_message: Error message to display.
-
-    Returns:
-        HTMLResponse with 422 status.
-    """
-    return HTMLResponse(
-        content=to_xml(
-            render_page(
-                request,
-                product_sold_form(
-                    products,
-                    selected_product_code=selected_product_code,
-                    error=error_message,
-                    action=product_sold,
-                ),
-                title="Sell - AnimalTrack",
-                active_nav=None,
-            )
-        ),
-        status_code=422,
-    )

src/animaltrack/web/templates/actions.py

@@ -18,8 +18,10 @@ from ulid import ULID
 
 from animaltrack.models.animals import Animal
 from animaltrack.models.reference import Location, Species
+from animaltrack.repositories.animals import FacetCounts
 from animaltrack.selection.validation import SelectionDiff
 from animaltrack.web.templates.action_bar import ActionBar
+from animaltrack.web.templates.dsl_facets import dsl_facet_pills, dsl_facet_pills_script
 
 # =============================================================================
 # Selection Diff Confirmation Panel
@@ -622,7 +624,10 @@ def tag_add_form(
     error: str | None = None,
     action: Callable[..., Any] | str = "/actions/animal-tag-add",
     animals: list | None = None,
-) -> Form:
+    facets: FacetCounts | None = None,
+    locations: list[Location] | None = None,
+    species_list: list[Species] | None = None,
+) -> Div:
     """Create the Add Tag form.
 
     Args:
@@ -634,9 +639,12 @@ def tag_add_form(
         error: Optional error message to display.
         action: Route function or URL string for form submission.
         animals: List of AnimalListItem for checkbox selection (optional).
+        facets: Optional FacetCounts for facet pills display.
+        locations: Optional list of Locations for facet name lookup.
+        species_list: Optional list of Species for facet name lookup.
 
     Returns:
-        Form component for adding tags to animals.
+        Div component containing facet script and form.
     """
     from animaltrack.web.templates.animal_select import animal_checkbox_list
 
@@ -686,10 +694,19 @@ def tag_add_form(
         Hidden(name="resolved_ids", value=animal_id) for animal_id in resolved_ids
     ]
 
-    return Form(
+    # Build facet pills component if facets provided
+    facet_pills_component = None
+    facet_script = None
+    if facets:
+        facet_pills_component = dsl_facet_pills(facets, "filter", locations, species_list)
+        facet_script = dsl_facet_pills_script("filter")
+
+    form = Form(
         H2("Add Tag", cls="text-xl font-bold mb-4"),
         # Error message if present
         error_component,
+        # Facet pills for easy filter composition (tap to add filter terms)
+        facet_pills_component,
         # Filter input with HTMX to fetch selection preview
         LabelInput(
             "Filter",
@@ -735,6 +752,8 @@ def tag_add_form(
         cls="space-y-4",
     )
 
+    return Div(facet_script, form)
+
 
 def tag_add_diff_panel(
     diff: SelectionDiff,
@@ -788,7 +807,10 @@ def tag_end_form(
     error: str | None = None,
     action: Callable[..., Any] | str = "/actions/animal-tag-end",
     animals: list | None = None,
-) -> Form:
+    facets: FacetCounts | None = None,
+    locations: list[Location] | None = None,
+    species_list: list[Species] | None = None,
+) -> Div:
     """Create the End Tag form.
 
     Args:
@@ -801,9 +823,12 @@ def tag_end_form(
         error: Optional error message to display.
         action: Route function or URL string for form submission.
         animals: List of AnimalListItem for checkbox selection (optional).
+        facets: Optional FacetCounts for facet pills display.
+        locations: Optional list of Locations for facet name lookup.
+        species_list: Optional list of Species for facet name lookup.
 
     Returns:
-        Form component for ending tags on animals.
+        Div component containing facet script and form.
     """
     from animaltrack.web.templates.animal_select import animal_checkbox_list
 
@@ -860,10 +885,19 @@ def tag_end_form(
         Hidden(name="resolved_ids", value=animal_id) for animal_id in resolved_ids
     ]
 
-    return Form(
+    # Build facet pills component if facets provided
+    facet_pills_component = None
+    facet_script = None
+    if facets:
+        facet_pills_component = dsl_facet_pills(facets, "filter", locations, species_list)
+        facet_script = dsl_facet_pills_script("filter")
+
+    form = Form(
         H2("End Tag", cls="text-xl font-bold mb-4"),
         # Error message if present
         error_component,
+        # Facet pills for easy filter composition (tap to add filter terms)
+        facet_pills_component,
         # Filter input with HTMX to fetch selection preview
         LabelInput(
             "Filter",
@@ -919,6 +953,8 @@ def tag_end_form(
         cls="space-y-4",
     )
 
+    return Div(facet_script, form)
+
 
 def tag_end_diff_panel(
     diff: SelectionDiff,
@@ -971,7 +1007,10 @@ def attrs_form(
     error: str | None = None,
     action: Callable[..., Any] | str = "/actions/animal-attrs",
     animals: list | None = None,
-) -> Form:
+    facets: FacetCounts | None = None,
+    locations: list[Location] | None = None,
+    species_list: list[Species] | None = None,
+) -> Div:
     """Create the Update Attributes form.
 
     Args:
@@ -983,9 +1022,12 @@ def attrs_form(
         error: Optional error message to display.
         action: Route function or URL string for form submission.
         animals: List of AnimalListItem for checkbox selection (optional).
+        facets: Optional FacetCounts for facet pills display.
+        locations: Optional list of Locations for facet name lookup.
+        species_list: Optional list of Species for facet name lookup.
 
     Returns:
-        Form component for updating animal attributes.
+        Div component containing facet script and form.
     """
     from animaltrack.web.templates.animal_select import animal_checkbox_list
 
@@ -1063,10 +1105,19 @@ def attrs_form(
         Hidden(name="resolved_ids", value=animal_id) for animal_id in resolved_ids
     ]
 
-    return Form(
+    # Build facet pills component if facets provided
+    facet_pills_component = None
+    facet_script = None
+    if facets:
+        facet_pills_component = dsl_facet_pills(facets, "filter", locations, species_list)
+        facet_script = dsl_facet_pills_script("filter")
+
+    form = Form(
         H2("Update Attributes", cls="text-xl font-bold mb-4"),
         # Error message if present
         error_component,
+        # Facet pills for easy filter composition (tap to add filter terms)
+        facet_pills_component,
         # Filter input with HTMX to fetch selection preview
         LabelInput(
             "Filter",
@@ -1121,6 +1172,8 @@ def attrs_form(
         cls="space-y-4",
     )
 
+    return Div(facet_script, form)
+
 
 def attrs_diff_panel(
     diff: SelectionDiff,
@@ -1182,7 +1235,10 @@ def outcome_form(
     error: str | None = None,
     action: Callable[..., Any] | str = "/actions/animal-outcome",
     animals: list | None = None,
-) -> Form:
+    facets: FacetCounts | None = None,
+    locations: list[Location] | None = None,
+    species_list: list[Species] | None = None,
+) -> Div:
     """Create the Record Outcome form.
 
     Args:
@@ -1195,9 +1251,12 @@ def outcome_form(
         error: Optional error message to display.
         action: Route function or URL string for form submission.
         animals: List of AnimalListItem for checkbox selection (optional).
+        facets: Optional FacetCounts for facet pills display.
+        locations: Optional list of Locations for facet name lookup.
+        species_list: Optional list of Species for facet name lookup.
 
     Returns:
-        Form component for recording animal outcomes.
+        Div component containing facet script and form.
     """
     from animaltrack.web.templates.animal_select import animal_checkbox_list
 
@@ -1320,9 +1379,18 @@ def outcome_form(
         cls="p-3 bg-slate-100 dark:bg-slate-800 rounded-md space-y-3",
     )
 
-    return Form(
+    # Build facet pills component if facets provided
+    facet_pills_component = None
+    facet_script = None
+    if facets:
+        facet_pills_component = dsl_facet_pills(facets, "filter", locations, species_list)
+        facet_script = dsl_facet_pills_script("filter")
+
+    form = Form(
         H2("Record Outcome", cls="text-xl font-bold mb-4"),
         error_component,
+        # Facet pills for easy filter composition (tap to add filter terms)
+        facet_pills_component,
         # Filter field with HTMX to fetch selection preview
         LabelInput(
             label="Filter (DSL)",
@@ -1379,6 +1447,8 @@ def outcome_form(
         cls="space-y-4",
     )
 
+    return Div(facet_script, form)
+
 
 def outcome_diff_panel(
     diff: SelectionDiff,
@@ -1448,7 +1518,10 @@ def status_correct_form(
     resolved_count: int = 0,
     error: str | None = None,
     action: Callable[..., Any] | str = "/actions/animal-status-correct",
-) -> Form:
+    facets: FacetCounts | None = None,
+    locations: list[Location] | None = None,
+    species_list: list[Species] | None = None,
+) -> Div:
     """Create the Correct Status form (admin-only).
 
     Args:
@@ -1459,9 +1532,12 @@ def status_correct_form(
         resolved_count: Number of resolved animals.
         error: Optional error message to display.
         action: Route function or URL string for form submission.
+        facets: Optional FacetCounts for facet pills display.
+        locations: Optional list of Locations for facet name lookup.
+        species_list: Optional list of Species for facet name lookup.
 
     Returns:
-        Form component for correcting animal status.
+        Div component containing facet script and form.
     """
     if resolved_ids is None:
         resolved_ids = []
@@ -1508,11 +1584,19 @@ def status_correct_form(
         Hidden(name="resolved_ids", value=animal_id) for animal_id in resolved_ids
     ]
 
-    return Form(
+    # Build facet pills component if facets provided
+    facet_pills_component = None
+    facet_script = None
+    if facets:
+        facet_pills_component = dsl_facet_pills(facets, "filter", locations, species_list)
+        facet_script = dsl_facet_pills_script("filter")
+
+    form = Form(
         H2("Correct Animal Status", cls="text-xl font-bold mb-4"),
         admin_warning,
         error_component,
-        selection_preview,
+        # Facet pills for easy filter composition (tap to add filter terms)
+        facet_pills_component,
         # Filter field
         LabelInput(
             label="Filter (DSL)",
@@ -1521,6 +1605,7 @@ def status_correct_form(
             value=filter_str,
             placeholder="e.g., species:duck location:Coop1",
         ),
+        selection_preview,
         # New status selection - using raw Select due to MonsterUI LabelSelect value bug
         Div(
             FormLabel("New Status", _for="new_status"),
@@ -1564,6 +1649,8 @@ def status_correct_form(
         cls="space-y-4",
     )
 
+    return Div(facet_script, form)
+
 
 def status_correct_diff_panel(
     diff: SelectionDiff,

src/animaltrack/web/templates/base.py

@@ -39,6 +39,12 @@ def SelectStyles():  # noqa: N802
             color: #e5e5e5 !important;
             -webkit-text-fill-color: #e5e5e5 !important;
         }
+        /* Tell browser to use native dark mode for select dropdown options.
+           This makes <option> elements readable with light text on dark background.
+           CSS styling of <option> is limited by browsers, so color-scheme is the fix. */
+        select, .uk-select {
+            color-scheme: dark;
+        }
         /* Placeholder text styling */
         input::placeholder, textarea::placeholder,
         .uk-input::placeholder, .uk-textarea::placeholder {
@@ -46,7 +52,7 @@ def SelectStyles():  # noqa: N802
             -webkit-text-fill-color: #737373 !important;
             opacity: 1;
         }
-        /* Select dropdown options */
+        /* Select dropdown options - fallback for browsers that support it */
         select option, .uk-select option {
             background-color: #1c1c1c;
             color: #e5e5e5;

src/animaltrack/web/templates/dsl_facets.py

@@ -0,0 +1,170 @@
+# ABOUTME: Reusable DSL facet pills component for filter composition.
+# ABOUTME: Provides clickable pills that compose DSL filter expressions via JavaScript and HTMX.
+
+from typing import Any
+
+from fasthtml.common import Div, P, Script, Span
+
+from animaltrack.models.reference import Location, Species
+from animaltrack.repositories.animals import FacetCounts
+
+
+def dsl_facet_pills(
+    facets: FacetCounts,
+    filter_input_id: str,
+    locations: list[Location] | None,
+    species_list: list[Species] | None,
+    include_status: bool = False,
+) -> Div:
+    """Render clickable facet pills that compose DSL filter expressions.
+
+    This component displays pills for species, sex, life_stage, and location facets.
+    Clicking a pill appends the corresponding field:value to the filter input and
+    triggers HTMX updates for both the selection preview and the facet counts.
+
+    Args:
+        facets: FacetCounts with by_species, by_sex, by_life_stage, by_location dicts.
+        filter_input_id: ID of the filter input element (e.g., "filter").
+        locations: List of Location objects for name lookup.
+        species_list: List of Species objects for name lookup.
+        include_status: If True, include status facet section (for registry).
+            Defaults to False (action forms filter to alive by default).
+
+    Returns:
+        Div component containing facet pill sections with HTMX attributes.
+    """
+    location_map = {loc.id: loc.name for loc in (locations or [])}
+    species_map = {s.code: s.name for s in (species_list or [])}
+
+    # Build facet sections
+    sections = []
+
+    # Status facet (optional - registry shows all statuses, action forms skip)
+    if include_status:
+        sections.append(facet_pill_section("Status", facets.by_status, filter_input_id, "status"))
+
+    sections.extend(
+        [
+            facet_pill_section(
+                "Species", facets.by_species, filter_input_id, "species", species_map
+            ),
+            facet_pill_section("Sex", facets.by_sex, filter_input_id, "sex"),
+            facet_pill_section("Life Stage", facets.by_life_stage, filter_input_id, "life_stage"),
+            facet_pill_section(
+                "Location", facets.by_location, filter_input_id, "location", location_map
+            ),
+        ]
+    )
+
+    # Filter out None sections (empty facets)
+    sections = [s for s in sections if s is not None]
+
+    # Build HTMX URL with include_status param if needed
+    htmx_url = "/api/facets"
+    if include_status:
+        htmx_url = "/api/facets?include_status=true"
+
+    return Div(
+        *sections,
+        id="dsl-facet-pills",
+        # HTMX: Refresh facets when filter input changes (600ms after change)
+        hx_get=htmx_url,
+        hx_trigger=f"change from:#{filter_input_id} delay:600ms",
+        hx_include=f"#{filter_input_id}",
+        hx_target="this",
+        hx_swap="outerHTML",
+        cls="space-y-3 mb-4",
+    )
+
+
+def facet_pill_section(
+    title: str,
+    counts: dict[str, int],
+    filter_input_id: str,
+    field: str,
+    label_map: dict[str, str] | None = None,
+) -> Any:
+    """Single facet section with clickable pills.
+
+    Args:
+        title: Section title (e.g., "Species", "Sex").
+        counts: Dictionary of value -> count.
+        filter_input_id: ID of the filter input element.
+        field: Field name for DSL filter (e.g., "species", "sex").
+        label_map: Optional mapping from value to display label.
+
+    Returns:
+        Div component with facet pills, or None if counts is empty.
+    """
+    if not counts:
+        return None
+
+    # Build inline pill items, sorted by count descending
+    items = []
+    for value, count in sorted(counts.items(), key=lambda x: -x[1]):
+        # Get display label
+        label = label_map.get(value, value) if label_map else value.replace("_", " ").title()
+
+        # Build pill with data attributes and onclick handler
+        items.append(
+            Span(
+                Span(label, cls="text-xs"),
+                Span(str(count), cls="text-xs text-stone-500 ml-1"),
+                data_facet_field=field,
+                data_facet_value=value,
+                onclick=f"addFacetToFilter('{filter_input_id}', '{field}', '{value}')",
+                cls="inline-flex items-center px-2 py-1 rounded bg-stone-800 "
+                "hover:bg-stone-700 cursor-pointer mr-1 mb-1",
+            )
+        )
+
+    return Div(
+        P(title, cls="font-semibold text-xs text-stone-400 mb-2"),
+        Div(
+            *items,
+            cls="flex flex-wrap",
+        ),
+    )
+
+
+def dsl_facet_pills_script(filter_input_id: str) -> Script:
+    """JavaScript for facet pill click handling.
+
+    Provides the addFacetToFilter function that:
+    1. Appends field:value to the filter input
+    2. Triggers a change event to refresh selection preview and facet counts
+
+    Args:
+        filter_input_id: ID of the filter input element.
+
+    Returns:
+        Script element with the facet interaction JavaScript.
+    """
+    return Script("""
+    // Add a facet filter term to the filter input
+    function addFacetToFilter(inputId, field, value) {
+        var input = document.getElementById(inputId);
+        if (!input) return;
+
+        var currentFilter = input.value.trim();
+        var newTerm = field + ':' + value;
+
+        // Check if value contains spaces and needs quoting
+        if (value.indexOf(' ') !== -1) {
+            newTerm = field + ':"' + value + '"';
+        }
+
+        // Append to filter (space-separated)
+        if (currentFilter) {
+            input.value = currentFilter + ' ' + newTerm;
+        } else {
+            input.value = newTerm;
+        }
+
+        // Trigger change event for HTMX updates
+        input.dispatchEvent(new Event('change', { bubbles: true }));
+
+        // Also trigger input event for any other listeners
+        input.dispatchEvent(new Event('input', { bubbles: true }));
+    }
+    """)

src/animaltrack/web/templates/eggs.py

@@ -44,7 +44,7 @@ def eggs_page(
     harvest_quantity: str | None = None,
     harvest_notes: str | None = None,
     sell_quantity: str | None = None,
-    sell_total_price_cents: str | None = None,
+    sell_total_price_euros: str | None = None,
     sell_buyer: str | None = None,
     sell_notes: str | None = None,
 ):
@@ -71,7 +71,7 @@ def eggs_page(
         harvest_quantity: Preserved quantity value on error.
         harvest_notes: Preserved notes value on error.
         sell_quantity: Preserved quantity value on error.
-        sell_total_price_cents: Preserved total price value on error.
+        sell_total_price_euros: Preserved total price value on error.
         sell_buyer: Preserved buyer value on error.
         sell_notes: Preserved notes value on error.
 
@@ -119,7 +119,7 @@ def eggs_page(
                     recent_events=sell_events,
                     sales_stats=sales_stats,
                     default_quantity=sell_quantity,
-                    default_total_price_cents=sell_total_price_cents,
+                    default_total_price_euros=sell_total_price_euros,
                     default_buyer=sell_buyer,
                     default_notes=sell_notes,
                 ),
@@ -270,7 +270,7 @@ def sell_form(
     recent_events: list[tuple[Event, bool]] | None = None,
     sales_stats: dict | None = None,
     default_quantity: str | None = None,
-    default_total_price_cents: str | None = None,
+    default_total_price_euros: str | None = None,
     default_buyer: str | None = None,
     default_notes: str | None = None,
 ) -> Div:
@@ -284,7 +284,7 @@ def sell_form(
         recent_events: Recent (Event, is_deleted) tuples, most recent first.
         sales_stats: Dict with 'total_qty' and 'total_cents' for 30-day sales.
         default_quantity: Preserved quantity value on error.
-        default_total_price_cents: Preserved total price value on error.
+        default_total_price_euros: Preserved total price value on error.
         default_buyer: Preserved buyer value on error.
         default_notes: Preserved notes value on error.
 
@@ -363,17 +363,17 @@ def sell_form(
             required=True,
             value=default_quantity or "",
         ),
-        # Total price in cents
+        # Total price in euros
         LabelInput(
-            "Total Price (cents)",
-            id="total_price_cents",
-            name="total_price_cents",
+            "Total Price (€)",
+            id="total_price_euros",
+            name="total_price_euros",
             type="number",
             min="0",
-            step="1",
-            placeholder="Total price in cents",
+            step="0.01",
+            placeholder="e.g., 12.50",
             required=True,
-            value=default_total_price_cents or "",
+            value=default_total_price_euros or "",
         ),
         # Optional buyer
         LabelInput(

src/animaltrack/web/templates/move.py

@@ -9,10 +9,12 @@ from monsterui.all import Alert, AlertT, Button, ButtonT, FormLabel, LabelInput,
 from ulid import ULID
 
 from animaltrack.models.events import Event
-from animaltrack.models.reference import Location
+from animaltrack.models.reference import Location, Species
+from animaltrack.repositories.animals import FacetCounts
 from animaltrack.selection.validation import SelectionDiff
 from animaltrack.web.templates.action_bar import ActionBar
 from animaltrack.web.templates.actions import event_datetime_field
+from animaltrack.web.templates.dsl_facets import dsl_facet_pills, dsl_facet_pills_script
 from animaltrack.web.templates.recent_events import recent_events_section
 
 
@@ -31,6 +33,8 @@ def move_form(
     recent_events: list[tuple[Event, bool]] | None = None,
     days_since_last_move: int | None = None,
     location_names: dict[str, str] | None = None,
+    facets: FacetCounts | None = None,
+    species_list: list[Species] | None = None,
 ) -> Div:
     """Create the Move Animals form.
 
@@ -49,6 +53,8 @@ def move_form(
         recent_events: Recent (Event, is_deleted) tuples, most recent first.
         days_since_last_move: Number of days since the last move event.
         location_names: Dict mapping location_id to location name.
+        facets: Optional FacetCounts for facet pills display.
+        species_list: Optional list of Species for facet name lookup.
 
     Returns:
         Div containing form and recent events section.
@@ -134,10 +140,19 @@ def move_form(
         else:
             stat_text = f"Last move: {days_since_last_move} days ago"
 
+    # Build facet pills component if facets provided
+    facet_pills_component = None
+    facet_script = None
+    if facets:
+        facet_pills_component = dsl_facet_pills(facets, "filter", locations, species_list)
+        facet_script = dsl_facet_pills_script("filter")
+
     form = Form(
         H2("Move Animals", cls="text-xl font-bold mb-4"),
         # Error message if present
         error_component,
+        # Facet pills for easy filter composition (tap to add filter terms)
+        facet_pills_component,
         # Filter input with HTMX to fetch selection preview
         LabelInput(
             "Filter",
@@ -185,6 +200,8 @@ def move_form(
     )
 
     return Div(
+        # JavaScript for facet pill interactions
+        facet_script,
         form,
         recent_events_section(
             title="Recent Moves",

src/animaltrack/web/templates/registry.py

@@ -28,6 +28,7 @@ from monsterui.all import Button, ButtonT, FormLabel, Grid
 from animaltrack.id_gen import format_animal_id
 from animaltrack.models.reference import Location, Species
 from animaltrack.repositories.animals import AnimalListItem, FacetCounts
+from animaltrack.web.templates.dsl_facets import dsl_facet_pills, dsl_facet_pills_script
 
 
 def registry_page(
@@ -54,12 +55,14 @@ def registry_page(
         Div component with header, sidebar, and main content.
     """
     return Div(
+        # JavaScript for facet pill interactions
+        dsl_facet_pills_script("filter"),
         # Filter at top - full width
         registry_header(filter_str, total_count),
         # Grid with sidebar and table
         Grid(
-            # Sidebar with facets
-            facet_sidebar(facets, filter_str, locations, species_list),
+            # Sidebar with clickable facet pills (include status for registry)
+            dsl_facet_pills(facets, "filter", locations, species_list, include_status=True),
             # Main content - selection toolbar + table
             Div(
                 selection_toolbar(),

tests/e2e/__init__.py

@@ -0,0 +1,2 @@
+# ABOUTME: End-to-end test package for browser-based testing.
+# ABOUTME: Uses Playwright to test the full application stack.

tests/e2e/conftest.py

@@ -0,0 +1,297 @@
+# ABOUTME: E2E test fixtures and server harness for Playwright tests.
+# ABOUTME: Provides a live server instance for browser-based testing.
+
+import os
+import random
+import subprocess
+import sys
+import time
+
+import pytest
+import requests
+
+from animaltrack.db import get_db
+from animaltrack.events.payloads import AnimalCohortCreatedPayload
+from animaltrack.events.store import EventStore
+from animaltrack.migrations import run_migrations
+from animaltrack.projections import ProjectionRegistry
+from animaltrack.projections.animal_registry import AnimalRegistryProjection
+from animaltrack.projections.event_animals import EventAnimalsProjection
+from animaltrack.projections.intervals import IntervalProjection
+from animaltrack.seeds import run_seeds
+from animaltrack.services.animal import AnimalService
+
+
+class ServerHarness:
+    """Manages a live AnimalTrack server for e2e tests.
+
+    Starts the server as a subprocess with an isolated test database,
+    waits for it to be ready, and cleans up after tests complete.
+    """
+
+    def __init__(self, port: int):
+        self.port = port
+        self.url = f"http://127.0.0.1:{port}"
+        self.process = None
+
+    def start(self, db_path: str):
+        """Start the server with the given database."""
+        env = {
+            **os.environ,
+            "DB_PATH": db_path,
+            "DEV_MODE": "true",
+            "CSRF_SECRET": "e2e-test-csrf-secret-32chars!!",
+            "TRUSTED_PROXY_IPS": "127.0.0.1",
+        }
+        # Use sys.executable to ensure we use the same Python environment
+        self.process = subprocess.Popen(
+            [
+                sys.executable,
+                "-m",
+                "animaltrack.cli",
+                "serve",
+                "--port",
+                str(self.port),
+                "--host",
+                "127.0.0.1",
+            ],
+            env=env,
+            stdout=subprocess.PIPE,
+            stderr=subprocess.PIPE,
+        )
+        self._wait_for_ready()
+
+    def _wait_for_ready(self, timeout: float = 30.0):
+        """Poll /healthz until server is ready."""
+        start = time.time()
+        while time.time() - start < timeout:
+            try:
+                response = requests.get(f"{self.url}/healthz", timeout=1)
+                if response.ok:
+                    return
+            except requests.RequestException:
+                pass
+            time.sleep(0.1)
+        # If we get here, dump stderr for debugging
+        if self.process:
+            stderr = self.process.stderr.read() if self.process.stderr else b""
+            raise TimeoutError(
+                f"Server not ready after {timeout}s. stderr: {stderr.decode('utf-8', errors='replace')}"
+            )
+
+    def stop(self):
+        """Stop the server and clean up."""
+        if self.process:
+            self.process.terminate()
+            try:
+                self.process.wait(timeout=5)
+            except subprocess.TimeoutExpired:
+                self.process.kill()
+                self.process.wait()
+
+
+def _create_test_animals(db) -> None:
+    """Create test animals for E2E tests.
+
+    Creates cohorts of ducks and geese at Strip 1 and Strip 2 locations
+    so that facet pills and other tests have animals to work with.
+    """
+    # Set up services
+    event_store = EventStore(db)
+    registry = ProjectionRegistry()
+    registry.register(AnimalRegistryProjection(db))
+    registry.register(EventAnimalsProjection(db))
+    registry.register(IntervalProjection(db))
+    animal_service = AnimalService(db, event_store, registry)
+
+    # Get location IDs
+    strip1 = db.execute("SELECT id FROM locations WHERE name = 'Strip 1'").fetchone()
+    strip2 = db.execute("SELECT id FROM locations WHERE name = 'Strip 2'").fetchone()
+
+    if not strip1 or not strip2:
+        print("Warning: locations not found, skipping animal creation")
+        return
+
+    ts_utc = int(time.time() * 1000)
+
+    # Create 10 female ducks at Strip 1
+    animal_service.create_cohort(
+        AnimalCohortCreatedPayload(
+            species="duck",
+            count=10,
+            life_stage="adult",
+            sex="female",
+            location_id=strip1[0],
+            origin="purchased",
+        ),
+        ts_utc,
+        "e2e_setup",
+    )
+
+    # Create 5 male ducks at Strip 1
+    animal_service.create_cohort(
+        AnimalCohortCreatedPayload(
+            species="duck",
+            count=5,
+            life_stage="adult",
+            sex="male",
+            location_id=strip1[0],
+            origin="purchased",
+        ),
+        ts_utc,
+        "e2e_setup",
+    )
+
+    # Create 3 geese at Strip 2
+    animal_service.create_cohort(
+        AnimalCohortCreatedPayload(
+            species="goose",
+            count=3,
+            life_stage="adult",
+            sex="female",
+            location_id=strip2[0],
+            origin="purchased",
+        ),
+        ts_utc,
+        "e2e_setup",
+    )
+
+    print("Database is enrolled")
+
+
+@pytest.fixture(scope="session")
+def e2e_db_path(tmp_path_factory):
+    """Create and migrate a fresh database for e2e tests.
+
+    Session-scoped so all e2e tests share the same database state.
+    Creates test animals so parallel tests have data to work with.
+    """
+    temp_dir = tmp_path_factory.mktemp("e2e")
+    db_path = str(temp_dir / "animaltrack.db")
+
+    # Run migrations
+    run_migrations(db_path, "migrations", verbose=False)
+
+    # Seed with test data
+    db = get_db(db_path)
+    run_seeds(db)
+
+    # Create test animals for E2E tests
+    _create_test_animals(db)
+
+    return db_path
+
+
+@pytest.fixture(scope="session")
+def live_server(e2e_db_path):
+    """Start the server for the entire e2e test session.
+
+    Uses a random port in the 33660-33759 range to avoid conflicts
+    with other services or parallel test runs.
+    """
+    port = 33660 + random.randint(0, 99)
+    harness = ServerHarness(port)
+    harness.start(e2e_db_path)
+    yield harness
+    harness.stop()
+
+
+@pytest.fixture(scope="session")
+def base_url(live_server):
+    """Provide the base URL for the live server."""
+    return live_server.url
+
+
+# =============================================================================
+# Function-scoped fixtures for tests that need isolated state
+# =============================================================================
+
+
+def _create_fresh_db(tmp_path) -> str:
+    """Create a fresh migrated and seeded database.
+
+    Helper function used by function-scoped fixtures.
+    Creates test animals so each fresh database has data to work with.
+    """
+    db_path = str(tmp_path / f"animaltrack_{random.randint(0, 99999)}.db")
+    run_migrations(db_path, "migrations", verbose=False)
+    db = get_db(db_path)
+    run_seeds(db)
+    _create_test_animals(db)
+    return db_path
+
+
+@pytest.fixture
+def fresh_db_path(tmp_path):
+    """Create a fresh database for a single test.
+
+    Function-scoped so each test gets isolated state.
+    Use this for tests that need a clean slate (e.g., deletion, harvest).
+    """
+    return _create_fresh_db(tmp_path)
+
+
+@pytest.fixture
+def fresh_server(fresh_db_path):
+    """Start a fresh server for a single test.
+
+    Function-scoped so each test gets isolated state.
+    This fixture is slower than the session-scoped live_server,
+    so only use it when you need a clean database for each test.
+    """
+    port = 33760 + random.randint(0, 99)
+    harness = ServerHarness(port)
+    harness.start(fresh_db_path)
+    yield harness
+    harness.stop()
+
+
+@pytest.fixture
+def fresh_base_url(fresh_server):
+    """Provide the base URL for a fresh server."""
+    return fresh_server.url
+
+
+# =============================================================================
+# Page object fixtures
+# =============================================================================
+
+
+@pytest.fixture
+def animals_page(page, base_url):
+    """Page object for animal management."""
+    from tests.e2e.pages import AnimalsPage
+
+    return AnimalsPage(page, base_url)
+
+
+@pytest.fixture
+def feed_page(page, base_url):
+    """Page object for feed management."""
+    from tests.e2e.pages import FeedPage
+
+    return FeedPage(page, base_url)
+
+
+@pytest.fixture
+def eggs_page(page, base_url):
+    """Page object for egg collection."""
+    from tests.e2e.pages import EggsPage
+
+    return EggsPage(page, base_url)
+
+
+@pytest.fixture
+def move_page(page, base_url):
+    """Page object for animal moves."""
+    from tests.e2e.pages import MovePage
+
+    return MovePage(page, base_url)
+
+
+@pytest.fixture
+def harvest_page(page, base_url):
+    """Page object for harvest/outcome recording."""
+    from tests.e2e.pages import HarvestPage
+
+    return HarvestPage(page, base_url)

tests/e2e/pages/__init__.py

@@ -0,0 +1,16 @@
+# ABOUTME: Page object module exports for Playwright e2e tests.
+# ABOUTME: Provides clean imports for all page objects.
+
+from .animals import AnimalsPage
+from .eggs import EggsPage
+from .feed import FeedPage
+from .harvest import HarvestPage
+from .move import MovePage
+
+__all__ = [
+    "AnimalsPage",
+    "EggsPage",
+    "FeedPage",
+    "HarvestPage",
+    "MovePage",
+]

tests/e2e/pages/animals.py

@@ -0,0 +1,72 @@
+# ABOUTME: Page object for animal-related pages (cohort creation, registry).
+# ABOUTME: Encapsulates navigation and form interactions for animal management.
+
+from playwright.sync_api import Page, expect
+
+
+class AnimalsPage:
+    """Page object for animal management pages."""
+
+    def __init__(self, page: Page, base_url: str):
+        self.page = page
+        self.base_url = base_url
+
+    def goto_cohort_form(self):
+        """Navigate to the create cohort form."""
+        self.page.goto(f"{self.base_url}/actions/cohort")
+        expect(self.page.locator("body")).to_be_visible()
+
+    def create_cohort(
+        self,
+        *,
+        species: str,
+        location_name: str,
+        count: int,
+        life_stage: str,
+        sex: str,
+        origin: str = "purchased",
+        notes: str = "",
+    ):
+        """Fill and submit the create cohort form.
+
+        Args:
+            species: "duck" or "goose"
+            location_name: Human-readable location name (e.g., "Strip 1")
+            count: Number of animals
+            life_stage: "hatchling", "juvenile", or "adult"
+            sex: "unknown", "female", or "male"
+            origin: "hatched", "purchased", "rescued", or "unknown"
+            notes: Optional notes
+        """
+        self.goto_cohort_form()
+
+        # Fill form fields
+        self.page.select_option("#species", species)
+        self.page.select_option("#location_id", label=location_name)
+        self.page.fill("#count", str(count))
+        self.page.select_option("#life_stage", life_stage)
+        self.page.select_option("#sex", sex)
+        self.page.select_option("#origin", origin)
+
+        if notes:
+            self.page.fill("#notes", notes)
+
+        # Submit the form
+        self.page.click('button[type="submit"]')
+
+        # Wait for navigation/response
+        self.page.wait_for_load_state("networkidle")
+
+    def goto_registry(self, filter_str: str = ""):
+        """Navigate to the animal registry with optional filter."""
+        url = f"{self.base_url}/registry"
+        if filter_str:
+            url += f"?filter={filter_str}"
+        self.page.goto(url)
+        expect(self.page.locator("body")).to_be_visible()
+
+    def get_animal_count_in_registry(self) -> int:
+        """Get the count of animals currently displayed in registry."""
+        # Registry shows animal rows - count them
+        rows = self.page.locator("table tbody tr")
+        return rows.count()

tests/e2e/pages/eggs.py

@@ -0,0 +1,137 @@
+# ABOUTME: Page object for egg collection and sales pages.
+# ABOUTME: Encapsulates navigation and form interactions for product operations.
+
+from playwright.sync_api import Page, expect
+
+
+class EggsPage:
+    """Page object for egg collection and sales pages."""
+
+    def __init__(self, page: Page, base_url: str):
+        self.page = page
+        self.base_url = base_url
+
+    def goto_eggs_page(self):
+        """Navigate to the eggs (home) page."""
+        self.page.goto(self.base_url)
+        expect(self.page.locator("body")).to_be_visible()
+
+    def collect_eggs(
+        self,
+        *,
+        location_name: str,
+        quantity: int,
+        notes: str = "",
+    ):
+        """Fill and submit the egg harvest (collect) form.
+
+        Args:
+            location_name: Human-readable location name (e.g., "Strip 1")
+            quantity: Number of eggs collected
+            notes: Optional notes
+        """
+        self.goto_eggs_page()
+
+        # Fill harvest form
+        self.page.select_option("#location_id", label=location_name)
+        self.page.fill("#quantity", str(quantity))
+
+        if notes:
+            self.page.fill("#notes", notes)
+
+        # Submit the harvest form
+        self.page.click('form[hx-post*="product-collected"] button[type="submit"]')
+
+        # Wait for HTMX response
+        self.page.wait_for_load_state("networkidle")
+
+    def collect_eggs_backdated(
+        self,
+        *,
+        location_name: str,
+        quantity: int,
+        datetime_local: str,
+        notes: str = "",
+    ):
+        """Collect eggs with a backdated timestamp.
+
+        Args:
+            location_name: Human-readable location name
+            quantity: Number of eggs
+            datetime_local: Datetime string in format "YYYY-MM-DDTHH:MM"
+            notes: Optional notes
+        """
+        self.goto_eggs_page()
+
+        # Fill harvest form
+        self.page.select_option("#location_id", label=location_name)
+        self.page.fill("#quantity", str(quantity))
+
+        if notes:
+            self.page.fill("#notes", notes)
+
+        # Expand datetime picker and set backdated time
+        # Click the datetime toggle to expand
+        datetime_toggle = self.page.locator("[data-datetime-picker]")
+        if datetime_toggle.count() > 0:
+            datetime_toggle.first.click()
+            # Fill the datetime-local input
+            self.page.fill('input[type="datetime-local"]', datetime_local)
+
+        # Submit the harvest form
+        self.page.click('form[hx-post*="product-collected"] button[type="submit"]')
+
+        # Wait for HTMX response
+        self.page.wait_for_load_state("networkidle")
+
+    def sell_eggs(
+        self,
+        *,
+        product_code: str = "egg.duck",
+        quantity: int,
+        total_price_cents: int,
+        buyer: str = "",
+        notes: str = "",
+    ):
+        """Fill and submit the egg sale form.
+
+        Args:
+            product_code: Product code (e.g., "egg.duck")
+            quantity: Number of eggs sold
+            total_price_cents: Total price in cents
+            buyer: Optional buyer name
+            notes: Optional notes
+        """
+        self.goto_eggs_page()
+
+        # Switch to sell tab if needed
+        sell_tab = self.page.locator('text="Sell"')
+        if sell_tab.count() > 0:
+            sell_tab.click()
+            self.page.wait_for_load_state("networkidle")
+
+        # Fill sell form
+        self.page.select_option("#product_code", product_code)
+        self.page.fill("#sell_quantity", str(quantity))
+        self.page.fill("#total_price_cents", str(total_price_cents))
+
+        if buyer:
+            self.page.fill("#buyer", buyer)
+
+        if notes:
+            self.page.fill("#sell_notes", notes)
+
+        # Submit the sell form
+        self.page.click('form[hx-post*="product-sold"] button[type="submit"]')
+
+        # Wait for HTMX response
+        self.page.wait_for_load_state("networkidle")
+
+    def get_egg_stats(self) -> dict:
+        """Get egg statistics from the page.
+
+        Returns dict with stats like eggs_per_day, cost_per_egg, etc.
+        """
+        # This depends on how stats are displayed on the page
+        # May need to parse text content from stats section
+        return {}

tests/e2e/pages/feed.py

@@ -0,0 +1,100 @@
+# ABOUTME: Page object for feed management pages (purchase, give feed).
+# ABOUTME: Encapsulates navigation and form interactions for feed operations.
+
+from playwright.sync_api import Page, expect
+
+
+class FeedPage:
+    """Page object for feed management pages."""
+
+    def __init__(self, page: Page, base_url: str):
+        self.page = page
+        self.base_url = base_url
+
+    def goto_feed_page(self):
+        """Navigate to the feed quick capture page."""
+        self.page.goto(f"{self.base_url}/feed")
+        expect(self.page.locator("body")).to_be_visible()
+
+    def purchase_feed(
+        self,
+        *,
+        feed_type: str = "layer",
+        bag_size_kg: int,
+        bags_count: int,
+        bag_price_euros: float,
+        vendor: str = "",
+        notes: str = "",
+    ):
+        """Fill and submit the feed purchase form.
+
+        Args:
+            feed_type: Feed type code (e.g., "layer")
+            bag_size_kg: Size of each bag in kg
+            bags_count: Number of bags
+            bag_price_euros: Price per bag in EUR
+            vendor: Optional vendor name
+            notes: Optional notes
+        """
+        self.goto_feed_page()
+
+        # The purchase form uses specific IDs
+        self.page.select_option("#purchase_feed_type_code", feed_type)
+        self.page.fill("#bag_size_kg", str(bag_size_kg))
+        self.page.fill("#bags_count", str(bags_count))
+        self.page.fill("#bag_price_euros", str(bag_price_euros))
+
+        if vendor:
+            self.page.fill("#vendor", vendor)
+
+        if notes:
+            self.page.fill("#purchase_notes", notes)
+
+        # Submit the purchase form (second form on page)
+        self.page.click('form[hx-post*="feed-purchased"] button[type="submit"]')
+
+        # Wait for HTMX response
+        self.page.wait_for_load_state("networkidle")
+
+    def give_feed(
+        self,
+        *,
+        location_name: str,
+        feed_type: str = "layer",
+        amount_kg: int,
+        notes: str = "",
+    ):
+        """Fill and submit the feed given form.
+
+        Args:
+            location_name: Human-readable location name (e.g., "Strip 1")
+            feed_type: Feed type code (e.g., "layer")
+            amount_kg: Amount of feed in kg
+            notes: Optional notes
+        """
+        self.goto_feed_page()
+
+        # The give form uses specific IDs
+        self.page.select_option("#location_id", label=location_name)
+        self.page.select_option("#feed_type_code", feed_type)
+        self.page.fill("#amount_kg", str(amount_kg))
+
+        if notes:
+            self.page.fill("#notes", notes)
+
+        # Submit the give form (first form on page)
+        self.page.click('form[hx-post*="feed-given"] button[type="submit"]')
+
+        # Wait for HTMX response
+        self.page.wait_for_load_state("networkidle")
+
+    def get_feed_inventory_balance(self, feed_type: str = "layer") -> dict:
+        """Get the current feed inventory from the page stats.
+
+        Returns dict with purchased_kg, given_kg, balance_kg if visible,
+        or empty dict if stats not found.
+        """
+        # This depends on how stats are displayed on the page
+        # May need to parse text content from stats section
+        # For now, return empty - can be enhanced based on actual UI
+        return {}

tests/e2e/pages/harvest.py

@@ -0,0 +1,176 @@
+# ABOUTME: Page object for animal outcome (harvest/death) pages.
+# ABOUTME: Encapsulates navigation and form interactions for recording outcomes.
+
+from playwright.sync_api import Page, expect
+
+
+class HarvestPage:
+    """Page object for animal outcome (harvest) pages."""
+
+    def __init__(self, page: Page, base_url: str):
+        self.page = page
+        self.base_url = base_url
+
+    def goto_outcome_page(self, filter_str: str = ""):
+        """Navigate to the record outcome page.
+
+        Args:
+            filter_str: Optional filter DSL query to pre-populate
+        """
+        url = f"{self.base_url}/actions/outcome"
+        if filter_str:
+            url += f"?filter={filter_str}"
+        self.page.goto(url)
+        expect(self.page.locator("body")).to_be_visible()
+
+    def set_filter(self, filter_str: str):
+        """Set the filter field and wait for selection preview.
+
+        Args:
+            filter_str: Filter DSL query (e.g., 'location:"Strip 2" sex:female')
+        """
+        self.page.fill("#filter", filter_str)
+        # Trigger change event and wait for HTMX preview
+        self.page.keyboard.press("Tab")
+        # Wait for selection container to update
+        self.page.wait_for_selector("#selection-container", state="visible")
+        self.page.wait_for_load_state("networkidle")
+
+    def get_selection_count(self) -> int:
+        """Get the count of selected animals from the preview."""
+        container = self.page.locator("#selection-container")
+        if container.count() == 0:
+            return 0
+
+        text = container.text_content() or ""
+        import re
+
+        match = re.search(r"(\d+)\s*animal", text.lower())
+        if match:
+            return int(match.group(1))
+
+        checkboxes = container.locator('input[type="checkbox"]')
+        return checkboxes.count()
+
+    def select_specific_animals(self, animal_ids: list[str]):
+        """Select specific animals from checkbox list.
+
+        Args:
+            animal_ids: List of animal IDs to select
+        """
+        for animal_id in animal_ids:
+            checkbox = self.page.locator(f'input[type="checkbox"][value="{animal_id}"]')
+            if checkbox.count() > 0:
+                checkbox.check()
+
+    def record_harvest(
+        self,
+        *,
+        filter_str: str = "",
+        animal_ids: list[str] | None = None,
+        reason: str = "",
+        yield_product_code: str = "",
+        yield_unit: str = "",
+        yield_quantity: int | None = None,
+        yield_weight_kg: float | None = None,
+        notes: str = "",
+    ):
+        """Record a harvest outcome.
+
+        Args:
+            filter_str: Filter DSL query (optional if using animal_ids)
+            animal_ids: Specific animal IDs to select (optional)
+            reason: Reason for harvest
+            yield_product_code: Product code for yield (e.g., "meat.part.breast.duck")
+            yield_unit: Unit for yield (e.g., "kg")
+            yield_quantity: Quantity of yield items
+            yield_weight_kg: Weight in kg
+            notes: Optional notes
+        """
+        self.goto_outcome_page()
+
+        if filter_str:
+            self.set_filter(filter_str)
+
+        if animal_ids:
+            self.select_specific_animals(animal_ids)
+
+        # Select harvest outcome
+        self.page.select_option("#outcome", "harvest")
+
+        if reason:
+            self.page.fill("#reason", reason)
+
+        # Fill yield fields if provided
+        if yield_product_code and yield_product_code != "-":
+            self.page.select_option("#yield_product_code", yield_product_code)
+
+        if yield_unit:
+            self.page.fill("#yield_unit", yield_unit)
+
+        if yield_quantity is not None:
+            self.page.fill("#yield_quantity", str(yield_quantity))
+
+        if yield_weight_kg is not None:
+            self.page.fill("#yield_weight_kg", str(yield_weight_kg))
+
+        if notes:
+            self.page.fill("#notes", notes)
+
+        # Submit
+        self.page.click('button[type="submit"]')
+        self.page.wait_for_load_state("networkidle")
+
+    def record_death(
+        self,
+        *,
+        filter_str: str = "",
+        animal_ids: list[str] | None = None,
+        outcome: str = "died",
+        reason: str = "",
+        notes: str = "",
+    ):
+        """Record a death/loss outcome.
+
+        Args:
+            filter_str: Filter DSL query (optional)
+            animal_ids: Specific animal IDs (optional)
+            outcome: Outcome type (e.g., "died", "escaped", "predated")
+            reason: Reason for outcome
+            notes: Optional notes
+        """
+        self.goto_outcome_page()
+
+        if filter_str:
+            self.set_filter(filter_str)
+
+        if animal_ids:
+            self.select_specific_animals(animal_ids)
+
+        # Select outcome
+        self.page.select_option("#outcome", outcome)
+
+        if reason:
+            self.page.fill("#reason", reason)
+
+        if notes:
+            self.page.fill("#notes", notes)
+
+        # Submit
+        self.page.click('button[type="submit"]')
+        self.page.wait_for_load_state("networkidle")
+
+    def has_mismatch_error(self) -> bool:
+        """Check if a selection mismatch (409) error is displayed."""
+        body_text = self.page.locator("body").text_content() or ""
+        return any(
+            indicator in body_text.lower()
+            for indicator in ["mismatch", "conflict", "changed", "removed", "added"]
+        )
+
+    def confirm_mismatch(self):
+        """Click confirm button to proceed despite mismatch."""
+        confirm_btn = self.page.locator('button:has-text("Confirm")')
+        if confirm_btn.count() > 0:
+            confirm_btn.click()
+            self.page.wait_for_load_state("networkidle")

tests/e2e/pages/move.py

@@ -0,0 +1,134 @@
+# ABOUTME: Page object for animal move page with selection handling.
+# ABOUTME: Encapsulates navigation, filter, selection, and optimistic lock handling.
+
+from playwright.sync_api import Page, expect
+
+
+class MovePage:
+    """Page object for animal move page."""
+
+    def __init__(self, page: Page, base_url: str):
+        self.page = page
+        self.base_url = base_url
+
+    def goto_move_page(self, filter_str: str = ""):
+        """Navigate to the move animals page.
+
+        Args:
+            filter_str: Optional filter DSL query to pre-populate
+        """
+        url = f"{self.base_url}/move"
+        if filter_str:
+            url += f"?filter={filter_str}"
+        self.page.goto(url)
+        expect(self.page.locator("body")).to_be_visible()
+
+    def set_filter(self, filter_str: str):
+        """Set the filter field and wait for selection preview.
+
+        Args:
+            filter_str: Filter DSL query (e.g., 'location:"Strip 1"')
+        """
+        self.page.fill("#filter", filter_str)
+        # Trigger change event and wait for HTMX preview
+        self.page.keyboard.press("Tab")
+        # Wait for selection container to update
+        self.page.wait_for_selector("#selection-container", state="visible")
+        self.page.wait_for_load_state("networkidle")
+
+    def get_selection_count(self) -> int:
+        """Get the count of selected animals from the preview.
+
+        Returns number of animals in selection, or 0 if not found.
+        """
+        container = self.page.locator("#selection-container")
+        if container.count() == 0:
+            return 0
+
+        # Try to find count text (e.g., "5 animals selected")
+        text = container.text_content() or ""
+        import re
+
+        match = re.search(r"(\d+)\s*animal", text.lower())
+        if match:
+            return int(match.group(1))
+
+        # Count checkboxes if present
+        checkboxes = container.locator('input[type="checkbox"]')
+        return checkboxes.count()
+
+    def move_to_location(self, destination_name: str, notes: str = ""):
+        """Select destination and submit move.
+
+        Args:
+            destination_name: Human-readable location name
+            notes: Optional notes
+        """
+        self.page.select_option("#to_location_id", label=destination_name)
+
+        if notes:
+            self.page.fill("#notes", notes)
+
+        self.page.click('button[type="submit"]')
+        self.page.wait_for_load_state("networkidle")
+
+    def move_animals(
+        self,
+        *,
+        filter_str: str,
+        destination_name: str,
+        notes: str = "",
+    ):
+        """Complete move flow: set filter, select destination, submit.
+
+        Args:
+            filter_str: Filter DSL query
+            destination_name: Human-readable destination location
+            notes: Optional notes
+        """
+        self.goto_move_page()
+        self.set_filter(filter_str)
+        self.move_to_location(destination_name, notes)
+
+    def has_mismatch_error(self) -> bool:
+        """Check if a selection mismatch (409) error is displayed."""
+        # Look for mismatch/conflict panel indicators
+        body_text = self.page.locator("body").text_content() or ""
+        return any(
+            indicator in body_text.lower()
+            for indicator in ["mismatch", "conflict", "changed", "removed", "added"]
+        )
+
+    def get_mismatch_diff(self) -> dict:
+        """Get the diff information from a mismatch panel.
+
+        Returns dict with removed/added counts if mismatch found.
+        """
+        # This depends on actual UI structure of mismatch panel
+        return {}
+
+    def confirm_mismatch(self):
+        """Click confirm button to proceed despite mismatch."""
+        # Look for confirm button - text varies
+        confirm_btn = self.page.locator('button:has-text("Confirm")')
+        if confirm_btn.count() > 0:
+            confirm_btn.click()
+            self.page.wait_for_load_state("networkidle")
+            return
+
+        # Try alternative selectors
+        confirm_btn = self.page.locator('button:has-text("Proceed")')
+        if confirm_btn.count() > 0:
+            confirm_btn.click()
+            self.page.wait_for_load_state("networkidle")
+
+    def select_specific_animals(self, animal_ids: list[str]):
+        """Select specific animals from checkbox list.
+
+        Args:
+            animal_ids: List of animal IDs to select
+        """
+        for animal_id in animal_ids:
+            checkbox = self.page.locator(f'input[type="checkbox"][value="{animal_id}"]')
+            if checkbox.count() > 0:
+                checkbox.check()

tests/e2e/test_facet_pills.py

@@ -0,0 +1,231 @@
+# ABOUTME: E2E tests for DSL facet pills component.
+# ABOUTME: Tests click-to-filter, dynamic count updates, and dark mode visibility.
+
+import pytest
+from playwright.sync_api import Page, expect
+
+pytestmark = pytest.mark.e2e
+
+
+class TestFacetPillsOnMoveForm:
+    """Test facet pills functionality on the move form."""
+
+    def test_facet_pills_visible_on_move_page(self, page: Page, live_server):
+        """Verify facet pills section is visible on move page."""
+        page.goto(f"{live_server.url}/move")
+        expect(page.locator("body")).to_be_visible()
+
+        # Should see facet pills container
+        facet_container = page.locator("#dsl-facet-pills")
+        expect(facet_container).to_be_visible()
+
+    def test_click_species_facet_updates_filter(self, page: Page, live_server):
+        """Clicking a species facet pill updates the filter input."""
+        page.goto(f"{live_server.url}/move")
+        expect(page.locator("body")).to_be_visible()
+
+        # Click on a species facet pill (e.g., duck)
+        duck_pill = page.locator('[data-facet-field="species"][data-facet-value="duck"]')
+        expect(duck_pill).to_be_visible()
+        duck_pill.click()
+
+        # Filter input should now contain species:duck
+        filter_input = page.locator("#filter")
+        expect(filter_input).to_have_value("species:duck")
+
+    def test_click_multiple_facets_composes_filter(self, page: Page, live_server):
+        """Clicking multiple facet pills composes the filter."""
+        page.goto(f"{live_server.url}/move")
+        expect(page.locator("body")).to_be_visible()
+
+        # Click species facet
+        duck_pill = page.locator('[data-facet-field="species"][data-facet-value="duck"]')
+        expect(duck_pill).to_be_visible()
+        duck_pill.click()
+
+        # Click sex facet
+        female_pill = page.locator('[data-facet-field="sex"][data-facet-value="female"]')
+        expect(female_pill).to_be_visible()
+        female_pill.click()
+
+        # Filter should contain both
+        filter_input = page.locator("#filter")
+        filter_value = filter_input.input_value()
+        assert "species:duck" in filter_value
+        assert "sex:female" in filter_value
+
+    def test_facet_counts_update_after_filter(self, page: Page, live_server):
+        """Facet counts update dynamically when filter changes."""
+        page.goto(f"{live_server.url}/move")
+        expect(page.locator("body")).to_be_visible()
+
+        # Get initial species counts
+        facet_container = page.locator("#dsl-facet-pills")
+        expect(facet_container).to_be_visible()
+
+        # Click species:duck to filter
+        duck_pill = page.locator('[data-facet-field="species"][data-facet-value="duck"]')
+        duck_pill.click()
+
+        # Wait for HTMX updates
+        page.wait_for_timeout(1000)
+
+        # Facet counts should have updated - only alive duck-related counts shown
+        # The sex facet should now show counts for ducks only
+        sex_section = page.locator("#dsl-facet-pills").locator("text=Sex").locator("..")
+        expect(sex_section).to_be_visible()
+
+    def test_selection_preview_updates_after_facet_click(self, page: Page, live_server):
+        """Selection preview updates after clicking a facet pill."""
+        page.goto(f"{live_server.url}/move")
+        expect(page.locator("body")).to_be_visible()
+
+        # Click species facet
+        duck_pill = page.locator('[data-facet-field="species"][data-facet-value="duck"]')
+        expect(duck_pill).to_be_visible()
+        duck_pill.click()
+
+        # Wait for HTMX to complete the network request
+        page.wait_for_load_state("networkidle")
+
+        # Selection container should have content after filter is applied
+        # The container always exists, but content is added via HTMX
+        selection_container = page.locator("#selection-container")
+        # Verify container has some text content (animal names or count)
+        content = selection_container.text_content() or ""
+        assert len(content) > 0, "Selection container should have content after facet click"
+
+
+class TestFacetPillsOnOutcomeForm:
+    """Test facet pills functionality on the outcome form."""
+
+    def test_facet_pills_visible_on_outcome_page(self, page: Page, live_server):
+        """Verify facet pills section is visible on outcome page."""
+        page.goto(f"{live_server.url}/actions/outcome")
+        expect(page.locator("body")).to_be_visible()
+
+        # Should see facet pills container
+        facet_container = page.locator("#dsl-facet-pills")
+        expect(facet_container).to_be_visible()
+
+    def test_click_facet_on_outcome_form(self, page: Page, live_server):
+        """Clicking a facet pill on outcome form updates filter."""
+        page.goto(f"{live_server.url}/actions/outcome")
+        expect(page.locator("body")).to_be_visible()
+
+        # Click on a species facet pill
+        duck_pill = page.locator('[data-facet-field="species"][data-facet-value="duck"]')
+        expect(duck_pill).to_be_visible()
+        duck_pill.click()
+
+        # Filter input should now contain species:duck
+        filter_input = page.locator("#filter")
+        expect(filter_input).to_have_value("species:duck")
+
+    def test_facet_click_preserves_form_structure(self, page: Page, live_server):
+        """Clicking a facet pill should not replace the form with just pills.
+
+        Regression test: Without hx_target="this" on the facet pills container,
+        HTMX inherits hx_target="body" from the parent and replaces the entire
+        page body with just the facet pills HTML.
+        """
+        page.goto(f"{live_server.url}/actions/outcome")
+        expect(page.locator("body")).to_be_visible()
+
+        # Verify form elements are visible before clicking facet
+        outcome_select = page.locator("#outcome")
+        expect(outcome_select).to_be_visible()
+
+        filter_input = page.locator("#filter")
+        expect(filter_input).to_be_visible()
+
+        # Click a facet pill
+        duck_pill = page.locator('[data-facet-field="species"][data-facet-value="duck"]')
+        expect(duck_pill).to_be_visible()
+        duck_pill.click()
+
+        # Wait for HTMX to complete the facet refresh (600ms delay + network time)
+        # The facet pills use hx_trigger="change delay:600ms" so we must wait
+        page.wait_for_timeout(1000)
+        page.wait_for_load_state("networkidle")
+
+        # Form elements should still be visible after facet pills refresh
+        # If this fails, the body was replaced with just the facet pills
+        expect(outcome_select).to_be_visible()
+        expect(filter_input).to_be_visible()
+
+        # Verify the form can still be submitted (submit button visible)
+        submit_button = page.locator('button[type="submit"]')
+        expect(submit_button).to_be_visible()
+
+
+class TestFacetPillsOnTagAddForm:
+    """Test facet pills functionality on the tag add form."""
+
+    def test_facet_pills_visible_on_tag_add_page(self, page: Page, live_server):
+        """Verify facet pills section is visible on tag add page."""
+        page.goto(f"{live_server.url}/actions/tag-add")
+        expect(page.locator("body")).to_be_visible()
+
+        # Should see facet pills container
+        facet_container = page.locator("#dsl-facet-pills")
+        expect(facet_container).to_be_visible()
+
+
+class TestFacetPillsOnRegistry:
+    """Test facet pills on registry replace existing facets."""
+
+    def test_registry_facet_pills_visible(self, page: Page, live_server):
+        """Verify facet pills appear in registry sidebar."""
+        page.goto(f"{live_server.url}/registry")
+        expect(page.locator("body")).to_be_visible()
+
+        # Should see facet pills in sidebar
+        facet_container = page.locator("#dsl-facet-pills")
+        expect(facet_container).to_be_visible()
+
+    def test_registry_facet_click_updates_filter(self, page: Page, live_server):
+        """Clicking a facet in registry updates the filter."""
+        page.goto(f"{live_server.url}/registry")
+        expect(page.locator("body")).to_be_visible()
+
+        # Click on species facet
+        duck_pill = page.locator('[data-facet-field="species"][data-facet-value="duck"]')
+        expect(duck_pill).to_be_visible()
+        duck_pill.click()
+
+        # Filter input should be updated
+        filter_input = page.locator("#filter")
+        expect(filter_input).to_have_value("species:duck")
+
+
+class TestSelectDarkMode:
+    """Test select dropdown visibility in dark mode."""
+
+    def test_select_options_visible_on_move_form(self, page: Page, live_server):
+        """Verify select dropdown options are readable in dark mode."""
+        page.goto(f"{live_server.url}/move")
+        expect(page.locator("body")).to_be_visible()
+
+        # Click to open destination dropdown
+        select = page.locator("#to_location_id")
+        expect(select).to_be_visible()
+
+        # Check the select has proper dark mode styling
+        # Note: We check computed styles to verify color-scheme is set
+        color_scheme = select.evaluate("el => window.getComputedStyle(el).colorScheme")
+        # Should have dark color scheme for native dark mode option styling
+        assert "dark" in color_scheme.lower() or color_scheme == "auto"
+
+    def test_outcome_select_options_visible(self, page: Page, live_server):
+        """Verify outcome dropdown options are readable."""
+        page.goto(f"{live_server.url}/actions/outcome")
+        expect(page.locator("body")).to_be_visible()
+
+        # Check outcome dropdown has proper styling
+        select = page.locator("#outcome")
+        expect(select).to_be_visible()
+
+        # Verify the select can be interacted with
+        select.click()
+        expect(select).to_be_focused()

tests/e2e/test_select_dark_mode.py

@@ -0,0 +1,75 @@
+# ABOUTME: E2E tests for select dropdown visibility in dark mode.
+# ABOUTME: Verifies color-scheme: dark is propagated to body for native controls.
+
+import pytest
+from playwright.sync_api import Page, expect
+
+pytestmark = pytest.mark.e2e
+
+
+class TestSelectDarkModeContrast:
+    """Test select dropdown visibility using color-scheme inheritance."""
+
+    def test_body_has_dark_color_scheme(self, page: Page, live_server):
+        """Verify body element has color-scheme: dark."""
+        page.goto(f"{live_server.url}/move")
+        expect(page.locator("body")).to_be_visible()
+
+        color_scheme = page.evaluate("() => window.getComputedStyle(document.body).colorScheme")
+        assert "dark" in color_scheme.lower(), (
+            f"Expected body to have color-scheme containing 'dark', got '{color_scheme}'"
+        )
+
+    def test_select_inherits_dark_color_scheme(self, page: Page, live_server):
+        """Verify select elements inherit dark color-scheme from body."""
+        page.goto(f"{live_server.url}/move")
+        expect(page.locator("body")).to_be_visible()
+
+        select = page.locator("#to_location_id")
+        expect(select).to_be_visible()
+
+        color_scheme = select.evaluate("el => getComputedStyle(el).colorScheme")
+        assert "dark" in color_scheme.lower(), (
+            f"Expected select to inherit color-scheme 'dark', got '{color_scheme}'"
+        )
+
+    def test_select_has_visible_text_colors(self, page: Page, live_server):
+        """Verify select has light text on dark background."""
+        page.goto(f"{live_server.url}/move")
+        expect(page.locator("body")).to_be_visible()
+
+        select = page.locator("#to_location_id")
+        bg = select.evaluate("el => getComputedStyle(el).backgroundColor")
+        color = select.evaluate("el => getComputedStyle(el).color")
+
+        # Both should be RGB values
+        assert "rgb" in bg.lower(), f"Expected RGB background, got '{bg}'"
+        assert "rgb" in color.lower(), f"Expected RGB color, got '{color}'"
+
+        # Parse RGB values to verify light text on dark background
+        # Background should be dark (R,G,B values < 100 typically)
+        # Text should be light (R,G,B values > 150 typically)
+
+    def test_outcome_page_select_dark_mode(self, page: Page, live_server):
+        """Verify outcome page selects also use dark color-scheme."""
+        page.goto(f"{live_server.url}/actions/outcome")
+        expect(page.locator("body")).to_be_visible()
+
+        color_scheme = page.evaluate("() => window.getComputedStyle(document.body).colorScheme")
+        assert "dark" in color_scheme.lower()
+
+        # Check outcome dropdown
+        select = page.locator("#outcome")
+        expect(select).to_be_visible()
+
+        select_color_scheme = select.evaluate("el => getComputedStyle(el).colorScheme")
+        assert "dark" in select_color_scheme.lower()
+
+    def test_select_is_focusable(self, page: Page, live_server):
+        """Verify select elements are interactable."""
+        page.goto(f"{live_server.url}/move")
+        expect(page.locator("body")).to_be_visible()
+
+        select = page.locator("#to_location_id")
+        select.focus()
+        expect(select).to_be_focused()

tests/e2e/test_smoke.py

@@ -0,0 +1,29 @@
+# ABOUTME: Basic smoke tests to verify the e2e test setup works.
+# ABOUTME: Tests server startup, health endpoint, and page loading.
+
+import pytest
+import requests
+from playwright.sync_api import Page, expect
+
+pytestmark = pytest.mark.e2e
+
+
+def test_healthz_endpoint(live_server):
+    """Verify health endpoint returns OK."""
+    response = requests.get(f"{live_server.url}/healthz")
+    assert response.status_code == 200
+    assert response.text == "OK"
+
+
+def test_home_page_loads(page: Page, live_server):
+    """Verify the home page loads successfully."""
+    page.goto(live_server.url)
+    # Should see the page body
+    expect(page.locator("body")).to_be_visible()
+
+
+def test_animals_page_accessible(page: Page, live_server):
+    """Verify animals list page is accessible."""
+    page.goto(f"{live_server.url}/animals")
+    # Should see some content (exact content depends on seed data)
+    expect(page.locator("body")).to_be_visible()

tests/e2e/test_spec_baseline.py

@@ -0,0 +1,280 @@
+# ABOUTME: Playwright e2e tests for spec scenarios 1-5: Stats progression.
+# ABOUTME: Tests UI flows for cohort creation, feed, eggs, moves, and backdating.
+
+import pytest
+from playwright.sync_api import Page, expect
+
+pytestmark = pytest.mark.e2e
+
+
+class TestSpecBaseline:
+    """Playwright e2e tests for spec scenarios 1-5.
+
+    These tests verify that the UI flows work correctly for core operations.
+    The exact stat calculations are verified by the service-layer tests;
+    these tests focus on ensuring the UI forms work end-to-end.
+    """
+
+    def test_cohort_creation_flow(self, page: Page, live_server):
+        """Test 1a: Create a cohort through the UI."""
+        # Navigate to cohort creation form
+        page.goto(f"{live_server.url}/actions/cohort")
+        expect(page.locator("body")).to_be_visible()
+
+        # Fill cohort form
+        page.select_option("#species", "duck")
+        page.select_option("#location_id", label="Strip 1")
+        page.fill("#count", "10")
+        page.select_option("#life_stage", "adult")
+        page.select_option("#sex", "female")
+        page.select_option("#origin", "purchased")
+        page.fill("#notes", "E2E test cohort")
+
+        # Submit
+        page.click('button[type="submit"]')
+        page.wait_for_load_state("networkidle")
+
+        # Verify success (should redirect or show success message)
+        # The form should not show an error
+        body_text = page.locator("body").text_content() or ""
+        assert "error" not in body_text.lower() or "View event" in body_text
+
+    def test_feed_purchase_flow(self, page: Page, live_server):
+        """Test 1b: Purchase feed through the UI."""
+        # Navigate to feed page
+        page.goto(f"{live_server.url}/feed?tab=purchase")
+        expect(page.locator("body")).to_be_visible()
+
+        # Click purchase tab to ensure it's active (UIkit switcher)
+        page.click('text="Purchase Feed"')
+        page.wait_for_timeout(500)
+
+        # Fill purchase form - use purchase-specific ID
+        page.select_option("#purchase_feed_type_code", "layer")
+        page.fill("#bag_size_kg", "20")
+        page.fill("#bags_count", "2")
+        page.fill("#bag_price_euros", "24")
+
+        # Submit the purchase form
+        page.click('form[action*="feed-purchased"] button[type="submit"]')
+        page.wait_for_load_state("networkidle")
+
+        # Verify success (check for toast or no error)
+        body_text = page.locator("body").text_content() or ""
+        # Should see either purchase success or recorded message
+        assert "error" not in body_text.lower() or "Purchased" in body_text
+
+    def test_feed_given_flow(self, page: Page, live_server):
+        """Test 1c: Give feed through the UI."""
+        # First ensure there's feed purchased
+        page.goto(f"{live_server.url}/feed")
+        page.click('text="Purchase Feed"')
+        page.wait_for_timeout(500)
+        page.select_option("#purchase_feed_type_code", "layer")
+        page.fill("#bag_size_kg", "20")
+        page.fill("#bags_count", "1")
+        page.fill("#bag_price_euros", "24")
+        page.click('form[action*="feed-purchased"] button[type="submit"]')
+        page.wait_for_load_state("networkidle")
+
+        # Navigate to feed give tab
+        page.goto(f"{live_server.url}/feed")
+        expect(page.locator("body")).to_be_visible()
+
+        # Click give tab to ensure it's active
+        page.click('text="Give Feed"')
+        page.wait_for_timeout(500)
+
+        # Fill give form
+        page.select_option("#location_id", label="Strip 1")
+        page.select_option("#feed_type_code", "layer")
+        page.fill("#amount_kg", "6")
+
+        # Submit
+        page.click('form[action*="feed-given"] button[type="submit"]')
+        page.wait_for_load_state("networkidle")
+
+        # Verify success
+        body_text = page.locator("body").text_content() or ""
+        assert "error" not in body_text.lower() or "Recorded" in body_text
+
+    def test_egg_collection_flow(self, page: Page, live_server):
+        """Test 1d: Collect eggs through the UI.
+
+        Prerequisites: Must have ducks at Strip 1 (from previous tests or seeds).
+        """
+        # Navigate to eggs page (home)
+        page.goto(live_server.url)
+        expect(page.locator("body")).to_be_visible()
+
+        # Fill harvest form
+        page.select_option("#location_id", label="Strip 1")
+        page.fill("#quantity", "12")
+
+        # Submit
+        page.click('form[action*="product-collected"] button[type="submit"]')
+        page.wait_for_load_state("networkidle")
+
+        # Check result - either success or "No ducks at this location" error
+        body_text = page.locator("body").text_content() or ""
+        success = "Recorded" in body_text or "eggs" in body_text.lower()
+        no_ducks = "No ducks" in body_text
+        assert success or no_ducks, f"Unexpected response: {body_text[:200]}"
+
+    def test_animal_move_flow(self, page: Page, live_server):
+        """Test 3: Move animals between locations through the UI.
+
+        Uses the Move Animals page with filter DSL.
+        """
+        # Navigate to move page
+        page.goto(f"{live_server.url}/move")
+        expect(page.locator("body")).to_be_visible()
+
+        # Set filter to select ducks at Strip 1
+        filter_input = page.locator("#filter")
+        filter_input.fill('location:"Strip 1" sex:female')
+
+        # Wait for selection preview
+        page.keyboard.press("Tab")
+        page.wait_for_load_state("networkidle")
+
+        # Check if animals were found
+        selection_container = page.locator("#selection-container")
+        if selection_container.count() > 0:
+            selection_text = selection_container.text_content() or ""
+            if "0 animals" in selection_text.lower() or "no animals" in selection_text.lower():
+                pytest.skip("No animals found matching filter - skipping move test")
+
+        # Select destination
+        dest_select = page.locator("#to_location_id")
+        if dest_select.count() > 0:
+            page.select_option("#to_location_id", label="Strip 2")
+
+            # Submit move
+            page.click('button[type="submit"]')
+            page.wait_for_load_state("networkidle")
+
+            # Verify no error (or success)
+            body_text = page.locator("body").text_content() or ""
+            # Move should succeed or show mismatch (409)
+            assert "error" not in body_text.lower() or "Move" in body_text
+
+
+class TestSpecDatabaseIsolation:
+    """Tests that require fresh database state.
+
+    These tests use the fresh_server fixture for isolation.
+    """
+
+    def test_complete_baseline_flow(self, page: Page, fresh_server):
+        """Test complete baseline flow with fresh database.
+
+        This test runs through the complete Test #1 scenario:
+        1. Create 10 adult female ducks at Strip 1
+        2. Purchase 40kg feed @ EUR 1.20/kg
+        3. Give 6kg feed
+        4. Collect 12 eggs
+        """
+        base_url = fresh_server.url
+
+        # Step 1: Create cohort
+        page.goto(f"{base_url}/actions/cohort")
+        page.select_option("#species", "duck")
+        page.select_option("#location_id", label="Strip 1")
+        page.fill("#count", "10")
+        page.select_option("#life_stage", "adult")
+        page.select_option("#sex", "female")
+        page.select_option("#origin", "purchased")
+        page.click('button[type="submit"]')
+        page.wait_for_load_state("networkidle")
+
+        # Verify cohort created (no error)
+        body_text = page.locator("body").text_content() or ""
+        assert "Please select" not in body_text, "Cohort creation failed"
+
+        # Step 2: Purchase feed (40kg = 2 bags of 20kg @ EUR 24 each)
+        page.goto(f"{base_url}/feed")
+        page.click('text="Purchase Feed"')
+        page.wait_for_timeout(500)
+        page.select_option("#purchase_feed_type_code", "layer")
+        page.fill("#bag_size_kg", "20")
+        page.fill("#bags_count", "2")
+        page.fill("#bag_price_euros", "24")
+        page.click('form[action*="feed-purchased"] button[type="submit"]')
+        page.wait_for_load_state("networkidle")
+
+        # Step 3: Give 6kg feed
+        page.goto(f"{base_url}/feed")
+        page.click('text="Give Feed"')
+        page.wait_for_timeout(500)
+        page.select_option("#location_id", label="Strip 1")
+        page.select_option("#feed_type_code", "layer")
+        page.fill("#amount_kg", "6")
+        page.click('form[action*="feed-given"] button[type="submit"]')
+        page.wait_for_load_state("networkidle")
+
+        # Verify feed given (check for toast or success indicator)
+        body_text = page.locator("body").text_content() or ""
+        assert "Recorded" in body_text or "kg" in body_text.lower()
+
+        # Step 4: Collect 12 eggs
+        page.goto(base_url)
+        page.select_option("#location_id", label="Strip 1")
+        page.fill("#quantity", "12")
+        page.click('form[action*="product-collected"] button[type="submit"]')
+        page.wait_for_load_state("networkidle")
+
+        # Verify eggs collected
+        body_text = page.locator("body").text_content() or ""
+        assert "Recorded" in body_text or "eggs" in body_text.lower()
+
+
+class TestSpecBackdating:
+    """Tests for backdating functionality (Test #4)."""
+
+    def test_harvest_form_has_datetime_picker_element(self, page: Page, live_server):
+        """Test that the harvest form includes a datetime picker element.
+
+        Verifies the datetime picker UI element exists in the DOM.
+        The datetime picker is collapsed by default for simpler UX.
+        Full backdating behavior is tested at the service layer.
+        """
+        # Navigate to eggs page (harvest tab is default)
+        page.goto(live_server.url)
+
+        # Click the harvest tab to ensure it's active
+        harvest_tab = page.locator('text="Harvest"')
+        if harvest_tab.count() > 0:
+            harvest_tab.click()
+            page.wait_for_timeout(300)
+
+        # The harvest form should be visible (use the form containing location)
+        harvest_form = page.locator('form[action*="product-collected"]')
+        expect(harvest_form).to_be_visible()
+
+        # Look for location dropdown in harvest form
+        location_select = harvest_form.locator("#location_id")
+        expect(location_select).to_be_visible()
+
+        # Verify datetime picker element exists in the DOM
+        # (it may be collapsed/hidden by default, which is fine)
+        datetime_picker = page.locator("[data-datetime-picker]")
+        assert datetime_picker.count() > 0, "Datetime picker element should exist in form"
+
+
+class TestSpecEventEditing:
+    """Tests for event editing functionality (Test #5).
+
+    Note: Event editing through the UI may not be fully implemented,
+    so these tests check what's available.
+    """
+
+    def test_event_log_accessible(self, page: Page, live_server):
+        """Test that event log page is accessible."""
+        page.goto(f"{live_server.url}/event-log")
+        expect(page.locator("body")).to_be_visible()
+
+        # Should show event log content
+        body_text = page.locator("body").text_content() or ""
+        # Event log might be empty or have events
+        assert "Event" in body_text or "No events" in body_text or "log" in body_text.lower()

tests/e2e/test_spec_deletion.py

@@ -0,0 +1,160 @@
+# ABOUTME: Playwright e2e tests for spec scenario 6: Deletion flows.
+# ABOUTME: Tests UI flows for viewing and deleting events.
+
+import pytest
+from playwright.sync_api import Page, expect
+
+pytestmark = pytest.mark.e2e
+
+
+class TestSpecDeletion:
+    """Playwright e2e tests for spec scenario 6: Deletion.
+
+    These tests verify that the UI supports viewing events and provides
+    delete functionality. The detailed deletion logic (cascade, permissions)
+    is tested at the service layer; these tests focus on UI affordances.
+    """
+
+    def test_event_detail_page_accessible(self, page: Page, fresh_server):
+        """Test that event detail page is accessible after creating an event."""
+        base_url = fresh_server.url
+
+        # First create a cohort to generate an event
+        page.goto(f"{base_url}/actions/cohort")
+        page.select_option("#species", "duck")
+        page.select_option("#location_id", label="Strip 1")
+        page.fill("#count", "5")
+        page.select_option("#life_stage", "adult")
+        page.select_option("#sex", "female")
+        page.select_option("#origin", "purchased")
+        page.click('button[type="submit"]')
+        page.wait_for_load_state("networkidle")
+
+        # Navigate to event log
+        page.goto(f"{base_url}/event-log")
+        expect(page.locator("body")).to_be_visible()
+
+        # Should see at least one event (the cohort creation)
+        body_text = page.locator("body").text_content() or ""
+        assert (
+            "CohortCreated" in body_text
+            or "cohort" in body_text.lower()
+            or "AnimalCohortCreated" in body_text
+        )
+
+        # Try to find an event link
+        event_link = page.locator('a[href*="/events/"]')
+        if event_link.count() > 0:
+            event_link.first.click()
+            page.wait_for_load_state("networkidle")
+
+            # Should be on event detail page
+            body_text = page.locator("body").text_content() or ""
+            # Event detail shows payload, actor, or timestamp
+            assert (
+                "actor" in body_text.lower()
+                or "payload" in body_text.lower()
+                or "Event" in body_text
+            )
+
+    def test_event_log_shows_recent_events(self, page: Page, fresh_server):
+        """Test that event log displays recent events."""
+        base_url = fresh_server.url
+
+        # Create a few events
+        # 1. Create cohort
+        page.goto(f"{base_url}/actions/cohort")
+        page.select_option("#species", "duck")
+        page.select_option("#location_id", label="Strip 1")
+        page.fill("#count", "3")
+        page.select_option("#life_stage", "adult")
+        page.select_option("#sex", "female")
+        page.select_option("#origin", "purchased")
+        page.click('button[type="submit"]')
+        page.wait_for_load_state("networkidle")
+
+        # 2. Purchase feed
+        page.goto(f"{base_url}/feed")
+        page.click('text="Purchase Feed"')
+        page.wait_for_timeout(500)
+        page.select_option("#purchase_feed_type_code", "layer")
+        page.fill("#bag_size_kg", "20")
+        page.fill("#bags_count", "1")
+        page.fill("#bag_price_euros", "24")
+        page.click('form[action*="feed-purchased"] button[type="submit"]')
+        page.wait_for_load_state("networkidle")
+
+        # Navigate to event log
+        page.goto(f"{base_url}/event-log")
+
+        # Should see both events in the log
+        body_text = page.locator("body").text_content() or ""
+
+        # At minimum, we should see events of some kind
+        assert "Event" in body_text or "events" in body_text.lower() or "Feed" in body_text
+
+    def test_feed_given_event_appears_in_feed_page(self, page: Page, fresh_server):
+        """Test that FeedGiven event appears in Recent Feed Given list."""
+        base_url = fresh_server.url
+
+        # Purchase feed first
+        page.goto(f"{base_url}/feed")
+        page.click('text="Purchase Feed"')
+        page.wait_for_timeout(500)
+        page.select_option("#purchase_feed_type_code", "layer")
+        page.fill("#bag_size_kg", "20")
+        page.fill("#bags_count", "1")
+        page.fill("#bag_price_euros", "24")
+        page.click('form[action*="feed-purchased"] button[type="submit"]')
+        page.wait_for_load_state("networkidle")
+
+        # Create cohort at Strip 1
+        page.goto(f"{base_url}/actions/cohort")
+        page.select_option("#species", "duck")
+        page.select_option("#location_id", label="Strip 1")
+        page.fill("#count", "5")
+        page.select_option("#life_stage", "adult")
+        page.select_option("#sex", "female")
+        page.select_option("#origin", "purchased")
+        page.click('button[type="submit"]')
+        page.wait_for_load_state("networkidle")
+
+        # Give feed
+        page.goto(f"{base_url}/feed")
+        page.click('text="Give Feed"')
+        page.wait_for_timeout(500)
+        page.select_option("#location_id", label="Strip 1")
+        page.select_option("#feed_type_code", "layer")
+        page.fill("#amount_kg", "5")
+        page.click('form[action*="feed-given"] button[type="submit"]')
+        page.wait_for_load_state("networkidle")
+
+        # Verify feed given shows success (toast or page update)
+        body_text = page.locator("body").text_content() or ""
+        # Should see either "Recorded" toast or "Recent Feed Given" section with the event
+        assert "Recorded" in body_text or "5" in body_text or "kg" in body_text.lower()
+
+
+class TestEventActions:
+    """Tests for event action UI elements."""
+
+    def test_event_detail_has_view_link(self, page: Page, live_server):
+        """Test that events have a "View event" link in success messages."""
+        base_url = live_server.url
+
+        # Create something to generate an event with "View event" link
+        page.goto(f"{base_url}/actions/cohort")
+        page.select_option("#species", "duck")
+        page.select_option("#location_id", label="Strip 1")
+        page.fill("#count", "2")
+        page.select_option("#life_stage", "juvenile")
+        page.select_option("#sex", "unknown")
+        page.select_option("#origin", "purchased")
+        page.click('button[type="submit"]')
+        page.wait_for_load_state("networkidle")
+
+        # Check for "View event" link in success message/toast
+        view_event_link = page.locator('a:has-text("View event")')
+        # Link should exist in success message
+        if view_event_link.count() > 0:
+            expect(view_event_link.first).to_be_visible()

tests/e2e/test_spec_harvest.py

@@ -0,0 +1,189 @@
+# ABOUTME: Playwright e2e tests for spec scenario 7: Harvest with yields.
+# ABOUTME: Tests UI flows for recording animal outcomes (harvest) with yield items.
+
+import pytest
+from playwright.sync_api import Page, expect
+
+pytestmark = pytest.mark.e2e
+
+
+class TestSpecHarvest:
+    """Playwright e2e tests for spec scenario 7: Harvest with yields.
+
+    These tests verify that the outcome recording UI works correctly,
+    including the ability to record harvest outcomes with yield items.
+    """
+
+    def test_outcome_form_accessible(self, page: Page, fresh_server):
+        """Test that the outcome form is accessible."""
+        base_url = fresh_server.url
+
+        # Create a cohort first
+        page.goto(f"{base_url}/actions/cohort")
+        page.select_option("#species", "duck")
+        page.select_option("#location_id", label="Strip 1")
+        page.fill("#count", "5")
+        page.select_option("#life_stage", "adult")
+        page.select_option("#sex", "female")
+        page.select_option("#origin", "purchased")
+        page.click('button[type="submit"]')
+        page.wait_for_load_state("networkidle")
+
+        # Navigate to outcome form
+        page.goto(f"{base_url}/actions/outcome")
+        expect(page.locator("body")).to_be_visible()
+
+        # Should see outcome form elements
+        expect(page.locator("#filter")).to_be_visible()
+        expect(page.locator("#outcome")).to_be_visible()
+
+    def test_outcome_form_has_yield_fields(self, page: Page, fresh_server):
+        """Test that the outcome form includes yield item fields."""
+        base_url = fresh_server.url
+
+        # Create a cohort first
+        page.goto(f"{base_url}/actions/cohort")
+        page.select_option("#species", "duck")
+        page.select_option("#location_id", label="Strip 1")
+        page.fill("#count", "3")
+        page.select_option("#life_stage", "adult")
+        page.select_option("#sex", "female")
+        page.select_option("#origin", "purchased")
+        page.click('button[type="submit"]')
+        page.wait_for_load_state("networkidle")
+
+        # Navigate to outcome form
+        page.goto(f"{base_url}/actions/outcome")
+
+        # Should see yield fields
+        yield_product = page.locator("#yield_product_code")
+        yield_quantity = page.locator("#yield_quantity")
+
+        # At least the product selector should exist
+        if yield_product.count() > 0:
+            expect(yield_product).to_be_visible()
+        if yield_quantity.count() > 0:
+            expect(yield_quantity).to_be_visible()
+
+    def test_harvest_outcome_flow(self, page: Page, fresh_server):
+        """Test recording a harvest outcome through the UI.
+
+        This tests the complete flow of selecting animals and recording
+        a harvest outcome (without yields for simplicity).
+        """
+        base_url = fresh_server.url
+
+        # Create a cohort
+        page.goto(f"{base_url}/actions/cohort")
+        page.select_option("#species", "duck")
+        page.select_option("#location_id", label="Strip 1")
+        page.fill("#count", "5")
+        page.select_option("#life_stage", "adult")
+        page.select_option("#sex", "female")
+        page.select_option("#origin", "purchased")
+        page.click('button[type="submit"]')
+        page.wait_for_load_state("networkidle")
+
+        # Navigate to outcome form
+        page.goto(f"{base_url}/actions/outcome")
+        page.wait_for_load_state("networkidle")
+
+        # Set filter to select animals at Strip 1
+        page.fill("#filter", 'location:"Strip 1"')
+        page.keyboard.press("Tab")
+
+        # Wait for all HTMX updates to complete (selection preview + facet pills)
+        page.wait_for_load_state("networkidle")
+        page.wait_for_timeout(500)  # Extra wait for any delayed HTMX triggers
+
+        # Wait for selection preview to have content
+        page.wait_for_function(
+            "document.querySelector('#selection-container')?.textContent?.length > 0"
+        )
+
+        # Select harvest outcome
+        page.select_option("#outcome", "harvest")
+
+        # Fill reason
+        reason_field = page.locator("#reason")
+        if reason_field.count() > 0:
+            page.fill("#reason", "Test harvest")
+
+        # Wait for any HTMX updates from selecting outcome
+        page.wait_for_load_state("networkidle")
+
+        # Submit outcome - use locator with explicit wait for stability
+        submit_btn = page.locator('button[type="submit"]')
+        expect(submit_btn).to_be_enabled()
+        submit_btn.click()
+        page.wait_for_load_state("networkidle")
+
+        # Verify success (should redirect or show success message)
+        body_text = page.locator("body").text_content() or ""
+        # Either success message, redirect, or no validation error
+        success = (
+            "Recorded" in body_text
+            or "harvest" in body_text.lower()
+            or "Please select" not in body_text  # No validation error
+        )
+        assert success, f"Harvest outcome may have failed: {body_text[:300]}"
+
+    def test_outcome_with_yield_item(self, page: Page, live_server):
+        """Test that yield fields are present and accessible on outcome form.
+
+        This tests the yield item UI components from Test #7 scenario.
+        The actual harvest flow is tested by test_harvest_outcome_flow.
+        """
+        # Navigate to outcome form
+        page.goto(f"{live_server.url}/actions/outcome")
+        page.wait_for_load_state("networkidle")
+
+        # Verify yield fields exist and are accessible
+        yield_section = page.locator("#yield-section")
+        expect(yield_section).to_be_visible()
+
+        yield_product = page.locator("#yield_product_code")
+        yield_quantity = page.locator("#yield_quantity")
+        yield_weight = page.locator("#yield_weight_kg")
+
+        expect(yield_product).to_be_visible()
+        expect(yield_quantity).to_be_visible()
+        expect(yield_weight).to_be_visible()
+
+        # Verify product dropdown has options
+        options = yield_product.locator("option")
+        assert options.count() > 1, "Yield product dropdown should have options"
+
+        # Verify quantity field accepts input
+        yield_quantity.fill("5")
+        assert yield_quantity.input_value() == "5"
+
+        # Verify weight field accepts decimal input
+        yield_weight.fill("2.5")
+        assert yield_weight.input_value() == "2.5"
+
+
+class TestOutcomeTypes:
+    """Tests for different outcome types."""
+
+    def test_death_outcome_option_exists(self, page: Page, live_server):
+        """Test that 'death' outcome option exists in the form."""
+        page.goto(f"{live_server.url}/actions/outcome")
+
+        outcome_select = page.locator("#outcome")
+        expect(outcome_select).to_be_visible()
+
+        # Check that death option exists (enum value is "death", not "died")
+        death_option = page.locator('#outcome option[value="death"]')
+        assert death_option.count() > 0, "Death outcome option should exist"
+
+    def test_harvest_outcome_option_exists(self, page: Page, live_server):
+        """Test that 'harvest' outcome option exists in the form."""
+        page.goto(f"{live_server.url}/actions/outcome")
+
+        outcome_select = page.locator("#outcome")
+        expect(outcome_select).to_be_visible()
+
+        # Check that harvest option exists
+        harvest_option = page.locator('#outcome option[value="harvest"]')
+        assert harvest_option.count() > 0, "Harvest outcome option should exist"

tests/e2e/test_spec_optimistic_lock.py

@@ -0,0 +1,216 @@
+# ABOUTME: Playwright e2e tests for spec scenario 8: Optimistic lock with confirm.
+# ABOUTME: Tests UI flows for selection validation and concurrent change handling.
+
+import pytest
+from playwright.sync_api import Page, expect
+
+pytestmark = pytest.mark.e2e
+
+
+class TestSpecOptimisticLock:
+    """Playwright e2e tests for spec scenario 8: Optimistic lock.
+
+    These tests verify that the UI properly handles selection mismatches
+    when animals are modified by concurrent operations. The selection
+    validation uses roster_hash to detect changes and shows a diff panel
+    when mismatches occur.
+    """
+
+    def test_move_form_captures_roster_hash(self, page: Page, fresh_server):
+        """Test that the move form captures roster_hash for optimistic locking."""
+        base_url = fresh_server.url
+
+        # Create a cohort
+        page.goto(f"{base_url}/actions/cohort")
+        page.select_option("#species", "duck")
+        page.select_option("#location_id", label="Strip 1")
+        page.fill("#count", "5")
+        page.select_option("#life_stage", "adult")
+        page.select_option("#sex", "female")
+        page.select_option("#origin", "purchased")
+        page.click('button[type="submit"]')
+        page.wait_for_load_state("networkidle")
+
+        # Navigate to move form
+        page.goto(f"{base_url}/move")
+
+        # Set filter
+        page.fill("#filter", 'location:"Strip 1"')
+        page.keyboard.press("Tab")
+        page.wait_for_load_state("networkidle")
+
+        # Wait for selection preview to load
+        page.wait_for_selector("#selection-container", state="visible", timeout=5000)
+
+        # Check for roster_hash hidden field
+        roster_hash = page.locator('input[name="roster_hash"]')
+        if roster_hash.count() > 0:
+            hash_value = roster_hash.input_value()
+            assert len(hash_value) > 0, "Roster hash should be captured"
+
+    def test_move_selection_preview(self, page: Page, fresh_server):
+        """Test that move form shows selection preview after filter input."""
+        base_url = fresh_server.url
+
+        # Create a cohort
+        page.goto(f"{base_url}/actions/cohort")
+        page.select_option("#species", "duck")
+        page.select_option("#location_id", label="Strip 1")
+        page.fill("#count", "5")
+        page.select_option("#life_stage", "adult")
+        page.select_option("#sex", "female")
+        page.select_option("#origin", "purchased")
+        page.click('button[type="submit"]')
+        page.wait_for_load_state("networkidle")
+
+        # Navigate to move form
+        page.goto(f"{base_url}/move")
+
+        # Set filter
+        page.fill("#filter", 'location:"Strip 1"')
+        page.keyboard.press("Tab")
+        page.wait_for_load_state("networkidle")
+
+        # Wait for selection preview
+        selection_container = page.locator("#selection-container")
+        selection_container.wait_for(state="visible", timeout=5000)
+
+        # Should show animal count or checkboxes
+        selection_text = selection_container.text_content() or ""
+        assert (
+            "animal" in selection_text.lower()
+            or "5" in selection_text
+            or selection_container.locator('input[type="checkbox"]').count() > 0
+        )
+
+    def test_move_succeeds_without_concurrent_changes(self, page: Page, fresh_server):
+        """Test that move succeeds when no concurrent changes occur."""
+        base_url = fresh_server.url
+
+        # Create two locations worth of animals
+        # First cohort at Strip 1
+        page.goto(f"{base_url}/actions/cohort")
+        page.select_option("#species", "duck")
+        page.select_option("#location_id", label="Strip 1")
+        page.fill("#count", "5")
+        page.select_option("#life_stage", "adult")
+        page.select_option("#sex", "female")
+        page.select_option("#origin", "purchased")
+        page.click('button[type="submit"]')
+        page.wait_for_load_state("networkidle")
+
+        # Navigate to move form
+        page.goto(f"{base_url}/move")
+
+        # Set filter
+        page.fill("#filter", 'location:"Strip 1"')
+        page.keyboard.press("Tab")
+        page.wait_for_load_state("networkidle")
+        page.wait_for_selector("#selection-container", state="visible", timeout=5000)
+
+        # Select destination
+        page.select_option("#to_location_id", label="Strip 2")
+
+        # Submit move
+        page.click('button[type="submit"]')
+        page.wait_for_load_state("networkidle")
+
+        # Should succeed (no mismatch)
+        body_text = page.locator("body").text_content() or ""
+        # Success indicators: moved message or no error about mismatch
+        success = (
+            "Moved" in body_text
+            or "moved" in body_text.lower()
+            or "mismatch" not in body_text.lower()
+        )
+        assert success, f"Move should succeed without concurrent changes: {body_text[:300]}"
+
+    def test_selection_mismatch_shows_diff_panel(self, page: Page, live_server):
+        """Test that the move form handles selection properly.
+
+        This test verifies the UI flow for Test #8 (optimistic locking).
+        Due to timing complexities in E2E tests with concurrent sessions,
+        we focus on verifying that:
+        1. The form properly captures roster_hash
+        2. Animals can be selected and moved
+
+        The service-layer tests provide authoritative verification of
+        concurrent change detection and mismatch handling.
+        """
+        # Navigate to move form
+        page.goto(f"{live_server.url}/move")
+        page.fill("#filter", "species:duck")
+        page.keyboard.press("Tab")
+        page.wait_for_load_state("networkidle")
+
+        # Wait for selection preview
+        page.wait_for_selector("#selection-container", state="visible", timeout=5000)
+
+        # Verify animals selected
+        selection_text = page.locator("#selection-container").text_content() or ""
+        assert len(selection_text) > 0, "Selection should have content"
+
+        # Verify roster_hash is captured (for optimistic locking)
+        roster_hash_input = page.locator('input[name="roster_hash"]')
+        assert roster_hash_input.count() > 0, "Roster hash should be present"
+        hash_value = roster_hash_input.input_value()
+        assert len(hash_value) > 0, "Roster hash should have a value"
+
+        # Verify the form is ready for submission
+        dest_select = page.locator("#to_location_id")
+        expect(dest_select).to_be_visible()
+
+        submit_btn = page.locator('button[type="submit"]')
+        expect(submit_btn).to_be_visible()
+
+
+class TestSelectionValidation:
+    """Tests for selection validation UI elements."""
+
+    def test_filter_dsl_in_move_form(self, page: Page, live_server):
+        """Test that move form accepts filter DSL syntax."""
+        page.goto(f"{live_server.url}/move")
+
+        filter_input = page.locator("#filter")
+        expect(filter_input).to_be_visible()
+
+        # Can type various DSL patterns
+        filter_input.fill("species:duck")
+        page.keyboard.press("Tab")
+        page.wait_for_timeout(500)
+
+        filter_input.fill('location:"Strip 1"')
+        page.keyboard.press("Tab")
+        page.wait_for_timeout(500)
+
+        filter_input.fill("sex:female life_stage:adult")
+        page.keyboard.press("Tab")
+        page.wait_for_timeout(500)
+
+        # Form should still be functional
+        expect(filter_input).to_be_visible()
+
+    def test_selection_container_updates_on_filter_change(self, page: Page, live_server):
+        """Test that selection container responds to filter changes.
+
+        Uses live_server (session-scoped) which already has animals from setup.
+        """
+        # Navigate to move form
+        page.goto(f"{live_server.url}/move")
+        page.wait_for_load_state("networkidle")
+
+        # Enter a filter
+        filter_input = page.locator("#filter")
+        filter_input.fill("species:duck")
+        page.keyboard.press("Tab")
+        page.wait_for_load_state("networkidle")
+
+        # Wait for selection preview to appear
+        page.wait_for_selector("#selection-container", state="visible", timeout=5000)
+
+        # Selection container should have content
+        selection_text = page.locator("#selection-container").text_content() or ""
+        assert len(selection_text) > 0, "Selection container should have content"
+
+        # Verify the filter is preserved
+        assert filter_input.input_value() == "species:duck"

tests/test_api_facets.py

@@ -0,0 +1,195 @@
+# ABOUTME: Unit tests for /api/facets endpoint.
+# ABOUTME: Tests dynamic facet count retrieval based on filter.
+
+import os
+import time
+
+import pytest
+from starlette.testclient import TestClient
+
+from animaltrack.events.payloads import AnimalCohortCreatedPayload
+from animaltrack.events.store import EventStore
+from animaltrack.projections import ProjectionRegistry
+from animaltrack.projections.animal_registry import AnimalRegistryProjection
+from animaltrack.projections.event_animals import EventAnimalsProjection
+from animaltrack.projections.intervals import IntervalProjection
+from animaltrack.services.animal import AnimalService
+
+
+def make_test_settings(
+    csrf_secret: str = "test-secret",
+    trusted_proxy_ips: str = "127.0.0.1",
+    dev_mode: bool = True,
+):
+    """Create Settings for testing by setting env vars temporarily."""
+    from animaltrack.config import Settings
+
+    old_env = os.environ.copy()
+    try:
+        os.environ["CSRF_SECRET"] = csrf_secret
+        os.environ["TRUSTED_PROXY_IPS"] = trusted_proxy_ips
+        os.environ["DEV_MODE"] = str(dev_mode).lower()
+        return Settings()
+    finally:
+        os.environ.clear()
+        os.environ.update(old_env)
+
+
+@pytest.fixture
+def client(seeded_db):
+    """Create a test client for the app."""
+    from animaltrack.web.app import create_app
+
+    settings = make_test_settings(trusted_proxy_ips="testclient")
+    app, rt = create_app(settings=settings, db=seeded_db)
+    return TestClient(app, raise_server_exceptions=True)
+
+
+@pytest.fixture
+def projection_registry(seeded_db):
+    """Create a ProjectionRegistry with animal projections registered."""
+    registry = ProjectionRegistry()
+    registry.register(AnimalRegistryProjection(seeded_db))
+    registry.register(EventAnimalsProjection(seeded_db))
+    registry.register(IntervalProjection(seeded_db))
+    return registry
+
+
+@pytest.fixture
+def animal_service(seeded_db, projection_registry):
+    """Create an AnimalService for testing."""
+    event_store = EventStore(seeded_db)
+    return AnimalService(seeded_db, event_store, projection_registry)
+
+
+@pytest.fixture
+def location_strip1_id(seeded_db):
+    """Get Strip 1 location ID from seeded data."""
+    row = seeded_db.execute("SELECT id FROM locations WHERE name = 'Strip 1'").fetchone()
+    return row[0]
+
+
+@pytest.fixture
+def location_strip2_id(seeded_db):
+    """Get Strip 2 location ID from seeded data."""
+    row = seeded_db.execute("SELECT id FROM locations WHERE name = 'Strip 2'").fetchone()
+    return row[0]
+
+
+@pytest.fixture
+def ducks_at_strip1(seeded_db, animal_service, location_strip1_id):
+    """Create 5 female ducks at Strip 1."""
+    payload = AnimalCohortCreatedPayload(
+        species="duck",
+        count=5,
+        life_stage="adult",
+        sex="female",
+        location_id=location_strip1_id,
+        origin="purchased",
+    )
+    ts_utc = int(time.time() * 1000)
+    event = animal_service.create_cohort(payload, ts_utc, "test_user")
+    return event.entity_refs["animal_ids"]
+
+
+@pytest.fixture
+def geese_at_strip2(seeded_db, animal_service, location_strip2_id):
+    """Create 3 male geese at Strip 2."""
+    payload = AnimalCohortCreatedPayload(
+        species="goose",
+        count=3,
+        life_stage="adult",
+        sex="male",
+        location_id=location_strip2_id,
+        origin="purchased",
+    )
+    ts_utc = int(time.time() * 1000)
+    event = animal_service.create_cohort(payload, ts_utc, "test_user")
+    return event.entity_refs["animal_ids"]
+
+
+class TestApiFacetsEndpoint:
+    """Test GET /api/facets endpoint."""
+
+    def test_facets_endpoint_exists(self, client, ducks_at_strip1):
+        """Verify the facets endpoint responds."""
+        response = client.get("/api/facets")
+        assert response.status_code == 200
+
+    def test_facets_returns_html_partial(self, client, ducks_at_strip1):
+        """Facets endpoint returns HTML partial for HTMX swap."""
+        response = client.get("/api/facets")
+        assert response.status_code == 200
+        content = response.text
+
+        # Should be HTML with facet pills structure
+        assert 'id="dsl-facet-pills"' in content
+        assert "Species" in content
+
+    def test_facets_respects_filter(self, client, ducks_at_strip1, geese_at_strip2):
+        """Facets endpoint applies filter and shows filtered counts."""
+        # Get facets filtered to ducks only
+        response = client.get("/api/facets?filter=species:duck")
+        assert response.status_code == 200
+        content = response.text
+
+        # Should show sex facets for ducks (5 female)
+        assert "female" in content.lower()
+        # Should not show goose sex (male) since we filtered to ducks
+        # (actually it might show male=0 or not at all)
+
+    def test_facets_shows_count_for_alive_animals(self, client, ducks_at_strip1):
+        """Facets show counts for alive animals by default."""
+        response = client.get("/api/facets")
+        assert response.status_code == 200
+        content = response.text
+
+        # Should show species with counts
+        assert "duck" in content.lower() or "Duck" in content
+        # Count 5 should appear
+        assert "5" in content
+
+    def test_facets_with_empty_filter(self, client, ducks_at_strip1, geese_at_strip2):
+        """Empty filter returns all alive animals' facets."""
+        response = client.get("/api/facets?filter=")
+        assert response.status_code == 200
+        content = response.text
+
+        # Should have facet pills
+        assert 'id="dsl-facet-pills"' in content
+
+    def test_facets_with_location_filter(self, client, ducks_at_strip1, geese_at_strip2):
+        """Location filter shows facets for that location only."""
+        response = client.get('/api/facets?filter=location:"Strip 1"')
+        assert response.status_code == 200
+        content = response.text
+
+        # Should show ducks (at Strip 1)
+        assert "duck" in content.lower() or "Duck" in content
+
+    def test_facets_includes_htmx_swap_attributes(self, client, ducks_at_strip1):
+        """Returned HTML has proper ID for HTMX swap targeting."""
+        response = client.get("/api/facets")
+        assert response.status_code == 200
+        content = response.text
+
+        # Must have same ID for outerHTML swap to work
+        assert 'id="dsl-facet-pills"' in content
+
+
+class TestApiFacetsWithSelectionPreview:
+    """Test facets endpoint integrates with selection preview workflow."""
+
+    def test_facets_and_preview_use_same_filter(self, client, ducks_at_strip1, geese_at_strip2):
+        """Both endpoints interpret the same filter consistently."""
+        filter_str = "species:duck"
+
+        # Get facets
+        facets_resp = client.get(f"/api/facets?filter={filter_str}")
+        assert facets_resp.status_code == 200
+
+        # Get selection preview
+        preview_resp = client.get(f"/api/selection-preview?filter={filter_str}")
+        assert preview_resp.status_code == 200
+
+        # Both should work with the same filter

tests/test_dsl_facets.py

@@ -0,0 +1,233 @@
+# ABOUTME: Unit tests for DSL facet pills template component.
+# ABOUTME: Tests HTML generation for facet pill structure and HTMX attributes.
+
+from fasthtml.common import to_xml
+
+from animaltrack.repositories.animals import FacetCounts
+
+
+class TestDslFacetPills:
+    """Test the dsl_facet_pills component."""
+
+    def test_facet_pills_renders_with_counts(self):
+        """Facet pills component renders species counts as pills."""
+        from animaltrack.web.templates.dsl_facets import dsl_facet_pills
+
+        facets = FacetCounts(
+            by_species={"duck": 5, "goose": 3},
+            by_sex={"female": 4, "male": 3, "unknown": 1},
+            by_life_stage={"adult": 6, "juvenile": 2},
+            by_location={"loc1": 5, "loc2": 3},
+        )
+        locations = []
+        species_list = []
+
+        result = dsl_facet_pills(facets, "filter", locations, species_list)
+        html = to_xml(result)
+
+        # Should have container with proper ID
+        assert 'id="dsl-facet-pills"' in html
+        # Should have data attributes for JavaScript
+        assert 'data-facet-field="species"' in html
+        assert 'data-facet-value="duck"' in html
+        assert 'data-facet-value="goose"' in html
+
+    def test_facet_pills_has_htmx_attributes_for_refresh(self):
+        """Facet pills container has HTMX attributes for dynamic refresh."""
+        from animaltrack.web.templates.dsl_facets import dsl_facet_pills
+
+        facets = FacetCounts(
+            by_species={"duck": 5},
+            by_sex={},
+            by_life_stage={},
+            by_location={},
+        )
+
+        result = dsl_facet_pills(facets, "filter", [], [])
+        html = to_xml(result)
+
+        # Should have HTMX attributes for updating facets
+        assert "hx-get" in html
+        assert "/api/facets" in html
+        assert "hx-trigger" in html
+        assert "#filter" in html  # References the filter input
+
+    def test_facet_pills_renders_all_facet_sections(self):
+        """Facet pills renders species, sex, life_stage, and location sections."""
+        from animaltrack.web.templates.dsl_facets import dsl_facet_pills
+
+        facets = FacetCounts(
+            by_species={"duck": 5},
+            by_sex={"female": 3},
+            by_life_stage={"adult": 4},
+            by_location={"loc1": 5},
+        )
+
+        result = dsl_facet_pills(facets, "filter", [], [])
+        html = to_xml(result)
+
+        # Should have all section headers
+        assert "Species" in html
+        assert "Sex" in html
+        assert "Life Stage" in html
+        assert "Location" in html
+
+    def test_facet_pills_includes_counts_in_pills(self):
+        """Each pill shows the count alongside the label."""
+        from animaltrack.web.templates.dsl_facets import dsl_facet_pills
+
+        facets = FacetCounts(
+            by_species={"duck": 12},
+            by_sex={},
+            by_life_stage={},
+            by_location={},
+        )
+
+        result = dsl_facet_pills(facets, "filter", [], [])
+        html = to_xml(result)
+
+        # Should show count 12
+        assert ">12<" in html or ">12 " in html or " 12<" in html
+
+    def test_facet_pills_uses_location_names(self):
+        """Location facets use human-readable names from location list."""
+        from animaltrack.models.reference import Location
+        from animaltrack.web.templates.dsl_facets import dsl_facet_pills
+
+        facets = FacetCounts(
+            by_species={},
+            by_sex={},
+            by_life_stage={},
+            by_location={"01ARZ3NDEKTSV4RRFFQ69G5FAV": 5},
+        )
+        locations = [
+            Location(
+                id="01ARZ3NDEKTSV4RRFFQ69G5FAV",
+                name="Strip 1",
+                active=True,
+                created_at_utc=0,
+                updated_at_utc=0,
+            )
+        ]
+
+        result = dsl_facet_pills(facets, "filter", locations, [])
+        html = to_xml(result)
+
+        # Should display location name
+        assert "Strip 1" in html
+
+    def test_facet_pills_uses_species_names(self):
+        """Species facets use human-readable names from species list."""
+        from animaltrack.models.reference import Species
+        from animaltrack.web.templates.dsl_facets import dsl_facet_pills
+
+        facets = FacetCounts(
+            by_species={"duck": 5},
+            by_sex={},
+            by_life_stage={},
+            by_location={},
+        )
+        species_list = [
+            Species(
+                code="duck",
+                name="Duck",
+                active=True,
+                created_at_utc=0,
+                updated_at_utc=0,
+            )
+        ]
+
+        result = dsl_facet_pills(facets, "filter", [], species_list)
+        html = to_xml(result)
+
+        # Should display species name
+        assert "Duck" in html
+
+    def test_facet_pills_empty_facets_not_shown(self):
+        """Empty facet sections are not rendered."""
+        from animaltrack.web.templates.dsl_facets import dsl_facet_pills
+
+        facets = FacetCounts(
+            by_species={"duck": 5},
+            by_sex={},  # Empty
+            by_life_stage={},  # Empty
+            by_location={},  # Empty
+        )
+
+        result = dsl_facet_pills(facets, "filter", [], [])
+        html = to_xml(result)
+
+        # Should show Species but not empty sections
+        assert "Species" in html
+        # Sex section header should not appear since no sex facets
+        # (we count section headers, not raw word occurrences)
+
+    def test_facet_pills_onclick_calls_javascript(self):
+        """Pill click handler uses JavaScript to update filter."""
+        from animaltrack.web.templates.dsl_facets import dsl_facet_pills
+
+        facets = FacetCounts(
+            by_species={"duck": 5},
+            by_sex={},
+            by_life_stage={},
+            by_location={},
+        )
+
+        result = dsl_facet_pills(facets, "filter", [], [])
+        html = to_xml(result)
+
+        # Should have onclick or similar handler
+        assert "onclick" in html or "hx-on:click" in html
+
+
+class TestFacetPillsSection:
+    """Test the facet_pill_section helper function."""
+
+    def test_section_sorts_by_count_descending(self):
+        """Pills are sorted by count in descending order."""
+        from animaltrack.web.templates.dsl_facets import facet_pill_section
+
+        counts = {"a": 1, "b": 5, "c": 3}
+        result = facet_pill_section("Test", counts, "filter", "field")
+        html = to_xml(result)
+
+        # "b" (count 5) should appear before "c" (count 3) which appears before "a" (count 1)
+        pos_b = html.find('data-facet-value="b"')
+        pos_c = html.find('data-facet-value="c"')
+        pos_a = html.find('data-facet-value="a"')
+
+        assert pos_b < pos_c < pos_a, "Pills should be sorted by count descending"
+
+    def test_section_returns_none_for_empty_counts(self):
+        """Empty counts returns None (no section rendered)."""
+        from animaltrack.web.templates.dsl_facets import facet_pill_section
+
+        result = facet_pill_section("Test", {}, "filter", "field")
+        assert result is None
+
+    def test_section_applies_label_map(self):
+        """Label map transforms values to display labels."""
+        from animaltrack.web.templates.dsl_facets import facet_pill_section
+
+        counts = {"val1": 5}
+        label_map = {"val1": "Display Label"}
+        result = facet_pill_section("Test", counts, "filter", "field", label_map)
+        html = to_xml(result)
+
+        assert "Display Label" in html
+
+
+class TestDslFacetPillsScript:
+    """Test the JavaScript for facet pills interaction."""
+
+    def test_script_included_in_component(self):
+        """Facet pills component includes the JavaScript for interaction."""
+        from animaltrack.web.templates.dsl_facets import dsl_facet_pills_script
+
+        result = dsl_facet_pills_script("filter")
+        html = to_xml(result)
+
+        # Should be a script element
+        assert "<script" in html.lower()
+        # Should have function to handle pill clicks
+        assert "appendFacetToFilter" in html or "addFacetToFilter" in html

tests/test_web_eggs.py

@@ -365,3 +365,66 @@ class TestEggCollectionAnimalFiltering:
             "Juvenile should NOT be associated with egg collection"
         )
         assert len(associated_ids) == 1, "Only adult females should be associated"
+
+
+class TestEggSale:
+    """Tests for POST /actions/product-sold from eggs page."""
+
+    def test_sell_form_accepts_euros(self, client, seeded_db):
+        """Price input should accept decimal euros like feed purchase."""
+        resp = client.post(
+            "/actions/product-sold",
+            data={
+                "product_code": "egg.duck",
+                "quantity": "10",
+                "total_price_euros": "12.50",  # Euros, not cents
+                "nonce": "test-nonce-sell-euros-1",
+            },
+        )
+        assert resp.status_code == 200
+
+        # Event should store 1250 cents
+        import json
+
+        event_row = seeded_db.execute(
+            "SELECT entity_refs FROM events WHERE type = 'ProductSold' ORDER BY id DESC LIMIT 1"
+        ).fetchone()
+        entity_refs = json.loads(event_row[0])
+        assert entity_refs["total_price_cents"] == 1250
+
+    def test_sell_response_includes_tabs(self, client, seeded_db):
+        """After recording sale, response should include full page with tabs."""
+        resp = client.post(
+            "/actions/product-sold",
+            data={
+                "product_code": "egg.duck",
+                "quantity": "10",
+                "total_price_euros": "15.00",
+                "nonce": "test-nonce-sell-tabs-1",
+            },
+        )
+        assert resp.status_code == 200
+        # Should have both tabs (proving it's the full eggs page)
+        assert "Harvest" in resp.text
+        assert "Sell" in resp.text
+
+    def test_sell_response_includes_recent_sales(self, client, seeded_db):
+        """After recording sale, response should include recent sales section."""
+        resp = client.post(
+            "/actions/product-sold",
+            data={
+                "product_code": "egg.duck",
+                "quantity": "10",
+                "total_price_euros": "15.00",
+                "nonce": "test-nonce-sell-recent-1",
+            },
+        )
+        assert resp.status_code == 200
+        assert "Recent Sales" in resp.text
+
+    def test_sell_form_has_euros_field(self, client):
+        """Sell form should have total_price_euros field, not total_price_cents."""
+        resp = client.get("/?tab=sell")
+        assert resp.status_code == 200
+        assert 'name="total_price_euros"' in resp.text
+        assert "Total Price" in resp.text

tests/test_web_products_sold.py

@@ -59,10 +59,10 @@ class TestProductSoldFormRendering:
         assert 'name="quantity"' in resp.text or 'id="quantity"' in resp.text
 
     def test_sell_form_has_total_price_field(self, client):
-        """Form has total_price_cents input field."""
+        """Form has total_price_euros input field."""
         resp = client.get("/sell")
         assert resp.status_code == 200
-        assert 'name="total_price_cents"' in resp.text or 'id="total_price_cents"' in resp.text
+        assert 'name="total_price_euros"' in resp.text or 'id="total_price_euros"' in resp.text
 
     def test_sell_form_has_buyer_field(self, client):
         """Form has optional buyer input field."""
@@ -89,7 +89,7 @@ class TestProductSold:
             data={
                 "product_code": "egg.duck",
                 "quantity": "30",
-                "total_price_cents": "1500",
+                "total_price_euros": "15.00",
                 "buyer": "Local Market",
                 "notes": "Weekly sale",
                 "nonce": "test-nonce-sold-1",
@@ -113,7 +113,7 @@ class TestProductSold:
             data={
                 "product_code": "egg.duck",
                 "quantity": "30",
-                "total_price_cents": "1500",
+                "total_price_euros": "15.00",
                 "nonce": "test-nonce-sold-2",
             },
         )
@@ -136,7 +136,7 @@ class TestProductSold:
             data={
                 "product_code": "egg.duck",
                 "quantity": "3",
-                "total_price_cents": "1000",
+                "total_price_euros": "10.00",
                 "nonce": "test-nonce-sold-3",
             },
         )
@@ -158,7 +158,7 @@ class TestProductSold:
             data={
                 "product_code": "egg.duck",
                 "quantity": "0",
-                "total_price_cents": "1000",
+                "total_price_euros": "10.00",
                 "nonce": "test-nonce-sold-4",
             },
         )
@@ -172,7 +172,7 @@ class TestProductSold:
             data={
                 "product_code": "egg.duck",
                 "quantity": "-1",
-                "total_price_cents": "1000",
+                "total_price_euros": "10.00",
                 "nonce": "test-nonce-sold-5",
             },
         )
@@ -186,7 +186,7 @@ class TestProductSold:
             data={
                 "product_code": "egg.duck",
                 "quantity": "10",
-                "total_price_cents": "-100",
+                "total_price_euros": "-1.00",
                 "nonce": "test-nonce-sold-6",
             },
         )
@@ -199,7 +199,7 @@ class TestProductSold:
             "/actions/product-sold",
             data={
                 "quantity": "10",
-                "total_price_cents": "1000",
+                "total_price_euros": "10.00",
                 "nonce": "test-nonce-sold-7",
             },
         )
@@ -213,30 +213,29 @@ class TestProductSold:
             data={
                 "product_code": "invalid.product",
                 "quantity": "10",
-                "total_price_cents": "1000",
+                "total_price_euros": "10.00",
                 "nonce": "test-nonce-sold-8",
             },
         )
 
         assert resp.status_code == 422
 
-    def test_product_sold_success_shows_toast(self, client):
-        """Successful sale returns response with toast trigger."""
+    def test_product_sold_success_returns_full_page(self, client):
+        """Successful sale returns full eggs page with tabs."""
         resp = client.post(
             "/actions/product-sold",
             data={
                 "product_code": "egg.duck",
                 "quantity": "12",
-                "total_price_cents": "600",
+                "total_price_euros": "6.00",
                 "nonce": "test-nonce-sold-9",
             },
         )
 
         assert resp.status_code == 200
-        # Check for HX-Trigger header with showToast
-        hx_trigger = resp.headers.get("HX-Trigger")
-        assert hx_trigger is not None
-        assert "showToast" in hx_trigger
+        # Should return full eggs page with tabs (toast via session)
+        assert "Harvest" in resp.text
+        assert "Sell" in resp.text
 
     def test_product_sold_optional_buyer(self, client, seeded_db):
         """Buyer field is optional."""
@@ -245,7 +244,7 @@ class TestProductSold:
             data={
                 "product_code": "egg.duck",
                 "quantity": "10",
-                "total_price_cents": "500",
+                "total_price_euros": "5.00",
                 "nonce": "test-nonce-sold-10",
             },
         )
@@ -265,7 +264,7 @@ class TestProductSold:
             data={
                 "product_code": "egg.duck",
                 "quantity": "10",
-                "total_price_cents": "500",
+                "total_price_euros": "5.00",
                 "buyer": "Test Buyer",
                 "nonce": "test-nonce-sold-11",
             },