node-data: change Event to only support JSON

node-data/src/events.rs

@@ -15,15 +15,15 @@ pub struct Event {
     pub component: &'static str,
     pub topic: &'static str,
     pub entity: String,
-    pub data: EventData,
+    pub data: Option<serde_json::Value>,
 }
 
 pub trait EventSource {
     const COMPONENT: &'static str;
 
     fn topic(&self) -> &'static str;
     fn entity(&self) -> String;
-    fn data(&self) -> EventData;
+    fn data(&self) -> Option<serde_json::Value>;
 }
 
 impl<ES: EventSource> From<ES> for Event {
@@ -36,11 +36,3 @@ impl<ES: EventSource> From<ES> for Event {
         }
     }
 }
-
-#[derive(Clone, Debug)]
-pub enum EventData {
-    None,
-    Json(serde_json::Value),
-    Text(String),
-    Binary(Vec<u8>),
-}

node-data/src/events/blocks.rs

@@ -16,26 +16,27 @@ impl EventSource for BlockEvent<'_> {
             Self::StateChange { .. } => "statechange",
         }
     }
-    fn data(&self) -> EventData {
-        match self {
+    fn data(&self) -> Option<serde_json::Value> {
+        let data = match self {
             Self::Accepted(b) => {
                 let header = b.header();
                 let header = serde_json::to_value(header)
                     .expect("json to be serialized");
                 let txs: Vec<_> =
                     b.txs().iter().map(|t| hex::encode(t.id())).collect();
-                EventData::Json(serde_json::json!({
+                serde_json::json!({
                     "header": header,
                     "transactions": txs,
-                }))
+                })
             }
             Self::StateChange { state, height, .. } => {
-                EventData::Json(serde_json::json!({
+                serde_json::json!({
                     "state": state,
                     "atHeight": height,
-                }))
+                })
             }
-        }
+        };
+        Some(data)
     }
     fn entity(&self) -> String {
         let hash = match self {

node-data/src/events/transactions.rs

@@ -24,8 +24,8 @@ impl EventSource for TransactionEvent<'_> {
             Self::Included(_) => "included",
         }
     }
-    fn data(&self) -> EventData {
-        EventData::None
+    fn data(&self) -> Option<serde_json::Value> {
+        None
     }
     fn entity(&self) -> String {
         let hash = match self {