Deterministic, authoritative server game logic. More...

#include <GameLogic.hpp>

Inheritance diagram for server::GameLogic:

Collaboration diagram for server::GameLogic:

Classes
struct	PlayerInput

Public Member Functions
	GameLogic (std::shared_ptr< ecs::wrapper::ECSWorld > world=nullptr, std::shared_ptr< ThreadPool > threadPool=nullptr, std::shared_ptr< EventBus > eventBus=nullptr)
	Constructor.

	~GameLogic () override

bool	initialize () override
	Initialize game logic and ECS systems.

void	update (float deltaTime, uint32_t currentTick) override
	Update game state for one frame.

uint32_t	spawnPlayer (uint32_t playerId, const std::string &playerName) override
	Spawn a player entity.

void	despawnPlayer (uint32_t playerId) override
	Remove a player from the game.

void	processPlayerInput (uint32_t playerId, int inputX, int inputY, bool isShooting, uint32_t sequenceId) override
	Process player input event.

uint32_t	getLastProcessedInput (uint32_t playerId) const override
	Get the last processed input sequence ID for a player.

ecs::Registry &	getRegistry () override
	Get reference to the ECS registry.

bool	isGameActive () const override
	Check if the game is active.

void	resetGame () override
	Reset game state (new game)

void	onGameStart ()
	Notify Lua scripts that the game has started.

std::shared_ptr< ecs::wrapper::ECSWorld >	getECSWorld ()
	Get the ECS world instance.

std::shared_ptr< GameStateManager >	getStateManager ()
	Get the game state manager.

GameRules &	getGameRules ()
	Get the game rules.

const GameRules &	getGameRules () const override
	Get the game rules (const version)

bool	loadMap (const std::string &mapFilePath)
	Load and activate a new map from a JSON file.

Public Member Functions inherited from server::IGameLogic
virtual	~IGameLogic ()=default

Private Member Functions
void	_executeSystems (float deltaTime)
	Execute all systems in order.

void	_processInput ()
	Process accumulated player input.

void	_cleanupDeadEntities ()
	Clean up dead entities.

void	_checkGameOverCondition ()
	Check if all players are dead and trigger game over.

void	_applyPlayerInput (uint32_t playerId, const PlayerInput &input)
	Apply a single input snapshot to a player entity.

Private Attributes
std::shared_ptr< ecs::wrapper::ECSWorld >	_world

std::unique_ptr< scripting::LuaEngine >	_luaEngine

std::unordered_map< uint32_t, ecs::Address >	_playerMap

std::unordered_map< uint32_t, std::deque< PlayerInput > >	_pendingInput

std::unordered_map< uint32_t, uint32_t >	_lastReceivedSequenceId

std::unordered_map< uint32_t, uint32_t >	_lastAppliedSequenceId

std::shared_ptr< GameStateManager >	_stateManager

std::shared_ptr< ThreadPool >	_threadPool

std::shared_ptr< EventBus >	_eventBus

bool	_gameActive {false}

bool	_hadPlayers {false}

std::atomic< bool >	_initialized {false}

std::mutex	_inputMutex

std::mutex	_playerMutex

GameRules	_gameRules

Static Private Attributes
static constexpr float	FIXED_TIMESTEP = 1.0f / 60.0f

Detailed Description

Deterministic, authoritative server game logic.

Coordinates all ECS systems in a strict order:

Input processing
Movement system
Collision detection
Health/damage system
Spawning system
AI system
Projectile system
Boundary system
State serialization

Features:

Fixed timestep (60 Hz / 1/60s per frame)
Deterministic updates (same input = same output)
Multi-threaded safe (internal synchronization)
Player entity management
Game state snapshots
Uses World abstraction layer for entity management

Definition at line 57 of file GameLogic.hpp.

Constructor & Destructor Documentation

◆ GameLogic()

server::GameLogic::GameLogic	(	std::shared_ptr< ecs::wrapper::ECSWorld >	world = `nullptr`,
		std::shared_ptr< ThreadPool >	threadPool = `nullptr`,
		std::shared_ptr< EventBus >	eventBus = `nullptr`
	)

explicit

Constructor.

Parameters

world	Optional ECSWorld instance (creates one if not provided)
threadPool	Optional ThreadPool for parallel system execution
eventBus	Optional EventBus for publishing game events

Definition at line 54 of file GameLogic.cpp.

References _eventBus, _luaEngine, _threadPool, _world, LOG_DEBUG, and LOG_INFO.

◆ ~GameLogic()

server::GameLogic::~GameLogic ( )

overridedefault

Member Function Documentation

◆ _applyPlayerInput()

void server::GameLogic::_applyPlayerInput	(	uint32_t	playerId,
		const PlayerInput &	input
	)

private

Apply a single input snapshot to a player entity.

Parameters

playerId	Player ID
input	Input snapshot to apply

Definition at line 300 of file GameLogic.cpp.

References _lastAppliedSequenceId, _playerMap, _world, FIXED_TIMESTEP, ecs::wrapper::Entity::get(), ecs::Animation::getCurrentClipName(), ecs::Velocity::getSpeed(), ecs::wrapper::Entity::has(), server::GameLogic::PlayerInput::inputX, server::GameLogic::PlayerInput::inputY, server::GameLogic::PlayerInput::isShooting, LOG_ERROR, LOG_WARNING, server::GameLogic::PlayerInput::sequenceId, ecs::Animation::setCurrentClipName(), ecs::Animation::setCurrentFrameIndex(), ecs::Velocity::setDirection(), ecs::Weapon::setShouldShoot(), and ecs::Animation::setTimer().

