session_purge_control_test.go RawHistoryFolder

1package daemon
2
3import (
4	"errors"
5	"testing"
6
7	"github.com/stretchr/testify/require"
8
9	"github.com/bnema/vev/internal/domain"
10	"github.com/bnema/vev/internal/persist"
11	portsmocks "github.com/bnema/vev/internal/ports/mocks"
12)
13
14func TestStoppedPurgeMetadataFailureFencesCatalogue(t *testing.T) {
15	d := newTestDaemon(t, portsmocks.NewMockPTYFactory(t), stubClock{})
16	repository := &retryablePurgeRepository{}
17	WithSnapshotRepository(repository)(d)
18	store, state := newMockStore(t)
19	WithStore(t, store)(d)
20	record := domain.CatalogueRecord{Name: "work", IncarnationID: domain.IncarnationID{1}}
21	require.NoError(t, d.catalogue.Create(record))
22	metadataErr := errors.New("metadata delete failed")
23	state.mu.Lock()
24	state.deleteErr = func(string) error { return metadataErr }
25	state.mu.Unlock()
26	d.inactive["work"] = inactiveSession{name: "work", incarnation: record.IncarnationID, record: record}
27
28	require.ErrorIs(t, d.retryStoppedPurge("work"), metadataErr)
29	require.Empty(t, repository.calls, "snapshot deletion must wait for catalogue removal")
30
31	state.mu.Lock()
32	state.deleteErr = nil
33	state.mu.Unlock()
34	require.ErrorIs(t, d.retryStoppedPurge("work"), persist.ErrCatalogueDurability)
35	require.Empty(t, repository.calls, "a fenced catalogue must not retry deletion")
36}