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