Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
d5a308ac8d | ||
|
|
bb2facd4d1 | ||
|
|
c706665196 | ||
|
|
5d50b609f6 | ||
|
|
4a346c4ed9 | ||
|
|
e78a72d516 |
@@ -22,7 +22,8 @@
|
||||
- **Мониторинг** — состояние, аптайм, CPU и память процесса сервера, свободные
|
||||
ОЗУ и диск на хосте, список игроков онлайн.
|
||||
- **Редактор конфигов** — `servertest.ini` и `SandboxVars.lua` прямо в
|
||||
браузере, с поиском по параметрам и сохранением комментариев в файле.
|
||||
браузере: параметры разложены по разделам, у каждого видно описание из
|
||||
самого конфига, поиск идёт и по названию, и по описанию.
|
||||
- **Мод-менеджер** — моды списком с галочками и перетаскиванием порядка
|
||||
загрузки, добавление по ссылке и разворачивание коллекций Steam целиком.
|
||||
- **Бэкапы** — ручные и по расписанию, отдельно по каждому профилю, с
|
||||
@@ -192,6 +193,22 @@ Mod ID, который нужен серверу, лежит внутри сам
|
||||
Один пакет мастерской может содержать несколько модов — в списке они идут
|
||||
отдельными строками, и включать их можно по отдельности.
|
||||
|
||||
## Редактор конфигов
|
||||
|
||||
Вкладки «Конфиг сервера» и «Песочница» показывают параметры не сплошным
|
||||
списком, а разделами: «Основное», «PVP и урон», «Убежища», «Античит» и так
|
||||
далее. Разделы сворачиваются, а поиск сверху раскрывает те, где нашлось
|
||||
совпадение. Ключи, которых панель не знает (в новой версии игры их всегда
|
||||
добавляют), не теряются — они собираются в раздел «Прочее».
|
||||
|
||||
Описания параметров панель берёт из самого конфига: игра пишет их
|
||||
комментариями на языке сервера. Полный текст виден при наведении, начало —
|
||||
прямо под полем.
|
||||
|
||||
Правка меняет ровно ту строку, которую поправили: комментарии, порядок и
|
||||
переводы строк файла сохраняются, а рядом остаётся копия прежней версии с
|
||||
расширением `.bak`.
|
||||
|
||||
## Профили серверов
|
||||
|
||||
Профиль — это отдельный сервер: свой мир, свой `*.ini`, свои настройки
|
||||
@@ -213,6 +230,20 @@ Mod ID, который нужен серверу, лежит внутри сам
|
||||
При создании профиля можно скопировать `.ini` и настройки песочницы из
|
||||
существующего: удобно, когда нужен тот же набор правил, но чистый мир.
|
||||
|
||||
### Память JVM
|
||||
|
||||
`java_memory` — это `-Xmx`, верхняя граница кучи. `java_memory_min` (`-Xms`)
|
||||
по умолчанию пуст, и это осознанно: равные значения избавляют от роста кучи на
|
||||
ходу, но заставляют JVM занять весь объём сразу при старте. На машине, где
|
||||
столько свободной памяти не набирается, сервер тогда не поднимется вовсе —
|
||||
`Failed to allocate initial Java heap`. Задавайте минимум, только если памяти
|
||||
заведомо хватает.
|
||||
|
||||
Сервер, упавший сразу после запуска три раза подряд, панель перестаёт
|
||||
поднимать автоматически: обычно так проявляется нехватка памяти или битый
|
||||
конфиг, и перезапуск делу не помогает. Пока идёт отсчёт до автоподъёма, его
|
||||
можно отменить кнопкой «Отменить перезапуск».
|
||||
|
||||
Удаление профиля убирает его только из панели — мир и конфиги остаются на
|
||||
диске. Чтобы вернуть профиль, создайте его с тем же идентификатором.
|
||||
|
||||
@@ -327,7 +358,8 @@ profiles: # серверы: у каждого свой м
|
||||
- id: vanilla # vanilla -> vanilla.ini, Saves/Multiplayer/vanilla
|
||||
title: Ванильный мир # как профиль подписан в панели
|
||||
admin_password: "" # пароль админа игрового сервера
|
||||
java_memory: 4g # -Xmx для JVM этого профиля
|
||||
java_memory: 4g # -Xmx: верхняя граница кучи JVM
|
||||
java_memory_min: "" # -Xms: пусто — JVM берёт память по мере надобности
|
||||
extra_args: [] # доп. аргументы start-server.sh
|
||||
- id: modded
|
||||
title: Сборка с модами
|
||||
|
||||
@@ -32,6 +32,9 @@ func (s *Server) handleGetServerConfig(w http.ResponseWriter, r *http.Request) {
|
||||
"path": path,
|
||||
"keys": ini.Keys(),
|
||||
"values": ini.Map(),
|
||||
// Игра сама пишет в конфиг описания параметров на языке сервера —
|
||||
// показываем их, вместо того чтобы придумывать свои.
|
||||
"descriptions": ini.Comments(),
|
||||
})
|
||||
}
|
||||
|
||||
|
||||
@@ -7,15 +7,36 @@ import (
|
||||
"os"
|
||||
|
||||
"github.com/mrleo1nid/pzmanager/internal/config"
|
||||
"github.com/mrleo1nid/pzmanager/internal/pzconfig"
|
||||
"github.com/mrleo1nid/pzmanager/internal/pzserver"
|
||||
)
|
||||
|
||||
// validateProfileMemory проверяет границы кучи JVM здесь, а не при запуске
|
||||
// сервера: иначе про опечатку в профиле стало бы известно только из лога
|
||||
// упавшего сервера.
|
||||
func validateProfileMemory(dto profileDTO) error {
|
||||
maxBytes, err := pzconfig.ParseMemory(dto.JavaMemory)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
minBytes, err := pzconfig.ParseMemory(dto.JavaMemoryMin)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
if maxBytes > 0 && minBytes > maxBytes {
|
||||
return fmt.Errorf("начальный размер памяти (%s) больше максимального (%s)",
|
||||
dto.JavaMemoryMin, dto.JavaMemory)
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
// profileDTO — профиль в том виде, в каком его показывает панель. Пароль
|
||||
// наружу не отдаётся, только признак того, что он задан.
|
||||
type profileDTO struct {
|
||||
ID string `json:"id"`
|
||||
Title string `json:"title"`
|
||||
JavaMemory string `json:"java_memory"`
|
||||
JavaMemoryMin string `json:"java_memory_min"`
|
||||
ExtraArgs []string `json:"extra_args"`
|
||||
HasAdminPassword bool `json:"has_admin_password"`
|
||||
AdminPassword string `json:"admin_password,omitempty"`
|
||||
@@ -33,6 +54,7 @@ func (s *Server) profileToDTO(p config.Profile) profileDTO {
|
||||
ID: p.ID,
|
||||
Title: p.Title,
|
||||
JavaMemory: p.JavaMemory,
|
||||
JavaMemoryMin: p.JavaMemoryMin,
|
||||
ExtraArgs: p.ExtraArgs,
|
||||
HasAdminPassword: p.AdminPassword != "",
|
||||
HasConfig: fileExists(s.cfg.ServerConfigPathFor(p.ID)),
|
||||
@@ -61,11 +83,16 @@ func (s *Server) handleCreateProfile(w http.ResponseWriter, r *http.Request) {
|
||||
if !decodeJSON(w, r, &dto) {
|
||||
return
|
||||
}
|
||||
if err := validateProfileMemory(dto); err != nil {
|
||||
writeError(w, http.StatusBadRequest, err.Error())
|
||||
return
|
||||
}
|
||||
|
||||
profile := config.Profile{
|
||||
ID: dto.ID,
|
||||
Title: dto.Title,
|
||||
JavaMemory: dto.JavaMemory,
|
||||
JavaMemoryMin: dto.JavaMemoryMin,
|
||||
ExtraArgs: dto.ExtraArgs,
|
||||
AdminPassword: dto.AdminPassword,
|
||||
}
|
||||
@@ -133,11 +160,16 @@ func (s *Server) handleUpdateProfile(w http.ResponseWriter, r *http.Request) {
|
||||
if !decodeJSON(w, r, &dto) {
|
||||
return
|
||||
}
|
||||
if err := validateProfileMemory(dto); err != nil {
|
||||
writeError(w, http.StatusBadRequest, err.Error())
|
||||
return
|
||||
}
|
||||
|
||||
updated := config.Profile{
|
||||
ID: id,
|
||||
Title: dto.Title,
|
||||
JavaMemory: dto.JavaMemory,
|
||||
JavaMemoryMin: dto.JavaMemoryMin,
|
||||
ExtraArgs: dto.ExtraArgs,
|
||||
// Пустой пароль означает "оставить прежний": наружу мы его не отдаём,
|
||||
// и форма присылает пустую строку, пока его не меняли.
|
||||
|
||||
@@ -236,12 +236,16 @@ func StartBackupScheduler(ctx context.Context, s *Server) {
|
||||
// При обычном старте то же самое делает супервизор.
|
||||
func (s *Server) applyJavaMemory(log func(string)) error {
|
||||
profile := s.cfg.ActiveProfile()
|
||||
if profile.JavaMemory == "" {
|
||||
if profile.JavaMemory == "" && profile.JavaMemoryMin == "" {
|
||||
return nil
|
||||
}
|
||||
if err := pzconfig.SetJavaMemory(s.cfg.ServerDir, profile.JavaMemory); err != nil {
|
||||
if err := pzconfig.SetJavaMemory(s.cfg.ServerDir, profile.JavaMemory, profile.JavaMemoryMin); err != nil {
|
||||
return err
|
||||
}
|
||||
if profile.JavaMemoryMin != "" {
|
||||
log(fmt.Sprintf("Память JVM: от %s до %s", profile.JavaMemoryMin, profile.JavaMemory))
|
||||
} else {
|
||||
log("Лимит памяти JVM выставлен: " + profile.JavaMemory)
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
@@ -34,6 +34,11 @@ type Profile struct {
|
||||
// запуске: файл запуска сервера общий для всех профилей.
|
||||
JavaMemory string `yaml:"java_memory"`
|
||||
|
||||
// JavaMemoryMin — -Xms. Пусто (по умолчанию) означает, что JVM занимает
|
||||
// память по мере надобности: равные -Xms и -Xmx заставляют её забрать всё
|
||||
// сразу, и на машине с небольшой ОЗУ сервер не поднимется.
|
||||
JavaMemoryMin string `yaml:"java_memory_min"`
|
||||
|
||||
// ExtraArgs — дополнительные аргументы start-server.sh.
|
||||
ExtraArgs []string `yaml:"extra_args"`
|
||||
}
|
||||
|
||||
@@ -16,6 +16,10 @@ type iniLine struct {
|
||||
Key string
|
||||
Value string
|
||||
Raw string
|
||||
// Comment — описание параметра: строки комментария прямо перед ним.
|
||||
// Project Zomboid пишет их на языке сервера, так что панели есть что
|
||||
// показать человеку, не выдумывая своих формулировок.
|
||||
Comment string
|
||||
}
|
||||
|
||||
// INI — конфиг PZ в виде плоских key=value. Разбор сохраняет исходный порядок
|
||||
@@ -23,22 +27,46 @@ type iniLine struct {
|
||||
type INI struct {
|
||||
lines []iniLine
|
||||
index map[string]int
|
||||
// crlf — файл был с виндовыми переводами строк. Сохраняем как было: иначе
|
||||
// правка одного параметра переписывает весь файл целиком.
|
||||
crlf bool
|
||||
}
|
||||
|
||||
// ParseINI разбирает содержимое конфига.
|
||||
func ParseINI(data []byte) *INI {
|
||||
ini := &INI{index: make(map[string]int)}
|
||||
text := strings.ReplaceAll(string(data), "\r\n", "\n")
|
||||
raw := string(data)
|
||||
ini.crlf = strings.Contains(raw, "\r\n")
|
||||
text := strings.ReplaceAll(raw, "\r\n", "\n")
|
||||
|
||||
// Комментарии копим до ближайшего параметра: в конфигах PZ описание стоит
|
||||
// строкой выше. Пустая строка обрывает связь — иначе описание прилипло бы
|
||||
// к следующему блоку.
|
||||
var comment []string
|
||||
|
||||
for _, raw := range strings.Split(text, "\n") {
|
||||
trimmed := strings.TrimSpace(raw)
|
||||
key, value, found := strings.Cut(raw, "=")
|
||||
if !found || trimmed == "" || strings.HasPrefix(trimmed, "#") {
|
||||
|
||||
if strings.HasPrefix(trimmed, "#") {
|
||||
comment = append(comment, strings.TrimSpace(strings.TrimPrefix(trimmed, "#")))
|
||||
ini.lines = append(ini.lines, iniLine{Raw: raw})
|
||||
continue
|
||||
}
|
||||
if !found || trimmed == "" {
|
||||
comment = nil
|
||||
ini.lines = append(ini.lines, iniLine{Raw: raw})
|
||||
continue
|
||||
}
|
||||
|
||||
key = strings.TrimSpace(key)
|
||||
ini.index[key] = len(ini.lines)
|
||||
ini.lines = append(ini.lines, iniLine{Key: key, Value: strings.TrimSpace(value)})
|
||||
ini.lines = append(ini.lines, iniLine{
|
||||
Key: key,
|
||||
Value: strings.TrimSpace(value),
|
||||
Comment: strings.Join(comment, " "),
|
||||
})
|
||||
comment = nil
|
||||
}
|
||||
return ini
|
||||
}
|
||||
@@ -90,6 +118,17 @@ func (i *INI) Keys() []string {
|
||||
return out
|
||||
}
|
||||
|
||||
// Comments возвращает описания параметров: ключ -> текст комментария.
|
||||
func (i *INI) Comments() map[string]string {
|
||||
out := make(map[string]string, len(i.index))
|
||||
for _, l := range i.lines {
|
||||
if l.Key != "" && l.Comment != "" {
|
||||
out[l.Key] = l.Comment
|
||||
}
|
||||
}
|
||||
return out
|
||||
}
|
||||
|
||||
// Map отдаёт все параметры в виде словаря.
|
||||
func (i *INI) Map() map[string]string {
|
||||
out := make(map[string]string, len(i.index))
|
||||
@@ -103,6 +142,11 @@ func (i *INI) Map() map[string]string {
|
||||
|
||||
// Render собирает файл обратно в текст.
|
||||
func (i *INI) Render() []byte {
|
||||
newline := "\n"
|
||||
if i.crlf {
|
||||
newline = "\r\n"
|
||||
}
|
||||
|
||||
var buf bytes.Buffer
|
||||
for n, l := range i.lines {
|
||||
if l.Key == "" {
|
||||
@@ -113,7 +157,7 @@ func (i *INI) Render() []byte {
|
||||
buf.WriteString(l.Value)
|
||||
}
|
||||
if n < len(i.lines)-1 {
|
||||
buf.WriteByte('\n')
|
||||
buf.WriteString(newline)
|
||||
}
|
||||
}
|
||||
return buf.Bytes()
|
||||
|
||||
+63
-13
@@ -6,24 +6,71 @@ import (
|
||||
"os"
|
||||
"path/filepath"
|
||||
"regexp"
|
||||
"strconv"
|
||||
"strings"
|
||||
)
|
||||
|
||||
// javaLauncherFile — файл, из которого сервер берёт аргументы JVM.
|
||||
const javaLauncherFile = "ProjectZomboid64.json"
|
||||
|
||||
var xmxRe = regexp.MustCompile(`^-Xm[sx]`)
|
||||
var (
|
||||
heapArgRe = regexp.MustCompile(`^-Xm[sx]`)
|
||||
memoryRe = regexp.MustCompile(`^([0-9]+)([kKmMgG])$`)
|
||||
)
|
||||
|
||||
// SetJavaMemory прописывает лимит памяти JVM в ProjectZomboid64.json. Именно
|
||||
// оттуда start-server.sh берёт -Xmx, поэтому менять размер памяти в аргументах
|
||||
// запуска бесполезно.
|
||||
func SetJavaMemory(serverDir, memory string) error {
|
||||
memory = strings.TrimSpace(memory)
|
||||
if memory == "" {
|
||||
// ParseMemory переводит запись вида "4g" в байты. Возвращает 0, если строка
|
||||
// пустая, и ошибку, если формат непонятен.
|
||||
func ParseMemory(value string) (int64, error) {
|
||||
value = strings.TrimSpace(value)
|
||||
if value == "" {
|
||||
return 0, nil
|
||||
}
|
||||
match := memoryRe.FindStringSubmatch(value)
|
||||
if match == nil {
|
||||
return 0, fmt.Errorf("объём памяти должен выглядеть как 4g или 8192m, получено %q", value)
|
||||
}
|
||||
amount, err := strconv.ParseInt(match[1], 10, 64)
|
||||
if err != nil {
|
||||
return 0, fmt.Errorf("не разобран объём памяти %q", value)
|
||||
}
|
||||
switch strings.ToLower(match[2]) {
|
||||
case "k":
|
||||
return amount * 1024, nil
|
||||
case "m":
|
||||
return amount * 1024 * 1024, nil
|
||||
default:
|
||||
return amount * 1024 * 1024 * 1024, nil
|
||||
}
|
||||
}
|
||||
|
||||
// SetJavaMemory прописывает границы кучи JVM в ProjectZomboid64.json. Именно
|
||||
// оттуда start-server.sh берёт -Xmx и -Xms, поэтому менять размер памяти в
|
||||
// аргументах запуска бесполезно.
|
||||
//
|
||||
// maxMemory задаёт -Xmx (верхнюю границу), minMemory — -Xms. Пустой minMemory
|
||||
// означает, что -Xms не выставляется вовсе: JVM тогда занимает память по мере
|
||||
// надобности. Равные значения удобны тем, что куча не растёт на ходу, но JVM
|
||||
// обязана занять весь объём при старте — на машине с небольшой ОЗУ сервер
|
||||
// просто не поднимется.
|
||||
func SetJavaMemory(serverDir, maxMemory, minMemory string) error {
|
||||
maxMemory = strings.TrimSpace(maxMemory)
|
||||
minMemory = strings.TrimSpace(minMemory)
|
||||
if maxMemory == "" && minMemory == "" {
|
||||
return nil
|
||||
}
|
||||
if !regexp.MustCompile(`^[0-9]+[kKmMgG]$`).MatchString(memory) {
|
||||
return fmt.Errorf("объём памяти должен выглядеть как 4g или 8192m, получено %q", memory)
|
||||
|
||||
maxBytes, err := ParseMemory(maxMemory)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
minBytes, err := ParseMemory(minMemory)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
// JVM с -Xms больше -Xmx не стартует вообще, поэтому ловим это здесь, а не
|
||||
// в логе упавшего сервера.
|
||||
if maxBytes > 0 && minBytes > maxBytes {
|
||||
return fmt.Errorf("начальный размер кучи (%s) больше максимального (%s)", minMemory, maxMemory)
|
||||
}
|
||||
|
||||
path := filepath.Join(serverDir, javaLauncherFile)
|
||||
@@ -41,14 +88,17 @@ func SetJavaMemory(serverDir, memory string) error {
|
||||
args, _ := doc["vmArgs"].([]any)
|
||||
updated := make([]any, 0, len(args)+2)
|
||||
for _, a := range args {
|
||||
if str, ok := a.(string); ok && xmxRe.MatchString(str) {
|
||||
if str, ok := a.(string); ok && heapArgRe.MatchString(str) {
|
||||
continue
|
||||
}
|
||||
updated = append(updated, a)
|
||||
}
|
||||
// -Xms равным -Xmx: JVM сразу забирает память и не тратит время на рост
|
||||
// кучи в момент, когда на сервере много игроков.
|
||||
updated = append(updated, "-Xms"+memory, "-Xmx"+memory)
|
||||
if minMemory != "" {
|
||||
updated = append(updated, "-Xms"+minMemory)
|
||||
}
|
||||
if maxMemory != "" {
|
||||
updated = append(updated, "-Xmx"+maxMemory)
|
||||
}
|
||||
doc["vmArgs"] = updated
|
||||
|
||||
out, err := json.MarshalIndent(doc, "", " ")
|
||||
|
||||
@@ -0,0 +1,167 @@
|
||||
package pzconfig
|
||||
|
||||
import (
|
||||
"encoding/json"
|
||||
"os"
|
||||
"path/filepath"
|
||||
"testing"
|
||||
)
|
||||
|
||||
// TestSetJavaMemoryKeepsOnlyXmx: -Xms равным -Xmx заставляет JVM занять весь
|
||||
// объём при старте, и на машине с небольшой ОЗУ сервер падает с «Failed to
|
||||
// allocate initial Java heap». Ставим только верхнюю границу.
|
||||
func TestSetJavaMemoryKeepsOnlyXmx(t *testing.T) {
|
||||
dir := t.TempDir()
|
||||
writeLauncher(t, dir, map[string]any{
|
||||
"mainClass": "zombie/network/GameServer",
|
||||
"vmArgs": []any{
|
||||
"-Djava.awt.headless=true",
|
||||
"-XX:+UseZGC",
|
||||
// Значения от прошлой установки должны замениться.
|
||||
"-Xms8g",
|
||||
"-Xmx8g",
|
||||
},
|
||||
})
|
||||
|
||||
if err := SetJavaMemory(dir, "3g", ""); err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
|
||||
args := launcherArgs(t, dir)
|
||||
var xms, xmx int
|
||||
for _, a := range args {
|
||||
switch {
|
||||
case len(a) > 4 && a[:4] == "-Xms":
|
||||
xms++
|
||||
t.Errorf("в аргументах остался %s — JVM займёт всю память при старте", a)
|
||||
case a == "-Xmx3g":
|
||||
xmx++
|
||||
}
|
||||
}
|
||||
if xms != 0 {
|
||||
t.Errorf("-Xms не должен добавляться, найдено вхождений: %d", xms)
|
||||
}
|
||||
if xmx != 1 {
|
||||
t.Errorf("-Xmx3g встречается %d раз, ожидалось 1: %v", xmx, args)
|
||||
}
|
||||
|
||||
// Чужие аргументы должны остаться нетронутыми.
|
||||
if !contains(args, "-XX:+UseZGC") || !contains(args, "-Djava.awt.headless=true") {
|
||||
t.Errorf("потеряны исходные аргументы: %v", args)
|
||||
}
|
||||
}
|
||||
|
||||
func TestSetJavaMemoryValidates(t *testing.T) {
|
||||
dir := t.TempDir()
|
||||
writeLauncher(t, dir, map[string]any{"vmArgs": []any{}})
|
||||
|
||||
for _, bad := range []string{"4", "4gb", "много", "-4g", "4g; rm -rf /"} {
|
||||
if err := SetJavaMemory(dir, bad, ""); err == nil {
|
||||
t.Errorf("значение %q принято, ожидалась ошибка", bad)
|
||||
}
|
||||
}
|
||||
// Пустые значения — «не трогать», это не ошибка.
|
||||
if err := SetJavaMemory(dir, "", ""); err != nil {
|
||||
t.Errorf("пустое значение вернуло ошибку: %v", err)
|
||||
}
|
||||
for _, good := range []string{"512m", "4g", "8G", "16384M"} {
|
||||
if err := SetJavaMemory(dir, good, ""); err != nil {
|
||||
t.Errorf("значение %q отклонено: %v", good, err)
|
||||
}
|
||||
}
|
||||
|
||||
// JVM с -Xms больше -Xmx не стартует, поэтому ловим это заранее.
|
||||
if err := SetJavaMemory(dir, "2g", "4g"); err == nil {
|
||||
t.Error("начальный размер больше максимального принят, ожидалась ошибка")
|
||||
}
|
||||
if err := SetJavaMemory(dir, "4g", "2g"); err != nil {
|
||||
t.Errorf("корректная пара 2g/4g отклонена: %v", err)
|
||||
}
|
||||
}
|
||||
|
||||
func writeLauncher(t *testing.T, dir string, doc map[string]any) {
|
||||
t.Helper()
|
||||
raw, err := json.MarshalIndent(doc, "", " ")
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
if err := os.WriteFile(filepath.Join(dir, javaLauncherFile), raw, 0o644); err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
}
|
||||
|
||||
func launcherArgs(t *testing.T, dir string) []string {
|
||||
t.Helper()
|
||||
raw, err := os.ReadFile(filepath.Join(dir, javaLauncherFile))
|
||||
if err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
var doc struct {
|
||||
VMArgs []string `json:"vmArgs"`
|
||||
}
|
||||
if err := json.Unmarshal(raw, &doc); err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
return doc.VMArgs
|
||||
}
|
||||
|
||||
func contains(list []string, want string) bool {
|
||||
for _, item := range list {
|
||||
if item == want {
|
||||
return true
|
||||
}
|
||||
}
|
||||
return false
|
||||
}
|
||||
|
||||
// TestSetJavaMemoryWritesXmsWhenAsked: минимальный размер кучи задаётся
|
||||
// отдельно и попадает в файл, только если его действительно указали.
|
||||
func TestSetJavaMemoryWritesXmsWhenAsked(t *testing.T) {
|
||||
dir := t.TempDir()
|
||||
writeLauncher(t, dir, map[string]any{"vmArgs": []any{"-XX:+UseZGC"}})
|
||||
|
||||
if err := SetJavaMemory(dir, "6g", "2g"); err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
args := launcherArgs(t, dir)
|
||||
if !contains(args, "-Xms2g") || !contains(args, "-Xmx6g") {
|
||||
t.Fatalf("границы кучи не выставлены: %v", args)
|
||||
}
|
||||
|
||||
// Убрали минимум — из файла он тоже должен уйти.
|
||||
if err := SetJavaMemory(dir, "6g", ""); err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
args = launcherArgs(t, dir)
|
||||
for _, a := range args {
|
||||
if len(a) > 4 && a[:4] == "-Xms" {
|
||||
t.Errorf("после очистки минимума остался %s: %v", a, args)
|
||||
}
|
||||
}
|
||||
if !contains(args, "-Xmx6g") {
|
||||
t.Errorf("максимум потерян: %v", args)
|
||||
}
|
||||
}
|
||||
|
||||
func TestParseMemory(t *testing.T) {
|
||||
cases := map[string]int64{
|
||||
"": 0,
|
||||
"512m": 512 * 1024 * 1024,
|
||||
"4g": 4 * 1024 * 1024 * 1024,
|
||||
"8G": 8 * 1024 * 1024 * 1024,
|
||||
"1024k": 1024 * 1024,
|
||||
}
|
||||
for input, want := range cases {
|
||||
got, err := ParseMemory(input)
|
||||
if err != nil {
|
||||
t.Errorf("ParseMemory(%q): %v", input, err)
|
||||
continue
|
||||
}
|
||||
if got != want {
|
||||
t.Errorf("ParseMemory(%q) = %d, ожидалось %d", input, got, want)
|
||||
}
|
||||
}
|
||||
if _, err := ParseMemory("4гб"); err == nil {
|
||||
t.Error("значение с кириллицей принято")
|
||||
}
|
||||
}
|
||||
@@ -154,3 +154,34 @@ func TestSandboxEntriesFollowFileOrder(t *testing.T) {
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// TestKeepsWindowsLineEndings: конфиги, созданные игрой на Windows, приходят с
|
||||
// CRLF. Если при сохранении переписать их в LF, изменится каждая строка файла —
|
||||
// правка одного параметра превратится в полную перезапись.
|
||||
func TestKeepsWindowsLineEndings(t *testing.T) {
|
||||
ini := ParseINI([]byte("# Комментарий\r\nMaxPlayers=32\r\nPVP=true\r\n"))
|
||||
ini.Set("MaxPlayers", "64")
|
||||
|
||||
got := string(ini.Render())
|
||||
if strings.Count(got, "\r\n") != 3 {
|
||||
t.Errorf("переводы строк не сохранены:\n%q", got)
|
||||
}
|
||||
if strings.Contains(strings.ReplaceAll(got, "\r\n", ""), "\n") {
|
||||
t.Errorf("в файле появились одиночные LF:\n%q", got)
|
||||
}
|
||||
|
||||
// Файл с LF таким и остаётся.
|
||||
unix := ParseINI([]byte("MaxPlayers=32\nPVP=true"))
|
||||
unix.Set("PVP", "false")
|
||||
if strings.Contains(string(unix.Render()), "\r") {
|
||||
t.Error("в файл с LF добавились CR")
|
||||
}
|
||||
|
||||
sandbox := ParseSandbox([]byte("SandboxVars = {\r\n Zombies = 3,\r\n}\r\n"))
|
||||
if err := sandbox.Set("Zombies", "1"); err != nil {
|
||||
t.Fatal(err)
|
||||
}
|
||||
if strings.Count(string(sandbox.Render()), "\r\n") != 3 {
|
||||
t.Errorf("песочница потеряла CRLF:\n%q", string(sandbox.Render()))
|
||||
}
|
||||
}
|
||||
|
||||
@@ -13,6 +13,9 @@ import (
|
||||
type SandboxEntry struct {
|
||||
Path string `json:"path"`
|
||||
Value string `json:"value"`
|
||||
// Comment — строки "--" перед параметром: игра расписывает там смысл
|
||||
// значения и расшифровку вариантов.
|
||||
Comment string `json:"comment,omitempty"`
|
||||
}
|
||||
|
||||
// Sandbox — разбор <server>_SandboxVars.lua. Файл генерируется игрой и имеет
|
||||
@@ -24,6 +27,10 @@ type Sandbox struct {
|
||||
lines []string
|
||||
// index сопоставляет путь параметра с номером строки.
|
||||
index map[string]int
|
||||
// comments хранит описание параметра по его пути.
|
||||
comments map[string]string
|
||||
// crlf — файл был с виндовыми переводами строк; сохраняем как было.
|
||||
crlf bool
|
||||
}
|
||||
|
||||
var (
|
||||
@@ -33,14 +40,24 @@ var (
|
||||
|
||||
// ParseSandbox разбирает содержимое SandboxVars.lua.
|
||||
func ParseSandbox(data []byte) *Sandbox {
|
||||
s := &Sandbox{index: make(map[string]int)}
|
||||
text := strings.ReplaceAll(string(data), "\r\n", "\n")
|
||||
s := &Sandbox{index: make(map[string]int), comments: make(map[string]string)}
|
||||
raw := string(data)
|
||||
s.crlf = strings.Contains(raw, "\r\n")
|
||||
text := strings.ReplaceAll(raw, "\r\n", "\n")
|
||||
s.lines = strings.Split(text, "\n")
|
||||
|
||||
var stack []string
|
||||
// Комментарии копим до ближайшего параметра, как и в .ini.
|
||||
var comment []string
|
||||
|
||||
for n, line := range s.lines {
|
||||
trimmed := strings.TrimSpace(line)
|
||||
if trimmed == "" || strings.HasPrefix(trimmed, "--") {
|
||||
if strings.HasPrefix(trimmed, "--") {
|
||||
comment = append(comment, strings.TrimSpace(strings.TrimPrefix(trimmed, "--")))
|
||||
continue
|
||||
}
|
||||
if trimmed == "" {
|
||||
comment = nil
|
||||
continue
|
||||
}
|
||||
if sandboxCloseRe.MatchString(line) {
|
||||
@@ -62,6 +79,7 @@ func ParseSandbox(data []byte) *Sandbox {
|
||||
} else {
|
||||
stack = stack[:0]
|
||||
}
|
||||
comment = nil
|
||||
continue
|
||||
}
|
||||
path := name
|
||||
@@ -69,6 +87,10 @@ func ParseSandbox(data []byte) *Sandbox {
|
||||
path = strings.Join(stack, ".") + "." + name
|
||||
}
|
||||
s.index[path] = n
|
||||
if len(comment) > 0 {
|
||||
s.comments[path] = strings.Join(comment, " ")
|
||||
}
|
||||
comment = nil
|
||||
}
|
||||
return s
|
||||
}
|
||||
@@ -95,7 +117,11 @@ func (s *Sandbox) Entries() []SandboxEntry {
|
||||
if !ok {
|
||||
continue
|
||||
}
|
||||
out = append(out, SandboxEntry{Path: path, Value: s.valueAt(n)})
|
||||
out = append(out, SandboxEntry{
|
||||
Path: path,
|
||||
Value: s.valueAt(n),
|
||||
Comment: s.comments[path],
|
||||
})
|
||||
}
|
||||
return out
|
||||
}
|
||||
@@ -139,11 +165,16 @@ func (s *Sandbox) Set(path, value string) error {
|
||||
|
||||
// Render собирает файл обратно.
|
||||
func (s *Sandbox) Render() []byte {
|
||||
newline := "\n"
|
||||
if s.crlf {
|
||||
newline = "\r\n"
|
||||
}
|
||||
|
||||
var buf bytes.Buffer
|
||||
for n, line := range s.lines {
|
||||
buf.WriteString(line)
|
||||
if n < len(s.lines)-1 {
|
||||
buf.WriteByte('\n')
|
||||
buf.WriteString(newline)
|
||||
}
|
||||
}
|
||||
return buf.Bytes()
|
||||
|
||||
@@ -24,6 +24,9 @@ type State string
|
||||
|
||||
const (
|
||||
StateStopped State = "stopped"
|
||||
// StateRestarting — сервер упал и ждёт автоподъёма. Отдельное состояние
|
||||
// нужно, чтобы это ожидание можно было отменить кнопкой.
|
||||
StateRestarting State = "restarting"
|
||||
StateStarting State = "starting"
|
||||
StateRunning State = "running"
|
||||
StateStopping State = "stopping"
|
||||
@@ -42,6 +45,14 @@ const playersPollInterval = 30 * time.Second
|
||||
// restartDelay — пауза перед автоподъёмом упавшего сервера.
|
||||
const restartDelay = 10 * time.Second
|
||||
|
||||
// Сервер, падающий сразу после старта, автоперезапуском не лечится: обычно
|
||||
// это нехватка памяти или испорченный конфиг. После нескольких таких падений
|
||||
// подряд перестаём поднимать его сам, чтобы не крутить бесконечный цикл.
|
||||
const (
|
||||
quickCrashWindow = time.Minute
|
||||
maxQuickCrashes = 3
|
||||
)
|
||||
|
||||
// Status — снимок состояния для веб-панели.
|
||||
type Status struct {
|
||||
State State `json:"state"`
|
||||
@@ -56,6 +67,8 @@ type Status struct {
|
||||
PlayersAt int64 `json:"players_at"`
|
||||
LastExit string `json:"last_exit"`
|
||||
AutoRestart bool `json:"auto_restart"`
|
||||
// RestartInSec — сколько секунд осталось до автоподъёма (0, если не ждём).
|
||||
RestartInSec int64 `json:"restart_in_sec"`
|
||||
Proc sysinfo.ProcStats `json:"proc"`
|
||||
Host sysinfo.HostStats `json:"host"`
|
||||
}
|
||||
@@ -89,6 +102,13 @@ type Supervisor struct {
|
||||
captured []string
|
||||
autoQuery bool
|
||||
|
||||
// restartCancel закрывается, чтобы отменить ожидание автоперезапуска;
|
||||
// restartAt — когда оно закончится.
|
||||
restartCancel chan struct{}
|
||||
restartAt time.Time
|
||||
// crashStreak — сколько раз подряд сервер упал сразу после запуска.
|
||||
crashStreak int
|
||||
|
||||
sampler *sysinfo.Sampler
|
||||
stopOnce sync.Once
|
||||
quit chan struct{}
|
||||
@@ -165,9 +185,14 @@ func (s *Supervisor) Status() Status {
|
||||
if s.cmd != nil && s.cmd.Process != nil {
|
||||
st.PID = s.cmd.Process.Pid
|
||||
}
|
||||
if !s.startedAt.IsZero() && s.state != StateStopped {
|
||||
if !s.startedAt.IsZero() && s.state != StateStopped && s.state != StateRestarting {
|
||||
st.UptimeSec = int64(time.Since(s.startedAt).Seconds())
|
||||
}
|
||||
if s.state == StateRestarting && !s.restartAt.IsZero() {
|
||||
if left := time.Until(s.restartAt).Seconds(); left > 0 {
|
||||
st.RestartInSec = int64(left + 0.5)
|
||||
}
|
||||
}
|
||||
s.mu.Unlock()
|
||||
|
||||
st.Installed = s.Installed()
|
||||
@@ -185,9 +210,28 @@ func (s *Supervisor) Status() Status {
|
||||
func (s *Supervisor) Start() error {
|
||||
s.mu.Lock()
|
||||
defer s.mu.Unlock()
|
||||
|
||||
// Запуск руками — знак, что причину падений устранили.
|
||||
s.crashStreak = 0
|
||||
// Если ждали автоподъёма, поднимаем немедленно.
|
||||
s.cancelRestartLocked()
|
||||
return s.startLocked()
|
||||
}
|
||||
|
||||
// cancelRestartLocked снимает запланированный автоперезапуск. Вызывается под
|
||||
// удержанным s.mu.
|
||||
func (s *Supervisor) cancelRestartLocked() {
|
||||
if s.restartCancel == nil {
|
||||
return
|
||||
}
|
||||
close(s.restartCancel)
|
||||
s.restartCancel = nil
|
||||
s.restartAt = time.Time{}
|
||||
if s.state == StateRestarting {
|
||||
s.state = StateStopped
|
||||
}
|
||||
}
|
||||
|
||||
func (s *Supervisor) startLocked() error {
|
||||
if s.state != StateStopped {
|
||||
return ErrAlreadyRunning
|
||||
@@ -204,8 +248,8 @@ func (s *Supervisor) startLocked() error {
|
||||
profile := s.cfg.ActiveProfile()
|
||||
// Лимит памяти живёт в файле запуска, общем для всех профилей, поэтому
|
||||
// выставляем его на каждом старте — иначе профиль унаследует чужой -Xmx.
|
||||
if err := pzconfig.SetJavaMemory(s.cfg.ServerDir, profile.JavaMemory); err != nil {
|
||||
s.AppendLog("manager", "Не удалось выставить лимит памяти JVM: "+err.Error())
|
||||
if err := pzconfig.SetJavaMemory(s.cfg.ServerDir, profile.JavaMemory, profile.JavaMemoryMin); err != nil {
|
||||
s.AppendLog("manager", "Не удалось выставить границы памяти JVM: "+err.Error())
|
||||
}
|
||||
|
||||
args := []string{"-servername", profile.ID}
|
||||
@@ -322,6 +366,8 @@ func (s *Supervisor) wait(cmd *exec.Cmd, exited chan struct{}) {
|
||||
err := cmd.Wait()
|
||||
close(exited)
|
||||
|
||||
lifetime := time.Since(s.startedAt)
|
||||
|
||||
s.mu.Lock()
|
||||
wasIntentional := s.intentionalStop
|
||||
s.state = StateStopped
|
||||
@@ -336,6 +382,15 @@ func (s *Supervisor) wait(cmd *exec.Cmd, exited chan struct{}) {
|
||||
s.lastExit = "штатное завершение"
|
||||
}
|
||||
reason := s.lastExit
|
||||
|
||||
// Падение сразу после запуска — признак того, что перезапуск не поможет:
|
||||
// не хватило памяти, испорчен конфиг, нет файлов сервера.
|
||||
if !wasIntentional && lifetime < quickCrashWindow {
|
||||
s.crashStreak++
|
||||
} else {
|
||||
s.crashStreak = 0
|
||||
}
|
||||
streak := s.crashStreak
|
||||
autoRestart := s.cfg.AutoRestart && !wasIntentional
|
||||
s.mu.Unlock()
|
||||
|
||||
@@ -343,14 +398,38 @@ func (s *Supervisor) wait(cmd *exec.Cmd, exited chan struct{}) {
|
||||
if !autoRestart {
|
||||
return
|
||||
}
|
||||
if streak >= maxQuickCrashes {
|
||||
s.AppendLog("manager", fmt.Sprintf(
|
||||
"Сервер падает сразу после запуска %d раза подряд — автоперезапуск остановлен. "+
|
||||
"Посмотрите ошибку выше и запустите сервер вручную.", streak))
|
||||
return
|
||||
}
|
||||
|
||||
s.mu.Lock()
|
||||
cancel := make(chan struct{})
|
||||
s.restartCancel = cancel
|
||||
s.restartAt = time.Now().Add(restartDelay)
|
||||
s.state = StateRestarting
|
||||
s.mu.Unlock()
|
||||
|
||||
s.AppendLog("manager", fmt.Sprintf("Автоперезапуск через %s (можно отменить кнопкой «Остановить»)", restartDelay))
|
||||
|
||||
s.AppendLog("manager", fmt.Sprintf("Автоперезапуск через %s", restartDelay))
|
||||
select {
|
||||
case <-time.After(restartDelay):
|
||||
case <-cancel:
|
||||
// Состояние уже переставил тот, кто отменил ожидание.
|
||||
s.AppendLog("manager", "Автоперезапуск отменён")
|
||||
return
|
||||
case <-s.quit:
|
||||
return
|
||||
}
|
||||
|
||||
s.mu.Lock()
|
||||
s.restartCancel = nil
|
||||
s.restartAt = time.Time{}
|
||||
if s.state == StateRestarting {
|
||||
s.state = StateStopped
|
||||
}
|
||||
err = s.startLocked()
|
||||
s.mu.Unlock()
|
||||
if err != nil && !errors.Is(err, ErrAlreadyRunning) {
|
||||
@@ -394,6 +473,12 @@ func (s *Supervisor) sendQuiet(command string) error {
|
||||
// мир), затем SIGTERM группе процессов и в крайнем случае SIGKILL.
|
||||
func (s *Supervisor) Stop() error {
|
||||
s.mu.Lock()
|
||||
// Ждём автоподъёма — «остановить» здесь значит «не поднимать».
|
||||
if s.state == StateRestarting {
|
||||
s.cancelRestartLocked()
|
||||
s.mu.Unlock()
|
||||
return nil
|
||||
}
|
||||
if s.state == StateStopped || s.cmd == nil {
|
||||
s.mu.Unlock()
|
||||
return ErrNotRunning
|
||||
|
||||
+69
-14
@@ -16,6 +16,7 @@ import (
|
||||
"fmt"
|
||||
"net/http"
|
||||
"os/exec"
|
||||
"sort"
|
||||
"strconv"
|
||||
"strings"
|
||||
"time"
|
||||
@@ -27,6 +28,14 @@ const adminCommand = "pzmanager-admin"
|
||||
// ErrNoAdmin возвращается, когда обновление из панели недоступно.
|
||||
var ErrNoAdmin = errors.New("обновление из панели недоступно: нет pzmanager-admin или правила sudo")
|
||||
|
||||
// ReleaseNote — одна версия в списке изменений.
|
||||
type ReleaseNote struct {
|
||||
Version string `json:"version"`
|
||||
Notes string `json:"notes"`
|
||||
Published int64 `json:"published"`
|
||||
URL string `json:"url"`
|
||||
}
|
||||
|
||||
// Info — то, что панель показывает в разделе обновления.
|
||||
type Info struct {
|
||||
Current string `json:"current"`
|
||||
@@ -40,6 +49,10 @@ type Info struct {
|
||||
CanApply bool `json:"can_apply"`
|
||||
// ManualCommand — что выполнить в терминале, если сама не может.
|
||||
ManualCommand string `json:"manual_command"`
|
||||
// Changelog — все версии между установленной и последней, свежие первыми.
|
||||
// Одного описания последнего релиза мало: пропустив пару версий, человек
|
||||
// не увидит, что менялось в промежутке.
|
||||
Changelog []ReleaseNote `json:"changelog"`
|
||||
// Error — почему не удалось узнать последнюю версию.
|
||||
Error string `json:"error,omitempty"`
|
||||
}
|
||||
@@ -75,12 +88,14 @@ func (u *Updater) apiBase() (string, error) {
|
||||
return fmt.Sprintf("%s://%s/api/v1/repos/%s", scheme, host, path), nil
|
||||
}
|
||||
|
||||
// Check спрашивает у Gitea последний релиз и сравнивает его с текущей версией.
|
||||
// Check спрашивает у Gitea список релизов и оставляет те, что новее
|
||||
// установленной версии.
|
||||
func (u *Updater) Check(ctx context.Context) Info {
|
||||
info := Info{
|
||||
Current: u.Version,
|
||||
CanApply: u.CanApply(ctx),
|
||||
ManualCommand: u.manualCommand(),
|
||||
Changelog: []ReleaseNote{},
|
||||
}
|
||||
|
||||
api, err := u.apiBase()
|
||||
@@ -89,7 +104,10 @@ func (u *Updater) Check(ctx context.Context) Info {
|
||||
return info
|
||||
}
|
||||
|
||||
req, err := http.NewRequestWithContext(ctx, http.MethodGet, api+"/releases/latest", nil)
|
||||
// limit с запасом: показываем изменения за все пропущенные версии, но не
|
||||
// тянем историю репозитория целиком.
|
||||
req, err := http.NewRequestWithContext(ctx, http.MethodGet,
|
||||
api+"/releases?limit=30&draft=false", nil)
|
||||
if err != nil {
|
||||
info.Error = err.Error()
|
||||
return info
|
||||
@@ -101,36 +119,73 @@ func (u *Updater) Check(ctx context.Context) Info {
|
||||
}
|
||||
defer resp.Body.Close()
|
||||
|
||||
if resp.StatusCode == http.StatusNotFound {
|
||||
info.Error = "в репозитории ещё нет релизов"
|
||||
return info
|
||||
}
|
||||
if resp.StatusCode != http.StatusOK {
|
||||
info.Error = "репозиторий ответил " + resp.Status
|
||||
return info
|
||||
}
|
||||
|
||||
var release struct {
|
||||
var releases []struct {
|
||||
TagName string `json:"tag_name"`
|
||||
Body string `json:"body"`
|
||||
HTMLURL string `json:"html_url"`
|
||||
PublishedAt time.Time `json:"published_at"`
|
||||
Draft bool `json:"draft"`
|
||||
Prerelease bool `json:"prerelease"`
|
||||
}
|
||||
if err := json.NewDecoder(resp.Body).Decode(&release); err != nil {
|
||||
if err := json.NewDecoder(resp.Body).Decode(&releases); err != nil {
|
||||
info.Error = "ответ репозитория не разобран: " + err.Error()
|
||||
return info
|
||||
}
|
||||
|
||||
info.Latest = release.TagName
|
||||
info.Notes = release.Body
|
||||
info.URL = release.HTMLURL
|
||||
if !release.PublishedAt.IsZero() {
|
||||
info.Published = release.PublishedAt.Unix()
|
||||
notes := make([]ReleaseNote, 0, len(releases))
|
||||
for _, r := range releases {
|
||||
if r.Draft || r.Prerelease || r.TagName == "" {
|
||||
continue
|
||||
}
|
||||
info.Available = IsNewer(u.Version, release.TagName)
|
||||
note := ReleaseNote{Version: r.TagName, Notes: r.Body, URL: r.HTMLURL}
|
||||
if !r.PublishedAt.IsZero() {
|
||||
note.Published = r.PublishedAt.Unix()
|
||||
}
|
||||
notes = append(notes, note)
|
||||
}
|
||||
if len(notes) == 0 {
|
||||
info.Error = "в репозитории ещё нет релизов"
|
||||
return info
|
||||
}
|
||||
|
||||
// Gitea отдаёт релизы свежими вперёд, но полагаться на это не станем.
|
||||
sort.Slice(notes, func(i, j int) bool {
|
||||
if IsNewer(notes[j].Version, notes[i].Version) {
|
||||
return true
|
||||
}
|
||||
if IsNewer(notes[i].Version, notes[j].Version) {
|
||||
return false
|
||||
}
|
||||
return notes[i].Published > notes[j].Published
|
||||
})
|
||||
|
||||
latest := notes[0]
|
||||
info.Latest = latest.Version
|
||||
info.Notes = latest.Notes
|
||||
info.URL = latest.URL
|
||||
info.Published = latest.Published
|
||||
info.Available = IsNewer(u.Version, latest.Version)
|
||||
info.Changelog = NewerThan(notes, u.Version)
|
||||
return info
|
||||
}
|
||||
|
||||
// NewerThan оставляет из списка релизы новее указанной версии, сохраняя
|
||||
// порядок «свежие первыми».
|
||||
func NewerThan(notes []ReleaseNote, current string) []ReleaseNote {
|
||||
out := make([]ReleaseNote, 0, len(notes))
|
||||
for _, note := range notes {
|
||||
if IsNewer(current, note.Version) {
|
||||
out = append(out, note)
|
||||
}
|
||||
}
|
||||
return out
|
||||
}
|
||||
|
||||
// CanApply проверяет, что привилегированный скрипт на месте и sudo пускает к
|
||||
// нему без пароля. Проверяем вызовом: наличие файла ещё не значит, что
|
||||
// правило sudoers действует.
|
||||
|
||||
@@ -57,3 +57,33 @@ func TestAPIBase(t *testing.T) {
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
func TestNewerThan(t *testing.T) {
|
||||
notes := []ReleaseNote{
|
||||
{Version: "v0.3.0"},
|
||||
{Version: "v0.2.2"},
|
||||
{Version: "v0.2.1"},
|
||||
{Version: "v0.2.0"},
|
||||
{Version: "v0.1.3"},
|
||||
}
|
||||
|
||||
got := NewerThan(notes, "v0.2.0")
|
||||
want := []string{"v0.3.0", "v0.2.2", "v0.2.1"}
|
||||
if len(got) != len(want) {
|
||||
t.Fatalf("отобрано %d версий, ожидалось %d: %v", len(got), len(want), got)
|
||||
}
|
||||
for i, version := range want {
|
||||
if got[i].Version != version {
|
||||
t.Errorf("changelog[%d] = %s, ожидалось %s", i, got[i].Version, version)
|
||||
}
|
||||
}
|
||||
|
||||
// На последней версии показывать нечего.
|
||||
if got := NewerThan(notes, "v0.3.0"); len(got) != 0 {
|
||||
t.Errorf("на последней версии отобрано %d записей: %v", len(got), got)
|
||||
}
|
||||
// Сборка из рабочей копии не знает своей версии — показываем всё.
|
||||
if got := NewerThan(notes, "dev"); len(got) != len(notes) {
|
||||
t.Errorf("для dev отобрано %d из %d записей", len(got), len(notes))
|
||||
}
|
||||
}
|
||||
|
||||
+926
-59
File diff suppressed because it is too large
Load Diff
@@ -149,7 +149,7 @@
|
||||
</div>
|
||||
</div>
|
||||
<p class="muted" id="config-empty" hidden></p>
|
||||
<div id="config-fields" class="fields"></div>
|
||||
<div id="config-fields"></div>
|
||||
</section>
|
||||
|
||||
<!-- Песочница -->
|
||||
@@ -165,7 +165,7 @@
|
||||
</div>
|
||||
</div>
|
||||
<p class="muted" id="sandbox-empty" hidden></p>
|
||||
<div id="sandbox-fields" class="fields"></div>
|
||||
<div id="sandbox-fields"></div>
|
||||
</section>
|
||||
|
||||
<!-- Моды -->
|
||||
|
||||
+55
-2
@@ -108,7 +108,7 @@ code {
|
||||
background: var(--muted);
|
||||
}
|
||||
.dot.running { background: var(--accent); box-shadow: 0 0 8px var(--accent); }
|
||||
.dot.starting, .dot.stopping { background: var(--warn); animation: pulse 1.2s infinite; }
|
||||
.dot.starting, .dot.stopping, .dot.restarting { background: var(--warn); animation: pulse 1.2s infinite; }
|
||||
.dot.stopped { background: #5b636f; }
|
||||
|
||||
@keyframes pulse { 50% { opacity: .35; } }
|
||||
@@ -267,6 +267,40 @@ input.input-sm, .input-sm { width: auto; padding: 6px 10px; font-size: 13px; }
|
||||
gap: 12px;
|
||||
}
|
||||
|
||||
.cfg-group {
|
||||
border: 1px solid var(--border);
|
||||
border-radius: var(--radius);
|
||||
background: var(--bg-soft);
|
||||
margin-bottom: 10px;
|
||||
}
|
||||
|
||||
.cfg-group > summary {
|
||||
padding: 11px 14px;
|
||||
cursor: pointer;
|
||||
font-weight: 600;
|
||||
font-size: 14px;
|
||||
user-select: none;
|
||||
list-style: none;
|
||||
}
|
||||
.cfg-group > summary::-webkit-details-marker { display: none; }
|
||||
.cfg-group > summary::before {
|
||||
content: "▸";
|
||||
display: inline-block;
|
||||
width: 14px;
|
||||
color: var(--muted);
|
||||
}
|
||||
.cfg-group[open] > summary::before { content: "▾"; }
|
||||
.cfg-group > summary:hover { background: var(--bg-card); border-radius: var(--radius); }
|
||||
|
||||
.cfg-count {
|
||||
color: var(--muted);
|
||||
font-weight: 400;
|
||||
font-size: 12px;
|
||||
margin-left: 4px;
|
||||
}
|
||||
|
||||
.cfg-group > .fields { padding: 0 14px 14px; }
|
||||
|
||||
.cfg-field {
|
||||
background: var(--bg-card);
|
||||
border: 1px solid var(--border);
|
||||
@@ -275,7 +309,17 @@ input.input-sm, .input-sm { width: auto; padding: 6px 10px; font-size: 13px; }
|
||||
}
|
||||
.cfg-field.changed { border-color: var(--accent-dark); }
|
||||
.cfg-field label { display: block; font-size: 13px; margin-bottom: 6px; }
|
||||
.cfg-field .hint { color: var(--muted); font-size: 12px; margin-top: 5px; }
|
||||
.cfg-field .hint {
|
||||
color: var(--muted);
|
||||
font-size: 12px;
|
||||
margin-top: 5px;
|
||||
/* Описания из конфига бывают в абзац: показываем начало, остальное — в
|
||||
подсказке при наведении. */
|
||||
display: -webkit-box;
|
||||
-webkit-line-clamp: 3;
|
||||
-webkit-box-orient: vertical;
|
||||
overflow: hidden;
|
||||
}
|
||||
.cfg-field .key { color: var(--muted); font-family: var(--mono); font-size: 11px; }
|
||||
|
||||
/* ---------- Моды ---------- */
|
||||
@@ -477,6 +521,15 @@ input.input-sm, .input-sm { width: auto; padding: 6px 10px; font-size: 13px; }
|
||||
line-height: 1.5;
|
||||
}
|
||||
|
||||
.release-version {
|
||||
margin: 14px 0 6px;
|
||||
font-size: 13px;
|
||||
color: var(--accent);
|
||||
text-transform: none;
|
||||
letter-spacing: 0;
|
||||
}
|
||||
.release-version:first-child { margin-top: 0; }
|
||||
|
||||
.release-notes ul { margin: 0; padding-left: 20px; }
|
||||
.release-notes li { margin-bottom: 5px; }
|
||||
.release-notes li:last-child { margin-bottom: 0; }
|
||||
|
||||
Reference in New Issue
Block a user