SlabUploader/backend/review.py

"""Review to ready: deterministic title/short description, price suggestion,
ready-gate. Cites REVIEW-5/10/15/20/25/30/40/45/50, METADATA-80/85/90,
SETTINGS-35.

METADATA-80/85: title and short_description are assembled only from the
confirmed (persisted) listing facts — primary wood-category leaf, species,
figure term, and the dimension fact block. Owner-supplied values win
(METADATA-50) via stored fields.
"""
from __future__ import annotations

import json
import re
from datetime import datetime, timezone
from typing import Any

from fastapi import APIRouter
from fastapi.responses import JSONResponse

from .db import get_connection
from .pricing import rate_for_species

router = APIRouter(prefix="/api/v1/slabs")

# Wood-category leaf slug -> (title pattern, noun, carries_dims).
# Patterns interpolate {figure}, {species}, {length}, {width}, {thickness}, {bdft}.
# Figure is a Title-Case adjective; absent figure drops the slot.
_LEAF_PATTERNS = {
    "live-edge-wood": ("{figure}{species} Live Edge Slab", "Live Edge Slab", False),
    "dimensional-wood": ("{figure}{species} {live_edge}Dimensional", "Dimensional", False),
    "knife-blanks": ("{figure}{species} Knife Blank ({dims})", "Knife Blank", True),
    "bowl-blanks": ("{figure}{species} {live_edge}Bowl Blank ({dims})", "Bowl Blank", True),
    "logs-and-caps": ("{figure}{species} Log Cap", "Log Cap", False),
    "pen-blanks": ("{figure}{species} Pen Blank ({dims})", "Pen Blank", True),
    "pepper-mill-blanks": ("{figure}{species} Pepper Mill Blank ({dims})", "Pepper Mill Blank", True),
}

# Required fields for a slab to reach `ready` (REVIEW-5). Measurement fields
# (widths/sqft/bdft) are read-only client math but must be present.
_REQUIRED = [
    "sku", "length_in", "thickness_in", "sqft", "bdft",
    "width_min_in", "width_max_in", "width_avg_in",
    "species_id", "wood_category_ids", "edge_type_term_id",
    "grade_term_id", "thickness_term_id", "moisture_term_id",
    "price", "price_source", "title", "short_description", "description",
    "content_source",
]

# REVIEW-45: 3-24 chars, alphanumerics + hyphen. Middle-tier arbiter; the DB
# CHECK is the backstop.
_SKU_RE = re.compile(r"^[A-Za-z0-9-]{3,24}$")


def _error(code: str, message: str, detail: Any = None) -> dict:
    return {"error": {"code": code, "message": message, "detail": detail}}


def _now() -> str:
    return datetime.now(timezone.utc).replace(microsecond=0, tzinfo=None).isoformat()


