refstore: Improve interfaces, errors, and make batch work v0.1.92

1 files changed, 28 insertions, 0 deletions

diff --git a/refstore/files/update_prepare_lock.go b/refstore/files/update_prepare_lock.go
new file mode 100644
index 00000000..d958fc0a
--- /dev/null
+++ b/refstore/files/update_prepare_lock.go
@@ -0,0 +1,28 @@
+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
+}