wiz0u/WTelegramClient
1
0
Fork 0
mirror of https://github.com/wiz0u/WTelegramClient.git synced 2025-12-06 06:52:01 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix never-ending loop in Channels_GetAllParticipants

Browse source
This commit is contained in:
Wizou 2021-12-07 15:07:35 +01:00
parent 73ac9384e4
commit f6eb1aa6fd
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/Client.cs
View file

@ -1339,7 +1339,7 @@ namespace WTelegram
/// <summary>Helper method that tries to fetch all participants from a Channel (beyond Telegram server-side limitations)</summary> /// <summary>Helper method that tries to fetch all participants from a Channel (beyond Telegram server-side limitations)</summary>
/// <param name="channel">The channel to query</param> /// <param name="channel">The channel to query</param>
/// <param name="includeKickBan">Also detch the kicked/banned members?</param> /// <param name="includeKickBan">Also fetch the kicked/banned members?</param>
/// <returns>Field count indicates the total count of members. Field participants contains those that were successfully fetched</returns> /// <returns>Field count indicates the total count of members. Field participants contains those that were successfully fetched</returns>
/// <remarks>This method can take a few minutes to complete on big channels. It likely won't be able to obtain the full total count of members</remarks> /// <remarks>This method can take a few minutes to complete on big channels. It likely won't be able to obtain the full total count of members</remarks>
public async Task<Channels_ChannelParticipants> Channels_GetAllParticipants(InputChannelBase channel, bool includeKickBan = false) public async Task<Channels_ChannelParticipants> Channels_GetAllParticipants(InputChannelBase channel, bool includeKickBan = false)
@ -1377,7 +1377,7 @@ namespace WTelegram
await sem.WaitAsync(); await sem.WaitAsync();
try try
{ {
ccp = await this.Channels_GetParticipants(channel, filter, offset, 2000, 0); ccp = await this.Channels_GetParticipants(channel, filter, offset, 1024, 0);
} }
finally finally
{ {
@ -1390,7 +1390,7 @@ namespace WTelegram
if (user_ids.Add(participant.UserID)) if (user_ids.Add(participant.UserID))
participants.Add(participant); participants.Add(participant);
offset += ccp.participants.Length; offset += ccp.participants.Length;
if (offset >= ccp.count) break; if (offset >= ccp.count || ccp.participants.Length == 0) break;
} }
if (recurse != null && (ccp.count == 200 || ccp.count == 1000)) if (recurse != null && (ccp.count == 200 || ccp.count == 1000))
await Task.WhenAll(Enumerable.Range('a', 26).Select(c => GetWithFilter(recurse(filter, (char)c), recurse))); await Task.WhenAll(Enumerable.Range('a', 26).Select(c => GetWithFilter(recurse(filter, (char)c), recurse)));