import io.trtc.tuikit.atomicxcore.api.CompletionHandler
import io.trtc.tuikit.atomicxcore.api.live.CoGuestStore

val liveId = "房间ID"
val guestStore = CoGuestStore.create(liveId)

// 用户点击“申请连麦”
fun requestToConnect() {
    // timeout: 请求超时时间，例如 30 秒
    guestStore.applyForSeat(-1, 30, null, object : CompletionHandler {
        override fun onSuccess() {
            print("连麦申请已发送，等待主播处理...")
        }

        override fun onFailure(code: Int, desc: String) {
            print("申请发送失败: $desc")
        }
    })
}

import io.trtc.tuikit.atomicxcore.api.device.DeviceStore
import io.trtc.tuikit.atomicxcore.api.live.GuestListener
import io.trtc.tuikit.atomicxcore.api.live.LiveUserInfo

// 在您的 Activity/Fragment 初始化时添加监听
fun subscribeGuestEvents() {
    val guestListener = object : GuestListener() {
        override fun onGuestApplicationResponded(isAccept: Boolean, hostUser: LiveUserInfo) {
            if (isAccept) {
                print("主播 ${hostUser.userName} 同意了你的申请，准备上麦")
                // 1. 打开摄像头、麦克风
                DeviceStore.shared().openLocalCamera(true, null)
                DeviceStore.shared().openLocalMicrophone(null)
                // 2. 在此更新 UI，例如关闭申请按钮，显示连麦中的状态
            } else {
                print("主播 ${hostUser.userName} 拒绝了你的申请")
                // 弹窗提示用户申请被拒绝
            }
        }
    }
    guestStore.addGuestListener(guestListener)
}

// 用户点击“下麦”按钮
fun leaveSeat() {
    guestStore.disconnect(object : CompletionHandler {
        override fun onSuccess() {
            print("已成功下麦")
        }

        override fun onFailure(code: Int, desc: String) {
            print("下麦失败: $desc")
        }
    })
}

// 用户在等待时，点击“取消申请”
fun cancelRequest() {
    guestStore.cancelApplication(object : CompletionHandler {
        override fun onSuccess() {
            print("申请已取消")
        }

        override fun onFailure(code: Int, desc: String) {
            print("申请取消失败: $desc")
        }
    })
}

import io.trtc.tuikit.atomicxcore.api.live.CoGuestStore
import io.trtc.tuikit.atomicxcore.api.live.HostListener
import io.trtc.tuikit.atomicxcore.api.live.LiveUserInfo

val liveId = "房间ID"
val guestStore = CoGuestStore.create(liveId)

// 订阅主播事件
val hostListener = object : HostListener() {
    override fun onGuestApplicationReceived(guestUser: LiveUserInfo) {
        print("收到观众 ${guestUser.userName} 的连麦申请")
        // 在此更新 UI，例如在“申请列表”按钮上显示红点
    }

    // ... 覆盖其他需要的回调方法
}
guestStore.addHostListener(hostListener)

import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.launch

// 订阅状态变更
fun observeApplicants() {
    CoroutineScope(Dispatchers.Main).launch {
         guestStore.coGuestState.applicants.collect { applicants ->
             print("当前申请人数: ${applicants.size}")
             // 在此刷新您的“申请者列表”UI
         }
    }
}

// 主播点击“同意”按钮，传入申请者的 userID
fun accept(userId: String) {
    guestStore.acceptApplication(
        userId,
        object : CompletionHandler {
            override fun onSuccess() {
                print("已同意 $userId 的申请，对方正在上麦")
            }

            override fun onFailure(code: Int, desc: String) {
                print("同意申请失败: $desc")
            }
        }
    )
}

// 主播点击“拒绝”按钮
fun reject(userId: String) {
    guestStore.rejectApplication(
        userId,
        object : CompletionHandler {
            override fun onSuccess() {
                print("已拒绝 $userId 的申请")
            }

            override fun onFailure(code: Int, desc: String) {
                print("拒绝申请失败: $desc")
            }
        }
    )
}


// 主播选择观众并发起邀请
fun invite(userId: String) {
    // timeout: 邀请超时时间
    guestStore.inviteToSeat(userId, -1, 30, null, object : CompletionHandler {
        override fun onSuccess() {
            print("已向 $userId 发出邀请，等待对方回应...")
        }

        override fun onFailure(code: Int, desc: String) {
            print("邀请发送失败: $desc")
        }
    })
}

// 在 hostListener 的实现中添加
override fun onHostInvitationResponded(isAccept: Boolean, guestUser: LiveUserInfo) {
    if (isAccept) {
        print("观众 ${guestUser.userName} 接受了你的邀请")
    } else {
        print("观众 ${guestUser.userName} 拒绝了你的邀请")
    }
}

// 在 guestListener 的实现中添加
override fun onHostInvitationReceived(hostUser: LiveUserInfo) {
    print("收到主播 ${hostUser.userName} 的连麦邀请")
    // 在此弹出一个对话框，让用户选择“接受”或“拒绝”
}

val inviterId = "发起邀请的主播ID" // 从 onHostInvitationReceived 事件中获取

// 用户点击“接受”
fun accept() {
    guestStore.acceptInvitation(inviterId, object : CompletionHandler {
        override fun onSuccess() {
            // 2. 打开麦克风
            DeviceStore.shared().openLocalMicrophone(null)
        }

        override fun onFailure(code: Int, desc: String) {
            print("接受邀请失败: $desc")
        }
    })
}

// 用户点击“拒绝”
fun reject() {
    guestStore.rejectInvitation(inviterId, object : CompletionHandler {
        override fun onSuccess() {
            // ...
        }
        override fun onFailure(code: Int, desc: String) {
            // ...
        }
    })
}