*: objectstore -> object/store

1 files changed, 30 insertions, 0 deletions

diff --git a/object/store/loose/write_temp_object_file.go b/object/store/loose/write_temp_object_file.go
new file mode 100644
index 00000000..1a78db48
--- /dev/null
+++ b/object/store/loose/write_temp_object_file.go
@@ -0,0 +1,30 @@
+package loose
+
+import (
+	"crypto/rand"
+	"errors"
+	"io/fs"
+	"os"
+	"path/filepath"
+)
+
+// createTempObjectFile creates a unique temporary object file within dir.
+// The returned path is relative to the objects root.
+func (store *Store) createTempObjectFile(dir string) (string, *os.File, error) {
+	for range 16 {
+		relPath := filepath.Join(dir, tempObjectFilePrefix+rand.Text())
+
+		file, err := store.root.OpenFile(relPath, os.O_CREATE|os.O_EXCL|os.O_WRONLY, 0o644)
+		if err == nil {
+			return relPath, file, nil
+		}
+
+		if errors.Is(err, fs.ErrExist) {
+			continue
+		}
+
+		return "", nil, err
+	}
+
+	return "", nil, errors.New("objectstore/loose: failed to create temporary object file")
+}