audio_player_handler.dart 2.79 KB
import 'package:appframe/bloc/web_cubit.dart';
import 'package:appframe/config/locator.dart';
import 'package:appframe/services/dispatcher.dart';
import 'package:appframe/services/player_service.dart';
import 'package:uuid/uuid.dart';

class AudioPlayHandler extends MessageHandler {
  late WebCubit? _webCubit;

  @override
  Future<dynamic> handleMessage(dynamic params) async {
    try {
      if (params is! Map<String, dynamic>) {
        throw Exception('参数错误');
      }

      // 检测音量
      _webCubit!.checkVolume();

      final url = params['url'] as String;
      final seek = params['seek'] as int? ?? 0;
      // 暂时忽略
      // final isBg = params['isBg'] as bool ?? false;
      final playRate = (params['playRate'] as num?)?.toDouble() ?? 1.0;

      var playId = params['playId'] as String? ?? '';
      if (playId.isEmpty) {
        playId = Uuid().v4();
      }

      var playerService = getIt.get<PlayerService>();
      var result = await playerService.playAudio(url, seek, playId, playRate);

      if (!result) {
        throw Exception('播放错误');
      }
      return {'playId': playId};
    } finally {
      _unfollowCubit();
    }
  }

  @override
  void setCubit(WebCubit cubit) {
    this._webCubit = cubit;
  }

  void _unfollowCubit() {
    this._webCubit = null;
  }
}

class AudioPauseHandler extends MessageHandler {
  @override
  Future<dynamic> handleMessage(dynamic params) async {
    return await getIt.get<PlayerService>().pauseAudio();
  }
}

class AudioResumeHandler extends MessageHandler {
  @override
  Future<dynamic> handleMessage(dynamic params) async {
    double? playRate = (params['playRate'] as num?)?.toDouble();
    return await getIt.get<PlayerService>().resumeAudio(playRate);
  }
}

class AudioSeekHandler extends MessageHandler {
  @override
  Future<dynamic> handleMessage(dynamic params) async {
    if (params is! Map<String, dynamic>) {
      throw Exception('参数错误');
    }

    final seek = params['seek'] as int;
    return await getIt.get<PlayerService>().seekAudio(seek);
  }
}

class AudioPlayRateHandler extends MessageHandler {
  @override
  Future<dynamic> handleMessage(dynamic params) async {
    if (params is! Map<String, dynamic>) {
      throw Exception('参数错误');
    }

    // var playId = params['playId'] as String? ?? '';
    final playRate = (params['playRate'] as num?)?.toDouble() ?? 1.0;

    return await getIt.get<PlayerService>().rateAudio(playRate);
  }
}

class AudioStopHandler extends MessageHandler {
  @override
  Future<dynamic> handleMessage(dynamic params) async {
    return await getIt.get<PlayerService>().stopAudio();
  }
}

class AudioClearHandler extends MessageHandler {
  @override
  Future<dynamic> handleMessage(dynamic params) async {
    await getIt.get<PlayerService>().clearAudio();
    return true;
  }
}