Add Debug to event type (#141)

dcSpark · Feb 27, 2023 · acbf44c · acbf44c
1 parent 26c085b
commit acbf44c
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git 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
@@ -10,7 +10,7 @@ use std::time::Duration;
 
 pub struct FetchEngine<
     FromType: PullFrom + Clone,
-    EventType,
+    EventType: std::fmt::Debug,
     SourceType: Source<From = FromType, Event = EventType> + StoppableService + Send,
     SinkType: Sink<From = FromType, Event = EventType> + StoppableService + Send,
 > {
@@ -21,7 +21,7 @@ pub struct FetchEngine<
 
 impl<
         FromType: PullFrom + Clone,
-        EventType: GetNextFrom<From = FromType>,
+        EventType: std::fmt::Debug + GetNextFrom<From = FromType>,
         SourceType: Source<From = FromType, Event = EventType> + StoppableService + Send,
         SinkType: Sink<From = FromType, Event = EventType> + StoppableService + Send,
     > FetchEngine<FromType, EventType, SourceType, SinkType>
@@ -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<From = FromType>,
+        EventType: std::fmt::Debug + GetNextFrom<From = FromType>,
         SourceType: Source<From = FromType, Event = EventType> + StoppableService + Send,
         SinkType: Sink<From = FromType, Event = EventType> + StoppableService + Send,
     > StoppableService for FetchEngine<FromType, EventType, SourceType, SinkType>