BackwardsCompatiblePayloadSerializerFactory::createSerializer() - Code Metrics - Inspection of "III-2436 Add main language when creating event/pla..." - cultuurnet/udb3-php - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#344)

by Luc

created 2018-02-14 10:37 UTC

createSerializer() B

↳ Parent: BackwardsCompatiblePayloadSerializerFactory

Complexity

Conditions	3
Paths	4

Size

Total Lines	233
Code Lines	120

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	233
rs	8.2857
c	0
b	0
f	0
cc	3
eloc	120
nc	4
nop	1

How to fix Long Method

<?php

namespace CultuurNet\UDB3;

use Broadway\Serializer\SerializerInterface;
use Broadway\Serializer\SimpleInterfaceSerializer;
use CultuurNet\UDB3\Event\Events\BookingInfoUpdated as EventBookingInfoUpdated;
use CultuurNet\UDB3\Event\Events\ContactPointUpdated as EventContactPointUpdated;
use CultuurNet\UDB3\Event\Events\DescriptionTranslated;
use CultuurNet\UDB3\Event\Events\DescriptionUpdated as EventDescriptionUpdated;
use CultuurNet\UDB3\Event\Events\EventDeleted;
use CultuurNet\UDB3\Event\Events\EventImportedFromUDB2;
use CultuurNet\UDB3\Event\Events\LabelAdded;
use CultuurNet\UDB3\Event\Events\LabelRemoved;
use CultuurNet\UDB3\Event\Events\MajorInfoUpdated;
use CultuurNet\UDB3\Event\Events\OrganizerDeleted as EventOrganizerDeleted;
use CultuurNet\UDB3\Event\Events\OrganizerUpdated as EventOrganizerUpdated;
use CultuurNet\UDB3\Event\Events\TitleTranslated;
use CultuurNet\UDB3\Event\Events\TypicalAgeRangeDeleted as EventTypicalAgeRangeDeleted;
use CultuurNet\UDB3\Event\Events\TypicalAgeRangeUpdated as EventTypicalAgeRangeUpdated;
use CultuurNet\UDB3\EventSourcing\PayloadManipulatingSerializer;
use CultuurNet\UDB3\Label\ReadModels\JSON\Repository\ReadRepositoryInterface;
use CultuurNet\UDB3\Label\ValueObjects\Visibility;
use CultuurNet\UDB3\Place\Events\BookingInfoUpdated as PlaceBookingInfoUpdated;
use CultuurNet\UDB3\Place\Events\ContactPointUpdated as PlaceContactPointUpdated;
use CultuurNet\UDB3\Place\Events\DescriptionUpdated as PlaceDescriptionUpdated;
use CultuurNet\UDB3\Place\Events\OrganizerDeleted as PlaceOrganizerDeleted;
use CultuurNet\UDB3\Place\Events\OrganizerUpdated as PlaceOrganizerUpdated;
use CultuurNet\UDB3\Place\Events\PlaceDeleted;
use CultuurNet\UDB3\Place\Events\TypicalAgeRangeDeleted as PlaceTypicalAgeRangeDeleted;
use CultuurNet\UDB3\Place\Events\TypicalAgeRangeUpdated as PlaceTypicalAgeRangeUpdated;
use ValueObjects\Identity\UUID;

/**
 * Factory chaining together the logic to manipulate the payload of old events
 * in order to make it usable by new events.
 *
 * Some cases:
 * - changing the class name / namespace after class renames
 * - changing the names of properties
 */
class BackwardsCompatiblePayloadSerializerFactory
{
    private function __construct()
    {

    }

