From 1e3aa30ed5a6f4c9a13fe72f1099a0699ce21164 Mon Sep 17 00:00:00 2001
From: levlam <levlam@telegram.org>
Date: Fri, 30 Jun 2023 16:20:09 +0300
Subject: [PATCH] Add source to StoryManager::load_dialog_expiring_stories.

---
 td/telegram/StoryManager.cpp | 10 ++++++----
 td/telegram/StoryManager.h   |  2 +-
 2 files changed, 7 insertions(+), 5 deletions(-)

diff --git a/td/telegram/StoryManager.cpp b/td/telegram/StoryManager.cpp
index 76b63f012..b00243d08 100644
--- a/td/telegram/StoryManager.cpp
+++ b/td/telegram/StoryManager.cpp
@@ -1129,13 +1129,14 @@ uint64 StoryManager::save_load_dialog_expiring_stories_log_event(DialogId owner_
                     get_log_event_storer(log_event));
 }
 
-void StoryManager::load_dialog_expiring_stories(DialogId owner_dialog_id, uint64 log_event_id) {
+void StoryManager::load_dialog_expiring_stories(DialogId owner_dialog_id, uint64 log_event_id, const char *source) {
   if (load_expiring_stories_log_event_ids_.count(owner_dialog_id)) {
     if (log_event_id != 0) {
       binlog_erase(G()->td_db()->get_binlog(), log_event_id);
     }
     return;
   }
+  LOG(INFO) << "Load active stories in " << owner_dialog_id << " from " << source;
   if (log_event_id == 0 && G()->use_message_database()) {
     log_event_id = save_load_dialog_expiring_stories_log_event(owner_dialog_id);
   }
@@ -1156,7 +1157,7 @@ void StoryManager::on_load_dialog_expiring_stories(DialogId owner_dialog_id) {
     return;
   }
   auto it = load_expiring_stories_log_event_ids_.find(owner_dialog_id);
-  if (it != load_expiring_stories_log_event_ids_.end()) {
+  if (it == load_expiring_stories_log_event_ids_.end()) {
     return;
   }
   auto log_event_id = it->second;
@@ -1164,6 +1165,7 @@ void StoryManager::on_load_dialog_expiring_stories(DialogId owner_dialog_id) {
   if (log_event_id != 0) {
     binlog_erase(G()->td_db()->get_binlog(), log_event_id);
   }
+  LOG(INFO) << "Finished loading of active stories in " << owner_dialog_id;
 }
 
 void StoryManager::on_get_dialog_expiring_stories(DialogId owner_dialog_id,
@@ -1841,7 +1843,7 @@ StoryId StoryManager::on_get_new_story(DialogId owner_dialog_id,
     auto active_stories = get_active_stories(owner_dialog_id);
     if (active_stories == nullptr) {
       if (is_subscribed_to_dialog_stories(owner_dialog_id)) {
-        load_dialog_expiring_stories(owner_dialog_id, 0);
+        load_dialog_expiring_stories(owner_dialog_id, 0, "on_get_new_story");
       }
     } else if (!contains(active_stories->story_ids_, story_id)) {
       auto story_ids = active_stories->story_ids_;
@@ -2800,7 +2802,7 @@ void StoryManager::on_binlog_events(vector<BinlogEvent> &&events) {
           binlog_erase(G()->td_db()->get_binlog(), event.id_);
           break;
         }
-        load_dialog_expiring_stories(dialog_id, event.id_);
+        load_dialog_expiring_stories(dialog_id, event.id_, "LoadDialogExpiringStoriesLogEvent");
         break;
       }
       default:
diff --git a/td/telegram/StoryManager.h b/td/telegram/StoryManager.h
index 0160e59df..7353c0bc4 100644
--- a/td/telegram/StoryManager.h
+++ b/td/telegram/StoryManager.h
@@ -290,7 +290,7 @@ class StoryManager final : public Actor {
 
   static uint64 save_load_dialog_expiring_stories_log_event(DialogId owner_dialog_id);
 
-  void load_dialog_expiring_stories(DialogId owner_dialog_id, uint64 log_event_id);
+  void load_dialog_expiring_stories(DialogId owner_dialog_id, uint64 log_event_id, const char *source);
 
   void on_load_dialog_expiring_stories(DialogId owner_dialog_id);