Extract job delay calculations.

src/Illuminate/Contracts/Queue/Job.php

@@ -11,6 +11,14 @@ interface Job
      */
     public function fire();
 
+    /**
+     * Release the job back into the queue.
+     *
+     * @param  int   $delay
+     * @return void
+     */
+    public function release($delay = 0);
+
     /**
      * Delete the job from the queue.
      *
@@ -25,14 +33,6 @@ public function delete();
      */
     public function isDeleted();
 
-    /**
-     * Release the job back into the queue.
-     *
-     * @param  int   $delay
-     * @return void
-     */
-    public function release($delay = 0);
-
     /**
      * Determine if the job has been deleted or released.
      *
@@ -47,6 +47,14 @@ public function isDeletedOrReleased();
      */
     public function attempts();
 
+    /**
+     * Process an exception that caused the job to fail.
+     *
+     * @param  \Throwable  $e
+     * @return void
+     */
+    public function failed($e);
+
     /**
      * Get the name of the queued job class.
      *
@@ -63,14 +71,6 @@ public function getName();
      */
     public function resolveName();
 
-    /**
-     * Process an exception that caused the job to fail.
-     *
-     * @param  \Throwable  $e
-     * @return void
-     */
-    public function failed($e);
-
     /**
      * Get the name of the connection the job belongs to.
      *

src/Illuminate/Queue/BeanstalkdQueue.php

@@ -102,7 +102,7 @@ public function later($delay, $job, $data = '', $queue = null)
         return $pheanstalk->put(
             $this->createPayload($job, $data),
             Pheanstalk::DEFAULT_PRIORITY,
-            $this->getSeconds($delay),
+            $this->secondsUntil($delay),
             $this->timeToRun
         );
     }

src/Illuminate/Queue/CalculatesDelays.php

@@ -0,0 +1,32 @@
+<?php
+
+namespace Illuminate\Queue;
+
+use Carbon\Carbon;
+use DateTimeInterface;
+
+trait CalculatesDelays
+{
+    /**
+     * Get the number of seconds until the given DateTime.
+     *
+     * @param  \DateTimeInterface  $delay
+     * @return int
+     */
+    protected function secondsUntil($delay)
+    {
+        return $delay instanceof DateTimeInterface
+                            ? max(0, $delay->getTimestamp() - $this->currentTime())
+                            : (int) $delay;
+    }
+
+    /**
+     * Get the current system time as a UNIX timestamp.
+     *
+     * @return int
+     */
+    protected function currentTime()
+    {
+        return Carbon::now()->getTimestamp();
+    }
+}

src/Illuminate/Queue/DatabaseQueue.php

@@ -218,7 +218,7 @@ protected function isAvailable($query)
     {
         $query->where(function ($query) {
             $query->whereNull('reserved_at');
-            $query->where('available_at', '<=', $this->getTime());
+            $query->where('available_at', '<=', $this->currentTime());
         });
     }
 
