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

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

// 用户点击"申请连麦"
fun requestToConnect() {
    // timeout: 请求超时时间，例如 30 秒
    guestStore.applyForSeat(
        seatIndex = 0, // 麦位索引
        timeout = 30,
        extraInfo = null,
        completion = object : CompletionHandler {
            override fun onSuccess() {
                println("连麦申请已发送，等待主播处理...")
            }

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

import android.os.Bundle
import androidx.appcompat.app.AppCompatActivity
import io.trtc.tuikit.atomicxcore.api.device.DeviceStore
import io.trtc.tuikit.atomicxcore.api.live.CoGuestStore
import io.trtc.tuikit.atomicxcore.api.live.GuestListener
import io.trtc.tuikit.atomicxcore.api.live.LiveUserInfo

// 在您的Activity或Fragment中实现监听
class YourActivity : AppCompatActivity() {
    val liveId = "房间ID"
    val guestStore = CoGuestStore.create(liveId)
    val deviceStore = DeviceStore.shared()
    private val guestListener = object : GuestListener() {
        override fun onGuestApplicationResponded(isAccept: Boolean, hostUser: LiveUserInfo) {
            if (isAccept) {
                println("主播 ${hostUser.userName} 同意了你的申请，准备上麦")
                // 上麦申请被同意，进行上麦后的操作
                // 1. 打开摄像头、麦克风
                DeviceStore.shared().openLocalCamera(true, completion = null)
                DeviceStore.shared().openLocalMicrophone(completion = null)
                // 2. 在此更新 UI，例如关闭申请按钮，显示连麦中的状态
            } else {
                println("主播 ${hostUser.userName} 拒绝了你的申请")
                // 上麦申请被拒绝，弹窗提示
            }
        }
    }

    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        // 添加监听器
        guestStore.addGuestListener(guestListener)
    }

    override fun onDestroy() {
        super.onDestroy()
        // 移除监听器
        guestStore.removeGuestListener(guestListener)
    }
}

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

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

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

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

import android.os.Bundle
import androidx.appcompat.app.AppCompatActivity
import io.trtc.tuikit.atomicxcore.api.live.CoGuestStore
import io.trtc.tuikit.atomicxcore.api.live.HostListener
import io.trtc.tuikit.atomicxcore.api.live.LiveUserInfo

class YourActivity : AppCompatActivity() {
    val liveId = "房间ID"
    val guestStore = CoGuestStore.create(liveId)
    val hostListener = object : HostListener() {
        override fun onGuestApplicationReceived(guestUser: LiveUserInfo) {
            println("收到观众 ${guestUser.userName} 的连麦申请")
            // 在此更新 UI，例如在"申请列表"按钮上显示红点
        }
    }

    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        // 添加监听器
        guestStore.addHostListener(hostListener)
    }

    override fun onDestroy() {
        super.onDestroy()
        // 移除监听器
        guestStore.removeHostListener(hostListener)
    }
}

class YourActivity : AppCompatActivity() {
    val liveId = "房间ID"
    val guestStore = CoGuestStore.create(liveId)

    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)

        // 订阅申请者列表变化
        lifecycleScope.launch {
            guestStore.coGuestState.applicants.collect { applicants ->
                println("当前申请人数: ${applicants.size}")
                // 在此刷新您的"申请者列表"UI
                // updateApplicantListView(applicants)
            }
        }
    }
}

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

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

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

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

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

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

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

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

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

// 用户点击"接受"
fun accept() {
    guestStore.acceptInvitation(inviterId, object : CompletionHandler {
        override fun onSuccess() {
            // 2. 打开摄像头、麦克风
            DeviceStore.shared().openLocalCamera(true, completion = null)
            DeviceStore.shared().openLocalMicrophone(completion = null)
        }

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

// 用户点击"拒绝"
fun reject() {
    guestStore.rejectInvitation(inviterId, object : CompletionHandler {
        override fun onSuccess() {
            println("已拒绝邀请")
        }

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

import android.content.Context
import android.graphics.Color
import android.view.Gravity
import android.view.ViewGroup
import android.widget.LinearLayout
import android.widget.TextView

// 自定义的用户信息悬浮视图（前景）
class CustomSeatView(context: Context) : LinearLayout(context) {
    private val nameLabel: TextView

    init {
        orientation = VERTICAL
        gravity = Gravity.BOTTOM or Gravity.START
        setBackgroundColor(Color.parseColor("#80000000")) // 半透明黑色背景

        nameLabel = TextView(context).apply {
            setTextColor(Color.WHITE)
            textSize = 14f
        }

        addView(nameLabel, LayoutParams(
            ViewGroup.LayoutParams.WRAP_CONTENT,
            ViewGroup.LayoutParams.WRAP_CONTENT
        ).apply {
            setMargins(20, 0, 0, 20) // 左边距20，下边距20
        })
    }

    fun setUserName(userName: String) {
        nameLabel.text = userName
    }
}

import android.content.Context
import android.graphics.Color
import android.view.Gravity
import android.view.ViewGroup
import android.widget.ImageView
import android.widget.LinearLayout

// 自定义的头像占位视图（背景）
class CustomAvatarView(context: Context) : LinearLayout(context) {
    private val avatarImageView: ImageView

    init {
        orientation = VERTICAL
        gravity = Gravity.CENTER
        setBackgroundColor(Color.TRANSPARENT)

        avatarImageView = ImageView(context).apply {
            setColorFilter(Color.GRAY)
            scaleType = ImageView.ScaleType.CENTER_CROP
        }

        addView(avatarImageView, LayoutParams(120, 120)) // 60dp * 2 = 120px
    }

    fun setUserAvatar(avatarUrl: String) {
        // 在这里加载用户头像，可以使用Glide等图片加载库
        // Glide.with(context).load(avatarUrl).into(avatarImageView)
    }
}

import android.os.Bundle
import android.view.View
import androidx.appcompat.app.AppCompatActivity
import com.tencent.cloud.tuikit.engine.room.TUIRoomDefine
import io.trtc.tuikit.atomicxcore.api.view.VideoViewAdapter
import io.trtc.tuikit.atomicxcore.api.view.ViewLayer

// 1. 在您的Activity中，实现 VideoViewAdapter 接口
class YourActivity : AppCompatActivity(), VideoViewAdapter {

    // ... 其他代码 ...
    
    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        // 1. 设置适配器
        liveCoreView.setVideoViewAdapter(this)
    }

    // 2. 完整实现接口方法，处理两种 viewLayer
    override fun createCoGuestView(userInfo: TUIRoomDefine.SeatFullInfo?, viewLayer: ViewLayer?): View? {
        userInfo ?: return null
        val userId = userInfo.userId
        if (userId.isNullOrEmpty()) return null

        return when (viewLayer) {
            ViewLayer.FOREGROUND -> {
                // 用户摄像头开启时，显示前景视图
                val seatView = CustomSeatView(this)
                seatView.setUserName(userInfo.userName ?: "")
                seatView
            }
            ViewLayer.BACKGROUND -> {
                // 用户摄像头关闭时，显示背景视图
                val avatarView = CustomAvatarView(this)
                // 您可以在这里通过 userInfo.userAvatar 加载用户真实头像
                userInfo.userAvatar?.let { avatarView.setUserAvatar(it) }
                avatarView
            }
            else -> null
        }
    }
}