ACommunication.hpp

Go to the documentation of this file.

/*
** EPITECH PROJECT, 2023
** Communication.hpp
** File description:
** Communication
*/
 
#ifndef COMMUNICATION_HPP_
#define COMMUNICATION_HPP_
 
#include "../../include/RType.hpp"
#include <any>
#include <asio.hpp>
#include <iostream>
#include "../../include/Protocol.hpp"
 
namespace GameEngine::Network
{
    class ACommunication
    {
      public:
        ACommunication(asio::io_context &IOContext, unsigned short port);
        // ACommunication(asio::io_context &IOContext, unsigned short port);
        virtual ~ACommunication(){};
        template <typename Socket, typename Endpoint>
        void sendData(void *data, std::size_t size, uint8_t packetType, Socket &socket, Endpoint &endpoint)
        {
            struct RType::Protocol::HeaderDataPacket header = {};
 
            header.packetType = packetType;
            header.payloadSize = size;
            this->sendInformation(data, size, socket, endpoint, header);
        };
        void sendInformation(void *data, std::size_t size, asio::ip::udp::socket &socket,
            asio::ip::udp::endpoint &endpoint, struct RType::Protocol::HeaderDataPacket &header);
        void sendInformation(void *data, std::size_t size, asio::ip::tcp::socket &socket, asio::ip::tcp::endpoint &,
            struct RType::Protocol::HeaderDataPacket &header);
        void handleReceive(
            const asio::error_code &error, std::size_t recvBytes, struct RType::Protocol::HeaderDataPacket &header);
        void readHeader();
 
      protected:
        virtual void handleData(struct RType::Protocol::HeaderDataPacket &, unsigned short port) = 0;
 
      protected:
        asio::streambuf _streamBuffer;
        asio::ip::udp::socket _udpSocket;
        asio::streambuf::mutable_buffers_type _buffer;
        struct RType::Protocol::HeaderDataPacket _header;
        asio::ip::udp::endpoint _endpoint;
        std::map<unsigned short, asio::ip::udp::endpoint> _listClient;
 
      private:
    };
 
}; // namespace GameEngine::Network
 
#endif /* !COMMUNICATION_HPP_ */