Function InvalidateTx

cmd/cql-eth-exchange/tx_record.go:191–224

InvalidateTx invalidates eth transactions based on block number.

(db *gorp.DbMap, blkNumber uint64)

// InvalidateTx invalidates eth transactions based on block number.
func InvalidateTx(db *gorp.DbMap, blkNumber uint64) (err error) {
	var records []*TxRecord
	defer func() {
		for _, r := range records {
			_ = AddAuditRecord(db, &AuditRecord{
				Hash:  r.Hash,
				Op:    "chain_reorganize",
				Data:  blkNumber,
				Error: err.Error(),
			})
		}

		if len(records) == 0 {
			_ = AddAuditRecord(db, &AuditRecord{
				Op:    "chain_reorganize",
				Data:  blkNumber,
				Error: err.Error(),
			})
		}
	}()
	var rawTxs []interface{}
	rawTxs, err = db.Select(&records, `SELECT * FROM "record" WHERE "is_reverted" = 0 AND "eth_block_number" = ?`, blkNumber)
	if err != nil {
		return
	}

	for _, r := range records {
		r.IsReverted = 1
	}

	_, err = db.Update(rawTxs...)

	return
}

// GetToProcessTx fetches unprocessed transactions begin before confirmed block number.
func GetToProcessTx(db *gorp.DbMap, confirmedBlkNumber uint64) (records []*TxRecord, err error) {