fluffychat/lib/pages/chat/events/audio_player.dart

import 'dart:async';
import 'dart:developer';
import 'dart:io';

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

import 'package:flutter_linkify/flutter_linkify.dart';
import 'package:just_audio/just_audio.dart';
import 'package:matrix/matrix.dart';
import 'package:opus_caf_converter_dart/opus_caf_converter_dart.dart';
import 'package:path_provider/path_provider.dart';

import 'package:fluffychat/pages/chat/chat.dart';
import 'package:fluffychat/pangea/toolbar/widgets/message_audio_card.dart';
import 'package:fluffychat/pangea/toolbar/widgets/message_selection_overlay.dart';
import 'package:fluffychat/utils/error_reporter.dart';
import 'package:fluffychat/utils/file_description.dart';
import 'package:fluffychat/utils/localized_exception_extension.dart';
import 'package:fluffychat/utils/url_launcher.dart';
import '../../../utils/matrix_sdk_extensions/event_extension.dart';

class AudioPlayerWidget extends StatefulWidget {
  final Color color;
  final Color linkColor;
  final double fontSize;
  // #Pangea
  // final Event event;
  final Event? event;
  final PangeaAudioFile? matrixFile;
  final bool autoplay;
  final Function(bool)? setIsPlayingAudio;
  final double padding;
  final ChatController chatController;
  final bool isOverlay;
  final MessageOverlayController? overlayController;
  // Pangea#

  static String? currentId;

  static const int wavesCount = 40;

  // #Pangea
  final int? sectionStartMS;
  final int? sectionEndMS;
  // Pangea#

  const AudioPlayerWidget(
    this.event, {
    required this.color,
    required this.linkColor,
    required this.fontSize,
    // #Pangea
    this.matrixFile,
    this.autoplay = false,
    this.sectionStartMS,
    this.sectionEndMS,
    this.setIsPlayingAudio,
    this.padding = 12.0,
    required this.chatController,
    required this.isOverlay,
    this.overlayController,
    // Pangea#
    super.key,
  });

  @override
  AudioPlayerState createState() => AudioPlayerState();
}

enum AudioPlayerStatus { notDownloaded, downloading, downloaded }

class AudioPlayerState extends State<AudioPlayerWidget> {
  AudioPlayerStatus status = AudioPlayerStatus.notDownloaded;
  AudioPlayer? audioPlayer;

  StreamSubscription? onAudioPositionChanged;
  StreamSubscription? onDurationChanged;
  StreamSubscription? onPlayerStateChanged;
  StreamSubscription? onPlayerError;

  String? statusText;
  double currentPosition = 0;
  double maxPosition = 1;

  MatrixFile? matrixFile;
  File? audioFile;

  // #Pangea
  StreamSubscription? _onShowToolbar;
  // Pangea#

  @override
  void dispose() {
    if (audioPlayer?.playerState.playing == true) {
      audioPlayer?.stop();
    }
    onAudioPositionChanged?.cancel();
    onDurationChanged?.cancel();
    onPlayerStateChanged?.cancel();
    onPlayerError?.cancel();
    // #Pangea
    _onShowToolbar?.cancel();
    // Pangea#

    super.dispose();
  }

  void _startAction() {
    if (status == AudioPlayerStatus.downloaded) {
      _playAction();
    } else {
      _downloadAction();
    }
  }

