Event Handling

// Listen to all WebSocket events from the client
client.events.listen((event) {
  print('Received event: ${event.runtimeType}');
});

// Real-time updates require a watched feed. `watch` defaults to true, so a
// plain `client.feed(...)` is already watched; pass false to opt out.
final feed = client.feedFromQuery(
  const FeedQuery(fid: FeedId.user('john'), watch: true),
);
await feed.getOrCreate();

// The SDK applies each event to the feed's state, so following the state is
// usually all an app needs.
feed.stream.listen((state) {
  print('${state.activities.length} activities');
});

// The feed state stream emits whenever the feed state changes (activities,
// aggregated groups, notification status, etc.)
notificationFeed.stream.listen((state) {
  final unread = state.notificationStatus?.unread ?? 0;
  final unseen = state.notificationStatus?.unseen ?? 0;
  print('Unread: $unread, Unseen: $unseen');

  // Per-activity isRead/isSeen are updated automatically when the
  // activity.marked WebSocket event arrives after markActivity() calls.
  for (final group in state.aggregatedActivities) {
    print('Group ${group.group}: read=${group.isRead}, seen=${group.isSeen}');
  }
});

// The activity.marked WS event fires when activities are marked read/seen.
// The SDK automatically updates the feed state's isRead/isSeen flags.
// Observe changes via the feed state stream:
notificationFeed.stream.listen((state) {
  final unreadCount = state.notificationStatus?.unread ?? 0;
  print('Unread count updated: $unreadCount');

  // All aggregated groups with their current read state
  final unreadGroups = state.aggregatedActivities.where((g) => g.isRead != true);
  print('Unread groups: ${unreadGroups.length}');
});

// The connection's own comings and goings
client.connectionState.listen((state) {
  print('Connection state: $state');
});