feat(resolver): allow skipping a set of updates if the channel head

explicitly states that a range of existing operators can update directly

this is to support z-stream releases for operators, where there is a
reasonable degree of confidence that it's safe to skip updates, and
where it is difficult to generate the graph ahead of time

Makefile

@@ -130,7 +130,7 @@ codegen:
 	cp scripts/generate_internal_groups.sh vendor/k8s.io/code-generator/generate_internal_groups.sh
 	mkdir -p vendor/k8s.io/code-generator/hack
 	cp boilerplate.go.txt vendor/k8s.io/code-generator/hack/boilerplate.go.txt
-	go run vendor/k8s.io/kube-openapi/cmd/openapi-gen/openapi-gen.go --logtostderr -i ./vendor/k8s.io/apimachinery/pkg/runtime,./vendor/k8s.io/apimachinery/pkg/apis/meta/v1,./vendor/k8s.io/apimachinery/pkg/version,./pkg/package-server/apis/operators/v1,./pkg/package-server/apis/apps/v1alpha1,./pkg/api/apis/operators/v1alpha1 -p $(PKG)/pkg/package-server/apis/openapi -O zz_generated.openapi -h boilerplate.go.txt -r /dev/null
+	go run vendor/k8s.io/kube-openapi/cmd/openapi-gen/openapi-gen.go --logtostderr -i ./vendor/k8s.io/apimachinery/pkg/runtime,./vendor/k8s.io/apimachinery/pkg/apis/meta/v1,./vendor/k8s.io/apimachinery/pkg/version,./pkg/package-server/apis/operators/v1,./pkg/package-server/apis/apps/v1alpha1,./pkg/api/apis/operators/v1alpha1,./pkg/lib/version -p $(PKG)/pkg/package-server/apis/openapi -O zz_generated.openapi -h boilerplate.go.txt -r /dev/null
 	$(CODEGEN) all $(PKG)/pkg/api/client $(PKG)/pkg/api/apis "operators:v1alpha1,v1"
 	$(CODEGEN_INTERNAL) all $(PKG)/pkg/package-server/client $(PKG)/pkg/package-server/apis $(PKG)/pkg/package-server/apis "operators:v1 apps:v1alpha1"
 

pkg/api/apis/operators/v1alpha1/clusterserviceversion_types.go

