session_purge_retry_test.go RawHistoryFolder

1package daemon
2
3import (
4	"context"
5	"errors"
6	"testing"
7
8	"github.com/stretchr/testify/require"
9
10	"github.com/bnema/vev/internal/domain"
11	portsmocks "github.com/bnema/vev/internal/ports/mocks"
12	"github.com/bnema/vev/internal/protocol"
13)
14
15type retryablePurgeRepository struct {
16	noOpSnapshotRepository
17	deleteErr      error
18	calls          []string
19	deadlineScoped []bool
20}
21
22func (r *retryablePurgeRepository) DeleteIncarnation(ctx context.Context, _ domain.IncarnationID) error {
23	_, hasDeadline := ctx.Deadline()
24	r.deadlineScoped = append(r.deadlineScoped, hasDeadline)
25	r.calls = append(r.calls, "delete incarnation")
26	return r.deleteErr
27}
28
29func TestLivePurgeLeavesFailedDirectoryDeletionForBackgroundGarbageCollection(t *testing.T) {
30	d := newTestDaemon(t, portsmocks.NewMockPTYFactory(t), stubClock{})
31	repository := &retryablePurgeRepository{deleteErr: errors.New("delete failed")}
32	WithSnapshotRepository(repository)(d)
33	store, _ := newMockStore(t)
34	WithStore(t, store)(d)
35	sess := newSnapshotTestSession(t, "work", false, "/work")
36	record := sess.persistRecordLocked(1)
37	require.NoError(t, d.catalogue.Create(record))
38	pty, ok := sess.tabs[0].panes["pane-1"].pty.(*portsmocks.MockPTY)
39	require.True(t, ok)
40	pty.EXPECT().Close().Return(nil).Once()
41	d.sessions = map[domain.SessionID]*session{sess.id: sess}
42
43	require.Error(t, d.killSession(sess, protocol.ReasonSessionKilled, true))
44	require.Equal(t, []string{"delete incarnation"}, repository.calls)
45	_, exists, err := d.catalogue.Record("work")
46	require.NoError(t, err)
47	require.False(t, exists, "catalogue removal commits before best-effort directory deletion")
48	require.Equal(t, []bool{true}, repository.deadlineScoped)
49}