X-Git-Url: http://git.euphorik.ch/?p=euphorik.git;a=blobdiff_plain;f=modules%2Ferl%2Feuphorik_minichat_conversation.erl;h=156eaac9d7bebed897845bbfae97011ac2576ee6;hp=5cf9a0a62e4752cda14c0e1f26c044f0a74e2d48;hb=81393a74d648e4830dc8c7c562fa203f50a105f6;hpb=828daf607fdce322ea17c1786dff84f712aa1632 diff --git a/modules/erl/euphorik_minichat_conversation.erl b/modules/erl/euphorik_minichat_conversation.erl index 5cf9a0a..156eaac 100755 --- a/modules/erl/euphorik_minichat_conversation.erl +++ b/modules/erl/euphorik_minichat_conversation.erl @@ -15,23 +15,23 @@ % % You should have received a copy of the GNU General Public License % along with Euphorik. If not, see . -% +% % Ce module permet la gestion des conversations du minichat d'euphorik. % Un message (enfant) peut répondre à des messages (ses parents). % Un message (parent) peut avoir plusieurs réponses (enfants) % @author G.Burri -% +% % Les conversation se compose d'une liste de tuple comprenant la conversation, du premier message de la conversation, % et d'un booleen indiquant s'il y a encore des messages % @type Conversations() = [{Conversation(), Message(), bool()}] -% +% % Une conversation est simplement une liste de messages % @type Conversation() = [Message()] % % Un message est un tuple représentant le message et la liste des id % des messages auquels il répond % @type Message() = {#minichat, [int()]} - + -module(euphorik_minichat_conversation). -export([ @@ -42,8 +42,8 @@ -import(lists, [reverse/1, any/2, map/2, sublist/3, filter/2]). -import(euphorik_bd, [resultat_transaction/1]). -import(mnesia, [table/1, transaction/1]). - - + + % Renvoie les conversations. % Chaque racine est un tuple {R, P, D} % R : l'id de la racine @@ -69,7 +69,7 @@ conversations(Racines, N, D, P) -> true -> mise_en_forme_conversations(Conversations) end. - + % Mise en forme des conversations pour l'utilisateur du module. % @type Conversation_principale() = {[integer()], bool} @@ -78,8 +78,8 @@ conversations(Racines, N, D, P) -> mise_en_forme_conversations([]) -> []; mise_en_forme_conversations([{Principale, Plus_principale} | Conversations]) -> [{mise_en_forme_conversation(Principale), Plus_principale} | map(fun({_, Cn, _, Plus}) -> {mise_en_forme_conversation(Cn), Plus} end, Conversations)]. - - + + % Mise en forme d'une liste d'id de messages : [4, 9, 8, ...] -> [{#minichat, [5, 6]}, ...]. % Ajoute les parents de chaque message. % @spec mise_en_forme_conversation([integer()]) -> [{#minichat, [integer()]}] @@ -101,20 +101,20 @@ mise_en_forme_conversation(Messages) -> end )). - + % Renvoie une liste de conversations, le première élément correspond à la conversation principale. % Les autres éléments sont des tuples {C, Cn, X, Plus}, voir conversation/4 pour plus d'infos. % Racines est une liste de tuple {Id, P} des racines des conversations ou P est la page et Id l'id du message. % @spec conversations_detailees([{integer(), integer()}], integer(), integer(), integer()) -> [[{integer(), bool()}] | Conversation_detailee()] -conversations_detailees(Racines, N, D, P) -> +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() -> + Conversation_principale = resultat_transaction(transaction(fun() -> Dernier_id = mnesia:table_info(minichat, size), {CP, Plus} = conversation_principale(Dernier_id, Conversations, N, P), {[M || M <- CP, M > D], Plus} % filtre en fonction de D end)), [Conversation_principale | Conversations]. - + % Construit la conversation principale en fonction d'un id de message initialement placé sur le dernier message % et la liste de conversations. @@ -134,28 +134,28 @@ conversation_principale(Id, Conversations, N, P) -> end, Plus }. - - + + % Id est l'id d'un message, voir ce dessus % 'Messages' sont les messages que l'on doit enlever de la conversation % S est le nombre de messages qu'il faut sauter. % @spec conversation_principale2(integer(), [integer()], integer(), integer()) -> [integer()] conversation_principale2(_, _, 0, _) -> - []; + []; conversation_principale2(0, _, _, _) -> []; -conversation_principale2(Id, Messages, N, S) -> +conversation_principale2(Id, Messages, N, S) -> % traitement message par message (pas des plus performant :/) Doit_etre_saute = any(fun(E) -> E == Id end, Messages), - if Doit_etre_saute -> + if Doit_etre_saute -> conversation_principale2(Id - 1, Messages, N, S); % le message ne fait pas partie de la conversation S =:= 0 -> [Id | conversation_principale2(Id - 1, Messages, N - 1, S)]; % ok : le message fait partie de la conversation true -> conversation_principale2(Id - 1, Messages, N, S - 1) % on n'a pas encore atteint le début de la page end. - - + + % Renvoie un tuple {C, Cn, X, Plus} où % C : La conversation complète % Cn : La conversation tronqué en fonction de N, D et P @@ -181,10 +181,10 @@ conversation(R, N, D, P) -> ) end, reverse(X), - Decalage + N - 1 < length(C) + Decalage + N - 1 < length(C) }. - - + + % Renvoie un tuple {C, X} où C est la conversation complète et X les messages répondant à des mess qui ne font pas partie de la conversation % Attention : les messages de C et de X sont ordrés du plus grand Id au plus petit. % @spec conversation([integer()], [integer()], [integer()]) -> {[int()], [int()]} @@ -201,7 +201,7 @@ conversation(Conv, [M | Reste], X) -> end; conversation(Messages, [], X) -> {Messages, X}. - + % Intersection entre deux listes : [1, 3, 4] n [2, 4, 7] = [4] % @spec intersection(list(term()), list(term())) -> list(term())