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. }