diff --git a/crates/hotblocks/src/dataset_controller/ingest.rs b/crates/hotblocks/src/dataset_controller/ingest.rs index f2edc18..7f3bb2d 100644 --- a/crates/hotblocks/src/dataset_controller/ingest.rs +++ b/crates/hotblocks/src/dataset_controller/ingest.rs @@ -36,6 +36,9 @@ pub fn ingest<'a, 'b>( DatasetKind::Solana => { run!(sqd_data::solana::tables::SolanaChunkBuilder::new()) }, + DatasetKind::Bitcoin => { + run!(sqd_data::bitcoin::tables::BitcoinChunkBuilder::new()) + }, DatasetKind::HyperliquidFills => { run!(sqd_data::hyperliquid_fills::tables::HyperliquidFillsChunkBuilder::new()) } diff --git a/crates/hotblocks/src/types.rs b/crates/hotblocks/src/types.rs index 692af8f..29aa767 100644 --- a/crates/hotblocks/src/types.rs +++ b/crates/hotblocks/src/types.rs @@ -14,6 +14,8 @@ pub enum DatasetKind { Evm, #[serde(rename = "solana")] Solana, + #[serde(rename = "bitcoin")] + Bitcoin, #[serde(rename = "hyperliquid-fills")] HyperliquidFills, #[serde(rename = "hyperliquid-replica-cmds")] @@ -30,6 +32,7 @@ impl DatasetKind { match self { DatasetKind::Evm => "evm", DatasetKind::Solana => "solana", + DatasetKind::Bitcoin => "bitcoin", DatasetKind::HyperliquidFills => "hl-fills", DatasetKind::HyperliquidReplicaCmds => "hl-replica-cmds", } @@ -39,6 +42,7 @@ impl DatasetKind { match self { DatasetKind::Evm => sqd_data::evm::tables::EvmChunkBuilder::dataset_description(), DatasetKind::Solana => sqd_data::solana::tables::SolanaChunkBuilder::dataset_description(), + DatasetKind::Bitcoin => sqd_data::bitcoin::tables::BitcoinChunkBuilder::dataset_description(), DatasetKind::HyperliquidFills => sqd_data::hyperliquid_fills::tables::HyperliquidFillsChunkBuilder::dataset_description(), DatasetKind::HyperliquidReplicaCmds => sqd_data::hyperliquid_replica_cmds::tables::HyperliquidReplicaCmdsChunkBuilder::dataset_description(), } @@ -48,6 +52,7 @@ impl DatasetKind { match query { Query::Eth(_) => Self::Evm, Query::Solana(_) => Self::Solana, + Query::Bitcoin(_) => Self::Bitcoin, Query::HyperliquidFills(_) => Self::HyperliquidFills, Query::HyperliquidReplicaCmds(_) => Self::HyperliquidReplicaCmds, _ => unimplemented!()