CultuurNet\UDB3\Offer\Offer

Complexity

Total Complexity

137

Size/Duplication

Total Lines	1171
Duplicated Lines	3.93 %

Coupling/Cohesion

Components	1
Dependencies	47

Importance

Changes

0

101 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	12	1
A	updateType()	0	6	3
A	updateTheme()	0	6	3
A	updateFacilities()	0	6	3
A	applyFacilitiesUpdated()	0	4	1
A	sameFacilities()	0	16	2
A	getMainImageId()	0	5	2
A	addLabel()	0	8	2
A	removeLabel()	0	8	2
C	importLabels()	8	61	10
A	updateTitle()	0	12	3
A	applyTitleTranslated()	0	4	1
A	applyTitleUpdated()	0	4	1
A	updateDescription()	0	12	3
A	updateCalendar()	0	8	3
A	applyCalendarUpdated()	0	4	1
A	updateTypicalAgeRange()	0	8	3
A	applyTypicalAgeRangeUpdated()	0	4	1
A	deleteTypicalAgeRange()	0	8	2
A	applyTypicalAgeRangeDeleted()	0	4	1
A	updateOrganizer()	0	8	2
A	deleteOrganizer()	0	8	2
A	deleteCurrentOrganizer()	0	8	2
A	updateContactPoint()	0	8	3
A	applyContactPointUpdated()	0	4	1
A	updateGeoCoordinates()	0	10	1
A	updateBookingInfo()	0	8	3
A	applyBookingInfoUpdated()	0	4	1
A	updatePriceInfo()	0	8	3
A	applyPriceInfoUpdated()	0	4	1
A	applyLabelAdded()	0	4	1
A	applyLabelRemoved()	0	4	1
A	applyThemeUpdated()	0	4	1
A	applyTypeUpdated()	0	4	1
A	applyDescriptionUpdated()	0	5	1
A	applyDescriptionTranslated()	0	5	1
A	addImage()	0	11	2
A	updateImage()	0	15	2
A	updateImageAllowed()	0	16	3
A	removeImage()	0	12	2
A	selectMainImage()	0	14	4
B	importImages()	0	45	5
A	delete()	0	6	1
A	importWorkflowStatus()	0	9	2
A	publish()	0	6	2
A	guardPublish()	12	12	3
A	approve()	0	4	2
A	guardApprove()	12	12	3
A	reject()	0	4	2
A	flagAsDuplicate()	0	5	2
A	flagAsInappropriate()	0	5	2
A	guardRejection()	0	16	5
A	isTitleChanged()	7	7	2
A	isDescriptionChanged()	7	7	2
A	importImagesFromUDB2()	0	4	1
A	updateImagesFromUDB2()	0	4	1
A	applyPublished()	0	4	1
A	applyApproved()	0	4	1
A	applyRejected()	0	5	1
A	applyFlaggedAsDuplicate()	0	5	1
A	applyFlaggedAsInappropriate()	0	5	1
A	applyImageAdded()	0	4	1
A	applyImageUpdated()	0	17	1
A	applyImageRemoved()	0	7	2
A	applyMainImageSelected()	0	4	1
A	applyOrganizerUpdated()	0	4	1
A	applyOrganizerDeleted()	0	4	1
A	applyImagesImportedFromUDB2()	0	4	1
A	applyImagesUpdatedFromUDB2()	0	4	1
A	applyUdb2ImagesEvent()	0	16	2
	createLabelAddedEvent()	0	1	?
	createLabelRemovedEvent()	0	1	?
	createLabelsImportedEvent()	0	1	?
	createTitleTranslatedEvent()	0	1	?
	createDescriptionTranslatedEvent()	0	1	?
	createImageAddedEvent()	0	1	?
	createImageRemovedEvent()	0	1	?
	createImageUpdatedEvent()	0	5	?
	createMainImageSelectedEvent()	0	1	?
	createOfferDeletedEvent()	0	1	?
	createTitleUpdatedEvent()	0	1	?
	createDescriptionUpdatedEvent()	0	1	?
	createCalendarUpdatedEvent()	0	1	?
	createTypicalAgeRangeUpdatedEvent()	0	1	?
	createTypicalAgeRangeDeletedEvent()	0	1	?
	createOrganizerUpdatedEvent()	0	1	?
	createOrganizerDeletedEvent()	0	1	?
	createContactPointUpdatedEvent()	0	1	?
	createGeoCoordinatesUpdatedEvent()	0	1	?
	createBookingInfoUpdatedEvent()	0	1	?
	createPriceInfoUpdatedEvent()	0	1	?
	createPublishedEvent()	0	1	?
	createApprovedEvent()	0	1	?
	createRejectedEvent()	0	1	?
	createFlaggedAsDuplicate()	0	1	?
	createFlaggedAsInappropriate()	0	1	?
	createImagesImportedFromUDB2()	0	1	?
	createImagesUpdatedFromUDB2()	0	1	?
	createTypeUpdatedEvent()	0	1	?
	createThemeUpdatedEvent()	0	1	?
	createFacilitiesUpdatedEvent()	0	1	?

<?php

namespace CultuurNet\UDB3\Offer;

