fix(*)

Author: liuchuancong

lib/modules/live_play/live_play_controller.dart

@@ -325,6 +325,7 @@ class LivePlayController extends StateController with GetSingleTickerProviderSta
       success.value = false;
       return;
     }
+    log(playUrl.toString(), name: "play_url");
     playUrls.value = playUrl;
     setPlayer();
   }
@@ -361,6 +362,7 @@ class LivePlayController extends StateController with GetSingleTickerProviderSta
     GlobalPlayerState().setCurrentRoom(room.roomId!);
     videoController.value = VideoController(
       room: detail.value!,
+      playUrs: playUrls.value,
       datasource: playUrls.value[currentLineIndex.value],
       allowScreenKeepOn: settings.enableScreenKeepOn.value,
       headers: headers,

lib/modules/live_play/widgets/video_player/video_controller.dart

@@ -22,6 +22,7 @@ import 'package:pure_live/pkg/canvas_danmaku/models/danmaku_content_item.dart';
 class VideoController with ChangeNotifier {
   final LiveRoom room;
   String datasource;
+  List<String> playUrs;
   final bool allowScreenKeepOn;
   final bool allowFullScreen;
   final Map<String, String> headers;
@@ -91,6 +92,7 @@ class VideoController with ChangeNotifier {
     required this.room,
     required this.datasource,
     required this.headers,
+    required this.playUrs,
     this.allowScreenKeepOn = false,
     this.allowFullScreen = true,
     BoxFit fitMode = BoxFit.contain,
@@ -142,7 +144,7 @@ class VideoController with ChangeNotifier {
       FlutterVolumeController.updateShowSystemUI(false);
       registerVolumeListener();
     }
-    globalPlayer.setDataSource(datasource, headers, room);
+    globalPlayer.setDataSource(datasource, playUrs, headers, room);
     globalPlayer.onError.listen((error) {
       if (error != null) {
         log("An error occured while loading the stream: $error", error: error, name: "VideoController");

lib/player/fijk_adapter.dart

@@ -87,7 +87,7 @@ class FijkPlayerAdapter implements UnifiedPlayer {
   }
 
   @override
-  Future<void> setDataSource(String url, Map<String, String> headers) async {
+  Future<void> setDataSource(String url, List<String> playUrls, Map<String, String> headers) async {
     if (_disposed) return;
     final SettingsService settings = Get.find<SettingsService>();
     await _player.reset();

lib/player/media_kit_adapter.dart

@@ -52,21 +52,13 @@ class MediaKitPlayerAdapter implements UnifiedPlayer {
       await pp.setProperty('force-seekable', 'yes');
     }
     if (_player.platform is NativePlayer) {
-      if (_player.platform is NativePlayer) {
-        final native = _player.platform as dynamic;
-
-        // 1. 设置协议白名单
-        await native.setProperty('protocol_whitelist', 'httpproxy,udp,rtp,tcp,tls,data,file,http,https,crypto');
-
-        // 2. 合并设置 demuxer 参数 (用逗号分隔，不要分两次 set)
-        // 这样同时开启了重连和 5 秒超时
-        // Optimized reconnection parameters
-        await native.setproperty(
-          'demuxer-lavf-o',
-          'reconnect=1,reconnect_at_eof=1,reconnect_streamed=1,reconnect_on_network_error=1,reconnect_on_http_error=4xx,5xx,timeout=5000000',
-        );
-        await native.setproperty('stream-lavf-o', 'reconnect_streamed=1,reconnect_delay_max=5');
-      }
+      await (_player.platform as dynamic).setProperty(
+        'protocol_whitelist',
+        'httpproxy,udp,rtp,tcp,tls,data,file,http,https,crypto',
+      );
+      await (_player.platform as NativePlayer).setProperty('network-timeout', '30'); // 给 mpv 30秒的总容忍时间
+      await (_player.platform as NativePlayer).setProperty('demuxer-lavf-probsize', '1048576'); // 减半探测大小
+      await (_player.platform as NativePlayer).setProperty('demuxer-lavf-analyzeduration', '3'); // 减少解析时间
     }
 
     // Initialize controller based on settings
@@ -141,10 +133,11 @@ class MediaKitPlayerAdapter implements UnifiedPlayer {
   }
 
   @override
-  Future<void> setDataSource(String url, Map<String, String> headers) async {
+  Future<void> setDataSource(String url, List<String> playUrls, Map<String, String> headers) async {
     if (_disposed) return;
     await _player.stop();
-    await _player.open(Media(url, httpHeaders: headers));
+    Playlist playlist = Playlist(playUrls.map((playUrl) => Media(playUrl, httpHeaders: headers)).toList());
+    await _player.open(playlist);
   }
 
   @override

lib/player/switchable_global_player.dart

@@ -95,7 +95,7 @@ class SwitchableGlobalPlayer {
     playerHasInit = true;
   }
 
-  Future<void> setDataSource(String url, Map<String, String> headers, LiveRoom room) async {
+  Future<void> setDataSource(String url, List<String> playUrls, Map<String, String> headers, LiveRoom room) async {
     if (_currentPlayer != null || playerHasInit) {
       _currentPlayer!.stop();
       _cleanup();
@@ -120,7 +120,7 @@ class SwitchableGlobalPlayer {
     try {
       await _currentPlayer!.init();
       await Future.delayed(const Duration(milliseconds: 100));
-      await _currentPlayer!.setDataSource(url, headers);
+      await _currentPlayer!.setDataSource(url, playUrls, headers);
       if (PlatformUtils.isAndroid) {
         BackgroundService.startService(room.nick!, room.title!);
       }

lib/player/unified_player_interface.dart

@@ -6,7 +6,7 @@ abstract class UnifiedPlayer {
   Future<void> init();
 
   // 设置播放源
-  Future<void> setDataSource(String url, Map<String, String> headers);
+  Future<void> setDataSource(String url, List<String> playUrls, Map<String, String> headers);
 
   // 播放 / 暂停
   Future<void> play();