mirror of
https://gitlab.com/comunic/comunicmobile
synced 2024-11-22 12:59:21 +00:00
766 lines
24 KiB
Dart
766 lines
24 KiB
Dart
import 'dart:async';
|
|
|
|
import 'package:comunic/enums/report_target_type.dart';
|
|
import 'package:comunic/helpers/conversations_helper.dart';
|
|
import 'package:comunic/helpers/events_helper.dart';
|
|
import 'package:comunic/helpers/server_config_helper.dart';
|
|
import 'package:comunic/helpers/users_helper.dart';
|
|
import 'package:comunic/lists/conversation_messages_list.dart';
|
|
import 'package:comunic/lists/users_list.dart';
|
|
import 'package:comunic/models/api_request.dart';
|
|
import 'package:comunic/models/config.dart';
|
|
import 'package:comunic/models/conversation.dart';
|
|
import 'package:comunic/models/conversation_message.dart';
|
|
import 'package:comunic/models/new_conversation_message.dart';
|
|
import 'package:comunic/models/report_target.dart';
|
|
import 'package:comunic/ui/dialogs/pick_file_dialog.dart';
|
|
import 'package:comunic/ui/dialogs/report_dialog.dart';
|
|
import 'package:comunic/ui/routes/main_route/main_route.dart';
|
|
import 'package:comunic/ui/tiles/conversation_message_tile.dart';
|
|
import 'package:comunic/ui/tiles/server_conversation_message_tile.dart';
|
|
import 'package:comunic/ui/widgets/account_image_widget.dart';
|
|
import 'package:comunic/ui/widgets/safe_state.dart';
|
|
import 'package:comunic/ui/widgets/scroll_watcher.dart';
|
|
import 'package:comunic/ui/widgets/user_writing_in_conv_notifier.dart';
|
|
import 'package:comunic/utils/account_utils.dart';
|
|
import 'package:comunic/utils/date_utils.dart';
|
|
import 'package:comunic/utils/files_utils.dart';
|
|
import 'package:comunic/utils/intl_utils.dart';
|
|
import 'package:comunic/utils/list_utils.dart';
|
|
import 'package:comunic/utils/log_utils.dart';
|
|
import 'package:comunic/utils/ui_utils.dart';
|
|
import 'package:comunic/utils/video_utils.dart';
|
|
import 'package:dio/dio.dart';
|
|
import 'package:emoji_picker_flutter/emoji_picker_flutter.dart' as emoji;
|
|
import 'package:flutter/material.dart';
|
|
import 'package:mime/mime.dart';
|
|
|
|
/// Conversation screen
|
|
///
|
|
/// @author Pierre HUBERT
|
|
|
|
enum ErrorLevel { NONE, MINOR, MAJOR }
|
|
enum _OlderMessagesLevel { NONE, LOADING, NO_MORE_AVAILABLE }
|
|
|
|
class ConversationScreen extends StatefulWidget {
|
|
final int conversationID;
|
|
|
|
const ConversationScreen({Key? key, required this.conversationID})
|
|
: super(key: key);
|
|
|
|
@override
|
|
State<StatefulWidget> createState() => _ConversationScreenState();
|
|
}
|
|
|
|
class _ConversationScreenState extends SafeState<ConversationScreen> {
|
|
//Helpers
|
|
final ConversationsHelper _conversationsHelper = ConversationsHelper();
|
|
final UsersHelper _usersHelper = UsersHelper();
|
|
|
|
// Class members
|
|
late Conversation _conversation;
|
|
ConversationMessagesList? _messages;
|
|
UsersList _usersInfo = UsersList();
|
|
ErrorLevel _error = ErrorLevel.NONE;
|
|
final _textFieldFocus = FocusNode();
|
|
|
|
bool _showEmojiPicker = false;
|
|
|
|
bool _isSendingMessage = false;
|
|
TextEditingController _textController = TextEditingController();
|
|
ScrollWatcher? _scrollController;
|
|
_OlderMessagesLevel _loadingOlderMessages = _OlderMessagesLevel.NONE;
|
|
|
|
int _lastWritingEventSent = 0;
|
|
|
|
CancelToken? _sendCancel;
|
|
double? _sendProgress;
|
|
|
|
String get textMessage => _textController.text;
|
|
|
|
bool get _isMessageValid =>
|
|
textMessage.length >=
|
|
ServerConfigurationHelper.config!.conversationsPolicy.minMessageLen &&
|
|
textMessage.length <
|
|
ServerConfigurationHelper.config!.conversationsPolicy.maxMessageLen;
|
|
|
|
showKeyboard() => _textFieldFocus.requestFocus();
|
|
|
|
hideKeyboard() => _textFieldFocus.unfocus();
|
|
|
|
hideEmojiContainer() => setState(() => _showEmojiPicker = false);
|
|
|
|
showEmojiContainer() => setState(() => _showEmojiPicker = true);
|
|
|
|
// Colors definition
|
|
Color get _senderColor =>
|
|
_conversation.color ??
|
|
config().defaultConversationColor ??
|
|
/*(darkTheme() ? Color(0xff2b343b) :*/ Colors.blue.shade700; //);
|
|
|
|
Color get _receiverColor =>
|
|
darkTheme() ? Color(0xff3a3d40) : Colors.grey.shade600;
|
|
|
|
Color get _greyColor => Color(0xff8f8f8f);
|
|
|
|
Color get _gradientColorStart =>
|
|
(_conversation.color ?? config().defaultConversationColor)
|
|
?.withOpacity(0.7) ??
|
|
(darkTheme() ? Color(0xff00b6f3) : Colors.blue.shade300);
|
|
|
|
Color get _gradientColorEnd =>
|
|
_conversation.color ??
|
|
config().defaultConversationColor ??
|
|
(darkTheme() ? Color(0xff0184dc) : Colors.blueAccent.shade700);
|
|
|
|
Color get _separatorColor =>
|
|
darkTheme() ? Color(0xff272c35) : Color(0xffBEBEBE);
|
|
|
|
LinearGradient get _fabGradient => LinearGradient(
|
|
colors: [_gradientColorStart, _gradientColorEnd],
|
|
begin: Alignment.topLeft,
|
|
end: Alignment.bottomRight,
|
|
);
|
|
|
|
LinearGradient get _disabledGradient => LinearGradient(
|
|
colors: [_greyColor, _receiverColor],
|
|
begin: Alignment.topLeft,
|
|
end: Alignment.bottomRight,
|
|
);
|
|
|
|
@override
|
|
void initState() {
|
|
super.initState();
|
|
_init();
|
|
}
|
|
|
|
@override
|
|
void dispose() {
|
|
super.dispose();
|
|
_deallocate();
|
|
}
|
|
|
|
void _setError(ErrorLevel err) => setState(() => _error = err);
|
|
|
|
void _setSending(bool sending) => setState(() => _isSendingMessage = sending);
|
|
|
|
void _setLoadingOlderMessagesState(_OlderMessagesLevel state) => setState(() {
|
|
_loadingOlderMessages = state;
|
|
});
|
|
|
|
/// Method called when an error occurred while loading messages
|
|
void _errorLoading() =>
|
|
_setError(_messages == null ? ErrorLevel.MAJOR : ErrorLevel.MINOR);
|
|
|
|
/// Load the first conversations
|
|
Future<void> _init() async {
|
|
_scrollController = ScrollWatcher(onReachBottom: _loadOlderMessages);
|
|
|
|
_conversation =
|
|
await ConversationsHelper().getSingle(widget.conversationID);
|
|
|
|
// Fetch latest messages
|
|
await _loadMessages(false);
|
|
await _loadMessages(true);
|
|
|
|
await _conversationsHelper
|
|
.registerConversationEvents(widget.conversationID);
|
|
|
|
this.listen<NewConversationMessageEvent>((ev) async {
|
|
if (ev.msg.convID == widget.conversationID) {
|
|
try {
|
|
await _conversationsHelper.saveMessage(ev.msg);
|
|
await _applyNewMessages(ConversationMessagesList()..add(ev.msg));
|
|
} catch (e, s) {
|
|
print("Failed to show new message! $e => $s");
|
|
_errorLoading();
|
|
}
|
|
}
|
|
});
|
|
|
|
this.listen<UpdatedConversationMessageEvent>((ev) async {
|
|
if (ev.msg.convID == widget.conversationID) {
|
|
await _conversationsHelper.saveMessage(ev.msg);
|
|
setState(() => _messages!.replace(ev.msg));
|
|
}
|
|
});
|
|
|
|
this.listen<DeletedConversationMessageEvent>((ev) async {
|
|
if (ev.msg.convID == widget.conversationID) {
|
|
await _conversationsHelper.removeMessage(ev.msg);
|
|
setState(() => _messages!.removeMsg(ev.msg.id));
|
|
}
|
|
});
|
|
|
|
this.listen<RemovedUserFromConversationEvent>((ev) {
|
|
if (ev.userID == userID() && ev.convID == widget.conversationID) {
|
|
setState(() => _error = ErrorLevel.MAJOR);
|
|
}
|
|
});
|
|
|
|
this.listen<DeletedConversationEvent>((ev) {
|
|
if (ev.convID == widget.conversationID) {
|
|
setState(() => _error = ErrorLevel.MAJOR);
|
|
}
|
|
});
|
|
}
|
|
|
|
/// Free resources when this conversation widget is no longer required
|
|
void _deallocate() {
|
|
_conversationsHelper.unregisterConversationEvents(widget.conversationID);
|
|
}
|
|
|
|
/// Load a list of messages
|
|
Future<void> _loadMessages(bool online) async {
|
|
if (!mounted) return;
|
|
|
|
try {
|
|
//First, get the messages
|
|
final messages = await _conversationsHelper.getNewMessages(
|
|
conversationID: widget.conversationID,
|
|
lastMessageID: _messages == null ? 0 : _messages!.lastMessageID,
|
|
online: online,
|
|
);
|
|
|
|
// In case we are offline and we did not get any message we do not do
|
|
// anything (we wait for the online request)
|
|
if (messages.length == 0 && !online) return;
|
|
|
|
await _applyNewMessages(messages);
|
|
} catch (e, s) {
|
|
debugPrint("Failed to load messages! $e => $s", wrapWidth: 4096);
|
|
_errorLoading();
|
|
}
|
|
}
|
|
|
|
/// Get older messages
|
|
Future<void> _loadOlderMessages() async {
|
|
if (_loadingOlderMessages != _OlderMessagesLevel.NONE ||
|
|
_messages == null ||
|
|
_messages!.length == 0) return;
|
|
try {
|
|
// Let's start to load older messages
|
|
_setLoadingOlderMessagesState(_OlderMessagesLevel.LOADING);
|
|
|
|
final messages = await _conversationsHelper.getOlderMessages(
|
|
conversationID: widget.conversationID,
|
|
oldestMessagesID: _messages!.firstMessageID);
|
|
|
|
// Mark as not loading anymore
|
|
_setLoadingOlderMessagesState(_OlderMessagesLevel.NONE);
|
|
|
|
// Check if there is no more unread messages
|
|
if (messages.length == 0) {
|
|
_setLoadingOlderMessagesState(_OlderMessagesLevel.NO_MORE_AVAILABLE);
|
|
return;
|
|
}
|
|
|
|
// Apply the messages
|
|
_applyNewMessages(messages);
|
|
} catch (e, s) {
|
|
print("Failed to load older messages! $e => $s");
|
|
_errorLoading();
|
|
}
|
|
}
|
|
|
|
/// Apply new messages [messages] must not be null
|
|
///
|
|
/// Throws in case of failure
|
|
Future<void> _applyNewMessages(ConversationMessagesList messages) async {
|
|
// We ignore new messages once the area is no longer visible
|
|
if (!this.mounted) return;
|
|
|
|
//Then get information about users
|
|
final usersToGet =
|
|
findMissingFromSet(_usersInfo.usersID.toSet(), messages.getUsersID());
|
|
|
|
final users = await _usersHelper.getList(usersToGet);
|
|
|
|
// Save the new list of messages
|
|
setState(() {
|
|
_usersInfo.addAll(users);
|
|
if (_messages == null)
|
|
_messages = messages;
|
|
else
|
|
_messages!.addAll(messages);
|
|
|
|
//Reverse the order of the messages (if required)
|
|
if (messages.length > 0) {
|
|
_messages!.sort();
|
|
final Iterable<ConversationMessage> reverse = _messages!.reversed;
|
|
_messages = ConversationMessagesList();
|
|
_messages!.addAll(reverse);
|
|
}
|
|
});
|
|
|
|
// Remove previous errors
|
|
_setError(ErrorLevel.NONE);
|
|
}
|
|
|
|
/// Send a file message
|
|
Future<void> _sendFileMessage() async {
|
|
try {
|
|
final file = await showPickFileDialog(
|
|
context: context,
|
|
maxFileSize: srvConfig!.conversationsPolicy.filesMaxSize,
|
|
allowedMimeTypes: srvConfig!.conversationsPolicy.allowedFilesType,
|
|
imageMaxWidth: srvConfig!.conversationsPolicy.maxMessageImageWidth,
|
|
imageMaxHeight: srvConfig!.conversationsPolicy.maxMessageImageHeight,
|
|
);
|
|
|
|
if (file == null) return;
|
|
|
|
BytesFile? thumbnail;
|
|
|
|
if (isVideo(lookupMimeType(file.filename)!))
|
|
thumbnail = await generateVideoThumbnail(
|
|
videoFile: file,
|
|
maxWidth: srvConfig!.conversationsPolicy.maxThumbnailWidth,
|
|
);
|
|
|
|
_sendCancel = CancelToken();
|
|
final progressCb =
|
|
(count, total) => setState(() => _sendProgress = count / total);
|
|
final res = await ConversationsHelper().sendMessage(
|
|
NewConversationMessage(
|
|
conversationID: widget.conversationID,
|
|
message: null,
|
|
file: file,
|
|
thumbnail: thumbnail),
|
|
sendProgress: progressCb,
|
|
cancelToken: _sendCancel,
|
|
);
|
|
assert(res == SendMessageResult.SUCCESS);
|
|
} catch (e, s) {
|
|
logError(e, s);
|
|
showSimpleSnack(context, tr("Failed to send a file!")!);
|
|
}
|
|
|
|
setState(() {
|
|
_sendCancel = null;
|
|
_sendProgress = null;
|
|
});
|
|
}
|
|
|
|
/// Send a new text message
|
|
Future<void> _submitTextMessage() async {
|
|
if (await _submitMessage(NewConversationMessage(
|
|
conversationID: widget.conversationID,
|
|
message: textMessage,
|
|
)) ==
|
|
SendMessageResult.SUCCESS) _clearSendMessageForm();
|
|
}
|
|
|
|
/// Submit a new message
|
|
Future<SendMessageResult> _submitMessage(
|
|
NewConversationMessage message) async {
|
|
//Send the message
|
|
_setSending(true);
|
|
final result = await _conversationsHelper.sendMessage(message);
|
|
_setSending(false);
|
|
|
|
//Check the result of the operation
|
|
if (result != SendMessageResult.SUCCESS)
|
|
ScaffoldMessenger.of(context).showSnackBar(
|
|
SnackBar(
|
|
content: Text(
|
|
result == SendMessageResult.MESSAGE_REJECTED
|
|
? tr("Message rejected by the server!")!
|
|
: tr("Could not send message!")!,
|
|
),
|
|
duration: Duration(milliseconds: 500),
|
|
),
|
|
);
|
|
|
|
return result;
|
|
}
|
|
|
|
/// Clear send message form
|
|
void _clearSendMessageForm() {
|
|
setState(() => _textController = TextEditingController());
|
|
}
|
|
|
|
/// Error handling
|
|
Widget _buildError() {
|
|
return buildErrorCard(tr("Could not load the list of messages!"));
|
|
}
|
|
|
|
/// Widget shown when loading older messages
|
|
Widget _buildLoadingOlderMessage() {
|
|
return Container(
|
|
padding: EdgeInsets.all(8.0),
|
|
child: CircularProgressIndicator(),
|
|
);
|
|
}
|
|
|
|
/// Notice shown when there is no messages to show
|
|
Widget _buildNoMessagesNotice() {
|
|
return Expanded(
|
|
child: Center(
|
|
child: Text(tr("There is no message yet in this conversation.")!),
|
|
),
|
|
);
|
|
}
|
|
|
|
/// Messages list
|
|
Widget _buildMessagesList() {
|
|
return Expanded(
|
|
child: ListView.builder(
|
|
controller: _scrollController,
|
|
reverse: true,
|
|
itemCount: _messages!.length,
|
|
itemBuilder: (c, i) => _buildMessageItem(i),
|
|
));
|
|
}
|
|
|
|
Widget _buildMessageItem(int msgIndex) {
|
|
final msg = _messages![msgIndex];
|
|
final nextMessage =
|
|
msgIndex + 1 < _messages!.length ? _messages![msgIndex + 1] : null;
|
|
|
|
return Column(
|
|
children: <Widget>[
|
|
Container(
|
|
child: !isSameDate(msg.date, nextMessage?.date)
|
|
? _buildDateWidget(msg.date)
|
|
: null,
|
|
),
|
|
msg.isServerMessage
|
|
? Container(
|
|
alignment: Alignment.center,
|
|
child: ServerConversationMessageTile(
|
|
message: msg.serverMessage!, users: _usersInfo),
|
|
)
|
|
: Container(
|
|
margin: EdgeInsets.symmetric(vertical: 5),
|
|
alignment:
|
|
msg.isOwner ? Alignment.centerRight : Alignment.centerLeft,
|
|
child: msg.isOwner
|
|
? _buildSenderLayout(msg, nextMessage)
|
|
: _buildReceiverLayout(msg, nextMessage),
|
|
),
|
|
],
|
|
);
|
|
}
|
|
|
|
Widget _buildSenderLayout(
|
|
ConversationMessage message, ConversationMessage? previousMessage) {
|
|
final messageRadius = Radius.circular(10);
|
|
|
|
return Container(
|
|
margin: EdgeInsets.only(
|
|
top: previousMessage?.isOwner == true ? 0 : 12, right: 5),
|
|
constraints:
|
|
BoxConstraints(maxWidth: MediaQuery.of(context).size.width * 0.65),
|
|
decoration: BoxDecoration(
|
|
color: _senderColor,
|
|
borderRadius: BorderRadius.only(
|
|
topLeft: messageRadius,
|
|
topRight: messageRadius,
|
|
bottomLeft: messageRadius,
|
|
),
|
|
),
|
|
child: Padding(
|
|
padding: EdgeInsets.all(10),
|
|
child: _buildMessage(message),
|
|
),
|
|
);
|
|
}
|
|
|
|
Widget _buildReceiverLayout(
|
|
ConversationMessage message, ConversationMessage? previousMessage) {
|
|
final messageRadius = Radius.circular(10);
|
|
|
|
return Row(children: [
|
|
SizedBox(width: 5),
|
|
AccountImageWidget(
|
|
user: _usersInfo.getUser(message.userID),
|
|
),
|
|
SizedBox(width: 5),
|
|
Container(
|
|
margin: EdgeInsets.only(
|
|
top: previousMessage == null ||
|
|
message.userID != previousMessage.userID
|
|
? 12
|
|
: 0),
|
|
constraints:
|
|
BoxConstraints(maxWidth: MediaQuery.of(context).size.width * 0.65),
|
|
decoration: BoxDecoration(
|
|
color: _receiverColor,
|
|
borderRadius: BorderRadius.only(
|
|
bottomRight: messageRadius,
|
|
topRight: messageRadius,
|
|
bottomLeft: messageRadius,
|
|
),
|
|
),
|
|
child: Padding(
|
|
padding: EdgeInsets.all(10),
|
|
child: _buildMessage(message),
|
|
),
|
|
),
|
|
]);
|
|
}
|
|
|
|
Widget _buildMessage(ConversationMessage msg) => ConversationMessageTile(
|
|
message: msg,
|
|
user: _usersInfo.getUser(msg.userID),
|
|
onRequestMessageStats: _requestMessageStats,
|
|
onRequestMessageUpdate: _updateMessage,
|
|
onRequestMessageDelete: _deleteMessage,
|
|
onReportMessage: _reportMessage,
|
|
);
|
|
|
|
Widget _buildDateWidget(DateTime dt) => Center(
|
|
child: Container(
|
|
child: Text(
|
|
formatDisplayDate(dt, time: false),
|
|
style: TextStyle(fontWeight: FontWeight.bold),
|
|
),
|
|
padding: EdgeInsets.only(top: 50, bottom: 5),
|
|
));
|
|
|
|
/// Send new message form
|
|
Widget _buildSendMessageForm() => Container(
|
|
padding: EdgeInsets.fromLTRB(10, 5, 10, 5),
|
|
child: Row(
|
|
children: <Widget>[
|
|
GestureDetector(
|
|
onTap: !_isSendingMessage ? _sendFileMessage : null,
|
|
child: Container(
|
|
padding: EdgeInsets.all(6),
|
|
decoration: BoxDecoration(
|
|
gradient:
|
|
_isSendingMessage ? _disabledGradient : _fabGradient,
|
|
shape: BoxShape.circle,
|
|
),
|
|
child: Icon(
|
|
Icons.add,
|
|
color: Colors.white,
|
|
),
|
|
),
|
|
),
|
|
SizedBox(width: 5),
|
|
Expanded(
|
|
child: Stack(
|
|
alignment: Alignment.centerRight,
|
|
children: [
|
|
TextField(
|
|
enabled: !_isSendingMessage,
|
|
maxLines: 10,
|
|
minLines: 1,
|
|
controller: _textController,
|
|
focusNode: _textFieldFocus,
|
|
onTap: () => hideEmojiContainer(),
|
|
textInputAction: TextInputAction.send,
|
|
onSubmitted: (s) => _submitTextMessage(),
|
|
style: TextStyle(
|
|
color: darkTheme() ? Colors.white : Colors.black,
|
|
),
|
|
onChanged: (s) {
|
|
_sendWritingEvent();
|
|
setState(() {});
|
|
},
|
|
decoration: InputDecoration(
|
|
hintText: tr("New message..."),
|
|
hintStyle: TextStyle(
|
|
color: _greyColor,
|
|
),
|
|
border: OutlineInputBorder(
|
|
borderRadius: const BorderRadius.all(
|
|
const Radius.circular(50.0),
|
|
),
|
|
borderSide: BorderSide.none),
|
|
contentPadding: EdgeInsets.fromLTRB(20, 8, 32, 8),
|
|
filled: true,
|
|
fillColor: _separatorColor,
|
|
),
|
|
),
|
|
IconButton(
|
|
splashColor: Colors.transparent,
|
|
highlightColor: Colors.transparent,
|
|
onPressed: () {
|
|
if (!_showEmojiPicker) {
|
|
// keyboard is visible
|
|
hideKeyboard();
|
|
Future.delayed(Duration(milliseconds: 100),
|
|
() => showEmojiContainer());
|
|
} else {
|
|
//keyboard is hidden
|
|
showKeyboard();
|
|
hideEmojiContainer();
|
|
}
|
|
},
|
|
icon: Icon(
|
|
Icons.face,
|
|
color: _showEmojiPicker ? _senderColor : null,
|
|
),
|
|
),
|
|
],
|
|
),
|
|
),
|
|
SizedBox(width: 5),
|
|
GestureDetector(
|
|
onTap: _isMessageValid ? _submitTextMessage : null,
|
|
child: Container(
|
|
padding: EdgeInsets.all(8),
|
|
decoration: BoxDecoration(
|
|
gradient: !_isMessageValid ? _disabledGradient : _fabGradient,
|
|
shape: BoxShape.circle,
|
|
),
|
|
child: Icon(
|
|
Icons.send,
|
|
color: Colors.white,
|
|
),
|
|
),
|
|
),
|
|
],
|
|
),
|
|
);
|
|
|
|
Widget _buildEmojiContainer() => Container(
|
|
height: 200,
|
|
child: emoji.EmojiPicker(
|
|
config: emoji.Config(
|
|
bgColor: _senderColor,
|
|
indicatorColor: _senderColor,
|
|
columns: 8,
|
|
showRecentsTab: false,
|
|
),
|
|
onEmojiSelected: (category, emoji) {
|
|
_textController.text = _textController.text + emoji.emoji;
|
|
},
|
|
),
|
|
);
|
|
|
|
Widget _buildSendingWidget() => Container(
|
|
height: 68,
|
|
color: _senderColor,
|
|
child: Row(
|
|
children: <Widget>[
|
|
Spacer(flex: 1),
|
|
Flexible(
|
|
child: LinearProgressIndicator(value: _sendProgress),
|
|
flex: 5,
|
|
),
|
|
Spacer(flex: 1),
|
|
Text("${(_sendProgress! * 100).toInt()}%"),
|
|
Spacer(flex: 1),
|
|
OutlinedButton(
|
|
onPressed: () => _sendCancel!.cancel(),
|
|
child: Text(tr("Cancel")!.toUpperCase()),
|
|
),
|
|
Spacer(flex: 1),
|
|
],
|
|
),
|
|
);
|
|
|
|
@override
|
|
Widget build(BuildContext context) {
|
|
if (_error == ErrorLevel.MAJOR) return _buildError();
|
|
|
|
if (_messages == null) return buildCenteredProgressBar();
|
|
|
|
return Column(
|
|
children: <Widget>[
|
|
Container(
|
|
child: _error == ErrorLevel.MINOR ? _buildError() : null,
|
|
),
|
|
Container(
|
|
child: _loadingOlderMessages == _OlderMessagesLevel.LOADING
|
|
? _buildLoadingOlderMessage()
|
|
: null,
|
|
),
|
|
_messages!.length == 0
|
|
? _buildNoMessagesNotice()
|
|
: _buildMessagesList(),
|
|
UserWritingInConvNotifier(convID: _conversation.id!),
|
|
_sendCancel != null ? _buildSendingWidget() : _buildSendMessageForm(),
|
|
_showEmojiPicker ? _buildEmojiContainer() : Container(),
|
|
],
|
|
);
|
|
}
|
|
|
|
void _sendWritingEvent() async {
|
|
try {
|
|
if (textMessage.isEmpty) return;
|
|
final t = time();
|
|
|
|
if (t - _lastWritingEventSent <
|
|
srvConfig!.conversationsPolicy.writingEventInterval) return;
|
|
|
|
_lastWritingEventSent = t;
|
|
await ConversationsHelper.sendWritingEvent(_conversation.id);
|
|
} catch (e, s) {
|
|
logError(e, s);
|
|
}
|
|
}
|
|
|
|
/// Request message statistics
|
|
void _requestMessageStats(ConversationMessage message) async {
|
|
MainController.of(context)!
|
|
.openConversationMessageStats(_conversation, message);
|
|
}
|
|
|
|
/// Request message content update
|
|
Future<void> _updateMessage(ConversationMessage message) async {
|
|
final newContent = await askUserString(
|
|
context: context,
|
|
title: tr("Update message")!,
|
|
message: tr("Please enter new message content:")!,
|
|
defaultValue: message.message.content!,
|
|
hint: tr("New message")!,
|
|
minLength:
|
|
ServerConfigurationHelper.config!.conversationsPolicy.minMessageLen,
|
|
maxLength:
|
|
ServerConfigurationHelper.config!.conversationsPolicy.maxMessageLen,
|
|
);
|
|
|
|
if (newContent == null) return;
|
|
|
|
if (!await _conversationsHelper.updateMessage(message.id, newContent)) {
|
|
showSimpleSnack(context, tr("Could not update message content!")!);
|
|
return;
|
|
}
|
|
}
|
|
|
|
/// Request message deletion
|
|
Future<void> _deleteMessage(ConversationMessage message) async {
|
|
final choice = await showDialog<bool>(
|
|
context: context,
|
|
builder: (c) => AlertDialog(
|
|
title: Text(tr("Confirm deletion")!),
|
|
content: Text(
|
|
tr("Do you really want to delete this message ? The operation can not be cancelled !")!,
|
|
textAlign: TextAlign.justify,
|
|
),
|
|
actions: <Widget>[
|
|
TextButton(
|
|
child: Text(
|
|
tr("Cancel")!.toUpperCase(),
|
|
),
|
|
onPressed: () => Navigator.pop(c, false),
|
|
),
|
|
TextButton(
|
|
child: Text(
|
|
tr("Confirm")!.toUpperCase(),
|
|
style: TextStyle(color: Colors.red),
|
|
),
|
|
onPressed: () => Navigator.pop(c, true),
|
|
),
|
|
],
|
|
),
|
|
);
|
|
|
|
if (choice == null || !choice) return;
|
|
|
|
// Execute the request
|
|
if (!await _conversationsHelper.deleteMessage(message.id))
|
|
showSimpleSnack(context, tr("Could not delete conversation message!")!);
|
|
}
|
|
|
|
/// Report message
|
|
void _reportMessage(ConversationMessage msg) => showReportDialog(
|
|
ctx: context,
|
|
target: ReportTarget(ReportTargetType.ConversationMessage, msg.id!));
|
|
}
|