shithub: furgit

ref: d314d1f7e933ca83081eec289aa0cb6e75a7eeac
dir: /refstore/files/transaction_write_loose.go/

package files

import (
	"fmt"
	"os"
	"path"
	"strings"
)

func (tx *Transaction) writeLoose(item preparedTxOp) error {
	root := tx.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 txCreate, txUpdate:
		content = item.op.newID.String() + "\n"
	case txCreateSymbolic, txUpdateSymbolic:
		content = "ref: " + strings.TrimSpace(item.op.newTarget) + "\n"
	case txDelete, txVerify, txDeleteSymbolic, txVerifySymbolic:
	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 = tx.removeEmptyDirTree(item.target.loc)
	if err != nil {
		return err
	}

	return root.Rename(lockName, item.target.loc.path)
}