summaryrefslogtreecommitdiffstats
path: root/tests/auto/conformance/tst_conformance.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'tests/auto/conformance/tst_conformance.cpp')
-rw-r--r--tests/auto/conformance/tst_conformance.cpp104
1 files changed, 78 insertions, 26 deletions
diff --git a/tests/auto/conformance/tst_conformance.cpp b/tests/auto/conformance/tst_conformance.cpp
index ca3cc61..d093637 100644
--- a/tests/auto/conformance/tst_conformance.cpp
+++ b/tests/auto/conformance/tst_conformance.cpp
@@ -50,15 +50,19 @@ private Q_SLOTS:
void initTestCase();
void cleanupTestCase();
+ void basic_test_data();
void basic_test();
void retained_message_test_data();
void retained_message_test();
+ void will_message_test_data();
void will_message_test();
void zero_length_clientid_test_data();
void zero_length_clientid_test();
+ void offline_message_queueing_test_data();
void offline_message_queueing_test();
// overlapping_subscriptions_test // Skipped at the module emits multiple messages for each sub
// keepalive_test // The module handles sending ping requests
+ void subscribe_failure_test_data();
void subscribe_failure_test();
private:
QProcess m_brokerProcess;
@@ -83,9 +87,13 @@ void Tst_MqttConformance::cleanupTestCase()
{
}
+DefaultVersionTestData(Tst_MqttConformance::basic_test_data)
+
void Tst_MqttConformance::basic_test()
{
- QMqttClient client;
+ QFETCH(QMqttClient::ProtocolVersion, mqttVersion);
+
+ VersionClient(mqttVersion, client);
client.setHostname(m_testBroker);
client.setPort(m_port);
@@ -96,20 +104,32 @@ void Tst_MqttConformance::basic_test()
client.disconnectFromHost();
QTRY_VERIFY2(client.state() == QMqttClient::Disconnected, "Could not disconnect from broker");
+ // The MQTT 5 broker might provide topic alias by default. Hence, disable it.
+ if (mqttVersion == QMqttClient::MQTT_5_0) {
+ QMqttConnectionProperties p;
+ p.setMaximumTopicAlias(0);
+ client.setConnectionProperties(p);
+ }
+
client.connectToHost();
QTRY_VERIFY2(client.state() == QMqttClient::Connected, "Could not connect to broker");
const QString topic(QLatin1String("Qt/conformance"));
- auto sub = client.subscribe(topic, 2);
+ auto sub = client.subscribe(topic, 1);
QTRY_VERIFY2(sub->state() == QMqttSubscription::Subscribed, "Could not subscribe");
int msgCount = 0;
- connect(sub, &QMqttSubscription::messageReceived, this, [&msgCount](QMqttMessage msg) {
- qDebug() << "Message received:" << msg.payload();
+ connect(sub, &QMqttSubscription::messageReceived, this, [&msgCount](QMqttMessage) {
msgCount++;
});
+ connect(&client, &QMqttClient::messageReceived, this, [](const QByteArray &message, const QMqttTopicName &topic)
+ {
+ Q_UNUSED(message)
+ Q_UNUSED(topic)
+ });
+
client.publish(topic, "qos 0", 0);
client.publish(topic, "qos 1", 1);
client.publish(topic, "qos 2", 2);
@@ -126,22 +146,28 @@ void Tst_MqttConformance::basic_test()
void Tst_MqttConformance::retained_message_test_data()
{
+ QTest::addColumn<QMqttClient::ProtocolVersion>("mqttVersion");
QTest::addColumn<QStringList>("messages");
QTest::addColumn<int>("expectedMsgCount");
- const QStringList topics1{"qos 0", "qos 1", "qos 2"};
- const QStringList topics2{"", "", ""};
+ QList<QMqttClient::ProtocolVersion> versions{QMqttClient::MQTT_3_1_1, QMqttClient::MQTT_5_0};
+
+ for (int i = 0; i < 2; ++i) {
+ const QStringList topics1{"qos 0", "qos 1", "qos 2"};
+ const QStringList topics2{"", "", ""};
- QTest::newRow("receiveRetain") << topics1 << 3;
- QTest::newRow("clearRetain") << topics2 << 0;
+ QTest::newRow(qPrintable(QString::number(versions[i]) + ":receiveRetain")) << versions[i] << topics1 << 3;
+ QTest::newRow(qPrintable(QString::number(versions[i]) + ":clearRetain")) << versions[i] << topics2 << 0;
+ }
}
void Tst_MqttConformance::retained_message_test()
{
+ QFETCH(QMqttClient::ProtocolVersion, mqttVersion);
QFETCH(QStringList, messages);
QFETCH(int, expectedMsgCount);
- QMqttClient client;
+ VersionClient(mqttVersion, client);
client.setHostname(m_testBroker);
client.setPort(m_port);
@@ -149,8 +175,8 @@ void Tst_MqttConformance::retained_message_test()
client.connectToHost();
QTRY_VERIFY2(client.state() == QMqttClient::Connected, "Could not connect to broker");
- const QStringList topics{"Qt/tests/retain1", "Qt/tests/retain2", "Qt/tests2/retain1"};
- const QString subTop{"Qt/#"}; // ### TODO: The test suite uses {"Qt/+/+"}; but we do not support ++ yet.
+ const QStringList topics{"Qt/conformance/tests/retain1", "Qt/conformance/tests/retain2", "Qt/conformance/tests2/retain1"};
+ const QString subTop{"Qt/conformance/#"}; // ### TODO: The test suite uses {"Qt/+/+"}; but we do not support ++ yet.
client.publish(topics[0], messages[0].toLocal8Bit(), 0, true);
client.publish(topics[1], messages[1].toLocal8Bit(), 1, true);
@@ -181,14 +207,18 @@ void Tst_MqttConformance::retained_message_test()
QTRY_VERIFY2(client.state() == QMqttClient::Disconnected, "Could not disconnect");
}
+DefaultVersionTestData(Tst_MqttConformance::will_message_test_data)
+
void Tst_MqttConformance::will_message_test()
{
- QMqttClient client;
+ QFETCH(QMqttClient::ProtocolVersion, mqttVersion);
+
+ VersionClient(mqttVersion, client);
client.setHostname(m_testBroker);
client.setPort(m_port);
- const QString wTopic{"Qt/willtest"};
+ const QString wTopic{"Qt/conformance/willtest"};
const QByteArray wMessage{"client got lost"};
client.setWillMessage(wMessage);
@@ -199,7 +229,7 @@ void Tst_MqttConformance::will_message_test()
QTRY_VERIFY2(client.state() == QMqttClient::Connected, "Could not connect to broker");
- QMqttClient recipient;
+ VersionClient(mqttVersion, recipient);
recipient.setHostname(m_testBroker);
recipient.setPort(m_port);
recipient.connectToHost();
@@ -221,17 +251,23 @@ void Tst_MqttConformance::will_message_test()
void Tst_MqttConformance::zero_length_clientid_test_data()
{
+ QTest::addColumn<QMqttClient::ProtocolVersion>("mqttVersion");
QTest::addColumn<bool>("session");
- QTest::newRow("noncleanSession") << false;
- QTest::newRow("cleanSession") << true;
+ QList<QMqttClient::ProtocolVersion> versions{QMqttClient::MQTT_3_1_1, QMqttClient::MQTT_5_0};
+
+ for (int i = 0; i < 2; ++i) {
+ QTest::newRow(qPrintable(QString::number(versions[i]) + ":noncleanSession")) << versions[i] << false;
+ QTest::newRow(qPrintable(QString::number(versions[i]) + ":cleanSession")) << versions[i] << true;
+ }
}
void Tst_MqttConformance::zero_length_clientid_test()
{
+ QFETCH(QMqttClient::ProtocolVersion, mqttVersion);
QFETCH(bool, session);
- QMqttClient client;
+ VersionClient(mqttVersion, client);
client.setHostname(m_testBroker);
client.setPort(m_port);
@@ -242,7 +278,13 @@ void Tst_MqttConformance::zero_length_clientid_test()
QVERIFY2(client.state() == QMqttClient::Connecting, "Could not set state to connecting.");
if (!session) {
- QTRY_VERIFY2(client.state() == QMqttClient::Disconnected, "Sessions with empty client should not be allowed.");
+ if (client.protocolVersion() == QMqttClient::MQTT_5_0) {
+ // For MQTT 5 the broker creates an ID and returns it in CONNACK
+ QTRY_VERIFY2(client.state() == QMqttClient::Connected, "Could not connect to broker.");
+ QVERIFY(!client.clientId().isEmpty());
+ } else {
+ QTRY_VERIFY2(client.state() == QMqttClient::Disconnected, "Sessions with empty client should not be allowed.");
+ }
} else {
QTRY_VERIFY2(client.state() == QMqttClient::Connected, "Could not connect to broker.");
client.disconnectFromHost();
@@ -250,9 +292,12 @@ void Tst_MqttConformance::zero_length_clientid_test()
}
}
+DefaultVersionTestData(Tst_MqttConformance::offline_message_queueing_test_data)
+
void Tst_MqttConformance::offline_message_queueing_test()
{
- QMqttClient client;
+ QFETCH(QMqttClient::ProtocolVersion, mqttVersion);
+ VersionClient(mqttVersion, client);
client.setHostname(m_testBroker);
client.setPort(m_port);
@@ -260,23 +305,23 @@ void Tst_MqttConformance::offline_message_queueing_test()
client.connectToHost();
QTRY_VERIFY2(client.state() == QMqttClient::Connected, "Could not connect to broker.");
- const QString subTopic{"Qt/offline/#"};
+ const QString subTopic{"Qt/conformance/offline/#"};
auto sub = client.subscribe(subTopic, 2);
Q_UNUSED(sub);
client.disconnectFromHost();
QTRY_VERIFY2(client.state() == QMqttClient::Disconnected, "Could not disconnect.");
- QMqttClient publisher;
+ VersionClient(mqttVersion, publisher);
publisher.setHostname(m_testBroker);
publisher.setPort(m_port);
publisher.connectToHost();
QTRY_VERIFY2(publisher.state() == QMqttClient::Connected, "Could not connect to broker.");
QSignalSpy pubCounter(&publisher, SIGNAL(messageSent(qint32)));
- publisher.publish(QLatin1String("Qt/offline/foo/bar"), "msg1", 1);
- publisher.publish(QLatin1String("Qt/offline/foo/bar2"), "msg2", 1);
- publisher.publish(QLatin1String("Qt/offline/foo2/bar"), "msg3", 1);
+ publisher.publish(QLatin1String("Qt/conformance/offline/foo/bar"), "msg1", 1);
+ publisher.publish(QLatin1String("Qt/conformance/offline/foo/bar2"), "msg2", 1);
+ publisher.publish(QLatin1String("Qt/conformance/offline/foo2/bar"), "msg3", 1);
QTRY_VERIFY2(pubCounter.size() == 3, "Could not publish all messages.");
publisher.disconnectFromHost();
@@ -287,17 +332,24 @@ void Tst_MqttConformance::offline_message_queueing_test()
client.connectToHost();
QTRY_VERIFY2(client.state() == QMqttClient::Connected, "Could not connect to broker.");
+ // ### TODO: MQTT5 Investigate / Fixme
+ if (client.protocolVersion() == QMqttClient::MQTT_5_0)
+ QEXPECT_FAIL("", "Offline messages seem not supported with MQTT5", Continue);
QTRY_VERIFY2(receiveCounter.size() == 3, "Did not receive all offline messages.");
client.disconnectFromHost();
QTRY_VERIFY2(client.state() == QMqttClient::Disconnected, "Could not disconnect.");
}
+DefaultVersionTestData(Tst_MqttConformance::subscribe_failure_test_data)
+
void Tst_MqttConformance::subscribe_failure_test()
{
- QMqttClient client;
+ QFETCH(QMqttClient::ProtocolVersion, mqttVersion);
+
+ VersionClient(mqttVersion, client);
- const QByteArray forbiddenTopic{"nosubscribe"};
+ const QByteArray forbiddenTopic{"Qt/conformance/nosubscribe"};
// We do not have a test broker with forbidden topics.
QSKIP("Missing infrastructure to set forbidden topics");
generated by cgit v1.2.3 (git 2.25.1) at 2024-06-13 15:57:00 +0000