X-Git-Url: http://git.euphorik.ch/?p=euphorik.git;a=blobdiff_plain;f=modules%2Ferl%2Feuphorik_protocole.erl;h=99eb300fa530e9ee7b6338d11dbf375f3d738b08;hp=7b9423a394b7fc8de0998375866a2af8c8034128;hb=897468be6fa01ab87f38189f2daf266f3289c9fb;hpb=0c375e90be7cb944c1724b78377ae23c2f2ee8ef diff --git a/modules/erl/euphorik_protocole.erl b/modules/erl/euphorik_protocole.erl index 7b9423a..99eb300 100755 --- a/modules/erl/euphorik_protocole.erl +++ b/modules/erl/euphorik_protocole.erl @@ -20,8 +20,7 @@ ]). -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 @@ -30,8 +29,8 @@ generation_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() +% 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 @@ -49,10 +48,12 @@ nouveau_user_captcha(Action) -> end ). + +% Une utilisateur s'enregistre avec un tuple {Login, Password}. nouveau_user_login(Action) -> {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,15 +67,15 @@ nouveau_user_login(Action) -> ). -% Un utilisateur se logge +% 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)); + loginUser(euphorik_minichat: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)); + loginUser(euphorik_minichat:user_by_login_password(Login, Password)); _ -> simple_xml_to_string(xml_reponse_login_pas_ok("XML malformé")) end @@ -138,61 +139,72 @@ refreshMessage(Action) -> 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, + end, User = case xmerl_xpath:string("cookie", Action) of [#xmlElement{content = [#xmlText{value = Cookie}]}] -> - case euphorik_minichat:get_user_by_cookie(Cookie) of + case euphorik_minichat: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) + end, + % extraction des conversations en [{id, page}, ..] + Conversations = lists:map( + fun(Conv) -> + [#xmlElement{content = [#xmlText{value = Id_racine_str}]}] = xmerl_xpath:string("racine", Conv), + [#xmlElement{content = [#xmlText{value = Page_conv_str}]}] = xmerl_xpath:string("page", Conv), + {erlang:list_to_integer(Id_racine_str, 36), erlang:list_to_integer(Page_conv_str)} + end, + xmerl_xpath:string("conversation", Action) ), + Poulpe = euphorik_minichat_conversation:conversations(Conversations, Nb_message, Dernier_id, Page), + io:format("Poulpe = ~p~n", [Poulpe]), + % 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, + Poulpe + ) }]; _ -> [{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 +224,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), @@ -266,7 +278,8 @@ format_date(Date) -> %%%%%%%%% %%%%%%%%% simple_xml_to_string(XML) -> - lists:flatten(xmerl:export_simple(XML, xmerl_xml, [{prolog, ["\n"]}])). + io:format("~p~n", [XML]), + lists:flatten(xmerl:export_simple(XML, xmerl_xml, [{prolog, ["\n"]}])). % Construit une réponse positive à un login @@ -327,13 +340,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 ). @@ -356,7 +370,3 @@ xml_reponse_generation_captcha(Chemin, Captcha) -> } ]. %%%%%%%%% %%%%%%%%% - - - -