PEIP\Gateway\SimpleMessagingGateway

Complexity

Total Complexity

17

Size/Duplication

Total Lines	145
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	5
Bugs	5	Features	0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	2
A	setRequestChannel()	0	4	1
A	setReplyChannel()	0	7	2
A	send()	0	4	1
A	receive()	0	10	3
A	sendAndReceive()	0	11	2
A	buildMessage()	0	4	1
A	getMessageBuilder()	0	6	3
A	setMessageClass()	0	4	1
A	getMessageClass()	0	4	1

<?php

namespace PEIP\Gateway;

/*
 * This file is part of the PEIP package.
 * (c) 2009-2016 Timo Michna <timomichna/yahoo.de>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

/*
 * SimpleMessagingGateway
 * Basic implementation of a messaging gateway
 *
 * @author Timo Michna <timomichna/yahoo.de>
 * @package PEIP
 * @subpackage gateway
 * @implements \PEIP\INF\Gateway\MessagingGateway, \PEIP\INF\Message\MessageBuilder
 */

use PEIP\Message\MessageBuilder;

class SimpleMessagingGateway implements
        \PEIP\INF\Gateway\MessagingGateway,
        \PEIP\INF\Message\MessageBuilder
{
    protected $requestChannel,
        $replyChannel,
        $messageClass = '\PEIP\Message\GenericMessage',
        $defaultHeaders,
        $messageBuilder;

    /**
     * constructor.
     *
     * @param \PEIP\INF\Channel\Channel         $requestChannel The default channel to send requests from the gateway
     * @param \PEIP\INF\Channel\PollableChannel $replyChannel   The default channel to receive requests from the gateway
     * @param array                             $defaultHeaders The default headers to apply to request messages
     */
    public function __construct(\PEIP\INF\Channel\Channel $requestChannel, \PEIP\INF\Channel\Channel $replyChannel = null, array $defaultHeaders = [])
    {
        $this->setRequestChannel($requestChannel);
        if ($replyChannel) {
            $this->setReplyChannel($replyChannel);
        }
        $this->defaultHeaders = $defaultHeaders;
        $this->messageBuilder = MessageBuilder::getInstance($this->messageClass);
    }

    /**
     * sets the channel to send requests from the gateway.
     *
     * @return
     */
    public function setRequestChannel(\PEIP\INF\Channel\Channel $requestChannel)
    {
        $this->requestChannel = $requestChannel;
    }

    /**
     * sets the default channel to receive requests from the gateway.
     *
     * @param \PEIP\INF\Channel\PollableChannel $replyChannel The default channel to receive requests from the gateway
     *
     * @return
     */
    public function setReplyChannel(\PEIP\INF\Channel\Channel $replyChannel)
    {
        if (!($replyChannel instanceof \PEIP\INF\Channel\PollableChannel)) {
            throw new \InvalidArgumentException('reply channel must be instance of \PEIP\INF\Channel\PollableChannel.');
        }
        $this->replyChannel = $replyChannel;
    }

    /**
     * sends a request/message through the gateway.
     *
     * @param mixed $content the content/payload for the message to send
     *
     * @return
     */
    public function send($content)
    {
        return $this->requestChannel->send($this->buildMessage($content));
    }

    /**
     * receives a request/message from the gateway.
     *
     * @return mixed content/payload of the received message
     */
    public function receive()
    {
        if (!isset($this->replyChannel)) {
            throw new \LogicException('No replyChannel set.');
        }
        $message = $this->replyChannel->receive();
        if ($message) {
            return $message->getContent();
        }
    }

    /**
     * sends and receives a request/message through the gateway.
     *
     * @param \Order $content the content/payload for the message to send
     *
     * @return mixed content/payload of the received message
     */
    public function sendAndReceive($content)
    {
        $this->send($content);
        try {
            $res = $this->receive();
        } catch (\Exception $e) {
            return;
        }

        return $res;
    }

    /**
     * builds the message to send from given content/payload.
     *
     * @param mixed $content the content/payload for the message to send
     *
     * @return \PEIP\INF\Message\Message the built message
     */
    protected function buildMessage($content)
    {
        return $this->getMessageBuilder()->setContent($content)->build();
    }

    /**
     * returns the message builder instance for the registerd message class.
     *
     * @return MessageBuilder message builder instance for the registerd message class
     */
    protected function getMessageBuilder()
    {
        return isset($this->messageBuilder) && ($this->messageBuilder->getMessageClass() == $this->getMessageClass())
            ? $this->messageBuilder
            : $this->messageBuilder = MessageBuilder::getInstance($this->messageClass)->setHeaders($this->defaultHeaders);
    }

    /**
     * registers the message class to create instances from by the gateway.
     *
     * @param string $messageClass message class to create instances from
     *
     * @return
     */
    public function setMessageClass($messageClass)
    {
        $this->messageClass = $messageClass;
    }

    /**
     * returns the message class to create instances from.
     *
     * @return string message class to create instances from
     */
    public function getMessageClass()
    {
        return $this->messageClass;
    }
}