diff options
| author | 2026-03-07 18:09:20 +0800 | |
|---|---|---|
| committer | 2026-03-07 18:17:54 +0800 | |
| commit | e667c3c52a535ee67fe895bb0240fbad6e920087 (patch) | |
| tree | 0815f7cc9b2c4a06d00722bce4c3ac57c515288b /refstore/files/transaction_verify_current.go | |
| parent | receivepack: Connect protocol with service (diff) | |
| signature | No signature | |
refstore/files: Accept timeout instead of reading from config
And split things up again.
Diffstat (limited to 'refstore/files/transaction_verify_current.go')
| -rw-r--r-- | refstore/files/transaction_verify_current.go | 53 |
1 files changed, 53 insertions, 0 deletions
diff --git a/refstore/files/transaction_verify_current.go b/refstore/files/transaction_verify_current.go new file mode 100644 index 00000000..03ee3e9c --- /dev/null +++ b/refstore/files/transaction_verify_current.go @@ -0,0 +1,53 @@ +package files + +import ( + "fmt" + "strings" +) + +func (tx *Transaction) verifyCurrent(item preparedTxOp) error { + switch item.op.kind { + case txCreate: + if item.target.ref.kind != directMissing { + return fmt.Errorf("refstore/files: reference %q already exists", item.target.name) + } + + return nil + case txUpdate, txDelete, txVerify: + if item.target.ref.kind == directMissing { + return fmt.Errorf("refstore/files: reference %q is missing", item.target.name) + } + + if item.target.ref.kind != directDetached { + return fmt.Errorf("refstore/files: reference %q is not detached", item.target.name) + } + + if item.target.ref.id != item.op.oldID { + return fmt.Errorf("refstore/files: reference %q is at %s but expected %s", item.target.name, item.target.ref.id, item.op.oldID) + } + + return nil + case txCreateSymbolic: + if item.target.ref.kind != directMissing { + return fmt.Errorf("refstore/files: reference %q already exists", item.target.name) + } + + return nil + case txUpdateSymbolic, txDeleteSymbolic, txVerifySymbolic: + if item.target.ref.kind == directMissing { + return fmt.Errorf("refstore/files: symbolic reference %q is missing", item.target.name) + } + + if item.target.ref.kind != directSymbolic { + return fmt.Errorf("refstore/files: reference %q is not symbolic", item.target.name) + } + + if strings.TrimSpace(item.target.ref.target) != strings.TrimSpace(item.op.oldTarget) { + return fmt.Errorf("refstore/files: reference %q points at %q, expected %q", item.target.name, item.target.ref.target, item.op.oldTarget) + } + + return nil + default: + return fmt.Errorf("refstore/files: unsupported transaction operation %d", item.op.kind) + } +} |
