diff libervia/backend/core/log_config.py @ 4270:0d7bb4df2343

Reformatted code base using black.
author Goffi <goffi@goffi.org>
date Wed, 19 Jun 2024 18:44:57 +0200
parents 15055a00162c
children
line wrap: on
line diff
--- a/libervia/backend/core/log_config.py	Tue Jun 18 12:06:45 2024 +0200
+++ b/libervia/backend/core/log_config.py	Wed Jun 19 18:44:57 2024 +0200
@@ -31,6 +31,7 @@
     def __init__(self, *args, **kwargs):
         super().__init__(*args, **kwargs)
         from twisted.logger import Logger
+
         self.twisted_log = Logger()
 
     def out(self, message, level=None, **kwargs):
@@ -59,7 +60,7 @@
             except AttributeError:
                 isatty = False
             # FIXME: isatty should be tested on each handler, not globaly
-            if (force_colors or isatty):
+            if force_colors or isatty:
                 # we need colors
                 log.Logger.post_treat = lambda logger, level, message: self.ansi_colors(
                     level, message
@@ -109,6 +110,7 @@
 
     def pre_treatment(self):
         from twisted import logger
+
         global logger
         self.level_map = {
             C.LOG_LVL_DEBUG: logger.LogLevel.debug,
@@ -125,6 +127,7 @@
     def configure_output(self, output):
         import sys
         from twisted.python import logfile
+
         self.log_publisher = logger.LogPublisher()
 
         if output is None:
@@ -137,13 +140,15 @@
                     "You must pass options as backend_data with Twisted backend"
                 )
             options = self.backend_data
-            log_file = logfile.LogFile.fromFullPath(options['logfile'])
+            log_file = logfile.LogFile.fromFullPath(options["logfile"])
             self.log_publisher.addObserver(
-                logger.FileLogObserver(log_file, self.text_formatter))
+                logger.FileLogObserver(log_file, self.text_formatter)
+            )
             # we also want output to stdout if we are in debug or nodaemon mode
             if options.get("nodaemon", False) or options.get("debug", False):
                 self.log_publisher.addObserver(
-                    logger.FileLogObserver(sys.stdout, self.text_formatter))
+                    logger.FileLogObserver(sys.stdout, self.text_formatter)
+                )
 
         if C.LOG_OPT_OUTPUT_FILE in log.handlers:
 
@@ -152,7 +157,8 @@
                     sys.stdout if path == "-" else logfile.LogFile.fromFullPath(path)
                 )
                 self.log_publisher.addObserver(
-                    logger.FileLogObserver(log_file, self.text_formatter))
+                    logger.FileLogObserver(log_file, self.text_formatter)
+                )
 
         if C.LOG_OPT_OUTPUT_MEMORY in log.handlers:
             raise NotImplementedError(
@@ -172,21 +178,21 @@
         """Install twistedObserver which manage non SàT logs"""
         # from twisted import logger
         import sys
+
         filtering_obs = logger.FilteringLogObserver(
             observer=self.log_publisher,
             predicates=[
                 logger.LogLevelFilterPredicate(self.level),
-                ]
+            ],
         )
         logger.globalLogBeginner.beginLoggingTo([filtering_obs])
 
     def text_formatter(self, event):
-        if event.get('sat_logged', False):
-            timestamp = ''.join([logger.formatTime(event.get("log_time", None)), " "])
+        if event.get("sat_logged", False):
+            timestamp = "".join([logger.formatTime(event.get("log_time", None)), " "])
             return f"{timestamp}{event.get('log_format', '')}\n"
         else:
-            eventText = logger.eventAsText(
-                event, includeSystem=True)
+            eventText = logger.eventAsText(event, includeSystem=True)
             if not eventText:
                 return None
             return eventText.replace("\n", "\n\t") + "\n"
@@ -241,6 +247,7 @@
 
         class SatFormatter(logging.Formatter):
             """Formatter which manage SàT specificities"""
+
             _format = fmt
             _with_profile = "%(profile)s" in fmt
 
@@ -310,11 +317,9 @@
                             super(SatMemoryHandler, self).emit(self.format(record))
 
                     hdlr = SatMemoryHandler(options)
-                    log.handlers[
-                        handler
-                    ] = (
-                        hdlr
-                    )  # we keep a reference to the handler to read the buffer later
+                    log.handlers[handler] = (
+                        hdlr  # we keep a reference to the handler to read the buffer later
+                    )
                     self._add_handler(root_logger, hdlr, can_colors=False)
                 elif handler == C.LOG_OPT_OUTPUT_FILE:
                     import os.path