test: add e2e case of declarative database with delete retain policy

Signed-off-by: Gabriele Quaresima <[email protected]>

tests/e2e/declarative_database_management_test.go

@@ -32,11 +32,13 @@ import (
 // - spinning up a cluster, apply a declarative database on it
 
 // Set of tests in which we use the declarative database CRD to add new databases on an existing cluster
-var _ = Describe("Declarative databases management test", Label(tests.LabelSmoke, tests.LabelBasic), func() {
+var _ = Describe("Declarative databases management test", Label(tests.LabelSmoke, tests.LabelBasic,
+	tests.LabelDeclarativeDatabase), func() {
 	const (
-		clusterManifest  = fixturesDir + "/declarative_databases/cluster.yaml.template"
-		databaseManifest = fixturesDir + "/declarative_databases/database.yaml.template"
-		level            = tests.Medium
+		clusterManifest                         = fixturesDir + "/declarative_databases/cluster.yaml.template"
+		databaseManifest                        = fixturesDir + "/declarative_databases/database.yaml.template"
+		databaseManifestWithDeleteReclaimPolicy = fixturesDir + "/declarative_databases/database-with-delete-reclaim-policy.yaml.template"
+		level                                   = tests.Medium
 	)
 
 	BeforeEach(func() {
@@ -47,13 +49,15 @@ var _ = Describe("Declarative databases management test", Label(tests.LabelSmoke
 
 	Context("plain vanilla cluster", Ordered, func() {
 		const (
-			namespacePrefix = "declarative-db"
-			databaseCrdName = "db-declarative"
-			dbname          = "declarative"
+			namespacePrefix                       = "declarative-db"
+			databaseCrdName                       = "db-declarative"
+			databaseWithDeleteRetainPolicyCrdName = "db-declarative-delete"
+			dbname                                = "declarative"
 		)
 		var (
-			clusterName, namespace string
-			database               *apiv1.Database
+			clusterName, namespace         string
+			database                       *apiv1.Database
+			databaseWithDeleteRetainPolicy *apiv1.Database
 		)
 
 		BeforeAll(func() {
@@ -110,7 +114,7 @@ var _ = Describe("Declarative databases management test", Label(tests.LabelSmoke
 					}, 300).WithPolling(10 * time.Second).Should(Succeed())
 				})
 
-				By("verifying new database has been added", func() {
+				By("verifying the db exists", func() {
 					primaryPodInfo, err := env.GetClusterPrimary(namespace, clusterName)
 					Expect(err).ToNot(HaveOccurred())
 
@@ -123,13 +127,79 @@ var _ = Describe("Declarative databases management test", Label(tests.LabelSmoke
 					Expect(utils.DeleteObject(env, database)).To(Succeed())
 				})
 
-				By("verifying database is still existing", func() {
+				By("verifying db is still existing", func() {
 					primaryPodInfo, err := env.GetClusterPrimary(namespace, clusterName)
 					Expect(err).ToNot(HaveOccurred())
 
 					assertDatabaseExists(namespace, primaryPodInfo.Name, dbname, true)
 				})
 			})
 		})
+		When("Database CRD reclaim policy is set to delete inside spec", func() {
+			It("can add a declarative database", func() {
+				By("applying Database CRD manifest", func() {
+					CreateResourceFromFile(namespace, databaseManifestWithDeleteReclaimPolicy)
+					_, err := env.GetResourceNameFromYAML(databaseManifestWithDeleteReclaimPolicy)
+					Expect(err).NotTo(HaveOccurred())
+				})
+				By("ensuring the Database CRD succeeded reconciliation", func() {
+					// get database object
+					databaseWithDeleteRetainPolicy = &apiv1.Database{}
+					databaseNamespacedName := types.NamespacedName{
+						Namespace: namespace,
+						Name:      databaseWithDeleteRetainPolicyCrdName,
+					}
+
+					Eventually(func(g Gomega) {
+						err := env.Client.Get(env.Ctx, databaseNamespacedName, databaseWithDeleteRetainPolicy)
+						Expect(err).ToNot(HaveOccurred())
+						g.Expect(databaseWithDeleteRetainPolicy.Status.Ready).Should(BeTrue())
+					}, 300).WithPolling(10 * time.Second).Should(Succeed())
+				})
+
+				By("verifying the db exists", func() {
+					primaryPodInfo, err := env.GetClusterPrimary(namespace, clusterName)
+					Expect(err).ToNot(HaveOccurred())
+
+					assertDatabaseExists(namespace, primaryPodInfo.Name, dbname, true)
+				})
+			})
+
+			It("maintains the db when Database CRD is removed", func() {
+				By("remove Database CRD", func() {
+					Expect(utils.DeleteObject(env, databaseWithDeleteRetainPolicy)).To(Succeed())
+				})
+
+				By("verifying db has been removed", func() {
+					primaryPodInfo, err := env.GetClusterPrimary(namespace, clusterName)
+					Expect(err).ToNot(HaveOccurred())
+
+					assertDatabaseExists(namespace, primaryPodInfo.Name, dbname, false)
+				})
+			})
+
+			It("applies the Database CRD one last time to exercise finalizers removal when the namespace "+
+				"will be deleted", func() {
+				By("applying Database CRD manifest", func() {
+					CreateResourceFromFile(namespace, databaseManifestWithDeleteReclaimPolicy)
+					_, err := env.GetResourceNameFromYAML(databaseManifestWithDeleteReclaimPolicy)
+					Expect(err).NotTo(HaveOccurred())
+				})
+				By("ensuring the Database CRD succeeded reconciliation", func() {
+					// get database object
+					databaseWithDeleteRetainPolicy = &apiv1.Database{}
+					databaseNamespacedName := types.NamespacedName{
+						Namespace: namespace,
+						Name:      databaseWithDeleteRetainPolicyCrdName,
+					}
+
+					Eventually(func(g Gomega) {
+						err := env.Client.Get(env.Ctx, databaseNamespacedName, databaseWithDeleteRetainPolicy)
+						Expect(err).ToNot(HaveOccurred())
+						g.Expect(databaseWithDeleteRetainPolicy.Status.Ready).Should(BeTrue())
+					}, 300).WithPolling(10 * time.Second).Should(Succeed())
+				})
+			})
+		})
 	})
 })

tests/e2e/fixtures/declarative_databases/database-with-delete-reclaim-policy.yaml.template

@@ -0,0 +1,10 @@
+apiVersion: postgresql.cnpg.io/v1
+kind: Database
+metadata:
+  name: db-declarative
+spec:
+  name: declarative
+  owner: app
+  databaseReclaimPolicy: delete
+  cluster:
+    name: cluster-with-declarative-databases

tests/labels.go

@@ -23,12 +23,15 @@ const (
 	// LabelBackupRestore is a label for only selecting backup and restore tests
 	LabelBackupRestore = "backup-restore"
 
-	// LabelBasic is a label for  selecting basic test
+	// LabelBasic is a label for selecting basic test
 	LabelBasic = "basic"
 
 	// LabelClusterMetadata is a label for selecting cluster-metadata test
 	LabelClusterMetadata = "cluster-metadata"
 
+	// LabelDeclarativeDatabase is a label for selecting the test exercising declarative databases
+	LabelDeclarativeDatabase = "declarative-databases"
+
 	// LabelDisruptive is the string for labelling disruptive tests
 	LabelDisruptive = "disruptive"
 
@@ -74,7 +77,7 @@ const (
 	// LabelServiceConnectivity is a label for selecting service connections test
 	LabelServiceConnectivity = "service-connectivity"
 
-	// LabelSmoke is a label for selecting  smoke test
+	// LabelSmoke is a label for selecting smoke test
 	LabelSmoke = "smoke"
 
 	// LabelSnapshot is a label for selecting snapshot tests
@@ -83,9 +86,9 @@ const (
 	// LabelStorage is a label for selecting storage test
 	LabelStorage = "storage"
 
-	// LabelTablespaces is a lable for selectin the tablespaces tests
+	// LabelTablespaces is a label for selecting the tablespaces tests
 	LabelTablespaces = "tablespaces"
 
-	// LabelUpgrade is the string for labelling upgrade tests
+	// LabelUpgrade is a label for upgrade tests
 	LabelUpgrade = "upgrade"
 )