From b342389be3b56a618270af4c252ecbd6244b4462 Mon Sep 17 00:00:00 2001 From: Julien Robert Date: Wed, 29 Apr 2026 15:32:46 +0200 Subject: [PATCH 1/3] refactor(execution/grpc): move execution service where it belongs --- .just/proto.just | 1 + CHANGELOG.md | 4 +- buf.gen.grpc.yaml | 11 ++ buf.yaml | 5 +- execution/grpc/client.go | 8 +- execution/grpc/go.mod | 3 - execution/grpc/go.sum | 2 - execution/grpc/handler.go | 6 +- .../grpc/proto}/execution.proto | 4 +- execution/grpc/server.go | 2 +- execution/grpc/server_test.go | 2 +- execution/grpc/tx_batch.go | 2 +- execution/grpc/tx_batch_test.go | 2 +- .../grpc/types/pb}/execution.pb.go | 138 +++++++++--------- .../types/pb/pbconnect}/execution.connect.go | 82 +++++------ 15 files changed, 140 insertions(+), 132 deletions(-) create mode 100644 buf.gen.grpc.yaml rename {proto/evnode/v1 => execution/grpc/proto}/execution.proto (96%) rename {types/pb/evnode/v1 => execution/grpc/types/pb}/execution.pb.go (85%) rename {types/pb/evnode/v1/v1connect => execution/grpc/types/pb/pbconnect}/execution.connect.go (74%) diff --git a/.just/proto.just b/.just/proto.just index 722e53397c..35f7436bcb 100644 --- a/.just/proto.just +++ b/.just/proto.just @@ -4,6 +4,7 @@ proto-gen: @echo "--> Generating Protobuf files" buf generate --path="./proto/evnode" --template="buf.gen.yaml" --config="buf.yaml" buf generate --path="./proto/execution/evm" --template="buf.gen.evm.yaml" --config="buf.yaml" + buf generate --template="buf.gen.grpc.yaml" --config="buf.yaml" # Lint protobuf files (requires Docker) [group('proto')] diff --git a/CHANGELOG.md b/CHANGELOG.md index aca78dcc0e..c8d7e9f6ba 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -13,7 +13,9 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0 - Optimization of mutex usage in cache for reaper [#3286](https://github.com/evstack/ev-node/pull/3286) - Add Unix domain socket support for gRPC execution endpoints via `unix:///path/to/socket` [#3297](https://github.com/evstack/ev-node/pull/3297) -- **BREAKING:** Replace legacy gRPC execution `txs` payload fields with `tx_batch` so clients and servers use contiguous transaction buffers [#3297](https://github.com/evstack/ev-node/pull/3297) +- **BREAKING:** (execution/grpc) + - Move execution service where it belongs in execution/grpc. []() + - Replace legacy gRPC execution `txs` payload fields with `tx_batch` so clients and servers use contiguous transaction buffers [#3297](https://github.com/evstack/ev-node/pull/3297) - Optimize metadata writes by making it async in cache store [#3298](https://github.com/evstack/ev-node/pull/3298) - Reduce tx cache retention to avoid OOM under (really) heavy tx load [#3299](https://github.com/evstack/ev-node/pull/3299) diff --git a/buf.gen.grpc.yaml b/buf.gen.grpc.yaml new file mode 100644 index 0000000000..019de76139 --- /dev/null +++ b/buf.gen.grpc.yaml @@ -0,0 +1,11 @@ +version: v2 + +plugins: + - remote: buf.build/protocolbuffers/go + out: execution/grpc/types/pb + opt: paths=source_relative + - remote: buf.build/connectrpc/go + out: execution/grpc/types/pb + opt: paths=source_relative +inputs: + - directory: execution/grpc/proto diff --git a/buf.yaml b/buf.yaml index c558c32114..de4bdb8eef 100644 --- a/buf.yaml +++ b/buf.yaml @@ -2,6 +2,7 @@ version: v2 modules: - path: proto + - path: execution/grpc/proto lint: use: - COMMENTS @@ -14,6 +15,4 @@ lint: breaking: use: - FILE - ignore_only: - FIELD_NO_DELETE: - - proto/evnode/v1/execution.proto + diff --git a/execution/grpc/client.go b/execution/grpc/client.go index cfcb6612f0..f2a44cce2b 100644 --- a/execution/grpc/client.go +++ b/execution/grpc/client.go @@ -15,8 +15,8 @@ import ( "google.golang.org/protobuf/types/known/timestamppb" "github.com/evstack/ev-node/core/execution" - pb "github.com/evstack/ev-node/types/pb/evnode/v1" - "github.com/evstack/ev-node/types/pb/evnode/v1/v1connect" + pb "github.com/evstack/ev-node/execution/grpc/types/pb" + "github.com/evstack/ev-node/execution/grpc/types/pb/pbconnect" ) // Ensure Client implements the execution.Executor interface @@ -25,7 +25,7 @@ var _ execution.Executor = (*Client)(nil) // Client is a gRPC client that implements the execution.Executor interface. // It communicates with a remote execution service via gRPC using Connect-RPC. type Client struct { - client v1connect.ExecutorServiceClient + client pbconnect.ExecutorServiceClient } const ( @@ -99,7 +99,7 @@ func NewClient(url string, opts ...connect.ClientOption) (*Client, error) { return nil, err } return &Client{ - client: v1connect.NewExecutorServiceClient( + client: pbconnect.NewExecutorServiceClient( httpClient, targetURL, opts..., diff --git a/execution/grpc/go.mod b/execution/grpc/go.mod index bbedeaf599..b702023db3 100644 --- a/execution/grpc/go.mod +++ b/execution/grpc/go.mod @@ -2,12 +2,9 @@ module github.com/evstack/ev-node/execution/grpc go 1.25.7 -replace github.com/evstack/ev-node => ../.. - require ( connectrpc.com/connect v1.19.2 connectrpc.com/grpcreflect v1.3.0 - github.com/evstack/ev-node v1.1.1 github.com/evstack/ev-node/core v1.0.0 golang.org/x/net v0.53.0 google.golang.org/protobuf v1.36.11 diff --git a/execution/grpc/go.sum b/execution/grpc/go.sum index 20c9e1b3d0..e0bdd7d74e 100644 --- a/execution/grpc/go.sum +++ b/execution/grpc/go.sum @@ -2,8 +2,6 @@ connectrpc.com/connect v1.19.2 h1:McQ83FGdzL+t60peksi0gXC7MQ/iLKgLduAnThbM0mo= connectrpc.com/connect v1.19.2/go.mod h1:tN20fjdGlewnSFeZxLKb0xwIZ6ozc3OQs2hTXy4du9w= connectrpc.com/grpcreflect v1.3.0 h1:Y4V+ACf8/vOb1XOc251Qun7jMB75gCUNw6llvB9csXc= connectrpc.com/grpcreflect v1.3.0/go.mod h1:nfloOtCS8VUQOQ1+GTdFzVg2CJo4ZGaat8JIovCtDYs= -github.com/evstack/ev-node v1.1.1 h1:J9h5PKx177XdvNWLZCDOkWJEGRIrPzYxkCFhbGkVUm8= -github.com/evstack/ev-node v1.1.1/go.mod h1:/d/i+SSTDFnxffoijcrwmlt0LgfUU8D4S3HQqucwtu8= github.com/evstack/ev-node/core v1.0.0 h1:s0Tx0uWHme7SJn/ZNEtee4qNM8UO6PIxXnHhPbbKTz8= github.com/evstack/ev-node/core v1.0.0/go.mod h1:n2w/LhYQTPsi48m6lMj16YiIqsaQw6gxwjyJvR+B3sY= github.com/google/go-cmp v0.7.0 h1:wk8382ETsv4JYUZwIsn6YpYiWiBsYLSJiTsyBybVuN8= diff --git a/execution/grpc/handler.go b/execution/grpc/handler.go index 8c785987fc..478c417a1d 100644 --- a/execution/grpc/handler.go +++ b/execution/grpc/handler.go @@ -10,7 +10,7 @@ import ( "golang.org/x/net/http2/h2c" "github.com/evstack/ev-node/core/execution" - "github.com/evstack/ev-node/types/pb/evnode/v1/v1connect" + "github.com/evstack/ev-node/execution/grpc/types/pb/pbconnect" ) // NewExecutorServiceHandler creates a new HTTP handler for the ExecutorService. @@ -33,13 +33,13 @@ func NewExecutorServiceHandler(executor execution.Executor, opts ...connect.Hand // Set up gRPC reflection for debugging and discovery reflector := grpcreflect.NewStaticReflector( - v1connect.ExecutorServiceName, + pbconnect.ExecutorServiceName, ) mux.Handle(grpcreflect.NewHandlerV1(reflector, compress1KB)) mux.Handle(grpcreflect.NewHandlerV1Alpha(reflector, compress1KB)) // Register the ExecutorService - path, handler := v1connect.NewExecutorServiceHandler(server, append(opts, compress1KB)...) + path, handler := pbconnect.NewExecutorServiceHandler(server, append(opts, compress1KB)...) mux.Handle(path, handler) // Use h2c to support HTTP/2 without TLS diff --git a/proto/evnode/v1/execution.proto b/execution/grpc/proto/execution.proto similarity index 96% rename from proto/evnode/v1/execution.proto rename to execution/grpc/proto/execution.proto index d1773c4289..a0c7446554 100644 --- a/proto/evnode/v1/execution.proto +++ b/execution/grpc/proto/execution.proto @@ -3,9 +3,9 @@ package evnode.v1; import "google/protobuf/timestamp.proto"; -option go_package = "github.com/evstack/ev-node/types/pb/evnode/v1"; +option go_package = "github.com/evstack/ev-node/execution/grpc/types/pb"; -// ExecutorService defines the execution layer interface for EVNode +// ExecutorService defines the execution layer interface for execution/grpc service ExecutorService { // InitChain initializes a new blockchain instance with genesis parameters rpc InitChain(InitChainRequest) returns (InitChainResponse) {} diff --git a/execution/grpc/server.go b/execution/grpc/server.go index 8f1cbb48ce..906109b247 100644 --- a/execution/grpc/server.go +++ b/execution/grpc/server.go @@ -8,7 +8,7 @@ import ( "connectrpc.com/connect" "github.com/evstack/ev-node/core/execution" - pb "github.com/evstack/ev-node/types/pb/evnode/v1" + pb "github.com/evstack/ev-node/execution/grpc/types/pb" ) // Server is a gRPC server that wraps an execution.Executor implementation. diff --git a/execution/grpc/server_test.go b/execution/grpc/server_test.go index 26a6d37ef4..aefece1561 100644 --- a/execution/grpc/server_test.go +++ b/execution/grpc/server_test.go @@ -10,7 +10,7 @@ import ( "google.golang.org/protobuf/types/known/timestamppb" "github.com/evstack/ev-node/core/execution" - pb "github.com/evstack/ev-node/types/pb/evnode/v1" + pb "github.com/evstack/ev-node/execution/grpc/types/pb" ) func TestServer_InitChain(t *testing.T) { diff --git a/execution/grpc/tx_batch.go b/execution/grpc/tx_batch.go index 2e3e600596..ae4df1c73e 100644 --- a/execution/grpc/tx_batch.go +++ b/execution/grpc/tx_batch.go @@ -3,7 +3,7 @@ package grpc import ( "fmt" - pb "github.com/evstack/ev-node/types/pb/evnode/v1" + pb "github.com/evstack/ev-node/execution/grpc/types/pb" ) // maxTxBatchTxSize is the largest transaction length representable in TxBatch.TxSizes: diff --git a/execution/grpc/tx_batch_test.go b/execution/grpc/tx_batch_test.go index 71c48a7306..52c20ee40f 100644 --- a/execution/grpc/tx_batch_test.go +++ b/execution/grpc/tx_batch_test.go @@ -4,7 +4,7 @@ import ( "bytes" "testing" - pb "github.com/evstack/ev-node/types/pb/evnode/v1" + pb "github.com/evstack/ev-node/execution/grpc/types/pb" ) func mustEncodeTxBatch(t *testing.T, txs [][]byte) *pb.TxBatch { diff --git a/types/pb/evnode/v1/execution.pb.go b/execution/grpc/types/pb/execution.pb.go similarity index 85% rename from types/pb/evnode/v1/execution.pb.go rename to execution/grpc/types/pb/execution.pb.go index 9f4e3d5809..401b030a74 100644 --- a/types/pb/evnode/v1/execution.pb.go +++ b/execution/grpc/types/pb/execution.pb.go @@ -2,9 +2,9 @@ // versions: // protoc-gen-go v1.36.11 // protoc (unknown) -// source: evnode/v1/execution.proto +// source: execution.proto -package v1 +package pb import ( protoreflect "google.golang.org/protobuf/reflect/protoreflect" @@ -59,11 +59,11 @@ func (x FilterStatus) String() string { } func (FilterStatus) Descriptor() protoreflect.EnumDescriptor { - return file_evnode_v1_execution_proto_enumTypes[0].Descriptor() + return file_execution_proto_enumTypes[0].Descriptor() } func (FilterStatus) Type() protoreflect.EnumType { - return &file_evnode_v1_execution_proto_enumTypes[0] + return &file_execution_proto_enumTypes[0] } func (x FilterStatus) Number() protoreflect.EnumNumber { @@ -72,7 +72,7 @@ func (x FilterStatus) Number() protoreflect.EnumNumber { // Deprecated: Use FilterStatus.Descriptor instead. func (FilterStatus) EnumDescriptor() ([]byte, []int) { - return file_evnode_v1_execution_proto_rawDescGZIP(), []int{0} + return file_execution_proto_rawDescGZIP(), []int{0} } // InitChainRequest contains the genesis parameters for chain initialization @@ -90,7 +90,7 @@ type InitChainRequest struct { func (x *InitChainRequest) Reset() { *x = InitChainRequest{} - mi := &file_evnode_v1_execution_proto_msgTypes[0] + mi := &file_execution_proto_msgTypes[0] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -102,7 +102,7 @@ func (x *InitChainRequest) String() string { func (*InitChainRequest) ProtoMessage() {} func (x *InitChainRequest) ProtoReflect() protoreflect.Message { - mi := &file_evnode_v1_execution_proto_msgTypes[0] + mi := &file_execution_proto_msgTypes[0] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -115,7 +115,7 @@ func (x *InitChainRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use InitChainRequest.ProtoReflect.Descriptor instead. func (*InitChainRequest) Descriptor() ([]byte, []int) { - return file_evnode_v1_execution_proto_rawDescGZIP(), []int{0} + return file_execution_proto_rawDescGZIP(), []int{0} } func (x *InitChainRequest) GetGenesisTime() *timestamppb.Timestamp { @@ -150,7 +150,7 @@ type InitChainResponse struct { func (x *InitChainResponse) Reset() { *x = InitChainResponse{} - mi := &file_evnode_v1_execution_proto_msgTypes[1] + mi := &file_execution_proto_msgTypes[1] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -162,7 +162,7 @@ func (x *InitChainResponse) String() string { func (*InitChainResponse) ProtoMessage() {} func (x *InitChainResponse) ProtoReflect() protoreflect.Message { - mi := &file_evnode_v1_execution_proto_msgTypes[1] + mi := &file_execution_proto_msgTypes[1] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -175,7 +175,7 @@ func (x *InitChainResponse) ProtoReflect() protoreflect.Message { // Deprecated: Use InitChainResponse.ProtoReflect.Descriptor instead. func (*InitChainResponse) Descriptor() ([]byte, []int) { - return file_evnode_v1_execution_proto_rawDescGZIP(), []int{1} + return file_execution_proto_rawDescGZIP(), []int{1} } func (x *InitChainResponse) GetStateRoot() []byte { @@ -194,7 +194,7 @@ type GetTxsRequest struct { func (x *GetTxsRequest) Reset() { *x = GetTxsRequest{} - mi := &file_evnode_v1_execution_proto_msgTypes[2] + mi := &file_execution_proto_msgTypes[2] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -206,7 +206,7 @@ func (x *GetTxsRequest) String() string { func (*GetTxsRequest) ProtoMessage() {} func (x *GetTxsRequest) ProtoReflect() protoreflect.Message { - mi := &file_evnode_v1_execution_proto_msgTypes[2] + mi := &file_execution_proto_msgTypes[2] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -219,7 +219,7 @@ func (x *GetTxsRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use GetTxsRequest.ProtoReflect.Descriptor instead. func (*GetTxsRequest) Descriptor() ([]byte, []int) { - return file_evnode_v1_execution_proto_rawDescGZIP(), []int{2} + return file_execution_proto_rawDescGZIP(), []int{2} } // TxBatch stores ordered transactions in one contiguous bytes buffer. @@ -235,7 +235,7 @@ type TxBatch struct { func (x *TxBatch) Reset() { *x = TxBatch{} - mi := &file_evnode_v1_execution_proto_msgTypes[3] + mi := &file_execution_proto_msgTypes[3] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -247,7 +247,7 @@ func (x *TxBatch) String() string { func (*TxBatch) ProtoMessage() {} func (x *TxBatch) ProtoReflect() protoreflect.Message { - mi := &file_evnode_v1_execution_proto_msgTypes[3] + mi := &file_execution_proto_msgTypes[3] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -260,7 +260,7 @@ func (x *TxBatch) ProtoReflect() protoreflect.Message { // Deprecated: Use TxBatch.ProtoReflect.Descriptor instead. func (*TxBatch) Descriptor() ([]byte, []int) { - return file_evnode_v1_execution_proto_rawDescGZIP(), []int{3} + return file_execution_proto_rawDescGZIP(), []int{3} } func (x *TxBatch) GetData() []byte { @@ -288,7 +288,7 @@ type GetTxsResponse struct { func (x *GetTxsResponse) Reset() { *x = GetTxsResponse{} - mi := &file_evnode_v1_execution_proto_msgTypes[4] + mi := &file_execution_proto_msgTypes[4] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -300,7 +300,7 @@ func (x *GetTxsResponse) String() string { func (*GetTxsResponse) ProtoMessage() {} func (x *GetTxsResponse) ProtoReflect() protoreflect.Message { - mi := &file_evnode_v1_execution_proto_msgTypes[4] + mi := &file_execution_proto_msgTypes[4] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -313,7 +313,7 @@ func (x *GetTxsResponse) ProtoReflect() protoreflect.Message { // Deprecated: Use GetTxsResponse.ProtoReflect.Descriptor instead. func (*GetTxsResponse) Descriptor() ([]byte, []int) { - return file_evnode_v1_execution_proto_rawDescGZIP(), []int{4} + return file_execution_proto_rawDescGZIP(), []int{4} } func (x *GetTxsResponse) GetTxBatch() *TxBatch { @@ -340,7 +340,7 @@ type ExecuteTxsRequest struct { func (x *ExecuteTxsRequest) Reset() { *x = ExecuteTxsRequest{} - mi := &file_evnode_v1_execution_proto_msgTypes[5] + mi := &file_execution_proto_msgTypes[5] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -352,7 +352,7 @@ func (x *ExecuteTxsRequest) String() string { func (*ExecuteTxsRequest) ProtoMessage() {} func (x *ExecuteTxsRequest) ProtoReflect() protoreflect.Message { - mi := &file_evnode_v1_execution_proto_msgTypes[5] + mi := &file_execution_proto_msgTypes[5] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -365,7 +365,7 @@ func (x *ExecuteTxsRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use ExecuteTxsRequest.ProtoReflect.Descriptor instead. func (*ExecuteTxsRequest) Descriptor() ([]byte, []int) { - return file_evnode_v1_execution_proto_rawDescGZIP(), []int{5} + return file_execution_proto_rawDescGZIP(), []int{5} } func (x *ExecuteTxsRequest) GetBlockHeight() uint64 { @@ -409,7 +409,7 @@ type ExecuteTxsResponse struct { func (x *ExecuteTxsResponse) Reset() { *x = ExecuteTxsResponse{} - mi := &file_evnode_v1_execution_proto_msgTypes[6] + mi := &file_execution_proto_msgTypes[6] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -421,7 +421,7 @@ func (x *ExecuteTxsResponse) String() string { func (*ExecuteTxsResponse) ProtoMessage() {} func (x *ExecuteTxsResponse) ProtoReflect() protoreflect.Message { - mi := &file_evnode_v1_execution_proto_msgTypes[6] + mi := &file_execution_proto_msgTypes[6] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -434,7 +434,7 @@ func (x *ExecuteTxsResponse) ProtoReflect() protoreflect.Message { // Deprecated: Use ExecuteTxsResponse.ProtoReflect.Descriptor instead. func (*ExecuteTxsResponse) Descriptor() ([]byte, []int) { - return file_evnode_v1_execution_proto_rawDescGZIP(), []int{6} + return file_execution_proto_rawDescGZIP(), []int{6} } func (x *ExecuteTxsResponse) GetUpdatedStateRoot() []byte { @@ -462,7 +462,7 @@ type SetFinalRequest struct { func (x *SetFinalRequest) Reset() { *x = SetFinalRequest{} - mi := &file_evnode_v1_execution_proto_msgTypes[7] + mi := &file_execution_proto_msgTypes[7] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -474,7 +474,7 @@ func (x *SetFinalRequest) String() string { func (*SetFinalRequest) ProtoMessage() {} func (x *SetFinalRequest) ProtoReflect() protoreflect.Message { - mi := &file_evnode_v1_execution_proto_msgTypes[7] + mi := &file_execution_proto_msgTypes[7] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -487,7 +487,7 @@ func (x *SetFinalRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use SetFinalRequest.ProtoReflect.Descriptor instead. func (*SetFinalRequest) Descriptor() ([]byte, []int) { - return file_evnode_v1_execution_proto_rawDescGZIP(), []int{7} + return file_execution_proto_rawDescGZIP(), []int{7} } func (x *SetFinalRequest) GetBlockHeight() uint64 { @@ -506,7 +506,7 @@ type SetFinalResponse struct { func (x *SetFinalResponse) Reset() { *x = SetFinalResponse{} - mi := &file_evnode_v1_execution_proto_msgTypes[8] + mi := &file_execution_proto_msgTypes[8] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -518,7 +518,7 @@ func (x *SetFinalResponse) String() string { func (*SetFinalResponse) ProtoMessage() {} func (x *SetFinalResponse) ProtoReflect() protoreflect.Message { - mi := &file_evnode_v1_execution_proto_msgTypes[8] + mi := &file_execution_proto_msgTypes[8] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -531,7 +531,7 @@ func (x *SetFinalResponse) ProtoReflect() protoreflect.Message { // Deprecated: Use SetFinalResponse.ProtoReflect.Descriptor instead. func (*SetFinalResponse) Descriptor() ([]byte, []int) { - return file_evnode_v1_execution_proto_rawDescGZIP(), []int{8} + return file_execution_proto_rawDescGZIP(), []int{8} } // GetExecutionInfoRequest requests execution layer parameters @@ -543,7 +543,7 @@ type GetExecutionInfoRequest struct { func (x *GetExecutionInfoRequest) Reset() { *x = GetExecutionInfoRequest{} - mi := &file_evnode_v1_execution_proto_msgTypes[9] + mi := &file_execution_proto_msgTypes[9] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -555,7 +555,7 @@ func (x *GetExecutionInfoRequest) String() string { func (*GetExecutionInfoRequest) ProtoMessage() {} func (x *GetExecutionInfoRequest) ProtoReflect() protoreflect.Message { - mi := &file_evnode_v1_execution_proto_msgTypes[9] + mi := &file_execution_proto_msgTypes[9] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -568,7 +568,7 @@ func (x *GetExecutionInfoRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use GetExecutionInfoRequest.ProtoReflect.Descriptor instead. func (*GetExecutionInfoRequest) Descriptor() ([]byte, []int) { - return file_evnode_v1_execution_proto_rawDescGZIP(), []int{9} + return file_execution_proto_rawDescGZIP(), []int{9} } // GetExecutionInfoResponse contains execution layer parameters @@ -583,7 +583,7 @@ type GetExecutionInfoResponse struct { func (x *GetExecutionInfoResponse) Reset() { *x = GetExecutionInfoResponse{} - mi := &file_evnode_v1_execution_proto_msgTypes[10] + mi := &file_execution_proto_msgTypes[10] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -595,7 +595,7 @@ func (x *GetExecutionInfoResponse) String() string { func (*GetExecutionInfoResponse) ProtoMessage() {} func (x *GetExecutionInfoResponse) ProtoReflect() protoreflect.Message { - mi := &file_evnode_v1_execution_proto_msgTypes[10] + mi := &file_execution_proto_msgTypes[10] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -608,7 +608,7 @@ func (x *GetExecutionInfoResponse) ProtoReflect() protoreflect.Message { // Deprecated: Use GetExecutionInfoResponse.ProtoReflect.Descriptor instead. func (*GetExecutionInfoResponse) Descriptor() ([]byte, []int) { - return file_evnode_v1_execution_proto_rawDescGZIP(), []int{10} + return file_execution_proto_rawDescGZIP(), []int{10} } func (x *GetExecutionInfoResponse) GetMaxGas() uint64 { @@ -635,7 +635,7 @@ type FilterTxsRequest struct { func (x *FilterTxsRequest) Reset() { *x = FilterTxsRequest{} - mi := &file_evnode_v1_execution_proto_msgTypes[11] + mi := &file_execution_proto_msgTypes[11] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -647,7 +647,7 @@ func (x *FilterTxsRequest) String() string { func (*FilterTxsRequest) ProtoMessage() {} func (x *FilterTxsRequest) ProtoReflect() protoreflect.Message { - mi := &file_evnode_v1_execution_proto_msgTypes[11] + mi := &file_execution_proto_msgTypes[11] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -660,7 +660,7 @@ func (x *FilterTxsRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use FilterTxsRequest.ProtoReflect.Descriptor instead. func (*FilterTxsRequest) Descriptor() ([]byte, []int) { - return file_evnode_v1_execution_proto_rawDescGZIP(), []int{11} + return file_execution_proto_rawDescGZIP(), []int{11} } func (x *FilterTxsRequest) GetMaxBytes() uint64 { @@ -702,7 +702,7 @@ type FilterTxsResponse struct { func (x *FilterTxsResponse) Reset() { *x = FilterTxsResponse{} - mi := &file_evnode_v1_execution_proto_msgTypes[12] + mi := &file_execution_proto_msgTypes[12] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -714,7 +714,7 @@ func (x *FilterTxsResponse) String() string { func (*FilterTxsResponse) ProtoMessage() {} func (x *FilterTxsResponse) ProtoReflect() protoreflect.Message { - mi := &file_evnode_v1_execution_proto_msgTypes[12] + mi := &file_execution_proto_msgTypes[12] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -727,7 +727,7 @@ func (x *FilterTxsResponse) ProtoReflect() protoreflect.Message { // Deprecated: Use FilterTxsResponse.ProtoReflect.Descriptor instead. func (*FilterTxsResponse) Descriptor() ([]byte, []int) { - return file_evnode_v1_execution_proto_rawDescGZIP(), []int{12} + return file_execution_proto_rawDescGZIP(), []int{12} } func (x *FilterTxsResponse) GetStatuses() []FilterStatus { @@ -737,11 +737,11 @@ func (x *FilterTxsResponse) GetStatuses() []FilterStatus { return nil } -var File_evnode_v1_execution_proto protoreflect.FileDescriptor +var File_execution_proto protoreflect.FileDescriptor -const file_evnode_v1_execution_proto_rawDesc = "" + +const file_execution_proto_rawDesc = "" + "\n" + - "\x19evnode/v1/execution.proto\x12\tevnode.v1\x1a\x1fgoogle/protobuf/timestamp.proto\"\x93\x01\n" + + "\x0fexecution.proto\x12\tevnode.v1\x1a\x1fgoogle/protobuf/timestamp.proto\"\x93\x01\n" + "\x10InitChainRequest\x12=\n" + "\fgenesis_time\x18\x01 \x01(\v2\x1a.google.protobuf.TimestampR\vgenesisTime\x12%\n" + "\x0einitial_height\x18\x02 \x01(\x04R\rinitialHeight\x12\x19\n" + @@ -787,23 +787,23 @@ const file_evnode_v1_execution_proto_rawDesc = "" + "ExecuteTxs\x12\x1c.evnode.v1.ExecuteTxsRequest\x1a\x1d.evnode.v1.ExecuteTxsResponse\"\x00\x12E\n" + "\bSetFinal\x12\x1a.evnode.v1.SetFinalRequest\x1a\x1b.evnode.v1.SetFinalResponse\"\x00\x12]\n" + "\x10GetExecutionInfo\x12\".evnode.v1.GetExecutionInfoRequest\x1a#.evnode.v1.GetExecutionInfoResponse\"\x00\x12H\n" + - "\tFilterTxs\x12\x1b.evnode.v1.FilterTxsRequest\x1a\x1c.evnode.v1.FilterTxsResponse\"\x00B/Z-github.com/evstack/ev-node/types/pb/evnode/v1b\x06proto3" + "\tFilterTxs\x12\x1b.evnode.v1.FilterTxsRequest\x1a\x1c.evnode.v1.FilterTxsResponse\"\x00B4Z2github.com/evstack/ev-node/execution/grpc/types/pbb\x06proto3" var ( - file_evnode_v1_execution_proto_rawDescOnce sync.Once - file_evnode_v1_execution_proto_rawDescData []byte + file_execution_proto_rawDescOnce sync.Once + file_execution_proto_rawDescData []byte ) -func file_evnode_v1_execution_proto_rawDescGZIP() []byte { - file_evnode_v1_execution_proto_rawDescOnce.Do(func() { - file_evnode_v1_execution_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_evnode_v1_execution_proto_rawDesc), len(file_evnode_v1_execution_proto_rawDesc))) +func file_execution_proto_rawDescGZIP() []byte { + file_execution_proto_rawDescOnce.Do(func() { + file_execution_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_execution_proto_rawDesc), len(file_execution_proto_rawDesc))) }) - return file_evnode_v1_execution_proto_rawDescData + return file_execution_proto_rawDescData } -var file_evnode_v1_execution_proto_enumTypes = make([]protoimpl.EnumInfo, 1) -var file_evnode_v1_execution_proto_msgTypes = make([]protoimpl.MessageInfo, 13) -var file_evnode_v1_execution_proto_goTypes = []any{ +var file_execution_proto_enumTypes = make([]protoimpl.EnumInfo, 1) +var file_execution_proto_msgTypes = make([]protoimpl.MessageInfo, 13) +var file_execution_proto_goTypes = []any{ (FilterStatus)(0), // 0: evnode.v1.FilterStatus (*InitChainRequest)(nil), // 1: evnode.v1.InitChainRequest (*InitChainResponse)(nil), // 2: evnode.v1.InitChainResponse @@ -820,7 +820,7 @@ var file_evnode_v1_execution_proto_goTypes = []any{ (*FilterTxsResponse)(nil), // 13: evnode.v1.FilterTxsResponse (*timestamppb.Timestamp)(nil), // 14: google.protobuf.Timestamp } -var file_evnode_v1_execution_proto_depIdxs = []int32{ +var file_execution_proto_depIdxs = []int32{ 14, // 0: evnode.v1.InitChainRequest.genesis_time:type_name -> google.protobuf.Timestamp 4, // 1: evnode.v1.GetTxsResponse.tx_batch:type_name -> evnode.v1.TxBatch 14, // 2: evnode.v1.ExecuteTxsRequest.timestamp:type_name -> google.protobuf.Timestamp @@ -846,27 +846,27 @@ var file_evnode_v1_execution_proto_depIdxs = []int32{ 0, // [0:6] is the sub-list for field type_name } -func init() { file_evnode_v1_execution_proto_init() } -func file_evnode_v1_execution_proto_init() { - if File_evnode_v1_execution_proto != nil { +func init() { file_execution_proto_init() } +func file_execution_proto_init() { + if File_execution_proto != nil { return } type x struct{} out := protoimpl.TypeBuilder{ File: protoimpl.DescBuilder{ GoPackagePath: reflect.TypeOf(x{}).PkgPath(), - RawDescriptor: unsafe.Slice(unsafe.StringData(file_evnode_v1_execution_proto_rawDesc), len(file_evnode_v1_execution_proto_rawDesc)), + RawDescriptor: unsafe.Slice(unsafe.StringData(file_execution_proto_rawDesc), len(file_execution_proto_rawDesc)), NumEnums: 1, NumMessages: 13, NumExtensions: 0, NumServices: 1, }, - GoTypes: file_evnode_v1_execution_proto_goTypes, - DependencyIndexes: file_evnode_v1_execution_proto_depIdxs, - EnumInfos: file_evnode_v1_execution_proto_enumTypes, - MessageInfos: file_evnode_v1_execution_proto_msgTypes, + GoTypes: file_execution_proto_goTypes, + DependencyIndexes: file_execution_proto_depIdxs, + EnumInfos: file_execution_proto_enumTypes, + MessageInfos: file_execution_proto_msgTypes, }.Build() - File_evnode_v1_execution_proto = out.File - file_evnode_v1_execution_proto_goTypes = nil - file_evnode_v1_execution_proto_depIdxs = nil + File_execution_proto = out.File + file_execution_proto_goTypes = nil + file_execution_proto_depIdxs = nil } diff --git a/types/pb/evnode/v1/v1connect/execution.connect.go b/execution/grpc/types/pb/pbconnect/execution.connect.go similarity index 74% rename from types/pb/evnode/v1/v1connect/execution.connect.go rename to execution/grpc/types/pb/pbconnect/execution.connect.go index 35a85ec77b..783edb89d2 100644 --- a/types/pb/evnode/v1/v1connect/execution.connect.go +++ b/execution/grpc/types/pb/pbconnect/execution.connect.go @@ -1,14 +1,14 @@ // Code generated by protoc-gen-connect-go. DO NOT EDIT. // -// Source: evnode/v1/execution.proto +// Source: execution.proto -package v1connect +package pbconnect import ( connect "connectrpc.com/connect" context "context" errors "errors" - v1 "github.com/evstack/ev-node/types/pb/evnode/v1" + pb "github.com/evstack/ev-node/execution/grpc/types/pb" http "net/http" strings "strings" ) @@ -55,17 +55,17 @@ const ( // ExecutorServiceClient is a client for the evnode.v1.ExecutorService service. type ExecutorServiceClient interface { // InitChain initializes a new blockchain instance with genesis parameters - InitChain(context.Context, *connect.Request[v1.InitChainRequest]) (*connect.Response[v1.InitChainResponse], error) + InitChain(context.Context, *connect.Request[pb.InitChainRequest]) (*connect.Response[pb.InitChainResponse], error) // GetTxs fetches available transactions from the execution layer's mempool - GetTxs(context.Context, *connect.Request[v1.GetTxsRequest]) (*connect.Response[v1.GetTxsResponse], error) + GetTxs(context.Context, *connect.Request[pb.GetTxsRequest]) (*connect.Response[pb.GetTxsResponse], error) // ExecuteTxs processes transactions to produce a new block state - ExecuteTxs(context.Context, *connect.Request[v1.ExecuteTxsRequest]) (*connect.Response[v1.ExecuteTxsResponse], error) + ExecuteTxs(context.Context, *connect.Request[pb.ExecuteTxsRequest]) (*connect.Response[pb.ExecuteTxsResponse], error) // SetFinal marks a block as finalized at the specified height - SetFinal(context.Context, *connect.Request[v1.SetFinalRequest]) (*connect.Response[v1.SetFinalResponse], error) + SetFinal(context.Context, *connect.Request[pb.SetFinalRequest]) (*connect.Response[pb.SetFinalResponse], error) // GetExecutionInfo returns current execution layer parameters - GetExecutionInfo(context.Context, *connect.Request[v1.GetExecutionInfoRequest]) (*connect.Response[v1.GetExecutionInfoResponse], error) + GetExecutionInfo(context.Context, *connect.Request[pb.GetExecutionInfoRequest]) (*connect.Response[pb.GetExecutionInfoResponse], error) // FilterTxs validates force-included transactions and calculates gas for all transactions - FilterTxs(context.Context, *connect.Request[v1.FilterTxsRequest]) (*connect.Response[v1.FilterTxsResponse], error) + FilterTxs(context.Context, *connect.Request[pb.FilterTxsRequest]) (*connect.Response[pb.FilterTxsResponse], error) } // NewExecutorServiceClient constructs a client for the evnode.v1.ExecutorService service. By @@ -77,39 +77,39 @@ type ExecutorServiceClient interface { // http://api.acme.com or https://acme.com/grpc). func NewExecutorServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ExecutorServiceClient { baseURL = strings.TrimRight(baseURL, "/") - executorServiceMethods := v1.File_evnode_v1_execution_proto.Services().ByName("ExecutorService").Methods() + executorServiceMethods := pb.File_execution_proto.Services().ByName("ExecutorService").Methods() return &executorServiceClient{ - initChain: connect.NewClient[v1.InitChainRequest, v1.InitChainResponse]( + initChain: connect.NewClient[pb.InitChainRequest, pb.InitChainResponse]( httpClient, baseURL+ExecutorServiceInitChainProcedure, connect.WithSchema(executorServiceMethods.ByName("InitChain")), connect.WithClientOptions(opts...), ), - getTxs: connect.NewClient[v1.GetTxsRequest, v1.GetTxsResponse]( + getTxs: connect.NewClient[pb.GetTxsRequest, pb.GetTxsResponse]( httpClient, baseURL+ExecutorServiceGetTxsProcedure, connect.WithSchema(executorServiceMethods.ByName("GetTxs")), connect.WithClientOptions(opts...), ), - executeTxs: connect.NewClient[v1.ExecuteTxsRequest, v1.ExecuteTxsResponse]( + executeTxs: connect.NewClient[pb.ExecuteTxsRequest, pb.ExecuteTxsResponse]( httpClient, baseURL+ExecutorServiceExecuteTxsProcedure, connect.WithSchema(executorServiceMethods.ByName("ExecuteTxs")), connect.WithClientOptions(opts...), ), - setFinal: connect.NewClient[v1.SetFinalRequest, v1.SetFinalResponse]( + setFinal: connect.NewClient[pb.SetFinalRequest, pb.SetFinalResponse]( httpClient, baseURL+ExecutorServiceSetFinalProcedure, connect.WithSchema(executorServiceMethods.ByName("SetFinal")), connect.WithClientOptions(opts...), ), - getExecutionInfo: connect.NewClient[v1.GetExecutionInfoRequest, v1.GetExecutionInfoResponse]( + getExecutionInfo: connect.NewClient[pb.GetExecutionInfoRequest, pb.GetExecutionInfoResponse]( httpClient, baseURL+ExecutorServiceGetExecutionInfoProcedure, connect.WithSchema(executorServiceMethods.ByName("GetExecutionInfo")), connect.WithClientOptions(opts...), ), - filterTxs: connect.NewClient[v1.FilterTxsRequest, v1.FilterTxsResponse]( + filterTxs: connect.NewClient[pb.FilterTxsRequest, pb.FilterTxsResponse]( httpClient, baseURL+ExecutorServiceFilterTxsProcedure, connect.WithSchema(executorServiceMethods.ByName("FilterTxs")), @@ -120,58 +120,58 @@ func NewExecutorServiceClient(httpClient connect.HTTPClient, baseURL string, opt // executorServiceClient implements ExecutorServiceClient. type executorServiceClient struct { - initChain *connect.Client[v1.InitChainRequest, v1.InitChainResponse] - getTxs *connect.Client[v1.GetTxsRequest, v1.GetTxsResponse] - executeTxs *connect.Client[v1.ExecuteTxsRequest, v1.ExecuteTxsResponse] - setFinal *connect.Client[v1.SetFinalRequest, v1.SetFinalResponse] - getExecutionInfo *connect.Client[v1.GetExecutionInfoRequest, v1.GetExecutionInfoResponse] - filterTxs *connect.Client[v1.FilterTxsRequest, v1.FilterTxsResponse] + initChain *connect.Client[pb.InitChainRequest, pb.InitChainResponse] + getTxs *connect.Client[pb.GetTxsRequest, pb.GetTxsResponse] + executeTxs *connect.Client[pb.ExecuteTxsRequest, pb.ExecuteTxsResponse] + setFinal *connect.Client[pb.SetFinalRequest, pb.SetFinalResponse] + getExecutionInfo *connect.Client[pb.GetExecutionInfoRequest, pb.GetExecutionInfoResponse] + filterTxs *connect.Client[pb.FilterTxsRequest, pb.FilterTxsResponse] } // InitChain calls evnode.v1.ExecutorService.InitChain. -func (c *executorServiceClient) InitChain(ctx context.Context, req *connect.Request[v1.InitChainRequest]) (*connect.Response[v1.InitChainResponse], error) { +func (c *executorServiceClient) InitChain(ctx context.Context, req *connect.Request[pb.InitChainRequest]) (*connect.Response[pb.InitChainResponse], error) { return c.initChain.CallUnary(ctx, req) } // GetTxs calls evnode.v1.ExecutorService.GetTxs. -func (c *executorServiceClient) GetTxs(ctx context.Context, req *connect.Request[v1.GetTxsRequest]) (*connect.Response[v1.GetTxsResponse], error) { +func (c *executorServiceClient) GetTxs(ctx context.Context, req *connect.Request[pb.GetTxsRequest]) (*connect.Response[pb.GetTxsResponse], error) { return c.getTxs.CallUnary(ctx, req) } // ExecuteTxs calls evnode.v1.ExecutorService.ExecuteTxs. -func (c *executorServiceClient) ExecuteTxs(ctx context.Context, req *connect.Request[v1.ExecuteTxsRequest]) (*connect.Response[v1.ExecuteTxsResponse], error) { +func (c *executorServiceClient) ExecuteTxs(ctx context.Context, req *connect.Request[pb.ExecuteTxsRequest]) (*connect.Response[pb.ExecuteTxsResponse], error) { return c.executeTxs.CallUnary(ctx, req) } // SetFinal calls evnode.v1.ExecutorService.SetFinal. -func (c *executorServiceClient) SetFinal(ctx context.Context, req *connect.Request[v1.SetFinalRequest]) (*connect.Response[v1.SetFinalResponse], error) { +func (c *executorServiceClient) SetFinal(ctx context.Context, req *connect.Request[pb.SetFinalRequest]) (*connect.Response[pb.SetFinalResponse], error) { return c.setFinal.CallUnary(ctx, req) } // GetExecutionInfo calls evnode.v1.ExecutorService.GetExecutionInfo. -func (c *executorServiceClient) GetExecutionInfo(ctx context.Context, req *connect.Request[v1.GetExecutionInfoRequest]) (*connect.Response[v1.GetExecutionInfoResponse], error) { +func (c *executorServiceClient) GetExecutionInfo(ctx context.Context, req *connect.Request[pb.GetExecutionInfoRequest]) (*connect.Response[pb.GetExecutionInfoResponse], error) { return c.getExecutionInfo.CallUnary(ctx, req) } // FilterTxs calls evnode.v1.ExecutorService.FilterTxs. -func (c *executorServiceClient) FilterTxs(ctx context.Context, req *connect.Request[v1.FilterTxsRequest]) (*connect.Response[v1.FilterTxsResponse], error) { +func (c *executorServiceClient) FilterTxs(ctx context.Context, req *connect.Request[pb.FilterTxsRequest]) (*connect.Response[pb.FilterTxsResponse], error) { return c.filterTxs.CallUnary(ctx, req) } // ExecutorServiceHandler is an implementation of the evnode.v1.ExecutorService service. type ExecutorServiceHandler interface { // InitChain initializes a new blockchain instance with genesis parameters - InitChain(context.Context, *connect.Request[v1.InitChainRequest]) (*connect.Response[v1.InitChainResponse], error) + InitChain(context.Context, *connect.Request[pb.InitChainRequest]) (*connect.Response[pb.InitChainResponse], error) // GetTxs fetches available transactions from the execution layer's mempool - GetTxs(context.Context, *connect.Request[v1.GetTxsRequest]) (*connect.Response[v1.GetTxsResponse], error) + GetTxs(context.Context, *connect.Request[pb.GetTxsRequest]) (*connect.Response[pb.GetTxsResponse], error) // ExecuteTxs processes transactions to produce a new block state - ExecuteTxs(context.Context, *connect.Request[v1.ExecuteTxsRequest]) (*connect.Response[v1.ExecuteTxsResponse], error) + ExecuteTxs(context.Context, *connect.Request[pb.ExecuteTxsRequest]) (*connect.Response[pb.ExecuteTxsResponse], error) // SetFinal marks a block as finalized at the specified height - SetFinal(context.Context, *connect.Request[v1.SetFinalRequest]) (*connect.Response[v1.SetFinalResponse], error) + SetFinal(context.Context, *connect.Request[pb.SetFinalRequest]) (*connect.Response[pb.SetFinalResponse], error) // GetExecutionInfo returns current execution layer parameters - GetExecutionInfo(context.Context, *connect.Request[v1.GetExecutionInfoRequest]) (*connect.Response[v1.GetExecutionInfoResponse], error) + GetExecutionInfo(context.Context, *connect.Request[pb.GetExecutionInfoRequest]) (*connect.Response[pb.GetExecutionInfoResponse], error) // FilterTxs validates force-included transactions and calculates gas for all transactions - FilterTxs(context.Context, *connect.Request[v1.FilterTxsRequest]) (*connect.Response[v1.FilterTxsResponse], error) + FilterTxs(context.Context, *connect.Request[pb.FilterTxsRequest]) (*connect.Response[pb.FilterTxsResponse], error) } // NewExecutorServiceHandler builds an HTTP handler from the service implementation. It returns the @@ -180,7 +180,7 @@ type ExecutorServiceHandler interface { // By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf // and JSON codecs. They also support gzip compression. func NewExecutorServiceHandler(svc ExecutorServiceHandler, opts ...connect.HandlerOption) (string, http.Handler) { - executorServiceMethods := v1.File_evnode_v1_execution_proto.Services().ByName("ExecutorService").Methods() + executorServiceMethods := pb.File_execution_proto.Services().ByName("ExecutorService").Methods() executorServiceInitChainHandler := connect.NewUnaryHandler( ExecutorServiceInitChainProcedure, svc.InitChain, @@ -240,26 +240,26 @@ func NewExecutorServiceHandler(svc ExecutorServiceHandler, opts ...connect.Handl // UnimplementedExecutorServiceHandler returns CodeUnimplemented from all methods. type UnimplementedExecutorServiceHandler struct{} -func (UnimplementedExecutorServiceHandler) InitChain(context.Context, *connect.Request[v1.InitChainRequest]) (*connect.Response[v1.InitChainResponse], error) { +func (UnimplementedExecutorServiceHandler) InitChain(context.Context, *connect.Request[pb.InitChainRequest]) (*connect.Response[pb.InitChainResponse], error) { return nil, connect.NewError(connect.CodeUnimplemented, errors.New("evnode.v1.ExecutorService.InitChain is not implemented")) } -func (UnimplementedExecutorServiceHandler) GetTxs(context.Context, *connect.Request[v1.GetTxsRequest]) (*connect.Response[v1.GetTxsResponse], error) { +func (UnimplementedExecutorServiceHandler) GetTxs(context.Context, *connect.Request[pb.GetTxsRequest]) (*connect.Response[pb.GetTxsResponse], error) { return nil, connect.NewError(connect.CodeUnimplemented, errors.New("evnode.v1.ExecutorService.GetTxs is not implemented")) } -func (UnimplementedExecutorServiceHandler) ExecuteTxs(context.Context, *connect.Request[v1.ExecuteTxsRequest]) (*connect.Response[v1.ExecuteTxsResponse], error) { +func (UnimplementedExecutorServiceHandler) ExecuteTxs(context.Context, *connect.Request[pb.ExecuteTxsRequest]) (*connect.Response[pb.ExecuteTxsResponse], error) { return nil, connect.NewError(connect.CodeUnimplemented, errors.New("evnode.v1.ExecutorService.ExecuteTxs is not implemented")) } -func (UnimplementedExecutorServiceHandler) SetFinal(context.Context, *connect.Request[v1.SetFinalRequest]) (*connect.Response[v1.SetFinalResponse], error) { +func (UnimplementedExecutorServiceHandler) SetFinal(context.Context, *connect.Request[pb.SetFinalRequest]) (*connect.Response[pb.SetFinalResponse], error) { return nil, connect.NewError(connect.CodeUnimplemented, errors.New("evnode.v1.ExecutorService.SetFinal is not implemented")) } -func (UnimplementedExecutorServiceHandler) GetExecutionInfo(context.Context, *connect.Request[v1.GetExecutionInfoRequest]) (*connect.Response[v1.GetExecutionInfoResponse], error) { +func (UnimplementedExecutorServiceHandler) GetExecutionInfo(context.Context, *connect.Request[pb.GetExecutionInfoRequest]) (*connect.Response[pb.GetExecutionInfoResponse], error) { return nil, connect.NewError(connect.CodeUnimplemented, errors.New("evnode.v1.ExecutorService.GetExecutionInfo is not implemented")) } -func (UnimplementedExecutorServiceHandler) FilterTxs(context.Context, *connect.Request[v1.FilterTxsRequest]) (*connect.Response[v1.FilterTxsResponse], error) { +func (UnimplementedExecutorServiceHandler) FilterTxs(context.Context, *connect.Request[pb.FilterTxsRequest]) (*connect.Response[pb.FilterTxsResponse], error) { return nil, connect.NewError(connect.CodeUnimplemented, errors.New("evnode.v1.ExecutorService.FilterTxs is not implemented")) } From 1b90a91e210c55630d65b2d2e5461bd9eacd89ec Mon Sep 17 00:00:00 2001 From: Julien Robert Date: Wed, 29 Apr 2026 15:42:26 +0200 Subject: [PATCH 2/3] reduce diff --- execution/grpc/client.go | 8 +- execution/grpc/handler.go | 6 +- .../proto/{ => evnode/v1}/execution.proto | 2 +- execution/grpc/server.go | 2 +- execution/grpc/server_test.go | 2 +- execution/grpc/tx_batch.go | 2 +- execution/grpc/tx_batch_test.go | 2 +- .../types/pb/{ => evnode/v1}/execution.pb.go | 138 +++++++++--------- .../v1/v1connect}/execution.connect.go | 82 +++++------ 9 files changed, 122 insertions(+), 122 deletions(-) rename execution/grpc/proto/{ => evnode/v1}/execution.proto (99%) rename execution/grpc/types/pb/{ => evnode/v1}/execution.pb.go (85%) rename execution/grpc/types/pb/{pbconnect => evnode/v1/v1connect}/execution.connect.go (74%) diff --git a/execution/grpc/client.go b/execution/grpc/client.go index f2a44cce2b..253dbcb464 100644 --- a/execution/grpc/client.go +++ b/execution/grpc/client.go @@ -15,8 +15,8 @@ import ( "google.golang.org/protobuf/types/known/timestamppb" "github.com/evstack/ev-node/core/execution" - pb "github.com/evstack/ev-node/execution/grpc/types/pb" - "github.com/evstack/ev-node/execution/grpc/types/pb/pbconnect" + pb "github.com/evstack/ev-node/execution/grpc/types/pb/evnode/v1" + "github.com/evstack/ev-node/execution/grpc/types/pb/evnode/v1/v1connect" ) // Ensure Client implements the execution.Executor interface @@ -25,7 +25,7 @@ var _ execution.Executor = (*Client)(nil) // Client is a gRPC client that implements the execution.Executor interface. // It communicates with a remote execution service via gRPC using Connect-RPC. type Client struct { - client pbconnect.ExecutorServiceClient + client v1connect.ExecutorServiceClient } const ( @@ -99,7 +99,7 @@ func NewClient(url string, opts ...connect.ClientOption) (*Client, error) { return nil, err } return &Client{ - client: pbconnect.NewExecutorServiceClient( + client: v1connect.NewExecutorServiceClient( httpClient, targetURL, opts..., diff --git a/execution/grpc/handler.go b/execution/grpc/handler.go index 478c417a1d..c3b3bc2ab6 100644 --- a/execution/grpc/handler.go +++ b/execution/grpc/handler.go @@ -10,7 +10,7 @@ import ( "golang.org/x/net/http2/h2c" "github.com/evstack/ev-node/core/execution" - "github.com/evstack/ev-node/execution/grpc/types/pb/pbconnect" + "github.com/evstack/ev-node/execution/grpc/types/pb/evnode/v1/v1connect" ) // NewExecutorServiceHandler creates a new HTTP handler for the ExecutorService. @@ -33,13 +33,13 @@ func NewExecutorServiceHandler(executor execution.Executor, opts ...connect.Hand // Set up gRPC reflection for debugging and discovery reflector := grpcreflect.NewStaticReflector( - pbconnect.ExecutorServiceName, + v1connect.ExecutorServiceName, ) mux.Handle(grpcreflect.NewHandlerV1(reflector, compress1KB)) mux.Handle(grpcreflect.NewHandlerV1Alpha(reflector, compress1KB)) // Register the ExecutorService - path, handler := pbconnect.NewExecutorServiceHandler(server, append(opts, compress1KB)...) + path, handler := v1connect.NewExecutorServiceHandler(server, append(opts, compress1KB)...) mux.Handle(path, handler) // Use h2c to support HTTP/2 without TLS diff --git a/execution/grpc/proto/execution.proto b/execution/grpc/proto/evnode/v1/execution.proto similarity index 99% rename from execution/grpc/proto/execution.proto rename to execution/grpc/proto/evnode/v1/execution.proto index a0c7446554..7300c00929 100644 --- a/execution/grpc/proto/execution.proto +++ b/execution/grpc/proto/evnode/v1/execution.proto @@ -3,7 +3,7 @@ package evnode.v1; import "google/protobuf/timestamp.proto"; -option go_package = "github.com/evstack/ev-node/execution/grpc/types/pb"; +option go_package = "github.com/evstack/ev-node/execution/grpc/types/pb/evnode/v1"; // ExecutorService defines the execution layer interface for execution/grpc service ExecutorService { diff --git a/execution/grpc/server.go b/execution/grpc/server.go index 906109b247..48a6b673ea 100644 --- a/execution/grpc/server.go +++ b/execution/grpc/server.go @@ -8,7 +8,7 @@ import ( "connectrpc.com/connect" "github.com/evstack/ev-node/core/execution" - pb "github.com/evstack/ev-node/execution/grpc/types/pb" + pb "github.com/evstack/ev-node/execution/grpc/types/pb/evnode/v1" ) // Server is a gRPC server that wraps an execution.Executor implementation. diff --git a/execution/grpc/server_test.go b/execution/grpc/server_test.go index aefece1561..7d879e69b5 100644 --- a/execution/grpc/server_test.go +++ b/execution/grpc/server_test.go @@ -10,7 +10,7 @@ import ( "google.golang.org/protobuf/types/known/timestamppb" "github.com/evstack/ev-node/core/execution" - pb "github.com/evstack/ev-node/execution/grpc/types/pb" + pb "github.com/evstack/ev-node/execution/grpc/types/pb/evnode/v1" ) func TestServer_InitChain(t *testing.T) { diff --git a/execution/grpc/tx_batch.go b/execution/grpc/tx_batch.go index ae4df1c73e..e80d7abbc6 100644 --- a/execution/grpc/tx_batch.go +++ b/execution/grpc/tx_batch.go @@ -3,7 +3,7 @@ package grpc import ( "fmt" - pb "github.com/evstack/ev-node/execution/grpc/types/pb" + pb "github.com/evstack/ev-node/execution/grpc/types/pb/evnode/v1" ) // maxTxBatchTxSize is the largest transaction length representable in TxBatch.TxSizes: diff --git a/execution/grpc/tx_batch_test.go b/execution/grpc/tx_batch_test.go index 52c20ee40f..7e21055651 100644 --- a/execution/grpc/tx_batch_test.go +++ b/execution/grpc/tx_batch_test.go @@ -4,7 +4,7 @@ import ( "bytes" "testing" - pb "github.com/evstack/ev-node/execution/grpc/types/pb" + pb "github.com/evstack/ev-node/execution/grpc/types/pb/evnode/v1" ) func mustEncodeTxBatch(t *testing.T, txs [][]byte) *pb.TxBatch { diff --git a/execution/grpc/types/pb/execution.pb.go b/execution/grpc/types/pb/evnode/v1/execution.pb.go similarity index 85% rename from execution/grpc/types/pb/execution.pb.go rename to execution/grpc/types/pb/evnode/v1/execution.pb.go index 401b030a74..6dfc0d5d3e 100644 --- a/execution/grpc/types/pb/execution.pb.go +++ b/execution/grpc/types/pb/evnode/v1/execution.pb.go @@ -2,9 +2,9 @@ // versions: // protoc-gen-go v1.36.11 // protoc (unknown) -// source: execution.proto +// source: evnode/v1/execution.proto -package pb +package v1 import ( protoreflect "google.golang.org/protobuf/reflect/protoreflect" @@ -59,11 +59,11 @@ func (x FilterStatus) String() string { } func (FilterStatus) Descriptor() protoreflect.EnumDescriptor { - return file_execution_proto_enumTypes[0].Descriptor() + return file_evnode_v1_execution_proto_enumTypes[0].Descriptor() } func (FilterStatus) Type() protoreflect.EnumType { - return &file_execution_proto_enumTypes[0] + return &file_evnode_v1_execution_proto_enumTypes[0] } func (x FilterStatus) Number() protoreflect.EnumNumber { @@ -72,7 +72,7 @@ func (x FilterStatus) Number() protoreflect.EnumNumber { // Deprecated: Use FilterStatus.Descriptor instead. func (FilterStatus) EnumDescriptor() ([]byte, []int) { - return file_execution_proto_rawDescGZIP(), []int{0} + return file_evnode_v1_execution_proto_rawDescGZIP(), []int{0} } // InitChainRequest contains the genesis parameters for chain initialization @@ -90,7 +90,7 @@ type InitChainRequest struct { func (x *InitChainRequest) Reset() { *x = InitChainRequest{} - mi := &file_execution_proto_msgTypes[0] + mi := &file_evnode_v1_execution_proto_msgTypes[0] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -102,7 +102,7 @@ func (x *InitChainRequest) String() string { func (*InitChainRequest) ProtoMessage() {} func (x *InitChainRequest) ProtoReflect() protoreflect.Message { - mi := &file_execution_proto_msgTypes[0] + mi := &file_evnode_v1_execution_proto_msgTypes[0] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -115,7 +115,7 @@ func (x *InitChainRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use InitChainRequest.ProtoReflect.Descriptor instead. func (*InitChainRequest) Descriptor() ([]byte, []int) { - return file_execution_proto_rawDescGZIP(), []int{0} + return file_evnode_v1_execution_proto_rawDescGZIP(), []int{0} } func (x *InitChainRequest) GetGenesisTime() *timestamppb.Timestamp { @@ -150,7 +150,7 @@ type InitChainResponse struct { func (x *InitChainResponse) Reset() { *x = InitChainResponse{} - mi := &file_execution_proto_msgTypes[1] + mi := &file_evnode_v1_execution_proto_msgTypes[1] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -162,7 +162,7 @@ func (x *InitChainResponse) String() string { func (*InitChainResponse) ProtoMessage() {} func (x *InitChainResponse) ProtoReflect() protoreflect.Message { - mi := &file_execution_proto_msgTypes[1] + mi := &file_evnode_v1_execution_proto_msgTypes[1] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -175,7 +175,7 @@ func (x *InitChainResponse) ProtoReflect() protoreflect.Message { // Deprecated: Use InitChainResponse.ProtoReflect.Descriptor instead. func (*InitChainResponse) Descriptor() ([]byte, []int) { - return file_execution_proto_rawDescGZIP(), []int{1} + return file_evnode_v1_execution_proto_rawDescGZIP(), []int{1} } func (x *InitChainResponse) GetStateRoot() []byte { @@ -194,7 +194,7 @@ type GetTxsRequest struct { func (x *GetTxsRequest) Reset() { *x = GetTxsRequest{} - mi := &file_execution_proto_msgTypes[2] + mi := &file_evnode_v1_execution_proto_msgTypes[2] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -206,7 +206,7 @@ func (x *GetTxsRequest) String() string { func (*GetTxsRequest) ProtoMessage() {} func (x *GetTxsRequest) ProtoReflect() protoreflect.Message { - mi := &file_execution_proto_msgTypes[2] + mi := &file_evnode_v1_execution_proto_msgTypes[2] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -219,7 +219,7 @@ func (x *GetTxsRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use GetTxsRequest.ProtoReflect.Descriptor instead. func (*GetTxsRequest) Descriptor() ([]byte, []int) { - return file_execution_proto_rawDescGZIP(), []int{2} + return file_evnode_v1_execution_proto_rawDescGZIP(), []int{2} } // TxBatch stores ordered transactions in one contiguous bytes buffer. @@ -235,7 +235,7 @@ type TxBatch struct { func (x *TxBatch) Reset() { *x = TxBatch{} - mi := &file_execution_proto_msgTypes[3] + mi := &file_evnode_v1_execution_proto_msgTypes[3] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -247,7 +247,7 @@ func (x *TxBatch) String() string { func (*TxBatch) ProtoMessage() {} func (x *TxBatch) ProtoReflect() protoreflect.Message { - mi := &file_execution_proto_msgTypes[3] + mi := &file_evnode_v1_execution_proto_msgTypes[3] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -260,7 +260,7 @@ func (x *TxBatch) ProtoReflect() protoreflect.Message { // Deprecated: Use TxBatch.ProtoReflect.Descriptor instead. func (*TxBatch) Descriptor() ([]byte, []int) { - return file_execution_proto_rawDescGZIP(), []int{3} + return file_evnode_v1_execution_proto_rawDescGZIP(), []int{3} } func (x *TxBatch) GetData() []byte { @@ -288,7 +288,7 @@ type GetTxsResponse struct { func (x *GetTxsResponse) Reset() { *x = GetTxsResponse{} - mi := &file_execution_proto_msgTypes[4] + mi := &file_evnode_v1_execution_proto_msgTypes[4] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -300,7 +300,7 @@ func (x *GetTxsResponse) String() string { func (*GetTxsResponse) ProtoMessage() {} func (x *GetTxsResponse) ProtoReflect() protoreflect.Message { - mi := &file_execution_proto_msgTypes[4] + mi := &file_evnode_v1_execution_proto_msgTypes[4] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -313,7 +313,7 @@ func (x *GetTxsResponse) ProtoReflect() protoreflect.Message { // Deprecated: Use GetTxsResponse.ProtoReflect.Descriptor instead. func (*GetTxsResponse) Descriptor() ([]byte, []int) { - return file_execution_proto_rawDescGZIP(), []int{4} + return file_evnode_v1_execution_proto_rawDescGZIP(), []int{4} } func (x *GetTxsResponse) GetTxBatch() *TxBatch { @@ -340,7 +340,7 @@ type ExecuteTxsRequest struct { func (x *ExecuteTxsRequest) Reset() { *x = ExecuteTxsRequest{} - mi := &file_execution_proto_msgTypes[5] + mi := &file_evnode_v1_execution_proto_msgTypes[5] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -352,7 +352,7 @@ func (x *ExecuteTxsRequest) String() string { func (*ExecuteTxsRequest) ProtoMessage() {} func (x *ExecuteTxsRequest) ProtoReflect() protoreflect.Message { - mi := &file_execution_proto_msgTypes[5] + mi := &file_evnode_v1_execution_proto_msgTypes[5] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -365,7 +365,7 @@ func (x *ExecuteTxsRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use ExecuteTxsRequest.ProtoReflect.Descriptor instead. func (*ExecuteTxsRequest) Descriptor() ([]byte, []int) { - return file_execution_proto_rawDescGZIP(), []int{5} + return file_evnode_v1_execution_proto_rawDescGZIP(), []int{5} } func (x *ExecuteTxsRequest) GetBlockHeight() uint64 { @@ -409,7 +409,7 @@ type ExecuteTxsResponse struct { func (x *ExecuteTxsResponse) Reset() { *x = ExecuteTxsResponse{} - mi := &file_execution_proto_msgTypes[6] + mi := &file_evnode_v1_execution_proto_msgTypes[6] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -421,7 +421,7 @@ func (x *ExecuteTxsResponse) String() string { func (*ExecuteTxsResponse) ProtoMessage() {} func (x *ExecuteTxsResponse) ProtoReflect() protoreflect.Message { - mi := &file_execution_proto_msgTypes[6] + mi := &file_evnode_v1_execution_proto_msgTypes[6] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -434,7 +434,7 @@ func (x *ExecuteTxsResponse) ProtoReflect() protoreflect.Message { // Deprecated: Use ExecuteTxsResponse.ProtoReflect.Descriptor instead. func (*ExecuteTxsResponse) Descriptor() ([]byte, []int) { - return file_execution_proto_rawDescGZIP(), []int{6} + return file_evnode_v1_execution_proto_rawDescGZIP(), []int{6} } func (x *ExecuteTxsResponse) GetUpdatedStateRoot() []byte { @@ -462,7 +462,7 @@ type SetFinalRequest struct { func (x *SetFinalRequest) Reset() { *x = SetFinalRequest{} - mi := &file_execution_proto_msgTypes[7] + mi := &file_evnode_v1_execution_proto_msgTypes[7] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -474,7 +474,7 @@ func (x *SetFinalRequest) String() string { func (*SetFinalRequest) ProtoMessage() {} func (x *SetFinalRequest) ProtoReflect() protoreflect.Message { - mi := &file_execution_proto_msgTypes[7] + mi := &file_evnode_v1_execution_proto_msgTypes[7] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -487,7 +487,7 @@ func (x *SetFinalRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use SetFinalRequest.ProtoReflect.Descriptor instead. func (*SetFinalRequest) Descriptor() ([]byte, []int) { - return file_execution_proto_rawDescGZIP(), []int{7} + return file_evnode_v1_execution_proto_rawDescGZIP(), []int{7} } func (x *SetFinalRequest) GetBlockHeight() uint64 { @@ -506,7 +506,7 @@ type SetFinalResponse struct { func (x *SetFinalResponse) Reset() { *x = SetFinalResponse{} - mi := &file_execution_proto_msgTypes[8] + mi := &file_evnode_v1_execution_proto_msgTypes[8] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -518,7 +518,7 @@ func (x *SetFinalResponse) String() string { func (*SetFinalResponse) ProtoMessage() {} func (x *SetFinalResponse) ProtoReflect() protoreflect.Message { - mi := &file_execution_proto_msgTypes[8] + mi := &file_evnode_v1_execution_proto_msgTypes[8] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -531,7 +531,7 @@ func (x *SetFinalResponse) ProtoReflect() protoreflect.Message { // Deprecated: Use SetFinalResponse.ProtoReflect.Descriptor instead. func (*SetFinalResponse) Descriptor() ([]byte, []int) { - return file_execution_proto_rawDescGZIP(), []int{8} + return file_evnode_v1_execution_proto_rawDescGZIP(), []int{8} } // GetExecutionInfoRequest requests execution layer parameters @@ -543,7 +543,7 @@ type GetExecutionInfoRequest struct { func (x *GetExecutionInfoRequest) Reset() { *x = GetExecutionInfoRequest{} - mi := &file_execution_proto_msgTypes[9] + mi := &file_evnode_v1_execution_proto_msgTypes[9] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -555,7 +555,7 @@ func (x *GetExecutionInfoRequest) String() string { func (*GetExecutionInfoRequest) ProtoMessage() {} func (x *GetExecutionInfoRequest) ProtoReflect() protoreflect.Message { - mi := &file_execution_proto_msgTypes[9] + mi := &file_evnode_v1_execution_proto_msgTypes[9] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -568,7 +568,7 @@ func (x *GetExecutionInfoRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use GetExecutionInfoRequest.ProtoReflect.Descriptor instead. func (*GetExecutionInfoRequest) Descriptor() ([]byte, []int) { - return file_execution_proto_rawDescGZIP(), []int{9} + return file_evnode_v1_execution_proto_rawDescGZIP(), []int{9} } // GetExecutionInfoResponse contains execution layer parameters @@ -583,7 +583,7 @@ type GetExecutionInfoResponse struct { func (x *GetExecutionInfoResponse) Reset() { *x = GetExecutionInfoResponse{} - mi := &file_execution_proto_msgTypes[10] + mi := &file_evnode_v1_execution_proto_msgTypes[10] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -595,7 +595,7 @@ func (x *GetExecutionInfoResponse) String() string { func (*GetExecutionInfoResponse) ProtoMessage() {} func (x *GetExecutionInfoResponse) ProtoReflect() protoreflect.Message { - mi := &file_execution_proto_msgTypes[10] + mi := &file_evnode_v1_execution_proto_msgTypes[10] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -608,7 +608,7 @@ func (x *GetExecutionInfoResponse) ProtoReflect() protoreflect.Message { // Deprecated: Use GetExecutionInfoResponse.ProtoReflect.Descriptor instead. func (*GetExecutionInfoResponse) Descriptor() ([]byte, []int) { - return file_execution_proto_rawDescGZIP(), []int{10} + return file_evnode_v1_execution_proto_rawDescGZIP(), []int{10} } func (x *GetExecutionInfoResponse) GetMaxGas() uint64 { @@ -635,7 +635,7 @@ type FilterTxsRequest struct { func (x *FilterTxsRequest) Reset() { *x = FilterTxsRequest{} - mi := &file_execution_proto_msgTypes[11] + mi := &file_evnode_v1_execution_proto_msgTypes[11] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -647,7 +647,7 @@ func (x *FilterTxsRequest) String() string { func (*FilterTxsRequest) ProtoMessage() {} func (x *FilterTxsRequest) ProtoReflect() protoreflect.Message { - mi := &file_execution_proto_msgTypes[11] + mi := &file_evnode_v1_execution_proto_msgTypes[11] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -660,7 +660,7 @@ func (x *FilterTxsRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use FilterTxsRequest.ProtoReflect.Descriptor instead. func (*FilterTxsRequest) Descriptor() ([]byte, []int) { - return file_execution_proto_rawDescGZIP(), []int{11} + return file_evnode_v1_execution_proto_rawDescGZIP(), []int{11} } func (x *FilterTxsRequest) GetMaxBytes() uint64 { @@ -702,7 +702,7 @@ type FilterTxsResponse struct { func (x *FilterTxsResponse) Reset() { *x = FilterTxsResponse{} - mi := &file_execution_proto_msgTypes[12] + mi := &file_evnode_v1_execution_proto_msgTypes[12] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -714,7 +714,7 @@ func (x *FilterTxsResponse) String() string { func (*FilterTxsResponse) ProtoMessage() {} func (x *FilterTxsResponse) ProtoReflect() protoreflect.Message { - mi := &file_execution_proto_msgTypes[12] + mi := &file_evnode_v1_execution_proto_msgTypes[12] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -727,7 +727,7 @@ func (x *FilterTxsResponse) ProtoReflect() protoreflect.Message { // Deprecated: Use FilterTxsResponse.ProtoReflect.Descriptor instead. func (*FilterTxsResponse) Descriptor() ([]byte, []int) { - return file_execution_proto_rawDescGZIP(), []int{12} + return file_evnode_v1_execution_proto_rawDescGZIP(), []int{12} } func (x *FilterTxsResponse) GetStatuses() []FilterStatus { @@ -737,11 +737,11 @@ func (x *FilterTxsResponse) GetStatuses() []FilterStatus { return nil } -var File_execution_proto protoreflect.FileDescriptor +var File_evnode_v1_execution_proto protoreflect.FileDescriptor -const file_execution_proto_rawDesc = "" + +const file_evnode_v1_execution_proto_rawDesc = "" + "\n" + - "\x0fexecution.proto\x12\tevnode.v1\x1a\x1fgoogle/protobuf/timestamp.proto\"\x93\x01\n" + + "\x19evnode/v1/execution.proto\x12\tevnode.v1\x1a\x1fgoogle/protobuf/timestamp.proto\"\x93\x01\n" + "\x10InitChainRequest\x12=\n" + "\fgenesis_time\x18\x01 \x01(\v2\x1a.google.protobuf.TimestampR\vgenesisTime\x12%\n" + "\x0einitial_height\x18\x02 \x01(\x04R\rinitialHeight\x12\x19\n" + @@ -787,23 +787,23 @@ const file_execution_proto_rawDesc = "" + "ExecuteTxs\x12\x1c.evnode.v1.ExecuteTxsRequest\x1a\x1d.evnode.v1.ExecuteTxsResponse\"\x00\x12E\n" + "\bSetFinal\x12\x1a.evnode.v1.SetFinalRequest\x1a\x1b.evnode.v1.SetFinalResponse\"\x00\x12]\n" + "\x10GetExecutionInfo\x12\".evnode.v1.GetExecutionInfoRequest\x1a#.evnode.v1.GetExecutionInfoResponse\"\x00\x12H\n" + - "\tFilterTxs\x12\x1b.evnode.v1.FilterTxsRequest\x1a\x1c.evnode.v1.FilterTxsResponse\"\x00B4Z2github.com/evstack/ev-node/execution/grpc/types/pbb\x06proto3" + "\tFilterTxs\x12\x1b.evnode.v1.FilterTxsRequest\x1a\x1c.evnode.v1.FilterTxsResponse\"\x00B>Z google.protobuf.Timestamp 4, // 1: evnode.v1.GetTxsResponse.tx_batch:type_name -> evnode.v1.TxBatch 14, // 2: evnode.v1.ExecuteTxsRequest.timestamp:type_name -> google.protobuf.Timestamp @@ -846,27 +846,27 @@ var file_execution_proto_depIdxs = []int32{ 0, // [0:6] is the sub-list for field type_name } -func init() { file_execution_proto_init() } -func file_execution_proto_init() { - if File_execution_proto != nil { +func init() { file_evnode_v1_execution_proto_init() } +func file_evnode_v1_execution_proto_init() { + if File_evnode_v1_execution_proto != nil { return } type x struct{} out := protoimpl.TypeBuilder{ File: protoimpl.DescBuilder{ GoPackagePath: reflect.TypeOf(x{}).PkgPath(), - RawDescriptor: unsafe.Slice(unsafe.StringData(file_execution_proto_rawDesc), len(file_execution_proto_rawDesc)), + RawDescriptor: unsafe.Slice(unsafe.StringData(file_evnode_v1_execution_proto_rawDesc), len(file_evnode_v1_execution_proto_rawDesc)), NumEnums: 1, NumMessages: 13, NumExtensions: 0, NumServices: 1, }, - GoTypes: file_execution_proto_goTypes, - DependencyIndexes: file_execution_proto_depIdxs, - EnumInfos: file_execution_proto_enumTypes, - MessageInfos: file_execution_proto_msgTypes, + GoTypes: file_evnode_v1_execution_proto_goTypes, + DependencyIndexes: file_evnode_v1_execution_proto_depIdxs, + EnumInfos: file_evnode_v1_execution_proto_enumTypes, + MessageInfos: file_evnode_v1_execution_proto_msgTypes, }.Build() - File_execution_proto = out.File - file_execution_proto_goTypes = nil - file_execution_proto_depIdxs = nil + File_evnode_v1_execution_proto = out.File + file_evnode_v1_execution_proto_goTypes = nil + file_evnode_v1_execution_proto_depIdxs = nil } diff --git a/execution/grpc/types/pb/pbconnect/execution.connect.go b/execution/grpc/types/pb/evnode/v1/v1connect/execution.connect.go similarity index 74% rename from execution/grpc/types/pb/pbconnect/execution.connect.go rename to execution/grpc/types/pb/evnode/v1/v1connect/execution.connect.go index 783edb89d2..c4f7f1df64 100644 --- a/execution/grpc/types/pb/pbconnect/execution.connect.go +++ b/execution/grpc/types/pb/evnode/v1/v1connect/execution.connect.go @@ -1,14 +1,14 @@ // Code generated by protoc-gen-connect-go. DO NOT EDIT. // -// Source: execution.proto +// Source: evnode/v1/execution.proto -package pbconnect +package v1connect import ( connect "connectrpc.com/connect" context "context" errors "errors" - pb "github.com/evstack/ev-node/execution/grpc/types/pb" + v1 "github.com/evstack/ev-node/execution/grpc/types/pb/evnode/v1" http "net/http" strings "strings" ) @@ -55,17 +55,17 @@ const ( // ExecutorServiceClient is a client for the evnode.v1.ExecutorService service. type ExecutorServiceClient interface { // InitChain initializes a new blockchain instance with genesis parameters - InitChain(context.Context, *connect.Request[pb.InitChainRequest]) (*connect.Response[pb.InitChainResponse], error) + InitChain(context.Context, *connect.Request[v1.InitChainRequest]) (*connect.Response[v1.InitChainResponse], error) // GetTxs fetches available transactions from the execution layer's mempool - GetTxs(context.Context, *connect.Request[pb.GetTxsRequest]) (*connect.Response[pb.GetTxsResponse], error) + GetTxs(context.Context, *connect.Request[v1.GetTxsRequest]) (*connect.Response[v1.GetTxsResponse], error) // ExecuteTxs processes transactions to produce a new block state - ExecuteTxs(context.Context, *connect.Request[pb.ExecuteTxsRequest]) (*connect.Response[pb.ExecuteTxsResponse], error) + ExecuteTxs(context.Context, *connect.Request[v1.ExecuteTxsRequest]) (*connect.Response[v1.ExecuteTxsResponse], error) // SetFinal marks a block as finalized at the specified height - SetFinal(context.Context, *connect.Request[pb.SetFinalRequest]) (*connect.Response[pb.SetFinalResponse], error) + SetFinal(context.Context, *connect.Request[v1.SetFinalRequest]) (*connect.Response[v1.SetFinalResponse], error) // GetExecutionInfo returns current execution layer parameters - GetExecutionInfo(context.Context, *connect.Request[pb.GetExecutionInfoRequest]) (*connect.Response[pb.GetExecutionInfoResponse], error) + GetExecutionInfo(context.Context, *connect.Request[v1.GetExecutionInfoRequest]) (*connect.Response[v1.GetExecutionInfoResponse], error) // FilterTxs validates force-included transactions and calculates gas for all transactions - FilterTxs(context.Context, *connect.Request[pb.FilterTxsRequest]) (*connect.Response[pb.FilterTxsResponse], error) + FilterTxs(context.Context, *connect.Request[v1.FilterTxsRequest]) (*connect.Response[v1.FilterTxsResponse], error) } // NewExecutorServiceClient constructs a client for the evnode.v1.ExecutorService service. By @@ -77,39 +77,39 @@ type ExecutorServiceClient interface { // http://api.acme.com or https://acme.com/grpc). func NewExecutorServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ExecutorServiceClient { baseURL = strings.TrimRight(baseURL, "/") - executorServiceMethods := pb.File_execution_proto.Services().ByName("ExecutorService").Methods() + executorServiceMethods := v1.File_evnode_v1_execution_proto.Services().ByName("ExecutorService").Methods() return &executorServiceClient{ - initChain: connect.NewClient[pb.InitChainRequest, pb.InitChainResponse]( + initChain: connect.NewClient[v1.InitChainRequest, v1.InitChainResponse]( httpClient, baseURL+ExecutorServiceInitChainProcedure, connect.WithSchema(executorServiceMethods.ByName("InitChain")), connect.WithClientOptions(opts...), ), - getTxs: connect.NewClient[pb.GetTxsRequest, pb.GetTxsResponse]( + getTxs: connect.NewClient[v1.GetTxsRequest, v1.GetTxsResponse]( httpClient, baseURL+ExecutorServiceGetTxsProcedure, connect.WithSchema(executorServiceMethods.ByName("GetTxs")), connect.WithClientOptions(opts...), ), - executeTxs: connect.NewClient[pb.ExecuteTxsRequest, pb.ExecuteTxsResponse]( + executeTxs: connect.NewClient[v1.ExecuteTxsRequest, v1.ExecuteTxsResponse]( httpClient, baseURL+ExecutorServiceExecuteTxsProcedure, connect.WithSchema(executorServiceMethods.ByName("ExecuteTxs")), connect.WithClientOptions(opts...), ), - setFinal: connect.NewClient[pb.SetFinalRequest, pb.SetFinalResponse]( + setFinal: connect.NewClient[v1.SetFinalRequest, v1.SetFinalResponse]( httpClient, baseURL+ExecutorServiceSetFinalProcedure, connect.WithSchema(executorServiceMethods.ByName("SetFinal")), connect.WithClientOptions(opts...), ), - getExecutionInfo: connect.NewClient[pb.GetExecutionInfoRequest, pb.GetExecutionInfoResponse]( + getExecutionInfo: connect.NewClient[v1.GetExecutionInfoRequest, v1.GetExecutionInfoResponse]( httpClient, baseURL+ExecutorServiceGetExecutionInfoProcedure, connect.WithSchema(executorServiceMethods.ByName("GetExecutionInfo")), connect.WithClientOptions(opts...), ), - filterTxs: connect.NewClient[pb.FilterTxsRequest, pb.FilterTxsResponse]( + filterTxs: connect.NewClient[v1.FilterTxsRequest, v1.FilterTxsResponse]( httpClient, baseURL+ExecutorServiceFilterTxsProcedure, connect.WithSchema(executorServiceMethods.ByName("FilterTxs")), @@ -120,58 +120,58 @@ func NewExecutorServiceClient(httpClient connect.HTTPClient, baseURL string, opt // executorServiceClient implements ExecutorServiceClient. type executorServiceClient struct { - initChain *connect.Client[pb.InitChainRequest, pb.InitChainResponse] - getTxs *connect.Client[pb.GetTxsRequest, pb.GetTxsResponse] - executeTxs *connect.Client[pb.ExecuteTxsRequest, pb.ExecuteTxsResponse] - setFinal *connect.Client[pb.SetFinalRequest, pb.SetFinalResponse] - getExecutionInfo *connect.Client[pb.GetExecutionInfoRequest, pb.GetExecutionInfoResponse] - filterTxs *connect.Client[pb.FilterTxsRequest, pb.FilterTxsResponse] + initChain *connect.Client[v1.InitChainRequest, v1.InitChainResponse] + getTxs *connect.Client[v1.GetTxsRequest, v1.GetTxsResponse] + executeTxs *connect.Client[v1.ExecuteTxsRequest, v1.ExecuteTxsResponse] + setFinal *connect.Client[v1.SetFinalRequest, v1.SetFinalResponse] + getExecutionInfo *connect.Client[v1.GetExecutionInfoRequest, v1.GetExecutionInfoResponse] + filterTxs *connect.Client[v1.FilterTxsRequest, v1.FilterTxsResponse] } // InitChain calls evnode.v1.ExecutorService.InitChain. -func (c *executorServiceClient) InitChain(ctx context.Context, req *connect.Request[pb.InitChainRequest]) (*connect.Response[pb.InitChainResponse], error) { +func (c *executorServiceClient) InitChain(ctx context.Context, req *connect.Request[v1.InitChainRequest]) (*connect.Response[v1.InitChainResponse], error) { return c.initChain.CallUnary(ctx, req) } // GetTxs calls evnode.v1.ExecutorService.GetTxs. -func (c *executorServiceClient) GetTxs(ctx context.Context, req *connect.Request[pb.GetTxsRequest]) (*connect.Response[pb.GetTxsResponse], error) { +func (c *executorServiceClient) GetTxs(ctx context.Context, req *connect.Request[v1.GetTxsRequest]) (*connect.Response[v1.GetTxsResponse], error) { return c.getTxs.CallUnary(ctx, req) } // ExecuteTxs calls evnode.v1.ExecutorService.ExecuteTxs. -func (c *executorServiceClient) ExecuteTxs(ctx context.Context, req *connect.Request[pb.ExecuteTxsRequest]) (*connect.Response[pb.ExecuteTxsResponse], error) { +func (c *executorServiceClient) ExecuteTxs(ctx context.Context, req *connect.Request[v1.ExecuteTxsRequest]) (*connect.Response[v1.ExecuteTxsResponse], error) { return c.executeTxs.CallUnary(ctx, req) } // SetFinal calls evnode.v1.ExecutorService.SetFinal. -func (c *executorServiceClient) SetFinal(ctx context.Context, req *connect.Request[pb.SetFinalRequest]) (*connect.Response[pb.SetFinalResponse], error) { +func (c *executorServiceClient) SetFinal(ctx context.Context, req *connect.Request[v1.SetFinalRequest]) (*connect.Response[v1.SetFinalResponse], error) { return c.setFinal.CallUnary(ctx, req) } // GetExecutionInfo calls evnode.v1.ExecutorService.GetExecutionInfo. -func (c *executorServiceClient) GetExecutionInfo(ctx context.Context, req *connect.Request[pb.GetExecutionInfoRequest]) (*connect.Response[pb.GetExecutionInfoResponse], error) { +func (c *executorServiceClient) GetExecutionInfo(ctx context.Context, req *connect.Request[v1.GetExecutionInfoRequest]) (*connect.Response[v1.GetExecutionInfoResponse], error) { return c.getExecutionInfo.CallUnary(ctx, req) } // FilterTxs calls evnode.v1.ExecutorService.FilterTxs. -func (c *executorServiceClient) FilterTxs(ctx context.Context, req *connect.Request[pb.FilterTxsRequest]) (*connect.Response[pb.FilterTxsResponse], error) { +func (c *executorServiceClient) FilterTxs(ctx context.Context, req *connect.Request[v1.FilterTxsRequest]) (*connect.Response[v1.FilterTxsResponse], error) { return c.filterTxs.CallUnary(ctx, req) } // ExecutorServiceHandler is an implementation of the evnode.v1.ExecutorService service. type ExecutorServiceHandler interface { // InitChain initializes a new blockchain instance with genesis parameters - InitChain(context.Context, *connect.Request[pb.InitChainRequest]) (*connect.Response[pb.InitChainResponse], error) + InitChain(context.Context, *connect.Request[v1.InitChainRequest]) (*connect.Response[v1.InitChainResponse], error) // GetTxs fetches available transactions from the execution layer's mempool - GetTxs(context.Context, *connect.Request[pb.GetTxsRequest]) (*connect.Response[pb.GetTxsResponse], error) + GetTxs(context.Context, *connect.Request[v1.GetTxsRequest]) (*connect.Response[v1.GetTxsResponse], error) // ExecuteTxs processes transactions to produce a new block state - ExecuteTxs(context.Context, *connect.Request[pb.ExecuteTxsRequest]) (*connect.Response[pb.ExecuteTxsResponse], error) + ExecuteTxs(context.Context, *connect.Request[v1.ExecuteTxsRequest]) (*connect.Response[v1.ExecuteTxsResponse], error) // SetFinal marks a block as finalized at the specified height - SetFinal(context.Context, *connect.Request[pb.SetFinalRequest]) (*connect.Response[pb.SetFinalResponse], error) + SetFinal(context.Context, *connect.Request[v1.SetFinalRequest]) (*connect.Response[v1.SetFinalResponse], error) // GetExecutionInfo returns current execution layer parameters - GetExecutionInfo(context.Context, *connect.Request[pb.GetExecutionInfoRequest]) (*connect.Response[pb.GetExecutionInfoResponse], error) + GetExecutionInfo(context.Context, *connect.Request[v1.GetExecutionInfoRequest]) (*connect.Response[v1.GetExecutionInfoResponse], error) // FilterTxs validates force-included transactions and calculates gas for all transactions - FilterTxs(context.Context, *connect.Request[pb.FilterTxsRequest]) (*connect.Response[pb.FilterTxsResponse], error) + FilterTxs(context.Context, *connect.Request[v1.FilterTxsRequest]) (*connect.Response[v1.FilterTxsResponse], error) } // NewExecutorServiceHandler builds an HTTP handler from the service implementation. It returns the @@ -180,7 +180,7 @@ type ExecutorServiceHandler interface { // By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf // and JSON codecs. They also support gzip compression. func NewExecutorServiceHandler(svc ExecutorServiceHandler, opts ...connect.HandlerOption) (string, http.Handler) { - executorServiceMethods := pb.File_execution_proto.Services().ByName("ExecutorService").Methods() + executorServiceMethods := v1.File_evnode_v1_execution_proto.Services().ByName("ExecutorService").Methods() executorServiceInitChainHandler := connect.NewUnaryHandler( ExecutorServiceInitChainProcedure, svc.InitChain, @@ -240,26 +240,26 @@ func NewExecutorServiceHandler(svc ExecutorServiceHandler, opts ...connect.Handl // UnimplementedExecutorServiceHandler returns CodeUnimplemented from all methods. type UnimplementedExecutorServiceHandler struct{} -func (UnimplementedExecutorServiceHandler) InitChain(context.Context, *connect.Request[pb.InitChainRequest]) (*connect.Response[pb.InitChainResponse], error) { +func (UnimplementedExecutorServiceHandler) InitChain(context.Context, *connect.Request[v1.InitChainRequest]) (*connect.Response[v1.InitChainResponse], error) { return nil, connect.NewError(connect.CodeUnimplemented, errors.New("evnode.v1.ExecutorService.InitChain is not implemented")) } -func (UnimplementedExecutorServiceHandler) GetTxs(context.Context, *connect.Request[pb.GetTxsRequest]) (*connect.Response[pb.GetTxsResponse], error) { +func (UnimplementedExecutorServiceHandler) GetTxs(context.Context, *connect.Request[v1.GetTxsRequest]) (*connect.Response[v1.GetTxsResponse], error) { return nil, connect.NewError(connect.CodeUnimplemented, errors.New("evnode.v1.ExecutorService.GetTxs is not implemented")) } -func (UnimplementedExecutorServiceHandler) ExecuteTxs(context.Context, *connect.Request[pb.ExecuteTxsRequest]) (*connect.Response[pb.ExecuteTxsResponse], error) { +func (UnimplementedExecutorServiceHandler) ExecuteTxs(context.Context, *connect.Request[v1.ExecuteTxsRequest]) (*connect.Response[v1.ExecuteTxsResponse], error) { return nil, connect.NewError(connect.CodeUnimplemented, errors.New("evnode.v1.ExecutorService.ExecuteTxs is not implemented")) } -func (UnimplementedExecutorServiceHandler) SetFinal(context.Context, *connect.Request[pb.SetFinalRequest]) (*connect.Response[pb.SetFinalResponse], error) { +func (UnimplementedExecutorServiceHandler) SetFinal(context.Context, *connect.Request[v1.SetFinalRequest]) (*connect.Response[v1.SetFinalResponse], error) { return nil, connect.NewError(connect.CodeUnimplemented, errors.New("evnode.v1.ExecutorService.SetFinal is not implemented")) } -func (UnimplementedExecutorServiceHandler) GetExecutionInfo(context.Context, *connect.Request[pb.GetExecutionInfoRequest]) (*connect.Response[pb.GetExecutionInfoResponse], error) { +func (UnimplementedExecutorServiceHandler) GetExecutionInfo(context.Context, *connect.Request[v1.GetExecutionInfoRequest]) (*connect.Response[v1.GetExecutionInfoResponse], error) { return nil, connect.NewError(connect.CodeUnimplemented, errors.New("evnode.v1.ExecutorService.GetExecutionInfo is not implemented")) } -func (UnimplementedExecutorServiceHandler) FilterTxs(context.Context, *connect.Request[pb.FilterTxsRequest]) (*connect.Response[pb.FilterTxsResponse], error) { +func (UnimplementedExecutorServiceHandler) FilterTxs(context.Context, *connect.Request[v1.FilterTxsRequest]) (*connect.Response[v1.FilterTxsResponse], error) { return nil, connect.NewError(connect.CodeUnimplemented, errors.New("evnode.v1.ExecutorService.FilterTxs is not implemented")) } From 9a35a4d2ba39c313ca83a1a9daf6b0243a2ca555 Mon Sep 17 00:00:00 2001 From: Julien Robert Date: Wed, 29 Apr 2026 16:59:35 +0200 Subject: [PATCH 3/3] fix lint --- buf.yaml | 1 - 1 file changed, 1 deletion(-) diff --git a/buf.yaml b/buf.yaml index de4bdb8eef..f3aef299bd 100644 --- a/buf.yaml +++ b/buf.yaml @@ -15,4 +15,3 @@ lint: breaking: use: - FILE -