ReceiveSystem.hpp

/*
** EPITECH PROJECT, 2022
** B-CPP-500-PAR-5-1-rtype-martin.vanaud
** File description:
** ReceiveSytem
*/
 
#ifndef RECEIVESYSTEM_HPP_
    #define RECEIVESYSTEM_HPP_
 
    #include <functional>
    #include <unordered_map>
 
    /* Ecs */
    #include "Registry.hpp"
 
    /* Serialization */
    #include "Serialization.hpp"
 
    /* Component */
    #include "Component/CNetworkQueue.hpp"
 
namespace System {
    class ReceiveSystem {
        public:
            ReceiveSystem();
            ~ReceiveSystem() = default;
 
            void operator()(
                Registry &registry,
                Sparse_array<component::cnetwork_queue_t> &queues
            );
 
        protected:
        private:
            void addMoveOnQueue(std::vector<byte> const &data, int clientId, Sparse_array<component::cnetwork_queue_t> &queues);
 
            void addShootOnQueue(std::vector<byte> const &data, int clientId, Sparse_array<component::cnetwork_queue_t> &queues);
 
            void addNewPLayerOnQueue(std::vector<byte> const &data, int clientId, Sparse_array<component::cnetwork_queue_t> &queues);
 
            void addDisconnectionOnQueue(std::vector<byte> const &data, int clientId, Sparse_array<component::cnetwork_queue_t> &queues);
 
            void addJoinLobbyOnQueue(std::vector<byte> const &data, int clientId, Sparse_array<component::cnetwork_queue_t> &queues);
 
            void addStartGameOnQueue(std::vector<byte> const &data, int clientId, Sparse_array<component::cnetwork_queue_t> &queues);
 
            std::unordered_map<uint8_t, std::function<void(std::vector<byte> const &, int, Sparse_array<component::cnetwork_queue_t> &)>> callBacks {
                {NETWORK_CLIENT_TO_SERVER::PACKET_TYPE::NEW_CLIENT, std::bind(&ReceiveSystem::addNewPLayerOnQueue, this, std::placeholders::_1, std::placeholders::_2, std::placeholders::_3)},
                {NETWORK_CLIENT_TO_SERVER::PACKET_TYPE::DIRECTION, std::bind(&ReceiveSystem::addMoveOnQueue, this, std::placeholders::_1, std::placeholders::_2, std::placeholders::_3)},
                {NETWORK_CLIENT_TO_SERVER::PACKET_TYPE::SHOOT, std::bind(&ReceiveSystem::addShootOnQueue, this, std::placeholders::_1, std::placeholders::_2, std::placeholders::_3)},
                {NETWORK_CLIENT_TO_SERVER::PACKET_TYPE::DISCONNECTION, std::bind(&ReceiveSystem::addDisconnectionOnQueue, this, std::placeholders::_1, std::placeholders::_2, std::placeholders::_3)},
                {NETWORK_CLIENT_TO_SERVER::PACKET_TYPE::JOIN_LOBBY, std::bind(&ReceiveSystem::addJoinLobbyOnQueue, this, std::placeholders::_1, std::placeholders::_2, std::placeholders::_3)},
                {NETWORK_CLIENT_TO_SERVER::PACKET_TYPE::START_GAME, std::bind(&ReceiveSystem::addStartGameOnQueue, this, std::placeholders::_1, std::placeholders::_2, std::placeholders::_3)}
            }; 
    };
};
 
#endif /* !RECEIVESYSTEM_HPP_ */