[Code] UCSConnection Global to Singleton Cleanup

This commit is contained in:
Kinglykrab
2025-06-20 22:29:15 -04:00
parent 1be7e56b86
commit 17144d769f
7 changed files with 15 additions and 14 deletions
-1
View File
@@ -16,7 +16,6 @@
extern ZSList zoneserver_list; extern ZSList zoneserver_list;
extern ClientList client_list; extern ClientList client_list;
extern WorldGuildManager guild_mgr; extern WorldGuildManager guild_mgr;
extern UCSConnection UCSLink;
extern QueryServConnection QSLink; extern QueryServConnection QSLink;
void callGetZoneList(Json::Value &response) void callGetZoneList(Json::Value &response)
+3 -4
View File
@@ -97,7 +97,6 @@ ClientList client_list;
GroupLFPList LFPGroupList; GroupLFPList LFPGroupList;
ZSList zoneserver_list; ZSList zoneserver_list;
LoginServerList loginserverlist; LoginServerList loginserverlist;
UCSConnection UCSLink;
QueryServConnection QSLink; QueryServConnection QSLink;
LauncherList launcher_list; LauncherList launcher_list;
AdventureManager adventure_manager; AdventureManager adventure_manager;
@@ -303,7 +302,7 @@ int main(int argc, char **argv)
connection->GetUUID() connection->GetUUID()
); );
UCSLink.SetConnection(connection); UCSConnection::Instance()->SetConnection(connection);
zoneserver_list.UpdateUCSServerAvailable(); zoneserver_list.UpdateUCSServerAvailable();
} }
@@ -313,11 +312,11 @@ int main(int argc, char **argv)
"UCS", [](std::shared_ptr<EQ::Net::ServertalkServerConnection> connection) { "UCS", [](std::shared_ptr<EQ::Net::ServertalkServerConnection> connection) {
LogInfo("Connection lost from UCS Server [{}]", connection->GetUUID()); LogInfo("Connection lost from UCS Server [{}]", connection->GetUUID());
auto ucs_connection = UCSLink.GetConnection(); auto ucs_connection = UCSConnection::Instance()->GetConnection();
if (ucs_connection->GetUUID() == connection->GetUUID()) { if (ucs_connection->GetUUID() == connection->GetUUID()) {
LogInfo("Removing currently active UCS connection"); LogInfo("Removing currently active UCS connection");
UCSLink.SetConnection(nullptr); UCSConnection::Instance()->SetConnection(nullptr);
zoneserver_list.UpdateUCSServerAvailable(false); zoneserver_list.UpdateUCSServerAvailable(false);
} }
} }
+6
View File
@@ -19,6 +19,12 @@ public:
const std::shared_ptr<EQ::Net::ServertalkServerConnection> &GetConnection() const; const std::shared_ptr<EQ::Net::ServertalkServerConnection> &GetConnection() const;
inline bool IsConnected() const { return connection->Handle() ? connection->Handle()->IsConnected() : false; } inline bool IsConnected() const { return connection->Handle() ? connection->Handle()->IsConnected() : false; }
static UCSConnection* Instance()
{
static UCSConnection instance;
return &instance;
}
private: private:
inline std::string GetIP() const { return (connection && connection->Handle()) ? connection->Handle()->RemoteIP() : 0; } inline std::string GetIP() const { return (connection && connection->Handle()) ? connection->Handle()->RemoteIP() : 0; }
std::shared_ptr<EQ::Net::ServertalkServerConnection> connection; std::shared_ptr<EQ::Net::ServertalkServerConnection> connection;
+2 -2
View File
@@ -628,14 +628,14 @@ void WorldBoot::Shutdown()
void WorldBoot::SendDiscordMessage(int webhook_id, const std::string &message) void WorldBoot::SendDiscordMessage(int webhook_id, const std::string &message)
{ {
if (UCSLink.IsConnected()) { if (UCSConnection::Instance()->IsConnected()) {
auto pack = new ServerPacket(ServerOP_DiscordWebhookMessage, sizeof(DiscordWebhookMessage_Struct) + 1); auto pack = new ServerPacket(ServerOP_DiscordWebhookMessage, sizeof(DiscordWebhookMessage_Struct) + 1);
auto *q = (DiscordWebhookMessage_Struct *) pack->pBuffer; auto *q = (DiscordWebhookMessage_Struct *) pack->pBuffer;
strn0cpy(q->message, message.c_str(), 2000); strn0cpy(q->message, message.c_str(), 2000);
q->webhook_id = webhook_id; q->webhook_id = webhook_id;
UCSLink.SendPacket(pack); UCSConnection::Instance()->SendPacket(pack);
safe_delete(pack); safe_delete(pack);
} }
-2
View File
@@ -6,8 +6,6 @@
#include "../common/discord/discord.h" #include "../common/discord/discord.h"
#include "ucs.h" #include "ucs.h"
extern UCSConnection UCSLink;
class WorldBoot { class WorldBoot {
public: public:
static void GMSayHookCallBackProcessWorld(uint16 log_category, const char *func, std::string message); static void GMSayHookCallBackProcessWorld(uint16 log_category, const char *func, std::string message);
+1 -1
View File
@@ -984,7 +984,7 @@ void ZSList::SendServerReload(ServerReload::Type type, uchar *packet)
} else if (type == ServerReload::Type::Logs) { } else if (type == ServerReload::Type::Logs) {
LogSys.LoadLogDatabaseSettings(); LogSys.LoadLogDatabaseSettings();
player_event_logs.ReloadSettings(); player_event_logs.ReloadSettings();
UCSLink.SendPacket(&pack); UCSConnection::Instance()->SendPacket(&pack);
} else if (type == ServerReload::Type::Tasks) { } else if (type == ServerReload::Type::Tasks) {
shared_task_manager.LoadTaskData(); shared_task_manager.LoadTaskData();
} else if (type == ServerReload::Type::DzTemplates) { } else if (type == ServerReload::Type::DzTemplates) {
+3 -4
View File
@@ -59,7 +59,6 @@ extern LoginServerList loginserverlist;
extern volatile bool RunLoops; extern volatile bool RunLoops;
extern volatile bool UCSServerAvailable_; extern volatile bool UCSServerAvailable_;
extern AdventureManager adventure_manager; extern AdventureManager adventure_manager;
extern UCSConnection UCSLink;
extern QueryServConnection QSLink; extern QueryServConnection QSLink;
extern SharedTaskManager shared_task_manager; extern SharedTaskManager shared_task_manager;
@@ -381,7 +380,7 @@ void ZoneServer::HandleMessage(uint16 opcode, const EQ::Net::Packet &p) {
// if discord enabled for event, ship to UCS to process // if discord enabled for event, ship to UCS to process
if (player_event_logs.IsEventDiscordEnabled(n.player_event_log.event_type_id)) { if (player_event_logs.IsEventDiscordEnabled(n.player_event_log.event_type_id)) {
UCSLink.SendPacket(pack); UCSConnection::Instance()->SendPacket(pack);
} }
break; break;
@@ -435,7 +434,7 @@ void ZoneServer::HandleMessage(uint16 opcode, const EQ::Net::Packet &p) {
auto scm = (ServerChannelMessage_Struct*) pack->pBuffer; auto scm = (ServerChannelMessage_Struct*) pack->pBuffer;
if (scm->chan_num == ChatChannel_UCSRelay) { if (scm->chan_num == ChatChannel_UCSRelay) {
UCSLink.SendMessage(scm->from, scm->message); UCSConnection::Instance()->SendMessage(scm->from, scm->message);
break; break;
} }
@@ -1344,7 +1343,7 @@ void ZoneServer::HandleMessage(uint16 opcode, const EQ::Net::Packet &p) {
} }
case ServerOP_DiscordWebhookMessage: case ServerOP_DiscordWebhookMessage:
case ServerOP_UCSMailMessage: { case ServerOP_UCSMailMessage: {
UCSLink.SendPacket(pack); UCSConnection::Instance()->SendPacket(pack);
break; break;
} }
case ServerOP_UCSServerStatusRequest: { case ServerOP_UCSServerStatusRequest: {