diff --git a/grpc-server.go b/grpc-server.go index c5155a6f..63a3fc11 100644 --- a/grpc-server.go +++ b/grpc-server.go @@ -621,3 +621,7 @@ func (multi *MultiEpoch) GetBlockTime(ctx context.Context, params *old_faithful_ BlockTime: int64(blocktime), }, nil } + +func (multi *MultiEpoch) StreamBlocks(*old_faithful_grpc.StreamBlocksRequest, grpc.ServerStreamingServer[*old_faithful_grpc.StreamBlocksResponse]) error { + return nil +} diff --git a/old-faithful-proto/proto/old-faithful.proto b/old-faithful-proto/proto/old-faithful.proto index 1a7ed9ec..de328a7e 100644 --- a/old-faithful-proto/proto/old-faithful.proto +++ b/old-faithful-proto/proto/old-faithful.proto @@ -12,7 +12,7 @@ service OldFaithful { rpc Get(stream GetRequest) returns (stream GetResponse); - rpc StreamBlocks(StreamBlocksRequest) returns (stream StreamBlocksResponse); + rpc StreamBlocks(StreamBlocksRequest) returns (stream BlockResponse); } message VersionRequest {} @@ -103,21 +103,3 @@ message StreamBlocksRequest { message StreamBlocksFilter { repeated string account_include = 1; // Filter blocks/txns mentioning these accounts } - -message StreamBlocksResponse { - oneof response { - StreamBlocksError error = 1; - BlockResponse block = 2; - } -} - -message StreamBlocksError { - StreamBlocksErrorCode code = 1; - string message = 2; -} - -enum StreamBlocksErrorCode { - STREAM_BLOCKS_INTERNAL = 0; - STREAM_BLOCKS_INVALID_SLOT_RANGE = 1; - STREAM_BLOCKS_SLOT_NOT_FOUND = 2; -}