|
1
|
|
|
<?php |
|
2
|
|
|
|
|
3
|
|
|
namespace CultuurNet\UDB3\Event\ReadModel\History; |
|
4
|
|
|
|
|
5
|
|
|
use Broadway\Domain\DateTime; |
|
6
|
|
|
use Broadway\Domain\DomainMessage; |
|
7
|
|
|
use Broadway\Domain\Metadata; |
|
8
|
|
|
use Broadway\EventHandling\EventListenerInterface; |
|
9
|
|
|
use CultuurNet\UDB3\Cdb\EventItemFactory; |
|
10
|
|
|
use CultuurNet\UDB3\Event\Events\DescriptionTranslated; |
|
11
|
|
|
use CultuurNet\UDB3\Event\Events\EventCreatedFromCdbXml; |
|
12
|
|
|
use CultuurNet\UDB3\Event\Events\EventImportedFromUDB2; |
|
13
|
|
|
use CultuurNet\UDB3\Event\Events\EventUpdatedFromCdbXml; |
|
14
|
|
|
use CultuurNet\UDB3\Event\Events\EventUpdatedFromUDB2; |
|
15
|
|
|
use CultuurNet\UDB3\Event\Events\LabelAdded; |
|
16
|
|
|
use CultuurNet\UDB3\Event\Events\LabelRemoved; |
|
17
|
|
|
use CultuurNet\UDB3\Event\Events\TitleTranslated; |
|
18
|
|
|
use CultuurNet\UDB3\Event\Events\TranslationApplied; |
|
19
|
|
|
use CultuurNet\UDB3\Event\Events\TranslationDeleted; |
|
20
|
|
|
use CultuurNet\UDB3\Event\ReadModel\DocumentRepositoryInterface; |
|
21
|
|
|
use CultuurNet\UDB3\EventHandling\DelegateEventHandlingToSpecificMethodTrait; |
|
22
|
|
|
use CultuurNet\UDB3\Offer\ReadModel\History\OfferHistoryProjector; |
|
23
|
|
|
use CultuurNet\UDB3\ReadModel\JsonDocument; |
|
24
|
|
|
use ValueObjects\String\String; |
|
25
|
|
|
|
|
26
|
|
|
class HistoryProjector extends OfferHistoryProjector implements EventListenerInterface |
|
27
|
|
|
{ |
|
28
|
|
|
|
|
29
|
|
|
protected function applyEventImportedFromUDB2( |
|
30
|
|
|
EventImportedFromUDB2 $eventImportedFromUDB2, |
|
31
|
|
|
DomainMessage $domainMessage |
|
32
|
|
|
) { |
|
33
|
|
|
$udb2Event = EventItemFactory::createEventFromCdbXml( |
|
34
|
|
|
$eventImportedFromUDB2->getCdbXmlNamespaceUri(), |
|
35
|
|
|
$eventImportedFromUDB2->getCdbXml() |
|
36
|
|
|
); |
|
37
|
|
|
|
|
38
|
|
|
$this->writeHistory( |
|
39
|
|
|
$eventImportedFromUDB2->getEventId(), |
|
40
|
|
|
new Log( |
|
41
|
|
|
$this->dateFromUdb2DateString( |
|
42
|
|
|
$udb2Event->getCreationDate() |
|
43
|
|
|
), |
|
44
|
|
|
new String('Aangemaakt in UDB2'), |
|
45
|
|
|
new String($udb2Event->getCreatedBy()) |
|
46
|
|
|
) |
|
47
|
|
|
); |
|
48
|
|
|
|
|
49
|
|
|
$this->writeHistory( |
|
50
|
|
|
$eventImportedFromUDB2->getEventId(), |
|
51
|
|
|
new Log( |
|
52
|
|
|
$this->domainMessageDateToNativeDate( |
|
53
|
|
|
$domainMessage->getRecordedOn() |
|
54
|
|
|
), |
|
55
|
|
|
new String('Geïmporteerd vanuit UDB2') |
|
56
|
|
|
) |
|
57
|
|
|
); |
|
58
|
|
|
} |
|
59
|
|
|
|
|
60
|
|
View Code Duplication |
protected function applyEventCreatedFromCdbXml( |
|
|
|
|
|
|
61
|
|
|
EventCreatedFromCdbXml $eventCreatedFromCdbXml, |
|
62
|
|
|
DomainMessage $domainMessage |
|
63
|
|
|
) { |
|
64
|
|
|
$consumerName = $this->getConsumerFromMetadata($domainMessage->getMetadata()); |
|
65
|
|
|
|
|
66
|
|
|
$this->writeHistory( |
|
67
|
|
|
$eventCreatedFromCdbXml->getEventId()->toNative(), |
|
68
|
|
|
new Log( |
|
69
|
|
|
$this->domainMessageDateToNativeDate( |
|
70
|
|
|
$domainMessage->getRecordedOn() |
|
71
|
|
|
), |
|
72
|
|
|
new String( |
|
73
|
|
|
'Aangemaakt via EntryAPI door consumer "' . $consumerName . '"' |
|
74
|
|
|
), |
|
75
|
|
|
$this->getAuthorFromMetadata($domainMessage->getMetadata()) |
|
|
|
|
|
|
76
|
|
|
) |
|
77
|
|
|
); |
|
78
|
|
|
} |
|
79
|
|
|
|
|
80
|
|
View Code Duplication |
protected function applyEventUpdatedFromCdbXml( |
|
|
|
|
|
|
81
|
|
|
EventUpdatedFromCdbXml $eventUpdatedFromCdbXml, |
|
82
|
|
|
DomainMessage $domainMessage |
|
83
|
|
|
) { |
|
84
|
|
|
$consumerName = $this->getConsumerFromMetadata($domainMessage->getMetadata()); |
|
85
|
|
|
|
|
86
|
|
|
$this->writeHistory( |
|
87
|
|
|
$eventUpdatedFromCdbXml->getEventId()->toNative(), |
|
88
|
|
|
new Log( |
|
89
|
|
|
$this->domainMessageDateToNativeDate( |
|
90
|
|
|
$domainMessage->getRecordedOn() |
|
91
|
|
|
), |
|
92
|
|
|
new String( |
|
93
|
|
|
'Geüpdatet via EntryAPI door consumer "' . $consumerName . '"' |
|
94
|
|
|
), |
|
95
|
|
|
$this->getAuthorFromMetadata($domainMessage->getMetadata()) |
|
|
|
|
|
|
96
|
|
|
) |
|
97
|
|
|
); |
|
98
|
|
|
} |
|
99
|
|
|
|
|
100
|
|
|
protected function applyEventUpdatedFromUDB2( |
|
101
|
|
|
EventUpdatedFromUDB2 $eventUpdatedFromUDB2, |
|
102
|
|
|
DomainMessage $domainMessage |
|
103
|
|
|
) { |
|
104
|
|
|
$this->writeHistory( |
|
105
|
|
|
$eventUpdatedFromUDB2->getEventId(), |
|
106
|
|
|
new Log( |
|
107
|
|
|
$this->domainMessageDateToNativeDate($domainMessage->getRecordedOn()), |
|
108
|
|
|
new String('Geüpdatet vanuit UDB2') |
|
109
|
|
|
) |
|
110
|
|
|
); |
|
111
|
|
|
} |
|
112
|
|
|
|
|
113
|
|
|
protected function applyTranslationApplied( |
|
114
|
|
|
TranslationApplied $translationApplied, |
|
115
|
|
|
DomainMessage $domainMessage |
|
116
|
|
|
) { |
|
117
|
|
|
$fields = []; |
|
118
|
|
|
|
|
119
|
|
|
if ($translationApplied->getTitle() !== null) { |
|
120
|
|
|
$fields[] = 'titel'; |
|
121
|
|
|
} |
|
122
|
|
|
if ($translationApplied->getShortDescription() !== null) { |
|
123
|
|
|
$fields[] = 'korte beschrijving'; |
|
124
|
|
|
} |
|
125
|
|
|
if ($translationApplied->getLongDescription() !== null) { |
|
126
|
|
|
$fields[] = 'lange beschrijving'; |
|
127
|
|
|
} |
|
128
|
|
|
$fieldString = ucfirst(implode(', ', $fields)); |
|
129
|
|
|
|
|
130
|
|
|
$logMessage = "{$fieldString} vertaald ({$translationApplied->getLanguage()->getCode()})"; |
|
131
|
|
|
|
|
132
|
|
|
$consumerName = $this->getConsumerFromMetadata($domainMessage->getMetadata()); |
|
133
|
|
|
if ($consumerName) { |
|
134
|
|
|
$logMessage .= " via EntryAPI door consumer \"{$consumerName}\""; |
|
135
|
|
|
} |
|
136
|
|
|
|
|
137
|
|
|
$this->writeHistory( |
|
138
|
|
|
$translationApplied->getEventId()->toNative(), |
|
139
|
|
|
new Log( |
|
140
|
|
|
$this->domainMessageDateToNativeDate( |
|
141
|
|
|
$domainMessage->getRecordedOn() |
|
142
|
|
|
), |
|
143
|
|
|
new String($logMessage), |
|
144
|
|
|
$this->getAuthorFromMetadata($domainMessage->getMetadata()) |
|
|
|
|
|
|
145
|
|
|
) |
|
146
|
|
|
); |
|
147
|
|
|
} |
|
148
|
|
|
|
|
149
|
|
|
/** |
|
150
|
|
|
* @param TranslationDeleted $translationDeleted |
|
151
|
|
|
* @param DomainMessage $domainMessage |
|
152
|
|
|
*/ |
|
153
|
|
|
protected function applyTranslationDeleted( |
|
154
|
|
|
TranslationDeleted $translationDeleted, |
|
155
|
|
|
DomainMessage $domainMessage |
|
156
|
|
|
) { |
|
157
|
|
|
$message = "Vertaling verwijderd ({$translationDeleted->getLanguage()})"; |
|
158
|
|
|
|
|
159
|
|
|
$consumerName = $this->getConsumerFromMetadata($domainMessage->getMetadata()); |
|
160
|
|
|
|
|
161
|
|
|
if ($consumerName) { |
|
162
|
|
|
$message .= ' via EntryAPI door consumer "' . $consumerName . '"'; |
|
163
|
|
|
} |
|
164
|
|
|
|
|
165
|
|
|
$this->writeHistory( |
|
166
|
|
|
$translationDeleted->getEventId()->toNative(), |
|
167
|
|
|
new Log( |
|
168
|
|
|
$this->domainMessageDateToNativeDate( |
|
169
|
|
|
$domainMessage->getRecordedOn() |
|
170
|
|
|
), |
|
171
|
|
|
new String($message), |
|
172
|
|
|
$this->getAuthorFromMetadata($domainMessage->getMetadata()) |
|
|
|
|
|
|
173
|
|
|
) |
|
174
|
|
|
); |
|
175
|
|
|
} |
|
176
|
|
|
|
|
177
|
|
|
/** |
|
178
|
|
|
* @return string |
|
179
|
|
|
*/ |
|
180
|
|
|
protected function getLabelAddedClassName() |
|
181
|
|
|
{ |
|
182
|
|
|
return LabelAdded::class; |
|
183
|
|
|
} |
|
184
|
|
|
|
|
185
|
|
|
/** |
|
186
|
|
|
* @return string |
|
187
|
|
|
*/ |
|
188
|
|
|
protected function getLabelRemovedClassName() |
|
189
|
|
|
{ |
|
190
|
|
|
return LabelRemoved::class; |
|
191
|
|
|
} |
|
192
|
|
|
|
|
193
|
|
|
/** |
|
194
|
|
|
* @return string |
|
195
|
|
|
*/ |
|
196
|
|
|
protected function getTitleTranslatedClassName() |
|
197
|
|
|
{ |
|
198
|
|
|
return TitleTranslated::class; |
|
199
|
|
|
} |
|
200
|
|
|
|
|
201
|
|
|
/** |
|
202
|
|
|
* @return string |
|
203
|
|
|
*/ |
|
204
|
|
|
protected function getDescriptionTranslatedClassName() |
|
205
|
|
|
{ |
|
206
|
|
|
return DescriptionTranslated::class; |
|
207
|
|
|
} |
|
208
|
|
|
} |
|
209
|
|
|
|
cultuurnet /
udb3-php
Loading history...
Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation.
You can also find more detailed suggestions in the “Code” section of your repository.