@@ -7,7 +7,7 @@ use std::{
7
7
8
8
use chainhook_sdk:: {
9
9
indexer:: bitcoin:: {
10
- build_http_client, download_block_with_retry, retrieve_block_hash_with_retry, try_fetch_block_bytes_with_retry , parse_fetched_block,
10
+ build_http_client, download_block_with_retry, retrieve_block_hash_with_retry, try_download_block_bytes_with_retry , parse_fetched_block, download_block , parse_downloaded_block ,
11
11
} ,
12
12
types:: {
13
13
BitcoinBlockData , BlockIdentifier , OrdinalInscriptionRevealData ,
@@ -1891,7 +1891,7 @@ pub async fn rebuild_rocks_db(
1891
1891
let config = moved_config. clone ( ) ;
1892
1892
let ctx = moved_ctx. clone ( ) ;
1893
1893
let http_client = moved_http_client. clone ( ) ;
1894
- set. spawn ( try_fetch_block_bytes_with_retry (
1894
+ set. spawn ( try_download_block_bytes_with_retry (
1895
1895
http_client,
1896
1896
block_height,
1897
1897
config,
@@ -1905,7 +1905,7 @@ pub async fn rebuild_rocks_db(
1905
1905
while let Ok ( Some ( block_bytes) ) = block_data_rx. recv ( ) {
1906
1906
let block_compressed_tx_moved = block_compressed_tx. clone ( ) ;
1907
1907
compress_block_data_pool. execute ( move || {
1908
- let block_data = parse_fetched_block ( block_bytes) . unwrap ( ) ;
1908
+ let block_data = parse_downloaded_block ( block_bytes) . unwrap ( ) ;
1909
1909
let compressed_block =
1910
1910
LazyBlock :: from_full_block ( & block_data) . expect ( "unable to serialize block" ) ;
1911
1911
let block_index = block_data. height as u32 ;
@@ -1998,7 +1998,7 @@ pub async fn rebuild_rocks_db(
1998
1998
let config = moved_config. clone ( ) ;
1999
1999
let ctx = ctx. clone ( ) ;
2000
2000
let http_client = moved_http_client. clone ( ) ;
2001
- set. spawn ( try_fetch_block_bytes_with_retry (
2001
+ set. spawn ( try_download_block_bytes_with_retry (
2002
2002
http_client,
2003
2003
block_height,
2004
2004
config,
0 commit comments