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
).
22 -include_lib("xmerl/include/xmerl.hrl").
23 -include("../include/euphorik_bd.hrl").
24 -include("../include/euphorik_defines.hrl").
27 % Une utilisateur s'enregistre avec un tuple {Login, Password}.
28 register([{login
, Login
}, {password
, Password
}], IP
) ->
29 Can_register
= euphorik_bd:can_register(IP
),
31 case euphorik_bd:user_by_login(Login
) of
33 erreur("Login déjà existant");
35 User
= euphorik_bd:nouveau_user(Login
, Password
, generer_cookie()),
36 euphorik_bd:update_ip(User#user
.id
, IP
),
37 json_reponse_login_ok(User
)
40 erreur_register_flood()
42 % Enregistrement sans {Login, Password}
44 Can_register
= euphorik_bd:can_register(IP
),
46 User
= euphorik_bd:nouveau_user("<nick>", generer_cookie()),
47 euphorik_bd:update_ip(User#user
.id
, IP
),
48 json_reponse_login_ok(User
);
50 erreur_register_flood()
53 erreur_register_flood() ->
54 erreur("Trop de register (flood)").
57 % Un utilisateur se logge (avec un couple {login, mot de passe})
58 login([{login
, Login
}, {password
, Password
}], IP
) ->
59 loginUser(euphorik_bd:user_by_login_password(Login
, Password
), IP
);
60 % Un utilisateur se logge (avec un cookie)
61 login([{cookie
, Cookie
}], IP
) ->
62 loginUser(euphorik_bd:user_by_cookie(Cookie
), IP
).
64 loginUser({ok
, User
}, IP
) ->
65 euphorik_bd:update_ip(User#user
.id
, IP
),
66 euphorik_bd:update_date_derniere_connexion(User#user
.id
),
67 json_reponse_login_ok(User
);
69 % ajoute un délais d'attente (TODO : un autre moyen plus élégant ?)
71 erreur("Erreur login")
75 % Renvoie un string() représentant un cookie en base 36. Il y a 10^32 possibillités.
78 random:seed(A1
, A2
, A3
),
79 erlang:integer_to_list(random:uniform(math:pow(10, 32)), 36).
82 % Un utilisateur se délogge.
87 % Modification du profile.
96 {nick_format
, Nick_format_str
},
97 {main_page
, Main_page
},
98 {conversations
, {array
, Conversations_json
}}
101 % est-ce que les messages auquel on répond existent ?
102 Conversations
= lists:foldr(
103 fun({struct
, [{root
, Root
}, {page
, Page
}]}, Acc
) ->
104 Message_existe
= euphorik_bd:message_existe(Root
),
106 [{Root
, Page
} | Acc
];
114 case euphorik_bd:set_profile(Cookie
, Login
, Password
, Pseudo
, Email
, Css
, list_to_atom(Nick_format_str
), Main_page
, Conversations
) of
118 erreur("Login déjà pris");
120 erreur("Impossible de mettre à jour le profile")
124 % Renvoie les messages appropriés.
125 % last_message id et cookie sont facultatifs
126 wait_event([{page
, "chat"} | Data
]) ->
127 Cookie
= case lists:keysearch(cookie
, 1, Data
) of {value
, {_
, C
}} -> C
; _
-> inconnu
end,
128 Last_message_id
= case lists:keysearch(last_message_id
, 1, Data
) of {value
, {_
, Id
}} -> Id
; _
-> 0 end,
129 {value
, {_
, Message_count
}} = lists:keysearch(message_count
, 1, Data
),
130 Main_page
= case lists:keysearch(main_page
, 1, Data
) of {value
, {_
, P
}} -> P
; _
-> 1 end,
131 {value
, {_
, {array
, Conversations_json
}}} = lists:keysearch(conversations
, 1, Data
),
132 Conversations
= lists:map(
133 fun({struct
, [{root
, Racine
}, {page
, Page
} | Reste
]}) ->
134 Last_mess_conv
= case Reste
of [{last_message_id
, L
}] -> L
; _
-> 0 end,
135 {Racine
, Page
, Last_mess_conv
}
139 User
= case euphorik_bd:user_by_cookie(Cookie
) of
144 {reply
, "new_message"},
145 {conversations
, {array
,
146 % accrochez-vous ca va siouxer ;)
150 {last_page
, not Plus
},
153 fun({Mess
, Repond_a
}) ->
154 Est_proprietaire
= User
=/= inconnu andalso User#user
.id
=:= Mess#minichat
.auteur_id
,
155 A_repondu_a_message
= User
=/= inconnu andalso
euphorik_bd:a_repondu_a_message(User#user
.id
, Mess#minichat
.id
),
156 Est_une_reponse_a_user
= User
=/= inconnu andalso
euphorik_bd:est_une_reponse_a_user(User#user
.id
, Mess#minichat
.id
),
157 {ok
, User_mess
} = euphorik_bd:user_by_id(Mess#minichat
.auteur_id
),
159 {id
, Mess#minichat
.id
},
160 {user_id
, User_mess#user
.id
},
161 {date, format_date(Mess#minichat
.date)},
162 {system
, Mess#minichat
.auteur_id
=:= 0},
163 {owner
, Est_proprietaire
},
164 {answered
, A_repondu_a_message
},
165 {is_a_reply
, Est_une_reponse_a_user
},
166 {nick
, Mess#minichat
.pseudo
},
167 {login
, User_mess#user
.login
},
168 {content
, Mess#minichat
.contenu
},
169 {answer_to
, {array
, lists:map(
171 {ok
, M
} = euphorik_bd:message_by_id(Id_mess
),
172 {ok
, User_reponse
} = euphorik_bd:user_by_mess(M#minichat
.id
),
173 {struct
, [{id
, M#minichat
.id
}, {nick
, M#minichat
.pseudo
}, {login
, User_reponse#user
.login
}]}
177 {ek_master
, User_mess#user
.ek_master
}
185 euphorik_minichat_conversation:conversations(
194 wait_event([{page
, "admin"}, {last_troll
, Last_troll
}]) ->
195 case euphorik_bd:trolls(Last_troll
) of
199 {reply
, "troll_modified"},
200 {troll_id
, Troll#troll
.id
},
201 {content
, Troll#troll
.content
}
207 {reply
, "troll_added"},
213 {troll_id
, T#troll
.id
},
214 {content
, T#troll
.content
}
226 {reply
, "troll_deleted"},
234 erreur("Page inconnue").
237 % Un utilisateur envoie un message
243 {answer_to
, {array
, Answer_to
}}
246 case euphorik_bd:user_by_cookie(Cookie
) of
248 case euphorik_bd:est_banni(User#user
.id
) of
249 {true
, Temps_restant
} ->
250 erreur("Vous êtes banni pour encore " ++ format_minutes(Temps_restant
));
252 Strip_content
= string:strip(Content
),
253 if Strip_content
=:= [] ->
254 erreur("Message vide");
256 % TODO : non-atomique (update_pseudo+nouveau_message)
257 euphorik_bd:update_pseudo_user(User#user
.id
, Nick
),
258 case euphorik_bd:nouveau_message(Strip_content
, User#user
.id
, Answer_to
) of
259 erreur
-> erreur("Impossible d'ajouter un nouveau message");
266 erreur("Utilisateur inconnu")
270 % Formatage de minutes.
271 % par exemple : "1min", "45min", "1h23min", "1jour 2h34min"
272 format_minutes(Min
) ->
273 Jours
= Min
div (60 * 24),
274 Heures
= Min
rem (60 * 24) div
60,
275 Minutes
= Min
rem (60),
276 if Jours
=/= 0 -> integer_to_list(Jours
) ++ "Jour" ++ if Jours
> 1 -> "s"; true
-> "" end ++ " "; true
-> "" end ++
277 if Heures
=/= 0 -> integer_to_list(Heures
) ++ "h"; true
-> "" end ++
281 lists:flatten(io_lib:format(if Jours
=:= 0, Heures
=:= 0 -> "~w"; true
-> "~2.2.0w" end, [Minutes
])) ++ "min"
285 % bannissement d'un utilisateur (son ip est bannie)
289 {duration
, Duration
},
293 % controle que l'utilisateur est un admin
294 case euphorik_bd:user_by_cookie(Cookie
) of
295 {ok
, User1
= #user
{ek_master
= true
}} ->
296 case euphorik_bd:user_by_id(User_id
) of
298 erreur("Il n'est pas possible de s'auto bannir");
299 {ok
, User2
= #user
{ek_master
= false
}} ->
300 euphorik_bd:ban(User2#user
.last_ip
, Duration
),
301 euphorik_bd:nouveau_message_sys(lists:flatten(io_lib:format("~s ~s est ~s pour ~s.~s",
304 if User2#user
.login
=:= [] -> ""; true
-> "(" ++ User2#user
.login
++ ")" end,
305 if Duration
=< 15 -> "kické"; true
-> "banni" end,
306 format_minutes(Duration
),
307 if Reason
=/= [] -> " - Raison: " ++ Reason
; true
-> "" end ++ "."
312 erreur("L'utilisateur est lui même un ekMaster");
314 erreur("Utilisateur à bannir inconnu")
317 erreur("Utilisateur inconnu ou non ek master")
321 % slapage d'un user (avertissement)
328 % controle que l'utilisateur est un admin
329 case euphorik_bd:user_by_cookie(Cookie
) of
330 {ok
, User1
= #user
{ek_master
= true
}} ->
331 case euphorik_bd:user_by_id(User_id
) of
333 euphorik_bd:nouveau_message_sys(lists:flatten(io_lib:format("~s s'auto slap~s.",
336 if Reason
=/= [] -> " - Raison: " ++ Reason
; true
-> "" end
339 {ok
, User2
= #user
{ek_master
= false
}} ->
340 euphorik_bd:nouveau_message_sys(lists:flatten(io_lib:format("~s se fait slaper par ~s.~s",
344 if Reason
=/= [] -> " - Raison: " ++ Reason
; true
-> "" end ++ "."
349 erreur("L'utilisateur est lui même un ekMaster");
351 erreur("Utilisateur à slaper inconnu")
354 erreur("Utilisateur inconnu ou non ek master")
364 % controle que l'utilisateur est un admin
365 case euphorik_bd:user_by_cookie(Cookie
) of
366 {ok
, User
= #user
{ek_master
= true
}} ->
367 case euphorik_bd:put_troll(User#user
.id
, Content
) of
368 max_troll_reached_per_user
->
369 erreur(lists:flatten(io_lib:format("Le nombre de troll maximum par utilisateur est atteint : ~w ", [?NB_MAX_TROLL_WAITING_BY_USER
])));
371 erreur(lists:flatten(io_lib:format("Le nombre de troll maximum en attente est atteint : ~w ", [?NB_MAX_TROLL_WAITING
])));
376 erreur("Seul les ekMaster peuvent proposer des trolls")
383 {troll_id
, Troll_id
},
387 % controle que l'utilisateur est un admin
388 case euphorik_bd:user_by_cookie(Cookie
) of
389 {ok
, User
= #user
{ek_master
= true
}} ->
390 User_id
= User#user
.id
,
391 case euphorik_bd:troll_by_id(Troll_id
) of
392 {ok
, #troll
{id_user
= User_id
}} ->
393 euphorik_bd:mod_troll(User#user
.id
, Content
),
396 erreur("Vous ne posséder pas ce troll")
399 erreur("Seul les ekMaster peuvent proposer des trolls")
409 % controle que l'utilisateur est un admin
410 case euphorik_bd:user_by_cookie(Cookie
) of
411 {ok
, User
= #user
{ek_master
= true
}} ->
412 User_id
= User#user
.id
,
413 case euphorik_bd:troll_by_id(Troll_id
) of
414 {ok
, #troll
{id_user
= User_id
}} ->
415 euphorik_bd:del_troll(User#user
.id
),
418 erreur("Vous ne posséder pas ce troll")
421 erreur("Seul les ekMaster peuvent proposer des trolls")
425 % Construit une erreur
430 {error_message
, Message
}
435 % Formatage d'une heure
436 % local_time() -> string
438 DateLocal
= calendar:now_to_local_time(Date
),
439 DateNowLocal
= calendar:local_time(),
440 {{Annee
, Mois
, Jour
}, {Heure
, Minute
, Seconde
}} = DateLocal
,
441 {{AnneeNow
, _
, _
}, {_
, _
, _
}} = DateNowLocal
,
442 Hier
= calendar:date_to_gregorian_days(element(1, DateLocal
)) =:= calendar:date_to_gregorian_days(element(1, DateNowLocal
)) - 1,
444 if element(1, DateLocal
) =:= element(1, DateNowLocal
) ->
448 Annee
=:= AnneeNow
->
449 io_lib:format("~2.10.0B/~2.10.0B ", [Jour
, Mois
]);
451 io_lib:format("~2.10.0B/~2.10.0B/~B ", [Jour
, Mois
, Annee
])
453 io_lib:format("~2.10.0B:~2.10.0B:~2.10.0B", [Heure
, Minute
, Seconde
])
458 {struct
, [{reply
, "ok"}]}.
461 json_reponse_login_ok(User
) ->
465 {status
, if (User#user
.password
=/= []) and (User#user
.login
=/= []) -> "auth_registered"; true
-> "auth_not_registered" end},
466 {cookie
, User#user
.cookie
},
468 {nick
, User#user
.pseudo
},
469 {login
, User#user
.login
},
470 {email
, User#user
.email
},
471 {css
, User#user
.css
},
472 {nick_format
, atom_to_list(User#user
.nick_format
)},
473 {main_page
, User#user
.page_principale
},
480 {root
, element(1, C
)},
481 {page
, element(2, C
)}
485 User#user
.conversations
489 {ek_master
, User#user
.ek_master
}