83 lines
2.4 KiB
Go
83 lines
2.4 KiB
Go
package context
|
|
|
|
import (
|
|
"fmt"
|
|
|
|
"github.com/cosmos/cosmos-sdk/client/flags"
|
|
sdk "github.com/cosmos/cosmos-sdk/types"
|
|
)
|
|
|
|
// BroadcastTx broadcasts a transactions either synchronously or asynchronously
|
|
// based on the context parameters. The result of the broadcast is parsed into
|
|
// an intermediate structure which is logged if the context has a logger
|
|
// defined.
|
|
func (ctx CLIContext) BroadcastTx(txBytes []byte) (res sdk.TxResponse, err error) {
|
|
switch ctx.BroadcastMode {
|
|
case flags.BroadcastSync:
|
|
res, err = ctx.BroadcastTxSync(txBytes)
|
|
|
|
case flags.BroadcastAsync:
|
|
res, err = ctx.BroadcastTxAsync(txBytes)
|
|
|
|
case flags.BroadcastBlock:
|
|
res, err = ctx.BroadcastTxCommit(txBytes)
|
|
|
|
default:
|
|
return sdk.TxResponse{}, fmt.Errorf("unsupported return type %s; supported types: sync, async, block", ctx.BroadcastMode)
|
|
}
|
|
|
|
return res, err
|
|
}
|
|
|
|
// BroadcastTxCommit broadcasts transaction bytes to a Tendermint node and
|
|
// waits for a commit.
|
|
//
|
|
// NOTE: This should ideally not be used as the request may timeout but the tx
|
|
// may still be included in a block. Use BroadcastTxAsync or BroadcastTxSync
|
|
// instead.
|
|
func (ctx CLIContext) BroadcastTxCommit(txBytes []byte) (sdk.TxResponse, error) {
|
|
node, err := ctx.GetNode()
|
|
if err != nil {
|
|
return sdk.TxResponse{}, err
|
|
}
|
|
|
|
res, err := node.BroadcastTxCommit(txBytes)
|
|
if err != nil {
|
|
return sdk.NewResponseFormatBroadcastTxCommit(res), err
|
|
}
|
|
|
|
if !res.CheckTx.IsOK() {
|
|
return sdk.NewResponseFormatBroadcastTxCommit(res), fmt.Errorf(res.CheckTx.Log)
|
|
}
|
|
|
|
if !res.DeliverTx.IsOK() {
|
|
return sdk.NewResponseFormatBroadcastTxCommit(res), fmt.Errorf(res.DeliverTx.Log)
|
|
}
|
|
|
|
return sdk.NewResponseFormatBroadcastTxCommit(res), nil
|
|
}
|
|
|
|
// BroadcastTxSync broadcasts transaction bytes to a Tendermint node
|
|
// synchronously (i.e. returns after CheckTx execution).
|
|
func (ctx CLIContext) BroadcastTxSync(txBytes []byte) (sdk.TxResponse, error) {
|
|
node, err := ctx.GetNode()
|
|
if err != nil {
|
|
return sdk.TxResponse{}, err
|
|
}
|
|
|
|
res, err := node.BroadcastTxSync(txBytes)
|
|
return sdk.NewResponseFormatBroadcastTx(res), err
|
|
}
|
|
|
|
// BroadcastTxAsync broadcasts transaction bytes to a Tendermint node
|
|
// asynchronously (i.e. returns immediately).
|
|
func (ctx CLIContext) BroadcastTxAsync(txBytes []byte) (sdk.TxResponse, error) {
|
|
node, err := ctx.GetNode()
|
|
if err != nil {
|
|
return sdk.TxResponse{}, err
|
|
}
|
|
|
|
res, err := node.BroadcastTxAsync(txBytes)
|
|
return sdk.NewResponseFormatBroadcastTx(res), err
|
|
}
|