Henry-Hiles/nexus
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

messages rendering

Browse source
This commit is contained in:
Henry Hiles 2025-11-11 21:00:28 -05:00
commit d1f070e5c8
No known key found for this signature in database
8 changed files with 387 additions and 122 deletions
Download patch file Download diff file Expand all files Collapse all files

18
lib/controllers/current_room_controller.dart Normal file
View file

@ -0,0 +1,18 @@
import "package:flutter_riverpod/flutter_riverpod.dart";
import "package:nexus/controllers/spaces_controller.dart";
import "package:nexus/helpers/extension_helper.dart";
import "package:nexus/models/full_room.dart";
class CurrentRoomController extends AsyncNotifier<FullRoom> {
@override
Future<FullRoom> build() async => (await ref.watch(
SpacesController.provider.future,
))[0].children[0].roomData.fullRoom;
void set(FullRoom room) => state = AsyncValue.data(room);
static final provider =
AsyncNotifierProvider<CurrentRoomController, FullRoom>(
CurrentRoomController.new,
);
}

125
lib/controllers/room_chat_controller.dart
View file

@ -1,27 +1,132 @@
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:matrix/matrix.dart";
class RoomChatController extends Notifier<ChatController> {
RoomChatController(this.roomId);
final String roomId;
class RoomChatController extends AsyncNotifier<ChatController> {
RoomChatController(this.room);
final Room room;
@override
InMemoryChatController build() => InMemoryChatController();
Future<ChatController> build() async {
final timeline = await room.getTimeline();
// void setRoom(Room room) => state = (await ref.watch(ClientController.provider.future));
final controller = InMemoryChatController(
messages: (await Future.wait(
timeline.events.map(toMessage),
)).toList().reversed.nonNulls.toList(),
);
return controller;
}
void send(String message) {
state.insertMessage(
Future<void> insertMessage(Message message) async {
final controller = await future;
return controller.insertMessage(message);
}
Future<void> updateMessage(Message message, Message newMessage) async {
final controller = await future;
return controller.updateMessage(message, newMessage);
}
Future<Message?> toMessage(Event event) async {
final replyId = event.relationshipType == RelationshipTypes.reply
? event.relationshipEventId
: null;
final metadata = {
"eventType": event.type,
"displayName": event.senderFromMemoryOrFallback.displayName,
};
return event.redacted
? Message.text(
metadata: metadata,
id: event.eventId,
authorId: event.senderId,
text: "~~This message has been redacted.~~",
deletedAt: event.redactedBecause?.originServerTs,
)
: switch (event.type) {
EventTypes.Message => switch (event.messageType) {
MessageTypes.Image => Message.image(
metadata: metadata,
id: event.eventId,
authorId: event.senderId,
source: (await event.getAttachmentUri()).toString(),
replyToMessageId: replyId,
deliveredAt: event.originServerTs,
),
MessageTypes.Audio => Message.audio(
metadata: metadata,
id: event.eventId,
authorId: event.senderId,
text: event.body,
replyToMessageId: replyId,
source: (await event.getAttachmentUri()).toString(),
deliveredAt: event.originServerTs,
duration: Duration(hours: 1),
),
MessageTypes.File => Message.file(
name: event.content["filename"].toString(),
metadata: metadata,
id: event.eventId,
authorId: event.senderId,
source: (await event.getAttachmentUri()).toString(),
replyToMessageId: replyId,
deliveredAt: event.originServerTs,
),
_ => Message.text(
metadata: metadata,
id: event.eventId,
authorId: event.senderId,
text: event.body,
replyToMessageId: replyId,
deliveredAt: event.originServerTs,
),
},
EventTypes.RoomMember => Message.system(
metadata: metadata,
id: event.eventId,
authorId: event.senderId,
text:
"${event.senderFromMemoryOrFallback.calcDisplayname()} joined the room.",
),
EventTypes.Redaction => null,
_ => Message.unsupported(
metadata: metadata,
id: event.eventId,
authorId: event.senderId,
replyToMessageId: replyId,
),
};
}
Future<void> send(String message) async {
insertMessage(
Message.text(
id: DateTime.now().millisecondsSinceEpoch.toString(),
authorId: "foo",
authorId: room.client.userID!,
text: message,
),
);
await room.sendTextEvent(message);
}
static final provider =
NotifierProvider.family<RoomChatController, ChatController, String>(
Future<chat.User> resolveUser(String id) async {
final user = await room.client.getUserProfile(id);
return chat.User(
id: id,
name: user.displayname,
imageSource: (await user.avatarUrl?.getThumbnailUri(
room.client,
width: 24,
height: 24,
))?.toString(),
);
}
static final provider = AsyncNotifierProvider.family
.autoDispose<RoomChatController, ChatController, Room>(
RoomChatController.new,
);
}