src/Core/EventSubscriber/AuthorizationHeaderSubscriber.php line 52

  1. <?php
  3. declare(strict_types=1);
  4. /**
  5.  * Copyright (c) 2022 TECLA Consulting Group oü.
  6.  * All rights reserved.
  7.  *
  8.  * This unpublished material is proprietary to TECLA Consulting Group oü.
  9.  * All rights reserved. The methods and
  10.  * techniques described herein are considered trade secrets
  11.  * and/or confidential. Reproduction or distribution, in whole
  12.  * or in part, is forbidden except by express written permission
  13.  * of TECLA Consulting Group oü.
  14.  *
  15.  * @author    Matúš Sýkorjak <matus@tecla.no>
  16.  * @copyright 2022 TECLA Consulting Group oü
  17.  */
  19. namespace App\Core\EventSubscriber;
  21. use App\Contact\Model\Identity\ContactId;
  22. use App\Contact\Repository\ContactRepositoryInterface;
  23. use App\Contact\Security\ContactContextInterface;
  24. use JetBrains\PhpStorm\ArrayShape;
  25. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  26. use Symfony\Component\HttpKernel\Event\RequestEvent;
  27. use Symfony\Component\HttpKernel\KernelEvents;
  28. use Throwable;
  30. final class AuthorizationHeaderSubscriber implements EventSubscriberInterface
  31. {
  32.     private ContactRepositoryInterface $contactRepository;
  34.     private ContactContextInterface $contactContext;
  36.     public function __construct(ContactRepositoryInterface $contactRepository, ContactContextInterface $contactContext)
  37.     {
  38.         $this->contactRepository = $contactRepository;
  39.         $this->contactContext = $contactContext;
  40.     }
  42.     #[ArrayShape([KernelEvents::REQUEST => 'string'])]
  43.     public static function getSubscribedEvents(): array
  44.     {
  45.         return [
  46.             KernelEvents::REQUEST => [
  47.                 ['onKernelRequest', 5],
  48.             ],
  49.         ];
  50.     }
  52.     public function onKernelRequest(RequestEvent $event): void
  53.     {
  54.         if (false === $event->isMainRequest()) {
  55.             return;
  56.         }
  58.         $request = $event->getRequest();
  60.         if (false === $request->headers->has('Authorization')) {
  61.             return;
  62.         }
  64.         try {
  65.             $authorizationHeader = explode(' ', $request->headers->get('Authorization'));
  66.             [$username, $password] = explode(':', base64_decode($authorizationHeader[1]));
  67.             $contactId = ContactId::createFromString($username);
  68.             $contact = $this->contactRepository->find($contactId);
  69.             $this->contactContext->setCurrent($contact);
  70.         } catch (Throwable $e) {
  71.         }
  72.     }
  73. }