OTA-1966: Manage proposals

.openshift-tests-extension/openshift_payload_cluster-version-operator.json

@@ -101,6 +101,7 @@
     "name": "[Jira:\"Cluster Version Operator\"] cluster-version-operator should create proposals",
     "labels": {
       "Lifecycle:informing": {},
+      "OTA-1966": {},
       "Serial": {}
     },
     "resources": {

install/0000_00_cluster-version-operator_45_openshift-lightspeed_namespace.yaml

@@ -0,0 +1,7 @@
+apiVersion: v1
+kind: Namespace
+metadata:
+  name: openshift-lightspeed
+  annotations:
+    kubernetes.io/description: This manifest is only for testing purpose and will be removed when its own operator becomes available on the cluster.
+    include.release.openshift.io/self-managed-high-availability: "true"

install/0000_00_cluster-version-operator_50_lightspeed-prompts.yaml

@@ -0,0 +1,30 @@
+---
+apiVersion: v1
+kind: ConfigMap
+metadata:
+  name: ota-advisory-prompt
+  namespace: openshift-lightspeed
+  annotations:
+    include.release.openshift.io/self-managed-high-availability: "true"
+    release.openshift.io/feature-set: TechPreviewNoUpgrade
+data:
+  prompt: |
+    You are an OpenShift upgrade advisor. Analyze the cluster readiness
+    data in the proposal request and produce an upgrade risk assessment.
+
+    The request contains a "Cluster Readiness Data" section with a JSON
+    block. This was collected by the Cluster Version Operator — do not
+    re-collect it. Parse the JSON, evaluate each check's results, and
+    classify findings as blockers, warnings, or informational.
+
+    Use the ota-upgrade-advisor skill for the decision framework and
+    blocker classification rules. When findings need deeper investigation,
+    use prometheus, platform-docs, redhat-support, or product-lifecycle
+    skills.
+
+    When the readiness data includes olm_operator_lifecycle results, use
+    the product-lifecycle skill to cross-reference each operator's package
+    name against the Red Hat Product Life Cycle API. Report support phase,
+    EOL dates, and OCP compatibility from PLCC alongside the OLM data.
+
+    Do not guess or assume cluster state. Do not execute upgrade commands.

pkg/cvo/availableupdates_test.go

@@ -211,6 +211,12 @@ func newOperator(url string, cluster release, promqlMock clusterconditions.Condi
 		fake.NewClientBuilder().Build(), func(_ string) (*configv1.ClusterVersion, error) {
 			return &configv1.ClusterVersion{}, nil
 		},
+		func(_ context.Context, namespace, name string, _ metav1.GetOptions) (*corev1.ConfigMap, error) {
+			return &corev1.ConfigMap{}, nil
+		},
+		func() string {
+			return operator.release.Version
+		},
 	)
 	return availableUpdates, operator
 }

pkg/cvo/cvo.go

@@ -324,13 +324,23 @@ func New(
 
 	optr.configuration = configuration.NewClusterVersionOperatorConfiguration(operatorClient, operatorInformerFactory)
 
-	optr.proposalController = proposal.NewController(func() ([]configv1.Release, []configv1.ConditionalUpdate, error) {
-		availableUpdates := optr.getAvailableUpdates()
-		if availableUpdates == nil {
-			return nil, nil, nil
-		}
-		return availableUpdates.Updates, availableUpdates.ConditionalUpdates, nil
-	}, rtClient, cvInformer.Lister().Get)
+	optr.proposalController = proposal.NewController(
+		func() ([]configv1.Release, []configv1.ConditionalUpdate, error) {
+			availableUpdates := optr.getAvailableUpdates()
+			if availableUpdates == nil {
+				return nil, nil, nil
+			}
+			return availableUpdates.Updates, availableUpdates.ConditionalUpdates, nil
+		},
+		rtClient,
+		cvInformer.Lister().Get,
+		func(ctx context.Context, namespace, name string, opts metav1.GetOptions) (*corev1.ConfigMap, error) {
+			return kubeClient.CoreV1().ConfigMaps(namespace).Get(ctx, name, opts)
+		},
+		func() string {
+			return optr.release.Version
+		},
+	)
 
 	return optr, nil
 }

pkg/cvo/cvo_test.go

@@ -2764,6 +2764,10 @@ func TestOperator_availableUpdatesSync(t *testing.T) {
 				return nil, nil, nil
 			}, ctrlruntimefake.NewClientBuilder().Build(), func(_ string) (*configv1.ClusterVersion, error) {
 				return &configv1.ClusterVersion{}, nil
+			}, func(_ context.Context, namespace, name string, _ metav1.GetOptions) (*corev1.ConfigMap, error) {
+				return &corev1.ConfigMap{}, nil
+			}, func() string {
+				return optr.release.Version
 			})
 			err := optr.availableUpdatesSync(ctx, optr.queueKey())
 			if err != nil && tt.wantErr == nil {

pkg/cvo/status.go

@@ -182,6 +182,12 @@ func (optr *Operator) syncStatus(ctx context.Context, original, config *configv1
 	if klog.V(6).Enabled() {
 		klog.Infof("Apply config: %s", cmp.Diff(original, config))
 	}
+	if optr.shouldEnableProposalController() {
+		if original != nil && len(config.Status.History) < len(original.Status.History) {
+			klog.V(internal.Normal).Infof("Reconciling proposals because ClusterVersion.status.history got pruned")
+			optr.proposalController.Queue().Add(optr.proposalController.QueueKey())
+		}
+	}
 	updated, err := applyClusterVersionStatus(ctx, optr.client.ConfigV1(), config, original)
 	optr.rememberLastUpdate(updated)
 	return err

pkg/internal/constants.go

@@ -4,6 +4,8 @@ import (
 	"fmt"
 	"strings"
 
+	"github.com/blang/semver/v4"
+
 	"k8s.io/apimachinery/pkg/util/sets"
 	"k8s.io/klog/v2"
 
@@ -131,3 +133,24 @@ func IsAlertConditionReason(reason string) bool {
 func AlertConditionMessage(alertName, severity, state, impact, details string) string {
 	return fmt.Sprintf("%s alert %s %s, %s. %s", severity, alertName, state, impact, details)
 }
+
+const (
+	UpdateTypeMajor   = "Major"
+	UpdateTypeMinor   = "Minor"
+	UpdateTypePatch   = "Patch"
+	UpdateTypeUnknown = "Unknown"
+)
+
+// UpdateType returns the type of the update from the source to the target versions
+func UpdateType(source, target semver.Version) string {
+	if source.Major < target.Major {
+		return UpdateTypeMajor
+	}
+	if source.Major == target.Major && source.Minor < target.Minor {
+		return UpdateTypeMinor
+	}
+	if source.LT(target) {
+		return UpdateTypePatch
+	}
+	return UpdateTypeUnknown
+}

pkg/payload/precondition/clusterversion/upgradeable.go

@@ -150,11 +150,8 @@ func majorOrMinorUpdateFrom(status configv1.ClusterVersionStatus, currentVersion
 	}
 	if cond := resourcemerge.FindOperatorStatusCondition(status.Conditions, configv1.OperatorProgressing); cond != nil &&
 		cond.Status == configv1.ConditionTrue {
-		if v.Major < currentVersion.Major {
-			return completedVersion, "Major"
-		}
-		if v.Major == currentVersion.Major && v.Minor < currentVersion.Minor {
-			return completedVersion, "Minor"
+		if ut := internal.UpdateType(v, currentVersion); ut == internal.UpdateTypeMajor || ut == internal.UpdateTypeMinor {
+			return completedVersion, ut
 		}
 	}
 	return "", ""