use Broadway\EventSourcing\EventSourcedAggregateRoot;
use CultureFeed_Cdb_Item_Base;
use CultuurNet\Geocoding\Coordinate\Coordinates;
use CultuurNet\UDB3\BookingInfo;
use CultuurNet\UDB3\Calendar;
use CultuurNet\UDB3\ContactPoint;
use CultuurNet\UDB3\Description;
use CultuurNet\UDB3\Event\EventType;
use CultuurNet\UDB3\Facility;
use CultuurNet\UDB3\Label;
use CultuurNet\UDB3\LabelAwareAggregateRoot;
use CultuurNet\UDB3\LabelCollection;
use CultuurNet\UDB3\Media\Image;
use CultuurNet\UDB3\Media\ImageCollection;
use CultuurNet\UDB3\Media\Properties\CopyrightHolder;
use \CultuurNet\UDB3\Media\Properties\Description as ImageDescription;
use CultuurNet\UDB3\Model\ValueObject\Taxonomy\Label\LabelName;
use CultuurNet\UDB3\Model\ValueObject\Taxonomy\Label\Labels;
use CultuurNet\UDB3\Language;
use CultuurNet\UDB3\Offer\Events\AbstractBookingInfoUpdated;
use CultuurNet\UDB3\Offer\Events\AbstractCalendarUpdated;
use CultuurNet\UDB3\Offer\Events\AbstractContactPointUpdated;
use CultuurNet\UDB3\Offer\Events\AbstractFacilitiesUpdated;
use CultuurNet\UDB3\Offer\Events\AbstractGeoCoordinatesUpdated;
use CultuurNet\UDB3\Offer\Events\AbstractLabelsImported;
use CultuurNet\UDB3\Offer\Events\AbstractThemeUpdated;
use CultuurNet\UDB3\Offer\Events\AbstractTitleTranslated;
use CultuurNet\UDB3\Offer\Events\AbstractTitleUpdated;
use CultuurNet\UDB3\Offer\Events\AbstractDescriptionTranslated;
use CultuurNet\UDB3\Offer\Events\AbstractDescriptionUpdated;
use CultuurNet\UDB3\Offer\Events\AbstractLabelAdded;
use CultuurNet\UDB3\Offer\Events\AbstractLabelRemoved;
use CultuurNet\UDB3\Offer\Events\AbstractOfferDeleted;
use CultuurNet\UDB3\Offer\Events\AbstractOrganizerDeleted;
use CultuurNet\UDB3\Offer\Events\AbstractOrganizerUpdated;
use CultuurNet\UDB3\Offer\Events\AbstractPriceInfoUpdated;
use CultuurNet\UDB3\Offer\Events\AbstractTypeUpdated;
use CultuurNet\UDB3\Offer\Events\AbstractTypicalAgeRangeDeleted;
use CultuurNet\UDB3\Offer\Events\AbstractTypicalAgeRangeUpdated;
use CultuurNet\UDB3\Offer\Events\Image\AbstractImageAdded;
use CultuurNet\UDB3\Offer\Events\Image\AbstractImageRemoved;
use CultuurNet\UDB3\Offer\Events\Image\AbstractImagesEvent;
use CultuurNet\UDB3\Offer\Events\Image\AbstractImagesImportedFromUDB2;
use CultuurNet\UDB3\Offer\Events\Image\AbstractImagesUpdatedFromUDB2;
use CultuurNet\UDB3\Offer\Events\Image\AbstractImageUpdated;
use CultuurNet\UDB3\Offer\Events\Image\AbstractMainImageSelected;
use CultuurNet\UDB3\Offer\Events\Moderation\AbstractApproved;
use CultuurNet\UDB3\Offer\Events\Moderation\AbstractFlaggedAsDuplicate;
use CultuurNet\UDB3\Offer\Events\Moderation\AbstractFlaggedAsInappropriate;
use CultuurNet\UDB3\Offer\Events\Moderation\AbstractPublished;
use CultuurNet\UDB3\Offer\Events\Moderation\AbstractRejected;
use CultuurNet\UDB3\PriceInfo\PriceInfo;
use CultuurNet\UDB3\Theme;
use CultuurNet\UDB3\Title;
use Exception;
use TwoDotsTwice\Collection\Exception\CollectionItemNotFoundException;
use ValueObjects\Identity\UUID;
use ValueObjects\StringLiteral\StringLiteral;

abstract class Offer extends EventSourcedAggregateRoot implements LabelAwareAggregateRoot
{
    const DUPLICATE_REASON = 'duplicate';
    const INAPPROPRIATE_REASON = 'inappropriate';

    /**
     * @var LabelCollection
     */
    protected $labels;

    /**
     * @var ImageCollection
     */
    protected $images;

    /**
     * @var string
     *
     * Organizer ids can come from UDB2 which does not strictly use UUIDs.
     */
    protected $organizerId;

    /**
     * @var WorkflowStatus
     */
    protected $workflowStatus;

    /**
     * @var StringLiteral|null
     */
    protected $rejectedReason;

    /**
     * @var PriceInfo
     */
    protected $priceInfo;

    /**
     * @var StringLiteral[]
     */
    protected $titles;

    /**
     * @var Description[]
     */
    protected $descriptions;

    /**
     * @var Language
     */
    protected $mainLanguage;

    /**
     * @var string;
     */
    protected $typeId;

    /**
     * @var string;
     */
    protected $themeId;

    /**
     * @var array
     */
    protected $facilities;

    /**
     * @var ContactPoint
     */
    protected $contactPoint;

    /**
     * @var Calendar
     */
    protected $calendar;

    /**
     * @var AgeRange
     */
    protected $typicalAgeRange;

