Require every job to extend the base Job class

Author: pprkut

README.md

@@ -110,9 +110,9 @@ Resque\Resque::enqueue('default', 'My_Job', $args);
 Each job should be in its own class, and include a `perform` method.
 
 ```php
-class My_Job
+class My_Job extends \Resque\Job\Job
 {
-    public function perform()
+    public function perform(): void
     {
         // Work work work
         echo $this->args['name'];
@@ -132,19 +132,19 @@ defined, it will be called before the `perform` method is run. The `tearDown`
 method, if defined, will be called after the job finishes.
 
 ```php
-class My_Job
+class My_Job extends \Resque\Job\Job
 {
-    public function setUp()
+    public function setUp(): void
     {
         // ... Set up environment for this job
     }
 
-    public function perform()
+    public function perform(): void
     {
         // .. Run job
     }
 
-    public function tearDown()
+    public function tearDown(): void
     {
         // ... Remove environment for this job
     }

lib/Job/Factory.php

@@ -10,23 +10,17 @@ class Factory implements FactoryInterface
 	 * @param $className
 	 * @param array $args
 	 * @param $queue
-	 * @return \Resque\Job\JobInterface
+	 * @return \Resque\Job\Job
 	 * @throws \Resque\Exceptions\ResqueException
 	 */
-	public function create($className, $args, $queue)
+	public function create($className, $args, $queue): Job
 	{
 		if (!class_exists($className)) {
 			throw new ResqueException(
 				'Could not find job class ' . $className . '.'
 			);
 		}
 
-		if (!method_exists($className, 'perform')) {
-			throw new ResqueException(
-				'Job class ' . $className . ' does not contain a perform method.'
-			);
-		}
-
 		$instance = new $className();
 		$instance->args = $args;
 		$instance->queue = $queue;

lib/Job/FactoryInterface.php

@@ -8,7 +8,7 @@ interface FactoryInterface
 	 * @param $className
 	 * @param array $args
 	 * @param $queue
-	 * @return \Resque\Job\JobInterface
+	 * @return \Resque\Job\Job
 	 */
-	public function create($className, $args, $queue);
+	public function create($className, $args, $queue): Job;
 }

lib/Job/JobInterface.php

@@ -8,6 +8,7 @@
 use Resque\Exceptions\DoNotPerformException;
 use Resque\Job\FactoryInterface;
 use Resque\Job\Factory;
+use Resque\Job\Job;
 use Error;
 
 /**
@@ -50,7 +51,7 @@ class JobHandler
 	public $endTime;
 
 	/**
-	 * @var object|\Resque\Job\JobInterface Instance of the class performing work for this job.
+	 * @var Job Instance of the class performing work for this job.
 	 */
 	private $instance;
 
@@ -194,10 +195,10 @@ public function getArguments()
 
 	/**
 	 * Get the instantiated object for this job that will be performing work.
-	 * @return \Resque\Job\JobInterface Instance of the object that this job belongs to.
+	 * @return \Resque\Job\Job Instance of the object that this job belongs to.
 	 * @throws \Resque\Exceptions\ResqueException
 	 */
-	public function getInstance()
+	public function getInstance(): Job
 	{
 		if (!is_null($this->instance)) {
 			return $this->instance;
@@ -225,15 +226,12 @@ public function perform()
 			$this->startTime = microtime(true);
 
 			$instance = $this->getInstance();
-			if (is_callable([$instance, 'setUp'])) {
-				$instance->setUp();
-			}
 
-			$result = $instance->perform();
+			$instance->setUp();
 
-			if (is_callable([$instance, 'tearDown'])) {
-				$instance->tearDown();
-			}
+			$instance->perform();
+
+			$instance->tearDown();
 
 			$this->endTime = microtime(true);
 
@@ -343,7 +341,7 @@ public function setJobFactory(FactoryInterface $jobFactory)
 	/**
 	 * @return Resque\Job\FactoryInterface
 	 */
-	public function getJobFactory()
+	public function getJobFactory(): FactoryInterface
 	{
 		if ($this->jobFactory === null) {
 			$this->jobFactory = new Factory();

lib/JobHandler.php

@@ -7,7 +7,7 @@
 use \Resque\Redis;
 use \Resque\JobHandler;
 use \Resque\Stat;
-use \Resque\Job\JobInterface;
+use \Resque\Job\Job;
 use \Resque\Job\FactoryInterface;
 use \Test_Job_With_SetUp;
 use \Test_Job_With_TearDown;
@@ -410,7 +410,7 @@ public function testUseFactoryToGetJobInstance()
 		$factory = new Some_Stub_Factory();
 		$job->setJobFactory($factory);
 		$instance = $job->getInstance();
-		$this->assertInstanceOf('Resque\Job\JobInterface', $instance);
+		$this->assertInstanceOf('Resque\Job\Job', $instance);
 	}
 
 	public function testDoNotUseFactoryToGetInstance()
@@ -422,11 +422,11 @@ public function testDoNotUseFactoryToGetInstance()
 		$job = new JobHandler('jobs', $payload);
 		$factory = $this->getMockBuilder('Resque\Job\FactoryInterface')
 			->getMock();
-		$testJob = $this->getMockBuilder('Resque\Job\JobInterface')
+		$testJob = $this->getMockBuilder('Resque\Job\Job')
 			->getMock();
 		$factory->expects(self::never())->method('create')->will(self::returnValue($testJob));
 		$instance = $job->getInstance();
-		$this->assertInstanceOf('Resque\Job\JobInterface', $instance);
+		$this->assertInstanceOf('Resque\Job\Job', $instance);
 	}
 
 	public function testJobStatusIsNullIfIdMissingFromPayload()
@@ -505,15 +505,15 @@ public function testJobHandlerSetsStartAndEndTimeForFailedJob()
 	}
 }
 
-class Some_Job_Class implements JobInterface
+class Some_Job_Class extends Job
 {
 
 	/**
-	 * @return bool
+	 * @return void
 	 */
-	public function perform()
+	public function perform(): void
 	{
-		return true;
+		// no-op
 	}
 }
 
@@ -524,9 +524,9 @@ class Some_Stub_Factory implements FactoryInterface
 	 * @param $className
 	 * @param array $args
 	 * @param $queue
-	 * @return Resque\Job\JobInterface
+	 * @return Resque\Job\Job
 	 */
-	public function create($className, $args, $queue)
+	public function create($className, $args, $queue): Job
 	{
 		return new Some_Job_Class();
 	}

test/Resque/Tests/JobHandlerTest.php

@@ -85,11 +85,11 @@ function sigint()
 	pcntl_signal(SIGTERM, 'sigint');
 }
 