    /**
     * @param ReadRepositoryInterface $labelRepository
     * @return SerializerInterface
     */
    public static function createSerializer(ReadRepositoryInterface $labelRepository)
    {
        $payloadManipulatingSerializer = new PayloadManipulatingSerializer(
            new SimpleInterfaceSerializer()
        );

        /*
         * CREATE EVENTS
         *
         */

        $payloadManipulatingSerializer->manipulateEventsOfClass(
            'CultuurNet\UDB3\Event\Events\EventCreated',
            function (array $serializedObject) {
                return self::addDefaultMainLanguage($serializedObject);
            }
        );

        $payloadManipulatingSerializer->manipulateEventsOfClass(
            'CultuurNet\UDB3\Place\Events\PlaceCreated',
            function (array $serializedObject) {
                return self::addDefaultMainLanguage($serializedObject);
            }
        );

        /*
         * TRANSLATION EVENTS
         */

        $payloadManipulatingSerializer->manipulateEventsOfClass(
            'CultuurNet\UDB3\Event\TitleTranslated',
            function (array $serializedObject) {
                $serializedObject['class'] = TitleTranslated::class;

                $serializedObject = self::replaceEventIdWithItemId($serializedObject);

                return $serializedObject;
            }
        );

        $payloadManipulatingSerializer->manipulateEventsOfClass(
            'CultuurNet\UDB3\Event\DescriptionTranslated',
            function (array $serializedObject) {
                $serializedObject['class'] = DescriptionTranslated::class;

                $serializedObject = self::replaceEventIdWithItemId($serializedObject);

                return $serializedObject;
            }
        );

        /*
         * LABEL EVENTS
         */

        $payloadManipulatingSerializer->manipulateEventsOfClass(
            'CultuurNet\UDB3\Label\Events\MadeInvisible',
            function (array $serializedObject) use ($labelRepository) {
                return self::addLabelName($serializedObject, $labelRepository);
            }
        );

        $payloadManipulatingSerializer->manipulateEventsOfClass(
            'CultuurNet\UDB3\Label\Events\MadeVisible',
            function (array $serializedObject) use ($labelRepository) {
                return self::addLabelName($serializedObject, $labelRepository);
            }
        );

        $payloadManipulatingSerializer->manipulateEventsOfClass(
            'CultuurNet\UDB3\Label\Events\MadePrivate',
            function (array $serializedObject) use ($labelRepository) {
                return self::addLabelName($serializedObject, $labelRepository);
            }
        );

        $payloadManipulatingSerializer->manipulateEventsOfClass(
            'CultuurNet\UDB3\Label\Events\MadePublic',
            function (array $serializedObject) use ($labelRepository) {
                return self::addLabelName($serializedObject, $labelRepository);
            }
        );

        $payloadManipulatingSerializer->manipulateEventsOfClass(
            'CultuurNet\UDB3\Organizer\Events\LabelAdded',
            function (array $serializedObject) use ($labelRepository) {
                return self::fixOrganizerLabelEvent($serializedObject, $labelRepository);
            }
        );

        $payloadManipulatingSerializer->manipulateEventsOfClass(
            'CultuurNet\UDB3\Organizer\Events\LabelRemoved',
            function (array $serializedObject) use ($labelRepository) {
                return self::fixOrganizerLabelEvent($serializedObject, $labelRepository);
            }
        );

        $payloadManipulatingSerializer->manipulateEventsOfClass(
            'CultuurNet\UDB3\Event\Events\EventWasLabelled',
            function (array $serializedObject) {
                $serializedObject['class'] = LabelAdded::class;

                $serializedObject = self::replaceEventIdWithItemId($serializedObject);

                return $serializedObject;
            }
        );

        $payloadManipulatingSerializer->manipulateEventsOfClass(
            'CultuurNet\UDB3\Event\EventWasTagged',
            function (array $serializedObject) {
                $serializedObject['class'] = LabelAdded::class;

                $serializedObject = self::replaceEventIdWithItemId($serializedObject);

                $serializedObject = self::replaceKeywordWithLabel($serializedObject);

                return $serializedObject;
            }
        );

        $payloadManipulatingSerializer->manipulateEventsOfClass(
            'CultuurNet\UDB3\Event\TagErased',
            function (array $serializedObject) {
                $serializedObject['class'] = LabelRemoved::class;

                $serializedObject = self::replaceEventIdWithItemId($serializedObject);

                $serializedObject = self::replaceKeywordWithLabel($serializedObject);

                return $serializedObject;
            }
        );

        $payloadManipulatingSerializer->manipulateEventsOfClass(
            'CultuurNet\UDB3\Event\Events\Unlabelled',
            function (array $serializedObject) {
                $serializedObject['class'] = LabelRemoved::class;

                $serializedObject = self::replaceEventIdWithItemId($serializedObject);

                return $serializedObject;
            }
        );

        /**
         * UBD2 IMPORT
         */

        $payloadManipulatingSerializer->manipulateEventsOfClass(
            'CultuurNet\UDB3\Event\EventImportedFromUDB2',
            function (array $serializedObject) {
                $serializedObject['class'] = EventImportedFromUDB2::class;

                return $serializedObject;
            }
        );

        /**
         * PLACE FACILITIES EVENT
         */
        $payloadManipulatingSerializer->manipulateEventsOfClass(
            'CultuurNet\UDB3\Place\Events\FacilitiesUpdated',
            function (array $serializedObject) {
                $serializedObject = self::replacePlaceIdWithItemId($serializedObject);

                return $serializedObject;
            }
        );

        /**
         * GEOCOORDINATES UPDATED EVENT
         */
        $payloadManipulatingSerializer->manipulateEventsOfClass(
            'CultuurNet\UDB3\Place\Events\GeoCoordinatesUpdated',
            function (array $serializedObject) {
                $serializedObject = self::replacePlaceIdWithItemId($serializedObject);

                return $serializedObject;
            }
        );

        /**
         * EventEvent to AbstractEvent (Offer)
         */
        $refactoredEventEvents = [
            EventBookingInfoUpdated::class,
            EventTypicalAgeRangeDeleted::class,
            EventTypicalAgeRangeUpdated::class,
            EventContactPointUpdated::class,
            MajorInfoUpdated::class,
            EventOrganizerUpdated::class,
            EventOrganizerDeleted::class,
            EventDescriptionUpdated::class,
            EventDeleted::class,
        ];

        foreach ($refactoredEventEvents as $refactoredEventEvent) {
            $payloadManipulatingSerializer->manipulateEventsOfClass(
                $refactoredEventEvent,
                function (array $serializedObject) {
                    $serializedObject = self::replaceEventIdWithItemId($serializedObject);
                    return $serializedObject;
                }
            );
        }

        /**
         * PlaceEvent to AbstractEvent (Offer)
         */
        $refactoredPlaceEvents = [
            PlaceOrganizerUpdated::class,
            PlaceOrganizerDeleted::class,
            PlaceBookingInfoUpdated::class,
            PlaceTypicalAgeRangeDeleted::class,
            PlaceTypicalAgeRangeUpdated::class,
            PlaceContactPointUpdated::class,
            PlaceDescriptionUpdated::class,
            PlaceDeleted::class,
        ];

        foreach ($refactoredPlaceEvents as $refactoredPlaceEvent) {
            $payloadManipulatingSerializer->manipulateEventsOfClass(
                $refactoredPlaceEvent,
                function (array $serializedObject) {
                    $serializedObject = self::replacePlaceIdWithItemId($serializedObject);
                    return $serializedObject;
                }
            );
        }

        return $payloadManipulatingSerializer;
    }

