Completed
Pull Request — master (#290)
by Luc
04:46
created

OrganizerCommandHandler::updateAddress()   A

Complexity

Conditions 1
Paths 1

Size

Total Lines 8
Code Lines 4

Duplication

Lines 0
Ratio 0 %

Importance

Changes 0
Metric Value
dl 0
loc 8
rs 9.4285
c 0
b 0
f 0
cc 1
eloc 4
nc 1
nop 1
1
<?php
2
3
namespace CultuurNet\UDB3\Organizer;
4
5
use Broadway\CommandHandling\CommandHandlerInterface;
6
use Broadway\Repository\RepositoryInterface;
7
use CultuurNet\UDB3\Label;
8
use CultuurNet\UDB3\Label\ValueObjects\Visibility;
9
use CultuurNet\UDB3\Organizer\Commands\AbstractLabelCommand;
10
use CultuurNet\UDB3\Organizer\Commands\AddLabel;
11
use CultuurNet\UDB3\Organizer\Commands\DeleteOrganizer;
12
use CultuurNet\UDB3\Organizer\Commands\RemoveLabel;
13
use CultuurNet\UDB3\Organizer\Commands\UpdateAddress;
14
use CultuurNet\UDB3\Organizer\Commands\UpdateContactPoint;
15
use CultuurNet\UDB3\Organizer\Commands\UpdateTitle;
16
use CultuurNet\UDB3\Organizer\Commands\UpdateWebsite;
17
use ValueObjects\StringLiteral\StringLiteral;
18
use CultuurNet\UDB3\Label\ReadModels\JSON\Repository\ReadRepositoryInterface;
19
20
class OrganizerCommandHandler implements CommandHandlerInterface
21
{
22
    /**
23
     * @var RepositoryInterface
24
     */
25
    private $organizerRepository;
26
27
    /**
28
     * @var ReadRepositoryInterface
29
     */
30
    private $labelRepository;
31
32
    /**
33
     * @var OrganizerRelationServiceInterface[]
34
     */
35
    private $organizerRelationServices;
36
37
    /**
38
     * @param RepositoryInterface $organizerRepository
39
     * @param ReadRepositoryInterface $labelRepository
40
     */
41
    public function __construct(
42
        RepositoryInterface $organizerRepository,
43
        ReadRepositoryInterface $labelRepository
44
    ) {
45
        $this->organizerRepository = $organizerRepository;
46
        $this->labelRepository = $labelRepository;
47
        $this->organizerRelationServices = [];
48
    }
49
50
    /**
51
     * @param OrganizerRelationServiceInterface $relationService
52
     * @return OrganizerCommandHandler
53
     */
54
    public function withOrganizerRelationService(OrganizerRelationServiceInterface $relationService)
55
    {
56
        $c = clone $this;
57
        $c->organizerRelationServices[] = $relationService;
58
        return $c;
59
    }
60
61
    /**
62
     * @return array
63
     */
64
    protected function getCommandHandlerMethods()
65
    {
66
        return [
67
            UpdateWebsite::class => 'updateWebsite',
68
            UpdateTitle::class => 'updateTitle',
69
            UpdateAddress::class => 'updateAddress',
70
            UpdateContactPoint::class => 'updateContactPoint',
71
            DeleteOrganizer::class => 'deleteOrganizer',
72
            AddLabel::class => 'addLabel',
73
            RemoveLabel::class => 'removeLabel'
74
        ];
75
    }
76
77
    /**
78
     * @param mixed $command
79
     */
80
    public function handle($command)
81
    {
82
        $class = get_class($command);
83
        $handlers = $this->getCommandHandlerMethods();
84
85
        if (isset($handlers[$class])) {
86
            $method = $handlers[$class];
87
            $this->{$method}($command);
88
        }
89
    }
90
91
    /**
92
     * @param UpdateWebsite $updateWebsite
93
     */
94
    protected function updateWebsite(UpdateWebsite $updateWebsite)
95
    {
96
        $organizer = $this->loadOrganizer($updateWebsite->getOrganizerId());
97
98
        $organizer->updateWebsite($updateWebsite->getWebsite());
99
100
        $this->organizerRepository->save($organizer);
101
    }
102
103
    /**
104
     * @param UpdateTitle $updateTitle
105
     */
106
    protected function updateTitle(UpdateTitle $updateTitle)
107
    {
108
        $organizer = $this->loadOrganizer($updateTitle->getOrganizerId());
109
110
        $organizer->updateTitle($updateTitle->getTitle());
111
112
        $this->organizerRepository->save($organizer);
113
    }
114
115
    /**
116
     * @param UpdateAddress $updateAddress
117
     */
118
    protected function updateAddress(UpdateAddress $updateAddress)
119
    {
120
        $organizer = $this->loadOrganizer($updateAddress->getOrganizerId());
121
122
        $organizer->updateAddress($updateAddress->getAddress());
123
124
        $this->organizerRepository->save($organizer);
125
    }
126
127
    /**
128
     * @param UpdateContactPoint $updateContactPoint
129
     */
130
    protected function updateContactPoint(UpdateContactPoint $updateContactPoint)
131
    {
132
        $organizer = $this->loadOrganizer($updateContactPoint->getOrganizerId());
133
134
        $organizer->updateContactPoint($updateContactPoint->getContactPoint());
135
136
        $this->organizerRepository->save($organizer);
137
    }
138
139
    /**
140
     * @param AddLabel $addLabel
141
     */
142
    protected function addLabel(AddLabel $addLabel)
143
    {
144
        $organizer = $this->loadOrganizer($addLabel->getOrganizerId());
145
146
        $organizer->addLabel($this->createLabel($addLabel));
147
148
        $this->organizerRepository->save($organizer);
149
    }
150
151
    /**
152
     * @param RemoveLabel $removeLabel
153
     */
154
    protected function removeLabel(RemoveLabel $removeLabel)
155
    {
156
        $organizer = $this->loadOrganizer($removeLabel->getOrganizerId());
157
158
        $organizer->removeLabel($this->createLabel($removeLabel));
159
160
        $this->organizerRepository->save($organizer);
161
    }
162
163
    /**
164
     * @param AbstractLabelCommand $labelCommand
165
     * @return Label
166
     */
167 View Code Duplication
    private function createLabel(AbstractLabelCommand $labelCommand)
0 ignored issues
show
Duplication introduced by
This method seems to be duplicated in your project.

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.

Loading history...
168
    {
169
        $labelName = new StringLiteral((string) $labelCommand->getLabel());
170
        $label = $this->labelRepository->getByName($labelName);
171
172
        return new Label(
173
            $labelName->toNative(),
174
            $label->getVisibility() === Visibility::VISIBLE()
175
        );
176
    }
177
178
    /**
179
     * @param DeleteOrganizer $deleteOrganizer
180
     */
181
    public function deleteOrganizer(DeleteOrganizer $deleteOrganizer)
182
    {
183
        $id = $deleteOrganizer->getOrganizerId();
184
185
        // First remove all relations to the given organizer.
186
        foreach ($this->organizerRelationServices as $relationService) {
187
            $relationService->deleteOrganizer($id);
188
        }
189
190
        // Delete the organizer itself.
191
        $organizer = $this->loadOrganizer($id);
192
193
        $organizer->delete();
194
195
        $this->organizerRepository->save($organizer);
196
    }
197
198
    /**
199
     * Makes it easier to type hint to Organizer.
200
     *
201
     * @param string $id
202
     * @return Organizer
203
     */
204
    protected function loadOrganizer($id)
205
    {
206
        return $this->organizerRepository->load($id);
207
    }
208
}
209