diff options
| author | Christophe Besson <cbesson@gmail.com> | 2026-09-24 09:23:12 +0200 |
|---|---|---|
| committer | Christophe Besson <cbesson@gmail.com> | 2026-09-24 16:45:38 +0200 |
| commit | 219f3f7d1caafb45a9f7118f9792f6881501b3e7 (patch) | |
| tree | 4c42577300f78f4207031f9c2d38b349e9c9d18b /packages/meshbay-node/tests/test_transfer_slots_wire.py | |
| parent | ffdb70784f11de0df8162cea5e9f5abfac91ea96 (diff) | |
| download | meshbay-219f3f7d1caafb45a9f7118f9792f6881501b3e7.tar.gz | |
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 <noreply@anthropic.com>
Diffstat (limited to 'packages/meshbay-node/tests/test_transfer_slots_wire.py')
| -rw-r--r-- | packages/meshbay-node/tests/test_transfer_slots_wire.py | 7 |
1 files changed, 4 insertions, 3 deletions
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): |