clean up pt2

Author: cody-wang-cb

crates/audit/src/reader.rs

@@ -10,7 +10,7 @@ use rdkafka::{
 use std::time::{Duration, SystemTime, UNIX_EPOCH};
 use tips_core::kafka::load_kafka_config_from_file;
 use tokio::time::sleep;
-use tracing::{error, info};
+use tracing::{debug, error};
 
 pub fn create_kafka_consumer(kafka_properties_file: &str) -> Result<StreamConsumer> {
     let client_config: ClientConfig =
@@ -79,7 +79,7 @@ impl EventReader for KafkaAuditLogReader {
 
                 let event: BundleEvent = serde_json::from_slice(payload)?;
 
-                info!(
+                debug!(
                     event_name = %event.event_name(),
                     bundle_id = ?event.bundle_id(),
                     tx_hash = ?event.tx_hash(),

crates/audit/src/storage.rs

@@ -63,53 +63,45 @@ pub enum BundleHistoryEvent {
         timestamp: i64,
         reason: DropReason,
     },
-    /// Transaction received by ingress-rpc
     TransactionReceived {
         key: String,
         timestamp: i64,
         bundle: Box<AcceptedBundle>,
     },
-    /// Transaction sent from ingress-rpc
     TransactionSent {
         key: String,
         timestamp: i64,
         tx_hash: TxHash,
     },
-    /// Backrun bundle received by ingress-rpc
     BackrunReceived {
         key: String,
         timestamp: i64,
         bundle: Box<AcceptedBundle>,
     },
-    /// Backrun bundle sent to builder from ingress-rpc
     BackrunSent {
         key: String,
         timestamp: i64,
         target_tx_hash: TxHash,
     },
-    /// Backrun bundle inserted into builder store in builder
     BackrunInserted {
         key: String,
         timestamp: i64,
         target_tx_hash: TxHash,
         backrun_tx_hashes: Vec<TxHash>,
     },
-    /// Transaction selected for execution
     StartExecuting {
         key: String,
         timestamp: i64,
         tx_hash: TxHash,
         block_number: u64,
     },
-    /// Transaction successfully executed
     Executed {
         key: String,
         timestamp: i64,
         tx_hash: TxHash,
         block_number: u64,
         gas_used: u64,
     },
-    /// Backrun bundle transaction executed
     BackrunBundleExecuted {
         key: String,
         timestamp: i64,

crates/audit/src/types.rs

@@ -268,22 +268,13 @@ impl BundleEvent {
             BundleEvent::BackrunInserted { bundle_id, .. } => {
                 format!("backrun-inserted-{bundle_id}")
             }
-            BundleEvent::StartExecuting {
-                tx_hash,
-                ..
-            } => {
+            BundleEvent::StartExecuting { tx_hash, .. } => {
                 format!("tx-start-executing-{tx_hash}")
-            },
-            BundleEvent::Executed {
-                tx_hash,
-                ..
-            } => {
+            }
+            BundleEvent::Executed { tx_hash, .. } => {
                 format!("tx-executed-{tx_hash}")
-            },
-            BundleEvent::BackrunBundleExecuted {
-                bundle_id,
-                ..
-            } => {
+            }
+            BundleEvent::BackrunBundleExecuted { bundle_id, .. } => {
                 format!("backrun-bundle-executed-{bundle_id}")
             }
             _ => {

crates/ingress-rpc/src/lib.rs

@@ -11,7 +11,7 @@ use std::net::{IpAddr, SocketAddr};
 use std::str::FromStr;
 use tips_core::MeterBundleResponse;
 use tokio::sync::broadcast;
-use tracing::{error, info, warn};
+use tracing::{error, warn};
 use url::Url;
 
 #[derive(Debug, Clone, Copy)]

justfile

@@ -99,11 +99,6 @@ get-blocks:
 sender := "0x70997970C51812dc3A010C7d01b50e0d17dc79C8"
 sender_key := "0x59c6995e998f97a5a0044966f0945389dc9e86dae88c7a8412f4603b6b78690d"
 
-backrunner := "0x3C44CdDdB6a900fa2b585dd299e03d12FA4293BC"
-backrunner_key := "0x5de4111afa1a4b94908f83103eb1f1706367c2e68ca870fc3fb9a804cdab365a"
-
-chain_id := "13"
-
 send-txn:
     #!/usr/bin/env bash
     set -euxo pipefail