Function upload_change_smart

atomic-cli/src/commands/push/helpers.rs:303–349

Upload a single change using the threshold-gated delta transfer protocol. - Changes smaller than [`DELTA_TRANSFER_THRESHOLD`]: sent directly (fast path) - Changes larger: manifest exchange → send only missing chunks (delta path) # Arguments `remote` - The HTTP remote to push to. `repo` - The local repository. `hash` - The change hash. `view` - The target view name on the remote. # Returns A [

(
    remote: &atomic_remote::HttpRemote,
    repo: &Repository,
    hash: &Hash,
    view: &str,
)

///
/// A [`PushTransferResult`] describing the transfer, or an error.
pub async fn upload_change_smart(
    remote: &atomic_remote::HttpRemote,
    repo: &Repository,
    hash: &Hash,
    view: &str,
) -> CliResult<PushTransferResult> {
    let hash_str = hash.to_base32();

    // Prefer streaming from the on-disk change file for large changes.
    // This avoids loading 50MB+ into memory and uses chunked transfer
    // encoding so the server can stream-to-disk instead of buffering.
    let change_path = repo.change_store().change_path(hash);
    let file_size = change_path.metadata().map(|m| m.len()).unwrap_or(0);

    log::debug!(
        "push: uploading {} ({} bytes / {}){}",
        &hash_str[..12.min(hash_str.len())],
        file_size,
        format_bytes(file_size),
        if file_size as usize >= DELTA_TRANSFER_THRESHOLD {
            " [streamed]"
        } else {
            ""
        },
    );

    // For large changes, stream directly from disk.
    if file_size as usize >= DELTA_TRANSFER_THRESHOLD && change_path.exists() {
        remote
            .upload_change_streamed(&hash_str, view, &change_path)
            .await
            .map_err(|e| convert_remote_error(e, remote.url().as_ref()))?;

        return Ok(PushTransferResult::direct(file_size));
    }

    // Small changes: load into memory and send directly.
    let change_data = load_change_data(repo, hash)?;
    let data_len = change_data.len();

    remote
        .upload_change(&hash_str, view, change_data)
        .await
        .map_err(|e| convert_remote_error(e, remote.url().as_ref()))?;

    Ok(PushTransferResult::direct(data_len as u64))
}

/// Format a byte count for display.
fn format_bytes(bytes: u64) -> String {