File indexing completed on 2024-12-01 13:09:12

 /*
 
  * SPDX-FileCopyrightText: 2016 Riccardo Iaconelli <riccardo@kde.org>
  *
  * SPDX-License-Identifier: LGPL-2.0-or-later
  *
  */
 
 #include "messagequeue.h"
 #include "ddpapi/ddpauthenticationmanager.h"
 #include "ddpapi/ddpclient.h"
 #include "rocketchataccount.h"
 
 #include <QCborValue>
 #include <QDataStream>
 #include <QDir>
 #include <QJsonArray>
 #include <QPair>
 
 MessageQueue::MessageQueue(RocketChatAccount *account, QObject *parent)
     : QObject(parent)
     , mRocketChatAccount(account)
 {
 }
 
 MessageQueue::~MessageQueue()
 {
 }
 
 void MessageQueue::loadCache()
 {
     connect(mRocketChatAccount->ddp()->authenticationManager(), &DDPAuthenticationManager::loginStatusChanged, this, &MessageQueue::onLoginStatusChanged);
 }
 
 QPair<QString, QJsonDocument> MessageQueue::fromJson(const QJsonObject &object)
 {
     QPair<QString, QJsonDocument> pair;
 
     pair.first = object[QLatin1String("method")].toString();
     QJsonArray arr = object[QLatin1String("params")].toArray();
     pair.second = QJsonDocument(arr);
     return pair;
 }
 
 QByteArray MessageQueue::serialize(const QPair<QString, QJsonDocument> &pair)
 {
     QJsonObject o;
 
     o[QLatin1String("method")] = QJsonValue(pair.first);
 
     QJsonArray arr;
     if (pair.second.isArray()) {
         arr.append(pair.second.array());
     } else if (pair.second.isObject()) {
         arr.append(pair.second.object());
     }
 
     o[QLatin1String("params")] = QJsonValue(arr);
 
     return QCborValue::fromJsonValue(o).toCbor();
 }
 
 void MessageQueue::onLoginStatusChanged()
 {
     // retry sending messages
     // TODO: check login status?
     processQueue();
 }
 
 void MessageQueue::processQueue()
 {
     // can be optimized using single shot timer
     while (mRocketChatAccount->loginStatus() == DDPAuthenticationManager::LoggedIn && !mRocketChatAccount->ddp()->messageQueue().empty()) {
         const QPair<QString, QJsonDocument> pair = mRocketChatAccount->ddp()->messageQueue().head();
         const QString method = pair.first;
         const QJsonDocument params = pair.second;
         mRocketChatAccount->ddp()->method(method, params);
     }
 }
 
 #include "moc_messagequeue.cpp"