-
Andrea Gianarda authored
Set it as Address in account parameters and core in order to easily take advantage of address comparison, parameter management and compliance with RFC3261 Conference: Allow applications to directly mute licrophone and get input device volume through the conference object. This will ensure that whatever type of confenrece is and regardless if the device is hosting or being a participant, the application will have only one interface to use and the SDK will work under the hood. Deprecated methods: Delete linphone_core_mute_mic and linphone_core_is_mic_muted Add LINPHONE_DEPRECATED to deprecated Account parameter methods Tester: Pass conference factory uri to ClientConference constructor instead of focus identity Memory leaks: Free data of list returned by linphone_friend_get_phone_numbers
3a43603e
/* * copyright (c) 2010-2023 belledonne communications sarl. * * This file is part of Liblinphone * (see https://gitlab.linphone.org/BC/public/liblinphone). * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU Affero 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 Affero General Public License for more details. * * You should have received a copy of the GNU Affero General Public License * along with this program. If not, see <http://www.gnu.org/licenses/>. */#include "liblinphone_tester.h"#include "local_conference_tester_functions.h"#include "shared_tester_functions.h"namespace LinphoneTest {static void edit_simple_conference_base(bool_t from_organizer, bool_t use_default_account, bool_t enable_bundle_mode, bool_t join, bool_t enable_encryption, bool_t server_restart, LinphoneConferenceSecurityLevel security_level, bool_t role_changed) { Focus focus("chloe_rc"); { // to make sure focus is destroyed after clients. ClientConference marie("marie_rc", focus.getConferenceFactoryAddress()); ClientConference pauline("pauline_rc", focus.getConferenceFactoryAddress()); ClientConference laure("laure_tcp_rc", focus.getConferenceFactoryAddress()); ClientConference michelle("michelle_rc", focus.getConferenceFactoryAddress()); ClientConference lise("lise_rc", focus.getConferenceFactoryAddress()); LinphoneCoreManager *manager_editing = (from_organizer) ? marie.getCMgr() : laure.getCMgr(); linphone_core_enable_rtp_bundle(manager_editing->lc, enable_bundle_mode); int default_index = linphone_config_get_int(linphone_core_get_config(manager_editing->lc), "sip", "default_proxy", 0); LinphoneAccountParams *params = linphone_account_params_new_with_config(manager_editing->lc, default_index); LinphoneAddress *alternative_address = linphone_address_new("sip:toto@sip.linphone.org"); linphone_account_params_set_identity_address(params, alternative_address); LinphoneAccount *new_account = linphone_account_new(manager_editing->lc, params); linphone_core_add_account(manager_editing->lc, new_account); linphone_account_params_unref(params); linphone_account_unref(new_account); focus.registerAsParticipantDevice(marie); focus.registerAsParticipantDevice(pauline); focus.registerAsParticipantDevice(laure); focus.registerAsParticipantDevice(michelle); focus.registerAsParticipantDevice(lise); setup_conference_info_cbs(marie.getCMgr()); linphone_core_set_file_transfer_server(marie.getLc(), file_transfer_url); for (auto mgr : {focus.getCMgr(), marie.getCMgr(), pauline.getCMgr(), laure.getCMgr()}) { LinphoneVideoActivationPolicy *pol = linphone_factory_create_video_activation_policy(linphone_factory_get()); linphone_video_activation_policy_set_automatically_accept(pol, TRUE); linphone_video_activation_policy_set_automatically_initiate(pol, TRUE); linphone_core_set_video_activation_policy(mgr->lc, pol);7172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140
linphone_video_activation_policy_unref(pol);
linphone_core_set_video_device(mgr->lc, liblinphone_tester_mire_id);
linphone_core_enable_video_capture(mgr->lc, TRUE);
linphone_core_enable_video_display(mgr->lc, TRUE);
if ((mgr != focus.getCMgr()) && enable_encryption) {
linphone_config_set_int(linphone_core_get_config(mgr->lc), "rtp", "accept_any_encryption", 1);
linphone_core_set_media_encryption_mandatory(mgr->lc, TRUE);
linphone_core_set_media_encryption(mgr->lc, LinphoneMediaEncryptionZRTP);
}
}
bctbx_list_t *coresList = bctbx_list_append(NULL, focus.getLc());
coresList = bctbx_list_append(coresList, marie.getLc());
coresList = bctbx_list_append(coresList, pauline.getLc());
coresList = bctbx_list_append(coresList, laure.getLc());
coresList = bctbx_list_append(coresList, michelle.getLc());
coresList = bctbx_list_append(coresList, lise.getLc());
std::list<LinphoneCoreManager *> invitedParticipants{pauline.getCMgr(), laure.getCMgr()};
time_t start_time = time(NULL) + 600; // Start in 10 minutes
int duration = 60; // minutes
time_t end_time = (duration <= 0) ? -1 : (start_time + duration * 60);
const char *initialSubject = "Test characters: <S-F12><S-F11><S-F6> £$%§";
const char *description = "Testing characters";
bctbx_list_t *participants_info = NULL;
std::map<LinphoneCoreManager *, LinphoneParticipantInfo *> participantList;
LinphoneParticipantRole role = LinphoneParticipantRoleSpeaker;
for (auto &p : invitedParticipants) {
participantList.insert(
std::make_pair(p, add_participant_info_to_list(&participants_info, p->identity, role, -1)));
role = (role == LinphoneParticipantRoleSpeaker) ? LinphoneParticipantRoleListener
: LinphoneParticipantRoleSpeaker;
}
LinphoneAddress *confAddr = create_conference_on_server(focus, marie, participantList, start_time, end_time,
initialSubject, description, TRUE, security_level);
BC_ASSERT_PTR_NOT_NULL(confAddr);
// Chat room creation to send ICS
BC_ASSERT_TRUE(wait_for_list(coresList, &marie.getStats().number_of_LinphoneConferenceStateCreated, 2,
liblinphone_tester_sip_timeout));
char *conference_address_str = (confAddr) ? linphone_address_as_string(confAddr) : ms_strdup("<unknown>");
std::list<LinphoneCoreManager *> participants{pauline.getCMgr(), laure.getCMgr()};
char *uid = NULL;
unsigned int sequence = 0;
LinphoneConferenceInfo *conf_info = linphone_core_find_conference_information_from_uri(marie.getLc(), confAddr);
BC_ASSERT_PTR_NOT_NULL(conf_info);
if (conf_info) {
uid = ms_strdup(linphone_conference_info_get_ics_uid(conf_info));
BC_ASSERT_PTR_NOT_NULL(uid);
sequence = linphone_conference_info_get_ics_sequence(conf_info);
ms_message("%s is trying to update conference %s - adding %s", linphone_core_get_identity(marie.getLc()),
conference_address_str, linphone_core_get_identity(lise.getLc()));
participants.push_back(lise.getCMgr());
LinphoneParticipantRole role = LinphoneParticipantRoleListener;
stats focus_stat = focus.getStats();
stats marie_stat = marie.getStats();
linphone_conference_info_set_subject(conf_info, initialSubject);
linphone_conference_info_set_description(conf_info, description);
LinphoneParticipantInfo *lise_participant_info =
add_participant_info_to_list(&participants_info, lise.getCMgr()->identity, role, -1);
linphone_conference_info_add_participant_2(conf_info, lise_participant_info);
141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210
participantList.insert(std::make_pair(lise.getCMgr(), lise_participant_info));
if (role_changed) {
LinphoneParticipantRole current_pauline_role =
linphone_participant_info_get_role(participantList[pauline.getCMgr()]);
LinphoneParticipantRole new_pauline_role = (current_pauline_role == LinphoneParticipantRoleListener)
? LinphoneParticipantRoleSpeaker
: LinphoneParticipantRoleListener;
ms_message("%s is trying to update conference %s - changing role of %s from %s to %s",
linphone_core_get_identity(marie.getLc()), conference_address_str,
linphone_core_get_identity(pauline.getLc()),
linphone_participant_role_to_string(current_pauline_role),
linphone_participant_role_to_string(new_pauline_role));
const LinphoneParticipantInfo *old_pauline_partipant_info =
linphone_conference_info_find_participant(conf_info, pauline.getCMgr()->identity);
BC_ASSERT_PTR_NOT_NULL(old_pauline_partipant_info);
if (old_pauline_partipant_info) {
LinphoneParticipantInfo *pauline_participant_info =
linphone_participant_info_clone(old_pauline_partipant_info);
linphone_participant_info_set_role(pauline_participant_info, new_pauline_role);
linphone_conference_info_update_participant(conf_info, pauline_participant_info);
linphone_participant_info_set_role(participantList[pauline.getCMgr()], new_pauline_role);
const bctbx_list_t *participant_info_it = bctbx_list_find_custom(
participants_info, (int (*)(const void *, const void *))find_matching_participant_info,
pauline_participant_info);
BC_ASSERT_PTR_NOT_NULL(participant_info_it);
if (participant_info_it) {
LinphoneParticipantInfo *participant_info_found =
(LinphoneParticipantInfo *)bctbx_list_get_data(participant_info_it);
linphone_participant_info_set_role(participant_info_found, new_pauline_role);
}
linphone_participant_info_unref(pauline_participant_info);
}
}
const auto ics_participant_number = 3;
const bctbx_list_t *ics_participants = linphone_conference_info_get_participant_infos(conf_info);
BC_ASSERT_EQUAL(bctbx_list_size(ics_participants), ics_participant_number, size_t, "%zu");
std::list<stats> participant_stats;
for (auto mgr : {focus.getCMgr(), marie.getCMgr(), laure.getCMgr(), pauline.getCMgr(), lise.getCMgr()}) {
participant_stats.push_back(mgr->stat);
}
LinphoneConferenceScheduler *conference_scheduler =
linphone_core_create_conference_scheduler(marie.getLc());
LinphoneConferenceSchedulerCbs *cbs =
linphone_factory_create_conference_scheduler_cbs(linphone_factory_get());
linphone_conference_scheduler_cbs_set_state_changed(cbs, conference_scheduler_state_changed);
linphone_conference_scheduler_cbs_set_invitations_sent(cbs, conference_scheduler_invitations_sent);
linphone_conference_scheduler_add_callbacks(conference_scheduler, cbs);
linphone_conference_scheduler_cbs_unref(cbs);
linphone_conference_scheduler_set_info(conference_scheduler, conf_info);
BC_ASSERT_TRUE(wait_for_list(coresList, &marie.getStats().number_of_ConferenceSchedulerStateUpdating,
marie_stat.number_of_ConferenceSchedulerStateUpdating + 1,
liblinphone_tester_sip_timeout));
BC_ASSERT_TRUE(wait_for_list(coresList, &marie.getStats().number_of_ConferenceSchedulerStateReady,
marie_stat.number_of_ConferenceSchedulerStateReady + 1,
liblinphone_tester_sip_timeout));
BC_ASSERT_TRUE(wait_for_list(coresList, &focus.getStats().number_of_LinphoneCallIncomingReceived,
focus_stat.number_of_LinphoneCallIncomingReceived + 1,
liblinphone_tester_sip_timeout));
BC_ASSERT_TRUE(wait_for_list(coresList, &focus.getStats().number_of_LinphoneCallStreamsRunning,
focus_stat.number_of_LinphoneCallStreamsRunning + 1,
liblinphone_tester_sip_timeout));
BC_ASSERT_TRUE(wait_for_list(coresList, &focus.getStats().number_of_LinphoneCallEnd,
focus_stat.number_of_LinphoneCallEnd + 1, liblinphone_tester_sip_timeout));
211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280
BC_ASSERT_TRUE(wait_for_list(coresList, &focus.getStats().number_of_LinphoneCallReleased,
focus_stat.number_of_LinphoneCallReleased + 1,
liblinphone_tester_sip_timeout));
LinphoneChatRoomParams *chat_room_params = linphone_core_create_default_chat_room_params(marie.getLc());
linphone_chat_room_params_set_backend(chat_room_params, LinphoneChatRoomBackendBasic);
linphone_conference_scheduler_send_invitations(conference_scheduler, chat_room_params);
linphone_chat_room_params_unref(chat_room_params);
BC_ASSERT_TRUE(wait_for_list(coresList, &marie.getStats().number_of_ConferenceSchedulerInvitationsSent,
marie_stat.number_of_ConferenceSchedulerInvitationsSent + 1,
liblinphone_tester_sip_timeout));
for (auto mgr : {focus.getCMgr(), marie.getCMgr(), laure.getCMgr(), pauline.getCMgr(), lise.getCMgr()}) {
auto old_stats = participant_stats.front();
if ((mgr != focus.getCMgr()) && (mgr != marie.getCMgr())) {
BC_ASSERT_TRUE(wait_for_list(coresList, &mgr->stat.number_of_LinphoneMessageReceived,
old_stats.number_of_LinphoneMessageReceived + 1,
liblinphone_tester_sip_timeout));
if (!linphone_core_conference_ics_in_message_body_enabled(marie.getLc())) {
BC_ASSERT_TRUE(wait_for_list(coresList, &mgr->stat.number_of_LinphoneMessageReceivedWithFile,
old_stats.number_of_LinphoneMessageReceivedWithFile + 1,
liblinphone_tester_sip_timeout));
}
BC_ASSERT_PTR_NOT_NULL(mgr->stat.last_received_chat_message);
if (mgr->stat.last_received_chat_message != NULL) {
const string expected = ContentType::Icalendar.getMediaType();
BC_ASSERT_STRING_EQUAL(
linphone_chat_message_get_content_type(mgr->stat.last_received_chat_message),
expected.c_str());
}
bctbx_list_t *participant_chat_room_participants =
bctbx_list_append(NULL, marie.getCMgr()->identity);
LinphoneChatRoom *pcr = linphone_core_search_chat_room(mgr->lc, NULL, mgr->identity, NULL,
participant_chat_room_participants);
bctbx_list_free(participant_chat_room_participants);
BC_ASSERT_PTR_NOT_NULL(pcr);
bctbx_list_t *chat_room_participants = bctbx_list_append(NULL, mgr->identity);
LinphoneChatRoom *cr = linphone_core_search_chat_room(
marie.getLc(), NULL, marie.getCMgr()->identity, NULL, chat_room_participants);
bctbx_list_free(chat_room_participants);
BC_ASSERT_PTR_NOT_NULL(cr);
BC_ASSERT_EQUAL((int)bctbx_list_size(linphone_core_get_chat_rooms(mgr->lc)), 1, int, "%d");
if (cr) {
LinphoneChatMessage *msg = linphone_chat_room_get_last_message_in_history(cr);
BC_ASSERT_PTR_NOT_NULL(msg);
const bctbx_list_t *original_contents = linphone_chat_message_get_contents(msg);
BC_ASSERT_EQUAL((int)bctbx_list_size(original_contents), 1, int, "%d");
LinphoneContent *original_content = (LinphoneContent *)bctbx_list_get_data(original_contents);
if (BC_ASSERT_PTR_NOT_NULL(original_content)) {
LinphoneConferenceInfo *conf_info_from_original_content =
linphone_factory_create_conference_info_from_icalendar_content(linphone_factory_get(),
original_content);
if (BC_ASSERT_PTR_NOT_NULL(conf_info_from_original_content)) {
int exp_sequence = 0;
if (mgr == lise.getCMgr()) {
exp_sequence = 0;
} else {
exp_sequence = (sequence + 1);
}
LinphoneConferenceInfoState exp_state = LinphoneConferenceInfoStateNew;
if (mgr == lise.getCMgr()) {
exp_state = LinphoneConferenceInfoStateNew;
281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350
} else {
exp_state = LinphoneConferenceInfoStateUpdated;
}
update_sequence_number(&participants_info, {lise.getCMgr()->identity},
(mgr == focus.getCMgr()) ? 0 : 1,
(mgr == focus.getCMgr()) ? -1 : 0);
check_conference_info_against_db(mgr, confAddr, conf_info_from_original_content);
linphone_conference_info_unref(conf_info_from_original_content);
check_conference_info_in_db(mgr, uid, confAddr, marie.getCMgr()->identity,
participants_info, start_time, duration, initialSubject,
description, exp_sequence, exp_state, security_level,
FALSE);
}
}
linphone_chat_message_unref(msg);
}
}
participant_stats.pop_front();
}
linphone_conference_info_unref(conf_info);
linphone_conference_scheduler_unref(conference_scheduler);
}
ms_free(uid);
uid = NULL;
if (join) {
std::list<LinphoneCoreManager *> conferenceMgrs{focus.getCMgr(), marie.getCMgr(), pauline.getCMgr()};
std::list<LinphoneCoreManager *> members{marie.getCMgr(), pauline.getCMgr()};
add_participant_info_to_list(&participants_info, marie.getCMgr()->identity, LinphoneParticipantRoleSpeaker,
0);
stats focus_stat = focus.getStats();
for (auto mgr : members) {
LinphoneCallParams *new_params = linphone_core_create_call_params(mgr->lc, nullptr);
linphone_core_invite_address_with_params_2(mgr->lc, confAddr, new_params, NULL, nullptr);
linphone_call_params_unref(new_params);
}
for (auto mgr : members) {
BC_ASSERT_TRUE(wait_for_list(coresList, &mgr->stat.number_of_LinphoneCallOutgoingProgress, 1,
liblinphone_tester_sip_timeout));
int no_streams_running = 2;
BC_ASSERT_TRUE(wait_for_list(coresList, &mgr->stat.number_of_LinphoneCallUpdating,
(no_streams_running - 1), liblinphone_tester_sip_timeout));
BC_ASSERT_TRUE(wait_for_list(coresList, &mgr->stat.number_of_LinphoneCallStreamsRunning,
no_streams_running, liblinphone_tester_sip_timeout));
// Update to add to conference.
// If ICE is enabled, the addition to a conference may go through a resume of the call
BC_ASSERT_TRUE(wait_for_list(coresList, &mgr->stat.number_of_LinphoneConferenceStateCreated,
((mgr == marie.getCMgr()) ? 3 : 2), liblinphone_tester_sip_timeout));
BC_ASSERT_TRUE(
wait_for_list(coresList, &mgr->stat.number_of_LinphoneSubscriptionOutgoingProgress, 1, 5000));
BC_ASSERT_TRUE(wait_for_list(coresList, &mgr->stat.number_of_LinphoneSubscriptionActive, 1, 5000));
BC_ASSERT_TRUE(wait_for_list(coresList, &mgr->stat.number_of_NotifyFullStateReceived, 1,
liblinphone_tester_sip_timeout));
}
BC_ASSERT_TRUE(wait_for_list(coresList, &focus.getStats().number_of_LinphoneCallIncomingReceived,
focus_stat.number_of_LinphoneCallIncomingReceived + 2,
liblinphone_tester_sip_timeout));
int focus_no_streams_running = 4;
// Update to end ICE negotiations
BC_ASSERT_TRUE(
wait_for_list(coresList, &focus.getStats().number_of_LinphoneCallUpdatedByRemote,
focus_stat.number_of_LinphoneCallUpdatedByRemote + (focus_no_streams_running - 2),
liblinphone_tester_sip_timeout));
BC_ASSERT_TRUE(wait_for_list(coresList, &focus.getStats().number_of_LinphoneCallStreamsRunning,
351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420
focus_stat.number_of_LinphoneCallStreamsRunning + focus_no_streams_running,
liblinphone_tester_sip_timeout));
// Update to add to conference.
// If ICE is enabled, the addition to a conference may go through a resume of the call
BC_ASSERT_TRUE(wait_for_list(coresList, &focus.getStats().number_of_LinphoneConferenceStateCreated,
focus_stat.number_of_LinphoneConferenceStateCreated + 1,
liblinphone_tester_sip_timeout));
BC_ASSERT_TRUE(wait_for_list(coresList, &focus.getStats().number_of_LinphoneSubscriptionIncomingReceived,
focus_stat.number_of_LinphoneSubscriptionIncomingReceived + 2, 5000));
BC_ASSERT_TRUE(wait_for_list(coresList, &focus.getStats().number_of_LinphoneSubscriptionActive,
focus_stat.number_of_LinphoneSubscriptionActive + 2, 5000));
BC_ASSERT_TRUE(wait_for_list(coresList, &focus.getStats().number_of_participants_added,
focus_stat.number_of_participants_added + 2, liblinphone_tester_sip_timeout));
BC_ASSERT_TRUE(wait_for_list(coresList, &focus.getStats().number_of_participant_devices_added,
focus_stat.number_of_participant_devices_added + 2,
liblinphone_tester_sip_timeout));
BC_ASSERT_TRUE(wait_for_list(coresList, &focus.getStats().number_of_participant_devices_joined,
focus_stat.number_of_participant_devices_joined + 2,
liblinphone_tester_sip_timeout));
std::map<LinphoneCoreManager *, LinphoneParticipantInfo *> memberList =
fill_memmber_list(members, participantList, marie.getCMgr(), participants_info);
wait_for_conference_streams({focus, marie, pauline, laure, michelle, lise}, conferenceMgrs, focus.getCMgr(),
memberList, confAddr, TRUE);
LinphoneConference *fconference = linphone_core_search_conference_2(focus.getLc(), confAddr);
BC_ASSERT_PTR_NOT_NULL(fconference);
// wait bit more to detect side effect if any
CoreManagerAssert({focus, marie, pauline, laure, michelle, lise}).waitUntil(chrono::seconds(2), [] {
return false;
});
for (auto mgr : conferenceMgrs) {
LinphoneConference *pconference = linphone_core_search_conference_2(mgr->lc, confAddr);
BC_ASSERT_PTR_NOT_NULL(pconference);
if (pconference) {
const LinphoneConferenceParams *conference_params =
linphone_conference_get_current_params(pconference);
int no_participants = 0;
if (start_time >= 0) {
BC_ASSERT_EQUAL((long long)linphone_conference_params_get_start_time(conference_params),
(long long)start_time, long long, "%lld");
}
BC_ASSERT_EQUAL((long long)linphone_conference_params_get_end_time(conference_params),
(long long)end_time, long long, "%lld");
bctbx_list_t *participant_device_list =
linphone_conference_get_participant_device_list(pconference);
BC_ASSERT_EQUAL(bctbx_list_size(participant_device_list), 2, size_t, "%zu");
for (bctbx_list_t *d_it = participant_device_list; d_it; d_it = bctbx_list_next(d_it)) {
LinphoneParticipantDevice *d = (LinphoneParticipantDevice *)bctbx_list_get_data(d_it);
BC_ASSERT_PTR_NOT_NULL(d);
if (d) {
BC_ASSERT_TRUE((!!linphone_participant_device_get_is_muted(d)) ==
(linphone_address_weak_equal(linphone_participant_device_get_address(d),
laure.getCMgr()->identity)));
linphone_participant_device_set_user_data(d, mgr->lc);
LinphoneParticipantDeviceCbs *cbs =
linphone_factory_create_participant_device_cbs(linphone_factory_get());
linphone_participant_device_cbs_set_is_muted(cbs, on_muted_notified);
linphone_participant_device_add_callbacks(d, cbs);
linphone_participant_device_cbs_unref(cbs);
}
}
bctbx_list_free_with_data(participant_device_list,
(void (*)(void *))linphone_participant_device_unref);
if (mgr == focus.getCMgr()) {
421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490
no_participants = 2;
BC_ASSERT_FALSE(linphone_conference_is_in(pconference));
} else {
no_participants = 1;
BC_ASSERT_TRUE(linphone_conference_is_in(pconference));
LinphoneCall *current_call = linphone_core_get_current_call(mgr->lc);
BC_ASSERT_PTR_NOT_NULL(current_call);
if (current_call) {
BC_ASSERT_EQUAL((int)linphone_call_get_state(current_call),
(int)LinphoneCallStateStreamsRunning, int, "%0d");
}
LinphoneVideoActivationPolicy *pol = linphone_core_get_video_activation_policy(mgr->lc);
bool_t enabled = !!linphone_video_activation_policy_get_automatically_initiate(pol);
linphone_video_activation_policy_unref(pol);
size_t no_streams_audio = 0;
size_t no_streams_video = 3;
size_t no_active_streams_video = 0;
size_t no_streams_text = 0;
LinphoneCall *pcall = linphone_core_get_call_by_remote_address2(mgr->lc, confAddr);
BC_ASSERT_PTR_NOT_NULL(pcall);
if (pcall) {
no_streams_audio = compute_no_audio_streams(pcall, pconference);
no_active_streams_video = compute_no_video_streams(enabled, pcall, pconference);
_linphone_call_check_max_nb_streams(pcall, no_streams_audio, no_streams_video,
no_streams_text);
_linphone_call_check_nb_active_streams(pcall, no_streams_audio, no_active_streams_video,
no_streams_text);
const LinphoneCallParams *call_lparams = linphone_call_get_params(pcall);
BC_ASSERT_EQUAL(linphone_call_params_video_enabled(call_lparams), enabled, int, "%0d");
const LinphoneCallParams *call_rparams = linphone_call_get_remote_params(pcall);
BC_ASSERT_EQUAL(linphone_call_params_video_enabled(call_rparams), enabled, int, "%0d");
const LinphoneCallParams *call_cparams = linphone_call_get_current_params(pcall);
BC_ASSERT_EQUAL(linphone_call_params_video_enabled(call_cparams), enabled, int, "%0d");
}
LinphoneCall *ccall = linphone_core_get_call_by_remote_address2(focus.getLc(), mgr->identity);
BC_ASSERT_PTR_NOT_NULL(ccall);
if (ccall) {
_linphone_call_check_max_nb_streams(ccall, no_streams_audio, no_streams_video,
no_streams_text);
_linphone_call_check_nb_active_streams(ccall, no_streams_audio, no_active_streams_video,
no_streams_text);
const LinphoneCallParams *call_lparams = linphone_call_get_params(ccall);
BC_ASSERT_EQUAL(linphone_call_params_video_enabled(call_lparams), enabled, int, "%0d");
const LinphoneCallParams *call_rparams = linphone_call_get_remote_params(ccall);
BC_ASSERT_EQUAL(linphone_call_params_video_enabled(call_rparams), enabled, int, "%0d");
const LinphoneCallParams *call_cparams = linphone_call_get_current_params(ccall);
BC_ASSERT_EQUAL(linphone_call_params_video_enabled(call_cparams), enabled, int, "%0d");
}
}
BC_ASSERT_EQUAL(linphone_conference_get_participant_count(pconference), no_participants, int,
"%0d");
BC_ASSERT_STRING_EQUAL(linphone_conference_get_subject(pconference), initialSubject);
LinphoneParticipant *me = linphone_conference_get_me(pconference);
BC_ASSERT_TRUE(linphone_participant_is_admin(me) ==
((mgr == marie.getCMgr()) || (mgr == focus.getCMgr())));
BC_ASSERT_TRUE(linphone_address_weak_equal(linphone_participant_get_address(me), mgr->identity));
bctbx_list_t *participants = linphone_conference_get_participant_list(pconference);
for (bctbx_list_t *itp = participants; itp; itp = bctbx_list_next(itp)) {
LinphoneParticipant *p = (LinphoneParticipant *)bctbx_list_get_data(itp);
BC_ASSERT_TRUE(linphone_participant_is_admin(p) ==
linphone_address_weak_equal(linphone_participant_get_address(p),
marie.getCMgr()->identity));
}
bctbx_list_free_with_data(participants, (void (*)(void *))linphone_participant_unref);
if (mgr != focus.getCMgr()) {
check_conference_ssrc(fconference, pconference);
491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560
}
}
}
}
if (server_restart) {
ms_message("%s is restarting", linphone_core_get_identity(focus.getLc()));
coresList = bctbx_list_remove(coresList, focus.getLc());
// Restart flexisip
focus.reStart();
LinphoneVideoActivationPolicy *pol =
linphone_factory_create_video_activation_policy(linphone_factory_get());
linphone_video_activation_policy_set_automatically_accept(pol, TRUE);
linphone_video_activation_policy_set_automatically_initiate(pol, TRUE);
linphone_core_set_video_activation_policy(focus.getLc(), pol);
linphone_video_activation_policy_unref(pol);
linphone_core_enable_video_capture(focus.getLc(), TRUE);
linphone_core_enable_video_display(focus.getLc(), TRUE);
coresList = bctbx_list_append(coresList, focus.getLc());
}
const char *subject = "Test characters: <S-F12><S-F11><S-F6> £$%§ (+edits)";
const char *description2 = "Testing characters (+edits)";
stats manager_editing_stat = manager_editing->stat;
LinphoneAccount *editing_account = NULL;
if (use_default_account) {
editing_account = linphone_core_get_default_account(manager_editing->lc);
} else {
editing_account = linphone_core_lookup_known_account(manager_editing->lc, alternative_address);
}
BC_ASSERT_PTR_NOT_NULL(editing_account);
if (editing_account) {
LinphoneAccountParams *account_params =
linphone_account_params_clone(linphone_account_get_params(editing_account));
linphone_account_params_enable_rtp_bundle(account_params, enable_bundle_mode);
linphone_account_set_params(editing_account, account_params);
linphone_account_params_unref(account_params);
}
LinphoneConferenceInfo *info = linphone_core_find_conference_information_from_uri(marie.getLc(), confAddr);
if (BC_ASSERT_PTR_NOT_NULL(info)) {
uid = ms_strdup(linphone_conference_info_get_ics_uid(info));
BC_ASSERT_PTR_NOT_NULL(uid);
sequence = linphone_conference_info_get_ics_sequence(info);
linphone_conference_info_unref(info);
}
bool_t add = TRUE;
std::list<LinphoneCoreManager *> initialParticipants{pauline.getCMgr(), laure.getCMgr(), lise.getCMgr()};
bctbx_list_t *initialInfos = NULL;
for (const auto &participant : initialParticipants) {
LinphoneParticipantInfo *info = linphone_participant_info_new(participant->identity);
const bctbx_list_t *participant_info_it = bctbx_list_find_custom(
participants_info, (int (*)(const void *, const void *))find_matching_participant_info, info);
BC_ASSERT_PTR_NOT_NULL(participant_info_it);
if (participant_info_it) {
LinphoneParticipantInfo *participant_info_found =
(LinphoneParticipantInfo *)bctbx_list_get_data(participant_info_it);
initialInfos = bctbx_list_append(initialInfos, participant_info_found);
}
linphone_participant_info_unref(info);
}
for (int attempt = 0; attempt < 3; attempt++) {
ms_message("%s is trying to update conference %s - attempt %0d - %s %s",
linphone_core_get_identity(manager_editing->lc), conference_address_str, attempt,
(add) ? "adding" : "removing", linphone_core_get_identity(michelle.getLc()));
561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630
stats focus_stat = focus.getStats();
std::list<LinphoneCoreManager *> participants = initialParticipants;
LinphoneConferenceInfo *conf_info =
linphone_core_find_conference_information_from_uri(manager_editing->lc, confAddr);
BC_ASSERT_PTR_NOT_NULL(conf_info);
if (conf_info) {
linphone_conference_info_set_subject(conf_info, subject);
linphone_conference_info_set_description(conf_info, description2);
if (add) {
linphone_conference_info_add_participant(conf_info, michelle.getCMgr()->identity);
} else {
// If marie was in the list of participants, she will be removed as well but she will be kept as
// organizer
linphone_conference_info_set_participant_infos(conf_info, initialInfos);
}
const auto ics_participant_number = ((add) ? 4 : 3) + (((attempt == 0) && join) ? 1 : 0);
const bctbx_list_t *ics_participants = linphone_conference_info_get_participant_infos(conf_info);
BC_ASSERT_EQUAL(bctbx_list_size(ics_participants), ics_participant_number, size_t, "%zu");
std::list<stats> participant_stats;
for (auto mgr : {focus.getCMgr(), marie.getCMgr(), laure.getCMgr(), pauline.getCMgr(),
michelle.getCMgr(), lise.getCMgr()}) {
participant_stats.push_back(mgr->stat);
}
LinphoneConferenceScheduler *conference_scheduler =
linphone_core_create_conference_scheduler(manager_editing->lc);
linphone_conference_scheduler_set_account(conference_scheduler, editing_account);
LinphoneConferenceSchedulerCbs *cbs =
linphone_factory_create_conference_scheduler_cbs(linphone_factory_get());
linphone_conference_scheduler_cbs_set_state_changed(cbs, conference_scheduler_state_changed);
linphone_conference_scheduler_cbs_set_invitations_sent(cbs, conference_scheduler_invitations_sent);
linphone_conference_scheduler_add_callbacks(conference_scheduler, cbs);
linphone_conference_scheduler_cbs_unref(cbs);
linphone_conference_scheduler_set_info(conference_scheduler, conf_info);
if (use_default_account) {
BC_ASSERT_TRUE(wait_for_list(coresList,
&manager_editing->stat.number_of_ConferenceSchedulerStateUpdating,
manager_editing_stat.number_of_ConferenceSchedulerStateUpdating + 1,
liblinphone_tester_sip_timeout));
BC_ASSERT_TRUE(wait_for_list(coresList,
&manager_editing->stat.number_of_ConferenceSchedulerStateReady,
manager_editing_stat.number_of_ConferenceSchedulerStateReady + 1,
liblinphone_tester_sip_timeout));
BC_ASSERT_TRUE(wait_for_list(coresList, &focus.getStats().number_of_LinphoneCallIncomingReceived,
focus_stat.number_of_LinphoneCallIncomingReceived + 1,
liblinphone_tester_sip_timeout));
BC_ASSERT_TRUE(wait_for_list(coresList, &focus.getStats().number_of_LinphoneCallStreamsRunning,
focus_stat.number_of_LinphoneCallStreamsRunning + 1,
liblinphone_tester_sip_timeout));
BC_ASSERT_TRUE(wait_for_list(coresList, &focus.getStats().number_of_LinphoneCallEnd,
focus_stat.number_of_LinphoneCallEnd + 1,
liblinphone_tester_sip_timeout));
BC_ASSERT_TRUE(wait_for_list(coresList, &focus.getStats().number_of_LinphoneCallReleased,
focus_stat.number_of_LinphoneCallReleased + 1,
liblinphone_tester_sip_timeout));
if (add) {
LinphoneParticipantRole role = LinphoneParticipantRoleUnknown;
add_participant_info_to_list(&participants_info, michelle.getCMgr()->identity, role, 0);
} else {
for (const auto &mgr : {michelle.getCMgr(), marie.getCMgr()}) {
LinphoneParticipantInfo *participant_info = linphone_participant_info_new(mgr->identity);
bctbx_list_t *participant_info_found_it = bctbx_list_find_custom(
participants_info, (int (*)(const void *, const void *))find_matching_participant_info,
631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700
participant_info);
if (participant_info_found_it) {
LinphoneParticipantInfo *participant_info_found =
(LinphoneParticipantInfo *)bctbx_list_get_data(participant_info_found_it);
participants_info = bctbx_list_remove(participants_info, participant_info_found);
linphone_participant_info_unref(participant_info_found);
}
linphone_participant_info_unref(participant_info);
}
}
LinphoneChatRoomParams *chat_room_params =
linphone_core_create_default_chat_room_params(manager_editing->lc);
linphone_chat_room_params_set_backend(chat_room_params, LinphoneChatRoomBackendBasic);
linphone_conference_scheduler_send_invitations(conference_scheduler, chat_room_params);
linphone_chat_room_params_unref(chat_room_params);
BC_ASSERT_TRUE(wait_for_list(coresList,
&manager_editing->stat.number_of_ConferenceSchedulerInvitationsSent,
manager_editing_stat.number_of_ConferenceSchedulerInvitationsSent + 1,
liblinphone_tester_sip_timeout));
for (auto mgr : {focus.getCMgr(), marie.getCMgr(), laure.getCMgr(), pauline.getCMgr(),
michelle.getCMgr(), lise.getCMgr()}) {
auto old_stats = participant_stats.front();
if ((mgr != focus.getCMgr()) && (mgr != manager_editing)) {
BC_ASSERT_TRUE(wait_for_list(coresList, &mgr->stat.number_of_LinphoneMessageReceived,
old_stats.number_of_LinphoneMessageReceived + 1,
liblinphone_tester_sip_timeout));
if (!linphone_core_conference_ics_in_message_body_enabled(manager_editing->lc)) {
BC_ASSERT_TRUE(wait_for_list(coresList,
&mgr->stat.number_of_LinphoneMessageReceivedWithFile,
old_stats.number_of_LinphoneMessageReceivedWithFile + 1,
liblinphone_tester_sip_timeout));
}
BC_ASSERT_PTR_NOT_NULL(mgr->stat.last_received_chat_message);
if (mgr->stat.last_received_chat_message != NULL) {
const string expected = ContentType::Icalendar.getMediaType();
BC_ASSERT_STRING_EQUAL(
linphone_chat_message_get_content_type(mgr->stat.last_received_chat_message),
expected.c_str());
}
bctbx_list_t *participant_chat_room_participants =
bctbx_list_append(NULL, manager_editing->identity);
LinphoneChatRoom *pcr = linphone_core_search_chat_room(mgr->lc, NULL, mgr->identity, NULL,
participant_chat_room_participants);
bctbx_list_free(participant_chat_room_participants);
BC_ASSERT_PTR_NOT_NULL(pcr);
bctbx_list_t *chat_room_participants = bctbx_list_append(NULL, mgr->identity);
LinphoneChatRoom *cr = linphone_core_search_chat_room(
manager_editing->lc, NULL, manager_editing->identity, NULL, chat_room_participants);
bctbx_list_free(chat_room_participants);
BC_ASSERT_PTR_NOT_NULL(cr);
int number_chat_rooms = 0;
if (mgr == marie.getCMgr()) {
number_chat_rooms = 3;
} else if (from_organizer || (mgr == michelle.getCMgr())) {
number_chat_rooms = 1;
} else {
number_chat_rooms = 2;
}
BC_ASSERT_EQUAL((int)bctbx_list_size(linphone_core_get_chat_rooms(mgr->lc)),
number_chat_rooms, int, "%d");
if (cr) {
LinphoneChatMessage *msg = linphone_chat_room_get_last_message_in_history(cr);
701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770
BC_ASSERT_PTR_NOT_NULL(msg);
const bctbx_list_t *original_contents = linphone_chat_message_get_contents(msg);
BC_ASSERT_EQUAL((int)bctbx_list_size(original_contents), 1, int, "%d");
LinphoneContent *original_content =
(LinphoneContent *)bctbx_list_get_data(original_contents);
if (BC_ASSERT_PTR_NOT_NULL(original_content)) {
LinphoneConferenceInfo *conf_info_from_original_content =
linphone_factory_create_conference_info_from_icalendar_content(
linphone_factory_get(), original_content);
if (BC_ASSERT_PTR_NOT_NULL(conf_info_from_original_content)) {
int exp_sequence = 0;
if (mgr == michelle.getCMgr()) {
if (add) {
exp_sequence = 0;
} else {
exp_sequence = 1;
}
} else if (mgr == lise.getCMgr()) {
exp_sequence = (attempt + 1);
} else {
exp_sequence = (sequence + attempt + 1);
}
LinphoneConferenceInfoState exp_state = LinphoneConferenceInfoStateNew;
if (mgr == michelle.getCMgr()) {
if (add) {
exp_state = LinphoneConferenceInfoStateNew;
} else {
exp_state = LinphoneConferenceInfoStateCancelled;
}
} else {
exp_state = LinphoneConferenceInfoStateUpdated;
}
update_sequence_number(&participants_info, {michelle.getCMgr()->identity},
(mgr == focus.getCMgr()) ? 0 : (sequence + attempt + 1),
(mgr == focus.getCMgr()) ? -1 : 0);
LinphoneParticipantInfo *participant_info =
linphone_participant_info_new(lise.getCMgr()->identity);
const bctbx_list_t *participant_info_it = bctbx_list_find_custom(
participants_info,
(int (*)(const void *, const void *))find_matching_participant_info,
participant_info);
BC_ASSERT_PTR_NOT_NULL(participant_info_it);
if (participant_info_it) {
LinphoneParticipantInfo *participant_info_found =
(LinphoneParticipantInfo *)bctbx_list_get_data(participant_info_it);
linphone_participant_info_set_sequence_number(participant_info_found,
(attempt + 1));
}
linphone_participant_info_unref(participant_info);
check_conference_info_against_db(mgr, confAddr,
conf_info_from_original_content);
linphone_conference_info_unref(conf_info_from_original_content);
check_conference_info_in_db(mgr, uid, confAddr, marie.getCMgr()->identity,
participants_info, start_time, duration, subject,
description2, exp_sequence, exp_state,
security_level, FALSE);
}
}
linphone_chat_message_unref(msg);
}
}
participant_stats.pop_front();
}
} else {
771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840
BC_ASSERT_TRUE(wait_for_list(coresList,
&manager_editing->stat.number_of_ConferenceSchedulerStateError,
manager_editing_stat.number_of_ConferenceSchedulerStateError + 1,
liblinphone_tester_sip_timeout));
}
linphone_conference_scheduler_unref(conference_scheduler);
for (auto mgr : {focus.getCMgr(), marie.getCMgr(), laure.getCMgr(), pauline.getCMgr(),
michelle.getCMgr(), lise.getCMgr()}) {
LinphoneConferenceInfo *info =
linphone_core_find_conference_information_from_uri(mgr->lc, confAddr);
if (!use_default_account && (mgr == michelle.getCMgr())) {
BC_ASSERT_PTR_NULL(info);
} else if (BC_ASSERT_PTR_NOT_NULL(info)) {
const char *exp_subject = NULL;
if (use_default_account) {
exp_subject = subject;
} else {
exp_subject = initialSubject;
}
const char *exp_description = NULL;
if (mgr != focus.getCMgr()) {
if (use_default_account) {
exp_description = description2;
} else {
exp_description = description;
}
}
unsigned int exp_sequence = 0;
LinphoneConferenceInfoState exp_state = LinphoneConferenceInfoStateNew;
if (mgr == focus.getCMgr()) {
exp_sequence = 0;
exp_state = LinphoneConferenceInfoStateUpdated;
} else {
if (mgr == michelle.getCMgr()) {
if (add) {
exp_state = LinphoneConferenceInfoStateNew;
} else {
exp_state = LinphoneConferenceInfoStateCancelled;
}
} else if (mgr == lise.getCMgr()) {
exp_state = use_default_account ? LinphoneConferenceInfoStateUpdated
: LinphoneConferenceInfoStateNew;
} else {
exp_state = LinphoneConferenceInfoStateUpdated;
}
if (mgr == michelle.getCMgr()) {
if (add) {
exp_sequence = 0;
} else {
exp_sequence = 1;
}
} else if (mgr == lise.getCMgr()) {
exp_sequence = use_default_account ? (attempt + 1) : 0;
} else {
exp_sequence = use_default_account ? (attempt + 2) : 1;
}
}
bool is_focus = (mgr == focus.getCMgr());
bctbx_list_t *participants_info2 = bctbx_list_copy_with_data(
participants_info, (bctbx_list_copy_func)linphone_participant_info_clone);
if (is_focus) {
add_participant_info_to_list(&participants_info2, marie.getCMgr()->identity,
LinphoneParticipantRoleSpeaker, 0);
}
841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910
// If not using the default account (which was used to create the conference), the
// conference scheduler errors out and Michelle is not added
int exp_sequence_number = 0;
if (use_default_account) {
if (is_focus) {
exp_sequence_number = (attempt + 1);
} else {
exp_sequence_number = (attempt + 2);
}
} else {
if (is_focus) {
exp_sequence_number = 0;
} else {
exp_sequence_number = 1;
}
}
std::list<LinphoneAddress *> new_participants{michelle.getCMgr()->identity};
if (!join || (is_focus && (attempt > 0))) {
new_participants.push_back(marie.getCMgr()->identity);
}
update_sequence_number(&participants_info2, new_participants, exp_sequence_number,
(mgr == focus.getCMgr()) ? -1 : 0);
LinphoneParticipantInfo *lise_participant_info =
linphone_participant_info_new(lise.getCMgr()->identity);
const bctbx_list_t *participant_info_it = bctbx_list_find_custom(
participants_info2, (int (*)(const void *, const void *))find_matching_participant_info,
lise_participant_info);
BC_ASSERT_PTR_NOT_NULL(participant_info_it);
if (participant_info_it) {
int exp_lise_sequence_number = 0;
if (use_default_account) {
if (is_focus) {
exp_lise_sequence_number = attempt;
} else {
exp_lise_sequence_number = (attempt + 1);
}
} else {
if (is_focus) {
exp_lise_sequence_number = -1;
} else {
exp_lise_sequence_number = 0;
}
}
LinphoneParticipantInfo *participant_info_found =
(LinphoneParticipantInfo *)bctbx_list_get_data(participant_info_it);
linphone_participant_info_set_sequence_number(participant_info_found,
exp_lise_sequence_number);
}
linphone_participant_info_unref(lise_participant_info);
if (!is_focus) {
int exp_organizer_sequence = 0;
if (use_default_account) {
exp_organizer_sequence = attempt + 2;
} else {
exp_organizer_sequence = 1;
}
linphone_conference_info_check_organizer(info, exp_organizer_sequence);
}
check_conference_info_in_db(mgr, uid, confAddr, marie.getCMgr()->identity, participants_info2,
start_time, duration, exp_subject, exp_description, exp_sequence,
exp_state, security_level, FALSE);
bctbx_list_free_with_data(participants_info2,
(bctbx_list_free_func)linphone_participant_info_unref);
}
if (info) {
linphone_conference_info_unref(info);
911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980
}
}
linphone_conference_info_unref(conf_info);
}
add = !add;
}
bctbx_list_free(initialInfos);
bctbx_list_free_with_data(participants_info, (bctbx_list_free_func)linphone_participant_info_unref);
ms_free(uid);
ms_free(conference_address_str);
linphone_address_unref(alternative_address);
linphone_address_unref(confAddr);
bctbx_list_free(coresList);
}
}
static void organizer_edits_simple_conference(void) {
edit_simple_conference_base(TRUE, TRUE, FALSE, FALSE, TRUE, FALSE, LinphoneConferenceSecurityLevelNone, FALSE);
}
static void organizer_edits_simple_conference_using_different_account(void) {
edit_simple_conference_base(TRUE, FALSE, TRUE, FALSE, FALSE, FALSE, LinphoneConferenceSecurityLevelNone, FALSE);
}
static void organizer_edits_simple_conference_while_active(void) {
edit_simple_conference_base(TRUE, TRUE, FALSE, TRUE, TRUE, FALSE, LinphoneConferenceSecurityLevelNone, FALSE);
}
static void participant_edits_simple_conference(void) {
edit_simple_conference_base(FALSE, TRUE, TRUE, FALSE, FALSE, FALSE, LinphoneConferenceSecurityLevelNone, FALSE);
}
static void participant_edits_simple_conference_using_different_account(void) {
edit_simple_conference_base(FALSE, FALSE, FALSE, FALSE, TRUE, FALSE, LinphoneConferenceSecurityLevelNone, FALSE);
}
static void organizer_edits_simple_conference_with_server_restart(void) {
edit_simple_conference_base(TRUE, TRUE, FALSE, FALSE, TRUE, TRUE, LinphoneConferenceSecurityLevelNone, FALSE);
}
static void conference_edition_with_participant_role_changed(void) {
edit_simple_conference_base(TRUE, TRUE, TRUE, TRUE, FALSE, FALSE, LinphoneConferenceSecurityLevelNone, TRUE);
}
static void conference_edition_with_simultaneous_participant_add_remove_base(bool_t codec_mismatch) {
Focus focus("chloe_rc");
{ // to make sure focus is destroyed after clients.
linphone_core_enable_lime_x3dh(focus.getLc(), true);
ClientConference marie("marie_rc", focus.getConferenceFactoryAddress(), true);
ClientConference pauline("pauline_rc", focus.getConferenceFactoryAddress(), true);
ClientConference laure("laure_tcp_rc", focus.getConferenceFactoryAddress(), true);
ClientConference michelle("michelle_rc", focus.getConferenceFactoryAddress(), true);
focus.registerAsParticipantDevice(marie);
focus.registerAsParticipantDevice(pauline);
focus.registerAsParticipantDevice(laure);
focus.registerAsParticipantDevice(michelle);
setup_conference_info_cbs(marie.getCMgr());
linphone_core_set_file_transfer_server(marie.getLc(), file_transfer_url);
bctbx_list_t *coresList = bctbx_list_append(NULL, focus.getLc());
coresList = bctbx_list_append(coresList, marie.getLc());
coresList = bctbx_list_append(coresList, pauline.getLc());
coresList = bctbx_list_append(coresList, laure.getLc());
coresList = bctbx_list_append(coresList, michelle.getLc());
BC_ASSERT_TRUE(wait_for_list(coresList, &marie.getStats().number_of_X3dhUserCreationSuccess, 1,
x3dhServer_creationTimeout));
BC_ASSERT_TRUE(wait_for_list(coresList, &laure.getStats().number_of_X3dhUserCreationSuccess, 1,
981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050
x3dhServer_creationTimeout));
BC_ASSERT_TRUE(wait_for_list(coresList, &pauline.getStats().number_of_X3dhUserCreationSuccess, 1,
x3dhServer_creationTimeout));
BC_ASSERT_TRUE(wait_for_list(coresList, &michelle.getStats().number_of_X3dhUserCreationSuccess, 1,
x3dhServer_creationTimeout));
BC_ASSERT_TRUE(linphone_core_lime_x3dh_enabled(marie.getLc()));
BC_ASSERT_TRUE(linphone_core_lime_x3dh_enabled(pauline.getLc()));
BC_ASSERT_TRUE(linphone_core_lime_x3dh_enabled(laure.getLc()));
BC_ASSERT_TRUE(linphone_core_lime_x3dh_enabled(michelle.getLc()));
for (auto mgr : {focus.getCMgr(), marie.getCMgr(), pauline.getCMgr(), laure.getCMgr(), michelle.getCMgr()}) {
if (codec_mismatch) {
if (mgr == marie.getCMgr()) {
disable_all_audio_codecs_except_one(mgr->lc, "pcmu", -1);
} else {
disable_all_audio_codecs_except_one(mgr->lc, "pcma", -1);
}
}
}
std::list<LinphoneCoreManager *> participants{pauline.getCMgr(), marie.getCMgr(), laure.getCMgr()};
time_t start_time = time(NULL) + 600; // Start in 10 minutes
int duration = 60; // minutes
time_t end_time = (duration <= 0) ? -1 : (start_time + duration * 60);
const char *initialSubject = "Test characters: <S-F12><S-F11><S-F6> £$%§";
const char *description = "Testing characters";
LinphoneConferenceSecurityLevel security_level = LinphoneConferenceSecurityLevelNone;
bctbx_list_t *participants_info = NULL;
std::map<LinphoneCoreManager *, LinphoneParticipantInfo *> participantList;
LinphoneParticipantRole role = LinphoneParticipantRoleSpeaker;
for (auto &p : participants) {
participantList.insert(
std::make_pair(p, add_participant_info_to_list(&participants_info, p->identity, role, -1)));
role = (role == LinphoneParticipantRoleSpeaker) ? LinphoneParticipantRoleListener
: LinphoneParticipantRoleSpeaker;
}
LinphoneAddress *confAddr = create_conference_on_server(focus, marie, participantList, start_time, end_time,
initialSubject, description, TRUE, security_level);
BC_ASSERT_PTR_NOT_NULL(confAddr);
// Chat room creation to send ICS
BC_ASSERT_TRUE(wait_for_list(coresList, &marie.getStats().number_of_LinphoneConferenceStateCreated, 2,
liblinphone_tester_sip_timeout));
const char *subject = "Test characters: <S-F12><S-F11><S-F6> £$%§ (+edits)";
const char *description2 = "Testing characters (+edits)";
stats marie_stat = marie.getStats();
LinphoneAccount *editing_account = linphone_core_get_default_account(marie.getLc());
BC_ASSERT_PTR_NOT_NULL(editing_account);
char *uid = NULL;
unsigned int sequence = 0;
LinphoneConferenceInfo *info = linphone_core_find_conference_information_from_uri(marie.getLc(), confAddr);
if (BC_ASSERT_PTR_NOT_NULL(info)) {
uid = ms_strdup(linphone_conference_info_get_ics_uid(info));
BC_ASSERT_PTR_NOT_NULL(uid);
sequence = linphone_conference_info_get_ics_sequence(info);
linphone_conference_info_unref(info);
}
char *conference_address_str = (confAddr) ? linphone_address_as_string(confAddr) : ms_strdup("<unknown>");
ms_message("%s is trying to update conference %s - adding %s and removing %s",
linphone_core_get_identity(marie.getLc()), conference_address_str,
linphone_core_get_identity(michelle.getLc()), linphone_core_get_identity(laure.getLc()));
ms_free(conference_address_str);
1051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120
// Remove Laure from list of expected participants
LinphoneParticipantInfo *laure_participant_info = linphone_participant_info_new(laure.getCMgr()->identity);
bctbx_list_t *laure_participant_info_found_it = bctbx_list_find_custom(
participants_info, (int (*)(const void *, const void *))find_matching_participant_info,
laure_participant_info);
BC_ASSERT_PTR_NOT_NULL(laure_participant_info_found_it);
if (laure_participant_info_found_it) {
LinphoneParticipantInfo *laure_participant_info_found =
(LinphoneParticipantInfo *)bctbx_list_get_data(laure_participant_info_found_it);
participants_info = bctbx_list_remove(participants_info, laure_participant_info_found);
linphone_participant_info_unref(laure_participant_info_found);
}
linphone_participant_info_unref(laure_participant_info);
participantList.erase(laure.getCMgr());
// Add michelle to list of expected participants
participantList.insert(std::make_pair(
michelle.getCMgr(), add_participant_info_to_list(&participants_info, michelle.getCMgr()->identity,
LinphoneParticipantRoleUnknown, 0)));
stats focus_stat = focus.getStats();
LinphoneConferenceInfo *conf_info = linphone_core_find_conference_information_from_uri(marie.getLc(), confAddr);
linphone_conference_info_set_subject(conf_info, subject);
linphone_conference_info_set_description(conf_info, description2);
linphone_conference_info_add_participant(conf_info, michelle.getCMgr()->identity);
linphone_conference_info_remove_participant(conf_info, laure.getCMgr()->identity);
const bctbx_list_t *ics_participants = linphone_conference_info_get_participant_infos(conf_info);
BC_ASSERT_EQUAL(bctbx_list_size(ics_participants), participants.size(), size_t, "%zu");
std::list<stats> participant_stats;
for (auto mgr : {focus.getCMgr(), marie.getCMgr(), laure.getCMgr(), pauline.getCMgr(), michelle.getCMgr()}) {
participant_stats.push_back(mgr->stat);
}
LinphoneConferenceScheduler *conference_scheduler = linphone_core_create_conference_scheduler(marie.getLc());
linphone_conference_scheduler_set_account(conference_scheduler, editing_account);
LinphoneConferenceSchedulerCbs *cbs = linphone_factory_create_conference_scheduler_cbs(linphone_factory_get());
linphone_conference_scheduler_cbs_set_state_changed(cbs, conference_scheduler_state_changed);
linphone_conference_scheduler_cbs_set_invitations_sent(cbs, conference_scheduler_invitations_sent);
linphone_conference_scheduler_add_callbacks(conference_scheduler, cbs);
linphone_conference_scheduler_cbs_unref(cbs);
linphone_conference_scheduler_set_info(conference_scheduler, conf_info);
BC_ASSERT_TRUE(wait_for_list(coresList, &marie.getStats().number_of_ConferenceSchedulerStateUpdating,
marie_stat.number_of_ConferenceSchedulerStateUpdating + 1,
liblinphone_tester_sip_timeout));
BC_ASSERT_TRUE(wait_for_list(coresList, &marie.getStats().number_of_ConferenceSchedulerStateReady,
marie_stat.number_of_ConferenceSchedulerStateReady + 1,
liblinphone_tester_sip_timeout));
BC_ASSERT_TRUE(wait_for_list(coresList, &focus.getStats().number_of_LinphoneCallIncomingReceived,
focus_stat.number_of_LinphoneCallIncomingReceived + 1,
liblinphone_tester_sip_timeout));
BC_ASSERT_TRUE(wait_for_list(coresList, &focus.getStats().number_of_LinphoneCallStreamsRunning,
focus_stat.number_of_LinphoneCallStreamsRunning + 1,
liblinphone_tester_sip_timeout));
BC_ASSERT_TRUE(wait_for_list(coresList, &focus.getStats().number_of_LinphoneCallEnd,
focus_stat.number_of_LinphoneCallEnd + 1, liblinphone_tester_sip_timeout));
BC_ASSERT_TRUE(wait_for_list(coresList, &focus.getStats().number_of_LinphoneCallReleased,
focus_stat.number_of_LinphoneCallReleased + 1, liblinphone_tester_sip_timeout));
LinphoneChatRoomParams *chat_room_params = linphone_core_create_default_chat_room_params(marie.getLc());
linphone_chat_room_params_set_subject(chat_room_params, "Conference");
linphone_chat_room_params_enable_encryption(chat_room_params, TRUE);
linphone_chat_room_params_set_backend(chat_room_params, LinphoneChatRoomBackendFlexisipChat);
linphone_conference_scheduler_send_invitations(conference_scheduler, chat_room_params);
BC_ASSERT_TRUE(wait_for_list(coresList, &marie.getStats().number_of_ConferenceSchedulerInvitationsSent,
1121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190
marie_stat.number_of_ConferenceSchedulerInvitationsSent + 1,
liblinphone_tester_sip_timeout));
for (auto mgr : {focus.getCMgr(), marie.getCMgr(), laure.getCMgr(), pauline.getCMgr(), michelle.getCMgr()}) {
auto old_stats = participant_stats.front();
if ((mgr != focus.getCMgr()) && (mgr != marie.getCMgr())) {
BC_ASSERT_TRUE(wait_for_list(coresList, &mgr->stat.number_of_LinphoneMessageReceived,
old_stats.number_of_LinphoneMessageReceived + 1,
liblinphone_tester_sip_timeout));
if (!linphone_core_conference_ics_in_message_body_enabled(marie.getLc())) {
BC_ASSERT_TRUE(wait_for_list(coresList, &mgr->stat.number_of_LinphoneMessageReceivedWithFile,
old_stats.number_of_LinphoneMessageReceivedWithFile + 1,
liblinphone_tester_sip_timeout));
}
BC_ASSERT_PTR_NOT_NULL(mgr->stat.last_received_chat_message);
if (mgr->stat.last_received_chat_message != NULL) {
const string expected = ContentType::Icalendar.getMediaType();
BC_ASSERT_STRING_EQUAL(linphone_chat_message_get_content_type(mgr->stat.last_received_chat_message),
expected.c_str());
}
bctbx_list_t *participant_chat_room_participants = bctbx_list_append(NULL, marie.getCMgr()->identity);
LinphoneChatRoom *pcr = linphone_core_search_chat_room(mgr->lc, chat_room_params, mgr->identity, NULL,
participant_chat_room_participants);
bctbx_list_free(participant_chat_room_participants);
BC_ASSERT_PTR_NOT_NULL(pcr);
bctbx_list_t *chat_room_participants = bctbx_list_append(NULL, mgr->identity);
LinphoneChatRoom *cr = linphone_core_search_chat_room(
marie.getLc(), chat_room_params, marie.getCMgr()->identity, NULL, chat_room_participants);
bctbx_list_free(chat_room_participants);
BC_ASSERT_PTR_NOT_NULL(cr);
BC_ASSERT_EQUAL((int)bctbx_list_size(linphone_core_get_chat_rooms(mgr->lc)),
(mgr == michelle.getCMgr()) ? 1 : 2, int, "%d");
if (cr) {
LinphoneChatMessage *msg = linphone_chat_room_get_last_message_in_history(cr);
BC_ASSERT_PTR_NOT_NULL(msg);
const bctbx_list_t *original_contents = linphone_chat_message_get_contents(msg);
BC_ASSERT_EQUAL((int)bctbx_list_size(original_contents), 1, int, "%d");
LinphoneContent *original_content = (LinphoneContent *)bctbx_list_get_data(original_contents);
if (BC_ASSERT_PTR_NOT_NULL(original_content)) {
LinphoneConferenceInfo *conf_info_from_original_content =
linphone_factory_create_conference_info_from_icalendar_content(linphone_factory_get(),
original_content);
if (BC_ASSERT_PTR_NOT_NULL(conf_info_from_original_content)) {
LinphoneConferenceInfoState exp_state = LinphoneConferenceInfoStateNew;
if (mgr == laure.getCMgr()) {
exp_state = LinphoneConferenceInfoStateCancelled;
} else if (mgr == michelle.getCMgr()) {
exp_state = LinphoneConferenceInfoStateNew;
} else {
exp_state = LinphoneConferenceInfoStateUpdated;
}
update_sequence_number(&participants_info, {michelle.getCMgr()->identity},
(mgr == focus.getCMgr()) ? 0 : 1, (mgr == focus.getCMgr()) ? -1 : 0);
const unsigned int ics_sequence = (mgr == michelle.getCMgr()) ? 0 : (sequence + 1);
check_conference_info_members(conf_info_from_original_content, uid, confAddr,
marie.getCMgr()->identity, participants_info, start_time,
duration, subject, description2, ics_sequence, exp_state,
security_level, FALSE);
linphone_conference_info_unref(conf_info_from_original_content);
}
}
linphone_chat_message_unref(msg);
1191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260
}
}
participant_stats.pop_front();
}
linphone_chat_room_params_unref(chat_room_params);
linphone_conference_scheduler_unref(conference_scheduler);
for (auto mgr : {focus.getCMgr(), marie.getCMgr(), laure.getCMgr(), pauline.getCMgr(), michelle.getCMgr()}) {
LinphoneConferenceInfo *info = linphone_core_find_conference_information_from_uri(mgr->lc, confAddr);
if (BC_ASSERT_PTR_NOT_NULL(info)) {
const char *exp_subject = subject;
const char *exp_description = NULL;
if (mgr != focus.getCMgr()) {
exp_description = description2;
}
unsigned int exp_sequence = 0;
LinphoneConferenceInfoState exp_state = LinphoneConferenceInfoStateNew;
if (mgr == focus.getCMgr()) {
exp_sequence = 0;
exp_state = LinphoneConferenceInfoStateUpdated;
} else {
exp_sequence = (mgr == michelle.getCMgr()) ? 0 : (sequence + 1);
if (mgr == laure.getCMgr()) {
exp_state = LinphoneConferenceInfoStateCancelled;
} else if (mgr == michelle.getCMgr()) {
exp_state = LinphoneConferenceInfoStateNew;
} else {
exp_state = LinphoneConferenceInfoStateUpdated;
}
}
update_sequence_number(&participants_info, {michelle.getCMgr()->identity},
(mgr == focus.getCMgr()) ? 0 : 1, (mgr == focus.getCMgr()) ? -1 : 0);
check_conference_info_in_db(mgr, NULL, confAddr, marie.getCMgr()->identity, participants_info,
start_time, duration, exp_subject, exp_description, exp_sequence, exp_state,
security_level, FALSE);
}
if (info) {
linphone_conference_info_unref(info);
}
}
bctbx_list_free_with_data(participants_info, (bctbx_list_free_func)linphone_participant_info_unref);
linphone_conference_info_unref(conf_info);
ms_free(uid);
linphone_address_unref(confAddr);
bctbx_list_free(coresList);
}
}
static void conference_edition_with_simultaneous_participant_add_remove(void) {
conference_edition_with_simultaneous_participant_add_remove_base(FALSE);
}
static void conference_edition_with_organizer_codec_mismatch(void) {
conference_edition_with_simultaneous_participant_add_remove_base(TRUE);
}
static void conference_cancelled_through_edit_base(bool_t server_restart) {
Focus focus("chloe_rc");
{ // to make sure focus is destroyed after clients.
ClientConference marie("marie_rc", focus.getConferenceFactoryAddress());
ClientConference pauline("pauline_rc", focus.getConferenceFactoryAddress());
ClientConference laure("laure_tcp_rc", focus.getConferenceFactoryAddress());
ClientConference michelle("michelle_rc", focus.getConferenceFactoryAddress());
focus.registerAsParticipantDevice(marie);
1261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330
focus.registerAsParticipantDevice(pauline);
focus.registerAsParticipantDevice(laure);
focus.registerAsParticipantDevice(michelle);
setup_conference_info_cbs(marie.getCMgr());
linphone_core_set_file_transfer_server(marie.getLc(), file_transfer_url);
bctbx_list_t *coresList = bctbx_list_append(NULL, focus.getLc());
coresList = bctbx_list_append(coresList, marie.getLc());
coresList = bctbx_list_append(coresList, pauline.getLc());
coresList = bctbx_list_append(coresList, laure.getLc());
coresList = bctbx_list_append(coresList, michelle.getLc());
std::list<LinphoneCoreManager *> participants{michelle.getCMgr(), pauline.getCMgr(), laure.getCMgr()};
time_t start_time = time(NULL) + 600; // Start in 10 minutes
int duration = 60; // minutes
time_t end_time = (duration <= 0) ? -1 : (start_time + duration * 60);
const char *initialSubject = "Test characters: <S-F12><S-F11><S-F6> £$%§";
const char *description = "Testing characters";
LinphoneConferenceSecurityLevel security_level = LinphoneConferenceSecurityLevelNone;
bctbx_list_t *participants_info = NULL;
std::map<LinphoneCoreManager *, LinphoneParticipantInfo *> participantList;
LinphoneParticipantRole role = LinphoneParticipantRoleSpeaker;
for (auto &p : participants) {
participantList.insert(
std::make_pair(p, add_participant_info_to_list(&participants_info, p->identity, role, -1)));
role = (role == LinphoneParticipantRoleSpeaker) ? LinphoneParticipantRoleListener
: LinphoneParticipantRoleSpeaker;
}
LinphoneAddress *confAddr = create_conference_on_server(focus, marie, participantList, start_time, end_time,
initialSubject, description, TRUE, security_level);
BC_ASSERT_PTR_NOT_NULL(confAddr);
// Chat room creation to send ICS
BC_ASSERT_TRUE(wait_for_list(coresList, &marie.getStats().number_of_LinphoneConferenceStateCreated, 2,
liblinphone_tester_sip_timeout));
char *uid = NULL;
unsigned int sequence = 0;
LinphoneConferenceInfo *info = linphone_core_find_conference_information_from_uri(marie.getLc(), confAddr);
if (BC_ASSERT_PTR_NOT_NULL(info)) {
uid = ms_strdup(linphone_conference_info_get_ics_uid(info));
BC_ASSERT_PTR_NOT_NULL(uid);
sequence = linphone_conference_info_get_ics_sequence(info);
linphone_conference_info_unref(info);
}
stats focus_stat = focus.getStats();
stats manager_editing_stat = marie.getStats();
std::list<stats> participant_stats;
for (auto mgr : {focus.getCMgr(), marie.getCMgr(), laure.getCMgr(), pauline.getCMgr(), michelle.getCMgr()}) {
participant_stats.push_back(mgr->stat);
}
char *conference_address_str = (confAddr) ? linphone_address_as_string(confAddr) : ms_strdup("<unknown>");
ms_message("%s is trying to change duration of conference %s", linphone_core_get_identity(marie.getLc()),
conference_address_str);
LinphoneConferenceInfo *conf_info = linphone_core_find_conference_information_from_uri(marie.getLc(), confAddr);
unsigned int new_duration = 2000;
linphone_conference_info_set_duration(conf_info, new_duration);
LinphoneConferenceScheduler *conference_scheduler = linphone_core_create_conference_scheduler(marie.getLc());
LinphoneAccount *editing_account = linphone_core_get_default_account(marie.getLc());
BC_ASSERT_PTR_NOT_NULL(editing_account);
linphone_conference_scheduler_set_account(conference_scheduler, editing_account);
LinphoneConferenceSchedulerCbs *cbs = linphone_factory_create_conference_scheduler_cbs(linphone_factory_get());
linphone_conference_scheduler_cbs_set_state_changed(cbs, conference_scheduler_state_changed);
1331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400
linphone_conference_scheduler_cbs_set_invitations_sent(cbs, conference_scheduler_invitations_sent);
linphone_conference_scheduler_add_callbacks(conference_scheduler, cbs);
linphone_conference_scheduler_cbs_unref(cbs);
cbs = nullptr;
linphone_conference_scheduler_set_info(conference_scheduler, conf_info);
BC_ASSERT_TRUE(wait_for_list(coresList, &marie.getStats().number_of_ConferenceSchedulerStateUpdating,
manager_editing_stat.number_of_ConferenceSchedulerStateUpdating + 1,
liblinphone_tester_sip_timeout));
BC_ASSERT_TRUE(wait_for_list(coresList, &marie.getStats().number_of_ConferenceSchedulerStateReady,
manager_editing_stat.number_of_ConferenceSchedulerStateReady + 1,
liblinphone_tester_sip_timeout));
BC_ASSERT_TRUE(wait_for_list(coresList, &focus.getStats().number_of_LinphoneCallIncomingReceived,
focus_stat.number_of_LinphoneCallIncomingReceived + 1,
liblinphone_tester_sip_timeout));
BC_ASSERT_TRUE(wait_for_list(coresList, &focus.getStats().number_of_LinphoneCallStreamsRunning,
focus_stat.number_of_LinphoneCallStreamsRunning + 1,
liblinphone_tester_sip_timeout));
BC_ASSERT_TRUE(wait_for_list(coresList, &focus.getStats().number_of_LinphoneCallEnd,
focus_stat.number_of_LinphoneCallEnd + 1, liblinphone_tester_sip_timeout));
BC_ASSERT_TRUE(wait_for_list(coresList, &focus.getStats().number_of_LinphoneCallReleased,
focus_stat.number_of_LinphoneCallReleased + 1, liblinphone_tester_sip_timeout));
LinphoneChatRoomParams *chat_room_params = linphone_core_create_default_chat_room_params(marie.getLc());
linphone_chat_room_params_set_backend(chat_room_params, LinphoneChatRoomBackendBasic);
linphone_conference_scheduler_send_invitations(conference_scheduler, chat_room_params);
linphone_chat_room_params_unref(chat_room_params);
chat_room_params = nullptr;
BC_ASSERT_TRUE(wait_for_list(coresList, &marie.getStats().number_of_ConferenceSchedulerInvitationsSent,
manager_editing_stat.number_of_ConferenceSchedulerInvitationsSent + 1,
liblinphone_tester_sip_timeout));
for (auto mgr : {focus.getCMgr(), marie.getCMgr(), laure.getCMgr(), pauline.getCMgr(), michelle.getCMgr()}) {
auto old_stats = participant_stats.front();
if ((mgr != focus.getCMgr()) && (mgr != marie.getCMgr())) {
BC_ASSERT_TRUE(wait_for_list(coresList, &mgr->stat.number_of_LinphoneMessageReceived,
old_stats.number_of_LinphoneMessageReceived + 1,
liblinphone_tester_sip_timeout));
if (!linphone_core_conference_ics_in_message_body_enabled(marie.getLc())) {
BC_ASSERT_TRUE(wait_for_list(coresList, &mgr->stat.number_of_LinphoneMessageReceivedWithFile,
old_stats.number_of_LinphoneMessageReceivedWithFile + 1,
liblinphone_tester_sip_timeout));
}
BC_ASSERT_PTR_NOT_NULL(mgr->stat.last_received_chat_message);
if (mgr->stat.last_received_chat_message != NULL) {
const string expected = ContentType::Icalendar.getMediaType();
BC_ASSERT_STRING_EQUAL(linphone_chat_message_get_content_type(mgr->stat.last_received_chat_message),
expected.c_str());
}
bctbx_list_t *participant_chat_room_participants = bctbx_list_append(NULL, marie.getCMgr()->identity);
LinphoneChatRoom *pcr = linphone_core_search_chat_room(mgr->lc, NULL, mgr->identity, NULL,
participant_chat_room_participants);
bctbx_list_free(participant_chat_room_participants);
BC_ASSERT_PTR_NOT_NULL(pcr);
bctbx_list_t *chat_room_participants = bctbx_list_append(NULL, mgr->identity);
LinphoneChatRoom *cr = linphone_core_search_chat_room(marie.getLc(), NULL, marie.getCMgr()->identity,
NULL, chat_room_participants);
bctbx_list_free(chat_room_participants);
BC_ASSERT_PTR_NOT_NULL(cr);
BC_ASSERT_EQUAL((int)bctbx_list_size(linphone_core_get_chat_rooms(mgr->lc)), 1, int, "%d");
if (cr) {
LinphoneChatMessage *msg = linphone_chat_room_get_last_message_in_history(cr);
BC_ASSERT_PTR_NOT_NULL(msg);
1401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470
const bctbx_list_t *original_contents = linphone_chat_message_get_contents(msg);
BC_ASSERT_EQUAL((int)bctbx_list_size(original_contents), 1, int, "%d");
LinphoneContent *original_content = (LinphoneContent *)bctbx_list_get_data(original_contents);
if (BC_ASSERT_PTR_NOT_NULL(original_content)) {
LinphoneConferenceInfo *conf_info_from_original_content =
linphone_factory_create_conference_info_from_icalendar_content(linphone_factory_get(),
original_content);
if (BC_ASSERT_PTR_NOT_NULL(conf_info_from_original_content)) {
const unsigned int ics_sequence = (sequence + 1);
LinphoneConferenceInfoState exp_state = LinphoneConferenceInfoStateUpdated;
update_sequence_number(&participants_info, {}, (mgr == focus.getCMgr()) ? 0 : 1,
(mgr == focus.getCMgr()) ? -1 : 0);
check_conference_info_members(conf_info_from_original_content, uid, confAddr,
marie.getCMgr()->identity, participants_info, start_time,
new_duration, initialSubject, description, ics_sequence,
exp_state, security_level, FALSE);
linphone_conference_info_unref(conf_info_from_original_content);
}
}
linphone_chat_message_unref(msg);
}
}
participant_stats.pop_front();
}
linphone_conference_scheduler_unref(conference_scheduler);
conference_scheduler = nullptr;
linphone_conference_info_unref(conf_info);
conf_info = nullptr;
if (server_restart) {
ms_message("%s is restarting", linphone_core_get_identity(focus.getLc()));
coresList = bctbx_list_remove(coresList, focus.getLc());
// Restart flexisip
focus.reStart();
LinphoneVideoActivationPolicy *pol =
linphone_factory_create_video_activation_policy(linphone_factory_get());
linphone_video_activation_policy_set_automatically_accept(pol, TRUE);
linphone_video_activation_policy_set_automatically_initiate(pol, TRUE);
linphone_core_set_video_activation_policy(focus.getLc(), pol);
linphone_video_activation_policy_unref(pol);
linphone_core_enable_video_capture(focus.getLc(), TRUE);
linphone_core_enable_video_display(focus.getLc(), TRUE);
coresList = bctbx_list_append(coresList, focus.getLc());
}
const char *subject = "Test characters: <S-F12><S-F11><S-F6> £$%§ (+cancelled)";
const char *description2 = "Testing characters (+cancelled)";
info = linphone_core_find_conference_information_from_uri(marie.getLc(), confAddr);
if (BC_ASSERT_PTR_NOT_NULL(info)) {
sequence = linphone_conference_info_get_ics_sequence(info);
linphone_conference_info_unref(info);
}
ms_message("%s is trying to cancel conference %s", linphone_core_get_identity(marie.getLc()),
conference_address_str);
ms_free(conference_address_str);
focus_stat = focus.getStats();
manager_editing_stat = marie.getStats();
participant_stats.clear();
for (auto mgr : {focus.getCMgr(), marie.getCMgr(), laure.getCMgr(), pauline.getCMgr(), michelle.getCMgr()}) {
participant_stats.push_back(mgr->stat);
}
1471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540
conf_info = linphone_core_find_conference_information_from_uri(marie.getLc(), confAddr);
linphone_conference_info_set_subject(conf_info, subject);
linphone_conference_info_set_description(conf_info, description2);
const bctbx_list_t *ics_participants = linphone_conference_info_get_participant_infos(conf_info);
BC_ASSERT_EQUAL(bctbx_list_size(ics_participants), 3, size_t, "%zu");
conference_scheduler = linphone_core_create_conference_scheduler(marie.getLc());
linphone_conference_scheduler_set_account(conference_scheduler, editing_account);
cbs = linphone_factory_create_conference_scheduler_cbs(linphone_factory_get());
linphone_conference_scheduler_cbs_set_state_changed(cbs, conference_scheduler_state_changed);
linphone_conference_scheduler_cbs_set_invitations_sent(cbs, conference_scheduler_invitations_sent);
linphone_conference_scheduler_add_callbacks(conference_scheduler, cbs);
linphone_conference_scheduler_cbs_unref(cbs);
linphone_conference_scheduler_cancel_conference(conference_scheduler, conf_info);
BC_ASSERT_TRUE(wait_for_list(coresList, &marie.getStats().number_of_ConferenceSchedulerStateUpdating,
manager_editing_stat.number_of_ConferenceSchedulerStateUpdating + 1,
liblinphone_tester_sip_timeout));
BC_ASSERT_TRUE(wait_for_list(coresList, &marie.getStats().number_of_ConferenceSchedulerStateReady,
manager_editing_stat.number_of_ConferenceSchedulerStateReady + 1,
liblinphone_tester_sip_timeout));
BC_ASSERT_TRUE(wait_for_list(coresList, &focus.getStats().number_of_LinphoneCallIncomingReceived,
focus_stat.number_of_LinphoneCallIncomingReceived + 1,
liblinphone_tester_sip_timeout));
BC_ASSERT_TRUE(wait_for_list(coresList, &focus.getStats().number_of_LinphoneCallStreamsRunning,
focus_stat.number_of_LinphoneCallStreamsRunning + 1,
liblinphone_tester_sip_timeout));
BC_ASSERT_TRUE(wait_for_list(coresList, &focus.getStats().number_of_LinphoneCallEnd,
focus_stat.number_of_LinphoneCallEnd + 1, liblinphone_tester_sip_timeout));
BC_ASSERT_TRUE(wait_for_list(coresList, &focus.getStats().number_of_LinphoneCallReleased,
focus_stat.number_of_LinphoneCallReleased + 1, liblinphone_tester_sip_timeout));
BC_ASSERT_TRUE(wait_for_list(coresList, &focus.getStats().number_of_LinphoneConferenceStateTerminationPending,
focus_stat.number_of_LinphoneConferenceStateTerminationPending + 1,
liblinphone_tester_sip_timeout));
BC_ASSERT_TRUE(wait_for_list(coresList, &focus.getStats().number_of_LinphoneConferenceStateTerminated,
focus_stat.number_of_LinphoneConferenceStateTerminated + 1,
liblinphone_tester_sip_timeout));
BC_ASSERT_TRUE(wait_for_list(coresList, &focus.getStats().number_of_LinphoneConferenceStateDeleted,
focus_stat.number_of_LinphoneConferenceStateDeleted + 1,
liblinphone_tester_sip_timeout));
chat_room_params = linphone_core_create_default_chat_room_params(marie.getLc());
linphone_chat_room_params_set_backend(chat_room_params, LinphoneChatRoomBackendBasic);
linphone_conference_scheduler_send_invitations(conference_scheduler, chat_room_params);
linphone_chat_room_params_unref(chat_room_params);
BC_ASSERT_TRUE(wait_for_list(coresList, &marie.getStats().number_of_ConferenceSchedulerInvitationsSent,
manager_editing_stat.number_of_ConferenceSchedulerInvitationsSent + 1,
liblinphone_tester_sip_timeout));
for (auto mgr : {focus.getCMgr(), marie.getCMgr(), laure.getCMgr(), pauline.getCMgr(), michelle.getCMgr()}) {
auto old_stats = participant_stats.front();
if ((mgr != focus.getCMgr()) && (mgr != marie.getCMgr())) {
BC_ASSERT_TRUE(wait_for_list(coresList, &mgr->stat.number_of_LinphoneMessageReceived,
old_stats.number_of_LinphoneMessageReceived + 1,
liblinphone_tester_sip_timeout));
if (!linphone_core_conference_ics_in_message_body_enabled(marie.getLc())) {
BC_ASSERT_TRUE(wait_for_list(coresList, &mgr->stat.number_of_LinphoneMessageReceivedWithFile,
old_stats.number_of_LinphoneMessageReceivedWithFile + 1,
liblinphone_tester_sip_timeout));
}
BC_ASSERT_PTR_NOT_NULL(mgr->stat.last_received_chat_message);
if (mgr->stat.last_received_chat_message != NULL) {
const string expected = ContentType::Icalendar.getMediaType();
BC_ASSERT_STRING_EQUAL(linphone_chat_message_get_content_type(mgr->stat.last_received_chat_message),
expected.c_str());
1541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610
}
bctbx_list_t *participant_chat_room_participants = bctbx_list_append(NULL, marie.getCMgr()->identity);
LinphoneChatRoom *pcr = linphone_core_search_chat_room(mgr->lc, NULL, mgr->identity, NULL,
participant_chat_room_participants);
bctbx_list_free(participant_chat_room_participants);
BC_ASSERT_PTR_NOT_NULL(pcr);
bctbx_list_t *chat_room_participants = bctbx_list_append(NULL, mgr->identity);
LinphoneChatRoom *cr = linphone_core_search_chat_room(marie.getLc(), NULL, marie.getCMgr()->identity,
NULL, chat_room_participants);
bctbx_list_free(chat_room_participants);
BC_ASSERT_PTR_NOT_NULL(cr);
BC_ASSERT_EQUAL((int)bctbx_list_size(linphone_core_get_chat_rooms(mgr->lc)), 1, int, "%d");
if (cr) {
LinphoneChatMessage *msg = linphone_chat_room_get_last_message_in_history(cr);
BC_ASSERT_PTR_NOT_NULL(msg);
const bctbx_list_t *original_contents = linphone_chat_message_get_contents(msg);
BC_ASSERT_EQUAL((int)bctbx_list_size(original_contents), 1, int, "%d");
LinphoneContent *original_content = (LinphoneContent *)bctbx_list_get_data(original_contents);
if (BC_ASSERT_PTR_NOT_NULL(original_content)) {
LinphoneConferenceInfo *conf_info_from_original_content =
linphone_factory_create_conference_info_from_icalendar_content(linphone_factory_get(),
original_content);
if (BC_ASSERT_PTR_NOT_NULL(conf_info_from_original_content)) {
const unsigned int ics_sequence = (sequence + 1);
LinphoneConferenceInfoState exp_state = LinphoneConferenceInfoStateNew;
if (mgr == focus.getCMgr()) {
exp_state = LinphoneConferenceInfoStateUpdated;
} else {
exp_state = LinphoneConferenceInfoStateCancelled;
}
check_conference_info_members(conf_info_from_original_content, uid, confAddr,
marie.getCMgr()->identity, NULL, start_time, new_duration,
subject, description2, ics_sequence, exp_state,
security_level, FALSE);
linphone_conference_info_unref(conf_info_from_original_content);
}
}
linphone_chat_message_unref(msg);
}
}
participant_stats.pop_front();
}
linphone_conference_scheduler_unref(conference_scheduler);
for (auto mgr : {focus.getCMgr(), marie.getCMgr(), laure.getCMgr(), pauline.getCMgr(), michelle.getCMgr()}) {
LinphoneConferenceInfo *info = linphone_core_find_conference_information_from_uri(mgr->lc, confAddr);
if (BC_ASSERT_PTR_NOT_NULL(info)) {
const char *exp_subject = subject;
const char *exp_description = NULL;
if (mgr != focus.getCMgr()) {
exp_description = description2;
}
unsigned int exp_sequence = 0;
LinphoneConferenceInfoState exp_state = LinphoneConferenceInfoStateCancelled;
if (mgr == focus.getCMgr()) {
exp_sequence = 0;
} else {
exp_sequence = (sequence + 1);
}
check_conference_info_in_db(mgr, NULL, confAddr, marie.getCMgr()->identity, NULL, start_time,
new_duration, exp_subject, exp_description, exp_sequence, exp_state,
security_level, FALSE);
161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664
}
if (info) {
linphone_conference_info_unref(info);
}
}
bctbx_list_free_with_data(participants_info, (bctbx_list_free_func)linphone_participant_info_unref);
linphone_conference_info_unref(conf_info);
ms_free(uid);
linphone_address_unref(confAddr);
bctbx_list_free(coresList);
}
}
static void conference_cancelled_through_edit(void) {
conference_cancelled_through_edit_base(FALSE);
}
static void create_conference_with_server_restart_conference_cancelled(void) {
conference_cancelled_through_edit_base(TRUE);
}
} // namespace LinphoneTest
static test_t local_conference_conference_edition_tests[] = {
TEST_NO_TAG("Organizer edits simple conference", LinphoneTest::organizer_edits_simple_conference),
TEST_NO_TAG("Organizer edits simple conference using different account",
LinphoneTest::organizer_edits_simple_conference_using_different_account),
TEST_NO_TAG("Organizer edits simple conference while it is active",
LinphoneTest::organizer_edits_simple_conference_while_active),
TEST_NO_TAG("Organizer edits simple conference with server restart",
LinphoneTest::organizer_edits_simple_conference_with_server_restart),
TEST_NO_TAG("Participant edits simple conference", LinphoneTest::participant_edits_simple_conference),
TEST_NO_TAG("Participant edits simple conference using different account",
LinphoneTest::participant_edits_simple_conference_using_different_account),
TEST_NO_TAG("Conference cancelled through edit", LinphoneTest::conference_cancelled_through_edit),
TEST_NO_TAG("Conference edition with simultanoues participant added removed",
LinphoneTest::conference_edition_with_simultaneous_participant_add_remove),
TEST_NO_TAG("Conference edition with participant role changed",
LinphoneTest::conference_edition_with_participant_role_changed),
TEST_NO_TAG("Conference edition with organizer codec mismatch",
LinphoneTest::conference_edition_with_organizer_codec_mismatch),
TEST_NO_TAG("Create conference with server restart (conference cancelled)",
LinphoneTest::create_conference_with_server_restart_conference_cancelled)};
test_suite_t local_conference_test_suite_conference_edition = {"Local conference tester (Conference edition)",
NULL,
NULL,
liblinphone_tester_before_each,
liblinphone_tester_after_each,
sizeof(local_conference_conference_edition_tests) /
sizeof(local_conference_conference_edition_tests[0]),
local_conference_conference_edition_tests,
0};