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

Don't update channel pts if failed to process updateEditChannelMessage.

Browse Source
This commit is contained in:
levlam 2022-10-26 14:52:51 +03:00
parent 201c4c3a2e
commit 8f0d216601
2 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
td/telegram/MessagesManager.cpp
View File

@ -7880,7 +7880,11 @@ void MessagesManager::add_pending_channel_update(DialogId dialog_id, tl_object_p
} }
if (d == nullptr || pts_count > 0) { if (d == nullptr || pts_count > 0) {
process_channel_update(std::move(update)); if (!process_channel_update(std::move(update)) &&
channel_get_difference_retry_timeout_.has_timeout(dialog_id.get())) {
promise.set_value(Unit());
return;
}
LOG_CHECK(!running_get_channel_difference(dialog_id)) << '"' << active_get_channel_differencies_[dialog_id] << '"'; LOG_CHECK(!running_get_channel_difference(dialog_id)) << '"' << active_get_channel_differencies_[dialog_id] << '"';
} else { } else {
LOG_IF(INFO, update->get_id() != dummyUpdate::ID) LOG_IF(INFO, update->get_id() != dummyUpdate::ID)
@ -7988,7 +7992,7 @@ void MessagesManager::process_pts_update(tl_object_ptr<telegram_api::Update> &&u
CHECK(!td_->updates_manager_->running_get_difference()); CHECK(!td_->updates_manager_->running_get_difference());
} }
void MessagesManager::process_channel_update(tl_object_ptr<telegram_api::Update> &&update_ptr) { bool MessagesManager::process_channel_update(tl_object_ptr<telegram_api::Update> &&update_ptr) {
switch (update_ptr->get_id()) { switch (update_ptr->get_id()) {
case dummyUpdate::ID: case dummyUpdate::ID:
LOG(INFO) << "Process dummyUpdate"; LOG(INFO) << "Process dummyUpdate";
@ -8030,6 +8034,9 @@ void MessagesManager::process_channel_update(tl_object_ptr<telegram_api::Update>
bool had_message = have_message_force(get_full_message_id(update->message_, false), "updateEditChannelMessage"); bool had_message = have_message_force(get_full_message_id(update->message_, false), "updateEditChannelMessage");
auto full_message_id = auto full_message_id =
on_get_message(std::move(update->message_), false, true, false, false, false, "updateEditChannelMessage"); on_get_message(std::move(update->message_), false, true, false, false, false, "updateEditChannelMessage");
if (full_message_id == FullMessageId()) {
return false;
}
on_message_edited(full_message_id, update->pts_, had_message); on_message_edited(full_message_id, update->pts_, had_message);
break; break;
} }
@ -8053,6 +8060,7 @@ void MessagesManager::process_channel_update(tl_object_ptr<telegram_api::Update>
default: default:
UNREACHABLE(); UNREACHABLE();
} }
return true;
} }
void MessagesManager::on_message_edited(FullMessageId full_message_id, int32 pts, bool had_message) { void MessagesManager::on_message_edited(FullMessageId full_message_id, int32 pts, bool had_message) {

2
td/telegram/MessagesManager.h
View File

@ -1971,7 +1971,7 @@ class MessagesManager final : public Actor {
void add_postponed_channel_update(DialogId dialog_id, tl_object_ptr<telegram_api::Update> &&update, int32 new_pts, void add_postponed_channel_update(DialogId dialog_id, tl_object_ptr<telegram_api::Update> &&update, int32 new_pts,
int32 pts_count, Promise<Unit> &&promise); int32 pts_count, Promise<Unit> &&promise);
void process_channel_update(tl_object_ptr<telegram_api::Update> &&update_ptr); bool process_channel_update(tl_object_ptr<telegram_api::Update> &&update_ptr);
void on_message_edited(FullMessageId full_message_id, int32 pts, bool had_message); void on_message_edited(FullMessageId full_message_id, int32 pts, bool had_message);