src/EventListener/NeutralApiAuthListener.php line 82

Open in your IDE?
  1. <?php
  2. declare(strict_types=1);
  4. namespace App\EventListener;
  6. use EightPoints\Bundle\GuzzleBundle\Events\GuzzleEventListenerInterface;
  7. use EightPoints\Bundle\GuzzleBundle\Events\PreTransactionEvent;
  8. use GuzzleHttp\Client;
  9. use Psr\Cache\CacheItemPoolInterface;
  10. use Symfony\Component\HttpFoundation\RequestStack;
  12. class NeutralApiAuthListener implements GuzzleEventListenerInterface
  13. {
  14.     protected $serviceName;
  16.     /**
  17.      * @var CacheItemPoolInterface
  18.      */
  19.     protected $cache;
  21.     /**
  22.      * @var Client
  23.      */
  24.     protected $client;
  26.     /**
  27.      * @var RequestStack
  28.      */
  29.     protected $requestStack;
  31.     public function __construct(CacheItemPoolInterface $cache, Client $client, RequestStack $requestStack)
  32.     {
  33.         $this->cache = $cache;
  34.         $this->client = $client;
  35.         $this->requestStack = $requestStack;
  36.     }
  38.     public function getServiceName()
  39.     {
  40.         return $this->serviceName;
  41.     }
  43.     /**
  44.      * @inheritDoc
  45.      */
  46.     public function setServiceName($serviceName)
  47.     {
  48.         $this->serviceName = $serviceName;
  49.         return $this;
  50.     }
  52.     /**
  53.      * @return string
  54.      * @throws \Psr\Cache\InvalidArgumentException
  55.      */
  56.     protected function getToken(): string
  57.     {
  58.         $cacheItem = $this->cache->getItem('neutral_token');
  59.         if (!$cacheItem->isHit()) {
  60.             $response = $this->client->post('/restV/oauth/token', [
  61.                 'multipart' => [
  62.                     ['name' => 'grant_type', 'contents' => 'client_credentials']
  63.                 ]
  64.             ]);
  65.             $token = json_decode($response->getBody()->getContents(), true);
  66.             $cacheItem->set($token);
  67.             $minutes = intval($token['expires_in'] / 60);
  68.             $cacheItem->expiresAfter(\DateInterval::createFromDateString(sprintf('+ %s minutes', $minutes)));
  70.             $this->cache->save($cacheItem);
  71.         }
  72.         $token = $cacheItem->get();
  74.         return $token['access_token'];
  75.     }
  77.     /**
  78.      * @param PreTransactionEvent $event
  79.      *
  80.      * @throws \Psr\Cache\InvalidArgumentException
  81.      */
  82.     public function onPreTransaction(PreTransactionEvent $event)
  83.     {
  84.         if ($event->getServiceName() !== $this->getServiceName()) {
  85.             return;
  86.         }
  88.         $token = $this->getToken();
  90.         $transaction = $event->getTransaction();
  91.         $modifiedRequest = $transaction->withHeader('Authorization', sprintf('Bearer %s', $token));
  92.         if ($request = $this->requestStack->getMasterRequest()) {
  93.             if (!$language = $modifiedRequest->getHeader('Accept-Language')) {
  94.                 $modifiedRequest = $modifiedRequest->withHeader('Accept-Language', $request->getLocale());
  95.             }
  96.         }
  97.         $event->setTransaction($modifiedRequest);
  98.     }
  99. }