feat(log): Group loggers in gallia context

src/gallia/command/base.py

@@ -94,7 +94,7 @@ class BaseCommand(ABC):
     EPILOG: str | None = None
 
     #: The name of the logger when this command is run.
-    LOGGER_NAME = "gallia"
+    LOGGER_NAME = __name__
     #: Enable a artifacts_dir. Setting this property to
     #: True enables the creation of a logfile.
     HAS_ARTIFACTS_DIR: bool = False

src/gallia/commands/scan/uds/services.py

@@ -28,6 +28,7 @@ class ServicesScanner(UDSScanner):
     EPILOG = (
         "https://fraunhofer-aisec.github.io/gallia/uds/scan_modes.html#service-scan"
     )
+    LOGGER_NAME = "gallia.scan.services"
 
     def configure_parser(self) -> None:
         self.parser.add_argument(

src/gallia/commands/scan/uds/sessions.py

@@ -25,6 +25,7 @@ class SessionsScanner(UDSScanner):
 
     COMMAND = "sessions"
     SHORT_HELP = "session scan on an ECU"
+    LOGGER_NAME = "gallia.scan.sessions"
 
     def configure_parser(self) -> None:
         self.parser.add_argument(

src/gallia/db/handler.py

@@ -141,7 +141,7 @@ def __init__(self, database: Path):
         self.target: str | None = None
         self.discovery_run: int | None = None
         self.meta: int | None = None
-        self.logger = get_logger("db")
+        self.logger = get_logger("gallia.db")
 
     async def connect(self) -> None:
         assert self.connection is None, "Already connected to the database"

src/gallia/dumpcap.py

@@ -47,7 +47,7 @@ async def start(
         target: TargetURI,
         artifacts_dir: Path,
     ) -> Dumpcap:
-        logger = get_logger("dumpcap")
+        logger = get_logger("gallia.dumpcap")
 
         ts = int(datetime.now().timestamp())
         if target.scheme in [ISOTPTransport.SCHEME, RawCANTransport.SCHEME]:

src/gallia/powersupply.py

@@ -39,7 +39,7 @@ def product_id(self) -> str:
 
 class PowerSupply:
     def __init__(self, client: BaseNetzteil, channel_id: int | list[int]) -> None:
-        self.logger = get_logger("power_supply")
+        self.logger = get_logger("gallia.power_supply")
         self.channel_id = channel_id
         self.netzteil = client
         self.mutex = asyncio.Lock()

src/gallia/services/uds/core/client.py

@@ -43,7 +43,7 @@ def __init__(
         self.retry_wait = 0.2
         self.pending_timeout = 5
         self.mutex = asyncio.Lock()
-        self.logger = get_logger("uds")
+        self.logger = get_logger("gallia.uds")
 
     async def reconnect(self, timeout: int | None = None) -> None:
         """Calls the underlying transport to trigger a reconnect"""

src/gallia/services/uds/core/service.py

@@ -37,7 +37,7 @@
     uds_memory_parameters,
 )
 
-logger = get_logger("uds")
+logger = get_logger("gallia.uds")
 
 # ****************
 # * Base classes *

src/gallia/services/uds/ecu.py

@@ -62,7 +62,7 @@ def __init__(
         power_supply: PowerSupply | None = None,
     ) -> None:
         super().__init__(transport, timeout, max_retry)
-        self.logger = get_logger("ecu")
+        self.logger = get_logger("gallia.ecu")
         self.tester_present_task: Task[None] | None = None
         self.tester_present_interval: float | None = None
         self.power_supply = power_supply

src/gallia/services/xcp/__init__.py

@@ -12,7 +12,7 @@
 
 class XCPService:
     def __init__(self, transport: BaseTransport, timeout: float = 1.0) -> None:
-        self.logger = get_logger("xcp")
+        self.logger = get_logger("gallia.xcp")
         self.timeout = timeout
         self.transport = transport
         # This uses construct types which would result in a new

src/gallia/transports/base.py

@@ -134,7 +134,7 @@ class BaseTransport(ABC):
 
     def __init__(self, target: TargetURI) -> None:
         self.mutex = asyncio.Lock()
-        self.logger = get_logger(self.SCHEME)
+        self.logger = get_logger(f"gallia.{self.SCHEME}")
         self.target = target
         self.is_closed = False
 

src/gallia/transports/doip.py

@@ -291,7 +291,7 @@ def __init__(
         src_addr: int,
         target_addr: int,
     ):
-        self.logger = get_logger("doip")
+        self.logger = get_logger("gallia.doip")
         self.reader = reader
         self.writer = writer
         self.src_addr = src_addr