test: modify cbt tests (#1863)

Remove vanilla and rancher failover failback tests since they use older way of clusterpair creation and are not good candidate for CBTs. Replaced them with DR tests and also add clone test.

Author: strivedi-px

test/integration_test/common_test.go

@@ -195,13 +195,35 @@ func TestSnapshot(t *testing.T) {
 }
 
 func TestStorkCbt(t *testing.T) {
+	// reset mock time before running any tests
+	err := setMockTime(nil)
+	log.FailOnError(t, err, "Error resetting mock time")
+	currentTestSuite = t.Name()
+
+	err = setSourceKubeConfig()
+	log.FailOnError(t, err, "failed to set kubeconfig to source cluster: %v", err)
+
+	log.InfoD("Using stork volume driver: %s", volumeDriverName)
+	log.InfoD("Backup path being used: %s", backupLocationPath)
+	setDefaultsForBackup(t)
+
+	// get the destination kubeconfig from configmap in source cluster so that it can be passed to storkctl commands
+	// since both the dr cli commands run in destination cluster
+	destinationKubeConfigPath, err = getDestinationKubeConfigFile()
+	log.FailOnError(t, err, "Error getting destination kubeconfig file")
+
+	// Get the source kubeconfig from configmap.
+	srcKubeConfigPath, err = getSourceKubeConfigFile()
+	log.FailOnError(t, err, "Error getting source kubeconfig file")
+
 	t.Run("deploymentTest", deploymentMigrationTest)
 	t.Run("dataExportTest", TestDataExportRsync)
-	t.Run("testMigrationFailoverFailback", testMigrationFailoverFailback)
+	t.Run("testDRActionFailbackIntervalScheduleTest", testDRActionFailbackIntervalScheduleTest)
 	t.Run("stopDriverTest", stopDriverTest)
 	t.Run("simpleSnapshotTest", simpleSnapshotTest)
 	t.Run("pvcOwnershipTest", pvcOwnershipTest)
 	t.Run("cmdExecutorTest", cmdExecutorTest)
+	t.Run("statefulsetTest", statefulsetApplicationCloneTest)
 }
 
 func TestStorkCbtBackup(t *testing.T) {

test/integration_test/migration_dr_actions_test.go

@@ -42,8 +42,8 @@ func TestDRActions(t *testing.T) {
 	log.FailOnError(t, err, "Error getting destination kubeconfig file")
 
 	// Get the source kubeconfig from configmap.
-	srcKubeConfigPath, err = getDestinationKubeConfigFile()
-	log.FailOnError(t, err, "Error getting destination kubeconfig file")
+	srcKubeConfigPath, err = getSourceKubeConfigFile()
+	log.FailOnError(t, err, "Error getting source kubeconfig file")
 
 	t.Run("testSyncDR", testSyncDR)
 	t.Run("testAsyncDR", testAsyncDR)