    /**
     * @var BookingInfo
     */
    protected $bookingInfo;

    /**
     * @var bool
     */
    protected $isDeleted = false;

    /**
     * Offer constructor.
     */
    public function __construct()
    {
        $this->titles = [];
        $this->descriptions = [];
        $this->labels = new LabelCollection();
        $this->images = new ImageCollection();
        $this->facilities = [];
        $this->contactPoint = null;
        $this->calendar = null;
        $this->typicalAgeRange = null;
        $this->bookingInfo = null;
    }

    /**
     * @param EventType $type
     */
    public function updateType(EventType $type)
    {
        if (!$this->typeId || $this->typeId !== $type->getId()) {
            $this->apply($this->createTypeUpdatedEvent($type));
        }
    }

    /**
     * @param Theme $theme
     */
    public function updateTheme(Theme $theme)
    {
        if (!$this->themeId || $this->themeId !== $theme->getId()) {
            $this->apply($this->createThemeUpdatedEvent($theme));
        }
    }

    /**
     * @param array $facilities
     */
    public function updateFacilities(array $facilities)
    {
        if (empty($this->facilities) || !$this->sameFacilities($this->facilities, $facilities)) {
            $this->apply($this->createFacilitiesUpdatedEvent($facilities));
        }
    }

    /**
     * @param AbstractFacilitiesUpdated $facilitiesUpdated
     */
    protected function applyFacilitiesUpdated(AbstractFacilitiesUpdated $facilitiesUpdated)
    {
        $this->facilities = $facilitiesUpdated->getFacilities();
    }

    /**
     * @param array $facilities1
     * @param array $facilities2
     * @return bool
     */
    private function sameFacilities($facilities1, $facilities2)
    {
        if (count($facilities1) !== count($facilities2)) {
            return false;
        }

        $sameFacilities = array_uintersect(
            $facilities1,
            $facilities2,
            function (Facility $facility1, Facility $facility2) {
                return strcmp($facility1->getId(), $facility2->getId());
            }
        );

        return count($sameFacilities) === count($facilities2);
    }

    /**
     * Get the id of the main image if one is selected for this offer.
     *
     * @return UUID|null
     */
    protected function getMainImageId()
    {
        $mainImage = $this->images->getMain();
        return isset($mainImage) ? $mainImage->getMediaObjectId() : null;
    }

    /**
     * @inheritdoc
     */
    public function addLabel(Label $label)
    {
        if (!$this->labels->contains($label)) {
            $this->apply(
                $this->createLabelAddedEvent($label)
            );
        }
    }

    /**
     * @inheritdoc
     */
    public function removeLabel(Label $label)
    {
        if ($this->labels->contains($label)) {
            $this->apply(
                $this->createLabelRemovedEvent($label)
            );
        }
    }

    /**
     * @param Labels $labels
     * @param Labels $labelsToKeepIfAlreadyOnOffer
     */
    public function importLabels(Labels $labels, Labels $labelsToKeepIfAlreadyOnOffer, Labels $labelsToRemoveWhenOnOffer)
    {
        $convertLabelClass = function (\CultuurNet\UDB3\Model\ValueObject\Taxonomy\Label\Label $label) {
            return new Label(
                $label->getName()->toString(),
                $label->isVisible()
            );
        };

        // Convert the imported labels to label collection.
        $importLabelsCollection = new LabelCollection(
            array_map($convertLabelClass, $labels->toArray())
        );

        // Convert the labels to keep if already applied.
        $keepLabelsCollection = new LabelCollection(
            array_map($convertLabelClass, $labelsToKeepIfAlreadyOnOffer->toArray())
        );

        // Convert the labels to remove when on offer.
        $removeLabelsCollection = new LabelCollection(
            array_map($convertLabelClass, $labelsToRemoveWhenOnOffer->toArray())
        );

        // What are the added labels?
        // Labels which are not inside the internal state but inside the imported labels
        $addedLabels = new LabelCollection();
        foreach ($importLabelsCollection->asArray() as $label) {
            if (!$this->labels->contains($label)) {
                $addedLabels = $addedLabels->with($label);
            }
        }

        // Fire a LabelsImported for all new labels.
        $importLabels = new Labels();
        foreach ($addedLabels->asArray() as $addedLabel) {

This code seems to be duplicated across your project.

            $importLabels = $importLabels->with(
                new \CultuurNet\UDB3\Model\ValueObject\Taxonomy\Label\Label(
                    new LabelName((string) $addedLabel),
                    $addedLabel->isVisible()
                )
            );
        }
        if ($importLabels->count() > 0) {
            $this->apply($this->createLabelsImportedEvent($importLabels));
        }

        // For each added label fire a LabelAdded event.
        foreach ($addedLabels->asArray() as $label) {
            $this->apply($this->createLabelAddedEvent($label));
        }

        // What are the deleted labels?
        // Labels which are inside the internal state but not inside imported labels or labels to keep.
        // For each deleted label fire a LabelDeleted event.
        foreach ($this->labels->asArray() as $label) {
            if (!$importLabelsCollection->contains($label) && !$keepLabelsCollection->contains($label) && $removeLabelsCollection->contains($label)) {
                $this->apply($this->createLabelRemovedEvent($label));
            }
        }
    }

