Implement voice messages

lib/components/audio_player.dart

@@ -0,0 +1,140 @@
+import 'dart:async';
+import 'dart:io';
+import 'dart:typed_data';
+
+import 'package:famedlysdk/famedlysdk.dart';
+import 'package:flutter/foundation.dart';
+import 'package:flutter/material.dart';
+import 'package:flutter_sound/flutter_sound.dart';
+import 'package:intl/intl.dart';
+
+import 'matrix.dart';
+
+class AudioPlayer extends StatefulWidget {
+  final Color color;
+  final MxContent content;
+
+  const AudioPlayer(this.content, {this.color = Colors.black, Key key})
+      : super(key: key);
+
+  @override
+  _AudioPlayerState createState() => _AudioPlayerState();
+}
+
+enum AudioPlayerStatus { NOT_DOWNLOADED, DOWNLOADING, DOWNLOADED }
+
+class _AudioPlayerState extends State<AudioPlayer> {
+  AudioPlayerStatus status = AudioPlayerStatus.NOT_DOWNLOADED;
+
+  FlutterSound flutterSound = FlutterSound();
+
+  StreamSubscription soundSubscription;
+
+  static var httpClient = HttpClient();
+  Uint8List audioFile;
+
+  String statusText = "00:00";
+  double currentPosition = 0;
+  double maxPosition = 0;
+
+  @override
+  void dispose() {
+    if (flutterSound.audioState == t_AUDIO_STATE.IS_PLAYING) {
+      flutterSound.stopPlayer();
+    }
+    soundSubscription?.cancel();
+    super.dispose();
+  }
+
+  _downloadAction() async {
+    if (status != AudioPlayerStatus.NOT_DOWNLOADED) return;
+    setState(() => status = AudioPlayerStatus.DOWNLOADING);
+    String url = widget.content.getDownloadLink(Matrix.of(context).client);
+    var request = await httpClient.getUrl(Uri.parse(url));
+    var response = await request.close();
+    var bytes = await consolidateHttpClientResponseBytes(response);
+    setState(() {
+      audioFile = bytes;
+      status = AudioPlayerStatus.DOWNLOADED;
+    });
+    _playAction();
+  }
+
+  _playAction() async {
+    switch (flutterSound.audioState) {
+      case t_AUDIO_STATE.IS_PLAYING:
+        await flutterSound.pausePlayer();
+        break;
+      case t_AUDIO_STATE.IS_PAUSED:
+        await flutterSound.resumePlayer();
+        break;
+      case t_AUDIO_STATE.IS_RECORDING:
+        break;
+      case t_AUDIO_STATE.IS_STOPPED:
+        await flutterSound.startPlayerFromBuffer(
+          audioFile,
+          codec: t_CODEC.CODEC_AAC,
+        );
+        soundSubscription ??= flutterSound.onPlayerStateChanged.listen((e) {
+          if (e != null) {
+            DateTime date =
+                DateTime.fromMillisecondsSinceEpoch(e.currentPosition.toInt());
+            String txt = DateFormat('mm:ss', 'en_US').format(date);
+            this.setState(() {
+              maxPosition = e.duration;
+              currentPosition = e.currentPosition;
+              statusText = txt;
+            });
+            if (e.duration == e.currentPosition) {
+              soundSubscription
+                  ?.cancel()
+                  ?.then((f) => soundSubscription = null);
+            }
+          }
+        });
+        break;
+    }
+  }
+
+  @override
+  Widget build(BuildContext context) {
+    return Row(
+      mainAxisSize: MainAxisSize.min,
+      children: <Widget>[
+        Container(
+          width: 40,
+          child: status == AudioPlayerStatus.DOWNLOADING
+              ? CircularProgressIndicator()
+              : IconButton(
+                  icon: Icon(
+                    flutterSound.audioState == t_AUDIO_STATE.IS_PLAYING
+                        ? Icons.pause
+                        : Icons.play_arrow,
+                    color: widget.color,
+                  ),
+                  onPressed: () {
+                    if (status == AudioPlayerStatus.DOWNLOADED) {
+                      _playAction();
+                    } else {
+                      _downloadAction();
+                    }
+                  },
+                ),
+        ),
+        Slider(
+          value: currentPosition,
+          onChanged: (double position) =>
+              flutterSound.seekToPlayer(position.toInt()),
+          max: status == AudioPlayerStatus.DOWNLOADED ? maxPosition : 0,
+          min: 0,
+        ),
+        Text(
+          statusText,
+          style: TextStyle(
+            color: widget.color,
+          ),
+        ),
+      ],
+    );
+  }
+}

