ADD ajout d'une version de protocole, chaque message du client est taggé avec la...
authorGreg Burri <greg.burri@gmail.com>
Wed, 25 Jun 2008 19:57:37 +0000 (19:57 +0000)
committerGreg Burri <greg.burri@gmail.com>
Wed, 25 Jun 2008 19:57:37 +0000 (19:57 +0000)
12 files changed:
doc/TODO.txt
js/euphorik.js
js/pageAdmin.js
js/pageMinichat.js
modules/Makefile
modules/erl/euphorik_bd.erl
modules/erl/euphorik_protocole.erl
modules/erl/euphorik_requests.erl
modules/include/euphorik_defines.hrl
nbproject/private/private.xml
nbproject/project.properties
nbproject/project.xml

index 483ea60..a9f994c 100755 (executable)
@@ -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 !
 * 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)
    * 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)
index 9e969f5..9e4d8ec 100755 (executable)
@@ -29,6 +29,7 @@
   * Normalement 'const' à la place de 'var' mais non supporté par IE7.
   */
 var conf = {
   * Normalement 'const' à la place de 'var' mais non supporté par IE7.
   */
 var conf = {
+   versionProtocole : 3, // version du protcole
    nickDefaut : "<nick>",
    nbMessageAffiche : 40, // (par page)
    pseudoDefaut : "<nick>",
    nickDefaut : "<nick>",
    nbMessageAffiche : 40, // (par page)
    pseudoDefaut : "<nick>",
@@ -684,7 +685,7 @@ Client.prototype.supprimerConversation = function(num)
 Client.prototype.getJSONLogin = function(login, password)
 {
    return {
 Client.prototype.getJSONLogin = function(login, password)
 {
    return {
-      "action" : "authentification",
+      "header" : { "action" : "authentification", "version" : conf.versionProtocole },
       "login" : login,
       "password" : password
    }
       "login" : login,
       "password" : password
    }
@@ -693,7 +694,7 @@ Client.prototype.getJSONLogin = function(login, password)
 Client.prototype.getJSONLoginCookie = function()
 {
    return {
 Client.prototype.getJSONLoginCookie = function()
 {
    return {
-      "action" : "authentification",
+      "header" : { "action" : "authentification", "version" : conf.versionProtocole },
       "cookie" : this.cookie
    }
 }  
       "cookie" : this.cookie
    }
 }  
@@ -704,7 +705,7 @@ Client.prototype.getJSONLoginCookie = function()
   */
 Client.prototype.getJSONEnregistrement = function(login, password)
 {
   */
 Client.prototype.getJSONEnregistrement = function(login, password)
 {
-   var mess = { "action" : "register" }
+   var mess = { "header" : { "action" : "register", "version" : conf.versionProtocole }}
    
    if (login != undefined && password != undefined)
    {
    
    if (login != undefined && password != undefined)
    {
@@ -726,7 +727,7 @@ Client.prototype.getJSONConversations = function()
 Client.prototype.getJSONProfile = function()
 {
    return {
 Client.prototype.getJSONProfile = function()
 {
    return {
-      "action" : "set_profile",
+      "header" : { "action" : "set_profile", "version" : conf.versionProtocole },
       "cookie" : this.cookie,
       "login" : this.login,
       "password" : this.password,
       "cookie" : this.cookie,
       "login" : this.login,
       "password" : this.password,
@@ -828,7 +829,6 @@ Client.prototype.enregistrement = function(login, password)
 
 Client.prototype.connexion = function(messageJson)
 {
 
 Client.prototype.connexion = function(messageJson)
 {
-   ;; dumpObj(messageJson)
    thisClient = this
    jQuery.ajax(
       {
    thisClient = this
    jQuery.ajax(
       {
@@ -840,7 +840,6 @@ Client.prototype.connexion = function(messageJson)
          success:
             function(data)
             {
          success:
             function(data)
             {
-               ;; dumpObj(data)
                if (data["reply"] == "error")
                   thisClient.util.messageDialogue(data["error_message"])
                else
                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
    
    var thisClient = this
    var ok = true
    
-   ;; dumpObj(this.getJSONProfile())
    jQuery.ajax(
       {
          async: async,
    jQuery.ajax(
       {
          async: async,
@@ -921,7 +919,6 @@ Client.prototype.flush = function(async)
          success:
             function(data)
             {
          success:
             function(data)
             {
-               ;; dumpObj(data)
                if (data["reply"] == "error")
                {
                   thisClient.util.messageDialogue(data["error_message"])
                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(
          {
       dataType: "json",
       data: this.util.jsonVersAction(
          {
-            "action" : "slap",
+            "header" : { "action" : "slap", "version" : conf.versionProtocole },
             "cookie" : thisClient.cookie,
             "user_id" : userId,
             "reason" : raison
             "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(
          {
       dataType: "json",
       data: this.util.jsonVersAction(
          {
-            "action" : "ban",
+            "header" : { "action" : "ban", "version" : conf.versionProtocole },
             "cookie" : thisClient.cookie,
             "duration" : minutes,
             "user_id" : userId,
             "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 :
    *  {
    * 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" : <v> },
    *     "page" : <page>
    *     [..]
    *  }
    *     "page" : <page>
    *     [..]
    *  }
@@ -1105,15 +1102,13 @@ PageEvent.prototype.waitEvent = function(funSend, funsReceive)
    // TODO : ya pas mieux ?
    var dataToSend = 
    {
    // 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]
    
       "page" : this.page
    }
    var poulpe = funSend()
    for (v in poulpe)
       dataToSend[v] = poulpe[v]
    
-   ;; dumpObj(dataToSend)
-   
    this.attenteCourante = jQuery.ajax({
       type: "POST",
       url: "request",
    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)
       data: this.util.jsonVersAction(dataToSend),
       success:
          function(data)
-         {            
-            ;; dumpObj(data)
-            
+         {                        
             funsReceive[data["reply"]](data)
             
             // rappel de la fonction dans 100 ms
             funsReceive[data["reply"]](data)
             
             // rappel de la fonction dans 100 ms
index 6f3b3db..8fc6e22 100644 (file)
@@ -108,12 +108,11 @@ PageAdmin.prototype.posterTroll = function()
 
    var dataToSend = 
       {
 
    var dataToSend = 
       {
-         "action" : "put_troll", 
+         "header" : { "action" : "put_troll", "version" : conf.versionProtocole },
          "cookie" : this.client.cookie,
          "content" : content
       }
 
          "cookie" : this.client.cookie,
          "content" : content
       }
 
-   ;; dumpObj(dataToSend)
    jQuery.ajax(
       {
          type: "POST",
    jQuery.ajax(
       {
          type: "POST",
@@ -122,9 +121,7 @@ PageAdmin.prototype.posterTroll = function()
          data: this.util.jsonVersAction(dataToSend),
          success:
             function(data)
          data: this.util.jsonVersAction(dataToSend),
          success:
             function(data)
-            {
-               ;; dumpObj(data)
-               
+            {               
                if (data["reply"] == "ok")
                {
                   $("#page form#nouveauTroll input.troll").val("")
                if (data["reply"] == "ok")
                {
                   $("#page form#nouveauTroll input.troll").val("")
@@ -150,11 +147,10 @@ PageAdmin.prototype.majIPs = function()
 
    var dataToSend = 
       {
 
    var dataToSend = 
       {
-         "action" : "list_banned_ips", 
+         "header" : { "action" : "list_banned_ips", "version" : conf.versionProtocole },
          "cookie" : this.client.cookie
       }
 
          "cookie" : this.client.cookie
       }
 
-   ;; dumpObj(dataToSend)
    jQuery.ajax(
       {
          type: "POST",
    jQuery.ajax(
       {
          type: "POST",
@@ -163,9 +159,7 @@ PageAdmin.prototype.majIPs = function()
          data: this.util.jsonVersAction(dataToSend),
          success:
             function(data)
          data: this.util.jsonVersAction(dataToSend),
          success:
             function(data)
-            {
-               ;; dumpObj(data)
-               
+            {               
                if (data["reply"] == "list_banned_ips")
                {
                   var XHTML = ""
                if (data["reply"] == "list_banned_ips")
                {
                   var XHTML = ""
@@ -233,12 +227,11 @@ PageAdmin.prototype.deban = function(ip)
 
    var dataToSend = 
       {
 
    var dataToSend = 
       {
-         "action" : "unban", 
+         "header" : { "action" : "unban", "version" : conf.versionProtocole },
          "cookie" : this.client.cookie,
          "ip" : ip
       }
 
          "cookie" : this.client.cookie,
          "ip" : ip
       }
 
-   ;; dumpObj(dataToSend)
    jQuery.ajax(
       {
          type: "POST",
    jQuery.ajax(
       {
          type: "POST",
@@ -248,11 +241,8 @@ PageAdmin.prototype.deban = function(ip)
          success:
             function(data)
             {
          success:
             function(data)
             {
-               ;; dumpObj(data)
                if(data["reply"] == "error")
                if(data["reply"] == "error")
-               {
                   thisPageAdmin.util.messageDialogue(data["error_message"])
                   thisPageAdmin.util.messageDialogue(data["error_message"])
-               }
             }
       }
    )
             }
       }
    )
@@ -410,13 +400,12 @@ Trolls.prototype.modifier = function(id, content)
    
    var dataToSend =
       {
    
    var dataToSend =
       {
-         "action" : "mod_troll",
+         "header" : { "action" : "mod_troll", "version" : conf.versionProtocole },
          "cookie" : this.client.cookie,
          "troll_id" : id,
          "content" : content
       }
 
          "cookie" : this.client.cookie,
          "troll_id" : id,
          "content" : content
       }
 
-   ;; dumpObj(dataToSend)
    jQuery.ajax(
       {
          type: "POST",
    jQuery.ajax(
       {
          type: "POST",
@@ -426,7 +415,6 @@ Trolls.prototype.modifier = function(id, content)
          success:
             function(data)
             {
          success:
             function(data)
             {
-               ;; dumpObj(data)
                if (data["reply"] == "error")
                {
                   thisTrolls.util.messageDialogue(data["error_message"])
                if (data["reply"] == "error")
                {
                   thisTrolls.util.messageDialogue(data["error_message"])
@@ -445,12 +433,11 @@ Trolls.prototype.supprimer = function(id)
 
    var dataToSend =
       {
 
    var dataToSend =
       {
-         "action" : "del_troll",
+         "header" : { "action" : "del_troll", "version" : conf.versionProtocole },
          "cookie" : this.client.cookie,
          "troll_id" : id
       }
 
          "cookie" : this.client.cookie,
          "troll_id" : id
       }
 
-   ;; dumpObj(dataToSend)
    jQuery.ajax(
       {
          type: "POST",
    jQuery.ajax(
       {
          type: "POST",
@@ -460,7 +447,6 @@ Trolls.prototype.supprimer = function(id)
          success:
             function(data)
             {
          success:
             function(data)
             {
-               ;; dumpObj(data)
                if (data["reply"] == "error")
                {
                   thisTrolls.util.messageDialogue(data["error_message"])
                if (data["reply"] == "error")
                {
                   thisTrolls.util.messageDialogue(data["error_message"])
index 8586bb5..2de1531 100755 (executable)
@@ -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 {
       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,
       "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.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
 
    
    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)
    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)
       else if (this.messages[i].clientARepondu)
-         messagesRepondu += "#" + this.messages[i].getId() + ","
+         messagesRepondu += "#" + this.messages[i].getId(this.getId()) + ","
       else if (this.messages[i].estUneReponse)
       else if (this.messages[i].estUneReponse)
-         messagesReponse += "#" + this.messages[i].getId() + ","
+         messagesReponse += "#" + this.messages[i].getId(this.getId()) + ","
    }
    $(messagesReponse).addClass("reponse")
    $(messagesRepondu).addClass("repondu")
    }
    $(messagesReponse).addClass("reponse")
    $(messagesRepondu).addClass("repondu")
@@ -579,6 +579,11 @@ Conversation.prototype.viderMessages = function()
    $("#conversations #" + this.getId() + " .message").remove()
 }
 
    $("#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.
 /**
   * 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)
       {
    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
       }
    
          messagePair = !messagePair
       }
    
@@ -613,7 +618,7 @@ Conversation.prototype.flush = function(funClickOuvrirConv, funClickMessage)
             {          
                // FIXME : ya pas mieux ?
                var racine = $(event.target).text()
             {          
                // 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
             }
          )         
                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
          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)
          
          $(this).click(
             function(event)
@@ -674,7 +679,7 @@ Conversation.prototype.flush = function(funClickOuvrirConv, funClickMessage)
             $(".pseudo", this).hover(
                function(e)
                {     
             $(".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()
                   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)
 {   
   */
 Conversation.prototype.afficherConversation = function(id)
 {   
+   var thisConversation = this
+    
    var message = this.messagesParId[id]
    if (message == undefined) return
       
    var message = this.messagesParId[id]
    if (message == undefined) return
       
@@ -740,7 +747,7 @@ Conversation.prototype.afficherConversation = function(id)
       function()
       {
          var jq = $(this)
       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
          if (statut == undefined)
             jq.addClass("cache")
          else
@@ -822,6 +829,10 @@ Messages.prototype.toggleMessageRepond = function(mess)
   */
 Messages.prototype.enleverMessagesRepond = function()
 {
   */
 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()
    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)
 {
   */
 Messages.prototype.enleverMessageRepond = function(mess)
 {
-    console.log(mess)
    $("#" + mess.getId()).removeClass("repondEnEvidence")
    $("#" + mess.getId(this.prefixIdMessage)).remove()
    delete this.messagesRepond[mess.id]
    $("#" + 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)
       {
          // met ou enlève la mise en evidence du message
          thisMessages.toggleMessageRepond(Mess)
+         // donne le focus à la ligne de saisie
+         $("form input.message").focus()
       }
    )
 }
       }
    )
 }
index ebeff42..32edb72 100755 (executable)
@@ -1,62 +1,62 @@
-# Répertoire dans lequel se trouve les modules compilés (beam)\r
-rep_ebin = ebin\r
-\r
-# Répertoire dans lequel se trouve les fichiers sources\r
-rep_erl = erl\r
-\r
-# Répertoire dans lequel se trouve les fichier hrl (définition de record)\r
-rep_include = include\r
-\r
-# Paramètre du compilateur\r
-erlc_params = -I $(rep_include) -o $(rep_ebin) $<\r
-\r
-# Compilation de toute l'application euphorik\r
+# 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 \
 all: $(rep_ebin)/euphorik_bd.beam \
-$(rep_ebin)/euphorik_minichat_conversation.beam \\r
-$(rep_ebin)/euphorik_requests.beam \\r
+$(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
 $(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
-\r
-# Module pour la gestion des données persistante la BD\r
-$(rep_ebin)/euphorik_bd.beam: $(rep_erl)/euphorik_bd.erl $(rep_include)/euphorik_bd.hrl $(rep_include)/euphorik_defines.hrl\r
+
+# 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)
    
        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
 $(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)\r
+       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
 
 # 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)\r
-       \r
-# Module traitant les requêtes AJAX du client javascript d'euphorik\r
-$(rep_ebin)/euphorik_requests.beam: $(rep_erl)/euphorik_requests.erl\r
-       erlc $(erlc_params)\r
-       \r
-# Module interpretant les messages XML du client\r
-$(rep_ebin)/euphorik_protocole.beam: $(rep_erl)/euphorik_protocole.erl $(rep_include)/euphorik_defines.hrl\r
+       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)
    
        erlc $(erlc_params)
    
-# Module pour la génération du captcha\r
-#$(rep_ebin)/captcha.beam: $(rep_erl)/captcha.erl\r
+# Module pour la génération du captcha
+#$(rep_ebin)/captcha.beam: $(rep_erl)/captcha.erl
 #      erlc $(erlc_params)
 #      erlc $(erlc_params)
-      \r
-# Module effectuant periodiquement certaines tâches\r
-$(rep_ebin)/euphorik_daemon.beam: $(rep_erl)/euphorik_daemon.erl $(rep_include)/euphorik_defines.hrl\r
+      
+# 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)
    
        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
 $(rep_ebin)/euphorik_test.beam: $(rep_erl)/euphorik_test.erl $(rep_erl)/euphorik_bd.erl $(rep_include)/euphorik_bd.hrl
-       erlc $(erlc_params)\r
-\r
-# Suppression des modules compilés\r
-clean:\r
+       erlc $(erlc_params)
+
+# Suppression des modules compilés
+clean:
        rm ebin/*.beam
        rm ebin/*.beam
index a0ffc3a..ed07a56 100755 (executable)
@@ -423,50 +423,62 @@ user_by_mess(Id) ->
 nouveau_message(Mess, Auteur_id, Repond_A_ids) ->\r
    % regarde si les id 'Repond_A' existent\r
    F = fun() ->   \r
 nouveau_message(Mess, Auteur_id, Repond_A_ids) ->\r
    % regarde si les id 'Repond_A' existent\r
    F = fun() ->   \r
-      Repond_A = e(\r
+      Repond_a = e(\r
          q([M || M <- mnesia:table(minichat), lists:member(M#minichat.id, Repond_A_ids)]),\r
          [{tmpdir, ?KEY_SORT_TEMP_DIR}]\r
          q([M || M <- mnesia:table(minichat), lists:member(M#minichat.id, Repond_A_ids)]),\r
          [{tmpdir, ?KEY_SORT_TEMP_DIR}]\r
-      ),\r
-      Racine_id = case Repond_A of\r
+      ), \r
+      Racine_id = case Repond_a of\r
          [] -> undefined;\r
          [] -> undefined;\r
-         [M | _ ] -> M#minichat.racine_id\r
-      end,\r
-      % est-ce que l'auteur existe ?\r
-      case e(q([E || E <- mnesia:table(user), E#user.id =:= Auteur_id]), [{tmpdir, ?KEY_SORT_TEMP_DIR}]) of\r
-         [Auteur] ->\r
-            if length(Repond_A) =/= length(Repond_A_ids) ->\r
-                  {erreur, "Un ou plusieurs messages introuvable"};\r
+         [M | _ ] -> \r
+            Une_racine = M#minichat.racine_id,\r
+            % vérification que tout les messages de Repond_a possède la même racine (même conversation)\r
+            case lists:all(fun(R) -> R#minichat.racine_id =:= Une_racine end, Repond_a) of\r
                true ->\r
                true ->\r
-                  % comparaison entre la date du dernier poste et maintenant (gestion du flood)\r
-                  Delta = delta_date_ms(Auteur#user.date_derniere_connexion, now()),\r
-                  Nouvel_indice_flood = Auteur#user.indice_flood + if Delta =< ?DUREE_SPAM -> 2; true -> -1 end,\r
-                  Auteur_maj = Auteur#user{\r
-                     indice_flood = if Nouvel_indice_flood > ?INDICE_SPAM_MAX -> ?INDICE_SPAM_MAX; Nouvel_indice_flood < 0 -> 0; true -> Nouvel_indice_flood end,\r
-                     date_derniere_connexion = now()\r
-                  },\r
-                  % est-ce que l'auteur à trop floodé ?\r
-                  if Auteur#user.indice_flood =/= ?INDICE_SPAM_MAX, Auteur_maj#user.indice_flood =:= ?INDICE_SPAM_MAX, Delta =< ?DUREE_BLOCAGE_SPAM ->\r
-                     mnesia:write(Auteur#user{indice_flood = Auteur_maj#user.indice_flood}),\r
-                     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.");\r
-                  Auteur#user.indice_flood =:= ?INDICE_SPAM_MAX, Delta =< ?DUREE_BLOCAGE_SPAM ->\r
-                     {erreur, "Bloqué pour cause de flood"};\r
-                  true ->     \r
-                     mnesia:write(Auteur_maj),\r
-                     Id = nouvel_id(minichat),\r
-                     inserer_reponses(Id, Repond_A_ids),\r
-                     mnesia:write(#minichat{\r
-                        id = Id,\r
-                        auteur_id = Auteur#user.id,\r
-                        date = now(),\r
-                        pseudo = Auteur#user.pseudo,\r
-                        contenu = Mess,\r
-                        racine_id = if Racine_id =:= undefined -> Id; true -> Racine_id end\r
-                     }),\r
-                     Id\r
-                  end\r
-            end;\r
+                  Une_racine;\r
+               _ ->\r
+                  {erreur, "Les messages ne font pas partie de la même conversation"}\r
+            end\r
+      end,      \r
+      case Racine_id of\r
+         {erreur, E} -> {erreur, E};\r
          _ ->\r
          _ ->\r
-            {erreur, "L'auteur du message est introuvable"}\r
+            % est-ce que l'auteur existe ?\r
+            case e(q([E || E <- mnesia:table(user), E#user.id =:= Auteur_id]), [{tmpdir, ?KEY_SORT_TEMP_DIR}]) of\r
+               [Auteur] ->\r
+                  if length(Repond_a) =/= length(Repond_A_ids) ->\r
+                        {erreur, "Un ou plusieurs messages introuvable"};\r
+                     true ->\r
+                        % comparaison entre la date du dernier poste et maintenant (gestion du flood)\r
+                        Delta = delta_date_ms(Auteur#user.date_derniere_connexion, now()),\r
+                        Nouvel_indice_flood = Auteur#user.indice_flood + if Delta =< ?DUREE_SPAM -> 2; true -> -1 end,\r
+                        Auteur_maj = Auteur#user{\r
+                           indice_flood = if Nouvel_indice_flood > ?INDICE_SPAM_MAX -> ?INDICE_SPAM_MAX; Nouvel_indice_flood < 0 -> 0; true -> Nouvel_indice_flood end,\r
+                           date_derniere_connexion = now()\r
+                        },\r
+                        % est-ce que l'auteur à trop floodé ?\r
+                        if Auteur#user.indice_flood =/= ?INDICE_SPAM_MAX, Auteur_maj#user.indice_flood =:= ?INDICE_SPAM_MAX, Delta =< ?DUREE_BLOCAGE_SPAM ->\r
+                           mnesia:write(Auteur#user{indice_flood = Auteur_maj#user.indice_flood}),\r
+                           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.");\r
+                        Auteur#user.indice_flood =:= ?INDICE_SPAM_MAX, Delta =< ?DUREE_BLOCAGE_SPAM ->\r
+                           {erreur, "Bloqué pour cause de flood"};\r
+                        true ->     \r
+                           mnesia:write(Auteur_maj),\r
+                           Id = nouvel_id(minichat),\r
+                           inserer_reponses(Id, Repond_A_ids),\r
+                           mnesia:write(#minichat{\r
+                              id = Id,\r
+                              auteur_id = Auteur#user.id,\r
+                              date = now(),\r
+                              pseudo = Auteur#user.pseudo,\r
+                              contenu = Mess,\r
+                              racine_id = if Racine_id =:= undefined -> Id; true -> Racine_id end\r
+                           }),\r
+                           Id\r
+                        end\r
+                  end;\r
+               _ ->\r
+                  {erreur, "L'auteur du message est introuvable"}\r
+            end\r
       end\r
    end,\r
    resultat_transaction(mnesia:transaction(F)).\r
       end\r
    end,\r
    resultat_transaction(mnesia:transaction(F)).\r
index c15ada1..448a20b 100755 (executable)
 %\r
 % You should have received a copy of the GNU General Public License\r
 % along with Euphorik.  If not, see <http://www.gnu.org/licenses/>.\r
 %\r
 % You should have received a copy of the GNU General Public License\r
 % along with Euphorik.  If not, see <http://www.gnu.org/licenses/>.\r
-% 
-% 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
+% \r
+% Ce module gére les différents messages envoyés par le client (javascript) via AJAX.\r
+% Les messages donnés ainsi que les réponses sont au format JSON.\r
+% @author G.Burri\r
 \r
 \r
-
--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
-]).
+\r
+-module(euphorik_protocole).\r
+-export([\r
+   register/2,\r
+   login/2,\r
+   logout/1,\r
+   profile/1,\r
+   wait_event/1,\r
+   put_message/1,\r
+   ban/1,\r
+   slap/1,\r
+   put_troll/1,\r
+   mod_troll/1,\r
+   del_troll/1,\r
+   unban_ip/1,\r
+   list_banned_ips/1,\r
+   erreur/1\r
+]).\r
 -include("../include/euphorik_bd.hrl").\r
 -include("../include/euphorik_defines.hrl").\r
 -include("../include/euphorik_bd.hrl").\r
 -include("../include/euphorik_defines.hrl").\r
-
-
-% 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("<nick>", 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)").
-   
 \r
 \r
-% 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").
-   
+\r
+% Une utilisateur s'enregistre avec un tuple {Login, Password}.\r
+register([{login, Login}, {password, Password}], IP) ->\r
+   Can_register = euphorik_bd:can_register(IP),\r
+   if Can_register ->\r
+         case euphorik_bd:user_by_login(Login) of\r
+            {ok, _} ->\r
+               erreur("Login déjà existant");\r
+            _ ->\r
+               User = euphorik_bd:nouveau_user(Login, Password, generer_cookie()),\r
+               euphorik_bd:update_ip(User#user.id, IP),\r
+               json_reponse_login_ok(User)\r
+         end;\r
+      true ->\r
+         erreur_register_flood()\r
+   end;\r
+% Enregistrement sans {Login, Password}\r
+register([], IP) ->   \r
+   Can_register = euphorik_bd:can_register(IP),\r
+   if Can_register ->\r
+         User = euphorik_bd:nouveau_user("<nick>", generer_cookie()),\r
+         euphorik_bd:update_ip(User#user.id, IP),\r
+         json_reponse_login_ok(User);\r
+      true ->\r
+         erreur_register_flood()\r
+   end.\r
+   \r
+erreur_register_flood() ->\r
+   erreur("Trop de register (flood)").\r
+   \r
+\r
+% Un utilisateur se logge (avec un couple {login, mot de passe})\r
+login([{login, Login}, {password, Password}], IP) ->\r
+   loginUser(euphorik_bd:user_by_login_password(Login, Password), IP);\r
+% Un utilisateur se logge (avec un cookie)\r
+login([{cookie, Cookie}], IP) ->\r
+   loginUser(euphorik_bd:user_by_cookie(Cookie), IP).\r
+   \r
+loginUser({ok, User}, IP) ->\r
+   euphorik_bd:update_ip(User#user.id, IP),\r
+   euphorik_bd:update_date_derniere_connexion(User#user.id),\r
+   json_reponse_login_ok(User);\r
+loginUser(_, _) ->\r
+   % ajoute un délais d'attente\r
+   timer:sleep(?TEMPS_ATTENTE_ERREUR_LOGIN),\r
+   erreur("Couple login/pass introuvable").\r
+   \r
    \r
 % Renvoie un string() représentant un cookie en base 36. Il y a 10^32 possibillités.\r
    \r
 % Renvoie un string() représentant un cookie en base 36. Il y a 10^32 possibillités.\r
-generer_cookie() ->
-   {A1, A2, A3} = now(),
+generer_cookie() ->\r
+   {A1, A2, A3} = now(),\r
    random:seed(A1, A2, A3),\r
    erlang:integer_to_list(random:uniform(math:pow(10, 32)), 36).\r
    random:seed(A1, A2, A3),\r
    erlang:integer_to_list(random:uniform(math:pow(10, 32)), 36).\r
-
-
-% 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
-   ),
+\r
+\r
+% Un utilisateur se délogge.\r
+logout(_) ->\r
+   do_nothing.\r
+\r
+\r
+% Modification du profile.\r
+profile(\r
+   [\r
+      {cookie, Cookie},\r
+      {login, Login},\r
+      {password, Password},\r
+      {nick, Pseudo},\r
+      {email, Email},\r
+      {css, Css},\r
+      {nick_format, Nick_format_str},\r
+      {view_times, View_times},\r
+      {view_tooltips, View_tooltips},\r
+      {conversations, {array, Conversations_json}}\r
+   ]\r
+) ->\r
+   % virage des messages qui n'existent pas\r
+   Conversations = lists:dropwhile(\r
+      fun(Message_id) ->\r
+         not euphorik_bd:message_existe(Message_id)\r
+      end,\r
+      Conversations_json\r
+   ),\r
+   %  TODO : pas très beau, mieux vaut construire un #user\r
+   case euphorik_bd:set_profile(\r
+         Cookie,\r
+         Login,\r
+         Password,\r
+         Pseudo,\r
+         Email,\r
+         Css,\r
+         list_to_atom(Nick_format_str),\r
+         View_times,\r
+         View_tooltips,\r
+         Conversations) of\r
+      ok ->\r
+         json_reponse_ok();\r
+      login_deja_pris ->\r
+         erreur("Login déjà pris");\r
+      _ ->\r
+         erreur("Impossible de mettre à jour le profile")\r
+   end.\r
+\r
+\r
+% Renvoie les messages appropriés.\r
+% last_message id et cookie sont facultatifs\r
+wait_event([{page, "chat"} | Data]) ->\r
+   % traitement des inputs\r
+   Cookie = case lists:keysearch(cookie, 1, Data) of {value, {_, C}} -> C; _ -> inconnu end,\r
+   Last_message_id = case lists:keysearch(last_message_id, 1, Data) of {value, {_, Id}} -> Id; _ -> 0 end,\r
+   {value, {_, Message_count}} = lists:keysearch(message_count, 1, Data),\r
+   Main_page = case lists:keysearch(main_page, 1, Data) of {value, {_, P}} -> P; _ -> 1 end,\r
+   Troll_id = case lists:keysearch(troll_id, 1, Data) of {value, {_, T}} -> T; _ -> 0 end,\r
+   {value, {_, {array, Conversations_json}}} = lists:keysearch(conversations, 1, Data),\r
+   Racines_conversations = lists:map(\r
+      fun({struct, [{root, Racine}, {page, Page} | Reste]}) ->\r
+         Last_mess_conv  = case Reste of [{last_message_id, L}] -> L; _ -> 0 end,\r
+         {Racine, Page, Last_mess_conv}\r
+      end,\r
+      Conversations_json\r
+   ),\r
    User = case euphorik_bd:user_by_cookie(Cookie) of\r
       {ok, U} -> U;\r
       _ -> inconnu\r
    User = case euphorik_bd:user_by_cookie(Cookie) of\r
       {ok, U} -> U;\r
       _ -> inconnu\r
-   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,\r
+   case {mnesia:subscribe({table, minichat, detailed}), mnesia:subscribe({table, troll, detailed})} of\r
+      {{error, E}, _} -> E;\r
+      {_, {error, E}} -> E;\r
+      _ ->\r
+         % attente d'événements\r
+         R = wait_event_page_chat(User, Racines_conversations, Message_count, Last_message_id, Main_page, Troll_id),\r
+         mnesia:unsubscribe({table, minichat, detailed}),\r
+         mnesia:unsubscribe({table, troll, detailed}),\r
+         R\r
+   end;\r
+wait_event([{page, "admin"}, {last_troll, Last_troll}]) ->\r
+   case wait_event_page_admin(Last_troll) of\r
+      banned_ips_refresh ->\r
+         {struct, \r
+            [\r
+               {reply, "banned_ips_refresh"}\r
+            ]\r
+         };\r
+      {mod, Troll} ->\r
+         {struct,\r
+            [\r
+               {reply, "troll_modified"},\r
+               {troll_id, Troll#troll.id},\r
+               {content, Troll#troll.content}\r
+            ]\r
+         };\r
+      {add, Trolls} ->\r
+         {struct,\r
+            [\r
+               {reply, "troll_added"},\r
+               {trolls, {array, \r
+                  lists:map(\r
+                     fun(T) ->                        \r
+                        {ok, User} = euphorik_bd:user_by_id(T#troll.id_user),\r
+                        {struct,\r
+                           [\r
+                              {troll_id, T#troll.id},\r
+                              {content, T#troll.content},\r
+                              {author, User#user.pseudo},\r
+                              {author_id, User#user.id}\r
+                           ]\r
+                        }\r
+                     end,\r
+                     Trolls\r
+                  )\r
+               }}\r
+            ]\r
+         };         \r
+      {del, Troll_id} ->\r
+         {struct,\r
+            [\r
+               {reply, "troll_deleted"},\r
+               {troll_id, Troll_id}\r
+            ]\r
+         };                  \r
+      _ ->\r
+         erreur("timeout")\r
+   end;\r
+wait_event(_) ->\r
+   erreur("Page inconnue").\r
+\r
+\r
+wait_event_page_chat(User, Racines_conversations, Message_count, Last_message_id, Main_page, Troll_id) ->\r
+   % est-ce que le troll est à jour ?\r
+   case euphorik_bd:current_troll() of\r
+      Current when is_record(Current, troll), Current#troll.id =/= Troll_id ->\r
+         {struct, [\r
+            {reply, "new_troll"},\r
+            {troll_id, Current#troll.id},\r
+            {message_id, euphorik_bd:message_id_associe(Current#troll.id)},\r
+            {content, Current#troll.content}\r
+         ]};\r
+      _ ->\r
+         % est-ce qu'il y a des nouveaux messages ?\r
+         case euphorik_minichat_conversation:conversations(Racines_conversations, Message_count, Last_message_id, Main_page) of\r
+            vide ->            \r
+               wait_event_bd_page_chat(),\r
+               wait_event_page_chat(User, Racines_conversations, Message_count, Last_message_id, Main_page, Troll_id);\r
+            Conversations ->\r
+               % accrochez-vous ca va siouxer ;)\r
+               {struct, [\r
+                  {reply, "new_messages"},\r
+                  {conversations, {array,\r
+                     lists:map(\r
+                        fun({Conv, Plus}) ->\r
+                           {struct, [\r
+                              {last_page, not Plus},\r
+                              {messages, {array, \r
+                                 lists:map(\r
+                                    fun({Mess, Repond_a}) ->                                 \r
+                                       Est_proprietaire = User =/= inconnu andalso User#user.id =:= Mess#minichat.auteur_id,\r
+                                       A_repondu_a_message = User =/= inconnu andalso euphorik_bd:a_repondu_a_message(User#user.id, Mess#minichat.id),\r
+                                       Est_une_reponse_a_user = User =/= inconnu andalso euphorik_bd:est_une_reponse_a_user(User#user.id, Mess#minichat.id),\r
+                                       {ok, User_mess } = euphorik_bd:user_by_id(Mess#minichat.auteur_id),\r
+                                       {struct, [\r
+                                          {id, Mess#minichat.id},\r
+                                          {user_id, User_mess#user.id},\r
+                                          {date, format_date(Mess#minichat.date)},\r
+                                          {system, Mess#minichat.auteur_id =:= 0},\r
+                                          {owner, Est_proprietaire},\r
+                                          {answered, A_repondu_a_message},\r
+                                          {is_a_reply, Est_une_reponse_a_user},\r
+                                          {nick, Mess#minichat.pseudo},\r
+                                          {login, User_mess#user.login},\r
+                                          {content, Mess#minichat.contenu},\r
+                                          {root, Mess#minichat.racine_id},\r
+                                          {answer_to, {array, lists:map(\r
+                                             fun(Id_mess) ->                   \r
+                                                {ok, M} = euphorik_bd:message_by_id(Id_mess),\r
+                                                {ok, User_reponse} = euphorik_bd:user_by_mess(M#minichat.id),\r
+                                                {struct, [{id, M#minichat.id}, {nick, M#minichat.pseudo}, {login, User_reponse#user.login}]}\r
+                                             end,\r
+                                             Repond_a\r
+                                          )}},\r
+                                          {ek_master, User_mess#user.ek_master}\r
+                                       ]}\r
+                                    end,\r
+                                    Conv\r
+                                 )\r
+                              }}\r
+                           ]}\r
+                        end,\r
+                        Conversations\r
+                     )\r
+                  }}\r
+               ]}\r
+         end\r
+   end.\r
+\r
+\r
+% Attend un événement lié à la page 'chat'.\r
+wait_event_bd_page_chat() ->\r
+   receive % attente d'un post\r
+      {mnesia_table_event, {write, minichat, _Message, [], _}} ->\r
+         ok;\r
+      {mnesia_table_event, {write, troll, Troll, [Old_troll | _], _}} when Troll#troll.date_post =/= undefined, Old_troll#troll.date_post == undefined ->\r
+         ok;\r
+      {tcp_closed, _} ->\r
+         exit(normal);\r
+      _ ->\r
+         wait_event_bd_page_chat()\r
+   % 60 minutes de timeout (on ne sais jamais)\r
+   % Après 60 minutes de connexion, le client doit donc reétablir une connexion\r
+   after 1000 * 60 * 60 -> \r
+      timeout\r
+   end.\r
+\r
+\r
+% Attent un événement concernant la page admin\r
+% Renvoie les trolls manquants posté après Last_id ou banned_ips_refresh.\r
+% Si pas de trolls alors attend un événement tel qu'un ajout, une modification ou une suppression.\r
+% renvoie :\r
+%  {mod, Troll}\r
+% ou {add, [Trolls]}\r
+% ou {del, Troll_id}\r
+% ou banned_ips_refresh\r
+% ou timeout\r
+wait_event_page_admin(Last_id) ->\r
+   case {mnesia:subscribe({table, troll, detailed}), mnesia:subscribe({table, ip_table, detailed})} of\r
+      {{error, E}, _ } -> E;\r
+      {_, {error, E}} -> E;\r
+      _ ->\r
+         R = case euphorik_bd:trolls(Last_id) of\r
+               [] -> % pas de trolls\r
+                  wait_event_page_admin();\r
+               Trolls ->\r
+                  {add, Trolls}\r
+         end,\r
+         mnesia:unsubscribe({table, troll, detailed}),\r
+         mnesia:unsubscribe({table, ip_table, detailed}),\r
+         R\r
+   end.\r
+   \r
+wait_event_page_admin() ->\r
+   % s'il n'y a pas de trolls que l'utilisateur n'a pas connaissance alors on attend un événement\r
+   receive\r
+      % cas où un troll est choisit comme courant\r
+      {mnesia_table_event, {write, troll, Troll, [Old_troll | _], _}}\r
+         when Old_troll#troll.date_post =:= undefined, Troll#troll.date_post =/= undefined ->\r
+         {del, Troll#troll.id};\r
+      {mnesia_table_event, {write, troll, Troll, [_Old_troll | _], _}} ->\r
+         {mod, Troll};\r
+      {mnesia_table_event, {write, troll, Troll, [], _}} ->\r
+         {add, [Troll]};\r
+      {mnesia_table_event, {delete, troll, {troll, Id}, _, _}} ->\r
+         {del, Id};\r
+      {mnesia_table_event, {write, ip_table, IP, [Old_IP | _], _}}\r
+         when Old_IP#ip_table.ban =/= IP#ip_table.ban; Old_IP#ip_table.ban_duration =/= IP#ip_table.ban_duration ->\r
+         banned_ips_refresh;\r
+      {tcp_closed, _} ->\r
+         exit(normal);\r
+      _ ->\r
+         wait_event_page_admin()\r
+   % 60 minutes de timeout (on ne sais jamais)\r
+   % Après 60 minutes de connexion, le client doit donc reétablir une connexion\r
+   after 1000 * 60 * 60 -> \r
+      timeout\r
+   end.\r
+         \r
+         \r
+% Un utilisateur envoie un message\r
+% Answer_to est une liste d'id (int)\r
+put_message(\r
+   [\r
+      {cookie, Cookie},\r
+      {nick, Nick},\r
+      {content, Content},\r
+      {answer_to, {array, Answer_to}}\r
+   ]\r
+) ->\r
+   case euphorik_bd:user_by_cookie(Cookie) of\r
+      {ok, User} ->\r
+         case euphorik_bd:est_banni(User#user.id) of\r
+            {true, Temps_restant} ->\r
+               erreur("Vous êtes banni pour encore " ++ format_minutes(Temps_restant));\r
+            _ ->\r
+               Strip_content = string:strip(Content),\r
+               if Strip_content =:= [] ->\r
+                     erreur("Message vide");\r
+                  true ->\r
+                     % attention : non-atomique (update_pseudo+nouveau_message)\r
+                     euphorik_bd:update_pseudo_user(User#user.id, Nick),\r
+                     case euphorik_bd:nouveau_message(Strip_content, User#user.id, Answer_to) of\r
+                        {erreur, R} -> erreur("Impossible d'ajouter un nouveau message. Raison : " ++ R);\r
+                        _ ->\r
+                           json_reponse_ok()\r
+                     end\r
+               end\r
+         end;\r
+   _ ->\r
+      erreur("Utilisateur inconnu")\r
+   end.\r
+\r
+\r
+% bannissement d'un utilisateur (son ip est bannie)\r
+ban(\r
+   [\r
+      {cookie, Cookie},\r
+      {duration, Duration},\r
+      {user_id, User_id},\r
+      {reason, Reason}\r
+   ]) ->\r
+      % controle que l'utilisateur est un admin\r
+      case euphorik_bd:user_by_cookie(Cookie) of\r
+         {ok, User1 = #user{ek_master = true}} ->\r
+            case euphorik_bd:user_by_id(User_id) of\r
+               {ok, User1} ->\r
+                  erreur("Il n'est pas possible de s'auto bannir");\r
+               {ok, User2 = #user{ek_master = false}} ->\r
+                  euphorik_bd:ban(User2#user.last_ip, Duration),\r
+                  euphorik_bd:nouveau_message_sys(lists:flatten(io_lib:format("''~s~s'' est ~s pour ~s.~s",\r
+                     [\r
+                        User2#user.pseudo,\r
+                        if User2#user.login =:= [] -> ""; true -> " (" ++ User2#user.login ++ ")" end,\r
+                        if Duration =< 15 -> "kické"; true -> "banni" end,\r
+                        format_minutes(Duration),\r
+                        if Reason =/= [] -> " - Raison: " ++ Reason; true -> "" end ++ "."\r
+                     ]\r
+                  ))),\r
+                  json_reponse_ok();\r
+               {ok, _} ->\r
+                  erreur("L'utilisateur est lui même un ekMaster");\r
+               _ ->\r
+                  erreur("Utilisateur à bannir inconnu")\r
+            end;\r
+         _ ->\r
+            erreur("Utilisateur inconnu ou non ek master")\r
+      end.\r
+      \r
+\r
+% slapage d'un user (avertissement)\r
+slap(\r
+   [\r
+      {cookie, Cookie},\r
+      {user_id, User_id},\r
+      {reason, Reason}\r
+   ]) ->\r
+      % controle que l'utilisateur est un admin\r
+      case euphorik_bd:user_by_cookie(Cookie) of\r
+         {ok, User1 = #user{ek_master = true}} ->\r
+            case euphorik_bd:user_by_id(User_id) of\r
+               {ok, User1} ->\r
+                  euphorik_bd:nouveau_message_sys(lists:flatten(io_lib:format("~s s'auto slap~s.", \r
+                     [\r
+                        User1#user.pseudo,\r
+                        if Reason =/= [] -> " - Raison: " ++ Reason; true -> "" end\r
+                     ]\r
+                  ))),\r
+                  json_reponse_ok();\r
+               {ok, User2 = #user{ek_master = false}} ->\r
+                  euphorik_bd:nouveau_message_sys(lists:flatten(io_lib:format("~s se fait slaper par ~s.~s",\r
+                     [\r
+                        User2#user.pseudo,\r
+                        User1#user.pseudo,\r
+                        if Reason =/= [] -> " - Raison: " ++ Reason; true -> "" end ++ "."\r
+                     ]\r
+                  ))),\r
+                  json_reponse_ok();\r
+               {ok, _} ->\r
+                  erreur("L'utilisateur est lui même un ekMaster");\r
+               _ ->\r
+                  erreur("Utilisateur à slaper inconnu")\r
+            end;\r
+         _ ->\r
+            erreur("Utilisateur inconnu ou non ek master")\r
+      end.\r
+      \r
\r
+put_troll(\r
+   [\r
+      {cookie, Cookie},\r
+      {content, Content}\r
+   ]\r
+) ->\r
+   % controle que l'utilisateur est un admin\r
+   case euphorik_bd:user_by_cookie(Cookie) of\r
+      {ok, User = #user{ek_master = true}} ->\r
+         case euphorik_bd:put_troll(User#user.id, Content) of\r
+            max_troll_reached_per_user ->\r
+               erreur(lists:flatten(io_lib:format("Le nombre de troll maximum par utilisateur est atteint : ~w ", [?NB_MAX_TROLL_WAITING_BY_USER])));\r
+            max_troll_reached ->\r
+               erreur(lists:flatten(io_lib:format("Le nombre de troll maximum en attente est atteint : ~w ", [?NB_MAX_TROLL_WAITING])));\r
+            _Id ->\r
+               json_reponse_ok()\r
+         end;\r
+      _ ->\r
+         erreur("Seul les ekMaster peuvent proposer des trolls")\r
+   end.\r
+   \r
+   \r
+mod_troll(\r
+   [\r
+      {cookie, Cookie},\r
+      {troll_id, Troll_id},\r
+      {content, Content}\r
+   ]\r
+) ->\r
+   % controle que l'utilisateur est un admin\r
+   case euphorik_bd:user_by_cookie(Cookie) of\r
+      {ok, User = #user{ek_master = true}} ->\r
+         User_id = User#user.id,\r
+         case euphorik_bd:troll_by_id(Troll_id) of\r
+            {ok, #troll{id_user = User_id}} ->\r
+               euphorik_bd:mod_troll(Troll_id, Content),\r
+               json_reponse_ok();\r
+            _ ->\r
+               erreur("Vous ne posséder pas ce troll")\r
+         end;\r
+      _ ->\r
+         erreur("Seul les ekMaster peuvent proposer des trolls")\r
+      end.\r
+\r
+   \r
+del_troll(\r
+   [\r
+      {cookie, Cookie},\r
+      {troll_id, Troll_id}\r
+   ]\r
+) -> \r
+   % controle que l'utilisateur est un admin\r
+   case euphorik_bd:user_by_cookie(Cookie) of\r
+      {ok, User = #user{ek_master = true}} ->\r
+         User_id = User#user.id,\r
+         case euphorik_bd:troll_by_id(Troll_id) of\r
+            {ok, #troll{id_user = User_id}} ->\r
+               euphorik_bd:del_troll(Troll_id),\r
+               json_reponse_ok();\r
+            _ ->\r
+               erreur("Vous ne posséder pas ce troll")\r
+         end;\r
+      _ ->\r
+         erreur("Seul les ekMaster peuvent proposer des trolls")\r
+   end.\r
+   \r
+   \r
+unban_ip(\r
+   [\r
+      {cookie, Cookie},\r
+      {ip, IP}\r
+   ]\r
+) ->\r
+   case euphorik_bd:user_by_cookie(Cookie) of\r
+      {ok, #user{ek_master = true}} ->\r
+         euphorik_bd:deban(euphorik_common:unserialize_ip(IP)),\r
+         json_reponse_ok();\r
+      _ ->\r
+         erreur("Seul les ekMaster peuvent connaitre la liste des ips bannies")\r
+   end.\r
+   \r
+   \r
+list_banned_ips(\r
+   [\r
+      {cookie, Cookie}\r
+   ]\r
+) ->\r
+   case euphorik_bd:user_by_cookie(Cookie) of\r
+      {ok, #user{ek_master = true}} ->\r
+         {\r
+            struct,\r
+            [\r
+               {reply, "list_banned_ips"},\r
+               {list, {array, lists:map(\r
+                  fun({IP, T, Users}) ->\r
+                     {struct,\r
+                        [\r
+                           {ip, euphorik_common:serialize_ip(IP)},\r
+                           {remaining_time, format_minutes(T)},\r
+                           {users, {array, lists:map(\r
+                              fun({Pseudo, Login}) ->\r
+                                 {struct,\r
+                                    [\r
+                                       {nick, Pseudo},\r
+                                       {login, Login}\r
+                                    ]\r
+                                 }\r
+                              end,\r
+                              Users\r
+                           )}}\r
+                        ]\r
+                     }\r
+                  end,\r
+                  euphorik_bd:list_ban()\r
+               )}}\r
+            ]\r
+         };\r
+      _ ->\r
+         erreur("Seul les ekMaster peuvent connaitre la liste des ips bannies")\r
+   end.\r
+\r
+\r
+% Construit une erreur\r
+erreur(Message) ->\r
+   {\r
+      struct, [\r
+         {reply, "error"},\r
+         {error_message, Message}\r
+      ]\r
+   }.\r
+   \r
+   \r
+% Formatage de minutes.\r
+% par exemple : "1min", "45min", "1h23min", "1jour 2h34min"\r
+format_minutes(Min) ->\r
+   Jours = Min div (60 * 24),\r
+   Heures = Min rem (60 * 24) div 60,\r
+   Minutes = Min rem (60),\r
+   if Jours =/= 0 -> integer_to_list(Jours) ++ " Jour" ++ if Jours > 1 -> "s"; true -> "" end ++ " "; true -> "" end ++\r
+   if Heures =/= 0 -> integer_to_list(Heures) ++ " heure"  ++ if Heures > 1 -> "s"; true -> "" end; true -> "" end ++\r
+   if Minutes == 0 ->\r
+         "";\r
+      true ->\r
+         " " ++ integer_to_list(Minutes) ++ " minute"  ++ if Minutes > 1 -> "s"; true -> "" end\r
+   end.\r
+   \r
    \r
 % Formatage d'une heure\r
 % local_time() -> string\r
    \r
 % Formatage d'une heure\r
 % local_time() -> string\r
@@ -627,7 +628,7 @@ format_date(Date) ->
    {{Annee, Mois, Jour}, {Heure, Minute, Seconde}} = DateLocal,\r
    {{AnneeNow, _, _}, {_, _, _}} = DateNowLocal,\r
    Hier = calendar:date_to_gregorian_days(element(1, DateLocal)) =:=  calendar:date_to_gregorian_days(element(1, DateNowLocal)) - 1,\r
    {{Annee, Mois, Jour}, {Heure, Minute, Seconde}} = DateLocal,\r
    {{AnneeNow, _, _}, {_, _, _}} = DateNowLocal,\r
    Hier = calendar:date_to_gregorian_days(element(1, DateLocal)) =:=  calendar:date_to_gregorian_days(element(1, DateNowLocal)) - 1,\r
-   lists:flatten(
+   lists:flatten(\r
       if element(1, DateLocal) =:= element(1, DateNowLocal) ->\r
          "";\r
          Hier ->\r
       if element(1, DateLocal) =:= element(1, DateNowLocal) ->\r
          "";\r
          Hier ->\r
@@ -637,29 +638,29 @@ format_date(Date) ->
          true ->\r
             io_lib:format("~2.10.0B/~2.10.0B/~B ", [Jour, Mois, Annee])\r
       end ++\r
          true ->\r
             io_lib:format("~2.10.0B/~2.10.0B/~B ", [Jour, Mois, Annee])\r
       end ++\r
-      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])\r
+   ).\r
+\r
+\r
+json_reponse_ok() ->\r
+   {struct, [{reply, "ok"}]}.\r
+   \r
+   \r
+json_reponse_login_ok(User) ->\r
+   {\r
+      struct, [\r
+         {reply, "login"},\r
+         {status, if (User#user.password =/= []) and (User#user.login =/= []) -> "auth_registered"; true -> "auth_not_registered" end},\r
+         {cookie, User#user.cookie},\r
+         {id, User#user.id},\r
+         {nick, User#user.pseudo},\r
+         {login, User#user.login},\r
+         {email, User#user.email},\r
+         {css, User#user.css},\r
+         {nick_format, atom_to_list(User#user.nick_format)},\r
+         {view_times, User#user.view_times},\r
+         {view_tooltips, User#user.view_tooltips},\r
+         {conversations, {array, User#user.conversations } },\r
+         {ek_master, User#user.ek_master}\r
+      ]\r
+   }.\r
index 28019da..616d0e7 100755 (executable)
 % \r
 % Ce module est fait pour répondre à des requêtes 'AJAX'.\r
 % Il est définit comme 'appmods' pour l'url "request" dans yaws.\r
 % \r
 % Ce module est fait pour répondre à des requêtes 'AJAX'.\r
 % Il est définit comme 'appmods' pour l'url "request" dans yaws.\r
-% 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.\r
+% @author G.Burri\r
+\r
 \r
 \r
-
 -module(euphorik_requests).\r
 -export([out/1]).\r
 -include_lib("xmerl/include/xmerl.hrl").\r
 -module(euphorik_requests).\r
 -export([out/1]).\r
 -include_lib("xmerl/include/xmerl.hrl").\r
--include_lib("yaws/include/yaws_api.hrl").
-
+-include_lib("yaws/include/yaws_api.hrl").\r
+-include("../include/euphorik_defines.hrl").\r
+\r
 \r
 \r
-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) ->\r
+   %io:format("~p~n", [A]), % utilisé parfois pendant le debug\r
+   IP = case inet:peername(A#arg.clisock) of\r
+      {ok, {Adresse, _Port}} -> Adresse;\r
+      _ -> inconnue\r
+   end,\r
+   % passive -> active, permet de recevoir {tcp_closed, _} lorsque le socket se ferme\r
    % keepalive -> true, evite que des firewalls coupe la connexion TCP sans prévenir\r
    inet:setopts(A#arg.clisock, [{active, true}, {keepalive, true}]),\r
    {value, {_, Contenu}} = lists:keysearch("action", 1, yaws_api:parse_post(A)),\r
    % keepalive -> true, evite que des firewalls coupe la connexion TCP sans prévenir\r
    inet:setopts(A#arg.clisock, [{active, true}, {keepalive, true}]),\r
    {value, {_, Contenu}} = lists:keysearch("action", 1, yaws_api:parse_post(A)),\r
-   Ret = traiter_donnees(Contenu, IP),
+   Ret = traiter_donnees(Contenu, IP),\r
    {content, "application/json", Ret}.\r
    {content, "application/json", Ret}.\r
-
 \r
 \r
-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).
+\r
+% Décode les données JSON.\r
+traiter_donnees(Contenu, IP) ->\r
+   {ok, {struct, [{header, {struct, [{action, Action}, {version, Version_client}]}} | Reste]}} = json:decode_string(Contenu),\r
+   json:encode(\r
+      if Version_client =:= ?VERSION_PROTOCOLE ->\r
+            traiter_action(Action, Reste, IP);\r
+         true ->\r
+            euphorik_protocole:erreur(lists:flatten(io_lib:format(\r
+               "La version du protocole du client (~w) ne correspond à celle du serveur (~w)", [Version_client, ?VERSION_PROTOCOLE]\r
+            )))\r
+      end\r
+   ).\r
+   \r
+\r
+% authentification d'un client\r
+traiter_action("authentification", JSON, IP) ->\r
+   euphorik_protocole:login(JSON, IP);\r
+% un client s'enregistre (pseudo + password)\r
+traiter_action("register", JSON, IP) ->\r
+   euphorik_protocole:register(JSON, IP);\r
+% modification du profile\r
+traiter_action("set_profile", JSON, _) ->\r
+   euphorik_protocole:profile(JSON);\r
+% un utilisateur attend un événement (par exemple l'arrivé d'un nouveau message)\r
+traiter_action("wait_event", JSON, _) ->\r
+   euphorik_protocole:wait_event(JSON);\r
+% un utilisateur envoie un message\r
+traiter_action("put_message", JSON, _) ->\r
+   euphorik_protocole:put_message(JSON);\r
+traiter_action("ban", JSON, _) ->\r
+   euphorik_protocole:ban(JSON);\r
+traiter_action("slap", JSON, _) ->\r
+   euphorik_protocole:slap(JSON);\r
+traiter_action("put_troll", JSON, _) ->\r
+   euphorik_protocole:put_troll(JSON);\r
+traiter_action("mod_troll", JSON, _) ->\r
+   euphorik_protocole:mod_troll(JSON);\r
+traiter_action("del_troll", JSON, _) ->\r
+   euphorik_protocole:del_troll(JSON);\r
+traiter_action("list_banned_ips", JSON, _) ->\r
+   euphorik_protocole:list_banned_ips(JSON);\r
+traiter_action("unban", JSON, _) ->\r
+   euphorik_protocole:unban_ip(JSON).\r
  
\ No newline at end of file
  
\ No newline at end of file
index bf6ec5b..8d22486 100755 (executable)
@@ -15,6 +15,9 @@
 % You should have received a copy of the GNU General Public License
 % along with Euphorik.  If not, see <http://www.gnu.org/licenses/>.
 
 % You should have received a copy of the GNU General Public License
 % along with Euphorik.  If not, see <http://www.gnu.org/licenses/>.
 
+% 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
 
 % Le temps d'attente après une erreur de login (mauvais login/pass) : une demie seconde
 % Permet d'éviter (limiter) les attaques par dictionnaire
index 71b24c3..1daf207 100644 (file)
@@ -3,7 +3,9 @@
     <editor-bookmarks xmlns="http://www.netbeans.org/ns/editor-bookmarks/1">
         <file>
             <url>js/pageMinichat.js</url>
     <editor-bookmarks xmlns="http://www.netbeans.org/ns/editor-bookmarks/1">
         <file>
             <url>js/pageMinichat.js</url>
-            <line>834</line>
+            <line>237</line>
+            <line>867</line>
+            <line>1107</line>
         </file>
     </editor-bookmarks>
 </project-private>
         </file>
     </editor-bookmarks>
 </project-private>
index 93e29d0..c61bcc0 100644 (file)
@@ -1,12 +1,11 @@
 file.reference.modules-erl=modules/erl
 file.reference.modules-include=modules/include
 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
 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.doc.dir=doc
 src.js.dir=js
+src.modules.dir=modules
 src.pages.dir=pages
 src.tools.dir=tools
 src.pages.dir=pages
 src.tools.dir=tools
index fa0f3ba..55ee5ef 100644 (file)
@@ -5,13 +5,12 @@
         <data xmlns="http://www.netbeans.org/ns/erlang-project/1">
             <name>euphorik</name>
             <source-roots>
         <data xmlns="http://www.netbeans.org/ns/erlang-project/1">
             <name>euphorik</name>
             <source-roots>
-                <root id="src.css.dir"/>
-                <root id="src.doc.dir"/>
-                <root id="src.pages.dir"/>
-                <root id="src.tools.dir"/>
-                <root id="src.js.dir"/>
-                <root id="src.dir"/>
-                <root id="include.dir"/>
+                <root id="src.css.dir" name="Css"/>
+                <root id="src.doc.dir" name="Documentation"/>
+                <root id="src.pages.dir" name="Pages XHTML"/>
+                <root id="src.tools.dir" name="Tools"/>
+                <root id="src.js.dir" name="JS"/>
+                <root id="src.modules.dir"/>
             </source-roots>
             <include-roots/>
             <test-roots/>
             </source-roots>
             <include-roots/>
             <test-roots/>