Add queue tests

tests/QueueTest.php

@@ -2,12 +2,46 @@
 
 class QueueTest extends TestCase
 {
-    public function testQueue()
+    public function setUp()
     {
-        $id = Queue::push('test', ['foo' => 'bar'], 'test');
+        parent::setUp();
+
+        // Always start with a clean slate
+        Queue::getDatabase()->table(Config::get('queue.connections.database.table'))->truncate();
+        Queue::getDatabase()->table(Config::get('queue.failed.table'))->truncate();
+    }
+
+    public function testQueueJobLifeCycle()
+    {
+        $id = Queue::push('test', ['action' => 'QueueJobLifeCycle'], 'test');
         $this->assertNotNull($id);
 
+        // Get and reserve the test job (next available)
         $job = Queue::pop('test');
         $this->assertInstanceOf('Illuminate\Queue\Jobs\DatabaseJob', $job);
+        $this->assertEquals(1, $job->getDatabaseJob()->reserved);
+        $this->assertEquals(json_encode(['job' => 'test', 'data' => ['action' => 'QueueJobLifeCycle']]), $job->getRawBody());
+
+        // Remove reserved job
+        $job->delete();
+        $this->assertEquals(0, Queue::getDatabase()->table(Config::get('queue.connections.database.table'))->count());
+    }
+
+    public function testQueueJobExpired()
+    {
+        $id = Queue::push('test', ['action' => 'QueueJobExpired'], 'test');
+        $this->assertNotNull($id);
+
+        // Expire the test job
+        $expiry = \Carbon\Carbon::now()->subSeconds(Config::get('queue.connections.database.expire'))->getTimestamp();
+        Queue::getDatabase()->table(Config::get('queue.connections.database.table'))->where('_id', $id)->update(['reserved' => 1, 'reserved_at' => $expiry]);
+
+        // Expect an attempted older job in the queue
+        $job = Queue::pop('test');
+        $this->assertEquals(2, $job->getDatabaseJob()->attempts);
+        $this->assertGreaterThan($expiry, $job->getDatabaseJob()->reserved_at);
+
+        $job->delete();
+        $this->assertEquals(0, Queue::getDatabase()->table(Config::get('queue.connections.database.table'))->count());
     }
 }

tests/config/queue.php

+<?php
+
+return [
+
+    'default' => 'database',
+
+    'connections' => [
+
+        'database' => [
+            'driver' => 'mongodb',
+            'table'  => 'jobs',
+            'queue'  => 'default',
+            'expire' => 60,
+        ],
+
+    ],
+
+    'failed' => [
+        'database' => 'mongodb',
+        'table'    => 'failed_jobs',
+    ],
+
+];