Strider2038\JsonRpcClient\Service\ProcessingClient

Complexity

Total Complexity

5

Size/Duplication

Total Lines	49
Duplicated Lines	0 %

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	notify()	0	5	1
A	__construct()	0	4	1
A	call()	0	11	2
A	batch()	0	3	1

<?php
/*
 * This file is part of JSON RPC Client.
 *
 * (c) Igor Lazarev <strider2038@yandex.ru>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Strider2038\JsonRpcClient\Service;

use Strider2038\JsonRpcClient\BatchRequestInterface;
use Strider2038\JsonRpcClient\ClientInterface;
use Strider2038\JsonRpcClient\Exception\JsonRpcClientException;
use Strider2038\JsonRpcClient\Request\RequestObjectFactory;

/**
 * Can be used for high-level operations. Remote procedure results returned as response data. On server
 * errors it throws exceptions. It is recommended for use as reliable channel between client and server
 * when errors from server are not expected as normal behaviour. Advantage of this type of client over
 * raw client is automatic ordering of responses for batch requests.
 *
 * @author Igor Lazarev <strider2038@yandex.ru>
 */
class ProcessingClient implements ClientInterface
{
    /** @var RequestObjectFactory */
    private $requestObjectFactory;

    /** @var Caller */
    private $caller;

    public function __construct(RequestObjectFactory $requestObjectFactory, Caller $caller)
    {
        $this->requestObjectFactory = $requestObjectFactory;
        $this->caller = $caller;
    }

    public function batch(): BatchRequestInterface
    {
        return new ProcessingBatchRequester($this->requestObjectFactory, $this->caller);
    }

    /**
     * @param array|object|null $params
     *
     * @throws JsonRpcClientException
     *
     * @return array|object|null
     */
    public function call(string $method, $params = null)
    {
        $result = null;
        $requestObject = $this->requestObjectFactory->createRequest($method, $params);
        $responseObject = $this->caller->call($requestObject);

        if (null !== $responseObject) {
            $result = $responseObject->getResult();
        }

        return $result;
    }

    /**
     * @param array|object|null $params
     *
     * @throws JsonRpcClientException
     */
    public function notify(string $method, $params = null): void
    {
        $notificationObject = $this->requestObjectFactory->createNotification($method, $params);

        $this->caller->call($notificationObject);
    }
}