2 % Ce module gére les différents messages envoyés par le client (javascript) via AJAX.
3 % Les messages donnés ainsi que les réponses sont au format JSON.
6 -module(euphorik_protocole
).
17 -include_lib("xmerl/include/xmerl.hrl").
18 -include("../include/euphorik_bd.hrl").
19 -include("../include/euphorik_defines.hrl").
22 % Une utilisateur s'enregistre avec un tuple {Login, Password}.
23 register([{login
, Login
}, {password
, Password
}]) ->
24 case euphorik_minichat:user_by_login(Login
) of
26 erreur("Login déjà existant");
28 User
= euphorik_minichat:nouveau_user(Login
, Password
, generer_cookie()),
29 json_reponse_login_ok(User
)
31 % Enregistrement sans {Login, Password}
33 User
= euphorik_minichat:nouveau_user("<nick>", generer_cookie()),
34 json_reponse_login_ok(User
).
37 % Un utilisateur se logge (avec un couple {login, mot de passe})
38 login([{login
, Login
}, {password
, Password
}]) ->
39 loginUser(euphorik_minichat:user_by_login_password(Login
, Password
));
40 % Un utilisateur se logge (avec un cookie)
41 login([{cookie
, Cookie
}]) ->
42 loginUser(euphorik_minichat:user_by_cookie(Cookie
)).
44 loginUser({ok
, User
}) ->
45 euphorik_minichat:update_date_derniere_connexion(User#user
.id
),
46 json_reponse_login_ok(User
);
48 erreur("Erreur login").
51 % Renvoie un string() représentant un cookie en base 36. Il y a 10^32 possibillités.
54 random:seed(A1
, A2
, A3
),
55 erlang:integer_to_list(random:uniform(math:pow(10, 32)), 36).
58 % Un utilisateur se délogge.
63 % Modification du profile.
72 {main_page
, Main_page
},
73 {conversations
, {array
, Conversations_json
}}
76 % est-ce que les messages auquel on répond existent ?
77 Conversations
= lists:foldr(
78 fun({struct
, [{root
, Root
}, {page
, Page
}]}, Acc
) ->
79 Message_existe
= euphorik_minichat:message_existe(Root
),
89 case euphorik_minichat:set_profile(Cookie
, Login
, Password
, Pseudo
, Email
, Css
, Main_page
, Conversations
) of
93 erreur("Login déjà pris");
95 erreur("Impossible de mettre à jour le profile")
99 % Renvoie les messages appropriés.
100 % last_message id et cookie sont facultatifs
101 % TODO : erreur : {badmatch,false}
103 Cookie
= case lists:keysearch(cookie
, 1, Data
) of {value
, {_
, C
}} -> C
; _
-> inconnu
end,
104 Last_message_id
= case lists:keysearch(last_message_id
, 1, Data
) of {value
, {_
, Id
}} -> Id
; _
-> 0 end,
105 {value
, {_
, Message_count
}} = lists:keysearch(message_count
, 1, Data
),
106 Main_page
= case lists:keysearch(main_page
, 1, Data
) of {value
, {_
, P
}} -> P
; _
-> 1 end,
107 {value
, {_
, {array
, Conversations_json
}}} = lists:keysearch(conversations
, 1, Data
),
108 Conversations
= lists:map(fun({struct
, [{root
, Racine
}, {page
, Page
}]}) -> {Racine
, Page
} end, Conversations_json
),
109 User
= case euphorik_minichat:user_by_cookie(Cookie
) of
114 {reply
, "new_message"},
115 {conversations
, {array
,
116 % accrochez-vous ca va siouxer ;)
120 {last_page
, not Plus
},
123 fun({Mess
, Repond_a
}) ->
124 Est_proprietaire
= User
=/= inconnu andalso User#user
.id
=:= Mess#minichat
.auteur_id
,
125 A_repondu_a_message
= User
=/= inconnu andalso
euphorik_minichat:a_repondu_a_message(User#user
.id
, Mess#minichat
.id
),
126 Est_une_reponse_a_user
= User
=/= inconnu andalso
euphorik_minichat:est_une_reponse_a_user(User#user
.id
, Mess#minichat
.id
),
127 % io:format("Repond_a : ~p~n", [Repond_a]),
129 if Mess#minichat
.auteur_id
=:= 0 ->
132 {ok
, U2
} = euphorik_minichat:user_by_id(Mess#minichat
.auteur_id
),
136 {id
, Mess#minichat
.id
},
137 {date, format_date(Mess#minichat
.date)},
138 {system
, Mess#minichat
.auteur_id
=:= 0},
139 {owner
, Est_proprietaire
},
140 {answered
, A_repondu_a_message
},
141 {is_a_reply
, Est_une_reponse_a_user
},
142 {nick
, Mess#minichat
.pseudo
},
143 {login
, if User_mess
=:= inconnu
-> Mess#minichat
.pseudo
; true
-> User_mess#user
.login
end},
144 {content
, Mess#minichat
.contenu
},
145 {answer_to
, {array
, lists:map(
147 {ok
, M
} = euphorik_minichat:message_by_id(Id_mess
),
148 {ok
, User_reponse
} = euphorik_minichat:user_by_mess(M#minichat
.id
),
149 {struct
, [{id
, M#minichat
.id
}, {nick
, M#minichat
.pseudo
}, {login
, User_reponse#user
.login
}]}
160 euphorik_minichat_conversation:conversations(
171 % Un utilisateur envoie un message
177 {answer_to
, {array
, Answer_to
}}
180 case euphorik_minichat:user_by_cookie(Cookie
) of
182 Strip_content
= string:strip(Content
),
183 if (Strip_content
=:= []) ->
184 erreur("Message vide");
186 % TODO : non-atomique (update_pseudo+nouveau_message)
187 euphorik_minichat:update_pseudo_user(User#user
.id
, Nick
),
188 case euphorik_minichat:nouveau_message(Strip_content
, User#user
.id
, Answer_to
) of
189 erreur
-> erreur("Impossible d'ajouter un nouveau message");
195 erreur("Utilisateur inconnu")
199 % Construit une erreur
204 {error_message
, Message
}
209 % Formatage d'une heure
210 % local_time() -> string
212 DateLocal
= calendar:now_to_local_time(Date
),
213 DateNowLocal
= calendar:local_time(),
214 {{Annee
, Mois
, Jour
}, {Heure
, Minute
, Seconde
}} = DateLocal
,
215 {{AnneeNow
, _
, _
}, {_
, _
, _
}} = DateNowLocal
,
216 Hier
= calendar:date_to_gregorian_days(element(1, DateLocal
)) =:= calendar:date_to_gregorian_days(element(1, DateNowLocal
)) - 1,
218 if element(1, DateLocal
) =:= element(1, DateNowLocal
) ->
222 Annee
=:= AnneeNow
->
223 io_lib:format("~2.10.0B/~2.10.0B ", [Jour
, Mois
]);
225 io_lib:format("~2.10.0B/~2.10.0B/~B ", [Jour
, Mois
, Annee
])
227 io_lib:format("~2.10.0B:~2.10.0B:~2.10.0B", [Heure
, Minute
, Seconde
])
231 %%%%%%%%% <Réponses JSON> %%%%%%%%%
234 {struct
, [{reply
, "ok"}]}.
237 json_reponse_login_ok(User
) ->
241 {status
, if (User#user
.password
=/= []) and (User#user
.login
=/= []) -> "auth_registered"; true
-> "auth_not_registered" end},
242 {cookie
, User#user
.cookie
},
244 {nick
, User#user
.pseudo
},
245 {login
, User#user
.login
},
246 {email
, User#user
.email
},
247 {css
, User#user
.css
},
248 {main_page
, User#user
.page_principale
},
255 {root
, element(1, C
)},
256 {page
, element(2, C
)}
260 User#user
.conversations
268 %%%%%%%%% </réponses JSON> %%%%%%%%%