import AtomicXCore

let liveID = "房间ID"
var guestStore: CoGuestStore {
    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)")
      }
    }
}

import AtomicXCore
import Combine

// 在您的视图控制器初始化时订阅事件
func subscribeGuestEvents() {
    guestStore.guestEventPublisher
      .sink { [weak self] event in
          if case let .onGuestApplicationResponded(isAccept, hostUser) = event {
              if isAccept {
                  print("主播 \\(hostUser.userName) 同意了你的申请，准备上麦")
                  // 1. 打开麦克风 
                  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
import Combine

let liveID = "房间ID"
var guestStore: CoGuestStore {
    CoGuestStore.create(liveID: liveID)
}

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

import AtomicXCore
import Combine

// 订阅状态变更
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.openLocalMicrophone(completion: nil)
        }
    }
}

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