-class Test_Job
+class Test_Job extends \Resque\Job\Job
 {
 	public static $called = false;
 
-	public function perform()
+	public function perform(): void
 	{
 		self::$called = true;
 	}
@@ -100,9 +100,9 @@ class Failing_Job_Exception extends \Exception
 
 }
 
-class Failing_Job
+class Failing_Job extends \Resque\Job\Job
 {
-	public function perform()
+	public function perform(): void
 	{
 		throw new Failing_Job_Exception('Message!');
 	}
@@ -114,9 +114,9 @@ public function perform()
  *
  * CAUTION Use this test job only with Worker::work, i.e. only when you actually trigger the fork in tests.
  */
-class InProgress_Job
+class InProgress_Job extends \Resque\Job\Job
 {
-	public function perform()
+	public function perform(): void
 	{
 		if(!function_exists('pcntl_fork')) {
 			// We can't lose the worker on a non-forking OS.
@@ -126,47 +126,42 @@ public function perform()
 	}
 }
 
-class Test_Job_Without_Perform_Method
-{
-
-}
-
-class Test_Job_With_SetUp
+class Test_Job_With_SetUp extends \Resque\Job\Job
 {
 	public static $called = false;
 	public $args = false;
 
-	public function setUp()
+	public function setUp(): void
 	{
 		self::$called = true;
 	}
 
-	public function perform()
+	public function perform(): void
 	{
 
 	}
 }
 
 
-class Test_Job_With_TearDown
+class Test_Job_With_TearDown extends \Resque\Job\Job
 {
 	public static $called = false;
 	public $args = false;
 
-	public function perform()
+	public function perform(): void
 	{
 
 	}
 
-	public function tearDown()
+	public function tearDown(): void
 	{
 		self::$called = true;
 	}
 }
 
-class Test_Infinite_Recursion_Job
+class Test_Infinite_Recursion_Job extends \Resque\Job\Job
 {
-    public function perform()
+    public function perform(): void
     {
         $this->perform();
     }