K8SPG-781 add TestGetLatestCommitTimestamp (#1309)

Author: gkech

percona/watcher/wal.go

@@ -162,6 +162,7 @@ func getLatestBackup(ctx context.Context, cli client.Client, cr *pgv2.PerconaPGC
 	return latest, nil
 }
 
+// GetLatestCommitTimestamp gets the timestamp of the latest commit.
 func GetLatestCommitTimestamp(ctx context.Context, cli client.Client, execCli *clientcmd.Client, cr *pgv2.PerconaPGCluster, backup *pgv2.PerconaPGBackup) (*metav1.Time, error) {
 	log := logging.FromContext(ctx)
 

percona/watcher/wal_test.go

@@ -2,6 +2,7 @@ package watcher
 
 import (
 	"context"
+	"errors"
 	"testing"
 	"time"
 
@@ -310,3 +311,49 @@ func TestGetLatestBackup(t *testing.T) {
 		})
 	}
 }
+
+func TestGetLatestCommitTimestamp(t *testing.T) {
+	ctx := context.Background()
+
+	tests := map[string]struct {
+		pods        []client.Object
+		backup      *pgv2.PerconaPGBackup
+		cluster     *pgv2.PerconaPGCluster
+		expectedErr error
+	}{
+		"primary pod not found due to invalid patroni version": {
+			pods: []client.Object{},
+			backup: &pgv2.PerconaPGBackup{
+				ObjectMeta: metav1.ObjectMeta{
+					Name:      "backup1",
+					Namespace: "test-ns",
+				},
+				Spec: pgv2.PerconaPGBackupSpec{
+					PGCluster: "test-cluster",
+					RepoName:  "repo1",
+				},
+			},
+			cluster: &pgv2.PerconaPGCluster{
+				ObjectMeta: metav1.ObjectMeta{
+					Name:      "test-cluster",
+					Namespace: "test-ns",
+				},
+				Status: pgv2.PerconaPGClusterStatus{
+					Patroni: pgv2.Patroni{
+						Version: "error",
+					},
+				},
+			},
+			expectedErr: errors.New("failed to get patroni version: Malformed version: error: primary pod not found"),
+		},
+	}
+	for name, tt := range tests {
+		t.Run(name, func(t *testing.T) {
+			c := testutils.BuildFakeClient(tt.pods...)
+
+			_, err := GetLatestCommitTimestamp(ctx, c, nil, tt.cluster, tt.backup)
+
+			assert.EqualError(t, err, tt.expectedErr.Error())
+		})
+	}
+}