Evolution #163: Evenements: Prise en comptes des autres facteurs

app/Resources/translations/elements.fr.yml

       min:              Le commentaire doit être de %limit% caractéres minimum
       max:              Le commentaire doit être de %limit% caractéres maximum
       unknow:           Une erreur est survenue
+    follow:
+      label:            M'avertir en cas de nouveaux commentaires
   vote:
     good:               Ce partage mérite un point supplémentaire (cliquez a nouveau pour enlever)
   

src/Muzich/CommentBundle/Controller/CommentController.php

       )));
     }
     
+    $follow = false;
+    if ($this->getRequest()->request->get('follow') == true)
+    {
+      $follow = true;
+    }
+    
     // On met a jour les commentaires
     $cm = new CommentsManager($element->getComments());
-    $cm->add($this->getUser(), $comment);
+    $cm->add($this->getUser(), $comment, $follow);
     $element->setComments($cm->get());
     $event = new EventElement($this->container);
     
     // Event pour user d'un nouveau comment
-    if ($this->getUserId() != $element->getOwner()->getId())
-    {
-      $event->commentAdded($element);
-    }
+    $event->commentAdded($element, $this->getUser());
 
     $this->getDoctrine()->getEntityManager()->persist($element);
     $this->getDoctrine()->getEntityManager()->flush();
         )
       )));
     }
+    
+    $follow = false;
+    if ($this->getRequest()->request->get('follow') == true)
+    {
+      $follow = true;
+    }
       
     // On met a jour les commentaires
     $cm = new CommentsManager($element->getComments());
-    $cm->update($this->getUser(), $date, $comment);
+    $cm->update($this->getUser(), $date, $comment, $follow);
     $element->setComments($cm->get());
 
     $this->getDoctrine()->getEntityManager()->persist($element);

src/Muzich/CommentBundle/Resources/views/Comment/form.html.twig

 <textarea name="comment">{% if comment_value is defined %}{{ comment_value }}{% endif %}</textarea>
+
 <div class="buttons">
   <input 
     type="submit" 
     value="{{ cancel_value }}" 
     class="button cancel"
   />
-</div>
+</div>
+
+{% if not own %}
+  <br />
+  <input type="checkbox" name="follow" id="input_comment_follow" {% if following %}checked="checked"{% endif %} />
+  <label for="input_comment_follow">{{ 'element.comments.follow.label'|trans({}, 'elements') }}</label>
+{% endif %}

src/Muzich/CoreBundle/DataFixtures/ORM/LoadElementData.php

     $cm = new CommentsManager();
     $cm->add($joelle, "J'aime bien quand ça tape. Ca rapelle ".
       "le grincement sinistre des volets de vieilles ".
-      "maisons. D'ailleur j'ai repeint mon mur des shiots !", $this->dateD(180));
+      "maisons. D'ailleur j'ai repeint mon mur des shiots !", false, $this->dateD(180));
     
     $this->createElement('azyd_azylum_1', 'AZYD AZYLUM Live au Café Provisoire', 
       'http://www.youtube.com/watch?v=8AXhRXAt2E4', 
     );
     
     $cm = new CommentsManager();
-    $cm->add($bux, "Je commenteuuh nanana 1", $this->dateD(180));
-    $cm->add($paul, "Je répond 2", $this->dateD(180));
-    $cm->add($bux, "Je répond 3", $this->dateD(179));
-    $cm->add($paul, "Je répond 4", $this->dateD(178));
-    $cm->add($bux, "Je répond 5", $this->dateD(177));
-    $cm->add($paul, "Je répond 6", $this->dateD(176));
-    $cm->add($bux, "Je répond 7", $this->dateD(175));
-    $cm->add($paul, "Je répond 8", $this->dateD(174));
-    $cm->add($bux, "Je répond 9", $this->dateD(173));
-    $cm->add($paul, "Je répond 10", $this->dateD(172));
-    $cm->add($bux, "Je répond 11", $this->dateD(161));
-    $cm->add($paul, "Je répond 12", $this->dateD(150));
-    $cm->add($bux, "Je répond 13", $this->dateD(140));
+    $cm->add($bux, "Je commenteuuh nanana 1", false, $this->dateD(180));
+    $cm->add($paul, "Je répond 2", false, $this->dateD(180));
+    $cm->add($bux, "Je répond 3", false, $this->dateD(179));
+    $cm->add($paul, "Je répond 4", false, $this->dateD(178));
+    $cm->add($bux, "Je répond 5", false, $this->dateD(177));
+    $cm->add($paul, "Je répond 6", false, $this->dateD(176));
+    $cm->add($bux, "Je répond 7", false, $this->dateD(175));
+    $cm->add($paul, "Je répond 8", false, $this->dateD(174));
+    $cm->add($bux, "Je répond 9", false, $this->dateD(173));
+    $cm->add($paul, "Je répond 10", false, $this->dateD(172));
+    $cm->add($bux, "Je répond 11", false, $this->dateD(161));
+    $cm->add($paul, "Je répond 12", false, $this->dateD(150));
+    $cm->add($bux, "Je répond 13", false, $this->dateD(140));
     
     $this->createElement('babylon_pression_1', 'Babylon Pression - Des Tasers et des Pauvres', 
       'http://www.youtube.com/watch?v=XWkbaHxRvds&feature=related', 
     );
     
     $cm = new CommentsManager();
