From 95df7ea443f2a6d76164dd35b8be962f25669d0d Mon Sep 17 00:00:00 2001
From: Michael Sproul <michael@sigmaprime.io>
Date: Fri, 8 Nov 2024 11:59:00 +1100
Subject: [PATCH] Fix attempted optimisation and add more logs

---
 database_manager/src/lib.rs | 16 ++++++++++++----
 1 file changed, 12 insertions(+), 4 deletions(-)

diff --git a/database_manager/src/lib.rs b/database_manager/src/lib.rs
index 73949b7180..b9f9aed22d 100644
--- a/database_manager/src/lib.rs
+++ b/database_manager/src/lib.rs
@@ -578,9 +578,12 @@ fn inspect_blobs<E: EthSpec>(
                 .blob_kzg_commitments()
                 .map_or(0, |blobs| blobs.len());
             if num_expected_blobs > 0 {
-                info!(log, "Slot {}: {} blobs missing", slot, num_expected_blobs);
+                warn!(
+                    log,
+                    "Slot {}: {} blobs missing ({:?})", slot, num_expected_blobs, block_root
+                );
             } else {
-                info!(log, "Slot {}: block with no blobs", slot);
+                info!(log, "Slot {}: block with 0 blobs", slot);
             }
         }
         last_block_root = block_root;
@@ -631,13 +634,18 @@ fn import_blobs<E: EthSpec>(
         } else {
             let blobs = BlobSidecarList::<E>::from_ssz_bytes(&blob_bytes)?;
             ops.push(KeyValueStoreOp::PutKeyValue(
-                block_root.to_vec(),
+                store::get_key_for_col(DBColumn::BeaconBlob.as_str(), block_root.as_slice()),
                 blob_bytes,
             ));
 
             if let Some(blob) = blobs.first() {
                 oldest_blob_slot = oldest_blob_slot.min(blob.slot());
-                debug!(log, "Imported blobs for slot {}", blob.slot());
+                debug!(
+                    log,
+                    "Imported blobs for slot {} ({:?})",
+                    blob.slot(),
+                    block_root
+                );
             }
             num_imported += 1;