1
0
Fork 0
forked from Nexus/nexus

Compare commits

..

No commits in common. "b93f4c979c2d0b40391218082e8ec22b96d24ae6" and "690d2549bc31e8fc25137bcacf49b103b641636a" have entirely different histories.

72 changed files with 836 additions and 2173 deletions

4
.gitmodules vendored
View file

@ -1,4 +1,4 @@
[submodule "gomuks"] [submodule "gomuks"]
path = gomuks path = gomuks
url = https://github.com/gomuks/gomuks url = https://github.com/zachatrocity/gomuks
branch = main branch = init-root-dir

View file

@ -2,11 +2,8 @@
"cSpell.words": [ "cSpell.words": [
"Appbar", "Appbar",
"Displayname", "Displayname",
"fluttertagger",
"Gomuks",
"Homeserver", "Homeserver",
"localpart", "prefs",
"muks", "vodozemac"
"prefs"
] ]
} }

View file

@ -1,7 +1,7 @@
# Nexus Client # Nexus Client
> [!WARNING] > [!WARNING]
> Nexus Client is still in development, and doesn't support everything needed for daily use. > Nexus Client is still heavily in development, and is not ready for use!
## Description ## Description
@ -21,9 +21,9 @@ A simple and user-friendly Matrix client made with Flutter and a Gomuks backend.
- [ ] Allow using remote Gomuks over websocket - [ ] Allow using remote Gomuks over websocket
- [ ] Platform Support - [ ] Platform Support
- [x] Linux - [x] Linux
- [ ] Windows (WIP) - [x] Windows
- [ ] MacOS - [ ] MacOS
- [x] Android - [ ] Android
- [ ] iOS - [ ] iOS
- [ ] Web (may not be possible) - [ ] Web (may not be possible)
- [x] Login - [x] Login
@ -37,7 +37,7 @@ A simple and user-friendly Matrix client made with Flutter and a Gomuks backend.
- [ ] Searching - [ ] Searching
- [ ] Creating (Rooms, Spaces, and DMs) - [ ] Creating (Rooms, Spaces, and DMs)
- [x] Joining - [x] Joining
- [x] Parse vias - [ ] Parse vias
- [x] Using a text/uri/link - [x] Using a text/uri/link
- [x] Plain text - [x] Plain text
- [x] `matrix:` Uri - [x] `matrix:` Uri
@ -63,11 +63,10 @@ A simple and user-friendly Matrix client made with Flutter and a Gomuks backend.
- [ ] Inline emoji picker (Putting this here since it'll be implemented the same way as mentions) - [ ] Inline emoji picker (Putting this here since it'll be implemented the same way as mentions)
- [ ] Custom emojis/stickers - [ ] Custom emojis/stickers
- [ ] GIFs using Gomuks' GIF proxies - [ ] GIFs using Gomuks' GIF proxies
- [x] Receiving - [x] Recieving
- [x] Plain text - [x] Plain text
- [x] Per message profiles - [x] Per message profiles
- [x] HTML - [x] HTML
- [x] URL Previews
- [x] Replies - [x] Replies
- [x] Viewing - [x] Viewing
- [ ] Jump to original message - [ ] Jump to original message
@ -80,34 +79,28 @@ A simple and user-friendly Matrix client made with Flutter and a Gomuks backend.
- [x] Blurhashing - [x] Blurhashing
- [ ] Downloading attachments - [ ] Downloading attachments
- [x] Opening attachments in their own view - [x] Opening attachments in their own view
- [ ] Polls - [ ] Polls: Waiting on https://github.com/SwanFlutter/dynamic_polls/issues/1
- [x] Mentions - [x] Mentions
- [x] Users - [x] Users
- [x] Clickable
- [x] Rooms - [x] Rooms
- [x] Clickable - [ ] Plain text (not sure if I want to add this or not, I probably won't unless there's interest)
- [x] Matrix URIs - [x] Matrix URIs
- [x] Matrix.to links - [x] Matrix.to links
- [x] Events - [ ] Do some fancy fetching to get nice names
- [ ] Render more nicely - [ ] Make clickable
- [ ] Clickable
- [x] Custom emojis/stickers - [x] Custom emojis/stickers
- [x] History loading - [x] History loading
- [x] Backwards - [x] Backwards
- [ ] Forwards - [ ] Forwards
- [x] Editing - [x] Editing
- [x] Deleting - [x] Deleting
- [x] Reactions - [ ] Reactions: Waiting on https://github.com/flyerhq/flutter_chat_ui/pull/838 or me doing a custom impl
- [ ] Pins - [ ] Pins
- [ ] Displaying - [ ] Displaying
- [ ] Creating - [ ] Creating
- [ ] Threads - [ ] Threads
- [x] Profile popouts - [ ] Profile popouts
- [x] Working actions - [ ] Copy link to [room, space]
- [x] Copy link to:
- [x] Room
- [x] Space
- [x] Message
- [ ] Reporting - [ ] Reporting
- [x] Events - [x] Events
- [ ] Rooms - [ ] Rooms
@ -115,7 +108,6 @@ A simple and user-friendly Matrix client made with Flutter and a Gomuks backend.
- [ ] Group calls using [MSC4195](https://github.com/matrix-org/matrix-spec-proposals/pull/4195) - [ ] Group calls using [MSC4195](https://github.com/matrix-org/matrix-spec-proposals/pull/4195)
- [ ] Invites - [ ] Invites
- [ ] Settings - [ ] Settings
- [ ] Matrix: URIs vs Matrix.to links
- [ ] Light/Dark mode - [ ] Light/Dark mode
- [ ] SSD or CSD - [ ] SSD or CSD
- [ ] Show media by default - [ ] Show media by default
@ -123,7 +115,7 @@ A simple and user-friendly Matrix client made with Flutter and a Gomuks backend.
- [ ] Devices - [ ] Devices
- [ ] Viewing devices - [ ] Viewing devices
- [ ] Verifying devices - [ ] Verifying devices
- [ ] URL preview: Server / Sending Client (Beeper spec) / None - [ ] URL preview: Server / Client / None
- [ ] Account changes - [ ] Account changes
- [ ] Display name - [ ] Display name
- [ ] Profile picture - [ ] Profile picture
@ -133,34 +125,7 @@ A simple and user-friendly Matrix client made with Flutter and a Gomuks backend.
- [ ] About - [ ] About
- [x] Log Out - [x] Log Out
## Try it out ## Build Instructions
If you want to try out Nexus, grab one of the following artifacts from CI:
- [Android APK](https://nightly.link/Henry-Hiles/nexus/workflows/android/main/APK.zip)
- Windows
- [Portable Build](https://nightly.link/Henry-Hiles/nexus/workflows/windows/main/windows-portable.zip)
- [Installer](https://nightly.link/Henry-Hiles/nexus/workflows/windows/main/windows-installer.zip)
- Flatpak
- [AArch64/Arm64](https://nightly.link/Henry-Hiles/nexus/workflows/flatpak/main/flatpak-aarch64.zip)
- [x86_64/AMD64](https://nightly.link/Henry-Hiles/nexus/workflows/flatpak/main/flatpak-x86_64.zip)
Or, try the Nix package: `nix run git+https://git.federated.nexus/Henry-Hiles/nexus`
## Build it yourself
### Prerequisites
#### Linux
- With Nix: Either use direnv and `direnv allow`, or `nix flake develop`
- Without Nix: Install Flutter, Go, Git, Libclang, and Glibc. Do not use any Snap packages, they cause various compilation issues.
#### Windows / MacOS
I don't really know. You will need Flutter, Git, Go, and Visual Studio tools, and otherwise I guess just keep installing stuff until there aren't any errors. I will look into this sometimeTM.
### Clone repo
First, clone and open the repo: First, clone and open the repo:
@ -169,6 +134,17 @@ git clone --recurse-submodules https://git.federated.nexus/Henry-Hiles/nexus
cd nexus cd nexus
``` ```
### Prerequisites
#### Linux
- With Nix: Either use direnv and `direnv allow`, or `nix flake develop`
- Without Nix: Install Flutter, Go, Olm, Git, Clang, and GLibc.
#### Windows / MacOS
I don't really know. You will need Flutter, Git, Go, and Visual Studio tools, and otherwise I guess just keep installing stuff until there aren't any errors. I will look into this sometimeTM.
### Set up Flutter ### Set up Flutter
Get dependencies: Get dependencies:
@ -180,7 +156,7 @@ flutter pub get
Generate Gomuks bindings: Generate Gomuks bindings:
```sh ```sh
dart scripts/generate.dart scripts/generate.sh
``` ```
Build generated files, and watch for new changes: Build generated files, and watch for new changes:

Binary file not shown.

Before

Width:  |  Height:  |  Size: 6.8 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 6.2 KiB

After

Width:  |  Height:  |  Size: 8.7 KiB

Before After
Before After

Binary file not shown.

Before

Width:  |  Height:  |  Size: 4 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 4.1 KiB

After

Width:  |  Height:  |  Size: 5.7 KiB

Before After
Before After

Binary file not shown.

Before

Width:  |  Height:  |  Size: 9.7 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 8.4 KiB

After

Width:  |  Height:  |  Size: 12 KiB

Before After
Before After

Binary file not shown.

Before

Width:  |  Height:  |  Size: 21 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 13 KiB

After

Width:  |  Height:  |  Size: 18 KiB

Before After
Before After

Binary file not shown.

Before

Width:  |  Height:  |  Size: 29 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 24 KiB

After

Width:  |  Height:  |  Size: 34 KiB

Before After
Before After

View file

@ -1,6 +1,6 @@
<?xml version="1.0" encoding="utf-8"?> <?xml version="1.0" encoding="utf-8"?>
<adaptive-icon xmlns:android="http://schemas.android.com/apk/res/android"> <adaptive-icon xmlns:android="http://schemas.android.com/apk/res/android">
<background android:drawable="@drawable/ic_launcher_background"/> <background android:drawable="@color/ic_launcher_background"/>
<foreground> <foreground>
<inset <inset
android:drawable="@drawable/ic_launcher_foreground" android:drawable="@drawable/ic_launcher_foreground"

Binary file not shown.

Before

Width:  |  Height:  |  Size: 13 KiB

Binary file not shown.

Before

Width:  |  Height:  |  Size: 14 KiB

View file

@ -1,126 +0,0 @@
<?xml version="1.0" encoding="UTF-8" standalone="no"?>
<!-- Created with Inkscape (http://www.inkscape.org/) -->
<svg
width="100mm"
height="100mm"
viewBox="0 0 100 100"
version="1.1"
id="svg1"
xml:space="preserve"
inkscape:version="1.4.3 (0d15f75042, 2025-12-25)"
sodipodi:docname="smallerForeground.svg"
xmlns:inkscape="http://www.inkscape.org/namespaces/inkscape"
xmlns:sodipodi="http://sodipodi.sourceforge.net/DTD/sodipodi-0.dtd"
xmlns="http://www.w3.org/2000/svg"
xmlns:svg="http://www.w3.org/2000/svg"><sodipodi:namedview
id="namedview1"
pagecolor="#505050"
bordercolor="#eeeeee"
borderopacity="1"
inkscape:showpageshadow="0"
inkscape:pageopacity="0"
inkscape:pagecheckerboard="0"
inkscape:deskcolor="#505050"
inkscape:document-units="mm"
inkscape:zoom="1.0847363"
inkscape:cx="58.078632"
inkscape:cy="213.41592"
inkscape:window-width="2544"
inkscape:window-height="1363"
inkscape:window-x="35"
inkscape:window-y="32"
inkscape:window-maximized="0"
inkscape:current-layer="layer1" /><defs
id="defs1" /><g
inkscape:label="Layer 1"
inkscape:groupmode="layer"
id="layer1"><path
style="fill:none;fill-opacity:1;stroke:#ffffff;stroke-width:5.41161;stroke-linecap:round;stroke-linejoin:round;stroke-dasharray:none"
d="M 29.285638,62.248476 70.927843,38.119963"
id="path10" /><path
style="fill:none;fill-opacity:1;stroke:#ffffff;stroke-width:5.41161;stroke-linecap:round;stroke-linejoin:round;stroke-dasharray:none"
d="M 29.060097,38.141229 70.741564,62.202356"
id="path9" /><path
style="fill:none;fill-opacity:1;stroke:#ffffff;stroke-width:5.41161;stroke-linecap:round;stroke-linejoin:round;stroke-dasharray:none"
d="M 50,74.064703 V 25.935297"
id="path8" /><circle
style="fill:none;stroke:#ffffff;stroke-width:4.81294;stroke-linecap:round;stroke-linejoin:round"
id="path1"
cx="50"
cy="50"
r="24.064703" /><circle
style="fill:#09bd05;fill-opacity:1;stroke:#ffffff;stroke-width:3.38226;stroke-linecap:round;stroke-linejoin:round;stroke-dasharray:none"
id="path2"
cx="50"
cy="73.408524"
r="5.5813141" /><circle
style="fill:#fe1e24;fill-opacity:1;stroke:#ffffff;stroke-width:3.38226;stroke-linecap:round;stroke-linejoin:round;stroke-dasharray:none"
id="circle2"
cx="50"
cy="26.59148"
r="5.5813141" /><circle
style="fill:#fe941d;fill-opacity:1;stroke:#ffffff;stroke-width:3.38226;stroke-linecap:round;stroke-linejoin:round;stroke-dasharray:none"
id="circle3"
cx="-68.30127"
cy="41.709789"
r="5.5813141"
transform="rotate(-120)" /><circle
style="fill:#001996;fill-opacity:1;stroke:#ffffff;stroke-width:3.38226;stroke-linecap:round;stroke-linejoin:round;stroke-dasharray:none"
id="circle4"
cx="-68.30127"
cy="-5.1072531"
r="5.5813141"
transform="rotate(-120)" /><circle
style="fill:#ffff04;fill-opacity:1;stroke:#ffffff;stroke-width:3.38226;stroke-linecap:round;stroke-linejoin:round;stroke-dasharray:none"
id="circle5"
cx="-18.301271"
cy="91.709793"
r="5.5813141"
transform="rotate(-60)" /><circle
style="fill:#770287;fill-opacity:1;stroke:#ffffff;stroke-width:3.38226;stroke-linecap:round;stroke-linejoin:round;stroke-dasharray:none"
id="circle6"
cx="-18.301271"
cy="44.89275"
r="5.5813141"
transform="rotate(-60)" /><circle
style="fill:none;fill-opacity:1;stroke:#ffffff;stroke-width:4.56605;stroke-linecap:round;stroke-linejoin:round;stroke-dasharray:none"
id="path7"
cx="50"
cy="50"
r="6.6237097" /><g
inkscape:label="Layer 1"
id="layer1-3"
transform="matrix(0.05578547,0,0,0.05578547,42.442929,42.442929)"
style="stroke:#ffffff"><text
xml:space="preserve"
style="font-style:normal;font-variant:normal;font-weight:900;font-stretch:normal;font-size:96.3615px;line-height:0;font-family:'Noto Serif';-inkscape-font-specification:'Noto Serif, Heavy';font-variant-ligatures:normal;font-variant-caps:normal;font-variant-numeric:normal;font-variant-east-asian:normal;text-align:end;text-anchor:end;fill:#ffffff;fill-opacity:1;stroke:#ffffff;stroke-width:0;stroke-dasharray:none;stroke-opacity:1"
x="-305.64749"
y="194.14493"
id="text2819"><tspan
sodipodi:role="line"
id="tspan2817"
style="stroke:#ffffff;stroke-width:0"
x="-305.64749"
y="194.14493" /></text><circle
style="fill:#354b5f;fill-opacity:1;stroke:#ffffff;stroke-width:0;stroke-dasharray:none;stroke-opacity:1"
id="path342"
cx="135.46666"
cy="135.46666"
r="135.46666" /><text
xml:space="preserve"
style="font-style:normal;font-variant:normal;font-weight:900;font-stretch:normal;font-size:96.3615px;line-height:0;font-family:'Noto Serif';-inkscape-font-specification:'Noto Serif, Heavy';font-variant-ligatures:normal;font-variant-caps:normal;font-variant-numeric:normal;font-variant-east-asian:normal;text-align:end;text-anchor:end;fill:#ffffff;fill-opacity:1;stroke:#ffffff;stroke-width:0;stroke-dasharray:none;stroke-opacity:1"
x="-305.64749"
y="194.14493"
id="text2819-3"><tspan
sodipodi:role="line"
id="tspan2817-5"
style="stroke:#ffffff;stroke-width:0"
x="-305.64749"
y="194.14493" /></text><g
aria-label=""
id="text2827-6"
style="font-size:132.452px;line-height:0;font-family:PowerlineSymbols;-inkscape-font-specification:'PowerlineSymbols, Normal';text-align:end;text-anchor:end;fill:#4e94e4;fill-opacity:1;stroke:#ffffff;stroke-width:0"><path
d="M 95.096912,209.8167 143.88912,135.46666 95.096912,61.116629 h 32.818568 l 47.92093,74.350031 -47.92093,74.35004 z"
id="path2883-2"
style="fill:#4e94e4;fill-opacity:1;stroke:#ffffff;stroke-width:0" /></g></g></g></svg>

Before

Width:  |  Height:  |  Size: 6 KiB

View file

@ -1,28 +1,31 @@
import "dart:async"; import "dart:async";
import "package:collection/collection.dart";
import "package:fast_immutable_collections/fast_immutable_collections.dart"; import "package:fast_immutable_collections/fast_immutable_collections.dart";
import "package:flutter_chat_core/flutter_chat_core.dart";
import "package:flutter_riverpod/flutter_riverpod.dart"; import "package:flutter_riverpod/flutter_riverpod.dart";
import "package:nexus/controllers/client_state_controller.dart"; import "package:nexus/controllers/client_state_controller.dart";
import "package:nexus/controllers/user_controller.dart"; import "package:nexus/controllers/members_controller.dart";
import "package:nexus/helpers/extensions/get_localpart.dart"; import "package:nexus/models/configs/author_config.dart";
import "package:nexus/models/membership.dart"; import "package:nexus/models/membership.dart";
import "package:nexus/models/membership_status.dart";
class AuthorController extends AsyncNotifier<Membership> { class AuthorController extends AsyncNotifier<Membership> {
final Message message; final AuthorConfig config;
AuthorController(this.message); AuthorController(this.config);
@override @override
Future<Membership> build() async { Future<Membership> build() async {
final member = await ref.watch( final member = await ref.watch(
UserController.provider(message.authorId).future, MembersController.provider(config.room).selectAsync(
(value) => value.firstWhereOrNull(
(membership) => membership.userId == config.message.authorId,
),
),
); );
final pmp = message.metadata?["pmp"] == null final pmp = config.message.metadata?["pmp"] == null
? null ? null
: Membership.fromContent( : Membership.fromContent(
IMap(message.metadata?["pmp"]), IMap(config.message.metadata?["pmp"]),
message.authorId, config.message.authorId,
ref.watch( ref.watch(
ClientStateController.provider.select( ClientStateController.provider.select(
(value) => value?.homeserverUrl, (value) => value?.homeserverUrl,
@ -32,16 +35,17 @@ class AuthorController extends AsyncNotifier<Membership> {
); );
return Membership( return Membership(
status: member?.status ?? MembershipStatus.leave,
avatarUrl: pmp?.avatarUrl ?? member?.avatarUrl, avatarUrl: pmp?.avatarUrl ?? member?.avatarUrl,
displayName: displayName:
pmp?.displayName ?? member?.displayName ?? message.authorId.localpart, pmp?.displayName ??
userId: message.authorId, member?.displayName ??
config.message.authorId.substring(1).split(":").first,
userId: config.message.authorId,
); );
} }
static final provider = static final provider = AsyncNotifierProvider.family
AsyncNotifierProvider.family<AuthorController, Membership, Message>( .autoDispose<AuthorController, Membership, AuthorConfig>(
AuthorController.new, AuthorController.new,
); );
} }

View file

@ -9,13 +9,11 @@ import "package:flutter/foundation.dart";
import "package:nexus/controllers/account_data_controller.dart"; import "package:nexus/controllers/account_data_controller.dart";
import "package:nexus/controllers/client_state_controller.dart"; import "package:nexus/controllers/client_state_controller.dart";
import "package:nexus/controllers/init_complete_controller.dart"; import "package:nexus/controllers/init_complete_controller.dart";
import "package:nexus/controllers/new_events_controller.dart";
import "package:nexus/controllers/rooms_controller.dart"; import "package:nexus/controllers/rooms_controller.dart";
import "package:nexus/controllers/space_edges_controller.dart"; import "package:nexus/controllers/space_edges_controller.dart";
import "package:nexus/controllers/sync_status_controller.dart"; import "package:nexus/controllers/sync_status_controller.dart";
import "package:nexus/controllers/top_level_spaces_controller.dart"; import "package:nexus/controllers/top_level_spaces_controller.dart";
import "package:nexus/helpers/extensions/gomuks_buffer.dart"; import "package:nexus/helpers/extensions/gomuks_buffer.dart";
import "package:nexus/main.dart";
import "package:nexus/models/client_state.dart"; import "package:nexus/models/client_state.dart";
import "package:nexus/models/event.dart"; import "package:nexus/models/event.dart";
import "package:nexus/models/paginate.dart"; import "package:nexus/models/paginate.dart";
@ -28,9 +26,7 @@ import "package:nexus/models/profile.dart";
import "package:nexus/models/requests/paginate_request.dart"; import "package:nexus/models/requests/paginate_request.dart";
import "package:nexus/models/requests/redact_event_request.dart"; import "package:nexus/models/requests/redact_event_request.dart";
import "package:nexus/models/requests/report_request.dart"; import "package:nexus/models/requests/report_request.dart";
import "package:nexus/models/requests/send_event_request.dart";
import "package:nexus/models/requests/send_message_request.dart"; import "package:nexus/models/requests/send_message_request.dart";
import "package:nexus/models/requests/set_membership_request.dart";
import "package:nexus/models/room.dart"; import "package:nexus/models/room.dart";
import "package:nexus/models/sync_data.dart"; import "package:nexus/models/sync_data.dart";
import "package:nexus/models/sync_status.dart"; import "package:nexus/models/sync_status.dart";
@ -78,17 +74,6 @@ class ClientController extends AsyncNotifier<int> {
case "init_complete": case "init_complete":
ref.watch(InitCompleteController.provider.notifier).complete(); ref.watch(InitCompleteController.provider.notifier).complete();
break; break;
case "send_complete":
final event = Event.fromJson(decodedMuksEvent["event"]);
if (event.type == "m.room.message") {
ref
.watch(
NewEventsController.provider(event.roomId).notifier,
)
.add(IList([event]));
}
break;
case "sync_complete": case "sync_complete":
final syncData = SyncData.fromJson(decodedMuksEvent); final syncData = SyncData.fromJson(decodedMuksEvent);
final roomProvider = RoomsController.provider; final roomProvider = RoomsController.provider;
@ -128,7 +113,6 @@ class ClientController extends AsyncNotifier<int> {
debugPrint("Finished handling $muksEventType..."); debugPrint("Finished handling $muksEventType...");
} catch (error, stackTrace) { } catch (error, stackTrace) {
debugger(); debugger();
showError(error, stackTrace);
debugPrintStack(stackTrace: stackTrace, label: error.toString()); debugPrintStack(stackTrace: stackTrace, label: error.toString());
} }
}); });
@ -166,11 +150,8 @@ class ClientController extends AsyncNotifier<int> {
Future<void> redactEvent(RedactEventRequest report) => Future<void> redactEvent(RedactEventRequest report) =>
_sendCommand("redact_event", report.toJson()); _sendCommand("redact_event", report.toJson());
Future<Event> sendMessage(SendMessageRequest request) async => Future<void> sendMessage(SendMessageRequest request) =>
Event.fromJson(await _sendCommand("send_message", request.toJson())); _sendCommand("send_message", request.toJson());
Future<Event> sendEvent(SendEventRequest request) async =>
Event.fromJson(await _sendCommand("send_event", request.toJson()));
Future<String?> verify(String recoveryKey) async { Future<String?> verify(String recoveryKey) async {
try { try {
@ -202,13 +183,9 @@ class ClientController extends AsyncNotifier<int> {
// })); // }));
Future<IList<Event>> getRoomState(GetRoomStateRequest request) async { Future<IList<Event>> getRoomState(GetRoomStateRequest request) async {
Future<List?> getState(GetRoomStateRequest request) async => final response =
(await _sendCommand("get_room_state", request.toJson())) as List?; (await _sendCommand("get_room_state", request.toJson())) as List;
final response = await getState(request); return response.map((event) => Event.fromJson(event)).toIList();
return (response ?? await getState(request.copyWith(refetch: true)) ?? [])
.map((event) => Event.fromJson(event))
.toIList();
} }
Future<IList<Event>?> getRelatedEvents( Future<IList<Event>?> getRelatedEvents(
@ -235,11 +212,8 @@ class ClientController extends AsyncNotifier<int> {
Future<Profile> getProfile(String userId) async => Future<Profile> getProfile(String userId) async =>
Profile.fromJson(await _sendCommand("get_profile", {"user_id": userId})); Profile.fromJson(await _sendCommand("get_profile", {"user_id": userId}));
Future<void> reportEvent(ReportRequest request) => Future<void> reportEvent(ReportRequest report) =>
_sendCommand("report_event", request.toJson()); _sendCommand("report_event", report.toJson());
Future<void> setMembership(SetMembershipRequest request) =>
_sendCommand("set_membership", request.toJson());
Future<void> markRead(Room room) async { Future<void> markRead(Room room) async {
final event = room.events.firstWhereOrNull( final event = room.events.firstWhereOrNull(
@ -266,7 +240,7 @@ class ClientController extends AsyncNotifier<int> {
Future<String?> discoverHomeserver(Uri homeserver) async { Future<String?> discoverHomeserver(Uri homeserver) async {
try { try {
final response = await _sendCommand("discover_homeserver", { final response = await _sendCommand("discover_homeserver", {
"user_id": "@fake-user:${homeserver.host}", "user_id": "@fakeuser:${homeserver.host}",
}); });
return response["m.homeserver"]?["base_url"]; return response["m.homeserver"]?["base_url"];
} catch (error) { } catch (error) {

View file

@ -1,25 +0,0 @@
import "package:fast_immutable_collections/fast_immutable_collections.dart";
import "package:flutter_riverpod/flutter_riverpod.dart";
import "package:nexus/controllers/members_controller.dart";
import "package:nexus/models/membership.dart";
import "package:nexus/models/membership_status.dart";
class MembersByTypeController extends AsyncNotifier<IList<Membership>> {
final MembershipStatus status;
MembersByTypeController(this.status);
@override
Future<IList<Membership>> build() => ref.watch(
MembersController.provider.selectAsync(
(members) =>
members.where((membership) => membership.status == status).toIList(),
),
);
static final provider =
AsyncNotifierProvider.family<
MembersByTypeController,
IList<Membership>,
MembershipStatus
>(MembersByTypeController.new);
}

View file

@ -2,34 +2,30 @@ import "package:fast_immutable_collections/fast_immutable_collections.dart";
import "package:flutter_riverpod/flutter_riverpod.dart"; import "package:flutter_riverpod/flutter_riverpod.dart";
import "package:nexus/controllers/client_controller.dart"; import "package:nexus/controllers/client_controller.dart";
import "package:nexus/controllers/client_state_controller.dart"; import "package:nexus/controllers/client_state_controller.dart";
import "package:nexus/controllers/selected_room_controller.dart";
import "package:nexus/models/membership.dart"; import "package:nexus/models/membership.dart";
import "package:nexus/models/requests/get_room_state_request.dart"; import "package:nexus/models/requests/get_room_state_request.dart";
import "package:nexus/models/room.dart";
class MembersController extends AsyncNotifier<IList<Membership>> { class MembersController extends AsyncNotifier<IList<Membership>> {
final Room room;
MembersController(this.room);
@override @override
Future<IList<Membership>> build() async { Future<IList<Membership>> build() async {
final data = ref.watch( if (room.metadata == null) return const IList.empty();
SelectedRoomController.provider.select(
(value) => value?.metadata == null
? null
: (value!.metadata!.id, value.metadata!.hasMemberList),
),
);
if (data == null) return const IList.empty();
final state = await ref final state = await ref
.watch(ClientController.provider.notifier) .watch(ClientController.provider.notifier)
.getRoomState( .getRoomState(
GetRoomStateRequest( GetRoomStateRequest(
roomId: data.$1, roomId: room.metadata!.id,
fetchMembers: data.$2 == false, fetchMembers: room.metadata!.hasMemberList == false,
includeMembers: true, includeMembers: true,
), ),
); );
return state.nonNulls return state.nonNulls
.where((state) => state.type == "m.room.member") .where((member) => member.content["membership"] == "join")
.map( .map(
(membership) => Membership.fromContent( (membership) => Membership.fromContent(
membership.content, membership.content,
@ -46,7 +42,7 @@ class MembersController extends AsyncNotifier<IList<Membership>> {
} }
static final provider = static final provider =
AsyncNotifierProvider<MembersController, IList<Membership>>( AsyncNotifierProvider.family<MembersController, IList<Membership>, Room>(
MembersController.new, MembersController.new,
); );
} }

View file

@ -1,12 +1,9 @@
import "package:collection/collection.dart"; import "package:collection/collection.dart";
import "package:fast_immutable_collections/fast_immutable_collections.dart";
import "package:flutter_chat_core/flutter_chat_core.dart"; import "package:flutter_chat_core/flutter_chat_core.dart";
import "package:flutter_riverpod/flutter_riverpod.dart"; import "package:flutter_riverpod/flutter_riverpod.dart";
import "package:nexus/controllers/client_controller.dart";
import "package:nexus/controllers/client_state_controller.dart"; import "package:nexus/controllers/client_state_controller.dart";
import "package:nexus/helpers/extensions/mxc_to_https.dart"; import "package:nexus/helpers/extensions/mxc_to_https.dart";
import "package:nexus/models/configs/message_config.dart"; import "package:nexus/models/configs/message_config.dart";
import "package:nexus/models/requests/get_related_events_request.dart";
class MessageController extends AsyncNotifier<Message?> { class MessageController extends AsyncNotifier<Message?> {
final MessageConfig config; final MessageConfig config;
@ -15,11 +12,11 @@ class MessageController extends AsyncNotifier<Message?> {
@override @override
Future<Message?> build() async { Future<Message?> build() async {
try { try {
final isEdit = config.event.relationType == "m.replace"; if (config.event.relationType == "m.replace" && !config.includeEdits) {
if ((isEdit && !config.includeEdits) || config.room.metadata == null) {
return null; return null;
} }
if (!ref.mounted) return null;
final event = config.event.lastEditRowId == null final event = config.event.lastEditRowId == null
? config.event ? config.event
: config.room.events.firstWhereOrNull( : config.room.events.firstWhereOrNull(
@ -27,11 +24,11 @@ class MessageController extends AsyncNotifier<Message?> {
) ?? ) ??
config.event; config.event;
final decrypted = (event.decrypted ?? event.content); if (!ref.mounted) return null;
final content = (event.decrypted ?? event.content);
final type = (config.event.decryptedType ?? config.event.type); final type = (config.event.decryptedType ?? config.event.type);
final content = decrypted["m.new_content"] == null final newContent = content["m.new_content"] as Map?;
? decrypted
: IMap(decrypted["m.new_content"]);
final homeserver = ref final homeserver = ref
.read(ClientStateController.provider) .read(ClientStateController.provider)
@ -42,19 +39,22 @@ class MessageController extends AsyncNotifier<Message?> {
final metadata = { final metadata = {
"body": config.event.redactedBy == null "body": config.event.redactedBy == null
? (content["body"] ?? "") ? (newContent?["body"] ?? content["body"] ?? "")
: "Deleted Message", : "Deleted Message",
"flashing": false, "flashing": false,
"timelineId": event.timelineRowId, "timelineId": event.timelineRowId,
"big": event.localContent?.bigEmoji == true, "big": event.localContent?.bigEmoji == true,
"eventType": type, "eventType": type,
"pmp": content["com.beeper.per_message_profile"], "pmp": event.content["com.beeper.per_message_profile"],
"error": event.sendError, "editSource":
"format": content["format"] ?? content["format"], event.localContent?.editSource ??
"editSource": event.localContent?.editSource ?? content["body"], newContent?["body"] ??
content["body"],
"txnId": config.event.transactionId, "txnId": config.event.transactionId,
}; };
if (!ref.mounted) return null;
final editedAt = event.relationType == "m.replace" final editedAt = event.relationType == "m.replace"
? event.timestamp ? event.timestamp
: null; : null;
@ -65,60 +65,32 @@ class MessageController extends AsyncNotifier<Message?> {
return null; return null;
} }
// TODO: Use server-generated preview if enabled
// final match = Uri.tryParse(
// RegExp(regexLink, caseSensitive: false).firstMatch(body)?.group(0) ?? "",
// );
final replyId = final replyId =
config.event.content["m.relates_to"]?["m.in_reply_to"]?["event_id"]; config.event.content["m.relates_to"]?["m.in_reply_to"]?["event_id"];
final reactionEvents = config.event.reactions.isEmpty && !isEdit
? null
: await ref
.watch(ClientController.provider.notifier)
.getRelatedEvents(
GetRelatedEventsRequest(
roomId: config.room.metadata!.id,
eventId:
(isEdit ? config.event.relatesTo : null) ??
config.event.eventId,
relationType: "m.annotation",
),
);
final reactions = reactionEvents
?.where((event) => event.redactedBy == null)
.fold<IMap<String, IList<String>>>(IMap(), (acc, event) {
final key = event.content["m.relates_to"]?["key"];
if (key == null) return acc;
return acc.update(
key,
(list) => list.add(event.authorId),
ifAbsent: () => IList([event.authorId]),
);
})
.map((key, value) => MapEntry(key, value.unlock))
.unlock;
final asText = final asText =
Message.text( Message.text(
metadata: metadata, metadata: metadata,
id: config.event.eventId, id: config.event.eventId,
reactions: reactions,
authorId: event.authorId, authorId: event.authorId,
text: content["formatted_body"] ?? content["body"] ?? "", text:
newContent?["formatted_body"] ??
newContent?["body"] ??
content["formatted_body"] ??
content["body"] ??
"",
replyToMessageId: replyId, replyToMessageId: replyId,
deliveredAt: config.event.timestamp, deliveredAt: config.event.timestamp,
editedAt: editedAt, editedAt: editedAt,
) )
as TextMessage; as TextMessage;
Message toSystemMessage(String content) => Message.system(
metadata: {...metadata, "body": content},
id: config.event.eventId,
reactions: reactions,
authorId: event.authorId,
deliveredAt: config.event.timestamp,
text: content,
);
return switch (type) { return switch (type) {
"m.room.encrypted" => asText.copyWith( "m.room.encrypted" => asText.copyWith(
text: "Unable to decrypt message.", text: "Unable to decrypt message.",
@ -138,7 +110,6 @@ class MessageController extends AsyncNotifier<Message?> {
null || "m.image" => Message.image( null || "m.image" => Message.image(
id: config.event.eventId, id: config.event.eventId,
authorId: event.authorId, authorId: event.authorId,
reactions: reactions,
source: source, source: source,
replyToMessageId: replyId, replyToMessageId: replyId,
metadata: metadata, metadata: metadata,
@ -151,7 +122,6 @@ class MessageController extends AsyncNotifier<Message?> {
size: content["info"]["size"], size: content["info"]["size"],
metadata: metadata, metadata: metadata,
id: config.event.eventId, id: config.event.eventId,
reactions: reactions,
authorId: event.authorId, authorId: event.authorId,
source: source, source: source,
replyToMessageId: replyId, replyToMessageId: replyId,
@ -162,21 +132,33 @@ class MessageController extends AsyncNotifier<Message?> {
"m.room.member" => "m.room.member" =>
content["membership"] == event.unsigned["prev_content"]?["membership"] content["membership"] == event.unsigned["prev_content"]?["membership"]
? null ? null
: toSystemMessage( : Message.system(
"${content["displayname"] ?? event.stateKey} ${switch (content["membership"]) { metadata: {
"invite" => "was invited to", ...metadata,
"join" => "joined", "body":
"leave" => event.authorId == event.stateKey ? "left" : (event.unsigned["prev_content"]?["membership"] == "ban" ? "was unbanned from" : "was kicked from"), "${content["displayname"] ?? event.stateKey} ${switch (content["membership"]) {
"ban" => "was banned from", "invite" => "was invited to",
"knock" => "asked to join", "join" => "joined",
_ => "did something relating to", "leave" => "left",
}} the room. ${content["reason"] ?? ""}", "knock" => "asked to join",
"ban" => "was banned from",
_ => "did something relating to",
}} the room.",
},
id: config.event.eventId,
authorId: event.authorId,
deliveredAt: config.event.timestamp,
text:
"${content["displayname"] ?? event.stateKey} ${switch (content["membership"]) {
"invite" => "was invited to",
"join" => "joined",
"leave" => "left",
"knock" => "asked to join",
"ban" => "was banned from",
_ => "did something relating to",
}} the room.",
), ),
"m.room.server_acl" => toSystemMessage(
"${event.authorId} updated the server ban list.",
),
"m.room.redaction" => "m.room.redaction" =>
config.alwaysReturn config.alwaysReturn
? asText.copyWith( ? asText.copyWith(
@ -195,7 +177,6 @@ class MessageController extends AsyncNotifier<Message?> {
// ignore: dead_code // ignore: dead_code
? Message.unsupported( ? Message.unsupported(
metadata: metadata, metadata: metadata,
reactions: reactions,
id: config.event.eventId, id: config.event.eventId,
authorId: event.authorId, authorId: event.authorId,
replyToMessageId: replyId, replyToMessageId: replyId,

View file

@ -1,70 +0,0 @@
import "package:collection/collection.dart";
import "package:flutter_riverpod/flutter_riverpod.dart";
import "package:nexus/controllers/client_state_controller.dart";
import "package:nexus/controllers/selected_room_controller.dart";
import "package:nexus/models/configs/power_level_config.dart";
import "package:nexus/models/requests/membership_action.dart";
class PowerLevelController extends Notifier<bool> {
final PowerLevelConfig config;
PowerLevelController(this.config);
@override
bool build() {
final room = ref.watch(SelectedRoomController.provider);
final event = room?.events.firstWhereOrNull(
(event) => event.rowId == room.state["m.room.power_levels"]?[""],
);
final user = ref.watch(ClientStateController.provider)?.userId;
if (event == null || user == null) return false;
final users = (event.content["users"] as Map<String, dynamic>? ?? {});
final events = (event.content["events"] as Map<String, dynamic>? ?? {});
int powerLevelOf(String userId) => users.containsKey(userId)
? (users[userId] as int)
: (event.content["users_default"] as int? ?? 0);
final userLevel = powerLevelOf(user);
final targetLevel = config.targetUser != null
? powerLevelOf(config.targetUser!)
: null;
if (config.action != null) {
return switch (config.action!) {
MembershipAction.invite =>
userLevel >= (event.content["invite"] as int? ?? 0),
MembershipAction.kick =>
targetLevel != null &&
userLevel >= (event.content["kick"] as int? ?? 50) &&
userLevel > targetLevel,
MembershipAction.ban =>
targetLevel != null &&
userLevel >= (event.content["ban"] as int? ?? 50) &&
userLevel > targetLevel,
MembershipAction.unban =>
userLevel >= (event.content["ban"] as int? ?? 50),
};
}
if (config.eventType == "m.room.redaction") {
return userLevel >= (event.content["redact"] as int? ?? 50);
}
final requiredLevel = events.containsKey(config.eventType)
? (events[config.eventType] as int)
: (config.isStateEvent
? (event.content["state_default"] as int? ?? 50)
: (event.content["events_default"] as int? ?? 0));
return userLevel >= requiredLevel;
}
static final provider = NotifierProvider.autoDispose
.family<PowerLevelController, bool, PowerLevelConfig>(
PowerLevelController.new,
);
}

View file

@ -1,17 +0,0 @@
import "package:flutter_riverpod/flutter_riverpod.dart";
import "package:nexus/controllers/client_controller.dart";
import "package:nexus/models/profile.dart";
class ProfileController extends AsyncNotifier<Profile> {
final String userId;
ProfileController(this.userId);
@override
Future<Profile> build() {
final client = ref.watch(ClientController.provider.notifier);
return client.getProfile(userId);
}
static final provider = AsyncNotifierProvider.autoDispose
.family<ProfileController, Profile, String>(ProfileController.new);
}

View file

@ -2,6 +2,7 @@ import "dart:async";
import "package:collection/collection.dart"; import "package:collection/collection.dart";
import "package:fast_immutable_collections/fast_immutable_collections.dart"; import "package:fast_immutable_collections/fast_immutable_collections.dart";
import "package:flutter_chat_core/flutter_chat_core.dart"; import "package:flutter_chat_core/flutter_chat_core.dart";
import "package:flutter_chat_core/flutter_chat_core.dart" as chat;
import "package:flutter_riverpod/flutter_riverpod.dart"; import "package:flutter_riverpod/flutter_riverpod.dart";
import "package:fluttertagger/fluttertagger.dart"; import "package:fluttertagger/fluttertagger.dart";
import "package:nexus/controllers/client_controller.dart"; import "package:nexus/controllers/client_controller.dart";
@ -9,15 +10,12 @@ import "package:nexus/controllers/message_controller.dart";
import "package:nexus/controllers/messages_controller.dart"; import "package:nexus/controllers/messages_controller.dart";
import "package:nexus/controllers/new_events_controller.dart"; import "package:nexus/controllers/new_events_controller.dart";
import "package:nexus/controllers/rooms_controller.dart"; import "package:nexus/controllers/rooms_controller.dart";
import "package:nexus/controllers/selected_room_controller.dart";
import "package:nexus/models/configs/messages_config.dart"; import "package:nexus/models/configs/messages_config.dart";
import "package:nexus/models/configs/message_config.dart"; import "package:nexus/models/configs/message_config.dart";
import "package:nexus/models/requests/get_related_events_request.dart";
import "package:nexus/models/requests/get_room_state_request.dart"; import "package:nexus/models/requests/get_room_state_request.dart";
import "package:nexus/models/requests/paginate_request.dart"; import "package:nexus/models/requests/paginate_request.dart";
import "package:nexus/models/requests/redact_event_request.dart"; import "package:nexus/models/requests/redact_event_request.dart";
import "package:nexus/models/relation_type.dart"; import "package:nexus/models/relation_type.dart";
import "package:nexus/models/requests/send_event_request.dart";
import "package:nexus/models/requests/send_message_request.dart"; import "package:nexus/models/requests/send_message_request.dart";
import "package:nexus/models/room.dart"; import "package:nexus/models/room.dart";
@ -30,6 +28,7 @@ class RoomChatController extends AsyncNotifier<InMemoryChatController> {
final client = ref.watch(ClientController.provider.notifier); final client = ref.watch(ClientController.provider.notifier);
var room = ref.read(RoomsController.provider)[roomId]; var room = ref.read(RoomsController.provider)[roomId];
if (room == null) return InMemoryChatController(); if (room == null) return InMemoryChatController();
final state = await client.getRoomState( final state = await client.getRoomState(
GetRoomStateRequest(roomId: roomId), GetRoomStateRequest(roomId: roomId),
); );
@ -79,68 +78,16 @@ class RoomChatController extends AsyncNotifier<InMemoryChatController> {
ref.onDispose( ref.onDispose(
ref.listen(NewEventsController.provider(roomId), (_, next) async { ref.listen(NewEventsController.provider(roomId), (_, next) async {
final controller = await future;
for (final event in next) { for (final event in next) {
if (event.type == "m.reaction") {
final message = controller.messages.firstWhereOrNull(
(message) =>
message.id == event.content["m.relates_to"]?["event_id"],
);
final key = event.content["m.relates_to"]?["key"];
if (message == null || key == null || !ref.mounted) return;
return await controller.updateMessage(
message,
message.copyWith(
reactions: IMap(message.reactions)
.update(
key,
(reactors) => [...reactors, event.authorId],
ifAbsent: () => [event.authorId],
)
.unlock,
),
);
}
if (event.type == "m.room.redaction") { if (event.type == "m.room.redaction") {
final controller = await future; final controller = await future;
final redactsId = event.content["redacts"]; final message = controller.messages.firstWhereOrNull(
final originalMessage = controller.messages.firstWhereOrNull( (message) => message.id == event.content["redacts"],
(message) => message.id == redactsId,
); );
if (!ref.mounted) return; if (message == null || !ref.mounted) return;
if (originalMessage != null) { await controller.removeMessage(message);
return await controller.removeMessage(originalMessage);
}
final redacts = ref
.read(SelectedRoomController.provider)
?.events
.firstWhere((event) => event.eventId == redactsId);
if (redacts?.type == "m.reaction") {
final message = controller.messages.firstWhereOrNull(
(message) =>
message.id == redacts!.content["m.relates_to"]?["event_id"],
);
final key = redacts!.content["m.relates_to"]?["key"];
if (message == null || key == null || !ref.mounted) return;
return await controller.updateMessage(
message,
message.copyWith(
reactions: IMap(message.reactions)
.update(
key,
(reactors) =>
IList(reactors).remove(redacts.authorId).unlock,
)
.where((_, value) => value.isNotEmpty)
.unlock,
),
);
}
} else { } else {
final message = await ref.watch( final message = await ref.watch(
MessageController.provider( MessageController.provider(
@ -169,8 +116,12 @@ class RoomChatController extends AsyncNotifier<InMemoryChatController> {
), ),
); );
} }
if (message != null && ref.mounted) { if (message != null &&
await insertMessage(message); !controller.messages.any(
(oldMessage) => oldMessage.id == message.id,
) &&
ref.mounted) {
await controller.insertMessage(message);
} }
} }
} }
@ -179,9 +130,9 @@ class RoomChatController extends AsyncNotifier<InMemoryChatController> {
ref.onDispose(controller.dispose); ref.onDispose(controller.dispose);
// While there are under 20 messages, try up to load more messages until theres no more or we have 20 messages. // While there are under 20 messages, try up to two times to load more messages.
for (var more = true; more == true && controller.messages.length < 20;) { for (var i = 0; i < 2 && messages.length < 20; i++) {
more = await loadOlder(controller); await loadOlder(controller);
} }
return controller; return controller;
@ -201,13 +152,21 @@ class RoomChatController extends AsyncNotifier<InMemoryChatController> {
: controller.updateMessage(oldMessage, message); : controller.updateMessage(oldMessage, message);
} }
Future<void> deleteMessage(Message message, {String? reason}) => ref Future<void> deleteMessage(Message message, {String? reason}) async {
.watch(ClientController.provider.notifier) final controller = await future;
.redactEvent( await controller.removeMessage(message);
RedactEventRequest(eventId: message.id, roomId: roomId, reason: reason), await ref
); .watch(ClientController.provider.notifier)
.redactEvent(
RedactEventRequest(
eventId: message.id,
roomId: roomId,
reason: reason,
),
);
}
Future<bool> loadOlder([InMemoryChatController? chatController]) async { Future<void> loadOlder([InMemoryChatController? chatController]) async {
final response = await ref final response = await ref
.watch(ClientController.provider.notifier) .watch(ClientController.provider.notifier)
.paginate( .paginate(
@ -239,40 +198,38 @@ class RoomChatController extends AsyncNotifier<InMemoryChatController> {
), ),
}), }),
const ISet.empty(), const ISet.empty(),
addToNewEvents: false,
); );
final room = ref.read(RoomsController.provider)[roomId]; final room = ref.read(RoomsController.provider)[roomId];
if (room != null) { if (room == null) return;
final messages = await ref.watch(
MessagesController.provider(
MessagesConfig(room: room, events: response.events.reversed),
).future,
);
final controller = chatController ?? await future; final messages = await ref.watch(
await controller.insertAllMessages( MessagesController.provider(
messages MessagesConfig(room: room, events: response.events.reversed),
.where( ).future,
(newMessage) => !controller.messages.any( );
(message) => message.id == newMessage.id,
), final controller = chatController ?? await future;
) await controller.insertAllMessages(
.toList(), messages
index: 0, .where(
); (newMessage) => !controller.messages.any(
} (message) => message.id == newMessage.id,
return response.hasMore; ),
)
.toList(),
index: 0,
);
} }
Future<void> send( Future<void> send(
String text, { String message, {
bool shouldMention = true, bool shouldMention = true,
required IList<Tag> tags, required Iterable<Tag> tags,
required RelationType relationType, required RelationType relationType,
Message? relation, Message? relation,
}) async { }) async {
var taggedMessage = text; var taggedMessage = message;
for (final tag in tags) { for (final tag in tags) {
final escaped = RegExp.escape(tag.id); final escaped = RegExp.escape(tag.id);
@ -285,8 +242,7 @@ class RoomChatController extends AsyncNotifier<InMemoryChatController> {
} }
final client = ref.watch(ClientController.provider.notifier); final client = ref.watch(ClientController.provider.notifier);
final room = ref.read(RoomsController.provider)[roomId]; client.sendMessage(
final event = await client.sendMessage(
SendMessageRequest( SendMessageRequest(
roomId: roomId, roomId: roomId,
mentions: Mentions( mentions: Mentions(
@ -304,15 +260,21 @@ class RoomChatController extends AsyncNotifier<InMemoryChatController> {
: Relation(eventId: relation.id, relationType: relationType), : Relation(eventId: relation.id, relationType: relationType),
), ),
); );
final message = room == null }
? null
: await ref.watch(
MessageController.provider(
MessageConfig(room: room, event: event),
).future,
);
if (message != null) insertMessage(message); Future<chat.User> resolveUser(String id) async {
final user = await ref
.watch(ClientController.provider.notifier)
.getProfile(id);
return chat.User(
id: id,
name: user.displayName,
// imageSource: user.avatarUrl == null
// ? null
// : (await ref.watch(
// AvatarController.provider(user.avatarUrl!.toString()).future,
// )).toString(),
);
} }
Future<void> scrollToMessage(Message message) async { Future<void> scrollToMessage(Message message) async {
@ -330,59 +292,6 @@ class RoomChatController extends AsyncNotifier<InMemoryChatController> {
return await controller.scrollToMessage(message.id); return await controller.scrollToMessage(message.id);
} }
Future<void> removeReaction(
String reaction,
Message message,
String userId,
) async {
final client = ref.watch(ClientController.provider.notifier);
final allReactionEvents = await client.getRelatedEvents(
GetRelatedEventsRequest(
roomId: roomId,
eventId: message.id,
relationType: "m.annotation",
),
);
final reactionEvents = allReactionEvents
?.where((event) => event.redactedBy == null)
.toIList();
final reactionEvent = reactionEvents?.firstWhereOrNull(
(event) =>
event.authorId == userId &&
event.content["m.relates_to"]?["key"] == reaction,
);
if (reactionEvent != null) {
await ref
.watch(ClientController.provider.notifier)
.redactEvent(
RedactEventRequest(eventId: reactionEvent.eventId, roomId: roomId),
);
}
}
Future<void> sendReaction(String reaction, Message message) async {
final client = ref.watch(ClientController.provider.notifier);
await client.sendEvent(
SendEventRequest(
roomId: roomId,
type: "m.reaction",
content: {
"m.relates_to": {
"event_id": message.id,
"rel_type": "m.annotation",
"key": reaction,
},
},
synchronous: true,
disableEncryption: true,
),
);
}
static final provider = AsyncNotifierProvider.family static final provider = AsyncNotifierProvider.family
.autoDispose<RoomChatController, InMemoryChatController, String>( .autoDispose<RoomChatController, InMemoryChatController, String>(
RoomChatController.new, RoomChatController.new,

View file

@ -11,11 +11,7 @@ class RoomsController extends Notifier<IMap<String, Room>> {
@override @override
IMap<String, Room> build() => const IMap.empty(); IMap<String, Room> build() => const IMap.empty();
void update( void update(IMap<String, Room> rooms, ISet<String> leftRooms) {
IMap<String, Room> rooms,
ISet<String> leftRooms, {
bool addToNewEvents = true,
}) {
final homeserver = final homeserver =
ref.watch( ref.watch(
ClientStateController.provider.select( ClientStateController.provider.select(
@ -33,20 +29,18 @@ class RoomsController extends Notifier<IMap<String, Room>> {
(item) => item.eventId, (item) => item.eventId,
); );
if (addToNewEvents) { ref
ref .watch(NewEventsController.provider(roomId).notifier)
.watch(NewEventsController.provider(roomId).notifier) .add(
.add( incoming.timeline
incoming.timeline .map(
.map( (timelineTuple) => events?.firstWhereOrNull(
(timelineTuple) => events?.firstWhereOrNull( (event) => timelineTuple.eventRowId == event.rowId,
(event) => timelineTuple.eventRowId == event.rowId, ),
), )
) .nonNulls
.nonNulls .toIList(),
.toIList(), );
);
}
return acc.add( return acc.add(
roomId, roomId,

View file

@ -1,17 +1,11 @@
import "package:flutter_riverpod/flutter_riverpod.dart"; import "package:flutter_riverpod/flutter_riverpod.dart";
import "package:nexus/main.dart";
import "package:nexus/models/sync_status.dart"; import "package:nexus/models/sync_status.dart";
class SyncStatusController extends Notifier<SyncStatus?> { class SyncStatusController extends Notifier<SyncStatus?> {
@override @override
Null build() => null; Null build() => null;
void set(SyncStatus newStatus) { void set(SyncStatus newStatus) => state = newStatus;
if (newStatus.type == SyncStatusType.permanentlyFailed) {
showError(newStatus.error ?? "Syncing failed");
}
state = newStatus;
}
static final provider = NotifierProvider<SyncStatusController, SyncStatus?>( static final provider = NotifierProvider<SyncStatusController, SyncStatus?>(
SyncStatusController.new, SyncStatusController.new,

View file

@ -1,60 +0,0 @@
import "dart:convert";
import "package:flutter_chat_core/flutter_chat_core.dart";
import "package:flutter_riverpod/flutter_riverpod.dart";
import "package:http/http.dart";
import "package:nexus/controllers/client_state_controller.dart";
import "package:nexus/controllers/header_controller.dart";
import "package:nexus/helpers/extensions/mxc_to_https.dart";
class UrlPreviewController extends AsyncNotifier<LinkPreviewData?> {
final String link;
UrlPreviewController(this.link);
@override
Future<LinkPreviewData?> build() async {
final homeserver = ref.watch(ClientStateController.provider)?.homeserverUrl;
if (homeserver != null && !link.contains("matrix.to")) {
{
final response = await get(
Uri.parse(homeserver)
.resolve("/_matrix/client/v1/media/preview_url")
.replace(queryParameters: {"url": link}),
headers: await ref.watch(HeaderController.provider.future),
);
if (response.statusCode == 200) {
final decodedValue = json.decode(response.body);
final mxc = decodedValue["og:image"];
final image = mxc == null
? null
: Uri.tryParse(mxc)?.mxcToHttps(homeserver);
return LinkPreviewData(
link: link,
title: decodedValue["og:title"],
description: decodedValue["og:description"],
image: image == null
? null
: ImagePreviewData(
url: image.toString(),
width:
(decodedValue["og:image:width"] as int?)?.toDouble() ??
0,
height:
(decodedValue["og:image:height"] as int?)?.toDouble() ??
0,
),
);
}
}
}
return null;
}
static final provider = AsyncNotifierProvider.autoDispose
.family<UrlPreviewController, LinkPreviewData?, String>(
UrlPreviewController.new,
);
}

View file

@ -1,40 +0,0 @@
import "dart:async";
import "package:collection/collection.dart";
import "package:flutter_riverpod/flutter_riverpod.dart";
import "package:nexus/controllers/members_controller.dart";
import "package:nexus/controllers/profile_controller.dart";
import "package:nexus/helpers/extensions/get_localpart.dart";
import "package:nexus/models/membership.dart";
import "package:nexus/models/membership_status.dart";
class UserController extends AsyncNotifier<Membership?> {
final String userId;
UserController(this.userId);
@override
Future<Membership?> build() async {
final member = await ref.watch(
MembersController.provider.selectAsync(
(value) =>
value.firstWhereOrNull((membership) => membership.userId == userId),
),
);
if (member != null) return member;
final profile = await ref.watch(ProfileController.provider(userId).future);
return Membership(
status: MembershipStatus.leave,
avatarUrl: profile.avatarUrl == null
? null
: Uri.tryParse(profile.avatarUrl!),
displayName: profile.displayName ?? userId.localpart,
userId: userId,
);
}
static final provider =
AsyncNotifierProvider.family<UserController, Membership?, String>(
UserController.new,
);
}

View file

@ -1,54 +0,0 @@
import "package:collection/collection.dart";
import "package:fast_immutable_collections/fast_immutable_collections.dart";
import "package:flutter_riverpod/flutter_riverpod.dart";
import "package:nexus/controllers/client_state_controller.dart";
import "package:nexus/models/room.dart";
class ViaController extends Notifier<String> {
final Room room;
ViaController(this.room);
@override
String build() {
final servers = <String>{};
void addUserId(String? userId) {
final server = userId?.split(":").lastOrNull;
if (server != null) {
servers.add(server);
}
}
addUserId(ref.watch(ClientStateController.provider)?.userId);
final powerLevels = room.events.firstWhereOrNull(
(event) => event.rowId == room.state["m.room.power_levels"]?[""],
);
for (final userId in IMap(powerLevels?.content["users"]).keys) {
addUserId(userId);
if (servers.length >= 5) break;
}
final members = room.state["m.room.member"]?.values.toIList();
for (var i = 0; servers.length < 5; i++) {
final member = room.events.firstWhereOrNull(
(event) => event.rowId == members?.getOrNull(i),
);
if (member?.content["membership"] == "join") {
addUserId(member?.stateKey);
}
if (members?.getOrNull(i) == null) break;
}
return servers.isEmpty
? ""
: "?${servers.map((server) => "via=$server").join("&")}";
}
static final provider = NotifierProvider.family<ViaController, String, Room>(
ViaController.new,
);
}

View file

@ -1,3 +0,0 @@
extension GetLocalpart on String {
String get localpart => substring(1).split(":").first;
}

View file

@ -0,0 +1,91 @@
import "package:collection/collection.dart";
import "package:fast_immutable_collections/fast_immutable_collections.dart";
import "package:flutter/material.dart";
import "package:hooks_riverpod/hooks_riverpod.dart";
import "package:nexus/controllers/client_controller.dart";
import "package:nexus/controllers/key_controller.dart";
import "package:nexus/controllers/spaces_controller.dart";
import "package:nexus/helpers/extensions/link_to_mention.dart";
import "package:nexus/models/requests/join_room_request.dart";
extension JoinRoomWithSnackbars on ClientController {
Future<void> joinRoomWithSnackBars(
BuildContext context,
String roomAlias,
WidgetRef ref,
) async {
final roomIdOrAlias = roomAlias.mention ?? roomAlias;
// TODO: Parse vias properly
final scaffoldMessenger = ScaffoldMessenger.of(context);
final snackbar = scaffoldMessenger.showSnackBar(
SnackBar(
content: Text("Joining room $roomIdOrAlias."),
duration: Duration(days: 999),
),
);
try {
final id = await joinRoom(
JoinRoomRequest(
roomIdOrAlias: roomIdOrAlias,
via: IList(Uri.tryParse(roomAlias)?.queryParametersAll["via"] ?? []),
),
);
snackbar.close();
scaffoldMessenger.showSnackBar(
SnackBar(
content: Text("Room $roomIdOrAlias successfully joined."),
action: SnackBarAction(
label: "Open",
onPressed: () async {
final spaces = ref.watch(SpacesController.provider);
final space = spaces.firstWhereOrNull((space) => space.id == id);
await ref
.watch(
KeyController.provider(KeyController.spaceKey).notifier,
)
.set(
space?.id ??
spaces
.firstWhere(
(space) => space.children.any(
(child) => child.metadata?.id == id,
),
)
.id,
);
if (space == null) {
await ref
.watch(
KeyController.provider(KeyController.roomKey).notifier,
)
.set(id);
}
},
),
),
);
} catch (error) {
snackbar.close();
if (context.mounted) {
scaffoldMessenger.showSnackBar(
SnackBar(
backgroundColor: Theme.of(context).colorScheme.errorContainer,
content: Text(
error.toString(),
style: TextStyle(
color: Theme.of(context).colorScheme.onErrorContainer,
),
),
),
);
}
}
}
}

View file

@ -30,8 +30,7 @@ extension LinkToMention on String {
final identifier = uri.pathSegments.last; final identifier = uri.pathSegments.last;
if (identifier.isNotEmpty) { if (identifier.isNotEmpty) {
return "${switch (uri.pathSegments.firstOrNull) { return "${switch (uri.pathSegments.firstOrNull) {
"r" => "#", "r" || "roomid" => "#",
"roomid" => "!",
"u" => "@", "u" => "@",
_ => "", _ => "",
}}${Uri.decodeComponent(identifier)}"; }}${Uri.decodeComponent(identifier)}";

View file

@ -7,13 +7,8 @@ extension SchemeToTheme on ColorScheme {
titleSpacing: 0, titleSpacing: 0,
backgroundColor: surfaceContainerLow, backgroundColor: surfaceContainerLow,
), ),
menuTheme: MenuThemeData(
style: MenuStyle(
backgroundColor: WidgetStatePropertyAll(primaryContainer),
),
),
textTheme: ThemeData( textTheme: ThemeData(
fontFamilyFallback: ["sans", "emoji"], fontFamilyFallback: ["sans"],
brightness: brightness, brightness: brightness,
).textTheme, ).textTheme,
inputDecorationTheme: const InputDecorationTheme( inputDecorationTheme: const InputDecorationTheme(

View file

@ -9,7 +9,6 @@ extension ShowContextMenu on BuildContext {
showMenu( showMenu(
context: this, context: this,
constraints: BoxConstraints.loose(Size.infinite),
position: RelativeRect.fromLTRB( position: RelativeRect.fromLTRB(
globalPosition.dx, globalPosition.dx,
globalPosition.dy, globalPosition.dy,

View file

@ -1,18 +0,0 @@
import "package:flutter/material.dart";
import "package:nexus/helpers/extensions/show_context_menu.dart";
import "package:nexus/models/membership.dart";
import "package:nexus/widgets/chat_page/user_popover.dart";
extension ShowUserPopover on BuildContext {
void showUserPopover(Membership member, {required Offset globalPosition}) =>
showContextMenu(
globalPosition: globalPosition,
children: [
PopupMenuItem(
enabled: false,
padding: EdgeInsets.symmetric(horizontal: 16, vertical: 8),
child: IconTheme(data: IconThemeData(), child: UserPopover(member)),
),
],
);
}

View file

@ -5,6 +5,7 @@ import "package:flutter_riverpod/flutter_riverpod.dart";
import "package:nexus/controllers/client_controller.dart"; import "package:nexus/controllers/client_controller.dart";
import "package:nexus/controllers/client_state_controller.dart"; import "package:nexus/controllers/client_state_controller.dart";
import "package:nexus/controllers/header_controller.dart"; import "package:nexus/controllers/header_controller.dart";
import "package:nexus/controllers/init_complete_controller.dart";
import "package:nexus/controllers/multi_provider_controller.dart"; import "package:nexus/controllers/multi_provider_controller.dart";
import "package:nexus/controllers/shared_prefs_controller.dart"; import "package:nexus/controllers/shared_prefs_controller.dart";
import "package:nexus/helpers/extensions/better_when.dart"; import "package:nexus/helpers/extensions/better_when.dart";
@ -126,7 +127,9 @@ class App extends StatelessWidget {
} else if (!clientState.isVerified) { } else if (!clientState.isVerified) {
return VerifyPage(); return VerifyPage();
} else { } else {
return ChatPage(); return ref.watch(InitCompleteController.provider)
? ChatPage()
: Loading();
} }
}, },
), ),

View file

@ -0,0 +1,14 @@
import "package:flutter_chat_core/flutter_chat_core.dart";
import "package:freezed_annotation/freezed_annotation.dart";
import "package:nexus/models/room.dart";
part "author_config.freezed.dart";
part "author_config.g.dart";
@freezed
abstract class AuthorConfig with _$AuthorConfig {
const factory AuthorConfig({required Message message, required Room room}) =
_AuthorConfig;
factory AuthorConfig.fromJson(Map<String, Object?> json) =>
_$AuthorConfigFromJson(json);
}

View file

@ -18,10 +18,10 @@ abstract class MessageConfig with _$MessageConfig {
bool operator ==(Object other) => bool operator ==(Object other) =>
other.runtimeType == runtimeType && other.runtimeType == runtimeType &&
other is MessageConfig && other is MessageConfig &&
other.event == event; other.event.eventId == event.eventId;
@override @override
int get hashCode => Object.hash(runtimeType, event); int get hashCode => Object.hash(runtimeType, event.eventId);
factory MessageConfig.fromJson(Map<String, Object?> json) => factory MessageConfig.fromJson(Map<String, Object?> json) =>
_$MessageConfigFromJson(json); _$MessageConfigFromJson(json);

View file

@ -1,17 +0,0 @@
import "package:freezed_annotation/freezed_annotation.dart";
import "package:nexus/models/requests/membership_action.dart";
part "power_level_config.freezed.dart";
part "power_level_config.g.dart";
@freezed
abstract class PowerLevelConfig with _$PowerLevelConfig {
const factory PowerLevelConfig({
@Default(false) bool isStateEvent,
required String eventType,
MembershipAction? action,
String? targetUser,
}) = _PowerLevelConfig;
factory PowerLevelConfig.fromJson(Map<String, Object?> json) =>
_$PowerLevelConfigFromJson(json);
}

View file

@ -1,14 +1,12 @@
import "package:fast_immutable_collections/fast_immutable_collections.dart"; import "package:fast_immutable_collections/fast_immutable_collections.dart";
import "package:freezed_annotation/freezed_annotation.dart"; import "package:freezed_annotation/freezed_annotation.dart";
import "package:nexus/helpers/extensions/mxc_to_https.dart"; import "package:nexus/helpers/extensions/mxc_to_https.dart";
import "package:nexus/models/membership_status.dart";
part "membership.freezed.dart"; part "membership.freezed.dart";
@freezed @freezed
abstract class Membership with _$Membership { abstract class Membership with _$Membership {
const Membership._(); const Membership._();
const factory Membership({ const factory Membership({
required MembershipStatus status,
required Uri? avatarUrl, required Uri? avatarUrl,
required String displayName, required String displayName,
required String userId, required String userId,
@ -19,10 +17,6 @@ abstract class Membership with _$Membership {
String userId, String userId,
String homeserver, String homeserver,
) => Membership( ) => Membership(
status: MembershipStatus.values.firstWhere(
(status) => status.name == content["membership"],
orElse: () => MembershipStatus.leave,
),
avatarUrl: Uri.tryParse( avatarUrl: Uri.tryParse(
content["avatar_url"] ?? "", content["avatar_url"] ?? "",
)?.mxcToHttps(homeserver), )?.mxcToHttps(homeserver),

View file

@ -1,4 +0,0 @@
import "package:freezed_annotation/freezed_annotation.dart";
@JsonEnum()
enum MembershipStatus { leave, invite, ban, join }

View file

@ -3,22 +3,15 @@ import "package:freezed_annotation/freezed_annotation.dart";
part "profile.freezed.dart"; part "profile.freezed.dart";
part "profile.g.dart"; part "profile.g.dart";
Object? readPronouns(Map<dynamic, dynamic> map, _) =>
map["m.pronouns"] ?? map["io.fsky.nyx.pronouns"];
Object? readTimezone(Map<dynamic, dynamic> map, _) =>
map["m.tz"] ?? map["us.cloke.msc4175.tz"];
@freezed @freezed
abstract class Profile with _$Profile { abstract class Profile with _$Profile {
const factory Profile({ const factory Profile({
String? avatarUrl, String? avatarUrl,
@JsonKey(name: "displayname") String? displayName, @JsonKey(name: "displayname") String? displayName,
@JsonKey(name: "us.cloke.msc4175.tz") String? timezone,
@JsonKey(readValue: readTimezone) String? timezone,
@Default(IList.empty()) @Default(IList.empty())
@JsonKey(readValue: readPronouns) @JsonKey(name: "io.fsky.nyx.pronouns")
IList<Pronoun> pronouns, IList<Pronoun> pronouns,
}) = _Profile; }) = _Profile;

View file

@ -6,7 +6,6 @@ part "get_room_state_request.g.dart";
abstract class GetRoomStateRequest with _$GetRoomStateRequest { abstract class GetRoomStateRequest with _$GetRoomStateRequest {
const factory GetRoomStateRequest({ const factory GetRoomStateRequest({
required String roomId, required String roomId,
@Default(false) bool refetch,
@Default(false) bool fetchMembers, @Default(false) bool fetchMembers,
@Default(false) bool includeMembers, @Default(false) bool includeMembers,
}) = _GetRoomStateRequest; }) = _GetRoomStateRequest;

View file

@ -1,4 +0,0 @@
import "package:freezed_annotation/freezed_annotation.dart";
@JsonEnum()
enum MembershipAction { ban, kick, unban, invite }

View file

@ -1,17 +0,0 @@
import "package:freezed_annotation/freezed_annotation.dart";
part "send_event_request.freezed.dart";
part "send_event_request.g.dart";
@freezed
abstract class SendEventRequest with _$SendEventRequest {
const factory SendEventRequest({
required String roomId,
required String type,
required Map<String, dynamic> content,
@Default(false) bool synchronous,
@Default(false) bool disableEncryption,
}) = _SendEventRequest;
factory SendEventRequest.fromJson(Map<String, Object?> json) =>
_$SendEventRequestFromJson(json);
}

View file

@ -1,19 +0,0 @@
import "package:freezed_annotation/freezed_annotation.dart";
import "package:nexus/models/requests/membership_action.dart";
part "set_membership_request.freezed.dart";
part "set_membership_request.g.dart";
@freezed
abstract class SetMembershipRequest with _$SetMembershipRequest {
const factory SetMembershipRequest({
required String userId,
required String roomId,
String? reason,
@JsonKey(name: "action") required MembershipAction action,
@Default(false) @JsonKey(name: "msc4293_redact_events") bool redact,
}) = _SetMembershipRequest;
factory SetMembershipRequest.fromJson(Map<String, Object?> json) =>
_$SetMembershipRequestFromJson(json);
}

View file

@ -14,5 +14,5 @@ abstract class SyncStatus with _$SyncStatus {
_$SyncStatusFromJson(json); _$SyncStatusFromJson(json);
} }
@JsonEnum(fieldRename: FieldRename.kebab) @JsonEnum(fieldRename: FieldRename.snake)
enum SyncStatusType { ok, waiting, erroring, permanentlyFailed } enum SyncStatusType { ok, waiting, erroring, permanentlyFailed }

View file

@ -1,10 +1,7 @@
import "package:flutter/material.dart"; import "package:flutter/material.dart";
import "package:flutter_riverpod/flutter_riverpod.dart"; import "package:flutter_riverpod/flutter_riverpod.dart";
import "package:nexus/controllers/init_complete_controller.dart";
import "package:nexus/widgets/appbar.dart";
import "package:nexus/widgets/chat_page/sidebar.dart"; import "package:nexus/widgets/chat_page/sidebar.dart";
import "package:nexus/widgets/chat_page/room_chat.dart"; import "package:nexus/widgets/chat_page/room_chat.dart";
import "package:nexus/widgets/loading.dart";
class ChatPage extends ConsumerWidget { class ChatPage extends ConsumerWidget {
const ChatPage({super.key}); const ChatPage({super.key});
@ -14,33 +11,22 @@ class ChatPage extends ConsumerWidget {
builder: (context, constraints) { builder: (context, constraints) {
final isDesktop = constraints.maxWidth > 650; final isDesktop = constraints.maxWidth > 650;
final showMembersByDefault = constraints.maxWidth > 1000; final showMembersByDefault = constraints.maxWidth > 1000;
final initComplete = ref.watch(InitCompleteController.provider);
return Scaffold( return Scaffold(
appBar: initComplete ? null : Appbar(), body: Builder(
body: initComplete builder: (context) => Row(
? Builder( children: [
builder: (context) => Row( if (isDesktop) Sidebar(isDesktop: isDesktop),
children: [ Expanded(
if (isDesktop) Sidebar(isDesktop: isDesktop), child: RoomChat(
Expanded( isDesktop: isDesktop,
child: RoomChat( showMembersByDefault: showMembersByDefault,
isDesktop: isDesktop,
showMembersByDefault: showMembersByDefault,
),
),
],
),
)
: Center(
child: Column(
mainAxisSize: MainAxisSize.min,
children: [Loading(), Text("Syncing...")],
), ),
), ),
drawer: isDesktop || !initComplete ],
? null ),
: Sidebar(isDesktop: isDesktop), ),
drawer: isDesktop ? null : Sidebar(isDesktop: isDesktop),
); );
}, },
); );

View file

@ -50,7 +50,7 @@ class AvatarOrHash extends ConsumerWidget {
ref.watch(CrossCacheController.provider), ref.watch(CrossCacheController.provider),
headers: ref.headers, headers: ref.headers,
), ),
fit: BoxFit.cover, fit: BoxFit.contain,
errorBuilder: (_, _, _) => box, errorBuilder: (_, _, _) => box,
), ),
), ),

View file

@ -1,33 +1,25 @@
import "package:fast_immutable_collections/fast_immutable_collections.dart";
import "package:flutter/material.dart"; import "package:flutter/material.dart";
import "package:flutter/services.dart";
import "package:flutter_chat_core/flutter_chat_core.dart"; import "package:flutter_chat_core/flutter_chat_core.dart";
import "package:flutter_hooks/flutter_hooks.dart"; import "package:flutter_hooks/flutter_hooks.dart";
import "package:fluttertagger/fluttertagger.dart"; import "package:fluttertagger/fluttertagger.dart";
import "package:hooks_riverpod/hooks_riverpod.dart"; import "package:hooks_riverpod/hooks_riverpod.dart";
import "package:nexus/controllers/power_level_controller.dart"; import "package:nexus/controllers/room_chat_controller.dart";
import "package:nexus/models/configs/power_level_config.dart";
import "package:nexus/models/relation_type.dart"; import "package:nexus/models/relation_type.dart";
import "package:nexus/models/room.dart";
import "package:nexus/widgets/chat_page/composer/mention_overlay.dart"; import "package:nexus/widgets/chat_page/composer/mention_overlay.dart";
import "package:nexus/widgets/chat_page/composer/relation_preview.dart"; import "package:nexus/widgets/chat_page/composer/relation_preview.dart";
import "package:nexus/widgets/chat_page/emoji_picker_button.dart";
class ChatBox extends HookConsumerWidget { class ChatBox extends HookConsumerWidget {
final Message? relatedMessage; final Message? relatedMessage;
final RelationType relationType; final RelationType relationType;
final VoidCallback onDismiss; final VoidCallback onDismiss;
final FocusNode? node; final Room room;
final Future<void> Function(
String text, {
required bool shouldMention,
required IList<Tag> tags,
})
onSend;
const ChatBox({ const ChatBox({
required this.relatedMessage, required this.relatedMessage,
required this.relationType, required this.relationType,
required this.onDismiss, required this.onDismiss,
required this.onSend, required this.room,
this.node,
super.key, super.key,
}); });
@ -46,28 +38,37 @@ class ChatBox extends HookConsumerWidget {
} }
void send() { void send() {
if (controller.value.text.isEmpty) return; if (controller.value.text.trim().isEmpty || room.metadata == null) return;
onSend( ref
controller.value.formattedText, .watch(RoomChatController.provider(room.metadata!.id).notifier)
shouldMention: shouldMention.value, .send(
tags: controller.value.tags.toIList(), controller.value.formattedText,
); shouldMention: shouldMention.value,
relation: relatedMessage,
relationType: relationType,
tags: controller.value.tags,
);
onDismiss(); onDismiss();
controller.value.text = ""; controller.value.text = "";
} }
final node = useFocusNode(
onKeyEvent: (_, event) {
if (event is KeyDownEvent &&
event.logicalKey == LogicalKeyboardKey.escape) {
onDismiss();
return KeyEventResult.handled;
}
return KeyEventResult.ignored;
},
);
final style = TextStyle( final style = TextStyle(
color: theme.colorScheme.primary, color: theme.colorScheme.primary,
fontWeight: FontWeight.bold, fontWeight: FontWeight.bold,
); );
final canSendMessages = ref.watch(
PowerLevelController.provider(
PowerLevelConfig(eventType: "m.room.message"),
),
);
return Positioned( return Positioned(
bottom: 0, bottom: 0,
left: 0, left: 0,
@ -80,6 +81,7 @@ class ChatBox extends HookConsumerWidget {
children: [ children: [
RelationPreview( RelationPreview(
relatedMessage, relatedMessage,
room: room,
shouldMention: shouldMention.value, shouldMention: shouldMention.value,
toggleShouldMention: () => toggleShouldMention: () =>
shouldMention.value = !shouldMention.value, shouldMention.value = !shouldMention.value,
@ -92,14 +94,8 @@ class ChatBox extends HookConsumerWidget {
child: Row( child: Row(
spacing: 8, spacing: 8,
children: [ children: [
EmojiPickerButton(
context: context,
onSelection: (_) => node?.requestFocus(),
controller: controller.value,
),
PopupMenuButton( PopupMenuButton(
tooltip: "Add media", tooltip: "Add media",
enabled: canSendMessages,
itemBuilder: (context) => [ itemBuilder: (context) => [
PopupMenuItem( PopupMenuItem(
child: ListTile( child: ListTile(
@ -121,16 +117,18 @@ class ChatBox extends HookConsumerWidget {
), ),
], ],
icon: Icon(Icons.add), icon: Icon(Icons.add),
// enabled: room.canSendDefaultMessages, TODO: Permissions check
), ),
Expanded( Expanded(
child: FlutterTagger( child: FlutterTagger(
triggerStrategy: TriggerStrategy.eager, triggerStrategy: TriggerStrategy.eager,
overlay: MentionOverlay( overlay: MentionOverlay(
room,
query: query.value, query: query.value,
triggerCharacter: triggerCharacter.value, triggerCharacter: triggerCharacter.value,
addTag: ({required id, required name}) { addTag: ({required id, required name}) {
controller.value.addTag(id: id, name: name); controller.value.addTag(id: id, name: name);
node?.requestFocus(); node.requestFocus();
}, },
), ),
controller: controller.value, controller: controller.value,
@ -140,28 +138,28 @@ class ChatBox extends HookConsumerWidget {
}, },
triggerCharacterAndStyles: {"@": style, "#": style}, triggerCharacterAndStyles: {"@": style, "#": style},
builder: (context, key) => TextFormField( builder: (context, key) => TextFormField(
enabled: canSendMessages, // enabled: room.canSendDefaultMessages,
maxLines: 12, maxLines: 12,
minLines: 1, minLines: 1,
autofocus: true,
decoration: InputDecoration( decoration: InputDecoration(
hintText: canSendMessages hintText:
true // TODO: room.canSendDefaultMessages
? "Your message here..." ? "Your message here..."
: "You don't have permission to send messages in this room...", : "You don't have permission to send messages in this room...",
border: InputBorder.none, border: InputBorder.none,
), ),
controller: controller.value, controller: controller.value,
key: key, key: key,
// TODO: Setting for send on enter on / off
onFieldSubmitted: (_) => send(), onFieldSubmitted: (_) => send(),
// Don't defocus on submit
onEditingComplete: () {},
textInputAction: TextInputAction.done, textInputAction: TextInputAction.done,
focusNode: node, focusNode: node,
), ),
), ),
), ),
IconButton( IconButton(
onPressed: !canSendMessages ? null : send, onPressed: send,
// onPressed: room.canSendDefaultMessages ? send : null,
icon: Icon(Icons.send), icon: Icon(Icons.send),
tooltip: "Send message", tooltip: "Send message",
), ),

View file

@ -1,18 +1,19 @@
import "package:flutter/material.dart"; import "package:flutter/material.dart";
import "package:hooks_riverpod/hooks_riverpod.dart"; import "package:hooks_riverpod/hooks_riverpod.dart";
import "package:nexus/controllers/members_by_type_controller.dart"; import "package:nexus/controllers/members_controller.dart";
import "package:nexus/controllers/rooms_controller.dart"; import "package:nexus/controllers/rooms_controller.dart";
import "package:nexus/controllers/via_controller.dart";
import "package:nexus/helpers/extensions/better_when.dart"; import "package:nexus/helpers/extensions/better_when.dart";
import "package:nexus/models/membership_status.dart"; import "package:nexus/models/room.dart";
import "package:nexus/widgets/avatar_or_hash.dart"; import "package:nexus/widgets/avatar_or_hash.dart";
import "package:nexus/widgets/loading.dart"; import "package:nexus/widgets/loading.dart";
class MentionOverlay extends ConsumerWidget { class MentionOverlay extends ConsumerWidget {
final String? triggerCharacter; final String? triggerCharacter;
final String query; final String query;
final Room room;
final void Function({required String id, required String name}) addTag; final void Function({required String id, required String name}) addTag;
const MentionOverlay({ const MentionOverlay(
this.room, {
required this.query, required this.query,
required this.addTag, required this.addTag,
required this.triggerCharacter, required this.triggerCharacter,
@ -33,9 +34,7 @@ class MentionOverlay extends ConsumerWidget {
child: switch (triggerCharacter) { child: switch (triggerCharacter) {
"@" => "@" =>
ref ref
.watch( .watch(MembersController.provider(room))
MembersByTypeController.provider(MembershipStatus.join),
)
.betterWhen( .betterWhen(
data: (members) => ListView( data: (members) => ListView(
children: children:
@ -63,7 +62,7 @@ class MentionOverlay extends ConsumerWidget {
title: Text(member.displayName), title: Text(member.displayName),
subtitle: Text(member.userId), subtitle: Text(member.userId),
onTap: () => addTag( onTap: () => addTag(
id: "[@${member.displayName}](matrix:u/${member.userId.substring(1)})", id: "[@${member.displayName}](https://matrix.to/#/${member.userId})",
name: member.userId name: member.userId
.substring(1) .substring(1)
.split(":") .split(":")
@ -79,43 +78,33 @@ class MentionOverlay extends ConsumerWidget {
(query.isEmpty (query.isEmpty
? rooms.values ? rooms.values
: rooms.values.where( : rooms.values.where(
(room) => (room) => (room.metadata?.name ?? "Unnamed Room")
(room.metadata?.name ?? room.metadata!.id) .toLowerCase()
.toLowerCase() .contains(query.toLowerCase()),
.contains(query.toLowerCase()),
)) ))
.map((room) { .map(
final name = (room) => ListTile(
room.metadata?.name ??
room.metadata!.canonicalAlias ??
room.metadata!.id;
return ListTile(
leading: AvatarOrHash( leading: AvatarOrHash(
room.metadata?.avatar, room.metadata?.avatar,
name, room.metadata?.name ?? "Unnamed Room",
fallback: Icon(Icons.numbers), fallback: Icon(Icons.numbers),
), ),
title: Text(name), title: Text(room.metadata?.name ?? "Unnamed Room"),
subtitle: room.metadata?.topic == null subtitle: room.metadata?.topic == null
? null ? null
: Text(room.metadata!.topic!, maxLines: 1), : Text(room.metadata!.topic!, maxLines: 1),
onTap: () { onTap: () => addTag(
final vias = ref.watch( id: "[#${room.metadata?.name ?? "Unnamed Room"}](https://matrix.to/#/${room.metadata?.id})",
ViaController.provider(room), name:
); (room.metadata?.canonicalAlias ??
addTag( room.metadata?.id)
id: "[#$name](matrix:roomid/${room.metadata?.id.substring(1)}$vias)", ?.substring(1)
name: .split(":")
(room.metadata?.canonicalAlias ?? .first ??
room.metadata?.id) "",
?.substring(1) ),
.split(":") ),
.first ?? )
"",
);
},
);
})
.toList(), .toList(),
), ),

View file

@ -2,6 +2,7 @@ import "package:flutter/material.dart";
import "package:flutter_chat_core/flutter_chat_core.dart"; import "package:flutter_chat_core/flutter_chat_core.dart";
import "package:hooks_riverpod/hooks_riverpod.dart"; import "package:hooks_riverpod/hooks_riverpod.dart";
import "package:nexus/models/relation_type.dart"; import "package:nexus/models/relation_type.dart";
import "package:nexus/models/room.dart";
import "package:nexus/widgets/chat_page/lazy_loading/message_avatar.dart"; import "package:nexus/widgets/chat_page/lazy_loading/message_avatar.dart";
import "package:nexus/widgets/chat_page/lazy_loading/message_displayname.dart"; import "package:nexus/widgets/chat_page/lazy_loading/message_displayname.dart";
@ -11,9 +12,11 @@ class RelationPreview extends ConsumerWidget {
final VoidCallback onDismiss; final VoidCallback onDismiss;
final bool shouldMention; final bool shouldMention;
final VoidCallback toggleShouldMention; final VoidCallback toggleShouldMention;
final Room room;
const RelationPreview( const RelationPreview(
this.relatedMessage, { this.relatedMessage, {
required this.room,
required this.relationType, required this.relationType,
required this.onDismiss, required this.onDismiss,
required this.shouldMention, required this.shouldMention,
@ -32,38 +35,27 @@ class RelationPreview extends ConsumerWidget {
child: Row( child: Row(
spacing: 8, spacing: 8,
children: [ children: [
SizedBox(width: 4),
if (relationType == RelationType.edit) if (relationType == RelationType.edit)
Text( Text(
"Editing message:", "Editing message:",
style: TextStyle(fontWeight: FontWeight.bold), style: TextStyle(fontWeight: FontWeight.bold),
), ),
MessageAvatar(relatedMessage!, room),
MessageAvatar(relatedMessage!), MessageDisplayname(
relatedMessage!,
room,
style: theme.textTheme.labelMedium?.copyWith(
fontWeight: FontWeight.bold,
),
),
Expanded( Expanded(
child: Row( child: Text(
spacing: 8, relatedMessage?.metadata?["body"] ??
children: [ relatedMessage?.metadata?["eventType"],
Flexible( overflow: TextOverflow.ellipsis,
child: MessageDisplayname( style: theme.textTheme.labelMedium,
relatedMessage!, maxLines: 1,
style: theme.textTheme.labelMedium?.copyWith(
fontWeight: FontWeight.bold,
),
),
),
Expanded(
child: Text(
relatedMessage?.metadata?["body"] ??
relatedMessage?.metadata?["eventType"] ??
"",
maxLines: 1,
overflow: TextOverflow.ellipsis,
softWrap: false,
style: theme.textTheme.labelMedium,
),
),
],
), ),
), ),
@ -78,12 +70,11 @@ class RelationPreview extends ConsumerWidget {
), ),
), ),
), ),
IconButton( IconButton(
tooltip: tooltip:
"Cancel ${relationType == RelationType.edit ? "edit" : "reply"}", "Cancel ${relationType == RelationType.edit ? "edit" : "reply"}",
onPressed: onDismiss, onPressed: onDismiss,
icon: const Icon(Icons.close), icon: Icon(Icons.close),
iconSize: 20, iconSize: 20,
), ),
], ],

View file

@ -1,41 +0,0 @@
import "package:emoji_text_field/emoji_text_field.dart";
import "package:flutter/material.dart";
import "package:flutter_hooks/flutter_hooks.dart";
class EmojiPickerButton extends HookWidget {
final TextEditingController? controller;
final void Function(String emoji)? onSelection;
final VoidCallback? onPressed;
final BuildContext context;
const EmojiPickerButton({
this.controller,
this.onPressed,
this.onSelection,
required this.context,
super.key,
});
@override
Widget build(_) => IconButton(
onPressed: () {
onPressed?.call();
final controller = this.controller ?? TextEditingController();
showModalBottomSheet(
context: context,
builder: (context) => EmojiKeyboardView(
config: EmojiViewConfig(
showRecentTab: false,
backgroundColor: Theme.of(context).colorScheme.surfaceContainer,
height: 600,
),
textController: controller
..addListener(() async {
Navigator.of(context).pop();
onSelection?.call(controller.text);
}),
),
);
},
icon: Icon(Icons.emoji_emotions),
);
}

View file

@ -1,15 +1,12 @@
import "package:cross_cache/cross_cache.dart";
import "package:fast_immutable_collections/fast_immutable_collections.dart"; import "package:fast_immutable_collections/fast_immutable_collections.dart";
import "package:flutter/material.dart"; import "package:flutter/material.dart";
import "package:flutter_riverpod/flutter_riverpod.dart"; import "package:flutter_riverpod/flutter_riverpod.dart";
import "package:flutter_widget_from_html_core/flutter_widget_from_html_core.dart"; import "package:flutter_widget_from_html_core/flutter_widget_from_html_core.dart";
import "package:nexus/controllers/client_state_controller.dart"; import "package:nexus/controllers/client_state_controller.dart";
import "package:nexus/controllers/cross_cache_controller.dart";
import "package:nexus/helpers/extensions/get_headers.dart"; import "package:nexus/helpers/extensions/get_headers.dart";
import "package:nexus/helpers/extensions/link_to_mention.dart"; import "package:nexus/helpers/extensions/link_to_mention.dart";
import "package:nexus/helpers/extensions/mxc_to_https.dart"; import "package:nexus/helpers/extensions/mxc_to_https.dart";
import "package:nexus/helpers/launch_helper.dart"; import "package:nexus/helpers/launch_helper.dart";
import "package:nexus/widgets/chat_page/expandable_image.dart";
import "package:nexus/widgets/chat_page/html/mention_chip.dart"; import "package:nexus/widgets/chat_page/html/mention_chip.dart";
import "package:nexus/widgets/chat_page/html/spoiler_text.dart"; import "package:nexus/widgets/chat_page/html/spoiler_text.dart";
import "package:nexus/widgets/chat_page/html/code_block.dart"; import "package:nexus/widgets/chat_page/html/code_block.dart";
@ -33,29 +30,20 @@ class Html extends ConsumerWidget {
return InlineCustomWidget(child: SpoilerText(text: element.text)); return InlineCustomWidget(child: SpoilerText(text: element.text));
} }
final height = final height = int.tryParse(element.attributes["height"] ?? "") ?? 300;
int.tryParse(element.attributes["height"] ?? "") ??
(element.attributes.keys.contains("data-mx-emoticon") ? 32 : null) ??
300;
final width = int.tryParse(element.attributes["width"] ?? ""); final width = int.tryParse(element.attributes["width"] ?? "");
final src = Uri.tryParse(element.attributes["src"] ?? "")
?.mxcToHttps(
ref.watch(
ClientStateController.provider.select(
(value) => value?.homeserverUrl,
),
) ??
"",
)
.toString();
return switch (element.localName) { return switch (element.localName) {
"code" => "code" =>
element.parent?.localName == "pre" element.parent?.localName == "pre"
? CodeBlock( ? element.outerHtml.contains("<br class=\"fake-break\">")
element.text, ? Html(
lang: element.className.replaceAll("language-", ""), """<pre>${element.outerHtml.replaceAll("<br class=\"fake-break\">", "\n")}</pre>""",
) )
: CodeBlock(
element.text,
lang: element.className.replaceAll("language-", ""),
)
: null, : null,
"blockquote" => Quoted(Html(element.innerHtml)), "blockquote" => Quoted(Html(element.innerHtml)),
@ -63,40 +51,39 @@ class Html extends ConsumerWidget {
"a" => "a" =>
element.attributes["href"]?.mention == null element.attributes["href"]?.mention == null
? null ? null
: InlineCustomWidget( : InlineCustomWidget(child: MentionChip(element.text)),
child: MentionChip(element.attributes["href"]!),
),
"img" => "img" =>
src == null element.attributes["src"] == null
? SizedBox.shrink() ? SizedBox.shrink()
: InlineCustomWidget( : InlineCustomWidget(
alignment: PlaceholderAlignment.middle, alignment: PlaceholderAlignment.middle,
child: ExpandableImage( child: Image.network(
src, Uri.parse(element.attributes["src"]!)
child: Image( .mxcToHttps(
image: CachedNetworkImage( ref.watch(
src, ClientStateController.provider.select(
ref.watch(CrossCacheController.provider), (value) => value?.homeserverUrl,
headers: ref.headers, ),
) ??
"",
)
.toString(),
headers: ref.headers,
errorBuilder: (_, error, _) => Text(
"Image Failed to Load",
style: TextStyle(
color: Theme.of(context).colorScheme.error,
), ),
errorBuilder: (_, error, _) => Text(
"Image Failed to Load",
style: TextStyle(
color: Theme.of(context).colorScheme.error,
),
),
height: height.toDouble(),
width: width?.toDouble(),
loadingBuilder: (_, child, loadingProgress) =>
loadingProgress == null
? child
: CircularProgressIndicator(),
), ),
height: height.toDouble(),
width: width?.toDouble(),
loadingBuilder: (_, child, loadingProgress) =>
loadingProgress == null
? child
: CircularProgressIndicator(),
), ),
), ),
// Allowed elements list
("del" || ("del" ||
"h1" || "h1" ||
"h2" || "h2" ||

View file

@ -1,44 +1,25 @@
import "package:flutter/material.dart"; import "package:flutter/material.dart";
import "package:flutter_riverpod/flutter_riverpod.dart";
import "package:nexus/controllers/user_controller.dart";
import "package:nexus/helpers/extensions/link_to_mention.dart"; import "package:nexus/helpers/extensions/link_to_mention.dart";
import "package:nexus/helpers/extensions/show_user_popover.dart";
class MentionChip extends ConsumerWidget { class MentionChip extends StatelessWidget {
final String content; final String label;
const MentionChip(this.content, {super.key}); const MentionChip(this.label, {super.key});
@override @override
Widget build(BuildContext context, WidgetRef ref) { Widget build(BuildContext context) => ActionChip(
final membership = content.mention!.startsWith("@") == true label: Text(
? ref label.mention ?? label,
.watch(UserController.provider(content.mention!)) style: TextStyle(
.whenOrNull(data: (data) => data) fontWeight: FontWeight.bold,
: null; color: Theme.of(context).colorScheme.onPrimary,
return InkWell(
onTapUp: (details) {
content.mention;
if (membership != null) {
context.showUserPopover(
membership,
globalPosition: details.globalPosition,
);
}
},
child: IgnorePointer(
child: Chip(
label: Text(
(membership == null ? null : "@${membership.displayName}") ??
content.mention!,
style: TextStyle(
fontWeight: FontWeight.bold,
color: Theme.of(context).colorScheme.onPrimary,
),
),
backgroundColor: Theme.of(context).colorScheme.primary,
),
), ),
); ),
} backgroundColor: Theme.of(context).colorScheme.primary,
onPressed: () => showDialog(
context: context,
builder: (_) => Dialog(
child: Text("TODO: Open room or join room dialog, or user popover"),
),
),
);
} }

View file

@ -1,137 +0,0 @@
import "package:collection/collection.dart";
import "package:fast_immutable_collections/fast_immutable_collections.dart";
import "package:flutter/material.dart";
import "package:flutter_hooks/flutter_hooks.dart";
import "package:hooks_riverpod/hooks_riverpod.dart";
import "package:nexus/controllers/client_controller.dart";
import "package:nexus/controllers/key_controller.dart";
import "package:nexus/controllers/spaces_controller.dart";
import "package:nexus/helpers/extensions/link_to_mention.dart";
import "package:nexus/models/requests/join_room_request.dart";
import "package:nexus/widgets/form_text_input.dart";
class JoinDialog extends HookWidget {
final WidgetRef ref;
const JoinDialog(this.ref, {super.key});
@override
Widget build(BuildContext context) {
final roomAlias = useTextEditingController();
return AlertDialog(
title: Text("Join a Room"),
content: Column(
mainAxisSize: MainAxisSize.min,
crossAxisAlignment: CrossAxisAlignment.start,
children: [
Text("Enter the room alias, Matrix URI, or Matrix.to link."),
SizedBox(height: 12),
FormTextInput(
required: false,
capitalize: true,
controller: roomAlias,
title: "#room:server",
),
],
),
actions: [
TextButton(onPressed: Navigator.of(context).pop, child: Text("Cancel")),
TextButton(
onPressed: () async {
Navigator.of(context).pop();
if (context.mounted) {
final roomIdOrAlias = roomAlias.text.mention ?? roomAlias.text;
final scaffoldMessenger = ScaffoldMessenger.of(context);
final snackbar = scaffoldMessenger.showSnackBar(
SnackBar(
content: Text("Joining room $roomIdOrAlias."),
duration: Duration(days: 999),
),
);
try {
final id = await ref
.watch(ClientController.provider.notifier)
.joinRoom(
JoinRoomRequest(
roomIdOrAlias: roomIdOrAlias,
via: IList(
Uri.tryParse(
roomAlias.text.replaceAll("/#", ""),
)?.queryParametersAll["via"] ??
[],
),
),
);
snackbar.close();
scaffoldMessenger.showSnackBar(
SnackBar(
content: Text("Room $roomIdOrAlias successfully joined."),
action: SnackBarAction(
label: "Open",
onPressed: () async {
final spaces = ref.watch(SpacesController.provider);
final space = spaces.firstWhereOrNull(
(space) => space.id == id,
);
await ref
.watch(
KeyController.provider(
KeyController.spaceKey,
).notifier,
)
.set(
space?.id ??
spaces
.firstWhere(
(space) => space.children.any(
(child) => child.metadata?.id == id,
),
)
.id,
);
if (space == null) {
await ref
.watch(
KeyController.provider(
KeyController.roomKey,
).notifier,
)
.set(id);
}
},
),
),
);
} catch (error) {
snackbar.close();
if (context.mounted) {
scaffoldMessenger.showSnackBar(
SnackBar(
backgroundColor: Theme.of(
context,
).colorScheme.errorContainer,
content: Text(
error.toString(),
style: TextStyle(
color: Theme.of(context).colorScheme.onErrorContainer,
),
),
),
);
}
}
}
},
child: Text("Join"),
),
],
);
}
}

View file

@ -1,30 +1,28 @@
import "package:flutter/material.dart"; import "package:flutter/widgets.dart";
import "package:flutter_chat_core/flutter_chat_core.dart"; import "package:flutter_chat_core/flutter_chat_core.dart";
import "package:flutter_riverpod/flutter_riverpod.dart"; import "package:flutter_riverpod/flutter_riverpod.dart";
import "package:nexus/controllers/author_controller.dart"; import "package:nexus/controllers/author_controller.dart";
import "package:nexus/helpers/extensions/better_when.dart"; import "package:nexus/helpers/extensions/better_when.dart";
import "package:nexus/helpers/extensions/show_user_popover.dart"; import "package:nexus/models/configs/author_config.dart";
import "package:nexus/models/room.dart";
import "package:nexus/widgets/avatar_or_hash.dart"; import "package:nexus/widgets/avatar_or_hash.dart";
class MessageAvatar extends ConsumerWidget { class MessageAvatar extends ConsumerWidget {
final Message message; final Message message;
final Room room;
final double height; final double height;
const MessageAvatar(this.message, {this.height = 16, super.key}); const MessageAvatar(this.message, this.room, {this.height = 16, super.key});
@override @override
Widget build(BuildContext context, WidgetRef ref) => ref Widget build(BuildContext context, WidgetRef ref) => ref
.watch(AuthorController.provider(message)) .watch(
AuthorController.provider(AuthorConfig(room: room, message: message)),
)
.betterWhen( .betterWhen(
data: (membership) => InkWell( data: (membership) => AvatarOrHash(
onTapUp: (details) => context.showUserPopover( membership.avatarUrl,
membership, membership.displayName,
globalPosition: details.globalPosition, height: height,
),
child: AvatarOrHash(
membership.avatarUrl,
membership.displayName,
height: height,
),
), ),
loading: () => loading: () =>
AvatarOrHash(null, message.authorId.substring(1), height: height), AvatarOrHash(null, message.authorId.substring(1), height: height),

View file

@ -1,37 +1,27 @@
import "package:flutter/material.dart"; import "package:flutter/widgets.dart";
import "package:flutter_chat_core/flutter_chat_core.dart"; import "package:flutter_chat_core/flutter_chat_core.dart";
import "package:flutter_riverpod/flutter_riverpod.dart"; import "package:flutter_riverpod/flutter_riverpod.dart";
import "package:nexus/controllers/author_controller.dart"; import "package:nexus/controllers/author_controller.dart";
import "package:nexus/helpers/extensions/better_when.dart"; import "package:nexus/helpers/extensions/better_when.dart";
import "package:nexus/helpers/extensions/show_user_popover.dart"; import "package:nexus/models/configs/author_config.dart";
import "package:nexus/models/room.dart";
class MessageDisplayname extends ConsumerWidget { class MessageDisplayname extends ConsumerWidget {
final Message message; final Message message;
final Room room;
final TextStyle? style; final TextStyle? style;
final bool clickable; const MessageDisplayname(this.message, this.room, {this.style, super.key});
const MessageDisplayname(
this.message, {
this.clickable = true,
this.style,
super.key,
});
@override @override
Widget build(BuildContext context, WidgetRef ref) => ref Widget build(BuildContext context, WidgetRef ref) => ref
.watch(AuthorController.provider(message)) .watch(
AuthorController.provider(AuthorConfig(room: room, message: message)),
)
.betterWhen( .betterWhen(
data: (membership) => InkWell( data: (membership) => Text(
onTapUp: clickable "${membership.displayName} ${message.metadata?["pmp"] == null ? "" : "(via ${message.authorId})"}",
? (details) => context.showUserPopover( style: style,
membership, overflow: TextOverflow.ellipsis,
globalPosition: details.globalPosition,
)
: null,
child: Text(
"${membership.displayName}${message.metadata?["pmp"] == null ? "" : " (via ${message.authorId})"}",
style: style,
overflow: TextOverflow.ellipsis,
),
), ),
loading: () => Text(""), loading: () => Text(""),
); );

View file

@ -1,31 +1,27 @@
import "package:flutter/material.dart"; import "package:flutter/material.dart";
import "package:flutter_hooks/flutter_hooks.dart";
import "package:hooks_riverpod/hooks_riverpod.dart"; import "package:hooks_riverpod/hooks_riverpod.dart";
import "package:nexus/controllers/members_by_type_controller.dart"; import "package:nexus/controllers/members_controller.dart";
import "package:nexus/helpers/extensions/better_when.dart"; import "package:nexus/helpers/extensions/better_when.dart";
import "package:nexus/helpers/extensions/show_user_popover.dart"; import "package:nexus/models/room.dart";
import "package:nexus/models/membership_status.dart";
import "package:nexus/widgets/avatar_or_hash.dart"; import "package:nexus/widgets/avatar_or_hash.dart";
class MemberList extends HookConsumerWidget { class MemberList extends ConsumerWidget {
const MemberList({super.key}); final Room room;
const MemberList(this.room, {super.key});
@override @override
Widget build(BuildContext context, WidgetRef ref) { Widget build(BuildContext context, WidgetRef ref) {
final status = useState(MembershipStatus.join); final membersProvider = ref.watch(MembersController.provider(room));
final membersProvider = ref.watch(
MembersByTypeController.provider(status.value),
);
return Drawer( return Drawer(
shape: Border(), shape: Border(),
child: Column( child: Column(
spacing: 8,
children: [ children: [
AppBar( AppBar(
scrolledUnderElevation: 0, scrolledUnderElevation: 0,
leading: Icon(Icons.people), leading: Icon(Icons.people),
title: Text("Members"), title: Text(
"Members ${membersProvider.when(data: (members) => "${members.length}", error: (_, _) => "", loading: () => "")}",
),
actionsPadding: EdgeInsets.only(right: 4), actionsPadding: EdgeInsets.only(right: 4),
actions: [ actions: [
if (Scaffold.of(context).hasEndDrawer) if (Scaffold.of(context).hasEndDrawer)
@ -36,50 +32,28 @@ class MemberList extends HookConsumerWidget {
), ),
], ],
), ),
Row(
mainAxisAlignment: MainAxisAlignment.center,
spacing: 8,
children: [
FilterChip(
label: Text("Joined"),
onSelected: (value) => status.value = MembershipStatus.join,
selected: status.value == MembershipStatus.join,
),
FilterChip(
label: Text("Invited"),
onSelected: (value) => status.value = MembershipStatus.invite,
selected: status.value == MembershipStatus.invite,
),
FilterChip(
label: Text("Banned"),
onSelected: (value) => status.value = MembershipStatus.ban,
selected: status.value == MembershipStatus.ban,
),
],
),
membersProvider.betterWhen( membersProvider.betterWhen(
data: (members) => Expanded( data: (members) => Expanded(
child: ListView( child: ListView(
children: members children: members
.map( .map(
(member) => InkWell( (member) => ListTile(
onTapUp: (details) => context.showUserPopover( onTap: () => showDialog(
member, context: context,
globalPosition: details.globalPosition, builder: (context) =>
Dialog(child: Text("TODO: Open member popover")),
), ),
child: ListTile( leading: AvatarOrHash(
leading: AvatarOrHash( member.avatarUrl,
member.avatarUrl, member.displayName,
member.displayName, ),
), title: Text(
title: Text( member.displayName,
member.displayName, overflow: TextOverflow.ellipsis,
overflow: TextOverflow.ellipsis, ),
), subtitle: Text(
subtitle: Text( member.userId,
member.userId, overflow: TextOverflow.ellipsis,
overflow: TextOverflow.ellipsis,
),
), ),
), ),
) )

View file

@ -3,10 +3,10 @@ import "package:flutter_chat_core/flutter_chat_core.dart";
import "package:flutter_riverpod/flutter_riverpod.dart"; import "package:flutter_riverpod/flutter_riverpod.dart";
import "package:nexus/controllers/event_controller.dart"; import "package:nexus/controllers/event_controller.dart";
import "package:nexus/controllers/message_controller.dart"; import "package:nexus/controllers/message_controller.dart";
import "package:nexus/controllers/selected_room_controller.dart";
import "package:nexus/helpers/extensions/better_when.dart"; import "package:nexus/helpers/extensions/better_when.dart";
import "package:nexus/models/configs/message_config.dart"; import "package:nexus/models/configs/message_config.dart";
import "package:nexus/models/requests/get_event_request.dart"; import "package:nexus/models/requests/get_event_request.dart";
import "package:nexus/models/room.dart";
import "package:nexus/widgets/chat_page/html/quoted.dart"; import "package:nexus/widgets/chat_page/html/quoted.dart";
import "package:nexus/widgets/chat_page/lazy_loading/message_avatar.dart"; import "package:nexus/widgets/chat_page/lazy_loading/message_avatar.dart";
import "package:nexus/widgets/chat_page/lazy_loading/message_displayname.dart"; import "package:nexus/widgets/chat_page/lazy_loading/message_displayname.dart";
@ -16,10 +16,12 @@ typedef OnTapReply = void Function(Message message)?;
class ReplyWidget extends ConsumerWidget { class ReplyWidget extends ConsumerWidget {
final Message message; final Message message;
final bool alwaysShow; final bool alwaysShow;
final Room room;
final MessageGroupStatus? groupStatus; final MessageGroupStatus? groupStatus;
final OnTapReply onTapReply; final OnTapReply onTapReply;
const ReplyWidget( const ReplyWidget(
this.message, { this.message, {
required this.room,
required this.groupStatus, required this.groupStatus,
this.onTapReply, this.onTapReply,
this.alwaysShow = false, this.alwaysShow = false,
@ -27,75 +29,73 @@ class ReplyWidget extends ConsumerWidget {
}); });
@override @override
Widget build(BuildContext context, WidgetRef ref) { Widget build(BuildContext context, WidgetRef ref) =>
final room = ref.watch(SelectedRoomController.provider); message.replyToMessageId == null
return message.replyToMessageId == null || room == null ? SizedBox.shrink()
? SizedBox.shrink() : Padding(
: Padding( padding: EdgeInsets.only(bottom: 12),
padding: EdgeInsets.only(bottom: 12), child: Quoted(
child: Quoted( ref
ref .watch(
.watch( EventController.provider(
EventController.provider( GetEventRequest(
GetEventRequest( room: room,
room: room, eventId: message.replyToMessageId!,
eventId: message.replyToMessageId!,
),
), ),
)
.betterWhen(
loading: () => Text("Fetching event..."),
data: (event) => event == null
? SizedBox.shrink()
: ref
.watch(
MessageController.provider(
MessageConfig(room: room, event: event),
),
)
.betterWhen(
loading: () => Text("Parsing message..."),
data: (replyMessage) {
if (replyMessage == null) {
return SizedBox.shrink();
}
return InkWell(
onTap: () => onTapReply?.call(replyMessage),
child: Row(
mainAxisSize: MainAxisSize.min,
spacing: 8,
children: [
MessageAvatar(replyMessage),
Flexible(
child: MessageDisplayname(
replyMessage,
clickable: false,
style: Theme.of(context)
.textTheme
.labelMedium
?.copyWith(
fontWeight: FontWeight.bold,
),
),
),
Flexible(
child: Text(
replyMessage.metadata!["body"],
overflow: TextOverflow.ellipsis,
style: Theme.of(
context,
).textTheme.labelMedium,
maxLines: 1,
),
),
],
),
);
},
),
), ),
), )
); .betterWhen(
} loading: () => Text("Fetching event..."),
data: (event) => event == null
? SizedBox.shrink()
: ref
.watch(
MessageController.provider(
MessageConfig(room: room, event: event),
),
)
.betterWhen(
loading: () => Text("Parsing message..."),
data: (replyMessage) {
if (replyMessage == null) {
return SizedBox.shrink();
}
return InkWell(
onTap: () => onTapReply?.call(replyMessage),
child: Row(
mainAxisSize: MainAxisSize.min,
spacing: 8,
children: [
MessageAvatar(replyMessage, room),
Flexible(
child: MessageDisplayname(
replyMessage,
room,
style: Theme.of(context)
.textTheme
.labelMedium
?.copyWith(
fontWeight: FontWeight.bold,
),
),
),
Flexible(
child: Text(
replyMessage.metadata!["body"],
overflow: TextOverflow.ellipsis,
style: Theme.of(
context,
).textTheme.labelMedium,
maxLines: 1,
),
),
],
),
);
},
),
),
),
);
} }

View file

@ -1,20 +1,21 @@
import "package:fast_immutable_collections/fast_immutable_collections.dart"; import "package:fast_immutable_collections/fast_immutable_collections.dart";
import "package:flutter/material.dart"; import "package:flutter/material.dart";
import "package:hooks_riverpod/hooks_riverpod.dart"; import "package:nexus/models/room.dart";
import "package:nexus/controllers/selected_room_controller.dart";
import "package:nexus/widgets/appbar.dart"; import "package:nexus/widgets/appbar.dart";
import "package:nexus/widgets/avatar_or_hash.dart"; import "package:nexus/widgets/avatar_or_hash.dart";
import "package:nexus/widgets/chat_page/expandable_image.dart"; import "package:nexus/widgets/chat_page/expandable_image.dart";
import "package:nexus/widgets/chat_page/room_menu.dart"; import "package:nexus/widgets/chat_page/room_menu.dart";
class RoomAppbar extends ConsumerWidget implements PreferredSizeWidget { class RoomAppbar extends StatelessWidget implements PreferredSizeWidget {
final bool isDesktop; final bool isDesktop;
final void Function(BuildContext context)? onOpenMemberList; final Room room;
final void Function(BuildContext context) onOpenMemberList;
final void Function(BuildContext context) onOpenDrawer; final void Function(BuildContext context) onOpenDrawer;
const RoomAppbar({ const RoomAppbar(
this.room, {
required this.isDesktop, required this.isDesktop,
required this.onOpenMemberList,
required this.onOpenDrawer, required this.onOpenDrawer,
this.onOpenMemberList,
super.key, super.key,
}); });
@ -22,57 +23,50 @@ class RoomAppbar extends ConsumerWidget implements PreferredSizeWidget {
Size get preferredSize => AppBar().preferredSize; Size get preferredSize => AppBar().preferredSize;
@override @override
Widget build(BuildContext context, WidgetRef ref) { Widget build(BuildContext context) => Appbar(
final room = ref.watch(SelectedRoomController.provider); leading: isDesktop
return Appbar( ? ExpandableImage(
leading: isDesktop room.metadata?.avatar?.toString(),
? room == null child: AvatarOrHash(
? null room.metadata?.avatar,
: ExpandableImage( room.metadata?.name ?? "Unnamed Rooms",
room.metadata?.avatar?.toString(), height: 24,
child: AvatarOrHash( fallback: Icon(Icons.numbers),
room.metadata?.avatar,
room.metadata?.name ?? "Unnamed Rooms",
height: 24,
fallback: Icon(Icons.numbers),
),
)
: DrawerButton(onPressed: () => onOpenDrawer(context)),
scrolledUnderElevation: 0,
title: room == null
? null
: Column(
crossAxisAlignment: CrossAxisAlignment.start,
children: [
Text(
room.metadata?.name ?? "Unnamed Room",
overflow: TextOverflow.ellipsis,
maxLines: 1,
),
if (room.metadata?.topic?.isNotEmpty == true)
Text(
room.metadata!.topic!,
maxLines: 1,
overflow: TextOverflow.ellipsis,
style: Theme.of(context).textTheme.labelMedium?.copyWith(
color: Theme.of(context).colorScheme.onSurfaceVariant,
),
),
],
), ),
actions: [ )
IconButton( : DrawerButton(onPressed: () => onOpenDrawer(context)),
onPressed: null, scrolledUnderElevation: 0,
icon: Icon(Icons.push_pin), title: Column(
tooltip: "Open pinned messages", crossAxisAlignment: CrossAxisAlignment.start,
children: [
Text(
room.metadata?.name ?? "Unnamed Room",
overflow: TextOverflow.ellipsis,
maxLines: 1,
), ),
IconButton( if (room.metadata?.topic?.isNotEmpty == true)
onPressed: () => onOpenMemberList?.call(context), Text(
tooltip: "Open member list", room.metadata!.topic!,
icon: Icon(Icons.people), maxLines: 1,
), overflow: TextOverflow.ellipsis,
if (room != null) RoomMenu(room), style: Theme.of(context).textTheme.labelMedium?.copyWith(
].toIList(), color: Theme.of(context).colorScheme.onSurfaceVariant,
); ),
} ),
],
),
actions: [
IconButton(
onPressed: null,
icon: Icon(Icons.push_pin),
tooltip: "Open pinned messages",
),
IconButton(
onPressed: () => onOpenMemberList(context),
tooltip: "Open member list",
icon: Icon(Icons.people),
),
RoomMenu(room),
].toIList(),
);
} }

View file

@ -1,26 +1,19 @@
import "package:fast_immutable_collections/fast_immutable_collections.dart";
import "package:flutter/material.dart"; import "package:flutter/material.dart";
import "package:flutter/services.dart";
import "package:flutter_chat_core/flutter_chat_core.dart"; import "package:flutter_chat_core/flutter_chat_core.dart";
import "package:flutter_chat_ui/flutter_chat_ui.dart"; import "package:flutter_chat_ui/flutter_chat_ui.dart";
import "package:flutter_hooks/flutter_hooks.dart"; import "package:flutter_hooks/flutter_hooks.dart";
import "package:flyer_chat_file_message/flyer_chat_file_message.dart"; import "package:flyer_chat_file_message/flyer_chat_file_message.dart";
import "package:flyer_chat_system_message/flyer_chat_system_message.dart"; import "package:flyer_chat_system_message/flyer_chat_system_message.dart";
import "package:hooks_riverpod/hooks_riverpod.dart"; import "package:hooks_riverpod/hooks_riverpod.dart";
import "package:nexus/controllers/account_data_controller.dart";
import "package:nexus/controllers/client_controller.dart"; import "package:nexus/controllers/client_controller.dart";
import "package:nexus/controllers/client_state_controller.dart"; import "package:nexus/controllers/client_state_controller.dart";
import "package:nexus/controllers/power_level_controller.dart";
import "package:nexus/controllers/selected_room_controller.dart"; import "package:nexus/controllers/selected_room_controller.dart";
import "package:nexus/controllers/room_chat_controller.dart"; import "package:nexus/controllers/room_chat_controller.dart";
import "package:nexus/controllers/via_controller.dart";
import "package:nexus/helpers/extensions/better_when.dart"; import "package:nexus/helpers/extensions/better_when.dart";
import "package:nexus/helpers/extensions/show_context_menu.dart"; import "package:nexus/helpers/extensions/show_context_menu.dart";
import "package:nexus/models/configs/power_level_config.dart";
import "package:nexus/models/relation_type.dart"; import "package:nexus/models/relation_type.dart";
import "package:nexus/models/requests/report_request.dart"; import "package:nexus/models/requests/report_request.dart";
import "package:nexus/widgets/chat_page/composer/chat_box.dart"; import "package:nexus/widgets/chat_page/composer/chat_box.dart";
import "package:nexus/widgets/chat_page/emoji_picker_button.dart";
import "package:nexus/widgets/chat_page/expandable_image_message.dart"; import "package:nexus/widgets/chat_page/expandable_image_message.dart";
import "package:nexus/widgets/chat_page/member_list.dart"; import "package:nexus/widgets/chat_page/member_list.dart";
import "package:nexus/widgets/chat_page/wrappers/message_wrapper.dart"; import "package:nexus/widgets/chat_page/wrappers/message_wrapper.dart";
@ -28,7 +21,7 @@ import "package:nexus/widgets/chat_page/room_appbar.dart";
import "package:nexus/widgets/chat_page/wrappers/text_message_wrapper.dart"; import "package:nexus/widgets/chat_page/wrappers/text_message_wrapper.dart";
import "package:nexus/widgets/chat_page/reply_widget.dart"; import "package:nexus/widgets/chat_page/reply_widget.dart";
import "package:nexus/widgets/form_text_input.dart"; import "package:nexus/widgets/form_text_input.dart";
import "package:nexus/main.dart"; // import "package:dynamic_polls/dynamic_polls.dart";
class RoomChat extends HookConsumerWidget { class RoomChat extends HookConsumerWidget {
final bool isDesktop; final bool isDesktop;
@ -42,128 +35,46 @@ class RoomChat extends HookConsumerWidget {
@override @override
Widget build(BuildContext context, WidgetRef ref) { Widget build(BuildContext context, WidgetRef ref) {
final client = ref.watch(ClientController.provider.notifier); final client = ref.watch(ClientController.provider.notifier);
final relatedMessage = useState<Message?>(null); final replyToMessage = useState<Message?>(null);
final memberListOpened = useState<bool>(showMembersByDefault); final memberListOpened = useState<bool>(showMembersByDefault);
final relationType = useState(RelationType.reply); final relationType = useState(RelationType.reply);
final room = ref.watch(SelectedRoomController.provider);
final userId = ref.watch(ClientStateController.provider)?.userId; final userId = ref.watch(ClientStateController.provider)?.userId;
final roomId = ref.watch(
SelectedRoomController.provider.select((value) => value?.metadata?.id),
);
final theme = Theme.of(context); final theme = Theme.of(context);
final danger = theme.colorScheme.error; final danger = theme.colorScheme.error;
if (roomId == null || userId == null) { if (room == null || userId == null || room.metadata?.id == null) {
return Scaffold( return Center(
appBar: RoomAppbar( child: Text(
isDesktop: isDesktop, "Nothing to see here...",
onOpenDrawer: (_) => Scaffold.of(context).openDrawer(), style: theme.textTheme.headlineMedium,
onOpenMemberList: null,
),
body: Center(
child: Text(
"Nothing to see here...",
style: theme.textTheme.headlineMedium,
),
), ),
); );
} }
final controllerProvider = RoomChatController.provider(roomId); final controllerProvider = RoomChatController.provider(room.metadata!.id);
final notifier = ref.watch(controllerProvider.notifier); final notifier = ref.watch(controllerProvider.notifier);
final composerNode = useFocusNode(
onKeyEvent: (_, event) {
if (event is KeyDownEvent &&
event.logicalKey == LogicalKeyboardKey.escape) {
relatedMessage.value = null;
return KeyEventResult.handled;
}
return KeyEventResult.ignored;
},
);
List<PopupMenuEntry> getMessageOptions(Message message) { List<PopupMenuEntry> getMessageOptions(Message message) {
final isSentByMe = message.authorId == userId; final isSentByMe = message.authorId == userId;
return [ return [
PopupMenuItem(
child: Row(
children: [
...{
...ref.watch(
AccountDataController.provider.select(
(value) => IList(
value["m.recent_emoji"]?.content["recent_emoji"] ??
[],
).map((entry) => entry["emoji"]),
),
),
"👍",
"🤣",
"😭",
"🤔",
}
.toIList()
.sublist(0, 4)
.map(
(emoji) => IconButton(
onPressed: () async {
Navigator.of(context).pop();
await notifier
.sendReaction(emoji, message)
.onError(showError);
},
icon: Text(emoji),
),
),
EmojiPickerButton(
context: context,
onPressed: Navigator.of(context).pop,
onSelection: (emoji) =>
notifier.sendReaction(emoji, message).onError(showError),
),
],
),
),
PopupMenuItem( PopupMenuItem(
onTap: () { onTap: () {
relatedMessage.value = message; replyToMessage.value = message;
relationType.value = RelationType.reply; relationType.value = RelationType.reply;
composerNode.requestFocus();
}, },
child: ListTile(leading: Icon(Icons.reply), title: Text("Reply")), child: ListTile(leading: Icon(Icons.reply), title: Text("Reply")),
), ),
if (message is TextMessage && isSentByMe) if (message is TextMessage && isSentByMe)
PopupMenuItem( PopupMenuItem(
onTap: () { onTap: () {
relatedMessage.value = message; replyToMessage.value = message;
relationType.value = RelationType.edit; relationType.value = RelationType.edit;
composerNode.requestFocus();
}, },
child: ListTile(leading: Icon(Icons.edit), title: Text("Edit")), child: ListTile(leading: Icon(Icons.edit), title: Text("Edit")),
), ),
PopupMenuItem( if (isSentByMe) // TODO: Or if user has permission to redact others' messages
onTap: () async {
final room = ref.watch(SelectedRoomController.provider);
if (room == null) return;
final vias = ref.watch(ViaController.provider(room));
await Clipboard.setData(
ClipboardData(
text:
"matrix:roomid/${room.metadata?.id.substring(1)}/e/${message.id}$vias)",
),
);
},
child: ListTile(leading: Icon(Icons.link), title: Text("Copy Link")),
),
if (ref.watch(
PowerLevelController.provider(
PowerLevelConfig(eventType: "m.room.redaction"),
),
))
PopupMenuItem( PopupMenuItem(
onTap: () => showDialog( onTap: () => showDialog(
context: context, context: context,
@ -195,13 +106,11 @@ class RoomChat extends HookConsumerWidget {
), ),
TextButton( TextButton(
onPressed: () async { onPressed: () async {
notifier.deleteMessage(
message,
reason: deleteReasonController.text,
);
Navigator.of(context).pop(); Navigator.of(context).pop();
await notifier
.deleteMessage(
message,
reason: deleteReasonController.text,
)
.onError(showError);
}, },
child: Text("Delete"), child: Text("Delete"),
), ),
@ -210,10 +119,7 @@ class RoomChat extends HookConsumerWidget {
}, },
), ),
), ),
child: ListTile( child: ListTile(leading: Icon(Icons.delete), title: Text("Delete")),
leading: Icon(Icons.delete, color: danger),
title: Text("Delete", style: TextStyle(color: danger)),
),
), ),
PopupMenuItem( PopupMenuItem(
onTap: () => showDialog( onTap: () => showDialog(
@ -247,9 +153,10 @@ class RoomChat extends HookConsumerWidget {
), ),
TextButton( TextButton(
onPressed: () { onPressed: () {
if (room.metadata == null) return;
client.reportEvent( client.reportEvent(
ReportRequest( ReportRequest(
roomId: roomId, roomId: room.metadata!.id,
eventId: message.id, eventId: message.id,
reason: reasonController.text.isEmpty reason: reasonController.text.isEmpty
? null ? null
@ -282,6 +189,7 @@ class RoomChat extends HookConsumerWidget {
return Scaffold( return Scaffold(
appBar: RoomAppbar( appBar: RoomAppbar(
room,
isDesktop: isDesktop, isDesktop: isDesktop,
onOpenDrawer: (_) => Scaffold.of(context).openDrawer(), onOpenDrawer: (_) => Scaffold.of(context).openDrawer(),
onOpenMemberList: (thisContext) { onOpenMemberList: (thisContext) {
@ -329,42 +237,18 @@ class RoomChat extends HookConsumerWidget {
chatAnimatedListBuilder: (_, itemBuilder) => chatAnimatedListBuilder: (_, itemBuilder) =>
ChatAnimatedList( ChatAnimatedList(
itemBuilder: itemBuilder, itemBuilder: itemBuilder,
onEndReached: onEndReached: room.hasMore
ref.watch(
SelectedRoomController.provider.select(
(room) => room?.hasMore == true,
),
)
? notifier.loadOlder ? notifier.loadOlder
: null, : null,
onStartReached: () async { onStartReached: () => client.markRead(room),
final room = ref.watch(
SelectedRoomController.provider,
);
return room == null
? null
: await client.markRead(room);
},
bottomPadding: 72, bottomPadding: 72,
), ),
composerBuilder: (_) => ChatBox( composerBuilder: (_) => ChatBox(
node: composerNode,
onSend:
(
text, {
required shouldMention,
required tags,
}) => notifier.send(
text,
tags: tags,
relationType: relationType.value,
shouldMention: shouldMention,
relation: relatedMessage.value,
),
relationType: relationType.value, relationType: relationType.value,
relatedMessage: relatedMessage.value, relatedMessage: replyToMessage.value,
onDismiss: () => relatedMessage.value = null, onDismiss: () => replyToMessage.value = null,
room: room,
), ),
textMessageBuilder: textMessageBuilder:
@ -375,6 +259,7 @@ class RoomChat extends HookConsumerWidget {
required bool isSentByMe, required bool isSentByMe,
MessageGroupStatus? groupStatus, MessageGroupStatus? groupStatus,
}) => TextMessageWrapper( }) => TextMessageWrapper(
room: room,
message, message,
content: message.text, content: message.text,
groupStatus: groupStatus, groupStatus: groupStatus,
@ -392,6 +277,7 @@ class RoomChat extends HookConsumerWidget {
MessageGroupStatus? groupStatus, MessageGroupStatus? groupStatus,
}) => TextMessageWrapper( }) => TextMessageWrapper(
message, message,
room: room,
content: message.text, content: message.text,
groupStatus: groupStatus, groupStatus: groupStatus,
onTapReply: notifier.scrollToMessage, onTapReply: notifier.scrollToMessage,
@ -423,6 +309,7 @@ class RoomChat extends HookConsumerWidget {
), ),
child: FlyerChatFileMessage( child: FlyerChatFileMessage(
topWidget: ReplyWidget( topWidget: ReplyWidget(
room: room,
message, message,
onTapReply: notifier.scrollToMessage, onTapReply: notifier.scrollToMessage,
groupStatus: groupStatus, groupStatus: groupStatus,
@ -432,6 +319,7 @@ class RoomChat extends HookConsumerWidget {
), ),
), ),
groupStatus, groupStatus,
room,
), ),
systemMessageBuilder: systemMessageBuilder:
@ -460,7 +348,7 @@ class RoomChat extends HookConsumerWidget {
), ),
), ),
), ),
resolveUser: (_) async => null, resolveUser: notifier.resolveUser,
chatController: controller, chatController: controller,
), ),
), ),
@ -470,11 +358,11 @@ class RoomChat extends HookConsumerWidget {
), ),
if (memberListOpened.value == true && showMembersByDefault) if (memberListOpened.value == true && showMembersByDefault)
MemberList(), MemberList(room),
], ],
), ),
endDrawer: showMembersByDefault ? null : MemberList(), endDrawer: showMembersByDefault ? null : MemberList(room),
); );
} }
} }

View file

@ -1,9 +1,7 @@
import "package:fast_immutable_collections/fast_immutable_collections.dart"; import "package:fast_immutable_collections/fast_immutable_collections.dart";
import "package:flutter/material.dart"; import "package:flutter/material.dart";
import "package:flutter/services.dart";
import "package:flutter_riverpod/flutter_riverpod.dart"; import "package:flutter_riverpod/flutter_riverpod.dart";
import "package:nexus/controllers/client_controller.dart"; import "package:nexus/controllers/client_controller.dart";
import "package:nexus/controllers/via_controller.dart";
import "package:nexus/models/room.dart"; import "package:nexus/models/room.dart";
class RoomMenu extends ConsumerWidget { class RoomMenu extends ConsumerWidget {
@ -18,6 +16,13 @@ class RoomMenu extends ConsumerWidget {
return PopupMenuButton( return PopupMenuButton(
itemBuilder: (_) => [ itemBuilder: (_) => [
// PopupMenuItem(
// onTap: () async {
// final link = await room.matrixToInviteLink();
// await Clipboard.setData(ClipboardData(text: link.toString()));
// },
// child: ListTile(leading: Icon(Icons.link), title: Text("Copy Link")),
// ),
PopupMenuItem( PopupMenuItem(
onTap: () async { onTap: () async {
await client.markRead(room); await client.markRead(room);
@ -28,18 +33,6 @@ class RoomMenu extends ConsumerWidget {
title: Text("Mark as Read"), title: Text("Mark as Read"),
), ),
), ),
PopupMenuItem(
onTap: () async {
final vias = ref.watch(ViaController.provider(room));
await Clipboard.setData(
ClipboardData(
text: "matrix:roomid/${room.metadata?.id.substring(1)}$vias)",
),
);
},
child: ListTile(leading: Icon(Icons.link), title: Text("Copy Link")),
),
PopupMenuItem( PopupMenuItem(
onTap: () => showDialog( onTap: () => showDialog(
context: context, context: context,

View file

@ -1,11 +1,15 @@
import "package:flutter/material.dart"; import "package:flutter/material.dart";
import "package:flutter_hooks/flutter_hooks.dart";
import "package:hooks_riverpod/hooks_riverpod.dart"; import "package:hooks_riverpod/hooks_riverpod.dart";
import "package:nexus/controllers/client_controller.dart";
import "package:nexus/controllers/key_controller.dart"; import "package:nexus/controllers/key_controller.dart";
import "package:nexus/controllers/selected_space_controller.dart"; import "package:nexus/controllers/selected_space_controller.dart";
import "package:nexus/controllers/spaces_controller.dart"; import "package:nexus/controllers/spaces_controller.dart";
import "package:nexus/helpers/extensions/join_room_with_snackbars.dart";
import "package:nexus/pages/settings_page.dart";
import "package:nexus/widgets/avatar_or_hash.dart"; import "package:nexus/widgets/avatar_or_hash.dart";
import "package:nexus/widgets/chat_page/join_dialog.dart";
import "package:nexus/widgets/chat_page/room_menu.dart"; import "package:nexus/widgets/chat_page/room_menu.dart";
import "package:nexus/widgets/form_text_input.dart";
class Sidebar extends HookConsumerWidget { class Sidebar extends HookConsumerWidget {
final bool isDesktop; final bool isDesktop;
@ -88,7 +92,53 @@ class Sidebar extends HookConsumerWidget {
PopupMenuItem( PopupMenuItem(
onTap: () => showDialog( onTap: () => showDialog(
context: context, context: context,
builder: (_) => JoinDialog(ref), builder: (alertContext) => HookBuilder(
builder: (_) {
final roomAlias = useTextEditingController();
return AlertDialog(
title: Text("Join a Room"),
content: Column(
mainAxisSize: MainAxisSize.min,
crossAxisAlignment: CrossAxisAlignment.start,
children: [
Text(
"Enter the room alias, ID, or a Matrix.to link.",
),
SizedBox(height: 12),
FormTextInput(
required: false,
capitalize: true,
controller: roomAlias,
title: "#room:server",
),
],
),
actions: [
TextButton(
onPressed: Navigator.of(context).pop,
child: Text("Cancel"),
),
TextButton(
onPressed: () async {
Navigator.of(alertContext).pop();
final client = ref.watch(
ClientController.provider.notifier,
);
if (context.mounted) {
client.joinRoomWithSnackBars(
context,
roomAlias.text,
ref,
);
}
},
child: Text("Join"),
),
],
);
},
),
), ),
child: ListTile( child: ListTile(
title: Text("Join an existing room (or space)"), title: Text("Join an existing room (or space)"),
@ -96,7 +146,7 @@ class Sidebar extends HookConsumerWidget {
), ),
), ),
PopupMenuItem( PopupMenuItem(
onTap: null, onTap: () {},
child: ListTile( child: ListTile(
title: Text("Create a new room"), title: Text("Create a new room"),
leading: Icon(Icons.add), leading: Icon(Icons.add),
@ -107,15 +157,17 @@ class Sidebar extends HookConsumerWidget {
), ),
IconButton( IconButton(
tooltip: "Explore other rooms", tooltip: "Explore other rooms",
onPressed: null, onPressed: () => showDialog(
context: context,
builder: (context) => AlertDialog(title: Text("To-do")),
),
icon: Icon(Icons.explore), icon: Icon(Icons.explore),
), ),
IconButton( IconButton(
tooltip: "Open settings", tooltip: "Open settings",
onPressed: null, onPressed: () => Navigator.of(
// () => Navigator.of( context,
// context, ).push(MaterialPageRoute(builder: (_) => SettingsPage())),
// ).push(MaterialPageRoute(builder: (_) => SettingsPage())),
icon: Icon(Icons.settings), icon: Icon(Icons.settings),
), ),
], ],

View file

@ -1,214 +0,0 @@
import "package:flutter/material.dart";
import "package:flutter_hooks/flutter_hooks.dart";
import "package:flutter_riverpod/flutter_riverpod.dart";
import "package:intl/intl.dart";
import "package:nexus/controllers/client_controller.dart";
import "package:nexus/controllers/client_state_controller.dart";
import "package:nexus/controllers/power_level_controller.dart";
import "package:nexus/controllers/profile_controller.dart";
import "package:nexus/controllers/selected_room_controller.dart";
import "package:nexus/helpers/extensions/better_when.dart";
import "package:nexus/models/configs/power_level_config.dart";
import "package:nexus/models/membership.dart";
import "package:nexus/models/membership_status.dart";
import "package:nexus/models/requests/membership_action.dart";
import "package:nexus/models/requests/set_membership_request.dart";
import "package:nexus/widgets/avatar_or_hash.dart";
import "package:nexus/main.dart";
import "package:nexus/widgets/chat_page/expandable_image.dart";
import "package:nexus/widgets/form_text_input.dart";
class UserPopover extends ConsumerWidget {
final Membership member;
const UserPopover(this.member, {super.key});
@override
Widget build(BuildContext context, WidgetRef ref) {
final theme = Theme.of(context);
final textTheme = theme.textTheme;
final client = ref.watch(ClientController.provider.notifier);
final roomId = ref.watch(
SelectedRoomController.provider.select((room) => room?.metadata?.id),
);
void showMembershipDialog(MembershipAction action) => showDialog(
context: context,
builder: (context) => HookBuilder(
builder: (context) {
final actionReasonController = useTextEditingController();
return AlertDialog(
title: Text(
"${toBeginningOfSentenceCase(action.name)} ${member.userId}",
),
content: Column(
mainAxisSize: MainAxisSize.min,
crossAxisAlignment: CrossAxisAlignment.start,
children: [
Text(
"Are you sure you want to ${action.name} ${member.userId}?",
),
SizedBox(height: 12),
FormTextInput(
required: false,
capitalize: true,
controller: actionReasonController,
title: "Reason for ${action.name} (optional)",
),
],
),
actions: [
TextButton(
onPressed: Navigator.of(context).pop,
child: Text("Cancel"),
),
TextButton(
onPressed: () {
Navigator.of(context).pop();
client
.setMembership(
SetMembershipRequest(
userId: member.userId,
roomId: roomId!,
action: action,
reason: actionReasonController.text,
),
)
.onError(showError);
},
child: Text(toBeginningOfSentenceCase(action.name)),
),
],
);
},
),
);
return Column(
spacing: 16,
crossAxisAlignment: CrossAxisAlignment.stretch,
children: [
Wrap(
alignment: WrapAlignment.center,
spacing: 16,
runSpacing: 8,
children: [
ExpandableImage(
member.avatarUrl?.toString(),
child: AvatarOrHash(
member.avatarUrl,
member.displayName,
height: 80,
),
),
Column(
crossAxisAlignment: CrossAxisAlignment.start,
children: [
SelectableText(
member.displayName,
style: textTheme.headlineSmall,
),
SelectableText(member.userId, style: textTheme.titleSmall),
SizedBox(height: 4),
ref
.watch(ProfileController.provider(member.userId))
.betterWhen(
loading: SizedBox.shrink,
data: (profile) => Wrap(
spacing: 4,
children: [
for (final pronoun in profile.pronouns.where(
(pronoun) => pronoun.language == "en",
))
Chip(
label: Text(pronoun.summary),
labelStyle: TextStyle(
color: theme.colorScheme.onPrimary,
),
color: WidgetStatePropertyAll(
theme.colorScheme.primary,
),
),
if (profile.timezone != null)
Chip(
label: Text(profile.timezone!),
labelStyle: TextStyle(
color: theme.colorScheme.onPrimary,
),
color: WidgetStatePropertyAll(
theme.colorScheme.primary,
),
),
],
),
),
],
),
],
),
if (member.userId !=
ref.watch(ClientStateController.provider)?.userId &&
roomId != null)
Wrap(
spacing: 8,
runSpacing: 8,
children: [
FilledButton.icon(onPressed: null, label: Text("Message")),
if (ref.watch(
PowerLevelController.provider(
PowerLevelConfig(
eventType: "m.room.member",
action: MembershipAction.kick,
isStateEvent: true,
targetUser: member.userId,
),
),
) &&
member.status == MembershipStatus.join ||
member.status == MembershipStatus.invite)
FilledButton.icon(
onPressed: () => showMembershipDialog(MembershipAction.kick),
label: Text("Kick"),
style: ButtonStyle(
backgroundColor: WidgetStatePropertyAll(
theme.colorScheme.error,
),
foregroundColor: WidgetStatePropertyAll(
theme.colorScheme.onError,
),
),
),
if (ref.watch(
PowerLevelController.provider(
PowerLevelConfig(
eventType: "m.room.member",
action: MembershipAction.ban,
isStateEvent: true,
targetUser: member.userId,
),
),
))
ElevatedButton.icon(
onPressed: () => showMembershipDialog(
member.status == MembershipStatus.ban
? MembershipAction.unban
: MembershipAction.ban,
),
label: Text(
member.status == MembershipStatus.ban ? "Unban" : "Ban",
),
style: ButtonStyle(
backgroundColor: WidgetStatePropertyAll(
theme.colorScheme.errorContainer,
),
foregroundColor: WidgetStatePropertyAll(
theme.colorScheme.onErrorContainer,
),
),
),
],
),
],
);
}
}

View file

@ -1,83 +1,59 @@
import "package:flutter/material.dart"; import "package:flutter/material.dart";
import "package:flutter_chat_core/flutter_chat_core.dart"; import "package:flutter_chat_core/flutter_chat_core.dart";
import "package:nexus/models/room.dart";
import "package:nexus/widgets/chat_page/lazy_loading/message_avatar.dart"; import "package:nexus/widgets/chat_page/lazy_loading/message_avatar.dart";
import "package:nexus/widgets/chat_page/lazy_loading/message_displayname.dart"; import "package:nexus/widgets/chat_page/lazy_loading/message_displayname.dart";
import "package:nexus/widgets/chat_page/wrappers/reaction_row.dart";
import "package:timeago/timeago.dart";
class MessageWrapper extends StatelessWidget { class MessageWrapper extends StatelessWidget {
final Message message; final Message message;
final Widget child; final Widget child;
final Room room;
final MessageGroupStatus? groupStatus; final MessageGroupStatus? groupStatus;
const MessageWrapper(this.message, this.child, this.groupStatus, {super.key}); const MessageWrapper(
this.message,
this.child,
this.groupStatus,
this.room, {
super.key,
});
@override @override
Widget build(BuildContext context) { Widget build(BuildContext context) => ClipRRect(
final theme = Theme.of(context); borderRadius: BorderRadius.all(Radius.circular(12)),
final error = message.metadata?["error"]; child: AnimatedContainer(
padding: message.metadata?["flashing"] == true
return ClipRRect( ? EdgeInsets.all(8)
borderRadius: BorderRadius.all(Radius.circular(12)), : EdgeInsets.all(0),
child: AnimatedContainer( color: message.metadata?["flashing"] == true
padding: message.metadata?["flashing"] == true ? Theme.of(context).colorScheme.onSurface.withAlpha(50)
? EdgeInsets.all(8) : Colors.transparent,
: EdgeInsets.all(0), duration: Duration(milliseconds: 250),
color: message.metadata?["flashing"] == true child: Row(
? Theme.of(context).colorScheme.onSurface.withAlpha(50) spacing: 8,
: Colors.transparent, crossAxisAlignment: CrossAxisAlignment.start,
duration: Duration(milliseconds: 250), children: [
child: Row( groupStatus?.isFirst != false
spacing: 8, ? MessageAvatar(message, room, height: 40)
crossAxisAlignment: CrossAxisAlignment.start, : SizedBox(width: 40),
children: [ Expanded(
groupStatus?.isFirst != false child: Column(
? MessageAvatar(message, height: 40) crossAxisAlignment: CrossAxisAlignment.start,
: SizedBox(width: 40), spacing: 4,
Expanded( children: [
child: Column( if (groupStatus?.isFirst != false)
crossAxisAlignment: CrossAxisAlignment.start, MessageDisplayname(
spacing: 4, message,
children: [ room,
if (groupStatus?.isFirst != false) style: Theme.of(context).textTheme.titleMedium?.copyWith(
Row( fontWeight: FontWeight.bold,
spacing: 4,
children: [
Flexible(
child: MessageDisplayname(
message,
style: theme.textTheme.titleMedium?.copyWith(
fontWeight: FontWeight.bold,
),
),
),
if (message.deliveredAt != null &&
groupStatus?.isFirst != false)
Tooltip(
message: message.deliveredAt!.toString(),
child: Text(
format(message.deliveredAt!),
style: theme.textTheme.labelSmall?.copyWith(
color: Colors.grey,
),
),
),
],
), ),
child, ),
if (error != null && error != "not sent") child,
Text( ],
error,
style: theme.textTheme.labelSmall?.copyWith(
color: theme.colorScheme.error,
),
),
ReactionRow(message),
],
),
), ),
], ),
), ],
), ),
); ),
} );
} }

View file

@ -1,116 +0,0 @@
import "package:cross_cache/cross_cache.dart";
import "package:fast_immutable_collections/fast_immutable_collections.dart";
import "package:flutter/material.dart";
import "package:flutter_chat_core/flutter_chat_core.dart";
import "package:flutter_hooks/flutter_hooks.dart";
import "package:flutter_riverpod/flutter_riverpod.dart";
import "package:nexus/controllers/client_state_controller.dart";
import "package:nexus/controllers/cross_cache_controller.dart";
import "package:nexus/controllers/room_chat_controller.dart";
import "package:nexus/controllers/selected_room_controller.dart";
import "package:nexus/helpers/extensions/get_headers.dart";
import "package:nexus/helpers/extensions/mxc_to_https.dart";
import "package:nexus/main.dart";
class ReactionRow extends ConsumerWidget {
final Message message;
const ReactionRow(this.message, {super.key});
@override
Widget build(BuildContext context, WidgetRef ref) {
final clientState = ref.watch(ClientStateController.provider);
return Wrap(
spacing: 4,
runSpacing: 4,
children: clientState?.homeserverUrl == null || message.reactions == null
? []
: message.reactions!
.mapTo(
(reaction, reactors) => HookBuilder(
builder: (context) {
final enabled = useState(true);
final selected = reactors.contains(clientState!.userId);
return Tooltip(
message: reactors.join(", "),
child: ChoiceChip(
showCheckmark: false,
selected: selected,
label: Row(
mainAxisSize: MainAxisSize.min,
spacing: 8,
children: [
Flexible(
child: reaction.startsWith("mxc://")
? Image(
height: 20,
image: CachedNetworkImage(
headers: ref.headers,
Uri.parse(reaction)
.mxcToHttps(
clientState.homeserverUrl!,
)
.toString(),
ref.watch(
CrossCacheController.provider,
),
),
)
: Text(
reaction,
overflow: TextOverflow.ellipsis,
),
),
Text(
reactors.length.toString(),
overflow: TextOverflow.ellipsis,
),
],
),
onSelected: enabled.value
? (value) async {
enabled.value = false;
try {
final roomId = ref.watch(
SelectedRoomController.provider.select(
(value) => value?.metadata?.id,
),
);
if (roomId == null ||
clientState.userId == null) {
return;
}
final controller = ref.watch(
RoomChatController.provider(
roomId,
).notifier,
);
if (selected) {
await controller
.removeReaction(
reaction,
message,
clientState.userId!,
)
.onError(showError);
} else {
await controller
.sendReaction(reaction, message)
.onError(showError);
}
} finally {
enabled.value = true;
}
}
: null,
),
);
},
),
)
.toList(),
);
}
}

View file

@ -1,21 +1,15 @@
import "package:cross_cache/cross_cache.dart";
import "package:flutter/material.dart"; import "package:flutter/material.dart";
import "package:flutter_chat_core/flutter_chat_core.dart"; import "package:flutter_chat_core/flutter_chat_core.dart";
import "package:flutter_link_previewer/flutter_link_previewer.dart"; import "package:flutter_link_previewer/flutter_link_previewer.dart";
import "package:flutter_linkify/flutter_linkify.dart"; import "package:nexus/models/room.dart";
import "package:flutter_riverpod/flutter_riverpod.dart";
import "package:nexus/controllers/cross_cache_controller.dart";
import "package:nexus/controllers/url_preview_controller.dart";
import "package:nexus/helpers/extensions/better_when.dart";
import "package:nexus/helpers/extensions/get_headers.dart";
import "package:nexus/helpers/launch_helper.dart";
import "package:nexus/widgets/chat_page/html/html.dart"; import "package:nexus/widgets/chat_page/html/html.dart";
import "package:nexus/widgets/chat_page/wrappers/message_wrapper.dart"; import "package:nexus/widgets/chat_page/wrappers/message_wrapper.dart";
import "package:nexus/widgets/chat_page/reply_widget.dart"; import "package:nexus/widgets/chat_page/reply_widget.dart";
class TextMessageWrapper extends ConsumerWidget { class TextMessageWrapper extends StatelessWidget {
final Message message; final Message message;
final String? content; final String? content;
final Room room;
final MessageGroupStatus? groupStatus; final MessageGroupStatus? groupStatus;
final Future<void> Function(Message oldMessage, Message newMessage) final Future<void> Function(Message oldMessage, Message newMessage)
updateMessage; updateMessage;
@ -27,6 +21,7 @@ class TextMessageWrapper extends ConsumerWidget {
this.message, { this.message, {
this.content, this.content,
this.onTapReply, this.onTapReply,
required this.room,
required this.updateMessage, required this.updateMessage,
required this.groupStatus, required this.groupStatus,
required this.isSentByMe, required this.isSentByMe,
@ -35,17 +30,11 @@ class TextMessageWrapper extends ConsumerWidget {
}); });
@override @override
Widget build(BuildContext context, WidgetRef ref) { Widget build(BuildContext context) {
final theme = Theme.of(context); final theme = Theme.of(context);
final colorScheme = theme.colorScheme; final colorScheme = theme.colorScheme;
final textMessage = message is TextMessage ? message as TextMessage : null; final textMessage = message is TextMessage ? message as TextMessage : null;
final link = textMessage == null
? null
: RegExp(
r'''https?://[^\s"'<>]+''',
).allMatches(textMessage.text).firstOrNull?.group(0);
return MessageWrapper( return MessageWrapper(
message, message,
ClipRRect( ClipRRect(
@ -54,9 +43,7 @@ class TextMessageWrapper extends ConsumerWidget {
padding: EdgeInsets.symmetric(vertical: 8, horizontal: 12), padding: EdgeInsets.symmetric(vertical: 8, horizontal: 12),
decoration: BoxDecoration( decoration: BoxDecoration(
color: isSentByMe color: isSentByMe
? (message.id.startsWith("~") ? colorScheme.primaryContainer
? colorScheme.onPrimary
: colorScheme.primaryContainer)
: colorScheme.surfaceContainer, : colorScheme.surfaceContainer,
), ),
child: Column( child: Column(
@ -64,84 +51,65 @@ class TextMessageWrapper extends ConsumerWidget {
children: [ children: [
ReplyWidget( ReplyWidget(
message, message,
room: room,
groupStatus: groupStatus, groupStatus: groupStatus,
onTapReply: onTapReply, onTapReply: onTapReply,
), ),
if (content != null) if (content != null)
message.metadata?["format"] == "org.matrix.custom.html" Html(
? Html( textStyle: message.metadata?["big"] == true
textStyle: message.metadata?["big"] == true ? TextStyle(fontSize: 32)
? TextStyle(fontSize: 32) : null,
: null, content!
content!.replaceAllMapped( .replaceAllMapped(
RegExp( RegExp(
"(<a\\b[^>]*>.*?<\\/a>)|(\\bhttps?:\\/\\/[^\\s<]+)", "(<a\\b[^>]*>.*?<\\/a>)|(\\bhttps?:\\/\\/[^\\s<]+)",
caseSensitive: false, caseSensitive: false,
dotAll: true, ),
), (m) {
(m) { // If it's already an <a> tag, leave it unchanged
// If it's already an <a> tag, leave it unchanged if (m.group(1) != null) {
if (m.group(1) != null) { return m.group(1)!;
return m.group(1)!; }
}
// Otherwise, wrap the bare URL // Otherwise, wrap the bare URL
final url = m.group(2)!; final url = m.group(2)!;
return "<a href=\"$url\">$url</a>"; return "<a href=\"$url\">$url</a>";
}, },
),
) )
: Linkify( .replaceAll("\n", "<br class=\"fake-break\"/>"),
text: content!, ),
options: LinkifyOptions(humanize: false),
onOpen: (link) => ref
.watch(LaunchHelper.provider)
.launchUrl(Uri.parse(link.url)),
linkStyle: TextStyle(
color: Theme.of(context).colorScheme.primary,
),
),
if (textMessage?.editedAt != null) if (textMessage?.editedAt != null)
Text("(edited)", style: theme.textTheme.labelSmall), Text("(edited)", style: theme.textTheme.labelSmall),
if (link != null) if (textMessage != null)
ref LinkPreview(
.watch(UrlPreviewController.provider(link)) text: textMessage.text,
.betterWhen( backgroundColor: isSentByMe
loading: SizedBox.shrink, ? colorScheme.inversePrimary
data: (preview) => preview == null : colorScheme.surfaceContainerLow,
? SizedBox.shrink() outsidePadding: EdgeInsets.only(top: 4),
: LinkPreview( insidePadding: EdgeInsets.symmetric(
onTap: (url) => ref vertical: 8,
.watch(LaunchHelper.provider) horizontal: 16,
.launchUrl(Uri.parse(url)), ),
imageBuilder: (url) => Image( linkPreviewData: message.metadata?["linkPreviewData"],
image: CachedNetworkImage( onLinkPreviewDataFetched: (linkPreviewData) => updateMessage(
url, message,
ref.watch(CrossCacheController.provider), message.copyWith(
headers: ref.headers, metadata: {
), ...(message.metadata ?? {}),
fit: BoxFit.cover, "linkPreviewData": linkPreviewData,
errorBuilder: (_, _, _) => SizedBox.shrink(), },
),
text: link,
backgroundColor: isSentByMe
? colorScheme.inversePrimary
: colorScheme.surfaceContainerLow,
outsidePadding: EdgeInsets.only(top: 4),
insidePadding: EdgeInsets.symmetric(
vertical: 8,
horizontal: 16,
),
linkPreviewData: preview,
onLinkPreviewDataFetched: (_) => null,
),
), ),
),
),
if (extra != null) extra!, if (extra != null) extra!,
], ],
), ),
), ),
), ),
groupStatus, groupStatus,
room,
); );
} }
} }

View file

@ -26,7 +26,6 @@ flutter.buildFlutterApplication {
dynamic_system_colors = "sha256-es6rjMK1drkqZBKYUP77yw/q5+0uLwWOEDOXRawy3Dc="; dynamic_system_colors = "sha256-es6rjMK1drkqZBKYUP77yw/q5+0uLwWOEDOXRawy3Dc=";
flutter_chat_ui = "sha256-4fuag7lRH5cMBFD3fUzj2K541JwXLoz8HF/4OMr3uhk="; flutter_chat_ui = "sha256-4fuag7lRH5cMBFD3fUzj2K541JwXLoz8HF/4OMr3uhk=";
flutter_link_previewer = "sha256-4fuag7lRH5cMBFD3fUzj2K541JwXLoz8HF/4OMr3uhk="; flutter_link_previewer = "sha256-4fuag7lRH5cMBFD3fUzj2K541JwXLoz8HF/4OMr3uhk=";
emoji_text_field = "sha256-F0QbIHP3wpKoL6QbJ20Oun0SsOdwnXe84IqsK2ad85w=";
}; };
postInstall = '' postInstall = ''

View file

@ -354,15 +354,6 @@ packages:
url: "https://github.com/hasali19/flutter_dynamic_system_colors" url: "https://github.com/hasali19/flutter_dynamic_system_colors"
source: git source: git
version: "1.8.0" version: "1.8.0"
emoji_text_field:
dependency: "direct main"
description:
path: "."
ref: HEAD
resolved-ref: "0e90703a6e876939be70bd1816c49cf14474de61"
url: "https://github.com/Henry-Hiles/emoji_text_field"
source: git
version: "1.0.0"
encrypt: encrypt:
dependency: transitive dependency: transitive
description: description:
@ -475,10 +466,11 @@ packages:
flutter_chat_ui: flutter_chat_ui:
dependency: "direct main" dependency: "direct main"
description: description:
name: flutter_chat_ui path: "packages/flutter_chat_ui"
sha256: cfbaac38f429beb33d9cc1ca920ae7ccbadbed282c99335d590d61306d3a3d0f ref: HEAD
url: "https://pub.dev" resolved-ref: "03be67c8c81c8f637672ee03dd8f082d2c223627"
source: hosted url: "https://github.com/Henry-Hiles/flutter_chat_ui"
source: git
version: "2.11.1" version: "2.11.1"
flutter_hooks: flutter_hooks:
dependency: "direct main" dependency: "direct main"
@ -499,19 +491,12 @@ packages:
flutter_link_previewer: flutter_link_previewer:
dependency: "direct main" dependency: "direct main"
description: description:
name: flutter_link_previewer path: "packages/flutter_link_previewer"
sha256: "346f345064e65bc8bf739bccf19d6d6ca50f8183ffc52e452afa58c06ee2cbf7" ref: HEAD
url: "https://pub.dev" resolved-ref: "03be67c8c81c8f637672ee03dd8f082d2c223627"
source: hosted url: "https://github.com/Henry-Hiles/flutter_chat_ui"
source: git
version: "4.2.0" version: "4.2.0"
flutter_linkify:
dependency: "direct main"
description:
name: flutter_linkify
sha256: "74669e06a8f358fee4512b4320c0b80e51cffc496607931de68d28f099254073"
url: "https://pub.dev"
source: hosted
version: "6.0.0"
flutter_lints: flutter_lints:
dependency: "direct dev" dependency: "direct dev"
description: description:
@ -672,7 +657,7 @@ packages:
source: hosted source: hosted
version: "0.15.6" version: "0.15.6"
http: http:
dependency: "direct main" dependency: transitive
description: description:
name: http name: http
sha256: "87721a4a50b19c7f1d49001e51409bddc46303966ce89a65af4f4e6004896412" sha256: "87721a4a50b19c7f1d49001e51409bddc46303966ce89a65af4f4e6004896412"
@ -839,14 +824,6 @@ packages:
url: "https://pub.dev" url: "https://pub.dev"
source: hosted source: hosted
version: "3.0.2" version: "3.0.2"
linkify:
dependency: transitive
description:
name: linkify
sha256: "4139ea77f4651ab9c315b577da2dd108d9aa0bd84b5d03d33323f1970c645832"
url: "https://pub.dev"
source: hosted
version: "5.0.0"
lints: lints:
dependency: transitive dependency: transitive
description: description:
@ -1380,14 +1357,6 @@ packages:
url: "https://pub.dev" url: "https://pub.dev"
source: hosted source: hosted
version: "0.1.0+1" version: "0.1.0+1"
timeago:
dependency: "direct main"
description:
name: timeago
sha256: b05159406a97e1cbb2b9ee4faa9fb096fe0e2dfcd8b08fcd2a00553450d3422e
url: "https://pub.dev"
source: hosted
version: "3.7.1"
typed_data: typed_data:
dependency: transitive dependency: transitive
description: description:

View file

@ -40,8 +40,14 @@ dependencies:
flyer_chat_image_message: ^2.2.2 flyer_chat_image_message: ^2.2.2
flyer_chat_system_message: ^2.1.13 flyer_chat_system_message: ^2.1.13
flyer_chat_file_message: ^2.3.1 flyer_chat_file_message: ^2.3.1
flutter_chat_ui: ^2.11.1 flutter_chat_ui:
flutter_link_previewer: ^4.2.0 git:
url: https://github.com/Henry-Hiles/flutter_chat_ui
path: packages/flutter_chat_ui
flutter_link_previewer:
git:
url: https://github.com/Henry-Hiles/flutter_chat_ui
path: packages/flutter_link_previewer
color_hash: ^1.0.1 color_hash: ^1.0.1
flutter_widget_from_html_core: ^0.17.0 flutter_widget_from_html_core: ^0.17.0
flutter_svg: ^2.2.2 flutter_svg: ^2.2.2
@ -55,12 +61,6 @@ dependencies:
hooks: ^1.0.0 hooks: ^1.0.0
code_assets: ^1.0.0 code_assets: ^1.0.0
ffigen: ^20.1.1 ffigen: ^20.1.1
timeago: ^3.7.1
http: ^1.6.0
flutter_linkify: ^6.0.0
emoji_text_field:
git:
url: https://github.com/Henry-Hiles/emoji_text_field
dev_dependencies: dev_dependencies:
build_runner: ^2.4.11 build_runner: ^2.4.11
@ -76,7 +76,7 @@ flutter_launcher_icons:
android: true android: true
image_path: assets/icon.png image_path: assets/icon.png
adaptive_icon_background: assets/background.png adaptive_icon_background: assets/background.png
adaptive_icon_foreground: assets/smallerForeground.png adaptive_icon_foreground: assets/foreground.png
remove_alpha_ios: true remove_alpha_ios: true
windows: windows:
generate: true generate: true