PSB\Core\MessageMutation\Pipeline\Incoming\IncomingLogicalMessageMutationPipelineStep

Complexity

Total Complexity

6

Size/Duplication

Total Lines	62
Duplicated Lines	43.55 %

Coupling/Cohesion

Components	1
Dependencies	6

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	invoke()	27	27	4
A	getStageContextClass()	0	4	1

<?php
namespace PSB\Core\MessageMutation\Pipeline\Incoming;


use PSB\Core\MessageMutatorRegistry;
use PSB\Core\Pipeline\Incoming\IncomingLogicalMessageFactory;
use PSB\Core\Pipeline\Incoming\StageContext\IncomingLogicalMessageContext;
use PSB\Core\Pipeline\PipelineStepInterface;

class IncomingLogicalMessageMutationPipelineStep implements PipelineStepInterface
{
    /**
     * @var MessageMutatorRegistry
     */
    private $mutatorRegistry;

    /**
     * @var IncomingLogicalMessageFactory
     */
    private $messageFactory;

    /**
     * @param MessageMutatorRegistry        $mutatorRegistry
     * @param IncomingLogicalMessageFactory $messageFactory
     */
    public function __construct(MessageMutatorRegistry $mutatorRegistry, IncomingLogicalMessageFactory $messageFactory)
    {
        $this->mutatorRegistry = $mutatorRegistry;
        $this->messageFactory = $messageFactory;
    }

    /**
     * @param IncomingLogicalMessageContext $context
     * @param callable                      $next
     */
    public function invoke($context, callable $next)
    {
        $mutatorIds = $this->mutatorRegistry->getIncomingLogicalMessageMutatorIds();

        if (empty($mutatorIds)) {
            $next();
            return;
        }

        $logicalMessage = $context->getMessage();
        $messageInstance = $logicalMessage->getMessageInstance();

        $mutatorContext = new IncomingLogicalMessageMutationContext($messageInstance, $context->getHeaders());

        foreach ($mutatorIds as $mutatorId) {
            /** @var IncomingLogicalMessageMutatorInterface $mutator */
            $mutator = $context->getBuilder()->build($mutatorId);
            $mutator->mutateIncoming($mutatorContext);
        }

        if ($mutatorContext->hasMessageChanged()) {
            $logicalMessage->updateInstance($mutatorContext->getMessage(), $this->messageFactory);
        }
        $context->replaceHeaders($mutatorContext->getHeaders());

        $next();
    }

    /**
     * @return string
     */
    public static function getStageContextClass()
    {
        return IncomingLogicalMessageContext::class;
    }
}