void/AyuGramDesktop
2
0
Fork 0
mirror of https://github.com/AyuGram/AyuGramDesktop.git synced 2025-06-07 15:43:55 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Added timeout to earn requests for channels and bots.

Browse source
This commit is contained in:
23rd 2025-05-06 21:30:02 +03:00
parent a8afc62db7
commit 53cee177e8
2 changed files with 16 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
Telegram/SourceFiles/data/data_channel.cpp
View file

@ -10,6 +10,7 @@ https://github.com/telegramdesktop/tdesktop/blob/master/LEGAL
#include "api/api_credits.h" #include "api/api_credits.h"
#include "api/api_global_privacy.h" #include "api/api_global_privacy.h"
#include "api/api_statistics.h" #include "api/api_statistics.h"
#include "base/timer_rpl.h"
#include "data/components/credits.h" #include "data/components/credits.h"
#include "data/data_changes.h" #include "data/data_changes.h"
#include "data/data_channel_admins.h" #include "data/data_channel_admins.h"
@ -1360,6 +1361,7 @@ void ApplyChannelUpdate(
} }
if (channel->flags() & Flag::CanViewRevenue) { if (channel->flags() & Flag::CanViewRevenue) {
static constexpr auto kTimeout = crl::time(60000);
const auto id = channel->id; const auto id = channel->id;
const auto weak = base::make_weak(&channel->session()); const auto weak = base::make_weak(&channel->session());
const auto creditsLoadLifetime = std::make_shared<rpl::lifetime>(); const auto creditsLoadLifetime = std::make_shared<rpl::lifetime>();
@ -1371,6 +1373,9 @@ void ApplyChannelUpdate(
creditsLoadLifetime->destroy(); creditsLoadLifetime->destroy();
} }
}); });
base::timer_once(kTimeout) | rpl::start_with_next([=] {
creditsLoadLifetime->destroy();
}, *creditsLoadLifetime);
const auto currencyLoadLifetime = std::make_shared<rpl::lifetime>(); const auto currencyLoadLifetime = std::make_shared<rpl::lifetime>();
const auto currencyLoad const auto currencyLoad
= currencyLoadLifetime->make_state<Api::EarnStatistics>(channel); = currencyLoadLifetime->make_state<Api::EarnStatistics>(channel);
@ -1385,6 +1390,9 @@ void ApplyChannelUpdate(
currencyLoadLifetime->destroy(); currencyLoadLifetime->destroy();
} }
}, *currencyLoadLifetime); }, *currencyLoadLifetime);
base::timer_once(kTimeout) | rpl::start_with_next([=] {
currencyLoadLifetime->destroy();
}, *currencyLoadLifetime);
} }
// For clearUpTill() call. // For clearUpTill() call.

8
Telegram/SourceFiles/data/data_user.cpp
View file

@ -11,6 +11,7 @@ https://github.com/telegramdesktop/tdesktop/blob/master/LEGAL
#include "api/api_global_privacy.h" #include "api/api_global_privacy.h"
#include "api/api_sensitive_content.h" #include "api/api_sensitive_content.h"
#include "api/api_statistics.h" #include "api/api_statistics.h"
#include "base/timer_rpl.h"
#include "storage/localstorage.h" #include "storage/localstorage.h"
#include "storage/storage_account.h" #include "storage/storage_account.h"
#include "storage/storage_user_photos.h" #include "storage/storage_user_photos.h"
@ -767,6 +768,7 @@ void ApplyUserUpdate(not_null<UserData*> user, const MTPDuserFull &update) {
Data::PeerUpdate::Flag::Rights); Data::PeerUpdate::Flag::Rights);
} }
if (info->canEditInformation) { if (info->canEditInformation) {
static constexpr auto kTimeout = crl::time(60000);
const auto id = user->id; const auto id = user->id;
const auto weak = base::make_weak(&user->session()); const auto weak = base::make_weak(&user->session());
const auto creditsLoadLifetime const auto creditsLoadLifetime
@ -779,6 +781,9 @@ void ApplyUserUpdate(not_null<UserData*> user, const MTPDuserFull &update) {
creditsLoadLifetime->destroy(); creditsLoadLifetime->destroy();
} }
}); });
base::timer_once(kTimeout) | rpl::start_with_next([=] {
creditsLoadLifetime->destroy();
}, *creditsLoadLifetime);
const auto currencyLoadLifetime const auto currencyLoadLifetime
= std::make_shared<rpl::lifetime>(); = std::make_shared<rpl::lifetime>();
const auto currencyLoad const auto currencyLoad
@ -794,6 +799,9 @@ void ApplyUserUpdate(not_null<UserData*> user, const MTPDuserFull &update) {
currencyLoadLifetime->destroy(); currencyLoadLifetime->destroy();
} }
}, *currencyLoadLifetime); }, *currencyLoadLifetime);
base::timer_once(kTimeout) | rpl::start_with_next([=] {
currencyLoadLifetime->destroy();
}, *currencyLoadLifetime);
} }
} }