diff --git a/common/txmgr/confirmer.go b/common/txmgr/confirmer.go index 184deacd6b4..ef78998d4d2 100644 --- a/common/txmgr/confirmer.go +++ b/common/txmgr/confirmer.go @@ -167,7 +167,7 @@ func NewConfirmer[ lggr: lggr, client: client, TxAttemptBuilder: txAttemptBuilder, - tracker: NewTracker[CHAIN_ID, ADDR, TX_HASH, BLOCK_HASH, R, SEQ, FEE]( + abandonedTracker: NewTracker[CHAIN_ID, ADDR, TX_HASH, BLOCK_HASH, R, SEQ, FEE]( &txStore, lggr), resumeCallback: nil, chainConfig: chainConfig, diff --git a/common/txmgr/tracker.go b/common/txmgr/tracker.go index 6b26c915b46..4ba4f52a8fb 100644 --- a/common/txmgr/tracker.go +++ b/common/txmgr/tracker.go @@ -129,6 +129,7 @@ func (tracker *Tracker[CHAIN_ID, ADDR, TX_HASH, BLOCK_HASH, R, SEQ, FEE]) finali ctx context.Context, atx AbandonedTx[CHAIN_ID, ADDR, TX_HASH, BLOCK_HASH, SEQ, FEE]) bool { switch atx.tx.State { case TxConfirmed, TxConfirmedMissingReceipt, TxFatalError: + // TODO: Query db again to see if this was updated? return true case TxInProgress: if time.Now().After(atx.fatalTime) {