chore: log adjustments

hirosystems · Aug 4, 2023 · dac9eb6 · dac9eb6
1 parent deaa739
commit dac9eb6
Show file tree

Hide file tree

Showing 4 changed files with 15 additions and 22 deletions.
diff --git a/components/hord-cli/src/core/pipeline/mod.rs b/components/hord-cli/src/core/pipeline/mod.rs
@@ -194,13 +194,6 @@ pub async fn download_and_pipeline_blocks(
                 let mut compacted_blocks = vec![];
                 let mut blocks = vec![];
                 while let Some((block, compacted_block)) = inbox.remove(&inbox_cursor) {
-                    cloned_ctx.try_log(|logger| {
-                        info!(
-                            logger,
-                            "Adding block #{inbox_cursor} to next sequence (# blocks inboxed: {})",
-                            inbox.len()
-                        )
-                    });
                     compacted_blocks.push((inbox_cursor, compacted_block));
                     blocks.push(block);
                     inbox_cursor += 1;

diff --git a/components/hord-cli/src/core/pipeline/processors/block_ingestion.rs b/components/hord-cli/src/core/pipeline/processors/block_ingestion.rs
@@ -86,7 +86,9 @@ pub fn store_compacted_blocks(
 
     for (block_height, compacted_block) in compacted_blocks.into_iter() {
         insert_entry_in_blocks(block_height as u32, &compacted_block, &blocks_db_rw, &ctx);
-        info!(ctx.expect_logger(), "Block #{block_height} saved to disk");
+        ctx.try_log(|logger| {
+            info!(logger, "Block #{block_height} saved to disk");
+        });
     }
 
     if let Err(e) = blocks_db_rw.flush() {

diff --git a/components/hord-cli/src/core/pipeline/processors/inscription_indexing.rs b/components/hord-cli/src/core/pipeline/processors/inscription_indexing.rs
@@ -101,6 +101,11 @@ pub fn start_inscription_indexing_processor(
 
                 store_compacted_blocks(compacted_blocks, &blocks_db_rw, &Context::empty());
 
+                // Early return
+                if blocks.is_empty() {
+                    continue;
+                }
+
                 info!(ctx.expect_logger(), "Processing {} blocks", blocks.len());
 
                 blocks = process_blocks(
@@ -182,7 +187,7 @@ pub fn process_blocks(
         ctx.try_log(|logger| {
             info!(
                 logger,
-                "Block #{} revealed {} inscriptions [{}]",
+                "Block #{} processed and revealed {} inscriptions [{}]",
                 block.block_identifier.index,
                 inscriptions_revealed.len(),
                 inscriptions_revealed.join(", ")
@@ -201,12 +206,12 @@ pub fn process_blocks(
         } else {
             match inscriptions_db_tx.commit() {
                 Ok(_) => {
-                    ctx.try_log(|logger| {
-                        info!(
-                            logger,
-                            "Updates saved for block {}", block.block_identifier.index,
-                        )
-                    });
+                    // ctx.try_log(|logger| {
+                    //     info!(
+                    //         logger,
+                    //         "Updates saved for block {}", block.block_identifier.index,
+                    //     )
+                    // });
                 }
                 Err(e) => {
                     ctx.try_log(|logger| {

diff --git a/components/hord-cli/src/core/protocol/inscription_sequencing.rs b/components/hord-cli/src/core/protocol/inscription_sequencing.rs
@@ -245,13 +245,6 @@ pub fn parallelize_inscription_data_computations(
                 let _ = handle.join();
             }
         });
-    } else {
-        ctx.try_log(|logger| {
-            info!(
-                logger,
-                "No inscriptions to index in block #{}", block.block_identifier.index
-            )
-        });
     }
     Ok(has_transactions_to_process)
 }