Referenced by _processInput().

Here is the call graph for this function:

◆ _checkGameOverCondition()

void server::GameLogic::_checkGameOverCondition ( )

private

Check if all players are dead and trigger game over.

Definition at line 484 of file GameLogic.cpp.

References _eventBus, _gameActive, _hadPlayers, _playerMap, _playerMutex, _stateManager, _world, ecs::wrapper::Entity::get(), ecs::Health::getCurrentHealth(), ecs::wrapper::Entity::has(), ecs::Spawner::isActive, and LOG_INFO.

Referenced by update().

Here is the call graph for this function:

◆ _cleanupDeadEntities()

void server::GameLogic::_cleanupDeadEntities ( )

private

Clean up dead entities.

Definition at line 459 of file GameLogic.cpp.

References _playerMap, _playerMutex, _world, and LOG_INFO.

Referenced by update().

◆ _executeSystems()

void server::GameLogic::_executeSystems ( float deltaTime )

private

Execute all systems in order.

Parameters

deltaTime Frame delta time

Definition at line 402 of file GameLogic.cpp.

References _threadPool, and _world.

Referenced by update().

◆ _processInput()

void server::GameLogic::_processInput ( )

private

Process accumulated player input.

Definition at line 272 of file GameLogic.cpp.

References _applyPlayerInput(), _inputMutex, and _pendingInput.

Referenced by update().

Here is the call graph for this function:

◆ despawnPlayer()

void server::GameLogic::despawnPlayer ( uint32_t playerId )

overridevirtual

Remove a player from the game.

Parameters

playerId Player ID to remove

Implements server::IGameLogic.

Definition at line 227 of file GameLogic.cpp.

References _playerMap, _playerMutex, _world, LOG_ERROR, LOG_INFO, LOG_WARNING, and ecs::Manual.

◆ getECSWorld()

std::shared_ptr< ecs::wrapper::ECSWorld > server::GameLogic::getECSWorld ( )

inline

Get the ECS world instance.

Returns: Shared pointer to ECSWorld

Definition at line 97 of file GameLogic.hpp.

References _world.

◆ getGameRules() [1/2]

GameRules & server::GameLogic::getGameRules ( )

inline

Get the game rules.

Returns: Reference to game rules

Definition at line 109 of file GameLogic.hpp.

References _gameRules.

◆ getGameRules() [2/2]

const GameRules & server::GameLogic::getGameRules ( ) const

inlineoverridevirtual

Get the game rules (const version)

Returns: Const reference to game rules

Implements server::IGameLogic.

Definition at line 115 of file GameLogic.hpp.

References _gameRules.

◆ getLastProcessedInput()

uint32_t server::GameLogic::getLastProcessedInput ( uint32_t playerId ) const

inlineoverridevirtual

Get the last processed input sequence ID for a player.

Parameters

playerId Player ID

Returns: Sequence ID or 0 if none

Implements server::IGameLogic.

Definition at line 78 of file GameLogic.hpp.

References _inputMutex, and _lastAppliedSequenceId.

◆ getRegistry()

ecs::Registry & server::GameLogic::getRegistry ( )

inlineoverridevirtual

Get reference to the ECS registry.

Returns: Registry reference

Implements server::IGameLogic.

Definition at line 84 of file GameLogic.hpp.

References _world.

◆ getStateManager()

std::shared_ptr< GameStateManager > server::GameLogic::getStateManager ( )

inline

Get the game state manager.

Returns: Shared pointer to GameStateManager

Definition at line 103 of file GameLogic.hpp.

References _stateManager.

◆ initialize()

bool server::GameLogic::initialize ( )

overridevirtual

Initialize game logic and ECS systems.

Returns: true if successful

Implements server::IGameLogic.

Definition at line 87 of file GameLogic.cpp.

References _eventBus, _gameActive, _initialized, _luaEngine, _stateManager, _threadPool, _world, LOG_ERROR, and LOG_INFO.

◆ isGameActive()

bool server::GameLogic::isGameActive ( ) const

inlineoverridevirtual

Check if the game is active.

Returns: true if game is running

Implements server::IGameLogic.

Definition at line 85 of file GameLogic.hpp.

References _gameActive.

◆ loadMap()

bool server::GameLogic::loadMap ( const std::string & mapFilePath )

Load and activate a new map from a JSON file.

Parameters

mapFilePath Path to the map JSON file

Returns: True if map was loaded successfully

Definition at line 597 of file GameLogic.cpp.

References _luaEngine, _world, ecs::MapData::getDuration(), ecs::MapData::getMapId(), ecs::MapData::getName(), ecs::MapData::getScrollSpeed(), ecs::MapData::getSpawnScript(), map::MapLoader::loadFromFile(), LOG_ERROR, and LOG_INFO.

Referenced by onGameStart().

Here is the call graph for this function:

◆ onGameStart()

void server::GameLogic::onGameStart ( )

Notify Lua scripts that the game has started.

Parameters

roomId The ID of the room where the game started

Definition at line 588 of file GameLogic.cpp.

References loadMap(), and LOG_INFO.

Here is the call graph for this function:

◆ processPlayerInput()

void server::GameLogic::processPlayerInput	(	uint32_t	playerId,
		int	inputX,
		int	inputY,
		bool	isShooting,
		uint32_t	sequenceId
	)

overridevirtual

Process player input event.

Parameters

playerId	Player ID
inputX	Horizontal input (-1, 0, 1)
inputY	Vertical input (-1, 0, 1)
isShooting	Whether player is shooting
sequenceId	Input sequence ID (for redundancy handling)