Strider2038\JsonRpcClient\ClientFactory

Complexity

Total Complexity

6

Size/Duplication

Total Lines	44
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	1

3 Methods

Rating	Name	Duplication	Size	Complexity
A	createClient()	0	22	2
A	__construct()	0	3	1
A	createSerializer()	0	11	3

<?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;

use Psr\Log\LoggerInterface;
use Strider2038\JsonRpcClient\Bridge\Symfony\DependencyInjection\Factory\SerializerFactory;
use Strider2038\JsonRpcClient\Bridge\Symfony\Serialization\SymfonySerializerAdapter;
use Strider2038\JsonRpcClient\Configuration\GeneralOptions;
use Strider2038\JsonRpcClient\Configuration\SerializationOptions;
use Strider2038\JsonRpcClient\Serialization\JsonArraySerializer;
use Strider2038\JsonRpcClient\Serialization\JsonObjectSerializer;
use Strider2038\JsonRpcClient\Serialization\MessageSerializerInterface;
use Strider2038\JsonRpcClient\Transport\MultiTransportFactory;
use Strider2038\JsonRpcClient\Transport\TransportFactoryInterface;

/**
 * @experimental API may be changed
 *
 * @author Igor Lazarev <strider2038@yandex.ru>
 */
class ClientFactory implements ClientFactoryInterface
{
    private TransportFactoryInterface $transportFactory;

    public function __construct(LoggerInterface $logger = null)
    {
        $this->transportFactory = new MultiTransportFactory($logger);
    }

    public function createClient(string $url, array $options = []): ClientInterface
    {
        $generalOptions = GeneralOptions::createFromArray($options);
        $transport = $this->transportFactory->createTransport($url, $generalOptions);
        $clientBuilder = new ClientBuilder($transport);

        $serializationOptions = $generalOptions->getSerializationOptions();

        $clientBuilder->setResultTypesByMethods($serializationOptions->getResultTypesByMethods());
        $clientBuilder->setDefaultErrorType($serializationOptions->getDefaultErrorType());

        $serializerType = $serializationOptions->getSerializerType();
        $serializer = $this->createSerializer($serializerType);
        $clientBuilder->setSerializer($serializer);

        if ($generalOptions->isResponseProcessingEnabled()) {
            $clientBuilder->enableResponseProcessing();
        } else {
            $clientBuilder->disableResponseProcessing();
        }

        return $clientBuilder->getClient();
    }

    protected function createSerializer(string $serializerType): MessageSerializerInterface
    {
        if (SerializationOptions::OBJECT_SERIALIZER === $serializerType) {
            $serializer = new JsonObjectSerializer();
        } elseif (SerializationOptions::SYMFONY_SERIALIZER === $serializerType) {
            $serializer = new SymfonySerializerAdapter(SerializerFactory::createSerializer());
        } else {
            $serializer = new JsonArraySerializer();
        }

        return $serializer;
    }
}