moved retieve loop to after sync block manager + log

block/manager.go

@@ -146,8 +146,6 @@ func (m *Manager) Start(ctx context.Context) error {
 	// Fullnode loop can start before syncing from DA
 	if !isSequencer {
 		go uevent.MustSubscribe(ctx, m.Pubsub, "applyGossipedBlocksLoop", p2p.EventQueryNewNewGossipedBlock, m.onNewGossipedBlock, m.logger)
-		go m.RetrieveLoop(ctx)
-		go m.SyncTargetLoop(ctx)
 	}
 
 	// TODO: populate the accumulatedSize on startup
@@ -159,10 +157,13 @@ func (m *Manager) Start(ctx context.Context) error {
 		return fmt.Errorf("sync block manager: %w", err)
 	}
 
-	// Aggregator producer loop is started only when finished syncing from DA
+	// Sequencer producer loop and full-node retrieve loop is started only when finished syncing from DA
 	if isSequencer {
 		go m.ProduceBlockLoop(ctx)
 		go m.SubmitLoop(ctx)
+	} else {
+		go m.RetrieveLoop(ctx)
+		go m.SyncTargetLoop(ctx)
 	}
 	return nil
 }

block/retriever.go

@@ -38,6 +38,7 @@ func (m *Manager) RetrieveLoop(ctx context.Context) {
 // the actual blocks from the DA.
 func (m *Manager) syncUntilTarget(targetHeight uint64) error {
 	for currH := m.State.Height(); currH < targetHeight; currH = m.State.Height() {
+		m.logger.Info("Syncing from DA", "store height", currH, "target height", targetHeight)
 
 		// It's important that we query the state index before fetching the batch, rather
 		// than e.g. keep it and increment it, because we might be concurrently applying blocks