@@ -7,8 +7,9 @@ import (
 	"fmt"
 	"sort"
 
-	"github.com/blang/semver"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+
+	"github.com/operator-framework/operator-lifecycle-manager/pkg/lib/version"
 )
 
 const (
@@ -136,7 +137,7 @@ type APIServiceDefinitions struct {
 // that can manage apps for a given version.
 type ClusterServiceVersionSpec struct {
 	InstallStrategy           NamedInstallStrategy      `json:"install"`
-	Version                   semver.Version            `json:"version,omitempty"`
+	Version                   version.OperatorVersion   `json:"version,omitempty"`
 	Maturity                  string                    `json:"maturity,omitempty"`
 	CustomResourceDefinitions CustomResourceDefinitions `json:"customresourcedefinitions,omitempty"`
 	APIServiceDefinitions     APIServiceDefinitions     `json:"apiservicedefinitions,omitempty"`

pkg/controller/operators/catalog/operator.go

@@ -779,7 +779,7 @@ func (o *Operator) ensureSubscriptionCSVState(logger *logrus.Entry, sub *v1alpha
 		return sub, false, nil
 	}
 
-	_, err := o.client.OperatorsV1alpha1().ClusterServiceVersions(sub.GetNamespace()).Get(sub.Status.CurrentCSV, metav1.GetOptions{})
+	csv, err := o.client.OperatorsV1alpha1().ClusterServiceVersions(sub.GetNamespace()).Get(sub.Status.CurrentCSV, metav1.GetOptions{})
 	out := sub.DeepCopy()
 	if err != nil {
 		logger.WithError(err).WithField("currentCSV", sub.Status.CurrentCSV).Debug("error fetching csv listed in subscription status")
@@ -789,7 +789,7 @@ func (o *Operator) ensureSubscriptionCSVState(logger *logrus.Entry, sub *v1alpha
 		if err := querier.Queryable(); err != nil {
 			return nil, false, err
 		}
-		bundle, _, _ := querier.FindReplacement(sub.Status.CurrentCSV, sub.Spec.Package, sub.Spec.Channel, resolver.CatalogKey{sub.Spec.CatalogSource, sub.Spec.CatalogSourceNamespace})
+		bundle, _, _ := querier.FindReplacement(&csv.Spec.Version.Version, sub.Status.CurrentCSV, sub.Spec.Package, sub.Spec.Channel, resolver.CatalogKey{sub.Spec.CatalogSource, sub.Spec.CatalogSourceNamespace})
 		if bundle != nil {
 			out.Status.State = v1alpha1.SubscriptionStateUpgradeAvailable
 		} else {

pkg/controller/operators/olm/operator.go

@@ -752,7 +752,7 @@ func (a *Operator) transitionCSVState(in v1alpha1.ClusterServiceVersion) (out *v
 		return
 	}
 
-	operatorSurface, err := resolver.NewOperatorFromCSV(out)
+	operatorSurface, err := resolver.NewOperatorFromV1Alpha1CSV(out)
 	if err != nil {
 		// TODO: Add failure status to CSV
 		syncError = err

pkg/controller/operators/olm/operatorgroup.go

@@ -171,7 +171,7 @@ func (a *Operator) providedAPIsFromCSVs(group *v1.OperatorGroup, logger *logrus.
 		// TODO: Throw out CSVs that aren't members of the group due to group related failures?
 
 		// Union the providedAPIsFromCSVs from existing members of the group
-		operatorSurface, err := resolver.NewOperatorFromCSV(csv)
+		operatorSurface, err := resolver.NewOperatorFromV1Alpha1CSV(csv)
 		if err != nil {
 			logger.WithError(err).Warn("could not create OperatorSurface from csv")
 			continue
@@ -763,7 +763,7 @@ func (a *Operator) findCSVsThatProvideAnyOf(provide resolver.APISet) ([]*v1alpha
 			continue
 		}
 
-		operatorSurface, err := resolver.NewOperatorFromCSV(csv)
+		operatorSurface, err := resolver.NewOperatorFromV1Alpha1CSV(csv)
 		if err != nil {
 			continue
 		}

pkg/controller/registry/resolver/evolver.go

@@ -57,7 +57,7 @@ func (e *NamespaceGenerationEvolver) checkForUpdates() error {
 			continue
 		}
 
-		bundle, key, err := e.querier.FindReplacement(op.Identifier(), op.SourceInfo().Package, op.SourceInfo().Channel, op.SourceInfo().Catalog)
+		bundle, key, err := e.querier.FindReplacement(op.Version(), op.Identifier(), op.SourceInfo().Package, op.SourceInfo().Channel, op.SourceInfo().Catalog)
 		if err != nil || bundle == nil {
 			continue
 		}

pkg/controller/registry/resolver/generation.go

@@ -47,7 +47,7 @@ func NewGenerationFromCluster(csvs []*v1alpha1.ClusterServiceVersion, subs []*v1
 		}
 	}
 	for _, csv := range csvs {
-		op, err := NewOperatorFromCSV(csv)
+		op, err := NewOperatorFromV1Alpha1CSV(csv)
 		if err != nil {
 			return nil, err
 		}

pkg/controller/registry/resolver/generation_test.go

@@ -4,6 +4,7 @@ import (
 	"fmt"
 	"testing"
 
+	"github.com/blang/semver"
 	"github.com/operator-framework/operator-registry/pkg/registry"
 	opregistry "github.com/operator-framework/operator-registry/pkg/registry"
 	"github.com/stretchr/testify/require"
@@ -12,6 +13,8 @@ import (
 	"github.com/operator-framework/operator-lifecycle-manager/pkg/api/apis/operators/v1alpha1"
 )
 
+var NoVersion = semver.MustParse("0.0.0")
+
 func TestNewGenerationFromCSVs(t *testing.T) {
 	type args struct {
 		csvs []*v1alpha1.ClusterServiceVersion
@@ -82,6 +85,7 @@ func TestNewGenerationFromCSVs(t *testing.T) {
 						},
 						requiredAPIs: EmptyAPISet(),
 						sourceInfo:   &ExistingOperator,
+						version:      &NoVersion,
 					},
 					{Group: "g", Version: "v1", Kind: "CRDKind", Plural: "crdkinds"}: &Operator{
 						name: "operator.v1",
@@ -91,6 +95,7 @@ func TestNewGenerationFromCSVs(t *testing.T) {
 						},
 						requiredAPIs: EmptyAPISet(),
 						sourceInfo:   &ExistingOperator,
+						version:      &NoVersion,
 					},
 				},
 				requiredAPIs:  EmptyAPIMultiOwnerSet(),
@@ -142,6 +147,7 @@ func TestNewGenerationFromCSVs(t *testing.T) {
 								{Group: "g", Version: "v1", Kind: "CRDKind", Plural: "crdkinds"}: {},
 							},
 							sourceInfo: &ExistingOperator,
+							version:    &NoVersion,
 						},
 					},
 					{Group: "g", Version: "v1", Kind: "CRDKind", Plural: "crdkinds"}: map[string]OperatorSurface{
@@ -153,6 +159,7 @@ func TestNewGenerationFromCSVs(t *testing.T) {
 								{Group: "g", Version: "v1", Kind: "CRDKind", Plural: "crdkinds"}: {},
 							},
 							sourceInfo: &ExistingOperator,
+							version:    &NoVersion,
 						},
 					},
 				},
@@ -170,6 +177,7 @@ func TestNewGenerationFromCSVs(t *testing.T) {
 								{Group: "g", Version: "v1", Kind: "CRDKind", Plural: "crdkinds"}: {},
 							},
 							sourceInfo: &ExistingOperator,
+							version:    &NoVersion,
 						},
 					},
 					{Group: "g", Version: "v1", Kind: "CRDKind", Plural: "crdkinds"}: map[string]OperatorSurface{
@@ -181,6 +189,7 @@ func TestNewGenerationFromCSVs(t *testing.T) {
 								{Group: "g", Version: "v1", Kind: "CRDKind", Plural: "crdkinds"}: {},
 							},
 							sourceInfo: &ExistingOperator,
+							version:    &NoVersion,
 						},
 					},
 				},
@@ -246,6 +255,7 @@ func TestNewGenerationFromCSVs(t *testing.T) {
 							{Group: "g2", Version: "v1", Kind: "CRDReqKind", Plural: "crdreqkinds"}: {},
 						},
 						sourceInfo: &ExistingOperator,
+						version:    &NoVersion,
 					},
 					{Group: "g", Version: "v1", Kind: "CRDOwnedKind", Plural: "crdownedkinds"}: &Operator{
 						name: "operator.v1",
@@ -258,6 +268,7 @@ func TestNewGenerationFromCSVs(t *testing.T) {
 							{Group: "g2", Version: "v1", Kind: "CRDReqKind", Plural: "crdreqkinds"}: {},
 						},
 						sourceInfo: &ExistingOperator,
+						version:    &NoVersion,
 					},
 				},
 				requiredAPIs: map[opregistry.APIKey]OperatorSet{
@@ -273,6 +284,7 @@ func TestNewGenerationFromCSVs(t *testing.T) {
 								{Group: "g2", Version: "v1", Kind: "CRDReqKind", Plural: "crdreqkinds"}: {},
 							},
 							sourceInfo: &ExistingOperator,
+							version:    &NoVersion,
 						},
 					},
 					{Group: "g2", Version: "v1", Kind: "CRDReqKind", Plural: "crdreqkinds"}: map[string]OperatorSurface{
@@ -287,6 +299,7 @@ func TestNewGenerationFromCSVs(t *testing.T) {
 								{Group: "g2", Version: "v1", Kind: "CRDReqKind", Plural: "crdreqkinds"}: {},
 							},
 							sourceInfo: &ExistingOperator,
+							version:    &NoVersion,
 						},
 					},
 				},
