Mercurial > libervia-backend
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