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) SnapshotIncarnations(context.Context) ([]domain.IncarnationID, error) {
22	return nil, nil
23}
24func (testLifecycleRepository) CollectIncarnationGarbage(context.Context, domain.IncarnationID, *domain.CheckpointRef) error {
25	return nil
26}
27
28// WithStore is package-test composition glue. Production injects the same
29// recovery coordinator explicitly from internal/app.
30func WithStore(t testing.TB, store ports.Store) Option {
31	t.Helper()
32	return func(d *Daemon) {
33		if store == nil {
34			return
35		}
36		catalogue := persist.New(store)
37		records, err := catalogue.Records()
38		require.NoError(t, err)
39		d.catalogue = catalogue
40		d.persistEnabled = true
41		d.catalogueRecords = records
42		d.catalogueRecordsProvided = true
43		repository := d.snapshotRepository
44		if repository == nil {
45			repository = testLifecycleRepository{}
46		}
47		d.recovery = recoveryusecase.NewCoordinator(catalogue, repository, rand.Reader)
48	}
49}
50
51func testPersister(t testing.TB, d *Daemon) *persist.Persister {
52	t.Helper()
53	persister, ok := d.catalogue.(*persist.Persister)
54	require.True(t, ok, "catalogue type %T is not *persist.Persister", d.catalogue)
55	return persister
56}