Method upload_change

atomic-remote/src/http/upload.rs:42–89

Upload a change file. # Arguments `hash` - The base32-encoded hash of the change. `view` - The target view name. `data` - The raw change file data.

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

    /// * `view` - The target view name.
    /// * `data` - The raw change file data.
    pub async fn upload_change(&self, hash: &str, view: &str, data: Bytes) -> RemoteResult<()> {
        let url = format!("{}?insert={}&view={}", self.base_url, hash, view);
        debug!("POST insert: {} ({} 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 change {}", 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 | StatusCode::INTERNAL_SERVER_ERROR => {
                let msg = response.text().await.unwrap_or_default();
                // Missing-dependency error: name the offending hashes when the
                // server included them; otherwise preserve the full message
                // rather than collapsing it to "0 dependencies".
                if msg.contains("missing") && msg.contains("dependenc") {
                    let hashes = extract_change_hashes(&msg);
                    if hashes.is_empty() {
                        Err(RemoteError::http(status.as_u16(), msg))
                    } else {
                        Err(RemoteError::missing_deps(hashes))
                    }
                } else {
                    Err(RemoteError::http(status.as_u16(), msg))
                }
            }
            _ => {
                let msg = response.text().await.unwrap_or_default();
                Err(RemoteError::http(status.as_u16(), msg))
            }
        }
    }

    /// Store a change file on the remote without applying it to any view.
    ///