diff --git a/td/telegram/ContactsManager.cpp b/td/telegram/ContactsManager.cpp index 6905de650..42c31b856 100644 --- a/td/telegram/ContactsManager.cpp +++ b/td/telegram/ContactsManager.cpp @@ -13128,7 +13128,7 @@ void ContactsManager::on_get_chat_full(tl_object_ptr &&c MessageId(ServerMessageId(channel->read_outbox_max_id_))); if ((channel->flags_ & CHANNEL_FULL_FLAG_HAS_AVAILABLE_MIN_MESSAGE_ID) != 0) { td_->messages_manager_->on_update_channel_max_unavailable_message_id( - channel_id, MessageId(ServerMessageId(channel->available_min_id_))); + channel_id, MessageId(ServerMessageId(channel->available_min_id_)), "ChannelFull"); } td_->messages_manager_->on_read_channel_inbox(channel_id, MessageId(ServerMessageId(channel->read_inbox_max_id_)), channel->unread_count_, channel->pts_, "ChannelFull"); diff --git a/td/telegram/MessagesManager.cpp b/td/telegram/MessagesManager.cpp index c2fcc3d5a..b8ca1d8c9 100644 --- a/td/telegram/MessagesManager.cpp +++ b/td/telegram/MessagesManager.cpp @@ -7484,20 +7484,20 @@ void MessagesManager::on_read_channel_outbox(ChannelId channel_id, MessageId max } void MessagesManager::on_update_channel_max_unavailable_message_id(ChannelId channel_id, - MessageId max_unavailable_message_id) { + MessageId max_unavailable_message_id, + const char *source) { if (!channel_id.is_valid()) { - LOG(ERROR) << "Receive max_unavailable_message_id in invalid " << channel_id; + LOG(ERROR) << "Receive max_unavailable_message_id in invalid " << channel_id << " from " << source; return; } DialogId dialog_id(channel_id); CHECK(!max_unavailable_message_id.is_scheduled()); if (!max_unavailable_message_id.is_valid() && max_unavailable_message_id != MessageId()) { - LOG(ERROR) << "Receive wrong max_unavailable_message_id: " << max_unavailable_message_id; + LOG(ERROR) << "Receive wrong max_unavailable_message_id: " << max_unavailable_message_id << " from " << source; max_unavailable_message_id = MessageId(); } - set_dialog_max_unavailable_message_id(dialog_id, max_unavailable_message_id, true, - "on_update_channel_max_unavailable_message_id"); + set_dialog_max_unavailable_message_id(dialog_id, max_unavailable_message_id, true, source); } void MessagesManager::on_update_dialog_online_member_count(DialogId dialog_id, int32 online_member_count, diff --git a/td/telegram/MessagesManager.h b/td/telegram/MessagesManager.h index af2c87b93..7e2105d73 100644 --- a/td/telegram/MessagesManager.h +++ b/td/telegram/MessagesManager.h @@ -376,7 +376,8 @@ class MessagesManager final : public Actor { void on_read_channel_outbox(ChannelId channel_id, MessageId max_message_id); - void on_update_channel_max_unavailable_message_id(ChannelId channel_id, MessageId max_unavailable_message_id); + void on_update_channel_max_unavailable_message_id(ChannelId channel_id, MessageId max_unavailable_message_id, + const char *source); void on_update_dialog_online_member_count(DialogId dialog_id, int32 online_member_count, bool is_from_server); diff --git a/td/telegram/UpdatesManager.cpp b/td/telegram/UpdatesManager.cpp index 55f981b4f..a4d68f030 100644 --- a/td/telegram/UpdatesManager.cpp +++ b/td/telegram/UpdatesManager.cpp @@ -3428,7 +3428,8 @@ void UpdatesManager::on_update(tl_object_ptr update, Promise &&promise) { td_->messages_manager_->on_update_channel_max_unavailable_message_id( - ChannelId(update->channel_id_), MessageId(ServerMessageId(update->available_min_id_))); + ChannelId(update->channel_id_), MessageId(ServerMessageId(update->available_min_id_)), + "updateChannelAvailableMessages"); promise.set_value(Unit()); }