@@ -307,6 +320,7 @@ func TestNewGenerationFromCSVs(t *testing.T) {
 								{Group: "g2", Version: "v1", Kind: "CRDReqKind", Plural: "crdreqkinds"}: {},
 							},
 							sourceInfo: &ExistingOperator,
+							version:    &NoVersion,
 						},
 					},
 					{Group: "g2", Version: "v1", Kind: "CRDReqKind", Plural: "crdreqkinds"}: map[string]OperatorSurface{
@@ -321,6 +335,7 @@ func TestNewGenerationFromCSVs(t *testing.T) {
 								{Group: "g2", Version: "v1", Kind: "CRDReqKind", Plural: "crdreqkinds"}: {},
 							},
 							sourceInfo: &ExistingOperator,
+							version:    &NoVersion,
 						},
 					},
 				},
@@ -334,7 +349,7 @@ func TestNewGenerationFromCSVs(t *testing.T) {
 			operatorSet := EmptyOperatorSet()
 			for _, csv := range tt.args.csvs {
 				// there's a separate unit test for this constructor
-				op, err := NewOperatorFromCSV(csv)
+				op, err := NewOperatorFromV1Alpha1CSV(csv)
 				require.NoError(t, err)
 				operatorSet[op.Identifier()] = op
 			}

pkg/controller/registry/resolver/operators.go

@@ -6,9 +6,11 @@ import (
 	"sort"
 	"strings"
 
-	"github.com/operator-framework/operator-lifecycle-manager/pkg/api/apis/operators/v1alpha1"
+	"github.com/blang/semver"
 	opregistry "github.com/operator-framework/operator-registry/pkg/registry"
 	"k8s.io/apimachinery/pkg/runtime/schema"
+
+	"github.com/operator-framework/operator-lifecycle-manager/pkg/api/apis/operators/v1alpha1"
 )
 
 type CatalogKey struct {
@@ -215,6 +217,7 @@ type OperatorSurface interface {
 	RequiredAPIs() APISet
 	Identifier() string
 	Replaces() string
+	Version() *semver.Version
 	SourceInfo() *OperatorSourceInfo
 	Bundle() *opregistry.Bundle
 }
@@ -224,6 +227,7 @@ type Operator struct {
 	replaces     string
 	providedAPIs APISet
 	requiredAPIs APISet
+	version      *semver.Version
 	bundle       *opregistry.Bundle
 	sourceInfo   *OperatorSourceInfo
 }
@@ -246,6 +250,7 @@ func NewOperatorFromBundle(bundle *opregistry.Bundle, startingCSV string, source
 	return &Operator{
 		name:         csv.GetName(),
 		replaces:     csv.Spec.Replaces,
+		version:      &csv.Spec.Version.Version,
 		providedAPIs: providedAPIs,
 		requiredAPIs: requiredAPIs,
 		bundle:       bundle,
@@ -258,7 +263,7 @@ func NewOperatorFromBundle(bundle *opregistry.Bundle, startingCSV string, source
 	}, nil
 }
 
-func NewOperatorFromCSV(csv *v1alpha1.ClusterServiceVersion) (*Operator, error) {
+func NewOperatorFromV1Alpha1CSV(csv *v1alpha1.ClusterServiceVersion) (*Operator, error) {
 	providedAPIs := EmptyAPISet()
 	for _, crdDef := range csv.Spec.CustomResourceDefinitions.Owned {
 		parts := strings.SplitN(crdDef.Name, ".", 2)
@@ -285,6 +290,7 @@ func NewOperatorFromCSV(csv *v1alpha1.ClusterServiceVersion) (*Operator, error)
 
 	return &Operator{
 		name:         csv.GetName(),
+		version:      &csv.Spec.Version.Version,
 		replaces:     csv.Spec.Replaces,
 		providedAPIs: providedAPIs,
 		requiredAPIs: requiredAPIs,
@@ -319,3 +325,7 @@ func (o *Operator) SourceInfo() *OperatorSourceInfo {
 func (o *Operator) Bundle() *opregistry.Bundle {
 	return o.bundle
 }
+
+func (o *Operator) Version() *semver.Version {
+	return o.version
+}