PSB\Core\MessageMutation\Pipeline\Outgoing\OutgoingPhysicalMessageMutationPipelineStep

Complexity

Total Complexity

5

Size/Duplication

Total Lines	56
Duplicated Lines	100 %

Coupling/Cohesion

Components	1
Dependencies	6

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	4	4	1
A	invoke()	26	26	3
A	getStageContextClass()	4	4	1

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


use PSB\Core\MessageMutatorRegistry;
use PSB\Core\Pipeline\Outgoing\StageContext\OutgoingPhysicalMessageContext;
use PSB\Core\Pipeline\PipelineStepInterface;

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

    /**
     * IncomingPhysicalMessageMutationPipelineStep constructor.
     *
     * @param MessageMutatorRegistry $mutatorRegistry
     */
    public function __construct(MessageMutatorRegistry $mutatorRegistry)
    {
        $this->mutatorRegistry = $mutatorRegistry;
    }

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

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

        $physicalMessage = $context->getMessage();
        $mutatorContext = new OutgoingPhysicalMessageMutationContext(
            $physicalMessage->getBody(),
            $physicalMessage->getHeaders()
        );

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

        $physicalMessage->replaceBody($mutatorContext->getBody());
        $physicalMessage->replaceHeaders($mutatorContext->getHeaders());

        $next();
    }

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