Implement Connection media state management (#41)

CHANGELOG.md

@@ -59,7 +59,12 @@ All user visible changes to this project will be documented in this file. This p
         - `MediaStateTransitionException`;
         - `MediaSettingsUpdateException`.
     - `MediaManagerHandle.set_output_audio_id()` function switching output audio device on Dart platform ([#29]);
-    - `MediaManagerHandle.on_device_change()` callback firing whenever `MediaManagerHandle.enumerate_devices()` list changes ([#30]).
+    - `MediaManagerHandle.on_device_change()` callback firing whenever `MediaManagerHandle.enumerate_devices()` list changes ([#30]);
+    - `ConnectionHandle` methods ([#43]):
+      - `enable_remote_video`;
+      - `disable_remote_video`;
+      - `enable_remote_audio`;
+      - `disable_remote_audio`.
 
 ### Updated
 
@@ -70,6 +75,7 @@ All user visible changes to this project will be documented in this file. This p
 [#16]: /../../pull/16
 [#29]: /../../pull/29
 [#30]: /../../pull/30
+[#43]: /../../pull/43
 
 
 

Cargo.toml

@@ -52,7 +52,7 @@ tracerr = "0.3"
 url = "2.1"
 
 [target.'cfg(target_os = "android")'.dependencies]
-android_logger = "0.10"
+android_logger = "0.11"
 
 [target.'cfg(any(target_os = "windows", target_os = "linux", target_os = "macos"))'.dependencies]
 simple_logger = "2.1"

e2e/src/object/connection.rs

@@ -1,8 +1,10 @@
 //! `Connection` JS object's representation.
 
+use std::borrow::Cow;
+
 use crate::{
     browser::Statement,
-    object::{tracks_store, Object},
+    object::{tracks_store, MediaKind, Object},
 };
 
 use super::Error;
@@ -28,6 +30,62 @@ impl Object<Connection> {
         .await
     }
 
+    /// Enables remote media receiving for the provided [`MediaKind`].
+    ///
+    /// # Errors
+    ///
+    /// If failed to execute JS statement.
+    pub async fn enable_remote_media(
+        &self,
+        kind: MediaKind,
+    ) -> Result<(), Error> {
+        let enable: Cow<'_, _> = match kind {
+            MediaKind::Audio => "c.conn.enable_remote_audio()".into(),
+            MediaKind::Video => "c.conn.enable_remote_video()".into(),
+        };
+        self.execute(Statement::new(
+            // language=JavaScript
+            &format!(
+                r#"
+                async (c) => {{
+                    await {enable};
+                }}
+                "#,
+            ),
+            [],
+        ))
+        .await
+        .map(drop)
+    }
+
+    /// Disables remote media receiving for the provided [`MediaKind`].
+    ///
+    /// # Errors
+    ///
+    /// If failed to execute JS statement.
+    pub async fn disable_remote_media(
+        &self,
+        kind: MediaKind,
+    ) -> Result<(), Error> {
+        let disable: Cow<'_, _> = match kind {
+            MediaKind::Audio => "c.conn.disable_remote_audio()".into(),
+            MediaKind::Video => "c.conn.disable_remote_video()".into(),
+        };
+        self.execute(Statement::new(
+            // language=JavaScript
+            &format!(
+                r#"
+                async (c) => {{
+                    await {disable};
+                }}
+                "#,
+            ),
+            [],
+        ))
+        .await
+        .map(drop)
+    }
+
     /// Returns a [`Future`] resolving when `Connection.on_close()` callback is
     /// fired.
     ///