Method get_state

atomic-remote/src/http/queries.rs:29–67

Get the current state of a view. # Arguments `view` - The name of the view to query. # Returns The current state of the view, or `StateResponse::Empty` if the view is empty.

(&self, view: &str)

    /// The current state of the view, or `StateResponse::Empty` if the
    /// view is empty.
    pub async fn get_state(&self, view: &str) -> RemoteResult<StateResponse> {
        let url = format!("{}?view={}&state=", self.base_url, view);
        debug!("GET state: {}", url);

        let response = self
            .client
            .get(&url)
            .send()
            .await
            .map_err(|e| RemoteError::connection_failed(&url, e))?;

        crate::check_min_version_header(response.headers());
        let status = response.status();
        trace!("GET state response status: {}", status);

        match status {
            StatusCode::OK => {
                let text = response
                    .text()
                    .await
                    .map_err(|e| RemoteError::connection_failed(&url, e))?;

                trace!("GET state response body: {:?}", text);

                StateResponse::parse(&text).map_err(|e| {
                    RemoteError::protocol(format!("Failed to parse state response: {}", e))
                })
            }
            StatusCode::NOT_FOUND => Err(RemoteError::view_not_found(view)),
            StatusCode::UNAUTHORIZED | StatusCode::FORBIDDEN => {
                let msg = response.text().await.unwrap_or_default();
                Err(RemoteError::auth_failed(&url, msg))
            }
            _ => {
                let msg = response.text().await.unwrap_or_default();
                Err(RemoteError::http(status.as_u16(), msg))
            }
        }
    }

    /// Get the changelist for a view starting from a position.
    ///