fix(2228): restructure queue tests

Author: Stephen Odoardi

docker-compose.yml

@@ -12,6 +12,7 @@ services:
         depends_on:
           - mongodb
           - mysql
+        command: vendor/bin/phpunit
 
     mysql:
         container_name: mysql

tests/QueueTest.php

@@ -5,6 +5,7 @@
 use Carbon\Carbon;
 use Illuminate\Support\Str;
 use Jenssegers\Mongodb\Queue\Failed\MongoFailedJobProvider;
+use Jenssegers\Mongodb\Queue\MongoQueue;
 
 class QueueTest extends TestCase
 {
@@ -107,10 +108,11 @@ public function testIncrementAttempts(): void
 
     public function testJobRelease(): void
     {
-        $job_id = Queue::push('test', ['action' => 'QueueJobExpired'], 'test');
+        $queue = 'test';
+        $job_id = Queue::push($queue, ['action' => 'QueueJobRelease'], 'test');
         $this->assertNotNull($job_id);
 
-        $job = Queue::pop('test');
+        $job = Queue::pop($queue);
         $job->release();
 
         $jobs = Queue::getDatabase()
@@ -119,23 +121,58 @@ public function testJobRelease(): void
 
         $this->assertCount(1, $jobs);
         $this->assertEquals(1, $jobs[0]['attempts']);
-        $this->assertNotEquals($job_id, $jobs[0]['_id']);
     }
 
-    public function testQueueDeleteAndRelease(): void
+    public function testQueueDeleteReserved(): void
     {
         $queue = 'test';
-        $job_id = Queue::push($queue, ['action' => 'QueueJobExpired'], 'test');
-
-        $job = Queue::pop('test');
-        Queue::deleteAndRelease($queue, $job, 0);
+        $job_id = Queue::push($queue, ['action' => 'QueueDeleteReserved'], 'test');
 
+        Queue::deleteReserved($queue, $job_id, 0);
         $jobs = Queue::getDatabase()
             ->table(Config::get('queue.connections.database.table'))
             ->get();
 
-        $this->assertCount(1, $jobs);
-        $this->assertEquals(1, $jobs[0]['attempts']);
-        $this->assertNotEquals($job_id, $jobs[0]['_id']);
+        $this->assertCount(0, $jobs);
+    }
+
+    public function testQueueRelease(): void
+    {
+        Carbon::setTestNow();
+        $queue = 'test';
+        $delay = 123;
+        Queue::push($queue, ['action' => 'QueueRelease'], 'test');
+
+        $job = Queue::pop($queue);
+        $released_job_id = Queue::release($queue, $job->getJobRecord(), $delay);
+
+        $released_job = Queue::getDatabase()
+            ->table(Config::get('queue.connections.database.table'))
+            ->where('_id', $released_job_id)
+            ->first();
+
+        $this->assertEquals($queue, $released_job['queue']);
+        $this->assertEquals(1, $released_job['attempts']);
+        $this->assertNull($released_job['reserved_at']);
+        $this->assertEquals(
+            Carbon::now()->addRealSeconds($delay)->getTimestamp(),
+            $released_job['available_at']
+        );
+        $this->assertEquals(Carbon::now()->getTimestamp(), $released_job['created_at']);
+        $this->assertEquals($job->getRawBody(), $released_job['payload']);
+    }
+
+    public function testQueueDeleteAndRelease(): void
+    {
+        $queue = 'test';
+        $delay = 123;
+        Queue::push($queue, ['action' => 'QueueDeleteAndRelease'], 'test');
+        $job = Queue::pop($queue);
+
+        $mock = Mockery::mock(MongoQueue::class)->makePartial();
+        $mock->expects('deleteReserved')->once()->with($queue, $job->getJobId());
+        $mock->expects('release')->once()->with($queue, $job->getJobRecord(), $delay);
+
+        $mock->deleteAndRelease($queue, $job, $delay);
     }
 }