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

Fix send_get_dialog_query.

Browse Source 
GitOrigin-RevId: f1bee7dddc9a95daccc36cc5bb1e51f2627907de
This commit is contained in:
levlam 2018-06-17 18:20:37 +03:00
parent aeaa195233
commit 3827fb91eb
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
td/telegram/MessagesManager.cpp
View File

@ -20011,15 +20011,25 @@ class MessagesManager::GetDialogFromServerLogEvent {
void MessagesManager::send_get_dialog_query(DialogId dialog_id, Promise<Unit> &&promise, uint64 logevent_id) { void MessagesManager::send_get_dialog_query(DialogId dialog_id, Promise<Unit> &&promise, uint64 logevent_id) {
if (td_->auth_manager_->is_bot() || dialog_id.get_type() == DialogType::SecretChat) { if (td_->auth_manager_->is_bot() || dialog_id.get_type() == DialogType::SecretChat) {
if (logevent_id != 0) {
BinlogHelper::erase(G()->td_db()->get_binlog(), logevent_id);
}
return promise.set_error(Status::Error(500, "Wrong getDialog query")); return promise.set_error(Status::Error(500, "Wrong getDialog query"));
} }
if (!have_input_peer(dialog_id, AccessRights::Read)) { if (!have_input_peer(dialog_id, AccessRights::Read)) {
if (logevent_id != 0) {
BinlogHelper::erase(G()->td_db()->get_binlog(), logevent_id);
}
return promise.set_error(Status::Error(400, "Can't access the chat")); return promise.set_error(Status::Error(400, "Can't access the chat"));
} }
auto &promises = get_dialog_queries_[dialog_id]; auto &promises = get_dialog_queries_[dialog_id];
promises.push_back(std::move(promise)); promises.push_back(std::move(promise));
if (promises.size() != 1) { if (promises.size() != 1) {
if (logevent_id != 0) {
LOG(ERROR) << "Duplicate getDialog query for " << dialog_id;
BinlogHelper::erase(G()->td_db()->get_binlog(), logevent_id);
}
// query has already been sent, just wait for the result // query has already been sent, just wait for the result
return; return;
} }