Move Saved Messages-specific functions to SavedMessagesManager.
This commit is contained in:
levlam
parent
1eb8c22f75
commit
7267e1e89c
@ -188,238 +188,6 @@ class GetPinnedDialogsQuery final : public Td::ResultHandler {
|
||||
}
|
||||
};
|
||||
|
||||
class GetPinnedSavedDialogsQuery final : public Td::ResultHandler {
|
||||
Promise<td_api::object_ptr<td_api::foundSavedMessagesTopics>> promise_;
|
||||
|
||||
public:
|
||||
explicit GetPinnedSavedDialogsQuery(Promise<td_api::object_ptr<td_api::foundSavedMessagesTopics>> &&promise)
|
||||
: promise_(std::move(promise)) {
|
||||
}
|
||||
|
||||
void send() {
|
||||
send_query(G()->net_query_creator().create(telegram_api::messages_getPinnedSavedDialogs()));
|
||||
}
|
||||
|
||||
void on_result(BufferSlice packet) final {
|
||||
auto result_ptr = fetch_result<telegram_api::messages_getPinnedSavedDialogs>(packet);
|
||||
if (result_ptr.is_error()) {
|
||||
return on_error(result_ptr.move_as_error());
|
||||
}
|
||||
|
||||
auto result = result_ptr.move_as_ok();
|
||||
LOG(INFO) << "Receive result for GetPinnedSavedDialogsQuery: " << to_string(result);
|
||||
td_->messages_manager_->on_get_saved_messages_topics(std::move(result), std::move(promise_));
|
||||
}
|
||||
|
||||
void on_error(Status status) final {
|
||||
promise_.set_error(std::move(status));
|
||||
}
|
||||
};
|
||||
|
||||
class GetSavedDialogsQuery final : public Td::ResultHandler {
|
||||
Promise<td_api::object_ptr<td_api::foundSavedMessagesTopics>> promise_;
|
||||
|
||||
public:
|
||||
explicit GetSavedDialogsQuery(Promise<td_api::object_ptr<td_api::foundSavedMessagesTopics>> &&promise)
|
||||
: promise_(std::move(promise)) {
|
||||
}
|
||||
|
||||
void send(int32 offset_date, MessageId offset_message_id, DialogId offset_dialog_id, int32 limit) {
|
||||
auto input_peer = DialogManager::get_input_peer_force(offset_dialog_id);
|
||||
CHECK(input_peer != nullptr);
|
||||
|
||||
int32 flags = telegram_api::messages_getSavedDialogs::EXCLUDE_PINNED_MASK;
|
||||
send_query(G()->net_query_creator().create(telegram_api::messages_getSavedDialogs(
|
||||
flags, false /*ignored*/, offset_date, offset_message_id.get_server_message_id().get(), std::move(input_peer),
|
||||
limit, 0)));
|
||||
}
|
||||
|
||||
void on_result(BufferSlice packet) final {
|
||||
auto result_ptr = fetch_result<telegram_api::messages_getSavedDialogs>(packet);
|
||||
if (result_ptr.is_error()) {
|
||||
return on_error(result_ptr.move_as_error());
|
||||
}
|
||||
|
||||
auto result = result_ptr.move_as_ok();
|
||||
LOG(INFO) << "Receive result for GetSavedDialogsQuery: " << to_string(result);
|
||||
td_->messages_manager_->on_get_saved_messages_topics(std::move(result), std::move(promise_));
|
||||
}
|
||||
|
||||
void on_error(Status status) final {
|
||||
promise_.set_error(std::move(status));
|
||||
}
|
||||
};
|
||||
|
||||
class GetSavedHistoryQuery final : public Td::ResultHandler {
|
||||
Promise<td_api::object_ptr<td_api::messages>> promise_;
|
||||
SavedMessagesTopicId saved_messages_topic_id_;
|
||||
|
||||
public:
|
||||
explicit GetSavedHistoryQuery(Promise<td_api::object_ptr<td_api::messages>> &&promise)
|
||||
: promise_(std::move(promise)) {
|
||||
}
|
||||
|
||||
void send(SavedMessagesTopicId saved_messages_topic_id, MessageId from_message_id, int32 offset, int32 limit) {
|
||||
saved_messages_topic_id_ = saved_messages_topic_id;
|
||||
auto saved_input_peer = saved_messages_topic_id.get_input_peer(td_);
|
||||
CHECK(saved_input_peer != nullptr);
|
||||
send_query(G()->net_query_creator().create(telegram_api::messages_getSavedHistory(
|
||||
std::move(saved_input_peer), from_message_id.get_server_message_id().get(), 0, offset, limit, 0, 0, 0)));
|
||||
}
|
||||
|
||||
void on_result(BufferSlice packet) final {
|
||||
auto result_ptr = fetch_result<telegram_api::messages_getSavedHistory>(packet);
|
||||
if (result_ptr.is_error()) {
|
||||
return on_error(result_ptr.move_as_error());
|
||||
}
|
||||
|
||||
auto my_dialog_id = td_->dialog_manager_->get_my_dialog_id();
|
||||
auto info = get_messages_info(td_, my_dialog_id, result_ptr.move_as_ok(), "GetSavedHistoryQuery");
|
||||
LOG_IF(ERROR, info.is_channel_messages) << "Receive channel messages in GetSavedHistoryQuery";
|
||||
|
||||
vector<td_api::object_ptr<td_api::message>> messages;
|
||||
for (auto &message : info.messages) {
|
||||
auto full_message_id =
|
||||
td_->messages_manager_->on_get_message(std::move(message), false, false, false, "GetSavedHistoryQuery");
|
||||
auto dialog_id = full_message_id.get_dialog_id();
|
||||
if (dialog_id != my_dialog_id) {
|
||||
if (dialog_id != DialogId()) {
|
||||
LOG(ERROR) << "Receive " << full_message_id << " in history of " << saved_messages_topic_id_;
|
||||
}
|
||||
continue;
|
||||
}
|
||||
messages.push_back(td_->messages_manager_->get_message_object(full_message_id, "GetSavedHistoryQuery"));
|
||||
}
|
||||
promise_.set_value(td_api::make_object<td_api::messages>(info.total_count, std::move(messages)));
|
||||
}
|
||||
|
||||
void on_error(Status status) final {
|
||||
promise_.set_error(std::move(status));
|
||||
}
|
||||
};
|
||||
|
||||
class GetSavedMessageByDateQuery final : public Td::ResultHandler {
|
||||
Promise<td_api::object_ptr<td_api::message>> promise_;
|
||||
int32 date_ = 0;
|
||||
|
||||
public:
|
||||
explicit GetSavedMessageByDateQuery(Promise<td_api::object_ptr<td_api::message>> &&promise)
|
||||
: promise_(std::move(promise)) {
|
||||
}
|
||||
|
||||
void send(SavedMessagesTopicId saved_messages_topic_id, int32 date) {
|
||||
date_ = date;
|
||||
auto saved_input_peer = saved_messages_topic_id.get_input_peer(td_);
|
||||
CHECK(saved_input_peer != nullptr);
|
||||
|
||||
send_query(G()->net_query_creator().create(
|
||||
telegram_api::messages_getSavedHistory(std::move(saved_input_peer), 0, date, -3, 5, 0, 0, 0)));
|
||||
}
|
||||
|
||||
void on_result(BufferSlice packet) final {
|
||||
auto result_ptr = fetch_result<telegram_api::messages_getSavedHistory>(packet);
|
||||
if (result_ptr.is_error()) {
|
||||
return on_error(result_ptr.move_as_error());
|
||||
}
|
||||
|
||||
auto my_dialog_id = td_->dialog_manager_->get_my_dialog_id();
|
||||
auto info = get_messages_info(td_, my_dialog_id, result_ptr.move_as_ok(), "GetSavedMessageByDateQuery");
|
||||
LOG_IF(ERROR, info.is_channel_messages) << "Receive channel messages in GetSavedMessageByDateQuery";
|
||||
for (auto &message : info.messages) {
|
||||
auto message_date = MessagesManager::get_message_date(message);
|
||||
auto message_dialog_id = DialogId::get_message_dialog_id(message);
|
||||
if (message_dialog_id != my_dialog_id) {
|
||||
LOG(ERROR) << "Receive message in wrong " << message_dialog_id << " instead of " << my_dialog_id;
|
||||
continue;
|
||||
}
|
||||
if (message_date != 0 && message_date <= date_) {
|
||||
auto message_full_id = td_->messages_manager_->on_get_message(std::move(message), false, false, false,
|
||||
"GetSavedMessageByDateQuery");
|
||||
if (message_full_id != MessageFullId()) {
|
||||
return promise_.set_value(
|
||||
td_->messages_manager_->get_message_object(message_full_id, "GetSavedMessageByDateQuery"));
|
||||
}
|
||||
}
|
||||
}
|
||||
promise_.set_value(nullptr);
|
||||
}
|
||||
|
||||
void on_error(Status status) final {
|
||||
promise_.set_error(std::move(status));
|
||||
}
|
||||
};
|
||||
|
||||
class ToggleSavedDialogPinQuery final : public Td::ResultHandler {
|
||||
Promise<Unit> promise_;
|
||||
|
||||
public:
|
||||
explicit ToggleSavedDialogPinQuery(Promise<Unit> &&promise) : promise_(std::move(promise)) {
|
||||
}
|
||||
|
||||
void send(SavedMessagesTopicId saved_messages_topic_id, bool is_pinned) {
|
||||
auto saved_input_peer = saved_messages_topic_id.get_input_dialog_peer(td_);
|
||||
CHECK(saved_input_peer != nullptr);
|
||||
|
||||
int32 flags = 0;
|
||||
if (is_pinned) {
|
||||
flags |= telegram_api::messages_toggleSavedDialogPin::PINNED_MASK;
|
||||
}
|
||||
send_query(G()->net_query_creator().create(
|
||||
telegram_api::messages_toggleSavedDialogPin(flags, false /*ignored*/, std::move(saved_input_peer))));
|
||||
}
|
||||
|
||||
void on_result(BufferSlice packet) final {
|
||||
auto result_ptr = fetch_result<telegram_api::messages_toggleSavedDialogPin>(packet);
|
||||
if (result_ptr.is_error()) {
|
||||
return on_error(result_ptr.move_as_error());
|
||||
}
|
||||
|
||||
td_->messages_manager_->on_update_pinned_saved_messages_topics();
|
||||
promise_.set_value(Unit());
|
||||
}
|
||||
|
||||
void on_error(Status status) final {
|
||||
promise_.set_error(std::move(status));
|
||||
}
|
||||
};
|
||||
|
||||
class ReorderPinnedSavedDialogsQuery final : public Td::ResultHandler {
|
||||
Promise<Unit> promise_;
|
||||
|
||||
public:
|
||||
explicit ReorderPinnedSavedDialogsQuery(Promise<Unit> &&promise) : promise_(std::move(promise)) {
|
||||
}
|
||||
|
||||
void send(const vector<SavedMessagesTopicId> &saved_messages_topic_ids) {
|
||||
auto order = transform(saved_messages_topic_ids, [td = td_](SavedMessagesTopicId saved_messages_topic_id) {
|
||||
auto saved_input_peer = saved_messages_topic_id.get_input_dialog_peer(td);
|
||||
CHECK(saved_input_peer != nullptr);
|
||||
return saved_input_peer;
|
||||
});
|
||||
int32 flags = telegram_api::messages_reorderPinnedSavedDialogs::FORCE_MASK;
|
||||
send_query(G()->net_query_creator().create(
|
||||
telegram_api::messages_reorderPinnedSavedDialogs(flags, true /*ignored*/, std::move(order))));
|
||||
}
|
||||
|
||||
void on_result(BufferSlice packet) final {
|
||||
auto result_ptr = fetch_result<telegram_api::messages_reorderPinnedSavedDialogs>(packet);
|
||||
if (result_ptr.is_error()) {
|
||||
return on_error(result_ptr.move_as_error());
|
||||
}
|
||||
|
||||
bool result = result_ptr.move_as_ok();
|
||||
if (!result) {
|
||||
return on_error(Status::Error(400, "Result is false"));
|
||||
}
|
||||
td_->messages_manager_->on_update_pinned_saved_messages_topics();
|
||||
promise_.set_value(Unit());
|
||||
}
|
||||
|
||||
void on_error(Status status) final {
|
||||
promise_.set_error(std::move(status));
|
||||
}
|
||||
};
|
||||
|
||||
class GetDialogUnreadMarksQuery final : public Td::ResultHandler {
|
||||
public:
|
||||
void send() {
|
||||
@ -2637,36 +2405,6 @@ class DeleteChannelHistoryQuery final : public Td::ResultHandler {
|
||||
}
|
||||
};
|
||||
|
||||
class DeleteSavedHistoryQuery final : public Td::ResultHandler {
|
||||
Promise<AffectedHistory> promise_;
|
||||
|
||||
public:
|
||||
explicit DeleteSavedHistoryQuery(Promise<AffectedHistory> &&promise) : promise_(std::move(promise)) {
|
||||
}
|
||||
|
||||
void send(SavedMessagesTopicId saved_messages_topic_id) {
|
||||
auto saved_input_peer = saved_messages_topic_id.get_input_peer(td_);
|
||||
CHECK(saved_input_peer != nullptr);
|
||||
|
||||
int32 flags = 0;
|
||||
send_query(G()->net_query_creator().create(telegram_api::messages_deleteSavedHistory(
|
||||
flags, std::move(saved_input_peer), std::numeric_limits<int32>::max(), 0, 0)));
|
||||
}
|
||||
|
||||
void on_result(BufferSlice packet) final {
|
||||
auto result_ptr = fetch_result<telegram_api::messages_deleteSavedHistory>(packet);
|
||||
if (result_ptr.is_error()) {
|
||||
return on_error(result_ptr.move_as_error());
|
||||
}
|
||||
|
||||
promise_.set_value(AffectedHistory(result_ptr.move_as_ok()));
|
||||
}
|
||||
|
||||
void on_error(Status status) final {
|
||||
promise_.set_error(std::move(status));
|
||||
}
|
||||
};
|
||||
|
||||
class DeleteMessagesByDateQuery final : public Td::ResultHandler {
|
||||
Promise<AffectedHistory> promise_;
|
||||
DialogId dialog_id_;
|
||||
@ -2709,38 +2447,6 @@ class DeleteMessagesByDateQuery final : public Td::ResultHandler {
|
||||
}
|
||||
};
|
||||
|
||||
class DeleteSavedMessagesByDateQuery final : public Td::ResultHandler {
|
||||
Promise<AffectedHistory> promise_;
|
||||
|
||||
public:
|
||||
explicit DeleteSavedMessagesByDateQuery(Promise<AffectedHistory> &&promise) : promise_(std::move(promise)) {
|
||||
}
|
||||
|
||||
void send(SavedMessagesTopicId saved_messages_topic_id, int32 min_date, int32 max_date) {
|
||||
auto saved_input_peer = saved_messages_topic_id.get_input_peer(td_);
|
||||
CHECK(saved_input_peer != nullptr);
|
||||
|
||||
int32 flags =
|
||||
telegram_api::messages_deleteHistory::MIN_DATE_MASK | telegram_api::messages_deleteHistory::MAX_DATE_MASK;
|
||||
|
||||
send_query(G()->net_query_creator().create(
|
||||
telegram_api::messages_deleteSavedHistory(flags, std::move(saved_input_peer), 0, min_date, max_date)));
|
||||
}
|
||||
|
||||
void on_result(BufferSlice packet) final {
|
||||
auto result_ptr = fetch_result<telegram_api::messages_deleteSavedHistory>(packet);
|
||||
if (result_ptr.is_error()) {
|
||||
return on_error(result_ptr.move_as_error());
|
||||
}
|
||||
|
||||
promise_.set_value(AffectedHistory(result_ptr.move_as_ok()));
|
||||
}
|
||||
|
||||
void on_error(Status status) final {
|
||||
promise_.set_error(std::move(status));
|
||||
}
|
||||
};
|
||||
|
||||
class DeletePhoneCallHistoryQuery final : public Td::ResultHandler {
|
||||
Promise<AffectedHistory> promise_;
|
||||
|
||||
@ -16210,265 +15916,6 @@ void MessagesManager::reload_pinned_dialogs(DialogListId dialog_list_id, Promise
|
||||
}
|
||||
}
|
||||
|
||||
void MessagesManager::get_pinned_saved_messages_topics(
|
||||
Promise<td_api::object_ptr<td_api::foundSavedMessagesTopics>> &&promise) {
|
||||
td_->create_handler<GetPinnedSavedDialogsQuery>(std::move(promise))->send();
|
||||
}
|
||||
|
||||
void MessagesManager::get_saved_messages_topics(
|
||||
const string &offset, int32 limit, Promise<td_api::object_ptr<td_api::foundSavedMessagesTopics>> &&promise) {
|
||||
int32 offset_date = std::numeric_limits<int32>::max();
|
||||
DialogId offset_dialog_id;
|
||||
MessageId offset_message_id;
|
||||
bool is_offset_valid = [&] {
|
||||
if (offset.empty()) {
|
||||
return true;
|
||||
}
|
||||
|
||||
auto parts = full_split(offset, ',');
|
||||
if (parts.size() != 3) {
|
||||
return false;
|
||||
}
|
||||
auto r_offset_date = to_integer_safe<int32>(parts[0]);
|
||||
auto r_offset_dialog_id = to_integer_safe<int64>(parts[1]);
|
||||
auto r_offset_message_id = to_integer_safe<int32>(parts[2]);
|
||||
if (r_offset_date.is_error() || r_offset_date.ok() <= 0 || r_offset_message_id.is_error() ||
|
||||
r_offset_dialog_id.is_error()) {
|
||||
return false;
|
||||
}
|
||||
offset_date = r_offset_date.ok();
|
||||
offset_message_id = MessageId(ServerMessageId(r_offset_message_id.ok()));
|
||||
offset_dialog_id = DialogId(r_offset_dialog_id.ok());
|
||||
if (!offset_message_id.is_valid() || !offset_dialog_id.is_valid() ||
|
||||
DialogManager::get_input_peer_force(offset_dialog_id)->get_id() == telegram_api::inputPeerEmpty::ID) {
|
||||
return false;
|
||||
}
|
||||
return true;
|
||||
}();
|
||||
if (!is_offset_valid) {
|
||||
return promise.set_error(Status::Error(400, "Invalid offset specified"));
|
||||
}
|
||||
|
||||
if (limit < 0) {
|
||||
return promise.set_error(Status::Error(400, "Limit must be non-negative"));
|
||||
}
|
||||
|
||||
td_->create_handler<GetSavedDialogsQuery>(std::move(promise))
|
||||
->send(offset_date, offset_message_id, offset_dialog_id, limit);
|
||||
}
|
||||
|
||||
void MessagesManager::on_get_saved_messages_topics(
|
||||
telegram_api::object_ptr<telegram_api::messages_SavedDialogs> &&saved_dialogs_ptr,
|
||||
Promise<td_api::object_ptr<td_api::foundSavedMessagesTopics>> &&promise) {
|
||||
CHECK(saved_dialogs_ptr != nullptr);
|
||||
int32 total_count = -1;
|
||||
vector<telegram_api::object_ptr<telegram_api::savedDialog>> dialogs;
|
||||
vector<telegram_api::object_ptr<telegram_api::Message>> messages;
|
||||
vector<telegram_api::object_ptr<telegram_api::Chat>> chats;
|
||||
vector<telegram_api::object_ptr<telegram_api::User>> users;
|
||||
bool is_last = false;
|
||||
switch (saved_dialogs_ptr->get_id()) {
|
||||
case telegram_api::messages_savedDialogsNotModified::ID:
|
||||
LOG(ERROR) << "Receive messages.savedDialogsNotModified";
|
||||
return promise.set_error(Status::Error(500, "Receive messages.savedDialogsNotModified"));
|
||||
case telegram_api::messages_savedDialogs::ID: {
|
||||
auto saved_dialogs = telegram_api::move_object_as<telegram_api::messages_savedDialogs>(saved_dialogs_ptr);
|
||||
total_count = static_cast<int32>(saved_dialogs->dialogs_.size());
|
||||
dialogs = std::move(saved_dialogs->dialogs_);
|
||||
messages = std::move(saved_dialogs->messages_);
|
||||
chats = std::move(saved_dialogs->chats_);
|
||||
users = std::move(saved_dialogs->users_);
|
||||
is_last = true;
|
||||
break;
|
||||
}
|
||||
case telegram_api::messages_savedDialogsSlice::ID: {
|
||||
auto saved_dialogs = telegram_api::move_object_as<telegram_api::messages_savedDialogsSlice>(saved_dialogs_ptr);
|
||||
total_count = saved_dialogs->count_;
|
||||
if (total_count < static_cast<int32>(saved_dialogs->dialogs_.size())) {
|
||||
LOG(ERROR) << "Receive total_count = " << total_count << ", but " << saved_dialogs->dialogs_.size()
|
||||
<< " Saved Messages topics";
|
||||
total_count = static_cast<int32>(saved_dialogs->dialogs_.size());
|
||||
}
|
||||
dialogs = std::move(saved_dialogs->dialogs_);
|
||||
messages = std::move(saved_dialogs->messages_);
|
||||
chats = std::move(saved_dialogs->chats_);
|
||||
users = std::move(saved_dialogs->users_);
|
||||
break;
|
||||
}
|
||||
default:
|
||||
UNREACHABLE();
|
||||
}
|
||||
td_->contacts_manager_->on_get_users(std::move(users), "on_get_saved_messages_topics");
|
||||
td_->contacts_manager_->on_get_chats(std::move(chats), "on_get_saved_messages_topics");
|
||||
|
||||
FlatHashMap<MessageId, tl_object_ptr<telegram_api::Message>, MessageIdHash> message_id_to_message;
|
||||
for (auto &message : messages) {
|
||||
auto message_id = MessageId::get_message_id(message, false);
|
||||
if (!message_id.is_valid()) {
|
||||
continue;
|
||||
}
|
||||
message_id_to_message[message_id] = std::move(message);
|
||||
}
|
||||
|
||||
int32 last_message_date = 0;
|
||||
MessageId last_message_id;
|
||||
DialogId last_dialog_id;
|
||||
vector<SavedMessagesTopicId> added_saved_messages_topic_ids;
|
||||
vector<td_api::object_ptr<td_api::foundSavedMessagesTopic>> found_saved_messages_topics;
|
||||
for (auto &dialog : dialogs) {
|
||||
auto peer_dialog_id = DialogId(dialog->peer_);
|
||||
if (!peer_dialog_id.is_valid()) {
|
||||
LOG(ERROR) << "Receive " << peer_dialog_id << " in result of getSavedMessagesTopics";
|
||||
total_count--;
|
||||
continue;
|
||||
}
|
||||
SavedMessagesTopicId saved_messages_topic_id(peer_dialog_id);
|
||||
if (td::contains(added_saved_messages_topic_ids, saved_messages_topic_id)) {
|
||||
LOG(ERROR) << "Receive " << saved_messages_topic_id
|
||||
<< " twice in result of getSavedMessagesTopics with total_count = " << total_count;
|
||||
total_count--;
|
||||
continue;
|
||||
}
|
||||
added_saved_messages_topic_ids.push_back(saved_messages_topic_id);
|
||||
|
||||
MessageId last_topic_message_id(ServerMessageId(dialog->top_message_));
|
||||
if (!last_topic_message_id.is_valid()) {
|
||||
// skip topics without messages
|
||||
LOG(ERROR) << "Receive " << saved_messages_topic_id << " without last message";
|
||||
total_count--;
|
||||
continue;
|
||||
}
|
||||
|
||||
auto it = message_id_to_message.find(last_topic_message_id);
|
||||
if (it == message_id_to_message.end()) {
|
||||
LOG(ERROR) << "Can't find last " << last_topic_message_id << " in " << saved_messages_topic_id;
|
||||
total_count--;
|
||||
continue;
|
||||
}
|
||||
auto message_date = get_message_date(it->second);
|
||||
if (message_date > 0) {
|
||||
last_message_date = message_date;
|
||||
last_message_id = last_topic_message_id;
|
||||
last_dialog_id = peer_dialog_id;
|
||||
}
|
||||
auto full_message_id = on_get_message(std::move(it->second), false, false, false, "on_get_saved_messages_topics");
|
||||
message_id_to_message.erase(it);
|
||||
|
||||
if (full_message_id.get_dialog_id() != DialogId() &&
|
||||
full_message_id.get_dialog_id() != td_->dialog_manager_->get_my_dialog_id()) {
|
||||
LOG(ERROR) << "Can't add last " << last_message_id << " to " << saved_messages_topic_id;
|
||||
total_count--;
|
||||
continue;
|
||||
}
|
||||
found_saved_messages_topics.push_back(td_api::make_object<td_api::foundSavedMessagesTopic>(
|
||||
saved_messages_topic_id.get_saved_messages_topic_object(td_),
|
||||
get_message_object(full_message_id, "on_get_saved_messages_topics")));
|
||||
}
|
||||
string next_offset;
|
||||
if (last_message_date > 0 && !is_last) {
|
||||
next_offset = PSTRING() << last_message_date << ',' << last_dialog_id.get() << ','
|
||||
<< last_message_id.get_server_message_id().get();
|
||||
}
|
||||
promise.set_value(td_api::make_object<td_api::foundSavedMessagesTopics>(
|
||||
total_count, std::move(found_saved_messages_topics), next_offset));
|
||||
}
|
||||
|
||||
void MessagesManager::get_saved_messages_topic_history(SavedMessagesTopicId saved_messages_topic_id,
|
||||
MessageId from_message_id, int32 offset, int32 limit,
|
||||
Promise<td_api::object_ptr<td_api::messages>> &&promise) {
|
||||
if (limit <= 0) {
|
||||
return promise.set_error(Status::Error(400, "Parameter limit must be positive"));
|
||||
}
|
||||
if (limit > MAX_GET_HISTORY) {
|
||||
limit = MAX_GET_HISTORY;
|
||||
}
|
||||
if (offset > 0) {
|
||||
return promise.set_error(Status::Error(400, "Parameter offset must be non-positive"));
|
||||
}
|
||||
if (offset <= -MAX_GET_HISTORY) {
|
||||
return promise.set_error(Status::Error(400, "Parameter offset must be greater than -100"));
|
||||
}
|
||||
if (offset < -limit) {
|
||||
return promise.set_error(Status::Error(400, "Parameter offset must be greater than or equal to -limit"));
|
||||
}
|
||||
|
||||
TRY_STATUS_PROMISE(promise, saved_messages_topic_id.is_valid_status(td_));
|
||||
|
||||
if (from_message_id == MessageId() || from_message_id.get() > MessageId::max().get()) {
|
||||
from_message_id = MessageId::max();
|
||||
}
|
||||
if (!from_message_id.is_valid() || !from_message_id.is_server()) {
|
||||
return promise.set_error(Status::Error(400, "Invalid value of parameter from_message_id specified"));
|
||||
}
|
||||
|
||||
td_->create_handler<GetSavedHistoryQuery>(std::move(promise))
|
||||
->send(saved_messages_topic_id, from_message_id, offset, limit);
|
||||
}
|
||||
|
||||
void MessagesManager::delete_saved_messages_topic_history(SavedMessagesTopicId saved_messages_topic_id,
|
||||
Promise<Unit> &&promise) {
|
||||
TRY_STATUS_PROMISE(promise, saved_messages_topic_id.is_valid_status(td_));
|
||||
|
||||
AffectedHistoryQuery query = [td = td_, saved_messages_topic_id](DialogId, Promise<AffectedHistory> &&query_promise) {
|
||||
td->create_handler<DeleteSavedHistoryQuery>(std::move(query_promise))->send(saved_messages_topic_id);
|
||||
};
|
||||
auto my_dialog_id = td_->dialog_manager_->get_my_dialog_id();
|
||||
run_affected_history_query_until_complete(my_dialog_id, std::move(query), true, std::move(promise));
|
||||
}
|
||||
|
||||
void MessagesManager::get_saved_messages_topic_message_by_date(SavedMessagesTopicId saved_messages_topic_id, int32 date,
|
||||
Promise<td_api::object_ptr<td_api::message>> &&promise) {
|
||||
TRY_STATUS_PROMISE(promise, saved_messages_topic_id.is_valid_status(td_));
|
||||
|
||||
if (date <= 0) {
|
||||
date = 1;
|
||||
}
|
||||
|
||||
td_->create_handler<GetSavedMessageByDateQuery>(std::move(promise))->send(saved_messages_topic_id, date);
|
||||
}
|
||||
|
||||
void MessagesManager::delete_saved_messages_topic_messages_by_date(SavedMessagesTopicId saved_messages_topic_id,
|
||||
int32 min_date, int32 max_date,
|
||||
Promise<Unit> &&promise) {
|
||||
TRY_STATUS_PROMISE(promise, saved_messages_topic_id.is_valid_status(td_));
|
||||
|
||||
TRY_STATUS_PROMISE(promise, fix_delete_message_min_max_dates(min_date, max_date));
|
||||
if (max_date == 0) {
|
||||
return promise.set_value(Unit());
|
||||
}
|
||||
|
||||
AffectedHistoryQuery query = [td = td_, saved_messages_topic_id, min_date, max_date](
|
||||
DialogId, Promise<AffectedHistory> &&query_promise) {
|
||||
td->create_handler<DeleteSavedMessagesByDateQuery>(std::move(query_promise))
|
||||
->send(saved_messages_topic_id, min_date, max_date);
|
||||
};
|
||||
auto my_dialog_id = td_->dialog_manager_->get_my_dialog_id();
|
||||
run_affected_history_query_until_complete(my_dialog_id, std::move(query), true, std::move(promise));
|
||||
}
|
||||
|
||||
void MessagesManager::toggle_saved_messages_topic_is_pinned(SavedMessagesTopicId saved_messages_topic_id,
|
||||
bool is_pinned, Promise<Unit> &&promise) {
|
||||
TRY_STATUS_PROMISE(promise, saved_messages_topic_id.is_valid_status(td_));
|
||||
td_->create_handler<ToggleSavedDialogPinQuery>(std::move(promise))->send(saved_messages_topic_id, is_pinned);
|
||||
}
|
||||
|
||||
void MessagesManager::set_pinned_saved_messages_topics(vector<SavedMessagesTopicId> saved_messages_topic_ids,
|
||||
Promise<Unit> &&promise) {
|
||||
for (const auto &saved_messages_topic_id : saved_messages_topic_ids) {
|
||||
TRY_STATUS_PROMISE(promise, saved_messages_topic_id.is_valid_status(td_));
|
||||
}
|
||||
td_->create_handler<ReorderPinnedSavedDialogsQuery>(std::move(promise))->send(std::move(saved_messages_topic_ids));
|
||||
}
|
||||
|
||||
void MessagesManager::on_update_pinned_saved_messages_topics() {
|
||||
if (td_->auth_manager_->is_bot()) {
|
||||
// just in case
|
||||
return;
|
||||
}
|
||||
|
||||
send_closure(G()->td(), &Td::send_update, td_api::make_object<td_api::updatePinnedSavedMessagesTopics>());
|
||||
}
|
||||
|
||||
vector<DialogId> MessagesManager::search_public_dialogs(const string &query, Promise<Unit> &&promise) {
|
||||
LOG(INFO) << "Search public chats with query = \"" << query << '"';
|
||||
|
||||
|
||||
@ -364,6 +364,8 @@ class MessagesManager final : public Actor {
|
||||
|
||||
void delete_dialog_messages_by_sender(DialogId dialog_id, DialogId sender_dialog_id, Promise<Unit> &&promise);
|
||||
|
||||
static Status fix_delete_message_min_max_dates(int32 &min_date, int32 &max_date);
|
||||
|
||||
void delete_dialog_messages_by_date(DialogId dialog_id, int32 min_date, int32 max_date, bool revoke,
|
||||
Promise<Unit> &&promise);
|
||||
|
||||
@ -532,33 +534,6 @@ class MessagesManager final : public Actor {
|
||||
|
||||
void read_all_dialogs_from_list(DialogListId dialog_list_id, Promise<Unit> &&promise, bool is_recursive = false);
|
||||
|
||||
void get_pinned_saved_messages_topics(Promise<td_api::object_ptr<td_api::foundSavedMessagesTopics>> &&promise);
|
||||
|
||||
void get_saved_messages_topics(const string &offset, int32 limit,
|
||||
Promise<td_api::object_ptr<td_api::foundSavedMessagesTopics>> &&promise);
|
||||
|
||||
void on_get_saved_messages_topics(telegram_api::object_ptr<telegram_api::messages_SavedDialogs> &&saved_dialogs_ptr,
|
||||
Promise<td_api::object_ptr<td_api::foundSavedMessagesTopics>> &&promise);
|
||||
|
||||
void get_saved_messages_topic_history(SavedMessagesTopicId saved_messages_topic_id, MessageId from_message_id,
|
||||
int32 offset, int32 limit,
|
||||
Promise<td_api::object_ptr<td_api::messages>> &&promise);
|
||||
|
||||
void delete_saved_messages_topic_history(SavedMessagesTopicId saved_messages_topic_id, Promise<Unit> &&promise);
|
||||
|
||||
void get_saved_messages_topic_message_by_date(SavedMessagesTopicId saved_messages_topic_id, int32 date,
|
||||
Promise<td_api::object_ptr<td_api::message>> &&promise);
|
||||
|
||||
void delete_saved_messages_topic_messages_by_date(SavedMessagesTopicId saved_messages_topic_id, int32 min_date,
|
||||
int32 max_date, Promise<Unit> &&promise);
|
||||
|
||||
void toggle_saved_messages_topic_is_pinned(SavedMessagesTopicId saved_messages_topic_id, bool is_pinned,
|
||||
Promise<Unit> &&promise);
|
||||
|
||||
void set_pinned_saved_messages_topics(vector<SavedMessagesTopicId> saved_messages_topic_ids, Promise<Unit> &&promise);
|
||||
|
||||
void on_update_pinned_saved_messages_topics();
|
||||
|
||||
vector<DialogId> search_public_dialogs(const string &query, Promise<Unit> &&promise);
|
||||
|
||||
std::pair<int32, vector<DialogId>> search_dialogs(const string &query, int32 limit, Promise<Unit> &&promise);
|
||||
@ -788,6 +763,11 @@ class MessagesManager final : public Actor {
|
||||
vector<MessageId> get_dialog_scheduled_messages(DialogId dialog_id, bool force, bool ignore_result,
|
||||
Promise<Unit> &&promise);
|
||||
|
||||
using AffectedHistoryQuery = std::function<void(DialogId, Promise<AffectedHistory>)>;
|
||||
|
||||
void run_affected_history_query_until_complete(DialogId dialog_id, AffectedHistoryQuery query,
|
||||
bool get_affected_messages, Promise<Unit> &&promise);
|
||||
|
||||
Result<td_api::object_ptr<td_api::availableReactions>> get_message_available_reactions(MessageFullId message_full_id,
|
||||
int32 row_size);
|
||||
|
||||
@ -1959,11 +1939,6 @@ class MessagesManager final : public Actor {
|
||||
|
||||
void unpin_all_dialog_messages_on_server(DialogId dialog_id, uint64 log_event_id, Promise<Unit> &&promise);
|
||||
|
||||
using AffectedHistoryQuery = std::function<void(DialogId, Promise<AffectedHistory>)>;
|
||||
|
||||
void run_affected_history_query_until_complete(DialogId dialog_id, AffectedHistoryQuery query,
|
||||
bool get_affected_messages, Promise<Unit> &&promise);
|
||||
|
||||
void on_get_affected_history(DialogId dialog_id, AffectedHistoryQuery query, bool get_affected_messages,
|
||||
AffectedHistory affected_history, Promise<Unit> &&promise);
|
||||
|
||||
@ -2691,8 +2666,6 @@ class MessagesManager final : public Actor {
|
||||
void on_get_dialog_message_by_date_from_database(DialogId dialog_id, int32 date, int64 random_id,
|
||||
Result<MessageDbDialogMessage> result, Promise<Unit> promise);
|
||||
|
||||
static Status fix_delete_message_min_max_dates(int32 &min_date, int32 &max_date);
|
||||
|
||||
std::pair<bool, int32> get_dialog_mute_until(DialogId dialog_id, const Dialog *d) const;
|
||||
|
||||
int64 get_dialog_notification_ringtone_id(DialogId dialog_id, const Dialog *d) const;
|
||||
|
||||
@ -6,8 +6,319 @@
|
||||
//
|
||||
#include "td/telegram/SavedMessagesManager.h"
|
||||
|
||||
#include "td/telegram/AffectedHistory.h"
|
||||
#include "td/telegram/AuthManager.h"
|
||||
#include "td/telegram/ContactsManager.h"
|
||||
#include "td/telegram/DialogId.h"
|
||||
#include "td/telegram/DialogManager.h"
|
||||
#include "td/telegram/Global.h"
|
||||
#include "td/telegram/MessagesInfo.h"
|
||||
#include "td/telegram/MessagesManager.h"
|
||||
#include "td/telegram/ServerMessageId.h"
|
||||
#include "td/telegram/Td.h"
|
||||
#include "td/telegram/telegram_api.h"
|
||||
|
||||
#include "td/utils/algorithm.h"
|
||||
#include "td/utils/buffer.h"
|
||||
#include "td/utils/FlatHashMap.h"
|
||||
#include "td/utils/logging.h"
|
||||
|
||||
namespace td {
|
||||
|
||||
class GetPinnedSavedDialogsQuery final : public Td::ResultHandler {
|
||||
Promise<td_api::object_ptr<td_api::foundSavedMessagesTopics>> promise_;
|
||||
|
||||
public:
|
||||
explicit GetPinnedSavedDialogsQuery(Promise<td_api::object_ptr<td_api::foundSavedMessagesTopics>> &&promise)
|
||||
: promise_(std::move(promise)) {
|
||||
}
|
||||
|
||||
void send() {
|
||||
send_query(G()->net_query_creator().create(telegram_api::messages_getPinnedSavedDialogs()));
|
||||
}
|
||||
|
||||
void on_result(BufferSlice packet) final {
|
||||
auto result_ptr = fetch_result<telegram_api::messages_getPinnedSavedDialogs>(packet);
|
||||
if (result_ptr.is_error()) {
|
||||
return on_error(result_ptr.move_as_error());
|
||||
}
|
||||
|
||||
auto result = result_ptr.move_as_ok();
|
||||
LOG(INFO) << "Receive result for GetPinnedSavedDialogsQuery: " << to_string(result);
|
||||
td_->saved_messages_manager_->on_get_saved_messages_topics(std::move(result), std::move(promise_));
|
||||
}
|
||||
|
||||
void on_error(Status status) final {
|
||||
promise_.set_error(std::move(status));
|
||||
}
|
||||
};
|
||||
|
||||
class GetSavedDialogsQuery final : public Td::ResultHandler {
|
||||
Promise<td_api::object_ptr<td_api::foundSavedMessagesTopics>> promise_;
|
||||
|
||||
public:
|
||||
explicit GetSavedDialogsQuery(Promise<td_api::object_ptr<td_api::foundSavedMessagesTopics>> &&promise)
|
||||
: promise_(std::move(promise)) {
|
||||
}
|
||||
|
||||
void send(int32 offset_date, MessageId offset_message_id, DialogId offset_dialog_id, int32 limit) {
|
||||
auto input_peer = DialogManager::get_input_peer_force(offset_dialog_id);
|
||||
CHECK(input_peer != nullptr);
|
||||
|
||||
int32 flags = telegram_api::messages_getSavedDialogs::EXCLUDE_PINNED_MASK;
|
||||
send_query(G()->net_query_creator().create(telegram_api::messages_getSavedDialogs(
|
||||
flags, false /*ignored*/, offset_date, offset_message_id.get_server_message_id().get(), std::move(input_peer),
|
||||
limit, 0)));
|
||||
}
|
||||
|
||||
void on_result(BufferSlice packet) final {
|
||||
auto result_ptr = fetch_result<telegram_api::messages_getSavedDialogs>(packet);
|
||||
if (result_ptr.is_error()) {
|
||||
return on_error(result_ptr.move_as_error());
|
||||
}
|
||||
|
||||
auto result = result_ptr.move_as_ok();
|
||||
LOG(INFO) << "Receive result for GetSavedDialogsQuery: " << to_string(result);
|
||||
td_->saved_messages_manager_->on_get_saved_messages_topics(std::move(result), std::move(promise_));
|
||||
}
|
||||
|
||||
void on_error(Status status) final {
|
||||
promise_.set_error(std::move(status));
|
||||
}
|
||||
};
|
||||
|
||||
class GetSavedHistoryQuery final : public Td::ResultHandler {
|
||||
Promise<td_api::object_ptr<td_api::messages>> promise_;
|
||||
SavedMessagesTopicId saved_messages_topic_id_;
|
||||
|
||||
public:
|
||||
explicit GetSavedHistoryQuery(Promise<td_api::object_ptr<td_api::messages>> &&promise)
|
||||
: promise_(std::move(promise)) {
|
||||
}
|
||||
|
||||
void send(SavedMessagesTopicId saved_messages_topic_id, MessageId from_message_id, int32 offset, int32 limit) {
|
||||
saved_messages_topic_id_ = saved_messages_topic_id;
|
||||
auto saved_input_peer = saved_messages_topic_id.get_input_peer(td_);
|
||||
CHECK(saved_input_peer != nullptr);
|
||||
send_query(G()->net_query_creator().create(telegram_api::messages_getSavedHistory(
|
||||
std::move(saved_input_peer), from_message_id.get_server_message_id().get(), 0, offset, limit, 0, 0, 0)));
|
||||
}
|
||||
|
||||
void on_result(BufferSlice packet) final {
|
||||
auto result_ptr = fetch_result<telegram_api::messages_getSavedHistory>(packet);
|
||||
if (result_ptr.is_error()) {
|
||||
return on_error(result_ptr.move_as_error());
|
||||
}
|
||||
|
||||
auto my_dialog_id = td_->dialog_manager_->get_my_dialog_id();
|
||||
auto info = get_messages_info(td_, my_dialog_id, result_ptr.move_as_ok(), "GetSavedHistoryQuery");
|
||||
LOG_IF(ERROR, info.is_channel_messages) << "Receive channel messages in GetSavedHistoryQuery";
|
||||
|
||||
vector<td_api::object_ptr<td_api::message>> messages;
|
||||
for (auto &message : info.messages) {
|
||||
auto full_message_id =
|
||||
td_->messages_manager_->on_get_message(std::move(message), false, false, false, "GetSavedHistoryQuery");
|
||||
auto dialog_id = full_message_id.get_dialog_id();
|
||||
if (dialog_id != my_dialog_id) {
|
||||
if (dialog_id != DialogId()) {
|
||||
LOG(ERROR) << "Receive " << full_message_id << " in history of " << saved_messages_topic_id_;
|
||||
}
|
||||
continue;
|
||||
}
|
||||
messages.push_back(td_->messages_manager_->get_message_object(full_message_id, "GetSavedHistoryQuery"));
|
||||
}
|
||||
promise_.set_value(td_api::make_object<td_api::messages>(info.total_count, std::move(messages)));
|
||||
}
|
||||
|
||||
void on_error(Status status) final {
|
||||
promise_.set_error(std::move(status));
|
||||
}
|
||||
};
|
||||
|
||||
class GetSavedMessageByDateQuery final : public Td::ResultHandler {
|
||||
Promise<td_api::object_ptr<td_api::message>> promise_;
|
||||
int32 date_ = 0;
|
||||
|
||||
public:
|
||||
explicit GetSavedMessageByDateQuery(Promise<td_api::object_ptr<td_api::message>> &&promise)
|
||||
: promise_(std::move(promise)) {
|
||||
}
|
||||
|
||||
void send(SavedMessagesTopicId saved_messages_topic_id, int32 date) {
|
||||
date_ = date;
|
||||
auto saved_input_peer = saved_messages_topic_id.get_input_peer(td_);
|
||||
CHECK(saved_input_peer != nullptr);
|
||||
|
||||
send_query(G()->net_query_creator().create(
|
||||
telegram_api::messages_getSavedHistory(std::move(saved_input_peer), 0, date, -3, 5, 0, 0, 0)));
|
||||
}
|
||||
|
||||
void on_result(BufferSlice packet) final {
|
||||
auto result_ptr = fetch_result<telegram_api::messages_getSavedHistory>(packet);
|
||||
if (result_ptr.is_error()) {
|
||||
return on_error(result_ptr.move_as_error());
|
||||
}
|
||||
|
||||
auto my_dialog_id = td_->dialog_manager_->get_my_dialog_id();
|
||||
auto info = get_messages_info(td_, my_dialog_id, result_ptr.move_as_ok(), "GetSavedMessageByDateQuery");
|
||||
LOG_IF(ERROR, info.is_channel_messages) << "Receive channel messages in GetSavedMessageByDateQuery";
|
||||
for (auto &message : info.messages) {
|
||||
auto message_date = MessagesManager::get_message_date(message);
|
||||
auto message_dialog_id = DialogId::get_message_dialog_id(message);
|
||||
if (message_dialog_id != my_dialog_id) {
|
||||
LOG(ERROR) << "Receive message in wrong " << message_dialog_id << " instead of " << my_dialog_id;
|
||||
continue;
|
||||
}
|
||||
if (message_date != 0 && message_date <= date_) {
|
||||
auto message_full_id = td_->messages_manager_->on_get_message(std::move(message), false, false, false,
|
||||
"GetSavedMessageByDateQuery");
|
||||
if (message_full_id != MessageFullId()) {
|
||||
return promise_.set_value(
|
||||
td_->messages_manager_->get_message_object(message_full_id, "GetSavedMessageByDateQuery"));
|
||||
}
|
||||
}
|
||||
}
|
||||
promise_.set_value(nullptr);
|
||||
}
|
||||
|
||||
void on_error(Status status) final {
|
||||
promise_.set_error(std::move(status));
|
||||
}
|
||||
};
|
||||
|
||||
class DeleteSavedHistoryQuery final : public Td::ResultHandler {
|
||||
Promise<AffectedHistory> promise_;
|
||||
|
||||
public:
|
||||
explicit DeleteSavedHistoryQuery(Promise<AffectedHistory> &&promise) : promise_(std::move(promise)) {
|
||||
}
|
||||
|
||||
void send(SavedMessagesTopicId saved_messages_topic_id) {
|
||||
auto saved_input_peer = saved_messages_topic_id.get_input_peer(td_);
|
||||
CHECK(saved_input_peer != nullptr);
|
||||
|
||||
int32 flags = 0;
|
||||
send_query(G()->net_query_creator().create(telegram_api::messages_deleteSavedHistory(
|
||||
flags, std::move(saved_input_peer), std::numeric_limits<int32>::max(), 0, 0)));
|
||||
}
|
||||
|
||||
void on_result(BufferSlice packet) final {
|
||||
auto result_ptr = fetch_result<telegram_api::messages_deleteSavedHistory>(packet);
|
||||
if (result_ptr.is_error()) {
|
||||
return on_error(result_ptr.move_as_error());
|
||||
}
|
||||
|
||||
promise_.set_value(AffectedHistory(result_ptr.move_as_ok()));
|
||||
}
|
||||
|
||||
void on_error(Status status) final {
|
||||
promise_.set_error(std::move(status));
|
||||
}
|
||||
};
|
||||
|
||||
class DeleteSavedMessagesByDateQuery final : public Td::ResultHandler {
|
||||
Promise<AffectedHistory> promise_;
|
||||
|
||||
public:
|
||||
explicit DeleteSavedMessagesByDateQuery(Promise<AffectedHistory> &&promise) : promise_(std::move(promise)) {
|
||||
}
|
||||
|
||||
void send(SavedMessagesTopicId saved_messages_topic_id, int32 min_date, int32 max_date) {
|
||||
auto saved_input_peer = saved_messages_topic_id.get_input_peer(td_);
|
||||
CHECK(saved_input_peer != nullptr);
|
||||
|
||||
int32 flags =
|
||||
telegram_api::messages_deleteHistory::MIN_DATE_MASK | telegram_api::messages_deleteHistory::MAX_DATE_MASK;
|
||||
|
||||
send_query(G()->net_query_creator().create(
|
||||
telegram_api::messages_deleteSavedHistory(flags, std::move(saved_input_peer), 0, min_date, max_date)));
|
||||
}
|
||||
|
||||
void on_result(BufferSlice packet) final {
|
||||
auto result_ptr = fetch_result<telegram_api::messages_deleteSavedHistory>(packet);
|
||||
if (result_ptr.is_error()) {
|
||||
return on_error(result_ptr.move_as_error());
|
||||
}
|
||||
|
||||
promise_.set_value(AffectedHistory(result_ptr.move_as_ok()));
|
||||
}
|
||||
|
||||
void on_error(Status status) final {
|
||||
promise_.set_error(std::move(status));
|
||||
}
|
||||
};
|
||||
|
||||
class ToggleSavedDialogPinQuery final : public Td::ResultHandler {
|
||||
Promise<Unit> promise_;
|
||||
|
||||
public:
|
||||
explicit ToggleSavedDialogPinQuery(Promise<Unit> &&promise) : promise_(std::move(promise)) {
|
||||
}
|
||||
|
||||
void send(SavedMessagesTopicId saved_messages_topic_id, bool is_pinned) {
|
||||
auto saved_input_peer = saved_messages_topic_id.get_input_dialog_peer(td_);
|
||||
CHECK(saved_input_peer != nullptr);
|
||||
|
||||
int32 flags = 0;
|
||||
if (is_pinned) {
|
||||
flags |= telegram_api::messages_toggleSavedDialogPin::PINNED_MASK;
|
||||
}
|
||||
send_query(G()->net_query_creator().create(
|
||||
telegram_api::messages_toggleSavedDialogPin(flags, false /*ignored*/, std::move(saved_input_peer))));
|
||||
}
|
||||
|
||||
void on_result(BufferSlice packet) final {
|
||||
auto result_ptr = fetch_result<telegram_api::messages_toggleSavedDialogPin>(packet);
|
||||
if (result_ptr.is_error()) {
|
||||
return on_error(result_ptr.move_as_error());
|
||||
}
|
||||
|
||||
td_->saved_messages_manager_->on_update_pinned_saved_messages_topics();
|
||||
promise_.set_value(Unit());
|
||||
}
|
||||
|
||||
void on_error(Status status) final {
|
||||
promise_.set_error(std::move(status));
|
||||
}
|
||||
};
|
||||
|
||||
class ReorderPinnedSavedDialogsQuery final : public Td::ResultHandler {
|
||||
Promise<Unit> promise_;
|
||||
|
||||
public:
|
||||
explicit ReorderPinnedSavedDialogsQuery(Promise<Unit> &&promise) : promise_(std::move(promise)) {
|
||||
}
|
||||
|
||||
void send(const vector<SavedMessagesTopicId> &saved_messages_topic_ids) {
|
||||
auto order = transform(saved_messages_topic_ids, [td = td_](SavedMessagesTopicId saved_messages_topic_id) {
|
||||
auto saved_input_peer = saved_messages_topic_id.get_input_dialog_peer(td);
|
||||
CHECK(saved_input_peer != nullptr);
|
||||
return saved_input_peer;
|
||||
});
|
||||
int32 flags = telegram_api::messages_reorderPinnedSavedDialogs::FORCE_MASK;
|
||||
send_query(G()->net_query_creator().create(
|
||||
telegram_api::messages_reorderPinnedSavedDialogs(flags, true /*ignored*/, std::move(order))));
|
||||
}
|
||||
|
||||
void on_result(BufferSlice packet) final {
|
||||
auto result_ptr = fetch_result<telegram_api::messages_reorderPinnedSavedDialogs>(packet);
|
||||
if (result_ptr.is_error()) {
|
||||
return on_error(result_ptr.move_as_error());
|
||||
}
|
||||
|
||||
bool result = result_ptr.move_as_ok();
|
||||
if (!result) {
|
||||
return on_error(Status::Error(400, "Result is false"));
|
||||
}
|
||||
td_->saved_messages_manager_->on_update_pinned_saved_messages_topics();
|
||||
promise_.set_value(Unit());
|
||||
}
|
||||
|
||||
void on_error(Status status) final {
|
||||
promise_.set_error(std::move(status));
|
||||
}
|
||||
};
|
||||
|
||||
SavedMessagesManager::SavedMessagesManager(Td *td, ActorShared<> parent) : td_(td), parent_(std::move(parent)) {
|
||||
}
|
||||
|
||||
@ -15,4 +326,267 @@ void SavedMessagesManager::tear_down() {
|
||||
parent_.reset();
|
||||
}
|
||||
|
||||
void SavedMessagesManager::get_pinned_saved_messages_topics(
|
||||
Promise<td_api::object_ptr<td_api::foundSavedMessagesTopics>> &&promise) {
|
||||
td_->create_handler<GetPinnedSavedDialogsQuery>(std::move(promise))->send();
|
||||
}
|
||||
|
||||
void SavedMessagesManager::get_saved_messages_topics(
|
||||
const string &offset, int32 limit, Promise<td_api::object_ptr<td_api::foundSavedMessagesTopics>> &&promise) {
|
||||
int32 offset_date = std::numeric_limits<int32>::max();
|
||||
DialogId offset_dialog_id;
|
||||
MessageId offset_message_id;
|
||||
bool is_offset_valid = [&] {
|
||||
if (offset.empty()) {
|
||||
return true;
|
||||
}
|
||||
|
||||
auto parts = full_split(offset, ',');
|
||||
if (parts.size() != 3) {
|
||||
return false;
|
||||
}
|
||||
auto r_offset_date = to_integer_safe<int32>(parts[0]);
|
||||
auto r_offset_dialog_id = to_integer_safe<int64>(parts[1]);
|
||||
auto r_offset_message_id = to_integer_safe<int32>(parts[2]);
|
||||
if (r_offset_date.is_error() || r_offset_date.ok() <= 0 || r_offset_message_id.is_error() ||
|
||||
r_offset_dialog_id.is_error()) {
|
||||
return false;
|
||||
}
|
||||
offset_date = r_offset_date.ok();
|
||||
offset_message_id = MessageId(ServerMessageId(r_offset_message_id.ok()));
|
||||
offset_dialog_id = DialogId(r_offset_dialog_id.ok());
|
||||
if (!offset_message_id.is_valid() || !offset_dialog_id.is_valid() ||
|
||||
DialogManager::get_input_peer_force(offset_dialog_id)->get_id() == telegram_api::inputPeerEmpty::ID) {
|
||||
return false;
|
||||
}
|
||||
return true;
|
||||
}();
|
||||
if (!is_offset_valid) {
|
||||
return promise.set_error(Status::Error(400, "Invalid offset specified"));
|
||||
}
|
||||
|
||||
if (limit < 0) {
|
||||
return promise.set_error(Status::Error(400, "Limit must be non-negative"));
|
||||
}
|
||||
|
||||
td_->create_handler<GetSavedDialogsQuery>(std::move(promise))
|
||||
->send(offset_date, offset_message_id, offset_dialog_id, limit);
|
||||
}
|
||||
|
||||
void SavedMessagesManager::on_get_saved_messages_topics(
|
||||
telegram_api::object_ptr<telegram_api::messages_SavedDialogs> &&saved_dialogs_ptr,
|
||||
Promise<td_api::object_ptr<td_api::foundSavedMessagesTopics>> &&promise) {
|
||||
CHECK(saved_dialogs_ptr != nullptr);
|
||||
int32 total_count = -1;
|
||||
vector<telegram_api::object_ptr<telegram_api::savedDialog>> dialogs;
|
||||
vector<telegram_api::object_ptr<telegram_api::Message>> messages;
|
||||
vector<telegram_api::object_ptr<telegram_api::Chat>> chats;
|
||||
vector<telegram_api::object_ptr<telegram_api::User>> users;
|
||||
bool is_last = false;
|
||||
switch (saved_dialogs_ptr->get_id()) {
|
||||
case telegram_api::messages_savedDialogsNotModified::ID:
|
||||
LOG(ERROR) << "Receive messages.savedDialogsNotModified";
|
||||
return promise.set_error(Status::Error(500, "Receive messages.savedDialogsNotModified"));
|
||||
case telegram_api::messages_savedDialogs::ID: {
|
||||
auto saved_dialogs = telegram_api::move_object_as<telegram_api::messages_savedDialogs>(saved_dialogs_ptr);
|
||||
total_count = static_cast<int32>(saved_dialogs->dialogs_.size());
|
||||
dialogs = std::move(saved_dialogs->dialogs_);
|
||||
messages = std::move(saved_dialogs->messages_);
|
||||
chats = std::move(saved_dialogs->chats_);
|
||||
users = std::move(saved_dialogs->users_);
|
||||
is_last = true;
|
||||
break;
|
||||
}
|
||||
case telegram_api::messages_savedDialogsSlice::ID: {
|
||||
auto saved_dialogs = telegram_api::move_object_as<telegram_api::messages_savedDialogsSlice>(saved_dialogs_ptr);
|
||||
total_count = saved_dialogs->count_;
|
||||
if (total_count < static_cast<int32>(saved_dialogs->dialogs_.size())) {
|
||||
LOG(ERROR) << "Receive total_count = " << total_count << ", but " << saved_dialogs->dialogs_.size()
|
||||
<< " Saved Messages topics";
|
||||
total_count = static_cast<int32>(saved_dialogs->dialogs_.size());
|
||||
}
|
||||
dialogs = std::move(saved_dialogs->dialogs_);
|
||||
messages = std::move(saved_dialogs->messages_);
|
||||
chats = std::move(saved_dialogs->chats_);
|
||||
users = std::move(saved_dialogs->users_);
|
||||
break;
|
||||
}
|
||||
default:
|
||||
UNREACHABLE();
|
||||
}
|
||||
td_->contacts_manager_->on_get_users(std::move(users), "on_get_saved_messages_topics");
|
||||
td_->contacts_manager_->on_get_chats(std::move(chats), "on_get_saved_messages_topics");
|
||||
|
||||
FlatHashMap<MessageId, telegram_api::object_ptr<telegram_api::Message>, MessageIdHash> message_id_to_message;
|
||||
for (auto &message : messages) {
|
||||
auto message_id = MessageId::get_message_id(message, false);
|
||||
if (!message_id.is_valid()) {
|
||||
continue;
|
||||
}
|
||||
message_id_to_message[message_id] = std::move(message);
|
||||
}
|
||||
|
||||
int32 last_message_date = 0;
|
||||
MessageId last_message_id;
|
||||
DialogId last_dialog_id;
|
||||
vector<SavedMessagesTopicId> added_saved_messages_topic_ids;
|
||||
vector<td_api::object_ptr<td_api::foundSavedMessagesTopic>> found_saved_messages_topics;
|
||||
for (auto &dialog : dialogs) {
|
||||
auto peer_dialog_id = DialogId(dialog->peer_);
|
||||
if (!peer_dialog_id.is_valid()) {
|
||||
LOG(ERROR) << "Receive " << peer_dialog_id << " in result of getSavedMessagesTopics";
|
||||
total_count--;
|
||||
continue;
|
||||
}
|
||||
SavedMessagesTopicId saved_messages_topic_id(peer_dialog_id);
|
||||
if (td::contains(added_saved_messages_topic_ids, saved_messages_topic_id)) {
|
||||
LOG(ERROR) << "Receive " << saved_messages_topic_id
|
||||
<< " twice in result of getSavedMessagesTopics with total_count = " << total_count;
|
||||
total_count--;
|
||||
continue;
|
||||
}
|
||||
added_saved_messages_topic_ids.push_back(saved_messages_topic_id);
|
||||
|
||||
MessageId last_topic_message_id(ServerMessageId(dialog->top_message_));
|
||||
if (!last_topic_message_id.is_valid()) {
|
||||
// skip topics without messages
|
||||
LOG(ERROR) << "Receive " << saved_messages_topic_id << " without last message";
|
||||
total_count--;
|
||||
continue;
|
||||
}
|
||||
|
||||
auto it = message_id_to_message.find(last_topic_message_id);
|
||||
if (it == message_id_to_message.end()) {
|
||||
LOG(ERROR) << "Can't find last " << last_topic_message_id << " in " << saved_messages_topic_id;
|
||||
total_count--;
|
||||
continue;
|
||||
}
|
||||
auto message_date = MessagesManager::get_message_date(it->second);
|
||||
if (message_date > 0) {
|
||||
last_message_date = message_date;
|
||||
last_message_id = last_topic_message_id;
|
||||
last_dialog_id = peer_dialog_id;
|
||||
}
|
||||
auto full_message_id = td_->messages_manager_->on_get_message(std::move(it->second), false, false, false,
|
||||
"on_get_saved_messages_topics");
|
||||
message_id_to_message.erase(it);
|
||||
|
||||
if (full_message_id.get_dialog_id() != DialogId() &&
|
||||
full_message_id.get_dialog_id() != td_->dialog_manager_->get_my_dialog_id()) {
|
||||
LOG(ERROR) << "Can't add last " << last_message_id << " to " << saved_messages_topic_id;
|
||||
total_count--;
|
||||
continue;
|
||||
}
|
||||
found_saved_messages_topics.push_back(td_api::make_object<td_api::foundSavedMessagesTopic>(
|
||||
saved_messages_topic_id.get_saved_messages_topic_object(td_),
|
||||
td_->messages_manager_->get_message_object(full_message_id, "on_get_saved_messages_topics")));
|
||||
}
|
||||
string next_offset;
|
||||
if (last_message_date > 0 && !is_last) {
|
||||
next_offset = PSTRING() << last_message_date << ',' << last_dialog_id.get() << ','
|
||||
<< last_message_id.get_server_message_id().get();
|
||||
}
|
||||
promise.set_value(td_api::make_object<td_api::foundSavedMessagesTopics>(
|
||||
total_count, std::move(found_saved_messages_topics), next_offset));
|
||||
}
|
||||
|
||||
void SavedMessagesManager::get_saved_messages_topic_history(SavedMessagesTopicId saved_messages_topic_id,
|
||||
MessageId from_message_id, int32 offset, int32 limit,
|
||||
Promise<td_api::object_ptr<td_api::messages>> &&promise) {
|
||||
if (limit <= 0) {
|
||||
return promise.set_error(Status::Error(400, "Parameter limit must be positive"));
|
||||
}
|
||||
if (limit > MAX_GET_HISTORY) {
|
||||
limit = MAX_GET_HISTORY;
|
||||
}
|
||||
if (offset > 0) {
|
||||
return promise.set_error(Status::Error(400, "Parameter offset must be non-positive"));
|
||||
}
|
||||
if (offset <= -MAX_GET_HISTORY) {
|
||||
return promise.set_error(Status::Error(400, "Parameter offset must be greater than -100"));
|
||||
}
|
||||
if (offset < -limit) {
|
||||
return promise.set_error(Status::Error(400, "Parameter offset must be greater than or equal to -limit"));
|
||||
}
|
||||
|
||||
TRY_STATUS_PROMISE(promise, saved_messages_topic_id.is_valid_status(td_));
|
||||
|
||||
if (from_message_id == MessageId() || from_message_id.get() > MessageId::max().get()) {
|
||||
from_message_id = MessageId::max();
|
||||
}
|
||||
if (!from_message_id.is_valid() || !from_message_id.is_server()) {
|
||||
return promise.set_error(Status::Error(400, "Invalid value of parameter from_message_id specified"));
|
||||
}
|
||||
|
||||
td_->create_handler<GetSavedHistoryQuery>(std::move(promise))
|
||||
->send(saved_messages_topic_id, from_message_id, offset, limit);
|
||||
}
|
||||
|
||||
void SavedMessagesManager::delete_saved_messages_topic_history(SavedMessagesTopicId saved_messages_topic_id,
|
||||
Promise<Unit> &&promise) {
|
||||
TRY_STATUS_PROMISE(promise, saved_messages_topic_id.is_valid_status(td_));
|
||||
|
||||
MessagesManager::AffectedHistoryQuery query = [td = td_, saved_messages_topic_id](
|
||||
DialogId, Promise<AffectedHistory> &&query_promise) {
|
||||
td->create_handler<DeleteSavedHistoryQuery>(std::move(query_promise))->send(saved_messages_topic_id);
|
||||
};
|
||||
auto my_dialog_id = td_->dialog_manager_->get_my_dialog_id();
|
||||
td_->messages_manager_->run_affected_history_query_until_complete(my_dialog_id, std::move(query), true,
|
||||
std::move(promise));
|
||||
}
|
||||
|
||||
void SavedMessagesManager::get_saved_messages_topic_message_by_date(
|
||||
SavedMessagesTopicId saved_messages_topic_id, int32 date, Promise<td_api::object_ptr<td_api::message>> &&promise) {
|
||||
TRY_STATUS_PROMISE(promise, saved_messages_topic_id.is_valid_status(td_));
|
||||
|
||||
if (date <= 0) {
|
||||
date = 1;
|
||||
}
|
||||
|
||||
td_->create_handler<GetSavedMessageByDateQuery>(std::move(promise))->send(saved_messages_topic_id, date);
|
||||
}
|
||||
|
||||
void SavedMessagesManager::delete_saved_messages_topic_messages_by_date(SavedMessagesTopicId saved_messages_topic_id,
|
||||
int32 min_date, int32 max_date,
|
||||
Promise<Unit> &&promise) {
|
||||
TRY_STATUS_PROMISE(promise, saved_messages_topic_id.is_valid_status(td_));
|
||||
|
||||
TRY_STATUS_PROMISE(promise, MessagesManager::fix_delete_message_min_max_dates(min_date, max_date));
|
||||
if (max_date == 0) {
|
||||
return promise.set_value(Unit());
|
||||
}
|
||||
|
||||
MessagesManager::AffectedHistoryQuery query = [td = td_, saved_messages_topic_id, min_date, max_date](
|
||||
DialogId, Promise<AffectedHistory> &&query_promise) {
|
||||
td->create_handler<DeleteSavedMessagesByDateQuery>(std::move(query_promise))
|
||||
->send(saved_messages_topic_id, min_date, max_date);
|
||||
};
|
||||
auto my_dialog_id = td_->dialog_manager_->get_my_dialog_id();
|
||||
td_->messages_manager_->run_affected_history_query_until_complete(my_dialog_id, std::move(query), true,
|
||||
std::move(promise));
|
||||
}
|
||||
|
||||
void SavedMessagesManager::toggle_saved_messages_topic_is_pinned(SavedMessagesTopicId saved_messages_topic_id,
|
||||
bool is_pinned, Promise<Unit> &&promise) {
|
||||
TRY_STATUS_PROMISE(promise, saved_messages_topic_id.is_valid_status(td_));
|
||||
td_->create_handler<ToggleSavedDialogPinQuery>(std::move(promise))->send(saved_messages_topic_id, is_pinned);
|
||||
}
|
||||
|
||||
void SavedMessagesManager::set_pinned_saved_messages_topics(vector<SavedMessagesTopicId> saved_messages_topic_ids,
|
||||
Promise<Unit> &&promise) {
|
||||
for (const auto &saved_messages_topic_id : saved_messages_topic_ids) {
|
||||
TRY_STATUS_PROMISE(promise, saved_messages_topic_id.is_valid_status(td_));
|
||||
}
|
||||
td_->create_handler<ReorderPinnedSavedDialogsQuery>(std::move(promise))->send(std::move(saved_messages_topic_ids));
|
||||
}
|
||||
|
||||
void SavedMessagesManager::on_update_pinned_saved_messages_topics() {
|
||||
if (td_->auth_manager_->is_bot()) {
|
||||
// just in case
|
||||
return;
|
||||
}
|
||||
|
||||
send_closure(G()->td(), &Td::send_update, td_api::make_object<td_api::updatePinnedSavedMessagesTopics>());
|
||||
}
|
||||
|
||||
} // namespace td
|
||||
|
||||
@ -6,9 +6,14 @@
|
||||
//
|
||||
#pragma once
|
||||
|
||||
#include "td/telegram/MessageId.h"
|
||||
#include "td/telegram/SavedMessagesTopicId.h"
|
||||
#include "td/telegram/td_api.h"
|
||||
|
||||
#include "td/actor/actor.h"
|
||||
|
||||
#include "td/utils/common.h"
|
||||
#include "td/utils/Promise.h"
|
||||
|
||||
namespace td {
|
||||
|
||||
@ -18,7 +23,36 @@ class SavedMessagesManager final : public Actor {
|
||||
public:
|
||||
SavedMessagesManager(Td *td, ActorShared<> parent);
|
||||
|
||||
void get_pinned_saved_messages_topics(Promise<td_api::object_ptr<td_api::foundSavedMessagesTopics>> &&promise);
|
||||
|
||||
void get_saved_messages_topics(const string &offset, int32 limit,
|
||||
Promise<td_api::object_ptr<td_api::foundSavedMessagesTopics>> &&promise);
|
||||
|
||||
void on_get_saved_messages_topics(telegram_api::object_ptr<telegram_api::messages_SavedDialogs> &&saved_dialogs_ptr,
|
||||
Promise<td_api::object_ptr<td_api::foundSavedMessagesTopics>> &&promise);
|
||||
|
||||
void get_saved_messages_topic_history(SavedMessagesTopicId saved_messages_topic_id, MessageId from_message_id,
|
||||
int32 offset, int32 limit,
|
||||
Promise<td_api::object_ptr<td_api::messages>> &&promise);
|
||||
|
||||
void delete_saved_messages_topic_history(SavedMessagesTopicId saved_messages_topic_id, Promise<Unit> &&promise);
|
||||
|
||||
void get_saved_messages_topic_message_by_date(SavedMessagesTopicId saved_messages_topic_id, int32 date,
|
||||
Promise<td_api::object_ptr<td_api::message>> &&promise);
|
||||
|
||||
void delete_saved_messages_topic_messages_by_date(SavedMessagesTopicId saved_messages_topic_id, int32 min_date,
|
||||
int32 max_date, Promise<Unit> &&promise);
|
||||
|
||||
void toggle_saved_messages_topic_is_pinned(SavedMessagesTopicId saved_messages_topic_id, bool is_pinned,
|
||||
Promise<Unit> &&promise);
|
||||
|
||||
void set_pinned_saved_messages_topics(vector<SavedMessagesTopicId> saved_messages_topic_ids, Promise<Unit> &&promise);
|
||||
|
||||
void on_update_pinned_saved_messages_topics();
|
||||
|
||||
private:
|
||||
static constexpr int32 MAX_GET_HISTORY = 100; // server side limit
|
||||
|
||||
void tear_down() final;
|
||||
|
||||
Td *td_;
|
||||
|
||||
@ -5058,42 +5058,42 @@ void Td::on_request(uint64 id, const td_api::getChats &request) {
|
||||
void Td::on_request(uint64 id, const td_api::getPinnedSavedMessagesTopics &request) {
|
||||
CHECK_IS_USER();
|
||||
CREATE_REQUEST_PROMISE();
|
||||
messages_manager_->get_pinned_saved_messages_topics(std::move(promise));
|
||||
saved_messages_manager_->get_pinned_saved_messages_topics(std::move(promise));
|
||||
}
|
||||
|
||||
void Td::on_request(uint64 id, const td_api::getSavedMessagesTopics &request) {
|
||||
CHECK_IS_USER();
|
||||
// don't need to check offset UTF-8 correctness
|
||||
CREATE_REQUEST_PROMISE();
|
||||
messages_manager_->get_saved_messages_topics(request.offset_, request.limit_, std::move(promise));
|
||||
saved_messages_manager_->get_saved_messages_topics(request.offset_, request.limit_, std::move(promise));
|
||||
}
|
||||
|
||||
void Td::on_request(uint64 id, const td_api::getSavedMessagesTopicHistory &request) {
|
||||
CHECK_IS_USER();
|
||||
CREATE_REQUEST_PROMISE();
|
||||
messages_manager_->get_saved_messages_topic_history(SavedMessagesTopicId(this, request.saved_messages_topic_),
|
||||
MessageId(request.from_message_id_), request.offset_,
|
||||
request.limit_, std::move(promise));
|
||||
saved_messages_manager_->get_saved_messages_topic_history(SavedMessagesTopicId(this, request.saved_messages_topic_),
|
||||
MessageId(request.from_message_id_), request.offset_,
|
||||
request.limit_, std::move(promise));
|
||||
}
|
||||
|
||||
void Td::on_request(uint64 id, const td_api::getSavedMessagesTopicMessageByDate &request) {
|
||||
CHECK_IS_USER();
|
||||
CREATE_REQUEST_PROMISE();
|
||||
messages_manager_->get_saved_messages_topic_message_by_date(SavedMessagesTopicId(this, request.saved_messages_topic_),
|
||||
request.date_, std::move(promise));
|
||||
saved_messages_manager_->get_saved_messages_topic_message_by_date(
|
||||
SavedMessagesTopicId(this, request.saved_messages_topic_), request.date_, std::move(promise));
|
||||
}
|
||||
|
||||
void Td::on_request(uint64 id, const td_api::deleteSavedMessagesTopicHistory &request) {
|
||||
CHECK_IS_USER();
|
||||
CREATE_OK_REQUEST_PROMISE();
|
||||
messages_manager_->delete_saved_messages_topic_history(SavedMessagesTopicId(this, request.saved_messages_topic_),
|
||||
std::move(promise));
|
||||
saved_messages_manager_->delete_saved_messages_topic_history(
|
||||
SavedMessagesTopicId(this, request.saved_messages_topic_), std::move(promise));
|
||||
}
|
||||
|
||||
void Td::on_request(uint64 id, const td_api::deleteSavedMessagesTopicMessagesByDate &request) {
|
||||
CHECK_IS_USER();
|
||||
CREATE_OK_REQUEST_PROMISE();
|
||||
messages_manager_->delete_saved_messages_topic_messages_by_date(
|
||||
saved_messages_manager_->delete_saved_messages_topic_messages_by_date(
|
||||
SavedMessagesTopicId(this, request.saved_messages_topic_), request.min_date_, request.max_date_,
|
||||
std::move(promise));
|
||||
}
|
||||
@ -5101,8 +5101,8 @@ void Td::on_request(uint64 id, const td_api::deleteSavedMessagesTopicMessagesByD
|
||||
void Td::on_request(uint64 id, const td_api::toggleSavedMessagesTopicIsPinned &request) {
|
||||
CHECK_IS_USER();
|
||||
CREATE_OK_REQUEST_PROMISE();
|
||||
messages_manager_->toggle_saved_messages_topic_is_pinned(SavedMessagesTopicId(this, request.saved_messages_topic_),
|
||||
request.is_pinned_, std::move(promise));
|
||||
saved_messages_manager_->toggle_saved_messages_topic_is_pinned(
|
||||
SavedMessagesTopicId(this, request.saved_messages_topic_), request.is_pinned_, std::move(promise));
|
||||
}
|
||||
|
||||
void Td::on_request(uint64 id, const td_api::setPinnedSavedMessagesTopics &request) {
|
||||
@ -5110,7 +5110,7 @@ void Td::on_request(uint64 id, const td_api::setPinnedSavedMessagesTopics &reque
|
||||
CREATE_OK_REQUEST_PROMISE();
|
||||
auto saved_messages_topic_ids = transform(request.saved_messages_topics_,
|
||||
[this](const auto &topic) { return SavedMessagesTopicId(this, topic); });
|
||||
messages_manager_->set_pinned_saved_messages_topics(std::move(saved_messages_topic_ids), std::move(promise));
|
||||
saved_messages_manager_->set_pinned_saved_messages_topics(std::move(saved_messages_topic_ids), std::move(promise));
|
||||
}
|
||||
|
||||
void Td::on_request(uint64 id, td_api::searchPublicChat &request) {
|
||||
|
||||
@ -55,6 +55,7 @@
|
||||
#include "td/telegram/ReactionListType.h"
|
||||
#include "td/telegram/ReactionManager.h"
|
||||
#include "td/telegram/ReactionType.h"
|
||||
#include "td/telegram/SavedMessagesManager.h"
|
||||
#include "td/telegram/ScheduledServerMessageId.h"
|
||||
#include "td/telegram/SecretChatId.h"
|
||||
#include "td/telegram/SecretChatsManager.h"
|
||||
@ -4047,12 +4048,12 @@ void UpdatesManager::on_update(tl_object_ptr<telegram_api::updatePinnedDialogs>
|
||||
}
|
||||
|
||||
void UpdatesManager::on_update(tl_object_ptr<telegram_api::updateSavedDialogPinned> update, Promise<Unit> &&promise) {
|
||||
td_->messages_manager_->on_update_pinned_saved_messages_topics();
|
||||
td_->saved_messages_manager_->on_update_pinned_saved_messages_topics();
|
||||
promise.set_value(Unit());
|
||||
}
|
||||
|
||||
void UpdatesManager::on_update(tl_object_ptr<telegram_api::updatePinnedSavedDialogs> update, Promise<Unit> &&promise) {
|
||||
td_->messages_manager_->on_update_pinned_saved_messages_topics();
|
||||
td_->saved_messages_manager_->on_update_pinned_saved_messages_topics();
|
||||
promise.set_value(Unit());
|
||||
}
|
||||
|
||||
|
||||
Loading…
Reference in New Issue
Block a user