Completed
Pull Request — master (#7)
by Marc
02:31
created

JSONTaskFactory::create()   B

Complexity

Conditions 5
Paths 4

Size

Total Lines 20
Code Lines 11

Duplication

Lines 0
Ratio 0 %

Importance

Changes 0
Metric Value
dl 0
loc 20
rs 8.8571
c 0
b 0
f 0
cc 5
eloc 11
nc 4
nop 1
1
<?php
2
3
namespace Cmp\Queues\Domain\Task;
4
5
use Cmp\Queues\Domain\Queue\JSONMessageFactory;
6
use Cmp\Queues\Domain\Task\Exception\InvalidJSONTaskException;
7
use Cmp\Queues\Domain\Task\Exception\TaskException;
8
9
class JSONTaskFactory implements JSONMessageFactory
10
{
11
    /**
12
     * @param string $json
13
     *
14
     * @return Task
15
     * @throws InvalidJSONTaskException
16
     */
17
    public function create($json)
18
    {
19
        $taskArray = json_decode($json, true);
20
21
        if (json_last_error() !== JSON_ERROR_NONE) {
22
            throw new InvalidJSONTaskException("String is not valid JSON");
23
        }
24
25
        if (!isset($taskArray['name'], $taskArray['body'])) {
26
            throw new InvalidJSONTaskException("Cannot reconstruct task. Name or body fields are missing");
27
        }
28
29
        try {
30
            return new Task(
31
                $taskArray['name'], $taskArray['body'], isset($taskArray['delay']) ? $taskArray['delay'] : 0
32
            );
33
        } catch(TaskException $e) {
34
            throw new InvalidJSONTaskException("Failed creating Task instance", 0, $e);
35
        }
36
    }
37
}