package main

import (
	"bufio"
	"bytes"
	"flag"
	"fmt"
	"io"
	"os"
	"os/exec"
	"path"
	"path/filepath"
	"runtime"
	"sync"
)

type testError struct {
	testDir string
	stdout  bytes.Buffer
	stderr  bytes.Buffer
}

func runProcess(prefix string, command string, args ...string) error {
	fmt.Println(fmt.Sprintf("%s: Executing %s %s", prefix, command, args))

	cmd := exec.Command(command, args...)

	stdoutReader, err := cmd.StdoutPipe()
	if err != nil {
		return err
	}

	stderrReader, err := cmd.StderrPipe()
	if err != nil {
		return err
	}

	done := make(chan struct{})

	go func() {
		reader := io.MultiReader(stdoutReader, stderrReader)
		scanner := bufio.NewScanner(reader)
		for scanner.Scan() {
			line := scanner.Bytes()
			fmt.Println(fmt.Sprintf("%s: %s", prefix, line))
		}
		done <- struct{}{}
	}()

	err = cmd.Start()
	if err != nil {
		return err
	}

	<-done

	return cmd.Wait()
}

func contains(haystack []string, needle string) bool {
	for _, s := range haystack {
		if s == needle {
			return true
		}
	}
	return false
}

func runTest(rootDir string, testDir string) error {
	prefix := testDir
	cmdPath := filepath.Join(rootDir, "..", "gomod2nix")
	testDir = filepath.Join(rootDir, testDir)
	err := runProcess(prefix, cmdPath, "--dir", testDir, "--outdir", testDir)
	if err != nil {
		return err
	}

	buildExpr := fmt.Sprintf("with (import <nixpkgs> { overlays = [ (import %s/../overlay.nix) ]; }); callPackage %s {}", rootDir, testDir)
	err = runProcess(prefix, "nix-build", "--no-out-link", "--expr", buildExpr)
	if err != nil {
		return err
	}

	return nil
}

func getTestDirs(rootDir string) ([]string, error) {
	// Takes too long for Github Actions
	var blacklist []string
	if os.Getenv("GITHUB_ACTIONS") == "true" {
		blacklist = []string{
			"helm",
			"minikube",
			"cross",
		}
	}

	files, err := os.ReadDir(rootDir)
	if err != nil {
		return nil, err
	}

	testDirs := []string{}
	for _, f := range files {
		if f.IsDir() && !contains(blacklist, f.Name()) {
			testDirs = append(testDirs, f.Name())
		}
	}

	return testDirs, nil
}

func runTests(rootDir string, testDirs []string) error {
	var wg sync.WaitGroup
	cmdErrChan := make(chan error)
	for _, testDir := range testDirs {
		testDir := testDir
		fmt.Println(fmt.Sprintf("Running test for: '%s'", testDir))
		wg.Add(1)
		go func() {
			defer wg.Done()
			err := runTest(rootDir, testDir)
			if err != nil {
				cmdErrChan <- fmt.Errorf("Test for '%s' failed: %w", testDir, err)
			}
		}()
	}

	go func() {
		wg.Wait()
		close(cmdErrChan)
	}()

	for cmdErr := range cmdErrChan {
		return cmdErr
	}

	return nil
}

func main() {

	var rootDir string
	{
		_, file, _, ok := runtime.Caller(0)
		if !ok {
			panic("Couldn't get test directory")
		}
		rootDir = path.Dir(file)
	}

	flag.Parse()

	nArgs := flag.NArg()

	action := "run"
	if nArgs >= 1 {
		action = flag.Arg(0)
	}

	switch action {
	case "list":
		testDirs, err := getTestDirs(rootDir)
		if err != nil {
			panic(err)
		}

		for _, testDir := range testDirs {
			fmt.Println(testDir)
		}

		return

	case "run":
		var testDirs []string
		var err error
		if nArgs > 1 {
			args := flag.Args()
			testDirs = args[1:nArgs]
		} else {
			testDirs, err = getTestDirs(rootDir)
			if err != nil {
				panic(err)
			}
		}

		err = runTests(rootDir, testDirs)
		if err != nil {
			panic(err)
		}

		return

	default:
		panic(fmt.Errorf("Unhandled action: %s", flag.Arg(0)))
	}

}