aboutsummaryrefslogtreecommitdiff
path: root/object/store/loose/quarantine_begin.go
blob: dd27f968ad5d4f87e2d7c5309b58ad73afc6d3e7 (about) (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
package loose

import (
	"crypto/rand"
	"errors"
	"fmt"
	"io/fs"
	"os"

	objectstore "codeberg.org/lindenii/furgit/object/store"
)

// BeginObjectQuarantine creates one quarantined loose store rooted privately
// beneath the destination loose root.
//
// Labels: Deps-Borrowed, Life-Parent, Close-No.
func (store *Store) BeginObjectQuarantine(_ objectstore.ObjectQuarantineOptions) (objectstore.ObjectQuarantine, error) {
	tempName, tempRoot, err := createLooseQuarantineRoot(store.root)
	if err != nil {
		return nil, err
	}

	quarantineStore, err := New(tempRoot, store.algo)
	if err != nil {
		_ = tempRoot.Close()
		_ = store.root.RemoveAll(tempName)

		return nil, err
	}

	return &objectQuarantine{
		Store:    quarantineStore,
		parent:   store,
		tempName: tempName,
		tempRoot: tempRoot,
	}, nil
}

func createLooseQuarantineRoot(parent *os.Root) (string, *os.Root, error) {
	for range 32 {
		name := "tmp_looseq_" + rand.Text()

		err := parent.Mkdir(name, 0o700)
		if err == nil {
			root, err := parent.OpenRoot(name)
			if err == nil {
				return name, root, nil
			}

			_ = parent.RemoveAll(name)

			return "", nil, err
		}

		if errors.Is(err, fs.ErrExist) {
			continue
		}

		return "", nil, err
	}

	return "", nil, fmt.Errorf("objectstore/loose: unable to create quarantine directory")
}