X-Git-Url: http://git.euphorik.ch/?a=blobdiff_plain;f=modules%2Ferl%2Feuphorik_requests.erl;h=4af2f7ecde9a24fc9ceed7d90832f31fa7df04a7;hb=13bf850da2316cde3ad2ff8d5c26fb32928bf7b4;hp=abfdd93befb680db3c2b76ff321a3561fb060b7d;hpb=bacec85920574375f4b8df20d6a0457e1fffc658;p=euphorik.git diff --git a/modules/erl/euphorik_requests.erl b/modules/erl/euphorik_requests.erl index abfdd93..4af2f7e 100755 --- a/modules/erl/euphorik_requests.erl +++ b/modules/erl/euphorik_requests.erl @@ -12,76 +12,49 @@ -include_lib("xmerl/include/xmerl.hrl"). -include_lib("yaws/include/yaws_api.hrl"). + -% Test du module -tester() -> - %~ {XML, _} = xmerl_scan:string( - %~ "" - %~ " b1b1b4e72e6f3d00e477cf37cced5851" - %~ " LKJDLA" - %~ ""), - %~ io:format("Nouvel user : ~p~n", [nouveau_user(XML)]). - - %~ {XML2, _} = xmerl_scan:string( - %~ "" - %~ " 5DZQ2HCRO7JIX3QCSWRNL" - %~ ""), - %~ io:format("Login : ~p~n", [euphorik_protocole:login(XML2)]). - - XML = - "" - "2" - "1" - "31" - "", - io:format("Messages de la premières page : ~p~n", [traiter_xml(XML)]). - - %~ traiter_xml("" - %~ "4UDUSY6Z2IZNTQO484S8X" - %~ "Pifou" - %~ "test & plop" - %~ ""). - %~ traiter_xml( - %~ "" - %~ ""). +% Test du module (TODO) +tester() -> + que_dal. -% il faut catcher toutes les exceptions possibles -out(A) -> +out(A) -> + %io:format("~p~n~n", [A]), + IP = case inet:peername(A#arg.clisock) of + {ok, {Adresse, _Port}} -> Adresse; + _ -> inconnue + end, %inet:setopts(A#arg.clisock, inet:getopts(A#arg.clisock, [active])), {value, {_, Contenu}} = lists:keysearch("action", 1, yaws_api:parse_post(A)), - Ret = traiter_xml(Contenu), - {content, "text/xml", Ret}. + Ret = traiter_donnees(Contenu, IP), + {content, "application/json", Ret}. -traiter_xml(Contenu) -> - {XML, _} = xmerl_scan:string(Contenu), - traiter_action(XML#xmlElement.attributes, XML). - - -% un client demande la génération d'un captcha (obsolète) -%~ traiter_action([#xmlAttribute{value="generationCaptcha"}], XML) -> - %~ euphorik_protocole:generation_captcha(XML); -% un client se log pour la première fois (obsolète) -%~ traiter_action([#xmlAttribute{value="loginCaptcha"}], XML) -> - %~ euphorik_protocole:nouveau_user_captcha(XML); - +traiter_donnees(Contenu, IP) -> + case json:decode_string(Contenu) of + {ok, {struct, [{action, Action}| Reste]}} -> + json:encode(traiter_action(Action, Reste, IP)); + _ -> + error + end. + +% authentification d'un client +traiter_action("authentification", JSON, IP) -> + euphorik_protocole:login(JSON, IP); % un client s'enregistre (pseudo + password) -traiter_action([#xmlAttribute{value="register"}], XML) -> - euphorik_protocole:nouveau_user_login(XML); -% authentification d'un client -traiter_action([#xmlAttribute{value="login"}], XML) -> - euphorik_protocole:login(XML); +traiter_action("register", JSON, IP) -> + euphorik_protocole:register(JSON, IP); % modification du profile -traiter_action([#xmlAttribute{value="profile"}], XML) -> - euphorik_protocole:profile(XML); -% un utilisateur demande les messages -traiter_action([#xmlAttribute{value="refreshMessages"}], XML) -> - euphorik_protocole:refreshMessage(XML); -% un utilisateur envoie un message -traiter_action([#xmlAttribute{value="message"}], XML) -> - euphorik_protocole:message(XML). - - - +traiter_action("set_profile", JSON, _) -> + euphorik_protocole:profile(JSON); +% un utilisateur attend un événement (par exemple l'arrivé d'un nouveau message) +traiter_action("wait_event", JSON, _) -> + euphorik_protocole:wait_event(JSON); +% un utilisateur envoie un message +traiter_action("put_message", JSON, _) -> + euphorik_protocole:put_message(JSON); +traiter_action("ban", JSON, _) -> + euphorik_protocole:ban(JSON). + \ No newline at end of file