    /**
     * @param array $serializedObject
     * @return array
     */
    private static function replaceEventIdWithItemId(array $serializedObject)
    {
        return self::replaceKeys('event_id', 'item_id', $serializedObject);
    }

    /**
     * @param array $serializedObject
     * @return array
     */
    private static function replacePlaceIdWithItemId(array $serializedObject)
    {
        return self::replaceKeys('place_id', 'item_id', $serializedObject);
    }

    /**
     * @param string $oldKey
     * @param string $newKey
     * @param array $serializedObject
     * @return array
     */
    private static function replaceKeys($oldKey, $newKey, $serializedObject)
    {
        if (isset($serializedObject['payload'][$oldKey])) {
            $value = $serializedObject['payload'][$oldKey];
            $serializedObject['payload'][$newKey] = $value;
            unset($serializedObject['payload'][$oldKey]);
        }

        return $serializedObject;
    }

    /**
     * @param array $serializedObject
     * @return array
     */
    private static function replaceKeywordWithLabel(array $serializedObject)
    {
        $keyword = $serializedObject['payload']['keyword'];
        $serializedObject['payload']['label'] = $keyword;
        unset($serializedObject['payload']['keyword']);

        return $serializedObject;
    }

    /**
     * @param array $serializedObject
     * @param ReadRepositoryInterface $labelRepository
     * @return array
     */
    private static function addLabelName(
        array $serializedObject,
        ReadRepositoryInterface $labelRepository
    ) {
        if (!isset($serializedObject['payload']['name'])) {
            $uuid = $serializedObject['payload']['uuid'];
            $label = $labelRepository->getByUuid(new UUID($uuid));

            $serializedObject['payload']['name'] = $label->getName()->toNative();
        }

        return $serializedObject;
    }

