1 files changed, 0 insertions, 305 deletions
diff --git a/internal/file/file.go b/internal/file/file.go
deleted file mode 100644
index 7f86d41..0000000
--- a/internal/file/file.go
+++ /dev/null
@@ -1,305 +0,0 @@
-package file
-
-import (
-	"bytes"
-	"crypto/sha256"
-	"fmt"
-	"log"
-	"os"
-	"os/user"
-	"strconv"
-	"strings"
-	"text/template"
-
-	"codeberg.org/snonux/gonf/internal/resource"
-)
-
-type File struct {
-	path    string
-	param   string
-	source  string
-	user    string
-	group   string
-	mode    os.FileMode
-	modeSet bool
-	absent  bool
-
-	symlink       bool
-	symlinkTarget string
-
-	hardlink       bool
-	hardlinkTarget string
-
-	directory      bool
-	pruneDirectory bool // with Absent(): remove directory recursively
-}
-
-type Option func(*File)
-
-func WithContent(content string) Option {
-	return func(f *File) {
-		f.param = content
-		f.source = ""
-	}
-}
-
-func WithSource(source string) Option {
-	return func(f *File) {
-		if !strings.HasPrefix(source, "source://") {
-			source = "source://" + source
-		}
-		f.source = source
-		f.param = source
-	}
-}
-
-func WithUser(user string) Option {
-	return func(f *File) {
-		f.user = user
-	}
-}
-
-func WithGroup(group string) Option {
-	return func(f *File) {
-		f.group = group
-	}
-}
-
-func WithMode(mode os.FileMode) Option {
-	return func(f *File) {
-		f.mode = mode
-		f.modeSet = true
-	}
-}
-
-func IsAbsent() Option {
-	return func(f *File) {
-		f.absent = true
-	}
-}
-
-func IsDirectory() Option {
-	return func(f *File) {
-		f.directory = true
-	}
-}
-
-func IsSymlink(target string) Option {
-	return func(f *File) {
-		f.symlink = true
-		f.symlinkTarget = target
-	}
-}
-
-func IsHardlink(target string) Option {
-	return func(f *File) {
-		f.hardlink = true
-		f.hardlinkTarget = target
-	}
-}
-
-func PruneDirectory() Option {
-	return func(f *File) {
-		f.pruneDirectory = true
-	}
-}
-
-func Have(path string, opts ...Option) resource.Resource {
-	res, err := have(path, opts...)
-	if err != nil {
-		log.Fatalf("failed to apply file resource %s: %v", path, err)
-	}
-
-	return res
-}
-
-func have(path string, opts ...Option) (resource.Resource, error) {
-	curr, err := user.Current()
-	if err != nil {
-		return resource.Resource{}, fmt.Errorf("failed to get current user for default: %w", err)
-	}
-
-	f := &File{
-		path:  path,
-		mode:  0o640,
-		user:  curr.Username,
-		group: curr.Gid,
-	}
-
-	for _, opt := range opts {
-		opt(f)
-	}
-
-	return f.Apply()
-}
-
-// Apply dispatches to the concrete resource implementation based on the
-// options that were set. Each kind lives in its own file:
-// regular_file.go, directory.go and symlink.go.
-func (f *File) Apply() (resource.Resource, error) {
-	var res resource.Resource
-
-	switch {
-	case f.absent:
-		res = resource.Register(f.resourceType(), f.path)
-		return res, f.haveAbsent()
-
-	case f.symlink:
-		res = resource.Register("Symlink", f.path)
-		return res, f.haveSymlink()
-
-	case f.hardlink:
-		res = resource.Register("Hardlink", f.path)
-		return res, f.haveHardlink()
-
-	case f.directory:
-		if !f.modeSet {
-			f.mode = 0o750
-		}
-		res = resource.Register("Directory", f.path)
-		return res, f.haveDirectory()
-
-	default:
-		res = resource.Register("File", f.path)
-		content, err := f.resolveContent()
-		if err != nil {
-			return res, fmt.Errorf("failed to resolve content for %s: %w", f.path, err)
-		}
-		return res, f.haveRegularFile(content)
-	}
-}
-
-// resourceType returns the registry type name for this resource, used when the
-// concrete kind matters for registration (e.g. absent works for any kind).
-func (f *File) resourceType() string {
-	switch {
-	case f.symlink:
-		return "Symlink"
-	case f.hardlink:
-		return "Hardlink"
-	case f.directory:
-		return "Directory"
-	default:
-		return "File"
-	}
-}
-
-func (f *File) resolveContent() ([]byte, error) {
-	var content []byte
-	var err error
-
-	if strings.HasPrefix(f.param, "source://") {
-		sourcePath := strings.TrimPrefix(f.param, "source://")
-		content, err = os.ReadFile(sourcePath)
-		if err != nil {
-			return nil, fmt.Errorf("failed to read source file %s: %w", sourcePath, err)
-		}
-	} else {
-		content = []byte(f.param)
-	}
-
-	if strings.HasSuffix(f.path, ".tmpl") || (strings.HasPrefix(f.param, "source://") && strings.HasSuffix(strings.TrimPrefix(f.param, "source://"), ".tmpl")) {
-		return f.applyTemplate(content)
-	}
-
-	return content, nil
-}
-
-func (f *File) applyTemplate(content []byte) ([]byte, error) {
-	data := make(map[string]string)
-	for _, env := range os.Environ() {
-		pair := strings.SplitN(env, "=", 2)
-		if len(pair) == 2 {
-			data[pair[0]] = pair[1]
-		}
-	}
-	data["Param"] = f.param
-
-	tmpl, err := template.New("resource").Parse(string(content))
-	if err != nil {
-		return nil, fmt.Errorf("template parse error: %w", err)
-	}
-
-	var buf bytes.Buffer
-	if err := tmpl.Execute(&buf, data); err != nil {
-		return nil, fmt.Errorf("template execute error: %w", err)
-	}
-	return buf.Bytes(), nil
-}
-
-func (f *File) applyAttributes() error {
-	// Apply Mode
-	if err := os.Chmod(f.path, f.mode); err != nil {
-		return fmt.Errorf("failed to chmod %s to %v: %w", f.path, f.mode, err)
-	}
-	log.Printf("set mode %v for %s", f.mode, f.path)
-
-	// Apply User and Group
-	uid, gid := -1, -1
-
-	if f.user != "" {
-		u, err := user.Lookup(f.user)
-		if err != nil {
-			return fmt.Errorf("failed to lookup user %s: %w", f.user, err)
-		}
-		uid, _ = strconv.Atoi(u.Uid)
-	}
-
-	if f.group != "" {
-		gidInt, err := strconv.Atoi(f.group)
-		if err != nil {
-			return fmt.Errorf("group must be numeric for now: %s", f.group)
-		}
-		gid = gidInt
-	}
-
-	if err := os.Chown(f.path, uid, gid); err != nil {
-		return fmt.Errorf("failed to chown %s to %s:%s: %w", f.path, f.user, f.group, err)
-	}
-	log.Printf("set owner %s:%s for %s", f.user, f.group, f.path)
-
-	return nil
-}
-
-func getChecksum(path string) [32]byte {
-	var checksum [32]byte
-	data, err := os.ReadFile(path)
-	if err != nil {
-		log.Printf("reading %s: %v (file does not exist or cannot be read)", path, err)
-		return checksum
-	}
-	checksum = sha256.Sum256(data)
-	log.Printf("computed checksum for %s: %x", path, checksum)
-	return checksum
-}
-
-func writeTmpFile(tmpPath string, content []byte, mode os.FileMode) error {
-	log.Printf("writing %d bytes to temporary file %s with mode %v", len(content), tmpPath, mode)
-	if err := os.WriteFile(tmpPath, content, mode); err != nil {
-		log.Printf("failed to write temporary file %s: %v", tmpPath, err)
-		return err
-	}
-	log.Printf("successfully wrote temporary file %s", tmpPath)
-	return nil
-}
-
-func updateFromTmp(tmpPath, path string, checksumChanged bool) error {
-	if !checksumChanged {
-		log.Printf("checksums match, removing temporary file %s", tmpPath)
-		if err := os.Remove(tmpPath); err != nil {
-			log.Printf("failed to remove temporary file %s: %v", tmpPath, err)
-			return err
-		}
-		log.Printf("no changes needed for %s", path)
-		return nil
-	}
-
-	log.Printf("checksums differ, renaming %s to %s", tmpPath, path)
-	if err := os.Rename(tmpPath, path); err != nil {
-		log.Printf("failed to rename %s to %s: %v", tmpPath, path, err)
-		os.Remove(tmpPath)
-		return err
-	}
-	log.Printf("successfully updated %s", path)
-	return nil
-}