def _split_length(length_in: float) -> tuple[int, float]:
    ft = int(length_in // 12)
    rem = round(length_in - ft * 12, 1)
    return ft, rem


def _fmt1(v: float) -> str:
    s = f"{v:.1f}"
    return s[:-2] if s.endswith(".0") else s


def _fmt2(v: float) -> str:
    # 2 dp, trim trailing zeros (thickness carries 1/8-inch precision)
    return f"{v:.2f}".rstrip("0").rstrip(".")


def _dims(length_in: float, width_avg_in: float, thickness_in: float) -> str:
    return f"{_fmt1(length_in)} x {_fmt1(width_avg_in)} x {_fmt2(thickness_in)} in"


def _edge_is_live(edge_term_id: Any, terms: dict) -> bool:
    """True when the synced edge term name/slug indicates live edge.

    METADATA-5 / #98: "Live Edge" is a product-form flag driven by the *synced*
    edge term — never any non-null edge id.
    """
    if not edge_term_id:
        return False
    term = terms.get(edge_term_id) or {}
    blob = f"{term.get('name', '')} {term.get('slug', '')}".lower()
    return "live" in blob


def build_title(slab: dict, figure: str | None, species_name: str, primary_leaf: dict, terms: dict | None = None) -> str:
    pattern, _noun, carries_dims = _LEAF_PATTERNS.get(
        primary_leaf.get("slug"), ("{figure}{species} Slab", "Slab", False)
    )
    figure = (figure or "").strip()
    live_edge = ""
    if primary_leaf.get("slug") in ("dimensional-wood", "bowl-blanks"):
        live_edge = "Live Edge " if _edge_is_live(slab.get("edge_type_term_id"), terms or {}) else ""
    title = pattern.format(
        figure=figure + " " if figure else "",
        species=species_name,
        live_edge=live_edge,
        dims=_dims(slab["length_in"], slab["width_avg_in"], slab["thickness_in"]) if carries_dims else "",
    )
    return re.sub(r"\s+", " ", title).strip()


def build_short_description(slab: dict, figure: str | None, species_name: str, primary_leaf: dict, terms: dict | None = None) -> str:
    title = build_title(slab, figure, species_name, primary_leaf, terms)
    ft, rem = _split_length(slab["length_in"])
    line = (
        f"{title}, {ft}ft {_fmt1(rem)}in x {_fmt1(slab['width_avg_in'])}in x "
        f"{_fmt2(slab['thickness_in'])}in, {_fmt1(round(slab['bdft'], 1))} bdft"
    )
    return re.sub(r"\s+", " ", line).strip()


def _slab_dict(row) -> dict:
    d = dict(row)
    for f in ("wood_category_ids", "figure_term_ids", "fig_tag_ids", "feat_tag_ids"):
        if d.get(f) is not None and isinstance(d[f], str):
            try:
                d[f] = json.loads(d[f])
            except (ValueError, TypeError):
                d[f] = []
    return d


def _taxonomy_lookup(conn) -> tuple[dict, dict]:
    cats = {r["id"]: dict(r) for r in conn.execute("SELECT * FROM woo_categories").fetchall()}
    terms = {r["id"]: dict(r) for r in conn.execute("SELECT * FROM woo_attribute_terms").fetchall()}
    return cats, terms


def missing_required(slab: dict) -> list[str]:
    return [f for f in _REQUIRED if slab.get(f) in (None, "", [])]


def sku_valid(sku: Any) -> bool:
    return isinstance(sku, str) and bool(_SKU_RE.match(sku))


def compute_ready(slab: dict) -> tuple[bool, list[str]]:
    missing = missing_required(slab)
    # A present-but-malformed SKU is not ready (business rule, middle tier).
    if "sku" not in missing and not sku_valid(slab.get("sku")):
        missing.append("sku")
    return len(missing) == 0, missing


def price_suggestion(conn, slab: dict) -> float | None:
    if not slab.get("species_id") or slab.get("bdft") is None:
        return None
    rate = rate_for_species(conn, slab["species_id"])
    if rate is None:
        return None
    return round(slab["bdft"] * rate, 2)


def _resolve_price(conn, slab: dict, payload: dict) -> float | None:
    """REVIEW-25: bdft * species rate as the suggestion; owner override sticks,
    else the stored price, else the suggestion (None if no rate)."""
    suggested = price_suggestion(conn, slab)
    if payload.get("price") is not None:
        return payload["price"]
    if slab.get("price") not in (None, 0):
        return slab["price"]
    return suggested


@router.post("/{slab_id}/review")
async def review_slab(slab_id: str, payload: dict[str, Any] | None = None) -> dict:
    """Compute ready + deterministic title/short_description from *locked*
    taxonomy (#89: the Create button's source of truth).

    Owner overrides (price/sku) from the payload are persisted; title and
    short_description are produced by the deterministic build and are NOT
    persisted from the payload.
    """
    payload = payload or {}
    conn = get_connection()
    row = conn.execute("SELECT * FROM slabs WHERE id=? AND deleted_at IS NULL", (slab_id,)).fetchone()
    if row is None:
        return JSONResponse(status_code=404, content=_error("not_found", "Slab not found"))
    slab = _slab_dict(row)

    cats, terms = _taxonomy_lookup(conn)
    primary_id = payload.get("primary_wood_category_id")
    wood_cats = slab.get("wood_category_ids") or []
    if not primary_id:
        primary_id = wood_cats[0] if wood_cats else None
    primary_leaf = cats.get(primary_id, {}) if primary_id else {}
    species_name = cats.get(slab.get("species_id"), {}).get("name", "") if slab.get("species_id") else ""
    figure_term_ids = slab.get("figure_term_ids") or []
    figure = terms.get(figure_term_ids[0], {}).get("name") if figure_term_ids else None

    # #80: persist owner overrides (price/sku only) so the review is self-contained.
    overrides = {k: payload[k] for k in ("price", "sku") if payload.get(k) is not None}
    if overrides:
        set_clause = ", ".join(f"{k} = ?" for k in overrides)
        conn.execute(
            f"UPDATE slabs SET {set_clause}, server_rev=server_rev+1, updated_at=? WHERE id=?",
            [*overrides.values(), _now(), slab_id],
        )
        conn.commit()
        slab.update(overrides)

    title = (
        build_title(slab, figure, species_name, primary_leaf, terms)
        if (primary_leaf and species_name)
        else slab.get("title") or None
    )
    short_desc = (
        build_short_description(slab, figure, species_name, primary_leaf, terms)
        if (primary_leaf and species_name)
        else slab.get("short_description") or None
    )

    price = _resolve_price(conn, slab, payload)
    ready, missing = compute_ready({**slab, "price": price, "title": title, "short_description": short_desc})
    return {
        "ready": ready, "missing": missing, "title": title, "short_description": short_desc,
        "price": price, "price_suggestion": price_suggestion(conn, slab),
        "primary_wood_category_id": primary_id,
    }