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

Immediately reget paid media in newly viewed messages.

Browse Source
This commit is contained in:
levlam 2024-08-06 12:20:25 +03:00
parent 62642f83d5
commit 8a0e13f440
2 changed files with 15 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
td/telegram/MessagesManager.cpp
View File

@ -12008,21 +12008,28 @@ void MessagesManager::on_update_viewed_messages_timeout(DialogId dialog_id) {
return; return;
} }
auto &info = it->second; vector<MessageId> viewed_message_ids;
CHECK(info != nullptr); for (const auto &message_it : it->second->message_id_to_view_id) {
viewed_message_ids.push_back(message_it.first);
}
process_viewed_message(d, viewed_message_ids, false);
}
void MessagesManager::process_viewed_message(Dialog *d, const vector<MessageId> &viewed_message_ids, bool is_first) {
auto dialog_id = d->dialog_id;
vector<MessageId> reaction_message_ids; vector<MessageId> reaction_message_ids;
vector<MessageId> views_message_ids; vector<MessageId> views_message_ids;
vector<MessageId> extended_media_message_ids; vector<MessageId> extended_media_message_ids;
int32 newest_message_date = 0; int32 newest_message_date = 0;
for (auto &message_it : info->message_id_to_view_id) { for (auto message_id : viewed_message_ids) {
Message *m = get_message_force(d, message_it.first, "on_update_viewed_messages_timeout"); Message *m = get_message_force(d, message_id, "on_update_viewed_messages_timeout");
CHECK(m != nullptr); CHECK(m != nullptr);
CHECK(m->message_id.is_valid()); CHECK(m->message_id.is_valid());
CHECK(m->message_id.is_server()); CHECK(m->message_id.is_server());
if (need_poll_message_reactions(d, m)) { if (need_poll_message_reactions(d, m)) {
reaction_message_ids.push_back(m->message_id); reaction_message_ids.push_back(m->message_id);
} }
if (m->view_count > 0 && !m->has_get_message_views_query) { if (!is_first && m->view_count > 0 && !m->has_get_message_views_query) {
m->has_get_message_views_query = true; m->has_get_message_views_query = true;
views_message_ids.push_back(m->message_id); views_message_ids.push_back(m->message_id);
} }
@ -18894,7 +18901,6 @@ Status MessagesManager::view_messages(DialogId dialog_id, vector<MessageId> mess
vector<MessageId> read_content_message_ids; vector<MessageId> read_content_message_ids;
vector<MessageId> read_reaction_message_ids; vector<MessageId> read_reaction_message_ids;
vector<MessageId> new_viewed_message_ids; vector<MessageId> new_viewed_message_ids;
vector<MessageId> viewed_reaction_message_ids;
vector<MessageId> viewed_fact_check_message_ids; vector<MessageId> viewed_fact_check_message_ids;
vector<string> authentication_codes; vector<string> authentication_codes;
vector<MessageId> screenshotted_secret_message_ids; vector<MessageId> screenshotted_secret_message_ids;
@ -18953,9 +18959,6 @@ Status MessagesManager::view_messages(DialogId dialog_id, vector<MessageId> mess
auto &view_id = info->message_id_to_view_id[message_id]; auto &view_id = info->message_id_to_view_id[message_id];
if (view_id == 0) { if (view_id == 0) {
new_viewed_message_ids.push_back(message_id); new_viewed_message_ids.push_back(message_id);
if (need_poll_message_reactions(d, m)) {
viewed_reaction_message_ids.push_back(message_id);
}
} else { } else {
info->recently_viewed_messages.erase(view_id); info->recently_viewed_messages.erase(view_id);
} }
@ -19015,9 +19018,7 @@ Status MessagesManager::view_messages(DialogId dialog_id, vector<MessageId> mess
info->message_id_to_view_id.erase(it->second); info->message_id_to_view_id.erase(it->second);
info->recently_viewed_messages.erase(it); info->recently_viewed_messages.erase(it);
} }
if (!viewed_reaction_message_ids.empty()) { process_viewed_message(d, new_viewed_message_ids, true);
queue_message_reactions_reload(dialog_id, viewed_reaction_message_ids);
}
} }
if (!viewed_fact_check_message_ids.empty()) { if (!viewed_fact_check_message_ids.empty()) {
CHECK(dialog_id.get_type() != DialogType::SecretChat); CHECK(dialog_id.get_type() != DialogType::SecretChat);

2
td/telegram/MessagesManager.h
View File

@ -2870,6 +2870,8 @@ class MessagesManager final : public Actor {
MessageId offset_message_id, int32 limit, MessageSearchFilter filter, MessageId offset_message_id, int32 limit, MessageSearchFilter filter,
Promise<td_api::object_ptr<td_api::foundMessages>> &&promise); Promise<td_api::object_ptr<td_api::foundMessages>> &&promise);
void process_viewed_message(Dialog *d, const vector<MessageId> &viewed_message_ids, bool is_first);
void on_load_active_live_location_message_full_ids_from_database(string value); void on_load_active_live_location_message_full_ids_from_database(string value);
void on_load_active_live_location_messages_finished(); void on_load_active_live_location_messages_finished();