1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
|
/*
* SPDX-FileCopyrightText: 2022 Nextcloud GmbH and Nextcloud contributors
* SPDX-License-Identifier: GPL-2.0-or-later
*/
#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()
{
OCC::Logger::instance()->setLogFlush(true);
OCC::Logger::instance()->setLogDebug(true);
QStandardPaths::setTestModeEnabled(true);
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"
|
