Merge pull request #56 from liuck8080/feat/support_ckb_0.108.0

feat: 🎸 Bump ckb to 0.108.0

Author: quake

CHANGELOG.md

@@ -1,6 +1,7 @@
 # 2.5.0
 * Support indexer `exact` search mode.
 * Add `get_block_with_cycles` and `get_block_by_number_with_cycles` to support `get_block` and `get_block_by_number` with parameter `with_cycles`.
+* Support ckb 0.108.0
 
 # 2.4.0
 * Update ckb to 0.106.0

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "ckb-sdk"
-version = "2.4.1"
+version = "2.5.0"
 authors = ["Linfeng Qian <thewawar@gmail.com>", "Nervos Core Dev <dev@nervos.org>"]
 edition = "2018"
 license = "MIT"
@@ -18,7 +18,7 @@ bech32 = "0.8.1"
 log = "0.4.6"
 reqwest = { version = "0.11", features = ["json", "blocking"] }
 secp256k1 = { version = "0.24", features = ["recovery"] }
-tokio-util = { version = "0.6", features = ["codec"] }
+tokio-util = { version = "0.7.7", features = ["codec"] }
 tokio = { version = "1" }
 bytes = "1"
 futures = "0.3"
@@ -27,32 +27,32 @@ parking_lot = "0.12"
 lru = "0.7.1"
 dashmap = "5.4"
 
-ckb-types = "=0.106.0"
-ckb-dao-utils = "=0.106.0"
-ckb-traits = "=0.106.0"
-ckb-jsonrpc-types = "=0.106.0"
-ckb-hash = "=0.106.0"
-ckb-resource = "=0.106.0"
-ckb-crypto = { version = "=0.106.0", features = ["secp"] }
-ckb-script = { version = "=0.106.0"}
+ckb-types = "=0.108.0"
+ckb-dao-utils = "=0.108.0"
+ckb-traits = "=0.108.0"
+ckb-jsonrpc-types = "=0.108.0"
+ckb-hash = "=0.108.0"
+ckb-resource = "=0.108.0"
+ckb-crypto = { version = "=0.108.0", features = ["secp"] }
+ckb-script = { version = "=0.108.0"}
 bitflags = "1.3.2"
 sha3 = "0.10.1"
 enum-repr-derive = "0.2.0"
 
 # for feature test
 rand = { version = "0.7.3", optional = true }
-ckb-mock-tx-types = { version = "0.106.0", optional = true }
-ckb-chain-spec = { version = "=0.106.0", optional = true }
+ckb-mock-tx-types = { version = "0.108.0", optional = true }
+ckb-chain-spec = { version = "0.108.0", optional = true }
 
-sparse-merkle-tree = "0.5.4"
+sparse-merkle-tree = "0.6.1"
 lazy_static = "1.3.0"
 
 [features]
 default = []
 test = []
 
 [dev-dependencies]
-clap = { version = "3.1.9", features = ["derive"] }
+clap = { version = "4.1.8", features = ["derive"] }
 httpmock = "0.6"
-async-global-executor = "=2.0.4"
+async-global-executor = "2.3.1"
 hex = "0.4"

examples/transfer_from_multisig.rs

