X-Git-Url: http://git.euphorik.ch/?p=euphorik.git;a=blobdiff_plain;f=modules%2Ferl%2Feuphorik_requests.erl;h=49cbe026132afa200c3b98e313c0382faf002045;hp=69a5597eade7af2ec44e6b7338bf1eff8a4906dd;hb=5d9992368bb386d2e606ae037c5478fe10ac70e8;hpb=4a6c575807a90370c0069b688026b10102e1ce10 diff --git a/modules/erl/euphorik_requests.erl b/modules/erl/euphorik_requests.erl index 69a5597..49cbe02 100755 --- a/modules/erl/euphorik_requests.erl +++ b/modules/erl/euphorik_requests.erl @@ -36,8 +36,10 @@ out(A) -> end, % 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 ->