主播连线和 PK（Flutter）

import 'package:atomic_x_core/atomicxcore.dart';

// 主播A的页面
class AnchorAPage extends StatefulWidget {
  final String liveId;

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

  @override
  State<AnchorAPage> createState() => _AnchorAPageState();
}

class _AnchorAPageState extends State<AnchorAPage> {
  late final CoHostStore _coHostStore;
  late final CoHostListener _coHostListener;

  @override
  void initState() {
    super.initState();
    _coHostStore = CoHostStore.create(widget.liveId);
    _setupListeners();
  }

  // 用户点击"连线"按钮，并选择了主播B
  Future<void> inviteHostB(String targetHostLiveId) async {
    final layout = CoHostLayoutTemplate.hostDynamicGrid; // 选择一个布局模板
    const timeout = 30; // 邀请超时时间（秒）

    final result = await _coHostStore.requestHostConnection(
      targetHostLiveID: targetHostLiveId,
      layoutTemplate: layout,
      timeout: timeout,
    );

    if (result.isSuccess) {
      print('连线邀请已发送，等待对方处理...');
    } else {
      print('邀请发送失败: ${result.errorMessage}');
    }
  }

  @override
  void dispose() {
    _coHostStore.removeCoHostListener(_coHostListener);
    super.dispose();
  }
}

// 在 _AnchorAPageState 初始化时设置监听
void _setupListeners() {
  _coHostListener = CoHostListener(
    onCoHostRequestAccepted: (invitee) {
      print('主播 ${invitee.userName} 同意了你的连线邀请');
    },
    onCoHostRequestRejected: (invitee) {
      print('主播 ${invitee.userName} 拒绝了你的邀请');
    },
    onCoHostRequestTimeout: (inviter, invitee) {
      print('邀请超时，对方未回应');
    },
    onCoHostUserJoined: (userInfo) {
      print('主播 ${userInfo.userName} 已加入连线');
    },
    onCoHostUserLeft: (userInfo) {
      print('主播 ${userInfo.userName} 已离开连线');
    },
  );
  _coHostStore.addCoHostListener(_coHostListener);
}

import 'package:atomic_x_core/atomicxcore.dart';

// 主播B的页面
class AnchorBPage extends StatefulWidget {
  final String liveId;

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

  @override
  State<AnchorBPage> createState() => _AnchorBPageState();
}

class _AnchorBPageState extends State<AnchorBPage> {
  late final CoHostStore _coHostStore;
  late final CoHostListener _coHostListener;

  @override
  void initState() {
    super.initState();
    _coHostStore = CoHostStore.create(widget.liveId);
    _setupListeners();
  }

  // 在初始化时设置监听
  void _setupListeners() {
    _coHostListener = CoHostListener(
      onCoHostRequestReceived: (inviter, extensionInfo) {
        print('收到主播 ${inviter.userName} 的连线邀请');
        // _showInvitationDialog(inviter);
      },
    );
    _coHostStore.addCoHostListener(_coHostListener);
  }

  @override
  void dispose() {
    _coHostStore.removeCoHostListener(_coHostListener);
    super.dispose();
  }
}

// _AnchorBPageState 的一部分
Future<void> acceptInvitation(String fromHostLiveId) async {
  final result = await _coHostStore.acceptHostConnection(fromHostLiveId);
  if (result.isSuccess) {
    print('已接受连线邀请');
  } else {
    print('接受连线失败: ${result.errorMessage}');
  }
}

Future<void> rejectInvitation(String fromHostLiveId) async {
  final result = await _coHostStore.rejectHostConnection(fromHostLiveId);
  if (result.isSuccess) {
    print('已拒绝连线邀请');
  } else {
    print('拒绝连线失败: ${result.errorMessage}');
  }
}

// _AnchorAPageState 的一部分
late final BattleStore _battleStore;
late final BattleListener _battleListener;

@override
void initState() {
  super.initState();
  _coHostStore = CoHostStore.create(widget.liveId);
  _battleStore = BattleStore.create(widget.liveId);
  _setupListeners();
  _setupBattleListeners();
}

Future<void> startPK(String opponentUserId) async {
  final config = BattleConfig(duration: 300); // PK 持续 5 分钟
  final result = await _battleStore.requestBattle(
    config: config,
    userIDList: [opponentUserId],
    timeout: 30,
  );

  if (result.isSuccess) {
    print('PK 请求已发送，battleID: ${result.battleID}');
  } else {
    print('PK 请求失败: ${result.errorMessage}');
  }
}

