From 219f3f7d1caafb45a9f7118f9792f6881501b3e7 Mon Sep 17 00:00:00 2001 From: Christophe Besson Date: Thu, 24 Sep 2026 09:23:12 +0200 Subject: refactor(node): move transfer slots and leases out of webrtc_server TransferMixin in transport/webrtc/transfer_handlers.py, with the sweep interval. Co-Authored-By: Claude Opus 5.5 --- packages/meshbay-node/tests/test_transfer_slots_wire.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) (limited to 'packages/meshbay-node/tests') diff --git a/packages/meshbay-node/tests/test_transfer_slots_wire.py b/packages/meshbay-node/tests/test_transfer_slots_wire.py index d96456c..6e9ef94 100644 --- a/packages/meshbay-node/tests/test_transfer_slots_wire.py +++ b/packages/meshbay-node/tests/test_transfer_slots_wire.py @@ -329,13 +329,14 @@ async def test_the_sweeper_stops_when_the_last_lease_goes(ctx): import asyncio from meshbay_node.transport import webrtc_server as ws + from meshbay_node.transport.webrtc import transfer_handlers peer = _join(ctx, "s1", "alice") peer._tasks = set() peer._spawn = ws.WebRTCPeerSession._spawn.__get__(peer) - original = ws.TRANSFER_SWEEP_SECS - ws.TRANSFER_SWEEP_SECS = 0.01 + original = transfer_handlers.TRANSFER_SWEEP_SECS + transfer_handlers.TRANSFER_SWEEP_SECS = 0.01 try: peer._do_transfer_open({"tr": "t1"}) peer._do_transfer_close({"tr": "t1"}) @@ -343,7 +344,7 @@ async def test_the_sweeper_stops_when_the_last_lease_goes(ctx): await asyncio.wait_for(sweeper, timeout=2) assert ctx.get("_transfer_sweeper") is None finally: - ws.TRANSFER_SWEEP_SECS = original + transfer_handlers.TRANSFER_SWEEP_SECS = original async def test_a_chunk_request_keeps_its_lease_alive(ctx): -- cgit v1.2.3