Function ApplyTokenTask

cmd/cql-proxy/api/account.go:197–245

ApplyTokenTask handles the token apply process.

(ctx context.Context, cfg *config.Config, db *gorp.DbMap, t *model.Task)

// ApplyTokenTask handles the token apply process.
func ApplyTokenTask(ctx context.Context, cfg *config.Config, db *gorp.DbMap, t *model.Task) (r gin.H, err error) {
	args := struct {
		Amount uint64 `json:"amount"`
	}{}
	err = json.Unmarshal(t.RawArgs, &args)
	if err != nil {
		err = errors.Wrapf(err, "unmarshal task args failed")
		return
	}

	p, err := model.GetAccountByID(db, t.Developer, t.Account)
	if err != nil {
		err = errors.Wrapf(err, "get account for task failed")
		return
	}

	accountAddr, err := p.Account.Get()
	if err != nil {
		err = errors.Wrapf(err, "decode task account failed")
		return
	}

	txHash, err := client.TransferToken(accountAddr, args.Amount, types.Particle)
	if err != nil {
		err = errors.Wrapf(err, "send transfer token rpc failed")
		return
	}

	// add record
	ar, err := model.AddTokenApplyRecord(db, t.Developer, p.Account, args.Amount)
	if err != nil {
		err = errors.Wrapf(err, "record token application log failed")
		return
	}

	// wait for transaction to complete in several cycles
	timeoutCtx, cancelCtx := context.WithTimeout(ctx, 3*time.Minute)
	defer cancelCtx()

	lastState, _ := waitForTxState(timeoutCtx, txHash)
	r = gin.H{
		"id":      ar.ID,
		"account": p.Account,
		"tx":      txHash.String(),
		"state":   lastState.String(),
	}

	return
}