Function TestCloneRepo

operator/controllers/source_controller_test.go:358–390

(t *testing.T)

}

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

	t.Run("rejects invalid url before running git", func(t *testing.T) {
		err := r.cloneRepo(ctx, newSourceRepo("-oProxyCommand=evil", "main"), filepath.Join(t.TempDir(), "clone"), nil)
		if err == nil || !strings.Contains(err.Error(), "unsupported repository URL") {
			t.Fatalf("expected URL validation error, got %v", err)
		}
	})

	t.Run("surfaces parent dir creation failure", func(t *testing.T) {
		blocker := filepath.Join(t.TempDir(), "blocker")
		writeTestFile(t, blocker, "not a directory\n")
		err := r.cloneRepo(ctx, newSourceRepo("https://example.com/repo.git", "main"),
			filepath.Join(blocker, "sub", "clone"), nil)
		if err == nil || !strings.Contains(err.Error(), "creating clone parent dir") {
			t.Fatalf("expected mkdir error, got %v", err)
		}
	})

	t.Run("surfaces git clone failure", func(t *testing.T) {
		cloneCtx, cancel := context.WithTimeout(ctx, 30*time.Second)
		defer cancel()
		// Port 1 is reserved and never listening: the clone fails fast
		// with a connection error instead of touching the network.
		err := r.cloneRepo(cloneCtx, newSourceRepo("https://127.0.0.1:1/repo.git", "main"),
			filepath.Join(t.TempDir(), "clone"), nil)
		if err == nil || !strings.Contains(err.Error(), "git clone failed") {
			t.Fatalf("expected git clone error, got %v", err)
		}
	})
}

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