Skip to content

Commit 8480511

Browse files
authored
Merge branch 'main' into txmgr-ifaces
2 parents f725ce0 + bcbe08e commit 8480511

3 files changed

Lines changed: 5 additions & 7 deletions

File tree

chains/txmgr/broadcaster.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -472,8 +472,7 @@ func (eb *Broadcaster[CID, HEAD, ADDR, THASH, BHASH, SEQ, FEE]) handleInProgress
472472

473473
lgr := etx.GetLogger(logger.With(eb.lggr, "fee", attempt.TxFee))
474474
errType, err := eb.client.SendTransactionReturnCode(ctx, etx, attempt, lgr)
475-
lgr.Infow("Broadcasted transaction", "txAttemptID", attempt.ID, "txHash", attempt.Hash, "tracingID", etx.GetTracingID(lgr), "meta", etx.Meta, "feeLimit",
476-
attempt.ChainSpecificFeeLimit, "callerProvidedFeeLimit", etx.FeeLimit, "attempt", attempt, "etxID", etx.ID, "etx", etx, "errType", errType, "err", err)
475+
eb.lggr.Infow("Broadcasted transaction", "txHash", attempt.Hash, "tracingID", etx.GetTracingID(lgr), "attempt", attempt, "etxID", etx.ID, "etx", etx, "errType", errType, "err", err)
477476

478477
// The validation below is only applicable to Hedera because it has instant finality and a unique sequence behavior
479478
if eb.chainType == hederaChainType {

chains/txmgr/confirmer.go

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -811,11 +811,9 @@ func (ec *Confirmer[CID, HEAD, ADDR, THASH, BHASH, R, SEQ, FEE]) ForceRebroadcas
811811
attempt.Tx = *etx // for logging
812812
errType, err := ec.client.SendTransactionReturnCode(ctx, *etx, attempt, ec.lggr)
813813
if errType == multinode.Successful || errType == multinode.TransactionAlreadyKnown {
814-
ec.lggr.Infow("ForceRebroadcast: Broadcasted transaction", "txAttemptID", attempt.ID, "txHash", attempt.Hash, "tracingID", etx.GetTracingID(ec.lggr), "meta", etx.Meta, "feeLimit",
815-
attempt.ChainSpecificFeeLimit, "callerProvidedFeeLimit", etx.FeeLimit, "attempt", attempt, "etxID", etx.ID, "etx", etx, "errType", errType, "err", err)
814+
ec.lggr.Infow("ForceRebroadcast: Broadcasted transaction", "txHash", attempt.Hash, "tracingID", etx.GetTracingID(ec.lggr), "attempt", attempt, "etxID", etx.ID, "etx", etx, "errType", errType, "err", err)
816815
} else {
817-
ec.lggr.Errorw("ForceRebroadcast: Broadcasted transaction", "txAttemptID", attempt.ID, "txHash", attempt.Hash, "tracingID", etx.GetTracingID(ec.lggr), "meta", etx.Meta, "feeLimit",
818-
attempt.ChainSpecificFeeLimit, "callerProvidedFeeLimit", etx.FeeLimit, "attempt", attempt, "etxID", etx.ID, "etx", etx, "errType", errType, "err", err)
816+
ec.lggr.Errorw("ForceRebroadcast: Broadcasted transaction", "txHash", attempt.Hash, "tracingID", etx.GetTracingID(ec.lggr), "attempt", attempt, "etxID", etx.ID, "etx", etx, "errType", errType, "err", err)
819817
}
820818
}
821819
}

chains/txmgr/txmgr.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -966,11 +966,12 @@ func (b *Txm[CID, HEAD, ADDR, THASH, BHASH, R, SEQ, FEE]) pruneQueueAndCreateTxn
966966
if err != nil {
967967
return tx, err
968968
}
969-
b.logger.Debugw("Created transaction",
969+
b.logger.Infow("Created transaction",
970970
"fromAddress", txRequest.FromAddress,
971971
"toAddress", txRequest.ToAddress,
972972
"meta", txRequest.Meta,
973973
"transactionID", tx.ID,
974+
"tracingID", tx.GetTracingID(b.logger),
974975
)
975976

976977
return tx, nil

0 commit comments

Comments
 (0)