lib/components/dialogs/recording_dialog.dart

@@ -0,0 +1,97 @@
+import 'dart:async';
+
+import 'package:fluffychat/i18n/i18n.dart';
+import 'package:flutter/material.dart';
+import 'package:flutter_sound/flutter_sound.dart';
+import 'package:intl/intl.dart';
+
+class RecordingDialog extends StatefulWidget {
+  final Function onFinished;
+
+  const RecordingDialog({this.onFinished, Key key}) : super(key: key);
+
+  @override
+  _RecordingDialogState createState() => _RecordingDialogState();
+}
+
+class _RecordingDialogState extends State<RecordingDialog> {
+  FlutterSound flutterSound = FlutterSound();
+  String time = "00:00:00";
+
+  StreamSubscription _recorderSubscription;
+
+  void startRecording() async {
+    await flutterSound.startRecorder(
+      codec: t_CODEC.CODEC_AAC,
+    );
+    _recorderSubscription = flutterSound.onRecorderStateChanged.listen((e) {
+      DateTime date =
+          DateTime.fromMillisecondsSinceEpoch(e.currentPosition.toInt());
+      setState(() => time = DateFormat('mm:ss:SS', 'en_US').format(date));
+    });
+  }
+
+  @override
+  void initState() {
+    super.initState();
+    startRecording();
+  }
+
+  @override
+  void dispose() {
+    if (flutterSound.isRecording) flutterSound.stopRecorder();
+    _recorderSubscription?.cancel();
+    super.dispose();
+  }
+
+  @override
+  Widget build(BuildContext context) {
+    return AlertDialog(
+      content: Row(
+        children: <Widget>[
+          CircleAvatar(
+            backgroundColor: Colors.red,
+            radius: 8,
+          ),
+          SizedBox(width: 8),
+          Expanded(
+            child: Text(
+              "${I18n.of(context).recording}: $time",
+              style: TextStyle(
+                fontSize: 18,
+              ),
+            ),
+          ),
+        ],
+      ),
+      actions: <Widget>[
+        FlatButton(
+          child: Text(
+            I18n.of(context).cancel.toUpperCase(),
+            style: TextStyle(
+              color: Theme.of(context).textTheme.body1.color.withAlpha(150),
+            ),
+          ),
+          onPressed: () => Navigator.of(context).pop(),
+        ),
+        FlatButton(
+          child: Row(
+            children: <Widget>[
+              Text(I18n.of(context).send.toUpperCase()),
+              SizedBox(width: 4),
+              Icon(Icons.send, size: 15),
+            ],
+          ),
+          onPressed: () async {
+            await _recorderSubscription?.cancel();
+            final String result = await flutterSound.stopRecorder();
+            if (widget.onFinished != null) {
+              widget.onFinished(result);
+            }
+            Navigator.of(context).pop();
+          },
+        ),
+      ],
+    );
+  }
+}

lib/components/message_content.dart

@@ -1,6 +1,7 @@
 import 'package:bubble/bubble.dart';
 import 'package:cached_network_image/cached_network_image.dart';
 import 'package:famedlysdk/famedlysdk.dart';
+import 'package:fluffychat/components/audio_player.dart';
 import 'package:fluffychat/i18n/i18n.dart';
 import 'package:fluffychat/utils/event_extension.dart';
 import 'package:fluffychat/views/image_viewer.dart';
@@ -59,6 +60,10 @@ class MessageContent extends StatelessWidget {
               ),
             );
           case MessageTypes.Audio:
+            return AudioPlayer(
+              MxContent(event.content["url"]),
+              color: textColor,
+            );
           case MessageTypes.Video:
           case MessageTypes.File:
             return Container(