@@ -246,7 +246,7 @@ protected function isReservedButExpired($query)
     protected function markJobAsReserved($job)
     {
         $job->attempts = $job->attempts + 1;
-        $job->reserved_at = $this->getTime();
+        $job->reserved_at = $this->currentTime();
 
         $this->database->table($this->table)->where('id', $job->id)->update([
             'reserved_at' => $job->reserved_at,
@@ -303,7 +303,7 @@ protected function buildDatabaseRecord($queue, $payload, $availableAt, $attempts
             'attempts' => $attempts,
             'reserved_at' => null,
             'available_at' => $availableAt,
-            'created_at' => $this->getTime(),
+            'created_at' => $this->currentTime(),
             'payload' => $payload,
         ];
     }

src/Illuminate/Queue/Jobs/BeanstalkdJob.php

@@ -50,18 +50,6 @@ public function getRawBody()
         return $this->job->getData();
     }
 
-    /**
-     * Delete the job from the queue.
-     *
-     * @return void
-     */
-    public function delete()
-    {
-        parent::delete();
-
-        $this->pheanstalk->delete($this->job);
-    }
-
     /**
      * Release the job back into the queue.
      *
@@ -89,6 +77,18 @@ public function bury()
         $this->pheanstalk->bury($this->job);
     }
 
+    /**
+     * Delete the job from the queue.
+     *
+     * @return void
+     */
+    public function delete()
+    {
+        parent::delete();
+
+        $this->pheanstalk->delete($this->job);
+    }
+
     /**
      * Get the number of times the job has been attempted.
      *

src/Illuminate/Queue/Jobs/Job.php

@@ -5,9 +5,12 @@
 use DateTime;
 use Carbon\Carbon;
 use Illuminate\Support\Arr;
+use Illuminate\Queue\CalculatesDelays;
 
 abstract class Job
 {
+    use CalculatesDelays;
+
     /**
      * The job handler instance.
      *
@@ -22,18 +25,6 @@ abstract class Job
      */
     protected $container;
 
-    /**
-     * The name of the connection the job belongs to.
-     */
-    protected $connectionName;
-
-    /**
-     * The name of the queue the job belongs to.
-     *
-     * @var string
-     */
-    protected $queue;
-
     /**
      * Indicates if the job has been deleted.
      *
@@ -49,18 +40,16 @@ abstract class Job
     protected $released = false;
 
     /**
-     * Get the number of times the job has been attempted.
-     *
-     * @return int
+     * The name of the connection the job belongs to.
      */
-    abstract public function attempts();
+    protected $connectionName;
 
     /**
-     * Get the raw body string for the job.
+     * The name of the queue the job belongs to.
      *
-     * @return string
+     * @var string
      */
-    abstract public function getRawBody();
+    protected $queue;
 
     /**
      * Fire the job.
@@ -172,31 +161,6 @@ protected function parseJob($job)
         return count($segments) > 1 ? $segments : [$segments[0], 'fire'];
     }
 
-    /**
-     * Calculate the number of seconds with the given delay.
-     *
-     * @param  \DateTime|int  $delay
-     * @return int
-     */
-    protected function getSeconds($delay)
-    {
-        if ($delay instanceof DateTime) {
-            return max(0, $delay->getTimestamp() - $this->getTime());
-        }
-
-        return (int) $delay;
-    }
-
-    /**
-     * Get the current system time.
-     *
-     * @return int
-     */
-    protected function getTime()
-    {
-        return Carbon::now()->getTimestamp();
-    }
-
     /**
      * Get the name of the queued job class.
      *

src/Illuminate/Queue/Queue.php

@@ -10,6 +10,8 @@
 
 abstract class Queue
 {
+    use CalculatesDelays;
+
     /**
      * The IoC container instance.
      *
@@ -134,31 +136,6 @@ protected function setMeta($payload, $key, $value)
         return $payload;
     }
 
-    /**
-     * Calculate the number of seconds with the given delay.
-     *
-     * @param  \DateTime|int  $delay
-     * @return int
-     */
-    protected function getSeconds($delay)
-    {
-        if ($delay instanceof DateTime) {
-            return max(0, $delay->getTimestamp() - $this->getTime());
-        }
-
-        return (int) $delay;
-    }
-
-    /**
-     * Get the current UNIX timestamp.
-     *
-     * @return int
-     */
-    protected function getTime()
-    {
-        return Carbon::now()->getTimestamp();
-    }
-
     /**
      * Set the IoC container instance.
      *

src/Illuminate/Queue/RedisQueue.php

@@ -110,7 +110,7 @@ public function later($delay, $job, $data = '', $queue = null)
         $payload = $this->createPayload($job, $data);
 
         $this->getConnection()->zadd(
-            $this->getQueue($queue).':delayed', $this->getTime() + $this->getSeconds($delay), $payload
+            $this->getQueue($queue).':delayed', $this->currentTime() + $this->secondsUntil($delay), $payload
         );
 
         return Arr::get(json_decode($payload, true), 'id');
@@ -135,7 +135,7 @@ public function pop($queue = null)
         }
 
         list($job, $reserved) = $this->getConnection()->eval(
-            LuaScripts::pop(), 2, $queue, $queue.':reserved', $this->getTime() + $this->expire
+            LuaScripts::pop(), 2, $queue, $queue.':reserved', $this->currentTime() + $this->expire
         );
 
         if ($reserved) {
@@ -169,7 +169,7 @@ public function deleteAndRelease($queue, $job, $delay)
 
         $this->getConnection()->eval(
             LuaScripts::release(), 2, $queue.':delayed', $queue.':reserved',
-            $job, $this->getTime() + $delay
+            $job, $this->currentTime() + $delay
         );
     }
 
@@ -183,7 +183,7 @@ public function deleteAndRelease($queue, $job, $delay)
     public function migrateExpiredJobs($from, $to)
     {
         $this->getConnection()->eval(
-            LuaScripts::migrateExpiredJobs(), 2, $from, $to, $this->getTime()
+            LuaScripts::migrateExpiredJobs(), 2, $from, $to, $this->currentTime()
         );
     }
 

src/Illuminate/Queue/SqsQueue.php

@@ -98,14 +98,10 @@ public function pushRaw($payload, $queue = null, array $options = [])
      */
     public function later($delay, $job, $data = '', $queue = null)
     {
-        $payload = $this->createPayload($job, $data);
-
-        $delay = $this->getSeconds($delay);
-
         return $this->sqs->sendMessage([
             'QueueUrl' => $this->getQueue($queue),
-            'MessageBody' => $payload,
-            'DelaySeconds' => $delay,
+            'MessageBody' => $this->createPayload($job, $data),
+            'DelaySeconds' => $this->secondsUntil($delay),
         ])->get('MessageId');
     }
 

tests/Queue/QueueDatabaseQueueUnitTest.php

@@ -11,8 +11,8 @@ public function tearDown()
 
     public function testPushProperlyPushesJobOntoDatabase()
     {
-        $queue = $this->getMockBuilder('Illuminate\Queue\DatabaseQueue')->setMethods(['getTime'])->setConstructorArgs([$database = m::mock('Illuminate\Database\Connection'), 'table', 'default'])->getMock();
-        $queue->expects($this->any())->method('getTime')->will($this->returnValue('time'));
+        $queue = $this->getMockBuilder('Illuminate\Queue\DatabaseQueue')->setMethods(['currentTime'])->setConstructorArgs([$database = m::mock('Illuminate\Database\Connection'), 'table', 'default'])->getMock();
+        $queue->expects($this->any())->method('currentTime')->will($this->returnValue('time'));
         $database->shouldReceive('table')->with('table')->andReturn($query = m::mock('StdClass'));
         $query->shouldReceive('insertGetId')->once()->andReturnUsing(function ($array) {
             $this->assertEquals('default', $array['queue']);
@@ -29,10 +29,10 @@ public function testDelayedPushProperlyPushesJobOntoDatabase()
     {
         $queue = $this->getMockBuilder(
             'Illuminate\Queue\DatabaseQueue')->setMethods(
-            ['getTime'])->setConstructorArgs(
+            ['currentTime'])->setConstructorArgs(
             [$database = m::mock('Illuminate\Database\Connection'), 'table', 'default']
         )->getMock();
-        $queue->expects($this->any())->method('getTime')->will($this->returnValue('time'));
+        $queue->expects($this->any())->method('currentTime')->will($this->returnValue('time'));
         $database->shouldReceive('table')->with('table')->andReturn($query = m::mock('StdClass'));
         $query->shouldReceive('insertGetId')->once()->andReturnUsing(function ($array) {
             $this->assertEquals('default', $array['queue']);
@@ -93,8 +93,8 @@ public function testFailureToCreatePayloadAfterAddingMeta()
     public function testBulkBatchPushesOntoDatabase()
     {
         $database = m::mock('Illuminate\Database\Connection');
-        $queue = $this->getMockBuilder('Illuminate\Queue\DatabaseQueue')->setMethods(['getTime', 'getAvailableAt'])->setConstructorArgs([$database, 'table', 'default'])->getMock();
-        $queue->expects($this->any())->method('getTime')->will($this->returnValue('created'));
+        $queue = $this->getMockBuilder('Illuminate\Queue\DatabaseQueue')->setMethods(['currentTime', 'getAvailableAt'])->setConstructorArgs([$database, 'table', 'default'])->getMock();
+        $queue->expects($this->any())->method('currentTime')->will($this->returnValue('created'));
         $queue->expects($this->any())->method('getAvailableAt')->will($this->returnValue('available'));
         $database->shouldReceive('table')->with('table')->andReturn($query = m::mock('StdClass'));
         $query->shouldReceive('insert')->once()->andReturnUsing(function ($records) {