  Future<void> _downloadAction() async {
    // #Pangea
    // if (status != AudioPlayerStatus.notDownloaded) return;
    if (status != AudioPlayerStatus.notDownloaded || widget.event == null) {
      return;
    }
    // Pangea#
    setState(() => status = AudioPlayerStatus.downloading);
    try {
      // #Pangea
      // final matrixFile = await widget.event.downloadAndDecryptAttachment();
      final matrixFile = await widget.event!.downloadAndDecryptAttachment();
      // Pangea#
      File? file;

      if (!kIsWeb) {
        final tempDir = await getTemporaryDirectory();
        final fileName = Uri.encodeComponent(
          // #Pangea
          // widget.event.attachmentOrThumbnailMxcUrl()!.pathSegments.last,
          widget.event!.attachmentOrThumbnailMxcUrl()!.pathSegments.last,
          // Pangea#
        );
        file = File('${tempDir.path}/${fileName}_${matrixFile.name}');

        await file.writeAsBytes(matrixFile.bytes);

        if (Platform.isIOS &&
            matrixFile.mimeType.toLowerCase() == 'audio/ogg') {
          Logs().v('Convert ogg audio file for iOS...');
          final convertedFile = File('${file.path}.caf');
          if (await convertedFile.exists() == false) {
            OpusCaf().convertOpusToCaf(file.path, convertedFile.path);
          }
          file = convertedFile;
        }
      }

      setState(() {
        audioFile = file;
        this.matrixFile = matrixFile;
        status = AudioPlayerStatus.downloaded;
      });
      _playAction();
    } catch (e, s) {
      Logs().v('Could not download audio file', e, s);
      ScaffoldMessenger.of(context).showSnackBar(
        SnackBar(
          content: Text(e.toLocalizedString(context)),
        ),
      );
    }
  }

  void _playAction() async {
    final audioPlayer = this.audioPlayer ??= AudioPlayer();
    // #Pangea
    // If there's another audio playing, stop it. Wait for this to come through
    // the stream so that the listener doesn't stop the audio that just started
    final future = widget.chatController.stopMediaStream.stream.first;
    widget.chatController.stopMediaStream.add(null);
    await future;

    // if (AudioPlayerWidget.currentId != widget.event.eventId) {
    if (AudioPlayerWidget.currentId != widget.event?.eventId) {
      // Pangea#
      if (AudioPlayerWidget.currentId != null) {
        if (audioPlayer.playerState.playing) {
          await audioPlayer.stop();
          setState(() {});
        }
      }
      // #Pangea
      // AudioPlayerWidget.currentId = widget.event.eventId;
      AudioPlayerWidget.currentId = widget.event?.eventId;
      // Pangea#
    }
    if (audioPlayer.playerState.playing) {
      await audioPlayer.pause();
      return;
    } else if (audioPlayer.position != Duration.zero) {
      await audioPlayer.play();
      return;
    }

    onAudioPositionChanged ??= audioPlayer.positionStream.listen((state) {
      if (maxPosition <= 0) return;
      setState(() {
        statusText =
            '${state.inMinutes.toString().padLeft(2, '0')}:${(state.inSeconds % 60).toString().padLeft(2, '0')}';
        currentPosition = state.inMilliseconds.toDouble();
      });
      if (state.inMilliseconds.toDouble() == maxPosition) {
        audioPlayer.stop();
        audioPlayer.seek(null);
      }
      // #Pangea
      // Pass current timestamp to overlay, so it can highlight as necessary
      if (widget.matrixFile != null) {
        widget.overlayController?.highlightCurrentText(
          state.inMilliseconds,
          widget.matrixFile!.tokens,
        );
      }
      // Pangea#
    });
    onDurationChanged ??= audioPlayer.durationStream.listen((max) {
      if (max == null || max == Duration.zero) return;
      setState(() => maxPosition = max.inMilliseconds.toDouble());
    });
    onPlayerStateChanged ??= audioPlayer.playingStream.listen(
      (isPlaying) => setState(() {
        // #Pangea
        widget.setIsPlayingAudio?.call(isPlaying);
        // Pangea#
      }),
    );
    final audioFile = this.audioFile;
    if (audioFile != null) {
      audioPlayer.setFilePath(audioFile.path);
    } else {
      // #Pangea
      try {
        if (widget.matrixFile != null) {
          await audioPlayer.setAudioSource(
            BytesAudioSource(
              widget.matrixFile!.bytes,
              widget.matrixFile!.mimeType,
            ),
          );
        } else {
          // Pangea#
          await audioPlayer.setAudioSource(MatrixFileAudioSource(matrixFile!));
          // #Pangea
        }
      } catch (e, _) {
        debugger(when: kDebugMode);
      }
      // Pangea#
    }
    audioPlayer.play().onError(
          ErrorReporter(context, 'Unable to play audio message')
              .onErrorCallback,
        );
  }

