JobAttemptsTest

Author: vyuldashev

.gitignore

@@ -3,4 +3,5 @@
 /vendor
 composer.lock
 .phpstorm.meta.php
-phpunit.xml
+phpunit.xml
+.phpunit.result.cache

composer.json

@@ -21,7 +21,8 @@
     "phpunit/phpunit": "^8.4",
     "illuminate/events": "^6.0",
     "mockery/mockery": "^1.0",
-    "laravel/horizon": "^3.0"
+    "laravel/horizon": "^3.0",
+    "larapack/dd": "^1.1"
   },
   "autoload": {
     "psr-4": {

tests/Functional/JobAttemptsTest.php

@@ -0,0 +1,107 @@
+<?php
+
+namespace VladimirYuldashev\LaravelQueueRabbitMQ\Tests\Functional;
+
+use Enqueue\AmqpLib\AmqpConnectionFactory;
+use Illuminate\Container\Container;
+use Illuminate\Events\Dispatcher;
+use Interop\Amqp\AmqpTopic;
+use Interop\Queue\Exception\PurgeQueueNotSupportedException;
+use PHPUnit\Framework\TestCase;
+use Psr\Log\NullLogger;
+use ReflectionException;
+use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\Connectors\RabbitMQConnector;
+use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\Jobs\RabbitMQJob;
+use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\RabbitMQQueue;
+
+/**
+ * @group functional
+ */
+class JobAttemptsTest extends TestCase
+{
+    /**
+     * @throws PurgeQueueNotSupportedException
+     * @throws ReflectionException
+     */
+    public function test()
+    {
+        $config = [
+            'factory_class' => AmqpConnectionFactory::class,
+            'dsn' => null,
+            'host' => getenv('HOST'),
+            'port' => getenv('PORT'),
+            'login' => 'guest',
+            'password' => 'guest',
+            'vhost' => '/',
+            'options' => [
+                'exchange' => [
+                    'name' => null,
+                    'declare' => true,
+                    'type' => AmqpTopic::TYPE_DIRECT,
+                    'passive' => false,
+                    'durable' => true,
+                    'auto_delete' => false,
+                ],
+
+                'queue' => [
+                    'name' => 'default',
+                    'declare' => true,
+                    'bind' => true,
+                    'passive' => false,
+                    'durable' => true,
+                    'exclusive' => false,
+                    'auto_delete' => false,
+                    'arguments' => '[]',
+                ],
+            ],
+            'ssl_params' => [
+                'ssl_on' => false,
+                'cafile' => null,
+                'local_cert' => null,
+                'local_key' => null,
+                'verify_peer' => true,
+                'passphrase' => null,
+            ],
+        ];
+
+        $connector = new RabbitMQConnector(new Dispatcher());
+        /** @var RabbitMQQueue $queue */
+        $queue = $connector->connect($config);
+        $queue->setContainer($this->createDummyContainer());
+
+        // we need it to declare exchange\queue on RabbitMQ side.
+        $queue->pushRaw('something');
+
+        $queue->getContext()->purgeQueue($queue->getContext()->createQueue('default'));
+
+        $expectedPayload = __METHOD__.microtime(true);
+
+        $queue->pushRaw($expectedPayload);
+
+        sleep(1);
+
+        $this->assertEquals(1, $queue->size());
+
+        $job = $queue->pop();
+
+        $this->assertInstanceOf(RabbitMQJob::class, $job);
+        $this->assertSame(1, $job->attempts());
+
+        $job->release();
+
+        $this->assertEquals(1, $queue->size());
+
+        $job = $queue->pop();
+
+        $this->assertInstanceOf(RabbitMQJob::class, $job);
+        $this->assertSame(2, $job->attempts());
+    }
+
+    private function createDummyContainer()
+    {
+        $container = new Container();
+        $container['log'] = new NullLogger();
+
+        return $container;
+    }
+}