feat: add `setClientRole(role: ClientRole, options?: ClientRoleOption…

…s): Promise<void>`
maxxfrazer · Dec 15, 2020 · 2fef3ae · 2fef3ae
1 parent fcb57cc
commit 2fef3ae
Show file tree

Hide file tree

Showing 4 changed files with 27 additions and 2 deletions.
diff --git a/Annotations.java b/Annotations.java
@@ -857,4 +857,12 @@ public class Annotations {
   @Retention(RetentionPolicy.SOURCE)
   public @interface AgoraVoiceBeautifierPreset {
   }
+
+  @IntDef({
+    Constants.AUDIENCE_LATENCY_LEVEL_LOW_LATENCY,
+    Constants.AUDIENCE_LATENCY_LEVEL_ULTRA_LOW_LATENCY,
+  })
+  @Retention(RetentionPolicy.SOURCE)
+  public @interface AgoraAudienceLatencyLevelType {
+  }
 }
diff --git a/BeanCovertor.kt b/BeanCovertor.kt
@@ -7,6 +7,7 @@ import io.agora.rtc.live.LiveInjectStreamConfig
 import io.agora.rtc.live.LiveTranscoding
 import io.agora.rtc.live.LiveTranscoding.TranscodingUser
 import io.agora.rtc.models.ChannelMediaOptions
+import io.agora.rtc.models.ClientRoleOptions
 import io.agora.rtc.video.*
 
 fun mapToVideoDimensions(map: Map<*, *>): VideoEncoderConfiguration.VideoDimensions {
@@ -177,3 +178,9 @@ fun mapToEncryptionConfig(map: Map<*, *>): EncryptionConfig {
     (map["encryptionKey"] as? String)?.let { encryptionKey = it }
   }
 }
+
+fun mapToClientRoleOptions(map: Map<*, *>): ClientRoleOptions {
+  return ClientRoleOptions().apply {
+    (map["audienceLatencyLevel"] as? Number)?.let { audienceLatencyLevel = it.toInt() }
+  }
+}
diff --git a/RtcChannel.kt b/RtcChannel.kt
@@ -149,7 +149,12 @@ class RtcChannelManager(
   }
 
   override fun setClientRole(params: Map<String, *>, callback: Callback) {
-    callback.code(this[params["channelId"] as String]?.setClientRole((params["role"] as Number).toInt()))
+    val role = (params["role"] as Number).toInt()
+    (params["options"] as? Map<*, *>)?.let {
+      callback.code(this[params["channelId"] as String]?.setClientRole(role, mapToClientRoleOptions(it)))
+      return@setClientRole
+    }
+    callback.code(this[params["channelId"] as String]?.setClientRole(role))
   }
 
   override fun joinChannel(params: Map<String, *>, callback: Callback) {

diff --git a/RtcEngine.kt b/RtcEngine.kt
@@ -364,7 +364,12 @@ class RtcEngineManager(
   }
 
   override fun setClientRole(params: Map<String, *>, callback: Callback) {
-    callback.code(engine?.setClientRole((params["role"] as Number).toInt()))
+    val role = (params["role"] as Number).toInt()
+    (params["options"] as? Map<*, *>)?.let {
+      callback.code(engine?.setClientRole(role, mapToClientRoleOptions(it)))
+      return@setClientRole
+    }
+    callback.code(engine?.setClientRole(role))
   }
 
   override fun joinChannel(params: Map<String, *>, callback: Callback) {