Do not allow emits on a namespace that is not connected (Fixes #325)

socketio/asyncio_client.py

@@ -142,6 +142,9 @@ class AsyncClient(client.Client):
         Note: this method is a coroutine.
         """
         namespace = namespace or '/'
+        if namespace != '/' and namespace not in self.namespaces:
+            raise exceptions.BadNamespaceError(
+                namespace + ' is not a connected namespace.')
         self.logger.info('Emitting event "%s" [%s]', event, namespace)
         if callback is not None:
             id = self._generate_ack_id(namespace, callback)

socketio/client.py

@@ -298,6 +298,9 @@ class Client(object):
                          when addressing an individual client.
         """
         namespace = namespace or '/'
+        if namespace != '/' and namespace not in self.namespaces:
+            raise exceptions.BadNamespaceError(
+                namespace + ' is not a connected namespace.')
         self.logger.info('Emitting event "%s" [%s]', event, namespace)
         if callback is not None:
             id = self._generate_ack_id(namespace, callback)

socketio/exceptions.py

@@ -24,3 +24,7 @@ class ConnectionRefusedError(ConnectionError):
 
 class TimeoutError(SocketIOError):
     pass
+
+
+class BadNamespaceError(SocketIOError):
+    pass

tests/asyncio/test_asyncio_client.py

@@ -194,6 +194,7 @@ class TestAsyncClient(unittest.TestCase):
 
     def test_emit_namespace(self):
         c = asyncio_client.AsyncClient()
+        c.namespaces = ['/foo']
         c._send_packet = AsyncMock()
         _run(c.emit('foo', namespace='/foo'))
         expected_packet = packet.Packet(packet.EVENT, namespace='/foo',
@@ -202,6 +203,12 @@ class TestAsyncClient(unittest.TestCase):
         self.assertEqual(c._send_packet.mock.call_args_list[0][0][0].encode(),
                          expected_packet.encode())
 
+    def test_emit_unknown_namespace(self):
+        c = asyncio_client.AsyncClient()
+        c.namespaces = ['/foo']
+        self.assertRaises(exceptions.BadNamespaceError, _run,
+                          c.emit('foo', namespace='/bar'))
+
     def test_emit_with_callback(self):
         c = asyncio_client.AsyncClient()
         c._send_packet = AsyncMock()
@@ -216,6 +223,7 @@ class TestAsyncClient(unittest.TestCase):
 
     def test_emit_namespace_with_callback(self):
         c = asyncio_client.AsyncClient()
+        c.namespaces = ['/foo']
         c._send_packet = AsyncMock()
         c._generate_ack_id = mock.MagicMock(return_value=123)
         _run(c.emit('foo', namespace='/foo', callback='cb'))

tests/common/test_client.py

@@ -288,6 +288,7 @@ class TestClient(unittest.TestCase):
 
     def test_emit_namespace(self):
         c = client.Client()
+        c.namespaces = ['/foo']
         c._send_packet = mock.MagicMock()
         c.emit('foo', namespace='/foo')
         expected_packet = packet.Packet(packet.EVENT, namespace='/foo',
@@ -296,6 +297,12 @@ class TestClient(unittest.TestCase):
         self.assertEqual(c._send_packet.call_args_list[0][0][0].encode(),
                          expected_packet.encode())
 
+    def test_emit_unknown_namespace(self):
+        c = client.Client()
+        c.namespaces = ['/foo']
+        self.assertRaises(exceptions.BadNamespaceError, c.emit, 'foo',
+                          namespace='/bar')
+
     def test_emit_with_callback(self):
         c = client.Client()
         c._send_packet = mock.MagicMock()
@@ -310,6 +317,7 @@ class TestClient(unittest.TestCase):
 
     def test_emit_namespace_with_callback(self):
         c = client.Client()
+        c.namespaces = ['/foo']
         c._send_packet = mock.MagicMock()
         c._generate_ack_id = mock.MagicMock(return_value=123)
         c.emit('foo', namespace='/foo', callback='cb')