9 log "github.com/sirupsen/logrus"
11 "github.com/vapor/account"
12 "github.com/vapor/blockchain/txbuilder"
13 "github.com/vapor/errors"
14 "github.com/vapor/net/http/reqid"
15 "github.com/vapor/protocol/bc"
16 "github.com/vapor/protocol/bc/types"
20 defaultTxTTL = 30 * time.Minute
21 defaultBaseRate = float64(100000)
24 func (a *API) actionDecoder(action string) (func([]byte) (txbuilder.Action, error), bool) {
25 decoders := map[string]func([]byte) (txbuilder.Action, error){
26 "control_address": txbuilder.DecodeControlAddressAction,
27 "control_program": txbuilder.DecodeControlProgramAction,
28 "retire": txbuilder.DecodeRetireAction,
29 "spend_account": a.wallet.AccountMgr.DecodeSpendAction,
30 "spend_account_unspent_output": a.wallet.AccountMgr.DecodeSpendUTXOAction,
32 decoder, ok := decoders[action]
36 func onlyHaveInputActions(req *BuildRequest) (bool, error) {
38 for i, act := range req.Actions {
39 actionType, ok := act["type"].(string)
41 return false, errors.WithDetailf(ErrBadActionType, "no action type provided on action %d", i)
44 if strings.HasPrefix(actionType, "spend") || actionType == "issue" {
49 return count == len(req.Actions), nil
52 func (a *API) buildSingle(ctx context.Context, req *BuildRequest) (*txbuilder.Template, error) {
53 if err := a.checkRequestValidity(ctx, req); err != nil {
56 actions, err := a.mergeSpendActions(req)
61 maxTime := time.Now().Add(req.TTL.Duration)
62 tpl, err := txbuilder.Build(ctx, req.Tx, actions, maxTime, req.TimeRange)
63 if errors.Root(err) == txbuilder.ErrAction {
64 // append each of the inner errors contained in the data.
67 for i, innerErr := range errors.Data(err)["actions"].([]error) {
69 rootErr = errors.Root(innerErr)
71 Errs = Errs + innerErr.Error()
73 err = errors.WithDetail(rootErr, Errs)
79 // ensure null is never returned for signing instructions
80 if tpl.SigningInstructions == nil {
81 tpl.SigningInstructions = []*txbuilder.SigningInstruction{}
86 // POST /build-transaction
87 func (a *API) build(ctx context.Context, buildReqs *BuildRequest) Response {
88 subctx := reqid.NewSubContext(ctx, reqid.New())
89 tmpl, err := a.buildSingle(subctx, buildReqs)
91 return NewErrorResponse(err)
94 return NewSuccessResponse(tmpl)
96 func (a *API) checkRequestValidity(ctx context.Context, req *BuildRequest) error {
97 if err := a.completeMissingIDs(ctx, req); err != nil {
101 if req.TTL.Duration == 0 {
102 req.TTL.Duration = defaultTxTTL
105 if ok, err := onlyHaveInputActions(req); err != nil {
108 return errors.WithDetail(ErrBadActionConstruction, "transaction contains only input actions and no output actions")
113 func (a *API) mergeSpendActions(req *BuildRequest) ([]txbuilder.Action, error) {
114 actions := make([]txbuilder.Action, 0, len(req.Actions))
115 for i, act := range req.Actions {
116 typ, ok := act["type"].(string)
118 return nil, errors.WithDetailf(ErrBadActionType, "no action type provided on action %d", i)
120 decoder, ok := a.actionDecoder(typ)
122 return nil, errors.WithDetailf(ErrBadActionType, "unknown action type %q on action %d", typ, i)
125 // Remarshal to JSON, the action may have been modified when we
127 b, err := json.Marshal(act)
131 action, err := decoder(b)
133 return nil, errors.WithDetailf(ErrBadAction, "%s on action %d", err.Error(), i)
135 actions = append(actions, action)
137 actions = account.MergeSpendAction(actions)
141 func (a *API) buildTxs(ctx context.Context, req *BuildRequest) ([]*txbuilder.Template, error) {
142 if err := a.checkRequestValidity(ctx, req); err != nil {
145 actions, err := a.mergeSpendActions(req)
150 builder := txbuilder.NewBuilder(time.Now().Add(req.TTL.Duration))
151 tpls := []*txbuilder.Template{}
152 for _, action := range actions {
153 if action.ActionType() == "spend_account" {
154 tpls, err = account.SpendAccountChain(ctx, builder, action)
156 err = action.Build(ctx, builder)
165 tpl, _, err := builder.Build()
171 tpls = append(tpls, tpl)
175 // POST /build-chain-transactions
176 func (a *API) buildChainTxs(ctx context.Context, buildReqs *BuildRequest) Response {
177 subctx := reqid.NewSubContext(ctx, reqid.New())
178 tmpls, err := a.buildTxs(subctx, buildReqs)
180 return NewErrorResponse(err)
182 return NewSuccessResponse(tmpls)
185 type submitTxResp struct {
186 TxID *bc.Hash `json:"tx_id"`
189 // POST /submit-transaction
190 func (a *API) submit(ctx context.Context, ins struct {
191 Tx types.Tx `json:"raw_transaction"`
193 if err := txbuilder.FinalizeTx(ctx, a.chain, &ins.Tx); err != nil {
194 return NewErrorResponse(err)
197 log.WithField("tx_id", ins.Tx.ID.String()).Info("submit single tx")
198 return NewSuccessResponse(&submitTxResp{TxID: &ins.Tx.ID})
201 type submitTxsResp struct {
202 TxID []*bc.Hash `json:"tx_id"`
205 // POST /submit-transactions
206 func (a *API) submitTxs(ctx context.Context, ins struct {
207 Tx []types.Tx `json:"raw_transactions"`
209 txHashs := []*bc.Hash{}
210 for i := range ins.Tx {
211 if err := txbuilder.FinalizeTx(ctx, a.chain, &ins.Tx[i]); err != nil {
212 return NewErrorResponse(err)
214 log.WithField("tx_id", ins.Tx[i].ID.String()).Info("submit single tx")
215 txHashs = append(txHashs, &ins.Tx[i].ID)
217 return NewSuccessResponse(&submitTxsResp{TxID: txHashs})
220 // POST /estimate-transaction-gas
221 func (a *API) estimateTxGas(ctx context.Context, in struct {
222 TxTemplate txbuilder.Template `json:"transaction_template"`
224 txGasResp, err := txbuilder.EstimateTxGas(in.TxTemplate)
226 return NewErrorResponse(err)
228 return NewSuccessResponse(txGasResp)