func EnableStaticPods()

in projects/aws/bottlerocket-bootstrap/pkg/utils/pods.go [16:57]
36 lines of code
7 McCabe index (conditional complexity)

func EnableStaticPods(path string) ([]*v1.Pod, error) {
	var podDefinitions []*v1.Pod
	fmt.Println("Enabling static pods on host")

	files, err := ioutil.ReadDir(path)
	if err != nil {
		return podDefinitions, errors.Wrap(err, "error reading from manifest path")
	}

	for _, f := range files {
		if !isPodFile(f) {
			continue
		}

		baseFileName := strings.TrimSuffix(f.Name(), filepath.Ext(f.Name()))
		// Read the manifest and base64 encode it
		fileData, err := ioutil.ReadFile(filepath.Join(path, f.Name()))
		if err != nil {
			return podDefinitions, errors.Wrapf(err, "Error reading file %s", f.Name())
		}
		b64Manifest := base64.StdEncoding.EncodeToString(fileData)
		fmt.Println("Enabling static pod " + baseFileName)
		fmt.Println("-------------------------------")
		fmt.Printf("Manifest string: \n%s\n", string(fileData))
		fmt.Println("-------------------------------")
		fmt.Printf("Encoded string: \n%s\n", b64Manifest)
		cmd := exec.Command("bash", "-c", "apiclient set \"kubernetes.static-pods."+baseFileName+".manifest\"=\""+b64Manifest+"\" \"kubernetes.static-pods."+baseFileName+".enabled\"=true")
		out, err := cmd.CombinedOutput()
		if err != nil {
			fmt.Printf("Apiclient command for static pod failed, output: %s\n", string(out))
			return podDefinitions, errors.Wrapf(err, "error running apiclient command for static pod: %v", err)
		}

		// Parse manifest from file and add to array
		podDef, err := UnmarshalPodDefinition(fileData)
		if err != nil {
			return podDefinitions, errors.Wrap(err, "Error getting pod def from manifest")
		}
		podDefinitions = append(podDefinitions, podDef)
	}
	return podDefinitions, nil
}