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

Read unread reactions.

Browse Source
This commit is contained in:
levlam 2022-01-28 20:27:39 +03:00
parent 1cf2a9e9c9
commit 41a5248169
2 changed files with 35 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
td/telegram/MessagesManager.cpp
View File

@ -7114,7 +7114,7 @@ bool MessagesManager::update_message_interaction_info(DialogId dialog_id, Messag
if (d->unread_reaction_count + unread_reaction_diff < 0) { if (d->unread_reaction_count + unread_reaction_diff < 0) {
if (is_dialog_inited(d)) { if (is_dialog_inited(d)) {
LOG(ERROR) << "Unread reaction count of " << d->dialog_id << " became negative from " << source; LOG(ERROR) << "Unread reaction count of " << dialog_id << " became negative from " << source;
} }
} else { } else {
set_dialog_unread_reaction_count(d, d->unread_reaction_count + unread_reaction_diff); set_dialog_unread_reaction_count(d, d->unread_reaction_count + unread_reaction_diff);
@ -7223,6 +7223,31 @@ bool MessagesManager::update_message_contains_unread_mention(Dialog *d, Message
return false; return false;
} }
bool MessagesManager::remove_message_unread_reactions(Dialog *d, Message *m, const char *source) {
CHECK(m != nullptr);
CHECK(!m->message_id.is_scheduled());
if (!has_unread_message_reactions(d->dialog_id, m)) {
return false;
}
// remove_message_notification_id(d, m, true, true);
m->reactions->unread_reactions_.clear();
if (d->unread_reaction_count == 0) {
if (is_dialog_inited(d)) {
LOG(ERROR) << "Unread reaction count of " << d->dialog_id << " became negative from " << source;
}
} else {
set_dialog_unread_reaction_count(d, d->unread_reaction_count - 1);
on_dialog_updated(d->dialog_id, "remove_message_unread_reactions");
}
LOG(INFO) << "Update unread reaction count in " << d->dialog_id << " to " << d->unread_reaction_count
<< " by reading " << m->message_id << " from " << source;
send_update_message_unread_reactions(d->dialog_id, m, d->unread_reaction_count);
return true;
}
void MessagesManager::on_read_channel_inbox(ChannelId channel_id, MessageId max_message_id, int32 server_unread_count, void MessagesManager::on_read_channel_inbox(ChannelId channel_id, MessageId max_message_id, int32 server_unread_count,
int32 pts, const char *source) { int32 pts, const char *source) {
if (td_->auth_manager_->is_bot()) { if (td_->auth_manager_->is_bot()) {
@ -12845,6 +12870,7 @@ void MessagesManager::on_message_ttl_expired_impl(Dialog *d, Message *m) {
} }
remove_message_notification_id(d, m, true, true); remove_message_notification_id(d, m, true, true);
update_message_contains_unread_mention(d, m, false, "on_message_ttl_expired_impl"); update_message_contains_unread_mention(d, m, false, "on_message_ttl_expired_impl");
remove_message_unread_reactions(d, m, "on_message_ttl_expired_impl");
unregister_message_reply(d, m); unregister_message_reply(d, m);
m->noforwards = false; m->noforwards = false;
m->contains_mention = false; m->contains_mention = false;
@ -20342,6 +20368,12 @@ Status MessagesManager::view_messages(DialogId dialog_id, MessageId top_thread_m
read_content_message_ids.push_back(m->message_id); read_content_message_ids.push_back(m->message_id);
on_message_changed(d, m, true, "view_messages"); on_message_changed(d, m, true, "view_messages");
} }
if (need_read && remove_message_unread_reactions(d, m, "view_messages")) {
CHECK(m->message_id.is_server());
read_content_message_ids.push_back(m->message_id);
on_message_changed(d, m, true, "view_messages");
}
} else if (!message_id.is_yet_unsent() && message_id > max_message_id && } else if (!message_id.is_yet_unsent() && message_id > max_message_id &&
message_id <= d->max_notification_message_id) { message_id <= d->max_notification_message_id) {
max_message_id = message_id; max_message_id = message_id;

2
td/telegram/MessagesManager.h
View File

@ -2123,6 +2123,8 @@ class MessagesManager final : public Actor {
bool update_message_contains_unread_mention(Dialog *d, Message *m, bool contains_unread_mention, const char *source); bool update_message_contains_unread_mention(Dialog *d, Message *m, bool contains_unread_mention, const char *source);
bool remove_message_unread_reactions(Dialog *d, Message *m, const char *source);
void read_message_content_from_updates(MessageId message_id); void read_message_content_from_updates(MessageId message_id);
void read_channel_message_content_from_updates(Dialog *d, MessageId message_id); void read_channel_message_content_from_updates(Dialog *d, MessageId message_id);