update_date_derniere_connexion/1,
update_ip/2,
update_pseudo_user/2,
- users/0,
+ print_users/0,
+ print_users/1,
+ print_user/1,
user_by_cookie/1,
user_by_id/1,
user_by_login/1,
% utiles :
resultat_transaction/1\r
]).
-
-import(qlc, [e/1, e/2, q/1, cursor/1]).\r
-\r
-include("../include/euphorik_bd.hrl").
-include("../include/euphorik_defines.hrl").\r
-include_lib("stdlib/include/qlc.hrl").\r
end
).
-
-% Renvoie tous les users.
-users() ->
+
+% Affiche N user trié par leur date de dernière connexion.
+% Attention : pas d'index sur ce champs (la date)
+print_users(N) ->
resultat_transaction(mnesia:transaction(fun() ->
- e(q([E || E <- mnesia:table(user)]))
- end)).
+ C = cursor(q([E || E <- qlc:keysort(9, mnesia:table(user), [{order, descending}])])),
+ Users = qlc:next_answers(C, N),
+ lists:foreach(
+ fun(U) ->
+ print_user(U)
+ end,
+ Users
+ ),
+ qlc:delete_cursor(C)
+ end)).
+
+
+% Affiche tous les users.
+print_users() ->
+ print_users(all_remaining).
+
+
+print_user(User) when is_record(User, user) ->
+ #user{id = Id, pseudo = Pseudo, login = Login, ek_master = Ek_master, date_derniere_connexion = Date} = User,
+ {{Annee, Mois, Jour}, {Heure, Min, _}} = calendar:now_to_local_time(Date),
+ io:format(
+ "~4w : ~10.10..s~10.10..s ~2w.~2.2.0w.~w - ~2wh~2.2.0w~n",
+ [
+ Id,
+ if Ek_master -> "*"; true -> "" end ++ Pseudo,
+ "(" ++ Login ++ ")",
+ Jour, Mois, Annee, Heure, Min
+ ]
+ );
+% Affichage d'un user en fonction de son login
+print_user(Login) when is_list(Login) ->
+ case user_by_login(Login) of
+ {ok, User} ->
+ print_user(User);
+ _ ->
+ {erreur, "Login pas trouvé : " ++ Login}
+ end;
+% Affichage d'un user en fonction de son id
+print_user(Id) when is_integer(Id) ->
+ case user_by_id(Id) of
+ {ok, User} ->
+ print_user(User);
+ _ ->
+ {erreur, "Id pas trouvé : " ++ integer_to_list(Id)}
+ end.
% Est-ce qu'un utilisateur existe en fonction de son cookie ?
\r
% Ajoute un message. Repond_A est une liste d'id auquel le message répond
-% retourne soit l'id du message soit erreur.
+% retourne soit l'id du message soit {erreur, <raison>}.
nouveau_message(Mess, Auteur_id, Repond_A) ->
% regarde si les id 'Repond_A' existent
F = fun() ->
% est-ce que l'auteur existe ?
Auteur = case e(q([E || E <- mnesia:table(user), E#user.id =:= Auteur_id])) of
[A] -> A;
- _ -> throw("L'auteur du message est introuvable")
+ _ -> {erreur, "L'auteur du message est introuvable"}
end,
- if Nb_id_trouve =/= length(Repond_A) -> throw("Un ou plusieurs messages introuvable");
- true -> ok
- end,
- % compare les dernière
- Delta = delta_date_ms(Auteur#user.date_derniere_connexion, now()),
- Nouvel_indice_flood = Auteur#user.indice_flood + if Delta =< ?DUREE_SPAM -> 2; true -> -1 end,
- Auteur_maj = Auteur#user{
- indice_flood = if Nouvel_indice_flood > ?INDICE_SPAM_MAX -> ?INDICE_SPAM_MAX; Nouvel_indice_flood < 0 -> 0; true -> Nouvel_indice_flood end,
- date_derniere_connexion = now()
- },
- % est-ce que l'auteur à trop floodé ?
- if Auteur#user.indice_flood =/= ?INDICE_SPAM_MAX, Auteur_maj#user.indice_flood =:= ?INDICE_SPAM_MAX, Delta =< ?DUREE_BLOCAGE_SPAM ->
- mnesia:write(Auteur#user{indice_flood = Auteur_maj#user.indice_flood}),
- nouveau_message_sys(Auteur#user.pseudo ++ if Auteur#user.login =/= [] -> " (" ++ Auteur#user.login ++ ")"; true -> "" end ++ " est bloqué pour " ++ integer_to_list(trunc(?DUREE_BLOCAGE_SPAM / 1000)) ++ " secondes pour cause de flood.");
- Auteur#user.indice_flood =:= ?INDICE_SPAM_MAX, Delta =< ?DUREE_BLOCAGE_SPAM ->
- erreur;
- true ->
- mnesia:write(Auteur_maj),
- Id = nouvel_id(minichat),
- inserer_reponses(Id, Repond_A),
- mnesia:write(#minichat{id=Id, auteur_id=Auteur#user.id, date=now(), pseudo=Auteur#user.pseudo, contenu=Mess}),
- Id
+ if Nb_id_trouve =/= length(Repond_A) ->
+ {erreur, "Un ou plusieurs messages introuvable"};
+ true ->
+ % comparaison entre la date du dernier poste et maintenant (gestion du flood)
+ Delta = delta_date_ms(Auteur#user.date_derniere_connexion, now()),
+ Nouvel_indice_flood = Auteur#user.indice_flood + if Delta =< ?DUREE_SPAM -> 2; true -> -1 end,
+ Auteur_maj = Auteur#user{
+ indice_flood = if Nouvel_indice_flood > ?INDICE_SPAM_MAX -> ?INDICE_SPAM_MAX; Nouvel_indice_flood < 0 -> 0; true -> Nouvel_indice_flood end,
+ date_derniere_connexion = now()
+ },
+ % est-ce que l'auteur à trop floodé ?
+ if Auteur#user.indice_flood =/= ?INDICE_SPAM_MAX, Auteur_maj#user.indice_flood =:= ?INDICE_SPAM_MAX, Delta =< ?DUREE_BLOCAGE_SPAM ->
+ mnesia:write(Auteur#user{indice_flood = Auteur_maj#user.indice_flood}),
+ nouveau_message_sys(Auteur#user.pseudo ++ if Auteur#user.login =/= [] -> " (" ++ Auteur#user.login ++ ")"; true -> "" end ++ " est bloqué pour " ++ integer_to_list(trunc(?DUREE_BLOCAGE_SPAM / 1000)) ++ " secondes pour cause de flood.");
+ Auteur#user.indice_flood =:= ?INDICE_SPAM_MAX, Delta =< ?DUREE_BLOCAGE_SPAM ->
+ {erreur, "Bloqué pour cause de flood"};
+ true ->
+ mnesia:write(Auteur_maj),
+ Id = nouvel_id(minichat),
+ inserer_reponses(Id, Repond_A),
+ mnesia:write(#minichat{id=Id, auteur_id=Auteur#user.id, date=now(), pseudo=Auteur#user.pseudo, contenu=Mess}),
+ Id
+ end
end
end,
resultat_transaction(mnesia:transaction(F)).
)).
-% Renvoie tous les trolls.
+% Renvoie tous les trolls
trolls() ->
resultat_transaction(mnesia:transaction(
fun() ->
{add, [Troll]};
{mnesia_table_event, {delete, troll, {troll, Id}, _, _}} ->
{del, Id};
+ {tcp_closed, _} ->
+ exit(normal);
_ ->
attend_evenement_troll()
+ % 60 minutes de timeout (on ne sais jamais)
+ % Après 60 minutes de connexion, le client doit donc reétablir une connexion
after 1000 * 60 * 60 ->
timeout
end.
projects / euphorik.git / blobdiff