From 48ff647cf4a8bb8f23fcd6b8616f56a8ef72b980 Mon Sep 17 00:00:00 2001 From: Runxi Yu Date: Wed, 25 Mar 2026 14:31:16 +0000 Subject: *: refstore -> ref/store --- ref/store/files/update_write_loose.go | 59 +++++++++++++++++++++++++++++++++++ 1 file changed, 59 insertions(+) create mode 100644 ref/store/files/update_write_loose.go (limited to 'ref/store/files/update_write_loose.go') diff --git a/ref/store/files/update_write_loose.go b/ref/store/files/update_write_loose.go new file mode 100644 index 00000000..212be9a8 --- /dev/null +++ b/ref/store/files/update_write_loose.go @@ -0,0 +1,59 @@ +package files + +import ( + "fmt" + "os" + "path" + "strings" +) + +func (executor *refUpdateExecutor) writePreparedLooseUpdate(item preparedUpdate) error { + root := executor.store.rootFor(item.target.loc.root) + lockName := item.target.loc.path + ".lock" + + lock, err := root.OpenFile(lockName, os.O_WRONLY|os.O_TRUNC, 0o644) + if err != nil { + return err + } + + var content string + + switch item.op.kind { + case updateCreate, updateReplace: + content = item.op.newID.String() + "\n" + case updateCreateSymbolic, updateReplaceSymbolic: + content = "ref: " + strings.TrimSpace(item.op.newTarget) + "\n" + case updateDelete, updateVerify, updateDeleteSymbolic, updateVerifySymbolic: + default: + _ = lock.Close() + + return fmt.Errorf("refstore/files: unsupported write operation %d", item.op.kind) + } + + _, err = lock.WriteString(content) + if err != nil { + _ = lock.Close() + + return err + } + + err = lock.Close() + if err != nil { + return err + } + + dir := path.Dir(item.target.loc.path) + if dir != "." { + err = root.MkdirAll(dir, 0o755) + if err != nil { + return err + } + } + + err = executor.removeEmptyDirTree(item.target.loc) + if err != nil { + return err + } + + return root.Rename(lockName, item.target.loc.path) +} -- cgit v1.3.1-10-gc9f91