chore: wss -> ws, and example uses local dev server

README.md

@@ -8,5 +8,13 @@ The library wraps the Janus core API and some of the most popular plugins APIs.
 
 ## Examples
 
-- [jarust examples](./jarust/examples/), example usage of jarust.
+To run the examples first you have to lunch the janus server.
+
+```sh
+docker compose up -d
+```
+
+Then you can run any of the these examples:
+
+- [jarust examples](./jarust/examples/), example usage of core jarust.
 - [plugins examples](./jarust_plugins/examples/), example usage of jarust's predefined plugins.

docker-compose.yml

@@ -1,8 +1,8 @@
-version: '2.1'
+version: '3.8'
 
 services:
   janus-gateway:
-    name: janus-server
+    container_name: janus-dev-server
     image: 'canyan/janus-gateway:latest'
     command: ["/usr/local/bin/janus", "-F", "/usr/local/etc/janus"]
     ports:

jarust/examples/raw_echotest.rs

@@ -11,8 +11,8 @@ async fn main() -> anyhow::Result<()> {
     init_logger()?;
 
     let mut connection = jarust::connect(
-        JaConfig::new("wss://janus.conf.meetecho.com/ws", None, "janus"),
-        TransportType::Wss,
+        JaConfig::new("ws://localhost:8188/ws", None, "janus"),
+        TransportType::Ws,
     )
     .await?;
     let session = connection.create(10).await?;

jarust/examples/secure_ws.rs

@@ -0,0 +1,44 @@
+use jarust::jaconfig::JaConfig;
+use jarust::jaconfig::TransportType;
+use jarust::japlugin::Attach;
+use log::LevelFilter;
+use log::SetLoggerError;
+use serde_json::json;
+use simple_logger::SimpleLogger;
+
+#[tokio::main(flavor = "current_thread")]
+async fn main() -> anyhow::Result<()> {
+    init_logger()?;
+
+    let mut connection = jarust::connect(
+        JaConfig::new("wss://janus.conf.meetecho.com/ws", None, "janus"),
+        TransportType::Ws,
+    )
+    .await?;
+    let session = connection.create(10).await?;
+    let (handle, mut event_receiver) = session.attach("janus.plugin.echotest").await?;
+
+    handle
+        .message(json!({
+            "video": true,
+            "audio": true,
+        }))
+        .await?;
+
+    while let Some(event) = event_receiver.recv().await {
+        log::info!("response: {event:?}");
+    }
+
+    Ok(())
+}
+
+fn init_logger() -> Result<(), SetLoggerError> {
+    SimpleLogger::new()
+        .with_level(LevelFilter::Trace)
+        .with_colors(true)
+        .with_module_level("tokio_tungstenite", LevelFilter::Off)
+        .with_module_level("tungstenite", LevelFilter::Off)
+        .with_module_level("want", LevelFilter::Off)
+        .with_module_level("rustls", LevelFilter::Off)
+        .init()
+}

jarust/src/jaconfig.rs

@@ -9,7 +9,7 @@ pub struct JaConfig {
 
 #[derive(Debug, Clone, Copy, PartialEq, Eq)]
 pub enum TransportType {
-    Wss,
+    Ws,
 }
 
 impl JaConfig {

jarust/src/lib.rs

@@ -21,15 +21,15 @@ use prelude::JaResult;
 /// Creates a new connection with janus server from the provided configs
 pub async fn connect(jaconfig: JaConfig, transport_type: TransportType) -> JaResult<JaConnection> {
     let transport = match transport_type {
-        jaconfig::TransportType::Wss => transport::wss::WebsocketTransport::new(),
+        jaconfig::TransportType::Ws => transport::web_socket::WebsocketTransport::new(),
     };
     connect_with_transport(jaconfig, transport).await
 }
 
 #[cfg(target_family = "wasm")]
 /// Creates a new connection with janus server from the provided configs
 pub async fn connect(jaconfig: JaConfig, transport_type: TransportType) -> JaResult<JaConnection> {
-    let transport = transport::wasm_wss::WasmWsTransport;
+    let transport = transport::wasm_web_socket::WasmWsTransport;
     connect_with_transport(jaconfig, transport).await
 }
 

jarust/src/transport/mod.rs

@@ -1,5 +1,5 @@
 pub mod trans;
 #[cfg(target_family = "wasm")]
-pub mod wasm_wss;
+pub mod wasm_web_socket;
 #[cfg(not(target_family = "wasm"))]
-pub mod wss;
+pub mod web_socket;

jarust_plugins/examples/echotest.rs

@@ -12,8 +12,8 @@ async fn main() -> anyhow::Result<()> {
     init_logger()?;
 
     let mut connection = jarust::connect(
-        JaConfig::new("wss://janus.conf.meetecho.com/ws", None, "janus"),
-        TransportType::Wss,
+        JaConfig::new("ws://localhost:8188/ws", None, "janus"),
+        TransportType::Ws,
     )
     .await?;
     let session = connection.create(10).await?;