add

Author: esemeniuc

Cargo.lock

@@ -3,7 +3,7 @@ members = ["examples", "jito_protos", "proxy"]
 resolver = "2"
 
 [workspace.package]
-version = "0.2.13"
+version = "0.2.14"
 description = "Fast path to receive shreds from Jito, forwarding to local consumers. See https://docs.jito.wtf/lowlatencytxnfeed/ for details."
 authors = ["Jito Team <team@jito.wtf>"]
 homepage = "https://jito.wtf/"
@@ -13,6 +13,7 @@ edition = "2021"
 ahash = "0.8"
 arc-swap = "1.6"
 bincode = "1.3.3"
+bitvec = "1"
 borsh = "1.5.3"
 clap = { version = "4", features = ["derive", "env"] }
 crossbeam-channel = "0.5.8"

Cargo.toml

@@ -1,3 +1,4 @@
+use bincode::Options;
 use jito_protos::shredstream::{
     shredstream_proxy_client::ShredstreamProxyClient, SubscribeEntriesRequest,
 };
@@ -12,16 +13,19 @@ async fn main() -> Result<(), std::io::Error> {
         .await
         .unwrap()
         .into_inner();
+    let bincode_opts = bincode::DefaultOptions::new().with_fixint_encoding();
 
     while let Some(slot_entry) = stream.message().await.unwrap() {
-        let entries =
-            match bincode::deserialize::<Vec<solana_entry::entry::Entry>>(&slot_entry.entries) {
-                Ok(e) => e,
-                Err(e) => {
-                    println!("Deserialization failed with err: {e}");
-                    continue;
-                }
-            };
+        let entries = match bincode_opts
+            .allow_trailing_bytes()
+            .deserialize::<Vec<solana_entry::entry::Entry>>(&slot_entry.entries)
+        {
+            Ok(e) => e,
+            Err(e) => {
+                println!("Deserialization failed with err: {e}");
+                continue;
+            }
+        };
         println!(
             "slot {}, entries: {}, transactions: {}",
             slot_entry.slot,

examples/deshred.rs

@@ -10,6 +10,7 @@ edition = { workspace = true }
 ahash = { workspace = true }
 arc-swap = { workspace = true }
 bincode = { workspace = true }
+bitvec = { workspace = true }
 borsh = { workspace = true }
 clap = { workspace = true }
 crossbeam-channel = { workspace = true }