    /**
     * @param Language $language
     * @param Title $title
     */
    public function updateTitle(Language $language, Title $title)
    {
        if ($this->isTitleChanged($title, $language)) {
            if ($language->getCode() !== $this->mainLanguage->getCode()) {
                $event = $this->createTitleTranslatedEvent($language, $title);
            } else {
                $event = $this->createTitleUpdatedEvent($title);
            }

            $this->apply($event);
        }
    }

    /**
     * @param AbstractTitleTranslated $titleTranslated
     */
    public function applyTitleTranslated(AbstractTitleTranslated $titleTranslated)
    {
        $this->titles[$titleTranslated->getLanguage()->getCode()] = $titleTranslated->getTitle();
    }


    /**
     * @param AbstractTitleUpdated $titleUpdated
     */
    public function applyTitleUpdated(AbstractTitleUpdated $titleUpdated)
    {
        $this->titles[$this->mainLanguage->getCode()] = $titleUpdated->getTitle();
    }

    /**
     * @param Description $description
     * @param Language $language
     */
    public function updateDescription(Description $description, Language $language)
    {
        if ($this->isDescriptionChanged($description, $language)) {
            if ($language->getCode() !== $this->mainLanguage->getCode()) {
                $event = $this->createDescriptionTranslatedEvent($language, $description);
            } else {
                $event = $this->createDescriptionUpdatedEvent($description);
            }

            $this->apply($event);
        }
    }

    /**
     * @param Calendar $calendar
     */
    public function updateCalendar(Calendar $calendar)
    {
        if (is_null($this->calendar) || !$this->calendar->sameAs($calendar)) {
            $this->apply(
                $this->createCalendarUpdatedEvent($calendar)
            );
        }
    }

    /**
     * @param AbstractCalendarUpdated $calendarUpdated
     */
    protected function applyCalendarUpdated(AbstractCalendarUpdated $calendarUpdated)
    {
        $this->calendar = $calendarUpdated->getCalendar();
    }

    /**
     * @param AgeRange $typicalAgeRange
     */
    public function updateTypicalAgeRange(AgeRange $typicalAgeRange)
    {
        $typicalAgeRangeUpdatedEvent = $this->createTypicalAgeRangeUpdatedEvent($typicalAgeRange);

        if (empty($this->typicalAgeRange) || !$this->typicalAgeRange->sameAs($typicalAgeRangeUpdatedEvent->getTypicalAgeRange())) {
            $this->apply($typicalAgeRangeUpdatedEvent);
        }
    }

    /**
     * @param AbstractTypicalAgeRangeUpdated $typicalAgeRangeUpdated
     */
    protected function applyTypicalAgeRangeUpdated(AbstractTypicalAgeRangeUpdated $typicalAgeRangeUpdated)
    {
        $this->typicalAgeRange = $typicalAgeRangeUpdated->getTypicalAgeRange();
    }

    public function deleteTypicalAgeRange()
    {
        if (!is_null($this->typicalAgeRange)) {
            $this->apply(
                $this->createTypicalAgeRangeDeletedEvent()
            );
        }
    }

    /**
     * @param AbstractTypicalAgeRangeDeleted $typicalAgeRangeDeleted
     */
    public function applyTypicalAgeRangeDeleted(AbstractTypicalAgeRangeDeleted $typicalAgeRangeDeleted)

The parameter $typicalAgeRangeDeleted is not used and could be removed.

    {
        $this->typicalAgeRange = null;
    }

    /**
     * @param string $organizerId
     */
    public function updateOrganizer($organizerId)
    {
        if ($this->organizerId !== $organizerId) {
            $this->apply(
                $this->createOrganizerUpdatedEvent($organizerId)
            );
        }
    }

    /**
     * Delete the given organizer.
     *
     * @param string $organizerId
     */
    public function deleteOrganizer($organizerId)
    {
        if ($this->organizerId === $organizerId) {
            $this->apply(
                $this->createOrganizerDeletedEvent($organizerId)
            );
        }
    }

    /**
     * Delete the current organizer regardless of the id.
     */
    public function deleteCurrentOrganizer()
    {
        if (!is_null($this->organizerId)) {
            $this->apply(
                $this->createOrganizerDeletedEvent($this->organizerId)
            );
        }
    }

    /**
     * Updated the contact info.
     * @param ContactPoint $contactPoint
     */
    public function updateContactPoint(ContactPoint $contactPoint)
    {
        if (is_null($this->contactPoint) || !$this->contactPoint->sameAs($contactPoint)) {
            $this->apply(
                $this->createContactPointUpdatedEvent($contactPoint)
            );
        }
    }

    /**
     * @param AbstractContactPointUpdated $contactPointUpdated
     */
    protected function applyContactPointUpdated(AbstractContactPointUpdated $contactPointUpdated)
    {
        $this->contactPoint = $contactPointUpdated->getContactPoint();
    }

    /**
     * @param Coordinates $coordinates
     */
    public function updateGeoCoordinates(Coordinates $coordinates)
    {
        // Note: DON'T compare to previous coordinates and apply only on
        // changes. Various projectors expect GeoCoordinatesUpdated after
        // MajorInfoUpdated and PlaceUpdatedFromUDB2, even if the address
        // and thus the coordinates haven't actually changed.
        $this->apply(
            $this->createGeoCoordinatesUpdatedEvent($coordinates)
        );
    }

    /**
     * Updated the booking info.
     *
     * @param BookingInfo $bookingInfo
     */
    public function updateBookingInfo(BookingInfo $bookingInfo)
    {
        if (is_null($this->bookingInfo) || !$this->bookingInfo->sameAs($bookingInfo)) {
            $this->apply(
                $this->createBookingInfoUpdatedEvent($bookingInfo)
            );
        }
    }

