CultuurNet\UDB3\Event\EventCommandHandler

Complexity

Total Complexity

29

Size/Duplication

Total Lines	365
Duplicated Lines	4.66 %

Coupling/Cohesion

Components	1
Dependencies	26

Importance

Changes	2
Bugs	0	Features	0

20 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	handleLabelEvents()	0	6	2
A	handleTranslateTitle()	0	12	1
A	handleTranslateDescription()	0	14	1
A	handleUpdateDescription()	0	13	1
A	handleUpdateTypicalAgeRange()	0	13	1
A	handleDeleteTypicalAgeRange()	0	11	1
A	handleUpdateOrganizer()	0	13	1
A	handleDeleteOrganizer()	0	13	1
A	handleUpdateContactPoint()	0	13	1
A	handleUpdateBookingInfo()	0	13	1
A	handleAddImage()	0	13	1
A	handleUpdateImage()	0	9	1
A	handleRemoveImage()	0	9	1
A	handleUpdateMajorInfo()	17	17	1
A	handleDeleteEvent()	0	10	1
A	handleApplyLabel()	0	8	1
A	handleUnlabel()	0	8	1
B	handleLabelQuery()	0	55	6
B	labelEvent()	0	29	4

<?php


namespace CultuurNet\UDB3\Event;

use Broadway\Repository\RepositoryInterface;
use CultuurNet\UDB3\CommandHandling\Udb3CommandHandler;
use CultuurNet\UDB3\Event\Commands\AddImage;
use CultuurNet\UDB3\Event\Commands\ApplyLabel;
use CultuurNet\UDB3\Event\Commands\DeleteEvent;
use CultuurNet\UDB3\Event\Commands\RemoveImage;
use CultuurNet\UDB3\Event\Commands\DeleteOrganizer;
use CultuurNet\UDB3\Event\Commands\DeleteTypicalAgeRange;
use CultuurNet\UDB3\Event\Commands\LabelEvents;
use CultuurNet\UDB3\Event\Commands\LabelQuery;
use CultuurNet\UDB3\Event\Commands\Unlabel;
use CultuurNet\UDB3\Event\Commands\UpdateBookingInfo;
use CultuurNet\UDB3\Event\Commands\UpdateContactPoint;
use CultuurNet\UDB3\Event\Commands\UpdateDescription;
use CultuurNet\UDB3\Event\Commands\UpdateImage;
use CultuurNet\UDB3\Event\Commands\UpdateMajorInfo;
use CultuurNet\UDB3\Event\Commands\UpdateOrganizer;
use CultuurNet\UDB3\Event\Commands\UpdateTypicalAgeRange;
use CultuurNet\UDB3\Label as Label;
use CultuurNet\UDB3\Search\Results;
use CultuurNet\UDB3\Search\SearchServiceInterface;
use Guzzle\Http\Exception\ClientErrorResponseException;
use Psr\Log\LoggerAwareInterface;
use Psr\Log\LoggerAwareTrait;

/**
 * Commandhandler for events
 */
class EventCommandHandler extends Udb3CommandHandler implements LoggerAwareInterface
{
    use LoggerAwareTrait;

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

    /**
     * @var SearchServiceInterface
     */
    protected $searchService;

    public function __construct(
        RepositoryInterface $eventRepository,
        SearchServiceInterface $searchService
    ) {
        $this->eventRepository = $eventRepository;
        $this->searchService = $searchService;
    }

    public function handleLabelEvents(LabelEvents $labelEvents)
    {
        foreach ($labelEvents->getEventIds() as $eventId) {
            $this->labelEvent($labelEvents->getLabel(), $eventId);

$labelEvents->getLabel() of type object<CultuurNet\Entry\Keyword> is not a sub-type of object<CultuurNet\UDB3\Label>. It seems like you assume a child class of the class CultuurNet\Entry\Keyword to be always present.

        }
    }

