Merge pull request #6 from php-enqueue/solution-based-on-pager-persister

Solution based on pager persister provider API.

Author: makasim

Async/ElasticaPopulateProcessor.php

@@ -2,17 +2,8 @@
 
 namespace Enqueue\ElasticaBundle;
 
-use Enqueue\ElasticaBundle\DependencyInjection\Compiler\AsyncProviderCompilerPass;
-use Symfony\Component\DependencyInjection\ContainerBuilder;
 use Symfony\Component\HttpKernel\Bundle\Bundle;
 
 class EnqueueElasticaBundle extends Bundle
 {
-    /**
-     * {@inheritdoc}
-     */
-    public function build(ContainerBuilder $container)
-    {
-        $container->addCompilerPass(new AsyncProviderCompilerPass());
-    }
 }

DependencyInjection/Compiler/AsyncProviderCompilerPass.php

@@ -0,0 +1,56 @@
+<?php
+namespace Enqueue\ElasticaBundle\Persister\Listener;
+
+use FOS\ElasticaBundle\Persister\Event\PrePersistEvent;
+use Interop\Queue\PsrContext;
+use FOS\ElasticaBundle\Persister\Event\Events;
+use Symfony\Component\EventDispatcher\EventSubscriberInterface;
+
+class PurgePopulateQueueListener implements EventSubscriberInterface
+{
+    /**
+     * @var PsrContext
+     */
+    private $context;
+
+    /**
+     * @param PsrContext $context
+     */
+    public function __construct(PsrContext $context)
+    {
+        $this->context = $context;
+    }
+
+    public function purgePopulateQueue(PrePersistEvent $event)
+    {
+        $options = $event->getOptions();
+        if (empty($options['purge_populate_queue'])) {
+            return;
+        }
+        if (empty($options['populate_queue'])) {
+            return;
+        }
+
+        if (method_exists($this->context, 'purge')) {
+            $queue = $this->context->createQueue($options['populate_queue']);
+
+            $this->context->purge($queue);
+        }
+
+        if (method_exists($this->context, 'purgeQueue')) {
+            $queue = $this->context->createQueue($options['populate_queue']);
+
+            $this->context->purgeQueue($queue);
+        }
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public static function getSubscribedEvents()
+    {
+        return [
+            Events::PRE_PERSIST => 'purgePopulateQueue',
+        ];
+    }
+}