dispatch events on import success / failure

fastbolt · Nov 20, 2023 · 9cb7949 · 9cb7949
1 parent f73b2a1
commit 9cb7949
Show file tree

Hide file tree

Showing 9 changed files with 211 additions and 6 deletions.
diff --git a/src/EntityImporterManager.php b/src/EntityImporterManager.php
@@ -8,8 +8,15 @@
 
 namespace Fastbolt\EntityImporter;
 
+use DateTime;
+use Exception;
+use Fastbolt\EntityImporter\Events\ImportFailureEvent;
+use Fastbolt\EntityImporter\Events\ImportSuccessEvent;
 use Fastbolt\EntityImporter\Exceptions\ImporterDefinitionNotFoundException;
+use Fastbolt\EntityImporter\Exceptions\InvalidInputFormatException;
+use Fastbolt\EntityImporter\Exceptions\SourceUnavailableException;
 use Fastbolt\EntityImporter\Types\ImportResult;
+use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
 use Throwable;
 
 class EntityImporterManager
@@ -24,13 +31,23 @@ class EntityImporterManager
      */
     private EntityImporter $importer;
 
+    /**
+     * @var EventDispatcherInterface
+     */
+    private EventDispatcherInterface $eventDispatcher;
+
     /**
      * @param EntityImporter                     $importer
+     * @param EventDispatcherInterface           $eventDispatcher
      * @param iterable<EntityImporterDefinition> $importerDefinitions
      */
