decentraland / social-service-ea / 28526473436 / 1

90%

main: 90%

Pull #424

github

fix: harden the subscription path (non-fatal snapshot, no-emitter backoff, drop metric)

Server-side robustness for the subscription streams, complementing the client-side
re-subscribe fixes:

- subscribe-to-friend-connectivity: make the initial online-friends snapshot best-effort.
  A DB/registry hiccup no longer tears down the whole subscription (which forced the client
  to reconnect and re-run the queries, churning); log a warning and continue to live updates.
  (peersStats.getConnectedPeers already swallows its own errors, so the real risk was
  getOnlineFriends / getProfiles.)
- handleSubscriptionUpdates: on the "no emitter" path (RPC call live but the per-address
  emitter is gone — an abnormal/racy state), throw instead of returning. A clean completion
  invited an instant re-open into a hot loop; erroring makes a well-behaved client back off.
- emitterToGenerator: add an onOverflowDrop hook + subscription_updates_dropped_total metric
  so silent value-queue drops (a slow consumer missing updates) are observable.
- Keep the per-occurrence "Duplicate subscription detected" debug log alongside the
  subscription_duplicates_total metric, for per-connection visibility into re-subscribe churn.

Build, lint and full unit suite (106 suites / 1615 tests) green.

2466 of 2863 branches covered (86.13%)

Branch coverage included in aggregate %.

11512 of 12442 relevant lines covered (92.53%)

40.38 hits per line