Handle message:read events (update readAt in DB), typing:start/typing:stop events with user:typing broadcasts. Implement unread count computation.
Handle message:read events (update readAt in DB), typing:start/typing:stop events with user:typing broadcasts. Implement unread count computation.