+ 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)).
+
+% Définit Id_repondant comme étant la réponse à Ids. Ids est une liste d'id.
+inserer_reponses(Id_repondant, [Id_mess | Reste]) ->
+ mnesia:write(#reponse_minichat{repondant = Id_repondant, cible = Id_mess}),
+ inserer_reponses(Id_repondant, Reste);
+inserer_reponses(_, []) ->
+ ok.
+
+
+% Permet de créer un message système.
+% Renvoie l'id du message système
+nouveau_message_sys(Mess) ->
+ nouveau_message_sys(Mess, undefined).
+
+
+% Création d'un message système lié à un troll.
+nouveau_message_sys(Mess, Troll_id) ->
+ {ok, Root} = user_by_id(0),
+ resultat_transaction(mnesia:transaction(
+ fun() ->
+ Id = nouvel_id(minichat),
+ mnesia:write(#minichat{id=Id, auteur_id=0, date=now(), pseudo=Root#user.pseudo, contenu=Mess, troll_id=Troll_id}),
+ Id
+ end
+ )).
+
+
+% Renvoie N messages se trouvant sur la première page
+messages(N) ->
+ messages(N, 1).
+
+
+% Renvoie N messages se trouvant sur la page P
+messages(N, P) ->
+ F = fun() ->
+ C = cursor(q([
+ E#minichat{contenu = contenu_message(E)} ||
+ E <- qlc:keysort(2, mnesia:table(minichat), [{order, descending}])
+ ])),
+ if P > 1 -> qlc:next_answers(C, N * (P - 1));
+ true -> ok
+ end,
+ R = qlc:next_answers(C, N),
+ qlc:delete_cursor(C),
+ lists:reverse(R)
+ end,
+ 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) ->
+ case resultat_transaction(mnesia:transaction(
+ fun() ->
+ e(q([E#minichat{contenu = contenu_message(E)} || E <- qlc:keysort(2, mnesia:table(minichat), [{order, ascending}]), Id =:= E#minichat.id]))
+ end
+ )) of
+ [M] -> {ok, M};
+ _ -> erreur
+ 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) ->
+ lists:flatten(E#minichat.contenu ++ e(q([T#troll.content || T <- mnesia:table(troll), T#troll.id =:= E#minichat.troll_id]))).
+
+
+% Renvoie une liste de message (voir #minichat de euphorik_bd.hrl) à partir d'une liste d'id (Ids).
+messages_by_ids(Ids) ->
+ resultat_transaction(mnesia:transaction(
+ fun() ->
+ % TODO : optimisations ? serait-ce du O(n) ?
+ Query = q([E || E <- qlc:keysort(2, mnesia:table(minichat), [{order, ascending}]), lists:any(fun(Id) -> Id =:= E#minichat.id end, Ids)]),
+ e(Query)
+ 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]))) =:= 1
+ end)).
+
+
+% Renvoie les reponses (utilisé normalement uniquement pendant le debug).
+reponses() ->
+ F = fun() ->
+ e(q([E || E <- mnesia:table(reponse_minichat)]))
+ 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]))
+ 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}])
+ 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}])
+ 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]))
+ 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(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]))
+ } ||
+ IP <- qlc:keysort(2, 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
+ ]))
+ 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