Interface TranscriptSource

src/sessions/source.rs:99–122

A pluggable transcript provider. Implementors locate their transcript files for a project and parse only the content appended/changed since the last run. The shared [`ingest_source`] driver handles offset persistence and idempotent session/message upserts. `Send + Sync` is required so boxed sources can be driven from detached background tasks (e.g. the serve-side startup sweep).

/// `Send + Sync` is required so boxed sources can be driven from detached
/// background tasks (e.g. the serve-side startup sweep).
pub trait TranscriptSource: Send + Sync {
    /// Stable provider id stored on every session/message row (e.g. `"claude"`).
    fn provider(&self) -> &'static str;

    /// Candidate transcript files to consider for `project_root`. May scan
    /// per-project and/or OS-specific global directories. Non-existent paths
    /// are tolerated by the driver.
    fn transcript_paths(&self, project_root: &Path) -> Vec<PathBuf>;

    /// Parse only the new content of `path` given the previously stored cursor.
    ///
    /// Returns `None` to mean "ingest nothing and do not advance the cursor"
    /// (unreadable file, hot-path byte cap exceeded, or the transcript does not
    /// belong to `project_root`). Returns `Some` with a possibly-empty message
    /// list otherwise; an empty list still advances the cursor (e.g. only
    /// non-message lines were appended).
    fn parse_new(
        &self,
        path: &Path,
        prev: StoredCursor,
        project_root: &Path,
        max_new_bytes: Option<u64>,
    ) -> Option<ParsedTranscript>;
}

/// Drive a single source to completion against `db`, ingesting every transcript
/// it locates for `project_root`. Fail-open: per-file errors are swallowed.