Who Is Currently Connected: rapla-who.py

#!/usr/bin/env python

"""Search connected users.
The standard input is the RAPLA server log file
"""

import sys

class User:
    def __init__(self, ip):
        self.ip = ip
        self.connect = 0
        self.disconnect = 0
        self.names = []

    def __str__(self):
        if self.connect != self.disconnect:
            s = " ### Connected ###"
        else:
            s = ""
        return ("%-15s %-37s (%2d,%2d)" % (self.ip, str(self.names),
                                  self.connect, self.disconnect)) + s

def date(line):
    return line[6:20]

class Logs:
    def __init__(self, file):
        logs = []

        for line in file.readlines():
            if line.endswith("Storage service started\n"):
                self.start = date(line)
                logs = []
            else:
                logs.append(line)

        users = {}
        last = None
        self.stop = "Running"
                
        for log in logs:
            if last:
                name = log.split(" ")[-1][:-1]
                if name not in last.names:
                    last.names.append(name)
                last.connect += 1
                last = None
                continue
            if log.find("Client subscribed") >= 0:
                ip = log.split(" /")[1].split(":")[0]
                if not users.has_key(ip):
                    users[ip] = User(ip)
                last = users[ip]
                continue
            if log.find("Client unsubscribed") >= 0:
                ip = log.split(" /")[1].split(":")[0]
                users[ip].disconnect += 1
                continue
            if log.find("Storage service stopped") >= 0:
                self.stop = date(line)

        self.users = users

    def __str__(self):
        s = "Start date = %s, Stop date = %s\n" % (self.start, self.stop)
        for u in self.users.values():
            s += str(u) + "\n"
        return s

if __name__ == "__main__":
    print Logs(sys.stdin)