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
|
|
|
|