+
+
+% 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
+ ])) 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])) 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(2, q([T || T <- mnesia:table(troll)])))
+ end
+ )).
+
+
+% Renvoie les trolls manquants posté après Last_id.
+trolls(Last_id) ->
+ resultat_transaction(mnesia:transaction(
+ fun() ->
+ e(qlc:keysort(2, q([T || T <- mnesia:table(troll), T#troll.id > Last_id, T#troll.date_post =:= undefined])))
+ 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
+ ]
+ ))),
+ Nb_troll_poste_total = length(e(q(
+ [
+ E#troll.id || E <- mnesia:table(troll),
+ E#troll.date_post =:= undefined
+ ]
+ ))),
+ 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
+ )).
+
+
+% renvoie ok | erreur
+mod_troll(Troll_id, Content) ->
+ mnesia:transaction(
+ fun() ->
+ case mnesia:wread({troll, Troll_id}) of
+ [Troll = #troll{date_post = undefined}] ->
+ mnesia:write(Troll#troll{content = Content});
+ _ ->
+ mnesia:abort("mod_troll: Troll inconnu ou déjà posté")
+ end
+ end
+ ).
+
+
+del_troll(Troll_id) ->
+ mnesia:transaction(
+ fun() ->
+ case mnesia:wread({troll, Troll_id}) of
+ [#troll{date_post = undefined}] ->
+ mnesia:delete({troll, Troll_id});
+ _ ->
+ mnesia:abort("mod_troll: Troll inconnu ou déjà posté")
+ end
+ end
+ ).
+
+
+troll_by_id(Troll_id) ->
+ resultat_transaction(mnesia:transaction(
+ fun() ->
+ case e(q([T || T <- mnesia:table(troll), T#troll.id =:= Troll_id])) of
+ [T] -> {ok, T};
+ _ ->
+ erreur
+ end
+ end
+ )).
+
+
+% Renvoie le troll actuel qui se trouve sur la page principale.
+% Renvois aucun si pas de troll courant.
+current_troll() ->
+ resultat_transaction(mnesia:transaction(
+ fun() ->
+ % TODO : ya pas moyen de désigner le champs plutot qu'avec un nombre pour le tri ?
+ C = cursor(qlc:keysort(5, q([T || T <- mnesia:table(troll), T#troll.date_post =/= undefined]), [{order, descending}])),
+ R = case qlc:next_answers(C, 1) of
+ [T] -> T;
+ _ -> aucun
+ end,
+ qlc:delete_cursor(C),
+ R
+ end
+ )).
+
+
+% Elit un troll au hasard parmis les trolls en attente (leur date_post =:= undefined)
+% Un message est posté par 'Sys' et le troll elu est lié à ce message
+% met à jour sa date de post.
+% renvoie plus_de_trolls si il n'y a aucun troll en attente.
+elire_troll() ->
+ {A1,A2,A3} = now(),
+ random:seed(A1, A2, A3),
+ mnesia:transaction(
+ fun() ->
+ case e(q([T || T <- mnesia:table(troll), T#troll.date_post =:= undefined])) of
+ [] ->
+ plus_de_trolls;
+ Trolls ->
+ Troll = lists:nth(random:uniform(length(Trolls)), Trolls),
+ Troll2 = Troll#troll{date_post = now()},
+ mnesia:write(Troll2),
+ nouveau_message_sys("Troll de la semaine : ", Troll2#troll.id)
+ end
+ end
+ ).
+
+
+% Renvoie l'id du message associé au troll dont l'id est donnée.
+% Renvoie undefined si il n'y en a pas.
+message_id_associe(Troll_id) ->
+ resultat_transaction(mnesia:transaction(
+ fun() ->
+ case e(q([M#minichat.id || M <- mnesia:table(minichat), M#minichat.troll_id =:= Troll_id])) of
+ [Id] -> Id;
+ _ -> undefined
+ end
+ end
+ )).
+
+
+update_version(1) ->
+ mnesia:transform_table(
+ ip_table,
+ fun() -> null end,
+ record_info(fields, ip_table),
+ ip_table
+ ).
+
+
+% 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).
+
+% Retourne la différence entre deux timestamp (erlang:now) en minutes
+delta_date_minute(D1, D2) ->
+ trunc(delta_date_ms(D1, D2) / 1000 / 60).
+
+
+% Bizarre, cette fonction n'existe pas dans la stdlib.
+% Pas utilisé mais bon ca me fait de la peine de l'enlever.
+ceiling(X) ->
+ T = trunc(X),
+ case (X - T) of
+ Neg when Neg < 0 -> T;
+ Pos when Pos > 0 -> T + 1;
+ _ -> T
+ end.