validate: Test validate clusters

Add fast tests using a mock backend, validating that the report
represent the command result.

Signed-off-by: Nir Soffer <nsoffer@redhat.com>

Author: nirs

pkg/validate/command_test.go

@@ -0,0 +1,118 @@
+// SPDX-FileCopyrightText: The RamenDR authors
+// SPDX-License-Identifier: Apache-2.0
+
+package validate
+
+import (
+	"context"
+	"errors"
+	"testing"
+
+	"github.com/ramendr/ramen/e2e/types"
+
+	"github.com/ramendr/ramenctl/pkg/command"
+	"github.com/ramendr/ramenctl/pkg/config"
+	"github.com/ramendr/ramenctl/pkg/report"
+	"github.com/ramendr/ramenctl/pkg/validation"
+)
+
+var (
+	testConfig = &config.Config{}
+
+	testEnv = &types.Env{
+		Hub: &types.Cluster{Name: "hub"},
+		C1:  &types.Cluster{Name: "c1"},
+		C2:  &types.Cluster{Name: "c2"},
+	}
+
+	validateConfigFailed = &validation.Mock{
+		ValidateFunc: func(ctx validation.Context) error {
+			return errors.New("No validate for you!")
+		},
+	}
+
+	validateConfigCanceled = &validation.Mock{
+		ValidateFunc: func(ctx validation.Context) error {
+			return context.Canceled
+		},
+	}
+)
+
+func TestValidateClustersPassed(t *testing.T) {
+	validate := testCommand(t, "validate-clusters", &validation.Mock{})
+	if err := validate.Clusters(); err != nil {
+		t.Fatal(err)
+	}
+	checkReport(t, validate.report, report.Passed)
+	if len(validate.report.Steps) != 2 {
+		t.Fatalf("unexpected steps %+v", validate.report.Steps)
+	}
+	checkStep(t, validate.report.Steps[0], "validate config", report.Passed)
+	checkStep(t, validate.report.Steps[1], "validate clusters", report.Passed)
+}
+
+func TestValidateClustersFailed(t *testing.T) {
+	validate := testCommand(t, "validate-clusters", validateConfigFailed)
+	if err := validate.Clusters(); err == nil {
+		t.Fatal("command did not fail")
+	}
+	checkReport(t, validate.report, report.Failed)
+	if len(validate.report.Steps) != 1 {
+		t.Fatalf("unexpected steps %+v", validate.report.Steps)
+	}
+	checkStep(t, validate.report.Steps[0], "validate config", report.Failed)
+}
+
+func TestValidateClustersCanceled(t *testing.T) {
+	validate := testCommand(t, "validate-clusters", validateConfigCanceled)
+	if err := validate.Clusters(); err == nil {
+		t.Fatal("command did not fail")
+	}
+	checkReport(t, validate.report, report.Canceled)
+	if len(validate.report.Steps) != 1 {
+		t.Fatalf("unexpected steps %+v", validate.report.Steps)
+	}
+	checkStep(t, validate.report.Steps[0], "validate config", report.Canceled)
+}
+
+func testCommand(t *testing.T, name string, backend validation.Validation) *Command {
+	cmd, err := command.ForTest(name, testEnv, t.TempDir())
+	if err != nil {
+		t.Fatal(err)
+	}
+	t.Cleanup(func() {
+		cmd.Close()
+	})
+	return newCommand(cmd, testConfig, backend)
+}
+
+func checkReport(t *testing.T, report *Report, status report.Status) {
+	if report.Status != status {
+		t.Fatalf("expected status %q, got %q", status, report.Status)
+	}
+	if !report.Config.Equal(testConfig) {
+		t.Fatalf("expected config %q, got %q", testConfig, report.Config)
+	}
+	duration := totalDuration(report.Steps)
+	if report.Duration != duration {
+		t.Fatalf("expected duration %v, got %v", duration, report.Duration)
+	}
+}
+
+func checkStep(t *testing.T, step *report.Step, name string, status report.Status) {
+	if name != step.Name {
+		t.Fatalf("expected step %q, got %q", name, step.Name)
+	}
+	if status != step.Status {
+		t.Fatalf("expected status %q, got %q", status, step.Status)
+	}
+	// We cannot check duration since it may be zero on windows.
+}
+
+func totalDuration(steps []*report.Step) float64 {
+	var total float64
+	for _, step := range steps {
+		total += step.Duration
+	}
+	return total
+}