Function _all_report_records

deployments/desktop/shared/agents.py:751–778

()

        return 10


_REPORT_RECORD_CACHE_LOCK = threading.Lock()
# path -> (mtime_ns, size, parsed record). Parsing a report means reading the
# whole file and extracting frontmatter, and the reports view rescans every
# markdown file under the configured directories on each call: 1752 files and
# 22.8MB in local testing, taking 1.6-2.3s and getting slower as the OS cache
# churns. list_reports, get_report_content and delete_report each triggered a
# full scan, so opening one report paid for two.
_REPORT_RECORD_CACHE: Dict[str, Tuple[int, int, Dict[str, Any]]] = {}


def _cached_report_record(path: Path, resolved_key: str) -> Optional[Dict[str, Any]]:
    """Return the parsed record for path, re-reading only when it changed.

    Keyed on mtime_ns plus size so an edit is always picked up; a stale entry
    would show the user outdated report content, which is worse than the scan
    cost this avoids.
    """
    try:
        stat = path.stat()
    except OSError:
        with _REPORT_RECORD_CACHE_LOCK:
            _REPORT_RECORD_CACHE.pop(resolved_key, None)
        return None

    signature = (stat.st_mtime_ns, stat.st_size)
    with _REPORT_RECORD_CACHE_LOCK:
        cached = _REPORT_RECORD_CACHE.get(resolved_key)
        if cached is not None and cached[0] == signature[0] and cached[1] == signature[1]:
            # deepcopy: callers mutate the record (e.g. _source_priority) and
            # must not corrupt the cached copy.