package core

import (
	"bytes"
	"context"
	"errors"
	"fmt"
	"io"
	"io/fs"
	"os"
	"os/exec"
	"path/filepath"
	"sort"
	"strings"
	"time"

	"github.com/Masterminds/semver/v3"

	shellquote "github.com/kballard/go-shellquote"
)

// TimeNow is a func type for time.Now
type TimeNow func() time.Time

type EditorRunner interface {
	Run() error
}

var (
	ErrBadVersionOrPart      = errors.New("part string is not a supported version or version increment")
	ErrMissingAutoLevel      = errors.New("kind config missing auto level value for auto bumping")
	ErrNoChangesFoundForAuto = errors.New("no unreleased changes found for automatic bumping")
	ErrKindNotFound          = errors.New("kind not found but configuration expects one")
)

var (
	bom = []byte{0xef, 0xbb, 0xbf}
)

func AppendFile(rootFile io.Writer, path string) error {
	otherFile, err := os.Open(path)
	if err != nil {
		return err
	}
	defer otherFile.Close()

	_, err = io.Copy(rootFile, otherFile)

	return err
}

func GetAllVersions(
	config *Config,
	skipPrereleases bool,
	projectKey string,
) ([]*semver.Version, error) {
	allVersions := make([]*semver.Version, 0)

	versionsPath := config.ChangesDir
	if len(projectKey) > 0 {
		versionsPath = filepath.Join(versionsPath, projectKey)
	}

	fileInfos, err := os.ReadDir(versionsPath)
	if err != nil && errors.Is(err, fs.ErrNotExist) {
		return allVersions, nil
	}

	if err != nil {
		return allVersions, fmt.Errorf("reading files from '%s': %w", versionsPath, err)
	}

	for _, file := range fileInfos {
		if file.Name() == config.HeaderPath || file.IsDir() {
			continue
		}

		versionString := strings.TrimSuffix(file.Name(), filepath.Ext(file.Name()))

		v, err := semver.NewVersion(versionString)
		if err != nil {
			continue
		}

		if skipPrereleases && v.Prerelease() != "" {
			continue
		}

		allVersions = append(allVersions, v)
	}

	sort.Sort(sort.Reverse(semver.Collection(allVersions)))

	return allVersions, nil
}

func GetLatestVersion(
	config *Config,
	skipPrereleases bool,
	projectKey string,
) (*semver.Version, error) {
	allVersions, err := GetAllVersions(config, skipPrereleases, projectKey)
	if err != nil {
		return nil, err
	}

	// if no versions exist default to v0.0.0
	if len(allVersions) == 0 {
		return semver.MustParse("v0.0.0"), nil
	}

	return allVersions[0], nil
}

func ValidBumpLevel(level string) bool {
	return level == MajorLevel ||
		level == MinorLevel ||
		level == PatchLevel ||
		level == AutoLevel
}

func HighestAutoLevel(config *Config, allChanges []Change) (string, error) {
	if len(allChanges) == 0 {
		return "", ErrNoChangesFoundForAuto
	}

	highestLevel := EmptyLevel
	err := ErrNoChangesFoundForAuto

	for _, change := range allChanges {
		for _, kc := range config.Kinds {
			if kc.KeyOrLabel() != change.Kind {
				continue
			}

			switch kc.AutoLevel {
			case MajorLevel:
				// major is the highest one, so we can just return it
				return MajorLevel, nil
			case PatchLevel:
				if highestLevel == EmptyLevel {
					highestLevel = PatchLevel
					err = nil
				}
			case MinorLevel:
				// bump to minor if we have a minor level
				if highestLevel == PatchLevel || highestLevel == EmptyLevel {
					highestLevel = MinorLevel
					err = nil
				}
			case EmptyLevel:
				return EmptyLevel, ErrMissingAutoLevel
			}
		}
	}

	return highestLevel, err
}

func GetNextVersion(
	config *Config,
	partOrVersion string,
	prerelease, meta []string,
	allChanges []Change,
	projectKey string,
) (*semver.Version, error) {
	var (
		err  error
		next *semver.Version
		ver  semver.Version
	)

	// if part or version is a valid version, then return it
	next, err = semver.NewVersion(partOrVersion)
	if err != nil {
		if !ValidBumpLevel(partOrVersion) {
			return nil, ErrBadVersionOrPart
		}

		// otherwise use a bump type command
		next, err = GetLatestVersion(config, false, projectKey)
		if err != nil {
			return nil, err
		}

		if partOrVersion == AutoLevel {
			partOrVersion, err = HighestAutoLevel(config, allChanges)
			if err != nil {
				return nil, err
			}
		}

		switch partOrVersion {
		case MajorLevel:
			ver = next.IncMajor()
		case MinorLevel:
			ver = next.IncMinor()
		case PatchLevel:
			ver = next.IncPatch()
		}

		next = &ver
	}

	if len(prerelease) > 0 {
		ver, err = next.SetPrerelease(strings.Join(prerelease, "."))
		if err != nil {
			return nil, err
		}

		next = &ver
	}

	if len(meta) > 0 {
		ver, err = next.SetMetadata(strings.Join(meta, "."))
		if err != nil {
			return nil, err
		}

		next = &ver
	}

	return next, nil
}

