Function TestPullRepo

operator/controllers/source_controller_test.go:321–356

(t *testing.T)

}

func TestPullRepo(t *testing.T) {
	r := &SourceRepositoryReconciler{}
	ctx := context.Background()

	t.Run("rejects invalid url before touching git", func(t *testing.T) {
		err := r.pullRepo(ctx, newSourceRepo("file:///etc", ""), t.TempDir(), nil)
		if err == nil || !strings.Contains(err.Error(), "repository URL must use") {
			t.Fatalf("expected URL validation error, got %v", err)
		}
	})

	t.Run("fetch failure on a non-repo directory", func(t *testing.T) {
		err := r.pullRepo(ctx, newSourceRepo("https://example.com/repo.git", "main"), t.TempDir(), nil)
		if err == nil || !strings.Contains(err.Error(), "git fetch") {
			t.Fatalf("expected git fetch error, got %v", err)
		}
	})

	t.Run("fetches and resets from origin", func(t *testing.T) {
		origin := newLocalGitRepo(t)
		work := t.TempDir()
		runGit(t, work, "-c", "init.defaultBranch=main", "init")
		// file:// (instead of a bare path) forces the smart transport,
		// which supports the shallow fetch pullRepo performs.
		runGit(t, work, "remote", "add", "origin", "file://"+origin)

		// Branch defaulting: empty Spec.Branch must resolve to main.
		repo := newSourceRepo("https://example.com/repo.git", "")
		if err := r.pullRepo(ctx, repo, work, nil); err != nil {
			t.Fatalf("pullRepo: %v", err)
		}
		if _, err := os.Stat(filepath.Join(work, "main.go")); err != nil {
			t.Errorf("expected main.go after reset --hard origin/main: %v", err)
		}
	})
}

func TestCloneRepo(t *testing.T) {
	r := &SourceRepositoryReconciler{}