// 在 _AnchorAPageState 的 _setupBattleListeners 方法中添加
void _setupBattleListeners() {
  _battleListener = BattleListener(
    onBattleStarted: (battleInfo, inviter, invitees) {
      print('PK 开始');
    },
    onBattleEnded: (battleInfo, reason) {
      print('PK 结束，原因: $reason');
    },
    onUserJoinBattle: (battleID, battleUser) {
      print('用户 ${battleUser.userName} 加入了 PK');
    },
    onUserExitBattle: (battleID, battleUser) {
      print('用户 ${battleUser.userName} 退出了 PK');
    },
  );
  _battleStore.addBattleListener(_battleListener);
}

@override
void dispose() {
  _coHostStore.removeCoHostListener(_coHostListener);
  _battleStore.removeBattleListener(_battleListener);
  super.dispose();
}

// 在 _AnchorBPageState 的 _setupBattleListeners 方法中添加
void _setupBattleListeners() {
  _battleListener = BattleListener(
    onBattleRequestReceived: (battleId, inviter, invitee) {
      print('收到主播 ${inviter.userName} 的PK挑战');
      // 弹出对话框，让主播B选择"接受"或"拒绝"
      // _showPKChallengeDialog(battleId);
    },
    onBattleStarted: (battleInfo, inviter, invitees) {
      print('PK 开始');
    },
    onBattleEnded: (battleInfo, reason) {
      print('PK 结束');
    },
  );
  _battleStore.addBattleListener(_battleListener);
}

// _AnchorBPageState 的一部分
// 用户点击"接受挑战"
Future<void> acceptPK(String battleId) async {
  final result = await _battleStore.acceptBattle(battleId);
  if (result.isSuccess) {
    print('已接受 PK 挑战');
  } else {
    print('接受 PK 失败: ${result.errorMessage}');
  }
}

// 用户点击"拒绝挑战"
Future<void> rejectPK(String battleId) async {
  final result = await _battleStore.rejectBattle(battleId);
  if (result.isSuccess) {
    print('已拒绝 PK 挑战');
  } else {
    print('拒绝 PK 失败: ${result.errorMessage}');
  }
}

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

/// 自定义的连线主播信息悬浮视图（前景）
class CustomCoHostForegroundView extends StatelessWidget {
  final SeatFullInfo seatInfo;

  const CustomCoHostForegroundView({
    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.0),
          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 CustomCoHostBackgroundView extends StatelessWidget {
  final SeatFullInfo seatInfo;

  const CustomCoHostBackgroundView({
    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 CustomCoHostLiveWidget extends StatefulWidget {
  final String liveId;

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

  @override
  State<CustomCoHostLiveWidget> createState() => _CustomCoHostLiveWidgetState();
}

class _CustomCoHostLiveWidgetState extends State<CustomCoHostLiveWidget> {
  late LiveCoreController _controller;

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

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

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

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

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

/// 自定义 PK 用户视图
class CustomBattleUserView extends StatefulWidget {
  final String liveId;
  final TUIBattleUser battleUser;

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

  @override
  State<CustomBattleUserView> createState() => _CustomBattleUserViewState();
}

class _CustomBattleUserViewState extends State<CustomBattleUserView> {
  late final BattleStore _battleStore;
  late final VoidCallback _scoreChangedListener = _onScoreChanged;
  int _score = 0;

  @override
  void initState() {
    super.initState();
    _battleStore = BattleStore.create(widget.liveId);
    _subscribeBattleState();
  }

  /// 订阅 PK 分数变化
  void _subscribeBattleState() {
    _battleStore.battleState.battleScore.addListener(_scoreChangedListener);
    // 初始化分数
    _updateScore(_battleStore.battleState.battleScore.value);
  }

  void _onScoreChanged() {
    _updateScore(_battleStore.battleState.battleScore.value);
  }

  void _updateScore(Map<String, int> battleScore) {
    final score = battleScore[widget.battleUser.userId] ?? 0;
    if (mounted && score != _score) {
      setState(() {
        _score = score;
      });
    }
  }

  @override
  void dispose() {
    _battleStore.battleState.battleScore.removeListener(_scoreChangedListener);
    super.dispose();
  }

  @override
  Widget build(BuildContext context) {
    return IgnorePointer(
      child: Align(
        alignment: Alignment.bottomRight,
        child: Container(
          margin: const EdgeInsets.all(5),
          padding: const EdgeInsets.symmetric(horizontal: 8, vertical: 4),
          decoration: BoxDecoration(
            color: Colors.black.withOpacity(0.4),
            borderRadius: BorderRadius.circular(12),
          ),
          child: Text(
            '$_score',
            style: const TextStyle(
              color: Colors.white,
              fontSize: 14,
              fontWeight: FontWeight.bold,
            ),
          ),
        ),
      ),
    );
  }
}