mirror of
https://github.com/EQEmu/Server.git
synced 2025-12-11 21:01: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>
75 lines
1.7 KiB
C++
75 lines
1.7 KiB
C++
#include "../common/global_define.h"
|
|
#include "../common/servertalk.h"
|
|
#include "../common/strings.h"
|
|
#include "queryserv.h"
|
|
#include "worldserver.h"
|
|
|
|
|
|
extern WorldServer worldserver;
|
|
extern QueryServ *QServ;
|
|
|
|
QueryServ::QueryServ()
|
|
{
|
|
}
|
|
|
|
QueryServ::~QueryServ()
|
|
{
|
|
}
|
|
|
|
void QueryServ::SendQuery(std::string Query)
|
|
{
|
|
auto pack = new ServerPacket(ServerOP_QSSendQuery, Query.length() + 5);
|
|
pack->WriteUInt32(Query.length()); /* Pack Query String Size so it can be dynamically broken out at queryserv */
|
|
pack->WriteString(Query.c_str()); /* Query */
|
|
worldserver.SendPacket(pack);
|
|
safe_delete(pack);
|
|
}
|
|
|
|
void QueryServ::Connect()
|
|
{
|
|
m_connection = std::make_unique<EQ::Net::ServertalkClient>(Config->QSHost, Config->QSPort, false, "Zone", Config->SharedKey);
|
|
m_connection->OnMessage(std::bind(&QueryServ::HandleMessage, this, std::placeholders::_1, std::placeholders::_2));
|
|
m_connection->OnConnect([this](EQ::Net::ServertalkClient *client) {
|
|
m_is_qs_connected = true;
|
|
LogInfo("Query Server connection established to [{}] [{}]", client->Handle()->RemoteIP(), client->Handle()->RemotePort());
|
|
});
|
|
|
|
LogInfo(
|
|
"New Query Server connection to [{}:{}]",
|
|
Config->QSHost,
|
|
Config->QSPort
|
|
);
|
|
}
|
|
|
|
bool QueryServ::SendPacket(ServerPacket *pack)
|
|
{
|
|
if (m_connection.get() == nullptr) {
|
|
Connect();
|
|
}
|
|
|
|
if (!m_connection.get()) {
|
|
return false;
|
|
}
|
|
|
|
if (m_is_qs_connected) {
|
|
m_connection->SendPacket(pack);
|
|
return true;
|
|
}
|
|
|
|
LogInfo("SendPacket request with QS Server Offline.");
|
|
return false;
|
|
}
|
|
|
|
void QueryServ::HandleMessage(uint16 opcode, const EQ::Net::Packet &p)
|
|
{
|
|
ServerPacket tpack(opcode, p);
|
|
auto pack = &tpack;
|
|
|
|
switch (opcode) {
|
|
default: {
|
|
LogInfo("Unknown ServerOP Received <red>[{}]", opcode);
|
|
break;
|
|
}
|
|
}
|
|
}
|