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

Delay responses to clickAnimatedEmojiMessage.

Browse Source
This commit is contained in:
levlam 2021-09-19 20:43:47 +03:00
parent d04aed1146
commit 22cd853249
2 changed files with 30 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
td/telegram/StickersManager.cpp
View File

@ -1236,6 +1236,7 @@ StickersManager::StickersManager(Td *td, ActorShared<> parent) : td_(td), parent
narrow_cast<int32>(G()->shared_config().get_option_integer("favorite_stickers_limit", 5)));
on_update_dice_emojis();
next_click_animated_emoji_message_ = Time::now();
next_update_animated_emoji_clicked_ = Time::now();
}
@ -4136,7 +4137,28 @@ void StickersManager::choose_animated_emoji_click_sticker(const StickerSet *stic
} else {
set_timeout_in(0.5);
}
promise.set_value(get_sticker_object(result.second));
auto now = Time::now();
if (now >= next_click_animated_emoji_message_) {
next_click_animated_emoji_message_ = now + MIN_ANIMATED_EMOJI_CLICK_DELAY;
promise.set_value(get_sticker_object(result.second));
} else {
create_actor<SleepActor>("SendClickAnimatedEmojiMessageResponse", next_click_animated_emoji_message_ - now,
PromiseCreator::lambda([actor_id = actor_id(this), sticker_id = result.second,
promise = std::move(promise)](Result<Unit> result) mutable {
send_closure(actor_id, &StickersManager::send_click_animated_emoji_message_response,
sticker_id, std::move(promise));
}))
.release();
next_click_animated_emoji_message_ += MIN_ANIMATED_EMOJI_CLICK_DELAY;
}
}
void StickersManager::send_click_animated_emoji_message_response(
FileId sticker_id, Promise<td_api::object_ptr<td_api::sticker>> &&promise) {
if (G()->close_flag()) {
return promise.set_error(Status::Error(500, "Request aborted"));
}
promise.set_value(get_sticker_object(sticker_id));
}
void StickersManager::timeout_expired() {
@ -4344,6 +4366,9 @@ void StickersManager::schedule_update_animated_emoji_clicked(const StickerSet *s
}
void StickersManager::send_update_animated_emoji_clicked(FullMessageId full_message_id, FileId sticker_id) {
if (G()->close_flag()) {
return;
}
if (td_->messages_manager_->is_message_edited_recently(full_message_id, 2)) {
// includes deleted full_message_id
return;

4
td/telegram/StickersManager.h
View File

@ -602,6 +602,9 @@ class StickersManager final : public Actor {
FullMessageId full_message_id, double start_time,
Promise<td_api::object_ptr<td_api::sticker>> &&promise);
void send_click_animated_emoji_message_response(FileId sticker_id,
Promise<td_api::object_ptr<td_api::sticker>> &&promise);
void flush_sent_animated_emoji_clicks();
void flush_pending_animated_emoji_clicks();
@ -763,6 +766,7 @@ class StickersManager final : public Actor {
std::unordered_map<int64, unique_ptr<PendingSetStickerSetThumbnail>> pending_set_sticker_set_thumbnails_;
double next_click_animated_emoji_message_ = 0;
double next_update_animated_emoji_clicked_ = 0;
vector<PendingGetAnimatedEmojiClickSticker> pending_get_animated_emoji_click_stickers_;
vector<PendingOnAnimatedEmojiClicked> pending_on_animated_emoji_message_clicked_;