手动控制说话开始和结束

val config = ConversationalAIAPIConfig(
    rtcEngine = rtcEngine,
    rtmClient = rtmClient,
    renderMode = TranscriptRenderMode.Word,
    enableLog = true,
    enableRenderModeFallback = true
)

val api = ConversationalAIAPIImpl(config)

let config = ConversationalAIAPIConfig(
    rtcEngine: rtcEngine,
    rtmEngine: rtmEngine,
    renderMode: .words,
    enableLog: true,
    enableRenderModeFallback: true
)

convoAIAPI = ConversationalAIAPIImpl(config: config)

const config: IConversationalAIAPIConfig = {
  rtcEngine: rtcEngine,
  rtmEngine: rtmEngine,
  renderMode: ETranscriptHelperMode.WORD,
  enableLog: true,
  enableRenderModeFallback: true,
};

const conversationalAIAPI = await ConversationalAIAPI.init(config);

api.addHandler(object : IConversationalAIAPIEventHandler {
    override fun onUserManualSosEvent(agentUserId: String, event: UserManualSosEvent) {
        // 处理手动 SOS 结果。event.payload.success 表示服务端是否接受。
    }

    override fun onUserManualEosEvent(agentUserId: String, event: UserManualEosEvent) {
        // 处理手动 EOS 结果。
    }

    override fun onAgentManualEosEvent(agentUserId: String, event: AgentManualEosEvent) {
        // 处理服务端因超限等原因触发的自动 EOS 通知。
    }
})

api.subscribeMessage("channelName") { error ->
    if (error != null) {
        // 处理订阅失败
    }
}

convoAIAPI.addHandler(handler: self)

func onUserManualSosEvent(agentUserId: String, event: UserManualSosEvent) {
    // 处理手动 SOS 结果。event.payload.success 表示服务端是否接受。
}

func onUserManualEosEvent(agentUserId: String, event: UserManualEosEvent) {
    // 处理手动 EOS 结果。
}

func onAgentManualEosEvent(agentUserId: String, event: AgentManualEosEvent) {
    // 处理服务端因超限等原因触发的自动 EOS 通知。
}

convoAIAPI.subscribeMessage(channelName: channelName) { error in
    if let error = error {
        print("订阅失败: \(error.message)")
    }
}

import {
  AgoraVoiceAIEvents,
  type UserManualSosEvent,
  type UserManualEosEvent,
  type AgentManualEosEvent,
} from 'agora-agent-client-toolkit'

conversationalAIAPI.on(
  AgoraVoiceAIEvents.USER_MANUAL_SOS,
  (agentUserId: string, event: UserManualSosEvent) => {
    // 处理手动 SOS 结果。event.payload.success 表示服务端是否接受。
  }
)

conversationalAIAPI.on(
  AgoraVoiceAIEvents.USER_MANUAL_EOS,
  (agentUserId: string, event: UserManualEosEvent) => {
    // 处理手动 EOS 结果。
  }
)

conversationalAIAPI.on(
  AgoraVoiceAIEvents.AGENT_MANUAL_EOS,
  (agentUserId: string, event: AgentManualEosEvent) => {
    // 处理服务端因超限等原因触发的自动 EOS 通知。
  }
)

conversationalAIAPI.subscribeMessage(channelName)

api.manualSOS(agentUserId = "agentUserId") { requestId, error ->
    if (error != null) {
        Log.e("ManualSOS", "发送失败: ${error.errorMessage}, requestId=$requestId")
    } else {
        Log.i("ManualSOS", "已发送 SOS, requestId=$requestId")
    }
}

convoAIAPI.manualSOS(agentUserId: agentUid) { requestId, error in
    if let error = error {
        print("发送失败: \(error.message), requestId=\(requestId)")
    } else {
        print("已发送 SOS, requestId=\(requestId)")
    }
}

const requestId = await conversationalAIAPI.manualSOS(
  agentUserId,
  'sos-req-20260612-001'
)

api.manualEOS(agentUserId = "agentUserId") { requestId, error ->
    if (error != null) {
        Log.e("ManualEOS", "发送失败: ${error.errorMessage}, requestId=$requestId")
    } else {
        Log.i("ManualEOS", "已发送 EOS, requestId=$requestId")
    }
}

convoAIAPI.manualEOS(agentUserId: agentUid) { requestId, error in
    if let error = error {
        print("发送失败: \(error.message), requestId=\(requestId)")
    } else {
        print("已发送 EOS, requestId=\(requestId)")
    }
}

const requestId = await conversationalAIAPI.manualEOS(
  agentUserId,
  'eos-req-20260612-001'
)

api.destroy()

convoAIAPI.destroy()

conversationalAIAPI.destroy()