web: add mock wasm-socket for building on non-wasm
This commit is contained in:
@@ -4,7 +4,63 @@ use letterbox_shared::WebsocketMessage;
|
||||
use log::{error, info};
|
||||
use seed::prelude::*;
|
||||
use serde::{Deserialize, Serialize};
|
||||
use wasm_sockets::{self, ConnectionStatus, EventClient, Message, WebSocketError};
|
||||
#[cfg(not(target_arch = "wasm32"))]
|
||||
#[allow(dead_code)]
|
||||
mod wasm_sockets {
|
||||
use std::{cell::RefCell, rc::Rc};
|
||||
|
||||
use thiserror::Error;
|
||||
use web_sys::{CloseEvent, ErrorEvent};
|
||||
|
||||
#[derive(Debug)]
|
||||
pub struct JsValue;
|
||||
#[derive(Debug)]
|
||||
pub enum ConnectionStatus {
|
||||
/// Connecting to a server
|
||||
Connecting,
|
||||
/// Connected to a server
|
||||
Connected,
|
||||
/// Disconnected from a server due to an error
|
||||
Error,
|
||||
/// Disconnected from a server without an error
|
||||
Disconnected,
|
||||
}
|
||||
#[derive(Debug)]
|
||||
pub struct EventClient {
|
||||
pub status: Rc<RefCell<ConnectionStatus>>,
|
||||
}
|
||||
impl EventClient {
|
||||
pub fn new(_: &str) -> Result<Self, WebSocketError> {
|
||||
todo!("this is a mock")
|
||||
}
|
||||
pub fn send_string(&self, _essage: &str) -> Result<(), JsValue> {
|
||||
todo!("this is a mock")
|
||||
}
|
||||
pub fn set_on_error(&mut self, _: Option<Box<dyn Fn(ErrorEvent)>>) {
|
||||
todo!("this is a mock")
|
||||
}
|
||||
pub fn set_on_connection(&mut self, _: Option<Box<dyn Fn(&EventClient)>>) {
|
||||
todo!("this is a mock")
|
||||
}
|
||||
pub fn set_on_close(&mut self, _: Option<Box<dyn Fn(CloseEvent)>>) {
|
||||
todo!("this is a mock")
|
||||
}
|
||||
pub fn set_on_message(&mut self, _: Option<Box<dyn Fn(&EventClient, Message)>>) {
|
||||
todo!("this is a mock")
|
||||
}
|
||||
}
|
||||
#[derive(Debug, Clone)]
|
||||
pub enum Message {
|
||||
Text(String),
|
||||
Binary(Vec<u8>),
|
||||
}
|
||||
#[derive(Debug, Clone, Error)]
|
||||
pub enum WebSocketError {}
|
||||
}
|
||||
#[cfg(not(target_arch = "wasm32"))]
|
||||
use wasm_sockets::{ConnectionStatus, EventClient, Message, WebSocketError};
|
||||
#[cfg(target_arch = "wasm32")]
|
||||
use wasm_sockets::{ConnectionStatus, EventClient, Message, WebSocketError};
|
||||
use web_sys::CloseEvent;
|
||||
|
||||
/// Message from the server to the client.
|
||||
@@ -142,9 +198,9 @@ fn create_websocket(orders: &impl Orders<Msg>) -> Result<EventClient, WebSocketE
|
||||
})));
|
||||
|
||||
let send = msg_sender.clone();
|
||||
client.set_on_message(Some(Box::new(
|
||||
move |_: &EventClient, msg: wasm_sockets::Message| decode_message(msg, Rc::clone(&send)),
|
||||
)));
|
||||
client.set_on_message(Some(Box::new(move |_: &EventClient, msg: Message| {
|
||||
decode_message(msg, Rc::clone(&send))
|
||||
})));
|
||||
|
||||
Ok(client)
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user