X-Git-Url: http://git.euphorik.ch/?p=euphorik.git;a=blobdiff_plain;f=modules%2Ferl%2Feuphorik_protocole.erl;fp=modules%2Ferl%2Feuphorik_protocole.erl;h=3f9d7a1509cdeca488765020bb533e22d703e1e1;hp=dac7d03661424a8ba9b479406d201f5b642d057f;hb=7ade6a3495cd5c74c964df5ed794e110e770ed9d;hpb=1f99e21a004d4dd93102bec8248af067c831386b diff --git a/modules/erl/euphorik_protocole.erl b/modules/erl/euphorik_protocole.erl index dac7d03..3f9d7a1 100755 --- a/modules/erl/euphorik_protocole.erl +++ b/modules/erl/euphorik_protocole.erl @@ -74,19 +74,27 @@ erreur_register_flood() -> % Un utilisateur se logge (avec un couple {login, mot de passe}) login([{login, Login}, {password, Password}], IP) -> - loginUser(euphorik_bd:user_by_login_password(Login, Password), IP); + case euphorik_bd:user_by_login_password(Login, Password) of + {ok, User} -> + loginUser(User, IP); + _ -> + timer:sleep(?TEMPS_ATTENTE_ERREUR_LOGIN), + erreur("Couple login/pass introuvable") + end; % Un utilisateur se logge (avec un cookie) login([{cookie, Cookie}], IP) -> - loginUser(euphorik_bd:user_by_cookie(Cookie), IP). + case euphorik_bd:user_by_cookie(Cookie) of + {ok, User} -> + loginUser(User, IP); + _ -> + timer:sleep(?TEMPS_ATTENTE_ERREUR_LOGIN), + erreur("Authentification impossible par cookie") + end. -loginUser({ok, User}, IP) -> +loginUser(User, IP) -> euphorik_bd:update_ip(User#user.id, IP), euphorik_bd:update_date_derniere_connexion(User#user.id), - json_reponse_login_ok(User); -loginUser(_, _) -> - % ajoute un délais d'attente - timer:sleep(?TEMPS_ATTENTE_ERREUR_LOGIN), - erreur("Couple login/pass introuvable"). + json_reponse_login_ok(User). % Renvoie un string() représentant un cookie en base 36. Il y a 10^32 possibillités. @@ -113,14 +121,22 @@ profile( {nick_format, Nick_format_str}, {view_times, View_times}, {view_tooltips, View_tooltips}, - {conversations, {array, Conversations_json}} + {conversations, {array, Conversations_json}}, + {ostentatious_master, Ostentatious_master} ] ) -> - % virage des messages qui n'existent pas - Conversations = lists:dropwhile( - fun(Message_id) -> - not euphorik_bd:message_existe(Message_id) + % décomposition de la strucure JSON + Conversations = lists:foldr( + fun({struc, [{root, Racine}, {minimized, Reduit}]}, A) -> + % virage des messages qui n'existent pas + Message_exite = euphorik_bd:message_existe(Racine), + if Message_exite -> + [ {Racine, Reduit} | A]; + true -> + A + end end, + [], Conversations_json ), % TODO : pas très beau, mieux vaut construire un #user @@ -134,7 +150,8 @@ profile( list_to_atom(Nick_format_str), View_times, View_tooltips, - Conversations) of + Conversations, + list_to_atom(Ostentatious_master)) of ok -> json_reponse_ok(); login_deja_pris -> @@ -658,8 +675,14 @@ json_reponse_login_ok(User) -> {nick_format, atom_to_list(User#user.nick_format)}, {view_times, User#user.view_times}, {view_tooltips, User#user.view_tooltips}, - {conversations, {array, User#user.conversations } }, - {ek_master, User#user.ek_master} + {conversations, {array, lists:map( + fun({Racine, Reduit}) -> + {struct, [{root, Racine}, {minimized, Reduit}]} + end, + User#user.conversations + )}}, + {ek_master, User#user.ek_master}, + {ostentatious_master, atom_to_list(User#user.ostentatious_master)} ] }. @@ -692,5 +715,6 @@ json_message(Mess, Repond_a, User) -> end, Repond_a )}}, - {ek_master, User_mess#user.ek_master} + {ek_master, User_mess#user.ek_master}, + {ostentatious_master, atom_to_list(User_mess#user.ostentatious_master)} ]}.