From: Greg Burri Date: Wed, 25 Jun 2008 19:57:37 +0000 (+0000) Subject: ADD ajout d'une version de protocole, chaque message du client est taggé avec la... X-Git-Tag: 1.1.0~114 X-Git-Url: http://git.euphorik.ch/index.cgi?a=commitdiff_plain;h=c01d54fd6a515a6f2860e3b18ff574afa5caa83b;p=euphorik.git ADD ajout d'une version de protocole, chaque message du client est taggé avec la version qu'il supporte --- diff --git a/doc/TODO.txt b/doc/TODO.txt index 483ea60..a9f994c 100755 --- a/doc/TODO.txt +++ b/doc/TODO.txt @@ -6,7 +6,12 @@ * Revoir le système de conversation : * Pouvoir extraire "toute la conversation" ou seulement une "sous conversation" (ce qui est actuellement le cas) * Tous les messages auquels on répond doivent faire partie de la conversation ! - * L'entête de la conversation contient le premier message (la racine) + * L'entête de la conversation contient : + * le premier message (la racine) + * des flèches et un numéro de page pour passer d'une page à l'autre + * un bouton "réduire" + * un bouton "créer lien" + * un bouton "fermer" * Possibilité de fermer temporairement une conversation (la réduire sous la forme d'un onglet) * lien vers une conversation : http://www.euphorik.ch/#conv=45 * Mettre un icon (genre sablier ou truc qui tourne à la apple) lorsque le chat se charge (également lors d'un changement de page par exemple) diff --git a/js/euphorik.js b/js/euphorik.js index 9e969f5..9e4d8ec 100755 --- a/js/euphorik.js +++ b/js/euphorik.js @@ -29,6 +29,7 @@ * Normalement 'const' à la place de 'var' mais non supporté par IE7. */ var conf = { + versionProtocole : 3, // version du protcole nickDefaut : "", nbMessageAffiche : 40, // (par page) pseudoDefaut : "", @@ -684,7 +685,7 @@ Client.prototype.supprimerConversation = function(num) Client.prototype.getJSONLogin = function(login, password) { return { - "action" : "authentification", + "header" : { "action" : "authentification", "version" : conf.versionProtocole }, "login" : login, "password" : password } @@ -693,7 +694,7 @@ Client.prototype.getJSONLogin = function(login, password) Client.prototype.getJSONLoginCookie = function() { return { - "action" : "authentification", + "header" : { "action" : "authentification", "version" : conf.versionProtocole }, "cookie" : this.cookie } } @@ -704,7 +705,7 @@ Client.prototype.getJSONLoginCookie = function() */ Client.prototype.getJSONEnregistrement = function(login, password) { - var mess = { "action" : "register" } + var mess = { "header" : { "action" : "register", "version" : conf.versionProtocole }} if (login != undefined && password != undefined) { @@ -726,7 +727,7 @@ Client.prototype.getJSONConversations = function() Client.prototype.getJSONProfile = function() { return { - "action" : "set_profile", + "header" : { "action" : "set_profile", "version" : conf.versionProtocole }, "cookie" : this.cookie, "login" : this.login, "password" : this.password, @@ -828,7 +829,6 @@ Client.prototype.enregistrement = function(login, password) Client.prototype.connexion = function(messageJson) { - ;; dumpObj(messageJson) thisClient = this jQuery.ajax( { @@ -840,7 +840,6 @@ Client.prototype.connexion = function(messageJson) success: function(data) { - ;; dumpObj(data) if (data["reply"] == "error") thisClient.util.messageDialogue(data["error_message"]) else @@ -910,7 +909,6 @@ Client.prototype.flush = function(async) var thisClient = this var ok = true - ;; dumpObj(this.getJSONProfile()) jQuery.ajax( { async: async, @@ -921,7 +919,6 @@ Client.prototype.flush = function(async) success: function(data) { - ;; dumpObj(data) if (data["reply"] == "error") { thisClient.util.messageDialogue(data["error_message"]) @@ -997,7 +994,7 @@ Client.prototype.slap = function(userId, raison) dataType: "json", data: this.util.jsonVersAction( { - "action" : "slap", + "header" : { "action" : "slap", "version" : conf.versionProtocole }, "cookie" : thisClient.cookie, "user_id" : userId, "reason" : raison @@ -1025,7 +1022,7 @@ Client.prototype.ban = function(userId, raison, minutes) dataType: "json", data: this.util.jsonVersAction( { - "action" : "ban", + "header" : { "action" : "ban", "version" : conf.versionProtocole }, "cookie" : thisClient.cookie, "duration" : minutes, "user_id" : userId, @@ -1051,7 +1048,7 @@ Client.prototype.kick = function(userId, raison) * classe permettant de gérer les événements (push serveur). * l'information envoyé est sous la forme : * { - * "action" : "wait_event" + * "header" : {"action" : "wait_event", "version" : }, * "page" : * [..] * } @@ -1105,15 +1102,13 @@ PageEvent.prototype.waitEvent = function(funSend, funsReceive) // TODO : ya pas mieux ? var dataToSend = { - "action" : "wait_event", + "header" : { "action" : "wait_event", "version" : conf.versionProtocole }, "page" : this.page } var poulpe = funSend() for (v in poulpe) dataToSend[v] = poulpe[v] - ;; dumpObj(dataToSend) - this.attenteCourante = jQuery.ajax({ type: "POST", url: "request", @@ -1123,9 +1118,7 @@ PageEvent.prototype.waitEvent = function(funSend, funsReceive) data: this.util.jsonVersAction(dataToSend), success: function(data) - { - ;; dumpObj(data) - + { funsReceive[data["reply"]](data) // rappel de la fonction dans 100 ms diff --git a/js/pageAdmin.js b/js/pageAdmin.js index 6f3b3db..8fc6e22 100644 --- a/js/pageAdmin.js +++ b/js/pageAdmin.js @@ -108,12 +108,11 @@ PageAdmin.prototype.posterTroll = function() var dataToSend = { - "action" : "put_troll", + "header" : { "action" : "put_troll", "version" : conf.versionProtocole }, "cookie" : this.client.cookie, "content" : content } - ;; dumpObj(dataToSend) jQuery.ajax( { type: "POST", @@ -122,9 +121,7 @@ PageAdmin.prototype.posterTroll = function() data: this.util.jsonVersAction(dataToSend), success: function(data) - { - ;; dumpObj(data) - + { if (data["reply"] == "ok") { $("#page form#nouveauTroll input.troll").val("") @@ -150,11 +147,10 @@ PageAdmin.prototype.majIPs = function() var dataToSend = { - "action" : "list_banned_ips", + "header" : { "action" : "list_banned_ips", "version" : conf.versionProtocole }, "cookie" : this.client.cookie } - ;; dumpObj(dataToSend) jQuery.ajax( { type: "POST", @@ -163,9 +159,7 @@ PageAdmin.prototype.majIPs = function() data: this.util.jsonVersAction(dataToSend), success: function(data) - { - ;; dumpObj(data) - + { if (data["reply"] == "list_banned_ips") { var XHTML = "" @@ -233,12 +227,11 @@ PageAdmin.prototype.deban = function(ip) var dataToSend = { - "action" : "unban", + "header" : { "action" : "unban", "version" : conf.versionProtocole }, "cookie" : this.client.cookie, "ip" : ip } - ;; dumpObj(dataToSend) jQuery.ajax( { type: "POST", @@ -248,11 +241,8 @@ PageAdmin.prototype.deban = function(ip) success: function(data) { - ;; dumpObj(data) if(data["reply"] == "error") - { thisPageAdmin.util.messageDialogue(data["error_message"]) - } } } ) @@ -410,13 +400,12 @@ Trolls.prototype.modifier = function(id, content) var dataToSend = { - "action" : "mod_troll", + "header" : { "action" : "mod_troll", "version" : conf.versionProtocole }, "cookie" : this.client.cookie, "troll_id" : id, "content" : content } - ;; dumpObj(dataToSend) jQuery.ajax( { type: "POST", @@ -426,7 +415,6 @@ Trolls.prototype.modifier = function(id, content) success: function(data) { - ;; dumpObj(data) if (data["reply"] == "error") { thisTrolls.util.messageDialogue(data["error_message"]) @@ -445,12 +433,11 @@ Trolls.prototype.supprimer = function(id) var dataToSend = { - "action" : "del_troll", + "header" : { "action" : "del_troll", "version" : conf.versionProtocole }, "cookie" : this.client.cookie, "troll_id" : id } - ;; dumpObj(dataToSend) jQuery.ajax( { type: "POST", @@ -460,7 +447,6 @@ Trolls.prototype.supprimer = function(id) success: function(data) { - ;; dumpObj(data) if (data["reply"] == "error") { thisTrolls.util.messageDialogue(data["error_message"]) diff --git a/js/pageMinichat.js b/js/pageMinichat.js index 8586bb5..2de1531 100755 --- a/js/pageMinichat.js +++ b/js/pageMinichat.js @@ -174,7 +174,7 @@ PageMinichat.prototype.getJSONMessage = function(pseudo, message) repondA.push(parseInt(id)) // FIXME : une propriété ne peut pas être de type int ? return { - "action" : "put_message", + "header" : { "action" : "put_message", "version" : conf.versionProtocole }, "cookie" : this.client.cookie, "nick" : pseudo, "content" : message, @@ -437,8 +437,8 @@ function Conversation(num, util, formateur, client) this.client = client this.idDernierMessageAffiche = 0 - this.messages = new Array() - this.messagesParId = new Object() + this.messages = [] + this.messagesParId = {} this.nbMessageMax = conf.nbMessageAffiche // Le nombre de message affiché par page @@ -472,11 +472,11 @@ Conversation.prototype.colorerEntetes = function() for (var i = 0; i < this.messages.length; i++) { if (this.messages[i].appartientAuClient) - messagesProprietaire += "#" + this.messages[i].getId() + "," + messagesProprietaire += "#" + this.messages[i].getId(this.getId()) + "," else if (this.messages[i].clientARepondu) - messagesRepondu += "#" + this.messages[i].getId() + "," + messagesRepondu += "#" + this.messages[i].getId(this.getId()) + "," else if (this.messages[i].estUneReponse) - messagesReponse += "#" + this.messages[i].getId() + "," + messagesReponse += "#" + this.messages[i].getId(this.getId()) + "," } $(messagesReponse).addClass("reponse") $(messagesRepondu).addClass("repondu") @@ -579,6 +579,11 @@ Conversation.prototype.viderMessages = function() $("#conversations #" + this.getId() + " .message").remove() } +Conversation.prototype.idMessageFromString = function(idString) +{ + return parseInt(idString.substr(4 + this.getId().length), 36) +} + /** * Après l'ajout d'un ou plusieurs message cette méthode est appelée afin * d'afficher les messages non-affichés. @@ -600,7 +605,7 @@ Conversation.prototype.flush = function(funClickOuvrirConv, funClickMessage) for (var i = 0; i < this.messages.length; i++) if (this.messages[i].id > this.idDernierMessageAffiche) { - XHTML += this.messages[i].XHTML(messagePair) + XHTML += this.messages[i].XHTML(messagePair, this.getId()) messagePair = !messagePair } @@ -613,7 +618,7 @@ Conversation.prototype.flush = function(funClickOuvrirConv, funClickMessage) { // FIXME : ya pas mieux ? var racine = $(event.target).text() - funClickOuvrirConv(parseInt(racine.substring(1, racine.length - 1), 36)) + funClickOuvrirConv(parseInt(idString.substring(1, racine.length - 1), 36)) return false } ) @@ -622,7 +627,7 @@ Conversation.prototype.flush = function(funClickOuvrirConv, funClickMessage) thisConversation.util.infoBulle("Extraction de la conversation complète", $(".extraireCompletement", this)) // l'id du message - var idMess = parseInt($(this).attr("id").substr(4), 36) + var idMess = thisConversation.idMessageFromString($(this).attr("id")) $(this).click( function(event) @@ -674,7 +679,7 @@ Conversation.prototype.flush = function(funClickOuvrirConv, funClickMessage) $(".pseudo", this).hover( function(e) { - var userId = parseInt($(".id", this).text()) + var userId = parseInt($(".id", this).text()) var element = $(this) var h = element.height() var offset = element.offset() @@ -730,6 +735,8 @@ Conversation.prototype.flush = function(funClickOuvrirConv, funClickMessage) */ Conversation.prototype.afficherConversation = function(id) { + var thisConversation = this + var message = this.messagesParId[id] if (message == undefined) return @@ -740,7 +747,7 @@ Conversation.prototype.afficherConversation = function(id) function() { var jq = $(this) - var statut = mess[parseInt(jq.attr("id").substr(4), 36)] + var statut = mess[thisConversation.idMessageFromString(jq.attr("id"))] if (statut == undefined) jq.addClass("cache") else @@ -822,6 +829,10 @@ Messages.prototype.toggleMessageRepond = function(mess) */ Messages.prototype.enleverMessagesRepond = function() { + for (var messId in this.messagesRepond) + this.enleverMessageRepond(this.messagesRepond[messId]) + + // on réinitialise pour être sur que tout est bien enlevé this.messagesRepond = {} $("#conversations div.message").removeClass("repondEnEvidence") $("form#posterMessage #repondA .messages").empty() @@ -832,7 +843,6 @@ Messages.prototype.enleverMessagesRepond = function() */ Messages.prototype.enleverMessageRepond = function(mess) { - console.log(mess) $("#" + mess.getId()).removeClass("repondEnEvidence") $("#" + mess.getId(this.prefixIdMessage)).remove() delete this.messagesRepond[mess.id] @@ -1105,6 +1115,8 @@ Messages.prototype.flush = function(numConv) { // met ou enlève la mise en evidence du message thisMessages.toggleMessageRepond(Mess) + // donne le focus à la ligne de saisie + $("form input.message").focus() } ) } diff --git a/modules/Makefile b/modules/Makefile index ebeff42..32edb72 100755 --- a/modules/Makefile +++ b/modules/Makefile @@ -1,62 +1,62 @@ -# Répertoire dans lequel se trouve les modules compilés (beam) -rep_ebin = ebin - -# Répertoire dans lequel se trouve les fichiers sources -rep_erl = erl - -# Répertoire dans lequel se trouve les fichier hrl (définition de record) -rep_include = include - -# Paramètre du compilateur -erlc_params = -I $(rep_include) -o $(rep_ebin) $< - -# Compilation de toute l'application euphorik +# Répertoire dans lequel se trouve les modules compilés (beam) +rep_ebin = ebin + +# Répertoire dans lequel se trouve les fichiers sources +rep_erl = erl + +# Répertoire dans lequel se trouve les fichier hrl (définition de record) +rep_include = include + +# Paramètre du compilateur +erlc_params = -I $(rep_include) -o $(rep_ebin) $< + +# Compilation de toute l'application euphorik all: $(rep_ebin)/euphorik_bd.beam \ -$(rep_ebin)/euphorik_minichat_conversation.beam \ -$(rep_ebin)/euphorik_requests.beam \ +$(rep_ebin)/euphorik_minichat_conversation.beam \ +$(rep_ebin)/euphorik_requests.beam \ $(rep_ebin)/euphorik_protocole.beam \ $(rep_ebin)/euphorik_daemon.beam \ $(rep_ebin)/euphorik_bd.beam \ $(rep_ebin)/euphorik_bd_update.beam \ $(rep_ebin)/euphorik_common.beam \ $(rep_ebin)/euphorik_test.beam - -# Module pour la gestion des données persistante la BD -$(rep_ebin)/euphorik_bd.beam: $(rep_erl)/euphorik_bd.erl $(rep_include)/euphorik_bd.hrl $(rep_include)/euphorik_defines.hrl + +# Module pour la gestion des données persistante la BD +$(rep_ebin)/euphorik_bd.beam: $(rep_erl)/euphorik_bd.erl $(rep_include)/euphorik_bd.hrl $(rep_include)/euphorik_defines.hrl erlc $(erlc_params) -# Module pour la mise à jour de la BD +# Module pour la mise à jour de la BD $(rep_ebin)/euphorik_bd_update.beam: $(rep_erl)/euphorik_bd_update.erl $(rep_erl)/euphorik_bd.erl $(rep_include)/euphorik_bd.hrl $(rep_include)/euphorik_defines.hrl - erlc $(erlc_params) + erlc $(erlc_params) # Module permettant l'extraction des conversations du minichat $(rep_ebin)/euphorik_minichat_conversation.beam: $(rep_erl)/euphorik_minichat_conversation.erl $(rep_include)/euphorik_bd.hrl - erlc $(erlc_params) - -# Module traitant les requêtes AJAX du client javascript d'euphorik -$(rep_ebin)/euphorik_requests.beam: $(rep_erl)/euphorik_requests.erl - erlc $(erlc_params) - -# Module interpretant les messages XML du client -$(rep_ebin)/euphorik_protocole.beam: $(rep_erl)/euphorik_protocole.erl $(rep_include)/euphorik_defines.hrl + erlc $(erlc_params) + +# Module traitant les requêtes AJAX du client javascript d'euphorik +$(rep_ebin)/euphorik_requests.beam: $(rep_erl)/euphorik_requests.erl $(rep_include)/euphorik_defines.hrl + erlc $(erlc_params) + +# Module interpretant les messages XML du client +$(rep_ebin)/euphorik_protocole.beam: $(rep_erl)/euphorik_protocole.erl $(rep_include)/euphorik_defines.hrl erlc $(erlc_params) -# Module pour la génération du captcha -#$(rep_ebin)/captcha.beam: $(rep_erl)/captcha.erl +# Module pour la génération du captcha +#$(rep_ebin)/captcha.beam: $(rep_erl)/captcha.erl # erlc $(erlc_params) - -# Module effectuant periodiquement certaines tâches -$(rep_ebin)/euphorik_daemon.beam: $(rep_erl)/euphorik_daemon.erl $(rep_include)/euphorik_defines.hrl + +# Module effectuant periodiquement certaines tâches +$(rep_ebin)/euphorik_daemon.beam: $(rep_erl)/euphorik_daemon.erl $(rep_include)/euphorik_defines.hrl erlc $(erlc_params) # Module avec plein de bordel dedant $(rep_ebin)/euphorik_common.beam: $(rep_erl)/euphorik_common.erl erlc $(erlc_params) -# Module dédié au tests +# Module dédié au tests $(rep_ebin)/euphorik_test.beam: $(rep_erl)/euphorik_test.erl $(rep_erl)/euphorik_bd.erl $(rep_include)/euphorik_bd.hrl - erlc $(erlc_params) - -# Suppression des modules compilés -clean: + erlc $(erlc_params) + +# Suppression des modules compilés +clean: rm ebin/*.beam diff --git a/modules/erl/euphorik_bd.erl b/modules/erl/euphorik_bd.erl index a0ffc3a..ed07a56 100755 --- a/modules/erl/euphorik_bd.erl +++ b/modules/erl/euphorik_bd.erl @@ -423,50 +423,62 @@ user_by_mess(Id) -> nouveau_message(Mess, Auteur_id, Repond_A_ids) -> % regarde si les id 'Repond_A' existent F = fun() -> - Repond_A = e( + Repond_a = e( q([M || M <- mnesia:table(minichat), lists:member(M#minichat.id, Repond_A_ids)]), [{tmpdir, ?KEY_SORT_TEMP_DIR}] - ), - Racine_id = case Repond_A of + ), + Racine_id = case Repond_a of [] -> undefined; - [M | _ ] -> M#minichat.racine_id - end, - % est-ce que l'auteur existe ? - case e(q([E || E <- mnesia:table(user), E#user.id =:= Auteur_id]), [{tmpdir, ?KEY_SORT_TEMP_DIR}]) of - [Auteur] -> - if length(Repond_A) =/= length(Repond_A_ids) -> - {erreur, "Un ou plusieurs messages introuvable"}; + [M | _ ] -> + Une_racine = M#minichat.racine_id, + % vérification que tout les messages de Repond_a possède la même racine (même conversation) + case lists:all(fun(R) -> R#minichat.racine_id =:= Une_racine end, Repond_a) of true -> - % comparaison entre la date du dernier poste et maintenant (gestion du flood) - Delta = delta_date_ms(Auteur#user.date_derniere_connexion, now()), - Nouvel_indice_flood = Auteur#user.indice_flood + if Delta =< ?DUREE_SPAM -> 2; true -> -1 end, - Auteur_maj = Auteur#user{ - indice_flood = if Nouvel_indice_flood > ?INDICE_SPAM_MAX -> ?INDICE_SPAM_MAX; Nouvel_indice_flood < 0 -> 0; true -> Nouvel_indice_flood end, - date_derniere_connexion = now() - }, - % est-ce que l'auteur à trop floodé ? - if Auteur#user.indice_flood =/= ?INDICE_SPAM_MAX, Auteur_maj#user.indice_flood =:= ?INDICE_SPAM_MAX, Delta =< ?DUREE_BLOCAGE_SPAM -> - mnesia:write(Auteur#user{indice_flood = Auteur_maj#user.indice_flood}), - nouveau_message_sys("''" ++ Auteur#user.pseudo ++ if Auteur#user.login =/= [] -> " (" ++ Auteur#user.login ++ ")"; true -> "" end ++ "'' est bloqué pour " ++ integer_to_list(trunc(?DUREE_BLOCAGE_SPAM / 1000)) ++ " secondes pour cause de flood."); - Auteur#user.indice_flood =:= ?INDICE_SPAM_MAX, Delta =< ?DUREE_BLOCAGE_SPAM -> - {erreur, "Bloqué pour cause de flood"}; - true -> - mnesia:write(Auteur_maj), - Id = nouvel_id(minichat), - inserer_reponses(Id, Repond_A_ids), - mnesia:write(#minichat{ - id = Id, - auteur_id = Auteur#user.id, - date = now(), - pseudo = Auteur#user.pseudo, - contenu = Mess, - racine_id = if Racine_id =:= undefined -> Id; true -> Racine_id end - }), - Id - end - end; + Une_racine; + _ -> + {erreur, "Les messages ne font pas partie de la même conversation"} + end + end, + case Racine_id of + {erreur, E} -> {erreur, E}; _ -> - {erreur, "L'auteur du message est introuvable"} + % est-ce que l'auteur existe ? + case e(q([E || E <- mnesia:table(user), E#user.id =:= Auteur_id]), [{tmpdir, ?KEY_SORT_TEMP_DIR}]) of + [Auteur] -> + if length(Repond_a) =/= length(Repond_A_ids) -> + {erreur, "Un ou plusieurs messages introuvable"}; + true -> + % comparaison entre la date du dernier poste et maintenant (gestion du flood) + Delta = delta_date_ms(Auteur#user.date_derniere_connexion, now()), + Nouvel_indice_flood = Auteur#user.indice_flood + if Delta =< ?DUREE_SPAM -> 2; true -> -1 end, + Auteur_maj = Auteur#user{ + indice_flood = if Nouvel_indice_flood > ?INDICE_SPAM_MAX -> ?INDICE_SPAM_MAX; Nouvel_indice_flood < 0 -> 0; true -> Nouvel_indice_flood end, + date_derniere_connexion = now() + }, + % est-ce que l'auteur à trop floodé ? + if Auteur#user.indice_flood =/= ?INDICE_SPAM_MAX, Auteur_maj#user.indice_flood =:= ?INDICE_SPAM_MAX, Delta =< ?DUREE_BLOCAGE_SPAM -> + mnesia:write(Auteur#user{indice_flood = Auteur_maj#user.indice_flood}), + nouveau_message_sys("''" ++ Auteur#user.pseudo ++ if Auteur#user.login =/= [] -> " (" ++ Auteur#user.login ++ ")"; true -> "" end ++ "'' est bloqué pour " ++ integer_to_list(trunc(?DUREE_BLOCAGE_SPAM / 1000)) ++ " secondes pour cause de flood."); + Auteur#user.indice_flood =:= ?INDICE_SPAM_MAX, Delta =< ?DUREE_BLOCAGE_SPAM -> + {erreur, "Bloqué pour cause de flood"}; + true -> + mnesia:write(Auteur_maj), + Id = nouvel_id(minichat), + inserer_reponses(Id, Repond_A_ids), + mnesia:write(#minichat{ + id = Id, + auteur_id = Auteur#user.id, + date = now(), + pseudo = Auteur#user.pseudo, + contenu = Mess, + racine_id = if Racine_id =:= undefined -> Id; true -> Racine_id end + }), + Id + end + end; + _ -> + {erreur, "L'auteur du message est introuvable"} + end end end, resultat_transaction(mnesia:transaction(F)). diff --git a/modules/erl/euphorik_protocole.erl b/modules/erl/euphorik_protocole.erl index c15ada1..448a20b 100755 --- a/modules/erl/euphorik_protocole.erl +++ b/modules/erl/euphorik_protocole.erl @@ -15,609 +15,610 @@ % % You should have received a copy of the GNU General Public License % along with Euphorik. If not, see . -% -% Ce module gére les différents messages envoyés par le client (javascript) via AJAX. -% Les messages donnés ainsi que les réponses sont au format JSON. -% @author G.Burri +% +% Ce module gére les différents messages envoyés par le client (javascript) via AJAX. +% Les messages donnés ainsi que les réponses sont au format JSON. +% @author G.Burri - --module(euphorik_protocole). --export([ - register/2, - login/2, - logout/1, - profile/1, - wait_event/1, - put_message/1, - ban/1, - slap/1, - put_troll/1, - mod_troll/1, - del_troll/1, - unban_ip/1, - list_banned_ips/1, - erreur/1 -]). + +-module(euphorik_protocole). +-export([ + register/2, + login/2, + logout/1, + profile/1, + wait_event/1, + put_message/1, + ban/1, + slap/1, + put_troll/1, + mod_troll/1, + del_troll/1, + unban_ip/1, + list_banned_ips/1, + erreur/1 +]). -include("../include/euphorik_bd.hrl"). -include("../include/euphorik_defines.hrl"). - - -% Une utilisateur s'enregistre avec un tuple {Login, Password}. -register([{login, Login}, {password, Password}], 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()), - euphorik_bd:update_ip(User#user.id, IP), - json_reponse_login_ok(User) - end; - true -> - erreur_register_flood() - end; -% Enregistrement sans {Login, Password} -register([], IP) -> - Can_register = euphorik_bd:can_register(IP), - if Can_register -> - User = euphorik_bd:nouveau_user("", generer_cookie()), - euphorik_bd:update_ip(User#user.id, IP), - json_reponse_login_ok(User); - true -> - erreur_register_flood() - end. - -erreur_register_flood() -> - erreur("Trop de 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); -% Un utilisateur se logge (avec un cookie) -login([{cookie, Cookie}], IP) -> - loginUser(euphorik_bd:user_by_cookie(Cookie), IP). - -loginUser({ok, 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"). - + +% Une utilisateur s'enregistre avec un tuple {Login, Password}. +register([{login, Login}, {password, Password}], 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()), + euphorik_bd:update_ip(User#user.id, IP), + json_reponse_login_ok(User) + end; + true -> + erreur_register_flood() + end; +% Enregistrement sans {Login, Password} +register([], IP) -> + Can_register = euphorik_bd:can_register(IP), + if Can_register -> + User = euphorik_bd:nouveau_user("", generer_cookie()), + euphorik_bd:update_ip(User#user.id, IP), + json_reponse_login_ok(User); + true -> + erreur_register_flood() + end. + +erreur_register_flood() -> + erreur("Trop de 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); +% Un utilisateur se logge (avec un cookie) +login([{cookie, Cookie}], IP) -> + loginUser(euphorik_bd:user_by_cookie(Cookie), IP). + +loginUser({ok, 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"). + % Renvoie un string() représentant un cookie en base 36. Il y a 10^32 possibillités. -generer_cookie() -> - {A1, A2, A3} = now(), +generer_cookie() -> + {A1, A2, A3} = now(), random:seed(A1, A2, A3), erlang:integer_to_list(random:uniform(math:pow(10, 32)), 36). - - -% Un utilisateur se délogge. -logout(_) -> - do_nothing. - - -% Modification du profile. -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}} - ] -) -> - % virage des messages qui n'existent pas - Conversations = lists:dropwhile( - fun(Message_id) -> - not euphorik_bd:message_existe(Message_id) - 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") - end. - - -% Renvoie les messages appropriés. -% last_message id et cookie sont facultatifs -wait_event([{page, "chat"} | Data]) -> - % traitement des inputs - Cookie = case lists:keysearch(cookie, 1, Data) of {value, {_, C}} -> C; _ -> inconnu end, - Last_message_id = case lists:keysearch(last_message_id, 1, Data) of {value, {_, Id}} -> Id; _ -> 0 end, - {value, {_, Message_count}} = lists:keysearch(message_count, 1, Data), - Main_page = case lists:keysearch(main_page, 1, Data) of {value, {_, P}} -> P; _ -> 1 end, - Troll_id = case lists:keysearch(troll_id, 1, Data) of {value, {_, T}} -> T; _ -> 0 end, - {value, {_, {array, Conversations_json}}} = lists:keysearch(conversations, 1, Data), - Racines_conversations = lists:map( - fun({struct, [{root, Racine}, {page, Page} | Reste]}) -> - Last_mess_conv = case Reste of [{last_message_id, L}] -> L; _ -> 0 end, - {Racine, Page, Last_mess_conv} - end, - Conversations_json - ), + + +% Un utilisateur se délogge. +logout(_) -> + do_nothing. + + +% Modification du profile. +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}} + ] +) -> + % virage des messages qui n'existent pas + Conversations = lists:dropwhile( + fun(Message_id) -> + not euphorik_bd:message_existe(Message_id) + 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") + end. + + +% Renvoie les messages appropriés. +% last_message id et cookie sont facultatifs +wait_event([{page, "chat"} | Data]) -> + % traitement des inputs + Cookie = case lists:keysearch(cookie, 1, Data) of {value, {_, C}} -> C; _ -> inconnu end, + Last_message_id = case lists:keysearch(last_message_id, 1, Data) of {value, {_, Id}} -> Id; _ -> 0 end, + {value, {_, Message_count}} = lists:keysearch(message_count, 1, Data), + Main_page = case lists:keysearch(main_page, 1, Data) of {value, {_, P}} -> P; _ -> 1 end, + Troll_id = case lists:keysearch(troll_id, 1, Data) of {value, {_, T}} -> T; _ -> 0 end, + {value, {_, {array, Conversations_json}}} = lists:keysearch(conversations, 1, Data), + Racines_conversations = lists:map( + fun({struct, [{root, Racine}, {page, Page} | Reste]}) -> + Last_mess_conv = case Reste of [{last_message_id, L}] -> L; _ -> 0 end, + {Racine, Page, Last_mess_conv} + end, + Conversations_json + ), User = case euphorik_bd:user_by_cookie(Cookie) of {ok, U} -> U; _ -> inconnu - end, - case {mnesia:subscribe({table, minichat, detailed}), mnesia:subscribe({table, troll, detailed})} of - {{error, E}, _} -> E; - {_, {error, E}} -> E; - _ -> - % attente d'événements - R = wait_event_page_chat(User, Racines_conversations, Message_count, Last_message_id, Main_page, Troll_id), - mnesia:unsubscribe({table, minichat, detailed}), - mnesia:unsubscribe({table, troll, detailed}), - R - end; -wait_event([{page, "admin"}, {last_troll, Last_troll}]) -> - case wait_event_page_admin(Last_troll) of - banned_ips_refresh -> - {struct, - [ - {reply, "banned_ips_refresh"} - ] - }; - {mod, Troll} -> - {struct, - [ - {reply, "troll_modified"}, - {troll_id, Troll#troll.id}, - {content, Troll#troll.content} - ] - }; - {add, Trolls} -> - {struct, - [ - {reply, "troll_added"}, - {trolls, {array, - lists:map( - fun(T) -> - {ok, User} = euphorik_bd:user_by_id(T#troll.id_user), - {struct, - [ - {troll_id, T#troll.id}, - {content, T#troll.content}, - {author, User#user.pseudo}, - {author_id, User#user.id} - ] - } - end, - Trolls - ) - }} - ] - }; - {del, Troll_id} -> - {struct, - [ - {reply, "troll_deleted"}, - {troll_id, Troll_id} - ] - }; - _ -> - erreur("timeout") - end; -wait_event(_) -> - erreur("Page inconnue"). - - -wait_event_page_chat(User, Racines_conversations, Message_count, Last_message_id, Main_page, Troll_id) -> - % 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}, - {message_id, euphorik_bd:message_id_associe(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(), - 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}, - {root, Mess#minichat.racine_id}, - {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. - - -% Attend un événement lié à la page 'chat'. -wait_event_bd_page_chat() -> - receive % attente d'un post - {mnesia_table_event, {write, minichat, _Message, [], _}} -> - 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 (on ne sais jamais) - % Après 60 minutes de connexion, le client doit donc reétablir une connexion - after 1000 * 60 * 60 -> - timeout - end. - - -% Attent un événement concernant la page admin -% Renvoie les trolls manquants posté après Last_id ou banned_ips_refresh. -% Si pas de trolls alors attend un événement tel qu'un ajout, une modification ou une suppression. -% renvoie : -% {mod, Troll} -% ou {add, [Trolls]} -% ou {del, Troll_id} -% ou banned_ips_refresh -% ou timeout -wait_event_page_admin(Last_id) -> - case {mnesia:subscribe({table, troll, detailed}), mnesia:subscribe({table, ip_table, detailed})} of - {{error, E}, _ } -> E; - {_, {error, E}} -> E; - _ -> - R = case euphorik_bd:trolls(Last_id) of - [] -> % pas de trolls - wait_event_page_admin(); - Trolls -> - {add, Trolls} - end, - mnesia:unsubscribe({table, troll, detailed}), - mnesia:unsubscribe({table, ip_table, detailed}), - R - end. - -wait_event_page_admin() -> - % s'il n'y a pas de trolls que l'utilisateur n'a pas connaissance alors on attend un événement - receive - % cas où un troll est choisit comme courant - {mnesia_table_event, {write, troll, Troll, [Old_troll | _], _}} - when Old_troll#troll.date_post =:= undefined, Troll#troll.date_post =/= undefined -> - {del, Troll#troll.id}; - {mnesia_table_event, {write, troll, Troll, [_Old_troll | _], _}} -> - {mod, Troll}; - {mnesia_table_event, {write, troll, Troll, [], _}} -> - {add, [Troll]}; - {mnesia_table_event, {delete, troll, {troll, Id}, _, _}} -> - {del, Id}; - {mnesia_table_event, {write, ip_table, IP, [Old_IP | _], _}} - when Old_IP#ip_table.ban =/= IP#ip_table.ban; Old_IP#ip_table.ban_duration =/= IP#ip_table.ban_duration -> - banned_ips_refresh; - {tcp_closed, _} -> - exit(normal); - _ -> - wait_event_page_admin() - % 60 minutes de timeout (on ne sais jamais) - % Après 60 minutes de connexion, le client doit donc reétablir une connexion - after 1000 * 60 * 60 -> - timeout - end. - - -% Un utilisateur envoie un message -put_message( - [ - {cookie, Cookie}, - {nick, Nick}, - {content, Content}, - {answer_to, {array, Answer_to}} - ] -) -> - case euphorik_bd:user_by_cookie(Cookie) of - {ok, User} -> - case euphorik_bd:est_banni(User#user.id) of - {true, Temps_restant} -> - erreur("Vous êtes banni pour encore " ++ format_minutes(Temps_restant)); - _ -> - Strip_content = string:strip(Content), - if Strip_content =:= [] -> - erreur("Message vide"); - true -> - % attention : 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, R} -> erreur("Impossible d'ajouter un nouveau message. Raison : " ++ R); - _ -> - json_reponse_ok() - end - end - end; - _ -> - erreur("Utilisateur inconnu") - end. - - -% bannissement d'un utilisateur (son ip est bannie) -ban( - [ - {cookie, Cookie}, - {duration, Duration}, - {user_id, User_id}, - {reason, Reason} - ]) -> - % controle que l'utilisateur est un admin - case euphorik_bd:user_by_cookie(Cookie) of - {ok, User1 = #user{ek_master = true}} -> - case euphorik_bd:user_by_id(User_id) of - {ok, User1} -> - erreur("Il n'est pas possible de s'auto bannir"); - {ok, User2 = #user{ek_master = false}} -> - euphorik_bd:ban(User2#user.last_ip, Duration), - euphorik_bd:nouveau_message_sys(lists:flatten(io_lib:format("''~s~s'' est ~s pour ~s.~s", - [ - User2#user.pseudo, - if User2#user.login =:= [] -> ""; true -> " (" ++ User2#user.login ++ ")" end, - if Duration =< 15 -> "kické"; true -> "banni" end, - format_minutes(Duration), - if Reason =/= [] -> " - Raison: " ++ Reason; true -> "" end ++ "." - ] - ))), - json_reponse_ok(); - {ok, _} -> - erreur("L'utilisateur est lui même un ekMaster"); - _ -> - erreur("Utilisateur à bannir inconnu") - end; - _ -> - erreur("Utilisateur inconnu ou non ek master") - end. - - -% slapage d'un user (avertissement) -slap( - [ - {cookie, Cookie}, - {user_id, User_id}, - {reason, Reason} - ]) -> - % controle que l'utilisateur est un admin - case euphorik_bd:user_by_cookie(Cookie) of - {ok, User1 = #user{ek_master = true}} -> - case euphorik_bd:user_by_id(User_id) of - {ok, User1} -> - euphorik_bd:nouveau_message_sys(lists:flatten(io_lib:format("~s s'auto slap~s.", - [ - 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", - [ - User2#user.pseudo, - User1#user.pseudo, - if Reason =/= [] -> " - Raison: " ++ Reason; true -> "" end ++ "." - ] - ))), - json_reponse_ok(); - {ok, _} -> - erreur("L'utilisateur est lui même un ekMaster"); - _ -> - erreur("Utilisateur à slaper inconnu") - end; - _ -> - erreur("Utilisateur inconnu ou non ek master") - end. - - -put_troll( - [ - {cookie, Cookie}, - {content, Content} - ] -) -> - % controle que l'utilisateur est un admin - case euphorik_bd:user_by_cookie(Cookie) of - {ok, User = #user{ek_master = true}} -> - case euphorik_bd:put_troll(User#user.id, Content) of - max_troll_reached_per_user -> - erreur(lists:flatten(io_lib:format("Le nombre de troll maximum par utilisateur est atteint : ~w ", [?NB_MAX_TROLL_WAITING_BY_USER]))); - max_troll_reached -> - erreur(lists:flatten(io_lib:format("Le nombre de troll maximum en attente est atteint : ~w ", [?NB_MAX_TROLL_WAITING]))); - _Id -> - json_reponse_ok() - end; - _ -> - erreur("Seul les ekMaster peuvent proposer des trolls") - end. - - -mod_troll( - [ - {cookie, Cookie}, - {troll_id, Troll_id}, - {content, Content} - ] -) -> - % controle que l'utilisateur est un admin - case euphorik_bd:user_by_cookie(Cookie) of - {ok, User = #user{ek_master = true}} -> - User_id = User#user.id, - case euphorik_bd:troll_by_id(Troll_id) of - {ok, #troll{id_user = User_id}} -> - euphorik_bd:mod_troll(Troll_id, Content), - json_reponse_ok(); - _ -> - erreur("Vous ne posséder pas ce troll") - end; - _ -> - erreur("Seul les ekMaster peuvent proposer des trolls") - end. - - -del_troll( - [ - {cookie, Cookie}, - {troll_id, Troll_id} - ] -) -> - % controle que l'utilisateur est un admin - case euphorik_bd:user_by_cookie(Cookie) of - {ok, User = #user{ek_master = true}} -> - User_id = User#user.id, - case euphorik_bd:troll_by_id(Troll_id) of - {ok, #troll{id_user = User_id}} -> - euphorik_bd:del_troll(Troll_id), - json_reponse_ok(); - _ -> - erreur("Vous ne posséder pas ce troll") - end; - _ -> - 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(euphorik_common: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, euphorik_common: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) -> - { - struct, [ - {reply, "error"}, - {error_message, Message} - ] - }. - - -% 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. - + end, + case {mnesia:subscribe({table, minichat, detailed}), mnesia:subscribe({table, troll, detailed})} of + {{error, E}, _} -> E; + {_, {error, E}} -> E; + _ -> + % attente d'événements + R = wait_event_page_chat(User, Racines_conversations, Message_count, Last_message_id, Main_page, Troll_id), + mnesia:unsubscribe({table, minichat, detailed}), + mnesia:unsubscribe({table, troll, detailed}), + R + end; +wait_event([{page, "admin"}, {last_troll, Last_troll}]) -> + case wait_event_page_admin(Last_troll) of + banned_ips_refresh -> + {struct, + [ + {reply, "banned_ips_refresh"} + ] + }; + {mod, Troll} -> + {struct, + [ + {reply, "troll_modified"}, + {troll_id, Troll#troll.id}, + {content, Troll#troll.content} + ] + }; + {add, Trolls} -> + {struct, + [ + {reply, "troll_added"}, + {trolls, {array, + lists:map( + fun(T) -> + {ok, User} = euphorik_bd:user_by_id(T#troll.id_user), + {struct, + [ + {troll_id, T#troll.id}, + {content, T#troll.content}, + {author, User#user.pseudo}, + {author_id, User#user.id} + ] + } + end, + Trolls + ) + }} + ] + }; + {del, Troll_id} -> + {struct, + [ + {reply, "troll_deleted"}, + {troll_id, Troll_id} + ] + }; + _ -> + erreur("timeout") + end; +wait_event(_) -> + erreur("Page inconnue"). + + +wait_event_page_chat(User, Racines_conversations, Message_count, Last_message_id, Main_page, Troll_id) -> + % 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}, + {message_id, euphorik_bd:message_id_associe(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(), + 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}, + {root, Mess#minichat.racine_id}, + {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. + + +% Attend un événement lié à la page 'chat'. +wait_event_bd_page_chat() -> + receive % attente d'un post + {mnesia_table_event, {write, minichat, _Message, [], _}} -> + 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 (on ne sais jamais) + % Après 60 minutes de connexion, le client doit donc reétablir une connexion + after 1000 * 60 * 60 -> + timeout + end. + + +% Attent un événement concernant la page admin +% Renvoie les trolls manquants posté après Last_id ou banned_ips_refresh. +% Si pas de trolls alors attend un événement tel qu'un ajout, une modification ou une suppression. +% renvoie : +% {mod, Troll} +% ou {add, [Trolls]} +% ou {del, Troll_id} +% ou banned_ips_refresh +% ou timeout +wait_event_page_admin(Last_id) -> + case {mnesia:subscribe({table, troll, detailed}), mnesia:subscribe({table, ip_table, detailed})} of + {{error, E}, _ } -> E; + {_, {error, E}} -> E; + _ -> + R = case euphorik_bd:trolls(Last_id) of + [] -> % pas de trolls + wait_event_page_admin(); + Trolls -> + {add, Trolls} + end, + mnesia:unsubscribe({table, troll, detailed}), + mnesia:unsubscribe({table, ip_table, detailed}), + R + end. + +wait_event_page_admin() -> + % s'il n'y a pas de trolls que l'utilisateur n'a pas connaissance alors on attend un événement + receive + % cas où un troll est choisit comme courant + {mnesia_table_event, {write, troll, Troll, [Old_troll | _], _}} + when Old_troll#troll.date_post =:= undefined, Troll#troll.date_post =/= undefined -> + {del, Troll#troll.id}; + {mnesia_table_event, {write, troll, Troll, [_Old_troll | _], _}} -> + {mod, Troll}; + {mnesia_table_event, {write, troll, Troll, [], _}} -> + {add, [Troll]}; + {mnesia_table_event, {delete, troll, {troll, Id}, _, _}} -> + {del, Id}; + {mnesia_table_event, {write, ip_table, IP, [Old_IP | _], _}} + when Old_IP#ip_table.ban =/= IP#ip_table.ban; Old_IP#ip_table.ban_duration =/= IP#ip_table.ban_duration -> + banned_ips_refresh; + {tcp_closed, _} -> + exit(normal); + _ -> + wait_event_page_admin() + % 60 minutes de timeout (on ne sais jamais) + % Après 60 minutes de connexion, le client doit donc reétablir une connexion + after 1000 * 60 * 60 -> + timeout + end. + + +% Un utilisateur envoie un message +% Answer_to est une liste d'id (int) +put_message( + [ + {cookie, Cookie}, + {nick, Nick}, + {content, Content}, + {answer_to, {array, Answer_to}} + ] +) -> + case euphorik_bd:user_by_cookie(Cookie) of + {ok, User} -> + case euphorik_bd:est_banni(User#user.id) of + {true, Temps_restant} -> + erreur("Vous êtes banni pour encore " ++ format_minutes(Temps_restant)); + _ -> + Strip_content = string:strip(Content), + if Strip_content =:= [] -> + erreur("Message vide"); + true -> + % attention : 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, R} -> erreur("Impossible d'ajouter un nouveau message. Raison : " ++ R); + _ -> + json_reponse_ok() + end + end + end; + _ -> + erreur("Utilisateur inconnu") + end. + + +% bannissement d'un utilisateur (son ip est bannie) +ban( + [ + {cookie, Cookie}, + {duration, Duration}, + {user_id, User_id}, + {reason, Reason} + ]) -> + % controle que l'utilisateur est un admin + case euphorik_bd:user_by_cookie(Cookie) of + {ok, User1 = #user{ek_master = true}} -> + case euphorik_bd:user_by_id(User_id) of + {ok, User1} -> + erreur("Il n'est pas possible de s'auto bannir"); + {ok, User2 = #user{ek_master = false}} -> + euphorik_bd:ban(User2#user.last_ip, Duration), + euphorik_bd:nouveau_message_sys(lists:flatten(io_lib:format("''~s~s'' est ~s pour ~s.~s", + [ + User2#user.pseudo, + if User2#user.login =:= [] -> ""; true -> " (" ++ User2#user.login ++ ")" end, + if Duration =< 15 -> "kické"; true -> "banni" end, + format_minutes(Duration), + if Reason =/= [] -> " - Raison: " ++ Reason; true -> "" end ++ "." + ] + ))), + json_reponse_ok(); + {ok, _} -> + erreur("L'utilisateur est lui même un ekMaster"); + _ -> + erreur("Utilisateur à bannir inconnu") + end; + _ -> + erreur("Utilisateur inconnu ou non ek master") + end. + + +% slapage d'un user (avertissement) +slap( + [ + {cookie, Cookie}, + {user_id, User_id}, + {reason, Reason} + ]) -> + % controle que l'utilisateur est un admin + case euphorik_bd:user_by_cookie(Cookie) of + {ok, User1 = #user{ek_master = true}} -> + case euphorik_bd:user_by_id(User_id) of + {ok, User1} -> + euphorik_bd:nouveau_message_sys(lists:flatten(io_lib:format("~s s'auto slap~s.", + [ + 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", + [ + User2#user.pseudo, + User1#user.pseudo, + if Reason =/= [] -> " - Raison: " ++ Reason; true -> "" end ++ "." + ] + ))), + json_reponse_ok(); + {ok, _} -> + erreur("L'utilisateur est lui même un ekMaster"); + _ -> + erreur("Utilisateur à slaper inconnu") + end; + _ -> + erreur("Utilisateur inconnu ou non ek master") + end. + + +put_troll( + [ + {cookie, Cookie}, + {content, Content} + ] +) -> + % controle que l'utilisateur est un admin + case euphorik_bd:user_by_cookie(Cookie) of + {ok, User = #user{ek_master = true}} -> + case euphorik_bd:put_troll(User#user.id, Content) of + max_troll_reached_per_user -> + erreur(lists:flatten(io_lib:format("Le nombre de troll maximum par utilisateur est atteint : ~w ", [?NB_MAX_TROLL_WAITING_BY_USER]))); + max_troll_reached -> + erreur(lists:flatten(io_lib:format("Le nombre de troll maximum en attente est atteint : ~w ", [?NB_MAX_TROLL_WAITING]))); + _Id -> + json_reponse_ok() + end; + _ -> + erreur("Seul les ekMaster peuvent proposer des trolls") + end. + + +mod_troll( + [ + {cookie, Cookie}, + {troll_id, Troll_id}, + {content, Content} + ] +) -> + % controle que l'utilisateur est un admin + case euphorik_bd:user_by_cookie(Cookie) of + {ok, User = #user{ek_master = true}} -> + User_id = User#user.id, + case euphorik_bd:troll_by_id(Troll_id) of + {ok, #troll{id_user = User_id}} -> + euphorik_bd:mod_troll(Troll_id, Content), + json_reponse_ok(); + _ -> + erreur("Vous ne posséder pas ce troll") + end; + _ -> + erreur("Seul les ekMaster peuvent proposer des trolls") + end. + + +del_troll( + [ + {cookie, Cookie}, + {troll_id, Troll_id} + ] +) -> + % controle que l'utilisateur est un admin + case euphorik_bd:user_by_cookie(Cookie) of + {ok, User = #user{ek_master = true}} -> + User_id = User#user.id, + case euphorik_bd:troll_by_id(Troll_id) of + {ok, #troll{id_user = User_id}} -> + euphorik_bd:del_troll(Troll_id), + json_reponse_ok(); + _ -> + erreur("Vous ne posséder pas ce troll") + end; + _ -> + 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(euphorik_common: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, euphorik_common: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) -> + { + struct, [ + {reply, "error"}, + {error_message, Message} + ] + }. + + +% 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. + % Formatage d'une heure % local_time() -> string @@ -627,7 +628,7 @@ format_date(Date) -> {{Annee, Mois, Jour}, {Heure, Minute, Seconde}} = DateLocal, {{AnneeNow, _, _}, {_, _, _}} = DateNowLocal, Hier = calendar:date_to_gregorian_days(element(1, DateLocal)) =:= calendar:date_to_gregorian_days(element(1, DateNowLocal)) - 1, - lists:flatten( + lists:flatten( if element(1, DateLocal) =:= element(1, DateNowLocal) -> ""; Hier -> @@ -637,29 +638,29 @@ format_date(Date) -> true -> io_lib:format("~2.10.0B/~2.10.0B/~B ", [Jour, Mois, Annee]) end ++ - io_lib:format("~2.10.0B:~2.10.0B:~2.10.0B", [Heure, Minute, Seconde]) - ). - - -json_reponse_ok() -> - {struct, [{reply, "ok"}]}. - - -json_reponse_login_ok(User) -> - { - struct, [ - {reply, "login"}, - {status, if (User#user.password =/= []) and (User#user.login =/= []) -> "auth_registered"; true -> "auth_not_registered" end}, - {cookie, User#user.cookie}, - {id, User#user.id}, - {nick, User#user.pseudo}, - {login, User#user.login}, - {email, User#user.email}, - {css, User#user.css}, - {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} - ] - }. + io_lib:format("~2.10.0B:~2.10.0B:~2.10.0B", [Heure, Minute, Seconde]) + ). + + +json_reponse_ok() -> + {struct, [{reply, "ok"}]}. + + +json_reponse_login_ok(User) -> + { + struct, [ + {reply, "login"}, + {status, if (User#user.password =/= []) and (User#user.login =/= []) -> "auth_registered"; true -> "auth_not_registered" end}, + {cookie, User#user.cookie}, + {id, User#user.id}, + {nick, User#user.pseudo}, + {login, User#user.login}, + {email, User#user.email}, + {css, User#user.css}, + {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} + ] + }. diff --git a/modules/erl/euphorik_requests.erl b/modules/erl/euphorik_requests.erl index 28019da..616d0e7 100755 --- a/modules/erl/euphorik_requests.erl +++ b/modules/erl/euphorik_requests.erl @@ -18,66 +18,72 @@ % % Ce module est fait pour répondre à des requêtes 'AJAX'. % Il est définit comme 'appmods' pour l'url "request" dans yaws. -% Par exemple http://www.euphorik.ch/request abouti sur la fonction out() de ce module. -% @author G.Burri +% Par exemple http://www.euphorik.ch/request abouti sur la fonction out() de ce module. +% @author G.Burri + - -module(euphorik_requests). -export([out/1]). -include_lib("xmerl/include/xmerl.hrl"). --include_lib("yaws/include/yaws_api.hrl"). - +-include_lib("yaws/include/yaws_api.hrl"). +-include("../include/euphorik_defines.hrl"). + -out(A) -> - %io:format("~p~n", [A]), % utilisé parfois pendant le debug - IP = case inet:peername(A#arg.clisock) of - {ok, {Adresse, _Port}} -> Adresse; - _ -> inconnue - end, - % passive -> active, permet de recevoir {tcp_closed, _} lorsque le socket se ferme +out(A) -> + %io:format("~p~n", [A]), % utilisé parfois pendant le debug + IP = case inet:peername(A#arg.clisock) of + {ok, {Adresse, _Port}} -> Adresse; + _ -> inconnue + end, + % passive -> active, permet de recevoir {tcp_closed, _} lorsque le socket se ferme % keepalive -> true, evite que des firewalls coupe la connexion TCP sans prévenir inet:setopts(A#arg.clisock, [{active, true}, {keepalive, true}]), {value, {_, Contenu}} = lists:keysearch("action", 1, yaws_api:parse_post(A)), - Ret = traiter_donnees(Contenu, IP), + Ret = traiter_donnees(Contenu, IP), {content, "application/json", Ret}. - -traiter_donnees(Contenu, IP) -> - case json:decode_string(Contenu) of - {ok, {struct, [{action, Action}| Reste]}} -> - json:encode(traiter_action(Action, Reste, IP)); - _ -> - error - end. - - -% authentification d'un client -traiter_action("authentification", JSON, IP) -> - euphorik_protocole:login(JSON, IP); -% un client s'enregistre (pseudo + password) -traiter_action("register", JSON, IP) -> - euphorik_protocole:register(JSON, IP); -% modification du profile -traiter_action("set_profile", JSON, _) -> - euphorik_protocole:profile(JSON); -% un utilisateur attend un événement (par exemple l'arrivé d'un nouveau message) -traiter_action("wait_event", JSON, _) -> - euphorik_protocole:wait_event(JSON); -% un utilisateur envoie un message -traiter_action("put_message", JSON, _) -> - euphorik_protocole:put_message(JSON); -traiter_action("ban", JSON, _) -> - euphorik_protocole:ban(JSON); -traiter_action("slap", JSON, _) -> - euphorik_protocole:slap(JSON); -traiter_action("put_troll", JSON, _) -> - euphorik_protocole:put_troll(JSON); -traiter_action("mod_troll", JSON, _) -> - euphorik_protocole:mod_troll(JSON); -traiter_action("del_troll", JSON, _) -> - euphorik_protocole:del_troll(JSON); -traiter_action("list_banned_ips", JSON, _) -> - euphorik_protocole:list_banned_ips(JSON); -traiter_action("unban", JSON, _) -> - euphorik_protocole:unban_ip(JSON). + +% Décode les données JSON. +traiter_donnees(Contenu, IP) -> + {ok, {struct, [{header, {struct, [{action, Action}, {version, Version_client}]}} | Reste]}} = json:decode_string(Contenu), + json:encode( + if Version_client =:= ?VERSION_PROTOCOLE -> + traiter_action(Action, Reste, IP); + true -> + euphorik_protocole:erreur(lists:flatten(io_lib:format( + "La version du protocole du client (~w) ne correspond à celle du serveur (~w)", [Version_client, ?VERSION_PROTOCOLE] + ))) + end + ). + + +% authentification d'un client +traiter_action("authentification", JSON, IP) -> + euphorik_protocole:login(JSON, IP); +% un client s'enregistre (pseudo + password) +traiter_action("register", JSON, IP) -> + euphorik_protocole:register(JSON, IP); +% modification du profile +traiter_action("set_profile", JSON, _) -> + euphorik_protocole:profile(JSON); +% un utilisateur attend un événement (par exemple l'arrivé d'un nouveau message) +traiter_action("wait_event", JSON, _) -> + euphorik_protocole:wait_event(JSON); +% un utilisateur envoie un message +traiter_action("put_message", JSON, _) -> + euphorik_protocole:put_message(JSON); +traiter_action("ban", JSON, _) -> + euphorik_protocole:ban(JSON); +traiter_action("slap", JSON, _) -> + euphorik_protocole:slap(JSON); +traiter_action("put_troll", JSON, _) -> + euphorik_protocole:put_troll(JSON); +traiter_action("mod_troll", JSON, _) -> + euphorik_protocole:mod_troll(JSON); +traiter_action("del_troll", JSON, _) -> + euphorik_protocole:del_troll(JSON); +traiter_action("list_banned_ips", JSON, _) -> + euphorik_protocole:list_banned_ips(JSON); +traiter_action("unban", JSON, _) -> + euphorik_protocole:unban_ip(JSON). \ No newline at end of file diff --git a/modules/include/euphorik_defines.hrl b/modules/include/euphorik_defines.hrl index bf6ec5b..8d22486 100755 --- a/modules/include/euphorik_defines.hrl +++ b/modules/include/euphorik_defines.hrl @@ -15,6 +15,9 @@ % You should have received a copy of the GNU General Public License % along with Euphorik. If not, see . +% La version du protocole, le client doit, à chaque requête, transmettre la version qu'il support, +% si la version client est serveur ne correspondent pas alors la requête est rejetée. +-define(VERSION_PROTOCOLE, 3). % Le temps d'attente après une erreur de login (mauvais login/pass) : une demie seconde % Permet d'éviter (limiter) les attaques par dictionnaire diff --git a/nbproject/private/private.xml b/nbproject/private/private.xml index 71b24c3..1daf207 100644 --- a/nbproject/private/private.xml +++ b/nbproject/private/private.xml @@ -3,7 +3,9 @@ js/pageMinichat.js - 834 + 237 + 867 + 1107 diff --git a/nbproject/project.properties b/nbproject/project.properties index 93e29d0..c61bcc0 100644 --- a/nbproject/project.properties +++ b/nbproject/project.properties @@ -1,12 +1,11 @@ file.reference.modules-erl=modules/erl file.reference.modules-include=modules/include -include.dir=${file.reference.modules-include} javac.classpath= main.file= ruby.includejava=false src.css.dir=css -src.dir=${file.reference.modules-erl} src.doc.dir=doc src.js.dir=js +src.modules.dir=modules src.pages.dir=pages src.tools.dir=tools diff --git a/nbproject/project.xml b/nbproject/project.xml index fa0f3ba..55ee5ef 100644 --- a/nbproject/project.xml +++ b/nbproject/project.xml @@ -5,13 +5,12 @@ euphorik - - - - - - - + + + + + +