vendor/gos/web-socket-bundle/src/Pusher/Wamp/WampConnectionFactory.php line 12

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Gos\Bundle\WebSocketBundle\Pusher\Wamp;
  5. use Gos\Component\WebSocketClient\Wamp\Client;
  6. use Gos\Component\WebSocketClient\Wamp\ClientFactory;
  7. use Gos\Component\WebSocketClient\Wamp\ClientInterface;
  8. use Psr\Log\LoggerAwareInterface;
  9. use Psr\Log\LoggerAwareTrait;
  10. use Symfony\Component\OptionsResolver\OptionsResolver;
  12. trigger_deprecation('gos/web-socket-bundle', '3.1', 'The "%s" class is deprecated and will be removed in 4.0, use "%s" instead.', WampConnectionFactory::class, ClientFactory::class);
  14. /**
  15. * @deprecated to be removed in 4.0, use Gos\Component\WebSocketClient\Wamp\ClientFactory from the gos/websocket-client package instead
  16. */
  17. final class WampConnectionFactory implements WampConnectionFactoryInterface, LoggerAwareInterface
  18. {
  19. use LoggerAwareTrait;
  21. private array $config;
  23. public function __construct(array $config)
  24. {
  25. $this->config = $this->resolveConfig($config);
  26. }
  28. public function createConnection(): ClientInterface
  29. {
  30. $client = new Client(
  31. $this->config['host'],
  32. $this->config['port'],
  33. $this->config['ssl'],
  34. $this->config['origin']
  35. );
  37. if (null !== $this->logger) {
  38. $client->setLogger($this->logger);
  39. }
  41. return $client;
  42. }
  44. private function resolveConfig(array $config): array
  45. {
  46. $resolver = new OptionsResolver();
  48. $resolver->setRequired(
  49. [
  50. 'host',
  51. 'port',
  52. ]
  53. );
  55. $resolver->setDefaults(
  56. [
  57. 'ssl' => false,
  58. 'origin' => null,
  59. ]
  60. );
  62. $resolver->setAllowedTypes('host', 'string');
  63. $resolver->setAllowedTypes('port', ['string', 'integer']);
  64. $resolver->setAllowedTypes('ssl', 'boolean');
  65. $resolver->setAllowedTypes('origin', ['string', 'null']);
  67. return $resolver->resolve($config);
  68. }
  69. }