1
|
|
|
<?php |
2
|
|
|
|
3
|
|
|
namespace CultuurNet\UDB3\Event\ReadModel\JSONLD; |
4
|
|
|
|
5
|
|
|
use Broadway\EventHandling\EventListenerInterface; |
6
|
|
|
use CultuurNet\UDB3\Event\EventServiceInterface; |
7
|
|
|
use CultuurNet\UDB3\Event\ReadModel\DocumentRepositoryInterface; |
8
|
|
|
use CultuurNet\UDB3\EventHandling\DelegateEventHandlingToSpecificMethodTrait; |
9
|
|
|
use CultuurNet\UDB3\Offer\IriOfferIdentifierFactoryInterface; |
10
|
|
|
use CultuurNet\UDB3\Organizer\OrganizerProjectedToJSONLD; |
11
|
|
|
use CultuurNet\UDB3\OrganizerService; |
12
|
|
|
use CultuurNet\UDB3\Place\Events\PlaceProjectedToJSONLD; |
13
|
|
|
use CultuurNet\UDB3\PlaceService; |
14
|
|
|
use ValueObjects\Web\Url; |
15
|
|
|
|
16
|
|
|
class RelatedEventLDProjector implements EventListenerInterface |
17
|
|
|
{ |
18
|
|
|
use DelegateEventHandlingToSpecificMethodTrait; |
19
|
|
|
|
20
|
|
|
/** |
21
|
|
|
* @var PlaceService |
22
|
|
|
*/ |
23
|
|
|
protected $placeService; |
24
|
|
|
|
25
|
|
|
/** |
26
|
|
|
* @var OrganizerServiceInterface |
27
|
|
|
*/ |
28
|
|
|
protected $organizerService; |
29
|
|
|
|
30
|
|
|
/** |
31
|
|
|
* @var EventServiceInterface |
32
|
|
|
*/ |
33
|
|
|
protected $eventService; |
34
|
|
|
|
35
|
|
|
/** |
36
|
|
|
* @var IriOfferIdentifierFactoryInterface |
37
|
|
|
*/ |
38
|
|
|
protected $iriOfferIdentifierFactory; |
39
|
|
|
|
40
|
|
|
/** |
41
|
|
|
* @param DocumentRepositoryInterface $repository |
42
|
|
|
* @param EventServiceInterface $eventService |
43
|
|
|
* @param PlaceService $placeService |
44
|
|
|
* @param OrganizerService $organizerService |
45
|
|
|
*/ |
46
|
|
|
public function __construct( |
47
|
|
|
DocumentRepositoryInterface $repository, |
48
|
|
|
EventServiceInterface $eventService, |
49
|
|
|
PlaceService $placeService, |
50
|
|
|
OrganizerService $organizerService, |
51
|
|
|
IriOfferIdentifierFactoryInterface $iriOfferIdentifierFactory |
52
|
|
|
) { |
53
|
|
|
$this->repository = $repository; |
|
|
|
|
54
|
|
|
$this->eventService = $eventService; |
55
|
|
|
$this->placeService = $placeService; |
56
|
|
|
$this->organizerService = $organizerService; |
|
|
|
|
57
|
|
|
|
58
|
|
|
|
59
|
|
|
$this->iriOfferIdentifierFactory = $iriOfferIdentifierFactory; |
60
|
|
|
} |
61
|
|
|
|
62
|
|
View Code Duplication |
protected function applyOrganizerProjectedToJSONLD( |
|
|
|
|
63
|
|
|
OrganizerProjectedToJSONLD $organizerProjectedToJSONLD |
64
|
|
|
) { |
65
|
|
|
$eventIds = $this->eventService->eventsOrganizedByOrganizer( |
66
|
|
|
$organizerProjectedToJSONLD->getId() |
67
|
|
|
); |
68
|
|
|
|
69
|
|
|
$organizer = $this->organizerService->getEntity( |
|
|
|
|
70
|
|
|
$organizerProjectedToJSONLD->getId() |
71
|
|
|
); |
72
|
|
|
|
73
|
|
|
$organizerJSONLD = json_decode($organizer); |
74
|
|
|
|
75
|
|
|
foreach ($eventIds as $eventId) { |
76
|
|
|
$this->updateEmbeddedOrganizer($eventId, $organizerJSONLD); |
77
|
|
|
} |
78
|
|
|
} |
79
|
|
|
|
80
|
|
|
protected function applyPlaceProjectedToJSONLD( |
81
|
|
|
PlaceProjectedToJSONLD $placeProjectedToJSONLD |
82
|
|
|
) { |
83
|
|
|
$identifier = $this->iriOfferIdentifierFactory->fromIri( |
84
|
|
|
Url::fromNative($placeProjectedToJSONLD->getIri()) |
85
|
|
|
); |
86
|
|
|
|
87
|
|
|
$eventsLocatedAtPlace = $this->eventService->eventsLocatedAtPlace( |
88
|
|
|
$placeProjectedToJSONLD->getItemId() |
89
|
|
|
); |
90
|
|
|
|
91
|
|
|
$placeJSONLDString = $this->placeService->getEntity( |
92
|
|
|
$identifier->getId() |
93
|
|
|
); |
94
|
|
|
$placeJSONLD = json_decode($placeJSONLDString); |
95
|
|
|
|
96
|
|
|
foreach ($eventsLocatedAtPlace as $eventId) { |
97
|
|
|
$this->updatedEmbeddedLocation($eventId, $placeJSONLD); |
98
|
|
|
} |
99
|
|
|
} |
100
|
|
|
|
101
|
|
|
private function updateEmbeddedOrganizer($eventId, $organizerJSONLD) |
102
|
|
|
{ |
103
|
|
|
$this->updateJSONLD( |
104
|
|
|
$eventId, |
105
|
|
|
function ($eventLd) use ($organizerJSONLD) { |
106
|
|
|
$eventLd->organizer = $organizerJSONLD; |
107
|
|
|
} |
108
|
|
|
); |
109
|
|
|
} |
110
|
|
|
|
111
|
|
|
private function updatedEmbeddedLocation($eventId, $placeJSONLD) |
112
|
|
|
{ |
113
|
|
|
$this->updateJSONLD( |
114
|
|
|
$eventId, |
115
|
|
|
function ($eventLd) use ($placeJSONLD) { |
116
|
|
|
$eventLd->location = $placeJSONLD; |
117
|
|
|
} |
118
|
|
|
); |
119
|
|
|
} |
120
|
|
|
|
121
|
|
View Code Duplication |
private function updateJSONLD($eventId, $callback) |
|
|
|
|
122
|
|
|
{ |
123
|
|
|
$document = $this->repository->get($eventId); |
124
|
|
|
|
125
|
|
|
if (!$document) { |
126
|
|
|
return; |
127
|
|
|
} |
128
|
|
|
|
129
|
|
|
$eventLD = $document->getBody(); |
130
|
|
|
|
131
|
|
|
$newEventLD = clone $eventLD; |
132
|
|
|
|
133
|
|
|
$callback($newEventLD); |
134
|
|
|
|
135
|
|
|
if ($newEventLD == $eventLD) { |
136
|
|
|
return; |
137
|
|
|
} |
138
|
|
|
|
139
|
|
|
$document = $document->withBody($newEventLD); |
140
|
|
|
|
141
|
|
|
$this->repository->save($document); |
142
|
|
|
} |
143
|
|
|
} |
144
|
|
|
|
In PHP it is possible to write to properties without declaring them. For example, the following is perfectly valid PHP code:
Generally, it is a good practice to explictly declare properties to avoid accidental typos and provide IDE auto-completion: