import android.content.Context

import android.content.pm.PackageManager

import android.os.SystemClock

import android.util.Base64

import android.util.Log

import androidx.core.content.ContextCompat

import kotlinx.coroutines.CoroutineScope

MicCaptureManager(

context = appContext,

scope = scope,

createTranscriptionSession = {

val params =

buildJsonObject {

put("mode", JsonPrimitive("transcription"))

put("transport", JsonPrimitive("gateway-relay"))

put("brain", JsonPrimitive("none"))

}

val response =

operatorSession.request(

"talk.session.create",

params.toString(),

timeoutMs = 15_000,

)

parseTalkSessionId(response)

},

appendTranscriptionAudio = { sessionId, audio, onError ->

val params =

buildJsonObject {

put("sessionId", JsonPrimitive(sessionId))

put("audioBase64", JsonPrimitive(Base64.encodeToString(audio, Base64.NO_WRAP)))

put("timestamp", JsonPrimitive(SystemClock.elapsedRealtime()))

}

operatorSession.sendRequestFrame(

"talk.session.appendAudio",

params.toString(),

timeoutMs = 8_000,

) { error -> onError(error.message) }

},

closeTranscriptionSession = { sessionId ->

val params = buildJsonObject { put("sessionId", JsonPrimitive(sessionId)) }

operatorSession.request(

"talk.session.close",

params.toString(),

timeoutMs = 5_000,

)

},

sendToGateway = { message, onRunIdKnown ->

val idempotencyKey = UUID.randomUUID().toString()

// Notify MicCaptureManager of the idempotency key *before* the network

}

}

private fun parseTalkSessionId(response: String): String {

val root = json.parseToJsonElement(response).asObjectOrNull()

val sessionId =

root?.get("transcriptionSessionId").asStringOrNull()

?: root?.get("sessionId").asStringOrNull()

if (sessionId.isNullOrBlank()) {

throw IllegalStateException("talk.session.create returned no session id")

}

return sessionId

}

private suspend fun refreshBrandingFromGateway() {

if (!_isConnected.value) return

try {