-]).
-
--include("euphorik_bd.hrl").
--include_lib("stdlib/include/qlc.hrl").
-
--import(lists, [reverse/1, any/2, map/2, sublist/3, filter/2]).
--import(euphorik_minichat, [resultat_transaction/1]).
--import(qlc, [e/1, q/1, keysort/3]).
--import(mnesia, [table/1, transaction/1]).
-
-
-% Renvoie les conversations sous la forme d'une liste de conversation.
-% Chaque conversation est un tuple {[{Message, Parents}], Plus} où
-% 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.
-% @spec conversations([{integer(), integer()}], integer(), integer(), integer()) -> [Conversation()]
-conversations(Racines, N, D, P) ->
- % écoute des nouveaux messages
- case subscribe(minichat, 2) of
- erreur = E ->
- E;
- _ ->
- % demande des conversations
- Conversations = conversations_detailees(Racines, N, D, P),
- % si les conversations sont vides alors on attend un nouveau message
- Vide = not any(
- fun(C) ->
- case C of
- {[], _} -> false;
- {_, [], _, _} -> false;
- _ -> true
- end
- end,
- Conversations
- ),
- Conversations_mises_en_forme = mise_en_forme_conversations(
- if Vide ->
- attend_nouveau_message(),
- conversations_detailees(Racines, N, D, P);
- true ->
- Conversations
- end
- ),
- unsubscribe(minichat),
- Conversations_mises_en_forme
- end.
-
-
-% Ecoute les événements de modification d'une table.
-% @spec subscribe(atom(), integer()) -> ok | erreur
-subscribe(_Table, 0) ->
- erreur;
-subscribe(Table, C) ->
- case mnesia:subscribe({table, Table, simple}) of
- {error, {not_active_local, Table}} ->
- mnesia:add_table_copy(minichat, node(), ram_copies),
- subscribe(Table, C - 1);
- {error, _}->
- erreur;
- _ ->
- ok
- end.
-
-
-% Arrête d'écouter les modifications d'une table.
-% @spec unsubscribe(atom()) -> term()
-unsubscribe(Table) ->
- mnesia:unsubscribe({table, Table, simple}).
-
-
-% Attend qu'un nouveau message arrive, function bloquante.
-% Renvoie le nouveau message.
-% @spec attend_nouveau_message() -> #minichat | timeout
-attend_nouveau_message() ->
- receive % attente d'un post
- {mnesia_table_event, {write, Message, _}} ->
- Message;
- %file:close(F);
- %~ {tcp_closed, _} ->
- %~ mnesia:unsubscribe({table, minichat, simple});
- _ ->
- 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
- % TODO : pour être mieux : quand le socket se ferme alors un message devrait être envoyé et débloquer ce receive (demande en cours sur la mailing list de yaws)
- after 1000 * 60 * 60 ->
- timeout
- end.
-
-
-% Mise en forme des conversations pour l'utilisateur du module.
-% @spec mise_en_forme_conversations([[integer()] | Conversation_detailee()]) -> [Conversation()]
-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, 5, 8, ...] -> [{4, [5, 6]}, ...].
-% Ajoute les parents de chaque message.
-% @spec mise_en_forme_conversation([integer()]) -> [{integer(), [integer()]}]
-mise_en_forme_conversation(Messages) ->
- lists:foldr(
- fun(Id, Acc) ->
- case euphorik_minichat:message_by_id(Id) of
- {ok, Message} ->
- [{Message, parents(Id)} | Acc];
- _ ->
- Acc
- end
- end,
- [],
- Messages
- ).
-
-
-% 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.
-% @spec conversations_detailees([{integer(), integer()}], integer(), integer(), integer()) -> [[integer()] | Conversation_detailee()]
-conversations_detailees(Racines, N, D, P) ->
- Conversations = map(fun({Racine, P_conv}) -> conversation(Racine, N, D, P_conv) end, Racines),
+]).\r
+-include("../include/euphorik_bd.hrl").\r
+-include("../include/euphorik_defines.hrl").\r
+-import(lists, [reverse/1, any/2, map/2, sublist/3, filter/2]).\r
+-import(euphorik_bd, [resultat_transaction/1]).\r
+-import(mnesia, [table/1, transaction/1]).\r
+ \r
+ \r
+% Renvoie les conversations.\r
+% Chaque racine est un tuple {R, P, D}\r
+% R : l'id de la racine\r
+% N : le nombre de message\r
+% D : le dernier message connu, 0 si aucun\r
+% P : la page souhaité, la premier est la 1\r
+% @spec conversations([{integer(), integer(), integer()}], integer(), integer(), integer()) -> Conversations()\r
+conversations(Racines, N, D, P) ->\r
+ Conversations = conversations_detailees(Racines, N, D, P),\r
+ % si les conversations sont vides alors on attend un nouveau message\r
+ Vide = not any(\r
+ fun(C) ->\r
+ case C of\r
+ {[], _} -> false;\r
+ {_, [], _, _} -> false;\r
+ _ -> true\r
+ end\r
+ end,\r
+ Conversations\r
+ ),\r
+ if Vide ->\r
+ vide;\r
+ true ->\r
+ mise_en_forme_conversations(Conversations)\r
+ end.\r
+ \r
+\r
+% Mise en forme des conversations pour l'utilisateur du module.\r
+% @type Conversation_principale() = {[integer()], bool}\r
+% @type Conversation_detailee() = {[integer()], [integer()], [integer()], bool()}\r
+% @spec mise_en_forme_conversations([Conversation_principal() | Conversation_detailee()]) -> [Conversation()]\r
+mise_en_forme_conversations([]) -> [];\r
+mise_en_forme_conversations([{Principale, Plus_principale} | Conversations]) ->\r
+ [{mise_en_forme_conversation(Principale), Plus_principale} | map(fun({_, Cn, _, Plus}) -> {mise_en_forme_conversation(Cn), Plus} end, Conversations)].\r
+ \r
+ \r
+% Mise en forme d'une liste d'id de messages : [4, 9, 8, ...] -> [{#minichat, [5, 6]}, ...].\r
+% Ajoute les parents de chaque message.\r
+% @spec mise_en_forme_conversation([integer()]) -> [{#minichat, [integer()]}]\r
+mise_en_forme_conversation(Messages) ->\r
+ resultat_transaction(transaction(\r
+ fun() ->\r
+ lists:foldr(\r
+ fun(Id, Acc) ->\r
+ case euphorik_bd:message_by_id(Id) of\r
+ {ok, Message} ->\r
+ [{Message, euphorik_bd:parents_id(Id)} | Acc];\r
+ _ ->\r
+ Acc\r
+ end\r
+ end,\r
+ [],\r
+ Messages\r
+ )\r
+ end\r
+ )).\r
+\r
+ \r
+% Renvoie une liste de conversations, le première élément correspond à la conversation principale.\r
+% Les autres éléments sont des tuples {C, Cn, X, Plus}, voir conversation/4 pour plus d'infos.\r
+% Racines est une liste de tuple {Id, P} des racines des conversations ou P est la page et Id l'id du message.\r
+% @spec conversations_detailees([{integer(), integer()}], integer(), integer(), integer()) -> [[{integer(), bool()}] | Conversation_detailee()]\r
+conversations_detailees(Racines, N, D, P) -> \r
+ Conversations = map(fun({Racine, P_conv, Dernier}) -> conversation(Racine, N, Dernier, P_conv) end, Racines),\r