import 'package:atomic_x_core/atomicxcore.dart';

final String liveId = "房间ID";
final CoGuestStore guestStore = CoGuestStore.create(liveId);

// 用户点击"申请连麦"
void requestToConnect() async {
    // seatIndex: 麦位索引，取值范围为 -1(自动选择空麦位) 和 [0,当前房间支持最大麦位数-1] ，timeout: 请求超时时间（秒）
    final result = await guestStore.applyForSeat(
        seatIndex: 0, 
        timeout: 30, 
        extraInfo: null,
    );
    if (result.isSuccess) {
        print("连麦申请已发送，等待主播处理...");
    } else {
        print("申请发送失败: ${result.errorMessage}");
    }
}

late GuestListener _guestListener;

// 在您的 Widget 初始化时订阅事件
void subscribeGuestEvents() {
    _guestListener = GuestListener(
        onApplicationAccepted: (hostUser) {
            print("主播 ${hostUser.userName} 同意了你的申请，准备上麦");
            // 1. 打开摄像头、麦克风 
            DeviceStore.shared.openLocalCamera(isFront: true);
            DeviceStore.shared.openLocalMicrophone();
            // 2. 在此更新 UI，例如关闭申请按钮，显示连麦中的状态
        },
        onApplicationRejected: (hostUser) {
            print("主播 ${hostUser.userName} 拒绝了你的申请");
            // 弹窗提示用户申请被拒绝
        },
        onInvitationReceived: (hostUser) {
            print("收到主播 ${hostUser.userName} 的连麦邀请");
            // 在此弹出一个对话框，让用户选择"接受"或"拒绝"
            _showInvitationDialog(hostUser);
        },
        onKickedOffSeat: () {
            print("您已被主播踢下麦位");
            // 更新 UI，关闭摄像头和麦克风
        },
    );
    guestStore.addGuestListener(_guestListener);
}

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

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

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

import 'package:atomic_x_core/atomicxcore.dart';

final String liveId = "房间ID";
final CoGuestStore guestStore = CoGuestStore.create(liveId);
late HostListener _hostListener;
late final VoidCallback _applicantsChangedListener = _onApplicantsChanged;

// 订阅主播事件
void subscribeHostEvents() {
    _hostListener = HostListener(
        onApplicationReceived: (guestUser) {
            print("收到观众 ${guestUser.userName} 的连麦申请");
            // 在此更新 UI，例如在"申请列表"按钮上显示红点
        },
        onInvitationAccepted: (guestUser) {
            print("观众 ${guestUser.userName} 接受了你的邀请");
        },
        onInvitationRejected: (guestUser) {
            print("观众 ${guestUser.userName} 拒绝了你的邀请");
        },
    );
    guestStore.addHostListener(_hostListener);
}

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

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

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

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

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

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

// 主播选择观众并发起邀请
void invite(String userId) async {
    // inviteeID: 被邀请者ID，seatIndex: 麦位索引，取值范围为 -1(自动选择空麦位) 和 [0,当前房间支持最大麦位数-1] 
    // timeout: 邀请超时时间
    final result = await guestStore.inviteToSeat(
        inviteeID: userId,
        seatIndex: 0,
        timeout: 30, 
        extraInfo: null,
    );
    if (result.isSuccess) {
        print("已向 $userId 发出邀请，等待对方回应...");
    }
}

// 在 HostListener 中已配置回调
_hostListener = HostListener(
    onInvitationAccepted: (guestUser) {
        print("观众 ${guestUser.userName} 接受了你的邀请");
    },
    onInvitationRejected: (guestUser) {
        print("观众 ${guestUser.userName} 拒绝了你的邀请");
    },
);

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

String inviterId = "发起邀请的主播ID"; // 从 onInvitationReceived 回调中获取

// 用户点击"接受"
void acceptInvitation() async {
    final result = await guestStore.acceptInvitation(inviterId);
    if (result.isSuccess) {
        // 打开摄像头、麦克风  
        DeviceStore.shared.openLocalCamera(isFront: true);
        DeviceStore.shared.openLocalMicrophone();
    }
}

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

import 'package:flutter/material.dart';
import 'package:rtc_room_engine/rtc_room_engine.dart';

