X-Git-Url: http://git.euphorik.ch/?p=euphorik.git;a=blobdiff_plain;f=modules%2Ferl%2Feuphorik_requests.erl;h=49cbe026132afa200c3b98e313c0382faf002045;hp=1cd460ad20517a1216561fda416f2c7b88f192e2;hb=5d9992368bb386d2e606ae037c5478fe10ac70e8;hpb=ba4387c6afaaa2964c28292e7fbd1c35b3404ce5 diff --git a/modules/erl/euphorik_requests.erl b/modules/erl/euphorik_requests.erl index 1cd460a..49cbe02 100755 --- a/modules/erl/euphorik_requests.erl +++ b/modules/erl/euphorik_requests.erl @@ -15,29 +15,31 @@ % % You should have received a copy of the GNU General Public License % along with Euphorik. If not, see . -% -% Ce module est fait pour répondre à des requêtes JSON via 'AJAX'. -% Il est définit comme 'appmods' pour l'url "request" dans Yaws. -% Par exemple http://www.euphorik.ch/request abouti sur la fonction out/1 de ce module. -% @author G.Burri +% +% This module responds to JSON requests via 'AJAX'. +% It's defined as an Yaws 'appmods' with the url '/request'. +% For instance in debug mode 'http://localhost:8090/request' will call the out/1 function. -module(euphorik_requests). +-author("Greg Burri "). -export([out/1]). --include_lib("yaws/include/yaws_api.hrl"). +-include_lib("yaws_api.hrl"). -include("../include/euphorik_defines.hrl"). -% Point d'entrée pour les requêtes AJAX sur http://www.euphorik.ch/request. +% Entry point for all AJAX requests on '/request'. out(A) -> IP = case inet:peername(A#arg.clisock) of - {ok, {Adresse, _Port}} -> Adresse; - _ -> inconnue + {ok, {Address, _Port}} -> Address; + _ -> unknown end, - % passive -> active, permet de recevoir {tcp_closed, _} lorsque le socket se ferme - % keepalive -> true, evite que des firewalls coupe la connexion TCP sans prévenir + % active: to receive {tcp_closed, _} when the socket is closing. + % keepalive: avoid firewalls to cut the connection. + inet:setopts(A#arg.clisock, [{active, true}, {keepalive, true}]), {value, {_, Contenu}} = lists:keysearch("action", 1, yaws_api:parse_post(A)), + Ret = traiter_message(Contenu, IP), {content, "application/json", Ret}. @@ -45,8 +47,9 @@ out(A) -> % Décode le message JSON. traiter_message(Contenu, IP) -> % extrait l'entête obligatoire des messages JSON - {ok, {struct, [{header, {struct, [{action, Action}, {version, Version_client}]}} | Reste]}} = json:decode_string(Contenu), - json:encode( + {ok, {struct, [{"header", {struct, [{"action", Action}, {"version", Version_client}]}} | Reste]}} = json2:decode_string(Contenu), + + json2:encode( if Version_client =:= ?VERSION_PROTOCOLE -> traiter_action(Action, Reste, IP); true -> @@ -55,7 +58,7 @@ traiter_message(Contenu, IP) -> ))) end ). - + % Authentification d'un client. traiter_action("authentification", JSON, IP) -> @@ -78,19 +81,9 @@ traiter_action("ban", JSON, _) -> % Un ekMaster slap un utilisateur. traiter_action("slap", JSON, _) -> euphorik_protocole:slap(JSON); -% Un ekMaster envoie un nouveau troll. -traiter_action("put_troll", JSON, _) -> - euphorik_protocole:put_troll(JSON); -% Un ekMaster modifie un troll. -traiter_action("mod_troll", JSON, _) -> - euphorik_protocole:mod_troll(JSON); -% Un ekMaster supprime un troll. -traiter_action("del_troll", JSON, _) -> - euphorik_protocole:del_troll(JSON); % Un ekMaster demande la liste des ips bannies. traiter_action("list_banned_ips", JSON, _) -> euphorik_protocole:list_banned_ips(JSON); % Un ekMaster débannie une ip. traiter_action("unban", JSON, _) -> euphorik_protocole:unban_ip(JSON). - \ No newline at end of file