feat: wip

Author: oxyno-zeta

api/postgresql/v1alpha1/postgresqlbackup_types.go

@@ -29,8 +29,6 @@ import (
 type PostgresqlBackupSpec struct {
 	// Schedule for cronjob
 	Schedule string `json:"schedule"`
-	// One shot backup ?
-	OneShot bool `json:"oneShot"`
 	// Postgresql Database
 	// +required
 	// +kubebuilder:validation:Required

config/crd/bases/postgresql.easymile.com_postgresqlbackups.yaml

@@ -63,16 +63,12 @@ spec:
                 required:
                 - name
                 type: object
-              oneShot:
-                description: One shot backup ?
-                type: boolean
               schedule:
                 description: Schedule for cronjob
                 type: string
             required:
             - backupProvider
             - database
-            - oneShot
             - schedule
             type: object
           status:

internal/controller/postgresql/postgresqlbackup_controller.go

@@ -33,6 +33,7 @@ import (
 
 	postgresqlv1alpha1 "github.com/easymile/postgresql-operator/api/postgresql/v1alpha1"
 	"github.com/easymile/postgresql-operator/internal/controller/config"
+	"github.com/easymile/postgresql-operator/internal/controller/utils"
 )
 
 // PostgresqlBackupReconciler reconciles a PostgresqlBackup object.
@@ -151,6 +152,34 @@ func (r *PostgresqlBackupReconciler) mainReconcile(
 		return ctrl.Result{}, nil
 	}
 
+	// Get related database
+	database, err := utils.FindPgDatabaseFromLink(ctx, r.Client, instance.Spec.Database, instance.Namespace)
+	// Check error
+	if err != nil {
+		return r.manageError(ctx, reqLogger, instance, originalPatch, err)
+	}
+
+	// Find pgec
+	pgec, err := utils.FindPgEngineCfg(ctx, r.Client, database)
+	// Check error
+	if err != nil {
+		return r.manageError(ctx, reqLogger, instance, originalPatch, err)
+	}
+
+	// Find pgec secret
+	pgecSecret, err := utils.FindSecretPgEngineCfg(ctx, r.Client, pgec)
+	// Check error
+	if err != nil {
+		return r.manageError(ctx, reqLogger, instance, originalPatch, err)
+	}
+
+	// Get related provider
+	backupProvider, err := utils.FindPgBackupProviderFromLink(ctx, r.Client, instance.Spec.BackupProvider, instance.Namespace)
+	// Check error
+	if err != nil {
+		return r.manageError(ctx, reqLogger, instance, originalPatch, err)
+	}
+
 	// Compute spec hash
 
 	// Success

internal/controller/utils/utils.go

@@ -144,3 +144,25 @@ func FindPgDatabaseFromLink(
 
 	return pgDatabase, err
 }
+
+func FindPgBackupProviderFromLink(
+	ctx context.Context,
+	cl client.Client,
+	link *common.CRLink,
+	instanceNamespace string,
+) (*postgresqlv1alpha1.PostgresqlBackupProvider, error) {
+	// Try to get namespace from spec
+	namespace := link.Namespace
+	if namespace == "" {
+		// Namespace not found, take it from instance namespace
+		namespace = instanceNamespace
+	}
+
+	item := &postgresqlv1alpha1.PostgresqlBackupProvider{}
+	err := cl.Get(ctx, client.ObjectKey{
+		Name:      link.Name,
+		Namespace: namespace,
+	}, item)
+
+	return item, err
+}