feat: Add runtime permission check for RECORD_AUDIO

Author: google-labs-jules[bot]

firebase-ai/src/main/kotlin/com/google/firebase/ai/LiveGenerativeModel.kt

@@ -113,7 +113,11 @@ internal constructor(
       val receivedJson = JSON.parseToJsonElement(receivedJsonStr)
 
       return if (receivedJson is JsonObject && "setupComplete" in receivedJson) {
-        LiveSession(session = webSession, blockingDispatcher = blockingDispatcher)
+        LiveSession(
+          session = webSession,
+          blockingDispatcher = blockingDispatcher,
+          firebaseApp = controller.firebaseApp
+        )
       } else {
         webSession.close()
         throw ServiceConnectionHandshakeFailedException("Unable to connect to the server")

firebase-ai/src/main/kotlin/com/google/firebase/ai/common/APIController.kt

@@ -97,7 +97,7 @@ internal constructor(
   private val requestOptions: RequestOptions,
   httpEngine: HttpClientEngine,
   private val apiClient: String,
-  private val firebaseApp: FirebaseApp,
+  internal val firebaseApp: FirebaseApp,
   private val appVersion: Int = 0,
   private val googleAppId: String,
   private val headerProvider: HeaderProvider?,

firebase-ai/src/main/kotlin/com/google/firebase/ai/type/Exceptions.kt

@@ -222,3 +222,6 @@ public class ServiceConnectionHandshakeFailedException(message: String, cause: T
 /** Catch all case for exceptions not explicitly expected. */
 public class UnknownException internal constructor(message: String, cause: Throwable? = null) :
   FirebaseAIException(message, cause)
+
+/** A required permission is missing. */
+public class PermissionMissingException(message: String) : FirebaseAIException(message)

firebase-ai/src/main/kotlin/com/google/firebase/ai/type/LiveSession.kt

@@ -24,6 +24,8 @@ import androidx.annotation.RequiresPermission
 import com.google.firebase.ai.common.JSON
 import com.google.firebase.ai.common.util.CancelledCoroutineScope
 import com.google.firebase.ai.common.util.accumulateUntil
+import com.google.firebase.FirebaseApp
+import android.content.pm.PackageManager
 import com.google.firebase.ai.common.util.childJob
 import com.google.firebase.annotations.concurrent.Blocking
 import io.ktor.client.plugins.websocket.ClientWebSocketSession
@@ -58,7 +60,8 @@ public class LiveSession
 internal constructor(
   private val session: ClientWebSocketSession,
   @Blocking private val blockingDispatcher: CoroutineContext,
-  private var audioHelper: AudioHelper? = null
+  private var audioHelper: AudioHelper? = null,
+  private val firebaseApp: FirebaseApp,
 ) {
   /**
    * Coroutine scope that we batch data on for [startAudioConversation].
@@ -93,12 +96,19 @@ internal constructor(
   public suspend fun startAudioConversation(
     functionCallHandler: ((FunctionCallPart) -> FunctionResponsePart)? = null
   ) {
+    val context = firebaseApp.applicationContext
+    if (context.checkSelfPermission(RECORD_AUDIO) !=
+      android.content.pm.PackageManager.PERMISSION_GRANTED
+    ) {
+      throw PermissionMissingException("Missing RECORD_AUDIO permission.")
+    }
+
     FirebaseAIException.catchAsync {
       if (scope.isActive) {
         Log.w(
           TAG,
           "startAudioConversation called after the recording has already started. " +
-            "Call stopAudioConversation to close the previous connection."
+            "Call stopAudioAudioConversation to close the previous connection."
         )
         return@catchAsync
       }