  static const double buttonSize = 36;

  String? get _durationString {
    // #Pangea
    int? durationInt;
    if (widget.matrixFile?.duration != null) {
      durationInt = widget.matrixFile!.duration;
    } else {
      // final durationInt = widget.event?.content
      durationInt = widget.event?.content
          .tryGetMap<String, dynamic>('info')
          ?.tryGet<int>('duration');
    }
    // Pangea#
    if (durationInt == null) return null;
    final duration = Duration(milliseconds: durationInt);
    return '${duration.inMinutes.toString().padLeft(2, '0')}:${(duration.inSeconds % 60).toString().padLeft(2, '0')}';
  }

  List<int>? _getWaveform() {
    // #Pangea
    final eventWaveForm = widget.matrixFile?.waveform ??
        widget.event?.content
            .tryGetMap<String, dynamic>('org.matrix.msc1767.audio')
            ?.tryGetList<int>('waveform');
    // final eventWaveForm = widget.event?.content
    //     .tryGetMap<String, dynamic>('org.matrix.msc1767.audio')
    //     ?.tryGetList<int>('waveform');
    // Pangea#
    if (eventWaveForm == null || eventWaveForm.isEmpty) {
      return null;
    }
    while (eventWaveForm.length < AudioPlayerWidget.wavesCount) {
      for (var i = 0; i < eventWaveForm.length; i = i + 2) {
        eventWaveForm.insert(i, eventWaveForm[i]);
      }
    }
    var i = 0;
    final step = (eventWaveForm.length / AudioPlayerWidget.wavesCount).round();
    while (eventWaveForm.length > AudioPlayerWidget.wavesCount) {
      eventWaveForm.removeAt(i);
      i = (i + step) % AudioPlayerWidget.wavesCount;
    }
    return eventWaveForm.map((i) => i > 1024 ? 1024 : i).toList();
  }

  late final List<int>? _waveform;

  // #Pangea
  // void _toggleSpeed() async {
  //   final audioPlayer = this.audioPlayer;
  //   if (audioPlayer == null) return;
  //   switch (audioPlayer.speed) {
  //     case 1.0:
  //       await audioPlayer.setSpeed(1.25);
  //       break;
  //     case 1.25:
  //       await audioPlayer.setSpeed(1.5);
  //       break;
  //     case 1.5:
  //       await audioPlayer.setSpeed(2.0);
  //       break;
  //     case 2.0:
  //       await audioPlayer.setSpeed(0.5);
  //       break;
  //     case 0.5:
  //     default:
  //       await audioPlayer.setSpeed(1.0);
  //       break;
  //   }
  //   setState(() {});
  // }
  // Pangea#

  // #Pangea
  Future<void> _downloadMatrixFile() async {
    if (kIsWeb) return;
    final temp = await getTemporaryDirectory();
    final tempDir = temp;
    String filename = widget.matrixFile!.name;
    if (filename.length > 100) {
      filename = filename.substring(filename.length - 100);
    }
    final file = File('${tempDir.path}/$filename');

    await file.writeAsBytes(widget.matrixFile!.bytes);
    audioFile = file;
  }
  // Pangea#

