mirror of
https://github.com/EQEmu/Server.git
synced 2025-12-11 16:51:29 +00:00
8f4f8368df
* First pass of player_event_loot_items * Second pass of player_event_loot_items * Third pass of player_event_loot_items * Example without RecordDetailEvent template * Cleanup the removal of the template * Fourth Pass Add retention for etl tables Rename tables/fields to etl nomenclature Combine database work to one atomic load * Reposition to reduce db tasks * Refactor etl processing for easier additions * Add merchant purchase event testing passed though appears that the event itself has a few bugs. Will fix them in another commit * Fix PlayerEventMerchantPurchase in client_packet.cpp * WIP - Handin * Handin Event added * Cleanup * All a rentention period of 0 days which deletes all current records. * Updates Cleanup and refactor a few items. * Cleanup and Formatting Cleanup and Formatting * Add etl for Playerevent::Trade PlayerEvent::Speech (new event to mirror functionality of qs_speech * Add etl for Playerevent::KilledNPC, KilledNamedNPC and KilledRaidNPC * Add etl for Playerevent::AA_purchase Add etl for Playerevent::AA_purchase * Cleanup before PR * Review comment updates. * Add world cli etl:settings to output a json on all player event details. * Add reserve for all etl_queues Correct a failed test case for improper next id for etl tables when table is first created. * Potential solution for a dedicated database connection for player events. * Simple thread for player_events. Likely there is a better way to do this. * Add zone to qs communications for recordplayerevents First pass of enabling zone to qs direct transport to allow for PlayerEvents to bypass world. * Cleanup a linux compile issue * Add augments to LOOT ITEM and DESTROY ITEM * Add augments to ITEMCREATION, FORAGESUCCESS, FISHSUCCESS, DESTROYITEM, LOOTITEM, DROPPEDITEM, TRADERPURCHASE, TRADERSELL, GUILDTRIBUTEDONATE and cleaned up the naming convention of augments * Formatting fixes * Swap out GetNextTableId * Statically load counter * Add counter.clear() since the counter is static * Upload optional QS conversion scripts * Remove all qs_tables and code referencing them * Update database.cpp * Simplify ProcessBatchQueue * Simplify PorcessBatchQueue * Simplify event truncation * Build event truncation to bulk query by retention groups * Post rebase * Update player_events.h * Fix build * Update npc.cpp * First pass of direct zone to qs sending for player events * Remove keepalive logic * Fix event ordering * Cleanup * Update player_event_logs.cpp * Wipe event data after ETL processed * Split up database connections, hot reload logs for QS * Load rules from database vs qs_database * Update player_event_logs.cpp * Hot toggle queryserv connect --------- Co-authored-by: Akkadius <akkadius1@gmail.com>
55 lines
1.7 KiB
C++
55 lines
1.7 KiB
C++
#pragma once
|
|
|
|
#include "tcp_connection.h"
|
|
#include "../event/timer.h"
|
|
#include "servertalk_common.h"
|
|
#include "packet.h"
|
|
|
|
namespace EQ
|
|
{
|
|
namespace Net
|
|
{
|
|
class ServertalkClient
|
|
{
|
|
public:
|
|
ServertalkClient(const std::string &addr, int port, bool ipv6, const std::string &identifier, const std::string &credentials);
|
|
~ServertalkClient();
|
|
|
|
void Send(uint16_t opcode, EQ::Net::Packet &p);
|
|
void SendPacket(ServerPacket *p);
|
|
void OnConnect(std::function<void(ServertalkClient*)> cb) { m_on_connect_cb = cb; }
|
|
void OnMessage(uint16_t opcode, std::function<void(uint16_t, EQ::Net::Packet&)> cb);
|
|
void OnMessage(std::function<void(uint16_t, EQ::Net::Packet&)> cb);
|
|
bool Connected() const { return m_connecting != true; }
|
|
|
|
std::shared_ptr<EQ::Net::TCPConnection> Handle() { return m_connection; }
|
|
|
|
const std::unique_ptr<EQ::Timer> &GetTimer() const { return m_timer; }
|
|
|
|
private:
|
|
void Connect();
|
|
void ProcessData(EQ::Net::TCPConnection *c, const unsigned char *data, size_t length);
|
|
void SendHello();
|
|
void InternalSend(ServertalkPacketType type, EQ::Net::Packet &p);
|
|
void ProcessReadBuffer();
|
|
void ProcessHello(EQ::Net::Packet &p);
|
|
void ProcessMessage(EQ::Net::Packet &p);
|
|
void SendHandshake();
|
|
|
|
std::unique_ptr<EQ::Timer> m_timer;
|
|
|
|
std::string m_addr;
|
|
std::string m_identifier;
|
|
std::string m_credentials;
|
|
bool m_connecting;
|
|
int m_port;
|
|
bool m_ipv6;
|
|
std::shared_ptr<EQ::Net::TCPConnection> m_connection;
|
|
std::vector<char> m_buffer;
|
|
std::unordered_map<uint16_t, std::function<void(uint16_t, EQ::Net::Packet&)>> m_message_callbacks;
|
|
std::function<void(uint16_t, EQ::Net::Packet&)> m_message_callback;
|
|
std::function<void(ServertalkClient*)> m_on_connect_cb;
|
|
};
|
|
}
|
|
}
|