refstore/files: Accept timeout instead of reading from config

And split things up again.

1 files changed, 65 insertions, 0 deletions

diff --git a/refstore/files/transaction_commit.go b/refstore/files/transaction_commit.go
new file mode 100644
index 00000000..eba959cb
--- /dev/null
+++ b/refstore/files/transaction_commit.go
@@ -0,0 +1,65 @@
+package files
+
+import (
+	"errors"
+	"os"
+)
+
+func (tx *Transaction) Commit() error {
+	err := tx.ensureOpen()
+	if err != nil {
+		return err
+	}
+
+	prepared, err := tx.prepare()
+	if err != nil {
+		tx.closed = true
+
+		return err
+	}
+
+	defer func() {
+		_ = tx.cleanup(prepared)
+	}()
+
+	for _, item := range prepared {
+		if item.op.kind == txDelete || item.op.kind == txDeleteSymbolic || item.op.kind == txVerify || item.op.kind == txVerifySymbolic {
+			continue
+		}
+
+		err = tx.writeLoose(item)
+		if err != nil {
+			tx.closed = true
+
+			return err
+		}
+	}
+
+	err = tx.applyPackedDeletes(prepared)
+	if err != nil {
+		tx.closed = true
+
+		return err
+	}
+
+	for _, item := range prepared {
+		switch item.op.kind {
+		case txDelete, txDeleteSymbolic:
+			if item.target.ref.isLoose {
+				err = tx.store.rootFor(item.target.loc.root).Remove(item.target.loc.path)
+				if err != nil && !errors.Is(err, os.ErrNotExist) {
+					tx.closed = true
+
+					return err
+				}
+
+				tx.tryRemoveEmptyParents(item.target.name)
+			}
+		case txCreate, txUpdate, txVerify, txCreateSymbolic, txUpdateSymbolic, txVerifySymbolic:
+		}
+	}
+
+	tx.closed = true
+
+	return nil
+}