Function GetToProcessTx

cmd/cql-eth-exchange/tx_record.go:227–231

GetToProcessTx fetches unprocessed transactions begin before confirmed block number.

(db *gorp.DbMap, confirmedBlkNumber uint64)

// GetToProcessTx fetches unprocessed transactions begin before confirmed block number.
func GetToProcessTx(db *gorp.DbMap, confirmedBlkNumber uint64) (records []*TxRecord, err error) {
	_, err = db.Select(&records, `SELECT * FROM "record" WHERE "eth_block_number" <= ? AND "state" = ?`,
		confirmedBlkNumber, ExchangeStateDetected)
	return
}

// GetTransferringTx returns the transactions in transferring state.
func GetTransferringTx(db *gorp.DbMap) (records []*TxRecord, err error) {