silkenweb-dom 0.1.3

use std::cell::RefCell;

use wasm_bindgen::{prelude::Closure, JsCast, JsValue};

use crate::window;

pub fn queue_update(x: impl 'static + FnOnce()) {
    let len = {
        PENDING_UPDATES.with(|update_queue| {
            let mut update_queue = update_queue.borrow_mut();

            update_queue.push(Box::new(x));
            update_queue.len()
        })
    };

    if len == 1 {
        request_render_updates();
    }
}

/// Run a closure after the next render.
pub fn after_render(x: impl 'static + FnOnce()) {
    PENDING_EFFECTS.with(|pending_effects| pending_effects.borrow_mut().push(Box::new(x)));
}

/// Render any pending updates.
///
/// This is mostly useful for testing.
pub fn render_updates() {
    PENDING_UPDATES.with(|update_queue| {
        let update_queue = update_queue.take();

        for update in update_queue {
            update();
        }
    });

    PENDING_EFFECTS.with(|effect_queue| {
        for effect in effect_queue.take() {
            effect();
        }
    });
}

fn request_render_updates() {
    ON_ANIMATION_FRAME.with(|process_updates| {
        window()
            .request_animation_frame(process_updates.as_ref().unchecked_ref())
            .unwrap()
    });
}

thread_local!(
    static PENDING_UPDATES: RefCell<Vec<Box<dyn FnOnce()>>> = RefCell::new(Vec::new());
    static PENDING_EFFECTS: RefCell<Vec<Box<dyn FnOnce()>>> = RefCell::new(Vec::new());
    static ON_ANIMATION_FRAME: Closure<dyn FnMut(JsValue)> =
        Closure::wrap(Box::new(move |_time_stamp: JsValue| {
            render_updates();
        }));
);