Merge pull request #54 from php-enqueue/dbal-transport

DBAL Transport

Author: makasim

EnqueueBundle.php

@@ -11,6 +11,8 @@
 use Enqueue\Bundle\DependencyInjection\Compiler\BuildQueueMetaRegistryPass;
 use Enqueue\Bundle\DependencyInjection\Compiler\BuildTopicMetaSubscribersPass;
 use Enqueue\Bundle\DependencyInjection\EnqueueExtension;
+use Enqueue\Dbal\DbalContext;
+use Enqueue\Dbal\Symfony\DbalTransportFactory;
 use Enqueue\Fs\FsContext;
 use Enqueue\Fs\Symfony\FsTransportFactory;
 use Enqueue\Redis\RedisContext;
@@ -58,5 +60,9 @@ public function build(ContainerBuilder $container)
         if (class_exists(RedisContext::class)) {
             $extension->addTransportFactory(new RedisTransportFactory());
         }
+
+        if (class_exists(DbalContext::class)) {
+            $extension->addTransportFactory(new DbalTransportFactory());
+        }
     }
 }

Tests/Functional/UseCasesTest.php

@@ -72,7 +72,20 @@ public function provideEnqueueConfigs()
                         'store_dir' => sys_get_temp_dir(),
                     ]
                 ]
-            ]]
+            ]],
+            ['dbal' => [
+                'transport' => [
+                    'default' => 'dbal',
+                    'dbal' => [
+                        'dbname' => getenv('SYMFONY__DB__NAME'),
+                        'user' => getenv('SYMFONY__DB__USER'),
+                        'password' => getenv('SYMFONY__DB__PASSWORD'),
+                        'host' => getenv('SYMFONY__DB__HOST'),
+                        'port' => getenv('SYMFONY__DB__PORT'),
+                        'driver' => getenv('SYMFONY__DB__DRIVER'),
+                    ]
+                ]
+            ]],
         ];
     }
 

Tests/Unit/EnqueueBundleTest.php

@@ -11,6 +11,7 @@
 use Enqueue\Bundle\DependencyInjection\Compiler\BuildTopicMetaSubscribersPass;
 use Enqueue\Bundle\DependencyInjection\EnqueueExtension;
 use Enqueue\Bundle\EnqueueBundle;
+use Enqueue\Dbal\Symfony\DbalTransportFactory;
 use Enqueue\Fs\Symfony\FsTransportFactory;
 use Enqueue\Redis\Symfony\RedisTransportFactory;
 use Enqueue\Stomp\Symfony\RabbitMqStompTransportFactory;
@@ -176,6 +177,23 @@ public function testShouldRegisterRedisTransportFactory()
         $bundle->build($container);
     }
 
+    public function testShouldRegisterDbalTransportFactory()
+    {
+        $extensionMock = $this->createEnqueueExtensionMock();
+
+        $container = new ContainerBuilder();
+        $container->registerExtension($extensionMock);
+
+        $extensionMock
+            ->expects($this->at(8))
+            ->method('addTransportFactory')
+            ->with($this->isInstanceOf(DbalTransportFactory::class))
+        ;
+
+        $bundle = new EnqueueBundle();
+        $bundle->build($container);
+    }
+
     /**
      * @return \PHPUnit_Framework_MockObject_MockObject|EnqueueExtension
      */