+ )) of
+ [M] -> {ok, M};
+ _ -> erreur
+ end.
+
+
+% 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 = qlc:q([E || E <- qlc:keysort(2, mnesia:table(minichat), [{order, ascending}]), lists:any(fun(Id) -> Id =:= E#minichat.id end, Ids)]),
+ %io:format("~s~n", [qlc:info(Query)]),
+ qlc: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(qlc:e(qlc: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() ->
+ qlc:e(qlc: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() ->
+ qlc:e(qlc: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() ->
+ qlc:e(qlc: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() ->
+ qlc:e(qlc: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() ->
+ qlc:e(qlc:q([E#minichat.auteur_id || E <- mnesia:table(minichat), E#minichat.id =:= Id_mess]))
+ end
+ ) of
+ {atomic, [Id_user | []]} -> true;
+ _ -> false
+ end.
+
+
+% 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.\r
+can_register(IP) ->
+ resultat_transaction(mnesia:transaction(
+ fun() ->
+ case qlc:e(qlc:q([I || I <- mnesia:table(ip_table), I#ip_table.ip =:= IP])) 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 le résultat d'une transaction (en décomposant le tuple fournit)
+resultat_transaction({_, T}) ->
+ T.
+
+
+% Retourne la difference entre deux timestamp (erlang:now()) en miliseconde
+delta_date_ms(D1, D2) ->
+ 1000000000 * abs(element(1, D1) - element(1, D2)) + 1000 * abs(element(2, D1) - element(2, D2)) + trunc(abs(element(3, D1) - element(3, D2)) / 1000).
+
+
+% Bizarre, cette fonction n'existe pas dans la stdlib.
+ceiling(X) ->
+ T = trunc(X),
+ case (X - T) of
+ Neg when Neg < 0 -> T;
+ Pos when Pos > 0 -> T + 1;
+ _ -> T
+ end.