Completed
Push — master ( 2705ab...006cbd )
by Dmitry
04:32
created

Runner   A

Complexity

Total Complexity 16

Size/Duplication

Total Lines 89
Duplicated Lines 0 %

Coupling/Cohesion

Components 1
Dependencies 1

Test Coverage

Coverage 93.62%

Importance

Changes 0
Metric Value
wmc 16
c 0
b 0
f 0
lcom 1
cbo 1
dl 0
loc 89
ccs 44
cts 47
cp 0.9362
rs 10

6 Methods

Rating   Name   Duplication   Size   Complexity  
A __construct() 0 4 1
B getMapping() 0 28 5
A hasJob() 0 4 1
A getJobClass() 0 14 3
A dispatch() 0 15 3
A castArguments() 0 13 3
1
<?php
2
3
namespace Basis;
4
5
use LogicException;
6
use League\Container\Container;
7
use ReflectionClass;
8
use ReflectionProperty;
9
10
class Runner
11
{
12
    private $app;
13
    private $mapping;
14
15 10
    public function __construct(Application $app)
16
    {
17 10
        $this->app = $app;
18 10
    }
19
20 10
    public function getMapping() : array
21
    {
22 10
        if (!$this->mapping) {
23 10
            $jobs = [];
24 10
            foreach ($this->app->get(Framework::class)->listClasses('Job') as $class) {
25 10
                $jobs[substr($class, strlen('Basis\\Job\\'))] = $class;
26
            }
27 10
            $serviceName = ucfirst($this->app->get(Config::class)['service']);
28 10
            foreach ($this->app->get(Filesystem::class)->listClasses('Job') as $class) {
29 10
                $jobs[$serviceName.'\\'.substr($class, strlen('Job\\'))] = $class;
30 10
                $jobs[$serviceName.'\\'.lcfirst(substr($class, strlen('Job\\')))] = $class;
31 10
                $jobs[substr($class, strlen('Job\\'))] = $class;
32 10
                $jobs[lcfirst(substr($class, strlen('Job\\')))] = $class;
33
            }
34
35
36 10
            foreach ($jobs as $part => $class) {
37 10
                $nick = str_replace('\\', '.', $part);
38 10
                $jobs[$nick] = $class;
39 10
                $jobs[lcfirst($nick)] = $class;
40 10
                $jobs[strtolower($nick)] = $class;
41
            }
42
43 10
            $this->mapping = $jobs;
44
        }
45
46 10
        return $this->mapping;
47
    }
48
49 10
    public function hasJob(string $nick) : bool
50
    {
51 10
        return array_key_exists($nick, $this->getMapping());
52
    }
53
54 10
    public function getJobClass(string $nick) : string
55
    {
56 10
        $mapping = $this->getMapping();
57 10
        if (!array_key_exists($nick, $mapping)) {
58
            throw new LogicException("No job $nick");
59
        }
60
61 10
        $class = $mapping[$nick];
62
63 10
        if (!class_exists($class)) {
64
            throw new LogicException("No class for job $nick");
65
        }
66 10
        return $class;
67
    }
68
69 10
    public function dispatch(string $nick, array $arguments = [])
70
    {
71 10
        $class = $this->getJobClass($nick);
72
73 10
        $instance = $this->app->get($class);
74 10
        if (array_key_exists(0, $arguments)) {
75 1
            $arguments = $this->castArguments($class, $arguments);
76
        }
77
78 10
        foreach ($arguments as $k => $v) {
79 4
            $instance->$k = $v;
80
        }
81
82 10
        return $this->app->call([$instance, 'run']);
83
    }
84
85 1
    private function castArguments(string $class, array $arguments) : array
86
    {
87 1
        $reflection = new ReflectionClass($class);
88 1
        $properties = $reflection->getProperties(ReflectionProperty::IS_PUBLIC);
89 1
        if (count($properties) == 1) {
90
            return [
91 1
                $properties[0]->getName() => count($arguments) == 1
92 1
                    ? $arguments[0]
93 1
                    : implode(' ', $arguments)
94
            ];
95
        }
96
        return $arguments;
97
    }
98
}
99