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