Nexus/nexus
Nexus/nexus
4
4
Fork 5
Code Issues 6 Pull requests Projects Releases Packages Wiki Activity

Remove flutter chat #26

Manually merged
Henry-Hiles merged 108 commits from remove-flutter-chat into main 2026-05-22 15:26:28 -04:00
Conversation 1 Commits 108 Files changed 111 +18 -10
1 changed files with 18 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files
Showing only changes of commit 34e6c07d8d - Show all commits

temp isolate

Prev Next
Henry Hiles 2026-05-21 12:16:01 -04:00
commit 34e6c07d8d
Signed by: Henry-Hiles
SSH key fingerprint: SHA256:VKQUdS31Q90KvX7EkKMHMBpUspcmItAh86a+v7PGiIs

28
lib/controllers/rooms_controller.dart
View file

@ -1,3 +1,5 @@
import "dart:isolate";
import "package:fast_immutable_collections/fast_immutable_collections.dart"; 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/models/event.dart"; import "package:nexus/models/event.dart";
@ -38,7 +40,11 @@ class RoomsController extends Notifier<IMap<String, Room>> {
); );
Future<void> update(IMap<String, Room> rooms, ISet<String> leftRooms) async { Future<void> update(IMap<String, Room> rooms, ISet<String> leftRooms) async {
final merged = rooms.entries.fold(state, (acc, entry) { final merged = await rooms.entries.fold(Future.sync(() => state), (
accF,
entry,
) async {
final acc = await accF;
final roomId = entry.key; final roomId = entry.key;
final incoming = entry.value; final incoming = entry.value;
final existing = acc[roomId]; final existing = acc[roomId];
@ -51,15 +57,18 @@ class RoomsController extends Notifier<IMap<String, Room>> {
events: incoming.events.isEmpty events: incoming.events.isEmpty
? existing.events ? existing.events
: existing.events.addAll(incoming.events), : existing.events.addAll(incoming.events),
state: incoming.state.entries.fold( state: await Isolate.run(() {
existing.state, final state = incoming.state.entries.fold(
(previousValue, event) => previousValue.add( existing.state,
event.key, (previousValue, event) => previousValue.add(
(previousValue[event.key] ?? const IMap.empty()).addAll( event.key,
event.value, (previousValue[event.key] ?? const IMap.empty()).addAll(
event.value,
),
), ),
), );
), return state;
}),
reset: false, reset: false,
hasFetchedMembers: hasFetchedMembers:
incoming.hasFetchedMembers || existing.hasFetchedMembers, incoming.hasFetchedMembers || existing.hasFetchedMembers,
@ -86,7 +95,6 @@ class RoomsController extends Notifier<IMap<String, Room>> {
merged, merged,
(acc, roomId) => acc.remove(roomId), (acc, roomId) => acc.remove(roomId),
); );
state = prunedList; state = prunedList;
} }