    /**
     * @param array $serializedObject
     * @param ReadRepositoryInterface $labelRepository
     * @return array
     */
    private static function fixOrganizerLabelEvent(
        array $serializedObject,
        ReadRepositoryInterface $labelRepository
    ) {
        if (!isset($serializedObject['payload']['label']) ||
            !isset($serializedObject['payload']['visibility'])) {
            $uuid = $serializedObject['payload']['labelId'];
            $label = $labelRepository->getByUuid(new UUID($uuid));

            $serializedObject['payload']['label'] = $label->getName()->toNative();
            $serializedObject['payload']['visibility'] = $label->getVisibility() === Visibility::VISIBLE();
        }

        return $serializedObject;
    }

    /**
     * @param array $serializedObject
     * @return array
     */
    private static function addDefaultMainLanguage(array $serializedObject)
    {
        if (!isset($serializedObject['payload']['main_language'])) {
            $mainLanguage = new Language('nl');
            $serializedObject['payload']['main_language'] = $mainLanguage->getCode();
        }

        return $serializedObject;
    }
}


1			<?php
2
3			namespace CultuurNet\UDB3;
4
5			use Broadway\Serializer\SerializerInterface;
6			use Broadway\Serializer\SimpleInterfaceSerializer;
7			use CultuurNet\UDB3\Event\Events\BookingInfoUpdated as EventBookingInfoUpdated;
8			use CultuurNet\UDB3\Event\Events\ContactPointUpdated as EventContactPointUpdated;
9			use CultuurNet\UDB3\Event\Events\DescriptionTranslated;
10			use CultuurNet\UDB3\Event\Events\DescriptionUpdated as EventDescriptionUpdated;
11			use CultuurNet\UDB3\Event\Events\EventDeleted;
12			use CultuurNet\UDB3\Event\Events\EventImportedFromUDB2;
13			use CultuurNet\UDB3\Event\Events\LabelAdded;
14			use CultuurNet\UDB3\Event\Events\LabelRemoved;
15			use CultuurNet\UDB3\Event\Events\MajorInfoUpdated;
16			use CultuurNet\UDB3\Event\Events\OrganizerDeleted as EventOrganizerDeleted;
17			use CultuurNet\UDB3\Event\Events\OrganizerUpdated as EventOrganizerUpdated;
18			use CultuurNet\UDB3\Event\Events\TitleTranslated;
19			use CultuurNet\UDB3\Event\Events\TypicalAgeRangeDeleted as EventTypicalAgeRangeDeleted;
20			use CultuurNet\UDB3\Event\Events\TypicalAgeRangeUpdated as EventTypicalAgeRangeUpdated;
21			use CultuurNet\UDB3\EventSourcing\PayloadManipulatingSerializer;
22			use CultuurNet\UDB3\Label\ReadModels\JSON\Repository\ReadRepositoryInterface;
23			use CultuurNet\UDB3\Label\ValueObjects\Visibility;
24			use CultuurNet\UDB3\Place\Events\BookingInfoUpdated as PlaceBookingInfoUpdated;
25			use CultuurNet\UDB3\Place\Events\ContactPointUpdated as PlaceContactPointUpdated;
26			use CultuurNet\UDB3\Place\Events\DescriptionUpdated as PlaceDescriptionUpdated;
27			use CultuurNet\UDB3\Place\Events\OrganizerDeleted as PlaceOrganizerDeleted;
28			use CultuurNet\UDB3\Place\Events\OrganizerUpdated as PlaceOrganizerUpdated;
29			use CultuurNet\UDB3\Place\Events\PlaceDeleted;
30			use CultuurNet\UDB3\Place\Events\TypicalAgeRangeDeleted as PlaceTypicalAgeRangeDeleted;
31			use CultuurNet\UDB3\Place\Events\TypicalAgeRangeUpdated as PlaceTypicalAgeRangeUpdated;
32			use ValueObjects\Identity\UUID;
33
34			/**
35			* Factory chaining together the logic to manipulate the payload of old events
36			* in order to make it usable by new events.
37			*
38			* Some cases:
39			* - changing the class name / namespace after class renames
40			* - changing the names of properties
41			*/
42			class BackwardsCompatiblePayloadSerializerFactory
43			{
44			private function __construct()
45			{
46
47			}
48
49			/**
50			* @param ReadRepositoryInterface $labelRepository
51			* @return SerializerInterface
52			*/
53			public static function createSerializer(ReadRepositoryInterface $labelRepository)
54			{
55			$payloadManipulatingSerializer = new PayloadManipulatingSerializer(
56			new SimpleInterfaceSerializer()
57			);
58
59			/*
60			* CREATE EVENTS
61			*
62			*/
63
64			$payloadManipulatingSerializer->manipulateEventsOfClass(
65			'CultuurNet\UDB3\Event\Events\EventCreated',
66			function (array $serializedObject) {
67			return self::addDefaultMainLanguage($serializedObject);
68			}
69			);
70
71			$payloadManipulatingSerializer->manipulateEventsOfClass(
72			'CultuurNet\UDB3\Place\Events\PlaceCreated',
73			function (array $serializedObject) {
74			return self::addDefaultMainLanguage($serializedObject);
75			}
76			);
77
78			/*
79			* TRANSLATION EVENTS
80			*/
81
82			$payloadManipulatingSerializer->manipulateEventsOfClass(
83			'CultuurNet\UDB3\Event\TitleTranslated',
84			function (array $serializedObject) {
85			$serializedObject['class'] = TitleTranslated::class;
86
87			$serializedObject = self::replaceEventIdWithItemId($serializedObject);
88
89			return $serializedObject;
90			}
91			);
92
93			$payloadManipulatingSerializer->manipulateEventsOfClass(
94			'CultuurNet\UDB3\Event\DescriptionTranslated',
95			function (array $serializedObject) {
96			$serializedObject['class'] = DescriptionTranslated::class;
97
98			$serializedObject = self::replaceEventIdWithItemId($serializedObject);
99
100			return $serializedObject;
101			}
102			);
103
104			/*
105			* LABEL EVENTS
106			*/
107
108			$payloadManipulatingSerializer->manipulateEventsOfClass(
109			'CultuurNet\UDB3\Label\Events\MadeInvisible',
110			function (array $serializedObject) use ($labelRepository) {
111			return self::addLabelName($serializedObject, $labelRepository);
112			}
113			);
114
115			$payloadManipulatingSerializer->manipulateEventsOfClass(
116			'CultuurNet\UDB3\Label\Events\MadeVisible',
117			function (array $serializedObject) use ($labelRepository) {
118			return self::addLabelName($serializedObject, $labelRepository);
119			}
120			);
121
122			$payloadManipulatingSerializer->manipulateEventsOfClass(
123			'CultuurNet\UDB3\Label\Events\MadePrivate',
124			function (array $serializedObject) use ($labelRepository) {
125			return self::addLabelName($serializedObject, $labelRepository);
126			}
127			);
128
129			$payloadManipulatingSerializer->manipulateEventsOfClass(
130			'CultuurNet\UDB3\Label\Events\MadePublic',
131			function (array $serializedObject) use ($labelRepository) {
132			return self::addLabelName($serializedObject, $labelRepository);
133			}
134			);
135
136			$payloadManipulatingSerializer->manipulateEventsOfClass(
137			'CultuurNet\UDB3\Organizer\Events\LabelAdded',
138			function (array $serializedObject) use ($labelRepository) {
139			return self::fixOrganizerLabelEvent($serializedObject, $labelRepository);
140			}
141			);
142
143			$payloadManipulatingSerializer->manipulateEventsOfClass(
144			'CultuurNet\UDB3\Organizer\Events\LabelRemoved',
145			function (array $serializedObject) use ($labelRepository) {
146			return self::fixOrganizerLabelEvent($serializedObject, $labelRepository);
147			}
148			);
149
150			$payloadManipulatingSerializer->manipulateEventsOfClass(
151			'CultuurNet\UDB3\Event\Events\EventWasLabelled',
152			function (array $serializedObject) {
153			$serializedObject['class'] = LabelAdded::class;
154
155			$serializedObject = self::replaceEventIdWithItemId($serializedObject);
156
157			return $serializedObject;
158			}
159			);
160
161			$payloadManipulatingSerializer->manipulateEventsOfClass(
162			'CultuurNet\UDB3\Event\EventWasTagged',
163			function (array $serializedObject) {
164			$serializedObject['class'] = LabelAdded::class;
165
166			$serializedObject = self::replaceEventIdWithItemId($serializedObject);
167
168			$serializedObject = self::replaceKeywordWithLabel($serializedObject);
169
170			return $serializedObject;
171			}
172			);
173
174			$payloadManipulatingSerializer->manipulateEventsOfClass(
175			'CultuurNet\UDB3\Event\TagErased',
176			function (array $serializedObject) {
177			$serializedObject['class'] = LabelRemoved::class;
178
179			$serializedObject = self::replaceEventIdWithItemId($serializedObject);
180
181			$serializedObject = self::replaceKeywordWithLabel($serializedObject);
182
183			return $serializedObject;
184			}
185			);
186
187			$payloadManipulatingSerializer->manipulateEventsOfClass(
188			'CultuurNet\UDB3\Event\Events\Unlabelled',
189			function (array $serializedObject) {
190			$serializedObject['class'] = LabelRemoved::class;
191
192			$serializedObject = self::replaceEventIdWithItemId($serializedObject);
193
194			return $serializedObject;
195			}
196			);
197
198			/**
199			* UBD2 IMPORT
200			*/
201
202			$payloadManipulatingSerializer->manipulateEventsOfClass(
203			'CultuurNet\UDB3\Event\EventImportedFromUDB2',
204			function (array $serializedObject) {
205			$serializedObject['class'] = EventImportedFromUDB2::class;
206
207			return $serializedObject;
208			}
209			);
210
211			/**
212			* PLACE FACILITIES EVENT
213			*/
214			$payloadManipulatingSerializer->manipulateEventsOfClass(
215			'CultuurNet\UDB3\Place\Events\FacilitiesUpdated',
216			function (array $serializedObject) {
217			$serializedObject = self::replacePlaceIdWithItemId($serializedObject);
218
219			return $serializedObject;
220			}
221			);
222
223			/**
224			* GEOCOORDINATES UPDATED EVENT
225			*/
226			$payloadManipulatingSerializer->manipulateEventsOfClass(
227			'CultuurNet\UDB3\Place\Events\GeoCoordinatesUpdated',
228			function (array $serializedObject) {
229			$serializedObject = self::replacePlaceIdWithItemId($serializedObject);
230
231			return $serializedObject;
232			}
233			);
234
235			/**
236			* EventEvent to AbstractEvent (Offer)
237			*/
238			$refactoredEventEvents = [
239			EventBookingInfoUpdated::class,
240			EventTypicalAgeRangeDeleted::class,
241			EventTypicalAgeRangeUpdated::class,
242			EventContactPointUpdated::class,
243			MajorInfoUpdated::class,
244			EventOrganizerUpdated::class,
245			EventOrganizerDeleted::class,
246			EventDescriptionUpdated::class,
247			EventDeleted::class,
248			];
249
250			foreach ($refactoredEventEvents as $refactoredEventEvent) {
251			$payloadManipulatingSerializer->manipulateEventsOfClass(
252			$refactoredEventEvent,
253			function (array $serializedObject) {
254			$serializedObject = self::replaceEventIdWithItemId($serializedObject);
255			return $serializedObject;
256			}
257			);
258			}
259
260			/**
261			* PlaceEvent to AbstractEvent (Offer)
262			*/
263			$refactoredPlaceEvents = [
264			PlaceOrganizerUpdated::class,
265			PlaceOrganizerDeleted::class,
266			PlaceBookingInfoUpdated::class,
267			PlaceTypicalAgeRangeDeleted::class,
268			PlaceTypicalAgeRangeUpdated::class,
269			PlaceContactPointUpdated::class,
270			PlaceDescriptionUpdated::class,
271			PlaceDeleted::class,
272			];
273
274			foreach ($refactoredPlaceEvents as $refactoredPlaceEvent) {
275			$payloadManipulatingSerializer->manipulateEventsOfClass(
276			$refactoredPlaceEvent,
277			function (array $serializedObject) {
278			$serializedObject = self::replacePlaceIdWithItemId($serializedObject);
279			return $serializedObject;
280			}
281			);
282			}
283
284			return $payloadManipulatingSerializer;
285			}
286
287			/**
288			* @param array $serializedObject
289			* @return array
290			*/
291			private static function replaceEventIdWithItemId(array $serializedObject)
292			{
293			return self::replaceKeys('event_id', 'item_id', $serializedObject);
294			}
295
296			/**
297			* @param array $serializedObject
298			* @return array
299			*/
300			private static function replacePlaceIdWithItemId(array $serializedObject)
301			{
302			return self::replaceKeys('place_id', 'item_id', $serializedObject);
303			}
304
305			/**
306			* @param string $oldKey
307			* @param string $newKey
308			* @param array $serializedObject
309			* @return array
310			*/
311			private static function replaceKeys($oldKey, $newKey, $serializedObject)
312			{
313			if (isset($serializedObject['payload'][$oldKey])) {
314			$value = $serializedObject['payload'][$oldKey];
315			$serializedObject['payload'][$newKey] = $value;
316			unset($serializedObject['payload'][$oldKey]);
317			}
318
319			return $serializedObject;
320			}
321
322			/**
323			* @param array $serializedObject
324			* @return array
325			*/
326			private static function replaceKeywordWithLabel(array $serializedObject)
327			{
328			$keyword = $serializedObject['payload']['keyword'];
329			$serializedObject['payload']['label'] = $keyword;
330			unset($serializedObject['payload']['keyword']);
331
332			return $serializedObject;
333			}
334
335			/**
336			* @param array $serializedObject
337			* @param ReadRepositoryInterface $labelRepository
338			* @return array
339			*/
340			private static function addLabelName(
341			array $serializedObject,
342			ReadRepositoryInterface $labelRepository
343			) {
344			if (!isset($serializedObject['payload']['name'])) {
345			$uuid = $serializedObject['payload']['uuid'];
346			$label = $labelRepository->getByUuid(new UUID($uuid));
347
348			$serializedObject['payload']['name'] = $label->getName()->toNative();
349			}
350
351			return $serializedObject;
352			}
353
354			/**
355			* @param array $serializedObject
356			* @param ReadRepositoryInterface $labelRepository
357			* @return array
358			*/
359			private static function fixOrganizerLabelEvent(
360			array $serializedObject,
361			ReadRepositoryInterface $labelRepository
362			) {
363			if (!isset($serializedObject['payload']['label']) \|\|
364			!isset($serializedObject['payload']['visibility'])) {
365			$uuid = $serializedObject['payload']['labelId'];
366			$label = $labelRepository->getByUuid(new UUID($uuid));
367
368			$serializedObject['payload']['label'] = $label->getName()->toNative();
369			$serializedObject['payload']['visibility'] = $label->getVisibility() === Visibility::VISIBLE();
370			}
371
372			return $serializedObject;
373			}
374
375			/**
376			* @param array $serializedObject
377			* @return array
378			*/
379			private static function addDefaultMainLanguage(array $serializedObject)
380			{
381			if (!isset($serializedObject['payload']['main_language'])) {
382			$mainLanguage = new Language('nl');
383			$serializedObject['payload']['main_language'] = $mainLanguage->getCode();
384			}
385
386			return $serializedObject;
387			}
388			}
389

cultuurnet / udb3-php

Pull Request — master (#344)

createSerializer() B

Complexity

Size

Duplication

Importance

How to fix Long Method

Long Method

Duplication Side-by-Side

Filter issues like