[Sylius 1.x] Added post flush event for product

src/Event/Product/PostFlushEvent.php

@@ -0,0 +1,21 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Synolia\SyliusAkeneoPlugin\Event\Product;
+
+use Sylius\Component\Core\Model\ProductInterface;
+use Synolia\SyliusAkeneoPlugin\Event\AbstractResourceEvent;
+
+class PostFlushEvent extends AbstractResourceEvent
+{
+    public function __construct(array $resource, private ProductInterface $product)
+    {
+        parent::__construct($resource);
+    }
+
+    public function getProduct(): ProductInterface
+    {
+        return $this->product;
+    }
+}

src/Processor/Resource/Product/ProductModelResourceProcessor.php

@@ -15,6 +15,7 @@
 use Synolia\SyliusAkeneoPlugin\Checker\Product\IsProductProcessableCheckerInterface;
 use Synolia\SyliusAkeneoPlugin\Event\Product\AfterProcessingProductEvent;
 use Synolia\SyliusAkeneoPlugin\Event\Product\BeforeProcessingProductEvent;
+use Synolia\SyliusAkeneoPlugin\Event\Product\PostFlushEvent;
 use Synolia\SyliusAkeneoPlugin\Processor\Product\ProductProcessorChainInterface;
 use Synolia\SyliusAkeneoPlugin\Processor\ProductGroup\ProductGroupProcessor;
 use Synolia\SyliusAkeneoPlugin\Processor\Resource\AkeneoResourceProcessorInterface;
@@ -66,6 +67,7 @@ public function process(array $resource): void
 
             $this->dispatcher->dispatch(new AfterProcessingProductEvent($resource, $product));
             $this->entityManager->flush();
+            $this->dispatcher->dispatch(new PostFlushEvent($resource, $product));
         } catch (ORMInvalidArgumentException $ormInvalidArgumentException) {
             ++$this->retryCount;
             usleep($this->retryWaitTime);

src/Processor/Resource/ProductVariant/SimpleProductVariantResourceProcessor.php

@@ -16,6 +16,7 @@
 use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
 use Synolia\SyliusAkeneoPlugin\Event\Product\AfterProcessingProductEvent;
 use Synolia\SyliusAkeneoPlugin\Event\Product\BeforeProcessingProductEvent;
+use Synolia\SyliusAkeneoPlugin\Event\Product\PostFlushEvent;
 use Synolia\SyliusAkeneoPlugin\Event\ProductVariant\AfterProcessingProductVariantEvent;
 use Synolia\SyliusAkeneoPlugin\Event\ProductVariant\BeforeProcessingProductVariantEvent;
 use Synolia\SyliusAkeneoPlugin\Processor\Product\ProductProcessorChainInterface;
@@ -91,8 +92,9 @@ public function process(array $resource): void
 
             $product = $this->getOrCreateEntity($resource);
             $this->productProcessorChain->chain($product, $resource);
-
             $this->dispatcher->dispatch(new AfterProcessingProductEvent($resource, $product));
+            $this->entityManager->flush();
+            $this->dispatcher->dispatch(new PostFlushEvent($resource, $product));
 
             $this->dispatcher->dispatch(new BeforeProcessingProductVariantEvent($resource, $product));