Client::__construct() - Code Metrics - Inspection of "Support box.cfg.listen URI format in tests" - tarantool-php/client - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 29a805...bdeb81 )

by Eugene

created 2020-05-07 22:17 UTC

Client::__construct() A

↳ Parent: Client

Complexity

Conditions	1
Paths	1

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	2

Importance

Changes

Metric	Value
cc	1
nc	1
nop	1
dl	0
loc	4
ccs	0
cts	4
cp	0
crap	2
rs	10
c	0
b	0
f	0

<?php

/**
 * This file is part of the Tarantool Client package.
 *
 * (c) Eugene Leonovich <[email protected]>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

declare(strict_types=1);

namespace Tarantool\Client;

use Tarantool\Client\Connection\StreamConnection;
use Tarantool\Client\Exception\RequestFailed;
use Tarantool\Client\Handler\DefaultHandler;
use Tarantool\Client\Handler\Handler;
use Tarantool\Client\Handler\MiddlewareHandler;
use Tarantool\Client\Middleware\AuthenticationMiddleware;
use Tarantool\Client\Middleware\Middleware;
use Tarantool\Client\Middleware\RetryMiddleware;
use Tarantool\Client\Packer\Packer;
use Tarantool\Client\Packer\PackerFactory;
use Tarantool\Client\Request\CallRequest;
use Tarantool\Client\Request\EvaluateRequest;
use Tarantool\Client\Request\ExecuteRequest;
use Tarantool\Client\Request\PingRequest;
use Tarantool\Client\Request\PrepareRequest;
use Tarantool\Client\Schema\Criteria;
use Tarantool\Client\Schema\Space;

final class Client
{
    /** @var Handler */
    private $handler;

    /** @var array<array-key, Space> */
    private $spaces = [];

    public function __construct(Handler $handler)
    {
        $this->handler = $handler;
    }

    public static function fromDefaults() : self
    {
        return new self(new DefaultHandler(
            StreamConnection::createTcp(),
            PackerFactory::create()
        ));
    }

    public static function fromOptions(array $options, ?Packer $packer = null) : self
    {
        $connectionOptions = [];
        if (isset($options['connect_timeout'])) {
            $connectionOptions['connect_timeout'] = $options['connect_timeout'];
        }
        if (isset($options['socket_timeout'])) {
            $connectionOptions['socket_timeout'] = $options['socket_timeout'];
        }
        if (isset($options['tcp_nodelay'])) {
            $connectionOptions['tcp_nodelay'] = $options['tcp_nodelay'];
        }
        if (isset($options['persistent'])) {
            $connectionOptions['persistent'] = $options['persistent'];
        }

        $connection = StreamConnection::create($options['uri'] ?? StreamConnection::DEFAULT_URI, $connectionOptions);
        $handler = new DefaultHandler($connection, $packer ?? PackerFactory::create());

        if (isset($options['max_retries']) && 0 !== $options['max_retries']) {
            $handler = MiddlewareHandler::create($handler, RetryMiddleware::linear($options['max_retries']));
        }
        if (isset($options['username'])) {
            $handler = MiddlewareHandler::create($handler, new AuthenticationMiddleware($options['username'], $options['password'] ?? ''));
        }

        return new self($handler);
    }

    public static function fromDsn(string $dsn, ?Packer $packer = null) : self
    {
        $dsn = Dsn::parse($dsn);

        $connectionOptions = [];
        if (null !== $timeout = $dsn->getInt('connect_timeout')) {
            $connectionOptions['connect_timeout'] = $timeout;
        }
        if (null !== $timeout = $dsn->getInt('socket_timeout')) {
            $connectionOptions['socket_timeout'] = $timeout;
        }
        if (null !== $tcpNoDelay = $dsn->getBool('tcp_nodelay')) {
            $connectionOptions['tcp_nodelay'] = $tcpNoDelay;
        }
        if (null !== $persistent = $dsn->getBool('persistent')) {
            $connectionOptions['persistent'] = $persistent;
        }

        $connection = $dsn->isTcp()
            ? StreamConnection::createTcp($dsn->getConnectionUri(), $connectionOptions)
            : StreamConnection::createUds($dsn->getConnectionUri(), $connectionOptions);

        $handler = new DefaultHandler($connection, $packer ?? PackerFactory::create());

        if ($maxRetries = $dsn->getInt('max_retries')) {
            $handler = MiddlewareHandler::create($handler, RetryMiddleware::linear($maxRetries));
        }
        if ($username = $dsn->getUsername()) {
            $handler = MiddlewareHandler::create($handler, new AuthenticationMiddleware($username, $dsn->getPassword() ?? ''));
        }

        return new self($handler);
    }

    public function withMiddleware(Middleware $middleware, Middleware ...$middlewares) : self
    {
        $new = clone $this;
        $new->handler = MiddlewareHandler::create($new->handler, $middleware, ...$middlewares);

        return $new;
    }

    public function getHandler() : Handler
    {
        return $this->handler;
    }

    public function getSpace(string $spaceName) : Space
    {
        if (isset($this->spaces[$spaceName])) {
            return $this->spaces[$spaceName];
        }

        $spaceId = $this->getSpaceIdByName($spaceName);

        return $this->spaces[$spaceName] = $this->spaces[$spaceId] = new Space($this->handler, $spaceId);
    }

    public function getSpaceById(int $spaceId) : Space
    {
        if (isset($this->spaces[$spaceId])) {
            return $this->spaces[$spaceId];
        }

        return $this->spaces[$spaceId] = new Space($this->handler, $spaceId);
    }

    public function ping() : void
    {
        $this->handler->handle(new PingRequest());
    }

    /**
     * @param mixed ...$args
     */
    public function call(string $funcName, ...$args) : array
    {
        return $this->handler->handle(new CallRequest($funcName, $args))
            ->getBodyField(Keys::DATA);
    }

    /**
     * @param mixed ...$args
     */
    public function evaluate(string $expr, ...$args) : array
    {
        return $this->handler->handle(new EvaluateRequest($expr, $args))
            ->getBodyField(Keys::DATA);
    }

    /**
     * @param mixed ...$params
     */
    public function execute(string $sql, ...$params) : Response
    {
        return $this->handler->handle(ExecuteRequest::fromSql($sql, $params));
    }

    /**
     * @param mixed ...$params
     */
    public function executeQuery(string $sql, ...$params) : SqlQueryResult
    {
        $response = $this->handler->handle(ExecuteRequest::fromSql($sql, $params));

        return new SqlQueryResult(
            $response->getBodyField(Keys::DATA),
            $response->getBodyField(Keys::METADATA)
        );
    }

    /**
     * @param mixed ...$params
     */
    public function executeUpdate(string $sql, ...$params) : SqlUpdateResult
    {
        $response = $this->handler->handle(ExecuteRequest::fromSql($sql, $params));

        return new SqlUpdateResult($response->getBodyField(Keys::SQL_INFO));
    }

    public function prepare(string $sql) : PreparedStatement
    {
        $response = $this->handler->handle(PrepareRequest::fromSql($sql));

        return new PreparedStatement(
            $this->handler,
            $response->getBodyField(Keys::STMT_ID),
            $response->getBodyField(Keys::BIND_COUNT),
            $response->getBodyField(Keys::BIND_METADATA),
            $response->tryGetBodyField(Keys::METADATA, [])
        );
    }

    public function flushSpaces() : void
    {
        $this->spaces = [];
    }

    public function __clone()
    {
        $this->spaces = [];
    }

    private function getSpaceIdByName(string $spaceName) : int
    {
        $schema = $this->getSpaceById(Space::VSPACE_ID);
        $data = $schema->select(Criteria::key([$spaceName])->andIndex(Space::VSPACE_NAME_INDEX));

        if ($data) {

            return $data[0][0];
        }

        throw RequestFailed::unknownSpace($spaceName);
    }
}


