kylefang/bitcoin-indexer
1
0
Fork 0
mirror of https://github.com/alexgo-io/bitcoin-indexer.git synced 2026-06-14 08:29:31 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: off by one

Browse Source
This commit is contained in:
Ludo Galabru
2023-08-02 17:48:13 +02:00
parent 8b46a5d7f4
commit 94e11411f8
2 changed files with 5 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
components/hord-cli/src/core/mod.rs
View File

@@ -240,7 +240,7 @@ pub fn should_sync_hord_db(config: &Config, ctx: &Context) -> Result<Option<(u64
start_block += 1;
if start_block < end_block {
if start_block <= end_block {
Ok(Some((start_block, end_block)))
} else {
Ok(None)

10
components/hord-cli/src/service/mod.rs
View File

@@ -3,7 +3,7 @@ mod runloops;
use crate::cli::fetch_and_standardize_block;
use crate::config::{Config, PredicatesApi, PredicatesApiConfig};
use crate::core::pipeline::processors::inscription_indexing::{process_blocks};
use crate::core::pipeline::processors::inscription_indexing::process_blocks;
use crate::core::pipeline::processors::start_inscription_indexing_processor;
use crate::core::pipeline::{download_and_pipeline_blocks, PostProcessorCommand};
use crate::core::protocol::sequencing::update_storage_and_augment_bitcoin_block_with_inscription_transfer_data_tx;
@@ -30,17 +30,15 @@ use chainhook_sdk::chainhooks::types::{
use chainhook_sdk::indexer::bitcoin::build_http_client;
use chainhook_sdk::observer::{
start_event_observer, BitcoinConfig, EventObserverConfig, HandleBlock,
ObserverEvent,
start_event_observer, BitcoinConfig, EventObserverConfig, HandleBlock, ObserverEvent,
};
use chainhook_sdk::types::{
BitcoinBlockData, BitcoinNetwork, OrdinalInscriptionTransferData,
OrdinalOperation,
BitcoinBlockData, BitcoinNetwork, OrdinalInscriptionTransferData, OrdinalOperation,
};
use chainhook_sdk::utils::Context;
use redis::{Commands, Connection};
use std::collections::{BTreeMap};
use std::collections::BTreeMap;
use std::sync::mpsc::{channel, Sender};
use std::sync::Arc;