ConferenceTools\Tickets\Cli\Command\TimeoutPurchases

Complexity

Total Complexity

5

Size/Duplication

Total Lines	39
Duplicated Lines	0 %

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	configure()	0	4	1
A	execute()	0	12	3
A	build()	0	7	1

<?php

namespace ConferenceTools\Tickets\Cli\Command;

use Carnage\Cqrs\MessageBus\MessageBusInterface;
use Doctrine\ORM\EntityManagerInterface;
use ConferenceTools\Tickets\Domain\Command\Ticket\TimeoutPurchase;
use ConferenceTools\Tickets\Domain\ReadModel\TicketRecord\PurchaseRecord;
use ConferenceTools\Tickets\Domain\ReadModel\TicketRecord\TicketRecord;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;

class TimeoutPurchases extends Command
{
    /**
     * @var EntityManagerInterface
     */
    private $em;

    /**
     * @var MessageBusInterface
     */
    private $commandBus;

    public static function build(EntityManagerInterface $em, MessageBusInterface $commandBus)
    {
        $instance = new static();
        $instance->em = $em;
        $instance->commandBus = $commandBus;

        return $instance;
    }

    protected function configure()
    {
        $this->setName('tickets:timeout-purchases')
            ->setDescription('Times out all purchases over 30 mins old.');
    }

    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $qb = $this->em->getRepository(PurchaseRecord::class)->createQueryBuilder('pr');
        /** @var PurchaseRecord[] $timedout */
        $timedout = $qb->where('pr.paid = false')
            ->getQuery()
            ->getResult();

        foreach ($timedout as $ticketRecord) {
            if ($ticketRecord->hasTimedout()) {
                $command = new TimeoutPurchase($ticketRecord->getPurchaseId());
                $this->commandBus->dispatch($command);
            }
        }
    }

}