fix: need to resign resending stale txns

client/eth/client_provider.go

@@ -342,7 +342,7 @@ func (c *ChainProviderImpl) SuggestGasTipCap(ctx context.Context) (*big.Int, err
 	return nil, ErrClientNotFound
 }
 
-// FeeHistory returns the fee history for the given block count, last block, and reward percentiles.
+// FeeHistory returns fee history for the given block count, last block, and reward percentiles.
 func (c *ChainProviderImpl) FeeHistory(
 	ctx context.Context, blockCount uint64, lastBlock *big.Int,
 	rewardPercentiles []float64) (*ethereum.FeeHistory, error) {
@@ -373,8 +373,6 @@ func (c *ChainProviderImpl) TransactionByHash(
 	return nil, false, ErrClientNotFound
 }
 
-
-
 /*
 TxPoolContentFrom returns the pending and queued transactions of this address.
 Example response:

core/transactor/sender/utils.go

@@ -20,36 +20,36 @@ func BumpGas(tx *coretypes.Transaction) *coretypes.Transaction {
 	switch tx.Type() {
 	case coretypes.DynamicFeeTxType, coretypes.BlobTxType:
 		// Bump the existing gas tip cap 15% (10% is required but add a buffer to be safe).
-		bumpedGasTipCap := new(big.Int).Mul(tx.GasTipCap(), multiplier)
-		bumpedGasTipCap = new(big.Int).Quo(bumpedGasTipCap, quotient)
+		// bumpedGasTipCap := new(big.Int).Mul(tx.GasTipCap(), multiplier)
+		// bumpedGasTipCap = new(big.Int).Quo(bumpedGasTipCap, quotient)
 
 		// Bump the existing gas fee cap 15% (only 10% required but add a buffer to be safe).
-		bumpedGasFeeCap := new(big.Int).Mul(tx.GasFeeCap(), multiplier)
-		bumpedGasFeeCap = new(big.Int).Quo(bumpedGasFeeCap, quotient)
+		// bumpedGasFeeCap := new(big.Int).Mul(tx.GasFeeCap(), multiplier)
+		// bumpedGasFeeCap = new(big.Int).Quo(bumpedGasFeeCap, quotient)
 
 		if tx.Type() == coretypes.BlobTxType {
 			// Bump the existing blob gas fee cap 15%. // TODO: verify that this is correct.
 			bumpedBlobGasFeeCap := new(big.Int).Mul(tx.BlobGasFeeCap(), multiplier)
 			bumpedBlobGasFeeCap = new(big.Int).Quo(bumpedBlobGasFeeCap, quotient)
 
 			innerTx = &coretypes.BlobTx{
-				Nonce:      tx.Nonce(),
-				To:         *tx.To(),
-				Gas:        tx.Gas(),
-				Value:      uint256.MustFromBig(tx.Value()),
-				Data:       tx.Data(),
+				Nonce: tx.Nonce(),
+				To:    *tx.To(),
+				Gas:   tx.Gas(),
+				Value: uint256.MustFromBig(tx.Value()),
+				Data:  tx.Data(),
 				// GasTipCap:  uint256.MustFromBig(bumpedGasTipCap),
 				// GasFeeCap:  uint256.MustFromBig(bumpedGasFeeCap),
-				GasTipCap: nil,
-				GasFeeCap: nil,
+				GasTipCap:  nil,
+				GasFeeCap:  nil,
 				BlobFeeCap: uint256.MustFromBig(bumpedBlobGasFeeCap),
 				BlobHashes: tx.BlobHashes(),
 				Sidecar:    tx.BlobTxSidecar(),
 			}
 		} else {
 			innerTx = &coretypes.DynamicFeeTx{
-				ChainID:   tx.ChainId(),
-				Nonce:     tx.Nonce(),
+				ChainID: tx.ChainId(),
+				Nonce:   tx.Nonce(),
 				// GasTipCap: bumpedGasTipCap,
 				// GasFeeCap: bumpedGasFeeCap,
 				GasTipCap: nil,

core/transactor/transactor.go

@@ -228,7 +228,8 @@ func (t *TxrV2) resendStaleTxns(ctx context.Context, chain eth.Client) error {
 	if pendingTxs := txPoolContent["pending"]; len(pendingTxs) > 0 {
 		t.logger.Info("🔄 resending stale (pending in txpool) txs", "count", len(pendingTxs))
 		for _, tx := range pendingTxs {
-			t.fire(ctx, &tracker.Response{Transaction: sender.BumpGas(tx)}, false)
+			resp := &tracker.Response{Transaction: sender.BumpGas(tx)}
+			t.fire(ctx, resp, true, types.CallMsgFromTx(resp.Transaction))
 		}
 	}