    public function handleLabelQuery(LabelQuery $labelQuery)
    {
        $query = $labelQuery->getQuery();

        // do a pre query to test if the query is valid and check the item count
        $preQueryResult = $this->searchService->search($query, 1, 0);
        $totalItemCount = $preQueryResult->getTotalItems()->toNative();

        if (0 === $totalItemCount) {
            return;
        }

        // change this pageSize value to increase or decrease the page size;
        $pageSize = 10;
        $pageCount = ceil($totalItemCount / $pageSize);
        $pageCounter = 0;
        $labelledEventIds = [];

        //Page querying the search service;
        while ($pageCounter < $pageCount) {
            $start = $pageCounter * $pageSize;
            // Sort ascending by creation date to make sure we get a quite consistent paging.
            $sort = 'creationdate asc';
            $results = $this->searchService->search(
                $query,
                $pageSize,
                $start,
                $sort
            );

            // Iterate the results of the current page and get their IDs
            // by stripping them from the json-LD representation
            foreach ($results->getItems() as $event) {
                $expoId = explode('/', $event['@id']);
                $eventId = array_pop($expoId);

                if (!array_key_exists($eventId, $labelledEventIds)) {
                    $labelledEventIds[$eventId] = $pageCounter;

                    $this->labelEvent($labelQuery->getLabel(), $eventId);
                } else {
                    if ($this->logger) {
                        $this->logger->error(
                            'query_duplicate_event',
                            array(
                                'query' => $query,
                                'error' => "found duplicate event {$eventId} on page {$pageCounter}, occurred first time on page {$labelledEventIds[$eventId]}"
                            )
                        );
                    }
                }
            }
            ++$pageCounter;
        };
    }

    /**
     * Labels a single event with a keyword.
     *
     * @param Label $label
     * @param $eventId
     */
    private function labelEvent(Label $label, $eventId)
    {
        /** @var Event $event */
        $event = $this->eventRepository->load($eventId);
        $event->label($label);
        try {
            $this->eventRepository->save($event);

            if ($this->logger) {
                $this->logger->info(
                    'event_was_labelled',
                    array(
                        'event_id' => $eventId,
                    )
                );
            }
        } catch (\Exception $e) {
            if ($this->logger) {
                $this->logger->error(
                    'event_was_not_labelled',
                    array(
                        'event_id' => $eventId,
                        'error' => $e->getMessage(),
                        'exception_class' => get_class($e),
                    )
                );
            }
        }
    }

    public function handleTranslateTitle(TranslateTitle $translateTitle)
    {
        /** @var Event $event */
        $event = $this->eventRepository->load($translateTitle->getId());

        $event->translateTitle(
            $translateTitle->getLanguage(),
            $translateTitle->getTitle()
        );

        $this->eventRepository->save($event);
    }

    public function handleTranslateDescription(
        TranslateDescription $translateDescription
    ) {

        /** @var Event $event */
        $event = $this->eventRepository->load($translateDescription->getId());

        $event->translateDescription(
            $translateDescription->getLanguage(),
            $translateDescription->getDescription()
        );

        $this->eventRepository->save($event);
    }

    /**
     * Handle an update command to update the main description.
     */
    public function handleUpdateDescription(UpdateDescription $updateDescription)
    {

        /** @var Event $event */
        $event = $this->eventRepository->load($updateDescription->getId());

        $event->updateDescription(
            $updateDescription->getDescription()
        );

        $this->eventRepository->save($event);

    }

    /**
     * Handle an update command to update the typical age range.
     */
    public function handleUpdateTypicalAgeRange(UpdateTypicalAgeRange $updateTypicalAgeRange)
    {

        /** @var Event $event */
        $event = $this->eventRepository->load($updateTypicalAgeRange->getId());

        $event->updateTypicalAgeRange(
            $updateTypicalAgeRange->getTypicalAgeRange()
        );

        $this->eventRepository->save($event);

    }

    /**
     * Handle the deletion of typical age range on an event.
     */
    public function handleDeleteTypicalAgeRange(DeleteTypicalAgeRange $deleteTypicalAgeRange)
    {

        /** @var Event $event */
        $event = $this->eventRepository->load($deleteTypicalAgeRange->getId());

        $event->deleteTypicalAgeRange();

        $this->eventRepository->save($event);

    }

