tdlight-team/tdlight
tdlight-team/tdlight
1
1
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Save group call's stream_dc_id.

Browse Source
This commit is contained in:
levlam 2021-03-09 18:12:15 +03:00
parent 62cfe3bdd9
commit cd2fbc19e6
1 changed files with 13 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
td/telegram/GroupCallManager.cpp
View File

@ -13,6 +13,7 @@
#include "td/telegram/MessageId.h"
#include "td/telegram/MessagesManager.h"
#include "td/telegram/misc.h"
#include "td/telegram/net/DcId.h"
#include "td/telegram/net/NetQuery.h"
#include "td/telegram/Td.h"
#include "td/telegram/UpdatesManager.h"
@ -530,8 +531,9 @@ struct GroupCallManager::GroupCall {
int32 duration = 0;
int32 audio_source = 0;
int32 joined_date = 0;
vector<Promise<Unit>> after_join;
DcId stream_dc_id;
vector<Promise<Unit>> after_join;
bool have_pending_mute_new_participants = false;
bool pending_mute_new_participants = false;
string pending_title;
@ -2614,6 +2616,13 @@ InputGroupCallId GroupCallManager::update_group_call(const tl_object_ptr<telegra
call.mute_new_participants = group_call->join_muted_;
call.allowed_change_mute_new_participants = group_call->can_change_join_muted_;
call.participant_count = group_call->participants_count_;
if ((group_call->flags_ & telegram_api::groupCall::STREAM_DC_ID_MASK) != 0) {
call.stream_dc_id = DcId::create(group_call->stream_dc_id_);
if (!call.stream_dc_id.is_exact()) {
LOG(ERROR) << "Receive invalid stream DC ID in " << input_group_call_id;
call.stream_dc_id = DcId();
}
}
call.version = group_call->version_;
if (group_call->params_ != nullptr) {
join_params = std::move(group_call->params_->data_);
@ -2701,6 +2710,9 @@ InputGroupCallId GroupCallManager::update_group_call(const tl_object_ptr<telegra
group_call->can_be_managed = call.can_be_managed;
need_update = true;
}
if (call.stream_dc_id != group_call->stream_dc_id) {
group_call->stream_dc_id = call.stream_dc_id;
}
if (call.version > group_call->version) {
if (group_call->version != -1) {
// if we know group call version, then update participants only by corresponding updates