Minor cleanup

Author: alpe

block/internal/syncing/async_da_retriever_test.go

@@ -39,7 +39,7 @@ func TestAsyncDARetriever_RequestRetrieval(t *testing.T) {
 	// 2. Test deduplication (idempotency)
 	// We'll block the retriever to simulate a slow request, then send multiple requests for the same height
 	height2 := uint64(200)
-	
+
 	// Create a channel to signal when the mock is called
 	calledCh := make(chan struct{})
 	// Create a channel to unblock the mock
@@ -98,7 +98,7 @@ func TestAsyncDARetriever_WorkerPoolLimit(t *testing.T) {
 
 	// We have 5 workers. We'll block them all.
 	unblockCh := make(chan struct{})
-	
+
 	// Expect 5 calls that block
 	for i := 0; i < 5; i++ {
 		h := uint64(1000 + i)

block/internal/syncing/syncer_test.go

@@ -731,31 +731,31 @@ func TestProcessHeightEvent_TriggersAsyncDARetrieval(t *testing.T) {
 	// Mock AsyncDARetriever
 	mockRetriever := NewMockDARetriever(t)
 	asyncRetriever := NewAsyncDARetriever(mockRetriever, s.heightInCh, zerolog.Nop())
-	// We don't start the async retriever to avoid race conditions in test, 
+	// We don't start the async retriever to avoid race conditions in test,
 	// we just want to verify RequestRetrieval queues the request.
 	// However, RequestRetrieval writes to a channel, so we need a consumer or a buffered channel.
 	// The workCh is buffered (100), so we are good.
 	s.asyncDARetriever = asyncRetriever
 
 	// Create event with DA height hint
 	evt := common.DAHeightEvent{
-		Header: &types.SignedHeader{Header: types.Header{BaseHeader: types.BaseHeader{ChainID: "c", Height: 2}}},
-		Data:   &types.Data{Metadata: &types.Metadata{ChainID: "c", Height: 2}},
-		Source: common.SourceP2P,
+		Header:        &types.SignedHeader{Header: types.Header{BaseHeader: types.BaseHeader{ChainID: "c", Height: 2}}},
+		Data:          &types.Data{Metadata: &types.Metadata{ChainID: "c", Height: 2}},
+		Source:        common.SourceP2P,
 		DaHeightHints: [2]uint64{100, 100},
 	}
 
 	// Current height is 0 (from init), event height is 2.
 	// processHeightEvent checks:
 	// 1. height <= currentHeight (2 <= 0 -> false)
 	// 2. height != currentHeight+1 (2 != 1 -> true) -> stores as pending event
-	
+
 	// We need to simulate height 1 being processed first so height 2 is "next"
 	// OR we can just test that it DOES NOT trigger DA retrieval if it's pending.
 	// Wait, the logic for DA retrieval is BEFORE the "next block" check?
 	// Let's check syncer.go...
 	// Yes, "If this is a P2P event with a DA height hint, trigger targeted DA retrieval" block is AFTER "If this is not the next block in sequence... return"
-	
+
 	// So we need to be at height 1 to process height 2.
 	// Let's set the store height to 1.
 	batch, err := st.NewBatch(context.Background())

test/e2e/go.sum

@@ -72,6 +72,8 @@ github.com/btcsuite/btcd/btcutil v1.1.6 h1:zFL2+c3Lb9gEgqKNzowKUPQNb8jV7v5Oaodi/
 github.com/btcsuite/btcd/btcutil v1.1.6/go.mod h1:9dFymx8HpuLqBnsPELrImQeTQfKBQqzqGbbV3jK55aE=
 github.com/celestiaorg/go-header v0.7.4 h1:kQx3bVvKV+H2etxRi4IUuby5VQydBONx3giHFXDcZ/o=
 github.com/celestiaorg/go-header v0.7.4/go.mod h1:eX9iTSPthVEAlEDLux40ZT/olXPGhpxHd+mEzJeDhd0=
+github.com/celestiaorg/go-libp2p-messenger v0.2.2 h1:osoUfqjss7vWTIZrrDSy953RjQz+ps/vBFE7bychLEc=
+github.com/celestiaorg/go-libp2p-messenger v0.2.2/go.mod h1:oTCRV5TfdO7V/k6nkx7QjQzGrWuJbupv+0o1cgnY2i4=
 github.com/celestiaorg/go-square/v3 v3.0.2 h1:eSQOgNII8inK9IhiBZ+6GADQeWbRq4HYY72BOgcduA4=
 github.com/celestiaorg/go-square/v3 v3.0.2/go.mod h1:oFReMLsSDMRs82ICFEeFQFCqNvwdsbIM1BzCcb0f7dM=
 github.com/celestiaorg/tastora v0.8.0 h1:+FWAIsP2onwwqPTGzBLIBtx8B1h9sImdx4msv2N4DsI=