  @override
  void initState() {
    super.initState();
    _waveform = _getWaveform();
    // #Pangea
    if (widget.matrixFile != null) {
      _downloadMatrixFile().then((_) {
        setState(() => status = AudioPlayerStatus.downloaded);
        if (widget.autoplay) _playAction();
      });
    } else if (widget.autoplay) {
      status == AudioPlayerStatus.downloaded
          ? _playAction()
          : _downloadAction();
    }

    _onShowToolbar = widget.chatController.stopMediaStream.stream.listen((_) {
      audioPlayer?.pause();
      audioPlayer?.seek(Duration.zero);
    });
    // Pangea#
  }

  @override
  Widget build(BuildContext context) {
    final theme = Theme.of(context);
    final waveform = _waveform;

    final statusText = this.statusText ??= _durationString ?? '00:00';
    final audioPlayer = this.audioPlayer;

    // #Pangea
    // final fileDescription = widget.event.fileDescription;
    final fileDescription = widget.event?.fileDescription;
    // Pangea#

    final wavePosition =
        (currentPosition / maxPosition) * AudioPlayerWidget.wavesCount;

    return Padding(
      // #Pangea
      // padding: const EdgeInsets.all(12.0),
      padding: EdgeInsets.all(widget.padding),
      // Pangea#
      child: Column(
        mainAxisSize: MainAxisSize.min,
        crossAxisAlignment: CrossAxisAlignment.start,
        children: [
          ConstrainedBox(
            // #Pangea
            // constraints:
            //     const BoxConstraints(maxWidth: FluffyThemes.columnWidth),
            constraints: const BoxConstraints(maxWidth: 250),
            // Pangea#
            child: Row(
              mainAxisSize: MainAxisSize.min,
              children: <Widget>[
                SizedBox(
                  width: buttonSize,
                  height: buttonSize,
                  child: status == AudioPlayerStatus.downloading
                      ? CircularProgressIndicator(
                          strokeWidth: 2,
                          color: widget.color,
                        )
                      : InkWell(
                          borderRadius: BorderRadius.circular(64),
                          // #Pangea
                          // onLongPress: () => widget.event.saveFile(context),
                          onLongPress: () => widget.event?.saveFile(context),
                          // Pangea#
                          onTap: _startAction,
                          child: Material(
                            color: widget.color.withAlpha(64),
                            borderRadius: BorderRadius.circular(64),
                            child: Icon(
                              audioPlayer?.playerState.playing == true
                                  ? Icons.pause_outlined
                                  : Icons.play_arrow_outlined,
                              color: widget.color,
                            ),
                          ),
                        ),
                ),
                // #Pangea
                // const SizedBox(width: 8),
                // Pangea#
                Expanded(
                  child: Stack(
                    children: [
                      if (waveform != null)
                        Padding(
                          padding: const EdgeInsets.symmetric(horizontal: 16.0),
                          child: Row(
                            children: [
                              for (var i = 0;
                                  i < AudioPlayerWidget.wavesCount;
                                  i++)
                                Expanded(
                                  child: Container(
                                    height: 32,
                                    alignment: Alignment.center,
                                    child: Container(
                                      // #Pangea
                                      // margin: const EdgeInsets.symmetric(
                                      //   horizontal: 1,
                                      // ),
                                      margin: const EdgeInsets.only(
                                        right: 0.5,
                                      ),
                                      // Pangea#
                                      decoration: BoxDecoration(
                                        color: i < wavePosition
                                            ? widget.color
                                            : widget.color.withAlpha(128),
                                        borderRadius: BorderRadius.circular(64),
                                      ),
                                      height: 32 * (waveform[i] / 1024),
                                    ),
                                  ),
                                ),
                            ],
                          ),
                        ),
                      SizedBox(
                        height: 32,
                        child: Slider(
                          thumbColor: widget.event?.senderId ==
                                  widget.event?.room.client.userID
                              ? theme.colorScheme.onPrimary
                              : theme.colorScheme.primary,
                          activeColor: waveform == null
                              ? widget.color
                              : Colors.transparent,
                          inactiveColor: waveform == null
                              ? widget.color.withAlpha(128)
                              : Colors.transparent,
                          max: maxPosition,
                          value: currentPosition,
                          onChanged: (position) => audioPlayer == null
                              ? _startAction()
                              : audioPlayer.seek(
                                  Duration(milliseconds: position.round()),
                                ),
                        ),
                      ),
                    ],
                  ),
                ),
                // #Pangea
                // const SizedBox(width: 8),
                // SizedBox(
                //   width: 36,
                //   child:
                // Pangea#
                Text(
                  statusText,
                  style: TextStyle(
                    color: widget.color,
                    fontSize: 12,
                  ),
                ),
                // #Pangea
                // const SizedBox(width: 8),
                // AnimatedCrossFade(
                //   firstChild: Padding(
                //     padding: const EdgeInsets.only(right: 8.0),
                //     child: Icon(
                //       Icons.mic_none_outlined,
                //       color: widget.color,
                //     ),
                //   ),
                //   secondChild: Material(
                //     color: widget.color.withAlpha(64),
                //     borderRadius: BorderRadius.circular(AppConfig.borderRadius),
                //     child: InkWell(
                //       borderRadius:
                //           BorderRadius.circular(AppConfig.borderRadius),
                //       onTap: _toggleSpeed,
                //       child: SizedBox(
                //         width: 32,
                //         height: 20,
                //         child: Center(
                //           child: Text(
                //             '${audioPlayer?.speed.toString()}x',
                //             style: TextStyle(
                //               color: widget.color,
                //               fontSize: 9,
                //             ),
                //           ),
                //         ),
                //       ),
                //     ),
                //   ),
                //   alignment: Alignment.center,
                //   crossFadeState: audioPlayer == null
                //       ? CrossFadeState.showFirst
                //       : CrossFadeState.showSecond,
                //   duration: FluffyThemes.animationDuration,
                // ),
                // Pangea#
              ],
            ),
          ),
          if (fileDescription != null
                  // #Pangea
                  &&
                  widget.event != null
              // Pangea#
              ) ...[
            const SizedBox(height: 8),
            Padding(
              padding: const EdgeInsets.symmetric(
                horizontal: 16,
                vertical: 8,
              ),
              child: Linkify(
                text: fileDescription,
                textScaleFactor: MediaQuery.textScalerOf(context).scale(1),
                style: TextStyle(
                  color: widget.color,
                  fontSize: widget.fontSize,
                ),
                options: const LinkifyOptions(humanize: false),
                linkStyle: TextStyle(
                  color: widget.linkColor,
                  fontSize: widget.fontSize,
                  decoration: TextDecoration.underline,
                  decorationColor: widget.linkColor,
                ),
                onOpen: (url) => UrlLauncher(context, url.url).launchUrl(),
              ),
            ),
          ],
        ],
      ),
    );
  }
}

/// To use a MatrixFile as an AudioSource for the just_audio package
class MatrixFileAudioSource extends StreamAudioSource {
  final MatrixFile file;

  MatrixFileAudioSource(this.file);

  @override
  Future<StreamAudioResponse> request([int? start, int? end]) async {
    start ??= 0;
    end ??= file.bytes.length;
    return StreamAudioResponse(
      sourceLength: file.bytes.length,
      contentLength: end - start,
      offset: start,
      stream: Stream.value(file.bytes.sublist(start, end)),
      contentType: file.mimeType,
    );
  }
}

// #Pangea
class BytesAudioSource extends StreamAudioSource {
  final Uint8List bytes;
  final String mimeType;
  BytesAudioSource(this.bytes, this.mimeType);

  @override
  Future<StreamAudioResponse> request([int? start, int? end]) async {
    start ??= 0;
    end ??= bytes.length;
    return StreamAudioResponse(
      sourceLength: bytes.length,
      contentLength: end - start,
      offset: start,
      stream: Stream.value(bytes.sublist(start, end)),
      contentType: mimeType,
    );
  }
}
// Pangea#