From 6c1173d611855acf9b68b1b0166f2a83350ce1fa Mon Sep 17 00:00:00 2001
From: levlam <levlam@telegram.org>
Date: Sat, 16 Mar 2019 21:30:03 +0300
Subject: [PATCH] Add channel messages debug.

GitOrigin-RevId: 168f724d92d3ea48295216be6ce029439917b99c
---
 td/telegram/MessagesManager.cpp | 11 ++++++++---
 td/telegram/MessagesManager.h   |  2 ++
 2 files changed, 10 insertions(+), 3 deletions(-)

diff --git a/td/telegram/MessagesManager.cpp b/td/telegram/MessagesManager.cpp
index cca0a72a..013e452f 100644
--- a/td/telegram/MessagesManager.cpp
+++ b/td/telegram/MessagesManager.cpp
@@ -5632,10 +5632,10 @@ void MessagesManager::process_channel_update(tl_object_ptr<telegram_api::Update>
       break;
     }
     case telegram_api::updateEditChannelMessage::ID: {
+      LOG(INFO) << "Process updateEditChannelMessage";
       auto full_message_id =
           on_get_message(std::move(move_tl_object_as<telegram_api::updateEditChannelMessage>(update)->message_), false,
                          true, false, false, "updateEditChannelMessage");
-      LOG(INFO) << "Process updateEditChannelMessage";
       on_message_edited(full_message_id);
       break;
     }
@@ -21697,8 +21697,8 @@ MessagesManager::Message *MessagesManager::add_message_to_dialog(Dialog *d, uniq
                         message_id.get() > d->last_database_message_id.get() && !message->is_failed_to_send))) {
     if (!message->from_database) {
       LOG(ERROR) << "Ignore " << message_id << " in " << dialog_id << " received not through update from " << source
-                 << ". Last new is " << d->last_new_message_id << ", "
-                 << to_string(get_message_object(dialog_id, message.get()));
+                 << ". Last new is " << d->last_new_message_id << ", channel difference "
+                 << debug_channel_difference_dialog_ << to_string(get_message_object(dialog_id, message.get()));
       dump_debug_message_op(d, 3);
       if (dialog_id.get_type() == DialogType::Channel && have_input_peer(dialog_id, AccessRights::Read)) {
         channel_get_difference_retry_timeout_.add_timeout_in(dialog_id.get(), 0.001);
@@ -24041,6 +24041,8 @@ void MessagesManager::process_get_channel_difference_updates(
     vector<tl_object_ptr<telegram_api::Update>> &&other_updates) {
   LOG(INFO) << "In get channel difference for " << dialog_id << " receive " << new_messages.size() << " messages and "
             << other_updates.size() << " other updates";
+  CHECK(!debug_channel_difference_dialog_.is_valid());
+  debug_channel_difference_dialog_ = dialog_id;
   for (auto &update : other_updates) {
     if (update->get_id() == telegram_api::updateMessageID::ID) {
       auto sent_message_update = move_tl_object_as<telegram_api::updateMessageID>(update);
@@ -24078,6 +24080,9 @@ void MessagesManager::process_get_channel_difference_updates(
   if (need_repair_unread_count) {
     repair_channel_server_unread_count(get_dialog(dialog_id));
   }
+
+  CHECK(debug_channel_difference_dialog_ == dialog_id);
+  debug_channel_difference_dialog_ = DialogId();
 }
 
 void MessagesManager::on_get_channel_dialog(DialogId dialog_id, MessageId last_message_id,
diff --git a/td/telegram/MessagesManager.h b/td/telegram/MessagesManager.h
index b7d2e7e4..8dba6ec6 100644
--- a/td/telegram/MessagesManager.h
+++ b/td/telegram/MessagesManager.h
@@ -2384,6 +2384,8 @@ class MessagesManager : public Actor {
 
   DialogId being_added_dialog_id_;
 
+  DialogId debug_channel_difference_dialog_;
+
   double start_time_ = 0;
   bool is_inited_ = false;