backfill

Author: serichoi65

go.mod

@@ -3,6 +3,7 @@ module github.com/Layr-Labs/protocol-apis
 go 1.23.6
 
 require (
+	github.com/Layr-Labs/protobuf-libs v0.0.0-20250305032038-8d1047b56aab
 	github.com/akuity/grpc-gateway-client v0.0.0-20240912082144-55a48e8b4b89
 	github.com/grpc-ecosystem/grpc-gateway/v2 v2.15.2
 	google.golang.org/genproto/googleapis/api v0.0.0-20230525234035-dd9d682886f9
@@ -11,7 +12,6 @@ require (
 )
 
 require (
-	github.com/Layr-Labs/protobuf-libs v0.0.0-20250305032038-8d1047b56aab // indirect
 	github.com/alevinval/sse v1.0.1 // indirect
 	github.com/go-resty/resty/v2 v2.7.0 // indirect
 	github.com/golang/protobuf v1.5.3 // indirect

protos/eigenlayer/sidecar/v1/backfiller/backfiller.proto

@@ -0,0 +1,75 @@
+syntax = "proto3";
+
+package eigenlayer.sidecar.v1.backfiller;
+
+option go_package = "github.com/Layr-Labs/protocol-apis/gen/protos/eigenlayer/sidecar/v1/backfiller";
+
+import "google/api/annotations.proto";
+import "eigenlayer/sidecar/v1/ethereumTypes/ethereumTypes.proto";
+
+// BackfillRequest represents a request to backfill transaction data for a range of blocks
+message BackfillRequest {
+  // StartBlock is the first block to process (inclusive)
+  uint64 start_block = 1;
+  
+  // EndBlock is the last block to process (inclusive)
+  uint64 end_block = 2;
+  
+  // Addresses is a list of contract addresses to filter logs by
+  repeated string addresses = 3;
+  
+  // EventSignatures is a list of event signatures to filter logs by
+  repeated string event_signatures = 4;
+}
+
+// BackfillResponse represents the result of a backfill operation
+message BackfillResponse {
+  // Success indicates whether the backfill operation was successful
+  bool success = 1;
+  
+  // Errors is a list of errors encountered during backfilling
+  repeated string errors = 2;
+  
+  // ProcessedBlocks is the number of blocks that were processed
+  uint64 processed_blocks = 3;
+  
+  // ProcessedLogs is the number of logs that were processed
+  uint64 processed_logs = 4;
+}
+
+// BackfillStatusRequest represents a request to get the status of a backfill operation
+message BackfillStatusRequest {
+  // RequestId is the ID of the backfill request to get status for
+  string request_id = 1;
+}
+
+// BackfillStatusResponse represents the status of a backfill operation
+message BackfillStatusResponse {
+  // RequestId is the ID of the backfill request
+  string request_id = 1;
+  
+  // Status is the current status of the backfill operation
+  enum Status {
+    UNKNOWN = 0;
+    QUEUED = 1;
+    PROCESSING = 2;
+    COMPLETED = 3;
+    FAILED = 4;
+  }
+  Status status = 2;
+  
+  // Progress is the percentage of completion (0-100)
+  uint32 progress = 3;
+  
+  // StartBlock is the first block being processed
+  uint64 start_block = 4;
+  
+  // CurrentBlock is the block currently being processed
+  uint64 current_block = 5;
+  
+  // EndBlock is the last block to be processed
+  uint64 end_block = 6;
+  
+  // Errors is a list of errors encountered during backfilling
+  repeated string errors = 7;
+} 

protos/eigenlayer/sidecar/v1/backfiller/rpc.proto

@@ -0,0 +1,33 @@
+syntax = "proto3";
+
+package eigenlayer.sidecar.v1.backfiller;
+
+option go_package = "github.com/Layr-Labs/protocol-apis/gen/protos/eigenlayer/sidecar/v1/backfiller";
+
+import "google/api/annotations.proto";
+import "eigenlayer/sidecar/v1/backfiller/backfiller.proto";
+
+// TransactionBackfiller service provides methods for backfilling transaction data
+service TransactionBackfiller {
+  // BackfillBlocks initiates a backfill operation for a range of blocks
+  rpc BackfillBlocks(BackfillRequest) returns (BackfillResponse) {
+    option (google.api.http) = {
+      post: "/backfiller/v1/backfill-blocks"
+      body: "*"
+    };
+  }
+  
+  // GetBackfillStatus retrieves the status of a backfill operation
+  rpc GetBackfillStatus(BackfillStatusRequest) returns (BackfillStatusResponse) {
+    option (google.api.http) = {
+      get: "/backfiller/v1/status/{request_id}"
+    };
+  }
+  
+  // StreamBackfillStatus streams the status of a backfill operation in real-time
+  rpc StreamBackfillStatus(BackfillStatusRequest) returns (stream BackfillStatusResponse) {
+    option (google.api.http) = {
+      get: "/backfiller/v1/stream-status/{request_id}"
+    };
+  }
+}