-    public function __construct(EntityImporter $importer, iterable $importerDefinitions)
-    {
-        $this->importer = $importer;
+    public function __construct(
+        EntityImporter $importer,
+        EventDispatcherInterface $eventDispatcher,
+        iterable $importerDefinitions
+    ) {
+        $this->importer        = $importer;
+        $this->eventDispatcher = $eventDispatcher;
 
         foreach ($importerDefinitions as $importerDefinition) {
             $this->definitions[$importerDefinition->getName()] = $importerDefinition;
@@ -52,13 +69,27 @@ public function getImporterDefinitions(): array
      * @param int|null                 $limit
      *
      * @return ImportResult
+     *
+     * @throws InvalidInputFormatException
+     * @throws SourceUnavailableException
      */
     public function import(string $name, callable $statusCallback, callable $errorCallback, ?int $limit): ImportResult
     {
-        if (!$name || null === ($definition = $this->definitions[$name] ?? null)) {
-            throw new ImporterDefinitionNotFoundException($name);
+        $start = new DateTime();
+        try {
+            if (!$name || null === ($definition = $this->definitions[$name] ?? null)) {
+                throw new ImporterDefinitionNotFoundException($name);
+            }
+
+            $return = $this->importer->import($definition, $statusCallback, $errorCallback, $limit);
+        } catch (Exception $exception) {
+            $this->eventDispatcher->dispatch(new ImportFailureEvent($definition, $start, $exception));
+
+            throw $exception;
         }
 
-        return $this->importer->import($definition, $statusCallback, $errorCallback, $limit);
+        $this->eventDispatcher->dispatch(new ImportSuccessEvent($definition, $start, $return));
+
+        return $return;
     }
 }
diff --git a/src/Events/ImportFailureEvent.php b/src/Events/ImportFailureEvent.php
@@ -0,0 +1,70 @@
+<?php
+
+/**
+ * Copyright © Fastbolt Schraubengroßhandels GmbH.
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace Fastbolt\EntityImporter\Events;
+
+use DateTimeInterface;
+use Exception;
+use Fastbolt\EntityImporter\EntityImporterDefinition;
+
+class ImportFailureEvent
+{
+    /**
+     * @var Exception
+     */
+    private Exception $exception;
+
+    /**
+     * @var EntityImporterDefinition|null
+     */
+    private ?EntityImporterDefinition $definition;
+
+    /**
+     * @var DateTimeInterface
+     */
+    private DateTimeInterface $importStart;
+
+    /**
+     * @param EntityImporterDefinition|null $definition
+     * @param DateTimeInterface             $importStart
+     * @param Exception                     $exception
+     */
+    public function __construct(
+        ?EntityImporterDefinition $definition,
+        DateTimeInterface $importStart,
+        Exception $exception
+    ) {
+        $this->definition  = $definition;
+        $this->importStart = $importStart;
+        $this->exception   = $exception;
+    }
+
+    /**
+     * @return Exception
+     */
+    public function getException(): Exception
+    {
+        return $this->exception;
+    }
+
+    /**
+     * @return EntityImporterDefinition|null
+     */
+    public function getDefinition(): ?EntityImporterDefinition
+    {
+        return $this->definition;
+    }
+
+    /**
+     * @return DateTimeInterface
+     */
+    public function getImportStart(): DateTimeInterface
+    {
+        return $this->importStart;
+    }
+}
diff --git a/src/Events/ImportSuccessEvent.php b/src/Events/ImportSuccessEvent.php
@@ -0,0 +1,70 @@
+<?php
+
+/**
+ * Copyright © Fastbolt Schraubengroßhandels GmbH.
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace Fastbolt\EntityImporter\Events;
+
+use DateTimeInterface;
+use Fastbolt\EntityImporter\EntityImporterDefinition;
+use Fastbolt\EntityImporter\Types\ImportResult;
+
+class ImportSuccessEvent
+{
+    /**
+     * @var ImportResult
+     */
+    private ImportResult $importResult;
+
+    /**
+     * @var EntityImporterDefinition
+     */
+    private EntityImporterDefinition $definition;
+
+    /**
+     * @var DateTimeInterface
+     */
+    private DateTimeInterface $importStart;
+
+    /**
+     * @param EntityImporterDefinition $definition
+     * @param DateTimeInterface        $importStart
+     * @param ImportResult             $importResult
+     */
+    public function __construct(
+        EntityImporterDefinition $definition,
+        DateTimeInterface $importStart,
+        ImportResult $importResult
+    ) {
+        $this->definition   = $definition;
+        $this->importStart  = $importStart;
+        $this->importResult = $importResult;
+    }
+
+    /**
+     * @return ImportResult
+     */
+    public function getImportResult(): ImportResult
+    {
+        return $this->importResult;
+    }
+
+    /**
+     * @return EntityImporterDefinition
+     */
+    public function getDefinition(): EntityImporterDefinition
+    {
+        return $this->definition;
+    }
+
+    /**
+     * @return DateTimeInterface
+     */
+    public function getImportStart(): DateTimeInterface
+    {
+        return $this->importStart;
+    }
+}
diff --git a/src/Reader/Factory/CsvReaderFactory.php b/src/Reader/Factory/CsvReaderFactory.php
@@ -21,6 +21,7 @@ class CsvReaderFactory implements ReaderFactoryInterface
      * @param array<string,mixed>      $options
      *
      * @return CsvReader
+     * @throws SourceUnavailableException
      */
     public function getReader(EntityImporterDefinition $importerDefinition, array $options): CsvReader
     {

diff --git a/src/Reader/Factory/ReaderFactoryInterface.php b/src/Reader/Factory/ReaderFactoryInterface.php
@@ -9,6 +9,7 @@
 namespace Fastbolt\EntityImporter\Reader\Factory;
 
 use Fastbolt\EntityImporter\EntityImporterDefinition;
+use Fastbolt\EntityImporter\Exceptions\SourceUnavailableException;
 use Fastbolt\EntityImporter\Reader\ReaderInterface;
 
 interface ReaderFactoryInterface
@@ -18,6 +19,8 @@ interface ReaderFactoryInterface
      * @param array<string,mixed>      $options Array containing implementation-specific options
      *
      * @return ReaderInterface
+     *
+     * @throws SourceUnavailableException
      */
     public function getReader(EntityImporterDefinition $importerDefinition, array $options): ReaderInterface;
 

diff --git a/src/Reader/Factory/XlsxReaderFactory.php b/src/Reader/Factory/XlsxReaderFactory.php
@@ -20,6 +20,8 @@ class XlsxReaderFactory implements ReaderFactoryInterface
      * @param array<string,mixed>      $options Array containing implementation-specific options
      *
      * @return XlsxReader
+     *
+     * @throws SourceUnavailableException
      */
     public function getReader(EntityImporterDefinition $importerDefinition, array $options): XlsxReader
     {

diff --git a/src/Resources/config/services.yaml b/src/Resources/config/services.yaml
@@ -6,6 +6,7 @@ services:
     Fastbolt\EntityImporter\EntityImporterManager:
         $importer: '@Fastbolt\EntityImporter\EntityImporter'
         $importerDefinitions: !tagged fastbolt.entity_importer.definition
+        $eventDispatcher: '@Symfony\Contracts\EventDispatcher\EventDispatcherInterface'
 
     Fastbolt\EntityImporter\Reader\Factory\ReaderFactoryManager:
         $factories: !tagged fastbolt.entity_importer.reader_factory

diff --git a/tests/unit/EntityImporterManagerTest.php b/tests/unit/EntityImporterManagerTest.php
@@ -11,10 +11,13 @@
 use Fastbolt\EntityImporter\EntityImporter;
 use Fastbolt\EntityImporter\EntityImporterDefinition;
 use Fastbolt\EntityImporter\EntityImporterManager;
+use Fastbolt\EntityImporter\Events\ImportFailureEvent;
+use Fastbolt\EntityImporter\Events\ImportSuccessEvent;
 use Fastbolt\EntityImporter\Exceptions\ImporterDefinitionNotFoundException;
 use Fastbolt\TestHelpers\BaseTestCase;
 use PHPUnit\Framework\MockObject\MockObject;
 use stdClass;
+use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
 
 /**
  * @covers \Fastbolt\EntityImporter\EntityImporterManager
@@ -46,10 +49,16 @@ class EntityImporterManagerTest extends BaseTestCase
      */
     private $errorCallback;
 
+    /**
+     * @var EventDispatcherInterface|MockObject
+     */
+    private $dispatcher;
+
     public function testImport(): void
     {
         $manager = new EntityImporterManager(
             $this->importer,
+            $this->dispatcher,
             [
                 $this->definition1,
                 $this->definition2,
@@ -65,6 +74,9 @@ public function testImport(): void
         $this->importer->expects(self::once())
                        ->method('import')
                        ->with($this->definition2, $this->statusCallback, $this->errorCallback);
+        $this->dispatcher->expects(self::once())
+                         ->method('dispatch')
+                         ->with(self::isInstanceOf(ImportSuccessEvent::class));
 
         $result = $manager->import('importer:def2:name', $this->statusCallback, $this->errorCallback, null);
     }
@@ -75,8 +87,12 @@ public function testImportInvalidType(): void
         $this->expectExceptionMessage('Importer importer:def2:name not found.');
         $manager = new EntityImporterManager(
             $this->importer,
+            $this->dispatcher,
             []
         );
+        $this->dispatcher->expects(self::once())
+                         ->method('dispatch')
+                         ->with(self::isInstanceOf(ImportFailureEvent::class));
         self::assertSame([], $manager->getImporterDefinitions());
         $manager->import('importer:def2:name', $this->statusCallback, $this->errorCallback, null);
     }
@@ -86,6 +102,7 @@ protected function setUp(): void
         parent::setUp();
 
         $this->importer       = $this->getMock(EntityImporter::class, ['import']);
+        $this->dispatcher     = $this->getMock(EventDispatcherInterface::class);
         $this->definition1    = $this->getMock(EntityImporterDefinition::class);
         $this->definition2    = $this->getMock(EntityImporterDefinition::class);
         $this->statusCallback = $this->getCallable();

diff --git a/tests/unit/Events/ImportSuccessEventTest.php b/tests/unit/Events/ImportSuccessEventTest.php
@@ -0,0 +1,10 @@
+<?php
+
+namespace Fastbolt\EntityImporter\Tests\Unit\Events;
+
+use Fastbolt\EntityImporter\Events\ImportSuccessEvent;
+use Fastbolt\TestHelpers\BaseTestCase;
+
+class ImportSuccessEventTest extends BaseTestCase {
+
+}