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

state changed notification

Browse Source
This commit is contained in:
Simon Stürz 2016-03-04 11:46:13 +01:00 committed by Michael Zanetti
parent a225423b73
commit b841fd03d6
1 changed files with 13 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
tests/auto/jsonrpc/testjsonrpc.cpp
View File

@ -213,7 +213,9 @@ void TestJSONRPC::stateChangeEmitsNotifications()
QNetworkReply *reply = nam.get(request); QNetworkReply *reply = nam.get(request);
reply->deleteLater(); reply->deleteLater();
clientSpy.wait(); qDebug() << "Waiting for notifications";
clientSpy.wait(8000);
// Make sure the notification contains all the stuff we expect // Make sure the notification contains all the stuff we expect
QVariantList stateChangedVariants = checkNotifications(clientSpy, "Devices.StateChanged"); QVariantList stateChangedVariants = checkNotifications(clientSpy, "Devices.StateChanged");
@ -221,13 +223,15 @@ void TestJSONRPC::stateChangeEmitsNotifications()
qDebug() << "got" << stateChangedVariants.count() << "Devices.StateChanged notifications"; qDebug() << "got" << stateChangedVariants.count() << "Devices.StateChanged notifications";
foreach (const QVariant &stateChangedVariant, stateChangedVariants) { foreach (const QVariant &stateChangedVariant, stateChangedVariants) {
qDebug() << QJsonDocument::fromVariant(stateChangedVariant).toJson();
if (stateChangedVariant.toMap().value("params").toMap().value("stateTypeId").toUuid() == stateTypeId) { if (stateChangedVariant.toMap().value("params").toMap().value("stateTypeId").toUuid() == stateTypeId) {
found = true; found = true;
QCOMPARE(stateChangedVariant.toMap().value("params").toMap().value("value").toInt(), newVal); QCOMPARE(stateChangedVariant.toMap().value("params").toMap().value("value").toInt(), newVal);
break; break;
} }
} }
if (!found)
qDebug() << QJsonDocument::fromVariant(stateChangedVariants).toJson();
QVERIFY2(found, "Could not find the correct Devices.StateChanged notification"); QVERIFY2(found, "Could not find the correct Devices.StateChanged notification");
// Make sure the logg notification contains all the stuff we expect // Make sure the logg notification contains all the stuff we expect
@ -246,9 +250,10 @@ void TestJSONRPC::stateChangeEmitsNotifications()
break; break;
} }
} }
QVERIFY2(found, "Could not find the correct Events.EventTriggered notification"); if (!found)
qDebug() << QJsonDocument::fromVariant(loggEntryAddedVariants).toJson();
QVERIFY2(found, "Could not find the corresponding Logging.LogEntryAdded notification");
// Make sure the notification contains all the stuff we expect // Make sure the notification contains all the stuff we expect
@ -265,7 +270,10 @@ void TestJSONRPC::stateChangeEmitsNotifications()
break; break;
} }
} }
QVERIFY2(found, "Could not find the correct Events.EventTriggered notification"); if (!found)
qDebug() << QJsonDocument::fromVariant(eventTriggeredVariants).toJson();
QVERIFY2(found, "Could not find the corresponding Events.EventTriggered notification");
// Now turn off notifications // Now turn off notifications
QCOMPARE(disableNotifications(), true); QCOMPARE(disableNotifications(), true);