proto: add from_slot (#477)

rpcpool · Dec 13, 2024 · 5bf7570 · 5bf7570
1 parent c6ff97c
commit 5bf7570
Show file tree

Hide file tree

Showing 16 changed files with 212 additions and 52 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -12,17 +12,29 @@ The minor version will be incremented upon a breaking change and the patch versi
 
 ### Fixes
 
+### Features
+
+### Breaking
+
+## 2024-12-13
+
+- yellowstone-grpc-client-simple-4.2.0
+- yellowstone-grpc-client-4.1.0
+- yellowstone-grpc-geyser-4.2.0
+- yellowstone-grpc-proto-4.1.0
+
+### Fixes
+
 - nodejs: fix connector for custom port ([#488](https://github.com/rpcpool/yellowstone-grpc/pull/488))
 - nodejs: fix connector for host/hostname ([#491](https://github.com/rpcpool/yellowstone-grpc/pull/491))
 
 ### Features
 
 - proto: add tonic feature ([#474](https://github.com/rpcpool/yellowstone-grpc/pull/474))
+- proto: add `from_slot` ([#477](https://github.com/rpcpool/yellowstone-grpc/pull/477))
 - proto: add field `created_at` to update message ([#479](https://github.com/rpcpool/yellowstone-grpc/pull/479))
 - nodejs: add parse err function ([#483](https://github.com/rpcpool/yellowstone-grpc/pull/483))
 
-### Breaking
-
 ## 2024-12-01
 
 - yellowstone-grpc-client-simple-4.1.0

diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -1,10 +1,10 @@
 [workspace]
 resolver = "2"
 members = [
-    "examples/rust", # 4.1.0
-    "yellowstone-grpc-client", # 4.0.0
-    "yellowstone-grpc-geyser", # 4.1.0
-    "yellowstone-grpc-proto", # 4.0.0
+    "examples/rust", # 4.2.0
+    "yellowstone-grpc-client", # 4.1.0
+    "yellowstone-grpc-geyser", # 4.2.0
+    "yellowstone-grpc-proto", # 4.1.0
 ]
 exclude = [
     "yellowstone-grpc-client-nodejs/solana-encoding-wasm", # 3.0.0
@@ -69,8 +69,8 @@ tonic = "0.12.1"
 tonic-build = "0.12.1"
 tonic-health = "0.12.1"
 vergen = "9.0.0"
-yellowstone-grpc-client = { path = "yellowstone-grpc-client", version = "4.0.0" }
-yellowstone-grpc-proto = { path = "yellowstone-grpc-proto", version = "4.0.0", default-features = false }
+yellowstone-grpc-client = { path = "yellowstone-grpc-client", version = "4.1.0" }
+yellowstone-grpc-proto = { path = "yellowstone-grpc-proto", version = "4.1.0", default-features = false }
 
 [workspace.lints.clippy]
 clone_on_ref_ptr = "deny"

diff --git a/examples/rust/Cargo.toml b/examples/rust/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "yellowstone-grpc-client-simple"
-version = "4.1.0"
+version = "4.2.0"
 authors = { workspace = true }
 edition = { workspace = true }
 homepage = { workspace = true }

diff --git a/examples/rust/src/bin/client.rs b/examples/rust/src/bin/client.rs
@@ -329,6 +329,10 @@ struct ActionSubscribe {
     #[clap(long)]
     blocks_meta: bool,
 
+    /// Re-send message from slot
+    #[clap(long)]
+    from_slot: Option<u64>,
+
     /// Send ping in subscribe request
     #[clap(long)]
     ping: Option<i32>,
@@ -522,6 +526,7 @@ impl Action {
                         commitment: commitment.map(|x| x as i32),
                         accounts_data_slice,
                         ping,
+                        from_slot: args.from_slot,
                     },
                     args.resub.unwrap_or(0),
                     args.stats,
@@ -887,6 +892,7 @@ async fn geyser_subscribe(
                     commitment: None,
                     accounts_data_slice: Vec::default(),
                     ping: None,
+                    from_slot: None,
                 })
                 .await
                 .map_err(GeyserGrpcClientError::SubscribeSendError)?;

diff --git a/examples/rust/src/bin/tx-blocktime.rs b/examples/rust/src/bin/tx-blocktime.rs
@@ -111,6 +111,7 @@ async fn main() -> anyhow::Result<()> {
             commitment: Some(commitment as i32),
             accounts_data_slice: vec![],
             ping: None,
+            from_slot: None,
         })
         .await?;
 

diff --git a/yellowstone-grpc-client-nodejs/solana-encoding-wasm/Cargo.lock b/yellowstone-grpc-client-nodejs/solana-encoding-wasm/Cargo.lock
diff --git a/yellowstone-grpc-client-nodejs/solana-encoding-wasm/Cargo.toml b/yellowstone-grpc-client-nodejs/solana-encoding-wasm/Cargo.toml
@@ -16,7 +16,7 @@ crate-type = ["cdylib"]
 serde_json = "1.0.86"
 solana-transaction-status = "~2.1.1"
 wasm-bindgen = "0.2.95"
-yellowstone-grpc-proto = { path = "../../yellowstone-grpc-proto", version = "4.0.0", default-features = false, features = ["convert"] }
+yellowstone-grpc-proto = { path = "../../yellowstone-grpc-proto", version = "4.1.0", default-features = false, features = ["convert"] }
 
 [workspace.lints.clippy]
 clone_on_ref_ptr = "deny"

diff --git a/yellowstone-grpc-client/Cargo.toml b/yellowstone-grpc-client/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "yellowstone-grpc-client"
-version = "4.0.0"
+version = "4.1.0"
 authors = { workspace = true }
 edition = { workspace = true }
 description = "Yellowstone gRPC Geyser Simple Client"

diff --git a/yellowstone-grpc-geyser/Cargo.toml b/yellowstone-grpc-geyser/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "yellowstone-grpc-geyser"
-version = "4.1.0"
+version = "4.2.0"
 authors = { workspace = true }
 edition = { workspace = true }
 description = "Yellowstone gRPC Geyser Plugin"

diff --git a/yellowstone-grpc-geyser/config.json b/yellowstone-grpc-geyser/config.json
@@ -24,8 +24,9 @@
     "unary_concurrency_limit": 100,
     "unary_disabled": false,
     "x_token": null,
-    "filter_name_size_limit": 32,
-    "filter_names_size_limit": 1024,
+    "replay_stored_slots": 0,
+    "filter_name_size_limit": 128,
+    "filter_names_size_limit": 4096,
     "filter_names_cleanup_interval": "1s",
     "filter_limits": {
       "accounts": {

diff --git a/yellowstone-grpc-geyser/src/config.rs b/yellowstone-grpc-geyser/src/config.rs
@@ -189,6 +189,9 @@ pub struct ConfigGrpc {
         with = "humantime_serde"
     )]
     pub filter_names_cleanup_interval: Duration,
+    /// Number of slots stored for re-broadcast (replay)
+    #[serde(default = "ConfigGrpc::default_replay_stored_slots")]
+    pub replay_stored_slots: u64,
 }
 
 impl ConfigGrpc {
@@ -223,6 +226,10 @@ impl ConfigGrpc {
     const fn default_filter_names_cleanup_interval() -> Duration {
         Duration::from_secs(1)
     }
+
+    const fn default_replay_stored_slots() -> u64 {
+        0
+    }
 }
 
 #[derive(Debug, Clone, Deserialize)]