/// 自定义的用户信息悬浮视图（前景）
class CustomSeatForegroundView extends StatelessWidget {
    final SeatFullInfo seatInfo;

    const CustomSeatForegroundView({
        Key? key, 
        required this.seatInfo,
    }) : super(key: key);

    @override
    Widget build(BuildContext context) {
        return Container(
            color: Colors.transparent,
            child: Align(
                alignment: Alignment.bottomLeft,
                child: Container(
                    margin: const EdgeInsets.all(5),
                    padding: const EdgeInsets.symmetric(horizontal: 8, vertical: 4),
                    decoration: BoxDecoration(
                        color: Colors.black.withOpacity(0.5),
                        borderRadius: BorderRadius.circular(12),
                    ),
                    child: Text(
                        seatInfo.userInfo.userName,
                        style: const TextStyle(
                            color: Colors.white,
                            fontSize: 14,
                        ),
                    ),
                ),
            ),
        );
    }
}

import 'package:flutter/material.dart';
import 'package:rtc_room_engine/rtc_room_engine.dart';

/// 自定义的头像占位视图（背景）
class CustomSeatBackgroundView extends StatelessWidget {
    final SeatFullInfo seatInfo;

    const CustomSeatBackgroundView({
        Key? key, 
        required this.seatInfo,
    }) : super(key: key);

    @override
    Widget build(BuildContext context) {
        final avatarUrl = seatInfo.userInfo.avatarUrl;
        return Container(
            decoration: BoxDecoration(
                color: Colors.grey[800],
            ),
            child: Center(
                child: Column(
                    mainAxisSize: MainAxisSize.min,
                    children: [
                        ClipOval(
                            child: avatarUrl.isNotEmpty
                                ? Image.network(
                                    avatarUrl, 
                                    width: 60, 
                                    height: 60,
                                    fit: BoxFit.cover,
                                    errorBuilder: (context, error, stackTrace) {
                                        return _buildDefaultAvatar();
                                    },
                                )
                                : _buildDefaultAvatar(),
                        ),
                        const SizedBox(height: 8),
                        Text(
                            seatInfo.userInfo.userName,
                            style: const TextStyle(
                                color: Colors.white,
                                fontSize: 12,
                            ),
                        ),
                    ],
                ),
            ),
        );
    }

    Widget _buildDefaultAvatar() {
        return Container(
            width: 60,
            height: 60,
            color: Colors.grey,
            child: const Icon(Icons.person, size: 40, color: Colors.white),
        );
    }
}

import 'package:flutter/material.dart';
import 'package:atomic_x_core/atomicxcore.dart';
import 'package:rtc_room_engine/rtc_room_engine.dart';

/// 带有自定义连麦视图的直播页面
class CustomCoGuestLiveWidget extends StatefulWidget {
    final String liveId;

    const CustomCoGuestLiveWidget({
        Key? key, 
        required this.liveId,
    }) : super(key: key);

    @override
    State<CustomCoGuestLiveWidget> createState() => _CustomCoGuestLiveWidgetState();
}

class _CustomCoGuestLiveWidgetState extends State<CustomCoGuestLiveWidget> {
    late LiveCoreController _controller;

    @override
    void initState() {
        super.initState();
        _controller = LiveCoreController.create();
        _controller.setLiveID(widget.liveId);
    }

    @override
    void dispose() {
        _controller.dispose();
        super.dispose();
    }

    /// 构建连麦观众的自定义视图
    Widget _buildCoGuestWidget(
        BuildContext context, 
        SeatFullInfo seatFullInfo, 
        ViewLayer viewLayer,
    ) {
        if (viewLayer == ViewLayer.foreground) {
            // 前景层：始终显示在视频画面的最上层，用于显示昵称等信息
            return CustomSeatForegroundView(seatInfo: seatFullInfo);
        } else {
            // 背景层：仅在对应用户没有视频流时显示，用于显示头像占位图
            return CustomSeatBackgroundView(seatInfo: seatFullInfo);
        }
    }

    @override
    Widget build(BuildContext context) {
        return Scaffold(
            body: LiveCoreWidget(
                controller: _controller,
                videoWidgetBuilder: VideoWidgetBuilder(
                    coGuestWidgetBuilder: _buildCoGuestWidget,
                ),
            ),
        );
    }
}