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

Save changed dialog total count even if the sum is still the same.

Browse Source 
GitOrigin-RevId: 7a3027bc5defba37c089368c71cfdc7e009a440e
This commit is contained in:
levlam 2020-05-29 09:08:01 +03:00
parent 3033f31525
commit 42b2e84e4a
2 changed files with 33 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
td/telegram/MessagesManager.cpp
View File

@ -10294,8 +10294,12 @@ void MessagesManager::on_get_secret_chat_total_count(DialogListId dialog_list_id
if (list->secret_chat_total_count_ != total_count) {
auto old_dialog_total_count = get_dialog_total_count(*list);
list->secret_chat_total_count_ = total_count;
if (list->is_dialog_unread_count_inited_ && old_dialog_total_count != get_dialog_total_count(*list)) {
send_update_unread_chat_count(*list, DialogId(), true, "on_get_secret_chat_total_count");
if (list->is_dialog_unread_count_inited_) {
if (old_dialog_total_count != get_dialog_total_count(*list)) {
send_update_unread_chat_count(*list, DialogId(), true, "on_get_secret_chat_total_count");
} else {
save_unread_chat_count(*list);
}
}
}
}
@ -10375,11 +10379,13 @@ void MessagesManager::recalc_unread_count(DialogListId dialog_list_id, int32 old
if (old_dialog_total_count == -1) {
old_dialog_total_count = get_dialog_total_count(list);
}
bool need_save = false;
if (list.list_last_dialog_date_ == MAX_DIALOG_DATE) {
if (server_dialog_total_count != list.server_dialog_total_count_ ||
secret_chat_total_count != list.secret_chat_total_count_) {
list.server_dialog_total_count_ = server_dialog_total_count;
list.secret_chat_total_count_ = secret_chat_total_count;
need_save = true;
}
} else {
repair_server_dialog_total_count(dialog_list_id);
@ -10397,6 +10403,8 @@ void MessagesManager::recalc_unread_count(DialogListId dialog_list_id, int32 old
list.unread_dialog_marked_count_ = dialog_marked_count;
list.unread_dialog_muted_marked_count_ = dialog_muted_marked_count;
send_update_unread_chat_count(list, DialogId(), true, "recalc_unread_count");
} else if (need_save) {
save_unread_chat_count(list);
}
}
@ -13095,8 +13103,12 @@ void MessagesManager::on_get_dialogs(FolderId folder_id, vector<tl_object_ptr<te
if (list.server_dialog_total_count_ != total_count) {
auto old_dialog_total_count = get_dialog_total_count(list);
list.server_dialog_total_count_ = total_count;
if (list.is_dialog_unread_count_inited_ && old_dialog_total_count != get_dialog_total_count(list)) {
send_update_unread_chat_count(list, DialogId(), true, "on_get_dialogs");
if (list.is_dialog_unread_count_inited_) {
if (old_dialog_total_count != get_dialog_total_count(list)) {
send_update_unread_chat_count(list, DialogId(), true, "on_get_dialogs");
} else {
save_unread_chat_count(list);
}
}
}
}
@ -15994,6 +16006,9 @@ void MessagesManager::edit_dialog_filter(unique_ptr<DialogFilter> new_dialog_fil
old_list.unread_dialog_muted_marked_count_ != new_list.unread_dialog_muted_marked_count_ ||
get_dialog_total_count(old_list) != get_dialog_total_count(new_list) ||
!old_list.is_dialog_unread_count_inited_);
bool need_save_unread_chat_count = new_list.is_dialog_unread_count_inited_ &&
(old_list.server_dialog_total_count_ != new_list.server_dialog_total_count_ ||
old_list.secret_chat_total_count_ != new_list.secret_chat_total_count_);
auto load_list_promises = std::move(old_list.load_list_queries_);
@ -16005,6 +16020,8 @@ void MessagesManager::edit_dialog_filter(unique_ptr<DialogFilter> new_dialog_fil
}
if (need_update_unread_chat_count) {
send_update_unread_chat_count(old_list, DialogId(), true, source);
} else if (need_save_unread_chat_count) {
save_unread_chat_count(old_list);
}
for (auto it : updated_position_dialogs) {
@ -24899,11 +24916,7 @@ void MessagesManager::send_update_unread_chat_count(DialogList &list, DialogId d
}
if (!from_database) {
G()->td_db()->get_binlog_pmc()->set(
PSTRING() << "unread_dialog_count" << dialog_list_id.get(),
PSTRING() << list.unread_dialog_total_count_ << ' ' << list.unread_dialog_muted_count_ << ' '
<< list.unread_dialog_marked_count_ << ' ' << list.unread_dialog_muted_marked_count_ << ' '
<< list.server_dialog_total_count_ << ' ' << list.secret_chat_total_count_);
save_unread_chat_count(list);
}
bool need_postpone = !force && running_get_difference_;
@ -24922,6 +24935,15 @@ void MessagesManager::send_update_unread_chat_count(DialogList &list, DialogId d
}
}
void MessagesManager::save_unread_chat_count(const DialogList &list) {
LOG(INFO) << "Save unread chat count in " << list.dialog_list_id;
G()->td_db()->get_binlog_pmc()->set(
PSTRING() << "unread_dialog_count" << list.dialog_list_id.get(),
PSTRING() << list.unread_dialog_total_count_ << ' ' << list.unread_dialog_muted_count_ << ' '
<< list.unread_dialog_marked_count_ << ' ' << list.unread_dialog_muted_marked_count_ << ' '
<< list.server_dialog_total_count_ << ' ' << list.secret_chat_total_count_);
}
void MessagesManager::send_update_chat_read_inbox(const Dialog *d, bool force, const char *source) {
if (td_->auth_manager_->is_bot()) {
return;

2
td/telegram/MessagesManager.h
View File

@ -2096,6 +2096,8 @@ class MessagesManager : public Actor {
td_api::object_ptr<td_api::updateUnreadChatCount> get_update_unread_chat_count_object(const DialogList &list) const;
void save_unread_chat_count(const DialogList &list);
void set_dialog_last_read_inbox_message_id(Dialog *d, MessageId message_id, int32 server_unread_count,
int32 local_unread_count, bool force_update, const char *source);