uqbar-dao/nectar
1
1
Fork 0
mirror of https://github.com/uqbar-dao/nectar.git synced 2024-12-22 16:11:38 +03:00
Code Issues Packages Projects Releases Wiki Activity

add printout for newHeads (bad!)

Browse Source
This commit is contained in:
dr-frmr 2024-09-13 16:49:28 -04:00
parent bd4147bd9b
commit df3bb4795d
No known key found for this signature in database
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
kinode/src/eth/subscription.rs
View File

@ -1,6 +1,7 @@
use crate::eth::*; use crate::eth::*;
use alloy::pubsub::RawSubscription; use alloy::pubsub::RawSubscription;
use alloy::rpc::types::eth::pubsub::SubscriptionResult; use alloy::rpc::types::eth::pubsub::SubscriptionResult;
use alloy::rpc::types::pubsub;
/// cleans itself up when the subscription is closed or fails. /// cleans itself up when the subscription is closed or fails.
pub async fn create_new_subscription( pub async fn create_new_subscription(
@ -189,6 +190,11 @@ async fn build_subscription(
else { else {
return Err(EthError::PermissionDenied); // will never hit return Err(EthError::PermissionDenied); // will never hit
}; };
if *kind == pubsub::SubscriptionKind::NewHeads {
Printout::new(0, format!("newHeads subscription requested by {target}!"))
.send(print_tx)
.await;
}
let mut urls = { let mut urls = {
// in code block to drop providers lock asap to avoid deadlock // in code block to drop providers lock asap to avoid deadlock
let Some(aps) = providers.get(&chain_id) else { let Some(aps) = providers.get(&chain_id) else {