File indexing completed on 2024-05-19 05:03:21
0001 /* 0002 SPDX-FileCopyrightText: 2018-2024 Laurent Montel <montel@kde.org> 0003 0004 SPDX-License-Identifier: LGPL-2.0-or-later 0005 */ 0006 0007 #include "getmessagejob.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 GetMessageJob::GetMessageJob(QObject *parent) 0016 : RestApiAbstractJob(parent) 0017 { 0018 } 0019 0020 GetMessageJob::~GetMessageJob() = default; 0021 0022 bool GetMessageJob::requireHttpAuthentication() const 0023 { 0024 return true; 0025 } 0026 0027 bool GetMessageJob::start() 0028 { 0029 if (!canStart()) { 0030 qCWarning(ROCKETCHATQTRESTAPI_LOG) << "Impossible to start get message job"; 0031 deleteLater(); 0032 return false; 0033 } 0034 submitGetRequest(); 0035 0036 addStartRestApiInfo(QByteArrayLiteral("GetMessageJob: get message starting")); 0037 return true; 0038 } 0039 0040 void GetMessageJob::onGetRequestResponse(const QString &replyErrorString, const QJsonDocument &replyJson) 0041 { 0042 const QJsonObject replyObject = replyJson.object(); 0043 if (replyObject[QLatin1String("success")].toBool()) { 0044 addLoggerInfo(QByteArrayLiteral("GetMessageJob: success: ") + replyJson.toJson(QJsonDocument::Indented)); 0045 Q_EMIT getMessageDone(replyObject, mMessageId, mRoomId); 0046 } else { 0047 emitFailedMessage(replyErrorString, replyObject); 0048 addLoggerWarning(QByteArrayLiteral("GetMessageJob: Problem when we tried to get message : ") + replyJson.toJson(QJsonDocument::Indented)); 0049 } 0050 } 0051 0052 QString GetMessageJob::roomId() const 0053 { 0054 return mRoomId; 0055 } 0056 0057 void GetMessageJob::setRoomId(const QString &roomId) 0058 { 0059 mRoomId = roomId; 0060 } 0061 0062 QString GetMessageJob::messageId() const 0063 { 0064 return mMessageId; 0065 } 0066 0067 void GetMessageJob::setMessageId(const QString &messageId) 0068 { 0069 mMessageId = messageId; 0070 } 0071 0072 QNetworkRequest GetMessageJob::request() const 0073 { 0074 QUrl url = mRestApiMethod->generateUrl(RestApiUtil::RestApiUrlType::ChatGetMessage); 0075 QUrlQuery queryUrl; 0076 queryUrl.addQueryItem(QStringLiteral("msgId"), mMessageId); 0077 url.setQuery(queryUrl); 0078 QNetworkRequest request(url); 0079 addAuthRawHeader(request); 0080 addRequestAttribute(request, false); 0081 0082 return request; 0083 } 0084 0085 bool GetMessageJob::canStart() const 0086 { 0087 if (!RestApiAbstractJob::canStart()) { 0088 return false; 0089 } 0090 if (mMessageId.isEmpty()) { 0091 qCWarning(ROCKETCHATQTRESTAPI_LOG) << "MessageId is empty"; 0092 return false; 0093 } 0094 return true; 0095 } 0096 0097 #include "moc_getmessagejob.cpp"