revertme: use serde json again

paradigmxyz · Oct 1, 2024 · 989700b · 989700b
1 parent c1fe123
commit 989700b
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 26 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/crates/exex/exex/Cargo.toml b/crates/exex/exex/Cargo.toml
@@ -46,7 +46,8 @@ eyre.workspace = true
 itertools.workspace = true
 metrics.workspace = true
 parking_lot.workspace = true
-rmp-serde = "1.3"
+# 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
@@ -118,7 +118,8 @@ impl Storage {
 
         // Deserialize using the bincode- and msgpack-compatible serde wrapper
         let notification: reth_exex_types::serde_bincode_compat::ExExNotification<'_> =
-            rmp_serde::decode::from_read(&mut file).map_err(|err| {
+            // rmp_serde::decode::from_read(&mut file).map_err(|err| {
+        serde_json::from_reader(&mut file).map_err(|err| {
                 eyre::eyre!("failed to decode notification from {file_path:?}: {err:?}")
             })?;
 
@@ -140,7 +141,8 @@ impl Storage {
             reth_exex_types::serde_bincode_compat::ExExNotification::from(notification);
 
         Ok(reth_fs_util::atomic_write_file(&file_path, |file| {
-            rmp_serde::encode::write(file, &notification)
+            // rmp_serde::encode::write(file, &notification)
+            serde_json::to_writer(file, &notification)
         })?)
     }
 }