update_date_derniere_connexion/1,\r
update_ip/2,\r
update_pseudo_user/2,\r
- print_users/0,\r
- print_users/1,\r
- print_user/1,\r
user_by_cookie/1, \r
user_by_id/1, \r
user_by_login/1,\r
user_by_login_password/2,\r
user_by_mess/1,\r
- toggle_ek_master/1,\r
css_from_user_cookie/1,\r
is_ek_master_from_cookie/1,\r
\r
nouveau_user(Login, Password, Cookie, Profile) ->\r
F = fun() ->\r
Id = nouvel_id(user),\r
- User = #user{id = Id, cookie = Cookie, login = Login, password = Password, date_creation = now(), date_derniere_connexion = now(), profile = Profile#profile{pseudo = login}},\r
+ User = #user{id = Id, cookie = Cookie, login = Login, password = Password, date_creation = now(), date_derniere_connexion = now(), profile = Profile#profile{pseudo = Login}},\r
mnesia:write(User),\r
User\r
end,\r
end\r
end\r
).\r
- \r
- \r
-% Affiche N user trié par leur date de dernière connexion.\r
-% Opt est une liste d'option d'affichage :\r
-% * ekmaster : n'affiche que les admins\r
-print_users(N, Opt) ->\r
- AfficheQueLesEkMaster = lists:any(fun(O) -> O =:= ekmaster end, Opt),\r
- resultat_transaction(mnesia:transaction(fun() ->\r
- C = cursor(\r
- qlc:keysort(\r
- #user.date_derniere_connexion, \r
- if AfficheQueLesEkMaster ->\r
- q([E || E <- mnesia:table(user), E#user.ek_master =:= true]);\r
- true ->\r
- q([E || E <- mnesia:table(user)])\r
- end,\r
- [{order, descending}]\r
- ),\r
- [{tmpdir, ?KEY_SORT_TEMP_DIR}]\r
- ),\r
- Users = qlc:next_answers(C, N),\r
- lists:foreach(\r
- fun(U) ->\r
- print_user(U)\r
- end,\r
- Users\r
- ),\r
- qlc:delete_cursor(C)\r
- end)).\r
- \r
- \r
-% Affiche tous les users.\r
-print_users(Opt) ->\r
- print_users(all_remaining, Opt).\r
-\r
-% Affiche tous les users.\r
-print_users() ->\r
- print_users(all_remaining, []).\r
- \r
-print_user(User) when is_record(User, user) ->\r
- #user{id = Id, profile = #profile{pseudo = Pseudo}, login = Login, ek_master = Ek_master, date_derniere_connexion = Date, last_ip = IP} = User,\r
- {{Annee, Mois, Jour}, {Heure, Min, _}} = calendar:now_to_local_time(Date),\r
- io:format(\r
- % id pseudo (login) IP Jour Mois Année Heure Minute\r
- "~4w : ~10.10..s(~10.10..s) ~s ~2w.~2.2.0w.~w - ~2wh~2.2.0w~n",\r
- [ \r
- Id,\r
- if Ek_master -> "*"; true -> "" end ++ Pseudo,\r
- Login,\r
- euphorik_common:serialize_ip(IP),\r
- Jour, Mois, Annee, Heure, Min\r
- ]\r
- );\r
-% Affichage d'un user en fonction de son login\r
-print_user(Login) when is_list(Login) ->\r
- case user_by_login(Login) of\r
- {ok, User} ->\r
- print_user(User);\r
- _ ->\r
- {erreur, "Login pas trouvé : " ++ Login}\r
- end;\r
-% Affichage d'un user en fonction de son id\r
-print_user(Id) when is_integer(Id) -> \r
- case user_by_id(Id) of \r
- {ok, User} ->\r
- print_user(User);\r
- _ ->\r
- {erreur, "Id pas trouvé : " ++ integer_to_list(Id)}\r
- end.\r
- \r
+ \r
\r
% Est-ce qu'un utilisateur existe en fonction de son cookie ?\r
% Renvoie {ok, User} ou erreur\r
user_by_id(ID) ->\r
resultat_transaction(mnesia:transaction(\r
fun() ->\r
- case e(q([E || E <- mnesia:table(user), E#user.id =:= ID]), [{tmpdir, ?KEY_SORT_TEMP_DIR}]) of\r
+% case e(q([E || E <- mnesia:table(user), E#user.id =:= ID]), [{tmpdir, ?KEY_SORT_TEMP_DIR}]) of\r
+% [User] -> {ok, User};\r
+% _ -> erreur\r
+% end\r
+ case mnesia:read({user, ID}) of\r
[User] -> {ok, User};\r
_ -> erreur\r
end\r
end\r
)).\r
\r
- \r
-toggle_ek_master(User_id) ->\r
- resultat_transaction(mnesia:transaction(\r
- fun() ->\r
- Users = e(q([E || E <- mnesia:table(user), E#user.id =:= User_id]), [{tmpdir, ?KEY_SORT_TEMP_DIR}]),\r
- case Users of\r
- [User] ->\r
- mnesia:write(User#user{ek_master = not User#user.ek_master});\r
- _ -> erreur\r
- end\r
- end\r
- )).\r
- \r
\r
% Renvoie une chaine représentant le cookie ou undefined si pas trouvé.\r
css_from_user_cookie(Cookie) ->\r
resultat_transaction(mnesia:transaction(\r
fun() ->\r
case mnesia:read({minichat, Id}) of\r
- [] -> erreur;\r
- [M] ->\r
- {ok, M#minichat{contenu = contenu_message(M)}}\r
+ [M] -> {ok, M#minichat{contenu = contenu_message(M)}};\r
+ _ -> erreur\r
end\r
end\r
)).\r
\r
\r
-% Renvoie le contenu d'un message donnée, à utiliser à l'intérieur d'une transaction.\r
+% Renvoie le contenu d'un message donnée en fonction du troll associé, à utiliser à l'intérieur d'une transaction.\r
% TODO : Cette fonction pourrait être remplacé par un "outer-join", est-ce possible avec qlc ?\r
contenu_message(E) ->\r
case mnesia:read({troll, E#minichat.troll_id}) of\r
)).\r
\r
\r
-% Renvoie les parents d'un message M (les messages auquels répond M)\r
+% Renvoie les id des parents d'un message M (les messages auquels répond M)\r
% ordrés du plus petit au plus grand..\r
+% On évite d'utiliser qlc pour des raisons de performance\r
% @spec parents_id(integer()) -> [integer()]\r
-parents_id(M) ->\r
+parents_id(M_id) ->\r
resultat_transaction(mnesia:transaction(fun() ->\r
- e(\r
- qlc:sort(\r
- q([E#reponse_minichat.cible || E <- mnesia:table(reponse_minichat), E#reponse_minichat.repondant =:= M]),\r
- [{order, ascending}]\r
- ),\r
- [{tmpdir, ?KEY_SORT_TEMP_DIR}]\r
- )\r
+ case mnesia:read({reponse_minichat, M_id}) of\r
+ Parents when is_list(Parents) ->\r
+ lists:sort(lists:map(\r
+ fun(#reponse_minichat{cible = Cible}) -> Cible end,\r
+ Parents\r
+ ));\r
+ _ -> [] \r
+ end\r
end)).\r
\r
\r
\r
\r
% Est-ce que le message Id_mess est une réponse d'une message de Id_user ?\r
+% On evite d'utiliser qlc (ce qui était fait avant) pour des raisons de performance.\r
est_une_reponse_a_user(Id_user, Id_mess) ->\r
- case mnesia:transaction(\r
- fun() ->\r
- e(q([\r
- M#minichat.auteur_id || M <- mnesia:table(minichat), R <- mnesia:table(reponse_minichat),\r
- M#minichat.auteur_id =:= Id_user, M#minichat.id =:= R#reponse_minichat.cible, R#reponse_minichat.repondant =:= Id_mess\r
- ]), [{unique_all, true}, {tmpdir, ?KEY_SORT_TEMP_DIR}])\r
- end\r
- ) of\r
- {atomic, [_]} -> true;\r
- _ -> false\r
- end.\r
+ resultat_transaction(mnesia:transaction(\r
+ fun() ->\r
+ case mnesia:read({reponse_minichat, Id_mess}) of\r
+ [] -> false;\r
+ Cibles ->\r
+ lists:any(\r
+ fun(#reponse_minichat{cible = Cible}) ->\r
+ case mnesia:read({minichat, Cible}) of\r
+ [#minichat{auteur_id = Id_user}] -> true;\r
+ _ -> false\r
+ end\r
+ end,\r
+ Cibles\r
+ )\r
+ end\r
+ end\r
+ )).\r
\r
\r
% Est-ce que Id_user à répondu au message Id_mess\r
+% On evite d'utiliser qlc (ce qui était fait avant) pour des raisons de performance.\r
a_repondu_a_message(Id_user, Id_mess) ->\r
- case mnesia:transaction(\r
- fun() ->\r
- e(q([\r
- M#minichat.auteur_id || M <- mnesia:table(minichat), R <- mnesia:table(reponse_minichat),\r
- R#reponse_minichat.cible =:= Id_mess, R#reponse_minichat.repondant =:= M#minichat.id, M#minichat.auteur_id =:= Id_user\r
- ]), [{unique_all, true}, {tmpdir, ?KEY_SORT_TEMP_DIR}])\r
- end\r
- ) of\r
- {atomic, [_]} -> true;\r
- _ -> false\r
- end.\r
+ resultat_transaction(mnesia:transaction(\r
+ fun() ->\r
+ case mnesia:match_object({reponse_minichat, '_', Id_mess}) of\r
+ [] -> false;\r
+ Reponses ->\r
+ lists:any(\r
+ fun(#reponse_minichat{repondant = Reponse}) ->\r
+ case mnesia:read({minichat, Reponse}) of\r
+ [#minichat{auteur_id = Id_user}] -> true;\r
+ _ -> false\r
+ end\r
+ end,\r
+ Reponses\r
+ )\r
+ end\r
+ end\r
+ )).\r
\r
\r
% Est-ce que Id_user possède Id_mess ?\r
projects / euphorik.git / blobdiff