void/AyuGramDesktop
2
0
Fork 0
mirror of https://github.com/AyuGram/AyuGramDesktop.git synced 2025-06-03 21:54:05 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Remove unnecessary stale participant check.

Browse source
This commit is contained in:
John Preston 2025-04-05 09:57:47 +05:00
parent 783c5c12e9
commit e5f31dbe8e
2 changed files with 6 additions and 53 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

55
Telegram/SourceFiles/data/data_group_call.cpp
View file

@ -108,7 +108,6 @@ GroupCall::~GroupCall() {
}
api().request(_unknownParticipantPeersRequestId).cancel();
api().request(_participantsRequestId).cancel();
api().request(_checkStaleRequestId).cancel();
api().request(_reloadRequestId).cancel();
}
@ -212,9 +211,6 @@ void GroupCall::setParticipantsLoaded() {
}
void GroupCall::checkStaleParticipants() {
if (_checkStaleRequestId) {
return;
}
const auto &list = _participantsWithAccess.current();
if (list.empty()) {
return;
@ -227,57 +223,16 @@ void GroupCall::checkStaleParticipants() {
existing.emplace(id);
}
}
if (list.size() > existing.size()) {
checkStaleRequest();
return;
}
auto stale = base::flat_set<UserId>();
for (const auto &id : list) {
if (!existing.contains(id)) {
checkStaleRequest();
return;
stale.reserve(list.size());
stale.emplace(id);
}
}
}
void GroupCall::checkStaleRequest() {
if (_checkStaleRequestId) {
return;
if (!stale.empty()) {
_staleParticipantIds.fire(std::move(stale));
}
_checkStaleRequestId = api().request(MTPphone_GetGroupParticipants(
input(),
MTP_vector<MTPInputPeer>(), // ids
MTP_vector<MTPint>(), // ssrcs
MTP_string(QString()),
MTP_int(kMaxConferenceMembers + 10)
)).done([=](const MTPphone_GroupParticipants &result) {
_checkStaleRequestId = 0;
const auto &list = _participantsWithAccess.current();
if (list.empty()) {
return;
}
auto existing = base::flat_set<UserId>();
const auto &data = result.data();
existing.reserve(data.vparticipants().v.size() + 1);
existing.emplace(session().userId());
for (const auto &participant : data.vparticipants().v) {
const auto peerId = peerFromMTP(participant.data().vpeer());
if (const auto id = peerToUser(peerId)) {
existing.emplace(id);
}
}
auto stale = base::flat_set<UserId>();
for (const auto &id : list) {
if (!existing.contains(id)) {
stale.reserve(list.size());
stale.emplace(id);
}
}
if (!stale.empty()) {
_staleParticipantIds.fire(std::move(stale));
}
}).fail([=] {
_checkStaleRequestId = 0;
}).send();
}
bool GroupCall::processSavedFullCall() {

4
Telegram/SourceFiles/data/data_group_call.h
View file

@ -30,7 +30,7 @@ namespace Data {
[[nodiscard]] const std::string &RtmpEndpointId();
inline constexpr auto kMaxConferenceMembers = 10;
inline constexpr auto kMaxConferenceMembers = 200;
struct LastSpokeTimes {
crl::time anything = 0;
@ -157,7 +157,6 @@ public:
-> rpl::producer<base::flat_set<UserId>>;
void setParticipantsLoaded();
void checkStaleParticipants();
void checkStaleRequest();
void enqueueUpdate(const MTPUpdate &update);
void applyLocalUpdate(
@ -269,7 +268,6 @@ private:
rpl::variable<base::flat_set<UserId>> _participantsWithAccess;
rpl::event_stream<base::flat_set<UserId>> _staleParticipantIds;
mtpRequestId _checkStaleRequestId = 0;
rpl::lifetime _checkStaleLifetime;
bool _creator : 1 = false;