101 lines
2.7 KiB
Rust
101 lines
2.7 KiB
Rust
#![doc = include_str!("../README.md")]
|
|
#![doc(html_logo_url = "https://avatars.githubusercontent.com/u/79236386")]
|
|
#![doc(html_favicon_url = "https://avatars.githubusercontent.com/u/79236386")]
|
|
|
|
pub mod adapters {
|
|
#[cfg(feature = "warp")]
|
|
pub mod warp_adapter;
|
|
#[cfg(feature = "warp")]
|
|
pub use warp_adapter::*;
|
|
|
|
#[cfg(feature = "axum")]
|
|
pub mod axum_adapter;
|
|
#[cfg(feature = "axum")]
|
|
pub use axum_adapter::*;
|
|
|
|
#[cfg(feature = "salvo")]
|
|
pub mod salvo_adapter;
|
|
|
|
#[cfg(feature = "salvo")]
|
|
pub use salvo_adapter::*;
|
|
|
|
#[cfg(feature = "rocket")]
|
|
pub mod rocket_adapter;
|
|
#[cfg(feature = "rocket")]
|
|
pub use rocket_adapter::*;
|
|
}
|
|
|
|
pub use adapters::*;
|
|
|
|
mod element;
|
|
pub mod pool;
|
|
mod query;
|
|
use futures_util::{SinkExt, StreamExt};
|
|
pub use pool::*;
|
|
mod eval;
|
|
mod events;
|
|
|
|
pub trait WebsocketTx: SinkExt<String, Error = LiveViewError> {}
|
|
impl<T> WebsocketTx for T where T: SinkExt<String, Error = LiveViewError> {}
|
|
|
|
pub trait WebsocketRx: StreamExt<Item = Result<String, LiveViewError>> {}
|
|
impl<T> WebsocketRx for T where T: StreamExt<Item = Result<String, LiveViewError>> {}
|
|
|
|
#[derive(Debug, thiserror::Error)]
|
|
pub enum LiveViewError {
|
|
#[error("warp error")]
|
|
SendingFailed,
|
|
}
|
|
|
|
static MINIFIED: &str = include_str!("./minified.js");
|
|
|
|
/// This script that gets injected into your app connects this page to the websocket endpoint
|
|
///
|
|
/// Once the endpoint is connected, it will send the initial state of the app, and then start
|
|
/// processing user events and returning edits to the liveview instance.
|
|
///
|
|
/// You can pass a relative path prefixed with "/", or enter a full URL including the protocol
|
|
/// (`ws:` or `wss:`) as an argument.
|
|
///
|
|
/// If you enter a relative path, the web client automatically prefixes the host address in
|
|
/// `window.location` when creating a web socket to LiveView.
|
|
///
|
|
/// ```
|
|
/// // Creates websocket connection to same host as current page
|
|
/// interpreter_glue("/api/liveview");
|
|
///
|
|
/// // Creates websocket connection to specified url
|
|
/// interpreter_glue("ws://localhost:8080/api/liveview");
|
|
/// ```
|
|
pub fn interpreter_glue(url_or_path: &str) -> String {
|
|
// If the url starts with a `/`, generate glue which reuses current host
|
|
let get_ws_url = if url_or_path.starts_with('/') {
|
|
r#"
|
|
let loc = window.location;
|
|
let new_url = "";
|
|
if (loc.protocol === "https:") {{
|
|
new_url = "wss:";
|
|
}} else {{
|
|
new_url = "ws:";
|
|
}}
|
|
new_url += "//" + loc.host + path;
|
|
return new_url;
|
|
"#
|
|
} else {
|
|
"return path;"
|
|
};
|
|
|
|
format!(
|
|
r#"
|
|
<script>
|
|
function __dioxusGetWsUrl(path) {{
|
|
{get_ws_url}
|
|
}}
|
|
|
|
var WS_ADDR = __dioxusGetWsUrl("{url_or_path}");
|
|
{MINIFIED}
|
|
</script>
|
|
"#
|
|
)
|
|
}
|