PSB\Core\Pipeline\Incoming\IncomingContextFactory

Complexity

Total Complexity

4

Size/Duplication

Total Lines	91
Duplicated Lines	36.26 %

Coupling/Cohesion

Components	1
Dependencies	7

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	createPhysicalMessageContext()	0	14	1
A	createLogicalMessageContext()	16	16	1
A	createInvokeHandlerContext()	17	17	1

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


use PSB\Core\MessageHandlerInterface;
use PSB\Core\OutgoingOptionsFactory;
use PSB\Core\Pipeline\BusOperations;
use PSB\Core\Pipeline\Incoming\StageContext\IncomingLogicalMessageContext;
use PSB\Core\Pipeline\Incoming\StageContext\IncomingPhysicalMessageContext;
use PSB\Core\Pipeline\Incoming\StageContext\InvokeHandlerContext;
use PSB\Core\Pipeline\Incoming\StageContext\TransportReceiveContext;
use PSB\Core\Pipeline\PendingTransportOperations;

class IncomingContextFactory
{
    /**
     * @var BusOperations
     */
    private $busOperations;

    /**
     * @var OutgoingOptionsFactory
     */
    private $outgoingOptionsFactory;

    /**
     * @param BusOperations          $busOperations
     * @param OutgoingOptionsFactory $outgoingOptionsFactory
     */
    public function __construct(
        BusOperations $busOperations,
        OutgoingOptionsFactory $outgoingOptionsFactory
    ) {
        $this->busOperations = $busOperations;
        $this->outgoingOptionsFactory = $outgoingOptionsFactory;
    }

    /**
     * @param TransportReceiveContext $parentContext
     *
     * @return IncomingPhysicalMessageContext
     */
    public function createPhysicalMessageContext(TransportReceiveContext $parentContext)
    {
        $physicalMessage = $parentContext->getMessage();
        return new IncomingPhysicalMessageContext(
            $physicalMessage,
            $physicalMessage->getMessageId(),
            $physicalMessage->getHeaders(),
            new PendingTransportOperations(),
            $this->busOperations,
            $this->outgoingOptionsFactory,
            $parentContext->getEndpointControlToken(),
            $parentContext
        );
    }

    /**
     * @param IncomingLogicalMessage         $logicalMessage
     * @param IncomingPhysicalMessageContext $parentContext
     *
     * @return IncomingLogicalMessageContext
     */
    public function createLogicalMessageContext(
        IncomingLogicalMessage $logicalMessage,
        IncomingPhysicalMessageContext $parentContext
    ) {
        return new IncomingLogicalMessageContext(
            $logicalMessage,
            $parentContext->getMessageId(),
            $parentContext->getHeaders(),
            $parentContext->getIncomingPhysicalMessage(),
            $parentContext->getPendingTransportOperations(),
            $this->busOperations,
            $this->outgoingOptionsFactory,
            $parentContext->getEndpointControlToken(),
            $parentContext
        );
    }

    /**
     * @param MessageHandlerInterface       $messageHandler
     * @param IncomingLogicalMessageContext $parentContext
     *
     * @return InvokeHandlerContext
     */
    public function createInvokeHandlerContext(
        MessageHandlerInterface $messageHandler,
        IncomingLogicalMessageContext $parentContext
    ) {
        return new InvokeHandlerContext(
            $messageHandler,
            $parentContext->getMessage()->getMessageInstance(),
            $parentContext->getMessageId(),
            $parentContext->getHeaders(),
            $parentContext->getIncomingPhysicalMessage(),
            $parentContext->getPendingTransportOperations(),
            $this->busOperations,
            $this->outgoingOptionsFactory,
            $parentContext->getEndpointControlToken(),
            $parentContext
        );
    }
}