From 85df37c26ef0061bf6bf5ee1e53b7ab2980f5934 Mon Sep 17 00:00:00 2001 From: mrleo1nid <43583385+mrleo1nid@users.noreply.github.com> Date: Fri, 30 Oct 2026 22:17:17 +0300 Subject: [PATCH] Add city gameplay, snapshot migrations, administration and Compose operations --- .dockerignore | 1 + .env.example | 10 ++ .gitignore | 1 + Dockerfile | 4 + README.md | 7 ++ client/admin.ts | 38 +++++++ client/connection.ts | 5 +- client/generated/city_pb.ts | 162 +++++++++++++++++++++++++--- compose.yaml | 61 +++++++++++ deploy/README.md | 75 +++++++++++++ deploy/alerts.yml | 23 ++++ deploy/prometheus.yml | 8 ++ docs/PLAN.md | 33 +++--- proto/city.proto | 14 ++- scripts/browser-smoke.mjs | 14 +++ server/README.md | 32 +++++- server/src/gameplay.rs | 205 ++++++++++++++++++++++++++++++++++++ server/src/gateway.rs | 175 ++++++++++++++++++++++++++++-- server/src/lib.rs | 1 + server/src/main.rs | 26 ++++- server/src/simulation.rs | 52 ++++++++- server/src/storage.rs | 60 ++++++++++- server/tests/websocket.rs | 73 +++++++++++++ src/main.ts | 17 +++ 24 files changed, 1042 insertions(+), 55 deletions(-) create mode 100644 .env.example create mode 100644 client/admin.ts create mode 100644 compose.yaml create mode 100644 deploy/README.md create mode 100644 deploy/alerts.yml create mode 100644 deploy/prometheus.yml create mode 100644 server/src/gameplay.rs diff --git a/.dockerignore b/.dockerignore index 67e5ce7..cca66ef 100644 --- a/.dockerignore +++ b/.dockerignore @@ -6,3 +6,4 @@ server/target data world.json public/cities +.env diff --git a/.env.example b/.env.example new file mode 100644 index 0000000..b4aa1d3 --- /dev/null +++ b/.env.example @@ -0,0 +1,10 @@ +# Optional administrator API; at least 32 random characters. Empty disables it. +CITYGEN_ADMIN_TOKEN= +CITYGEN_HOST_IP=127.0.0.1 +CITYGEN_PORT=3000 +CITYGEN_AGENTS=1000 +CITYGEN_MAX_ROOMS=5 +CITYGEN_MEMORY=4g +CITYGEN_CPUS=4 +CITYGEN_SIM_THREADS=4 +CITYGEN_SAVE_QUOTA_BYTES=2147483648 diff --git a/.gitignore b/.gitignore index 7e2966f..8f08165 100644 --- a/.gitignore +++ b/.gitignore @@ -6,3 +6,4 @@ world.json server/target/ data/ public/cities/ +.env diff --git a/Dockerfile b/Dockerfile index e814ddb..9b1e393 100644 --- a/Dockerfile +++ b/Dockerfile @@ -17,9 +17,13 @@ COPY --from=client /app/node_modules node_modules COPY --from=client /app/dist dist COPY --from=client /app/src src COPY --from=client /app/tools tools +COPY --from=client /app/samples samples COPY --from=client /app/package.json package.json COPY --from=server /app/server/target/release/citygen-server /usr/local/bin/citygen-server +RUN mkdir -p /app/public/cities /app/data && chown -R node:node /app ENV CITYGEN_BIND=0.0.0.0:3000 +USER node +HEALTHCHECK --interval=15s --timeout=3s --start-period=30s --retries=3 CMD node -e "fetch('http://127.0.0.1:3000/health').then(r=>process.exit(r.ok?0:1)).catch(()=>process.exit(1))" VOLUME ["/app/public/cities", "/app/data"] EXPOSE 3000 CMD ["citygen-server"] diff --git a/README.md b/README.md index 1f3eec0..7327c0e 100644 --- a/README.md +++ b/README.md @@ -4,6 +4,13 @@ комнаты до 30 наблюдателей, жители по расписанию, общий календарь и голосования, сохранения и очередь генерации. Браузерный генератор ниже остаётся режимом отладки. +## Эксплуатация и игровой слой + +Для запуска через Docker Compose см. [deploy/README.md](deploy/README.md). +В комнате доступны казна, запасы еды, потребности населения, события и три +ограниченных действия игроков. Подробности модели и настроек — +[server/README.md](server/README.md). Интерфейс оператора: `/?admin`. + ## Сетевая игра Нужны Node.js 22+ и Rust stable (на Windows — установленный MSVC linker). diff --git a/client/admin.ts b/client/admin.ts new file mode 100644 index 0000000..4e83d14 --- /dev/null +++ b/client/admin.ts @@ -0,0 +1,38 @@ +/** Operator UI. The token lives only in this page's memory, never in a URL or storage. */ +export function showAdmin(root: HTMLElement) { + root.replaceChildren(); + const panel = document.createElement('section'); panel.className = 'card picker-panel'; panel.style.maxWidth = '850px'; + panel.innerHTML = `

Администрирование

