BigChef/utils/modifycommand.go

package utils

import (
	"fmt"
	"modify/logger"
	"os"

	"github.com/bmatcuk/doublestar/v4"
)

type ModifyCommand struct {
	Pattern  string   `yaml:"pattern"`
	LuaExpr  string   `yaml:"lua"`
	Files    []string `yaml:"files"`
	Git      bool     `yaml:"git"`
	Reset    bool     `yaml:"reset"`
	LogLevel string   `yaml:"loglevel"`
}
type CookFile []ModifyCommand

func (c *ModifyCommand) Validate() error {
	if c.Pattern == "" {
		return fmt.Errorf("pattern is required")
	}
	if c.LuaExpr == "" {
		return fmt.Errorf("lua expression is required")
	}
	if len(c.Files) == 0 {
		return fmt.Errorf("at least one file is required")
	}
	if c.LogLevel == "" {
		c.LogLevel = "INFO"
	}
	return nil
}

func AssociateFilesWithCommands(files []string, commands []ModifyCommand) (map[string][]ModifyCommand, error) {
	associationCount := 0
	fileCommands := make(map[string][]ModifyCommand)
	for _, file := range files {
		for _, command := range commands {
			for _, glob := range command.Files {
				// TODO: Maybe memoize this function call
				matches, err := doublestar.Match(glob, file)
				if err != nil {
					logger.Trace("Failed to match glob %s with file %s: %v", glob, file, err)
					continue
				}
				if matches {
					logger.Debug("Found match for file %q and command %q", file, command.Pattern)
					fileCommands[file] = append(fileCommands[file], command)
					associationCount++
				}
			}
		}
		logger.Debug("Found %d commands for file %q", len(fileCommands[file]), file)
		if len(fileCommands[file]) == 0 {
			logger.Info("No commands found for file %q", file)
		}
	}
	logger.Info("Found %d associations between %d files and %d commands", associationCount, len(files), len(commands))
	return fileCommands, nil
}

func AggregateGlobs(commands []ModifyCommand) map[string]struct{} {
	logger.Info("Aggregating globs for %d commands", len(commands))
	globs := make(map[string]struct{})
	for _, command := range commands {
		for _, glob := range command.Files {
			globs[glob] = struct{}{}
		}
	}
	logger.Info("Found %d unique globs", len(globs))
	return globs
}

func ExpandGLobs(patterns map[string]struct{}) ([]string, error) {
	var files []string
	filesMap := make(map[string]bool)

	cwd, err := os.Getwd()
	if err != nil {
		return nil, fmt.Errorf("failed to get current working directory: %w", err)
	}

	logger.Debug("Expanding patterns from directory: %s", cwd)
	for pattern := range patterns {
		logger.Trace("Processing pattern: %s", pattern)
		matches, _ := doublestar.Glob(os.DirFS(cwd), pattern)
		logger.Debug("Found %d matches for pattern %s", len(matches), pattern)
		for _, m := range matches {
			info, err := os.Stat(m)
			if err != nil {
				logger.Warning("Error getting file info for %s: %v", m, err)
				continue
			}
			if !info.IsDir() && !filesMap[m] {
				logger.Trace("Adding file to process list: %s", m)
				filesMap[m], files = true, append(files, m)
			}
		}
	}

	if len(files) > 0 {
		logger.Debug("Found %d files to process: %v", len(files), files)
	}
	return files, nil
}

func LoadCommands(args []string) ([]ModifyCommand, error) {
	commands := []ModifyCommand{}

	logger.Info("Loading commands from cook files: %s", *Cookfile)
	newcommands, err := LoadCommandsFromCookFiles(*Cookfile)
	if err != nil {
		return nil, fmt.Errorf("failed to load commands from cook files: %w", err)
	}
	logger.Info("Successfully loaded %d commands from cook files", len(newcommands))
	commands = append(commands, newcommands...)
	logger.Info("Now total commands: %d", len(commands))

	logger.Info("Loading commands from arguments: %v", args)
	newcommands, err = LoadCommandFromArgs(args)
	if err != nil {
		return nil, fmt.Errorf("failed to load commands from args: %w", err)
	}
	logger.Info("Successfully loaded %d commands from args", len(newcommands))
	commands = append(commands, newcommands...)
	logger.Info("Now total commands: %d", len(commands))

	return commands, nil
}

func LoadCommandFromArgs(args []string) ([]ModifyCommand, error) {
	// Cannot reset without git, right?
	if *ResetFlag {
		*GitFlag = true
	}

	if len(args) < 3 {
		return nil, fmt.Errorf("at least %d arguments are required", 3)
	}

	command := ModifyCommand{
		Pattern:  args[0],
		LuaExpr:  args[1],
		Files:    args[2:],
		Git:      *GitFlag,
		Reset:    *ResetFlag,
		LogLevel: *LogLevel,
	}

	if err := command.Validate(); err != nil {
		return nil, fmt.Errorf("invalid command: %w", err)
	}

	return []ModifyCommand{command}, nil
}

func LoadCommandsFromCookFiles(s string) ([]ModifyCommand, error) {
	return nil, nil
}