src/EventSubscriber/NotificationSubscriber.php line 46

Open in your IDE?
  1. <?php
  4. namespace App\EventSubscriber;
  6. use ApiPlatform\Core\EventListener\EventPriorities;
  7. use App\Entity\Notification;
  8. use App\Entity\User;
  9. use Doctrine\ORM\EntityManagerInterface;
  10. use Nyholm\Psr7\Factory\Psr17Factory;
  11. use OneSignal\Config;
  12. use OneSignal\OneSignal;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use Symfony\Component\HttpClient\Psr18Client;
  15. use Symfony\Component\HttpFoundation\Request;
  16. use Symfony\Component\HttpKernel\Event\ViewEvent;
  17. use Symfony\Component\HttpKernel\KernelEvents;
  18. use Symfony\Component\Security\Core\Encoder\UserPasswordEncoderInterface;
  20. class NotificationSubscriber implements EventSubscriberInterface
  21. {
  22.     private $entityManager;
  23.     private $config;
  24.     private $httpClient;
  25.     private $requestFactory;
  26.     private $oneSignal;
  27.     private $streamFactory;
  29.     public function __construct(EntityManagerInterface $entityManager)
  30.     {
  31.         $this->entityManager = $entityManager;
  32.         $this->config = new Config('26b2a12d-5cb9-4eea-a668-01f7e98ad9c2', 'MjNjZjcwNDItNzkyNC00MjBlLTg4NGMtZWZkNTNjNzkzMDU1');
  33.         $this->httpClient = new Psr18Client();
  34.         $this->requestFactory = $this->streamFactory = new Psr17Factory();
  36.         $this->oneSignal = new OneSignal($this->config, $this->httpClient, $this->requestFactory, $this->streamFactory);
  37.     }
  39.     public static function getSubscribedEvents()
  40.     {
  41.         return [
  42.             KernelEvents::VIEW => ['sendNotification', EventPriorities::PRE_WRITE],
  43.         ];
  44.     }
  46.     public function sendNotification(ViewEvent $event): void
  47.     {
  48.         $notification = $event->getControllerResult();
  49.         $method = $event->getRequest()->getMethod();
  51.         if (!$notification instanceof Notification || Request::METHOD_POST !== $method) {
  52.             return;
  53.         }
  54.         /*hashes_array = array();
  55.         $hashes_array[] = array(
  56.             "id" => "like-button",
  57.             "text" => "Like",
  58.             "icon" => "http://i.imgur.com/N8SN8ZS.png",
  59.             "url" => "https://yoursite.com"
  60.         );
  61.         $hashes_array[] = array(
  62.             "id" => "like-button-2",
  63.             "text" => "Like2",
  64.             "icon" => "http://i.imgur.com/N8SN8ZS.png",
  65.             "url" => "https://yoursite.com"
  66.         );*/
  67.         if(is_null($notification->getDeliverAt())){
  68.             $this->oneSignal->notifications()->add([
  69.                 'contents' => [
  70.                     $notification->getLocale() => $notification->getMessage()
  71.                 ],
  72.                 'subtitle' => [
  73.                     'en' => $notification->getSubtitle()
  74.                 ],
  75.                 'included_segments' => ['Subscribed Users'],
  76.                 'data' => ["target" => $notification->getTarget(),"id" => $notification->getIdobject()]
  77.             ]);
  78.         } else {
  79.             $this->oneSignal->notifications()->add([
  80.                 'contents' => [
  81.                     $notification->getLocale() => $notification->getMessage()
  82.                 ],
  83.                 'subtitle' => [
  84.                     'en' => $notification->getSubtitle()
  85.                 ],
  86.                 'included_segments' => ['Subscribed Users'],
  87.                 'data' => ["target" => $notification->getTarget(),"id" => $notification->getIdobject()],
  88.                 'send_after' => new \DateTimeImmutable($notification->getDeliverAt())
  89.             ]);
  90.         }
  92.     }
  93. }