diff --git a/src/data/communication.rs b/src/data/communication.rs index d96e20b..b63409a 100644 --- a/src/data/communication.rs +++ b/src/data/communication.rs @@ -201,7 +201,7 @@ pub enum CommunicationType { start_stream, end_stream, watch_stream, - call_get, + call_token, call_invite, function, update, @@ -253,7 +253,7 @@ impl CommunicationType { "startstream" => CommunicationType::start_stream, "endstream" => CommunicationType::end_stream, "watchstream" => CommunicationType::watch_stream, - "callget" => CommunicationType::call_get, + "calltoken" => CommunicationType::call_token, "callinvite" => CommunicationType::call_invite, "function" => CommunicationType::function, "update" => CommunicationType::update, diff --git a/src/rho/client_connection.rs b/src/rho/client_connection.rs index a9e3008..6f0e2ef 100644 --- a/src/rho/client_connection.rs +++ b/src/rho/client_connection.rs @@ -141,7 +141,7 @@ impl ClientConnection { } // Handle get call requests - if cv.is_type(CommunicationType::call_get) { + if cv.is_type(CommunicationType::call_token) { self.handle_get_call(cv).await; return; } @@ -366,7 +366,7 @@ impl ClientConnection { }; if let Some(token) = call_manager::get_call_token(user_id, call_id).await { - let response = CommunicationValue::new(CommunicationType::call_get) + let response = CommunicationValue::new(CommunicationType::call_token) .with_id(cv.get_id()) .with_receiver(user_id) .add_data_str(DataTypes::call_token, token); diff --git a/src/rho/iota_connection.rs b/src/rho/iota_connection.rs index b7eb7fb..b827a07 100644 --- a/src/rho/iota_connection.rs +++ b/src/rho/iota_connection.rs @@ -7,14 +7,12 @@ use async_tungstenite::WebSocketReceiver; use async_tungstenite::WebSocketSender; use async_tungstenite::tungstenite::Message; use json::JsonValue; -use json::parse; use std::{ collections::HashMap, sync::{Arc, Weak}, }; use tokio::sync::RwLock; use tokio_util::compat::Compat; -use tower::retry::backoff::InvalidBackoff; use tungstenite::Utf8Bytes; use uuid::Uuid;