观众列表（Flutter）

import 'package:atomic_x_core/atomicxcore.dart';

class AudienceManager {
    final String liveId;
    late final LiveAudienceStore audienceStore;
    late LiveAudienceListener _audienceListener;
    late final VoidCallback _audienceListChangedListener = _onAudienceListChanged;
    late final VoidCallback _audienceCountChangedListener = _onAudienceCountChanged;

    // 对外暴露【全量】观众列表
    List<LiveUserInfo> audienceList = [];
    // 对外暴露观众总数
    int audienceCount = 0;

    // 状态变更回调
    Function()? onStateChanged;

    AudienceManager({required this.liveId}) {
        // 1. 通过 liveId 获取 LiveAudienceStore 的实例
        audienceStore = LiveAudienceStore.create(liveId);

        // 2. 订阅状态和事件
        _subscribeToAudienceState();
        _subscribeToAudienceEvents();

        // 3. 主动拉取首屏数据
        fetchInitialAudienceList();
    }

    /// 主动获取一次观众列表快照
    Future<void> fetchInitialAudienceList() async {
        final result = await audienceStore.fetchAudienceList();
        if (result.isSuccess) {
            print("首次拉取观众列表成功");
            // 成功后，数据会通过下面的 state 订阅通道自动更新
        } else {
            print("首次拉取观众列表失败: ${result.errorMessage}");
        }
    }

    void dispose() {
        audienceStore.liveAudienceState.audienceList.removeListener(_audienceListChangedListener);
        audienceStore.liveAudienceState.audienceCount.removeListener(_audienceCountChangedListener);
        audienceStore.removeLiveAudienceListener(_audienceListener);
    }
}

extension AudienceManagerSubscription on AudienceManager {
    /// 订阅 state，用于获取观众总数和列表快照
    void _subscribeToAudienceState() {
        // 监听观众列表变化
        audienceStore.liveAudienceState.audienceList.addListener(_audienceListChangedListener);
        // 监听观众人数变化
        audienceStore.liveAudienceState.audienceCount.addListener(_audienceCountChangedListener);
    }

    void _onAudienceListChanged() {
        // audienceList 是一个全量快照
        audienceList = audienceStore.liveAudienceState.audienceList.value;
        onStateChanged?.call();
    }

    void _onAudienceCountChanged() {
        // audienceCount 是实时总数
        audienceCount = audienceStore.liveAudienceState.audienceCount.value;
        onStateChanged?.call();
    }

    /// 订阅 event，用于处理观众的实时进出
    void _subscribeToAudienceEvents() {
        _audienceListener = LiveAudienceListener(
            onAudienceJoined: (audience) {
                print("观众 ${audience.userName} 加入了直播间");
                // 增量更新：在当前列表末尾添加新观众
                if (!audienceList.any((a) => a.userID == audience.userID)) {
                    audienceList.add(audience);
                    onStateChanged?.call();
                }
            },
            onAudienceLeft: (audience) {
                print("观众 ${audience.userName} 离开了直播间");
                // 增量更新：从当前列表中移除离开的观众
                audienceList.removeWhere((a) => a.userID == audience.userID);
                onStateChanged?.call();
            },
        );
        audienceStore.addLiveAudienceListener(_audienceListener);
    }
}

extension AudienceManagerActions on AudienceManager {
    Future<void> kick(String userId) async {
        final result = await audienceStore.kickUserOutOfRoom(userId);
        if (result.isSuccess) {
            print("成功将用户 $userId 踢出房间");
            // 踢出成功后，您会收到 onAudienceLeft 事件
        } else {
            print("踢出用户 $userId 失败: ${result.errorMessage}");
        }
    }
}

extension AudienceManagerAdmin on AudienceManager {
    /// 将用户设为管理员
    Future<void> promoteToAdmin(String userId) async {
        final result = await audienceStore.setAdministrator(userId);
        if (result.isSuccess) {
            print("成功将用户 $userId 设为管理员");
        }
    }

    /// 撤销用户的管理员身份
    Future<void> revokeAdmin(String userId) async {
        final result = await audienceStore.revokeAdministrator(userId);
        if (result.isSuccess) {
            print("成功撤销用户 $userId 的管理员身份");
        }
    }
}

import 'package:atomic_x_core/atomicxcore.dart';

class LiveRoomManager {
    final String liveId;
    late LiveAudienceListener _welcomeListener;

    LiveRoomManager({required this.liveId}) {
        _setupWelcomeMessageFlow();
    }

    void _setupWelcomeMessageFlow() {
        // 1. 获取 LiveAudienceStore 的实例
        final audienceStore = LiveAudienceStore.create(liveId);

        // 2. 获取 BarrageStore 的实例 (得益于内部机制，这会是同一个实例)
        final barrageStore = BarrageStore.create(liveId);

        // 3. 订阅观众事件
        _welcomeListener = LiveAudienceListener(
            onAudienceJoined: (audience) {
                // 4. 创建一条本地提示消息
                final welcomeTip = Barrage(
                    messageType: BarrageType.text,
                    textContent: "欢迎 ${audience.userName} 进入直播间！",
                );

                // 5. 调用 BarrageStore 的接口将其插入弹幕列表
                barrageStore.appendLocalTip(welcomeTip);
            },
        );
        audienceStore.addLiveAudienceListener(_welcomeListener);
    }

    void dispose() {
        final audienceStore = LiveAudienceStore.create(liveId);
        audienceStore.removeLiveAudienceListener(_welcomeListener);
    }
}