Skip to content

Commit 260a398

Browse files
author
colinlyguo
committed
address comments
1 parent a843f55 commit 260a398

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

rollup/internal/controller/sender/sender.go

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -655,8 +655,9 @@ func (s *Sender) checkPendingTransaction() {
655655
if updateErr := s.pendingTransactionOrm.UpdateTransactionStatusByTxHash(s.ctx, originalTx.Hash(), types.TxStatusConfirmedFailed, dbTX); updateErr != nil {
656656
return fmt.Errorf("failed to update original transaction status, hash: %s, err: %w", originalTx.Hash().Hex(), updateErr)
657657
}
658-
if updateErr := s.pendingTransactionOrm.DeleteTransactionByTxHash(s.ctx, newSignedTx.Hash(), dbTX); updateErr != nil {
659-
return fmt.Errorf("failed to delete replacement transaction, hash: %s, err: %w", newSignedTx.Hash().Hex(), updateErr)
658+
// Mark the replacement transaction as failed
659+
if updateErr := s.pendingTransactionOrm.UpdateTransactionStatusByTxHash(s.ctx, newSignedTx.Hash(), types.TxStatusConfirmedFailed, dbTX); updateErr != nil {
660+
return fmt.Errorf("failed to update replacement transaction status, hash: %s, err: %w", newSignedTx.Hash().Hex(), updateErr)
660661
}
661662
return nil
662663
}); dbErr != nil {

0 commit comments

Comments
 (0)