X-Git-Url: http://git.euphorik.ch/?p=euphorik.git;a=blobdiff_plain;f=modules%2Ferl%2Feuphorik_bd.erl;h=0539910361d55353db9ccd7f06a1a24127c65b66;hp=a0ffc3ae1e0630a59b33d90b83db4117f8f20c39;hb=5b696161ae91e007fc2e9bd455a14f4363772131;hpb=2424ba818818a6bd0b547fa540742f9b54db990b

diff --git a/modules/erl/euphorik_bd.erl b/modules/erl/euphorik_bd.erl
index a0ffc3a..0539910 100755
--- a/modules/erl/euphorik_bd.erl
+++ b/modules/erl/euphorik_bd.erl
@@ -23,17 +23,11 @@
 
 
 -module(euphorik_bd).
--export([
-   % gestion :
-   create/0,
-   connect/0,
-   connect/1,
-   reset/0,
-   
+-export([   
    % users :
    nouveau_user/2,
    nouveau_user/3,
-   set_profile/10,
+   set_profile/12,
    update_date_derniere_connexion/1,
    update_ip/2,
    update_pseudo_user/2,
@@ -47,6 +41,7 @@
    user_by_mess/1,
    toggle_ek_master/1,
    css_from_user_cookie/1,
+   is_ek_master_from_cookie/1,
    
    % messages :e
    nouveau_message/3,
@@ -61,6 +56,8 @@
    reponses/0,
    parents/1,
    enfants/1,
+   parents_id/1,
+   enfants_id/1,
    est_une_reponse_a_user/2,
    a_repondu_a_message/2,
    possede_message/2,
@@ -92,81 +89,6 @@
 -include_lib("stdlib/include/qlc.hrl").
 
 
-% Instructions pour créer une nouvelle base : 
-% $erl -sname yaws -mnesia dir '"/projets/euphorik/BD"'
-% voir doc/installation.txt
-% >l(euphorik_bd).
-% >euphorik_bd:create().
-create() ->
-   mnesia:stop(),
-   mnesia:delete_schema([node()]),
-   mnesia:create_schema([node()]), % nécessaire pour les tables sur disc
-   mnesia:start(),
-   create_tables(),
-   reset().
-   
-create_tables() ->
-   mnesia:create_table(counter, [
-      {attributes, record_info(fields, counter)},
-      {disc_copies, [node()]}
-   ]),
-   mnesia:create_table(proprietes, [
-      {attributes, record_info(fields, proprietes)},
-      {disc_copies, [node()]}
-   ]),
-   mnesia:create_table(minichat, [
-      {attributes, record_info(fields, minichat)},
-      {index, [auteur_id, troll_id]},
-      {disc_copies, [node()]}
-   ]),
-   mnesia:create_table(reponse_minichat, [
-      {type, bag},
-      {attributes, record_info(fields, reponse_minichat)},
-      {index, [cible]},
-      {disc_copies, [node()]}
-   ]),
-   mnesia:create_table(user, [
-      {attributes, record_info(fields, user)},
-      {index, [cookie, login]},
-      {disc_copies, [node()]}
-   ]),
-   mnesia:create_table(ip_table, [
-      {attributes, record_info(fields, ip_table)},
-      {disc_copies, [node()]}
-   ]),
-   mnesia:create_table(troll, [
-      {attributes, record_info(fields, troll)},
-      {index, [date_post]},
-      {disc_copies, [node()]}
-   ]).
-   
-   
-% Connexion à la base de données de yaws sur overnux
-connect() ->
-   connect(yaws@flynux).
-connect(Node) ->
-   mnesia:start(),
-   mnesia:change_config(extra_db_nodes, [Node]).
-
-
-% Efface tous les users, minichat_reponse et minichat.
-reset() ->
-   mnesia:clear_table(counter),
-   mnesia:clear_table(proprietes),
-   mnesia:clear_table(user),
-   mnesia:clear_table(reponse_minichat),
-   mnesia:clear_table(minichat),
-   mnesia:clear_table(troll),
-   mnesia:clear_table(ip_table),
-   % crée l'utilisateur root
-   mnesia:transaction(fun() ->
-      mnesia:write(#proprietes{nom = version, valeur = ?VERSION_BD}),
-      User = #user{id = 0, pseudo = "Sys", login = "Sys", date_creation = now(), date_derniere_connexion = now(), ek_master = true},
-      mnesia:write(User),
-      User
-   end).
-
-
 % Ajoute un nouveau user et le renvoie
 nouveau_user(Pseudo, Cookie) ->
    F = fun() ->
@@ -190,8 +112,11 @@ nouveau_user(Login, Password, Cookie) ->
 
 
 % Mise à par Cookie les autres peuvent être undefined ce qui veut dire qu'ils ne seront pas modifié.
-set_profile(Cookie, Login, Password, Pseudo, Email, Css, Nick_format, View_times, View_tooltips, Conversations) ->
-   if Nick_format =:= nick; Nick_format =:= login; Nick_format =:= nick_login ->
+% Conversation est de type [{int(), bool()}] où l'entier est la racine, le booléen indique si la conversation est réduite ou non
+% Ostentatious_master peut valoir invisible, light ou heavy
+set_profile(Cookie, Login, Password, Pseudo, Email, Css, Chat_order, Nick_format, View_times, View_tooltips, Conversations, Ostentatious_master) ->
+   if Nick_format =:= nick; Nick_format =:= login; Nick_format =:= nick_login,
+      Ostentatious_master =:= invisible; Ostentatious_master =:= light; Ostentatious_master =:= heavy ->
          resultat_transaction(mnesia:transaction(
             fun() ->
                case user_by_cookie(Cookie) of
@@ -208,10 +133,12 @@ set_profile(Cookie, Login, Password, Pseudo, Email, Css, Nick_format, View_times
                               pseudo = if is_list(Pseudo) -> Pseudo; true -> User#user.pseudo end,
                               email = if is_list(Email) -> Email; true -> User#user.email end,
                               css = if is_list(Css) -> Css; true -> User#user.css end,
+                              chat_order = Chat_order,
                               nick_format = Nick_format,
                               view_times = View_times,
                               view_tooltips = View_tooltips,
-                              conversations = if is_list(Conversations) -> Conversations; true -> User#user.conversations end
+                              conversations = if is_list(Conversations) -> Conversations; true -> User#user.conversations end,
+                              ostentatious_master = Ostentatious_master
                            },
                            mnesia:write(User_modifie),
                            ok
@@ -394,6 +321,13 @@ css_from_user_cookie(Cookie) ->
          undefined
    end.
    
+   
+is_ek_master_from_cookie(Cookie) ->
+   case user_by_cookie(Cookie) of
+      {ok, #user{ek_master = true}} -> true;
+      _ -> false
+   end.
+   
 
 user_by_login_password(Login, Password) ->
    resultat_transaction(mnesia:transaction(
@@ -423,50 +357,62 @@ user_by_mess(Id) ->
 nouveau_message(Mess, Auteur_id, Repond_A_ids) ->
    % regarde si les id 'Repond_A' existent
    F = fun() ->   
-      Repond_A = e(
+      Repond_a = e(
          q([M || M <- mnesia:table(minichat), lists:member(M#minichat.id, Repond_A_ids)]),
          [{tmpdir, ?KEY_SORT_TEMP_DIR}]
-      ),
-      Racine_id = case Repond_A of
+      ), 
+      Racine_id = case Repond_a of
          [] -> undefined;
-         [M | _ ] -> M#minichat.racine_id
-      end,
-      % est-ce que l'auteur existe ?
-      case e(q([E || E <- mnesia:table(user), E#user.id =:= Auteur_id]), [{tmpdir, ?KEY_SORT_TEMP_DIR}]) of
-         [Auteur] ->
-            if length(Repond_A) =/= length(Repond_A_ids) ->
-                  {erreur, "Un ou plusieurs messages introuvable"};
+         [M | _ ] -> 
+            Une_racine = M#minichat.racine_id,
+            % vérification que tout les messages de Repond_a possède la même racine (même conversation)
+            case lists:all(fun(R) -> R#minichat.racine_id =:= Une_racine end, Repond_a) of
                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_ids),
-                     mnesia:write(#minichat{
-                        id = Id,
-                        auteur_id = Auteur#user.id,
-                        date = now(),
-                        pseudo = Auteur#user.pseudo,
-                        contenu = Mess,
-                        racine_id = if Racine_id =:= undefined -> Id; true -> Racine_id end
-                     }),
-                     Id
-                  end
-            end;
+                  Une_racine;
+               _ ->
+                  {erreur, "Les messages ne font pas partie de la même conversation"}
+            end
+      end,      
+      case Racine_id of
+         {erreur, E} -> {erreur, E};
          _ ->
-            {erreur, "L'auteur du message est introuvable"}
+            % est-ce que l'auteur existe ?
+            case e(q([E || E <- mnesia:table(user), E#user.id =:= Auteur_id]), [{tmpdir, ?KEY_SORT_TEMP_DIR}]) of
+               [Auteur] ->
+                  if length(Repond_a) =/= length(Repond_A_ids) ->
+                        {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_ids),
+                           mnesia:write(#minichat{
+                              id = Id,
+                              auteur_id = Auteur#user.id,
+                              date = now(),
+                              pseudo = Auteur#user.pseudo,
+                              contenu = Mess,
+                              racine_id = if Racine_id =:= undefined -> Id; true -> Racine_id end
+                           }),
+                           Id
+                        end
+                  end;
+               _ ->
+                  {erreur, "L'auteur du message est introuvable"}
+            end
       end
    end,
    resultat_transaction(mnesia:transaction(F)).
@@ -607,6 +553,36 @@ enfants(M_id) ->
       end
    )).
    
+   
+% Renvoie les parents d'un message M (les messages auquels répond M)
+% ordrés du plus petit au plus grand..
+% @spec parents_id(integer()) -> [integer()]
+parents_id(M) ->
+   resultat_transaction(mnesia:transaction(fun() ->
+      e(
+         qlc:sort(
+            q([E#reponse_minichat.cible || E <- mnesia:table(reponse_minichat), E#reponse_minichat.repondant =:= M]),
+            [{order, ascending}]
+         ),
+         [{tmpdir, ?KEY_SORT_TEMP_DIR}]
+      )
+   end)).
+   
+   
+% Renvoie les id des enfants d'un message M (les messages qui répondent à M)
+% ordrés du plus petit au plus grand.
+% @spec enfants_id(integer()) -> [integer()]
+enfants_id(M) ->
+   resultat_transaction(mnesia:transaction(fun() ->
+      e(
+         qlc:sort(
+            q([E#reponse_minichat.repondant || E <- mnesia:table(reponse_minichat), E#reponse_minichat.cible =:= M]),
+            [{order, ascending}]
+         ),
+         [{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) ->