CoHostStore

abstract fun addCoHostListener(
    listener: CoHostListener?
)

abstract fun removeCoHostListener(
    listener: CoHostListener?
)

abstract fun requestHostConnection(
    targetHostLiveID: String?,
    layoutTemplate: CoHostLayoutTemplate,
    timeout: Int,
    extraInfo: String?,
    completion: CompletionHandler?
)

abstract fun cancelHostConnection(
    toHostLiveID: String?,
    completion: CompletionHandler?
)

abstract fun acceptHostConnection(
    fromHostLiveID: String?,
    completion: CompletionHandler?
)

abstract fun rejectHostConnection(
    fromHostLiveID: String?,
    completion: CompletionHandler?
)

abstract fun exitHostConnection(
    completion: CompletionHandler?
)

abstract fun getCoHostCandidates(
    cursor: String,
    completion: CompletionHandler?
)

// 创建 store 实例
val store = CoHostStore.create("live_room_123")

// 订阅状态变化
lifecycleScope.launch {
    store.coHostState.coHostStatus.collect { status ->
        println("连线状态: $status")
    }
}

lifecycleScope.launch {
    store.coHostState.connected.collect { connected ->
        println("已连接主播: ${connected.size}")
    }
}

// 添加连线事件监听器
store.addCoHostListener(object : CoHostListener() {
    override fun onCoHostRequestReceived(inviter: SeatUserInfo, extensionInfo: String) {
        println("收到来自 ${inviter.userName} 的连线请求")
        // 显示接受/拒绝的 UI
    }
    override fun onCoHostRequestAccepted(invitee: SeatUserInfo) {
        println("连线请求被 ${invitee.userName} 接受")
    }
    override fun onCoHostUserJoined(userInfo: SeatUserInfo) {
        println("主播 ${userInfo.userName} 加入连线")
    }
})

// 发起连线请求
store.requestHostConnection(
    targetHostLiveID = "target_live_id",
    layoutTemplate = CoHostLayoutTemplate.HOST_DYNAMIC_GRID,
    timeout = 30,
    extraInfo = "",
    completion = { code, message ->
        if (code == 0) {
            println("连线请求发送成功")
        }
    }
)