summaryrefslogtreecommitdiff
path: root/libraries/katabasis/src/PollServer.cpp
diff options
context:
space:
mode:
authorMehmet Samet Duman <yongdohyun@projecttick.org>2026-04-02 17:36:40 +0300
committerMehmet Samet Duman <yongdohyun@projecttick.org>2026-04-02 17:36:40 +0300
commit1d4bf6e8b1208383021e22f61d859e9b721c482d (patch)
tree21c8e0c4350d7c44d817243ebf409be625ea4f21 /libraries/katabasis/src/PollServer.cpp
parent38c57e163abad6216f7e0f44d401c362c5fd5da6 (diff)
downloadProject-Tick-1d4bf6e8b1208383021e22f61d859e9b721c482d.tar.gz
Project-Tick-1d4bf6e8b1208383021e22f61d859e9b721c482d.zip
NOISSUE reformat MeshMC to new clang format rules and fixed macOS portability issue and java find issue
Signed-off-by: Mehmet Samet Duman <yongdohyun@projecttick.org>
Diffstat (limited to 'libraries/katabasis/src/PollServer.cpp')
-rw-r--r--libraries/katabasis/src/PollServer.cpp231
1 files changed, 117 insertions, 114 deletions
diff --git a/libraries/katabasis/src/PollServer.cpp b/libraries/katabasis/src/PollServer.cpp
index 99fc8279f5..1c8556aa98 100644
--- a/libraries/katabasis/src/PollServer.cpp
+++ b/libraries/katabasis/src/PollServer.cpp
@@ -25,120 +25,123 @@
#include "katabasis/PollServer.h"
#include "JsonResponse.h"
-namespace {
-QMap<QString, QString> toVerificationParams(const QVariantMap &map)
+namespace
{
- QMap<QString, QString> params;
- for (QVariantMap::const_iterator i = map.constBegin();
- i != map.constEnd(); ++i)
- {
- params[i.key()] = i.value().toString();
- }
- return params;
-}
-}
-
-namespace Katabasis {
-
-PollServer::PollServer(QNetworkAccessManager *manager, const QNetworkRequest &request, const QByteArray &payload, int expiresIn, QObject *parent)
- : QObject(parent)
- , manager_(manager)
- , request_(request)
- , payload_(payload)
- , expiresIn_(expiresIn)
+ QMap<QString, QString> toVerificationParams(const QVariantMap& map)
+ {
+ QMap<QString, QString> params;
+ for (QVariantMap::const_iterator i = map.constBegin();
+ i != map.constEnd(); ++i) {
+ params[i.key()] = i.value().toString();
+ }
+ return params;
+ }
+} // namespace
+
+namespace Katabasis
{
- expirationTimer.setTimerType(Qt::VeryCoarseTimer);
- expirationTimer.setInterval(expiresIn * 1000);
- expirationTimer.setSingleShot(true);
- connect(&expirationTimer, SIGNAL(timeout()), this, SLOT(onExpiration()));
- expirationTimer.start();
-
- pollTimer.setTimerType(Qt::VeryCoarseTimer);
- pollTimer.setInterval(5 * 1000);
- pollTimer.setSingleShot(true);
- connect(&pollTimer, SIGNAL(timeout()), this, SLOT(onPollTimeout()));
-}
-
-int PollServer::interval() const
-{
- return pollTimer.interval() / 1000;
-}
-
-void PollServer::setInterval(int interval)
-{
- pollTimer.setInterval(interval * 1000);
-}
-
-void PollServer::startPolling()
-{
- if (expirationTimer.isActive()) {
- pollTimer.start();
- }
-}
-void PollServer::onPollTimeout()
-{
- qDebug() << "PollServer::onPollTimeout: retrying";
- QNetworkReply * reply = manager_->post(request_, payload_);
- connect(reply, SIGNAL(finished()), this, SLOT(onReplyFinished()));
-}
-
-void PollServer::onExpiration()
-{
- pollTimer.stop();
- emit serverClosed(false);
-}
-
-void PollServer::onReplyFinished()
-{
- QNetworkReply *reply = qobject_cast<QNetworkReply *>(sender());
-
- if (!reply) {
- qDebug() << "PollServer::onReplyFinished: reply is null";
- return;
- }
-
- QByteArray replyData = reply->readAll();
- QMap<QString, QString> params = toVerificationParams(parseJsonResponse(replyData));
-
- // Dump replyData
- // SENSITIVE DATA in RelWithDebInfo or Debug builds
- // qDebug() << "PollServer::onReplyFinished: replyData\n";
- // qDebug() << QString( replyData );
-
- if (reply->error() == QNetworkReply::TimeoutError) {
- // rfc8628#section-3.2
- // "On encountering a connection timeout, clients MUST unilaterally
- // reduce their polling frequency before retrying. The use of an
- // exponential backoff algorithm to achieve this, such as doubling the
- // polling interval on each such connection timeout, is RECOMMENDED."
- setInterval(interval() * 2);
- pollTimer.start();
- }
- else {
- QString error = params.value("error");
- if (error == "slow_down") {
- // rfc8628#section-3.2
- // "A variant of 'authorization_pending', the authorization request is
- // still pending and polling should continue, but the interval MUST
- // be increased by 5 seconds for this and all subsequent requests."
- setInterval(interval() + 5);
- pollTimer.start();
- }
- else if (error == "authorization_pending") {
- // keep trying - rfc8628#section-3.2
- // "The authorization request is still pending as the end user hasn't
- // yet completed the user-interaction steps (Section 3.3)."
- pollTimer.start();
- }
- else {
- expirationTimer.stop();
- emit serverClosed(true);
- // let O2 handle the other cases
- emit verificationReceived(params);
- }
- }
- reply->deleteLater();
-}
-
-}
+ PollServer::PollServer(QNetworkAccessManager* manager,
+ const QNetworkRequest& request,
+ const QByteArray& payload, int expiresIn,
+ QObject* parent)
+ : QObject(parent), manager_(manager), request_(request),
+ payload_(payload), expiresIn_(expiresIn)
+ {
+ expirationTimer.setTimerType(Qt::VeryCoarseTimer);
+ expirationTimer.setInterval(expiresIn * 1000);
+ expirationTimer.setSingleShot(true);
+ connect(&expirationTimer, SIGNAL(timeout()), this,
+ SLOT(onExpiration()));
+ expirationTimer.start();
+
+ pollTimer.setTimerType(Qt::VeryCoarseTimer);
+ pollTimer.setInterval(5 * 1000);
+ pollTimer.setSingleShot(true);
+ connect(&pollTimer, SIGNAL(timeout()), this, SLOT(onPollTimeout()));
+ }
+
+ int PollServer::interval() const
+ {
+ return pollTimer.interval() / 1000;
+ }
+
+ void PollServer::setInterval(int interval)
+ {
+ pollTimer.setInterval(interval * 1000);
+ }
+
+ void PollServer::startPolling()
+ {
+ if (expirationTimer.isActive()) {
+ pollTimer.start();
+ }
+ }
+
+ void PollServer::onPollTimeout()
+ {
+ qDebug() << "PollServer::onPollTimeout: retrying";
+ QNetworkReply* reply = manager_->post(request_, payload_);
+ connect(reply, SIGNAL(finished()), this, SLOT(onReplyFinished()));
+ }
+
+ void PollServer::onExpiration()
+ {
+ pollTimer.stop();
+ emit serverClosed(false);
+ }
+
+ void PollServer::onReplyFinished()
+ {
+ QNetworkReply* reply = qobject_cast<QNetworkReply*>(sender());
+
+ if (!reply) {
+ qDebug() << "PollServer::onReplyFinished: reply is null";
+ return;
+ }
+
+ QByteArray replyData = reply->readAll();
+ QMap<QString, QString> params =
+ toVerificationParams(parseJsonResponse(replyData));
+
+ // Dump replyData
+ // SENSITIVE DATA in RelWithDebInfo or Debug builds
+ // qDebug() << "PollServer::onReplyFinished: replyData\n";
+ // qDebug() << QString( replyData );
+
+ if (reply->error() == QNetworkReply::TimeoutError) {
+ // rfc8628#section-3.2
+ // "On encountering a connection timeout, clients MUST unilaterally
+ // reduce their polling frequency before retrying. The use of an
+ // exponential backoff algorithm to achieve this, such as doubling
+ // the polling interval on each such connection timeout, is
+ // RECOMMENDED."
+ setInterval(interval() * 2);
+ pollTimer.start();
+ } else {
+ QString error = params.value("error");
+ if (error == "slow_down") {
+ // rfc8628#section-3.2
+ // "A variant of 'authorization_pending', the authorization
+ // request is still pending and polling should continue, but the
+ // interval MUST be increased by 5 seconds for this and all
+ // subsequent requests."
+ setInterval(interval() + 5);
+ pollTimer.start();
+ } else if (error == "authorization_pending") {
+ // keep trying - rfc8628#section-3.2
+ // "The authorization request is still pending as the end user
+ // hasn't yet completed the user-interaction steps
+ // (Section 3.3)."
+ pollTimer.start();
+ } else {
+ expirationTimer.stop();
+ emit serverClosed(true);
+ // let O2 handle the other cases
+ emit verificationReceived(params);
+ }
+ }
+ reply->deleteLater();
+ }
+
+} // namespace Katabasis