skew

var InspectCurrentVersion = func() (*Versions, error) {
	versions := &Versions{}

	cmd := exec.Command("kubectl", []string{"version", "--short"}...)
	out, err := cmd.Output()
	if err != nil {
		return nil, err
	}

	idx := 0
	scanner := bufio.NewScanner(bytes.NewReader(out))
	for scanner.Scan() {
		if idx >= 2 {
			return nil, fmt.Errorf("something wrong: kubectl version --short result is more than 3 lines")
		}

		line := scanner.Text()
		splitted := strings.Split(line, ": ")
		if len(splitted) != 2 {
			return nil, fmt.Errorf("something wrong: kubectl version --short result has unexpected format")
		}

		switch idx {
		case 0:
			if splitted[0] != "Client Version" {
				return nil, fmt.Errorf("something wrong: kubectl version --short result first line is unexpected")
			}
			v, err := semver.NewVersion(splitted[1])
			if err != nil {
				return nil, err
			}
			versions.Client = v
		case 1:
			if splitted[0] != "Server Version" {
				return nil, fmt.Errorf("something wrong: kubectl version --short result second line is unexpected")
			}
			v, err := semver.NewVersion(splitted[1])
			if err != nil {
				return nil, err
			}
			versions.Server = v
		}

		idx++
	}

	if err := scanner.Err(); err != nil {
		return nil, err
	}

	if debugClient != "" {
		dcv, err := semver.NewVersion(debugClient)
		if err != nil {
			return nil, err
		}
		versions.Client = dcv
	}

	if debugServer != "" {
		dsv, err := semver.NewVersion(debugServer)
		if err != nil {
			return nil, err
		}
		versions.Server = dsv
	}

	return versions, nil
}

var InspectLatestVersion = func() (*semver.Version, error) {
	u := "https://dl.k8s.io/release/stable.txt"

	resp, err := http.Get(u)
	if err != nil {
		return nil, err
	}
	defer resp.Body.Close()

	b, err := ioutil.ReadAll(resp.Body)
	if err != nil {
		return nil, err
	}

	v, err := semver.NewVersion(string(b))
	if err != nil {
		return nil, err
	}

	return v, nil
}