X-Git-Url: http://git.euphorik.ch/index.cgi?a=blobdiff_plain;f=modules%2Ferl%2Feuphorik_minichat_conversation.erl;h=2d546f17caf10470d4bdaaed42331b427f496349;hb=5d9992368bb386d2e606ae037c5478fe10ac70e8;hp=4d0b3a8574d4f64e816c78076e96c280c99f8c01;hpb=8ee1535f5594573931ddaebee77bf6148a5358cb;p=euphorik.git
diff --git a/modules/erl/euphorik_minichat_conversation.erl b/modules/erl/euphorik_minichat_conversation.erl
index 4d0b3a8..2d546f1 100755
--- a/modules/erl/euphorik_minichat_conversation.erl
+++ b/modules/erl/euphorik_minichat_conversation.erl
@@ -15,25 +15,25 @@
%
% 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).
+-author("Greg Burri ").
-export([
conversations/4
]).
@@ -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() ->
- Dernier_id = mnesia:last(minichat),
+ 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,29 +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('$end_of_table', _, _, _) ->
[];
-conversation_principale2(Id, Messages, N, S) ->
- % traitement message par message (pas des plus performant :/)
- Id_prev = mnesia:prev(minichat, Id),
+conversation_principale2(0, _, _, _) ->
+ [];
+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 ->
- conversation_principale2(Id_prev, Messages, N, S); % le message ne fait pas partie de la conversation
+ 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_prev, Messages, N - 1, S)]; % ok : le message fait partie de la conversation
+ [Id | conversation_principale2(Id - 1, Messages, N - 1, S)]; % ok : le message fait partie de la conversation
true ->
- conversation_principale2(Id_prev, Messages, N, S - 1) % on n'a pas encore atteint le début de la page
+ 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
@@ -182,16 +181,16 @@ 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()]}
conversation(Conv, [M | Reste], X) ->
Est_deja_traite = any(fun(E) -> E =:= M end, Conv),
- if Est_deja_traite ->
+ if Est_deja_traite ->
conversation(Conv, Reste, X);
true ->
Enfants = euphorik_bd:enfants_id(M),
@@ -202,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())