66 lines
1.7 KiB
Go
66 lines
1.7 KiB
Go
|
package handlers_build
|
||
|
|
|
||
|
|
import (
|
||
|
|
"brunel/buildqueue"
|
||
|
|
"brunel/domain"
|
||
|
|
"brunel/fastmap"
|
||
|
|
"brunel/helpers"
|
||
|
|
"fmt"
|
||
|
|
"strings"
|
||
|
|
|
||
|
|
"github.com/gofiber/fiber/v2"
|
||
|
|
)
|
||
|
|
|
||
|
|
type QueueResponse struct {
|
||
|
|
Total int `json:"total"`
|
||
|
|
Packages *fastmap.Fastmap[string, domain.BuildQueueItem] `json:"packages"`
|
||
|
|
}
|
||
|
|
|
||
|
|
func Queue(c *fiber.Ctx) error {
|
||
|
|
pageNum := c.QueryInt("page", 1)
|
||
|
|
pageSize := c.QueryInt("pageSize", 250)
|
||
|
|
search := strings.ToLower(c.Query("search"))
|
||
|
|
filter := c.Query("filter")
|
||
|
|
|
||
|
|
cacheKey := fmt.Sprintf("buildqueue:%d:%d:%s:%s", pageNum, pageSize, search, filter)
|
||
|
|
if cachedResponse, ok := helpers.Cache.Get(cacheKey); ok {
|
||
|
|
return c.Status(fiber.StatusOK).JSON(cachedResponse)
|
||
|
|
}
|
||
|
|
|
||
|
|
// Adjust pageNum to be 0-based for GetPage
|
||
|
|
adjustedPageNum := pageNum - 1
|
||
|
|
if adjustedPageNum < 0 {
|
||
|
|
adjustedPageNum = 0
|
||
|
|
}
|
||
|
|
|
||
|
|
packs := buildqueue.GetQueue()
|
||
|
|
packs.StableSortByKey()
|
||
|
|
finalReturn := fastmap.New[string, domain.BuildQueueItem]()
|
||
|
|
|
||
|
|
packs.Iter(func(k string, source domain.BuildQueueItem) bool {
|
||
|
|
matchesSearch := search == "" || strings.Contains(strings.ToLower(k), search)
|
||
|
|
matchesFilter := filter == "" || source.Status == domain.BuildStatus(filter)
|
||
|
|
source.Source.Packages.Iter(func(key string, value domain.PackageInfo) bool {
|
||
|
|
if !matchesSearch && strings.Contains(strings.ToLower(key), search) {
|
||
|
|
matchesSearch = true
|
||
|
|
}
|
||
|
|
return !(matchesSearch)
|
||
|
|
})
|
||
|
|
|
||
|
|
if matchesFilter && matchesSearch {
|
||
|
|
finalReturn.Set(k, source)
|
||
|
|
}
|
||
|
|
return true
|
||
|
|
})
|
||
|
|
|
||
|
|
result := finalReturn.GetPage(adjustedPageNum, pageSize)
|
||
|
|
|
||
|
|
response := QueueResponse{
|
||
|
|
Total: finalReturn.Len(),
|
||
|
|
Packages: result,
|
||
|
|
}
|
||
|
|
|
||
|
|
helpers.Cache.Set(cacheKey, response)
|
||
|
|
return c.Status(fiber.StatusOK).JSON(response)
|
||
|
|
}
|