chore: add debug logs

Author: danyalprout

crates/audit/src/lib.rs

@@ -21,7 +21,7 @@ where
         let mut event_rx = event_rx;
         while let Some(event) = event_rx.recv().await {
             if let Err(e) = publisher.publish(event).await {
-                error!(error = %e, "Failed to publish bundle event");
+                error!(error = %e, "failed to publish bundle event");
             }
         }
     });

crates/audit/src/publisher.rs

@@ -40,7 +40,7 @@ impl KafkaBundleEventPublisher {
                     bundle_id = %bundle_id,
                     topic = %self.topic,
                     payload_size = payload.len(),
-                    "Successfully published event"
+                    "successfully published event"
                 );
                 Ok(())
             }
@@ -49,7 +49,7 @@ impl KafkaBundleEventPublisher {
                     bundle_id = %bundle_id,
                     topic = %self.topic,
                     error = %err,
-                    "Failed to publish event"
+                    "failed to publish event"
                 );
                 Err(anyhow::anyhow!("Failed to publish event: {err}"))
             }

crates/audit/src/reader.rs

@@ -104,7 +104,6 @@ impl EventReader for KafkaAuditLogReader {
                 Ok(event_result)
             }
             Err(e) => {
-                println!("received error {e:?}");
                 error!(error = %e, "Error receiving message from Kafka");
                 sleep(Duration::from_secs(1)).await;
                 Err(e.into())

crates/ingress-rpc/src/service.rs

@@ -285,7 +285,13 @@ impl<Q: MessageQueue + 'static> IngressApiServer for IngressService<Q> {
             });
         }
 
-        self.send_audit_event(&accepted_bundle, transaction.tx_hash());
+        debug!(
+            message = "processed transaction",
+            bundle_hash = %bundle_hash,
+            transaction_hash = %transaction.tx_hash(),
+        );
+
+        self.send_audit_event(&accepted_bundle, accepted_bundle.bundle_hash());
 
         self.metrics
             .send_raw_transaction_duration
@@ -431,7 +437,7 @@ impl<Q: MessageQueue> IngressService<Q> {
         };
         if let Err(e) = self.audit_channel.send(audit_event) {
             warn!(
-                message = "Failed to send audit event",
+                message = "failed to send audit event",
                 bundle_hash = %bundle_hash,
                 error = %e
             );