+#!/usr/bin/python
+# -*- coding:utf8 -*-
+
+# Codé par 20-100 (commencé le 23/04/12)
+
+# Un bot IRC qui, un jour, s'interfacera avec la Note Kfet 2015
+
+import threading
+import random
+import time
+import socket, ssl, json
+import pickle
+import re
+import os
+import signal
+import sys
+
+# Oui, j'ai recodé ma version d'irclib pour pouvoir rattrapper les SIGHUP
+sys.path.insert(0, "/home/vincent/scripts/python-myirclib")
+import irclib
+import ircbot
+
+from commands import getstatusoutput as ex
+
+# on récupère la config
+import config
+
+# la partie qui réfère au fichier lui-même est mieux ici
+# sinon on réfère la config et pas le fichier lui-même
+import os
+config.thisfile= os.path.realpath( __file__ )
+
+def get_config_logfile(serveur):
+ serveurs={"acoeur.crans.org":"acoeur","irc.crans.org":"crans"}
+ return config.logfile_template%(serveurs[serveur])
+
+def log(serveur,channel,auteur=None,message=None):
+ f=open(get_config_logfile(serveur),"a")
+ if auteur==message==None:
+ # alors c'est que c'est pas un channel mais juste une ligne de log
+ chain="%s %s"%(time.strftime("%F %T"),channel)
+ else:
+ chain="%s [%s:%s] %s"%(time.strftime("%F %T"),channel,auteur,message)
+ f.write(chain+"\n")
+ if config.debug_stdout:
+ print chain
+ f.close()
+
+def is_something(chain,matches,avant=u".*(?:^| )",apres=u"(?:$|\.| |,|;).*",case_sensitive=False,debug=False):
+ if case_sensitive:
+ chain=unicode(chain,"utf8")
+ else:
+ chain=unicode(chain,"utf8").lower()
+ allmatches="("+"|".join(matches)+")"
+ reg=(avant+allmatches+apres).lower()
+ o=re.match(reg,chain)
+ return o
+
+def is_insult(chain,debug=True):
+ return is_something(chain,config.insultes,avant=".*(?:^| |')")
+def is_not_insult(chain):
+ chain=unicode(chain,"utf8")
+ insult_regexp=u"("+u"|".join(config.insultes)+u")"
+ middle_regexp=u"(une? (?:(?:putain|enfoiré) d(?:e |'))*|)(?:| super )(?: (?:gros|petit|grand|énorme) |)"
+ reg=".*pas %s%s.*"%(middle_regexp,insult_regexp)
+ if re.match(reg,chain):
+ return True
+ else:
+ return False
+def is_compliment(chain,debug=True):
+ return is_something(chain,config.compliment_triggers,avant=".*(?:^| |')")
+def is_perdu(chain):
+ return is_something(chain,config.perdu)
+def is_tag(chain):
+ return is_something(chain,config.tag_triggers)
+def is_gros(chain):
+ return is_something(chain,config.gros)
+def is_tesla(chain):
+ return is_something(chain,config.tesla_triggers,avant=u"^",apres=u"$",debug=True)
+def is_merci(chain):
+ return is_something(chain,config.merci_triggers)
+def is_tamere(chain):
+ return is_something(chain,config.tamere_triggers)
+def is_bad_action_trigger(chain,pseudo):
+ return is_something(chain,config.bad_action_triggers,avant=u"^",
+ apres="(?: [a-z]*ment)? %s($|\.| |,|;).*"%(pseudo))
+def is_good_action_trigger(chain,pseudo):
+ return is_something(chain,config.good_action_triggers,avant=u"^",
+ apres="(?: [a-z]*ment)? %s($|\.| |,|;).*"%(pseudo))
+def is_bonjour(chain):
+ return is_something(chain,config.bonjour_triggers,avant=u"^")
+def is_bonne_nuit(chain):
+ return is_something(chain,config.bonne_nuit_triggers,avant=u"^")
+def is_pan(chain):
+ return re.match(u"^(pan|bim|bang)( .*)?$",unicode(chain,"utf8").lower().strip())
+
+def is_time(conf):
+ _,_,_,h,m,s,_,_,_=time.localtime()
+ return (conf[0],0,0)<(h,m,s)<(conf[1],0,0)
+def is_day():
+ return is_time(config.daytime)
+def is_night():
+ return is_time(config.nighttime)
+
+
+class UnicodeBotError(Exception):
+ pass
+
+class CrashError(Exception):
+ """Pour pouvoir faire crasher le bot, parce que ça a l'air drôle"""
+ pass
+
+def bot_unicode(chain):
+ try:
+ unicode(chain,"utf8")
+ except UnicodeDecodeError as exc:
+ raise UnicodeBotError
+
+
+class Ibot(ircbot.SingleServerIRCBot):
+ def __init__(self,serveur,debug=False):
+ temporary_pseudo=config.irc_pseudo+str(random.randrange(10000,100000))
+ ircbot.SingleServerIRCBot.__init__(self, [(serveur, 6667)],
+ temporary_pseudo,"iDon't care", 10)
+ self.debug=debug
+ self.serveur=serveur
+ self.overops=config.overops
+ self.ops=self.overops+config.ops
+ self.report_bugs_to=config.report_bugs_to
+ self.chanlist=config.chanlist
+ self.stay_channels=config.stay_channels
+ self.i_channels=config.i_channels
+ self.quiet_channels=config.quiet_channels
+ self.last_perdu=0
+
+
+ def give_me_my_pseudo(self,serv):
+ serv.privmsg("NickServ","RECOVER %s %s"%(config.irc_pseudo,config.irc_password))
+ serv.privmsg("NickServ","RELEASE %s %s"%(config.irc_pseudo,config.irc_password))
+ time.sleep(0.3)
+ serv.nick(config.irc_pseudo)
+
+ def on_welcome(self, serv, ev):
+ self.serv=serv # ça serv ira :)
+ self.give_me_my_pseudo(serv)
+ serv.privmsg("NickServ","identify %s"%(config.irc_password))
+ log(self.serveur,"Connected")
+ if self.debug:
+ self.chanlist=["#bot"]
+ for c in self.chanlist:
+ log(self.serveur,"JOIN %s"%(c))
+ serv.join(c)
+
+ def pourmoi(self, serv, message):
+ """renvoie (False,lemessage) ou (True, le message amputé de "pseudo: ")"""
+ pseudo=self.nick
+ size=len(pseudo)
+ if message[:size]==pseudo and len(message)>size and message[size]==":":
+ return (True,message[size+1:].lstrip(" "))
+ else:
+ return (False,message)
+
+ def on_privmsg(self, serv, ev):
+ message=ev.arguments()[0]
+ auteur = irclib.nm_to_n(ev.source())
+ try:
+ test=bot_unicode(message)
+ except UnicodeBotError:
+ if config.utf8_trigger:
+ serv.privmsg(auteur, random.choice(config.utf8_fail_answers).encode("utf8"))
+ return
+ message=message.split()
+ cmd=message[0].lower()
+ notunderstood=False
+ if cmd=="help":
+ helpdico={"help": ["""HELP <commande>
+ Affiche de l'aide sur la commande""",None,None],
+ "join": [None, """JOIN <channel>
+ Me fait rejoindre le channel""",None],
+ "leave": [None,"""LEAVE <channel>
+ Me fait quitter le channel (sauf s'il est dans ma stay_list).""",None],
+ "ichannel": [None, """ICHANNEL <channel>,
+ Rend le channel i-nazi""", None],
+ "noichannel": [None, """NOICHANNEL <channel>,
+ Dé-i-nazifie le channel""", None],
+ "reload": [None,"""RELOAD
+ Recharge la configuration.""",None],
+ "say": [None,None,"""SAY <channel> <message>
+ Me fait parler sur le channel."""],
+ "do": [None,None,"""DO <channel> <action>
+ Me fait faitre une action (/me) sur le channel."""],
+ "stay": [None,None,"""STAY <channel>
+ Ajoute le channel à ma stay_list."""],
+ "nostay": [None,None,"""NOSTAY <channel>
+ Retire le channel de ma stay_list."""],
+ "ops": [None,None,"""OPS
+ Affiche la liste des ops."""],
+ "overops": [None,None,"""OVEROPS
+ Affiche la liste des overops."""],
+ "kick": [None,None,"""KICK <channel> <pseudo> [<raison>]
+ Kicke <pseudo> du channel (Il faut bien entendu que j'y sois op)."""],
+ "die": [None,None,"""DIE
+ Me déconnecte du serveur IRC."""],
+ "crash": [None,None,"""CRASH
+ Me fait crasher"""]
+ }
+ helpmsg_default="Liste des commandes disponibles :\nHELP "
+ helpmsg_ops=" JOIN LEAVE QUIET NOQUIET LOST RELOAD ICHANNEL NOICHANNEL"
+ helpmsg_overops=" SAY DO STAY NOSTAY OPS OVEROPS KICK DIE CRASH"
+ op,overop=auteur in self.ops, auteur in self.overops
+ if len(message)==1:
+ helpmsg=helpmsg_default
+ if op:
+ helpmsg+=helpmsg_ops
+ if overop:
+ helpmsg+=helpmsg_overops
+ else:
+ helpmsgs=helpdico.get(message[1].lower(),["Commande inconnue.",None,None])
+ helpmsg=helpmsgs[0]
+ if op and helpmsgs[1]:
+ if helpmsg:
+ helpmsg+="\n"+helpmsgs[1]
+ else:
+ helpmsg=helpmsgs[1]
+ if overop and helpmsgs[2]:
+ if helpmsg:
+ helpmsg+="\n"+helpmsgs[2]
+ else:
+ helpmsg=helpmsgs[2]
+ for ligne in helpmsg.split("\n"):
+ serv.privmsg(auteur,ligne)
+ elif cmd=="join":
+ if auteur in self.ops:
+ if len(message)>1:
+ if message[1] in self.chanlist:
+ serv.privmsg(auteur,"Je suis déjà sur %s"%(message[1]))
+ else:
+ serv.join(message[1])
+ self.chanlist.append(message[1])
+ serv.privmsg(auteur,"Channels : "+" ".join(self.chanlist))
+ log(self.serveur,"priv",auteur," ".join(message))
+ else:
+ serv.privmsg(auteur,"Channels : "+" ".join(self.chanlist))
+ else:
+ notunderstood=True
+ elif cmd=="leave":
+ if auteur in self.ops and len(message)>1:
+ if message[1] in self.chanlist:
+ if not (message[1] in self.stay_channels) or auteur in self.overops:
+ self.quitter(message[1]," ".join(message[2:]))
+ self.chanlist.remove(message[1])
+ log(self.serveur,"priv",auteur," ".join(message)+"[successful]")
+ else:
+ serv.privmsg(auteur,"Non, je reste !")
+ log(self.serveur,"priv",auteur," ".join(message)+"[failed]")
+ else:
+ serv.privmsg(auteur,"Je ne suis pas sur %s"%(message[1]))
+ else:
+ notunderstood=True
+ elif cmd=="stay":
+ if auteur in self.overops:
+ if len(message)>1:
+ if message[1] in self.stay_channels:
+ log(self.serveur,"priv",auteur," ".join(message)+"[failed]")
+ serv.privmsg(auteur,"Je stay déjà sur %s."%(message[1]))
+ else:
+ log(self.serveur,"priv",auteur," ".join(message)+"[successful]")
+ self.stay_channels.append(message[1])
+ serv.privmsg(auteur,"Stay channels : "+" ".join(self.stay_channels))
+ else:
+ serv.privmsg(auteur,"Stay channels : "+" ".join(self.stay_channels))
+ else:
+ notunderstood=True
+ elif cmd=="nostay":
+ if auteur in self.overops:
+ if len(message)>1:
+ if message[1] in self.stay_channels:
+ log(self.serveur,"priv",auteur," ".join(message)+"[successful]")
+ self.stay_channels.remove(message[1])
+ serv.privmsg(auteur,"Stay channels : "+" ".join(self.stay_channels))
+ else:
+ log(self.serveur,"priv",auteur," ".join(message)+"[failed]")
+ serv.privmsg(auteur,"Je ne stay pas sur %s."%(message[1]))
+
+ else:
+ notunderstood=True
+ elif cmd=="ichannel":
+ if auteur in self.ops:
+ if len(message)>1:
+ if message[1] in self.i_channels:
+ log(self.serveur,"priv",auteur," ".join(message)+"[failed]")
+ serv.privmsg(auteur,"%s est déjà i-nazi."%(message[1]))
+ else:
+ log(self.serveur,"priv",auteur," ".join(message)+"[successful]")
+ self.i_channels.append(message[1])
+ serv.privmsg(auteur,"I-channels : "+" ".join(self.i_channels))
+ else:
+ serv.privmsg(auteur,"I-channels : "+" ".join(self.i_channels))
+ else:
+ notunderstood=True
+ elif cmd=="nostay":
+ if auteur in self.ops:
+ if len(message)>1:
+ if message[1] in self.i_channels:
+ log(self.serveur,"priv",auteur," ".join(message)+"[successful]")
+ self.i_channels.remove(message[1])
+ serv.privmsg(auteur,"I-channels : "+" ".join(self.i_channels))
+ else:
+ log(self.serveur,"priv",auteur," ".join(message)+"[failed]")
+ serv.privmsg(auteur,"%s n'est pas i-nazi."%(message[1]))
+
+ else:
+ notunderstood=True
+ elif cmd=="die":
+ if auteur in self.overops:
+ log(self.serveur,"priv",auteur," ".join(message)+"[successful]")
+ self.mourir()
+ else:
+ notunderstood=True
+ elif cmd=="crash":
+ if auteur in self.overops:
+ log(self.serveur,"priv",auteur," ".join(message)+"[successful]")
+ self.crash()
+ else:
+ notunderstood=True
+ elif cmd=="reload":
+ if auteur in self.ops:
+ self.reload(auteur)
+ log(self.serveur,"priv",auteur," ".join(message)+"[successful]")
+ else:
+ notunderstood=True
+ elif cmd=="quiet":
+ if auteur in self.ops:
+ if len(message)>1:
+ if message[1] in self.quiet_channels:
+ serv.privmsg(auteur,"Je me la ferme déjà sur %s"%(message[1]))
+ log(self.serveur,"priv",auteur," ".join(message)+"[failed]")
+ else:
+ self.quiet_channels.append(message[1])
+ serv.privmsg(auteur,"Quiet channels : "+" ".join(self.quiet_channels))
+ log(self.serveur,"priv",auteur," ".join(message)+"[successful]")
+ else:
+ serv.privmsg(auteur,"Quiet channels : "+" ".join(self.quiet_channels))
+ else:
+ notunderstood=True
+ elif cmd=="noquiet":
+ if auteur in self.ops:
+ if len(message)>1:
+ if message[1] in self.quiet_channels:
+ self.quiet_channels.remove(message[1])
+ serv.privmsg(auteur,"Quiet channels : "+" ".join(self.quiet_channels))
+ log(self.serveur,"priv",auteur," ".join(message)+"[successful]")
+ else:
+ serv.privmsg(auteur,"Je ne me la ferme pas sur %s."%(message[1]))
+ log(self.serveur,"priv",auteur," ".join(message)+"[failed]")
+ else:
+ notunderstood=True
+ elif cmd=="say":
+ if auteur in self.overops and len(message)>2:
+ serv.privmsg(message[1]," ".join(message[2:]))
+ log(self.serveur,"priv",auteur," ".join(message))
+ elif len(message)<=2:
+ serv.privmsg(auteur,"Syntaxe : SAY <channel> <message>")
+ else:
+ notunderstood=True
+ elif cmd=="do":
+ if auteur in self.overops and len(message)>2:
+ serv.action(message[1]," ".join(message[2:]))
+ log(self.serveur,"priv",auteur," ".join(message))
+ elif len(message)<=2:
+ serv.privmsg(auteur,"Syntaxe : DO <channel> <action>")
+ else:
+ notunderstood=True
+ elif cmd=="kick":
+ if auteur in self.overops and len(message)>2:
+ serv.kick(message[1],message[2]," ".join(message[3:]))
+ log(self.serveur,"priv",auteur," ".join(message))
+ elif len(message)<=2:
+ serv.privmsg(auteur,"Syntaxe : KICK <channel> <pseudo> [<raison>]")
+ else:
+ notunderstood=True
+ elif cmd=="ops":
+ if auteur in self.overops:
+ serv.privmsg(auteur," ".join(self.ops))
+ else:
+ notunderstood=True
+ elif cmd=="overops":
+ if auteur in self.overops:
+ serv.privmsg(auteur," ".join(self.overops))
+ else:
+ notunderstood=True
+ else:
+ notunderstood=True
+ if notunderstood:
+ serv.privmsg(auteur,"Je n'ai pas compris. Essayez HELP…")
+
+ def on_pubmsg(self, serv, ev):
+ auteur = irclib.nm_to_n(ev.source())
+ canal = ev.target()
+ message = ev.arguments()[0]
+ try:
+ test=bot_unicode(message)
+ except UnicodeBotError:
+ if config.utf8_trigger and not canal in self.quiet_channels:
+ serv.privmsg(canal, (u"%s: %s"%(auteur,random.choice(config.utf8_fail_answers))).encode("utf8"))
+ return
+ pour_moi,message=self.pourmoi(serv,message)
+ if pour_moi and message.split()!=[]:
+ cmd=message.split()[0].lower()
+ try:
+ args=" ".join(message.split()[1:])
+ except:
+ args=""
+ if cmd in ["meurs","die","crève"]:
+ if auteur in self.overops:
+ log(self.serveur,canal,auteur,message+"[successful]")
+ self.mourir()
+ elif cmd == "reload":
+ if auteur in self.ops:
+ log(self.serveur, canal, auteur, message+"[successful]")
+ self.reload(canal)
+ elif cmd == "crash":
+ if auteur in self.overops:
+ self.crash()
+ elif cmd in ["part","leave","dégage","va-t-en"]:
+ if auteur in self.ops and (not (canal in self.stay_channels)
+ or auteur in self.overops):
+ self.quitter(canal)
+ log(self.serveur,canal,auteur,message+"[successful]")
+ if canal in self.chanlist:
+ self.chanlist.remove(canal)
+ elif cmd in ["deviens","pseudo"]:
+ if auteur in self.ops:
+ become=args
+ serv.nick(become)
+ log(self.serveur,canal,auteur,message+"[successful]")
+
+ else:
+ if not re.match(u'i.*',message.decode("utf8").lower().strip(u" ")) and canal in self.i_channels:
+ serv.kick(canal, auteur, u"iKick".encode("utf8"))
+
+ def on_action(self, serv, ev):
+ action = ev.arguments()[0]
+ auteur = irclib.nm_to_n(ev.source())
+ channel = ev.target()
+ try:
+ test=bot_unicode(action)
+ except UnicodeBotError:
+ if config.utf8_trigger and not channel in self.quiet_channels:
+ serv.privmsg(channel, (u"%s: %s"%(auteur,random.choice(config.utf8_fail_answers))).encode("utf8"))
+ return
+ mypseudo=self.nick
+
+ def on_kick(self,serv,ev):
+ auteur = irclib.nm_to_n(ev.source())
+ channel = ev.target()
+ victime = ev.arguments()[0]
+ raison = ev.arguments()[1]
+ if victime==self.nick:
+ log(self.serveur,"%s kické de %s par %s (raison : %s)" %(victime,channel,auteur,raison))
+ time.sleep(2)
+ serv.join(channel)
+
+ def quitter(self,chan,leave_message=None):
+ if leave_message==None:
+ leave_message=random.choice(config.leave_messages)
+ self.serv.part(chan,message=leave_message.encode("utf8"))
+
+ def mourir(self):
+ quit_message=random.choice(config.quit_messages)
+ self.die(msg=quit_message.encode("utf8"))
+
+ def _getnick(self):
+ return self.serv.get_nickname()
+ nick=property(_getnick)
+
+ def reload(self, auteur=None):
+ reload(config)
+ if auteur in [None, "SIGHUP"]:
+ towrite = "Config reloaded" + " (SIGHUP received)"*(auteur == "SIGHUP")
+ for to in config.report_bugs_to:
+ self.serv.privmsg(to, towrite)
+ log(self.serveur, towrite)
+ else:
+ self.serv.privmsg(auteur,"Config reloaded")
+
+ def crash(self):
+ raise CrashError
+
+ def start_as_daemon(self, outfile):
+ sys.stderr = Logger(outfile)
+ self.start()
+
+
+class Logger(object):
+ """Pour écrire ailleurs que sur stdout"""
+ def __init__(self, filename="ibot.full.log"):
+ self.filename = filename
+
+ def write(self, message):
+ f = open(self.filename, "a")
+ f.write(message)
+ f.close()
+
+def main():
+ if len(sys.argv)==1:
+ print "Usage : ibot.py <serveur> [--debug] [--no-output] [--daemon [--pidfile]] [--outfile]"
+ print " --outfile sans --no-output ni --daemon n'a aucun effet"
+ exit(1)
+ serveur=sys.argv[1]
+ if "--daemon" in sys.argv:
+ thisfile = os.path.realpath(__file__)
+ thisdirectory = thisfile.rsplit("/", 1)[0]
+ os.chdir(thisdirectory)
+ daemon = True
+ else:
+ daemon = False
+ if "debug" in sys.argv or "--debug" in sys.argv:
+ debug=True
+ else:
+ debug=False
+ if "--quiet" in sys.argv:
+ config.debug_stdout=False
+ serveurs={"a♡":"acoeur.crans.org","acoeur":"acoeur.crans.org","acoeur.crans.org":"acoeur.crans.org",
+ "irc":"irc.crans.org","crans":"irc.crans.org","irc.crans.org":"irc.crans.org"}
+ if "--no-output" in sys.argv or "--daemon" in sys.argv:
+ outfile = "/var/log/bots/ibot.full.log"
+ for arg in sys.argv:
+ arg = arg.split("=")
+ if arg[0].strip('-') in ["out", "outfile", "logfile"]:
+ outfile = arg[1]
+ sys.stdout = Logger(outfile)
+ try:
+ serveur=serveurs[serveur]
+ except KeyError:
+ print "Server Unknown : %s"%(serveur)
+ exit(404)
+ ibot=Ibot(serveur,debug)
+ # Si on reçoit un SIGHUP, on reload la config
+ def sighup_handler(signum, frame):
+ ibot.reload("SIGHUP")
+ signal.signal(signal.SIGHUP, sighup_handler)
+ if daemon:
+ child_pid = os.fork()
+ if child_pid == 0:
+ os.setsid()
+ ibot.start_as_daemon(outfile)
+ else:
+ # on enregistre le pid du bot
+ pidfile = "/var/run/bots/ibot.pid"
+ for arg in sys.argv:
+ arg = arg.split("=")
+ if arg[0].strip('-') in ["pidfile"]:
+ pidfile = arg[1]
+ f = open(pidfile, "w")
+ f.write("%s\n" % child_pid)
+ f.close()
+ else:
+ ibot.start()
+
+if __name__ == "__main__":
+ main()