Commit ed063e7c by qlintonger xeno

对接GetCompanyUserList成功+1

parent e1abb6bd
use crate::events::Event; use crate::events::Event;
use crate::handles::online_users_update::{online_messages, send_online_users_resp}; use crate::handles::online_users_update::{online_messages, send_online_users_resp};
use tokio::sync::mpsc::UnboundedSender; use tokio::sync::mpsc::UnboundedSender;
use crate::handles::handle_agora_call::handle_agora_call;
pub async fn handle_ws_msg( pub async fn handle_ws_msg(
msg_type: String, msg_type: String,
...@@ -29,6 +30,9 @@ pub async fn handle_ws_msg( ...@@ -29,6 +30,9 @@ pub async fn handle_ws_msg(
} }
} }
} }
"Call" | "CancelCall" => {
handle_agora_call(&msg_type, &from_id, &event_sender, &connection_time).await;
}
_ => {} _ => {}
} }
} }
use crate::events::Event;
use tokio::sync::mpsc::UnboundedSender;
pub async fn handle_agora_call(
msg_type: &String,
from_id: &String,
event_sender: &UnboundedSender<Event>,
connection_time: &u128,
) {
}
...@@ -2,4 +2,4 @@ pub mod handshake; ...@@ -2,4 +2,4 @@ pub mod handshake;
pub mod heartbeat; pub mod heartbeat;
pub mod online_users_update; pub mod online_users_update;
pub mod redis; pub mod redis;
mod handle_agora_call; pub mod handle_agora_call;
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment