CultuurNet\UDB3\ReadModel\Index\Projector

Complexity

Total Complexity

10

Size/Duplication

Total Lines	181
Duplicated Lines	18.78 %

Coupling/Cohesion

Components	1
Dependencies	16

Importance

Changes

0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	1
A	applyEventProjectedToJSONLD()	0	9	1
A	applyPlaceProjectedToJSONLD()	0	9	1
A	setItemUpdateDate()	0	13	1
A	applyEventCreated()	17	17	1
A	applyEventCopied()	0	12	1
A	applyPlaceCreated()	17	17	1
A	addNewItemToIndex()	0	19	1
A	applyEventDeleted()	0	8	1
A	applyPlaceDeleted()	0	8	1

<?php

namespace CultuurNet\UDB3\ReadModel\Index;

use Broadway\EventHandling\EventListenerInterface;
use CultuurNet\UDB3\DomainMessageAdapter as DomainMessage;
use CultuurNet\UDB3\Event\Events\EventCopied;
use CultuurNet\UDB3\Event\Events\EventCreated;
use CultuurNet\UDB3\Event\Events\EventDeleted;
use CultuurNet\UDB3\Event\Events\EventProjectedToJSONLD;
use CultuurNet\UDB3\EventHandling\DelegateEventHandlingToSpecificMethodTraitWithDomainMessageAdapter;
use CultuurNet\UDB3\Offer\Events\AbstractEventWithIri;
use CultuurNet\UDB3\Offer\IriOfferIdentifierFactoryInterface;
use CultuurNet\UDB3\Place\Events\PlaceCreated;
use CultuurNet\UDB3\Place\Events\PlaceDeleted;
use CultuurNet\UDB3\Place\Events\PlaceProjectedToJSONLD;
use ValueObjects\Web\Domain;
use ValueObjects\Web\Url;

/**
 * Logs new events / updates to an index for querying.
 */
class Projector implements EventListenerInterface
{
    use DelegateEventHandlingToSpecificMethodTraitWithDomainMessageAdapter;

    /**
     * @var RepositoryInterface
     */
    protected $repository;

    /**
     * @var Domain
     */
    protected $localDomain;

    /**
     * @var IriOfferIdentifierFactoryInterface
     */
    protected $identifierFactory;

    /**
     * @param RepositoryInterface $repository
     * @param Domain $localDomain
     * @param IriOfferIdentifierFactoryInterface $identifierFactory
     */
    public function __construct(
        RepositoryInterface $repository,
        Domain $localDomain,
        IriOfferIdentifierFactoryInterface $identifierFactory
    ) {
        $this->repository = $repository;
        $this->localDomain = $localDomain;
        $this->identifierFactory = $identifierFactory;
    }

    public function applyEventProjectedToJSONLD(
        EventProjectedToJSONLD $eventProjectedToJSONLD,
        DomainMessage $domainMessage
    ) {
        $this->setItemUpdateDate(
            $eventProjectedToJSONLD,
            $domainMessage
        );
    }

    public function applyPlaceProjectedToJSONLD(
        PlaceProjectedToJSONLD $placeProjectedToJSONLD,
        DomainMessage $domainMessage
    ) {
        $this->setItemUpdateDate(
            $placeProjectedToJSONLD,
            $domainMessage
        );
    }

    /**
     * @param AbstractEventWithIri $eventWithIri
     * @param DomainMessage $domainMessage
     */
    protected function setItemUpdateDate(
        AbstractEventWithIri $eventWithIri,
        DomainMessage $domainMessage
    ) {
        $identifier = $this->identifierFactory->fromIri(
            Url::fromNative($eventWithIri->getIri())
        );

        $this->repository->setUpdateDate(
            $identifier->getId(),
            $domainMessage->getRecordedDateTime()
        );
    }

    /**
     * Listener for event created commands.
     * @param EventCreated $eventCreated
     * @param DomainMessage $domainMessage
     */
    protected function applyEventCreated(

This method seems to be duplicated in your project.

        EventCreated $eventCreated,
        DomainMessage $domainMessage
    ) {
        $eventId = $eventCreated->getEventId();

        $location = $eventCreated->getLocation();

        $this->addNewItemToIndex(
            $domainMessage,
            $eventId,
            EntityType::EVENT(),
            $eventCreated->getTitle(),
            $location->getAddress()->getPostalCode(),
            $location->getAddress()->getCountry()->getCode()
        );
    }

    /**
     * @param EventCopied $eventCopied
     * @param DomainMessage $domainMessage
     */
    public function applyEventCopied(
        EventCopied $eventCopied,
        DomainMessage $domainMessage
    ) {
        $eventId = $eventCopied->getItemId();

        $this->addNewItemToIndex(
            $domainMessage,
            $eventId,
            EntityType::EVENT()
        );
    }

    /**
     * Listener for place created commands.
     * @param PlaceCreated $placeCreated
     * @param DomainMessage $domainMessage
     */
    protected function applyPlaceCreated(

This method seems to be duplicated in your project.

        PlaceCreated $placeCreated,
        DomainMessage $domainMessage
    ) {
        $placeId = $placeCreated->getPlaceId();

        $address = $placeCreated->getAddress();

        $this->addNewItemToIndex(
            $domainMessage,
            $placeId,
            EntityType::PLACE(),
            $placeCreated->getTitle(),
            $address->getPostalCode(),
            $address->getCountry()->getCode()
        );
    }

    private function addNewItemToIndex(
        DomainMessage $domainMessage,
        $id,
        EntityType $entityType,
        $name = '',
        $postalCode = '',
        $country = ''
    ) {
        $this->repository->updateIndex(
            $id,
            $entityType,
            $domainMessage->getUserId(),
            $name,
            $postalCode,
            $country,
            $this->localDomain,
            $domainMessage->getRecordedDateTime()
        );
    }

    /**
     * Remove the index for events
     * @param EventDeleted $eventDeleted
     */
    public function applyEventDeleted(
        EventDeleted $eventDeleted
    ) {
        $this->repository->deleteIndex(
            $eventDeleted->getItemId(),
            EntityType::EVENT()
        );
    }

    /**
     * Remove the index for places
     * @param PlaceDeleted $placeDeleted
     */
    public function applyPlaceDeleted(
        PlaceDeleted $placeDeleted
    ) {
        $this->repository->deleteIndex(
            $placeDeleted->getItemId(),
            EntityType::PLACE()
        );
    }
}