put_troll/1,
mod_troll/1,
del_troll/1,
+ unban_ip/1,
+ list_banned_ips/1,
erreur/1
-]).\r
-
+]).
-include_lib("xmerl/include/xmerl.hrl").
-include("../include/euphorik_bd.hrl").\r
-include("../include/euphorik_defines.hrl").\r
wait_event_page_chat(User, Racines_conversations, Message_count, Last_message_id, Main_page, Troll_id) ->
- % est-ce qu'il y a des nouveaux messages ?
- case euphorik_minichat_conversation:conversations(Racines_conversations, Message_count, Last_message_id, Main_page) of
- vide ->
- % est-ce que le troll est à jour ?
- case euphorik_bd:current_troll() of
- Current when is_record(Current, troll), Current#troll.id =/= Troll_id ->
- {struct, [
- {reply, "new_troll"},
- {troll_id, Current#troll.id},
- {content, Current#troll.content}
- ]};
- _ ->
+ % est-ce que le troll est à jour ?
+ case euphorik_bd:current_troll() of
+ Current when is_record(Current, troll), Current#troll.id =/= Troll_id ->
+ {struct, [
+ {reply, "new_troll"},
+ {troll_id, Current#troll.id},
+ {content, Current#troll.content}
+ ]};
+ _ ->
+ % est-ce qu'il y a des nouveaux messages ?
+ case euphorik_minichat_conversation:conversations(Racines_conversations, Message_count, Last_message_id, Main_page) of
+ vide ->
wait_event_bd_page_chat(),
% TODO : l'appel est-il bien tail-recursive ?
- wait_event_page_chat(User, Racines_conversations, Message_count, Last_message_id, Main_page, Troll_id)
- end;
- Conversations ->
- % accrochez-vous ca va siouxer ;)
- {struct, [
- {reply, "new_messages"},
- {conversations, {array,
- lists:map(
- fun({Conv, Plus}) ->
- {struct, [
- {last_page, not Plus},
- {messages, {array,
- lists:map(
- fun({Mess, Repond_a}) ->
- Est_proprietaire = User =/= inconnu andalso User#user.id =:= Mess#minichat.auteur_id,
- A_repondu_a_message = User =/= inconnu andalso euphorik_bd:a_repondu_a_message(User#user.id, Mess#minichat.id),
- Est_une_reponse_a_user = User =/= inconnu andalso euphorik_bd:est_une_reponse_a_user(User#user.id, Mess#minichat.id),
- {ok, User_mess } = euphorik_bd:user_by_id(Mess#minichat.auteur_id),
- {struct, [
- {id, Mess#minichat.id},
- {user_id, User_mess#user.id},
- {date, format_date(Mess#minichat.date)},
- {system, Mess#minichat.auteur_id =:= 0},
- {owner, Est_proprietaire},
- {answered, A_repondu_a_message},
- {is_a_reply, Est_une_reponse_a_user},
- {nick, Mess#minichat.pseudo},
- {login, User_mess#user.login},
- {content, Mess#minichat.contenu},
- {answer_to, {array, lists:map(
- fun(Id_mess) ->
- {ok, M} = euphorik_bd:message_by_id(Id_mess),
- {ok, User_reponse} = euphorik_bd:user_by_mess(M#minichat.id),
- {struct, [{id, M#minichat.id}, {nick, M#minichat.pseudo}, {login, User_reponse#user.login}]}
- end,
- Repond_a
- )}},
- {ek_master, User_mess#user.ek_master}
- ]}
- end,
- Conv
- )
- }}
- ]}
- end,
- Conversations
- )
- }}
- ]}
+ wait_event_page_chat(User, Racines_conversations, Message_count, Last_message_id, Main_page, Troll_id);
+ Conversations ->
+ % accrochez-vous ca va siouxer ;)
+ {struct, [
+ {reply, "new_messages"},
+ {conversations, {array,
+ lists:map(
+ fun({Conv, Plus}) ->
+ {struct, [
+ {last_page, not Plus},
+ {messages, {array,
+ lists:map(
+ fun({Mess, Repond_a}) ->
+ Est_proprietaire = User =/= inconnu andalso User#user.id =:= Mess#minichat.auteur_id,
+ A_repondu_a_message = User =/= inconnu andalso euphorik_bd:a_repondu_a_message(User#user.id, Mess#minichat.id),
+ Est_une_reponse_a_user = User =/= inconnu andalso euphorik_bd:est_une_reponse_a_user(User#user.id, Mess#minichat.id),
+ {ok, User_mess } = euphorik_bd:user_by_id(Mess#minichat.auteur_id),
+ {struct, [
+ {id, Mess#minichat.id},
+ {user_id, User_mess#user.id},
+ {date, format_date(Mess#minichat.date)},
+ {system, Mess#minichat.auteur_id =:= 0},
+ {owner, Est_proprietaire},
+ {answered, A_repondu_a_message},
+ {is_a_reply, Est_une_reponse_a_user},
+ {nick, Mess#minichat.pseudo},
+ {login, User_mess#user.login},
+ {content, Mess#minichat.contenu},
+ {answer_to, {array, lists:map(
+ fun(Id_mess) ->
+ {ok, M} = euphorik_bd:message_by_id(Id_mess),
+ {ok, User_reponse} = euphorik_bd:user_by_mess(M#minichat.id),
+ {struct, [{id, M#minichat.id}, {nick, M#minichat.pseudo}, {login, User_reponse#user.login}]}
+ end,
+ Repond_a
+ )}},
+ {ek_master, User_mess#user.ek_master}
+ ]}
+ end,
+ Conv
+ )
+ }}
+ ]}
+ end,
+ Conversations
+ )
+ }}
+ ]}
+ end
end.
ok;
{mnesia_table_event, {write, troll, Troll, [Old_troll | _], _}} when Troll#troll.date_post =/= undefined, Old_troll#troll.date_post == undefined ->
ok;
+ {tcp_closed, _} ->
+ exit(normal);
_ ->
wait_event_bd_page_chat()
- % 60 minutes de timeout (le cas ou il n'y a que des consultations et jamais de post)
+ % 60 minutes de timeout (on ne sais jamais)
% Après 60 minutes de connexion, le client doit donc reétablir une connexion
- % TODO : pour être mieux : quand le socket se ferme alors un message devrait être envoyé et débloquer ce receive (demande en cours sur la mailing list de yaws)
after 1000 * 60 * 60 ->
timeout
end.
% TODO : non-atomique (update_pseudo+nouveau_message)
euphorik_bd:update_pseudo_user(User#user.id, Nick),
case euphorik_bd:nouveau_message(Strip_content, User#user.id, Answer_to) of
- erreur -> erreur("Impossible d'ajouter un nouveau message");
+ {erreur, R} -> erreur("Impossible d'ajouter un nouveau message. Raison : " ++ R);
_ ->
json_reponse_ok()
end
_ ->
erreur("Utilisateur inconnu")
end.
-
-
-% Formatage de minutes.
-% par exemple : "1min", "45min", "1h23min", "1jour 2h34min"
-format_minutes(Min) ->
- Jours = Min div (60 * 24),
- Heures = Min rem (60 * 24) div 60,
- Minutes = Min rem (60),
- if Jours =/= 0 -> integer_to_list(Jours) ++ "Jour" ++ if Jours > 1 -> "s"; true -> "" end ++ " "; true -> "" end ++
- if Heures =/= 0 -> integer_to_list(Heures) ++ "h"; true -> "" end ++
- if Minutes == 0 ->
- "";
- true ->
- lists:flatten(io_lib:format(if Jours =:= 0, Heures =:= 0 -> "~w"; true -> "~2.2.0w" end, [Minutes])) ++ "min"
- end.
% bannissement d'un utilisateur (son ip est bannie)
User1#user.pseudo,
if Reason =/= [] -> " - Raison: " ++ Reason; true -> "" end
]
- )));
+ ))),
+ json_reponse_ok();
{ok, User2 = #user{ek_master = false}} ->
euphorik_bd:nouveau_message_sys(lists:flatten(io_lib:format("~s se fait slaper par ~s.~s",
[
erreur("Seul les ekMaster peuvent proposer des trolls")
end.
+
+unban_ip(
+ [
+ {cookie, Cookie},
+ {ip, IP}
+ ]
+) ->
+ case euphorik_bd:user_by_cookie(Cookie) of
+ {ok, #user{ek_master = true}} ->
+ euphorik_bd:deban(unserialize_ip(IP)),
+ json_reponse_ok();
+ _ ->
+ erreur("Seul les ekMaster peuvent connaitre la liste des ips bannies")
+ end.
+
+
+list_banned_ips(
+ [
+ {cookie, Cookie}
+ ]
+) ->
+ case euphorik_bd:user_by_cookie(Cookie) of
+ {ok, #user{ek_master = true}} ->
+ {
+ struct,
+ [
+ {reply, "list_banned_ips"},
+ {list, {array, lists:map(
+ fun({IP, T, Users}) ->
+ {struct,
+ [
+ {ip, serialize_ip(IP)},
+ {remaining_time, format_minutes(T)},
+ {users, {array, lists:map(
+ fun({Pseudo, Login}) ->
+ {struct,
+ [
+ {nick, Pseudo},
+ {login, Login}
+ ]
+ }
+ end,
+ Users
+ )}}
+ ]
+ }
+ end,
+ euphorik_bd:list_ban()
+ )}}
+ ]
+ };
+ _ ->
+ erreur("Seul les ekMaster peuvent connaitre la liste des ips bannies")
+ end.
+
% Construit une erreur
erreur(Message) ->
]
}.
+
+serialize_ip(IP) ->
+ lists:flatten(io_lib:format("~w.~w.~w.~w", tuple_to_list(IP))).
+
+
+unserialize_ip(IP) ->
+ case io_lib:fread("~d.~d.~d.~d", IP) of
+ {ok, [A, B, C, D], []} -> {A, B, C, D};
+ _ -> erreur
+ end.
+
+
+% Formatage de minutes.
+% par exemple : "1min", "45min", "1h23min", "1jour 2h34min"
+format_minutes(Min) ->
+ Jours = Min div (60 * 24),
+ Heures = Min rem (60 * 24) div 60,
+ Minutes = Min rem (60),
+ if Jours =/= 0 -> integer_to_list(Jours) ++ " Jour" ++ if Jours > 1 -> "s"; true -> "" end ++ " "; true -> "" end ++
+ if Heures =/= 0 -> integer_to_list(Heures) ++ " heure" ++ if Heures > 1 -> "s"; true -> "" end; true -> "" end ++
+ if Minutes == 0 ->
+ "";
+ true ->
+ integer_to_list(Minutes) ++ " minute" ++ if Minutes > 1 -> "s"; true -> "" end
+ end.
+
\r
% Formatage d'une heure\r
% local_time() -> string\r
projects / euphorik.git / blobdiff