vendor/nellapp/sdk-bundle/src/Export/AutoExport/EventSubscriber/TerminateExportSubscriber.php line 31

Open in your IDE?
  1. <?php
  3. namespace Nellapp\Bundle\SDKBundle\Export\AutoExport\EventSubscriber;
  5. use Nellapp\Bundle\SDKBundle\Export\AutoExport\Resolvers\ExportTerminateResolverManager;
  6. use Nellapp\Bundle\SDKBundle\Export\AutoExport\AutoExportTerminateTracker;
  7. use Symfony\Component\Console\ConsoleEvents;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. use Symfony\Component\HttpKernel\Event\TerminateEvent;
  10. use Symfony\Component\Console\Event\ConsoleTerminateEvent;
  11. use Symfony\Component\HttpKernel\KernelEvents;
  12. use Symfony\Contracts\EventDispatcher\Event;
  14. class TerminateExportSubscriber implements EventSubscriberInterface
  15. {
  16.     public function __construct(
  17.         private AutoExportTerminateTracker     $terminateTracker,
  18.         private ExportTerminateResolverManager $exportTerminateResolverManager,
  19.     )
  20.     {
  21.     }
  23.     public static function getSubscribedEvents(): array
  24.     {
  25.         return [
  26.             KernelEvents::TERMINATE => 'exportTracked',
  27.             ConsoleEvents::TERMINATE => 'exportTracked',
  28.         ];
  29.     }
  31.     public function exportTracked(Event $event): void
  32.     {
  33.         if (!$event instanceof TerminateEvent && !$event instanceof ConsoleTerminateEvent) {
  34.             return;
  35.         }
  37.         foreach ($this->terminateTracker->getTrackedEntities() as $resolverClass => $entityIds) {
  38.             $exportTerminateResolver = $this->exportTerminateResolverManager->getExportTerminateResolverByClass($resolverClass);
  39.             if ($exportTerminateResolver === null) {
  40.                 continue;
  41.             }
  43.             $exportTerminateResolver->exportTracked($entityIds);
  44.         }
  45.     }
  46. }