Clean up more loggings (#266)

* Reduce logs

* Remove one more log

Author: shenkeyao

espresso/docker/op-geth/op-geth-init.sh

@@ -34,7 +34,6 @@ if [ "$MODE" = "genesis" ]; then
       "$L1_RPC" | jq -r '.result.number')
 
     if [[ -z "$finalized_block" || "$finalized_block" == "null" ]]; then
-      echo "No finalized block yet, waiting..."
       sleep 3
       continue
     fi

espresso/streamer.go

@@ -321,7 +321,7 @@ func (s *BatchStreamer[B]) Update(ctx context.Context) error {
 		// Process the remaining batches
 		s.processRemainingBatches(ctx)
 
-		s.Log.Info("Fetching hotshot blocks", "from", start, "upTo", finish)
+		s.Log.Debug("Fetching hotshot blocks", "from", start, "upTo", finish)
 
 		// Process the new batches fetched from Espresso
 		if err := s.fetchHotShotRange(ctx, start, finish); err != nil {

op-batcher/batcher/espresso.go

@@ -274,7 +274,7 @@ func (s *espressoTransactionSubmitter) handleTransactionSubmitJobResponse() {
 		case <-s.ctx.Done():
 			return
 		case <-ticker.C:
-			log.Info("Espresso transaction submitter queue status",
+			log.Debug("Espresso transaction submitter queue status",
 				"submitJobQueue", len(s.submitJobQueue),
 				"submitRespQueue", len(s.submitRespQueue),
 				"verifyReceiptJobQueue", len(s.verifyReceiptJobQueue),
@@ -790,7 +790,7 @@ func (l *BlockLoader) reset(ctx context.Context) {
 }
 
 func (l *BlockLoader) EnqueueBlocks(ctx context.Context, blocksToQueue inclusiveBlockRange) {
-	l.batcher.Log.Info("Loading and queueing blocks", "range", blocksToQueue)
+	l.batcher.Log.Debug("Loading and queueing blocks", "range", blocksToQueue)
 	for i := blocksToQueue.start; i <= blocksToQueue.end; i++ {
 		block, err := l.batcher.fetchBlock(ctx, i)
 		if err != nil {
@@ -799,7 +799,7 @@ func (l *BlockLoader) EnqueueBlocks(ctx context.Context, blocksToQueue inclusive
 		}
 
 		for _, txn := range block.Transactions() {
-			l.batcher.Log.Info("tx hash before submitting to Espresso", "hash", txn.Hash().String())
+			l.batcher.Log.Debug("tx hash before submitting to Espresso", "hash", txn.Hash().String())
 		}
 
 		if len(l.queuedBlocks) > 0 && block.ParentHash() != l.queuedBlocks[len(l.queuedBlocks)-1].Hash {

op-batcher/batcher/sync_actions.go

@@ -98,7 +98,9 @@ func computeSyncActions[T channelStatuser](
 		s := syncActions{
 			blocksToLoad: allUnsafeBlocks,
 		}
-		m.Info("no blocks in state", "syncActions", s.TerminalString())
+		// TODO: Fix upstream compatibility for logs.
+		// <https://app.asana.com/1/1208976916964769/project/1209392461754458/task/1211175327473209?focus=true>
+		m.Debug("no blocks in state", "syncActions", s.TerminalString())
 		return s, false
 	}
 

op-node/rollup/derive/base_batch_stage.go

@@ -124,7 +124,9 @@ func (bs *baseBatchStage) updateOrigins(parent eth.L2BlockRef) {
 			// originBehind is false.
 			bs.l1Blocks = bs.l1Blocks[:0]
 		}
-		bs.log.Info("Advancing bq origin", "origin", bs.origin, "originBehind", originBehind)
+		// TODO: Fix upstream compatibility for logs.
+		// <https://app.asana.com/1/1208976916964769/project/1209392461754458/task/1211175327473209?focus=true>
+		bs.log.Debug("Advancing bq origin", "origin", bs.origin, "originBehind", originBehind)
 	}
 
 	// If the epoch is advanced, update bq.l1Blocks

op-node/rollup/driver/state.go

@@ -134,7 +134,9 @@ func (s *Driver) eventLoop() {
 			<-sequencerCh
 		}
 		delta := time.Until(nextAction)
-		s.log.Info("Scheduled sequencer action", "delta", delta)
+		// TODO: Fix upstream compatibility for logs.
+		// <https://app.asana.com/1/1208976916964769/project/1209392461754458/task/1211175327473209?focus=true>
+		s.log.Debug("Scheduled sequencer action", "delta", delta)
 		sequencerTimer.Reset(delta)
 	}
 

op-node/rollup/sequencing/sequencer.go

@@ -333,7 +333,9 @@ func (d *Sequencer) onPayloadSuccess(x engine.PayloadSuccessEvent) {
 		return
 	}
 	d.latest = BuildingState{}
-	d.log.Info("Sequencer inserted block",
+	// TODO: Fix upstream compatibility for logs.
+	// <https://app.asana.com/1/1208976916964769/project/1209392461754458/task/1211175327473209?focus=true>
+	d.log.Debug("Sequencer inserted block",
 		"block", x.Ref, "parent", x.Envelope.ExecutionPayload.ParentID())
 	// The payload was already published upon sealing.
 	// Now that we have processed it ourselves we don't need it anymore.
@@ -513,7 +515,9 @@ func (d *Sequencer) startBuildingBlock() {
 		return
 	}
 
-	d.log.Info("Started sequencing new block", "parent", l2Head, "l1Origin", l1Origin)
+	// TODO: Fix upstream compatibility for logs.
+	// <https://app.asana.com/1/1208976916964769/project/1209392461754458/task/1211175327473209?focus=true>
+	d.log.Debug("Started sequencing new block", "parent", l2Head, "l1Origin", l1Origin)
 
 	fetchCtx, cancel := context.WithTimeout(ctx, time.Second*20)
 	defer cancel()

op-node/rollup/status/status.go

@@ -115,7 +115,9 @@ func (st *StatusTracker) OnEvent(ctx context.Context, ev event.Event) bool {
 		st.metrics.RecordL1Ref("l1_safe", x.L1Safe)
 		st.data.SafeL1 = x.L1Safe
 	case finality.FinalizeL1Event:
-		st.log.Info("New L1 finalized block", "l1_finalized", x.FinalizedL1)
+		// TODO: Fix upstream compatibility for logs.
+		// <https://app.asana.com/1/1208976916964769/project/1209392461754458/task/1211175327473209?focus=true>
+		st.log.Debug("New L1 finalized block", "l1_finalized", x.FinalizedL1)
 		st.metrics.RecordL1Ref("l1_finalized", x.FinalizedL1)
 		st.data.FinalizedL1 = x.FinalizedL1
 		st.data.CurrentL1Finalized = x.FinalizedL1

op-node/rollup/sync/start.go

@@ -171,6 +171,7 @@ func FindL2Heads(ctx context.Context, cfg *rollup.Config, l1 L1Chain, l2 L2Chain
 			}
 			// TODO: Fix upstream compatibility for logs.
 			// <https://app.asana.com/1/1208976916964769/project/1209392461754458/task/1211175327473209?focus=true>
+			lgr.Debug("Walking back L1Block by hash", "curr", l1Block, "next", b, "l2block", n)
 			l1Block = b
 			ahead = false
 		} else if l1Block == (eth.L1BlockRef{}) || n.L1Origin.Hash != l1Block.Hash {
@@ -184,6 +185,7 @@ func FindL2Heads(ctx context.Context, cfg *rollup.Config, l1 L1Chain, l2 L2Chain
 			ahead = notFound
 			// TODO: Fix upstream compatibility for logs.
 			// <https://app.asana.com/1/1208976916964769/project/1209392461754458/task/1211175327473209?focus=true>
+			lgr.Debug("Walking back L1Block by number", "curr", l1Block, "next", b, "l2block", n)
 		}
 
 		lgr.Trace("walking sync start", "l2block", n)

op-proposer/proposer/driver.go

@@ -292,7 +292,9 @@ func (l *L2OutputSubmitter) FetchDGFOutput(ctx context.Context) (source.Proposal
 		return source.Proposal{}, false, nil
 	}
 
-	l.Log.Info("No proposals found for at least proposal interval, submitting proposal now", "proposalInterval", l.Cfg.ProposalInterval)
+	// TODO: Fix upstream compatibility for logs.
+	// <https://app.asana.com/1/1208976916964769/project/1209392461754458/task/1211175327473209?focus=true>
+	l.Log.Debug("No proposals found for at least proposal interval, submitting proposal now", "proposalInterval", l.Cfg.ProposalInterval)
 
 	return output, true, nil
 }
@@ -306,7 +308,6 @@ func (l *L2OutputSubmitter) FetchCurrentBlockNumber(ctx context.Context) (uint64
 	}
 
 	// Use either the finalized or safe head depending on the config. Finalized head is default & safer.
-	l.Log.Info("Proposer config for finality", "AllowNonFinalized", l.Cfg.AllowNonFinalized)
 	if l.Cfg.AllowNonFinalized {
 		return status.SafeL2, nil
 	}
@@ -375,7 +376,9 @@ func (l *L2OutputSubmitter) waitForL1Head(ctx context.Context, blockNum uint64)
 
 // sendTransaction creates & sends transactions through the underlying transaction manager.
 func (l *L2OutputSubmitter) sendTransaction(ctx context.Context, output source.Proposal) error {
-	l.Log.Info("Proposing output root", "output", output.Root, "block", output.SequenceNum)
+	// TODO: Fix upstream compatibility for logs.
+	// <https://app.asana.com/1/1208976916964769/project/1209392461754458/task/1211175327473209?focus=true>
+	l.Log.Debug("Proposing output root", "output", output.Root, "block", output.SequenceNum)
 	var receipt *types.Receipt
 	if l.Cfg.DisputeGameFactoryAddr != nil {
 		candidate, err := l.ProposeL2OutputDGFTxCandidate(ctx, output)