broadcast.go

package tx

import (
	"net/http"

	"github.com/cosmos/cosmos-sdk/client/rest"

	"io/ioutil"

	"github.com/cosmos/cosmos-sdk/client/context"
	"github.com/cosmos/cosmos-sdk/codec"
)

const (
	// Returns with the response from CheckTx.
	flagSync = "sync"
	// Returns right away, with no response
	flagAsync = "async"
	// Only returns error if mempool.BroadcastTx errs (ie. problem with the app) or if we timeout waiting for tx to commit.
	flagBlock = "block"
)

// BroadcastBody Tx Broadcast Body
type BroadcastBody struct {
	TxBytes []byte `json:"tx"`
	Return  string `json:"return"`
}

// BroadcastTxRequest REST Handler
// nolint: gocyclo
func BroadcastTxRequest(cliCtx context.CLIContext, cdc *codec.Codec) http.HandlerFunc {
	return func(w http.ResponseWriter, r *http.Request) {
		var m BroadcastBody
		body, err := ioutil.ReadAll(r.Body)
		if err != nil {
			rest.WriteErrorResponse(w, http.StatusBadRequest, err.Error())
			return
		}
		err = cdc.UnmarshalJSON(body, &m)
		if err != nil {
			rest.WriteErrorResponse(w, http.StatusBadRequest, err.Error())
			return
		}
		var res interface{}
		switch m.Return {
		case flagBlock:
			res, err = cliCtx.BroadcastTx(m.TxBytes)
		case flagSync:
			res, err = cliCtx.BroadcastTxSync(m.TxBytes)
		case flagAsync:
			res, err = cliCtx.BroadcastTxAsync(m.TxBytes)
		default:
			rest.WriteErrorResponse(w, http.StatusInternalServerError, "unsupported return type. supported types: block, sync, async")
			return
		}
		if err != nil {
			rest.WriteErrorResponse(w, http.StatusInternalServerError, err.Error())
			return
		}
		rest.PostProcessResponse(w, cdc, res, cliCtx.Indent)
	}
}