Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
d5a308ac8d | ||
|
|
bb2facd4d1 | ||
|
|
c706665196 | ||
|
|
5d50b609f6 | ||
|
|
4a346c4ed9 | ||
|
|
e78a72d516 | ||
|
|
f6eba8c75c | ||
|
|
27a2fd6386 | ||
|
|
08908bede8 | ||
|
|
3dc8fdae05 | ||
|
|
1e0b0a8d2b | ||
|
|
41c7cb9bb0 | ||
|
|
e25294db16 | ||
|
|
a8d86e0c48 |
@@ -1,5 +1,6 @@
|
|||||||
# PZ Manager
|
# PZ Manager
|
||||||
|
|
||||||
|
[](https://gitea.hsrv.site/mrleo1nid/pzmanager/releases/latest)
|
||||||
[](LICENSE)
|
[](LICENSE)
|
||||||
[](https://go.dev/)
|
[](https://go.dev/)
|
||||||
[](https://ubuntu.com/)
|
[](https://ubuntu.com/)
|
||||||
@@ -21,7 +22,8 @@
|
|||||||
- **Мониторинг** — состояние, аптайм, CPU и память процесса сервера, свободные
|
- **Мониторинг** — состояние, аптайм, CPU и память процесса сервера, свободные
|
||||||
ОЗУ и диск на хосте, список игроков онлайн.
|
ОЗУ и диск на хосте, список игроков онлайн.
|
||||||
- **Редактор конфигов** — `servertest.ini` и `SandboxVars.lua` прямо в
|
- **Редактор конфигов** — `servertest.ini` и `SandboxVars.lua` прямо в
|
||||||
браузере, с поиском по параметрам и сохранением комментариев в файле.
|
браузере: параметры разложены по разделам, у каждого видно описание из
|
||||||
|
самого конфига, поиск идёт и по названию, и по описанию.
|
||||||
- **Мод-менеджер** — моды списком с галочками и перетаскиванием порядка
|
- **Мод-менеджер** — моды списком с галочками и перетаскиванием порядка
|
||||||
загрузки, добавление по ссылке и разворачивание коллекций Steam целиком.
|
загрузки, добавление по ссылке и разворачивание коллекций Steam целиком.
|
||||||
- **Бэкапы** — ручные и по расписанию, отдельно по каждому профилю, с
|
- **Бэкапы** — ручные и по расписанию, отдельно по каждому профилю, с
|
||||||
@@ -84,28 +86,31 @@ curl -fsSL https://gitea.hsrv.site/mrleo1nid/pzmanager/raw/branch/main/deploy/ge
|
|||||||
```
|
```
|
||||||
|
|
||||||
**Обновление** — та же команда или кнопка в панели (вкладка «Настройки» →
|
**Обновление** — та же команда или кнопка в панели (вкладка «Настройки» →
|
||||||
«Версия панели»). Конфиг, миры и учётные записи не трогаются, меняется только
|
«Версия панели»). Конфиг, миры и учётные записи не трогаются. Повторный запуск
|
||||||
бинарник.
|
с той же версией службу не трогает вовсе: если бинарник не изменился,
|
||||||
|
установщик не станет ради него ронять игровой сервер.
|
||||||
|
|
||||||
Дальше:
|
Дальше:
|
||||||
|
|
||||||
1. Посмотрите код первичной настройки:
|
1. Откройте панель в браузере и создайте администратора, введя код первичной
|
||||||
|
настройки — установщик печатает его последним сообщением. Если панель
|
||||||
```bash
|
слушает localhost, пробросьте порт:
|
||||||
journalctl -u pzmanager -n 30 --no-pager
|
|
||||||
```
|
|
||||||
|
|
||||||
2. Откройте панель в браузере и создайте администратора, введя этот код.
|
|
||||||
Если панель слушает localhost, пробросьте порт:
|
|
||||||
|
|
||||||
```bash
|
```bash
|
||||||
ssh -L 8080:127.0.0.1:8080 пользователь@сервер
|
ssh -L 8080:127.0.0.1:8080 пользователь@сервер
|
||||||
```
|
```
|
||||||
|
|
||||||
3. Во вкладке «Обзор» нажмите **Установить / обновить через SteamCMD** и
|
Код одноразовый и перестаёт работать сразу после создания администратора.
|
||||||
|
Если вывод установщика потерялся, код есть в журнале:
|
||||||
|
|
||||||
|
```bash
|
||||||
|
journalctl -u pzmanager -n 30 --no-pager
|
||||||
|
```
|
||||||
|
|
||||||
|
2. Во вкладке «Обзор» нажмите **Установить / обновить через SteamCMD** и
|
||||||
дождитесь окончания — прогресс виден во вкладке «Консоль».
|
дождитесь окончания — прогресс виден во вкладке «Консоль».
|
||||||
|
|
||||||
4. Запустите сервер. При первом запуске PZ создаст `Zomboid/Server/*.ini` —
|
3. Запустите сервер. При первом запуске PZ создаст `Zomboid/Server/*.ini` —
|
||||||
после этого станут доступны вкладки «Конфиг сервера», «Песочница» и «Моды».
|
после этого станут доступны вкладки «Конфиг сервера», «Песочница» и «Моды».
|
||||||
|
|
||||||
Порты, которые нужно открыть:
|
Порты, которые нужно открыть:
|
||||||
@@ -131,6 +136,32 @@ make build-linux
|
|||||||
sudo PZ_LISTEN=10.10.1.142:8080 ./deploy/install.sh
|
sudo PZ_LISTEN=10.10.1.142:8080 ./deploy/install.sh
|
||||||
```
|
```
|
||||||
|
|
||||||
|
### Удаление
|
||||||
|
|
||||||
|
Убрать панель, оставив миры и настройки:
|
||||||
|
|
||||||
|
```bash
|
||||||
|
sudo /opt/pzmanager/install.sh --uninstall
|
||||||
|
```
|
||||||
|
|
||||||
|
Удалить всё вместе с мирами, бэкапами и учётными записями:
|
||||||
|
|
||||||
|
```bash
|
||||||
|
sudo /opt/pzmanager/install.sh --uninstall --purge
|
||||||
|
```
|
||||||
|
|
||||||
|
`--purge` спрашивает подтверждение; в неинтерактивном запуске нужен ещё и
|
||||||
|
`--yes`. Каталог сносится, только если похож на установку панели — иначе
|
||||||
|
опечатка в `PZ_HOME` стоила бы чужих файлов.
|
||||||
|
|
||||||
|
Установщик кладёт свою копию в `/opt/pzmanager/install.sh`, так что для
|
||||||
|
удаления ничего скачивать не нужно. Если копии нет, те же аргументы принимает
|
||||||
|
и установочная команда:
|
||||||
|
|
||||||
|
```bash
|
||||||
|
curl -fsSL https://gitea.hsrv.site/mrleo1nid/pzmanager/raw/branch/main/deploy/get.sh | sudo bash -s -- --uninstall --purge
|
||||||
|
```
|
||||||
|
|
||||||
## Моды
|
## Моды
|
||||||
|
|
||||||
Project Zomboid хранит моды в двух строках конфига: `WorkshopItems` — что
|
Project Zomboid хранит моды в двух строках конфига: `WorkshopItems` — что
|
||||||
@@ -162,6 +193,22 @@ Mod ID, который нужен серверу, лежит внутри сам
|
|||||||
Один пакет мастерской может содержать несколько модов — в списке они идут
|
Один пакет мастерской может содержать несколько модов — в списке они идут
|
||||||
отдельными строками, и включать их можно по отдельности.
|
отдельными строками, и включать их можно по отдельности.
|
||||||
|
|
||||||
|
## Редактор конфигов
|
||||||
|
|
||||||
|
Вкладки «Конфиг сервера» и «Песочница» показывают параметры не сплошным
|
||||||
|
списком, а разделами: «Основное», «PVP и урон», «Убежища», «Античит» и так
|
||||||
|
далее. Разделы сворачиваются, а поиск сверху раскрывает те, где нашлось
|
||||||
|
совпадение. Ключи, которых панель не знает (в новой версии игры их всегда
|
||||||
|
добавляют), не теряются — они собираются в раздел «Прочее».
|
||||||
|
|
||||||
|
Описания параметров панель берёт из самого конфига: игра пишет их
|
||||||
|
комментариями на языке сервера. Полный текст виден при наведении, начало —
|
||||||
|
прямо под полем.
|
||||||
|
|
||||||
|
Правка меняет ровно ту строку, которую поправили: комментарии, порядок и
|
||||||
|
переводы строк файла сохраняются, а рядом остаётся копия прежней версии с
|
||||||
|
расширением `.bak`.
|
||||||
|
|
||||||
## Профили серверов
|
## Профили серверов
|
||||||
|
|
||||||
Профиль — это отдельный сервер: свой мир, свой `*.ini`, свои настройки
|
Профиль — это отдельный сервер: свой мир, свой `*.ini`, свои настройки
|
||||||
@@ -183,6 +230,20 @@ Mod ID, который нужен серверу, лежит внутри сам
|
|||||||
При создании профиля можно скопировать `.ini` и настройки песочницы из
|
При создании профиля можно скопировать `.ini` и настройки песочницы из
|
||||||
существующего: удобно, когда нужен тот же набор правил, но чистый мир.
|
существующего: удобно, когда нужен тот же набор правил, но чистый мир.
|
||||||
|
|
||||||
|
### Память JVM
|
||||||
|
|
||||||
|
`java_memory` — это `-Xmx`, верхняя граница кучи. `java_memory_min` (`-Xms`)
|
||||||
|
по умолчанию пуст, и это осознанно: равные значения избавляют от роста кучи на
|
||||||
|
ходу, но заставляют JVM занять весь объём сразу при старте. На машине, где
|
||||||
|
столько свободной памяти не набирается, сервер тогда не поднимется вовсе —
|
||||||
|
`Failed to allocate initial Java heap`. Задавайте минимум, только если памяти
|
||||||
|
заведомо хватает.
|
||||||
|
|
||||||
|
Сервер, упавший сразу после запуска три раза подряд, панель перестаёт
|
||||||
|
поднимать автоматически: обычно так проявляется нехватка памяти или битый
|
||||||
|
конфиг, и перезапуск делу не помогает. Пока идёт отсчёт до автоподъёма, его
|
||||||
|
можно отменить кнопкой «Отменить перезапуск».
|
||||||
|
|
||||||
Удаление профиля убирает его только из панели — мир и конфиги остаются на
|
Удаление профиля убирает его только из панели — мир и конфиги остаются на
|
||||||
диске. Чтобы вернуть профиль, создайте его с тем же идентификатором.
|
диске. Чтобы вернуть профиль, создайте его с тем же идентификатором.
|
||||||
|
|
||||||
@@ -206,9 +267,19 @@ Mod ID, который нужен серверу, лежит внутри сам
|
|||||||
pzserver ALL=(root) NOPASSWD: /usr/local/bin/pzmanager-admin
|
pzserver ALL=(root) NOPASSWD: /usr/local/bin/pzmanager-admin
|
||||||
```
|
```
|
||||||
|
|
||||||
Скрипт качает бинарник нужной архитектуры, сверяет sha256 с `checksums.txt`
|
Скрипт не повторяет логику установки, а забирает из релиза `get.sh` (сверив
|
||||||
релиза, подменяет файл и перезапускает службу. Панель к этим файлам доступа не
|
его sha256) и отдаёт работу ему — поэтому кнопка обновляет всё сразу: бинарник,
|
||||||
имеет — она может только попросить выполнить `update` или `restart`.
|
скрипты установки и systemd-юнит. Панель к этим файлам доступа не имеет, она
|
||||||
|
может только попросить выполнить `update` или `restart`.
|
||||||
|
|
||||||
|
Работа уходит в отдельный разовый юнит (`systemd-run --unit=pzmanager-update`).
|
||||||
|
Иначе обновление не пережило бы само себя: панель вызывает скрипт через sudo,
|
||||||
|
тот живёт в cgroup её юнита, и остановка службы убила бы его на середине.
|
||||||
|
Побочный эффект — вывод идёт не в консоль панели, а в свой журнал:
|
||||||
|
|
||||||
|
```bash
|
||||||
|
journalctl -u pzmanager-update -f
|
||||||
|
```
|
||||||
|
|
||||||
Если правило sudo не установлено (панель поставлена вручную или в системе нет
|
Если правило sudo не установлено (панель поставлена вручную или в системе нет
|
||||||
`sudo`), кнопка не появится, а рядом будет показана команда для терминала:
|
`sudo`), кнопка не появится, а рядом будет показана команда для терминала:
|
||||||
@@ -287,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: Сборка с модами
|
||||||
|
|||||||
@@ -131,10 +131,19 @@ func serve(cfg *config.Config, users *auth.Store, secureCookies bool) error {
|
|||||||
// Пока учёток нет, создать первого администратора можно только с этим
|
// Пока учёток нет, создать первого администратора можно только с этим
|
||||||
// кодом — иначе панель захватит любой, кто откроет её первым.
|
// кодом — иначе панель захватит любой, кто откроет её первым.
|
||||||
setupToken := ""
|
setupToken := ""
|
||||||
|
setupTokenFile := filepath.Join(cfg.DataDir, "setup-token")
|
||||||
if users.IsEmpty() {
|
if users.IsEmpty() {
|
||||||
setupToken = randomToken()
|
setupToken = randomToken()
|
||||||
|
// Код кладём и в файл: установщик читает его оттуда и показывает сразу
|
||||||
|
// после установки, не заставляя идти в журнал.
|
||||||
|
if err := os.WriteFile(setupTokenFile, []byte(setupToken+"\n"), 0o600); err != nil {
|
||||||
|
fmt.Fprintf(os.Stderr, "не удалось записать %s: %v\n", setupTokenFile, err)
|
||||||
|
}
|
||||||
fmt.Printf("\n Панель ещё не настроена.\n"+
|
fmt.Printf("\n Панель ещё не настроена.\n"+
|
||||||
" Откройте её в браузере и введите код первичной настройки:\n\n %s\n\n", setupToken)
|
" Откройте её в браузере и введите код первичной настройки:\n\n %s\n\n", setupToken)
|
||||||
|
} else {
|
||||||
|
// Панель уже настроена: файл мог остаться от прошлой установки.
|
||||||
|
os.Remove(setupTokenFile)
|
||||||
}
|
}
|
||||||
|
|
||||||
apiServer := api.New(api.Options{
|
apiServer := api.New(api.Options{
|
||||||
@@ -148,6 +157,7 @@ func serve(cfg *config.Config, users *auth.Store, secureCookies bool) error {
|
|||||||
Static: static,
|
Static: static,
|
||||||
SecureCookies: secureCookies,
|
SecureCookies: secureCookies,
|
||||||
SetupToken: setupToken,
|
SetupToken: setupToken,
|
||||||
|
SetupTokenFile: setupTokenFile,
|
||||||
Repo: repoURL(),
|
Repo: repoURL(),
|
||||||
})
|
})
|
||||||
|
|
||||||
|
|||||||
+37
-5
@@ -7,6 +7,15 @@
|
|||||||
#
|
#
|
||||||
# curl -fsSL .../get.sh | sudo PZ_LISTEN=10.10.1.142:8080 bash
|
# curl -fsSL .../get.sh | sudo PZ_LISTEN=10.10.1.142:8080 bash
|
||||||
#
|
#
|
||||||
|
# Удаление (аргументы уходят установщику как есть):
|
||||||
|
#
|
||||||
|
# curl -fsSL .../get.sh | sudo bash -s -- --uninstall
|
||||||
|
# curl -fsSL .../get.sh | sudo bash -s -- --uninstall --purge
|
||||||
|
#
|
||||||
|
# Если панель уже установлена, то же самое умеет её локальная копия:
|
||||||
|
#
|
||||||
|
# sudo /opt/pzmanager/install.sh --uninstall --purge
|
||||||
|
#
|
||||||
# Переменные окружения:
|
# Переменные окружения:
|
||||||
# PZ_VERSION какой тег ставить (по умолчанию последний релиз)
|
# PZ_VERSION какой тег ставить (по умолчанию последний релиз)
|
||||||
# PZ_HOME куда ставить (по умолчанию /opt/pzmanager)
|
# PZ_HOME куда ставить (по умолчанию /opt/pzmanager)
|
||||||
@@ -29,6 +38,19 @@ die() { echo "Ошибка: $*" >&2; exit 1; }
|
|||||||
|
|
||||||
[[ $EUID -eq 0 ]] || die "запустите с правами root (sudo)"
|
[[ $EUID -eq 0 ]] || die "запустите с правами root (sudo)"
|
||||||
|
|
||||||
|
# Аргументы уходят установщику. Для удаления бинарник качать незачем — это
|
||||||
|
# лишние восемь мегабайт ради скрипта, который его же и сотрёт.
|
||||||
|
ARGS=("$@")
|
||||||
|
NEED_BINARY=1
|
||||||
|
# Идиома ${ARGS[@]+...} нужна из-за set -u: обычная "${ARGS[@]:-}" на пустом
|
||||||
|
# массиве разворачивается в один пустой аргумент, и установщик спотыкается о
|
||||||
|
# него при обычной установке.
|
||||||
|
for arg in ${ARGS[@]+"${ARGS[@]}"}; do
|
||||||
|
case "$arg" in
|
||||||
|
--uninstall | --remove | --purge) NEED_BINARY=0 ;;
|
||||||
|
esac
|
||||||
|
done
|
||||||
|
|
||||||
for tool in curl sha256sum; do
|
for tool in curl sha256sum; do
|
||||||
command -v "$tool" >/dev/null 2>&1 || die "не найдена утилита $tool"
|
command -v "$tool" >/dev/null 2>&1 || die "не найдена утилита $tool"
|
||||||
done
|
done
|
||||||
@@ -68,10 +90,13 @@ asset_url() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
BIN_NAME="pzmanager-linux-${ARCH}"
|
BIN_NAME="pzmanager-linux-${ARCH}"
|
||||||
|
if [[ "$NEED_BINARY" == "1" ]]; then
|
||||||
BIN_URL="$(asset_url "$BIN_NAME")"
|
BIN_URL="$(asset_url "$BIN_NAME")"
|
||||||
[[ -n "$BIN_URL" ]] || die "в релизе ${TAG} нет файла ${BIN_NAME}"
|
[[ -n "$BIN_URL" ]] || die "в релизе ${TAG} нет файла ${BIN_NAME}"
|
||||||
|
|
||||||
echo "==> Ставлю ${TAG} (${ARCH})"
|
echo "==> Ставлю ${TAG} (${ARCH})"
|
||||||
|
else
|
||||||
|
echo "==> Беру установщик из ${TAG} для удаления"
|
||||||
|
fi
|
||||||
|
|
||||||
TMP="$(mktemp -d)"
|
TMP="$(mktemp -d)"
|
||||||
trap 'rm -rf "$TMP"' EXIT
|
trap 'rm -rf "$TMP"' EXIT
|
||||||
@@ -91,13 +116,17 @@ download() {
|
|||||||
curl -fsSL -o "$name" "$url" || die "не удалось скачать ${name}"
|
curl -fsSL -o "$name" "$url" || die "не удалось скачать ${name}"
|
||||||
}
|
}
|
||||||
|
|
||||||
download "$BIN_NAME"
|
|
||||||
download install.sh
|
download install.sh
|
||||||
download pzmanager.service
|
download pzmanager.service
|
||||||
|
FILES=(install.sh pzmanager.service)
|
||||||
|
|
||||||
|
if [[ "$NEED_BINARY" == "1" ]]; then
|
||||||
|
download "$BIN_NAME"
|
||||||
|
FILES+=("$BIN_NAME")
|
||||||
|
fi
|
||||||
|
|
||||||
# Скрипт привилегированных действий появился не сразу: со старым релизом
|
# Скрипт привилегированных действий появился не сразу: со старым релизом
|
||||||
# ставим без него, панель просто не покажет кнопку обновления.
|
# ставим без него, панель просто не покажет кнопку обновления.
|
||||||
FILES=("$BIN_NAME" install.sh pzmanager.service)
|
|
||||||
if download pzmanager-admin.sh optional; then
|
if download pzmanager-admin.sh optional; then
|
||||||
FILES+=(pzmanager-admin.sh)
|
FILES+=(pzmanager-admin.sh)
|
||||||
fi
|
fi
|
||||||
@@ -120,8 +149,11 @@ mv install.sh pzmanager.service deploy/
|
|||||||
if [[ -f pzmanager-admin.sh ]]; then
|
if [[ -f pzmanager-admin.sh ]]; then
|
||||||
mv pzmanager-admin.sh deploy/
|
mv pzmanager-admin.sh deploy/
|
||||||
fi
|
fi
|
||||||
|
chmod +x deploy/install.sh
|
||||||
|
if [[ "$NEED_BINARY" == "1" ]]; then
|
||||||
mv "$BIN_NAME" pzmanager
|
mv "$BIN_NAME" pzmanager
|
||||||
chmod +x pzmanager deploy/install.sh
|
chmod +x pzmanager
|
||||||
|
fi
|
||||||
|
|
||||||
echo "==> Запускаю установщик"
|
echo "==> Запускаю установщик"
|
||||||
BINARY="$TMP/pzmanager" bash deploy/install.sh
|
BINARY="$TMP/pzmanager" bash deploy/install.sh ${ARGS[@]+"${ARGS[@]}"}
|
||||||
|
|||||||
+176
-9
@@ -1,10 +1,12 @@
|
|||||||
#!/usr/bin/env bash
|
#!/usr/bin/env bash
|
||||||
# Установка и обновление pzmanager на Ubuntu/Debian. Запускать от root:
|
# Установка, обновление и удаление pzmanager на Ubuntu/Debian. От root:
|
||||||
#
|
#
|
||||||
# sudo ./deploy/install.sh
|
# sudo ./deploy/install.sh установить или обновить
|
||||||
|
# sudo ./deploy/install.sh --uninstall убрать панель, данные оставить
|
||||||
|
# sudo ./deploy/install.sh --uninstall --purge убрать вместе с мирами
|
||||||
#
|
#
|
||||||
# Скрипт идемпотентен: на уже настроенной машине он обновляет бинарник и
|
# Установка идемпотентна: на уже настроенной машине обновляются бинарник и
|
||||||
# юнит, не трогая конфиг, миры и учётные записи панели.
|
# юнит, а конфиг, миры и учётные записи панели остаются нетронутыми.
|
||||||
#
|
#
|
||||||
# Переменные окружения:
|
# Переменные окружения:
|
||||||
# PZ_HOME куда ставить всё хозяйство (по умолчанию /opt/pzmanager)
|
# PZ_HOME куда ставить всё хозяйство (по умолчанию /opt/pzmanager)
|
||||||
@@ -29,11 +31,96 @@ ADMIN_SRC="${SCRIPT_DIR}/pzmanager-admin.sh"
|
|||||||
TARGET_BINARY=/usr/local/bin/pzmanager
|
TARGET_BINARY=/usr/local/bin/pzmanager
|
||||||
ADMIN_BINARY=/usr/local/bin/pzmanager-admin
|
ADMIN_BINARY=/usr/local/bin/pzmanager-admin
|
||||||
|
|
||||||
|
UNINSTALL=0
|
||||||
|
PURGE=0
|
||||||
|
for arg in "$@"; do
|
||||||
|
case "$arg" in
|
||||||
|
--uninstall | --remove) UNINSTALL=1 ;;
|
||||||
|
--purge) UNINSTALL=1; PURGE=1 ;;
|
||||||
|
--yes | -y) PZ_ASSUME_YES=1 ;;
|
||||||
|
-h | --help)
|
||||||
|
# Справка — это шапка файла: печатаем комментарии со второй строки и
|
||||||
|
# останавливаемся, как только они кончились.
|
||||||
|
awk 'NR > 1 && /^#/ { sub(/^# ?/, ""); print; next } NR > 1 { exit }' "$0"
|
||||||
|
exit 0
|
||||||
|
;;
|
||||||
|
*)
|
||||||
|
echo "Неизвестный аргумент: $arg" >&2
|
||||||
|
exit 2
|
||||||
|
;;
|
||||||
|
esac
|
||||||
|
done
|
||||||
|
|
||||||
if [[ $EUID -ne 0 ]]; then
|
if [[ $EUID -ne 0 ]]; then
|
||||||
echo "Запустите скрипт от root: sudo $0" >&2
|
echo "Запустите скрипт от root: sudo $0" >&2
|
||||||
exit 1
|
exit 1
|
||||||
fi
|
fi
|
||||||
|
|
||||||
|
# uninstall снимает панель с машины. Данные (миры, бэкапы, учётки) удаляются
|
||||||
|
# только по --purge: потерять сохранения из-за неудачно набранной команды
|
||||||
|
# гораздо обиднее, чем лишний раз убрать каталог руками.
|
||||||
|
uninstall() {
|
||||||
|
echo "==> Удаляю pzmanager"
|
||||||
|
|
||||||
|
if systemctl list-unit-files pzmanager.service &>/dev/null &&
|
||||||
|
systemctl is-active --quiet pzmanager; then
|
||||||
|
echo "==> Останавливаю службу (игровой сервер завершится штатно, это небыстро)"
|
||||||
|
systemctl stop pzmanager || true
|
||||||
|
fi
|
||||||
|
systemctl disable --quiet pzmanager 2>/dev/null || true
|
||||||
|
rm -f /etc/systemd/system/pzmanager.service
|
||||||
|
systemctl daemon-reload
|
||||||
|
systemctl reset-failed pzmanager 2>/dev/null || true
|
||||||
|
|
||||||
|
rm -f /usr/local/bin/pzmanager /usr/local/bin/pzmanager-admin /etc/sudoers.d/pzmanager
|
||||||
|
echo "Служба, бинарники и правило sudo удалены."
|
||||||
|
|
||||||
|
if [[ "$PURGE" != "1" ]]; then
|
||||||
|
echo
|
||||||
|
echo "Данные остались в ${PZ_HOME} (миры, бэкапы, конфиг, учётные записи)."
|
||||||
|
echo "Удалить и их: sudo $0 --uninstall --purge"
|
||||||
|
return
|
||||||
|
fi
|
||||||
|
|
||||||
|
# Защита от опечатки в PZ_HOME: сносим только то, что похоже на нашу
|
||||||
|
# установку, и никогда — корень или домашние каталоги.
|
||||||
|
local home_clean="${PZ_HOME%/}"
|
||||||
|
if [[ -z "$home_clean" || "$home_clean" == "/" || "$home_clean" != /* ]]; then
|
||||||
|
echo "!! PZ_HOME=${PZ_HOME} не похож на каталог установки — не трогаю" >&2
|
||||||
|
return
|
||||||
|
fi
|
||||||
|
if [[ ! -e "$home_clean/config.yaml" && ! -d "$home_clean/data" ]]; then
|
||||||
|
echo "!! В ${home_clean} нет ни config.yaml, ни data/ — не похоже на установку pzmanager," >&2
|
||||||
|
echo " поэтому каталог оставлен нетронутым." >&2
|
||||||
|
return
|
||||||
|
fi
|
||||||
|
|
||||||
|
if [[ "${PZ_ASSUME_YES:-0}" != "1" ]]; then
|
||||||
|
echo
|
||||||
|
echo "Будет безвозвратно удалено: ${home_clean}"
|
||||||
|
echo "Это миры, бэкапы, конфиг и учётные записи панели."
|
||||||
|
if [[ -t 0 ]]; then
|
||||||
|
read -r -p "Введите YES для подтверждения: " answer
|
||||||
|
[[ "$answer" == "YES" ]] || { echo "Отменено."; return; }
|
||||||
|
else
|
||||||
|
echo "Запуск неинтерактивный — повторите с флагом --yes, если уверены." >&2
|
||||||
|
return
|
||||||
|
fi
|
||||||
|
fi
|
||||||
|
|
||||||
|
rm -rf "$home_clean"
|
||||||
|
if id "$PZ_USER" &>/dev/null; then
|
||||||
|
deluser --system "$PZ_USER" &>/dev/null || userdel "$PZ_USER" &>/dev/null || true
|
||||||
|
echo "Пользователь ${PZ_USER} удалён."
|
||||||
|
fi
|
||||||
|
echo "Удалено полностью: ${home_clean}"
|
||||||
|
}
|
||||||
|
|
||||||
|
if [[ "$UNINSTALL" == "1" ]]; then
|
||||||
|
uninstall
|
||||||
|
exit 0
|
||||||
|
fi
|
||||||
|
|
||||||
if [[ ! -f "$BINARY" ]]; then
|
if [[ ! -f "$BINARY" ]]; then
|
||||||
echo "Не найден бинарник $BINARY. Соберите его: make build-linux" >&2
|
echo "Не найден бинарник $BINARY. Соберите его: make build-linux" >&2
|
||||||
exit 1
|
exit 1
|
||||||
@@ -118,17 +205,29 @@ EOF
|
|||||||
chmod 0640 "$CONFIG"
|
chmod 0640 "$CONFIG"
|
||||||
fi
|
fi
|
||||||
|
|
||||||
|
# Если ставим ровно то же самое, что уже лежит, службу трогать незачем: её
|
||||||
|
# остановка кладёт и игровой сервер, а повторный запуск установщика — обычное
|
||||||
|
# дело (например, чтобы обновить скрипты).
|
||||||
|
SAME_BINARY=0
|
||||||
|
if [[ "$MODE" == "update" ]] &&
|
||||||
|
[[ "$(sha256sum "$BINARY" | cut -d' ' -f1)" == "$(sha256sum "$TARGET_BINARY" | cut -d' ' -f1)" ]]; then
|
||||||
|
SAME_BINARY=1
|
||||||
|
echo "==> Бинарник не изменился — службу не останавливаю"
|
||||||
|
fi
|
||||||
|
|
||||||
# Останавливаем сервис перед заменой бинарника: менеджер должен корректно
|
# Останавливаем сервис перед заменой бинарника: менеджер должен корректно
|
||||||
# завершить игровой сервер, а не быть подменённым на ходу.
|
# завершить игровой сервер, а не быть подменённым на ходу.
|
||||||
RESTART_AFTER=0
|
RESTART_AFTER=0
|
||||||
if [[ "$MODE" == "update" ]] && systemctl is-active --quiet pzmanager; then
|
if [[ "$MODE" == "update" && "$SAME_BINARY" == "0" ]] && systemctl is-active --quiet pzmanager; then
|
||||||
echo "==> Останавливаю pzmanager (игровой сервер завершится штатно)"
|
echo "==> Останавливаю pzmanager (игровой сервер завершится штатно)"
|
||||||
systemctl stop pzmanager
|
systemctl stop pzmanager
|
||||||
RESTART_AFTER=1
|
RESTART_AFTER=1
|
||||||
fi
|
fi
|
||||||
|
|
||||||
|
if [[ "$SAME_BINARY" == "0" ]]; then
|
||||||
echo "==> Копирую бинарник в $TARGET_BINARY"
|
echo "==> Копирую бинарник в $TARGET_BINARY"
|
||||||
install -m 0755 "$BINARY" "$TARGET_BINARY"
|
install -m 0755 "$BINARY" "$TARGET_BINARY"
|
||||||
|
fi
|
||||||
|
|
||||||
# Панель работает от непривилегированного пользователя и не может ни заменить
|
# Панель работает от непривилегированного пользователя и не может ни заменить
|
||||||
# бинарник, ни дёрнуть systemctl. Даём ей ровно одну команду через sudo.
|
# бинарник, ни дёрнуть systemctl. Даём ей ровно одну команду через sudo.
|
||||||
@@ -136,6 +235,8 @@ if [[ -f "$ADMIN_SRC" ]] && command -v sudo >/dev/null 2>&1; then
|
|||||||
echo "==> Ставлю $ADMIN_BINARY и правило sudo"
|
echo "==> Ставлю $ADMIN_BINARY и правило sudo"
|
||||||
sed -e "s|@PZ_REPO@|${PZ_REPO}|" \
|
sed -e "s|@PZ_REPO@|${PZ_REPO}|" \
|
||||||
-e "s|@PZ_BINARY@|${TARGET_BINARY}|" \
|
-e "s|@PZ_BINARY@|${TARGET_BINARY}|" \
|
||||||
|
-e "s|@PZ_HOME@|${PZ_HOME}|" \
|
||||||
|
-e "s|@PZ_USER@|${PZ_USER}|" \
|
||||||
"$ADMIN_SRC" > "$ADMIN_BINARY"
|
"$ADMIN_SRC" > "$ADMIN_BINARY"
|
||||||
chown root:root "$ADMIN_BINARY"
|
chown root:root "$ADMIN_BINARY"
|
||||||
chmod 0755 "$ADMIN_BINARY"
|
chmod 0755 "$ADMIN_BINARY"
|
||||||
@@ -152,6 +253,14 @@ else
|
|||||||
echo "!! $ADMIN_SRC не найден или нет sudo — обновление из панели будет недоступно" >&2
|
echo "!! $ADMIN_SRC не найден или нет sudo — обновление из панели будет недоступно" >&2
|
||||||
fi
|
fi
|
||||||
|
|
||||||
|
# Кладём сам установщик рядом с данными: удалить или переустановить панель
|
||||||
|
# можно будет одной локальной командой, без похода в репозиторий.
|
||||||
|
install -m 0755 "$0" "$PZ_HOME/install.sh"
|
||||||
|
if [[ -f "$ADMIN_SRC" ]]; then
|
||||||
|
install -m 0755 "$ADMIN_SRC" "$PZ_HOME/pzmanager-admin.sh"
|
||||||
|
fi
|
||||||
|
install -m 0644 "$UNIT_SRC" "$PZ_HOME/pzmanager.service"
|
||||||
|
|
||||||
echo "==> Ставлю systemd-юнит"
|
echo "==> Ставлю systemd-юнит"
|
||||||
sed -e "s|/opt/pzmanager|${PZ_HOME}|g" \
|
sed -e "s|/opt/pzmanager|${PZ_HOME}|g" \
|
||||||
-e "s|User=pzserver|User=${PZ_USER}|" \
|
-e "s|User=pzserver|User=${PZ_USER}|" \
|
||||||
@@ -161,10 +270,25 @@ sed -e "s|/opt/pzmanager|${PZ_HOME}|g" \
|
|||||||
systemctl daemon-reload
|
systemctl daemon-reload
|
||||||
systemctl enable --quiet pzmanager
|
systemctl enable --quiet pzmanager
|
||||||
|
|
||||||
|
# wait_active ждёт, пока служба поднимется, и говорит, чем всё кончилось:
|
||||||
|
# молчаливый systemctl start оставлял пользователя гадать, работает ли панель.
|
||||||
|
wait_active() {
|
||||||
|
local i
|
||||||
|
for i in $(seq 1 15); do
|
||||||
|
if systemctl is-active --quiet pzmanager; then
|
||||||
|
return 0
|
||||||
|
fi
|
||||||
|
sleep 1
|
||||||
|
done
|
||||||
|
return 1
|
||||||
|
}
|
||||||
|
|
||||||
if [[ "$MODE" == "update" ]]; then
|
if [[ "$MODE" == "update" ]]; then
|
||||||
if [[ "$RESTART_AFTER" == "1" ]]; then
|
if [[ "$RESTART_AFTER" == "1" ]]; then
|
||||||
|
echo "==> Запускаю pzmanager"
|
||||||
systemctl start pzmanager
|
systemctl start pzmanager
|
||||||
fi
|
fi
|
||||||
|
|
||||||
echo
|
echo
|
||||||
if [[ "$OLD_VERSION" == "$NEW_VERSION" ]]; then
|
if [[ "$OLD_VERSION" == "$NEW_VERSION" ]]; then
|
||||||
echo "Переустановлена версия ${NEW_VERSION}."
|
echo "Переустановлена версия ${NEW_VERSION}."
|
||||||
@@ -172,17 +296,50 @@ if [[ "$MODE" == "update" ]]; then
|
|||||||
echo "Обновлено: ${OLD_VERSION} -> ${NEW_VERSION}."
|
echo "Обновлено: ${OLD_VERSION} -> ${NEW_VERSION}."
|
||||||
fi
|
fi
|
||||||
echo "Конфиг, миры и учётные записи не тронуты."
|
echo "Конфиг, миры и учётные записи не тронуты."
|
||||||
|
|
||||||
LISTEN_NOW="$(grep -E '^listen:' "$CONFIG" | head -1 | awk '{print $2}')"
|
LISTEN_NOW="$(grep -E '^listen:' "$CONFIG" | head -1 | awk '{print $2}')"
|
||||||
echo "Панель слушает ${LISTEN_NOW:-?}."
|
if [[ "$RESTART_AFTER" == "1" ]]; then
|
||||||
|
if wait_active; then
|
||||||
|
echo "Панель работает и слушает ${LISTEN_NOW:-?}."
|
||||||
|
else
|
||||||
|
echo "!! Служба не поднялась. Посмотрите, что случилось:" >&2
|
||||||
|
echo " journalctl -u pzmanager -n 40 --no-pager" >&2
|
||||||
|
exit 1
|
||||||
|
fi
|
||||||
|
elif systemctl is-active --quiet pzmanager; then
|
||||||
|
echo "Панель работает и слушает ${LISTEN_NOW:-?}."
|
||||||
|
else
|
||||||
|
# Службу останавливали не мы — значит и поднимать её самовольно не стоит.
|
||||||
|
echo "Служба сейчас остановлена. Запустить: systemctl start pzmanager"
|
||||||
|
fi
|
||||||
exit 0
|
exit 0
|
||||||
fi
|
fi
|
||||||
|
|
||||||
systemctl start pzmanager
|
systemctl start pzmanager
|
||||||
# Дадим сервису секунду подняться, чтобы код настройки успел попасть в журнал.
|
|
||||||
sleep 2
|
# Панель кладёт код первичной настройки в файл, как только поднимется. Ждём
|
||||||
|
# его, чтобы показать код прямо здесь: иначе за ним пришлось бы идти в журнал.
|
||||||
|
SETUP_TOKEN=""
|
||||||
|
TOKEN_FILE="$PZ_HOME/data/setup-token"
|
||||||
|
for _ in $(seq 1 20); do
|
||||||
|
if [[ -s "$TOKEN_FILE" ]]; then
|
||||||
|
SETUP_TOKEN="$(head -1 "$TOKEN_FILE")"
|
||||||
|
break
|
||||||
|
fi
|
||||||
|
if ! systemctl is-active --quiet pzmanager; then
|
||||||
|
break
|
||||||
|
fi
|
||||||
|
sleep 1
|
||||||
|
done
|
||||||
|
|
||||||
echo
|
echo
|
||||||
|
if wait_active; then
|
||||||
echo "Готово. Панель запущена и слушает ${PZ_LISTEN}."
|
echo "Готово. Панель запущена и слушает ${PZ_LISTEN}."
|
||||||
|
else
|
||||||
|
echo "!! Служба не поднялась. Посмотрите, что случилось:" >&2
|
||||||
|
echo " journalctl -u pzmanager -n 40 --no-pager" >&2
|
||||||
|
exit 1
|
||||||
|
fi
|
||||||
echo
|
echo
|
||||||
if [[ "$PZ_LISTEN" == 127.0.0.1:* || "$PZ_LISTEN" == localhost:* ]]; then
|
if [[ "$PZ_LISTEN" == 127.0.0.1:* || "$PZ_LISTEN" == localhost:* ]]; then
|
||||||
echo "Панель доступна только с самой машины. Пробросьте порт:"
|
echo "Панель доступна только с самой машины. Пробросьте порт:"
|
||||||
@@ -198,8 +355,18 @@ else
|
|||||||
echo " sudo ufw allow ${PORT}/tcp"
|
echo " sudo ufw allow ${PORT}/tcp"
|
||||||
echo
|
echo
|
||||||
fi
|
fi
|
||||||
echo "Код первичной настройки — в журнале:"
|
if [[ -n "$SETUP_TOKEN" ]]; then
|
||||||
|
echo "Код первичной настройки (введите его в браузере):"
|
||||||
|
echo
|
||||||
|
echo " ${SETUP_TOKEN}"
|
||||||
|
echo
|
||||||
|
echo "Код одноразовый: после создания администратора он перестаёт работать."
|
||||||
|
else
|
||||||
|
echo "Код первичной настройки не удалось прочитать. Посмотрите журнал:"
|
||||||
echo
|
echo
|
||||||
echo " journalctl -u pzmanager -n 30 --no-pager"
|
echo " journalctl -u pzmanager -n 30 --no-pager"
|
||||||
|
fi
|
||||||
echo
|
echo
|
||||||
echo "Игровые порты сервера: udp/16261 и udp/16262."
|
echo "Игровые порты сервера: udp/16261 и udp/16262."
|
||||||
|
echo
|
||||||
|
echo "Удалить панель целиком: sudo ${PZ_HOME}/install.sh --uninstall --purge"
|
||||||
|
|||||||
+68
-34
@@ -11,7 +11,11 @@ set -euo pipefail
|
|||||||
|
|
||||||
PZ_REPO="@PZ_REPO@"
|
PZ_REPO="@PZ_REPO@"
|
||||||
PZ_BINARY="@PZ_BINARY@"
|
PZ_BINARY="@PZ_BINARY@"
|
||||||
|
PZ_HOME="@PZ_HOME@"
|
||||||
|
PZ_USER="@PZ_USER@"
|
||||||
PZ_SERVICE="pzmanager"
|
PZ_SERVICE="pzmanager"
|
||||||
|
# Имя разового юнита, в котором идёт обновление.
|
||||||
|
UPDATE_UNIT="pzmanager-update"
|
||||||
|
|
||||||
die() { echo "Ошибка: $*" >&2; exit 1; }
|
die() { echo "Ошибка: $*" >&2; exit 1; }
|
||||||
|
|
||||||
@@ -22,21 +26,57 @@ api_base() {
|
|||||||
printf '%s/api/v1/repos/%s' "$host" "${url#"$host"/}"
|
printf '%s/api/v1/repos/%s' "$host" "${url#"$host"/}"
|
||||||
}
|
}
|
||||||
|
|
||||||
|
# asset_url ищет в описании релиза ссылку на файл с точным именем.
|
||||||
|
asset_url() {
|
||||||
|
local release="$1" name="$2"
|
||||||
|
printf '%s' "$release" \
|
||||||
|
| grep -o '"browser_download_url" *: *"[^"]*"' \
|
||||||
|
| cut -d'"' -f4 \
|
||||||
|
| while read -r url; do
|
||||||
|
if [[ "${url##*/}" == "$name" ]]; then
|
||||||
|
printf '%s' "$url"
|
||||||
|
return
|
||||||
|
fi
|
||||||
|
done
|
||||||
|
}
|
||||||
|
|
||||||
|
# cmd_update только запускает работу и сразу возвращает управление панели.
|
||||||
|
#
|
||||||
|
# Обновление обязано пережить перезапуск службы: установщик остановит
|
||||||
|
# pzmanager, а вместе с ним systemd убьёт и этот скрипт — панель вызывает его
|
||||||
|
# через sudo, так что он живёт в cgroup её юнита. Поэтому саму работу уносим
|
||||||
|
# в отдельный разовый юнит, который к pzmanager отношения не имеет.
|
||||||
cmd_update() {
|
cmd_update() {
|
||||||
local version="${1:-latest}"
|
local version="${1:-latest}"
|
||||||
local api release tag url name tmp arch
|
# Версия приходит из панели: проверяем до запуска юнита, чтобы не плодить
|
||||||
|
# заведомо провальные.
|
||||||
|
[[ "$version" == "latest" || "$version" =~ ^[A-Za-z0-9._-]+$ ]] \
|
||||||
|
|| die "недопустимая версия: $version"
|
||||||
|
command -v systemd-run >/dev/null 2>&1 \
|
||||||
|
|| die "нет systemd-run — обновите панель командой из README"
|
||||||
|
|
||||||
case "$(uname -m)" in
|
# --collect убирает юнит после завершения, в том числе неуспешного: иначе
|
||||||
x86_64 | amd64) arch=amd64 ;;
|
# следующий запуск упрётся в оставшийся failed-юнит с тем же именем.
|
||||||
aarch64 | arm64) arch=arm64 ;;
|
systemd-run --quiet --collect --unit="$UPDATE_UNIT" \
|
||||||
*) die "архитектура $(uname -m) не поддерживается" ;;
|
--description="Обновление pzmanager" \
|
||||||
esac
|
"$0" do-update "$version" \
|
||||||
|
|| die "не удалось запустить обновление разовым юнитом"
|
||||||
|
|
||||||
|
echo "Обновление запущено в фоне."
|
||||||
|
echo "Ход работы: journalctl -u ${UPDATE_UNIT} -f"
|
||||||
|
}
|
||||||
|
|
||||||
|
# cmd_do_update выполняется уже внутри разового юнита. Обновляет всё сразу:
|
||||||
|
# бинарник, скрипты установки и systemd-юнит, — поэтому просто отдаёт работу
|
||||||
|
# get.sh из релиза вместо того, чтобы повторять его логику.
|
||||||
|
cmd_do_update() {
|
||||||
|
local version="${1:-latest}" api release tag url tmp
|
||||||
|
|
||||||
api="$(api_base)"
|
api="$(api_base)"
|
||||||
if [[ "$version" == "latest" ]]; then
|
if [[ "$version" == "latest" ]]; then
|
||||||
release="$(curl -fsSL "${api}/releases/latest")" || die "не удалось запросить релиз"
|
release="$(curl -fsSL "${api}/releases/latest")" || die "не удалось запросить релиз"
|
||||||
else
|
else
|
||||||
# Тег приходит из панели; всё, кроме безопасных символов, отвергаем.
|
# Версия приходит из панели; всё, кроме безопасных символов, отвергаем.
|
||||||
[[ "$version" =~ ^[A-Za-z0-9._-]+$ ]] || die "недопустимая версия: $version"
|
[[ "$version" =~ ^[A-Za-z0-9._-]+$ ]] || die "недопустимая версия: $version"
|
||||||
release="$(curl -fsSL "${api}/releases/tags/${version}")" || die "релиз ${version} не найден"
|
release="$(curl -fsSL "${api}/releases/tags/${version}")" || die "релиз ${version} не найден"
|
||||||
fi
|
fi
|
||||||
@@ -44,52 +84,46 @@ cmd_update() {
|
|||||||
tag="$(printf '%s' "$release" | grep -o '"tag_name" *: *"[^"]*"' | head -1 | cut -d'"' -f4)"
|
tag="$(printf '%s' "$release" | grep -o '"tag_name" *: *"[^"]*"' | head -1 | cut -d'"' -f4)"
|
||||||
[[ -n "$tag" ]] || die "в ответе нет тега"
|
[[ -n "$tag" ]] || die "в ответе нет тега"
|
||||||
|
|
||||||
name="pzmanager-linux-${arch}"
|
url="$(asset_url "$release" get.sh)"
|
||||||
url="$(printf '%s' "$release" \
|
[[ -n "$url" ]] || die "в релизе ${tag} нет get.sh"
|
||||||
| grep -o '"browser_download_url" *: *"[^"]*"' | cut -d'"' -f4 \
|
|
||||||
| while read -r candidate; do
|
|
||||||
[[ "${candidate##*/}" == "$name" ]] && { printf '%s' "$candidate"; break; }
|
|
||||||
done)"
|
|
||||||
[[ -n "$url" ]] || die "в релизе ${tag} нет файла ${name}"
|
|
||||||
|
|
||||||
local sums_url
|
local sums_url
|
||||||
sums_url="$(printf '%s' "$release" \
|
sums_url="$(asset_url "$release" checksums.txt)"
|
||||||
| grep -o '"browser_download_url" *: *"[^"]*"' | cut -d'"' -f4 \
|
|
||||||
| while read -r candidate; do
|
|
||||||
[[ "${candidate##*/}" == "checksums.txt" ]] && { printf '%s' "$candidate"; break; }
|
|
||||||
done)"
|
|
||||||
[[ -n "$sums_url" ]] || die "в релизе ${tag} нет checksums.txt"
|
[[ -n "$sums_url" ]] || die "в релизе ${tag} нет checksums.txt"
|
||||||
|
|
||||||
tmp="$(mktemp -d)"
|
tmp="$(mktemp -d)"
|
||||||
trap 'rm -rf "$tmp"' RETURN
|
trap 'rm -rf "$tmp"' RETURN
|
||||||
|
|
||||||
echo "==> Скачиваю ${tag} (${arch})"
|
echo "==> Беру установщик из ${tag}"
|
||||||
curl -fsSL -o "${tmp}/${name}" "$url" || die "не удалось скачать ${name}"
|
curl -fsSL -o "${tmp}/get.sh" "$url" || die "не удалось скачать get.sh"
|
||||||
curl -fsSL -o "${tmp}/checksums.txt" "$sums_url" || die "не удалось скачать checksums.txt"
|
curl -fsSL -o "${tmp}/checksums.txt" "$sums_url" || die "не удалось скачать checksums.txt"
|
||||||
|
|
||||||
echo "==> Проверяю контрольную сумму"
|
echo "==> Проверяю контрольную сумму"
|
||||||
( cd "$tmp" && grep " ${name}\$" checksums.txt > expected.txt && sha256sum -c expected.txt ) \
|
( cd "$tmp" && awk '$NF == "get.sh"' checksums.txt > expected.txt \
|
||||||
|| die "контрольная сумма не сошлась — файл повреждён или подменён"
|
&& [[ -s expected.txt ]] && sha256sum -c expected.txt ) \
|
||||||
|
|| die "контрольная сумма get.sh не сошлась"
|
||||||
|
|
||||||
echo "==> Заменяю ${PZ_BINARY}"
|
echo "==> Обновляю до ${tag}"
|
||||||
chmod 0755 "${tmp}/${name}"
|
# get.sh скачает бинарник нужной архитектуры и запустит install.sh, который
|
||||||
# Через временный файл рядом и rename: перезаписать работающий бинарник
|
# сам остановит службу, заменит файлы и поднимет её обратно.
|
||||||
# нельзя, а переименовать поверх — можно.
|
PZ_HOME="$PZ_HOME" PZ_USER="$PZ_USER" PZ_REPO="$PZ_REPO" PZ_VERSION="$tag" \
|
||||||
install -m 0755 "${tmp}/${name}" "${PZ_BINARY}.new"
|
bash "${tmp}/get.sh" \
|
||||||
mv -f "${PZ_BINARY}.new" "${PZ_BINARY}"
|
|| die "обновление не удалось"
|
||||||
|
|
||||||
echo "==> Перезапускаю ${PZ_SERVICE}"
|
echo "Обновление до ${tag} завершено"
|
||||||
systemctl restart "$PZ_SERVICE"
|
|
||||||
echo "Обновлено до ${tag}"
|
|
||||||
}
|
}
|
||||||
|
|
||||||
case "${1:-}" in
|
case "${1:-}" in
|
||||||
update)
|
update)
|
||||||
cmd_update "${2:-latest}"
|
cmd_update "${2:-latest}"
|
||||||
;;
|
;;
|
||||||
|
do-update)
|
||||||
|
cmd_do_update "${2:-latest}"
|
||||||
|
;;
|
||||||
restart)
|
restart)
|
||||||
echo "==> Перезапускаю ${PZ_SERVICE}"
|
echo "==> Перезапускаю ${PZ_SERVICE}"
|
||||||
systemctl restart "$PZ_SERVICE"
|
# --no-block: команда ставит задание и выходит, не дожидаясь остановки.
|
||||||
|
# Иначе systemd убил бы нас вместе со службой на середине ожидания.
|
||||||
|
systemctl restart --no-block "$PZ_SERVICE"
|
||||||
;;
|
;;
|
||||||
version)
|
version)
|
||||||
"$PZ_BINARY" version
|
"$PZ_BINARY" version
|
||||||
|
|||||||
@@ -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
|
||||||
|
|||||||
@@ -4,6 +4,7 @@ import (
|
|||||||
"crypto/subtle"
|
"crypto/subtle"
|
||||||
"errors"
|
"errors"
|
||||||
"net/http"
|
"net/http"
|
||||||
|
"os"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/mrleo1nid/pzmanager/internal/auth"
|
"github.com/mrleo1nid/pzmanager/internal/auth"
|
||||||
@@ -55,6 +56,10 @@ func (s *Server) handleSetup(w http.ResponseWriter, r *http.Request) {
|
|||||||
writeError(w, http.StatusInternalServerError, err.Error())
|
writeError(w, http.StatusInternalServerError, err.Error())
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
// Администратор создан — код больше не нужен и не должен лежать на диске.
|
||||||
|
if s.setupTokenFile != "" {
|
||||||
|
os.Remove(s.setupTokenFile)
|
||||||
|
}
|
||||||
s.setSessionCookie(w, id, sessionTTL)
|
s.setSessionCookie(w, id, sessionTTL)
|
||||||
writeJSON(w, http.StatusOK, map[string]any{"authenticated": true, "login": creds.Login})
|
writeJSON(w, http.StatusOK, map[string]any{"authenticated": true, "login": creds.Login})
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -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(),
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -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,11 +160,16 @@ 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,
|
||||||
|
JavaMemoryMin: dto.JavaMemoryMin,
|
||||||
ExtraArgs: dto.ExtraArgs,
|
ExtraArgs: dto.ExtraArgs,
|
||||||
// Пустой пароль означает "оставить прежний": наружу мы его не отдаём,
|
// Пустой пароль означает "оставить прежний": наружу мы его не отдаём,
|
||||||
// и форма присылает пустую строку, пока его не меняли.
|
// и форма присылает пустую строку, пока его не меняли.
|
||||||
|
|||||||
@@ -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
|
||||||
}
|
}
|
||||||
|
if profile.JavaMemoryMin != "" {
|
||||||
|
log(fmt.Sprintf("Память JVM: от %s до %s", profile.JavaMemoryMin, profile.JavaMemory))
|
||||||
|
} else {
|
||||||
log("Лимит памяти JVM выставлен: " + profile.JavaMemory)
|
log("Лимит памяти JVM выставлен: " + profile.JavaMemory)
|
||||||
|
}
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -35,7 +35,8 @@ func (s *Server) handleApplyUpdate(w http.ResponseWriter, r *http.Request) {
|
|||||||
// Игровой сервер останавливаем сами: иначе это сделает systemd уже в
|
// Игровой сервер останавливаем сами: иначе это сделает systemd уже в
|
||||||
// момент перезапуска, и ожидание растянется на таймаут остановки.
|
// момент перезапуска, и ожидание растянется на таймаут остановки.
|
||||||
s.stopServerBefore(log, "обновлением")
|
s.stopServerBefore(log, "обновлением")
|
||||||
log("Запускаю обновление, панель перезапустится")
|
log("Запускаю обновление — оно идёт отдельной службой и переживёт перезапуск панели")
|
||||||
|
log("Подробности: journalctl -u pzmanager-update -f")
|
||||||
return s.updater.Apply(ctx, log, body.Version)
|
return s.updater.Apply(ctx, log, body.Version)
|
||||||
})
|
})
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|||||||
@@ -40,8 +40,11 @@ type Server struct {
|
|||||||
// secureCookies включает флаг Secure у cookie сессии (панель за HTTPS).
|
// secureCookies включает флаг Secure у cookie сессии (панель за HTTPS).
|
||||||
secureCookies bool
|
secureCookies bool
|
||||||
// setupToken защищает первичное создание администратора: менеджер печатает
|
// setupToken защищает первичное создание администратора: менеджер печатает
|
||||||
// его в журнал при старте, когда учёток ещё нет.
|
// его при старте, когда учёток ещё нет.
|
||||||
setupToken string
|
setupToken string
|
||||||
|
// setupTokenFile — копия кода на диске, которую показывает установщик.
|
||||||
|
// После создания администратора файл больше не нужен.
|
||||||
|
setupTokenFile string
|
||||||
}
|
}
|
||||||
|
|
||||||
// Options — то, что нужно собрать серверу API.
|
// Options — то, что нужно собрать серверу API.
|
||||||
@@ -57,6 +60,9 @@ type Options struct {
|
|||||||
Static fs.FS
|
Static fs.FS
|
||||||
SecureCookies bool
|
SecureCookies bool
|
||||||
SetupToken string
|
SetupToken string
|
||||||
|
// SetupTokenFile — файл с кодом первичной настройки, удаляется после
|
||||||
|
// создания администратора.
|
||||||
|
SetupTokenFile string
|
||||||
// Repo — репозиторий, из которого панель берёт обновления.
|
// Repo — репозиторий, из которого панель берёт обновления.
|
||||||
Repo string
|
Repo string
|
||||||
}
|
}
|
||||||
@@ -76,6 +82,7 @@ func New(o Options) *Server {
|
|||||||
static: o.Static,
|
static: o.Static,
|
||||||
secureCookies: o.SecureCookies,
|
secureCookies: o.SecureCookies,
|
||||||
setupToken: o.SetupToken,
|
setupToken: o.SetupToken,
|
||||||
|
setupTokenFile: o.SetupTokenFile,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -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"`
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -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
@@ -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, "", " ")
|
||||||
|
|||||||
@@ -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 {
|
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()
|
||||||
|
|||||||
@@ -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++
|
||||||
|
|||||||
@@ -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)
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -24,6 +24,9 @@ type State string
|
|||||||
|
|
||||||
const (
|
const (
|
||||||
StateStopped State = "stopped"
|
StateStopped State = "stopped"
|
||||||
|
// StateRestarting — сервер упал и ждёт автоподъёма. Отдельное состояние
|
||||||
|
// нужно, чтобы это ожидание можно было отменить кнопкой.
|
||||||
|
StateRestarting State = "restarting"
|
||||||
StateStarting State = "starting"
|
StateStarting State = "starting"
|
||||||
StateRunning State = "running"
|
StateRunning State = "running"
|
||||||
StateStopping State = "stopping"
|
StateStopping State = "stopping"
|
||||||
@@ -42,6 +45,14 @@ 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"`
|
||||||
@@ -56,6 +67,8 @@ type Status struct {
|
|||||||
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
@@ -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()
|
|
||||||
}
|
}
|
||||||
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
|
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 пускает к
|
// CanApply проверяет, что привилегированный скрипт на месте и sudo пускает к
|
||||||
// нему без пароля. Проверяем вызовом: наличие файла ещё не значит, что
|
// нему без пароля. Проверяем вызовом: наличие файла ещё не значит, что
|
||||||
// правило sudoers действует.
|
// правило 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))
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|||||||
+1050
-44
File diff suppressed because it is too large
Load Diff
+11
-11
@@ -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>
|
||||||
@@ -145,11 +145,11 @@
|
|||||||
</div>
|
</div>
|
||||||
<div>
|
<div>
|
||||||
<input type="search" id="config-filter" placeholder="Поиск параметра…" class="input-sm">
|
<input type="search" id="config-filter" placeholder="Поиск параметра…" class="input-sm">
|
||||||
<button class="btn btn-primary" id="btn-config-save">Сохранить</button>
|
<button class="btn btn-primary" id="btn-config-save" disabled>Сохранить</button>
|
||||||
</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>
|
||||||
|
|
||||||
<!-- Песочница -->
|
<!-- Песочница -->
|
||||||
@@ -161,11 +161,11 @@
|
|||||||
</div>
|
</div>
|
||||||
<div>
|
<div>
|
||||||
<input type="search" id="sandbox-filter" placeholder="Поиск параметра…" class="input-sm">
|
<input type="search" id="sandbox-filter" placeholder="Поиск параметра…" class="input-sm">
|
||||||
<button class="btn btn-primary" id="btn-sandbox-save">Сохранить</button>
|
<button class="btn btn-primary" id="btn-sandbox-save" disabled>Сохранить</button>
|
||||||
</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>
|
||||||
|
|
||||||
<!-- Моды -->
|
<!-- Моды -->
|
||||||
@@ -176,7 +176,7 @@
|
|||||||
<p class="muted small">Галочка включает мод, перетаскивание задаёт порядок загрузки.
|
<p class="muted small">Галочка включает мод, перетаскивание задаёт порядок загрузки.
|
||||||
Сервер сам скачивает моды из мастерской при запуске.</p>
|
Сервер сам скачивает моды из мастерской при запуске.</p>
|
||||||
</div>
|
</div>
|
||||||
<button class="btn btn-primary" id="btn-mods-save">Сохранить</button>
|
<button class="btn btn-primary" id="btn-mods-save" disabled>Сохранить</button>
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
<p class="muted" id="mods-empty" hidden></p>
|
<p class="muted" id="mods-empty" hidden></p>
|
||||||
@@ -284,13 +284,13 @@
|
|||||||
<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>
|
||||||
|
|
||||||
<h2>Настройки менеджера</h2>
|
<h2>Настройки менеджера</h2>
|
||||||
<form id="settings-form" class="fields"></form>
|
<form id="settings-form" class="fields"></form>
|
||||||
<button class="btn btn-primary" id="btn-settings-save">Сохранить настройки</button>
|
<button class="btn btn-primary" id="btn-settings-save" disabled>Сохранить настройки</button>
|
||||||
|
|
||||||
<h2>Пользователи панели</h2>
|
<h2>Пользователи панели</h2>
|
||||||
<ul class="user-list" id="user-list"></ul>
|
<ul class="user-list" id="user-list"></ul>
|
||||||
|
|||||||
+77
-8
@@ -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); }
|
||||||
|
|||||||
Reference in New Issue
Block a user