Method put_view_manifest

atomic-remote/src/http/upload.rs:144–200

Declare a view's identity and change log on the remote. POSTs the manifest text (header `name\tscope\tparent\tstate` plus the change log, one base32 hash per line). The server applies it declaratively: creates the view with the declared scope/parent if absent, fast-forwards its log, and verifies the resulting merkle equals the declared state. Every referenced change must already be on the server

(&self, view: &str, manifest_text: String)

    /// String-level like the rest of this client: serialization lives in
    /// `atomic-repository`.
    pub async fn put_view_manifest(&self, view: &str, manifest_text: String) -> RemoteResult<()> {
        let url = format!("{}?view-manifest={}", self.base_url, view);
        debug!(
            "POST view-manifest: {} ({} bytes)",
            url,
            manifest_text.len()
        );

        let response = self
            .client
            .post(&url)
            .header(CONTENT_TYPE, "text/plain")
            .body(manifest_text)
            .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 declared view manifest for {}", view);
                Ok(())
            }
            StatusCode::NOT_FOUND => Err(RemoteError::repo_not_found(&url)),
            StatusCode::CONFLICT => {
                // Divergence / identity mismatch / state mismatch.
                let msg = response.text().await.unwrap_or_default();
                Err(RemoteError::protocol(msg))
            }
            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();
                // A missing change/dependency from the manifest apply names the
                // offending hash(es); surface them instead of "0 dependencies",
                // and fall back to the full server message when none parse.
                if msg.contains("missing") && msg.contains("change") {
                    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))
            }
        }
    }