remove redundant call

Author: tac0turtle

block/internal/syncing/p2p_handler.go

@@ -55,11 +55,6 @@ func (h *P2PHandler) SetProcessedHeight(height uint64) {
 	h.mu.Unlock()
 }
 
-// OnHeightProcessed records progress after a block is successfully applied.
-func (h *P2PHandler) OnHeightProcessed(height uint64) {
-	h.SetProcessedHeight(height)
-}
-
 // ProcessHeaderRange scans the provided heights and emits events when both the
 // header and data are available.
 func (h *P2PHandler) ProcessHeaderRange(ctx context.Context, startHeight, endHeight uint64, heightInCh chan<- common.DAHeightEvent) {

block/internal/syncing/p2p_handler_test.go

@@ -261,7 +261,7 @@ func TestP2PHandler_OnHeightProcessedPreventsDuplicates(t *testing.T) {
 	require.Len(t, events, 1)
 
 	// Mark the height as processed; a subsequent range should skip lookups.
-	p.Handler.OnHeightProcessed(8)
+	p.Handler.SetProcessedHeight(8)
 
 	p.HeaderStore.AssertExpectations(t)
 	p.DataStore.AssertExpectations(t)

block/internal/syncing/syncer.go

@@ -33,7 +33,6 @@ type p2pHandler interface {
 	ProcessHeaderRange(ctx context.Context, fromHeight, toHeight uint64, heightInCh chan<- common.DAHeightEvent)
 	ProcessDataRange(ctx context.Context, fromHeight, toHeight uint64, heightInCh chan<- common.DAHeightEvent)
 	SetProcessedHeight(height uint64)
-	OnHeightProcessed(height uint64)
 }
 
 // Syncer handles block synchronization from DA and P2P sources.
@@ -146,7 +145,7 @@ func (s *Syncer) Start(ctx context.Context) error {
 		s.processLoop()
 	}()
 
-	// Start dedicated workers for P2P, DA, and pending processing
+	// Start dedicated workers for DA, and pending processing
 	s.startSyncWorkers()
 
 	s.logger.Info().Msg("syncer started")
@@ -612,7 +611,7 @@ func (s *Syncer) trySyncNextBlock(event *common.DAHeightEvent) error {
 	}
 
 	if s.p2pHandler != nil {
-		s.p2pHandler.OnHeightProcessed(newState.LastBlockHeight)
+		s.p2pHandler.SetProcessedHeight(newState.LastBlockHeight)
 	}
 
 	return nil