Aggrego\CommandLogicUnit\EventConsumer\Client

Complexity

Total Complexity

3

Size/Duplication

Total Lines	28
Duplicated Lines	0 %

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	consume()	0	4	2
A	__construct()	0	6	1

<?php
/**
 *
 * This file is part of the Aggrego.
 * (c) Tomasz Kunicki <kunicki.tomasz@gmail.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 *
 */

declare(strict_types = 1);

namespace Aggrego\CommandLogicUnit\EventConsumer;

use Aggrego\CommandConsumer\Client as CommandConsumerClient;
use Aggrego\CommandLogicUnit\EventProcessor\EventProcessor;
use Aggrego\EventConsumer\Client as EventConsumerClient;
use Aggrego\EventConsumer\Event;
use Aggrego\EventConsumer\Exception\UnprocessableEventException;

class Client implements EventConsumerClient
{
    /**
     * @var EventProcessor
     */
    private $eventProcessor;

    /**
     * @var CommandConsumerClient
     */
    private $commandConsumer;

    public function __construct(
        EventProcessor $eventProcessor,
        CommandConsumerClient $commandConsumer
    ) {
        $this->eventProcessor = $eventProcessor;
        $this->commandConsumer = $commandConsumer;
    }

    /**
     * @param  Event $event
     * @throws UnprocessableEventException if event (payload) have invalid structure.
     */
    public function consume(Event $event): void
    {
        foreach ($this->eventProcessor->transform($event) as $command) {
            $this->commandConsumer->consume($command);
        }
    }
}