src/AdminBundle/Services/WebsocketNotificationService.php line 28

Open in your IDE?
  1. <?php
  3. namespace AdminBundle\Services;
  5. use AdminBundle\Entity\NotificationHistory;
  6. use AdminBundle\Entity\User;
  7. use DateTime;
  8. use Doctrine\ORM\EntityManagerInterface;
  9. use ZMQ;
  10. use ZMQContext;
  11. use ZMQSocket;
  13. class WebsocketNotificationService
  14. {
  15. /** @var EntityManagerInterface */
  16. private $em;
  18. /** @var string */
  19. private $tcpServer;
  21. /** @var string */
  22. private $port;
  24. /**
  25. * @param string $tcpServer
  26. * @param string $port
  27. */
  28. public function __construct(EntityManagerInterface $em, $tcpServer, $port)
  29. {
  30. $this->em = $em;
  31. $this->tcpServer = $tcpServer;
  32. $this->port = $port;
  34. $context = new ZMQContext();
  35. $this->socket = new ZMQSocket($context, ZMQ::SOCKET_PUSH);
  36. $this->server = "tcp://{$tcpServer}:{$port}";
  37. }
  39. /**
  40. * @param array $data
  41. */
  42. public function send($data)
  43. {
  44. $this->socket->connect($this->server);
  45. $this->socket->send(json_encode($data));
  47. $this->createHistory($data);
  49. $this->socket->disconnect("tcp://{$this->tcpServer}:{$this->port}");
  50. }
  52. /**
  53. * @param array $data
  54. */
  55. private function createHistory($data)
  56. {
  57. $user = $this->em->getRepository(User::class)->findOneByApiKey($data['apiKey']);
  59. if (!$user) {
  60. return;
  61. }
  63. $this
  64. ->em
  65. ->getRepository(NotificationHistory::class)
  66. ->insert($user->getId(), $data['data']['event'], $data, new DateTime())
  67. ;
  68. }
  69. }