🧪 Add tests for log.configure options

tests/unit/test_log/test_init.py

@@ -0,0 +1,48 @@
+import io
+import logging
+
+import pytest
+
+import enapter.log
+
+
+@pytest.fixture(autouse=True)
+def reset_logger():
+    original_level = enapter.log.LOGGER.level
+    original_handlers = enapter.log.LOGGER.handlers.copy()
+    yield
+    enapter.log.LOGGER.setLevel(original_level)
+    enapter.log.LOGGER.handlers = original_handlers
+
+
+def test_configure_level_none():
+    enapter.log.configure(level=None)
+    assert len(enapter.log.LOGGER.handlers) == 1
+    assert isinstance(enapter.log.LOGGER.handlers[0], logging.NullHandler)
+
+
+def test_configure_level_str():
+    enapter.log.configure(level="DEBUG")
+    assert enapter.log.LOGGER.level == logging.DEBUG
+    assert len(enapter.log.LOGGER.handlers) == 1
+    handler = enapter.log.LOGGER.handlers[0]
+    assert isinstance(handler, logging.StreamHandler)
+    assert isinstance(handler.formatter, enapter.log.JSONFormatter)
+
+
+def test_configure_level_int():
+    enapter.log.configure(level=logging.INFO)
+    assert enapter.log.LOGGER.level == logging.INFO
+    assert len(enapter.log.LOGGER.handlers) == 1
+    handler = enapter.log.LOGGER.handlers[0]
+    assert isinstance(handler, logging.StreamHandler)
+    assert isinstance(handler.formatter, enapter.log.JSONFormatter)
+
+
+def test_configure_custom_stream():
+    stream = io.StringIO()
+    enapter.log.configure(level=logging.INFO, stream=stream)
+    assert len(enapter.log.LOGGER.handlers) == 1
+    handler = enapter.log.LOGGER.handlers[0]
+    assert isinstance(handler, logging.StreamHandler)
+    assert handler.stream is stream

tests/unit/test_standalone/test_mqtt_adapter.py

@@ -59,7 +59,7 @@ async def test_publish_properties():
             device=device,
             task_group=tg,
         ):
-            await asyncio.sleep(0.02)
+            await asyncio.sleep(0.1)
             device_channel.publish_properties.assert_called()
             last_call = device_channel.publish_properties.call_args
             published_properties = last_call.kwargs["properties"]
@@ -80,7 +80,7 @@ async def test_publish_telemetry():
             device=device,
             task_group=tg,
         ):
-            await asyncio.sleep(0.02)
+            await asyncio.sleep(0.1)
             device_channel.publish_telemetry.assert_called()
             last_call = device_channel.publish_telemetry.call_args
             published_telemetry = last_call.kwargs["telemetry"]
@@ -103,7 +103,7 @@ async def test_publish_logs(log_severity, persist_logs) -> None:
             device=device,
             task_group=tg,
         ):
-            await asyncio.sleep(0.02)
+            await asyncio.sleep(0.1)
             device_channel.publish_log.assert_called()
             last_call = device_channel.publish_log.call_args
             published_log = last_call.kwargs["log"]
@@ -129,7 +129,7 @@ async def test_publish_properties_exception():
             device=device,
             task_group=tg,
         ):
-            await asyncio.sleep(0.02)
+            await asyncio.sleep(0.1)
             device_channel.publish_properties.assert_called()
 
 
@@ -147,7 +147,7 @@ async def test_publish_telemetry_exception():
             device=device,
             task_group=tg,
         ):
-            await asyncio.sleep(0.02)
+            await asyncio.sleep(0.1)
             device_channel.publish_telemetry.assert_called()
 
 
@@ -165,7 +165,7 @@ async def test_publish_logs_exception():
             device=device,
             task_group=tg,
         ):
-            await asyncio.sleep(0.02)
+            await asyncio.sleep(0.1)
             device_channel.publish_log.assert_called()