LiveDebuggerServer.h

#ifndef GRAIL_LIVE_DEBUGGER_SERVER
#define GRAIL_LIVE_DEBUGGER_SERVER
 
#include "../GrailCore/DebugUtilities/IDebugSnapshotReceiver.h"
#include "../GrailYamlConverters/YamlConvertersDebug.h"
 
#include "TCPServer.h"
#include "UDPServer.h"
 
namespace grail
{
    class LiveDebuggerServer : public IDebugSnapshotReceiver
    {
    public:
        LiveDebuggerServer(const std::string& serverName);
        ~LiveDebuggerServer() override = default;
 
        // IDebugSnapshotReceiver interface
        void ProcessSnapshot(GrailStateSnapshot& stateSnapshot) override;
        void ProcessSnapshot(UtilityReasonerSnapshot& utilitySnapshot) override;
        void ProcessSnapshot(PlannerReasonerSnapshot& plannerSnapshot) override;
        void ProcessSnapshot(SimulatedGameReasonerSnapshot& simulatedGamesSnapshot) override;
 
    private:
        template <typename SnapshotType>
        void SendSnapshots(SnapshotType snapshot)
        {
            if(tcpServer.IsAnyConnected())
            {
                std::string serializedSnapshot = c4::yml::writeToString(snapshot);
                tcpServer.SendToAll(serializedSnapshot);
            }
        }
 
        const Poco::UInt16 PORT_NUMBER = 6000;
        TCPServer tcpServer;
        UDPServer udpServer;
    };
}
 
#endif