-    $cm->add($bux, "C'est trop bon hein ?", $this->dateD(180));
-    $cm->add($paul, "C'est pas mal en effet", $this->dateD(180));
+    $cm->add($bux, "C'est trop bon hein ?", false, $this->dateD(180));
+    $cm->add($paul, "C'est pas mal en effet", false, $this->dateD(180));
         
     $this->createElement('ed_cox_1', 'Ed Cox - La fanfare des teuffeurs (Hardcordian)', 
       'http://www.youtube.com/watch?v=Lk1gnh-JCDs&feature=related', 

src/Muzich/CoreBundle/Entity/Element.php

 use Symfony\Component\Validator\Constraints as Assert;
 use Muzich\CoreBundle\Validator as MuzichAssert;
 use Muzich\CoreBundle\Entity\Tag;
+use Muzich\CoreBundle\Managers\CommentsManager;
 
 /**
  * L'Element est l'Element central de l'application. C'est cet
     return false;
   }
   
+  /**
+   * Retourne vrai si l'utilisateur a demandé qa suivre les commentaires
+   *  
+   * @param int $user_id identifiant de l'utilisateur
+   * @return boolean 
+   */
+  public function userFollowComments($user_id)
+  {
+    $cm = new CommentsManager($this->getComments());
+    return $cm->userFollow($user_id);
+  }
+  
 }

src/Muzich/CoreBundle/Managers/CommentsManager.php

   
   public function __construct($comments = array())
   {
+    if ($comments == null)
+    {
+      $comments = array();
+    }
+    
     $this->comments = $comments;
   }
   
    * Ajouter un commentaire au tableau.
    * 
    * @param \Muzich\CoreBundle\Entity\User $user
-   * @param String $comment
-   * @param String $date 
+   * @param String $comment Contenu du commentaire
+   * @param boolean $follow L'utilisateur désire être avertis des nouveaux commentaires
+   * @param String $date date de l'envoi
    */
-  public function add($user, $comment, $date = null)
+  public function add($user, $comment, $follow = false, $date = null)
   {
     if (!$date)
     {
         "s" => $user->getSlug(),
         "n" => $user->getName()
       ),
+      "f" => $follow,
       "d" => $date,
       "c" => $comment
     );
+    
+    if (!$follow)
+    {
+      $this->userSetFollowToFalse($user->getId());
+    }
   }
   
   /**
    * @param \Muzich\CoreBundle\Entity\User $user
    * @param date $date (Y-m-d H:i:s u)
    * @param string $comment_c 
+   * @param boolean $follow
    */
-  public function update($user, $date, $comment_c)
+  public function update($user, $date, $comment_c, $follow)
   {
     $comments = array();
+    $found = false;
     foreach ($this->comments as $comment)
     {
       if ($comment['u']['i'] == $user->getId() && $comment['d'] == $date)
       {
+        $found = true;
         $comments[] = array(
           "u" => array(
             "i" => $user->getId(),
             "n" => $user->getName()
           ),
           "e" => date('Y-m-d H:i:s u'),
+          "f" => $follow,
           "d" => $date,
           "c" => $comment_c
         );
     }
     
     $this->comments = $comments;
+    
+    if (!$follow && $found)
+    {
+      $this->userSetFollowToFalse($user->getId());
+    }
   }
   
   /**
     return $this->comments[$index];
   }
   
+  /**
+   * Regarde si il existe un commentaire pour cet utilisateur où il demande
+   * a suivre les commentaires.
+   * 
+   * @param int $user_id
+   * @return boolean 
+   */
+  public function userFollow($user_id)
+  {
+    foreach ($this->comments as $i => $comment)
+    {
+      if ($comment['u']['i'] == $user_id && $comment['f'] == true)
+      {
+        return true;
+      }
+    }
+    return false;
+  }
+  
+  /**
+   * Passe tout les commentaire de cet utilisateur en follow = false
+   * 
+   * @param int $user_id 
+   */
+  private function userSetFollowToFalse($user_id)
+  {
+    $comments = array();
+    foreach ($this->comments as $comment)
+    {
+      if ($comment['u']['i'] == $user_id)
+      {
+        $comment['f'] = false;
+      }
+      $comments[] = $comment;
+    }
+    $this->comments = $comments;
+  }
+  
+  /**
+   *  Retourne les ids utilisateurs ayant demandé a être avertis des nouveaux
+   * commentaires.
+   * 
+   * @return array ids des utilisateurs
+   */
+  public function getFollowersIds()
+  {
+    $ids = array();
+    foreach ($this->comments as $comment)
+    {
+      if ($comment['f'] == true)
+      {
+        if (!in_array($comment['u']['i'], $ids))
+        {
+          $ids[] = $comment['u']['i'];
+        }
+      }
+    }
+    return $ids;
+  }
+  
 }

