help4bis
b941cdfe4b
Critical: - Fix MXC URI resolution: all avatars/images now resolve mxc:// to HTTP - Sync persistence: only write changed rooms, batch message upserts - lastActivityAt uses room.lastEvent.originServerTs, not creation time High: - Shared MatrixAvatar widget replaces 6 duplicate implementations - CallScreen decodes roomId before LiveKit JWT fetch - Decline button actually dismisses incoming call overlay - EventTypes constants replace raw string literals - LiveKitService uses lazy auth reads, onDispose disconnects Medium: - CallController is keepAlive with timer/room cleanup - authRepository is keepAlive (used from keepAlive notifier) - StreamController not closed in stopListening (crash fix) - Index on messages.roomId for query performance - 400ms debounce on user search - Static DateFormat in MessageBubble - Hardcoded strings replaced with AppConfig refs - Duplicate isDirectMessage field removed from RoomModel - E2EE profile claim corrected to Phase 3 Shared utilities: - lib/shared/widgets/matrix_avatar.dart - lib/shared/utils/mxc_url.dart - lib/shared/utils/room_preview.dart - lib/shared/utils/matrix_id.dart rawJson column removed (unused, caused main-thread jsonEncode) Schema migrated to v2 with roomId index. Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
62 lines
1.9 KiB
Dart
62 lines
1.9 KiB
Dart
// Version: 1.2.0 | Created: 2026-04-01 | Updated: 2026-04-02
|
|
// Rooms repository. Reads room list from the Matrix SDK client.
|
|
|
|
import 'package:matrix/matrix.dart';
|
|
import 'package:riverpod_annotation/riverpod_annotation.dart';
|
|
|
|
import '../../../core/network/matrix_client.dart';
|
|
import '../../../shared/utils/mxc_url.dart';
|
|
import '../../../shared/utils/room_preview.dart';
|
|
import '../domain/room_model.dart';
|
|
|
|
part 'rooms_repository.g.dart';
|
|
|
|
@riverpod
|
|
RoomsRepository roomsRepository(Ref ref) {
|
|
return RoomsRepository(client: ref.watch(matrixClientProvider));
|
|
}
|
|
|
|
class RoomsRepository {
|
|
RoomsRepository({required Client client}) : _client = client;
|
|
|
|
final Client _client;
|
|
|
|
/// Returns the current room list, sorted unread-first then by last activity.
|
|
List<RoomModel> getRooms() {
|
|
final rooms = _client.rooms;
|
|
final models = rooms.map(_toModel).toList();
|
|
|
|
models.sort((a, b) {
|
|
// Unread rooms first.
|
|
if (a.unreadCount != b.unreadCount) {
|
|
return b.unreadCount.compareTo(a.unreadCount);
|
|
}
|
|
// Then by most recent activity.
|
|
final aTime = a.lastActivityAt ?? DateTime(0);
|
|
final bTime = b.lastActivityAt ?? DateTime(0);
|
|
return bTime.compareTo(aTime);
|
|
});
|
|
|
|
return models;
|
|
}
|
|
|
|
/// Emits current rooms immediately, then re-emits on every sync.
|
|
/// Immediate yield prevents indefinite spinner while waiting for first sync.
|
|
Stream<List<RoomModel>> watchRooms() async* {
|
|
yield getRooms();
|
|
yield* _client.onSync.stream.map((_) => getRooms());
|
|
}
|
|
|
|
RoomModel _toModel(Room room) {
|
|
return RoomModel(
|
|
id: room.id,
|
|
displayName: room.getLocalizedDisplayname(),
|
|
avatarUrl: resolveMxcUrl(_client, room.avatar),
|
|
lastMessagePreview: lastMessagePreview(room),
|
|
lastActivityAt: room.lastEvent?.originServerTs ?? room.timeCreated,
|
|
unreadCount: room.notificationCount,
|
|
isDirect: room.isDirectChat,
|
|
);
|
|
}
|
|
}
|