diff --git a/indexer/src/common.rs b/indexer/src/common.rs index 1b919c89..f4860b69 100644 --- a/indexer/src/common.rs +++ b/indexer/src/common.rs @@ -2,6 +2,7 @@ use dcspark_blockchain_source::cardano::Point; use dcspark_blockchain_source::{EventObject, GetNextFrom}; use dcspark_core::{BlockId, SlotNumber}; +#[derive(Debug)] pub enum CardanoEventType { RollBack { block_slot: u64, diff --git a/indexer/src/engine.rs b/indexer/src/engine.rs index 4dd68e7e..27bb4316 100644 --- a/indexer/src/engine.rs +++ b/indexer/src/engine.rs @@ -10,7 +10,7 @@ use std::time::Duration; pub struct FetchEngine< FromType: PullFrom + Clone, - EventType, + EventType: std::fmt::Debug, SourceType: Source + StoppableService + Send, SinkType: Sink + StoppableService + Send, > { @@ -21,7 +21,7 @@ pub struct FetchEngine< impl< FromType: PullFrom + Clone, - EventType: GetNextFrom, + EventType: std::fmt::Debug + GetNextFrom, SourceType: Source + StoppableService + Send, SinkType: Sink + StoppableService + Send, > FetchEngine @@ -54,7 +54,6 @@ impl< continue; }; perf_aggregator.block_fetch += event_fetch_start.elapsed(); - let new_from = event.next_from().unwrap_or(pull_from); self.sink.process(event, &mut perf_aggregator).await?; pull_from = new_from; @@ -67,7 +66,7 @@ impl< #[async_trait] impl< FromType: PullFrom + Clone, - EventType: GetNextFrom, + EventType: std::fmt::Debug + GetNextFrom, SourceType: Source + StoppableService + Send, SinkType: Sink + StoppableService + Send, > StoppableService for FetchEngine