sapphire/src/servers/Server_Zone/Network/GameConnection.h

#ifndef GAMECONNECTION_H
#define GAMECONNECTION_H

#include <src/servers/Server_Common/Network/Connection.h>
#include <src/servers/Server_Common/Network/Acceptor.h>
#include <src/servers/Server_Common/Network/CommonNetwork.h>

#include <src/servers/Server_Common/Network/GamePacket.h>

#include <src/servers/Server_Common/Util/LockedQueue.h>

#include "src/servers/Server_Zone/Forwards.h"

#define DECLARE_HANDLER( x ) void x( const Packets::GamePacket& inPacket, Entity::PlayerPtr pPlayer )

namespace Core {
namespace Network {

enum struct ConnectionType : uint8_t
{
   Zone,
   Chat,
   None
};

class GameConnection : public Connection
{

private:
   typedef void ( GameConnection::* Handler )( const Packets::GamePacket& inPacket, Entity::PlayerPtr pPlayer );

   typedef std::map< uint16_t, Handler > HandlerMap;
   typedef std::map< uint16_t, std::string > HandlerStrMap;

   AcceptorPtr m_pAcceptor;

   // handler for game packets (main type 0x03)
   HandlerMap m_packetHandlerMap;
   HandlerStrMap m_packetHandlerStrMap;

   SessionPtr m_pSession;

   LockedQueue< Packets::GamePacketPtr > m_inQueue;
   LockedQueue< Packets::GamePacketPtr > m_outQueue;

public:
   ConnectionType m_conType;

   GameConnection( HivePtr pHive, AcceptorPtr pAcceptor );

   ~GameConnection();

   // overwrite the parents onConnect for our game socket needs
   void OnAccept( const std::string & host, uint16_t port ) override;

   void OnDisconnect() override;

   void OnRecv( std::vector< uint8_t > & buffer ) override;

   void OnError( const boost::system::error_code & error ) override;

   void handlePackets( const Packets::FFXIVARR_PACKET_HEADER& ipcHeader,
                       const std::vector<Packets::FFXIVARR_PACKET_RAW>& packetData );

   void queueInPacket( Packets::GamePacketPtr inPacket );
   void queueOutPacket( Packets::GamePacketPtr outPacket );

   void processInQueue();
   void processOutQueue();

   void handleGamePacket( Packets::GamePacketPtr pPacket );

   void sendPackets( Packets::PacketContainer * pPacket );

   void sendSinglePacket( Packets::GamePacket * pPacket );

   void injectPacket( const std::string& packetpath, Entity::PlayerPtr pPlayer );

   DECLARE_HANDLER( initHandler );
   DECLARE_HANDLER( finishLoadingHandler );
   DECLARE_HANDLER( blackListHandler );
   DECLARE_HANDLER( socialListHandler );
   DECLARE_HANDLER( linkshellListHandler );
   DECLARE_HANDLER( playTimeHandler );
   DECLARE_HANDLER( pingHandler );
   DECLARE_HANDLER( fcInfoReqHandler );
   DECLARE_HANDLER( setSearchInfoHandler );
   DECLARE_HANDLER( reqSearchInfoHandler );
   DECLARE_HANDLER( updatePositionHandler );
   DECLARE_HANDLER( chatHandler );
   DECLARE_HANDLER( zoneLineHandler );
   DECLARE_HANDLER( actionHandler );
   DECLARE_HANDLER( inventoryModifyHandler );
   DECLARE_HANDLER( discoveryHandler );
   DECLARE_HANDLER( eventHandler );
   DECLARE_HANDLER( logoutHandler );
   
   DECLARE_HANDLER( cfDutyInfoRequest );
   DECLARE_HANDLER( cfRegisterDuty );
   DECLARE_HANDLER( cfRegisterRoulette );
   DECLARE_HANDLER( cfDutyAccepted );


   DECLARE_HANDLER( skillHandler );

   DECLARE_HANDLER( gm1Handler );
   DECLARE_HANDLER( gm2Handler );



};



}
}


#endif