mirror of
https://github.com/LadybirdBrowser/ladybird
synced 2026-04-25 17:25:08 +02:00
Route BroadcastChannel messages over IPC so matching channels can receive them across WebContent and WebWorker processes, rather than only within a single process. Each channel now serializes its payload, sends it upward over IPC, and receiving processes deliver it locally after matching by storage key and channel name.
1020 lines
34 KiB
C++
1020 lines
34 KiB
C++
/*
|
|
* Copyright (c) 2020-2023, Andreas Kling <andreas@ladybird.org>
|
|
* Copyright (c) 2021-2022, Linus Groh <linusg@serenityos.org>
|
|
* Copyright (c) 2023, Andrew Kaster <akaster@serenityos.org>
|
|
* Copyright (c) 2024, Sam Atkins <sam@ladybird.org>
|
|
*
|
|
* SPDX-License-Identifier: BSD-2-Clause
|
|
*/
|
|
|
|
#include <AK/JsonObjectSerializer.h>
|
|
#include <AK/JsonValue.h>
|
|
#include <LibCore/Timer.h>
|
|
#include <LibGfx/Bitmap.h>
|
|
#include <LibGfx/ShareableBitmap.h>
|
|
#include <LibHTTP/Cookie/ParsedCookie.h>
|
|
#include <LibIPC/TransportHandle.h>
|
|
#include <LibJS/Console.h>
|
|
#include <LibJS/Runtime/ConsoleObject.h>
|
|
#include <LibWeb/Bindings/MainThreadVM.h>
|
|
#include <LibWeb/CSS/CSSImportRule.h>
|
|
#include <LibWeb/CSS/StyleSheetList.h>
|
|
#include <LibWeb/DOM/CharacterData.h>
|
|
#include <LibWeb/DOM/Document.h>
|
|
#include <LibWeb/DOM/Element.h>
|
|
#include <LibWeb/DOM/MutationType.h>
|
|
#include <LibWeb/DOM/NodeList.h>
|
|
#include <LibWeb/HTML/BrowsingContext.h>
|
|
#include <LibWeb/HTML/HTMLLinkElement.h>
|
|
#include <LibWeb/HTML/Scripting/ClassicScript.h>
|
|
#include <LibWeb/HTML/TraversableNavigable.h>
|
|
#include <LibWeb/InvalidateDisplayList.h>
|
|
#include <LibWeb/Layout/Viewport.h>
|
|
#include <LibWeb/Painting/PaintableBox.h>
|
|
#include <LibWebView/SiteIsolation.h>
|
|
#include <LibWebView/ViewImplementation.h>
|
|
#include <WebContent/ConnectionFromClient.h>
|
|
#include <WebContent/DevToolsConsoleClient.h>
|
|
#include <WebContent/PageClient.h>
|
|
#include <WebContent/PageHost.h>
|
|
#include <WebContent/WebContentClientEndpoint.h>
|
|
#include <WebContent/WebDriverConnection.h>
|
|
#include <WebContent/WebUIConnection.h>
|
|
|
|
namespace WebContent {
|
|
|
|
static PageClient::UseSkiaPainter s_use_skia_painter = PageClient::UseSkiaPainter::GPUBackendIfAvailable;
|
|
static bool s_is_headless { false };
|
|
|
|
GC_DEFINE_ALLOCATOR(PageClient);
|
|
|
|
void PageClient::set_use_skia_painter(UseSkiaPainter use_skia_painter)
|
|
{
|
|
s_use_skia_painter = use_skia_painter;
|
|
}
|
|
|
|
bool PageClient::is_headless() const
|
|
{
|
|
return s_is_headless;
|
|
}
|
|
|
|
void PageClient::set_is_headless(bool is_headless)
|
|
{
|
|
s_is_headless = is_headless;
|
|
}
|
|
|
|
GC::Ref<PageClient> PageClient::create(JS::VM& vm, PageHost& page_host, u64 id)
|
|
{
|
|
return vm.heap().allocate<PageClient>(page_host, id);
|
|
}
|
|
|
|
PageClient::PageClient(PageHost& owner, u64 id)
|
|
: m_owner(owner)
|
|
, m_page(Web::Page::create(Web::Bindings::main_thread_vm(), *this))
|
|
, m_id(id)
|
|
{
|
|
setup_palette();
|
|
|
|
// FIXME: This removes the decimal part, so the refresh interval will actually be higher than the maximum FPS.
|
|
// For example, 60 FPS = 1000ms / 60 = 16.6666...ms, but it will become 16ms, making the interval equivalent
|
|
// to 62.5 FPS.
|
|
int refresh_interval = static_cast<int>(1000.0 / m_maximum_frames_per_second);
|
|
|
|
m_paint_refresh_timer = Core::Timer::create_repeating(refresh_interval, [] {
|
|
Web::HTML::main_thread_event_loop().queue_task_to_update_the_rendering();
|
|
});
|
|
|
|
m_paint_refresh_timer->start();
|
|
}
|
|
|
|
PageClient::~PageClient() = default;
|
|
|
|
void PageClient::visit_edges(JS::Cell::Visitor& visitor)
|
|
{
|
|
Base::visit_edges(visitor);
|
|
visitor.visit(m_page);
|
|
visitor.visit(m_top_level_document_console_client);
|
|
|
|
if (m_webdriver)
|
|
m_webdriver->visit_edges(visitor);
|
|
if (m_web_ui)
|
|
m_web_ui->visit_edges(visitor);
|
|
}
|
|
|
|
ConnectionFromClient& PageClient::client() const
|
|
{
|
|
return m_owner.client();
|
|
}
|
|
|
|
void PageClient::set_has_focus(bool has_focus)
|
|
{
|
|
m_has_focus = has_focus;
|
|
}
|
|
|
|
void PageClient::setup_palette()
|
|
{
|
|
// FIXME: Get the proper palette from our peer somehow
|
|
auto buffer_or_error = Core::AnonymousBuffer::create_with_size(sizeof(Gfx::SystemTheme));
|
|
VERIFY(!buffer_or_error.is_error());
|
|
auto buffer = buffer_or_error.release_value();
|
|
auto* theme = buffer.data<Gfx::SystemTheme>();
|
|
theme->color[to_underlying(Gfx::ColorRole::Window)] = Color(Color::Magenta).value();
|
|
theme->color[to_underlying(Gfx::ColorRole::WindowText)] = Color(Color::Cyan).value();
|
|
m_palette_impl = Gfx::PaletteImpl::create_with_anonymous_buffer(buffer);
|
|
}
|
|
|
|
bool PageClient::is_connection_open() const
|
|
{
|
|
return client().is_open();
|
|
}
|
|
|
|
bool PageClient::is_url_suitable_for_same_process_navigation(URL::URL const& current_url, URL::URL const& target_url) const
|
|
{
|
|
return WebView::is_url_suitable_for_same_process_navigation(current_url, target_url);
|
|
}
|
|
|
|
void PageClient::request_new_process_for_navigation(URL::URL const& url)
|
|
{
|
|
client().async_did_request_new_process_for_navigation(m_id, url);
|
|
}
|
|
|
|
Gfx::Palette PageClient::palette() const
|
|
{
|
|
return Gfx::Palette(*m_palette_impl);
|
|
}
|
|
|
|
void PageClient::set_palette_impl(Gfx::PaletteImpl& impl)
|
|
{
|
|
m_palette_impl = impl;
|
|
if (auto* document = page().top_level_browsing_context().active_document())
|
|
document->invalidate_style(Web::DOM::StyleInvalidationReason::SettingsChange);
|
|
}
|
|
|
|
void PageClient::set_preferred_color_scheme(Web::CSS::PreferredColorScheme color_scheme)
|
|
{
|
|
m_preferred_color_scheme = color_scheme;
|
|
if (auto* document = page().top_level_browsing_context().active_document()) {
|
|
document->invalidate_style(Web::DOM::StyleInvalidationReason::SettingsChange);
|
|
document->set_needs_media_query_evaluation();
|
|
}
|
|
}
|
|
|
|
void PageClient::set_preferred_contrast(Web::CSS::PreferredContrast contrast)
|
|
{
|
|
m_preferred_contrast = contrast;
|
|
if (auto* document = page().top_level_browsing_context().active_document()) {
|
|
document->invalidate_style(Web::DOM::StyleInvalidationReason::SettingsChange);
|
|
document->set_needs_media_query_evaluation();
|
|
}
|
|
}
|
|
|
|
void PageClient::set_preferred_motion(Web::CSS::PreferredMotion motion)
|
|
{
|
|
m_preferred_motion = motion;
|
|
if (auto* document = page().top_level_browsing_context().active_document()) {
|
|
document->invalidate_style(Web::DOM::StyleInvalidationReason::SettingsChange);
|
|
document->set_needs_media_query_evaluation();
|
|
}
|
|
}
|
|
|
|
void PageClient::set_is_scripting_enabled(bool is_scripting_enabled)
|
|
{
|
|
page().set_is_scripting_enabled(is_scripting_enabled);
|
|
}
|
|
|
|
void PageClient::set_window_position(Web::DevicePixelPoint position)
|
|
{
|
|
page().set_window_position(position);
|
|
}
|
|
|
|
void PageClient::set_window_size(Web::DevicePixelSize size)
|
|
{
|
|
page().set_window_size(size);
|
|
}
|
|
|
|
void PageClient::ready_to_paint()
|
|
{
|
|
page().top_level_traversable()->ready_to_paint();
|
|
}
|
|
|
|
Queue<Web::QueuedInputEvent>& PageClient::input_event_queue()
|
|
{
|
|
return client().input_event_queue();
|
|
}
|
|
|
|
void PageClient::report_finished_handling_input_event(u64 page_id, Web::EventResult event_was_handled)
|
|
{
|
|
client().async_did_finish_handling_input_event(page_id, event_was_handled);
|
|
}
|
|
|
|
void PageClient::set_viewport(Web::DevicePixelSize const& size, double device_pixel_ratio)
|
|
{
|
|
auto invalidate = m_device_pixel_ratio != device_pixel_ratio
|
|
? Web::InvalidateDisplayList::Yes
|
|
: Web::InvalidateDisplayList::No;
|
|
|
|
m_viewport_size = size;
|
|
m_device_pixel_ratio = device_pixel_ratio;
|
|
|
|
page().top_level_traversable()->set_viewport_size(page().device_to_css_size(size), invalidate);
|
|
}
|
|
|
|
void PageClient::set_zoom_level(double zoom_level)
|
|
{
|
|
m_zoom_level = zoom_level;
|
|
page().top_level_traversable()->set_viewport_size(page().device_to_css_size(m_viewport_size), Web::InvalidateDisplayList::Yes);
|
|
}
|
|
|
|
void PageClient::set_maximum_frames_per_second(u64 maximum_frames_per_second)
|
|
{
|
|
m_maximum_frames_per_second = maximum_frames_per_second;
|
|
|
|
// FIXME: This removes the decimal part, so the refresh interval will actually be higher than the maximum FPS.
|
|
// For example, 60 FPS = 1000ms / 60 = 16.6666...ms, but it will become 16ms, making the interval equivalent
|
|
// to 62.5 FPS.
|
|
int refresh_interval = static_cast<int>(1000.0 / m_maximum_frames_per_second);
|
|
|
|
VERIFY(m_paint_refresh_timer);
|
|
m_paint_refresh_timer->set_interval(refresh_interval);
|
|
}
|
|
|
|
void PageClient::page_did_request_cursor_change(Gfx::Cursor const& cursor)
|
|
{
|
|
client().async_did_request_cursor_change(m_id, cursor);
|
|
}
|
|
|
|
void PageClient::page_did_change_title(Utf16String const& title)
|
|
{
|
|
client().async_did_change_title(m_id, title);
|
|
}
|
|
|
|
void PageClient::page_did_change_url(URL::URL const& url)
|
|
{
|
|
client().async_did_change_url(m_id, url);
|
|
}
|
|
|
|
void PageClient::page_did_request_refresh()
|
|
{
|
|
client().async_did_request_refresh(m_id);
|
|
}
|
|
|
|
void PageClient::page_did_request_resize_window(Gfx::IntSize size)
|
|
{
|
|
client().async_did_request_resize_window(m_id, size);
|
|
}
|
|
|
|
void PageClient::page_did_request_reposition_window(Gfx::IntPoint position)
|
|
{
|
|
client().async_did_request_reposition_window(m_id, position);
|
|
}
|
|
|
|
void PageClient::page_did_request_restore_window()
|
|
{
|
|
client().async_did_request_restore_window(m_id);
|
|
}
|
|
|
|
void PageClient::page_did_request_maximize_window()
|
|
{
|
|
client().async_did_request_maximize_window(m_id);
|
|
}
|
|
|
|
void PageClient::page_did_request_minimize_window()
|
|
{
|
|
client().async_did_request_minimize_window(m_id);
|
|
}
|
|
|
|
void PageClient::page_did_request_fullscreen_window()
|
|
{
|
|
client().async_did_request_fullscreen_window(m_id);
|
|
}
|
|
|
|
void PageClient::page_did_request_exit_fullscreen()
|
|
{
|
|
client().async_did_request_exit_fullscreen(m_id);
|
|
}
|
|
|
|
void PageClient::page_did_request_tooltip_override(Web::CSSPixelPoint position, ByteString const& title)
|
|
{
|
|
auto device_position = page().css_to_device_point(position);
|
|
client().async_did_request_tooltip_override(m_id, { device_position.x(), device_position.y() }, title);
|
|
}
|
|
|
|
void PageClient::page_did_stop_tooltip_override()
|
|
{
|
|
client().async_did_leave_tooltip_area(m_id);
|
|
}
|
|
|
|
void PageClient::page_did_enter_tooltip_area(ByteString const& title)
|
|
{
|
|
client().async_did_enter_tooltip_area(m_id, title);
|
|
}
|
|
|
|
void PageClient::page_did_leave_tooltip_area()
|
|
{
|
|
client().async_did_leave_tooltip_area(m_id);
|
|
}
|
|
|
|
void PageClient::page_did_hover_link(URL::URL const& url)
|
|
{
|
|
client().async_did_hover_link(m_id, url);
|
|
}
|
|
|
|
void PageClient::page_did_unhover_link()
|
|
{
|
|
client().async_did_unhover_link(m_id);
|
|
}
|
|
|
|
void PageClient::page_did_click_link(URL::URL const& url, ByteString const& target, unsigned modifiers)
|
|
{
|
|
client().async_did_click_link(m_id, url, target, modifiers);
|
|
}
|
|
|
|
void PageClient::page_did_middle_click_link(URL::URL const& url, ByteString const& target, unsigned modifiers)
|
|
{
|
|
client().async_did_middle_click_link(m_id, url, target, modifiers);
|
|
}
|
|
|
|
void PageClient::page_did_start_loading(URL::URL const& url, bool is_redirect)
|
|
{
|
|
client().async_did_start_loading(m_id, url, is_redirect);
|
|
}
|
|
|
|
void PageClient::page_did_create_new_document(Web::DOM::Document& document)
|
|
{
|
|
initialize_js_console(document);
|
|
}
|
|
|
|
void PageClient::page_did_change_active_document_in_top_level_browsing_context(Web::DOM::Document& document)
|
|
{
|
|
auto& realm = document.realm();
|
|
|
|
m_web_ui.clear();
|
|
|
|
if (auto console_client = document.console_client()) {
|
|
auto& web_content_console_client = as<WebContentConsoleClient>(*console_client);
|
|
m_top_level_document_console_client = web_content_console_client;
|
|
|
|
auto console_object = realm.intrinsics().console_object();
|
|
console_object->console().set_client(*console_client);
|
|
}
|
|
}
|
|
|
|
void PageClient::page_did_finish_loading(URL::URL const& url)
|
|
{
|
|
client().async_did_finish_loading(m_id, url);
|
|
}
|
|
|
|
void PageClient::page_did_finish_test(String const& text)
|
|
{
|
|
client().async_did_finish_test(m_id, text);
|
|
}
|
|
|
|
void PageClient::page_did_set_test_timeout(double milliseconds)
|
|
{
|
|
client().async_did_set_test_timeout(m_id, milliseconds);
|
|
}
|
|
|
|
void PageClient::page_did_receive_reference_test_metadata(JsonValue metadata)
|
|
{
|
|
client().async_did_receive_reference_test_metadata(m_id, metadata);
|
|
}
|
|
|
|
void PageClient::page_did_receive_test_variant_metadata(JsonValue metadata)
|
|
{
|
|
client().async_did_receive_test_variant_metadata(m_id, metadata);
|
|
}
|
|
|
|
void PageClient::page_did_set_browser_zoom(double factor)
|
|
{
|
|
auto traversable = page().top_level_traversable();
|
|
traversable->set_pending_set_browser_zoom_request(true);
|
|
client().async_did_set_browser_zoom(m_id, factor);
|
|
auto& event_loop = Web::HTML::main_thread_event_loop();
|
|
event_loop.spin_until(GC::create_function(event_loop.heap(), [this, traversable]() {
|
|
return !traversable->pending_set_browser_zoom_request() || !is_connection_open();
|
|
}));
|
|
}
|
|
|
|
void PageClient::page_did_set_device_pixel_ratio_for_testing(double ratio)
|
|
{
|
|
set_viewport(m_viewport_size, ratio);
|
|
}
|
|
|
|
void PageClient::page_did_request_context_menu(Web::CSSPixelPoint content_position)
|
|
{
|
|
client().async_did_request_context_menu(m_id, page().css_to_device_point(content_position).to_type<int>());
|
|
}
|
|
|
|
void PageClient::page_did_request_link_context_menu(Web::CSSPixelPoint content_position, URL::URL const& url, ByteString const& target, unsigned modifiers)
|
|
{
|
|
client().async_did_request_link_context_menu(m_id, page().css_to_device_point(content_position).to_type<int>(), url, target, modifiers);
|
|
}
|
|
|
|
void PageClient::page_did_request_image_context_menu(Web::CSSPixelPoint content_position, URL::URL const& url, ByteString const& target, unsigned modifiers, Optional<Gfx::Bitmap const*> bitmap_pointer)
|
|
{
|
|
Optional<Gfx::ShareableBitmap> bitmap;
|
|
if (bitmap_pointer.has_value() && bitmap_pointer.value())
|
|
bitmap = bitmap_pointer.value()->to_shareable_bitmap();
|
|
|
|
client().async_did_request_image_context_menu(m_id, page().css_to_device_point(content_position).to_type<int>(), url, target, modifiers, bitmap);
|
|
}
|
|
|
|
void PageClient::page_did_request_media_context_menu(Web::CSSPixelPoint content_position, ByteString const& target, unsigned modifiers, Web::Page::MediaContextMenu const& menu)
|
|
{
|
|
client().async_did_request_media_context_menu(m_id, page().css_to_device_point(content_position).to_type<int>(), target, modifiers, menu);
|
|
}
|
|
|
|
void PageClient::page_did_request_alert(String const& message)
|
|
{
|
|
client().async_did_request_alert(m_id, message);
|
|
|
|
if (m_webdriver)
|
|
m_webdriver->page_did_open_dialog({});
|
|
}
|
|
|
|
void PageClient::alert_closed()
|
|
{
|
|
page().alert_closed();
|
|
}
|
|
|
|
void PageClient::page_did_request_confirm(String const& message)
|
|
{
|
|
client().async_did_request_confirm(m_id, message);
|
|
|
|
if (m_webdriver)
|
|
m_webdriver->page_did_open_dialog({});
|
|
}
|
|
|
|
void PageClient::confirm_closed(bool accepted)
|
|
{
|
|
page().confirm_closed(accepted);
|
|
}
|
|
|
|
void PageClient::page_did_request_prompt(String const& message, String const& default_)
|
|
{
|
|
client().async_did_request_prompt(m_id, message, default_);
|
|
|
|
if (m_webdriver)
|
|
m_webdriver->page_did_open_dialog({});
|
|
}
|
|
|
|
void PageClient::page_did_request_set_prompt_text(String const& text)
|
|
{
|
|
client().async_did_request_set_prompt_text(m_id, text);
|
|
}
|
|
|
|
void PageClient::prompt_closed(Optional<String> response)
|
|
{
|
|
page().prompt_closed(move(response));
|
|
}
|
|
|
|
void PageClient::color_picker_update(Optional<Color> picked_color, Web::HTML::ColorPickerUpdateState state)
|
|
{
|
|
page().color_picker_update(picked_color, state);
|
|
}
|
|
|
|
void PageClient::select_dropdown_closed(Optional<u32> const& selected_item_id)
|
|
{
|
|
page().select_dropdown_closed(selected_item_id);
|
|
}
|
|
|
|
void PageClient::toggle_media_play_state()
|
|
{
|
|
page().toggle_media_play_state();
|
|
}
|
|
|
|
void PageClient::toggle_media_mute_state()
|
|
{
|
|
page().toggle_media_mute_state();
|
|
}
|
|
|
|
void PageClient::toggle_media_loop_state()
|
|
{
|
|
page().toggle_media_loop_state();
|
|
}
|
|
|
|
void PageClient::toggle_media_controls_state()
|
|
{
|
|
page().toggle_media_controls_state();
|
|
}
|
|
|
|
void PageClient::set_user_style(String source)
|
|
{
|
|
page().set_user_style(source);
|
|
}
|
|
|
|
void PageClient::page_did_request_accept_dialog()
|
|
{
|
|
client().async_did_request_accept_dialog(m_id);
|
|
}
|
|
|
|
void PageClient::page_did_request_dismiss_dialog()
|
|
{
|
|
client().async_did_request_dismiss_dialog(m_id);
|
|
}
|
|
|
|
void PageClient::page_did_change_favicon(Gfx::Bitmap const& favicon)
|
|
{
|
|
client().async_did_change_favicon(m_id, favicon.to_shareable_bitmap());
|
|
}
|
|
|
|
Optional<Core::SharedVersion> PageClient::page_did_request_document_cookie_version(Core::SharedVersionIndex document_index)
|
|
{
|
|
return Core::get_shared_version(m_document_cookie_version_buffer, document_index);
|
|
}
|
|
|
|
void PageClient::page_did_receive_document_cookie_version_buffer(Core::AnonymousBuffer document_cookie_version_buffer)
|
|
{
|
|
m_document_cookie_version_buffer = move(document_cookie_version_buffer);
|
|
}
|
|
|
|
void PageClient::page_did_request_document_cookie_version_index(Web::UniqueNodeID document_id, String const& domain)
|
|
{
|
|
// FIXME: Support transferring DistinctNumeric over IPC.
|
|
client().async_did_request_document_cookie_version_index(m_id, document_id.value(), domain);
|
|
}
|
|
|
|
void PageClient::page_did_receive_document_cookie_version_index(Web::UniqueNodeID document_id, Core::SharedVersionIndex document_index)
|
|
{
|
|
if (auto* document = as_if<Web::DOM::Document>(Web::DOM::Node::from_unique_id(document_id)))
|
|
document->set_cookie_version_index(document_index);
|
|
}
|
|
|
|
Vector<HTTP::Cookie::Cookie> PageClient::page_did_request_all_cookies_webdriver(URL::URL const& url)
|
|
{
|
|
return client().did_request_all_cookies_webdriver(url);
|
|
}
|
|
|
|
Vector<HTTP::Cookie::Cookie> PageClient::page_did_request_all_cookies_cookiestore(URL::URL const& url)
|
|
{
|
|
return client().did_request_all_cookies_cookiestore(url);
|
|
}
|
|
|
|
Optional<HTTP::Cookie::Cookie> PageClient::page_did_request_named_cookie(URL::URL const& url, String const& name)
|
|
{
|
|
return client().did_request_named_cookie(url, name);
|
|
}
|
|
|
|
HTTP::Cookie::VersionedCookie PageClient::page_did_request_cookie(URL::URL const& url, HTTP::Cookie::Source source)
|
|
{
|
|
auto response = client().send_sync_but_allow_failure<Messages::WebContentClient::DidRequestCookie>(m_id, url, source);
|
|
if (!response) {
|
|
dbgln("WebContent client disconnected during DidRequestCookie. Exiting peacefully.");
|
|
exit(0);
|
|
}
|
|
return response->take_cookie();
|
|
}
|
|
|
|
void PageClient::page_did_set_cookie(URL::URL const& url, HTTP::Cookie::ParsedCookie const& cookie, HTTP::Cookie::Source source)
|
|
{
|
|
auto response = client().send_sync_but_allow_failure<Messages::WebContentClient::DidSetCookie>(url, cookie, source);
|
|
if (!response) {
|
|
dbgln("WebContent client disconnected during DidSetCookie. Exiting peacefully.");
|
|
exit(0);
|
|
}
|
|
}
|
|
|
|
void PageClient::page_did_update_cookie(HTTP::Cookie::Cookie const& cookie)
|
|
{
|
|
client().async_did_update_cookie(cookie);
|
|
|
|
// Since the above (test-only) IPC is async, we reset the document cookie version now to avoid a stale cache.
|
|
if (auto* document = page().top_level_browsing_context().active_document())
|
|
document->reset_cookie_version();
|
|
}
|
|
|
|
void PageClient::page_did_expire_cookies_with_time_offset(AK::Duration offset)
|
|
{
|
|
client().async_did_expire_cookies_with_time_offset(offset);
|
|
|
|
// Since the above (test-only) IPC is async, we reset the document cookie version now to avoid a stale cache.
|
|
if (auto* document = page().top_level_browsing_context().active_document())
|
|
document->reset_cookie_version();
|
|
}
|
|
|
|
Optional<String> PageClient::page_did_request_storage_item(Web::StorageAPI::StorageEndpointType storage_endpoint, String const& storage_key, String const& bottle_key)
|
|
{
|
|
auto response = client().send_sync_but_allow_failure<Messages::WebContentClient::DidRequestStorageItem>(storage_endpoint, storage_key, bottle_key);
|
|
if (!response) {
|
|
dbgln("WebContent client disconnected during DidRequestStorageItem. Exiting peacefully.");
|
|
exit(0);
|
|
}
|
|
return response->take_value();
|
|
}
|
|
|
|
WebView::StorageSetResult PageClient::page_did_set_storage_item(Web::StorageAPI::StorageEndpointType storage_endpoint, String const& storage_key, String const& bottle_key, String const& value)
|
|
{
|
|
auto response = client().send_sync_but_allow_failure<Messages::WebContentClient::DidSetStorageItem>(storage_endpoint, storage_key, bottle_key, value);
|
|
if (!response) {
|
|
dbgln("WebContent client disconnected during DidSetStorageItem. Exiting peacefully.");
|
|
exit(0);
|
|
}
|
|
return response->result();
|
|
}
|
|
|
|
void PageClient::page_did_remove_storage_item(Web::StorageAPI::StorageEndpointType storage_endpoint, String const& storage_key, String const& bottle_key)
|
|
{
|
|
auto response = client().send_sync_but_allow_failure<Messages::WebContentClient::DidRemoveStorageItem>(storage_endpoint, storage_key, bottle_key);
|
|
if (!response) {
|
|
dbgln("WebContent client disconnected during DidRemoveStorageItem. Exiting peacefully.");
|
|
exit(0);
|
|
}
|
|
}
|
|
|
|
Vector<String> PageClient::page_did_request_storage_keys(Web::StorageAPI::StorageEndpointType storage_endpoint, String const& storage_key)
|
|
{
|
|
auto response = client().send_sync_but_allow_failure<Messages::WebContentClient::DidRequestStorageKeys>(storage_endpoint, storage_key);
|
|
if (!response) {
|
|
dbgln("WebContent client disconnected during DidRequestStorageKeys. Exiting peacefully.");
|
|
exit(0);
|
|
}
|
|
return response->take_keys();
|
|
}
|
|
|
|
void PageClient::page_did_clear_storage(Web::StorageAPI::StorageEndpointType storage_endpoint, String const& storage_key)
|
|
{
|
|
auto response = client().send_sync_but_allow_failure<Messages::WebContentClient::DidClearStorage>(storage_endpoint, storage_key);
|
|
if (!response) {
|
|
dbgln("WebContent client disconnected during DidClearStorage. Exiting peacefully.");
|
|
exit(0);
|
|
}
|
|
}
|
|
|
|
void PageClient::page_did_post_broadcast_channel_message(Web::HTML::BroadcastChannelMessage const& message)
|
|
{
|
|
client().async_did_post_broadcast_channel_message(m_id, message);
|
|
}
|
|
|
|
void PageClient::page_did_update_resource_count(i32 count_waiting)
|
|
{
|
|
client().async_did_update_resource_count(m_id, count_waiting);
|
|
}
|
|
|
|
PageClient::NewWebViewResult PageClient::page_did_request_new_web_view(Web::HTML::ActivateTab activate_tab, Web::HTML::WebViewHints hints, Web::HTML::TokenizedFeature::NoOpener no_opener)
|
|
{
|
|
auto& new_client = m_owner.create_page();
|
|
|
|
Optional<u64> page_id;
|
|
if (no_opener == Web::HTML::TokenizedFeature::NoOpener::Yes) {
|
|
// FIXME: Create an abstraction to let this WebContent process know about a new process we create?
|
|
// FIXME: For now, just create a new page in the same process anyway
|
|
}
|
|
|
|
page_id = new_client.m_id;
|
|
|
|
auto response = client().send_sync_but_allow_failure<Messages::WebContentClient::DidRequestNewWebView>(m_id, activate_tab, hints, page_id);
|
|
if (!response) {
|
|
dbgln("WebContent client disconnected during DidRequestNewWebView. Exiting peacefully.");
|
|
exit(0);
|
|
}
|
|
|
|
return { &new_client.page(), response->take_handle() };
|
|
}
|
|
|
|
void PageClient::page_did_request_activate_tab()
|
|
{
|
|
client().async_did_request_activate_tab(m_id);
|
|
}
|
|
|
|
void PageClient::page_did_close_top_level_traversable()
|
|
{
|
|
// FIXME: Rename this IPC call
|
|
client().async_did_close_browsing_context(m_id);
|
|
|
|
// NOTE: This only removes the strong reference the PageHost has for this PageClient.
|
|
// It will be GC'd 'later'.
|
|
m_owner.remove_page({}, m_id);
|
|
}
|
|
|
|
void PageClient::page_did_update_navigation_buttons_state(bool back_enabled, bool forward_enabled)
|
|
{
|
|
client().async_did_update_navigation_buttons_state(m_id, back_enabled, forward_enabled);
|
|
}
|
|
|
|
void PageClient::request_file(Web::FileRequest file_request)
|
|
{
|
|
client().request_file(m_id, move(file_request));
|
|
}
|
|
|
|
void PageClient::page_did_request_color_picker(Color current_color)
|
|
{
|
|
client().async_did_request_color_picker(m_id, current_color);
|
|
}
|
|
|
|
void PageClient::page_did_request_file_picker(Web::HTML::FileFilter const& accepted_file_types, Web::HTML::AllowMultipleFiles allow_multiple_files)
|
|
{
|
|
client().async_did_request_file_picker(m_id, accepted_file_types, allow_multiple_files);
|
|
}
|
|
|
|
void PageClient::page_did_request_select_dropdown(Web::CSSPixelPoint content_position, Web::CSSPixels minimum_width, Vector<Web::HTML::SelectItem> items)
|
|
{
|
|
client().async_did_request_select_dropdown(m_id, page().css_to_device_point(content_position).to_type<int>(), minimum_width * device_pixels_per_css_pixel(), items);
|
|
}
|
|
|
|
void PageClient::page_did_change_theme_color(Gfx::Color color)
|
|
{
|
|
client().async_did_change_theme_color(m_id, color);
|
|
}
|
|
|
|
void PageClient::page_did_insert_clipboard_entry(Web::Clipboard::SystemClipboardRepresentation const& entry, StringView presentation_style)
|
|
{
|
|
client().async_did_insert_clipboard_entry(m_id, entry, presentation_style);
|
|
}
|
|
|
|
void PageClient::page_did_request_clipboard_entries(u64 request_id)
|
|
{
|
|
client().async_did_request_clipboard_entries(m_id, request_id);
|
|
}
|
|
|
|
void PageClient::page_did_change_audio_play_state(Web::HTML::AudioPlayState play_state)
|
|
{
|
|
client().async_did_change_audio_play_state(m_id, play_state);
|
|
}
|
|
|
|
void PageClient::page_did_allocate_backing_stores(i32 front_bitmap_id, Gfx::SharedImage front_backing_store, i32 back_bitmap_id, Gfx::SharedImage back_backing_store)
|
|
{
|
|
client().async_did_allocate_backing_stores(m_id, front_bitmap_id, move(front_backing_store), back_bitmap_id, move(back_backing_store));
|
|
}
|
|
|
|
Web::PageClient::WorkerAgentResponse PageClient::request_worker_agent(Web::Bindings::AgentType type)
|
|
{
|
|
auto response = client().send_sync_but_allow_failure<Messages::WebContentClient::RequestWorkerAgent>(m_id, type);
|
|
if (!response) {
|
|
dbgln("WebContent client disconnected during RequestWorkerAgent. Exiting peacefully.");
|
|
exit(0);
|
|
}
|
|
|
|
return { response->take_handle(), response->take_request_server_handle(), response->take_image_decoder_handle() };
|
|
}
|
|
|
|
void PageClient::page_did_mutate_dom(FlyString const& type, Web::DOM::Node const& target, Web::DOM::NodeList& added_nodes, Web::DOM::NodeList& removed_nodes, GC::Ptr<Web::DOM::Node>, GC::Ptr<Web::DOM::Node>, Optional<String> const& attribute_name)
|
|
{
|
|
Optional<WebView::Mutation::Type> mutation;
|
|
|
|
if (type == Web::DOM::MutationType::attributes) {
|
|
VERIFY(attribute_name.has_value());
|
|
|
|
auto const& element = as<Web::DOM::Element>(target);
|
|
mutation = WebView::AttributeMutation { *attribute_name, element.attribute(*attribute_name) };
|
|
} else if (type == Web::DOM::MutationType::characterData) {
|
|
auto const& character_data = as<Web::DOM::CharacterData>(target);
|
|
mutation = WebView::CharacterDataMutation { character_data.data().to_utf8_but_should_be_ported_to_utf16() };
|
|
} else if (type == Web::DOM::MutationType::childList) {
|
|
Vector<Web::UniqueNodeID> added;
|
|
added.ensure_capacity(added_nodes.length());
|
|
|
|
Vector<Web::UniqueNodeID> removed;
|
|
removed.ensure_capacity(removed_nodes.length());
|
|
|
|
for (auto i = 0u; i < added_nodes.length(); ++i)
|
|
added.unchecked_append(added_nodes.item(i)->unique_id());
|
|
for (auto i = 0u; i < removed_nodes.length(); ++i)
|
|
removed.unchecked_append(removed_nodes.item(i)->unique_id());
|
|
|
|
mutation = WebView::ChildListMutation { move(added), move(removed), target.child_count() };
|
|
} else {
|
|
VERIFY_NOT_REACHED();
|
|
}
|
|
|
|
StringBuilder builder;
|
|
auto serializer = MUST(JsonObjectSerializer<>::try_create(builder));
|
|
target.serialize_tree_as_json(serializer);
|
|
MUST(serializer.finish());
|
|
auto serialized_target = MUST(builder.to_string());
|
|
|
|
client().async_did_mutate_dom(m_id, { type.to_string(), target.unique_id(), move(serialized_target), mutation.release_value() });
|
|
}
|
|
|
|
void PageClient::page_did_paint(Gfx::IntRect const& content_rect, i32 bitmap_id)
|
|
{
|
|
client().async_did_paint(m_id, content_rect, bitmap_id);
|
|
}
|
|
|
|
void PageClient::page_did_take_screenshot(Gfx::ShareableBitmap const& screenshot)
|
|
{
|
|
client().async_did_take_screenshot(m_id, screenshot);
|
|
}
|
|
|
|
ErrorOr<void> PageClient::connect_to_webdriver(ByteString const& webdriver_endpoint)
|
|
{
|
|
VERIFY(!m_webdriver);
|
|
m_webdriver = TRY(WebDriverConnection::connect(*this, webdriver_endpoint));
|
|
|
|
return {};
|
|
}
|
|
|
|
ErrorOr<void> PageClient::connect_to_web_ui(IPC::TransportHandle handle)
|
|
{
|
|
auto* active_document = page().top_level_browsing_context().active_document();
|
|
if (!active_document || !active_document->window())
|
|
return {};
|
|
|
|
VERIFY(!m_web_ui);
|
|
m_web_ui = TRY(WebUIConnection::connect(move(handle), *active_document));
|
|
|
|
return {};
|
|
}
|
|
|
|
void PageClient::received_message_from_web_ui(String const& name, JS::Value data)
|
|
{
|
|
if (m_web_ui)
|
|
m_web_ui->received_message_from_web_ui(name, data);
|
|
}
|
|
|
|
void PageClient::page_did_start_network_request(u64 request_id, URL::URL const& url, ByteString const& method, Vector<HTTP::Header> const& request_headers, ReadonlyBytes request_body, Optional<String> initiator_type)
|
|
{
|
|
client().async_did_start_network_request(m_id, request_id, url, method, request_headers, request_body, move(initiator_type));
|
|
}
|
|
|
|
void PageClient::page_did_receive_network_response_headers(u64 request_id, u32 status_code, Optional<String> reason_phrase, Vector<HTTP::Header> const& response_headers)
|
|
{
|
|
client().async_did_receive_network_response_headers(m_id, request_id, status_code, move(reason_phrase), response_headers);
|
|
}
|
|
|
|
void PageClient::page_did_receive_network_response_body(u64 request_id, ReadonlyBytes data)
|
|
{
|
|
if (!has_devtools_client())
|
|
return;
|
|
client().async_did_receive_network_response_body(m_id, request_id, data);
|
|
}
|
|
|
|
void PageClient::did_connect_devtools_client()
|
|
{
|
|
++m_devtools_client_count;
|
|
}
|
|
|
|
void PageClient::did_disconnect_devtools_client()
|
|
{
|
|
VERIFY(m_devtools_client_count > 0);
|
|
--m_devtools_client_count;
|
|
}
|
|
|
|
void PageClient::page_did_finish_network_request(u64 request_id, u64 body_size, Requests::RequestTimingInfo const& timing_info, Optional<Requests::NetworkError> const& network_error)
|
|
{
|
|
client().async_did_finish_network_request(m_id, request_id, body_size, timing_info, network_error);
|
|
}
|
|
|
|
void PageClient::initialize_js_console(Web::DOM::Document& document)
|
|
{
|
|
if (document.is_temporary_document_for_fragment_parsing())
|
|
return;
|
|
|
|
auto& realm = document.realm();
|
|
auto console_object = realm.intrinsics().console_object();
|
|
|
|
auto console_client = DevToolsConsoleClient::create(document.realm(), console_object->console(), *this);
|
|
document.set_console_client(console_client);
|
|
}
|
|
|
|
void PageClient::did_execute_js_console_input(JsonValue const& result)
|
|
{
|
|
client().async_did_execute_js_console_input(m_id, result);
|
|
}
|
|
|
|
void PageClient::js_console_input(StringView js_source)
|
|
{
|
|
if (m_top_level_document_console_client)
|
|
m_top_level_document_console_client->handle_input(js_source);
|
|
}
|
|
|
|
void PageClient::run_javascript(StringView js_source)
|
|
{
|
|
auto* active_document = page().top_level_browsing_context().active_document();
|
|
|
|
if (!active_document)
|
|
return;
|
|
|
|
// This is partially based on "execute a javascript: URL request" https://html.spec.whatwg.org/multipage/browsing-the-web.html#javascript-protocol
|
|
|
|
// Let settings be browsingContext's active document's relevant settings object.
|
|
auto& settings = active_document->relevant_settings_object();
|
|
|
|
// Let baseURL be settings's API base URL.
|
|
auto base_url = settings.api_base_url();
|
|
|
|
// Let script be the result of creating a classic script given scriptSource, settings, baseURL, and the default classic script fetch options.
|
|
// FIXME: This doesn't pass in "default classic script fetch options"
|
|
// FIXME: What should the filename be here?
|
|
auto script = Web::HTML::ClassicScript::create("(client connection run_javascript)", js_source, settings, move(base_url));
|
|
|
|
// Let evaluationStatus be the result of running the classic script script.
|
|
auto evaluation_status = script->run();
|
|
|
|
if (evaluation_status.is_error())
|
|
dbgln("Exception :(");
|
|
}
|
|
|
|
void PageClient::did_output_js_console_message(WebView::ConsoleOutput console_output)
|
|
{
|
|
client().async_did_output_js_console_message(m_id, move(console_output));
|
|
}
|
|
|
|
void PageClient::console_peer_did_misbehave(char const* reason)
|
|
{
|
|
client().did_misbehave(reason);
|
|
}
|
|
|
|
static void gather_style_sheets(Vector<Web::CSS::StyleSheetIdentifier>& results, Web::CSS::CSSStyleSheet& sheet)
|
|
{
|
|
Web::CSS::StyleSheetIdentifier identifier {};
|
|
|
|
bool valid = true;
|
|
|
|
if (sheet.owner_rule()) {
|
|
identifier.type = Web::CSS::StyleSheetIdentifier::Type::ImportRule;
|
|
} else if (auto* node = sheet.owner_node()) {
|
|
if (node->is_html_style_element() || node->is_svg_style_element()) {
|
|
identifier.type = Web::CSS::StyleSheetIdentifier::Type::StyleElement;
|
|
} else if (is<Web::HTML::HTMLLinkElement>(node)) {
|
|
identifier.type = Web::CSS::StyleSheetIdentifier::Type::LinkElement;
|
|
} else {
|
|
dbgln("Can't identify where style sheet came from; owner node is {}", node->debug_description());
|
|
identifier.type = Web::CSS::StyleSheetIdentifier::Type::StyleElement;
|
|
}
|
|
identifier.dom_element_unique_id = node->unique_id();
|
|
} else {
|
|
dbgln("Style sheet has no owner rule or owner node; skipping");
|
|
valid = false;
|
|
}
|
|
|
|
if (valid) {
|
|
if (auto sheet_url = sheet.href(); sheet_url.has_value())
|
|
identifier.url = sheet_url.release_value();
|
|
|
|
identifier.rule_count = sheet.rules().length();
|
|
results.append(move(identifier));
|
|
}
|
|
|
|
for (auto& import_rule : sheet.import_rules()) {
|
|
if (import_rule->loaded_style_sheet()) {
|
|
gather_style_sheets(results, *import_rule->loaded_style_sheet());
|
|
} else {
|
|
// We can gather this anyway, and hope it loads later
|
|
results.append({
|
|
.type = Web::CSS::StyleSheetIdentifier::Type::ImportRule,
|
|
.url = import_rule->href(),
|
|
});
|
|
}
|
|
}
|
|
}
|
|
|
|
Vector<Web::CSS::StyleSheetIdentifier> PageClient::list_style_sheets() const
|
|
{
|
|
Vector<Web::CSS::StyleSheetIdentifier> results;
|
|
|
|
auto const* document = page().top_level_browsing_context().active_document();
|
|
if (document) {
|
|
for (auto& sheet : document->style_sheets().sheets()) {
|
|
gather_style_sheets(results, sheet);
|
|
}
|
|
}
|
|
|
|
// User style
|
|
if (page().user_style().has_value()) {
|
|
results.append({
|
|
.type = Web::CSS::StyleSheetIdentifier::Type::UserStyle,
|
|
});
|
|
}
|
|
|
|
// User-agent
|
|
results.append({
|
|
.type = Web::CSS::StyleSheetIdentifier::Type::UserAgent,
|
|
.url = "CSS/Default.css"_string,
|
|
});
|
|
if (document && document->in_quirks_mode()) {
|
|
results.append({
|
|
.type = Web::CSS::StyleSheetIdentifier::Type::UserAgent,
|
|
.url = "CSS/QuirksMode.css"_string,
|
|
});
|
|
}
|
|
results.append({
|
|
.type = Web::CSS::StyleSheetIdentifier::Type::UserAgent,
|
|
.url = "MathML/Default.css"_string,
|
|
});
|
|
results.append({
|
|
.type = Web::CSS::StyleSheetIdentifier::Type::UserAgent,
|
|
.url = "SVG/Default.css"_string,
|
|
});
|
|
|
|
return results;
|
|
}
|
|
|
|
Web::DisplayListPlayerType PageClient::display_list_player_type() const
|
|
{
|
|
switch (s_use_skia_painter) {
|
|
case UseSkiaPainter::GPUBackendIfAvailable:
|
|
return Web::DisplayListPlayerType::SkiaGPUIfAvailable;
|
|
case UseSkiaPainter::CPUBackend:
|
|
return Web::DisplayListPlayerType::SkiaCPU;
|
|
default:
|
|
VERIFY_NOT_REACHED();
|
|
}
|
|
}
|
|
|
|
void PageClient::queue_screenshot_task(Optional<Web::UniqueNodeID> node_id)
|
|
{
|
|
page().top_level_traversable()->queue_screenshot_task(node_id);
|
|
}
|
|
|
|
}
|