show messages whilst sending

lib/controllers/client_controller.dart

@@ -15,7 +15,6 @@ import "package:nexus/controllers/top_level_spaces_controller.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/content/content.dart";
 import "package:nexus/models/event.dart";
 import "package:nexus/models/paginate.dart";
 import "package:nexus/models/requests/get_event_request.dart";
@@ -79,10 +78,17 @@ class ClientController extends AsyncNotifier<int> {
                 break;
               case "send_complete":
                 final event = Event.fromJson(decodedMuksEvent["event"]);
+                ref
+                    .watch(RoomsController.provider.notifier)
+                    .update(
+                      {
+                        event.roomId: Room(
+                          events: {event.rowId: event}.toIMap(),
+                        ),
+                      }.toIMap(),
+                      const ISet.empty(),
+                    );
 
-                if (event.type == EventType.message.type) {
-                  // ref.watch(provider.notifier).addEvent(event); TODO
-                }
                 break;
               case "sync_complete":
                 final syncData = SyncData.fromJson(decodedMuksEvent);

lib/controllers/room_chat_controller.dart

@@ -44,12 +44,16 @@ class RoomChatController extends AsyncNotifier<IList<Event>> {
       loadOlder();
     }
 
-    return room.timeline
+    return IMap<int, int?>.fromValues(
+          keyMapper: (id) => 9999999 + (id ?? 0),
+          values: room.sticky,
+        )
+        .addAll(room.timeline)
         .toEntryIList(compare: (a, b) => (b?.key ?? 0).compareTo(a?.key ?? 0))
         .map((entry) {
-          if (entry.value == null) return null;
+          final foundEvent = entry.value == null
-
+              ? null
-          final foundEvent = room.events[entry.value!];
+              : room.events[entry.value!];
 
           final editedEvent =
               foundEvent == null || foundEvent.lastEditRowId == 0
@@ -153,23 +157,17 @@ class RoomChatController extends AsyncNotifier<IList<Event>> {
       ),
     );
 
-    // TODO: Add new event to timeline whilst its sending
+    ref
-    // ref
+        .watch(RoomsController.provider.notifier)
-    //     .watch(RoomsController.provider.notifier)
+        .update(
-    //     .update(
+          {
-    //       {
+            roomId: Room(
-    //         roomId: Room(
+              events: {event.rowId: event}.toIMap(),
-    //           events: [event].toIList(),
+              sticky: {event.rowId}.toISet(),
-    //           timeline: [
+            ),
-    //             TimelineRowTuple(
+          }.toIMap(),
-    //               timelineRowId: event.timelineRowId,
+          const ISet.empty(),
-    //               eventRowId: event.rowId,
+        );
-    //             ),
-    //           ].toIList(),
-    //         ),
-    //       }.toIMap(),
-    //       const ISet.empty(),
-    //     );
   }
 
   Future<void> removeReaction(

lib/controllers/rooms_controller.dart

@@ -50,6 +50,13 @@ class RoomsController extends Notifier<IMap<String, Room>> {
         roomId,
         existing?.copyWith(
               hasMore: incoming.hasMore,
+              sticky:
+                  (incoming.sticky.isEmpty == true
+                          ? existing.sticky
+                          : existing.sticky.addAll(incoming.sticky))
+                      .removeWhere(
+                        (rowId) => incoming.timeline.values.contains(rowId),
+                      ),
               metadata: incoming.metadata ?? existing.metadata,
               events: incoming.events.isEmpty
                   ? existing.events

lib/models/room.dart

@@ -28,11 +28,13 @@ abstract class Room with _$Room {
 
   /// [timeline] is an IMap of timelineRowId to eventRowId
   /// [events] is an IMap of eventRowId to event
+  /// [sticky] is an ISet of eventRowId
   const factory Room({
     @JsonKey(name: "meta") RoomMetadata? metadata,
     @Default(IMap.empty())
     @JsonKey(fromJson: Room.timelineTupleJsonToIMap)
     IMap<int, int?> timeline,
+    @Default(ISet.empty()) ISet<int> sticky,
 
     @Default(IMap.empty())
     @JsonKey(fromJson: Room.eventsJsonToIMap)

lib/widgets/composer/composer.dart

@@ -165,12 +165,14 @@ class Composer extends HookConsumerWidget {
                         ),
                       ]
                     : [
-                        Padding(
+                        Expanded(
+                          child: Padding(
                             padding: EdgeInsetsGeometry.all(8),
                             child: Text(
                               "You don't have permission to send messages in this room...",
                             ),
                           ),
+                        ),
                       ],
               ),
             ),

lib/widgets/lazy_loading/message_avatar.dart

@@ -1,7 +1,6 @@
 import "package:flutter/material.dart";
 import "package:flutter_riverpod/flutter_riverpod.dart";
 import "package:nexus/controllers/author_controller.dart";
-import "package:nexus/helpers/extensions/better_when.dart";
 import "package:nexus/helpers/extensions/get_localpart.dart";
 import "package:nexus/helpers/extensions/show_user_popover.dart";
 import "package:nexus/models/event.dart";
@@ -13,24 +12,22 @@ class MessageAvatar extends ConsumerWidget {
   const MessageAvatar(this.event, {this.height = 24, super.key});
 
   @override
-  Widget build(BuildContext context, WidgetRef ref) => ref
+  Widget build(BuildContext context, WidgetRef ref) =>
-      .watch(AuthorController.provider(event))
+      switch (ref.watch(AuthorController.provider(event))) {
-      .betterWhen(
+        AsyncData(:final value) || AsyncLoading(:final value?) => InkWell(
-        data: (membership) => InkWell(
           onTapUp: (details) {
             context.showUserPopover(
-              membership,
+              value,
               event.sender,
               globalPosition: details.globalPosition,
             );
           },
           child: AvatarOrHash(
-            membership.avatarUrl,
+            value.avatarUrl,
-            membership.displayName ?? event.sender.localpart,
+            value.displayName ?? event.sender.localpart,
             height: height,
           ),
         ),
-        loading: () =>
+        _ => AvatarOrHash(null, event.sender.localpart, height: height),
-            AvatarOrHash(null, event.sender.localpart, height: height),
+      };
-      );
 }

lib/widgets/renderers/event.dart

@@ -446,11 +446,8 @@ class EventRenderer extends ConsumerWidget {
               ),
             ),
 
-          if (event.content is! MessageContent)
+          ...[
-            Padding(
+            if (event.content is! MessageContent) ReactionRow(event),
-              padding: EdgeInsetsGeometry.only(left: 12),
-              child: ReactionRow(event),
-            ),
 
             if (event.sendError != null && event.sendError != "not sent")
               Text(
@@ -459,6 +456,12 @@ class EventRenderer extends ConsumerWidget {
                   color: theme.colorScheme.error,
                 ),
               ),
+          ].map(
+            (child) => Padding(
+              padding: EdgeInsetsGeometry.only(left: 4),
+              child: child,
+            ),
+          ),
         ] else if (textOnly)
           Text("Unknown event type", style: errorStyle),
       ],