Merge pull request #1398 from AndriiDiachuk/AndriiDiachuk/4754-add-en…

…dpoints-to-execution-nodes-to-suppport-tx-result-err-msgs
onflow · Nov 17, 2023 · 19ae56e · 19ae56e
2 parents 5baffff + ed39603
commit 19ae56e
Show file tree

Hide file tree

Showing 4 changed files with 486 additions and 90 deletions.
diff --git a/protobuf/flow/execution/execution.proto b/protobuf/flow/execution/execution.proto
@@ -41,15 +41,28 @@ service ExecutionAPI {
   rpc GetTransactionResult(GetTransactionResultRequest)
       returns (GetTransactionResultResponse);
 
-  // GetTransactionResultByIndex gets the result of a transaction at the index .
+  // GetTransactionResultByIndex gets the result of a transaction at the index.
   rpc GetTransactionResultByIndex(GetTransactionByIndexRequest)
       returns (GetTransactionResultResponse);
 
   // GetTransactionResultByIndex gets the results of all transactions in the
-  // block ordered by transaction index
+  // block ordered by transaction index.
   rpc GetTransactionResultsByBlockID(GetTransactionsByBlockIDRequest)
       returns (GetTransactionResultsResponse);
 
+  // GetTransactionErrorMessage gets the error messages of a failed transaction by id.
+  rpc GetTransactionErrorMessage(GetTransactionErrorMessageRequest)
+    returns (GetTransactionErrorMessagesResponse);
+
+  // GetTransactionErrorMessageByIndex gets the error messages of a failed transaction at the index.
+  rpc GetTransactionErrorMessageByIndex(GetTransactionErrorMessageByIndexRequest)
+    returns (GetTransactionErrorMessagesResponse);
+
+  // GetTransactionErrorMessagesByBlockID gets the error messages of all failed transactions in the
+  // block ordered by transaction index.
+  rpc GetTransactionErrorMessagesByBlockID(GetTransactionErrorMessagesByBlockIDRequest)
+    returns (GetTransactionErrorMessagesResponse);
+
   // Registers
 
   // GetRegisterAtBlockID collects a register at the block with the given ID (if
@@ -141,6 +154,29 @@ message GetTransactionResultsResponse {
   entities.EventEncodingVersion event_encoding_version = 2;
 }
 
+message GetTransactionErrorMessageRequest {
+  bytes block_id = 1;
+  bytes transaction_id = 2;
+}
+
+message GetTransactionErrorMessageByIndexRequest {
+  bytes block_id = 1;
+  uint32 index = 2;
+}
+
+message GetTransactionErrorMessagesByBlockIDRequest {
+  bytes block_id = 1;
+}
+
+message GetTransactionErrorMessagesResponse {
+  message Result {
+    bytes transaction_id = 1;
+    uint32 index = 2;
+    string error_message = 3;
+  }
+  repeated Result results = 1;
+}
+
 // Registers
 
 message GetRegisterAtBlockIDRequest {