fix: always update pending versions

Author: Kbayero

installer/services/search.go

@@ -42,7 +42,7 @@ func InitOpenSearch() error {
 
 	_, err = grequests.Put(baseURL+"_index_template/utmstack_indexes", &grequests.RequestOptions{
 		JSON: map[string]any{
-			"index_patterns": []string{"alert-*", "log-*", ".utm-*", ".utmstack-*"},
+			"index_patterns": []string{"v11-alert-", "v11-log-", ".utm-", ".utmstack-"},
 			"template": map[string]any{
 				"settings": map[string]any{
 					"index.number_of_shards":           1,

installer/updater/client.go

@@ -115,24 +115,20 @@ func (c *UpdaterClient) CheckUpdate() error {
 		updates = append(updates, newUpdate)
 	}
 
-	currentVersion, err := GetVersion()
-	if err != nil {
-		return fmt.Errorf("error getting current version: %v", err)
-	}
-
 	sortedUpdates := SortVersions(updates)
 
 	for _, update := range sortedUpdates {
-		if update["version"] != currentVersion.Version {
-			err := c.UpdateToNewVersion(update["version"], update["edition"], update["changelog"])
+		// Apply all updates from the server regardless of current version
+		// This allows for rollbacks, pre-release type changes (alpha→dev), and ensures all updates are applied in order
+		// The server is responsible for only sending pending updates (marked as sent after application)
+		err := c.UpdateToNewVersion(update["version"], update["edition"], update["changelog"])
+		if err != nil {
+			return fmt.Errorf("error updating to new version: %v", err)
+		}
+		if update["id"] != "offline" {
+			err = c.MarkUpdateSent(update["id"])
 			if err != nil {
-				return fmt.Errorf("error updating to new version: %v", err)
-			}
-			if update["id"] != "offline" {
-				err = c.MarkUpdateSent(update["id"])
-				if err != nil {
-					return fmt.Errorf("error marking update as sent: %v", err)
-				}
+				return fmt.Errorf("error marking update as sent: %v", err)
 			}
 		}
 	}

installer/updater/versions.go

@@ -127,7 +127,8 @@ func ParseVersion(versionStr string) Version {
 	versionStr = strings.TrimPrefix(versionStr, "V")
 
 	// Parse version with regex: X.Y.Z or X.Y.Z-type.num
-	re := regexp.MustCompile(`^(\d+)\.(\d+)\.(\d+)(?:-(alpha|beta|rc)\.(\d+))?$`)
+	// Supports: dev, alpha, beta, rc
+	re := regexp.MustCompile(`^(\d+)\.(\d+)\.(\d+)(?:-(dev|alpha|beta|rc)\.(\d+))?$`)
 	matches := re.FindStringSubmatch(versionStr)
 
 	if len(matches) > 1 {
@@ -161,11 +162,30 @@ func CompareVersions(v1, v2 Version) int {
 		return v1.Patch - v2.Patch
 	}
 
-	if v1.PrereleaseNum != v2.PrereleaseNum {
-		return v1.PrereleaseNum - v2.PrereleaseNum
+	// Handle stable vs prerelease versions
+	// According to semver: stable version (no prerelease) is GREATER than any prerelease
+	// Example: v11.0.0 > v11.0.0-rc.1 > v11.0.0-beta.1 > v11.0.0-alpha.1 > v11.0.0-dev.1
+	if v1.PrereleaseName == "" && v2.PrereleaseName != "" {
+		return 1 // v1 is stable, v2 is prerelease → v1 > v2
+	}
+	if v1.PrereleaseName != "" && v2.PrereleaseName == "" {
+		return -1 // v1 is prerelease, v2 is stable → v1 < v2
+	}
+
+	// Both are prereleases or both are stable
+	if v1.PrereleaseName != v2.PrereleaseName {
+		// Compare prerelease type names: dev < alpha < beta < rc
+		order := map[string]int{
+			"dev":   1,
+			"alpha": 2,
+			"beta":  3,
+			"rc":    4,
+		}
+		return order[v1.PrereleaseName] - order[v2.PrereleaseName]
 	}
 
-	return 0
+	// Same prerelease type, compare numbers
+	return v1.PrereleaseNum - v2.PrereleaseNum
 }
 
 func SortVersions(versions []map[string]string) []map[string]string {