观众连线（iOS）

import AtomicXCore

let liveId = "房间ID"
let guestStore = CoGuestStore.create(liveID: liveId)

// 用户点击“申请连麦”
func requestToConnect() {
    // timeout: 请求超时时间，例如 30 秒
    guestStore.applyForSeat(timeout: 30.0, extraInfo: nil) { result in
      switch result {
      case .success():
          print("连麦申请已发送，等待主播处理...")
      case .failure(let error):
          print("申请发送失败: \\(error.message)")
      }
    }
}

// 在您的视图控制器初始化时订阅事件
func subscribeGuestEvents() {
    guestStore.guestEventPublisher
      .sink { [weak self] event in
          if case let .onGuestApplicationResponded(isAccept, hostUser) = event {
              if isAccept {
                  print("主播 \\(hostUser.userName) 同意了你的申请，准备上麦")
                  // 1. 打开摄像头、麦克风 
                  DeviceStore.shared.openLocalCamera(isFront: true, completion: nil)
                  DeviceStore.shared.openLocalMicrophone(completion: nil)
                  // 2. 在此更新 UI，例如关闭申请按钮，显示连麦中的状态
              } else {
                  print("主播 \\(hostUser.userName) 拒绝了你的申请")
                  // 弹窗提示用户申请被拒绝
              }
          }
      }
      .store(in: &cancellables) // 管理订阅生命周期
}

// 用户点击“下麦”按钮
func leaveSeat() {
    guestStore.disConnect { result in
      switch result {
      case .success():
          print("已成功下麦")
      case .failure(let error):
          print("下麦失败: \\(error.message)")
      }
    }
}

// 用户在等待时，点击“取消申请”
func cancelRequest() {
    guestStore.cancelApplication { result in
      switch result {
      case .success():
          print("申请已取消")
      case .failure(let error):
          print("申请取消失败: \\(error.message)")
      }
    }
}

import AtomicXCore

let liveId = "房间ID"
let guestStore = CoGuestStore.create(liveID: liveId)

// 订阅主播事件
guestStore.hostEventPublisher
    .sink { [weak self] event in
        if case let .onGuestApplicationReceived(guestUser) = event {
            print("收到观众 \\(guestUser.userName) 的连麦申请")
            // 在此更新 UI，例如在“申请列表”按钮上显示红点
        }
    }
    .store(in: &cancellables)

// 订阅状态变更
guestStore.state
    .subscribe(StatePublisherSelector(keyPath: \\CoGuestState.applicants)) // 只关心申请者列表的变化
    .removeDuplicates()
    .sink { applicants in
        print("当前申请人数: \\(applicants.count)")
        // 在此刷新您的“申请者列表”UI
        // self.applicantListView.update(with: applicants)
    }
    .store(in: &cancellables)

// 主播点击“同意”按钮，传入申请者的 userID
func accept(userId: String) {
    guestStore.acceptApplication(userID: userId) { result in
        if case .success = result {
            print("已同意 \\(userId) 的申请，对方正在上麦")
        }
    }
}

// 主播点击“拒绝”按钮
func reject(userId: String) {
    guestStore.rejectApplication(userID: userId) { result in
        if case .success = result {
            print("已拒绝 \\(userId) 的申请")
        }
    }
}

 // 主播选择观众并发起邀请
func invite(userId: String) {
    // timeout: 邀请超时时间
    guestStore.inviteToSeat(userID: userId, timeout: 30.0, extraInfo: nil) { result in
        if case .success = result {
            print("已向 \\(userId) 发出邀请，等待对方回应...")
        }
    }
}

// 在 hostEventPublisher 的订阅中添加
if case let .onHostInvitationResponded(isAccept, guestUser) = event {
    if isAccept {
        print("观众 \\(guestUser.userName) 接受了你的邀请")
    } else {
        print("观众 \\(guestUser.userName) 拒绝了你的邀请")
    }
}

// 在 guestEventPublisher 的订阅中添加
if case let .onHostInvitationReceived(hostUser) = event {
    print("收到主播 \\(hostUser.userName) 的连麦邀请")
    // 在此弹出一个对话框，让用户选择“接受”或“拒绝”
    // self.showInvitationDialog(from: hostUser)
}

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

// 用户点击“接受”
func accept() {
    guestStore.acceptInvitation(inviterID: inviterId) { result in
        if case .success = result {
            // 2. 打开摄像头、麦克风  
            DeviceStore.shared.openLocalCamera(isFront: true, completion: nil)
            DeviceStore.shared.openLocalMicrophone(completion: nil)
        }
    }
}

// 用户点击“拒绝”
func reject() {
    guestStore.rejectInvitation(inviterID: inviterId) { result in
        // ...
    }
}

import UIKit

// 自定义的用户信息悬浮视图（前景）
class CustomSeatView: UIView {
   lazy var nameLabel: UILabel = {
        let label = UILabel()
        label.textColor = .white
        label.font = .systemFont(ofSize: 14)
        return label
    }()

    override init(frame: CGRect) {
        super.init(frame: frame)
        backgroundColor = UIColor.black.withAlphaComponent(0.5)
        addSubview(nameLabel)
        nameLabel.snp.makeConstraints { make in
            make.bottom.equalToSuperview().offset(-5)
            make.leading.equalToSuperview().offset(5)
        }
    }
}

import UIKit

// 自定义的头像占位视图（背景）
class CustomAvatarView: UIView {
    lazy var avatarImageView: UIImageView = {
        let imageView = UIImageView()
        imageView.tintColor = .gray
        return imageView
    }()

    override init(frame: CGRect) {
        super.init(frame: frame)
        backgroundColor = .clear
        layer.cornerRadius = 30
        addSubview(avatarImageView)
        avatarImageView.snp.makeConstraints { make in
            make.center.equalToSuperview()
            make.width.height.equalTo(60)
        }
    }
}


import AtomicXCore

// 1. 在您的视图控制器中，遵守 VideoViewDelegate 协议
class YourViewController: UIViewController, VideoViewDelegate {

    // ... 其他代码 ...
    
    // 2. 完整实现协议方法，处理两种 viewLayer
    func createCoGuestView(seatInfo: TUISeatFullInfo, viewLayer: ViewLayer) -> UIView? {
        guard let userId = seatInfo.userID,!userId.isEmpty else {
            return nil
        }
        if viewLayer == .foreground {
            // 用户摄像头开启时，显示前景视图
            let seatView = CustomSeatView()
            seatView.nameLabel.text = seatInfo.userName
            return seatView
        } else { // viewLayer == .background
            // 用户摄像头关闭时，显示背景视图
            let avatarView = CustomAvatarView()
            // 您可以在这里通过 seatInfo.userAvatar 加载用户真实头像
            return avatarView
        }
    }
}