[DNM] feat(da): support fiber (not via c-node)

apps/evm/cmd/run.go

@@ -131,7 +131,10 @@ var RunCmd = &cobra.Command{
 			}()
 		}
 
-		return rollcmd.StartNode(logger, cmd, executor, sequencer, nodeKey, datastore, nodeConfig, genesis, node.NodeOptions{})
+		// nil fiberClient: the EVM app doesn't wire Fibre DA. See
+		// tools/celestia-node-fiber for the adapter; testapp/cmd/run.go
+		// has the same TODO note for matching context.
+		return rollcmd.StartNode(logger, cmd, executor, sequencer, nodeKey, datastore, nodeConfig, genesis, node.NodeOptions{}, nil)
 	},
 }
 

apps/grpc/cmd/run.go

@@ -86,8 +86,10 @@ The execution client must implement the Evolve execution gRPC interface.`,
 			return err
 		}
 
-		// Start the node
-		return rollcmd.StartNode(logger, cmd, executor, sequencer, nodeKey, datastore, nodeConfig, genesis, node.NodeOptions{})
+		// Start the node. nil fiberClient: the gRPC app doesn't wire
+		// Fibre DA. See tools/celestia-node-fiber for the adapter;
+		// testapp/cmd/run.go has the same TODO note for context.
+		return rollcmd.StartNode(logger, cmd, executor, sequencer, nodeKey, datastore, nodeConfig, genesis, node.NodeOptions{}, nil)
 	},
 }
 

apps/testapp/cmd/run.go

@@ -97,7 +97,12 @@ var RunCmd = &cobra.Command{
 			return err
 		}
 
-		return cmd.StartNode(logger, command, executor, sequencer, nodeKey, datastore, nodeConfig, genesis, node.NodeOptions{})
+		// nil fiberClient: testapp doesn't yet wire Fibre DA. To enable
+		// fiber support here, build a *cnfiber.Adapter from
+		// nodeConfig.DA.Fiber and pass it as the last argument. The
+		// adapter wiring lives in tools/celestia-node-fiber; see the
+		// fiber-bench tool's run.go for a working caller.
+		return cmd.StartNode(logger, command, executor, sequencer, nodeKey, datastore, nodeConfig, genesis, node.NodeOptions{}, nil)
 	},
 }
 

block/internal/cache/manager.go

@@ -27,7 +27,7 @@ const (
 
 	// DefaultTxCacheRetention is the default time to keep transaction hashes in cache.
 	// Keeping a too high value can lead to OOM during heavy transaction load.
-	DefaultTxCacheRetention = 30 * time.Minute
+	DefaultTxCacheRetention = 30 * time.Second
 )
 
 // CacheManager provides thread-safe cache operations for tracking seen blocks
@@ -77,10 +77,14 @@ type PendingManager interface {
 	GetPendingData(ctx context.Context) ([]*types.SignedData, [][]byte, error)
 	SetLastSubmittedHeaderHeight(ctx context.Context, height uint64)
 	GetLastSubmittedHeaderHeight() uint64
+	ResetInFlightHeaderRange(start, end uint64)
 	SetLastSubmittedDataHeight(ctx context.Context, height uint64)
 	GetLastSubmittedDataHeight() uint64
+	ResetInFlightDataRange(start, end uint64)
 	NumPendingHeaders() uint64
 	NumPendingData() uint64
+	NumPendingHeadersTotal() uint64
+	NumPendingDataTotal() uint64
 }
 
 // Manager combines CacheManager and PendingManager.
@@ -311,6 +315,10 @@ func (m *implementation) SetLastSubmittedHeaderHeight(ctx context.Context, heigh
 	m.pendingHeaders.SetLastSubmittedHeaderHeight(ctx, height)
 }
 
+func (m *implementation) ResetInFlightHeaderRange(start, end uint64) {
+	m.pendingHeaders.ResetInFlightHeaderRange(start, end)
+}
+
 func (m *implementation) GetLastSubmittedDataHeight() uint64 {
 	return m.pendingData.GetLastSubmittedDataHeight()
 }
@@ -319,6 +327,10 @@ func (m *implementation) SetLastSubmittedDataHeight(ctx context.Context, height
 	m.pendingData.SetLastSubmittedDataHeight(ctx, height)
 }
 
+func (m *implementation) ResetInFlightDataRange(start, end uint64) {
+	m.pendingData.ResetInFlightDataRange(start, end)
+}
+
 func (m *implementation) NumPendingHeaders() uint64 {
 	return m.pendingHeaders.NumPendingHeaders()
 }
@@ -327,6 +339,14 @@ func (m *implementation) NumPendingData() uint64 {
 	return m.pendingData.NumPendingData()
 }
 
+func (m *implementation) NumPendingHeadersTotal() uint64 {
+	return m.pendingHeaders.NumPendingHeadersTotal()
+}
+
+func (m *implementation) NumPendingDataTotal() uint64 {
+	return m.pendingData.NumPendingDataTotal()
+}
+
 // SetPendingEvent sets the event at the specified height.
 func (m *implementation) SetPendingEvent(height uint64, event *common.DAHeightEvent) {
 	m.pendingMu.Lock()

block/internal/cache/manager_test.go

@@ -221,6 +221,12 @@ func TestPendingHeadersAndData_Flow(t *testing.T) {
 	// update last submitted heights and re-check
 	cm.SetLastSubmittedHeaderHeight(ctx, 1)
 	cm.SetLastSubmittedDataHeight(ctx, 2)
+	cm.ResetInFlightHeaderRange(1, 3)
+	cm.ResetInFlightDataRange(2, 3)
+
+	// numPending views (before getPending claims items)
+	assert.Equal(t, uint64(2), cm.NumPendingHeaders())
+	assert.Equal(t, uint64(1), cm.NumPendingData())
 
 	headers, _, err = cm.GetPendingHeaders(ctx)
 	require.NoError(t, err)
@@ -231,10 +237,6 @@ func TestPendingHeadersAndData_Flow(t *testing.T) {
 	require.NoError(t, err)
 	require.Len(t, signedData, 1)
 	assert.Equal(t, uint64(3), signedData[0].Height())
-
-	// numPending views
-	assert.Equal(t, uint64(2), cm.NumPendingHeaders())
-	assert.Equal(t, uint64(1), cm.NumPendingData())
 }
 
 func TestManager_TxOperations(t *testing.T) {