decentraland / comms-gatekeeper
87%
main: 86%

LAST BUILD BRANCH: feat/cluster-livekit-subscriber
DEFAULT BRANCH: main
Repo Added
Token H9CF0YzviAGXBYzx8ZZY8Lv8V4wtqKxTm regen
Build 907 Last
Files 162
Badge
Embed ▾
README BADGES
x

If you need to use a raster PNG badge, change the '.svg' to '.png' in the link

Markdown

Textile

RDoc

HTML

Rst

LAST BUILD ON BRANCH feat/cluster-livekit-subscriber
branch: SELECT
CHANGE BRANCH
x
Sync Branches

coverage: 87.116% (+1.0%) from 86.086%
34891158967

Pull #283

github

LautaroPetaccio 
feat: drain in-flight work on shutdown instead of dropping it

Components stop in reverse creation order, so the subscriber stops before
the NATS adapter closes its connection. Nothing used that: a mint that was
mid-flight when the signal arrived reached its publish after the connection
had gone, the adapter dropped the write, and that peer waited for its next
event to get a room.

Three parts make the order count. The NATS adapter's subscribe returns a
handle: it drops the registration first, so a reconnect cannot restore it,
then cancels the live subscription when the link is up. The cluster
subscriber cancels its three subscriptions on stop, so later events go to
another replica in the queue group. The keyed queue then drains, re-checking
each round so work queued during the drain is waited on too.

The drain is bounded by KEYED_QUEUE_DRAIN_TIMEOUT_MS (5 s default, 0 to skip
the wait): the lifecycle has no stop timeout of its own, and a task stuck on
a request without one would hold shutdown until the orchestrator killed the
process. Giving up names the keys still running. Work enqueued after stop is
still accepted, since refusing it would gain nothing.
Pull Request #283: feat: mint LiveKit island rooms from Pulse cluster feed (Archipelago ⇒ Pulse, iteration 1)

1265 of 1575 branches covered (80.32%)

Branch coverage included in aggregate %.

354 of 357 new or added lines in 17 files covered. (99.16%)

4 existing lines in 2 files now uncovered.

3475 of 3866 relevant lines covered (89.89%)

82.7 hits per line

Relevant lines Covered
3866 RELEVANT LINES 3475 COVERED LINES
82.7 HITS PER LINE
Source Files on main

Recent builds

Builds Branch Commit Type Ran Committer Via Coverage
34891158967 feat/cluster-livekit-subscriber feat: drain in-flight work on shutdown instead of dropping it Components stop in reverse creation order, so the subscriber stops before the NATS adapter closes its connection. Nothing used that: a mint that was mid-flight when the signal arrived ... Pull #283 LautaroPetaccio github
87.12
34887569144 feat/cluster-livekit-subscriber refactor: move the ban-result cache into the access gate and extract the keyed queue Cluster subscriber ban path. The subscriber asked the connection store for the wallet's last device before calling the access gate, which user moderation already... Pull #283 LautaroPetaccio github
87.03
34879214649 feat/cluster-livekit-subscriber refactor: resolve holdsParticipant with a single listParticipants call listRooms was there so a missing room read as an empty array instead of an error code. It cost a second round trip on the common path, where the island room still exists, and ... Pull #283 LautaroPetaccio github
87.05
34872261654 feat/cluster-livekit-subscriber refactor: replace the assignment-mirror adapter with a dedicated memory cache The mirror was a thin wrapper over lru-cache with get, set and size, the same library @dcl/memory-cache-component wraps. It is now an instance of that component created... Pull #283 LautaroPetaccio github
86.87
34847328041 feat/it2-wp2-presence-map feat: serve presence exclusively from Pulse Pull #293 mikhail-dcl github
87.71
34580664750 feat/cluster-livekit-subscriber feat: decode PeerClusterChange with @dcl/protocol and drop the transition flags Pin @dcl/protocol to the branch build that carries session, displaced_session and displaced_cluster_id, and delete the local codec that bridged the gap. island_change... Pull #283 mikhail-dcl github
86.89
34523673799 feat/cluster-livekit-subscriber feat: evict the displaced session and address island_changed to the owning session Pulse's cluster feed now names the session that owns an assignment and the one it displaced. The displaced participant is removed from its island room with its tok... Pull #283 mikhail-dcl github
86.76
34487642996 feat/cluster-livekit-subscriber docs: note the session id now riding peer.connect WS Connector uses it to order duplicate sessions across its replicas; this service still reads only the wallet from the subject. Pull #283 mikhail-dcl github
86.73
34470086212 feat/cluster-livekit-subscriber feat: re-announce a peer island when its comms session starts Pulse only speaks when a cluster changes, so a client whose websocket reconnects standing still was never given a room. Answers peer.{addr}.connect from a replica-wide assignment mirro... Pull #283 mikhail-dcl github
86.73
34469175540 feat/cluster-livekit-subscriber feat: re-announce a peer island when its comms session starts Pulse only speaks when a cluster changes, so a client whose websocket reconnects standing still was never given a room. Answers peer.{addr}.connect from a replica-wide assignment mirro... Pull #283 mikhail-dcl github
86.73
See All Builds (904)

Badge your Repo: comms-gatekeeper

We detected this repo isn’t badged! Grab the embed code to the right, add it to your repo to show off your code coverage, and when the badge is live hit the refresh button to remove this message.
Embed ▾
README BADGES
x

If you need to use a raster PNG badge, change the '.svg' to '.png' in the link

Markdown

Textile

RDoc

HTML

Rst

Refresh