vendor/hwi/oauth-bundle/src/OAuth/RequestDataStorage/SessionStorage.php line 47

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of the HWIOAuthBundle package.
  5.  *
  6.  * (c) Hardware Info <opensource@hardware.info>
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. namespace HWI\Bundle\OAuthBundle\OAuth\RequestDataStorage;
  14. use HWI\Bundle\OAuthBundle\OAuth\RequestDataStorageInterface;
  15. use HWI\Bundle\OAuthBundle\OAuth\ResourceOwnerInterface;
  16. use Symfony\Component\HttpFoundation\RequestStack;
  17. use Symfony\Component\HttpFoundation\Session\SessionInterface;
  19. /**
  20.  * Request token storage implementation using the Symfony session.
  21.  *
  22.  * @author Alexander <iam.asm89@gmail.com>
  23.  * @author Francisco Facioni <fran6co@gmail.com>
  24.  * @author Joseph Bielawski <stloyd@gmail.com>
  25.  */
  26. final class SessionStorage implements RequestDataStorageInterface
  27. {
  28.     private RequestStack $requestStack;
  30.     public function __construct(RequestStack $requestStack)
  31.     {
  32.         $this->requestStack = $requestStack;
  33.     }
  35.     /**
  36.      * {@inheritdoc}
  37.      */
  38.     public function fetch(ResourceOwnerInterface $resourceOwner, $key, $type = 'token')
  39.     {
  40.         $key = $this->generateKey($resourceOwner, $key, $type);
  41.         if (null === $data = $this->getSession()->get($key)) {
  42.             throw new \InvalidArgumentException('No data available in storage.');
  43.         }
  45.         // Request tokens are one time use only
  46.         if (\in_array($type, ['token', 'csrf_state'], true)) {
  47.             $this->getSession()->remove($key);
  48.         }
  50.         return $data;
  51.     }
  53.     /**
  54.      * {@inheritdoc}
  55.      */
  56.     public function save(ResourceOwnerInterface $resourceOwner, $value, $type = 'token')
  57.     {
  58.         if ('token' === $type) {
  59.             if (!\is_array($value) || !isset($value['oauth_token'])) {
  60.                 throw new \InvalidArgumentException('Invalid request token.');
  61.             }
  63.             $key = $this->generateKey($resourceOwner, $value['oauth_token'], 'token');
  64.         } else {
  65.             $key = $this->generateKey($resourceOwner, $this->getStorageKey($value), $type);
  66.         }
  68.         $this->getSession()->set($key, $this->getStorageValue($value));
  69.     }
  71.     /**
  72.      * Key to for fetching or saving a token.
  73.      */
  74.     private function generateKey(ResourceOwnerInterface $resourceOwner, string $key, string $type): string
  75.     {
  76.         return sprintf('_hwi_oauth.%s.%s.%s.%s', $resourceOwner->getName(), $resourceOwner->getOption('client_id'), $type, $key);
  77.     }
  79.     /**
  80.      * @param array|string|object $value
  81.      *
  82.      * @return array|string
  83.      */
  84.     private function getStorageValue($value)
  85.     {
  86.         if (\is_object($value)) {
  87.             $value = serialize($value);
  88.         }
  90.         return $value;
  91.     }
  93.     /**
  94.      * @param array|string|object $value
  95.      */
  96.     private function getStorageKey($value): string
  97.     {
  98.         if (\is_array($value)) {
  99.             $storageKey = reset($value);
  100.         } elseif (\is_object($value)) {
  101.             $storageKey = $value::class;
  102.         } else {
  103.             $storageKey = $value;
  104.         }
  106.         return (string) $storageKey;
  107.     }
  109.     private function getSession(): SessionInterface
  110.     {
  111.         if (method_exists($this->requestStack, 'getSession')) {
  112.             return $this->requestStack->getSession();
  113.         }
  115.         if ((null !== $request = $this->requestStack->getCurrentRequest()) && $request->hasSession()) {
  116.             return $request->getSession();
  117.         }
  119.         throw new \LogicException('There is currently no session available.');
  120.     }
  121. }