Method upload_provenance

atomic-remote/src/http/upload.rs:245–283

Upload a provenance graph to the remote server. Provenance graphs are content-addressed DAGs that capture the causal decision chain of an AI agent session. They are stored separately from changes and don't modify the content graph. # Arguments `hash` - The base32-encoded hash of the provenance graph. `data` - The raw serialized provenance graph bytes (.provenance format).

(&self, hash: &str, data: Bytes)

    /// * `hash` - The base32-encoded hash of the provenance graph.
    /// * `data` - The raw serialized provenance graph bytes (.provenance format).
    pub async fn upload_provenance(&self, hash: &str, data: Bytes) -> RemoteResult<()> {
        let url = format!("{}?provenance={}", self.base_url, hash);
        debug!("POST provenance: {} ({} bytes)", url, data.len());

        let response = self
            .client
            .post(&url)
            .header(CONTENT_TYPE, "application/octet-stream")
            .body(data)
            .send()
            .await
            .map_err(|e| RemoteError::connection_failed(&url, e))?;

        crate::check_min_version_header(response.headers());
        let status = response.status();

        match status {
            StatusCode::OK => {
                debug!("Successfully uploaded provenance graph {}", hash);
                Ok(())
            }
            StatusCode::NOT_FOUND => Err(RemoteError::repo_not_found(&url)),
            StatusCode::UNAUTHORIZED | StatusCode::FORBIDDEN => {
                let msg = response.text().await.unwrap_or_default();
                Err(RemoteError::auth_failed(&url, msg))
            }
            StatusCode::BAD_REQUEST => {
                let msg = response.text().await.unwrap_or_default();
                Err(RemoteError::protocol(format!(
                    "Failed to upload provenance graph: {}",
                    msg
                )))
            }
            _ => {
                let msg = response.text().await.unwrap_or_default();
                Err(RemoteError::http(status.as_u16(), msg))
            }
        }
    }

    // Streaming V3 Protocol — Upload Methods