geyser: allow to set custom filter size in the config (#288)

CHANGELOG.md

@@ -13,6 +13,7 @@ The minor version will be incremented upon a breaking change and the patch versi
 ### Fixes
 
 - deps: make cargo-deny happy about openssl, unsafe-libyaml, h2, ahash ([#278](https://github.com/rpcpool/yellowstone-grpc/pull/278))
+- geyser: allow to set custom filter size in the config ([#288](https://github.com/rpcpool/yellowstone-grpc/pull/288))
 
 ### Features
 

yellowstone-grpc-geyser/src/config.rs

@@ -64,6 +64,12 @@ pub struct ConfigGrpc {
     pub address: SocketAddr,
     /// TLS config
     pub tls_config: Option<ConfigGrpcServerTls>,
+    /// Limits the maximum size of a decoded message, default is 4MiB
+    #[serde(
+        default = "ConfigGrpc::max_decoding_message_size_default",
+        deserialize_with = "deserialize_usize_str"
+    )]
+    pub max_decoding_message_size: usize,
     /// Capacity of the channel used for accounts from snapshot,
     /// on reaching the limit Sender block validator startup.
     #[serde(
@@ -98,6 +104,10 @@ pub struct ConfigGrpc {
 }
 
 impl ConfigGrpc {
+    const fn max_decoding_message_size_default() -> usize {
+        4 * 1024 * 1024
+    }
+
     const fn snapshot_plugin_channel_capacity_default() -> Option<usize> {
         None
     }

yellowstone-grpc-geyser/src/grpc.rs

@@ -745,6 +745,7 @@ impl GrpcService {
         }
 
         // Create Server
+        let max_decoding_message_size = config.max_decoding_message_size;
         let service = GeyserServer::new(Self {
             config,
             blocks_meta,
@@ -753,7 +754,8 @@ impl GrpcService {
             broadcast_tx: broadcast_tx.clone(),
         })
         .accept_compressed(CompressionEncoding::Gzip)
-        .send_compressed(CompressionEncoding::Gzip);
+        .send_compressed(CompressionEncoding::Gzip)
+        .max_decoding_message_size(max_decoding_message_size);
 
         // Run geyser message loop
         let (messages_tx, messages_rx) = mpsc::unbounded_channel();