Use CoralogixReconciler for ApiKey (#416)

Author: assafad1

api/coralogix/object.go

@@ -0,0 +1,28 @@
+// Copyright 2024 Coralogix Ltd.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package coralogix
+
+import (
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"sigs.k8s.io/controller-runtime/pkg/client"
+)
+
+// Object is an interface that extends the client.Object interface with Coralogix-specific methods.
+type Object interface {
+	client.Object
+	HasIDInStatus() bool
+	GetConditions() []metav1.Condition
+	SetConditions(conditions []metav1.Condition)
+}

api/coralogix/v1alpha1/alertscheduler_types.go

@@ -221,6 +221,10 @@ func (a *AlertScheduler) SetConditions(conditions []metav1.Condition) {
 	a.Status.Conditions = conditions
 }
 
+func (a *AlertScheduler) HasIDInStatus() bool {
+	return a.Status.ID != nil && *a.Status.ID != ""
+}
+
 func (a *AlertScheduler) ExtractCreateAlertSchedulerRequest() (*cxsdk.CreateAlertSchedulerRuleRequest, error) {
 	alertScheduler, err := a.extractAlertScheduler()
 	if err != nil {

api/coralogix/v1alpha1/apikey_types.go

@@ -75,6 +75,10 @@ func (a *ApiKey) SetConditions(conditions []metav1.Condition) {
 	a.Status.Conditions = conditions
 }
 
+func (a *ApiKey) HasIDInStatus() bool {
+	return a.Status.Id != nil && *a.Status.Id != ""
+}
+
 // +kubebuilder:object:root=true
 // +kubebuilder:subresource:status
 // ApiKey is the Schema for the ApiKeys API.

api/coralogix/v1alpha1/archivelogstarget_types.go

@@ -96,12 +96,16 @@ func (s *ArchiveLogsTargetSpec) ExtractSetTargetRequest(isTargetActive bool) (*c
 	}, nil
 }
 
-func (i *ArchiveLogsTarget) GetConditions() []metav1.Condition {
-	return i.Status.Conditions
+func (a *ArchiveLogsTarget) GetConditions() []metav1.Condition {
+	return a.Status.Conditions
 }
 
-func (i *ArchiveLogsTarget) SetConditions(conditions []metav1.Condition) {
-	i.Status.Conditions = conditions
+func (a *ArchiveLogsTarget) SetConditions(conditions []metav1.Condition) {
+	a.Status.Conditions = conditions
+}
+
+func (a *ArchiveLogsTarget) HasIDInStatus() bool {
+	return a.Status.ID != nil && *a.Status.ID != ""
 }
 
 // +kubebuilder:object:root=true

api/coralogix/v1alpha1/archivemetricstarget_types.go

@@ -126,12 +126,16 @@ func (s *ArchiveMetricsTargetSpec) ExtractUpdateRequest() (*cxsdk.UpdateTenantRe
 	}, nil
 }
 
-func (i *ArchiveMetricsTarget) GetConditions() []metav1.Condition {
-	return i.Status.Conditions
+func (a *ArchiveMetricsTarget) GetConditions() []metav1.Condition {
+	return a.Status.Conditions
 }
 
-func (i *ArchiveMetricsTarget) SetConditions(conditions []metav1.Condition) {
-	i.Status.Conditions = conditions
+func (a *ArchiveMetricsTarget) SetConditions(conditions []metav1.Condition) {
+	a.Status.Conditions = conditions
+}
+
+func (a *ArchiveMetricsTarget) HasIDInStatus() bool {
+	return a.Status.ID != nil && *a.Status.ID != ""
 }
 
 // +kubebuilder:object:root=true

api/coralogix/v1alpha1/connector_types.go

@@ -89,6 +89,10 @@ func (c *Connector) SetConditions(conditions []metav1.Condition) {
 	c.Status.Conditions = conditions
 }
 
+func (c *Connector) HasIDInStatus() bool {
+	return c.Status.Id != nil && *c.Status.Id != ""
+}
+
 var (
 	schemaToProtoConnectorType = map[string]cxsdk.ConnectorType{
 		"slack":        cxsdk.ConnectorTypeSlack,

api/coralogix/v1alpha1/customrole_types.go

@@ -77,6 +77,10 @@ func (c *CustomRole) SetConditions(conditions []metav1.Condition) {
 	c.Status.Conditions = conditions
 }
 
+func (c *CustomRole) HasIDInStatus() bool {
+	return c.Status.ID != nil && *c.Status.ID != ""
+}
+
 // +kubebuilder:object:root=true
 // +kubebuilder:subresource:status
 

api/coralogix/v1alpha1/dashboard_types.go

@@ -166,6 +166,10 @@ func (d *Dashboard) SetConditions(conditions []metav1.Condition) {
 	d.Status.Conditions = conditions
 }
 
+func (d *Dashboard) HasIDInStatus() bool {
+	return d.Status.ID != nil && *d.Status.ID != ""
+}
+
 // +kubebuilder:object:root=true
 // +kubebuilder:storageversion
 // +kubebuilder:conversion:hub

api/coralogix/v1alpha1/dashboardsfolder_types.go

@@ -101,6 +101,10 @@ func (df *DashboardsFolder) SetConditions(conditions []metav1.Condition) {
 	df.Status.Conditions = conditions
 }
 
+func (df *DashboardsFolder) HasIDInStatus() bool {
+	return df.Status.ID != nil && *df.Status.ID != ""
+}
+
 // +kubebuilder:object:root=true
 // +kubebuilder:subresource:status
 

api/coralogix/v1alpha1/events2metric_types.go

@@ -234,6 +234,10 @@ func (e2m *Events2Metric) SetConditions(conditions []metav1.Condition) {
 	e2m.Status.Conditions = conditions
 }
 
+func (e2m *Events2Metric) HasIDInStatus() bool {
+	return e2m.Status.Id != nil && *e2m.Status.Id != ""
+}
+
 // +kubebuilder:object:root=true
 // +kubebuilder:subresource:status
 // See also https://coralogix.com/docs/user-guides/monitoring-and-insights/events2metrics/