CultuurNet\UDB3\Label\ReadModels\AbstractProjector

Complexity

Total Complexity

10

Size/Duplication

Total Lines	81
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
B	handle()	0	23	4
	applyLabelAdded()	0	1	?
	applyLabelRemoved()	0	1	?
	applyLabelsImported()	0	1	?
A	isLabelAdded()	0	5	2
A	isLabelRemoved()	0	5	2
A	isLabelsImported()	0	5	2

<?php

namespace CultuurNet\UDB3\Label\ReadModels;

use Broadway\Domain\DomainMessage;
use Broadway\Domain\Metadata;
use Broadway\EventHandling\EventListenerInterface;
use CultuurNet\UDB3\EventHandling\DelegateEventHandlingToSpecificMethodTrait;
use CultuurNet\UDB3\LabelEventInterface;
use CultuurNet\UDB3\LabelsImportedEventInterface;
use CultuurNet\UDB3\Offer\Events\AbstractLabelAdded as OfferAbstractLabelAdded;
use CultuurNet\UDB3\Offer\Events\AbstractLabelRemoved as OfferAbstractLabelRemoved;
use CultuurNet\UDB3\Offer\Events\AbstractLabelsImported;
use CultuurNet\UDB3\Organizer\Events\LabelAdded as OrganizerLabelAdded;
use CultuurNet\UDB3\Organizer\Events\LabelRemoved as OrganizerLabelRemoved;
use CultuurNet\UDB3\Organizer\Events\LabelsImported;

abstract class AbstractProjector implements EventListenerInterface
{
    use DelegateEventHandlingToSpecificMethodTrait {
        DelegateEventHandlingToSpecificMethodTrait::handle as handleSpecific;
    }

    /**
     * @param DomainMessage $domainMessage
     */
    public function handle(DomainMessage $domainMessage)
    {
        $payload = $domainMessage->getPayload();

        if ($this->isLabelAdded($payload)) {
            $this->applyLabelAdded(
                $domainMessage->getPayload(),
                $domainMessage->getMetadata()
            );
        } elseif ($this->isLabelRemoved($payload)) {
            $this->applyLabelRemoved(
                $domainMessage->getPayload(),
                $domainMessage->getMetadata()
            );
        } elseif ($this->isLabelsImported($payload)) {
            $this->applyLabelsImported(
                $domainMessage->getPayload(),
                $domainMessage->getMetadata()
            );
        } else {
            $this->handleSpecific($domainMessage);
        }
    }

    /**
     * @param LabelEventInterface $labelAdded
     * @param Metadata $metadata
     */
    abstract public function applyLabelAdded(LabelEventInterface $labelAdded, Metadata $metadata);

    /**
     * @param LabelEventInterface $labelRemoved
     * @param Metadata $metadata
     */
    abstract public function applyLabelRemoved(LabelEventInterface $labelRemoved, Metadata $metadata);

    /**
     * @param LabelsImportedEventInterface $labelsImported
     * @param Metadata $metadata
     */
    abstract public function applyLabelsImported(LabelsImportedEventInterface $labelsImported, Metadata $metadata);

    /**
     * @param $payload
     * @return bool
     */
    private function isLabelAdded($payload)
    {
        return ($payload instanceof OfferAbstractLabelAdded ||
            $payload instanceof OrganizerLabelAdded);
    }

    /**
     * @param $payload
     * @return bool
     */
    private function isLabelRemoved($payload)
    {
        return ($payload instanceof OfferAbstractLabelRemoved ||
            $payload instanceof OrganizerLabelRemoved);
    }

    /**
     * @param $payload
     * @return bool
     */
    private function isLabelsImported($payload)
    {
        return ($payload instanceof AbstractLabelsImported ||
            $payload instanceof LabelsImported);
    }
}