tdlight-team/tdlight-telegram-bot-api
tdlight-team/tdlight-telegram-bot-api
1
1
Fork 0
mirror of https://github.com/tdlight-team/tdlight-telegram-bot-api.git synced 2024-12-24 03:35:52 +01:00
Code Issues Projects Releases Wiki Activity

Destroy deleted messages on another thread.

Browse Source
This commit is contained in:
levlam 2022-11-03 20:30:14 +03:00
parent 8aac13eb4d
commit daf986972b
2 changed files with 14 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
telegram-bot-api/Client.cpp
View File

@ -4806,9 +4806,14 @@ void Client::on_update(object_ptr<td_api::Object> result) {
} }
case td_api::updateDeleteMessages::ID: { case td_api::updateDeleteMessages::ID: {
auto update = move_object_as<td_api::updateDeleteMessages>(result); auto update = move_object_as<td_api::updateDeleteMessages>(result);
td::vector<td::unique_ptr<MessageInfo>> deleted_messages;
for (auto message_id : update->message_ids_) { for (auto message_id : update->message_ids_) {
delete_message(update->chat_id_, message_id, update->from_cache_); auto deleted_message = delete_message(update->chat_id_, message_id, update->from_cache_);
if (deleted_message != nullptr) {
deleted_messages.push_back(std::move(deleted_message));
}
} }
td::Scheduler::instance()->destroy_on_scheduler(get_file_gc_scheduler_id(), deleted_messages);
break; break;
} }
case td_api::updateFile::ID: { case td_api::updateFile::ID: {
@ -10548,10 +10553,10 @@ void Client::remove_replies_to_message(int64 chat_id, int64 reply_to_message_id,
reply_message_ids_.erase(it); reply_message_ids_.erase(it);
} }
void Client::delete_message(int64 chat_id, int64 message_id, bool only_from_cache) { td::unique_ptr<Client::MessageInfo> Client::delete_message(int64 chat_id, int64 message_id, bool only_from_cache) {
remove_replies_to_message(chat_id, message_id, only_from_cache); remove_replies_to_message(chat_id, message_id, only_from_cache);
auto message_info = messages_.get_pointer({chat_id, message_id}); auto message_info = std::move(messages_[{chat_id, message_id}]);
if (message_info == nullptr) { if (message_info == nullptr) {
if (yet_unsent_messages_.count({chat_id, message_id}) > 0) { if (yet_unsent_messages_.count({chat_id, message_id}) > 0) {
// yet unsent message is deleted, possible only if we are trying to write to inaccessible supergroup or // yet unsent message is deleted, possible only if we are trying to write to inaccessible supergroup or
@ -10576,12 +10581,11 @@ void Client::delete_message(int64 chat_id, int64 message_id, bool only_from_cach
on_message_send_failed(chat_id, message_id, 0, std::move(error)); on_message_send_failed(chat_id, message_id, 0, std::move(error));
} }
return; } else {
set_message_reply_to_message_id(message_info.get(), 0);
messages_.erase({chat_id, message_id});
} }
return message_info;
set_message_reply_to_message_id(message_info, 0);
messages_.erase({chat_id, message_id});
} }
Client::FullMessageId Client::add_message(object_ptr<td_api::message> &&message, bool force_update_content) { Client::FullMessageId Client::add_message(object_ptr<td_api::message> &&message, bool force_update_content) {

3
telegram-bot-api/Client.h
View File

@ -812,7 +812,8 @@ class Client final : public WebhookActor::Callback {
static void json_store_permissions(td::JsonObjectScope &object, const td_api::chatPermissions *permissions); static void json_store_permissions(td::JsonObjectScope &object, const td_api::chatPermissions *permissions);
void remove_replies_to_message(int64 chat_id, int64 reply_to_message_id, bool only_from_cache); void remove_replies_to_message(int64 chat_id, int64 reply_to_message_id, bool only_from_cache);
void delete_message(int64 chat_id, int64 message_id, bool only_from_cache);
td::unique_ptr<MessageInfo> delete_message(int64 chat_id, int64 message_id, bool only_from_cache);
void add_new_message(object_ptr<td_api::message> &&message, bool is_edited); void add_new_message(object_ptr<td_api::message> &&message, bool is_edited);
void process_new_message_queue(int64 chat_id); void process_new_message_queue(int64 chat_id);