script/
script_mutation_observers.rs

1/* This Source Code Form is subject to the terms of the Mozilla Public
2 * License, v. 2.0. If a copy of the MPL was not distributed with this
3 * file, You can obtain one at https://mozilla.org/MPL/2.0/. */
4
5use std::cell::Cell;
6use std::rc::Rc;
7
8use script_bindings::callback::ExceptionHandling;
9use script_bindings::inheritance::Castable;
10use script_bindings::root::{Dom, DomRoot};
11use script_bindings::script_runtime::CanGc;
12
13use crate::dom::bindings::cell::DomRefCell;
14use crate::dom::types::{EventTarget, HTMLSlotElement, MutationObserver, MutationRecord};
15use crate::microtask::{Microtask, MicrotaskQueue};
16
17/// A helper struct for mutation observers used in `ScriptThread`
18/// Since the Rc is always stored in ScriptThread, it's always reachable by the GC.
19#[derive(JSTraceable, Default)]
20#[cfg_attr(crown, crown::unrooted_must_root_lint::allow_unrooted_in_rc)]
21#[cfg_attr(crown, crown::unrooted_must_root_lint::must_root)]
22pub(crate) struct ScriptMutationObservers {
23    /// Microtask Queue for adding support for mutation observer microtasks
24    mutation_observer_microtask_queued: Cell<bool>,
25
26    /// The unit of related similar-origin browsing contexts' list of MutationObserver objects
27    mutation_observers: DomRefCell<Vec<Dom<MutationObserver>>>,
28
29    /// <https://dom.spec.whatwg.org/#signal-slot-list>
30    signal_slots: DomRefCell<Vec<Dom<HTMLSlotElement>>>,
31}
32
33impl ScriptMutationObservers {
34    pub(crate) fn add_mutation_observer(&self, observer: &MutationObserver) {
35        self.mutation_observers
36            .borrow_mut()
37            .push(Dom::from_ref(observer));
38    }
39
40    /// <https://dom.spec.whatwg.org/#notify-mutation-observers>
41    pub(crate) fn notify_mutation_observers(&self, cx: &mut js::context::JSContext) {
42        // Step 1. Set the surrounding agent’s mutation observer microtask queued to false.
43        self.mutation_observer_microtask_queued.set(false);
44
45        // Step 2. Let notifySet be a clone of the surrounding agent’s pending mutation observers.
46        // Step 3. Empty the surrounding agent’s pending mutation observers.
47        let notify_list = self.take_mutation_observers();
48
49        // Step 4. Let signalSet be a clone of the surrounding agent’s signal slots.
50        // Step 5. Empty the surrounding agent’s signal slots.
51        let signal_set: Vec<DomRoot<HTMLSlotElement>> = self.take_signal_slots();
52
53        // Step 6. For each mo of notifySet:
54        for mo in notify_list.iter() {
55            let record_queue = mo.record_queue();
56
57            // Step 6.1 Let records be a clone of mo’s record queue.
58            let queue: Vec<DomRoot<MutationRecord>> = record_queue
59                .borrow()
60                .iter()
61                .map(|record| record.as_rooted())
62                .collect();
63
64            // Step 6.2 Empty mo’s record queue.
65            record_queue.borrow_mut().clear();
66
67            // TODO Step 6.3 For each node of mo’s node list, remove all transient registered observers
68            // whose observer is mo from node’s registered observer list.
69
70            // Step 6.4 If records is not empty, then invoke mo’s callback with « records,
71            // mo » and "report", and with callback this value mo.
72            if !queue.is_empty() {
73                let _ = mo.callback().Call_(
74                    &**mo,
75                    queue,
76                    mo,
77                    ExceptionHandling::Report,
78                    CanGc::from_cx(cx),
79                );
80            }
81        }
82
83        // Step 6. For each slot of signalSet, fire an event named slotchange,
84        // with its bubbles attribute set to true, at slot.
85        for slot in signal_set {
86            slot.upcast::<EventTarget>()
87                .fire_event(cx, atom!("slotchange"));
88        }
89    }
90
91    /// <https://dom.spec.whatwg.org/#queue-a-mutation-observer-compound-microtask>
92    pub(crate) fn queue_mutation_observer_microtask(&self, microtask_queue: Rc<MicrotaskQueue>) {
93        // Step 1. If the surrounding agent’s mutation observer microtask queued is true, then return.
94        if self.mutation_observer_microtask_queued.get() {
95            return;
96        }
97
98        // Step 2. Set the surrounding agent’s mutation observer microtask queued to true.
99        self.mutation_observer_microtask_queued.set(true);
100
101        // Step 3. Queue a microtask to notify mutation observers.
102        crate::script_thread::with_script_thread(|script_thread| {
103            microtask_queue.enqueue(Microtask::NotifyMutationObservers, script_thread.get_cx());
104        });
105    }
106
107    pub(crate) fn add_signal_slot(&self, observer: &HTMLSlotElement) {
108        self.signal_slots.borrow_mut().push(Dom::from_ref(observer));
109    }
110
111    pub(crate) fn take_signal_slots(&self) -> Vec<DomRoot<HTMLSlotElement>> {
112        self.signal_slots
113            .take()
114            .into_iter()
115            .inspect(|slot| {
116                slot.remove_from_signal_slots();
117            })
118            .map(|slot| slot.as_rooted())
119            .collect()
120    }
121
122    pub(crate) fn take_mutation_observers(&self) -> Vec<DomRoot<MutationObserver>> {
123        self.mutation_observers
124            .take()
125            .iter()
126            .map(|mo| mo.as_rooted())
127            .collect()
128    }
129}
script/script_mutation_observers.rs

script/
script_mutation_observers.rs
