use serde_json

paradigmxyz · Sep 24, 2024 · bf5cd2b · bf5cd2b
1 parent ba279f3
commit bf5cd2b
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 27 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/crates/exex/exex/Cargo.toml b/crates/exex/exex/Cargo.toml
@@ -39,7 +39,7 @@ tokio.workspace = true
 ## misc
 eyre.workspace = true
 metrics.workspace = true
-rmp-serde = "1.3"
+serde_json.workspace = true
 tracing.workspace = true
 
 [dev-dependencies]

diff --git a/crates/exex/exex/src/wal/storage.rs b/crates/exex/exex/src/wal/storage.rs
@@ -131,14 +131,18 @@ impl Storage {
     }
 }
 
-fn write_notification(w: &mut impl Write, notification: &ExExNotification) -> eyre::Result<()> {
-    rmp_serde::encode::write(w, notification)?;
+// TODO(alexey): use rmp-serde when Alloy and Reth serde issues are resolved
+
+fn write_notification(mut w: &mut impl Write, notification: &ExExNotification) -> eyre::Result<()> {
+    // rmp_serde::encode::write(w, notification)?;
+    serde_json::to_writer(&mut w, notification)?;
     w.flush()?;
     Ok(())
 }
 
 fn read_notification(r: &mut impl Read) -> eyre::Result<ExExNotification> {
-    Ok(rmp_serde::from_read(r)?)
+    // Ok(rmp_serde::from_read(r)?)
+    Ok(serde_json::from_reader(r)?)
 }
 
 #[cfg(test)]