import 'dart:async'; import 'dart:io'; import 'package:flutter/foundation.dart'; import 'package:flutter/material.dart'; import 'package:flutter/services.dart'; import 'package:adaptive_dialog/adaptive_dialog.dart'; import 'package:flutter_gen/gen_l10n/l10n.dart'; import 'package:flutter_shortcuts/flutter_shortcuts.dart'; import 'package:future_loading_dialog/future_loading_dialog.dart'; import 'package:go_router/go_router.dart'; import 'package:matrix/matrix.dart' as sdk; import 'package:matrix/matrix.dart'; import 'package:receive_sharing_intent/receive_sharing_intent.dart'; import 'package:uni_links/uni_links.dart'; import 'package:fluffychat/config/app_config.dart'; import 'package:fluffychat/pages/chat/send_file_dialog.dart'; import 'package:fluffychat/pages/chat_list/chat_list_view.dart'; import 'package:fluffychat/utils/localized_exception_extension.dart'; import 'package:fluffychat/utils/matrix_sdk_extensions/matrix_locals.dart'; import 'package:fluffychat/utils/platform_infos.dart'; import '../../../utils/account_bundles.dart'; import '../../config/setting_keys.dart'; import '../../utils/matrix_sdk_extensions/matrix_file_extension.dart'; import '../../utils/url_launcher.dart'; import '../../utils/voip/callkeep_manager.dart'; import '../../widgets/fluffy_chat_app.dart'; import '../../widgets/matrix.dart'; import '../bootstrap/bootstrap_dialog.dart'; import 'package:fluffychat/utils/tor_stub.dart' if (dart.library.html) 'package:tor_detector_web/tor_detector_web.dart'; enum SelectMode { normal, share, } enum PopupMenuAction { settings, invite, newGroup, newSpace, setStatus, archive, } enum ActiveFilter { allChats, unread, groups, spaces, } extension LocalizedActiveFilter on ActiveFilter { String toLocalizedString(BuildContext context) { switch (this) { case ActiveFilter.allChats: return L10n.of(context)!.all; case ActiveFilter.unread: return L10n.of(context)!.unread; case ActiveFilter.groups: return L10n.of(context)!.groups; case ActiveFilter.spaces: return L10n.of(context)!.spaces; } } } class ChatList extends StatefulWidget { static BuildContext? contextForVoip; final String? activeChat; const ChatList({ super.key, required this.activeChat, }); @override ChatListController createState() => ChatListController(); } class ChatListController extends State with TickerProviderStateMixin, RouteAware { StreamSubscription? _intentDataStreamSubscription; StreamSubscription? _intentFileStreamSubscription; StreamSubscription? _intentUriStreamSubscription; void createNewSpace() { context.push('/rooms/newspace'); } ActiveFilter activeFilter = ActiveFilter.allChats; String? _activeSpaceId; String? get activeSpaceId => _activeSpaceId; void setActiveSpace(String spaceId) => setState(() { _activeSpaceId = spaceId; }); void clearActiveSpace() => setState(() { _activeSpaceId = null; }); void addChatAction() async { if (activeSpaceId == null) { context.go('/rooms/newprivatechat'); return; } final roomType = await showConfirmationDialog( context: context, title: L10n.of(context)!.addChatOrSubSpace, actions: [ AlertDialogAction( key: AddRoomType.subspace, label: L10n.of(context)!.createNewSpace, ), AlertDialogAction( key: AddRoomType.chat, label: L10n.of(context)!.createGroup, ), ], ); if (roomType == null) return; final names = await showTextInputDialog( context: context, title: roomType == AddRoomType.subspace ? L10n.of(context)!.createNewSpace : L10n.of(context)!.createGroup, textFields: [ DialogTextField( hintText: roomType == AddRoomType.subspace ? L10n.of(context)!.spaceName : L10n.of(context)!.groupName, minLines: 1, maxLines: 1, maxLength: 64, validator: (text) { if (text == null || text.isEmpty) { return L10n.of(context)!.pleaseChoose; } return null; }, ), DialogTextField( hintText: L10n.of(context)!.chatDescription, minLines: 4, maxLines: 8, maxLength: 255, ), ], okLabel: L10n.of(context)!.create, cancelLabel: L10n.of(context)!.cancel, ); if (names == null) return; final client = Matrix.of(context).client; final result = await showFutureLoadingDialog( context: context, future: () async { late final String roomId; final activeSpace = client.getRoomById(activeSpaceId!)!; await activeSpace.postLoad(); if (roomType == AddRoomType.subspace) { roomId = await client.createSpace( name: names.first, topic: names.last.isEmpty ? null : names.last, visibility: activeSpace.joinRules == JoinRules.public ? sdk.Visibility.public : sdk.Visibility.private, ); } else { roomId = await client.createGroupChat( groupName: names.first, preset: activeSpace.joinRules == JoinRules.public ? CreateRoomPreset.publicChat : CreateRoomPreset.privateChat, visibility: activeSpace.joinRules == JoinRules.public ? sdk.Visibility.public : sdk.Visibility.private, initialState: names.length > 1 && names.last.isNotEmpty ? [ sdk.StateEvent( type: sdk.EventTypes.RoomTopic, content: {'topic': names.last}, ), ] : null, ); } await activeSpace.setSpaceChild(roomId); }, ); if (result.error != null) return; } void onChatTap(Room room) async { if (room.isSpace) { setActiveSpace(room.id); return; } if (room.membership == Membership.invite) { final inviterId = room.getState(EventTypes.RoomMember, room.client.userID!)?.senderId; final inviteAction = await showModalActionSheet( context: context, message: room.isDirectChat ? L10n.of(context)!.invitePrivateChat : L10n.of(context)!.inviteGroupChat, title: room.getLocalizedDisplayname(MatrixLocals(L10n.of(context)!)), actions: [ SheetAction( key: InviteActions.accept, label: L10n.of(context)!.accept, icon: Icons.check_outlined, isDefaultAction: true, ), SheetAction( key: InviteActions.decline, label: L10n.of(context)!.decline, icon: Icons.close_outlined, isDestructiveAction: true, ), SheetAction( key: InviteActions.block, label: L10n.of(context)!.block, icon: Icons.block_outlined, isDestructiveAction: true, ), ], ); if (inviteAction == null) return; if (inviteAction == InviteActions.block) { context.go('/rooms/settings/security/ignorelist', extra: inviterId); return; } if (inviteAction == InviteActions.decline) { await showFutureLoadingDialog( context: context, future: room.leave, ); return; } final joinResult = await showFutureLoadingDialog( context: context, future: () async { final waitForRoom = room.client.waitForRoomInSync( room.id, join: true, ); await room.join(); await waitForRoom; }, ); if (joinResult.error != null) return; } if (room.membership == Membership.ban) { ScaffoldMessenger.of(context).showSnackBar( SnackBar( content: Text(L10n.of(context)!.youHaveBeenBannedFromThisChat), ), ); return; } if (room.membership == Membership.leave) { context.go('/rooms/archive/${room.id}'); return; } // Share content into this room final shareContent = Matrix.of(context).shareContent; if (shareContent != null) { final shareFile = shareContent.tryGet('file'); if (shareContent.tryGet('msgtype') == 'chat.fluffy.shared_file' && shareFile != null) { await showDialog( context: context, useRootNavigator: false, builder: (c) => SendFileDialog( files: [shareFile], room: room, ), ); Matrix.of(context).shareContent = null; } else { final consent = await showOkCancelAlertDialog( context: context, title: L10n.of(context)!.forward, message: L10n.of(context)!.forwardMessageTo( room.getLocalizedDisplayname(MatrixLocals(L10n.of(context)!)), ), okLabel: L10n.of(context)!.forward, cancelLabel: L10n.of(context)!.cancel, ); if (consent == OkCancelResult.cancel) { Matrix.of(context).shareContent = null; return; } if (consent == OkCancelResult.ok) { room.sendEvent(shareContent); Matrix.of(context).shareContent = null; } } } context.go('/rooms/${room.id}'); } bool Function(Room) getRoomFilterByActiveFilter(ActiveFilter activeFilter) { switch (activeFilter) { case ActiveFilter.allChats: return (room) => true; case ActiveFilter.groups: return (room) => !room.isSpace && !room.isDirectChat; case ActiveFilter.unread: return (room) => room.isUnreadOrInvited; case ActiveFilter.spaces: return (room) => room.isSpace; } } List get filteredRooms => Matrix.of(context) .client .rooms .where(getRoomFilterByActiveFilter(activeFilter)) .toList(); bool isSearchMode = false; Future? publicRoomsResponse; String? searchServer; Timer? _coolDown; SearchUserDirectoryResponse? userSearchResult; QueryPublicRoomsResponse? roomSearchResult; bool isSearching = false; static const String _serverStoreNamespace = 'im.fluffychat.search.server'; void setServer() async { final newServer = await showTextInputDialog( useRootNavigator: false, title: L10n.of(context)!.changeTheHomeserver, context: context, okLabel: L10n.of(context)!.ok, cancelLabel: L10n.of(context)!.cancel, textFields: [ DialogTextField( prefixText: 'https://', hintText: Matrix.of(context).client.homeserver?.host, initialText: searchServer, keyboardType: TextInputType.url, autocorrect: false, validator: (server) => server?.contains('.') == true ? null : L10n.of(context)!.invalidServerName, ), ], ); if (newServer == null) return; Matrix.of(context).store.setString(_serverStoreNamespace, newServer.single); setState(() { searchServer = newServer.single; }); _coolDown?.cancel(); _coolDown = Timer(const Duration(milliseconds: 500), _search); } final TextEditingController searchController = TextEditingController(); final FocusNode searchFocusNode = FocusNode(); void _search() async { final client = Matrix.of(context).client; if (!isSearching) { setState(() { isSearching = true; }); } SearchUserDirectoryResponse? userSearchResult; QueryPublicRoomsResponse? roomSearchResult; final searchQuery = searchController.text.trim(); try { roomSearchResult = await client.queryPublicRooms( server: searchServer, filter: PublicRoomQueryFilter(genericSearchTerm: searchQuery), limit: 20, ); if (searchQuery.isValidMatrixId && searchQuery.sigil == '#' && roomSearchResult.chunk .any((room) => room.canonicalAlias == searchQuery) == false) { final response = await client.getRoomIdByAlias(searchQuery); final roomId = response.roomId; if (roomId != null) { roomSearchResult.chunk.add( PublicRoomsChunk( name: searchQuery, guestCanJoin: false, numJoinedMembers: 0, roomId: roomId, worldReadable: false, canonicalAlias: searchQuery, ), ); } } userSearchResult = await client.searchUserDirectory( searchController.text, limit: 20, ); } catch (e, s) { Logs().w('Searching has crashed', e, s); ScaffoldMessenger.of(context).showSnackBar( SnackBar( content: Text( e.toLocalizedString(context), ), ), ); } if (!isSearchMode) return; setState(() { isSearching = false; this.roomSearchResult = roomSearchResult; this.userSearchResult = userSearchResult; }); } void onSearchEnter(String text, {bool globalSearch = true}) { if (text.isEmpty) { cancelSearch(unfocus: false); return; } setState(() { isSearchMode = true; }); _coolDown?.cancel(); if (globalSearch) { _coolDown = Timer(const Duration(milliseconds: 500), _search); } } void startSearch() { setState(() { isSearchMode = true; }); searchFocusNode.requestFocus(); _coolDown?.cancel(); _coolDown = Timer(const Duration(milliseconds: 500), _search); } void cancelSearch({bool unfocus = true}) { setState(() { searchController.clear(); isSearchMode = false; roomSearchResult = userSearchResult = null; isSearching = false; }); if (unfocus) searchFocusNode.unfocus(); } bool isTorBrowser = false; BoxConstraints? snappingSheetContainerSize; final ScrollController scrollController = ScrollController(); final ValueNotifier scrolledToTop = ValueNotifier(true); final StreamController _clientStream = StreamController.broadcast(); Stream get clientStream => _clientStream.stream; void addAccountAction() => context.go('/rooms/settings/account'); void _onScroll() { final newScrolledToTop = scrollController.position.pixels <= 0; if (newScrolledToTop != scrolledToTop.value) { scrolledToTop.value = newScrolledToTop; } } void editSpace(BuildContext context, String spaceId) async { await Matrix.of(context).client.getRoomById(spaceId)!.postLoad(); if (mounted) { context.push('/rooms/$spaceId/details'); } } // Needs to match GroupsSpacesEntry for 'separate group' checking. List get spaces => Matrix.of(context).client.rooms.where((r) => r.isSpace).toList(); String? get activeChat => widget.activeChat; SelectMode get selectMode => Matrix.of(context).shareContent != null ? SelectMode.share : SelectMode.normal; void _processIncomingSharedFiles(List files) { if (files.isEmpty) return; final file = File(files.first.path.replaceFirst('file://', '')); Matrix.of(context).shareContent = { 'msgtype': 'chat.fluffy.shared_file', 'file': MatrixFile( bytes: file.readAsBytesSync(), name: file.path, ).detectFileType, }; context.go('/rooms'); } void _processIncomingSharedText(String? text) { if (text == null) return; if (text.toLowerCase().startsWith(AppConfig.deepLinkPrefix) || text.toLowerCase().startsWith(AppConfig.inviteLinkPrefix) || (text.toLowerCase().startsWith(AppConfig.schemePrefix) && !RegExp(r'\s').hasMatch(text))) { return _processIncomingUris(text); } Matrix.of(context).shareContent = { 'msgtype': 'm.text', 'body': text, }; context.go('/rooms'); } void _processIncomingUris(String? text) async { if (text == null) return; context.go('/rooms'); WidgetsBinding.instance.addPostFrameCallback((_) { UrlLauncher(context, text).openMatrixToUrl(); }); } void _initReceiveSharingIntent() { if (!PlatformInfos.isMobile) return; // For sharing images coming from outside the app while the app is in the memory _intentFileStreamSubscription = ReceiveSharingIntent.getMediaStream() .listen(_processIncomingSharedFiles, onError: print); // For sharing images coming from outside the app while the app is closed ReceiveSharingIntent.getInitialMedia().then(_processIncomingSharedFiles); // For sharing or opening urls/text coming from outside the app while the app is in the memory _intentDataStreamSubscription = ReceiveSharingIntent.getTextStream() .listen(_processIncomingSharedText, onError: print); // For sharing or opening urls/text coming from outside the app while the app is closed ReceiveSharingIntent.getInitialText().then(_processIncomingSharedText); // For receiving shared Uris _intentUriStreamSubscription = linkStream.listen(_processIncomingUris); if (FluffyChatApp.gotInitialLink == false) { FluffyChatApp.gotInitialLink = true; getInitialLink().then(_processIncomingUris); } if (PlatformInfos.isAndroid) { final shortcuts = FlutterShortcuts(); shortcuts.initialize().then( (_) => shortcuts.listenAction((action) { if (!mounted) return; UrlLauncher(context, action).launchUrl(); }), ); } } @override void initState() { _initReceiveSharingIntent(); scrollController.addListener(_onScroll); _waitForFirstSync(); _hackyWebRTCFixForWeb(); CallKeepManager().initialize(); WidgetsBinding.instance.addPostFrameCallback((_) async { if (mounted) { searchServer = Matrix.of(context).store.getString(_serverStoreNamespace); Matrix.of(context).backgroundPush?.setupPush(); } // Workaround for system UI overlay style not applied on app start SystemChrome.setSystemUIOverlayStyle( Theme.of(context).appBarTheme.systemOverlayStyle!, ); }); _checkTorBrowser(); super.initState(); } @override void dispose() { _intentDataStreamSubscription?.cancel(); _intentFileStreamSubscription?.cancel(); _intentUriStreamSubscription?.cancel(); scrollController.removeListener(_onScroll); super.dispose(); } void chatContextAction(Room room) async { final action = await showModalActionSheet( context: context, title: room.getLocalizedDisplayname(MatrixLocals(L10n.of(context)!)), actions: [ SheetAction( key: ChatContextAction.markUnread, icon: room.markedUnread ? Icons.mark_as_unread : Icons.mark_as_unread_outlined, label: room.markedUnread ? L10n.of(context)!.markAsRead : L10n.of(context)!.unread, ), SheetAction( key: ChatContextAction.favorite, icon: room.isFavourite ? Icons.pin : Icons.pin_outlined, label: room.isFavourite ? L10n.of(context)!.unpin : L10n.of(context)!.pin, ), SheetAction( key: ChatContextAction.mute, icon: room.pushRuleState == PushRuleState.notify ? Icons.notifications_off_outlined : Icons.notifications, label: room.pushRuleState == PushRuleState.notify ? L10n.of(context)!.muteChat : L10n.of(context)!.unmuteChat, ), SheetAction( isDestructiveAction: true, key: ChatContextAction.leave, icon: Icons.delete_outlined, label: L10n.of(context)!.leave, ), ], ); if (action == null) return; if (!mounted) return; await showFutureLoadingDialog( context: context, future: () { switch (action) { case ChatContextAction.favorite: return room.setFavourite(!room.isFavourite); case ChatContextAction.markUnread: return room.markUnread(!room.markedUnread); case ChatContextAction.mute: return room.setPushRuleState( room.pushRuleState == PushRuleState.notify ? PushRuleState.mentionsOnly : PushRuleState.notify, ); case ChatContextAction.leave: return room.leave(); } }, ); } void dismissStatusList() async { final result = await showOkCancelAlertDialog( title: L10n.of(context)!.hidePresences, context: context, ); if (result == OkCancelResult.ok) { await Matrix.of(context).store.setBool(SettingKeys.showPresences, false); AppConfig.showPresences = false; setState(() {}); } } void setStatus() async { final client = Matrix.of(context).client; final currentPresence = await client.fetchCurrentPresence(client.userID!); final input = await showTextInputDialog( useRootNavigator: false, context: context, title: L10n.of(context)!.setStatus, message: L10n.of(context)!.leaveEmptyToClearStatus, okLabel: L10n.of(context)!.ok, cancelLabel: L10n.of(context)!.cancel, textFields: [ DialogTextField( hintText: L10n.of(context)!.statusExampleMessage, maxLines: 6, minLines: 1, maxLength: 255, initialText: currentPresence.statusMsg, ), ], ); if (input == null) return; if (!mounted) return; await showFutureLoadingDialog( context: context, future: () => client.setPresence( client.userID!, PresenceType.online, statusMsg: input.single, ), ); } bool waitForFirstSync = false; Future _waitForFirstSync() async { final client = Matrix.of(context).client; await client.roomsLoading; await client.accountDataLoading; await client.userDeviceKeysLoading; if (client.prevBatch == null) { await client.onSync.stream.first; // Display first login bootstrap if enabled if (client.encryption?.keyManager.enabled == true) { if (await client.encryption?.keyManager.isCached() == false || await client.encryption?.crossSigning.isCached() == false || client.isUnknownSession && !mounted) { await BootstrapDialog(client: client).show(context); } } } if (!mounted) return; setState(() { waitForFirstSync = true; }); } void cancelAction() { if (selectMode == SelectMode.share) { setState(() => Matrix.of(context).shareContent = null); } } void setActiveFilter(ActiveFilter filter) { setState(() { activeFilter = filter; }); } void setActiveClient(Client client) { context.go('/rooms'); setState(() { activeFilter = ActiveFilter.allChats; _activeSpaceId = null; Matrix.of(context).setActiveClient(client); }); _clientStream.add(client); } void setActiveBundle(String bundle) { context.go('/rooms'); setState(() { _activeSpaceId = null; Matrix.of(context).activeBundle = bundle; if (!Matrix.of(context) .currentBundle! .any((client) => client == Matrix.of(context).client)) { Matrix.of(context) .setActiveClient(Matrix.of(context).currentBundle!.first); } }); } void editBundlesForAccount(String? userId, String? activeBundle) async { final l10n = L10n.of(context)!; final client = Matrix.of(context) .widget .clients[Matrix.of(context).getClientIndexByMatrixId(userId!)]; final action = await showConfirmationDialog( context: context, title: L10n.of(context)!.editBundlesForAccount, actions: [ AlertDialogAction( key: EditBundleAction.addToBundle, label: L10n.of(context)!.addToBundle, ), if (activeBundle != client.userID) AlertDialogAction( key: EditBundleAction.removeFromBundle, label: L10n.of(context)!.removeFromBundle, ), ], ); if (action == null) return; switch (action) { case EditBundleAction.addToBundle: final bundle = await showTextInputDialog( context: context, title: l10n.bundleName, textFields: [DialogTextField(hintText: l10n.bundleName)], ); if (bundle == null || bundle.isEmpty || bundle.single.isEmpty) return; await showFutureLoadingDialog( context: context, future: () => client.setAccountBundle(bundle.single), ); break; case EditBundleAction.removeFromBundle: await showFutureLoadingDialog( context: context, future: () => client.removeFromAccountBundle(activeBundle!), ); } } bool get displayBundles => Matrix.of(context).hasComplexBundles && Matrix.of(context).accountBundles.keys.length > 1; String? get secureActiveBundle { if (Matrix.of(context).activeBundle == null || !Matrix.of(context) .accountBundles .keys .contains(Matrix.of(context).activeBundle)) { return Matrix.of(context).accountBundles.keys.first; } return Matrix.of(context).activeBundle; } void resetActiveBundle() { WidgetsBinding.instance.addPostFrameCallback((timeStamp) { setState(() { Matrix.of(context).activeBundle = null; }); }); } @override Widget build(BuildContext context) => ChatListView(this); void _hackyWebRTCFixForWeb() { ChatList.contextForVoip = context; } Future _checkTorBrowser() async { if (!kIsWeb) return; final isTor = await TorBrowserDetector.isTorBrowser; isTorBrowser = isTor; } Future dehydrate() => Matrix.of(context).dehydrateAction(); } enum EditBundleAction { addToBundle, removeFromBundle } enum InviteActions { accept, decline, block, } enum AddRoomType { chat, subspace } enum ChatContextAction { favorite, markUnread, mute, leave, }