Add tx broadcast gRPC endpoint

proto/cosmos/tx/v1beta1/service.proto

@@ -4,25 +4,29 @@ package cosmos.tx.v1beta1;
 import "google/api/annotations.proto";
 import "cosmos/base/abci/v1beta1/abci.proto";
 import "cosmos/tx/v1beta1/tx.proto";
+import "gogoproto/gogo.proto";
 import "cosmos/base/query/v1beta1/pagination.proto";
 
 option go_package = "github.com/cosmos/cosmos-sdk/types/tx";
 
 // Service defines a gRPC service for interacting with transactions.
 service Service {
-  // Simulate simulates executing a transaction for estimating gas usage.
-  rpc Simulate(SimulateRequest) returns (SimulateResponse) {
-    option (google.api.http).post = "/cosmos/tx/v1beta1/simulate";
-  }
-  // GetTx fetches a tx by hash.
-  rpc GetTx(GetTxRequest) returns (GetTxResponse) {
-    option (google.api.http).get = "/cosmos/tx/v1beta1/tx/{hash}";
-  }
-
-  // GetTxsEvent fetches txs by event.
-  rpc GetTxsEvent(GetTxsEventRequest) returns (GetTxsEventResponse) {
-    option (google.api.http).get = "/cosmos/tx/v1beta1/txs";
-  }
+    // Simulate simulates executing a transaction for estimating gas usage.
+    rpc Simulate(SimulateRequest) returns (SimulateResponse) {
+        option (google.api.http).post = "/cosmos/tx/v1beta1/simulate";
+    }
+    // GetTx fetches a tx by hash.
+    rpc GetTx(GetTxRequest) returns (GetTxResponse) {
+        option (google.api.http).get = "/cosmos/tx/v1beta1/tx/{hash}";
+    }
+    // BroadcastTx broadcast transaction.
+    rpc BroadcastTx(BroadcastTxRequest) returns (BroadcastTxResponse) {
+            option (google.api.http).post = "/cosmos/tx/v1beta1/txs";
+    }
+    // GetTxsEvent fetches txs by event.
+    rpc GetTxsEvent(GetTxsEventRequest) returns (GetTxsEventResponse) {
+        option (google.api.http).get = "/cosmos/tx/v1beta1/txs";
+    }
 }
 
 // GetTxsEventRequest is the request type for the Service.TxsByEvents
@@ -45,6 +49,39 @@ message GetTxsEventResponse {
   cosmos.base.query.v1beta1.PageResponse pagination = 3;
 }
 
+// BroadcastTxRequest is the request type for the Service.BroadcastTxRequest
+// RPC method.
+message BroadcastTxRequest {
+    // tx is the list of queried transactions.
+    bytes tx = 1;
+    BroadcastMode mode = 2;
+}
+
+// BroadcastMode specifies the broadcast mode for the TxService.Broadcast RPC method.
+enum BroadcastMode {
+    // zero-value for mode ordering
+    BROADCAST_MODE_UNSPECIFIED = 0 [(gogoproto.enumvalue_customname) = "none"];
+    // BROADCAST_MODE_BLOCK defines a tx broadcasting mode where the client waits for
+    // the tx to be committed in a block.
+    BROADCAST_MODE_BLOCK = 1 [(gogoproto.enumvalue_customname) = "block"];
+    // BROADCAST_MODE_SYNC defines a tx broadcasting mode where the client waits for
+    // a CheckTx execution response only.
+    BROADCAST_MODE_SYNC = 2 [(gogoproto.enumvalue_customname) = "sync"];
+    // BROADCAST_MODE_ASYNC defines a tx broadcasting mode where the client returns
+    // immediately.
+    BROADCAST_MODE_ASYNC = 3 [(gogoproto.enumvalue_customname) = "async"];
+}
+
+// BroadcastTxResponse is the response type for the
+// Service.BroadcastTx method.
+message BroadcastTxResponse {
+    // tx is the queried transaction.
+    cosmos.tx.v1beta1.Tx tx = 1;
+    // tx_response is the queried TxResponses.
+    cosmos.base.abci.v1beta1.TxResponse tx_response = 2;
+}
+
+
 // SimulateRequest is the request type for the Service.Simulate
 // RPC method.
 message SimulateRequest {