ConferenceTools\Checkin\Domain\ProcessManager\ImportPurchase

Complexity

Total Complexity

7

Size/Duplication

Total Lines	46
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	handleDelegateRegistered()	0	5	1
A	loadProcess()	0	9	2
A	handleTicketAssigned()	0	5	1
A	handleTicketPurchasePaid()	0	5	1
A	__construct()	0	3	1
A	handleTicketCreated()	0	5	1

<?php

namespace ConferenceTools\Checkin\Domain\ProcessManager;

use Carnage\Cqrs\MessageHandler\AbstractMethodNameMessageHandler;
use Carnage\Cqrs\Persistence\EventStore\NotFoundException;
use Carnage\Cqrs\Persistence\Repository\RepositoryInterface;
use ConferenceTools\Checkin\Domain\Event\Delegate\DelegateRegistered;
use ConferenceTools\Checkin\Domain\Event\Purchase\TicketAssigned;
use ConferenceTools\Checkin\Domain\Event\Purchase\TicketCreated;
use ConferenceTools\Checkin\Domain\Event\Purchase\TicketPurchasePaid;
use ConferenceTools\Checkin\Domain\Process\ImportPurchase as ImportPurchaseProcess;

class ImportPurchase extends AbstractMethodNameMessageHandler
{
    private $repository;

    public function __construct(RepositoryInterface $repository)
    {
        $this->repository = $repository;
    }

    protected function handleTicketCreated(TicketCreated $event)
    {
        $process = $this->loadProcess($event->getTicket()->getPurchaseId());
        $process->ticketCreated($event);
        $this->repository->save($process);
    }

    protected function handleTicketAssigned(TicketAssigned $event)
    {
        $process = $this->loadProcess($event->getTicket()->getPurchaseId());
        $process->ticketAssigned($event);
        $this->repository->save($process);
    }

    protected function handleTicketPurchasePaid(TicketPurchasePaid $event)
    {
        $process = $this->loadProcess($event->getPurchaseId());
        $process->ticketPurchasePaid($event);
        $this->repository->save($process);
    }

    protected function handleDelegateRegistered(DelegateRegistered $event)
    {
        $process = $this->loadProcess($event->getTicket()->getPurchaseId());
        $process->delegateRegistered($event);
        $this->repository->save($process);
    }

    private function loadProcess($id): ImportPurchaseProcess
    {
        try {
            $process = $this->repository->load($id);
        } catch (NotFoundException $e) {
            $process = ImportPurchaseProcess::withId($id);
        }

        return $process;

The expression return $process could return the type Carnage\Cqrs\Aggregate\AggregateInterface which includes types incompatible with the type-hinted return ConferenceTools\Checkin\Domain\Process\ImportPurchase. Consider adding an additional type-check to rule them out.

    }
}