]> gitweb.pimeys.fr Git - today.git/blob - today.py
ssh -4 parce qu'il se passe des choses bizarres avec pimeys et l'IPv6
[today.git] / today.py
1 #!/usr/bin/python
2 # -*- encoding: utf-8 -*-
3
4 """ Codé par 20-100
5 script qui affiche des trucs à penser, des J-n des conneries
6 or that kind of stuff"""
7
8 import time, datetime
9 import re
10 import os
11 import sys
12 import subprocess
13 import json
14 os.chdir('/home/vincent/scripts/today/')
15
16
17 class Config(object):
18 """Configuration (pas de couleurs si on n'output pas dans un terminal"""
19 def __init__(self, color=True):
20 if color:
21 self.endcolor = u"\e[0m"
22 self.blue = u"\e[1;36m"
23 self.red = u"\e[1;31m"
24 self.green = u"\e[1;32m"
25 else:
26 self.endcolor=self.blue=self.red=self.green=""
27 #: Serveur distant où aller récupérer les checks
28 self.distant_server = "pimeys"
29 #: path de today-server.py sur le serveur distant
30 self.path_today_server = "/home/vincent/scripts/today/today_server.py"
31 #: Fichier contenant les anniversaires
32 self.birthdays_file = "birthdays.txt"
33 #: Fichier contenant les évènements à venir
34 self.timers_file = "timers.txt"
35 #: Fichier contenant les fêtes à souhaiter
36 self.saints_file = "saints.json"
37 #: Fichier contenant les ids des derniers trucs vus/lus
38 self.last_seen_file = "lasts"
39 #: Fichier contenant le timestamp de dernière exécution
40 self.lasttime_file = ".lasttime"
41 #: Fichier contenant un booléen mémorisant si il y a quelquechose dans le today du jour et qu'il n'a pas encore été regardé
42 self.something_file = ".something"
43
44 if "--color" in sys.argv:
45 sys.argv.remove("--color")
46 color = True
47 elif sys.stdout.isatty():
48 color = True
49 else:
50 color = False
51
52 config = Config(color=color)
53
54 def print_date(timestamp=None,color=True):
55 """Afficher la date"""
56 if timestamp == None:
57 timestamp = time.time()
58 return time.strftime(" "*30 + config.blue+"%d/%m/%Y %H:%M:%S"+config.endcolor + "\n",
59 time.localtime(timestamp))
60
61 def add_title(titre, texte):
62 """Ajoute un titre à la partie si il y a quelque chose dedans"""
63 if texte:
64 texte = u" %s%s :%s\n" % (config.green, titre, config.endcolor) + texte + "\n"
65 return texte
66
67 def get_now():
68 """Obtenir la date actuelle sous le bon format"""
69 timestamp = time.time()
70 now = datetime.datetime(*time.localtime(timestamp)[:7])
71 return now
72
73 def get_last_seen():
74 """Récupère la liste des derniers trucs vus/lus"""
75 with open(config.last_seen_file) as f:
76 return json.loads(f.read())
77
78 def update_last_seen(newdict):
79 """Met à jour un des derniers trucs vus/lus"""
80 lasts = get_last_seen()
81 lasts.update(newdict)
82 with open(config.last_seen_file, "w") as f:
83 f.write(json.dumps(lasts))
84
85 def parse_datefile(namefile):
86 """Ouvre et parse un fichier avec des lignes de la forme
87 jj/mm/aaaa Truc
88 """
89 with open(namefile) as f:
90 rawdata = [l.strip().decode("utf8") for l in f.readlines()[1:] if not l.strip().startswith("#") and not l.strip() == '']
91 data = []
92 for l in rawdata:
93 date, truc = l.split("\t",1)
94 date = datetime.datetime(*time.strptime(date, "%d/%m/%Y")[:7])
95 data.append([date, truc])
96 return data
97
98
99 def get_timers():
100 """Obtenir la liste des évènements à venir (J-n)"""
101 now = get_now()
102 data = parse_datefile(config.timers_file)
103 timers = []
104 for [date, event] in data:
105 delta = date - now + datetime.timedelta(1)
106 if delta > datetime.timedelta(0):
107 timers.append([event,delta.days])
108 eventsize = max([0]+[len(l[0]) for l in timers])
109 timers = u"\n".join([(u"%%-%ss J-%%s" % eventsize) % (event, timer) for event,timer in timers])
110 timers = add_title(u"Timers", timers)
111 return timers
112
113 def exists(l):
114 """Renvoie True si au moins un élément de l est vrai"""
115 for i in l:
116 if i:
117 return True
118 return False
119
120 def get_birthdays(*search):
121 """Obtenir la liste des anniversaires à venir,
122 ou la liste des anniversaires correspondants à une recherche"""
123 now = get_now()
124 liste = parse_datefile(config.birthdays_file)
125 birthdays = []
126 if len(search) == 0:
127 # Simple demande d'anniversaires courants
128 for date, nom in liste:
129 thisyeardate = datetime.datetime(now.year, date.month, date.day)
130 delta = thisyeardate - now + datetime.timedelta(1)
131 if delta > datetime.timedelta(0):
132 age = now.year - date.year
133 if abs(delta) < datetime.timedelta(1):
134 birthdays.append([config.red, u"%s a %s ans AUJOURD'HUI !" % (nom, age), 0, config.endcolor])
135 elif delta < datetime.timedelta(7):
136 birthdays.append([config.red, u"%s va avoir %s ans" % (nom, age), -delta.days, config.endcolor])
137 elif delta < datetime.timedelta(14):
138 birthdays.append([u"", u"%s va avoir %s ans" % (nom, age), -delta.days, u""])
139 elif datetime.timedelta(30-4) < delta < datetime.timedelta(30+4):
140 birthdays.append([u"", u"%s va avoir %s ans" % (nom, age), -delta.days, u""])
141 else:
142 # Recherche spécifique
143 search = [i.lower() for i in search]
144 tous = ("--all" in search)
145 for date, nom in liste:
146 if tous or exists([term.lower() in nom.lower() for term in search]):
147 thisyeardate = datetime.datetime(now.year, date.month, date.day)
148 delta = thisyeardate - now + datetime.timedelta(1)
149 age = now.year - date.year
150 if delta.days<0:
151 birthdays.append([u"", u"%s a eu %s ans" % (nom, age), -delta.days, ""])
152 else:
153 birthdays.append([u"", u"%s va avoir %s ans" % (nom, age), -delta.days, ""])
154 birthdays.sort(lambda x,y: -cmp(x[2], y[2]))
155 eventsize = max([0]+[len(l[1]) for l in birthdays])
156 template = (u"%%s%%-%ss J%%+d%%s" % eventsize)
157 birthdays = u"\n".join([template % tuple(tup) for tup in birthdays])
158 birthdays = add_title(u"Anniversaires", birthdays)
159 return birthdays
160
161 def _parse_saint(s):
162 """Renvoie la liste des fêtes contenue dans un jour"""
163 l = s.split(",")
164 ll = []
165 for st in l:
166 if st[0] == "&":
167 ll.append(["St ", st[1:]])
168 elif st[0] == "!":
169 ll.append(["Ste ", st[1:]])
170 return ll
171
172 def _get_firstnames():
173 """Récupère la liste des noms des gens connus"""
174 birthdays = parse_datefile(config.birthdays_file)
175 firstnames = [b[1].split()[0] for b in birthdays]
176 return firstnames
177
178 def get_saints():
179 """Renvoie la liste des fêtes à souhaiter aujourd'hui et demain"""
180 sourcesaints = json.load(open(config.saints_file))
181 now = get_now()
182 saints = {}
183 saints["today"] = _parse_saint(sourcesaints[now.month - 1][now.day - 1])
184 nbdays = len(sourcesaints[now.month - 1])
185 if now.day == nbdays: # il faut regarder le mois suivant
186 if now.month == 12: # il faut regarder l'année suivante
187 saints["tomorrow"] = _parse_saint(sourcesaints[0][0])
188 else:
189 saints["tomorrow"] = _parse_saint(sourcesaints[now.month][0])
190 else:
191 saints["tomorrow"] = _parse_saint(sourcesaints[now.month - 1][now.day])
192 firstnames = _get_firstnames()
193 towish = {"today" : [], "tomorrow" : []}
194 for day in ["today", "tomorrow"]:
195 ssaints = saints[day]
196 for (sexe, saint) in ssaints:
197 if exists([firstname.lower() in saint.lower().split() for firstname in firstnames]):
198 towish[day].append(sexe + saint)
199 ttowish = []
200 if towish["today"]:
201 ttowish.append(u"Aujourd'hui :\n" + "\n".join(towish["today"]))
202 if towish["tomorrow"]:
203 ttowish.append(u"Demain :\n" + "\n".join(towish["tomorrow"]))
204 saints = "\n".join(ttowish)
205 saints = add_title(u"Fêtes à souhaiter", saints)
206 return saints
207
208 def check_birthdays():
209 """Compte combien il y a d'anniversaires à afficher"""
210 birthdays = get_birthdays()
211 if birthdays:
212 n = birthdays.count(u"\n") - 1
213 else:
214 n = 0
215 return n
216
217 def check_saints():
218 """Compte combien il y a de fêtes à afficher"""
219 saints = get_saints()
220 return len(re.findall("\nSt", saints))
221
222 def format_quotes(liste):
223 """Formate les quotes de dicos à texte"""
224 t = (u"\n" + u"_"*80 + u"\n").join([u"%(id)s (%(date)s)\n%(quote)s" % q for q in liste])
225 return t
226
227 def get_dtc(*args):
228 """Récupère les quotes DTC non lues"""
229 if len(args) == 0:
230 last_dtc = get_last_seen().get("dtc", 0)
231 cmd = "~/bin/dtc %s + --json" % (last_dtc+1,)
232 elif len(args) == 1:
233 cmd = "~/bin/dtc %s --json" % args[0]
234 elif len(args) == 2:
235 cmd = "~/bin/dtc %s %s --json" % (args[0], args[1])
236 else:
237 return None
238 proc = subprocess.Popen(["ssh", "-4", config.distant_server, cmd], stdout=subprocess.PIPE, stderr=subprocess.PIPE)
239 out, err = proc.communicate()
240 out += err
241 quotes = json.loads(out)
242 if quotes:
243 last_id = max([q["id"] for q in quotes])
244 update_last_seen({"dtc" : last_id})
245 textquotes = format_quotes(quotes)
246 return textquotes
247
248 def update_xkcd(newid):
249 update_last_seen({"xkcd" : int(newid)})
250
251 def update_xantah(newid):
252 update_last_seen({"xantah" : int(newid)})
253
254 def update_visiteur(newid):
255 update_last_seen({"visiteur" : int(newid)})
256
257 def update_noob(newid):
258 update_last_seen({"noob" : int(newid)})
259
260 def update_warpzone(newid):
261 update_last_seen({"warpzone" : int(newid)})
262
263 def update_hugo(newid):
264 update_last_seen({"hugo" : int(newid)})
265
266 def update_norman(newid):
267 update_last_seen({"norman" : int(newid)})
268
269 def update_cyprien(newid):
270 update_last_seen({"cyprien" : int(newid)})
271
272 def update_grenier(newid):
273 update_last_seen({"grenier" : int(newid)})
274
275
276 THINGS = {
277 "dtc" : u"Quotes DTC",
278 "xkcd" : u"Épisodes de XKCD",
279 "xantah" : u"Épisodes de La Légende de Xantah",
280 "visiteur" : u"Épisodes du Visiteur du Futur",
281 "noob" : u"Épisodes de NOOB",
282 "warpzone" : u"Épisodes de WARPZONE PROJECT",
283 "hugo" : u"Vidéos de Hugo Tout Seul",
284 "norman" : u"Vidéos de Norman",
285 "cyprien" : u"Vidéos de Cyprien",
286 "grenier" : u"Épisodes du joueur du grenier",
287
288 "birthdays" : u"Anniversaires à souhaiter",
289 "saints" : u"Fêtes à souhaiter",
290 }
291
292 def check_all():
293 """Vérifie si il y a des derniers trucs non lus/vus."""
294 cmd = "%s whatsup" % (config.path_today_server,)
295 proc = subprocess.Popen(["ssh", "-4", config.distant_server, cmd], stdout=subprocess.PIPE)
296 out, err = proc.communicate()
297 news = json.loads(out)
298 seen = get_last_seen()
299 news["birthdays"] = check_birthdays()
300 news["saints"] = check_saints()
301 checks = []
302 for (thing, comm) in THINGS.iteritems():
303 n = news[thing] - seen.get(thing, 0)
304 if type(n) != int:
305 print n
306 elif n > 0:
307 checks.append("%s : %s (last : %s)" % (comm, n, news[thing]))
308 checks = u"\n".join(checks)
309 checks = add_title(u"Checks", checks)
310 return checks
311
312 def get_everything():
313 """Récupère toutes les infos"""
314 work = [action() for action in AUTOMATED_ACTIONS.values()]
315 chain = u"\n\n".join([result for result in work if result])
316 return chain
317
318 def _is_there_something_in_today():
319 """Teste si il y a des choses non lue dans le today"""
320 return open(config.something_file, "r").read() == "True"
321
322 def _there_is_something_in_today(something):
323 """Met à jour le something"""
324 f = open(config.something_file, "w")
325 f.write(str(bool(something)))
326 f.close()
327
328 def _get_lasttime():
329 """Récupère la dernière fois que today a été exécuté"""
330 if os.path.isfile(config.lasttime_file):
331 lasttime = open(config.lasttime_file, "r").read()
332 else:
333 lasttime = 0
334 lasttime = datetime.datetime(*time.localtime(float(lasttime))[:7])
335 return lasttime
336
337 def _update_lasttime(when):
338 """Met à jour le timestamp de dernière exécution de today"""
339 f = open(config.lasttime_file, "w")
340 f.write(str(time.mktime(when.timetuple())))
341 f.close()
342
343 def ping():
344 """Dit juste si il y a quelque chose à voir.
345 La première exécution de la journée peut être lente parce qu'elle va bosser avnt de répondre."""
346 now = get_now()
347 lasttime = _get_lasttime()
348 if (lasttime.date() < now.date()):
349 # On a changé de jour
350 _update_lasttime(now)
351 something = get_everything()
352 _there_is_something_in_today(something)
353 if something:
354 return u"You have something in %stoday%s" % (config.red, config.endcolor)
355 else:
356 return u"Nothing in today"
357 else:
358 if _is_there_something_in_today():
359 return u"You have something in %stoday%s" % (config.red, config.endcolor)
360
361 def affiche():
362 """Action par défaut, affiche toutes les infos"""
363 out = print_date()
364 out += get_everything()
365 _there_is_something_in_today(False)
366 return out
367
368 def initialize():
369 """Crée les fichiers (vides) nécessaires au fonctionnement du script"""
370 files = [config.birthdays_file, config.timers_file, config.saints_file,
371 config.last_seen_file]
372 contents = [u"# Anniversaires\n#jj/mm/aaaa Prénom Nom\n",
373 u"# Évènements à venir\n#jj/mm/aaaa Évènement\n",
374 json.dumps([[""]*31]*12).decode(),
375 u"{}"]
376 for ifile in range(len(files)):
377 namefile = files[ifile]
378 if os.path.isfile(namefile):
379 print "%s exists, skipping." % (namefile,)
380 else:
381 f = open(namefile, "w")
382 f.write(contents[ifile].encode("utf-8"))
383 f.close()
384
385 def sync():
386 """Synchronise les last_seen avec le serveur distant qui en garde une copie,
387 le maximum de chaque truc vu est gardé des deux côtés."""
388 lasts = get_last_seen()
389 cmd = "%s sync" % (config.path_today_server,)
390 proc = subprocess.Popen(["ssh", "-4", config.distant_server, cmd],
391 stdin = subprocess.PIPE, stdout=subprocess.PIPE,
392 close_fds = True)
393 lasts_raw = json.dumps(lasts)
394 proc.stdin.write(lasts_raw)
395 proc.stdin.close()
396 out = proc.stdout.read()
397 newdict = json.loads(out)
398 update_last_seen(newdict)
399 print u"Nouvel état : %r" % newdict
400
401
402
403 #: Les actions effectuées lors d'un appel sans paramètres
404 AUTOMATED_ACTIONS = {
405 "timers" : get_timers,
406 "birth" : get_birthdays,
407 "saints" : get_saints,
408 "check" : check_all,
409 }
410
411 #: Les actions qu'on peut effectuer en rajoutant des paramètres
412 OTHER_ACTIONS = {
413 "xkcd" : update_xkcd,
414 "xantah" : update_xantah,
415 "visiteur" : update_visiteur,
416 "noob" : update_noob,
417 "warpzone" : update_warpzone,
418 "hugo" : update_hugo,
419 "norman" : update_norman,
420 "cyprien" : update_cyprien,
421 "grenier" : update_grenier,
422
423 "dtc" : get_dtc,
424 "ping" : ping,
425 "show" : affiche,
426 "sync" : sync,
427
428 "init" : initialize,
429 }
430
431 #: Toutes les actions
432 ACTIONS = dict(AUTOMATED_ACTIONS)
433 ACTIONS.update(OTHER_ACTIONS)
434
435 ACTIONS[None] = affiche # action par défaut
436
437 if __name__ == "__main__":
438 import sys
439 if "--no-color" in sys.argv:
440 config.endcolor, config.red, config.blue = u"", u"", u""
441 if len(sys.argv) == 1:
442 # Juste un today
443 output = ACTIONS[None]()
444 else:
445 commande = sys.argv[1]
446 args = sys.argv[2:]
447 output = ACTIONS[commande](*args)
448 if output:
449 print output