You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
191 lines
5.9 KiB
Python
191 lines
5.9 KiB
Python
"""Setup a logging helper for our module.
|
|
|
|
|
|
Helpers:
|
|
LOG - out active logger instance
|
|
set_logging_level(level) - adjust the current logging level
|
|
"""
|
|
import logging
|
|
import sys
|
|
import time
|
|
from collections import namedtuple
|
|
from hashlib import md5
|
|
from lxml.etree import tounicode
|
|
|
|
|
|
# For pretty log messages, if available
|
|
try:
|
|
import curses
|
|
except ImportError:
|
|
curses = None
|
|
|
|
LOGLEVEL = "WARNING"
|
|
|
|
|
|
# Logging bits stolen and adapted from:
|
|
# http://www.tornadoweb.org/documentation/_modules/tornado/options.html
|
|
LogOptions = namedtuple('LogOptions', [
|
|
'loglevel',
|
|
'log_file_prefix',
|
|
'log_file_max_size',
|
|
'log_file_num_backups',
|
|
'log_to_stderr',
|
|
])
|
|
|
|
options = LogOptions(
|
|
loglevel=LOGLEVEL,
|
|
log_file_prefix="",
|
|
log_file_max_size=100 * 1000 * 1000,
|
|
log_file_num_backups=5,
|
|
log_to_stderr=True,
|
|
)
|
|
|
|
|
|
def set_logging_level(level):
|
|
"""Adjust the current logging level.
|
|
|
|
Expect a string of DEBUG, WARNING, INFO, etc.
|
|
|
|
"""
|
|
logging.getLogger('breadable').setLevel(getattr(logging, level))
|
|
|
|
|
|
def enable_pretty_logging():
|
|
"""Turns on formatted logging output as configured.
|
|
|
|
This is called automatically by `parse_command_line`.
|
|
"""
|
|
root_logger = logging.getLogger()
|
|
if options.log_file_prefix:
|
|
channel = logging.handlers.RotatingFileHandler(
|
|
filename=options.log_file_prefix,
|
|
maxBytes=options.log_file_max_size,
|
|
backupCount=options.log_file_num_backups)
|
|
channel.setFormatter(_LogFormatter(color=False))
|
|
root_logger.addHandler(channel)
|
|
|
|
if (options.log_to_stderr or
|
|
(options.log_to_stderr is None and not root_logger.handlers)):
|
|
# Set up color if we are in a tty and curses is installed
|
|
color = False
|
|
if curses and sys.stderr.isatty():
|
|
try:
|
|
curses.setupterm()
|
|
if curses.tigetnum("colors") > 0:
|
|
color = True
|
|
except Exception:
|
|
pass
|
|
channel = logging.StreamHandler()
|
|
channel.setFormatter(_LogFormatter(color=color))
|
|
root_logger.addHandler(channel)
|
|
|
|
|
|
class LogHelper(object):
|
|
"""Helper to allow us to log as we want for debugging"""
|
|
scoring = 1
|
|
removing = 2
|
|
_active = False
|
|
|
|
_actions = None
|
|
|
|
def __init__(self, log, actions=None, content=False):
|
|
if actions is None:
|
|
self._actions = tuple()
|
|
else:
|
|
self._actions = actions
|
|
|
|
self._log = log
|
|
self.content = content
|
|
|
|
@property
|
|
def actions(self):
|
|
"""Return a tuple of the actions we want to log"""
|
|
return self._actions
|
|
|
|
def activate(self):
|
|
"""Turn on this logger."""
|
|
self._active = True
|
|
|
|
def deactivate(self):
|
|
"""Turn off the logger"""
|
|
self._active = False
|
|
|
|
def log(self, node, action, description):
|
|
"""Write out our log info based on the node and event specified.
|
|
|
|
We only log this information if we're are DEBUG loglevel
|
|
|
|
"""
|
|
if self._active:
|
|
content = tounicode(node)
|
|
hashed = md5()
|
|
try:
|
|
hashed.update(content.encode('utf-8', errors="replace"))
|
|
except Exception, exc:
|
|
LOG.error("Cannot hash the current node." + str(exc))
|
|
hash_id = hashed.hexdigest()[0:8]
|
|
# if hash_id in ['9c880b27', '8393b7d7', '69bfebdd']:
|
|
print(u"{0} :: {1}\n{2}".format(
|
|
hash_id,
|
|
description,
|
|
content.replace(u"\n", u"")[0:202],
|
|
))
|
|
|
|
|
|
class _LogFormatter(logging.Formatter):
|
|
def __init__(self, color, *args, **kwargs):
|
|
logging.Formatter.__init__(self, *args, **kwargs)
|
|
self._color = color
|
|
if color:
|
|
# The curses module has some str/bytes confusion in python3.
|
|
# Most methods return bytes, but only accept strings.
|
|
# The explict calls to unicode() below are harmless in python2,
|
|
# but will do the right conversion in python3.
|
|
fg_color = unicode(curses.tigetstr("setaf") or
|
|
curses.tigetstr("setf") or "", "ascii")
|
|
self._colors = {
|
|
logging.DEBUG: unicode(
|
|
curses.tparm(fg_color, curses.COLOR_CYAN),
|
|
"ascii"),
|
|
logging.INFO: unicode(
|
|
curses.tparm(fg_color, curses.COLOR_GREEN),
|
|
"ascii"),
|
|
logging.WARNING: unicode(
|
|
curses.tparm(fg_color, curses.COLOR_YELLOW), # Yellow
|
|
"ascii"),
|
|
logging.ERROR: unicode(
|
|
curses.tparm(fg_color, curses.COLOR_RED), # Red
|
|
"ascii"),
|
|
}
|
|
self._normal = unicode(curses.tigetstr("sgr0"), "ascii")
|
|
|
|
def format(self, record):
|
|
try:
|
|
record.message = record.getMessage()
|
|
except Exception, e:
|
|
record.message = "Bad message (%r): %r" % (e, record.__dict__)
|
|
record.asctime = time.strftime(
|
|
"%y%m%d %H:%M:%S", self.converter(record.created))
|
|
prefix = '[%(levelname)1.1s %(asctime)s %(module)s:%(lineno)d]' % \
|
|
record.__dict__
|
|
if self._color:
|
|
prefix = (self._colors.get(record.levelno, self._normal) +
|
|
prefix + self._normal)
|
|
formatted = prefix + " " + record.message
|
|
if record.exc_info:
|
|
if not record.exc_text:
|
|
record.exc_text = self.formatException(record.exc_info)
|
|
if record.exc_text:
|
|
formatted = formatted.rstrip() + "\n" + record.exc_text
|
|
return formatted.replace("\n", "\n ")
|
|
|
|
|
|
# Set up log level and pretty console logging by default
|
|
logging.getLogger('breadable').setLevel(getattr(logging, LOGLEVEL))
|
|
enable_pretty_logging()
|
|
LOG = logging.getLogger('breadable')
|
|
LNODE = LogHelper(LOG,
|
|
actions=(LogHelper.scoring, LogHelper.removing),
|
|
content=True
|
|
)
|