Update jsonrpsee reference (#1049)

* update jsonrpsee

* test

* Revert "test"

This reverts commit 2b69652ab92ff0d9649088c76faed2c94384540d.

bridges/relays/client-substrate/Cargo.toml

@@ -9,8 +9,8 @@ license = "GPL-3.0-or-later WITH Classpath-exception-2.0"
 async-std = { version = "1.6.5", features = ["attributes"] }
 async-trait = "0.1.40"
 codec = { package = "parity-scale-codec", version = "2.2.0" }
-jsonrpsee-proc-macros = "=0.2.0-alpha.6"
-jsonrpsee-ws-client = "=0.2.0-alpha.6"
+jsonrpsee-proc-macros = "0.2"
+jsonrpsee-ws-client = "0.2"
 log = "0.4.11"
 num-traits = "0.2"
 rand = "0.7"

bridges/relays/client-substrate/src/error.rs

@@ -71,9 +71,7 @@ impl MaybeConnectionError for Error {
 	fn is_connection_error(&self) -> bool {
 		matches!(
 			*self,
-			Error::RpcError(RpcError::TransportError(_))
-				// right now if connection to the ws server is dropped (after it is already established),
-				// we're getting this error
+			Error::RpcError(RpcError::Transport(_))
 				| Error::RpcError(RpcError::Internal(_))
 				| Error::RpcError(RpcError::RestartNeeded(_))
 				| Error::ClientNotSynced(_),

bridges/relays/client-substrate/src/finality_source.rs

@@ -134,20 +134,27 @@ where
 			self.client.clone().subscribe_justifications().await?,
 			move |mut subscription| async move {
 				loop {
-					let next_justification = subscription.next().await?;
+					let log_error = |err| {
+						log::error!(
+							target: "bridge",
+							"Failed to read justification target from the {} justifications stream: {:?}",
+							P::SOURCE_NAME,
+							err,
+						);
+					};
+
+					let next_justification = subscription
+						.next()
+						.await
+						.map_err(|err| log_error(err.to_string()))
+						.ok()??;
 					let decoded_justification =
 						GrandpaJustification::<C::Header>::decode(&mut &next_justification.0[..]);
 
 					let justification = match decoded_justification {
 						Ok(j) => j,
 						Err(err) => {
-							log::error!(
-								target: "bridge",
-								"Failed to decode justification target from the {} justifications stream: {:?}",
-								P::SOURCE_NAME,
-								err,
-							);
-
+							log_error(format!("decode failed with error {:?}", err));
 							continue;
 						}
 					};