src/EventSubscriber/Messaging/MessageResourceSubscriber.php line 34

  1. <?php
  3. namespace App\EventSubscriber\Messaging;
  5. use Symfony\Component\HttpFoundation\RequestStack;
  6. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  7. use Symfony\Component\EventDispatcher\GenericEvent;
  8. use Webmozart\Assert\Assert;
  9. use Sylius\Component\Customer\Model\CustomerInterface;
  10. use App\Repository\Customer\CustomerRepository;
  11. use App\Entity\Channel\ChannelEcodaAccountInfo;
  12. use App\Entity\Messaging\AdminMessage;
  13. use App\Repository\Channel\ChannelEcodaAccountInfoRepository;
  14. use App\Repository\Channel\ChannelEcodaAccountTypeRepository;
  15. use Doctrine\ORM\EntityManagerInterface;
  16. use Symfony\Component\Security\Core\Authorization\AuthorizationCheckerInterface;
  17. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
  18. use App\Entity\Messaging\Message; 
  21. class MessageResourceSubscriber  implements EventSubscriberInterface
  22. { 
  23.     private $request;
  24.     private $storage;
  25.     private $em;
  27.     public function __construct(RequestStack $request, EntityManagerInterface $em, TokenStorageInterface $storage)
  28.     {
  29.         $this->request = $request->getCurrentRequest(); 
  30.         $this->storage = $storage;
  31.         $this->em = $em;
  32.     }
  34.     public function onPreCreate(GenericEvent $event)
  35.     {  
  36.         $entity = $event->getSubject();  
  37.         Assert::isInstanceOf($entity, Message::class);
  38.     
  39.         $thread = $this->em->getRepository('App:Messaging\Thread')->find($this->request->query->get('thread')); 
  40.         $replyTo = $this->em->getRepository('App:Messaging\Message')->find($this->request->query->get('reply_to')); 
  41.         
  42.         $entity->setThread($thread);
  43.         $entity->setReplyTo($replyTo);
  44.         $entity->setType('admin');
  46.         $message = new AdminMessage();
  47.         $message->setAdmin($this->storage->getToken()->getUser());  
  48.         $message->setCustomer($thread->getOwner()->getCustomer());
  49.         
  50.         $entity->setAdminMessage($message);
  51.     }   
  53.     public function onPreUpdate(GenericEvent $event)
  54.     {  
  55.         $entity = $event->getSubject();  
  56.         Assert::isInstanceOf($entity, Message::class);
  57.      
  58.         
  59.         $entity->getThread()->setUpdatedAt(new \Datetime('now')); 
  60.     }   
  61.     public static function getSubscribedEvents()
  62.     {
  63.         return [
  64.            'app.message.pre_create' => 'onPreCreate',  
  65.            'app.message.pre_update' => 'onPreUpdate',   
  66.         ];
  67.     }
  68. }