*: refstore -> ref/store

1 files changed, 29 insertions, 0 deletions

diff --git a/ref/store/files/update_prepare_lock.go b/ref/store/files/update_prepare_lock.go
new file mode 100644
index 00000000..67db9628
--- /dev/null
+++ b/ref/store/files/update_prepare_lock.go
@@ -0,0 +1,29 @@
+package files
+
+import "slices"
+
+func (executor *refUpdateExecutor) prepareUpdateLocks(prepared []preparedUpdate) error {
+	lockNames := make([]string, 0, len(prepared))
+	for _, item := range prepared {
+		lockNames = append(lockNames, updateTargetKey(item.target.loc))
+	}
+
+	slices.Sort(lockNames)
+
+	for _, lockKey := range lockNames {
+		lockPath := refPathFromKey(lockKey)
+
+		err := executor.createUpdateLock(lockPath)
+		if err != nil {
+			for _, item := range prepared {
+				if updateTargetKey(item.target.loc) == lockKey {
+					return wrapUpdateError(item.op.name, err)
+				}
+			}
+
+			return err
+		}
+	}
+
+	return nil
+}