Merge pull request #23 from DivanteLtd/feature/export-event

Batch exported event

src/ScheduledExportBundle/Event/BatchExportedEvent.php

@@ -0,0 +1,31 @@
+<?php
+
+namespace Divante\ScheduledExportBundle\Event;
+
+use Pimcore\Model\DataObject\Concrete;
+
+class BatchExportedEvent extends \Symfony\Component\EventDispatcher\Event
+{
+    const NAME = 'divante.scheduled_export.batch_exported';
+
+    /** @var string[] */
+    private $objectsIds;
+
+    /**
+     * BatchExportedEvent constructor.
+     * @param string[] $objectsIds
+     */
+    public function __construct(array $objectsIds)
+    {
+        $this->objectsIds = $objectsIds;
+    }
+
+    /**
+     * @return string[]
+     */
+    public function getObjectsIds(): array
+    {
+        return $this->objectsIds;
+    }
+
+}

src/ScheduledExportBundle/Export/Export.php

@@ -7,6 +7,7 @@
 
 namespace Divante\ScheduledExportBundle\Export;
 
+use Divante\ScheduledExportBundle\Event\BatchExportedEvent;
 use Pimcore\Bundle\AdminBundle\Controller\Admin\DataObject\DataObjectHelperController;
 use Pimcore\Localization\LocaleService;
 use Pimcore\Logger;
@@ -23,6 +24,7 @@
 use Symfony\Component\Console\Input\Input;
 use Symfony\Component\Console\Output\Output;
 use Symfony\Component\DependencyInjection\ContainerInterface;
+use Symfony\Component\EventDispatcher\EventDispatcher;
 use Symfony\Component\HttpFoundation\Request;
 use Symfony\Component\HttpFoundation\Session\Attribute\AttributeBagInterface;
 
@@ -495,15 +497,18 @@ protected function exportToFilenames(array $objectIds): array
     {
         $filenames = [];
         $localeService = new LocaleService();
+        $dispatcher = $this->container->get('event_dispatcher');
         foreach ($objectIds as $objectIdBatch) {
             $filename = uniqid();
             $request = $this->prepareRequest($objectIdBatch, $filename);
             if (!count($request->request->get('ids'))) {
                 break;
             }
 
-
             $this->controller->doExportAction($request, $localeService);
+            $event = new BatchExportedEvent($objectIdBatch ?? []);
+            $dispatcher->dispatch(BatchExportedEvent::NAME, $event);
+
             $filenames[] = $filename;
             $this->process = $this->processRepository->find($this->process->getId());
             $this->process->progress(count($objectIdBatch));