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

Repair scheduled messages when has_scheduled_server_messages changes.

Browse Source 
GitOrigin-RevId: 916d603b7b0715cf95ac07b900b820ff17fa1b6d
This commit is contained in:
levlam 2019-12-05 00:58:59 +03:00
parent 28f0cd5df5
commit 11f313c283
2 changed files with 23 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
td/telegram/MessagesManager.cpp
View File

@ -13395,11 +13395,13 @@ MessageId MessagesManager::get_dialog_pinned_message(DialogId dialog_id, Promise
get_dialog_info_full(dialog_id, Auto()); get_dialog_info_full(dialog_id, Auto());
tl_object_ptr<telegram_api::InputMessage> input_message; if (d->pinned_message_id.is_valid()) {
if (dialog_id.get_type() == DialogType::Channel) { tl_object_ptr<telegram_api::InputMessage> input_message;
input_message = make_tl_object<telegram_api::inputMessagePinned>(); if (dialog_id.get_type() == DialogType::Channel) {
input_message = make_tl_object<telegram_api::inputMessagePinned>();
}
get_message_force_from_server(d, d->pinned_message_id, std::move(promise), std::move(input_message));
} }
get_message_force_from_server(d, d->pinned_message_id, std::move(promise), std::move(input_message));
return d->pinned_message_id; return d->pinned_message_id;
} }
@ -16953,6 +16955,11 @@ void MessagesManager::load_messages(DialogId dialog_id, MessageId from_message_i
} }
vector<MessageId> MessagesManager::get_dialog_scheduled_messages(DialogId dialog_id, Promise<Unit> &&promise) { vector<MessageId> MessagesManager::get_dialog_scheduled_messages(DialogId dialog_id, Promise<Unit> &&promise) {
if (G()->close_flag()) {
promise.set_error(Status::Error(500, "Request aborted"));
return {};
}
const Dialog *d = get_dialog_force(dialog_id); const Dialog *d = get_dialog_force(dialog_id);
if (d == nullptr) { if (d == nullptr) {
promise.set_error(Status::Error(6, "Chat not found")); promise.set_error(Status::Error(6, "Chat not found"));
@ -23058,6 +23065,14 @@ void MessagesManager::set_dialog_pinned_message_id(Dialog *d, MessageId pinned_m
make_tl_object<td_api::updateChatPinnedMessage>(d->dialog_id.get(), pinned_message_id.get())); make_tl_object<td_api::updateChatPinnedMessage>(d->dialog_id.get(), pinned_message_id.get()));
} }
void MessagesManager::repair_dialog_scheduled_messages(DialogId dialog_id) {
get_dialog_scheduled_messages(dialog_id,
PromiseCreator::lambda([actor_id = actor_id(this), dialog_id](Unit) {
send_closure(G()->messages_manager(), &MessagesManager::get_dialog_scheduled_messages,
dialog_id, Promise<Unit>());
}));
}
void MessagesManager::on_update_dialog_has_scheduled_server_messages(DialogId dialog_id, void MessagesManager::on_update_dialog_has_scheduled_server_messages(DialogId dialog_id,
bool has_scheduled_server_messages) { bool has_scheduled_server_messages) {
if (!dialog_id.is_valid()) { if (!dialog_id.is_valid()) {
@ -23071,6 +23086,7 @@ void MessagesManager::on_update_dialog_has_scheduled_server_messages(DialogId di
return; return;
} }
LOG(INFO) << "Receive has_scheduled_server_messages = " << has_scheduled_server_messages << " in " << dialog_id;
if (d->has_scheduled_server_messages != has_scheduled_server_messages) { if (d->has_scheduled_server_messages != has_scheduled_server_messages) {
set_dialog_has_scheduled_server_messages(d, has_scheduled_server_messages); set_dialog_has_scheduled_server_messages(d, has_scheduled_server_messages);
} }
@ -23080,6 +23096,7 @@ void MessagesManager::set_dialog_has_scheduled_server_messages(Dialog *d, bool h
CHECK(d != nullptr); CHECK(d != nullptr);
CHECK(d->has_scheduled_server_messages != has_scheduled_server_messages); CHECK(d->has_scheduled_server_messages != has_scheduled_server_messages);
d->has_scheduled_server_messages = has_scheduled_server_messages; d->has_scheduled_server_messages = has_scheduled_server_messages;
repair_dialog_scheduled_messages(d->dialog_id);
on_dialog_updated(d->dialog_id, "set_dialog_has_scheduled_server_messages"); on_dialog_updated(d->dialog_id, "set_dialog_has_scheduled_server_messages");
LOG(INFO) << "Set " << d->dialog_id << " has_scheduled_server_messages to " << has_scheduled_server_messages; LOG(INFO) << "Set " << d->dialog_id << " has_scheduled_server_messages to " << has_scheduled_server_messages;

2
td/telegram/MessagesManager.h
View File

@ -1934,6 +1934,8 @@ class MessagesManager : public Actor {
void set_dialog_pinned_message_id(Dialog *d, MessageId pinned_message_id); void set_dialog_pinned_message_id(Dialog *d, MessageId pinned_message_id);
void repair_dialog_scheduled_messages(DialogId dialog_id);
void set_dialog_has_scheduled_server_messages(Dialog *d, bool has_scheduled_server_messages); void set_dialog_has_scheduled_server_messages(Dialog *d, bool has_scheduled_server_messages);
void set_dialog_has_scheduled_database_messages(DialogId dialog_id, bool has_scheduled_database_messages); void set_dialog_has_scheduled_database_messages(DialogId dialog_id, bool has_scheduled_database_messages);