    /**
     * @param AbstractBookingInfoUpdated $bookingInfoUpdated
     */
    public function applyBookingInfoUpdated(AbstractBookingInfoUpdated $bookingInfoUpdated)
    {
        $this->bookingInfo = $bookingInfoUpdated->getBookingInfo();
    }

    /**
     * @param PriceInfo $priceInfo
     */
    public function updatePriceInfo(PriceInfo $priceInfo)
    {
        if (is_null($this->priceInfo) || $priceInfo->serialize() !== $this->priceInfo->serialize()) {
            $this->apply(
                $this->createPriceInfoUpdatedEvent($priceInfo)
            );
        }
    }

    /**
     * @param AbstractPriceInfoUpdated $priceInfoUpdated
     */
    protected function applyPriceInfoUpdated(AbstractPriceInfoUpdated $priceInfoUpdated)
    {
        $this->priceInfo = $priceInfoUpdated->getPriceInfo();
    }

    /**
     * @param AbstractLabelAdded $labelAdded
     */
    protected function applyLabelAdded(AbstractLabelAdded $labelAdded)
    {
        $this->labels = $this->labels->with($labelAdded->getLabel());
    }

    /**
     * @param AbstractLabelRemoved $labelRemoved
     */
    protected function applyLabelRemoved(AbstractLabelRemoved $labelRemoved)
    {
        $this->labels = $this->labels->without($labelRemoved->getLabel());
    }

    /**
     * @param AbstractThemeUpdated $themeUpdated
     */
    protected function applyThemeUpdated(AbstractThemeUpdated $themeUpdated)
    {
        $this->themeId = $themeUpdated->getTheme()->getId();
    }

    /**
     * @param AbstractTypeUpdated $themeUpdated
     */
    protected function applyTypeUpdated(AbstractTypeUpdated $themeUpdated)
    {
        $this->typeId = $themeUpdated->getType()->getId();
    }

    protected function applyDescriptionUpdated(AbstractDescriptionUpdated $descriptionUpdated)
    {
        $mainLanguageCode = $this->mainLanguage->getCode();
        $this->descriptions[$mainLanguageCode] = $descriptionUpdated->getDescription();
    }

    protected function applyDescriptionTranslated(AbstractDescriptionTranslated $descriptionTranslated)
    {
        $languageCode = $descriptionTranslated->getLanguage()->getCode();
        $this->descriptions[$languageCode] = $descriptionTranslated->getDescription();
    }

    /**
     * Add a new image.
     *
     * @param Image $image
     */
    public function addImage(Image $image)
    {
        // Find the image based on UUID inside the internal state.
        $existingImage = $this->images->findImageByUUID($image->getMediaObjectId());

        if ($existingImage === null) {
            $this->apply(
                $this->createImageAddedEvent($image)
            );
        }
    }

    /**
     * @param UUID $mediaObjectId
     * @param StringLiteral $description
     * @param StringLiteral $copyrightHolder
     */
    public function updateImage(
        UUID $mediaObjectId,
        StringLiteral $description,
        StringLiteral $copyrightHolder
    ) {
        if ($this->updateImageAllowed($mediaObjectId, $description, $copyrightHolder)) {
            $this->apply(
                $this->createImageUpdatedEvent(
                    $mediaObjectId,
                    $description,
                    $copyrightHolder
                )
            );
        }
    }

    /**
     * @param UUID $mediaObjectId
     * @param StringLiteral $description
     * @param StringLiteral $copyrightHolder
     * @return bool
     */
    private function updateImageAllowed(
        UUID $mediaObjectId,
        StringLiteral $description,
        StringLiteral $copyrightHolder
    ) {
        $image = $this->images->findImageByUUID($mediaObjectId);

        // Don't update if the image is not found based on UUID.
        if (!$image) {
            return false;
        }

        // Update when copyright or description is changed.
        return !$copyrightHolder->sameValueAs($image->getCopyrightHolder()) ||
            !$description->sameValueAs($image->getDescription());
    }

    /**
     * Remove an image.
     *
     * @param Image $image
     */
    public function removeImage(Image $image)
    {
        // Find the image based on UUID inside the internal state.
        // Use the image from the internal state.
        $existingImage = $this->images->findImageByUUID($image->getMediaObjectId());

        if ($existingImage) {
            $this->apply(
                $this->createImageRemovedEvent($existingImage)
            );
        }
    }

    /**
     * Make an existing image of the item the main image.
     *
     * @param Image $image
     */
    public function selectMainImage(Image $image)
    {
        if (!$this->images->findImageByUUID($image->getMediaObjectId())) {
            throw new \InvalidArgumentException('You can not select a random image to be main, it has to be added to the item.');
        }

        $oldMainImage = $this->images->getMain();

        if (!isset($oldMainImage) || $oldMainImage->getMediaObjectId() !== $image->getMediaObjectId()) {
            $this->apply(
                $this->createMainImageSelectedEvent($image)
            );
        }
    }

