% 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_bd:message_by_id(Id) of
- {ok, Message} ->
- [{Message, parents(Id)} | Acc];
- _ ->
- Acc
- end
- end,
- [],
- Messages
- ).
-
+ resultat_transaction(mnesia:transaction(
+ fun() ->
+ lists:foldr(
+ fun(Id, Acc) ->
+ case euphorik_bd:message_by_id_sans_transaction(Id) of
+ {ok, Message} ->
+ [{Message, parents(Id)} | Acc];
+ _ ->
+ Acc
+ end
+ end,
+ [],
+ 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}, voir conversation/4 pour plus d'infos.
% 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()]) -> {}
-conversation(Messages, [M | Reste], X) ->
- Est_deja_traite = any(fun(E) -> E =:= M end, Messages),
+conversation(Conv, [M | Reste], X) ->
+ Est_deja_traite = any(fun(E) -> E =:= M end, Conv),
if Est_deja_traite ->
- conversation(Messages, Reste, X);
+ conversation(Conv, Reste, X);
true ->
Enfants = enfants(M),
Parents = parents(M),
% un message est dit externe si un de ses parent ne fait pas partie de la conversation ou si un de ses parents fait partie de X
- Est_message_externe = Parents -- Messages =/= [] orelse intersection(Parents, X) =/= [],
- conversation([M | Messages], lists:merge(Reste, Enfants), if Est_message_externe -> [M | X]; true -> X end)
+ Est_message_externe = Parents -- Conv =/= [] orelse intersection(Parents, X) =/= [],
+ conversation([M | Conv], lists:merge(Reste, Enfants), if Est_message_externe -> [M | X]; true -> X end)
end;
conversation(Messages, [], X) ->
{Messages, X}.
% @spec enfants(integer()) -> [integer()]
enfants(M) ->
resultat_transaction(transaction(fun() ->
- e(q([E#reponse_minichat.repondant || E <- qlc:sort(table(reponse_minichat), [{order, ascending}]), E#reponse_minichat.cible =:= M]))
+ e(
+ qlc:sort(
+ q([E#reponse_minichat.repondant || E <- table(reponse_minichat), E#reponse_minichat.cible =:= M]),
+ [{order, ascending}]
+ )
+ )
end)).
% @spec parents(integer()) -> [integer()]
parents(M) ->
resultat_transaction(transaction(fun() ->
- e(q([E#reponse_minichat.cible || E <- keysort(1, table(reponse_minichat), [{order, ascending}]), E#reponse_minichat.repondant =:= M]))
+ e(
+ qlc:sort(
+ q([E#reponse_minichat.cible || E <- table(reponse_minichat), E#reponse_minichat.repondant =:= M]),
+ [{order, ascending}]
+ )
+ )
end)).