-
Notifications
You must be signed in to change notification settings - Fork 0
/
RulesRunner.php
87 lines (78 loc) · 2.07 KB
/
RulesRunner.php
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
<?php
namespace Altair\Validation;
use Altair\Middleware\Contracts\PayloadInterface;
use Altair\Structure\Queue;
use Altair\Validation\Contracts\ResolverInterface;
use Altair\Validation\Contracts\RuleInterface;
use Altair\Validation\Contracts\RulesRunnerInterface;
class RulesRunner implements RulesRunnerInterface
{
/**
* The middleware queue.
*
* @var Queue
*/
protected $queue;
/**
*
* A callable to convert queue entries to callables.
*
* @var callable|ResolverInterface
*
*/
protected $resolver;
/**
*
* Constructor.
*
* @param callable|ResolverInterface $resolver Converts queue entries to callables.
* @param Queue $queue The middleware queue.
*/
public function __construct(ResolverInterface $resolver = null, Queue $queue = null)
{
$this->resolver = $resolver;
$this->queue = $queue;
}
/**
* Calls the next entry in the queue.
*
* @param PayloadInterface $payload
*
* @return PayloadInterface
*/
public function __invoke(PayloadInterface $payload): PayloadInterface
{
$entry = null !== $this->queue && !$this->queue->isEmpty() ? $this->queue->pop() : null;
$middleware = $this->resolve($entry);
return $middleware($payload, $this);
}
/**
* @param array $rules
*
* @return RulesRunnerInterface
*/
public function withRules(array $rules): RulesRunnerInterface
{
$this->queue = new Queue($rules);
return $this;
}
/**
* Converts a queue entry to a callable, using the resolver if present.
*
* @param mixed|callable|RuleInterface $entry the queue entry.
*
* @return callable|RuleInterface
*/
protected function resolve($entry)
{
if (!$entry) {
return function (PayloadInterface $payload, callable $next) {
return $payload;
};
}
if (!$this->resolver) {
return $entry;
}
return call_user_func($this->resolver, $entry);
}
}