Method get_changelist

atomic-remote/src/http/queries.rs:79–119

Get the changelist for a view starting from a position. # Arguments `view` - The name of the view to query. `from` - The starting position (sequence number). # Returns A vector of changelist entries, starting from the given position.

(
        &self,
        view: &str,
        from: u64,
    )

    ///
    /// A vector of changelist entries, starting from the given position.
    pub async fn get_changelist(
        &self,
        view: &str,
        from: u64,
    ) -> RemoteResult<Vec<ChangelistEntry>> {
        let url = format!("{}?view={}&changelist={}", self.base_url, view, from);
        debug!("GET changelist: {}", 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 changelist response status: {}", status);

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

                trace!("GET changelist response body length: {} bytes", text.len());

                parse_changelist(&text)
            }
            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 view ID (UUID).
    ///