func parseKubeGitVersionContent()

in release/pkg/kube_reader.go [55:99]

• 44 lines of code
• 13 McCabe index (conditional complexity)

func parseKubeGitVersionContent(input io.Reader) (*kubeGitVersionFile, error) {
	resp := &kubeGitVersionFile{}
	scanner := bufio.NewScanner(input)
	for scanner.Scan() {
		line := scanner.Text()
		parts := strings.SplitN(line, "=", 2)
		if len(parts) != 2 {
			return nil, errors.Errorf("no equal sign in line: %s", line)
		}
		value := strings.Trim(parts[1], `'`)
		switch parts[0] {
		case "KUBE_GIT_COMMIT":
			resp.KubeGitCommit = value
		case "KUBE_GIT_VERSION":
			resp.KubeGitVersion = value
		case "KUBE_GIT_MAJOR":
			val, err := strconv.Atoi(value)
			if err != nil {
				return nil, errors.Wrapf(err, "Could not parse '%s'", value)
			}
			resp.KubeGitMajor = val
		case "KUBE_GIT_MINOR":
			value = strings.ReplaceAll(value, "+", "")
			val, err := strconv.Atoi(value)
			if err != nil {
				return nil, errors.Wrapf(err, "Could not parse '%s'", value)
			}
			resp.KubeGitMinor = val
		case "SOURCE_DATE_EPOCH":
			val, err := strconv.Atoi(value)
			if err != nil {
				return nil, errors.Wrapf(err, "Could not parse '%s'", value)
			}
			resp.SourceDateEpoch = val
		case "KUBE_GIT_TREE_STATE":
			resp.KubeGitTreeState = value
		default:
		}

	}
	if err := scanner.Err(); err != nil {
		return nil, errors.Wrap(err, "Error reading KUBE_GIT_VERSION_FILE")
	}
	return resp, nil
}