add more traces

Author: wlawt

crates/ingress-rpc/src/main.rs

@@ -7,7 +7,7 @@ use rdkafka::producer::FutureProducer;
 use std::fs;
 use std::net::IpAddr;
 use tips_common::init_tracing;
-use tracing::{info, warn};
+use tracing::{info, trace, warn};
 use url::Url;
 
 mod queue;
@@ -98,7 +98,7 @@ async fn main() -> anyhow::Result<()> {
             log_level.to_string(),
         )?;
     }
-    info!(
+    trace!(
         message = "Starting ingress service",
         address = %config.address,
         port = config.port,

crates/ingress-rpc/src/queue.rs

@@ -5,7 +5,7 @@ use async_trait::async_trait;
 use backon::{ExponentialBuilder, Retryable};
 use rdkafka::producer::{FutureProducer, FutureRecord};
 use tokio::time::Duration;
-use tracing::{error, info};
+use tracing::{error, info, trace};
 
 /// A queue to buffer transactions
 #[async_trait]
@@ -32,6 +32,7 @@ impl KafkaQueuePublisher {
         let key = sender.to_string();
         let payload = serde_json::to_vec(bundle)?;
 
+        trace!(message = "Enqueuing bundle", sender = %sender, topic = %self.topic);
         let enqueue = || async {
             let record = FutureRecord::to(&self.topic).key(&key).payload(&payload);
 

crates/ingress-rpc/src/service.rs

@@ -11,7 +11,7 @@ use op_alloy_consensus::OpTxEnvelope;
 use op_alloy_network::Optimism;
 use reth_rpc_eth_types::EthApiError;
 use std::time::{SystemTime, UNIX_EPOCH};
-use tracing::{info, warn};
+use tracing::{info, trace, warn};
 
 use crate::queue::QueuePublisher;
 
@@ -75,6 +75,7 @@ where
     }
 
     async fn send_raw_transaction(&self, data: Bytes) -> RpcResult<B256> {
+        trace!(message = "Sending raw transaction", data = %data);
         if data.is_empty() {
             return Err(EthApiError::EmptyRawTransactionData.into_rpc_err());
         }
@@ -92,6 +93,8 @@ where
             .provider
             .fetch_account_info(transaction.signer())
             .await?;
+
+        trace!(message = "Validating transaction", account = %transaction.signer(), transaction = %transaction.tx_hash());
         validate_tx(account, &transaction, &data, &mut l1_block_info).await?;
 
         let expiry_timestamp = SystemTime::now()
@@ -110,6 +113,7 @@ where
         };
 
         // queue the bundle
+        trace!(message = "Queueing bundle", bundle = ?bundle);
         let sender = transaction.signer();
         if let Err(e) = self.queue.publish(&bundle, sender).await {
             warn!(message = "Failed to publish Queue::enqueue_bundle", sender = %sender, error = %e);

crates/ingress-rpc/src/validation.rs

@@ -9,7 +9,7 @@ use op_alloy_network::Optimism;
 use op_revm::{OpSpecId, l1block::L1BlockInfo};
 use reth_optimism_evm::extract_l1_info_from_tx;
 use reth_rpc_eth_types::{EthApiError, RpcInvalidTransactionError, SignError};
-use tracing::warn;
+use tracing::{trace, warn};
 
 /// Account info for a given address
 pub struct AccountInfo {
@@ -89,6 +89,8 @@ pub async fn validate_tx<T: Transaction>(
     data: &[u8],
     l1_block_info: &mut L1BlockInfo,
 ) -> RpcResult<()> {
+    trace!(message = "Validating with no state", account = %txn.signer(), transaction = ?txn);
+
     // skip eip4844 transactions
     if txn.is_eip4844() {
         warn!(message = "EIP-4844 transactions are not supported");
@@ -108,6 +110,7 @@ pub async fn validate_tx<T: Transaction>(
         }
     }
 
+    trace!(message = "Validating with inner state", account = %txn.signer(), transaction = ?txn);
     // error if account is 7702 but tx is not 7702
     if account.code_hash != KECCAK_EMPTY && !txn.is_eip7702() {
         return Err(EthApiError::InvalidTransaction(
@@ -144,6 +147,7 @@ pub async fn validate_tx<T: Transaction>(
         .into_rpc_err());
     }
 
+    trace!(message = "Validating op checks", account = %txn.signer(), transaction = ?txn);
     // op-checks to see if sender can cover L1 gas cost
     // from: https://github.com/paradigmxyz/reth/blob/6aa73f14808491aae77fc7c6eb4f0aa63bef7e6e/crates/optimism/txpool/src/validator.rs#L219
     let l1_cost_addition = l1_block_info.calculate_tx_l1_cost(data, OpSpecId::ISTHMUS);