#4 Add e2e backup and restore test

test/e2e/restorebackup_test.go

@@ -0,0 +1,146 @@
+package e2e
+
+import (
+	"context"
+	"testing"
+
+	"github.com/jenkinsci/kubernetes-operator/pkg/apis/jenkins/v1alpha2"
+	"github.com/jenkinsci/kubernetes-operator/pkg/controller/jenkins/client"
+	"github.com/jenkinsci/kubernetes-operator/pkg/controller/jenkins/configuration/base/resources"
+	"github.com/jenkinsci/kubernetes-operator/pkg/controller/jenkins/constants"
+
+	framework "github.com/operator-framework/operator-sdk/pkg/test"
+	"github.com/stretchr/testify/assert"
+	"github.com/stretchr/testify/require"
+	corev1 "k8s.io/api/core/v1"
+	"k8s.io/apimachinery/pkg/api/resource"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+)
+
+const pvcName = "pvc"
+
+func TestBackupAndRestore(t *testing.T) {
+	t.Parallel()
+	namespace, ctx := setupTest(t)
+	// Deletes test namespace
+	defer ctx.Cleanup()
+
+	createPVC(t, namespace)
+	jenkins := createJenkinsWithBackupAndRestoreConfigured(t, "e2e", namespace)
+	waitForJenkinsUserConfigurationToComplete(t, jenkins)
+	restartJenkinsMasterPod(t, jenkins)
+	waitForRecreateJenkinsMasterPod(t, jenkins)
+	waitForJenkinsUserConfigurationToComplete(t, jenkins)
+	jenkinsClient := verifyJenkinsAPIConnection(t, jenkins)
+	verifyJobBuildsAfterRestoreBackup(t, jenkinsClient)
+}
+
+func verifyJobBuildsAfterRestoreBackup(t *testing.T, jenkins client.Jenkins) {
+	job, err := jenkins.GetJob(constants.UserConfigurationJobName)
+	require.NoError(t, err)
+	build, err := job.GetLastBuild()
+	require.NoError(t, err)
+	assert.Equal(t, int64(2), build.GetBuildNumber())
+
+	job, err = jenkins.GetJob(constants.UserConfigurationCASCJobName)
+	require.NoError(t, err)
+	build, err = job.GetLastBuild()
+	require.NoError(t, err)
+	assert.Equal(t, int64(2), build.GetBuildNumber())
+}
+
+func createPVC(t *testing.T, namespace string) {
+	pvc := &corev1.PersistentVolumeClaim{
+		ObjectMeta: metav1.ObjectMeta{
+			Name:      pvcName,
+			Namespace: namespace,
+		},
+		Spec: corev1.PersistentVolumeClaimSpec{
+			AccessModes: []corev1.PersistentVolumeAccessMode{corev1.ReadWriteOnce},
+			Resources: corev1.ResourceRequirements{
+				Requests: corev1.ResourceList{
+					corev1.ResourceStorage: resource.MustParse("1Gi"),
+				},
+			},
+		},
+	}
+
+	err := framework.Global.Client.Create(context.TODO(), pvc, nil)
+	require.NoError(t, err)
+}
+
+func createJenkinsWithBackupAndRestoreConfigured(t *testing.T, name, namespace string) *v1alpha2.Jenkins {
+	containerName := "backup"
+	jenkins := &v1alpha2.Jenkins{
+		ObjectMeta: metav1.ObjectMeta{
+			Name:      name,
+			Namespace: namespace,
+		},
+		Spec: v1alpha2.JenkinsSpec{
+			Backup: v1alpha2.Backup{
+				ContainerName: containerName,
+				Action: v1alpha2.Handler{
+					Exec: &corev1.ExecAction{
+						Command: []string{"/home/user/bin/backup.sh"},
+					},
+				},
+			},
+			Restore: v1alpha2.Restore{
+				ContainerName: containerName,
+				Action: v1alpha2.Handler{
+					Exec: &corev1.ExecAction{
+						Command: []string{"/home/user/bin/restore.sh"},
+					},
+				},
+			},
+			Master: v1alpha2.JenkinsMaster{
+				Containers: []v1alpha2.Container{
+					{
+						Name: resources.JenkinsMasterContainerName,
+					},
+					{
+						Name:            containerName,
+						Image:           "virtuslab/jenkins-operator-backup-pvc:v0.0.1",
+						ImagePullPolicy: corev1.PullIfNotPresent,
+						Env: []corev1.EnvVar{
+							{
+								Name:  "BACKUP_DIR",
+								Value: "/backup",
+							},
+							{
+								Name:  "JENKINS_HOME",
+								Value: "/jenkins-home",
+							},
+						},
+						VolumeMounts: []corev1.VolumeMount{
+							{
+								Name:      "backup",
+								MountPath: "/backup",
+							},
+							{
+								Name:      "jenkins-home",
+								MountPath: "/jenkins-home",
+							},
+						},
+					},
+				},
+				Volumes: []corev1.Volume{
+					{
+						Name: "backup",
+						VolumeSource: corev1.VolumeSource{
+							PersistentVolumeClaim: &corev1.PersistentVolumeClaimVolumeSource{
+								ClaimName: pvcName,
+							},
+						},
+					},
+				},
+			},
+		},
+	}
+
+	t.Logf("Jenkins CR %+v", *jenkins)
+	err := framework.Global.Client.Create(context.TODO(), jenkins, nil)
+	require.NoError(t, err)
+
+	return jenkins
+}