hal_sim/ui/
middleware.rs

use core::fmt::Debug;

use yewdux_middleware::*;

use log::{log, Level};

extern crate alloc;
use alloc::rc::Rc;

use super::*;
use crate::dto::*;

pub use io::*;

pub fn log_msg<M, D>(level: Level) -> impl Fn(&MiddlewareContext, M, D)
where
    M: Debug,
    D: MiddlewareDispatch<M>,
{
    move |mcx, msg, dispatch| {
        log!(level, "Dispatching message: {:?}", msg);

        dispatch.invoke(mcx, msg);
    }
}

pub fn log_store<S, M, D>(level: Level) -> impl Fn(&MiddlewareContext, M, D)
where
    S: Store + Debug,
    M: Reducer<S> + Debug,
    D: MiddlewareDispatch<M>,
{
    move |mcx, msg, dispatch| {
        log!(level, "Store (before): {:?}", mcx.context().get::<S>());

        dispatch.invoke(mcx, msg);

        log!(level, "Store (after): {:?}", mcx.context().get::<S>());
    }
}

pub fn hook<S, R>(mcx: &MiddlewareContext, send: S, receive: R)
where
    S: Fn(&MiddlewareContext, UpdateRequest) + 'static,
    R: FnOnce() + 'static,
{
    // Dispatch UpdateRequest messages => send to backend
    mcx.register(send);

    // Dispatch UpdateEvent messages => redispatch as PinMsg or DisplayMsg messages
    mcx.register::<UpdateEvent, _>(|mcx: &MiddlewareContext, event| {
        if let Some(msg) = PinMsg::from_event(&event) {
            mcx.invoke(msg);
        } else if let Some(msg) = DisplayMsg::from_event(&event) {
            FrameBuffer::update(mcx.context(), &msg);
            mcx.invoke(msg);
        }
    });

    mcx.register(store_dispatch::<PinsStore, PinMsg>());
    mcx.register(store_dispatch::<DisplaysStore, DisplayMsg>());

    // Receive from backend => dispatch UpdateEvent messages
    receive();
}

// Set the middleware for each store type (PinsState & DisplaysState)
fn store_dispatch<S, M>() -> impl MiddlewareDispatch<M> + Clone
where
    S: Store + Debug,
    M: Reducer<S> + Debug + 'static,
    for<'a> &'a M: Into<Option<UpdateRequest>>,
{
    // Update store
    MiddlewareContext::store
        // PinMsg => UpdateRequest
        .fuse(as_request)
        // Log store before/after dispatching
        .fuse(Rc::new(log_store(Level::Trace)))
        // Log msg before dispatching
        .fuse(Rc::new(log_msg(Level::Trace)))
}

fn as_request<M, D>(mcx: &MiddlewareContext, msg: M, dispatch: D)
where
    M: Debug + 'static,
    for<'a> &'a M: Into<Option<UpdateRequest>>,
    D: MiddlewareDispatch<M>,
{
    if let Some(request) = (&msg).into() {
        mcx.invoke(request);
    }

    dispatch.invoke(mcx, msg);
}

mod io {
    use core::cell::RefCell;
    use core::fmt::Debug;

    use channel_bridge::asynch::ws::{WsWebReceiver, WsWebSender};
    use channel_bridge::asynch::{Receiver, Sender};

    use log::trace;

    use embassy_sync::{blocking_mutex::raw::CriticalSectionRawMutex, channel};

    use wasm_bindgen_futures::spawn_local;

    extern crate alloc;
    use alloc::rc::Rc;

    use super::*;

    use gloo_net::websocket::futures::WebSocket;

    use futures::StreamExt;

    pub fn init(mcx: &MiddlewareContext, endpoint: Option<&str>) {
        if let Some(endpoint) = endpoint {
            let (sender, receiver) = WebSocket::open(&format!(
                "ws://{}{}",
                web_sys::window().unwrap().location().host().unwrap(),
                endpoint,
            ))
            .unwrap_or_else(|_| panic!("Failed to open websocket"))
            .split();

            hook(mcx, send(WsWebSender::new(sender)), {
                let mcx = mcx.clone();
                move || receive(&mcx, WsWebReceiver::<UpdateEvent>::new(receiver))
            });
        } else {
            pub(crate) static REQUEST_QUEUE: channel::Channel<
                CriticalSectionRawMutex,
                UpdateRequest,
                1,
            > = channel::Channel::new();
            pub(crate) static EVENT_QUEUE: channel::Channel<
                CriticalSectionRawMutex,
                UpdateEvent,
                1,
            > = channel::Channel::new();

            hook(mcx, send(REQUEST_QUEUE.sender()), {
                let mcx = mcx.clone();
                move || receive(&mcx, EVENT_QUEUE.receiver())
            });

            process_local(EVENT_QUEUE.sender(), REQUEST_QUEUE.receiver());
        }
    }

    #[allow(clippy::await_holding_refcell_ref)]
    fn send<S>(sender: S) -> impl Fn(&MiddlewareContext, S::Data)
    where
        S: Sender + 'static,
        S::Data: Debug + 'static,
    {
        let sender = Rc::new(RefCell::new(sender));

        move |_ctx, msg| {
            let sender = sender.clone();

            spawn_local(async move {
                trace!("Sending request: {:?}", msg);

                let mut guard = sender.borrow_mut();

                guard.send(msg).await.unwrap();
            });
        }
    }

    fn receive<R>(mcx: &MiddlewareContext, mut receiver: R)
    where
        R: Receiver + 'static,
        R::Data: Debug + 'static,
    {
        let mcx = mcx.clone();

        spawn_local(async move {
            loop {
                let event = receiver.recv().await.unwrap();
                trace!("Received event: {:?}", event);

                mcx.invoke(event);
            }
        });
    }

    fn process_local<S, R>(sender: S, receiver: R)
    where
        S: Sender<Data = UpdateEvent> + 'static,
        R: Receiver<Data = UpdateRequest, Error = S::Error> + 'static,
    {
        spawn_local(async move {
            crate::io::process(sender, receiver).await;
        });
    }
}
hal_sim/ui/middleware.rs

hal_sim/ui/
middleware.rs
