Bot speaking callbacks

pipecat-ai · Aug 19, 2024 · 8cb3ffe · 8cb3ffe
1 parent 9a095f2
commit 8cb3ffe
Show file tree

Hide file tree

Showing 4 changed files with 17 additions and 7 deletions.
diff --git a/.github/workflows/ci.yaml b/.github/workflows/ci.yaml
@@ -45,5 +45,5 @@ jobs:
       - name: Upload Maven repo
         uses: actions/upload-artifact@v4
         with:
-          name: Release Library Repo
+          name: RTVIClientAndroid-Repo
           path: build/RTVILocalRepo
diff --git a/rtvi-client-android/src/main/java/ai/rtvi/client/VoiceClient.kt b/rtvi-client-android/src/main/java/ai/rtvi/client/VoiceClient.kt
@@ -166,6 +166,14 @@ open class VoiceClient(
                         callbacks.onUserStoppedSpeaking()
                     }
 
+                    MsgServerToClient.Type.BotStartedSpeaking -> {
+                        callbacks.onBotStartedSpeaking()
+                    }
+
+                    MsgServerToClient.Type.BotStoppedSpeaking -> {
+                        callbacks.onBotStoppedSpeaking()
+                    }
+
                     else -> {
 
                         var match = false

diff --git a/rtvi-client-android/src/main/java/ai/rtvi/client/VoiceEventCallbacks.kt b/rtvi-client-android/src/main/java/ai/rtvi/client/VoiceEventCallbacks.kt
@@ -85,12 +85,12 @@ abstract class VoiceEventCallbacks {
     /**
      * Invoked when the bot starts talking.
      */
-    open fun onBotStartedSpeaking(participant: Participant) {}
+    open fun onBotStartedSpeaking() {}
 
     /**
      * Invoked when the bot stops talking.
      */
-    open fun onBotStoppedSpeaking(participant: Participant) {}
+    open fun onBotStoppedSpeaking() {}
 
     /**
      * Invoked when the local user starts talking.
@@ -189,12 +189,12 @@ internal class CallbackInterceptor(vararg listeners: VoiceEventCallbacks): Voice
         callbacks.forEach { it.onRemoteAudioLevel(level, participant) }
     }
 
-    override fun onBotStartedSpeaking(participant: Participant) {
-        callbacks.forEach { it.onBotStartedSpeaking(participant) }
+    override fun onBotStartedSpeaking() {
+        callbacks.forEach { it.onBotStartedSpeaking() }
     }
 
-    override fun onBotStoppedSpeaking(participant: Participant) {
-        callbacks.forEach { it.onBotStoppedSpeaking(participant) }
+    override fun onBotStoppedSpeaking() {
+        callbacks.forEach { it.onBotStoppedSpeaking() }
     }
 
     override fun onUserStartedSpeaking() {

diff --git a/rtvi-client-android/src/main/java/ai/rtvi/client/transport/MsgServerToClient.kt b/rtvi-client-android/src/main/java/ai/rtvi/client/transport/MsgServerToClient.kt
@@ -30,6 +30,8 @@ data class MsgServerToClient(
         const val BotTranscription = "tts-text"
         const val UserStartedSpeaking = "user-started-speaking"
         const val UserStoppedSpeaking = "user-stopped-speaking"
+        const val BotStartedSpeaking = "bot-started-speaking"
+        const val BotStoppedSpeaking = "bot-stopped-speaking"
     }
 
     object Data {