Cmp\Queues\Domain\Task\JSONTaskFactory

Complexity

Total Complexity

5

Size/Duplication

Total Lines	27
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	2

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
B	create()	0	18	5

<?php

namespace Cmp\Queues\Domain\Task;

use Cmp\Queues\Domain\Queue\JSONMessageFactory;
use Cmp\Queues\Domain\Task\Exception\InvalidJSONTaskException;
use Cmp\Queues\Domain\Task\Exception\TaskException;

class JSONTaskFactory implements JSONMessageFactory
{
    /**
     * @param string $json
     *
     * @return Task
     * @throws InvalidJSONTaskException
     */
    public function create($json)
    {
        $taskArray = json_decode($json, true);

        if (json_last_error() !== JSON_ERROR_NONE) {
            throw new InvalidJSONTaskException("String is not valid JSON");
        }

        if (!isset($taskArray['name'], $taskArray['body'])) {
            throw new InvalidJSONTaskException("Cannot reconstruct task. Name or body fields are missing");
        }

        try {
            return new Task($taskArray['name'], $taskArray['body'], isset($taskArray['delay']) ? $taskArray['delay'] : 0);
        } catch (TaskException $e) {
            throw new InvalidJSONTaskException("Failed creating Task instance", 0, $e);
        }
    }
}