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. }