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
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
|
// SPDX-FileCopyrightText: 2020 Linus Jahn <lnj@kaidan.im>
// SPDX-FileCopyrightText: 2021 Melvin Keskin <melvo@olomono.de>
//
// SPDX-License-Identifier: LGPL-2.1-or-later
#include "QXmppClient.h"
#include "QXmppDiscoveryManager.h"
#include "QXmppRosterManager.h"
#include "TestClient.h"
class tst_QXmppRosterManager : public QObject
{
Q_OBJECT
private:
Q_SLOT void initTestCase();
Q_SLOT void testDiscoFeatures();
Q_SLOT void testRenameItem();
Q_SLOT void subscriptionRequestReceived();
Q_SLOT void testAddItem();
Q_SLOT void testRemoveItem();
private:
QXmppClient client;
QXmppLogger logger;
QXmppRosterManager *manager;
};
void tst_QXmppRosterManager::initTestCase()
{
logger.setLoggingType(QXmppLogger::SignalLogging);
client.setLogger(&logger);
manager = client.findExtension<QXmppRosterManager>();
}
void tst_QXmppRosterManager::testDiscoFeatures()
{
QCOMPARE(manager->discoveryFeatures(), QStringList());
}
void tst_QXmppRosterManager::testRenameItem()
{
// used to clean up lambda signal connections
QObject context;
auto createItem = [](const QString &jid, const QString &ask = {}) -> QXmppRosterIq::Item {
QXmppRosterIq::Item item;
item.setBareJid(jid);
item.setSubscriptionStatus(ask);
return item;
};
// fill roster with initial contacts to rename
QXmppRosterIq initialItems;
initialItems.setType(QXmppIq::Result);
initialItems.addItem(createItem("stpeter@jabber.org"));
initialItems.addItem(createItem("bob@qxmpp.org"));
QVERIFY(manager->handleStanza(writePacketToDom(initialItems)));
// set a subscription state for bob (the subscription state MUST NOT be
// sent when renaming an item, so we need to check that it's not)
QXmppRosterIq bobAsk;
bobAsk.setType(QXmppIq::Set);
bobAsk.addItem(createItem("bob@qxmpp.org", "subscribe"));
QVERIFY(manager->handleStanza(writePacketToDom(bobAsk)));
QCOMPARE(manager->getRosterEntry("bob@qxmpp.org").subscriptionStatus(), QStringLiteral("subscribe"));
// rename bob
bool requestSent = false;
connect(&logger, &QXmppLogger::message, &context, [&](QXmppLogger::MessageType type, const QString &text) {
if (type == QXmppLogger::SentMessage) {
requestSent = true;
QXmppRosterIq renameRequest;
parsePacket(renameRequest, text.toUtf8());
QCOMPARE(renameRequest.items().size(), 1);
QCOMPARE(renameRequest.items().first().bareJid(), QStringLiteral("bob@qxmpp.org"));
QCOMPARE(renameRequest.items().first().name(), QStringLiteral("Bob"));
// check that subscription state ('ask') for bob is not included
QVERIFY(renameRequest.items().first().subscriptionStatus().isNull());
}
});
manager->renameItem("bob@qxmpp.org", "Bob");
QVERIFY(requestSent);
}
void tst_QXmppRosterManager::subscriptionRequestReceived()
{
QXmppPresence presence;
presence.setType(QXmppPresence::Subscribe);
presence.setFrom(QStringLiteral("alice@example.org/notebook"));
presence.setStatusText(QStringLiteral("Hi, I'm Alice."));
bool subscriptionRequestReceived = false;
connect(manager, &QXmppRosterManager::subscriptionRequestReceived, this, [&](const QString &subscriberBareJid, const QXmppPresence &presence) {
subscriptionRequestReceived = true;
QCOMPARE(subscriberBareJid, QStringLiteral("alice@example.org"));
QCOMPARE(presence.statusText(), QStringLiteral("Hi, I'm Alice."));
});
Q_EMIT client.presenceReceived(presence);
QVERIFY(subscriptionRequestReceived);
}
void tst_QXmppRosterManager::testAddItem()
{
TestClient test;
test.configuration().setJid(QStringLiteral("juliet@capulet.lit"));
auto *rosterManager = test.addNewExtension<QXmppRosterManager>(&test);
auto future = rosterManager->addRosterItem("contact@example.org");
test.expect("<iq id='qxmpp1' to='capulet.lit' type='set'><query xmlns='jabber:iq:roster'><item jid='contact@example.org'/></query></iq>");
test.inject<QString>("<iq id='qxmpp1' from='capulet.lit' type='result'/>");
expectFutureVariant<QXmpp::Success>(future);
future = rosterManager->addRosterItem("contact@example.org");
test.expect("<iq id='qxmpp1' to='capulet.lit' type='set'><query xmlns='jabber:iq:roster'><item jid='contact@example.org'/></query></iq>");
test.inject<QString>(R"(
<iq id='qxmpp1' from='capulet.lit' type='error'>
<error type='modify'>
<not-authorized xmlns='urn:ietf:params:xml:ns:xmpp-stanzas'/>
<text xmlns='urn:ietf:params:xml:ns:xmpp-stanzas'>This is not allowed</text>
</error>
</iq>)");
auto err = expectFutureVariant<QXmppError>(future);
auto error = err.value<QXmppStanza::Error>().value();
QCOMPARE(error.type(), QXmppStanza::Error::Modify);
QCOMPARE(error.text(), QStringLiteral("This is not allowed"));
}
void tst_QXmppRosterManager::testRemoveItem()
{
TestClient test;
test.configuration().setJid(QStringLiteral("juliet@capulet.lit"));
auto *rosterManager = test.addNewExtension<QXmppRosterManager>(&test);
auto future = rosterManager->removeRosterItem("contact@example.org");
test.expect("<iq id='qxmpp1' to='capulet.lit' type='set'><query xmlns='jabber:iq:roster'><item jid='contact@example.org' subscription='remove'/></query></iq>");
test.inject<QString>("<iq id='qxmpp1' from='capulet.lit' type='result'/>");
expectFutureVariant<QXmpp::Success>(future);
future = rosterManager->removeRosterItem("contact@example.org");
test.expect("<iq id='qxmpp1' to='capulet.lit' type='set'><query xmlns='jabber:iq:roster'><item jid='contact@example.org' subscription='remove'/></query></iq>");
test.inject<QString>(R"(
<iq id='qxmpp1' from='capulet.lit' type='error'>
<error type='cancel'>
<item-not-found xmlns='urn:ietf:params:xml:ns:xmpp-stanzas'/>
<text xmlns='urn:ietf:params:xml:ns:xmpp-stanzas'>Not found</text>
</error>
</iq>)");
auto err = expectFutureVariant<QXmppError>(future);
auto error = err.value<QXmppStanza::Error>().value();
QCOMPARE(error.type(), QXmppStanza::Error::Cancel);
QCOMPARE(error.text(), QStringLiteral("Not found"));
}
QTEST_MAIN(tst_QXmppRosterManager)
#include "tst_qxmpprostermanager.moc"
|
