Skip to content

Commit

Permalink
dev demo: stopwatching
Browse files Browse the repository at this point in the history
  • Loading branch information
chrisbobbe committed Oct 20, 2023
1 parent 774dce1 commit af399c6
Show file tree
Hide file tree
Showing 2 changed files with 20 additions and 1 deletion.
12 changes: 12 additions & 0 deletions lib/model/store.dart
Original file line number Diff line number Diff line change
Expand Up @@ -309,23 +309,35 @@ class PerAccountStore extends ChangeNotifier {
for (final view in _messageListViews) {
view.maybeAddMessage(event.message);
}
final stopwatch = Stopwatch()..start();
unreads.handleMessageEvent(event);
final t = (stopwatch..stop()).elapsed;
assert(debugLog('handleMessageEvent time: ${t.inMilliseconds}ms'));
} else if (event is UpdateMessageEvent) {
assert(debugLog("server event: update_message ${event.messageId}"));
for (final view in _messageListViews) {
view.maybeUpdateMessage(event);
}
final stopwatch = Stopwatch()..start();
unreads.handleUpdateMessageEvent(event);
final t = (stopwatch..stop()).elapsed;
assert(debugLog('handleUpdateMessageEvent time: ${t.inMilliseconds}ms'));
} else if (event is DeleteMessageEvent) {
assert(debugLog("server event: delete_message ${event.messageIds}"));
// TODO handle in message lists
final stopwatch = Stopwatch()..start();
unreads.handleDeleteMessageEvent(event);
final t = (stopwatch..stop()).elapsed;
assert(debugLog('handleDeleteMessageEvent time: ${t.inMilliseconds}ms'));
} else if (event is UpdateMessageFlagsEvent) {
assert(debugLog("server event: update_message_flags/${event.op} ${event.flag.toJson()}"));
for (final view in _messageListViews) {
view.maybeUpdateMessageFlags(event);
}
final stopwatch = Stopwatch()..start();
unreads.handleUpdateMessageFlagsEvent(event);
final t = (stopwatch..stop()).elapsed;
assert(debugLog('handleUpdateMessageFlagsEvent time: ${t.inMilliseconds}ms'));
} else if (event is ReactionEvent) {
assert(debugLog("server event: reaction/${event.op}"));
for (final view in _messageListViews) {
Expand Down
9 changes: 8 additions & 1 deletion lib/model/unreads.dart
Original file line number Diff line number Diff line change
Expand Up @@ -39,6 +39,8 @@ import 'narrow.dart';
// messages and refresh [mentions] (see [mentions] dartdoc).
class Unreads extends ChangeNotifier {
factory Unreads({required UnreadMessagesSnapshot initial, required selfUserId}) {
final stopwatch = Stopwatch()..start();

final streams = <int, Map<String, QueueList<int>>>{};
final dms = <DmNarrow, QueueList<int>>{};
final mentions = Set.of(initial.mentions);
Expand All @@ -60,13 +62,18 @@ class Unreads extends ChangeNotifier {
dms[narrow] = QueueList.from(unreadHuddleSnapshot.unreadMessageIds);
}

return Unreads._(
final result = Unreads._(
streams: streams,
dms: dms,
mentions: mentions,
oldUnreadsMissing: initial.oldUnreadsMissing,
selfUserId: selfUserId,
);

final t = (stopwatch..stop()).elapsed;
assert(debugLog('Unreads constructor time: ${t.inMilliseconds}ms'));

return result;
}

Unreads._({
Expand Down

0 comments on commit af399c6

Please sign in to comment.