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
).
23 -include_lib("xmerl/include/xmerl.hrl").
24 -include("../include/euphorik_bd.hrl").
25 -include("../include/euphorik_defines.hrl").
28 % Une utilisateur s'enregistre avec un tuple {Login, Password}.
29 register([{login
, Login
}, {password
, Password
}], IP
) ->
30 Can_register
= euphorik_bd:can_register(IP
),
32 case euphorik_bd:user_by_login(Login
) of
34 erreur("Login déjà existant");
36 User
= euphorik_bd:nouveau_user(Login
, Password
, generer_cookie()),
37 euphorik_bd:update_ip(User#user
.id
, IP
),
38 json_reponse_login_ok(User
)
41 erreur_register_flood()
43 % Enregistrement sans {Login, Password}
45 Can_register
= euphorik_bd:can_register(IP
),
47 User
= euphorik_bd:nouveau_user("<nick>", generer_cookie()),
48 euphorik_bd:update_ip(User#user
.id
, IP
),
49 json_reponse_login_ok(User
);
51 erreur_register_flood()
54 erreur_register_flood() ->
55 erreur("Trop de register (flood)").
58 % Un utilisateur se logge (avec un couple {login, mot de passe})
59 login([{login
, Login
}, {password
, Password
}], IP
) ->
60 loginUser(euphorik_bd:user_by_login_password(Login
, Password
), IP
);
61 % Un utilisateur se logge (avec un cookie)
62 login([{cookie
, Cookie
}], IP
) ->
63 loginUser(euphorik_bd:user_by_cookie(Cookie
), IP
).
65 loginUser({ok
, User
}, IP
) ->
66 euphorik_bd:update_ip(User#user
.id
, IP
),
67 euphorik_bd:update_date_derniere_connexion(User#user
.id
),
68 json_reponse_login_ok(User
);
70 % ajoute un délais d'attente
72 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 % traitement des inputs
128 Cookie
= case lists:keysearch(cookie
, 1, Data
) of {value
, {_
, C
}} -> C
; _
-> inconnu
end,
129 Last_message_id
= case lists:keysearch(last_message_id
, 1, Data
) of {value
, {_
, Id
}} -> Id
; _
-> 0 end,
130 {value
, {_
, Message_count
}} = lists:keysearch(message_count
, 1, Data
),
131 Main_page
= case lists:keysearch(main_page
, 1, Data
) of {value
, {_
, P
}} -> P
; _
-> 1 end,
132 Troll_id
= case lists:keysearch(troll_id
, 1, Data
) of {value
, {_
, T
}} -> T
; _
-> 0 end,
133 {value
, {_
, {array
, Conversations_json
}}} = lists:keysearch(conversations
, 1, Data
),
134 Racines_conversations
= lists:map(
135 fun({struct
, [{root
, Racine
}, {page
, Page
} | Reste
]}) ->
136 Last_mess_conv
= case Reste
of [{last_message_id
, L
}] -> L
; _
-> 0 end,
137 {Racine
, Page
, Last_mess_conv
}
141 User
= case euphorik_bd:user_by_cookie(Cookie
) of
145 case {mnesia:subscribe({table
, minichat
, detailed
}), mnesia:subscribe({table
, troll
, detailed
})} of
146 {{error
, E
}, _
} -> E
;
147 {_
, {error
, E
}} -> E
;
149 % attente d'événements
150 R
= wait_event_page_chat(User
, Racines_conversations
, Message_count
, Last_message_id
, Main_page
, Troll_id
),
151 mnesia:unsubscribe({table
, minichat
, detailed
}),
152 mnesia:unsubscribe({table
, troll
, detailed
}),
155 wait_event([{page
, "admin"}, {last_troll
, Last_troll
}]) ->
156 case wait_event_page_admin(Last_troll
) of
157 banned_ips_refresh
->
160 {reply
, "banned_ips_refresh"}
166 {reply
, "troll_modified"},
167 {troll_id
, Troll#troll
.id
},
168 {content
, Troll#troll
.content
}
174 {reply
, "troll_added"},
178 {ok
, User
} = euphorik_bd:user_by_id(T#troll
.id_user
),
181 {troll_id
, T#troll
.id
},
182 {content
, T#troll
.content
},
183 {author
, User#user
.pseudo
},
184 {author_id
, User#user
.id
}
196 {reply
, "troll_deleted"},
204 erreur("Page inconnue").
207 wait_event_page_chat(User
, Racines_conversations
, Message_count
, Last_message_id
, Main_page
, Troll_id
) ->
208 % est-ce que le troll est à jour ?
209 case euphorik_bd:current_troll() of
210 Current
when is_record(Current
, troll
), Current#troll
.id
=/= Troll_id
->
212 {reply
, "new_troll"},
213 {troll_id
, Current#troll
.id
},
214 {content
, Current#troll
.content
}
217 % est-ce qu'il y a des nouveaux messages ?
218 case euphorik_minichat_conversation:conversations(Racines_conversations
, Message_count
, Last_message_id
, Main_page
) of
220 wait_event_bd_page_chat(),
221 % TODO : l'appel est-il bien tail-recursive ?
222 wait_event_page_chat(User
, Racines_conversations
, Message_count
, Last_message_id
, Main_page
, Troll_id
);
224 % accrochez-vous ca va siouxer ;)
226 {reply
, "new_messages"},
227 {conversations
, {array
,
231 {last_page
, not Plus
},
234 fun({Mess
, Repond_a
}) ->
235 Est_proprietaire
= User
=/= inconnu andalso User#user
.id
=:= Mess#minichat
.auteur_id
,
236 A_repondu_a_message
= User
=/= inconnu andalso
euphorik_bd:a_repondu_a_message(User#user
.id
, Mess#minichat
.id
),
237 Est_une_reponse_a_user
= User
=/= inconnu andalso
euphorik_bd:est_une_reponse_a_user(User#user
.id
, Mess#minichat
.id
),
238 {ok
, User_mess
} = euphorik_bd:user_by_id(Mess#minichat
.auteur_id
),
240 {id
, Mess#minichat
.id
},
241 {user_id
, User_mess#user
.id
},
242 {date, format_date(Mess#minichat
.date)},
243 {system
, Mess#minichat
.auteur_id
=:= 0},
244 {owner
, Est_proprietaire
},
245 {answered
, A_repondu_a_message
},
246 {is_a_reply
, Est_une_reponse_a_user
},
247 {nick
, Mess#minichat
.pseudo
},
248 {login
, User_mess#user
.login
},
249 {content
, Mess#minichat
.contenu
},
250 {answer_to
, {array
, lists:map(
252 {ok
, M
} = euphorik_bd:message_by_id(Id_mess
),
253 {ok
, User_reponse
} = euphorik_bd:user_by_mess(M#minichat
.id
),
254 {struct
, [{id
, M#minichat
.id
}, {nick
, M#minichat
.pseudo
}, {login
, User_reponse#user
.login
}]}
258 {ek_master
, User_mess#user
.ek_master
}
274 % Attend un événement lié à la page 'chat'.
275 wait_event_bd_page_chat() ->
276 receive % attente d'un post
277 {mnesia_table_event
, {write
, minichat
, _Message
, [], _
}} ->
279 {mnesia_table_event
, {write
, troll
, Troll
, [Old_troll
| _
], _
}} when Troll#troll
.date_post
=/= undefined
, Old_troll#troll
.date_post
== undefined
->
284 wait_event_bd_page_chat()
285 % 60 minutes de timeout (on ne sais jamais)
286 % Après 60 minutes de connexion, le client doit donc reétablir une connexion
287 after 1000 * 60 * 60 ->
292 % Attent un événement concernant la page admin
293 % Renvoie les trolls manquants posté après Last_id ou banned_ips_refresh.
294 % Si pas de trolls alors attend un événement tel qu'un ajout, une modification ou une suppression.
299 % ou banned_ips_refresh
301 wait_event_page_admin(Last_id
) ->
302 case {mnesia:subscribe({table
, troll
, detailed
}), mnesia:subscribe({table
, ip_table
, detailed
})} of
303 {{error
, E
}, _
} -> E
;
304 {_
, {error
, E
}} -> E
;
306 R
= case euphorik_bd:trolls(Last_id
) of
307 [] -> % pas de trolls
308 wait_event_page_admin();
312 mnesia:unsubscribe({table
, troll
, detailed
}),
313 mnesia:unsubscribe({table
, ip_table
, detailed
}),
317 wait_event_page_admin() ->
318 % s'il n'y a pas de trolls que l'utilisateur n'a pas connaissance alors on attend un événement
320 % cas où un troll est choisit comme courant
321 {mnesia_table_event
, {write
, troll
, Troll
, [Old_troll
| _
], _
}}
322 when Old_troll#troll
.date_post
=:= undefined
, Troll#troll
.date_post
=/= undefined
->
323 {del
, Troll#troll
.id
};
324 {mnesia_table_event
, {write
, troll
, Troll
, [_Old_troll
| _
], _
}} ->
326 {mnesia_table_event
, {write
, troll
, Troll
, [], _
}} ->
328 {mnesia_table_event
, {delete
, troll
, {troll
, Id
}, _
, _
}} ->
330 {mnesia_table_event
, {write
, ip_table
, IP
, [Old_IP
| _
], _
}}
331 when Old_IP#ip_table
.ban
=/= IP#ip_table
.ban
; Old_IP#ip_table
.ban_duration
=/= IP#ip_table
.ban_duration
->
336 wait_event_page_admin()
337 % 60 minutes de timeout (on ne sais jamais)
338 % Après 60 minutes de connexion, le client doit donc reétablir une connexion
339 after 1000 * 60 * 60 ->
344 % Un utilisateur envoie un message
350 {answer_to
, {array
, Answer_to
}}
353 case euphorik_bd:user_by_cookie(Cookie
) of
355 case euphorik_bd:est_banni(User#user
.id
) of
356 {true
, Temps_restant
} ->
357 erreur("Vous êtes banni pour encore " ++ format_minutes(Temps_restant
));
359 Strip_content
= string:strip(Content
),
360 if Strip_content
=:= [] ->
361 erreur("Message vide");
363 % TODO : non-atomique (update_pseudo+nouveau_message)
364 euphorik_bd:update_pseudo_user(User#user
.id
, Nick
),
365 case euphorik_bd:nouveau_message(Strip_content
, User#user
.id
, Answer_to
) of
366 {erreur
, R
} -> erreur("Impossible d'ajouter un nouveau message. Raison : " ++ R
);
373 erreur("Utilisateur inconnu")
377 % bannissement d'un utilisateur (son ip est bannie)
381 {duration
, Duration
},
385 % controle que l'utilisateur est un admin
386 case euphorik_bd:user_by_cookie(Cookie
) of
387 {ok
, User1
= #user
{ek_master
= true
}} ->
388 case euphorik_bd:user_by_id(User_id
) of
390 erreur("Il n'est pas possible de s'auto bannir");
391 {ok
, User2
= #user
{ek_master
= false
}} ->
392 euphorik_bd:ban(User2#user
.last_ip
, Duration
),
393 euphorik_bd:nouveau_message_sys(lists:flatten(io_lib:format("''~s~s'' est ~s pour ~s.~s",
396 if User2#user
.login
=:= [] -> ""; true
-> " (" ++ User2#user
.login
++ ")" end,
397 if Duration
=< 15 -> "kické"; true
-> "banni" end,
398 format_minutes(Duration
),
399 if Reason
=/= [] -> " - Raison: " ++ Reason
; true
-> "" end ++ "."
404 erreur("L'utilisateur est lui même un ekMaster");
406 erreur("Utilisateur à bannir inconnu")
409 erreur("Utilisateur inconnu ou non ek master")
413 % slapage d'un user (avertissement)
420 % controle que l'utilisateur est un admin
421 case euphorik_bd:user_by_cookie(Cookie
) of
422 {ok
, User1
= #user
{ek_master
= true
}} ->
423 case euphorik_bd:user_by_id(User_id
) of
425 euphorik_bd:nouveau_message_sys(lists:flatten(io_lib:format("~s s'auto slap~s.",
428 if Reason
=/= [] -> " - Raison: " ++ Reason
; true
-> "" end
432 {ok
, User2
= #user
{ek_master
= false
}} ->
433 euphorik_bd:nouveau_message_sys(lists:flatten(io_lib:format("~s se fait slaper par ~s.~s",
437 if Reason
=/= [] -> " - Raison: " ++ Reason
; true
-> "" end ++ "."
442 erreur("L'utilisateur est lui même un ekMaster");
444 erreur("Utilisateur à slaper inconnu")
447 erreur("Utilisateur inconnu ou non ek master")
457 % controle que l'utilisateur est un admin
458 case euphorik_bd:user_by_cookie(Cookie
) of
459 {ok
, User
= #user
{ek_master
= true
}} ->
460 case euphorik_bd:put_troll(User#user
.id
, Content
) of
461 max_troll_reached_per_user
->
462 erreur(lists:flatten(io_lib:format("Le nombre de troll maximum par utilisateur est atteint : ~w ", [?NB_MAX_TROLL_WAITING_BY_USER
])));
464 erreur(lists:flatten(io_lib:format("Le nombre de troll maximum en attente est atteint : ~w ", [?NB_MAX_TROLL_WAITING
])));
469 erreur("Seul les ekMaster peuvent proposer des trolls")
476 {troll_id
, Troll_id
},
480 % controle que l'utilisateur est un admin
481 case euphorik_bd:user_by_cookie(Cookie
) of
482 {ok
, User
= #user
{ek_master
= true
}} ->
483 User_id
= User#user
.id
,
484 case euphorik_bd:troll_by_id(Troll_id
) of
485 {ok
, #troll
{id_user
= User_id
}} ->
486 euphorik_bd:mod_troll(Troll_id
, Content
),
489 erreur("Vous ne posséder pas ce troll")
492 erreur("Seul les ekMaster peuvent proposer des trolls")
502 % controle que l'utilisateur est un admin
503 case euphorik_bd:user_by_cookie(Cookie
) of
504 {ok
, User
= #user
{ek_master
= true
}} ->
505 User_id
= User#user
.id
,
506 case euphorik_bd:troll_by_id(Troll_id
) of
507 {ok
, #troll
{id_user
= User_id
}} ->
508 euphorik_bd:del_troll(Troll_id
),
511 erreur("Vous ne posséder pas ce troll")
514 erreur("Seul les ekMaster peuvent proposer des trolls")
524 case euphorik_bd:user_by_cookie(Cookie
) of
525 {ok
, #user
{ek_master
= true
}} ->
526 euphorik_bd:deban(unserialize_ip(IP
)),
529 erreur("Seul les ekMaster peuvent connaitre la liste des ips bannies")
538 case euphorik_bd:user_by_cookie(Cookie
) of
539 {ok
, #user
{ek_master
= true
}} ->
543 {reply
, "list_banned_ips"},
544 {list, {array
, lists:map(
545 fun({IP
, T
, Users
}) ->
548 {ip
, serialize_ip(IP
)},
549 {remaining_time
, format_minutes(T
)},
550 {users
, {array
, lists:map(
551 fun({Pseudo
, Login
}) ->
564 euphorik_bd:list_ban()
569 erreur("Seul les ekMaster peuvent connaitre la liste des ips bannies")
573 % Construit une erreur
578 {error_message
, Message
}
584 lists:flatten(io_lib:format("~w.~w.~w.~w", tuple_to_list(IP
))).
587 unserialize_ip(IP
) ->
588 case io_lib:fread("~d.~d.~d.~d", IP
) of
589 {ok
, [A
, B
, C
, D
], []} -> {A
, B
, C
, D
};
594 % Formatage de minutes.
595 % par exemple : "1min", "45min", "1h23min", "1jour 2h34min"
596 format_minutes(Min
) ->
597 Jours
= Min
div (60 * 24),
598 Heures
= Min
rem (60 * 24) div
60,
599 Minutes
= Min
rem (60),
600 if Jours
=/= 0 -> integer_to_list(Jours
) ++ " Jour" ++ if Jours
> 1 -> "s"; true
-> "" end ++ " "; true
-> "" end ++
601 if Heures
=/= 0 -> integer_to_list(Heures
) ++ " heure" ++ if Heures
> 1 -> "s"; true
-> "" end; true
-> "" end ++
605 " " ++ integer_to_list(Minutes
) ++ " minute" ++ if Minutes
> 1 -> "s"; true
-> "" end
609 % Formatage d'une heure
610 % local_time() -> string
612 DateLocal
= calendar:now_to_local_time(Date
),
613 DateNowLocal
= calendar:local_time(),
614 {{Annee
, Mois
, Jour
}, {Heure
, Minute
, Seconde
}} = DateLocal
,
615 {{AnneeNow
, _
, _
}, {_
, _
, _
}} = DateNowLocal
,
616 Hier
= calendar:date_to_gregorian_days(element(1, DateLocal
)) =:= calendar:date_to_gregorian_days(element(1, DateNowLocal
)) - 1,
618 if element(1, DateLocal
) =:= element(1, DateNowLocal
) ->
622 Annee
=:= AnneeNow
->
623 io_lib:format("~2.10.0B/~2.10.0B ", [Jour
, Mois
]);
625 io_lib:format("~2.10.0B/~2.10.0B/~B ", [Jour
, Mois
, Annee
])
627 io_lib:format("~2.10.0B:~2.10.0B:~2.10.0B", [Heure
, Minute
, Seconde
])
632 {struct
, [{reply
, "ok"}]}.
635 json_reponse_login_ok(User
) ->
639 {status
, if (User#user
.password
=/= []) and (User#user
.login
=/= []) -> "auth_registered"; true
-> "auth_not_registered" end},
640 {cookie
, User#user
.cookie
},
642 {nick
, User#user
.pseudo
},
643 {login
, User#user
.login
},
644 {email
, User#user
.email
},
645 {css
, User#user
.css
},
646 {nick_format
, atom_to_list(User#user
.nick_format
)},
647 {main_page
, User#user
.page_principale
},
654 {root
, element(1, C
)},
655 {page
, element(2, C
)}
659 User#user
.conversations
663 {ek_master
, User#user
.ek_master
}