import 'package:atomic_x_core/atomicxcore.dart';

final String liveId = "房间ID";
late CoGuestStore guestStore;

@override
void initState() {
  super.initState();
  guestStore = CoGuestStore.create(liveId);
}

// 用户点击"申请连麦"
Future<void> requestToConnect() async {
  // seatIndex: 麦位索引，从 0 开始,表示要申请的麦位位置。0 表示第一个麦位。可通过 LiveSeatState.seatList.value 查看麦位状态,选择空闲的麦位
  // timeout: 请求超时时间（秒），在超时时间内观众可调用 cancelApplication 取消上麦请求，
  // 到达超时时间后如该请求未被处理则会失效
  final result = await guestStore.applyForSeat(
    seatIndex: 0,
    timeout: 30,
    extraInfo: null,
  );
  if (result.isSuccess) {
    debugPrint('连麦申请已发送，等待主播处理...');
  } else {
    debugPrint('申请发送失败: ${result.message}');
  }
}

late GuestListener _guestListener;

// 在您的 Widget 初始化时订阅事件
void subscribeGuestEvents() {
  _guestListener = GuestListener(
    onGuestApplicationResponded: (isAccept, hostUser) {
      if (isAccept) {
        debugPrint('主播 ${hostUser.userName} 同意了您的申请，准备上麦');
        // 1. 打开麦克风
        // DeviceStore 是 AtomicXCore 提供的设备管理模块，用于管理麦克风、摄像头等物理设备。
        // 当主播同意连麦后,需要打开麦克风开始采集音频。
        DeviceStore.shared.openLocalMicrophone();
        // 2. 在此更新 UI，例如关闭申请按钮，显示连麦中的状态
      } else {
        debugPrint('主播 ${hostUser.userName} 拒绝了您的申请');
        // 弹窗提示用户申请被拒绝
      }
    },
  );
  guestStore.addGuestListener(_guestListener);
}

@override
void dispose() {
  guestStore.removeGuestListener(_guestListener);
  super.dispose();
}

// 用户点击"下麦"按钮
Future<void> leaveSeat() async {
  final result = await guestStore.disconnect();
  if (result.isSuccess) {
    debugPrint('已成功下麦');
  } else {
    debugPrint('下麦失败: ${result.message}');
  }
}

// 用户在等待时，点击"取消申请"
Future<void> cancelApplication() async {
  final result = await guestStore.cancelApplication();
  if (result.isSuccess) {
    debugPrint('申请已取消');
  } else {
    debugPrint('申请取消失败: ${result.message}');
  }
}

import 'package:atomic_x_core/atomicxcore.dart';

final String liveId = "房间ID";
late CoGuestStore guestStore;
late HostListener _hostListener;

@override
void initState() {
  super.initState();
  guestStore = CoGuestStore.create(liveId);

  // 订阅主播事件
  _hostListener = HostListener(
    onGuestApplicationReceived: (guestUser) {
      debugPrint('收到观众 ${guestUser.userName} 的连麦申请');
      // 在此更新 UI，例如在"申请列表"按钮上显示红点
    },
  );
  guestStore.addHostListener(_hostListener);
}

@override
void dispose() {
  guestStore.removeHostListener(_hostListener);
  super.dispose();
}

late final VoidCallback _applicantsListener = _onApplicantsChanged;

// 订阅状态变更
void subscribeApplicants() {
  guestStore.coGuestState.applicants.addListener(_applicantsListener);
}

void _onApplicantsChanged() {
  final applicants = guestStore.coGuestState.applicants.value;
  debugPrint('当前申请人数: ${applicants.length}');
  // 在此刷新您的"申请者列表" UI
}

@override
void dispose() {
  guestStore.coGuestState.applicants.removeListener(_applicantsListener);
  super.dispose();
}

// 主播点击"同意"按钮，传入申请者的 userID
Future<void> accept(String userId) async {
  final result = await guestStore.acceptApplication(userId);
  if (result.isSuccess) {
    debugPrint('已同意 $userId 的申请，对方正在上麦');
  }
}

// 主播点击"拒绝"按钮
Future<void> reject(String userId) async {
  final result = await guestStore.rejectApplication(userId);
  if (result.isSuccess) {
    debugPrint('已拒绝 $userId 的申请');
  }
}

// 主播选择观众并发起邀请
Future<void> invite(String userId) async {
  // inviteeID: 被邀请者 ID，seatIndex: 麦位索引，timeout: 邀请超时时间
  final result = await guestStore.inviteToSeat(
    inviteeID: userId,
    seatIndex: 0,
    timeout: 30,
    extraInfo: null,
  );
  if (result.isSuccess) {
    debugPrint('已向 $userId 发出邀请，等待对方回应...');
  }
}

// 在 HostListener 的配置中添加
_hostListener = HostListener(
  onHostInvitationResponded: (isAccept, guestUser) {
    if (isAccept) {
      debugPrint('观众 ${guestUser.userName} 接受了您的邀请');
    } else {
      debugPrint('观众 ${guestUser.userName} 拒绝了您的邀请');
    }
  },
);

// 在 GuestListener 的配置中添加
_guestListener = GuestListener(
  onHostInvitationReceived: (hostUser) {
    debugPrint('收到主播 ${hostUser.userName} 的连麦邀请');
    // 在此弹出一个对话框，让用户选择"接受"或"拒绝"
    // showInvitationDialog(hostUser);
  },
);

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

// 用户点击"接受"
Future<void> accept() async {
  final result = await guestStore.acceptInvitation(inviterId);
  if (result.isSuccess) {
    // 打开麦克风
    // DeviceStore 是 AtomicXCore 提供的设备管理模块，用于管理麦克风、摄像头等物理设备。
    // 接受邀请后，需要打开麦克风开始采集音频
    DeviceStore.shared.openLocalMicrophone();
  }
}

// 用户点击"拒绝"
Future<void> reject() async {
  await guestStore.rejectInvitation(inviterId);
}