(no commit message)

diff --git a/css/1/euphorik.css b/css/1/euphorik.css
index a110f8b..4dd700b 100755 (executable)
--- a/css/1/euphorik.css
+++ b/css/1/euphorik.css
@@ -18,10 +18,9 @@ body {
 \r
 #container {
    position: relative;\r
-   width: 700px;\r
    height: auto;\r
-   margin-left: auto;\r
-   margin-right: auto;\r
+   margin-left: 10px;\r
+   margin-right: 10px;\r
    margin-top: 40px;\r
 }
 

diff --git a/modules/erl/euphorik_minichat.erl b/modules/erl/euphorik_minichat.erl
index d45ca1c..68c1ed5 100755 (executable)
--- a/modules/erl/euphorik_minichat.erl
+++ b/modules/erl/euphorik_minichat.erl
@@ -369,14 +369,7 @@ nb_page(N) ->
    resultat_transaction(mnesia:transaction(fun() ->
       ceiling(length(qlc:e(qlc:q([E#minichat.id || E <- mnesia:table(minichat)]))) / N)
    end)).
-   
-   
-% Renvoie le numéro de la page sur lequel se trouve le message M en sachant qu'il y a N messages par page.
-%~ page(M, N) ->
-   %~ resultat_transaction(mnesia:transaction(fun() ->
-      %~ ceiling((length(qlc:e(qlc:q([E || E <- mnesia:table(minichat), E#minichat.id >= M])))) / N)
-   %~ end)).\r
-   
+     
    
 % Bizarre, cette fonction n'existe pas dans la stdlib.
 ceiling(X) ->

diff --git a/modules/erl/euphorik_minichat_conversation.erl b/modules/erl/euphorik_minichat_conversation.erl
index 57c48d6..abe4368 100755 (executable)
--- a/modules/erl/euphorik_minichat_conversation.erl
+++ b/modules/erl/euphorik_minichat_conversation.erl
@@ -3,6 +3,10 @@
 % 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.
 
 -module(euphorik_minichat_conversation).\r
 -export([\r
@@ -23,6 +27,7 @@
 % 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
@@ -31,9 +36,8 @@ conversations(Racines, N, D, P) ->
       _ ->
          % demande des conversations
          Conversations = conversations_detailees(Racines, N, D, P),
-         %io:format("~p~n", [Conversations]),
          % si les conversations sont vides alors on attend un nouveau message
-         Vide = not lists:any(
+         Vide = not any(
             fun(C) ->
                case C of
                   {[], _} -> false;
@@ -57,6 +61,7 @@ conversations(Racines, N, D, P) ->
    
    
 % Ecoute les événements de modification d'une table.
+% @spec subscribe(atom(), integer()) -> ok | erreur
 subscribe(_Table, 0) ->
    erreur;
 subscribe(Table, C) ->
@@ -72,23 +77,22 @@ subscribe(Table, C) ->
    
    
 % 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() ->
-   %io:format(F, "En attente d'un message !~n", []),
    receive % attente d'un post
       {mnesia_table_event, {write, Message, _}} ->
          Message;
-         %io:format(F, "Debloquage !~n", []),
          %file:close(F);
       %~ {tcp_closed, _} ->
          %~ mnesia:unsubscribe({table, minichat, simple});      
       _ ->
-         %io:format(F, "~p~n", [M]),
          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
@@ -99,14 +103,17 @@ attend_nouveau_message() ->
      
 
 % 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} | 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()]}]
 mise_en_forme_conversation(Messages) ->
-   lists:map(
+   map(
       fun(Id) ->
          {ok, Message} = euphorik_minichat:message_by_id(Id),
          {Message, parents(Id)}
@@ -118,6 +125,7 @@ mise_en_forme_conversation(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),
    Conversation_principale = resultat_transaction(transaction(fun() ->
@@ -134,6 +142,7 @@ conversations_detailees(Racines, N, D, P) ->
 % N est le nombre de messages que l'on souhaite.
 % P est le numéro de la page (1, 2, 3...)
 % Renvoie {[Id], Plus}
+% @spec conversation_principale(qlc:QueryCursor(), [Conversation_detailee()], integer(), integer())
 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,
@@ -150,15 +159,15 @@ conversation_principale(C, Conversations, N, P) ->
       
 % 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 :/)
-         %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 ->
@@ -179,10 +188,11 @@ conversation_principale2(C, Messages, N, S) ->
 % N : le nombre de message par page
 % D : Le dernier message connu 0 si aucun de connu
 % P : La page désirée
+% @spec conversation([integer()], integer(), integer(), integer()) -> Conversation_detailee()
 conversation(R, N, D, P) ->
    {C, X} = conversation([], [R], []),
    Decalage = N*(P-1)+1,
-   { 
+   {
       reverse(C),
       if Decalage > length(C) ->
             [];
@@ -236,5 +246,5 @@ parents(M) ->
 % Intersection entre deux listes : [1, 3, 4] n [2, 4, 7] = [4]
 % @spec intersection(list(term()), list(term())) -> list(term())
 intersection(L1, L2) ->
-   lists:filter(fun(X) -> lists:member(X, L1) end, L2).
+   filter(fun(X) -> lists:member(X, L1) end, L2).
 

diff --git a/modules/erl/euphorik_protocole.erl b/modules/erl/euphorik_protocole.erl
index 2f4a5a3..75c017c 100755 (executable)
--- a/modules/erl/euphorik_protocole.erl
+++ b/modules/erl/euphorik_protocole.erl
@@ -159,9 +159,7 @@ refreshMessage(Action) ->
                   {erlang:list_to_integer(Id_racine_str, 36), erlang:list_to_integer(Page_conv_str)}
                end,
                xmerl_xpath:string("conversation", Action)
-            ),
-            Poulpe = euphorik_minichat_conversation:conversations(Conversations, Nb_message, Dernier_id, Page),
-            io:format("Poulpe = ~p~n", [Poulpe]),\r
+            ),\r
             % accrochez-vous ca va siouxer ;)
             [{reponse, [{name, "refreshMessages"}],\r
                lists:map(\r
@@ -198,8 +196,8 @@ refreshMessage(Action) ->
                            )
                         ]
                      }\r
-                  end,               
-                  Poulpe\r
+                  end,            
+                  euphorik_minichat_conversation:conversations(Conversations, Nb_message, Dernier_id, Page)\r
                )
             }];
          _ ->
@@ -281,7 +279,6 @@ format_date(Date) ->
 
 %%%%%%%%% <Réponses XML> %%%%%%%%%
 simple_xml_to_string(XML) ->
-   io:format("~p~n", [XML]),
    lists:flatten(xmerl:export_simple(XML, xmerl_xml, [{prolog, ["<?xml version=\"1.0\" encoding=\"utf-8\" ?>\n"]}])).