mirror of
https://github.com/alexgo-io/bitcoin-indexer.git
synced 2026-06-15 00:49:30 +08:00
fix: revisit transfer loop
This commit is contained in:
@@ -734,9 +734,16 @@ async fn handle_command(opts: Opts, ctx: &Context) -> Result<(), String> {
|
||||
};
|
||||
let service = Service::new(config, ctx.clone());
|
||||
let blocks = cmd.get_blocks();
|
||||
service
|
||||
.replay_transfers(blocks, block_post_processor)
|
||||
.await?;
|
||||
info!(
|
||||
ctx.expect_logger(),
|
||||
"Re-indexing transfers for {} blocks",
|
||||
blocks.len()
|
||||
);
|
||||
for block in blocks.into_iter() {
|
||||
service
|
||||
.replay_transfers(vec![block], block_post_processor.clone())
|
||||
.await?;
|
||||
}
|
||||
}
|
||||
},
|
||||
Command::Db(OrdhookDbCommand::Check(cmd)) => {
|
||||
|
||||
@@ -515,13 +515,7 @@ impl Service {
|
||||
let blocks_post_processor =
|
||||
start_transfers_recomputing_processor(&self.config, &self.ctx, block_post_processor);
|
||||
|
||||
info!(
|
||||
self.ctx.expect_logger(),
|
||||
"Re-indexing transfers for {} blocks",
|
||||
blocks.len()
|
||||
);
|
||||
|
||||
let ordhook_config = self.config.get_ordhook_config();
|
||||
let ordhook_config = self.config.get_ordhook_config();
|
||||
let first_inscription_height = ordhook_config.first_inscription_height;
|
||||
download_and_pipeline_blocks(
|
||||
&self.config,
|
||||
|
||||
Reference in New Issue
Block a user