pub async fn send_with_retry(
    build_request: impl Fn() -> reqwest::RequestBuilder,
) -> Result<reqwest::Response, reqwest::Error> {
    for attempt in 0..MAX_RETRIES {
        match build_request().send().await {
            Ok(resp) => {
                if resp.status() != reqwest::StatusCode::TOO_MANY_REQUESTS {
                    return Ok(resp);
                }

                let header_value = resp
                    .headers()
                    .get("retry-after")
                    .and_then(|v| v.to_str().ok());
                let retry_after = compute_retry_delay(header_value, attempt);
                tokio::time::sleep(std::time::Duration::from_secs(retry_after)).await;
            }
            Err(e) if e.is_connect() || e.is_timeout() => {
                let delay = compute_retry_delay(None, attempt);
                tokio::time::sleep(std::time::Duration::from_secs(delay)).await;
            }
            Err(e) => return Err(e), // Non-retryable error
        }
    }

    // Final attempt
    build_request().send().await
}