From 9cd8e549796bdc6b4ed574c2f4afd7ed2f8338cd Mon Sep 17 00:00:00 2001
From: metamuffin <metamuffin@disroot.org>
Date: Fri, 9 Dec 2022 21:28:29 +0100
Subject: support for tracks

---
 client-native-lib/src/peer.rs | 28 ++++++++++++++++++++++++++++
 1 file changed, 28 insertions(+)

(limited to 'client-native-lib/src/peer.rs')

diff --git a/client-native-lib/src/peer.rs b/client-native-lib/src/peer.rs
index 82c7c94..b271318 100644
--- a/client-native-lib/src/peer.rs
+++ b/client-native-lib/src/peer.rs
@@ -99,6 +99,34 @@ impl Peer {
                 .await;
         }
 
+        {
+            let weak = Arc::<Peer>::downgrade(&peer);
+            peer.peer_connection
+                .on_track(box move |track_remote, receiver| {
+                    let receiver = receiver.unwrap();
+                    let track_remote = track_remote.unwrap();
+                    let peer = weak.upgrade().unwrap();
+                    Box::pin(async move {
+                        let id = &track_remote.stream_id().await;
+                        if let Some(res) = peer.remote_provided.read().await.get(id) {
+                            info!("track for ({:?}) '{:?}'", res.id, res.label);
+                            peer.inst
+                                .event_handler
+                                .resource_connected(
+                                    peer.clone(),
+                                    res,
+                                    TransportChannel::Track(track_remote),
+                                )
+                                .await;
+                        } else {
+                            warn!("got unassociated track; stopping receiver");
+                            receiver.stop().await.unwrap();
+                        }
+                    })
+                })
+                .await;
+        }
+
         {
             let weak = Arc::<Peer>::downgrade(&peer);
             peer.peer_connection
-- 
cgit v1.2.3-70-g09d2