From 4959006fc7be96577f3da40415ed65bd88f2b5aa Mon Sep 17 00:00:00 2001
From: Louis-Vincent <louis-vincent@triton.one>
Date: Fri, 10 May 2024 14:45:12 -0400
Subject: [PATCH] fix proto endpoint bad naming

---
 yellowstone-grpc-proto/proto/yellowstone-log.proto   | 2 +-
 yellowstone-grpc-tools/src/scylladb/consumer/grpc.rs | 6 +++---
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/yellowstone-grpc-proto/proto/yellowstone-log.proto b/yellowstone-grpc-proto/proto/yellowstone-log.proto
index 07e4d625..bec67e39 100644
--- a/yellowstone-grpc-proto/proto/yellowstone-log.proto
+++ b/yellowstone-grpc-proto/proto/yellowstone-log.proto
@@ -8,7 +8,7 @@ option go_package = "github.com/rpcpool/solana-geyser-grpc/golang/proto";
 package yellowstone.log;
 
 service YellowstoneLog {
-  rpc consume(ConsumeRequest) returns (stream geyser.SubscribeUpdate) {}
+  rpc Consume(ConsumeRequest) returns (stream geyser.SubscribeUpdate) {}
 }
 
 
diff --git a/yellowstone-grpc-tools/src/scylladb/consumer/grpc.rs b/yellowstone-grpc-tools/src/scylladb/consumer/grpc.rs
index cd2d4aef..857646f5 100644
--- a/yellowstone-grpc-tools/src/scylladb/consumer/grpc.rs
+++ b/yellowstone-grpc-tools/src/scylladb/consumer/grpc.rs
@@ -416,12 +416,12 @@ pub type LogStream = Pin<Box<dyn Stream<Item = Result<SubscribeUpdate, tonic::St
 #[tonic::async_trait]
 impl YellowstoneLog for ScyllaYsLog {
     #[doc = r" Server streaming response type for the consume method."]
-    type consumeStream = LogStream;
+    type ConsumeStream = LogStream;
 
     async fn consume(
         &self,
         request: tonic::Request<ConsumeRequest>,
-    ) -> Result<tonic::Response<Self::consumeStream>, tonic::Status> {
+    ) -> Result<tonic::Response<Self::ConsumeStream>, tonic::Status> {
         let cr = request.into_inner();
 
         let consumer_id = cr.consumer_id.clone().unwrap_or(Uuid::new_v4().to_string());
@@ -475,7 +475,7 @@ impl YellowstoneLog for ScyllaYsLog {
 
         let ret = ReceiverStream::new(rx);
 
-        let res = Response::new(Box::pin(ret) as Self::consumeStream);
+        let res = Response::new(Box::pin(ret) as Self::ConsumeStream);
         Ok(res)
     }
 }