Function _sync_obsidian_daily_note

agents/reading-agent/main.py:2106–2145

(
    *,
    user_id: str,
    paper: Dict[str, Any],
    report_payload: Dict[str, Any],
    report_path: Path,
    report_content: str,
)

def _sync_obsidian_daily_note(
    *,
    user_id: str,
    paper: Dict[str, Any],
    report_payload: Dict[str, Any],
    report_path: Path,
    report_content: str,
) -> Optional[str]:
    daily_note = _obsidian_daily_note_path(report_path, paper)
    if daily_note is None:
        return None
    daily_note.parent.mkdir(parents=True, exist_ok=True)
    category = _daily_note_category(paper, report_payload)
    entry = _daily_note_entry(
        paper=paper,
        report_payload=report_payload,
        report_path=report_path,
        report_content=report_content,
    )
    marker = entry.splitlines()[0]
    current = daily_note.read_text(encoding="utf-8") if daily_note.exists() else ""
    if marker in current:
        current = _remove_daily_note_entry(current, marker) or current
        current = _prune_empty_daily_note_sections(current)
    section_heading = f"# {category}"
    if section_heading not in current:
        current = current.rstrip() + ("\n\n" if current.strip() else "") + section_heading + "\n"
    insert_at = current.find(section_heading) + len(section_heading)
    next_section = current.find("\n# ", insert_at)
    if next_section == -1:
        updated = current.rstrip() + "\n\n" + entry
    else:
        updated = current[:next_section].rstrip() + "\n\n" + entry + "\n" + current[next_section:].lstrip("\n")
    user_profile = _daily_note_user_profile(user_id)
    updated = _refresh_daily_note_topic_summaries(updated, user_profile=user_profile)
    updated = _llm_review_daily_note_categories(updated, user_profile=user_profile)
    updated = _refresh_daily_note_topic_summaries(updated, user_profile=user_profile)
    daily_note.write_text(updated.rstrip() + "\n", encoding="utf-8")
    _sync_obsidian_toc(daily_note)
    return str(daily_note)


def _markdown_section_excerpt(content: str, *headings: str, max_chars: int = 900) -> str: