9 Commits
Author SHA1 Message Date
mrleo1nidandClaude Opus 5 d5a308ac8d Описания параметров песочницы на русском
CI / test (push) Successful in 23s
Release / release (push) Successful in 28s
Подписи были переведены, а пояснения по-прежнему приходили из файла — то
есть на языке сервера, обычно английском. Теперь у всех 270 параметров
песочницы есть своё русское описание: что параметр делает и на что влияет.

Текст из конфига не выбрасывается, а дополняет своё: игра расписывает там,
что означает каждое значение («1 = Бегают, 2 = Ходят…»), и это видно во
всплывающей подсказке. Под полем остаётся короткое объяснение смысла.

Вместе с прошлым заходом по servertest.ini панель теперь описывает все 414
параметров обоих конфигов независимо от локали сервера.

Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
2026-09-05 19:28:20 +03:00
mrleo1nidandClaude Opus 5 bb2facd4d1 Русские подписи для всех параметров песочницы
CI / test (push) Successful in 21s
Release / release (push) Successful in 28s
Прошлый заход покрыл ходовые настройки, а вложенные таблицы остались с
английскими именами ключей вместо подписей — «MultiplierConfig.Lightfoot»
мало кому что говорит.

Теперь подписаны все 270 параметров: характеристики и повадки зомби,
популяция и респавн, множители опыта каждого навыка, карта, подвалы и
новая система лута Build 42. Названия самих таблиц тоже переведены —
раздел называется «Множители опыта навыков», а не «MultiplierConfig».

Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
2026-09-05 16:58:49 +03:00
mrleo1nidandClaude Opus 5 c706665196 Описания параметров на русском независимо от локали сервера
CI / test (push) Failing after 7s
Release / release (push) Successful in 29s
Панель показывала комментарии из самого конфига, а игра пишет их на языке
сервера: на Windows-клиенте они русские, на Linux-сервере почти всегда
английские — и вся вкладка оказывалась на английском.

Теперь у панели свой словарь: подпись и описание для всех 153 параметров
servertest.ini, встречающихся в Build 41 и 42, плюс подписи для 182
параметров песочницы. Комментарий из файла остаётся запасным вариантом для
ключей, которых словарь не знает, — в новых версиях игры их добавляют.

Песочница заодно научилась отдавать свои комментарии: игра расписывает там
смысл каждого значения, и даже английский текст лучше пустоты.

Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
2026-09-05 16:03:09 +03:00
mrleo1nidandClaude Opus 5 5d50b609f6 Настройки сервера и песочницы разложены по разделам
CI / test (push) Successful in 21s
Release / release (push) Successful in 26s
Полторы сотни параметров сплошным списком читать невозможно. Теперь они
разбиты на разделы — «Основное», «PVP и урон», «Убежища», «Античит» и так
далее, — свёрнутые по умолчанию, кроме первого. Поиск раскрывает разделы с
совпадениями и прячет остальные, а раскрытые разделы не схлопываются при
возврате на вкладку.

Категории составлены по настоящим конфигам Build 41 и 42: все 144 ключа
.ini и 270 параметров песочницы раскладываются без остатка. Нумерованные
и однотипные ключи (AntiCheatProtectionType1..24, *Loot, Animal*, Firearm*)
подхватываются по префиксу, а незнакомые попадают в «Прочее» — в новых
версиях игры ключи добавляют, и терять их со страницы нельзя.

Описания параметров панель больше не выдумывает, а берёт из самого
конфига: игра пишет их комментариями на языке сервера. Полный текст — во
всплывающей подсказке, начало — под полем; поиск ищет и по описанию, так
что параметр можно найти по-русски.

Заодно исправлено сохранение файлов с виндовыми переводами строк: панель
переписывала их в LF, и правка одного параметра меняла каждую строку
файла. Проверено на реальном SandboxVars.lua: правка одного значения
меняет ровно одну строку, размер файла не меняется.

Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
2026-09-05 03:07:59 +03:00
mrleo1nidandClaude Opus 5 4a346c4ed9 В обновлении видно изменения всех пропущенных версий
CI / test (push) Successful in 21s
Release / release (push) Successful in 29s
Панель показывала описание только последнего релиза. Пропустив пару
версий, человек не узнал бы, что менялось в промежутке, — теперь
запрашивается список релизов и показываются все, что новее установленной,
каждая со своим заголовком и датой. Черновики и предрелизы отбрасываются,
порядок восстанавливается по номерам версий, а не по тому, как их отдал
Gitea.

Заодно в карточке профиля появились подсказки: сколько на машине ОЗУ (не
выбирать же лимит JVM вслепую) и что означает пустое поле начальной
памяти.

Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
2026-09-05 02:25:16 +03:00
mrleo1nidandClaude Opus 5 e78a72d516 Память JVM задаётся раздельно, автоперезапуск можно отменить
Панель принудительно ставила -Xms равным -Xmx: куча не растёт на ходу, но
JVM обязана занять весь объём при старте. На машине с 5 ГБ ОЗУ сервер с
4g так вообще не поднимался — «Failed to allocate initial Java heap».

Теперь -Xmx задаётся как раньше, а -Xms стал отдельным полем профиля и по
умолчанию пуст: JVM берёт память по мере надобности. Пара значений
проверяется при сохранении профиля, а не при запуске сервера, — про
опечатку лучше узнать из формы, чем из лога упавшего сервера.

Там же в супервизоре: ожидание автоподъёма стало отдельным состоянием.
Раньше упавший сервер уходил в цикл «падение — пауза 10 секунд — падение»,
причём во время паузы он считался остановленным, и прервать это было
нечем. Теперь паузу видно в статусе с обратным отсчётом и её можно
отменить, а после трёх падений сразу после запуска подряд панель
перестаёт поднимать сервер сама: так проявляется нехватка памяти или
битый конфиг, и перезапуск тут не помогает.

Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
2026-09-05 02:25:16 +03:00
mrleo1nidandClaude Opus 5 f6eba8c75c Кнопка SteamCMD называет то, что произойдёт
Release / release (push) Successful in 26s
CI / test (push) Successful in 20s
«Установить / обновить через SteamCMD» одинаково выглядела и на чистой
машине, и на готовой. Теперь пока серверных файлов нет — это «Установить
сервер через SteamCMD», после установки — «Обновить сервер через
SteamCMD»; подсказка и вопрос перед запуском меняются вместе с ней.

