proto: add field interslot_updates (#527)

fanatid · web-flow · commit 924ee5a68ff4 · 2025-02-05T12:23:36.000-05:00
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -16,6 +16,18 @@ The minor version will be incremented upon a breaking change and the patch versi
 
 ### Breaking
 
+## 2025-02-05
+
+- @triton-one/yellowstone-grpc@2.1.0
+- yellowstone-grpc-client-simple-4.4.0
+- yellowstone-grpc-client-4.2.0
+- yellowstone-grpc-geyser-4.3.0
+- yellowstone-grpc-proto-4.2.0
+
+### Features
+
+- proto: add field `interslot_updates` ([#527](https://github.com/rpcpool/yellowstone-grpc/pull/527))
+
 ## 2025-01-13
 
 - yellowstone-grpc-client-4.1.1
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.3.0
-    "yellowstone-grpc-client", # 4.1.1
-    "yellowstone-grpc-geyser", # 4.2.2
-    "yellowstone-grpc-proto", # 4.1.1
+    "examples/rust", # 4.4.0
+    "yellowstone-grpc-client", # 4.2.0
+    "yellowstone-grpc-geyser", # 4.3.0
+    "yellowstone-grpc-proto", # 4.2.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.1.0" }
-yellowstone-grpc-proto = { path = "yellowstone-grpc-proto", version = "4.1.1", default-features = false }
+yellowstone-grpc-client = { path = "yellowstone-grpc-client", version = "4.2.0" }
+yellowstone-grpc-proto = { path = "yellowstone-grpc-proto", version = "4.2.0", default-features = false }
 
 [workspace.lints.clippy]
 clone_on_ref_ptr = "deny"
diff --git a/examples/golang/proto/geyser.pb.go b/examples/golang/proto/geyser.pb.go
diff --git a/examples/rust/Cargo.toml b/examples/rust/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "yellowstone-grpc-client-simple"
-version = "4.3.0"
+version = "4.4.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
@@ -256,6 +256,10 @@ struct ActionSubscribe {
     #[clap(long)]
     slots_filter_by_commitment: bool,
 
+    /// Subscribe on interslot slot updates
+    #[clap(long)]
+    slots_interslot_updates: bool,
+
     /// Subscribe on transactions updates
     #[clap(long)]
     transactions: bool,
@@ -451,6 +455,7 @@ impl Action {
                         "client".to_owned(),
                         SubscribeRequestFilterSlots {
                             filter_by_commitment: Some(args.slots_filter_by_commitment),
+                            interslot_updates: Some(args.slots_interslot_updates),
                         },
                     );
                 }
diff --git a/examples/rust/src/bin/subscribe-ping.rs b/examples/rust/src/bin/subscribe-ping.rs
@@ -44,12 +44,17 @@ async fn main() -> anyhow::Result<()> {
     futures::try_join!(
         async move {
             subscribe_tx
-            .send(SubscribeRequest {
-                slots: maplit::hashmap! { "".to_owned() => SubscribeRequestFilterSlots { filter_by_commitment: Some(true) } },
-                commitment: Some(CommitmentLevel::Processed as i32),
-                ..Default::default()
-            })
-            .await?;
+                .send(SubscribeRequest {
+                    slots: maplit::hashmap! {
+                        "".to_owned() => SubscribeRequestFilterSlots {
+                            filter_by_commitment: Some(true),
+                            interslot_updates: Some(false)
+                        }
+                    },
+                    commitment: Some(CommitmentLevel::Processed as i32),
+                    ..Default::default()
+                })
+                .await?;
 
             let mut timer = interval(Duration::from_secs(3));
             let mut id = 0;
diff --git a/examples/typescript/package-lock.json b/examples/typescript/package-lock.json
diff --git a/examples/typescript/package.json b/examples/typescript/package.json
@@ -1,6 +1,6 @@
 {
   "name": "yellowstone-grpc-client-example-ts",
-  "version": "2.0.1",
+  "version": "2.1.0",
   "license": "Apache-2.0",
   "author": "Triton One",
   "main": "dist/client.js",
diff --git a/yellowstone-grpc-client-nodejs/package-lock.json b/yellowstone-grpc-client-nodejs/package-lock.json
diff --git a/yellowstone-grpc-client-nodejs/package.json b/yellowstone-grpc-client-nodejs/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@triton-one/yellowstone-grpc",
-  "version": "2.0.0",
+  "version": "2.1.0",
   "license": "Apache-2.0",
   "author": "Triton One",
   "description": "Yellowstone gRPC Geyser Node.js Client",
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/Cargo.toml b/yellowstone-grpc-client/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "yellowstone-grpc-client"
-version = "4.1.1"
+version = "4.2.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.2.2"
+version = "4.3.0"
 authors = { workspace = true }
 edition = { workspace = true }
 description = "Yellowstone gRPC Geyser Plugin"
diff --git a/yellowstone-grpc-proto/Cargo.toml b/yellowstone-grpc-proto/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "yellowstone-grpc-proto"
-version = "4.1.1"
+version = "4.2.0"
 authors = { workspace = true }
 edition = { workspace = true }
 description = "Yellowstone gRPC Geyser Protobuf Definitions"
diff --git a/yellowstone-grpc-proto/proto/geyser.proto b/yellowstone-grpc-proto/proto/geyser.proto
@@ -77,6 +77,7 @@ message SubscribeRequestFilterAccountsFilterLamports {
 
 message SubscribeRequestFilterSlots {
   optional bool filter_by_commitment = 1;
+  optional bool interslot_updates = 2;
 }
 
 message SubscribeRequestFilterTransactions {
diff --git a/yellowstone-grpc-proto/src/plugin/filter/filter.rs b/yellowstone-grpc-proto/src/plugin/filter/filter.rs
@@ -581,12 +581,14 @@ impl<'a> FilterAccountsMatch<'a> {
 #[derive(Debug, Default, Clone, Copy)]
 struct FilterSlotsInner {
     filter_by_commitment: bool,
+    interslot_updates: bool,
 }
 
 impl FilterSlotsInner {
     fn new(filter: SubscribeRequestFilterSlots) -> Self {
         Self {
             filter_by_commitment: filter.filter_by_commitment.unwrap_or_default(),
+            interslot_updates: filter.interslot_updates.unwrap_or_default(),
         }
     }
 }
@@ -625,7 +627,15 @@ impl FilterSlots {
             .filters
             .iter()
             .filter_map(|(name, inner)| {
-                if !inner.filter_by_commitment || commitment == Some(message.status) {
+                if (!inner.filter_by_commitment || commitment == Some(message.status))
+                    && (inner.interslot_updates
+                        || matches!(
+                            message.status,
+                            CommitmentLevel::Processed
+                                | CommitmentLevel::Confirmed
+                                | CommitmentLevel::Finalized
+                        ))
+                {
                     Some(name.clone())
                 } else {
                     None

Original file line number	Diff line number	Diff line change
`@@ -1,6 +1,6 @@`
`1`	`1`	`{`
`2`	`2`	`"name": "yellowstone-grpc-client-example-ts",`
`3`		`- "version": "2.0.1",`
	`3`	`+ "version": "2.1.0",`
`4`	`4`	`"license": "Apache-2.0",`
`5`	`5`	`"author": "Triton One",`
`6`	`6`	`"main": "dist/client.js",`