vendor/gos/web-socket-bundle/src/Client/Auth/WebsocketAuthenticationProvider.php line 18

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Gos\Bundle\WebSocketBundle\Client\Auth;
  5. use Gos\Bundle\WebSocketBundle\Client\ClientStorageInterface;
  6. use Psr\Log\LoggerAwareInterface;
  7. use Psr\Log\LoggerAwareTrait;
  8. use Ratchet\ConnectionInterface;
  9. use Symfony\Component\Security\Core\Authentication\Token\AnonymousToken;
  10. use Symfony\Component\Security\Core\Authentication\Token\NullToken;
  11. use Symfony\Component\Security\Core\Authentication\Token\TokenInterface;
  13. trigger_deprecation('gos/web-socket-bundle', '3.11', 'The "%s" class is deprecated and will be removed in 4.0, use the new websocket authentication API instead.', WebsocketAuthenticationProvider::class);
  15. /**
  16.  * @deprecated to be removed in 4.0, use the new websocket authentication API instead
  17.  */
  18. final class WebsocketAuthenticationProvider implements WebsocketAuthenticationProviderInterface, LoggerAwareInterface
  19. {
  20.     use LoggerAwareTrait;
  22.     private ClientStorageInterface $clientStorage;
  24.     /**
  25.      * @var string[]
  26.      */
  27.     private array $firewalls = [];
  29.     /**
  30.      * @param string[] $firewalls
  31.      */
  32.     public function __construct(ClientStorageInterface $clientStorage, array $firewalls = [])
  33.     {
  34.         $this->clientStorage = $clientStorage;
  35.         $this->firewalls = $firewalls;
  36.     }
  38.     public function authenticate(ConnectionInterface $conn): TokenInterface
  39.     {
  40.         if (1 === \count($this->firewalls) && 'ws_firewall' === $this->firewalls[0]) {
  41.             if (null !== $this->logger) {
  42.                 $this->logger->warning(
  43.                     sprintf(
  44.                         'User firewall is not configured, we have set %s by default',
  45.                         $this->firewalls[0]
  46.                     )
  47.                 );
  48.             }
  49.         }
  51.         $token = $this->getToken($conn);
  53.         $identifier = $this->clientStorage->getStorageId($conn);
  55.         $this->clientStorage->addClient($identifier, $token);
  57.         if (null !== $this->logger) {
  58.             $this->logger->info(
  59.                 sprintf(
  60.                     '%s connected',
  61.                     method_exists($token, 'getUserIdentifier') ? $token->getUserIdentifier() : $token->getUsername()
  62.                 ),
  63.                 [
  64.                     'connection_id' => $conn->resourceId,
  65.                     'session_id' => $conn->WAMP->sessionId,
  66.                     'storage_id' => $identifier,
  67.                 ]
  68.             );
  69.         }
  71.         return $token;
  72.     }
  74.     private function getToken(ConnectionInterface $connection): TokenInterface
  75.     {
  76.         $token = null;
  78.         if (isset($connection->Session) && $connection->Session) {
  79.             foreach ($this->firewalls as $firewall) {
  80.                 if (false !== $serializedToken = $connection->Session->get('_security_'.$firewall, false)) {
  81.                     /** @var TokenInterface $token */
  82.                     $token = unserialize($serializedToken);
  84.                     break;
  85.                 }
  86.             }
  87.         }
  89.         if (null === $token) {
  90.             if (class_exists(NullToken::class)) {
  91.                 $token = new NullToken();
  92.             } else {
  93.                 $token = new AnonymousToken($this->firewalls[0], 'anon-'.$connection->WAMP->sessionId);
  94.             }
  95.         }
  97.         return $token;
  98.     }
  99. }