Calc need installation releases

This commit is contained in:
LittleSheep 2025-01-13 19:46:51 +08:00
parent fe94b96ce0
commit 9b44d4176f
3 changed files with 54 additions and 0 deletions

View File

@ -19,6 +19,7 @@ func MapAPIs(app *fiber.App, baseURL string) {
releases := products.Group("/:productId/releases") releases := products.Group("/:productId/releases")
{ {
releases.Get("/", listRelease) releases.Get("/", listRelease)
releases.Post("/calc", calcReleaseToInstall)
releases.Get("/:releaseId", getRelease) releases.Get("/:releaseId", getRelease)
releases.Post("/", createRelease) releases.Post("/", createRelease)
releases.Put("/:releaseId", updateRelease) releases.Put("/:releaseId", updateRelease)

View File

@ -30,6 +30,26 @@ func listRelease(c *fiber.Ctx) error {
}) })
} }
func calcReleaseToInstall(c *fiber.Ctx) error {
id, _ := c.ParamsInt("productId", 0)
var data struct {
CurrentVersion string `json:"current"`
TargetVersion string `json:"target"`
}
if err := exts.BindAndValidate(c, &data); err != nil {
return err
}
releases, err := services.CalcReleaseToInstall(id, data.CurrentVersion, data.TargetVersion)
if err != nil {
return fiber.NewError(fiber.StatusBadRequest, err.Error())
}
return c.JSON(releases)
}
func getRelease(c *fiber.Ctx) error { func getRelease(c *fiber.Ctx) error {
productId, _ := c.ParamsInt("productId", 0) productId, _ := c.ParamsInt("productId", 0)
id, _ := c.ParamsInt("releaseId", 0) id, _ := c.ParamsInt("releaseId", 0)

View File

@ -1,6 +1,8 @@
package services package services
import ( import (
"fmt"
"git.solsynth.dev/matrix/nucleus/pkg/internal/database" "git.solsynth.dev/matrix/nucleus/pkg/internal/database"
"git.solsynth.dev/matrix/nucleus/pkg/internal/models" "git.solsynth.dev/matrix/nucleus/pkg/internal/models"
"gorm.io/gorm" "gorm.io/gorm"
@ -15,6 +17,37 @@ func CountRelease(product int) (int64, error) {
return count, nil return count, nil
} }
func CalcReleaseToInstall(product int, current, target string) ([]models.ProductRelease, error) {
var targetRelease models.ProductRelease
if err := database.C.
Where("product_id = ? AND version = ?", product, target).
First(&targetRelease).Error; err != nil {
return nil, fmt.Errorf("target release was not found: %v", err)
}
if targetRelease.Type == models.ReleaseTypeFull {
return []models.ProductRelease{targetRelease}, nil
}
var lastFullRelease models.ProductRelease
if err := database.C.
Where("product_id = ? AND type = ?", product, models.ReleaseTypeFull).
Order("created_at DESC").
First(&lastFullRelease).Error; err != nil {
return nil, fmt.Errorf("failed to find last full release: %v", err)
}
var plannedRelease []models.ProductRelease
if err := database.C.
Where("product_id = ? AND version > ? AND version <= ?", product, lastFullRelease.Version, target).
Order("version ASC").
Find(&plannedRelease).Error; err != nil {
return nil, fmt.Errorf("failed to find planned releases: %v", err)
}
return plannedRelease, nil
}
func ListRelease(product int, take, offset int) ([]models.ProductRelease, error) { func ListRelease(product int, take, offset int) ([]models.ProductRelease, error) {
var items []models.ProductRelease var items []models.ProductRelease
if err := database.C. if err := database.C.