Method processPendingTxs

cmd/cql-eth-exchange/exchange.go:444–530

()

}

func (e *Exchange) processPendingTxs() {
	var (
		records []*TxRecord
		err     error
	)

	lastAvailBlock := atomic.LoadUint64(&e.currentBlock) - e.cfg.DelayBlockCount
	records, err = GetToProcessTx(e.metaDatabase, lastAvailBlock)
	if err != nil {
		return
	}

	// get current balance
	var balance uint64
	balance, err = e.getAccountBalance()
	if err != nil {
		return
	}

	// get current nonce
	var nonce cinter.AccountNonce
	nonce, err = e.getAccountNonce()
	if err != nil {
		return
	}

	for _, r := range records {
		if r.CQLAmount > balance {
			// skip this tx, account
			_ = AddAuditRecord(e.metaDatabase, &AuditRecord{
				Hash: r.Hash,
				Op:   "check_balance",
				Data: map[string]interface{}{
					"required": r.CQLAmount,
					"balance":  balance,
				},
			})
			continue
		}

		// send request and update state
		// parse cql account
		var target proto.AccountAddress
		err = hash.Decode((*hash.Hash)(&target), r.CQLAccount)
		if err != nil {
			_ = AddAuditRecord(e.metaDatabase, &AuditRecord{
				Hash: r.Hash,
				Op:   "invalid_target_account",
				Data: map[string]interface{}{
					"account": r.CQLAccount,
				},
			})
		}

		var txHash hash.Hash
		txHash, err = e.transferToken(target, nonce, r.CQLAmount)
		_ = AddAuditRecord(e.metaDatabase, &AuditRecord{
			Hash: r.Hash,