Function TestGetNodeDisks

pkg/api/node_disks_test.go:14–70

nolint:dupl // Test structure similarity is acceptable

(t *testing.T)

//nolint:dupl // Test structure similarity is acceptable
func TestGetNodeDisks(t *testing.T) {
	mockResponse := `{
		"data": [
			{
				"devpath": "/dev/sda",
				"health": "PASSED",
				"model": "Samsung SSD 860",
				"serial": "S4XBNF0M123456",
				"size": 500107862016,
				"type": "ssd",
				"used": "partitions"
			}
		]
	}`

	server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		if r.URL.Path == testAPITicketPath {
			_, _ = w.Write([]byte(`{"data":{"ticket":"ticket","CSRFPreventionToken":"token","username":"user@pam"}}`))
			return
		}
		if r.URL.Path != "/api2/json/nodes/pve1/disks/list" {
			t.Errorf("Expected path /api2/json/nodes/pve1/disks/list, got %s", r.URL.Path)
		}
		_, _ = w.Write([]byte(mockResponse))
	}))
	defer server.Close()

	mockConfig := &MockConfig{
		Addr:     server.URL,
		User:     "user",
		Password: "password",
		Realm:    "pam",
		Insecure: true,
	}
	// Important: Provide a NoOpCache to avoid nil pointer panic
	client, err := NewClient(mockConfig, WithCache(&interfaces.NoOpCache{}))
	if err != nil {
		t.Fatalf("NewClient failed: %v", err)
	}

	disks, err := client.GetNodeDisks("pve1")
	if err != nil {
		t.Fatalf("GetNodeDisks failed: %v", err)
	}

	if len(disks) != 1 {
		t.Fatalf("Expected 1 disk, got %d", len(disks))
	}

	if disks[0].Model != "Samsung SSD 860" {
		t.Errorf("Expected model 'Samsung SSD 860', got '%s'", disks[0].Model)
	}

	if disks[0].Size != 500107862016 {
		t.Errorf("Expected size 500107862016, got %d", disks[0].Size)
	}
}