    /**
     * @param ImageCollection $imageCollection
     */
    public function importImages(ImageCollection $imageCollection)
    {
        $currentImageCollection = $this->images;
        $newMainImage = $imageCollection->getMain();

        $importImages = $imageCollection->toArray();
        $currentImages = $currentImageCollection->toArray();

        $compareImages = function (Image $a, Image $b) {
            $idA = $a->getMediaObjectId()->toNative();
            $idB = $b->getMediaObjectId()->toNative();
            return strcmp($idA, $idB);
        };

        /* @var Image[] $addedImages */
        $addedImages = array_udiff($importImages, $currentImages, $compareImages);

        /* @var Image[] $updatedImages */
        $updatedImages = array_uintersect($importImages, $currentImages, $compareImages);

        /* @var Image[] $removedImages */
        $removedImages = array_udiff($currentImages, $importImages, $compareImages);

        foreach ($addedImages as $addedImage) {
            $this->apply($this->createImageAddedEvent($addedImage));
        }

        foreach ($updatedImages as $updatedImage) {
            $this->apply(
                $this->createImageUpdatedEvent(
                    $updatedImage->getMediaObjectId(),
                    $updatedImage->getDescription(),
                    $updatedImage->getCopyrightHolder()
                )
            );
        }

        foreach ($removedImages as $removedImage) {
            $this->apply($this->createImageRemovedEvent($removedImage));
        }

        if ($newMainImage) {
            $this->apply($this->createMainImageSelectedEvent($newMainImage));
        }
    }

    /**
     * Delete the offer.
     */
    public function delete()
    {
        $this->apply(
            $this->createOfferDeletedEvent()
        );
    }

    /**
     * @param CultureFeed_Cdb_Item_Base $cdbItem
     */
    protected function importWorkflowStatus(CultureFeed_Cdb_Item_Base $cdbItem)
    {
        try {
            $workflowStatus = WorkflowStatus::fromNative($cdbItem->getWfStatus());
        } catch (\InvalidArgumentException $exception) {
            $workflowStatus = WorkflowStatus::READY_FOR_VALIDATION();
        }
        $this->workflowStatus = $workflowStatus;
    }

    /**
     * Publish the offer when it has workflowstatus draft.
     * @param \DateTimeInterface $publicationDate
     */
    public function publish(\DateTimeInterface $publicationDate)
    {
        $this->guardPublish() ?: $this->apply(
            $this->createPublishedEvent($publicationDate)
        );
    }

    /**
     * @return bool
     * @throws Exception
     */
    private function guardPublish()

This method seems to be duplicated in your project.

    {
        if ($this->workflowStatus === WorkflowStatus::READY_FOR_VALIDATION()) {
            return true; // nothing left to do if the offer has already been published
        }

        if ($this->workflowStatus !== WorkflowStatus::DRAFT()) {
            throw new Exception('You can not publish an offer that is not draft');
        }

        return false;
    }

    /**
     * Approve the offer when it's waiting for validation.
     */
    public function approve()
    {
        $this->guardApprove() ?: $this->apply($this->createApprovedEvent());
    }

    /**
     * @return bool
     * @throws Exception
     */
    private function guardApprove()

This method seems to be duplicated in your project.

    {
        if ($this->workflowStatus === WorkflowStatus::APPROVED()) {
            return true; // nothing left to do if the offer has already been approved
        }

        if ($this->workflowStatus !== WorkflowStatus::READY_FOR_VALIDATION()) {
            throw new Exception('You can not approve an offer that is not ready for validation');
        }

        return false;
    }

    /**
     * Reject an offer that is waiting for validation with a given reason.
     * @param StringLiteral $reason
     */
    public function reject(StringLiteral $reason)
    {
        $this->guardRejection($reason) ?: $this->apply($this->createRejectedEvent($reason));
    }

    public function flagAsDuplicate()
    {
        $reason = new StringLiteral(self::DUPLICATE_REASON);
        $this->guardRejection($reason) ?: $this->apply($this->createFlaggedAsDuplicate());
    }

    public function flagAsInappropriate()
    {
        $reason = new StringLiteral(self::INAPPROPRIATE_REASON);
        $this->guardRejection($reason) ?: $this->apply($this->createFlaggedAsInappropriate());
    }

    /**
     * @param StringLiteral $reason
     * @return bool
     *  false when the offer can still be rejected, true when the offer is already rejected for the same reason
     * @throws Exception
     */
    private function guardRejection(StringLiteral $reason)
    {
        if ($this->workflowStatus === WorkflowStatus::REJECTED()) {
            if ($this->rejectedReason && $reason->sameValueAs($this->rejectedReason)) {
                return true; // nothing left to do if the offer has already been rejected for the same reason
            } else {
                throw new Exception('The offer has already been rejected for another reason: ' . $this->rejectedReason);
            }
        }

        if ($this->workflowStatus !== WorkflowStatus::READY_FOR_VALIDATION()) {
            throw new Exception('You can not reject an offer that is not ready for validation');
        }

        return false;
    }

    /**
     * @param Title $title
     * @param Language $language
     * @return bool
     */
    private function isTitleChanged(Title $title, Language $language)

This method seems to be duplicated in your project.

    {
        $languageCode = $language->getCode();

        return !isset($this->titles[$languageCode]) ||
            !$title->sameValueAs($this->titles[$languageCode]);
    }

    /**
     * @param Description $description
     * @param Language $language
     * @return bool
     */
    private function isDescriptionChanged(Description $description, Language $language)

This method seems to be duplicated in your project.

    {
        $languageCode = $language->getCode();

        return !isset($this->descriptions[$languageCode]) ||
            !$description->sameValueAs($this->descriptions[$languageCode]);
    }

