mirror of
https://github.com/PrismLauncher/PrismLauncher
synced 2026-04-23 09:05:03 +00:00
fd91f87c21
```
find $PWD \
-type f \
! -path '*/.git/*' ! -path '*/flatpak/shared-modules/*' \
! -path '*/libraries/*' ! -path '*/testdata/*' ! -name '*.patch' \
! -name '*.svg' ! -name '*.scd' ! -path '*/program_info/LICENSE' \
! -path '*/COPYING.md' ! -path '*/cmake/*' ! -name '.gitmodules' \
-exec eclint -fix {} \;
```
Signed-off-by: Seth Flynn <getchoo@tuta.io>
48 lines
1.7 KiB
C++
48 lines
1.7 KiB
C++
#include <QFutureWatcher>
|
|
|
|
#include <Json.h>
|
|
#include "Exception.h"
|
|
#include "McClient.h"
|
|
#include "McResolver.h"
|
|
#include "ServerPingTask.h"
|
|
|
|
unsigned getOnlinePlayers(QJsonObject data)
|
|
{
|
|
try {
|
|
return Json::requireInteger(Json::requireObject(data, "players"), "online");
|
|
} catch (Exception& e) {
|
|
qWarning() << "server ping failed to parse response" << e.what();
|
|
return 0;
|
|
}
|
|
}
|
|
|
|
void ServerPingTask::executeTask()
|
|
{
|
|
qDebug() << "Querying status of " << QString("%1:%2").arg(m_domain).arg(m_port);
|
|
|
|
// Resolve the actual IP and port for the server
|
|
McResolver* resolver = new McResolver(nullptr, m_domain, m_port);
|
|
connect(resolver, &McResolver::succeeded, this, [this](QString ip, int port) {
|
|
qDebug() << "Resolved Address for" << m_domain << ": " << ip << ":" << port;
|
|
|
|
// Now that we have the IP and port, query the server
|
|
McClient* client = new McClient(nullptr, m_domain, ip, port);
|
|
|
|
connect(client, &McClient::succeeded, this, [this](QJsonObject data) {
|
|
m_outputOnlinePlayers = getOnlinePlayers(data);
|
|
qDebug() << "Online players: " << m_outputOnlinePlayers;
|
|
emitSucceeded();
|
|
});
|
|
connect(client, &McClient::failed, this, [this](QString error) { emitFailed(error); });
|
|
|
|
// Delete McClient object when done
|
|
connect(client, &McClient::finished, this, [client]() { client->deleteLater(); });
|
|
client->getStatusData();
|
|
});
|
|
connect(resolver, &McResolver::failed, this, [this](QString error) { emitFailed(error); });
|
|
|
|
// Delete McResolver object when done
|
|
connect(resolver, &McResolver::finished, [resolver]() { resolver->deleteLater(); });
|
|
resolver->ping();
|
|
}
|