X-Git-Url: https://jfr.im/git/erebus.git/blobdiff_plain/f5e736ee1f5b10f6295a6febe91c2c8e3532dce1..689e6e9590c1fbeb47bb2433ad8418b968b49a82:/bot.py diff --git a/bot.py b/bot.py index 44181f4..ca7dc37 100644 --- a/bot.py +++ b/bot.py @@ -16,11 +16,10 @@ class Bot(object): self.realname = realname curs = self.parent.db.cursor() - curs.execute("SELECT chname FROM chans WHERE bot = %s AND active = 1", (self.nick,)) - chansres = curs.fetchall() - curs.close() - - self.chans = [self.parent.newchannel(self, row['chname']) for row in chansres] + if curs.execute("SELECT chname FROM chans WHERE bot = %s AND active = 1", (self.nick,)): + chansres = curs.fetchall() + curs.close() + self.chans = [self.parent.newchannel(self, row['chname']) for row in chansres] self.conn = BotConnection(self, bind, server, port) def connect(self): @@ -61,20 +60,37 @@ class Bot(object): qt = pieces[3] nick = pieces[4] auth = pieces[5] - if auth != '0': - self.parent.user(nick).authed(auth) + self.parent.user(nick).authed(auth) elif pieces[1] == "JOIN": nick = pieces[0].split('!')[0][1:] chan = self.parent.channel(pieces[2]) if nick == self.nick: - self.conn.send("WHO %s %%ant,1" % (chan)) + self.conn.send("WHO %s c%%ant,1" % (chan)) else: user = self.parent.user(nick, justjoined=True) chan.userjoin(user) user.join(chan) + + elif pieces[1] == "PART": + nick = pieces[0].split('!')[0][1:] + chan = self.parent.channel(pieces[2]) + if nick != self.nick: + self.parent.user(nick).part(chan) + chan.userpart(self.parent.user(nick)) + + elif pieces[1] == "QUIT": + nick = pieces[0].split('!')[0][1:] + if nick != self.nick: + self.parent.user(nick).quit() + del self.parent.users[nick.lower()] + + elif pieces[1] == "MODE": #TODO + pass + + def parsemsg(self, user, target, msg): chan = None if len(msg) == 0: @@ -85,6 +101,11 @@ class Bot(object): pieces = msg.split() if target == self.nick: + if msg[0] == "\001": #ctcp + msg = msg.strip("\001") + if msg == "VERSION": + self.msg(user, "\001VERSION Erebus v%d.%d - http://github.com/zonidjan/erebus" % (self.parent.APIVERSION, self.parent.RELEASE)) + return if len(pieces) > 1: chanword = pieces[1] if chanword[0] == '#': @@ -100,9 +121,14 @@ class Bot(object): pieces.pop(0) # command actually starts with next word msg = ' '.join(pieces) # command actually starts with next word elif not triggerused: + if self.parent.haschanhook(target.lower()): + for callback in self.parent.getchanhook(target.lower()): + cbret = callback(self, user, chan, *pieces) + if cbret is NotImplemented: + self.msg(user, "Command not implemented.") return # not to bot, don't process! except IndexError: - return # Fix if you feel like it /BiohZn + return # "message" is empty cmd = pieces[0].lower() @@ -114,10 +140,10 @@ class Bot(object): cbret = callback(self, user, chan, target, *pieces[1:]) if cbret is NotImplemented: self.msg(user, "Command not implemented.") - else: - self.msg(user, "No such command.") def msg(self, target, msg): + if target is None or msg is None: return + if isinstance(target, self.parent.User): self.conn.send("NOTICE %s :%s" % (target.nick, msg)) elif isinstance(target, self.parent.Channel): self.conn.send("PRIVMSG %s :%s" % (target.name, msg)) elif isinstance(target, basestring):