Function ingest_source

src/sessions/source.rs:130–141

Drive a single source to completion against `db`, ingesting every transcript it locates for `project_root`. Fail-open: per-file errors are swallowed. `max_new_bytes` bounds how much newly-appended content a byte-offset source will read in one call (used to keep per-prompt hot paths inside budget); pass `None` for an unbounded catch-up.

(
    db: &GlobalDb,
    source: &dyn TranscriptSource,
    project_root: &Path,
    max_new_bytes: Option<u64>,
)

/// will read in one call (used to keep per-prompt hot paths inside budget);
/// pass `None` for an unbounded catch-up.
pub async fn ingest_source(
    db: &GlobalDb,
    source: &dyn TranscriptSource,
    project_root: &Path,
    max_new_bytes: Option<u64>,
) -> TranscriptIngestStats {
    let mut stats = TranscriptIngestStats::default();
    for path in source.transcript_paths(project_root) {
        stats = stats.merge(ingest_one(db, source, &path, project_root, max_new_bytes).await);
    }
    stats
}

/// Ingest one transcript file: load the prior cursor, parse new content, persist
/// the advanced cursor, then upsert the session (merging preserved fields) and