josh.py

   1 #!/usr/bin/python
   2 # -*- coding:utf8 -*-
   3
   4 """ IRC bot to kickban spammers on c3 channels """
   5
   6 import threading
   7 import random
   8 import time
   9 import json
  10 import re
  11 import os
  12 import signal
  13 import sys
  14
  15 # Yup, I'va tweaked irclib to handle SIGHUP
  16 sys.path.insert(0, "/home/vincent/scripts/python-myirclib")
  17 import irclib
  18 import ircbot
  19
  20 #: Bot configuration
  21 import config
  22 #: Module de réponse aux questions de base
  23 import isit
  24
  25 # la partie qui réfère au fichier lui-même est mieux ici
  26 # sinon on réfère la config et pas le fichier lui-même
  27 config.thisfile = os.path.realpath(__file__)
  28
  29 def get_config_logfile(serveur):
  30     """Renvoie le nom du fichier de log en fonction du ``serveur`` et de la config."""
  31     serveurs = {"irc.hackint.org" : "hackint",
  32                 "irc.crans.org" : "crans"}
  33     return config.logfile_template % (serveurs[serveur],)
  34
  35 def log(serveur, channel, auteur=None, message=None):
  36     """Enregistre une ligne de log."""
  37     if auteur == message == None:
  38         # alors c'est que c'est pas un channel mais juste une ligne de log
  39         chain = u"%s %s" % (time.strftime("%F %T"), channel)
  40     else:
  41         chain = u"%s [%s:%s] %s" % (time.strftime("%F %T"), channel, auteur, message)
  42     f = open(get_config_logfile(serveur), "a")
  43     f.write((chain + u"\n").encode("utf-8"))
  44     f.close()
  45     if config.debug_stdout:
  46         print chain.encode("utf-8")
  47
  48 def ignore_event(serv, ev):
  49     """Retourne ``True`` si il faut ignorer cet évènement."""
  50     for (blackmask, exceptlist) in config.blacklisted_masks:
  51         usermask = ev.source()
  52         blackit = bool(irclib.mask_matches(usermask, blackmask))
  53         exceptit = any([bool(irclib.mask_matches(usermask, exceptmask)) for exceptmask in exceptlist])
  54         if exceptit: # Il est exempté
  55             return False
  56         else:
  57             if blackit: # Il n'est pas exempté et matche la blacklist
  58                 return True
  59
  60
  61 def bot_unicode(chain):
  62     """Essaye de décoder ``chain`` en UTF-8.
  63        Lève une py:class:`errors.UnicodeBotError` en cas d'échec."""
  64     try:
  65         return chain.decode("utf8")
  66     except UnicodeDecodeError as exc:
  67         raise errors.UnicodeBotError
  68
  69
  70 class Josh(ircbot.SingleServerIRCBot):
  71     """Classe principale : définition du bot"""
  72     def __init__(self, serveur, debug=False):
  73         temporary_pseudo = config.irc_pseudo + str(random.randrange(10000,100000))
  74         ircbot.SingleServerIRCBot.__init__(self, [(serveur, 6667)],
  75                               temporary_pseudo, "Basile, le bot irc. [Codé par 20-100]", 10)
  76         self.debug = debug
  77         self.serveur = serveur
  78         self.overops = config.overops
  79         self.ops = self.overops + config.ops
  80         self.report_bugs_to = config.report_bugs_to
  81         self.chanlist = config.chanlist
  82         self.stay_channels = config.stay_channels
  83         self.quiet_channels = config.quiet_channels
  84         self.last_perdu = 0
  85
  86     ### Utilitaires
  87     def _getnick(self):
  88         """Récuère le nick effectif du bot sur le serveur."""
  89         return self.serv.get_nickname()
  90     nick = property(_getnick)
  91
  92     def give_me_my_pseudo(self, serv):
  93         """Récupère le pseudo auprès de NickServ."""
  94         serv.privmsg("NickServ", "RECOVER %s %s" % (config.irc_pseudo, config.irc_password))
  95         serv.privmsg("NickServ", "RELEASE %s %s" % (config.irc_pseudo, config.irc_password))
  96         time.sleep(0.3)
  97         serv.nick(config.irc_pseudo)
  98
  99     def pourmoi(self, serv, message):
 100         """Renvoie (False, lemessage) ou (True, le message amputé de "pseudo: ")"""
 101         pseudo = self.nick
 102         pseudo = pseudo.decode("utf-8")
 103         size = len(pseudo)
 104         if message[:size] == pseudo and len(message) > size and message[size] == ":":
 105             return (True, message[size+1:].lstrip(" "))
 106         else:
 107             return (False, message)
 108
 109     ### Exécution d'actions
 110     def quitter(self, chan, leave_message=None):
 111         """Quitter un channel avec un message customisable."""
 112         if leave_message == None:
 113             leave_message = random.choice(config.leave_messages)
 114         self.serv.part(chan, message=leave_message.encode("utf8"))
 115
 116     def mourir(self):
 117         """Se déconnecter du serveur IRC avec un message customisable."""
 118         quit_message = random.choice(config.quit_messages)
 119         self.die(msg=quit_message.encode("utf8"))
 120
 121     def execute_reload(self, auteur=None):
 122         """Recharge la config."""
 123         reload(config)
 124         isit.regexp_compile()
 125         if auteur in [None, "SIGHUP"]:
 126             towrite = "Config reloaded" + " (SIGHUP received)" * (auteur == "SIGHUP")
 127             for to in config.report_bugs_to:
 128                 self.serv.privmsg(to, towrite)
 129             log(self.serveur, towrite)
 130             return True, None
 131         else:
 132             return True, u"Config reloaded"
 133
 134     def crash(self, who="nobody", chan="nowhere"):
 135         """Fait crasher le bot."""
 136         where = "en privé" if chan == "priv" else "sur le chan %s" % chan
 137         raise errors.CrashError((u"Crash demandé par %s %s" % (who, where)).encode("utf-8"))
 138
 139     ACTIONS = {
 140         "reload" : execute_reload,
 141         }
 142
 143     def execute_something(self, something, params, place=None, auteur=None):
 144         """Exécute une action et répond son résultat à ``auteur``
 145            sur un chan ou en privé en fonction de ``place``"""
 146         action = self.ACTIONS[something]
 147         success, message = action(self, **params)
 148         if message:
 149             if irclib.is_channel(place):
 150                 message = "%s: %s" % (auteur, message.encode("utf-8"))
 151             self.serv.privmsg(place, message)
 152         log(self.serveur, place, auteur, something + "%r" % params + ("[successful]" if success else "[failed]"))
 153
 154     ### Surcharge des events du Bot
 155     def on_welcome(self, serv, ev):
 156         """À l'arrivée sur le serveur."""
 157         self.serv = serv # ça serv ira :)
 158         self.give_me_my_pseudo(serv)
 159         serv.privmsg("NickServ", "IDENTIFY %s" % (config.irc_password))
 160         log(self.serveur, "Connected")
 161         if self.debug:
 162             self.chanlist = ["#bot"]
 163         for c in self.chanlist:
 164             log(self.serveur, "JOIN %s" % (c))
 165             serv.join(c)
 166
 167     def on_privmsg(self, serv, ev):
 168         """À la réception d'un message en privé."""
 169         if ignore_event(serv, ev):
 170             return
 171         message = ev.arguments()[0]
 172         auteur = irclib.nm_to_n(ev.source())
 173         try:
 174             message = bot_unicode(message)
 175         except errors.UnicodeBotError:
 176             if config.utf8_trigger:
 177                 serv.privmsg(auteur, random.choice(config.utf8_fail_answers).encode("utf8"))
 178             return
 179         message = message.split()
 180         cmd = message[0].lower()
 181         notunderstood = False
 182         if cmd == u"help":
 183             op,overop=auteur in self.ops, auteur in self.overops
 184             if len(message)==1:
 185                 helpmsg = config.helpmsg_default
 186                 if op:
 187                     helpmsg += config.helpmsg_ops
 188                 if overop:
 189                     helpmsg += config.helpmsg_overops
 190             else:
 191                 helpmsgs = config.helpdico.get(message[1].lower(), ["Commande inconnue.", None, None])
 192                 helpmsg = helpmsgs[0]
 193                 if op and helpmsgs[1]:
 194                     if helpmsg:
 195                         helpmsg += "\n" + helpmsgs[1]
 196                     else:
 197                         helpmsg = helpmsgs[1]
 198                 if overop and helpmsgs[2]:
 199                     if helpmsg:
 200                         helpmsg += "\n" + helpmsgs[2]
 201                     else:
 202                         helpmsg = helpmsgs[2]
 203             for ligne in helpmsg.split("\n"):
 204                 serv.privmsg(auteur, ligne.encode("utf-8"))
 205         elif cmd == u"join":
 206             if auteur in self.ops:
 207                 if len(message) > 1:
 208                     if message[1] in self.chanlist:
 209                         serv.privmsg(auteur, (u"Je suis déjà sur %s" % (message[1])).encode("utf-8"))
 210                     else:
 211                         serv.join(message[1])
 212                         self.chanlist.append(message[1])
 213                         serv.privmsg(auteur, "Channels : " + " ".join(self.chanlist))
 214                         log(self.serveur, "priv", auteur, " ".join(message))
 215                 else:
 216                     serv.privmsg(auteur, "Channels : " + " ".join(self.chanlist))
 217             else:
 218                 notunderstood = True
 219         elif cmd == u"leave":
 220             if auteur in self.ops and len(message) > 1:
 221                 if message[1] in self.chanlist:
 222                     if not (message[1] in self.stay_channels) or auteur in self.overops:
 223                         self.quitter(message[1].encode("utf-8"), " ".join(message[2:]))
 224                         self.chanlist.remove(message[1])
 225                         log(self.serveur, "priv", auteur, " ".join(message) + "[successful]")
 226                     else:
 227                         serv.privmsg(auteur, "Non, je reste !")
 228                         log(self.serveur, "priv", auteur, " ".join(message) + "[failed]")
 229                 else:
 230                     serv.privmsg(auteur, "Je ne suis pas sur %s" % (message[1]))
 231             else:
 232                 notunderstood = True
 233         elif cmd == u"stay":
 234             if auteur in self.overops:
 235                 if len(message) > 1:
 236                     if message[1] in self.stay_channels:
 237                         log(self.serveur, "priv", auteur, " ".join(message) + "[failed]")
 238                         serv.privmsg(auteur, "Je stay déjà sur %s." % (message[1]))
 239                     else:
 240                         log(self.serveur, "priv", auteur, " ".join(message) + "[successful]")
 241                         self.stay_channels.append(message[1])
 242                         serv.privmsg(auteur, "Stay channels : " + " ".join(self.stay_channels))
 243                 else:
 244                     serv.privmsg(auteur, "Stay channels : " + " ".join(self.stay_channels))
 245             else:
 246                 notunderstood = True
 247         elif cmd == u"nostay":
 248             if auteur in self.overops:
 249                 if len(message) > 1:
 250                     if message[1] in self.stay_channels:
 251                         log(self.serveur, "priv", auteur, " ".join(message) + "[successful]")
 252                         self.stay_channels.remove(message[1])
 253                         serv.privmsg(auteur, "Stay channels : " + " ".join(self.stay_channels))
 254                     else:
 255                         log(self.serveur, "priv", auteur, " ".join(message) + "[failed]")
 256                         serv.privmsg(auteur, "Je ne stay pas sur %s." % (message[1]))
 257             else:
 258                 notunderstood = True
 259         elif cmd == u"die":
 260             if auteur in self.overops:
 261                 log(self.serveur, "priv", auteur, " ".join(message) + "[successful]")
 262                 self.mourir()
 263             else:
 264                 notunderstood = True
 265         elif cmd == u"crash":
 266             if auteur in self.overops:
 267                 log(self.serveur, "priv", auteur, " ".join(message) + "[successful]")
 268                 self.crash(auteur, "priv")
 269             else:
 270                 notunderstood = True
 271         elif cmd == u"reload":
 272             if auteur in self.ops:
 273                 self.execute_something("reload", {"auteur" : auteur}, place=auteur, auteur=auteur)
 274             else:
 275                 notunderstood = True
 276         elif cmd == u"quiet":
 277             if auteur in self.ops:
 278                 if len(message) > 1:
 279                     if message[1] in self.quiet_channels:
 280                         serv.privmsg(auteur, "Je me la ferme déjà sur %s" % (message[1]))
 281                         log(self.serveur, "priv", auteur, " ".join(message) + "[failed]")
 282                     else:
 283                         self.quiet_channels.append(message[1])
 284                         serv.privmsg(auteur, "Quiet channels : " + " ".join(self.quiet_channels))
 285                         log(self.serveur, "priv", auteur, " ".join(message) + "[successful]")
 286                 else:
 287                     serv.privmsg(auteur, "Quiet channels : " + " ".join(self.quiet_channels))
 288             else:
 289                 notunderstood = True
 290         elif cmd == u"noquiet":
 291             if auteur in self.ops:
 292                 if len(message) > 1:
 293                     if message[1] in self.quiet_channels:
 294                         self.quiet_channels.remove(message[1])
 295                         serv.privmsg(auteur, "Quiet channels : " + " ".join(self.quiet_channels))
 296                         log(self.serveur, "priv", auteur, " ".join(message) + "[successful]")
 297                     else:
 298                         serv.privmsg(auteur, "Je ne me la ferme pas sur %s." % (message[1]))
 299                         log(self.serveur, "priv", auteur, " ".join(message) + "[failed]")
 300             else:
 301                 notunderstood = True
 302         elif cmd == u"say":
 303             if auteur in self.overops and len(message) > 2:
 304                 serv.privmsg(message[1].encode("utf-8"), (u" ".join(message[2:])).encode("utf-8"))
 305                 log(self.serveur, "priv", auteur, " ".join(message))
 306             elif len(message) <= 2:
 307                 serv.privmsg(auteur, "Syntaxe : SAY <channel> <message>")
 308             else:
 309                 notunderstood = True
 310         elif cmd == u"do":
 311             if auteur in self.overops and len(message) > 2:
 312                 serv.action(message[1], " ".join(message[2:]))
 313                 log(self.serveur, "priv", auteur, " ".join(message))
 314             elif len(message) <= 2:
 315                 serv.privmsg(auteur, "Syntaxe : DO <channel> <action>")
 316             else:
 317                 notunderstood = True
 318         elif cmd == u"kick":
 319             if auteur in self.overops and len(message) > 2:
 320                 serv.kick(message[1].encode("utf-8"), message[2].encode("utf-8"), " ".join(message[3:]).encode("utf-8"))
 321                 log(self.serveur, "priv", auteur, " ".join(message))
 322             elif len(message) <= 2:
 323                 serv.privmsg(auteur, "Syntaxe : KICK <channel> <pseudo> [<raison>]")
 324             else:
 325                 notunderstood = True
 326         elif cmd == u"ops":
 327             if auteur in self.overops:
 328                 serv.privmsg(auteur, " ".join(self.ops))
 329             else:
 330                 notunderstood = True
 331         elif cmd == u"overops":
 332             if auteur in self.overops:
 333                 serv.privmsg(auteur, " ".join(self.overops))
 334             else:
 335                 notunderstood = True
 336         if notunderstood:
 337             serv.privmsg(auteur, "I don't understand what you're saying. Try HELP…")
 338
 339     def on_pubmsg(self, serv, ev):
 340         """À la réception d'un message sur un channel."""
 341         if ignore_event(serv, ev):
 342             return
 343         auteur = irclib.nm_to_n(ev.source())
 344         canal = ev.target()
 345         message = ev.arguments()[0]
 346         try:
 347             message = bot_unicode(message)
 348         except errors.UnicodeBotError:
 349             if config.utf8_trigger and not canal in self.quiet_channels:
 350                 serv.privmsg(canal, (u"%s: %s"% ( auteur, random.choice(config.utf8_fail_answers))).encode("utf8"))
 351             return
 352         pour_moi, message = self.pourmoi(serv, message)
 353         if pour_moi and message.split()!=[]:
 354             cmd = message.split()[0].lower()
 355             try:
 356                 args = " ".join(message.split()[1:])
 357             except:
 358                 args = ""
 359             if cmd in [u"meurs", u"die", u"crève"]:
 360                 if auteur in self.overops:
 361                     log(self.serveur, canal, auteur, message + "[successful]")
 362                     self.mourir()
 363                 else:
 364                     serv.privmsg(canal,(u"%s: %s"%(auteur, random.choice(config.quit_fail_messages))).encode("utf8"))
 365                     log(self.serveur, canal, auteur, message + "[failed]")
 366             elif cmd == u"reload":
 367                 if auteur in self.ops:
 368                     self.execute_something("reload", {"auteur" : auteur}, place=canal, auteur=auteur)
 369             elif cmd == u"crash":
 370                 if auteur in self.overops:
 371                     self.crash(auteur, canal)
 372             elif cmd in [u"part", u"leave", u"dégage", u"va-t-en"]:
 373                 if auteur in self.ops and (not (canal in self.stay_channels)
 374                                            or auteur in self.overops):
 375                     self.quitter(canal)
 376                     log(self.serveur, canal, auteur, message + "[successful]")
 377                     if canal in self.chanlist:
 378                         self.chanlist.remove(canal)
 379                 else:
 380                     serv.privmsg(canal,(u"%s: %s" % (auteur, random.choice(config.leave_fail_messages))).encode("utf8"))
 381                     log(self.serveur, canal, auteur, message + "[failed]")
 382
 383             elif cmd in [u"deviens", u"pseudo", u"become", u"nick"]:
 384                 if auteur in self.ops:
 385                     become = args
 386                     serv.nick(become)
 387                     log(self.serveur, canal, auteur, message + "[successful]")
 388
 389             elif cmd in [u"ping"] and not canal in self.quiet_channels:
 390                 serv.privmsg(canal, "%s: pong" % (auteur))
 391
 392             if isit.is_tag(message) and not canal in self.quiet_channels:
 393                 if auteur in self.ops:
 394                     action = random.choice(config.tag_actions)
 395                     serv.action(canal, action.encode("utf8"))
 396                     self.quiet_channels.append(canal)
 397                 else:
 398                     answer = random.choice(config.tag_answers)
 399                     for ligne in answer.split("\n"):
 400                         serv.privmsg(canal, "%s: %s" % (auteur, ligne.encode("utf8")))
 401
 402     def on_action(self, serv, ev):
 403         """À la réception d'une action."""
 404         if ignore_event(serv, ev):
 405             return
 406         action = ev.arguments()[0]
 407         auteur = irclib.nm_to_n(ev.source())
 408         channel = ev.target()
 409         try:
 410             action = bot_unicode(action)
 411         except errors.UnicodeBotError:
 412             if config.utf8_trigger and not channel in self.quiet_channels:
 413                 serv.privmsg(channel, (u"%s: %s"%(auteur,random.choice(config.utf8_fail_answers))).encode("utf8"))
 414             return
 415         mypseudo = self.nick
 416
 417     def on_kick(self, serv, ev):
 418         """À la réception d'une action."""
 419         auteur = irclib.nm_to_n(ev.source())
 420         channel = ev.target()
 421         victime = ev.arguments()[0]
 422         raison = ev.arguments()[1]
 423         if victime == self.nick:
 424             log(self.serveur, ("%s kické de %s par %s (raison : %s)" % (victime, channel, auteur, raison)).decode("utf-8"))
 425             time.sleep(10)
 426             serv.join(channel)
 427 #            l1, l2 = config.kick_answers, config.kick_actions
 428 #            n1, n2 = len(l1), len(l2)
 429 #            i = random.randrange(n1 + n2)
 430 #            if i >= n1:
 431 #                serv.action(channel, l2[i-n1].format(auteur).encode("utf8"))
 432 #            else:
 433 #                serv.privmsg(channel, l1[i].format(auteur).encode("utf8"))
 434
 435     ### .fork trick
 436     def start_as_daemon(self, outfile):
 437         sys.stderr = Logger(outfile)
 438         self.start()
 439
 440
 441 class Logger(object):
 442     """Pour écrire ailleurs que sur stdout"""
 443     def __init__(self, filename="basile.full.log"):
 444         self.filename = filename
 445
 446     def write(self, message):
 447         f = open(self.filename, "a")
 448         f.write(message)
 449         f.close()
 450
 451 def main():
 452     """Exécution principal : lecture des paramètres et lancement du bot."""
 453     if len(sys.argv) == 1:
 454         print "Usage : josh.py <serveur> [--debug] [--no-output] [--daemon [--pidfile]] [--outfile]"
 455         print "        --outfile sans --no-output ni --daemon n'a aucun effet"
 456         exit(1)
 457     serveur = sys.argv[1]
 458     if "--daemon" in sys.argv:
 459         thisfile = os.path.realpath(__file__)
 460         thisdirectory = thisfile.rsplit("/", 1)[0]
 461         os.chdir(thisdirectory)
 462         daemon = True
 463     else:
 464         daemon = False
 465     if "debug" in sys.argv or "--debug" in sys.argv:
 466         debug = True
 467     else:
 468         debug = False
 469     if "--quiet" in sys.argv:
 470         config.debug_stdout = False
 471     serveurs = {
 472         "crans" : "irc.crans.org",
 473         "irc.crans.org" : "irc.crans.org",
 474         "hackint" : "irc.hackint.org",
 475         "irc.hackint.org" : "irc.hackint.org",
 476         }
 477     if "--no-output" in sys.argv or "--daemon" in sys.argv:
 478         outfile = "/var/log/bots/josh.full.log"
 479         for arg in sys.argv:
 480             arg = arg.split("=")
 481             if arg[0].strip('-') in ["out", "outfile", "logfile"]:
 482                 outfile = arg[1]
 483         sys.stdout = Logger(outfile)
 484     try:
 485         serveur = serveurs[serveur]
 486     except KeyError:
 487         print "Server Unknown : %s" % (serveur)
 488         exit(404)
 489     josh = Josh(serveur,debug)
 490     # Si on reçoit un SIGHUP, on reload la config
 491     def sighup_handler(signum, frame):
 492         basile.execute_reload(auteur="SIGHUP")
 493     signal.signal(signal.SIGHUP, sighup_handler)
 494     # Daemonization
 495     if daemon:
 496         child_pid = os.fork()
 497         if child_pid == 0:
 498             os.setsid()
 499             basile.start_as_daemon(outfile)
 500         else:
 501             # on enregistre le pid du bot
 502             pidfile = "/var/run/bots/josh.pid"
 503             for arg in sys.argv:
 504                 arg = arg.split("=")
 505                 if arg[0].strip('-') in ["pidfile"]:
 506                     pidfile = arg[1]
 507             f = open(pidfile, "w")
 508             f.write("%s\n" % child_pid)
 509             f.close()
 510     else:
 511         josh.start()
 512
 513 if __name__ == "__main__":
 514     main()