Skip to content
Snippets Groups Projects
Commit 8065504b authored by Sébastien Blin's avatar Sébastien Blin Committed by Adrien Béraud
Browse files

tests: fix testAddAcceptOfflineThenConnects

Change-Id: I0e0248d167af0e81cef828ef3c1e3746d974aaed
parent df918256
No related branches found
No related tags found
No related merge requests found
...@@ -584,12 +584,23 @@ ConversationMembersEventTest::testAddAcceptOfflineThenConnects() ...@@ -584,12 +584,23 @@ ConversationMembersEventTest::testAddAcceptOfflineThenConnects()
requestReceived = true; requestReceived = true;
cv.notify_one(); cv.notify_one();
})); }));
bool aliceStopped = false;
confHandlers.insert(
libjami::exportable_callback<libjami::ConfigurationSignal::VolatileDetailsChanged>(
[&](const std::string&, const std::map<std::string, std::string>&) {
auto details = aliceAccount->getVolatileAccountDetails();
auto daemonStatus = details[libjami::Account::ConfProperties::Registration::STATUS];
if (daemonStatus == "UNREGISTERED")
aliceStopped = true;
cv.notify_one();
}));
libjami::registerSignalHandlers(confHandlers); libjami::registerSignalHandlers(confHandlers);
libjami::addConversationMember(aliceId, convId, bobUri); libjami::addConversationMember(aliceId, convId, bobUri);
CPPUNIT_ASSERT(cv.wait_for(lk, 60s, [&] { return requestReceived; })); CPPUNIT_ASSERT(cv.wait_for(lk, 60s, [&] { return requestReceived; }));
Manager::instance().sendRegister(aliceId, false); // This avoid to sync immediately Manager::instance().sendRegister(aliceId, false); // This avoid to sync immediately
CPPUNIT_ASSERT(cv.wait_for(lk, 60s, [&] { return aliceStopped; }));
libjami::acceptConversationRequest(bobId, convId); libjami::acceptConversationRequest(bobId, convId);
std::this_thread::sleep_for(40s); // Wait for negotiation to timeout std::this_thread::sleep_for(40s); // Wait for negotiation to timeout
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment