ETM-Schurig/powersync-core
Archived
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

don't use QTRY_COMPARE because we need to build on xenial

Browse Source
This commit is contained in:
Michael Zanetti 2018-11-28 21:02:16 +01:00
parent 0d3e868cc1
commit 7987338241
1 changed files with 18 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
tests/auto/mqttbroker/testmqttbroker.cpp
View File

@ -101,8 +101,11 @@ void TestMqttBroker::testServerConfigurationAPI()
QSignalSpy connectedSpy(mqttClient, &MqttClient::connected); QSignalSpy connectedSpy(mqttClient, &MqttClient::connected);
QSignalSpy disconnectedSpy(mqttClient, &MqttClient::disconnected); QSignalSpy disconnectedSpy(mqttClient, &MqttClient::disconnected);
mqttClient->connectToHost("127.0.0.1", 1885); mqttClient->connectToHost("127.0.0.1", 1885);
QTRY_VERIFY2(connectedSpy.count() == 1, "Mqtt client didn't connect"); if (connectedSpy.count() == 0) {
QTRY_VERIFY2(connectedSpy.first().at(0).value<Mqtt::ConnectReturnCode>() == Mqtt::ConnectReturnCodeAccepted, "Connection not accepted"); connectedSpy.wait();
}
QVERIFY2(connectedSpy.count() == 1, "Mqtt client didn't connect");
QVERIFY2(connectedSpy.first().at(0).value<Mqtt::ConnectReturnCode>() == Mqtt::ConnectReturnCodeAccepted, "Connection not accepted");
// Update same configuration to a different port // Update same configuration to a different port
notificationsSpy.clear(); notificationsSpy.clear();
@ -135,8 +138,11 @@ void TestMqttBroker::testServerConfigurationAPI()
connectedSpy.clear(); connectedSpy.clear();
disconnectedSpy.clear(); disconnectedSpy.clear();
mqttClient->connectToHost("127.0.0.1", 1886); mqttClient->connectToHost("127.0.0.1", 1886);
QTRY_VERIFY2(connectedSpy.count() == 1, "Mqtt client didn't connect"); if (connectedSpy.count() == 0) {
QTRY_VERIFY2(connectedSpy.first().at(0).value<Mqtt::ConnectReturnCode>() == Mqtt::ConnectReturnCodeAccepted, "Connection not accepted"); connectedSpy.wait();
}
QVERIFY2(connectedSpy.count() == 1, "Mqtt client didn't connect");
QVERIFY2(connectedSpy.first().at(0).value<Mqtt::ConnectReturnCode>() == Mqtt::ConnectReturnCodeAccepted, "Connection not accepted");
// Delete the server config // Delete the server config
notificationsSpy.clear(); notificationsSpy.clear();
@ -178,7 +184,10 @@ void TestMqttBroker::testPolicyConfigurationAPI()
QSignalSpy connectedSpy(mqttClient, &MqttClient::connected); QSignalSpy connectedSpy(mqttClient, &MqttClient::connected);
QSignalSpy disconnectedSpy(mqttClient, &MqttClient::disconnected); QSignalSpy disconnectedSpy(mqttClient, &MqttClient::disconnected);
mqttClient->connectToHost("127.0.0.1", 1883); mqttClient->connectToHost("127.0.0.1", 1883);
QTRY_VERIFY2(connectedSpy.count() == 1, "Mqtt client didn't connect"); if (connectedSpy.count() == 0) {
connectedSpy.wait();
}
QVERIFY2(connectedSpy.count() == 1, "Mqtt client didn't connect");
QCOMPARE(connectedSpy.first().at(0).value<Mqtt::ConnectReturnCode>(), Mqtt::ConnectReturnCodeIdentifierRejected); QCOMPARE(connectedSpy.first().at(0).value<Mqtt::ConnectReturnCode>(), Mqtt::ConnectReturnCodeIdentifierRejected);
QCOMPARE(disconnectedSpy.count(), 1); // Connection should drop QCOMPARE(disconnectedSpy.count(), 1); // Connection should drop
@ -322,7 +331,10 @@ void TestMqttBroker::testConnectAuthentication()
QSignalSpy connectedSpy(mqttClient, &MqttClient::connected); QSignalSpy connectedSpy(mqttClient, &MqttClient::connected);
QSignalSpy disconnectedSpy(mqttClient, &MqttClient::disconnected); QSignalSpy disconnectedSpy(mqttClient, &MqttClient::disconnected);
mqttClient->connectToHost("127.0.0.1", 1883); mqttClient->connectToHost("127.0.0.1", 1883);
QTRY_VERIFY2(connectedSpy.count() == 1, "Mqtt client didn't connect"); if (connectedSpy.count() == 0) {
connectedSpy.wait();
}
QVERIFY2(connectedSpy.count() == 1, "Mqtt client didn't connect");
QCOMPARE(connectedSpy.first().at(0).value<Mqtt::ConnectReturnCode>(), connectReturnCode); QCOMPARE(connectedSpy.first().at(0).value<Mqtt::ConnectReturnCode>(), connectReturnCode);
if (connectReturnCode != Mqtt::ConnectReturnCodeAccepted) { if (connectReturnCode != Mqtt::ConnectReturnCodeAccepted) {
QVERIFY2(disconnectedSpy.count() == 1 || disconnectedSpy.wait(), "Client did get disconnected"); QVERIFY2(disconnectedSpy.count() == 1 || disconnectedSpy.wait(), "Client did get disconnected");