+ R = qlc:next_answers(C, N),
+ qlc:delete_cursor(C),
+ R
+ end,
+ lists:reverse(resultat_transaction(mnesia:transaction(F))).
+
+
+% Renvoie les messages manquants pour la page P en sachant qu'il y a N message
+% par page et que le dernier message que l'on possède est Id
+messages(Id, N, P) ->
+ lists:filter(fun (M) -> M#minichat.id > Id end, messages(N, P)).
+
+
+% Renvoie {ok, #minichat} (voir #minichat de euphorik_bd.hrl) à partir de son id.
+message_by_id(Id) ->
+ resultat_transaction(mnesia:transaction(
+ fun() ->
+ case mnesia:read({minichat, Id}) of
+ [] -> erreur;
+ [M] ->
+ {ok, M#minichat{contenu = contenu_message(M)}}
+ end
+ end
+ )).
+
+
+% Renvoie le contenu d'un message donnée, à utiliser à l'intérieur d'une transaction.
+% TODO : Cette fonction pourrait être remplacé par un "outer-join", est-ce possible avec qlc ?
+contenu_message(E) ->
+ case mnesia:read({troll, E#minichat.troll_id}) of
+ [] -> E#minichat.contenu;
+ [T] -> E#minichat.contenu ++ T#troll.content
+ end.
+
+
+% Renvoie une liste de message (voir #minichat de euphorik_bd.hrl) à partir d'une liste d'id (Ids).
+% TODO : optimisations ? serait-ce du O(n) ?
+% Bon de toutes façons on s'en fout c'est pas utilisé :)
+messages_by_ids(Ids) ->
+ resultat_transaction(mnesia:transaction(
+ fun() ->
+ e(qlc:keysort(
+ #minichat.id,
+ q([E || E <- mnesia:table(minichat), lists:any(fun(Id) -> Id =:= E#minichat.id end, Ids)]),
+ [{order, ascending}]
+ ),[{tmpdir, ?KEY_SORT_TEMP_DIR}])
+ end
+ )).
+
+
+% Est-ce qu'un message existe ? Renvoie un boolean.
+% TODO : ya pas plus simple ?
+message_existe(Id) ->
+ resultat_transaction(mnesia:transaction(fun() ->
+ length(e(q([E#minichat.id || E <- mnesia:table(minichat), E#minichat.id =:= Id]), [{tmpdir, ?KEY_SORT_TEMP_DIR}])) =:= 1
+ end)).
+
+
+% Renvoie les reponses (utilisé normalement uniquement pendant le debug).
+reponses() ->
+ F = fun() ->
+ e(q([E || E <- mnesia:table(reponse_minichat)]), [{tmpdir, ?KEY_SORT_TEMP_DIR}])
+ end,
+ resultat_transaction(mnesia:transaction(F)).
+
+
+% Renvoie les messages auquel M_id répond.
+repond_a(M_id) ->
+ resultat_transaction(mnesia:transaction(
+ fun() ->
+ e(q(
+ [M || E <- mnesia:table(reponse_minichat),
+ M <- mnesia:table(minichat),
+ E#reponse_minichat.repondant =:= M_id,
+ M#minichat.id =:= E#reponse_minichat.cible]), [{tmpdir, ?KEY_SORT_TEMP_DIR}])
+ end
+ )).
+
+
+% Est-ce que le message Id_mess est une réponse d'une message de Id_user ?
+est_une_reponse_a_user(Id_user, Id_mess) ->
+ case mnesia:transaction(
+ fun() ->
+ e(q([
+ M#minichat.auteur_id || M <- mnesia:table(minichat), R <- mnesia:table(reponse_minichat),
+ M#minichat.auteur_id =:= Id_user, M#minichat.id =:= R#reponse_minichat.cible, R#reponse_minichat.repondant =:= Id_mess
+ ]), [{unique_all, true}, {tmpdir, ?KEY_SORT_TEMP_DIR}])
+ end
+ ) of
+ {atomic, [_]} -> true;
+ _ -> false
+ end.
+
+
+% Est-ce que Id_user à répondu au message Id_mess
+a_repondu_a_message(Id_user, Id_mess) ->
+ case mnesia:transaction(
+ fun() ->
+ e(q([
+ M#minichat.auteur_id || M <- mnesia:table(minichat), R <- mnesia:table(reponse_minichat),
+ R#reponse_minichat.cible =:= Id_mess, R#reponse_minichat.repondant =:= M#minichat.id, M#minichat.auteur_id =:= Id_user
+ ]), [{unique_all, true}, {tmpdir, ?KEY_SORT_TEMP_DIR}])
+ end
+ ) of
+ {atomic, [_]} -> true;
+ _ -> false
+ end.
+
+ \r
+% Est-ce que Id_user possède Id_mess ?
+possede_message(Id_user, Id_mess) ->
+ case mnesia:transaction(
+ fun() ->
+ e(q([E#minichat.auteur_id || E <- mnesia:table(minichat), E#minichat.id =:= Id_mess]), [{tmpdir, ?KEY_SORT_TEMP_DIR}])
+ end
+ ) of
+ {atomic, [Id_user | []]} -> true;
+ _ -> false
+ end.
+
+
+% renvoie la liste des ip bannies
+% liste de {ip, temps_restant(en minutes), Users} ou Users est une liste de {pseudo, login}
+% TODO : déterminer la complexité de cette fonction. (Il n'y a pas d'index sur #user.last_ip)
+list_ban() ->
+ resultat_transaction(mnesia:transaction(
+ fun() ->
+ Now = now(),
+ e(qlc:keysort(1, q([
+ {
+ IP#ip_table.ip,
+ delta_date_minute(date_plus_minutes(IP#ip_table.ban, IP#ip_table.ban_duration), Now),
+ e(q([{U#user.pseudo, U#user.login} || U <- mnesia:table(user), U#user.last_ip =:= IP#ip_table.ip]), [{tmpdir, ?KEY_SORT_TEMP_DIR}])
+ } ||
+ IP <- mnesia:table(ip_table),
+ if IP#ip_table.ban =:= undefined -> false; true -> date_plus_minutes(IP#ip_table.ban, IP#ip_table.ban_duration) > Now end
+ ])), [{tmpdir, ?KEY_SORT_TEMP_DIR}])
+ end
+ )).
+
+
+% Bannie une ip pour un certain temps (en minute).
+ban(IP, Duration) ->
+ mnesia:transaction(
+ fun() ->
+ case mnesia:wread({ip_table, IP}) of
+ [IP_tuple] ->
+ mnesia:write(IP_tuple#ip_table{ban = now(), ban_duration = Duration});
+ _ ->
+ mnesia:write(#ip_table{ip = IP, ban = now(), ban_duration = Duration})
+ end
+ end
+ ).
+
+
+% Débanni une ip
+deban(IP) ->
+ ban(IP, 0).
+
+
+% Renvoie soit {true, Temps} où Temps est le temps en minutes pendant lequel le user est encore banni
+% ou false.
+est_banni(User_id) ->
+ resultat_transaction(mnesia:transaction(
+ fun() ->
+ case e(q([
+ {IP#ip_table.ban, IP#ip_table.ban_duration} ||
+ U <- mnesia:table(user),
+ U#user.id =:= User_id,
+ IP <- mnesia:table(ip_table),
+ IP#ip_table.ip =:= U#user.last_ip
+ ]), [{tmpdir, ?KEY_SORT_TEMP_DIR}]) of
+ [{Ban, Ban_duration}] ->
+ Echeance = date_plus_minutes(Ban, Ban_duration),
+ Now = now(),
+ if Echeance < Now -> % l'échéance est passée
+ false;
+ true ->
+ {true, delta_date_minute(Echeance, Now)}
+ end;
+ _ ->
+ false
+ end
+ end
+ )).
+
+
+% Ban est une date tel que retourner par now().
+% Ban_duration est un temps en minutes.
+% retourne une date.
+date_plus_minutes(Ban, Ban_duration) ->
+ Duration_sec = Ban_duration * 60,
+ {MegaSec, Sec, MicroSec} = Ban,
+ {MegaSec + if Sec + Duration_sec >= 1000000 -> 1; true -> 0 end,(Sec + Duration_sec) rem 1000000, MicroSec}.
+
+
+% Si deux enregistrements consequtifs de la même IP sont fait en moins d'une seconde alors
+% ip_table.nb_try_register est incrémenté de 1 sinon il est décrémenté de 1 (jusqu'a 0).
+% Si ip_table.nb_try_register vaut 5 alors l'ip ne peux plus s'enregistrer pour une heure.
+can_register(IP) ->
+ resultat_transaction(mnesia:transaction(
+ fun() ->
+ case e(q([I || I <- mnesia:table(ip_table), I#ip_table.ip =:= IP]), [{tmpdir, ?KEY_SORT_TEMP_DIR}]) of
+ [] ->
+ mnesia:write(#ip_table{ip = IP, date_last_try_register = now()}),
+ true;
+ [T] ->
+ Delta = delta_date_ms(T#ip_table.date_last_try_register, now()),
+ if T#ip_table.nb_try_register =:= ?NB_MAX_FLOOD_REGISTER, Delta < ?TEMPS_BAN_FLOOD_REGISTER ->
+ false;
+ true ->
+ mnesia:write(#ip_table{
+ ip = IP,
+ date_last_try_register = now(),
+ nb_try_register = T#ip_table.nb_try_register + if Delta < ?TEMPS_FLOOD_REGISTER -> 1; T#ip_table.nb_try_register > 0 -> -1; true -> 0 end
+ }),
+ true
+ end
+ end
+ end
+ )).
+
+
+% Renvoie tous les trolls
+trolls() ->
+ resultat_transaction(mnesia:transaction(
+ fun() ->
+ e(qlc:keysort(#troll.id, q([T || T <- mnesia:table(troll)])), [{tmpdir, ?KEY_SORT_TEMP_DIR}])
+ end
+ )).
+
+
+% Renvoie les trolls manquants posté après Last_id.
+trolls(Last_id) ->
+ resultat_transaction(mnesia:transaction(
+ fun() ->
+ e(qlc:keysort(#troll.id, q([T || T <- mnesia:table(troll), T#troll.id > Last_id, T#troll.date_post =:= undefined])), [{tmpdir, ?KEY_SORT_TEMP_DIR}])
+ end
+ )).
+
+
+ % Crée un nouveau troll.
+ % Renvoie l'id du nouveau troll
+ % ou max_troll_reached_per_user si le nombre de troll posté par l'utilisateur max a été atteind
+ % ou max_troll_reached si le nombre de troll posté max a été atteind
+ % ou user_unknown
+put_troll(User_id, Content) ->
+ resultat_transaction(mnesia:transaction(
+ fun() ->
+ % control le nombre de troll déjà posté
+ Nb_troll_poste_par_user = length(e(q(
+ [
+ E#troll.id || E <- mnesia:table(troll),
+ E#troll.id_user =:= User_id,
+ E#troll.date_post =:= undefined
+ ]
+ ), [{tmpdir, ?KEY_SORT_TEMP_DIR}])),
+ Nb_troll_poste_total = length(e(q(
+ [
+ E#troll.id || E <- mnesia:table(troll),
+ E#troll.date_post =:= undefined
+ ]
+ ), [{tmpdir, ?KEY_SORT_TEMP_DIR}])),
+ User = user_by_id(User_id),
+ case User of
+ {ok, _} ->
+ if Nb_troll_poste_par_user >= ?NB_MAX_TROLL_WAITING_BY_USER ->
+ max_troll_reached_per_user;
+ Nb_troll_poste_total >= ?NB_MAX_TROLL_WAITING ->
+ max_troll_reached;
+ true ->
+ Id = nouvel_id(minichat),
+ mnesia:write(#troll{id = Id, id_user = User_id, date_create = now(), content = Content}),
+ Id
+ end;
+ _ ->
+ user_unknown
+ end
+ end
+ )).