MOD avancement dans les conversations (il reste la partie JS)
[euphorik.git] / modules / erl / euphorik_protocole.erl
index 7b9423a..99eb300 100755 (executable)
@@ -20,8 +20,7 @@
 ]).
 -include_lib("xmerl/include/xmerl.hrl").
 -include("../include/euphorik_bd.hrl").\r
--include("../include/euphorik_defines.hrl").
-%-compile(export_all).\r
+-include("../include/euphorik_defines.hrl").\r
 
 
 % Génère un nouveau captchat dans ?DOSSIER_CAPTCHA
@@ -30,8 +29,8 @@ generation_captcha(_) ->
    simple_xml_to_string(xml_reponse_generation_captcha(?DOSSIER_CAPTCHA_RELATIF "/" ++ Nom_fichier, Mot_crypt)).
    
 \r
-% Un nouvel utilisateur doit être créé
-% Action est un xmlElement()
+% Un nouvel utilisateur doit être créé.
+% Action est un xmlElement().
 nouveau_user_captcha(Action) ->
    simple_xml_to_string(\r
       case {xmerl_xpath:string("captchaCrypt", Action), xmerl_xpath:string("captchaInput", Action)} of\r
@@ -49,10 +48,12 @@ nouveau_user_captcha(Action) ->
       end
    ).
    
+   
+% Une utilisateur s'enregistre avec un tuple {Login, Password}.
 nouveau_user_login(Action) ->\r
    {Login, Password, Login_deja_pris} = case {xmerl_xpath:string("login", Action), xmerl_xpath:string("password", Action)} of\r
       {[#xmlElement{content = [#xmlText{value = L}]}], [#xmlElement{content = [#xmlText{value = P}]}]} ->\r
-         {L, P, case euphorik_minichat:get_user_by_login(L) of {ok, _} -> true; _ -> false end};\r
+         {L, P, case euphorik_minichat:user_by_login(L) of {ok, _} -> true; _ -> false end};\r
       _ -> {[], [], false}\r
    end,      
    simple_xml_to_string(\r
@@ -66,15 +67,15 @@ nouveau_user_login(Action) ->
    ).\r
    
 \r
-% Un utilisateur se logge
+% Un utilisateur se logge.
 login(Action) ->
    case xmerl_xpath:string("cookie", Action) of
       [#xmlElement{content = [#xmlText{value = Cookie}]}] ->
-         loginUser(euphorik_minichat:get_user_by_cookie(Cookie));
+         loginUser(euphorik_minichat:user_by_cookie(Cookie));
       _ ->
          case {xmerl_xpath:string("login", Action), xmerl_xpath:string("password", Action)} of
             {[#xmlElement{content = [#xmlText{value = Login}]}], [#xmlElement{content = [#xmlText{value = Password}]}]} ->
-               loginUser(euphorik_minichat:get_user_by_login_password(Login, Password));
+               loginUser(euphorik_minichat:user_by_login_password(Login, Password));
          _ ->
             simple_xml_to_string(xml_reponse_login_pas_ok("XML malformé"))
          end
@@ -138,61 +139,72 @@ refreshMessage(Action) ->
             Dernier_id = case xmerl_xpath:string("dernierMessageId", Action) of % l'id du dernier message que connait le client
                [#xmlElement{content = [#xmlText{value = D}]}] -> erlang:list_to_integer(D, 36);
                _ -> 0
-            end,         
+            end,
             User = case xmerl_xpath:string("cookie", Action) of 
                [#xmlElement{content = [#xmlText{value = Cookie}]}] ->
-                  case euphorik_minichat:get_user_by_cookie(Cookie) of
+                  case euphorik_minichat:user_by_cookie(Cookie) of
                      {ok, U} -> U;
                      _ -> inconnu
                   end;
                _ -> inconnu
-            end,\r
-            % accrochez-vous ca va siouxer ;)\r
-            Mess = lists:map(\r
-               fun(Mess) ->\r
-                  Est_proprietaire = User =/= inconnu andalso User#user.id =:= Mess#minichat.auteur_id,\r
-                  A_repondu_a_message = User =/= inconnu andalso euphorik_minichat:a_repondu_a_message(User#user.id, Mess#minichat.id),\r
-                  Est_une_reponse_a_user = User =/= inconnu andalso euphorik_minichat:est_une_reponse_a_user(User#user.id, Mess#minichat.id),
-                  User_mess = if Mess#minichat.auteur_id =:= 0 -> inconnu; true ->
-                     {ok, U2} = euphorik_minichat:get_user_by_id(Mess#minichat.auteur_id),
-                     U2
-                  end,                  \r
-                  {message, [{id, erlang:integer_to_list(Mess#minichat.id, 36)}],\r
-                     [\r
-                        {date, [], [format_date(Mess#minichat.date)]},
-                        {systeme, [], [atom_to_list(Mess#minichat.auteur_id =:= 0)]},\r
-                        {proprietaire, [], [atom_to_list(Est_proprietaire)]},\r
-                        {repondu, [], [atom_to_list(A_repondu_a_message)]},\r
-                        {reponse, [], [atom_to_list(Est_une_reponse_a_user)]},\r
-                        {pseudo, [], [Mess#minichat.pseudo]},
-                        {login, [], [if User_mess =:= inconnu -> Mess#minichat.pseudo; true -> User_mess#user.login end]},\r
-                        {contenu, [], [Mess#minichat.contenu]},\r
-                        {repondA, [], xml_repond_a(Mess#minichat.id)}\r
-                     ]\r
-                  }\r
-               end,\r
-               get_dernieres_messages(Dernier_id, Nb_message, Page)\r
+            end,
+            % extraction des conversations en [{id, page}, ..]
+            Conversations = lists:map(
+               fun(Conv) ->
+                  [#xmlElement{content = [#xmlText{value = Id_racine_str}]}] = xmerl_xpath:string("racine", Conv),
+                  [#xmlElement{content = [#xmlText{value = Page_conv_str}]}] = xmerl_xpath:string("page", Conv), 
+                  {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
+            % accrochez-vous ca va siouxer ;)
             [{reponse, [{name, "refreshMessages"}],\r
-               % la fonction get_nb_page DOIT être évalué après get_dernieres_messages (merci les effets de bord)
-               [{nbPage, [], [integer_to_list(euphorik_minichat:get_nb_page(Nb_message))]} | Mess]
+               lists:map(\r
+                  fun({Conv, Plus}) ->
+                     {conversation, [], 
+                        [{autresPages, [], [atom_to_list(Plus)]} |
+                           lists:map(
+                              fun({Mess, Repond_a}) ->                                 \r
+                                 Est_proprietaire = User =/= inconnu andalso User#user.id =:= Mess#minichat.auteur_id,\r
+                                 A_repondu_a_message = User =/= inconnu andalso euphorik_minichat:a_repondu_a_message(User#user.id, Mess#minichat.id),\r
+                                 Est_une_reponse_a_user = User =/= inconnu andalso euphorik_minichat:est_une_reponse_a_user(User#user.id, Mess#minichat.id),
+                                 User_mess =
+                                    if Mess#minichat.auteur_id =:= 0 ->
+                                          inconnu;
+                                       true ->
+                                          {ok, U2} = euphorik_minichat:user_by_id(Mess#minichat.auteur_id),
+                                          U2
+                                    end,\r
+                                 {message, [{id, erlang:integer_to_list(Mess#minichat.id, 36)}],\r
+                                    [\r
+                                       {date, [], [format_date(Mess#minichat.date)]},
+                                       {systeme, [], [atom_to_list(Mess#minichat.auteur_id =:= 0)]},\r
+                                       {proprietaire, [], [atom_to_list(Est_proprietaire)]},\r
+                                       {repondu, [], [atom_to_list(A_repondu_a_message)]},\r
+                                       {reponse, [], [atom_to_list(Est_une_reponse_a_user)]},\r
+                                       {pseudo, [], [Mess#minichat.pseudo]},
+                                       {login, [], [if User_mess =:= inconnu -> Mess#minichat.pseudo; true -> User_mess#user.login end]},\r
+                                       {contenu, [], [Mess#minichat.contenu]},\r
+                                       {repondA, [], xml_repond_a(Repond_a)}\r
+                                    ]\r
+                                 }
+                              end,
+                              Conv
+                           )
+                        ]
+                     }\r
+                  end,               
+                  Poulpe\r
+               )
             }];
          _ ->
             [{reponse, [{name, "refreshMessages"}], [{erreur, [], ["erreur"]}]}]
       end\r
    ).
          
-
-% Renvoie les derniers messages, s'il n'y en a pas on effectue une attente.
-get_dernieres_messages(Dernier_id, Nb_message, Page) ->
-   Messages = euphorik_minichat:messages(Dernier_id, Nb_message, Page),
-   if Messages =:= [] ->
-         euphorik_minichat:attends_nouveau_messages(),
-         euphorik_minichat:messages(Dernier_id,  Nb_message, Page);
-      true ->
-         Messages
-   end.
-\r
+         \r
 % Prend une liste de xml text node et en resort un string()\r
 % xmerl : "test & test" devient deux fragments de texte : "test " et "& test", il faut donc rassembler les morceaux...\r
 defragmenter(Text_nodes) ->\r
@@ -212,7 +224,7 @@ message(Action) ->
             [#xmlElement{content = Pseudo_fragments}],
             [#xmlElement{content = Contenu_fragments}]
          } ->                    \r
-            case euphorik_minichat:get_user_by_cookie(Cookie) of\r
+            case euphorik_minichat:user_by_cookie(Cookie) of\r
                {ok, U} ->\r
                   Pseudo = defragmenter(Pseudo_fragments),\r
                   Contenu = defragmenter(Contenu_fragments),\r
@@ -266,7 +278,8 @@ format_date(Date) ->
 
 %%%%%%%%% <Réponses XML> %%%%%%%%%
 simple_xml_to_string(XML) ->
-    lists:flatten(xmerl:export_simple(XML, xmerl_xml, [{prolog, ["<?xml version=\"1.0\" encoding=\"utf-8\" ?>\n"]}])).
+   io:format("~p~n", [XML]),
+   lists:flatten(xmerl:export_simple(XML, xmerl_xml, [{prolog, ["<?xml version=\"1.0\" encoding=\"utf-8\" ?>\n"]}])).
 
 
 % Construit une réponse positive à un login
@@ -327,13 +340,14 @@ xml_reponse_profile_pas_ok(Message) ->
 
 
 % Renvoie un element XML representant une liste de messages auquel le message M_id repond
-xml_repond_a(Mess_id) ->
+xml_repond_a(Reponses) ->
    lists:map(
-      fun(M) ->
-         {ok, User} = euphorik_minichat:get_user_by_id(M#minichat.auteur_id),
+      fun(Id_mess) ->
+         {ok, M} = euphorik_minichat:message_by_id(Id_mess),
+         {ok, User} = euphorik_minichat:user_by_mess(Id_mess),
          {id, [{id, erlang:integer_to_list(M#minichat.id, 36)}, {pseudo, M#minichat.pseudo}, {login, User#user.login}], []}
       end,
-      euphorik_minichat:repond_a(Mess_id)
+      Reponses
    ).\r
    \r
    \r
@@ -356,7 +370,3 @@ xml_reponse_generation_captcha(Chemin, Captcha) ->
       }
    ].
 %%%%%%%%% </réponses XML> %%%%%%%%%
-
-
-
-