resolving wsl_v5 issues

Signed-off-by: Ariel Kass <[email protected]>

Author: Ariel Kass

controllers/secret.go

@@ -29,6 +29,7 @@ import (
 func (r *VolumeReplicationReconciler) getSecret(ctx context.Context, logger logr.Logger, name, namespace string) (map[string]string, error) {
 	namespacedName := types.NamespacedName{Name: name, Namespace: namespace}
 	secret := &corev1.Secret{}
+
 	err := r.Get(ctx, namespacedName, secret)
 	if err != nil {
 		if apierrors.IsNotFound(err) {

controllers/suite_test.go

@@ -74,6 +74,7 @@ var _ = ginkgo.BeforeSuite(func() {
 
 var _ = ginkgo.AfterSuite(func() {
 	ginkgo.By("tearing down the test environment")
+
 	err := testEnv.Stop()
 	gomega.Expect(err).NotTo(gomega.HaveOccurred())
 })

controllers/vg.go

@@ -32,6 +32,7 @@ func (r VolumeReplicationReconciler) getVGDataSource(ctx context.Context, logger
 	*volumegroupv1.VolumeGroup, *volumegroupv1.VolumeGroupContent, error,
 ) {
 	vg := &volumegroupv1.VolumeGroup{}
+
 	err := r.Get(ctx, req, vg)
 	if err != nil {
 		if errors.IsNotFound(err) {
@@ -44,6 +45,7 @@ func (r VolumeReplicationReconciler) getVGDataSource(ctx context.Context, logger
 	vgc := &volumegroupv1.VolumeGroupContent{}
 	volumeGroupContentName := *vg.Spec.Source.VolumeGroupContentName
 	namespacedVGC := types.NamespacedName{Name: volumeGroupContentName, Namespace: vg.Namespace}
+
 	err = r.Get(ctx, namespacedVGC, vgc)
 	if err != nil {
 		if errors.IsNotFound(err) {

controllers/volumereplication_controller.go

@@ -82,6 +82,7 @@ func (r *VolumeReplicationReconciler) Reconcile(ctx context.Context, req ctrl.Re
 
 	// Fetch VolumeReplication instance
 	instance := &replicationv1alpha1.VolumeReplication{}
+
 	err := r.Get(ctx, req.NamespacedName, instance)
 	if err != nil {
 		if errors.IsNotFound(err) {

controllers/volumereplicationclass.go

@@ -31,6 +31,7 @@ import (
 //nolint:gocritic
 func (r VolumeReplicationReconciler) getVolumeReplicationClass(ctx context.Context, logger logr.Logger, vrcName string) (*replicationv1alpha1.VolumeReplicationClass, error) {
 	vrcObj := &replicationv1alpha1.VolumeReplicationClass{}
+
 	err := r.Get(ctx, types.NamespacedName{Name: vrcName}, vrcObj)
 	if err != nil {
 		if errors.IsNotFound(err) {

controllers/volumereplicationclass_test.go

@@ -63,6 +63,7 @@ func TestGetVolumeReplicaClass(t *testing.T) {
 		}
 
 		reconciler := createFakeVolumeReplicationReconciler(t, objects...)
+
 		vrcObj, err := reconciler.getVolumeReplicationClass(context.TODO(), reconciler.Log, mockVolumeReplicationClassObj.Name)
 
 		if tc.errorExpected {

pkg/client/replication-client_test.go

@@ -35,6 +35,7 @@ func TestEnableVolumeReplication(t *testing.T) {
 		},
 	}
 	client := mockedEnableReplication
+
 	resp, err := client.EnableVolumeReplication("", "", nil, nil)
 	require.Equal(t, &replicationlib.EnableVolumeReplicationResponse{}, resp)
 	require.NoError(t, err)
@@ -60,6 +61,7 @@ func TestDisableVolumeReplication(t *testing.T) {
 		},
 	}
 	client := mockedDisableReplication
+
 	resp, err := client.DisableVolumeReplication("", "", nil, nil)
 	require.Equal(t, &replicationlib.DisableVolumeReplicationResponse{}, resp)
 	require.NoError(t, err)
@@ -85,6 +87,7 @@ func TestPromoteVolume(t *testing.T) {
 		},
 	}
 	client := mockedPromoteVolume
+
 	resp, err := client.PromoteVolume("", "", false, nil, nil)
 	require.Equal(t, &replicationlib.PromoteVolumeResponse{}, resp)
 	require.NoError(t, err)
@@ -110,6 +113,7 @@ func TestDemoteVolume(t *testing.T) {
 		},
 	}
 	client := mockedDemoteVolume
+
 	resp, err := client.DemoteVolume("", "", nil, nil)
 	require.Equal(t, &replicationlib.DemoteVolumeResponse{}, resp)
 	require.NoError(t, err)
@@ -135,6 +139,7 @@ func TestResyncVolume(t *testing.T) {
 		},
 	}
 	client := mockedResyncVolume
+
 	resp, err := client.ResyncVolume("", "", nil, nil)
 	require.Equal(t, &replicationlib.ResyncVolumeResponse{}, resp)
 	require.NoError(t, err)