Small WebRTC Transport

dependencies {
    implementation("ai.pipecat:small-webrtc-transport:1.2.0")
}

<uses-permission android:name="android.permission.RECORD_AUDIO" />

import ai.pipecat.client.PipecatClientOptions
import ai.pipecat.client.PipecatEventCallbacks
import ai.pipecat.client.small_webrtc_transport.PipecatClientSmallWebRTC
import ai.pipecat.client.small_webrtc_transport.SmallWebRTCTransport
import ai.pipecat.client.small_webrtc_transport.SmallWebRTCTransportConnectParams
import ai.pipecat.client.types.APIRequest
import ai.pipecat.client.types.BotReadyData
import ai.pipecat.client.types.Value

val callbacks = object : PipecatEventCallbacks() {
    override fun onBackendError(message: String) {
        Log.e(TAG, "Backend error: $message")
    }

    override fun onBotReady(data: BotReadyData) {
        Log.d(TAG, "Bot is ready")
    }
}

val options = PipecatClientOptions(callbacks = callbacks, enableMic = true)
val client = PipecatClientSmallWebRTC(SmallWebRTCTransport(context), options)

// Connect via your server's /start endpoint (recommended)
client.startBotAndConnect(
    APIRequest(
        endpoint = "https://your-server.com/start",
        // Pipecat Cloud and the Pipecat development runner use these fields
        // to decide how to run the bot; unknown fields are ignored
        requestData = Value.Object(
            "transport" to Value.Str("webrtc"),
            "enableDefaultIceServers" to Value.Bool(true),
        )
    )
).withCallback { result ->
    result.errorOrNull?.let { Log.e(TAG, "Connection failed: $it") }
}

// Or connect with coroutines
// client.startBotAndConnect(...).await()

client.connect(
    SmallWebRTCTransportConnectParams(
        webrtcRequestParams = APIRequest(
            endpoint = "https://your-server.com/api/offer",
            requestData = Value.Object()
        )
    )
)

val iceConfig = IceConfig(
    iceServers = listOf(
        IceServer(
            urls = listOf("turn:your-turn-server.com:3478"),
            username = "user",
            credential = "pass"
        )
    )
)

val transport = SmallWebRTCTransport(context, iceConfig = iceConfig)

// Route audio to speakerphone (default) or earpiece
client.updateMic(SmallWebRTCTransport.AudioDevices.Speakerphone.id)
client.updateMic(SmallWebRTCTransport.AudioDevices.Earpiece.id)

// Switch between front and rear cameras
client.updateCam(SmallWebRTCTransport.Cameras.Front.id)
client.updateCam(SmallWebRTCTransport.Cameras.Rear.id)