Strider2038\JsonRpcClient\Transport\Socket\SocketConnector

Complexity

Total Complexity

4

Size/Duplication

Total Lines	26
Duplicated Lines	0 %

Test Coverage

Coverage

63.64%

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	wait()	0	3	1
A	open()	0	16	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\Transport\Socket;

use Strider2038\JsonRpcClient\Exception\ConnectionFailedException;

/**
 * @internal
 *
 * @author Igor Lazarev <strider2038@yandex.ru>
 */
class SocketConnector
{
    /**
     * @throws ConnectionFailedException
     */
    public function open(string $url, int $connectionTimeoutUs, int $requestTimeoutUs): SocketConnection
    {
        $errorCode = null;
        $errorDescription = null;

        $stream = @stream_socket_client($url, $errorCode, $errorDescription, (float) $connectionTimeoutUs / 1000000);

        if (!is_resource($stream)) {
            throw new ConnectionFailedException($url, sprintf('%d: %s', $errorCode, $errorDescription));
        }

        if (false === stream_set_timeout($stream, 0, $requestTimeoutUs)) {
            throw new ConnectionFailedException($url, 'failed to set request timeout');
        }

        return new SocketConnection($stream, $url, $requestTimeoutUs);
    }

    public function wait(int $us): void
    {
        usleep($us);
    }
}