feat: Enable zstd response compression for RPC providers

Cargo.toml

@@ -66,7 +66,7 @@ tower = "0.5"
 oz-keystore = { version = "0.1.4"}
 hex = { version = "0.4"}
 bytes = { version = "1.9" }
-reqwest = { version = "0.12", features = ["json", "rustls-tls"] }
+reqwest = { version = "0.12", features = ["json", "rustls-tls", "zstd"] }
 base64 = { version =  "0.22" }
 hmac = { version = "0.12" }
 sha2 = { version = "0.10" }
@@ -141,6 +141,7 @@ proptest = "1.6.0"
 rand = "0.9.0"
 tempfile = "3.2"
 serial_test = "3.2"
+zstd = "0.13"
 clap = { version = "4.5", features = ["derive"] }
 
 

src/services/provider/mod.rs

@@ -114,6 +114,10 @@ impl ProviderConfig {
 
 /// Pre-configured `reqwest::ClientBuilder` with standard pool, keepalive, TLS,
 /// and redirect settings. Callers chain on extras (e.g., `.timeout(...)`) then `.build()`.
+///
+/// Response compression: the crate-level reqwest `zstd` feature (see Cargo.toml)
+/// makes clients built here send `Accept-Encoding: zstd` and transparently
+/// decompress zstd responses from providers that support it (e.g. QuickNode).
 fn base_rpc_client_builder() -> reqwest::ClientBuilder {
     ReqwestClient::builder()
         .connect_timeout(Duration::from_secs(
@@ -700,6 +704,37 @@ mod tests {
         assert!(matches!(provider_error, ProviderError::Other(_)));
     }
 
+    #[actix_rt::test]
+    async fn test_shared_rpc_client_zstd_response_decompression() {
+        let mut mock_server = mockito::Server::new_async().await;
+
+        let body = serde_json::json!({"jsonrpc": "2.0", "id": 1, "result": {"ok": true}});
+        let compressed = zstd::encode_all(body.to_string().as_bytes(), 3).unwrap();
+
+        let mock = mock_server
+            .mock("POST", "/")
+            .match_header(
+                "accept-encoding",
+                mockito::Matcher::Regex("zstd".to_string()),
+            )
+            .with_header("content-encoding", "zstd")
+            .with_body(compressed)
+            .create_async()
+            .await;
+
+        let client = get_shared_rpc_http_client().unwrap();
+        let response = client
+            .post(mock_server.url())
+            .json(&serde_json::json!({"jsonrpc": "2.0", "id": 1, "method": "test"}))
+            .send()
+            .await
+            .unwrap();
+
+        let json: serde_json::Value = response.json().await.unwrap();
+        assert_eq!(json["result"]["ok"], true);
+        mock.assert_async().await;
+    }
+
     #[test]
     fn test_from_eyre_report_other_error() {
         let eyre_error: eyre::Report = eyre::eyre!("Generic error");