internal/services: Populate Ceph state struct

Signed-off-by: Mathias Gibbens <mathias.gibbens@futurfusion.io>

Author: gibmat

incus-osd/internal/services/service_ceph.go

@@ -8,6 +8,9 @@ import (
 	"path/filepath"
 	"strings"
 
+	"github.com/lxc/incus/v7/shared/subprocess"
+	"go.yaml.in/yaml/v4"
+
 	"github.com/lxc/incus-os/incus-osd/api"
 	"github.com/lxc/incus-os/incus-osd/internal/state"
 )
@@ -20,12 +23,35 @@ type Ceph struct {
 }
 
 // Get returns the current service state.
-func (n *Ceph) Get(_ context.Context) (any, error) {
+func (n *Ceph) Get(ctx context.Context) (any, error) {
 	// Initialize target list if missing.
 	if n.state.Services.Ceph.Config.Clusters == nil {
 		n.state.Services.Ceph.Config.Clusters = map[string]api.ServiceCephCluster{}
 	}
 
+	// Get current Ceph cluster status. The JSON output is too verbose, while
+	// the plain text output is almost valid yaml (missing quotation of values).
+	output, err := subprocess.RunCommandContext(ctx, "ceph", "status")
+	if err == nil {
+		lines := strings.Split(output, "\n")
+
+		for i := range lines {
+			parts := strings.SplitN(lines[i], ":", 2)
+
+			if len(parts) != 2 {
+				continue
+			}
+
+			if len(parts[1]) > 0 {
+				parts[1] = ` "` + strings.TrimSpace(parts[1]) + `"`
+			}
+
+			lines[i] = parts[0] + ":" + parts[1]
+		}
+
+		_ = yaml.Load([]byte(strings.Join(lines, "\n")), &n.state.Services.Ceph.State)
+	}
+
 	return n.state.Services.Ceph, nil
 }