Adapt code and unit tests

Signed-off-by: David Cassany <[email protected]>

Author: davidcassany

cmd/config/config.go

@@ -300,7 +300,7 @@ func ReadUpgradeSpec(r *v1.RunConfig, flags *pflag.FlagSet) (*v1.UpgradeSpec, er
 		return nil, fmt.Errorf("failed sanitizing upgrade spec: %v", err)
 	}
 
-	err = config.ReconcileUpgradeSpec(upgrade)
+	err = config.ReconcileUpgradeSpec(r, upgrade)
 	r.Logger.Debugf("Loaded upgrade UpgradeSpec: %s", litter.Sdump(upgrade))
 	return upgrade, err
 }

cmd/config/config_test.go

@@ -61,9 +61,7 @@ var _ = Describe("Config", Label("config"), func() {
 
 				up, err := ReadUpgradeSpec(cfg, nil)
 				Expect(err).Should(HaveOccurred(), litter.Sdump(cfg))
-
-				Expect(up.GrubDefEntry).To(Equal("so"))
-				Expect(up.Active.Size).To(Equal(uint(2000)), litter.Sdump(up))
+				Expect(up).To(BeNil())
 
 				inst, err := ReadInstallSpec(cfg, nil)
 				Expect(err).Should(HaveOccurred(), litter.Sdump(cfg))
@@ -438,7 +436,7 @@ var _ = Describe("Config", Label("config"), func() {
 				ghwTest.CreateDevices()
 				defer ghwTest.Clean()
 
-				err := os.Setenv("ELEMENTAL_UPGRADE_RECOVERY", "true")
+				Expect(os.Setenv("ELEMENTAL_UPGRADE_RECOVERY", "true")).To(Succeed())
 				spec, err := ReadUpgradeSpec(cfg, nil)
 				Expect(err).ShouldNot(HaveOccurred())
 				// Overwrites recovery-system image, flags have priority over files and env vars

pkg/config/config.go

@@ -18,7 +18,6 @@ package config
 
 import (
 	"fmt"
-	"os/exec"
 	"path/filepath"
 	"runtime"
 	"strings"
@@ -597,34 +596,34 @@ func NewBuildConfig(opts ...GenericOptions) *v1.BuildConfig {
 
 // ReconcileUpgradeSpec will check current mounts which may differ from elemental disovery from /sys/block tree
 // as this skips multipathed devices which may be in use.
-func ReconcileUpgradeSpec(spec *v1.UpgradeSpec) error {
+func ReconcileUpgradeSpec(r *v1.RunConfig, spec *v1.UpgradeSpec) error {
 	if spec.Partitions.State != nil {
-		if err := reconcilePartition(spec.Partitions.State); err != nil {
+		if err := reconcilePartition(r, spec.Partitions.State); err != nil {
 			return err
 		}
 	}
 	if spec.Partitions.Recovery != nil {
-		if err := reconcilePartition(spec.Partitions.Recovery); err != nil {
+		if err := reconcilePartition(r, spec.Partitions.Recovery); err != nil {
 			return err
 		}
 	}
 
 	if spec.Partitions.Persistent != nil {
-		if err := reconcilePartition(spec.Partitions.Persistent); err != nil {
+		if err := reconcilePartition(r, spec.Partitions.Persistent); err != nil {
 			return err
 		}
 	}
 
 	if spec.Partitions.OEM != nil {
-		if err := reconcilePartition(spec.Partitions.OEM); err != nil {
+		if err := reconcilePartition(r, spec.Partitions.OEM); err != nil {
 			return err
 		}
 	}
 	return nil
 }
 
-func reconcilePartition(part *v1.Partition) error {
-	discoveredMountDiskBytes, err := execBlkid(part.FilesystemLabel)
+func reconcilePartition(r *v1.RunConfig, part *v1.Partition) error {
+	discoveredMountDiskBytes, err := execBlkid(r, part.FilesystemLabel)
 	if err != nil {
 		return fmt.Errorf("error discovering current partition using label %s: %w", part.FilesystemLabel, err)
 	}
@@ -636,12 +635,10 @@ func reconcilePartition(part *v1.Partition) error {
 	}
 	return nil
 }
-func execBlkid(name string) ([]byte, error) {
-	path, err := exec.LookPath("blkid")
-	if err != nil {
-		return nil, err
+func execBlkid(r *v1.RunConfig, name string) ([]byte, error) {
+	if ok := r.Config.Runner.CommandExists("blkid"); ok {
+		return r.Config.Runner.Run("blkid", "-L", name)
 	}
 
-	blkidCmd := exec.Command(path, "-L", name)
-	return blkidCmd.Output()
+	return []byte{}, fmt.Errorf("blkid not found")
 }