durable_authority_test.go RawHistoryFolder

1package daemon
2
3import (
4	"context"
5	"crypto/rand"
6	"testing"
7
8	"github.com/stretchr/testify/require"
9
10	"github.com/bnema/vev/internal/domain"
11	"github.com/bnema/vev/internal/persist"
12	"github.com/bnema/vev/internal/ports"
13	recoveryusecase "github.com/bnema/vev/internal/usecase/recovery"
14)
15
16type testLifecycleRepository struct{ ports.SnapshotRepository }
17
18func (testLifecycleRepository) DeleteIncarnation(context.Context, domain.IncarnationID) error {
19	return nil
20}
21func (testLifecycleRepository) CollectGarbage(context.Context, map[domain.IncarnationID]domain.CheckpointRef) error {
22	return nil
23}
24
25// WithStore is package-test composition glue. Production injects the same
26// recovery coordinator explicitly from internal/app.
27func WithStore(t testing.TB, store ports.Store) Option {
28	t.Helper()
29	return func(d *Daemon) {
30		if store == nil {
31			return
32		}
33		catalogue := persist.New(store)
34		records, err := catalogue.Records()
35		require.NoError(t, err)
36		d.catalogue = catalogue
37		d.persistEnabled = true
38		d.catalogueRecords = records
39		d.catalogueRecordsProvided = true
40		repository := d.snapshotRepository
41		if repository == nil {
42			repository = testLifecycleRepository{}
43		}
44		d.recovery = recoveryusecase.NewCoordinator(catalogue, repository, rand.Reader)
45	}
46}
47
48func testPersister(t testing.TB, d *Daemon) *persist.Persister {
49	t.Helper()
50	persister, ok := d.catalogue.(*persist.Persister)
51	require.True(t, ok, "catalogue type %T is not *persist.Persister", d.catalogue)
52	return persister
53}