@@ -201,7 +201,7 @@ fn main() -> Result<(), Box<dyn StdErr>> {
         }
         Commands::Send { tx_file, ckb_rpc } => {
             // Send transaction
-            let tx_info: TxInfo = serde_json::from_slice(&fs::read(&tx_file)?)?;
+            let tx_info: TxInfo = serde_json::from_slice(&fs::read(tx_file)?)?;
             println!(
                 "> tx: {}",
                 serde_json::to_string_pretty(&tx_info.tx).unwrap()

examples/transfer_from_omnilock.rs

@@ -209,7 +209,7 @@ fn main() -> Result<(), Box<dyn StdErr>> {
         }
         Commands::Send { tx_file, ckb_rpc } => {
             // Send transaction
-            let tx_info: TxInfo = serde_json::from_slice(&fs::read(&tx_file)?)?;
+            let tx_info: TxInfo = serde_json::from_slice(&fs::read(tx_file)?)?;
             println!("> tx: {}", serde_json::to_string_pretty(&tx_info.tx)?);
             let outputs_validator = Some(json_types::OutputsValidator::Passthrough);
             let _tx_hash = CkbRpcClient::new(ckb_rpc.as_str())

examples/transfer_from_omnilock_ethereum.rs

@@ -211,7 +211,7 @@ fn main() -> Result<(), Box<dyn StdErr>> {
         }
         Commands::Send { tx_file, ckb_rpc } => {
             // Send transaction
-            let tx_info: TxInfo = serde_json::from_slice(&fs::read(&tx_file)?)?;
+            let tx_info: TxInfo = serde_json::from_slice(&fs::read(tx_file)?)?;
             println!("> tx: {}", serde_json::to_string_pretty(&tx_info.tx)?);
             let outputs_validator = Some(json_types::OutputsValidator::Passthrough);
             let _tx_hash = CkbRpcClient::new(ckb_rpc.as_str())

examples/transfer_from_omnilock_multisig.rs

@@ -239,7 +239,7 @@ fn main() -> Result<(), Box<dyn StdErr>> {
         }
         Commands::Send { tx_file, ckb_rpc } => {
             // Send transaction
-            let tx_info: TxInfo = serde_json::from_slice(&fs::read(&tx_file)?)?;
+            let tx_info: TxInfo = serde_json::from_slice(&fs::read(tx_file)?)?;
             println!("> tx: {}", serde_json::to_string_pretty(&tx_info.tx)?);
             let outputs_validator = Some(json_types::OutputsValidator::Passthrough);
             let _tx_hash = CkbRpcClient::new(ckb_rpc.as_str())

rust-toolchain

@@ -1 +1 @@
-1.61.0
+1.67.1

src/pubsub/mod.rs

@@ -154,6 +154,7 @@ where
     }
 
     /// if topic is empty, return Ok, else Err
+    #[allow(clippy::result_large_err)]
     pub fn try_into(self) -> Result<Client<T>, Self> {
         if self.topic_list.is_empty() {
             Ok(Client {

src/rpc/mod.rs

@@ -45,7 +45,7 @@ macro_rules! jsonrpc {
                 $struct_name { url, id: 0, client: reqwest::blocking::Client::new(), }
             }
 
-            pub fn post<PARAM, RET>(&mut self, method:&str, params: PARAM)->Result<RET, crate::rpc::RpcError>
+            pub fn post<PARAM, RET>(&mut self, method:&str, params: PARAM)->Result<RET, $crate::rpc::RpcError>
             where
                 PARAM:serde::ser::Serialize,
                 RET: serde::de::DeserializeOwned,
@@ -74,9 +74,9 @@ macro_rules! jsonrpc {
 
             $(
                 $(#[$attr])*
-                pub fn $method(&mut $selff $(, $arg_name: $arg_ty)*) -> Result<$return_ty, crate::rpc::RpcError> {
+                pub fn $method(&mut $selff $(, $arg_name: $arg_ty)*) -> Result<$return_ty, $crate::rpc::RpcError> {
                     let method = String::from(stringify!($method));
-                    let params = crate::serialize_parameters!($($arg_name,)*);
+                    let params = $crate::serialize_parameters!($($arg_name,)*);
                     $selff.id += 1;
 
                     let mut req_json = serde_json::Map::new();

src/tests/mod.rs

@@ -339,7 +339,7 @@ fn test_transfer_to_acp() {
     let account1_key = secp256k1::SecretKey::from_slice(ACCOUNT1_KEY.as_bytes()).unwrap();
     let signer1 = SecpCkbRawKeySigner::new_with_secret_keys(vec![account1_key]);
     let sighash_unlocker = AcpUnlocker::from(Box::new(signer1) as Box<_>);
-    let acp_unlocker = AcpUnlocker::from(Box::new(SecpCkbRawKeySigner::default()) as Box<_>);
+    let acp_unlocker = AcpUnlocker::from(Box::<SecpCkbRawKeySigner>::default() as Box<_>);
     let mut unlockers: HashMap<ScriptId, Box<dyn ScriptUnlocker>> = HashMap::default();
     unlockers.insert(
         ScriptId::new_type(SIGHASH_TYPE_HASH),
@@ -1042,7 +1042,7 @@ fn test_udt_transfer() {
     let account1_key = secp256k1::SecretKey::from_slice(ACCOUNT1_KEY.as_bytes()).unwrap();
     let signer = SecpCkbRawKeySigner::new_with_secret_keys(vec![account1_key]);
     let script_unlocker = SecpSighashUnlocker::from(Box::new(signer) as Box<_>);
-    let acp_unlocker = AcpUnlocker::from(Box::new(SecpCkbRawKeySigner::default()) as Box<_>);
+    let acp_unlocker = AcpUnlocker::from(Box::<SecpCkbRawKeySigner>::default() as Box<_>);
     let mut unlockers: HashMap<ScriptId, Box<dyn ScriptUnlocker>> = HashMap::default();
     unlockers.insert(
         ScriptId::new_type(SIGHASH_TYPE_HASH.clone()),