Support legacy payload

Fixes Undefined index id/prefix e.g. when retrying job via Resque Web

Author: mrliptontea

lib/Resque/Job.php

@@ -131,18 +131,22 @@ public function updateStatus($status, $result = null)
 			return;
 		}
 
-		$statusInstance = new Resque_Job_Status($this->payload['id'], $this->payload['prefix']);
+		$statusInstance = new Resque_Job_Status($this->payload['id'], $this->getPrefix());
 		$statusInstance->update($status, $result);
 	}
 
 	/**
 	 * Return the status of the current job.
 	 *
-	 * @return int The status of the job as one of the Resque_Job_Status constants.
+	 * @return int|null The status of the job as one of the Resque_Job_Status constants or null if job is not being tracked.
 	 */
 	public function getStatus()
 	{
-		$status = new Resque_Job_Status($this->payload['id'], $this->payload['prefix']);
+		if(empty($this->payload['id'])) {
+			return null;
+		}
+
+		$status = new Resque_Job_Status($this->payload['id'], $this->getPrefix());
 		return $status->get();
 	}
 
@@ -248,13 +252,15 @@ public function fail($exception)
 	 */
 	public function recreate()
 	{
-		$status = new Resque_Job_Status($this->payload['id'], $this->payload['prefix']);
 		$monitor = false;
-		if($status->isTracking()) {
-			$monitor = true;
+		if (isset($this->payload['id'])) {
+			$status = new Resque_Job_Status($this->payload['id'], $this->getPrefix());
+			if($status->isTracking()) {
+				$monitor = true;
+			}
 		}
 
-		return self::create($this->queue, $this->payload['class'], $this->getArguments(), $monitor, $this->payload['prefix']);
+		return self::create($this->queue, $this->payload['class'], $this->getArguments(), $monitor, null, $this->getPrefix());
 	}
 
 	/**
@@ -298,4 +304,16 @@ public function getJobFactory()
         }
         return $this->jobFactory;
     }
+
+    /**
+     * @return string
+     */
+    private function getPrefix()
+    {
+    	if (isset($this->payload['prefix'])) {
+    		return $this->payload['prefix'];
+    	}
+
+    	return '';
+    }
 }

test/Resque/Tests/JobTest.php

@@ -416,6 +416,30 @@ public function testDoNotUseFactoryToGetInstance()
 		$instance = $job->getInstance();
 		$this->assertInstanceOf('Resque_JobInterface', $instance);
 	}
+
+	public function testJobStatusIsNullIfIdMissingFromPayload()
+	{
+		$payload = array(
+			'class' => 'Some_Job_Class',
+			'args' => null
+		);
+		$job = new Resque_Job('jobs', $payload);
+		$this->assertEquals(null, $job->getStatus());
+	}
+
+	public function testJobCanBeRecreatedFromLegacyPayload()
+	{
+		$payload = array(
+			'class' => 'Some_Job_Class',
+			'args' => null
+		);
+		$job = new Resque_Job('jobs', $payload);
+		$job->recreate();
+		$newJob = Resque_Job::reserve('jobs');
+		$this->assertEquals('jobs', $newJob->queue);
+		$this->assertEquals('Some_Job_Class', $newJob->payload['class']);
+		$this->assertNotNull($newJob->payload['id']);
+	}
 }
 
 class Some_Job_Class implements Resque_JobInterface