    /**
     * Overwrites or resets the main image and all media objects
     * by importing a new collection of images from UDB2.
     *
     * @param ImageCollection $images
     */
    public function importImagesFromUDB2(ImageCollection $images)
    {
        $this->apply($this->createImagesImportedFromUDB2($images));
    }

    /**
     * Overwrites or resets the main image and all media objects
     * by updating with a new collection of images from UDB2.
     *
     * @param ImageCollection $images
     */
    public function updateImagesFromUDB2(ImageCollection $images)
    {
        $this->apply($this->createImagesUpdatedFromUDB2($images));
    }

    /**
     * @param AbstractPublished $published
     */
    protected function applyPublished(AbstractPublished $published)

The parameter $published is not used and could be removed.

    {
        $this->workflowStatus = WorkflowStatus::READY_FOR_VALIDATION();
    }

    /**
     * @param AbstractApproved $approved
     */
    protected function applyApproved(AbstractApproved $approved)

The parameter $approved is not used and could be removed.

    {
        $this->workflowStatus = WorkflowStatus::APPROVED();
    }

    /**
     * @param AbstractRejected $rejected
     */
    protected function applyRejected(AbstractRejected $rejected)
    {
        $this->rejectedReason = $rejected->getReason();
        $this->workflowStatus = WorkflowStatus::REJECTED();
    }

    /**
     * @param AbstractFlaggedAsDuplicate $flaggedAsDuplicate
     */
    protected function applyFlaggedAsDuplicate(AbstractFlaggedAsDuplicate $flaggedAsDuplicate)

The parameter $flaggedAsDuplicate is not used and could be removed.

    {
        $this->rejectedReason = new StringLiteral(self::DUPLICATE_REASON);
        $this->workflowStatus = WorkflowStatus::REJECTED();
    }

    /**
     * @param AbstractFlaggedAsInappropriate $flaggedAsInappropriate
     */
    protected function applyFlaggedAsInappropriate(AbstractFlaggedAsInappropriate $flaggedAsInappropriate)

The parameter $flaggedAsInappropriate is not used and could be removed.

    {
        $this->rejectedReason = new StringLiteral(self::INAPPROPRIATE_REASON);
        $this->workflowStatus = WorkflowStatus::REJECTED();
    }

    protected function applyImageAdded(AbstractImageAdded $imageAdded)
    {
        $this->images = $this->images->with($imageAdded->getImage());
    }

    protected function applyImageUpdated(AbstractImageUpdated $imageUpdated)
    {
        $image = $this->images->findImageByUUID($imageUpdated->getMediaObjectId());

        $updatedImage = new Image(
            $image->getMediaObjectId(),
            $image->getMimeType(),
            new ImageDescription($imageUpdated->getDescription()->toNative()),
            new CopyrightHolder($imageUpdated->getCopyrightHolder()->toNative()),
            $image->getSourceLocation(),
            $image->getLanguage()
        );

        // Currently no other option to update an item inside a collection.
        $this->images = $this->images->without($image);
        $this->images = $this->images->with($updatedImage);
    }

    protected function applyImageRemoved(AbstractImageRemoved $imageRemoved)
    {
        try {
            $this->images = $this->images->without($imageRemoved->getImage());
        } catch (CollectionItemNotFoundException $exception) {

Consider adding a comment why this CATCH block is empty.

        }
    }

    protected function applyMainImageSelected(AbstractMainImageSelected $mainImageSelected)
    {
        $this->images = $this->images->withMain($mainImageSelected->getImage());
    }

    protected function applyOrganizerUpdated(AbstractOrganizerUpdated $organizerUpdated)
    {
        $this->organizerId = $organizerUpdated->getOrganizerId();
    }

    protected function applyOrganizerDeleted(AbstractOrganizerDeleted $organizerDeleted)

The parameter $organizerDeleted is not used and could be removed.

    {
        $this->organizerId = null;
    }

    /**
     * @param AbstractImagesImportedFromUDB2 $imagesImportedFromUDB2
     */
    protected function applyImagesImportedFromUDB2(AbstractImagesImportedFromUDB2 $imagesImportedFromUDB2)
    {
        $this->applyUdb2ImagesEvent($imagesImportedFromUDB2);
    }

    /**
     * @param AbstractImagesUpdatedFromUDB2 $imagesUpdatedFromUDB2
     */
    protected function applyImagesUpdatedFromUDB2(AbstractImagesUpdatedFromUDB2 $imagesUpdatedFromUDB2)
    {
        $this->applyUdb2ImagesEvent($imagesUpdatedFromUDB2);
    }

    /**
     * This indirect apply method can be called internally to deal with images coming from UDB2.
     * Imports from UDB2 only contain the native Dutch content.
     * @see https://github.com/cultuurnet/udb3-udb2-bridge/blob/db0a7ab2444f55bb3faae3d59b82b39aaeba253b/test/Media/ImageCollectionFactoryTest.php#L79-L103
     * Because of this we have to make sure translated images are left in place.
     *
     * @param AbstractImagesEvent $imagesEvent
     */
    protected function applyUdb2ImagesEvent(AbstractImagesEvent $imagesEvent)
    {
        $newMainImage = $imagesEvent->getImages()->getMain();
        $dutchImagesList = $imagesEvent->getImages()->toArray();
        $translatedImagesList = array_filter(
            $this->images->toArray(),
            function (Image $image) {
                return $image->getLanguage()->getCode() !== 'nl';
            }
        );

        $imagesList = array_merge($dutchImagesList, $translatedImagesList);
        $images = ImageCollection::fromArray($imagesList);

        $this->images = isset($newMainImage) ? $images->withMain($newMainImage) : $images;
    }

