Method handle_response

atomic-remote/src/storage.rs:185–219

Handle a response: check status, parse `ApiResponse `, unwrap data.

(
        &self,
        resp: reqwest::Response,
    )

    /// Handle a response: check status, parse `ApiResponse<T>`, unwrap data.
    async fn handle_response<T: DeserializeOwned>(
        &self,
        resp: reqwest::Response,
    ) -> Result<T, RemoteError> {
        crate::check_min_version_header(resp.headers());
        let status = resp.status();
        let body = resp
            .text()
            .await
            .map_err(|e| RemoteError::other(format!("failed to read response: {}", e)))?;

        if !status.is_success() {
            return Err(self.parse_error_body(status.as_u16(), &body));
        }

        let api_resp: ApiResponse<T> = serde_json::from_str(&body).map_err(|e| {
            let preview_len = body.len().min(200);
            RemoteError::other(format!(
                "invalid response JSON: {} (body: {})",
                e,
                &body[..preview_len]
            ))
        })?;

        if !api_resp.success {
            if let Some(err) = api_resp.error {
                return Err(RemoteError::other(format!("{}: {}", err.code, err.message)));
            }
            return Err(RemoteError::other("request failed with no error details"));
        }

        api_resp
            .data
            .ok_or_else(|| RemoteError::other("response had success=true but no data"))
    }

    fn parse_error_body(&self, status: u16, body: &str) -> RemoteError {
        // Try to parse as ApiResponse first.