Skip to content

Commit 1f2151c

Browse files
author
Ludo Galabru
committed
fix: revisit transfer loop
1 parent 4920e86 commit 1f2151c

File tree

2 files changed

+11
-10
lines changed
  • components

2 files changed

+11
-10
lines changed

components/ordhook-cli/src/cli/mod.rs

+10-3
Original file line numberDiff line numberDiff line change
@@ -734,9 +734,16 @@ async fn handle_command(opts: Opts, ctx: &Context) -> Result<(), String> {
734734
};
735735
let service = Service::new(config, ctx.clone());
736736
let blocks = cmd.get_blocks();
737-
service
738-
.replay_transfers(blocks, block_post_processor)
739-
.await?;
737+
info!(
738+
ctx.expect_logger(),
739+
"Re-indexing transfers for {} blocks",
740+
blocks.len()
741+
);
742+
for block in blocks.into_iter() {
743+
service
744+
.replay_transfers(vec![block], block_post_processor.clone())
745+
.await?;
746+
}
740747
}
741748
},
742749
Command::Db(OrdhookDbCommand::Check(cmd)) => {

components/ordhook-core/src/service/mod.rs

+1-7
Original file line numberDiff line numberDiff line change
@@ -515,13 +515,7 @@ impl Service {
515515
let blocks_post_processor =
516516
start_transfers_recomputing_processor(&self.config, &self.ctx, block_post_processor);
517517

518-
info!(
519-
self.ctx.expect_logger(),
520-
"Re-indexing transfers for {} blocks",
521-
blocks.len()
522-
);
523-
524-
let ordhook_config = self.config.get_ordhook_config();
518+
let ordhook_config = self.config.get_ordhook_config();
525519
let first_inscription_height = ordhook_config.first_inscription_height;
526520
download_and_pipeline_blocks(
527521
&self.config,

0 commit comments

Comments
 (0)