public/chat-signaling-server-rs
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add comment

Browse Source
This commit is contained in:
guochao 2024-06-04 11:29:50 +08:00
parent 3acfe8a9ea
commit 4e51d58c65
Signed by: guochao
GPG Key ID: 79F7306D2AA32FC3
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
chat-signaling-server/src/signaling/redisexchange.rs
View File

@ -69,7 +69,7 @@ pub async fn send_message_to_peers(
let room: String = message.room; let room: String = message.room;
match inner_message { match inner_message {
signaling::signaling_message::Message::Bootstrap(()) => { signaling::signaling_message::Message::Bootstrap(()) => { // client may need a name, bootstrap all the information here.
if message.sender != "" { if message.sender != "" {
name = message.sender.to_string(); name = message.sender.to_string();
} else { } else {
@ -85,7 +85,7 @@ pub async fn send_message_to_peers(
closing_rx.clone(), closing_rx.clone(),
)); ));
} }
signaling::signaling_message::Message::DiscoverRequest(()) => { signaling::signaling_message::Message::DiscoverRequest(()) => { // client broadcast discover to room
let peers: usize = match redis let peers: usize = match redis
.publish(format!("chatchat:{room}:discover"), name.clone()) .publish(format!("chatchat:{room}:discover"), name.clone())
.await .await
@ -98,7 +98,7 @@ pub async fn send_message_to_peers(
}; };
tracing::info!(peers, room, sender = name, "broadcasting discover"); tracing::info!(peers, room, sender = name, "broadcasting discover");
} }
signaling::signaling_message::Message::DiscoverResponse(()) => { signaling::signaling_message::Message::DiscoverResponse(()) => { // client received broadcast from others. responde to it: please connect to me. also it should prepare peer connection before send this message.
let receiver = message.receiver.unwrap(); let receiver = message.receiver.unwrap();
let peers: usize = match redis let peers: usize = match redis
.publish(format!("chatchat:{room}:discover:{receiver}"), name.clone()) .publish(format!("chatchat:{room}:discover:{receiver}"), name.clone())
@ -112,7 +112,7 @@ pub async fn send_message_to_peers(
}; };
tracing::info!(peers, room, sender = name, receiver, "reply to discover"); tracing::info!(peers, room, sender = name, receiver, "reply to discover");
} }
signaling::signaling_message::Message::SessionOffer(sdp) => { signaling::signaling_message::Message::SessionOffer(sdp) => { // client received conenct to me message. creating offer.
let msg = serde_json::to_string(&sdp).unwrap(); let msg = serde_json::to_string(&sdp).unwrap();
let receiver = message.receiver.unwrap(); let receiver = message.receiver.unwrap();
let peers: usize = match redis let peers: usize = match redis
@ -128,7 +128,7 @@ pub async fn send_message_to_peers(
tracing::info!(peers, room, sender = name, receiver, "offering") tracing::info!(peers, room, sender = name, receiver, "offering")
} }
signaling::signaling_message::Message::SessionAnswer(sdp) => { signaling::signaling_message::Message::SessionAnswer(sdp) => { // answer to offer
let msg = serde_json::to_string(&sdp).unwrap(); let msg = serde_json::to_string(&sdp).unwrap();
let receiver = message.receiver.unwrap(); let receiver = message.receiver.unwrap();
let peers: usize = match redis let peers: usize = match redis
@ -143,7 +143,7 @@ pub async fn send_message_to_peers(
}; };
tracing::info!(peers, room, sender = name, receiver, "answering") tracing::info!(peers, room, sender = name, receiver, "answering")
} }
signaling::signaling_message::Message::IceCandidate(candidate) => { signaling::signaling_message::Message::IceCandidate(candidate) => { // trickle ice
let msg = serde_json::to_string(&candidate).unwrap(); let msg = serde_json::to_string(&candidate).unwrap();
let receiver = message.receiver.unwrap(); let receiver = message.receiver.unwrap();
let peers: usize = match redis let peers: usize = match redis