log

Author: yashnevatia

chains/txmgr/broadcaster.go

@@ -407,6 +407,11 @@ func (eb *Broadcaster[CID, HEAD, ADDR, THASH, BHASH, SEQ, FEE]) handleUnstartedT
 		return fmt.Errorf("invariant violation: expected transaction %v to be unstarted, it was %s", etx.ID, etx.State), false
 	}
 
+	eb.lggr.Infow("DEBUG handleUnstartedTx loaded from DB",
+		"txID", etx.ID,
+		"maxGasPrice", etx.MaxGasPrice,
+		"maxGasPriceIsNil", etx.MaxGasPrice == nil)
+
 	attempt, _, _, retryable, err := eb.NewTxAttempt(ctx, *etx, eb.lggr)
 	// Mark transaction as fatal if provided gas limit is set too low
 	if errors.Is(err, fees.ErrFeeLimitTooLow) {

chains/txmgr/txmgr.go

@@ -538,6 +538,11 @@ func (b *Txm[CID, HEAD, ADDR, THASH, BHASH, R, SEQ, FEE]) Trigger(addr ADDR) {
 
 // CreateTransaction inserts a new transaction
 func (b *Txm[CID, HEAD, ADDR, THASH, BHASH, R, SEQ, FEE]) CreateTransaction(ctx context.Context, txRequest txmgrtypes.TxRequest[ADDR, THASH]) (tx txmgrtypes.Tx[CID, ADDR, THASH, BHASH, SEQ, FEE], err error) {
+	b.logger.Infow("DEBUG CreateTransaction entry",
+		"txRequest.MaxGasPrice", txRequest.MaxGasPrice,
+		"maxGasPriceIsNil", txRequest.MaxGasPrice == nil,
+		"idempotencyKey", txRequest.IdempotencyKey)
+
 	// Check for existing Tx with IdempotencyKey. If found, return the Tx and do nothing
 	// Skipping CreateTransaction to avoid double send
 	if b.txmv2wrapper != nil && txRequest.Meta != nil && txRequest.Meta.DualBroadcast != nil && *txRequest.Meta.DualBroadcast {
@@ -903,10 +908,20 @@ func (b *Txm[CID, HEAD, ADDR, THASH, BHASH, R, SEQ, FEE]) pruneQueueAndCreateTxn
 		)
 	}
 
+	b.logger.Infow("DEBUG pruneQueueAndCreateTxn BEFORE CreateTransaction",
+		"txRequest.MaxGasPrice", txRequest.MaxGasPrice,
+		"maxGasPriceIsNil", txRequest.MaxGasPrice == nil)
+
 	tx, err = b.txStore.CreateTransaction(ctx, txRequest, chainID)
 	if err != nil {
 		return tx, err
 	}
+
+	b.logger.Infow("DEBUG pruneQueueAndCreateTxn AFTER CreateTransaction",
+		"tx.ID", tx.ID,
+		"tx.MaxGasPrice", tx.MaxGasPrice,
+		"maxGasPriceIsNil", tx.MaxGasPrice == nil)
+
 	b.logger.Debugw("Created transaction",
 		"fromAddress", txRequest.FromAddress,
 		"toAddress", txRequest.ToAddress,