Use Kibana for version checks if ES is not configured

Author: tobio

internal/clients/api_client.go

@@ -358,6 +358,43 @@ func (a *ApiClient) serverInfo(ctx context.Context) (*models.ClusterInfo, diag.D
 }
 
 func (a *ApiClient) ServerVersion(ctx context.Context) (*version.Version, diag.Diagnostics) {
+	if a.elasticsearch != nil {
+		return a.versionFromElasticsearch(ctx)
+	}
+
+	return a.versionFromKibana()
+}
+
+func (a *ApiClient) versionFromKibana() (*version.Version, diag.Diagnostics) {
+	kibClient, err := a.GetKibanaClient()
+	if err != nil {
+		return nil, diag.FromErr(err)
+	}
+
+	status, err := kibClient.KibanaStatus.Get()
+	if err != nil {
+		return nil, diag.FromErr(err)
+	}
+
+	vMap, ok := status["version"].(map[string]interface{})
+	if !ok {
+		return nil, diag.Errorf("failed to get version from Kibana API")
+	}
+
+	rawVersion, ok := vMap["number"].(string)
+	if !ok {
+		return nil, diag.Errorf("failed to get version number from Kibana status")
+	}
+
+	serverVersion, err := version.NewVersion(rawVersion)
+	if err != nil {
+		return nil, diag.FromErr(err)
+	}
+
+	return serverVersion, nil
+}
+
+func (a *ApiClient) versionFromElasticsearch(ctx context.Context) (*version.Version, diag.Diagnostics) {
 	info, diags := a.serverInfo(ctx)
 	if diags.HasError() {
 		return nil, diags

internal/kibana/alerting_test.go

@@ -189,7 +189,6 @@ func TestAccResourceAlertingRule(t *testing.T) {
 func testAccResourceAlertingRuleCreate(name string) string {
 	return fmt.Sprintf(`
 provider "elasticstack" {
-  elasticsearch {}
   kibana {}
 }
 
@@ -221,7 +220,6 @@ resource "elasticstack_kibana_alerting_rule" "test_rule" {
 func testAccResourceAlertingRuleUpdate(name string) string {
 	return fmt.Sprintf(`
 provider "elasticstack" {
-  elasticsearch {}
   kibana {}
 }
 
@@ -256,7 +254,6 @@ resource "elasticstack_kibana_alerting_rule" "test_rule" {
 func testAccResourceAlertingRuleWithFrequencyCreate(name string) string {
 	return fmt.Sprintf(`
 provider "elasticstack" {
-  elasticsearch {}
   kibana {}
 }
 
@@ -314,7 +311,6 @@ resource "elasticstack_kibana_alerting_rule" "test_rule" {
 func testAccResourceAlertingRuleWithFrequencyUpdate(name string) string {
 	return fmt.Sprintf(`
 provider "elasticstack" {
-  elasticsearch {}
   kibana {}
 }
 
@@ -375,7 +371,6 @@ resource "elasticstack_kibana_alerting_rule" "test_rule" {
 func testAccResourceAlertingRuleWithAlertsFilterCreate(name string) string {
 	return fmt.Sprintf(`
 provider "elasticstack" {
-  elasticsearch {}
   kibana {}
 }
 
@@ -450,7 +445,6 @@ resource "elasticstack_kibana_alerting_rule" "test_rule" {
 func testAccResourceAlertingRuleWithAlertsFilterUpdate(name string) string {
 	return fmt.Sprintf(`
 provider "elasticstack" {
-  elasticsearch {}
   kibana {}
 }
 
@@ -527,7 +521,6 @@ resource "elasticstack_kibana_alerting_rule" "test_rule" {
 func testAccResourceAlertingRuleWithAlertDelayCreate(name string) string {
 	return fmt.Sprintf(`
 provider "elasticstack" {
-  elasticsearch {}
   kibana {}
 }
 
@@ -587,7 +580,6 @@ resource "elasticstack_kibana_alerting_rule" "test_rule" {
 func testAccResourceAlertingRuleWithAlertDelayUpdate(name string) string {
 	return fmt.Sprintf(`
 provider "elasticstack" {
-  elasticsearch {}
   kibana {}
 }