decentraland / social-service-ea / 24455772176 / 1

90%

main: 90%

Pull #407

github

fix: add cork wrapping, subscriber metrics, reconciliation, and sScan

Hardening changes to complement the critical OOM fixes:

1. Wrap all HTTP responses in res.cork() to prevent uWS warnings about
   writes outside corked callbacks. Under GC pressure these interleaved
   writes can hold object references longer than necessary.

2. Add subscriber monitoring metrics (gauges): subscribers_local_count,
   subscribers_generators_count, subscribers_redis_set_size, and a
   subscribers_stale_cleaned counter. Reported every 30s via setInterval.

3. Add periodic stale subscriber reconciliation (every 5 min, configurable
   via SUBSCRIBER_RECONCILIATION_INTERVAL_MS). Cross-references local
   subscribers against active WS connections from wsPool and removes any
   orphaned subscribers that the cleanup path missed.

4. Replace redis.sMembers() with redis.client.sScanIterator() in
   getSubscribersAddresses() to avoid loading the entire Redis SET at
   once. Adds a warning log when the set exceeds 10,000 entries.

5. Add redis.sCard() for O(1) subscriber count metric reporting.
6. Add wsPool.getAuthenticatedAddresses() for reconciliation.

2371 of 2772 branches covered (85.53%)

Branch coverage included in aggregate %.

10944 of 11942 relevant lines covered (91.64%)

35.71 hits per line