Method get_with_rate_limit

src/lib.rs:227–257

Get blockchain data for a single query, with rate limit info

(
        &'py self,
        query: Query,
        py: Python<'py>,
    )

    /// Get blockchain data for a single query, with rate limit info
    pub fn get_with_rate_limit<'py>(
        &'py self,
        query: Query,
        py: Python<'py>,
    ) -> PyResult<Bound<'py, PyAny>> {
        let inner = Arc::clone(&self.inner);

        future_into_py(py, async move {
            let query = query.try_convert().context("parse query")?;

            let res = inner
                .get_with_rate_limit(&query)
                .await
                .context("get with rate limit")?;

            // On HTTP 429 the response is `None`; inspect rate_limit and retry later.
            let (response, rate_limit) = match res {
                hypersync_client::RateLimitResponse::Success {
                    response,
                    rate_limit,
                } => (
                    Some(convert_response(response).context("convert response")?),
                    rate_limit,
                ),
                hypersync_client::RateLimitResponse::RateLimited(rate_limit) => (None, rate_limit),
            };
            let rate_limit: RateLimitInfo = rate_limit.into();

            Ok((response, rate_limit))
        })
    }

    /// Get the most recently observed rate limit information.
    /// Returns None if no requests have been made yet.