Function upsert_commit_session

src/sessions/git_correlation.rs:579–604

Inserts one commit attribution row; existing rows win (idempotent for re-runs of live attribution and the backfill command). Returns `true` when a new row was inserted.

(
    conn: &Connection,
    record: &CommitSessionRecord,
)

/// re-runs of live attribution and the backfill command). Returns `true`
/// when a new row was inserted.
pub(crate) async fn upsert_commit_session(
    conn: &Connection,
    record: &CommitSessionRecord,
) -> Result<bool, GitCorrelationError> {
    let worktree = record.worktree.as_deref().map(normalize_worktree);
    let inserted = conn
        .execute(
            "INSERT OR IGNORE INTO commit_sessions (
                commit_sha, provider, session_id, branch, worktree,
                committed_at, span_overlap_kind, span_id
             )
             VALUES (?1, ?2, ?3, ?4, ?5, ?6, ?7, ?8)",
            params![
                record.commit_sha.as_str(),
                record.provider.as_str(),
                record.session_id.as_str(),
                opt_text(record.branch.as_deref()),
                opt_text(worktree.as_deref()),
                record.committed_at,
                record.span_overlap_kind.as_str(),
                record.span_id.map_or(Value::Null, Value::Integer),
            ],
        )
        .await?;
    Ok(inserted > 0)
}

mod attribution;
pub(crate) use attribution::run_commit_attribution_sweep;