Function ingest_one

src/sessions/source.rs:146–238

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

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

/// the advanced cursor, then upsert the session (merging preserved fields) and
/// its new messages.
async fn ingest_one(
    db: &GlobalDb,
    source: &dyn TranscriptSource,
    path: &Path,
    project_root: &Path,
    max_new_bytes: Option<u64>,
) -> TranscriptIngestStats {
    let path_str = path.to_string_lossy().to_string();
    let prev_offset = db.get_parse_offset(&path_str).await.unwrap_or_default();
    let prev = StoredCursor {
        position: prev_offset.byte_offset,
        mtime: prev_offset.mtime,
        file_id: prev_offset.file_id,
    };
    let Some(parsed) = source.parse_new(path, prev, project_root, max_new_bytes) else {
        return TranscriptIngestStats::default();
    };

    if parsed.messages.is_empty() {
        // Non-message append (e.g. blank/undecodable rows) still advances the
        // cursor so the next ingest only sees genuinely new content.
        db.set_parse_offset(
            &path_str,
            ParseOffset {
                byte_offset: parsed.new_cursor.position,
                mtime: parsed.new_cursor.mtime,
                file_id: parsed.new_cursor.file_id,
            },
        )
        .await;
        return TranscriptIngestStats::default();
    }

    let provider = source.provider();
    let draft = parsed.draft;
    let existing = db.get_session(provider, &draft.session_id).await;
    // Preserve the session's original start time and title across appends; only
    // advance ended_at to the latest message seen.
    let started_at = existing
        .as_ref()
        .and_then(|session| session.started_at)
        .or_else(|| {
            parsed
                .messages
                .first()
                .and_then(|message| message.timestamp)
        });
    let title = existing
        .as_ref()
        .and_then(|session| session.title.clone())
        .or(draft.title);
    let ended_at = parsed
        .messages
        .last()
        .and_then(|message| message.timestamp)
        .or_else(|| existing.as_ref().and_then(|session| session.ended_at));

    let session = SessionRecord {