На чистой машине подсказка вместо требования остановить сервер (его ещё
нет) говорит то, что важно знать заранее: сколько это займёт времени и
места на диске.

Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
2026-09-05 02:02:08 +03:00
mrleo1nidandClaude Opus 5 27a2fd6386 Консоль не принимает команды у остановленного сервера
CI / test (push) Successful in 20s
Release / release (push) Successful in 25s
Поле ввода и кнопка «Отправить» были активны всегда, хотя команда уходит
в stdin процесса: у остановленного сервера его просто нет, и панель
отвечала ошибкой уже после отправки. Теперь консоль блокируется, а
подсказка объясняет, почему.

Заодно из вывода убираются управляющие последовательности терминала.
SteamCMD раскрашивает свои сообщения, и в браузере это выглядело как
«[0mWaiting for user info...[0mOK». Чистка стоит на общем пути записи в
буфер: через него идёт и вывод сервера, и SteamCMD, и сообщения панели.

Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
2026-09-05 01:56:55 +03:00
mrleo1nidandClaude Opus 5 08908bede8 Кнопка обновления не работала из-за NoNewPrivileges в юните
CI / test (push) Successful in 20s
Release / release (push) Successful in 26s
Панель показывала команду для терминала вместо кнопок обновления и
перезапуска, потому что sudo из неё не запускался вовсе: NoNewPrivileges
запрещает процессу и его потомкам повышать привилегии. Механизм с
sudoers, ради которого всё и делалось, был при этом мёртв.

Убрал эту опцию из юнита, оставив комментарий, почему её здесь быть не
должно. Ограничение прав никуда не делось: в sudoers сервисному
пользователю разрешена ровно одна команда, pzmanager-admin.

Заодно описание релиза перестало показываться сырой разметкой. Раздел
про установку в работающей панели ни к чему, поэтому берётся только
список изменений; блок прокручивается сам, не утягивая страницу, а рядом
появилась ссылка на полное описание.

Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
2026-09-05 01:49:02 +03:00
19 changed files with 1754 additions and 123 deletions
+34 -2
View File
@@ -22,7 +22,8 @@
- **Мониторинг** — состояние, аптайм, CPU и память процесса сервера, свободные - **Мониторинг** — состояние, аптайм, CPU и память процесса сервера, свободные
ОЗУ и диск на хосте, список игроков онлайн. ОЗУ и диск на хосте, список игроков онлайн.
- **Редактор конфигов** — `servertest.ini` и `SandboxVars.lua` прямо в - **Редактор конфигов** — `servertest.ini` и `SandboxVars.lua` прямо в
браузере, с поиском по параметрам и сохранением комментариев в файле. браузере: параметры разложены по разделам, у каждого видно описание из
самого конфига, поиск идёт и по названию, и по описанию.
- **Мод-менеджер** — моды списком с галочками и перетаскиванием порядка - **Мод-менеджер** — моды списком с галочками и перетаскиванием порядка
загрузки, добавление по ссылке и разворачивание коллекций Steam целиком. загрузки, добавление по ссылке и разворачивание коллекций Steam целиком.
- **Бэкапы** — ручные и по расписанию, отдельно по каждому профилю, с - **Бэкапы** — ручные и по расписанию, отдельно по каждому профилю, с
@@ -192,6 +193,22 @@ Mod ID, который нужен серверу, лежит внутри сам
Один пакет мастерской может содержать несколько модов — в списке они идут Один пакет мастерской может содержать несколько модов — в списке они идут
отдельными строками, и включать их можно по отдельности. отдельными строками, и включать их можно по отдельности.
## Редактор конфигов
Вкладки «Конфиг сервера» и «Песочница» показывают параметры не сплошным
списком, а разделами: «Основное», «PVP и урон», «Убежища», «Античит» и так
далее. Разделы сворачиваются, а поиск сверху раскрывает те, где нашлось
совпадение. Ключи, которых панель не знает (в новой версии игры их всегда
добавляют), не теряются — они собираются в раздел «Прочее».
Описания параметров панель берёт из самого конфига: игра пишет их
комментариями на языке сервера. Полный текст виден при наведении, начало —
прямо под полем.
Правка меняет ровно ту строку, которую поправили: комментарии, порядок и
переводы строк файла сохраняются, а рядом остаётся копия прежней версии с
расширением `.bak`.
## Профили серверов ## Профили серверов
Профиль — это отдельный сервер: свой мир, свой `*.ini`, свои настройки Профиль — это отдельный сервер: свой мир, свой `*.ini`, свои настройки
@@ -213,6 +230,20 @@ Mod ID, который нужен серверу, лежит внутри сам
При создании профиля можно скопировать `.ini` и настройки песочницы из При создании профиля можно скопировать `.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 - id: vanilla # vanilla -> vanilla.ini, Saves/Multiplayer/vanilla
title: Ванильный мир # как профиль подписан в панели title: Ванильный мир # как профиль подписан в панели
admin_password: "" # пароль админа игрового сервера admin_password: "" # пароль админа игрового сервера
java_memory: 4g # -Xmx для JVM этого профиля java_memory: 4g # -Xmx: верхняя граница кучи JVM
java_memory_min: "" # -Xms: пусто — JVM берёт память по мере надобности
extra_args: [] # доп. аргументы start-server.sh extra_args: [] # доп. аргументы start-server.sh
- id: modded - id: modded
title: Сборка с модами title: Сборка с модами
+5 -1
View File
@@ -19,7 +19,11 @@ KillMode=mixed
TimeoutStopSec=300 TimeoutStopSec=300
# Всё своё панель держит в /opt/pzmanager, домашние каталоги ей не нужны. # Всё своё панель держит в /opt/pzmanager, домашние каталоги ей не нужны.
NoNewPrivileges=true #
# NoNewPrivileges здесь намеренно не выставлен: он запрещает процессу и его
# потомкам повышать привилегии, а значит ломает sudo — и вместе с ним кнопки
# обновления и перезапуска панели. Прикрытием служит sudoers: сервисному
# пользователю разрешена ровно одна команда, pzmanager-admin.
PrivateTmp=true PrivateTmp=true
ProtectSystem=full ProtectSystem=full
ProtectHome=true ProtectHome=true
+3
View File
@@ -32,6 +32,9 @@ func (s *Server) handleGetServerConfig(w http.ResponseWriter, r *http.Request) {
"path": path, "path": path,
"keys": ini.Keys(), "keys": ini.Keys(),
"values": ini.Map(), "values": ini.Map(),
// Игра сама пишет в конфиг описания параметров на языке сервера —
// показываем их, вместо того чтобы придумывать свои.
"descriptions": ini.Comments(),
}) })
} }
+36 -4
View File
@@ -7,15 +7,36 @@ import (
"os" "os"
"github.com/mrleo1nid/pzmanager/internal/config" "github.com/mrleo1nid/pzmanager/internal/config"
"github.com/mrleo1nid/pzmanager/internal/pzconfig"
"github.com/mrleo1nid/pzmanager/internal/pzserver" "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 — профиль в том виде, в каком его показывает панель. Пароль // profileDTO — профиль в том виде, в каком его показывает панель. Пароль
// наружу не отдаётся, только признак того, что он задан. // наружу не отдаётся, только признак того, что он задан.
type profileDTO struct { type profileDTO struct {
ID string `json:"id"` ID string `json:"id"`
Title string `json:"title"` Title string `json:"title"`
JavaMemory string `json:"java_memory"` JavaMemory string `json:"java_memory"`
JavaMemoryMin string `json:"java_memory_min"`
ExtraArgs []string `json:"extra_args"` ExtraArgs []string `json:"extra_args"`
HasAdminPassword bool `json:"has_admin_password"` HasAdminPassword bool `json:"has_admin_password"`
AdminPassword string `json:"admin_password,omitempty"` AdminPassword string `json:"admin_password,omitempty"`
@@ -33,6 +54,7 @@ func (s *Server) profileToDTO(p config.Profile) profileDTO {
ID: p.ID, ID: p.ID,
Title: p.Title, Title: p.Title,
JavaMemory: p.JavaMemory, JavaMemory: p.JavaMemory,
JavaMemoryMin: p.JavaMemoryMin,
ExtraArgs: p.ExtraArgs, ExtraArgs: p.ExtraArgs,
HasAdminPassword: p.AdminPassword != "", HasAdminPassword: p.AdminPassword != "",
HasConfig: fileExists(s.cfg.ServerConfigPathFor(p.ID)), 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) { if !decodeJSON(w, r, &dto) {
return return
} }
if err := validateProfileMemory(dto); err != nil {
writeError(w, http.StatusBadRequest, err.Error())
return
}
profile := config.Profile{ profile := config.Profile{
ID: dto.ID, ID: dto.ID,
Title: dto.Title, Title: dto.Title,
JavaMemory: dto.JavaMemory, JavaMemory: dto.JavaMemory,
JavaMemoryMin: dto.JavaMemoryMin,
ExtraArgs: dto.ExtraArgs, ExtraArgs: dto.ExtraArgs,
AdminPassword: dto.AdminPassword, AdminPassword: dto.AdminPassword,
} }
@@ -133,12 +160,17 @@ func (s *Server) handleUpdateProfile(w http.ResponseWriter, r *http.Request) {
if !decodeJSON(w, r, &dto) { if !decodeJSON(w, r, &dto) {
return return
} }
if err := validateProfileMemory(dto); err != nil {
writeError(w, http.StatusBadRequest, err.Error())
return
}
updated := config.Profile{ updated := config.Profile{
ID: id, ID: id,
Title: dto.Title, Title: dto.Title,
JavaMemory: dto.JavaMemory, JavaMemory: dto.JavaMemory,
ExtraArgs: dto.ExtraArgs, JavaMemoryMin: dto.JavaMemoryMin,
ExtraArgs: dto.ExtraArgs,
// Пустой пароль означает "оставить прежний": наружу мы его не отдаём, // Пустой пароль означает "оставить прежний": наружу мы его не отдаём,
// и форма присылает пустую строку, пока его не меняли. // и форма присылает пустую строку, пока его не меняли.
AdminPassword: current.AdminPassword, AdminPassword: current.AdminPassword,
+7 -3
View File
@@ -236,12 +236,16 @@ func StartBackupScheduler(ctx context.Context, s *Server) {
// При обычном старте то же самое делает супервизор. // При обычном старте то же самое делает супервизор.
func (s *Server) applyJavaMemory(log func(string)) error { func (s *Server) applyJavaMemory(log func(string)) error {
profile := s.cfg.ActiveProfile() profile := s.cfg.ActiveProfile()
if profile.JavaMemory == "" { if profile.JavaMemory == "" && profile.JavaMemoryMin == "" {
return nil 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 return err
} }
log("Лимит памяти JVM выставлен: " + profile.JavaMemory) if profile.JavaMemoryMin != "" {
log(fmt.Sprintf("Память JVM: от %s до %s", profile.JavaMemoryMin, profile.JavaMemory))
} else {
log("Лимит памяти JVM выставлен: " + profile.JavaMemory)
}
return nil return nil
} }
+5
View File
@@ -34,6 +34,11 @@ type Profile struct {
// запуске: файл запуска сервера общий для всех профилей. // запуске: файл запуска сервера общий для всех профилей.
JavaMemory string `yaml:"java_memory"` JavaMemory string `yaml:"java_memory"`
// JavaMemoryMin — -Xms. Пусто (по умолчанию) означает, что JVM занимает
// память по мере надобности: равные -Xms и -Xmx заставляют её забрать всё
// сразу, и на машине с небольшой ОЗУ сервер не поднимется.
JavaMemoryMin string `yaml:"java_memory_min"`
// ExtraArgs — дополнительные аргументы start-server.sh. // ExtraArgs — дополнительные аргументы start-server.sh.
ExtraArgs []string `yaml:"extra_args"` ExtraArgs []string `yaml:"extra_args"`
} }
+48 -4
View File
@@ -16,6 +16,10 @@ type iniLine struct {
Key string Key string
Value string Value string
Raw string Raw string
// Comment — описание параметра: строки комментария прямо перед ним.
// Project Zomboid пишет их на языке сервера, так что панели есть что
// показать человеку, не выдумывая своих формулировок.
Comment string
} }
// INI — конфиг PZ в виде плоских key=value. Разбор сохраняет исходный порядок // INI — конфиг PZ в виде плоских key=value. Разбор сохраняет исходный порядок
@@ -23,22 +27,46 @@ type iniLine struct {
type INI struct { type INI struct {
lines []iniLine lines []iniLine
index map[string]int index map[string]int
// crlf — файл был с виндовыми переводами строк. Сохраняем как было: иначе
// правка одного параметра переписывает весь файл целиком.
crlf bool
} }
// ParseINI разбирает содержимое конфига. // ParseINI разбирает содержимое конфига.
func ParseINI(data []byte) *INI { func ParseINI(data []byte) *INI {
ini := &INI{index: make(map[string]int)} 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") { for _, raw := range strings.Split(text, "\n") {
trimmed := strings.TrimSpace(raw) trimmed := strings.TrimSpace(raw)
key, value, found := strings.Cut(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}) ini.lines = append(ini.lines, iniLine{Raw: raw})
continue continue
} }
if !found || trimmed == "" {
comment = nil
ini.lines = append(ini.lines, iniLine{Raw: raw})
continue
}
key = strings.TrimSpace(key) key = strings.TrimSpace(key)
ini.index[key] = len(ini.lines) 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 return ini
} }
@@ -90,6 +118,17 @@ func (i *INI) Keys() []string {
return out 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 отдаёт все параметры в виде словаря. // Map отдаёт все параметры в виде словаря.
func (i *INI) Map() map[string]string { func (i *INI) Map() map[string]string {
out := make(map[string]string, len(i.index)) out := make(map[string]string, len(i.index))
@@ -103,6 +142,11 @@ func (i *INI) Map() map[string]string {
// Render собирает файл обратно в текст. // Render собирает файл обратно в текст.
func (i *INI) Render() []byte { func (i *INI) Render() []byte {
newline := "\n"
if i.crlf {
newline = "\r\n"
}
var buf bytes.Buffer var buf bytes.Buffer
for n, l := range i.lines { for n, l := range i.lines {
if l.Key == "" { if l.Key == "" {
@@ -113,7 +157,7 @@ func (i *INI) Render() []byte {
buf.WriteString(l.Value) buf.WriteString(l.Value)
} }
if n < len(i.lines)-1 { if n < len(i.lines)-1 {
buf.WriteByte('\n') buf.WriteString(newline)
} }
} }
return buf.Bytes() return buf.Bytes()
+63 -13
View File
@@ -6,24 +6,71 @@ import (
"os" "os"
"path/filepath" "path/filepath"
"regexp" "regexp"
"strconv"
"strings" "strings"
) )
// javaLauncherFile — файл, из которого сервер берёт аргументы JVM. // javaLauncherFile — файл, из которого сервер берёт аргументы JVM.
const javaLauncherFile = "ProjectZomboid64.json" 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. Именно // ParseMemory переводит запись вида "4g" в байты. Возвращает 0, если строка
// оттуда start-server.sh берёт -Xmx, поэтому менять размер памяти в аргументах // пустая, и ошибку, если формат непонятен.
// запуска бесполезно. func ParseMemory(value string) (int64, error) {
func SetJavaMemory(serverDir, memory string) error { value = strings.TrimSpace(value)
memory = strings.TrimSpace(memory) if value == "" {
if memory == "" { 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 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) path := filepath.Join(serverDir, javaLauncherFile)
@@ -41,14 +88,17 @@ func SetJavaMemory(serverDir, memory string) error {
args, _ := doc["vmArgs"].([]any) args, _ := doc["vmArgs"].([]any)
updated := make([]any, 0, len(args)+2) updated := make([]any, 0, len(args)+2)
for _, a := range args { for _, a := range args {
if str, ok := a.(string); ok && xmxRe.MatchString(str) { if str, ok := a.(string); ok && heapArgRe.MatchString(str) {
continue continue
} }
updated = append(updated, a) updated = append(updated, a)
} }
// -Xms равным -Xmx: JVM сразу забирает память и не тратит время на рост if minMemory != "" {
// кучи в момент, когда на сервере много игроков. updated = append(updated, "-Xms"+minMemory)
updated = append(updated, "-Xms"+memory, "-Xmx"+memory) }
if maxMemory != "" {
updated = append(updated, "-Xmx"+maxMemory)
}
doc["vmArgs"] = updated doc["vmArgs"] = updated
out, err := json.MarshalIndent(doc, "", " ") out, err := json.MarshalIndent(doc, "", " ")
+167
View File
@@ -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("значение с кириллицей принято")
}
}
+31
View File
@@ -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()))
}
}
+36 -5
View File
@@ -13,6 +13,9 @@ import (
type SandboxEntry struct { type SandboxEntry struct {
Path string `json:"path"` Path string `json:"path"`
Value string `json:"value"` Value string `json:"value"`
// Comment — строки "--" перед параметром: игра расписывает там смысл
// значения и расшифровку вариантов.
Comment string `json:"comment,omitempty"`
} }
// Sandbox — разбор <server>_SandboxVars.lua. Файл генерируется игрой и имеет // Sandbox — разбор <server>_SandboxVars.lua. Файл генерируется игрой и имеет
@@ -24,6 +27,10 @@ type Sandbox struct {
lines []string lines []string
// index сопоставляет путь параметра с номером строки. // index сопоставляет путь параметра с номером строки.
index map[string]int index map[string]int
// comments хранит описание параметра по его пути.
comments map[string]string
// crlf — файл был с виндовыми переводами строк; сохраняем как было.
crlf bool
} }
var ( var (
@@ -33,14 +40,24 @@ var (
// ParseSandbox разбирает содержимое SandboxVars.lua. // ParseSandbox разбирает содержимое SandboxVars.lua.
func ParseSandbox(data []byte) *Sandbox { func ParseSandbox(data []byte) *Sandbox {
s := &Sandbox{index: make(map[string]int)} s := &Sandbox{index: make(map[string]int), comments: make(map[string]string)}
text := strings.ReplaceAll(string(data), "\r\n", "\n") raw := string(data)
s.crlf = strings.Contains(raw, "\r\n")
text := strings.ReplaceAll(raw, "\r\n", "\n")
s.lines = strings.Split(text, "\n") s.lines = strings.Split(text, "\n")
var stack []string var stack []string
// Комментарии копим до ближайшего параметра, как и в .ini.
var comment []string
for n, line := range s.lines { for n, line := range s.lines {
trimmed := strings.TrimSpace(line) 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 continue
} }
if sandboxCloseRe.MatchString(line) { if sandboxCloseRe.MatchString(line) {
@@ -62,6 +79,7 @@ func ParseSandbox(data []byte) *Sandbox {
} else { } else {
stack = stack[:0] stack = stack[:0]
} }
comment = nil
continue continue
} }
path := name path := name
@@ -69,6 +87,10 @@ func ParseSandbox(data []byte) *Sandbox {
path = strings.Join(stack, ".") + "." + name path = strings.Join(stack, ".") + "." + name
} }
s.index[path] = n s.index[path] = n
if len(comment) > 0 {
s.comments[path] = strings.Join(comment, " ")
}
comment = nil
} }
return s return s
} }
@@ -95,7 +117,11 @@ func (s *Sandbox) Entries() []SandboxEntry {
if !ok { if !ok {
continue 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 return out
} }
@@ -139,11 +165,16 @@ func (s *Sandbox) Set(path, value string) error {
// Render собирает файл обратно. // Render собирает файл обратно.
func (s *Sandbox) Render() []byte { func (s *Sandbox) Render() []byte {
newline := "\n"
if s.crlf {
newline = "\r\n"
}
var buf bytes.Buffer var buf bytes.Buffer
for n, line := range s.lines { for n, line := range s.lines {
buf.WriteString(line) buf.WriteString(line)
if n < len(s.lines)-1 { if n < len(s.lines)-1 {
buf.WriteByte('\n') buf.WriteString(newline)
} }
} }
return buf.Bytes() return buf.Bytes()
+19 -1
View File
@@ -1,6 +1,20 @@
package pzserver package pzserver
import "sync" import (
"regexp"
"sync"
)
// ansiRe ловит управляющие последовательности терминала: SteamCMD и сам
// сервер раскрашивают вывод, а в браузере эти коды превращаются в мусор
// вида "[0mOK". Первый вариант — CSI (цвета, перемещение курсора), второй —
// всё остальное, что начинается с ESC.
var ansiRe = regexp.MustCompile("\x1b\\[[0-9;?]*[ -/]*[@-~]|\x1b.")
// stripANSI убирает управляющие последовательности из строки вывода.
func stripANSI(text string) string {
return ansiRe.ReplaceAllString(text, "")
}
// LogLine — одна строка консоли сервера с монотонным номером, по которому // LogLine — одна строка консоли сервера с монотонным номером, по которому
// веб-клиент понимает, что он пропустил, и откуда догружать. // веб-клиент понимает, что он пропустил, и откуда догружать.
@@ -33,6 +47,10 @@ func newLogBuffer(capacity int) *logBuffer {
// append кладёт строку в буфер и рассылает подписчикам. // append кладёт строку в буфер и рассылает подписчикам.
func (b *logBuffer) append(line LogLine) { func (b *logBuffer) append(line LogLine) {
// Чистим здесь, а не у каждого источника: через буфер проходят и вывод
// сервера, и SteamCMD, и сообщения самой панели.
line.Text = stripANSI(line.Text)
b.mu.Lock() b.mu.Lock()
line.Seq = b.nextSeq line.Seq = b.nextSeq
b.nextSeq++ b.nextSeq++
+41
View File
@@ -0,0 +1,41 @@
package pzserver
import "testing"
// TestStripANSI берёт строки ровно в том виде, в каком их печатает SteamCMD:
// в браузере коды раскраски превращались в мусор вроде "[0mOK".
func TestStripANSI(t *testing.T) {
cases := map[string]string{
"\x1b[0mConnecting anonymously to Steam Public...\x1b[0mOK": "Connecting anonymously to Steam Public...OK",
"\x1b[0m Update state (0x3) reconfiguring, progress: 0.00": " Update state (0x3) reconfiguring, progress: 0.00",
"\x1b[1;32mSuccess!\x1b[0m": "Success!",
// Перемещение курсора и очистка строки — тоже CSI.
"\x1b[2K\x1b[1GЗагрузка": "Загрузка",
// Обычные строки не должны меняться.
"[----] Installing update...": "[----] Installing update...",
"Steam Console Client (c) Valve": "Steam Console Client (c) Valve",
"Мир сохранён, игроков онлайн: 3": "Мир сохранён, игроков онлайн: 3",
"": "",
}
for input, want := range cases {
if got := stripANSI(input); got != want {
t.Errorf("stripANSI(%q) = %q, ожидалось %q", input, got, want)
}
}
}
// TestAppendStripsANSI проверяет, что чистка стоит на общем пути: через буфер
// идёт и вывод сервера, и SteamCMD, и сообщения самой панели.
func TestAppendStripsANSI(t *testing.T) {
buf := newLogBuffer(10)
buf.append(LogLine{Stream: "task", Text: "\x1b[0mWaiting for user info...\x1b[0mOK"})
lines := buf.since(0)
if len(lines) != 1 {
t.Fatalf("строк в буфере: %d", len(lines))
}
if lines[0].Text != "Waiting for user info...OK" {
t.Errorf("в буфер попала строка с кодами: %q", lines[0].Text)
}
}
+102 -17
View File
@@ -23,10 +23,13 @@ import (
type State string type State string
const ( const (
StateStopped State = "stopped" StateStopped State = "stopped"
StateStarting State = "starting" // StateRestarting — сервер упал и ждёт автоподъёма. Отдельное состояние
StateRunning State = "running" // нужно, чтобы это ожидание можно было отменить кнопкой.
StateStopping State = "stopping" StateRestarting State = "restarting"
StateStarting State = "starting"
StateRunning State = "running"
StateStopping State = "stopping"
) )
// Ошибки, на которые HTTP-слой отвечает осмысленным кодом. // Ошибки, на которые HTTP-слой отвечает осмысленным кодом.
@@ -42,20 +45,30 @@ const playersPollInterval = 30 * time.Second
// restartDelay — пауза перед автоподъёмом упавшего сервера. // restartDelay — пауза перед автоподъёмом упавшего сервера.
const restartDelay = 10 * time.Second const restartDelay = 10 * time.Second
// Сервер, падающий сразу после старта, автоперезапуском не лечится: обычно
// это нехватка памяти или испорченный конфиг. После нескольких таких падений
// подряд перестаём поднимать его сам, чтобы не крутить бесконечный цикл.
const (
quickCrashWindow = time.Minute
maxQuickCrashes = 3
)
// Status — снимок состояния для веб-панели. // Status — снимок состояния для веб-панели.
type Status struct { type Status struct {
State State `json:"state"` State State `json:"state"`
// Profile и ProfileTitle описывают профиль, который сейчас работает // Profile и ProfileTitle описывают профиль, который сейчас работает
// (а если сервер остановлен — который будет запущен). // (а если сервер остановлен — который будет запущен).
Profile string `json:"profile"` Profile string `json:"profile"`
ProfileTitle string `json:"profile_title"` ProfileTitle string `json:"profile_title"`
Installed bool `json:"installed"` Installed bool `json:"installed"`
PID int `json:"pid"` PID int `json:"pid"`
UptimeSec int64 `json:"uptime_sec"` UptimeSec int64 `json:"uptime_sec"`
Players []string `json:"players"` Players []string `json:"players"`
PlayersAt int64 `json:"players_at"` PlayersAt int64 `json:"players_at"`
LastExit string `json:"last_exit"` LastExit string `json:"last_exit"`
AutoRestart bool `json:"auto_restart"` AutoRestart bool `json:"auto_restart"`
// RestartInSec — сколько секунд осталось до автоподъёма (0, если не ждём).
RestartInSec int64 `json:"restart_in_sec"`
Proc sysinfo.ProcStats `json:"proc"` Proc sysinfo.ProcStats `json:"proc"`
Host sysinfo.HostStats `json:"host"` Host sysinfo.HostStats `json:"host"`
} }
@@ -89,6 +102,13 @@ type Supervisor struct {
captured []string captured []string
autoQuery bool autoQuery bool
// restartCancel закрывается, чтобы отменить ожидание автоперезапуска;
// restartAt — когда оно закончится.
restartCancel chan struct{}
restartAt time.Time
// crashStreak — сколько раз подряд сервер упал сразу после запуска.
crashStreak int
sampler *sysinfo.Sampler sampler *sysinfo.Sampler
stopOnce sync.Once stopOnce sync.Once
quit chan struct{} quit chan struct{}
@@ -165,9 +185,14 @@ func (s *Supervisor) Status() Status {
if s.cmd != nil && s.cmd.Process != nil { if s.cmd != nil && s.cmd.Process != nil {
st.PID = s.cmd.Process.Pid 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()) 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() s.mu.Unlock()
st.Installed = s.Installed() st.Installed = s.Installed()
@@ -185,9 +210,28 @@ func (s *Supervisor) Status() Status {
func (s *Supervisor) Start() error { func (s *Supervisor) Start() error {
s.mu.Lock() s.mu.Lock()
defer s.mu.Unlock() defer s.mu.Unlock()
// Запуск руками — знак, что причину падений устранили.
s.crashStreak = 0
// Если ждали автоподъёма, поднимаем немедленно.
s.cancelRestartLocked()
return s.startLocked() 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 { func (s *Supervisor) startLocked() error {
if s.state != StateStopped { if s.state != StateStopped {
return ErrAlreadyRunning return ErrAlreadyRunning
@@ -204,8 +248,8 @@ func (s *Supervisor) startLocked() error {
profile := s.cfg.ActiveProfile() profile := s.cfg.ActiveProfile()
// Лимит памяти живёт в файле запуска, общем для всех профилей, поэтому // Лимит памяти живёт в файле запуска, общем для всех профилей, поэтому
// выставляем его на каждом старте — иначе профиль унаследует чужой -Xmx. // выставляем его на каждом старте — иначе профиль унаследует чужой -Xmx.
if err := pzconfig.SetJavaMemory(s.cfg.ServerDir, profile.JavaMemory); err != nil { if err := pzconfig.SetJavaMemory(s.cfg.ServerDir, profile.JavaMemory, profile.JavaMemoryMin); err != nil {
s.AppendLog("manager", "Не удалось выставить лимит памяти JVM: "+err.Error()) s.AppendLog("manager", "Не удалось выставить границы памяти JVM: "+err.Error())
} }
args := []string{"-servername", profile.ID} args := []string{"-servername", profile.ID}
@@ -322,6 +366,8 @@ func (s *Supervisor) wait(cmd *exec.Cmd, exited chan struct{}) {
err := cmd.Wait() err := cmd.Wait()
close(exited) close(exited)
lifetime := time.Since(s.startedAt)
s.mu.Lock() s.mu.Lock()
wasIntentional := s.intentionalStop wasIntentional := s.intentionalStop
s.state = StateStopped s.state = StateStopped
@@ -336,6 +382,15 @@ func (s *Supervisor) wait(cmd *exec.Cmd, exited chan struct{}) {
s.lastExit = "штатное завершение" s.lastExit = "штатное завершение"
} }
reason := s.lastExit reason := s.lastExit
// Падение сразу после запуска — признак того, что перезапуск не поможет:
// не хватило памяти, испорчен конфиг, нет файлов сервера.
if !wasIntentional && lifetime < quickCrashWindow {
s.crashStreak++
} else {
s.crashStreak = 0
}
streak := s.crashStreak
autoRestart := s.cfg.AutoRestart && !wasIntentional autoRestart := s.cfg.AutoRestart && !wasIntentional
s.mu.Unlock() s.mu.Unlock()
@@ -343,14 +398,38 @@ func (s *Supervisor) wait(cmd *exec.Cmd, exited chan struct{}) {
if !autoRestart { if !autoRestart {
return 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 { select {
case <-time.After(restartDelay): case <-time.After(restartDelay):
case <-cancel:
// Состояние уже переставил тот, кто отменил ожидание.
s.AppendLog("manager", "Автоперезапуск отменён")
return
case <-s.quit: case <-s.quit:
return return
} }
s.mu.Lock() s.mu.Lock()
s.restartCancel = nil
s.restartAt = time.Time{}
if s.state == StateRestarting {
s.state = StateStopped
}
err = s.startLocked() err = s.startLocked()
s.mu.Unlock() s.mu.Unlock()
if err != nil && !errors.Is(err, ErrAlreadyRunning) { if err != nil && !errors.Is(err, ErrAlreadyRunning) {
@@ -394,6 +473,12 @@ func (s *Supervisor) sendQuiet(command string) error {
// мир), затем SIGTERM группе процессов и в крайнем случае SIGKILL. // мир), затем SIGTERM группе процессов и в крайнем случае SIGKILL.
func (s *Supervisor) Stop() error { func (s *Supervisor) Stop() error {
s.mu.Lock() s.mu.Lock()
// Ждём автоподъёма — «остановить» здесь значит «не поднимать».
if s.state == StateRestarting {
s.cancelRestartLocked()
s.mu.Unlock()
return nil
}
if s.state == StateStopped || s.cmd == nil { if s.state == StateStopped || s.cmd == nil {
s.mu.Unlock() s.mu.Unlock()
return ErrNotRunning return ErrNotRunning
+69 -14
View File
@@ -16,6 +16,7 @@ import (
"fmt" "fmt"
"net/http" "net/http"
"os/exec" "os/exec"
"sort"
"strconv" "strconv"
"strings" "strings"
"time" "time"
@@ -27,6 +28,14 @@ const adminCommand = "pzmanager-admin"
// ErrNoAdmin возвращается, когда обновление из панели недоступно. // ErrNoAdmin возвращается, когда обновление из панели недоступно.
var ErrNoAdmin = errors.New("обновление из панели недоступно: нет pzmanager-admin или правила sudo") 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 — то, что панель показывает в разделе обновления. // Info — то, что панель показывает в разделе обновления.
type Info struct { type Info struct {
Current string `json:"current"` Current string `json:"current"`
@@ -40,6 +49,10 @@ type Info struct {
CanApply bool `json:"can_apply"` CanApply bool `json:"can_apply"`
// ManualCommand — что выполнить в терминале, если сама не может. // ManualCommand — что выполнить в терминале, если сама не может.
ManualCommand string `json:"manual_command"` ManualCommand string `json:"manual_command"`
// Changelog — все версии между установленной и последней, свежие первыми.
// Одного описания последнего релиза мало: пропустив пару версий, человек
// не увидит, что менялось в промежутке.
Changelog []ReleaseNote `json:"changelog"`
// Error — почему не удалось узнать последнюю версию. // Error — почему не удалось узнать последнюю версию.
Error string `json:"error,omitempty"` 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 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 { func (u *Updater) Check(ctx context.Context) Info {
info := Info{ info := Info{
Current: u.Version, Current: u.Version,
CanApply: u.CanApply(ctx), CanApply: u.CanApply(ctx),
ManualCommand: u.manualCommand(), ManualCommand: u.manualCommand(),
Changelog: []ReleaseNote{},
} }
api, err := u.apiBase() api, err := u.apiBase()
@@ -89,7 +104,10 @@ func (u *Updater) Check(ctx context.Context) Info {
return 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 { if err != nil {
info.Error = err.Error() info.Error = err.Error()
return info return info
@@ -101,36 +119,73 @@ func (u *Updater) Check(ctx context.Context) Info {
} }
defer resp.Body.Close() defer resp.Body.Close()
if resp.StatusCode == http.StatusNotFound {
info.Error = "в репозитории ещё нет релизов"
return info
}
if resp.StatusCode != http.StatusOK { if resp.StatusCode != http.StatusOK {
info.Error = "репозиторий ответил " + resp.Status info.Error = "репозиторий ответил " + resp.Status
return info return info
} }
var release struct { var releases []struct {
TagName string `json:"tag_name"` TagName string `json:"tag_name"`
Body string `json:"body"` Body string `json:"body"`
HTMLURL string `json:"html_url"` HTMLURL string `json:"html_url"`
PublishedAt time.Time `json:"published_at"` 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() info.Error = "ответ репозитория не разобран: " + err.Error()
return info return info
} }
info.Latest = release.TagName notes := make([]ReleaseNote, 0, len(releases))
info.Notes = release.Body for _, r := range releases {
info.URL = release.HTMLURL if r.Draft || r.Prerelease || r.TagName == "" {
if !release.PublishedAt.IsZero() { continue
info.Published = release.PublishedAt.Unix() }
note := ReleaseNote{Version: r.TagName, Notes: r.Body, URL: r.HTMLURL}
if !r.PublishedAt.IsZero() {
note.Published = r.PublishedAt.Unix()
}
notes = append(notes, note)
} }
info.Available = IsNewer(u.Version, release.TagName) 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 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 пускает к // CanApply проверяет, что привилегированный скрипт на месте и sudo пускает к
// нему без пароля. Проверяем вызовом: наличие файла ещё не значит, что // нему без пароля. Проверяем вызовом: наличие файла ещё не значит, что
// правило sudoers действует. // правило sudoers действует.
+30
View File
@@ -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))
}
}
+974 -44
View File
File diff suppressed because it is too large Load Diff
+7 -7
View File
@@ -114,8 +114,8 @@
<div class="card" id="install-card"> <div class="card" id="install-card">
<h3>Серверные файлы</h3> <h3>Серверные файлы</h3>
<p id="install-state" class="muted"></p> <p id="install-state" class="muted"></p>
<button class="btn btn-primary" id="btn-install">Установить / обновить через SteamCMD</button> <button class="btn btn-primary" id="btn-install">Установить сервер через SteamCMD</button>
<p class="muted small">Сервер должен быть остановлен. Обновление занимает несколько минут — прогресс виден во вкладке «Консоль».</p> <p class="muted small" id="install-hint">Займёт несколько минут и около 3 ГБ на диске — прогресс виден во вкладке «Консоль».</p>
</div> </div>
</section> </section>
@@ -129,8 +129,8 @@
<pre id="console-output" class="console"></pre> <pre id="console-output" class="console"></pre>
<form class="console-input" id="console-form"> <form class="console-input" id="console-form">
<input type="text" id="console-command" placeholder="Команда сервера, например: players, save, quit" <input type="text" id="console-command" placeholder="Команда сервера, например: players, save, quit"
autocomplete="off" spellcheck="false"> autocomplete="off" spellcheck="false" disabled>
<button class="btn btn-primary" type="submit">Отправить</button> <button class="btn btn-primary" type="submit" disabled>Отправить</button>
</form> </form>
<p class="muted small">Полезные команды: <code>players</code>, <code>save</code>, <code>servermsg "текст"</code>, <p class="muted small">Полезные команды: <code>players</code>, <code>save</code>, <code>servermsg "текст"</code>,
<code>kickuser "ник"</code>, <code>banuser "ник"</code>, <code>checkModsNeedUpdate</code>.</p> <code>kickuser "ник"</code>, <code>banuser "ник"</code>, <code>checkModsNeedUpdate</code>.</p>
@@ -149,7 +149,7 @@
</div> </div>
</div> </div>
<p class="muted" id="config-empty" hidden></p> <p class="muted" id="config-empty" hidden></p>
<div id="config-fields" class="fields"></div> <div id="config-fields"></div>
</section> </section>
<!-- Песочница --> <!-- Песочница -->
@@ -165,7 +165,7 @@
</div> </div>
</div> </div>
<p class="muted" id="sandbox-empty" hidden></p> <p class="muted" id="sandbox-empty" hidden></p>
<div id="sandbox-fields" class="fields"></div> <div id="sandbox-fields"></div>
</section> </section>
<!-- Моды --> <!-- Моды -->
@@ -284,7 +284,7 @@
<p class="muted small" id="update-manual" hidden></p> <p class="muted small" id="update-manual" hidden></p>
<details id="update-notes" hidden> <details id="update-notes" hidden>
<summary>Что нового</summary> <summary>Что нового</summary>
<pre class="release-notes" id="update-notes-body"></pre> <div class="release-notes" id="update-notes-body"></div>
</details> </details>
</div> </div>
+77 -8
View File
@@ -108,7 +108,7 @@ code {
background: var(--muted); background: var(--muted);
} }
.dot.running { background: var(--accent); box-shadow: 0 0 8px var(--accent); } .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; } .dot.stopped { background: #5b636f; }
@keyframes pulse { 50% { opacity: .35; } } @keyframes pulse { 50% { opacity: .35; } }
@@ -267,6 +267,40 @@ input.input-sm, .input-sm { width: auto; padding: 6px 10px; font-size: 13px; }
gap: 12px; 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 { .cfg-field {
background: var(--bg-card); background: var(--bg-card);
border: 1px solid var(--border); 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.changed { border-color: var(--accent-dark); }
.cfg-field label { display: block; font-size: 13px; margin-bottom: 6px; } .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; } .cfg-field .key { color: var(--muted); font-family: var(--mono); font-size: 11px; }
/* ---------- Моды ---------- */ /* ---------- Моды ---------- */
@@ -465,16 +509,41 @@ input.input-sm, .input-sm { width: auto; padding: 6px 10px; font-size: 13px; }
.release-notes { .release-notes {
margin: 10px 0 0; margin: 10px 0 0;
padding: 12px; padding: 12px 14px;
background: var(--bg); background: var(--bg);
border: 1px solid var(--border); border: 1px solid var(--border);
border-radius: 8px; border-radius: 8px;
max-height: 260px; max-height: 240px;
overflow: auto; /* Прокручивается сам блок, а не страница под ним. */
white-space: pre-wrap; overflow-y: auto;
word-break: break-word; overscroll-behavior: contain;
font-size: 12.5px; font-size: 13px;
line-height: 1.5; 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; }
.release-notes pre {
margin: 0;
white-space: pre-wrap;
word-break: break-word;
font-size: 12.5px;
}
.release-link { display: inline-block; margin-top: 10px; color: var(--info); }
/* Команду для терминала удобнее читать моноширинным. */
#update-manual { font-family: var(--mono); word-break: break-all; }
.update-available { color: var(--accent); } .update-available { color: var(--accent); }