src/Muzich/CoreBundle/Propagator/EventElement.php

 use Muzich\CoreBundle\Actions\User\Event as UserEventAction;
 use Muzich\CoreBundle\Actions\User\Reputation as UserReputation;
 use Muzich\CoreBundle\Entity\Event;
+use Muzich\CoreBundle\Entity\User;
+use Muzich\CoreBundle\Managers\CommentsManager;
 
 /**
  * Propagateur d'événement concernant les éléments
    * événement. Actuellement il:
    * * Met a jour ou créer un objet événement (nouveau commentaire) pour le
    *   propriétaire de l'élément.
+   * * Met a jour ou créer un objet événement (nouveau commentaire) pour les
+   *   utilisateurs qui follow cet élément.
    * 
    * @param Element $element 
    */
-  public function commentAdded(Element $element)
+  public function commentAdded(Element $element, User $user)
   {
-    $uea = new UserEventAction($element->getOwner(), $this->container);
-    $event = $uea->proceed(Event::TYPE_COMMENT_ADDED_ELEMENT, $element->getId());
-    $this->container->get('doctrine')->getEntityManager()->persist($event);
+    // On avertis le propriétaire si ce n'est pas lui même qui vient de commenter
+    if ($user->getId() != $element->getOwner()->getId())
+    {
+      $uea = new UserEventAction($element->getOwner(), $this->container);
+      $event = $uea->proceed(Event::TYPE_COMMENT_ADDED_ELEMENT, $element->getId());
+      $this->container->get('doctrine')->getEntityManager()->persist($event);
+    }
+    
+    // Pour chaque utilisateur qui a demandé a être avertis d'un nouveau commentaire
+    $cm = new CommentsManager($element->getComments());
+    $uids = $cm->getFollowersIds();
+    
+    if (count($uids))
+    {
+      $users = $this->container->get('doctrine')->getEntityManager()
+        ->getRepository('MuzichCoreBundle:User')
+        ->getUsersWithIds($uids)
+      ;
+      if (count($users))
+      {
+        foreach ($users as $user_c)
+        {
+          // On n'avertis pas l'utilisateur de son propre commentaire
+          if ($user->getId() != $user_c->getId())
+          {
+            $uea = new UserEventAction($user_c, $this->container);
+            $event = $uea->proceed(Event::TYPE_COMMENT_ADDED_ELEMENT, $element->getId());
+            $this->container->get('doctrine')->getEntityManager()->persist($event);
+          }
+        }
+      }
+    }
   }
   
   /**

src/Muzich/CoreBundle/Repository/UserRepository.php

     return 0;
   }
   
+  /**
+   * Retourne les objets utilisateurs correspondant aux ids transmis.
+   *
+   * @param array $ids
+   * @return Collection 
+   */
+  public function getUsersWithIds($ids)
+  {
+    return $this->getEntityManager()
+      ->createQuery('SELECT u FROM MuzichCoreBundle:User u'
+        .' WHERE u.id IN (:uids)')
+      ->setParameter('uids', $ids)
+      ->getResult()
+    ;
+  }
+  
 }  

src/Muzich/CoreBundle/Resources/views/SearchElement/element.html.twig

     >
       {% include "MuzichCommentBundle:Comment:form.html.twig" with {
         'submit_value' : 'element.comments.add_submit'|trans({}, 'elements'),
-        'cancel_value' : 'element.comments.add_cancel'|trans({}, 'elements')
+        'cancel_value' : 'element.comments.add_cancel'|trans({}, 'elements'),
+        'following'    : element.userFollowComments(app.user.id),
+        'own'          : (app.user.id == element.owner.id)
       } %}
     </form>