BackwardsCompatiblePayloadSerializerFactory::__construct() - Code Metrics - Inspection of "Merge pull request #359 from cultuurnet/feature/II..." - cultuurnet/udb3-php - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 1563bb...25b79c )

by Luc

created 2018-04-23 12:57 UTC

__construct() A

↳ Parent: BackwardsCompatiblePayloadSerializerFactory

Complexity

Conditions	1
Paths	1

Size

Total Lines	4
Code Lines	1

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	4
rs	10
c	0
b	0
f	0
cc	1
eloc	1
nc	1
nop	0

<?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\PriceInfoUpdated as EventPriceInfoUpdated;
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\PriceInfoUpdated as PlacePriceInfoUpdated;
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);
            }
        );

        $payloadManipulatingSerializer->manipulateEventsOfClass(
            'CultuurNet\UDB3\Organizer\Events\OrganizerCreatedWithUniqueWebsite',
            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;
            }
        );

        /**
         * BOOKING INFO EVENT
         */
        $manipulateAvailability = function (array $serializedBookingInfo, $propertyName) {
            if (!isset($serializedBookingInfo[$propertyName]) || empty($serializedBookingInfo[$propertyName])) {
                $serializedBookingInfo[$propertyName] = null;
                return $serializedBookingInfo;
            }

            $dateTimeString = $serializedBookingInfo[$propertyName];

            // The new serialized date time format is a string according the ISO 8601 format.
            // If this is so return without modifications.
            $dateTimeFromAtom = \DateTimeImmutable::createFromFormat(\DATE_ATOM, $dateTimeString);
            if ($dateTimeFromAtom) {
                return $serializedBookingInfo;
            }

            // For older format a modification is needed to ISO 8601 format.
            $dateTimeFromAtomWithMilliseconds = \DateTimeImmutable::createFromFormat(
                'Y-m-d\TH:i:s.uP',
                $dateTimeString
            );
            if ($dateTimeFromAtomWithMilliseconds) {
                $serializedBookingInfo[$propertyName] = $dateTimeFromAtomWithMilliseconds->format(\DATE_ATOM);
                return $serializedBookingInfo;
            }

            // In case of unknown format clear the available date property.
            unset($serializedBookingInfo[$propertyName]);
            return $serializedBookingInfo;
        };

        $manipulateBookingInfoEvent = function (array $serializedEvent) use ($manipulateAvailability) {
            $serializedEvent = self::replaceEventIdWithItemId($serializedEvent);
            $serializedEvent = self::replacePlaceIdWithItemId($serializedEvent);

            $serializedBookingInfo = $serializedEvent['payload']['bookingInfo'];
            $serializedBookingInfo = $manipulateAvailability($serializedBookingInfo, 'availabilityStarts');
            $serializedBookingInfo = $manipulateAvailability($serializedBookingInfo, 'availabilityEnds');
            $serializedEvent['payload']['bookingInfo'] = $serializedBookingInfo;

            return $serializedEvent;
        };

        $payloadManipulatingSerializer->manipulateEventsOfClass(
            EventBookingInfoUpdated::class,
            $manipulateBookingInfoEvent
        );

        $payloadManipulatingSerializer->manipulateEventsOfClass(
            PlaceBookingInfoUpdated::class,
            $manipulateBookingInfoEvent
        );

        /**
         * EventEvent to AbstractEvent (Offer)
         */
        $refactoredEventEvents = [
            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,
            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;
                }
            );
        }

        /**
         * PriceInfoUpdated events
         */
        $priceInfoEvents = [
            EventPriceInfoUpdated::class,
            PlacePriceInfoUpdated::class,
        ];

        foreach ($priceInfoEvents as $priceInfoEvent) {
            $payloadManipulatingSerializer->manipulateEventsOfClass(
                $priceInfoEvent,
                function (array $serializedObject) {
                    $payload = &$serializedObject['payload'];
                    $priceInfo = &$payload['price_info'];
                    $tariffs = array_map(
                        function (array $tariff) {
                            $name = $tariff['name'];
                            if (is_string($name)) {
                                $name = ['nl' => $name];
                            }
                            $tariff['name'] = $name;
                            return $tariff;
                        },
                        isset($priceInfo['tariffs']) ? $priceInfo['tariffs'] : []
                    );
                    $priceInfo['tariffs'] = $tariffs;
                    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\PriceInfoUpdated as EventPriceInfoUpdated;
19			use CultuurNet\UDB3\Event\Events\TitleTranslated;
20			use CultuurNet\UDB3\Event\Events\TypicalAgeRangeDeleted as EventTypicalAgeRangeDeleted;
21			use CultuurNet\UDB3\Event\Events\TypicalAgeRangeUpdated as EventTypicalAgeRangeUpdated;
22			use CultuurNet\UDB3\EventSourcing\PayloadManipulatingSerializer;
23			use CultuurNet\UDB3\Label\ReadModels\JSON\Repository\ReadRepositoryInterface;
24			use CultuurNet\UDB3\Label\ValueObjects\Visibility;
25			use CultuurNet\UDB3\Place\Events\BookingInfoUpdated as PlaceBookingInfoUpdated;
26			use CultuurNet\UDB3\Place\Events\ContactPointUpdated as PlaceContactPointUpdated;
27			use CultuurNet\UDB3\Place\Events\DescriptionUpdated as PlaceDescriptionUpdated;
28			use CultuurNet\UDB3\Place\Events\OrganizerDeleted as PlaceOrganizerDeleted;
29			use CultuurNet\UDB3\Place\Events\OrganizerUpdated as PlaceOrganizerUpdated;
30			use CultuurNet\UDB3\Place\Events\PlaceDeleted;
31			use CultuurNet\UDB3\Place\Events\PriceInfoUpdated as PlacePriceInfoUpdated;
32			use CultuurNet\UDB3\Place\Events\TypicalAgeRangeDeleted as PlaceTypicalAgeRangeDeleted;
33			use CultuurNet\UDB3\Place\Events\TypicalAgeRangeUpdated as PlaceTypicalAgeRangeUpdated;
34			use ValueObjects\Identity\UUID;
35
36			/**
37			* Factory chaining together the logic to manipulate the payload of old events
38			* in order to make it usable by new events.
39			*
40			* Some cases:
41			* - changing the class name / namespace after class renames
42			* - changing the names of properties
43			*/
44			class BackwardsCompatiblePayloadSerializerFactory
45			{
46			private function __construct()
47			{
48
49			}
50
51			/**
52			* @param ReadRepositoryInterface $labelRepository
53			* @return SerializerInterface
54			*/
55			public static function createSerializer(ReadRepositoryInterface $labelRepository)
56			{
57			$payloadManipulatingSerializer = new PayloadManipulatingSerializer(
58			new SimpleInterfaceSerializer()
59			);
60
61			/*
62			* CREATE EVENTS
63			*
64			*/
65
66			$payloadManipulatingSerializer->manipulateEventsOfClass(
67			'CultuurNet\UDB3\Event\Events\EventCreated',
68			function (array $serializedObject) {
69			return self::addDefaultMainLanguage($serializedObject);
70			}
71			);
72
73			$payloadManipulatingSerializer->manipulateEventsOfClass(
74			'CultuurNet\UDB3\Place\Events\PlaceCreated',
75			function (array $serializedObject) {
76			return self::addDefaultMainLanguage($serializedObject);
77			}
78			);
79
80			$payloadManipulatingSerializer->manipulateEventsOfClass(
81			'CultuurNet\UDB3\Organizer\Events\OrganizerCreatedWithUniqueWebsite',
82			function (array $serializedObject) {
83			return self::addDefaultMainLanguage($serializedObject);
84			}
85			);
86
87			/*
88			* TRANSLATION EVENTS
89			*/
90
91			$payloadManipulatingSerializer->manipulateEventsOfClass(
92			'CultuurNet\UDB3\Event\TitleTranslated',
93			function (array $serializedObject) {
94			$serializedObject['class'] = TitleTranslated::class;
95
96			$serializedObject = self::replaceEventIdWithItemId($serializedObject);
97
98			return $serializedObject;
99			}
100			);
101
102			$payloadManipulatingSerializer->manipulateEventsOfClass(
103			'CultuurNet\UDB3\Event\DescriptionTranslated',
104			function (array $serializedObject) {
105			$serializedObject['class'] = DescriptionTranslated::class;
106
107			$serializedObject = self::replaceEventIdWithItemId($serializedObject);
108
109			return $serializedObject;
110			}
111			);
112
113			/*
114			* LABEL EVENTS
115			*/
116
117			$payloadManipulatingSerializer->manipulateEventsOfClass(
118			'CultuurNet\UDB3\Label\Events\MadeInvisible',
119			function (array $serializedObject) use ($labelRepository) {
120			return self::addLabelName($serializedObject, $labelRepository);
121			}
122			);
123
124			$payloadManipulatingSerializer->manipulateEventsOfClass(
125			'CultuurNet\UDB3\Label\Events\MadeVisible',
126			function (array $serializedObject) use ($labelRepository) {
127			return self::addLabelName($serializedObject, $labelRepository);
128			}
129			);
130
131			$payloadManipulatingSerializer->manipulateEventsOfClass(
132			'CultuurNet\UDB3\Label\Events\MadePrivate',
133			function (array $serializedObject) use ($labelRepository) {
134			return self::addLabelName($serializedObject, $labelRepository);
135			}
136			);
137
138			$payloadManipulatingSerializer->manipulateEventsOfClass(
139			'CultuurNet\UDB3\Label\Events\MadePublic',
140			function (array $serializedObject) use ($labelRepository) {
141			return self::addLabelName($serializedObject, $labelRepository);
142			}
143			);
144
145			$payloadManipulatingSerializer->manipulateEventsOfClass(
146			'CultuurNet\UDB3\Organizer\Events\LabelAdded',
147			function (array $serializedObject) use ($labelRepository) {
148			return self::fixOrganizerLabelEvent($serializedObject, $labelRepository);
149			}
150			);
151
152			$payloadManipulatingSerializer->manipulateEventsOfClass(
153			'CultuurNet\UDB3\Organizer\Events\LabelRemoved',
154			function (array $serializedObject) use ($labelRepository) {
155			return self::fixOrganizerLabelEvent($serializedObject, $labelRepository);
156			}
157			);
158
159			$payloadManipulatingSerializer->manipulateEventsOfClass(
160			'CultuurNet\UDB3\Event\Events\EventWasLabelled',
161			function (array $serializedObject) {
162			$serializedObject['class'] = LabelAdded::class;
163
164			$serializedObject = self::replaceEventIdWithItemId($serializedObject);
165
166			return $serializedObject;
167			}
168			);
169
170			$payloadManipulatingSerializer->manipulateEventsOfClass(
171			'CultuurNet\UDB3\Event\EventWasTagged',
172			function (array $serializedObject) {
173			$serializedObject['class'] = LabelAdded::class;
174
175			$serializedObject = self::replaceEventIdWithItemId($serializedObject);
176
177			$serializedObject = self::replaceKeywordWithLabel($serializedObject);
178
179			return $serializedObject;
180			}
181			);
182
183			$payloadManipulatingSerializer->manipulateEventsOfClass(
184			'CultuurNet\UDB3\Event\TagErased',
185			function (array $serializedObject) {
186			$serializedObject['class'] = LabelRemoved::class;
187
188			$serializedObject = self::replaceEventIdWithItemId($serializedObject);
189
190			$serializedObject = self::replaceKeywordWithLabel($serializedObject);
191
192			return $serializedObject;
193			}
194			);
195
196			$payloadManipulatingSerializer->manipulateEventsOfClass(
197			'CultuurNet\UDB3\Event\Events\Unlabelled',
198			function (array $serializedObject) {
199			$serializedObject['class'] = LabelRemoved::class;
200
201			$serializedObject = self::replaceEventIdWithItemId($serializedObject);
202
203			return $serializedObject;
204			}
205			);
206
207			/**
208			* UBD2 IMPORT
209			*/
210
211			$payloadManipulatingSerializer->manipulateEventsOfClass(
212			'CultuurNet\UDB3\Event\EventImportedFromUDB2',
213			function (array $serializedObject) {
214			$serializedObject['class'] = EventImportedFromUDB2::class;
215
216			return $serializedObject;
217			}
218			);
219
220			/**
221			* PLACE FACILITIES EVENT
222			*/
223			$payloadManipulatingSerializer->manipulateEventsOfClass(
224			'CultuurNet\UDB3\Place\Events\FacilitiesUpdated',
225			function (array $serializedObject) {
226			$serializedObject = self::replacePlaceIdWithItemId($serializedObject);
227
228			return $serializedObject;
229			}
230			);
231
232			/**
233			* GEOCOORDINATES UPDATED EVENT
234			*/
235			$payloadManipulatingSerializer->manipulateEventsOfClass(
236			'CultuurNet\UDB3\Place\Events\GeoCoordinatesUpdated',
237			function (array $serializedObject) {
238			$serializedObject = self::replacePlaceIdWithItemId($serializedObject);
239
240			return $serializedObject;
241			}
242			);
243
244			/**
245			* BOOKING INFO EVENT
246			*/
247			$manipulateAvailability = function (array $serializedBookingInfo, $propertyName) {
248			if (!isset($serializedBookingInfo[$propertyName]) \|\| empty($serializedBookingInfo[$propertyName])) {
249			$serializedBookingInfo[$propertyName] = null;
250			return $serializedBookingInfo;
251			}
252
253			$dateTimeString = $serializedBookingInfo[$propertyName];
254
255			// The new serialized date time format is a string according the ISO 8601 format.
256			// If this is so return without modifications.
257			$dateTimeFromAtom = \DateTimeImmutable::createFromFormat(\DATE_ATOM, $dateTimeString);
258			if ($dateTimeFromAtom) {
259			return $serializedBookingInfo;
260			}
261
262			// For older format a modification is needed to ISO 8601 format.
263			$dateTimeFromAtomWithMilliseconds = \DateTimeImmutable::createFromFormat(
264			'Y-m-d\TH:i:s.uP',
265			$dateTimeString
266			);
267			if ($dateTimeFromAtomWithMilliseconds) {
268			$serializedBookingInfo[$propertyName] = $dateTimeFromAtomWithMilliseconds->format(\DATE_ATOM);
269			return $serializedBookingInfo;
270			}
271
272			// In case of unknown format clear the available date property.
273			unset($serializedBookingInfo[$propertyName]);
274			return $serializedBookingInfo;
275			};
276
277			$manipulateBookingInfoEvent = function (array $serializedEvent) use ($manipulateAvailability) {
278			$serializedEvent = self::replaceEventIdWithItemId($serializedEvent);
279			$serializedEvent = self::replacePlaceIdWithItemId($serializedEvent);
280
281			$serializedBookingInfo = $serializedEvent['payload']['bookingInfo'];
282			$serializedBookingInfo = $manipulateAvailability($serializedBookingInfo, 'availabilityStarts');
283			$serializedBookingInfo = $manipulateAvailability($serializedBookingInfo, 'availabilityEnds');
284			$serializedEvent['payload']['bookingInfo'] = $serializedBookingInfo;
285
286			return $serializedEvent;
287			};
288
289			$payloadManipulatingSerializer->manipulateEventsOfClass(
290			EventBookingInfoUpdated::class,
291			$manipulateBookingInfoEvent
292			);
293
294			$payloadManipulatingSerializer->manipulateEventsOfClass(
295			PlaceBookingInfoUpdated::class,
296			$manipulateBookingInfoEvent
297			);
298
299			/**
300			* EventEvent to AbstractEvent (Offer)
301			*/
302			$refactoredEventEvents = [
303			EventTypicalAgeRangeDeleted::class,
304			EventTypicalAgeRangeUpdated::class,
305			EventContactPointUpdated::class,
306			MajorInfoUpdated::class,
307			EventOrganizerUpdated::class,
308			EventOrganizerDeleted::class,
309			EventDescriptionUpdated::class,
310			EventDeleted::class,
311			];
312
313			foreach ($refactoredEventEvents as $refactoredEventEvent) {
314			$payloadManipulatingSerializer->manipulateEventsOfClass(
315			$refactoredEventEvent,
316			function (array $serializedObject) {
317			$serializedObject = self::replaceEventIdWithItemId($serializedObject);
318			return $serializedObject;
319			}
320			);
321			}
322
323			/**
324			* PlaceEvent to AbstractEvent (Offer)
325			*/
326			$refactoredPlaceEvents = [
327			PlaceOrganizerUpdated::class,
328			PlaceOrganizerDeleted::class,
329			PlaceTypicalAgeRangeDeleted::class,
330			PlaceTypicalAgeRangeUpdated::class,
331			PlaceContactPointUpdated::class,
332			PlaceDescriptionUpdated::class,
333			PlaceDeleted::class,
334			];
335
336			foreach ($refactoredPlaceEvents as $refactoredPlaceEvent) {
337			$payloadManipulatingSerializer->manipulateEventsOfClass(
338			$refactoredPlaceEvent,
339			function (array $serializedObject) {
340			$serializedObject = self::replacePlaceIdWithItemId($serializedObject);
341			return $serializedObject;
342			}
343			);
344			}
345
346			/**
347			* PriceInfoUpdated events
348			*/
349			$priceInfoEvents = [
350			EventPriceInfoUpdated::class,
351			PlacePriceInfoUpdated::class,
352			];
353
354			foreach ($priceInfoEvents as $priceInfoEvent) {
355			$payloadManipulatingSerializer->manipulateEventsOfClass(
356			$priceInfoEvent,
357			function (array $serializedObject) {
358			$payload = &$serializedObject['payload'];
359			$priceInfo = &$payload['price_info'];
360			$tariffs = array_map(
361			function (array $tariff) {
362			$name = $tariff['name'];
363			if (is_string($name)) {
364			$name = ['nl' => $name];
365			}
366			$tariff['name'] = $name;
367			return $tariff;
368			},
369			isset($priceInfo['tariffs']) ? $priceInfo['tariffs'] : []
370			);
371			$priceInfo['tariffs'] = $tariffs;
372			return $serializedObject;
373			}
374			);
375			}
376
377			return $payloadManipulatingSerializer;
378			}
379
380			/**
381			* @param array $serializedObject
382			* @return array
383			*/
384			private static function replaceEventIdWithItemId(array $serializedObject)
385			{
386			return self::replaceKeys('event_id', 'item_id', $serializedObject);
387			}
388
389			/**
390			* @param array $serializedObject
391			* @return array
392			*/
393			private static function replacePlaceIdWithItemId(array $serializedObject)
394			{
395			return self::replaceKeys('place_id', 'item_id', $serializedObject);
396			}
397
398			/**
399			* @param string $oldKey
400			* @param string $newKey
401			* @param array $serializedObject
402			* @return array
403			*/
404			private static function replaceKeys($oldKey, $newKey, $serializedObject)
405			{
406			if (isset($serializedObject['payload'][$oldKey])) {
407			$value = $serializedObject['payload'][$oldKey];
408			$serializedObject['payload'][$newKey] = $value;
409			unset($serializedObject['payload'][$oldKey]);
410			}
411
412			return $serializedObject;
413			}
414
415			/**
416			* @param array $serializedObject
417			* @return array
418			*/
419			private static function replaceKeywordWithLabel(array $serializedObject)
420			{
421			$keyword = $serializedObject['payload']['keyword'];
422			$serializedObject['payload']['label'] = $keyword;
423			unset($serializedObject['payload']['keyword']);
424
425			return $serializedObject;
426			}
427
428			/**
429			* @param array $serializedObject
430			* @param ReadRepositoryInterface $labelRepository
431			* @return array
432			*/
433			private static function addLabelName(
434			array $serializedObject,
435			ReadRepositoryInterface $labelRepository
436			) {
437			if (!isset($serializedObject['payload']['name'])) {
438			$uuid = $serializedObject['payload']['uuid'];
439			$label = $labelRepository->getByUuid(new UUID($uuid));
440
441			$serializedObject['payload']['name'] = $label->getName()->toNative();
442			}
443
444			return $serializedObject;
445			}
446
447			/**
448			* @param array $serializedObject
449			* @param ReadRepositoryInterface $labelRepository
450			* @return array
451			*/
452			private static function fixOrganizerLabelEvent(
453			array $serializedObject,
454			ReadRepositoryInterface $labelRepository
455			) {
456			if (!isset($serializedObject['payload']['label']) \|\|
457			!isset($serializedObject['payload']['visibility'])) {
458			$uuid = $serializedObject['payload']['labelId'];
459			$label = $labelRepository->getByUuid(new UUID($uuid));
460
461			$serializedObject['payload']['label'] = $label->getName()->toNative();
462			$serializedObject['payload']['visibility'] = $label->getVisibility() === Visibility::VISIBLE();
463			}
464
465			return $serializedObject;
466			}
467
468			/**
469			* @param array $serializedObject
470			* @return array
471			*/
472			private static function addDefaultMainLanguage(array $serializedObject)
473			{
474			if (!isset($serializedObject['payload']['main_language'])) {
475			$mainLanguage = new Language('nl');
476			$serializedObject['payload']['main_language'] = $mainLanguage->getCode();
477			}
478
479			return $serializedObject;
480			}
481			}
482

cultuurnet / udb3-php

Push — master ( 1563bb...25b79c )

__construct() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like