1			<?php
2
3			/**
4			* This file is part of the Tarantool Client package.
5			*
6			* (c) Eugene Leonovich <[email protected]>
7			*
8			* For the full copyright and license information, please view the LICENSE
9			* file that was distributed with this source code.
10			*/
11
12			declare(strict_types=1);
13
14			namespace Tarantool\Client;
15
16			use Tarantool\Client\Connection\StreamConnection;
17			use Tarantool\Client\Exception\RequestFailed;
18			use Tarantool\Client\Handler\DefaultHandler;
19			use Tarantool\Client\Handler\Handler;
20			use Tarantool\Client\Handler\MiddlewareHandler;
21			use Tarantool\Client\Middleware\AuthenticationMiddleware;
22			use Tarantool\Client\Middleware\Middleware;
23			use Tarantool\Client\Middleware\RetryMiddleware;
24			use Tarantool\Client\Packer\Packer;
25			use Tarantool\Client\Packer\PackerFactory;
26			use Tarantool\Client\Request\CallRequest;
27			use Tarantool\Client\Request\EvaluateRequest;
28			use Tarantool\Client\Request\ExecuteRequest;
29			use Tarantool\Client\Request\PingRequest;
30			use Tarantool\Client\Request\PrepareRequest;
31			use Tarantool\Client\Schema\Criteria;
32			use Tarantool\Client\Schema\Space;
33
34			final class Client
35			{
36			/** @var Handler */
37			private $handler;
38
39			/** @var array<array-key, Space> */
40			private $spaces = [];
41
42			public function __construct(Handler $handler)
43			{
44			$this->handler = $handler;
45			}
46
47			public static function fromDefaults() : self
48			{
49			return new self(new DefaultHandler(
50			StreamConnection::createTcp(),
51			PackerFactory::create()
52			));
53			}
54
55			public static function fromOptions(array $options, ?Packer $packer = null) : self
56			{
57			$connectionOptions = [];
58			if (isset($options['connect_timeout'])) {
59			$connectionOptions['connect_timeout'] = $options['connect_timeout'];
60			}
61			if (isset($options['socket_timeout'])) {
62			$connectionOptions['socket_timeout'] = $options['socket_timeout'];
63			}
64			if (isset($options['tcp_nodelay'])) {
65			$connectionOptions['tcp_nodelay'] = $options['tcp_nodelay'];
66			}
67			if (isset($options['persistent'])) {
68			$connectionOptions['persistent'] = $options['persistent'];
69			}
70
71			$connection = StreamConnection::create($options['uri'] ?? StreamConnection::DEFAULT_URI, $connectionOptions);
72			$handler = new DefaultHandler($connection, $packer ?? PackerFactory::create());
73
74			if (isset($options['max_retries']) && 0 !== $options['max_retries']) {
75			$handler = MiddlewareHandler::create($handler, RetryMiddleware::linear($options['max_retries']));
76			}
77			if (isset($options['username'])) {
78			$handler = MiddlewareHandler::create($handler, new AuthenticationMiddleware($options['username'], $options['password'] ?? ''));
79			}
80
81			return new self($handler);
82			}
83
84			public static function fromDsn(string $dsn, ?Packer $packer = null) : self
85			{
86			$dsn = Dsn::parse($dsn);
87
88			$connectionOptions = [];
89			if (null !== $timeout = $dsn->getInt('connect_timeout')) {
90			$connectionOptions['connect_timeout'] = $timeout;
91			}
92			if (null !== $timeout = $dsn->getInt('socket_timeout')) {
93			$connectionOptions['socket_timeout'] = $timeout;
94			}
95			if (null !== $tcpNoDelay = $dsn->getBool('tcp_nodelay')) {
96			$connectionOptions['tcp_nodelay'] = $tcpNoDelay;
97			}
98			if (null !== $persistent = $dsn->getBool('persistent')) {
99			$connectionOptions['persistent'] = $persistent;
100			}
101
102			$connection = $dsn->isTcp()
103			? StreamConnection::createTcp($dsn->getConnectionUri(), $connectionOptions)
104			: StreamConnection::createUds($dsn->getConnectionUri(), $connectionOptions);
105
106			$handler = new DefaultHandler($connection, $packer ?? PackerFactory::create());
107
108			if ($maxRetries = $dsn->getInt('max_retries')) {
109			$handler = MiddlewareHandler::create($handler, RetryMiddleware::linear($maxRetries));
110			}
111			if ($username = $dsn->getUsername()) {
112			$handler = MiddlewareHandler::create($handler, new AuthenticationMiddleware($username, $dsn->getPassword() ?? ''));
113			}
114
115			return new self($handler);
116			}
117
118			public function withMiddleware(Middleware $middleware, Middleware ...$middlewares) : self
119			{
120			$new = clone $this;
121			$new->handler = MiddlewareHandler::create($new->handler, $middleware, ...$middlewares);
122
123			return $new;
124			}
125
126			public function getHandler() : Handler
127			{
128			return $this->handler;
129			}
130
131			public function getSpace(string $spaceName) : Space
132			{
133			if (isset($this->spaces[$spaceName])) {
134			return $this->spaces[$spaceName];
135			}
136
137			$spaceId = $this->getSpaceIdByName($spaceName);
138
139			return $this->spaces[$spaceName] = $this->spaces[$spaceId] = new Space($this->handler, $spaceId);
140			}
141
142			public function getSpaceById(int $spaceId) : Space
143			{
144			if (isset($this->spaces[$spaceId])) {
145			return $this->spaces[$spaceId];
146			}
147
148			return $this->spaces[$spaceId] = new Space($this->handler, $spaceId);
149			}
150
151			public function ping() : void
152			{
153			$this->handler->handle(new PingRequest());
154			}
155
156			/**
157			* @param mixed ...$args
158			*/
159			public function call(string $funcName, ...$args) : array
160			{
161			return $this->handler->handle(new CallRequest($funcName, $args))
162			->getBodyField(Keys::DATA);
163			}
164
165			/**
166			* @param mixed ...$args
167			*/
168			public function evaluate(string $expr, ...$args) : array
169			{
170			return $this->handler->handle(new EvaluateRequest($expr, $args))
171			->getBodyField(Keys::DATA);
172			}
173
174			/**
175			* @param mixed ...$params
176			*/
177			public function execute(string $sql, ...$params) : Response
178			{
179			return $this->handler->handle(ExecuteRequest::fromSql($sql, $params));
180			}
181
182			/**
183			* @param mixed ...$params
184			*/
185			public function executeQuery(string $sql, ...$params) : SqlQueryResult
186			{
187			$response = $this->handler->handle(ExecuteRequest::fromSql($sql, $params));
188
189			return new SqlQueryResult(
190			$response->getBodyField(Keys::DATA),
191			$response->getBodyField(Keys::METADATA)
192			);
193			}
194
195			/**
196			* @param mixed ...$params
197			*/
198			public function executeUpdate(string $sql, ...$params) : SqlUpdateResult
199			{
200			$response = $this->handler->handle(ExecuteRequest::fromSql($sql, $params));
201
202			return new SqlUpdateResult($response->getBodyField(Keys::SQL_INFO));
203			}
204
205			public function prepare(string $sql) : PreparedStatement
206			{
207			$response = $this->handler->handle(PrepareRequest::fromSql($sql));
208
209			return new PreparedStatement(
210			$this->handler,
211			$response->getBodyField(Keys::STMT_ID),
212			$response->getBodyField(Keys::BIND_COUNT),
213			$response->getBodyField(Keys::BIND_METADATA),
214			$response->tryGetBodyField(Keys::METADATA, [])
215			);
216			}
217
218			public function flushSpaces() : void
219			{
220			$this->spaces = [];
221			}
222
223			public function __clone()
224			{
225			$this->spaces = [];
226			}
227
228			private function getSpaceIdByName(string $spaceName) : int
229			{
230			$schema = $this->getSpaceById(Space::VSPACE_ID);
231			$data = $schema->select(Criteria::key([$spaceName])->andIndex(Space::VSPACE_NAME_INDEX));
232
233			if ($data) {
			0 ignored issues – show Bug Best Practice introduced 2020-03-19 00:26 UTC by Report Bug Copy Issue Report The expression `$data` of type `array` is implicitly converted to a boolean; are you sure this is intended? If so, consider using `! empty($expr)` instead to make it clear that you intend to check for an array without elements. This check marks implicit conversions of arrays to boolean values in a comparison. While in PHP an empty array is considered to be equal (but not identical) to false, this is not always apparent. Consider making the comparison explicit by using `empty(..)` or `! empty(...)` instead. Loading history...
234			return $data[0][0];
235			}
236
237			throw RequestFailed::unknownSpace($spaceName);
238			}
239			}
240

tarantool-php / client

Push — master ( 29a805...bdeb81 )

Client::__construct() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like