diff --git a/web3_proxy/src/bin/web3_proxy_cli/sentryd/compare.rs b/web3_proxy/src/bin/web3_proxy_cli/sentryd/compare.rs index f4b5c27f..c04f350d 100644 --- a/web3_proxy/src/bin/web3_proxy_cli/sentryd/compare.rs +++ b/web3_proxy/src/bin/web3_proxy_cli/sentryd/compare.rs @@ -184,11 +184,15 @@ async fn check_rpc( Ok(abbreviated) } else if let Some(result) = response.error { Err(anyhow!( - "Failed parsing response from {} as JSON: {:?}", + "jsonrpc error during check_rpc from {}: {:#}", rpc, - result + json!(result), )) } else { - unimplemented!("{:?}", response) + Err(anyhow!( + "empty result during check_rpc from {}: {:#}", + rpc, + json!(response) + )) } } diff --git a/web3_proxy/src/bin/web3_proxy_cli/sentryd/mod.rs b/web3_proxy/src/bin/web3_proxy_cli/sentryd/mod.rs index 0708f7a7..cd14e351 100644 --- a/web3_proxy/src/bin/web3_proxy_cli/sentryd/mod.rs +++ b/web3_proxy/src/bin/web3_proxy_cli/sentryd/mod.rs @@ -152,7 +152,14 @@ impl SentrydSubCommand { } // check any other web3-proxy /health endpoints for other_web3_proxy in other_proxy.iter() { - let url = format!("{}/health", other_web3_proxy); + let url = if other_web3_proxy.contains("/rpc/") { + let x = other_web3_proxy.split("/rpc/").next().unwrap(); + + format!("{}/health", x) + } else { + format!("{}/health", other_web3_proxy) + }; + let error_sender = error_sender.clone(); let loop_f = a_loop(