#![allow( renamed_and_removed_lints, clippy::same_item_push, clippy::unknown_clippy_lints )] //! Ruffle web frontend. mod audio; mod locale; mod log_adapter; mod navigator; mod storage; mod ui; use generational_arena::{Arena, Index}; use js_sys::{Array, Function, Object, Uint8Array}; use ruffle_core::backend::{ audio::{AudioBackend, NullAudioBackend}, render::RenderBackend, storage::{MemoryStorageBackend, StorageBackend}, ui::UiBackend, }; use ruffle_core::config::Letterbox; use ruffle_core::context::UpdateContext; use ruffle_core::events::{KeyCode, MouseWheelDelta}; use ruffle_core::external::{ ExternalInterfaceMethod, ExternalInterfaceProvider, Value as ExternalValue, Value, }; use ruffle_core::property_map::PropertyMap; use ruffle_core::tag_utils::SwfMovie; use ruffle_core::{Color, PlayerEvent}; use ruffle_web_common::JsResult; use serde::{Deserialize, Serialize}; use std::collections::BTreeMap; use std::sync::Once; use std::sync::{Arc, Mutex}; use std::{cell::RefCell, error::Error, num::NonZeroI32}; use wasm_bindgen::{prelude::*, JsCast, JsValue}; use web_sys::{ AddEventListenerOptions, Element, Event, EventTarget, HtmlCanvasElement, HtmlElement, KeyboardEvent, PointerEvent, WheelEvent, }; static RUFFLE_GLOBAL_PANIC: Once = Once::new(); thread_local! { /// We store the actual instances of the ruffle core in a static pool. /// This gives us a clear boundary between the JS side and Rust side, avoiding /// issues with lifetimes and type parameters (which cannot be exported with wasm-bindgen). static INSTANCES: RefCell>> = RefCell::new(Arena::new()); static CURRENT_CONTEXT: RefCell>> = RefCell::new(None); } type AnimationHandler = Closure; struct RuffleInstance { core: Arc>, js_player: JavascriptPlayer, canvas: HtmlCanvasElement, canvas_width: i32, canvas_height: i32, device_pixel_ratio: f64, timestamp: Option, animation_handler: Option, // requestAnimationFrame callback animation_handler_id: Option, // requestAnimationFrame id #[allow(dead_code)] mouse_move_callback: Option>, mouse_down_callback: Option>, player_mouse_down_callback: Option>, window_mouse_down_callback: Option>, mouse_up_callback: Option>, mouse_wheel_callback: Option>, key_down_callback: Option>, key_up_callback: Option>, unload_callback: Option>, has_focus: bool, trace_observer: Arc>, } #[wasm_bindgen] extern "C" { #[wasm_bindgen(js_name = Error)] type JsError; #[wasm_bindgen(constructor, js_class = "Error")] fn new(message: &str) -> JsError; } #[wasm_bindgen(module = "/packages/core/src/ruffle-player.ts")] extern "C" { #[wasm_bindgen(extends = EventTarget)] #[derive(Clone)] pub type JavascriptPlayer; #[wasm_bindgen(method, js_name = "onCallbackAvailable")] fn on_callback_available(this: &JavascriptPlayer, name: &str); #[wasm_bindgen(method, catch, js_name = "onFSCommand")] fn on_fs_command(this: &JavascriptPlayer, command: &str, args: &str) -> Result; #[wasm_bindgen(method)] fn panic(this: &JavascriptPlayer, error: &JsError); #[wasm_bindgen(method, js_name = "displayUnsupportedMessage")] fn display_unsupported_message(this: &JavascriptPlayer); #[wasm_bindgen(method, js_name = "displayMessage")] fn display_message(this: &JavascriptPlayer, message: &str); #[wasm_bindgen(method, getter, js_name = "isFullscreen")] fn is_fullscreen(this: &JavascriptPlayer) -> bool; } struct JavascriptInterface { js_player: JavascriptPlayer, } #[derive(Serialize, Deserialize)] #[serde(default = "Default::default")] pub struct Config { #[serde(rename = "allowScriptAccess")] allow_script_access: bool, #[serde(rename = "backgroundColor")] background_color: Option, letterbox: Letterbox, #[serde(rename = "upgradeToHttps")] upgrade_to_https: bool, #[serde(rename = "warnOnUnsupportedContent")] warn_on_unsupported_content: bool, #[serde(rename = "logLevel")] log_level: log::Level, } impl Default for Config { fn default() -> Self { Self { allow_script_access: false, background_color: Default::default(), letterbox: Default::default(), upgrade_to_https: true, warn_on_unsupported_content: true, log_level: log::Level::Error, } } } /// An opaque handle to a `RuffleInstance` inside the pool. /// /// This type is exported to JS, and is used to interact with the library. #[wasm_bindgen] #[derive(Clone)] pub struct Ruffle(Index); #[wasm_bindgen] impl Ruffle { #[wasm_bindgen(constructor)] pub fn new( parent: HtmlElement, js_player: JavascriptPlayer, config: &JsValue, ) -> Result { if RUFFLE_GLOBAL_PANIC.is_completed() { // If an actual panic happened, then we can't trust the state it left us in. // Prevent future players from loading so that they can inform the user about the error. return Err("Ruffle is panicking!".into()); } set_panic_handler(); let config: Config = config.into_serde().unwrap_or_default(); Ruffle::new_internal(parent, js_player, config).map_err(|_| "Error creating player".into()) } /// Stream an arbitrary movie file from (presumably) the Internet. /// /// This method should only be called once per player. pub fn stream_from(&mut self, movie_url: &str, parameters: &JsValue) -> Result<(), JsValue> { INSTANCES.with(|instances| { let instances = instances.borrow(); let instance = instances.get(self.0).unwrap().borrow(); let mut parameters_to_load = PropertyMap::new(); populate_movie_parameters(¶meters, &mut parameters_to_load); instance .core .lock() .unwrap() .fetch_root_movie(movie_url, parameters_to_load); Ok(()) }) } /// Play an arbitrary movie on this instance. /// /// This method should only be called once per player. pub fn load_data(&mut self, swf_data: Uint8Array, parameters: &JsValue) -> Result<(), JsValue> { let movie = Arc::new({ let mut data = vec![0; swf_data.length() as usize]; swf_data.copy_to(&mut data[..]); let mut movie = SwfMovie::from_data(&data, None) .map_err(|e| format!("Error loading movie: {}", e))?; populate_movie_parameters(¶meters, movie.parameters_mut()); movie }); INSTANCES.with(|instances| { let instances = instances.borrow(); let instance = instances.get(self.0).unwrap(); instance.borrow().core.lock().unwrap().set_root_movie(movie); }); Ok(()) } pub fn play(&mut self) { INSTANCES.with(|instances| { let instances = instances.borrow(); let instance = instances.get(self.0).unwrap(); instance.borrow().core.lock().unwrap().set_is_playing(true); }); } pub fn pause(&mut self) { INSTANCES.with(|instances| { let instances = instances.borrow(); let instance = instances.get(self.0).unwrap(); instance.borrow().core.lock().unwrap().set_is_playing(false); }); } pub fn is_playing(&mut self) -> bool { INSTANCES.with(|instances| { let instances = instances.borrow(); let instance = instances.get(self.0).unwrap(); let is_playing = instance.borrow().core.lock().unwrap().is_playing(); is_playing }) } pub fn destroy(&mut self) { // Remove instance from the active list. if let Some(instance) = INSTANCES.with(|instances| { if let Ok(mut instances) = instances.try_borrow_mut() { instances.remove(self.0) } else { // If we're being destroyed mid-panic, we won't mind not being able to remove this. None } }) { let mut instance = instance.borrow_mut(); instance.canvas.remove(); // Stop all audio playing from the instance. let mut player = instance.core.lock().unwrap(); player.audio_mut().stop_all_sounds(); player.flush_shared_objects(); drop(player); // Clean up all event listeners. if let Some(window) = web_sys::window() { if let Some(mouse_move_callback) = &instance.mouse_move_callback { let canvas_events: &EventTarget = instance.canvas.as_ref(); canvas_events .remove_event_listener_with_callback( "pointermove", mouse_move_callback.as_ref().unchecked_ref(), ) .unwrap(); instance.mouse_move_callback = None; } if let Some(mouse_down_callback) = &instance.mouse_down_callback { let canvas_events: &EventTarget = instance.canvas.as_ref(); canvas_events .remove_event_listener_with_callback( "pointerdown", mouse_down_callback.as_ref().unchecked_ref(), ) .unwrap(); instance.mouse_down_callback = None; } if let Some(player_mouse_down_callback) = &instance.player_mouse_down_callback { let js_player_events: &EventTarget = instance.js_player.as_ref(); js_player_events .remove_event_listener_with_callback( "pointerdown", player_mouse_down_callback.as_ref().unchecked_ref(), ) .unwrap(); instance.player_mouse_down_callback = None; } if let Some(window_mouse_down_callback) = &instance.window_mouse_down_callback { window .remove_event_listener_with_callback_and_bool( "pointerdown", window_mouse_down_callback.as_ref().unchecked_ref(), true, ) .unwrap(); instance.window_mouse_down_callback = None; } if let Some(mouse_up_callback) = &instance.mouse_up_callback { let canvas_events: &EventTarget = instance.canvas.as_ref(); canvas_events .remove_event_listener_with_callback( "pointerup", mouse_up_callback.as_ref().unchecked_ref(), ) .unwrap(); instance.mouse_up_callback = None; } if let Some(mouse_wheel_callback) = &instance.mouse_wheel_callback { let canvas_events: &EventTarget = instance.canvas.as_ref(); canvas_events .remove_event_listener_with_callback( "wheel", mouse_wheel_callback.as_ref().unchecked_ref(), ) .unwrap(); instance.mouse_wheel_callback = None; } if let Some(key_down_callback) = &instance.key_down_callback { window .remove_event_listener_with_callback( "keydown", key_down_callback.as_ref().unchecked_ref(), ) .unwrap(); instance.key_down_callback = None; } if let Some(key_up_callback) = &instance.key_up_callback { window .remove_event_listener_with_callback( "keyup", key_up_callback.as_ref().unchecked_ref(), ) .unwrap(); instance.key_up_callback = None; } if let Some(unload_callback) = &instance.unload_callback { window .remove_event_listener_with_callback( "unload", unload_callback.as_ref().unchecked_ref(), ) .unwrap(); instance.unload_callback = None; } } // Cancel the animation handler, if it's still active. if let Some(id) = instance.animation_handler_id { if let Some(window) = web_sys::window() { let _ = window.cancel_animation_frame(id.into()); } } } // Player is dropped at this point. } #[allow(clippy::boxed_local)] // for js_bind pub fn call_exposed_callback(&self, name: &str, args: Box<[JsValue]>) -> JsValue { let args: Vec = args.iter().map(js_to_external_value).collect(); // Re-entrant callbacks need to return through the hole that was punched through for them // We record the context of external functions, and then if we get an internal callback // during the same call we'll reuse that. // This is unsafe by nature. I don't know any safe way to do this. if let Some(context) = CURRENT_CONTEXT.with(|v| *v.borrow()) { unsafe { if let Some(callback) = (*context).external_interface.get_callback(name) { return external_to_js_value(callback.call(&mut *context, name, args)); } } } INSTANCES.with(move |instances| { if let Ok(instances) = instances.try_borrow() { if let Some(instance) = instances.get(self.0) { if let Ok(mut player) = instance.borrow().core.try_lock() { return external_to_js_value(player.call_internal_interface(name, args)); } } } JsValue::NULL }) } pub fn set_trace_observer(&self, observer: JsValue) { INSTANCES.with(move |instances| { if let Ok(instances) = instances.try_borrow() { if let Some(instance) = instances.get(self.0) { *instance.borrow_mut().trace_observer.borrow_mut() = observer; } } }) } /// Returns the web AudioContext used by this player. /// Returns `None` if the audio backend does not use Web Audio. pub fn audio_context(&self) -> Option { INSTANCES.with(move |instances| { if let Ok(instances) = instances.try_borrow() { if let Some(instance) = instances.get(self.0) { let instance = instance.borrow_mut(); let player = instance.core.lock().unwrap(); return player .audio() .downcast_ref::() .map(|audio| audio.audio_context().clone()); } } None }) } } impl Ruffle { fn new_internal( parent: HtmlElement, js_player: JavascriptPlayer, config: Config, ) -> Result> { let _ = console_log::init_with_level(config.log_level); let allow_script_access = config.allow_script_access; let window = web_sys::window().ok_or("Expected window")?; let document = window.document().ok_or("Expected document")?; let (canvas, renderer) = create_renderer(&document)?; parent .append_child(&canvas.clone().into()) .into_js_result()?; let audio: Box = if let Ok(audio) = audio::WebAudioBackend::new() { Box::new(audio) } else { log::error!("Unable to create audio backend. No audio will be played."); Box::new(NullAudioBackend::new()) }; let navigator = Box::new(navigator::WebNavigatorBackend::new( allow_script_access, config.upgrade_to_https, )); let storage = match window.local_storage() { Ok(Some(s)) => { Box::new(storage::LocalStorageBackend::new(s)) as Box } err => { log::warn!("Unable to use localStorage: {:?}\nData will not save.", err); Box::new(MemoryStorageBackend::default()) } }; let locale = Box::new(locale::WebLocaleBackend::new()); let trace_observer = Arc::new(RefCell::new(JsValue::UNDEFINED)); let log = Box::new(log_adapter::WebLogBackend::new(trace_observer.clone())); let ui = Box::new(ui::WebUiBackend::new(js_player.clone(), &canvas)); let core = ruffle_core::Player::new(renderer, audio, navigator, storage, locale, log, ui)?; { let mut core = core.lock().unwrap(); if let Some(color) = config.background_color.and_then(parse_html_color) { core.set_background_color(Some(color)); } core.set_letterbox(config.letterbox); core.set_warn_on_unsupported_content(config.warn_on_unsupported_content); } // Create instance. let instance = RuffleInstance { core, js_player: js_player.clone(), canvas: canvas.clone(), canvas_width: 0, // Initialize canvas width and height to 0 to force an initial canvas resize. canvas_height: 0, device_pixel_ratio: window.device_pixel_ratio(), animation_handler: None, animation_handler_id: None, mouse_move_callback: None, mouse_down_callback: None, player_mouse_down_callback: None, window_mouse_down_callback: None, mouse_up_callback: None, mouse_wheel_callback: None, key_down_callback: None, key_up_callback: None, unload_callback: None, timestamp: None, has_focus: false, trace_observer, }; // Prevent touch-scrolling on canvas. canvas.style().set_property("touch-action", "none").unwrap(); // Register the instance and create the animation frame closure. let mut ruffle = INSTANCES.with(move |instances| { let index = instances.borrow_mut().insert(RefCell::new(instance)); let instances = instances.borrow(); let ruffle = Ruffle(index); // Create the external interface if allow_script_access { let instance = instances.get(index).unwrap(); let player = instance.borrow().js_player.clone(); instance .borrow() .core .lock() .unwrap() .add_external_interface(Box::new(JavascriptInterface::new(player))); } // Create the animation frame closure. { let mut ruffle = ruffle.clone(); let instance = instances.get(index).unwrap(); instance.borrow_mut().animation_handler = Some(Closure::wrap(Box::new(move |timestamp: f64| { ruffle.tick(timestamp); }) as Box)); } // Create mouse move handler. { let mouse_move_callback = Closure::wrap(Box::new(move |js_event: PointerEvent| { INSTANCES.with(move |instances| { let instances = instances.borrow(); if let Some(instance) = instances.get(index) { let instance = instance.borrow(); let event = PlayerEvent::MouseMove { x: f64::from(js_event.offset_x()) * instance.device_pixel_ratio, y: f64::from(js_event.offset_y()) * instance.device_pixel_ratio, }; instance.core.lock().unwrap().handle_event(event); if instance.has_focus { js_event.prevent_default(); } } }); }) as Box); let canvas_events: &EventTarget = canvas.as_ref(); canvas_events .add_event_listener_with_callback( "pointermove", mouse_move_callback.as_ref().unchecked_ref(), ) .unwrap(); let instance = instances.get(index).unwrap(); instance.borrow_mut().mouse_move_callback = Some(mouse_move_callback); } // Create mouse down handler. { let mouse_down_callback = Closure::wrap(Box::new(move |js_event: PointerEvent| { INSTANCES.with(move |instances| { let instances = instances.borrow(); if let Some(instance) = instances.get(index) { // Only fire player mouse event for left clicks. if js_event.button() == 0 { if let Some(target) = js_event.current_target() { let _ = target .unchecked_ref::() .set_pointer_capture(js_event.pointer_id()); } let device_pixel_ratio = instance.borrow().device_pixel_ratio; let event = PlayerEvent::MouseDown { x: f64::from(js_event.offset_x()) * device_pixel_ratio, y: f64::from(js_event.offset_y()) * device_pixel_ratio, }; instance.borrow().core.lock().unwrap().handle_event(event); } js_event.prevent_default(); } }); }) as Box); let canvas_events: &EventTarget = canvas.as_ref(); canvas_events .add_event_listener_with_callback( "pointerdown", mouse_down_callback.as_ref().unchecked_ref(), ) .unwrap(); let instance = instances.get(index).unwrap(); instance.borrow_mut().mouse_down_callback = Some(mouse_down_callback); } // Create player mouse down handler. { let window = window.clone(); let player_mouse_down_callback = Closure::wrap(Box::new(move |_js_event: PointerEvent| { INSTANCES.with(|instances| { let instances = instances.borrow(); if let Some(instance) = instances.get(index) { instance.borrow_mut().has_focus = true; // Ensure the parent window gets focus. This is necessary for events // to be received when the player is inside a frame. let _ = window.focus(); } }); }) as Box); let js_player_events: &EventTarget = js_player.as_ref(); js_player_events .add_event_listener_with_callback( "pointerdown", player_mouse_down_callback.as_ref().unchecked_ref(), ) .unwrap(); let instance = instances.get(index).unwrap(); instance.borrow_mut().player_mouse_down_callback = Some(player_mouse_down_callback); } // Create window mouse down handler. { let window_mouse_down_callback = Closure::wrap(Box::new(move |_js_event: PointerEvent| { INSTANCES.with(|instances| { let instances = instances.borrow(); if let Some(instance) = instances.get(index) { // If we actually clicked on the player, this will be reset to true // after the event bubbles down to the player. instance.borrow_mut().has_focus = false; } }); }) as Box); window .add_event_listener_with_callback_and_bool( "pointerdown", window_mouse_down_callback.as_ref().unchecked_ref(), true, // Use capture so this first *before* the player mouse down handler. ) .unwrap(); let instance = instances.get(index).unwrap(); instance.borrow_mut().window_mouse_down_callback = Some(window_mouse_down_callback); } // Create mouse up handler. { let mouse_up_callback = Closure::wrap(Box::new(move |js_event: PointerEvent| { INSTANCES.with(move |instances| { let instances = instances.borrow(); if let Some(instance) = instances.get(index) { let instance = instance.borrow(); // Only fire player mouse event for left clicks. if js_event.button() == 0 { if let Some(target) = js_event.current_target() { let _ = target .unchecked_ref::() .release_pointer_capture(js_event.pointer_id()); } let event = PlayerEvent::MouseUp { x: f64::from(js_event.offset_x()) * instance.device_pixel_ratio, y: f64::from(js_event.offset_y()) * instance.device_pixel_ratio, }; instance.core.lock().unwrap().handle_event(event); } if instance.has_focus { js_event.prevent_default(); } } }); }) as Box); let canvas_events: &EventTarget = canvas.as_ref(); canvas_events .add_event_listener_with_callback( "pointerup", mouse_up_callback.as_ref().unchecked_ref(), ) .unwrap(); let instance = instances.get(index).unwrap(); instance.borrow_mut().mouse_up_callback = Some(mouse_up_callback); } // Create mouse wheel handler. { let mouse_wheel_callback = Closure::wrap(Box::new(move |js_event: WheelEvent| { INSTANCES.with(move |instances| { let instances = instances.borrow(); if let Some(instance) = instances.get(index) { let delta = match js_event.delta_mode() { WheelEvent::DOM_DELTA_LINE => { MouseWheelDelta::Lines(-js_event.delta_y()) } WheelEvent::DOM_DELTA_PIXEL => { MouseWheelDelta::Pixels(-js_event.delta_y()) } _ => return, }; let core = &instance.borrow().core; let mut core_lock = core.lock().unwrap(); core_lock.handle_event(PlayerEvent::MouseWheel { delta }); if core_lock.should_prevent_scrolling() { js_event.prevent_default(); } } }); }) as Box); let canvas_events: &EventTarget = canvas.as_ref(); let mut options = AddEventListenerOptions::new(); options.passive(false); canvas_events .add_event_listener_with_callback_and_add_event_listener_options( "wheel", mouse_wheel_callback.as_ref().unchecked_ref(), &options, ) .unwrap(); let instance = instances.get(index).unwrap(); instance.borrow_mut().mouse_wheel_callback = Some(mouse_wheel_callback); } // Create keydown event handler. { let key_down_callback = Closure::wrap(Box::new(move |js_event: KeyboardEvent| { INSTANCES.with(|instances| { if let Some(instance) = instances.borrow().get(index) { let instance = instance.borrow(); if instance.has_focus { let mut core = instance.core.lock().unwrap(); let ui = core.ui_mut().downcast_mut::().unwrap(); ui.keydown(&js_event); let key_code = ui.last_key_code(); let key_char = ui.last_key_char(); if key_code != KeyCode::Unknown { core.handle_event(PlayerEvent::KeyDown { key_code }); } if let Some(codepoint) = key_char { core.handle_event(PlayerEvent::TextInput { codepoint }); } js_event.prevent_default(); } } }); }) as Box); window .add_event_listener_with_callback( "keydown", key_down_callback.as_ref().unchecked_ref(), ) .unwrap(); let instance = instances.get(index).unwrap(); instance.borrow_mut().key_down_callback = Some(key_down_callback); } // Create keyup event handler. { let key_up_callback = Closure::wrap(Box::new(move |js_event: KeyboardEvent| { js_event.prevent_default(); INSTANCES.with(|instances| { if let Some(instance) = instances.borrow().get(index) { let instance = instance.borrow(); if instance.has_focus { let mut core = instance.core.lock().unwrap(); let ui = core.ui_mut().downcast_mut::().unwrap(); ui.keyup(&js_event); let key_code = ui.last_key_code(); if key_code != KeyCode::Unknown { core.handle_event(PlayerEvent::KeyUp { key_code }); } js_event.prevent_default(); } } }); }) as Box); window .add_event_listener_with_callback( "keyup", key_up_callback.as_ref().unchecked_ref(), ) .unwrap(); let mut instance = instances.get(index).unwrap().borrow_mut(); instance.key_up_callback = Some(key_up_callback); } { let unload_callback = Closure::wrap(Box::new(move |_| { INSTANCES.with(|instances| { if let Some(instance) = instances.borrow().get(index) { let instance = instance.borrow(); let mut player = instance.core.lock().unwrap(); player.flush_shared_objects(); } }); }) as Box); window .add_event_listener_with_callback( "unload", unload_callback.as_ref().unchecked_ref(), ) .unwrap(); let mut instance = instances.get(index).unwrap().borrow_mut(); instance.unload_callback = Some(unload_callback); } ruffle }); // Set initial timestamp and do initial tick to start animation loop. ruffle.tick(0.0); Ok(ruffle) } fn tick(&mut self, timestamp: f64) { INSTANCES.with(|instances| { let instances = instances.borrow(); if let Some(instance) = instances.get(self.0) { let window = web_sys::window().unwrap(); let mut mut_instance = instance.borrow_mut(); // Calculate the dt from last tick. let dt = if let Some(prev_timestamp) = mut_instance.timestamp { mut_instance.timestamp = Some(timestamp); timestamp - prev_timestamp } else { // Store the timestamp from the initial tick. // (I tried to use Performance.now() to get the initial timestamp, // but this didn't seem to be accurate and caused negative dts on // Chrome.) mut_instance.timestamp = Some(timestamp); 0.0 }; drop(mut_instance); let core = instance.borrow().core.clone(); let mut core_lock = core.lock().unwrap(); core_lock.tick(dt); let mut needs_render = core_lock.needs_render(); // Check for canvas resize. let canvas = instance.borrow().canvas.to_owned(); let canvas_width = canvas.client_width(); let canvas_height = canvas.client_height(); let device_pixel_ratio = window.device_pixel_ratio(); // Changes via user zooming. if instance.borrow().canvas_width != canvas_width || instance.borrow().canvas_height != canvas_height || (instance.borrow().device_pixel_ratio - device_pixel_ratio).abs() >= std::f64::EPSILON { let mut mut_instance = instance.borrow_mut(); // If a canvas resizes, its drawing context will get scaled. You must reset // the width and height attributes of the canvas element to recreate the context. // (NOT the CSS width/height!) mut_instance.canvas_width = canvas_width; mut_instance.canvas_height = canvas_height; mut_instance.device_pixel_ratio = device_pixel_ratio; drop(mut_instance); // The actual viewport is scaled by DPI, bigger than CSS pixels. let viewport_width = (f64::from(canvas_width) * device_pixel_ratio) as u32; let viewport_height = (f64::from(canvas_height) * device_pixel_ratio) as u32; canvas.set_width(viewport_width); canvas.set_height(viewport_height); core_lock.set_viewport_dimensions(viewport_width, viewport_height); core_lock .renderer_mut() .set_viewport_dimensions(viewport_width, viewport_height); // Force a re-render if we resize. needs_render = true; } if needs_render { core_lock.render(); } // Request next animation frame. let mut instance = instance.borrow_mut(); if let Some(handler) = &instance.animation_handler { let window = web_sys::window().unwrap(); let id = window .request_animation_frame(handler.as_ref().unchecked_ref()) .unwrap(); instance.animation_handler_id = NonZeroI32::new(id); } else { instance.animation_handler_id = None; } } }); } } struct JavascriptMethod { this: JsValue, function: JsValue, } impl ExternalInterfaceMethod for JavascriptMethod { fn call( &self, context: &mut UpdateContext<'_, '_, '_>, args: &[ExternalValue], ) -> ExternalValue { let old_context = CURRENT_CONTEXT.with(|v| { v.replace(Some(unsafe { std::mem::transmute::< &mut UpdateContext, &mut UpdateContext<'static, 'static, 'static>, >(context) } as *mut UpdateContext)) }); let result = if let Some(function) = self.function.dyn_ref::() { let args_array = Array::new(); for arg in args { args_array.push(&external_to_js_value(arg.to_owned())); } if let Ok(result) = function.apply(&self.this, &args_array) { js_to_external_value(&result) } else { ExternalValue::Null } } else { ExternalValue::Null }; CURRENT_CONTEXT.with(|v| v.replace(old_context)); result } } impl JavascriptInterface { fn new(js_player: JavascriptPlayer) -> Self { Self { js_player } } fn find_method(&self, root: JsValue, name: &str) -> Option { let mut parent = JsValue::UNDEFINED; let mut value = root; for key in name.split('.') { parent = value; value = js_sys::Reflect::get(&parent, &JsValue::from_str(key)).ok()?; } if value.is_function() { Some(JavascriptMethod { this: parent, function: value, }) } else { None } } } impl ExternalInterfaceProvider for JavascriptInterface { fn get_method(&self, name: &str) -> Option> { if let Some(method) = self.find_method(self.js_player.clone().into(), name) { return Some(Box::new(method)); } if let Some(window) = web_sys::window() { if let Some(method) = self.find_method(window.into(), name) { return Some(Box::new(method)); } } None } fn on_callback_available(&self, name: &str) { self.js_player.on_callback_available(name); } fn on_fs_command(&self, command: &str, args: &str) -> bool { self.js_player .on_fs_command(command, args) .unwrap_or_default() } } fn js_to_external_value(js: &JsValue) -> ExternalValue { if let Some(value) = js.as_f64() { ExternalValue::Number(value) } else if let Some(value) = js.as_string() { ExternalValue::String(value) } else if let Some(value) = js.as_bool() { ExternalValue::Bool(value) } else if let Some(array) = js.dyn_ref::() { let mut values = Vec::new(); for value in array.values() { if let Ok(value) = value { values.push(js_to_external_value(&value)); } } ExternalValue::List(values) } else if let Some(object) = js.dyn_ref::() { let mut values = BTreeMap::new(); for entry in Object::entries(&object).values() { if let Ok(entry) = entry.and_then(|v| v.dyn_into::()) { if let Some(key) = entry.get(0).as_string() { values.insert(key, js_to_external_value(&entry.get(1))); } } } ExternalValue::Object(values) } else { ExternalValue::Null } } fn external_to_js_value(external: ExternalValue) -> JsValue { match external { Value::Null => JsValue::NULL, Value::Bool(value) => JsValue::from_bool(value), Value::Number(value) => JsValue::from_f64(value), Value::String(value) => JsValue::from_str(&value), Value::Object(object) => { let entries = Array::new(); for (key, value) in object { entries.push(&Array::of2( &JsValue::from_str(&key), &external_to_js_value(value), )); } if let Ok(result) = Object::from_entries(&entries) { result.into() } else { JsValue::NULL } } Value::List(values) => { let array = Array::new(); for value in values { array.push(&external_to_js_value(value)); } array.into() } } } fn create_renderer( document: &web_sys::Document, ) -> Result<(HtmlCanvasElement, Box), Box> { #[cfg(not(any(feature = "canvas", feature = "webgl")))] std::compile_error!("You must enable one of the render backend features (e.g., webgl)."); // Try to create a backend, falling through to the next backend on failure. // We must recreate the canvas each attempt, as only a single context may be created per canvas // with `getContext`. #[cfg(feature = "webgl")] { log::info!("Creating WebGL renderer..."); let canvas: HtmlCanvasElement = document .create_element("canvas") .into_js_result()? .dyn_into() .map_err(|_| "Expected HtmlCanvasElement")?; match ruffle_render_webgl::WebGlRenderBackend::new(&canvas) { Ok(renderer) => return Ok((canvas, Box::new(renderer))), Err(error) => log::error!("Error creating WebGL renderer: {}", error), } } #[cfg(feature = "canvas")] { log::info!("Falling back to Canvas renderer..."); let canvas: HtmlCanvasElement = document .create_element("canvas") .into_js_result()? .dyn_into() .map_err(|_| "Expected HtmlCanvasElement")?; match ruffle_render_canvas::WebCanvasRenderBackend::new(&canvas) { Ok(renderer) => return Ok((canvas, Box::new(renderer))), Err(error) => log::error!("Error creating canvas renderer: {}", error), } } Err("Unable to create renderer".into()) } pub fn set_panic_handler() { static HOOK_HAS_BEEN_SET: Once = Once::new(); HOOK_HAS_BEEN_SET.call_once(|| { std::panic::set_hook(Box::new(|info| { RUFFLE_GLOBAL_PANIC.call_once(|| { console_error_panic_hook::hook(info); let error = JsError::new(&info.to_string()); let _ = INSTANCES.try_with(|instances| { let mut players = Vec::new(); // We have to be super cautious to not panic here, and not hold any borrows for // longer than we need to. // We grab all of the JsPlayers out from the list and release our hold, as they // may call back to destroy() - which will mutably borrow instances. if let Ok(instances) = instances.try_borrow() { for (_, instance) in instances.iter() { if let Ok(player) = instance.try_borrow().map(|i| i.js_player.clone()) { players.push(player); } } } for player in players { player.panic(&error); } }); }); })); }); } fn populate_movie_parameters(input: &JsValue, output: &mut PropertyMap) { if let Ok(keys) = js_sys::Reflect::own_keys(input) { for key in keys.values() { if let Ok(key) = key { if let Ok(value) = js_sys::Reflect::get(input, &key) { if let (Some(key), Some(value)) = (key.as_string(), value.as_string()) { output.insert(&key, value, false); } } } } } } fn parse_html_color(color: impl AsRef) -> Option { // Parse classic HTML hex color (XXXXXX or #XXXXXX), attempting to match browser behavior. // Optional leading #. let mut color = color.as_ref(); color = color.strip_prefix('#').unwrap_or(color); // Fail if less than 6 digits. if color.len() < 6 { return None; } // Each char represents 4-bits. Invalid hex digit is allowed (converts to 0). let mut ret: u32 = 0; for c in color[..6].bytes() { let digit = match c { b'0'..=b'9' => c - b'0', b'a'..=b'f' => c - b'a' + 10, b'A'..=b'F' => c - b'A' + 10, _ => 0, }; ret <<= 4; ret |= u32::from(digit); } Some(Color::from_rgb(ret, 255)) }