vendor/gos/web-socket-bundle/src/Pusher/DataCollectingPusherDecorator.php line 8

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Gos\Bundle\WebSocketBundle\Pusher;
  5. use Gos\Bundle\WebSocketBundle\DataCollector\WebsocketDataCollector;
  6. use Symfony\Component\Stopwatch\Stopwatch;
  8. trigger_deprecation('gos/web-socket-bundle', '3.1', 'The "%s" class is deprecated and will be removed in 4.0, use the symfony/messenger component instead.', DataCollectingPusherDecorator::class);
  10. /**
  11. * @deprecated to be removed in 4.0, use the symfony/messenger component instead
  12. */
  13. final class DataCollectingPusherDecorator implements PusherInterface
  14. {
  15. private PusherInterface $pusher;
  16. private Stopwatch $stopwatch;
  17. private WebsocketDataCollector $dataCollector;
  19. public function __construct(PusherInterface $pusher, Stopwatch $stopwatch, WebsocketDataCollector $dataCollector)
  20. {
  21. $this->pusher = $pusher;
  22. $this->stopwatch = $stopwatch;
  23. $this->dataCollector = $dataCollector;
  24. }
  26. /**
  27. * @param string|array $data
  28. */
  29. public function push($data, string $routeName, array $routeParameters = [], array $context = []): void
  30. {
  31. $eventName = 'push.'.$this->getName();
  33. $this->stopwatch->start($eventName, 'websocket');
  34. $this->pusher->push($data, $routeName, $routeParameters, $context);
  35. $this->stopwatch->stop($eventName);
  37. $this->dataCollector->collectData($this->stopwatch->getEvent($eventName), $this->getName());
  38. }
  40. public function close(): void
  41. {
  42. $this->pusher->close();
  43. }
  45. public function setName(string $name): void
  46. {
  47. $this->pusher->setName($name);
  48. }
  50. public function getName(): string
  51. {
  52. return $this->pusher->getName();
  53. }
  54. }