feat(broadcasting): WebSocket reliability — activity monitor, jitter, connection timeout

[anilcancakir]

Summary

Three broadcasting reliability improvements for ReverbBroadcastDriver:

• Client-side activity monitor (feat(broadcasting): add client-side activity monitor with ping/pong timeout #55) — Implements Pusher protocol activity_timeout + pusher:ping/pusher:pong. Detects silent connection loss and triggers automatic reconnection
• Reconnection jitter (feat(broadcasting): add jitter to reconnection backoff delay #56) — Adds random jitter (up to 30%) to exponential backoff, preventing thundering herd when server restarts
• Connection establishment timeout (feat(broadcasting): add connection establishment timeout #57) — Configurable timeout (default 15s) on connect() prevents indefinite hang when server doesn't complete handshake

Closes #55, closes #56, closes #57

Changes

Activity Monitor (#55)

• reverb_broadcast_driver.dart — _activityTimer, _pongTimer fields, _resetActivityTimer() / _cancelActivityTimers() methods, wired into _onMessage(), _handleConnectionEstablished(), disconnect(), _onDone()
• 5 new test cases (ping after silence, pong timeout reconnect, timer reset on message, cancel on disconnect, restart after reconnect)

Reconnection Jitter (#56)

• reverb_broadcast_driver.dart — backoffDelay() formula updated to base * (1 + random(0..0.3)), Random DI via constructor
• Tests updated from exact equality to range matchers + seeded Random for determinism

Connection Timeout (#57)

• reverb_broadcast_driver.dart — connect() uses .timeout() with configurable connection_timeout (default 15s), schedules reconnect on timeout
• config/broadcasting.dart — Added connection_timeout: 15 default
• 2 new test cases (throws TimeoutException, schedules reconnect after timeout)

Docs & Config

• doc/digging-deeper/broadcasting.md — Connection Health Monitoring section, jitter formula, connection_timeout config
• CHANGELOG.md — 3 feature entries under [Unreleased]
• .claude/rules/broadcasting.md — Updated config example

Test plan

• flutter test — 922 tests pass (914 existing + 8 new)
• dart analyze — zero issues
• dart format --set-exit-if-changed . — zero changes

[sentry]

Codecov Report

✅ All modified and coverable lines are covered by tests.

📢 Thoughts on this report? Let us know!

[Copilot]

Pull request overview

Adds Pusher-protocol client-side connection health monitoring to ReverbBroadcastDriver so silent WebSocket failures can be detected and recovered via ping/pong + reconnect.

Changes:

• Introduces activity monitoring timers in ReverbBroadcastDriver (send pusher:ping after activity_timeout silence; close socket if no pusher:pong within a timeout).
• Adds test coverage for ping scheduling, pong-timeout closure behavior, timer reset/cancel, and post-reconnect restart.
• Documents the connection health monitoring behavior and records the feature in the changelog.

Reviewed changes

Copilot reviewed 4 out of 4 changed files in this pull request and generated 3 comments.

File	Description
lib/src/broadcasting/drivers/reverb_broadcast_driver.dart	Adds activity/pong timers and hooks them into message handling and lifecycle.
test/broadcasting/drivers/reverb_broadcast_driver_test.dart	Adds 5 new tests for the activity monitor behavior.
doc/digging-deeper/broadcasting.md	Documents the new connection health monitoring flow.
CHANGELOG.md	Notes the feature under Unreleased.

[Copilot]

Pull request overview

Copilot reviewed 6 out of 6 changed files in this pull request and generated 3 comments.

Comments suppressed due to low confidence (1)

lib/src/broadcasting/drivers/reverb_broadcast_driver.dart:442

• The switch (event) cases don’t terminate (no break/return/throw), which in Dart is a compile-time error and/or will cause unintended fall-through (e.g., handling pusher:connection_established would also run the pusher:ping path and others). Add explicit termination for each case (or use switch expressions) so only the intended handler runs.

    _resetActivityTimer();

    switch (event) {
      case 'pusher:connection_established':
        _handleConnectionEstablished(json);
      case 'pusher:ping':
        _sendPong();
      case 'pusher:subscription_succeeded':
        _handleSubscriptionSucceeded(json);
      case 'pusher:error':
        _handlePusherError(json);
      case 'pusher_internal:member_added':
        _handlePresenceEvent(json);
      case 'pusher_internal:member_removed':
        _handlePresenceEvent(json);
      default:
        _handleApplicationEvent(json);
    }