diff --git a/chat-signaling-server/src/signaling/redisexchange.rs b/chat-signaling-server/src/signaling/redisexchange.rs index b511c91..64699ae 100644 --- a/chat-signaling-server/src/signaling/redisexchange.rs +++ b/chat-signaling-server/src/signaling/redisexchange.rs @@ -69,7 +69,7 @@ pub async fn send_message_to_peers( let room: String = message.room; 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 != "" { name = message.sender.to_string(); } else { @@ -85,7 +85,7 @@ pub async fn send_message_to_peers( closing_rx.clone(), )); } - signaling::signaling_message::Message::DiscoverRequest(()) => { + signaling::signaling_message::Message::DiscoverRequest(()) => { // client broadcast discover to room let peers: usize = match redis .publish(format!("chatchat:{room}:discover"), name.clone()) .await @@ -98,7 +98,7 @@ pub async fn send_message_to_peers( }; 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 peers: usize = match redis .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"); } - 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 receiver = message.receiver.unwrap(); let peers: usize = match redis @@ -128,7 +128,7 @@ pub async fn send_message_to_peers( 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 receiver = message.receiver.unwrap(); let peers: usize = match redis @@ -143,7 +143,7 @@ pub async fn send_message_to_peers( }; 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 receiver = message.receiver.unwrap(); let peers: usize = match redis