**Phase 194 — final verification pass: all green.**
**Verified (all 5 tasks already complete; nothing re-implemented needed)**
- `app/rag/importer.py`: `_prescan_pending` + `_pending_hash_stmt` (scalar `documents.file_hash`, own session, ONE `asyncio.to_thread` span, REPLACES the stats pre-walk), `on_scan_progress`, `progress` pair = pending position, `0` branch = byte-identical phase-193 walk.
- `app/config.py`/`settings_catalog.py`/`.env.example`: `sync_pending_count=1` + validator; `app/api/sync.py`: `"scan"` phase, `scan_done`/`scan_total` (additive after `files_total`, kept at every terminal), forced/throttled RSS split; `frontend/assets/sources.js`: `fmtSyncPhaseLabel` scan branch first-arm, `fmtSyncLabel` untouched.
**Tests / lint / coverage (exact commands)**
- `uv run pytest --cov=app --cov-report=term-missing` → **4835 passed**, `app/` 99% (7240 stmts / 16 miss), exit 0
- `uv run pytest tests/e2e/test_sync_pending_count.py -v --no-cov` → **8 passed in 150.81s** (phase suite, isolated)
- 14 sync-lineage E2E suites, one pytest process each (`test_sync_remaining_count`, `…_chunk_progress`, `…_progress_box`, `…_peak_memory_visible`, `…_label_mobile`, `…_upload_progress`, `test_archive_upload_sources`, `…_image_progress`, `…_summary_visibility`, `…_status_freshness`, `test_smoke`, `test_fast_path_deferred_content`, `test_sync_session_reset`, `test_sync_git_freeze`) → **all exit 0**
- `uv run ruff check .` → All checks passed; `uv run pyright` → **0 errors**
**Completion criteria** — all met: `N remaining` = predicted change set (E2E arms 1/2/5, first import counts the walk, no-change → no count part); `scan` phase visible + flips to `import`, scan pair reset/kept at terminals (`test_sync_scan_phase.py`); `BOR_SYNC_PENDING_COUNT=0` walk semantics ("7 remaining" arm) + **negative refuses startup naming the field (verified live by importing `app.main`)**; pre-scan off-loop + cancel lands `cancelled` (integration pins); CLI/upload byte-identical (unedited pins green); payload additive (`_PRE_187_STATUS_KEYS | _MEMORY_KEYS | _SCAN_KEYS`); suite green, coverage >90%, lint/types clean.
**Documentation** — 3 fixes: README sync "States" bullet had an **unclosed parenthesis** (pre-existing, 193/194) and the scan-label "total is 0" clause was ambiguous about a `=0` run (it still counts the walk once the import starts); **AGENTS.md rule 17 had a stray `)`** (pre-existing from phase 191). Also verified consistency both directions for all 87 settings ↔ README ↔ `.env.example` ↔ settings catalog, the pages table ↔ `app/main.py` routes, no stale `BOR_` names, and README/AGENTS claims through phase 194.
**Notes/deviations** — no live-infra changes (prod sync knob ships default-on, no deployment touched); no git index/history commands run (all changes left in the working tree for the harness); commit criterion left to the harness as instructed.
**Next pending phase:** none — `.agents/phases/todo/` holds only `194_sync_pending_count`, which is now ready to move to `complete/`.
388 lines
14 KiB
Python
388 lines
14 KiB
Python
"""The admin Settings panel's catalogue (phase 168, task 02).
|
|
|
|
``TODO.md`` L3: "I want an admin panel that can edit anything in .env
|
|
and save it to the database."
|
|
|
|
This module is the single source of truth for what the panel shows and
|
|
what the DB-over-env overlay (``app.core.settings_overlay``) is allowed
|
|
to do with each of the ``Settings`` fields:
|
|
|
|
* :data:`CATALOG` maps every ``Settings`` field name to its
|
|
presentation metadata (``group`` + ``label``) and its capability
|
|
flags:
|
|
|
|
- ``secret`` — write-only (LOCKED A4): the API reports ``has_value``
|
|
(and ``masked=True`` / ``value=None``), never the plaintext; a
|
|
saved value is masked on read.
|
|
- ``restart_required`` — boot-wired (LOCKED A4): the middleware /
|
|
engine / logging / static mount read it once at boot, so the
|
|
override applies on the NEXT boot (the panel shows the badge).
|
|
- ``overridable`` — ``False`` for LOCKED A3's ``database_url``
|
|
(it builds the very engine that would read the override — a
|
|
chicken-and-egg brick) and ``embedding_dim`` (A6 fixes
|
|
``chunks.embedding`` at table-creation; a dim override would
|
|
corrupt retrieval).
|
|
|
|
The panel (task 05) is GENERATED from this catalogue — never
|
|
hand-written — so a new ``Settings`` field appears there only once
|
|
it has a :class:`SettingMeta`; the completeness pin
|
|
(``tests/unit/test_settings_catalog.py``: ``set(CATALOG) ==
|
|
set(Settings.model_fields)``) fails the build the moment a field is
|
|
added without metadata, so it can never silently disappear from the
|
|
panel.
|
|
* :data:`GROUPS` is the display order of the groups — it mirrors
|
|
``app/config.py``'s own section comments (App, HTTP response
|
|
compression / byte budget, UI customization, Database, LLM, Chat
|
|
history, RAG tuning, …).
|
|
* :data:`SECRETS`, :data:`RESTART_REQUIRED` and
|
|
:data:`NON_OVERRIDABLE` are DERIVED from :data:`CATALOG` — never
|
|
re-listed by hand, so they cannot drift.
|
|
|
|
:func:`env_var` keeps the ``BOR_`` prefix a pure presentation concern
|
|
(D1): the stored key is the bare ``Settings`` field name
|
|
(``relevance_threshold``), ``"BOR_" + key.upper()`` is what the panel
|
|
and the API show, and a stored prefix could double up — so it is
|
|
derived, never stored.
|
|
"""
|
|
from __future__ import annotations
|
|
|
|
from dataclasses import dataclass
|
|
|
|
|
|
@dataclass(frozen=True, slots=True)
|
|
class SettingMeta:
|
|
"""One settings field's panel metadata + capability flags."""
|
|
|
|
key: str
|
|
group: str
|
|
label: str
|
|
#: Write-only (LOCKED A4) — masked in responses, ``is_set`` only.
|
|
secret: bool = False
|
|
#: Boot-wired (LOCKED A4) — applies on the next boot.
|
|
restart_required: bool = False
|
|
#: ``False`` = read-only row (LOCKED A3).
|
|
overridable: bool = True
|
|
|
|
|
|
#: The ``BOR_`` prefix is presentation only (D1) — see :func:`env_var`.
|
|
ENV_PREFIX = "BOR_"
|
|
|
|
#: Display order of the groups (mirrors ``app/config.py``'s section
|
|
#: comments); :data:`CATALOG` is keyed in the same order.
|
|
GROUPS: tuple[str, ...] = (
|
|
"App & branding",
|
|
"HTTP & logging",
|
|
"Database",
|
|
"LLM (aipi)",
|
|
"Chat history",
|
|
"Retrieval & honesty",
|
|
"Chunking & embedding",
|
|
"Prompt budgets",
|
|
"Agent tools",
|
|
"Import & sources",
|
|
"Images",
|
|
"PDF",
|
|
"Docs push",
|
|
"Admin & security",
|
|
)
|
|
|
|
#: Every ``Settings`` field, in :data:`GROUPS` display order. Completeness
|
|
#: is pinned by ``tests/unit/test_settings_catalog.py`` (the diff is in
|
|
#: the failure message — a new setting without metadata fails the build).
|
|
CATALOG: dict[str, SettingMeta] = {
|
|
# --- App & branding ---
|
|
"app_name": SettingMeta("app_name", "App & branding", "App name"),
|
|
"app_version": SettingMeta("app_version", "App & branding", "App version"),
|
|
"environment": SettingMeta("environment", "App & branding", "Environment"),
|
|
"input_placeholder": SettingMeta(
|
|
"input_placeholder", "App & branding", "Input placeholder"
|
|
),
|
|
"footer_text": SettingMeta("footer_text", "App & branding", "Footer text"),
|
|
"suggestions": SettingMeta(
|
|
"suggestions", "App & branding", "Suggestions (JSON array)"
|
|
),
|
|
# --- HTTP & logging ---
|
|
"log_level": SettingMeta(
|
|
"log_level", "HTTP & logging", "Log level", restart_required=True
|
|
),
|
|
"log_large_response_bytes": SettingMeta(
|
|
"log_large_response_bytes",
|
|
"HTTP & logging",
|
|
"Log large response bytes",
|
|
),
|
|
"compress_min_bytes": SettingMeta(
|
|
"compress_min_bytes", "HTTP & logging", "Compress min bytes",
|
|
restart_required=True,
|
|
),
|
|
"static_dir": SettingMeta(
|
|
"static_dir", "HTTP & logging", "Static dir", restart_required=True
|
|
),
|
|
# --- Database ---
|
|
"database_url": SettingMeta(
|
|
"database_url", "Database", "Database URL",
|
|
secret=True, overridable=False,
|
|
),
|
|
"db_pool_size": SettingMeta(
|
|
"db_pool_size", "Database", "DB pool size", restart_required=True
|
|
),
|
|
"db_pool_max_overflow": SettingMeta(
|
|
"db_pool_max_overflow", "Database", "DB pool max overflow",
|
|
restart_required=True,
|
|
),
|
|
"db_pool_recycle": SettingMeta(
|
|
"db_pool_recycle", "Database", "DB pool recycle", restart_required=True
|
|
),
|
|
"chat_max_concurrent": SettingMeta(
|
|
"chat_max_concurrent", "Database", "Chat max concurrent"
|
|
),
|
|
# --- LLM (aipi) ---
|
|
"llm_base_url": SettingMeta(
|
|
"llm_base_url", "LLM (aipi)", "LLM base URL"
|
|
),
|
|
"llm_api_key": SettingMeta(
|
|
"llm_api_key", "LLM (aipi)", "LLM API key", secret=True
|
|
),
|
|
"llm_chat_model": SettingMeta(
|
|
"llm_chat_model", "LLM (aipi)", "LLM chat model"
|
|
),
|
|
"llm_embed_model": SettingMeta(
|
|
"llm_embed_model", "LLM (aipi)", "LLM embed model"
|
|
),
|
|
"llm_summary_model": SettingMeta(
|
|
"llm_summary_model", "LLM (aipi)", "LLM summary model"
|
|
),
|
|
"llm_chat_thinking_level": SettingMeta(
|
|
"llm_chat_thinking_level", "LLM (aipi)", "Chat thinking level"
|
|
),
|
|
"llm_summary_thinking_level": SettingMeta(
|
|
"llm_summary_thinking_level", "LLM (aipi)", "Summary thinking level"
|
|
),
|
|
"stream_thinking": SettingMeta(
|
|
"stream_thinking", "LLM (aipi)", "Stream thinking"
|
|
),
|
|
"llm_retries": SettingMeta("llm_retries", "LLM (aipi)", "LLM retries"),
|
|
"llm_retry_delay": SettingMeta(
|
|
"llm_retry_delay", "LLM (aipi)", "LLM retry delay"
|
|
),
|
|
"llm_timeout": SettingMeta("llm_timeout", "LLM (aipi)", "LLM timeout (s)"),
|
|
# --- Chat history ---
|
|
"history_max_turns": SettingMeta(
|
|
"history_max_turns", "Chat history", "History max turns"
|
|
),
|
|
"history_max_chars": SettingMeta(
|
|
"history_max_chars", "Chat history", "History max chars"
|
|
),
|
|
# --- Retrieval & honesty ---
|
|
"embedding_dim": SettingMeta(
|
|
"embedding_dim", "Retrieval & honesty", "Embedding dim",
|
|
overridable=False,
|
|
),
|
|
"top_n_docs": SettingMeta("top_n_docs", "Retrieval & honesty", "Top N docs"),
|
|
"relevance_threshold": SettingMeta(
|
|
"relevance_threshold", "Retrieval & honesty", "Relevance threshold"
|
|
),
|
|
"lexical_support_floor": SettingMeta(
|
|
"lexical_support_floor", "Retrieval & honesty", "Lexical support floor"
|
|
),
|
|
"source_usefulness_floor": SettingMeta(
|
|
"source_usefulness_floor",
|
|
"Retrieval & honesty",
|
|
"Source usefulness floor",
|
|
),
|
|
"related_max_docs": SettingMeta(
|
|
"related_max_docs", "Retrieval & honesty", "Related max docs"
|
|
),
|
|
"suggested_docs": SettingMeta(
|
|
"suggested_docs", "Retrieval & honesty", "Suggested docs"
|
|
),
|
|
"suggestion_preview_chars": SettingMeta(
|
|
"suggestion_preview_chars",
|
|
"Retrieval & honesty",
|
|
"Suggestion preview chars",
|
|
),
|
|
"hybrid_vector_candidates": SettingMeta(
|
|
"hybrid_vector_candidates",
|
|
"Retrieval & honesty",
|
|
"Hybrid vector candidates",
|
|
),
|
|
"retrieval_ef_search": SettingMeta(
|
|
"retrieval_ef_search", "Retrieval & honesty", "Vector ef_search"
|
|
),
|
|
"hybrid_lexical_candidates": SettingMeta(
|
|
"hybrid_lexical_candidates",
|
|
"Retrieval & honesty",
|
|
"Hybrid lexical candidates",
|
|
),
|
|
"rrf_k": SettingMeta("rrf_k", "Retrieval & honesty", "RRF k"),
|
|
"recency_boost": SettingMeta(
|
|
"recency_boost", "Retrieval & honesty", "Recency boost"
|
|
),
|
|
"recency_half_life_days": SettingMeta(
|
|
"recency_half_life_days",
|
|
"Retrieval & honesty",
|
|
"Recency half-life days",
|
|
),
|
|
"name_hit_bonus": SettingMeta(
|
|
"name_hit_bonus", "Retrieval & honesty", "Name hit bonus"
|
|
),
|
|
# Phase 191 (D3): the second, independent selection bonus — the SAME
|
|
# live shape as name_hit_bonus (the selection walk reads
|
|
# get_settings() per turn, so a saved override applies on the next
|
|
# question).
|
|
"source_name_hit_bonus": SettingMeta(
|
|
"source_name_hit_bonus", "Retrieval & honesty", "Source name hit bonus"
|
|
),
|
|
# --- Chunking & embedding ---
|
|
"chunk_target_chars": SettingMeta(
|
|
"chunk_target_chars", "Chunking & embedding", "Chunk target chars"
|
|
),
|
|
"chunk_overlap_chars": SettingMeta(
|
|
"chunk_overlap_chars", "Chunking & embedding", "Chunk overlap chars"
|
|
),
|
|
"embed_batch_size": SettingMeta(
|
|
"embed_batch_size", "Chunking & embedding", "Embed batch size"
|
|
),
|
|
"embed_question_max_chars": SettingMeta(
|
|
"embed_question_max_chars",
|
|
"Chunking & embedding",
|
|
"Embed question max chars",
|
|
),
|
|
# --- Prompt budgets ---
|
|
"max_output_tokens": SettingMeta(
|
|
"max_output_tokens", "Prompt budgets", "Max output tokens"
|
|
),
|
|
"steering_max_chars": SettingMeta(
|
|
"steering_max_chars", "Prompt budgets", "Steering max chars"
|
|
),
|
|
"summary_max_chars": SettingMeta(
|
|
"summary_max_chars", "Prompt budgets", "Summary max chars"
|
|
),
|
|
"kb_overview_max_chars": SettingMeta(
|
|
"kb_overview_max_chars", "Prompt budgets", "KB overview max chars"
|
|
),
|
|
"overview_input_max_chars": SettingMeta(
|
|
"overview_input_max_chars",
|
|
"Prompt budgets",
|
|
"Overview input max chars",
|
|
),
|
|
"folder_summary_input_max_chars": SettingMeta(
|
|
"folder_summary_input_max_chars",
|
|
"Prompt budgets",
|
|
"Folder summary input max chars",
|
|
),
|
|
# --- Agent tools ---
|
|
"agent_max_rounds": SettingMeta(
|
|
"agent_max_rounds", "Agent tools", "Agent max rounds"
|
|
),
|
|
"read_max_chars": SettingMeta(
|
|
"read_max_chars", "Agent tools", "Read max chars"
|
|
),
|
|
"answer_text": SettingMeta("answer_text", "Agent tools", "Answer text"),
|
|
"show_text_max_chars": SettingMeta(
|
|
"show_text_max_chars", "Agent tools", "Show text max chars"
|
|
),
|
|
"show_text_max_blocks": SettingMeta(
|
|
"show_text_max_blocks", "Agent tools", "Show text max blocks"
|
|
),
|
|
# --- Import & sources ---
|
|
"import_extensions": SettingMeta(
|
|
"import_extensions", "Import & sources", "Import extensions (CSV)"
|
|
),
|
|
"git_sources": SettingMeta(
|
|
"git_sources", "Import & sources", "Git sources (CSV)"
|
|
),
|
|
"sources_dir": SettingMeta(
|
|
"sources_dir", "Import & sources", "Sources dir"
|
|
),
|
|
"upload_dir": SettingMeta("upload_dir", "Import & sources", "Upload dir"),
|
|
"upload_max_mb": SettingMeta(
|
|
"upload_max_mb", "Import & sources", "Upload max MB"
|
|
),
|
|
"sync_session_reset_files": SettingMeta(
|
|
"sync_session_reset_files", "Import & sources", "Sync session reset files"
|
|
),
|
|
"sync_prune_batch": SettingMeta(
|
|
"sync_prune_batch", "Import & sources", "Sync prune batch"
|
|
),
|
|
"sync_pending_count": SettingMeta(
|
|
"sync_pending_count", "Import & sources", "Sync pending count"
|
|
),
|
|
# --- Images ---
|
|
"images": SettingMeta("images", "Images", "Images"),
|
|
"image_extensions": SettingMeta(
|
|
"image_extensions", "Images", "Image extensions (CSV)"
|
|
),
|
|
"image_dir": SettingMeta("image_dir", "Images", "Image dir"),
|
|
"chat_image_dir": SettingMeta(
|
|
"chat_image_dir", "Images", "Chat image dir"
|
|
),
|
|
"chat_image_max_mb": SettingMeta(
|
|
"chat_image_max_mb", "Images", "Chat image max MB"
|
|
),
|
|
"answer_images": SettingMeta("answer_images", "Images", "Answer images"),
|
|
# --- PDF ---
|
|
"pdf_pictorial": SettingMeta("pdf_pictorial", "PDF", "PDF pictorial"),
|
|
"pdf_pictorial_min_chars": SettingMeta(
|
|
"pdf_pictorial_min_chars", "PDF", "PDF pictorial min chars"
|
|
),
|
|
"pdf_image_skip_blank": SettingMeta(
|
|
"pdf_image_skip_blank", "PDF", "PDF image skip blank"
|
|
),
|
|
"pdf_page_dir": SettingMeta("pdf_page_dir", "PDF", "PDF page dir"),
|
|
# --- Docs push ---
|
|
"docs_repo": SettingMeta("docs_repo", "Docs push", "Docs repo"),
|
|
"docs_user": SettingMeta("docs_user", "Docs push", "Docs user"),
|
|
"docs_token": SettingMeta(
|
|
"docs_token", "Docs push", "Docs token", secret=True
|
|
),
|
|
"docs_branch": SettingMeta("docs_branch", "Docs push", "Docs branch"),
|
|
"docs_base_branch": SettingMeta(
|
|
"docs_base_branch", "Docs push", "Docs base branch"
|
|
),
|
|
"docs_work_dir": SettingMeta("docs_work_dir", "Docs push", "Docs work dir"),
|
|
# --- Admin & security ---
|
|
"admin_password": SettingMeta(
|
|
"admin_password", "Admin & security", "Admin password", secret=True
|
|
),
|
|
"session_secret": SettingMeta(
|
|
"session_secret", "Admin & security", "Session secret",
|
|
secret=True, restart_required=True,
|
|
),
|
|
"session_max_age": SettingMeta(
|
|
"session_max_age", "Admin & security", "Session max age",
|
|
restart_required=True,
|
|
),
|
|
"session_cookie": SettingMeta(
|
|
"session_cookie", "Admin & security", "Session cookie",
|
|
restart_required=True,
|
|
),
|
|
}
|
|
|
|
#: The masked set (LOCKED A4: write-only; ``database_url`` is read-only
|
|
#: but its URL carries credentials, so it is masked too) — derived,
|
|
#: never re-listed by hand.
|
|
SECRETS: frozenset[str] = frozenset(
|
|
key for key, meta in CATALOG.items() if meta.secret
|
|
)
|
|
|
|
#: The boot-wired set (LOCKED A4: logging, the gzip middleware, the
|
|
#: static mount, ``create_engine``, ``SessionMiddleware``) — derived.
|
|
RESTART_REQUIRED: frozenset[str] = frozenset(
|
|
key for key, meta in CATALOG.items() if meta.restart_required
|
|
)
|
|
|
|
#: The read-only set (LOCKED A3) — derived.
|
|
NON_OVERRIDABLE: frozenset[str] = frozenset(
|
|
key for key, meta in CATALOG.items() if not meta.overridable
|
|
)
|
|
|
|
|
|
def env_var(key: str) -> str:
|
|
"""The env var for one bare setting key — presentation only (D1).
|
|
|
|
The stored key is the bare ``Settings`` field name; the ``BOR_``
|
|
form is what the panel and the API show, never what is stored
|
|
(a stored prefix could double up).
|
|
"""
|
|
return ENV_PREFIX + key.upper()
|