MOD maj du README principal

[euphorik.git] / modules / erl / euphorik_minichat_conversation.erl

diff --git a/modules/erl/euphorik_minichat_conversation.erl b/modules/erl/euphorik_minichat_conversation.erl
index 2db3586..e46ca91 100755 (executable)
--- a/modules/erl/euphorik_minichat_conversation.erl
+++ b/modules/erl/euphorik_minichat_conversation.erl
@@ -30,11 +30,12 @@
 -export([\r
    conversations/4\r
 ]).
--include("euphorik_bd.hrl").
+-include("../include/euphorik_bd.hrl").
+-include("../include/euphorik_defines.hrl").
 -include_lib("stdlib/include/qlc.hrl").
 -import(lists, [reverse/1, any/2, map/2, sublist/3, filter/2]).
 -import(euphorik_bd, [resultat_transaction/1]).
--import(qlc, [e/1, q/1, keysort/3]).
+-import(qlc, [e/2, q/1]).
 -import(mnesia, [table/1, transaction/1]).
   
    
@@ -43,6 +44,10 @@
 % Message est le message de type #minichat et Parents une liste d'Id.
 % Plus est un bool. Si Plus vaut true alors il y a encore des messages.
 % Si il n'y a pas de nouveaux message alors vide est renvoyé.
+% Chaque racine est un tuple {R, P,  D}
+% N : le nombre de message
+% D : le dernier message connu, 0 si aucun
+% P : la page souhaité, la premier est la 1
 % @spec conversations([{integer(), integer(), integer()}], integer(), integer(), integer()) -> [Conversation()]
 conversations(Racines, N, D, P) ->
       Conversations = conversations_detailees(Racines, N, D, P),
@@ -79,7 +84,7 @@ mise_en_forme_conversation(Messages) ->
       fun() ->
          lists:foldr(
             fun(Id, Acc) ->
-               case euphorik_bd:message_by_id_sans_transaction(Id) of
+               case euphorik_bd:message_by_id(Id) of
                   {ok, Message} ->
                      [{Message, parents(Id)} | Acc];
                   _ ->
@@ -100,7 +105,10 @@ mise_en_forme_conversation(Messages) ->
 conversations_detailees(Racines, N, D, P) ->   
    Conversations = map(fun({Racine, P_conv, Dernier}) -> conversation(Racine, N, Dernier, P_conv) end, Racines),
    Conversation_principale = resultat_transaction(transaction(fun() ->
-      Curseur = qlc:cursor(q([E#minichat.id || E <- qlc:sort(table(minichat), [{order, descending}])])),
+      Curseur = qlc:cursor(
+         qlc:sort(q([E#minichat.id || E <- table(minichat)]), [{order, descending}]),
+         [{tmpdir, ?KEY_SORT_TEMP_DIR}]
+      ),
       {CP, Plus} = conversation_principale(Curseur, Conversations, N, P),
       qlc:delete_cursor(Curseur),
       {[M || M <- CP, M > D], Plus} % filtre en fonction de D
@@ -205,7 +213,8 @@ enfants(M) ->
          qlc:sort(
             q([E#reponse_minichat.repondant || E <- table(reponse_minichat), E#reponse_minichat.cible =:= M]),
             [{order, ascending}]
-         )
+         ),
+         [{tmpdir, ?KEY_SORT_TEMP_DIR}]
       )
    end)).
    
@@ -219,7 +228,8 @@ parents(M) ->
          qlc:sort(
             q([E#reponse_minichat.cible || E <- table(reponse_minichat), E#reponse_minichat.repondant =:= M]),
             [{order, ascending}]
-         )
+         ),
+         [{tmpdir, ?KEY_SORT_TEMP_DIR}]
       )
    end)).