1 | <?php |
||
18 | abstract class OfferHistoryProjector |
||
19 | { |
||
20 | use DelegateEventHandlingToSpecificMethodTrait { |
||
21 | DelegateEventHandlingToSpecificMethodTrait::handle as handleUnknownEvents; |
||
22 | } |
||
23 | |||
24 | /** |
||
25 | * @var DocumentRepositoryInterface |
||
26 | */ |
||
27 | private $documentRepository; |
||
28 | |||
29 | public function __construct(DocumentRepositoryInterface $documentRepository) |
||
30 | { |
||
31 | $this->documentRepository = $documentRepository; |
||
32 | } |
||
33 | |||
34 | /** |
||
35 | * {@inheritdoc} |
||
36 | */ |
||
37 | public function handle(DomainMessage $domainMessage) |
||
38 | { |
||
39 | $event = $domainMessage->getPayload(); |
||
40 | |||
41 | $eventName = get_class($event); |
||
42 | $eventHandlers = $this->getEventHandlers(); |
||
43 | |||
44 | if (isset($eventHandlers[$eventName])) { |
||
45 | $handler = $eventHandlers[$eventName]; |
||
46 | call_user_func(array($this, $handler), $event, $domainMessage); |
||
47 | } else { |
||
48 | $this->handleUnknownEvents($domainMessage); |
||
49 | } |
||
50 | } |
||
51 | |||
52 | /** |
||
53 | * @return string[] |
||
54 | * An associative array of commands and their handler methods. |
||
55 | */ |
||
56 | protected function getEventHandlers() |
||
57 | { |
||
58 | $events = []; |
||
59 | |||
60 | foreach (get_class_methods($this) as $method) { |
||
61 | $matches = []; |
||
62 | |||
63 | if (preg_match('/^apply(.+)$/', $method, $matches)) { |
||
64 | $event = $matches[1]; |
||
65 | $classNameMethod = 'get' . $event . 'ClassName'; |
||
66 | |||
67 | if (method_exists($this, $classNameMethod)) { |
||
68 | $eventFullClassName = call_user_func(array($this, $classNameMethod)); |
||
69 | $events[$eventFullClassName] = $method; |
||
70 | } |
||
71 | } |
||
72 | } |
||
73 | |||
74 | return $events; |
||
75 | } |
||
76 | |||
77 | /** |
||
78 | * @return string |
||
79 | */ |
||
80 | abstract protected function getLabelAddedClassName(); |
||
81 | |||
82 | /** |
||
83 | * @return string |
||
84 | */ |
||
85 | abstract protected function getLabelRemovedClassName(); |
||
86 | |||
87 | /** |
||
88 | * @return string |
||
89 | */ |
||
90 | abstract protected function getTitleTranslatedClassName(); |
||
91 | |||
92 | /** |
||
93 | * @return string |
||
94 | */ |
||
95 | abstract protected function getDescriptionTranslatedClassName(); |
||
96 | |||
97 | /** |
||
98 | * @param AbstractLabelAdded $labelAdded |
||
99 | * @param DomainMessage $domainMessage |
||
100 | */ |
||
101 | protected function applyLabelAdded( |
||
116 | |||
117 | /** |
||
118 | * @param AbstractLabelRemoved $labelRemoved |
||
119 | * @param DomainMessage $domainMessage |
||
120 | */ |
||
121 | protected function applyLabelRemoved( |
||
136 | |||
137 | protected function applyTitleTranslated( |
||
152 | |||
153 | protected function applyDescriptionTranslated( |
||
168 | |||
169 | /** |
||
170 | * @param DateTime $date |
||
171 | * @return \DateTime |
||
172 | */ |
||
173 | protected function domainMessageDateToNativeDate(DateTime $date) |
||
181 | |||
182 | /** |
||
183 | * @param $dateString |
||
184 | * @return \DateTime |
||
185 | */ |
||
186 | protected function dateFromUdb2DateString($dateString) |
||
194 | |||
195 | /** |
||
196 | * @param Metadata $metadata |
||
197 | * @return String|null |
||
198 | */ |
||
199 | protected function getAuthorFromMetadata(Metadata $metadata) |
||
207 | |||
208 | /** |
||
209 | * @param Metadata $metadata |
||
210 | * @return String|null |
||
211 | */ |
||
212 | protected function getConsumerFromMetadata(Metadata $metadata) |
||
220 | |||
221 | /** |
||
222 | * @param string $eventId |
||
223 | * @return JsonDocument |
||
224 | */ |
||
225 | protected function loadDocumentFromRepositoryByEventId($eventId) |
||
235 | |||
236 | /** |
||
237 | * @param string $eventId |
||
238 | * @param Log[]|Log $logs |
||
239 | */ |
||
240 | protected function writeHistory($eventId, $logs) |
||
259 | |||
260 | protected function getApiKeyFromMetadata(Metadata $metadata): ?string |
||
270 | |||
271 | protected function getApiFromMetadata(Metadata $metadata): ?string |
||
281 | } |
||
282 |