diff options
author | metamuffin <metamuffin@disroot.org> | 2022-09-16 23:15:51 +0200 |
---|---|---|
committer | metamuffin <metamuffin@disroot.org> | 2022-09-16 23:15:51 +0200 |
commit | fd005b751d1abc0835c3812f4b12aed55e5aac1c (patch) | |
tree | 5c0b0628f2330b8bb24841d97b836033d151a2f9 /client-native-lib/src/peer.rs | |
parent | ecd6ee088847a7068cb97a728b40450dc5e923b5 (diff) | |
download | keks-meet-fd005b751d1abc0835c3812f4b12aed55e5aac1c.tar keks-meet-fd005b751d1abc0835c3812f4b12aed55e5aac1c.tar.bz2 keks-meet-fd005b751d1abc0835c3812f4b12aed55e5aac1c.tar.zst |
dedup sdptype in rift too
Diffstat (limited to 'client-native-lib/src/peer.rs')
-rw-r--r-- | client-native-lib/src/peer.rs | 25 |
1 files changed, 10 insertions, 15 deletions
diff --git a/client-native-lib/src/peer.rs b/client-native-lib/src/peer.rs index f2ca015..b682bb7 100644 --- a/client-native-lib/src/peer.rs +++ b/client-native-lib/src/peer.rs @@ -4,7 +4,7 @@ Copyright (C) 2022 metamuffin <metamuffin@disroot.org> */ use crate::{ - protocol::{self, RTCSessionDescriptionInit, RelayMessage}, + protocol::{self, RelayMessage, Sdp}, state::{HasPeer, PeerInit, State}, }; use log::info; @@ -103,6 +103,7 @@ impl Peer { info!("received ICE candidate"); self.peer_connection.add_ice_candidate(c).await.unwrap(); } + _ => (), } } @@ -125,15 +126,12 @@ impl Peer { .set_local_description(offer.clone()) .await .unwrap(); - self.send_relay(protocol::RelayMessage::Offer(RTCSessionDescriptionInit { - sdp: offer.sdp, - ty: offer.sdp_type, - })) - .await + self.send_relay(protocol::RelayMessage::Offer(offer.sdp)) + .await } - pub async fn on_offer(&self, offer: RTCSessionDescriptionInit) { + pub async fn on_offer(&self, offer: Sdp) { info!("({}) received offer", self.id); - let offer = RTCSessionDescription::offer(offer.sdp).unwrap(); + let offer = RTCSessionDescription::offer(offer).unwrap(); self.peer_connection .set_remote_description(offer) .await @@ -147,15 +145,12 @@ impl Peer { .set_local_description(offer.clone()) .await .unwrap(); - self.send_relay(protocol::RelayMessage::Answer(RTCSessionDescriptionInit { - sdp: offer.sdp, - ty: offer.sdp_type, - })) - .await + self.send_relay(protocol::RelayMessage::Answer(offer.sdp)) + .await } - pub async fn on_answer(&self, answer: RTCSessionDescriptionInit) { + pub async fn on_answer(&self, answer: Sdp) { info!("({}) received answer", self.id); - let offer = RTCSessionDescription::answer(answer.sdp).unwrap(); + let offer = RTCSessionDescription::answer(answer).unwrap(); self.peer_connection .set_remote_description(offer) .await |