feat: draft ordhook-sdk-js

Author: Ludo Galabru

Cargo.lock

@@ -2,6 +2,7 @@
 members = [
     "components/ordhook-cli",
     "components/ordhook-core",
+    "components/ordhook-sdk-js"
 ]
 
 default-members = ["components/ordhook-cli"]

Cargo.toml

@@ -21,7 +21,9 @@ use crate::{
     core::{
         pipeline::processors::block_archiving::store_compacted_blocks,
         protocol::{
-            inscription_parsing::{get_inscriptions_revealed_in_block, get_inscriptions_transferred_in_block},
+            inscription_parsing::{
+                get_inscriptions_revealed_in_block, get_inscriptions_transferred_in_block,
+            },
             inscription_sequencing::{
                 augment_block_with_ordinals_inscriptions_data_and_write_to_db_tx,
                 parallelize_inscription_data_computations, SequenceCursor,

components/ordhook-core/src/core/pipeline/processors/inscription_indexing.rs

@@ -6,7 +6,7 @@ use chainhook_sdk::bitcoincore_rpc_json::bitcoin::Txid;
 use chainhook_sdk::indexer::bitcoin::{standardize_bitcoin_block, BitcoinBlockFullBreakdown};
 use chainhook_sdk::types::{
     BitcoinBlockData, BitcoinNetwork, BitcoinTransactionData, OrdinalInscriptionCurseType,
-    OrdinalInscriptionRevealData, OrdinalOperation, OrdinalInscriptionTransferData,
+    OrdinalInscriptionRevealData, OrdinalInscriptionTransferData, OrdinalOperation,
 };
 use chainhook_sdk::utils::Context;
 use chainhook_sdk::{

components/ordhook-core/src/core/protocol/inscription_parsing.rs

@@ -19,7 +19,7 @@ use chainhook_sdk::chainhooks::types::BitcoinChainhookSpecification;
 use chainhook_sdk::indexer::bitcoin::{
     build_http_client, download_and_parse_block_with_retry, retrieve_block_hash_with_retry,
 };
-use chainhook_sdk::observer::{gather_proofs, EventObserverConfig};
+use chainhook_sdk::observer::{gather_proofs, DataHandlerEvent, EventObserverConfig};
 use chainhook_sdk::types::{
     BitcoinBlockData, BitcoinChainEvent, BitcoinChainUpdatedWithBlocksData,
 };
@@ -273,7 +273,7 @@ pub async fn execute_predicates_action<'a>(
                     }
                     BitcoinChainhookOccurrence::Data(payload) => {
                         if let Some(ref tx) = config.data_handler_tx {
-                            let _ = tx.send(payload);
+                            let _ = tx.send(DataHandlerEvent::Process(payload));
                         }
                     }
                 };

components/ordhook-core/src/scan/bitcoin.rs

@@ -31,8 +31,8 @@ use chainhook_sdk::chainhooks::types::{
     BitcoinChainhookSpecification, ChainhookFullSpecification, ChainhookSpecification,
 };
 use chainhook_sdk::observer::{
-    start_event_observer, BitcoinBlockDataCached, EventObserverConfig, HandleBlock,
-    ObserverCommand, ObserverEvent, ObserverSidecar,
+    start_event_observer, BitcoinBlockDataCached, DataHandlerEvent, EventObserverConfig,
+    HandleBlock, ObserverCommand, ObserverEvent, ObserverSidecar,
 };
 use chainhook_sdk::types::{BitcoinBlockData, BlockIdentifier};
 use chainhook_sdk::utils::{BlockHeights, Context};
@@ -374,7 +374,7 @@ impl Service {
     ) -> Result<
         (
             EventObserverConfig,
-            Option<crossbeam_channel::Receiver<BitcoinChainhookOccurrencePayload>>,
+            Option<crossbeam_channel::Receiver<DataHandlerEvent>>,
         ),
         String,
     > {
@@ -456,9 +456,7 @@ impl Service {
                 &self.ctx,
             )?;
         }
-
         let tx_replayer = start_observer_forwarding(event_observer_config, &self.ctx);
-
         self.update_state(Some(tx_replayer)).await?;
         Ok(())
     }
@@ -469,7 +467,6 @@ impl Service {
     ) -> Result<(), String> {
         // Start predicate processor
         let mut last_block_processed = 0;
-
         while let Some((start_block, end_block, speed)) =
             should_sync_ordhook_db(&self.config, &self.ctx)?
         {
@@ -482,10 +479,12 @@ impl Service {
                 block_post_processor.clone(),
             );
 
-            info!(
-                self.ctx.expect_logger(),
-                "Indexing inscriptions from block #{start_block} to block #{end_block}"
-            );
+            self.ctx.try_log(|logger| {
+                info!(
+                    logger,
+                    "Indexing inscriptions from block #{start_block} to block #{end_block}"
+                )
+            });
 
             let ordhook_config = self.config.get_ordhook_config();
             let first_inscription_height = ordhook_config.first_inscription_height;
@@ -515,7 +514,7 @@ impl Service {
         let blocks_post_processor =
             start_transfers_recomputing_processor(&self.config, &self.ctx, block_post_processor);
 
-            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,