From cf7d2e87e769d470fe6390771d6f498fb3570ed0 Mon Sep 17 00:00:00 2001 From: Greg Burri Date: Mon, 3 Mar 2008 20:32:48 +0000 Subject: [PATCH] --- css/1/euphorik.css | 5 ++- modules/erl/euphorik_minichat.erl | 9 +---- .../erl/euphorik_minichat_conversation.erl | 36 ++++++++++++------- modules/erl/euphorik_protocole.erl | 9 ++--- 4 files changed, 29 insertions(+), 30 deletions(-) diff --git a/css/1/euphorik.css b/css/1/euphorik.css index a110f8b..4dd700b 100755 --- a/css/1/euphorik.css +++ b/css/1/euphorik.css @@ -18,10 +18,9 @@ body { #container { position: relative; - width: 700px; height: auto; - margin-left: auto; - margin-right: auto; + margin-left: 10px; + margin-right: 10px; margin-top: 40px; } diff --git a/modules/erl/euphorik_minichat.erl b/modules/erl/euphorik_minichat.erl index d45ca1c..68c1ed5 100755 --- 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)). - + % 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 --- 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). -export([ @@ -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 --- 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]), + ), % accrochez-vous ca va siouxer ;) [{reponse, [{name, "refreshMessages"}], lists:map( @@ -198,8 +196,8 @@ refreshMessage(Action) -> ) ] } - end, - Poulpe + end, + euphorik_minichat_conversation:conversations(Conversations, Nb_message, Dernier_id, Page) ) }]; _ -> @@ -281,7 +279,6 @@ format_date(Date) -> %%%%%%%%% %%%%%%%%% simple_xml_to_string(XML) -> - io:format("~p~n", [XML]), lists:flatten(xmerl:export_simple(XML, xmerl_xml, [{prolog, ["\n"]}])). -- 2.45.2