X-Git-Url: http://git.euphorik.ch/?a=blobdiff_plain;f=modules%2Ferl%2Feuphorik_protocole.erl;h=4eed84db9696d82ed069351c0160f8424a679ddf;hb=b5878679d51e91e8a86dd042251c91290bf8caf2;hp=7b9423a394b7fc8de0998375866a2af8c8034128;hpb=13ea96f3600d1c42b22b6ea91dc75055555f72b7;p=euphorik.git diff --git a/modules/erl/euphorik_protocole.erl b/modules/erl/euphorik_protocole.erl index 7b9423a..4eed84d 100755 --- a/modules/erl/euphorik_protocole.erl +++ b/modules/erl/euphorik_protocole.erl @@ -1,58 +1,32 @@ % coding: utf-8 -% Ce module gére les différents message envoyé par le client (javascript) +% Ce module gére les différents message envoyé par le client (javascript) via AJAX. % Par exemple le client peut demander les derniers messages du minichat. % Les messages sont au format XML, la plus part des fonctions accepte un xmlDocument() et renvoie un string() % qui est la réponse XML. -% Example XML : http://www.erlang.org/doc/apps/xmerl/xmerl_ug.html -% Auteur : G.Burri -% Date : 29.10.2007 +% Example XML : http://www.erlang.org/doc/apps/xmerl/xmerl_ug.html. +% @author G.Burri -module(euphorik_protocole). -export([ - generation_captcha/1, - nouveau_user_captcha/1, nouveau_user_login/1, login/1, logout/1, profile/1, refreshMessage/1, - message/1 -]). + message/1, + erreur/1 +]). + -include_lib("xmerl/include/xmerl.hrl"). -include("../include/euphorik_bd.hrl"). --include("../include/euphorik_defines.hrl"). -%-compile(export_all). - +-include("../include/euphorik_defines.hrl"). -% Génère un nouveau captchat dans ?DOSSIER_CAPTCHA -generation_captcha(_) -> - {Mot_crypt, Nom_fichier} = captcha:create(5, ?DOSSIER_CAPTCHA), - simple_xml_to_string(xml_reponse_generation_captcha(?DOSSIER_CAPTCHA_RELATIF "/" ++ Nom_fichier, Mot_crypt)). - - -% Un nouvel utilisateur doit être créé -% Action est un xmlElement() -nouveau_user_captcha(Action) -> - simple_xml_to_string( - case {xmerl_xpath:string("captchaCrypt", Action), xmerl_xpath:string("captchaInput", Action)} of - {[#xmlElement{content = [#xmlText{value = C1}]}], [#xmlElement{content = [#xmlText{value = C2}]}]} -> - C2_crypt = common:crypt(C2), - if C1 =:= C2_crypt -> - Cookie = generer_cookie(), - User = euphorik_minichat:nouveau_user("Paul", Cookie), - xml_reponse_login_ok(User); - true -> - xml_reponse_login_pas_ok("Captcha incorrect") - end; - _ -> - xml_reponse_login_pas_ok("XML malformé") - end - ). -nouveau_user_login(Action) -> +% Une utilisateur s'enregistre avec un tuple {Login, Password}. +register([]) -> {Login, Password, Login_deja_pris} = case {xmerl_xpath:string("login", Action), xmerl_xpath:string("password", Action)} of {[#xmlElement{content = [#xmlText{value = L}]}], [#xmlElement{content = [#xmlText{value = P}]}]} -> - {L, P, case euphorik_minichat:get_user_by_login(L) of {ok, _} -> true; _ -> false end}; + {L, P, case euphorik_minichat:user_by_login(L) of {ok, _} -> true; _ -> false end}; _ -> {[], [], false} end, simple_xml_to_string( @@ -66,24 +40,18 @@ nouveau_user_login(Action) -> ). -% Un utilisateur se logge -login(Action) -> - case xmerl_xpath:string("cookie", Action) of - [#xmlElement{content = [#xmlText{value = Cookie}]}] -> - loginUser(euphorik_minichat:get_user_by_cookie(Cookie)); - _ -> - case {xmerl_xpath:string("login", Action), xmerl_xpath:string("password", Action)} of - {[#xmlElement{content = [#xmlText{value = Login}]}], [#xmlElement{content = [#xmlText{value = Password}]}]} -> - loginUser(euphorik_minichat:get_user_by_login_password(Login, Password)); - _ -> - simple_xml_to_string(xml_reponse_login_pas_ok("XML malformé")) - end - end. +% Un utilisateur se logge (avec un couple {login, mot de passe}) +login([{login, Login}, {password, Password}]) -> + loginUser(euphorik_minichat:user_by_login_password(Login, Password)); +% Un utilisateur se logge (avec un cookie) +login([{cookie, Cookie}]) -> + loginUser(euphorik_minichat:user_by_cookie(Cookie)). + loginUser({ok, User}) -> euphorik_minichat:update_date_derniere_connexion(User#user.id), - simple_xml_to_string(xml_reponse_login_ok(User)); + json_reponse_login_ok(User); loginUser(_) -> - simple_xml_to_string(xml_reponse_login_pas_ok("Erreur de login")). + erreur("Erreur login"). % Renvoie un string() représentant un cookie en base 36. Il y a 10^32 possibillités. @@ -99,100 +67,116 @@ logout(_) -> % Modification du profile. -profile(Action) -> - simple_xml_to_string( - case xmerl_xpath:string("cookie", Action) of - [#xmlElement{content = [#xmlText{value = Cookie}]}] -> - Login = case xmerl_xpath:string("login", Action) of [#xmlElement{content = [#xmlText{value = L}]}] -> L; _ -> undefined end, - Password = case xmerl_xpath:string("password", Action) of [#xmlElement{content = [#xmlText{value = P}]}] -> P; _ -> undefined end, - Pseudo = case xmerl_xpath:string("pseudo", Action) of [#xmlElement{content = [#xmlText{value = P2}]}] -> P2; _ -> Login end, - Email = case xmerl_xpath:string("email", Action) of [#xmlElement{content = [#xmlText{value = E}]}] -> E; _ -> undefined end, - Css = case xmerl_xpath:string("css", Action) of [#xmlElement{content = [#xmlText{value = C}]}] -> C; _ -> undefined end, - case euphorik_minichat:set_profile(Cookie, Login, Password, Pseudo, Email, Css) of - ok -> - xml_reponse_profile_ok(); - login_deja_pris -> - xml_reponse_profile_pas_ok("Login déjà pris"); - _ -> - xml_reponse_profile_pas_ok("Impossible de mettre à jour le profile") - end; - _ -> - xml_reponse_profile_pas_ok("XML malformé") - end - ). - +profile( + [ + {cookie, Cookie}, + {login, Login}, + {password, Password}, + {pseudo, Pseudo}, + {email, Email}, + {css, Css}, + {main_page, Main_page}, + {conversations, {array, Conversations_json}} + ] +) -> + % est-ce que les messages auquel on répond existent ? + Conversations = lists:foldr( + fun([struct, {root, Root}, {page, Page}], Acc) -> + Message_existe = euphorik_minichat:message_existe(Root), + if Message_existe -> + [{Root, Page} | Acc]; + true -> + Acc + end, + [], + Conversations_json + ), + case euphorik_minichat:set_profile(Cookie, Login, Password, Pseudo, Email, Css, Main_page, Conversations) of + ok -> + json_reponse_ok(); + login_deja_pris -> + erreur("Login déjà pris"); + _ -> + erreur("Impossible de mettre à jour le profile") + end. + % Renvoie les messages appropriés. -refreshMessage(Action) -> - simple_xml_to_string( - case { - xmerl_xpath:string("nombreMessage", Action), % le nombre de message qu'affiche le client - xmerl_xpath:string("page", Action) % la page désiré, la première (les derniers messages) étant la 1 - } of - { - [#xmlElement{content = [#xmlText{value = Nb_message_str}]}], - [#xmlElement{content = [#xmlText{value = Page_str}]}] - } -> - Nb_message = list_to_integer(Nb_message_str), - Page = list_to_integer(Page_str), - Dernier_id = case xmerl_xpath:string("dernierMessageId", Action) of % l'id du dernier message que connait le client - [#xmlElement{content = [#xmlText{value = D}]}] -> erlang:list_to_integer(D, 36); - _ -> 0 - end, - User = case xmerl_xpath:string("cookie", Action) of - [#xmlElement{content = [#xmlText{value = Cookie}]}] -> - case euphorik_minichat:get_user_by_cookie(Cookie) of - {ok, U} -> U; - _ -> inconnu - end; - _ -> inconnu - end, - % accrochez-vous ca va siouxer ;) - Mess = lists:map( - fun(Mess) -> - Est_proprietaire = User =/= inconnu andalso User#user.id =:= Mess#minichat.auteur_id, - A_repondu_a_message = User =/= inconnu andalso euphorik_minichat:a_repondu_a_message(User#user.id, Mess#minichat.id), - Est_une_reponse_a_user = User =/= inconnu andalso euphorik_minichat:est_une_reponse_a_user(User#user.id, Mess#minichat.id), - User_mess = if Mess#minichat.auteur_id =:= 0 -> inconnu; true -> - {ok, U2} = euphorik_minichat:get_user_by_id(Mess#minichat.auteur_id), - U2 - end, - {message, [{id, erlang:integer_to_list(Mess#minichat.id, 36)}], - [ - {date, [], [format_date(Mess#minichat.date)]}, - {systeme, [], [atom_to_list(Mess#minichat.auteur_id =:= 0)]}, - {proprietaire, [], [atom_to_list(Est_proprietaire)]}, - {repondu, [], [atom_to_list(A_repondu_a_message)]}, - {reponse, [], [atom_to_list(Est_une_reponse_a_user)]}, - {pseudo, [], [Mess#minichat.pseudo]}, - {login, [], [if User_mess =:= inconnu -> Mess#minichat.pseudo; true -> User_mess#user.login end]}, - {contenu, [], [Mess#minichat.contenu]}, - {repondA, [], xml_repond_a(Mess#minichat.id)} - ] - } - end, - get_dernieres_messages(Dernier_id, Nb_message, Page) - ), +wait_event( + [ + {cookie, Cookie}, + {message_count, Message_count} | Reste + ] +) -> + % Last message id est facultatif + Last_message_id = case lists:keysearch(last_message_id, 1, Reste) of + {Id, _} -> Id; + _ -> 0 + end, + {Main_page, _} = lists:keysearch(main_page, 1, Reste), + {{array, Conversations_json}, _} = lists:keysearch(conversations, 1, Reste), + User = case euphorik_minichat:user_by_cookie(Cookie) of + {ok U} -> U; + _ -> inconnu + end, + {stuct, [ + {reply, "new_message"}, + {conversations, {array, + TODO ... + } + ]} + + % accrochez-vous ca va siouxer ;) [{reponse, [{name, "refreshMessages"}], - % la fonction get_nb_page DOIT être évalué après get_dernieres_messages (merci les effets de bord) - [{nbPage, [], [integer_to_list(euphorik_minichat:get_nb_page(Nb_message))]} | Mess] + lists:map( + fun({Conv, Plus}) -> + {conversation, [], + [{autresPages, [], [atom_to_list(Plus)]} | + lists:map( + fun({Mess, Repond_a}) -> + Est_proprietaire = User =/= inconnu andalso User#user.id =:= Mess#minichat.auteur_id, + A_repondu_a_message = User =/= inconnu andalso euphorik_minichat:a_repondu_a_message(User#user.id, Mess#minichat.id), + Est_une_reponse_a_user = User =/= inconnu andalso euphorik_minichat:est_une_reponse_a_user(User#user.id, Mess#minichat.id), + User_mess = + if Mess#minichat.auteur_id =:= 0 -> + inconnu; + true -> + {ok, U2} = euphorik_minichat:user_by_id(Mess#minichat.auteur_id), + U2 + end, + {message, [{id, erlang:integer_to_list(Mess#minichat.id, 36)}], + [ + {date, [], [format_date(Mess#minichat.date)]}, + {systeme, [], [atom_to_list(Mess#minichat.auteur_id =:= 0)]}, + {proprietaire, [], [atom_to_list(Est_proprietaire)]}, + {repondu, [], [atom_to_list(A_repondu_a_message)]}, + {reponse, [], [atom_to_list(Est_une_reponse_a_user)]}, + {pseudo, [], [Mess#minichat.pseudo]}, + {login, [], [if User_mess =:= inconnu -> Mess#minichat.pseudo; true -> User_mess#user.login end]}, + {contenu, [], [Mess#minichat.contenu]}, + {repondA, [], xml_repond_a(Repond_a)} + ] + } + end, + Conv + ) + ] + } + end, + euphorik_minichat_conversation:conversations( + if User =/= inconnu -> User#user.conversations; true -> [] end, + Nb_message, + Dernier_id, + if User =/= inconnu -> User#user.page_principale; true -> 1 end + ) + ) }]; _ -> [{reponse, [{name, "refreshMessages"}], [{erreur, [], ["erreur"]}]}] end ). - -% Renvoie les derniers messages, s'il n'y en a pas on effectue une attente. -get_dernieres_messages(Dernier_id, Nb_message, Page) -> - Messages = euphorik_minichat:messages(Dernier_id, Nb_message, Page), - if Messages =:= [] -> - euphorik_minichat:attends_nouveau_messages(), - euphorik_minichat:messages(Dernier_id, Nb_message, Page); - true -> - Messages - end. - + % Prend une liste de xml text node et en resort un string() % xmerl : "test & test" devient deux fragments de texte : "test " et "& test", il faut donc rassembler les morceaux... defragmenter(Text_nodes) -> @@ -212,7 +196,7 @@ message(Action) -> [#xmlElement{content = Pseudo_fragments}], [#xmlElement{content = Contenu_fragments}] } -> - case euphorik_minichat:get_user_by_cookie(Cookie) of + case euphorik_minichat:user_by_cookie(Cookie) of {ok, U} -> Pseudo = defragmenter(Pseudo_fragments), Contenu = defragmenter(Contenu_fragments), @@ -243,6 +227,16 @@ message(Action) -> end ). + +% Construit une erreur +erreur(Message) -> + { + struct, [ + {reply, "error"}, + {error_message, Message} + ] + }. + % Formatage d'une heure % local_time() -> string @@ -264,10 +258,11 @@ format_date(Date) -> io_lib:format("~2.10.0B:~2.10.0B:~2.10.0B", [Heure, Minute, Seconde]). -%%%%%%%%% %%%%%%%%% -simple_xml_to_string(XML) -> - lists:flatten(xmerl:export_simple(XML, xmerl_xml, [{prolog, ["\n"]}])). +%%%%%%%%% %%%%%%%%% +json_reponse_ok() -> + {struct, [{reply, "ok"}]}. + % Construit une réponse positive à un login % si Enregistre vaut true alors cela veut dire que la personne s'est enregistré (elle possède au moins un login et un password) @@ -280,11 +275,52 @@ xml_reponse_login_ok(User) -> {pseudo, [User#user.pseudo]}, {login, [User#user.login]}, {email, [User#user.email]}, - {css, [User#user.css]} - ] + {css, [User#user.css]}, + {pagePrincipale, [integer_to_list(User#user.page_principale)]} + ] ++ + lists:map( + fun(C) -> + {conversation, + [ + {racine, [erlang:integer_to_list(element(1, C), 36)]}, + {page, [integer_to_list(element(2, C))]} + ] + } + end, + User#user.conversations + ) }]. +json_reponse_login_ok(User) -> + { + struct, [ + {reply, "login"}, + {status, if (User#user.password =/= []) and (User#user.login =/= []) -> "enregistre"; true -> "identifie" end}, + {cookie, User#user.cookie}, + {id, User#user.id}, + {pseudo, User#user.pseudo}, + {login, User#user.login}, + {email, User#user.email}, + {css, User#user.css}, + {main_page, User#user.page_principale}, + {conversations, + {array, + lists:map( + fun(C) -> + {struct, + {root, element(1, C)}, + {page, element(2, C)} + } + end, + User#user.conversations + ) + } + } + ] + }. + + % Construit un réponse négative à un login xml_reponse_login_pas_ok(Message) -> [{reponse, [{name, "login"}], @@ -293,23 +329,6 @@ xml_reponse_login_pas_ok(Message) -> {information, [Message]} ] }]. - - -xml_reponse_profile_ok() -> - [{reponse, [{name, "profile"}], - [ - {statut, ["ok"]} - ] - }]. - - -xml_reponse_profile_pas_ok(Message) -> - [{reponse, [{name, "profile"}], - [ - {statut, ["pas ok"]}, - {information, [Message]} - ] - }]. % Pas utilisé @@ -327,13 +346,14 @@ xml_reponse_profile_pas_ok(Message) -> % Renvoie un element XML representant une liste de messages auquel le message M_id repond -xml_repond_a(Mess_id) -> +xml_repond_a(Reponses) -> lists:map( - fun(M) -> - {ok, User} = euphorik_minichat:get_user_by_id(M#minichat.auteur_id), + fun(Id_mess) -> + {ok, M} = euphorik_minichat:message_by_id(Id_mess), + {ok, User} = euphorik_minichat:user_by_mess(Id_mess), {id, [{id, erlang:integer_to_list(M#minichat.id, 36)}, {pseudo, M#minichat.pseudo}, {login, User#user.login}], []} end, - euphorik_minichat:repond_a(Mess_id) + Reponses ). @@ -345,18 +365,5 @@ xml_reponse_message(Ok) -> ] } ]. - -xml_reponse_generation_captcha(Chemin, Captcha) -> - [ - {reponse, [{name, "generationCaptcha"}], - [ - {chemin, [], [Chemin]}, - {captchaCrypt, [], [Captcha]} - ] - } - ]. -%%%%%%%%% %%%%%%%%% - - - +%%%%%%%%% %%%%%%%%%