X-Git-Url: http://git.euphorik.ch/?p=euphorik.git;a=blobdiff_plain;f=modules%2Ferl%2Feuphorik_protocole.erl;h=c3dfbbe0406a0c1c56233d9a738ec8f64f91d58c;hp=dac7d03661424a8ba9b479406d201f5b642d057f;hb=11fe8f6d268a9b1c0a773294cc7d70ffdb6afb30;hpb=302c16cbbd999e97f7bac2b3eb70bf057f5bc709

diff --git a/modules/erl/euphorik_protocole.erl b/modules/erl/euphorik_protocole.erl
index dac7d03..c3dfbbe 100755
--- a/modules/erl/euphorik_protocole.erl
+++ b/modules/erl/euphorik_protocole.erl
@@ -43,14 +43,14 @@
 
 
 % Une utilisateur s'enregistre avec un tuple {Login, Password}.
-register([{login, Login}, {password, Password}], IP) ->
+register([{login, Login}, {password, Password}, {profile_infos, Profile_infos}], IP) ->
    Can_register = euphorik_bd:can_register(IP),
    if Can_register ->
          case euphorik_bd:user_by_login(Login) of
             {ok, _} ->
                erreur("Login déjà existant");
             _ ->
-               User = euphorik_bd:nouveau_user(Login, Password, generer_cookie()),
+               User = euphorik_bd:nouveau_user(Login, Password, generer_cookie(), user_from_json(Profile_infos)),
                euphorik_bd:update_ip(User#user.id, IP),
                json_reponse_login_ok(User)
          end;
@@ -58,10 +58,10 @@ register([{login, Login}, {password, Password}], IP) ->
          erreur_register_flood()
    end;
 % Enregistrement sans {Login, Password}
-register([], IP) ->   
+register([{profile_infos, Profile_infos}], IP) ->   
    Can_register = euphorik_bd:can_register(IP),
    if Can_register ->
-         User = euphorik_bd:nouveau_user("<nick>", generer_cookie()),
+         User = euphorik_bd:nouveau_user("<nick>", generer_cookie(), user_from_json(Profile_infos)),
          euphorik_bd:update_ip(User#user.id, IP),
          json_reponse_login_ok(User);
       true ->
@@ -74,19 +74,27 @@ erreur_register_flood() ->
 
 % Un utilisateur se logge (avec un couple {login, mot de passe})
 login([{login, Login}, {password, Password}], IP) ->
-   loginUser(euphorik_bd:user_by_login_password(Login, Password), IP);
+   case euphorik_bd:user_by_login_password(Login, Password) of
+      {ok, User} ->
+         loginUser(User, IP);
+      _ -> 
+         timer:sleep(?TEMPS_ATTENTE_ERREUR_LOGIN),
+         erreur("Couple login/pass introuvable")
+   end;
 % Un utilisateur se logge (avec un cookie)
 login([{cookie, Cookie}], IP) ->
-   loginUser(euphorik_bd:user_by_cookie(Cookie), IP).
+   case euphorik_bd:user_by_cookie(Cookie) of
+      {ok, User} ->
+         loginUser(User, IP);
+      _ ->
+         timer:sleep(?TEMPS_ATTENTE_ERREUR_LOGIN),
+         erreur("Authentification impossible par cookie")
+   end.
    
-loginUser({ok, User}, IP) ->
+loginUser(User, IP) ->
    euphorik_bd:update_ip(User#user.id, IP),
    euphorik_bd:update_date_derniere_connexion(User#user.id),
-   json_reponse_login_ok(User);
-loginUser(_, _) ->
-   % ajoute un délais d'attente
-   timer:sleep(?TEMPS_ATTENTE_ERREUR_LOGIN),
-   erreur("Couple login/pass introuvable").
+   json_reponse_login_ok(User).
    
    
 % Renvoie un string() représentant un cookie en base 36. Il y a 10^32 possibillités.
@@ -107,40 +115,88 @@ profile(
       {cookie, Cookie},
       {login, Login},
       {password, Password},
-      {nick, Pseudo},
-      {email, Email},
-      {css, Css},
-      {nick_format, Nick_format_str},
-      {view_times, View_times},
-      {view_tooltips, View_tooltips},
-      {conversations, {array, Conversations_json}}
+      {profile_infos, Profile_infos}
    ]
 ) ->
-   % virage des messages qui n'existent pas
-   Conversations = lists:dropwhile(
-      fun(Message_id) ->
-         not euphorik_bd:message_existe(Message_id)
+   case user_from_json(Profile_infos) of
+      {erreur, E} -> E;
+      UserInfos ->
+         User = UserInfos#user {
+            cookie = Cookie,
+            login = Login,
+            password = Password
+         },   
+         %  TODO : pas très beau, mieux vaut construire un #user
+         case euphorik_bd:set_profile(User) of
+            ok ->
+               json_reponse_ok();
+            login_deja_pris ->
+               erreur("Login déjà pris");
+            _ ->
+               erreur("Impossible de mettre à jour le profile")
+         end
+   end.
+
+
+% Construit un #user à partir des données JSON
+user_from_json(
+   {struct,
+      [
+         {nick, Pseudo},
+         {email, Email},
+         {css, Css},
+         {chat_order, Chat_order_str},
+         {nick_format, Nick_format_str},
+         {view_times, View_times},
+         {view_tooltips, View_tooltips},
+         {conversations, {array, Conversations_json}},
+         {ostentatious_master, Ostentatious_master_str}
+      ]
+   }
+) ->
+   % décomposition de la strucure JSON
+   Conversations = lists:foldr(
+      fun({struct, [{root, Racine}, {minimized, Reduit}]}, A) ->
+         % virage des messages qui n'existent pas
+         Message_exite = euphorik_bd:message_existe(Racine),
+         if Message_exite ->
+               [ {Racine, Reduit} | A];
+            true ->
+               A
+         end
       end,
+      [],
       Conversations_json
    ),
-   %  TODO : pas très beau, mieux vaut construire un #user
-   case euphorik_bd:set_profile(
-         Cookie,
-         Login,
-         Password,
-         Pseudo,
-         Email,
-         Css,
-         list_to_atom(Nick_format_str),
-         View_times,
-         View_tooltips,
-         Conversations) of
-      ok ->
-         json_reponse_ok();
-      login_deja_pris ->
-         erreur("Login déjà pris");
-      _ ->
-         erreur("Impossible de mettre à jour le profile")
+   % vérification des données JSON
+   Chat_order = list_to_atom(Chat_order_str),
+   Chat_order_valide = lists:any(fun(E) -> E =:= Chat_order end, [reverse, chrono]),
+   if not Chat_order_valide ->
+         {erreur, Chat_order_str ++ " n'est pas une valeur acceptée pour 'chat_order'"};
+      true -> 
+         Nick_format = list_to_atom(Nick_format_str),
+         Nick_format_valide = lists:any(fun(E) -> E =:= Nick_format end, [nick, login, nick_login]),
+         if not Nick_format_valide ->
+               {erreur, Nick_format_str ++ " n'est pas une valeur acceptée pour 'nick_format'"};
+            true -> 
+               Ostentatious_master = list_to_atom(Ostentatious_master_str),
+               Ostentatious_master_valide = lists:any(fun(E) -> E =:= Ostentatious_master end, [invisible, light, heavy]),
+               if not Ostentatious_master_valide ->
+                     {erreur, Ostentatious_master_str ++ " n'est pas une valeur acceptée pour 'ostentatious_master'"};
+                  true ->
+                     #user{
+                        pseudo = Pseudo,
+                        email = Email,
+                        css = Css,
+                        chat_order = Chat_order,
+                        nick_format = Nick_format,
+                        view_times = View_times,
+                        view_tooltips = View_tooltips,
+                        conversations = Conversations,
+                        ostentatious_master = Ostentatious_master
+                     }
+               end
+         end      
    end.
 
 
@@ -252,7 +308,7 @@ wait_event_page_chat(User, Racines_conversations, Message_count, Last_message_id
                         fun({Racine, {Conv, Plus}}) ->
                            {struct, [
                               {last_page, not Plus},
-                              {first, 
+                              {first, % le premier message de la conversation
                                  if Racine =:= undefined orelse Conv =:= [] ->
                                        null;
                                     true ->
@@ -264,7 +320,7 @@ wait_event_page_chat(User, Racines_conversations, Message_count, Last_message_id
                                              null
                                        end
                                  end
-                              }, % le premier message de la conversation, peut correspondre
+                              },
                               {messages, {array,
                                  lists:map(
                                     fun({Mess, Repond_a}) ->
@@ -655,11 +711,18 @@ json_reponse_login_ok(User) ->
          {login, User#user.login},
          {email, User#user.email},
          {css, User#user.css},
+         {chat_order, atom_to_list(User#user.chat_order)},
          {nick_format, atom_to_list(User#user.nick_format)},
          {view_times, User#user.view_times},
          {view_tooltips, User#user.view_tooltips},
-         {conversations, {array, User#user.conversations } },
-         {ek_master, User#user.ek_master}
+         {conversations, {array, lists:map(
+            fun({Racine, Reduit}) ->
+               {struct, [{root, Racine}, {minimized, Reduit}]}
+            end,
+            User#user.conversations
+         )}},
+         {ek_master, User#user.ek_master},
+         {ostentatious_master, atom_to_list(User#user.ostentatious_master)}
       ]
    }.
    
@@ -692,5 +755,6 @@ json_message(Mess, Repond_a, User) ->
          end,
          Repond_a
       )}},
-      {ek_master, User_mess#user.ek_master}
+      {ek_master, User_mess#user.ek_master},
+      {ostentatious_master, atom_to_list(User_mess#user.ostentatious_master)}
    ]}.