This repository has been archived by the owner on Aug 28, 2024. It is now read-only.
forked from matter-labs/zksync-era
-
Notifications
You must be signed in to change notification settings - Fork 1
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge remote-tracking branch 'refs/remotes/origin/feat/bitcoin-integr…
…ation' into bitcoin-lib-fixes # Conflicts: # core/lib/via_btc_client/src/client/mod.rs # core/lib/via_btc_client/src/regtest.rs
- Loading branch information
Showing
1 changed file
with
136 additions
and
135 deletions.
There are no files selected for viewing
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,135 +1,136 @@ | ||
| // use std::{ | ||
| // process::{Command, Stdio}, | ||
| // thread, | ||
| // time::Duration, | ||
| // }; | ||
| // | ||
| // use anyhow::Result; | ||
| // use bitcoin::{address::NetworkUnchecked, Address, Network, PrivateKey}; | ||
| // | ||
| // const COMPOSE_FILE_PATH: &str = | ||
| // concat!(env!("CARGO_MANIFEST_DIR"), "/tests/docker-compose-btc.yml"); | ||
| // const CLI_CONTAINER_NAME: &str = "tests-bitcoin-cli-1"; | ||
| // | ||
| // pub struct BitcoinRegtest { | ||
| // private_key: PrivateKey, | ||
| // address: Address, | ||
| // } | ||
| // | ||
| // impl BitcoinRegtest { | ||
| // pub fn new() -> Result<Self> { | ||
| // let regtest = Self { | ||
| // address: "bcrt1qx2lk0unukm80qmepjp49hwf9z6xnz0s73k9j56" | ||
| // .parse::<Address<NetworkUnchecked>>()? | ||
| // .require_network(Network::Regtest)?, | ||
| // private_key: PrivateKey::from_wif( | ||
| // "cVZduZu265sWeAqFYygoDEE1FZ7wV9rpW5qdqjRkUehjaUMWLT1R", | ||
| // )?, | ||
| // }; | ||
| // regtest.setup()?; | ||
| // Ok(regtest) | ||
| // } | ||
| // | ||
| // fn setup(&self) -> Result<()> { | ||
| // self.run()?; | ||
| // thread::sleep(Duration::from_secs(10)); | ||
| // Ok(()) | ||
| // } | ||
| // | ||
| // fn run(&self) -> Result<()> { | ||
| // Command::new("docker") | ||
| // .args(["compose", "-f", COMPOSE_FILE_PATH, "up", "-d"]) | ||
| // .stdout(Stdio::null()) | ||
| // .stderr(Stdio::null()) | ||
| // .status()?; | ||
| // Ok(()) | ||
| // } | ||
| // | ||
| // pub fn get_miner_address(&self) -> Result<Address> { | ||
| // let output = Command::new("docker") | ||
| // .args(["logs", CLI_CONTAINER_NAME]) | ||
| // .output()?; | ||
| // let stdout_utf8 = std::str::from_utf8(&output.stdout)?; | ||
| // if let Some(line) = stdout_utf8 | ||
| // .lines() | ||
| // .find(|line| line.starts_with("Alice's address:")) | ||
| // { | ||
| // match line | ||
| // .split_once(": ") | ||
| // .map(|(_, addr)| addr.trim().to_string()) | ||
| // { | ||
| // Some(address) => Ok(address | ||
| // .parse::<Address<NetworkUnchecked>>()? | ||
| // .require_network(Network::Regtest)?), | ||
| // None => Err(anyhow::anyhow!("Error while getting miner address")), | ||
| // } | ||
| // } else { | ||
| // Err(anyhow::anyhow!("Error while getting miner address")) | ||
| // } | ||
| // } | ||
| // | ||
| // fn stop(&self) -> Result<()> { | ||
| // Command::new("docker") | ||
| // .args(["compose", "-f", COMPOSE_FILE_PATH, "down", "--volumes"]) | ||
| // .stdout(Stdio::null()) | ||
| // .stderr(Stdio::null()) | ||
| // .status()?; | ||
| // Ok(()) | ||
| // } | ||
| // | ||
| // pub fn get_url(&self) -> String { | ||
| // "http://127.0.0.1:18443".to_string() | ||
| // } | ||
| // | ||
| // pub fn get_address(&self) -> &Address { | ||
| // &self.address | ||
| // } | ||
| // | ||
| // pub fn get_private_key(&self) -> &PrivateKey { | ||
| // &self.private_key | ||
| // } | ||
| // } | ||
| // | ||
| // impl Drop for BitcoinRegtest { | ||
| // fn drop(&mut self) { | ||
| // if let Err(e) = self.stop() { | ||
| // eprintln!("Failed to stop Bitcoin regtest: {}", e); | ||
| // } | ||
| // } | ||
| // } | ||
| // | ||
| // #[cfg(test)] | ||
| // mod tests { | ||
| // use bitcoin::CompressedPublicKey; | ||
| // use secp256k1::Secp256k1; | ||
| // | ||
| // use super::*; | ||
| // // use crate::{client::BitcoinRpcClient, traits::BitcoinRpc}; | ||
| // // | ||
| // // #[tokio::test] | ||
| // // async fn test_bitcoin_regtest() { | ||
| // // let regtest = BitcoinRegtest::new().expect("Failed to create BitcoinRegtest"); | ||
| // // let rpc = BitcoinRpcClient::new(®test.get_url(), "rpcuser", "rpcpassword") | ||
| // // .expect("Failed create rpc client"); | ||
| // // | ||
| // // let block_count = rpc | ||
| // // .get_block_count() | ||
| // // .await | ||
| // // .expect("Failed to get block count"); | ||
| // // assert!(block_count > 100); | ||
| // // | ||
| // // let address = regtest.get_address(); | ||
| // // let private_key = regtest.get_private_key(); | ||
| // // let balance = rpc | ||
| // // .get_balance(address) | ||
| // // .await | ||
| // // .expect("Failed to get balance of test address"); | ||
| // // assert!(balance > 300000); | ||
| // // | ||
| // // let secp = Secp256k1::new(); | ||
| // // let compressed_public_key = CompressedPublicKey::from_private_key(&secp, private_key) | ||
| // // .expect("Failed to generate address from test private_key"); | ||
| // // let derived_address = Address::p2wpkh(&compressed_public_key, Network::Regtest); | ||
| // // assert_eq!(*address, derived_address, "Address mismatch!"); | ||
| // // } | ||
| // } | ||
| use std::{ | ||
| process::{Command, Stdio}, | ||
| thread, | ||
| time::Duration, | ||
| }; | ||
|
|
||
| use anyhow::Result; | ||
| use bitcoin::{address::NetworkUnchecked, Address, Network, PrivateKey}; | ||
|
|
||
| const COMPOSE_FILE_PATH: &str = | ||
| concat!(env!("CARGO_MANIFEST_DIR"), "/tests/docker-compose-btc.yml"); | ||
| const CLI_CONTAINER_NAME: &str = "tests-bitcoin-cli-1"; | ||
|
|
||
| pub struct BitcoinRegtest { | ||
| private_key: PrivateKey, | ||
| address: Address, | ||
| } | ||
|
|
||
| impl BitcoinRegtest { | ||
| pub fn new() -> Result<Self> { | ||
| let regtest = Self { | ||
| address: "bcrt1qx2lk0unukm80qmepjp49hwf9z6xnz0s73k9j56" | ||
| .parse::<Address<NetworkUnchecked>>()? | ||
| .require_network(Network::Regtest)?, | ||
| private_key: PrivateKey::from_wif( | ||
| "cVZduZu265sWeAqFYygoDEE1FZ7wV9rpW5qdqjRkUehjaUMWLT1R", | ||
| )?, | ||
| }; | ||
| regtest.setup()?; | ||
| Ok(regtest) | ||
| } | ||
|
|
||
| fn setup(&self) -> Result<()> { | ||
| self.run()?; | ||
| thread::sleep(Duration::from_secs(10)); | ||
| Ok(()) | ||
| } | ||
|
|
||
| fn run(&self) -> Result<()> { | ||
| Command::new("docker") | ||
| .args(["compose", "-f", COMPOSE_FILE_PATH, "up", "-d"]) | ||
| .stdout(Stdio::null()) | ||
| .stderr(Stdio::null()) | ||
| .status()?; | ||
| Ok(()) | ||
| } | ||
|
|
||
| pub fn get_miner_address(&self) -> Result<Address> { | ||
| let output = Command::new("docker") | ||
| .args(["logs", CLI_CONTAINER_NAME]) | ||
| .output()?; | ||
| let stdout_utf8 = std::str::from_utf8(&output.stdout)?; | ||
| if let Some(line) = stdout_utf8 | ||
| .lines() | ||
| .find(|line| line.starts_with("Alice's address:")) | ||
| { | ||
| match line | ||
| .split_once(": ") | ||
| .map(|(_, addr)| addr.trim().to_string()) | ||
| { | ||
| Some(address) => Ok(address | ||
| .parse::<Address<NetworkUnchecked>>()? | ||
| .require_network(Network::Regtest)?), | ||
| None => Err(anyhow::anyhow!("Error while getting miner address")), | ||
| } | ||
| } else { | ||
| Err(anyhow::anyhow!("Error while getting miner address")) | ||
| } | ||
| } | ||
|
|
||
| fn stop(&self) -> Result<()> { | ||
| Command::new("docker") | ||
| .args(["compose", "-f", COMPOSE_FILE_PATH, "down", "--volumes"]) | ||
| .stdout(Stdio::null()) | ||
| .stderr(Stdio::null()) | ||
| .status()?; | ||
| Ok(()) | ||
| } | ||
|
|
||
| pub fn get_url(&self) -> String { | ||
| "http://127.0.0.1:18443".to_string() | ||
| } | ||
|
|
||
| pub fn get_address(&self) -> &Address { | ||
| &self.address | ||
| } | ||
|
|
||
| pub fn get_private_key(&self) -> &PrivateKey { | ||
| &self.private_key | ||
| } | ||
| } | ||
|
|
||
| impl Drop for BitcoinRegtest { | ||
| fn drop(&mut self) { | ||
| if let Err(e) = self.stop() { | ||
| eprintln!("Failed to stop Bitcoin regtest: {}", e); | ||
| } | ||
| } | ||
| } | ||
|
|
||
| #[cfg(test)] | ||
| mod tests { | ||
| use bitcoin::CompressedPublicKey; | ||
| use bitcoincore_rpc::Auth; | ||
| use secp256k1::Secp256k1; | ||
|
|
||
| use super::*; | ||
| use crate::{client::BitcoinRpcClient, traits::BitcoinRpc}; | ||
|
|
||
| #[tokio::test] | ||
| async fn test_bitcoin_regtest() { | ||
| let regtest = BitcoinRegtest::new().expect("Failed to create BitcoinRegtest"); | ||
| let rpc = BitcoinRpcClient::new(®test.get_url(), Auth::UserPass("rpcuser".to_string(), "rpcpassword".to_string())) | ||
| .expect("Failed create rpc client"); | ||
|
|
||
| let block_count = rpc | ||
| .get_block_count() | ||
| .await | ||
| .expect("Failed to get block count"); | ||
| assert!(block_count > 100); | ||
|
|
||
| let address = regtest.get_address(); | ||
| let private_key = regtest.get_private_key(); | ||
| let balance = rpc | ||
| .get_balance(address) | ||
| .await | ||
| .expect("Failed to get balance of test address"); | ||
| assert!(balance > 300000); | ||
|
|
||
| let secp = Secp256k1::new(); | ||
| let compressed_public_key = CompressedPublicKey::from_private_key(&secp, private_key) | ||
| .expect("Failed to generate address from test private_key"); | ||
| let derived_address = Address::p2wpkh(&compressed_public_key, Network::Regtest); | ||
| assert_eq!(*address, derived_address, "Address mismatch!"); | ||
| } | ||
| } |