MainThreadVM.cpp 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492
  1. /*
  2. * Copyright (c) 2021-2022, Andreas Kling <kling@serenityos.org>
  3. * Copyright (c) 2021, Luke Wilde <lukew@serenityos.org>
  4. * Copyright (c) 2022, networkException <networkexception@serenityos.org>
  5. * Copyright (c) 2022-2023, Linus Groh <linusg@serenityos.org>
  6. *
  7. * SPDX-License-Identifier: BSD-2-Clause
  8. */
  9. #include <LibJS/Heap/DeferGC.h>
  10. #include <LibJS/Module.h>
  11. #include <LibJS/Runtime/Array.h>
  12. #include <LibJS/Runtime/Environment.h>
  13. #include <LibJS/Runtime/FinalizationRegistry.h>
  14. #include <LibJS/Runtime/ModuleRequest.h>
  15. #include <LibJS/Runtime/NativeFunction.h>
  16. #include <LibJS/Runtime/VM.h>
  17. #include <LibWeb/Bindings/Intrinsics.h>
  18. #include <LibWeb/Bindings/MainThreadVM.h>
  19. #include <LibWeb/Bindings/WindowExposedInterfaces.h>
  20. #include <LibWeb/DOM/Document.h>
  21. #include <LibWeb/HTML/Location.h>
  22. #include <LibWeb/HTML/PromiseRejectionEvent.h>
  23. #include <LibWeb/HTML/Scripting/ClassicScript.h>
  24. #include <LibWeb/HTML/Scripting/Environments.h>
  25. #include <LibWeb/HTML/Scripting/ExceptionReporter.h>
  26. #include <LibWeb/HTML/Scripting/Fetching.h>
  27. #include <LibWeb/HTML/Window.h>
  28. #include <LibWeb/HTML/WindowProxy.h>
  29. #include <LibWeb/Platform/EventLoopPlugin.h>
  30. #include <LibWeb/WebIDL/AbstractOperations.h>
  31. namespace Web::Bindings {
  32. // https://html.spec.whatwg.org/multipage/webappapis.html#active-script
  33. HTML::Script* active_script()
  34. {
  35. // 1. Let record be GetActiveScriptOrModule().
  36. auto record = main_thread_vm().get_active_script_or_module();
  37. // 2. If record is null, return null.
  38. // 3. Return record.[[HostDefined]].
  39. return record.visit(
  40. [](JS::NonnullGCPtr<JS::Script>& js_script) -> HTML::Script* {
  41. return verify_cast<HTML::ClassicScript>(js_script->host_defined());
  42. },
  43. [](JS::NonnullGCPtr<JS::Module>& js_module) -> HTML::Script* {
  44. return verify_cast<HTML::ModuleScript>(js_module->host_defined());
  45. },
  46. [](Empty) -> HTML::Script* {
  47. return nullptr;
  48. });
  49. }
  50. JS::VM& main_thread_vm()
  51. {
  52. static RefPtr<JS::VM> vm;
  53. if (!vm) {
  54. vm = JS::VM::create(make<WebEngineCustomData>());
  55. // NOTE: We intentionally leak the main thread JavaScript VM.
  56. // This avoids doing an exhaustive garbage collection on process exit.
  57. vm->ref();
  58. static_cast<WebEngineCustomData*>(vm->custom_data())->event_loop.set_vm(*vm);
  59. // 8.1.5.1 HostEnsureCanAddPrivateElement(O), https://html.spec.whatwg.org/multipage/webappapis.html#the-hostensurecanaddprivateelement-implementation
  60. vm->host_ensure_can_add_private_element = [](JS::Object const& object) -> JS::ThrowCompletionOr<void> {
  61. // 1. If O is a WindowProxy object, or implements Location, then return Completion { [[Type]]: throw, [[Value]]: a new TypeError }.
  62. if (is<HTML::WindowProxy>(object) || is<HTML::Location>(object))
  63. return vm->throw_completion<JS::TypeError>("Cannot add private elements to window or location object"sv);
  64. // 2. Return NormalCompletion(unused).
  65. return {};
  66. };
  67. // FIXME: Implement 8.1.5.2 HostEnsureCanCompileStrings(callerRealm, calleeRealm), https://html.spec.whatwg.org/multipage/webappapis.html#hostensurecancompilestrings(callerrealm,-calleerealm)
  68. // 8.1.5.3 HostPromiseRejectionTracker(promise, operation), https://html.spec.whatwg.org/multipage/webappapis.html#the-hostpromiserejectiontracker-implementation
  69. vm->host_promise_rejection_tracker = [](JS::Promise& promise, JS::Promise::RejectionOperation operation) {
  70. // 1. Let script be the running script.
  71. // The running script is the script in the [[HostDefined]] field in the ScriptOrModule component of the running JavaScript execution context.
  72. HTML::Script* script { nullptr };
  73. vm->running_execution_context().script_or_module.visit(
  74. [&script](JS::NonnullGCPtr<JS::Script>& js_script) {
  75. script = verify_cast<HTML::ClassicScript>(js_script->host_defined());
  76. },
  77. [&script](JS::NonnullGCPtr<JS::Module>& js_module) {
  78. script = verify_cast<HTML::ModuleScript>(js_module->host_defined());
  79. },
  80. [](Empty) {
  81. });
  82. // 2. If script is a classic script and script's muted errors is true, then return.
  83. // NOTE: is<T>() returns false if nullptr is passed.
  84. if (is<HTML::ClassicScript>(script)) {
  85. auto const& classic_script = static_cast<HTML::ClassicScript const&>(*script);
  86. if (classic_script.muted_errors() == HTML::ClassicScript::MutedErrors::Yes)
  87. return;
  88. }
  89. // 3. Let settings object be the current settings object.
  90. // 4. If script is not null, then set settings object to script's settings object.
  91. auto& settings_object = script ? script->settings_object() : HTML::current_settings_object();
  92. switch (operation) {
  93. case JS::Promise::RejectionOperation::Reject:
  94. // 4. If operation is "reject",
  95. // 1. Add promise to settings object's about-to-be-notified rejected promises list.
  96. settings_object.push_onto_about_to_be_notified_rejected_promises_list(promise);
  97. break;
  98. case JS::Promise::RejectionOperation::Handle: {
  99. // 5. If operation is "handle",
  100. // 1. If settings object's about-to-be-notified rejected promises list contains promise, then remove promise from that list and return.
  101. bool removed_about_to_be_notified_rejected_promise = settings_object.remove_from_about_to_be_notified_rejected_promises_list(promise);
  102. if (removed_about_to_be_notified_rejected_promise)
  103. return;
  104. // 3. Remove promise from settings object's outstanding rejected promises weak set.
  105. bool removed_outstanding_rejected_promise = settings_object.remove_from_outstanding_rejected_promises_weak_set(&promise);
  106. // 2. If settings object's outstanding rejected promises weak set does not contain promise, then return.
  107. // NOTE: This is done out of order because removed_outstanding_rejected_promise will be false if the promise wasn't in the set or true if it was and got removed.
  108. if (!removed_outstanding_rejected_promise)
  109. return;
  110. // 4. Let global be settings object's global object.
  111. auto& global = settings_object.global_object();
  112. // 5. Queue a global task on the DOM manipulation task source given global to fire an event named rejectionhandled at global, using PromiseRejectionEvent,
  113. // with the promise attribute initialized to promise, and the reason attribute initialized to the value of promise's [[PromiseResult]] internal slot.
  114. HTML::queue_global_task(HTML::Task::Source::DOMManipulation, global, [&global, &promise] {
  115. // FIXME: This currently assumes that global is a WindowObject.
  116. auto& window = verify_cast<HTML::Window>(global);
  117. HTML::PromiseRejectionEventInit event_init {
  118. {}, // Initialize the inherited DOM::EventInit
  119. /* .promise = */ promise,
  120. /* .reason = */ promise.result(),
  121. };
  122. auto promise_rejection_event = HTML::PromiseRejectionEvent::create(HTML::relevant_realm(global), String::from_deprecated_string(HTML::EventNames::rejectionhandled).release_value_but_fixme_should_propagate_errors(), event_init).release_value_but_fixme_should_propagate_errors();
  123. window.dispatch_event(promise_rejection_event);
  124. });
  125. break;
  126. }
  127. default:
  128. VERIFY_NOT_REACHED();
  129. }
  130. };
  131. // 8.1.5.4.1 HostCallJobCallback(callback, V, argumentsList), https://html.spec.whatwg.org/multipage/webappapis.html#hostcalljobcallback
  132. vm->host_call_job_callback = [](JS::JobCallback& callback, JS::Value this_value, JS::MarkedVector<JS::Value> arguments_list) {
  133. auto& callback_host_defined = verify_cast<WebEngineCustomJobCallbackData>(*callback.custom_data);
  134. // 1. Let incumbent settings be callback.[[HostDefined]].[[IncumbentSettings]]. (NOTE: Not necessary)
  135. // 2. Let script execution context be callback.[[HostDefined]].[[ActiveScriptContext]]. (NOTE: Not necessary)
  136. // 3. Prepare to run a callback with incumbent settings.
  137. callback_host_defined.incumbent_settings.prepare_to_run_callback();
  138. // 4. If script execution context is not null, then push script execution context onto the JavaScript execution context stack.
  139. if (callback_host_defined.active_script_context)
  140. vm->push_execution_context(*callback_host_defined.active_script_context);
  141. // 5. Let result be Call(callback.[[Callback]], V, argumentsList).
  142. auto result = JS::call(*vm, *callback.callback.cell(), this_value, move(arguments_list));
  143. // 6. If script execution context is not null, then pop script execution context from the JavaScript execution context stack.
  144. if (callback_host_defined.active_script_context) {
  145. VERIFY(&vm->running_execution_context() == callback_host_defined.active_script_context.ptr());
  146. vm->pop_execution_context();
  147. }
  148. // 7. Clean up after running a callback with incumbent settings.
  149. callback_host_defined.incumbent_settings.clean_up_after_running_callback();
  150. // 8. Return result.
  151. return result;
  152. };
  153. // 8.1.5.4.2 HostEnqueueFinalizationRegistryCleanupJob(finalizationRegistry), https://html.spec.whatwg.org/multipage/webappapis.html#hostenqueuefinalizationregistrycleanupjob
  154. vm->host_enqueue_finalization_registry_cleanup_job = [](JS::FinalizationRegistry& finalization_registry) {
  155. // 1. Let global be finalizationRegistry.[[Realm]]'s global object.
  156. auto& global = finalization_registry.realm().global_object();
  157. // 2. Queue a global task on the JavaScript engine task source given global to perform the following steps:
  158. HTML::queue_global_task(HTML::Task::Source::JavaScriptEngine, global, [&finalization_registry] {
  159. // 1. Let entry be finalizationRegistry.[[CleanupCallback]].[[Callback]].[[Realm]]'s environment settings object.
  160. auto& entry = host_defined_environment_settings_object(*finalization_registry.cleanup_callback().callback.cell()->realm());
  161. // 2. Check if we can run script with entry. If this returns "do not run", then return.
  162. if (entry.can_run_script() == HTML::RunScriptDecision::DoNotRun)
  163. return;
  164. // 3. Prepare to run script with entry.
  165. entry.prepare_to_run_script();
  166. // 4. Let result be the result of performing CleanupFinalizationRegistry(finalizationRegistry).
  167. auto result = finalization_registry.cleanup();
  168. // 5. Clean up after running script with entry.
  169. entry.clean_up_after_running_script();
  170. // 6. If result is an abrupt completion, then report the exception given by result.[[Value]].
  171. if (result.is_error())
  172. HTML::report_exception(result, finalization_registry.realm());
  173. });
  174. };
  175. // 8.1.5.4.3 HostEnqueuePromiseJob(job, realm), https://html.spec.whatwg.org/multipage/webappapis.html#hostenqueuepromisejob
  176. vm->host_enqueue_promise_job = [](Function<JS::ThrowCompletionOr<JS::Value>()> job, JS::Realm* realm) {
  177. // 1. If realm is not null, then let job settings be the settings object for realm. Otherwise, let job settings be null.
  178. HTML::EnvironmentSettingsObject* job_settings { nullptr };
  179. if (realm)
  180. job_settings = &host_defined_environment_settings_object(*realm);
  181. // IMPLEMENTATION DEFINED: The JS spec says we must take implementation defined steps to make the currently active script or module at the time of HostEnqueuePromiseJob being invoked
  182. // also be the active script or module of the job at the time of its invocation.
  183. // This means taking it here now and passing it through to the lambda.
  184. auto script_or_module = vm->get_active_script_or_module();
  185. // 2. Queue a microtask on the surrounding agent's event loop to perform the following steps:
  186. // This instance of "queue a microtask" uses the "implied document". The best fit for "implied document" here is "If the task is being queued by or for a script, then return the script's settings object's responsible document."
  187. // Do note that "implied document" from the spec is handwavy and the spec authors are trying to get rid of it: https://github.com/whatwg/html/issues/4980
  188. auto* script = active_script();
  189. // NOTE: This keeps job_settings alive by keeping realm alive, which is holding onto job_settings.
  190. HTML::queue_a_microtask(script ? script->settings_object().responsible_document().ptr() : nullptr, [job_settings, job = move(job), script_or_module = move(script_or_module)] {
  191. // The dummy execution context has to be kept up here to keep it alive for the duration of the function.
  192. Optional<JS::ExecutionContext> dummy_execution_context;
  193. if (job_settings) {
  194. // 1. If job settings is not null, then check if we can run script with job settings. If this returns "do not run" then return.
  195. if (job_settings->can_run_script() == HTML::RunScriptDecision::DoNotRun)
  196. return;
  197. // 2. If job settings is not null, then prepare to run script with job settings.
  198. job_settings->prepare_to_run_script();
  199. // IMPLEMENTATION DEFINED: Additionally to preparing to run a script, we also prepare to run a callback here. This matches WebIDL's
  200. // invoke_callback() / call_user_object_operation() functions, and prevents a crash in host_make_job_callback()
  201. // when getting the incumbent settings object.
  202. job_settings->prepare_to_run_callback();
  203. // IMPLEMENTATION DEFINED: Per the previous "implementation defined" comment, we must now make the script or module the active script or module.
  204. // Since the only active execution context currently is the realm execution context of job settings, lets attach it here.
  205. job_settings->realm_execution_context().script_or_module = script_or_module;
  206. } else {
  207. // FIXME: We need to setup a dummy execution context in case a JS::NativeFunction is called when processing the job.
  208. // This is because JS::NativeFunction::call excepts something to be on the execution context stack to be able to get the caller context to initialize the environment.
  209. // Do note that the JS spec gives _no_ guarantee that the execution context stack has something on it if HostEnqueuePromiseJob was called with a null realm: https://tc39.es/ecma262/#job-preparedtoevaluatecode
  210. dummy_execution_context = JS::ExecutionContext { vm->heap() };
  211. dummy_execution_context->script_or_module = script_or_module;
  212. vm->push_execution_context(dummy_execution_context.value());
  213. }
  214. // 3. Let result be job().
  215. [[maybe_unused]] auto result = job();
  216. // 4. If job settings is not null, then clean up after running script with job settings.
  217. if (job_settings) {
  218. // IMPLEMENTATION DEFINED: Disassociate the realm execution context from the script or module.
  219. job_settings->realm_execution_context().script_or_module = Empty {};
  220. // IMPLEMENTATION DEFINED: See comment above, we need to clean up the non-standard prepare_to_run_callback() call.
  221. job_settings->clean_up_after_running_callback();
  222. job_settings->clean_up_after_running_script();
  223. } else {
  224. // Pop off the dummy execution context. See the above FIXME block about why this is done.
  225. vm->pop_execution_context();
  226. }
  227. // 5. If result is an abrupt completion, then report the exception given by result.[[Value]].
  228. if (result.is_error())
  229. HTML::report_exception(result, job_settings->realm());
  230. });
  231. };
  232. // 8.1.5.4.4 HostMakeJobCallback(callable), https://html.spec.whatwg.org/multipage/webappapis.html#hostmakejobcallback
  233. vm->host_make_job_callback = [](JS::FunctionObject& callable) -> JS::JobCallback {
  234. // 1. Let incumbent settings be the incumbent settings object.
  235. auto& incumbent_settings = HTML::incumbent_settings_object();
  236. // 2. Let active script be the active script.
  237. auto* script = active_script();
  238. // 3. Let script execution context be null.
  239. OwnPtr<JS::ExecutionContext> script_execution_context;
  240. // 4. If active script is not null, set script execution context to a new JavaScript execution context, with its Function field set to null,
  241. // its Realm field set to active script's settings object's Realm, and its ScriptOrModule set to active script's record.
  242. if (script) {
  243. script_execution_context = adopt_own(*new JS::ExecutionContext(vm->heap()));
  244. script_execution_context->function = nullptr;
  245. script_execution_context->realm = &script->settings_object().realm();
  246. if (is<HTML::ClassicScript>(script)) {
  247. script_execution_context->script_or_module = JS::NonnullGCPtr<JS::Script>(*verify_cast<HTML::ClassicScript>(script)->script_record());
  248. } else if (is<HTML::ModuleScript>(script)) {
  249. if (is<HTML::JavaScriptModuleScript>(script)) {
  250. script_execution_context->script_or_module = JS::NonnullGCPtr<JS::Module>(*verify_cast<HTML::JavaScriptModuleScript>(script)->record());
  251. } else {
  252. // NOTE: Handle CSS and JSON module scripts once we have those.
  253. VERIFY_NOT_REACHED();
  254. }
  255. } else {
  256. VERIFY_NOT_REACHED();
  257. }
  258. }
  259. // 5. Return the JobCallback Record { [[Callback]]: callable, [[HostDefined]]: { [[IncumbentSettings]]: incumbent settings, [[ActiveScriptContext]]: script execution context } }.
  260. auto host_defined = adopt_own(*new WebEngineCustomJobCallbackData(incumbent_settings, move(script_execution_context)));
  261. return { JS::make_handle(&callable), move(host_defined) };
  262. };
  263. // FIXME: Implement 8.1.5.5.1 HostGetImportMetaProperties(moduleRecord), https://html.spec.whatwg.org/multipage/webappapis.html#hostgetimportmetaproperties
  264. // FIXME: Implement 8.1.5.5.2 HostImportModuleDynamically(referencingScriptOrModule, moduleRequest, promiseCapability), https://html.spec.whatwg.org/multipage/webappapis.html#hostimportmoduledynamically(referencingscriptormodule,-modulerequest,-promisecapability)
  265. // FIXME: Implement 8.1.5.5.3 HostResolveImportedModule(referencingScriptOrModule, moduleRequest), https://html.spec.whatwg.org/multipage/webappapis.html#hostresolveimportedmodule(referencingscriptormodule,-modulerequest)
  266. // 8.1.5.5.4 HostGetSupportedImportAssertions(), https://html.spec.whatwg.org/multipage/webappapis.html#hostgetsupportedimportassertions
  267. vm->host_get_supported_import_assertions = []() -> Vector<DeprecatedString> {
  268. // 1. Return « "type" ».
  269. return { "type"sv };
  270. };
  271. // 8.1.6.5.3 HostResolveImportedModule(referencingScriptOrModule, moduleRequest), https://html.spec.whatwg.org/multipage/webappapis.html#hostresolveimportedmodule(referencingscriptormodule,-modulerequest)
  272. vm->host_resolve_imported_module = [](JS::ScriptOrModule const& referencing_string_or_module, JS::ModuleRequest const& module_request) -> JS::ThrowCompletionOr<JS::NonnullGCPtr<JS::Module>> {
  273. // 1. Let moduleMap and referencingScript be null.
  274. Optional<HTML::ModuleMap&> module_map;
  275. Optional<HTML::Script&> referencing_script;
  276. // 2. If referencingScriptOrModule is not null, then:
  277. if (!referencing_string_or_module.has<Empty>()) {
  278. // 1. Set referencingScript to referencingScriptOrModule.[[HostDefined]].
  279. referencing_script = verify_cast<HTML::Script>(referencing_string_or_module.has<JS::NonnullGCPtr<JS::Script>>() ? *referencing_string_or_module.get<JS::NonnullGCPtr<JS::Script>>()->host_defined() : *referencing_string_or_module.get<JS::NonnullGCPtr<JS::Module>>()->host_defined());
  280. // 2. Set moduleMap to referencingScript's settings object's module map.
  281. module_map = referencing_script->settings_object().module_map();
  282. }
  283. // 3. Otherwise:
  284. else {
  285. // 1. Assert: there is a current settings object.
  286. // NOTE: This is handled by the HTML::current_settings_object() accessor.
  287. // 2. Set moduleMap to the current settings object's module map.
  288. module_map = HTML::current_settings_object().module_map();
  289. }
  290. // 4. Let url be the result of resolving a module specifier given referencingScript and moduleRequest.[[Specifier]].
  291. auto url = MUST(HTML::resolve_module_specifier(referencing_script, module_request.module_specifier));
  292. // 5. Assert: the previous step never throws an exception, because resolving a module specifier must have been previously successful
  293. // with these same two arguments (either while creating the corresponding module script, or in fetch an import() module script graph).
  294. // NOTE: Handled by MUST above.
  295. // 6. Let moduleType be the result of running the module type from module request steps given moduleRequest.
  296. auto module_type = HTML::module_type_from_module_request(module_request);
  297. // 7. Let resolvedModuleScript be moduleMap[(url, moduleType)]. (This entry must exist for us to have gotten to this point.)
  298. auto resolved_module_script = module_map->get(url, module_type).value();
  299. // 8. Assert: resolvedModuleScript is a module script (i.e., is not null or "fetching").
  300. VERIFY(resolved_module_script.type == HTML::ModuleMap::EntryType::ModuleScript);
  301. // 9. Assert: resolvedModuleScript's record is not null.
  302. VERIFY(resolved_module_script.module_script->record());
  303. // 10. Return resolvedModuleScript's record.
  304. return JS::NonnullGCPtr(*resolved_module_script.module_script->record());
  305. };
  306. // NOTE: We push a dummy execution context onto the JS execution context stack,
  307. // just to make sure that it's never empty.
  308. auto& custom_data = *verify_cast<WebEngineCustomData>(vm->custom_data());
  309. custom_data.root_execution_context = MUST(JS::Realm::initialize_host_defined_realm(*vm, nullptr, nullptr));
  310. auto* root_realm = custom_data.root_execution_context->realm;
  311. auto intrinsics = root_realm->heap().allocate<Intrinsics>(*root_realm, *root_realm).release_allocated_value_but_fixme_should_propagate_errors();
  312. auto host_defined = make<HostDefined>(nullptr, intrinsics);
  313. root_realm->set_host_defined(move(host_defined));
  314. custom_data.internal_realm = root_realm;
  315. // NOTE: We make sure the internal realm has all the Window intrinsics initialized.
  316. // The DeferGC is a hack to avoid nested GC allocations due to lazy ensure_web_prototype()
  317. // and ensure_web_constructor() invocations.
  318. // FIXME: Find a nicer way to do this.
  319. JS::DeferGC defer_gc(root_realm->heap());
  320. auto object = JS::Object::create(*root_realm, nullptr);
  321. root_realm->set_global_object(object, object);
  322. add_window_exposed_interfaces(*object);
  323. vm->push_execution_context(*custom_data.root_execution_context);
  324. }
  325. return *vm;
  326. }
  327. // https://dom.spec.whatwg.org/#queue-a-mutation-observer-compound-microtask
  328. void queue_mutation_observer_microtask(DOM::Document const& document)
  329. {
  330. auto& vm = main_thread_vm();
  331. auto& custom_data = verify_cast<WebEngineCustomData>(*vm.custom_data());
  332. // 1. If the surrounding agent’s mutation observer microtask queued is true, then return.
  333. if (custom_data.mutation_observer_microtask_queued)
  334. return;
  335. // 2. Set the surrounding agent’s mutation observer microtask queued to true.
  336. custom_data.mutation_observer_microtask_queued = true;
  337. // 3. Queue a microtask to notify mutation observers.
  338. // NOTE: This uses the implied document concept. In the case of mutation observers, it is always done in a node context, so document should be that node's document.
  339. // FIXME: Is it safe to pass custom_data through?
  340. HTML::queue_a_microtask(&document, [&custom_data]() {
  341. // 1. Set the surrounding agent’s mutation observer microtask queued to false.
  342. custom_data.mutation_observer_microtask_queued = false;
  343. // 2. Let notifySet be a clone of the surrounding agent’s mutation observers.
  344. auto notify_set = custom_data.mutation_observers;
  345. // FIXME: 3. Let signalSet be a clone of the surrounding agent’s signal slots.
  346. // FIXME: 4. Empty the surrounding agent’s signal slots.
  347. // 5. For each mo of notifySet:
  348. for (auto& mutation_observer : notify_set) {
  349. // 1. Let records be a clone of mo’s record queue.
  350. // 2. Empty mo’s record queue.
  351. auto records = mutation_observer->take_records();
  352. // 3. For each node of mo’s node list, remove all transient registered observers whose observer is mo from node’s registered observer list.
  353. for (auto& node : mutation_observer->node_list()) {
  354. // FIXME: Is this correct?
  355. if (node.is_null())
  356. continue;
  357. node->registered_observers_list().remove_all_matching([&mutation_observer](DOM::RegisteredObserver& registered_observer) {
  358. return is<DOM::TransientRegisteredObserver>(registered_observer) && static_cast<DOM::TransientRegisteredObserver&>(registered_observer).observer().ptr() == mutation_observer.ptr();
  359. });
  360. }
  361. // 4. If records is not empty, then invoke mo’s callback with « records, mo », and mo. If this throws an exception, catch it, and report the exception.
  362. if (!records.is_empty()) {
  363. auto& callback = mutation_observer->callback();
  364. auto& realm = callback.callback_context.realm();
  365. auto wrapped_records = MUST(JS::Array::create(realm, 0));
  366. for (size_t i = 0; i < records.size(); ++i) {
  367. auto& record = records.at(i);
  368. auto property_index = JS::PropertyKey { i };
  369. MUST(wrapped_records->create_data_property(property_index, record.ptr()));
  370. }
  371. auto result = WebIDL::invoke_callback(callback, mutation_observer.ptr(), wrapped_records, mutation_observer.ptr());
  372. if (result.is_abrupt())
  373. HTML::report_exception(result, realm);
  374. }
  375. }
  376. // FIXME: 6. For each slot of signalSet, fire an event named slotchange, with its bubbles attribute set to true, at slot.
  377. });
  378. }
  379. // https://html.spec.whatwg.org/multipage/webappapis.html#creating-a-new-javascript-realm
  380. NonnullOwnPtr<JS::ExecutionContext> create_a_new_javascript_realm(JS::VM& vm, Function<JS::Object*(JS::Realm&)> create_global_object, Function<JS::Object*(JS::Realm&)> create_global_this_value)
  381. {
  382. // 1. Perform InitializeHostDefinedRealm() with the provided customizations for creating the global object and the global this binding.
  383. // 2. Let realm execution context be the running JavaScript execution context.
  384. auto realm_execution_context = MUST(JS::Realm::initialize_host_defined_realm(vm, move(create_global_object), move(create_global_this_value)));
  385. // 3. Remove realm execution context from the JavaScript execution context stack.
  386. vm.execution_context_stack().remove_first_matching([&realm_execution_context](auto* execution_context) {
  387. return execution_context == realm_execution_context.ptr();
  388. });
  389. // NO-OP: 4. Let realm be realm execution context's Realm component.
  390. // NO-OP: 5. Set realm's agent to agent.
  391. // FIXME: 6. If agent's agent cluster's cross-origin isolation mode is "none", then:
  392. // 1. Let global be realm's global object.
  393. // 2. Let status be ! global.[[Delete]]("SharedArrayBuffer").
  394. // 3. Assert: status is true.
  395. // 7. Return realm execution context.
  396. return realm_execution_context;
  397. }
  398. void WebEngineCustomData::spin_event_loop_until(Function<bool()> goal_condition)
  399. {
  400. Platform::EventLoopPlugin::the().spin_until(move(goal_condition));
  401. }
  402. }