Review feedback

Author: alpe

block/internal/da/async_block_retriever.go

@@ -240,6 +240,7 @@ func (f *asyncBlockRetriever) fetchAndCacheBlock(ctx context.Context, height uin
 			Uint64("height", height).
 			Str("status", result.Message).
 			Msg("failed to retrieve block - will retry")
+		return fmt.Errorf("retrieve block at height %d: %s", height, result.Message)
 	}
 	return nil
 }

block/internal/da/async_block_retriever_test.go

@@ -262,6 +262,53 @@ func TestAsyncBlockRetriever_ReconnectOnSubscriptionError(t *testing.T) {
 	assert.Equal(t, []byte("reconnect-tx"), block.Blobs[0])
 }
 
+func TestAsyncBlockRetriever_FetchAndCacheBlock_ErrorResponse(t *testing.T) {
+	fiNs := datypes.NamespaceFromString("test-fi-ns").Bytes()
+	specs := map[string]struct {
+		code    datypes.StatusCode
+		message string
+		wantErr string
+	}{
+		"status_error": {
+			code:    datypes.StatusError,
+			message: "rpc failure",
+			wantErr: "retrieve block at height 123: rpc failure",
+		},
+		"status_context_deadline": {
+			code:    datypes.StatusContextDeadline,
+			message: "timeout",
+			wantErr: "retrieve block at height 123: timeout",
+		},
+	}
+
+	for name, spec := range specs {
+		t.Run(name, func(t *testing.T) {
+			client := &mocks.MockClient{}
+			client.
+				On("Retrieve", mock.Anything, uint64(123), fiNs).
+				Return(datypes.ResultRetrieve{
+					BaseResult: datypes.BaseResult{
+						Code:    spec.code,
+						Message: spec.message,
+					},
+				}).
+				Once()
+
+			logger := zerolog.Nop()
+			fetcher := NewAsyncBlockRetriever(client, logger, fiNs, 100*time.Millisecond, 100, 10).(*asyncBlockRetriever)
+
+			err := fetcher.fetchAndCacheBlock(t.Context(), 123)
+			require.EqualError(t, err, spec.wantErr)
+
+			block, getErr := fetcher.GetCachedBlock(t.Context(), 123)
+			require.NoError(t, getErr)
+			assert.Nil(t, block)
+
+			client.AssertExpectations(t)
+		})
+	}
+}
+
 func TestBlockData_Serialization(t *testing.T) {
 	block := &BlockData{
 		Height:    100,

block/internal/syncing/syncer.go

@@ -236,11 +236,13 @@ func (s *Syncer) Stop(ctx context.Context) error {
 	s.cancel()
 	s.cancelP2PWait(0)
 
-	// Stop the DA follower first (it owns its own goroutines).
+	if s.fiRetriever != nil {
+		s.fiRetriever.Stop()
+	}
+
 	if s.daFollower != nil {
 		s.daFollower.Stop()
 	}
-
 	s.wg.Wait()
 
 	// Skip draining if we're shutting down due to a critical error (e.g. execution