4 # Codé par 20-100 (commencé le 23/04/12)
6 # Un bot IRC qui, un jour, s'interfacera avec la Note Kfet 2015
11 import socket
, ssl
, json
18 # Oui, j'ai recodé ma version d'irclib pour pouvoir rattrapper les SIGHUP
19 sys
.path
.insert(0, "/home/vincent/scripts/python-myirclib")
23 from commands
import getstatusoutput
as ex
25 # on récupère la config
28 # la partie qui réfère au fichier lui-même est mieux ici
29 # sinon on réfère la config et pas le fichier lui-même
31 config
.thisfile
= os
.path
.realpath( __file__
)
33 def get_config_logfile(serveur
):
34 serveurs
={"acoeur.crans.org":"acoeur","irc.crans.org":"crans"}
35 return config
.logfile_template
%(serveurs
[serveur
])
38 return ex("ls -s %s"%(config
.thisfile
))[1].split()[0]
40 class NKError(Exception):
41 def __init__(self
,msg
):
42 Exception.__init
__(self
)
46 def __unicode__(self
):
47 return unicode(self
.msg
)
49 class NKRefused(NKError
):
52 class NKHelloFailed(NKError
):
55 class NKUnknownError(NKError
):
58 def log(serveur
,channel
,auteur
=None,message
=None):
59 f
=open(get_config_logfile(serveur
),"a")
60 if auteur
==message
==None:
61 # alors c'est que c'est pas un channel mais juste une ligne de log
62 chain
="%s %s"%(time
.strftime("%F %T"),channel
)
64 chain
="%s [%s:%s] %s"%(time
.strftime("%F %T"),channel
,auteur
,message
)
66 if config
.debug_stdout
:
73 # On établit la connexion sur port 4242
74 sock
.connect((config
.nk_server
, config
.nk_port
))
76 sock
=ssl
.wrap_socket(sock
,ca_certs
='../keys/ca_.crt')
78 sock
.write('["hello", "Basile"]')
79 # On récupère la réponse du hello
82 except Exception as exc
:
83 # Si on a foiré quelque part, c'est que le serveur est down
84 raise NKRefused(str(exc
))
87 elif out
["retcode"]==11:
88 raise NKHelloFailed(out
["errmsg"])
90 raise NKUnknownError(out
["errmsg"])
92 def login_NK(username
,password
,typ
="bdd"):
94 if typ
=="special": # ça c'est pour Basile lui-même
97 masque
='[[], [], true]'
99 # Basile a un compte special user
100 commande
='["login", [%s,%s,"%s",%s]]'%(json
.dumps(username
),json
.dumps(password
),typ
,masque
)
103 except Exception as exc
:
104 # Si on a foiré quelque part, c'est que le serveur est down
105 raise NKRefused(str(exc
))
106 # On vérifie ensuite que le login
107 return json
.loads(out
),sock
110 def is_something(chain
,matches
,avant
=u
".*(?:^| )",apres
=u
"(?:$|\.| |,|;).*",case_sensitive
=False,debug
=False):
112 chain
=unicode(chain
,"utf8")
114 chain
=unicode(chain
,"utf8").lower()
115 allmatches
="("+"|".join(matches
)+")"
116 reg
=(avant
+allmatches
+apres
).lower()
117 o
=re
.match(reg
,chain
)
120 def is_insult(chain
,debug
=True):
121 return is_something(chain
,config
.insultes
,avant
=".*(?:^| |')")
122 def is_not_insult(chain
):
123 chain
=unicode(chain
,"utf8")
124 insult_regexp
=u
"("+u
"|".join(config
.insultes
)+u
")"
125 middle_regexp
=u
"(une? (?:(?:putain|enfoiré) d(?:e |'))*|)(?:| super )(?: (?:gros|petit|grand|énorme) |)"
126 reg
=".*pas %s%s.*"%(middle_regexp
,insult_regexp
)
127 if re
.match(reg
,chain
):
131 def is_compliment(chain
,debug
=True):
132 return is_something(chain
,config
.compliment_triggers
,avant
=".*(?:^| |')")
134 return is_something(chain
,config
.perdu
)
136 return is_something(chain
,config
.tag_triggers
)
138 return is_something(chain
,config
.gros
)
140 return is_something(chain
,config
.tesla_triggers
,avant
=u
"^",apres
=u
"$",debug
=True)
142 return is_something(chain
,config
.merci_triggers
)
143 def is_tamere(chain
):
144 return is_something(chain
,config
.tamere_triggers
)
145 def is_bad_action_trigger(chain
,pseudo
):
146 return is_something(chain
,config
.bad_action_triggers
,avant
=u
"^",
147 apres
="(?: [a-z]*ment)? %s($|\.| |,|;).*"%(pseudo))
148 def is_good_action_trigger(chain
,pseudo
):
149 return is_something(chain
,config
.good_action_triggers
,avant
=u
"^",
150 apres
="(?: [a-z]*ment)? %s($|\.| |,|;).*"%(pseudo))
151 def is_bonjour(chain
):
152 return is_something(chain
,config
.bonjour_triggers
,avant
=u
"^")
153 def is_bonne_nuit(chain
):
154 return is_something(chain
,config
.bonne_nuit_triggers
,avant
=u
"^")
156 return re
.match(u
"^(pan|bim|bang)( .*)?$",unicode(chain
,"utf8").lower().strip())
159 _
,_
,_
,h
,m
,s
,_
,_
,_
=time
.localtime()
160 return (conf
[0],0,0)<(h
,m
,s
)<(conf
[1],0,0)
162 return is_time(config
.daytime
)
164 return is_time(config
.nighttime
)
167 class UnicodeBotError(Exception):
170 class CrashError(Exception):
171 """Pour pouvoir faire crasher Basile, parce que ça a l'air drôle"""
172 def __init__(self
, msg
=u
""):
173 Exception.__init
__(self
, msg
)
175 def bot_unicode(chain
):
177 unicode(chain
,"utf8")
178 except UnicodeDecodeError as exc
:
179 raise UnicodeBotError
182 class Basile(ircbot
.SingleServerIRCBot
):
183 def __init__(self
,serveur
,debug
=False):
184 temporary_pseudo
=config
.irc_pseudo
+str(random
.randrange(10000,100000))
185 ircbot
.SingleServerIRCBot
.__init
__(self
, [(serveur
, 6667)],
186 temporary_pseudo
,"Basile, le bot irc.[Codé par 20-100, fouettez-le]", 10)
189 self
.overops
=config
.overops
190 self
.ops
=self
.overops
+config
.ops
191 self
.report_bugs_to
=config
.report_bugs_to
192 self
.chanlist
=config
.chanlist
193 self
.identities
=pickle
.load(open("identities.pickle","r"))
194 self
.stay_channels
=config
.stay_channels
195 self
.quiet_channels
=config
.quiet_channels
199 def new_connection_NK(self
,serv
,username
,password
,typ
="bdd"):
201 login_result
,sock
=login_NK(username
,password
,typ
)
202 droits
,retcode
,errmsg
=login_result
["msg"],login_result
["retcode"],login_result
["errmsg"]
203 except NKRefused
as exc
:
204 for report
in self
.report_bugs_to
:
205 serv
.privmsg(report
,"Le Serveur NK2015 est down.")
207 except NKHelloFailed
as exc
:
208 for report
in self
.report_bugs_to
:
210 "La version du site utilisée n'est pas supportée par le serveur NK2015.")
212 except NKUnknownError
as exc
:
213 erreurs
=["Une fucking erreur inconnue s'est produite"]
214 erreurs
+=str(exc
).split("\n")
215 for report
in self
.report_bugs_to
:
217 serv
.privmsg(report
,err
)
219 except Exception as exc
:
220 # Exception qui ne vient pas de la communication avec le serveur NK2015
221 log(self
.serveur
,"Erreur dans new_connection_NK\n"+str(exc
))
228 def give_me_my_pseudo(self
,serv
):
229 serv
.privmsg("NickServ","RECOVER %s %s"%(config
.irc_pseudo
,config
.irc_password
))
230 serv
.privmsg("NickServ","RELEASE %s %s"%(config
.irc_pseudo
,config
.irc_password
))
232 serv
.nick(config
.irc_pseudo
)
234 def on_welcome(self
, serv
, ev
):
235 self
.serv
=serv
# ça serv ira :)
236 self
.give_me_my_pseudo(serv
)
237 serv
.privmsg("NickServ","identify %s"%(config
.irc_password
))
238 log(self
.serveur
,"Connected")
240 self
.chanlist
=["#bot"]
241 for c
in self
.chanlist
:
242 log(self
.serveur
,"JOIN %s"%(c))
244 # on ouvre la connexion note de Basile, special user
245 self
.nk
=self
.new_connection_NK(serv
,config
.note_pseudo
,config
.note_password
,"special")[1]
247 for report
in self
.report_bugs_to
:
248 serv
.privmsg(report
,"Connection to NK2015 failed, invalid password ?")
250 def lost(self
,serv
,channel
,forced
=False):
251 if self
.last_perdu
+config
.time_between_perdu
<time
.time() or forced
:
252 if not channel
in self
.quiet_channels
or forced
:
253 serv
.privmsg(channel
,"J'ai perdu !")
254 self
.last_perdu
=time
.time()
255 delay
=config
.time_between_perdu_trigger
256 delta
=config
.time_between_perdu_trigger_delta
257 serv
.execute_delayed(random
.randrange(delay
-delta
,delay
+delta
),self
.lost
,(serv
,channel
))
259 def pourmoi(self
, serv
, message
):
260 """renvoie (False,lemessage) ou (True, le message amputé de "pseudo: ")"""
263 if message
[:size
]==pseudo
and len(message
)>size
and message
[size
]==":":
264 return (True,message
[size
+1:].lstrip(" "))
266 return (False,message
)
268 def on_privmsg(self
, serv
, ev
):
269 message
=ev
.arguments()[0]
270 auteur
= irclib
.nm_to_n(ev
.source())
272 test
=bot_unicode(message
)
273 except UnicodeBotError
:
274 if config
.utf8_trigger
:
275 serv
.privmsg(auteur
, random
.choice(config
.utf8_fail_answers
).encode("utf8"))
277 message
=message
.split()
278 cmd
=message
[0].lower()
281 helpdico
={"help":["""HELP <commande>
282 Affiche de l'aide sur la commande""",None,None],
283 "identify": ["""IDENTIFY <username> <password>
284 Vérifie le mot de passe et me permet de savoir à l'avenir quel est votre pseudo note kfet.
285 Sans paramètre, je vous précise sous quel pseudo je vous connais.""",None,None],
286 "drop":["""DROP <password>
287 Vérifie le mot de passe et me fait d'oublier votre pseudo note kfet.""",None,None],
289 Affiche votre solde, si je connais votre pseudo note kfet.""",
291 Affiche le solde de la personne désignée (par son pseudo note).""",None],
292 "join": [None, """JOIN <channel>
293 Me fait rejoindre le channel""",None],
294 "leave": [None,"""LEAVE <channel>
295 Me fait quitter le channel (sauf s'il est dans ma stay_list).""",None],
296 "quiet": [None,"""QUIET <channel>
297 Me rend silencieux sur le channel.""",None],
298 "noquiet": [None,"""NOQUIET <channel>
299 Me rend la parole sur le channel.""",None],
300 "lost": [None,"""LOST <channel>
301 Me fait perdre sur le channel.""",None],
302 "reconnect": [None,"""RECONNECT
303 Établit à nouveau la connexion avec le serveur NK2015""",None],
304 "reload": [None,"""RELOAD
305 Recharge la configuration.""",None],
306 "say": [None,None,"""SAY <channel> <message>
307 Me fait parler sur le channel."""],
308 "do": [None,None,"""DO <channel> <action>
309 Me fait faitre une action (/me) sur le channel."""],
310 "stay": [None,None,"""STAY <channel>
311 Ajoute le channel à ma stay_list."""],
312 "nostay": [None,None,"""NOSTAY <channel>
313 Retire le channel de ma stay_list."""],
314 "ops": [None,None,"""OPS
315 Affiche la liste des ops."""],
316 "overops": [None,None,"""OVEROPS
317 Affiche la liste des overops."""],
318 "kick": [None,None,"""KICK <channel> <pseudo> [<raison>]
319 Kicke <pseudo> du channel (Il faut bien entendu que j'y sois op)."""],
320 "die": [None,None,"""DIE
321 Me déconnecte du serveur IRC."""],
322 "crash": [None,None,"""CRASH
325 helpmsg_default
="Liste des commandes disponibles :\nHELP IDENTIFY DROP SOLDE"
326 helpmsg_ops
=" JOIN LEAVE QUIET NOQUIET LOST RECONNECT RELOAD"
327 helpmsg_overops
=" SAY DO STAY NOSTAY OPS OVEROPS KICK DIE CRASH"
328 op
,overop
=auteur
in self
.ops
, auteur
in self
.overops
330 helpmsg
=helpmsg_default
334 helpmsg
+=helpmsg_overops
336 helpmsgs
=helpdico
.get(message
[1].lower(),["Commande inconnue.",None,None])
338 if op
and helpmsgs
[1]:
340 helpmsg
+="\n"+helpmsgs
[1]
343 if overop
and helpmsgs
[2]:
345 helpmsg
+="\n"+helpmsgs
[2]
348 for ligne
in helpmsg
.split("\n"):
349 serv
.privmsg(auteur
,ligne
)
350 elif cmd
=="identify":
352 if self
.identities
.has_key(auteur
):
353 serv
.privmsg(auteur
,"Je vous connais sous le pseudo note %s."%(
354 self
.identities
[auteur
].encode("utf8")))
356 serv
.privmsg(auteur
,"Je ne connais pas votre pseudo note.")
357 elif len(message
)>=3:
358 username
,password
=message
[1],unicode(" ".join(message
[2:]),"utf8")
359 success
,_
=self
.new_connection_NK(serv
,username
,password
)
361 log(self
.serveur
,"priv",auteur
," ".join(message
)+"[successful]")
362 serv
.privmsg(auteur
,"Identité enregistrée.")
363 self
.identities
[auteur
]=username
364 pickle
.dump(Xself
.identities
,open("identities.pickle","w"))
366 log(self
.serveur
,"priv",auteur
," ".join(message
)+"[failed]")
367 serv
.privmsg(auteur
,"Mot de passe invalide. (ou serveur down)")
369 serv
.privmsg(auteur
,u
"Syntaxe : IDENTIFY [<username> <password>]")
372 if self
.identities
.has_key(auteur
):
373 password
=" ".join(message
[1:])
374 success
,_
=self
.new_connection_NK(serv
,self
.identities
[auteur
],password
)
376 del self
.identities
[auteur
]
377 log(self
.serveur
,"priv",auteur
," ".join(message
)+"[successful]")
378 pickle
.dump(self
.identities
,open("identities.pickle","w"))
379 serv
.privmsg(auteur
,"Identité oubliée.")
381 log(self
.serveur
,"priv",auteur
," ".join(message
)+"[failed]")
382 serv
.privmsg(auteur
,"Mot de passe invalide. (ou serveur down)")
384 serv
.privmsg(auteur
,"Je ne connais pas ton pseudo note.")
386 serv
.privmsg(auteur
,"Syntaxe : DROP <password>")
388 if auteur
in self
.ops
:
390 if message
[1] in self
.chanlist
:
391 serv
.privmsg(auteur
,"Je suis déjà sur %s"%(message
[1]))
393 serv
.join(message
[1])
394 self
.chanlist
.append(message
[1])
395 serv
.privmsg(auteur
,"Channels : "+" ".join(self
.chanlist
))
396 log(self
.serveur
,"priv",auteur
," ".join(message
))
398 serv
.privmsg(auteur
,"Channels : "+" ".join(self
.chanlist
))
402 if auteur
in self
.ops
and len(message
)>1:
403 if message
[1] in self
.chanlist
:
404 if not (message
[1] in self
.stay_channels
) or auteur
in self
.overops
:
405 self
.quitter(message
[1]," ".join(message
[2:]))
406 self
.chanlist
.remove(message
[1])
407 log(self
.serveur
,"priv",auteur
," ".join(message
)+"[successful]")
409 serv
.privmsg(auteur
,"Non, je reste !")
410 log(self
.serveur
,"priv",auteur
," ".join(message
)+"[failed]")
412 serv
.privmsg(auteur
,"Je ne suis pas sur %s"%(message
[1]))
416 if auteur
in self
.overops
:
418 if message
[1] in self
.stay_channels
:
419 log(self
.serveur
,"priv",auteur
," ".join(message
)+"[failed]")
420 serv
.privmsg(auteur
,"Je stay déjà sur %s."%(message
[1]))
422 log(self
.serveur
,"priv",auteur
," ".join(message
)+"[successful]")
423 self
.stay_channels
.append(message
[1])
424 serv
.privmsg(auteur
,"Stay channels : "+" ".join(self
.stay_channels
))
426 serv
.privmsg(auteur
,"Stay channels : "+" ".join(self
.stay_channels
))
430 if auteur
in self
.overops
:
432 if message
[1] in self
.stay_channels
:
433 log(self
.serveur
,"priv",auteur
," ".join(message
)+"[successful]")
434 self
.stay_channels
.remove(message
[1])
435 serv
.privmsg(auteur
,"Stay channels : "+" ".join(self
.stay_channels
))
437 log(self
.serveur
,"priv",auteur
," ".join(message
)+"[failed]")
438 serv
.privmsg(auteur
,"Je ne stay pas sur %s."%(message
[1]))
443 if auteur
in self
.overops
:
444 log(self
.serveur
,"priv",auteur
," ".join(message
)+"[successful]")
449 if auteur
in self
.overops
:
450 log(self
.serveur
,"priv",auteur
," ".join(message
)+"[successful]")
451 self
.crash("priv", auteur
)
455 if auteur
in self
.ops
:
457 log(self
.serveur
,"priv",auteur
," ".join(message
)+"[successful]")
460 elif cmd
=="reconnect":
461 if auteur
in self
.ops
:
463 self
.nk
=self
.new_connection_NK(serv
,config
.note_pseudo
,
464 config
.note_password
,"special")[1]
465 except Exception as exc
:
467 log(self
.serveur
,"""Erreur dans on_pubmsg/"cmd in ["reconnect"]\n"""+str(exc
))
469 serv
.privmsg(auteur
,"%s: done"%(auteur))
470 log(self
.serveur
,"priv",auteur
," ".join(message
)+"[successful]")
472 serv
.privmsg(auteur
,"%s: failed"%(auteur))
473 log(self
.serveur
,"priv",auteur
," ".join(message
)+"[failed]")
474 for report
in self
.report_bugs_to
:
475 serv
.privmsg(report
,"Connection to NK2015 failed, invalid password ? Server dead ?")
479 if auteur
in self
.ops
:
481 if message
[1] in self
.quiet_channels
:
482 serv
.privmsg(auteur
,"Je me la ferme déjà sur %s"%(message
[1]))
483 log(self
.serveur
,"priv",auteur
," ".join(message
)+"[failed]")
485 self
.quiet_channels
.append(message
[1])
486 serv
.privmsg(auteur
,"Quiet channels : "+" ".join(self
.quiet_channels
))
487 log(self
.serveur
,"priv",auteur
," ".join(message
)+"[successful]")
489 serv
.privmsg(auteur
,"Quiet channels : "+" ".join(self
.quiet_channels
))
493 if auteur
in self
.ops
:
495 if message
[1] in self
.quiet_channels
:
496 self
.quiet_channels
.remove(message
[1])
497 serv
.privmsg(auteur
,"Quiet channels : "+" ".join(self
.quiet_channels
))
498 log(self
.serveur
,"priv",auteur
," ".join(message
)+"[successful]")
500 serv
.privmsg(auteur
,"Je ne me la ferme pas sur %s."%(message
[1]))
501 log(self
.serveur
,"priv",auteur
," ".join(message
)+"[failed]")
505 if auteur
in self
.overops
and len(message
)>2:
506 serv
.privmsg(message
[1]," ".join(message
[2:]))
507 log(self
.serveur
,"priv",auteur
," ".join(message
))
508 elif len(message
)<=2:
509 serv
.privmsg(auteur
,"Syntaxe : SAY <channel> <message>")
513 if auteur
in self
.overops
and len(message
)>2:
514 serv
.action(message
[1]," ".join(message
[2:]))
515 log(self
.serveur
,"priv",auteur
," ".join(message
))
516 elif len(message
)<=2:
517 serv
.privmsg(auteur
,"Syntaxe : DO <channel> <action>")
521 if auteur
in self
.overops
and len(message
)>2:
522 serv
.kick(message
[1],message
[2]," ".join(message
[3:]))
523 log(self
.serveur
,"priv",auteur
," ".join(message
))
524 elif len(message
)<=2:
525 serv
.privmsg(auteur
,"Syntaxe : KICK <channel> <pseudo> [<raison>]")
529 if auteur
in self
.ops
and len(message
)>1:
530 serv
.privmsg(message
[1],"J'ai perdu !")
531 log(self
.serveur
,"priv",auteur
," ".join(message
))
532 elif len(message
)<=1:
533 serv
.privmsg(auteur
,"Syntaxe : LOST <channel>")
538 if self
.identities
.has_key(auteur
):
540 self
.nk
.write('["search", ["x",["pseudo"],%s]]'%(json
.dumps(self
.identities
[auteur
])))
541 ret
=json
.loads(self
.nk
.read())
542 solde
=ret
["msg"][0]["solde"]
543 pseudo
=ret
["msg"][0]["pseudo"]
544 except Exception as exc
:
546 serv
.privmsg(auteur
,"failed")
547 log(self
.serveur
,"priv",auteur
," ".join(message
)+"[failed]")
549 serv
.privmsg(auteur
,"%s (%s)"%(float(solde
)/100,pseudo
.encode("utf8")))
550 log(self
.serveur
,"priv",auteur
," ".join(message
)+"[successful]")
552 serv
.privmsg(canal
,"Je ne connais pas ton pseudo note.")
553 elif auteur
in self
.ops
:
555 self
.nk
.write('["search", ["x",["pseudo"],%s]]'%(json
.dumps(message
[1])))
556 ret
=json
.loads(self
.nk
.read())
557 solde
=ret
["msg"][0]["solde"]
558 pseudo
=ret
["msg"][0]["pseudo"]
559 except Exception as exc
:
560 serv
.privmsg(auteur
,"failed")
561 log(self
.serveur
,"priv",auteur
," ".join(message
)+"[failed]")
563 serv
.privmsg(auteur
,"%s (%s)"%(float(solde
)/100,pseudo
.encode("utf8")))
565 if auteur
in self
.overops
:
566 serv
.privmsg(auteur
," ".join(self
.ops
))
570 if auteur
in self
.overops
:
571 serv
.privmsg(auteur
," ".join(self
.overops
))
577 serv
.privmsg(auteur
,"Je n'ai pas compris. Essayez HELP…")
579 def on_pubmsg(self
, serv
, ev
):
580 auteur
= irclib
.nm_to_n(ev
.source())
582 message
= ev
.arguments()[0]
584 test
=bot_unicode(message
)
585 except UnicodeBotError
:
586 if config
.utf8_trigger
and not canal
in self
.quiet_channels
:
587 serv
.privmsg(canal
, (u
"%s: %s"%(auteur
,random
.choice(config
.utf8_fail_answers
))).encode("utf8"))
589 pour_moi
,message
=self
.pourmoi(serv
,message
)
590 if pour_moi
and message
.split()!=[]:
591 cmd
=message
.split()[0].lower()
593 args
=" ".join(message
.split()[1:])
596 if cmd
in ["meurs","die","crève"]:
597 if auteur
in self
.overops
:
598 log(self
.serveur
,canal
,auteur
,message
+"[successful]")
601 serv
.privmsg(canal
,("%s: %s"%(auteur
,random
.choice(config
.quit_fail_messages
))).encode("utf8"))
602 log(self
.serveur
,canal
,auteur
,message
+"[failed]")
603 elif cmd
== "reload":
604 if auteur
in self
.ops
:
605 log(self
.serveur
, canal
, auteur
, message
+"[successful]")
608 if auteur
in self
.overops
:
609 self
.crash(auteur
, message
)
610 elif cmd
in ["part","leave","dégage","va-t-en","tut'tiresailleurs,c'estmesgalets"]:
611 if auteur
in self
.ops
and (not (canal
in self
.stay_channels
)
612 or auteur
in self
.overops
):
614 log(self
.serveur
,canal
,auteur
,message
+"[successful]")
615 if canal
in self
.chanlist
:
616 self
.chanlist
.remove(canal
)
618 serv
.privmsg(canal
,("%s: %s"%(auteur
,random
.choice(config
.leave_fail_messages
))).encode("utf8"))
619 log(self
.serveur
,canal
,auteur
,message
+"[failed]")
621 elif cmd
in ["reconnect"]:
622 if auteur
in self
.ops
:
624 self
.nk
=self
.new_connection_NK(serv
,config
.note_pseudo
,
625 config
.note_password
,"special")[1]
626 except Exception as exc
:
628 log(self
.serveur
,"""Erreur dans on_pubmsg/"cmd in ["reconnect"]\n"""+str(exc
))
630 serv
.privmsg(canal
,"%s: done"%(auteur))
631 log(self
.serveur
,canal
,auteur
,message
+"[successful]")
633 serv
.privmsg(canal
,"%s: failed"%(auteur))
634 log(self
.serveur
,canal
,auteur
,message
+"[failed]")
635 for report
in self
.report_bugs_to
:
636 serv
.privmsg(report
,"Connection to NK2015 failed, invalid password ? Server dead ?")
638 serv
.privmsg(canal
,"%s: %s"%(auteur
,random
.choice(config
.pas_programme_pour_tobeir
).encode("utf8")))
639 log(self
.serveur
,canal
,auteur
,message
+"[failed]")
641 elif cmd
in ["deviens","pseudo"]:
642 if auteur
in self
.ops
:
645 log(self
.serveur
,canal
,auteur
,message
+"[successful]")
647 if cmd
in ["meur", "meurt","meurre","meurres"] and not canal
in self
.quiet_channels
:
648 serv
.privmsg(canal
,'%s: Mourir, impératif, 2ème personne du singulier : "meurs" (de rien)'%(auteur))
649 elif cmd
in ["ping"] and not canal
in self
.quiet_channels
:
650 serv
.privmsg(canal
,"%s: pong"%(auteur))
652 elif cmd
in ["solde","!solde"]:
653 if self
.identities
.has_key(auteur
):
654 pseudo
=self
.identities
[auteur
]
656 self
.nk
.write('["search", ["x",["pseudo"],%s]]'%(json
.dumps(pseudo
)))
657 ret
=json
.loads(self
.nk
.read())
658 solde
=ret
["msg"][0]["solde"]
659 pseudo
=ret
["msg"][0]["pseudo"]
660 except Exception as exc
:
661 serv
.privmsg(canal
,"%s: failed"%(auteur))
662 log(self
.serveur
,canal
,auteur
,message
+"[failed]")
664 serv
.privmsg(canal
,"%s: %s (%s)"%(auteur
,float(solde
)/100,pseudo
.encode("utf8")))
665 log(self
.serveur
,canal
,auteur
,message
+"[successful]")
667 serv
.privmsg(canal
,"%s: Je ne connais pas votre pseudo note."%(auteur))
668 log(self
.serveur
,canal
,auteur
,message
+"[unknown]")
669 elif (re
.match("!?(pain au chocolat|chocolatine)",message
.lower())
670 and not canal
in self
.quiet_channels
):
671 serv
.action(canal
,"sert un pain au chocolat à %s"%(auteur))
672 elif re
.match("!?manzana",message
.lower()) and not canal
in self
.quiet_channels
:
673 if auteur
in config
.manzana
:
674 serv
.action(canal
,"sert une bouteille de manzana à %s"%(auteur))
675 elif auteur
in config
.manzana_bis
:
676 serv
.action(canal
,"sert un grand verre de jus de pomme à %s : tout le monde sait qu'il ne boit pas."%(auteur))
678 serv
.action(canal
,"sert un verre de manzana à %s"%(auteur))
679 if is_insult(message
) and not canal
in self
.quiet_channels
:
680 if is_not_insult(message
):
681 answer
=random
.choice(config
.compliment_answers
)
682 for ligne
in answer
.split("\n"):
683 serv
.privmsg(canal
,"%s: %s"%(auteur
,ligne
.encode("utf8")))
685 answer
=random
.choice(config
.insultes_answers
)
686 for ligne
in answer
.split("\n"):
687 serv
.privmsg(canal
,"%s: %s"%(auteur
,ligne
.encode("utf8")))
688 elif is_compliment(message
) and not canal
in self
.quiet_channels
:
689 answer
=random
.choice(config
.compliment_answers
)
690 for ligne
in answer
.split("\n"):
691 serv
.privmsg(canal
,"%s: %s"%(auteur
,ligne
.encode("utf8")))
692 gros_match
=is_gros(message
)
693 if gros_match
and not canal
in self
.quiet_channels
:
694 taille
=get_filesize()
695 answer
=u
"Mais non, je ne suis pas %s, %sKo tout au plus…"%(gros_match
.groups()[0],taille
)
696 serv
.privmsg(canal
,"%s: %s"%(auteur
,answer
.encode("utf8")))
697 if is_tesla(message
) and not canal
in self
.quiet_channels
:
698 l1
,l2
=config
.tesla_answers
,config
.tesla_actions
699 n1
,n2
=len(l1
),len(l2
)
700 i
=random
.randrange(n1
+n2
)
702 serv
.action(canal
,l2
[i
-n1
].encode("utf8"))
704 serv
.privmsg(canal
,"%s: %s"%(auteur
,l1
[i
].encode("utf8")))
705 if is_tamere(message
) and not canal
in self
.quiet_channels
:
706 answer
=random
.choice(config
.tamere_answers
)
707 for ligne
in answer
.split("\n"):
708 serv
.privmsg(canal
,"%s: %s"%(auteur
,ligne
.encode("utf8")))
709 if is_tag(message
) and not canal
in self
.quiet_channels
:
710 if auteur
in self
.ops
:
711 action
=random
.choice(config
.tag_actions
)
712 serv
.action(canal
,action
.encode("utf8"))
713 self
.quiet_channels
.append(canal
)
715 answer
=random
.choice(config
.tag_answers
)
716 for ligne
in answer
.split("\n"):
717 serv
.privmsg(canal
,"%s: %s"%(auteur
,ligne
.encode("utf8")))
718 if is_merci(message
):
719 answer
=random
.choice(config
.merci_answers
)
720 for ligne
in answer
.split("\n"):
721 serv
.privmsg(canal
,"%s: %s"%(auteur
,ligne
.encode("utf8")))
722 out
=re
.match(ur
"^([A-Z[]|\\|[0-9]+|(¹|²|³|⁴|⁵|⁶|⁷|⁸|⁹|⁰)+)(?:| \?| !)$",
723 unicode(message
.upper(),"utf8"))
724 if re
.match("ma bite dans ton oreille",message
) and not canal
in self
.quiet_channels
:
725 serv
.privmsg(canal
,"%s: Seul un olasd peut imiter un olasd dans un de ses grands jours !"%(auteur))
726 if out
and not canal
in self
.quiet_channels
:
730 serv
.privmsg(canal
,"%s: %s !"%(auteur
,out
+1))
732 serv
.privmsg(canal
,"%s: Ciel, un maxint ! Heureusement que je suis en python…"%(auteur))
734 if out
+1>1000 and random
.randrange(4)==0:
735 serv
.privmsg(canal
,"%s: Vous savez, moi et les chiffres…"%(auteur))
737 except Exception as exc
:
739 if re
.match("[A-Y]",out
):
740 alphabet
="ABCDEFGHIJKLMNOPQRSTUVWXYZ"
741 serv
.privmsg(canal
,"%s: %s !"%(auteur
,alphabet
[alphabet
.index(out
)+1]))
743 serv
.privmsg(canal
,"%s: Je ne vous remercie pas, j'ai l'air idiot ainsi… [ ?"%(auteur))
745 serv
.privmsg(canal
,"%s: Nous devrions nous en tenir là, ça va finir par poser des problèmes…"%(auteur))
746 elif re
.match(ur
"(¹|²|³|⁴|⁵|⁶|⁷|⁸|⁹|⁰)+",out
):
748 return "".join([{u
"⁰¹²³⁴⁵⁶⁷⁸⁹0123456789"[i
]:u
"0123456789⁰¹²³⁴⁵⁶⁷⁸⁹"[i
]
749 for i
in range(20)}[j
]
751 out
=int(translate(out
))
752 serv
.privmsg(canal
,"%s: %s !"%(auteur
,translate(str(out
+1)).encode("utf8")))
753 if is_bonjour(message
) and not canal
in self
.quiet_channels
:
755 answer
=random
.choice(config
.night_answers
)
757 answer
=random
.choice(config
.bonjour_answers
)
759 answer
=random
.choice(config
.bonsoir_answers
)
760 serv
.privmsg(canal
,answer
.format(auteur
).encode("utf8"))
761 if is_bonne_nuit(message
) and not canal
in self
.quiet_channels
:
762 answer
=random
.choice(config
.bonne_nuit_answers
)
763 serv
.privmsg(canal
,answer
.format(auteur
).encode("utf8"))
764 if is_pan(message
) and not canal
in self
.quiet_channels
:
765 serv
.privmsg(canal
,"%s: ce n'est pas sur moi qu'il faut tirer, même si je sais que j'attire l'œil !"%(auteur))
767 if message
in ["!pain au chocolat","!chocolatine"] and not canal
in self
.quiet_channels
:
768 serv
.action(canal
,"sert un pain au chocolat à %s"%(auteur))
769 if message
in ["!manzana"] and not canal
in self
.quiet_channels
:
770 if auteur
in config
.manzana
:
771 serv
.action(canal
,"sert une bouteille de manzana à %s"%(auteur))
772 elif auteur
in config
.manzana_bis
:
773 serv
.action(canal
,"sert un grand verre de jus de pomme à %s : tout le monde sait qu'il ne boit pas."%(auteur))
775 serv
.action(canal
,"sert un verre de manzana à %s"%(auteur))
776 if re
.match(u
'^ *(.|§|!|/|/|:|)(w|b) [0-9]+$',message
.decode("utf8")) and not canal
in self
.quiet_channels
:
777 failanswers
=config
.buffer_fail_answers
778 answer
=random
.choice(failanswers
)
779 serv
.privmsg(canal
,("%s: %s"%(auteur
,answer
)).encode("utf8"))
780 if not canal
in self
.quiet_channels
:
782 if re
.match((u
"^("+u
"|".join(config
.bonjour_triggers
)
783 +ur
")( {}| all| tout le monde| (à )?tous)(\.| ?!)?$"
784 ).format(mypseudo
).lower(), message
.decode("utf8").strip().lower()):
785 answer
=random
.choice(config
.bonjour_answers
)
786 serv
.privmsg(canal
,answer
.format(auteur
).encode("utf8"))
787 if (is_perdu(message
) and not canal
in self
.quiet_channels
):
788 # proba de perdre sur trigger :
789 # avant 30min (enfin, config) : 0
790 # ensuite, +25%/30min, linéairement
791 deltat
=time
.time()-self
.last_perdu
792 barre
=(deltat
-config
.time_between_perdu
)/(2*3600.0)
793 if random
.uniform(0,1)<barre
:
794 serv
.privmsg(canal
,"%s: J'ai perdu !"%(auteur))
795 self
.last_perdu
=time
.time()
797 def on_action(self
, serv
, ev
):
798 action
= ev
.arguments()[0]
799 auteur
= irclib
.nm_to_n(ev
.source())
800 channel
= ev
.target()
802 test
=bot_unicode(action
)
803 except UnicodeBotError
:
804 if config
.utf8_trigger
and not channel
in self
.quiet_channels
:
805 serv
.privmsg(channel
, (u
"%s: %s"%(auteur
,random
.choice(config
.utf8_fail_answers
))).encode("utf8"))
809 if is_bad_action_trigger(action
,mypseudo
) and not channel
in self
.quiet_channels
:
810 l1
,l2
=config
.bad_action_answers
,config
.bad_action_actions
811 n1
,n2
=len(l1
),len(l2
)
812 i
=random
.randrange(n1
+n2
)
814 serv
.action(channel
,l2
[i
-n1
].format(auteur
).encode("utf8"))
816 serv
.privmsg(channel
,l1
[i
].format(auteur
).format(auteur
).encode("utf8"))
817 if is_good_action_trigger(action
,mypseudo
) and not channel
in self
.quiet_channels
:
818 l1
,l2
=config
.good_action_answers
,config
.good_action_actions
819 n1
,n2
=len(l1
),len(l2
)
820 i
=random
.randrange(n1
+n2
)
822 serv
.action(channel
,l2
[i
-n1
].format(auteur
).format(auteur
).encode("utf8"))
824 serv
.privmsg(channel
,l1
[i
].format(auteur
).format(auteur
).encode("utf8"))
826 def on_kick(self
,serv
,ev
):
827 auteur
= irclib
.nm_to_n(ev
.source())
828 channel
= ev
.target()
829 victime
= ev
.arguments()[0]
830 raison
= ev
.arguments()[1]
831 if victime
==self
.nick
:
832 log(self
.serveur
,"%s kické de %s par %s (raison : %s)" %(victime
,channel
,auteur
,raison
))
835 l1
,l2
=config
.kick_answers
,config
.kick_actions
836 n1
,n2
=len(l1
),len(l2
)
837 i
=random
.randrange(n1
+n2
)
839 serv
.action(channel
,l2
[i
-n1
].format(auteur
).encode("utf8"))
841 serv
.privmsg(channel
,l1
[i
].format(auteur
).encode("utf8"))
843 def quitter(self
,chan
,leave_message
=None):
844 if leave_message
==None:
845 leave_message
=random
.choice(config
.leave_messages
)
846 self
.serv
.part(chan
,message
=leave_message
.encode("utf8"))
849 quit_message
=random
.choice(config
.quit_messages
)
850 self
.die(msg
=quit_message
.encode("utf8"))
853 return self
.serv
.get_nickname()
854 nick
=property(_getnick
)
856 def reload(self
, auteur
=None):
858 if auteur
in [None, "SIGHUP"]:
859 towrite
= "Config reloaded" + " (SIGHUP received)"*(auteur
== "SIGHUP")
860 for to
in config
.report_bugs_to
:
861 self
.serv
.privmsg(to
, towrite
)
862 log(self
.serveur
, towrite
)
864 self
.serv
.privmsg(auteur
,"Config reloaded")
866 def crash(self
, chan
="nowhere", who
="nobody"):
867 where
= u
"en privé" if chan
== "priv" else u
"sur le chan %s" % chan
868 raise CrashError(u
"Crash demandé par %s %s" % (who
, where
))
870 def start_as_daemon(self
, outfile
):
871 sys
.stderr
= Logger(outfile
)
875 class Logger(object):
876 """Pour écrire ailleurs que sur stdout"""
877 def __init__(self
, filename
="basile.full.log"):
878 self
.filename
= filename
880 def write(self
, message
):
881 f
= open(self
.filename
, "a")
887 print "Usage : basile.py <serveur> [--debug] [--no-output] [--daemon [--pidfile]] [--outfile]"
888 print " --outfile sans --no-output ni --daemon n'a aucun effet"
891 if "--daemon" in sys
.argv
:
892 thisfile
= os
.path
.realpath(__file__
)
893 thisdirectory
= thisfile
.rsplit("/", 1)[0]
894 os
.chdir(thisdirectory
)
898 if "debug" in sys
.argv
or "--debug" in sys
.argv
:
902 if "--quiet" in sys
.argv
:
903 config
.debug_stdout
=False
904 serveurs
={"a♡":"acoeur.crans.org","acoeur":"acoeur.crans.org","acoeur.crans.org":"acoeur.crans.org",
905 "irc":"irc.crans.org","crans":"irc.crans.org","irc.crans.org":"irc.crans.org"}
906 if "--no-output" in sys
.argv
or "--daemon" in sys
.argv
:
907 outfile
= "/var/log/bots/basile.full.log"
910 if arg
[0].strip('-') in ["out", "outfile", "logfile"]:
912 sys
.stdout
= Logger(outfile
)
914 serveur
=serveurs
[serveur
]
916 print "Server Unknown : %s"%(serveur)
918 basile
=Basile(serveur
,debug
)
919 # Si on reçoit un SIGHUP, on reload la config
920 def sighup_handler(signum
, frame
):
921 basile
.reload("SIGHUP")
922 signal
.signal(signal
.SIGHUP
, sighup_handler
)
924 child_pid
= os
.fork()
927 basile
.start_as_daemon(outfile
)
929 # on enregistre le pid de basile
930 pidfile
= "/var/run/bots/basile.pid"
933 if arg
[0].strip('-') in ["pidfile"]:
935 f
= open(pidfile
, "w")
936 f
.write("%s\n" % child_pid
)
941 if __name__
== "__main__":