tools: fix panic on Ping/Pong messages in google pubsub (#261)

CHANGELOG.md

@@ -16,6 +16,14 @@ The minor version will be incremented upon a breaking change and the patch versi
 
 ### Breaking
 
+## 2023-12-08
+
+- yellowstone-grpc-tools-1.0.0-rc.9+solana.1.17.6
+
+### Fixes
+
+- tools: fix panic on Ping/Pong messages in google pubsub ([#261](https://github.com/rpcpool/yellowstone-grpc/pull/261))
+
 ## 2023-12-06
 
 - yellowstone-grpc-tools-1.0.0-rc.8+solana.1.17.6

Cargo.lock

@@ -5041,7 +5041,7 @@ dependencies = [
 
 [[package]]
 name = "yellowstone-grpc-tools"
-version = "1.0.0-rc.8+solana.1.17.6"
+version = "1.0.0-rc.9+solana.1.17.6"
 dependencies = [
  "anyhow",
  "async-trait",

Cargo.toml

@@ -5,7 +5,7 @@ members = [
     "yellowstone-grpc-client", # 1.12.0+solana.1.17.6
     "yellowstone-grpc-geyser", # 1.11.1+solana.1.17.6
     "yellowstone-grpc-proto", # 1.11.0+solana.1.17.6
-    "yellowstone-grpc-tools", # 1.0.0-rc.8+solana.1.17.6
+    "yellowstone-grpc-tools", # 1.0.0-rc.9+solana.1.17.6
 ]
 
 [workspace.package]

yellowstone-grpc-tools/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "yellowstone-grpc-tools"
-version = "1.0.0-rc.8+solana.1.17.6"
+version = "1.0.0-rc.9+solana.1.17.6"
 authors = { workspace = true }
 edition = { workspace = true }
 description = "Yellowstone gRPC Tools"

yellowstone-grpc-tools/src/bin/grpc-google-pubsub.rs

@@ -147,17 +147,17 @@ impl ArgsAction {
                     None => break 'outer,
                 };
 
-                let payload = message.encode_to_vec();
-                let message = match &message.update_oneof {
-                    Some(value) => value,
+                match &message.update_oneof {
+                    Some(UpdateOneof::Ping(_)) => continue,
+                    Some(UpdateOneof::Pong(_)) => continue,
+                    Some(value) => prom_kind.push(GprcMessageKind::from(value)),
                     None => unreachable!("Expect valid message"),
                 };
 
                 messages.push(PubsubMessage {
-                    data: payload,
+                    data: message.encode_to_vec(),
                     ..Default::default()
                 });
-                prom_kind.push(GprcMessageKind::from(message));
             }
             if messages.is_empty() {
                 continue;