    /**
     * Handle an update command to update organizer.
     */
    public function handleUpdateOrganizer(UpdateOrganizer $updateOrganizer)
    {

        /** @var Event $event */
        $event = $this->eventRepository->load($updateOrganizer->getId());

        $event->updateOrganizer(
            $updateOrganizer->getOrganizerId()
        );

        $this->eventRepository->save($event);

    }

    /**
     * Handle an update command to delete the organizer.
     */
    public function handleDeleteOrganizer(DeleteOrganizer $deleteOrganizer)
    {

        /** @var Event $event */
        $event = $this->eventRepository->load($deleteOrganizer->getId());

        $event->deleteOrganizer(
            $deleteOrganizer->getOrganizerId()
        );

        $this->eventRepository->save($event);

    }

    /**
     * Handle an update command to updated the contact point.
     */
    public function handleUpdateContactPoint(UpdateContactPoint $updateContactPoint)
    {

        /** @var Event $event */
        $event = $this->eventRepository->load($updateContactPoint->getId());

        $event->updateContactPoint(
            $updateContactPoint->getContactPoint()
        );

        $this->eventRepository->save($event);

    }

    /**
     * Handle an update command to updated the booking info.
     */
    public function handleUpdateBookingInfo(UpdateBookingInfo $updateBookingInfo)
    {

        /** @var Event $event */
        $event = $this->eventRepository->load($updateBookingInfo->getId());

        $event->updateBookingInfo(
            $updateBookingInfo->getBookingInfo()
        );

        $this->eventRepository->save($event);

    }

    /**
     * Handle an add image command.
     * @param AddImage $addImage
     */
    public function handleAddImage(AddImage $addImage)
    {

        /** @var Event $event */
        $event = $this->eventRepository->load($addImage->getId());

        $event->addImage(
            $addImage->getImage()
        );

        $this->eventRepository->save($event);

    }

    /**
     * Handle an update image command.
     * @param UpdateImage $updateImage
     */
    public function handleUpdateImage(UpdateImage $updateImage)
    {
        /** @var Event $event */
        $event = $this->eventRepository->load($updateImage->getItemId());

        $event->updateImage($updateImage);

        $this->eventRepository->save($event);
    }

    /**
     * Handle a remove image command.
     * @param RemoveImage $removeImage
     */
    public function handleRemoveImage(RemoveImage $removeImage)
    {
        /** @var Event $event */
        $event = $this->eventRepository->load($removeImage->getItemId());

        $event->removeImage($removeImage->getImage());

        $this->eventRepository->save($event);
    }

    /**
     * Handle an update the major info command.
     */
    public function handleUpdateMajorInfo(UpdateMajorInfo $updateMajorInfo)

This method seems to be duplicated in your project.

    {

        /** @var Event $event */
        $event = $this->eventRepository->load($updateMajorInfo->getId());

        $event->updateMajorInfo(
            $updateMajorInfo->getTitle(),
            $updateMajorInfo->getEventType(),
            $updateMajorInfo->getLocation(),
            $updateMajorInfo->getCalendar(),
            $updateMajorInfo->getTheme()

$updateMajorInfo->getTheme() is of type object<CultuurNet\UDB3\Theme>, but the function expects a object<CultuurNet\UDB3\Event\type>|null.

        );

        $this->eventRepository->save($event);

    }

    /**
     * Handle a delete event command.
     */
    public function handleDeleteEvent(DeleteEvent $deleteEvent)
    {

        /** @var Event $event */
        $event = $this->eventRepository->load($deleteEvent->getId());
        $event->deleteEvent();

        $this->eventRepository->save($event);

    }

    public function handleApplyLabel(ApplyLabel $label)
    {
        /** @var Event $event */
        $event = $this->eventRepository->load($label->getEventId());
        $event->label($label->getLabel());

        $this->eventRepository->save($event);
    }

    public function handleUnlabel(Unlabel $label)
    {
        /** @var Event $event */
        $event = $this->eventRepository->load($label->getEventId());
        $event->unlabel($label->getLabel());

        $this->eventRepository->save($event);
    }
}