tdlight/td/telegram/WebPagesManager.h

204 lines
7.7 KiB
C
Raw Normal View History

//
2022-12-31 22:28:08 +01:00
// Copyright Aliaksei Levin (levlam@telegram.org), Arseny Smirnov (arseny30@gmail.com) 2014-2023
//
// Distributed under the Boost Software License, Version 1.0. (See accompanying
// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
//
#pragma once
#include "td/telegram/DialogId.h"
#include "td/telegram/files/FileId.h"
#include "td/telegram/files/FileSourceId.h"
2023-09-21 18:11:17 +02:00
#include "td/telegram/MessageFullId.h"
#include "td/telegram/SecretInputMedia.h"
#include "td/telegram/StoryFullId.h"
2021-10-27 16:32:09 +02:00
#include "td/telegram/td_api.h"
#include "td/telegram/telegram_api.h"
2023-07-01 15:22:01 +02:00
#include "td/telegram/UserId.h"
#include "td/telegram/WebPageId.h"
#include "td/actor/actor.h"
2022-07-02 22:32:18 +02:00
#include "td/actor/MultiTimeout.h"
#include "td/utils/common.h"
2022-02-07 22:04:34 +01:00
#include "td/utils/FlatHashMap.h"
2022-03-11 19:38:48 +01:00
#include "td/utils/FlatHashSet.h"
2022-06-27 12:30:18 +02:00
#include "td/utils/Promise.h"
2022-10-12 14:59:58 +02:00
#include "td/utils/Slice.h"
#include "td/utils/Status.h"
2022-08-04 13:48:10 +02:00
#include "td/utils/WaitFreeHashMap.h"
#include <utility>
namespace td {
struct BinlogEvent;
class Td;
class WebPagesManager final : public Actor {
public:
WebPagesManager(Td *td, ActorShared<> parent);
WebPagesManager(const WebPagesManager &) = delete;
WebPagesManager &operator=(const WebPagesManager &) = delete;
WebPagesManager(WebPagesManager &&) = delete;
WebPagesManager &operator=(WebPagesManager &&) = delete;
2021-07-03 22:51:36 +02:00
~WebPagesManager() final;
2023-10-16 18:37:40 +02:00
static string get_web_page_url(const tl_object_ptr<telegram_api::WebPage> &web_page_ptr);
WebPageId on_get_web_page(tl_object_ptr<telegram_api::WebPage> &&web_page_ptr, DialogId owner_dialog_id);
void on_get_web_page_by_url(const string &url, WebPageId web_page_id, bool from_database);
void on_get_web_page_instant_view_view_count(WebPageId web_page_id, int32 view_count);
2023-09-21 18:11:17 +02:00
void register_web_page(WebPageId web_page_id, MessageFullId message_full_id, const char *source);
2023-09-21 18:11:17 +02:00
void unregister_web_page(WebPageId web_page_id, MessageFullId message_full_id, const char *source);
bool have_web_page(WebPageId web_page_id) const;
bool have_web_page_force(WebPageId web_page_id);
2023-10-16 16:36:45 +02:00
tl_object_ptr<td_api::webPage> get_web_page_object(WebPageId web_page_id, bool force_small_media,
2023-10-19 12:03:27 +02:00
bool force_large_media, bool skip_confirmation) const;
tl_object_ptr<td_api::webPageInstantView> get_web_page_instant_view_object(WebPageId web_page_id) const;
void get_web_page_preview(td_api::object_ptr<td_api::formattedText> &&text,
Promise<td_api::object_ptr<td_api::webPage>> &&promise);
void get_web_page_instant_view(const string &url, bool force_full, Promise<WebPageId> &&promise);
string get_web_page_url(WebPageId web_page_id) const;
WebPageId get_web_page_by_url(const string &url) const;
2021-10-07 11:49:46 +02:00
void get_web_page_by_url(const string &url, Promise<WebPageId> &&promise);
2021-10-07 11:49:46 +02:00
void reload_web_page_by_url(const string &url, Promise<WebPageId> &&promise);
2023-10-16 20:18:41 +02:00
void on_get_web_page_preview(const string &first_url, tl_object_ptr<telegram_api::MessageMedia> &&message_media_ptr,
Promise<td_api::object_ptr<td_api::webPage>> &&promise);
void on_binlog_web_page_event(BinlogEvent &&event);
FileSourceId get_url_file_source_id(const string &url);
string get_web_page_search_text(WebPageId web_page_id) const;
int32 get_web_page_media_duration(WebPageId web_page_id) const;
2023-06-22 21:39:47 +02:00
StoryFullId get_web_page_story_full_id(WebPageId web_page_id) const;
vector<UserId> get_web_page_user_ids(WebPageId web_page_id) const;
void on_story_changed(StoryFullId story_full_id);
private:
class WebPage;
class WebPageInstantView;
class WebPageLogEvent;
void update_web_page(unique_ptr<WebPage> web_page, WebPageId web_page_id, bool from_binlog, bool from_database);
void update_web_page_instant_view(WebPageId web_page_id, WebPageInstantView &new_instant_view,
WebPageInstantView &&old_instant_view);
static bool need_use_old_instant_view(const WebPageInstantView &new_instant_view,
const WebPageInstantView &old_instant_view);
void on_web_page_changed(WebPageId web_page_id, bool have_web_page);
const WebPage *get_web_page(WebPageId web_page_id) const;
const WebPageInstantView *get_web_page_instant_view(WebPageId web_page_id) const;
void get_web_page_instant_view_impl(WebPageId web_page_id, bool force_full, Promise<WebPageId> &&promise);
tl_object_ptr<td_api::webPageInstantView> get_web_page_instant_view_object(
WebPageId web_page_id, const WebPageInstantView *web_page_instant_view, Slice web_page_url) const;
static void on_pending_web_page_timeout_callback(void *web_pages_manager_ptr, int64 web_page_id_int);
void on_pending_web_page_timeout(WebPageId web_page_id);
2023-10-16 20:18:41 +02:00
void on_get_web_page_preview_success(const string &first_url, WebPageId web_page_id,
Promise<td_api::object_ptr<td_api::webPage>> &&promise);
void on_get_web_page_instant_view(WebPage *web_page, tl_object_ptr<telegram_api::page> &&page, int32 hash,
DialogId owner_dialog_id);
void save_web_page(const WebPage *web_page, WebPageId web_page_id, bool from_binlog);
static string get_web_page_database_key(WebPageId web_page_id);
void on_save_web_page_to_database(WebPageId web_page_id, bool success);
void load_web_page_from_database(WebPageId web_page_id, Promise<Unit> promise);
void on_load_web_page_from_database(WebPageId web_page_id, string value);
const WebPage *get_web_page_force(WebPageId web_page_id);
static string get_web_page_instant_view_database_key(WebPageId web_page_id);
2021-10-07 11:49:46 +02:00
void load_web_page_instant_view(WebPageId web_page_id, bool force_full, Promise<WebPageId> &&promise);
void on_load_web_page_instant_view_from_database(WebPageId web_page_id, string value);
void reload_web_page_instant_view(WebPageId web_page_id);
2021-10-07 11:49:46 +02:00
void update_web_page_instant_view_load_requests(WebPageId web_page_id, bool force_update,
Result<WebPageId> r_web_page_id);
static string get_web_page_url_database_key(const string &url);
2021-10-19 17:11:16 +02:00
void load_web_page_by_url(string url, Promise<WebPageId> &&promise);
2021-10-07 11:49:46 +02:00
void on_load_web_page_id_by_url_from_database(string url, string value, Promise<WebPageId> &&promise);
2021-10-07 11:49:46 +02:00
void on_load_web_page_by_url_from_database(WebPageId web_page_id, string url, Promise<WebPageId> &&promise,
Result<Unit> &&result);
2021-07-03 22:51:36 +02:00
void tear_down() final;
int32 get_web_page_media_duration(const WebPage *web_page) const;
FileSourceId get_web_page_file_source_id(WebPage *web_page);
vector<FileId> get_web_page_file_ids(const WebPage *web_page) const;
Td *td_;
ActorShared<> parent_;
2022-08-04 13:48:10 +02:00
WaitFreeHashMap<WebPageId, unique_ptr<WebPage>, WebPageIdHash> web_pages_;
FlatHashMap<WebPageId, vector<Promise<Unit>>, WebPageIdHash> load_web_page_from_database_queries_;
2022-03-11 19:38:48 +01:00
FlatHashSet<WebPageId, WebPageIdHash> loaded_from_database_web_pages_;
struct PendingWebPageInstantViewQueries {
2021-10-07 11:49:46 +02:00
vector<Promise<WebPageId>> partial;
vector<Promise<WebPageId>> full;
};
FlatHashMap<WebPageId, PendingWebPageInstantViewQueries, WebPageIdHash> load_web_page_instant_view_queries_;
2023-09-21 18:11:17 +02:00
FlatHashMap<WebPageId, FlatHashSet<MessageFullId, MessageFullIdHash>, WebPageIdHash> web_page_messages_;
FlatHashMap<WebPageId, vector<std::pair<string, Promise<td_api::object_ptr<td_api::webPage>>>>, WebPageIdHash>
pending_get_web_pages_;
FlatHashMap<StoryFullId, FlatHashSet<WebPageId, WebPageIdHash>, StoryFullIdHash> story_web_pages_;
FlatHashMap<string, std::pair<WebPageId, bool>> url_to_web_page_id_; // url -> [WebPageId, from_database]
FlatHashMap<string, FileSourceId> url_to_file_source_id_;
MultiTimeout pending_web_pages_timeout_{"PendingWebPagesTimeout"};
};
} // namespace td