1 | <?php |
||
2 | |||
3 | namespace Cypress\PatchManager; |
||
4 | |||
5 | use Cypress\PatchManager\Request\Operations; |
||
6 | use PhpCollection\Sequence; |
||
7 | |||
8 | /** |
||
9 | * Match the correct handlers based on actual operations |
||
10 | */ |
||
11 | class OperationMatcher |
||
12 | { |
||
13 | /** |
||
14 | * @var Sequence |
||
15 | */ |
||
16 | private Sequence $handlers; |
||
0 ignored issues
–
show
Coding Style
introduced
by
Loading history...
|
|||
17 | |||
18 | /** |
||
19 | * @var Operations |
||
20 | */ |
||
21 | private Operations $operations; |
||
0 ignored issues
–
show
|
|||
22 | |||
23 | /** |
||
24 | * @param Operations $operations |
||
25 | */ |
||
26 | 7 | public function __construct(Operations $operations) |
|
27 | { |
||
28 | 7 | $this->handlers = new Sequence(); |
|
29 | 7 | $this->operations = $operations; |
|
30 | } |
||
31 | |||
32 | /** |
||
33 | * @param PatchOperationHandler $handler |
||
34 | */ |
||
35 | 6 | public function addHandler(PatchOperationHandler $handler): void |
|
36 | { |
||
37 | 6 | $this->handlers->add($handler); |
|
38 | } |
||
39 | |||
40 | /** |
||
41 | * @param array|Patchable|\Traversable $subject a Patchable instance or a collection of instances |
||
42 | * |
||
43 | * @throws Exception\MissingOperationNameRequest |
||
44 | * @throws Exception\MissingOperationRequest |
||
45 | * @throws Exception\InvalidJsonRequestContent |
||
46 | * @return Sequence |
||
47 | */ |
||
48 | 7 | public function getMatchedOperations($subject): Sequence |
|
49 | { |
||
50 | 7 | $handlers = $this->handlers; |
|
51 | |||
52 | 7 | return $this->operations |
|
53 | 7 | ->all() |
|
54 | 7 | ->foldLeft( |
|
55 | 7 | new Sequence(), |
|
56 | 7 | function (Sequence $matchedOperations, array $operationData) use ($handlers, $subject) { |
|
57 | 7 | $handler = $handlers->find(fn (PatchOperationHandler $patchHandler) => $operationData[Operations::OP_KEY_NAME] === $patchHandler->getName()); |
|
58 | 7 | if ($handler->isDefined()) { |
|
59 | /** @var PatchOperationHandler $patchOperationHandler */ |
||
60 | 4 | $patchOperationHandler = $handler->get(); |
|
61 | 4 | if ($patchOperationHandler->canHandle($subject)) { |
|
62 | 3 | $matchedOperations->add(MatchedPatchOperation::create($operationData, $handler->get())); |
|
63 | } |
||
64 | } |
||
65 | |||
66 | 7 | return $matchedOperations; |
|
67 | 7 | } |
|
68 | 7 | ); |
|
69 | } |
||
70 | |||
71 | /** |
||
72 | * @param array|Patchable|\Traversable $subject a Patchable instance or a collection of instances |
||
73 | * @throws Exception\InvalidJsonRequestContent |
||
74 | * @throws Exception\MissingOperationNameRequest |
||
75 | * @throws Exception\MissingOperationRequest |
||
76 | * @return Sequence |
||
77 | */ |
||
78 | 2 | public function getUnmatchedOperations($subject): Sequence |
|
79 | { |
||
80 | 2 | return $this->operations |
|
81 | 2 | ->all() |
|
82 | 2 | ->filter(fn (array $operationData) => $operationData !== $this->getMatchedOperations($subject)) |
|
83 | 2 | ->map(fn (array $operationData) => $operationData['op']); |
|
84 | } |
||
85 | } |
||
86 |