1use std::borrow::ToOwned;
6use std::cell::{Cell, RefCell, RefMut};
7use std::cmp;
8use std::collections::hash_map::Entry;
9use std::collections::{HashMap, HashSet};
10use std::default::Default;
11use std::ffi::c_void;
12use std::io::{Write, stderr, stdout};
13use std::rc::Rc;
14use std::sync::Arc;
15use std::time::{Duration, Instant};
16
17use app_units::Au;
18use backtrace::Backtrace;
19use base::cross_process_instant::CrossProcessInstant;
20use base::generic_channel;
21use base::generic_channel::GenericSender;
22use base::id::{BrowsingContextId, PipelineId, WebViewId};
23use base64::Engine;
24#[cfg(feature = "bluetooth")]
25use bluetooth_traits::BluetoothRequest;
26use canvas_traits::webgl::WebGLChan;
27use compositing_traits::CrossProcessCompositorApi;
28use constellation_traits::{
29 LoadData, LoadOrigin, NavigationHistoryBehavior, ScreenshotReadinessResponse,
30 ScriptToConstellationChan, ScriptToConstellationMessage, StructuredSerializedData,
31 WindowSizeType,
32};
33use content_security_policy::sandboxing_directive::SandboxingFlagSet;
34use crossbeam_channel::{Sender, unbounded};
35use cssparser::SourceLocation;
36use devtools_traits::{ScriptToDevtoolsControlMsg, TimelineMarker, TimelineMarkerType};
37use dom_struct::dom_struct;
38use embedder_traits::user_content_manager::{UserContentManager, UserScript};
39use embedder_traits::{
40 AlertResponse, ConfirmResponse, EmbedderMsg, JavaScriptEvaluationError, PromptResponse,
41 ScriptToEmbedderChan, SimpleDialog, Theme, UntrustedNodeAddress, ViewportDetails,
42 WebDriverJSResult, WebDriverLoadStatus,
43};
44use euclid::default::{Point2D as UntypedPoint2D, Rect as UntypedRect, Size2D as UntypedSize2D};
45use euclid::{Point2D, Scale, Size2D, Vector2D};
46use fonts::FontContext;
47use ipc_channel::ipc::IpcSender;
48use js::glue::DumpJSStack;
49use js::jsapi::{
50 GCReason, Heap, JS_GC, JSAutoRealm, JSContext as RawJSContext, JSObject, JSPROP_ENUMERATE,
51};
52use js::jsval::{NullValue, UndefinedValue};
53use js::rust::wrappers::JS_DefineProperty;
54use js::rust::{
55 CustomAutoRooter, CustomAutoRooterGuard, HandleObject, HandleValue, MutableHandleObject,
56 MutableHandleValue,
57};
58use layout_api::{
59 BoxAreaType, ElementsFromPointFlags, ElementsFromPointResult, FragmentType, Layout,
60 LayoutImageDestination, PendingImage, PendingImageState, PendingRasterizationImage, QueryMsg,
61 ReflowGoal, ReflowPhasesRun, ReflowRequest, ReflowRequestRestyle, RestyleReason,
62 ScrollContainerQueryFlags, ScrollContainerResponse, TrustedNodeAddress,
63 combine_id_with_fragment_type,
64};
65use malloc_size_of::MallocSizeOf;
66use media::WindowGLContext;
67use net_traits::ResourceThreads;
68use net_traits::image_cache::{
69 ImageCache, ImageCacheResponseMessage, ImageLoadListener, ImageResponse, PendingImageId,
70 PendingImageResponse, RasterizationCompleteResponse,
71};
72use num_traits::ToPrimitive;
73use profile_traits::generic_channel as ProfiledGenericChannel;
74use profile_traits::mem::ProfilerChan as MemProfilerChan;
75use profile_traits::time::ProfilerChan as TimeProfilerChan;
76use rustc_hash::{FxBuildHasher, FxHashMap};
77use script_bindings::codegen::GenericBindings::WindowBinding::ScrollToOptions;
78use script_bindings::conversions::SafeToJSValConvertible;
79use script_bindings::interfaces::WindowHelpers;
80use script_bindings::root::Root;
81use script_traits::{ConstellationInputEvent, ScriptThreadMessage};
82use selectors::attr::CaseSensitivity;
83use servo_arc::Arc as ServoArc;
84use servo_config::pref;
85use servo_geometry::{DeviceIndependentIntRect, f32_rect_to_au_rect};
86use servo_url::{ImmutableOrigin, MutableOrigin, ServoUrl};
87use storage_traits::StorageThreads;
88use storage_traits::webstorage_thread::StorageType;
89use style::error_reporting::{ContextualParseError, ParseErrorReporter};
90use style::properties::PropertyId;
91use style::properties::style_structs::Font;
92use style::selector_parser::PseudoElement;
93use style::str::HTML_SPACE_CHARACTERS;
94use style::stylesheets::UrlExtraData;
95use style_traits::CSSPixel;
96use stylo_atoms::Atom;
97use url::Position;
98use webrender_api::ExternalScrollId;
99use webrender_api::units::{DeviceIntSize, DevicePixel, LayoutPixel, LayoutPoint};
100
101use super::bindings::codegen::Bindings::MessagePortBinding::StructuredSerializeOptions;
102use super::bindings::trace::HashMapTracedValues;
103use super::types::SVGSVGElement;
104use crate::dom::bindings::cell::{DomRefCell, Ref};
105use crate::dom::bindings::codegen::Bindings::DocumentBinding::{
106 DocumentMethods, DocumentReadyState, NamedPropertyValue,
107};
108use crate::dom::bindings::codegen::Bindings::HTMLIFrameElementBinding::HTMLIFrameElementMethods;
109use crate::dom::bindings::codegen::Bindings::HistoryBinding::History_Binding::HistoryMethods;
110use crate::dom::bindings::codegen::Bindings::ImageBitmapBinding::{
111 ImageBitmapOptions, ImageBitmapSource,
112};
113use crate::dom::bindings::codegen::Bindings::MediaQueryListBinding::MediaQueryList_Binding::MediaQueryListMethods;
114use crate::dom::bindings::codegen::Bindings::ReportingObserverBinding::Report;
115use crate::dom::bindings::codegen::Bindings::RequestBinding::{RequestInfo, RequestInit};
116use crate::dom::bindings::codegen::Bindings::VoidFunctionBinding::VoidFunction;
117use crate::dom::bindings::codegen::Bindings::WindowBinding::{
118 self, DeferredRequestInit, FrameRequestCallback, ScrollBehavior, WindowMethods,
119 WindowPostMessageOptions,
120};
121use crate::dom::bindings::codegen::UnionTypes::{
122 RequestOrUSVString, TrustedScriptOrString, TrustedScriptOrStringOrFunction,
123};
124use crate::dom::bindings::error::{
125 Error, ErrorInfo, ErrorResult, Fallible, javascript_error_info_from_error_info,
126};
127use crate::dom::bindings::inheritance::{Castable, ElementTypeId, HTMLElementTypeId, NodeTypeId};
128use crate::dom::bindings::num::Finite;
129use crate::dom::bindings::refcounted::Trusted;
130use crate::dom::bindings::reflector::{DomGlobal, DomObject};
131use crate::dom::bindings::root::{Dom, DomRoot, MutNullableDom};
132use crate::dom::bindings::str::{DOMString, USVString};
133use crate::dom::bindings::structuredclone;
134use crate::dom::bindings::trace::{CustomTraceable, JSTraceable, RootedTraceableBox};
135use crate::dom::bindings::utils::GlobalStaticData;
136use crate::dom::bindings::weakref::DOMTracker;
137#[cfg(feature = "bluetooth")]
138use crate::dom::bluetooth::BluetoothExtraPermissionData;
139use crate::dom::cookiestore::CookieStore;
140use crate::dom::crypto::Crypto;
141use crate::dom::cssstyledeclaration::{CSSModificationAccess, CSSStyleDeclaration, CSSStyleOwner};
142use crate::dom::customelementregistry::CustomElementRegistry;
143use crate::dom::document::{AnimationFrameCallback, Document};
144use crate::dom::element::Element;
145use crate::dom::event::{Event, EventBubbles, EventCancelable};
146use crate::dom::eventtarget::EventTarget;
147use crate::dom::fetchlaterresult::FetchLaterResult;
148use crate::dom::globalscope::GlobalScope;
149use crate::dom::hashchangeevent::HashChangeEvent;
150use crate::dom::history::History;
151use crate::dom::html::htmlcollection::{CollectionFilter, HTMLCollection};
152use crate::dom::html::htmliframeelement::HTMLIFrameElement;
153use crate::dom::idbfactory::IDBFactory;
154use crate::dom::inputevent::HitTestResult;
155use crate::dom::location::Location;
156use crate::dom::medialist::MediaList;
157use crate::dom::mediaquerylist::{MediaQueryList, MediaQueryListMatchState};
158use crate::dom::mediaquerylistevent::MediaQueryListEvent;
159use crate::dom::messageevent::MessageEvent;
160use crate::dom::navigator::Navigator;
161use crate::dom::node::{Node, NodeDamage, NodeTraits, from_untrusted_node_address};
162use crate::dom::performance::Performance;
163use crate::dom::promise::Promise;
164use crate::dom::reportingendpoint::{ReportingEndpoint, SendReportsToEndpoints};
165use crate::dom::reportingobserver::ReportingObserver;
166use crate::dom::screen::Screen;
167use crate::dom::scrolling_box::{ScrollingBox, ScrollingBoxSource};
168use crate::dom::selection::Selection;
169use crate::dom::shadowroot::ShadowRoot;
170use crate::dom::storage::Storage;
171#[cfg(feature = "bluetooth")]
172use crate::dom::testrunner::TestRunner;
173use crate::dom::trustedtypepolicyfactory::TrustedTypePolicyFactory;
174use crate::dom::types::{ImageBitmap, UIEvent};
175use crate::dom::webgl::webglrenderingcontext::WebGLCommandSender;
176#[cfg(feature = "webgpu")]
177use crate::dom::webgpu::identityhub::IdentityHub;
178use crate::dom::windowproxy::{WindowProxy, WindowProxyHandler};
179use crate::dom::worklet::Worklet;
180use crate::dom::workletglobalscope::WorkletGlobalScopeType;
181use crate::layout_image::fetch_image_for_layout;
182use crate::messaging::{MainThreadScriptMsg, ScriptEventLoopReceiver, ScriptEventLoopSender};
183use crate::microtask::MicrotaskQueue;
184use crate::realms::{InRealm, enter_realm};
185use crate::script_runtime::{CanGc, JSContext, Runtime};
186use crate::script_thread::ScriptThread;
187use crate::script_window_proxies::ScriptWindowProxies;
188use crate::timers::{IsInterval, TimerCallback};
189use crate::unminify::unminified_path;
190use crate::webdriver_handlers::{find_node_by_unique_id_in_document, jsval_to_webdriver};
191use crate::{fetch, window_named_properties};
192
193#[derive(MallocSizeOf)]
198pub struct PendingImageCallback(
199 #[ignore_malloc_size_of = "dyn Fn is currently impossible to measure"]
200 Box<dyn Fn(PendingImageResponse) + 'static>,
201);
202
203#[derive(Clone, Copy, Debug, JSTraceable, MallocSizeOf, PartialEq)]
205enum WindowState {
206 Alive,
207 Zombie, }
209
210const INITIAL_REFLOW_DELAY: Duration = Duration::from_millis(200);
213
214#[derive(Clone, Copy, MallocSizeOf)]
225enum LayoutBlocker {
226 WaitingForParse,
228 Parsing(Instant),
230 FiredLoadEventOrParsingTimerExpired,
234}
235
236impl LayoutBlocker {
237 fn layout_blocked(&self) -> bool {
238 !matches!(self, Self::FiredLoadEventOrParsingTimerExpired)
239 }
240}
241
242#[derive(Clone, Copy, Debug, Default, JSTraceable, MallocSizeOf, PartialEq)]
245pub(crate) struct OngoingNavigation(u32);
246
247type PendingImageRasterizationKey = (PendingImageId, DeviceIntSize);
248
249#[cfg_attr(crown, crown::unrooted_must_root_lint::must_root)]
253#[derive(JSTraceable, MallocSizeOf)]
254struct PendingLayoutImageAncillaryData {
255 node: Dom<Node>,
256 #[no_trace]
257 destination: LayoutImageDestination,
258}
259
260#[dom_struct]
261pub(crate) struct Window {
262 globalscope: GlobalScope,
263 #[no_trace]
267 webview_id: WebViewId,
268 script_chan: Sender<MainThreadScriptMsg>,
269 #[no_trace]
270 #[ignore_malloc_size_of = "TODO: Add MallocSizeOf support to layout"]
271 layout: RefCell<Box<dyn Layout>>,
272 navigator: MutNullableDom<Navigator>,
273 #[ignore_malloc_size_of = "ImageCache"]
274 #[no_trace]
275 image_cache: Arc<dyn ImageCache>,
276 #[no_trace]
277 image_cache_sender: IpcSender<ImageCacheResponseMessage>,
278 window_proxy: MutNullableDom<WindowProxy>,
279 document: MutNullableDom<Document>,
280 location: MutNullableDom<Location>,
281 history: MutNullableDom<History>,
282 indexeddb: MutNullableDom<IDBFactory>,
283 custom_element_registry: MutNullableDom<CustomElementRegistry>,
284 performance: MutNullableDom<Performance>,
285 #[no_trace]
286 navigation_start: Cell<CrossProcessInstant>,
287 screen: MutNullableDom<Screen>,
288 session_storage: MutNullableDom<Storage>,
289 local_storage: MutNullableDom<Storage>,
290 status: DomRefCell<DOMString>,
291 trusted_types: MutNullableDom<TrustedTypePolicyFactory>,
292
293 ongoing_navigation: Cell<OngoingNavigation>,
296
297 #[no_trace]
300 devtools_markers: DomRefCell<HashSet<TimelineMarkerType>>,
301 #[no_trace]
302 devtools_marker_sender: DomRefCell<Option<IpcSender<Option<TimelineMarker>>>>,
303
304 #[no_trace]
306 unhandled_resize_event: DomRefCell<Option<(ViewportDetails, WindowSizeType)>>,
307
308 #[no_trace]
310 theme: Cell<Theme>,
311
312 #[no_trace]
314 parent_info: Option<PipelineId>,
315
316 dom_static: GlobalStaticData,
318
319 #[conditional_malloc_size_of]
321 js_runtime: DomRefCell<Option<Rc<Runtime>>>,
322
323 #[no_trace]
325 viewport_details: Cell<ViewportDetails>,
326
327 #[no_trace]
329 #[cfg(feature = "bluetooth")]
330 bluetooth_thread: IpcSender<BluetoothRequest>,
331
332 #[cfg(feature = "bluetooth")]
333 bluetooth_extra_permission_data: BluetoothExtraPermissionData,
334
335 #[no_trace]
339 layout_blocker: Cell<LayoutBlocker>,
340
341 #[no_trace]
343 webdriver_script_chan: DomRefCell<Option<IpcSender<WebDriverJSResult>>>,
344
345 #[no_trace]
347 webdriver_load_status_sender: RefCell<Option<GenericSender<WebDriverLoadStatus>>>,
348
349 current_state: Cell<WindowState>,
351
352 #[no_trace]
355 current_viewport_size: Cell<UntypedSize2D<Au>>,
356
357 error_reporter: CSSErrorReporter,
358
359 media_query_lists: DOMTracker<MediaQueryList>,
361
362 #[cfg(feature = "bluetooth")]
363 test_runner: MutNullableDom<TestRunner>,
364
365 #[ignore_malloc_size_of = "channels are hard"]
367 #[no_trace]
368 webgl_chan: Option<WebGLChan>,
369
370 #[ignore_malloc_size_of = "defined in webxr"]
371 #[no_trace]
372 #[cfg(feature = "webxr")]
373 webxr_registry: Option<webxr_api::Registry>,
374
375 #[no_trace]
379 pending_image_callbacks: DomRefCell<FxHashMap<PendingImageId, Vec<PendingImageCallback>>>,
380
381 pending_layout_images: DomRefCell<
386 HashMapTracedValues<PendingImageId, Vec<PendingLayoutImageAncillaryData>, FxBuildHasher>,
387 >,
388
389 pending_images_for_rasterization: DomRefCell<
393 HashMapTracedValues<PendingImageRasterizationKey, Vec<Dom<Node>>, FxBuildHasher>,
394 >,
395
396 unminified_css_dir: DomRefCell<Option<String>>,
399
400 local_script_source: Option<String>,
402
403 test_worklet: MutNullableDom<Worklet>,
405 paint_worklet: MutNullableDom<Worklet>,
407
408 exists_mut_observer: Cell<bool>,
410
411 #[ignore_malloc_size_of = "Wraps an IpcSender"]
413 #[no_trace]
414 compositor_api: CrossProcessCompositorApi,
415
416 has_sent_idle_message: Cell<bool>,
419
420 unminify_css: bool,
422
423 #[no_trace]
425 user_content_manager: UserContentManager,
426
427 #[ignore_malloc_size_of = "defined in script_thread"]
429 #[no_trace]
430 player_context: WindowGLContext,
431
432 throttled: Cell<bool>,
433
434 #[conditional_malloc_size_of]
438 layout_marker: DomRefCell<Rc<Cell<bool>>>,
439
440 current_event: DomRefCell<Option<Dom<Event>>>,
442
443 reporting_observer_list: DomRefCell<Vec<DomRoot<ReportingObserver>>>,
445
446 report_list: DomRefCell<Vec<Report>>,
448
449 #[no_trace]
451 endpoints_list: DomRefCell<Vec<ReportingEndpoint>>,
452
453 #[conditional_malloc_size_of]
455 script_window_proxies: Rc<ScriptWindowProxies>,
456
457 has_pending_screenshot_readiness_request: Cell<bool>,
459}
460
461impl Window {
462 pub(crate) fn webview_id(&self) -> WebViewId {
463 self.webview_id
464 }
465
466 pub(crate) fn as_global_scope(&self) -> &GlobalScope {
467 self.upcast::<GlobalScope>()
468 }
469
470 pub(crate) fn layout(&self) -> Ref<'_, Box<dyn Layout>> {
471 self.layout.borrow()
472 }
473
474 pub(crate) fn layout_mut(&self) -> RefMut<'_, Box<dyn Layout>> {
475 self.layout.borrow_mut()
476 }
477
478 pub(crate) fn get_exists_mut_observer(&self) -> bool {
479 self.exists_mut_observer.get()
480 }
481
482 pub(crate) fn set_exists_mut_observer(&self) {
483 self.exists_mut_observer.set(true);
484 }
485
486 #[allow(unsafe_code)]
487 pub(crate) fn clear_js_runtime_for_script_deallocation(&self) {
488 self.as_global_scope()
489 .remove_web_messaging_and_dedicated_workers_infra();
490 unsafe {
491 *self.js_runtime.borrow_for_script_deallocation() = None;
492 self.window_proxy.set(None);
493 self.current_state.set(WindowState::Zombie);
494 self.as_global_scope()
495 .task_manager()
496 .cancel_all_tasks_and_ignore_future_tasks();
497 }
498 }
499
500 pub(crate) fn discard_browsing_context(&self) {
503 let proxy = match self.window_proxy.get() {
504 Some(proxy) => proxy,
505 None => panic!("Discarding a BC from a window that has none"),
506 };
507 proxy.discard_browsing_context();
508 self.as_global_scope()
512 .task_manager()
513 .cancel_all_tasks_and_ignore_future_tasks();
514 }
515
516 pub(crate) fn time_profiler_chan(&self) -> &TimeProfilerChan {
518 self.globalscope.time_profiler_chan()
519 }
520
521 pub(crate) fn origin(&self) -> &MutableOrigin {
522 self.globalscope.origin()
523 }
524
525 #[allow(unsafe_code)]
526 pub(crate) fn get_cx(&self) -> JSContext {
527 unsafe { JSContext::from_ptr(self.js_runtime.borrow().as_ref().unwrap().cx()) }
528 }
529
530 pub(crate) fn get_js_runtime(&self) -> Ref<'_, Option<Rc<Runtime>>> {
531 self.js_runtime.borrow()
532 }
533
534 pub(crate) fn main_thread_script_chan(&self) -> &Sender<MainThreadScriptMsg> {
535 &self.script_chan
536 }
537
538 pub(crate) fn parent_info(&self) -> Option<PipelineId> {
539 self.parent_info
540 }
541
542 pub(crate) fn new_script_pair(&self) -> (ScriptEventLoopSender, ScriptEventLoopReceiver) {
543 let (sender, receiver) = unbounded();
544 (
545 ScriptEventLoopSender::MainThread(sender),
546 ScriptEventLoopReceiver::MainThread(receiver),
547 )
548 }
549
550 pub(crate) fn event_loop_sender(&self) -> ScriptEventLoopSender {
551 ScriptEventLoopSender::MainThread(self.script_chan.clone())
552 }
553
554 pub(crate) fn image_cache(&self) -> Arc<dyn ImageCache> {
555 self.image_cache.clone()
556 }
557
558 pub(crate) fn window_proxy(&self) -> DomRoot<WindowProxy> {
560 self.window_proxy.get().unwrap()
561 }
562
563 pub(crate) fn append_reporting_observer(&self, reporting_observer: DomRoot<ReportingObserver>) {
564 self.reporting_observer_list
565 .borrow_mut()
566 .push(reporting_observer);
567 }
568
569 pub(crate) fn remove_reporting_observer(&self, reporting_observer: &ReportingObserver) {
570 if let Some(index) = self
571 .reporting_observer_list
572 .borrow()
573 .iter()
574 .position(|observer| &**observer == reporting_observer)
575 {
576 self.reporting_observer_list.borrow_mut().remove(index);
577 }
578 }
579
580 pub(crate) fn registered_reporting_observers(&self) -> Vec<DomRoot<ReportingObserver>> {
581 self.reporting_observer_list.borrow().clone()
582 }
583
584 pub(crate) fn append_report(&self, report: Report) {
585 self.report_list.borrow_mut().push(report);
586 let trusted_window = Trusted::new(self);
587 self.upcast::<GlobalScope>()
588 .task_manager()
589 .dom_manipulation_task_source()
590 .queue(task!(send_to_reporting_endpoints: move || {
591 let window = trusted_window.root();
592 let reports = std::mem::take(&mut *window.report_list.borrow_mut());
593 window.upcast::<GlobalScope>().send_reports_to_endpoints(
594 reports,
595 window.endpoints_list.borrow().clone(),
596 );
597 }));
598 }
599
600 pub(crate) fn buffered_reports(&self) -> Vec<Report> {
601 self.report_list.borrow().clone()
602 }
603
604 pub(crate) fn set_endpoints_list(&self, endpoints: Vec<ReportingEndpoint>) {
605 *self.endpoints_list.borrow_mut() = endpoints;
606 }
607
608 pub(crate) fn undiscarded_window_proxy(&self) -> Option<DomRoot<WindowProxy>> {
611 self.window_proxy.get().and_then(|window_proxy| {
612 if window_proxy.is_browsing_context_discarded() {
613 None
614 } else {
615 Some(window_proxy)
616 }
617 })
618 }
619
620 pub(crate) fn webview_window_proxy(&self) -> Option<DomRoot<WindowProxy>> {
623 self.undiscarded_window_proxy().and_then(|window_proxy| {
624 self.script_window_proxies
625 .find_window_proxy(window_proxy.webview_id().into())
626 })
627 }
628
629 #[cfg(feature = "bluetooth")]
630 pub(crate) fn bluetooth_thread(&self) -> IpcSender<BluetoothRequest> {
631 self.bluetooth_thread.clone()
632 }
633
634 #[cfg(feature = "bluetooth")]
635 pub(crate) fn bluetooth_extra_permission_data(&self) -> &BluetoothExtraPermissionData {
636 &self.bluetooth_extra_permission_data
637 }
638
639 pub(crate) fn css_error_reporter(&self) -> Option<&dyn ParseErrorReporter> {
640 Some(&self.error_reporter)
641 }
642
643 pub(crate) fn webgl_chan(&self) -> Option<WebGLCommandSender> {
644 self.webgl_chan
645 .as_ref()
646 .map(|chan| WebGLCommandSender::new(chan.clone()))
647 }
648
649 #[cfg(feature = "webxr")]
650 pub(crate) fn webxr_registry(&self) -> Option<webxr_api::Registry> {
651 self.webxr_registry.clone()
652 }
653
654 fn new_paint_worklet(&self, can_gc: CanGc) -> DomRoot<Worklet> {
655 debug!("Creating new paint worklet.");
656 Worklet::new(self, WorkletGlobalScopeType::Paint, can_gc)
657 }
658
659 pub(crate) fn register_image_cache_listener(
660 &self,
661 id: PendingImageId,
662 callback: impl Fn(PendingImageResponse) + 'static,
663 ) -> IpcSender<ImageCacheResponseMessage> {
664 self.pending_image_callbacks
665 .borrow_mut()
666 .entry(id)
667 .or_default()
668 .push(PendingImageCallback(Box::new(callback)));
669 self.image_cache_sender.clone()
670 }
671
672 fn pending_layout_image_notification(&self, response: PendingImageResponse) {
673 let mut images = self.pending_layout_images.borrow_mut();
674 let nodes = images.entry(response.id);
675 let nodes = match nodes {
676 Entry::Occupied(nodes) => nodes,
677 Entry::Vacant(_) => return,
678 };
679 if matches!(
680 response.response,
681 ImageResponse::Loaded(_, _) | ImageResponse::PlaceholderLoaded(_, _)
682 ) {
683 for ancillary_data in nodes.get() {
684 match ancillary_data.destination {
685 LayoutImageDestination::BoxTreeConstruction => {
686 ancillary_data.node.dirty(NodeDamage::Other);
687 },
688 LayoutImageDestination::DisplayListBuilding => {
689 self.layout().set_needs_new_display_list();
690 },
691 }
692 }
693 }
694
695 match response.response {
696 ImageResponse::MetadataLoaded(_) => {},
697 ImageResponse::Loaded(_, _) |
698 ImageResponse::PlaceholderLoaded(_, _) |
699 ImageResponse::None => {
700 nodes.remove();
701 },
702 }
703 }
704
705 pub(crate) fn handle_image_rasterization_complete_notification(
706 &self,
707 response: RasterizationCompleteResponse,
708 ) {
709 let mut images = self.pending_images_for_rasterization.borrow_mut();
710 let nodes = images.entry((response.image_id, response.requested_size));
711 let nodes = match nodes {
712 Entry::Occupied(nodes) => nodes,
713 Entry::Vacant(_) => return,
714 };
715 for node in nodes.get() {
716 node.dirty(NodeDamage::Other);
717 }
718 nodes.remove();
719 }
720
721 pub(crate) fn pending_image_notification(&self, response: PendingImageResponse) {
722 let mut images = std::mem::take(&mut *self.pending_image_callbacks.borrow_mut());
727 let Entry::Occupied(callbacks) = images.entry(response.id) else {
728 let _ = std::mem::replace(&mut *self.pending_image_callbacks.borrow_mut(), images);
729 return;
730 };
731
732 for callback in callbacks.get() {
733 callback.0(response.clone());
734 }
735
736 match response.response {
737 ImageResponse::MetadataLoaded(_) => {},
738 ImageResponse::Loaded(_, _) |
739 ImageResponse::PlaceholderLoaded(_, _) |
740 ImageResponse::None => {
741 callbacks.remove();
742 },
743 }
744
745 let _ = std::mem::replace(&mut *self.pending_image_callbacks.borrow_mut(), images);
746 }
747
748 pub(crate) fn compositor_api(&self) -> &CrossProcessCompositorApi {
749 &self.compositor_api
750 }
751
752 pub(crate) fn userscripts(&self) -> &[UserScript] {
753 self.user_content_manager.scripts()
754 }
755
756 pub(crate) fn get_player_context(&self) -> WindowGLContext {
757 self.player_context.clone()
758 }
759
760 pub(crate) fn dispatch_event_with_target_override(&self, event: &Event, can_gc: CanGc) {
762 event.dispatch(self.upcast(), true, can_gc);
763 }
764
765 pub(crate) fn font_context(&self) -> &Arc<FontContext> {
766 self.as_global_scope()
767 .font_context()
768 .expect("A `Window` should always have a `FontContext`")
769 }
770
771 pub(crate) fn ongoing_navigation(&self) -> OngoingNavigation {
772 self.ongoing_navigation.get()
773 }
774
775 pub(crate) fn set_ongoing_navigation(&self) -> OngoingNavigation {
777 let new_value = self.ongoing_navigation.get().0.wrapping_add(1);
781
782 self.ongoing_navigation.set(OngoingNavigation(new_value));
789
790 OngoingNavigation(new_value)
792 }
793
794 fn stop_loading(&self, can_gc: CanGc) {
796 let doc = self.Document();
798
799 self.set_ongoing_navigation();
809
810 doc.abort(can_gc);
812 }
813
814 fn cannot_show_simple_dialogs(&self) -> bool {
816 if self
819 .Document()
820 .has_active_sandboxing_flag(SandboxingFlagSet::SANDBOXED_MODALS_FLAG)
821 {
822 return true;
823 }
824
825 false
844 }
845}
846
847pub(crate) fn base64_btoa(input: DOMString) -> Fallible<DOMString> {
849 if input.str().chars().any(|c: char| c > '\u{FF}') {
853 Err(Error::InvalidCharacter)
854 } else {
855 let octets = input
860 .str()
861 .chars()
862 .map(|c: char| c as u8)
863 .collect::<Vec<u8>>();
864
865 let config =
868 base64::engine::general_purpose::GeneralPurposeConfig::new().with_encode_padding(true);
869 let engine = base64::engine::GeneralPurpose::new(&base64::alphabet::STANDARD, config);
870 Ok(DOMString::from(engine.encode(octets)))
871 }
872}
873
874pub(crate) fn base64_atob(input: DOMString) -> Fallible<DOMString> {
876 fn is_html_space(c: char) -> bool {
878 HTML_SPACE_CHARACTERS.contains(&c)
879 }
880 let without_spaces = input
881 .str()
882 .chars()
883 .filter(|&c| !is_html_space(c))
884 .collect::<String>();
885 let mut input = &*without_spaces;
886
887 if input.len() % 4 == 0 {
891 if input.ends_with("==") {
892 input = &input[..input.len() - 2]
893 } else if input.ends_with('=') {
894 input = &input[..input.len() - 1]
895 }
896 }
897
898 if input.len() % 4 == 1 {
901 return Err(Error::InvalidCharacter);
902 }
903
904 if input
912 .chars()
913 .any(|c| c != '+' && c != '/' && !c.is_alphanumeric())
914 {
915 return Err(Error::InvalidCharacter);
916 }
917
918 let config = base64::engine::general_purpose::GeneralPurposeConfig::new()
919 .with_decode_padding_mode(base64::engine::DecodePaddingMode::RequireNone)
920 .with_decode_allow_trailing_bits(true);
921 let engine = base64::engine::GeneralPurpose::new(&base64::alphabet::STANDARD, config);
922
923 let data = engine.decode(input).map_err(|_| Error::InvalidCharacter)?;
924 Ok(data.iter().map(|&b| b as char).collect::<String>().into())
925}
926
927impl WindowMethods<crate::DomTypeHolder> for Window {
928 fn Alert_(&self) {
930 self.Alert(DOMString::new());
933 }
934
935 fn Alert(&self, mut message: DOMString) {
937 if self.cannot_show_simple_dialogs() {
939 return;
940 }
941
942 message.normalize_newlines();
946
947 {
958 let stderr = stderr();
962 let mut stderr = stderr.lock();
963 let stdout = stdout();
964 let mut stdout = stdout.lock();
965 writeln!(&mut stdout, "\nALERT: {message}").unwrap();
966 stdout.flush().unwrap();
967 stderr.flush().unwrap();
968 }
969
970 let (sender, receiver) =
971 ProfiledGenericChannel::channel(self.global().time_profiler_chan().clone()).unwrap();
972 let dialog = SimpleDialog::Alert {
973 message: message.to_string(),
974 response_sender: sender,
975 };
976 self.send_to_embedder(EmbedderMsg::ShowSimpleDialog(self.webview_id(), dialog));
977 receiver.recv().unwrap_or_else(|_| {
978 debug!("Alert dialog was cancelled or failed to show.");
980 AlertResponse::Ok
981 });
982
983 }
986
987 fn Confirm(&self, mut message: DOMString) -> bool {
989 if self.cannot_show_simple_dialogs() {
991 return false;
992 }
993
994 message.normalize_newlines();
996
997 let (sender, receiver) =
1003 ProfiledGenericChannel::channel(self.global().time_profiler_chan().clone()).unwrap();
1004 let dialog = SimpleDialog::Confirm {
1005 message: message.to_string(),
1006 response_sender: sender,
1007 };
1008 self.send_to_embedder(EmbedderMsg::ShowSimpleDialog(self.webview_id(), dialog));
1009
1010 match receiver.recv() {
1026 Ok(ConfirmResponse::Ok) => true,
1027 Ok(ConfirmResponse::Cancel) => false,
1028 Err(_) => {
1029 warn!("Confirm dialog was cancelled or failed to show.");
1030 false
1031 },
1032 }
1033 }
1034
1035 fn Prompt(&self, mut message: DOMString, default: DOMString) -> Option<DOMString> {
1037 if self.cannot_show_simple_dialogs() {
1039 return None;
1040 }
1041
1042 message.normalize_newlines();
1044
1045 let (sender, receiver) =
1053 ProfiledGenericChannel::channel(self.global().time_profiler_chan().clone()).unwrap();
1054 let dialog = SimpleDialog::Prompt {
1055 message: message.to_string(),
1056 default: default.to_string(),
1057 response_sender: sender,
1058 };
1059 self.send_to_embedder(EmbedderMsg::ShowSimpleDialog(self.webview_id(), dialog));
1060
1061 match receiver.recv() {
1080 Ok(PromptResponse::Ok(input)) => Some(input.into()),
1081 Ok(PromptResponse::Cancel) => None,
1082 Err(_) => {
1083 warn!("Prompt dialog was cancelled or failed to show.");
1084 None
1085 },
1086 }
1087 }
1088
1089 fn Stop(&self, can_gc: CanGc) {
1091 self.stop_loading(can_gc);
1096 }
1097
1098 fn Focus(&self) {
1100 let current = match self.undiscarded_window_proxy() {
1104 Some(proxy) => proxy,
1105 None => return,
1106 };
1107
1108 current.focus();
1110
1111 }
1117
1118 fn Blur(&self) {
1120 }
1123
1124 fn Open(
1126 &self,
1127 url: USVString,
1128 target: DOMString,
1129 features: DOMString,
1130 can_gc: CanGc,
1131 ) -> Fallible<Option<DomRoot<WindowProxy>>> {
1132 self.window_proxy().open(url, target, features, can_gc)
1133 }
1134
1135 fn GetOpener(
1137 &self,
1138 cx: JSContext,
1139 in_realm_proof: InRealm,
1140 mut retval: MutableHandleValue,
1141 ) -> Fallible<()> {
1142 let current = match self.window_proxy.get() {
1144 Some(proxy) => proxy,
1145 None => {
1147 retval.set(NullValue());
1148 return Ok(());
1149 },
1150 };
1151 if current.is_browsing_context_discarded() {
1156 retval.set(NullValue());
1157 return Ok(());
1158 }
1159 current.opener(*cx, in_realm_proof, retval);
1161 Ok(())
1162 }
1163
1164 #[allow(unsafe_code)]
1165 fn SetOpener(&self, cx: JSContext, value: HandleValue) -> ErrorResult {
1167 if value.is_null() {
1169 if let Some(proxy) = self.window_proxy.get() {
1170 proxy.disown();
1171 }
1172 return Ok(());
1173 }
1174 let obj = self.reflector().get_jsobject();
1176 unsafe {
1177 let result =
1178 JS_DefineProperty(*cx, obj, c"opener".as_ptr(), value, JSPROP_ENUMERATE as u32);
1179
1180 if result { Ok(()) } else { Err(Error::JSFailed) }
1181 }
1182 }
1183
1184 fn Closed(&self) -> bool {
1186 self.window_proxy
1187 .get()
1188 .map(|ref proxy| proxy.is_browsing_context_discarded() || proxy.is_closing())
1189 .unwrap_or(true)
1190 }
1191
1192 fn Close(&self) {
1194 let window_proxy = match self.window_proxy.get() {
1197 Some(proxy) => proxy,
1198 None => return,
1199 };
1200 if window_proxy.is_closing() {
1201 return;
1202 }
1203 if let Ok(history_length) = self.History().GetLength() {
1206 let is_auxiliary = window_proxy.is_auxiliary();
1207
1208 let is_script_closable = (self.is_top_level() && history_length == 1) ||
1210 is_auxiliary ||
1211 pref!(dom_allow_scripts_to_close_windows);
1212
1213 if is_script_closable {
1217 window_proxy.close();
1219
1220 let this = Trusted::new(self);
1222 let task = task!(window_close_browsing_context: move || {
1223 let window = this.root();
1224 let document = window.Document();
1225 if document.prompt_to_unload(false, CanGc::note()) {
1231 document.unload(false, CanGc::note());
1233
1234 window.discard_browsing_context();
1237
1238 window.send_to_constellation(ScriptToConstellationMessage::DiscardTopLevelBrowsingContext);
1239 }
1240 });
1241 self.as_global_scope()
1242 .task_manager()
1243 .dom_manipulation_task_source()
1244 .queue(task);
1245 }
1246 }
1247 }
1248
1249 fn Document(&self) -> DomRoot<Document> {
1251 self.document
1252 .get()
1253 .expect("Document accessed before initialization.")
1254 }
1255
1256 fn History(&self) -> DomRoot<History> {
1258 self.history.or_init(|| History::new(self, CanGc::note()))
1259 }
1260
1261 fn IndexedDB(&self) -> DomRoot<IDBFactory> {
1263 self.indexeddb.or_init(|| {
1264 let global_scope = self.upcast::<GlobalScope>();
1265 IDBFactory::new(global_scope, CanGc::note())
1266 })
1267 }
1268
1269 fn CustomElements(&self) -> DomRoot<CustomElementRegistry> {
1271 self.custom_element_registry
1272 .or_init(|| CustomElementRegistry::new(self, CanGc::note()))
1273 }
1274
1275 fn Location(&self) -> DomRoot<Location> {
1277 self.location.or_init(|| Location::new(self, CanGc::note()))
1278 }
1279
1280 fn SessionStorage(&self) -> DomRoot<Storage> {
1282 self.session_storage
1283 .or_init(|| Storage::new(self, StorageType::Session, CanGc::note()))
1284 }
1285
1286 fn LocalStorage(&self) -> DomRoot<Storage> {
1288 self.local_storage
1289 .or_init(|| Storage::new(self, StorageType::Local, CanGc::note()))
1290 }
1291
1292 fn CookieStore(&self, can_gc: CanGc) -> DomRoot<CookieStore> {
1294 self.global().cookie_store(can_gc)
1295 }
1296
1297 fn Crypto(&self) -> DomRoot<Crypto> {
1299 self.as_global_scope().crypto(CanGc::note())
1300 }
1301
1302 fn GetFrameElement(&self) -> Option<DomRoot<Element>> {
1304 let window_proxy = self.window_proxy.get()?;
1306
1307 let container = window_proxy.frame_element()?;
1309
1310 let container_doc = container.owner_document();
1312 let current_doc = GlobalScope::current()
1313 .expect("No current global object")
1314 .as_window()
1315 .Document();
1316 if !current_doc
1317 .origin()
1318 .same_origin_domain(container_doc.origin())
1319 {
1320 return None;
1321 }
1322 Some(DomRoot::from_ref(container))
1324 }
1325
1326 fn Navigator(&self) -> DomRoot<Navigator> {
1328 self.navigator
1329 .or_init(|| Navigator::new(self, CanGc::note()))
1330 }
1331
1332 fn SetTimeout(
1334 &self,
1335 _cx: JSContext,
1336 callback: TrustedScriptOrStringOrFunction,
1337 timeout: i32,
1338 args: Vec<HandleValue>,
1339 can_gc: CanGc,
1340 ) -> Fallible<i32> {
1341 let callback = match callback {
1342 TrustedScriptOrStringOrFunction::String(i) => {
1343 TimerCallback::StringTimerCallback(TrustedScriptOrString::String(i))
1344 },
1345 TrustedScriptOrStringOrFunction::TrustedScript(i) => {
1346 TimerCallback::StringTimerCallback(TrustedScriptOrString::TrustedScript(i))
1347 },
1348 TrustedScriptOrStringOrFunction::Function(i) => TimerCallback::FunctionTimerCallback(i),
1349 };
1350 self.as_global_scope().set_timeout_or_interval(
1351 callback,
1352 args,
1353 Duration::from_millis(timeout.max(0) as u64),
1354 IsInterval::NonInterval,
1355 can_gc,
1356 )
1357 }
1358
1359 fn ClearTimeout(&self, handle: i32) {
1361 self.as_global_scope().clear_timeout_or_interval(handle);
1362 }
1363
1364 fn SetInterval(
1366 &self,
1367 _cx: JSContext,
1368 callback: TrustedScriptOrStringOrFunction,
1369 timeout: i32,
1370 args: Vec<HandleValue>,
1371 can_gc: CanGc,
1372 ) -> Fallible<i32> {
1373 let callback = match callback {
1374 TrustedScriptOrStringOrFunction::String(i) => {
1375 TimerCallback::StringTimerCallback(TrustedScriptOrString::String(i))
1376 },
1377 TrustedScriptOrStringOrFunction::TrustedScript(i) => {
1378 TimerCallback::StringTimerCallback(TrustedScriptOrString::TrustedScript(i))
1379 },
1380 TrustedScriptOrStringOrFunction::Function(i) => TimerCallback::FunctionTimerCallback(i),
1381 };
1382 self.as_global_scope().set_timeout_or_interval(
1383 callback,
1384 args,
1385 Duration::from_millis(timeout.max(0) as u64),
1386 IsInterval::Interval,
1387 can_gc,
1388 )
1389 }
1390
1391 fn ClearInterval(&self, handle: i32) {
1393 self.ClearTimeout(handle);
1394 }
1395
1396 fn QueueMicrotask(&self, callback: Rc<VoidFunction>) {
1398 self.as_global_scope().queue_function_as_microtask(callback);
1399 }
1400
1401 fn CreateImageBitmap(
1403 &self,
1404 image: ImageBitmapSource,
1405 options: &ImageBitmapOptions,
1406 can_gc: CanGc,
1407 ) -> Rc<Promise> {
1408 ImageBitmap::create_image_bitmap(
1409 self.as_global_scope(),
1410 image,
1411 0,
1412 0,
1413 None,
1414 None,
1415 options,
1416 can_gc,
1417 )
1418 }
1419
1420 fn CreateImageBitmap_(
1422 &self,
1423 image: ImageBitmapSource,
1424 sx: i32,
1425 sy: i32,
1426 sw: i32,
1427 sh: i32,
1428 options: &ImageBitmapOptions,
1429 can_gc: CanGc,
1430 ) -> Rc<Promise> {
1431 ImageBitmap::create_image_bitmap(
1432 self.as_global_scope(),
1433 image,
1434 sx,
1435 sy,
1436 Some(sw),
1437 Some(sh),
1438 options,
1439 can_gc,
1440 )
1441 }
1442
1443 fn Window(&self) -> DomRoot<WindowProxy> {
1445 self.window_proxy()
1446 }
1447
1448 fn Self_(&self) -> DomRoot<WindowProxy> {
1450 self.window_proxy()
1451 }
1452
1453 fn Frames(&self) -> DomRoot<WindowProxy> {
1455 self.window_proxy()
1456 }
1457
1458 fn Length(&self) -> u32 {
1460 self.Document().iframes().iter().count() as u32
1461 }
1462
1463 fn GetParent(&self) -> Option<DomRoot<WindowProxy>> {
1465 let window_proxy = self.undiscarded_window_proxy()?;
1467
1468 if let Some(parent) = window_proxy.parent() {
1470 return Some(DomRoot::from_ref(parent));
1471 }
1472 Some(window_proxy)
1474 }
1475
1476 fn GetTop(&self) -> Option<DomRoot<WindowProxy>> {
1478 let window_proxy = self.undiscarded_window_proxy()?;
1480
1481 Some(DomRoot::from_ref(window_proxy.top()))
1483 }
1484
1485 fn Performance(&self) -> DomRoot<Performance> {
1488 self.performance.or_init(|| {
1489 Performance::new(
1490 self.as_global_scope(),
1491 self.navigation_start.get(),
1492 CanGc::note(),
1493 )
1494 })
1495 }
1496
1497 global_event_handlers!();
1499
1500 window_event_handlers!();
1502
1503 fn Screen(&self) -> DomRoot<Screen> {
1505 self.screen.or_init(|| Screen::new(self, CanGc::note()))
1506 }
1507
1508 fn Btoa(&self, btoa: DOMString) -> Fallible<DOMString> {
1510 base64_btoa(btoa)
1511 }
1512
1513 fn Atob(&self, atob: DOMString) -> Fallible<DOMString> {
1515 base64_atob(atob)
1516 }
1517
1518 fn RequestAnimationFrame(&self, callback: Rc<FrameRequestCallback>) -> u32 {
1520 self.Document()
1521 .request_animation_frame(AnimationFrameCallback::FrameRequestCallback { callback })
1522 }
1523
1524 fn CancelAnimationFrame(&self, ident: u32) {
1526 let doc = self.Document();
1527 doc.cancel_animation_frame(ident);
1528 }
1529
1530 fn PostMessage(
1532 &self,
1533 cx: JSContext,
1534 message: HandleValue,
1535 target_origin: USVString,
1536 transfer: CustomAutoRooterGuard<Vec<*mut JSObject>>,
1537 ) -> ErrorResult {
1538 let incumbent = GlobalScope::incumbent().expect("no incumbent global?");
1539 let source = incumbent.as_window();
1540 let source_origin = source.Document().origin().immutable().clone();
1541
1542 self.post_message_impl(&target_origin, source_origin, source, cx, message, transfer)
1543 }
1544
1545 fn PostMessage_(
1547 &self,
1548 cx: JSContext,
1549 message: HandleValue,
1550 options: RootedTraceableBox<WindowPostMessageOptions>,
1551 ) -> ErrorResult {
1552 let mut rooted = CustomAutoRooter::new(
1553 options
1554 .parent
1555 .transfer
1556 .iter()
1557 .map(|js: &RootedTraceableBox<Heap<*mut JSObject>>| js.get())
1558 .collect(),
1559 );
1560 let transfer = CustomAutoRooterGuard::new(*cx, &mut rooted);
1561
1562 let incumbent = GlobalScope::incumbent().expect("no incumbent global?");
1563 let source = incumbent.as_window();
1564
1565 let source_origin = source.Document().origin().immutable().clone();
1566
1567 self.post_message_impl(
1568 &options.targetOrigin,
1569 source_origin,
1570 source,
1571 cx,
1572 message,
1573 transfer,
1574 )
1575 }
1576
1577 fn CaptureEvents(&self) {
1579 }
1581
1582 fn ReleaseEvents(&self) {
1584 }
1586
1587 fn Debug(&self, message: DOMString) {
1589 debug!("{}", message);
1590 }
1591
1592 #[allow(unsafe_code)]
1593 fn Gc(&self) {
1594 unsafe {
1595 JS_GC(*self.get_cx(), GCReason::API);
1596 }
1597 }
1598
1599 #[allow(unsafe_code)]
1600 fn Js_backtrace(&self) {
1601 unsafe {
1602 println!("Current JS stack:");
1603 dump_js_stack(*self.get_cx());
1604 let rust_stack = Backtrace::new();
1605 println!("Current Rust stack:\n{:?}", rust_stack);
1606 }
1607 }
1608
1609 fn WebdriverCallback(&self, cx: JSContext, value: HandleValue, realm: InRealm, can_gc: CanGc) {
1610 let webdriver_script_sender = self.webdriver_script_chan.borrow_mut().take();
1611 if let Some(webdriver_script_sender) = webdriver_script_sender {
1612 let result = jsval_to_webdriver(cx, &self.globalscope, value, realm, can_gc);
1613 let _ = webdriver_script_sender.send(result);
1614 }
1615 }
1616
1617 fn WebdriverException(&self, cx: JSContext, value: HandleValue, can_gc: CanGc) {
1618 let webdriver_script_sender = self.webdriver_script_chan.borrow_mut().take();
1619 if let Some(webdriver_script_sender) = webdriver_script_sender {
1620 let _ =
1621 webdriver_script_sender.send(Err(JavaScriptEvaluationError::EvaluationFailure(
1622 Some(javascript_error_info_from_error_info(
1623 cx,
1624 &ErrorInfo::from_value(value, cx),
1625 value,
1626 can_gc,
1627 )),
1628 )));
1629 }
1630 }
1631
1632 fn WebdriverElement(&self, id: DOMString) -> Option<DomRoot<Element>> {
1633 find_node_by_unique_id_in_document(&self.Document(), id.into()).and_then(Root::downcast)
1634 }
1635
1636 fn WebdriverFrame(&self, browsing_context_id: DOMString) -> Option<DomRoot<WindowProxy>> {
1637 self.Document()
1638 .iframes()
1639 .iter()
1640 .find(|iframe| {
1641 iframe
1642 .browsing_context_id()
1643 .as_ref()
1644 .map(BrowsingContextId::to_string) ==
1645 Some(browsing_context_id.to_string())
1646 })
1647 .and_then(|iframe| iframe.GetContentWindow())
1648 }
1649
1650 fn WebdriverWindow(&self, webview_id: DOMString) -> Option<DomRoot<WindowProxy>> {
1651 let window_proxy = self.window_proxy.get()?;
1652
1653 if window_proxy.browsing_context_id() != window_proxy.webview_id() {
1655 return None;
1656 }
1657
1658 if self.webview_id().to_string() == webview_id {
1659 Some(DomRoot::from_ref(&window_proxy))
1660 } else {
1661 None
1662 }
1663 }
1664
1665 fn WebdriverShadowRoot(&self, id: DOMString) -> Option<DomRoot<ShadowRoot>> {
1666 find_node_by_unique_id_in_document(&self.Document(), id.into()).and_then(Root::downcast)
1667 }
1668
1669 fn GetComputedStyle(
1671 &self,
1672 element: &Element,
1673 pseudo: Option<DOMString>,
1674 ) -> DomRoot<CSSStyleDeclaration> {
1675 let mut is_null = false;
1679
1680 let pseudo = pseudo.map(|mut s| {
1683 s.make_ascii_lowercase();
1684 s
1685 });
1686 let pseudo = match pseudo {
1687 Some(ref pseudo) if pseudo == ":before" || pseudo == "::before" => {
1688 Some(PseudoElement::Before)
1689 },
1690 Some(ref pseudo) if pseudo == ":after" || pseudo == "::after" => {
1691 Some(PseudoElement::After)
1692 },
1693 Some(ref pseudo) if pseudo == "::selection" => Some(PseudoElement::Selection),
1694 Some(ref pseudo) if pseudo == "::marker" => Some(PseudoElement::Marker),
1695 Some(ref pseudo) if pseudo.starts_with(':') => {
1696 is_null = true;
1699 None
1700 },
1701 _ => None,
1702 };
1703
1704 CSSStyleDeclaration::new(
1720 self,
1721 if is_null {
1722 CSSStyleOwner::Null
1723 } else {
1724 CSSStyleOwner::Element(Dom::from_ref(element))
1725 },
1726 pseudo,
1727 CSSModificationAccess::Readonly,
1728 CanGc::note(),
1729 )
1730 }
1731
1732 fn InnerHeight(&self) -> i32 {
1735 self.viewport_details
1736 .get()
1737 .size
1738 .height
1739 .to_i32()
1740 .unwrap_or(0)
1741 }
1742
1743 fn InnerWidth(&self) -> i32 {
1746 self.viewport_details.get().size.width.to_i32().unwrap_or(0)
1747 }
1748
1749 fn ScrollX(&self) -> i32 {
1751 self.scroll_offset().x as i32
1752 }
1753
1754 fn PageXOffset(&self) -> i32 {
1756 self.ScrollX()
1757 }
1758
1759 fn ScrollY(&self) -> i32 {
1761 self.scroll_offset().y as i32
1762 }
1763
1764 fn PageYOffset(&self) -> i32 {
1766 self.ScrollY()
1767 }
1768
1769 fn Scroll(&self, options: &ScrollToOptions) {
1771 let x = options.left.unwrap_or(0.0) as f32;
1776
1777 let y = options.top.unwrap_or(0.0) as f32;
1780
1781 self.scroll(x, y, options.parent.behavior);
1783 }
1784
1785 fn Scroll_(&self, x: f64, y: f64) {
1787 self.scroll(x as f32, y as f32, ScrollBehavior::Auto);
1791 }
1792
1793 fn ScrollTo(&self, options: &ScrollToOptions) {
1798 self.Scroll(options);
1799 }
1800
1801 fn ScrollTo_(&self, x: f64, y: f64) {
1806 self.Scroll_(x, y)
1807 }
1808
1809 fn ScrollBy(&self, options: &ScrollToOptions) {
1811 let mut options = options.clone();
1817 let x = options.left.unwrap_or(0.0);
1818 let x = if x.is_finite() { x } else { 0.0 };
1819 let y = options.top.unwrap_or(0.0);
1820 let y = if y.is_finite() { y } else { 0.0 };
1821
1822 options.left.replace(x + self.ScrollX() as f64);
1824
1825 options.top.replace(y + self.ScrollY() as f64);
1827
1828 self.Scroll(&options)
1830 }
1831
1832 fn ScrollBy_(&self, x: f64, y: f64) {
1834 let mut options = ScrollToOptions::empty();
1838
1839 options.left.replace(x);
1842
1843 options.top.replace(y);
1845
1846 self.ScrollBy(&options);
1848 }
1849
1850 fn ResizeTo(&self, width: i32, height: i32) {
1852 let window_proxy = match self.window_proxy.get() {
1854 Some(proxy) => proxy,
1855 None => return,
1856 };
1857
1858 if !window_proxy.is_auxiliary() {
1861 return;
1862 }
1863
1864 let dpr = self.device_pixel_ratio();
1865 let size = Size2D::new(width, height).to_f32() * dpr;
1866 self.send_to_embedder(EmbedderMsg::ResizeTo(self.webview_id(), size.to_i32()));
1867 }
1868
1869 fn ResizeBy(&self, x: i32, y: i32) {
1871 let size = self.client_window().size();
1872 self.ResizeTo(x + size.width, y + size.height)
1874 }
1875
1876 fn MoveTo(&self, x: i32, y: i32) {
1878 let dpr = self.device_pixel_ratio();
1881 let point = Point2D::new(x, y).to_f32() * dpr;
1882 let msg = EmbedderMsg::MoveTo(self.webview_id(), point.to_i32());
1883 self.send_to_embedder(msg);
1884 }
1885
1886 fn MoveBy(&self, x: i32, y: i32) {
1888 let origin = self.client_window().min;
1889 self.MoveTo(x + origin.x, y + origin.y)
1891 }
1892
1893 fn ScreenX(&self) -> i32 {
1895 self.client_window().min.x
1896 }
1897
1898 fn ScreenY(&self) -> i32 {
1900 self.client_window().min.y
1901 }
1902
1903 fn OuterHeight(&self) -> i32 {
1905 self.client_window().height()
1906 }
1907
1908 fn OuterWidth(&self) -> i32 {
1910 self.client_window().width()
1911 }
1912
1913 fn DevicePixelRatio(&self) -> Finite<f64> {
1915 Finite::wrap(self.device_pixel_ratio().get() as f64)
1916 }
1917
1918 fn Status(&self) -> DOMString {
1920 self.status.borrow().clone()
1921 }
1922
1923 fn SetStatus(&self, status: DOMString) {
1925 *self.status.borrow_mut() = status
1926 }
1927
1928 fn MatchMedia(&self, query: DOMString) -> DomRoot<MediaQueryList> {
1930 let media_query_list = MediaList::parse_media_list(&query.str(), self);
1931 let document = self.Document();
1932 let mql = MediaQueryList::new(&document, media_query_list, CanGc::note());
1933 self.media_query_lists.track(&*mql);
1934 mql
1935 }
1936
1937 fn Fetch(
1939 &self,
1940 input: RequestOrUSVString,
1941 init: RootedTraceableBox<RequestInit>,
1942 comp: InRealm,
1943 can_gc: CanGc,
1944 ) -> Rc<Promise> {
1945 fetch::Fetch(self.upcast(), input, init, comp, can_gc)
1946 }
1947
1948 fn FetchLater(
1950 &self,
1951 input: RequestInfo,
1952 init: RootedTraceableBox<DeferredRequestInit>,
1953 can_gc: CanGc,
1954 ) -> Fallible<DomRoot<FetchLaterResult>> {
1955 fetch::FetchLater(self, input, init, can_gc)
1956 }
1957
1958 #[cfg(feature = "bluetooth")]
1959 fn TestRunner(&self) -> DomRoot<TestRunner> {
1960 self.test_runner
1961 .or_init(|| TestRunner::new(self.upcast(), CanGc::note()))
1962 }
1963
1964 fn RunningAnimationCount(&self) -> u32 {
1965 self.document
1966 .get()
1967 .map_or(0, |d| d.animations().running_animation_count() as u32)
1968 }
1969
1970 fn SetName(&self, name: DOMString) {
1972 if let Some(proxy) = self.undiscarded_window_proxy() {
1973 proxy.set_name(name);
1974 }
1975 }
1976
1977 fn Name(&self) -> DOMString {
1979 match self.undiscarded_window_proxy() {
1980 Some(proxy) => proxy.get_name(),
1981 None => "".into(),
1982 }
1983 }
1984
1985 fn Origin(&self) -> USVString {
1987 USVString(self.origin().immutable().ascii_serialization())
1988 }
1989
1990 fn GetSelection(&self) -> Option<DomRoot<Selection>> {
1992 self.document
1993 .get()
1994 .and_then(|d| d.GetSelection(CanGc::note()))
1995 }
1996
1997 fn Event(&self, cx: JSContext, rval: MutableHandleValue) {
1999 if let Some(ref event) = *self.current_event.borrow() {
2000 event.reflector().get_jsobject().safe_to_jsval(cx, rval);
2001 }
2002 }
2003
2004 fn IsSecureContext(&self) -> bool {
2005 self.as_global_scope().is_secure_context()
2006 }
2007
2008 fn NamedGetter(&self, name: DOMString) -> Option<NamedPropertyValue> {
2010 if name.is_empty() {
2011 return None;
2012 }
2013 let document = self.Document();
2014
2015 let iframes: Vec<_> = document
2017 .iframes()
2018 .iter()
2019 .filter(|iframe| {
2020 if let Some(window) = iframe.GetContentWindow() {
2021 return window.get_name() == name;
2022 }
2023 false
2024 })
2025 .collect();
2026
2027 let iframe_iter = iframes.iter().map(|iframe| iframe.upcast::<Element>());
2028
2029 let name = Atom::from(name);
2030
2031 let elements_with_name = document.get_elements_with_name(&name);
2033 let name_iter = elements_with_name
2034 .iter()
2035 .map(|element| &**element)
2036 .filter(|elem| is_named_element_with_name_attribute(elem));
2037 let elements_with_id = document.get_elements_with_id(&name);
2038 let id_iter = elements_with_id
2039 .iter()
2040 .map(|element| &**element)
2041 .filter(|elem| is_named_element_with_id_attribute(elem));
2042
2043 for elem in iframe_iter.clone() {
2045 if let Some(nested_window_proxy) = elem
2046 .downcast::<HTMLIFrameElement>()
2047 .and_then(|iframe| iframe.GetContentWindow())
2048 {
2049 return Some(NamedPropertyValue::WindowProxy(nested_window_proxy));
2050 }
2051 }
2052
2053 let mut elements = iframe_iter.chain(name_iter).chain(id_iter);
2054
2055 let first = elements.next()?;
2056
2057 if elements.next().is_none() {
2058 return Some(NamedPropertyValue::Element(DomRoot::from_ref(first)));
2060 }
2061
2062 #[derive(JSTraceable, MallocSizeOf)]
2064 struct WindowNamedGetter {
2065 #[no_trace]
2066 name: Atom,
2067 }
2068 impl CollectionFilter for WindowNamedGetter {
2069 fn filter(&self, elem: &Element, _root: &Node) -> bool {
2070 let type_ = match elem.upcast::<Node>().type_id() {
2071 NodeTypeId::Element(ElementTypeId::HTMLElement(type_)) => type_,
2072 _ => return false,
2073 };
2074 if elem.get_id().as_ref() == Some(&self.name) {
2075 return true;
2076 }
2077 match type_ {
2078 HTMLElementTypeId::HTMLEmbedElement |
2079 HTMLElementTypeId::HTMLFormElement |
2080 HTMLElementTypeId::HTMLImageElement |
2081 HTMLElementTypeId::HTMLObjectElement => {
2082 elem.get_name().as_ref() == Some(&self.name)
2083 },
2084 _ => false,
2085 }
2086 }
2087 }
2088 let collection = HTMLCollection::create(
2089 self,
2090 document.upcast(),
2091 Box::new(WindowNamedGetter { name }),
2092 CanGc::note(),
2093 );
2094 Some(NamedPropertyValue::HTMLCollection(collection))
2095 }
2096
2097 fn SupportedPropertyNames(&self) -> Vec<DOMString> {
2099 let mut names_with_first_named_element_map: HashMap<&Atom, &Element> = HashMap::new();
2100
2101 let document = self.Document();
2102 let name_map = document.name_map();
2103 for (name, elements) in &name_map.0 {
2104 if name.is_empty() {
2105 continue;
2106 }
2107 let mut name_iter = elements
2108 .iter()
2109 .filter(|elem| is_named_element_with_name_attribute(elem));
2110 if let Some(first) = name_iter.next() {
2111 names_with_first_named_element_map.insert(name, first);
2112 }
2113 }
2114 let id_map = document.id_map();
2115 for (id, elements) in &id_map.0 {
2116 if id.is_empty() {
2117 continue;
2118 }
2119 let mut id_iter = elements
2120 .iter()
2121 .filter(|elem| is_named_element_with_id_attribute(elem));
2122 if let Some(first) = id_iter.next() {
2123 match names_with_first_named_element_map.entry(id) {
2124 Entry::Vacant(entry) => drop(entry.insert(first)),
2125 Entry::Occupied(mut entry) => {
2126 if first.upcast::<Node>().is_before(entry.get().upcast()) {
2127 *entry.get_mut() = first;
2128 }
2129 },
2130 }
2131 }
2132 }
2133
2134 let mut names_with_first_named_element_vec: Vec<(&Atom, &Element)> =
2135 names_with_first_named_element_map
2136 .iter()
2137 .map(|(k, v)| (*k, *v))
2138 .collect();
2139 names_with_first_named_element_vec.sort_unstable_by(|a, b| {
2140 if a.1 == b.1 {
2141 a.0.cmp(b.0)
2144 } else if a.1.upcast::<Node>().is_before(b.1.upcast::<Node>()) {
2145 cmp::Ordering::Less
2146 } else {
2147 cmp::Ordering::Greater
2148 }
2149 });
2150
2151 names_with_first_named_element_vec
2152 .iter()
2153 .map(|(k, _v)| DOMString::from(&***k))
2154 .collect()
2155 }
2156
2157 fn StructuredClone(
2159 &self,
2160 cx: JSContext,
2161 value: HandleValue,
2162 options: RootedTraceableBox<StructuredSerializeOptions>,
2163 retval: MutableHandleValue,
2164 ) -> Fallible<()> {
2165 self.as_global_scope()
2166 .structured_clone(cx, value, options, retval)
2167 }
2168
2169 fn TrustedTypes(&self, can_gc: CanGc) -> DomRoot<TrustedTypePolicyFactory> {
2170 self.trusted_types
2171 .or_init(|| TrustedTypePolicyFactory::new(self.as_global_scope(), can_gc))
2172 }
2173}
2174
2175impl Window {
2176 pub(crate) fn scroll_offset(&self) -> Vector2D<f32, LayoutPixel> {
2177 self.scroll_offset_query_with_external_scroll_id(self.pipeline_id().root_scroll_id())
2178 }
2179
2180 #[allow(unsafe_code)]
2183 pub(crate) fn create_named_properties_object(
2184 cx: JSContext,
2185 proto: HandleObject,
2186 object: MutableHandleObject,
2187 ) {
2188 window_named_properties::create(cx, proto, object)
2189 }
2190
2191 pub(crate) fn current_event(&self) -> Option<DomRoot<Event>> {
2192 self.current_event
2193 .borrow()
2194 .as_ref()
2195 .map(|e| DomRoot::from_ref(&**e))
2196 }
2197
2198 pub(crate) fn set_current_event(&self, event: Option<&Event>) -> Option<DomRoot<Event>> {
2199 let current = self.current_event();
2200 *self.current_event.borrow_mut() = event.map(Dom::from_ref);
2201 current
2202 }
2203
2204 fn post_message_impl(
2206 &self,
2207 target_origin: &USVString,
2208 source_origin: ImmutableOrigin,
2209 source: &Window,
2210 cx: JSContext,
2211 message: HandleValue,
2212 transfer: CustomAutoRooterGuard<Vec<*mut JSObject>>,
2213 ) -> ErrorResult {
2214 let data = structuredclone::write(cx, message, Some(transfer))?;
2216
2217 let target_origin = match target_origin.0[..].as_ref() {
2219 "*" => None,
2220 "/" => Some(source_origin.clone()),
2221 url => match ServoUrl::parse(url) {
2222 Ok(url) => Some(url.origin().clone()),
2223 Err(_) => return Err(Error::Syntax(None)),
2224 },
2225 };
2226
2227 self.post_message(target_origin, source_origin, &source.window_proxy(), data);
2229 Ok(())
2230 }
2231
2232 pub(crate) fn paint_worklet(&self) -> DomRoot<Worklet> {
2234 self.paint_worklet
2235 .or_init(|| self.new_paint_worklet(CanGc::note()))
2236 }
2237
2238 pub(crate) fn has_document(&self) -> bool {
2239 self.document.get().is_some()
2240 }
2241
2242 pub(crate) fn clear_js_runtime(&self) {
2243 self.as_global_scope()
2244 .remove_web_messaging_and_dedicated_workers_infra();
2245
2246 if let Some(custom_elements) = self.custom_element_registry.get() {
2249 custom_elements.teardown();
2250 }
2251
2252 self.current_state.set(WindowState::Zombie);
2253 *self.js_runtime.borrow_mut() = None;
2254
2255 if let Some(proxy) = self.window_proxy.get() {
2258 let pipeline_id = self.pipeline_id();
2259 if let Some(currently_active) = proxy.currently_active() {
2260 if currently_active == pipeline_id {
2261 self.window_proxy.set(None);
2262 }
2263 }
2264 }
2265
2266 if let Some(performance) = self.performance.get() {
2267 performance.clear_and_disable_performance_entry_buffer();
2268 }
2269 self.as_global_scope()
2270 .task_manager()
2271 .cancel_all_tasks_and_ignore_future_tasks();
2272 }
2273
2274 pub(crate) fn scroll(&self, x: f32, y: f32, behavior: ScrollBehavior) {
2276 let xfinite = if x.is_finite() { x } else { 0.0 };
2278 let yfinite = if y.is_finite() { y } else { 0.0 };
2279
2280 let viewport = self.viewport_details.get().size;
2290
2291 let scrolling_area = self.scrolling_area_query(None).to_f32();
2310 let x = xfinite.clamp(0.0, 0.0f32.max(scrolling_area.width() - viewport.width));
2311 let y = yfinite.clamp(0.0, 0.0f32.max(scrolling_area.height() - viewport.height));
2312
2313 let scroll_offset = self.scroll_offset();
2316 if x == scroll_offset.x && y == scroll_offset.y {
2317 return;
2318 }
2319
2320 self.perform_a_scroll(x, y, self.pipeline_id().root_scroll_id(), behavior, None);
2325 }
2326
2327 pub(crate) fn perform_a_scroll(
2329 &self,
2330 x: f32,
2331 y: f32,
2332 scroll_id: ExternalScrollId,
2333 _behavior: ScrollBehavior,
2334 element: Option<&Element>,
2335 ) {
2336 let reflow_phases_run =
2340 self.reflow(ReflowGoal::UpdateScrollNode(scroll_id, Vector2D::new(x, y)));
2341 if reflow_phases_run.needs_frame() {
2342 self.compositor_api().generate_frame();
2343 }
2344
2345 if reflow_phases_run.contains(ReflowPhasesRun::UpdatedScrollNodeOffset) {
2350 match element {
2351 Some(el) => self.Document().handle_element_scroll_event(el),
2352 None => self.Document().handle_viewport_scroll_event(),
2353 };
2354 }
2355 }
2356
2357 pub(crate) fn device_pixel_ratio(&self) -> Scale<f32, CSSPixel, DevicePixel> {
2358 self.viewport_details.get().hidpi_scale_factor
2359 }
2360
2361 fn client_window(&self) -> DeviceIndependentIntRect {
2362 let (sender, receiver) = generic_channel::channel().expect("Failed to create IPC channel!");
2363
2364 self.send_to_embedder(EmbedderMsg::GetWindowRect(self.webview_id(), sender));
2365
2366 receiver.recv().unwrap_or_default()
2367 }
2368
2369 #[allow(unsafe_code)]
2372 pub(crate) fn advance_animation_clock(&self, delta_ms: i32) {
2373 self.Document()
2374 .advance_animation_timeline_for_testing(delta_ms as f64 / 1000.);
2375 ScriptThread::handle_tick_all_animations_for_testing(self.pipeline_id());
2376 }
2377
2378 pub(crate) fn reflow(&self, reflow_goal: ReflowGoal) -> ReflowPhasesRun {
2386 let document = self.Document();
2387
2388 if !document.is_fully_active() {
2390 return ReflowPhasesRun::empty();
2391 }
2392
2393 self.Document().ensure_safe_to_run_script_or_layout();
2394
2395 let pipeline_id = self.pipeline_id();
2399 if reflow_goal == ReflowGoal::UpdateTheRendering &&
2400 self.layout_blocker.get().layout_blocked()
2401 {
2402 debug!("Suppressing pre-load-event reflow pipeline {pipeline_id}");
2403 return ReflowPhasesRun::empty();
2404 }
2405
2406 debug!("script: performing reflow for goal {reflow_goal:?}");
2407 let marker = if self.need_emit_timeline_marker(TimelineMarkerType::Reflow) {
2408 Some(TimelineMarker::start("Reflow".to_owned()))
2409 } else {
2410 None
2411 };
2412
2413 let restyle_reason = document.restyle_reason();
2414 document.clear_restyle_reasons();
2415 let restyle = if restyle_reason.needs_restyle() {
2416 debug!("Invalidating layout cache due to reflow condition {restyle_reason:?}",);
2417 self.layout_marker.borrow().set(false);
2419 *self.layout_marker.borrow_mut() = Rc::new(Cell::new(true));
2421
2422 let stylesheets_changed = document.flush_stylesheets_for_reflow();
2423 let pending_restyles = document.drain_pending_restyles();
2424 let dirty_root = document
2425 .take_dirty_root()
2426 .filter(|_| !stylesheets_changed)
2427 .or_else(|| document.GetDocumentElement())
2428 .map(|root| root.upcast::<Node>().to_trusted_node_address());
2429
2430 Some(ReflowRequestRestyle {
2431 reason: restyle_reason,
2432 dirty_root,
2433 stylesheets_changed,
2434 pending_restyles,
2435 })
2436 } else {
2437 None
2438 };
2439
2440 let reflow = ReflowRequest {
2441 document: document.upcast::<Node>().to_trusted_node_address(),
2442 epoch: document.current_rendering_epoch(),
2443 restyle,
2444 viewport_details: self.viewport_details.get(),
2445 origin: self.origin().immutable().clone(),
2446 reflow_goal,
2447 dom_count: document.dom_count(),
2448 animation_timeline_value: document.current_animation_timeline_value(),
2449 animations: document.animations().sets.clone(),
2450 animating_images: document.image_animation_manager().animating_images(),
2451 theme: self.theme.get(),
2452 highlighted_dom_node: document.highlighted_dom_node().map(|node| node.to_opaque()),
2453 };
2454
2455 let Some(reflow_result) = self.layout.borrow_mut().reflow(reflow) else {
2456 return ReflowPhasesRun::empty();
2457 };
2458
2459 debug!("script: layout complete");
2460 if let Some(marker) = marker {
2461 self.emit_timeline_marker(marker.end());
2462 }
2463
2464 self.handle_pending_images_post_reflow(
2465 reflow_result.pending_images,
2466 reflow_result.pending_rasterization_images,
2467 reflow_result.pending_svg_elements_for_serialization,
2468 );
2469
2470 if let Some(iframe_sizes) = reflow_result.iframe_sizes {
2471 document
2472 .iframes_mut()
2473 .handle_new_iframe_sizes_after_layout(self, iframe_sizes);
2474 }
2475
2476 document.update_animations_post_reflow();
2477
2478 reflow_result.reflow_phases_run
2479 }
2480
2481 pub(crate) fn request_screenshot_readiness(&self) {
2482 self.has_pending_screenshot_readiness_request.set(true);
2483 self.maybe_resolve_pending_screenshot_readiness_requests();
2484 }
2485
2486 pub(crate) fn maybe_resolve_pending_screenshot_readiness_requests(&self) {
2487 let pending_request = self.has_pending_screenshot_readiness_request.get();
2488 if !pending_request {
2489 return;
2490 }
2491
2492 let document = self.Document();
2493 if document.ReadyState() != DocumentReadyState::Complete {
2494 return;
2495 }
2496
2497 if document.render_blocking_element_count() > 0 {
2498 return;
2499 }
2500
2501 if document.GetDocumentElement().is_some_and(|elem| {
2505 elem.has_class(&atom!("reftest-wait"), CaseSensitivity::CaseSensitive) ||
2506 elem.has_class(&Atom::from("test-wait"), CaseSensitivity::CaseSensitive)
2507 }) {
2508 return;
2509 }
2510
2511 if self.font_context().web_fonts_still_loading() != 0 {
2512 return;
2513 }
2514
2515 if !self.pending_layout_images.borrow().is_empty() ||
2516 !self.pending_images_for_rasterization.borrow().is_empty()
2517 {
2518 return;
2519 }
2520
2521 let document = self.Document();
2522 if document.needs_rendering_update() {
2523 return;
2524 }
2525
2526 let epoch = document.current_rendering_epoch();
2529 let pipeline_id = self.pipeline_id();
2530 debug!("Ready to take screenshot of {pipeline_id:?} at epoch={epoch:?}");
2531
2532 self.send_to_constellation(
2533 ScriptToConstellationMessage::RespondToScreenshotReadinessRequest(
2534 ScreenshotReadinessResponse::Ready(epoch),
2535 ),
2536 );
2537 self.has_pending_screenshot_readiness_request.set(false);
2538 }
2539
2540 pub(crate) fn reflow_if_reflow_timer_expired(&self) {
2543 if !matches!(
2546 self.layout_blocker.get(),
2547 LayoutBlocker::Parsing(instant) if instant + INITIAL_REFLOW_DELAY < Instant::now()
2548 ) {
2549 return;
2550 }
2551 self.allow_layout_if_necessary();
2552 }
2553
2554 pub(crate) fn prevent_layout_until_load_event(&self) {
2558 if !matches!(self.layout_blocker.get(), LayoutBlocker::WaitingForParse) {
2561 return;
2562 }
2563
2564 self.layout_blocker
2565 .set(LayoutBlocker::Parsing(Instant::now()));
2566 }
2567
2568 pub(crate) fn allow_layout_if_necessary(&self) {
2571 if matches!(
2572 self.layout_blocker.get(),
2573 LayoutBlocker::FiredLoadEventOrParsingTimerExpired
2574 ) {
2575 return;
2576 }
2577
2578 self.layout_blocker
2579 .set(LayoutBlocker::FiredLoadEventOrParsingTimerExpired);
2580
2581 if self.Document().update_the_rendering().needs_frame() {
2593 self.compositor_api().generate_frame();
2594 }
2595 }
2596
2597 pub(crate) fn layout_blocked(&self) -> bool {
2598 self.layout_blocker.get().layout_blocked()
2599 }
2600
2601 pub(crate) fn layout_reflow(&self, query_msg: QueryMsg) {
2603 self.reflow(ReflowGoal::LayoutQuery(query_msg));
2604 }
2605
2606 pub(crate) fn resolved_font_style_query(
2607 &self,
2608 node: &Node,
2609 value: String,
2610 ) -> Option<ServoArc<Font>> {
2611 self.layout_reflow(QueryMsg::ResolvedFontStyleQuery);
2612
2613 let document = self.Document();
2614 let animations = document.animations().sets.clone();
2615 self.layout.borrow().query_resolved_font_style(
2616 node.to_trusted_node_address(),
2617 &value,
2618 animations,
2619 document.current_animation_timeline_value(),
2620 )
2621 }
2622
2623 pub(crate) fn box_area_query_without_reflow(
2628 &self,
2629 node: &Node,
2630 area: BoxAreaType,
2631 ) -> Option<UntypedRect<Au>> {
2632 let layout = self.layout.borrow();
2633 layout.ensure_stacking_context_tree(self.viewport_details.get());
2634 layout.query_box_area(node.to_trusted_node_address(), area)
2635 }
2636
2637 pub(crate) fn box_area_query(&self, node: &Node, area: BoxAreaType) -> Option<UntypedRect<Au>> {
2638 self.layout_reflow(QueryMsg::BoxArea);
2639 self.box_area_query_without_reflow(node, area)
2640 }
2641
2642 pub(crate) fn box_areas_query(&self, node: &Node, area: BoxAreaType) -> Vec<UntypedRect<Au>> {
2643 self.layout_reflow(QueryMsg::BoxAreas);
2644 self.layout
2645 .borrow()
2646 .query_box_areas(node.to_trusted_node_address(), area)
2647 }
2648
2649 pub(crate) fn client_rect_query(&self, node: &Node) -> UntypedRect<i32> {
2650 self.layout_reflow(QueryMsg::ClientRectQuery);
2651 self.layout
2652 .borrow()
2653 .query_client_rect(node.to_trusted_node_address())
2654 }
2655
2656 pub(crate) fn scrolling_area_query(&self, node: Option<&Node>) -> UntypedRect<i32> {
2659 self.layout_reflow(QueryMsg::ScrollingAreaOrOffsetQuery);
2660 self.layout
2661 .borrow()
2662 .query_scrolling_area(node.map(Node::to_trusted_node_address))
2663 }
2664
2665 pub(crate) fn scroll_offset_query(&self, node: &Node) -> Vector2D<f32, LayoutPixel> {
2666 let external_scroll_id = ExternalScrollId(
2667 combine_id_with_fragment_type(node.to_opaque().id(), FragmentType::FragmentBody),
2668 self.pipeline_id().into(),
2669 );
2670 self.scroll_offset_query_with_external_scroll_id(external_scroll_id)
2671 }
2672
2673 fn scroll_offset_query_with_external_scroll_id(
2674 &self,
2675 external_scroll_id: ExternalScrollId,
2676 ) -> Vector2D<f32, LayoutPixel> {
2677 self.layout_reflow(QueryMsg::ScrollingAreaOrOffsetQuery);
2678 self.scroll_offset_query_with_external_scroll_id_no_reflow(external_scroll_id)
2679 }
2680
2681 fn scroll_offset_query_with_external_scroll_id_no_reflow(
2682 &self,
2683 external_scroll_id: ExternalScrollId,
2684 ) -> Vector2D<f32, LayoutPixel> {
2685 self.layout
2686 .borrow()
2687 .scroll_offset(external_scroll_id)
2688 .unwrap_or_default()
2689 }
2690
2691 pub(crate) fn scroll_an_element(
2694 &self,
2695 element: &Element,
2696 x: f32,
2697 y: f32,
2698 behavior: ScrollBehavior,
2699 ) {
2700 let scroll_id = ExternalScrollId(
2701 combine_id_with_fragment_type(
2702 element.upcast::<Node>().to_opaque().id(),
2703 FragmentType::FragmentBody,
2704 ),
2705 self.pipeline_id().into(),
2706 );
2707
2708 self.perform_a_scroll(x, y, scroll_id, behavior, Some(element));
2712 }
2713
2714 pub(crate) fn resolved_style_query(
2715 &self,
2716 element: TrustedNodeAddress,
2717 pseudo: Option<PseudoElement>,
2718 property: PropertyId,
2719 ) -> DOMString {
2720 self.layout_reflow(QueryMsg::ResolvedStyleQuery);
2721
2722 let document = self.Document();
2723 let animations = document.animations().sets.clone();
2724 DOMString::from(self.layout.borrow().query_resolved_style(
2725 element,
2726 pseudo,
2727 property,
2728 animations,
2729 document.current_animation_timeline_value(),
2730 ))
2731 }
2732
2733 pub(crate) fn get_iframe_viewport_details_if_known(
2737 &self,
2738 browsing_context_id: BrowsingContextId,
2739 ) -> Option<ViewportDetails> {
2740 self.layout_reflow(QueryMsg::InnerWindowDimensionsQuery);
2742 self.Document()
2743 .iframes()
2744 .get(browsing_context_id)
2745 .and_then(|iframe| iframe.size)
2746 }
2747
2748 #[allow(unsafe_code)]
2749 pub(crate) fn offset_parent_query(
2750 &self,
2751 node: &Node,
2752 ) -> (Option<DomRoot<Element>>, UntypedRect<Au>) {
2753 self.layout_reflow(QueryMsg::OffsetParentQuery);
2754 let response = self
2755 .layout
2756 .borrow()
2757 .query_offset_parent(node.to_trusted_node_address());
2758 let element = response.node_address.and_then(|parent_node_address| {
2759 let node = unsafe { from_untrusted_node_address(parent_node_address) };
2760 DomRoot::downcast(node)
2761 });
2762 (element, response.rect)
2763 }
2764
2765 pub(crate) fn scroll_container_query(
2766 &self,
2767 node: Option<&Node>,
2768 flags: ScrollContainerQueryFlags,
2769 ) -> Option<ScrollContainerResponse> {
2770 self.layout_reflow(QueryMsg::ScrollParentQuery);
2771 self.layout
2772 .borrow()
2773 .query_scroll_container(node.map(Node::to_trusted_node_address), flags)
2774 }
2775
2776 #[allow(unsafe_code)]
2777 pub(crate) fn scrolling_box_query(
2778 &self,
2779 node: Option<&Node>,
2780 flags: ScrollContainerQueryFlags,
2781 ) -> Option<ScrollingBox> {
2782 self.scroll_container_query(node, flags)
2783 .and_then(|response| {
2784 Some(match response {
2785 ScrollContainerResponse::Viewport(overflow) => {
2786 (ScrollingBoxSource::Viewport(self.Document()), overflow)
2787 },
2788 ScrollContainerResponse::Element(parent_node_address, overflow) => {
2789 let node = unsafe { from_untrusted_node_address(parent_node_address) };
2790 (
2791 ScrollingBoxSource::Element(DomRoot::downcast(node)?),
2792 overflow,
2793 )
2794 },
2795 })
2796 })
2797 .map(|(source, overflow)| ScrollingBox::new(source, overflow))
2798 }
2799
2800 pub(crate) fn text_index_query(
2801 &self,
2802 node: &Node,
2803 point_in_node: UntypedPoint2D<f32>,
2804 ) -> Option<usize> {
2805 self.layout_reflow(QueryMsg::TextIndexQuery);
2806 self.layout
2807 .borrow()
2808 .query_text_indext(node.to_opaque(), point_in_node)
2809 }
2810
2811 pub(crate) fn elements_from_point_query(
2812 &self,
2813 point: LayoutPoint,
2814 flags: ElementsFromPointFlags,
2815 ) -> Vec<ElementsFromPointResult> {
2816 self.layout_reflow(QueryMsg::ElementsFromPoint);
2817 self.layout().query_elements_from_point(point, flags)
2818 }
2819
2820 pub(crate) fn hit_test_from_input_event(
2821 &self,
2822 input_event: &ConstellationInputEvent,
2823 ) -> Option<HitTestResult> {
2824 self.hit_test_from_point_in_viewport(
2825 input_event.hit_test_result.as_ref()?.point_in_viewport,
2826 )
2827 }
2828
2829 #[allow(unsafe_code)]
2830 pub(crate) fn hit_test_from_point_in_viewport(
2831 &self,
2832 point_in_frame: Point2D<f32, CSSPixel>,
2833 ) -> Option<HitTestResult> {
2834 let result = self
2835 .elements_from_point_query(point_in_frame.cast_unit(), ElementsFromPointFlags::empty())
2836 .into_iter()
2837 .nth(0)?;
2838
2839 let point_relative_to_initial_containing_block =
2840 point_in_frame + self.scroll_offset().cast_unit();
2841
2842 let address = UntrustedNodeAddress(result.node.0 as *const c_void);
2845 Some(HitTestResult {
2846 node: unsafe { from_untrusted_node_address(address) },
2847 cursor: result.cursor,
2848 point_in_node: result.point_in_target,
2849 point_in_frame,
2850 point_relative_to_initial_containing_block,
2851 })
2852 }
2853
2854 #[allow(unsafe_code)]
2855 pub(crate) fn init_window_proxy(&self, window_proxy: &WindowProxy) {
2856 assert!(self.window_proxy.get().is_none());
2857 self.window_proxy.set(Some(window_proxy));
2858 }
2859
2860 #[allow(unsafe_code)]
2861 pub(crate) fn init_document(&self, document: &Document) {
2862 assert!(self.document.get().is_none());
2863 assert!(document.window() == self);
2864 self.document.set(Some(document));
2865
2866 if self.unminify_css {
2867 *self.unminified_css_dir.borrow_mut() = Some(unminified_path("unminified-css"));
2868 }
2869 }
2870
2871 pub(crate) fn load_url(
2875 &self,
2876 history_handling: NavigationHistoryBehavior,
2877 force_reload: bool,
2878 load_data: LoadData,
2879 can_gc: CanGc,
2880 ) {
2881 let doc = self.Document();
2882
2883 let initiator_origin_snapshot = &load_data.load_origin;
2885
2886 if !force_reload &&
2889 load_data.url.as_url()[..Position::AfterQuery] ==
2890 doc.url().as_url()[..Position::AfterQuery]
2891 {
2892 if let Some(fragment) = load_data.url.fragment() {
2895 let webdriver_sender = self.webdriver_load_status_sender.borrow().clone();
2896 if let Some(ref sender) = webdriver_sender {
2897 let _ = sender.send(WebDriverLoadStatus::NavigationStart);
2898 }
2899
2900 self.send_to_constellation(ScriptToConstellationMessage::NavigatedToFragment(
2901 load_data.url.clone(),
2902 history_handling,
2903 ));
2904 doc.check_and_scroll_fragment(fragment);
2905 let this = Trusted::new(self);
2906 let old_url = doc.url().into_string();
2907 let new_url = load_data.url.clone().into_string();
2908 let task = task!(hashchange_event: move || {
2909 let this = this.root();
2910 let event = HashChangeEvent::new(
2911 &this,
2912 atom!("hashchange"),
2913 false,
2914 false,
2915 old_url,
2916 new_url,
2917 CanGc::note());
2918 event.upcast::<Event>().fire(this.upcast::<EventTarget>(), CanGc::note());
2919 if let Some(sender) = webdriver_sender {
2920 let _ = sender.send(WebDriverLoadStatus::NavigationStop);
2921 }
2922 });
2923 self.as_global_scope()
2924 .task_manager()
2925 .dom_manipulation_task_source()
2926 .queue(task);
2927 doc.set_url(load_data.url.clone());
2928 return;
2929 }
2930 }
2931
2932 let pipeline_id = self.pipeline_id();
2934 let window_proxy = self.window_proxy();
2935 if let Some(active) = window_proxy.currently_active() {
2936 if pipeline_id == active && doc.is_prompting_or_unloading() {
2937 return;
2938 }
2939 }
2940
2941 if doc.prompt_to_unload(false, can_gc) {
2943 let window_proxy = self.window_proxy();
2944 if window_proxy.parent().is_some() {
2945 window_proxy.start_delaying_load_events_mode();
2949 }
2950
2951 let resolved_history_handling = if history_handling == NavigationHistoryBehavior::Auto {
2953 if let LoadOrigin::Script(initiator_origin) = initiator_origin_snapshot {
2959 if load_data.url == doc.url() && initiator_origin.same_origin(doc.origin()) {
2960 NavigationHistoryBehavior::Replace
2961 } else {
2962 NavigationHistoryBehavior::Push
2963 }
2964 } else {
2965 NavigationHistoryBehavior::Push
2967 }
2968 } else if load_data.url.scheme() == "javascript" || doc.is_initial_about_blank() {
2971 NavigationHistoryBehavior::Replace
2972 } else {
2973 NavigationHistoryBehavior::Push
2974 };
2975
2976 if let Some(sender) = self.webdriver_load_status_sender.borrow().as_ref() {
2977 let _ = sender.send(WebDriverLoadStatus::NavigationStart);
2978 }
2979
2980 ScriptThread::navigate(pipeline_id, load_data, resolved_history_handling);
2982 };
2983 }
2984
2985 pub(crate) fn set_viewport_details(&self, size: ViewportDetails) {
2986 self.viewport_details.set(size);
2987 }
2988
2989 pub(crate) fn viewport_details(&self) -> ViewportDetails {
2990 self.viewport_details.get()
2991 }
2992
2993 pub(crate) fn theme(&self) -> Theme {
2995 self.theme.get()
2996 }
2997
2998 pub(crate) fn handle_theme_change(&self, new_theme: Theme) {
3000 if self.theme.get() == new_theme {
3001 return;
3002 }
3003 self.theme.set(new_theme);
3004 self.Document()
3005 .add_restyle_reason(RestyleReason::ThemeChanged);
3006 }
3007
3008 pub(crate) fn get_url(&self) -> ServoUrl {
3009 self.Document().url()
3010 }
3011
3012 pub(crate) fn windowproxy_handler(&self) -> &'static WindowProxyHandler {
3013 self.dom_static.windowproxy_handler
3014 }
3015
3016 pub(crate) fn add_resize_event(&self, event: ViewportDetails, event_type: WindowSizeType) {
3017 *self.unhandled_resize_event.borrow_mut() = Some((event, event_type))
3020 }
3021
3022 pub(crate) fn take_unhandled_resize_event(&self) -> Option<(ViewportDetails, WindowSizeType)> {
3023 self.unhandled_resize_event.borrow_mut().take()
3024 }
3025
3026 pub(crate) fn has_unhandled_resize_event(&self) -> bool {
3028 self.unhandled_resize_event.borrow().is_some()
3029 }
3030
3031 pub(crate) fn set_viewport_size(&self, new_viewport_size: UntypedSize2D<f32>) {
3032 let new_viewport_size = Size2D::new(
3033 Au::from_f32_px(new_viewport_size.width),
3034 Au::from_f32_px(new_viewport_size.height),
3035 );
3036 if new_viewport_size == self.current_viewport_size.get() {
3037 return;
3038 }
3039
3040 self.current_viewport_size.set(new_viewport_size);
3041
3042 self.Document()
3045 .add_restyle_reason(RestyleReason::ViewportSizeChanged);
3046
3047 if self.layout().device().used_viewport_units() {
3050 self.Document().dirty_all_nodes();
3051 }
3052 }
3053
3054 pub(crate) fn suspend(&self, can_gc: CanGc) {
3055 self.as_global_scope().suspend();
3057
3058 if self.window_proxy().currently_active() == Some(self.global().pipeline_id()) {
3060 self.window_proxy().unset_currently_active(can_gc);
3061 }
3062
3063 self.Gc();
3068 }
3069
3070 pub(crate) fn resume(&self, can_gc: CanGc) {
3071 self.as_global_scope().resume();
3073
3074 self.window_proxy().set_currently_active(self, can_gc);
3076
3077 self.Document().title_changed();
3080 }
3081
3082 pub(crate) fn need_emit_timeline_marker(&self, timeline_type: TimelineMarkerType) -> bool {
3083 let markers = self.devtools_markers.borrow();
3084 markers.contains(&timeline_type)
3085 }
3086
3087 pub(crate) fn emit_timeline_marker(&self, marker: TimelineMarker) {
3088 let sender = self.devtools_marker_sender.borrow();
3089 let sender = sender.as_ref().expect("There is no marker sender");
3090 sender.send(Some(marker)).unwrap();
3091 }
3092
3093 pub(crate) fn set_devtools_timeline_markers(
3094 &self,
3095 markers: Vec<TimelineMarkerType>,
3096 reply: IpcSender<Option<TimelineMarker>>,
3097 ) {
3098 *self.devtools_marker_sender.borrow_mut() = Some(reply);
3099 self.devtools_markers.borrow_mut().extend(markers);
3100 }
3101
3102 pub(crate) fn drop_devtools_timeline_markers(&self, markers: Vec<TimelineMarkerType>) {
3103 let mut devtools_markers = self.devtools_markers.borrow_mut();
3104 for marker in markers {
3105 devtools_markers.remove(&marker);
3106 }
3107 if devtools_markers.is_empty() {
3108 *self.devtools_marker_sender.borrow_mut() = None;
3109 }
3110 }
3111
3112 pub(crate) fn set_webdriver_script_chan(&self, chan: Option<IpcSender<WebDriverJSResult>>) {
3113 *self.webdriver_script_chan.borrow_mut() = chan;
3114 }
3115
3116 pub(crate) fn set_webdriver_load_status_sender(
3117 &self,
3118 sender: Option<GenericSender<WebDriverLoadStatus>>,
3119 ) {
3120 *self.webdriver_load_status_sender.borrow_mut() = sender;
3121 }
3122
3123 pub(crate) fn is_alive(&self) -> bool {
3124 self.current_state.get() == WindowState::Alive
3125 }
3126
3127 pub(crate) fn is_top_level(&self) -> bool {
3129 self.parent_info.is_none()
3130 }
3131
3132 pub(crate) fn run_the_resize_steps(&self, can_gc: CanGc) -> bool {
3137 let Some((new_size, size_type)) = self.take_unhandled_resize_event() else {
3138 return false;
3139 };
3140
3141 if self.viewport_details() == new_size {
3142 return false;
3143 }
3144
3145 let _realm = enter_realm(self);
3146 debug!(
3147 "Resizing Window for pipeline {:?} from {:?} to {new_size:?}",
3148 self.pipeline_id(),
3149 self.viewport_details(),
3150 );
3151 self.set_viewport_details(new_size);
3152
3153 self.Document()
3157 .add_restyle_reason(RestyleReason::ViewportSizeChanged);
3158
3159 if self.layout().device().used_viewport_units() {
3162 self.Document().dirty_all_nodes();
3163 }
3164
3165 if size_type == WindowSizeType::Resize {
3167 let uievent = UIEvent::new(
3168 self,
3169 DOMString::from("resize"),
3170 EventBubbles::DoesNotBubble,
3171 EventCancelable::NotCancelable,
3172 Some(self),
3173 0i32,
3174 can_gc,
3175 );
3176 uievent.upcast::<Event>().fire(self.upcast(), can_gc);
3177 }
3178
3179 true
3180 }
3181
3182 pub(crate) fn evaluate_media_queries_and_report_changes(&self, can_gc: CanGc) {
3185 let _realm = enter_realm(self);
3186
3187 rooted_vec!(let mut mql_list);
3188 self.media_query_lists.for_each(|mql| {
3189 if let MediaQueryListMatchState::Changed = mql.evaluate_changes() {
3190 mql_list.push(Dom::from_ref(&*mql));
3192 }
3193 });
3194 for mql in mql_list.iter() {
3196 let event = MediaQueryListEvent::new(
3197 &mql.global(),
3198 atom!("change"),
3199 false,
3200 false,
3201 mql.Media(),
3202 mql.Matches(),
3203 can_gc,
3204 );
3205 event
3206 .upcast::<Event>()
3207 .fire(mql.upcast::<EventTarget>(), can_gc);
3208 }
3209 }
3210
3211 pub(crate) fn set_throttled(&self, throttled: bool) {
3213 self.throttled.set(throttled);
3214 if throttled {
3215 self.as_global_scope().slow_down_timers();
3216 } else {
3217 self.as_global_scope().speed_up_timers();
3218 }
3219 }
3220
3221 pub(crate) fn throttled(&self) -> bool {
3222 self.throttled.get()
3223 }
3224
3225 pub(crate) fn unminified_css_dir(&self) -> Option<String> {
3226 self.unminified_css_dir.borrow().clone()
3227 }
3228
3229 pub(crate) fn local_script_source(&self) -> &Option<String> {
3230 &self.local_script_source
3231 }
3232
3233 pub(crate) fn set_navigation_start(&self) {
3234 self.navigation_start.set(CrossProcessInstant::now());
3235 }
3236
3237 pub(crate) fn send_to_embedder(&self, msg: EmbedderMsg) {
3238 self.as_global_scope()
3239 .script_to_embedder_chan()
3240 .send(msg)
3241 .unwrap();
3242 }
3243
3244 pub(crate) fn send_to_constellation(&self, msg: ScriptToConstellationMessage) {
3245 self.as_global_scope()
3246 .script_to_constellation_chan()
3247 .send(msg)
3248 .unwrap();
3249 }
3250
3251 #[cfg(feature = "webxr")]
3252 pub(crate) fn in_immersive_xr_session(&self) -> bool {
3253 self.navigator
3254 .get()
3255 .as_ref()
3256 .and_then(|nav| nav.xr())
3257 .is_some_and(|xr| xr.pending_or_active_session())
3258 }
3259
3260 #[cfg(not(feature = "webxr"))]
3261 pub(crate) fn in_immersive_xr_session(&self) -> bool {
3262 false
3263 }
3264
3265 #[allow(unsafe_code)]
3266 fn handle_pending_images_post_reflow(
3267 &self,
3268 pending_images: Vec<PendingImage>,
3269 pending_rasterization_images: Vec<PendingRasterizationImage>,
3270 pending_svg_element_for_serialization: Vec<UntrustedNodeAddress>,
3271 ) {
3272 let pipeline_id = self.pipeline_id();
3273 for image in pending_images {
3274 let id = image.id;
3275 let node = unsafe { from_untrusted_node_address(image.node) };
3276
3277 if let PendingImageState::Unrequested(ref url) = image.state {
3278 fetch_image_for_layout(url.clone(), &node, id, self.image_cache.clone());
3279 }
3280
3281 let mut images = self.pending_layout_images.borrow_mut();
3282 if !images.contains_key(&id) {
3283 let trusted_node = Trusted::new(&*node);
3284 let sender = self.register_image_cache_listener(id, move |response| {
3285 trusted_node
3286 .root()
3287 .owner_window()
3288 .pending_layout_image_notification(response);
3289 });
3290
3291 self.image_cache
3292 .add_listener(ImageLoadListener::new(sender, pipeline_id, id));
3293 }
3294
3295 let nodes = images.entry(id).or_default();
3296 if !nodes.iter().any(|n| std::ptr::eq(&*(n.node), &*node)) {
3297 nodes.push(PendingLayoutImageAncillaryData {
3298 node: Dom::from_ref(&*node),
3299 destination: image.destination,
3300 });
3301 }
3302 }
3303
3304 for image in pending_rasterization_images {
3305 let node = unsafe { from_untrusted_node_address(image.node) };
3306
3307 let mut images = self.pending_images_for_rasterization.borrow_mut();
3308 if !images.contains_key(&(image.id, image.size)) {
3309 self.image_cache.add_rasterization_complete_listener(
3310 pipeline_id,
3311 image.id,
3312 image.size,
3313 self.image_cache_sender.clone(),
3314 );
3315 }
3316
3317 let nodes = images.entry((image.id, image.size)).or_default();
3318 if !nodes.iter().any(|n| std::ptr::eq(&**n, &*node)) {
3319 nodes.push(Dom::from_ref(&*node));
3320 }
3321 }
3322
3323 for node in pending_svg_element_for_serialization.into_iter() {
3324 let node = unsafe { from_untrusted_node_address(node) };
3325 let svg = node.downcast::<SVGSVGElement>().unwrap();
3326 svg.serialize_and_cache_subtree();
3327 node.dirty(NodeDamage::Other);
3328 }
3329 }
3330
3331 #[allow(unsafe_code)]
3332 #[allow(clippy::too_many_arguments)]
3333 pub(crate) fn new(
3334 webview_id: WebViewId,
3335 runtime: Rc<Runtime>,
3336 script_chan: Sender<MainThreadScriptMsg>,
3337 layout: Box<dyn Layout>,
3338 font_context: Arc<FontContext>,
3339 image_cache_sender: IpcSender<ImageCacheResponseMessage>,
3340 image_cache: Arc<dyn ImageCache>,
3341 resource_threads: ResourceThreads,
3342 storage_threads: StorageThreads,
3343 #[cfg(feature = "bluetooth")] bluetooth_thread: IpcSender<BluetoothRequest>,
3344 mem_profiler_chan: MemProfilerChan,
3345 time_profiler_chan: TimeProfilerChan,
3346 devtools_chan: Option<IpcSender<ScriptToDevtoolsControlMsg>>,
3347 constellation_chan: ScriptToConstellationChan,
3348 embedder_chan: ScriptToEmbedderChan,
3349 control_chan: GenericSender<ScriptThreadMessage>,
3350 pipeline_id: PipelineId,
3351 parent_info: Option<PipelineId>,
3352 viewport_details: ViewportDetails,
3353 origin: MutableOrigin,
3354 creation_url: ServoUrl,
3355 top_level_creation_url: ServoUrl,
3356 navigation_start: CrossProcessInstant,
3357 webgl_chan: Option<WebGLChan>,
3358 #[cfg(feature = "webxr")] webxr_registry: Option<webxr_api::Registry>,
3359 microtask_queue: Rc<MicrotaskQueue>,
3360 compositor_api: CrossProcessCompositorApi,
3361 unminify_js: bool,
3362 unminify_css: bool,
3363 local_script_source: Option<String>,
3364 user_content_manager: UserContentManager,
3365 player_context: WindowGLContext,
3366 #[cfg(feature = "webgpu")] gpu_id_hub: Arc<IdentityHub>,
3367 inherited_secure_context: Option<bool>,
3368 theme: Theme,
3369 ) -> DomRoot<Self> {
3370 let error_reporter = CSSErrorReporter {
3371 pipelineid: pipeline_id,
3372 script_chan: control_chan,
3373 };
3374
3375 let initial_viewport = f32_rect_to_au_rect(UntypedRect::new(
3376 Point2D::zero(),
3377 viewport_details.size.to_untyped(),
3378 ));
3379
3380 let win = Box::new(Self {
3381 webview_id,
3382 globalscope: GlobalScope::new_inherited(
3383 pipeline_id,
3384 devtools_chan,
3385 mem_profiler_chan,
3386 time_profiler_chan,
3387 constellation_chan,
3388 embedder_chan,
3389 resource_threads,
3390 storage_threads,
3391 origin,
3392 creation_url,
3393 Some(top_level_creation_url),
3394 microtask_queue,
3395 #[cfg(feature = "webgpu")]
3396 gpu_id_hub,
3397 inherited_secure_context,
3398 unminify_js,
3399 Some(font_context.clone()),
3400 ),
3401 ongoing_navigation: Default::default(),
3402 script_chan,
3403 layout: RefCell::new(layout),
3404 image_cache_sender,
3405 image_cache,
3406 navigator: Default::default(),
3407 location: Default::default(),
3408 history: Default::default(),
3409 indexeddb: Default::default(),
3410 custom_element_registry: Default::default(),
3411 window_proxy: Default::default(),
3412 document: Default::default(),
3413 performance: Default::default(),
3414 navigation_start: Cell::new(navigation_start),
3415 screen: Default::default(),
3416 session_storage: Default::default(),
3417 local_storage: Default::default(),
3418 status: DomRefCell::new(DOMString::new()),
3419 parent_info,
3420 dom_static: GlobalStaticData::new(),
3421 js_runtime: DomRefCell::new(Some(runtime.clone())),
3422 #[cfg(feature = "bluetooth")]
3423 bluetooth_thread,
3424 #[cfg(feature = "bluetooth")]
3425 bluetooth_extra_permission_data: BluetoothExtraPermissionData::new(),
3426 unhandled_resize_event: Default::default(),
3427 viewport_details: Cell::new(viewport_details),
3428 current_viewport_size: Cell::new(initial_viewport.to_untyped().size),
3429 layout_blocker: Cell::new(LayoutBlocker::WaitingForParse),
3430 current_state: Cell::new(WindowState::Alive),
3431 devtools_marker_sender: Default::default(),
3432 devtools_markers: Default::default(),
3433 webdriver_script_chan: Default::default(),
3434 webdriver_load_status_sender: Default::default(),
3435 error_reporter,
3436 media_query_lists: DOMTracker::new(),
3437 #[cfg(feature = "bluetooth")]
3438 test_runner: Default::default(),
3439 webgl_chan,
3440 #[cfg(feature = "webxr")]
3441 webxr_registry,
3442 pending_image_callbacks: Default::default(),
3443 pending_layout_images: Default::default(),
3444 pending_images_for_rasterization: Default::default(),
3445 unminified_css_dir: Default::default(),
3446 local_script_source,
3447 test_worklet: Default::default(),
3448 paint_worklet: Default::default(),
3449 exists_mut_observer: Cell::new(false),
3450 compositor_api,
3451 has_sent_idle_message: Cell::new(false),
3452 unminify_css,
3453 user_content_manager,
3454 player_context,
3455 throttled: Cell::new(false),
3456 layout_marker: DomRefCell::new(Rc::new(Cell::new(true))),
3457 current_event: DomRefCell::new(None),
3458 theme: Cell::new(theme),
3459 trusted_types: Default::default(),
3460 reporting_observer_list: Default::default(),
3461 report_list: Default::default(),
3462 endpoints_list: Default::default(),
3463 script_window_proxies: ScriptThread::window_proxies(),
3464 has_pending_screenshot_readiness_request: Default::default(),
3465 });
3466
3467 WindowBinding::Wrap::<crate::DomTypeHolder>(GlobalScope::get_cx(), win)
3468 }
3469
3470 pub(crate) fn pipeline_id(&self) -> PipelineId {
3471 self.as_global_scope().pipeline_id()
3472 }
3473
3474 pub(crate) fn cache_layout_value<T>(&self, value: T) -> LayoutValue<T>
3476 where
3477 T: Copy + MallocSizeOf,
3478 {
3479 LayoutValue::new(self.layout_marker.borrow().clone(), value)
3480 }
3481}
3482
3483#[derive(MallocSizeOf)]
3488pub(crate) struct LayoutValue<T: MallocSizeOf> {
3489 #[conditional_malloc_size_of]
3490 is_valid: Rc<Cell<bool>>,
3491 value: T,
3492}
3493
3494#[allow(unsafe_code)]
3495unsafe impl<T: JSTraceable + MallocSizeOf> JSTraceable for LayoutValue<T> {
3496 unsafe fn trace(&self, trc: *mut js::jsapi::JSTracer) {
3497 unsafe { self.value.trace(trc) };
3498 }
3499}
3500
3501impl<T: Copy + MallocSizeOf> LayoutValue<T> {
3502 fn new(marker: Rc<Cell<bool>>, value: T) -> Self {
3503 LayoutValue {
3504 is_valid: marker,
3505 value,
3506 }
3507 }
3508
3509 pub(crate) fn get(&self) -> Result<T, ()> {
3511 if self.is_valid.get() {
3512 return Ok(self.value);
3513 }
3514 Err(())
3515 }
3516}
3517
3518fn should_move_clip_rect(clip_rect: UntypedRect<Au>, new_viewport: UntypedRect<f32>) -> bool {
3519 let clip_rect = UntypedRect::new(
3520 Point2D::new(
3521 clip_rect.origin.x.to_f32_px(),
3522 clip_rect.origin.y.to_f32_px(),
3523 ),
3524 Size2D::new(
3525 clip_rect.size.width.to_f32_px(),
3526 clip_rect.size.height.to_f32_px(),
3527 ),
3528 );
3529
3530 static VIEWPORT_SCROLL_MARGIN_SIZE: f32 = 0.5;
3534 let viewport_scroll_margin = new_viewport.size * VIEWPORT_SCROLL_MARGIN_SIZE;
3535
3536 (clip_rect.origin.x - new_viewport.origin.x).abs() <= viewport_scroll_margin.width ||
3537 (clip_rect.max_x() - new_viewport.max_x()).abs() <= viewport_scroll_margin.width ||
3538 (clip_rect.origin.y - new_viewport.origin.y).abs() <= viewport_scroll_margin.height ||
3539 (clip_rect.max_y() - new_viewport.max_y()).abs() <= viewport_scroll_margin.height
3540}
3541
3542impl Window {
3543 pub(crate) fn post_message(
3545 &self,
3546 target_origin: Option<ImmutableOrigin>,
3547 source_origin: ImmutableOrigin,
3548 source: &WindowProxy,
3549 data: StructuredSerializedData,
3550 ) {
3551 let this = Trusted::new(self);
3552 let source = Trusted::new(source);
3553 let task = task!(post_serialised_message: move || {
3554 let this = this.root();
3555 let source = source.root();
3556 let document = this.Document();
3557
3558 if let Some(ref target_origin) = target_origin {
3560 if !target_origin.same_origin(document.origin()) {
3561 return;
3562 }
3563 }
3564
3565 let cx = this.get_cx();
3567 let obj = this.reflector().get_jsobject();
3568 let _ac = JSAutoRealm::new(*cx, obj.get());
3569 rooted!(in(*cx) let mut message_clone = UndefinedValue());
3570 if let Ok(ports) = structuredclone::read(this.upcast(), data, message_clone.handle_mut()) {
3571 MessageEvent::dispatch_jsval(
3573 this.upcast(),
3574 this.upcast(),
3575 message_clone.handle(),
3576 Some(&source_origin.ascii_serialization()),
3577 Some(&*source),
3578 ports,
3579 CanGc::note()
3580 );
3581 } else {
3582 MessageEvent::dispatch_error(
3584 this.upcast(),
3585 this.upcast(),
3586 CanGc::note()
3587 );
3588 }
3589 });
3590 self.as_global_scope()
3592 .task_manager()
3593 .dom_manipulation_task_source()
3594 .queue(task);
3595 }
3596}
3597
3598#[derive(MallocSizeOf)]
3599pub(crate) struct CSSErrorReporter {
3600 pub(crate) pipelineid: PipelineId,
3601 pub(crate) script_chan: GenericSender<ScriptThreadMessage>,
3602}
3603unsafe_no_jsmanaged_fields!(CSSErrorReporter);
3604
3605impl ParseErrorReporter for CSSErrorReporter {
3606 fn report_error(
3607 &self,
3608 url: &UrlExtraData,
3609 location: SourceLocation,
3610 error: ContextualParseError,
3611 ) {
3612 if log_enabled!(log::Level::Info) {
3613 info!(
3614 "Url:\t{}\n{}:{} {}",
3615 url.0.as_str(),
3616 location.line,
3617 location.column,
3618 error
3619 )
3620 }
3621
3622 let _ = self.script_chan.send(ScriptThreadMessage::ReportCSSError(
3624 self.pipelineid,
3625 url.0.to_string(),
3626 location.line,
3627 location.column,
3628 error.to_string(),
3629 ));
3630 }
3631}
3632
3633fn is_named_element_with_name_attribute(elem: &Element) -> bool {
3634 let type_ = match elem.upcast::<Node>().type_id() {
3635 NodeTypeId::Element(ElementTypeId::HTMLElement(type_)) => type_,
3636 _ => return false,
3637 };
3638 matches!(
3639 type_,
3640 HTMLElementTypeId::HTMLEmbedElement |
3641 HTMLElementTypeId::HTMLFormElement |
3642 HTMLElementTypeId::HTMLImageElement |
3643 HTMLElementTypeId::HTMLObjectElement
3644 )
3645}
3646
3647fn is_named_element_with_id_attribute(elem: &Element) -> bool {
3648 elem.is_html_element()
3649}
3650
3651#[allow(unsafe_code)]
3652#[unsafe(no_mangle)]
3653unsafe extern "C" fn dump_js_stack(cx: *mut RawJSContext) {
3655 unsafe {
3656 DumpJSStack(cx, true, false, false);
3657 }
3658}
3659
3660impl WindowHelpers for Window {
3661 fn create_named_properties_object(
3662 cx: JSContext,
3663 proto: HandleObject,
3664 object: MutableHandleObject,
3665 ) {
3666 Self::create_named_properties_object(cx, proto, object)
3667 }
3668}