package main

import (
	"fmt"
	"io/ioutil"
	"net/http"
	"os"
	"os/exec"
	"strings"
	"time"

	"github.com/docker/docker/integration-cli/requirement"
	"github.com/go-check/check"
)

func PlatformIs(platform string) bool {
	return testEnv.DaemonPlatform() == platform
}

func ArchitectureIs(arch string) bool {
	return os.Getenv("DOCKER_ENGINE_GOARCH") == arch
}

func ArchitectureIsNot(arch string) bool {
	return os.Getenv("DOCKER_ENGINE_GOARCH") != arch
}

func StorageDriverIs(storageDriver string) bool {
	return strings.HasPrefix(testEnv.DaemonStorageDriver(), storageDriver)
}

func StorageDriverIsNot(storageDriver string) bool {
	return !strings.HasPrefix(testEnv.DaemonStorageDriver(), storageDriver)
}

func DaemonIsWindows() bool {
	return PlatformIs("windows")
}

func DaemonIsLinux() bool {
	return PlatformIs("linux")
}

func ExperimentalDaemon() bool {
	return testEnv.ExperimentalDaemon()
}

func NotExperimentalDaemon() bool {
	return !testEnv.ExperimentalDaemon()
}

func IsAmd64() bool {
	return ArchitectureIs("amd64")
}

func NotArm() bool {
	return ArchitectureIsNot("arm")
}

func NotArm64() bool {
	return ArchitectureIsNot("arm64")
}

func NotPpc64le() bool {
	return ArchitectureIsNot("ppc64le")
}

func NotS390X() bool {
	return ArchitectureIsNot("s390x")
}

func SameHostDaemon() bool {
	return testEnv.LocalDaemon()
}

func UnixCli() bool {
	return isUnixCli
}

func ExecSupport() bool {
	return supportsExec
}

func Network() bool {
	// Set a timeout on the GET at 15s
	var timeout = time.Duration(15 * time.Second)
	var url = "https://hub.docker.com"

	client := http.Client{
		Timeout: timeout,
	}

	resp, err := client.Get(url)
	if err != nil && strings.Contains(err.Error(), "use of closed network connection") {
		panic(fmt.Sprintf("Timeout for GET request on %s", url))
	}
	if resp != nil {
		resp.Body.Close()
	}
	return err == nil
}

func Apparmor() bool {
	buf, err := ioutil.ReadFile("/sys/module/apparmor/parameters/enabled")
	return err == nil && len(buf) > 1 && buf[0] == 'Y'
}

func NotaryHosting() bool {
	// for now notary binary is built only if we're running inside
	// container through `make test`. Figure that out by testing if
	// notary-server binary is in PATH.
	_, err := exec.LookPath(notaryServerBinary)
	return err == nil
}

func NotaryServerHosting() bool {
	// for now notary-server binary is built only if we're running inside
	// container through `make test`. Figure that out by testing if
	// notary-server binary is in PATH.
	_, err := exec.LookPath(notaryServerBinary)
	return err == nil
}

func NotOverlay() bool {
	return StorageDriverIsNot("overlay")
}

func Devicemapper() bool {
	return StorageDriverIs("devicemapper")
}

func IPv6() bool {
	cmd := exec.Command("test", "-f", "/proc/net/if_inet6")
	return cmd.Run() != nil
}

func UserNamespaceROMount() bool {
	// quick case--userns not enabled in this test run
	if os.Getenv("DOCKER_REMAP_ROOT") == "" {
		return true
	}
	if _, _, err := dockerCmdWithError("run", "--rm", "--read-only", "busybox", "date"); err != nil {
		return false
	}
	return true
}

func NotUserNamespace() bool {
	root := os.Getenv("DOCKER_REMAP_ROOT")
	return root == ""
}

func UserNamespaceInKernel() bool {
	if _, err := os.Stat("/proc/self/uid_map"); os.IsNotExist(err) {
		/*
		 * This kernel-provided file only exists if user namespaces are
		 * supported
		 */
		return false
	}

	// We need extra check on redhat based distributions
	if f, err := os.Open("/sys/module/user_namespace/parameters/enable"); err == nil {
		defer f.Close()
		b := make([]byte, 1)
		_, _ = f.Read(b)
		return string(b) != "N"
	}

	return true
}

func IsPausable() bool {
	if testEnv.DaemonPlatform() == "windows" {
		return testEnv.Isolation() == "hyperv"
	}
	return true
}

func NotPausable() bool {
	if testEnv.DaemonPlatform() == "windows" {
		return testEnv.Isolation() == "process"
	}
	return false
}

func IsolationIs(expectedIsolation string) bool {
	return testEnv.DaemonPlatform() == "windows" && string(testEnv.Isolation()) == expectedIsolation
}

func IsolationIsHyperv() bool {
	return IsolationIs("hyperv")
}

func IsolationIsProcess() bool {
	return IsolationIs("process")
}

// testRequires checks if the environment satisfies the requirements
// for the test to run or skips the tests.
func testRequires(c *check.C, requirements ...requirement.Test) {
	requirement.Is(c, requirements...)
}