src/EventSubscriber/NotificationSubscriber.php line 53

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace App\EventSubscriber;
  7. use Doctrine\ORM\EntityManagerInterface;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use Gos\Bundle\WebSocketBundle\Pusher\PusherInterface;
  13. use App\Event\NotificationCreatedEvent;
  15. class NotificationSubscriber implements EventSubscriberInterface
  16. {
  17.     /**
  18.      * @var PusherInterface
  19.      */
  20.     private $pusher;
  22.     /**
  23.      * @var EntityManagerInterface
  24.      */
  25.     private $entityManager;
  27.     /**
  28.      * NotificationSubscriber constructor.
  29.      * @param PusherInterface $pusher
  30.      * @param EntityManagerInterface $entityManager
  31.      */
  32.     public function __construct(PusherInterface $pusher, EntityManagerInterface $entityManager)
  33.     {
  34.         $this->pusher = $pusher;
  35.         $this->entityManager = $entityManager;
  36.     }
  38.     /**
  39.      * @return array
  40.      */
  41.     public static function getSubscribedEvents()
  42.     {
  43.         return [
  44.             NotificationCreatedEvent::class => [
  45.                 ['onNotificationCreated', 10]
  46.             ],
  47.         ];
  48.     }
  50.     /**
  51.      * @param NotificationCreatedEvent $event
  52.      */
  53.     public function onNotificationCreated(NotificationCreatedEvent $event)
  54.     {
  55.         $notification = $event->getNotification();
  56.         $this->entityManager->persist($notification);
  58.        // $socketResponse = 'ready';
  59.        // $this->pusher->push($socketResponse, 'acme_topic', []);
  60.     }
  61. }