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

Fail sending of messages for which updateMessageId has been received.

Browse Source
This commit is contained in:
levlam 2024-01-29 01:48:58 +03:00
parent eb3f9f7ba1
commit 983f669116
1 changed files with 16 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
td/telegram/MessagesManager.cpp
View File

@ -12368,11 +12368,23 @@ void MessagesManager::hangup() {
while (!being_sent_messages_.empty()) {
on_send_message_fail(being_sent_messages_.begin()->first, Global::request_aborted_error());
}
if (!update_message_ids_.empty()) {
LOG(ERROR) << "Have " << update_message_ids_.size() << " awaited sent messages";
while (!update_message_ids_.empty()) {
auto it = update_message_ids_.begin();
auto message_full_id = MessageFullId(it->first.get_dialog_id(), it->second);
update_message_ids_.erase(it);
// the message was sent successfully, but can't be added yet
fail_send_message(message_full_id, Global::request_aborted_error());
}
if (!update_scheduled_message_ids_.empty()) {
LOG(ERROR) << "Have " << update_scheduled_message_ids_.size() << " awaited sent scheduled messages";
while (!update_scheduled_message_ids_.empty()) {
auto it = update_scheduled_message_ids_.begin();
auto dialog_id = it->first;
auto message_ids = std::move(it->second);
update_scheduled_message_ids_.erase(it);
for (auto &message_id_it : message_ids) {
// the message was sent successfully, but can't be added yet
fail_send_message({dialog_id, message_id_it.second}, Global::request_aborted_error());
}
}
}