feat: Esplora chain backend

.env

@@ -8,13 +8,25 @@ SWEEP_TIME=120
 SWEEP_INTERVAL=30
 
 # Possible values: mainnet, testnet, regtest
-NETWORK=regtest
+NETWORK=mainnet
 
 # Rest API configuration
 API_HOST=127.0.0.1
 API_PORT=1234
 
+# Chain backend to use
+# Options:
+# - elements
+# - esplora
+CHAIN_BACKEND=esplora
+
 # Configuration of the Elements daemon to connect to
 ELEMENTS_HOST=127.0.0.1
 ELEMENTS_PORT=18884
 ELEMENTS_COOKIE=/home/michael/Git/TypeScript/boltz-backend/docker/regtest/data/core/cookies/.elements-cookie
+
+# Configuration of the Esplora backend
+ESPLORA_ENDPOINT=https://blockstream.info/liquid/api
+
+# Poll interval for new blocks in seconds
+ESPLORA_POLL_INTERVAL=10

Cargo.toml

@@ -32,7 +32,6 @@ crossbeam-channel = "0.5.13"
 r2d2 = "0.8.10"
 rayon = "1.10.0"
 num_cpus = "1.16.0"
-esplora-client = { version = "0.9.0", default-features = false, features = ["async-https"] }
 async-trait = "0.1.80"
 
 [patch.crates-io]

src/chain/client.rs

@@ -10,7 +10,7 @@ use serde_json::json;
 use std::error::Error;
 use std::fs;
 
-use crate::chain::types::{ChainDataProvider, NetworkInfo, ZmqNotification};
+use crate::chain::types::{ChainBackend, NetworkInfo, ZmqNotification};
 use crate::chain::zmq::ZmqClient;
 
 enum StringOrU64 {
@@ -78,10 +78,6 @@ impl ChainClient {
         Ok(self)
     }
 
-    pub async fn get_network_info(self) -> Result<NetworkInfo, Box<dyn Error>> {
-        self.request::<NetworkInfo>("getnetworkinfo").await
-    }
-
     pub async fn get_zmq_notifications(self) -> Result<Vec<ZmqNotification>, Box<dyn Error>> {
         self.request::<Vec<ZmqNotification>>("getzmqnotifications")
             .await
@@ -128,23 +124,14 @@ impl ChainClient {
 
         Ok(res.result.unwrap())
     }
-
-    fn parse_hex<T: elements::encode::Decodable>(hex_str: String) -> Result<T, Box<dyn Error>> {
-        match elements::encode::deserialize(
-            match hex::decode(hex_str) {
-                Ok(res) => res,
-                Err(err) => return Err(Box::new(err)),
-            }
-            .as_ref(),
-        ) {
-            Ok(block) => Ok(block),
-            Err(e) => Err(Box::new(e)),
-        }
-    }
 }
 
 #[async_trait]
-impl ChainDataProvider for ChainClient {
+impl ChainBackend for ChainClient {
+    async fn get_network_info(&self) -> Result<NetworkInfo, Box<dyn Error>> {
+        self.clone().request::<NetworkInfo>("getnetworkinfo").await
+    }
+
     async fn get_block_count(&self) -> Result<u64, Box<dyn Error>> {
         self.clone().request::<u64>("getblockcount").await
     }
@@ -165,7 +152,7 @@ impl ChainDataProvider for ChainClient {
             .request_params::<String>("getblock", params)
             .await?;
 
-        Self::parse_hex(block_hex)
+        crate::chain::utils::parse_hex(block_hex)
     }
 
     async fn send_raw_transaction(&self, hex: String) -> Result<String, Box<dyn Error>> {
@@ -180,7 +167,7 @@ impl ChainDataProvider for ChainClient {
             .request_params::<String>("getrawtransaction", vec![hash])
             .await?;
 
-        Self::parse_hex(tx_hex)
+        crate::chain::utils::parse_hex(tx_hex)
     }
 
     fn get_tx_receiver(&self) -> Receiver<Transaction> {