    /**
     * @param Label $label
     * @return AbstractLabelAdded
     */
    abstract protected function createLabelAddedEvent(Label $label);

    /**
     * @param Label $label
     * @return AbstractLabelRemoved
     */
    abstract protected function createLabelRemovedEvent(Label $label);

    /**
     * @param Labels $labels
     * @return AbstractLabelsImported
     */
    abstract protected function createLabelsImportedEvent(Labels $labels);

    /**
     * @param Language $language
     * @param Title $title
     * @return AbstractTitleTranslated
     */
    abstract protected function createTitleTranslatedEvent(Language $language, Title $title);

    /**
     * @param Language $language
     * @param Description $description
     * @return AbstractDescriptionTranslated
     */
    abstract protected function createDescriptionTranslatedEvent(Language $language, Description $description);

    /**
     * @param Image $image
     * @return AbstractImageAdded
     */
    abstract protected function createImageAddedEvent(Image $image);

    /**
     * @param Image $image
     * @return AbstractImageRemoved
     */
    abstract protected function createImageRemovedEvent(Image $image);

    /**
     * @param UUID $uuid
     * @param StringLiteral $description
     * @param StringLiteral $copyrightHolder
     * @return AbstractImageUpdated
     */
    abstract protected function createImageUpdatedEvent(
        UUID $uuid,
        StringLiteral $description,
        StringLiteral $copyrightHolder
    );

    /**
     * @param Image $image
     * @return AbstractMainImageSelected
     */
    abstract protected function createMainImageSelectedEvent(Image $image);

    /**
     * @return AbstractOfferDeleted
     */
    abstract protected function createOfferDeletedEvent();

    /**
     * @param Title $title
     * @return AbstractTitleUpdated
     */
    abstract protected function createTitleUpdatedEvent(Title $title);

    /**
     * @param Description $description
     * @return AbstractDescriptionUpdated
     */
    abstract protected function createDescriptionUpdatedEvent(Description $description);

    /**
     * @param Calendar $calendar
     * @return AbstractCalendarUpdated
     */
    abstract protected function createCalendarUpdatedEvent(Calendar $calendar);

    /**
     * @param string $typicalAgeRange
     * @return AbstractTypicalAgeRangeUpdated
     */
    abstract protected function createTypicalAgeRangeUpdatedEvent($typicalAgeRange);

    /**
     * @return AbstractTypicalAgeRangeDeleted
     */
    abstract protected function createTypicalAgeRangeDeletedEvent();

    /**
     * @param string $organizerId
     * @return AbstractOrganizerUpdated
     */
    abstract protected function createOrganizerUpdatedEvent($organizerId);

    /**
     * @param string $organizerId
     * @return AbstractOrganizerDeleted
     */
    abstract protected function createOrganizerDeletedEvent($organizerId);

    /**
     * @param ContactPoint $contactPoint
     * @return AbstractContactPointUpdated
     */
    abstract protected function createContactPointUpdatedEvent(ContactPoint $contactPoint);

    /**
     * @param Coordinates $coordinates
     * @return AbstractGeoCoordinatesUpdated
     */
    abstract protected function createGeoCoordinatesUpdatedEvent(Coordinates $coordinates);

    /**
     * @param BookingInfo $bookingInfo
     * @return AbstractBookingInfoUpdated
     */
    abstract protected function createBookingInfoUpdatedEvent(BookingInfo $bookingInfo);

    /**
     * @param PriceInfo $priceInfo
     * @return AbstractPriceInfoUpdated
     */
    abstract protected function createPriceInfoUpdatedEvent(PriceInfo $priceInfo);

    /**
     * @param \DateTimeInterface $publicationDate
     * @return AbstractPublished
     */
    abstract protected function createPublishedEvent(\DateTimeInterface $publicationDate);

    /**
     * @return AbstractApproved
     */
    abstract protected function createApprovedEvent();

    /**
     * @param StringLiteral $reason
     * @return AbstractRejected
     */
    abstract protected function createRejectedEvent(StringLiteral $reason);

    /**
     * @return AbstractFlaggedAsDuplicate
     */
    abstract protected function createFlaggedAsDuplicate();

    /**
     * @return AbstractFlaggedAsInappropriate
     */
    abstract protected function createFlaggedAsInappropriate();

    /**
     * @param ImageCollection $images
     * @return AbstractImagesImportedFromUDB2
     */
    abstract protected function createImagesImportedFromUDB2(ImageCollection $images);

    /**
     * @param ImageCollection $images
     * @return AbstractImagesUpdatedFromUDB2
     */
    abstract protected function createImagesUpdatedFromUDB2(ImageCollection $images);

    /**
     * @param EventType $type
     * @return AbstractTypeUpdated
     */
    abstract protected function createTypeUpdatedEvent(EventType $type);

    /**
     * @param Theme $theme
     * @return AbstractThemeUpdated
     */
    abstract protected function createThemeUpdatedEvent(Theme $theme);

    /**
     * @param array $facilities
     * @return AbstractFacilitiesUpdated
     */
    abstract protected function createFacilitiesUpdatedEvent(array $facilities);
}