mirror of
https://github.com/vale981/clay
synced 2025-03-05 09:31:40 -05:00
109 lines
2.3 KiB
Python
109 lines
2.3 KiB
Python
"""
|
|
Logger implementation.
|
|
"""
|
|
# pylint: disable=too-few-public-methods
|
|
from threading import Lock
|
|
from datetime import datetime
|
|
|
|
from clay.eventhook import EventHook
|
|
|
|
|
|
class _LoggerRecord(object):
|
|
"""
|
|
Represents a logger record.
|
|
"""
|
|
def __init__(self, verbosity, message, args):
|
|
self._timestamp = datetime.now()
|
|
self._verbosity = verbosity
|
|
self._message = message
|
|
self._args = args
|
|
|
|
@property
|
|
def formatted_timestamp(self):
|
|
"""
|
|
Return timestamp.
|
|
"""
|
|
return str(self._timestamp)
|
|
|
|
@property
|
|
def verbosity(self):
|
|
"""
|
|
Return verbosity.
|
|
"""
|
|
return self._verbosity
|
|
|
|
@property
|
|
def formatted_message(self):
|
|
"""
|
|
Return formatted message.
|
|
"""
|
|
return self._message % self._args
|
|
|
|
|
|
class _Logger(object):
|
|
"""
|
|
Global logger.
|
|
|
|
Allows subscribing to log events.
|
|
"""
|
|
|
|
def __init__(self):
|
|
self.logs = []
|
|
self.logfile = open('/tmp/clay.log', 'w')
|
|
|
|
self._lock = Lock()
|
|
|
|
self.on_log_event = EventHook()
|
|
|
|
def log(self, level, message, *args):
|
|
"""
|
|
Add log item.
|
|
"""
|
|
self._lock.acquire()
|
|
try:
|
|
logger_record = _LoggerRecord(level, message, args)
|
|
self.logs.append(logger_record)
|
|
self.logfile.write('{} {:8} {}\n'.format(
|
|
logger_record.formatted_timestamp,
|
|
logger_record.verbosity,
|
|
logger_record.formatted_message
|
|
))
|
|
self.logfile.flush()
|
|
self.on_log_event.fire(logger_record)
|
|
finally:
|
|
self._lock.release()
|
|
|
|
def debug(self, message, *args):
|
|
"""
|
|
Add debug log item.
|
|
"""
|
|
self.log('DEBUG', message, *args)
|
|
|
|
def info(self, message, *args):
|
|
"""
|
|
Add info log item.
|
|
"""
|
|
self.log('INFO', message, *args)
|
|
|
|
def warn(self, message, *args):
|
|
"""
|
|
Add warning log item.
|
|
"""
|
|
self.log('WARNING', message, *args)
|
|
|
|
warning = warn
|
|
|
|
def error(self, message, *args):
|
|
"""
|
|
Add error log item.
|
|
"""
|
|
self.log('ERROR', message, *args)
|
|
|
|
def get_logs(self):
|
|
"""
|
|
Return all logs.
|
|
"""
|
|
return self.logs
|
|
|
|
|
|
logger = _Logger() # pylint: disable=invalid-name
|