define Track/TrackLocal/Remote Trait API

Author: yngrtc

rtc

@@ -3,19 +3,55 @@
 //! This module provides async-friendly wrappers around RTP media tracks.
 
 use crate::runtime::{Mutex, Receiver, Sender};
-use rtc::rtp_transceiver::{RTCRtpReceiverId, RTCRtpSenderId};
+use rtc::rtp_transceiver::{RTCRtpReceiverId, RTCRtpSenderId, RtpStreamId, SSRC};
 use rtc::shared::error::Result;
 
 pub use rtc::media_stream::{MediaStreamId, MediaStreamTrack, MediaStreamTrackId};
+use rtc::media_stream::{
+    MediaStreamTrackState, MediaTrackCapabilities, MediaTrackConstraints, MediaTrackSettings,
+};
+use rtc::rtp_transceiver::rtp_sender::{RTCRtpCodec, RtpCodecKind};
+use rtc::{rtcp, rtp};
 
 #[async_trait::async_trait]
-pub trait TrackLocal: Send + Sync + 'static {
-    async fn close(&self) -> Result<()>;
+pub trait Track: Send + Sync + 'static {
+    async fn stream_id(&self) -> MediaStreamId;
+    async fn track_id(&self) -> MediaStreamTrackId;
+    async fn label(&self) -> String;
+    async fn kind(&self) -> RtpCodecKind;
+    async fn rid(&self, ssrc: SSRC) -> Option<RtpStreamId>;
+    async fn codec(&self, ssrc: SSRC) -> Option<RTCRtpCodec>;
+    async fn ssrcs(&self) -> Vec<SSRC>;
+    async fn enabled(&self) -> bool;
+    async fn set_enabled(&self, enabled: bool);
+    async fn muted(&self) -> bool;
+    async fn ready_state(&self) -> MediaStreamTrackState;
+    async fn stop(&self);
+    async fn get_capabilities(&self) -> MediaTrackCapabilities;
+    async fn get_constraints(&self) -> MediaTrackConstraints;
+    async fn get_settings(&self) -> MediaTrackSettings;
+    async fn apply_constraints(&self, constraints: Option<MediaTrackConstraints>);
 }
 
 #[async_trait::async_trait]
-pub trait TrackRemote: Send + Sync + 'static {
-    async fn close(&self) -> Result<()>;
+pub trait TrackLocal: Track {
+    async fn write_rtp(&self, packet: rtp::Packet) -> Result<()>;
+    async fn write_rtcp(&self, packets: Vec<Box<dyn rtcp::Packet>>) -> Result<()>;
+}
+
+#[derive(Debug, Clone)]
+pub enum TrackRemoteEvent {
+    OnMute,
+    OnUnmute,
+    OnEnded,
+    OnRtpPacket(rtp::Packet),
+    OnRtcpPacket(Vec<Box<dyn rtcp::Packet>>),
+}
+
+#[async_trait::async_trait]
+pub trait TrackRemote: Track {
+    async fn write_rtcp(&self, packets: Vec<Box<dyn rtcp::Packet>>) -> Result<()>;
+    async fn poll(&self) -> Option<TrackRemoteEvent>;
 }
 
 /// A local track that sends RTP packets