per class logging

evrec/server.py

@@ -59,9 +59,10 @@
 
 class EvrecServer:
     def __init__(self, settings: Settings):
+        self.logger = logging.getLogger(__name__).getChild(self.__class__.__name__)
         self.settings = settings
         if self.settings.mqtt_topic_write is None:
-            logger.warning("Not publishing verified messages")
+            self.logger.warning("Not publishing verified messages")
         self.clients_keys = self.get_clients_keys()
         self.message_validator = MessageValidator()
 
@@ -85,7 +86,7 @@ def get_clients_keys(self) -> JWKSet:
             with open(filename, "rb") as fp:
                 key = JWK.from_pem(fp.read())
                 key.kid = filename.name.removesuffix(".pem")
-                logger.debug("Adding key kid=%s (%s)", key.kid, key.thumbprint())
+                self.logger.debug("Adding key kid=%s (%s)", key.kid, key.thumbprint())
                 res.add(key)
         return res
 
@@ -97,7 +98,7 @@ async def run(self):
                     await client.subscribe(self.settings.mqtt_topic_read)
 
                     async for message in client.messages:
-                        logger.debug("Received message on %s", message.topic)
+                        self.logger.debug("Received message on %s", message.topic)
                         try:
                             jws = JWS()
                             jws.deserialize(message.payload)
@@ -108,13 +109,13 @@ async def run(self):
                             if self.settings.mqtt_topic_write:
                                 await self.handle_payload(client, message, jws, key)
                             else:
-                                logger.debug("Not publishing verified message")
+                                self.logger.debug("Not publishing verified message")
                         except JWKeyNotFound:
-                            logger.warning(
+                            self.logger.warning(
                                 "Dropping unverified message on %s", message.topic
                             )
                         except Exception as exc:
-                            logger.error(
+                            self.logger.error(
                                 "Error parsing message on %s",
                                 message.topic,
                                 exc_info=exc,
@@ -143,7 +144,7 @@ async def handle_payload(
             retain=message.retain,
             properties=properties,
         )
-        logger.info("Published verified message from %s on %s", key.kid, new_topic)
+        self.logger.info("Published verified message from %s on %s", key.kid, new_topic)
 
 
 def verify_jws_with_keys(jws: JWS, keys: JWKSet) -> JWK: