tencent cloud

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?
)

// Create store instance
val store = CoHostStore.create("live_room_123")

// Subscribe to state changes
lifecycleScope.launch {
    store.coHostState.coHostStatus.collect { status ->
        println("Connection status: $status")
    }
}

lifecycleScope.launch {
    store.coHostState.connected.collect { connected ->
        println("Connected hosts: ${connected.size}")
    }
}

// Add connection event listener
store.addCoHostListener(object : CoHostListener() {
    override fun onCoHostRequestReceived(inviter: SeatUserInfo, extensionInfo: String) {
        println("Received connection request from ${inviter.userName}")
        // Show accept/reject UI
    }
    override fun onCoHostRequestAccepted(invitee: SeatUserInfo) {
        println("Connection request accepted by ${invitee.userName}")
    }
    override fun onCoHostUserJoined(userInfo: SeatUserInfo) {
        println("Host ${userInfo.userName} joined connection")
    }
})

// Initiate connection request
store.requestHostConnection(
    targetHostLiveID = "target_live_id",
    layoutTemplate = CoHostLayoutTemplate.HOST_DYNAMIC_GRID,
    timeout = 30,
    extraInfo = "",
    completion = { code, message ->
        if (code == 0) {
            println("Connection request sent successfully")
        }
    }
)