test_helpers_test.go RawHistoryFolder

1package snapshot
2
3import (
4	"context"
5	"errors"
6	"path/filepath"
7	"testing"
8
9	"github.com/bnema/vev/internal/domain"
10
11	vt "github.com/bnema/vev-vt"
12	renderer "github.com/bnema/vev-vt/ansi"
13)
14
15// collectAll runs one GC pass the way the recovery coordinator does: every
16// listed incarnation absent from keep is an orphan.
17func collectAll(ctx context.Context, r *Repository, keep map[domain.IncarnationID]domain.CheckpointRef) error {
18	ids, err := r.SnapshotIncarnations(ctx)
19	if err != nil {
20		return err
21	}
22	var collected error
23	for _, id := range ids {
24		var ref *domain.CheckpointRef
25		if committed, ok := keep[id]; ok {
26			ref = &committed
27		}
28		collected = errors.Join(collected, r.CollectIncarnationGarbage(ctx, id, ref))
29	}
30	return collected
31}
32
33func privateDir(t *testing.T) string {
34	t.Helper()
35	return filepath.Join(t.TempDir(), "vev")
36}
37
38func canonicalHistoryBlob(t testing.TB, text string) []byte {
39	t.Helper()
40	history := vt.NewHistory(vt.HistoryConfig{MaxRows: 1, ChunkRows: 1})
41	if text != "" {
42		row := make([]renderer.Cell, 0, len(text))
43		for _, r := range text {
44			row = append(row, renderer.Cell{Rune: r})
45		}
46		if err := history.Append(row, vt.LineBound{End: len(row)}); err != nil {
47			t.Fatal(err)
48		}
49	}
50	blob, err := vt.MarshalHistory(history.SealAndView())
51	if err != nil {
52		t.Fatal(err)
53	}
54	return blob
55}