From 80a117a9ec51144ef818d0be5d83350d6999a354 Mon Sep 17 00:00:00 2001 From: Julien Harbulot Date: Thu, 30 Oct 2025 11:06:32 +0400 Subject: [PATCH] Promote our debug logs to info --- eth/api_backend.go | 40 ++++++++++++++++++------------------ eth/api_userops.go | 2 +- eth/ssv_mailbox_processor.go | 8 ++++---- eth/tracers/native/ssv.go | 10 ++++----- miner/worker.go | 4 ++-- 5 files changed, 32 insertions(+), 32 deletions(-) diff --git a/eth/api_backend.go b/eth/api_backend.go index af1b241871..3306897ea2 100644 --- a/eth/api_backend.go +++ b/eth/api_backend.go @@ -534,7 +534,7 @@ func (b *EthAPIBackend) sendTx(ctx context.Context, signedTx *types.Transaction) } } b.sequencerTxMutex.RUnlock() - log.Debug("[SSV] Tracked local tx for resubmission", + log.Info("[SSV] Tracked local tx for resubmission", "txHash", signedTx.Hash().Hex(), "from", from.Hex(), "nonce", signedTx.Nonce(), @@ -587,7 +587,7 @@ func (b *EthAPIBackend) TxIndexDone() bool { func (b *EthAPIBackend) GetPoolNonce(ctx context.Context, addr common.Address) (uint64, error) { nonce := b.eth.txPool.PoolNonce(addr) pend, queued := b.eth.txPool.ContentFrom(addr) - log.Debug("[SSV] GetPoolNonce snapshot", + log.Info("[SSV] GetPoolNonce snapshot", "addr", addr.Hex(), "nonce", nonce, "pending_count", len(pend), @@ -886,7 +886,7 @@ func (b *EthAPIBackend) SimulateTransaction( if wants := staged.Nonce(); stateDB.GetNonce(stageMsg.From) != wants { prev := stateDB.GetNonce(stageMsg.From) stateDB.SetNonce(stageMsg.From, wants, tracing.NonceChangeUnspecified) - log.Debug("[SSV] Pre-apply putInbox adjusted nonce in simulation", + log.Info("[SSV] Pre-apply putInbox adjusted nonce in simulation", "from", stageMsg.From.Hex(), "prev", prev, "wants", wants, @@ -922,7 +922,7 @@ func (b *EthAPIBackend) SimulateTransaction( if wants := staged.Nonce(); stateDB.GetNonce(stageMsg.From) != wants { prev := stateDB.GetNonce(stageMsg.From) stateDB.SetNonce(stageMsg.From, wants, tracing.NonceChangeUnspecified) - log.Debug("[SSV] Pre-apply original adjusted nonce in simulation", + log.Info("[SSV] Pre-apply original adjusted nonce in simulation", "from", stageMsg.From.Hex(), "prev", prev, "wants", wants, @@ -1204,7 +1204,7 @@ func (b *EthAPIBackend) clearAllSequencerTransactions() { for _, hash := range txHashesToReject { if tx := b.eth.txPool.Get(hash); tx != nil { tx.SetRejected() - log.Debug("[SSV] Marked cleared tx as rejected in txpool", + log.Info("[SSV] Marked cleared tx as rejected in txpool", "txHash", hash.Hex()) } } @@ -1277,7 +1277,7 @@ func (b *EthAPIBackend) GetOrderedTransactionsForBlock(ctx context.Context) (typ from = s } } - log.Debug("[SSV] Block order", + log.Info("[SSV] Block order", "idx", i, "kind", kind, "from", from.Hex(), @@ -1287,7 +1287,7 @@ func (b *EthAPIBackend) GetOrderedTransactionsForBlock(ctx context.Context) (typ ) } b.sequencerTxMutex.RUnlock() - log.Debug("[SSV] GetOrderedTransactionsForBlock", + log.Info("[SSV] GetOrderedTransactionsForBlock", "total", len(txs), "putInbox", putCount, "original", origCount, @@ -1352,7 +1352,7 @@ func (b *EthAPIBackend) validateSequencerTransaction(tx *types.Transaction) erro log.Warn("[SSV] Sequencer transaction has high gas limit", "gas", tx.Gas()) } - log.Debug("[SSV] Sequencer transaction validated", + log.Info("[SSV] Sequencer transaction validated", "txHash", tx.Hash().Hex(), "to", tx.To().Hex(), "gas", tx.Gas(), @@ -1372,7 +1372,7 @@ func (b *EthAPIBackend) OnBlockBuildingStart(ctx context.Context) error { origCount := b.countEntriesByKindLocked(sequencerTxOriginal) total := len(b.pendingXTEntries) b.sequencerTxMutex.RUnlock() - log.Debug("[SSV] OnBlockBuildingStart", + log.Info("[SSV] OnBlockBuildingStart", "slot", slot, "state", state, "staged_total", total, @@ -1435,7 +1435,7 @@ func (b *EthAPIBackend) OnBlockBuildingComplete( from = s } } - log.Debug("[SSV] Included sequencer tx", + log.Info("[SSV] Included sequencer tx", "block", block.NumberU64(), "idx", i, "hash", tx.Hash().Hex(), @@ -1478,7 +1478,7 @@ func (b *EthAPIBackend) OnBlockBuildingComplete( totalStored := len(b.pendingBlocks) b.pendingBlockMutex.Unlock() - log.Debug("[SSV] Skipping duplicate block (identical hash already stored)", + log.Info("[SSV] Skipping duplicate block (identical hash already stored)", "slot", slot, "state", currentState, "blockNumber", blockNumber, @@ -1524,7 +1524,7 @@ func (b *EthAPIBackend) clearCommittedSequencerTransactions(committed map[common for hash := range removeSet { if tx := b.eth.txPool.Get(hash); tx != nil { tx.SetRejected() - log.Debug("[SSV] Marked committed tx as rejected in txpool to prevent re-inclusion", + log.Info("[SSV] Marked committed tx as rejected in txpool to prevent re-inclusion", "txHash", hash.Hex()) } } @@ -1549,7 +1549,7 @@ func (b *EthAPIBackend) reSimulateTransaction( blockNrOrHash rpc.BlockNumberOrHash, xtID *rollupv1.XtID, ) (bool, error) { - log.Debug("[SSV] Re-simulating transaction", + log.Info("[SSV] Re-simulating transaction", "txHash", tx.Hash().Hex(), "xtID", xtID.Hex()) @@ -1592,7 +1592,7 @@ func (b *EthAPIBackend) reSimulateTransaction( return false, nil } - log.Debug("[SSV] Transaction re-simulation successful", + log.Info("[SSV] Transaction re-simulation successful", "txHash", tx.Hash().Hex(), "gasUsed", traceResult.ExecutionResult.UsedGas, "mailboxOps", len(traceResult.Operations), @@ -1611,7 +1611,7 @@ func (b *EthAPIBackend) waitForPutInboxTransactionsToBeProcessed() error { // Wait for transactions to be in txpool for _, tx := range putInboxTxs { - log.Debug("[SSV] Waiting for putInbox tx to appear in pool", "txHash", tx.Hash().Hex(), "nonce", tx.Nonce()) + log.Info("[SSV] Waiting for putInbox tx to appear in pool", "txHash", tx.Hash().Hex(), "nonce", tx.Nonce()) timeout := time.After(5 * time.Second) ticker := time.NewTicker(10 * time.Millisecond) @@ -1637,7 +1637,7 @@ func (b *EthAPIBackend) waitForPutInboxTransactionsToBeProcessed() error { matchQueued++ } } - log.Debug("[SSV] putInbox pool scan", "nonce", tx.Nonce(), "matches_pending", matchPending, "matches_queued", matchQueued) + log.Info("[SSV] putInbox pool scan", "nonce", tx.Nonce(), "matches_pending", matchPending, "matches_queued", matchQueued) if poolTx := b.GetPoolTransaction(tx.Hash()); poolTx != nil { log.Info("[SSV] found putInbox transaction in pool", "hash", tx.Hash().Hex()) @@ -1754,7 +1754,7 @@ func (b *EthAPIBackend) addSequencerEntryLocked(tx *types.Transaction, kind sequ } putCount := b.countEntriesByKindLocked(sequencerTxPutInbox) origCount := b.countEntriesByKindLocked(sequencerTxOriginal) - log.Debug("[SSV] Staged add", + log.Info("[SSV] Staged add", "idx", idx, "kind", kindStr, "from", from.Hex(), @@ -1822,7 +1822,7 @@ func (b *EthAPIBackend) removeEntriesMatchingLocked(predicate func(sequencerTxEn if entry.kind == sequencerTxPutInbox { kindStr = "putInbox" } - log.Debug("[SSV] Staged remove", + log.Info("[SSV] Staged remove", "kind", kindStr, "from", from.Hex(), "nonce", entry.tx.Nonce(), @@ -1993,7 +1993,7 @@ func (b *EthAPIBackend) NotifySlotStart(startSlot *rollupv1.StartSlot) error { b.committedTxsMutex.Lock() prevCommittedCount := len(b.committedTxHashes) if prevCommittedCount > 0 { - log.Debug("[SSV] Clearing committed tx hashes from previous slot", + log.Info("[SSV] Clearing committed tx hashes from previous slot", "slot", startSlot.Slot, "count", prevCommittedCount) } @@ -2106,7 +2106,7 @@ func (b *EthAPIBackend) NotifyRequestSeal(ctx context.Context, requestSeal *roll // NotifyStateChange notifies the miner of sequencer state changes // SSV func (b *EthAPIBackend) NotifyStateChange(from, to sequencer.State, slot uint64) error { - log.Debug("[SSV] SBCP state change", "from", from.String(), "to", to.String(), "slot", slot) + log.Info("[SSV] SBCP state change", "from", from.String(), "to", to.String(), "slot", slot) // When SCP completes (Building-Locked → Building-Free), force miner to rebuild payload // with newly added SCP transactions. Without this, the payload remains stale and diff --git a/eth/api_userops.go b/eth/api_userops.go index fb880932d3..58b602bc20 100644 --- a/eth/api_userops.go +++ b/eth/api_userops.go @@ -570,7 +570,7 @@ func (api *composeUserOpsAPI) BuildSignedUserOpsTx( stateNonce = st.GetNonce(from) } } - log.Debug("[SSV] Sequencer nonce snapshot", + log.Info("[SSV] Sequencer nonce snapshot", "addr", from.Hex(), "poolNonce", nonce, "stateNonce", stateNonce, diff --git a/eth/ssv_mailbox_processor.go b/eth/ssv_mailbox_processor.go index 115c0bb74c..dedba88a7e 100644 --- a/eth/ssv_mailbox_processor.go +++ b/eth/ssv_mailbox_processor.go @@ -191,7 +191,7 @@ func (mp *MailboxProcessor) analyzeTransaction( continue } - log.Debug("[SSV] Found mailbox operation", + log.Info("[SSV] Found mailbox operation", "index", i, "type", op.Type.String(), "address", op.Address.Hex(), @@ -202,7 +202,7 @@ func (mp *MailboxProcessor) analyzeTransaction( if (op.Type == vm.CALL || op.Type == vm.STATICCALL) && len(op.CallData) >= 4 { call, err := mp.parseMailboxCall(op.CallData) if err != nil { - log.Debug("[SSV] Failed to parse mailbox call", "error", err) + log.Info("[SSV] Failed to parse mailbox call", "error", err) continue } @@ -299,7 +299,7 @@ func (mp *MailboxProcessor) analyzeTransaction( } } } else if op.Type != vm.CALL && op.Type != vm.STATICCALL { - log.Debug("[SSV] Ignoring non-CALL/STATICCALL operation to mailbox", "type", op.Type.String(), "address", op.Address.Hex()) + log.Info("[SSV] Ignoring non-CALL/STATICCALL operation to mailbox", "type", op.Type.String(), "address", op.Address.Hex()) } } @@ -783,7 +783,7 @@ func (mp *MailboxProcessor) reSimulateForACKMessages( return nil, fmt.Errorf("backend not available for re-simulation") } - log.Debug("[SSV] Re-simulating transaction for ACK detection", "txHash", tx.Hash().Hex(), "xtID", xtID.Hex()) + log.Info("[SSV] Re-simulating transaction for ACK detection", "txHash", tx.Hash().Hex(), "xtID", xtID.Hex()) // Re-simulate the transaction against pending state (which should include putInbox transactions) blockNrOrHash := rpc.BlockNumberOrHashWithNumber(rpc.PendingBlockNumber) diff --git a/eth/tracers/native/ssv.go b/eth/tracers/native/ssv.go index 9f691b7803..0f17ec3b9f 100644 --- a/eth/tracers/native/ssv.go +++ b/eth/tracers/native/ssv.go @@ -98,13 +98,13 @@ func newSSVTracer(ctx *tracers.Context, cfg json.RawMessage, chainConfig *params } func (t *SSVTracer) OnTxStart(env *tracing.VMContext, tx *types.Transaction, from common.Address) { - log.Debug("[SSV] OnTxStart called", "txHash", tx.Hash().Hex(), "from", from.Hex()) + log.Info("[SSV] OnTxStart called", "txHash", tx.Hash().Hex(), "from", from.Hex()) t.env = env } func (t *SSVTracer) OnTxEnd(_ *types.Receipt, err error) { - log.Debug("[SSV] OnTxEnd called") + log.Info("[SSV] OnTxEnd called") if err != nil { return @@ -157,7 +157,7 @@ func decodeTransactionInput(contractABIJSON string, input []byte) { } func (t *SSVTracer) OnEnter(depth int, typ byte, from common.Address, to common.Address, input []byte, gas uint64, value *big.Int) { - log.Debug("[SSV] OnEnter called", "depth", depth, "type", vm.OpCode(typ).String(), "from", from.Hex(), "to", to.Hex(), "gas", gas, "value", value) + log.Info("[SSV] OnEnter called", "depth", depth, "type", vm.OpCode(typ).String(), "from", from.Hex(), "to", to.Hex(), "gas", gas, "value", value) if t.interrupt.Load() { return @@ -179,7 +179,7 @@ func (t *SSVTracer) OnEnter(depth int, typ byte, from common.Address, to common. Gas: gas, } - log.Debug("[SSV] Operation recorded") + log.Info("[SSV] Operation recorded") t.operations = append(t.operations, op) } } @@ -208,7 +208,7 @@ func (t *SSVTracer) OnExit(depth int, output []byte, gasUsed uint64, err error, fields = append(fields, "err", err.Error()) } - log.Debug("[SSV] OnExit", fields...) + log.Info("[SSV] OnExit", fields...) if depth == 0 { log.Info("[SSV] Root call completed", diff --git a/miner/worker.go b/miner/worker.go index e8f9cebd36..fa0387d90b 100644 --- a/miner/worker.go +++ b/miner/worker.go @@ -1062,7 +1062,7 @@ func (miner *Miner) commitAccountBasedTransactions( committed := 0 for account, txs := range accountTxs { - log.Debug("[SSV] Processing account transactions", "account", account.Hex(), "count", len(txs)) + log.Info("[SSV] Processing account transactions", "account", account.Hex(), "count", len(txs)) for _, lazy := range txs { if interrupt != nil { @@ -1093,7 +1093,7 @@ func (miner *Miner) commitAccountBasedTransactions( env.state.SetTxContext(tx.Hash(), env.tcount) if err := miner.commitTransaction(env, tx); err != nil { - log.Debug("[SSV] Transaction failed, skipping", "hash", tx.Hash(), "account", account.Hex(), "err", err) + log.Info("[SSV] Transaction failed, skipping", "hash", tx.Hash(), "account", account.Hex(), "err", err) continue }