feat(upgrade): specify upgrade starting version constraint

Signed-off-by: Sergei Lukianov <me@slukjanov.name>

Author: Frostman

api/fabricator/v1beta1/fabricator_types.go

@@ -623,7 +623,9 @@ func (f *Fabricator) Validate(ctx context.Context) error {
 }
 
 func (f *Fabricator) CalculateVersions(def Versions) error {
-	f.Status.Versions = *f.Spec.Overrides.Versions.DeepCopy()
+	if f.Status.Versions.Fabricator.Controller == "" {
+		f.Status.Versions = *f.Spec.Overrides.Versions.DeepCopy()
+	}
 
 	if err := mergo.Merge(&f.Status.Versions, def); err != nil {
 		return fmt.Errorf("merging versions: %w", err)

pkg/fab/recipe/control_upgrade.go

@@ -13,6 +13,7 @@ import (
 	"path/filepath"
 	"time"
 
+	"github.com/Masterminds/semver/v3"
 	vpcapi "go.githedgehog.com/fabric/api/vpc/v1beta1"
 	wiringapi "go.githedgehog.com/fabric/api/wiring/v1beta1"
 	"go.githedgehog.com/fabric/pkg/util/kubeutil"
@@ -81,6 +82,25 @@ func (c *ControlUpgrade) Run(ctx context.Context) error {
 		return fmt.Errorf("retrying getting fabricator and control nodes: %w", err)
 	}
 
+	constraint, err := semver.NewConstraint(string(fab.UpgradeConstraint))
+	if err != nil {
+		return fmt.Errorf("parsing upgrade constraint: %w", err)
+	}
+
+	slog.Info("Currently running fabricator", "version", c.Fab.Status.Versions.Fabricator.Controller)
+
+	// TODO should we add some other markers on the host to make it more reliable?
+	version, err := semver.NewVersion(string(c.Fab.Status.Versions.Fabricator.Controller))
+	if err != nil {
+		return fmt.Errorf("parsing fabricator version: %w", err)
+	}
+
+	if !constraint.Check(version) {
+		slog.Error("Upgrading from the current version not be supported, please upgrade to the older versions first")
+
+		return fmt.Errorf("fabricator version %q does not match upgrade constraint %q", version, constraint) //nolint:goerr113
+	}
+
 	if err := waitKube(ctx, kube, c.Control.Name, "",
 		&comp.Node{}, func(obj *comp.Node) (bool, error) {
 			for _, cond := range obj.Status.Conditions {

pkg/fab/versions.go

@@ -12,6 +12,7 @@ import (
 )
 
 var (
+	UpgradeConstraint = meta.Version(">=0.32.1-0") // 24.09 release; -0 is added to allow pre-release versions
 	FabricatorVersion = meta.Version(version.Version)
 	FabricVersion     = meta.Version("v0.75.0")
 	GatewayVersion    = meta.Version("v0.5.0")

pkg/fab/versions_test.go

@@ -8,8 +8,10 @@ import (
 	"strings"
 	"testing"
 
+	"github.com/Masterminds/semver/v3"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
+	"go.githedgehog.com/fabricator/pkg/version"
 	"golang.org/x/mod/modfile"
 )
 
@@ -56,3 +58,26 @@ func checkVersion(t *testing.T, modfile *modfile.File, path, version string) {
 
 	assert.Truef(t, found, "Require path %s not found in go.mod", path)
 }
+
+func TestUpgradeConstraint(t *testing.T) {
+	c, err := semver.NewConstraint(string(UpgradeConstraint))
+	require.NoError(t, err, "Error parsing upgrade constraint")
+
+	for _, test := range []struct {
+		name     string
+		version  string
+		expected bool
+	}{
+		{"current", version.Version, true},
+		{"25.01", "v0.36.1", true},
+		{"24.09", "v0.32.1", true},
+		{"beta-1", "v0.30.3", false},
+	} {
+		t.Run(string(test.version), func(t *testing.T) {
+			v, err := semver.NewVersion(string(test.version))
+			require.NoError(t, err, "Error parsing version %q", test.version)
+
+			require.Equal(t, test.expected, c.Check(v), "Upgrade from version %q should be %v", test.version, test.expected)
+		})
+	}
+}