feat(module/das): add WaitCatchUp method to the module

nodebuilder/das/daser.go

@@ -14,12 +14,18 @@ import (
 
 var _ Module = (*daserStub)(nil)
 
+var errStub = fmt.Errorf("module/das: stubbed: dasing is not available on bridge nodes")
+
 // daserStub is a stub implementation of the DASer that is used on bridge nodes, so that we can
 // provide a friendlier error when users try to access the daser over the API.
 type daserStub struct{}
 
 func (d daserStub) SamplingStats(context.Context) (das.SamplingStats, error) {
-	return das.SamplingStats{}, fmt.Errorf("moddas: dasing is not available on bridge nodes")
+	return das.SamplingStats{}, errStub
+}
+
+func (d daserStub) WaitCatchUp(context.Context) error {
+	return errStub
 }
 
 func newDaserStub() Module {

nodebuilder/das/module_test.go

@@ -0,0 +1,31 @@
+package das
+
+import (
+	"context"
+	"testing"
+
+	"github.com/stretchr/testify/assert"
+	"go.uber.org/fx"
+	"go.uber.org/fx/fxtest"
+
+	"github.com/celestiaorg/celestia-node/nodebuilder/node"
+)
+
+// TestConstructModule_DASBridgeStub verifies that a bridge node implements a stub daser that
+// returns an error and empty das.SamplingStats
+func TestConstructModule_DASBridgeStub(t *testing.T) {
+	ctx, cancel := context.WithCancel(context.Background())
+	t.Cleanup(cancel)
+
+	var mod Module
+
+	cfg := DefaultConfig()
+	app := fxtest.New(t,
+		ConstructModule(node.Bridge, &cfg),
+		fx.Populate(&mod)).
+		RequireStart()
+	defer app.RequireStop()
+
+	_, err := mod.SamplingStats(ctx)
+	assert.ErrorIs(t, err, errStub)
+}

nodebuilder/das/service.go

@@ -10,10 +10,13 @@ import (
 type Module interface {
 	// SamplingStats returns the current statistics over the DA sampling process.
 	SamplingStats(ctx context.Context) (das.SamplingStats, error)
+	// WaitCatchUp blocks until DASer finishes catching up to the network head.
+	WaitCatchUp(ctx context.Context) error
 }
 
 // API is a wrapper around Module for the RPC.
 // TODO(@distractedm1nd): These structs need to be autogenerated.
 type API struct {
 	SamplingStats func(ctx context.Context) (das.SamplingStats, error)
+	WaitCatchUp   func(ctx context.Context) error
 }

nodebuilder/node_bridge_test.go

@@ -4,11 +4,9 @@ import (
 	"context"
 	"testing"
 
-	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 
 	"github.com/celestiaorg/celestia-node/core"
-	"github.com/celestiaorg/celestia-node/das"
 	coremodule "github.com/celestiaorg/celestia-node/nodebuilder/core"
 	"github.com/celestiaorg/celestia-node/nodebuilder/node"
 	"github.com/celestiaorg/celestia-node/nodebuilder/p2p"
@@ -31,23 +29,3 @@ func TestBridge_WithMockedCoreClient(t *testing.T) {
 	err = node.Stop(ctx)
 	require.NoError(t, err)
 }
-
-// TestBridge_HasStubDaser verifies that a bridge node implements a stub daser that returns an
-// error and empty das.SamplingStats
-func TestBridge_HasStubDaser(t *testing.T) {
-	ctx, cancel := context.WithCancel(context.Background())
-	t.Cleanup(cancel)
-
-	_, client := core.StartTestClient(ctx, t)
-	nd := TestNode(t, node.Bridge, coremodule.WithClient(client))
-	require.NotNil(t, nd)
-	err := nd.Start(ctx)
-	require.NoError(t, err)
-
-	stats, err := nd.DASer.SamplingStats(ctx)
-	assert.EqualError(t, err, "moddas: dasing is not available on bridge nodes")
-	assert.Equal(t, stats, das.SamplingStats{})
-
-	err = nd.Stop(ctx)
-	require.NoError(t, err)
-}