// Package tflint embeds execution of tflint, which is under an MPL license, and you can
// find its source code at https://github.com/terraform-linters/tflint
package tflint

import (
	"context"
	"fmt"
	"path/filepath"
	"slices"
	"strings"

	"github.com/gruntwork-io/terragrunt/internal/runner/runcfg"
	"github.com/gruntwork-io/terragrunt/internal/shell"
	"github.com/gruntwork-io/terragrunt/internal/vexec"
	"github.com/gruntwork-io/terragrunt/internal/writer"
	"github.com/gruntwork-io/terragrunt/pkg/log"

	"github.com/gruntwork-io/terragrunt/internal/errors"
	"github.com/gruntwork-io/terragrunt/internal/util"
)

// TFLintOptions contains the subset of configuration needed by tflint execution.
type TFLintOptions struct {
	ShellOptions         *shell.ShellOptions
	Writers              writer.Writers
	WorkingDir           string
	RootWorkingDir       string
	TerragruntConfigPath string
	MaxFoldersToCheck    int
}

const (
	// tfVarPrefix Prefix to use for terraform variables set with environment variables.
	tfVarPrefix      = "TF_VAR_"
	argVarPrefix     = "-var="
	argVarFilePrefix = "-var-file="
	tfExternalTFLint = "--terragrunt-external-tflint"
)

// RunTflintWithOpts runs tflint with the given options and returns an error if there are any issues.
func RunTflintWithOpts(
	ctx context.Context,
	l log.Logger,
	opts *TFLintOptions,
	cfg *runcfg.RunConfig,
	hook *runcfg.Hook,
) error {
	hookExecute := slices.Clone(hook.Execute)
	hookExecute = slices.DeleteFunc(hookExecute, func(arg string) bool {
		return arg == tfExternalTFLint
	})

	// try to fetch configuration file from hook parameters
	configFile, err := tflintConfigFilePath(l, opts, hookExecute)
	if err != nil {
		return err
	}

	l.Debugf("Using .tflint.hcl file in %s",
		util.RelPathForLog(opts.RootWorkingDir, configFile, opts.Writers.LogShowAbsPaths))

	variables, err := InputsToTflintVar(cfg.Inputs)
	if err != nil {
		return err
	}

	tfVariables, err := tfArgumentsToTflintVar(l, hook, &cfg.Terraform)
	if err != nil {
		return err
	}

	l.Debugf(
		"Initializing tflint in directory %s",
		util.RelPathForLog(opts.RootWorkingDir, opts.WorkingDir, opts.Writers.LogShowAbsPaths),
	)

	tflintArgs := hookExecute[1:]

	configFileRel := util.RelPathForLog(opts.WorkingDir, configFile, opts.Writers.LogShowAbsPaths)
	chdirRel := util.RelPathForLog(opts.RootWorkingDir, opts.WorkingDir, opts.Writers.LogShowAbsPaths)

	// tflint init
	initArgs := []string{"tflint", "--init", "--config", configFileRel, "--chdir", chdirRel}
	l.Debugf("Running external tflint init with args %v", initArgs)

	_, err = shell.RunCommandWithOutput(ctx, l, vexec.NewOSExec(), opts.ShellOptions, opts.RootWorkingDir, false, false,
		initArgs[0], initArgs[1:]...)
	if err != nil {
		return errors.New(ErrorRunningTflint{Args: initArgs, Err: err})
	}

	// tflint execution
	args := make([]string, 0, 5+len(variables)+len(tfVariables)+len(tflintArgs))
	args = append(args,
		"tflint",
		"--config", configFileRel,
		"--chdir", chdirRel,
	)
	args = append(args, variables...)
	args = append(args, tfVariables...)
	args = append(args, tflintArgs...)

	l.Debugf("Running external tflint with args %v", args)

	_, err = shell.RunCommandWithOutput(ctx, l, vexec.NewOSExec(), opts.ShellOptions, opts.RootWorkingDir, false, false,
		args[0], args[1:]...)
	if err != nil {
		return errors.New(ErrorRunningTflint{Args: args, Err: err})
	}

	l.Info("Tflint has run successfully. No issues found.")

	return nil
}

// InputsToTflintVar converts the inputs map to a list of tflint variables.
func InputsToTflintVar(inputs map[string]any) ([]string, error) {
	variables := make([]string, 0, len(inputs))

	for key, value := range inputs {
		varValue, err := util.AsTerraformEnvVarJSONValue(value)
		if err != nil {
			return nil, err
		}

		newVar := fmt.Sprintf("--var=%s=%s", key, varValue)
		variables = append(variables, newVar)
	}

	return variables, nil
}

// Custom error types

type ErrorRunningTflint struct {
	Err  error
	Args []string
}

func (err ErrorRunningTflint) Error() string {
	if err.Err != nil {
		return fmt.Sprintf("Error encountered while running tflint with args: '%v': %s", err.Args, err.Err)
	}

	return fmt.Sprintf("Error encountered while running tflint with args: '%v'", err.Args)
}

