Function sync_daily_notes_from_reports

agents/reading-agent/main.py:2202–2248

Create or refresh Daily Notes from existing reading-report records.

(
    *,
    user_id: str,
    reports: Iterable[Dict[str, Any]],
)

def sync_daily_notes_from_reports(
    *,
    user_id: str,
    reports: Iterable[Dict[str, Any]],
) -> Dict[str, Any]:
    """Create or refresh Daily Notes from existing reading-report records."""
    scanned = 0
    synced = 0
    daily_notes: List[str] = []
    report_paths: List[str] = []
    errors: List[str] = []

    for report in reports or []:
        scanned += 1
        metadata = dict(report.get("metadata") or {})
        report_user = _clean_text(metadata.get("user_id") or report.get("user_id"))
        if user_id and report_user and report_user != user_id:
            continue
        report_content = str(report.get("markdown") or "")
        if not report_content.strip():
            continue
        paper = _report_paper_from_metadata(metadata, report)
        payload = _report_payload_from_metadata(metadata, report_content, report)
        try:
            saved_path = _save_reading_report_markdown(
                user_id=user_id or report_user,
                paper=paper,
                report_content=report_content,
                report_payload=payload,
                doc_url=metadata.get("doc_url") or report.get("doc_url"),
                doc_token=metadata.get("doc_token") or report.get("doc_token"),
            )
            synced += 1
            report_paths.append(saved_path)
            daily_note = _obsidian_daily_note_path(Path(saved_path), paper)
            if daily_note is not None:
                daily_notes.append(str(daily_note))
        except Exception as exc:
            errors.append(f"{paper.get('title') or report.get('report_path')}: {exc}")

    return {
        "scanned": scanned,
        "synced": synced,
        "daily_notes": sorted(set(daily_notes)),
        "report_paths": sorted(set(report_paths)),
        "errors": errors[:8],
    }


def refresh_daily_note_files(