vendor/api-platform/core/src/Core/Bridge/Symfony/Bundle/DataPersister/TraceableChainDataPersister.php line 45

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of the API Platform project.
  5.  *
  6.  * (c) Kévin Dunglas <dunglas@gmail.com>
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. declare(strict_types=1);
  14. namespace ApiPlatform\Core\Bridge\Symfony\Bundle\DataPersister;
  16. use ApiPlatform\Core\DataPersister\ChainDataPersister;
  17. use ApiPlatform\Core\DataPersister\ContextAwareDataPersisterInterface;
  18. use ApiPlatform\Core\DataPersister\DataPersisterInterface;
  19. use ApiPlatform\Core\DataPersister\ResumableDataPersisterInterface;
  21. /**
  22.  * @author Anthony GRASSIOT <antograssiot@free.fr>
  23.  */
  24. final class TraceableChainDataPersister implements ContextAwareDataPersisterInterface
  25. {
  26.     private $persisters = [];
  27.     private $persistersResponse = [];
  28.     private $decorated;
  30.     public function __construct(DataPersisterInterface $dataPersister)
  31.     {
  32.         if ($dataPersister instanceof ChainDataPersister) {
  33.             $this->decorated = $dataPersister;
  34.             $this->persisters = $dataPersister->persisters;
  35.         }
  36.     }
  38.     public function getPersistersResponse(): array
  39.     {
  40.         return $this->persistersResponse;
  41.     }
  43.     public function supports($data, array $context = []): bool
  44.     {
  45.         return $this->decorated->supports($data, $context);
  46.     }
  48.     public function persist($data, array $context = [])
  49.     {
  50.         $this->tracePersisters($data, $context);
  52.         return $this->decorated->persist($data, $context);
  53.     }
  55.     public function remove($data, array $context = [])
  56.     {
  57.         $this->tracePersisters($data, $context);
  59.         return $this->decorated->remove($data, $context);
  60.     }
  62.     private function tracePersisters($data, array $context = [])
  63.     {
  64.         $found = false;
  65.         foreach ($this->persisters as $persister) {
  66.             if (
  67.                 ($this->persistersResponse[\get_class($persister)] = $found ? false : $persister->supports($data, $context))
  68.                 && !($persister instanceof ResumableDataPersisterInterface && $persister->resumable()) && !$found
  69.             ) {
  70.                 $found = true;
  71.             }
  72.         }
  73.     }
  74. }