tensamin/omikron
Watch
6
0
Fork
You've already forked omikron
 0
Code Issues Pull requests 3 Projects Releases Packages Wiki Activity Actions

Call Types

Browse source
This commit is contained in:
Alex Emmet 2025-11-25 17:47:05 +00:00
commit a78bbec294
3 changed files with 4 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

4
src/data/communication.rs
View file

@ -201,7 +201,7 @@ pub enum CommunicationType {
start_stream, start_stream,
end_stream, end_stream,
watch_stream, watch_stream,
call_get, call_token,
call_invite, call_invite,
function, function,
update, update,
@ -253,7 +253,7 @@ impl CommunicationType {
"startstream" => CommunicationType::start_stream, "startstream" => CommunicationType::start_stream,
"endstream" => CommunicationType::end_stream, "endstream" => CommunicationType::end_stream,
"watchstream" => CommunicationType::watch_stream, "watchstream" => CommunicationType::watch_stream,
"callget" => CommunicationType::call_get, "calltoken" => CommunicationType::call_token,
"callinvite" => CommunicationType::call_invite, "callinvite" => CommunicationType::call_invite,
"function" => CommunicationType::function, "function" => CommunicationType::function,
"update" => CommunicationType::update, "update" => CommunicationType::update,

4
src/rho/client_connection.rs
View file

@ -141,7 +141,7 @@ impl ClientConnection {
} }
// Handle get call requests // Handle get call requests
if cv.is_type(CommunicationType::call_get) { if cv.is_type(CommunicationType::call_token) {
self.handle_get_call(cv).await; self.handle_get_call(cv).await;
return; return;
} }
@ -366,7 +366,7 @@ impl ClientConnection {
}; };
if let Some(token) = call_manager::get_call_token(user_id, call_id).await { 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_id(cv.get_id())
.with_receiver(user_id) .with_receiver(user_id)
.add_data_str(DataTypes::call_token, token); .add_data_str(DataTypes::call_token, token);

2
src/rho/iota_connection.rs
View file

@ -7,14 +7,12 @@ use async_tungstenite::WebSocketReceiver;
use async_tungstenite::WebSocketSender; use async_tungstenite::WebSocketSender;
use async_tungstenite::tungstenite::Message; use async_tungstenite::tungstenite::Message;
use json::JsonValue; use json::JsonValue;
use json::parse;
use std::{ use std::{
collections::HashMap, collections::HashMap,
sync::{Arc, Weak}, sync::{Arc, Weak},
}; };
use tokio::sync::RwLock; use tokio::sync::RwLock;
use tokio_util::compat::Compat; use tokio_util::compat::Compat;
use tower::retry::backoff::InvalidBackoff;
use tungstenite::Utf8Bytes; use tungstenite::Utf8Bytes;
use uuid::Uuid; use uuid::Uuid;