Log warning if a Web3 request timed out

mm2src/coins/eth/web3_transport.rs

@@ -1,4 +1,5 @@
 use super::{RpcTransportEventHandler, RpcTransportEventHandlerShared};
+use common::log::warn;
 #[cfg(not(target_arch = "wasm32"))] use futures::FutureExt;
 use futures::TryFutureExt;
 use futures01::{Future, Poll};
@@ -11,6 +12,8 @@ use web3::error::{Error, ErrorKind};
 use web3::helpers::{build_request, to_result_from_output, to_string};
 use web3::{RequestId, Transport};
 
+const REQUEST_TIMEOUT_S: f64 = 60.;
+
 /// Parse bytes RPC response into `Result`.
 /// Implementation copied from Web3 HTTP transport
 #[cfg(not(target_arch = "wasm32"))]
@@ -122,13 +125,15 @@ async fn send_request(
         *req.uri_mut() = uri.clone();
         req.headers_mut()
             .insert(http::header::CONTENT_TYPE, HeaderValue::from_static("application/json"));
-        let timeout = Timer::sleep(60.);
+        let timeout = Timer::sleep(REQUEST_TIMEOUT_S);
         let req = Box::pin(slurp_req(req));
         let rc = select(req, timeout).await;
         let res = match rc {
             Either::Left((r, _t)) => r,
             Either::Right((_t, _r)) => {
-                errors.push(ERRL!("Error requesting '{}': timeout", uri));
+                let error = ERRL!("Error requesting '{}': {}s timeout expired", uri, REQUEST_TIMEOUT_S);
+                warn!("{}", error);
+                errors.push(error);
                 continue;
             },
         };