chore(tracing): improve bundle tracing, break when receiver is dropped (#115)

* chore(tracing): improve bundle tracing, break when receiver is dropped

* chore: don't warn and bail

* chore: clippy

* chore: improve bundle logging

* chore: log on ingestion into cache

* chore: rm tracing changes

* chore: rm tx traces

Author: Evalir

src/tasks/cache/bundle.rs

@@ -1,7 +1,8 @@
 //! Bundler service responsible for fetching bundles and sending them to the simulator.
 use crate::config::BuilderConfig;
+use eyre::bail;
 use init4_bin_base::{
-    deps::tracing::{Instrument, debug, debug_span, error, trace, warn},
+    deps::tracing::{Instrument, debug, debug_span, error, trace},
     perms::SharedToken,
 };
 use oauth2::TokenResponse;
@@ -46,8 +47,7 @@ impl BundlePoller {
     pub async fn check_bundle_cache(&mut self) -> eyre::Result<Vec<TxCacheBundle>> {
         let bundle_url: Url = Url::parse(&self.config.tx_pool_url)?.join("bundles")?;
         let Some(token) = self.token.read() else {
-            warn!("No token available, skipping bundle fetch");
-            return Ok(vec![]);
+            bail!("No token available, skipping bundle fetch");
         };
 
         self.client
@@ -89,10 +89,12 @@ impl BundlePoller {
                 .await
                 .inspect_err(|err| debug!(%err, "Error fetching bundles"))
             {
+                let _guard = span.entered();
                 debug!(count = ?bundles.len(), "found bundles");
                 for bundle in bundles.into_iter() {
                     if let Err(err) = outbound.send(bundle) {
                         error!(err = ?err, "Failed to send bundle - channel is dropped");
+                        break;
                     }
                 }
             }