@@ -16,6 +16,7 @@ import (
16
16
operatorsv1 "github.com/operator-framework/api/pkg/operators/v1"
17
17
operatorsv1alpha1 "github.com/operator-framework/api/pkg/operators/v1alpha1"
18
18
packageserverclientset "github.com/operator-framework/operator-lifecycle-manager/pkg/package-server/client/clientset/versioned"
19
+ apiextensionsv1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1"
19
20
k8serror "k8s.io/apimachinery/pkg/api/errors"
20
21
"sigs.k8s.io/controller-runtime/pkg/client"
21
22
@@ -24,7 +25,6 @@ import (
24
25
. "github.com/onsi/gomega"
25
26
appsv1 "k8s.io/api/apps/v1"
26
27
corev1 "k8s.io/api/core/v1"
27
- "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions"
28
28
"k8s.io/apimachinery/pkg/api/meta"
29
29
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
30
30
"k8s.io/apimachinery/pkg/labels"
@@ -93,7 +93,7 @@ var _ = Describe("Starting CatalogSource e2e tests", func() {
93
93
}
94
94
95
95
crd := newCRD (genName ("ins-" ))
96
- csv := newCSV (packageStable , generatedNamespace .GetName (), "" , semver .MustParse ("0.1.0" ), []apiextensions .CustomResourceDefinition {crd }, nil , nil )
96
+ csv := newCSV (packageStable , generatedNamespace .GetName (), "" , semver .MustParse ("0.1.0" ), []apiextensionsv1 .CustomResourceDefinition {crd }, nil , nil )
97
97
98
98
defer func () {
99
99
Eventually (func () error {
@@ -105,7 +105,7 @@ var _ = Describe("Starting CatalogSource e2e tests", func() {
105
105
}()
106
106
107
107
catalogSourceName := genName ("mock-ocs-" )
108
- _ , cleanupSource := createInternalCatalogSource (c , crc , catalogSourceName , generatedNamespace .GetName (), manifests , []apiextensions .CustomResourceDefinition {crd }, []v1alpha1.ClusterServiceVersion {csv })
108
+ _ , cleanupSource := createInternalCatalogSource (c , crc , catalogSourceName , generatedNamespace .GetName (), manifests , []apiextensionsv1 .CustomResourceDefinition {crd }, []v1alpha1.ClusterServiceVersion {csv })
109
109
defer cleanupSource ()
110
110
111
111
// ensure the mock catalog exists and has been synced by the catalog operator
@@ -147,8 +147,8 @@ var _ = Describe("Starting CatalogSource e2e tests", func() {
147
147
stableChannel := "stable"
148
148
149
149
mainCRD := newCRD (genName ("ins-" ))
150
- mainCSV := newCSV (mainPackageStable , generatedNamespace .GetName (), "" , semver .MustParse ("0.1.0" ), []apiextensions .CustomResourceDefinition {mainCRD }, nil , nil )
151
- replacementCSV := newCSV (mainPackageReplacement , generatedNamespace .GetName (), mainPackageStable , semver .MustParse ("0.2.0" ), []apiextensions .CustomResourceDefinition {mainCRD }, nil , nil )
150
+ mainCSV := newCSV (mainPackageStable , generatedNamespace .GetName (), "" , semver .MustParse ("0.1.0" ), []apiextensionsv1 .CustomResourceDefinition {mainCRD }, nil , nil )
151
+ replacementCSV := newCSV (mainPackageReplacement , generatedNamespace .GetName (), mainPackageStable , semver .MustParse ("0.2.0" ), []apiextensionsv1 .CustomResourceDefinition {mainCRD }, nil , nil )
152
152
153
153
defer func () {
154
154
Eventually (func () error {
@@ -176,7 +176,7 @@ var _ = Describe("Starting CatalogSource e2e tests", func() {
176
176
}
177
177
178
178
// Create the initial catalog source
179
- cs , cleanup := createInternalCatalogSource (c , crc , mainCatalogName , globalCatalogNamespace , mainManifests , []apiextensions .CustomResourceDefinition {mainCRD }, []v1alpha1.ClusterServiceVersion {mainCSV })
179
+ cs , cleanup := createInternalCatalogSource (c , crc , mainCatalogName , globalCatalogNamespace , mainManifests , []apiextensionsv1 .CustomResourceDefinition {mainCRD }, []v1alpha1.ClusterServiceVersion {mainCSV })
180
180
defer cleanup ()
181
181
182
182
// Attempt to get the catalog source before creating install plan
@@ -229,7 +229,7 @@ var _ = Describe("Starting CatalogSource e2e tests", func() {
229
229
}
230
230
231
231
// Update catalog configmap
232
- updateInternalCatalog (GinkgoT (), c , crc , cs .GetName (), cs .GetNamespace (), []apiextensions .CustomResourceDefinition {mainCRD }, []v1alpha1.ClusterServiceVersion {mainCSV , replacementCSV }, mainManifests )
232
+ updateInternalCatalog (GinkgoT (), c , crc , cs .GetName (), cs .GetNamespace (), []apiextensionsv1 .CustomResourceDefinition {mainCRD }, []v1alpha1.ClusterServiceVersion {mainCSV , replacementCSV }, mainManifests )
233
233
234
234
// Get updated catalogsource
235
235
fetchedUpdatedCatalog , err := fetchCatalogSourceOnStatus (crc , cs .GetName (), cs .GetNamespace (), catalogSourceRegistryPodSynced ())
@@ -256,8 +256,8 @@ var _ = Describe("Starting CatalogSource e2e tests", func() {
256
256
stableChannel := "stable"
257
257
258
258
dependentCRD := newCRD (genName ("ins-" ))
259
- mainCSV := newCSV (mainPackageStable , generatedNamespace .GetName (), "" , semver .MustParse ("0.1.0" ), nil , []apiextensions .CustomResourceDefinition {dependentCRD }, nil )
260
- dependentCSV := newCSV (dependentPackageStable , generatedNamespace .GetName (), "" , semver .MustParse ("0.1.0" ), []apiextensions .CustomResourceDefinition {dependentCRD }, nil , nil )
259
+ mainCSV := newCSV (mainPackageStable , generatedNamespace .GetName (), "" , semver .MustParse ("0.1.0" ), nil , []apiextensionsv1 .CustomResourceDefinition {dependentCRD }, nil )
260
+ dependentCSV := newCSV (dependentPackageStable , generatedNamespace .GetName (), "" , semver .MustParse ("0.1.0" ), []apiextensionsv1 .CustomResourceDefinition {dependentCRD }, nil , nil )
261
261
262
262
defer func () {
263
263
Eventually (func () error {
@@ -311,7 +311,7 @@ var _ = Describe("Starting CatalogSource e2e tests", func() {
311
311
Expect (initialPods .Items ).To (HaveLen (1 ))
312
312
313
313
// Update catalog configmap
314
- updateInternalCatalog (GinkgoT (), c , crc , mainCatalogName , generatedNamespace .GetName (), []apiextensions .CustomResourceDefinition {dependentCRD }, []v1alpha1.ClusterServiceVersion {mainCSV , dependentCSV }, append (mainManifests , dependentManifests ... ))
314
+ updateInternalCatalog (GinkgoT (), c , crc , mainCatalogName , generatedNamespace .GetName (), []apiextensionsv1 .CustomResourceDefinition {dependentCRD }, []v1alpha1.ClusterServiceVersion {mainCSV , dependentCSV }, append (mainManifests , dependentManifests ... ))
315
315
316
316
fetchedUpdatedCatalog , err := fetchCatalogSourceOnStatus (crc , mainCatalogName , generatedNamespace .GetName (), func (catalog * v1alpha1.CatalogSource ) bool {
317
317
before := fetchedInitialCatalog .Status .ConfigMapResource
@@ -389,8 +389,8 @@ var _ = Describe("Starting CatalogSource e2e tests", func() {
389
389
stableChannel := "stable"
390
390
391
391
dependentCRD := newCRD (genName ("ins-" ))
392
- mainCSV := newCSV (mainPackageStable , generatedNamespace .GetName (), "" , semver .MustParse ("0.1.0" ), nil , []apiextensions .CustomResourceDefinition {dependentCRD }, nil )
393
- dependentCSV := newCSV (dependentPackageStable , generatedNamespace .GetName (), "" , semver .MustParse ("0.1.0" ), []apiextensions .CustomResourceDefinition {dependentCRD }, nil , nil )
392
+ mainCSV := newCSV (mainPackageStable , generatedNamespace .GetName (), "" , semver .MustParse ("0.1.0" ), nil , []apiextensionsv1 .CustomResourceDefinition {dependentCRD }, nil )
393
+ dependentCSV := newCSV (dependentPackageStable , generatedNamespace .GetName (), "" , semver .MustParse ("0.1.0" ), []apiextensionsv1 .CustomResourceDefinition {dependentCRD }, nil , nil )
394
394
395
395
defer func () {
396
396
Eventually (func () error {
@@ -446,7 +446,7 @@ var _ = Describe("Starting CatalogSource e2e tests", func() {
446
446
cleanupSource ()
447
447
448
448
// create a catalog with the same name
449
- createInternalCatalogSource (c , crc , mainCatalogName , generatedNamespace .GetName (), append (mainManifests , dependentManifests ... ), []apiextensions .CustomResourceDefinition {dependentCRD }, []v1alpha1.ClusterServiceVersion {mainCSV , dependentCSV })
449
+ createInternalCatalogSource (c , crc , mainCatalogName , generatedNamespace .GetName (), append (mainManifests , dependentManifests ... ), []apiextensionsv1 .CustomResourceDefinition {dependentCRD }, []v1alpha1.ClusterServiceVersion {mainCSV , dependentCSV })
450
450
451
451
// Create Subscription
452
452
subscriptionName := genName ("sub-" )
@@ -482,9 +482,9 @@ var _ = Describe("Starting CatalogSource e2e tests", func() {
482
482
stableChannel := "stable"
483
483
484
484
dependentCRD := newCRD (genName ("ins-" ))
485
- mainCSV := newCSV (mainPackageStable , generatedNamespace .GetName (), "" , semver .MustParse ("0.1.0" ), nil , []apiextensions .CustomResourceDefinition {dependentCRD }, nil )
486
- replacementCSV := newCSV (mainPackageReplacement , generatedNamespace .GetName (), mainPackageStable , semver .MustParse ("0.2.0" ), nil , []apiextensions .CustomResourceDefinition {dependentCRD }, nil )
487
- dependentCSV := newCSV (dependentPackageStable , generatedNamespace .GetName (), "" , semver .MustParse ("0.1.0" ), []apiextensions .CustomResourceDefinition {dependentCRD }, nil , nil )
485
+ mainCSV := newCSV (mainPackageStable , generatedNamespace .GetName (), "" , semver .MustParse ("0.1.0" ), nil , []apiextensionsv1 .CustomResourceDefinition {dependentCRD }, nil )
486
+ replacementCSV := newCSV (mainPackageReplacement , generatedNamespace .GetName (), mainPackageStable , semver .MustParse ("0.2.0" ), nil , []apiextensionsv1 .CustomResourceDefinition {dependentCRD }, nil )
487
+ dependentCSV := newCSV (dependentPackageStable , generatedNamespace .GetName (), "" , semver .MustParse ("0.1.0" ), []apiextensionsv1 .CustomResourceDefinition {dependentCRD }, nil , nil )
488
488
489
489
defer func () {
490
490
Eventually (func () error {
@@ -536,8 +536,8 @@ var _ = Describe("Starting CatalogSource e2e tests", func() {
536
536
}
537
537
538
538
// Create ConfigMap CatalogSources
539
- createInternalCatalogSource (c , crc , mainSourceName , generatedNamespace .GetName (), append (mainManifests , dependentManifests ... ), []apiextensions .CustomResourceDefinition {dependentCRD }, []v1alpha1.ClusterServiceVersion {mainCSV , dependentCSV })
540
- createInternalCatalogSource (c , crc , replacementSourceName , generatedNamespace .GetName (), append (replacementManifests , dependentManifests ... ), []apiextensions .CustomResourceDefinition {dependentCRD }, []v1alpha1.ClusterServiceVersion {replacementCSV , mainCSV , dependentCSV })
539
+ createInternalCatalogSource (c , crc , mainSourceName , generatedNamespace .GetName (), append (mainManifests , dependentManifests ... ), []apiextensionsv1 .CustomResourceDefinition {dependentCRD }, []v1alpha1.ClusterServiceVersion {mainCSV , dependentCSV })
540
+ createInternalCatalogSource (c , crc , replacementSourceName , generatedNamespace .GetName (), append (replacementManifests , dependentManifests ... ), []apiextensionsv1 .CustomResourceDefinition {dependentCRD }, []v1alpha1.ClusterServiceVersion {replacementCSV , mainCSV , dependentCSV })
541
541
542
542
// Wait for ConfigMap CatalogSources to be ready
543
543
mainSource , err := fetchCatalogSourceOnStatus (crc , mainSourceName , generatedNamespace .GetName (), catalogSourceRegistryPodSynced ())
@@ -630,7 +630,7 @@ var _ = Describe("Starting CatalogSource e2e tests", func() {
630
630
stableChannel := "stable"
631
631
sourceName := genName ("catalog-" )
632
632
crd := newCRD (genName ("ins-" ))
633
- csv := newCSV (packageStable , generatedNamespace .GetName (), "" , semver .MustParse ("0.1.0" ), []apiextensions .CustomResourceDefinition {crd }, nil , nil )
633
+ csv := newCSV (packageStable , generatedNamespace .GetName (), "" , semver .MustParse ("0.1.0" ), []apiextensionsv1 .CustomResourceDefinition {crd }, nil , nil )
634
634
manifests := []registry.PackageManifest {
635
635
{
636
636
PackageName : packageName ,
@@ -650,7 +650,7 @@ var _ = Describe("Starting CatalogSource e2e tests", func() {
650
650
}).Should (Succeed ())
651
651
}()
652
652
653
- _ , cleanupSource := createInternalCatalogSource (c , crc , sourceName , generatedNamespace .GetName (), manifests , []apiextensions .CustomResourceDefinition {crd }, []v1alpha1.ClusterServiceVersion {csv })
653
+ _ , cleanupSource := createInternalCatalogSource (c , crc , sourceName , generatedNamespace .GetName (), manifests , []apiextensionsv1 .CustomResourceDefinition {crd }, []v1alpha1.ClusterServiceVersion {csv })
654
654
defer cleanupSource ()
655
655
656
656
// Wait for a new registry pod to be created
0 commit comments