feat(nodebuilder/prune): Enable sampling window for light nodes

das/daser.go

@@ -151,6 +151,8 @@ func (d *DASer) sample(ctx context.Context, h *header.ExtendedHeader) error {
 	// short-circuit if pruning is enabled and the header is outside the
 	// availability window
 	if !d.isWithinSamplingWindow(h) {
+		log.Debugw("skipping header outside sampling window", "height", h.Height(),
+			"time", h.Time())
 		return nil
 	}
 

das/daser_test.go

@@ -2,6 +2,7 @@ package das
 
 import (
 	"context"
+	"strconv"
 	"testing"
 	"time"
 
@@ -244,6 +245,42 @@ func TestDASerSampleTimeout(t *testing.T) {
 	}
 }
 
+// TestDASer_SamplingWindow tests the sampling window determination
+// for headers.
+func TestDASer_SamplingWindow(t *testing.T) {
+	ds := ds_sync.MutexWrap(datastore.NewMapDatastore())
+	sub := new(headertest.Subscriber)
+	fserv := &fraudtest.DummyService[*header.ExtendedHeader]{}
+	getter := getterStub{}
+	avail := mocks.NewMockAvailability(gomock.NewController(t))
+
+	// create and start DASer
+	daser, err := NewDASer(avail, sub, getter, ds, fserv, newBroadcastMock(1),
+		WithSamplingWindow(time.Second))
+	require.NoError(t, err)
+
+	var tests = []struct {
+		timestamp    time.Time
+		withinWindow bool
+	}{
+		{timestamp: time.Now().Add(-(time.Second * 5)), withinWindow: false},
+		{timestamp: time.Now().Add(-(time.Millisecond * 800)), withinWindow: true},
+		{timestamp: time.Now().Add(-(time.Hour)), withinWindow: false},
+		{timestamp: time.Now().Add(-(time.Hour * 24 * 30)), withinWindow: false},
+		{timestamp: time.Now(), withinWindow: true},
+	}
+
+	for i, tt := range tests {
+		t.Run(strconv.Itoa(i), func(t *testing.T) {
+			eh := headertest.RandExtendedHeader(t)
+			eh.RawHeader.Time = tt.timestamp
+
+			assert.Equal(t, tt.withinWindow, daser.isWithinSamplingWindow(eh))
+		})
+	}
+
+}
+
 // createDASerSubcomponents takes numGetter (number of headers
 // to store in mockGetter) and numSub (number of headers to store
 // in the mock header.Subscriber), returning a newly instantiated

nodebuilder/prune/module.go

@@ -39,7 +39,7 @@ func ConstructModule(tp node.Type) fx.Option {
 			fx.Provide(func() pruner.Pruner {
 				return light.NewPruner()
 			}),
-			fx.Supply(archival.Window), // TODO @renaynay: turn this into light.Window in following PR
+			fx.Supply(light.Window),
 		)
 	default:
 		panic("unknown node type")

pruner/light/window.go

@@ -6,4 +6,6 @@ import (
 	"github.com/celestiaorg/celestia-node/pruner"
 )
 
+// Window is the availability window for light nodes in the Celestia
+// network (30 days).
 const Window = pruner.AvailabilityWindow(time.Second * 86400 * 30)