feat: chime sdk api rewrite

Author: Taz03

chime-sdk/build.gradle.kts

@@ -12,7 +12,7 @@ plugins {
 }
 
 group = "com.wannaverse"
-version = "0.2.1"
+version = "0.3.0"
 
 kotlin {
     androidTarget {

…chimesdk/MeetingActiveSpeakerObserver.kt …averse/chimesdk/ActiveSpeakerObserver.ktchime-sdk/src/androidMain/kotlin/com/wannaverse/chimesdk/MeetingActiveSpeakerObserver.kt renamed to chime-sdk/src/androidMain/kotlin/com/wannaverse/chimesdk/ActiveSpeakerObserver.kt chime-sdk/src/androidMain/kotlin/com/wannaverse/chimesdk/MeetingActiveSpeakerObserver.kt renamed to chime-sdk/src/androidMain/kotlin/com/wannaverse/chimesdk/ActiveSpeakerObserver.kt

@@ -3,20 +3,18 @@ package com.wannaverse.chimesdk
 import com.amazonaws.services.chime.sdk.meetings.audiovideo.AttendeeInfo
 import com.amazonaws.services.chime.sdk.meetings.audiovideo.audio.activespeakerdetector.ActiveSpeakerObserver
 
-object MeetingActiveSpeakerObserver : ActiveSpeakerObserver {
-    private const val SPEAKING_THRESHOLD = 0.05
-    var onActiveSpeakersChanged: ((Set<String>) -> Unit)? = null
+class ActiveSpeakerObserver(val onActiveSpeakersChanged: (Set<String>) -> Unit) : ActiveSpeakerObserver {
+    companion object Companion {
+        private const val SPEAKING_THRESHOLD = 0.05
+    }
 
     override val scoreCallbackIntervalMs: Int = 500
 
     override fun onActiveSpeakerDetected(attendeeInfo: Array<AttendeeInfo>) {}
 
-    override fun onActiveSpeakerScoreChanged(scores: Map<AttendeeInfo, Double>) {
-        if (scores.isEmpty()) return
-        val activeSpeakers = scores
-            .filter { (_, score) -> score > SPEAKING_THRESHOLD }
+    override fun onActiveSpeakerScoreChanged(scores: Map<AttendeeInfo, Double>) =
+        scores.filter { (_, score) -> score > SPEAKING_THRESHOLD }
             .map { (attendee, _) -> attendee.externalUserId }
             .toSet()
-        onActiveSpeakersChanged?.invoke(activeSpeakers)
-    }
+            .let(onActiveSpeakersChanged)
 }

chime-sdk/src/androidMain/kotlin/com/wannaverse/chimesdk/AudioVideoObserverImpl.kt

@@ -10,8 +10,7 @@ class AudioVideoObserverImpl(
     private val onRemoteVideoAvailable: (isAvailable: Boolean, sourceCount: Int) -> Unit,
     private val onCameraSendAvailable: (available: Boolean) -> Unit,
     private val onSessionError: (message: String, isRecoverable: Boolean) -> Unit,
-    private val onVideoNeedsRestart: () -> Unit,
-    private val isJoiningOnMute: Boolean
+    private val onVideoNeedsRestart: () -> Unit
 ) : AudioVideoObserver {
 
     private var isVideoSessionActive = false
@@ -30,10 +29,6 @@ class AudioVideoObserverImpl(
     override fun onAudioSessionStarted(reconnecting: Boolean) {
         onConnectionStatusChanged(ConnectionStatus.CONNECTED)
 
-        if (!reconnecting && isJoiningOnMute) {
-            meetingSession?.audioVideo?.realtimeLocalMute()
-        }
-
         if (reconnecting && shouldRestartVideoAfterReconnect && !isVideoSessionActive) {
             onVideoNeedsRestart()
             shouldRestartVideoAfterReconnect = false