refactor: get rid of unittest.TestCase

replace `setUp`/`tearDown` methods with pytest fixtures

Replaced `asyncSetUp`/`asyncTearDown` in test cases with `@pytest.fixture` for improved pytest integration. Added `pytest-asyncio` as a dependency. Updated version bump to `2.1.3`.

Author: ttypic

conftest.py

@@ -0,0 +1,5 @@
+
+
+# Configure pytest-asyncio
+pytest_plugins = ('pytest_asyncio',)
+

pyproject.toml

@@ -42,6 +42,8 @@ crypto = ["pycryptodome"]
 vcdiff = ["vcdiff-decoder>=0.1.0,<0.2.0"]
 dev = [
   "pytest>=7.1,<8.0",
+  "pytest-asyncio>=0.21.0,<0.23.0; python_version=='3.7'",
+  "pytest-asyncio>=0.23.0,<1.0.0; python_version>='3.8'",
   "mock>=4.0.3,<5.0.0",
   "pytest-cov>=2.4,<3.0",
   "ruff>=0.14.0,<1.0.0",
@@ -91,6 +93,7 @@ packages = ["ably"]
 
 [tool.pytest.ini_options]
 timeout = 30
+asyncio_mode = "auto"
 
 [[tool.uv.index]]
 name = "experimental"

test/ably/conftest.py

@@ -1,13 +1,10 @@
-import asyncio
-
-import pytest
+import pytest_asyncio
 
 from test.ably.testapp import TestApp
 
 
-@pytest.fixture(scope='session', autouse=True)
-def event_loop():
-    loop = asyncio.get_event_loop_policy().new_event_loop()
-    loop.run_until_complete(TestApp.get_test_vars())
-    yield loop
-    loop.run_until_complete(TestApp.clear_test_vars())
+@pytest_asyncio.fixture(scope='session', autouse=True)
+async def test_app_setup():
+    await TestApp.get_test_vars()
+    yield
+    await TestApp.clear_test_vars()

test/ably/realtime/eventemitter_test.py

@@ -1,12 +1,15 @@
 import asyncio
 
+import pytest
+
 from ably.realtime.connection import ConnectionState
 from test.ably.testapp import TestApp
 from test.ably.utils import BaseAsyncTestCase
 
 
 class TestEventEmitter(BaseAsyncTestCase):
-    async def asyncSetUp(self):
+    @pytest.fixture(autouse=True)
+    async def setup(self):
         self.test_vars = await TestApp.get_test_vars()
 
     async def test_event_listener_error(self):

test/ably/realtime/realtimechannel_publish_test.py

@@ -14,7 +14,8 @@
 class TestRealtimeChannelPublish(BaseAsyncTestCase):
     """Tests for RTN7 spec - Message acknowledgment"""
 
-    async def asyncSetUp(self):
+    @pytest.fixture(autouse=True)
+    async def setup(self):
         self.test_vars = await TestApp.get_test_vars()
 
     # RTN7a - Basic ACK/NACK functionality

test/ably/realtime/realtimechannel_test.py

@@ -12,7 +12,8 @@
 
 
 class TestRealtimeChannel(BaseAsyncTestCase):
-    async def asyncSetUp(self):
+    @pytest.fixture(autouse=True)
+    async def setup(self):
         self.test_vars = await TestApp.get_test_vars()
         self.valid_key_format = "api:key"
 

test/ably/realtime/realtimechannel_vcdiff_test.py

@@ -1,6 +1,8 @@
 import asyncio
 import json
 
+import pytest
+
 from ably import AblyVCDiffDecoder
 from ably.realtime.connection import ConnectionState
 from ably.realtime.realtime_channel import ChannelOptions
@@ -31,7 +33,8 @@ def decode(self, delta: bytes, base: bytes) -> bytes:
 
 
 class TestRealtimeChannelVCDiff(BaseAsyncTestCase):
-    async def asyncSetUp(self):
+    @pytest.fixture(autouse=True)
+    async def setup(self):
         self.test_vars = await TestApp.get_test_vars()
         self.valid_key_format = "api:key"
 

test/ably/realtime/realtimeconnection_test.py

@@ -11,7 +11,8 @@
 
 
 class TestRealtimeConnection(BaseAsyncTestCase):
-    async def asyncSetUp(self):
+    @pytest.fixture(autouse=True)
+    async def setup(self):
         self.test_vars = await TestApp.get_test_vars()
         self.valid_key_format = "api:key"
 

test/ably/realtime/realtimeinit_test.py

@@ -10,7 +10,8 @@
 
 
 class TestRealtimeInit(BaseAsyncTestCase):
-    async def asyncSetUp(self):
+    @pytest.fixture(autouse=True)
+    async def setup(self):
         self.test_vars = await TestApp.get_test_vars()
         self.valid_key_format = "api:key"
 

test/ably/realtime/realtimeresume_test.py

@@ -1,5 +1,7 @@
 import asyncio
 
+import pytest
+
 from ably.realtime.connection import ConnectionState
 from ably.realtime.realtime_channel import ChannelState
 from ably.transport.websockettransport import ProtocolMessageAction
@@ -22,7 +24,8 @@ def on_message(_):
 
 
 class TestRealtimeResume(BaseAsyncTestCase):
-    async def asyncSetUp(self):
+    @pytest.fixture(autouse=True)
+    async def setup(self):
         self.test_vars = await TestApp.get_test_vars()
         self.valid_key_format = "api:key"