From b9ceca418216976bf127e161fb23ee1ce236664c Mon Sep 17 00:00:00 2001
From: andrussal <salumets.andrus@gmail.com>
Date: Thu, 11 Dec 2025 08:13:23 +0100
Subject: [PATCH] Add logging to DA and transaction utilities

---
 testing-framework/workflows/src/util/tx.rs                   | 1 +
 testing-framework/workflows/src/workloads/da/expectation.rs  | 2 ++
 testing-framework/workflows/src/workloads/da/workload.rs     | 2 ++
 .../workflows/src/workloads/transaction/workload.rs          | 5 +++++
 4 files changed, 10 insertions(+)

diff --git a/testing-framework/workflows/src/util/tx.rs b/testing-framework/workflows/src/util/tx.rs
index 6d797b1..dfe1bd4 100644
--- a/testing-framework/workflows/src/util/tx.rs
+++ b/testing-framework/workflows/src/util/tx.rs
@@ -29,6 +29,7 @@ pub fn create_inscription_transaction_with_id(id: ChannelId) -> SignedMantleTx {
 
     let tx_hash = mantle_tx.hash();
     let signature = signing_key.sign(&tx_hash.as_signing_bytes());
+    tracing::debug!(channel = ?id, tx_hash = ?tx_hash, "building inscription transaction");
 
     SignedMantleTx::new(
         mantle_tx,
diff --git a/testing-framework/workflows/src/workloads/da/expectation.rs b/testing-framework/workflows/src/workloads/da/expectation.rs
index 4063549..c31c7ec 100644
--- a/testing-framework/workflows/src/workloads/da/expectation.rs
+++ b/testing-framework/workflows/src/workloads/da/expectation.rs
@@ -185,11 +185,13 @@ fn capture_block(
     if !new_inscriptions.is_empty() {
         let mut guard = inscriptions.lock().expect("inscription lock poisoned");
         guard.extend(new_inscriptions);
+        tracing::debug!(count = guard.len(), "DA expectation captured inscriptions");
     }
 
     if !new_blobs.is_empty() {
         let mut guard = blobs.lock().expect("blob lock poisoned");
         guard.extend(new_blobs);
+        tracing::debug!(count = guard.len(), "DA expectation captured blobs");
     }
 }
 
diff --git a/testing-framework/workflows/src/workloads/da/workload.rs b/testing-framework/workflows/src/workloads/da/workload.rs
index e6d8b9b..a35cb61 100644
--- a/testing-framework/workflows/src/workloads/da/workload.rs
+++ b/testing-framework/workflows/src/workloads/da/workload.rs
@@ -143,6 +143,7 @@ where
         match receiver.recv().await {
             Ok(record) => {
                 if let Some(msg_id) = find_channel_op(record.block.as_ref(), &mut matcher) {
+                    tracing::debug!(?msg_id, "DA: matched channel operation");
                     return Ok(msg_id);
                 }
             }
@@ -166,6 +167,7 @@ async fn publish_blob(
 
     let signer = SigningKey::from_bytes(&TEST_KEY_BYTES).verifying_key();
     let data = random_blob_payload();
+    tracing::debug!(channel = ?channel_id, payload_bytes = data.len(), "DA: prepared blob payload");
     let client = ExecutorHttpClient::new(None);
 
     let mut candidates: Vec<&ApiClient> = executors.iter().collect();
diff --git a/testing-framework/workflows/src/workloads/transaction/workload.rs b/testing-framework/workflows/src/workloads/transaction/workload.rs
index c03897c..de62c42 100644
--- a/testing-framework/workflows/src/workloads/transaction/workload.rs
+++ b/testing-framework/workflows/src/workloads/transaction/workload.rs
@@ -198,6 +198,11 @@ impl<'a> Submission<'a> {
 
 async fn submit_wallet_transaction(ctx: &RunContext, input: &WalletInput) -> Result<(), DynError> {
     let signed_tx = Arc::new(build_wallet_transaction(input)?);
+    tracing::debug!(
+        tx_hash = ?signed_tx.hash(),
+        user = ?input.account.public_key(),
+        "submitting wallet transaction"
+    );
     submit_transaction_via_cluster(ctx, signed_tx).await
 }