% Un message (enfant) peut répondre à des messages (ses parents).
% Un message (parent) peut avoir plusieurs réponses (enfants)
% @author G.Burri
% Un message (enfant) peut répondre à des messages (ses parents).
% Un message (parent) peut avoir plusieurs réponses (enfants)
% @author G.Burri
+%
+% @type Message() = {integer(), [integer()]}
+% @type Conversation_detailee() = {[integer()], [integer()], [integer()], bool()}
+% @type Conversation = {[Message()] , bool()} bool() : si true alors il y a encore des messages dans les pages suivantes.
% 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 la fonction est bloquante et attend un nouveau message.
% 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 la fonction est bloquante et attend un nouveau message.
conversations(Racines, N, D, P) ->
% écoute des nouveaux messages
case subscribe(minichat, 2) of
conversations(Racines, N, D, P) ->
% écoute des nouveaux messages
case subscribe(minichat, 2) of
_ ->
% demande des conversations
Conversations = conversations_detailees(Racines, N, D, P),
_ ->
% demande des conversations
Conversations = conversations_detailees(Racines, N, D, P),
unsubscribe(Table) ->
mnesia:unsubscribe({table, Table, simple}).
% Attend qu'un nouveau message arrive, function bloquante.
% Renvoie le nouveau message.
unsubscribe(Table) ->
mnesia:unsubscribe({table, Table, simple}).
% Attend qu'un nouveau message arrive, function bloquante.
% Renvoie le nouveau message.
receive % attente d'un post
{mnesia_table_event, {write, Message, _}} ->
Message;
receive % attente d'un post
{mnesia_table_event, {write, Message, _}} ->
Message;
attend_nouveau_message()
% 60 minutes de timeout (le cas ou il n'y a que des consultations et jamais de post)
% Après 60 minutes de connexion, le client doit donc reétablir une connexion
attend_nouveau_message()
% 60 minutes de timeout (le cas ou il n'y a que des consultations et jamais de post)
% Après 60 minutes de connexion, le client doit donc reétablir une connexion
mise_en_forme_conversations([]) -> [];
mise_en_forme_conversations([{Principale, Plus_principale} | Conversations]) ->
mise_en_forme_conversations([]) -> [];
mise_en_forme_conversations([{Principale, Plus_principale} | Conversations]) ->
- [{mise_en_forme_conversation(Principale), Plus_principale} | lists:map(fun({_, Cn, _, Plus}) -> {mise_en_forme_conversation(Cn), Plus} end, 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, 5, 8, ...].
+% Mise en forme d'une liste d'id de messages : [4, 5, 8, ...] -> [{4, [5, 6]}, ...].
+% Ajoute les parents de chaque message.
+% @spec mise_en_forme_conversation([integer()]) -> [{integer(), [integer()]}]
% Renvoie une liste de conversations, le première élément correspond à la conversation principale.
% Les autres éléments sont des tuples {C, Cn, X}, 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.
% Renvoie une liste de conversations, le première élément correspond à la conversation principale.
% Les autres éléments sont des tuples {C, Cn, X}, 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.
conversations_detailees(Racines, N, D, P) ->
Conversations = map(fun({Racine, P_conv}) -> conversation(Racine, N, D, P_conv) end, Racines),
Conversation_principale = resultat_transaction(transaction(fun() ->
conversations_detailees(Racines, N, D, P) ->
Conversations = map(fun({Racine, P_conv}) -> conversation(Racine, N, D, P_conv) end, Racines),
Conversation_principale = resultat_transaction(transaction(fun() ->
% N est le nombre de messages que l'on souhaite.
% P est le numéro de la page (1, 2, 3...)
% Renvoie {[Id], Plus}
% N est le nombre de messages que l'on souhaite.
% P est le numéro de la page (1, 2, 3...)
% Renvoie {[Id], Plus}
conversation_principale(C, Conversations, N, P) ->
CP = conversation_principale2(C, lists:flatten(map(fun({C2, _, X, _}) -> C2 -- X end, Conversations)), N + 1, (P - 1) * N),
Plus = length(CP) =:= N + 1,
conversation_principale(C, Conversations, N, P) ->
CP = conversation_principale2(C, lists:flatten(map(fun({C2, _, X, _}) -> C2 -- X end, Conversations)), N + 1, (P - 1) * N),
Plus = length(CP) =:= N + 1,
% C est le curseur (voir ci dessus)
% 'Messages' sont les messages que l'on doit enlever de la conversation
% C est le curseur (voir ci dessus)
% 'Messages' sont les messages que l'on doit enlever de la conversation
-% S est le nombre de messages qu'il faut sauter
+% S est le nombre de messages qu'il faut sauter.
+% @spec conversation_principale2(qlc:QueryCursor(), [integer()], integer(), integer())
conversation_principale2(_, _, 0, _) ->
[];
conversation_principale2(C, Messages, N, S) ->
case qlc:next_answers(C, 1) of
[] -> [];
[M] -> % traitement message par message (pas des plus performant :/)
conversation_principale2(_, _, 0, _) ->
[];
conversation_principale2(C, Messages, N, S) ->
case qlc:next_answers(C, 1) of
[] -> [];
[M] -> % traitement message par message (pas des plus performant :/)
- %io:format("M: ~p~n", [M]),
- Doit_etre_saute = lists:any(fun(E) -> E == M end, Messages),
+ Doit_etre_saute = any(fun(E) -> E == M end, Messages),
if Doit_etre_saute ->
conversation_principale2(C, Messages, N, S); % le message ne fait pas partie de la conversation
S =:= 0 ->
if Doit_etre_saute ->
conversation_principale2(C, Messages, N, S); % le message ne fait pas partie de la conversation
S =:= 0 ->
conversation(R, N, D, P) ->
{C, X} = conversation([], [R], []),
Decalage = N*(P-1)+1,
conversation(R, N, D, P) ->
{C, X} = conversation([], [R], []),
Decalage = N*(P-1)+1,
% Intersection entre deux listes : [1, 3, 4] n [2, 4, 7] = [4]
% @spec intersection(list(term()), list(term())) -> list(term())
intersection(L1, L2) ->
% Intersection entre deux listes : [1, 3, 4] n [2, 4, 7] = [4]
% @spec intersection(list(term()), list(term())) -> list(term())
intersection(L1, L2) ->