CultuurNet\UDB3\Event\ReadModel\JSONLD\RelatedEventLDProjector

Complexity

Total Complexity

10

Size/Duplication

Total Lines	128
Duplicated Lines	30.47 %

Coupling/Cohesion

Components	1
Dependencies	8

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	15	1
A	applyOrganizerProjectedToJSONLD()	17	17	2
A	applyPlaceProjectedToJSONLD()	0	20	2
A	updateEmbeddedOrganizer()	0	9	1
A	updatedEmbeddedLocation()	0	9	1
A	updateJSONLD()	22	22	3

<?php

namespace CultuurNet\UDB3\Event\ReadModel\JSONLD;

use Broadway\EventHandling\EventListenerInterface;
use CultuurNet\UDB3\Event\EventServiceInterface;
use CultuurNet\UDB3\Event\ReadModel\DocumentRepositoryInterface;
use CultuurNet\UDB3\EventHandling\DelegateEventHandlingToSpecificMethodTrait;
use CultuurNet\UDB3\Offer\IriOfferIdentifierFactoryInterface;
use CultuurNet\UDB3\Organizer\OrganizerProjectedToJSONLD;
use CultuurNet\UDB3\OrganizerService;
use CultuurNet\UDB3\Place\Events\PlaceProjectedToJSONLD;
use CultuurNet\UDB3\PlaceService;
use ValueObjects\Web\Url;

class RelatedEventLDProjector implements EventListenerInterface
{
    use DelegateEventHandlingToSpecificMethodTrait;

    /**
     * @var PlaceService
     */
    protected $placeService;

    /**
     * @var OrganizerServiceInterface
     */
    protected $organizerService;

    /**
     * @var EventServiceInterface
     */
    protected $eventService;

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

    /**
     * @param DocumentRepositoryInterface $repository
     * @param EventServiceInterface $eventService
     * @param PlaceService $placeService
     * @param OrganizerService $organizerService
     */
    public function __construct(
        DocumentRepositoryInterface $repository,
        EventServiceInterface $eventService,
        PlaceService $placeService,
        OrganizerService $organizerService,
        IriOfferIdentifierFactoryInterface $iriOfferIdentifierFactory
    ) {
        $this->repository = $repository;

The property repository does not exist. Did you maybe forget to declare it?

        $this->eventService = $eventService;
        $this->placeService = $placeService;
        $this->organizerService = $organizerService;

It seems like $organizerService of type object<CultuurNet\UDB3\OrganizerService> is incompatible with the declared type object<CultuurNet\UDB3\Event\ReadModel\JSONLD\OrganizerServiceInterface> of property $organizerService.

        $this->iriOfferIdentifierFactory = $iriOfferIdentifierFactory;
    }

    protected function applyOrganizerProjectedToJSONLD(

This method seems to be duplicated in your project.

        OrganizerProjectedToJSONLD $organizerProjectedToJSONLD
    ) {
        $eventIds = $this->eventService->eventsOrganizedByOrganizer(
            $organizerProjectedToJSONLD->getId()
        );

        $organizer = $this->organizerService->getEntity(

The method getEntity() does not seem to exist on object<CultuurNet\UDB3\Event\ReadModel\JSONLD\OrganizerServiceInterface>.

            $organizerProjectedToJSONLD->getId()
        );

        $organizerJSONLD = json_decode($organizer);

        foreach ($eventIds as $eventId) {
            $this->updateEmbeddedOrganizer($eventId, $organizerJSONLD);
        }
    }

    protected function applyPlaceProjectedToJSONLD(
        PlaceProjectedToJSONLD $placeProjectedToJSONLD
    ) {
        $identifier = $this->iriOfferIdentifierFactory->fromIri(
            Url::fromNative($placeProjectedToJSONLD->getIri())
        );

        $eventsLocatedAtPlace = $this->eventService->eventsLocatedAtPlace(
            $placeProjectedToJSONLD->getItemId()
        );

        $placeJSONLDString = $this->placeService->getEntity(
            $identifier->getId()
        );
        $placeJSONLD = json_decode($placeJSONLDString);

        foreach ($eventsLocatedAtPlace as $eventId) {
            $this->updatedEmbeddedLocation($eventId, $placeJSONLD);
        }
    }

    private function updateEmbeddedOrganizer($eventId, $organizerJSONLD)
    {
        $this->updateJSONLD(
            $eventId,
            function ($eventLd) use ($organizerJSONLD) {
                $eventLd->organizer = $organizerJSONLD;
            }
        );
    }

    private function updatedEmbeddedLocation($eventId, $placeJSONLD)
    {
        $this->updateJSONLD(
            $eventId,
            function ($eventLd) use ($placeJSONLD) {
                $eventLd->location = $placeJSONLD;
            }
        );
    }

    private function updateJSONLD($eventId, $callback)

This method seems to be duplicated in your project.

    {
        $document = $this->repository->get($eventId);

        if (!$document) {
            return;
        }

        $eventLD = $document->getBody();

        $newEventLD = clone $eventLD;

        $callback($newEventLD);

        if ($newEventLD == $eventLD) {
            return;
        }

        $document = $document->withBody($newEventLD);

        $this->repository->save($document);
    }
}