func (err ErrorRunningTflint) Unwrap() error {
	return err.Err
}

type IssuesFound struct{}

func (err IssuesFound) Error() string {
	return "Tflint found issues in the project. Check for the tflint logs."
}

type UnknownError struct {
	statusCode int
}

func (err UnknownError) Error() string {
	return fmt.Sprintf("Unknown status code from tflint: %d", err.statusCode)
}

type ConfigNotFound struct {
	cause string
}

func (err ConfigNotFound) Error() string {
	return "Could not find .tflint.hcl config file in the parent folders: " + err.cause
}

// tfArgumentsToTflintVar converts variables from the terraform config to a list of tflint variables.
func tfArgumentsToTflintVar(l log.Logger, hook *runcfg.Hook,
	tfCfg *runcfg.TerraformConfig) ([]string, error) {
	var variables []string

	for i := range tfCfg.ExtraArgs {
		arg := &tfCfg.ExtraArgs[i]
		// use extra args which will be used on same command as hook
		if !slices.ContainsFunc(arg.Commands, func(cmd string) bool {
			return slices.Contains(hook.Commands, cmd)
		}) {
			continue
		}

		if len(arg.EnvVars) > 0 {
			// extract env_vars
			for name, value := range arg.EnvVars {
				if after, ok := strings.CutPrefix(name, tfVarPrefix); ok {
					varName := after

					varValue, err := util.AsTerraformEnvVarJSONValue(value)
					if err != nil {
						return nil, err
					}

					newVar := fmt.Sprintf("--var='%s=%s'", varName, varValue)
					variables = append(variables, newVar)
				}
			}
		}

		if len(arg.Arguments) > 0 {
			// extract variables and var files from arguments
			for _, value := range arg.Arguments {
				if after, ok := strings.CutPrefix(value, argVarPrefix); ok {
					varName := after
					newVar := fmt.Sprintf("--var='%s'", varName)
					variables = append(variables, newVar)
				}

				if after, ok := strings.CutPrefix(value, argVarFilePrefix); ok {
					varName := after
					newVar := "--var-file=" + varName
					variables = append(variables, newVar)
				}
			}
		}

		if len(arg.RequiredVarFiles) > 0 {
			// extract required variables
			for _, file := range arg.RequiredVarFiles {
				newVar := "--var-file=" + file
				variables = append(variables, newVar)
			}
		}

		if len(arg.OptionalVarFiles) > 0 {
			// extract optional variables
			for _, file := range util.RemoveDuplicatesKeepLast(arg.OptionalVarFiles) {
				if util.FileExists(file) {
					newVar := "--var-file=" + file
					variables = append(variables, newVar)
				} else {
					l.Debugf("Skipping tflint var-file %s as it does not exist", file)
				}
			}
		}
	}

	return variables, nil
}

// findTflintConfigInProject looks for a .tflint.hcl file in the current
// folder or it's parents. When running from cache, we start searching
// from the original config directory to find config in the source directory.
func findTflintConfigInProject(l log.Logger, opts *TFLintOptions) (string, error) {
	startDir := opts.WorkingDir
	if opts.TerragruntConfigPath != "" {
		startDir = filepath.Dir(opts.TerragruntConfigPath)
	}

	previousDir := startDir

	// To avoid getting into an accidental infinite loop (e.g. do to cyclical symlinks), set a max on the number of
	// parent folders we'll check
	for range opts.MaxFoldersToCheck {
		currentDir := filepath.Dir(previousDir)
		l.Debugf("Finding .tflint.hcl file from %s and going to %s",
			util.RelPathForLog(opts.RootWorkingDir, previousDir, opts.Writers.LogShowAbsPaths),
			util.RelPathForLog(opts.RootWorkingDir, currentDir, opts.Writers.LogShowAbsPaths))

		if currentDir == previousDir {
			return "", errors.New(ConfigNotFound{cause: "Traversed all the day to the root"})
		}

		fileToFind := filepath.Join(previousDir, ".tflint.hcl")
		if util.FileExists(fileToFind) {
			l.Debugf("Found .tflint.hcl in %s",
				util.RelPathForLog(opts.RootWorkingDir, fileToFind, opts.Writers.LogShowAbsPaths))

			return fileToFind, nil
		}

		previousDir = currentDir
	}

	return "", errors.New(ConfigNotFound{
		cause: fmt.Sprintf("Exceeded maximum folders to check (%d)", opts.MaxFoldersToCheck),
	})
}

// tflintConfigFilePath returns the configuration file specified in --config argument
func tflintConfigFilePath(l log.Logger, opts *TFLintOptions, arguments []string) (string, error) {
	for i, arg := range arguments {
		if arg == "--config" && len(arguments) > i+1 {
			return arguments[i+1], nil
		}
	}
	// find .tflint.hcl configuration in project files if it is not provided in arguments
	projectConfigFile, err := findTflintConfigInProject(l, opts)
	if err != nil {
		return "", err
	}

	return projectConfigFile, nil
}
