X-Git-Url: http://git.euphorik.ch/?p=euphorik.git;a=blobdiff_plain;f=modules%2Ferl%2Feuphorik_protocole.erl;h=40af2ea95f4a7457c3afb0b2b58799946d2b6f4c;hp=7e8030806b6aa0127f485aa6ad582fd371055ff1;hb=ccb7fdfe9914f47cc38f96e5973851f2c6f0c4b6;hpb=35b6b48d4c8fe3a262a4f01f9b97f0b2d7fdbbdf diff --git a/modules/erl/euphorik_protocole.erl b/modules/erl/euphorik_protocole.erl index 7e80308..40af2ea 100755 --- a/modules/erl/euphorik_protocole.erl +++ b/modules/erl/euphorik_protocole.erl @@ -13,7 +13,8 @@ logout/1, profile/1, refreshMessage/1, - message/1 + message/1, + erreur/1 ]). -include_lib("xmerl/include/xmerl.hrl"). @@ -21,9 +22,8 @@ -include("../include/euphorik_defines.hrl"). -% Une utilisateur s'enregistre avec un tuple {Login, Password}. -% @spec nouveau_user_login(xmerl:xmlElement()) -> string() -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:user_by_login(L) of {ok, _} -> true; _ -> false end}; @@ -40,28 +40,18 @@ nouveau_user_login(Action) -> ). -% Un utilisateur se logge. +% Un utilisateur se logge (avec un couple {login, mot de passe}) login([{login, Login}, {password, Password}]) -> - {ok, User} = euphorik_minichat:user_by_login_password(Login, 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)). - -login(Action) -> - case xmerl_xpath:string("cookie", Action) of - [#xmlElement{content = [#xmlText{value = 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:user_by_login_password(Login, Password)); - _ -> - simple_xml_to_string(xml_reponse_login_pas_ok("XML malformé")) - end - end. 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. @@ -77,48 +67,61 @@ 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, - Page_principale = case xmerl_xpath:string("pagePrincipale", Action) of [#xmlElement{content = [#xmlText{value = P3}]}] -> list_to_integer(P3); _ -> undefined end, - Conversations = lists:foldr( - fun(Conv, Acc) -> - [#xmlElement{content = [#xmlText{value = Id_racine_str}]}] = xmerl_xpath:string("racine", Conv), - [#xmlElement{content = [#xmlText{value = Page_conv_str}]}] = xmerl_xpath:string("page", Conv), - Message_id = erlang:list_to_integer(Id_racine_str, 36), - % vérification de la validité de l'id - Message_existe = euphorik_minichat:message_existe(Message_id), - if Message_existe -> - [{Message_id, list_to_integer(Page_conv_str)} | Acc]; - true -> - Acc - end - end, - [], - xmerl_xpath:string("conversation", Action) - ), - case euphorik_minichat:set_profile(Cookie, Login, Password, Pseudo, Email, Css, Page_principale, Conversations) 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) -> +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 = euphorik_minichat:user_by_cookie(Cookie), + + + % TODO.... + + + simple_xml_to_string( case xmerl_xpath:string("nombreMessage", Action) of % le nombre de message qu'affiche le client [#xmlElement{content = [#xmlText{value = Nb_message_str}]}] -> @@ -236,6 +239,16 @@ message(Action) -> end ). + +% Construit une erreur +erreur(Message) -> + { + struct, [ + {reply, "error"}, + {error_message, Message} + ] + }. + % Formatage d'une heure % local_time() -> string @@ -257,10 +270,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, [{status, "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) @@ -290,6 +304,35 @@ xml_reponse_login_ok(User) -> }]. +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"}], @@ -298,23 +341,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é