CommandDispatcher.hpp

Go to the documentation of this file.

#pragma once
 
#include <chrono>
#include <deque>
#include <optional>
#include <string>
#include <unordered_map>
#include <vector>
 
#include "core/GameClock.hpp"
#include "core/Scheduler.hpp"
#include "core/World.hpp"
#include "game/GuiNotifier.hpp"
#include "game/HandshakeHandler.hpp"
#include "network/ClientManager.hpp"
#include "protocol/AiParser.hpp"
 
class CommandDispatcher {
    public:
    CommandDispatcher(ClientManager& clients, World& world, GuiNotifier& notifier,
                      const ServerConfig& config, Scheduler& scheduler);
 
    void onNewConnection(int connectionId);
    void dispatch(int connectionId, const std::string& line);
    void onDisconnect(int connectionId);
    std::vector<int> drainPendingDisconnects();
 
    std::chrono::microseconds gameElapsed() const;
    double gameTicks() const;
    std::optional<GameClock::Stamp> teamJoin(const std::string& team) const;
 
    private:
    void _dispatchAi(int connectionId, const std::string& line);
    void _dispatchGui(int connectionId, const std::string& line);
    void _executeNext(int connectionId);
 
    void _onAiJoined(int connectionId, int playerId);
    void _startStarvationTimer(int connectionId, int playerId);
 
    static constexpr int STARVATION_INTERVAL_MS = 126000;
 
    // GUI command handlers
    void _handleMsz(int connectionId);
    void _handleBct(int connectionId, int x, int y);
    void _handleMct(int connectionId);
    void _handleTna(int connectionId);
    void _handlePpo(int connectionId, int playerId);
    void _handlePlv(int connectionId, int playerId);
    void _handlePin(int connectionId, int playerId);
    void _handleSgt(int connectionId);
    void _handleSst(int freq);
    void _handleStu(int connectionId);
 
    // AI command handlers
    void _handleForward(int connectionId);
    void _handleRight(int connectionId);
    void _handleLeft(int connectionId);
    void _handleLook(int connectionId);
    void _handleInventory(int connectionId);
    void _handleBroadcast(int connectionId, const std::string& msg);
    void _handleFork(int connectionId);
    void _handleEject(int connectionId);
    void _handleTake(int connectionId, ResourceType resource);
    void _handleSet(int connectionId, ResourceType resource);
    void _handleIncantation(int connectionId);
    void _handleConnectNbr(int connectionId);
 
    ClientManager& _clients;
    World& _world;
    GuiNotifier& _notifier;
    Scheduler& _scheduler;
    const ServerConfig& _config;
    GameClock _clock;
    HandshakeHandler _handshakeHandler;
 
    std::unordered_map<int, std::deque<Ai::Command>> _queues;
    std::unordered_map<int, bool> _hasActive;
    std::vector<int> _pendingDisconnects;
};