Cleanup post rebase to remove redundant methods and install D-Bus

Signed-off-by: Kate Goldenring <[email protected]>

Author: kate-goldenring

cmd/node-installer/install.go

@@ -116,6 +116,14 @@ func RunInstall(config Config, rootFs, hostFs afero.Fs, restarter containerd.Res
 		return nil
 	}
 
+	// Ensure D-Bus is installed and running if using systemd
+	if _, err := containerd.ListSystemdUnits(); err == nil {
+		err = containerd.InstallDbus()
+		if err != nil {
+			return fmt.Errorf("failed to install D-Bus: %w", err)
+		}
+	}
+
 	slog.Info("restarting containerd")
 	err = containerdConfig.RestartRuntime()
 	if err != nil {

internal/containerd/install_dbus.go

@@ -3,20 +3,8 @@ package containerd
 import (
 	"fmt"
 	"log/slog"
-	"os"
-	"os/exec"
 )
 
-// UsesSystemd checks if the system is using systemd.
-func UsesSystemd() bool {
-	cmd := nsenterCmd("systemctl", "list-units", "|", "grep", "-q", "containerd.service")
-	if err := cmd.Run(); err != nil {
-		slog.Info("Error with systemctl: %w\n", "error", err)
-		return false
-	}
-	return true
-}
-
 // InstallDbus checks if D-Bus service is installed and active. If not, installs D-Bus
 // and starts the service.
 // NOTE: this limits support to systems using systemctl to manage systemd.
@@ -63,8 +51,3 @@ func InstallDbus() error {
 
 	return nil
 }
-
-func nsenterCmd(cmd ...string) *exec.Cmd {
-	return exec.Command("nsenter",
-		append([]string{fmt.Sprintf("-m/%s/proc/1/ns/mnt", os.Getenv("HOST_ROOT")), "--"}, cmd...)...) // #nosec G204
-}

internal/containerd/restart_unix.go

@@ -40,7 +40,7 @@ func NewDefaultRestarter() Restarter {
 
 func (c defaultRestarter) Restart() error {
 	// If listing systemd units succeeds, prefer systemctl restart; otherwise kill pid
-	if _, err := listSystemdUnits(); err == nil {
+	if _, err := ListSystemdUnits(); err == nil {
 		out, err := nsenterCmd("systemctl", "restart", "containerd").CombinedOutput()
 		slog.Debug(string(out))
 		if err != nil {
@@ -67,7 +67,7 @@ type K0sRestarter struct{}
 func (c K0sRestarter) Restart() error {
 	// First, collect systemd units to determine which mode k0s is running in, eg
 	// k0sworker or k0scontroller
-	units, err := listSystemdUnits()
+	units, err := ListSystemdUnits()
 	if err != nil {
 		return fmt.Errorf("unable to list systemd units: %w", err)
 	}
@@ -88,7 +88,7 @@ func (c K3sRestarter) Restart() error {
 	// This restarter will be used both for stock K3s distros, which use systemd as well as K3d, which does not.
 
 	// If listing systemd units succeeds, prefer systemctl restart; otherwise kill pid
-	if _, err := listSystemdUnits(); err == nil {
+	if _, err := ListSystemdUnits(); err == nil {
 		out, err := nsenterCmd("systemctl", "restart", "k3s").CombinedOutput()
 		slog.Debug(string(out))
 		if err != nil {
@@ -130,7 +130,7 @@ type RKE2Restarter struct{}
 func (c RKE2Restarter) Restart() error {
 	// First, collect systemd units to determine which mode rke2 is running in, eg
 	// rke2-agent or rke2-server
-	units, err := listSystemdUnits()
+	units, err := ListSystemdUnits()
 	if err != nil {
 		return fmt.Errorf("unable to list systemd units: %w", err)
 	}
@@ -145,7 +145,7 @@ func (c RKE2Restarter) Restart() error {
 	return nil
 }
 
-func listSystemdUnits() ([]byte, error) {
+func ListSystemdUnits() ([]byte, error) {
 	return nsenterCmd("systemctl", "list-units", "--type", "service").CombinedOutput()
 }
 

internal/controller/shim_controller.go

@@ -380,6 +380,8 @@ func (sr *ShimReconciler) setOperationConfiguration(shim *rcmv1.Shim, opConfig *
 }
 
 // createJobManifest creates a Job manifest for a Shim.
+//
+//nolint:funlen // function is longer due to scaffolding an entire K8s Job manifest
 func (sr *ShimReconciler) createJobManifest(shim *rcmv1.Shim, node *corev1.Node, operation string) (*batchv1.Job, error) {
 	opConfig := opConfig{
 		operation:  operation,