Комнаты`; + root.appendChild(panel); + const status = panel.querySelector('[role=status]')!; + const results = panel.querySelector('[data-results]')!; + const request = async (path: string, method = 'GET') => { + const token = panel.querySelector('input')!.value; + const response = await fetch(path, { method, headers: { Authorization: `Bearer ${token}` }, signal: AbortSignal.timeout(25_000) }); + const data = await response.json(); + if (!response.ok) throw new Error(data.error ?? `HTTP ${response.status}`); + return data; + }; + const refresh = async () => { + results.replaceChildren(); status.textContent = 'Загрузка…'; + try { + const data = await request('/api/admin'); + status.textContent = `Снимки: ${(data.saveBytes / 1048576).toFixed(1)} / ${(data.saveQuotaBytes / 1048576).toFixed(1)} МиБ`; + for (const room of data.rooms) { + const row = document.createElement('p'); + row.textContent = `${room.id} · ${room.cityId} · ${room.players} игроков · тик ${room.tick} · сохранён ${room.savedTick} · ошибок записи ${room.saveErrors} `; + const button = document.createElement('button'); button.className = 'btn'; button.textContent = 'Сохранить'; button.disabled = !room.active; + button.onclick = async () => { + button.disabled = true; + try { await request(`/api/admin/rooms/${encodeURIComponent(room.id)}/checkpoint`, 'POST'); await refresh(); } + catch (e) { status.textContent = (e as Error).message; button.disabled = false; } + }; + row.appendChild(button); results.appendChild(row); + } + for (const snapshot of data.snapshots) if (snapshot.error) { + const row = document.createElement('p'); row.textContent = `${snapshot.id}: ${snapshot.error}`; results.appendChild(row); + } + } catch (e) { status.textContent = (e as Error).message; } + }; + panel.querySelector('[data-refresh]')!.onclick = () => { void refresh(); }; +} diff --git a/client/connection.ts b/client/connection.ts index 71aa7f3..9f95c11 100644 --- a/client/connection.ts +++ b/client/connection.ts @@ -1,5 +1,5 @@ import { create, fromBinary, toBinary } from '@bufbuild/protobuf'; -import { ClientMessageSchema, ServerMessageSchema, type ClientMessage, type Welcome, type Clock, type VoteState } from './generated/city_pb'; +import { ClientMessageSchema, ServerMessageSchema, type ClientMessage, type Welcome, type Clock, type VoteState, type Gameplay } from './generated/city_pb'; import type { Bounds } from '../src/city/format'; import { EntityState } from './entities'; @@ -15,6 +15,7 @@ export class RoomConnection { constructor(room: string, nickname: string, private events: { welcome: (welcome: Welcome) => void; status: (text: string) => void; clock: (clock: Clock) => void; vote: (vote: VoteState) => void; + gameplay: (state: Gameplay) => void; }) { const url = new URL(`/api/rooms/${encodeURIComponent(room)}/ws`, location.href); url.protocol = url.protocol === 'https:' ? 'wss:' : 'ws:'; @@ -42,6 +43,7 @@ export class RoomConnection { } else events.status(b.value.code === 'VOTE_LIMIT' ? 'Дождитесь завершения голосования или 30-секундного интервала между предложениями' : `${b.value.code}: ${b.value.message}`); break; case 'clock': events.clock(b.value); break; + case 'gameplay': events.gameplay(b.value); break; case 'voteState': events.vote(b.value); break; } } catch (error) { events.status((error as Error).message); this.destroy(); } @@ -64,5 +66,6 @@ export class RoomConnection { } propose(speed: number) { this.send({ case: 'propose', value: { speed } }); } vote(yes: boolean) { this.send({ case: 'vote', value: { yes } }); } + intervene(action: string) { this.send({ case: 'intervene', value: { action } }); } destroy() { this.closed = true; clearTimeout(this.retry); clearInterval(this.ping); this.socket.close(); this.entities.clear(); } } diff --git a/client/generated/city_pb.ts b/client/generated/city_pb.ts index 44acb96..9caf958 100644 --- a/client/generated/city_pb.ts +++ b/client/generated/city_pb.ts @@ -10,7 +10,7 @@ import type { Message } from "@bufbuild/protobuf"; * Describes the file city.proto. */ export const file_city: GenFile = /*@__PURE__*/ - fileDesc("CgpjaXR5LnByb3RvEgRjaXR5IkIKBFJlY3QSDQoFbWluX3gYASABKBESDQoFbWluX3kYAiABKBESDQoFbWF4X3gYAyABKBESDQoFbWF4X3kYBCABKBEiPgoESm9pbhIMCgRyb29tGAEgASgJEhYKDmNsaWVudF92ZXJzaW9uGAIgASgNEhAKCG5pY2tuYW1lGAMgASgJIjIKCVN1YnNjcmliZRIYCgRyZWN0GAEgASgLMgouY2l0eS5SZWN0EgsKA2xvZBgCIAEoDSIVCgRQaW5nEg0KBW5vbmNlGAEgASgNIhgKB1Byb3Bvc2USDQoFc3BlZWQYASABKA0iEwoEVm90ZRILCgN5ZXMYASABKAgiNgoKQ3JlYXRlQ2l0eRIMCgRiYm94GAEgAygBEgwKBG5hbWUYAiABKAkSDAoEc2VlZBgDIAEoDSJlCgdDaXR5Sm9iEgoKAmlkGAEgASgJEg8KB2NpdHlfaWQYAiABKAkSDgoGc3RhdHVzGAMgASgJEg8KB3Jvb21faWQYBCABKAkSDQoFZXJyb3IYBSABKAkSDQoFc3RhZ2UYBiABKAkiswEKDUNsaWVudE1lc3NhZ2USGgoEam9pbhgBIAEoCzIKLmNpdHkuSm9pbkgAEiQKCXN1YnNjcmliZRgCIAEoCzIPLmNpdHkuU3Vic2NyaWJlSAASGgoEcGluZxgDIAEoCzIKLmNpdHkuUGluZ0gAEiAKB3Byb3Bvc2UYBCABKAsyDS5jaXR5LlByb3Bvc2VIABIaCgR2b3RlGAUgASgLMgouY2l0eS5Wb3RlSABCBgoEYm9keSI3CgVBZ2VudBIKCgJpZBgBIAEoDRIJCgF4GAIgASgREgkKAXkYAyABKBESDAoEa2luZBgEIAEoDSJrCgdXZWxjb21lEgwKBHJvb20YASABKAkSDAoEdGljaxgCIAEoBBIZChFjaXR5X21hbmlmZXN0X3VybBgDIAEoCRIPCgdzZXNzaW9uGAQgASgJEhgKEHByb3RvY29sX3ZlcnNpb24YBSABKA0iNwoIU25hcHNob3QSDAoEdGljaxgBIAEoBBIdCghlbnRpdGllcxgCIAMoCzILLmNpdHkuQWdlbnQiZAoFRGVsdGESDAoEdGljaxgBIAEoBBIcCgdzcGF3bmVkGAIgAygLMgsuY2l0eS5BZ2VudBIcCgdjaGFuZ2VkGAMgAygLMgsuY2l0eS5BZ2VudBIRCglkZXNwYXduZWQYBCADKA0iJgoFRXJyb3ISDAoEY29kZRgBIAEoCRIPCgdtZXNzYWdlGAIgASgJImMKCVZvdGVTdGF0ZRIOCgZhY3RpdmUYASABKAgSDQoFc3BlZWQYAiABKA0SCwoDeWVzGAMgASgNEg8KB3BsYXllcnMYBCABKA0SGQoRcmVtYWluaW5nX3NlY29uZHMYBSABKA0iOgoFQ2xvY2sSDAoEdGljaxgBIAEoBBIUCgxnYW1lX3NlY29uZHMYAiABKAESDQoFc3BlZWQYAyABKA0i+gEKDVNlcnZlck1lc3NhZ2USIAoHd2VsY29tZRgBIAEoCzINLmNpdHkuV2VsY29tZUgAEiIKCHNuYXBzaG90GAIgASgLMg4uY2l0eS5TbmFwc2hvdEgAEhwKBWRlbHRhGAMgASgLMgsuY2l0eS5EZWx0YUgAEhwKBWVycm9yGAQgASgLMgsuY2l0eS5FcnJvckgAEhoKBHBvbmcYBSABKAsyCi5jaXR5LlBpbmdIABIlCgp2b3RlX3N0YXRlGAYgASgLMg8uY2l0eS5Wb3RlU3RhdGVIABIcCgVjbG9jaxgHIAEoCzILLmNpdHkuQ2xvY2tIAEIGCgRib2R5IjkKClNhdmVkQWdlbnQSCgoCaWQYASABKA0SDQoFcm91dGUYAiABKA0SEAoIZGlzdGFuY2UYAyABKAEiOgoFUm91dGUSCgoCeHkYASADKBESDwoHaG9tZV9pZBgCIAEoCRIUCgx3b3JrcGxhY2VfaWQYAyABKAki5QEKCFJvb21TYXZlEg8KB3ZlcnNpb24YASABKA0SCgoCaWQYAiABKAkSDwoHY2l0eV9pZBgDIAEoCRIUCgxjaXR5X3ZlcnNpb24YBCABKA0SDAoEdGljaxgFIAEoBBIMCgRzZWVkGAYgASgEEhQKDGdhbWVfc2Vjb25kcxgHIAEoARINCgVzcGVlZBgIIAEoDRIgCgZhZ2VudHMYCSADKAsyEC5jaXR5LlNhdmVkQWdlbnQSGwoGcm91dGVzGAogAygLMgsuY2l0eS5Sb3V0ZRIVCg1jaXR5X3JldmlzaW9uGAsgASgJYgZwcm90bzM"); + fileDesc("CgpjaXR5LnByb3RvEgRjaXR5IkIKBFJlY3QSDQoFbWluX3gYASABKBESDQoFbWluX3kYAiABKBESDQoFbWF4X3gYAyABKBESDQoFbWF4X3kYBCABKBEiPgoESm9pbhIMCgRyb29tGAEgASgJEhYKDmNsaWVudF92ZXJzaW9uGAIgASgNEhAKCG5pY2tuYW1lGAMgASgJIjIKCVN1YnNjcmliZRIYCgRyZWN0GAEgASgLMgouY2l0eS5SZWN0EgsKA2xvZBgCIAEoDSIVCgRQaW5nEg0KBW5vbmNlGAEgASgNIhgKB1Byb3Bvc2USDQoFc3BlZWQYASABKA0iEwoEVm90ZRILCgN5ZXMYASABKAgiGwoJSW50ZXJ2ZW5lEg4KBmFjdGlvbhgBIAEoCSI4CgVOZWVkcxIOCgZodW5nZXIYASABKA0SDwoHZmF0aWd1ZRgCIAEoDRIOCgZtb3JhbGUYAyABKA0iKQoJR2FtZUV2ZW50Eg4KBm1pbnV0ZRgBIAEoBBIMCgRraW5kGAIgASgJIqoBCghHYW1lcGxheRIQCgh0cmVhc3VyeRgBIAEoEhIMCgRmb29kGAIgASgEEhoKBW5lZWRzGAMgASgLMgsuY2l0eS5OZWVkcxIfCgZldmVudHMYBCADKAsyDy5jaXR5LkdhbWVFdmVudBIPCgdwZW5kaW5nGAUgAygJEg4KBm1pbnV0ZRgGIAEoBBIgChhuZXh0X2ludGVydmVudGlvbl9taW51dGUYByABKAQiNgoKQ3JlYXRlQ2l0eRIMCgRiYm94GAEgAygBEgwKBG5hbWUYAiABKAkSDAoEc2VlZBgDIAEoDSJlCgdDaXR5Sm9iEgoKAmlkGAEgASgJEg8KB2NpdHlfaWQYAiABKAkSDgoGc3RhdHVzGAMgASgJEg8KB3Jvb21faWQYBCABKAkSDQoFZXJyb3IYBSABKAkSDQoFc3RhZ2UYBiABKAki2QEKDUNsaWVudE1lc3NhZ2USGgoEam9pbhgBIAEoCzIKLmNpdHkuSm9pbkgAEiQKCXN1YnNjcmliZRgCIAEoCzIPLmNpdHkuU3Vic2NyaWJlSAASGgoEcGluZxgDIAEoCzIKLmNpdHkuUGluZ0gAEiAKB3Byb3Bvc2UYBCABKAsyDS5jaXR5LlByb3Bvc2VIABIaCgR2b3RlGAUgASgLMgouY2l0eS5Wb3RlSAASJAoJaW50ZXJ2ZW5lGAYgASgLMg8uY2l0eS5JbnRlcnZlbmVIAEIGCgRib2R5IjcKBUFnZW50EgoKAmlkGAEgASgNEgkKAXgYAiABKBESCQoBeRgDIAEoERIMCgRraW5kGAQgASgNImsKB1dlbGNvbWUSDAoEcm9vbRgBIAEoCRIMCgR0aWNrGAIgASgEEhkKEWNpdHlfbWFuaWZlc3RfdXJsGAMgASgJEg8KB3Nlc3Npb24YBCABKAkSGAoQcHJvdG9jb2xfdmVyc2lvbhgFIAEoDSI3CghTbmFwc2hvdBIMCgR0aWNrGAEgASgEEh0KCGVudGl0aWVzGAIgAygLMgsuY2l0eS5BZ2VudCJkCgVEZWx0YRIMCgR0aWNrGAEgASgEEhwKB3NwYXduZWQYAiADKAsyCy5jaXR5LkFnZW50EhwKB2NoYW5nZWQYAyADKAsyCy5jaXR5LkFnZW50EhEKCWRlc3Bhd25lZBgEIAMoDSImCgVFcnJvchIMCgRjb2RlGAEgASgJEg8KB21lc3NhZ2UYAiABKAkiYwoJVm90ZVN0YXRlEg4KBmFjdGl2ZRgBIAEoCBINCgVzcGVlZBgCIAEoDRILCgN5ZXMYAyABKA0SDwoHcGxheWVycxgEIAEoDRIZChFyZW1haW5pbmdfc2Vjb25kcxgFIAEoDSI6CgVDbG9jaxIMCgR0aWNrGAEgASgEEhQKDGdhbWVfc2Vjb25kcxgCIAEoARINCgVzcGVlZBgDIAEoDSKeAgoNU2VydmVyTWVzc2FnZRIgCgd3ZWxjb21lGAEgASgLMg0uY2l0eS5XZWxjb21lSAASIgoIc25hcHNob3QYAiABKAsyDi5jaXR5LlNuYXBzaG90SAASHAoFZGVsdGEYAyABKAsyCy5jaXR5LkRlbHRhSAASHAoFZXJyb3IYBCABKAsyCy5jaXR5LkVycm9ySAASGgoEcG9uZxgFIAEoCzIKLmNpdHkuUGluZ0gAEiUKCnZvdGVfc3RhdGUYBiABKAsyDy5jaXR5LlZvdGVTdGF0ZUgAEhwKBWNsb2NrGAcgASgLMgsuY2l0eS5DbG9ja0gAEiIKCGdhbWVwbGF5GAggASgLMg4uY2l0eS5HYW1lcGxheUgAQgYKBGJvZHkiOQoKU2F2ZWRBZ2VudBIKCgJpZBgBIAEoDRINCgVyb3V0ZRgCIAEoDRIQCghkaXN0YW5jZRgDIAEoASI6CgVSb3V0ZRIKCgJ4eRgBIAMoERIPCgdob21lX2lkGAIgASgJEhQKDHdvcmtwbGFjZV9pZBgDIAEoCSKHAgoIUm9vbVNhdmUSDwoHdmVyc2lvbhgBIAEoDRIKCgJpZBgCIAEoCRIPCgdjaXR5X2lkGAMgASgJEhQKDGNpdHlfdmVyc2lvbhgEIAEoDRIMCgR0aWNrGAUgASgEEgwKBHNlZWQYBiABKAQSFAoMZ2FtZV9zZWNvbmRzGAcgASgBEg0KBXNwZWVkGAggASgNEiAKBmFnZW50cxgJIAMoCzIQLmNpdHkuU2F2ZWRBZ2VudBIbCgZyb3V0ZXMYCiADKAsyCy5jaXR5LlJvdXRlEhUKDWNpdHlfcmV2aXNpb24YCyABKAkSIAoIZ2FtZXBsYXkYDCABKAsyDi5jaXR5LkdhbWVwbGF5YgZwcm90bzM"); /** * @generated from message city.Rect @@ -144,6 +144,121 @@ export type Vote = Message<"city.Vote"> & { export const VoteSchema: GenMessage = /*@__PURE__*/ messageDesc(file_city, 5); +/** + * Equal rights for every connected player; only these three bounded actions exist. + * + * @generated from message city.Intervene + */ +export type Intervene = Message<"city.Intervene"> & { + /** + * @generated from field: string action = 1; + */ + action: string; +}; + +/** + * Describes the message city.Intervene. + * Use `create(InterveneSchema)` to create a new message. + */ +export const InterveneSchema: GenMessage = /*@__PURE__*/ + messageDesc(file_city, 6); + +/** + * @generated from message city.Needs + */ +export type Needs = Message<"city.Needs"> & { + /** + * @generated from field: uint32 hunger = 1; + */ + hunger: number; + + /** + * @generated from field: uint32 fatigue = 2; + */ + fatigue: number; + + /** + * @generated from field: uint32 morale = 3; + */ + morale: number; +}; + +/** + * Describes the message city.Needs. + * Use `create(NeedsSchema)` to create a new message. + */ +export const NeedsSchema: GenMessage = /*@__PURE__*/ + messageDesc(file_city, 7); + +/** + * @generated from message city.GameEvent + */ +export type GameEvent = Message<"city.GameEvent"> & { + /** + * @generated from field: uint64 minute = 1; + */ + minute: bigint; + + /** + * @generated from field: string kind = 2; + */ + kind: string; +}; + +/** + * Describes the message city.GameEvent. + * Use `create(GameEventSchema)` to create a new message. + */ +export const GameEventSchema: GenMessage = /*@__PURE__*/ + messageDesc(file_city, 8); + +/** + * @generated from message city.Gameplay + */ +export type Gameplay = Message<"city.Gameplay"> & { + /** + * @generated from field: sint64 treasury = 1; + */ + treasury: bigint; + + /** + * @generated from field: uint64 food = 2; + */ + food: bigint; + + /** + * @generated from field: city.Needs needs = 3; + */ + needs?: Needs | undefined; + + /** + * @generated from field: repeated city.GameEvent events = 4; + */ + events: GameEvent[]; + + /** + * @generated from field: repeated string pending = 5; + */ + pending: string[]; + + /** + * @generated from field: uint64 minute = 6; + */ + minute: bigint; + + /** + * @generated from field: uint64 next_intervention_minute = 7; + */ + nextInterventionMinute: bigint; +}; + +/** + * Describes the message city.Gameplay. + * Use `create(GameplaySchema)` to create a new message. + */ +export const GameplaySchema: GenMessage = /*@__PURE__*/ + messageDesc(file_city, 9); + /** * @generated from message city.CreateCity */ @@ -169,7 +284,7 @@ export type CreateCity = Message<"city.CreateCity"> & { * Use `create(CreateCitySchema)` to create a new message. */ export const CreateCitySchema: GenMessage = /*@__PURE__*/ - messageDesc(file_city, 6); + messageDesc(file_city, 10); /** * @generated from message city.CityJob @@ -211,7 +326,7 @@ export type CityJob = Message<"city.CityJob"> & { * Use `create(CityJobSchema)` to create a new message. */ export const CityJobSchema: GenMessage = /*@__PURE__*/ - messageDesc(file_city, 7); + messageDesc(file_city, 11); /** * @generated from message city.ClientMessage @@ -250,6 +365,12 @@ export type ClientMessage = Message<"city.ClientMessage"> & { */ value: Vote; case: "vote"; + } | { + /** + * @generated from field: city.Intervene intervene = 6; + */ + value: Intervene; + case: "intervene"; } | { case: undefined; value?: undefined }; }; @@ -258,7 +379,7 @@ export type ClientMessage = Message<"city.ClientMessage"> & { * Use `create(ClientMessageSchema)` to create a new message. */ export const ClientMessageSchema: GenMessage = /*@__PURE__*/ - messageDesc(file_city, 8); + messageDesc(file_city, 12); /** * @generated from message city.Agent @@ -290,7 +411,7 @@ export type Agent = Message<"city.Agent"> & { * Use `create(AgentSchema)` to create a new message. */ export const AgentSchema: GenMessage = /*@__PURE__*/ - messageDesc(file_city, 9); + messageDesc(file_city, 13); /** * @generated from message city.Welcome @@ -327,7 +448,7 @@ export type Welcome = Message<"city.Welcome"> & { * Use `create(WelcomeSchema)` to create a new message. */ export const WelcomeSchema: GenMessage = /*@__PURE__*/ - messageDesc(file_city, 10); + messageDesc(file_city, 14); /** * @generated from message city.Snapshot @@ -349,7 +470,7 @@ export type Snapshot = Message<"city.Snapshot"> & { * Use `create(SnapshotSchema)` to create a new message. */ export const SnapshotSchema: GenMessage = /*@__PURE__*/ - messageDesc(file_city, 11); + messageDesc(file_city, 15); /** * @generated from message city.Delta @@ -381,7 +502,7 @@ export type Delta = Message<"city.Delta"> & { * Use `create(DeltaSchema)` to create a new message. */ export const DeltaSchema: GenMessage = /*@__PURE__*/ - messageDesc(file_city, 12); + messageDesc(file_city, 16); /** * @generated from message city.Error @@ -403,7 +524,7 @@ export type Error = Message<"city.Error"> & { * Use `create(ErrorSchema)` to create a new message. */ export const ErrorSchema: GenMessage = /*@__PURE__*/ - messageDesc(file_city, 13); + messageDesc(file_city, 17); /** * @generated from message city.VoteState @@ -440,7 +561,7 @@ export type VoteState = Message<"city.VoteState"> & { * Use `create(VoteStateSchema)` to create a new message. */ export const VoteStateSchema: GenMessage = /*@__PURE__*/ - messageDesc(file_city, 14); + messageDesc(file_city, 18); /** * @generated from message city.Clock @@ -467,7 +588,7 @@ export type Clock = Message<"city.Clock"> & { * Use `create(ClockSchema)` to create a new message. */ export const ClockSchema: GenMessage = /*@__PURE__*/ - messageDesc(file_city, 15); + messageDesc(file_city, 19); /** * @generated from message city.ServerMessage @@ -518,6 +639,12 @@ export type ServerMessage = Message<"city.ServerMessage"> & { */ value: Clock; case: "clock"; + } | { + /** + * @generated from field: city.Gameplay gameplay = 8; + */ + value: Gameplay; + case: "gameplay"; } | { case: undefined; value?: undefined }; }; @@ -526,7 +653,7 @@ export type ServerMessage = Message<"city.ServerMessage"> & { * Use `create(ServerMessageSchema)` to create a new message. */ export const ServerMessageSchema: GenMessage = /*@__PURE__*/ - messageDesc(file_city, 16); + messageDesc(file_city, 20); /** * @generated from message city.SavedAgent @@ -553,7 +680,7 @@ export type SavedAgent = Message<"city.SavedAgent"> & { * Use `create(SavedAgentSchema)` to create a new message. */ export const SavedAgentSchema: GenMessage = /*@__PURE__*/ - messageDesc(file_city, 17); + messageDesc(file_city, 21); /** * @generated from message city.Route @@ -580,7 +707,7 @@ export type Route = Message<"city.Route"> & { * Use `create(RouteSchema)` to create a new message. */ export const RouteSchema: GenMessage = /*@__PURE__*/ - messageDesc(file_city, 18); + messageDesc(file_city, 22); /** * @generated from message city.RoomSave @@ -640,6 +767,11 @@ export type RoomSave = Message<"city.RoomSave"> & { * @generated from field: string city_revision = 11; */ cityRevision: string; + + /** + * @generated from field: city.Gameplay gameplay = 12; + */ + gameplay?: Gameplay | undefined; }; /** @@ -647,5 +779,5 @@ export type RoomSave = Message<"city.RoomSave"> & { * Use `create(RoomSaveSchema)` to create a new message. */ export const RoomSaveSchema: GenMessage = /*@__PURE__*/ - messageDesc(file_city, 19); + messageDesc(file_city, 23); diff --git a/compose.yaml b/compose.yaml new file mode 100644 index 0000000..01a52f7 --- /dev/null +++ b/compose.yaml @@ -0,0 +1,61 @@ +name: citygen +services: + app: + build: . + init: true + restart: unless-stopped + ports: + - "${CITYGEN_HOST_IP:-127.0.0.1}:${CITYGEN_PORT:-3000}:3000" + environment: + CITYGEN_BIND: 0.0.0.0:3000 + CITYGEN_ADMIN_TOKEN: ${CITYGEN_ADMIN_TOKEN:-} + CITYGEN_AGENTS: ${CITYGEN_AGENTS:-1000} + CITYGEN_MAX_ROOMS: ${CITYGEN_MAX_ROOMS:-5} + CITYGEN_SAVE_INTERVAL: ${CITYGEN_SAVE_INTERVAL:-60} + CITYGEN_SAVE_QUOTA_BYTES: ${CITYGEN_SAVE_QUOTA_BYTES:-2147483648} + CITYGEN_SIM_THREADS: ${CITYGEN_SIM_THREADS:-4} + CITYGEN_MAX_GENERATION_KM2: ${CITYGEN_MAX_GENERATION_KM2:-25} + CITYGEN_MAX_BUILDINGS: ${CITYGEN_MAX_BUILDINGS:-10000} + CITYGEN_GENERATION_WORKERS: ${CITYGEN_GENERATION_WORKERS:-2} + volumes: + - cities:/app/public/cities + - saves:/app/data + stop_grace_period: 120s + mem_limit: ${CITYGEN_MEMORY:-4g} + cpus: ${CITYGEN_CPUS:-4} + pids_limit: 256 + security_opt: + - no-new-privileges:true + cap_drop: [ALL] + logging: + driver: json-file + options: + max-size: "10m" + max-file: "3" + prometheus: + image: prom/prometheus:v3.15.1 + profiles: [monitoring] + restart: unless-stopped + depends_on: + app: + condition: service_healthy + command: + - --config.file=/etc/prometheus/prometheus.yml + - --storage.tsdb.retention.time=7d + - --storage.tsdb.retention.size=1GB + ports: + - "127.0.0.1:${CITYGEN_METRICS_PORT:-9090}:9090" + volumes: + - ./deploy/prometheus.yml:/etc/prometheus/prometheus.yml:ro + - ./deploy/alerts.yml:/etc/prometheus/alerts.yml:ro + - metrics:/prometheus + mem_limit: 512m + logging: + driver: json-file + options: + max-size: "10m" + max-file: "3" +volumes: + cities: + saves: + metrics: diff --git a/deploy/README.md b/deploy/README.md new file mode 100644 index 0000000..ada94c5 --- /dev/null +++ b/deploy/README.md @@ -0,0 +1,75 @@ +# Запуск через Compose + +Из корня репозитория, с работающим Docker Engine: + +```sh +cp .env.example .env +docker compose config --quiet +docker compose build +# Необязательно: подготовить город из локальной OSM-выгрузки. +docker compose run --rm --no-deps app node --import tsx tools/demo.ts +docker compose up -d --wait +``` + +Открыть `http://localhost:3000/?play`. Можно создать город через интерфейс. +Города и сохранения находятся в отдельных постоянных томах `cities` и `saves`. +Пересборка и `docker compose down` сохраняют тома. `down -v` удаляет их. +Существующий каталог города нельзя перезаписывать, пока на него ссылаются комнаты. + +Приложение работает от пользователя `node`, с лимитами памяти, CPU, +процессов и ротацией логов. Значения `.env.example` рассчитаны на старт с +1000 жителями; миллион жителей и пять комнат требуют замера и настройки. +Порт по умолчанию доступен локально. Для внешнего доступа измените +`CITYGEN_HOST_IP` или используйте HTTPS reverse proxy с WebSocket. +Встроенный лимит создания видит IP TCP-соединения, поэтому за прокси он +общий для всех посетителей; недоверенные X-Forwarded-For не используются. + +Остановка посылает SIGTERM; сервер завершает комнаты и ждёт запись снимков +(до 120 секунд). Перед обновлением: + +```sh +docker compose stop +# Сделать резервную копию ОБОИХ томов средствами Docker-хоста. +docker compose build +docker compose up -d --wait +``` + +Проверка: `docker compose ps`, `docker compose logs --tail=100 app`, +`curl --fail http://localhost:3000/health`. Миграция комнат v1→v2 выполняется +при открытии комнаты; неизвестная версия остаётся на диске с ошибкой. +Квота `CITYGEN_SAVE_QUOTA_BYTES` включает все снимки и временный новый файл +до ротации: оставьте запас минимум на один полный снимок. При переполнении +запись отклоняется, прежние снимки сохраняются. Квота относится к снимкам; +объём городов ограничивайте средствами Docker-хоста. + +## Администрирование + +Задать `CITYGEN_ADMIN_TOKEN` случайной строкой минимум из 32 символов в `.env` +и пересоздать контейнер. Пустое значение отключает API. `.env` игнорируется Git +и не попадает в build context. `/?admin` показывает комнаты, использование +диска и ошибки несовместимых снимков, позволяет сохранить активную комнату. +Ответ приходит после записи. Токен остаётся только в памяти страницы. + +API: `GET /api/admin`, `POST /api/admin/rooms/{id}/checkpoint`, +заголовок `Authorization: Bearer `. Привилегии оператора не выдаются +игрокам и создателям комнат. Удаление миров/городов через API не предусмотрено. + +## Мониторинг + +```sh +docker compose --profile monitoring up -d --wait +``` + +Prometheus на `http://localhost:9090` опрашивает `/metrics` каждые 5 секунд, +хранит до 7 дней / 1 ГБ. `alerts.yml` содержит правила недоступности, +тиков дольше 50 мс и ошибок сохранения. Предупреждения видны в Prometheus; +внешние уведомления требуют отдельного Alertmanager. Зафиксирована +[версия 3.15.1](https://github.com/prometheus/prometheus/releases/tag/v3.15.1). + +Метрики: комнаты/игроки, сущности, последний/максимальный тик, +байты рассылки, ошибки и последний успешный тик сохранения. Ошибки снимков, +медленные тики, запуск/остановка пишутся JSON-строками в stderr. + +Без Engine можно проверить `docker compose --profile monitoring config --quiet`. +Полный smoke-test контейнера после запуска: `/health`, вход двух клиентов, +команда «Обед», остановка/запуск и проверка восстановленного состояния. diff --git a/deploy/alerts.yml b/deploy/alerts.yml new file mode 100644 index 0000000..7b2846c --- /dev/null +++ b/deploy/alerts.yml @@ -0,0 +1,23 @@ +groups: + - name: citygen + rules: + - alert: CitygenDown + expr: up{job="citygen"} == 0 + for: 1m + labels: + severity: critical + annotations: + summary: Citygen cannot be scraped + - alert: CitygenSlowTick + expr: citygen_room_tick_seconds > 0.05 + for: 30s + labels: + severity: warning + annotations: + summary: Room tick exceeds 50 ms + - alert: CitygenSaveFailure + expr: increase(citygen_room_save_errors_total[5m]) > 0 + labels: + severity: critical + annotations: + summary: Room snapshot failed; check disk quota and logs diff --git a/deploy/prometheus.yml b/deploy/prometheus.yml new file mode 100644 index 0000000..4d043f9 --- /dev/null +++ b/deploy/prometheus.yml @@ -0,0 +1,8 @@ +global: + scrape_interval: 5s +rule_files: + - /etc/prometheus/alerts.yml +scrape_configs: + - job_name: citygen + static_configs: + - targets: [app:3000] diff --git a/docs/PLAN.md b/docs/PLAN.md index a89cd8c..28be18c 100644 --- a/docs/PLAN.md +++ b/docs/PLAN.md @@ -4,7 +4,7 @@ ## 1. Цель и рамки -Игра: симулятор бога в духе RimWorld, но с меньшим влиянием игрока. Город живёт сам (жители, машины, потребности, события), игроки в основном наблюдают и ограниченно вмешиваются (вмешательство в первую версию не входит). +Игра: симулятор бога в духе RimWorld, но с меньшим влиянием игрока. Город живёт сам (жители, машины, потребности, события), игроки в основном наблюдают и ограниченно вмешиваются. По запросу автора от 2026-10-30 этап 5 включает базовые команды вмешательства. Исходные требования: @@ -14,7 +14,7 @@ - Клиент остаётся в браузере и только отображает. Вся симуляция и правила на сервере. - Сгенерированный город хранится готовым, генерация не выполняется в рантайме комнаты. -Не входит в первую версию: влияние игроков на мир, аккаунты и монетизация, предсказание на клиенте (в наблюдательной игре оно не нужно). +Не входит в первую версию: аккаунты и монетизация, предсказание на клиенте (в наблюдательной игре оно не нужно). Влияние ограничено командами этапа 5. ## 2. Ключевые решения @@ -172,20 +172,22 @@ - [x] Оптимизация протокола и рендера. Бинарные дельты, квантизация, объединение пропущенных обновлений под бюджетом трафика, ограничение видимых сущностей и кэш тайлов; динамика пока на Canvas. -**Этап 5. Игровой слой (дальше)** -- [ ] Потребности, события, экономика. -- [ ] Ограниченное влияние игроков (команды, права, очереди, лимиты). -- [ ] Сохранения, восстановление комнат, админка. - Сохранения и восстановление уже работают; админка, миграции схем и квоты диска остаются следующей частью этапа. +**Этап 5. Базовый игровой слой** +- [x] Потребности, события, экономика. + Усреднённые голод, усталость и настроение населения; сон, питание, производство еды и доход казны. События урожая, болезни и дождя воспроизводятся из seed и игрового времени. Индивидуальный ИИ жителей пока остаётся расписанием дом–работа. +- [x] Ограниченное влияние игроков (команды, права, очереди, лимиты). + Покупка запасов, общий обед и отдых; одинаковые права подключённых игроков, цена из общей казны, ограниченная очередь, общий часовой игровой интервал и интервал сессии. Пауза/скорость остаются голосованием. +- [x] Сохранения, восстановление комнат, админка. + Схема v2 сохраняет игровой слой и очередь, v1 мигрируется при открытии. Добавлены общая квота снимков, защита прежних файлов при переполнении и админский интерфейс/API с отдельным токеном оператора. **Этап 6. Эксплуатация** -- [ ] Деплой, мониторинг (метрики тика, число сущностей, трафик), логи. - Метрики, логи и Dockerfile подготовлены. Docker Engine в текущей среде не запущен; внешний сервер для деплоя не задан. +- [x] Подготовка Compose, мониторинг (метрики тика, число сущностей, трафик), логи. + По уточнению автора этап 6 ограничен подготовкой Compose. Добавлены постоянные тома, healthcheck, лимиты, SIGTERM с сохранением, ротация логов и опциональный Prometheus с правилами предупреждений. Проверка `docker compose --profile monitoring config --quiet` проходит. Docker Engine выключен: сборка и запуск контейнера не проверены. - [x] Создание комнат по запросу (выбор города), лимиты ресурсов. Проверка минимальной сцены: `npm run demo`, `npm run build`, `npm run server:dev`, затем `http://localhost:3000/?play`. Имя репозитория остаётся `citygen`; генератор и существующий рендер сохраняют свои пути в `src/`, новые сетевые модули находятся в `client/`. -Состояние и ограничения реализации описаны в `server/README.md`. Этапы 5–6 не объявляются завершёнными готовностью сетевого прототипа. +Состояние и ограничения реализации описаны в `server/README.md`, запуск Compose — в `deploy/README.md`. Этап 5 реализует базовую городскую модель, этап 6 — подготовку Compose в согласованном объёме. ## 10. Риски @@ -269,7 +271,10 @@ - Реальная нагрузка, 2026-10-30: Бальцерс, 1 000 000 жителей, 30 WebSocket-клиентов, 20 с, фоновые сохранения каждые 2 с. Выборка длительности тиков через метрики: p95 36,5 мс; максимум всех тиков по счётчику комнаты 44,7 мс. Средний трафик 4,8 КБ/с на клиента, максимальный 44,7 КБ/с. Ошибок, разрывов и срабатываний ограничения трафика не было. Это короткий локальный тест с небольшими AOI, а не гарантия для любого города, плотности, диска и целевого сервера. Пиковая память процесса со статикой и буферами — около 272 МиБ; память одной ECS отдельно не измерялась. - Браузер: повторный вход в сохранённую миллионную комнату до загруженной области — 1,31 с в локальном Chrome. -Детальные пути между этажами, использование мебели жителями, потребности, -события, экономика и вмешательство игроков остаются игровым слоем этапа 5. -Для эксплуатации также остаются миграции снимков, квоты диска, админка, -проверка контейнера и развёртывание в выбранном окружении. +- Этапы 5–6: 17 TS-тестов, 11 Rust unit-тестов и 2 интеграционных теста проходят. Проверены миграция v1→v2, сохранение очереди команды, детерминизм экономики/событий, влияние потребностей на производство, расход еды, квота без потери последнего снимка, отказ без админского токена и подтверждение записи через API. +- Chrome: отображение казны/еды/потребностей, команда «Обед» со списанием ресурсов и снижением голода, пауза, этаж/масштаб, админское сохранение. Загрузка области — 1,12 с локально. + +Дальнейшее развитие за пределами базового слоя: индивидуальные потребности и +выбор целей, детальные переходы между этажами, использование мебели и +уличных слотов жителями, транспорт. Подготовленный Compose ещё нужно собрать +и запустить на Docker-хосте; внешнее развёртывание в текущий запрос не входит. diff --git a/proto/city.proto b/proto/city.proto index 9bec345..fde3b47 100644 --- a/proto/city.proto +++ b/proto/city.proto @@ -7,10 +7,19 @@ message Subscribe { Rect rect = 1; uint32 lod = 2; } message Ping { uint32 nonce = 1; } message Propose { uint32 speed = 1; } message Vote { bool yes = 1; } +// Equal rights for every connected player; only these three bounded actions exist. +message Intervene { string action = 1; } +message Needs { uint32 hunger = 1; uint32 fatigue = 2; uint32 morale = 3; } +message GameEvent { uint64 minute = 1; string kind = 2; } +message Gameplay { + sint64 treasury = 1; uint64 food = 2; Needs needs = 3; + repeated GameEvent events = 4; repeated string pending = 5; + uint64 minute = 6; uint64 next_intervention_minute = 7; +} message CreateCity { repeated double bbox = 1; string name = 2; uint32 seed = 3; } message CityJob { string id = 1; string city_id = 2; string status = 3; string room_id = 4; string error = 5; string stage = 6; } message ClientMessage { - oneof body { Join join = 1; Subscribe subscribe = 2; Ping ping = 3; Propose propose = 4; Vote vote = 5; } + oneof body { Join join = 1; Subscribe subscribe = 2; Ping ping = 3; Propose propose = 4; Vote vote = 5; Intervene intervene = 6; } } message Agent { uint32 id = 1; sint32 x = 2; sint32 y = 3; uint32 kind = 4; } message Welcome { string room = 1; uint64 tick = 2; string city_manifest_url = 3; string session = 4; uint32 protocol_version = 5; } @@ -20,7 +29,7 @@ message Error { string code = 1; string message = 2; } message VoteState { bool active = 1; uint32 speed = 2; uint32 yes = 3; uint32 players = 4; uint32 remaining_seconds = 5; } message Clock { uint64 tick = 1; double game_seconds = 2; uint32 speed = 3; } message ServerMessage { - oneof body { Welcome welcome = 1; Snapshot snapshot = 2; Delta delta = 3; Error error = 4; Ping pong = 5; VoteState vote_state = 6; Clock clock = 7; } + oneof body { Welcome welcome = 1; Snapshot snapshot = 2; Delta delta = 3; Error error = 4; Ping pong = 5; VoteState vote_state = 6; Clock clock = 7; Gameplay gameplay = 8; } } message SavedAgent { uint32 id = 1; uint32 route = 2; double distance = 3; } message Route { repeated sint32 xy = 1; string home_id = 2; string workplace_id = 3; } @@ -29,4 +38,5 @@ message RoomSave { uint64 tick = 5; uint64 seed = 6; double game_seconds = 7; uint32 speed = 8; repeated SavedAgent agents = 9; repeated Route routes = 10; string city_revision = 11; + Gameplay gameplay = 12; } diff --git a/scripts/browser-smoke.mjs b/scripts/browser-smoke.mjs index ada3bee..f4136d8 100644 --- a/scripts/browser-smoke.mjs +++ b/scripts/browser-smoke.mjs @@ -24,6 +24,10 @@ try { await page.waitForFunction(()=>document.querySelector('.viewer-top [role=status]')?.textContent.includes('в загруженной области'),null,{timeout:60000}); const visibleMs=Math.round(performance.now()-started); await page.waitForFunction(()=>document.querySelector('.room-clock')?.textContent.includes('День'),null,{timeout:10000}); + await page.waitForFunction(()=>document.querySelector('.room-gameplay')?.textContent.includes('Казна'),null,{timeout:10000}); + await page.locator('[data-action=meal]').click(); + await page.waitForFunction(()=>document.querySelector('[data-action=meal]')?.disabled,null,{timeout:5000}); + await page.waitForFunction(()=>document.querySelector('.room-gameplay')?.textContent.includes('Общий обед'),null,{timeout:15000}); await page.getByRole('button',{name:'Пауза',exact:true}).click(); await page.waitForFunction(()=>document.querySelector('.room-clock')?.textContent.includes('×0'),null,{timeout:10000}); await page.getByRole('button',{name:'1',exact:true}).click(); @@ -31,4 +35,14 @@ try { await mkdir('.tools',{recursive:true}); await page.screenshot({path:'.tools/browser-room.png'}); assert.deepEqual(errors,[]); console.log(JSON.stringify({ui:'passed',visibleMs,status:await page.locator('.viewer-top').innerText(),screenshot:resolve('.tools/browser-room.png')})); + if (process.env.CITYGEN_TEST_ADMIN_TOKEN) { + await page.goto(`${base}/?admin`); + await page.getByLabel('Токен оператора').fill(process.env.CITYGEN_TEST_ADMIN_TOKEN); + await page.getByRole('button',{name:'Обновить',exact:true}).click(); + await page.waitForFunction(()=>document.querySelector('[role=status]')?.textContent.includes('МиБ'),null,{timeout:10000}); + const saved = page.waitForResponse(r=>r.url().endsWith('/checkpoint') && r.request().method()==='POST'); + await page.getByRole('button',{name:'Сохранить',exact:true}).first().click(); + assert.equal((await saved).status(),200); + console.log(JSON.stringify({admin:'passed'})); + } } finally {await browser.close();} diff --git a/server/README.md b/server/README.md index ee48a94..ed945a1 100644 --- a/server/README.md +++ b/server/README.md @@ -42,6 +42,8 @@ - `CITYGEN_MAX_VISIBLE`: 1000, максимум 5000; `CITYGEN_SIM_THREADS`: до четырёх CPU по умолчанию, общий пул ECS на процесс. - `CITYGEN_EMPTY_TIMEOUT`: 300 с; `CITYGEN_SAVE_INTERVAL`: 60 с. - `CITYGEN_KEEP_SNAPSHOTS`: 3. +- `CITYGEN_SAVE_QUOTA_BYTES`: 2147483648 (2 ГиБ, включая временный снимок). +- `CITYGEN_ADMIN_TOKEN`: пусто; для включения API требуется минимум 32 символа. - `CITYGEN_MAX_GENERATION_KM2`: 25; `CITYGEN_MAX_BUILDINGS`: 10000. - `CITYGEN_GENERATION_WORKERS`: 2; `CITYGEN_GENERATION_QUEUE`: 8. - `CITYGEN_GENERATION_TIMEOUT`: 600 с. @@ -68,6 +70,30 @@ Боты создают комнату, подключаются, подписываются на 30 областей, адаптируют LOD и выводят трафик, выборку длительности тиков и ошибки соединений. -Dockerfile подготавливает приложение для одного сервера. Каталоги городов -и `data/` необходимо подключать постоянными томами. Docker-сборка и внешний -деплой требуют отдельной проверки в целевом окружении. +Compose, постоянные тома, лимиты, healthcheck и профиль Prometheus описаны +в [deploy/README.md](../deploy/README.md). + +## Игровой слой + +Голод, усталость и настроение моделируются как усреднённые показатели +населения комнаты. Они меняются по игровому календарю независимо от камеры. +Сон ночью восстанавливает силы; питание трижды в день тратит запасы еды. +Голод и усталость снижают производство и доход казны в рабочие часы. +Почасовые события (урожай, болезнь, дождь) детерминированы seed и временем. +История ограничена 16 событиями. Это базовая экономика общего города; +индивидуальные кошельки, машины и детальное использование мебели не включены. + +Все игроки имеют одинаковые права на три команды: покупка запасов +(2 единицы казны на жителя), общий обед (1), отдых (3). Цена списывается +при приёме, действие исполняется в следующую игровую минуту. Сервер проверяет +ресурсы, паузу, очередь (до 8), общий интервал 60 игровых минут и интервал +сессии 30 реальных секунд. Общий интервал переживает переподключение. +Пауза и скорость по-прежнему требуют большинства голосов. + +Снимки v2 сохраняют экономику, потребности, историю, очередь и общий интервал. +Для v1 игровой слой инициализируется по числу жителей и сохранённому времени; +позиции, seed и расписания сохраняются. Неизвестные версии не перезаписываются. +Квота проверяется под общей блокировкой писателей комнат; при нехватке места +прежние снимки остаются. Один снимок ограничен 128 МиБ. +`/?admin` и API с Bearer-токеном показывают каталог, ошибки, квоту +и позволяют сохранить активную комнату. diff --git a/server/src/gameplay.rs b/server/src/gameplay.rs new file mode 100644 index 0000000..890f1d8 --- /dev/null +++ b/server/src/gameplay.rs @@ -0,0 +1,205 @@ +//! Coarse city-wide needs/economy. Updates cost O(game minutes), independent of +//! population and camera. Residents keep their deterministic commuter schedule. +use crate::protocol::{GameEvent, Gameplay, Needs}; +use bevy_ecs::prelude::Resource; + +#[derive(Resource, Clone)] +pub struct Game(pub Gameplay); +impl Game { + pub fn new(population: usize, seconds: f64) -> Self { + Self(Gameplay { + treasury: population as i64 * 100, + food: population as u64 * 2, + needs: Some(Needs { + hunger: 20, + fatigue: 20, + morale: 70, + }), + minute: (seconds / 60.0) as u64, + ..Default::default() + }) + } + pub fn validate(state: &Gameplay, seconds: f64, population: usize) -> Result<(), String> { + let needs = state.needs.as_ref().ok_or("Missing saved needs")?; + if state.minute != (seconds / 60.0) as u64 + || state.treasury < 0 + || state.food > (population as u64).saturating_mul(100).max(100) + || [needs.hunger, needs.fatigue, needs.morale] + .iter() + .any(|n| *n > 100) + || state.events.len() > 16 + || state.pending.len() > 8 + || state.events.iter().any(|e| { + e.minute > state.minute + || !["harvest", "illness", "rain", "supplies", "meal", "rest"] + .contains(&e.kind.as_str()) + }) + || state + .pending + .iter() + .any(|a| Self::cost(a, population).is_none()) + { + return Err("Invalid saved gameplay".into()); + } + Ok(()) + } + pub fn cost(action: &str, population: usize) -> Option { + let unit = population.max(1) as i64; + match action { + "supplies" => Some(unit * 2), + "meal" => Some(unit), + "rest" => Some(unit * 3), + _ => None, + } + } + pub fn enqueue(&mut self, action: &str, population: usize, paused: bool) -> Result<(), String> { + let cost = Self::cost(action, population).ok_or("Unknown intervention")?; + if paused { + return Err("Commands are unavailable while paused".into()); + } + if self.0.pending.len() >= 8 || self.0.minute < self.0.next_intervention_minute { + return Err("City intervention cooldown: one command per game hour".into()); + } + if self.0.treasury < cost { + return Err("Insufficient treasury".into()); + } + if action == "meal" && self.0.food < population as u64 { + return Err("Insufficient food; purchase supplies first".into()); + } + self.0.treasury -= cost; + self.0.pending.push(action.into()); + self.0.next_intervention_minute = self.0.minute + 60; + Ok(()) + } + fn event(&mut self, kind: &str) { + self.0.events.push(GameEvent { + minute: self.0.minute, + kind: kind.into(), + }); + if self.0.events.len() > 16 { + self.0.events.remove(0); + } + } + pub fn advance(&mut self, seconds: f64, population: usize, seed: u64) { + let until = (seconds / 60.0) as u64; + let population = population as u64; + while self.0.minute < until { + self.0.minute += 1; + for action in std::mem::take(&mut self.0.pending) { + match action.as_str() { + "supplies" => { + self.0.food = (self.0.food + population * 2).min(population * 100) + } + "meal" => { + let fed = self.0.food >= population; + if fed { + self.0.food -= population; + } + let needs = self.0.needs.as_mut().unwrap(); + if fed { + needs.hunger = needs.hunger.saturating_sub(40); + needs.morale = (needs.morale + 5).min(100); + } + } + "rest" => { + let n = self.0.needs.as_mut().unwrap(); + n.fatigue = n.fatigue.saturating_sub(30); + n.morale = (n.morale + 10).min(100); + } + _ => unreachable!(), + } + self.event(&action); + } + if self.0.minute % 10 == 0 { + let hour = (self.0.minute / 60) % 24; + let n = self.0.needs.as_mut().unwrap(); + n.hunger = (n.hunger + 1).min(100); + n.fatigue = if hour < 7 || hour >= 22 { + n.fatigue.saturating_sub(3) + } else { + (n.fatigue + 1).min(100) + }; + if n.hunger > 70 || n.fatigue > 80 { + n.morale = n.morale.saturating_sub(1); + } + } + if self.0.minute % 60 == 0 { + let hour = (self.0.minute / 60) % 24; + if (8..17).contains(&hour) { + let n = self.0.needs.as_ref().unwrap(); + // Hunger and fatigue reduce labour output and tax receipts. + let productivity = (200 - n.hunger - n.fatigue) as u64; + let output = population * productivity / 200; + self.0.treasury = self.0.treasury.saturating_add(output as i64); + self.0.food = (self.0.food + output / 3).min(population * 100); + } + if [7, 13, 19].contains(&hour) { + let served = self.0.food.min(population); + self.0.food -= served; + let reduction = (served * 25 / population.max(1)) as u32; + let n = self.0.needs.as_mut().unwrap(); + n.hunger = n.hunger.saturating_sub(reduction); + } + let random = (seed ^ (self.0.minute / 60).wrapping_mul(0x9e3779b97f4a7c15)) + .wrapping_mul(0xbf58476d1ce4e5b9); + match random % 24 { + 0 => { + self.0.food = (self.0.food + population).min(population * 100); + self.event("harvest"); + } + 1 => { + let n = self.0.needs.as_mut().unwrap(); + n.fatigue = (n.fatigue + 10).min(100); + self.event("illness"); + } + 2 => { + let n = self.0.needs.as_mut().unwrap(); + n.morale = n.morale.saturating_sub(5); + self.event("rain"); + } + _ => {} + } + } + } + } +} + +#[cfg(test)] +mod tests { + use super::*; + #[test] + fn needs_reduce_output_and_food_is_consumed() { + let mut healthy = Game::new(1000, 7.0 * 3600.0); + let mut hungry = healthy.clone(); + hungry.0.needs.as_mut().unwrap().hunger = 100; + hungry.0.needs.as_mut().unwrap().fatigue = 100; + healthy.advance(8.0 * 3600.0, 1000, 7); + hungry.advance(8.0 * 3600.0, 1000, 7); + assert!(healthy.0.treasury > hungry.0.treasury); + let mut meal = Game::new(1000, 12.0 * 3600.0); + meal.advance(13.0 * 3600.0, 1000, 7); + assert!(meal.0.food < 2000, "scheduled meals consume reserves"); + meal.0.food = 0; + assert!(meal.enqueue("meal", 1000, false).is_err()); + meal.0.treasury = 0; + assert!(meal.enqueue("supplies", 1000, false).is_err()); + } + #[test] + fn commands_budget_cooldown_and_deterministic_recovery() { + let mut game = Game::new(1000, 0.0); + assert!(game.enqueue("delete", 1000, false).is_err()); + assert!(game.enqueue("meal", 1000, true).is_err()); + game.enqueue("meal", 1000, false).unwrap(); + assert_eq!(game.0.treasury, 99000); + assert!(game.enqueue("meal", 1000, false).is_err()); + let mut restored = Game(game.0.clone()); + for minute in 1..=2880 { + game.advance(minute as f64 * 60.0, 1000, 7); + restored.advance(minute as f64 * 60.0, 1000, 7); + } + assert_eq!(game.0, restored.0); + assert!(game.0.pending.is_empty()); + assert!(!game.0.events.is_empty()); + Game::validate(&game.0, 2880.0 * 60.0, 1000).unwrap(); + } +} diff --git a/server/src/gateway.rs b/server/src/gateway.rs index eb1eb68..94d67ae 100644 --- a/server/src/gateway.rs +++ b/server/src/gateway.rs @@ -9,7 +9,7 @@ use axum::{ ws::{Message as WsMessage, WebSocket, WebSocketUpgrade}, ConnectInfo, Path, State, }, - http::StatusCode, + http::{HeaderMap, StatusCode}, response::IntoResponse, routing::get, Json, Router, @@ -48,6 +48,8 @@ pub struct Config { pub max_visible: usize, pub osm_fixture: Option, pub project_root: PathBuf, + pub save_quota_bytes: u64, + pub admin_token: Option, } impl Default for Config { fn default() -> Self { @@ -68,6 +70,8 @@ impl Default for Config { max_visible: 1000, osm_fixture: None, project_root: std::env::current_dir().unwrap_or_else(|_| ".".into()), + save_quota_bytes: 2 * 1024 * 1024 * 1024, + admin_token: None, } } } @@ -93,6 +97,8 @@ struct RoomMetrics { entities: AtomicU64, bytes: AtomicU64, max_micros: AtomicU64, + save_errors: AtomicU64, + saved_tick: AtomicU64, } pub(crate) enum Command { Join { @@ -103,6 +109,7 @@ pub(crate) enum Command { Leave(String), Input(String, p::ClientMessage), Stop, + Checkpoint(tokio::sync::oneshot::Sender>), } struct Player { nickname: String, @@ -111,6 +118,7 @@ struct Player { lod: u32, known: HashMap, last_proposal: Option, + last_intervention: Option, traffic: Traffic, metrics: Arc, } @@ -193,6 +201,8 @@ impl App { || config.generation_queue == 0 || config.max_visible == 0 || config.max_visible > 5000 + || config.save_quota_bytes == 0 + || config.admin_token.as_ref().is_some_and(|t| t.len() < 32) || !config.max_generation_km2.is_finite() || config.max_generation_km2 <= 0.0 { @@ -360,6 +370,11 @@ pub fn router(app: App) -> Router { .route("/api/rooms/{id}/ws", get(upgrade)) .route("/health", get(|| async { "ok" })) .route("/metrics", get(metrics)) + .route("/api/admin", get(admin_status)) + .route( + "/api/admin/rooms/{id}/checkpoint", + axum::routing::post(admin_checkpoint), + ) .nest("/cities", city_files) .fallback_service(tower_http::services::ServeDir::new("dist")) .with_state(app) @@ -373,6 +388,83 @@ async fn cache_city(mut response: axum::response::Response) -> axum::response::R } response } + +fn authorize(app: &App, headers: &HeaderMap) -> Result<(), ApiError> { + let expected = app + .config + .admin_token + .as_ref() + .ok_or_else(|| api_error(StatusCode::NOT_FOUND, "Administration is disabled"))?; + let received = headers + .get(axum::http::header::AUTHORIZATION) + .and_then(|h| h.to_str().ok()) + .and_then(|h| h.strip_prefix("Bearer ")) + .unwrap_or(""); + use sha2::{Digest, Sha256}; + let a = Sha256::digest(expected.as_bytes()); + let b = Sha256::digest(received.as_bytes()); + if a.iter() + .zip(b.iter()) + .fold(0u8, |diff, (a, b)| diff | (a ^ b)) + != 0 + { + return Err(api_error( + StatusCode::UNAUTHORIZED, + "Administrator token required", + )); + } + Ok(()) +} +async fn admin_status( + State(app): State, + headers: HeaderMap, +) -> Result, ApiError> { + authorize(&app, &headers)?; + let root = app.config.saves.clone(); + let disk = tokio::task::spawn_blocking(move || { + let mut snapshots = vec![]; + for entry in std::fs::read_dir(&root).map_err(|e| e.to_string())?.flatten() { + let id = entry.file_name().to_string_lossy().to_string(); + if !entry.file_type().map_err(|e| e.to_string())?.is_dir() || !safe_id(&id) { continue; } + let result = storage::load(&root, &id); + snapshots.push(serde_json::json!({"id":id,"error":result.as_ref().err(),"version":result.as_ref().ok().map(|s|s.version),"tick":result.as_ref().ok().map(|s|s.tick)})); + } + Ok::<_, String>((storage::disk_bytes(&root)?, snapshots)) + }).await.map_err(|e|api_error(StatusCode::INTERNAL_SERVER_ERROR,e.to_string()))?.map_err(|e|api_error(StatusCode::INTERNAL_SERVER_ERROR,e))?; + let rooms = app.rooms.lock().unwrap().iter().map(|(id,r)| serde_json::json!({"id":id,"cityId":r.city_id,"active":r.active.load(Ordering::Relaxed),"players":r.players.load(Ordering::Relaxed),"tick":r.metrics.tick.load(Ordering::Relaxed),"savedTick":r.metrics.saved_tick.load(Ordering::Relaxed),"saveErrors":r.metrics.save_errors.load(Ordering::Relaxed)})).collect::>(); + Ok(Json( + serde_json::json!({"rooms":rooms,"snapshots":disk.1,"saveBytes":disk.0,"saveQuotaBytes":app.config.save_quota_bytes}), + )) +} +async fn admin_checkpoint( + State(app): State, + Path(id): Path, + headers: HeaderMap, +) -> Result, ApiError> { + authorize(&app, &headers)?; + let (tx, rx) = tokio::sync::oneshot::channel(); + { + let rooms = app.rooms.lock().unwrap(); + let room = rooms + .get(&id) + .ok_or_else(|| api_error(StatusCode::NOT_FOUND, "Room not found"))?; + if !room.active.load(Ordering::Relaxed) { + return Err(api_error( + StatusCode::CONFLICT, + "Room is already saved and inactive", + )); + } + room.commands + .try_send(Command::Checkpoint(tx)) + .map_err(|_| api_error(StatusCode::TOO_MANY_REQUESTS, "Room command queue is busy"))?; + } + tokio::time::timeout(Duration::from_secs(20), rx) + .await + .map_err(|_| api_error(StatusCode::GATEWAY_TIMEOUT, "Checkpoint timed out"))? + .map_err(|_| api_error(StatusCode::SERVICE_UNAVAILABLE, "Room stopped"))? + .map_err(|e| api_error(StatusCode::INSUFFICIENT_STORAGE, e))?; + Ok(Json(serde_json::json!({"saved":true}))) +} async fn create_city( State(app): State, ConnectInfo(peer): ConnectInfo, @@ -533,6 +625,7 @@ async fn metrics(State(app): State) -> String { app.active() ); for (id, room) in app.rooms.lock().unwrap().iter() { + text.push_str(&format!("citygen_room_save_errors_total{{room=\"{id}\"}} {}\ncitygen_room_saved_tick{{room=\"{id}\"}} {}\n", room.metrics.save_errors.load(Ordering::Relaxed), room.metrics.saved_tick.load(Ordering::Relaxed))); text.push_str(&format!( "citygen_room_tick_max_seconds{{room=\"{id}\"}} {}\n", room.metrics.max_micros.load(Ordering::Relaxed) as f64 / 1_000_000.0 @@ -648,13 +741,31 @@ fn room_loop( } } let _lifecycle = Lifecycle(active.clone(), player_count.clone()); - let (save_tx, save_rx) = mpsc::sync_channel::(1); + let (save_tx, save_rx) = mpsc::sync_channel::<( + crate::simulation::Checkpoint, + Option>>, + )>(1); let save_root = config.saves.clone(); let keep = config.keep_snapshots; + let quota = config.save_quota_bytes; + let save_metrics = metrics.clone(); let save_thread = std::thread::spawn(move || { - while let Ok(snapshot) = save_rx.recv() { - if let Err(e) = storage::save(&save_root, &snapshot.materialize(), keep) { - eprintln!("snapshot failed: {e}"); + while let Ok((snapshot, response)) = save_rx.recv() { + let snapshot = snapshot.materialize(); + let result = storage::save_with_quota(&save_root, &snapshot, keep, quota); + if let Err(e) = &result { + save_metrics.save_errors.fetch_add(1, Ordering::Relaxed); + eprintln!( + "{}", + serde_json::json!({"event":"snapshot_failed","room":snapshot.id,"error":e}) + ); + } else { + save_metrics + .saved_tick + .store(snapshot.tick, Ordering::Relaxed); + } + if let Some(response) = response { + let _ = response.send(result); } } }); @@ -669,6 +780,15 @@ fn room_loop( if let Ok(command) = rx.recv_timeout(wait) { match command { Command::Stop => stopping = true, + Command::Checkpoint(response) => { + if let Err(e) = save_tx.try_send((sim.checkpoint(), Some(response))) { + let (mpsc::TrySendError::Full((_, response)) + | mpsc::TrySendError::Disconnected((_, response))) = e; + if let Some(response) = response { + let _ = response.send(Err("Snapshot writer is busy".into())); + } + } + } Command::Leave(id) => { players.remove(&id); if let Some(b) = &mut ballot { @@ -703,6 +823,7 @@ fn room_loop( lod: 0, known: HashMap::new(), last_proposal: None, + last_intervention: None, traffic: Traffic::new(), metrics: metrics.clone(), }; @@ -798,6 +919,32 @@ fn room_loop( }); } } + Some(client_message::Body::Intervene(command)) => { + if player + .last_intervention + .is_some_and(|at| at.elapsed() < Duration::from_secs(30)) + { + reply( + player, + error("COMMAND_LIMIT", "Wait 30 seconds between commands"), + ); + } else { + let paused = sim.clock().speed == 0; + let count = sim.world.entities().len() as usize; + let result = sim + .world + .resource_mut::() + .enqueue(&command.action, count, paused); + match result { + Ok(()) => { + player.last_intervention = Some(Instant::now()); + } + Err(e) => { + reply(player, error("COMMAND_LIMIT", e)); + } + } + } + } Some(client_message::Body::Vote(v)) => { if let Some(b) = &mut ballot { if Instant::now() < b.deadline @@ -886,6 +1033,14 @@ fn room_loop( } } if clock.tick % 10 == 0 { + if !reply( + player, + message(server_message::Body::Gameplay( + sim.world.resource::().0.clone(), + )), + ) { + return false; + } let b = ballot.as_ref(); if !reply( player, @@ -923,10 +1078,8 @@ fn room_loop( } if begin.elapsed() > Duration::from_millis(50) { eprintln!( - "room={} tick={} elapsed_ms={}", - sim.id, - clock.tick, - begin.elapsed().as_millis() + "{}", + serde_json::json!({"event":"slow_tick","room":sim.id,"tick":clock.tick,"elapsed_ms":begin.elapsed().as_millis()}) ); } next_tick += Duration::from_millis(100); @@ -934,7 +1087,7 @@ fn room_loop( next_tick = Instant::now() + Duration::from_millis(100); } if saved_at.elapsed() >= config.save_interval { - if let Err(error) = save_tx.try_send(sim.checkpoint()) { + if let Err(error) = save_tx.try_send((sim.checkpoint(), None)) { eprintln!("snapshot writer is busy or unavailable: {error}"); } saved_at = Instant::now(); @@ -954,7 +1107,7 @@ fn room_loop( .store(sim.world.entities().len() as u64, Ordering::Relaxed); } } - if save_tx.send(sim.checkpoint()).is_err() { + if save_tx.send((sim.checkpoint(), None)).is_err() { eprintln!("final snapshot writer is unavailable"); } drop(save_tx); diff --git a/server/src/lib.rs b/server/src/lib.rs index 5839c1f..b34a974 100644 --- a/server/src/lib.rs +++ b/server/src/lib.rs @@ -2,6 +2,7 @@ pub mod protocol { include!(concat!(env!("OUT_DIR"), "/city.rs")); } pub mod city; +pub mod gameplay; pub mod gateway; pub mod generation; pub mod navigation; diff --git a/server/src/main.rs b/server/src/main.rs index 057bec0..42f1885 100644 --- a/server/src/main.rs +++ b/server/src/main.rs @@ -28,6 +28,12 @@ async fn main() -> Result<(), Box> { if let Ok(value) = std::env::var("CITYGEN_KEEP_SNAPSHOTS") { config.keep_snapshots = value.parse()?; } + if let Ok(value) = std::env::var("CITYGEN_SAVE_QUOTA_BYTES") { + config.save_quota_bytes = value.parse()?; + } + config.admin_token = std::env::var("CITYGEN_ADMIN_TOKEN") + .ok() + .filter(|s| !s.is_empty()); if let Ok(value) = std::env::var("CITYGEN_MAX_GENERATION_KM2") { config.max_generation_km2 = value.parse()?; } @@ -49,17 +55,33 @@ async fn main() -> Result<(), Box> { let app = App::new(config).map_err(std::io::Error::other)?; let address = std::env::var("CITYGEN_BIND").unwrap_or("127.0.0.1:3000".into()); let listener = tokio::net::TcpListener::bind(&address).await?; - println!("Citygen: http://{address}"); + eprintln!( + "{}", + serde_json::json!({"event":"server_started","address":address}) + ); let shutdown_app = app.clone(); axum::serve( listener, gateway::router(app.clone()).into_make_service_with_connect_info::(), ) .with_graceful_shutdown(async move { - let _ = tokio::signal::ctrl_c().await; + shutdown_signal().await; let _ = tokio::task::spawn_blocking(move || shutdown_app.stop()).await; }) .await?; app.stop(); Ok(()) } + +async fn shutdown_signal() { + #[cfg(unix)] + { + let mut terminate = + tokio::signal::unix::signal(tokio::signal::unix::SignalKind::terminate()) + .expect("SIGTERM handler"); + tokio::select! { _ = tokio::signal::ctrl_c() => {}, _ = terminate.recv() => {} } + } + #[cfg(not(unix))] + let _ = tokio::signal::ctrl_c().await; + eprintln!("{}", serde_json::json!({"event":"server_stopping"})); +} diff --git a/server/src/simulation.rs b/server/src/simulation.rs index 5438c41..9df8e8d 100644 --- a/server/src/simulation.rs +++ b/server/src/simulation.rs @@ -225,6 +225,7 @@ impl Simulation { ..Default::default() }); world.insert_resource(PositionChanges::default()); + world.insert_resource(crate::gameplay::Game::new(count as usize, 7.9 * 3600.0)); world.spawn_batch((0..count).map(|i| { ( Resident { @@ -268,6 +269,12 @@ impl Simulation { clock.tick += 1; clock.seconds += clock.speed as f64 * 6.0; } + let seconds = self.clock().seconds; + self.world.resource_mut::().advance( + seconds, + self.population.len(), + self.seed, + ); self.schedule.run(&mut self.world); } pub fn clock(&self) -> Clock { @@ -387,7 +394,7 @@ impl Simulation { }) .collect(); let metadata = RoomSave { - version: 1, + version: 2, id: self.id.clone(), city_id: self.city_id.clone(), city_revision: self.city_revision.clone(), @@ -398,6 +405,7 @@ impl Simulation { speed: clock.speed, agents: vec![], routes, + gameplay: Some(self.world.resource::().0.clone()), }; Checkpoint { metadata, @@ -405,10 +413,13 @@ impl Simulation { } } pub fn restore(saved: RoomSave) -> Result { - if saved.version != 1 || saved.city_version != 1 { + if ![1, 2].contains(&saved.version) || saved.city_version != 1 { return Err("Incompatible room snapshot".into()); } - if !saved.game_seconds.is_finite() || ![0, 1, 2, 4].contains(&saved.speed) { + if !saved.game_seconds.is_finite() + || saved.game_seconds < 0.0 + || ![0, 1, 2, 4].contains(&saved.speed) + { return Err("Invalid room clock".into()); } let mut ids = std::collections::HashSet::new(); @@ -427,6 +438,14 @@ impl Simulation { paths.push(route.xy.chunks_exact(2).map(|p| [p[0], p[1]]).collect()); } let mut s = Self::new(saved.id, saved.city_id, saved.seed, 0, paths)?; + let gameplay = if saved.version == 1 { + crate::gameplay::Game::new(saved.agents.len(), saved.game_seconds) + } else { + let state = saved.gameplay.ok_or("Missing saved gameplay")?; + crate::gameplay::Game::validate(&state, saved.game_seconds, saved.agents.len())?; + crate::gameplay::Game(state) + }; + s.world.insert_resource(gameplay); s.goals( saved .routes @@ -545,4 +564,31 @@ mod tests { a.step(); assert_eq!(a.clock().seconds, seconds); } + #[test] + fn legacy_snapshot_migrates_and_pending_commands_survive_restart() { + let mut sim = + Simulation::new("r".into(), "c".into(), 7, 10, vec![vec![[0, 0], [100, 0]]]).unwrap(); + let mut legacy = sim.save(); + legacy.version = 1; + legacy.gameplay = None; + let mut migrated = Simulation::restore(legacy).unwrap(); + assert_eq!(migrated.save().version, 2); + migrated + .world + .resource_mut::() + .enqueue("supplies", 10, false) + .unwrap(); + let saved = migrated.save(); + let mut restored = Simulation::restore(saved.clone()).unwrap(); + assert_eq!(saved, restored.save()); + for _ in 0..100 { + migrated.step(); + restored.step(); + } + assert_eq!(migrated.save(), restored.save()); + assert!(restored.save().gameplay.unwrap().pending.is_empty()); + let mut invalid = restored.save(); + invalid.version = 99; + assert!(Simulation::restore(invalid).is_err()); + } } diff --git a/server/src/storage.rs b/server/src/storage.rs index e1e3f6a..560014a 100644 --- a/server/src/storage.rs +++ b/server/src/storage.rs @@ -7,11 +7,46 @@ use std::{ }; pub fn save(root: &Path, snapshot: &RoomSave, keep: usize) -> Result<(), String> { + save_with_quota(root, snapshot, keep, u64::MAX) +} +// Serialize quota checks and writes across room writer threads. Never evict the +// last snapshot of another room to make space for the current one. +static WRITES: std::sync::Mutex<()> = std::sync::Mutex::new(()); +pub fn disk_bytes(root: &Path) -> Result { + let mut bytes = 0u64; + for entry in fs::read_dir(root).map_err(|e| e.to_string())? { + let entry = entry.map_err(|e| e.to_string())?; + let kind = entry.file_type().map_err(|e| e.to_string())?; + if kind.is_symlink() { + continue; + } + bytes = bytes.saturating_add(if kind.is_dir() { + disk_bytes(&entry.path())? + } else { + entry.metadata().map_err(|e| e.to_string())?.len() + }); + } + Ok(bytes) +} +pub fn save_with_quota( + root: &Path, + snapshot: &RoomSave, + keep: usize, + quota: u64, +) -> Result<(), String> { + let _guard = WRITES.lock().map_err(|_| "Snapshot lock poisoned")?; if !safe_id(&snapshot.id) { return Err("Invalid room ID".into()); } let folder = root.join(&snapshot.id); fs::create_dir_all(&folder).map_err(|e| e.to_string())?; + let bytes = snapshot.encode_to_vec(); + if bytes.len() > 128 * 1024 * 1024 { + return Err("Snapshot exceeds 128 MiB".into()); + } + if disk_bytes(root)?.saturating_add(bytes.len() as u64) > quota { + return Err("Snapshot disk quota exceeded; previous snapshots preserved".into()); + } let name = format!("{:020}.pb", snapshot.tick); let file = folder.join(&name); // Replace through a complete temporary file, including control changes that @@ -19,9 +54,7 @@ pub fn save(root: &Path, snapshot: &RoomSave, keep: usize) -> Result<(), String> { let temporary = folder.join(format!("{name}.tmp")); let mut output = fs::File::create(&temporary).map_err(|e| e.to_string())?; - output - .write_all(&snapshot.encode_to_vec()) - .map_err(|e| e.to_string())?; + output.write_all(&bytes).map_err(|e| e.to_string())?; output.sync_all().map_err(|e| e.to_string())?; drop(output); fs::rename(temporary, file).map_err(|e| e.to_string())?; @@ -51,12 +84,15 @@ pub fn load(root: &Path, id: &str) -> Result { files.reverse(); // Try an older intact file if the latest is damaged. for file in files { + if fs::metadata(&file).map_or(true, |m| m.len() > 128 * 1024 * 1024) { + continue; + } if let Ok(bytes) = fs::read(file) { if let Ok(snapshot) = RoomSave::decode(&bytes[..]) { if snapshot.id != id { continue; } - if snapshot.version != 1 || snapshot.city_version != 1 { + if ![1, 2].contains(&snapshot.version) || snapshot.city_version != 1 { return Err("Incompatible room snapshot".into()); } return Ok(snapshot); @@ -91,4 +127,20 @@ mod tests { assert_eq!(load(dir.path(), "r").unwrap().tick, 3); assert!(load(dir.path(), "../secret").is_err()); } + #[test] + fn quota_preserves_committed_snapshot() { + let dir = tempfile::tempdir().unwrap(); + let mut snapshot = RoomSave { + version: 2, + city_version: 1, + id: "r".into(), + ..Default::default() + }; + save(dir.path(), &snapshot, 3).unwrap(); + let size = disk_bytes(dir.path()).unwrap(); + snapshot.tick = 1; + assert!(save_with_quota(dir.path(), &snapshot, 3, size).is_err()); + assert_eq!(load(dir.path(), "r").unwrap().tick, 0); + assert_eq!(disk_bytes(dir.path()).unwrap(), size); + } } diff --git a/server/tests/websocket.rs b/server/tests/websocket.rs index eb9069b..8c0690e 100644 --- a/server/tests/websocket.rs +++ b/server/tests/websocket.rs @@ -31,6 +31,19 @@ async fn read( } } } +async fn http_request( + address: std::net::SocketAddr, + path: &str, + method: &str, + token: &str, +) -> String { + use tokio::io::{AsyncReadExt, AsyncWriteExt}; + let mut socket = tokio::net::TcpStream::connect(address).await.unwrap(); + socket.write_all(format!("{method} {path} HTTP/1.1\r\nHost: localhost\r\nAuthorization: Bearer {token}\r\nContent-Length: 0\r\nConnection: close\r\n\r\n").as_bytes()).await.unwrap(); + let mut response = String::new(); + socket.read_to_string(&mut response).await.unwrap(); + response +} #[tokio::test] async fn thirty_observers_snapshot_delta_vote_and_restart() { let dir = tempfile::tempdir().unwrap(); @@ -38,6 +51,7 @@ async fn thirty_observers_snapshot_delta_vote_and_restart() { let app = App::new(Config { cities: dir.path().join("cities"), saves: dir.path().join("rooms"), + admin_token: Some("test-only-administrator-token-32-chars".into()), ..Default::default() }) .unwrap(); @@ -63,6 +77,26 @@ async fn thirty_observers_snapshot_delta_vote_and_restart() { let value: serde_json::Value = serde_json::from_str(response.split("\r\n\r\n").nth(1).unwrap()).unwrap(); let id = value["id"].as_str().unwrap().to_string(); + assert!(http_request(address, "/api/admin", "GET", "wrong") + .await + .starts_with("HTTP/1.1 401")); + assert!(http_request( + address, + "/api/admin", + "GET", + "test-only-administrator-token-32-chars" + ) + .await + .starts_with("HTTP/1.1 200")); + let checkpoint = http_request( + address, + &format!("/api/admin/rooms/{id}/checkpoint"), + "POST", + "test-only-administrator-token-32-chars", + ) + .await; + assert!(checkpoint.starts_with("HTTP/1.1 200"), "{checkpoint}"); + assert!(citygen_server::storage::load(&dir.path().join("rooms"), &id).is_ok()); let mut sockets = vec![]; for i in 0..30 { let (mut socket, _) = @@ -117,6 +151,37 @@ async fn thirty_observers_snapshot_delta_vote_and_restart() { } } // 31st observer must be rejected without affecting existing players. + let command = p::ClientMessage { + body: Some(client_message::Body::Intervene(p::Intervene { + action: "meal".into(), + })), + } + .encode_to_vec(); + s.send(tokio_tungstenite::tungstenite::Message::Binary( + command.clone().into(), + )) + .await + .unwrap(); + s.send(tokio_tungstenite::tungstenite::Message::Binary( + command.into(), + )) + .await + .unwrap(); + loop { + if let Some(server_message::Body::Error(error)) = read(s).await.body { + assert_eq!(error.code, "COMMAND_LIMIT"); + break; + } + } + loop { + if let Some(server_message::Body::Gameplay(state)) = read(s).await.body { + assert!( + state.pending.iter().any(|p| p == "meal") + || state.events.iter().any(|e| e.kind == "meal") + ); + break; + } + } let (mut extra, _) = tokio_tungstenite::connect_async(format!("ws://{address}/api/rooms/{id}/ws")) .await @@ -232,6 +297,14 @@ async fn thirty_observers_snapshot_delta_vote_and_restart() { )) .await .unwrap(); + assert!(http_request( + address, + "/api/admin", + "GET", + "test-only-administrator-token-32-chars" + ) + .await + .starts_with("HTTP/1.1 404")); assert!( matches!(read(&mut socket).await.body,Some(server_message::Body::Welcome(w)) if w.tick>=saved.tick) ); diff --git a/src/main.ts b/src/main.ts index 3a4d4cc..473d6f9 100644 --- a/src/main.ts +++ b/src/main.ts @@ -7,6 +7,7 @@ import type { World } from './types'; import { TileLoader } from '../client/tiles'; import type { Bounds } from './city/format'; import { RoomConnection } from '../client/connection'; +import { showAdmin } from '../client/admin'; import { create, fromBinary, toBinary } from '@bufbuild/protobuf'; import { CityJobSchema, CreateCitySchema } from '../client/generated/city_pb'; @@ -325,6 +326,14 @@ async function showTiledCity(url: string, connection?: RoomConnection) { } const vote = document.createElement('span'); vote.className = 'room-vote'; vote.setAttribute('role','status'); controls.appendChild(vote); tiledViewer.root.querySelector('.viewer-top')!.appendChild(controls); + const gameplay = document.createElement('div'); gameplay.className = 'row'; + const state = document.createElement('span'); state.className = 'room-gameplay'; state.setAttribute('role', 'status'); gameplay.appendChild(state); + for (const [action, label] of [['supplies', 'Запасы · 2¤/жит.'], ['meal', 'Обед · 1¤/жит.'], ['rest', 'Отдых · 3¤/жит.']]) { + const button = document.createElement('button'); button.className = 'btn'; button.dataset.action = action; button.textContent = label; + button.title = 'Общая казна. Одна команда на игровой час; исполнение в следующую игровую минуту.'; + button.onclick = () => connection.intervene(action); gameplay.appendChild(button); + } + tiledViewer.root.querySelector('.viewer-top')!.appendChild(gameplay); } (window as any).viewer = viewer; hideProgress(); @@ -361,6 +370,13 @@ async function showLobby() { status: text => { status.textContent = text; viewer?.setLoadStatus(text); }, clock: c => { const clock = app.querySelector('.room-clock'); if (clock) clock.textContent = `День ${Math.floor(c.gameSeconds / 86400) + 1} · ${String(Math.floor(c.gameSeconds/3600)%24).padStart(2,'0')}:${String(Math.floor(c.gameSeconds/60)%60).padStart(2,'0')} · ×${c.speed}`; }, vote: v => { const vote = app.querySelector('.room-vote'); if (vote) vote.textContent = v.active ? `Голосование за ×${v.speed}: ${v.yes}/${v.players}, ${v.remainingSeconds} с` : `${v.players} игроков`; }, + gameplay: g => { + const state = app.querySelector('.room-gameplay'); + const names: Record = { harvest: 'Урожай', illness: 'Болезнь', rain: 'Дождь', supplies: 'Запасы пополнены', meal: 'Общий обед', rest: 'Отдых' }; + const event = g.events.at(-1); + if (state) state.textContent = `Казна ${g.treasury}¤ · Еда ${g.food} · Голод ${g.needs?.hunger ?? 0}% · Усталость ${g.needs?.fatigue ?? 0}% · Настроение ${g.needs?.morale ?? 0}%${g.pending.length ? ' · Команда в очереди' : ''}${event ? ` · ${names[event.kind] ?? event.kind}` : ''}`; + for (const button of app.querySelectorAll('[data-action]')) button.disabled = g.pending.length > 0 || g.minute < g.nextInterventionMinute; + }, }); roomConnection = connection; }; @@ -394,6 +410,7 @@ async function showLobby() { (async () => { const params = new URLSearchParams(location.search); + if (params.has('admin')) return showAdmin(app); if (params.has('play')) return showLobby(); if (params.has('city')) return showTiledCity(params.get('city')!); if (params.has('last') && (await hasWorld())) {