test: json

Author: phi-friday

src/tests/test_async_aiopika_manager.py

@@ -21,11 +21,7 @@ def test_inherits_async_pubsub_manager(self) -> None:
     def test_init_signature(self) -> None:
         sig = inspect.signature(mod.AsyncAioPikaManager.__init__)
         params = list(sig.parameters.keys())
-        assert "self" in params
-        assert "url" in params
-        assert "channel" in params
-        assert "write_only" in params
-        assert "logger" in params
+        assert params == ["self", "url", "channel", "write_only", "logger", "json"]
 
     def test_name_attribute(self) -> None:
         assert hasattr(mod.AsyncAioPikaManager, "name")

src/tests/test_async_pubsub_manager.py

@@ -22,7 +22,7 @@ def test_init_signature(self) -> None:
         sig = inspect.signature(mod.AsyncPubSubManager.__init__)
         params = list(sig.parameters.keys())
         # Exact match to catch stub/runtime mismatches
-        assert params == ["self", "channel", "write_only", "logger"]
+        assert params == ["self", "channel", "write_only", "logger", "json"]
 
     def test_name_attribute(self) -> None:
         assert hasattr(mod.AsyncPubSubManager, "name")

src/tests/test_async_redis_manager.py

@@ -34,12 +34,15 @@ def test_inherits_async_pubsub_manager(self) -> None:
     def test_init_signature(self) -> None:
         sig = inspect.signature(mod.AsyncRedisManager.__init__)
         params = list(sig.parameters.keys())
-        assert "self" in params
-        assert "url" in params
-        assert "channel" in params
-        assert "write_only" in params
-        assert "logger" in params
-        assert "redis_options" in params
+        assert params == [
+            "self",
+            "url",
+            "channel",
+            "write_only",
+            "logger",
+            "json",
+            "redis_options",
+        ]
 
     def test_name_attribute(self) -> None:
         assert hasattr(mod.AsyncRedisManager, "name")

src/tests/test_base_manager.py

@@ -3,6 +3,7 @@
 from __future__ import annotations
 
 import inspect
+import json
 import logging
 from typing import assert_type
 
@@ -91,3 +92,10 @@ def test_get_rooms_method(self) -> None:
     def test_get_logger_method(self) -> None:
         assert hasattr(mod.BaseManager, "_get_logger")
         assert callable(mod.BaseManager._get_logger)  # noqa: SLF001
+
+    def test_json_attribute(self) -> None:
+        """Test json attribute exists and is a module."""
+        manager = mod.BaseManager()
+        assert hasattr(manager, "json")
+        # The json attribute should be the json module
+        assert manager.json is json

src/tests/test_kafka_manager.py

@@ -34,10 +34,7 @@ def test_inherits_pubsub_manager(self) -> None:
     def test_init_signature(self) -> None:
         sig = inspect.signature(mod.KafkaManager.__init__)
         params = list(sig.parameters.keys())
-        assert "self" in params
-        assert "url" in params
-        assert "channel" in params
-        assert "write_only" in params
+        assert params == ["self", "url", "channel", "write_only", "logger", "json"]
 
     def test_name_attribute(self) -> None:
         assert hasattr(mod.KafkaManager, "name")

src/tests/test_kombu_manager.py

@@ -21,15 +21,18 @@ def test_inherits_pubsub_manager(self) -> None:
     def test_init_signature(self) -> None:
         sig = inspect.signature(mod.KombuManager.__init__)
         params = list(sig.parameters.keys())
-        assert "self" in params
-        assert "url" in params
-        assert "channel" in params
-        assert "write_only" in params
-        assert "logger" in params
-        assert "connection_options" in params
-        assert "exchange_options" in params
-        assert "queue_options" in params
-        assert "producer_options" in params
+        assert params == [
+            "self",
+            "url",
+            "channel",
+            "write_only",
+            "logger",
+            "json",
+            "connection_options",
+            "exchange_options",
+            "queue_options",
+            "producer_options",
+        ]
 
     def test_name_attribute(self) -> None:
         assert hasattr(mod.KombuManager, "name")

src/tests/test_pubsub_manager.py

@@ -21,10 +21,7 @@ def test_inherits_manager(self) -> None:
     def test_init_signature(self) -> None:
         sig = inspect.signature(mod.PubSubManager.__init__)
         params = list(sig.parameters.keys())
-        assert "self" in params
-        assert "channel" in params
-        assert "write_only" in params
-        assert "logger" in params
+        assert params == ["self", "channel", "write_only", "logger", "json"]
 
     def test_name_attribute(self) -> None:
         assert hasattr(mod.PubSubManager, "name")

src/tests/test_redis_manager.py

@@ -47,12 +47,15 @@ def test_inherits_pubsub_manager(self) -> None:
     def test_init_signature(self) -> None:
         sig = inspect.signature(mod.RedisManager.__init__)
         params = list(sig.parameters.keys())
-        assert "self" in params
-        assert "url" in params
-        assert "channel" in params
-        assert "write_only" in params
-        assert "logger" in params
-        assert "redis_options" in params
+        assert params == [
+            "self",
+            "url",
+            "channel",
+            "write_only",
+            "logger",
+            "json",
+            "redis_options",
+        ]
 
     def test_name_attribute(self) -> None:
         assert hasattr(mod.RedisManager, "name")

src/tests/test_zmq_manager.py

@@ -21,11 +21,7 @@ def test_inherits_pubsub_manager(self) -> None:
     def test_init_signature(self) -> None:
         sig = inspect.signature(mod.ZmqManager.__init__)
         params = list(sig.parameters.keys())
-        assert "self" in params
-        assert "url" in params
-        assert "channel" in params
-        assert "write_only" in params
-        assert "logger" in params
+        assert params == ["self", "url", "channel", "write_only", "logger", "json"]
 
     def test_name_attribute(self) -> None:
         assert hasattr(mod.ZmqManager, "name")