import 'dart:async'; import 'package:flutter/foundation.dart'; import 'package:flutter/material.dart'; import 'package:flutter/services.dart'; import 'package:cross_file/cross_file.dart'; import 'package:flutter_gen/gen_l10n/l10n.dart'; import 'package:flutter_shortcuts/flutter_shortcuts.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_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 'package:fluffychat/utils/show_scaffold_dialog.dart'; import 'package:fluffychat/utils/show_update_snackbar.dart'; import 'package:fluffychat/widgets/adaptive_dialogs/show_modal_action_popup.dart'; import 'package:fluffychat/widgets/adaptive_dialogs/show_ok_cancel_alert_dialog.dart'; import 'package:fluffychat/widgets/adaptive_dialogs/show_text_input_dialog.dart'; import 'package:fluffychat/widgets/avatar.dart'; import 'package:fluffychat/widgets/future_loading_dialog.dart'; import 'package:fluffychat/widgets/share_scaffold_dialog.dart'; import '../../../utils/account_bundles.dart'; import '../../config/setting_keys.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 PopupMenuAction { settings, invite, newGroup, newSpace, setStatus, archive, } enum ActiveFilter { allChats, messages, groups, unread, spaces, } extension LocalizedActiveFilter on ActiveFilter { String toLocalizedString(BuildContext context) { switch (this) { case ActiveFilter.allChats: return L10n.of(context).all; case ActiveFilter.messages: return L10n.of(context).messages; 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; final bool displayNavigationRail; const ChatList({ super.key, required this.activeChat, this.displayNavigationRail = false, }); @override ChatListController createState() => ChatListController(); } class ChatListController extends State with TickerProviderStateMixin, RouteAware { StreamSubscription? _intentDataStreamSubscription; StreamSubscription? _intentFileStreamSubscription; StreamSubscription? _intentUriStreamSubscription; ActiveFilter activeFilter = AppConfig.separateChatTypes ? ActiveFilter.messages : ActiveFilter.allChats; String? _activeSpaceId; String? get activeSpaceId => _activeSpaceId; void setActiveSpace(String spaceId) async { await Matrix.of(context).client.getRoomById(spaceId)!.postLoad(); setState(() { _activeSpaceId = spaceId; }); } void clearActiveSpace() => setState(() { _activeSpaceId = null; }); void onChatTap(Room room) async { if (room.membership == Membership.invite) { final joinResult = await showFutureLoadingDialog( context: context, future: () async { final waitForRoom = room.client.waitForRoomInSync( room.id, join: true, ); await room.join(); await waitForRoom; }, exceptionContext: ExceptionContext.joinRoom, ); 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; } if (room.isSpace) { setActiveSpace(room.id); return; } context.go('/rooms/${room.id}'); } bool Function(Room) getRoomFilterByActiveFilter(ActiveFilter activeFilter) { switch (activeFilter) { case ActiveFilter.allChats: return (room) => true; case ActiveFilter.messages: return (room) => !room.isSpace && room.isDirectChat; 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, 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); setState(() { searchServer = newServer; }); _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; void _processIncomingSharedMedia(List files) { if (files.isEmpty) return; showScaffoldDialog( context: context, builder: (context) => ShareScaffoldDialog( items: files.map( (file) { if ({ SharedMediaType.text, SharedMediaType.url, }.contains(file.type)) { return TextShareItem(file.path); } return FileShareItem( XFile( file.path.replaceFirst('file://', ''), mimeType: file.mimeType, ), ); }, ).toList(), ), ); } 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.instance .getMediaStream() .listen(_processIncomingSharedMedia, onError: print); // For sharing images coming from outside the app while the app is closed ReceiveSharingIntent.instance .getInitialMedia() .then(_processIncomingSharedMedia); // 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(); UpdateNotifier.showUpdateSnackBar(context); } // 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, BuildContext posContext, [ Room? space, ]) async { final overlay = Overlay.of(posContext).context.findRenderObject() as RenderBox; final button = posContext.findRenderObject() as RenderBox; final position = RelativeRect.fromRect( Rect.fromPoints( button.localToGlobal(const Offset(0, -65), ancestor: overlay), button.localToGlobal( button.size.bottomRight(Offset.zero) + const Offset(-50, 0), ancestor: overlay, ), ), Offset.zero & overlay.size, ); final displayname = room.getLocalizedDisplayname(MatrixLocals(L10n.of(context))); final spacesWithPowerLevels = room.client.rooms .where( (space) => space.isSpace && space.canChangeStateEvent(EventTypes.SpaceChild) && !space.spaceChildren.any((c) => c.roomId == room.id), ) .toList(); final action = await showMenu( context: posContext, position: position, items: [ PopupMenuItem( value: ChatContextAction.open, child: Row( mainAxisSize: MainAxisSize.min, children: [ Avatar( mxContent: room.avatar, size: Avatar.defaultSize / 2, name: displayname, ), const SizedBox(width: 12), Text( displayname, style: TextStyle(color: Theme.of(context).colorScheme.onSurface), ), ], ), ), const PopupMenuDivider(), if (space != null) PopupMenuItem( value: ChatContextAction.goToSpace, child: Row( mainAxisSize: MainAxisSize.min, children: [ Avatar( mxContent: space.avatar, size: Avatar.defaultSize / 2, name: space.getLocalizedDisplayname(), ), const SizedBox(width: 12), Expanded( child: Text( L10n.of(context).goToSpace(space.getLocalizedDisplayname()), ), ), ], ), ), if (room.membership == Membership.join) ...[ PopupMenuItem( value: ChatContextAction.mute, child: Row( mainAxisSize: MainAxisSize.min, children: [ Icon( room.pushRuleState == PushRuleState.notify ? Icons.notifications_off_outlined : Icons.notifications_off, ), const SizedBox(width: 12), Text( room.pushRuleState == PushRuleState.notify ? L10n.of(context).muteChat : L10n.of(context).unmuteChat, ), ], ), ), PopupMenuItem( value: ChatContextAction.markUnread, child: Row( mainAxisSize: MainAxisSize.min, children: [ Icon( room.markedUnread ? Icons.mark_as_unread : Icons.mark_as_unread_outlined, ), const SizedBox(width: 12), Text( room.markedUnread ? L10n.of(context).markAsRead : L10n.of(context).markAsUnread, ), ], ), ), PopupMenuItem( value: ChatContextAction.favorite, child: Row( mainAxisSize: MainAxisSize.min, children: [ Icon( room.isFavourite ? Icons.push_pin : Icons.push_pin_outlined, ), const SizedBox(width: 12), Text( room.isFavourite ? L10n.of(context).unpin : L10n.of(context).pin, ), ], ), ), if (spacesWithPowerLevels.isNotEmpty) PopupMenuItem( value: ChatContextAction.addToSpace, child: Row( mainAxisSize: MainAxisSize.min, children: [ const Icon(Icons.group_work_outlined), const SizedBox(width: 12), Text(L10n.of(context).addToSpace), ], ), ), ], if (room.membership == Membership.invite) PopupMenuItem( value: ChatContextAction.block, child: Row( mainAxisSize: MainAxisSize.min, children: [ Icon( Icons.block_outlined, color: Theme.of(context).colorScheme.error, ), const SizedBox(width: 12), Text( L10n.of(context).block, style: TextStyle(color: Theme.of(context).colorScheme.error), ), ], ), ), PopupMenuItem( value: ChatContextAction.leave, child: Row( mainAxisSize: MainAxisSize.min, children: [ Icon( Icons.delete_outlined, color: Theme.of(context).colorScheme.onErrorContainer, ), const SizedBox(width: 12), Text( room.membership == Membership.invite ? L10n.of(context).delete : L10n.of(context).leave, style: TextStyle( color: Theme.of(context).colorScheme.onErrorContainer, ), ), ], ), ), ], ); if (action == null) return; if (!mounted) return; switch (action) { case ChatContextAction.open: onChatTap(room); return; case ChatContextAction.goToSpace: setActiveSpace(space!.id); return; case ChatContextAction.favorite: await showFutureLoadingDialog( context: context, future: () => room.setFavourite(!room.isFavourite), ); return; case ChatContextAction.markUnread: await showFutureLoadingDialog( context: context, future: () => room.markUnread(!room.markedUnread), ); return; case ChatContextAction.mute: await showFutureLoadingDialog( context: context, future: () => room.setPushRuleState( room.pushRuleState == PushRuleState.notify ? PushRuleState.mentionsOnly : PushRuleState.notify, ), ); return; case ChatContextAction.leave: final confirmed = await showOkCancelAlertDialog( useRootNavigator: false, context: context, title: L10n.of(context).areYouSure, message: L10n.of(context).archiveRoomDescription, okLabel: L10n.of(context).leave, cancelLabel: L10n.of(context).cancel, isDestructive: true, ); if (confirmed == OkCancelResult.cancel) return; if (!mounted) return; await showFutureLoadingDialog(context: context, future: room.leave); return; case ChatContextAction.addToSpace: final space = await showModalActionPopup( context: context, title: L10n.of(context).space, actions: spacesWithPowerLevels .map( (space) => AdaptiveModalAction( value: space, label: space .getLocalizedDisplayname(MatrixLocals(L10n.of(context))), ), ) .toList(), ); if (space == null) return; await showFutureLoadingDialog( context: context, future: () => space.setSpaceChild(room.id), ); case ChatContextAction.block: final userId = room.getState(EventTypes.RoomMember, room.client.userID!)?.senderId; context.go('/rooms/settings/security/ignorelist', extra: userId); } } 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, 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, ), ); } bool waitForFirstSync = false; Future _waitForFirstSync() async { final router = GoRouter.of(context); 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; }); if (client.userDeviceKeys[client.userID!]?.deviceKeys.values .any((device) => !device.verified && !device.blocked) ?? false) { late final ScaffoldFeatureController controller; final theme = Theme.of(context); controller = ScaffoldMessenger.of(context).showSnackBar( SnackBar( duration: const Duration(seconds: 15), showCloseIcon: true, backgroundColor: theme.colorScheme.errorContainer, closeIconColor: theme.colorScheme.onErrorContainer, content: Text( L10n.of(context).oneOfYourDevicesIsNotVerified, style: TextStyle( color: theme.colorScheme.onErrorContainer, ), ), action: SnackBarAction( onPressed: () { controller.close(); router.go('/rooms/settings/devices'); }, textColor: theme.colorScheme.onErrorContainer, label: L10n.of(context).settings, ), ), ); } } 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 showModalActionPopup( context: context, title: L10n.of(context).editBundlesForAccount, cancelLabel: L10n.of(context).cancel, actions: [ AdaptiveModalAction( value: EditBundleAction.addToBundle, label: L10n.of(context).addToBundle, ), if (activeBundle != client.userID) AdaptiveModalAction( value: 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, hintText: l10n.bundleName, ); if (bundle == null || bundle.isEmpty || bundle.isEmpty) return; await showFutureLoadingDialog( context: context, future: () => client.setAccountBundle(bundle), ); 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(context); } enum EditBundleAction { addToBundle, removeFromBundle } enum InviteActions { accept, decline, block, } enum ChatContextAction { open, goToSpace, favorite, markUnread, mute, leave, addToSpace, block }