maintenance_delete.go RawHistoryFolder

1package snapshot
2
3import (
4	"context"
5	"errors"
6	"fmt"
7	"os"
8	"path/filepath"
9
10	"github.com/bnema/vev/internal/domain"
11)
12
13// DeleteIncarnation removes one incarnation-keyed snapshot namespace. It is
14// retry-idempotent: an incarnation already absent is a successful deletion.
15func (r *Repository) DeleteIncarnation(ctx context.Context, id domain.IncarnationID) error {
16	if err := ctx.Err(); err != nil {
17		return err
18	}
19	key, err := incarnationKey(id)
20	if err != nil {
21		return err
22	}
23	lock := r.lockSession(key)
24	defer r.unlockSession(lock)
25
26	path := r.sessionPath(id)
27	if err := r.removeIncarnationLocked(id); err != nil {
28		return fmt.Errorf("remove snapshot incarnation %s: %w", id.String(), safeFilesystemError(err))
29	}
30	if err := ctx.Err(); err != nil {
31		return err
32	}
33	parent := filepath.Dir(path)
34	if _, err := os.Lstat(parent); errors.Is(err, os.ErrNotExist) {
35		return nil
36	} else if err != nil {
37		return err
38	}
39	return r.syncDirectory(parent)
40}
41
42// removeIncarnationLocked removes an incarnation through a root-pinned path.
43// The caller must hold the incarnation's session lock.
44func (r *Repository) removeIncarnationLocked(id domain.IncarnationID) (err error) {
45	root, err := r.openRoot()
46	if errors.Is(err, os.ErrNotExist) {
47		return nil
48	}
49	if err != nil {
50		return err
51	}
52	defer func() { joinCloseError(&err, "close snapshot root", r.closeRoot(root)) }()
53	return root.RemoveAll(filepath.Join(repositorySessionsDir, id.String()))
54}