mirror of
https://github.com/DarkflameUniverse/DarkflameServer.git
synced 2024-11-10 02:08:20 +00:00
183 lines
6.0 KiB
C++
183 lines
6.0 KiB
C++
#include "LeaderboardManager.h"
|
|
#include <utility>
|
|
#include "Database.h"
|
|
#include "EntityManager.h"
|
|
#include "Character.h"
|
|
#include "Game.h"
|
|
#include "GameMessages.h"
|
|
#include "dLogger.h"
|
|
#include "dConfig.h"
|
|
#include "CDClientManager.h"
|
|
#include "GeneralUtils.h"
|
|
#include "Entity.h"
|
|
#include <sstream>
|
|
|
|
#include "CDActivitiesTable.h"
|
|
#include "Metrics.hpp"
|
|
Leaderboard::Leaderboard(const GameID gameID, const Leaderboard::InfoType infoType, const bool weekly, const Leaderboard::Type leaderboardType) {
|
|
this->relatedPlayer = relatedPlayer;
|
|
this->gameID = gameID;
|
|
this->weekly = weekly;
|
|
this->infoType = infoType;
|
|
this->entries = entries;
|
|
this->leaderboardType = leaderboardType;
|
|
}
|
|
|
|
void Leaderboard::Serialize(RakNet::BitStream* bitStream) const {
|
|
std::ostringstream leaderboard;
|
|
|
|
leaderboard << "ADO.Result=7:1\n"; // Unused in 1.10.64, but is in captures
|
|
leaderboard << "Result.Count=1:1\n"; // number of results, always 1?
|
|
leaderboard << "Result[0].Index=0:RowNumber\n"; // "Primary key"
|
|
leaderboard << "Result[0].RowCount=1:" << entries.size() << '\n'; // number of rows
|
|
|
|
auto index = 0;
|
|
for (const auto& entry : entries) {
|
|
leaderboard << "Result[0].Row[" << index << "].LastPlayed=8:" << entry.lastPlayed << '\n';
|
|
leaderboard << "Result[0].Row[" << index << "].CharacterID=8:" << entry.playerID << '\n';
|
|
leaderboard << "Result[0].Row[" << index << "].NumPlayed=1:1\n"; // number of times the activity was played
|
|
leaderboard << "Result[0].Row[" << index << "].RowNumber=8:" << entry.placement << '\n';
|
|
leaderboard << "Result[0].Row[" << index << "].Time=1:" << entry.time << '\n';
|
|
|
|
// Only these minigames have a points system
|
|
if (leaderboardType == Survival || leaderboardType == ShootingGallery) {
|
|
leaderboard << "Result[0].Row[" << index << "].Points=1:"<< entry.score << '\n';
|
|
} else if (leaderboardType == SurvivalNS) {
|
|
leaderboard << "Result[0].Row[" << index << "].Wave=1:"<< entry.score << '\n';
|
|
}
|
|
|
|
leaderboard << "Result[0].Row[" << index << "].name=0:" << entry.playerName << '\n';
|
|
index++;
|
|
}
|
|
|
|
// Serialize the thing to a BitStream
|
|
bitStream->Write(leaderboard.str().c_str(), leaderboard.tellp());
|
|
}
|
|
|
|
void Leaderboard::SetupLeaderboard() {
|
|
// Setup query based on activity.
|
|
// Where clause will vary based on what query we are doing
|
|
|
|
}
|
|
|
|
void Leaderboard::Send(LWOOBJID targetID) const {
|
|
auto* player = EntityManager::Instance()->GetEntity(relatedPlayer);
|
|
if (player != nullptr) {
|
|
GameMessages::SendActivitySummaryLeaderboardData(targetID, this, player->GetSystemAddress());
|
|
}
|
|
}
|
|
|
|
void LeaderboardManager::SaveScore(LWOOBJID playerID, uint32_t gameID, uint32_t score, uint32_t time) {
|
|
const auto* player = EntityManager::Instance()->GetEntity(playerID);
|
|
if (player == nullptr)
|
|
return;
|
|
|
|
auto* character = player->GetCharacter();
|
|
if (!character)
|
|
return;
|
|
|
|
std::unique_ptr<sql::PreparedStatement> select(Database::CreatePreppedStmt("SELECT time, score FROM leaderboard WHERE character_id = ? AND game_id = ?;"));
|
|
|
|
select->setUInt64(1, character->GetID());
|
|
select->setInt(2, gameID);
|
|
|
|
auto any = false;
|
|
auto* result = select->executeQuery();
|
|
auto leaderboardType = GetLeaderboardType(gameID);
|
|
|
|
// Check if the new score is a high score
|
|
while (result->next()) {
|
|
any = true;
|
|
|
|
const auto storedTime = result->getInt(1);
|
|
const auto storedScore = result->getInt(2);
|
|
auto highscore = true;
|
|
bool classicSurvivalScoring = Game::config->GetValue("classic_survival_scoring") == "1";
|
|
|
|
switch (leaderboardType) {
|
|
case Leaderboard::Type::ShootingGallery:
|
|
if (score <= storedScore)
|
|
highscore = false;
|
|
break;
|
|
case Leaderboard::Type::Racing:
|
|
if (time >= storedTime)
|
|
highscore = false;
|
|
break;
|
|
case Leaderboard::Type::MonumentRace:
|
|
if (time >= storedTime)
|
|
highscore = false;
|
|
break;
|
|
case Leaderboard::Type::FootRace:
|
|
if (time <= storedTime)
|
|
highscore = false;
|
|
break;
|
|
case Leaderboard::Type::Survival:
|
|
if (classicSurvivalScoring) {
|
|
if (time <= storedTime) { // Based on time (LU live)
|
|
highscore = false;
|
|
}
|
|
} else {
|
|
if (score <= storedScore) // Based on score (DLU)
|
|
highscore = false;
|
|
}
|
|
break;
|
|
case Leaderboard::Type::SurvivalNS:
|
|
if (!(score > storedScore || (time < storedTime && score >= storedScore)))
|
|
highscore = false;
|
|
break;
|
|
default:
|
|
highscore = false;
|
|
}
|
|
|
|
if (!highscore) {
|
|
delete result;
|
|
return;
|
|
}
|
|
}
|
|
|
|
delete result;
|
|
|
|
if (any) {
|
|
auto* statement = Database::CreatePreppedStmt("UPDATE leaderboard SET time = ?, score = ?, last_played=SYSDATE() WHERE character_id = ? AND game_id = ?;");
|
|
statement->setInt(1, time);
|
|
statement->setInt(2, score);
|
|
statement->setUInt64(3, character->GetID());
|
|
statement->setInt(4, gameID);
|
|
statement->execute();
|
|
|
|
delete statement;
|
|
} else {
|
|
// Note: last_played will be set to SYSDATE() by default when inserting into leaderboard
|
|
auto* statement = Database::CreatePreppedStmt("INSERT INTO leaderboard (character_id, game_id, time, score) VALUES (?, ?, ?, ?);");
|
|
statement->setUInt64(1, character->GetID());
|
|
statement->setInt(2, gameID);
|
|
statement->setInt(3, time);
|
|
statement->setInt(4, score);
|
|
statement->execute();
|
|
|
|
delete statement;
|
|
}
|
|
}
|
|
|
|
void LeaderboardManager::SendLeaderboard(uint32_t gameID, Leaderboard::InfoType infoType, bool weekly, LWOOBJID targetID,
|
|
LWOOBJID playerID) {
|
|
// Create the leaderboard here and then send it right after. On the stack.
|
|
Leaderboard leaderboard(gameID, infoType, weekly, GetLeaderboardType(gameID));
|
|
leaderboard.SetupLeaderboard();
|
|
leaderboard.Send(targetID);
|
|
}
|
|
|
|
// Done
|
|
Leaderboard::Type LeaderboardManager::GetLeaderboardType(const GameID gameID) {
|
|
auto lookup = leaderboardCache.find(gameID);
|
|
if (lookup != leaderboardCache.end()) return lookup->second;
|
|
|
|
auto* activitiesTable = CDClientManager::Instance().GetTable<CDActivitiesTable>();
|
|
std::vector<CDActivities> activities = activitiesTable->Query([=](const CDActivities& entry) {
|
|
return (entry.ActivityID == gameID);
|
|
});
|
|
auto type = activities.empty() ? static_cast<Leaderboard::Type>(activities.at(0).leaderboardType) : Leaderboard::Type::None;
|
|
leaderboardCache.insert_or_assign(gameID, type);
|
|
return type;
|
|
}
|