WIP: feat: Implement api2/json/cluster/ceph/status endpoint (#186)

* Add ceph cluster type

Signed-off-by: JustusBunsi <[email protected]>

* Implement actual api endpoint

Signed-off-by: JustusBunsi <[email protected]>

* Add tests

Signed-off-by: JustusBunsi <[email protected]>

---------

Signed-off-by: JustusBunsi <[email protected]>

Author: justusbunsi

ceph.go

@@ -0,0 +1,13 @@
+package proxmox
+
+import "context"
+
+func (ce *Ceph) Status(ctx context.Context) (*ClusterCephStatus, error) {
+	cephStatus := &ClusterCephStatus{}
+
+	if err := ce.client.Get(ctx, "/cluster/ceph/status", cephStatus); !IsNotAuthorized(err) {
+		return cephStatus, err
+	}
+
+	return cephStatus, nil
+}

ceph_test.go

@@ -0,0 +1,46 @@
+package proxmox
+
+import (
+	"context"
+	"testing"
+
+	"github.com/stretchr/testify/assert"
+
+	"github.com/luthermonson/go-proxmox/tests/mocks"
+)
+
+func TestClusterCeph_Status(t *testing.T) {
+	mocks.ProxmoxVE8x(mockConfig)
+	defer mocks.Off()
+	client := mockClient()
+	ctx := context.Background()
+	ceph := Ceph{
+		client: client,
+	}
+
+	expectedOsdNearFullCheck := CephHealthCheck{
+		Detail: []CephHealthCheckDetail{
+			{
+				Message: "osd.3 is near full",
+			},
+			{
+				Message: "osd.8 is near full",
+			},
+			{
+				Message: "osd.9 is near full",
+			},
+		},
+		Muted:    false,
+		Severity: "HEALTH_WARN",
+		Summary: CephHealthCheckSummary{
+			Count:   3,
+			Message: "3 nearfull osd(s)",
+		},
+	}
+
+	actual, err := ceph.Status(ctx)
+	assert.Nil(t, err)
+	assert.Equal(t, "HEALTH_WARN", actual.Health.Status)
+	assert.Equal(t, []string{"proxmox-node01", "proxmox-node03", "proxmox-node02"}, actual.QuorumNames)
+	assert.Equal(t, expectedOsdNearFullCheck, actual.Health.Checks["OSD_NEARFULL"])
+}

cluster.go

@@ -79,3 +79,17 @@ func (cl *Cluster) Tasks(ctx context.Context) (Tasks, error) {
 
 	return tasks, nil
 }
+
+func (cl *Cluster) Ceph(ctx context.Context) (*Ceph, error) {
+	ceph := &Ceph{
+		client: cl.client,
+	}
+
+	// TODO?
+	//// requires (/, Sys.Audit), do not error out if no access to still get the ceph
+	//if err := ceph.Status(ctx); !IsNotAuthorized(err) {
+	//	return ceph, err
+	//}
+
+	return ceph, nil
+}