nextcloud-desktop/test/testtalkreply.cpp

Ignoring revisions in .git-blame-ignore-revs. Click here to bypass and see the normal blame view.

94 lines
4.1 KiB
C++
Raw Normal View History

#include "tray/talkreply.h"
#include "account.h"
#include "accountstate.h"
#include "syncenginetestutils.h"
#include <QJsonDocument>
#include <QJsonObject>
#include <QTest>
#include <QSignalSpy>
namespace {
//reply to message
//https://nextcloud-talk.readthedocs.io/en/latest/chat/#sending-a-new-chat-message
static QByteArray replyToMessageSent = R"({"ocs":{"meta":{"status":"ok","statuscode":201,"message":"OK"},"data":{"id":12,"token":"abc123","actorType":"users","actorId":"user1","actorDisplayName":"User 1","timestamp":1636474603,"message":"test message 2","messageParameters":[],"systemMessage":"","messageType":"comment","isReplyable":true,"referenceId":"","parent":{"id":10,"token":"abc123","actorType":"users","actorId":"user2","actorDisplayName":"User 2","timestamp":1624987427,"message":"test message 1","messageParameters":[],"systemMessage":"","messageType":"comment","isReplyable":true,"referenceId":"2857b6eb77b4d7f1f46c6783513e8ef4a0c7ac53"}}}}
)";
// only send message to chat
static QByteArray replyMessageSent = R"({"ocs":{"meta":{"status":"ok","statuscode":201,"message":"OK"},"data":{"id":11,"token":"abc123","actorType":"users","actorId":"user1","actorDisplayName":"User 1","timestamp":1636474440,"message":"test message 3","messageParameters":[],"systemMessage":"","messageType":"comment","isReplyable":true,"referenceId":""}}}
)";
}
class TestTalkReply : public QObject
{
Q_OBJECT
public:
TestTalkReply() = default;
OCC::AccountPtr account;
QScopedPointer<FakeQNAM> fakeQnam;
QScopedPointer<OCC::AccountState> accountState;
private slots:
void initTestCase()
{
fakeQnam.reset(new FakeQNAM({}));
account = OCC::Account::create();
account->setCredentials(new FakeCredentials{fakeQnam.data()});
account->setUrl(QUrl(("http://example.de")));
accountState.reset(new OCC::AccountState(account));
fakeQnam->setOverride([this](QNetworkAccessManager::Operation op, const QNetworkRequest &req, QIODevice *device) {
Q_UNUSED(device);
QNetworkReply *reply = nullptr;
const auto urlQuery = QUrlQuery(req.url());
const auto message = urlQuery.queryItemValue(QStringLiteral("message"));
const auto replyTo = urlQuery.queryItemValue(QStringLiteral("replyTo"));
const auto path = req.url().path();
if (path.startsWith(QStringLiteral("/ocs/v2.php/apps/spreed/api/v1/chat")) && replyTo.isEmpty()) {
reply = new FakePayloadReply(op, req, replyMessageSent, fakeQnam.data());
} else if (path.startsWith(QStringLiteral("/ocs/v2.php/apps/spreed/api/v1/chat")) && !replyTo.isEmpty()) {
reply = new FakePayloadReply(op, req, replyToMessageSent, fakeQnam.data());
}
if (!reply) {
return qobject_cast<QNetworkReply*>(new FakeErrorReply(op, req, this, 404, QByteArrayLiteral("{error: \"Not found!\"}")));
}
return reply;
});
}
void testSendReplyMessage_noReplyToSet_messageIsSent()
{
QPointer<OCC::TalkReply> talkReply = new OCC::TalkReply(accountState.data());
const auto message = QStringLiteral("test message 3");
talkReply->sendReplyMessage(QStringLiteral("abc123"), message);
QSignalSpy replyMessageSent(talkReply.data(), &OCC::TalkReply::replyMessageSent);
QVERIFY(replyMessageSent.wait());
QList<QVariant> arguments = replyMessageSent.takeFirst();
QVERIFY(arguments.at(0).toString() == message);
}
void testSendReplyMessage_replyToSet_messageIsSent()
{
QPointer<OCC::TalkReply> talkReply = new OCC::TalkReply(accountState.data());
const auto message = QStringLiteral("test message 2");
talkReply->sendReplyMessage(QStringLiteral("abc123"), message, QStringLiteral("11"));
QSignalSpy replyMessageSent(talkReply.data(), &OCC::TalkReply::replyMessageSent);
QVERIFY(replyMessageSent.wait());
QList<QVariant> arguments = replyMessageSent.takeFirst();
QVERIFY(arguments.at(0).toString() == message);
}
};
QTEST_MAIN(TestTalkReply)
#include "testtalkreply.moc"