]> gitweb.pimeys.fr Git - today.git/blob - today.py
sync côté serveur
[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 os
10 import sys
11 import subprocess
12 import json
13 os.chdir('/home/vincent/scripts/today/')
14
15
16 class Config(object):
17 """Configuration (pas de couleurs si on n'output pas dans un terminal"""
18 def __init__(self, color=True):
19 if color:
20 self.endcolor = "\e[0m"
21 self.blue = "\e[1;36m"
22 self.red = "\e[1;31m"
23 self.green = "\e[1;32m"
24 else:
25 self.endcolor=self.blue=self.red=self.green=""
26 #: Serveur distant où aller récupérer les checks
27 self.distant_server = "pimeys"
28 #: path de today-server.py sur le serveur distant
29 self.path_today_server = "/home/vincent/scripts/today/today-server.py"
30 #: Fichier contenant les anniversaires
31 self.birthdays_file = "birthdays.txt"
32 #: Fichier contenant les évènements à venir
33 self.timers_file = "timers.txt"
34 #: Fichier contenant les fêtes à souhaiter
35 self.saints_file = "saints.txt"
36 #: Fichier contenant les ids des derniers trucs vus/lus
37 self.last_seen_file = "lasts"
38 #: Fichier contenant le timestamp de dernière exécution
39 self.lasttime_file = ".lasttime"
40 #: 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é
41 self.something_file = ".something"
42
43 if "--color" in sys.argv:
44 sys.argv.remove("--color")
45 color = True
46 elif sys.stdout.isatty():
47 color = True
48 else:
49 color = False
50
51 config = Config(color=color)
52
53 def print_date(timestamp=None,color=True):
54 """Afficher la date"""
55 if timestamp == None:
56 timestamp = time.time()
57 return time.strftime(" "*30 + config.blue+"%d/%m/%Y %H:%M:%S"+config.endcolor + "\n",
58 time.localtime(timestamp))
59
60 def add_title(titre, texte):
61 """Ajoute un titre à la partie si il y a quelque chose dedans"""
62 if texte:
63 texte = " %s%s :%s\n" % (config.green, titre, config.endcolor) + texte + "\n"
64 return texte
65
66 def get_now():
67 """Obtenir la date actuelle sous le bon format"""
68 timestamp = time.time()
69 now = datetime.datetime(*time.localtime(timestamp)[:7])
70 return now
71
72 def get_last_seen():
73 """Récupère la liste des derniers trucs vus/lus"""
74 with open(config.last_seen_file) as f:
75 return json.loads(f.read())
76
77 def update_last_seen(newdict):
78 """Met à jour un des derniers trucs vus/lus"""
79 lasts = get_last_seen()
80 lasts.update(newdict)
81 with open(config.last_seen_file, "w") as f:
82 f.write(json.dumps(lasts))
83
84 def parse_datefile(namefile):
85 """Ouvre et parse un fichier avec des lignes de la forme
86 jj/mm/aaaa Truc
87 """
88 with open(namefile) as f:
89 rawdata = [l.strip().decode("utf8") for l in f.readlines()[1:] if not l.strip().startswith("#") and not l.strip() == '']
90 data = []
91 for l in rawdata:
92 date, truc = l.split("\t",1)
93 date = datetime.datetime(*time.strptime(date,"%d/%m/%Y")[:7])
94 data.append([date, truc])
95 return data
96
97
98 def get_timers():
99 """Obtenir la liste des évènements à venir (J-n)"""
100 now = get_now()
101 data = parse_datefile(config.timers_file)
102 timers = []
103 for [date, event] in data:
104 delta = date - now + datetime.timedelta(1)
105 if delta > datetime.timedelta(0):
106 timers.append([event,delta.days])
107 eventsize = max([0]+[len(l[0]) for l in timers])
108 timers = "\n".join([("%%-%ss J-%%s" % eventsize) % (event, timer) for event,timer in timers])
109 timers = add_title("Timers", timers)
110 return timers
111
112 def exists(l):
113 """Renvoie True si au moins un élément de l est vrai"""
114 for i in l:
115 if i:
116 return True
117 return False
118
119 def get_birthdays(*search):
120 """Obtenir la liste des anniversaires à venir,
121 ou la liste des anniversaires correspondants à une recherche"""
122 now = get_now()
123 liste = parse_datefile(config.birthdays_file)
124 birthdays = []
125 if len(search) == 0:
126 # Simple demande d'anniversaires courants
127 for date, nom in liste:
128 thisyeardate = datetime.datetime(now.year, date.month, date.day)
129 delta = thisyeardate - now + datetime.timedelta(1)
130 if delta > datetime.timedelta(0):
131 age = now.year - date.year
132 if abs(delta) < datetime.timedelta(1):
133 birthdays.append([config.red,"%s a %s ans AUJOURD'HUI !"%(nom,age),0,config.endcolor])
134 elif delta < datetime.timedelta(7):
135 birthdays.append([config.red,"%s va avoir %s ans"%(nom,age),-delta.days,config.endcolor])
136 elif delta < datetime.timedelta(14):
137 birthdays.append(["","%s va avoir %s ans"%(nom,age),-delta.days,""])
138 elif datetime.timedelta(30-4) < delta < datetime.timedelta(30+4):
139 birthdays.append(["","%s va avoir %s ans"%(nom,age),-delta.days,""])
140 else:
141 # Recherche spécifique
142 search = [i.lower() for i in search]
143 tous = ("--all" in search)
144 for date, nom in liste:
145 if tous or exists([term.lower() in nom.lower() for term in search]):
146 thisyeardate = datetime.datetime(now.year, date.month, date.day)
147 delta = thisyeardate - now + datetime.timedelta(1)
148 age = now.year - date.year
149 if delta.days<0:
150 birthdays.append(["", "%s a eu %s ans"%(nom,age), -delta.days, ""])
151 else:
152 birthdays.append(["", "%s va avoir %s ans"%(nom,age), -delta.days, ""])
153 birthdays.sort(lambda x,y: -cmp(x[2], y[2]))
154 eventsize = max([0]+[len(l[1]) for l in birthdays])
155 template = ("%%s%%-%ss J%%+d%%s" % eventsize)
156 birthdays = "\n".join([template % tuple(tup) for tup in birthdays])
157 birthdays = add_title("Anniversaires", birthdays)
158 return birthdays
159
160 def check_birthdays():
161 """Compte combien il y a d'anniversaires à afficher"""
162 birthdays = get_birthdays()
163 if birthdays:
164 n = birthdays.count("\n") - 1
165 else:
166 n = 0
167 return n
168
169 def format_quotes(liste):
170 """Formate les quotes de dicos à texte"""
171 t = ("\n" + "_"*80 + "\n").join(["%(id)s (%(date)s)\n%(quote)s" % q for q in liste])
172 return t
173
174 def get_dtc(*args):
175 """Récupère les quotes DTC non lues"""
176 if len(args) == 0:
177 last_dtc = get_last_seen().get("dtc", 0)
178 cmd = "~/bin/dtc %s + --json" % (last_dtc+1,)
179 elif len(args) == 1:
180 cmd = "~/bin/dtc %s --json" % args[0]
181 elif len(args) == 2:
182 cmd = "~/bin/dtc %s %s --json" % (args[0], args[1])
183 else:
184 return None
185 proc = subprocess.Popen(["ssh", config.distant_server, cmd], stdout=subprocess.PIPE, stderr=subprocess.PIPE)
186 out, err = proc.communicate()
187 out += err
188 quotes = json.loads(out)
189 if quotes:
190 last_id = max([q["id"] for q in quotes])
191 update_last_seen({"dtc" : last_id})
192 textquotes = format_quotes(quotes)
193 return textquotes
194
195 def update_xkcd(newid):
196 update_last_seen({"xkcd" : int(newid)})
197
198
199 def check_all():
200 """Vérifie si il y a des derniers trucs non lus/vus."""
201 cmd = "%s whatsup" % (config.path_today_server,)
202 proc = subprocess.Popen(["ssh", config.distant_server, cmd], stdout=subprocess.PIPE, stderr=subprocess.PIPE)
203 out, err = proc.communicate()
204 news = json.loads(out)
205 seen = get_last_seen()
206 n_birth = check_birthdays()
207 n_dtc = news["dtc"] - seen.get("dtc", 0)
208 n_xkcd = news["xkcd"] - seen.get("xkcd", 0)
209 l = [["Anniversaires", n_birth],
210 ["Quotes DTC", n_dtc],
211 ["XKCD non lus", n_xkcd]]
212 checks = []
213 for (text, n) in l:
214 if type(n) != int:
215 print n
216 elif n > 0:
217 checks.append("%s : %s" % (text, n))
218 checks = "\n".join(checks)
219 checks = add_title("Checks", checks)
220 return checks
221
222 def get_everything():
223 """Récupère toutes les infos"""
224 work = [action() for action in AUTOMATED_ACTIONS.values()]
225 chain = "\n\n".join([result for result in work if result])
226 return chain
227
228 def _is_there_something_in_today():
229 """Teste si il y a des choses non lue dans le today"""
230 return open(config.something_file, "r").read() == "True"
231
232 def _there_is_something_in_today(something):
233 """Met à jour le something"""
234 f = open(config.something_file, "w")
235 f.write(str(bool(something)))
236 f.close()
237
238 def _get_lasttime():
239 """Récupère la dernière fois que today a été exécuté"""
240 if os.path.isfile(config.lasttime_file):
241 lasttime = open(config.lasttime_file, "r").read()
242 else:
243 lasttime = 0
244 lasttime = datetime.datetime(*time.localtime(float(lasttime))[:7])
245 return lasttime
246
247 def _update_lasttime(when):
248 """Met à jour le timestamp de dernière exécution de today"""
249 f = open(config.lasttime_file, "w")
250 f.write(str(time.mktime(when.timetuple())))
251 f.close()
252
253 def ping():
254 """Dit juste si il y a quelque chose à voir.
255 La première exécution de la journée peut être lente parce qu'elle va bosser avnt de répondre."""
256 now = get_now()
257 lasttime = _get_lasttime()
258 if (lasttime.date() < now.date()):
259 # On a changé de jour
260 _update_lasttime(now)
261 something = get_everything()
262 _there_is_something_in_today(something)
263 if something:
264 return "You have something in %stoday%s" % (config.red, config.endcolor)
265 else:
266 return "Nothing in today"
267 else:
268 if _is_there_something_in_today():
269 return "You have something in %stoday%s" % (config.red, config.endcolor)
270
271 def affiche():
272 """Action par défaut, affiche toutes les infos"""
273 out = print_date()
274 out += get_everything()
275 _there_is_something_in_today(False)
276 return out
277
278 def initialize():
279 """Crée les fichiers (vides) nécessaires au fonctionnement du script"""
280 files = [config.birthdays_file, config.timers_file, config.saints_file,
281 config.last_seen_file]
282 contents = ["# Anniversaires\n#jj/mm/aaaa Prénom Nom\n",
283 "# Évènements à venir\n#jj/mm/aaaa Évènement\n",
284 "# Fêtes\n#jj/mm/aaaa Saint\n",
285 "{}"]
286 for ifile in range(len(files)):
287 namefile = files[ifile]
288 if os.path.isfile(namefile):
289 print "%s exists, skipping." % (namefile,)
290 else:
291 f = open(namefile, "w")
292 f.write(contents[ifile])
293 f.close()
294
295 def sync():
296 """Synchronise les last_seen avec le serveur distant qui en garde une copie,
297 le maximum de chaque truc vu est gardé des deux côtés."""
298 lasts = get_last_seen()
299 cmd = "%s sync" % (config.path_today_server,)
300 proc = subprocess.Popen(["ssh", config.distant_server, cmd],
301 stdin = subprocess.PIPE, stdout=subprocess.PIPE,
302 close_fds = True)
303 lasts_raw = json.dumps(lasts)
304 proc.stdin.write(lasts_raw)
305 proc.stdin.close()
306 out = proc.stdout.read()
307 newdict = json.loads(out)
308 update_last_seen(newdict)
309 print "Nouvel état : %r" % newdict
310
311
312
313 #: Les actions effectuées lors d'un appel sans paramètres
314 AUTOMATED_ACTIONS = {
315 "timers" : get_timers,
316 "birth" : get_birthdays,
317 "check" : check_all,
318 }
319
320 #: Les actions qu'on peut effectuer en rajoutant des paramètres
321 OTHER_ACTIONS = {
322 "xkcd" : update_xkcd,
323 "dtc" : get_dtc,
324 "ping" : ping,
325 "show" : affiche,
326 "sync" : sync,
327
328 "init" : initialize,
329 }
330
331 #: Toutes les actions
332 ACTIONS = dict(AUTOMATED_ACTIONS)
333 ACTIONS.update(OTHER_ACTIONS)
334
335 ACTIONS[None] = affiche # action par défaut
336
337 if __name__ == "__main__":
338 import sys
339 if "--no-color" in sys.argv:
340 config.endcolor, config.red, config.blue = "","",""
341 if len(sys.argv) == 1:
342 # Juste un today
343 output = ACTIONS[None]()
344 else:
345 commande = sys.argv[1]
346 args = sys.argv[2:]
347 output = ACTIONS[commande](*args)
348 if output:
349 print output.encode("utf-8")