Fix TypeError when editing queued job with invalid JSON payload

When invalid JSON is submitted via the data edit form, the
JsonableBehavior threw a TypeError because json_decode returned null
but the return type was array.

Changes:
- Update _fromJson() to throw InvalidArgumentException with a
  descriptive error message instead of TypeError
- Catch the exception in data() action and show a flash error
- Preserve the user's invalid input so they can fix it
- Add data_string virtual property annotation to QueuedJob entity
- Add test for invalid JSON handling
- Fix PHPStan errors: handle nullable description() in example tasks

Author: dereuromark

src/Controller/Admin/QueuedJobsController.php

@@ -8,6 +8,7 @@
 use Cake\Http\Exception\NotFoundException;
 use Cake\I18n\DateTime;
 use Cake\View\JsonView;
+use InvalidArgumentException;
 use Queue\Queue\TaskFinder;
 use RuntimeException;
 
@@ -304,14 +305,21 @@ public function data(?int $id = null) {
 		}
 
 		if ($this->request->is(['patch', 'post', 'put'])) {
-			$queuedJob = $this->QueuedJobs->patchEntity($queuedJob, $this->request->getData());
-			if ($this->QueuedJobs->save($queuedJob)) {
-				$this->Flash->success(__d('queue', 'The queued job has been saved.'));
+			try {
+				$queuedJob = $this->QueuedJobs->patchEntity($queuedJob, $this->request->getData());
+				if ($this->QueuedJobs->save($queuedJob)) {
+					$this->Flash->success(__d('queue', 'The queued job has been saved.'));
 
-				return $this->redirect(['action' => 'view', $id]);
-			}
+					return $this->redirect(['action' => 'view', $id]);
+				}
 
-			$this->Flash->error(__d('queue', 'The queued job could not be saved. Please try again.'));
+				$this->Flash->error(__d('queue', 'The queued job could not be saved. Please try again.'));
+			} catch (InvalidArgumentException $e) {
+				$this->Flash->error($e->getMessage());
+
+				// Preserve the user's invalid input so they can fix it
+				$queuedJob->data_string = $this->request->getData('data_string');
+			}
 		}
 
 		$this->set(compact('queuedJob'));

src/Model/Behavior/JsonableBehavior.php

@@ -216,10 +216,15 @@ public function _decode($val) {
 	/**
 	 * @param string $val
 	 *
+	 * @throws \InvalidArgumentException
+	 *
 	 * @return array
 	 */
 	protected function _fromJson(string $val): array {
-		$json = json_decode($val, true, JSON_THROW_ON_ERROR);
+		$json = json_decode($val, true);
+		if (!is_array($json)) {
+			throw new InvalidArgumentException('Invalid JSON: ' . json_last_error_msg());
+		}
 
 		return $json;
 	}

src/Model/Entity/QueuedJob.php

@@ -9,6 +9,7 @@
  * @property int $id
  * @property string $job_task
  * @property array|null $data
+ * @property string|null $data_string Virtual property from JsonableBehavior
  * @property string|null $job_group
  * @property string|null $reference
  * @property \Cake\I18n\DateTime $created

src/Queue/Task/CostsExampleTask.php

@@ -33,7 +33,7 @@ class CostsExampleTask extends Task implements AddInterface, AddFromBackendInter
 	public function add(?string $data): void {
 		$this->io->out('CakePHP Queue CostsExample task.');
 		$this->io->hr();
-		$this->io->out($this->description());
+		$this->io->out($this->description() ?? '');
 		$this->io->out('I will now add an example Job into the Queue.');
 		$this->io->out(' ');
 		$this->io->out('To run a Worker use:');

src/Queue/Task/ExampleTask.php

@@ -36,7 +36,7 @@ class ExampleTask extends Task implements AddInterface, AddFromBackendInterface
 	public function add(?string $data): void {
 		$this->io->out('CakePHP Queue Example task.');
 		$this->io->hr();
-		$this->io->out($this->description());
+		$this->io->out($this->description() ?? '');
 		$this->io->out('I will now add an example Job into the Queue.');
 		$this->io->out(' ');
 		$this->io->out('To run a Worker use:');

src/Queue/Task/ExceptionExampleTask.php

@@ -32,7 +32,7 @@ class ExceptionExampleTask extends Task implements AddInterface, AddFromBackendI
 	public function add(?string $data): void {
 		$this->io->out('CakePHP Queue ExceptionExample task.');
 		$this->io->hr();
-		$this->io->out($this->description());
+		$this->io->out($this->description() ?? '');
 		$this->io->out('I will now add an example Job into the Queue.');
 		$this->io->out(' ');
 		$this->io->out('To run a Worker use:');

src/Queue/Task/MonitorExampleTask.php

@@ -38,7 +38,7 @@ class MonitorExampleTask extends Task implements AddInterface, AddFromBackendInt
 	public function add(?string $data): void {
 		$this->io->out('CakePHP Queue MonitorExample task.');
 		$this->io->hr();
-		$this->io->out($this->description());
+		$this->io->out($this->description() ?? '');
 		$this->io->out('I will now add an example Job into the Queue.');
 		$this->io->out(' ');
 		$this->io->out('To run a Worker use:');

src/Queue/Task/ProgressExampleTask.php

@@ -36,7 +36,7 @@ class ProgressExampleTask extends Task implements AddInterface, AddFromBackendIn
 	public function add(?string $data): void {
 		$this->io->out('CakePHP Queue ProgressExample task.');
 		$this->io->hr();
-		$this->io->out($this->description());
+		$this->io->out($this->description() ?? '');
 		$this->io->out('I will now add the Job into the Queue.');
 		$this->io->out(' ');
 		$this->io->out('To run a Worker use:');

src/Queue/Task/RetryExampleTask.php

@@ -68,7 +68,7 @@ public static function init(): bool {
 	public function add(?string $data): void {
 		$this->io->out('CakePHP Queue RetryExample task.');
 		$this->io->hr();
-		$this->io->out($this->description());
+		$this->io->out($this->description() ?? '');
 		$this->io->out('I will now add an example Job into the Queue.');
 		$this->io->out(' ');
 		$this->io->out('To run a Worker use:');

src/Queue/Task/SuperExampleTask.php

@@ -36,7 +36,7 @@ class SuperExampleTask extends Task implements AddInterface, AddFromBackendInter
 	public function add(?string $data): void {
 		$this->io->out('CakePHP Queue SuperExample task.');
 		$this->io->hr();
-		$this->io->out($this->description());
+		$this->io->out($this->description() ?? '');
 		$this->io->out('I will now add an example Job into the Queue.');
 		$this->io->out(' ');
 		$this->io->out('To run a Worker use:');