|  | 
|  | 1 | +/* | 
|  | 2 | +Copyright 2025 The Kubernetes Authors. | 
|  | 3 | +
 | 
|  | 4 | +Licensed under the Apache License, Version 2.0 (the "License"); | 
|  | 5 | +you may not use this file except in compliance with the License. | 
|  | 6 | +You may obtain a copy of the License at | 
|  | 7 | +
 | 
|  | 8 | +    http://www.apache.org/licenses/LICENSE-2.0 | 
|  | 9 | +
 | 
|  | 10 | +Unless required by applicable law or agreed to in writing, software | 
|  | 11 | +distributed under the License is distributed on an "AS IS" BASIS, | 
|  | 12 | +WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | 
|  | 13 | +See the License for the specific language governing permissions and | 
|  | 14 | +limitations under the License. | 
|  | 15 | +*/ | 
|  | 16 | + | 
|  | 17 | +package clusters | 
|  | 18 | + | 
|  | 19 | +import ( | 
|  | 20 | +	"context" | 
|  | 21 | +	"fmt" | 
|  | 22 | + | 
|  | 23 | +	"k8s.io/client-go/rest" | 
|  | 24 | + | 
|  | 25 | +	"sigs.k8s.io/controller-runtime/pkg/cluster" | 
|  | 26 | +	"sigs.k8s.io/controller-runtime/pkg/envtest" | 
|  | 27 | + | 
|  | 28 | +	mcacceptance "sigs.k8s.io/multicluster-runtime/pkg/acceptance" | 
|  | 29 | +	mcmanager "sigs.k8s.io/multicluster-runtime/pkg/manager" | 
|  | 30 | + | 
|  | 31 | +	. "github.com/onsi/ginkgo/v2" | 
|  | 32 | +	. "github.com/onsi/gomega" | 
|  | 33 | +) | 
|  | 34 | + | 
|  | 35 | +var _ = Describe("Provider Clusters Acceptance", Ordered, func() { | 
|  | 36 | +	var provider *Provider | 
|  | 37 | +	var manager mcmanager.Manager | 
|  | 38 | +	var generateCluster mcacceptance.ClusterGenerator | 
|  | 39 | + | 
|  | 40 | +	BeforeAll(func() { | 
|  | 41 | +		By("Creating a new provider", func() { | 
|  | 42 | +			provider = New() | 
|  | 43 | +		}) | 
|  | 44 | + | 
|  | 45 | +		By("Creating a new manager", func() { | 
|  | 46 | +			var err error | 
|  | 47 | +			manager, err = mcmanager.New(localCfg, provider, mcmanager.Options{}) | 
|  | 48 | +			Expect(err).NotTo(HaveOccurred(), "Failed to create manager") | 
|  | 49 | +		}) | 
|  | 50 | + | 
|  | 51 | +		By("Defining the ClusterGenerator", func() { | 
|  | 52 | +			generateCluster = func(ctx context.Context, errHandler mcacceptance.ErrorHandler) (string, *rest.Config, error) { | 
|  | 53 | +				testenv := &envtest.Environment{} | 
|  | 54 | +				cfg, err := testenv.Start() | 
|  | 55 | +				if err != nil { | 
|  | 56 | +					return "", nil, fmt.Errorf("failed to start envtest: %w", err) | 
|  | 57 | +				} | 
|  | 58 | + | 
|  | 59 | +				cl, err := cluster.New(cfg) | 
|  | 60 | +				if err != nil { | 
|  | 61 | +					return "", nil, fmt.Errorf("failed to create cluster: %w", err) | 
|  | 62 | +				} | 
|  | 63 | + | 
|  | 64 | +				name := mcacceptance.RandomClusterName() | 
|  | 65 | +				if err := provider.Add(ctx, name, cl, manager); err != nil { | 
|  | 66 | +					return "", nil, fmt.Errorf("failed to add cluster to provider: %w", err) | 
|  | 67 | +				} | 
|  | 68 | +				go func() { | 
|  | 69 | +					<-ctx.Done() | 
|  | 70 | +					errHandler(testenv.Stop()) | 
|  | 71 | +				}() | 
|  | 72 | +				return name, cfg, nil | 
|  | 73 | +			} | 
|  | 74 | +		}) | 
|  | 75 | +	}) | 
|  | 76 | + | 
|  | 77 | +	It("Should run the acceptance tests", func() { | 
|  | 78 | +		mcacceptance.Provider(GinkgoTB(), generateCluster, manager) | 
|  | 79 | +	}) | 
|  | 80 | + | 
|  | 81 | +}) | 
0 commit comments