-
Notifications
You must be signed in to change notification settings - Fork 45
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
9 changed files
with
18 additions
and
1,827 deletions.
There are no files selected for viewing
Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,202 +1 @@ | ||
| // // use crate::BlockchainConfig; | ||
| // use crate::{BdkError, Transaction}; | ||
| // use crate::BdkError; | ||
| // use bdk::bitcoin::Network; | ||
| // use bdk::blockchain::any::{AnyBlockchain, AnyBlockchainConfig}; | ||
| // use bdk::blockchain::rpc::Auth as BdkAuth; | ||
| // use bdk::blockchain::rpc::RpcSyncParams as BdkRpcSyncParams; | ||
| // use bdk::blockchain::Blockchain as BdkBlockchain; | ||
| // use bdk::blockchain::GetBlockHash; | ||
| // use bdk::blockchain::GetHeight; | ||
| // use bdk::blockchain::{ | ||
| // electrum::ElectrumBlockchainConfig, esplora::EsploraBlockchainConfig, | ||
| // rpc::RpcConfig as BdkRpcConfig, ConfigurableBlockchain, | ||
| // }; | ||
| // use bdk::FeeRate; | ||
| // use std::convert::{From, TryFrom}; | ||
| // use std::path::PathBuf; | ||
| // use std::sync::{Arc, Mutex, MutexGuard}; | ||
| // | ||
| // pub(crate) struct Blockchain { | ||
| // inner_mutex: Mutex<AnyBlockchain>, | ||
| // } | ||
| // | ||
| // impl Blockchain { | ||
| // pub(crate) fn new(blockchain_config: BlockchainConfig) -> Result<Self, BdkError> { | ||
| // let any_blockchain_config = match blockchain_config { | ||
| // BlockchainConfig::Electrum { config } => { | ||
| // AnyBlockchainConfig::Electrum(ElectrumBlockchainConfig { | ||
| // retry: config.retry, | ||
| // socks5: config.socks5, | ||
| // timeout: config.timeout, | ||
| // url: config.url, | ||
| // stop_gap: usize::try_from(config.stop_gap).unwrap(), | ||
| // validate_domain: config.validate_domain, | ||
| // }) | ||
| // } | ||
| // BlockchainConfig::Esplora { config } => { | ||
| // AnyBlockchainConfig::Esplora(EsploraBlockchainConfig { | ||
| // base_url: config.base_url, | ||
| // proxy: config.proxy, | ||
| // concurrency: config.concurrency, | ||
| // stop_gap: usize::try_from(config.stop_gap).unwrap(), | ||
| // timeout: config.timeout, | ||
| // }) | ||
| // } | ||
| // BlockchainConfig::Rpc { config } => AnyBlockchainConfig::Rpc(BdkRpcConfig { | ||
| // url: config.url, | ||
| // auth: config.auth.into(), | ||
| // network: config.network, | ||
| // wallet_name: config.wallet_name, | ||
| // sync_params: config.sync_params.map(|p| p.into()), | ||
| // }), | ||
| // }; | ||
| // let blockchain = AnyBlockchain::from_config(&any_blockchain_config)?; | ||
| // Ok(Self { | ||
| // inner_mutex: Mutex::new(blockchain), | ||
| // }) | ||
| // } | ||
| // | ||
| // pub(crate) fn get_blockchain(&self) -> MutexGuard<AnyBlockchain> { | ||
| // self.inner_mutex.lock().expect("blockchain") | ||
| // } | ||
| // | ||
| // pub(crate) fn broadcast(&self, transaction: &Transaction) -> Result<(), BdkError> { | ||
| // let tx = &transaction.inner; | ||
| // self.get_blockchain().broadcast(tx) | ||
| // } | ||
| // | ||
| // pub(crate) fn estimate_fee(&self, target: u64) -> Result<Arc<FeeRate>, BdkError> { | ||
| // let result: Result<FeeRate, bdk::Error> = | ||
| // self.get_blockchain().estimate_fee(target as usize); | ||
| // result.map(Arc::new) | ||
| // } | ||
| // | ||
| // pub(crate) fn get_height(&self) -> Result<u32, BdkError> { | ||
| // self.get_blockchain().get_height() | ||
| // } | ||
| // | ||
| // pub(crate) fn get_block_hash(&self, height: u32) -> Result<String, BdkError> { | ||
| // self.get_blockchain() | ||
| // .get_block_hash(u64::from(height)) | ||
| // .map(|hash| hash.to_string()) | ||
| // } | ||
| // } | ||
| // | ||
| // /// Configuration for an ElectrumBlockchain | ||
| // pub struct ElectrumConfig { | ||
| // /// URL of the Electrum server (such as ElectrumX, Esplora, BWT) may start with ssl:// or tcp:// and include a port | ||
| // /// e.g. ssl://electrum.blockstream.info:60002 | ||
| // pub url: String, | ||
| // /// URL of the socks5 proxy server or a Tor service | ||
| // pub socks5: Option<String>, | ||
| // /// Request retry count | ||
| // pub retry: u8, | ||
| // /// Request timeout (seconds) | ||
| // pub timeout: Option<u8>, | ||
| // /// Stop searching addresses for transactions after finding an unused gap of this length | ||
| // pub stop_gap: u64, | ||
| // /// Validate the domain when using SSL | ||
| // pub validate_domain: bool, | ||
| // } | ||
| // | ||
| // /// Configuration for an EsploraBlockchain | ||
| // pub struct EsploraConfig { | ||
| // /// Base URL of the esplora service | ||
| // /// e.g. https://blockstream.info/api/ | ||
| // pub base_url: String, | ||
| // /// Optional URL of the proxy to use to make requests to the Esplora server | ||
| // /// The string should be formatted as: <protocol>://<user>:<password>@host:<port>. | ||
| // /// Note that the format of this value and the supported protocols change slightly between the | ||
| // /// sync version of esplora (using ureq) and the async version (using reqwest). For more | ||
| // /// details check with the documentation of the two crates. Both of them are compiled with | ||
| // /// the socks feature enabled. | ||
| // /// The proxy is ignored when targeting wasm32. | ||
| // pub proxy: Option<String>, | ||
| // /// Number of parallel requests sent to the esplora service (default: 4) | ||
| // pub concurrency: Option<u8>, | ||
| // /// Stop searching addresses for transactions after finding an unused gap of this length. | ||
| // pub stop_gap: u64, | ||
| // /// Socket timeout. | ||
| // pub timeout: Option<u64>, | ||
| // } | ||
| // | ||
| // pub enum Auth { | ||
| // /// No authentication | ||
| // None, | ||
| // /// Authentication with username and password, usually [Auth::Cookie] should be preferred | ||
| // UserPass { | ||
| // /// Username | ||
| // username: String, | ||
| // /// Password | ||
| // password: String, | ||
| // }, | ||
| // /// Authentication with a cookie file | ||
| // Cookie { | ||
| // /// Cookie file | ||
| // file: String, | ||
| // }, | ||
| // } | ||
| // | ||
| // impl From<Auth> for BdkAuth { | ||
| // fn from(auth: Auth) -> Self { | ||
| // match auth { | ||
| // Auth::None => BdkAuth::None, | ||
| // Auth::UserPass { username, password } => BdkAuth::UserPass { username, password }, | ||
| // Auth::Cookie { file } => BdkAuth::Cookie { | ||
| // file: PathBuf::from(file), | ||
| // }, | ||
| // } | ||
| // } | ||
| // } | ||
| // | ||
| // /// Sync parameters for Bitcoin Core RPC. | ||
| // /// | ||
| // /// In general, BDK tries to sync `scriptPubKey`s cached in `Database` with | ||
| // /// `scriptPubKey`s imported in the Bitcoin Core Wallet. These parameters are used for determining | ||
| // /// how the `importdescriptors` RPC calls are to be made. | ||
| // pub struct RpcSyncParams { | ||
| // /// The minimum number of scripts to scan for on initial sync. | ||
| // pub start_script_count: u64, | ||
| // /// Time in unix seconds in which initial sync will start scanning from (0 to start from genesis). | ||
| // pub start_time: u64, | ||
| // /// Forces every sync to use `start_time` as import timestamp. | ||
| // pub force_start_time: bool, | ||
| // /// RPC poll rate (in seconds) to get state updates. | ||
| // pub poll_rate_sec: u64, | ||
| // } | ||
| // | ||
| // impl From<RpcSyncParams> for BdkRpcSyncParams { | ||
| // fn from(params: RpcSyncParams) -> Self { | ||
| // BdkRpcSyncParams { | ||
| // start_script_count: params.start_script_count as usize, | ||
| // start_time: params.start_time, | ||
| // force_start_time: params.force_start_time, | ||
| // poll_rate_sec: params.poll_rate_sec, | ||
| // } | ||
| // } | ||
| // } | ||
| // | ||
| // /// RpcBlockchain configuration options | ||
| // pub struct RpcConfig { | ||
| // /// The bitcoin node url | ||
| // pub url: String, | ||
| // /// The bitcoin node authentication mechanism | ||
| // pub auth: Auth, | ||
| // /// The network we are using (it will be checked the bitcoin node network matches this) | ||
| // pub network: Network, | ||
| // /// The wallet name in the bitcoin node, consider using [crate::wallet::wallet_name_from_descriptor] for this | ||
| // pub wallet_name: String, | ||
| // /// Sync parameters | ||
| // pub sync_params: Option<RpcSyncParams>, | ||
| // } | ||
| // | ||
| // /// Type that can contain any of the blockchain configurations defined by the library. | ||
| // pub enum BlockchainConfig { | ||
| // /// Electrum client | ||
| // Electrum { config: ElectrumConfig }, | ||
| // /// Esplora client | ||
| // Esplora { config: EsploraConfig }, | ||
| // /// Bitcoin Core RPC client | ||
| // Rpc { config: RpcConfig }, | ||
| // } | ||
|
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,14 +1 @@ | ||
| // use bdk::database::any::{SledDbConfiguration, SqliteDbConfiguration}; | ||
| // | ||
| // /// Type that can contain any of the database configurations defined by the library | ||
| // /// This allows storing a single configuration that can be loaded into an AnyDatabaseConfig | ||
| // /// instance. Wallets that plan to offer users the ability to switch blockchain backend at runtime | ||
| // /// will find this particularly useful. | ||
| // pub enum DatabaseConfig { | ||
| // /// Memory database has no config | ||
| // Memory, | ||
| // /// Simple key-value embedded database based on sled | ||
| // Sled { config: SledDbConfiguration }, | ||
| // /// Sqlite embedded database using rusqlite | ||
| // Sqlite { config: SqliteDbConfiguration }, | ||
| // } | ||
|
|
Oops, something went wrong.