mirror of
https://github.com/servo/servo.git
synced 2025-07-23 23:33:43 +01:00
* Re-implement readablestream: basics and default reader and controller --------- Co-authored-by: Jason Tsai <jason@pews.dev> Signed-off-by: Wu Wayne <yuweiwu@pm.me> Add remaining WebIDLs of ReadableStream (#32605) * Add Reader's WebIDL files * Add necessary methods in ReadableStream.webidl Signed-off-by: Wu Wayne <yuweiwu@pm.me> Create safe wrapper for JSFunctions (#32620) * Create safe wrapper for JSFunctions Signed-off-by: Bentaimia Haddadi <haddadi.taym@gmail.com> * Add assert to check if the name ends in a null character Signed-off-by: Bentaimia Haddadi <haddadi.taym@gmail.com> * Create macro to wrap unsafe extern "C" function calls Signed-off-by: Bentaimia Haddadi <haddadi.taym@gmail.com> * Remove WRAPPER_FN Signed-off-by: Bentaimia Haddadi <haddadi.taym@gmail.com> * Add macro example documentation Signed-off-by: Bentaimia Haddadi <haddadi.taym@gmail.com> * Use C-string literals Signed-off-by: Bentaimia Haddadi <haddadi.taym@gmail.com> * Ensure name is Cstr type Signed-off-by: Bentaimia Haddadi <haddadi.taym@gmail.com> * Scope #[allow(unsafe_code)] Signed-off-by: Bentaimia Haddadi <haddadi.taym@gmail.com> --------- Signed-off-by: Bentaimia Haddadi <haddadi.taym@gmail.com> Signed-off-by: Wu Wayne <yuweiwu@pm.me> Start implementation of default controller and reader Start implementation of default controller and reader * implement basic internal slots, with todos Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> * enum for controller Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> * re-implement native controller methods Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> * add calling into pull algo Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> * more details on chunk enqueuing Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> * add fulfill read request, clean-up warnings Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> * read request and reader typing Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> * allow for more than one non-native underlying source type Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> * add todo for should pull Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> * add underlying source dom struct container Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> * remove rc around source type * add default controller init in stream constructor * setup source container with prototype of source dict * clean-up docs, dispatch of controller in pull algo call * turn off SM streams * remove prototype setting on underlying source container * fix read request promise resolving * tidy * clean-up js conversions in read req handlers * add queue with sizes concept * use dom in pull promise handlers * Demonstrate using dictionary as callback this object. * move value with size to a struct * fmt * put readable stream state in a cell * nits in expectations * remove allow unroot by passing read result directly to promise resolving * tidy * root default controller inside call_pull_if_needed --------- Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> Co-authored-by: Josh Matthews <josh@joshmatthews.net> Signed-off-by: Wu Wayne <yuweiwu@pm.me> ReadableStream: implement Cancel and Locked (#33136) * implement Locked * implement Cancel and close Signed-off-by: Wu Wayne <yuweiwu@pm.me> Add GetPromiseIsHandled and SetAnyPromiseIsHandled to Promise Signed-off-by: Taym <haddadi.taym@gmail.com> mach fmt Signed-off-by: Taym <haddadi.taym@gmail.com> Readablestream default controller: get desired size (#33497) Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> stream: implement controller close (#33498) Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> implement stream default controller error (#33503) Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> Readablestream default controller: enqueue (#33528) * Implement ReadableStreamDefaultControllerMethods::Enqueue Signed-off-by: Wu Wayne <yuweiwu@pm.me> * Add spec comments Signed-off-by: Wu Wayne <yuweiwu@pm.me> --------- Signed-off-by: Wu Wayne <yuweiwu@pm.me> readablestream default controller: fulfill read requests (#33542) Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> Fix extract_size_algorithm (#33561) Signed-off-by: Wu Wayne <yuweiwu@pm.me> Readablestream default controller: use strategy size (#33551) * readablestream default controller: use strategy size, fallible enqueue Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> docs * readablestream default controller: clear strategy size Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> * prevent potential re-borrow panics when calling into the strategy size Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> * document readablestream constructor Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> --------- Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> Readablestream: impl default controller should pull, start algo (#33586) * implement should-pull algo for default controller Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> * add start algorithm setup for default controller Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> --------- Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> implement promise native handling for start and pull algorithms (#33603) Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> Implement ReadableStreamDefaultReader (#33160) * Implement ReadableStreamDefaultReader Make the stream mutable readable-stream-reader-generic-release Proper error types when releasing Closed Cancel Signed-off-by: Taym <haddadi.taym@gmail.com> * follow the spec more closely Signed-off-by: Taym <haddadi.taym@gmail.com> --------- Signed-off-by: Taym <haddadi.taym@gmail.com> Implement ReadableStreamDefaultReader read (#34007) * Implement ReadableStreamDefaultReader read Signed-off-by: Taym <haddadi.taym@gmail.com> * Perform readRequest’s error steps with stream.stored_error Signed-off-by: Taym <haddadi.taym@gmail.com> --------- Signed-off-by: Taym <haddadi.taym@gmail.com> Improve ReadableStreamDefaultReader close (#34014) * improve ReadableStreamDefaultReader close Signed-off-by: Taym <haddadi.taym@gmail.com> * remove resolve_closed_promise Signed-off-by: Taym <haddadi.taym@gmail.com> --------- Signed-off-by: Taym <haddadi.taym@gmail.com> Use Rc<Box<[u8]>> for queue to optimize get_in_memory_bytes Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> Signed-off-by: Taym <haddadi.taym@gmail.com> * Improve read_a_chunk and stop_reading implemntation (#34077) Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * Implement ReadableStreamDefaultReader::Constructor (#34056) * Implement ReadableStreamDefaultReader::Constructor Signed-off-by: Taym <haddadi.taym@gmail.com> * make start_reading returns ReadableStreamDefaultReader Signed-off-by: Taym <haddadi.taym@gmail.com> * Fix can_gc Signed-off-by: Taym <haddadi.taym@gmail.com> * Add canGc to ReadableStream::GetReader Signed-off-by: Taym <haddadi.taym@gmail.com> --------- Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * Readablestream fix CanGc (#34080) Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * correct ReadableStream::error_native implementation and fix clippy warnings (#34088) Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * turn assertion of stream present on controller on a early return with false (#34097) Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * Fix already mutably borrowed crash (#34105) Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * Refactor `get_in_memory_bytes` to return `Option<Vec<u8>> and avoid `unreachable!` panic (#34123) Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * Set ReadableStream ReadableStreamDefaultReader in start_reading (#34125) Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * Fix Unhandled rejection with value: object `TypeError: stream is not locked` (#34204) Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * Fix assert!(self.is_readable()) crash in ReadableStream::close (#34207) Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * fix call to to_js_object in underlying source algos (#34098) Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * do not assume presence of a stream when performing pull steps (#34244) * do not assume presence of a stream when performing pull steps Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> * add doc comments Co-authored-by: Taym Haddadi <haddadi.taym@gmail.com> Signed-off-by: Gregory Terzian <2792687+gterzian@users.noreply.github.com> --------- Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> Signed-off-by: Gregory Terzian <2792687+gterzian@users.noreply.github.com> Co-authored-by: Taym Haddadi <haddadi.taym@gmail.com> Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * gracefully handle failure of underlying source algorithms (#34243) Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * ensure result of calling start algo is an object (#34245) Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * return js failed error if underlying source constructor threw (#34246) Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * Use JSVal for ValueWithSize::value (#34259) Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * fix release reader lock, (#34255) fix setting stream on controller in new, fix matching fallthrough, reduce visibility of controller error method Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * in stream cancel, reject promist if locked (#34271) Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * Fix UnderlyingSourceContainer::call_start_algorithm (#34277) Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * implement controller cancel steps, fix stream cancel method (#34301) Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * fix conditional in perform pull steps (#34324) Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * set reader closed promise to one resolved with undefined if stream closed on init (#34321) Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * fix init of stream and controller (#34323) Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * Stream: Fix reborrow in controller enqueue, and fix error and exception handling. (#34338) * fix re-borrow in controller enqueue Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> * do not call to_jsval on JSFailed error in enqueue Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> * fix error and exception handling in controller enqueue Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> * remove TODO about correctness of stored error, since this was done as part of the switch to a js val. Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> --------- Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * Stream: Fix incorrect "this" object in underlying source callbacks (#34368) * in controller close, throw type error if stream cannot be closed Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> * store original js object for underlying source, for use as this object in callbacks Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> --------- Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * fix conditional logic in enqueue to ensure pull is called into (#34375) Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * Stream: Fix bytelength queueing strategy (#34376) * fix handling of value that is not an object in bytelength queuing strategy Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> * return type error if strategy size call fails, to prevent panic because no exception is pending Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> --------- Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * set correct default count queuing size strategy (#34389) Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * use proto in stream constructor (#34441) Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * fix edge cases in get_desired_size (#34440) Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * Stream: fix algo and strategy calls error handling. (#34424) * fix error handling in cancel steps Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> * in pull steps, reject promise if pull algo throws Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> * if start algorithm fails, rethrow the error Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> * when the strategy size fails, directly get the pending exception and use it to error the stream Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> * add error handling to enqueue value with size Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> * when enqueueing a value errors, ensure we error and stream with the same error used to throw an exception Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> --------- Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * fix native use of streams (#34468) Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * Implement readablestreamdefaulttee (#34405) * Implement readablestreamdefaulttee Signed-off-by: Taym <haddadi.taym@gmail.com> * Create UnderlyingSourceType::Tee each stream Signed-off-by: Taym <haddadi.taym@gmail.com> * Use Dom instead of DomRoot Signed-off-by: Taym <haddadi.taym@gmail.com> * Queue a microtask for readRequest chunk steps Signed-off-by: Taym <haddadi.taym@gmail.com> * fix create_readable_stream Signed-off-by: Taym <haddadi.taym@gmail.com> * Remove unnecessary Rc Signed-off-by: Taym <haddadi.taym@gmail.com> * Use correct doc link Signed-off-by: Taym <haddadi.taym@gmail.com> * Add #[allow(crown::unrooted_must_root)] Signed-off-by: Taym <haddadi.taym@gmail.com> * Fix crash in ClosedPromiseRejectionHandler Signed-off-by: Taym <haddadi.taym@gmail.com> * reflect TeeReadRequest and TeeUnderlyingSource Signed-off-by: Taym <haddadi.taym@gmail.com> * fix can_gc Signed-off-by: Taym <haddadi.taym@gmail.com> * reflect tee source, and fix use of mutable dom for tee source and request Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> * Fix typo that resolves multiple test failures in 'Tee' tests Signed-off-by: Taym <haddadi.taym@gmail.com> * Fix readable-streams/tee.any.js test Signed-off-by: Taym <haddadi.taym@gmail.com> --------- Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> Co-authored-by: gterzian <2792687+gterzian@users.noreply.github.com> Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * Align ReadableStreamDefaultReader with spec and fix additional tests in default-reader.any.js (#34531) And fix crate::DomTypeHolder usage * Align ReadableStreamDefaultReader with spec and fix additional tests in default-reader.any.js Signed-off-by: Taym <haddadi.taym@gmail.com> * make reader rooted in Constructor and acquire_default_reader Signed-off-by: Taym <haddadi.taym@gmail.com> * Remove spaces Signed-off-by: Taym <haddadi.taym@gmail.com> --------- Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * Streams: fetch stream chunks should be uint8 arrays (#34553) * fetch stream chunks should be uint8 arrays Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> * fix clippy Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> --------- Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> Co-authored-by: Taym Haddadi <haddadi.taym@gmail.com> Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * Update wpt test for ReadableStream reimplementation (#34579) Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * Fix ignore_malloc_size_of in readablestream tee (#34578) Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * Remove incorrect use of handle array, fail test safely by giving only one reason (#34560) Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * Update more wpt test for ReadableStream reimplementation (#34598) Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * Fix doc and rename Tee to DefaultTee (#34612) Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * fix: Address review comments Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * Update response-stream-with-broken-then.any.js.ini test expectation Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * fix reflect_dom_object can_gc Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * Fix compositeReason for DefaultTeeUnderlyingSource (#34627) * Fix compositeReason for DefaultTeeUnderlyingSource Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * Update test Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> --------- Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> * Last fixes stream (#34636) * remove now unsused from_js method of readable stream * fix documenation of error steps * return type error instread of panicking on a todo, when trying to construct a stream of type bytes Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> --------- Signed-off-by: Gregory Terzian <2792687+gterzian@users.noreply.github.com> * fix crown rooting related errors (#34662) Signed-off-by: Gregory Terzian <2792687+gterzian@users.noreply.github.com> --------- Signed-off-by: Taym <haddadi.taym@gmail.com> Signed-off-by: gterzian <2792687+gterzian@users.noreply.github.com> Signed-off-by: Taym Haddadi <haddadi.taym@gmail.com> Signed-off-by: Gregory Terzian <2792687+gterzian@users.noreply.github.com> Co-authored-by: Wu Wayne <yuweiwu@pm.me> Co-authored-by: Taym Haddadi <haddadi.taym@gmail.com>
300 lines
10 KiB
Rust
300 lines
10 KiB
Rust
/* This Source Code Form is subject to the terms of the Mozilla Public
|
|
* License, v. 2.0. If a copy of the MPL was not distributed with this
|
|
* file, You can obtain one at https://mozilla.org/MPL/2.0/. */
|
|
|
|
//! Base classes to work with IDL callbacks.
|
|
|
|
use std::default::Default;
|
|
use std::ffi::CString;
|
|
use std::mem::drop;
|
|
use std::ptr;
|
|
use std::rc::Rc;
|
|
|
|
use js::jsapi::{
|
|
AddRawValueRoot, EnterRealm, Heap, IsCallable, JSObject, LeaveRealm, Realm, RemoveRawValueRoot,
|
|
};
|
|
use js::jsval::{JSVal, ObjectValue, UndefinedValue};
|
|
use js::rust::wrappers::{JS_GetProperty, JS_WrapObject};
|
|
use js::rust::{HandleObject, MutableHandleObject, Runtime};
|
|
|
|
use crate::dom::bindings::codegen::Bindings::WindowBinding::Window_Binding::WindowMethods;
|
|
use crate::dom::bindings::error::{report_pending_exception, Error, Fallible};
|
|
use crate::dom::bindings::inheritance::Castable;
|
|
use crate::dom::bindings::reflector::DomObject;
|
|
use crate::dom::bindings::root::{Dom, DomRoot};
|
|
use crate::dom::bindings::settings_stack::{AutoEntryScript, AutoIncumbentScript};
|
|
use crate::dom::bindings::utils::AsCCharPtrPtr;
|
|
use crate::dom::globalscope::GlobalScope;
|
|
use crate::dom::window::Window;
|
|
use crate::realms::{enter_realm, InRealm};
|
|
use crate::script_runtime::{CanGc, JSContext};
|
|
|
|
/// The exception handling used for a call.
|
|
#[derive(Clone, Copy, PartialEq)]
|
|
pub enum ExceptionHandling {
|
|
/// Report any exception and don't throw it to the caller code.
|
|
Report,
|
|
/// Throw any exception to the caller code.
|
|
Rethrow,
|
|
}
|
|
|
|
/// A common base class for representing IDL callback function and
|
|
/// callback interface types.
|
|
#[derive(JSTraceable)]
|
|
#[crown::unrooted_must_root_lint::must_root]
|
|
pub struct CallbackObject {
|
|
/// The underlying `JSObject`.
|
|
callback: Heap<*mut JSObject>,
|
|
permanent_js_root: Heap<JSVal>,
|
|
|
|
/// The ["callback context"], that is, the global to use as incumbent
|
|
/// global when calling the callback.
|
|
///
|
|
/// Looking at the WebIDL standard, it appears as though there would always
|
|
/// be a value here, but [sometimes] callback functions are created by
|
|
/// hand-waving without defining the value of the callback context, and
|
|
/// without any JavaScript code on the stack to grab an incumbent global
|
|
/// from.
|
|
///
|
|
/// ["callback context"]: https://heycam.github.io/webidl/#dfn-callback-context
|
|
/// [sometimes]: https://github.com/whatwg/html/issues/2248
|
|
incumbent: Option<Dom<GlobalScope>>,
|
|
}
|
|
|
|
impl CallbackObject {
|
|
#[allow(crown::unrooted_must_root)]
|
|
// These are used by the bindings and do not need `default()` functions.
|
|
#[allow(clippy::new_without_default)]
|
|
fn new() -> CallbackObject {
|
|
CallbackObject {
|
|
callback: Heap::default(),
|
|
permanent_js_root: Heap::default(),
|
|
incumbent: GlobalScope::incumbent().map(|i| Dom::from_ref(&*i)),
|
|
}
|
|
}
|
|
|
|
pub fn get(&self) -> *mut JSObject {
|
|
self.callback.get()
|
|
}
|
|
|
|
#[allow(unsafe_code)]
|
|
unsafe fn init(&mut self, cx: JSContext, callback: *mut JSObject) {
|
|
self.callback.set(callback);
|
|
self.permanent_js_root.set(ObjectValue(callback));
|
|
assert!(AddRawValueRoot(
|
|
*cx,
|
|
self.permanent_js_root.get_unsafe(),
|
|
b"CallbackObject::root\n".as_c_char_ptr()
|
|
));
|
|
}
|
|
}
|
|
|
|
impl Drop for CallbackObject {
|
|
#[allow(unsafe_code)]
|
|
fn drop(&mut self) {
|
|
unsafe {
|
|
let cx = Runtime::get();
|
|
RemoveRawValueRoot(cx, self.permanent_js_root.get_unsafe());
|
|
}
|
|
}
|
|
}
|
|
|
|
impl PartialEq for CallbackObject {
|
|
fn eq(&self, other: &CallbackObject) -> bool {
|
|
self.callback.get() == other.callback.get()
|
|
}
|
|
}
|
|
|
|
/// A trait to be implemented by concrete IDL callback function and
|
|
/// callback interface types.
|
|
pub trait CallbackContainer {
|
|
/// Create a new CallbackContainer object for the given `JSObject`.
|
|
unsafe fn new(cx: JSContext, callback: *mut JSObject) -> Rc<Self>;
|
|
/// Returns the underlying `CallbackObject`.
|
|
fn callback_holder(&self) -> &CallbackObject;
|
|
/// Returns the underlying `JSObject`.
|
|
fn callback(&self) -> *mut JSObject {
|
|
self.callback_holder().get()
|
|
}
|
|
/// Returns the ["callback context"], that is, the global to use as
|
|
/// incumbent global when calling the callback.
|
|
///
|
|
/// ["callback context"]: https://heycam.github.io/webidl/#dfn-callback-context
|
|
fn incumbent(&self) -> Option<&GlobalScope> {
|
|
self.callback_holder().incumbent.as_deref()
|
|
}
|
|
}
|
|
|
|
/// A common base class for representing IDL callback function types.
|
|
#[derive(JSTraceable, PartialEq)]
|
|
#[crown::unrooted_must_root_lint::must_root]
|
|
pub struct CallbackFunction {
|
|
object: CallbackObject,
|
|
}
|
|
|
|
impl CallbackFunction {
|
|
/// Create a new `CallbackFunction` for this object.
|
|
#[allow(crown::unrooted_must_root)]
|
|
// These are used by the bindings and do not need `default()` functions.
|
|
#[allow(clippy::new_without_default)]
|
|
pub fn new() -> CallbackFunction {
|
|
CallbackFunction {
|
|
object: CallbackObject::new(),
|
|
}
|
|
}
|
|
|
|
/// Returns the underlying `CallbackObject`.
|
|
pub fn callback_holder(&self) -> &CallbackObject {
|
|
&self.object
|
|
}
|
|
|
|
/// Initialize the callback function with a value.
|
|
/// Should be called once this object is done moving.
|
|
pub unsafe fn init(&mut self, cx: JSContext, callback: *mut JSObject) {
|
|
self.object.init(cx, callback);
|
|
}
|
|
}
|
|
|
|
/// A common base class for representing IDL callback interface types.
|
|
#[derive(JSTraceable, PartialEq)]
|
|
#[crown::unrooted_must_root_lint::must_root]
|
|
pub struct CallbackInterface {
|
|
object: CallbackObject,
|
|
}
|
|
|
|
impl CallbackInterface {
|
|
/// Create a new CallbackInterface object for the given `JSObject`.
|
|
// These are used by the bindings and do not need `default()` functions.
|
|
#[allow(clippy::new_without_default)]
|
|
pub fn new() -> CallbackInterface {
|
|
CallbackInterface {
|
|
object: CallbackObject::new(),
|
|
}
|
|
}
|
|
|
|
/// Returns the underlying `CallbackObject`.
|
|
pub fn callback_holder(&self) -> &CallbackObject {
|
|
&self.object
|
|
}
|
|
|
|
/// Initialize the callback function with a value.
|
|
/// Should be called once this object is done moving.
|
|
pub unsafe fn init(&mut self, cx: JSContext, callback: *mut JSObject) {
|
|
self.object.init(cx, callback);
|
|
}
|
|
|
|
/// Returns the property with the given `name`, if it is a callable object,
|
|
/// or an error otherwise.
|
|
pub fn get_callable_property(&self, cx: JSContext, name: &str) -> Fallible<JSVal> {
|
|
rooted!(in(*cx) let mut callable = UndefinedValue());
|
|
rooted!(in(*cx) let obj = self.callback_holder().get());
|
|
unsafe {
|
|
let c_name = CString::new(name).unwrap();
|
|
if !JS_GetProperty(*cx, obj.handle(), c_name.as_ptr(), callable.handle_mut()) {
|
|
return Err(Error::JSFailed);
|
|
}
|
|
|
|
if !callable.is_object() || !IsCallable(callable.to_object()) {
|
|
return Err(Error::Type(format!(
|
|
"The value of the {} property is not callable",
|
|
name
|
|
)));
|
|
}
|
|
}
|
|
Ok(callable.get())
|
|
}
|
|
}
|
|
|
|
pub trait ThisReflector {
|
|
fn jsobject(&self) -> *mut JSObject;
|
|
}
|
|
|
|
impl<T: DomObject> ThisReflector for T {
|
|
fn jsobject(&self) -> *mut JSObject {
|
|
self.reflector().get_jsobject().get()
|
|
}
|
|
}
|
|
|
|
impl<'a> ThisReflector for HandleObject<'a> {
|
|
fn jsobject(&self) -> *mut JSObject {
|
|
self.get()
|
|
}
|
|
}
|
|
|
|
/// Wraps the reflector for `p` into the realm of `cx`.
|
|
pub fn wrap_call_this_object<T: ThisReflector>(
|
|
cx: JSContext,
|
|
p: &T,
|
|
mut rval: MutableHandleObject,
|
|
) {
|
|
rval.set(p.jsobject());
|
|
assert!(!rval.get().is_null());
|
|
|
|
unsafe {
|
|
if !JS_WrapObject(*cx, rval) {
|
|
rval.set(ptr::null_mut());
|
|
}
|
|
}
|
|
}
|
|
|
|
/// A class that performs whatever setup we need to safely make a call while
|
|
/// this class is on the stack. After `new` returns, the call is safe to make.
|
|
pub struct CallSetup {
|
|
/// The global for reporting exceptions. This is the global object of the
|
|
/// (possibly wrapped) callback object.
|
|
exception_global: DomRoot<GlobalScope>,
|
|
/// The `JSContext` used for the call.
|
|
cx: JSContext,
|
|
/// The realm we were in before the call.
|
|
old_realm: *mut Realm,
|
|
/// The exception handling used for the call.
|
|
handling: ExceptionHandling,
|
|
/// <https://heycam.github.io/webidl/#es-invoking-callback-functions>
|
|
/// steps 8 and 18.2.
|
|
entry_script: Option<AutoEntryScript>,
|
|
/// <https://heycam.github.io/webidl/#es-invoking-callback-functions>
|
|
/// steps 9 and 18.1.
|
|
incumbent_script: Option<AutoIncumbentScript>,
|
|
}
|
|
|
|
impl CallSetup {
|
|
/// Performs the setup needed to make a call.
|
|
#[allow(crown::unrooted_must_root)]
|
|
pub fn new<T: CallbackContainer>(callback: &T, handling: ExceptionHandling) -> CallSetup {
|
|
let global = unsafe { GlobalScope::from_object(callback.callback()) };
|
|
if let Some(window) = global.downcast::<Window>() {
|
|
window.Document().ensure_safe_to_run_script_or_layout();
|
|
}
|
|
let cx = GlobalScope::get_cx();
|
|
|
|
let aes = AutoEntryScript::new(&global);
|
|
let ais = callback.incumbent().map(AutoIncumbentScript::new);
|
|
CallSetup {
|
|
exception_global: global,
|
|
cx,
|
|
old_realm: unsafe { EnterRealm(*cx, callback.callback()) },
|
|
handling,
|
|
entry_script: Some(aes),
|
|
incumbent_script: ais,
|
|
}
|
|
}
|
|
|
|
/// Returns the `JSContext` used for the call.
|
|
pub fn get_context(&self) -> JSContext {
|
|
self.cx
|
|
}
|
|
}
|
|
|
|
impl Drop for CallSetup {
|
|
fn drop(&mut self) {
|
|
unsafe {
|
|
LeaveRealm(*self.cx, self.old_realm);
|
|
if self.handling == ExceptionHandling::Report {
|
|
let ar = enter_realm(&*self.exception_global);
|
|
report_pending_exception(*self.cx, true, InRealm::Entered(&ar), CanGc::note());
|
|
}
|
|
drop(self.incumbent_script.take());
|
|
drop(self.entry_script.take().unwrap());
|
|
}
|
|
}
|
|
}
|