src/Component/Doctrine/EntityPersister/EntityPersister.php line 27

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace App\Component\Doctrine\EntityPersister;
  7. use Doctrine\ORM\EntityManagerInterface;
  8. use Symfony\Component\EventDispatcher\Attribute\AsEventListener;
  9. use Symfony\Component\HttpKernel\Event\TerminateEvent;
  11. /**
  12.  * We use this class to be able to persist objects in an onFlush or postFlush event. They will only be actually
  13.  * persisted when the kernel is shutting down. This way we can prevent nested flushing.
  14.  */
  15. #[AsEventListener]
  16. class EntityPersister
  17. {
  18.     /**
  19.      * @var array<int, object>
  20.      */
  21.     private array $queue = [];
  23.     public function __construct(private readonly EntityManagerInterface $em)
  24.     {
  25.     }
  27.     public function __invoke(TerminateEvent $event): void
  28.     {
  29.         if (empty($this->queue)) {
  30.             return;
  31.         }
  33.         foreach ($this->queue as $id => $object) {
  34.             unset($this->queue[$id]);
  35.             $this->em->persist($object);
  36.         }
  38.         $this->em->flush();
  39.     }
  41.     public function persist(object ...$entity): void
  42.     {
  43.         foreach ($entity as $object) {
  44.             $id = spl_object_id($object);
  45.             $this->queue[$id] = $object;
  46.         }
  47.     }
  48. }