Mirrored_Repos/DarkflameServer
1
0
Fork 0
mirror of https://github.com/DarkflameUniverse/DarkflameServer.git synced 2025-01-09 14:27:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

update cdclient.fdb file check (#1699)

Browse Source
This commit is contained in:
David Markowitz 2024-12-27 20:15:32 -08:00 committed by GitHub
parent 0c948a8df6
commit 08a168de88
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 113 additions and 113 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

226
dWorldServer/WorldServer.cpp
View File

@ -267,8 +267,6 @@ int main(int argc, char** argv) {
// pre calculate the FDB checksum // pre calculate the FDB checksum
if (Game::config->GetValue("check_fdb") == "1") { if (Game::config->GetValue("check_fdb") == "1") {
std::ifstream fileStream;
static const std::vector<std::string> aliases = { static const std::vector<std::string> aliases = {
"CDServers.fdb", "CDServers.fdb",
"cdserver.fdb", "cdserver.fdb",
@ -277,31 +275,33 @@ int main(int argc, char** argv) {
}; };
for (const auto& file : aliases) { for (const auto& file : aliases) {
fileStream.open(Game::assetManager->GetResPath() / file, std::ios::binary | std::ios::in); auto cdclient = Game::assetManager->GetFile("cdclient.fdb");
if (fileStream.is_open()) { if (cdclient) {
const int32_t bufferSize = 1024;
MD5 md5;
char fileStreamBuffer[1024] = {};
while (!cdclient.eof()) {
memset(fileStreamBuffer, 0, bufferSize);
cdclient.read(fileStreamBuffer, bufferSize);
md5.update(fileStreamBuffer, cdclient.gcount());
}
const char* nullTerminateBuffer = "\0";
md5.update(nullTerminateBuffer, 1); // null terminate the data
md5.finalize();
databaseChecksum = md5.hexdigest();
LOG("FDB Checksum calculated as: %s", databaseChecksum.c_str());
break; break;
} }
} }
if (databaseChecksum.empty()) {
const int32_t bufferSize = 1024; LOG("check_fdb is on but no fdb file found.");
MD5 md5; return EXIT_FAILURE;
char fileStreamBuffer[1024] = {};
while (!fileStream.eof()) {
memset(fileStreamBuffer, 0, bufferSize);
fileStream.read(fileStreamBuffer, bufferSize);
md5.update(fileStreamBuffer, fileStream.gcount());
} }
fileStream.close();
const char* nullTerminateBuffer = "\0";
md5.update(nullTerminateBuffer, 1); // null terminate the data
md5.finalize();
databaseChecksum = md5.hexdigest();
LOG("FDB Checksum calculated as: %s", databaseChecksum.c_str());
} }
uint32_t currentFrameDelta = highFrameDelta; uint32_t currentFrameDelta = highFrameDelta;
@ -548,115 +548,115 @@ void HandlePacketChat(Packet* packet) {
if (packet->data[0] == ID_USER_PACKET_ENUM && packet->length >= 4) { if (packet->data[0] == ID_USER_PACKET_ENUM && packet->length >= 4) {
if (static_cast<eConnectionType>(packet->data[1]) == eConnectionType::CHAT) { if (static_cast<eConnectionType>(packet->data[1]) == eConnectionType::CHAT) {
switch (static_cast<MessageType::Chat>(packet->data[3])) { switch (static_cast<MessageType::Chat>(packet->data[3])) {
case MessageType::Chat::WORLD_ROUTE_PACKET: { case MessageType::Chat::WORLD_ROUTE_PACKET: {
CINSTREAM_SKIP_HEADER; CINSTREAM_SKIP_HEADER;
LWOOBJID playerID; LWOOBJID playerID;
inStream.Read(playerID); inStream.Read(playerID);
auto player = Game::entityManager->GetEntity(playerID); auto player = Game::entityManager->GetEntity(playerID);
if (!player) return; if (!player) return;
auto sysAddr = player->GetSystemAddress(); auto sysAddr = player->GetSystemAddress();
//Write our stream outwards: //Write our stream outwards:
CBITSTREAM; CBITSTREAM;
unsigned char data; unsigned char data;
while (inStream.Read(data)) { while (inStream.Read(data)) {
bitStream.Write(data); bitStream.Write(data);
}
SEND_PACKET; //send routed packet to player
break;
} }
case MessageType::Chat::GM_ANNOUNCE: { SEND_PACKET; //send routed packet to player
CINSTREAM_SKIP_HEADER; break;
}
std::string title; case MessageType::Chat::GM_ANNOUNCE: {
std::string msg; CINSTREAM_SKIP_HEADER;
uint32_t len; std::string title;
inStream.Read<uint32_t>(len); std::string msg;
for (uint32_t i = 0; len > i; i++) {
char character;
inStream.Read<char>(character);
title += character;
}
len = 0; uint32_t len;
inStream.Read<uint32_t>(len); inStream.Read<uint32_t>(len);
for (uint32_t i = 0; len > i; i++) { for (uint32_t i = 0; len > i; i++) {
char character; char character;
inStream.Read<char>(character); inStream.Read<char>(character);
msg += character; title += character;
} }
//Send to our clients: len = 0;
AMFArrayValue args; inStream.Read<uint32_t>(len);
for (uint32_t i = 0; len > i; i++) {
char character;
inStream.Read<char>(character);
msg += character;
}
args.Insert("title", title); //Send to our clients:
args.Insert("message", msg); AMFArrayValue args;
GameMessages::SendUIMessageServerToAllClients("ToggleAnnounce", args); args.Insert("title", title);
args.Insert("message", msg);
GameMessages::SendUIMessageServerToAllClients("ToggleAnnounce", args);
break;
}
case MessageType::Chat::GM_MUTE: {
CINSTREAM_SKIP_HEADER;
LWOOBJID playerId;
time_t expire = 0;
inStream.Read(playerId);
inStream.Read(expire);
auto* entity = Game::entityManager->GetEntity(playerId);
auto* character = entity != nullptr ? entity->GetCharacter() : nullptr;
auto* user = character != nullptr ? character->GetParentUser() : nullptr;
if (user) {
user->SetMuteExpire(expire);
entity->GetCharacter()->SendMuteNotice();
}
break;
}
case MessageType::Chat::TEAM_GET_STATUS: {
CINSTREAM_SKIP_HEADER;
LWOOBJID teamID = 0;
char lootOption = 0;
char memberCount = 0;
std::vector<LWOOBJID> members;
inStream.Read(teamID);
bool deleteTeam = inStream.ReadBit();
if (deleteTeam) {
TeamManager::Instance()->DeleteTeam(teamID);
LOG("Deleting team (%llu)", teamID);
break; break;
} }
case MessageType::Chat::GM_MUTE: { inStream.Read(lootOption);
CINSTREAM_SKIP_HEADER; inStream.Read(memberCount);
LWOOBJID playerId; LOG("Updating team (%llu), (%i), (%i)", teamID, lootOption, memberCount);
time_t expire = 0; for (char i = 0; i < memberCount; i++) {
inStream.Read(playerId); LWOOBJID member = LWOOBJID_EMPTY;
inStream.Read(expire); inStream.Read(member);
members.push_back(member);
auto* entity = Game::entityManager->GetEntity(playerId); LOG("Updating team member (%llu)", member);
auto* character = entity != nullptr ? entity->GetCharacter() : nullptr;
auto* user = character != nullptr ? character->GetParentUser() : nullptr;
if (user) {
user->SetMuteExpire(expire);
entity->GetCharacter()->SendMuteNotice();
}
break;
} }
case MessageType::Chat::TEAM_GET_STATUS: { TeamManager::Instance()->UpdateTeam(teamID, lootOption, members);
CINSTREAM_SKIP_HEADER;
LWOOBJID teamID = 0; break;
char lootOption = 0; }
char memberCount = 0; default:
std::vector<LWOOBJID> members; LOG("Received an unknown chat: %i", int(packet->data[3]));
inStream.Read(teamID);
bool deleteTeam = inStream.ReadBit();
if (deleteTeam) {
TeamManager::Instance()->DeleteTeam(teamID);
LOG("Deleting team (%llu)", teamID);
break;
}
inStream.Read(lootOption);
inStream.Read(memberCount);
LOG("Updating team (%llu), (%i), (%i)", teamID, lootOption, memberCount);
for (char i = 0; i < memberCount; i++) {
LWOOBJID member = LWOOBJID_EMPTY;
inStream.Read(member);
members.push_back(member);
LOG("Updating team member (%llu)", member);
}
TeamManager::Instance()->UpdateTeam(teamID, lootOption, members);
break;
}
default:
LOG("Received an unknown chat: %i", int(packet->data[3]));
} }
} }
} }