File indexing completed on 2024-06-02 05:07:09
0001 /* 0002 SPDX-FileCopyrightText: 2019-2024 Laurent Montel <montel@kde.org> 0003 0004 SPDX-License-Identifier: LGPL-2.0-or-later 0005 */ 0006 0007 #include "syncthreadmessagesjob.h" 0008 #include "restapimethod.h" 0009 #include "rocketchatqtrestapi_debug.h" 0010 #include <QJsonDocument> 0011 #include <QJsonObject> 0012 #include <QNetworkReply> 0013 #include <QUrlQuery> 0014 using namespace RocketChatRestApi; 0015 SyncThreadMessagesJob::SyncThreadMessagesJob(QObject *parent) 0016 : RestApiAbstractJob(parent) 0017 { 0018 } 0019 0020 SyncThreadMessagesJob::~SyncThreadMessagesJob() = default; 0021 0022 bool SyncThreadMessagesJob::requireHttpAuthentication() const 0023 { 0024 return true; 0025 } 0026 0027 bool SyncThreadMessagesJob::canStart() const 0028 { 0029 if (!RestApiAbstractJob::canStart()) { 0030 return false; 0031 } 0032 if (mThreadMessageId.isEmpty()) { 0033 qCWarning(ROCKETCHATQTRESTAPI_LOG) << "SyncThreadMessagesJob: mThreadMessageId is empty"; 0034 return false; 0035 } 0036 if (mTimeStamp.isEmpty()) { 0037 qCWarning(ROCKETCHATQTRESTAPI_LOG) << "SyncThreadMessagesJob: mTimeStamp is empty"; 0038 return false; 0039 } 0040 return true; 0041 } 0042 0043 bool SyncThreadMessagesJob::start() 0044 { 0045 if (!canStart()) { 0046 qCWarning(ROCKETCHATQTRESTAPI_LOG) << "Impossible to start SyncThreadMessagesJob job"; 0047 deleteLater(); 0048 return false; 0049 } 0050 submitGetRequest(); 0051 0052 addStartRestApiInfo(QByteArrayLiteral("SyncThreadMessagesJob: update threads message in room")); 0053 return true; 0054 } 0055 0056 void SyncThreadMessagesJob::onGetRequestResponse(const QString &replyErrorString, const QJsonDocument &replyJson) 0057 { 0058 const QJsonObject replyObject = replyJson.object(); 0059 if (replyObject[QLatin1String("success")].toBool()) { 0060 addLoggerInfo(QByteArrayLiteral("SyncThreadMessagesJob: success: ") + replyJson.toJson(QJsonDocument::Indented)); 0061 Q_EMIT syncThreadMessagesDone(replyObject, mThreadMessageId); 0062 } else { 0063 emitFailedMessage(replyErrorString, replyObject); 0064 addLoggerWarning(QByteArrayLiteral("SyncThreadMessagesJob: Problem: ") + replyJson.toJson(QJsonDocument::Indented)); 0065 } 0066 } 0067 0068 QString SyncThreadMessagesJob::timeStamp() const 0069 { 0070 return mTimeStamp; 0071 } 0072 0073 void SyncThreadMessagesJob::setTimeStamp(const QString &timeStamp) 0074 { 0075 mTimeStamp = timeStamp; 0076 } 0077 0078 QString SyncThreadMessagesJob::threadMessageId() const 0079 { 0080 return mThreadMessageId; 0081 } 0082 0083 void SyncThreadMessagesJob::setThreadMessageId(const QString &threadMessageId) 0084 { 0085 mThreadMessageId = threadMessageId; 0086 } 0087 0088 QNetworkRequest SyncThreadMessagesJob::request() const 0089 { 0090 QUrl url = mRestApiMethod->generateUrl(RestApiUtil::RestApiUrlType::ChatSyncThreadMessages); 0091 QUrlQuery queryUrl; 0092 queryUrl.addQueryItem(QStringLiteral("tmid"), mThreadMessageId); 0093 queryUrl.addQueryItem(QStringLiteral("updatedSince"), mTimeStamp); 0094 url.setQuery(queryUrl); 0095 0096 QNetworkRequest request(url); 0097 addRequestAttribute(request, false); 0098 0099 addAuthRawHeader(request); 0100 return request; 0101 } 0102 0103 #include "moc_syncthreadmessagesjob.cpp"