from twisted.internet import reactor, protocolfrom twisted.protocols import basicimport osimport sysimport timeimport urllibclass Session(object):    def __init__(self, type, ip, name):        self.ip = ip        self.type = type        self.name = name        self.lasttime = time.time()#   Matcher keeps a list of sessions, and can return a list of #   sessions that match a given key and is not too oldclass Matcher(object):    def __init__(self):        self.sessions = {}    def update(self, ip, type, name):        self.sessions[ip] = Session(type, ip, name)    def search(self, pattern):        now = time.time()        # do incremental clean-up of the session list, one item per query        todel = None        ret = []        for k in self.sessions.iteritems():            if k[1].lasttime > now - 120:                if pattern in k[1].type:                    ret.append(k[1])            else:                todel = k[0]        if todel:            del self.session[todel]        return retmatcher = Matcher()class Protocol(basic.LineReceiver):    def lineReceived(self, line):        global matcher        if len(line) > 512:            # don't allow ridiculous sizes            self.transport.loseConnection()            return        parts = line.split(" ")        ret = ["error: no command given"]        if len(parts) > 0:            ret = ["error: unknown command '%s'" %                 (urllib.unquote(parts[0]).strip(),)]        if len(parts) == 2:            if parts[0] == 'MATCH':                q = matcher.search(urllib.unquote(parts[1]).strip())                ret = ["found %d matches" % (len(q),)]                for i in q:                    ret.append("%s %s %s" % (urllib.quote(str(i.ip.host)),                         urllib.quote(i.type), urllib.quote(i.name)))        elif len(parts) == 3:            if parts[0] == 'LIST':                matcher.update(self.transport.getPeer(),                      urllib.unquote(parts[1]).strip(),                      urllib.unquote(parts[2]).strip())                ret = ["ok"]        for l in ret:            self.transport.write(l + "\r\n")        self.transport.loseConnection()class Factory(protocol.ServerFactory):    protocol = Protocoldef run():    reactor.listenTCP(54321, Factory())    reactor.run()if __name__ == "__main__":    run()