andreacavalli/tdlib-fork
Archived
1
0
Fork 0
Code Pull Requests Releases Activity

Add separate update_sent_message_contents function.

Browse Source 
GitOrigin-RevId: 621fd837d722355a6e5a392b3de390f6bc0839ba
This commit is contained in:
levlam 2019-11-30 20:04:49 +03:00
parent 10c743a839
commit 7ea11b2150
2 changed files with 22 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
td/telegram/MessagesManager.cpp
View File

@ -25070,10 +25070,8 @@ MessagesManager::Message *MessagesManager::add_message_to_dialog(Dialog *d, uniq
} }
} }
UserId my_user_id(td_->contacts_manager_->get_my_id());
DialogId my_dialog_id(my_user_id);
if (*need_update && message_id > d->last_read_inbox_message_id && !td_->auth_manager_->is_bot()) { if (*need_update && message_id > d->last_read_inbox_message_id && !td_->auth_manager_->is_bot()) {
if (!message->is_outgoing && dialog_id != my_dialog_id) { if (!message->is_outgoing && dialog_id != get_my_dialog_id()) {
int32 server_unread_count = d->server_unread_count; int32 server_unread_count = d->server_unread_count;
int32 local_unread_count = d->local_unread_count; int32 local_unread_count = d->local_unread_count;
if (message_id.is_server()) { if (message_id.is_server()) {
@ -25186,17 +25184,15 @@ MessagesManager::Message *MessagesManager::add_message_to_dialog(Dialog *d, uniq
add_message_file_sources(dialog_id, m); add_message_file_sources(dialog_id, m);
register_message_content(td_, m->content.get(), {dialog_id, message_id}); register_message_content(td_, m->content.get(), {dialog_id, message_id});
if (from_update && message_id.is_server() && message_content_type == MessageContentType::PinMessage) { if (*need_update && message_id.is_server() && message_content_type == MessageContentType::PinMessage) {
// always update pinned message from service message, even new pinned_message_id is invalid
auto pinned_message_id = get_message_content_pinned_message_id(m->content.get()); auto pinned_message_id = get_message_content_pinned_message_id(m->content.get());
on_update_dialog_pinned_message_id(dialog_id, pinned_message_id); on_update_dialog_pinned_message_id(dialog_id, pinned_message_id);
} }
if (!td_->auth_manager_->is_bot() && from_update && (m->is_outgoing || dialog_id == my_dialog_id) &&
dialog_id.get_type() != DialogType::SecretChat && !message_id.is_local() && m->forward_info == nullptr &&
!m->had_forward_info) {
on_sent_message_content(td_, m->content.get());
}
if (from_update) { if (from_update) {
speculatively_update_channel_participants(dialog_id, m); speculatively_update_channel_participants(dialog_id, m);
update_sent_message_contents(dialog_id, m);
update_used_hashtags(dialog_id, m); update_used_hashtags(dialog_id, m);
update_top_dialogs(dialog_id, m); update_top_dialogs(dialog_id, m);
} }
@ -25339,17 +25335,14 @@ MessagesManager::Message *MessagesManager::add_scheduled_message_to_dialog(Dialo
add_message_file_sources(dialog_id, m); add_message_file_sources(dialog_id, m);
DialogId my_dialog_id = get_my_dialog_id();
if (from_update && m->forward_info == nullptr && !m->had_forward_info &&
(m->is_outgoing || dialog_id == my_dialog_id) && !message_id.is_local()) {
on_sent_message_content(td_, m->content.get());
}
if (from_update) { if (from_update) {
update_sent_message_contents(dialog_id, m);
update_used_hashtags(dialog_id, m); update_used_hashtags(dialog_id, m);
} }
Message *result_message = treap_insert_message(&d->scheduled_messages, std::move(message)); Message *result_message = treap_insert_message(&d->scheduled_messages, std::move(message));
CHECK(result_message != nullptr); CHECK(result_message != nullptr);
CHECK(d->scheduled_messages != nullptr);
return result_message; return result_message;
} }
@ -27761,6 +27754,7 @@ void MessagesManager::after_get_channel_difference(DialogId dialog_id, bool succ
} }
void MessagesManager::speculatively_update_channel_participants(DialogId dialog_id, const Message *m) { void MessagesManager::speculatively_update_channel_participants(DialogId dialog_id, const Message *m) {
CHECK(m != nullptr);
if (!m->message_id.is_any_server() || dialog_id.get_type() != DialogType::Channel || !m->sender_user_id.is_valid()) { if (!m->message_id.is_any_server() || dialog_id.get_type() != DialogType::Channel || !m->sender_user_id.is_valid()) {
return; return;
} }
@ -27786,6 +27780,17 @@ void MessagesManager::speculatively_update_channel_participants(DialogId dialog_
} }
} }
void MessagesManager::update_sent_message_contents(DialogId dialog_id, const Message *m) {
CHECK(m != nullptr);
if (td_->auth_manager_->is_bot() || (!m->is_outgoing && dialog_id != get_my_dialog_id()) ||
dialog_id.get_type() == DialogType::SecretChat || !m->message_id.is_local() || m->forward_info != nullptr ||
m->had_forward_info) {
return;
}
on_sent_message_content(td_, m->content.get());
}
void MessagesManager::update_used_hashtags(DialogId dialog_id, const Message *m) { void MessagesManager::update_used_hashtags(DialogId dialog_id, const Message *m) {
CHECK(m != nullptr); CHECK(m != nullptr);
if (td_->auth_manager_->is_bot() || (!m->is_outgoing && dialog_id != get_my_dialog_id()) || if (td_->auth_manager_->is_bot() || (!m->is_outgoing && dialog_id != get_my_dialog_id()) ||
@ -27822,6 +27827,7 @@ void MessagesManager::update_used_hashtags(DialogId dialog_id, const Message *m)
} }
void MessagesManager::update_top_dialogs(DialogId dialog_id, const Message *m) { void MessagesManager::update_top_dialogs(DialogId dialog_id, const Message *m) {
CHECK(m != nullptr);
auto dialog_type = dialog_id.get_type(); auto dialog_type = dialog_id.get_type();
if (td_->auth_manager_->is_bot() || (!m->is_outgoing && dialog_id != get_my_dialog_id()) || if (td_->auth_manager_->is_bot() || (!m->is_outgoing && dialog_id != get_my_dialog_id()) ||
dialog_type == DialogType::SecretChat || !m->message_id.is_any_server()) { dialog_type == DialogType::SecretChat || !m->message_id.is_any_server()) {

2
td/telegram/MessagesManager.h
View File

@ -2270,6 +2270,8 @@ class MessagesManager : public Actor {
void speculatively_update_channel_participants(DialogId dialog_id, const Message *m); void speculatively_update_channel_participants(DialogId dialog_id, const Message *m);
void update_sent_message_contents(DialogId dialog_id, const Message *m);
void update_used_hashtags(DialogId dialog_id, const Message *m); void update_used_hashtags(DialogId dialog_id, const Message *m);
void update_top_dialogs(DialogId dialog_id, const Message *m); void update_top_dialogs(DialogId dialog_id, const Message *m);