Release v4.0.7

tests/pytest/logger/test_logger_buffer.py

@@ -27,14 +27,38 @@ def test_multiple_logs_stored(test_logger):
         assert msg in logs[i]["message"]
 
 def test_log_levels_stored(test_logger):
+    """Debug messages are filtered when print_debug is False (default)."""
     logger, buffer = test_logger
     logger.debug("Debug message")
     logger.info("Info message")
     logger.warning("Warning message")
     logger.error("Error message")
     logs = buffer.get_logs()
     levels = [log["level"] for log in logs]
-    assert levels == ["DEBUG", "INFO", "WARNING", "ERROR"]
+    assert levels == ["INFO", "WARNING", "ERROR"]
+
+
+def test_log_levels_stored_with_print_debug(test_logger):
+    """Debug messages pass through when print_debug is enabled."""
+    from webserver.logger.config import LoggerConfig
+    from webserver.logger import get_logger
+
+    LoggerConfig.print_debug = True
+    try:
+        # Re-fetch logger to apply new level to handlers
+        logger, buffer = get_logger("test_logger", use_buffer=True)
+        buffer.clear()
+        logger.debug("Debug message")
+        logger.info("Info message")
+        logger.warning("Warning message")
+        logger.error("Error message")
+        logs = buffer.get_logs()
+        levels = [log["level"] for log in logs]
+        assert levels == ["DEBUG", "INFO", "WARNING", "ERROR"]
+    finally:
+        LoggerConfig.print_debug = False
+        # Re-fetch to restore INFO level on handlers
+        get_logger("test_logger", use_buffer=True)
 
 def test_normalize_no_microseconds(test_logger):
     logger, buffer = test_logger

webserver/logger/__init__.py

@@ -2,7 +2,6 @@
 import logging
 import sys
 
-from .logger import get_logger
 from .parser import LogParser
 from .bufferhandler import BufferHandler
 from .formatter import JsonFormatter, HumanReadableFormatter
@@ -49,7 +48,6 @@ def get_logger(name="runtime", use_buffer: bool = False):
 
     # Always update all handler levels to reflect current config
     for h in logger.handlers:
-        if isinstance(h, logging.StreamHandler):
-            h.setLevel(effective_level)
+        h.setLevel(effective_level)
 
     return logger, shared_buffer_handler

webserver/logger/parser.py

@@ -9,11 +9,17 @@
 LEVEL_MAP = {
     "DEBUG": logging.DEBUG,
     "INFO": logging.INFO,
+    "WARN": logging.WARNING,
     "WARNING": logging.WARNING,
     "ERROR": logging.ERROR,
     "CRITICAL": logging.CRITICAL,
 }
 
+# Normalize non-standard level names to Python conventions
+LEVEL_NORMALIZE = {
+    "WARN": "WARNING",
+}
+
 
 class LogParser:
     def __init__(self, collector_logger: logging.Logger):
@@ -37,7 +43,9 @@ def parse_and_log(self, line: str):
                 # Preserve incoming JSON fields, but ensure timestamp is present
                 parsed.setdefault("timestamp", str(timestamp))
                 level_name = parsed.get("level", "INFO")
+                level_name = LEVEL_NORMALIZE.get(level_name, level_name)
                 level = LEVEL_MAP.get(level_name, logging.INFO)
+                parsed["level"] = level_name
                 log_entry = parsed
             else:
                 raise ValueError("Not a valid log JSON dict")
@@ -46,6 +54,7 @@ def parse_and_log(self, line: str):
             match = LOG_PATTERN.match(sline)
             if match:
                 level_name = match["level"]
+                level_name = LEVEL_NORMALIZE.get(level_name, level_name)
                 level = LEVEL_MAP.get(level_name, logging.INFO)
                 message = match["message"]
             else: