Process updateDeleteEphemeralMessages.

4 files changed, 25 insertions, 7 deletions

diff --git a/td/telegram/MessagesManager.cpp b/td/telegram/MessagesManager.cpp
index e129925cc..e521821e8 100644
--- a/td/telegram/MessagesManager.cpp
+++ b/td/telegram/MessagesManager.cpp
@@ -4250,6 +4250,21 @@ void MessagesManager::on_edited_ephemeral_message(telegram_api::object_ptr<teleg
   on_get_message(std::move(message_info), false, "on_edited_ephemeral_message");
 }
 
+void MessagesManager::on_delete_ephemeral_messages(DialogId dialog_id, vector<int32> ephemeral_message_ids) {
+  Dialog *d = get_dialog_force(dialog_id, "on_delete_ephemeral_messages");
+  if (d == nullptr) {
+    return;
+  }
+  vector<MessageId> message_ids;
+  for (auto ephemeral_message_id : ephemeral_message_ids) {
+    auto it = d->ephemeral_message_ids.find(ephemeral_message_id);
+    if (it != d->ephemeral_message_ids.end()) {
+      message_ids.push_back(it->second);
+    }
+  }
+  do_delete_dialog_messages(d, message_ids, false, "on_delete_ephemeral_messages");
+}
+
 MessagesManager::Dialog *MessagesManager::get_service_notifications_dialog() {
   UserId service_notifications_user_id = td_->user_manager_->add_service_notifications_user();
   DialogId service_notifications_dialog_id(service_notifications_user_id);
diff --git a/td/telegram/MessagesManager.h b/td/telegram/MessagesManager.h
index 0f7abd81b..ffa847c0f 100644
--- a/td/telegram/MessagesManager.h
+++ b/td/telegram/MessagesManager.h
@@ -317,6 +317,8 @@ class MessagesManager final : public Actor {
 
   void on_edited_ephemeral_message(telegram_api::object_ptr<telegram_api::ephemeralMessage> &&message);
 
+  void on_delete_ephemeral_messages(DialogId dialog_id, vector<int32> ephemeral_message_ids);
+
   void on_update_service_notification(tl_object_ptr<telegram_api::updateServiceNotification> &&update,
                                       bool skip_new_entities, Promise<Unit> &&promise);
 
diff --git a/td/telegram/UpdatesManager.cpp b/td/telegram/UpdatesManager.cpp
index 4ba766a2d..6e883d94a 100644
--- a/td/telegram/UpdatesManager.cpp
+++ b/td/telegram/UpdatesManager.cpp
@@ -3722,6 +3722,12 @@ void UpdatesManager::on_update(tl_object_ptr<telegram_api::updateEditEphemeralMe
   promise.set_value(Unit());
 }
 
+void UpdatesManager::on_update(tl_object_ptr<telegram_api::updateDeleteEphemeralMessages> update,
+                               Promise<Unit> &&promise) {
+  td_->messages_manager_->on_delete_ephemeral_messages(DialogId(update->peer_), std::move(update->ids_));
+  promise.set_value(Unit());
+}
+
 void UpdatesManager::on_update(tl_object_ptr<telegram_api::updateReadHistoryInbox> update, Promise<Unit> &&promise) {
   int new_pts = update->pts_;
   int pts_count = update->pts_count_;
@@ -5043,11 +5049,6 @@ void UpdatesManager::on_update(tl_object_ptr<telegram_api::updateNewStoryReactio
   promise.set_value(Unit());
 }
 
-void UpdatesManager::on_update(tl_object_ptr<telegram_api::updateDeleteEphemeralMessages> update,
-                               Promise<Unit> &&promise) {
-  promise.set_value(Unit());
-}
-
 void UpdatesManager::on_update(tl_object_ptr<telegram_api::updateEphemeralBotCallbackQuery> update,
                                Promise<Unit> &&promise) {
   promise.set_value(Unit());
diff --git a/td/telegram/UpdatesManager.h b/td/telegram/UpdatesManager.h
index 023152544..c9cb62d25 100644
--- a/td/telegram/UpdatesManager.h
+++ b/td/telegram/UpdatesManager.h
@@ -520,6 +520,8 @@ class UpdatesManager final : public Actor {
 
   void on_update(tl_object_ptr<telegram_api::updateEditEphemeralMessage> update, Promise<Unit> &&promise);
 
+  void on_update(tl_object_ptr<telegram_api::updateDeleteEphemeralMessages> update, Promise<Unit> &&promise);
+
   void on_update(tl_object_ptr<telegram_api::updateReadHistoryInbox> update, Promise<Unit> &&promise);
 
   void on_update(tl_object_ptr<telegram_api::updateReadHistoryOutbox> update, Promise<Unit> &&promise);
@@ -778,8 +780,6 @@ class UpdatesManager final : public Actor {
 
   void on_update(tl_object_ptr<telegram_api::updateNewStoryReaction> update, Promise<Unit> &&promise);
 
-  void on_update(tl_object_ptr<telegram_api::updateDeleteEphemeralMessages> update, Promise<Unit> &&promise);
-
   void on_update(tl_object_ptr<telegram_api::updateEphemeralBotCallbackQuery> update, Promise<Unit> &&promise);
 };