/* * conference-event-tester.cpp * Copyright (C) 2017 Belledonne Communications SARL * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation, either version 3 of the License, or * (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program. If not, see . */ #include #include #include "linphone/core.h" #include "private.h" #include "liblinphone_tester.h" #include "conference/conference-listener.h" #include "conference/local-conference.h" #include "conference/local-conference-event-handler.h" #include "conference/participant.h" #include "conference/remote-conference-event-handler.h" using namespace LinphonePrivate; using namespace std; static const char *first_notify = \ " "\ " "\ " "\ " "\ " Agenda: This month's goals"\ " "\ " "\ " http://sharepoint/salesgroup/"\ " web-page"\ " "\ " "\ " "\ " "\ " "\ " 33"\ " "\ " "\ " "\ " "\ " Bob Hoskins"\ " "\ " "\ " Bob's Laptop"\ " disconnected"\ " departed"\ " "\ " 2005-03-04T20:00:00Z"\ " bad voice quality"\ " sip:mike@example.com"\ " "\ " "\ " "\ " main audio"\ " audio"\ " 34567"\ " 432424"\ " sendrecv"\ " "\ " "\ " "\ " "\ " "\ " Alice"\ " "\ " admin"\ " participant"\ " "\ " "\ " "\ " connected"\ " dialed-out"\ " "\ " 2005-03-04T20:00:00Z"\ " sip:mike@example.com"\ " "\ " "\ " "\ " main audio"\ " audio"\ " 34567"\ " 534232"\ " sendrecv"\ " "\ " "\ " "\ " "\ " "; static const char *participant_added_notify = \ " "\ " "\ " "\ " "\ " Agenda: This month's goals"\ " "\ " "\ " http://sharepoint/salesgroup/"\ " web-page"\ " "\ " "\ " "\ " "\ " "\ " 33"\ " "\ " "\ " "\ " "\ " Bob Hoskins"\ " "\ " "\ " Frank's Laptop"\ " disconnected"\ " departed"\ " "\ " 2005-03-04T20:00:00Z"\ " bad voice quality"\ " sip:mike@example.com"\ " "\ " "\ " "\ " main audio"\ " audio"\ " 34567"\ " 432424"\ " sendrecv"\ " "\ " "\ " "\ " "\ " "; static const char *participant_not_added_notify = \ " "\ " "\ " "\ " "\ " Agenda: This month's goals"\ " "\ " "\ " http://sharepoint/salesgroup/"\ " web-page"\ " "\ " "\ " "\ " "\ " "\ " 33"\ " "\ " "\ " "\ " "\ " Bob Hoskins"\ " "\ " "\ " Frank's Laptop"\ " disconnected"\ " departed"\ " "\ " 2005-03-04T20:00:00Z"\ " bad voice quality"\ " sip:mike@example.com"\ " "\ " "\ " "\ " main audio"\ " audio"\ " 34567"\ " 432424"\ " sendrecv"\ " "\ " "\ " "\ " "\ " "; static const char *participant_deleted_notify = \ " "\ " "\ " "\ " "\ " Agenda: This month's goals"\ " "\ " "\ " http://sharepoint/salesgroup/"\ " web-page"\ " "\ " "\ " "\ " "\ " "\ " 33"\ " "\ " "\ " "\ " "\ " Bob Hoskins"\ " "\ " "\ " Bob's Laptop"\ " disconnected"\ " departed"\ " "\ " 2005-03-04T20:00:00Z"\ " bad voice quality"\ " sip:mike@example.com"\ " "\ " "\ " "\ " main audio"\ " audio"\ " 34567"\ " 432424"\ " sendrecv"\ " "\ " "\ " "\ " "\ " "; static const char *participant_admined_notify = \ " "\ " "\ " "\ " "\ " Agenda: This month's goals"\ " "\ " "\ " http://sharepoint/salesgroup/"\ " web-page"\ " "\ " "\ " "\ " "\ " "\ " 33"\ " "\ " "\ " "\ " "\ " Bob Hoskins"\ " "\ " participant"\ " admin"\ " "\ " "\ " "\ " Bob's Laptop"\ " disconnected"\ " departed"\ " "\ " 2005-03-04T20:00:00Z"\ " bad voice quality"\ " sip:mike@example.com"\ " "\ " "\ " "\ " main audio"\ " audio"\ " 34567"\ " 432424"\ " sendrecv"\ " "\ " "\ " "\ " "\ " "; static const char *participant_unadmined_notify = \ " "\ " "\ " "\ " "\ " Agenda: This month's goals"\ " "\ " "\ " http://sharepoint/salesgroup/"\ " web-page"\ " "\ " "\ " "\ " "\ " "\ " 33"\ " "\ " "\ " "\ " "\ " Alice Hoskins"\ " "\ " participant"\ " "\ " "\ " "\ " Alice's Laptop"\ " disconnected"\ " departed"\ " "\ " 2005-03-04T20:00:00Z"\ " bad voice quality"\ " sip:mike@example.com"\ " "\ " "\ " "\ " main audio"\ " audio"\ " 34567"\ " 432424"\ " sendrecv"\ " "\ " "\ " "\ " "\ " "; static const char *bobUri = "sip:bob@example.com"; static const char *aliceUri = "sip:alice@example.com"; static const char *frankUri = "sip:frank@example.com"; static const char *confUri = "sips:conf233@example.com"; class ConferenceEventTester : public ConferenceListener { public: ConferenceEventTester (LinphoneCore *core, const Address &confAddr); ~ConferenceEventTester (); private: void onConferenceCreated (const Address &addr) override; void onConferenceTerminated (const Address &addr) override; void onParticipantAdded (const Address &addr) override; void onParticipantRemoved (const Address &addr) override; void onParticipantSetAdmin (const Address &addr, bool isAdmin) override; void onSubjectChanged(const std::string &subject) override; public: RemoteConferenceEventHandler *handler; map participants; }; ConferenceEventTester::ConferenceEventTester (LinphoneCore *core, const Address &confAddr) { handler = new RemoteConferenceEventHandler(core, this); } ConferenceEventTester::~ConferenceEventTester () { delete handler; } void ConferenceEventTester::onConferenceCreated (const Address &addr) {} void ConferenceEventTester::onConferenceTerminated (const Address &addr) {} void ConferenceEventTester::onParticipantAdded (const Address &addr) { participants.insert(pair(addr.asString(), false)); } void ConferenceEventTester::onParticipantRemoved (const Address &addr) { participants.erase(addr.asString()); } void ConferenceEventTester::onParticipantSetAdmin (const Address &addr, bool isAdmin) { auto it = participants.find(addr.asString()); if (it != participants.end()) it->second = isAdmin; } void first_notify_parsing() { LinphoneCoreManager *marie = linphone_core_manager_new("marie_rc"); LinphoneAddress *confAddress = linphone_core_interpret_url(marie->lc, confUri); char *confAddressStr = linphone_address_as_string(confAddress); Address addr(confAddressStr); bctbx_free(confAddressStr); linphone_address_unref(confAddress); ConferenceEventTester tester(marie->lc, addr); LinphoneAddress *bobAddr = linphone_core_interpret_url(marie->lc, bobUri); LinphoneAddress *aliceAddr = linphone_core_interpret_url(marie->lc, aliceUri); size_t size = strlen(first_notify) + strlen(confUri); char *notify = new char[size]; snprintf(notify, size, first_notify, confUri); tester.handler->notifyReceived(notify); delete[] notify; BC_ASSERT_EQUAL(tester.participants.size(), 2, int, "%d"); BC_ASSERT_TRUE(tester.participants.find(linphone_address_as_string(bobAddr)) != tester.participants.end()); BC_ASSERT_TRUE(tester.participants.find(linphone_address_as_string(aliceAddr)) != tester.participants.end()); BC_ASSERT_TRUE(!tester.participants.find(linphone_address_as_string(bobAddr))->second); BC_ASSERT_TRUE(tester.participants.find(linphone_address_as_string(aliceAddr))->second); linphone_address_unref(bobAddr); linphone_address_unref(aliceAddr); linphone_core_manager_destroy(marie); } void first_notify_parsing_wrong_conf() { LinphoneCoreManager *marie = linphone_core_manager_new("marie_rc"); LinphoneAddress *confAddress = linphone_core_interpret_url(marie->lc, "sips:conf322@example.com"); char *confAddressStr = linphone_address_as_string(confAddress); Address addr(confAddressStr); bctbx_free(confAddressStr); linphone_address_unref(confAddress); ConferenceEventTester tester(marie->lc, addr); LinphoneAddress *bobAddr = linphone_core_interpret_url(marie->lc, bobUri); LinphoneAddress *aliceAddr = linphone_core_interpret_url(marie->lc, aliceUri); size_t size = strlen(first_notify) + strlen(confUri); char *notify = new char[size]; snprintf(notify, size, first_notify, confUri); tester.handler->notifyReceived(notify); delete[] notify; BC_ASSERT_EQUAL(tester.participants.size(), 0, int, "%d"); BC_ASSERT_FALSE(tester.participants.find(linphone_address_as_string(bobAddr)) != tester.participants.end()); BC_ASSERT_FALSE(tester.participants.find(linphone_address_as_string(aliceAddr)) != tester.participants.end()); linphone_address_unref(bobAddr); linphone_address_unref(aliceAddr); linphone_core_manager_destroy(marie); } void participant_added_parsing() { LinphoneCoreManager *marie = linphone_core_manager_new("marie_rc"); LinphoneAddress *confAddress = linphone_core_interpret_url(marie->lc, confUri); char *confAddressStr = linphone_address_as_string(confAddress); Address addr(confAddressStr); bctbx_free(confAddressStr); linphone_address_unref(confAddress); ConferenceEventTester tester(marie->lc, addr); LinphoneAddress *bobAddr = linphone_core_interpret_url(marie->lc, bobUri); LinphoneAddress *aliceAddr = linphone_core_interpret_url(marie->lc, aliceUri); LinphoneAddress *frankAddr = linphone_core_interpret_url(marie->lc, frankUri); size_t size = strlen(first_notify) + strlen(confUri); char *notify = new char[size]; size_t size2 = strlen(participant_added_notify) + strlen(confUri); char *notify_added = new char[size2]; snprintf(notify, size, first_notify, confUri); tester.handler->notifyReceived(notify); delete[] notify; BC_ASSERT_EQUAL(tester.participants.size(), 2, int, "%d"); BC_ASSERT_TRUE(tester.participants.find(linphone_address_as_string(bobAddr)) != tester.participants.end()); BC_ASSERT_TRUE(tester.participants.find(linphone_address_as_string(aliceAddr)) != tester.participants.end()); BC_ASSERT_TRUE(!tester.participants.find(linphone_address_as_string(bobAddr))->second); BC_ASSERT_TRUE(tester.participants.find(linphone_address_as_string(aliceAddr))->second); snprintf(notify_added, size2, participant_added_notify, confUri); tester.handler->notifyReceived(notify_added); delete[] notify_added; BC_ASSERT_EQUAL(tester.participants.size(), 3, int, "%d"); BC_ASSERT_TRUE(tester.participants.find(linphone_address_as_string(frankAddr)) != tester.participants.end()); BC_ASSERT_TRUE(!tester.participants.find(linphone_address_as_string(frankAddr))->second); linphone_address_unref(bobAddr); linphone_address_unref(aliceAddr); linphone_address_unref(frankAddr); linphone_core_manager_destroy(marie); } void participant_not_added_parsing() { LinphoneCoreManager *marie = linphone_core_manager_new("marie_rc"); LinphoneAddress *confAddress = linphone_core_interpret_url(marie->lc, confUri); char *confAddressStr = linphone_address_as_string(confAddress); Address addr(confAddressStr); bctbx_free(confAddressStr); linphone_address_unref(confAddress); ConferenceEventTester tester(marie->lc, addr); LinphoneAddress *bobAddr = linphone_core_interpret_url(marie->lc, bobUri); LinphoneAddress *aliceAddr = linphone_core_interpret_url(marie->lc, aliceUri); LinphoneAddress *frankAddr = linphone_core_interpret_url(marie->lc, frankUri); size_t size = strlen(first_notify) + strlen(confUri); char *notify = new char[size]; size_t size2 = strlen(participant_not_added_notify) + strlen(confUri); char *notify_not_added = new char[size2]; snprintf(notify, size, first_notify, confUri); tester.handler->notifyReceived(notify); delete[] notify; BC_ASSERT_EQUAL(tester.participants.size(), 2, int, "%d"); BC_ASSERT_TRUE(tester.participants.find(linphone_address_as_string(bobAddr)) != tester.participants.end()); BC_ASSERT_TRUE(tester.participants.find(linphone_address_as_string(aliceAddr)) != tester.participants.end()); BC_ASSERT_TRUE(!tester.participants.find(linphone_address_as_string(bobAddr))->second); BC_ASSERT_TRUE(tester.participants.find(linphone_address_as_string(aliceAddr))->second); snprintf(notify_not_added, size2, participant_not_added_notify, confUri); tester.handler->notifyReceived(notify_not_added); delete[] notify_not_added; BC_ASSERT_EQUAL(tester.participants.size(), 2, int, "%d"); BC_ASSERT_FALSE(tester.participants.find(linphone_address_as_string(frankAddr)) != tester.participants.end()); linphone_address_unref(bobAddr); linphone_address_unref(aliceAddr); linphone_address_unref(frankAddr); linphone_core_manager_destroy(marie); } void participant_deleted_parsing() { LinphoneCoreManager *marie = linphone_core_manager_new("marie_rc"); LinphoneAddress *confAddress = linphone_core_interpret_url(marie->lc, confUri); char *confAddressStr = linphone_address_as_string(confAddress); Address addr(confAddressStr); bctbx_free(confAddressStr); linphone_address_unref(confAddress); ConferenceEventTester tester(marie->lc, addr); LinphoneAddress *bobAddr = linphone_core_interpret_url(marie->lc, bobUri); LinphoneAddress *aliceAddr = linphone_core_interpret_url(marie->lc, aliceUri); size_t size = strlen(first_notify) + strlen(confUri); char *notify = new char[size]; size_t size2 = strlen(participant_deleted_notify) + strlen(confUri); char *notify_deleted = new char[size2]; snprintf(notify, size, first_notify, confUri); tester.handler->notifyReceived(notify); delete[] notify; BC_ASSERT_EQUAL(tester.participants.size(), 2, int, "%d"); BC_ASSERT_TRUE(tester.participants.find(linphone_address_as_string(bobAddr)) != tester.participants.end()); BC_ASSERT_TRUE(tester.participants.find(linphone_address_as_string(aliceAddr)) != tester.participants.end()); BC_ASSERT_TRUE(!tester.participants.find(linphone_address_as_string(bobAddr))->second); BC_ASSERT_TRUE(tester.participants.find(linphone_address_as_string(aliceAddr))->second); snprintf(notify_deleted, size2, participant_deleted_notify, confUri); tester.handler->notifyReceived(notify_deleted); delete[] notify_deleted; BC_ASSERT_EQUAL(tester.participants.size(), 1, int, "%d"); BC_ASSERT_FALSE(tester.participants.find(linphone_address_as_string(bobAddr)) != tester.participants.end()); linphone_address_unref(bobAddr); linphone_address_unref(aliceAddr); linphone_core_manager_destroy(marie); } void participant_admined_parsing() { LinphoneCoreManager *marie = linphone_core_manager_new("marie_rc"); LinphoneAddress *confAddress = linphone_core_interpret_url(marie->lc, confUri); char *confAddressStr = linphone_address_as_string(confAddress); Address addr(confAddressStr); bctbx_free(confAddressStr); linphone_address_unref(confAddress); ConferenceEventTester tester(marie->lc, addr); LinphoneAddress *bobAddr = linphone_core_interpret_url(marie->lc, bobUri); LinphoneAddress *aliceAddr = linphone_core_interpret_url(marie->lc, aliceUri); size_t size = strlen(first_notify) + strlen(confUri); char *notify = new char[size]; size_t size2 = strlen(participant_admined_notify) + strlen(confUri); char *notify_admined = new char[size2]; snprintf(notify, size, first_notify, confUri); tester.handler->notifyReceived(notify); delete[] notify; BC_ASSERT_EQUAL(tester.participants.size(), 2, int, "%d"); BC_ASSERT_TRUE(tester.participants.find(linphone_address_as_string(bobAddr)) != tester.participants.end()); BC_ASSERT_TRUE(tester.participants.find(linphone_address_as_string(aliceAddr)) != tester.participants.end()); BC_ASSERT_TRUE(!tester.participants.find(linphone_address_as_string(bobAddr))->second); BC_ASSERT_TRUE(tester.participants.find(linphone_address_as_string(aliceAddr))->second); snprintf(notify_admined, size2, participant_admined_notify, confUri); tester.handler->notifyReceived(notify_admined); delete[] notify_admined; BC_ASSERT_EQUAL(tester.participants.size(), 2, int, "%d"); BC_ASSERT_TRUE(tester.participants.find(linphone_address_as_string(bobAddr)) != tester.participants.end()); BC_ASSERT_TRUE(tester.participants.find(linphone_address_as_string(bobAddr))->second); linphone_address_unref(bobAddr); linphone_address_unref(aliceAddr); linphone_core_manager_destroy(marie); } void participant_unadmined_parsing() { LinphoneCoreManager *marie = linphone_core_manager_new("marie_rc"); LinphoneAddress *confAddress = linphone_core_interpret_url(marie->lc, confUri); char *confAddressStr = linphone_address_as_string(confAddress); Address addr(confAddressStr); bctbx_free(confAddressStr); linphone_address_unref(confAddress); ConferenceEventTester tester(marie->lc, addr); LinphoneAddress *bobAddr = linphone_core_interpret_url(marie->lc, bobUri); LinphoneAddress *aliceAddr = linphone_core_interpret_url(marie->lc, aliceUri); size_t size = strlen(first_notify) + strlen(confUri); char *notify = new char[size]; size_t size2 = strlen(participant_unadmined_notify) + strlen(confUri); char *notify_unadmined = new char[size2]; snprintf(notify, size, first_notify, confUri); tester.handler->notifyReceived(notify); delete[] notify; BC_ASSERT_EQUAL(tester.participants.size(), 2, int, "%d"); BC_ASSERT_TRUE(tester.participants.find(linphone_address_as_string(bobAddr)) != tester.participants.end()); BC_ASSERT_TRUE(tester.participants.find(linphone_address_as_string(aliceAddr)) != tester.participants.end()); BC_ASSERT_TRUE(!tester.participants.find(linphone_address_as_string(bobAddr))->second); BC_ASSERT_TRUE(tester.participants.find(linphone_address_as_string(aliceAddr))->second); snprintf(notify_unadmined, size2, participant_unadmined_notify, confUri); tester.handler->notifyReceived(notify_unadmined); delete[] notify_unadmined; BC_ASSERT_EQUAL(tester.participants.size(), 2, int, "%d"); BC_ASSERT_TRUE(tester.participants.find(linphone_address_as_string(aliceAddr)) != tester.participants.end()); BC_ASSERT_TRUE(!tester.participants.find(linphone_address_as_string(aliceAddr))->second); linphone_address_unref(bobAddr); linphone_address_unref(aliceAddr); linphone_core_manager_destroy(marie); } void send_first_notify() { LinphoneCoreManager *marie = linphone_core_manager_new("marie_rc"); LinphoneCoreManager *pauline = linphone_core_manager_new(transport_supported(LinphoneTransportTls) ? "pauline_rc" : "pauline_tcp_rc"); char *identityStr = linphone_address_as_string(pauline->identity); Address addr(identityStr); bctbx_free(identityStr); ConferenceEventTester tester(marie->lc, addr); LocalConference localConf(pauline->lc, addr); LinphoneAddress *cBobAddr = linphone_core_interpret_url(marie->lc, bobUri); char *bobAddrStr = linphone_address_as_string(cBobAddr); Address bobAddr(bobAddrStr); bctbx_free(bobAddrStr); linphone_address_unref(cBobAddr); LinphoneAddress *cAliceAddr = linphone_core_interpret_url(marie->lc, aliceUri); char *aliceAddrStr = linphone_address_as_string(cAliceAddr); Address aliceAddr(aliceAddrStr); bctbx_free(aliceAddrStr); linphone_address_unref(cAliceAddr); CallSessionParams params; localConf.addParticipant(bobAddr, ¶ms, false); shared_ptr alice = localConf.addParticipant(aliceAddr, ¶ms, false); alice->setAdmin(true); LinphoneEvent *lev = linphone_core_create_notify(pauline->lc, marie->identity, "conference"); string notify = localConf.getEventHandler()->subscribeReceived(lev); tester.handler->notifyReceived(notify); linphone_event_unref(lev); BC_ASSERT_EQUAL(tester.participants.size(), 2, int, "%d"); BC_ASSERT_TRUE(tester.participants.find(bobAddr.asString()) != tester.participants.end()); BC_ASSERT_TRUE(tester.participants.find(aliceAddr.asString()) != tester.participants.end()); BC_ASSERT_TRUE(!tester.participants.find(bobAddr.asString())->second); BC_ASSERT_TRUE(tester.participants.find(aliceAddr.asString())->second); linphone_core_manager_destroy(marie); linphone_core_manager_destroy(pauline); } void send_added_notify() { LinphoneCoreManager *marie = linphone_core_manager_new("marie_rc"); LinphoneCoreManager *pauline = linphone_core_manager_new(transport_supported(LinphoneTransportTls) ? "pauline_rc" : "pauline_tcp_rc"); char *identityStr = linphone_address_as_string(pauline->identity); Address addr(identityStr); bctbx_free(identityStr); ConferenceEventTester tester(marie->lc, addr); LocalConference localConf(pauline->lc, addr); LinphoneAddress *cBobAddr = linphone_core_interpret_url(marie->lc, bobUri); char *bobAddrStr = linphone_address_as_string(cBobAddr); Address bobAddr(bobAddrStr); bctbx_free(bobAddrStr); linphone_address_unref(cBobAddr); LinphoneAddress *cAliceAddr = linphone_core_interpret_url(marie->lc, aliceUri); char *aliceAddrStr = linphone_address_as_string(cAliceAddr); Address aliceAddr(aliceAddrStr); bctbx_free(aliceAddrStr); linphone_address_unref(cAliceAddr); LinphoneAddress *cFrankAddr = linphone_core_interpret_url(marie->lc, frankUri); char *frankAddrStr = linphone_address_as_string(cFrankAddr); Address frankAddr(frankAddrStr); bctbx_free(frankAddrStr); linphone_address_unref(cFrankAddr); LinphoneEvent *lev = linphone_core_create_notify(pauline->lc, marie->identity, "conference"); CallSessionParams params; localConf.addParticipant(bobAddr, ¶ms, false); shared_ptr alice = localConf.addParticipant(aliceAddr, ¶ms, false); alice->setAdmin(true); string notify = localConf.getEventHandler()->subscribeReceived(lev); tester.handler->notifyReceived(notify); linphone_event_unref(lev); BC_ASSERT_EQUAL(tester.participants.size(), 2, int, "%d"); BC_ASSERT_TRUE(tester.participants.find(bobAddr.asString()) != tester.participants.end()); BC_ASSERT_TRUE(tester.participants.find(aliceAddr.asString()) != tester.participants.end()); BC_ASSERT_TRUE(!tester.participants.find(bobAddr.asString())->second); BC_ASSERT_TRUE(tester.participants.find(aliceAddr.asString())->second); notify = localConf.getEventHandler()->notifyParticipantAdded(frankAddr); tester.handler->notifyReceived(notify); BC_ASSERT_EQUAL(tester.participants.size(), 3, int, "%d"); BC_ASSERT_TRUE(tester.participants.find(bobAddr.asString()) != tester.participants.end()); BC_ASSERT_TRUE(tester.participants.find(aliceAddr.asString()) != tester.participants.end()); BC_ASSERT_TRUE(tester.participants.find(frankAddr.asString()) != tester.participants.end()); BC_ASSERT_TRUE(!tester.participants.find(bobAddr.asString())->second); BC_ASSERT_TRUE(tester.participants.find(aliceAddr.asString())->second); BC_ASSERT_TRUE(!tester.participants.find(frankAddr.asString())->second); linphone_core_manager_destroy(marie); linphone_core_manager_destroy(pauline); } void send_removed_notify() { LinphoneCoreManager *marie = linphone_core_manager_new("marie_rc"); LinphoneCoreManager *pauline = linphone_core_manager_new(transport_supported(LinphoneTransportTls) ? "pauline_rc" : "pauline_tcp_rc"); char *identityStr = linphone_address_as_string(pauline->identity); Address addr(identityStr); bctbx_free(identityStr); ConferenceEventTester tester(marie->lc, addr); LocalConference localConf(pauline->lc, addr); LinphoneAddress *cBobAddr = linphone_core_interpret_url(marie->lc, bobUri); char *bobAddrStr = linphone_address_as_string(cBobAddr); Address bobAddr(bobAddrStr); bctbx_free(bobAddrStr); linphone_address_unref(cBobAddr); LinphoneAddress *cAliceAddr = linphone_core_interpret_url(marie->lc, aliceUri); char *aliceAddrStr = linphone_address_as_string(cAliceAddr); Address aliceAddr(aliceAddrStr); bctbx_free(aliceAddrStr); linphone_address_unref(cAliceAddr); CallSessionParams params; localConf.addParticipant(bobAddr, ¶ms, false); shared_ptr alice = localConf.addParticipant(aliceAddr, ¶ms, false); alice->setAdmin(true); LinphoneEvent *lev = linphone_core_create_notify(pauline->lc, marie->identity, "conference"); string notify = localConf.getEventHandler()->subscribeReceived(lev); tester.handler->notifyReceived(notify); linphone_event_unref(lev); BC_ASSERT_EQUAL(tester.participants.size(), 2, int, "%d"); BC_ASSERT_TRUE(tester.participants.find(bobAddr.asString()) != tester.participants.end()); BC_ASSERT_TRUE(tester.participants.find(aliceAddr.asString()) != tester.participants.end()); BC_ASSERT_TRUE(!tester.participants.find(bobAddr.asString())->second); BC_ASSERT_TRUE(tester.participants.find(aliceAddr.asString())->second); notify = localConf.getEventHandler()->notifyParticipantRemoved(bobAddr); tester.handler->notifyReceived(notify); BC_ASSERT_EQUAL(tester.participants.size(), 1, int, "%d"); BC_ASSERT_FALSE(tester.participants.find(bobAddr.asString()) != tester.participants.end()); BC_ASSERT_TRUE(tester.participants.find(aliceAddr.asString()) != tester.participants.end()); BC_ASSERT_TRUE(tester.participants.find(aliceAddr.asString())->second); linphone_core_manager_destroy(marie); linphone_core_manager_destroy(pauline); } void send_admined_notify() { LinphoneCoreManager *marie = linphone_core_manager_new("marie_rc"); LinphoneCoreManager *pauline = linphone_core_manager_new(transport_supported(LinphoneTransportTls) ? "pauline_rc" : "pauline_tcp_rc"); char *identityStr = linphone_address_as_string(pauline->identity); Address addr(identityStr); bctbx_free(identityStr); ConferenceEventTester tester(marie->lc, addr); LocalConference localConf(pauline->lc, addr); LinphoneAddress *cBobAddr = linphone_core_interpret_url(marie->lc, bobUri); char *bobAddrStr = linphone_address_as_string(cBobAddr); Address bobAddr(bobAddrStr); bctbx_free(bobAddrStr); linphone_address_unref(cBobAddr); LinphoneAddress *cAliceAddr = linphone_core_interpret_url(marie->lc, aliceUri); char *aliceAddrStr = linphone_address_as_string(cAliceAddr); Address aliceAddr(aliceAddrStr); bctbx_free(aliceAddrStr); linphone_address_unref(cAliceAddr); CallSessionParams params; localConf.addParticipant(bobAddr, ¶ms, false); shared_ptr alice = localConf.addParticipant(aliceAddr, ¶ms, false); alice->setAdmin(true); LinphoneEvent *lev = linphone_core_create_notify(pauline->lc, marie->identity, "conference"); string notify = localConf.getEventHandler()->subscribeReceived(lev); tester.handler->notifyReceived(notify); linphone_event_unref(lev); BC_ASSERT_EQUAL(tester.participants.size(), 2, int, "%d"); BC_ASSERT_TRUE(tester.participants.find(bobAddr.asString()) != tester.participants.end()); BC_ASSERT_TRUE(tester.participants.find(aliceAddr.asString()) != tester.participants.end()); BC_ASSERT_TRUE(!tester.participants.find(bobAddr.asString())->second); BC_ASSERT_TRUE(tester.participants.find(aliceAddr.asString())->second); notify = localConf.getEventHandler()->notifyParticipantSetAdmin(bobAddr, true); tester.handler->notifyReceived(notify); BC_ASSERT_EQUAL(tester.participants.size(), 2, int, "%d"); BC_ASSERT_TRUE(tester.participants.find(bobAddr.asString()) != tester.participants.end()); BC_ASSERT_TRUE(tester.participants.find(aliceAddr.asString()) != tester.participants.end()); BC_ASSERT_TRUE(tester.participants.find(aliceAddr.asString())->second); BC_ASSERT_TRUE(tester.participants.find(bobAddr.asString())->second); linphone_core_manager_destroy(marie); linphone_core_manager_destroy(pauline); } void send_unadmined_notify() { LinphoneCoreManager *marie = linphone_core_manager_new("marie_rc"); LinphoneCoreManager *pauline = linphone_core_manager_new(transport_supported(LinphoneTransportTls) ? "pauline_rc" : "pauline_tcp_rc"); char *identityStr = linphone_address_as_string(pauline->identity); Address addr(identityStr); bctbx_free(identityStr); ConferenceEventTester tester(marie->lc, addr); LocalConference localConf(pauline->lc, addr); LinphoneAddress *cBobAddr = linphone_core_interpret_url(marie->lc, bobUri); char *bobAddrStr = linphone_address_as_string(cBobAddr); Address bobAddr(bobAddrStr); bctbx_free(bobAddrStr); linphone_address_unref(cBobAddr); LinphoneAddress *cAliceAddr = linphone_core_interpret_url(marie->lc, aliceUri); char *aliceAddrStr = linphone_address_as_string(cAliceAddr); Address aliceAddr(aliceAddrStr); bctbx_free(aliceAddrStr); linphone_address_unref(cAliceAddr); CallSessionParams params; localConf.addParticipant(bobAddr, ¶ms, false); shared_ptr alice = localConf.addParticipant(aliceAddr, ¶ms, false); alice->setAdmin(true); LinphoneEvent *lev = linphone_core_create_notify(pauline->lc, marie->identity, "conference"); string notify = localConf.getEventHandler()->subscribeReceived(lev); tester.handler->notifyReceived(notify); linphone_event_unref(lev); BC_ASSERT_EQUAL(tester.participants.size(), 2, int, "%d"); BC_ASSERT_TRUE(tester.participants.find(bobAddr.asString()) != tester.participants.end()); BC_ASSERT_TRUE(tester.participants.find(aliceAddr.asString()) != tester.participants.end()); BC_ASSERT_TRUE(!tester.participants.find(bobAddr.asString())->second); BC_ASSERT_TRUE(tester.participants.find(aliceAddr.asString())->second); notify = localConf.getEventHandler()->notifyParticipantSetAdmin(aliceAddr, false); tester.handler->notifyReceived(notify); BC_ASSERT_EQUAL(tester.participants.size(), 2, int, "%d"); BC_ASSERT_TRUE(tester.participants.find(bobAddr.asString()) != tester.participants.end()); BC_ASSERT_TRUE(tester.participants.find(aliceAddr.asString()) != tester.participants.end()); BC_ASSERT_TRUE(!tester.participants.find(aliceAddr.asString())->second); BC_ASSERT_TRUE(!tester.participants.find(bobAddr.asString())->second); linphone_core_manager_destroy(marie); linphone_core_manager_destroy(pauline); } #if 0 void send_subscribe_receive_first_notify() { LinphoneCoreManager *marie = linphone_core_manager_new("marie_rc"); LinphoneCoreManager *pauline = linphone_core_manager_new(transport_supported(LinphoneTransportTls) ? "pauline_rc" : "pauline_tcp_rc"); ConferenceEventTester tester(marie->lc, pauline->identity); LinphoneAddress *bobAddr = linphone_core_interpret_url(marie->lc, bobUri); LinphoneAddress *aliceAddr = linphone_core_interpret_url(marie->lc, aliceUri); string confId("conf233"); BC_ASSERT_TRUE(wait_for_until(marie->lc, pauline->lc, &marie->stat.number_of_LinphoneRegistrationOk, 1, 1000)); BC_ASSERT_TRUE(wait_for_until(marie->lc, pauline->lc, &pauline->stat.number_of_LinphoneRegistrationOk, 1, 1000)); tester.handler->subscribe(confId); BC_ASSERT_TRUE(wait_for_until(marie->lc, pauline->lc, &pauline->stat.number_of_LinphoneSubscriptionIncomingReceived, 1, 1000)); BC_ASSERT_TRUE(wait_for_until(marie->lc, pauline->lc, &pauline->stat.number_of_LinphoneSubscriptionActive, 1, 3000)); wait_for_until(marie->lc, pauline->lc, &marie->stat.number_of_NotifyReceived, 1, 3000); BC_ASSERT_EQUAL(tester.participants.size(), 2, int, "%d"); BC_ASSERT_TRUE(tester.participants.find(linphone_address_as_string(bobAddr)) != tester.participants.end()); BC_ASSERT_TRUE(tester.participants.find(linphone_address_as_string(aliceAddr)) != tester.participants.end()); BC_ASSERT_TRUE(!tester.participants.find(linphone_address_as_string(bobAddr))->second); BC_ASSERT_TRUE(tester.participants.find(linphone_address_as_string(aliceAddr))->second); tester.handler->unsubscribe(); BC_ASSERT_TRUE(wait_for_until(marie->lc, pauline->lc, &pauline->stat.number_of_LinphoneSubscriptionTerminated, 1, 1000)); linphone_address_unref(bobAddr); linphone_address_unref(aliceAddr); linphone_core_manager_destroy(marie); linphone_core_manager_destroy(pauline); } #endif test_t conference_event_tests[] = { TEST_NO_TAG("First notify parsing", first_notify_parsing), TEST_NO_TAG("First notify parsing wrong conf", first_notify_parsing_wrong_conf), TEST_NO_TAG("Participant added", participant_added_parsing), TEST_NO_TAG("Participant not added", participant_not_added_parsing), TEST_NO_TAG("Participant deleted", participant_deleted_parsing), TEST_NO_TAG("Participant admined", participant_admined_parsing), TEST_NO_TAG("Participant unadmined", participant_unadmined_parsing), TEST_NO_TAG("Send first notify", send_first_notify), TEST_NO_TAG("Send participant added notify", send_added_notify), TEST_NO_TAG("Send participant removed notify", send_removed_notify), TEST_NO_TAG("Send participant admined notify", send_admined_notify), TEST_NO_TAG("Send participant unadmined notify", send_unadmined_notify) //TEST_NO_TAG("Send subscribe receive first notify", send_subscribe_receive_first_notify) }; test_suite_t conference_event_test_suite = { "Conference event", nullptr, nullptr, liblinphone_tester_before_each, liblinphone_tester_after_each, sizeof(conference_event_tests) / sizeof(conference_event_tests[0]), conference_event_tests };