phosphorus_irc.py

import phosphorus
from phosphorus.irc import IRC

import sys
_, host, port, nick = sys.argv

def main():
    irc = IRC(host, port, nick)
    yield phosphorus.fork(irc.run())
    yield phosphorus.until_elapsed(2)
    yield from irc.send_command("join", "#overviewer")
    
    while 1:
        cmd = (yield from irc.get_next_command('privmsg'))
        if not cmd:
            break
        
        source, message = cmd[1]
        if source == "#overviewer":
            if "fnord" in message.lower():
                yield from irc.send_command("privmsg", "#overviewer", message.lower().replace("fnord", ""))

phosphorus.run(main())

class TimeCondition(Condition):
    def __init__(self, end_time):
        super(TimeCondition, self).__init__()
        self.end_time = end_time
    def is_fulfilled(self, rlist, wlist, xlist):
        return time.time() >= self.end_time
    def get_max_timeout(self):
        return self.end_time - time.time()

def until_elapsed(seconds):
    return TimeCondition(time.time() + seconds)