vendor/league/oauth2-server-bundle/src/Manager/Doctrine/ClientManager.php line 49

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace League\Bundle\OAuth2ServerBundle\Manager\Doctrine;
  7. use Doctrine\ORM\EntityManagerInterface;
  8. use League\Bundle\OAuth2ServerBundle\Event\PreSaveClientEvent;
  9. use League\Bundle\OAuth2ServerBundle\Manager\ClientFilter;
  10. use League\Bundle\OAuth2ServerBundle\Manager\ClientManagerInterface;
  11. use League\Bundle\OAuth2ServerBundle\Model\AbstractClient;
  12. use League\Bundle\OAuth2ServerBundle\Model\ClientInterface;
  13. use League\Bundle\OAuth2ServerBundle\OAuth2Events;
  14. use League\Bundle\OAuth2ServerBundle\ValueObject\Grant;
  15. use League\Bundle\OAuth2ServerBundle\ValueObject\RedirectUri;
  16. use League\Bundle\OAuth2ServerBundle\ValueObject\Scope;
  17. use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
  19. final class ClientManager implements ClientManagerInterface
  20. {
  21.     /**
  22.      * @var EntityManagerInterface
  23.      */
  24.     private $entityManager;
  26.     /**
  27.      * @var class-string<AbstractClient>
  28.      */
  29.     private $clientFqcn;
  31.     /**
  32.      * @var EventDispatcherInterface
  33.      */
  34.     private $dispatcher;
  36.     /**
  37.      * @param class-string<AbstractClient> $clientFqcn
  38.      */
  39.     public function __construct(
  40.         EntityManagerInterface $entityManager,
  41.         EventDispatcherInterface $dispatcher,
  42.         string $clientFqcn
  43.     ) {
  44.         $this->entityManager = $entityManager;
  45.         $this->dispatcher = $dispatcher;
  46.         $this->clientFqcn = $clientFqcn;
  47.     }
  49.     public function find(string $identifier): ?ClientInterface
  50.     {
  51.         $repository = $this->entityManager->getRepository($this->clientFqcn);
  53.         return $repository->findOneBy(['identifier' => $identifier]);
  54.     }
  56.     public function save(ClientInterface $client): void
  57.     {
  58.         $event = $this->dispatcher->dispatch(new PreSaveClientEvent($client), OAuth2Events::PRE_SAVE_CLIENT);
  59.         $client = $event->getClient();
  61.         $this->entityManager->persist($client);
  62.         $this->entityManager->flush();
  63.     }
  65.     public function remove(ClientInterface $client): void
  66.     {
  67.         $this->entityManager->remove($client);
  68.         $this->entityManager->flush();
  69.     }
  71.     /**
  72.      * @return list<AbstractClient>
  73.      */
  74.     public function list(?ClientFilter $clientFilter): array
  75.     {
  76.         $repository = $this->entityManager->getRepository($this->clientFqcn);
  77.         $criteria = self::filterToCriteria($clientFilter);
  79.         /** @var list<AbstractClient> */
  80.         return $repository->findBy($criteria);
  81.     }
  83.     /**
  84.      * @return array{grants?: list<Grant>, redirect_uris?: list<RedirectUri>, scopes?: list<Scope>}
  85.      */
  86.     private static function filterToCriteria(?ClientFilter $clientFilter): array
  87.     {
  88.         if (null === $clientFilter || false === $clientFilter->hasFilters()) {
  89.             return [];
  90.         }
  92.         $criteria = [];
  94.         $grants = $clientFilter->getGrants();
  95.         if ($grants) {
  96.             $criteria['grants'] = $grants;
  97.         }
  99.         $redirectUris = $clientFilter->getRedirectUris();
  100.         if ($redirectUris) {
  101.             $criteria['redirect_uris'] = $redirectUris;
  102.         }
  104.         $scopes = $clientFilter->getScopes();
  105.         if ($scopes) {
  106.             $criteria['scopes'] = $scopes;
  107.         }
  109.         return $criteria;
  110.     }
  111. }