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

Rename have_message to have_message_force.

Browse Source 
GitOrigin-RevId: 7ad820c8d73a5bcae4b30ccf2b1e3ba722047878
This commit is contained in:
levlam 2019-12-06 05:02:02 +03:00
parent 2baa52f975
commit d6ce1dfbc4
3 changed files with 10 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
td/telegram/CallbackQueriesManager.cpp
View File

@ -237,7 +237,7 @@ int64 CallbackQueriesManager::send_callback_query(FullMessageId full_message_id,
return 0;
}
if (!td_->messages_manager_->have_message(full_message_id, "send_callback_query")) {
if (!td_->messages_manager_->have_message_force(full_message_id, "send_callback_query")) {
promise.set_error(Status::Error(5, "Message not found"));
return 0;
}

13
td/telegram/MessagesManager.cpp
View File

@ -7555,7 +7555,7 @@ void MessagesManager::after_get_difference() {
// fallthrough
case DialogType::User:
case DialogType::Chat: {
if (!have_message({dialog_id, it.second}, "after get difference")) {
if (!have_message_force({dialog_id, it.second}, "after get difference")) {
// The sent message has already been deleted by the user or sent to inaccessible channel.
// The sent message may never be received, but we will need updateMessageId in case the message is received
// to delete it from the server and to not add to the chat.
@ -13264,7 +13264,7 @@ void MessagesManager::on_get_common_dialogs(UserId user_id, int32 offset_chat_id
}
}
bool MessagesManager::have_message(FullMessageId full_message_id, const char *source) {
bool MessagesManager::have_message_force(FullMessageId full_message_id, const char *source) {
return get_message_force(full_message_id, source) != nullptr;
}
@ -21913,7 +21913,7 @@ bool MessagesManager::add_new_message_notification(Dialog *d, Message *m, bool f
if (is_pinned) {
auto message_id = get_message_content_pinned_message_id(m->content.get());
if (message_id.is_valid() &&
!have_message({d->dialog_id, message_id},
!have_message_force({d->dialog_id, message_id},
force ? "add_new_message_notification force" : "add_new_message_notification not force")) {
missing_pinned_message_id = message_id;
}
@ -24475,7 +24475,7 @@ void MessagesManager::pin_dialog_message(DialogId dialog_id, MessageId message_i
if (is_unpin) {
CHECK(message_id == MessageId());
} else {
if (!have_message({dialog_id, message_id}, "pin_dialog_message")) {
if (!have_message_force({dialog_id, message_id}, "pin_dialog_message")) {
return promise.set_error(Status::Error(6, "Message not found"));
}
@ -25647,14 +25647,15 @@ MessagesManager::Message *MessagesManager::add_message_to_dialog(Dialog *d, uniq
if (*need_update) {
auto pinned_message_id = get_message_content_pinned_message_id(message->content.get());
added_pinned_message_id = pinned_message_id;
if (pinned_message_id.is_valid() && have_message({dialog_id, pinned_message_id}, "preload pinned message")) {
if (pinned_message_id.is_valid() && have_message_force({dialog_id, pinned_message_id}, "preload pinned message")) {
preloaded_pinned_message_id = pinned_message_id;
LOG(INFO) << "Preloaded pinned " << pinned_message_id << " from database";
}
add_error_reason = debug_add_message_to_dialog_fail_reason_;
if (d->pinned_message_notification_message_id.is_valid() &&
have_message({dialog_id, d->pinned_message_notification_message_id}, "preload previously pinned message")) {
have_message_force({dialog_id, d->pinned_message_notification_message_id},
"preload previously pinned message")) {
LOG(INFO) << "Preloaded previously pinned " << d->pinned_message_notification_message_id << " from database";
}
}

2
td/telegram/MessagesManager.h
View File

@ -503,7 +503,7 @@ class MessagesManager : public Actor {
vector<DialogId> get_common_dialogs(UserId user_id, DialogId offset_dialog_id, int32 limit, bool force,
Promise<Unit> &&promise);
bool have_message(FullMessageId full_message_id, const char *source);
bool have_message_force(FullMessageId full_message_id, const char *source);
void get_message(FullMessageId full_message_id, Promise<Unit> &&promise);