X-Git-Url: http://git.euphorik.ch/?p=euphorik.git;a=blobdiff_plain;f=modules%2Ferl%2Feuphorik_minichat_conversation.erl;h=e46ca913d0dbe9ced0506e57b243ad0dedbf9672;hp=06fad7fd2efd5bfee2f3858b77b7c9b30f4139bd;hb=ff7d9f985ef60d59b652a8950dbbee204b276c87;hpb=fdbd960f3fda4a5b1e71dc410ad162c78390f409 diff --git a/modules/erl/euphorik_minichat_conversation.erl b/modules/erl/euphorik_minichat_conversation.erl index 06fad7f..e46ca91 100755 --- a/modules/erl/euphorik_minichat_conversation.erl +++ b/modules/erl/euphorik_minichat_conversation.erl @@ -35,7 +35,7 @@ -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/2, q/1, keysort/3]). +-import(qlc, [e/2, q/1]). -import(mnesia, [table/1, transaction/1]). @@ -44,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), @@ -80,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]; _ -> @@ -101,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}])]), [{tmpdir, ?KEY_SORT_TEMP_DIR}]), + 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