88af3e7eff
Hotreload the contents of for loops, if chains, component bodies, props, attributes, and any literals discovered in rsx! Add a TUI renderer to the CLI. Improve the CLI build system to be async and parallel. Refactor RSX to allow partial expansion of expressions. Merge autofmt implementations for consistency. Merge the representation of elements and components under the hood. Add a diagnostics system for rsx for improved error messages. Drop interprocess and move to websockets for communication between the CLI and the server. Assign IDs to nodes and attributes in a stable way to be used in non compiler contexts. Add hotreloading to any body of component/for loop/if chain/etc. --------- Co-authored-by: Evan Almloff <evanalmloff@gmail.com> Co-authored-by: Liam Mitchell <liamkarlmitchell@gmail.com>
74 lines
2.5 KiB
Rust
74 lines
2.5 KiB
Rust
use crate::DevserverMsg;
|
|
use futures_util::{SinkExt, StreamExt};
|
|
use tokio::net::TcpStream;
|
|
use tokio_tungstenite::{
|
|
tungstenite::{Message, Result as TtResult},
|
|
MaybeTlsStream, WebSocketStream,
|
|
};
|
|
|
|
pub fn connect(mut callback: impl FnMut(DevserverMsg) + Send + 'static) {
|
|
tokio::spawn(async move {
|
|
let Some(Ok(mut recv)) = NativeReceiver::create_from_cli().await else {
|
|
return;
|
|
};
|
|
while let Some(msg) = recv.next().await {
|
|
match msg {
|
|
Ok(msg) => callback(msg),
|
|
Err(_e) => {}
|
|
}
|
|
}
|
|
});
|
|
}
|
|
|
|
/// A receiver for messages from the devserver
|
|
///
|
|
/// Calling `next` will watch the channel for the next valid message from the devserver
|
|
pub struct NativeReceiver {
|
|
socket: WebSocketStream<MaybeTlsStream<TcpStream>>,
|
|
}
|
|
|
|
impl NativeReceiver {
|
|
/// Connect to the devserver
|
|
async fn create(url: String) -> TtResult<Self> {
|
|
let (socket, _ws) = tokio_tungstenite::connect_async(&url).await?;
|
|
Ok(Self { socket })
|
|
}
|
|
|
|
/// Connect to the devserver with an address from the CLI. Returns None if the current application was not run with the CLI
|
|
pub async fn create_from_cli() -> Option<TtResult<Self>> {
|
|
let cli_args = dioxus_cli_config::RuntimeCLIArguments::from_cli()?;
|
|
let addr = cli_args.cli_address();
|
|
Some(Self::create(format!("ws://{addr}/_dioxus")).await)
|
|
}
|
|
|
|
/// Wait for the next message from the devserver
|
|
///
|
|
/// Returns None when the connection is closed or socket.next() returns None
|
|
pub async fn next(&mut self) -> Option<TtResult<DevserverMsg>> {
|
|
loop {
|
|
let res = self.socket.next().await?;
|
|
|
|
match res {
|
|
Ok(res) => match res {
|
|
Message::Text(text) => {
|
|
let leaked: &'static str = Box::leak(text.into_boxed_str());
|
|
let msg = serde_json::from_str::<DevserverMsg>(leaked);
|
|
if let Ok(msg) = msg {
|
|
return Some(Ok(msg));
|
|
}
|
|
}
|
|
// send a pong
|
|
Message::Ping(_) => {
|
|
let _ = self.socket.send(Message::Pong(vec![])).await;
|
|
}
|
|
Message::Close(_) => return None,
|
|
Message::Binary(_) => {}
|
|
Message::Pong(_) => {}
|
|
Message::Frame(_) => {}
|
|
},
|
|
Err(e) => return Some(Err(e)),
|
|
};
|
|
}
|
|
}
|
|
}
|