Solian/lib/screens/chat/chat.dart

269 lines
8.6 KiB
Dart
Raw Normal View History

2024-04-17 15:00:53 +00:00
import 'dart:convert';
import 'package:flutter/material.dart';
2024-04-26 17:36:54 +00:00
import 'package:flutter_animate/flutter_animate.dart';
2024-04-17 15:00:53 +00:00
import 'package:infinite_scroll_pagination/infinite_scroll_pagination.dart';
import 'package:provider/provider.dart';
2024-04-26 17:36:54 +00:00
import 'package:solian/models/call.dart';
2024-04-17 15:00:53 +00:00
import 'package:solian/models/channel.dart';
import 'package:solian/models/message.dart';
import 'package:solian/models/pagination.dart';
import 'package:solian/providers/auth.dart';
2024-04-26 17:36:54 +00:00
import 'package:solian/router.dart';
2024-04-17 15:00:53 +00:00
import 'package:solian/utils/service_url.dart';
import 'package:solian/widgets/chat/channel_action.dart';
import 'package:solian/widgets/chat/maintainer.dart';
2024-04-17 15:00:53 +00:00
import 'package:solian/widgets/chat/message.dart';
import 'package:solian/widgets/chat/message_action.dart';
2024-04-17 15:24:09 +00:00
import 'package:solian/widgets/chat/message_editor.dart';
2024-04-29 12:22:06 +00:00
import 'package:solian/widgets/exts.dart';
2024-04-17 15:00:53 +00:00
import 'package:solian/widgets/indent_wrapper.dart';
2024-04-26 17:36:54 +00:00
import 'package:flutter_gen/gen_l10n/app_localizations.dart';
2024-04-17 15:00:53 +00:00
import 'package:http/http.dart' as http;
class ChatScreen extends StatefulWidget {
final String alias;
const ChatScreen({super.key, required this.alias});
@override
State<ChatScreen> createState() => _ChatScreenState();
}
class _ChatScreenState extends State<ChatScreen> {
2024-04-26 17:36:54 +00:00
Call? _ongoingCall;
2024-04-17 15:00:53 +00:00
Channel? _channelMeta;
2024-05-01 11:39:48 +00:00
final PagingController<int, Message> _pagingController = PagingController(firstPageKey: 0);
2024-04-17 15:00:53 +00:00
final http.Client _client = http.Client();
2024-04-26 15:25:56 +00:00
Future<Channel> fetchMetadata() async {
2024-04-17 15:00:53 +00:00
var uri = getRequestUri('messaging', '/api/channels/${widget.alias}');
var res = await _client.get(uri);
if (res.statusCode == 200) {
final result = jsonDecode(utf8.decode(res.bodyBytes));
setState(() => _channelMeta = Channel.fromJson(result));
2024-04-26 15:25:56 +00:00
return _channelMeta!;
2024-04-17 15:00:53 +00:00
} else {
var message = utf8.decode(res.bodyBytes);
2024-04-29 12:22:06 +00:00
context.showErrorDialog(message);
2024-04-26 15:25:56 +00:00
throw Exception(message);
2024-04-17 15:00:53 +00:00
}
}
2024-04-26 17:36:54 +00:00
Future<Call?> fetchCall() async {
2024-05-01 11:39:48 +00:00
var uri = getRequestUri('messaging', '/api/channels/${widget.alias}/calls/ongoing');
2024-04-26 17:36:54 +00:00
var res = await _client.get(uri);
if (res.statusCode == 200) {
final result = jsonDecode(utf8.decode(res.bodyBytes));
setState(() => _ongoingCall = Call.fromJson(result));
return _ongoingCall;
} else if (res.statusCode != 404) {
var message = utf8.decode(res.bodyBytes);
2024-04-29 12:22:06 +00:00
context.showErrorDialog(message);
2024-04-26 17:36:54 +00:00
throw Exception(message);
} else {
return null;
}
}
2024-04-17 15:00:53 +00:00
Future<void> fetchMessages(int pageKey, BuildContext context) async {
final auth = context.read<AuthProvider>();
if (!await auth.isAuthorized()) return;
final offset = pageKey;
const take = 10;
2024-04-17 15:00:53 +00:00
var uri = getRequestUri(
'messaging',
'/api/channels/${widget.alias}/messages?take=$take&offset=$offset',
);
var res = await auth.client!.get(uri);
if (res.statusCode == 200) {
2024-05-01 11:39:48 +00:00
final result = PaginationResult.fromJson(jsonDecode(utf8.decode(res.bodyBytes)));
final items = result.data?.map((x) => Message.fromJson(x)).toList() ?? List.empty();
2024-04-17 15:00:53 +00:00
final isLastPage = (result.count - pageKey) < take;
if (isLastPage || result.data == null) {
_pagingController.appendLastPage(items);
} else {
final nextPageKey = pageKey + items.length;
_pagingController.appendPage(items, nextPageKey);
}
} else {
_pagingController.error = utf8.decode(res.bodyBytes);
}
}
bool getMessageMergeable(Message? a, Message? b) {
2024-05-01 09:37:34 +00:00
if (a?.replyTo != null) return false;
2024-04-17 15:00:53 +00:00
if (a == null || b == null) return false;
if (a.senderId != b.senderId) return false;
return a.createdAt.difference(b.createdAt).inMinutes <= 5;
}
void addMessage(Message item) {
setState(() {
_pagingController.itemList?.insert(0, item);
});
}
void updateMessage(Message item) {
setState(() {
2024-05-01 11:39:48 +00:00
_pagingController.itemList = _pagingController.itemList?.map((x) => x.id == item.id ? item : x).toList();
});
}
void deleteMessage(Message item) {
setState(() {
2024-05-01 11:39:48 +00:00
_pagingController.itemList = _pagingController.itemList?.where((x) => x.id != item.id).toList();
});
}
Message? _editingItem;
Message? _replyingItem;
void viewActions(Message item) {
showModalBottomSheet(
context: context,
builder: (context) => ChatMessageAction(
channel: widget.alias,
item: item,
onEdit: () => setState(() {
_editingItem = item;
}),
onReply: () => setState(() {
_replyingItem = item;
}),
),
);
}
2024-04-17 15:00:53 +00:00
@override
void initState() {
Future.delayed(Duration.zero, () {
fetchMetadata();
2024-04-26 17:36:54 +00:00
fetchCall();
2024-04-17 15:00:53 +00:00
});
2024-05-01 11:39:48 +00:00
_pagingController.addPageRequestListener((pageKey) => fetchMessages(pageKey, context));
2024-04-17 15:00:53 +00:00
super.initState();
}
@override
Widget build(BuildContext context) {
2024-04-26 17:36:54 +00:00
Widget chatHistoryBuilder(context, item, index) {
bool isMerged = false, hasMerged = false;
if (index > 0) {
2024-05-01 11:39:48 +00:00
hasMerged = getMessageMergeable(_pagingController.itemList?[index - 1], item);
2024-04-26 17:36:54 +00:00
}
if (index + 1 < (_pagingController.itemList?.length ?? 0)) {
2024-05-01 11:39:48 +00:00
isMerged = getMessageMergeable(item, _pagingController.itemList?[index + 1]);
2024-04-26 17:36:54 +00:00
}
return InkWell(
child: Container(
padding: EdgeInsets.only(
top: !isMerged ? 8 : 0,
bottom: !hasMerged ? 8 : 0,
left: 12,
right: 12,
),
child: ChatMessage(
key: Key('m${item.id}'),
item: item,
underMerged: isMerged,
),
),
onLongPress: () => viewActions(item),
);
}
final callBanner = MaterialBanner(
padding: const EdgeInsets.only(top: 4, bottom: 4, left: 20),
leading: const Icon(Icons.call_received),
2024-05-01 11:39:48 +00:00
backgroundColor: Theme.of(context).colorScheme.surfaceVariant.withOpacity(0.9),
2024-04-26 17:36:54 +00:00
dividerColor: const Color.fromARGB(1, 0, 0, 0),
content: Text(AppLocalizations.of(context)!.chatCallOngoing),
actions: [
TextButton(
child: Text(AppLocalizations.of(context)!.chatCallJoin),
onPressed: () {
router.pushNamed(
'chat.channel.call',
extra: _ongoingCall,
pathParameters: {'channel': widget.alias},
);
},
),
],
);
2024-04-17 15:00:53 +00:00
return IndentWrapper(
hideDrawer: true,
2024-05-01 11:39:48 +00:00
title: _channelMeta?.name ?? 'Loading...',
2024-04-26 17:36:54 +00:00
appBarActions: _channelMeta != null
? [
2024-05-01 09:37:34 +00:00
ChannelCallAction(
2024-05-01 11:39:48 +00:00
call: _ongoingCall,
channel: _channelMeta!,
onUpdate: () => fetchMetadata(),
),
2024-05-01 09:37:34 +00:00
ChannelManageAction(
2024-05-01 11:39:48 +00:00
channel: _channelMeta!,
onUpdate: () => fetchMetadata(),
),
2024-04-26 17:36:54 +00:00
]
: [],
2024-04-26 15:25:56 +00:00
child: FutureBuilder(
future: fetchMetadata(),
builder: (context, snapshot) {
if (!snapshot.hasData || snapshot.data == null) {
return const Center(child: CircularProgressIndicator());
}
return ChatMaintainer(
channel: snapshot.data!,
2024-04-26 17:36:54 +00:00
child: Stack(
2024-04-26 15:25:56 +00:00
children: [
2024-04-26 17:36:54 +00:00
Column(
children: [
Expanded(
child: PagedListView<int, Message>(
reverse: true,
pagingController: _pagingController,
builderDelegate: PagedChildBuilderDelegate<Message>(
2024-05-01 11:39:48 +00:00
animateTransitions: true,
transitionDuration: 500.ms,
2024-04-26 17:36:54 +00:00
itemBuilder: chatHistoryBuilder,
2024-05-01 11:39:48 +00:00
noItemsFoundIndicatorBuilder: (_) => Container(),
2024-04-26 17:36:54 +00:00
),
),
2024-04-26 15:25:56 +00:00
),
2024-04-26 17:36:54 +00:00
ChatMessageEditor(
channel: widget.alias,
editing: _editingItem,
replying: _replyingItem,
onReset: () => setState(() {
_editingItem = null;
_replyingItem = null;
}),
),
],
2024-04-26 15:25:56 +00:00
),
2024-05-01 11:39:48 +00:00
_ongoingCall != null ? callBanner.animate().slideY() : Container(),
2024-04-26 15:25:56 +00:00
],
),
2024-04-26 15:25:56 +00:00
onInsertMessage: (message) => addMessage(message),
onUpdateMessage: (message) => updateMessage(message),
onDeleteMessage: (message) => deleteMessage(message),
2024-04-26 17:36:54 +00:00
onCallStarted: (call) => setState(() => _ongoingCall = call),
onCallEnded: () => setState(() => _ongoingCall = null),
2024-04-26 15:25:56 +00:00
);
},
2024-04-17 15:00:53 +00:00
),
);
}
}