chore(rpc): broadcasttx timeout 1s

dashpay · Jan 16, 2024 · 68a9a7a · 68a9a7a
1 parent 96d9aa3
commit 68a9a7a
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/internal/rpc/core/mempool.go b/internal/rpc/core/mempool.go
@@ -37,6 +37,9 @@ func (env *Environment) BroadcastTxSync(ctx context.Context, req *coretypes.Requ
 // DeliverTx result.
 // More: https://docs.tendermint.com/master/rpc/#/Tx/broadcast_tx_sync
 func (env *Environment) BroadcastTx(ctx context.Context, req *coretypes.RequestBroadcastTx) (*coretypes.ResultBroadcastTx, error) {
+	ctx, cancel := context.WithTimeout(ctx, 1*time.Second)
+	defer cancel()
+
 	resCh := make(chan *abci.ResponseCheckTx, 1)
 	err := env.Mempool.CheckTx(
 		ctx,