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 ab670fa6..1421afd3 100644 --- a/web3_proxy/src/bin/web3_proxy_cli/sentryd/compare.rs +++ b/web3_proxy/src/bin/web3_proxy_cli/sentryd/compare.rs @@ -53,11 +53,13 @@ pub async fn main( .post(&rpc) .json(&block_by_number_request) .send() - .await? + .await + .context(format!("error fetching block from {}", rpc))? .json::>>() - .await? + .await + .context(format!("error parsing block from {}", rpc))? .result - .context(format!("error fetching block from {}", rpc))?; + .context(format!("no block from {}", rpc))?; // check the parent because b and c might not be as fast as a let parent_hash = a.parent_hash; 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 cd14e351..b9a77937 100644 --- a/web3_proxy/src/bin/web3_proxy_cli/sentryd/mod.rs +++ b/web3_proxy/src/bin/web3_proxy_cli/sentryd/mod.rs @@ -95,7 +95,7 @@ impl SentrydSubCommand { } while let Some(err) = error_receiver.recv().await { - log::log!(err.level, "check failed: {:?}", err); + log::log!(err.level, "check failed: {:#?}", err); if matches!(err.level, log::Level::Error) { let alert = pagerduty_alert( @@ -108,20 +108,20 @@ impl SentrydSubCommand { Some("web3-proxy-sentry".to_string()), pagerduty_rs::types::Severity::Error, None, - format!("{}", err.anyhow), + format!("{:#?}", err.anyhow), None, ); if let Some(pagerduty_async) = pagerduty_async.as_ref() { info!( - "sending to pagerduty: {}", + "sending to pagerduty: {:#}", serde_json::to_string_pretty(&alert)? ); if let Err(err) = pagerduty_async.event(Event::AlertTrigger(alert)).await { - error!("Failed sending to pagerduty: {}", err); + error!("Failed sending to pagerduty: {:#?}", err); } } } diff --git a/web3_proxy/src/pagerduty.rs b/web3_proxy/src/pagerduty.rs index b32f3f8a..75675ec8 100644 --- a/web3_proxy/src/pagerduty.rs +++ b/web3_proxy/src/pagerduty.rs @@ -59,6 +59,7 @@ pub fn pagerduty_alert( source.unwrap_or_else(|| gethostname().into_string().unwrap_or("unknown".to_string())); let mut s = DefaultHasher::new(); + // TODO: include severity here? summary.hash(&mut s); client.hash(&mut s); client_url.hash(&mut s);