openmw-tes3mp/components/openmw-mp/Packets/BasePacket.hpp

//
// Created by koncord on 05.01.16.
//

#ifndef OPENMW_BASEPACKET_HPP
#define OPENMW_BASEPACKET_HPP

#include <string>
#include <RakNetTypes.h>
#include <BitStream.h>
#include <PacketPriority.h>
#include <components/openmw-mp/Base/BasePlayer.hpp>


namespace mwmp
{
    class BasePacket
    {
    public:
        BasePacket(RakNet::RakPeerInterface *peer);

        ~BasePacket();

        virtual void Packet(RakNet::BitStream *bs, BasePlayer *player, bool send);

        virtual void Send(BasePlayer *player, bool toOtherPlayers = true);
        virtual void Send(BasePlayer *player, RakNet::AddressOrGUID destination);
        virtual void Read(BasePlayer *player);

        virtual void RequestData(RakNet::RakNetGUID player);

        void SetReadStream(RakNet::BitStream *bitStream);
        void SetSendStream(RakNet::BitStream *bitStream);
        void SetStreams(RakNet::BitStream *inStream, RakNet::BitStream *outStream);

        size_t headerSize()
        {
            return 10; // 10 == char + char + RakNetGUID (uint64_t)
        }

    protected:
        template<class templateType>
        void RW(templateType &data, unsigned int size, bool write)
        {
            if (write)
                bs->Write(data, size);
            else
                bs->Read(data, size);
        }

        template<class templateType>
        void RW(templateType &data, bool write)
        {
            if (write)
                bs->Write(data);
            else
                bs->Read(data);
        }

        void RW(bool &data, bool write)
        {
            char _data;
            if (write)
            {
                _data = data;
                bs->Write(_data);
            }
            else
            {
                bs->Read(_data);
                data = _data;
            }
        }


        void RW(std::string &str, bool write)
        {
            if (write)
            {
                RakNet::RakString rstr(str.c_str());
                bs->Write(rstr);
            }
            else
            {
                RakNet::RakString rstr;
                bs->Read(rstr);
                str = rstr.C_String();
            }
        }

    protected:
        BasePlayer *player;
        unsigned char packetID;
        PacketReliability reliability;
        PacketPriority priority;

    private:
        RakNet::BitStream *bsRead, *bsSend, *bs;
        RakNet::RakPeerInterface *peer;

    };
}

#endif //OPENMW_BASEPACKET_HPP