# Copyright 2010-2011 Florent Le Coz # # This file is part of Poezio. # # Poezio is free software: you can redistribute it and/or modify # it under the terms of the zlib license. See the COPYING file. from os import environ, makedirs import os import re from datetime import datetime from config import config from xhtml import clean_text from theming import dump_tuple, get_theme import logging log = logging.getLogger(__name__) from config import LOG_DIR log_dir = os.path.join(LOG_DIR, 'logs') message_log_re = re.compile('MR (\d{4})(\d{2})(\d{2})T(\d{2}):(\d{2}):(\d{2})Z (\d+) <([^ ]+)>  (.*)') info_log_re = re.compile('MI (\d{4})(\d{2})(\d{2})T(\d{2}):(\d{2}):(\d{2})Z (\d+) (.*)') def parse_message_line(msg): if re.match(message_log_re, msg): return [i for i in re.split(message_log_re, msg) if i] elif re.match(info_log_re, msg): return [i for i in re.split(info_log_re, msg) if i] return False class Logger(object): """ Appends things to files. Error/information/warning logs and also log the conversations to logfiles """ def __init__(self): self.logfile = config.get('logfile', 'logs') self.roster_logfile = None # a dict of 'groupchatname': file-object (opened) self.fds = dict() def __del__(self): for opened_file in self.fds.values(): if opened_file: try: opened_file.close() except: # Can't close? too bad pass def reload_all(self): """Close and reload all the file handles (on SIGHUP)""" for opened_file in self.fds.values(): if opened_file: opened_file.close() log.debug('All log file handles closed') for room in self.fds: self.fds[room] = self.check_and_create_log_dir(room) log.debug('Log handle for %s re-created', room) def check_and_create_log_dir(self, room, open_fd=True): """ Check that the directory where we want to log the messages exists. if not, create it """ if config.get_by_tabname('use_log', 'true', room) == 'false': return try: makedirs(log_dir) except FileExistsError: pass except: log.error('Unable to create the log dir', exc_info=True) return if not open_fd: return try: fd = open(os.path.join(log_dir, room), 'a') self.fds[room] = fd return fd except IOError: log.error('Unable to open the log file (%s)', os.path.join(log_dir, room), exc_info=True) def get_logs(self, jid, nb=10): """ Get the log history for the given jid """ if config.get_by_tabname('load_log', 10, jid) <= 0: return if config.get_by_tabname('use_log', 'true', jid) == 'false': return if nb <= 0: return self.check_and_create_log_dir(jid, open_fd=False) try: fd = open(os.path.join(log_dir, jid), 'rb') except: log.error('Unable to open the log file (%s)', os.path.join(log_dir, jid), exc_info=True) return if not fd: return pos = fd.seek(0, 2) reads = 0 check_next = False while reads < nb: if pos == 0: break pos -= 1 if pos < 0: pos = 0 fd.seek(pos) char = fd.read(1) if char == b'\n': if fd.read(2) in (b'MR', b'MI'): reads += 1 fd.seek(-2, 1) logs = fd.readlines() fd.close() lines = [] for line in logs: lines.append(line.decode(errors='replace')[:-1]) log.debug(lines) messages = [] color = '\x19%s}' % dump_tuple(get_theme().COLOR_INFORMATION_TEXT) idx = 0 while idx < len(lines): if lines[idx].startswith(' '): # should not happen ; skip idx += 1 log.debug('fail?') continue tup = parse_message_line(lines[idx]) idx += 1 if not tup or 7 > len(tup) > 10 : # skip log.debug('format? %s', tup) continue time = [int(i) for index, i in enumerate(tup) if index < 6] message = {'lines': [], 'history': True, 'time': datetime(*time)} size = int(tup[6]) if len(tup) == 8: #info line message['lines'].append(color+tup[7]) else: # message line message['nickname'] = tup[7] message['lines'].append(color+tup[8]) while size != 0 and idx < len(lines): message['lines'].append(lines[idx][1:]) size -= 1 idx += 1 message['txt'] = '\n'.join(message['lines']) del message['lines'] messages.append(message) return messages def log_message(self, jid, nick, msg, date=None, typ=1): """ log the message in the appropriate jid's file type: 0 = Don’t log 1 = Message 2 = Status/whatever """ if not typ: return True jid = str(jid).replace('/', '\\') if config.get_by_tabname('use_log', 'false', jid) != 'true': return True if jid in self.fds.keys(): fd = self.fds[jid] else: fd = self.check_and_create_log_dir(jid) if not fd: return True try: msg = clean_text(msg) if date is None: str_time = datetime.now().strftime('%Y%m%dT%H:%M:%SZ') else: str_time = date.strftime('%Y%m%dT%H:%M:%SZ') if typ == 1: prefix = 'MR' else: prefix = 'MI' lines = msg.split('\n') first_line = lines.pop(0) nb_lines = str(len(lines)).zfill(3) for line in lines: self.roster_logfile.write(' %s\n' % line) if nick: nick = '<' + nick + '>' fd.write(' '.join((prefix, str_time, nb_lines, nick, ' '+first_line, '\n'))) else: fd.write(' '.join((prefix, str_time, nb_lines, first_line, '\n'))) for line in lines: fd.write(' %s\n' % line) except: log.error('Unable to write in the log file (%s)', os.path.join(log_dir, jid), exc_info=True) return False else: try: fd.flush() # TODO do something better here? except: log.error('Unable to flush the log file (%s)', os.path.join(log_dir, jid), exc_info=True) return False return True def log_roster_change(self, jid, message): """ Log a roster change """ if config.get_by_tabname('use_log', 'false', jid) != 'true': return True if not self.roster_logfile: try: self.roster_logfile = open(os.path.join(log_dir, 'roster.log'), 'a') except IOError: log.error('Unable to create the log file (%s)', os.path.join(log_dir, 'roster.log'), exc_info=True) return False try: str_time = datetime.now().strftime('%Y%m%dT%H:%M:%SZ') message = clean_text(message) lines = message.split('\n') first_line = lines.pop(0) nb_lines = str(len(lines)).zfill(3) self.roster_logfile.write('MI %s %s %s %s\n' % (str_time, nb_lines, jid, first_line)) for line in lines: self.roster_logfile.write(' %s\n' % line) self.roster_logfile.flush() except: log.error('Unable to write in the log file (%s)', os.path.join(log_dir, 'roster.log'), exc_info=True) return False return True logger = Logger()