[Indexer-Grpc-V2] Add proto for filters. (#15851)

ecosystem/indexer-grpc/indexer-grpc-data-service-v2/src/live_data_service/data_client.rs

@@ -22,12 +22,13 @@ impl DataClient {
             starting_version: Some(starting_version),
             transactions_count: None,
             batch_size: None,
+            transaction_filter: None,
         };
         loop {
             let mut client = self
                 .connection_manager
                 .get_grpc_manager_client_for_request();
-            let response = client.get_transactions(request).await;
+            let response = client.get_transactions(request.clone()).await;
             if let Ok(response) = response {
                 return response.into_inner().transactions;
             }

ecosystem/indexer-grpc/indexer-grpc-data-service-v2/src/service.rs

@@ -48,13 +48,13 @@ impl DataService for DataServiceWrapperWrapper {
             if let Some(historical_data_service) = self.historical_data_service.as_ref() {
                 let request = req.into_inner();
                 let mut stream = live_data_service
-                    .get_transactions(Request::new(request))
+                    .get_transactions(Request::new(request.clone()))
                     .await?
                     .into_inner();
                 let peekable = std::pin::pin!(stream.as_mut().peekable());
                 if let Some(Ok(_)) = peekable.peek().await {
                     return live_data_service
-                        .get_transactions(Request::new(request))
+                        .get_transactions(Request::new(request.clone()))
                         .await;
                 }
 

protos/proto/aptos/indexer/v1/filter.proto

@@ -0,0 +1,63 @@
+// Copyright © Aptos Foundation
+// SPDX-License-Identifier: Apache-2.0
+
+syntax = "proto3";
+
+package aptos.indexer.v1;
+
+import "aptos/transaction/v1/transaction.proto";
+
+message LogicalAndFilters {
+  repeated BooleanTransactionFilter filters = 1;
+}
+
+message LogicalOrFilters {
+  repeated BooleanTransactionFilter filters = 1;
+}
+
+message TransactionRootFilter {
+  optional bool success = 1;
+  optional aptos.transaction.v1.Transaction.TransactionType transaction_type = 2;
+}
+
+message EntryFunctionFilter {
+  optional string address = 1;
+  optional string module_name  = 2;
+  optional string function = 3;
+}
+
+message UserTransactionPayloadFilter {
+  optional EntryFunctionFilter entry_function_filter = 1;
+}
+
+message UserTransactionFilter {
+  optional string sender = 1;
+  optional UserTransactionPayloadFilter payload_filter = 2;
+}
+
+
+message MoveStructTagFilter {
+  optional string address = 1;
+  optional string module = 2;
+  optional string name = 3;
+}
+
+message EventFilter {
+  optional MoveStructTagFilter struct_type = 1;
+  optional string data_substring_filter = 2;
+}
+
+message APIFilter {
+  optional TransactionRootFilter transaction_root_filter = 1;
+  optional UserTransactionFilter user_transaction_filter = 2;
+  optional EventFilter event_filter = 3;
+}
+
+message BooleanTransactionFilter {
+  oneof filter {
+      APIFilter api_filter = 1;
+      LogicalAndFilters logical_and = 2;
+      LogicalOrFilters logical_or = 3;
+      BooleanTransactionFilter logical_not = 4;
+  }
+}

protos/proto/aptos/indexer/v1/raw_data.proto

@@ -5,6 +5,7 @@ syntax = "proto3";
 
 package aptos.indexer.v1;
 
+import "aptos/indexer/v1/filter.proto";
 import "aptos/transaction/v1/transaction.proto";
 
 // This is for storage only.
@@ -26,6 +27,9 @@ message GetTransactionsRequest {
   // Optional; number of transactions in each `TransactionsResponse` for current stream.
   // If not present, default to 1000. If larger than 1000, request will be rejected.
   optional uint64 batch_size = 3;
+
+  // If provided, only transactions that match the filter will be included.
+  optional BooleanTransactionFilter transaction_filter = 4;
 }
 
 // TransactionsResponse is a batch of transactions.

protos/python/aptos_protos/aptos/indexer/v1/raw_data_pb2.pyi

@@ -4,6 +4,7 @@ from typing import Mapping as _Mapping
 from typing import Optional as _Optional
 from typing import Union as _Union
 
+from aptos.indexer.v1 import filter_pb2 as _filter_pb2
 from aptos.transaction.v1 import transaction_pb2 as _transaction_pb2
 from google.protobuf import descriptor as _descriptor
 from google.protobuf import message as _message
@@ -28,18 +29,28 @@ class TransactionsInStorage(_message.Message):
     ) -> None: ...
 
 class GetTransactionsRequest(_message.Message):
-    __slots__ = ["starting_version", "transactions_count", "batch_size"]
+    __slots__ = [
+        "starting_version",
+        "transactions_count",
+        "batch_size",
+        "transaction_filter",
+    ]
     STARTING_VERSION_FIELD_NUMBER: _ClassVar[int]
     TRANSACTIONS_COUNT_FIELD_NUMBER: _ClassVar[int]
     BATCH_SIZE_FIELD_NUMBER: _ClassVar[int]
+    TRANSACTION_FILTER_FIELD_NUMBER: _ClassVar[int]
     starting_version: int
     transactions_count: int
     batch_size: int
+    transaction_filter: _filter_pb2.BooleanTransactionFilter
     def __init__(
         self,
         starting_version: _Optional[int] = ...,
         transactions_count: _Optional[int] = ...,
         batch_size: _Optional[int] = ...,
+        transaction_filter: _Optional[
+            _Union[_filter_pb2.BooleanTransactionFilter, _Mapping]
+        ] = ...,
     ) -> None: ...
 
 class TransactionsResponse(_message.Message):