Method upsert_transcript_batch

src/global_db.rs:2627–2645

Atomically upserts one transcript session + all parsed messages and then advances the parse cursor. Any failure rolls back the entire batch so a follow-up ingest can safely replay from the previous offset.

(
        &self,
        session: &SessionRecord,
        messages: &[SessionMessageRecord],
        parse_offset_path: &str,
        parse_offset: ParseOffset,
    )

    /// advances the parse cursor. Any failure rolls back the entire batch so a
    /// follow-up ingest can safely replay from the previous offset.
    pub async fn upsert_transcript_batch(
        &self,
        session: &SessionRecord,
        messages: &[SessionMessageRecord],
        parse_offset_path: &str,
        parse_offset: ParseOffset,
    ) -> bool {
        let batch = TranscriptBatch {
            session: session.clone(),
            messages: messages.to_vec(),
        };
        self.upsert_transcript_batches_inner(
            std::slice::from_ref(&batch),
            parse_offset_path,
            parse_offset,
            TranscriptWriteMode::Full,
        )
        .await
    }

    /// Atomically upserts several transcript sessions (and their messages),
    /// writing only the searchable `session_messages` projection — never