Refactor Job plugins to Services and Observers

Author: claudio-ferraro

Observer/CategoryImport.php

@@ -0,0 +1,29 @@
+<?php
+
+namespace JustBetter\AkeneoBundle\Observer;
+
+use Akeneo\Connector\Executor\JobExecutor;
+use JustBetter\AkeneoBundle\Service\CategoryExist;
+use Magento\Framework\Event\Observer;
+use Magento\Framework\Event\ObserverInterface;
+
+class CategoryImport implements ObserverInterface
+{
+    public function __construct(
+        protected CategoryExist $categoryExist
+    ) {
+    }
+
+    public function execute(Observer $observer): void
+    {
+        /** @var JobExecutor $executor */
+        $executor = $observer->getData('import');
+
+        $method = $executor->getMethod();
+
+        // Run before setValues step
+        if ($method === 'setValues') {
+            $this->categoryExist->execute();
+        }
+    }
+}

Observer/ImportFinished.php

@@ -0,0 +1,30 @@
+<?php
+
+namespace JustBetter\AkeneoBundle\Observer;
+
+use Akeneo\Connector\Executor\JobExecutor;
+use Magento\Framework\Event\ManagerInterface as EventManager;
+use Magento\Framework\Event\Observer;
+use Magento\Framework\Event\ObserverInterface;
+
+class ImportFinished implements ObserverInterface
+{
+    public function __construct(
+        protected EventManager $eventManager
+    ) {
+    }
+
+    public function execute(Observer $observer): void
+    {
+        /** @var JobExecutor $executor */
+        $executor = $observer->getData('import');
+
+        $method = $executor->getMethod();
+
+        // Dispatch custom event before cleanCache step (last step before completion)
+        if ($method === 'cleanCache') {
+            $code = $executor->getCurrentJob()->getCode();
+            $this->eventManager->dispatch('akeneo_connector_import_finish_' . $code);
+        }
+    }
+}

Observer/ProductImport.php

@@ -0,0 +1,37 @@
+<?php
+
+namespace JustBetter\AkeneoBundle\Observer;
+
+use Akeneo\Connector\Executor\JobExecutor;
+use JustBetter\AkeneoBundle\Service\CheckWebsiteAssociation;
+use JustBetter\AkeneoBundle\Service\SetTaxClassId;
+use Magento\Framework\Event\Observer;
+use Magento\Framework\Event\ObserverInterface;
+
+class ProductImport implements ObserverInterface
+{
+    public function __construct(
+        protected CheckWebsiteAssociation $checkWebsiteAssociation,
+        protected SetTaxClassId $setTaxClassId
+    ) {
+    }
+
+    public function execute(Observer $observer): void
+    {
+        /** @var JobExecutor $executor */
+        $executor = $observer->getData('import');
+
+        $method = $executor->getMethod();
+        $code = $executor->getCurrentJob()->getCode();
+
+        // Run before setWebsites step
+        if ($method === 'setWebsites') {
+            $this->checkWebsiteAssociation->execute($code);
+        }
+
+        // Run before updateOption step
+        if ($method === 'updateOption') {
+            $this->setTaxClassId->execute($code);
+        }
+    }
+}