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

Add source to send_update_saved_messages_topic.

Browse Source
This commit is contained in:
levlam 2024-02-07 16:24:05 +03:00
parent 6cfb50fd8f
commit e7d6a982fa
2 changed files with 18 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
td/telegram/SavedMessagesManager.cpp
View File

@ -362,7 +362,7 @@ SavedMessagesManager::SavedMessagesTopic *SavedMessagesManager::add_topic(
result->draft_message_date_ = draft_message_object->date_; result->draft_message_date_ = draft_message_object->date_;
} }
} }
send_update_saved_messages_topic(result.get()); send_update_saved_messages_topic(result.get(), "add_topic");
} }
return result.get(); return result.get();
} }
@ -371,7 +371,7 @@ void SavedMessagesManager::set_topic_last_message_id(SavedMessagesTopicId saved_
MessageId last_message_id, int32 last_message_date) { MessageId last_message_id, int32 last_message_date) {
auto *topic = add_topic(saved_messages_topic_id); auto *topic = add_topic(saved_messages_topic_id);
do_set_topic_last_message_id(topic, last_message_id, last_message_date); do_set_topic_last_message_id(topic, last_message_id, last_message_date);
on_topic_changed(topic); on_topic_changed(topic, "set_topic_last_message_id");
} }
void SavedMessagesManager::do_set_topic_last_message_id(SavedMessagesTopic *topic, MessageId last_message_id, void SavedMessagesManager::do_set_topic_last_message_id(SavedMessagesTopic *topic, MessageId last_message_id,
@ -394,7 +394,7 @@ void SavedMessagesManager::on_topic_message_updated(SavedMessagesTopicId saved_m
return; return;
} }
send_update_saved_messages_topic(topic); send_update_saved_messages_topic(topic, "on_topic_message_updated");
} }
void SavedMessagesManager::on_topic_message_deleted(SavedMessagesTopicId saved_messages_topic_id, void SavedMessagesManager::on_topic_message_deleted(SavedMessagesTopicId saved_messages_topic_id,
@ -406,7 +406,7 @@ void SavedMessagesManager::on_topic_message_deleted(SavedMessagesTopicId saved_m
do_set_topic_last_message_id(topic, MessageId(), 0); do_set_topic_last_message_id(topic, MessageId(), 0);
on_topic_changed(topic); on_topic_changed(topic, "on_topic_message_deleted");
get_saved_messages_topic_history(saved_messages_topic_id, MessageId(), 0, 1, Auto()); get_saved_messages_topic_history(saved_messages_topic_id, MessageId(), 0, 1, Auto());
} }
@ -418,10 +418,11 @@ void SavedMessagesManager::on_topic_draft_message_updated(SavedMessagesTopicId s
return; return;
} }
LOG(INFO) << "Set draft message date in topic " << topic->saved_messages_topic_id_ << " to " << draft_message_date;
topic->draft_message_date_ = draft_message_date; topic->draft_message_date_ = draft_message_date;
topic->is_changed_ = true; topic->is_changed_ = true;
on_topic_changed(topic); on_topic_changed(topic, "on_topic_draft_message_updated");
} }
int64 SavedMessagesManager::get_topic_order(int32 message_date, MessageId message_id) { int64 SavedMessagesManager::get_topic_order(int32 message_date, MessageId message_id) {
@ -436,7 +437,7 @@ int64 SavedMessagesManager::get_topic_public_order(const SavedMessagesTopic *top
return 0; return 0;
} }
void SavedMessagesManager::on_topic_changed(SavedMessagesTopic *topic) { void SavedMessagesManager::on_topic_changed(SavedMessagesTopic *topic, const char *source) {
CHECK(topic != nullptr); CHECK(topic != nullptr);
if (!topic->is_changed_) { if (!topic->is_changed_) {
return; return;
@ -464,9 +465,10 @@ void SavedMessagesManager::on_topic_changed(SavedMessagesTopic *topic) {
topic_list_.ordered_topics_.insert({topic->private_order_, topic->saved_messages_topic_id_}).second; topic_list_.ordered_topics_.insert({topic->private_order_, topic->saved_messages_topic_id_}).second;
CHECK(is_inserted); CHECK(is_inserted);
} }
LOG(INFO) << "Update order of " << topic->saved_messages_topic_id_ << " to " << topic->private_order_; LOG(INFO) << "Update order of " << topic->saved_messages_topic_id_ << " to " << topic->private_order_ << " from "
<< source;
send_update_saved_messages_topic(topic); send_update_saved_messages_topic(topic, source);
} }
void SavedMessagesManager::load_saved_messages_topics(int32 limit, Promise<Unit> &&promise) { void SavedMessagesManager::load_saved_messages_topics(int32 limit, Promise<Unit> &&promise) {
@ -640,7 +642,7 @@ void SavedMessagesManager::on_get_saved_messages_topics(
if (topic->last_message_id_ == MessageId()) { if (topic->last_message_id_ == MessageId()) {
do_set_topic_last_message_id(topic, last_topic_message_id, message_date); do_set_topic_last_message_id(topic, last_topic_message_id, message_date);
} }
on_topic_changed(topic); on_topic_changed(topic, "on_get_saved_messages_topics");
} }
if (is_pinned) { if (is_pinned) {
@ -695,11 +697,11 @@ td_api::object_ptr<td_api::updateSavedMessagesTopic> SavedMessagesManager::get_u
return td_api::make_object<td_api::updateSavedMessagesTopic>(get_saved_messages_topic_object(topic)); return td_api::make_object<td_api::updateSavedMessagesTopic>(get_saved_messages_topic_object(topic));
} }
void SavedMessagesManager::send_update_saved_messages_topic(const SavedMessagesTopic *topic) const { void SavedMessagesManager::send_update_saved_messages_topic(const SavedMessagesTopic *topic, const char *source) const {
CHECK(topic != nullptr); CHECK(topic != nullptr);
LOG(INFO) << "Send update about " << topic->saved_messages_topic_id_ << " with order " LOG(INFO) << "Send update about " << topic->saved_messages_topic_id_ << " with order "
<< get_topic_public_order(topic) << " and last " << topic->last_message_id_ << " sent at " << get_topic_public_order(topic) << " and last " << topic->last_message_id_ << " sent at "
<< topic->last_message_date_ << " with draft at " << topic->draft_message_date_; << topic->last_message_date_ << " with draft at " << topic->draft_message_date_ << " from " << source;
send_closure(G()->td(), &Td::send_update, get_update_saved_messages_topic_object(topic)); send_closure(G()->td(), &Td::send_update, get_update_saved_messages_topic_object(topic));
} }
@ -775,7 +777,7 @@ bool SavedMessagesManager::set_saved_messages_topic_is_pinned(SavedMessagesTopic
LOG(INFO) << "Set " << saved_messages_topic_id << " pinned order to " << topic->pinned_order_; LOG(INFO) << "Set " << saved_messages_topic_id << " pinned order to " << topic->pinned_order_;
topic->is_changed_ = true; topic->is_changed_ = true;
on_topic_changed(topic); on_topic_changed(topic, "set_saved_messages_topic_is_pinned");
return true; return true;
} }
@ -789,7 +791,7 @@ void SavedMessagesManager::set_last_topic_date(TopicDate topic_date) {
it != topic_list_.ordered_topics_.end() && *it <= topic_date; ++it) { it != topic_list_.ordered_topics_.end() && *it <= topic_date; ++it) {
auto topic = get_topic(it->get_topic_id()); auto topic = get_topic(it->get_topic_id());
CHECK(topic != nullptr); CHECK(topic != nullptr);
send_update_saved_messages_topic(topic); send_update_saved_messages_topic(topic, "set_last_topic_date");
} }
} }
@ -873,7 +875,7 @@ void SavedMessagesManager::on_get_saved_messages_topic_history(
do_set_topic_last_message_id(topic, last_message_id, last_message_date); do_set_topic_last_message_id(topic, last_message_id, last_message_date);
} }
} }
on_topic_changed(topic); on_topic_changed(topic, "on_get_saved_messages_topic_history");
} }
promise.set_value(td_api::make_object<td_api::messages>(info.total_count, std::move(messages))); promise.set_value(td_api::make_object<td_api::messages>(info.total_count, std::move(messages)));
} }

4
td/telegram/SavedMessagesManager.h
View File

@ -165,14 +165,14 @@ class SavedMessagesManager final : public Actor {
void set_last_topic_date(TopicDate topic_date); void set_last_topic_date(TopicDate topic_date);
void on_topic_changed(SavedMessagesTopic *topic); void on_topic_changed(SavedMessagesTopic *topic, const char *source);
td_api::object_ptr<td_api::savedMessagesTopic> get_saved_messages_topic_object(const SavedMessagesTopic *topic) const; td_api::object_ptr<td_api::savedMessagesTopic> get_saved_messages_topic_object(const SavedMessagesTopic *topic) const;
td_api::object_ptr<td_api::updateSavedMessagesTopic> get_update_saved_messages_topic_object( td_api::object_ptr<td_api::updateSavedMessagesTopic> get_update_saved_messages_topic_object(
const SavedMessagesTopic *topic) const; const SavedMessagesTopic *topic) const;
void send_update_saved_messages_topic(const SavedMessagesTopic *topic) const; void send_update_saved_messages_topic(const SavedMessagesTopic *topic, const char *source) const;
Td *td_; Td *td_;
ActorShared<> parent_; ActorShared<> parent_;