func FindChangeFiles(
	config *Config,
	searchPaths []string,
) ([]string, error) {
	var yamlFiles []string

	// add the unreleased path to any search paths included
	searchPaths = append(searchPaths, config.UnreleasedDir)

	// read all yaml files from our search paths
	for _, searchPath := range searchPaths {
		rootPath := filepath.Join(config.ChangesDir, searchPath)

		fileInfos, err := os.ReadDir(rootPath)
		if err != nil {
			return yamlFiles, err
		}

		for _, file := range fileInfos {
			if filepath.Ext(file.Name()) != ".yaml" {
				continue
			}

			path := filepath.Join(rootPath, file.Name())
			yamlFiles = append(yamlFiles, path)
		}
	}

	return yamlFiles, nil
}

func WriteNewlines(writer io.Writer, lines int) error {
	if lines == 0 {
		return nil
	}

	_, err := writer.Write([]byte(strings.Repeat("\n", lines)))

	return err
}

func EnvVarMap(environ []string) map[string]string {
	ret := make(map[string]string)

	for _, env := range environ {
		split := strings.SplitN(env, "=", 2)
		ret[split[0]] = split[1]
	}

	return ret
}

func LoadEnvVars(config *Config, envs []string) map[string]string {
	ret := make(map[string]string)
	if config.EnvPrefix == "" {
		return ret
	}

	for k, v := range EnvVarMap(envs) {
		key, found := strings.CutPrefix(k, config.EnvPrefix)
		if found {
			ret[key] = v
		}
	}

	return ret
}

func GetChanges(
	cfg *Config,
	searchPaths []string,
	projectKey string,
) ([]Change, error) {
	var changes []Change

	changeFiles, err := FindChangeFiles(cfg, searchPaths)
	if err != nil {
		return changes, err
	}

	for _, cf := range changeFiles {
		c, err := LoadChange(cf)
		if err != nil {
			return changes, err
		}

		if len(projectKey) > 0 && c.Project != projectKey {
			continue
		}

		c.Env = cfg.EnvVars()

		kc := cfg.KindFromKeyOrLabel(c.KindKey)
		if kc != nil {
			c.KindLabel = kc.Label
		} else if len(cfg.Kinds) > 0 {
			return nil, fmt.Errorf("%w: '%s'", ErrKindNotFound, c.KindKey)
		}

		changes = append(changes, c)
	}

	sort.Slice(changes, ChangeLess(cfg, changes))

	return changes, nil
}

func FileExists(path string) (bool, error) {
	fi, err := os.Stat(path)
	if err == nil {
		return !fi.IsDir(), nil
	}

	if os.IsNotExist(err) {
		return false, nil
	}

	return false, err
}

// createTempFile will create a new temporary file, writing a BOM header if we need to.
// It will return the path to that file or an error.
func createTempFile(runtime string, ext string) (string, error) {
	file, err := os.CreateTemp("", "changie-body-txt-*."+ext)
	if err != nil {
		return "", err
	}

	defer file.Close()

	// The reason why we do this is because notepad.exe on Windows determines the
	// encoding of an "empty" text file by the locale, for example, GBK in China,
	// while golang string only handles utf8 well. However, a text file with utf8
	// BOM header is not considered "empty" on Windows, and the encoding will then
	// be determined utf8 by notepad.exe, instead of GBK or other encodings.
	// This could be enhanced in the future by doing this only when a non-utf8
	// locale is in use, and possibly doing that for any OS, not just windows.
	if runtime == "windows" {
		if _, err = file.Write(bom); err != nil {
			return "", err
		}
	}

	return file.Name(), nil
}

// BuildCommand will create an exec command to run our editor.
func BuildCommand(editorFilePath string) (EditorRunner, error) {
	editor := os.Getenv("EDITOR")
	if editor == "" {
		return nil, errors.New("'EDITOR' env variable not set")
	}

	args, err := shellquote.Split(editor)
	if err != nil {
		return nil, err
	}

	args = append(args, editorFilePath)

	// #nosec G204
	cmd := exec.CommandContext(context.Background(), args[0], args[1:]...)

	// Set the stdin and stdout of the command to the current process's stdin and stdout
	cmd.Stdin = os.Stdin
	cmd.Stdout = os.Stdout

	return cmd, nil
}

// getBodyTextWithEditor will run the provided editor runner and read the final file.
func getBodyTextWithEditor(runner EditorRunner, editorFile string) (string, error) {
	if err := runner.Run(); err != nil {
		return "", fmt.Errorf("opening the editor: %w", err)
	}

	buf, err := os.ReadFile(editorFile)
	if err != nil {
		return "", err
	}

	return strings.TrimSpace(string(bytes.TrimPrefix(buf, bom))), nil
}