Enabled RPC recconection

avail-rust/Cargo.toml

@@ -12,23 +12,23 @@ crate-type = ["cdylib", "rlib"]
 [target.'cfg(not(target_arch = "wasm32"))'.dependencies]
 derive_more = { version = "1", features = ["full"] }
 kate-recovery = {  git = "https://github.com/availproject/avail-core", tag = "core-node-4", features = ["serde"] }
-subxt = { version = "0.38.0" }
+subxt = { version = "0.38.0", features = ["reconnecting-rpc-client"] }
 subxt-core = { version = "0.38.0" }
 subxt-signer = { version = "0.38.0" }
 tokio = { version = "1.21.2" }
 
 [target.'cfg(target_arch = "wasm32")'.dependencies]
 derive_more = { version = "1", default-features = false, features = ["from", "constructor"] }
 kate-recovery = {  git = "https://github.com/availproject/avail-core", default-features = false, tag = "core-node-4", features = ["serde"] }
-subxt = { version = "0.38.0", default-features = false, features = ["web", "jsonrpsee"] }
+subxt = { version = "0.38.0", default-features = false, features = ["web", "jsonrpsee", "reconnecting-rpc-client"] }
 subxt-core = { version = "0.38.0", default-features = false }
 subxt-signer = { version = "0.38.0", default-features = false, features = ["web", "sr25519", "subxt"] }
 tokio = { version = "1.21.2", default-features = false }
 sp-io = { version = "30", default-features = false, features = [ "disable_panic_handler" ] }
 
 [dependencies]
 serde = { version = "1.0.195", features = ["derive", ] }
-serde_json = { version = "1.0.124" }
+serde_json = { version = "1.0.124", features = ["raw_value"] }
 codec = { package = "parity-scale-codec", version = "3", default-features = false, features = [
 	"derive",
 	"full",

avail-rust/docs/book/src/SUMMARY.md

@@ -9,6 +9,5 @@
     - [Events](./examples/events.md)
     - [Transactions](./examples/transactions.md)
     - [Validator](./examples/validator.md)
-    - [Insecure Connection](./examples/insecure_connection.md)
     - [Batch](./examples/batch.md)
 

avail-rust/docs/book/src/examples/mod.rs

@@ -1,7 +1,6 @@
 mod batch;
 mod data_submission;
 mod events;
-mod insecure_connection;
 mod transactions;
 mod validator;
 
@@ -10,7 +9,6 @@ use avail_rust::error::ClientError;
 pub async fn run() -> Result<(), ClientError> {
 	data_submission::run().await?;
 	events::run().await?;
-	insecure_connection::run().await?;
 	transactions::run().await?;
 	validator::run().await?;
 	batch::run().await?;

avail-rust/src/account.rs

@@ -1,5 +1,8 @@
 use std::str::FromStr;
-use subxt::{backend::rpc::RpcClient, blocks::StaticExtrinsic, ext::scale_encode::EncodeAsFields};
+use subxt::{
+	backend::rpc::reconnecting_rpc_client::RpcClient, blocks::StaticExtrinsic,
+	ext::scale_encode::EncodeAsFields,
+};
 
 use crate::{
 	avail,

avail-rust/src/block.rs

@@ -9,7 +9,7 @@ use crate::{
 };
 
 use primitive_types::H256;
-use subxt::backend::rpc::RpcClient;
+use subxt::backend::rpc::reconnecting_rpc_client::RpcClient;
 use subxt::backend::StreamOfResults;
 use subxt::blocks::StaticExtrinsic;
 use subxt::storage::StorageKeyValuePair;
@@ -21,7 +21,7 @@ pub struct Block {
 }
 
 impl Block {
-	pub async fn new(client: &AOnlineClient, block_hash: H256) -> Result<Self, subxt::Error> {
+	pub async fn new(client: &AOnlineClient, block_hash: H256) -> Result<Self, ClientError> {
 		let (block, transactions) = fetch_transactions(client, block_hash).await?;
 		Ok(Self {
 			block,
@@ -32,15 +32,15 @@ impl Block {
 	pub async fn new_best_block(
 		online_client: &AOnlineClient,
 		rpc_client: &RpcClient,
-	) -> Result<Self, subxt::Error> {
+	) -> Result<Self, ClientError> {
 		let block_hash = Self::fetch_best_block_hash(rpc_client).await?;
 		Self::new(online_client, block_hash).await
 	}
 
 	pub async fn new_finalized_block(
 		online_client: &AOnlineClient,
 		rpc_client: &RpcClient,
-	) -> Result<Self, subxt::Error> {
+	) -> Result<Self, ClientError> {
 		let block_hash = Self::fetch_finalized_block_hash(rpc_client).await?;
 		Self::new(online_client, block_hash).await
 	}
@@ -57,7 +57,7 @@ impl Block {
 		online_client: &AOnlineClient,
 		rpc_client: &RpcClient,
 		block_number: u32,
-	) -> Result<Self, subxt::Error> {
+	) -> Result<Self, ClientError> {
 		let block_hash = rpcs::get_block_hash(rpc_client, Some(block_number)).await?;
 		Self::new(online_client, block_hash).await
 	}
@@ -176,11 +176,11 @@ impl Block {
 		self.block.storage().iter(address).await
 	}
 
-	pub async fn fetch_best_block_hash(client: &RpcClient) -> Result<H256, subxt::Error> {
+	pub async fn fetch_best_block_hash(client: &RpcClient) -> Result<H256, ClientError> {
 		rpcs::get_block_hash(client, None).await
 	}
 
-	pub async fn fetch_finalized_block_hash(client: &RpcClient) -> Result<H256, subxt::Error> {
+	pub async fn fetch_finalized_block_hash(client: &RpcClient) -> Result<H256, ClientError> {
 		rpcs::get_finalized_head(client).await
 	}
 }

avail-rust/src/error.rs

@@ -5,10 +5,14 @@ use subxt_signer::SecretUriError;
 use crate::transactions::TransactionFailed;
 use crate::utils::TransactionExecutionError;
 
+type RpcError = subxt::backend::rpc::reconnecting_rpc_client::Error;
+
 #[derive(Debug)]
 pub enum ClientError {
 	Custom(String),
 	TransactionExecution(TransactionExecutionError),
+	RpcError(RpcError),
+	SerdeJson(serde_json::Error),
 	Subxt(subxt::Error),
 	SubxtSigner(SecretUriError),
 	Sr25519(sr25519::Error),
@@ -19,6 +23,8 @@ impl ClientError {
 		match self {
 			ClientError::Custom(e) => e.clone(),
 			ClientError::TransactionExecution(e) => e.to_string(),
+			ClientError::RpcError(e) => e.to_string(),
+			ClientError::SerdeJson(e) => e.to_string(),
 			ClientError::Subxt(e) => e.to_string(),
 			ClientError::SubxtSigner(e) => e.to_string(),
 			ClientError::Sr25519(e) => e.to_string(),
@@ -67,3 +73,15 @@ impl From<TransactionFailed> for ClientError {
 		value.reason
 	}
 }
+
+impl From<RpcError> for ClientError {
+	fn from(value: RpcError) -> Self {
+		Self::RpcError(value)
+	}
+}
+
+impl From<serde_json::Error> for ClientError {
+	fn from(value: serde_json::Error) -> Self {
+		Self::SerdeJson(value)
+	}
+}