src/Bundle/Croatia/EventListener/GenticsMeshApiAuthListener.php line 88

Open in your IDE?
  1. <?php
  2. declare(strict_types=1);
  4. namespace App\Bundle\Croatia\EventListener;
  6. use EightPoints\Bundle\GuzzleBundle\Events\GuzzleEventListenerInterface;
  7. use EightPoints\Bundle\GuzzleBundle\Events\PreTransactionEvent;
  8. use GuzzleHttp\Client;
  9. use Lexik\Bundle\JWTAuthenticationBundle\Services\JWSProvider\JWSProviderInterface;
  10. use Psr\Cache\CacheItemPoolInterface;
  12. class GenticsMeshApiAuthListener implements GuzzleEventListenerInterface
  13. {
  14.     /**
  15.      * @var string
  16.      */
  17.     protected $serviceName;
  19.     /**
  20.      * @var CacheItemPoolInterface
  21.      */
  22.     protected $cache;
  24.     /**
  25.      * @var Client
  26.      */
  27.     protected $client;
  29.     /**
  30.      * @var JWSProviderInterface
  31.      */
  32.     protected $JWSProvider;
  34.     public function __construct(CacheItemPoolInterface $cache, Client $client, JWSProviderInterface $JWSProvider)
  35.     {
  36.         $this->cache = $cache;
  37.         $this->client = $client;
  38.         $this->JWSProvider = $JWSProvider;
  39.     }
  41.     public function getServiceName()
  42.     {
  43.         return $this->serviceName;
  44.     }
  46.     /**
  47.      * @inheritDoc
  48.      */
  49.     public function setServiceName($serviceName)
  50.     {
  51.         $this->serviceName = $serviceName;
  52.         return $this;
  53.     }
  55.     /**
  56.      * @return string
  57.      * @throws \Psr\Cache\InvalidArgumentException
  58.      */
  59.     protected function getToken(): string
  60.     {
  61.         $cacheItem = $this->cache->getItem('gentics_mesh_token');
  62.         if ($cacheItem->isHit()) {
  63.             $token = $cacheItem->get();
  64.             return $token['token'];
  65.         }
  66.         $body = [
  67.             'username' => getenv('GETMESH_USER'),
  68.             'password' => getenv('GETMESH_PASSWORD')
  69.         ];
  70.         $response = $this->client->post('/api/v1/auth/login', ['body' => json_encode($body)]);
  71.         $token = json_decode($response->getBody()->getContents(), true);
  73.         $payload = $this->JWSProvider->load($token['token'])->getPayload();
  74.         $expiresAt = (new \DateTimeImmutable())->setTimestamp($payload['exp']);
  75.         $cacheItem->expiresAt($expiresAt);
  77.         $cacheItem->set($token);
  78.         $this->cache->save($cacheItem);
  80.         return $token['token'];
  81.     }
  83.     /**
  84.      * @param PreTransactionEvent $event
  85.      *
  86.      * @throws \Psr\Cache\InvalidArgumentException
  87.      */
  88.     public function onPreTransaction(PreTransactionEvent $event)
  89.     {
  90.         if ($event->getServiceName() !== $this->getServiceName()) {
  91.             return;
  92.         }
  94.         $token = $this->getToken();
  96.         $request = $event->getTransaction();
  97.         $modifiedRequest = $request->withHeader('Authorization', sprintf('Bearer %s', $token));
  98.         $event->setTransaction($modifiedRequest);
  99.     }
  100. }