Skip to content

Commit 913c68a

Browse files
add missing unit tests #nolog
1 parent 16e873d commit 913c68a

File tree

4 files changed

+21
-6
lines changed

4 files changed

+21
-6
lines changed

socketio/asyncio_server.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -327,10 +327,10 @@ async def disconnect(self, sid, namespace=None, ignore_queue=False):
327327
"""
328328
namespace = namespace or '/'
329329
if ignore_queue:
330-
do_it = self.manager.is_connected(sid, namespace)
330+
delete_it = self.manager.is_connected(sid, namespace)
331331
else:
332-
do_it = await self.manager.can_disconnect(sid, namespace)
333-
if do_it:
332+
delete_it = await self.manager.can_disconnect(sid, namespace)
333+
if delete_it:
334334
self.logger.info('Disconnecting %s [%s]', sid, namespace)
335335
self.manager.pre_disconnect(sid, namespace=namespace)
336336
await self._send_packet(sid, packet.Packet(packet.DISCONNECT,

socketio/server.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -518,10 +518,10 @@ def disconnect(self, sid, namespace=None, ignore_queue=False):
518518
"""
519519
namespace = namespace or '/'
520520
if ignore_queue:
521-
do_it = self.manager.is_connected(sid, namespace)
521+
delete_it = self.manager.is_connected(sid, namespace)
522522
else:
523-
do_it = self.manager.can_disconnect(sid, namespace)
524-
if do_it:
523+
delete_it = self.manager.can_disconnect(sid, namespace)
524+
if delete_it:
525525
self.logger.info('Disconnecting %s [%s]', sid, namespace)
526526
self.manager.pre_disconnect(sid, namespace=namespace)
527527
self._send_packet(sid, packet.Packet(packet.DISCONNECT,

tests/asyncio/test_asyncio_server.py

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -625,6 +625,15 @@ def test_disconnect(self, eio):
625625
s.eio.send.mock.assert_any_call('123', '1', binary=False)
626626
s.eio.disconnect.mock.assert_called_once_with('123')
627627

628+
def test_disconnect_ignore_queue(self, eio):
629+
eio.return_value.send = AsyncMock()
630+
eio.return_value.disconnect = AsyncMock()
631+
s = asyncio_server.AsyncServer()
632+
_run(s._handle_eio_connect('123', 'environ'))
633+
_run(s.disconnect('123', ignore_queue=True))
634+
s.eio.send.mock.assert_any_call('123', '1', binary=False)
635+
s.eio.disconnect.mock.assert_called_once_with('123')
636+
628637
def test_disconnect_namespace(self, eio):
629638
eio.return_value.send = AsyncMock()
630639
eio.return_value.disconnect = AsyncMock()

tests/common/test_server.py

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -553,6 +553,12 @@ def test_disconnect(self, eio):
553553
s.disconnect('123')
554554
s.eio.send.assert_any_call('123', '1', binary=False)
555555

556+
def test_disconnect_ignore_queue(self, eio):
557+
s = server.Server()
558+
s._handle_eio_connect('123', 'environ')
559+
s.disconnect('123', ignore_queue=True)
560+
s.eio.send.assert_any_call('123', '1', binary=False)
561+
556562
def test_disconnect_namespace(self, eio):
557563
s = server.Server()
558564
s._handle_eio_connect('123', 'environ')

0 commit comments

Comments
 (0)