UDPServer.h

// Copyright QED Software 2023.
 
#ifndef GRAIL_UDPSERVER_H
#define GRAIL_UDPSERVER_H
 
#include "../libs/poco/Net/include/Poco/Net/DatagramSocket.h"
#include "../libs/poco/Net/include/Poco/Net/HostEntry.h"
#include "../libs/poco/Net/include/Poco/Net/SocketAddress.h"
 
#include <cstddef>
#include <map>
#include <memory>
#include <string>
#include <thread>
#include <mutex>
 
namespace grail
{
namespace live
{
    class UDPServer
    {
    public:
        UDPServer(const std::string& appName,
                  unsigned int serverPort,
                  unsigned long bufferSize = 1024,
                  bool sendFakeNames = false);
        ~UDPServer();
        
        void Start();
        void Stop();
 
    private:
        void UDPChecker();
        void RebuildInterfaces();
        void CheckUDP();
        void StartReceive(const Poco::Net::IPAddress& ipHost);
 
        constexpr static std::size_t ITERATIONS_BETWEEN_REBUILD{500};
        constexpr static Poco::UInt16 UDP_LISTENER_PORT{6661};
        const static std::string SEARCH_COMMAND;
 
        const std::string appName{""};
        const unsigned int serverPort{0};
        const bool sendFakeNames{false};
        std::string hostName{""};
 
        std::unique_ptr<std::thread> udpCheckerThread{nullptr};
 
        std::vector<Poco::Net::IPAddress> interfaces{};
        Poco::Net::HostEntry localHostEntry{};
 
        Poco::Net::SocketAddress anyAddress{};
 
        std::atomic<bool> isWorking{false};
 
        std::map<std::string, Poco::Net::DatagramSocket> sockets{};
        char* buffer{nullptr};
        unsigned long bufferSize;
        std::mutex stateChangeMutex{};
    };
}
}
 
#endif // GRAIL_UDPSERVER_H