' # Will be closed by the first "Changed day" old_gmtime_day = None for line in logs.split('\n'): words = line.split(' ') if len(words) < 2: continue timestamp = words[0] command = words[1] new_line = None if command == 'PRIVMSG' or command == 'NOTICE': if command == 'PRIVMSG': nick_delimiters = ('<', '>') else: nick_delimiters = ('*', '*') formatted_nick = nick_delimiters[0] + format_nick(words[2]) + \ nick_delimiters[1] new_line = _('%(formatted_nick)s %(message)s') % { 'formatted_nick': formatted_nick, 'message': cgi.escape(' '.join(words[3:]))} elif command == 'PRIVMSG-ACTION': new_line = _('* %(nick)s %(message)s') % { 'nick': format_nick(words[2]), 'message': cgi.escape(' '.join(words[3:]))} elif command == 'PART': new_line = _('<-- %(nick)s has left the channel (%(reason)s)') % \ {'nick': format_nick(words[2]), 'reason': cgi.escape(' '.join(words[3:]))} elif command == 'QUIT': new_line = _('<-- %(nick)s has quit the network (%(reason)s)') % \ {'nick': format_nick(words[2]), 'reason': cgi.escape(' '.join(words[3:]))} elif command == 'JOIN': new_line = _('--> %(nick)s has joined the channel') % \ {'nick': format_nick(words[2])} elif command == 'MODE': new_line = _('*/* %(nick)s has set mode %(modes)s') % \ {'nick': format_nick(words[2]), 'modes': ' '.join(words[3:])} elif command == 'KICK': new_line = _('<-- %(kicked)s has been kicked by %(kicker)s (%(reason)s)') % \ {'kicked': format_nick(words[3]), 'kicker': format_nick(words[2]), 'reason': cgi.escape(' '.join(words[4:]))} if new_line is not None: template = """

%(timestamp)s %(line)s

""" new_line = URL_REGEXP.sub(r'\1', new_line) # Timestamp handling gmtime = time.gmtime(int(words[0])) gmtime_day = (gmtime.tm_mday, gmtime.tm_mon, gmtime.tm_year) if old_gmtime_day != gmtime_day: html_logs += '

' html_logs += """ """ html_logs += '

%i/%i/%i

' % \ gmtime_day old_gmtime_day = gmtime_day timestamp = time.strftime('%H:%M:%S', gmtime) html_logs += template % {'line': new_line, 'timestamp': timestamp, 'command': command} return html_logs class WebLogsMiddleware(object): """Class for reading and parsing WebLogs data.""" __shared_states = {} def __init__(self, channel): if channel in self.__shared_states: self.__dict__ = self.__shared_states[channel] else: self._channel = channel path = conf.supybot.directories.data.dirize('WebLogs_%s.log' % channel) self.fd = open(path, 'a+') self.__shared_states.update({channel: self.__dict__}) @classmethod def get_channel_list(cls): channels = [x[len('WebLogs_'):-len('.log')] for x in os.listdir(conf.supybot.directories.data()) if x.endswith('.log')] return [x for x in channels if cls._plugin.registryValue('enabled', x)] def get_logs(self): self.fd.seek(0) return self.fd.read() def write(self, *args): self.fd.read() self.fd.write('%i %s\n' % (time.time(), ' '.join(args))) class WebLogsServerCallback(httpserver.SupyHTTPServerCallback): name = 'WebLogs' def doGet(self, handler, path): if path == '': self.send_response(301) self.send_header('Location', '/weblogs/') self.end_headers() return elif path == '/': splitted_path = [] else: splitted_path = path[1:].split('/') if len(splitted_path) == 0: self.send_response(200) self.send_header('Content-type', 'text/html') self.end_headers() page_body = """Here is a list of available logs:

' self.wfile.write(page_template % {'title': 'Index', 'body': page_body}) return elif len(splitted_path) == 3: mode, channel, page = splitted_path else: self.send_response(404) self.send_header('Content-type', 'text/plain') self.end_headers() self.wfile.write('Bad URL.') return assert mode in ('html', 'json') channel = utils.web.urlunquote(channel) if channel not in WebLogsMiddleware.get_channel_list(): self.send_response(404) self.send_header('Content-type', 'text/plain') self.end_headers() self.wfile.write('This channel is not logged.') return middleware = WebLogsMiddleware(channel) if page == '': self.send_response(200) self.send_header('Content-type', 'text/html') self.end_headers() self.wfile.write(page_template % { 'title': channel, 'body': format_logs(middleware.get_logs())}) def check_enabled(f): def newf(self, irc, msg): channel = msg.args[0] if irc.isChannel(channel) and self.registryValue('enabled', channel) \ and not msg.tagged('relayedMsg'): return f(self, irc, msg, WebLogsMiddleware(channel)) return msg return newf @internationalizeDocstring class WebLogs(callbacks.Plugin): """Add the help for "@plugin help WebLogs" here This should describe *how* to use this plugin.""" def __init__(self, irc): # Some stuff needed by Supybot self.__parent = super(WebLogs, self) callbacks.Plugin.__init__(self, irc) self.lastStates = {} WebLogsMiddleware._plugin = self # registering the callback callback = WebLogsServerCallback() # create an instance of the callback httpserver.hook('weblogs', callback) @check_enabled def doPrivmsg(self, irc, msg, middleware): if ircmsgs.isAction(msg): middleware.write('PRIVMSG-ACTION', msg.nick, ircmsgs.unAction(msg)) else: middleware.write('PRIVMSG', msg.nick, msg.args[1]) @check_enabled def outFilter(self, irc, msg, middleware): if msg.command == 'PRIVMSG': middleware.write('PRIVMSG', irc.nick, msg.args[1]) elif msg.command == 'NOTICE': middleware.write('NOTICE', irc.nick, msg.args[1]) return msg @check_enabled def doNotice(self, irc, msg, middleware): middleware.write('NOTICE', msg.nick, msg.args[1]) @check_enabled def doPart(self, irc, msg, middleware): if len(msg.args) == 1: reason = '' else: reason = msg.args[1] middleware.write('PART', msg.nick, reason) @check_enabled def doJoin(self, irc, msg, middleware): middleware.write('JOIN', msg.nick) @check_enabled def doMode(self, irc, msg, middleware): middleware.write('MODE', msg.nick, msg.args[1], ' '.join(msg.args[2:])) @check_enabled def doKick(self, irc, msg, middleware): middleware.write('KICK', msg.nick, ' '.join(msg.args[1:])) def __call__(self, irc, msg): self.__parent.__call__(irc, msg) self.lastStates[irc] = irc.state.copy() def doQuit(self, irc, msg): if len(msg.args) == 0: reason = '' else: reason = msg.args[0] if not isinstance(irc, irclib.Irc): irc = irc.getRealIrc() for (channel, chan) in self.lastStates[irc].channels.items(): if msg.nick in chan.users: if self.registryValue('enabled', channel): middleware = WebLogsMiddleware(channel) middleware.write('QUIT', msg.nick, reason) def die(self): # unregister the callback httpserver.unhook('weblogs') # Stuff for Supybot self.__parent.die() Class = WebLogs # vim:set shiftwidth=4 softtabstop=4 expandtab textwidth=79: