(no commit message)
[euphorik.git] / modules / erl / euphorik_protocole.erl
index 57275fc..4eed84d 100755 (executable)
@@ -8,52 +8,22 @@
 
 -module(euphorik_protocole).
 -export([
-   %generation_captcha/1, Obsolète
-   %nouveau_user_captcha/1, Obsolète
    nouveau_user_login/1,
    login/1,
    logout/1,
    profile/1,
    refreshMessage/1,
-   message/1
+   message/1,
+   erreur/1
 ]).\r
 
 -include_lib("xmerl/include/xmerl.hrl").
 -include("../include/euphorik_bd.hrl").\r
 -include("../include/euphorik_defines.hrl").\r
 
-
-% Génère un nouveau captchat dans ?DOSSIER_CAPTCHA\r
-% Obsolète
-%~ generation_captcha(_) ->
-   %~ {Mot_crypt, Nom_fichier} = captcha:create(5, ?DOSSIER_CAPTCHA),
-   %~ simple_xml_to_string(xml_reponse_generation_captcha(?DOSSIER_CAPTCHA_RELATIF "/" ++ Nom_fichier, Mot_crypt)).
-   
-\r
-% Un nouvel utilisateur doit être créé.\r
-% Obolète : le captcha n'existe plus
-% 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
-         %~ {[#xmlElement{content = [#xmlText{value = C1}]}], [#xmlElement{content = [#xmlText{value = C2}]}]} ->\r
-            %~ C2_crypt = common:crypt(C2),\r
-            %~ if C1 =:= C2_crypt ->\r
-                  %~ Cookie = generer_cookie(),\r
-                  %~ User = euphorik_minichat:nouveau_user("Paul", Cookie),\r
-                  %~ xml_reponse_login_ok(User);\r
-               %~ true ->
-                  %~ xml_reponse_login_pas_ok("Captcha incorrect")\r
-            %~ end;
-         %~ _ ->
-            %~ xml_reponse_login_pas_ok("XML malformé")\r
-      %~ end
-   %~ ).
-   
    
-% Une utilisateur s'enregistre avec un tuple {Login, Password}.\r
-% @spec nouveau_user_login(xmerl:xmlElement()) -> string()
-nouveau_user_login(Action) ->\r
+% Une utilisateur s'enregistre avec un tuple {Login, Password}.
+register([]) ->\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:user_by_login(L) of {ok, _} -> true; _ -> false end};\r
@@ -70,24 +40,18 @@ nouveau_user_login(Action) ->
    ).\r
    
 \r
-% Un utilisateur se logge.
-login(Action) ->
-   case xmerl_xpath:string("cookie", Action) of
-      [#xmlElement{content = [#xmlText{value = 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:user_by_login_password(Login, Password));
-         _ ->
-            simple_xml_to_string(xml_reponse_login_pas_ok("XML malformé"))
-         end
-   end.
+% Un utilisateur se logge (avec un couple {login, mot de passe})
+login([{login, Login}, {password, Password}]) ->
+   loginUser(euphorik_minichat:user_by_login_password(Login, Password));
+% Un utilisateur se logge (avec un cookie)
+login([{cookie, Cookie}]) ->
+   loginUser(euphorik_minichat:user_by_cookie(Cookie)).
+   
 loginUser({ok, User}) ->
    euphorik_minichat:update_date_derniere_connexion(User#user.id),
-   simple_xml_to_string(xml_reponse_login_ok(User));   
+   json_reponse_login_ok(User);
 loginUser(_) ->
-   simple_xml_to_string(xml_reponse_login_pas_ok("Erreur de login")).
+   erreur("Erreur login").
    
    \r
 % Renvoie un string() représentant un cookie en base 36. Il y a 10^32 possibillités.\r
@@ -103,63 +67,65 @@ logout(_) ->
 
 
 % Modification du profile.
-profile(Action) ->
-   simple_xml_to_string(
-      case xmerl_xpath:string("cookie", Action) of
-         [#xmlElement{content = [#xmlText{value = Cookie}]}] ->
-            Login = case xmerl_xpath:string("login", Action) of [#xmlElement{content = [#xmlText{value = L}]}] -> L; _ -> undefined end,
-            Password = case xmerl_xpath:string("password", Action) of [#xmlElement{content = [#xmlText{value = P}]}] -> P; _ -> undefined end,
-            Pseudo = case xmerl_xpath:string("pseudo", Action) of [#xmlElement{content = [#xmlText{value = P2}]}] -> P2; _ -> Login end,
-            Email = case xmerl_xpath:string("email", Action) of [#xmlElement{content = [#xmlText{value = E}]}] -> E; _ -> undefined end,
-            Css = case xmerl_xpath:string("css", Action) of [#xmlElement{content = [#xmlText{value = C}]}] -> C; _ -> undefined end,
-            case euphorik_minichat:set_profile(Cookie, Login, Password, Pseudo, Email, Css) of
-               ok ->
-                  xml_reponse_profile_ok();\r
-               login_deja_pris ->\r
-                  xml_reponse_profile_pas_ok("Login déjà pris");
-               _ ->
-                  xml_reponse_profile_pas_ok("Impossible de mettre à jour le profile")
-            end;
-         _ ->
-            xml_reponse_profile_pas_ok("XML malformé")
-      end
-   ).
-   
+profile(
+   [
+      {cookie, Cookie},
+      {login, Login},
+      {password, Password},
+      {pseudo, Pseudo},
+      {email, Email},
+      {css, Css},
+      {main_page, Main_page},
+      {conversations, {array, Conversations_json}}
+   ]
+) ->
+   % est-ce que les messages auquel on répond existent ?
+   Conversations = lists:foldr(
+      fun([struct, {root, Root}, {page, Page}], Acc) ->
+         Message_existe = euphorik_minichat:message_existe(Root),
+         if  Message_existe ->
+            [{Root, Page} | Acc];
+         true ->
+            Acc
+      end,
+      [],
+      Conversations_json
+   ),
+   case euphorik_minichat:set_profile(Cookie, Login, Password, Pseudo, Email, Css, Main_page, Conversations) of
+      ok ->
+         json_reponse_ok();
+      login_deja_pris ->
+         erreur("Login déjà pris");
+      _ ->
+         erreur("Impossible de mettre à jour le profile")
+   end.
+
 
 % Renvoie les messages appropriés.
-refreshMessage(Action) ->\r
-   simple_xml_to_string(
-      case {
-         xmerl_xpath:string("nombreMessage", Action), % le nombre de message qu'affiche le client
-         xmerl_xpath:string("page", Action) % la page désiré, la première (les derniers messages) étant la 1
-         } of
-         {
-            [#xmlElement{content = [#xmlText{value = Nb_message_str}]}],
-            [#xmlElement{content = [#xmlText{value = Page_str}]}]
-         } ->         
-            Nb_message = list_to_integer(Nb_message_str),
-            Page = list_to_integer(Page_str),
-            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,
-            User = case xmerl_xpath:string("cookie", Action) of 
-               [#xmlElement{content = [#xmlText{value = Cookie}]}] ->
-                  case euphorik_minichat:user_by_cookie(Cookie) of
-                     {ok, U} -> U;
-                     _ -> inconnu
-                  end;
-               _ -> inconnu
-            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)
-            ),\r
+wait_event(
+   [
+      {cookie, Cookie},
+      {message_count, Message_count} | Reste
+   ]
+) ->
+   % Last message id est facultatif
+   Last_message_id = case lists:keysearch(last_message_id, 1, Reste) of
+      {Id, _} -> Id;
+      _ -> 0
+   end,
+   {Main_page, _} = lists:keysearch(main_page, 1, Reste),
+   {{array, Conversations_json}, _} = lists:keysearch(conversations, 1, Reste),
+   User = case euphorik_minichat:user_by_cookie(Cookie) of\r
+      {ok U} -> U;\r
+      _ -> inconnu\r
+   end,\r
+   {stuct, [\r
+      {reply, "new_message"},\r
+      {conversations, {array,\r
+         TODO ...\r
+      }   \r
+   ]}
+   \r
             % accrochez-vous ca va siouxer ;)
             [{reponse, [{name, "refreshMessages"}],\r
                lists:map(\r
@@ -196,8 +162,13 @@ refreshMessage(Action) ->
                            )
                         ]
                      }\r
-                  end,            
-                  euphorik_minichat_conversation:conversations(Conversations, Nb_message, Dernier_id, Page)\r
+                  end,
+                  euphorik_minichat_conversation:conversations(
+                     if User =/= inconnu -> User#user.conversations; true -> [] end,
+                     Nb_message,
+                     Dernier_id,
+                     if User =/= inconnu -> User#user.page_principale; true -> 1 end
+                  )\r
                )
             }];
          _ ->
@@ -256,6 +227,16 @@ message(Action) ->
       end\r
    ).\r
 
+
+% Construit une erreur
+erreur(Message) ->
+   {
+      struct, [
+         {reply, "error"},
+         {error_message, Message}
+      ]
+   }.
+   
 \r
 % Formatage d'une heure\r
 % local_time() -> string\r
@@ -277,10 +258,11 @@ format_date(Date) ->
    io_lib:format("~2.10.0B:~2.10.0B:~2.10.0B", [Heure, Minute, Seconde]).
 
 
-%%%%%%%%% <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"]}])).
+%%%%%%%%% <Réponses JSON> %%%%%%%%%
 
+json_reponse_ok() ->
+   {struct, [{reply, "ok"}]}.
+   
 
 % Construit une réponse positive à un login
 % si Enregistre vaut true alors cela veut dire que la personne s'est enregistré (elle possède au moins un login et un password)
@@ -293,11 +275,52 @@ xml_reponse_login_ok(User) ->
          {pseudo, [User#user.pseudo]},
          {login, [User#user.login]},
          {email, [User#user.email]},
-         {css, [User#user.css]}
-      ]
+         {css, [User#user.css]},
+         {pagePrincipale, [integer_to_list(User#user.page_principale)]}
+      ] ++ 
+      lists:map(
+         fun(C) -> 
+            {conversation, 
+               [
+                  {racine, [erlang:integer_to_list(element(1, C), 36)]},
+                  {page, [integer_to_list(element(2, C))]}
+               ]
+            }
+         end,
+         User#user.conversations
+      )
    }].
    
    
+json_reponse_login_ok(User) ->
+   {
+      struct, [
+         {reply, "login"},
+         {status, if (User#user.password =/= []) and (User#user.login =/= []) -> "enregistre"; true -> "identifie" end},
+         {cookie, User#user.cookie},
+         {id, User#user.id},
+         {pseudo, User#user.pseudo},
+         {login, User#user.login},
+         {email, User#user.email},
+         {css, User#user.css},
+         {main_page, User#user.page_principale},
+         {conversations, 
+            {array,
+               lists:map(
+                  fun(C) ->
+                     {struct,
+                        {root, element(1, C)},
+                        {page, element(2, C)}
+                     }
+                  end,
+                  User#user.conversations
+               )
+            }
+         }
+      ]
+   }.
+   
+   
 % Construit un réponse négative à un login
 xml_reponse_login_pas_ok(Message) ->
    [{reponse, [{name, "login"}],
@@ -306,23 +329,6 @@ xml_reponse_login_pas_ok(Message) ->
          {information, [Message]}
       ]
    }].
-
-
-xml_reponse_profile_ok() ->
-   [{reponse, [{name, "profile"}],
-      [
-         {statut, ["ok"]}
-      ]
-   }].
-
-
-xml_reponse_profile_pas_ok(Message) ->
-   [{reponse, [{name, "profile"}],
-      [
-         {statut, ["pas ok"]},
-         {information, [Message]}
-      ]
-   }].
    
    
 % Pas utilisé
@@ -359,16 +365,5 @@ xml_reponse_message(Ok) ->
          ]\r
       }\r
    ].
-\r
-\r
-% Obsolète
-%~ xml_reponse_generation_captcha(Chemin, Captcha) ->
-   %~ [
-      %~ {reponse, [{name, "generationCaptcha"}],
-         %~ [
-            %~ {chemin, [], [Chemin]},
-            %~ {captchaCrypt, [], [Captcha]}
-         %~ ]
-      %~ }
-   %~ ].
+
 %%%%%%%%% </réponses XML> %%%%%%%%%