X-Git-Url: http://git.euphorik.ch/?p=euphorik.git;a=blobdiff_plain;f=modules%2Ferl%2Feuphorik_protocole.erl;h=a34eae63058baf9e4e61e61fa75879e9db7a5423;hp=c3dfbbe0406a0c1c56233d9a738ec8f64f91d58c;hb=c6a3cf5c036c651fbe9d4d7c0e0ce34d991d3509;hpb=11fe8f6d268a9b1c0a773294cc7d70ffdb6afb30 diff --git a/modules/erl/euphorik_protocole.erl b/modules/erl/euphorik_protocole.erl index c3dfbbe..a34eae6 100755 --- a/modules/erl/euphorik_protocole.erl +++ b/modules/erl/euphorik_protocole.erl @@ -25,7 +25,6 @@ -export([ register/2, login/2, - logout/1, profile/1, wait_event/1, put_message/1, @@ -43,14 +42,14 @@ % Une utilisateur s'enregistre avec un tuple {Login, Password}. -register([{login, Login}, {password, Password}, {profile_infos, Profile_infos}], IP) -> +register([{login, Login}, {password, Password}, {profile, Profile_json}], IP) -> Can_register = euphorik_bd:can_register(IP), if Can_register -> case euphorik_bd:user_by_login(Login) of {ok, _} -> - erreur("Login déjà existant"); + erreur(10); _ -> - User = euphorik_bd:nouveau_user(Login, Password, generer_cookie(), user_from_json(Profile_infos)), + User = euphorik_bd:nouveau_user(Login, Password, generer_cookie(), profile_from_json(Profile_json)), euphorik_bd:update_ip(User#user.id, IP), json_reponse_login_ok(User) end; @@ -58,10 +57,11 @@ register([{login, Login}, {password, Password}, {profile_infos, Profile_infos}], erreur_register_flood() end; % Enregistrement sans {Login, Password} -register([{profile_infos, Profile_infos}], IP) -> +register([{profile, Profile_json}], IP) -> Can_register = euphorik_bd:can_register(IP), if Can_register -> - User = euphorik_bd:nouveau_user("", generer_cookie(), user_from_json(Profile_infos)), + Profile = profile_from_json(Profile_json), + User = euphorik_bd:nouveau_user(generer_cookie(), Profile#profile{pseudo = ""}), euphorik_bd:update_ip(User#user.id, IP), json_reponse_login_ok(User); true -> @@ -69,7 +69,7 @@ register([{profile_infos, Profile_infos}], IP) -> end. erreur_register_flood() -> - erreur("Trop de register (flood)"). + erreur(20). % Un utilisateur se logge (avec un couple {login, mot de passe}) @@ -79,7 +79,7 @@ login([{login, Login}, {password, Password}], IP) -> loginUser(User, IP); _ -> timer:sleep(?TEMPS_ATTENTE_ERREUR_LOGIN), - erreur("Couple login/pass introuvable") + erreur(30) end; % Un utilisateur se logge (avec un cookie) login([{cookie, Cookie}], IP) -> @@ -88,9 +88,11 @@ login([{cookie, Cookie}], IP) -> loginUser(User, IP); _ -> timer:sleep(?TEMPS_ATTENTE_ERREUR_LOGIN), - erreur("Authentification impossible par cookie") + erreur(40) end. + +% L'utilisateur donné se logge avec l'ip donnée. loginUser(User, IP) -> euphorik_bd:update_ip(User#user.id, IP), euphorik_bd:update_date_derniere_connexion(User#user.id), @@ -104,42 +106,31 @@ generer_cookie() -> erlang:integer_to_list(random:uniform(math:pow(10, 32)), 36). -% Un utilisateur se délogge. -logout(_) -> - do_nothing. - - % Modification du profile. profile( [ {cookie, Cookie}, {login, Login}, {password, Password}, - {profile_infos, Profile_infos} + {profile, Profile_json} ] ) -> - case user_from_json(Profile_infos) of + case profile_from_json(Profile_json) of {erreur, E} -> E; - UserInfos -> - User = UserInfos#user { - cookie = Cookie, - login = Login, - password = Password - }, - % TODO : pas très beau, mieux vaut construire un #user - case euphorik_bd:set_profile(User) of + Profile -> + case euphorik_bd:set_profile(Cookie, Login, Password, Profile) of ok -> json_reponse_ok(); login_deja_pris -> - erreur("Login déjà pris"); + erreur(10); _ -> - erreur("Impossible de mettre à jour le profile") + erreur(50) end end. % Construit un #user à partir des données JSON -user_from_json( +profile_from_json( {struct, [ {nick, Pseudo}, @@ -184,7 +175,7 @@ user_from_json( if not Ostentatious_master_valide -> {erreur, Ostentatious_master_str ++ " n'est pas une valeur acceptée pour 'ostentatious_master'"}; true -> - #user{ + #profile{ pseudo = Pseudo, email = Email, css = Css, @@ -200,7 +191,7 @@ user_from_json( end. -% Renvoie les messages appropriés. +% Attend un événement pour la page "Chat" % last_message id et cookie sont facultatifs wait_event([{page, "chat"} | Data]) -> % traitement des inputs @@ -231,6 +222,7 @@ wait_event([{page, "chat"} | Data]) -> mnesia:unsubscribe({table, troll, detailed}), R end; +% Attend un événement pour la page "Admin" wait_event([{page, "admin"}, {last_troll, Last_troll}]) -> case wait_event_page_admin(Last_troll) of banned_ips_refresh -> @@ -254,12 +246,12 @@ wait_event([{page, "admin"}, {last_troll, Last_troll}]) -> {trolls, {array, lists:map( fun(T) -> - {ok, User} = euphorik_bd:user_by_id(T#troll.id_user), + {ok, #user{profile = Profile} = User} = euphorik_bd:user_by_id(T#troll.id_user), {struct, [ {troll_id, T#troll.id}, {content, T#troll.content}, - {author, User#user.pseudo}, + {author, Profile#profile.pseudo}, {author_id, User#user.id} ] } @@ -277,12 +269,13 @@ wait_event([{page, "admin"}, {last_troll, Last_troll}]) -> ] }; _ -> - erreur("timeout") + erreur(60) end; wait_event(_) -> - erreur("Page inconnue"). + erreur(70). +% Attend un événement pour la page "Chat" et renvoie soit un troll soit les messages manquants au client. wait_event_page_chat(User, Racines_conversations, Message_count, Last_message_id, Main_page, Troll_id) -> % est-ce que le troll est à jour ? case euphorik_bd:current_troll() of @@ -433,23 +426,23 @@ put_message( {ok, User} -> case euphorik_bd:est_banni(User#user.id) of {true, Temps_restant} -> - erreur("Vous êtes banni pour encore " ++ format_minutes(Temps_restant)); + erreur(80, [format_minutes(Temps_restant)]); _ -> Strip_content = string:strip(Content), if Strip_content =:= [] -> - erreur("Message vide"); + erreur(90); true -> % attention : non-atomique (update_pseudo+nouveau_message) euphorik_bd:update_pseudo_user(User#user.id, Nick), case euphorik_bd:nouveau_message(Strip_content, User#user.id, Answer_to) of - {erreur, R} -> erreur("Impossible d'ajouter un nouveau message. Raison : " ++ R); + {erreur, R} -> erreur(100, [R]); _ -> json_reponse_ok() end end end; _ -> - erreur("Utilisateur inconnu") + erreur(110) end. @@ -466,12 +459,12 @@ ban( {ok, User1 = #user{ek_master = true}} -> case euphorik_bd:user_by_id(User_id) of {ok, User1} -> - erreur("Il n'est pas possible de s'auto bannir"); - {ok, User2 = #user{ek_master = false}} -> + erreur(120); + {ok, #user{ek_master = false, profile = Profile2} = User2} -> euphorik_bd:ban(User2#user.last_ip, Duration), - euphorik_bd:nouveau_message_sys(lists:flatten(io_lib:format("''~s~s'' est ~s pour ~s.~s", + euphorik_bd:nouveau_message_sys(lists:flatten(io_lib:format("\"~s~s\" est ~s pour ~s.~s", [ - User2#user.pseudo, + Profile2#profile.pseudo, if User2#user.login =:= [] -> ""; true -> " (" ++ User2#user.login ++ ")" end, if Duration =< 15 -> "kické"; true -> "banni" end, format_minutes(Duration), @@ -480,12 +473,12 @@ ban( ))), json_reponse_ok(); {ok, _} -> - erreur("L'utilisateur est lui même un ekMaster"); + erreur(130); _ -> - erreur("Utilisateur à bannir inconnu") + erreur(140) end; _ -> - erreur("Utilisateur inconnu ou non ek master") + erreur(150) end. @@ -498,32 +491,32 @@ slap( ]) -> % controle que l'utilisateur est un admin case euphorik_bd:user_by_cookie(Cookie) of - {ok, User1 = #user{ek_master = true}} -> + {ok, User1 = #user{ek_master = true, profile = Profile1}} -> case euphorik_bd:user_by_id(User_id) of {ok, User1} -> euphorik_bd:nouveau_message_sys(lists:flatten(io_lib:format("~s s'auto slap~s.", [ - User1#user.pseudo, + Profile1#profile.pseudo, if Reason =/= [] -> " - Raison: " ++ Reason; true -> "" end ] ))), json_reponse_ok(); - {ok, User2 = #user{ek_master = false}} -> + {ok, #user{ek_master = false, profile = Profile2}} -> euphorik_bd:nouveau_message_sys(lists:flatten(io_lib:format("~s se fait slaper par ~s.~s", [ - User2#user.pseudo, - User1#user.pseudo, + Profile2#profile.pseudo, + Profile1#profile.pseudo, if Reason =/= [] -> " - Raison: " ++ Reason; true -> "" end ++ "." ] ))), json_reponse_ok(); {ok, _} -> - erreur("L'utilisateur est lui même un ekMaster"); + erreur(130); _ -> - erreur("Utilisateur à slaper inconnu") + erreur(160) end; _ -> - erreur("Utilisateur inconnu ou non ek master") + erreur(170) end. @@ -538,14 +531,14 @@ put_troll( {ok, User = #user{ek_master = true}} -> case euphorik_bd:put_troll(User#user.id, Content) of max_troll_reached_per_user -> - erreur(lists:flatten(io_lib:format("Le nombre de troll maximum par utilisateur est atteint : ~w ", [?NB_MAX_TROLL_WAITING_BY_USER]))); + erreur(180, [?NB_MAX_TROLL_WAITING_BY_USER]); max_troll_reached -> - erreur(lists:flatten(io_lib:format("Le nombre de troll maximum en attente est atteint : ~w ", [?NB_MAX_TROLL_WAITING]))); + erreur(190, [?NB_MAX_TROLL_WAITING]); _Id -> json_reponse_ok() end; _ -> - erreur("Seul les ekMaster peuvent proposer des trolls") + erreur(200) end. @@ -565,10 +558,10 @@ mod_troll( euphorik_bd:mod_troll(Troll_id, Content), json_reponse_ok(); _ -> - erreur("Vous ne posséder pas ce troll") + erreur(210) end; _ -> - erreur("Seul les ekMaster peuvent proposer des trolls") + erreur(220) end. @@ -587,10 +580,10 @@ del_troll( euphorik_bd:del_troll(Troll_id), json_reponse_ok(); _ -> - erreur("Vous ne posséder pas ce troll") + erreur(210) end; _ -> - erreur("Seul les ekMaster peuvent proposer des trolls") + erreur(220) end. @@ -605,7 +598,7 @@ unban_ip( euphorik_bd:deban(euphorik_common:unserialize_ip(IP)), json_reponse_ok(); _ -> - erreur("Seul les ekMaster peuvent connaitre la liste des ips bannies") + erreur(230) end. @@ -645,16 +638,25 @@ list_banned_ips( ] }; _ -> - erreur("Seul les ekMaster peuvent connaitre la liste des ips bannies") + erreur(230) end. % Construit une erreur -erreur(Message) -> +erreur(Num, Args) -> + erreur_json(Num, lists:flatten(io_lib:format(euphorik_bd:get_texte(Num), Args))). + + +erreur(Num) -> + erreur_json(Num, euphorik_bd:get_texte(Num)). + + +erreur_json(Num, Mess) -> { struct, [ {reply, "error"}, - {error_message, Message} + {no, Num}, + {error_message, Mess} ] }. @@ -700,29 +702,33 @@ json_reponse_ok() -> {struct, [{reply, "ok"}]}. -json_reponse_login_ok(User) -> +json_reponse_login_ok(#user{profile = Profile} = User) -> { struct, [ {reply, "login"}, {status, if (User#user.password =/= []) and (User#user.login =/= []) -> "auth_registered"; true -> "auth_not_registered" end}, {cookie, User#user.cookie}, {id, User#user.id}, - {nick, User#user.pseudo}, {login, User#user.login}, - {email, User#user.email}, - {css, User#user.css}, - {chat_order, atom_to_list(User#user.chat_order)}, - {nick_format, atom_to_list(User#user.nick_format)}, - {view_times, User#user.view_times}, - {view_tooltips, User#user.view_tooltips}, - {conversations, {array, lists:map( - fun({Racine, Reduit}) -> - {struct, [{root, Racine}, {minimized, Reduit}]} - end, - User#user.conversations - )}}, {ek_master, User#user.ek_master}, - {ostentatious_master, atom_to_list(User#user.ostentatious_master)} + {profile, {struct, + [ + {nick, Profile#profile.pseudo}, + {email, Profile#profile.email}, + {css, Profile#profile.css}, + {chat_order, atom_to_list(Profile#profile.chat_order)}, + {nick_format, atom_to_list(Profile#profile.nick_format)}, + {view_times, Profile#profile.view_times}, + {view_tooltips, Profile#profile.view_tooltips}, + {conversations, {array, lists:map( + fun({Racine, Reduit}) -> + {struct, [{root, Racine}, {minimized, Reduit}]} + end, + Profile#profile.conversations + )}}, + {ostentatious_master, atom_to_list(Profile#profile.ostentatious_master)} + ] + }} ] }. @@ -734,7 +740,7 @@ json_message(Mess, Repond_a, User) -> Est_proprietaire = User =/= inconnu andalso User#user.id =:= Mess#minichat.auteur_id, A_repondu_a_message = User =/= inconnu andalso euphorik_bd:a_repondu_a_message(User#user.id, Mess#minichat.id), Est_une_reponse_a_user = User =/= inconnu andalso euphorik_bd:est_une_reponse_a_user(User#user.id, Mess#minichat.id), - {ok, User_mess } = euphorik_bd:user_by_id(Mess#minichat.auteur_id), + {ok, #user{profile = Profile_mess} = User_mess } = euphorik_bd:user_by_id(Mess#minichat.auteur_id), {struct, [ {id, Mess#minichat.id}, {user_id, User_mess#user.id}, @@ -756,5 +762,5 @@ json_message(Mess, Repond_a, User) -> Repond_a )}}, {ek_master, User_mess#user.ek_master}, - {ostentatious_master, atom_to_list(User_mess#user.ostentatious_master)} + {ostentatious_master, atom_to_list(Profile_mess#profile.ostentatious_master)} ]}.