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

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Gos\Bundle\WebSocketBundle\Pusher;
  5. use Gos\Bundle\WebSocketBundle\Router\WampRouter;
  6. use Symfony\Component\Serializer\SerializerInterface;
  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.', AbstractPusher::class);
  10. /**
  11.  * @deprecated to be removed in 4.0, use the symfony/messenger component instead
  12.  */
  13. abstract class AbstractPusher implements PusherInterface
  14. {
  15.     protected SerializerInterface $serializer;
  16.     protected WampRouter $router;
  17.     protected bool $connected = false;
  18.     protected string $name = '';
  20.     public function __construct(WampRouter $router, SerializerInterface $serializer)
  21.     {
  22.         $this->router = $router;
  23.         $this->serializer = $serializer;
  24.     }
  26.     /**
  27.      * @param array|string $data
  28.      */
  29.     public function push($data, string $routeName, array $routeParameters = [], array $context = []): void
  30.     {
  31.         $channel = $this->router->generate($routeName, $routeParameters);
  33.         if (\is_string($data)) {
  34.             $data = [$data];
  35.         } elseif (!\is_array($data)) {
  36.             throw new \InvalidArgumentException(sprintf('The $data argument of %s() must be a string or array, a %s was given.', __METHOD__, \gettype($data)));
  37.         }
  39.         $this->doPush(new Message($channel, $data), $context);
  40.     }
  42.     abstract protected function doPush(Message $message, array $context): void;
  44.     public function isConnected(): bool
  45.     {
  46.         return $this->connected;
  47.     }
  49.     public function setConnected(bool $bool = true): void
  50.     {
  51.         $this->connected = $bool;
  52.     }
  54.     public function getName(): string
  55.     {
  56.         return $this->name;
  57.     }
  59.     public function setName(string $name): void
  60.     {
  61.         $this->name = $name;
  62.     }
  63. }