geyser: fix filter update loop on snapshot (#410)

Co-authored-by: Kyle Espinola <kyle.s.espinola@gmail.com>
rpcpool · Aug 23, 2024 · c3302bd · c3302bd
1 parent 49aab5f
commit c3302bd
Show file tree

Hide file tree

Showing 5 changed files with 16 additions and 5 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -12,12 +12,22 @@ The minor version will be incremented upon a breaking change and the patch versi
 
 ### Fixes
 
-- example: fix tls root issue in rust example ([#404](https://github.com/rpcpool/yellowstone-grpc/pull/404))
-
 ### Features
 
 ### Breaking
 
+## 2024-08-22
+
+- yellowstone-grpc-client-1.16.0+solana.2.0.5
+- yellowstone-grpc-geyser-1.16.1+solana.2.0.5
+- yellowstone-grpc-proto-1.15.0+solana.2.0.5
+- yellowstone-grpc-tools-1.0.0-rc.12+solana.2.0.5
+
+### Fixes
+
+- example: fix tls root issue in rust example ([#404](https://github.com/rpcpool/yellowstone-grpc/pull/404))
+- geyser: fix filter update loop on snapshot ([#410](https://github.com/rpcpool/yellowstone-grpc/pull/410))
+
 ## 2024-08-09
 
 - yellowstone-grpc-client-1.16.0+solana.2.0.5

diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -3,7 +3,7 @@ resolver = "2"
 members = [
     "examples/rust", # 1.14.1+solana.2.0.5
     "yellowstone-grpc-client", # 1.16.0+solana.2.0.5
-    "yellowstone-grpc-geyser", # 1.16.0+solana.2.0.5
+    "yellowstone-grpc-geyser", # 1.16.1+solana.2.0.5
     "yellowstone-grpc-proto", # 1.15.0+solana.2.0.5
     "yellowstone-grpc-tools", # 1.0.0-rc.12+solana.2.0.5
 ]

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

diff --git a/yellowstone-grpc-geyser/src/grpc.rs b/yellowstone-grpc-geyser/src/grpc.rs
@@ -1175,6 +1175,7 @@ impl GrpcService {
                         metrics::update_subscriptions(&endpoint, Some(&filter), Some(&filter_new));
                         filter = filter_new;
                         info!("client #{id}: filter updated");
+                        break;
                     }
                     Some(None) => {
                         is_alive = false;